Class PrependableSocket
java.lang.Object
java.net.Socket
org.apache.zookeeper.server.quorum.PrependableSocket
- All Implemented Interfaces:
Closeable
,AutoCloseable
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
prependToInputStream
(byte[] bytes, int offset, int length) Prepend some bytes that have already been read back to the socket's input stream.Methods inherited from class java.net.Socket
bind, close, connect, connect, getChannel, getInetAddress, getKeepAlive, getLocalAddress, getLocalPort, getLocalSocketAddress, getOOBInline, getOutputStream, getPort, getReceiveBufferSize, getRemoteSocketAddress, getReuseAddress, getSendBufferSize, getSoLinger, getSoTimeout, getTcpNoDelay, getTrafficClass, isBound, isClosed, isConnected, isInputShutdown, isOutputShutdown, sendUrgentData, setKeepAlive, setOOBInline, setPerformancePreferences, setReceiveBufferSize, setReuseAddress, setSendBufferSize, setSocketImplFactory, setSoLinger, setSoTimeout, setTcpNoDelay, setTrafficClass, shutdownInput, shutdownOutput, toString
-
Constructor Details
-
PrependableSocket
- Throws:
IOException
-
-
Method Details
-
getInputStream
- Overrides:
getInputStream
in classSocket
- Throws:
IOException
-
prependToInputStream
Prepend some bytes that have already been read back to the socket's input stream. Note that this method can be called at most once with a non-0 length per socket instance.- Parameters:
bytes
- the bytes to prepend.offset
- offset in the byte array to start at.length
- number of bytes to prepend.- Throws:
IOException
- if this method was already called on the socket instance, or if super.getInputStream() throws.
-