org.spf4j.io.tcp.proxy

Class ProxyBufferTransferHandler

java.lang.Object

org.spf4j.io.tcp.SelectorEventHandler

org.spf4j.io.tcp.proxy.ProxyBufferTransferHandler

@ParametersAreNonnullByDefault
public final class ProxyBufferTransferHandler
extends SelectorEventHandler

Author:

zoly

Constructor Summary

Constructors

Constructor and Description
ProxyBufferTransferHandler(TransferBuffer in, TransferBuffer out, SnifferFactory snifferFactory, SocketChannel channel, Selector selector, ExecutorService exec, BlockingQueue<Runnable> tasksToRunBySelector, UpdateablePriorityQueue.ElementRef deadlineActionRef)

Method Summary

Modifier and Type	Method and Description
boolean	canRunAsync()
SelectionKey	initialInterestRegistration() Method must be invoked in selector thread.
void	run(SelectionKey skey)
void	runAsync(SelectionKey sKey)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ProxyBufferTransferHandler

public ProxyBufferTransferHandler(TransferBuffer in,
                                  TransferBuffer out,
                                  @Nullable
                                  SnifferFactory snifferFactory,
                                  SocketChannel channel,
                                  Selector selector,
                                  ExecutorService exec,
                                  BlockingQueue<Runnable> tasksToRunBySelector,
                                  UpdateablePriorityQueue.ElementRef deadlineActionRef)

Method Detail

initialInterestRegistration

public SelectionKey initialInterestRegistration()
                                         throws ClosedChannelException

Description copied from class: SelectorEventHandler

Method must be invoked in selector thread. THis will register this handler to Selector + channel.

Specified by:

initialInterestRegistration in class SelectorEventHandler

Returns:

Throws:

ClosedChannelException

canRunAsync

public boolean canRunAsync()

Specified by:

canRunAsync in class SelectorEventHandler

runAsync

public void runAsync(SelectionKey sKey)
              throws IOException

Specified by:

runAsync in class SelectorEventHandler

Throws:

IOException

run

public void run(SelectionKey skey)

Specified by:

run in class SelectorEventHandler

toString

public String toString()

Overrides:

toString in class Object