org.apache.cassandra.net.io
Class TcpReader
java.lang.Object
org.apache.cassandra.net.io.TcpReader
public class TcpReader
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TcpReader
public TcpReader(TcpConnection connection)
getSocketState
public StartState getSocketState(TcpReader.TcpReaderState state)
putSocketState
public void putSocketState(TcpReader.TcpReaderState state,
StartState socketState)
resetState
public void resetState()
morphState
public void morphState(StartState state)
getProtocolHeader
public ProtocolHeader getProtocolHeader()
getStream
public java.nio.channels.SocketChannel getStream()
read
public byte[] read()
throws java.io.IOException
- Throws:
java.io.IOException
main
public static void main(java.lang.String[] args)
throws java.lang.Throwable
- Throws:
java.lang.Throwable
Copyright © 2009 The Apache Software Foundation