pyrasun.eio.protocols.bytearray
Class EIOByteArrayEndpoint

java.lang.Object
  pyrasun.eio.Endpoint
      pyrasun.eio.ReadWriteEndpoint
          pyrasun.eio.protocols.bytearray.EIOByteArrayEndpoint

public class EIOByteArrayEndpoint

extends ReadWriteEndpoint

Central part of the ByteArray protocol, encapsulates non-blocking reading and writing.

Constructor Summary

EIOByteArrayEndpoint(EndpointCoordinator coordinator, java.nio.channels.SocketChannel nioChannel)

Method Summary

void	writeNext(byte[] nextVictim)

Methods inherited from class pyrasun.eio.ReadWriteEndpoint

abortWrites, addToProcessing, arePendingWrites, getInputBuffer, getNIOChannel, getOutputBuffer, getProcessingQueueDepth, getWriteQueueDepth, isWriteInProgress, isWriteQueueEmpty, needsReadPause, nextForProcessing, nextForWriting, noReadsForMe, noWritesForMe, processingDispatch, readPause, setIsWriteInProgress, write

Methods inherited from class pyrasun.eio.Endpoint

addInterest, addProcessing, attach, attachment, close, close, close, close, close, configureBlocking, dumpProcessedStats, getContext, getCoordinator, getInterestEvents, getNIOInterestEvents, getProcessingEvents, getReadyEvents, getState, isAborted, isBlocking, isLockedForProcessing, isLockedReady, isOpen, isReady, isSelectorized, lockForEventManager, lockForProcessing, lockForReady, masksAsString, registerEventListener, removeInterest, removeProcessing, removeReadiness, reportReadError, reportWriteError, setName, setReadiness, setReadiness, toString, unlockProcessing, updateProcessedStats

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

EIOByteArrayEndpoint

public EIOByteArrayEndpoint(EndpointCoordinator coordinator,
                            java.nio.channels.SocketChannel nioChannel)

Method Detail

writeNext

public void writeNext(byte[] nextVictim)
               throws java.io.IOException

Throws:

java.io.IOException