Package org.jboss.netty.channel.group

Examples of org.jboss.netty.channel.group.DefaultChannelGroupFuture

80
81
82
83
84
85
86
87
88
89
90
                // First time close() is called.
                return super.close();
            } else {
                Collection<ChannelFuture> futures = new ArrayList<ChannelFuture>();
                logger.debug("CleanupChannelGroup Already closed");
                return new DefaultChannelGroupFuture(ChannelGroup.class.cast(this), futures);
            }
        } finally {
            this.lock.writeLock().unlock();
        }
    }
View Full Code Here
191
192
193
194
195
196
197
198
199
200
201
202
            log.trace("{} send {} to {}", this, buffer.capacity(), peerCount);
            List<ChannelFuture> futures = new ArrayList<>(peerCount);
            for (Channel c : channels) {
                futures.add(c.write(buffer.duplicate()));
            }
            ChannelGroupFuture future = new DefaultChannelGroupFuture(DummyChannelGroup.DUMMY, futures);
            future.addListener(new ChannelGroupFutureListener() {
                @Override
                public void operationComplete(ChannelGroupFuture future) throws Exception {
                    master.sentBytes(reportBytes * peerCount);
                    ChannelState.returnSendBuffer(buffer);
                    if (watcher != null) {
View Full Code Here
191
192
193
194
195
196
197
198
199
200
201
202
            log.trace("{} send {} to {}", this, buffer.capacity(), peerCount);
            List<ChannelFuture> futures = new ArrayList<>(peerCount);
            for (Channel c : channels) {
                futures.add(c.write(buffer.duplicate()));
            }
            ChannelGroupFuture future = new DefaultChannelGroupFuture(DummyChannelGroup.DUMMY, futures);
            future.addListener(new ChannelGroupFutureListener() {
                @Override
                public void operationComplete(ChannelGroupFuture future) throws Exception {
                    master.sentBytes(reportBytes * peerCount);
                    ChannelState.returnSendBuffer(buffer);
                    if (watcher != null) {
View Full Code Here
TOP

Related Classes of org.jboss.netty.channel.group.DefaultChannelGroupFuture

  • com.addthis.meshy.SourceHandler
  • com.ning.http.util.CleanupChannelGroup
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.