Goby3  3.1.5a
2024.05.23
goby::zeromq::InterProcessPortalMainThread Class Reference

#include <goby/zeromq/transport/interprocess.h>

Public Member Functions

 InterProcessPortalMainThread (zmq::context_t &context)
 
 ~InterProcessPortalMainThread ()
 
bool publish_ready ()
 
bool subscribe_ready ()
 
bool recv (protobuf::InprocControl *control_msg, zmq_recv_flags_type flags=zmq_recv_flags_type())
 
void set_publish_cfg (const protobuf::Socket &cfg)
 
void set_hold_state (bool hold)
 
bool hold_state ()
 
void publish (const std::string &identifier, const char *bytes, int size, bool ignore_buffer=false)
 
void subscribe (const std::string &identifier)
 
void unsubscribe (const std::string &identifier)
 
void reader_shutdown ()
 
std::deque< protobuf::InprocControl > & control_buffer ()
 
void send_control_msg (const protobuf::InprocControl &control)
 

Detailed Description

Definition at line 169 of file interprocess.h.

Constructor & Destructor Documentation

◆ InterProcessPortalMainThread()

goby::zeromq::InterProcessPortalMainThread::InterProcessPortalMainThread ( zmq::context_t &  context)

◆ ~InterProcessPortalMainThread()

goby::zeromq::InterProcessPortalMainThread::~InterProcessPortalMainThread ( )
inline

Definition at line 173 of file interprocess.h.

Member Function Documentation

◆ control_buffer()

std::deque<protobuf::InprocControl>& goby::zeromq::InterProcessPortalMainThread::control_buffer ( )
inline

Definition at line 200 of file interprocess.h.

◆ hold_state()

bool goby::zeromq::InterProcessPortalMainThread::hold_state ( )
inline

Definition at line 192 of file interprocess.h.

◆ publish()

void goby::zeromq::InterProcessPortalMainThread::publish ( const std::string &  identifier,
const char bytes,
int  size,
bool  ignore_buffer = false 
)

◆ publish_ready()

bool goby::zeromq::InterProcessPortalMainThread::publish_ready ( )
inline

Definition at line 184 of file interprocess.h.

◆ reader_shutdown()

void goby::zeromq::InterProcessPortalMainThread::reader_shutdown ( )

◆ recv()

bool goby::zeromq::InterProcessPortalMainThread::recv ( protobuf::InprocControl control_msg,
zmq_recv_flags_type  flags = zmq_recv_flags_type() 
)

◆ send_control_msg()

void goby::zeromq::InterProcessPortalMainThread::send_control_msg ( const protobuf::InprocControl control)

◆ set_hold_state()

void goby::zeromq::InterProcessPortalMainThread::set_hold_state ( bool  hold)

◆ set_publish_cfg()

void goby::zeromq::InterProcessPortalMainThread::set_publish_cfg ( const protobuf::Socket cfg)

◆ subscribe()

void goby::zeromq::InterProcessPortalMainThread::subscribe ( const std::string &  identifier)

◆ subscribe_ready()

bool goby::zeromq::InterProcessPortalMainThread::subscribe_ready ( )
inline

Definition at line 185 of file interprocess.h.

◆ unsubscribe()

void goby::zeromq::InterProcessPortalMainThread::unsubscribe ( const std::string &  identifier)

The documentation for this class was generated from the following file: