Method Summary |
|
final public CloseFuture | close(boolean rightNow) |
final public CloseFuture | close() |
final public CloseFuture | closeOnFlush() |
final public boolean | containsAttribute(Object key) |
final protected void | decreaseReadBufferSize() |
final protected void | decreaseScheduledBytesAndMessages(WriteRequest request) |
final public boolean | equals(Object o) |
final public Object | getAttachment() |
final public Object | getAttribute(Object key) |
final public Object | getAttribute(Object key, Object defaultValue) |
final public Set<Object> | getAttributeKeys() |
final protected IoSessionAttributeMap | getAttributeMap() |
final public int | getBothIdleCount() |
final public CloseFuture | getCloseFuture() |
final public long | getCreationTime() |
final protected WriteRequest | getCurrentWriteRequest() |
final public long | getId() |
final public int | getIdleCount(IdleStatus status) |
final public long | getLastBothIdleTime() |
final public long | getLastIdleTime(IdleStatus status) |
final public long | getLastIoTime() |
final public long | getLastReadTime() |
final public long | getLastReaderIdleTime() |
final public long | getLastWriteTime() |
final public long | getLastWriterIdleTime() |
abstract protected IoProcessor | getProcessor() |
final public long | getReadBytes() |
final public double | getReadBytesThroughput() |
final public long | getReadMessages() |
final public double | getReadMessagesThroughput() |
final public int | getReaderIdleCount() |
final public long | getScheduledWriteBytes() |
final public int | getScheduledWriteMessages() |
public SocketAddress | getServiceAddress() |
final public TrafficMask | getTrafficMask() |
final protected WriteRequestQueue | getWriteRequestQueue() |
final public int | getWriterIdleCount() |
final public long | getWrittenBytes() |
final public double | getWrittenBytesThroughput() |
final public long | getWrittenMessages() |
final public double | getWrittenMessagesThroughput() |
final public int | hashCode() |
final protected void | increaseIdleCount(IdleStatus status, long currentTime) |
final protected void | increaseReadBufferSize() |
final protected void | increaseReadBytes(long increment, long currentTime) |
final protected void | increaseReadMessages(long currentTime) |
final protected void | increaseScheduledWriteBytes(long increment) |
final protected void | increaseScheduledWriteMessages() |
final protected void | increaseWrittenBytesAndMessages(WriteRequest request, long currentTime) |
final public boolean | isBothIdle() |
final public boolean | isClosing() |
final public boolean | isConnected() |
final public boolean | isIdle(IdleStatus status) |
final public boolean | isReaderIdle() |
final protected boolean | isScheduledForFlush() |
final public boolean | isWriterIdle() |
final protected void | offerClosedReadFuture() |
final protected void | offerFailedReadFuture(Throwable exception) |
final protected void | offerReadFuture(Object message) |
final public ReadFuture | read() |
final public Object | removeAttribute(Object key) |
final public boolean | removeAttribute(Object key, Object value) |
final public boolean | replaceAttribute(Object key, Object oldValue, Object newValue) |
final public void | resumeRead() |
final public void | resumeWrite() |
final public Object | setAttachment(Object attachment) |
final public Object | setAttribute(Object key, Object value) |
final public Object | setAttribute(Object key) |
final public Object | setAttributeIfAbsent(Object key, Object value) |
final public Object | setAttributeIfAbsent(Object key) |
final protected void | setAttributeMap(IoSessionAttributeMap attributes) |
final protected void | setCurrentWriteRequest(WriteRequest currentWriteRequest) |
final protected boolean | setScheduledForFlush(boolean flag) |
protected void | setScheduledWriteBytes(long byteCount) |
protected void | setScheduledWriteMessages(int messages) |
final public void | setTrafficMask(TrafficMask trafficMask) |
final protected void | setTrafficMaskNow(TrafficMask trafficMask) |
final protected void | setWriteRequestQueue(WriteRequestQueue writeRequestQueue) |
final public void | suspendRead() |
final public void | suspendWrite() |
public String | toString() |
final protected void | updateThroughput(long currentTime, boolean force) Update all statistical properties related with throughput assuming
the specified time is the current time. |
final public WriteFuture | write(Object message) |
final public WriteFuture | write(Object message, SocketAddress remoteAddress) |