Mercurial > hg > Members > nobuyasu > tightVNCProxy

annotate src/myVncProxy/acceptClient.java @ 63:4864a7d1df00

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add CreateThread.java modify acceptClient.java and VncProxyService.java
author Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
date Tue, 12 Jul 2011 13:47:32 +0900
parents 5953ac30cb20
children 3ec4c9e94462
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
49
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
1 package myVncProxy;
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
2
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
3 import java.net.Socket;
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
4 import java.io.*;
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
5 import java.net.*;
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
6 import java.util.*;
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
7
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
8 public class acceptClient extends Thread {
63
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
9 ServerSocket echoServer=null;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
10 // ソケットや入出力用のストリームの宣言
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
11 String line,port,handover;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
12 BufferedReader is;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
13 PrintStream os;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
14 Socket clientSocket = null;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
15 int intv_time = 100;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
16 int i = 0 , p = 0,t = 0;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
17 //String[] sub = new String[100];
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
18 LinkedList<String> ls = new LinkedList<String>();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
19 String request,name;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
20 int treebranch = 2;//treeの子ノードの数
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
21 String leaderflag="0",sendleaderflag="0";
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
22 boolean runflag =false,addrRegistor=true;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
23 BufferedReader temp = null;//一時的にisを保存する変数
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
24 CreateThread createThread;
49
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
25
63
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
26 public acceptClient(String _name) {
49
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
27 // TODO Auto-generated constructor stub
63
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
28 name = _name;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
29 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
30 public acceptClient() {
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
31 new CreateThread(this);
49
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
32 }
63
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
33
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
34
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
35
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
36 public synchronized void gethost(BufferedReader is,PrintStream os) {
49
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
37
63
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
38 //public synchronized void run () {
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
39 /*
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
40 while(true){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
41 // ポート9999番を開く
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
42 try {
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
43 echoServer = new ServerSocket(9999);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
44 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
45 catch (IOException e) {
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
46 System.out.println(e);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
47 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
48
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
49 // クライアントからの要求を受けるソケットを開く
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
50 try {
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
51 clientSocket = echoServer.accept();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
52 is = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
53 os = new PrintStream(clientSocket.getOutputStream());
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
54 */
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
55 // クライアントからのメッセージを待ち、受け取ったメッセージをそのまま返す
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
56 try {
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
57 while (true){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
58 line = is.readLine();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
59 port = is.readLine();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
60
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
61 System.out.println("データーを受信しましたlin="+line+" port="+port);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
62 //自分の IPADRESSを取得する
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
63 InetAddress addr = InetAddress.getLocalHost();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
64 String add = new String(addr.getHostAddress());
49
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
65
63
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
66 if("1".equals(line)){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
67 System.out.println("親が落ちましたmessage" + port);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
68 os.println(ls.getLast());
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
69 handover= String.valueOf((Integer.parseInt(port) - 1) / treebranch);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
70 String hidenchild=ls.getLast();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
71 String newparent=ls.get(Integer.parseInt(handover));
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
72 ls.remove(Integer.parseInt(port));
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
73 ls.add(Integer.parseInt(port),ls.getLast());
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
74 ls.remove(Integer.parseInt(port));
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
75 i--;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
76 t++;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
77 runflag = true;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
78 if(t % treebranch == 0){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
79 p--;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
80 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
81 if((i-1)%treebranch==1){ // children in most young treenum have leaderflag 1 other 0
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
82 sendleaderflag = "1";
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
83 }else{
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
84 sendleaderflag = "0";
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
85 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
86
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
87 child child = new child();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
88 child.clost(hidenchild,newparent,os,port,handover,sendleaderflag,i);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
89 os.println(port);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
90 Thread.sleep(intv_time);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
91 is.close();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
92 os.close();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
93
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
94 }else if("2".equals(line)){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
95 System.out.println("子供が落ちましたmessage" + port);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
96 //exit シグナルを送る
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
97 Thread.sleep(intv_time);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
98 }else if("3".equals(line)){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
99 System.out.println("落ちたのを確認しました");
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
100
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
101 os.println(ls.get(Integer.parseInt(port)));
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
102 os.println(port);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
103 line=null;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
104 runflag = false;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
105 is.close();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
106 os.close();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
107 }else{
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
108 if(addrRegistor==true){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
109 ls.add(add);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
110 addrRegistor = false;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
111 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
112 System.out.println(p);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
113 if(line != null){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
114 sock conf = new sock();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
115 conf.arg(line,ls);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
116 i++;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
117 }else{
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
118 break;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
119 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
120
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
121 if(i>=treebranch+1){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
122 if((i-1)%treebranch==0){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
123 leaderflag = "1";
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
124 }else{
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
125 leaderflag = "0";
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
126 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
127 if((i-1)%treebranch==0){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
128 p++;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
129 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
130 // request = [p-1];
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
131 request = ls.get(p);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
132 os.println(request);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
133 System.out.println("pの値="+p);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
134 os.println(String.valueOf(p));
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
135 System.out.println("iの値="+i);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
136 os.println(String.valueOf(i));
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
137 System.out.println("leaderflag="+leaderflag + "\n");
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
138 os.println(leaderflag);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
139 }else{
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
140 //treeの親ノードに接続する人に接続する人を教える
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
141
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
142 os.println(add);//あとで渡されたmainArgs[1]（現在はname）を渡す予定
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
143 os.println("0");
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
144 os.println(String.valueOf(i));
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
145 os.println(leaderflag + "\n");
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
146 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
147 Thread.sleep(intv_time);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
148 }
49
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
149 }
63
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
150
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
151 } catch (IOException e){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
152 System.out.println(e);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
153 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
154
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
155 catch(InterruptedException e){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
156 e.printStackTrace();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
157 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
158 /*
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
159 try{
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
160 echoServer.close();
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
161 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
162 catch (IOException e){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
163 System.out.println(e);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
164 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
165 */
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
166 //} comment out while
49
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
167 }
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
168 }
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
169
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
170
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
171 class sock{
63
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
172 void arg(String line,LinkedList<String> ls){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
173 if(line != null){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
174 ls.add(line);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
175 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
176 int g=0;
49
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
177
63
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
178 for(String bs: ls){
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
179 System.out.println(g+"番目"+bs);
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
180 g++;
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
181 }
49
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
182 }
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
183 }
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
184
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
185 class child{
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
186 Socket echoSocket;
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
187 DataOutputStream os = null;
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
188 BufferedReader is = null;
63
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
189 void clost(String hiddenchild,String newparent,PrintStream rep,String newtreenum,String newpnum,String newleaderflag,int i) throws IOException{
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
190 try {
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
191
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
192 System.out.println(hiddenchild + "に接続します");
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
193 echoSocket = new Socket(hiddenchild, 10001 + (i + 1));//i+1は実験中に同じマシーンを使っていたのでportを変えて対応、本番時には取り除く予定。
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
194
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
195 os = new DataOutputStream(echoSocket.getOutputStream());
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
196 is = new BufferedReader(new InputStreamReader(echoSocket.getInputStream()));
49
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
197
63
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
198 os.writeBytes(newparent+"\n");
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
199 os.writeBytes(newpnum+"\n");
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
200 os.writeBytes(newtreenum+"\n");
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
201 os.writeBytes(newleaderflag+"\n");
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
202
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
203 } catch (UnknownHostException e) {
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
204 System.err.println("Don't know about host: localhost");
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
205 } catch (IOException e) {
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
206 System.err.println("Couldn't get I/O for the connection to: localhost");
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
207 }
49
5953ac30cb20 add acceptClient.java
e085711
parents:
diff changeset
208
63
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
209 }
4864a7d1df00 add CreateThread.java modify acceptClient.java and VncProxyService.java
Yu Taninari <e085734@ie.u-ryukyu.ac.jp>
parents: 49
diff changeset
210 }