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

annotate src/main/java/jp/ac/u_ryukyu/treevnc/MyRfbProto.java @ 144:1e004d9c599d

notify connection panel

author	oc
date	Thu, 12 Jun 2014 19:35:00 +0900
parents	4547543ca73c
children	649794dfb9d5

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
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	3 import java.io.IOException;
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	4 import java.io.OutputStream;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	5 import java.net.BindException;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	6 import java.net.ServerSocket;
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	7 import java.net.Socket;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	8 import java.nio.ByteBuffer;
109 457f9dfbf7ce minor fix. oc parents: 107 diff changeset	9 import java.nio.ByteOrder;
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	10 import java.util.LinkedList;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	11 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	12 import java.util.zip.DataFormatException;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	13 import java.util.zip.Deflater;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	14 import java.util.zip.Inflater;
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	15
125 32c6563492f3 add vnc protocol command sender. oc parents: 124 diff changeset	16 import jp.ac.u_ryukyu.treevnc.client.TreeVncProtocol;
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	17 import jp.ac.u_ryukyu.treevnc.server.RequestScreenThread;
94 75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	18 import jp.ac.u_ryukyu.treevnc.server.VncProxyService;
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	19
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	20 import com.glavsoft.exceptions.TransportException;
107 660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	21 import com.glavsoft.rfb.client.ClientToServerMessage;
96 76e49dd9c9c5 Client resize without reconnection oc parents: 94 diff changeset	22 import com.glavsoft.rfb.encoding.EncodingType;
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	23 import com.glavsoft.rfb.protocol.Protocol;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	24 import com.glavsoft.rfb.protocol.ProtocolContext;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	25 import com.glavsoft.transport.Reader;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	26 import com.glavsoft.transport.Writer;
65 ffd7537cebfc cuiversion Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 64 diff changeset	27 import com.glavsoft.viewer.ViewerImpl;
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	28
124 214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	29
120 c1b14cef2704 MyRfb fix done. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 118 diff changeset	30 public abstract class MyRfbProto {
33 9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	31 final static int FramebufferUpdateRequest = 3;
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	32 final static int CheckDelay = 11;
103 84f254d8bde4 remove isinstaceof Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 102 diff changeset	33 protected final static int FramebufferUpdate = 0;
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	34 private ProtocolContext context;
103 84f254d8bde4 remove isinstaceof Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 102 diff changeset	35 protected final static String versionMsg_3_856 = "RFB 003.856\n";
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	36 private int clients;
98 8f4c45c1b396 add serial number to desktop size encoding packet. oc parents: 97 diff changeset	37 public MulticastQueue<LinkedList<ByteBuffer>> multicastqueue = new MulticastQueue<LinkedList<ByteBuffer>>();
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	38 private RequestScreenThread rThread;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	39 private boolean proxyFlag = true;
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	40 public int acceptPort = 0;
94 75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	41 protected boolean readyReconnect = false;
98 8f4c45c1b396 add serial number to desktop size encoding packet. oc parents: 97 diff changeset	42 private boolean cuiVersion;
107 660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	43 private long counter = 0; // packet serial number
135 ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	44 TreeVncProtocol treeProtocol;
138 c3761c896607 minor fix oc parents: 135 diff changeset	45 public TreeVncCommand treeVncCommand;
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	46 public ServerSocket servSock;
123 233e94a7b5ed add comment Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 122 diff changeset	47 private boolean permitChangeScreen = true;
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	48 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	49
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	50 private Inflater inflater = new Inflater();
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	51 private Deflater deflater = new Deflater();
135 ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	52 private VncProxyService viewer;
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	53
107 660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	54
33 9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	55 public MyRfbProto() {
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	56 rThread = new RequestScreenThread(this);
143 4547543ca73c findRootReply oc parents: 138 diff changeset	57 treeVncCommand = new TreeVncCommand(null,this,null);
33 9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	58 }
107 660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	59
111 a7988d3c0266 minor fix. oc parents: 110 diff changeset	60 public void setVncProxy(VncProxyService viewer) {
135 ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	61 this.viewer = viewer;
143 4547543ca73c findRootReply oc parents: 138 diff changeset	62 treeVncCommand.setViewer(viewer);
107 660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	63 }
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	64
120 c1b14cef2704 MyRfb fix done. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 118 diff changeset	65 abstract public boolean isRoot() ;
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	66
124 214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	67 public boolean initialConnection(final Writer os, final Reader is)
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	68 throws IOException, TransportException {
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	69 /**
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	70 * initial connection of RFB protocol
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	71 */
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	72 sendRfbVersion(os);
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	73 byte[] b;
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	74 if ((b = readVersionMsg(is, os))!=null) {
135 ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	75 treeVncCommand.treeVncCommand(b,is,os);
124 214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	76 return true;
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	77 }
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	78 sendSecurityType(os);
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	79 readSecType(is);
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	80 sendSecResult(os);
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	81 readClientInit(is);
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	82 sendInitData(os);
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	83 return false;
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	84 }
214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	85
130 1f6bfaa3281b root selection panel Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 129 diff changeset	86 /**
1f6bfaa3281b root selection panel Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 129 diff changeset	87 * handle new client accept
1f6bfaa3281b root selection panel Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 129 diff changeset	88 * it also handle TreeVNC Command
1f6bfaa3281b root selection panel Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 129 diff changeset	89 * @param acceptThread
1f6bfaa3281b root selection panel Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 129 diff changeset	90 * @param newCli
1f6bfaa3281b root selection panel Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 129 diff changeset	91 * @param os
1f6bfaa3281b root selection panel Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 129 diff changeset	92 * @param is
1f6bfaa3281b root selection panel Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 129 diff changeset	93 * @throws IOException
1f6bfaa3281b root selection panel Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 129 diff changeset	94 * @throws TransportException
1f6bfaa3281b root selection panel Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 129 diff changeset	95 */
133 70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	96 public void newClient(AcceptThread acceptThread, final Socket newCli,final Writer os, final Reader is) {
124 214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	97
133 70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	98 try {
70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	99 if (initialConnection(os, is)) {
70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	100 // TreeVNC command is processed
70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	101 newCli.close();
70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	102 return;
70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	103 }
70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	104 } catch (Exception e) {
70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	105 try {
70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	106 newCli.close();
70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	107 } catch (IOException e1) {
70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	108 // log
70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	109 }
70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	110 }
124 214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	111
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	112 final int myId = clients;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	113 final MulticastQueue.Client<LinkedList<ByteBuffer>> c = multicastqueue.newClient();
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	114 final AtomicInteger writerRunning = new AtomicInteger();
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	115 writerRunning.set(1);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	116 /**
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	117 * Timeout thread. If a client is suspended, it has top of queue
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	118 * indefinitely, which caused memory overflow. After the timeout, we
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	119 * poll the queue and discard it. Start long wait if writer is running.
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	120 */
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	121 final Runnable timer = new Runnable() {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	122 public void run() {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	123 int count = 0;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	124 for (;;) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	125 long timeout = 50000 / 8;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	126 try {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	127 synchronized (this) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	128 int state, flag;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	129 writerRunning.set(0);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	130 wait(timeout);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	131 flag = 0;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	132 while ((state = writerRunning.get()) == 0) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	133 c.poll(); // discard, should be timeout
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	134 count++;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	135 if (flag == 0) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	136 System.out.println("Discarding " + myId
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	137 + " count=" + count);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	138 flag = 1;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	139 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	140 wait(10); // if this is too short, writer cannot
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	141 // take the poll, if this is too
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	142 // long, memory will overflow...
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	143 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	144 if (flag == 1)
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	145 System.out.println("Resuming " + myId
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	146 + " count=" + count);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	147 if (state != 1) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	148 System.out.println("Client died " + myId);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	149 break;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	150 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	151 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	152 } catch (InterruptedException e) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	153 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	154 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	155 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	156 };
88 a719aa609e14 add name valuer threads. oc parents: 85 diff changeset	157 new Thread(timer, "timer-discard-multicastqueue").start();
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	158 /**
135 ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	159 * handle command from lower node
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	160 */
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	161 final Runnable reader = new Runnable() {
135 ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	162
122 e2416a246c95 noScreenChange flag on command line ( should be on panel also ) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 120 diff changeset	163 public void run() {
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	164 for (;;) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	165 try {
113 bce2ef0a2e79 use ProtocolContext.sendMessage for upward command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 112 diff changeset	166 final byte b[] = new byte[4096];
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 112 diff changeset	167 final int c = is.readByte(b);
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	168 if (c <= 0)
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	169 throw new IOException();
107 660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	170 if (isRoot()) {
660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	171 if (b[0] == ClientToServerMessage.SERVER_CHANGE_REQUEST) {
660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	172 if (permitChangeScreen()) {
109 457f9dfbf7ce minor fix. oc parents: 107 diff changeset	173 ByteBuffer buf = ByteBuffer.wrap(b);
457f9dfbf7ce minor fix. oc parents: 107 diff changeset	174 buf.order(ByteOrder.BIG_ENDIAN);
457f9dfbf7ce minor fix. oc parents: 107 diff changeset	175 int length = buf.getInt(4);
107 660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	176 if (length == 0)
660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	177 continue;
660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	178 String newHostName = new String(b, 8, length);
111 a7988d3c0266 minor fix. oc parents: 110 diff changeset	179 System.out.println("Root server change request :" + newHostName);
107 660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	180 // please remove these numbers.
660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	181 if (viewer != null) {
660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	182 viewer.changeVNCServer(newHostName, 3200, 1980);
660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	183 }
660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	184 } else {
660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	185 continue;
660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	186 }
660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	187 }
110 464eb64e3fd6 minor fix. oc parents: 109 diff changeset	188 } else if (b[0] == ClientToServerMessage.SERVER_CHANGE_REQUEST) {
113 bce2ef0a2e79 use ProtocolContext.sendMessage for upward command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 112 diff changeset	189 ClientToServerMessage sc = new ClientToServerMessage() {
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 112 diff changeset	190 @Override
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 112 diff changeset	191 public void send(Writer writer)
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 112 diff changeset	192 throws TransportException {
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 112 diff changeset	193 writer.write(b,0,c);
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 112 diff changeset	194 }
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 112 diff changeset	195 };
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 112 diff changeset	196 context.sendMessage(sc);
107 660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	197 }
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	198 // System.out.println("client read "+c);
89 1503a373ab73 close client correctly in -d mode. oc parents: 88 diff changeset	199 } catch (Exception e) {
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	200 try {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	201 writerRunning.set(2);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	202 os.close();
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	203 is.close();
36 b7d4d0349f99 write part of reconnection and remove warning. one parents: 35 diff changeset	204 break;
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	205 } catch (IOException e1) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	206 } catch (TransportException e1) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	207 e1.printStackTrace();
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	208 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	209 return;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	210 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	211 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	212 }
107 660b296d4f75 send change screen command throw the tree. oc parents: 103 diff changeset	213
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	214 };
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	215 /**
135 ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	216 * send packets to a client (one thread for each client )
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	217 */
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	218 Runnable sender = new Runnable() {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	219 public void run() {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	220 writerRunning.set(1);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	221 try {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	222 requestThreadNotify();
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	223
88 a719aa609e14 add name valuer threads. oc parents: 85 diff changeset	224 // after this, we discard upward packet.
131 95f53663295c lost host and parent not found Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 130 diff changeset	225 new Thread(reader, "upward-packet-processing").start();
135 ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	226
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	227 for (;;) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	228 LinkedList<ByteBuffer> bufs = c.poll();
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	229 int inputIndex = 0;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	230 ByteBuffer header = bufs.get(inputIndex);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	231 if (header == null)
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	232 continue;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	233 else if (header.get(0) == CheckDelay) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	234 writeToClient(os, bufs, inputIndex);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	235 continue;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	236 } else if (header.get(0) == FramebufferUpdate) {
63 84f1c39ba3bf temp commit Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 61 diff changeset	237 //System.out.println("client "+ myId);
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	238 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	239 /*
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	240 * if(i%20==0){ sendDataCheckDelay(); } i++;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	241 */
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	242 writeToClient(os, bufs, inputIndex);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	243 writerRunning.set(1); // yes my client is awaking.
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	244 }
89 1503a373ab73 close client correctly in -d mode. oc parents: 88 diff changeset	245 } catch (Exception e) {
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	246 try {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	247 writerRunning.set(2);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	248 os.close();
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	249 } catch (IOException e1) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	250 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	251 /* if socket closed cliList.remove(newCli); */
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	252 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	253 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	254
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	255 public void writeToClient(final Writer os,
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	256 LinkedList<ByteBuffer> bufs, int inputIndex)
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	257 throws TransportException {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	258 while (inputIndex < bufs.size()) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	259 ByteBuffer b = bufs.get(inputIndex++);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	260 os.write(b.array(), b.position(), b.limit());
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	261 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	262 os.flush();
74 f1938dd3b518 don't heap space error. oc parents: 69 diff changeset	263 bufs = null;
f1938dd3b518 don't heap space error. oc parents: 69 diff changeset	264 multicastqueue.heapAvailable();
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	265 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	266 };
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	267 clients++;
88 a719aa609e14 add name valuer threads. oc parents: 85 diff changeset	268 new Thread(sender, "writer-to-lower-node").start();
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	269
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	270 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	271
122 e2416a246c95 noScreenChange flag on command line ( should be on panel also ) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 120 diff changeset	272
e2416a246c95 noScreenChange flag on command line ( should be on panel also ) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 120 diff changeset	273 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	274 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	275 }
e2416a246c95 noScreenChange flag on command line ( should be on panel also ) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 120 diff changeset	276
e2416a246c95 noScreenChange flag on command line ( should be on panel also ) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 120 diff changeset	277
e2416a246c95 noScreenChange flag on command line ( should be on panel also ) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 120 diff changeset	278 public void setPermitChangeScreen(boolean v) {
e2416a246c95 noScreenChange flag on command line ( should be on panel also ) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 120 diff changeset	279 permitChangeScreen = v;
e2416a246c95 noScreenChange flag on command line ( should be on panel also ) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 120 diff changeset	280 }
e2416a246c95 noScreenChange flag on command line ( should be on panel also ) Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 120 diff changeset	281
88 a719aa609e14 add name valuer threads. oc parents: 85 diff changeset	282 public void requestThreadNotify() {
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	283 rThread.reStart();
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	284 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	285
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	286 private void sendRfbVersion(Writer writer) throws IOException, TransportException {
54 0ae87c7e767c bug fix one parents: 52 diff changeset	287 writer.write(versionMsg_3_856.getBytes());
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	288 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	289
124 214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	290 private byte[] readVersionMsg(Reader reader, Writer writer) throws IOException, TransportException {
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	291
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	292 byte[] b = new byte[12];
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	293
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	294 reader.readBytes(b);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	295
128 0cf1541f69bb find root reply is accepted. oc parents: 126 diff changeset	296 if ((b[0]&0xff)>=220) return b; // TreeVNC extention command.
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	297 if ((b[0] != 'R') \|\| (b[1] != 'F') \|\| (b[2] != 'B') \|\| (b[3] != ' ')
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	298 \|\| (b[4] < '0') \|\| (b[4] > '9') \|\| (b[5] < '0') \|\| (b[5] > '9')
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	299 \|\| (b[6] < '0') \|\| (b[6] > '9') \|\| (b[7] != '.')
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	300 \|\| (b[8] < '0') \|\| (b[8] > '9') \|\| (b[9] < '0') \|\| (b[9] > '9')
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	301 \|\| (b[10] < '0') \|\| (b[10] > '9') \|\| (b[11] != '\n')) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	302 throw new IOException("this is not an RFB server");
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	303 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	304
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	305 int rfbMajor = (b[4] - '0') * 100 + (b[5] - '0') * 10 + (b[6] - '0');
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	306 int rfbMinor = (b[8] - '0') * 100 + (b[9] - '0') * 10 + (b[10] - '0');
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	307
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	308 if (rfbMajor < 3) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	309 throw new IOException(
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	310 "RFB server does not support protocol version 3");
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	311 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	312
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	313 if (rfbMinor == 855) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	314 sendProxyFlag(writer);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	315 if (proxyFlag)
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	316 sendPortNumber(writer);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	317 }
124 214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	318 return null;
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	319 }
45 20326a4b9d88 create new change button for client. one parents: 43 diff changeset	320
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	321
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	322 private void sendProxyFlag(Writer writer) throws TransportException {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	323 if (proxyFlag)
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	324 writer.writeInt(1);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	325 else
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	326 writer.writeInt(0);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	327 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	328
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	329 private void sendPortNumber(Writer writer) throws TransportException {
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	330 ByteBuffer b = ByteBuffer.allocate(4);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	331 b.order(ByteOrder.BIG_ENDIAN);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	332 b.putInt(9999);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	333 writer.write(b.array());
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	334 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	335
45 20326a4b9d88 create new change button for client. one parents: 43 diff changeset	336
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	337 private void readSecType(Reader reader) throws TransportException {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	338 byte[] b = new byte[1];
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	339 reader.read(b);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	340 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	341
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	342 private void sendSecurityType(Writer os) throws TransportException {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	343 // number-of-security-types
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	344 os.writeInt(1);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	345 // security-types
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	346 // 1:None
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	347 os.writeInt(1);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	348
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	349 /*
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	350 * os.write(4); os.write(30); os.write(31); os.write(32); os.write(35);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	351 * os.flush();
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	352 */
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	353 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	354
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	355 private void sendSecResult(Writer os) throws TransportException {
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	356 ByteBuffer b = ByteBuffer.allocate(4);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	357 b.order(ByteOrder.BIG_ENDIAN);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	358 b.putInt(0);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	359 os.write(b.array());
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	360 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	361
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	362 private void readClientInit(Reader in) throws TransportException {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	363 byte[] b = new byte[0];
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	364 in.readBytes(b);
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	365 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	366
85 432dac0b9dae delete Share Screen pop up in display mode. sugi parents: 77 diff changeset	367 byte initData[] = {7, -128, 4, 56, 32, 24, 0, 1, 0, -1, 0, -1, 0, -1, 16, 8, 0, 0, 0, 0, 0, 0, 0, 7, 102, 105, 114, 101, 102, 108, 121};
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	368 private void sendInitData(Writer os) throws TransportException {
85 432dac0b9dae delete Share Screen pop up in display mode. sugi parents: 77 diff changeset	369 // In case of "-d" we have no context
432dac0b9dae delete Share Screen pop up in display mode. sugi parents: 77 diff changeset	370 if (context != null){
432dac0b9dae delete Share Screen pop up in display mode. sugi parents: 77 diff changeset	371 os.write(context.getInitData());
432dac0b9dae delete Share Screen pop up in display mode. sugi parents: 77 diff changeset	372 } else {
432dac0b9dae delete Share Screen pop up in display mode. sugi parents: 77 diff changeset	373 // Send dummy data
432dac0b9dae delete Share Screen pop up in display mode. sugi parents: 77 diff changeset	374 os.write(initData);
432dac0b9dae delete Share Screen pop up in display mode. sugi parents: 77 diff changeset	375 }
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	376 }
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	377
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	378 public void setProtocolContext(Protocol workingProtocol) {
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	379 context = workingProtocol;
18fad65bc447 Create MyRfbProto.java one parents: diff changeset	380 }
29 57eb5575e6c4 MyRfbProto for client and proxy. one parents: 28 diff changeset	381
134 128cce60c43c where to connect command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 133 diff changeset	382 public Socket accept() throws IOException {
128cce60c43c where to connect command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 133 diff changeset	383 return servSock.accept();
128cce60c43c where to connect command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 133 diff changeset	384 }
31 872d9bcbfe56 Before changing the Viewer. one parents: 29 diff changeset	385
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	386 public int selectPort(int p) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	387 int port = p;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	388 while (true) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	389 try {
134 128cce60c43c where to connect command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 133 diff changeset	390 servSock = new ServerSocket(port);
128cce60c43c where to connect command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 133 diff changeset	391 acceptPort = port;
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	392 break;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	393 } catch (BindException e) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	394 port++;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	395 continue;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	396 } catch (IOException e) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	397
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	398 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	399 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	400 System.out.println("accept port = " + port);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	401 return port;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	402 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	403
33 9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	404
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	405
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	406 public void writeFramebufferUpdateRequest(int x, int y, int w, int h,
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	407 boolean incremental) throws TransportException {
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	408 byte[] b = new byte[10];
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	409
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	410 b[0] = (byte) FramebufferUpdateRequest; // 3 is FrameBufferUpdateRequest
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	411 b[1] = (byte) (incremental ? 1 : 0);
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	412 b[2] = (byte) ((x >> 8) & 0xff);
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	413 b[3] = (byte) (x & 0xff);
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	414 b[4] = (byte) ((y >> 8) & 0xff);
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	415 b[5] = (byte) (y & 0xff);
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	416 b[6] = (byte) ((w >> 8) & 0xff);
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	417 b[7] = (byte) (w & 0xff);
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	418 b[8] = (byte) ((h >> 8) & 0xff);
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	419 b[9] = (byte) (h & 0xff);
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	420
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	421 // os.write(b);
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	422 }
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	423
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	424 public void notProxy() {
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	425 proxyFlag = false;
9d3478d11d3b Add the processing of client Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 32 diff changeset	426 }
35 1b81deb0abb3 write a little part reconnection. one parents: 33 diff changeset	427
125 32c6563492f3 add vnc protocol command sender. oc parents: 124 diff changeset	428 public void setEcho(TreeVncProtocol _echo) {
133 70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	429 treeProtocol = _echo;
143 4547543ca73c findRootReply oc parents: 138 diff changeset	430 treeVncCommand.setVncProtocol(_echo);
35 1b81deb0abb3 write a little part reconnection. one parents: 33 diff changeset	431 }
1b81deb0abb3 write a little part reconnection. one parents: 33 diff changeset	432
65 ffd7537cebfc cuiversion Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 64 diff changeset	433 public void setViewer(ViewerImpl v) {
133 70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	434 treeProtocol.setViewer(v);
36 b7d4d0349f99 write part of reconnection and remove warning. one parents: 35 diff changeset	435 }
b7d4d0349f99 write part of reconnection and remove warning. one parents: 35 diff changeset	436
65 ffd7537cebfc cuiversion Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 64 diff changeset	437 public ViewerImpl getViewer() {
133 70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	438 return treeProtocol.getViewer();
65 ffd7537cebfc cuiversion Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 64 diff changeset	439 }
ffd7537cebfc cuiversion Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 64 diff changeset	440
125 32c6563492f3 add vnc protocol command sender. oc parents: 124 diff changeset	441 public TreeVncProtocol getEcho() {
133 70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	442 return treeProtocol;
35 1b81deb0abb3 write a little part reconnection. one parents: 33 diff changeset	443 }
43 6687aa9dd55e add flag for screen change in ReciverTask.java. one parents: 38 diff changeset	444
6687aa9dd55e add flag for screen change in ReciverTask.java. one parents: 38 diff changeset	445 public void setTerminationType(boolean setType) {
6687aa9dd55e add flag for screen change in ReciverTask.java. one parents: 38 diff changeset	446 /nop/
6687aa9dd55e add flag for screen change in ReciverTask.java. one parents: 38 diff changeset	447 }
6687aa9dd55e add flag for screen change in ReciverTask.java. one parents: 38 diff changeset	448
6687aa9dd55e add flag for screen change in ReciverTask.java. one parents: 38 diff changeset	449 public boolean getTerminationType() {
6687aa9dd55e add flag for screen change in ReciverTask.java. one parents: 38 diff changeset	450 /nop/
6687aa9dd55e add flag for screen change in ReciverTask.java. one parents: 38 diff changeset	451 return true;
6687aa9dd55e add flag for screen change in ReciverTask.java. one parents: 38 diff changeset	452 }
45 20326a4b9d88 create new change button for client. one parents: 43 diff changeset	453
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	454 void sendProxyFlag(OutputStream os) throws IOException {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	455 if (proxyFlag)
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	456 os.write(1);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	457 else
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	458 os.write(0);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	459 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	460
134 128cce60c43c where to connect command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 133 diff changeset	461 public void close() {
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	462 // none
52 986f16afb753 update before change host. one parents: 45 diff changeset	463 }
45 20326a4b9d88 create new change button for client. one parents: 43 diff changeset	464
60 ac6f9e46566f proxy mode ok. Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 59 diff changeset	465 public int getAcceptPort() {
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	466 return acceptPort;
60 ac6f9e46566f proxy mode ok. Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 59 diff changeset	467 }
ac6f9e46566f proxy mode ok. Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 59 diff changeset	468
61 d9cf08c6415c During implementation change screen. Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 60 diff changeset	469 public boolean getReadyReconnect() {
d9cf08c6415c During implementation change screen. Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 60 diff changeset	470 return readyReconnect;
d9cf08c6415c During implementation change screen. Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 60 diff changeset	471 }
65 ffd7537cebfc cuiversion Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 64 diff changeset	472
ffd7537cebfc cuiversion Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 64 diff changeset	473
ffd7537cebfc cuiversion Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 64 diff changeset	474 public boolean getCuiVersion() {
ffd7537cebfc cuiversion Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 64 diff changeset	475 return cuiVersion;
61 d9cf08c6415c During implementation change screen. Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 60 diff changeset	476 }
65 ffd7537cebfc cuiversion Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 64 diff changeset	477
ffd7537cebfc cuiversion Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 64 diff changeset	478 public void setCuiVersion(boolean flag) {
ffd7537cebfc cuiversion Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 64 diff changeset	479 cuiVersion = flag;
ffd7537cebfc cuiversion Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 64 diff changeset	480 }
66 84ad879891e9 dont move Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 65 diff changeset	481
84ad879891e9 dont move Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 65 diff changeset	482 public void readCheckDelay(Reader reader) throws TransportException {
84ad879891e9 dont move Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 65 diff changeset	483
84ad879891e9 dont move Taninari YU <you@cr.ie.u-ryukyu.ac.jp> parents: 65 diff changeset	484 }
134 128cce60c43c where to connect command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 133 diff changeset	485
94 75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	486 public synchronized void setReadyReconnect(boolean ready) {
75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	487 readyReconnect = ready;
75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	488 if (ready) {
75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	489 notifyAll();
75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	490 }
75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	491 }
75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	492
75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	493 public synchronized void waitForReady(VncProxyService vncProxyService) throws InterruptedException {
75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	494 while (!readyReconnect) {
75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	495 wait();
75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	496 }
75879c316796 synchronized wait for Rfb initialization in change server. oc parents: 89 diff changeset	497 }
96 76e49dd9c9c5 Client resize without reconnection oc parents: 94 diff changeset	498
76e49dd9c9c5 Client resize without reconnection oc parents: 94 diff changeset	499
76e49dd9c9c5 Client resize without reconnection oc parents: 94 diff changeset	500 public void sendDesktopSizeChange() {
76e49dd9c9c5 Client resize without reconnection oc parents: 94 diff changeset	501 LinkedList<ByteBuffer> desktopSize = new LinkedList<ByteBuffer>();
97 44f5cdc63a76 don't create Rfb and VNC proxy on change server on root. oc parents: 96 diff changeset	502 int width = context.getFbWidth();
44f5cdc63a76 don't create Rfb and VNC proxy on change server on root. oc parents: 96 diff changeset	503 int height = context.getFbHeight();
44f5cdc63a76 don't create Rfb and VNC proxy on change server on root. oc parents: 96 diff changeset	504 desktopSize.add(new UpdateRectangleMessage(0,0, width, height, EncodingType.DESKTOP_SIZE).getMessage());
99 da5f74092be8 minor fix. oc parents: 98 diff changeset	505 addSerialNumber(desktopSize);
96 76e49dd9c9c5 Client resize without reconnection oc parents: 94 diff changeset	506 multicastqueue.put(desktopSize);
76e49dd9c9c5 Client resize without reconnection oc parents: 94 diff changeset	507 }
98 8f4c45c1b396 add serial number to desktop size encoding packet. oc parents: 97 diff changeset	508
8f4c45c1b396 add serial number to desktop size encoding packet. oc parents: 97 diff changeset	509
8f4c45c1b396 add serial number to desktop size encoding packet. oc parents: 97 diff changeset	510 public void addSerialNumber(LinkedList<ByteBuffer> bufs) {
8f4c45c1b396 add serial number to desktop size encoding packet. oc parents: 97 diff changeset	511 ByteBuffer serialNum = multicastqueue.allocate(8);
8f4c45c1b396 add serial number to desktop size encoding packet. oc parents: 97 diff changeset	512 serialNum.putLong(counter++);
8f4c45c1b396 add serial number to desktop size encoding packet. oc parents: 97 diff changeset	513 serialNum.flip();
8f4c45c1b396 add serial number to desktop size encoding packet. oc parents: 97 diff changeset	514 bufs.addFirst(serialNum);
8f4c45c1b396 add serial number to desktop size encoding packet. oc parents: 97 diff changeset	515 }
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	516
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	517
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	518 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	519 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	520 }
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	521
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	522 public void stopReceiverTask() {
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	523 if (context!=null)
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	524 context.cleanUpSession(null);
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	525 // cleanup zlib decoder for new VNCServer
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	526 if (isRoot())
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	527 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	528 }
113 bce2ef0a2e79 use ProtocolContext.sendMessage for upward command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 112 diff changeset	529
bce2ef0a2e79 use ProtocolContext.sendMessage for upward command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 112 diff changeset	530 public String getMyAddress() {
133 70cbec526039 connection handling Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 131 diff changeset	531 return treeProtocol.getMyAddress();
113 bce2ef0a2e79 use ProtocolContext.sendMessage for upward command Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 112 diff changeset	532 }
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	533
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	534 /**
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	535 * gzip byte arrays
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	536 *
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	537 * @param deflater
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	538 * @param inputs
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	539 * byte data[]
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	540 * @param inputIndex
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	541 * @param outputs
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	542 * byte data[]
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	543 * @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	544 * @throws IOException
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	545 */
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	546 public int zip(Deflater deflater, LinkedList<ByteBuffer> inputs,
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	547 int inputIndex, LinkedList<ByteBuffer> outputs) throws IOException {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	548 int len = 0;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	549 ByteBuffer c1 = multicastqueue.allocate(INFLATE_BUFSIZE);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	550 while (inputIndex < inputs.size()) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	551 ByteBuffer b1 = inputs.get(inputIndex++);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	552 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	553 /**
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	554 * 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	555 * 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	556 * 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	557 * 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	558 * of bug of Java library.
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 (inputIndex == inputs.size())
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	561 deflater.finish();
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	562 int len1 = 0;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	563 do {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	564 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	565 c1.remaining());
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	566 if (len1 > 0) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	567 len += len1;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	568 c1.position(c1.position() + len1);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	569 if (c1.remaining() == 0) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	570 c1.flip();
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	571 outputs.addLast(c1);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	572 c1 = multicastqueue.allocate(INFLATE_BUFSIZE);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	573 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	574 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	575 } 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	576 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	577 if (c1.position() != 0) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	578 c1.flip();
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	579 outputs.addLast(c1);
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 deflater.reset();
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	582 return len;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	583 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	584
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	585 /**
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	586 * gunzip byte arrays
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	587 *
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	588 * @param inflater
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	589 * @param inputs
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	590 * byte data[]
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	591 * @param outputs
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	592 * byte data[]
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	593 * @return number of total bytes
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	594 * @throws IOException
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	595 */
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	596 public int unzip(Inflater inflater, LinkedList<ByteBuffer> inputs,
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	597 int inputIndex, LinkedList<ByteBuffer> outputs, int bufSize)
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	598 throws DataFormatException {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	599 int len = 0;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	600 ByteBuffer buf = multicastqueue.allocate(bufSize);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	601 while (inputIndex < inputs.size()) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	602 ByteBuffer input = inputs.get(inputIndex++);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	603 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	604 // 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	605 // we need this
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	606 // 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	607 do {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	608 int len0 = inflater.inflate(buf.array(), buf.position(),
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	609 buf.remaining());
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	610 if (len0 > 0) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	611 buf.position(buf.position() + len0);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	612 len += len0;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	613 if (buf.remaining() == 0) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	614 buf.flip();
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	615 outputs.addLast(buf);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	616 buf = multicastqueue.allocate(bufSize);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	617 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	618 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	619 } while (!inflater.needsInput());
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 if (buf.position() != 0) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	622 buf.flip();
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	623 outputs.addLast(buf);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	624 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	625 return len;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	626 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	627
135 ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	628 /**
ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	629 * 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	630 * put the packet to the multicastqueue. Then normal rendering engine read the same stream using is.reset().
ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	631 * @param dataLen
ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	632 * @param reader
ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	633 * @throws TransportException
ada4d850a820 lostParent and notFoundParenet Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 134 diff changeset	634 */
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	635 public void readSendData(int dataLen, Reader reader)
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	636 throws TransportException {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	637 LinkedList<ByteBuffer> bufs = new LinkedList<ByteBuffer>();
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	638 ByteBuffer header = multicastqueue.allocate(16);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	639 ByteBuffer serial = multicastqueue.allocate(8);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	640 if (!isRoot()) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	641 reader.mark(dataLen+8); // +8 is serialnum
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	642 reader.readBytes(serial.array(),0,8);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	643 serial.limit(8);
120 c1b14cef2704 MyRfb fix done. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 118 diff changeset	644 }
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	645 reader.readBytes(header.array(), 0, 16);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	646 header.limit(16);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	647 if (header.get(0) == FramebufferUpdate) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	648 int encoding = header.getInt(12);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	649 if (encoding == EncodingType.ZRLE.getId()
120 c1b14cef2704 MyRfb fix done. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 118 diff changeset	650 \|\| encoding == EncodingType.ZLIB.getId()) { // ZRLEE is already compressed
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	651 ByteBuffer len = multicastqueue.allocate(4);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	652 reader.readBytes(len.array(), 0, 4);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	653 len.limit(4);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	654 ByteBuffer inputData = multicastqueue.allocate(dataLen - 20);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	655 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	656 inputData.limit(dataLen - 20);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	657 LinkedList<ByteBuffer> inputs = new LinkedList<ByteBuffer>();
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	658 inputs.add(inputData);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	659
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	660 header.putInt(12, EncodingType.ZRLEE.getId()); // means
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	661 // recompress
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	662 // every time
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	663 // 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	664 // protocol, clients have to be modified.
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	665 Deflater nDeflater = deflater; // new Deflater();
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	666 LinkedList<ByteBuffer> out = new LinkedList<ByteBuffer>();
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	667 try {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	668 unzip(inflater, inputs, 0, out, INFLATE_BUFSIZE);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	669 // dump32(inputs);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	670 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	671 ByteBuffer blen = multicastqueue.allocate(4);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	672 blen.putInt(len2);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	673 blen.flip();
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	674 bufs.addFirst(blen);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	675 bufs.addFirst(header);
120 c1b14cef2704 MyRfb fix done. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 118 diff changeset	676 this.addSerialNumber(bufs);
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	677 multicastqueue.put(bufs);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	678 if (!isRoot()) reader.reset();
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	679 } catch (DataFormatException e) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	680 throw new TransportException(e);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	681 } catch (IOException e) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	682 throw new TransportException(e);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	683 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	684 return;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	685 }
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	686 bufs.add(header);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	687 if (dataLen > 16) {
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	688 ByteBuffer b = multicastqueue.allocate(dataLen - 16);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	689 reader.readBytes(b.array(), 0, dataLen - 16);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	690 b.limit(dataLen - 16);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	691 bufs.add(b);
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	692 }
120 c1b14cef2704 MyRfb fix done. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 118 diff changeset	693 this.addSerialNumber(bufs);
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	694 multicastqueue.put(bufs);
120 c1b14cef2704 MyRfb fix done. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 118 diff changeset	695 if (!isRoot()) reader.reset();
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	696 return;
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	697 }
120 c1b14cef2704 MyRfb fix done. Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 118 diff changeset	698 if (isRoot()) reader.reset();
118 38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	699 // 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	700 // decompressing here,
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	701 // 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	702 // each client.
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	703 // 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	704 // here.
38e461e9b9c9 remove duplicated code in MyRfbProto* Shinji KONO <kono@ie.u-ryukyu.ac.jp> parents: 113 diff changeset	705 }
124 214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	706
143 4547543ca73c findRootReply oc parents: 138 diff changeset	707 public void addHostToSelectionPanel(int port, String hostname) {
4547543ca73c findRootReply oc parents: 138 diff changeset	708
4547543ca73c findRootReply oc parents: 138 diff changeset	709 }
4547543ca73c findRootReply oc parents: 138 diff changeset	710
144 1e004d9c599d notify connection panel oc parents: 143 diff changeset	711 public void createRootSelectionPanel(CreateConnectionParam createConnectionParam) {
143 4547543ca73c findRootReply oc parents: 138 diff changeset	712
4547543ca73c findRootReply oc parents: 138 diff changeset	713 }
4547543ca73c findRootReply oc parents: 138 diff changeset	714
124 214d4f206431 add TreeVNC command number. oc parents: 123 diff changeset	715
28 18fad65bc447 Create MyRfbProto.java one parents: diff changeset	716 }

Mercurial > hg > Members > riono > TreeVNC_ja_comment

annotate src/main/java/jp/ac/u_ryukyu/treevnc/MyRfbProto.java @ 144:1e004d9c599d