Mercurial > hg > Database > Alice

comparison src/alice/topology/manager/ConfigWaiter.java @ 270:23e53aaa8720

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
reconnect manager worked.
author sugi
date Wed, 21 Aug 2013 15:33:49 +0900
parents ac3b48c5f4da
children
comparison
equal deleted inserted replaced
269:9982e1c4f099 270:23e53aaa8720
3 import org.msgpack.type.ValueFactory; 3 import org.msgpack.type.ValueFactory;
4 4
5 import alice.codesegment.CodeSegment; 5 import alice.codesegment.CodeSegment;
6 import alice.datasegment.CommandType; 6 import alice.datasegment.CommandType;
7 import alice.datasegment.Receiver; 7 import alice.datasegment.Receiver;
8 import alice.topology.manager.reconnection.ReceiveError;
8 9
9 public class ConfigWaiter extends CodeSegment { 10 public class ConfigWaiter extends CodeSegment {
10 11
11 public Receiver done = ids.create(CommandType.TAKE); 12 public Receiver done = ids.create(CommandType.TAKE);
12 public int count; 13 public int count;
18 @Override 19 @Override
19 public void run() { 20 public void run() {
20 count--; 21 count--;
21 if (count == 0) { 22 if (count == 0) {
22 ods.put("local", "start", ValueFactory.createNilValue()); 23 ods.put("local", "start", ValueFactory.createNilValue());
24 new ReceiveError();
23 return; 25 return;
24 } 26 }
25 ConfigWaiter cs3 = new ConfigWaiter(count); 27 ConfigWaiter cs3 = new ConfigWaiter(count);
26 cs3.done.setKey("local", "done"); 28 cs3.done.setKey("local", "done");
27 } 29 }