helpers.cpp File Reference

Helper utilities for robust ZMQ message sending and receiving. More...

#include "cppzmqzoltanext/helpers.h"
#include <cerrno>

Include dependency graph for helpers.cpp:

Go to the source code of this file.

Functions
template<typename T >
zmq::send_result_t	zmqzext::send_retry_on_eintr (T &socket, zmq::const_buffer const &buf, zmq::send_flags flags)
	Send a message buffer with automatic retry on EINTR.
template<typename T >
zmq::send_result_t	zmqzext::send_retry_on_eintr (T &socket, zmq::message_t &msg, zmq::send_flags flags)
	Send a ZMQ message with automatic retry on EINTR.
template<typename T >
zmq::send_result_t	zmqzext::send_retry_on_eintr (T &socket, zmq::message_t &&msg, zmq::send_flags flags)
	Send a ZMQ message (rvalue) with automatic retry on EINTR.
template<typename T >
zmq::recv_buffer_result_t	zmqzext::recv_retry_on_eintr (T &socket, zmq::mutable_buffer const &buf, zmq::recv_flags flags)
	Receive data into a buffer with automatic retry on EINTR.
template<typename T >
zmq::recv_result_t	zmqzext::recv_retry_on_eintr (T &socket, zmq::message_t &msg, zmq::recv_flags flags)
	Receive a message with automatic retry on EINTR.
template CZZE_EXPORT zmq::send_result_t	zmqzext::send_retry_on_eintr< zmq::socket_t > (zmq::socket_t &socket, zmq::const_buffer const &buf, zmq::send_flags flags=zmq::send_flags::none)
template CZZE_EXPORT zmq::send_result_t	zmqzext::send_retry_on_eintr< zmq::socket_t > (zmq::socket_t &socket, zmq::message_t &msg, zmq::send_flags flags=zmq::send_flags::none)
template CZZE_EXPORT zmq::send_result_t	zmqzext::send_retry_on_eintr< zmq::socket_t > (zmq::socket_t &socket, zmq::message_t &&msg, zmq::send_flags flags=zmq::send_flags::none)
template CZZE_EXPORT zmq::recv_buffer_result_t	zmqzext::recv_retry_on_eintr< zmq::socket_t > (zmq::socket_t &socket, zmq::mutable_buffer const &buf, zmq::recv_flags flags=zmq::recv_flags::none)
template CZZE_EXPORT zmq::recv_result_t	zmqzext::recv_retry_on_eintr< zmq::socket_t > (zmq::socket_t &socket, zmq::message_t &msg, zmq::recv_flags flags=zmq::recv_flags::none)
template CZZE_EXPORT zmq::send_result_t	zmqzext::send_retry_on_eintr< zmq::socket_ref > (zmq::socket_ref &socket, zmq::const_buffer const &buf, zmq::send_flags flags=zmq::send_flags::none)
template CZZE_EXPORT zmq::send_result_t	zmqzext::send_retry_on_eintr< zmq::socket_ref > (zmq::socket_ref &socket, zmq::message_t &msg, zmq::send_flags flags=zmq::send_flags::none)
template CZZE_EXPORT zmq::send_result_t	zmqzext::send_retry_on_eintr< zmq::socket_ref > (zmq::socket_ref &socket, zmq::message_t &&msg, zmq::send_flags flags=zmq::send_flags::none)
template CZZE_EXPORT zmq::recv_buffer_result_t	zmqzext::recv_retry_on_eintr< zmq::socket_ref > (zmq::socket_ref &socket, zmq::mutable_buffer const &buf, zmq::recv_flags flags=zmq::recv_flags::none)
template CZZE_EXPORT zmq::recv_result_t	zmqzext::recv_retry_on_eintr< zmq::socket_ref > (zmq::socket_ref &socket, zmq::message_t &msg, zmq::recv_flags flags=zmq::recv_flags::none)

Detailed Description

Helper utilities for robust ZMQ message sending and receiving.

Authors

Luan Young (luanp.nosp@m.y@gm.nosp@m.ail.c.nosp@m.om)

Copyright

2025 Luan Young

