|
12
|
1 package jp.ac.u_ryukyu.treevnc.client;
|
|
1
|
2
|
|
|
3 import java.io.IOException;
|
|
38
|
4 import java.io.OutputStream;
|
|
42
|
5 import java.net.BindException;
|
|
1
|
6 import java.net.ServerSocket;
|
|
|
7 import java.net.Socket;
|
|
12
|
8
|
|
38
|
9 /**
|
|
|
10 * this Class get top(Proxy) Instruction.
|
|
|
11 * Type of Instruction is ReConnection and SocketClose.
|
|
|
12 */
|
|
1
|
13 public class WaitReply extends Thread {
|
|
38
|
14 private boolean passflag;
|
|
|
15 private EchoClient echo;
|
|
1
|
16
|
|
36
|
17 public WaitReply(String treenum, EchoClient echo) {
|
|
|
18 this.echo = echo;
|
|
1
|
19 }
|
|
|
20
|
|
|
21 public boolean checkPath() {
|
|
|
22 return passflag;
|
|
|
23 }
|
|
|
24
|
|
|
25 public void run() {
|
|
|
26 Socket clientSocket = null;
|
|
|
27 ServerSocket echoServer = null;
|
|
|
28 while (true) {
|
|
|
29 try {
|
|
|
30 echoServer = new ServerSocket(10001);
|
|
|
31 clientSocket = echoServer.accept();
|
|
|
32 if (clientSocket != null) {
|
|
42
|
33 echo.client.stopTask();
|
|
36
|
34 echo.client.close();
|
|
1
|
35 passflag = true;
|
|
42
|
36 System.out.println("------waitreply");
|
|
36
|
37 echo.client.setSocket(echo.createSocketForClient(clientSocket));
|
|
38
|
38 // hult();
|
|
36
|
39 // client.init();
|
|
|
40 echo.client.run();
|
|
1
|
41 echoServer.close();
|
|
|
42 }
|
|
42
|
43 } catch (BindException e) {
|
|
|
44 break;
|
|
1
|
45 } catch (IOException e) {
|
|
|
46 System.out.println(e);
|
|
42
|
47 }
|
|
1
|
48 }
|
|
|
49 }
|
|
38
|
50
|
|
|
51 private void hult() throws IOException {
|
|
|
52 Socket socket = new Socket("localhsot", echo.client.getPort());
|
|
|
53 OutputStream stream = socket.getOutputStream();
|
|
|
54 stream.write("halt".getBytes());
|
|
|
55 stream.flush();
|
|
|
56 }
|
|
1
|
57 }
|
