1 files changed, 74 insertions, 51 deletions

diff --git a/src/jrummikub/control/network/ConnectionControl.java b/src/jrummikub/control/network/ConnectionControl.java
index c63259d..2d8ff60 100644
--- a/src/jrummikub/control/network/ConnectionControl.java
+++ b/src/jrummikub/control/network/ConnectionControl.java
@@ -3,6 +3,8 @@ package jrummikub.control.network;
 import java.awt.Color;
 import java.io.Serializable;
 import java.util.UUID;
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.LinkedBlockingQueue;
 
 import javax.swing.SwingUtilities;
 
@@ -40,7 +42,7 @@ import org.jivesoftware.smackx.muc.DiscussionHistory;
 import org.jivesoftware.smackx.muc.MultiUserChat;
 
 /**
- * Connection control managing network connections, essages and events
+ * Connection control managing network connections, messages and events
  */
 public class ConnectionControl implements IConnectionControl {
 	private static class TurnEndData implements Serializable {
@@ -94,6 +96,8 @@ public class ConnectionControl implements IConnectionControl {
 
 	private GameData currentGame;
 
+	private BlockingQueue<Runnable> actionQueue = new LinkedBlockingQueue<Runnable>();
+
 	private volatile GameData offeredGame;
 
 	/**
@@ -113,6 +117,24 @@ public class ConnectionControl implements IConnectionControl {
 
 	@Override
 	public void connect() {
+		new Thread(new Runnable() {
+			@Override
+			public void run() {
+				while (true) {
+					Runnable runner;
+					try {
+						runner = actionQueue.take();
+						if (runner == null) {
+							return;
+						}
+
+						runner.run();
+					} catch (InterruptedException e) {
+					}
+				}
+			}
+		}).start();
+
 		run(new ConnectRunner());
 	}
 
@@ -123,12 +145,11 @@ public class ConnectionControl implements IConnectionControl {
 		run(new Runnable() {
 			@Override
 			public void run() {
-				synchronized (ConnectionControl.this) {
-					if (connection != null) {
-						connection.disconnect();
-						connection = null;
-					}
+				if (connection != null) {
+					connection.disconnect();
+					connection = null;
 				}
+				ConnectionControl.this.run(null);
 			}
 		});
 	}
@@ -240,7 +261,13 @@ public class ConnectionControl implements IConnectionControl {
 	}
 
 	private void run(Runnable runner) {
-		new Thread(runner).start();
+		while (true) {
+			try {
+				actionQueue.put(runner);
+				return;
+			} catch (InterruptedException e) {
+			}
+		}
 	}
 
 	@Override
@@ -520,46 +547,44 @@ public class ConnectionControl implements IConnectionControl {
 	private class ConnectRunner implements Runnable {
 		@Override
 		public void run() {
-			synchronized (ConnectionControl.this) {
-				ConnectionConfiguration config = new ConnectionConfiguration(
-						loginData.getServerName());
-				config.setSendPresence(false);
-				config.setRosterLoadedAtLogin(false);
-				config.setCompressionEnabled(true);
-
-				connection = new XMPPConnection(config);
-
-				connection.addPacketListener(new PacketListener() {
-					@Override
-					public void processPacket(final Packet packet) {
-						SwingUtilities.invokeLater(new Runnable() {
-							@Override
-							public void run() {
-								ConnectionControl.this.processPacket(packet);
-							}
-						});
-
-					}
-				}, new AndFilter(new PacketTypeFilter(Message.class),
-						new PacketExtensionFilter(ELEMENT_NAME, NAMESPACE)));
+			ConnectionConfiguration config = new ConnectionConfiguration(
+					loginData.getServerName());
+			config.setSendPresence(false);
+			config.setRosterLoadedAtLogin(false);
+			config.setCompressionEnabled(true);
+
+			connection = new XMPPConnection(config);
+
+			connection.addPacketListener(new PacketListener() {
+				@Override
+				public void processPacket(final Packet packet) {
+					SwingUtilities.invokeLater(new Runnable() {
+						@Override
+						public void run() {
+							ConnectionControl.this.processPacket(packet);
+						}
+					});
 
-				LoginError error = doConnect();
-				if (error == null) {
-					error = doLogin();
-				}
-				if (error == null) {
-					error = doJoin();
 				}
+			}, new AndFilter(new PacketTypeFilter(Message.class),
+					new PacketExtensionFilter(ELEMENT_NAME, NAMESPACE)));
 
-				if (error == null) {
-					requestGames();
-					emitLater(connectedEvent);
-				} else {
-					connection.disconnect();
-					connection = null;
+			LoginError error = doConnect();
+			if (error == null) {
+				error = doLogin();
+			}
+			if (error == null) {
+				error = doJoin();
+			}
 
-					emitLater(connectionFailedEvent, error);
-				}
+			if (error == null) {
+				requestGames();
+				emitLater(connectedEvent);
+			} else {
+				connection.disconnect();
+				connection = null;
+
+				emitLater(connectionFailedEvent, error);
 			}
 		}
 
@@ -630,14 +655,12 @@ public class ConnectionControl implements IConnectionControl {
 	private abstract class SendRunner implements Runnable {
 		@Override
 		public void run() {
-			synchronized (ConnectionControl.this) {
-				if (connection != null) {
-					DefaultPacketExtension extension = createJRummikubExtension();
-					addData(extension);
-					Message message = createMessage(extension);
-					modifyMessage(message);
-					connection.sendPacket(message);
-				}
+			if (connection != null) {
+				DefaultPacketExtension extension = createJRummikubExtension();
+				addData(extension);
+				Message message = createMessage(extension);
+				modifyMessage(message);
+				connection.sendPacket(message);
 			}
 		}