Class AEProxyImpl

java.lang.Object

com.biglybt.core.proxy.impl.AEProxyImpl

All Implemented Interfaces:

VirtualChannelSelector.VirtualAbstractSelectorListener, VirtualChannelSelector.VirtualSelectorListener, AEProxy

public class AEProxyImpl
extends Object
implements AEProxy, VirtualChannelSelector.VirtualSelectorListener

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	allow_external_access
(package private) final VirtualChannelSelector	connect_selector
private final long	connect_timeout
private static final int	DEBUG_PERIOD
private boolean	destroyed
private long	last_debug
private static final LogIDs	LOGID
private int	port
private final List<AEProxyConnectionImpl>	processors
private final AEProxyHandler	proxy_handler
(package private) final VirtualChannelSelector	read_selector
private final long	read_timeout
private ServerSocketChannel	ssc
private final AEMonitor	this_mon
private final HashMap	write_select_regs
(package private) final VirtualChannelSelector	write_selector

Constructor Summary

Constructors

Constructor	Description
AEProxyImpl(int _port, long _connect_timeout, long _read_timeout, AEProxyHandler _proxy_handler)

Method Summary

Modifier and Type	Method	Description
protected void	acceptLoop(ServerSocketChannel ssc)
protected void	cancelConnectSelect(SocketChannel sc)
protected void	cancelReadSelect(SocketChannel sc)
protected void	cancelWriteSelect(SocketChannel sc)
protected void	checkTimeouts()
protected void	close(AEProxyConnectionImpl processor)
void	destroy()
int	getPort()
protected void	requestConnectSelect(AEProxyConnectionImpl processor, SocketChannel sc)
protected void	requestReadSelect(AEProxyConnectionImpl processor, SocketChannel sc)
protected void	requestWriteSelect(AEProxyConnectionImpl processor, SocketChannel sc)
void	selectFailure(VirtualChannelSelector selector, SocketChannel sc, Object attachment, Throwable msg)	Called when a channel selection fails.
protected void	selectLoop(VirtualChannelSelector selector)
boolean	selectSuccess(VirtualChannelSelector selector, SocketChannel sc, Object attachment)	Called when a channel is successfully selected for readyness.
void	setAllowExternalConnections(boolean permit)

Methods inherited from class Object

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

Field Details

LOGID

private static final LogIDs LOGID

DEBUG_PERIOD

private static final int DEBUG_PERIOD

See Also:

• Constant Field Values

last_debug

private long last_debug

port

private int port

connect_timeout

private final long connect_timeout

read_timeout

private final long read_timeout

proxy_handler

private final AEProxyHandler proxy_handler

ssc

private ServerSocketChannel ssc

read_selector

final VirtualChannelSelector read_selector

connect_selector

final VirtualChannelSelector connect_selector

write_selector

final VirtualChannelSelector write_selector

processors

private final List<AEProxyConnectionImpl> processors

write_select_regs

private final HashMap write_select_regs

allow_external_access

private boolean allow_external_access

this_mon

private final AEMonitor this_mon

destroyed

private volatile boolean destroyed

Constructor Details

AEProxyImpl

public AEProxyImpl(int _port,
 long _connect_timeout,
 long _read_timeout,
 AEProxyHandler _proxy_handler)
            throws AEProxyException

Throws:

AEProxyException

Method Details

setAllowExternalConnections

public void setAllowExternalConnections(boolean permit)

Specified by:

setAllowExternalConnections in interface AEProxy

acceptLoop

protected void acceptLoop(ServerSocketChannel ssc)

close

protected void close(AEProxyConnectionImpl processor)

selectLoop

protected void selectLoop(VirtualChannelSelector selector)

checkTimeouts

protected void checkTimeouts()

requestWriteSelect

protected void requestWriteSelect(AEProxyConnectionImpl processor,
 SocketChannel sc)

cancelWriteSelect

protected void cancelWriteSelect(SocketChannel sc)

requestReadSelect

protected void requestReadSelect(AEProxyConnectionImpl processor,
 SocketChannel sc)

cancelReadSelect

protected void cancelReadSelect(SocketChannel sc)

requestConnectSelect

protected void requestConnectSelect(AEProxyConnectionImpl processor,
 SocketChannel sc)

cancelConnectSelect

protected void cancelConnectSelect(SocketChannel sc)

selectSuccess

public boolean selectSuccess(VirtualChannelSelector selector,
 SocketChannel sc,
 Object attachment)

Description copied from interface: VirtualChannelSelector.VirtualSelectorListener

Called when a channel is successfully selected for readyness.

Specified by:

selectSuccess in interface VirtualChannelSelector.VirtualSelectorListener

Parameters:

attachment - originally given with the channel's registration

Returns:

indicator of whether or not any 'progress' was made due to this select null -> progress made, String -> location of non progress e.g. read-select -> read >0 bytes, write-select -> wrote > 0 bytes

selectFailure

public void selectFailure(VirtualChannelSelector selector,
 SocketChannel sc,
 Object attachment,
 Throwable msg)

Description copied from interface: VirtualChannelSelector.VirtualSelectorListener

Called when a channel selection fails.

Specified by:

selectFailure in interface VirtualChannelSelector.VirtualSelectorListener

Parameters:

msg - failure message

getPort

public int getPort()

Specified by:

getPort in interface AEProxy

destroy

public void destroy()

Specified by:

destroy in interface AEProxy