|
12
|
1 package jp.ac.u_ryukyu.treevnc.server;
|
|
11
|
2 import java.net.Socket;
|
|
|
3 import java.io.IOException;
|
|
|
4 import java.io.InputStream;
|
|
|
5 import java.io.OutputStream;
|
|
|
6
|
|
17
|
7 import com.glavsoft.transport.Reader;
|
|
|
8 import com.glavsoft.transport.Writer;
|
|
|
9
|
|
11
|
10 public class AcceptThread implements Runnable {
|
|
12
|
11 MyRfbProtoProxy rfb = null;
|
|
11
|
12 byte[] imageBytes;
|
|
|
13 int port;
|
|
|
14
|
|
12
|
15 AcceptThread(MyRfbProtoProxy _rfb) {
|
|
11
|
16 rfb = _rfb;
|
|
|
17 }
|
|
|
18
|
|
|
19
|
|
12
|
20 AcceptThread(MyRfbProtoProxy _rfb, int p) {
|
|
11
|
21 rfb = _rfb;
|
|
|
22 port = p;
|
|
|
23 }
|
|
|
24
|
|
12
|
25 public void changeRfb(MyRfbProtoProxy _rfb) {
|
|
11
|
26 rfb = _rfb;
|
|
|
27 }
|
|
|
28
|
|
|
29 public void run() {
|
|
|
30 rfb.selectPort(port);
|
|
|
31
|
|
|
32 while (true) {
|
|
|
33 try {
|
|
|
34 Socket newCli = rfb.accept();
|
|
|
35
|
|
|
36 OutputStream os = newCli.getOutputStream();
|
|
|
37 InputStream is = newCli.getInputStream();
|
|
17
|
38 rfb.newClient(this, newCli, new Writer(os), new Reader(is));
|
|
11
|
39 } catch (IOException e) {
|
|
|
40 e.printStackTrace();
|
|
|
41 System.out.println(e);
|
|
|
42 }
|
|
|
43 }
|
|
|
44 }
|
|
|
45 }
|
