Class VirtualAbstractChannelSelector

java.lang.Object

com.biglybt.core.networkmanager.VirtualAbstractChannelSelector

Direct Known Subclasses:

VirtualChannelSelector

public class VirtualAbstractChannelSelector
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	VirtualAbstractChannelSelector.VirtualAcceptSelectorListener
static interface	VirtualAbstractChannelSelector.VirtualSelectorListener	Listener for notification upon socket channel selection.

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	destroyed
private final String	name
protected final int	op
static final int	OP_ACCEPT
static final int	OP_CONNECT
static final int	OP_READ
static final int	OP_WRITE
private boolean	randomise_keys
private final VirtualAbstractChannelSelectorImpl	selector_impl

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	cancel(AbstractSelectableChannel channel)	Cancel the selection operations for the given channel.
void	destroy()
String	getName()
boolean	isDestroyed()
boolean	isPaused(AbstractSelectableChannel channel)
boolean	isRegistered(AbstractSelectableChannel channel)
void	pauseSelects(AbstractSelectableChannel channel)	Pause selection operations for the given channel
void	register(ServerSocketChannel channel, VirtualAbstractChannelSelector.VirtualAcceptSelectorListener listener, Object attachment)
void	register(AbstractSelectableChannel channel, VirtualChannelSelector.VirtualAbstractSelectorListener listener, Object attachment)
protected void	registerSupport(AbstractSelectableChannel channel, VirtualChannelSelector.VirtualAbstractSelectorListener listener, Object attachment)	Register the given selectable channel, using the given listener for notification of completed select operations.
void	resumeSelects(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, AbstractSelectableChannel sc, Object attachment, Throwable msg)
boolean	selectSuccess(VirtualChannelSelector.VirtualAbstractSelectorListener listener, AbstractSelectableChannel sc, Object attachment)
void	setRandomiseKeys(boolean _rk)

Methods inherited from class Object

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

Field Details

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

name

private final String name

selector_impl

private final VirtualAbstractChannelSelectorImpl selector_impl

destroyed

private volatile boolean destroyed

op

protected final int op

randomise_keys

private boolean randomise_keys

Constructor Details

VirtualAbstractChannelSelector

public VirtualAbstractChannelSelector(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 Details

getName

public String getName()

register

public void register(AbstractSelectableChannel channel,
 VirtualChannelSelector.VirtualAbstractSelectorListener listener,
 Object attachment)

register

public void register(ServerSocketChannel channel,
 VirtualAbstractChannelSelector.VirtualAcceptSelectorListener listener,
 Object attachment)

registerSupport

protected void registerSupport(AbstractSelectableChannel channel,
 VirtualChannelSelector.VirtualAbstractSelectorListener listener,
 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

isPaused

public boolean isPaused(AbstractSelectableChannel channel)

pauseSelects

public void pauseSelects(AbstractSelectableChannel channel)

Pause selection operations for the given channel

Parameters:

channel - to pause

resumeSelects

public void resumeSelects(AbstractSelectableChannel channel)

Resume selection operations for the given channel

Parameters:

channel - to resume

isRegistered

public boolean isRegistered(AbstractSelectableChannel channel)

cancel

public void cancel(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()

selectSuccess

public boolean selectSuccess(VirtualChannelSelector.VirtualAbstractSelectorListener listener,
 AbstractSelectableChannel sc,
 Object attachment)

selectFailure

public void selectFailure(VirtualChannelSelector.VirtualAbstractSelectorListener listener,
 AbstractSelectableChannel sc,
 Object attachment,
 Throwable msg)