List of bufferAvailable() Examples

Examples of bufferAvailable()

org.apache.flink.runtime.io.network.netty.InboundEnvelopeDecoder.bufferAvailable()
Notifies the IO thread that a Buffer has become available again.
This method will be called from outside the Netty IO thread. The caller will be the buffer pool from which the available buffer comes (i.e. the InputGate).
We have to make sure that the available buffer is handed over to the IO thread in a safe manner.

Examples of org.apache.flink.runtime.io.network.netty.InboundEnvelopeDecoder.bufferAvailable()

    Assert.assertFalse(ch.config().isAutoRead());


    // notify of available buffer (=> bufferAvailable() callback does return a buffer
    // of the current network buffer size; the decoder needs to adjust its size to the
    // requested size
    decoder.bufferAvailable(allocBuffer(envelopes[0].getBuffer().size() * 2));
    ch.runPendingTasks();


    Assert.assertEquals(refCount - 1, slices[0].refCnt());
    Assert.assertTrue(ch.config().isAutoRead());

View Full Code Here

Examples of org.apache.flink.runtime.io.network.netty.InboundEnvelopeDecoder.bufferAvailable()

    decodeAndVerify(ch, slices[1]);


    Assert.assertEquals(refCount + 1, slices[1].refCnt());
    Assert.assertFalse(ch.config().isAutoRead());


    decoder.bufferAvailable(allocBuffer());
    ch.runPendingTasks();


    Assert.assertEquals(refCount - 1, slices[1].refCnt());
    Assert.assertTrue(ch.config().isAutoRead());

View Full Code Here

Examples of org.apache.flink.runtime.io.network.netty.InboundEnvelopeDecoder.bufferAvailable()


        Assert.assertFalse(ch.config().isAutoRead());
        Assert.assertEquals(refCount + 1, slice.refCnt());


        // return a buffer of max size => decoder needs to limit buffer size
        decoder.bufferAvailable(allocBuffer(MAX_BUFFER_SIZE));
        ch.runPendingTasks();
      }


      Assert.assertEquals(refCount - 1, slice.refCnt());
      Assert.assertTrue(ch.config().isAutoRead());

View Full Code Here

TOP

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.