Class TRNonBlockingServerProcessor

java.lang.Object

com.biglybt.core.util.AERunnable

com.biglybt.core.util.ThreadPoolTask

com.biglybt.core.tracker.server.impl.TRTrackerServerProcessor

com.biglybt.core.tracker.server.impl.tcp.TRTrackerServerProcessorTCP

com.biglybt.core.tracker.server.impl.tcp.nonblocking.TRNonBlockingServerProcessor

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

TRTrackerServerFactoryImpl.NonBlockingProcessor

public abstract class TRNonBlockingServerProcessor
extends TRTrackerServerProcessorTCP

Nested Class Summary

Nested classes/interfaces inherited from class TRTrackerServerProcessor

TRTrackerServerProcessor.lightweightPeer

Nested classes/interfaces inherited from class ThreadPoolTask

ThreadPoolTask.Worker

Nested classes/interfaces inherited from class AERunnable

AERunnable.AERunnableNamed

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	keep_alive
private String	lc_request_header
private static final int	MAX_POST
private ByteBuffer	post_data_buffer
private static final AEProxyAddressMapper	proxy_address_mapper
private ByteBuffer	read_buffer
private static final int	READ_BUFFER_INCREMENT
private static final int	READ_BUFFER_INITIAL
private static final int	READ_BUFFER_LIMIT
private VirtualChannelSelector.VirtualSelectorListener	read_listener
private String	request_header
private final SocketChannel	socket_channel
private long	start_time
private ByteBuffer	write_buffer
private VirtualChannelSelector.VirtualSelectorListener	write_listener

Fields inherited from class TRTrackerServerProcessorTCP

CR, FF, HTTP_RESPONSE_END_GZIP, HTTP_RESPONSE_END_NOGZIP, HTTP_RESPONSE_START, HTTP_RESPONSE_XML_START, NL, SOCKET_TIMEOUT

Fields inherited from class ThreadPoolTask

worker

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TRNonBlockingServerProcessor(TRTrackerServerTCP _server, SocketChannel _socket)

Method Summary

Modifier and Type	Method	Description
protected void	asyncProcessComplete(ByteArrayOutputStream response)
protected void	closed()
protected void	completed()
protected void	failed()
protected boolean	getKeepAlive()
protected byte[]	getPostData()
protected VirtualChannelSelector.VirtualSelectorListener	getReadListener()
protected SocketChannel	getSocketChannel()
protected long	getStartTime()
protected VirtualChannelSelector.VirtualSelectorListener	getWriteListener()
void	interruptTask()
boolean	isActive()
protected abstract ByteArrayOutputStream	process(String input_header, String lowercase_input_header, String url_path, InetSocketAddress client_address, boolean announce_and_scrape_only, InputStream is, AsyncController async)
protected int	processRead()
protected int	processWrite()
void	runSupport()
protected void	setKeepAlive(boolean k)
protected void	setReadListener(VirtualChannelSelector.VirtualSelectorListener rl)
protected void	setWriteListener(VirtualChannelSelector.VirtualSelectorListener wl)
protected void	writeComplete()

Methods inherited from class TRTrackerServerProcessorTCP

areTimeoutsDisabled, doAuthentication, getServer, handleExternalRequest, processRequest, setTimeoutsDisabled

Methods inherited from class TRTrackerServerProcessor

addScrapeInterval, addScrapeInterval, processTrackerRequest, taskCompleted

Methods inherited from class ThreadPoolTask

getTaskState, releaseToPool, setTaskState, taskStarted

Methods inherited from class AERunnable

create, getName, run

Methods inherited from class Object

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

Field Details

MAX_POST

private static final int MAX_POST

See Also:

• Constant Field Values

READ_BUFFER_INITIAL

private static final int READ_BUFFER_INITIAL

See Also:

• Constant Field Values

READ_BUFFER_INCREMENT

private static final int READ_BUFFER_INCREMENT

See Also:

• Constant Field Values

READ_BUFFER_LIMIT

private static final int READ_BUFFER_LIMIT

See Also:

• Constant Field Values

proxy_address_mapper

private static final AEProxyAddressMapper proxy_address_mapper

socket_channel

private final SocketChannel socket_channel

read_listener

private VirtualChannelSelector.VirtualSelectorListener read_listener

write_listener

private VirtualChannelSelector.VirtualSelectorListener write_listener

start_time

private long start_time

read_buffer

private ByteBuffer read_buffer

post_data_buffer

private ByteBuffer post_data_buffer

request_header

private String request_header

lc_request_header

private String lc_request_header

write_buffer

private ByteBuffer write_buffer

keep_alive

private boolean keep_alive

Constructor Details

TRNonBlockingServerProcessor

protected TRNonBlockingServerProcessor(TRTrackerServerTCP _server,
 SocketChannel _socket)

Method Details

setReadListener

protected void setReadListener(VirtualChannelSelector.VirtualSelectorListener rl)

getReadListener

protected VirtualChannelSelector.VirtualSelectorListener getReadListener()

setWriteListener

protected void setWriteListener(VirtualChannelSelector.VirtualSelectorListener wl)

getWriteListener

protected VirtualChannelSelector.VirtualSelectorListener getWriteListener()

processRead

protected int processRead()

processWrite

protected int processWrite()

runSupport

public void runSupport()

Specified by:

runSupport in class AERunnable

process

protected abstract ByteArrayOutputStream process(String input_header,
 String lowercase_input_header,
 String url_path,
 InetSocketAddress client_address,
 boolean announce_and_scrape_only,
 InputStream is,
 AsyncController async)
                                          throws IOException

Throws:

IOException

asyncProcessComplete

protected void asyncProcessComplete(ByteArrayOutputStream response)

getSocketChannel

protected SocketChannel getSocketChannel()

getPostData

protected byte[] getPostData()

getStartTime

protected long getStartTime()

getKeepAlive

protected boolean getKeepAlive()

setKeepAlive

protected void setKeepAlive(boolean k)

isActive

public boolean isActive()

Overrides:

isActive in class TRTrackerServerProcessorTCP

interruptTask

public void interruptTask()

Specified by:

interruptTask in class ThreadPoolTask

failed

protected void failed()

writeComplete

protected void writeComplete()

completed

protected void completed()

closed

protected void closed()