Class TRTrackerServerProcessorTCP

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

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

TRBlockingServerProcessor, TRNonBlockingServerProcessor

public abstract class TRTrackerServerProcessorTCP
extends TRTrackerServerProcessor

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
protected static final char	CR
private boolean	disable_timeouts
protected static final char	FF
protected static final byte[]	HTTP_RESPONSE_END_GZIP
protected static final byte[]	HTTP_RESPONSE_END_NOGZIP
protected static final byte[]	HTTP_RESPONSE_START
protected static final byte[]	HTTP_RESPONSE_XML_START
private static final String	lc_azureus_name
private static String	MSG_CLIENT_NOT_SUPPORTED
protected static final String	NL
private final TRTrackerServerTCP	server
private final String	server_url
protected static final int	SOCKET_TIMEOUT

Fields inherited from class ThreadPoolTask

worker

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TRTrackerServerProcessorTCP(TRTrackerServerTCP _server)

Method Summary

Modifier and Type	Method	Description
boolean	areTimeoutsDisabled()
protected String	doAuthentication(InetSocketAddress remote_ip, String url_path, String header, String lowercase_input_header, OutputStream os, boolean tracker)
protected TRTrackerServerTCP	getServer()
protected boolean	handleExternalRequest(InetSocketAddress local_address, InetSocketAddress remote_address, String user, String url, String header, InputStream is, OutputStream os, AsyncController async, boolean[] keep_alive)
protected boolean	isActive()
protected boolean	processRequest(String input_header, String lowercase_input_header, String url_path, InetSocketAddress local_address, InetSocketAddress remote_address, boolean announce_and_scrape_only, boolean keep_alive, InputStream is, OutputStream os, AsyncController async)
void	setTimeoutsDisabled(boolean d)

Methods inherited from class TRTrackerServerProcessor

addScrapeInterval, addScrapeInterval, processTrackerRequest, taskCompleted

Methods inherited from class ThreadPoolTask

getTaskState, interruptTask, releaseToPool, setTaskState, taskStarted

Methods inherited from class AERunnable

create, getName, run, runSupport

Methods inherited from class Object

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

Field Details

SOCKET_TIMEOUT

protected static final int SOCKET_TIMEOUT

See Also:

• Constant Field Values

CR

protected static final char CR

See Also:

• Constant Field Values

FF

protected static final char FF

See Also:

• Constant Field Values

NL

protected static final String NL

See Also:

• Constant Field Values

lc_azureus_name

private static final String lc_azureus_name

HTTP_RESPONSE_START

protected static final byte[] HTTP_RESPONSE_START

HTTP_RESPONSE_XML_START

protected static final byte[] HTTP_RESPONSE_XML_START

HTTP_RESPONSE_END_GZIP

protected static final byte[] HTTP_RESPONSE_END_GZIP

HTTP_RESPONSE_END_NOGZIP

protected static final byte[] HTTP_RESPONSE_END_NOGZIP

MSG_CLIENT_NOT_SUPPORTED

private static String MSG_CLIENT_NOT_SUPPORTED

server

private final TRTrackerServerTCP server

server_url

private final String server_url

disable_timeouts

private boolean disable_timeouts

Constructor Details

TRTrackerServerProcessorTCP

protected TRTrackerServerProcessorTCP(TRTrackerServerTCP _server)

Method Details

areTimeoutsDisabled

public boolean areTimeoutsDisabled()

setTimeoutsDisabled

public void setTimeoutsDisabled(boolean d)

getServer

protected TRTrackerServerTCP getServer()

processRequest

protected boolean processRequest(String input_header,
 String lowercase_input_header,
 String url_path,
 InetSocketAddress local_address,
 InetSocketAddress remote_address,
 boolean announce_and_scrape_only,
 boolean keep_alive,
 InputStream is,
 OutputStream os,
 AsyncController async)
                          throws IOException

Throws:

IOException

doAuthentication

protected String doAuthentication(InetSocketAddress remote_ip,
 String url_path,
 String header,
 String lowercase_input_header,
 OutputStream os,
 boolean tracker)
                           throws IOException

Throws:

IOException

isActive

protected boolean isActive()

handleExternalRequest

protected boolean handleExternalRequest(InetSocketAddress local_address,
 InetSocketAddress remote_address,
 String user,
 String url,
 String header,
 InputStream is,
 OutputStream os,
 AsyncController async,
 boolean[] keep_alive)
                                 throws IOException

Throws:

IOException