Package io.netty.buffer

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

226
227
228
229
230
231
232
233
234
235
236
            ArgumentCaptor<ByteBuf> argument = ArgumentCaptor.forClass(ByteBuf.class);
            captureWrite(STREAM_A, argument, 2, false);
            final ByteBuf writtenBuf = argument.getValue();
            assertEquals(3, writtenBuf.readableBytes());
            assertEquals(data.slice(0, 3), writtenBuf);
            assertEquals(2, writtenBuf.refCnt());
            assertEquals(2, data.refCnt());
        } finally {
            manualSafeRelease(data);
        }
    }
View Full Code Here
246
247
248
249
250
251
252
253
254
255
256
            // Verify that a partial frame of 5 was sent.
            ArgumentCaptor<ByteBuf> argument = ArgumentCaptor.forClass(ByteBuf.class);
            captureWrite(STREAM_A, argument, 5, false);
            final ByteBuf writtenBuf = argument.getValue();
            assertEquals(0, writtenBuf.readableBytes());
            assertEquals(1, writtenBuf.refCnt());
            assertEquals(1, data.refCnt());
        } finally {
            manualSafeRelease(data);
        }
    }
View Full Code Here
385
386
387
388
389
390
391
392
393
394
395
            ArgumentCaptor<ByteBuf> argument = ArgumentCaptor.forClass(ByteBuf.class);
            captureWrite(STREAM_A, argument, 0, false);
            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
154
155
156
157
158
159
160
161
162
163
164
        final ByteBuf data = dummyData();
        try {
            ChannelFuture future = encoder.writeData(ctx, STREAM_ID, data, 0, false, promise);
            assertTrue(future.awaitUninterruptibly().cause() instanceof IllegalStateException);
        } finally {
            while (data.refCnt() > 0) {
                data.release();
            }
        }
    }
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
        final ByteBuf buf = ReferenceCountUtil.releaseLater(Unpooled.buffer().writeBytes(new byte[]{'a'}));
        EmbeddedChannel channel = new EmbeddedChannel(new ByteToMessageDecoder() {
            @Override
            protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
                ByteBuf byteBuf = internalBuffer();
                Assert.assertEquals(1, byteBuf.refCnt());
                in.readByte();
                // Removal from pipeline should clear internal buffer
                ctx.pipeline().remove(this);
                Assert.assertEquals(0, byteBuf.refCnt());
            }
View Full Code Here
90
91
92
93
94
95
96
97
98
99
100
                ByteBuf byteBuf = internalBuffer();
                Assert.assertEquals(1, byteBuf.refCnt());
                in.readByte();
                // Removal from pipeline should clear internal buffer
                ctx.pipeline().remove(this);
                Assert.assertEquals(0, byteBuf.refCnt());
            }
        });
        Assert.assertFalse(channel.writeInbound(buf));
        Assert.assertFalse(channel.finish());
    }
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
        final ByteBuf buf = ReferenceCountUtil.releaseLater(Unpooled.buffer().writeBytes(new byte[]{'a', 'b'}));
        EmbeddedChannel channel = new EmbeddedChannel(new ByteToMessageDecoder() {
            @Override
            protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
                ByteBuf byteBuf = internalBuffer();
                Assert.assertEquals(1, byteBuf.refCnt());
                in.readByte();
                // Removal from pipeline should clear internal buffer
                ctx.pipeline().remove(this);
                Assert.assertEquals(0, byteBuf.refCnt());
            }
View Full Code Here
502
503
504
505
506
507
508
509
510
511
512
        group.register(pipeline.channel());

        ChannelPromise promise = pipeline.channel().newPromise();
        assertTrue(promise.cancel(false));
        ByteBuf buffer = Unpooled.buffer();
        assertEquals(1, buffer.refCnt());
        ChannelFuture future = pipeline.write(buffer, promise);
        assertTrue(future.isCancelled());
        assertEquals(0, buffer.refCnt());
    }
View Full Code Here
505
506
507
508
509
510
511
512
513
514
515
        assertTrue(promise.cancel(false));
        ByteBuf buffer = Unpooled.buffer();
        assertEquals(1, buffer.refCnt());
        ChannelFuture future = pipeline.write(buffer, promise);
        assertTrue(future.isCancelled());
        assertEquals(0, buffer.refCnt());
    }

    @Test
    public void testCancelWriteAndFlush() throws Exception {
        ChannelPipeline pipeline = new LocalChannel().pipeline();
View Full Code Here
516
517
518
519
520
521
522
523
524
525
526
        group.register(pipeline.channel());

        ChannelPromise promise = pipeline.channel().newPromise();
        assertTrue(promise.cancel(false));
        ByteBuf buffer = Unpooled.buffer();
        assertEquals(1, buffer.refCnt());
        ChannelFuture future = pipeline.writeAndFlush(buffer, promise);
        assertTrue(future.isCancelled());
        assertEquals(0, buffer.refCnt());
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.