List of refCnt() Examples

Examples of refCnt()

Examples of io.netty.buffer.ByteBuf.refCnt()

    int refCount = buf.refCnt();


    decodeAndVerify(ch, buf);


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


    try {
      decodeAndVerify(ch, buf);
      Assert.fail("Expected IllegalStateException not thrown");
    } catch (IllegalStateException e) {

View Full Code Here

Examples of io.netty.buffer.ByteBuf.refCnt()

    // --------------------------------------------------------------------


    ByteBuf buf = encode(ch, envelopes);


    decodeAndVerify(ch, buf, envelopes);
    Assert.assertEquals(0, buf.refCnt());
  }


  @Test
  public void testBufferAvailabilityRegistrationBufferPoolDestroyedSkipBytes() throws Exception {
    final EmbeddedChannel ch = new EmbeddedChannel(

View Full Code Here

Examples of io.netty.buffer.ByteBuf.refCnt()

      decodeAndVerify(ch, slices[2], expectedEnvelopes);
      Assert.assertEquals(refCount - 1, slices[2].refCnt());
    }


    // ref count should be 1, because slices shared the ref count
    Assert.assertEquals(1, buf.refCnt());
  }


  @Test
  public void testEncodeDecode() throws Exception {
    final EmbeddedChannel ch = new EmbeddedChannel(

View Full Code Here

Examples of io.netty.buffer.ByteBuf.refCnt()


    // 1. complete ByteBuf as input
    int refCount = buf.retain().refCnt();


    decodeAndVerify(ch, buf, envelopes);
    Assert.assertEquals(refCount - 1, buf.refCnt());


    // 2. random slices
    buf.readerIndex(0);
    ByteBuf[] slices = randomSlices(buf);

View Full Code Here

Examples of io.netty.buffer.ByteBuf.refCnt()


    Envelope[] expected = randomBufferAvailabilityRegistrationAnswer.removeSkippedEnvelopes(envelopes);


    decodeAndVerify(ch, expected);


    Assert.assertEquals(1, buf.refCnt());


    buf.release();
  }


  // ========================================================================

View Full Code Here

Examples of io.netty.buffer.ByteBuf.refCnt()

            ArgumentCaptor<ByteBuf> argument = ArgumentCaptor.forClass(ByteBuf.class);
            captureWrite(STREAM_A, argument, 0, false);
            final ByteBuf writtenBuf = argument.getValue();
            assertEquals(5, writtenBuf.readableBytes());
            assertEquals(data.slice(0, 5), writtenBuf);
            assertEquals(2, writtenBuf.refCnt());
            assertEquals(2, data.refCnt());
        } finally {
            manualSafeRelease(data);
        }
    }

View Full Code Here

Examples of io.netty.buffer.ByteBuf.refCnt()


            ArgumentCaptor<ByteBuf> argument = ArgumentCaptor.forClass(ByteBuf.class);
            captureWrite(STREAM_A, argument, 0, false);
            ByteBuf writtenBuf = argument.getValue();
            assertEquals(5, writtenBuf.readableBytes());
            assertEquals(2, writtenBuf.refCnt());
            assertEquals(2, data.refCnt());
        } finally {
            manualSafeRelease(data);
        }
    }

View Full Code Here

Examples of io.netty.buffer.ByteBuf.refCnt()

    public void frameShouldBeSentImmediately() throws Http2Exception {
        final ByteBuf data = dummyData(5, 5);
        try {
            send(STREAM_A, data.slice(0, 5), 5);
            verifyWrite(STREAM_A, data.slice(0, 5), 5);
            assertEquals(1, data.refCnt());
        } finally {
            manualSafeRelease(data);
        }
    }

View Full Code Here

Examples of io.netty.buffer.ByteBuf.refCnt()


        final ByteBuf data = dummyData(10, 5);
        try {
            send(STREAM_A, data.slice(0, 10), 5);
            verifyNoWrite(STREAM_A);
            assertEquals(1, data.refCnt());
        } finally {
            manualSafeRelease(data);
        }
    }

View Full Code Here

Examples of io.netty.buffer.ByteBuf.refCnt()

            // None of the padding should be sent in the frame.
            captureWrite(STREAM_A, argument, 0, false);
            final ByteBuf writtenBuf = argument.getValue();
            assertEquals(5, writtenBuf.readableBytes());
            assertEquals(data.slice(0, 5), writtenBuf);
            assertEquals(2, writtenBuf.refCnt());
            assertEquals(2, data.refCnt());
        } finally {
            manualSafeRelease(data);
        }
    }

View Full Code Here

0 1 2 3 4 5

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.