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}.

    /**
     * Writes next block of compressed data to the output stream.
     */
     protected Buffer deflate(Deflater deflater, MemoryManager memoryManager) {
        final Buffer buffer = memoryManager.allocate(bufferSize);
        final ByteBuffer byteBuffer = buffer.toByteBuffer();
        final byte[] array = byteBuffer.array();
        final int offset = byteBuffer.arrayOffset() + byteBuffer.position();


  int len = deflater.deflate(array, offset, bufferSize);
        if (len <= 0) {

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

        RexProRequest request = null;
        final byte messageVersion = sourceBuffer.get(0);
        try {
            switch (messageVersion) {
                case 1:
                    request = new RexProRequest(sourceBuffer.toByteBuffer(), sourceBufferLength, rexsterApplication);
                    break;
                default:
                    //unexpected rexpro version
                    logger.warn("unsupported rexpro version: " + messageVersion);
                    return ctx.getStopAction();

View Full Code Here


                ChannelBuffer frame;


                if (previousData.readable()) {
                    if (previousData instanceof DynamicChannelBuffer) {
                        previousData.writeBytes(grizzlyBuffer.toByteBuffer());
                        frame = previousData;
                    } else {
                        int size = previousData.readableBytes() + grizzlyBuffer.remaining();
                        frame = ChannelBuffers.dynamicBuffer(size > bufferSize ? size : bufferSize);
                        frame.writeBytes(previousData, previousData.readableBytes());

View Full Code Here

                        frame = previousData;
                    } else {
                        int size = previousData.readableBytes() + grizzlyBuffer.remaining();
                        frame = ChannelBuffers.dynamicBuffer(size > bufferSize ? size : bufferSize);
                        frame.writeBytes(previousData, previousData.readableBytes());
                        frame.writeBytes(grizzlyBuffer.toByteBuffer());
                    }
                } else {
                    frame = ChannelBuffers.wrappedBuffer(grizzlyBuffer.toByteBuffer());
                }

View Full Code Here

                        frame = ChannelBuffers.dynamicBuffer(size > bufferSize ? size : bufferSize);
                        frame.writeBytes(previousData, previousData.readableBytes());
                        frame.writeBytes(grizzlyBuffer.toByteBuffer());
                    }
                } else {
                    frame = ChannelBuffers.wrappedBuffer(grizzlyBuffer.toByteBuffer());
                }


                Object msg;
                int savedReadIndex;

View Full Code Here

        if (buffersSize == 0 || (position == limit)) {
            return Buffers.EMPTY_BYTE_BUFFER;
        } else if (buffersSize == 1) {
            final Buffer buffer = buffers[0];
            final int bufferPos = buffer.position();
            return buffer.toByteBuffer(bufferPos + position, bufferPos + limit);
        }


        checkIndex(position);
        final int pos1 = lastSegmentIndex;
        final int bufPosition = toActiveBufferPos(position);

View Full Code Here

        final int pos2 = lastSegmentIndex;
        final int bufLimit = toActiveBufferPos(limit);


        if (pos1 == pos2) {
            final Buffer buffer = buffers[pos1];
            return buffer.toByteBuffer(bufPosition, bufLimit);
        }


        final ByteBuffer resultByteBuffer = MemoryUtils.allocateByteBuffer(
                memoryManager, limit - position);

View Full Code Here

            // this is websocket with completed handshake
            if (message.getContent().hasRemaining()) {


                // get the frame(s) content
                Buffer buffer = message.getContent();
                final ByteBuffer webSocketBuffer = buffer.toByteBuffer();
                message.recycle();
                final ReadHandler readHandler = tyrusConnection.getReadHandler();


                taskQueue.add(new ProcessTask(webSocketBuffer, readHandler));

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

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.