# HG changeset patch # User sugi # Date 1418891325 -32400 # Node ID 79d5b317b2b62bd756e25b28007c7a5dce36b6f9 # Parent 7d83a188a4f7ba4814f5a6c49bd46147c6659d0e remove unused method diff -r 7d83a188a4f7 -r 79d5b317b2b6 src/main/java/alice/codesegment/OutputDataSegment.java --- a/src/main/java/alice/codesegment/OutputDataSegment.java Wed Dec 17 20:48:34 2014 +0900 +++ b/src/main/java/alice/codesegment/OutputDataSegment.java Thu Dec 18 17:28:45 2014 +0900 @@ -157,17 +157,6 @@ DataSegment.get(managerKey).ping(returnKey); } - /** - * this method is to forcibly close socket - * - * @param managerKey - */ - - public void shutdown(String managerKey){ - if (DataSegment.contains(managerKey)) - DataSegment.get(managerKey).shutdown(); - } - public boolean compressFlag() { return compressFlag; } diff -r 7d83a188a4f7 -r 79d5b317b2b6 src/main/java/alice/datasegment/DataSegmentManager.java --- a/src/main/java/alice/datasegment/DataSegmentManager.java Wed Dec 17 20:48:34 2014 +0900 +++ b/src/main/java/alice/datasegment/DataSegmentManager.java Thu Dec 18 17:28:45 2014 +0900 @@ -64,6 +64,5 @@ public abstract void response(String returnKey); public abstract void setSendError(boolean b); - public abstract void putSocketInfo(); } diff -r 7d83a188a4f7 -r 79d5b317b2b6 src/main/java/alice/datasegment/LocalDataSegmentManager.java --- a/src/main/java/alice/datasegment/LocalDataSegmentManager.java Wed Dec 17 20:48:34 2014 +0900 +++ b/src/main/java/alice/datasegment/LocalDataSegmentManager.java Thu Dec 18 17:28:45 2014 +0900 @@ -158,10 +158,4 @@ public void setSendError(boolean b) { } - - @Override - public void putSocketInfo() { - - } - } diff -r 7d83a188a4f7 -r 79d5b317b2b6 src/main/java/alice/datasegment/RemoteDataSegmentManager.java --- a/src/main/java/alice/datasegment/RemoteDataSegmentManager.java Wed Dec 17 20:48:34 2014 +0900 +++ b/src/main/java/alice/datasegment/RemoteDataSegmentManager.java Thu Dec 18 17:28:45 2014 +0900 @@ -159,10 +159,4 @@ public void setSendError(boolean b) { connection.sendManager = b; } - - @Override - public void putSocketInfo() { - connection.putConnectionInfo(); - } - } diff -r 7d83a188a4f7 -r 79d5b317b2b6 src/main/java/alice/topology/node/IncomingConnectionInfo.java --- a/src/main/java/alice/topology/node/IncomingConnectionInfo.java Wed Dec 17 20:48:34 2014 +0900 +++ b/src/main/java/alice/topology/node/IncomingConnectionInfo.java Thu Dec 18 17:28:45 2014 +0900 @@ -31,6 +31,9 @@ DataSegment.connect(hostInfo.connectionName, hostInfo.reverseName, hostInfo.name, hostInfo.port); ods.put(hostInfo.connectionName, "reverseKey", hostInfo.reverseName); count++; + + ods.put("cMember", hostInfo.connectionName); + new CreateConnectionList(); } } diff -r 7d83a188a4f7 -r 79d5b317b2b6 src/main/java/alice/topology/node/IncomingReverseKey.java --- a/src/main/java/alice/topology/node/IncomingReverseKey.java Wed Dec 17 20:48:34 2014 +0900 +++ b/src/main/java/alice/topology/node/IncomingReverseKey.java Thu Dec 18 17:28:45 2014 +0900 @@ -20,9 +20,6 @@ reverseCount++; ods.update("local", "reverseCount", reverseCount); - ods.put("cMember", reverseKey); - new CreateConnectionList(); - IncomingReverseKey cs = new IncomingReverseKey(); cs.reverseKey.setKey("local", "reverseKey"); cs.reverseCount.setKey("local", "reverseCount");