eckit::distributed::Actor class

Derived classes

class Consumer
class Producer

Public types

enum MessageTags { READY, WORK, SHUTDOWN, OPEN, WRITE, CLOSE, STATISTICS, BYE }

Public static functions

static auto tagName(int) -> const char*

Constructors, destructors, conversion operators

Actor(Transport& transport)
~Actor() virtual

Public functions

void run() pure virtual
void finalise() pure virtual
void messageFromWorker(Message& message, int worker) const virtual
void messageFromWriter(Message& message, int worker) const virtual
void sendStatisticsToProducer(const Message& message) const virtual
void sendMessageToNextWorker(const Message& message) const virtual
void getNextWorkMessage(Message& message) const virtual
void getNextWriteMessage(Message& message) const virtual
void sendToWriter(int writer, const Message& message) const virtual
void sendShutDownMessage() const virtual
This website is beyond its original expiry date and the content may be out of date. The site owner has been notified and may choose to extend the expiry date and remove this banner. If you have any questions about this, please visit our support portal.