comparison src/main/java/com/glavsoft/rfb/protocol/Protocol.java @ 482:73b52954efc9

handling vncconnection failure rfb/protocol/Protocol.java HG: changed src/main/java/com/glavsoft/ rfb/protocol/ReceiverTask.java HG: changed src/viewer_swing/ java/com/glavsoft/viewer/swing/SwingRfbConnectionWorker.java
author oshiro
date Thu, 24 Jan 2019 17:19:05 +0900 (2019-01-24)
parents 432e2967eaab
children b2f734f3eaf1
comparison
equal deleted inserted replaced
481:6e30cb5d905f 482:73b52954efc9
210 senderThread.start(); 210 senderThread.start();
211 decoders.resetDecoders(); 211 decoders.resetDecoders();
212 212
213 receiverThread = new Thread(receiverTask, "RfbReceiverTask"); 213 receiverThread = new Thread(receiverTask, "RfbReceiverTask");
214 receiverThread.start(); 214 receiverThread.start();
215 sendRefreshMessage();
215 } 216 }
216 217
217 private void correctServerPixelFormat() { 218 private void correctServerPixelFormat() {
218 // correct true color flag - we don't support color maps, so always set it up 219 // correct true color flag - we don't support color maps, so always set it up
219 serverPixelFormat.trueColourFlag = 1; 220 serverPixelFormat.trueColourFlag = 1;
278 279
279 @Override 280 @Override
280 public void sendRefreshMessage() { 281 public void sendRefreshMessage() {
281 if (receiverTask!=null) { 282 if (receiverTask!=null) {
282 sendMessage(receiverTask.fullscreenFbUpdateIncrementalRequest); 283 sendMessage(receiverTask.fullscreenFbUpdateIncrementalRequest);
283 logger.fine("sent: full FB Refresh"); 284 logger.fine("sent: incremental FB Refresh");
284 } 285 }
285 } 286 }
286 287
287 @Override 288 @Override
288 public void cleanUpSession(String message) { 289 public void cleanUpSession(String message) {
292 } 293 }
293 294
294 public synchronized void cleanUpSession() { 295 public synchronized void cleanUpSession() {
295 if (senderTask != null) { 296 if (senderTask != null) {
296 // stop senderTask to VNCServer task. 297 // stop senderTask to VNCServer task.
297 senderTask.stopTask(); 298 senderTask.stopTask();
298 try { 299 //try {
299 senderThread.join(); 300 // senderThread.join();
300 } catch (InterruptedException e) { 301 //} catch (InterruptedException e) {
301 System.out.println("any thread has interrupted the current thread"); 302 // System.out.println("any thread has interrupted the current thread");
302 } 303 //}
303 senderTask = null; 304 senderTask = null;
304 } 305 }
305 stopReceiverTask(); 306 stopReceiverTask();
306 } 307 }
307 308