Top Inners Fields Constructors Methods
org.glassfish.grizzly.servlet

public Class ServletInputStreamImpl

extends ServletInputStream
Class Inheritance
Imports
java.io.IOException, org.glassfish.grizzly.ReadHandler, org.glassfish.grizzly.http.io.NIOInputStream, org.glassfish.grizzly.localization.LogMessages, jakarta.servlet.ReadListener, .ServletInputStream

Author
Jeanfrancois Arcand

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv class

Field Summary

Modifier and TypeField and Description
private boolean
private NIOInputStream
private static final ThreadLocal<Boolean>
private boolean
private ReadHandler
private final HttpServletRequestImpl

Constructor Summary

AccessConstructor and Description
protected

Method Summary

Modifier and TypeMethod and Description
public int
available()

Overrides java.io.InputStream.available.

Returns an estimate of the number of bytes that can be read (or skipped over) from this input stream without blocking, which may be 0, or 0 when end of stream is detected.

public void
close()

Overrides java.io.InputStream.close.

Implements java.io.Closeable.close.

Close the stream Since we re-cycle, we can't allow the call to super.close() which would permanently disable us.

public void
public boolean
isFinished()

Implements abstract jakarta.servlet.ServletInputStream.isFinished.

Returns true when all the data from the stream has been read else it returns false.

public boolean
isReady()

Implements abstract jakarta.servlet.ServletInputStream.isReady.

Returns true if it is allowable to call a read() method.

public void
mark(final int readlimit)

Overrides java.io.InputStream.mark.

Marks the current position in this input stream.

public boolean
markSupported()

Overrides java.io.InputStream.markSupported.

Tests if this input stream supports the mark and reset methods.

public int
read()

Implements abstract java.io.InputStream.read.

Reads the next byte of data from the input stream.

public int
read(final byte[] b)

Overrides java.io.InputStream.read.

Reads some number of bytes from the input stream and stores them into the buffer array b.

public int
read(final byte[] b, final int off, final int len)

Overrides java.io.InputStream.read.

Reads up to len bytes of data from the input stream into an array of bytes.

pack-priv void
public void
reset()

Overrides java.io.InputStream.reset.

Repositions this stream to the position at the time the mark method was last called on this input stream.

public void
setReadListener(final ReadListener readListener)

Implements abstract jakarta.servlet.ServletInputStream.setReadListener.

Instructs the ServletInputStream to invoke the provided ReadListener when it is possible to read

public long
skip(final long n)

Overrides java.io.InputStream.skip.

Skips over and discards n bytes of data from this input stream.

Inherited from jakarta.servlet.ServletInputStream:
readreadAllBytesreadLinereadNBytesreadNBytes

Field Detail

hasSetReadListenerback to summary
private boolean hasSetReadListener
inputStreamback to summary
private NIOInputStream inputStream
IS_READY_SCOPEback to summary
private static final ThreadLocal<Boolean> IS_READY_SCOPE
prevIsReadyback to summary
private boolean prevIsReady
readHandlerback to summary
private ReadHandler readHandler
servletRequestback to summary
private final HttpServletRequestImpl servletRequest

Constructor Detail

ServletInputStreamImplback to summary
protected ServletInputStreamImpl(final HttpServletRequestImpl servletRequest)

Method Detail

availableback to summary
public int available() throws IOException

Overrides java.io.InputStream.available.

Doc from java.io.InputStream.available.

Returns an estimate of the number of bytes that can be read (or skipped over) from this input stream without blocking, which may be 0, or 0 when end of stream is detected. The read might be on the same thread or another thread. A single read or skip of this many bytes will not block, but may read or skip fewer bytes.

Note that while some implementations of InputStream will return the total number of bytes in the stream, many will not. It is never correct to use the return value of this method to allocate a buffer intended to hold all data in this stream.

A subclass's implementation of this method may choose to throw an IOException if this input stream has been closed by invoking the close() method.

Annotations
@Override
Exceptions
IOException:
if an I/O error occurs.
closeback to summary
public void close() throws IOException

Overrides java.io.InputStream.close.

Implements java.io.Closeable.close.

Close the stream Since we re-cycle, we can't allow the call to super.close() which would permanently disable us.

Annotations
@Override
@SuppressWarnings:unchecked
Exceptions
IOException:

Doc from java.io.InputStream.close.

if an I/O error occurs.

initializeback to summary
public void initialize() throws IOException
isFinishedback to summary
public boolean isFinished()

Implements abstract jakarta.servlet.ServletInputStream.isFinished.

