Mercurial > hg > Members > tatsuki > Alice
diff src/main/java/alice/daemon/IncomingTcpConnection.java @ 363:3c9446fa4073 multicast
remove no need method
author | sugi |
---|---|
date | Fri, 16 May 2014 16:50:38 +0900 |
parents | 11ba40caa93b |
children | 8072df9130c6 |
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; - } }