org.gudy.azureus2.core3.tracker.server.impl.tcp.nonblocking
Class TRNonBlockingServerProcessor
java.lang.Object
org.gudy.azureus2.core3.util.AERunnable
org.gudy.azureus2.core3.util.ThreadPoolTask
org.gudy.azureus2.core3.tracker.server.impl.TRTrackerServerProcessor
org.gudy.azureus2.core3.tracker.server.impl.tcp.TRTrackerServerProcessorTCP
org.gudy.azureus2.core3.tracker.server.impl.tcp.nonblocking.TRNonBlockingServerProcessor
- All Implemented Interfaces:
- java.lang.Runnable
- Direct Known Subclasses:
- TRTrackerServerFactoryImpl.NonBlockingProcessor
public abstract class TRNonBlockingServerProcessor
- extends TRTrackerServerProcessorTCP
- Author:
- parg
Methods inherited from class org.gudy.azureus2.core3.util.AERunnable |
run |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TRNonBlockingServerProcessor
protected TRNonBlockingServerProcessor(TRTrackerServerTCP _server,
java.nio.channels.SocketChannel _socket)
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 java.io.ByteArrayOutputStream process(java.lang.String input_header,
java.lang.String lowercase_input_header,
java.lang.String url_path,
java.net.InetSocketAddress client_address,
boolean announce_and_scrape_only,
java.io.InputStream is,
AsyncController async)
throws java.io.IOException
- Throws:
java.io.IOException
asyncProcessComplete
protected void asyncProcessComplete(java.io.ByteArrayOutputStream response)
getSocketChannel
protected java.nio.channels.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()