changeset 281:16d3584ae7a0

fix SEND_SINGLE_DISPLAY_WIDTH
author oc
date Sun, 11 Jan 2015 03:55:03 +0900
parents 9c5874d0f37e
children 6b232caa07fb
files src/main/java/jp/ac/u_ryukyu/treevnc/SendCheckDelay.java src/main/java/jp/ac/u_ryukyu/treevnc/SendSingleDisplayWidth.java src/main/java/jp/ac/u_ryukyu/treevnc/TreeRFBProto.java
diffstat 3 files changed, 14 insertions(+), 7 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/jp/ac/u_ryukyu/treevnc/SendCheckDelay.java	Sun Jan 11 03:38:25 2015 +0900
+++ b/src/main/java/jp/ac/u_ryukyu/treevnc/SendCheckDelay.java	Sun Jan 11 03:55:03 2015 +0900
@@ -14,9 +14,8 @@
     public SendCheckDelay(TreeRFBProto rfb) {
         this.rfb = rfb;
     }
-    
+
     public void sendCheckDelay() throws UnsupportedEncodingException {
-        
         LinkedList<ByteBuffer> checkdelay = new LinkedList<ByteBuffer>();
         long time = System.currentTimeMillis();
         checkdelay.add(new CheckDelay(0, 0, 0, 0, time, EncodingType.CHECK_DELAY).getMessage());
--- a/src/main/java/jp/ac/u_ryukyu/treevnc/SendSingleDisplayWidth.java	Sun Jan 11 03:38:25 2015 +0900
+++ b/src/main/java/jp/ac/u_ryukyu/treevnc/SendSingleDisplayWidth.java	Sun Jan 11 03:55:03 2015 +0900
@@ -20,6 +20,9 @@
         this.singleDisplayWidth = singleWidth;
     }
 
+    public SendSingleDisplayWidth() {
+    }
+
     public void sendSingleDisplayWidth() throws UnsupportedEncodingException {
         LinkedList<ByteBuffer> linkedListSendSingleDisplayWidth = new LinkedList<ByteBuffer>();
         linkedListSendSingleDisplayWidth.add(singleDisplayWidth(0, 0, this.singleDisplayWidth, 0));
--- a/src/main/java/jp/ac/u_ryukyu/treevnc/TreeRFBProto.java	Sun Jan 11 03:38:25 2015 +0900
+++ b/src/main/java/jp/ac/u_ryukyu/treevnc/TreeRFBProto.java	Sun Jan 11 03:55:03 2015 +0900
@@ -191,7 +191,7 @@
                                 buf.order(ByteOrder.BIG_ENDIAN);
                                 buf.get();
                                 // ここにエンコーディングタイプがSendSingleDisplayWidthなframebufferUpdateを送信する処理を書く
-                                // multicastqueue.put()な処理を
+                                sendSingleDisplayWidth(singleWidth);
                             } else if (b[0] == ClientToServerMessage.CHECK_DELAY_REPLY) {
                                 ByteBuffer buf = ByteBuffer.wrap(b);
                                 buf.order(ByteOrder.BIG_ENDIAN);
@@ -252,7 +252,6 @@
                     }
                 }
             }
-
         };
         /**
          * send packets to a client (one thread for each client )
@@ -287,7 +286,6 @@
                     /* if socket closed cliList.remove(newCli); */
                 }
             }
-
             public void writeToClient(final Writer os,
                     LinkedList<ByteBuffer> bufs, int inputIndex)
                             throws TransportException {
@@ -302,10 +300,16 @@
         };
         clients++;
         new Thread(sender, "writer-to-lower-node").start();
-
     }
 
-
+    public void sendSingleDisplayWidth(int singleDisplayWidth) throws UnsupportedEncodingException {
+        LinkedList<ByteBuffer> linkedListSendSingleDisplayWidth = new LinkedList<ByteBuffer>();
+        SendSingleDisplayWidth sendSingleDisplayWidth = new SendSingleDisplayWidth();
+        linkedListSendSingleDisplayWidth.add(sendSingleDisplayWidth.singleDisplayWidth(0, 0, singleDisplayWidth, 0));
+        addSerialNumber(linkedListSendSingleDisplayWidth);
+        multicastqueue.put(linkedListSendSingleDisplayWidth);
+        System.out.println(singleDisplayWidth + " : send single display width");
+    }
 
     public boolean permitChangeScreen() {
         return permitChangeScreen;
@@ -818,4 +822,5 @@
     public void setFilterSingleDisplay(boolean filterSingleDisplay) {
         this.filterSingleDisplay = filterSingleDisplay;
     }
+
 }
\ No newline at end of file