|
12
|
1 package jp.ac.u_ryukyu.treevnc.server;
|
|
11
|
2
|
|
|
3 import java.net.Socket;
|
|
|
4 import java.net.UnknownHostException;
|
|
|
5 import java.io.*;
|
|
|
6 import java.net.*;
|
|
|
7 import java.util.*;
|
|
|
8
|
|
|
9 public class AcceptClient {
|
|
13
|
10 private int counter = 0, parentnum = 0;
|
|
11
|
11 private LinkedList<String> ls = new LinkedList<String>();
|
|
|
12 private boolean addrRegistor = true;
|
|
|
13 private int passNumber=0,numberZone;
|
|
|
14 boolean runflag = false;
|
|
|
15 //private String name;
|
|
|
16 private int passCheck = 0;
|
|
13
|
17 private final int treebranch = 2;
|
|
11
|
18 private String newparent,request,myAddress;
|
|
|
19 private String leaderflag = "0", sendleaderflag = "0";
|
|
|
20 private final int intv_time = 100;
|
|
|
21
|
|
|
22
|
|
|
23
|
|
|
24 public AcceptClient(String name) {
|
|
|
25 //this.name = name;
|
|
|
26 }
|
|
|
27
|
|
|
28
|
|
|
29 /*
|
|
|
30 public AcceptClient() {
|
|
|
31 new CreateThread(this);
|
|
|
32 }
|
|
|
33 */
|
|
|
34
|
|
|
35 // public synchronized void transferParentAddrerss(BufferedReader
|
|
|
36 // is,PrintStream os) {
|
|
|
37 public void transferParentAddrerss(BufferedReader is,PrintStream os) {
|
|
|
38 try {
|
|
|
39 while (true) {
|
|
|
40 String line = is.readLine();
|
|
|
41 String port = is.readLine();
|
|
|
42 myAddress = getMyAddress();
|
|
|
43 if ("1".equals(line)||"3".equals(line)) {
|
|
|
44 String treeNumber = is.readLine();
|
|
|
45 // reply to Parents lost node
|
|
|
46 checkWait(os,is,port,Integer.parseInt(treeNumber));
|
|
|
47
|
|
|
48 } else if ("2".equals(line)) {
|
|
|
49 // reply to not Found Parents
|
|
|
50 replyNodeInformation(port);
|
|
|
51 listupdate(port, newparent);
|
|
|
52 outputStream(os, newparent, String.valueOf(parentnum),
|
|
|
53 port, leaderflag);
|
|
|
54 os.close();
|
|
|
55 is.close();
|
|
|
56 } else if (line!=null){
|
|
|
57 //connection First time
|
|
|
58 if(checkAddress(line)){
|
|
|
59 outputStream(os, myAddress,"0","0","0");
|
|
|
60 break;
|
|
|
61 }else {
|
|
|
62 if(replyCreateTree(os, port, line)) {
|
|
|
63 break;
|
|
|
64 } else {
|
|
|
65 break;
|
|
|
66 }
|
|
|
67 }
|
|
|
68 }
|
|
|
69 }
|
|
|
70 } catch (IOException e) {
|
|
|
71 System.out.println(e);
|
|
|
72 } catch (InterruptedException e) {
|
|
|
73 e.printStackTrace();
|
|
|
74 }
|
|
|
75 }
|
|
|
76
|
|
|
77 private boolean checkAddress(String line){
|
|
|
78 String test[] = line.split("\\.");
|
|
|
79 int a = Integer.parseInt(test[0]);
|
|
|
80 int b = Integer.parseInt(test[1]);
|
|
|
81 if((192==a&&b==168)||(172==a&&(b>15||b<32))||10==a) {
|
|
|
82 return true;
|
|
|
83 } else{
|
|
|
84 return false;
|
|
|
85 }
|
|
|
86 }
|
|
|
87
|
|
|
88 /**
|
|
|
89 * @param port
|
|
|
90 * parent value
|
|
|
91 */
|
|
|
92 private synchronized void listupdate(String port) {
|
|
|
93 ls.remove(Integer.parseInt(port));
|
|
|
94 ls.add(Integer.parseInt(port), ls.getLast());
|
|
|
95 ls.removeLast();
|
|
|
96 }
|
|
|
97
|
|
|
98 private synchronized void listupdate(String port,String myaddr) {
|
|
|
99 ls.remove(Integer.parseInt(port));
|
|
|
100 ls.add(Integer.parseInt(port), myaddr);
|
|
|
101 ls.removeLast();
|
|
|
102 }
|
|
|
103
|
|
|
104 private void outputStream(PrintStream os, String request, String parentnum,
|
|
|
105 String treenum, String leaderflag) {
|
|
|
106 os.println(request);
|
|
|
107 os.println(parentnum);
|
|
|
108 os.println(treenum);
|
|
|
109 os.println(leaderflag);
|
|
|
110 }
|
|
|
111
|
|
|
112 private void checkParameter(int parent, int counter, String leaderflag) {
|
|
|
113 System.out.println("number p =" + parentnum);
|
|
|
114 System.out.println("number i =" + counter);
|
|
|
115 System.out.println("leaderflag=" + leaderflag + "\n");
|
|
|
116 }
|
|
|
117
|
|
|
118 private synchronized void addClientAdress(String line, LinkedList<String> ls) {
|
|
|
119 if (line != null) {
|
|
|
120 ls.add(line);
|
|
|
121 }
|
|
|
122 //displyLinkedList(ls);
|
|
|
123 }
|
|
|
124
|
|
|
125 private void displyLinkedList( LinkedList<String> ls) {
|
|
|
126 int g = 0;
|
|
|
127 for (String bs : ls) {
|
|
|
128 System.out.println(g + "number" + bs);
|
|
|
129 g++;
|
|
|
130 }
|
|
|
131 }
|
|
|
132
|
|
|
133 private String decisionLeader(int counter, int treebranch) {
|
|
|
134 if ((counter - 1) % treebranch == 1) { // children in most young treenum
|
|
|
135 // have leaderflag 1 other 0
|
|
|
136 return "0";
|
|
|
137 } else {
|
|
|
138 return "1";
|
|
|
139 }
|
|
|
140 }
|
|
|
141
|
|
|
142 String getMyAddress () {
|
|
|
143 InetAddress addr = null;
|
|
|
144 try {
|
|
|
145 addr = InetAddress.getLocalHost();
|
|
|
146 } catch (UnknownHostException e) {
|
|
|
147 e.printStackTrace();
|
|
|
148 }
|
|
|
149 return new String(addr.getHostAddress());
|
|
|
150 }
|
|
|
151
|
|
|
152 private void replyNodeInformation (String port) {
|
|
|
153 parentnum = (Integer.parseInt(port) - 1) / treebranch;
|
|
|
154 newparent = ls.get(parentnum);
|
|
|
155 sendleaderflag = decisionLeader(Integer.parseInt(port), treebranch);
|
|
|
156 //leaderflag = decisionLeader(Integer.parseInt(port),treebranch);
|
|
|
157 }
|
|
|
158
|
|
|
159 private void replyLeaderNode(PrintStream os,BufferedReader is,String port,String treeNumber) throws IOException, InterruptedException {
|
|
|
160 os.println(ls.getLast());
|
|
|
161 replyNodeInformation(port);
|
|
|
162 counter--;
|
|
|
163 passCheck = 1;
|
|
|
164 reportLastNode(ls.getLast(), newparent,port, String.valueOf(parentnum),sendleaderflag);
|
|
|
165 listupdate(port);
|
|
|
166 waitThread();
|
|
|
167 /*
|
|
|
168 if (Integer.parseInt(treeNumber)==ls.size()-1)
|
|
|
169 return;
|
|
|
170 */
|
|
|
171 //displyLinkedList(ls);
|
|
|
172 os.println(port);
|
|
|
173 leaderflag = decisionLeader(Integer.parseInt(treeNumber),treebranch);
|
|
|
174 os.println(treeNumber);
|
|
|
175 Thread.sleep(intv_time);
|
|
|
176 is.close();
|
|
|
177 os.close();
|
|
|
178 }
|
|
|
179
|
|
|
180 private void replyNormalChildren(PrintStream os,BufferedReader is,String port,String treeNumber,boolean flag) throws IOException, InterruptedException {
|
|
|
181 if(flag)
|
|
|
182 notifyThread();
|
|
|
183 else
|
|
|
184 waitThread();
|
|
|
185 if (Integer.parseInt(treeNumber)==ls.size())
|
|
|
186 return;
|
|
|
187 os.println(ls.get(Integer.parseInt(port)));
|
|
|
188 os.println(port);
|
|
|
189 if(ls.size()-1+passCheck == Integer.parseInt(treeNumber))
|
|
|
190 treeNumber = "skip";
|
|
|
191 passCheck = 0;
|
|
|
192 os.println(treeNumber);
|
|
|
193 System.out.println("num4="+ ls.get(Integer.parseInt(port)));
|
|
|
194 runflag = false;
|
|
|
195 is.close();
|
|
|
196 os.close();
|
|
|
197 }
|
|
|
198
|
|
|
199 private synchronized boolean replyCreateTree(PrintStream os,String port,String line) throws InterruptedException {
|
|
|
200 if (addrRegistor == true) {
|
|
|
201 ls.add(myAddress);
|
|
|
202 addrRegistor = false;
|
|
|
203 }
|
|
|
204
|
|
|
205 if (line != null) {
|
|
|
206 addClientAdress(line, ls);
|
|
|
207 counter++;
|
|
|
208 } else {
|
|
|
209 return true;
|
|
|
210 }
|
|
|
211
|
|
|
212 if (counter >= treebranch + 1) {
|
|
|
213 leaderflag = decisionLeader(counter, treebranch);
|
|
|
214 parentnum = (counter - 1) / treebranch;
|
|
|
215 request = ls.get(parentnum);
|
|
|
216 System.out.println(parentnum);
|
|
|
217 outputStream(os, request,String.valueOf(parentnum),
|
|
|
218 String.valueOf(counter), leaderflag);
|
|
|
219 checkParameter(parentnum, counter, leaderflag);
|
|
|
220 } else {
|
|
|
221 outputStream(os, myAddress, "0",
|
|
|
222 String.valueOf(counter), leaderflag);
|
|
|
223 }
|
|
|
224 Thread.sleep(intv_time);
|
|
|
225 return false;
|
|
|
226 }
|
|
|
227
|
|
|
228 void reportLastNode(String newchild, String newparent, String newtreenum,
|
|
|
229 String newpnum, String newleaderflag) throws IOException {
|
|
|
230 try {
|
|
|
231 Socket echoSocket;
|
|
|
232 System.out.println(newchild + "connect");
|
|
|
233 // echoSocket = new Socket(newchild, 10001 + (i + 1));//
|
|
|
234 echoSocket = new Socket(newchild, 10001);
|
|
|
235 DataOutputStream os = new DataOutputStream(echoSocket.getOutputStream());
|
|
|
236 os.writeBytes(newparent + "\n");
|
|
|
237 os.writeBytes(newpnum + "\n");
|
|
|
238 os.writeBytes(newtreenum + "\n");
|
|
|
239 os.writeBytes(newleaderflag + "\n");
|
|
|
240 os.close();
|
|
|
241 } catch (UnknownHostException e) {
|
|
|
242 System.err.println("Don't know about host: localhost");
|
|
|
243 } catch (IOException e) {
|
|
|
244 System.err
|
|
|
245 .println("Couldn't get I/O for the connection to: localhost");
|
|
|
246 }
|
|
|
247 }
|
|
|
248
|
|
|
249 void reportFinishFlag(String nextLastNode) {
|
|
|
250 Socket echoSocket;
|
|
|
251 try {
|
|
|
252 echoSocket = new Socket(nextLastNode, 10001);
|
|
|
253 DataOutputStream os = new DataOutputStream(
|
|
|
254 echoSocket.getOutputStream());
|
|
|
255 os.writeBytes("lastnode" + "\n");
|
|
|
256 } catch (UnknownHostException e) {
|
|
|
257 e.printStackTrace();
|
|
|
258 } catch (IOException e) {
|
|
|
259 e.printStackTrace();
|
|
|
260 }
|
|
|
261
|
|
|
262 }
|
|
|
263
|
|
|
264 synchronized void checkWait(PrintStream os,BufferedReader is,String port,int treeNum) throws InterruptedException, IOException {
|
|
|
265 final int TIMEOUT = 3000;
|
|
|
266 if (passNumber == 0) {
|
|
|
267 passNumber++;
|
|
|
268 numberZone = ((treeNum - 1) / treebranch);
|
|
|
269 //System.out.println(treeNum + "--wait--");
|
|
|
270 replyLeaderNode(os,is,port,String.valueOf(treeNum));
|
|
|
271 notifyAll();
|
|
|
272 passNumber = 0;
|
|
|
273 } else if (numberZone == ((treeNum - 1) / treebranch)) {
|
|
|
274 if (++passNumber == treebranch) {
|
|
|
275 //System.out.println(treeNum + "--notify--");
|
|
|
276 passNumber = 0;
|
|
|
277 replyNormalChildren(os,is,port,String.valueOf(treeNum),true);
|
|
|
278 } else {
|
|
|
279 //System.out.println(treeNum + "--waityobi--");
|
|
|
280 replyNormalChildren(os,is,port,String.valueOf(treeNum),false);
|
|
|
281 wait(TIMEOUT);
|
|
|
282 }
|
|
|
283 } else {
|
|
|
284 wait();
|
|
|
285 checkWait(os,is,port,treeNum);
|
|
|
286 }
|
|
|
287 }
|
|
|
288
|
|
|
289 private void waitThread() {
|
|
|
290 final int TIMEOUT = 3000;
|
|
|
291 try {
|
|
|
292 wait(TIMEOUT);
|
|
|
293 } catch (InterruptedException e) {
|
|
|
294 e.printStackTrace();
|
|
|
295 }
|
|
|
296 }
|
|
|
297 private void notifyThread() {
|
|
|
298 notifyAll();
|
|
|
299 }
|
|
|
300 } |
