Mercurial > hg > Database > Alice

comparison src/main/java/alice/topology/node/ConfigurationFinish.java @ 552:767d93626b88 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add compressed to DSM name
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Mon, 16 Nov 2015 18:33:23 +0900
parents 145c425db88d
children
comparison
equal deleted inserted replaced
538:8c17a9e66cc7 552:767d93626b88
20 @Override 20 @Override
21 public void run() { 21 public void run() {
22 int rcount = reverseCount.asInteger(); 22 int rcount = reverseCount.asInteger();
23 int ncount = configNodeNum.asInteger(); 23 int ncount = configNodeNum.asInteger();
24 if (rcount == ncount) { 24 if (rcount == ncount) {
25 ods.put("manager", "done", ValueFactory.createNilValue()); 25 ods.put("compressedmanager", "done", ValueFactory.createNilValue());
26 Start cs = new Start(startCS); 26 Start cs = new Start(startCS);
27 cs.done.setKey("manager", "start"); 27 cs.done.setKey("compressedmanager", "start");
28 28
29 new StartKeepAlive().execute(); 29 new StartKeepAlive().execute();
30 new ReceiveCloseMessage(CommandType.PEEK); 30 new ReceiveCloseMessage(CommandType.PEEK);
31 ClosedEventManager.getInstance().register(DeleteConnection.class); 31 ClosedEventManager.getInstance().register(DeleteConnection.class);
32 ClosedEventManager.getInstance().setKey(); 32 ClosedEventManager.getInstance().setKey();
33 return; 33 return;
34 } 34 }
35 35
36 ConfigurationFinish cs3 = new ConfigurationFinish(startCS); 36 ConfigurationFinish cs3 = new ConfigurationFinish(startCS);
37 cs3.reverseCount.setKey("local", "reverseCount", this.reverseCount.index); 37 cs3.reverseCount.setKey("compressedlocal", "reverseCount", this.reverseCount.index);
38 cs3.configNodeNum.setKey("local", "configNodeNum"); 38 cs3.configNodeNum.setKey("compressedlocal", "configNodeNum");
39 } 39 }
40 40
41 } 41 }