bamboo.transport
Class TcpMessageTransport.ChannelState

java.lang.Object
  extended by bamboo.transport.TcpMessageTransport.ChannelState
All Implemented Interfaces:
ASyncCore.SelectableCB
Enclosing class:
TcpMessageTransport

public class TcpMessageTransport.ChannelState
extends Object
implements ASyncCore.SelectableCB


Field Summary
 int acks_to_send
           
 SocketChannel channel
           
 boolean client
           
 NioMultiplePacketInputBuffer ib
           
 LinkedList inflight
           
 int next_read_size
           
 SelectionKey skey
           
 LinkedList waiting
           
 ByteBuffer write_buf
           
 
Constructor Summary
TcpMessageTransport.ChannelState()
           
 
Method Summary
 void select_cb(SelectionKey skey, Object user_data)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

channel

public SocketChannel channel

write_buf

public ByteBuffer write_buf

waiting

public LinkedList waiting

inflight

public LinkedList inflight

acks_to_send

public int acks_to_send

ib

public NioMultiplePacketInputBuffer ib

next_read_size

public int next_read_size

client

public boolean client

skey

public SelectionKey skey
Constructor Detail

TcpMessageTransport.ChannelState

public TcpMessageTransport.ChannelState()
Method Detail

select_cb

public void select_cb(SelectionKey skey,
                      Object user_data)
Specified by:
select_cb in interface ASyncCore.SelectableCB