Mercurial > hg > Database > Alice
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");