Doc from jakarta.servlet.ServletInputStream.isFinished.

Returns true when all the data from the stream has been read else it returns false.

Annotations
@Override
isReadyback to summary
public boolean isReady()

Implements abstract jakarta.servlet.ServletInputStream.isReady.

Doc from jakarta.servlet.ServletInputStream.isReady.

Returns true if it is allowable to call a read() method. In blocking mode, this method will always return true, but a subsequent call to a read() method may block awaiting data. In non-blocking mode this method may return false, in which case it is illegal to call a read() method and an IllegalStateException MUST be thrown. When ReadListener#onDataAvailable() is called, a call to this method that returned true is implicit.

If this method returns false and a ReadListener has been set via setReadListener(ReadListener), then the container will subsequently invoke ReadListener#onDataAvailable() (or ReadListener#onAllDataRead()) once data (or EOF) has become available. Other than the initial call, ReadListener#onDataAvailable() will only be called if and only if this method is called and returns false.

Annotations
@Override
markback to summary
public void mark(final int readlimit)

Overrides java.io.InputStream.mark.

Doc from java.io.InputStream.mark.

Marks the current position in this input stream. A subsequent call to the reset method repositions this stream at the last marked position so that subsequent reads re-read the same bytes.

The readlimit arguments tells this input stream to allow that many bytes to be read before the mark position gets invalidated.

The general contract of mark is that, if the method markSupported returns true, the stream somehow remembers all the bytes read after the call to mark and stands ready to supply those same bytes again if and whenever the method reset is called. However, the stream is not required to remember any data at all if more than readlimit bytes are read from the stream before reset is called.

Marking a closed stream should not have any effect on the stream.

Annotations
@Override
markSupportedback to summary
public boolean markSupported()

Overrides java.io.InputStream.markSupported.

Doc from java.io.InputStream.markSupported.

Tests if this input stream supports the mark and reset methods. Whether or not mark and reset are supported is an invariant property of a particular input stream instance.

Annotations
@Override
readback to summary
public int read() throws IOException

Implements abstract java.io.InputStream.read.

Doc from java.io.InputStream.read.

Reads the next byte of data from the input stream. The value byte is returned as an int in the range 0 to 255. If no byte is available because the end of the stream has been reached, the value -1 is returned. This method blocks until input data is available, the end of the stream is detected, or an exception is thrown.

Annotations
@Override
Exceptions
IOException:
if an I/O error occurs.
readback to summary
public int read(final byte[] b) throws IOException

Overrides java.io.InputStream.read.

Doc from java.io.InputStream.read.

Reads some number of bytes from the input stream and stores them into the buffer array b. The number of bytes actually read is returned as an integer. This method blocks until input data is available, end of file is detected, or an exception is thrown.

If the length of b is zero, then no bytes are read and 0 is returned; otherwise, there is an attempt to read at least one byte. If no byte is available because the stream is at the end of the file, the value -1 is returned; otherwise, at least one byte is read and stored into b.

The first byte read is stored into element b[0], the next one into b[1], and so on. The number of bytes read is, at most, equal to the length of b. Let k be the number of bytes actually read; these bytes will be stored in elements b[0] through b[k-1], leaving elements b[k] through b[b.length-1] unaffected.

Annotations
@Override
Exceptions
IOException:
If the first byte cannot be read for any reason other than the end of the file, if the input stream has been closed, or if some other I/O error occurs.
readback to summary
public int read(final byte[] b, final int off, final int len) throws IOException

Overrides java.io.InputStream.read.

Doc from java.io.InputStream.read.

Reads up to len bytes of data from the input stream into an array of bytes. An attempt is made to read as many as len bytes, but a smaller number may be read. The number of bytes actually read is returned as an integer.

This method blocks until input data is available, end of file is detected, or an exception is thrown.

If len is zero, then no bytes are read and 0 is returned; otherwise, there is an attempt to read at least one byte. If no byte is available because the stream is at end of file, the value -1 is returned; otherwise, at least one byte is read and stored into b.

The first byte read is stored into element b[off], the next one into b[off+1], and so on. The number of bytes read is, at most, equal to len. Let k be the number of bytes actually read; these bytes will be stored in elements b[off] through b[off+k-1], leaving elements b[off+k] through b[off+len-1] unaffected.

In every case, elements b[0] through b[off-1] and elements b[off+len] through b[b.length-1] are unaffected.

Annotations
@Override
Exceptions
IOException:
If the first byte cannot be read for any reason other than end of file, or if the input stream has been closed, or if some other I/O error occurs.
recycleback to summary
pack-priv void recycle()
resetback to summary
public void reset() throws IOException

