com.aelitis.azureus.core.networkmanager
Class VirtualChannelSelector

java.lang.Object
  com.aelitis.azureus.core.networkmanager.VirtualChannelSelector

public class VirtualChannelSelector
extends java.lang.Object

Nested Class Summary

static interface	VirtualChannelSelector.VirtualAbstractSelectorListener
static interface	VirtualChannelSelector.VirtualAcceptSelectorListener
static interface	VirtualChannelSelector.VirtualSelectorListener Listener for notification upon socket channel selection.

Field Summary

static int	OP_ACCEPT
static int	OP_CONNECT
static int	OP_READ
static int	OP_WRITE

Constructor Summary

VirtualChannelSelector(java.lang.String name, int interest_op, boolean pause_after_select)
Create a new virtual selectable-channel selector, selecting over the given interest-op.

Method Summary

void	cancel(java.nio.channels.spi.AbstractSelectableChannel channel) Cancel the selection operations for the given channel.
void	destroy()
void	enableSafeSelectionMode()
java.lang.String	getName()
boolean	isDestroyed()
boolean	isSafeSelectionModeEnabled()
void	pauseSelects(java.nio.channels.spi.AbstractSelectableChannel channel) Pause selection operations for the given channel
void	register(java.nio.channels.ServerSocketChannel channel, VirtualChannelSelector.VirtualAcceptSelectorListener listener, java.lang.Object attachment)
void	register(java.nio.channels.SocketChannel channel, VirtualChannelSelector.VirtualSelectorListener listener, java.lang.Object attachment)
protected void	registerSupport(java.nio.channels.spi.AbstractSelectableChannel channel, VirtualChannelSelector.VirtualAbstractSelectorListener listener, java.lang.Object attachment) Register the given selectable channel, using the given listener for notification of completed select operations.
void	resumeSelects(java.nio.channels.spi.AbstractSelectableChannel channel) Resume selection operations for the given channel
int	select(long timeout) Run a virtual select() operation, with the given selection timeout value; (1) cancellations are processed (2) the select operation is performed; (3) listener notification of completed selects (4) new registrations are processed
void	selectFailure(VirtualChannelSelector.VirtualAbstractSelectorListener listener, java.nio.channels.spi.AbstractSelectableChannel sc, java.lang.Object attachment, java.lang.Throwable msg)
boolean	selectSuccess(VirtualChannelSelector.VirtualAbstractSelectorListener listener, java.nio.channels.spi.AbstractSelectableChannel sc, java.lang.Object attachment)
void	setRandomiseKeys(boolean _rk)

Methods inherited from class java.lang.Object

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

Field Detail

OP_ACCEPT

public static final int OP_ACCEPT

See Also:

Constant Field Values

OP_CONNECT

public static final int OP_CONNECT

See Also:

Constant Field Values

OP_READ

public static final int OP_READ

See Also:

Constant Field Values

OP_WRITE

public static final int OP_WRITE

See Also:

Constant Field Values

Constructor Detail

VirtualChannelSelector

public VirtualChannelSelector(java.lang.String name,
                              int interest_op,
                              boolean pause_after_select)

Create a new virtual selectable-channel selector, selecting over the given interest-op.

Parameters:

interest_op - operation set of OP_CONNECT, OP_ACCEPT, OP_READ, or OP_WRITE

pause_after_select - whether or not to auto-disable interest op after select

Method Detail

getName

public java.lang.String getName()

register

public void register(java.nio.channels.SocketChannel channel,
                     VirtualChannelSelector.VirtualSelectorListener listener,
                     java.lang.Object attachment)

register

public void register(java.nio.channels.ServerSocketChannel channel,
                     VirtualChannelSelector.VirtualAcceptSelectorListener listener,
                     java.lang.Object attachment)

registerSupport

protected void registerSupport(java.nio.channels.spi.AbstractSelectableChannel channel,
                               VirtualChannelSelector.VirtualAbstractSelectorListener listener,
                               java.lang.Object attachment)

Register the given selectable channel, using the given listener for notification of completed select operations. NOTE: For OP_CONNECT and OP_WRITE -type selectors, once a selection request op completes, the channel's op registration is automatically disabled (paused); any future wanted selection notification requires re-enabling via resume. For OP_READ selectors, it stays enabled until actively paused, no matter how many times it is selected.

Parameters:

channel - socket to listen for

listener - op-complete listener

attachment - object to be passed back with listener notification

pauseSelects

public void pauseSelects(java.nio.channels.spi.AbstractSelectableChannel channel)

Pause selection operations for the given channel

Parameters:

channel - to pause

resumeSelects

public void resumeSelects(java.nio.channels.spi.AbstractSelectableChannel channel)

Resume selection operations for the given channel

Parameters:

channel - to resume

cancel

public void cancel(java.nio.channels.spi.AbstractSelectableChannel channel)

Cancel the selection operations for the given channel.

Parameters:

channel - channel originally registered

setRandomiseKeys

public void setRandomiseKeys(boolean _rk)

select

public int select(long timeout)

Run a virtual select() operation, with the given selection timeout value; (1) cancellations are processed (2) the select operation is performed; (3) listener notification of completed selects (4) new registrations are processed

Parameters:

timeout - in ms; if zero, block indefinitely

Returns:

number of sockets selected

destroy

public void destroy()

isDestroyed

public boolean isDestroyed()

isSafeSelectionModeEnabled

public boolean isSafeSelectionModeEnabled()

enableSafeSelectionMode

public void enableSafeSelectionMode()

selectSuccess

public boolean selectSuccess(VirtualChannelSelector.VirtualAbstractSelectorListener listener,
                             java.nio.channels.spi.AbstractSelectableChannel sc,
                             java.lang.Object attachment)

selectFailure

public void selectFailure(VirtualChannelSelector.VirtualAbstractSelectorListener listener,
                          java.nio.channels.spi.AbstractSelectableChannel sc,
                          java.lang.Object attachment,
                          java.lang.Throwable msg)