eckit::distributed::Actor class

#include <eckit/distributed/Actor.h>

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