diff --git a/src/se/hal/deamon/PCDataSynchronizationClient.java b/src/se/hal/deamon/PCDataSynchronizationClient.java
index 04aabfdc..036c4a7c 100755
--- a/src/se/hal/deamon/PCDataSynchronizationClient.java
+++ b/src/se/hal/deamon/PCDataSynchronizationClient.java
@@ -55,6 +55,7 @@ public class PCDataSynchronizationClient implements HalDaemon {
                         logger.warning("Protocol version do not match, skipping user. " +
                                 "(local v"+PCDataSynchronizationDaemon.PROTOCOL_VERSION+" != remote v"+version+")");
                         out.writeObject(null); // Tell server we are disconnecting
+                        out.flush();
                         continue;
                     }
 
diff --git a/src/se/hal/deamon/PCDataSynchronizationDaemon.java b/src/se/hal/deamon/PCDataSynchronizationDaemon.java
index 8d4d64b1..80fc3b3a 100755
--- a/src/se/hal/deamon/PCDataSynchronizationDaemon.java
+++ b/src/se/hal/deamon/PCDataSynchronizationDaemon.java
@@ -28,7 +28,7 @@ import java.util.logging.Logger;
 
 public class PCDataSynchronizationDaemon extends ThreadedTCPNetworkServer implements HalDaemon {
 	private static final Logger logger = LogUtil.getLogger();
-    public static final int PROTOCOL_VERSION = 2;
+    public static final int PROTOCOL_VERSION = 3;
 
 
 	public PCDataSynchronizationDaemon() {
@@ -73,6 +73,7 @@ public class PCDataSynchronizationDaemon extends ThreadedTCPNetworkServer implem
 			try {
 				Object obj = null;
                 out.writeInt(PROTOCOL_VERSION); // send our protocol version to client
+                out.flush();
 				while((obj = in.readObject()) != null){
                     if(obj instanceof PeerDataReqDTO){
                         logger.fine("Client requesting peer data");