# HG changeset patch
# User oc
# Date 1424682874 -32400
# Node ID 7ef4ac588459d16122dcda1f247978003e327f1a
# Parent  eba44a31e868c28806dc4c30a81b1bcd048ee304
remove flag in writeToClinet

diff -r eba44a31e868 -r 7ef4ac588459 src/main/java/jp/ac/u_ryukyu/treevnc/MulticastQueue.java
--- a/src/main/java/jp/ac/u_ryukyu/treevnc/MulticastQueue.java	Mon Feb 23 17:43:45 2015 +0900
+++ b/src/main/java/jp/ac/u_ryukyu/treevnc/MulticastQueue.java	Mon Feb 23 18:14:34 2015 +0900
@@ -42,7 +42,7 @@
 			try {
 				wait();
 			} catch (InterruptedException e) {
-                System.out.println("any thread has interrupted the current thread.");
+                System.out.println("thread has interrupted the current thread.");
 			}
 		}		
 		return b;
@@ -100,8 +100,8 @@
 			do {
 				try {
 					next = node.next();
-				}catch(InterruptedException _e){
-                    System.out.println("any thread has interrupted the current thread.");
+				} catch(InterruptedException _e) {
+                    System.out.println("thread has interrupted the current thread.");
 					continue;
 				}
 				item = next.getItem();				
diff -r eba44a31e868 -r 7ef4ac588459 src/main/java/jp/ac/u_ryukyu/treevnc/TreeRFBProto.java
--- a/src/main/java/jp/ac/u_ryukyu/treevnc/TreeRFBProto.java	Mon Feb 23 17:43:45 2015 +0900
+++ b/src/main/java/jp/ac/u_ryukyu/treevnc/TreeRFBProto.java	Mon Feb 23 18:14:34 2015 +0900
@@ -346,7 +346,7 @@
             public void writeToClient(final Writer os,
                     LinkedList<ByteBuffer> bufs, int inputIndex)
                             throws TransportException {
-                while (inputIndex < bufs.size() && childrenMulticast) {
+                while (inputIndex < bufs.size()) {
                     ByteBuffer b = bufs.get(inputIndex++);
                     os.write(b.array(), b.position(), b.limit());
                 }
@@ -576,9 +576,9 @@
 
     public void clearChildrenTransmission() {
         // set discard flag
-//        childrenMulticast = false;
+        childrenMulticast = false;
         // put gurd erement to restart multicastqueue.
-//        multicastqueue.put(new LinkedList<ByteBuffer>());
+        multicastqueue.put(new LinkedList<ByteBuffer>());
     }
 
     public void enableChildrenTransmission() {