Mercurial > hg > Database > Christie

comparison src/main/java/christie/topology/node/IncomingReverseKey.java @ 49:fd944876257b

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add node and keepalive
author akahori
date Thu, 23 Aug 2018 09:29:05 +0900
parents
children 20d4c0cce914
comparison
equal deleted inserted replaced
48:174a2f37ec28 49:fd944876257b
1 package christie.topology.node;
2
3
4 import christie.annotation.Peek;
5 import christie.annotation.Take;
6 import christie.codegear.CodeGear;
7 import christie.codegear.CodeGearManager;
8 import christie.daemon.IncomingTcpConnection;
9
10 public class IncomingReverseKey extends CodeGear {
11
12 @Take
13 String reverseKey;
14
15 @Peek
16 int reverseCount;
17
18 @Override
19 protected void run(CodeGearManager cgm) {
20 //String from = this.reverseKey.from;
21 //IncomingTcpConnection s = DataSegment.getAccept(from);
22 //if (s != null) s.setReverseKey(reverseKey);
23
24 reverseCount++;
25 getLocalDGM().put( "reverseCount", reverseCount);
26 cgm.setup(new IncomingReverseKey());
27 }
28
29 }