annotate src/main/java/jp/ac/u_ryukyu/treevnc/TreeRFBProto.java @ 435:4ac83ab4be81

find our screen on fitScreen remove requestSingleScreenSize
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Sun, 12 Jun 2016 09:06:53 +0900
parents aad75cd6d9e2
children cee43ceac9b3
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
32
758d025ee24b add TextBox.java
one
parents: 31
diff changeset
1 package jp.ac.u_ryukyu.treevnc;
28
18fad65bc447 Create MyRfbProto.java
one
parents:
diff changeset
2
434
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
3 import com.glavsoft.exceptions.TransportException;
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
4 import com.glavsoft.rfb.client.ClientToServerMessage;
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
5 import com.glavsoft.rfb.encoding.EncodingType;
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
6 import com.glavsoft.rfb.encoding.decoder.FramebufferUpdateRectangle;
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
7 import com.glavsoft.rfb.protocol.Protocol;
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
8 import com.glavsoft.rfb.protocol.ProtocolContext;
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
9 import com.glavsoft.transport.Reader;
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
10 import com.glavsoft.transport.Writer;
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
11 import com.glavsoft.viewer.ConnectionPresenter;
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
12 import com.glavsoft.viewer.ViewerInterface;
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
13 import com.glavsoft.viewer.swing.ConnectionParams;
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
14
28
18fad65bc447 Create MyRfbProto.java
one
parents:
diff changeset
15 import java.io.IOException;
206
2b3eb4a9492f MyRfbProto reorganization
oc
parents: 205
diff changeset
16 import java.io.OutputStream;
232
6ee4cdca104c send value of port and localhost in checkdelay framebufferupdate, and get this.
oc
parents: 231
diff changeset
17 import java.io.UnsupportedEncodingException;
291
a310be14d757 send rtp+sound packet(client node version).
oc
parents: 290
diff changeset
18 import java.net.*;
28
18fad65bc447 Create MyRfbProto.java
one
parents:
diff changeset
19 import java.nio.ByteBuffer;
109
457f9dfbf7ce minor fix.
oc
parents: 107
diff changeset
20 import java.nio.ByteOrder;
369
2d01ec1c02d2 Fix ReConnectingFlag
innparusu
parents: 367
diff changeset
21 import java.util.Enumeration;
232
6ee4cdca104c send value of port and localhost in checkdelay framebufferupdate, and get this.
oc
parents: 231
diff changeset
22 import java.util.Iterator;
28
18fad65bc447 Create MyRfbProto.java
one
parents:
diff changeset
23 import java.util.LinkedList;
18fad65bc447 Create MyRfbProto.java
one
parents:
diff changeset
24 import java.util.concurrent.atomic.AtomicInteger;
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
25 import java.util.zip.DataFormatException;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
26 import java.util.zip.Deflater;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
27 import java.util.zip.Inflater;
150
925fb2090282 minor fix
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 147
diff changeset
28
124
214d4f206431 add TreeVNC command number.
oc
parents: 123
diff changeset
29
207
b31903e5b02d rename myRFBProto
oc
parents: 206
diff changeset
30 public class TreeRFBProto {
231
0e0e6744432c get new nodeList for checkDelay.
oc
parents: 230
diff changeset
31
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
32 final static int FramebufferUpdateRequest = 3;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
33 final static int CheckDelay = 11;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
34 protected final static int FramebufferUpdate = 0;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
35 protected ProtocolContext context;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
36 private int clients = 0;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
37 public MulticastQueue<LinkedList<ByteBuffer>> multicastqueue = new MulticastQueue<LinkedList<ByteBuffer>>();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
38 private RequestScreenThread rThread;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
39 public int acceptPort = 0;
174
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
40 private String myAddress;
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
41 private long counter = 0; // packet serial number
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
42 public ServerSocket servSock;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
43 private static final int INFLATE_BUFSIZE = 1024 * 100;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
44 private Inflater inflater = new Inflater();
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
45 private Deflater deflater = new Deflater();
174
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
46 ViewerInterface viewer;
341
1d9a4099ad44 change hasParent value.
oc
parents: 340
diff changeset
47 private short id = 0; // my tree node id ( = 0 in root ), -1 means no parent
174
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
48 private TreeVncCommandChannelListener acceptThread;
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
49 private TreeRootFinderListener getCast;
176
fa6cfb85444e on going ...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 175
diff changeset
50 private CreateConnectionParam cp;
205
614db20d8fab try to separate Network management
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 204
diff changeset
51 private TreeVNCNetwork nets = new TreeVNCNetwork();
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
52 private TreeVncRootSelectionPanel rootSelectionPanel;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
53 private String vncInterface;
418
0543c380308c Move bottleneck Node to outside node list
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 417
diff changeset
54 private TreeManagement treeManager;
231
0e0e6744432c get new nodeList for checkDelay.
oc
parents: 230
diff changeset
55 public LinkedList<TreeVNCNode> nodeList;
267
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
56
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
57 protected boolean readyReconnect = false;
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
58 private boolean cuiVersion;
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
59 private boolean permitChangeScreen = true;
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
60 private boolean leader;
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
61 private boolean hasViewer = false;
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
62 private boolean normalTermination;
402
73c96a1d4a3a Fix wasteful thread start
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 399
diff changeset
63
267
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
64 private boolean isTreeManager;
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
65 public boolean showTreeNode = false;
240
7310e7d7a45f add option --checkDelay.
oc
parents: 239
diff changeset
66 public boolean checkDelay = false;
241
b21a7842a41d add option addSerialNum.
oc
parents: 240
diff changeset
67 public boolean addSerialNum = false;
257
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
68 public boolean fixingSize = false;
267
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
69 public boolean filterSingleDisplay = false;
257
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
70 public int frameSizeWidth;
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
71 public int frameSizeHeight;
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
72 public int fixingSizeWidth;
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
73 public int fixingSizeHeight;
306
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
74 private int singleWidth = 0;
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
75 private int singleHeight = 0;
293
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
76 private DatagramSocket socket = null;
306
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
77 private byte[] originalInitData = null;
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
78 private boolean childrenMulticast = true;
411
4a925e55afd6 Enable auto Fit Screen
innparusu
parents: 410
diff changeset
79 private int retinaScale = 1;
417
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
80 private int x;
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
81 private int y;
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
82
418
0543c380308c Move bottleneck Node to outside node list
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 417
diff changeset
83
327
293c35aa902b add error message, add assure stream close, delete firstTime value in TreeRFBProto.
oc
parents: 325
diff changeset
84 public TreeRFBProto(boolean isTreeManager, ViewerInterface viewer) {
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
85 rThread = new RequestScreenThread(this);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
86 nets.setMyRfb(this);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
87 this.isTreeManager = isTreeManager;
327
293c35aa902b add error message, add assure stream close, delete firstTime value in TreeRFBProto.
oc
parents: 325
diff changeset
88 this.viewer = viewer;
302
7ef19658eb41 add createOriginalInitData().
oc
parents: 301
diff changeset
89 // this.socket = createSocket();
402
73c96a1d4a3a Fix wasteful thread start
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 399
diff changeset
90 startTreeRootFindThread();
73c96a1d4a3a Fix wasteful thread start
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 399
diff changeset
91 }
73c96a1d4a3a Fix wasteful thread start
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 399
diff changeset
92
73c96a1d4a3a Fix wasteful thread start
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 399
diff changeset
93 public void startTreeRootFindThread() {
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
94 if (isTreeManager()) {
327
293c35aa902b add error message, add assure stream close, delete firstTime value in TreeRFBProto.
oc
parents: 325
diff changeset
95 getCast = new TreeRootFinderListener(viewer);
293c35aa902b add error message, add assure stream close, delete firstTime value in TreeRFBProto.
oc
parents: 325
diff changeset
96 Thread treeRootFindThread = new Thread(getCast, "tree-root-find-listener");
293c35aa902b add error message, add assure stream close, delete firstTime value in TreeRFBProto.
oc
parents: 325
diff changeset
97 treeRootFindThread.start();
293c35aa902b add error message, add assure stream close, delete firstTime value in TreeRFBProto.
oc
parents: 325
diff changeset
98 }
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
99 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
100
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
101 public boolean isTreeManager() {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
102 return isTreeManager;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
103 }
207
b31903e5b02d rename myRFBProto
oc
parents: 206
diff changeset
104
402
73c96a1d4a3a Fix wasteful thread start
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 399
diff changeset
105 public void setIsTreeManager(boolean isTreeManager) {
73c96a1d4a3a Fix wasteful thread start
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 399
diff changeset
106 this.isTreeManager = isTreeManager;
73c96a1d4a3a Fix wasteful thread start
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 399
diff changeset
107 }
73c96a1d4a3a Fix wasteful thread start
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 399
diff changeset
108
378
60abae693629 Compare SerialNumber flag
innparusu
parents: 373
diff changeset
109 public boolean isAddSerialNum() {
60abae693629 Compare SerialNumber flag
innparusu
parents: 373
diff changeset
110 return addSerialNum;
60abae693629 Compare SerialNumber flag
innparusu
parents: 373
diff changeset
111 }
60abae693629 Compare SerialNumber flag
innparusu
parents: 373
diff changeset
112
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
113 public ProtocolContext getContext() {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
114 return context;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
115 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
116
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
117 /**
402
73c96a1d4a3a Fix wasteful thread start
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 399
diff changeset
118 * handle new client accept
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
119 * it also handle TreeVNC Command
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
120 *
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
121 * @param os
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
122 * @param is
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
123 * @param intf
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
124 * @throws IOException
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
125 * @throws TransportException
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
126 */
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
127 public void newClient(final Writer os, final Reader is, final String intf) {
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
128 final int myId = clients;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
129 final MulticastQueue.Client<LinkedList<ByteBuffer>> c = multicastqueue.newClient();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
130 final AtomicInteger writerRunning = new AtomicInteger();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
131 writerRunning.set(1);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
132 /**
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
133 * Timeout thread. If a client is suspended, it has top of queue
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
134 * indefinitely, which caused memory overflow. After the timeout, we
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
135 * poll the queue and discard it. Start long wait if writer is running.
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
136 */
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
137 final Runnable timer = new Runnable() {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
138 public void run() {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
139 int count = 0;
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
140 for (; ; ) {
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
141 long timeout = 50000 / 8;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
142 try {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
143 synchronized (this) {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
144 int state, flag;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
145 writerRunning.set(0);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
146 wait(timeout);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
147 flag = 0;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
148 while ((state = writerRunning.get()) == 0) {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
149 c.poll(); // discard, should be timeout
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
150 count++;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
151 if (flag == 0) {
434
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
152 // System.out.println("Discarding " + myId + " count=" + count);
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
153 flag = 1;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
154 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
155 wait(10); // if this is too short, writer cannot
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
156 // take the poll, if this is too
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
157 // long, memory will overflow...
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
158 }
434
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
159 // if (flag == 1)
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
160 // System.out.println("Resuming " + myId + " count=" + count);
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
161 if (state != 1) {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
162 System.out.println("Client died " + myId);
434
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
163 // System.out.println("task stop");
330
9d1ed0099350 root send lost child, hide function lost parent
oc
parents: 329
diff changeset
164 String rootHostName = null;
9d1ed0099350 root send lost child, hide function lost parent
oc
parents: 329
diff changeset
165 int rootHostPort = 0;
9d1ed0099350 root send lost child, hide function lost parent
oc
parents: 329
diff changeset
166 String myHostName = null;
9d1ed0099350 root send lost child, hide function lost parent
oc
parents: 329
diff changeset
167 int myHostPort = 0;
429
e16fb899620f Fix allocate the myId for LostChild
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 428
diff changeset
168 clients = myId;
385
b0be610bc4db Set reconnectingID
innparusu
parents: 384
diff changeset
169 if (!isTreeManager) {
330
9d1ed0099350 root send lost child, hide function lost parent
oc
parents: 329
diff changeset
170 rootHostName = getConnectionParam().getHostName();
9d1ed0099350 root send lost child, hide function lost parent
oc
parents: 329
diff changeset
171 rootHostPort = getConnectionParam().getPort();
9d1ed0099350 root send lost child, hide function lost parent
oc
parents: 329
diff changeset
172 myHostName = getMyAddress();
9d1ed0099350 root send lost child, hide function lost parent
oc
parents: 329
diff changeset
173 myHostPort = getAcceptPort();
385
b0be610bc4db Set reconnectingID
innparusu
parents: 384
diff changeset
174 TreeVncProtocol echo = new TreeVncProtocol(rootHostName, rootHostPort);
b0be610bc4db Set reconnectingID
innparusu
parents: 384
diff changeset
175 echo.lostChild(myHostName, myHostPort, myId);
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
176 } else {
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
177 getTreeManager(intf).fixLostChild1(myId + 1);
330
9d1ed0099350 root send lost child, hide function lost parent
oc
parents: 329
diff changeset
178 }
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
179 break;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
180 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
181 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
182 } catch (InterruptedException e) {
325
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
183 e.printStackTrace();
434
aad75cd6d9e2 Multicast joins both ipv4 and ipv6 now.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 429
diff changeset
184 System.out.println("timer thread interrupted.");
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
185 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
186 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
187 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
188 };
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
189 new Thread(timer, "timer-discard-multicastqueue").start();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
190 /**
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
191 * handle command from lower node
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
192 */
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
193 final Runnable reader = new Runnable() {
122
e2416a246c95 noScreenChange flag on command line ( should be on panel also )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 120
diff changeset
194 public void run() {
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
195 for (; ; ) {
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
196 try {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
197 final byte b[] = new byte[4096];
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
198 final int c = is.readByte(b);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
199 if (c <= 0)
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
200 throw new IOException();
290
c10e0dee7bbb add READY_SHARE_SOUND msg, add function of receive READY_SHARE_SOUND msg, add sendSound thread.
oc
parents: 287
diff changeset
201 // case of root node.
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
202 if (isTreeManager()) {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
203 if (b[0] == ClientToServerMessage.SERVER_CHANGE_REQUEST) {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
204 if (permitChangeScreen()) {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
205 ByteBuffer buf = ByteBuffer.wrap(b);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
206 buf.order(ByteOrder.BIG_ENDIAN);
325
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
207 buf.get(); // padding
257
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
208 buf.get();
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
209 short id = buf.getShort();
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
210 int length = buf.getInt();
325
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
211 if (length == 0)
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
212 continue;
257
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
213 byte[] byteAddress = new byte[length];
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
214 buf.get(byteAddress);
325
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
215 String newHostName = new String(byteAddress, "UTF-8");
417
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
216 int x = buf.getInt();
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
217 int y = buf.getInt();
257
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
218 int frameSizeWidth = buf.getInt();
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
219 int frameSizeHeight = buf.getInt();
340
fd529c51095f add port ScreenChangeRequest value.
oc
parents: 339
diff changeset
220 int port = buf.getInt();
410
da1d6d6b4981 Enable retina scale to fit screen
innparusu
parents: 405
diff changeset
221 int scale = buf.getInt();
340
fd529c51095f add port ScreenChangeRequest value.
oc
parents: 339
diff changeset
222 System.out.println("Root server change request :" + newHostName + " : " + port);
427
ed15f0bd8dfa Remove shareScrrenNumber for ScreenChangeRequest Message
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 425
diff changeset
223 changeVNCServer(viewer, newHostName, port, x, y, frameSizeWidth, frameSizeHeight, scale, id, is, os);
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
224 } else {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
225 continue;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
226 }
290
c10e0dee7bbb add READY_SHARE_SOUND msg, add function of receive READY_SHARE_SOUND msg, add sendSound thread.
oc
parents: 287
diff changeset
227 } else if (b[0] == ClientToServerMessage.READY_SHARE_SOUND) {
293
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
228 int rtpPort = selectPort(ConnectionParams.DEFAULT_RTP_PORT);
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
229 InetAddress hostname = InetAddress.getLocalHost();
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
230 ReceiveSound receiveSound = new ReceiveSound(socket);
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
231 Thread receiveSoundThread = new Thread(receiveSound, "receive-sound");
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
232 receiveSoundThread.start();
230
f4ea9ff04741 reply checkdelay
oc
parents: 229
diff changeset
233 } else if (b[0] == ClientToServerMessage.CHECK_DELAY_REPLY) {
f4ea9ff04741 reply checkdelay
oc
parents: 229
diff changeset
234 ByteBuffer buf = ByteBuffer.wrap(b);
f4ea9ff04741 reply checkdelay
oc
parents: 229
diff changeset
235 buf.order(ByteOrder.BIG_ENDIAN);
234
8479ad028ec7 fix checkdelay send and get.
oc
parents: 233
diff changeset
236 buf.getShort();
8479ad028ec7 fix checkdelay send and get.
oc
parents: 233
diff changeset
237 Long time = buf.getLong();
8479ad028ec7 fix checkdelay send and get.
oc
parents: 233
diff changeset
238 int port = buf.getInt();
8479ad028ec7 fix checkdelay send and get.
oc
parents: 233
diff changeset
239 int addressLength = buf.getInt();
414
3af5f4af2d63 Send data size for checkDelay
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 412
diff changeset
240 int dataLen = buf.getInt();
234
8479ad028ec7 fix checkdelay send and get.
oc
parents: 233
diff changeset
241 byte[] byteAddress = new byte[addressLength];
8479ad028ec7 fix checkdelay send and get.
oc
parents: 233
diff changeset
242 buf.get(byteAddress);
8479ad028ec7 fix checkdelay send and get.
oc
parents: 233
diff changeset
243 String address = new String(byteAddress, "UTF-8");
235
15e66adbb8bb get checkdelay nodeNum.
oc
parents: 234
diff changeset
244 int nodeNum = getNodeNum(port, address);
419
7e811f33b99d Adhoc implement multi display
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 418
diff changeset
245 if (nodeNum != 0) {
7e811f33b99d Adhoc implement multi display
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 418
diff changeset
246 Long delay = System.currentTimeMillis() - time;
7e811f33b99d Adhoc implement multi display
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 418
diff changeset
247 if (delay > 3000) {
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
248 getTreeManager(intf).fixLostChild1(nodeNum);
419
7e811f33b99d Adhoc implement multi display
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 418
diff changeset
249 }
7e811f33b99d Adhoc implement multi display
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 418
diff changeset
250 System.out.println(System.currentTimeMillis() + " : receive checkDelay : nodeNum" + nodeNum + ", port : " + port + ", address : " + address + ", delay : " + delay + ", size : " + dataLen);
418
0543c380308c Move bottleneck Node to outside node list
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 417
diff changeset
251 }
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
252 }
325
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
253 // case of client node.
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
254 } else if (b[0] == ClientToServerMessage.SERVER_CHANGE_REQUEST) {
295
71d24f7b3b3b fix send ClientToServerMessage
oc
parents: 293
diff changeset
255 ClientToServerMessage serverChangeRequest = new ClientToServerMessage() {
113
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 112
diff changeset
256 @Override
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 112
diff changeset
257 public void send(Writer writer)
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 112
diff changeset
258 throws TransportException {
325
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
259 writer.write(b, 0, c);
113
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 112
diff changeset
260 }
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
261 };
295
71d24f7b3b3b fix send ClientToServerMessage
oc
parents: 293
diff changeset
262 context.sendMessage(serverChangeRequest);
290
c10e0dee7bbb add READY_SHARE_SOUND msg, add function of receive READY_SHARE_SOUND msg, add sendSound thread.
oc
parents: 287
diff changeset
263 } else if (b[0] == ClientToServerMessage.READY_SHARE_SOUND) {
c10e0dee7bbb add READY_SHARE_SOUND msg, add function of receive READY_SHARE_SOUND msg, add sendSound thread.
oc
parents: 287
diff changeset
264 ClientToServerMessage readyShareSound = new ClientToServerMessage() {
c10e0dee7bbb add READY_SHARE_SOUND msg, add function of receive READY_SHARE_SOUND msg, add sendSound thread.
oc
parents: 287
diff changeset
265 @Override
c10e0dee7bbb add READY_SHARE_SOUND msg, add function of receive READY_SHARE_SOUND msg, add sendSound thread.
oc
parents: 287
diff changeset
266 public void send(Writer writer)
c10e0dee7bbb add READY_SHARE_SOUND msg, add function of receive READY_SHARE_SOUND msg, add sendSound thread.
oc
parents: 287
diff changeset
267 throws TransportException {
325
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
268 writer.write(b, 0, c);
290
c10e0dee7bbb add READY_SHARE_SOUND msg, add function of receive READY_SHARE_SOUND msg, add sendSound thread.
oc
parents: 287
diff changeset
269 }
c10e0dee7bbb add READY_SHARE_SOUND msg, add function of receive READY_SHARE_SOUND msg, add sendSound thread.
oc
parents: 287
diff changeset
270 };
c10e0dee7bbb add READY_SHARE_SOUND msg, add function of receive READY_SHARE_SOUND msg, add sendSound thread.
oc
parents: 287
diff changeset
271 context.sendMessage(readyShareSound);
230
f4ea9ff04741 reply checkdelay
oc
parents: 229
diff changeset
272 } else if (b[0] == ClientToServerMessage.CHECK_DELAY_REPLY) {
f4ea9ff04741 reply checkdelay
oc
parents: 229
diff changeset
273 ClientToServerMessage checkDelayReply = new ClientToServerMessage() {
f4ea9ff04741 reply checkdelay
oc
parents: 229
diff changeset
274 @Override
f4ea9ff04741 reply checkdelay
oc
parents: 229
diff changeset
275 public void send(Writer writer)
f4ea9ff04741 reply checkdelay
oc
parents: 229
diff changeset
276 throws TransportException {
325
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
277 writer.write(b, 0, c);
230
f4ea9ff04741 reply checkdelay
oc
parents: 229
diff changeset
278 }
f4ea9ff04741 reply checkdelay
oc
parents: 229
diff changeset
279 };
f4ea9ff04741 reply checkdelay
oc
parents: 229
diff changeset
280 context.sendMessage(checkDelayReply);
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
281 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
282 } catch (Exception e) {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
283 try {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
284 writerRunning.set(2);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
285 os.close();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
286 is.close();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
287 break;
367
0e3af3c8b771 Add Exception messeges
innparusu
parents: 359
diff changeset
288 } catch (Exception e1) {
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
289 System.out.println("cannot close ClientToServerMessage " + e1);
367
0e3af3c8b771 Add Exception messeges
innparusu
parents: 359
diff changeset
290
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
291 }
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
292 System.out.println("cannot read ClientToServerMessage " + e);
367
0e3af3c8b771 Add Exception messeges
innparusu
parents: 359
diff changeset
293
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
294 return;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
295 }
325
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
296
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
297 /*
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
298 // あとで検討
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
299 } catch (TransportException e) {
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
300
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
301 }
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
302 */
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
303 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
304 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
305 };
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
306 /**
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
307 * send packets to a client (one thread for each client )
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
308 */
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
309 Runnable sender = new Runnable() {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
310 public void run() {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
311 writerRunning.set(1);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
312 try {
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
313 requestThreadNotify(); // send full screen request via fullScreenRequestThread
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
314
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
315 // after this, we discard upward packet.
239
d655db005535 create sendCheckDelay Socket.
oc
parents: 237
diff changeset
316 new Thread(reader, "upward-packet-processing").start();
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
317
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
318 for (; ; ) {
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
319 LinkedList<ByteBuffer> bufs = c.poll();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
320 int inputIndex = 0;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
321 ByteBuffer header = bufs.get(inputIndex);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
322 if (header == null)
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
323 continue;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
324 writeToClient(os, bufs, inputIndex);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
325 writerRunning.set(1); // yes my client is awaking.
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
326 if (!childrenMulticast) {
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
327 for (; ; ) {
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
328 LinkedList<ByteBuffer> flag = c.poll();
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
329 if (flag.size() == 0) {
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
330 break;
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
331 }
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
332 }
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
333 }
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
334 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
335 } catch (Exception e) {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
336 try {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
337 writerRunning.set(2);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
338 os.close();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
339 } catch (IOException e1) {
420
0ad52aac3bc3 Send repeat FramebufferUpdateRequest from Timer class
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 419
diff changeset
340 System.out.println("root writer close failed :" + e1);
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
341 }
420
0ad52aac3bc3 Send repeat FramebufferUpdateRequest from Timer class
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 419
diff changeset
342 System.out.println("root writer failed :" + e);
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
343 /* if socket closed cliList.remove(newCli); */
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
344 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
345 }
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
346
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
347 public void writeToClient(final Writer os,
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
348 LinkedList<ByteBuffer> bufs, int inputIndex)
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
349 throws TransportException {
354
7ef4ac588459 remove flag in writeToClinet
oc
parents: 353
diff changeset
350 while (inputIndex < bufs.size()) {
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
351 ByteBuffer b = bufs.get(inputIndex++);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
352 os.write(b.array(), b.position(), b.limit());
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
353 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
354 os.flush();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
355 multicastqueue.heapAvailable();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
356 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
357 };
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
358 clients++;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
359 new Thread(sender, "writer-to-lower-node").start();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
360 }
157
7cea8789387b thread base command listening loop
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 153
diff changeset
361
122
e2416a246c95 noScreenChange flag on command line ( should be on panel also )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 120
diff changeset
362 public boolean permitChangeScreen() {
e2416a246c95 noScreenChange flag on command line ( should be on panel also )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 120
diff changeset
363 return permitChangeScreen;
e2416a246c95 noScreenChange flag on command line ( should be on panel also )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 120
diff changeset
364 }
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
365
122
e2416a246c95 noScreenChange flag on command line ( should be on panel also )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 120
diff changeset
366
e2416a246c95 noScreenChange flag on command line ( should be on panel also )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 120
diff changeset
367 public void setPermitChangeScreen(boolean v) {
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
368 permitChangeScreen = v;
122
e2416a246c95 noScreenChange flag on command line ( should be on panel also )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 120
diff changeset
369 }
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
370
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
371 public void requestThreadNotify() {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
372 rThread.reStart();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
373 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
374
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
375
28
18fad65bc447 Create MyRfbProto.java
one
parents:
diff changeset
376 public void setProtocolContext(Protocol workingProtocol) {
18fad65bc447 Create MyRfbProto.java
one
parents:
diff changeset
377 context = workingProtocol;
18fad65bc447 Create MyRfbProto.java
one
parents:
diff changeset
378 }
29
57eb5575e6c4 MyRfbProto for client and proxy.
one
parents: 28
diff changeset
379
134
128cce60c43c where to connect command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 133
diff changeset
380 public Socket accept() throws IOException {
128cce60c43c where to connect command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 133
diff changeset
381 return servSock.accept();
128cce60c43c where to connect command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 133
diff changeset
382 }
31
872d9bcbfe56 Before changing the Viewer.
one
parents: 29
diff changeset
383
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
384 public int selectPort(int p) {
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
385 int port = p;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
386 while (true) {
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
387 try {
134
128cce60c43c where to connect command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 133
diff changeset
388 servSock = new ServerSocket(port);
128cce60c43c where to connect command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 133
diff changeset
389 acceptPort = port;
181
9c02b5a72bf9 fix root myAddress.
oc
parents: 179
diff changeset
390 myAddress = "127.0.0.1";
207
b31903e5b02d rename myRFBProto
oc
parents: 206
diff changeset
391 nets.getNetworkInterfaces();
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
392 break;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
393 } catch (BindException e) {
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
394 port++;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
395 continue;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
396 } catch (IOException e) {
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
397
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
398 }
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
399 }
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
400 System.out.println("accept port = " + port);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
401 return port;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
402 }
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
403
33
9d3478d11d3b Add the processing of client
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
404
331
42fcc9419498 add error message, add lostParent case by fail to connectTo.
oc
parents: 330
diff changeset
405 public void writeFramebufferUpdateRequest(int x, int y, int w, int h, boolean incremental) {
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
406 byte[] b = new byte[10];
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
407
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
408 b[0] = (byte) FramebufferUpdateRequest; // 3 is FrameBufferUpdateRequest
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
409 b[1] = (byte) (incremental ? 1 : 0);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
410 b[2] = (byte) ((x >> 8) & 0xff);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
411 b[3] = (byte) (x & 0xff);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
412 b[4] = (byte) ((y >> 8) & 0xff);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
413 b[5] = (byte) (y & 0xff);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
414 b[6] = (byte) ((w >> 8) & 0xff);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
415 b[7] = (byte) (w & 0xff);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
416 b[8] = (byte) ((h >> 8) & 0xff);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
417 b[9] = (byte) (h & 0xff);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
418 }
33
9d3478d11d3b Add the processing of client
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
419
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
420 public void setViewer(ViewerInterface v) {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
421 viewer = v;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
422 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
423
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
424 public ViewerInterface getViewer() {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
425 return viewer;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
426 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
427
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
428
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
429 void sendInitData(OutputStream os) throws IOException {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
430 os.write(context.getInitData());
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
431 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
432
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
433
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
434 public void setTerminationType(boolean setType) {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
435 normalTermination = setType;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
436 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
437
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
438 public boolean getTerminationType() {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
439 return normalTermination;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
440 }
43
6687aa9dd55e add flag for screen change in ReciverTask.java.
one
parents: 38
diff changeset
441
206
2b3eb4a9492f MyRfbProto reorganization
oc
parents: 205
diff changeset
442
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
443 public void addHostToSelectionPanel(int port, String hostname, String myHostName) {
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
444 if (rootSelectionPanel != null) {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
445 rootSelectionPanel.checkBox(Integer.toString(port) + ":" + hostname + ":" + myHostName);
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
446 rootSelectionPanel.visible();
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
447 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
448 }
43
6687aa9dd55e add flag for screen change in ReciverTask.java.
one
parents: 38
diff changeset
449
399
28d67bbfa9f1 Implement SelectionPanel processing
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
450 public void createRootSelectionPanel(CreateConnectionParam cp, FindRoot getBcast) {
28d67bbfa9f1 Implement SelectionPanel processing
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
451 rootSelectionPanel = new TreeVncRootSelectionPanel(getBcast);
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
452 rootSelectionPanel.setCp(cp);
399
28d67bbfa9f1 Implement SelectionPanel processing
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 398
diff changeset
453 rootSelectionPanel.visible();
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
454 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
455
134
128cce60c43c where to connect command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 133
diff changeset
456 public void close() {
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
457 // none
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
458 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
459
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
460 public int getAcceptPort() {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
461 return acceptPort;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
462 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
463
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
464 public boolean getReadyReconnect() {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
465 return readyReconnect;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
466 }
65
ffd7537cebfc cuiversion
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents: 64
diff changeset
467
ffd7537cebfc cuiversion
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents: 64
diff changeset
468
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
469 public boolean getCuiVersion() {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
470 return cuiVersion;
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
471 }
66
84ad879891e9 dont move
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents: 65
diff changeset
472
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
473 public void setCuiVersion(boolean flag) {
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
474 cuiVersion = flag;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
475 }
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
476
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
477 public void readCheckDelay(Reader reader) throws TransportException {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
478
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
479 }
134
128cce60c43c where to connect command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 133
diff changeset
480
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
481 public synchronized void vncConnected(boolean ready) {
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
482 enableChildrenTransmission();
369
2d01ec1c02d2 Fix ReConnectingFlag
innparusu
parents: 367
diff changeset
483 readyReconnect = ready;
2d01ec1c02d2 Fix ReConnectingFlag
innparusu
parents: 367
diff changeset
484 if (ready) {
2d01ec1c02d2 Fix ReConnectingFlag
innparusu
parents: 367
diff changeset
485 notifyAll();
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
486 }
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
487 }
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
488
369
2d01ec1c02d2 Fix ReConnectingFlag
innparusu
parents: 367
diff changeset
489 public void printNetworkInterface() {
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
490 Socket vncSocket = viewer.getVNCSocket();
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
491 NetworkInterface ni = nets.getInterface(vncSocket);
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
492 if (ni != null) {
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
493 vncInterface = ni.getName();
369
2d01ec1c02d2 Fix ReConnectingFlag
innparusu
parents: 367
diff changeset
494 System.out.print("VNCNetworkInterface :" + vncInterface);
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
495 if (false) {
370
2c61e6d434ff Fix VncConnectionWorkers
innparusu
parents: 369
diff changeset
496 Enumeration<InetAddress> addresses = ni.getInetAddresses();
2c61e6d434ff Fix VncConnectionWorkers
innparusu
parents: 369
diff changeset
497 while (addresses.hasMoreElements()) {
2c61e6d434ff Fix VncConnectionWorkers
innparusu
parents: 369
diff changeset
498 InetAddress adr = addresses.nextElement();
2c61e6d434ff Fix VncConnectionWorkers
innparusu
parents: 369
diff changeset
499 System.out.print(" " + adr);
2c61e6d434ff Fix VncConnectionWorkers
innparusu
parents: 369
diff changeset
500 }
369
2d01ec1c02d2 Fix ReConnectingFlag
innparusu
parents: 367
diff changeset
501 }
2d01ec1c02d2 Fix ReConnectingFlag
innparusu
parents: 367
diff changeset
502 System.out.println();
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
503 }
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
504 }
94
75879c316796 synchronized wait for Rfb initialization in change server.
oc
parents: 89
diff changeset
505
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
506 public void sendDesktopSizeChange(short id) {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
507 LinkedList<ByteBuffer> desktopSize = new LinkedList<ByteBuffer>();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
508 int width = context.getFbWidth();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
509 int height = context.getFbHeight();
304
d2a56d7d4b2d send initData secound
oc
parents: 302
diff changeset
510 if (filterSingleDisplay) {
353
eba44a31e868 remove filterSingleDisplay option in retina version
oc
parents: 352
diff changeset
511 originalInitData = createOriginalInitData(singleWidth, singleHeight, context.getRemoteDesktopName());
350
7050b41329c6 remove original InitData
oc
parents: 349
diff changeset
512 // desktopSize.add(new ChengeDesktopSize(singleWidth, singleHeight, EncodingType.INIT_DATA, originalInitData, id).getMessage());
7050b41329c6 remove original InitData
oc
parents: 349
diff changeset
513 desktopSize.add(new ChengeDesktopSize(width, height, EncodingType.INIT_DATA, context.getInitData(), id).getMessage());
305
0ee520f535c9 fix initData
oc
parents: 304
diff changeset
514 } else {
0ee520f535c9 fix initData
oc
parents: 304
diff changeset
515 desktopSize.add(new ChengeDesktopSize(width, height, EncodingType.INIT_DATA, context.getInitData(), id).getMessage());
304
d2a56d7d4b2d send initData secound
oc
parents: 302
diff changeset
516 }
380
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
517 if (addSerialNum) {
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
518 addSerialNumber(desktopSize);
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
519 }
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
520 multicastqueue.put(desktopSize);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
521 }
98
8f4c45c1b396 add serial number to desktop size encoding packet.
oc
parents: 97
diff changeset
522
306
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
523 public byte[] createOriginalInitData(int singleWidth, int singleHeight, String remoteDesktopName) {
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
524 TreeVncCommandChannelListener treeVncCommandChannelListener = new TreeVncCommandChannelListener(this, acceptPort);
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
525 byte[] originalInitData = treeVncCommandChannelListener.createOriginalInitData(singleWidth, singleHeight, remoteDesktopName);
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
526 return originalInitData;
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
527 }
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
528
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
529 public void addSerialNumber(LinkedList<ByteBuffer> bufs) {
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
530 ByteBuffer serialNum = multicastqueue.allocate(4 + 8); // addSerialNum flag + SerialNum
380
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
531 serialNum.putInt(1);
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
532 serialNum.putLong(counter++);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
533 serialNum.flip();
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
534 bufs.addFirst(serialNum);
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
535 }
102
1f7ee648e1f6 inflator in MyRfbProtoProxy should be renew to accept new VNC server socket.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 99
diff changeset
536
1f7ee648e1f6 inflator in MyRfbProtoProxy should be renew to accept new VNC server socket.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 99
diff changeset
537
1f7ee648e1f6 inflator in MyRfbProtoProxy should be renew to accept new VNC server socket.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 99
diff changeset
538 public void resetDecoder() {
1f7ee648e1f6 inflator in MyRfbProtoProxy should be renew to accept new VNC server socket.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 99
diff changeset
539 context.resetDecoder();
1f7ee648e1f6 inflator in MyRfbProtoProxy should be renew to accept new VNC server socket.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 99
diff changeset
540 }
1f7ee648e1f6 inflator in MyRfbProtoProxy should be renew to accept new VNC server socket.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 99
diff changeset
541
1f7ee648e1f6 inflator in MyRfbProtoProxy should be renew to accept new VNC server socket.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 99
diff changeset
542 public void stopReceiverTask() {
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
543 if (context != null) {
102
1f7ee648e1f6 inflator in MyRfbProtoProxy should be renew to accept new VNC server socket.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 99
diff changeset
544 context.cleanUpSession(null);
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
545 context.getRfb().clearChildrenTransmission();
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
546 }
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
547 // cleanup zlib decoder for new VNCServer
202
22676ca0dd97 get VNC Socket.
oc
parents: 201
diff changeset
548 if (isTreeManager())
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
549 inflater = new Inflater();
102
1f7ee648e1f6 inflator in MyRfbProtoProxy should be renew to accept new VNC server socket.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 99
diff changeset
550 }
113
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 112
diff changeset
551
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
552 public void clearChildrenTransmission() {
355
82825c322044 comment out clear children transmission
oc
parents: 354
diff changeset
553 // discarding does not work now.
82825c322044 comment out clear children transmission
oc
parents: 354
diff changeset
554
82825c322044 comment out clear children transmission
oc
parents: 354
diff changeset
555 /*
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
556 // set discard flag
354
7ef4ac588459 remove flag in writeToClinet
oc
parents: 353
diff changeset
557 childrenMulticast = false;
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
558 // put gurd erement to restart multicastqueue.
354
7ef4ac588459 remove flag in writeToClinet
oc
parents: 353
diff changeset
559 multicastqueue.put(new LinkedList<ByteBuffer>());
355
82825c322044 comment out clear children transmission
oc
parents: 354
diff changeset
560 */
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
561 }
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
562
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
563 public void enableChildrenTransmission() {
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
564 // a child senderTask may skip this flag
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
565 // durling write waiting. in this case, remaining bufferes are sent.
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
566 childrenMulticast = true;
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
567 }
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
568
113
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 112
diff changeset
569 public String getMyAddress() {
174
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
570 return myAddress;
113
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 112
diff changeset
571 }
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
572
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
573 /**
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
574 * gzip byte arrays
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
575 *
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
576 * @param deflater
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
577 * @param inputs byte data[]
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
578 * @param inputIndex
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
579 * @param outputs byte data[]
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
580 * @return byte length in last byte array
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
581 * @throws IOException
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
582 */
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
583 public int zip(Deflater deflater, LinkedList<ByteBuffer> inputs,
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
584 int inputIndex, LinkedList<ByteBuffer> outputs) throws IOException {
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
585 int len = 0;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
586 ByteBuffer c1 = multicastqueue.allocate(INFLATE_BUFSIZE);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
587 while (inputIndex < inputs.size()) {
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
588 ByteBuffer b1 = inputs.get(inputIndex++);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
589 deflater.setInput(b1.array(), b1.position(), b1.remaining());
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
590 /**
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
591 * If we finish() stream and reset() it, Deflater start new gzip
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
592 * stream, this makes continuous zlib reader unhappy. if we remove
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
593 * finish(), Deflater.deflate() never flushes its output. The
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
594 * original zlib deflate has flush flag. I'm pretty sure this a kind
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
595 * of bug of Java library.
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
596 */
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
597 if (inputIndex == inputs.size())
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
598 deflater.finish();
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
599 int len1 = 0;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
600 do {
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
601 len1 = deflater.deflate(c1.array(), c1.position(),
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
602 c1.remaining());
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
603 if (len1 > 0) {
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
604 len += len1;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
605 c1.position(c1.position() + len1);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
606 if (c1.remaining() == 0) {
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
607 c1.flip();
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
608 outputs.addLast(c1);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
609 c1 = multicastqueue.allocate(INFLATE_BUFSIZE);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
610 }
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
611 }
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
612 } while (len1 > 0 || !deflater.needsInput()); // &&!deflater.finished());
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
613 }
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
614 if (c1.position() != 0) {
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
615 c1.flip();
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
616 outputs.addLast(c1);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
617 }
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
618 deflater.reset();
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
619 return len;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
620 }
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
621
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
622 /**
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
623 * gunzip byte arrays
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
624 *
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
625 * @param inflater
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
626 * @param inputs byte data[]
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
627 * @param bytes byte data[]
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
628 * @return number of total bytes
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
629 * @throws IOException
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
630 */
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
631 public int unzip(Inflater inflater, LinkedList<ByteBuffer> inputs,
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
632 int inputIndex, byte[] bytes, int bufSize) throws DataFormatException {
182
b3426724667b fix read send data.
oc
parents: 181
diff changeset
633 int position = 0;
b3426724667b fix read send data.
oc
parents: 181
diff changeset
634 int limit = bytes.length;
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
635 while (inputIndex < inputs.size()) {
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
636 ByteBuffer input = inputs.get(inputIndex++);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
637 inflater.setInput(input.array(), input.position(), input.limit());
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
638 // if (inputIndex==inputs.size()) if inflater/deflater has symmetry,
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
639 // we need this
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
640 // inflater.end(); but this won't work
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
641 do {
318
d01d56038dd1 try catch unzip inflate error.
oc
parents: 317
diff changeset
642 int len0;
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
643 len0 = inflater.inflate(bytes, position, limit - position);
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
644 if (len0 > 0) {
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
645 position += len0;
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
646 if (position > limit) throw new DataFormatException();
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
647 }
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
648 } while (!inflater.needsInput());
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
649 }
182
b3426724667b fix read send data.
oc
parents: 181
diff changeset
650 return position;
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
651 }
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
652
135
ada4d850a820 lostParent and notFoundParenet
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 134
diff changeset
653 /**
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 342
diff changeset
654 * Multicast framebufferUpdate to children.
135
ada4d850a820 lostParent and notFoundParenet
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 134
diff changeset
655 * read FrameBuffferUpdate. If it is ZLE, make it ZLEE which is self contained compressed packet.
ada4d850a820 lostParent and notFoundParenet
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 134
diff changeset
656 * put the packet to the multicastqueue. Then normal rendering engine read the same stream using is.reset().
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
657 *
135
ada4d850a820 lostParent and notFoundParenet
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 134
diff changeset
658 * @param dataLen
ada4d850a820 lostParent and notFoundParenet
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 134
diff changeset
659 * @param reader
ada4d850a820 lostParent and notFoundParenet
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 134
diff changeset
660 * @throws TransportException
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
661 * @throws UnsupportedEncodingException
135
ada4d850a820 lostParent and notFoundParenet
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 134
diff changeset
662 */
264
83d0256a8808 add fixing display filter.
oc
parents: 257
diff changeset
663 public void readSendData(int dataLen, Reader reader, byte[] bytes, FramebufferUpdateRectangle rect)
232
6ee4cdca104c send value of port and localhost in checkdelay framebufferupdate, and get this.
oc
parents: 231
diff changeset
664 throws TransportException, UnsupportedEncodingException {
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
665 LinkedList<ByteBuffer> bufs = new LinkedList<ByteBuffer>();
420
0ad52aac3bc3 Send repeat FramebufferUpdateRequest from Timer class
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 419
diff changeset
666 int BLOCKSIZE = 64 * 1024;
414
3af5f4af2d63 Send data size for checkDelay
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 412
diff changeset
667 int headerLen = rect.getEncodingType() == EncodingType.CHECK_DELAY ? 24 : 16;
3af5f4af2d63 Send data size for checkDelay
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 412
diff changeset
668 ByteBuffer header = multicastqueue.allocate(headerLen);
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
669 ByteBuffer serial = multicastqueue.allocate(4 + 8);
378
60abae693629 Compare SerialNumber flag
innparusu
parents: 373
diff changeset
670 if (!isTreeManager() && addSerialNum) {
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
671 reader.readBytes(serial.array(), 0, 4 + 8);
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
672 serial.limit(4 + 8);
182
b3426724667b fix read send data.
oc
parents: 181
diff changeset
673 }
185
feefc1e58153 minor fix
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 182
diff changeset
674 reader.mark(dataLen);
414
3af5f4af2d63 Send data size for checkDelay
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 412
diff changeset
675 reader.readBytes(header.array(), 0, headerLen);
3af5f4af2d63 Send data size for checkDelay
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 412
diff changeset
676 header.limit(headerLen);
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
677 if (header.get(0) == FramebufferUpdate) {
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
678 int encoding = header.getInt(12);
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
679
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
680 if (encoding == EncodingType.ZRLE.getId()
229
5eb8aa65f387 fix checkdelay number-of-rectangle, and send checkdelay to lower node.
oc
parents: 227
diff changeset
681 || encoding == EncodingType.ZLIB.getId()) {
186
f76ee760c2d2 dead lock on command line root
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 185
diff changeset
682 // recompress into ZREE
f76ee760c2d2 dead lock on command line root
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 185
diff changeset
683 // uncompressed result is remain in bytes
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
684 ByteBuffer len = multicastqueue.allocate(4);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
685 reader.readBytes(len.array(), 0, 4);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
686 len.limit(4);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
687 ByteBuffer inputData = multicastqueue.allocate(dataLen - 20);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
688 reader.readBytes(inputData.array(), 0, inputData.capacity());
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
689 inputData.limit(dataLen - 20);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
690 LinkedList<ByteBuffer> inputs = new LinkedList<ByteBuffer>();
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
691 inputs.add(inputData);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
692 header.putInt(12, EncodingType.ZRLEE.getId()); // means
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
693 // recompress
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
694 // every time
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
695 // using new Deflecter every time is incompatible with the
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
696 // protocol, clients have to be modified.
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
697 Deflater nDeflater = deflater; // new Deflater();
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
698 LinkedList<ByteBuffer> out = new LinkedList<ByteBuffer>();
380
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
699 try {
182
b3426724667b fix read send data.
oc
parents: 181
diff changeset
700 unzip(inflater, inputs, 0, bytes, INFLATE_BUFSIZE);
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
701 // dump32(inputs);
182
b3426724667b fix read send data.
oc
parents: 181
diff changeset
702 out.add(ByteBuffer.wrap(bytes));
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
703 int len2 = zip(nDeflater, out, 0, bufs);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
704 ByteBuffer blen = multicastqueue.allocate(4);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
705 blen.putInt(len2);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
706 blen.flip();
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
707 bufs.addFirst(blen);
415
5c3635d6ab3c Send Check_Delay packet if checkDelay flag is true
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 414
diff changeset
708 if (checkDelay) {
5c3635d6ab3c Send Check_Delay packet if checkDelay flag is true
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 414
diff changeset
709 bufs = createCheckDelayHeader(bufs, header);
5c3635d6ab3c Send Check_Delay packet if checkDelay flag is true
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 414
diff changeset
710 } else {
5c3635d6ab3c Send Check_Delay packet if checkDelay flag is true
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 414
diff changeset
711 bufs.addFirst(header);
5c3635d6ab3c Send Check_Delay packet if checkDelay flag is true
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 414
diff changeset
712 }
380
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
713 if (addSerialNum) {
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
714 addSerialNumber(bufs);
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
715 }
270
2d934eee4f4b small fix
oc
parents: 269
diff changeset
716 if (filterSingleDisplay) {
275
0f9b3de45fb2 set main display size.
oc
parents: 270
diff changeset
717 if (rect.x < singleWidth) {
270
2d934eee4f4b small fix
oc
parents: 269
diff changeset
718 multicastqueue.put(bufs);
2d934eee4f4b small fix
oc
parents: 269
diff changeset
719 }
2d934eee4f4b small fix
oc
parents: 269
diff changeset
720 } else {
2d934eee4f4b small fix
oc
parents: 269
diff changeset
721 multicastqueue.put(bufs);
2d934eee4f4b small fix
oc
parents: 269
diff changeset
722 }
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
723 } catch (IOException e) {
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
724 throw new TransportException(e);
335
49e25659ad05 remove socketClose, close unused viewer -d mode.
oc
parents: 334
diff changeset
725 } catch (DataFormatException e) {
49e25659ad05 remove socketClose, close unused viewer -d mode.
oc
parents: 334
diff changeset
726 throw new TransportException(e);
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
727 }
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
728 return;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
729 }
233
26b7c0a6d91b fix indent.
oc
parents: 232
diff changeset
730
186
f76ee760c2d2 dead lock on command line root
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 185
diff changeset
731 // ZRLEE is already compressed
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
732 bufs.add(header);
380
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
733 if (addSerialNum) {
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
734 this.addSerialNumber(bufs);
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
735 }
414
3af5f4af2d63 Send data size for checkDelay
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 412
diff changeset
736 if (dataLen > headerLen) {
3af5f4af2d63 Send data size for checkDelay
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 412
diff changeset
737 ByteBuffer b = multicastqueue.allocate(dataLen - headerLen);
3af5f4af2d63 Send data size for checkDelay
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 412
diff changeset
738 reader.readBytes(b.array(), 0, dataLen - headerLen);
3af5f4af2d63 Send data size for checkDelay
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 412
diff changeset
739 b.limit(dataLen - headerLen);
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
740 bufs.add(b);
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
741 }
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
742 multicastqueue.put(bufs);
233
26b7c0a6d91b fix indent.
oc
parents: 232
diff changeset
743
118
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
744 return;
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
745 }
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
746 // It may be compressed. We can inflate here to avoid repeating clients
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
747 // decompressing here,
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
748 // but it may generate too many large data. It is better to do it in
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
749 // each client.
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
750 // But we have do inflation for all input data, so we have to do it
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
751 // here.
38e461e9b9c9 remove duplicated code in MyRfbProto*
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 113
diff changeset
752 }
124
214d4f206431 add TreeVNC command number.
oc
parents: 123
diff changeset
753
415
5c3635d6ab3c Send Check_Delay packet if checkDelay flag is true
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 414
diff changeset
754 public LinkedList<ByteBuffer> createCheckDelayHeader(LinkedList<ByteBuffer> checkDelay, ByteBuffer header) {
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
755 int x = (int) header.getShort(4);
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
756 int y = (int) header.getShort(6);
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
757 int width = (int) header.getShort(8);
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
758 int height = (int) header.getShort(10);
414
3af5f4af2d63 Send data size for checkDelay
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 412
diff changeset
759 long time = System.currentTimeMillis();
3af5f4af2d63 Send data size for checkDelay
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 412
diff changeset
760 checkDelay.addFirst(new CheckDelay(x, y, width, height, time, EncodingType.CHECK_DELAY).getMessage());
415
5c3635d6ab3c Send Check_Delay packet if checkDelay flag is true
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 414
diff changeset
761 return checkDelay;
414
3af5f4af2d63 Send data size for checkDelay
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 412
diff changeset
762 }
3af5f4af2d63 Send data size for checkDelay
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 412
diff changeset
763
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
764 public void setId(short id) {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
765 this.id = id;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
766 }
169
8ab1f6905db4 Try to hide root frame
oc
parents: 166
diff changeset
767
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
768 public short getId() {
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
769 return id;
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
770 }
169
8ab1f6905db4 Try to hide root frame
oc
parents: 166
diff changeset
771
174
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
772 public void setMyAddress(String myHostName) {
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
773 this.myAddress = myHostName;
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
774
174
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
775 }
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
776
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
777 public void setLeader(boolean leader) {
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
778 this.leader = leader;
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
779 }
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
780
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
781 public boolean isLeader() {
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
782 return leader;
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
783 }
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
784
203
2f6237fea67e change createTreeManagers timing.
oc
parents: 202
diff changeset
785 public void setTreeManager(String intf, TreeManagement clients) {
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
786 nets.setTreeManager(intf, clients);
174
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
787 }
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
788
203
2f6237fea67e change createTreeManagers timing.
oc
parents: 202
diff changeset
789 public TreeManagement getTreeManager(String intf) {
418
0543c380308c Move bottleneck Node to outside node list
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 417
diff changeset
790 this.treeManager = nets.getTreeManager(intf);
0543c380308c Move bottleneck Node to outside node list
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 417
diff changeset
791 this.nodeList = treeManager.getList();
0543c380308c Move bottleneck Node to outside node list
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 417
diff changeset
792 return treeManager;
174
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
793 }
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
794
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
795 /**
290
c10e0dee7bbb add READY_SHARE_SOUND msg, add function of receive READY_SHARE_SOUND msg, add sendSound thread.
oc
parents: 287
diff changeset
796 * change VNCServer is called when host change.
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
797 *
405
cdab1354e227 Add multiscreen Share Filtering flag
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 402
diff changeset
798 * @param vncProxyService
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
799 * @param hostName HostAddress
427
ed15f0bd8dfa Remove shareScrrenNumber for ScreenChangeRequest Message
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 425
diff changeset
800 * @param x
ed15f0bd8dfa Remove shareScrrenNumber for ScreenChangeRequest Message
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 425
diff changeset
801 * @param y
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
802 * @param width FrameWidth
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
803 * @param height FrameHeight
427
ed15f0bd8dfa Remove shareScrrenNumber for ScreenChangeRequest Message
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 425
diff changeset
804 * @param scale
351
024ac6e457f4 fix changeVNCServer
oc
parents: 350
diff changeset
805 * @param newVNCServerId
382
37eb97a23dcf add variable(is,os) to changeVNCServer
kkb
parents: 380
diff changeset
806 * @param is
37eb97a23dcf add variable(is,os) to changeVNCServer
kkb
parents: 380
diff changeset
807 * @param os
174
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
808 */
427
ed15f0bd8dfa Remove shareScrrenNumber for ScreenChangeRequest Message
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 425
diff changeset
809 public void changeVNCServer(ViewerInterface vncProxyService, String hostName, int port, int x, int y, int width, int height, int scale, short newVNCServerId, Reader is, Writer os)
325
cc9d33208f34 small change catch error message.
oc
parents: 322
diff changeset
810 throws IOException {
351
024ac6e457f4 fix changeVNCServer
oc
parents: 350
diff changeset
811 if (newVNCServerId == -1) {
339
4713559f5838 if have a parent, send serverChangeRequest and whereToConnect
oc
parents: 335
diff changeset
812 // change to the tree vnc root on other network.
428
f6a828dd37b0 Change timing for setting share screen info
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 427
diff changeset
813 vncProxyService.changeToDirectConnectedServer(hostName, is, os, x, y, width, height, scale);
339
4713559f5838 if have a parent, send serverChangeRequest and whereToConnect
oc
parents: 335
diff changeset
814 return;
4713559f5838 if have a parent, send serverChangeRequest and whereToConnect
oc
parents: 335
diff changeset
815 }
342
4c670edf3065 fix setting remote id
oc
parents: 341
diff changeset
816 // serverChangeの処理
428
f6a828dd37b0 Change timing for setting share screen info
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 427
diff changeset
817 vncProxyService.inhelitClients(hostName, newVNCServerId, x, y, width, height, scale);
317
3c63bc88383e always fit screen, -d mode.
oc
parents: 306
diff changeset
818 // after connecting VNC server, rfb send SEND_INIT_DATA command and wakes me up if necessary
322
345185ef630e close viewer as soon as push share screen button.
oc
parents: 320
diff changeset
819 // stop reader stop
174
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
820 }
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
821
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
822 /**
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
823 * start accepting children
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
824 * run rootFinderListener if necessary
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
825 */
176
fa6cfb85444e on going ...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 175
diff changeset
826 public void createConnectionAndStart(ViewerInterface v) {
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
827 selectPort(ConnectionParams.DEFAULT_VNC_ROOT);
176
fa6cfb85444e on going ...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 175
diff changeset
828 acceptThread = new TreeVncCommandChannelListener(this, getAcceptPort());
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
829 Thread thread = new Thread(acceptThread, "TreeVNC-accept");
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
830 thread.start();
176
fa6cfb85444e on going ...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 175
diff changeset
831 }
fa6cfb85444e on going ...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 175
diff changeset
832
174
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
833 public TreeVncCommandChannelListener getAcceptThread() {
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
834 return acceptThread;
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
835 }
2e1530139169 reorganization
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 170
diff changeset
836
176
fa6cfb85444e on going ...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 175
diff changeset
837 public void setConnectionParam(CreateConnectionParam createConnectionParam) {
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
838 cp = createConnectionParam;
176
fa6cfb85444e on going ...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 175
diff changeset
839 }
fa6cfb85444e on going ...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 175
diff changeset
840
fa6cfb85444e on going ...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 175
diff changeset
841 public CreateConnectionParam getConnectionParam() {
fa6cfb85444e on going ...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 175
diff changeset
842 return cp;
fa6cfb85444e on going ...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 175
diff changeset
843 }
fa6cfb85444e on going ...
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 175
diff changeset
844
178
34b7558aeffa remove TreeTask, StartTreeHandling
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 177
diff changeset
845 public boolean hasViewer() {
34b7558aeffa remove TreeTask, StartTreeHandling
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 177
diff changeset
846 return hasViewer;
34b7558aeffa remove TreeTask, StartTreeHandling
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 177
diff changeset
847 }
34b7558aeffa remove TreeTask, StartTreeHandling
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 177
diff changeset
848
34b7558aeffa remove TreeTask, StartTreeHandling
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 177
diff changeset
849 public void setHasViewer(boolean b) {
34b7558aeffa remove TreeTask, StartTreeHandling
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 177
diff changeset
850 hasViewer = b;
34b7558aeffa remove TreeTask, StartTreeHandling
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 177
diff changeset
851 }
34b7558aeffa remove TreeTask, StartTreeHandling
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 177
diff changeset
852
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
853 public void setShowTree(boolean showTree) {
240
7310e7d7a45f add option --checkDelay.
oc
parents: 239
diff changeset
854 this.showTreeNode = showTree;
7310e7d7a45f add option --checkDelay.
oc
parents: 239
diff changeset
855 }
7310e7d7a45f add option --checkDelay.
oc
parents: 239
diff changeset
856
7310e7d7a45f add option --checkDelay.
oc
parents: 239
diff changeset
857 public void setCheckDelay(boolean checkDelay) {
7310e7d7a45f add option --checkDelay.
oc
parents: 239
diff changeset
858 this.checkDelay = checkDelay;
223
3189e210a7ed indent fix.
oc
parents: 207
diff changeset
859 }
194
b038aafeb2b0 hide VNC server's view to prevent video feed back.
oc
parents: 192
diff changeset
860
241
b21a7842a41d add option addSerialNum.
oc
parents: 240
diff changeset
861 public void setAddSerialNum(boolean addSerialNum) {
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
862 this.addSerialNum = addSerialNum;
241
b21a7842a41d add option addSerialNum.
oc
parents: 240
diff changeset
863 }
b21a7842a41d add option addSerialNum.
oc
parents: 240
diff changeset
864
235
15e66adbb8bb get checkdelay nodeNum.
oc
parents: 234
diff changeset
865 public int getNodeNum(int port, String address) {
232
6ee4cdca104c send value of port and localhost in checkdelay framebufferupdate, and get this.
oc
parents: 231
diff changeset
866 int nodeNum = 0;
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
867
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
868 for (Iterator<TreeVNCNode> i = nodeList.iterator(); i.hasNext(); ) {
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
869 TreeVNCNode tvn = (TreeVNCNode) i.next();
235
15e66adbb8bb get checkdelay nodeNum.
oc
parents: 234
diff changeset
870 if (port == tvn.port && address.equals(tvn.hostname)) {
15e66adbb8bb get checkdelay nodeNum.
oc
parents: 234
diff changeset
871 nodeNum = tvn.treeNum;
15e66adbb8bb get checkdelay nodeNum.
oc
parents: 234
diff changeset
872 return nodeNum;
15e66adbb8bb get checkdelay nodeNum.
oc
parents: 234
diff changeset
873 }
232
6ee4cdca104c send value of port and localhost in checkdelay framebufferupdate, and get this.
oc
parents: 231
diff changeset
874 }
6ee4cdca104c send value of port and localhost in checkdelay framebufferupdate, and get this.
oc
parents: 231
diff changeset
875 return nodeNum;
6ee4cdca104c send value of port and localhost in checkdelay framebufferupdate, and get this.
oc
parents: 231
diff changeset
876 }
241
b21a7842a41d add option addSerialNum.
oc
parents: 240
diff changeset
877
257
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
878 public void setFixingSize(boolean fixingSize) {
11b59b223222 add function of fixing display size
oc
parents: 256
diff changeset
879 this.fixingSize = fixingSize;
256
dfec8bc1eb8e fix --retina option
oc
parents: 255
diff changeset
880 }
267
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
881
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
882 public void setFilterSingleDisplay(boolean filterSingleDisplay) {
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
883 this.filterSingleDisplay = filterSingleDisplay;
5f697251860b add --filterSingleDisplay option.
oc
parents: 266
diff changeset
884 }
281
16d3584ae7a0 fix SEND_SINGLE_DISPLAY_WIDTH
oc
parents: 280
diff changeset
885
293
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
886 private DatagramSocket createSocket() {
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
887
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
888 try {
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
889 if (socket == null) {
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
890 this.socket = new DatagramSocket(ConnectionParams.DEFAULT_RTP_PORT, InetAddress.getLocalHost());
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
891 }
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
892 } catch (SocketException e) {
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
893 e.printStackTrace();
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
894 } catch (UnknownHostException e) {
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
895 e.printStackTrace();
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
896 }
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
897 return socket;
d1ceb4b7097a add function receive sound.
oc
parents: 292
diff changeset
898 }
306
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
899
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
900 public void setSingleDisplaySize(int singleWidth, int singleHeight) {
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
901 this.singleWidth = singleWidth;
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
902 this.singleHeight = singleHeight;
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
903 }
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
904
417
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
905 public int getX() {
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
906 return x;
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
907 }
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
908
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
909 public int getY() {
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
910 return y;
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
911 }
358
59b1ef1b0a89 fix ilter single display (HiDPI)
oc
parents: 357
diff changeset
912
306
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
913 public int getSingleWidth() {
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
914 return singleWidth;
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
915 }
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
916
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
917 public int getSingleHeight() {
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
918 return singleHeight;
5e55cc34f789 change public to private
oc
parents: 305
diff changeset
919 }
339
4713559f5838 if have a parent, send serverChangeRequest and whereToConnect
oc
parents: 335
diff changeset
920
410
da1d6d6b4981 Enable retina scale to fit screen
innparusu
parents: 405
diff changeset
921 public int getRetinaScale() {
da1d6d6b4981 Enable retina scale to fit screen
innparusu
parents: 405
diff changeset
922 return retinaScale;
da1d6d6b4981 Enable retina scale to fit screen
innparusu
parents: 405
diff changeset
923 }
da1d6d6b4981 Enable retina scale to fit screen
innparusu
parents: 405
diff changeset
924
da1d6d6b4981 Enable retina scale to fit screen
innparusu
parents: 405
diff changeset
925
339
4713559f5838 if have a parent, send serverChangeRequest and whereToConnect
oc
parents: 335
diff changeset
926 public boolean hasParent() {
4713559f5838 if have a parent, send serverChangeRequest and whereToConnect
oc
parents: 335
diff changeset
927 return id != -1;
4713559f5838 if have a parent, send serverChangeRequest and whereToConnect
oc
parents: 335
diff changeset
928 }
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
929
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
930 /**
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
931 * server change to directed connected server
395
704ac9e79e25 Call startVNCConnectionWithSocket for directedServerChangeReqeust
innparusu
parents: 394
diff changeset
932 * server maybe on the different network
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
933 * so can not in whereToConnect message
395
704ac9e79e25 Call startVNCConnectionWithSocket for directedServerChangeReqeust
innparusu
parents: 394
diff changeset
934 * reuse dynamic connect socket us a new client
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
935 * reother server exchange socket when serverChangeRequest with id -1
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
936 *
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
937 * @param previousReader
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
938 * @param previousWriter
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
939 */
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
940 public void exchangeDirectConnectedServer(Reader previousReader, Writer previousWriter) {
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
941 String adr = viewer.getRfb().getMyAddress();
410
da1d6d6b4981 Enable retina scale to fit screen
innparusu
parents: 405
diff changeset
942 int scale = viewer.getRfb().getRetinaScale();
417
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
943 int x = 0;
c225c7963778 Send screen position
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 415
diff changeset
944 int y = 0;
427
ed15f0bd8dfa Remove shareScrrenNumber for ScreenChangeRequest Message
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 425
diff changeset
945 ScreenChangeRequest scr = new ScreenChangeRequest(adr, ConnectionParams.DEFAULT_VNC_ROOT, (short) -1, x, y, singleWidth, singleHeight, scale);
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
946 try {
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
947 scr.send(previousWriter);
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
948 } catch (TransportException e) {
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
949 e.printStackTrace();
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
950 return;
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
951 }
425
90c059a70e2e Fix Change ViewerWindow
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 424
diff changeset
952 // newClient(previousWriter, previousReader, null);
384
0bbfc23ef8c4 implements exchangeDirectConnectedServer method
innparusu
parents: 383
diff changeset
953 }
389
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
954
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
955 /**
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
956 * Requested server is connected. stop old connection, replace old connection parameter such as
423
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
957 * context (PROTOCOL)
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
958 * start new connection and send INIT_DATA
ffe01c959cdd Fix LostChild for root node
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 420
diff changeset
959 *
389
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
960 * @param workingProtocol
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
961 * @param connectionPresenter
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
962 */
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
963 public synchronized void newVNCConnection(Protocol workingProtocol, ConnectionPresenter connectionPresenter) {
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
964 ProtocolContext previousContext = getContext();
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
965 stopReceiverTask();
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
966 setProtocolContext(workingProtocol);
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
967 connectionPresenter.viewer.setConnectionPresenter(connectionPresenter);
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
968 connectionPresenter.viewer.getConnectionPresenter().addModel("ConnectionParamsModel", connectionPresenter.getConnectionParams());
428
f6a828dd37b0 Change timing for setting share screen info
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 427
diff changeset
969 this.x = connectionPresenter.getX();
f6a828dd37b0 Change timing for setting share screen info
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 427
diff changeset
970 this.y = connectionPresenter.getY();
f6a828dd37b0 Change timing for setting share screen info
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 427
diff changeset
971 this.frameSizeWidth = connectionPresenter.getFrameSizeWidth();
f6a828dd37b0 Change timing for setting share screen info
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 427
diff changeset
972 this.frameSizeHeight = connectionPresenter.getFrameSizeHeight();
f6a828dd37b0 Change timing for setting share screen info
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 427
diff changeset
973 this.singleWidth = frameSizeWidth;
f6a828dd37b0 Change timing for setting share screen info
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 427
diff changeset
974 this.singleHeight = frameSizeHeight;
f6a828dd37b0 Change timing for setting share screen info
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 427
diff changeset
975 this.retinaScale = connectionPresenter.getRetinaScale();
389
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
976 if (previousContext != null && isTreeManager() && hasParent()) {
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
977 Reader previousReader = previousContext.getReader();
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
978 Writer previousWriter = previousContext.getWriter();
424
15836504f1a2 Fix ErrorAnnounce
Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
parents: 423
diff changeset
979 // exchangeDirectConnectedServer(previousReader, previousWriter);
389
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
980 }
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
981 enableChildrenTransmission();
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
982 printNetworkInterface();
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
983 sendDesktopSizeChange(connectionPresenter.getReconnectingId());
5a61cbdd83ab Lock rfb
innparusu
parents: 385
diff changeset
984 }
412
372532ae5f4d Add ErrorAnnounce
innparusu
parents: 411
diff changeset
985
372532ae5f4d Add ErrorAnnounce
innparusu
parents: 411
diff changeset
986 public void sendErrorAnnounce(short reconnectingId, String message) {
372532ae5f4d Add ErrorAnnounce
innparusu
parents: 411
diff changeset
987 LinkedList<ByteBuffer> errorAnnounce = new LinkedList<ByteBuffer>();
372532ae5f4d Add ErrorAnnounce
innparusu
parents: 411
diff changeset
988 errorAnnounce.add(new ChildNodeAnnounce(EncodingType.ERROR_ANNOUNCE, message.getBytes(), reconnectingId).getMessage());
372532ae5f4d Add ErrorAnnounce
innparusu
parents: 411
diff changeset
989 if (addSerialNum) {
372532ae5f4d Add ErrorAnnounce
innparusu
parents: 411
diff changeset
990 addSerialNumber(errorAnnounce);
372532ae5f4d Add ErrorAnnounce
innparusu
parents: 411
diff changeset
991 }
372532ae5f4d Add ErrorAnnounce
innparusu
parents: 411
diff changeset
992 multicastqueue.put(errorAnnounce);
372532ae5f4d Add ErrorAnnounce
innparusu
parents: 411
diff changeset
993 }
240
7310e7d7a45f add option --checkDelay.
oc
parents: 239
diff changeset
994 }