Package org.glassfish.grizzly.http.io

Class OutputBuffer

  • Direct Known Subclasses:
    ServerOutputBuffer
    public class OutputBuffer
extends java.lang.Object
    Abstraction exposing both byte and character methods to write content to the HTTP messaging system in Grizzly.

    • Field Detail

      • LOGGER

        protected static final java.util.logging.Logger LOGGER

      • sendfileEnabled

        protected boolean sendfileEnabled

    • Constructor Detail

      • OutputBuffer

        public OutputBuffer()

    • Method Detail

      • isAsyncEnabled

        @Deprecated
public boolean isAsyncEnabled()
        Deprecated.
        will always return true

        Returns true if content will be written in a non-blocking fashion, otherwise returns false.

        Returns:
        true if content will be written in a non-blocking fashion, otherwise returns false.
        Since:
        2.1.2

      • setAsyncEnabled

        @Deprecated
public void setAsyncEnabled​(boolean asyncEnabled)
        Deprecated.
        Sets the asynchronous processing state of this OutputBuffer.
        Parameters:
        asyncEnabled - true if this OutputBuffer will write content without blocking. @since 2.1.2 @deprecated OutputBuffer always supports async mode

      • prepareCharacterEncoder

        public void prepareCharacterEncoder()

      • getBufferSize

        public int getBufferSize()

      • setBufferSize

        public void setBufferSize​(int bufferSize)

      • reset

        public void reset()
        Reset current response.
        Throws:
        java.lang.IllegalStateException - if the response has already been committed

      • isClosed

        public boolean isClosed()
        Returns:
        true if this OutputBuffer is closed, otherwise returns false.

      • getBufferedDataSize

        public int getBufferedDataSize()
        Get the number of bytes buffered on OutputBuffer and ready to be sent.
        Returns:
        the number of bytes buffered on OutputBuffer and ready to be sent.

      • recycle

        public void recycle()
        Recycle the output buffer. This should be called when closing the connection.

      • endRequest

        public void endRequest()
                throws java.io.IOException
        Throws:
        java.io.IOException

      • acknowledge

        public void acknowledge()
                 throws java.io.IOException
        Acknowledge a HTTP Expect header. The response status code and reason phrase should be set before invoking this method.
        Throws:
        java.io.IOException - if an error occurs writing the acknowledgment.

      • writeChar

        public void writeChar​(int c)
               throws java.io.IOException
        Throws:
        java.io.IOException

      • write

        public void write​(char[] cbuf,
                  int off,
                  int len)
           throws java.io.IOException
        Throws:
        java.io.IOException

      • write

        public void write​(char[] cbuf)
           throws java.io.IOException
        Throws:
        java.io.IOException

      • write

        public void write​(java.lang.String str)
           throws java.io.IOException
        Throws:
        java.io.IOException

      • write

        public void write​(java.lang.String str,
                  int off,
                  int len)
           throws java.io.IOException
        Throws:
        java.io.IOException

      • writeByte

        public void writeByte​(int b)
               throws java.io.IOException
        Throws:
        java.io.IOException

      • write

        public void write​(byte[] b)
           throws java.io.IOException
        Throws:
        java.io.IOException

      • sendfile

        public void sendfile​(java.io.File file,
                     long offset,
                     long length,
                     CompletionHandler<WriteResult> handler)

        Will use FileChannel.transferTo(long, long, java.nio.channels.WritableByteChannel) to send file to the remote endpoint. Note that all headers necessary for the file transfer must be set prior to invoking this method as this will case the HTTP header to be flushed to the client prior to sending the file content. This should also be the last call to write any content to the remote endpoint.

        It's required that the response be suspended when using this functionality. It will be assumed that if the response wasn't suspended when this method is called, that it's desired that this method manages the suspend/resume cycle.

        Parameters:
        file - the File to transfer.
        offset - the starting offset within the File
        length - the total number of bytes to transfer
        handler - CompletionHandler that will be notified of the transfer progress/completion or failure.
        Throws:
        java.lang.IllegalArgumentException - if the response has already been committed at the time this method was invoked.
        java.lang.IllegalStateException - if a file transfer request has already been made or if send file support isn't available.
        java.lang.IllegalStateException - if the response was in a suspended state when this method was invoked, but no CompletionHandler was provided.
        Since:
        2.2

      • write

        public void write​(byte[] b,
                  int off,
                  int len)
           throws java.io.IOException
        Throws:
        java.io.IOException

      • close

        public void close()
           throws java.io.IOException
        Throws:
        java.io.IOException

      • flush

        public void flush()
           throws java.io.IOException
        Flush the response.
        Throws:
        java.io.IOException - an underlying I/O error occurred

      • writeByteBuffer

        public void writeByteBuffer​(java.nio.ByteBuffer byteBuffer)
                     throws java.io.IOException

        Writes the contents of the specified ByteBuffer to the client.

        Note, that passed ByteBuffer will be directly used by underlying connection, so it could be reused only if it has been flushed.
        Parameters:
        byteBuffer - the ByteBuffer to write
        Throws:
        java.io.IOException - if an error occurs during the write

      • writeBuffer

        public void writeBuffer​(Buffer buffer)
                 throws java.io.IOException

        Writes the contents of the specified Buffer to the client.

        Note, that passed Buffer will be directly used by underlying connection, so it could be reused only if it has been flushed.
        Parameters:
        buffer - the Buffer to write
        Throws:
        java.io.IOException - if an error occurs during the write

      • canWriteChar

        @Deprecated
public boolean canWriteChar​(int length)
        Deprecated.

      • notifyCanWrite

        public void notifyCanWrite​(WriteHandler handler)

      • setTrailers

        public void setTrailers​(java.util.function.Supplier<java.util.Map<java.lang.String,​java.lang.String>> trailersSupplier)

      • getTrailers

        public java.util.function.Supplier<java.util.Map<java.lang.String,​java.lang.String>> getTrailers()

      • getThreadPool

        protected java.util.concurrent.Executor getThreadPool()
        Returns:
        Executor, which will be used for notifying user registered WriteHandler.