ThreadIds

Struct-helper that holds all workers ids. It solves problem with immutability for Tids and allows to send and receive messages in a batch.

shared

struct ThreadIds {

Tid mClosedCheckerId;

Tid mFreeCheckerId;

Tid mConnectingCheckerId;

Tid mQueringCheckerId;

Tid closedCheckerId();

Tid freeCheckerId();

Tid connectingCheckerId();

Tid queringCheckerId();

this(Tid closedCheckerId, Tid freeCheckerId, Tid connectingCheckerId, Tid queringCheckerId);

void sendTids();

static shared(ThreadIds) receive();

void finalize(shared ILogger logger);

}

Constructors

this this(Tid closedCheckerId, Tid freeCheckerId, Tid connectingCheckerId, Tid queringCheckerId): Creating handler with all workers ids

Members

Functions

closedCheckerId Tid closedCheckerId(): Getter to cast away immutable
connectingCheckerId Tid connectingCheckerId(): Getter to cast away immutable
finalize void finalize(shared ILogger logger): Asks all workers to quit.
freeCheckerId Tid freeCheckerId(): Getter to cast away immutable
queringCheckerId Tid queringCheckerId(): Getter to cast away immutable
sendTids void sendTids(): Sends itself to all workers. Worker can restore local handler with use fo receive method.

Static functions

receive shared(ThreadIds) receive(): Constructing handler from message mailbox. The method is used with sendTids in workers.

Variables

mClosedCheckerId Tid mClosedCheckerId;: Worker for closed connections
mConnectingCheckerId Tid mConnectingCheckerId;: Worker for connections in connecting state
mFreeCheckerId Tid mFreeCheckerId;: Worker for free connections
mQueringCheckerId Tid mQueringCheckerId;: Worker for quering

Meta

Source

See Implementation

pgator db async workers handler modules