changeset 503:79d5b317b2b6 dispose

remove unused method
author sugi
date Thu, 18 Dec 2014 17:28:45 +0900
parents 7d83a188a4f7
children ece6a109b64c
files src/main/java/alice/codesegment/OutputDataSegment.java src/main/java/alice/datasegment/DataSegmentManager.java src/main/java/alice/datasegment/LocalDataSegmentManager.java src/main/java/alice/datasegment/RemoteDataSegmentManager.java src/main/java/alice/topology/node/IncomingConnectionInfo.java src/main/java/alice/topology/node/IncomingReverseKey.java
diffstat 6 files changed, 3 insertions(+), 27 deletions(-) [+]
line wrap: on
line diff
--- 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;
     }
--- 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();
 
 }
--- 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() {
-
-    }
-
 }
--- 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();
-    }
-
 }
--- 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();
             }
 
         }
--- 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");