Mercurial > hg > Database > Alice

comparison src/main/java/alice/topology/node/IncomingReverseKey.java @ 647:e321c5ec9b58

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix toplogy manager; ring worked
author suruga
date Sun, 31 Dec 2017 19:32:27 +0900
parents 145c425db88d
children
comparison
equal deleted inserted replaced
646:3c060de44c2e 647:e321c5ec9b58
1 package alice.topology.node; 1 package alice.topology.node;
2 2
3 import alice.codesegment.CodeSegment; 3 import alice.codesegment.CodeSegment;
4 import alice.daemon.IncomingTcpConnection;
4 import alice.datasegment.CommandType; 5 import alice.datasegment.CommandType;
5 import alice.datasegment.DataSegment; 6 import alice.datasegment.DataSegment;
6 import alice.datasegment.Receiver; 7 import alice.datasegment.Receiver;
7 8
8 public class IncomingReverseKey extends CodeSegment { 9 public class IncomingReverseKey extends CodeSegment {
12 13
13 @Override 14 @Override
14 public void run() { 15 public void run() {
15 String reverseKey = this.reverseKey.asString(); 16 String reverseKey = this.reverseKey.asString();
16 String from = this.reverseKey.from; 17 String from = this.reverseKey.from;
17 DataSegment.getAccept(from).setReverseKey(reverseKey); 18 IncomingTcpConnection s = DataSegment.getAccept(from);
19 if (s != null)
20 s.setReverseKey(reverseKey);
18 21
19 int reverseCount = this.reverseCount.asInteger(); 22 int reverseCount = this.reverseCount.asInteger();
20 reverseCount++; 23 reverseCount++;
21 ods.update("local", "reverseCount", reverseCount); 24 ods.update("local", "reverseCount", reverseCount);
22 25