Distributed under the MIT License (MIT) (See accompanying file LICENSE or copy at http://opensource.org/licenses/MIT)

Definition in file helpers.cpp.

Function Documentation

recv_retry_on_eintr() [1/2]

template<typename T >

zmq::recv_result_t zmqzext::recv_retry_on_eintr	(	T &	socket,
		zmq::message_t &	msg,
		zmq::recv_flags	flags = zmq::recv_flags::none
	)

Receive a message with automatic retry on EINTR.

Receives a ZMQ message from a socket, automatically retrying if the operation is interrupted by a signal. The message object is populated with the received data.

Parameters

socket	The ZMQ socket to receive data from
msg	Reference to the message object to populate with received data
flags	Optional ZMQ receive flags (default: none)

Returns

The receive result containing the number of bytes received

Exceptions

zmq::error_t

if an error occurs (other than EINTR)

Note

Overloads are provided for socket parameter types zmq::socket_t and zmq::socket_ref

See also

recv_retry_on_eintr(T&, zmq::mutable_buffer const&, zmq::recv_flags)

Definition at line 103 of file helpers.cpp.

recv_retry_on_eintr() [2/2]

template<typename T >

zmq::recv_buffer_result_t zmqzext::recv_retry_on_eintr	(	T &	socket,
		zmq::mutable_buffer const &	buf,
		zmq::recv_flags	flags = zmq::recv_flags::none
	)

Receive data into a buffer with automatic retry on EINTR.

Receives data from a ZMQ socket into a mutable buffer, automatically retrying if the operation is interrupted by a signal.

Parameters

socket	The ZMQ socket to receive data from
buf	The mutable buffer to receive data into
flags	Optional ZMQ receive flags (default: none)

Returns

The receive result containing the number of bytes received and the actual buffer used

Exceptions

zmq::error_t

if an error occurs (other than EINTR)

Note

Overloads are provided for socket parameter types zmq::socket_t and zmq::socket_ref

See also

recv_retry_on_eintr(T&, zmq::message_t&, zmq::recv_flags)

Definition at line 85 of file helpers.cpp.

send_retry_on_eintr() [1/3]

template<typename T >

zmq::send_result_t zmqzext::send_retry_on_eintr	(	T &	socket,
		zmq::const_buffer const &	buf,
		zmq::send_flags	flags = zmq::send_flags::none
	)

Send a message buffer with automatic retry on EINTR.

Sends data from a const buffer through a ZMQ socket, automatically retrying if the operation is interrupted by a signal.

Parameters

socket	The ZMQ socket to send data through
buf	The constant buffer containing data to send
flags	Optional ZMQ send flags (default: none)

Returns

The send result containing the number of bytes sent

Exceptions

zmq::error_t

if an error occurs (other than EINTR)

Note

Overloads are provided for socket parameter types zmq::socket_t and zmq::socket_ref

See also

send_retry_on_eintr(T&, zmq::message_t&, zmq::send_flags)

send_retry_on_eintr(T&, zmq::message_t&&, zmq::send_flags)

Definition at line 43 of file helpers.cpp.

send_retry_on_eintr() [2/3]

template<typename T >

zmq::send_result_t zmqzext::send_retry_on_eintr	(	T &	socket,
		zmq::message_t &&	msg,
		zmq::send_flags	flags = zmq::send_flags::none
	)

Send a ZMQ message (rvalue) with automatic retry on EINTR.

Sends a temporary ZMQ message through a socket, automatically retrying if the operation is interrupted by a signal.

Parameters

socket	The ZMQ socket to send data through
msg	Rvalue reference to the message to send
flags	Optional ZMQ send flags (default: none)

Returns

The send result containing the number of bytes sent

Exceptions

zmq::error_t

if an error occurs (other than EINTR)

Note

Overloads are provided for socket parameter types zmq::socket_t and zmq::socket_ref

See also

send_retry_on_eintr(T&, zmq::const_buffer const&, zmq::send_flags)

send_retry_on_eintr(T&, zmq::message_t&, zmq::send_flags)

Definition at line 79 of file helpers.cpp.

send_retry_on_eintr() [3/3]

template<typename T >

zmq::send_result_t zmqzext::send_retry_on_eintr	(	T &	socket,
		zmq::message_t &	msg,
		zmq::send_flags	flags = zmq::send_flags::none
	)

Send a ZMQ message with automatic retry on EINTR.

Sends a ZMQ message object through a socket, automatically retrying if the operation is interrupted by a signal.

Parameters

socket	The ZMQ socket to send data through
msg	Reference to the message to send
flags	Optional ZMQ send flags (default: none)

Returns

The send result containing the number of bytes sent

Exceptions

zmq::error_t

if an error occurs (other than EINTR)

Note

Overloads are provided for socket parameter types zmq::socket_t and zmq::socket_ref

See also

send_retry_on_eintr(T&, zmq::const_buffer const&, zmq::send_flags)

send_retry_on_eintr(T&, zmq::message_t&&, zmq::send_flags)

Definition at line 61 of file helpers.cpp.