Mercurial > hg > Members > nobuyasu > tightVNCProxy

comparison src/myVncProxy/MyRfbProto.java @ 149:f68f63c298d0

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
merge
author Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
date Fri, 09 Sep 2011 23:22:58 +0900
parents 0d9a824dd12f c1d7d4fbcfb9
children fb1a62154851
comparison
equal deleted inserted replaced
148:0d9a824dd12f 149:f68f63c298d0
24 import org.junit.Test; 24 import org.junit.Test;
25 25
26 import myVncProxy.MulticastQueue.Client; 26 import myVncProxy.MulticastQueue.Client;
27 27
28 import java.util.concurrent.ExecutorService; 28 import java.util.concurrent.ExecutorService;
29 import java.util.concurrent.atomic.AtomicBoolean;
30 import java.util.concurrent.atomic.AtomicInteger; 29 import java.util.concurrent.atomic.AtomicInteger;
31 import java.util.zip.DataFormatException; 30 import java.util.zip.DataFormatException;
32 import java.util.zip.Deflater; 31 import java.util.zip.Deflater;
33 import java.util.zip.Inflater; 32 import java.util.zip.Inflater;
34 import java.io.OutputStream; 33 import java.io.OutputStream;
53 private int encoding; 52 private int encoding;
54 private int zLen; 53 private int zLen;
55 private boolean clicomp = false; 54 private boolean clicomp = false;
56 55
57 private ServerSocket servSock; 56 private ServerSocket servSock;
58 private int acceptPort; 57 protected int acceptPort;
59 private byte initData[]; 58 private byte initData[];
60 private LinkedList<Socket> cliListTmp; 59 private LinkedList<Socket> cliListTmp;
61 private LinkedList<Socket> cliList; 60 private LinkedList<Socket> cliList;
62 boolean createBimgFlag; 61 boolean createBimgFlag;
63 62
117 acceptPort = port; 116 acceptPort = port;
118 } 117 }
119 118
120 // 5999を開けるが、開いてないなら+1のポートを開ける。 119 // 5999を開けるが、開いてないなら+1のポートを開ける。
121 void selectPort(int p) { 120 void selectPort(int p) {
121 if(servSock != null ) return ;
122 int port = p; 122 int port = p;
123 while (true) { 123 while (true) {
124 try { 124 try {
125 initServSock(port); 125 initServSock(port);
126 break; 126 break;
228 serverMajor = (b[4] - '0') * 100 + (b[5] - '0') * 10 + (b[6] - '0'); 228 serverMajor = (b[4] - '0') * 100 + (b[5] - '0') * 10 + (b[6] - '0');
229 serverMinor = (b[8] - '0') * 100 + (b[9] - '0') * 10 + (b[10] - '0'); 229 serverMinor = (b[8] - '0') * 100 + (b[9] - '0') * 10 + (b[10] - '0');
230 230
231 if (serverMajor < 3) { 231 if (serverMajor < 3) {
232 throw new IOException( 232 throw new IOException(
233 "RFB server does not support protocol version 3"); 233 "RFB server does not support protocol version 3");
234 } 234 }
235 235
236 if (serverMinor == 998) { 236 if (serverMinor == 998) {
237 sendPortNumber(os); 237 sendPortNumber(os);
238 } 238 }