Mercurial > hg > Database > Alice

comparison src/alice/datasegment/RemoteDataSegmentManager.java @ 20:0bb03861b5cd

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
set name to Thread
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Sun, 15 Jan 2012 18:44:25 +0900
parents 72dd27d952b0
children 54bf607118ae
comparison
equal deleted inserted replaced
19:e7867328a2fb 20:0bb03861b5cd
13 13
14 public RemoteDataSegmentManager(Connection connection) { 14 public RemoteDataSegmentManager(Connection connection) {
15 this.connection = connection; 15 this.connection = connection;
16 new IncomingTcpConnection(connection, this).start(); 16 new IncomingTcpConnection(connection, this).start();
17 new OutboundTcpConnection(connection).start(); 17 new OutboundTcpConnection(connection).start();
18 new Thread(replyThread).start(); 18 new Thread(replyThread, "RemoteDataSegmentManager-"
19 + connection.socket.getInetAddress().getHostName()
20 + ":" + connection.socket.getPort()).start();
19 } 21 }
20 22
21 @Override 23 @Override
22 public void put(String key, Value val) { 24 public void put(String key, Value val) {
23 connection.sendCommand(new Command(CommandType.PUT, null, key, val, 0, 0, null, null)); 25 connection.sendCommand(new Command(CommandType.PUT, null, key, val, 0, 0, null, null));