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
-
Nested Class Summary
Nested classes/interfaces inherited from class com.biglybt.core.tracker.server.impl.TRTrackerServerProcessor
TRTrackerServerProcessor.lightweightPeer
Nested classes/interfaces inherited from class com.biglybt.core.util.AERunnable
AERunnable.AERunnableNamed
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate boolean
private String
private static final int
private ByteBuffer
private static final AEProxyAddressMapper
private ByteBuffer
private static final int
private static final int
private static final int
private String
private final SocketChannel
private long
private ByteBuffer
Fields inherited from class com.biglybt.core.tracker.server.impl.tcp.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 com.biglybt.core.util.ThreadPoolTask
worker
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
TRNonBlockingServerProcessor
(TRTrackerServerTCP _server, SocketChannel _socket) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
asyncProcessComplete
(ByteArrayOutputStream response) protected void
closed()
protected void
protected void
failed()
protected boolean
protected byte[]
protected SocketChannel
protected long
void
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
protected int
void
protected void
setKeepAlive
(boolean k) protected void
protected void
protected void
Methods inherited from class com.biglybt.core.tracker.server.impl.tcp.TRTrackerServerProcessorTCP
areTimeoutsDisabled, doAuthentication, getServer, handleExternalRequest, processRequest, setTimeoutsDisabled
Methods inherited from class com.biglybt.core.tracker.server.impl.TRTrackerServerProcessor
addScrapeInterval, addScrapeInterval, processTrackerRequest, taskCompleted
Methods inherited from class com.biglybt.core.util.ThreadPoolTask
getName, getTaskState, releaseToPool, setTaskState, taskStarted
Methods inherited from class com.biglybt.core.util.AERunnable
create, run
-
Field Details
-
MAX_POST
private static final int MAX_POST- See Also:
-
READ_BUFFER_INITIAL
private static final int READ_BUFFER_INITIAL- See Also:
-
READ_BUFFER_INCREMENT
private static final int READ_BUFFER_INCREMENT- See Also:
-
READ_BUFFER_LIMIT
private static final int READ_BUFFER_LIMIT- See Also:
-
proxy_address_mapper
-
socket_channel
-
read_listener
-
write_listener
-
start_time
private long start_time -
read_buffer
-
post_data_buffer
-
request_header
-
lc_request_header
-
write_buffer
-
keep_alive
private boolean keep_alive
-
-
Constructor Details
-
TRNonBlockingServerProcessor
-
-
Method Details
-
setReadListener
-
getReadListener
-
setWriteListener
-
getWriteListener
-
processRead
protected int processRead() -
processWrite
protected int processWrite() -
runSupport
public void runSupport()- Specified by:
runSupport
in classAERunnable
-
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
-
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 classTRTrackerServerProcessorTCP
-
interruptTask
public void interruptTask()- Specified by:
interruptTask
in classThreadPoolTask
-
failed
protected void failed() -
writeComplete
protected void writeComplete() -
completed
protected void completed() -
closed
protected void closed()
-