TNonblockingServer
, TThreadedSelectorServer
public abstract class AbstractNonblockingServer extends TServer
Modifier and Type | Class | Description |
---|---|---|
static class |
AbstractNonblockingServer.AbstractNonblockingServerArgs<T extends AbstractNonblockingServer.AbstractNonblockingServerArgs<T>> |
|
protected class |
AbstractNonblockingServer.AbstractSelectThread |
An abstract thread that handles selecting on a set of transports and
FrameBuffers associated with selected keys
corresponding to requests. |
class |
AbstractNonblockingServer.AsyncFrameBuffer |
|
class |
AbstractNonblockingServer.FrameBuffer |
Class that implements a sort of state machine around the interaction with a
client and an invoker.
|
TServer.AbstractServerArgs<T extends TServer.AbstractServerArgs<T>>, TServer.Args
Modifier and Type | Field | Description |
---|---|---|
protected org.slf4j.Logger |
LOGGER |
eventHandler_, inputProtocolFactory_, inputTransportFactory_, outputProtocolFactory_, outputTransportFactory_, processorFactory_, serverTransport_
Constructor | Description |
---|---|
AbstractNonblockingServer(AbstractNonblockingServer.AbstractNonblockingServerArgs args) |
Modifier and Type | Method | Description |
---|---|---|
protected abstract boolean |
requestInvoke(AbstractNonblockingServer.FrameBuffer frameBuffer) |
Perform an invocation.
|
void |
serve() |
Begin accepting connections and processing invocations.
|
protected boolean |
startListening() |
Have the server transport start accepting connections.
|
protected abstract boolean |
startThreads() |
Starts any threads required for serving.
|
protected void |
stopListening() |
Stop listening for connections.
|
protected abstract void |
waitForShutdown() |
A method that will block until when threads handling the serving have been
shut down.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getEventHandler, isServing, setServerEventHandler, setServing, stop
public AbstractNonblockingServer(AbstractNonblockingServer.AbstractNonblockingServerArgs args)
public void serve()
protected abstract boolean startThreads()
protected abstract void waitForShutdown()
protected boolean startListening()
protected void stopListening()
protected abstract boolean requestInvoke(AbstractNonblockingServer.FrameBuffer frameBuffer)