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(const Actor&) deleted

Actor(Actor&&) deleted

~Actor() virtual

Public functions

auto operator=(const Actor&) -> Actor& deleted

auto operator=(Actor&&) -> Actor& deleted

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