eckit::distributed::Message class

Base classes

class eckit::Stream

Public static functions

static auto readyMessage() -> const Message&
static auto shutdownMessage() -> const Message&
static void dump(std::ostream&, const char*, size_t)

Constructors, destructors, conversion operators

Message(int tag = Actor::WORK, size_t size = 1024*1024)
~Message()

Public functions

void rewind() virtual
auto shutdownRequested() const -> bool
auto messageData() -> void*
auto messageData() const -> const void*
auto bufferSize() const -> size_t
auto messageSize() const -> size_t
void messageReceived(int, int)
auto getBlob(size_t& size) -> const void*
void reserve(size_t)
auto tag() const -> int
auto source() const -> int
auto operator<<(char) -> Stream&
auto operator<<(unsigned char) -> Stream&
auto operator<<(bool) -> Stream&
auto operator<<(int) -> Stream&
auto operator<<(unsigned int) -> Stream&
auto operator<<(short) -> Stream&
auto operator<<(unsigned short) -> Stream&
auto operator<<(long) -> Stream&
auto operator<<(unsigned long) -> Stream&
auto operator<<(long long) -> Stream&
auto operator<<(unsigned long long) -> Stream&
auto operator<<(float) -> Stream&
auto operator<<(double) -> Stream&
auto operator<<(const std::string&) -> Stream&
auto operator<<(const char*) -> Stream&
auto operator<<(const std::exception&) -> Stream&
auto operator<<(const Buffer&) -> Stream&
auto operator>>(char&) -> Stream&
auto operator>>(unsigned char&) -> Stream&
auto operator>>(int&) -> Stream&
auto operator>>(unsigned int&) -> Stream&
auto operator>>(bool&) -> Stream&
auto operator>>(long&) -> Stream&
auto operator>>(unsigned long&) -> Stream&
auto operator>>(long long&) -> Stream&
auto operator>>(unsigned long long&) -> Stream&
auto operator>>(short&) -> Stream&
auto operator>>(unsigned short&) -> Stream&
auto operator>>(float&) -> Stream&
auto operator>>(double&) -> Stream&
auto operator>>(std::string&) -> Stream&
auto operator>>(Buffer&) -> Stream&
auto operator>>(std::map<std::string, std::string>&) -> Stream&
auto next(std::string&) -> bool
auto next(bool&) -> bool
auto next(int&) -> bool
auto next() -> bool
auto endObjectFound() -> bool
void skipEndObject()
void startObject()
void endObject()
void writeBlob(const void*, size_t)
void readBlob(void*, size_t)
void writeLargeBlob(const void*, size_t)
void readLargeBlob(void*, size_t)
void closeOutput() virtual
void closeInput() virtual
auto bytesWritten() -> long long
void resetBytesWritten()
void startRecord(unsigned long)
void endRecord()
auto nextRecord(unsigned long&, bool sync = false) -> bool
void lock()
void unlock()

Private functions

auto name() const -> std::string virtual
auto write(const void*, long) -> long virtual
auto read(void*, long) -> long virtual
void print(std::ostream& out) const virtual

Friends

auto operator<<(std::ostream& s, const Message& x) -> std::ostream&

Function documentation

static void eckit::distributed::Message::dump(std::ostream&, const char*, size_t)

Stream& eckit::distributed::Message::operator<<(char)

Stream& eckit::distributed::Message::operator<<(unsigned char)

Stream& eckit::distributed::Message::operator<<(bool)

Stream& eckit::distributed::Message::operator<<(int)

Stream& eckit::distributed::Message::operator<<(unsigned int)

Stream& eckit::distributed::Message::operator<<(short)

Stream& eckit::distributed::Message::operator<<(unsigned short)

Stream& eckit::distributed::Message::operator<<(long)

Stream& eckit::distributed::Message::operator<<(unsigned long)

Stream& eckit::distributed::Message::operator<<(long long)

Stream& eckit::distributed::Message::operator<<(unsigned long long)

Stream& eckit::distributed::Message::operator<<(float)

Stream& eckit::distributed::Message::operator<<(double)

Stream& eckit::distributed::Message::operator<<(const std::string&)

Stream& eckit::distributed::Message::operator<<(const char*)

Stream& eckit::distributed::Message::operator<<(const std::exception&)

Stream& eckit::distributed::Message::operator<<(const Buffer&)

Stream& eckit::distributed::Message::operator>>(char&)

Stream& eckit::distributed::Message::operator>>(unsigned char&)

Stream& eckit::distributed::Message::operator>>(int&)

Stream& eckit::distributed::Message::operator>>(unsigned int&)

Stream& eckit::distributed::Message::operator>>(bool&)

Stream& eckit::distributed::Message::operator>>(long&)

Stream& eckit::distributed::Message::operator>>(unsigned long&)

Stream& eckit::distributed::Message::operator>>(long long&)

Stream& eckit::distributed::Message::operator>>(unsigned long long&)

Stream& eckit::distributed::Message::operator>>(short&)

Stream& eckit::distributed::Message::operator>>(unsigned short&)

Stream& eckit::distributed::Message::operator>>(float&)

Stream& eckit::distributed::Message::operator>>(double&)

Stream& eckit::distributed::Message::operator>>(std::string&)

Stream& eckit::distributed::Message::operator>>(Buffer&)

bool eckit::distributed::Message::next(std::string&)

bool eckit::distributed::Message::next(bool&)

bool eckit::distributed::Message::next(int&)

bool eckit::distributed::Message::next()

bool eckit::distributed::Message::endObjectFound()

void eckit::distributed::Message::skipEndObject()

void eckit::distributed::Message::startObject()

void eckit::distributed::Message::endObject()

void eckit::distributed::Message::writeBlob(const void*, size_t)

void eckit::distributed::Message::readBlob(void*, size_t)

void eckit::distributed::Message::writeLargeBlob(const void*, size_t)

void eckit::distributed::Message::readLargeBlob(void*, size_t)

void eckit::distributed::Message::closeOutput() virtual

void eckit::distributed::Message::closeInput() virtual

long long eckit::distributed::Message::bytesWritten()

void eckit::distributed::Message::resetBytesWritten()

void eckit::distributed::Message::startRecord(unsigned long)

void eckit::distributed::Message::endRecord()

bool eckit::distributed::Message::nextRecord(unsigned long&, bool sync = false)

void eckit::distributed::Message::lock()

void eckit::distributed::Message::unlock()