Mercurial > hg > Members > tatsuki > Alice
diff src/alice/daemon/IncomingTcpConnection.java @ 270:23e53aaa8720
reconnect manager worked.
author | sugi |
---|---|
date | Wed, 21 Aug 2013 15:33:49 +0900 |
parents | 88be2824a989 |
children | 7188fe3f7c95 |
line wrap: on
line diff
--- a/src/alice/daemon/IncomingTcpConnection.java Tue Aug 20 17:35:03 2013 +0900 +++ b/src/alice/daemon/IncomingTcpConnection.java Wed Aug 21 15:33:49 2013 +0900 @@ -13,6 +13,8 @@ import alice.datasegment.DataSegmentKey; import alice.datasegment.DataSegmentManager; import alice.datasegment.LocalDataSegmentManager; +import alice.topology.HostMessage; +import alice.topology.manager.reconnection.SendError; public class IncomingTcpConnection extends Thread { @@ -69,6 +71,7 @@ connection.sendCommand(new Command(CommandType.CLOSE, null, null, null, 0, 0, null, null, null)); return; } catch (EOFException e) { + new SendError(new HostMessage(connection.socket.getInetAddress().getHostName(), connection.socket.getPort())).execute(); connection.sendCommand(new Command(CommandType.CLOSE, null, null, null, 0, 0, null, null, null)); return; } catch (IOException e) {