public class THsHaServer extends TNonblockingServer
Modifier and Type | Class and Description |
---|---|
static class |
THsHaServer.Args |
TNonblockingServer.AbstractNonblockingServerArgs<T extends TNonblockingServer.AbstractNonblockingServerArgs<T>>, TNonblockingServer.FrameBuffer, TNonblockingServer.SelectThread
TServer.AbstractServerArgs<T extends TServer.AbstractServerArgs<T>>
inputProtocolFactory_, inputTransportFactory_, outputProtocolFactory_, outputTransportFactory_, processorFactory_, serverTransport_
Constructor and Description |
---|
THsHaServer(THsHaServer.Args args)
Create server with every option fully specified, and with an injected
ExecutorService
|
Modifier and Type | Method and Description |
---|---|
protected static java.util.concurrent.ExecutorService |
createInvokerPool(THsHaServer.Args options)
Helper to create an invoker pool
|
protected java.lang.Runnable |
getRunnable(TNonblockingServer.FrameBuffer frameBuffer) |
protected void |
gracefullyShutdownInvokerPool() |
protected boolean |
requestInvoke(TNonblockingServer.FrameBuffer frameBuffer)
We override the standard invoke method here to queue the invocation for
invoker service instead of immediately invoking.
|
void |
serve()
Begin accepting connections and processing invocations.
|
isStopped, joinSelector, requestSelectInterestChange, startListening, startSelectorThread, stop, stopListening
isServing, setServing
public THsHaServer(THsHaServer.Args args)
public void serve()
TNonblockingServer
serve
in class TNonblockingServer
protected static java.util.concurrent.ExecutorService createInvokerPool(THsHaServer.Args options)
protected void gracefullyShutdownInvokerPool()
protected boolean requestInvoke(TNonblockingServer.FrameBuffer frameBuffer)
requestInvoke
in class TNonblockingServer
protected java.lang.Runnable getRunnable(TNonblockingServer.FrameBuffer frameBuffer)