Overrides java.io.InputStream.reset.

Doc from java.io.InputStream.reset.

Repositions this stream to the position at the time the mark method was last called on this input stream.

The general contract of reset is:

  • If the method markSupported returns true, then:
    • If the method mark has not been called since the stream was created, or the number of bytes read from the stream since mark was last called is larger than the argument to mark at that last call, then an IOException might be thrown.
    • If such an IOException is not thrown, then the stream is reset to a state such that all the bytes read since the most recent call to mark (or since the start of the file, if mark has not been called) will be resupplied to subsequent callers of the read method, followed by any bytes that otherwise would have been the next input data as of the time of the call to reset.
  • If the method markSupported returns false, then:
    • The call to reset may throw an IOException.
    • If an IOException is not thrown, then the stream is reset to a fixed state that depends on the particular type of the input stream and how it was created. The bytes that will be supplied to subsequent callers of the read method depend on the particular type of the input stream.
Annotations
@Override
Exceptions
IOException:
if this stream has not been marked or if the mark has been invalidated.
setReadListenerback to summary
public void setReadListener(final ReadListener readListener)

Implements abstract jakarta.servlet.ServletInputStream.setReadListener.

Doc from jakarta.servlet.ServletInputStream.setReadListener.

Instructs the ServletInputStream to invoke the provided ReadListener when it is possible to read

Annotations
@Override
skipback to summary
public long skip(final long n) throws IOException

Overrides java.io.InputStream.skip.

Doc from java.io.InputStream.skip.

Skips over and discards n bytes of data from this input stream. The skip method may, for a variety of reasons, end up skipping over some smaller number of bytes, possibly 0. This may result from any of a number of conditions; reaching end of file before n bytes have been skipped is only one possibility. The actual number of bytes skipped is returned. If n is negative, the skip method for class InputStream always returns 0, and no bytes are skipped. Subclasses may handle the negative value differently.

Annotations
@Override
Exceptions
IOException:
if an I/O error occurs.
org.glassfish.grizzly.servlet back to summary

pack-priv Class ServletInputStreamImpl.ReadHandlerImpl

extends Object
implements ReadHandler
Class Inheritance
  • java.lang.Object
  • org.glassfish.grizzly.servlet.ServletInputStreamImpl.ReadHandlerImpl
All Implemented Interfaces
org.glassfish.grizzly.ReadHandler

Field Summary

Modifier and TypeField and Description
private ReadListener

Constructor Summary

AccessConstructor and Description
private

Method Summary

Modifier and TypeMethod and Description
private void
private void
public void
onAllDataRead()

Implements org.glassfish.grizzly.ReadHandler.onAllDataRead.

Invoked when all data for the current request has been read.

public void
onDataAvailable()

Implements org.glassfish.grizzly.ReadHandler.onDataAvailable.

Invoked when data is available to be read without blocking.

public void
onError(final Throwable t)

Implements org.glassfish.grizzly.ReadHandler.onError.

Invoked when an error occurs processing the request asynchronously.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

readListenerback to summary
private ReadListener readListener

Constructor Detail

ReadHandlerImplback to summary
private ReadHandlerImpl(ReadListener listener)

Method Detail

invokeAllDataReadCallbackback to summary
private void invokeAllDataReadCallback()
invokeReadPossibleCallbackback to summary
private void invokeReadPossibleCallback()
onAllDataReadback to summary
public void onAllDataRead() throws Exception

Implements org.glassfish.grizzly.ReadHandler.onAllDataRead.

Doc from org.glassfish.grizzly.ReadHandler.onAllDataRead.

Invoked when all data for the current request has been read.

Annotations
@Override
Exceptions
Exception:
Exception might be thrown by the custom handler code. This exception will be delegated for processing to onError(java.lang.Throwable).
onDataAvailableback to summary
public void onDataAvailable() throws Exception

Implements org.glassfish.grizzly.ReadHandler.onDataAvailable.

Doc from org.glassfish.grizzly.ReadHandler.onDataAvailable.

Invoked when data is available to be read without blocking. Data must be consumed by the handler implementation before re-registering.

Annotations
@Override
Exceptions
Exception:
Exception might be thrown by the custom handler code. This exception will be delegated for processing to onError(java.lang.Throwable).
onErrorback to summary
public void onError(final Throwable t)

Implements org.glassfish.grizzly.ReadHandler.onError.

Doc from org.glassfish.grizzly.ReadHandler.onError.

Invoked when an error occurs processing the request asynchronously.

Annotations
@Override