Class BlockingNngConnector

Defined in File nng_connector.h

Inheritance Relationships

Base Type

public O3DS::Connector (Class Connector)

Derived Types

public O3DS::ClientPair (Class ClientPair)
public O3DS::Publisher (Class Publisher)
public O3DS::Pull (Class Pull)
public O3DS::Push (Class Push)
public O3DS::Reply (Class Reply)
public O3DS::Request (Class Request)
public O3DS::ServerPair (Class ServerPair)
public O3DS::Subscriber (Class Subscriber)

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