MRPT  2.0.4
Namespaces | Functions
Serialization functions for ZMQ (v3 or above) (in #include <mrpt/serialization/serialization_zmq.h>)ingroup

Detailed Description

noncstream_serialization

Namespaces

 mrpt::serialization::internal
 

Functions

template<typename ZMQ_SOCKET_TYPE >
void mrpt::serialization::mrpt_send_to_zmq (ZMQ_SOCKET_TYPE zmq_socket, const mrpt::serialization::CSerializable &obj, const size_t max_packet_len=0)
 Send an MRPT object to a ZMQ socket. More...
 
template<typename ZMQ_SOCKET_TYPE , typename VECTOR_MSG_T >
bool mrpt::serialization::mrpt_recv_from_zmq_buf (ZMQ_SOCKET_TYPE zmq_socket, VECTOR_MSG_T &out_lst_msgs, mrpt::io::CMemoryStream &target_buf, bool dont_wait, size_t *rx_obj_length_in_bytes)
 Users may normally call mrpt_recv_from_zmq() and mrpt_recv_from_zmq_into(). More...
 
template<typename ZMQ_SOCKET_TYPE >
mrpt::serialization::CSerializable::Ptr mrpt::serialization::mrpt_recv_from_zmq (ZMQ_SOCKET_TYPE zmq_socket, bool dont_wait=false, size_t *rx_obj_length_in_bytes=nullptr)
 Receives an MRPT object from a ZMQ socket, determining the type of the object on-the-fly. More...
 
template<typename ZMQ_SOCKET_TYPE >
bool mrpt::serialization::mrpt_recv_from_zmq_into (ZMQ_SOCKET_TYPE zmq_socket, mrpt::serialization::CSerializable &target_object, bool dont_wait=false, size_t *rx_obj_length_in_bytes=nullptr)
 Like mrpt_recv_from_zmq() but without dynamically allocating the received object, more efficient to use if the type of the received object is known in advance. More...
 

Function Documentation

◆ mrpt_recv_from_zmq()

template<typename ZMQ_SOCKET_TYPE >
mrpt::serialization::CSerializable::Ptr mrpt::serialization::mrpt_recv_from_zmq ( ZMQ_SOCKET_TYPE  zmq_socket,
bool  dont_wait = false,
size_t *  rx_obj_length_in_bytes = nullptr 
)

Receives an MRPT object from a ZMQ socket, determining the type of the object on-the-fly.

Parameters
[in]zmq_socketThe zmq socket object.
[in]dont_waitIf true, will fail if there is no data ready to be read. If false (default) this function will block until data arrives.
[out]rx_obj_length_in_bytesIf non-nullptr, the object length will be stored here.
Returns
An empty smart pointer if there was any error. The received object if all went OK.
Note
Including <mrpt/serialization/serialization_zmq.h> requires libzmq to be available in your system and linked to your user code. This function can be used even if MRPT was built without ZMQ support, thanks to the use of templates.
Exceptions
std::exceptionIf the object finds any critical error during de-serialization.
See also
mrpt_recv_from_zmq_into
Note
See examples of usage in https://github.com/MRPT/mrpt/tree/master/doc/mrpt-zeromq-example

Definition at line 177 of file zmq_serialization.h.

References mrpt::serialization::internal::free_zmq_msg_lst(), and mrpt::serialization::mrpt_recv_from_zmq_buf().

Here is the call graph for this function:

◆ mrpt_recv_from_zmq_buf()

template<typename ZMQ_SOCKET_TYPE , typename VECTOR_MSG_T >
bool mrpt::serialization::mrpt_recv_from_zmq_buf ( ZMQ_SOCKET_TYPE  zmq_socket,
VECTOR_MSG_T &  out_lst_msgs,
mrpt::io::CMemoryStream target_buf,
bool  dont_wait,
size_t *  rx_obj_length_in_bytes 
)

Users may normally call mrpt_recv_from_zmq() and mrpt_recv_from_zmq_into().

This function just stores the received data into a memory buffer without parsing it into an MRPT object.

Returns
false on any error

Definition at line 98 of file zmq_serialization.h.

References mrpt::io::CMemoryStream::assignMemoryNotOwn(), mrpt::io::CMemoryStream::clear(), mrpt::io::CMemoryStream::getTotalBytesCount(), and mrpt::io::CMemoryStream::Seek().

Referenced by mrpt::serialization::mrpt_recv_from_zmq(), and mrpt::serialization::mrpt_recv_from_zmq_into().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ mrpt_recv_from_zmq_into()

template<typename ZMQ_SOCKET_TYPE >
bool mrpt::serialization::mrpt_recv_from_zmq_into ( ZMQ_SOCKET_TYPE  zmq_socket,
mrpt::serialization::CSerializable target_object,
bool  dont_wait = false,
size_t *  rx_obj_length_in_bytes = nullptr 
)

Like mrpt_recv_from_zmq() but without dynamically allocating the received object, more efficient to use if the type of the received object is known in advance.

Parameters
[in]target_objectThe received object will be stored here. An exception will be raised upon type mismatch.
Returns
true if all was OK, false on any ZMQ error.
See also
mrpt_recv_from_zmq() for details on the rest of parameters.
Note
See examples of usage in https://github.com/MRPT/mrpt/tree/master/doc/mrpt-zeromq-example

Definition at line 205 of file zmq_serialization.h.

References mrpt::serialization::internal::free_zmq_msg_lst(), and mrpt::serialization::mrpt_recv_from_zmq_buf().

Here is the call graph for this function:

◆ mrpt_send_to_zmq()

template<typename ZMQ_SOCKET_TYPE >
void mrpt::serialization::mrpt_send_to_zmq ( ZMQ_SOCKET_TYPE  zmq_socket,
const mrpt::serialization::CSerializable obj,
const size_t  max_packet_len = 0 
)

Send an MRPT object to a ZMQ socket.

Parameters
[in]objThe object to be serialized and sent to the socket.
[in]zmq_socketThe zmq socket object.
[in]max_packet_lenThe object will be split into a series of ZMQ "message parts" of this maximum length (in bytes). Default=0, which means do not split in parts.
Note
Including <mrpt/serialization/serialization_zmq.h> requires libzmq to be available in your system and linked to your user code. This function can be used even if MRPT was built without ZMQ support, thanks to the use of templates.
Exceptions
std::exceptionIf the object finds any critical error during serialization or on ZMQ errors.
Note
See examples of usage in https://github.com/MRPT/mrpt/tree/master/doc/mrpt-zeromq-example

Definition at line 42 of file zmq_serialization.h.

References mrpt::io::internal::free_fn_for_zmq(), and mrpt::io::CMemoryStream::getTotalBytesCount().

Here is the call graph for this function:



Page generated by Doxygen 1.8.14 for MRPT 2.0.4 Git: 33de1d0ad Sat Jun 20 11:02:42 2020 +0200 at sáb jun 20 17:35:17 CEST 2020