Mercurial > hg > Members > riono > TreeVNC_ja_comment

changeset 354:7ef4ac588459

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
remove flag in writeToClinet
author oc
date Mon, 23 Feb 2015 18:14:34 +0900
parents eba44a31e868
children 82825c322044
files src/main/java/jp/ac/u_ryukyu/treevnc/MulticastQueue.java src/main/java/jp/ac/u_ryukyu/treevnc/TreeRFBProto.java
diffstat 2 files changed, 6 insertions(+), 6 deletions(-) [+]
line wrap: on
line diff
--- 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();				
--- 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() {