Java 类org.jboss.netty.channel.WriteCompletionEvent 实例源码

项目：bigstreams 文件：ClientConnectionImpl.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception {
    // This method is called when the client has finished sending data
    // data is only ever sent if file lines were read and no
    // communication errors appeared.
    // setting the logDataSent flag will inform calling classes that
    // this instance actually did sent data.
    if (e.getWrittenAmount() > 0)
        clientHandlerContext.setLogDataSent(true);

    if (LOG.isDebugEnabled()) {
        LOG.info("waiting for server response: ("
                + e.getWrittenAmount() + ") bytes written");
    }

    super.writeComplete(ctx, e);
}

项目：fuck_zookeeper 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：https-github.com-apache-zookeeper 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：ZooKeeper 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：StreamProcessingInfrastructure 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：bigstreams 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：bigstreams 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：zookeeper-src-learning 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：zookeeper 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：SecureKeeper 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：SecureKeeper 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：bdclient 文件：TimeoutHandler.java

@Override
public void writeComplete(
        ChannelHandlerContext ctx, WriteCompletionEvent e) throws Exception
{
    startRead(ctx);
    ctx.sendUpstream(e);
}

项目：StreamBench 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：ACaZoo 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：AirSpeakerMobile 文件：RtspLoggingHandler.java

@Override
public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e)
        throws Exception {
    // TODO Auto-generated method stub
    super.writeComplete(ctx, e);
    LogManager.i("====================writeComplete");
}

项目：LoadBalanced_zk 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：LoadBalanced_zk 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：zookeeper-pkg 文件：NettyServerCnxnFactory.java

@Override
public void writeComplete(ChannelHandlerContext ctx,
        WriteCompletionEvent e) throws Exception
{
    if (LOG.isTraceEnabled()) {
        LOG.trace("write complete " + e);
    }
}

项目：httptunnel 文件：HttpTunnelLoadTest.java

@Override
public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e) throws Exception {
    super.writeComplete(ctx, e);

    sentData += e.getWrittenAmount();
    if (sentData >= expectedData)
        sentLatch.countDown();
}

项目：httptunnel 文件：HttpTunnelLoadTest.java

@Override
public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e) throws Exception {
    super.writeComplete(ctx, e);

    sentData += e.getWrittenAmount();
    if (sentData >= expectedData)
        sentLatch.countDown();
}

项目：bigstreams 文件：MetricChannel.java

@Override
public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e)
        throws Exception {
    kiloBytesWrittenPerSecond.incrementCounter(e.getWrittenAmount()/1024);
    super.writeComplete(ctx, e);
}

项目：fastcatsearch3 文件：ByteCounter.java

@Override
public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e)
        throws Exception {
    super.writeComplete(ctx, e);
    this.writtenBytes.addAndGet(e.getWrittenAmount());
}

项目：flazr 文件：ServerHandler.java

@Override
public void writeComplete(final ChannelHandlerContext ctx, final WriteCompletionEvent e) throws Exception {
    bytesWritten += e.getWrittenAmount();        
    super.writeComplete(ctx, e);
}

项目：netty-isdn-transport 文件：SimpleStateMachineHandler.java

/**
 * Invoked when something was written into a {@link Channel}.
 */
public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e) throws Exception {
    ctx.sendUpstream(e);
}

项目：fastcatsearch 文件：ByteCounter.java

@Override
public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e)
        throws Exception {
    super.writeComplete(ctx, e);
    this.writtenBytes.addAndGet(e.getWrittenAmount());
}

项目：httptunnel 文件：HttpTunnelClientChannelPollHandler.java

@Override
public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e) throws Exception {
    requestSizes.update(e.getWrittenAmount());

    super.writeComplete(ctx, e);
}

项目：httptunnel 文件：HttpTunnelClientChannelSendHandler.java

@Override
public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e) throws Exception {
    requestSizes.update(e.getWrittenAmount());

    super.writeComplete(ctx, e);
}

项目：httptunnel 文件：InterestOpsTest.java

@Override
public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e) {
    writtenLatch.countDown();
}

项目：httptunnel 文件：OpenCloseOutgoingChannelHandler.java

@Override
public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e) throws Exception {
    messageLatch.countDown();
}

项目：httptunnel 文件：ThroughputTest.java

@Override
public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e) {
    write += e.getWrittenAmount();
}

项目：netty-isdn-transport 文件：IStateMachineChannelHandler.java

/**
 * Invoked when something was written into a {@link Channel}.
 */
void writeComplete(ChannelHandlerContext context, WriteCompletionEvent event) throws Exception;