Class VirtualAbstractChannelSelectorImpl

java.lang.Object

com.biglybt.core.networkmanager.impl.VirtualAbstractChannelSelectorImpl

public class VirtualAbstractChannelSelectorImpl
extends Object

Provides a simplified and safe (selectable-channel) socket single-op selector.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	VirtualAbstractChannelSelectorImpl.RegistrationData
private static class	VirtualAbstractChannelSelectorImpl.SelectorTimeoutException

Field Summary

Fields

Modifier and Type	Field	Description
private int	consec_select_fails
private long	consec_select_fails_start
private boolean	destroyed
(package private) static final AESemaphore	get_selector_allowed
private final int	INTEREST_OP
private long	last_reopen_attempt
private long	last_select_debug
private long	last_write_select_debug
private boolean	logged_broken_select
private static final LogIDs	LOGID
private static final boolean	MAYBE_BROKEN_SELECT
private int	next_select_loop_pos
protected final VirtualAbstractChannelSelector	parent
private final boolean	pause_after_select
private final HashMap<AbstractSelectableChannel, Boolean>	paused_states
private boolean	randomise_keys
private final Map<AbstractSelectableChannel, Object>	register_cancel_list
private final AEMonitor	register_cancel_list_mon
private boolean	select_is_broken
private int	select_looks_broken_count
protected Selector	selector
private final SelectorGuard	selector_guard
private static final int	SELECTOR_TIMEOUT
private static final int	WRITE_SELECTOR_DEBUG_CHECK_PERIOD
private static final int	WRITE_SELECTOR_DEBUG_MAX_TIME

Constructor Summary

Constructors

Constructor	Description
VirtualAbstractChannelSelectorImpl(VirtualAbstractChannelSelector _parent, int _interest_op, boolean _pause_after_select, boolean _randomise_keys)

Method Summary

Modifier and Type	Method	Description
void	cancel(AbstractSelectableChannel channel)
protected void	closeExistingSelector()
void	destroy()	Note that you have to ensure that a select operation is performed on the normal select loop *after* destroying the selector to actually cause the destroy to occur
private static Selector	getSelector()
boolean	isPaused(AbstractSelectableChannel channel)
boolean	isRegistered(AbstractSelectableChannel channel)
protected Selector	openNewSelector()
void	pauseSelects(AbstractSelectableChannel channel)
void	register(AbstractSelectableChannel channel, VirtualChannelSelector.VirtualAbstractSelectorListener listener, Object attachment)
void	resumeSelects(AbstractSelectableChannel channel)
int	select(long timeout)
void	setRandomiseKeys(boolean r)

Methods inherited from class Object

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

Field Details

LOGID

private static final LogIDs LOGID

MAYBE_BROKEN_SELECT

private static final boolean MAYBE_BROKEN_SELECT

SELECTOR_TIMEOUT

private static final int SELECTOR_TIMEOUT

See Also:

• Constant Field Values

get_selector_allowed

static final AESemaphore get_selector_allowed

select_is_broken

private boolean select_is_broken

select_looks_broken_count

private int select_looks_broken_count

logged_broken_select

private boolean logged_broken_select

selector

protected Selector selector

selector_guard

private final SelectorGuard selector_guard

consec_select_fails

private int consec_select_fails

consec_select_fails_start

private long consec_select_fails_start

register_cancel_list

private final Map<AbstractSelectableChannel, Object> register_cancel_list

register_cancel_list_mon

private final AEMonitor register_cancel_list_mon

paused_states

private final HashMap<AbstractSelectableChannel, Boolean> paused_states

INTEREST_OP

private final int INTEREST_OP

pause_after_select

private final boolean pause_after_select

parent

protected final VirtualAbstractChannelSelector parent

destroyed

private volatile boolean destroyed

randomise_keys

private boolean randomise_keys

next_select_loop_pos

private int next_select_loop_pos

WRITE_SELECTOR_DEBUG_CHECK_PERIOD

private static final int WRITE_SELECTOR_DEBUG_CHECK_PERIOD

See Also:

• Constant Field Values

WRITE_SELECTOR_DEBUG_MAX_TIME

private static final int WRITE_SELECTOR_DEBUG_MAX_TIME

See Also:

• Constant Field Values

last_write_select_debug

private long last_write_select_debug

last_select_debug

private long last_select_debug

last_reopen_attempt

private long last_reopen_attempt

Constructor Details

VirtualAbstractChannelSelectorImpl

public VirtualAbstractChannelSelectorImpl(VirtualAbstractChannelSelector _parent,
 int _interest_op,
 boolean _pause_after_select,
 boolean _randomise_keys)

Method Details

getSelector

private static Selector getSelector()
                             throws IOException

Throws:

IOException

openNewSelector

protected Selector openNewSelector()

setRandomiseKeys

public void setRandomiseKeys(boolean r)

isPaused

public boolean isPaused(AbstractSelectableChannel channel)

pauseSelects

public void pauseSelects(AbstractSelectableChannel channel)

resumeSelects

public void resumeSelects(AbstractSelectableChannel channel)

isRegistered

public boolean isRegistered(AbstractSelectableChannel channel)

cancel

public void cancel(AbstractSelectableChannel channel)

register

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

select

public int select(long timeout)

destroy

public void destroy()

Note that you have to ensure that a select operation is performed on the normal select loop *after* destroying the selector to actually cause the destroy to occur

closeExistingSelector

protected void closeExistingSelector()