Mercurial > hg > Members > you > TreeVNC

comparison src/treeVnc/AcceptClient.java @ 35:cca2a548ed95

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
before update
author one
date Tue, 24 Apr 2012 08:34:34 +0900
parents da007a84f111
children
comparison
equal deleted inserted replaced
34:32b266967c2c 35:cca2a548ed95
118 118
119 private synchronized void addClientAdress(String line, LinkedList<String> ls) { 119 private synchronized void addClientAdress(String line, LinkedList<String> ls) {
120 if (line != null) { 120 if (line != null) {
121 ls.add(line); 121 ls.add(line);
122 } 122 }
123 displyLinkedList(ls); 123 //displyLinkedList(ls);
124 } 124 }
125 125
126 private void displyLinkedList( LinkedList<String> ls) { 126 private void displyLinkedList( LinkedList<String> ls) {
127 int g = 0; 127 int g = 0;
128 for (String bs : ls) { 128 for (String bs : ls) {
167 waitThread(); 167 waitThread();
168 /* 168 /*
169 if (Integer.parseInt(treeNumber)==ls.size()-1) 169 if (Integer.parseInt(treeNumber)==ls.size()-1)
170 return; 170 return;
171 */ 171 */
172 displyLinkedList(ls); 172 //displyLinkedList(ls);
173 os.println(port); 173 os.println(port);
174 leaderflag = decisionLeader(Integer.parseInt(treeNumber),treebranch); 174 leaderflag = decisionLeader(Integer.parseInt(treeNumber),treebranch);
175 os.println(treeNumber); 175 os.println(treeNumber);
176 Thread.sleep(intv_time); 176 Thread.sleep(intv_time);
177 is.close(); 177 is.close();
267 synchronized void checkWait(PrintStream os,BufferedReader is,String port,int treeNum) throws InterruptedException, IOException { 267 synchronized void checkWait(PrintStream os,BufferedReader is,String port,int treeNum) throws InterruptedException, IOException {
268 final int TIMEOUT = 3000; 268 final int TIMEOUT = 3000;
269 if (passNumber == 0) { 269 if (passNumber == 0) {
270 passNumber++; 270 passNumber++;
271 numberZone = ((treeNum - 1) / treebranch); 271 numberZone = ((treeNum - 1) / treebranch);
272 System.out.println(treeNum + "--wait--"); 272 //System.out.println(treeNum + "--wait--");
273 replyLeaderNode(os,is,port,String.valueOf(treeNum)); 273 replyLeaderNode(os,is,port,String.valueOf(treeNum));
274 notifyAll(); 274 notifyAll();
275 passNumber = 0; 275 passNumber = 0;
276 } else if (numberZone == ((treeNum - 1) / treebranch)) { 276 } else if (numberZone == ((treeNum - 1) / treebranch)) {
277 if (++passNumber == treebranch) { 277 if (++passNumber == treebranch) {
278 System.out.println(treeNum + "--notify--"); 278 //System.out.println(treeNum + "--notify--");
279 passNumber = 0; 279 passNumber = 0;
280 replyNormalChildren(os,is,port,String.valueOf(treeNum),true); 280 replyNormalChildren(os,is,port,String.valueOf(treeNum),true);
281 } else { 281 } else {
282 System.out.println(treeNum + "--waityobi--"); 282 //System.out.println(treeNum + "--waityobi--");
283 replyNormalChildren(os,is,port,String.valueOf(treeNum),false); 283 replyNormalChildren(os,is,port,String.valueOf(treeNum),false);
284 wait(TIMEOUT); 284 wait(TIMEOUT);
285 } 285 }
286 } else { 286 } else {
287 wait(); 287 wait();