Mercurial > hg > Applications > TreeVNC

annotate src/main/java/com/glavsoft/rfb/protocol/ReceiverTask.java @ 393:319447659dc6

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Change reader process for server change in direct mode
author innparusu
date Wed, 23 Sep 2015 20:50:29 +0900
parents 6a8b661367c6
children a8610fab6861
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
57
17b702648079 version2.7.2 original version.
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents: 0
diff changeset
1 // Copyright (C) 2010, 2011, 2012, 2013 GlavSoft LLC.
0
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
2 // All rights reserved.
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
3 //
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
4 //-------------------------------------------------------------------------
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
5 // This file is part of the TightVNC software. Please visit our Web site:
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
6 //
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
7 // http://www.tightvnc.com/
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
8 //
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
9 // This program is free software; you can redistribute it and/or modify
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
10 // it under the terms of the GNU General Public License as published by
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
11 // the Free Software Foundation; either version 2 of the License, or
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
12 // (at your option) any later version.
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
13 //
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
14 // This program is distributed in the hope that it will be useful,
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
15 // but WITHOUT ANY WARRANTY; without even the implied warranty of
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
16 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
17 // GNU General Public License for more details.
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
18 //
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
19 // You should have received a copy of the GNU General Public License along
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
20 // with this program; if not, write to the Free Software Foundation, Inc.,
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
21 // 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
22 //-------------------------------------------------------------------------
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
23 //
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
24
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
25 package com.glavsoft.rfb.protocol;
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
26
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
27 import com.glavsoft.drawing.Renderer;
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
28 import com.glavsoft.exceptions.CommonException;
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
29 import com.glavsoft.exceptions.ProtocolException;
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
30 import com.glavsoft.exceptions.TransportException;
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
31 import com.glavsoft.rfb.ClipboardController;
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
32 import com.glavsoft.rfb.IRepaintController;
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
33 import com.glavsoft.rfb.client.FramebufferUpdateRequestMessage;
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
34 import com.glavsoft.rfb.client.SetPixelFormatMessage;
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
35 import com.glavsoft.rfb.encoding.EncodingType;
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
36 import com.glavsoft.rfb.encoding.PixelFormat;
278
69e821effec6 add comment
oc
parents: 276
diff changeset
37 import com.glavsoft.rfb.encoding.decoder.*;
0
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
38 import com.glavsoft.transport.Reader;
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
39
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
40 import java.io.PrintWriter;
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
41 import java.io.StringWriter;
167
1d3fa20b86bb update remoteDesktopName.
oc
parents: 166
diff changeset
42 import java.io.UnsupportedEncodingException;
360
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
43 import java.util.LinkedList;
255
a931be447973 add framebufferUpdateRecuest timer
oc
parents: 254
diff changeset
44 import java.util.Timer;
a931be447973 add framebufferUpdateRecuest timer
oc
parents: 254
diff changeset
45 import java.util.TimerTask;
0
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
46 import java.util.logging.Logger;
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
47
332
6a6653b67bd7 fix bug lostChild and change message panel failed connect death node
oc
parents: 331
diff changeset
48 import com.glavsoft.viewer.ViewerInterface;
279
dce00f9ac98c add encodingType SEND_SINGLE_DISPLAY_WIDTH.
oc
parents: 278
diff changeset
49 import jp.ac.u_ryukyu.treevnc.*;
231
0e0e6744432c get new nodeList for checkDelay.
oc
parents: 230
diff changeset
50
35
1b81deb0abb3 write a little part reconnection.
one
parents: 28
diff changeset
51
0
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
52 public class ReceiverTask implements Runnable {
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
53 private static final byte FRAMEBUFFER_UPDATE = 0;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
54 private static final byte SET_COLOR_MAP_ENTRIES = 1;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
55 private static final byte BELL = 2;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
56 private static final byte SERVER_CUT_TEXT = 3;
0
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
57
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
58
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
59 private static Logger logger = Logger.getLogger("com.glavsoft.rfb.protocol.ReceiverTask");
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
60 private Reader reader;
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
61 private volatile boolean isRunning = false;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
62 private Renderer renderer;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
63 private final IRepaintController repaintController;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
64 private final ClipboardController clipboardController;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
65 protected final DecodersContainer decoders;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
66 protected FramebufferUpdateRequestMessage fullscreenFbUpdateIncrementalRequest;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
67 protected final ProtocolContext context;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
68 protected PixelFormat pixelFormat;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
69 protected boolean needSendPixelFormat;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
70 private TreeRFBProto rfb;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
71 private long checkCounter = 0;
248
e6abf4b0c92e add numberOfRectangle in checkDelay
Miwa Oshiro <e115747@ie.u-ryukyu.ac.jp>
parents: 246
diff changeset
72 public int numberOfRectangles = 0;
255
a931be447973 add framebufferUpdateRecuest timer
oc
parents: 254
diff changeset
73 private Timer timer = null;
a931be447973 add framebufferUpdateRecuest timer
oc
parents: 254
diff changeset
74
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
75 public ReceiverTask(Reader reader,
275
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
76 IRepaintController repaintController, ClipboardController clipboardController,
314
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
77 DecodersContainer decoders, final ProtocolContext context,
275
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
78 TreeRFBProto _rfb) {
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
79 rfb = _rfb;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
80 this.reader = reader;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
81 this.repaintController = repaintController;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
82 this.clipboardController = clipboardController;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
83 this.context = context;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
84 this.decoders = decoders;
178
34b7558aeffa remove TreeTask, StartTreeHandling
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 176
diff changeset
85
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
86 Decoder decoder = new ZRLEESender(rfb);
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
87 decoders.setDecoderByType(EncodingType.ZLIB, decoder);
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
88 decoders.setDecoderByType(EncodingType.ZRLE, decoder);
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
89 decoders.setDecoderByType(EncodingType.ZRLEE, decoder);
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
90
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
91 if(!rfb.getCuiVersion())
307
7e8b070dc15b create renderer filterSingleDisplay
oc
parents: 306
diff changeset
92 if (rfb.filterSingleDisplay) {
353
eba44a31e868 remove filterSingleDisplay option in retina version
oc
parents: 351
diff changeset
93 renderer = repaintController.createRenderer(reader, context.getFbWidth(), context.getFbHeight(), context.getPixelFormat());
361
df063169b0b1 FramebufferUpdateRequestMessage to false
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 360
diff changeset
94 fullscreenFbUpdateIncrementalRequest = new FramebufferUpdateRequestMessage(0, 0, rfb.getSingleWidth(), rfb.getSingleHeight(), false);
307
7e8b070dc15b create renderer filterSingleDisplay
oc
parents: 306
diff changeset
95 } else {
7e8b070dc15b create renderer filterSingleDisplay
oc
parents: 306
diff changeset
96 renderer = repaintController.createRenderer(reader, context.getFbWidth(), context.getFbHeight(), context.getPixelFormat());
361
df063169b0b1 FramebufferUpdateRequestMessage to false
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 360
diff changeset
97 fullscreenFbUpdateIncrementalRequest = new FramebufferUpdateRequestMessage(0, 0, context.getFbWidth(), context.getFbHeight(), false);
307
7e8b070dc15b create renderer filterSingleDisplay
oc
parents: 306
diff changeset
98 }
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
99 if(rfb.isTreeManager()) {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
100 fullscreenFbUpdateIncrementalRequest.sendFullScreenRequest();
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
101 connectionFinished();
314
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
102 if(rfb.checkDelay) {
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
103 SendCheckDelay sendCheckDelay = new SendCheckDelay(rfb);
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
104 Thread sendCheckDelayThread = new Thread(sendCheckDelay, "send-check-delay");
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
105 sendCheckDelayThread.start();
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
106 }
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
107 if(rfb.fixingSize) {
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
108 timer = new Timer("framebufferUpdate-request-timer", true);
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
109 timer.schedule(new TimerTask() {
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
110 @Override
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
111 public void run() {
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
112 context.setFbWidth(rfb.fixingSizeWidth);
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
113 context.setFbHeight(rfb.fixingSizeHeight);
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
114 context.sendMessage(new FramebufferUpdateRequestMessage(0, 0, context.getFbWidth(), context.getFbHeight(), true));
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
115 }
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
116 }, 0, 100);
e95cb9a3dd9b change code, delete firstTime.
oc
parents: 307
diff changeset
117 }
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
118 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
119 }
178
34b7558aeffa remove TreeTask, StartTreeHandling
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 176
diff changeset
120
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
121 @Override
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
122 public void run() {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
123 isRunning = true;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
124 while (isRunning) {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
125 try {
393
319447659dc6 Change reader process for server change in direct mode
innparusu
parents: 391
diff changeset
126 reader.available();
319447659dc6 Change reader process for server change in direct mode
innparusu
parents: 391
diff changeset
127 if (! isRunning) {
319447659dc6 Change reader process for server change in direct mode
innparusu
parents: 391
diff changeset
128 // server Change in direct mode
319447659dc6 Change reader process for server change in direct mode
innparusu
parents: 391
diff changeset
129 // pass the input stream to the TreeVNC protocol reader
319447659dc6 Change reader process for server change in direct mode
innparusu
parents: 391
diff changeset
130 return;
319447659dc6 Change reader process for server change in direct mode
innparusu
parents: 391
diff changeset
131 }
378
60abae693629 Compare SerialNumber flag
innparusu
parents: 362
diff changeset
132 if(! rfb.isTreeManager() && rfb.isAddSerialNum()) {
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
133 // client has 8byte packet sequence number
242
a640cd7001e1 fix checkdelay, and fix serial number option
oc
parents: 241
diff changeset
134 // add serial number flag (4byte)
a640cd7001e1 fix checkdelay, and fix serial number option
oc
parents: 241
diff changeset
135 reader.mark(20+8+4);
a640cd7001e1 fix checkdelay, and fix serial number option
oc
parents: 241
diff changeset
136 getLost(reader); //check seq consistency
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
137 } else {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
138 reader.mark(20);
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
139 }
393
319447659dc6 Change reader process for server change in direct mode
innparusu
parents: 391
diff changeset
140
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
141 byte messageId = reader.readByte();
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
142 switch (messageId) {
275
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
143 case FRAMEBUFFER_UPDATE:
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
144 // logger.fine("Server message: FramebufferUpdate (0)");
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
145 framebufferUpdateMessage();
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
146 break;
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
147 case SET_COLOR_MAP_ENTRIES:
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
148 logger.severe("Server message SetColorMapEntries is not implemented. Skip.");
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
149 setColorMapEntries();
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
150 break;
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
151 case BELL:
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
152 logger.fine("Server message: Bell");
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
153 // System.out.print("\0007");
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
154 // System.out.flush();
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
155 break;
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
156 case SERVER_CUT_TEXT:
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
157 logger.fine("Server message: CutText (3)");
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
158 serverCutText();
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
159 break;
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
160 default:
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
161 logger.severe("Unsupported server message. Id = " + messageId);
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
162 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
163 } catch (TransportException e) {
347
1f86df6504b7 don't use clearChildrenTransmission()
Miwa Oshiro <oshiro1122@gmail.com>
parents: 345
diff changeset
164 logger.severe("Close session : ReceiverTask : " + e.getMessage());
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
165 if(!rfb.isTreeManager() && !(rfb.getTerminationType())) {
332
6a6653b67bd7 fix bug lostChild and change message panel failed connect death node
oc
parents: 331
diff changeset
166 System.out.println("death parent node, wait connect new parent node.");
6a6653b67bd7 fix bug lostChild and change message panel failed connect death node
oc
parents: 331
diff changeset
167 // close viewer
6a6653b67bd7 fix bug lostChild and change message panel failed connect death node
oc
parents: 331
diff changeset
168 ViewerInterface viewer = rfb.getViewer();
6a6653b67bd7 fix bug lostChild and change message panel failed connect death node
oc
parents: 331
diff changeset
169 viewer.setVisible(false);
6a6653b67bd7 fix bug lostChild and change message panel failed connect death node
oc
parents: 331
diff changeset
170 try {
6a6653b67bd7 fix bug lostChild and change message panel failed connect death node
oc
parents: 331
diff changeset
171 // clean DataInputStream
6a6653b67bd7 fix bug lostChild and change message panel failed connect death node
oc
parents: 331
diff changeset
172 reader.close();
6a6653b67bd7 fix bug lostChild and change message panel failed connect death node
oc
parents: 331
diff changeset
173 } catch (TransportException e1) {
6a6653b67bd7 fix bug lostChild and change message panel failed connect death node
oc
parents: 331
diff changeset
174 e1.printStackTrace();
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
175 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
176 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
177 stopTask();
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
178 } catch (ProtocolException e) {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
179 logger.severe(e.getMessage());
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
180 if (isRunning) {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
181 context.cleanUpSession(e.getMessage() + "\nConnection closed.");
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
182 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
183 stopTask();
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
184 } catch (CommonException e) {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
185 logger.severe(e.getMessage());
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
186 if (isRunning) {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
187 context.cleanUpSession("Connection closed..");
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
188 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
189 stopTask();
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
190 } catch (Throwable te) {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
191 StringWriter sw = new StringWriter();
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
192 PrintWriter pw = new PrintWriter(sw);
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
193 te.printStackTrace(pw);
353
eba44a31e868 remove filterSingleDisplay option in retina version
oc
parents: 351
diff changeset
194 logger.severe("updateRectangle record failed : " + te.getMessage());
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
195 if (isRunning) {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
196 context.cleanUpSession(te.getMessage() + "\n" + sw.toString());
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
197 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
198 stopTask();
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
199 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
200 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
201 }
0
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
202
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
203 private void sleep(int i) {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
204 try {
145
649794dfb9d5 add my hostname to handle multiple network
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 135
diff changeset
205 Thread.sleep(i);
649794dfb9d5 add my hostname to handle multiple network
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 135
diff changeset
206 } catch (InterruptedException e) {
649794dfb9d5 add my hostname to handle multiple network
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 135
diff changeset
207 // nothing.
332
6a6653b67bd7 fix bug lostChild and change message panel failed connect death node
oc
parents: 331
diff changeset
208
145
649794dfb9d5 add my hostname to handle multiple network
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 135
diff changeset
209 }
649794dfb9d5 add my hostname to handle multiple network
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 135
diff changeset
210 }
649794dfb9d5 add my hostname to handle multiple network
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 135
diff changeset
211
649794dfb9d5 add my hostname to handle multiple network
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 135
diff changeset
212
649794dfb9d5 add my hostname to handle multiple network
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 135
diff changeset
213 private void setColorMapEntries() throws TransportException {
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
214 reader.readByte(); // padding
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
215 reader.readUInt16(); // first color index
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
216 int length = reader.readUInt16();
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
217 while (length-- > 0) {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
218 reader.readUInt16(); // R
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
219 reader.readUInt16(); // G
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
220 reader.readUInt16(); // B
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
221 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
222 }
0
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
223
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
224 private void serverCutText() throws TransportException {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
225 reader.readByte(); // padding
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
226 reader.readInt16(); // padding
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
227 int length = reader.readInt32() & Integer.MAX_VALUE;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
228 clipboardController.updateSystemClipboard(reader.readBytes(length));
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
229 }
0
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
230
353
eba44a31e868 remove filterSingleDisplay option in retina version
oc
parents: 351
diff changeset
231 public void framebufferUpdateMessage() throws Exception {
276
0309ea3a4f4e fix option --filterSingleDisplay, -p version.
oc
parents: 275
diff changeset
232
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
233 try {
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
234 reader.readByte(); // padding
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
235 this.numberOfRectangles = reader.readUInt16();
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
236 if(numberOfRectangles != 1)
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
237 System.out.println("numberofrectangle : " + numberOfRectangles);
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
238 while (numberOfRectangles-- > 0) {
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
239 FramebufferUpdateRectangle rect = new FramebufferUpdateRectangle();
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
240 rect.fill(reader);
380
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
241 if(rfb.isTreeManager() && rfb.checkDelay) {
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
242 long time = System.currentTimeMillis();
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
243 System.out.println(time + " : size : " + rect.width * rect.height);
380
aef5cbdd84ab Fix compare SerialNumber flag
innparusu
parents: 378
diff changeset
244 }
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
245 Decoder decoder = decoders.getDecoderByType(rect.getEncodingType());
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
246 logger.finest(rect.toString() + (0 == numberOfRectangles ? "\n---" : ""));
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
247 if (decoder != null) {
353
eba44a31e868 remove filterSingleDisplay option in retina version
oc
parents: 351
diff changeset
248 try {
eba44a31e868 remove filterSingleDisplay option in retina version
oc
parents: 351
diff changeset
249 decoder.decode(reader, renderer, rect); // TreeVNC processing here
eba44a31e868 remove filterSingleDisplay option in retina version
oc
parents: 351
diff changeset
250 if (rfb.getCuiVersion()) continue;
359
62a6c779fd7f remove function about catch next display size
oc
parents: 358
diff changeset
251 if (rfb.filterSingleDisplay && rect.x >= rfb.getSingleWidth()) continue;
353
eba44a31e868 remove filterSingleDisplay option in retina version
oc
parents: 351
diff changeset
252 repaintController.repaintBitmap(rect);
eba44a31e868 remove filterSingleDisplay option in retina version
oc
parents: 351
diff changeset
253 } catch (Exception e) {
eba44a31e868 remove filterSingleDisplay option in retina version
oc
parents: 351
diff changeset
254 throw e;
eba44a31e868 remove filterSingleDisplay option in retina version
oc
parents: 351
diff changeset
255 }
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
256 } else if (rect.getEncodingType() == EncodingType.RICH_CURSOR) {
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
257 RichCursorDecoder.getInstance().decode(reader, renderer, rect);
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
258 if(repaintController!=null)
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
259 repaintController.repaintCursor();
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
260 } else if (rect.getEncodingType() == EncodingType.CURSOR_POS) {
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
261 renderer.decodeCursorPosition(rect);
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
262 repaintController.repaintCursor();
360
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
263 } else if (rect.getEncodingType() == EncodingType.DESKTOP_SIZE || rect.getEncodingType() == EncodingType.INIT_DATA
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
264 || rect.getEncodingType() == EncodingType.EXTENDED_DESKTOP_SIZE) {
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
265 if (rect.getEncodingType() == EncodingType.EXTENDED_DESKTOP_SIZE){
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
266 int numberOfScreen = reader.readByte();
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
267 reader.readBytes(3);
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
268 LinkedList<FramebufferUpdateRectangle> screens = new LinkedList<FramebufferUpdateRectangle>();
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
269 for (int i = 0; i < numberOfScreen; i++){
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
270 long id = reader.readUInt32();
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
271 int x = reader.readUInt16();
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
272 int y = reader.readUInt16();
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
273 int width = reader.readUInt16();
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
274 int height = reader.readUInt16();
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
275 long flag = reader.readUInt32();
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
276
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
277
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
278 FramebufferUpdateRectangle screen = new FramebufferUpdateRectangle(x, y, width, height);
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
279 screen.port = (int) id;
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
280 screen.time = flag;
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
281 screens.add(screen);
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
282 System.out.println("screen " + id + ":" + "x=" + x + " y=" + y + "width=" + width + "height=" + height);
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
283
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
284 }
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
285
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
286 return;
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
287 }
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
288 fullscreenFbUpdateIncrementalRequest = new FramebufferUpdateRequestMessage(0, 0, rect.width, rect.height, false);
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
289 rfb.setCuiVersion(false);
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
290 boolean visible = true;
360
c43593064805 add ExtendetDesktopSize
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 359
diff changeset
291
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
292 if (rect.getEncodingType() == EncodingType.INIT_DATA) {
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 339
diff changeset
293 // VNCServer is changed, initiarize new screen.
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
294 int length = reader.readInt32();
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
295 byte[] initData = new byte[length];
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
296 reader.read(initData);
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
297 String name = new String(initData, 24, length - 24, "UTF-8");
391
6a8b661367c6 Fix serverChange desktop size
innparusu
parents: 380
diff changeset
298 context.setRemoteDesktopName(name);
6a8b661367c6 Fix serverChange desktop size
innparusu
parents: 380
diff changeset
299 context.setInitData(initData);
6a8b661367c6 Fix serverChange desktop size
innparusu
parents: 380
diff changeset
300 context.setFbWidth(rect.width);
6a8b661367c6 Fix serverChange desktop size
innparusu
parents: 380
diff changeset
301 context.setFbHeight(rect.height);
6a8b661367c6 Fix serverChange desktop size
innparusu
parents: 380
diff changeset
302 repaintController.updateRemoteDesktopName(context);
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
303 reader.reset();
345
47e351909227 add stop children sender when change server.
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 339
diff changeset
304 // All children multicastqueue should be discarded hear.
347
1f86df6504b7 don't use clearChildrenTransmission()
Miwa Oshiro <oshiro1122@gmail.com>
parents: 345
diff changeset
305 // rfb.clearChildrenTransmission();
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
306 rfb.readSendData(length + 20, reader, null, rect); // size of UpdateRectangleMessage with initData.
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
307 short id = (short) rect.x;
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
308 visible = (id != rfb.getId());
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
309 }
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
310 synchronized (renderer.getLock()) {
391
6a8b661367c6 Fix serverChange desktop size
innparusu
parents: 380
diff changeset
311 if(!(rfb.getCuiVersion())) {
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
312 renderer = repaintController.createRenderer(reader, rect.width, rect.height, context.getPixelFormat());
391
6a8b661367c6 Fix serverChange desktop size
innparusu
parents: 380
diff changeset
313
6a8b661367c6 Fix serverChange desktop size
innparusu
parents: 380
diff changeset
314 System.out.println("ReceiverTask INIT_DATA width =" +rect.width+ " height =" +rect.height);
6a8b661367c6 Fix serverChange desktop size
innparusu
parents: 380
diff changeset
315 }
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
316 }
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
317 if (rect.getEncodingType() == EncodingType.INIT_DATA) {
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
318 repaintController.setVisible(visible);
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
319 }
362
1eaaa650b4d0 setFitScreen in ReceiverTask
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 361
diff changeset
320 if (rfb.hasViewer()){
1eaaa650b4d0 setFitScreen in ReceiverTask
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 361
diff changeset
321 rfb.getViewer().setFitScreen();
1eaaa650b4d0 setFitScreen in ReceiverTask
one@firefly.cr.ie.u-ryukyu.ac.jp
parents: 361
diff changeset
322 }
391
6a8b661367c6 Fix serverChange desktop size
innparusu
parents: 380
diff changeset
323 if (rfb.isTreeManager()) {
6a8b661367c6 Fix serverChange desktop size
innparusu
parents: 380
diff changeset
324 context.sendMessage(new FramebufferUpdateRequestMessage(0, 0, rect.width, rect.height, false));
6a8b661367c6 Fix serverChange desktop size
innparusu
parents: 380
diff changeset
325 }
6a8b661367c6 Fix serverChange desktop size
innparusu
parents: 380
diff changeset
326
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
327 } else if (rect.getEncodingType() == EncodingType.CHECK_DELAY) {
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
328 int checkDelaySize = 24;
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
329 reader.reset();
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
330 rfb.readSendData(checkDelaySize, reader, null, rect);
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
331 int port = rfb.acceptPort;
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
332 String address = rfb.getMyAddress();
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
333 sendCheckDelayReply(rect.time, port, address);
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
334 } else if (rect.getEncodingType() == EncodingType.SOUND) {
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
335 // SOUNDを受信した時の処理を
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
336 } else
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
337 throw new CommonException("Unprocessed encoding: " + rect.toString());
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
338 }
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
339 } catch (UnsupportedEncodingException e) {
346
89c41f9870ba get singleDisplay size from retina display (HiDPI).
oc
parents: 345
diff changeset
340 e.getMessage();
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
341 e.printStackTrace();
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
342 reader.close();
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
343 }
275
0f9b3de45fb2 set main display size.
oc
parents: 272
diff changeset
344
336
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
345 if (rfb.isTreeManager()) {
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
346 synchronized (this) {
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
347 if (needSendPixelFormat) {
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
348 needSendPixelFormat = false;
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
349 context.setPixelFormat(pixelFormat);
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
350 context.sendMessage(new SetPixelFormatMessage(pixelFormat));
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
351 logger.fine("sent: " + pixelFormat);
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
352 context.sendRefreshMessage();
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
353 logger.fine("sent: nonincremental fb update");
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
354 } else {
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
355 context.sendMessage(new FramebufferUpdateRequestMessage(0, 0, context.getFbWidth(), context.getFbHeight(), false));
2aa4fcbc5ba2 fix framebufferUpdate
oc
parents: 332
diff changeset
356 }
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
357 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
358 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
359 }
0
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
360
234
8479ad028ec7 fix checkdelay send and get.
oc
parents: 233
diff changeset
361 private void sendCheckDelayReply(long time, int port, String address) throws UnsupportedEncodingException {
8479ad028ec7 fix checkdelay send and get.
oc
parents: 233
diff changeset
362 context.sendMessage(new CheckDelayReply(time, port, address));
230
f4ea9ff04741 reply checkdelay
oc
parents: 229
diff changeset
363 }
f4ea9ff04741 reply checkdelay
oc
parents: 229
diff changeset
364
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
365 public synchronized void queueUpdatePixelFormat(PixelFormat pf) {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
366 pixelFormat = pf;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
367 needSendPixelFormat = true;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
368 // context.sendMessage(new FramebufferUpdateRequestMessage(0, 0, 1, 1, false));
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
369 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
370
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
371 public void stopTask() {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
372 isRunning = false;
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
373 }
0
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
374
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
375 private void connectionFinished() {
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
376 rfb.vncConnected(true);
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
377 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
378
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
379 private void getLost(Reader reader) throws Exception {
242
a640cd7001e1 fix checkdelay, and fix serial number option
oc
parents: 241
diff changeset
380 int addSerialNumFlag = reader.readInt32();
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
381 long num = reader.readInt64();
243
0ed7719c1800 fix serial number option.
oc
parents: 242
diff changeset
382 if (addSerialNumFlag == 1) {
0ed7719c1800 fix serial number option.
oc
parents: 242
diff changeset
383 if(num != ++checkCounter) {
0ed7719c1800 fix serial number option.
oc
parents: 242
diff changeset
384 System.out.println("LostData" + (num - checkCounter));
0ed7719c1800 fix serial number option.
oc
parents: 242
diff changeset
385 checkCounter = num;
0ed7719c1800 fix serial number option.
oc
parents: 242
diff changeset
386 }
224
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
387 }
ccbc3a951961 fix indent, update mm.
oc
parents: 215
diff changeset
388 }
0
4689cc86d6cb create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
389 }