Mercurial > hg > Database > Alice

comparison src/main/java/alice/datasegment/LocalDataSegmentManager.java @ 366:abc54fa0c81b multicast

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
MulticastDataSegment's extend class change from DataSegmentManager from LocalDataSegmentManager
author sugi
date Sat, 17 May 2014 21:34:01 +0900
parents 388e7d4b0624
children aefbe41fcf12
comparison
equal deleted inserted replaced
365:8072df9130c6 366:abc54fa0c81b
23 23
24 public LocalDataSegmentManager() { 24 public LocalDataSegmentManager() {
25 new Thread(replyThread, "LocalDataSegmentManager-replyCommand").start(); 25 new Thread(replyThread, "LocalDataSegmentManager-replyCommand").start();
26 } 26 }
27 27
28 public void setReverseKey(String s){
29 reverseKey = s;
30 }
31
28 private class RunCommand implements Runnable { 32 private class RunCommand implements Runnable {
29 33
30 DataSegmentKey key; 34 DataSegmentKey key;
31 Command cmd; 35 Command cmd;
32 36
85 dataSegmentKey.runCommand(cmd); 89 dataSegmentKey.runCommand(cmd);
86 if (logger.isDebugEnabled()) 90 if (logger.isDebugEnabled())
87 logger.debug(cmd.getCommandString()); 91 logger.debug(cmd.getCommandString());
88 } 92 }
89 93
90
91 @Override 94 @Override
92 public void quickUpdate(String key, Object val) { 95 public void quickUpdate(String key, Object val) {
93 update(key, val); 96 update(key, val);
94 } 97 }
95
96
97 98
98 @Override 99 @Override
99 public void take(Receiver receiver, CodeSegment cs) { 100 public void take(Receiver receiver, CodeSegment cs) {
100 DataSegmentKey dataSegmentKey = getDataSegmentKey(receiver.key); 101 DataSegmentKey dataSegmentKey = getDataSegmentKey(receiver.key);
101 int seq = this.seq.getAndIncrement(); 102 int seq = this.seq.getAndIncrement();
122 123
123 @Override 124 @Override
124 public void quickPeek(Receiver receiver, CodeSegment cs) { 125 public void quickPeek(Receiver receiver, CodeSegment cs) {
125 peek(receiver, cs); 126 peek(receiver, cs);
126 } 127 }
127
128 128
129 @Override 129 @Override
130 public void remove(String key) { 130 public void remove(String key) {
131 DataSegmentKey dataSegmentKey = getDataSegmentKey(key); 131 DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
132 Command cmd = new Command(CommandType.REMOVE, null, key, null, 0, 0, replyQueue, null, null); 132 Command cmd = new Command(CommandType.REMOVE, null, key, null, 0, 0, replyQueue, null, null);