Mercurial > hg > Database > Alice

changeset 509:53d7cff1fe10 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
register IncomingUDPConnection acceptHash
author sugi
date Thu, 08 Jan 2015 12:10:02 +0900
parents b7d02ea79850
children 118e150ac9f3
files src/main/java/alice/datasegment/MulticastDataSegmentManager.java
diffstat 1 files changed, 1 insertions(+), 0 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/alice/datasegment/MulticastDataSegmentManager.java	Sun Jan 04 13:51:01 2015 +0900
+++ b/src/main/java/alice/datasegment/MulticastDataSegmentManager.java	Thu Jan 08 12:10:02 2015 +0900
@@ -37,6 +37,7 @@
                 IncomingUdpConnection in = new IncomingUdpConnection((MulticastConnection) connection, receiver, this);
                 in.setName("multicast-IncomingUdp");
                 in.start();
+                DataSegment.setAccept(connectionKey, in);
             }
             if (type !=SocketType.Receiver) {
                 OutboundTcpConnection out = new OutboundTcpConnection(connection); // OutboundUdpConnection sender