Mercurial > hg > Applications > TightVNC_orginal

comparison src/main/java/jp/ac/u_ryukyu/treevnc/server/CreateThread.java @ 38:c2f0b6907448

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add doc directory
author one
date Thu, 27 Sep 2012 19:32:25 +0900
parents 718cdde720d4
children
comparison
equal deleted inserted replaced
37:1454d6fe96c1 38:c2f0b6907448
10 10
11 public class CreateThread implements Runnable { 11 public class CreateThread implements Runnable {
12 ServerSocket echoServer; 12 ServerSocket echoServer;
13 AcceptClient acceptClient; 13 AcceptClient acceptClient;
14 private int port; 14 private int port;
15 private boolean stopFlag;
15 16
16 public CreateThread(AcceptClient _acc) { 17 public CreateThread(AcceptClient _acc) {
17 acceptClient = _acc; 18 acceptClient = _acc;
18 port = 9999; 19 port = 9999;
19 } 20 }
67 68
68 while (true) { 69 while (true) {
69 try { 70 try {
70 // echoServer = new ServerSocket(9999); 71 // echoServer = new ServerSocket(9999);
71 Socket clientSocket = echoServer.accept(); 72 Socket clientSocket = echoServer.accept();
73 if(stopFlag) break;
72 BufferedReader is = new BufferedReader(new InputStreamReader( 74 BufferedReader is = new BufferedReader(new InputStreamReader(
73 clientSocket.getInputStream())); 75 clientSocket.getInputStream()));
74 PrintStream os = new PrintStream(clientSocket.getOutputStream()); 76 PrintStream os = new PrintStream(clientSocket.getOutputStream());
75 newEchoClient(is,os); 77 newEchoClient(is,os);
76 // acceptClient.transferParentAddrerss(is, os); 78 // acceptClient.transferParentAddrerss(is, os);
77 } catch (IOException e) { 79 } catch (IOException e) {
78 System.out.println(e); 80 System.out.println(e);
79 } 81 }
80 /*
81 try {
82 echoServer.close();
83 } catch (IOException e) {
84 System.out.println(e);
85 }
86 */
87
88 } 82 }
89 83
90 } 84 }
85 public void setStopFlag(boolean flag){
86 stopFlag = flag;
87 }
91 88
92 } 89 }