public class RpcSocketInputStream
extends java.io.InputStream
This class does the most basic conversion from incoming bytes on the (TCP/IP) wire to a Java IO input stream whose contents are further decoded upstream.
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
TRACE_PREFIX |
Constructor and Description |
---|
RpcSocketInputStream(java.net.Socket socket,
ServerStats stats)
Construct a suitable stream for the passed-in socket.
|
Modifier and Type | Method and Description |
---|---|
protected java.net.Socket |
getSocket() |
protected java.io.InputStream |
getSockStream() |
int |
read() |
int |
read(byte[] bytes) |
int |
read(byte[] bytes,
int offset,
int len) |
protected void |
setSocket(java.net.Socket socket) |
protected void |
setSockStream(java.io.InputStream sockStream) |
public static final java.lang.String TRACE_PREFIX
public RpcSocketInputStream(java.net.Socket socket, ServerStats stats)
socket
- non-null socketstats
- statspublic int read() throws java.io.IOException
read
in class java.io.InputStream
java.io.IOException
public int read(byte[] bytes) throws java.io.IOException
read
in class java.io.InputStream
java.io.IOException
public int read(byte[] bytes, int offset, int len) throws java.io.IOException
read
in class java.io.InputStream
java.io.IOException
protected java.net.Socket getSocket()
protected void setSocket(java.net.Socket socket)
protected java.io.InputStream getSockStream()
protected void setSockStream(java.io.InputStream sockStream)