@InterfaceAudience.LimitedPrivate(value="HDFS") @InterfaceStability.Unstable public class SocketInputWrapper extends FilterInputStream
SocketInputStream
implementation. Otherwise, timeouts are managed by
setting the underlying socket timeout itself.in
Modifier and Type | Method and Description |
---|---|
ReadableByteChannel |
getReadableByteChannel() |
void |
setTimeout(long timeoutMs)
Set the timeout for reads from this stream.
|
available, close, mark, markSupported, read, read, read, reset, skip
public void setTimeout(long timeoutMs) throws SocketException
SocketInputWrapper
instance per socket.timeoutMs
- the new timeout, 0 for no timeoutSocketException
- if the timeout cannot be setpublic ReadableByteChannel getReadableByteChannel()
IllegalStateException
- if this socket does not have a channelCopyright © 2013 Apache Software Foundation. All rights reserved.