Mercurial > hg > Members > tatsuki > Alice
changeset 363:3c9446fa4073 multicast
remove no need method
author | sugi |
---|---|
date | Fri, 16 May 2014 16:50:38 +0900 |
parents | 5b706d682cba |
children | 1494d44392a2 |
files | src/main/java/alice/daemon/IncomingTcpConnection.java |
diffstat | 1 files changed, 7 insertions(+), 11 deletions(-) [+] |
line wrap: on
line diff
--- a/src/main/java/alice/daemon/IncomingTcpConnection.java Fri May 16 16:47:18 2014 +0900 +++ b/src/main/java/alice/daemon/IncomingTcpConnection.java Fri May 16 16:50:38 2014 +0900 @@ -21,7 +21,7 @@ public Connection connection; public DataSegmentManager manager; public String reverseKey; - private LocalDataSegmentManager lmanager = DataSegment.getLocal(); + protected LocalDataSegmentManager lmanager = DataSegment.getLocal(); public IncomingTcpConnection(Connection connection, DataSegmentManager manager, String reverseKey) { this.manager = manager; @@ -33,7 +33,12 @@ * pipeline thread for receiving */ public void run() { - Unpacker unpacker = this.getUnpacker(); + Unpacker unpacker = null; + try { + unpacker = SingletonMessage.getInstance().createUnpacker(connection.socket.getInputStream()); + } catch (IOException e) { + e.printStackTrace(); + } if (unpacker == null) { return; } @@ -89,13 +94,4 @@ } } - private Unpacker getUnpacker() { - Unpacker unpacker = null; - try { - unpacker = SingletonMessage.getInstance().createUnpacker(connection.socket.getInputStream()); - } catch (IOException e2) { - e2.printStackTrace(); - } - return unpacker; - } }