Mercurial > hg > Database > Alice
comparison src/alice/datasegment/RemoteDataSegmentManager.java @ 58:ebdcab7b9b04
add comment
author | one |
---|---|
date | Wed, 08 Feb 2012 17:06:39 +0900 |
parents | 27a64e771c4c |
children | 498d1d2524d3 |
comparison
equal
deleted
inserted
replaced
57:7fa9ddb31f64 | 58:ebdcab7b9b04 |
---|---|
43 new OutboundTcpConnection(connection).start(); | 43 new OutboundTcpConnection(connection).start(); |
44 } | 44 } |
45 }.start(); | 45 }.start(); |
46 } | 46 } |
47 | 47 |
48 /** | |
49 * send put command to target DataSegment | |
50 */ | |
48 @Override | 51 @Override |
49 public void put(String key, Value val, CodeSegment cs) { | 52 public void put(String key, Value val, CodeSegment cs) { |
50 Command cmd = new Command(CommandType.PUT, null, key, val, 0, 0, null, cs, null); | 53 Command cmd = new Command(CommandType.PUT, null, key, val, 0, 0, null, cs, null); |
51 connection.sendCommand(cmd); | 54 connection.sendCommand(cmd); // put command on the transmission thread |
52 logger.debug(cmd.getCommandString()); | 55 logger.debug(cmd.getCommandString()); |
53 } | 56 } |
54 | 57 |
55 @Override | 58 @Override |
56 public void update(String key, Value val, CodeSegment cs) { | 59 public void update(String key, Value val, CodeSegment cs) { |