Mercurial > hg > Database > Alice

annotate 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
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
1 package alice.topology.node;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
2
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
3 import alice.codesegment.CodeSegment;
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 523
diff changeset
4 import alice.daemon.IncomingTcpConnection;
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
5 import alice.datasegment.CommandType;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
6 import alice.datasegment.DataSegment;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
7 import alice.datasegment.Receiver;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
8
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
9 public class IncomingReverseKey extends CodeSegment {
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
10
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
11 public Receiver reverseKey = ids.create(CommandType.TAKE);
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
12 public Receiver reverseCount = ids.create(CommandType.PEEK);
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
13
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
14 @Override
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
15 public void run() {
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
16 String reverseKey = this.reverseKey.asString();
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
17 String from = this.reverseKey.from;
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 523
diff changeset
18 IncomingTcpConnection s = DataSegment.getAccept(from);
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 523
diff changeset
19 if (s != null)
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 523
diff changeset
20 s.setReverseKey(reverseKey);
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
21
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
22 int reverseCount = this.reverseCount.asInteger();
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
23 reverseCount++;
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
24 ods.update("local", "reverseCount", reverseCount);
523
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 516
diff changeset
25
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
26 IncomingReverseKey cs = new IncomingReverseKey();
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
27 cs.reverseKey.setKey("local", "reverseKey");
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
28 cs.reverseCount.setKey("local", "reverseCount");
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
29 }
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
30
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
31 }