Modifier and Type | Class and Description |
---|---|
pack-priv static class | Request.ReadStream
Implements blocking reading semantics on top of a non-blocking channel |
pack-priv static class |
Modifier and Type | Field and Description |
---|---|
pack-priv char[] | |
pack-priv static final int | |
private SocketChannel | |
pack-priv static final byte | |
pack-priv Headers | |
private InputStream | |
pack-priv static final byte | |
pack-priv StringBuffer | |
private OutputStream | |
pack-priv int | |
private String |
Access | Constructor and Description |
---|---|
pack-priv |
Modifier and Type | Method and Description |
---|---|
private void | |
pack-priv Headers | |
public InputStream | |
public OutputStream | |
public String | |
public String |
buf | back to summary |
---|---|
pack-priv char[] buf |
BUF_LEN | back to summary |
---|---|
pack-priv static final int BUF_LEN |
chan | back to summary |
---|---|
private SocketChannel chan |
CR | back to summary |
---|---|
pack-priv static final byte CR |
hdrs | back to summary |
---|---|
pack-priv Headers hdrs |
is | back to summary |
---|---|
private InputStream is |
LF | back to summary |
---|---|
pack-priv static final byte LF |
lineBuf | back to summary |
---|---|
pack-priv StringBuffer lineBuf |
os | back to summary |
---|---|
private OutputStream os |
pos | back to summary |
---|---|
pack-priv int pos |
startLine | back to summary |
---|---|
private String startLine |
Request | back to summary |
---|---|
pack-priv Request(InputStream rawInputStream, OutputStream rawout) throws IOException |
consume | back to summary |
---|---|
private void consume(int c) |
headers | back to summary |
---|---|
pack-priv Headers headers() throws IOException
|
inputStream | back to summary |
---|---|
public InputStream inputStream() |
outputStream | back to summary |
---|---|
public OutputStream outputStream() |
readLine | back to summary |
---|---|
public String readLine() throws IOException read a line from the stream returning as a String. Not used for reading headers. |
requestLine | back to summary |
---|---|
public String requestLine() returns the request line (first line of a request) |
Modifier and Type | Field and Description |
---|---|
pack-priv static final int | |
pack-priv ByteBuffer | |
pack-priv SocketChannel | |
private boolean | |
private boolean | |
pack-priv ByteBuffer | |
pack-priv boolean | |
pack-priv byte[] | |
pack-priv int | |
pack-priv static long | |
pack-priv boolean | |
pack-priv ServerImpl |
Access | Constructor and Description |
---|---|
public |
Modifier and Type | Method and Description |
---|---|
public synchronized int | available()
Overrides java. |
public void | close()
Overrides java. Implements java. |
public synchronized void | mark(int
the maximum limit of bytes that can be read before
the mark position becomes invalid. readlimit)Overrides java. |
public boolean | markSupported()
Overrides java. mark and
reset methods.
|
public synchronized int | read(byte[]
the buffer into which the data is read. b)Overrides java. b .
|
public synchronized int | read()
Implements abstract java. |
public synchronized int | read(byte[]
the buffer into which the data is read. b, int the start offset in array off, int b
at which the data is written.the maximum number of bytes to read. srclen)Overrides java. len bytes of data from the input stream into
an array of bytes.
|
public synchronized void | reset()
Overrides java. mark method was last called on this input stream.
|
BUFSIZE | back to summary |
---|---|
pack-priv static final int BUFSIZE |
chanbuf | back to summary |
---|---|
pack-priv ByteBuffer chanbuf |
channel | back to summary |
---|---|
pack-priv SocketChannel channel |
closed | back to summary |
---|---|
private boolean closed |
eof | back to summary |
---|---|
private boolean eof |
markBuf | back to summary |
---|---|
pack-priv ByteBuffer markBuf |
marked | back to summary |
---|---|
pack-priv boolean marked |
one | back to summary |
---|---|
pack-priv byte[] one |
readlimit | back to summary |
---|---|
pack-priv int readlimit |
readTimeout | back to summary |
---|---|
pack-priv static long readTimeout |
reset | back to summary |
---|---|
pack-priv boolean reset |
server | back to summary |
---|---|
pack-priv ServerImpl server |
ReadStream | back to summary |
---|---|
public ReadStream(ServerImpl server, SocketChannel chan) throws IOException |
available | back to summary |
---|---|
public synchronized int available() throws IOException Overrides java. Doc from java. 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 A subclass's implementation of this method may choose to throw an
|
close | back to summary |
---|---|
public void close() throws IOException Overrides java. Implements java. Doc from java. Closes this input stream and releases any system resources associated with the stream.
|
mark | back to summary |
---|---|
public synchronized void mark(int readlimit) Overrides java. Doc from java. Marks the current position in this input stream. A subsequent call to
the The The general contract of Marking a closed stream should not have any effect on the stream.
|
markSupported | back to summary |
---|---|
public boolean markSupported() Overrides java. Doc from java. Tests if this input stream supports the
|
read | back to summary |
---|---|
public synchronized int read(byte[] b) throws IOException Overrides java. Doc from java. Reads some number of bytes from the input stream and stores them into
the buffer array If the length of The first byte read is stored into element
|
read | back to summary |
---|---|
public synchronized int read() throws IOException Implements abstract java. Doc from java. Reads the next byte of data from the input stream. The value byte is
returned as an
|
read | back to summary |
---|---|
public synchronized int read(byte[] b, int off, int srclen) throws IOException Overrides java. Doc from java. Reads up to This method blocks until input data is available, end of file is detected, or an exception is thrown. If The first byte read is stored into element In every case, elements
|
reset | back to summary |
---|---|
public synchronized void reset() throws IOException Overrides java. Doc from java. Repositions this stream to the position at the time the
The general contract of
|
Modifier and Type | Field and Description |
---|---|
pack-priv ByteBuffer | |
pack-priv SocketChannel | |
pack-priv boolean | |
pack-priv SelectionKey | |
pack-priv byte[] | |
pack-priv ServerImpl |
Access | Constructor and Description |
---|---|
public |
Modifier and Type | Method and Description |
---|---|
public void | close()
Overrides java. Implements java. |
public synchronized void | write(int
the b)byte .Implements abstract java. |
public synchronized void | write(byte[]
the data. b)Overrides java. b.length bytes from the specified byte array
to this output stream.
|
public synchronized void | write(byte[]
the data. b, int the start offset in the data. off, int the number of bytes to write. len)Overrides java. len bytes from the specified byte array
starting at offset off to this output stream.
|
buf | back to summary |
---|---|
pack-priv ByteBuffer buf |
channel | back to summary |
---|---|
pack-priv SocketChannel channel |
closed | back to summary |
---|---|
pack-priv boolean closed |
key | back to summary |
---|---|
pack-priv SelectionKey key |
one | back to summary |
---|---|
pack-priv byte[] one |
server | back to summary |
---|---|
pack-priv ServerImpl server |
WriteStream | back to summary |
---|---|
public WriteStream(ServerImpl server, SocketChannel channel) throws IOException |
close | back to summary |
---|---|
public void close() throws IOException Overrides java. Implements java. Doc from java. Closes this output stream and releases any system resources
associated with this stream. The general contract of
|
write | back to summary |
---|---|
public synchronized void write(int b) throws IOException Implements abstract java. Doc from java. Writes the specified byte to this output stream. The general
contract for
|
write | back to summary |
---|---|
public synchronized void write(byte[] b) throws IOException Overrides java. Doc from java. Writes
|
write | back to summary |
---|---|
public synchronized void write(byte[] b, int off, int len) throws IOException Overrides java. Doc from java. Writes
If
If
|