java类org.jboss.netty.channel.WriteCompletionEvent的实例源码-面圈网

ClientConnectionImpl.java 文件源码项目：bigstreams 阅读 42 收藏 0 点赞 0 评论 0

@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);
}

NettyServerCnxnFactory.java 文件源码项目：fuck_zookeeper 阅读 46 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：https-github.com-apache-zookeeper 阅读 41 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：ZooKeeper 阅读 32 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：StreamProcessingInfrastructure 阅读 28 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：bigstreams 阅读 26 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：bigstreams 阅读 44 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：zookeeper-src-learning 阅读 44 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：zookeeper 阅读 30 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：SecureKeeper 阅读 29 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：SecureKeeper 阅读 38 收藏 0 点赞 0 评论 0

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

TimeoutHandler.java 文件源码项目：bdclient 阅读 31 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：StreamBench 阅读 31 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：ACaZoo 阅读 30 收藏 0 点赞 0 评论 0

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

RtspLoggingHandler.java 文件源码项目：AirSpeakerMobile 阅读 33 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：LoadBalanced_zk 阅读 28 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：LoadBalanced_zk 阅读 37 收藏 0 点赞 0 评论 0

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

NettyServerCnxnFactory.java 文件源码项目：zookeeper-pkg 阅读 30 收藏 0 点赞 0 评论 0

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

HttpTunnelLoadTest.java 文件源码项目：httptunnel 阅读 31 收藏 0 点赞 0 评论 0

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

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

HttpTunnelLoadTest.java 文件源码项目：httptunnel 阅读 42 收藏 0 点赞 0 评论 0

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

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

MetricChannel.java 文件源码项目：bigstreams 阅读 34 收藏 0 点赞 0 评论 0

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

ByteCounter.java 文件源码项目：fastcatsearch3 阅读 30 收藏 0 点赞 0 评论 0

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

ServerHandler.java 文件源码项目：flazr 阅读 31 收藏 0 点赞 0 评论 0

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

SimpleStateMachineHandler.java 文件源码项目：netty-isdn-transport 阅读 27 收藏 0 点赞 0 评论 0

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

ByteCounter.java 文件源码项目：fastcatsearch 阅读 35 收藏 0 点赞 0 评论 0

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

HttpTunnelClientChannelPollHandler.java 文件源码项目：httptunnel 阅读 44 收藏 0 点赞 0 评论 0

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

    super.writeComplete(ctx, e);
}

HttpTunnelClientChannelSendHandler.java 文件源码项目：httptunnel 阅读 33 收藏 0 点赞 0 评论 0

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

    super.writeComplete(ctx, e);
}

InterestOpsTest.java 文件源码项目：httptunnel 阅读 33 收藏 0 点赞 0 评论 0

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

OpenCloseOutgoingChannelHandler.java 文件源码项目：httptunnel 阅读 35 收藏 0 点赞 0 评论 0

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

ThroughputTest.java 文件源码项目：httptunnel 阅读 30 收藏 0 点赞 0 评论 0

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