TTaskPoolServer

A server which dispatches client requests to a std.parallelism TaskPool.

class TTaskPoolServer : TServer {

this(TProcessor processor, TServerTransport serverTransport, TTransportFactory transportFactory, TProtocolFactory protocolFactory, TaskPool taskPool);

this(TProcessorFactory processorFactory, TServerTransport serverTransport, TTransportFactory transportFactory, TProtocolFactory protocolFactory, TaskPool taskPool);

this(TProcessor processor, TServerTransport serverTransport, TTransportFactory inputTransportFactory, TTransportFactory outputTransportFactory, TProtocolFactory inputProtocolFactory, TProtocolFactory outputProtocolFactory, TaskPool taskPool);

this(TProcessorFactory processorFactory, TServerTransport serverTransport, TTransportFactory inputTransportFactory, TTransportFactory outputTransportFactory, TProtocolFactory inputProtocolFactory, TProtocolFactory outputProtocolFactory, TaskPool taskPool);

void serve(TCancellation cancellation);

void taskPool(TaskPool pool);

size_t maxActiveConns;

protected

TaskPool taskPool_;

}

Constructors

this this(TProcessor processor, TServerTransport serverTransport, TTransportFactory transportFactory, TProtocolFactory protocolFactory, TaskPool taskPool)
this this(TProcessorFactory processorFactory, TServerTransport serverTransport, TTransportFactory transportFactory, TProtocolFactory protocolFactory, TaskPool taskPool)
this this(TProcessor processor, TServerTransport serverTransport, TTransportFactory inputTransportFactory, TTransportFactory outputTransportFactory, TProtocolFactory inputProtocolFactory, TProtocolFactory outputProtocolFactory, TaskPool taskPool)
this this(TProcessorFactory processorFactory, TServerTransport serverTransport, TTransportFactory inputTransportFactory, TTransportFactory outputTransportFactory, TProtocolFactory inputProtocolFactory, TProtocolFactory outputProtocolFactory, TaskPool taskPool)

Members

Functions

serve void serve(TCancellation cancellation): Undocumented in source. Be warned that the author may not have intended to support it.
taskPool void taskPool(TaskPool pool): Sets the task pool to use.

Variables

maxActiveConns size_t maxActiveConns;: The maximum number of client connections open at the same time. Zero for no limit, which is the default.
taskPool_ TaskPool taskPool_;: Undocumented in source.

Inherited Members

From TServer

serve void serve(TCancellation cancellation): Starts serving.
eventHandler TServerEventHandler eventHandler;: The server event handler to notify. Null by default.
processorFactory_ TProcessorFactory processorFactory_;: Undocumented in source.
serverTransport_ TServerTransport serverTransport_;: Undocumented in source.
inputTransportFactory_ TTransportFactory inputTransportFactory_;: Undocumented in source.
outputTransportFactory_ TTransportFactory outputTransportFactory_;: Undocumented in source.
inputProtocolFactory_ TProtocolFactory inputProtocolFactory_;: Undocumented in source.
outputProtocolFactory_ TProtocolFactory outputProtocolFactory_;: Undocumented in source.
processorFactory TProcessorFactory processorFactory [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
serverTransport TServerTransport serverTransport [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
inputTransportFactory TTransportFactory inputTransportFactory [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
outputTransportFactory TTransportFactory outputTransportFactory [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
inputProtocolFactory TProtocolFactory inputProtocolFactory [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
outputProtocolFactory TProtocolFactory outputProtocolFactory [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.

TTaskPoolServer

Constructors

Members

Functions

Variables

Inherited Members

From TServer

Meta

Source