changeset 33:74195a7722be

add src/BlockingUpdateRectangle.java
author Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
date Thu, 05 Apr 2012 19:23:35 +0900
parents 3ad9ad996465
children 32b266967c2c
files src/test/BlockingUpdateRectangle.java src/treeVnc/MyRfbProtoProxy.java src/treeVnc/RfbProto.java
diffstat 3 files changed, 21 insertions(+), 7 deletions(-) [+]
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/test/BlockingUpdateRectangle.java	Thu Apr 05 19:23:35 2012 +0900
@@ -0,0 +1,14 @@
+package test;
+
+import static org.junit.Assert.*;
+
+import org.junit.Test;
+
+public class BlockingUpdateRectangle {
+
+	@Test
+	public void test() {
+		fail("Not yet implemented");
+	}
+
+}
--- a/src/treeVnc/MyRfbProtoProxy.java	Tue Feb 21 00:04:46 2012 +0900
+++ b/src/treeVnc/MyRfbProtoProxy.java	Thu Apr 05 19:23:35 2012 +0900
@@ -427,7 +427,7 @@
 			zLen = readU32();
 		else
 			zLen = 0;
-		System.out.println(zLen);
+		//System.out.println(zLen);
 		is.reset();
 
 	}
@@ -757,6 +757,7 @@
 
 				startTiming();
 				readFully(inputData.array(), 0, inputData.capacity());
+//				System.out.println(dataLen);
 				inputData.limit(dataLen - 20);
 				stopTiming();
 
@@ -778,7 +779,8 @@
 				bufs.addFirst(blen);
 
 				bufs.addFirst(header);
-				multicastqueue.put(bufs);
+			//	if(dataLen<=64000)
+					multicastqueue.put(bufs);
 				// is.reset();
 
 				/*
@@ -921,12 +923,10 @@
 						ByteBuffer header = bufs.get(inputIndex);
 						if (header == null)
 							continue;
-						if (header.get(0) == RfbProto.CheckDelay) {
+						else if (header.get(0) == RfbProto.CheckDelay) {
 							writeToClient(os, bufs, inputIndex);
-							// System.out.println("データ来たよ");
 							continue;
-						}
-						if (header.get(0) == RfbProto.FramebufferUpdate) {
+						} else if (header.get(0) == RfbProto.FramebufferUpdate) {
 							// System.out.println("client "+ myId);
 						}
 						/*
--- a/src/treeVnc/RfbProto.java	Tue Feb 21 00:04:46 2012 +0900
+++ b/src/treeVnc/RfbProto.java	Thu Apr 05 19:23:35 2012 +0900
@@ -30,7 +30,7 @@
 import java.net.Socket;
 import java.util.zip.*;
 
-class RfbProto {
+public class RfbProto {
 
 	final static String versionMsg_3_3 = "RFB 003.003\n",
 			versionMsg_3_7 = "RFB 003.007\n", versionMsg_3_8 = "RFB 003.008\n",versionMsg_3_855 = "RFB 003.855\n";