Mercurial > hg > Members > riono > TreeVNC_ja_comment

comparison src/main/java/jp/ac/u_ryukyu/treevnc/TreeRFBProto.java @ 420:0ad52aac3bc3

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Send repeat FramebufferUpdateRequest from Timer class
author Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp>
date Mon, 18 Jan 2016 17:37:58 +0900
parents 7e811f33b99d
children ffe01c959cdd
comparison
equal deleted inserted replaced
419:7e811f33b99d 420:0ad52aac3bc3
354 } catch (Exception e) { 354 } catch (Exception e) {
355 try { 355 try {
356 writerRunning.set(2); 356 writerRunning.set(2);
357 os.close(); 357 os.close();
358 } catch (IOException e1) { 358 } catch (IOException e1) {
359 System.out.println("root writer close faild :" + e1); 359 System.out.println("root writer close failed :" + e1);
360 } 360 }
361 System.out.println("root writer faild :" + e); 361 System.out.println("root writer failed :" + e);
362 /* if socket closed cliList.remove(newCli); */ 362 /* if socket closed cliList.remove(newCli); */
363 } 363 }
364 } 364 }
365 public void writeToClient(final Writer os, 365 public void writeToClient(final Writer os,
366 LinkedList<ByteBuffer> bufs, int inputIndex) 366 LinkedList<ByteBuffer> bufs, int inputIndex)
684 * @throws UnsupportedEncodingException 684 * @throws UnsupportedEncodingException
685 */ 685 */
686 public void readSendData(int dataLen, Reader reader, byte[] bytes, FramebufferUpdateRectangle rect) 686 public void readSendData(int dataLen, Reader reader, byte[] bytes, FramebufferUpdateRectangle rect)
687 throws TransportException, UnsupportedEncodingException { 687 throws TransportException, UnsupportedEncodingException {
688 LinkedList<ByteBuffer> bufs = new LinkedList<ByteBuffer>(); 688 LinkedList<ByteBuffer> bufs = new LinkedList<ByteBuffer>();
689 int BLOCKSIZE = 64 * 1024;
689 int headerLen = rect.getEncodingType() == EncodingType.CHECK_DELAY ? 24 : 16; 690 int headerLen = rect.getEncodingType() == EncodingType.CHECK_DELAY ? 24 : 16;
690 ByteBuffer header = multicastqueue.allocate(headerLen); 691 ByteBuffer header = multicastqueue.allocate(headerLen);
691 ByteBuffer serial = multicastqueue.allocate(4+8); 692 ByteBuffer serial = multicastqueue.allocate(4+8);
692 if (!isTreeManager() && addSerialNum) { 693 if (!isTreeManager() && addSerialNum) {
693 reader.readBytes(serial.array(),0,4+8); 694 reader.readBytes(serial.array(),0,4+8);