Constructor Detail

• NioReplicationTask

  public NioReplicationTask(ListenCallback callback,
                    NioReceiver receiver)

Method Detail

• run

  public void run()

• serviceChannel

  public void serviceChannel(java.nio.channels.SelectionKey key)

  Called to initiate a unit of work by this worker thread on the provided SelectionKey object. This method is synchronized, as is the run() method, so only one key can be serviced at a given time. Before waking the worker thread, and before returning to the main selection loop, this key's interest set is updated to remove OP_READ. This will cause the selector to ignore read-readiness for this channel while the worker thread is servicing it.

• drainChannel

  protected void drainChannel(java.nio.channels.SelectionKey key,
                  ObjectReader reader)
                       throws java.lang.Exception

  The actual code which drains the channel associated with the given key. This method assumes the key has been modified prior to invocation to turn off selection interest in OP_READ. When this method completes it re-enables OP_READ and calls wakeup() on the selector so the selector will resume watching this channel.

  Throws:

  java.lang.Exception

• registerForRead

  protected void registerForRead(java.nio.channels.SelectionKey key,
                     ObjectReader reader)

• sendAck

  protected void sendAck(java.nio.channels.SelectionKey key,
             java.nio.channels.WritableByteChannel channel,
             byte[] command,
             java.net.SocketAddress udpaddr)

  send a reply-acknowledgement (6,2,3), sends it doing a busy write, the ACK is so small that it should always go to the buffer

  Parameters:

  key -

  channel -

• setRxBufSize

  public void setRxBufSize(int rxBufSize)

• getRxBufSize

  public int getRxBufSize()