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:

• goby/zeromq/transport/interprocess.h