Members/riono/TreeVNC_ja_comment: src/main/java/jp/ac/u_ryukyu/treevnc/TreeRFBProto.java annotate

annotate src/main/java/jp/ac/u_ryukyu/treevnc/TreeRFBProto.java @ 470:f7210f834403

add unique node id

author	mir3636
date	Wed, 03 Aug 2016 19:09:11 +0900
parents	432e2967eaab
children	c1b4befc5933

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

Mercurial > hg > Members > riono > TreeVNC_ja_comment

annotate src/main/java/jp/ac/u_ryukyu/treevnc/TreeRFBProto.java @ 470:f7210f834403