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) {