Class BlockingNngConnector

Inheritance Relationships

Base Type

Derived Types

Class Documentation

class BlockingNngConnector : public O3DS::Connector

Subclassed by O3DS::ClientPair, O3DS::Publisher, O3DS::Pull, O3DS::Push, O3DS::Reply, O3DS::Request, O3DS::ServerPair, O3DS::Subscriber

Public Functions

virtual ~BlockingNngConnector()
virtual bool write(const char *data, size_t len) override

Writes an nng message.

virtual size_t read(char *data, size_t len) override

Read bytes - len is the size of data.

virtual size_t read(char **data, size_t *len) override

Read bytes, resize data if needed.

void setError(const char *msg, int ret)

Protected Attributes

nng_socket mSocket
std::mutex mutex