Examples of org.glassfish.grizzly.Buffer.toByteBuffer()

org.glassfish.grizzly.Buffer.toByteBuffer()

Converts this Buffer to a {@link ByteBuffer}. If this Buffer is not composite - then returned {@link ByteBuffer}'s content is a shared subsequence of this buffer's content, with {@link CompositeBuffer} this is not guaranteed.The position of the returned {@link ByteBuffer} is not guaranteed to be 0,the capacity of the returned {@link ByteBuffer} is not guaranteed to beequal to the capacity of this Buffer. It is guaranteed that the result of the returned ByteBuffer's {@link ByteBuffer#remaining()} call will be equal to this Buffer's{@link #remaining()} call.The Buffer's and ByteBuffer's position, limit, and mark values are not guaranteed to be independent, so it's recommended to save and restore position, limit values if it is planned to change them or {@link ByteBuffer#slice()} the returned {@link ByteBuffer}.
@return this Buffer as a {@link ByteBuffer}.

                }
            }
        }
        
        final Buffer buffer = ctx.getMessage();
        final ByteBuffer byteBuffer = buffer.toByteBuffer();
                
        final SocketChannel channel = (SocketChannel) connection.getChannel();
        connector.process(byteBuffer, channel);


        return ctx.getStopAction();

View Full Code Here

                    final MemoryManager mm = ctx.getMemoryManager();
                    boolean last = false;
                    while (!last) {
                        Buffer buffer = mm.allocate(BodyHandler.MAX_CHUNK_SIZE);
                        buffer.allowBufferDispose(true);
                        final long readBytes = bodyLocal.read(buffer.toByteBuffer());
                        if (readBytes > 0) {
                            buffer.position((int) readBytes);
                            buffer.trim();
                        } else {
                            buffer.dispose();

View Full Code Here


        while (!last) {
            Buffer buffer = mm.allocate(MAX_CHUNK_SIZE);
            buffer.allowBufferDispose(true);


            final long readBytes = bodyLocal.read(buffer.toByteBuffer());
            if (readBytes > 0) {
                buffer.position((int) readBytes);
                buffer.trim();
            } else {
                buffer.dispose();

View Full Code Here


            Buffer buffer = message.getContent();
            message.recycle();
            final ReadHandler readHandler = tyrusConnection.getReadHandler();
            if (!buffer.isComposite()) {
                taskQueue.add(new ProcessTask(buffer.toByteBuffer(), readHandler));
            } else {
                final ByteBufferArray byteBufferArray = buffer.toByteBufferArray();
                final ByteBuffer[] array = byteBufferArray.getArray();


                for (int i = 0; i < byteBufferArray.size(); i++) {

View Full Code Here


            Buffer buffer = message.getContent();
            message.recycle();
            final ReadHandler readHandler = tyrusConnection.getReadHandler();
            if (!buffer.isComposite()) {
                taskQueue.add(new ProcessTask(buffer.toByteBuffer(), readHandler));
            } else {
                final ByteBufferArray byteBufferArray = buffer.toByteBufferArray();
                final ByteBuffer[] array = byteBufferArray.getArray();


                for (int i = 0; i < byteBufferArray.size(); i++) {

View Full Code Here

                }
            }
        }
        
        final Buffer buffer = ctx.getMessage();
        final ByteBuffer byteBuffer = buffer.toByteBuffer();
                
        final SocketChannel channel = (SocketChannel) connection.getChannel();
        connector.process(byteBuffer, channel);


        return ctx.getStopAction();

View Full Code Here

0 1 2

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.