Package io.netty.buffer

Examples of io.netty.buffer.ChannelBuffer.readable()

461
462
463
464
465
466
467
468
469
470
471
        // Otherwise, all messages are encrypted.
        ChannelBuffer msg = (ChannelBuffer) e.getMessage();
        PendingWrite pendingWrite;

        if (msg.readable()) {
            pendingWrite = new PendingWrite(evt.getFuture(), msg.toByteBuffer(msg.readerIndex(), msg.readableBytes()));
        } else {
            pendingWrite = new PendingWrite(evt.getFuture(), null);
        }
        synchronized (pendingUnencryptedWrites) {
View Full Code Here
195
196
197
198
199
200
201
202
203
204
205
            ctx.sendUpstream(e);
            return;
        }

        ChannelBuffer input = (ChannelBuffer) m;
        if (!input.readable()) {
            return;
        }

        if (cumulation == null) {
            // the cumulation buffer is not created yet so just pass the input to callDecode(...) method
View Full Code Here
202
203
204
205
206
207
208
209
210
211
212
        }

        if (cumulation == null) {
            // the cumulation buffer is not created yet so just pass the input to callDecode(...) method
            callDecode(ctx, e.getChannel(), input, e.getRemoteAddress());
            if (input.readable()) {
                // seems like there is something readable left in the input buffer. So create the cumulation buffer and copy the input into it
                ChannelBuffer cumulation = cumulation(ctx);
                cumulation.writeBytes(input);
            }
        } else {
View Full Code Here
209
210
211
212
213
214
215
216
217
218
219
                ChannelBuffer cumulation = cumulation(ctx);
                cumulation.writeBytes(input);
            }
        } else {
            ChannelBuffer cumulation = cumulation(ctx);
            if (cumulation.readable()) {
                cumulation.discardReadBytes();
                cumulation.writeBytes(input);
                callDecode(ctx, e.getChannel(), cumulation, e.getRemoteAddress());
            } else {
                callDecode(ctx, e.getChannel(), input, e.getRemoteAddress());
View Full Code Here
335
336
337
338
339
340
341
342
343
344
345
                return;
            } else {
                this.cumulation = null;
            }

            if (cumulation.readable()) {
                // Make sure all frames are read before notifying a closed channel.
                callDecode(ctx, ctx.getChannel(), cumulation, null);
            }

            // Call decodeLast() finally.  Please note that decodeLast() is
View Full Code Here
424
425
426
427
428
429
430
431
432
433
434
            ctx.sendUpstream(e);
            return;
        }

        ChannelBuffer input = (ChannelBuffer) m;
        if (!input.readable()) {
            return;
        }

        ChannelBuffer cumulation = cumulation(ctx);
        needsCleanup = true;
View Full Code Here
536
537
538
539
540
541
542
543
544
545
546
            ChannelBuffer cumulation = this.cumulation;
            this.cumulation = null;
            replayable.terminate();

            if (cumulation != null && cumulation.readable()) {
                // Make sure all data was read before notifying a closed channel.
                callDecode(ctx, e.getChannel(), cumulation, null);
            }

            // Call decodeLast() finally.  Please note that decodeLast() is
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
            if (request.isChunked()) {
                readingChunks = true;
            } else {
                ChannelBuffer content = request.getContent();
                if (content.readable()) {
                    buf.append("CONTENT: " + content.toString(CharsetUtil.UTF_8) + "\r\n");
                }
                writeResponse(e);
            }
        } else {
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
            if (response.isChunked()) {
                readingChunks = true;
                System.out.println("CHUNKED CONTENT {");
            } else {
                ChannelBuffer content = response.getContent();
                if (content.readable()) {
                    System.out.println("CONTENT {");
                    System.out.println(content.toString(CharsetUtil.UTF_8));
                    System.out.println("} END OF CONTENT");
                }
            }
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
            if (response.getStatus().getCode() == 200 && response.isChunked()) {
                readingChunks = true;
                System.out.println("CHUNKED CONTENT {");
            } else {
                ChannelBuffer content = response.getContent();
                if (content.readable()) {
                    System.out.println("CONTENT {");
                    System.out.println(content.toString(CharsetUtil.UTF_8));
                    System.out.println("} END OF CONTENT");
                }
            }
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.