Mercurial > hg > Applications > TreeVNC

annotate src/main/java/jp/ac/u_ryukyu/treevnc/SendCheckDelay.java @ 239:d655db005535

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
create sendCheckDelay Socket.
author oc
date Sat, 11 Oct 2014 23:46:22 +0900
parents
children 7310e7d7a45f
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
239
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
1 package jp.ac.u_ryukyu.treevnc;
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
2
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
3 import java.io.UnsupportedEncodingException;
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
4 import java.nio.ByteBuffer;
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
5 import java.util.LinkedList;
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
6
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
7 import com.glavsoft.rfb.encoding.EncodingType;
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
8
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
9
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
10 public class SendCheckDelay implements Runnable {
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
11
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
12 private TreeRFBProto rfb;
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
13
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
14 public SendCheckDelay(TreeRFBProto rfb) {
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
15 this.rfb = rfb;
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
16 }
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
17
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
18 public void sendCheckDelay() throws UnsupportedEncodingException {
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
19
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
20 LinkedList<ByteBuffer> checkdelay = new LinkedList<ByteBuffer>();
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
21 long time = System.currentTimeMillis();
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
22 checkdelay.add(new CheckDelay(0, 0, 0, 0, time, EncodingType.CHECK_DELAY).getMessage());
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
23 rfb.addSerialNumber(checkdelay);
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
24 rfb.multicastqueue.put(checkdelay);
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
25
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
26 }
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
27
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
28 public void run() {
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
29 for (;;) {
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
30 System.out.println("run sendCheckDelay");
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
31 long timeout = 50000 / 8;
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
32 try {
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
33 synchronized (this) {
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
34 wait(timeout);
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
35 sendCheckDelay();
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
36 }
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
37 } catch (InterruptedException e) {
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
38 e.printStackTrace();
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
39 } catch (UnsupportedEncodingException e) {
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
40 e.printStackTrace();
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
41 }
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
42 }
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
43 }
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
44
d655db005535 create sendCheckDelay Socket.
oc
parents:
diff changeset
45 }