Class TRTrackerServerFactoryImpl.NonBlockingProcessor

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

com.biglybt.core.tracker.server.impl.TRTrackerServerFactoryImpl.NonBlockingProcessor

All Implemented Interfaces:

Runnable

Enclosing class:

TRTrackerServerFactoryImpl

protected static class TRTrackerServerFactoryImpl.NonBlockingProcessor
extends TRNonBlockingServerProcessor

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 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	NonBlockingProcessor(TRTrackerServerTCP _server, SocketChannel _socket)

Method Summary

Modifier and Type	Method	Description
protected ByteArrayOutputStream	process(String input_header, String lowercase_input_header, String url_path, InetSocketAddress remote_address, boolean announce_and_scrape_only, InputStream is, AsyncController async)

Methods inherited from class TRNonBlockingServerProcessor

asyncProcessComplete, closed, completed, failed, getKeepAlive, getPostData, getReadListener, getSocketChannel, getStartTime, getWriteListener, interruptTask, isActive, processRead, processWrite, runSupport, setKeepAlive, setReadListener, setWriteListener, 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

Constructor Details

NonBlockingProcessor

protected NonBlockingProcessor(TRTrackerServerTCP _server,
 SocketChannel _socket)

Method Details

process

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

Specified by:

process in class TRNonBlockingServerProcessor

Throws:

IOException