comparison src/main/java/jp/ac/u_ryukyu/treevnc/AcceptThread.java @ 31:872d9bcbfe56

Before changing the Viewer.
author one
date Sat, 01 Sep 2012 21:23:30 +0900
parents src/main/java/jp/ac/u_ryukyu/treevnc/server/AcceptThread.java@718cdde720d4
children 758d025ee24b
comparison
equal deleted inserted replaced
30:0c08cdc4b572 31:872d9bcbfe56
1 package jp.ac.u_ryukyu.treevnc;
2 import java.net.Socket;
3 import java.io.IOException;
4 import java.io.InputStream;
5 import java.io.OutputStream;
6
7 import jp.ac.u_ryukyu.treevnc.server.MyRfbProtoProxy;
8 import jp.ac.u_ryukyu.treevnc.test.MyRfbProto;
9
10 import com.glavsoft.transport.Reader;
11 import com.glavsoft.transport.Writer;
12
13 public class AcceptThread implements Runnable {
14 MyRfbProto rfb = null;
15 byte[] imageBytes;
16 int port;
17
18 public AcceptThread(MyRfbProto _rfb) {
19 rfb = _rfb;
20 }
21
22
23 public AcceptThread(MyRfbProto _rfb, int p) {
24 rfb = _rfb;
25 port = p;
26 }
27
28 public void changeRfb(MyRfbProto _rfb) {
29 rfb = _rfb;
30 }
31
32 public void run() {
33 rfb.selectPort(port);
34
35 while (true) {
36 try {
37 Socket newCli = rfb.accept();
38
39 OutputStream os = newCli.getOutputStream();
40 InputStream is = newCli.getInputStream();
41 rfb.newClient(this, newCli, new Writer(os), new Reader(is));
42 } catch (IOException e) {
43 e.printStackTrace();
44 System.out.println(e);
45 }
46 }
47 }
48 }