|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.caucho.vfs.StreamImpl
com.caucho.vfs.SocketChannelStream
@Module public class SocketChannelStream
Specialized stream to handle sockets.
Unlike VfsStream, when the read() throws and IOException or a SocketException, SocketStream will throw a ClientDisconnectException.
Field Summary |
---|
Fields inherited from class com.caucho.vfs.StreamImpl |
---|
_nullPath, _path |
Constructor Summary | |
---|---|
SocketChannelStream()
|
|
SocketChannelStream(java.nio.channels.SocketChannel channel)
|
Method Summary | |
---|---|
boolean |
canRead()
Returns true since the socket stream can be read. |
void |
close()
Closes the underlying sockets and socket streams. |
int |
getAvailable()
Returns the number of bytes available to be read from the input stream. |
byte[] |
getNewline()
Returns the stream's natural newline character. |
boolean |
getThrowReadInterrupts()
If true, throws read interrupts instead of returning an end of fail. |
boolean |
hasSkip()
Returns true if stream is readable and bytes can be skipped. |
void |
init(java.nio.channels.SocketChannel channel)
Initialize the SocketStream with a new Socket. |
int |
read(byte[] buf,
int offset,
int length)
Reads bytes from the socket. |
void |
setNewline(byte[] newline)
|
void |
setThrowReadInterrupts(boolean allowThrow)
If true, throws read interrupts instead of returning an end of fail. |
java.lang.String |
toString()
|
Methods inherited from class com.caucho.vfs.StreamImpl |
---|
canWrite, clearWrite, closeWrite, flush, flushBuffer, flushToDisk, getAttribute, getAttributeNames, getFlushOnNewline, getPath, getReadBuffer, getReadPosition, isClosed, isEof, isMmapEnabled, isSendfileEnabled, readNonBlock, readTimeout, removeAttribute, seekEnd, seekStart, setAttribute, setPath, setWriteEncoding, skip, write, write, writeMmap, writeSendfile |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public SocketChannelStream()
public SocketChannelStream(java.nio.channels.SocketChannel channel)
Method Detail |
---|
public void init(java.nio.channels.SocketChannel channel)
s
- the new socket.public void setThrowReadInterrupts(boolean allowThrow)
public boolean getThrowReadInterrupts()
public void setNewline(byte[] newline)
public byte[] getNewline()
StreamImpl
getNewline
in class StreamImpl
public boolean hasSkip()
hasSkip
in class StreamImpl
public boolean canRead()
canRead
in class StreamImpl
public int read(byte[] buf, int offset, int length) throws java.io.IOException
read
in class StreamImpl
buf
- byte buffer receiving the bytesoffset
- offset into the bufferlength
- number of bytes to read
throws
- ClientDisconnectException if the connection is dropped
java.io.IOException
public int getAvailable() throws java.io.IOException
getAvailable
in class StreamImpl
java.io.IOException
public void close() throws java.io.IOException
close
in class StreamImpl
java.io.IOException
public java.lang.String toString()
toString
in class java.lang.Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |