Class VirtualBlockingServerChannelSelector

java.lang.Object

com.biglybt.core.networkmanager.impl.tcp.VirtualBlockingServerChannelSelector

All Implemented Interfaces:

VirtualServerChannelSelector

public class VirtualBlockingServerChannelSelector
extends Object
implements VirtualServerChannelSelector

Virtual server socket channel for listening and accepting incoming connections.

Nested Class Summary

Nested classes/interfaces inherited from interface VirtualServerChannelSelector

VirtualServerChannelSelector.SelectListener

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	alert_on_fail
private final InetSocketAddress	bind_address
private long	last_accept_time
private final VirtualServerChannelSelector.SelectListener	listener
private static final LogIDs	LOGID
private final int	receive_buffer_size
private ServerSocketChannel	server_channel
protected final AEMonitor	this_mon

Constructor Summary

Constructors

Constructor	Description
VirtualBlockingServerChannelSelector(InetSocketAddress _bind_address, int so_rcvbuf_size, VirtualServerChannelSelector.SelectListener listener)	Create a new server listening on the given address and reporting to the given listener.

Method Summary

Modifier and Type	Method	Description
protected void	accept_loop()
InetAddress	getBoundToAddress()
int	getPort()
long	getTimeOfLastAccept()
boolean	isRunning()	Is this selector actively running
void	setAlertOnFail(boolean b)
void	startProcessing()	Start the server and begin accepting incoming connections.
void	stopProcessing()	Stop the server.

Methods inherited from class Object

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

Field Details

LOGID

private static final LogIDs LOGID

server_channel

private ServerSocketChannel server_channel

bind_address

private final InetSocketAddress bind_address

receive_buffer_size

private final int receive_buffer_size

listener

private final VirtualServerChannelSelector.SelectListener listener

this_mon

protected final AEMonitor this_mon

last_accept_time

private long last_accept_time

alert_on_fail

private boolean alert_on_fail

Constructor Details

VirtualBlockingServerChannelSelector

public VirtualBlockingServerChannelSelector(InetSocketAddress _bind_address,
 int so_rcvbuf_size,
 VirtualServerChannelSelector.SelectListener listener)

Create a new server listening on the given address and reporting to the given listener.

Parameters:

so_rcvbuf_size - new socket receive buffer size

listener - to notify of incoming connections

bind_address - ip+port to listen on

Method Details

setAlertOnFail

public void setAlertOnFail(boolean b)

Specified by:

setAlertOnFail in interface VirtualServerChannelSelector

startProcessing

public void startProcessing()

Start the server and begin accepting incoming connections.

Specified by:

startProcessing in interface VirtualServerChannelSelector

stopProcessing

public void stopProcessing()

Stop the server.

Specified by:

stopProcessing in interface VirtualServerChannelSelector

accept_loop

protected void accept_loop()

isRunning

public boolean isRunning()

Is this selector actively running

Specified by:

isRunning in interface VirtualServerChannelSelector

Returns:

true if enabled, false if not running

getBoundToAddress

public InetAddress getBoundToAddress()

Specified by:

getBoundToAddress in interface VirtualServerChannelSelector

getPort

public int getPort()

Specified by:

getPort in interface VirtualServerChannelSelector

getTimeOfLastAccept

public long getTimeOfLastAccept()

Specified by:

getTimeOfLastAccept in interface VirtualServerChannelSelector