zmq.h

Go to the documentation of this file.

#ifndef ZTH_ZMQ_H
#define ZTH_ZMQ_H
/*
 * SPDX-FileCopyrightText: 2019-2026 Jochem Rutgers
 *
 * SPDX-License-Identifier: MPL-2.0
 */
 
#include <libzth/macros.h>
 
#ifdef ZTH_HAVE_LIBZMQ
#  include <zmq.h>
 
#  ifndef ZTH_REDIRECT_ZMQ
#    define ZTH_REDIRECT_ZMQ 1
#  endif
 
#  ifdef __cplusplus
namespace zth {
namespace zmq {
 
void* zmq_context();
void* zmq_socket(int type);
int zmq_msg_send(zmq_msg_t* msg, void* socket, int flags);
int zmq_msg_recv(zmq_msg_t* msg, void* socket, int flags);
int zmq_send(void* socket, void const* buf, size_t len, int flags);
int zmq_recv(void* socket, void* buf, size_t len, int flags);
int zmq_send_const(void* socket, void const* buf, size_t len, int flags);
 
} // namespace zmq
} // namespace zth
 
#  endif // __cplusplus
 
#  if ZTH_REDIRECT_ZMQ
#    ifdef __cplusplus
EXTERN_C ZTH_EXPORT ZTH_INLINE void* zth_zmq_context()
{
        return zth::zmq::zmq_context();
}
 
EXTERN_C ZTH_EXPORT ZTH_INLINE void* zth_zmq_socket(int type)
{
        return zth::zmq::zmq_socket(type);
}
 
EXTERN_C ZTH_EXPORT ZTH_INLINE int zth_zmq_msg_send(zmq_msg_t* msg, void* socket, int flags)
{
        return zth::zmq::zmq_msg_send(msg, socket, flags);
}
 
EXTERN_C ZTH_EXPORT ZTH_INLINE int zth_zmq_msg_recv(zmq_msg_t* msg, void* socket, int flags)
{
        return zth::zmq::zmq_msg_recv(msg, socket, flags);
}
 
EXTERN_C ZTH_EXPORT ZTH_INLINE int
zth_zmq_send(void* socket, void const* buf, size_t len, int flags)
{
        return zth::zmq::zmq_send(socket, buf, len, flags);
}
 
EXTERN_C ZTH_EXPORT ZTH_INLINE int zth_zmq_recv(void* socket, void* buf, size_t len, int flags)
{
        return zth::zmq::zmq_recv(socket, buf, len, flags);
}
 
EXTERN_C ZTH_EXPORT ZTH_INLINE int
zth_zmq_send_const(void* socket, void const* buf, size_t len, int flags)
{
        return zth::zmq::zmq_send_const(socket, buf, len, flags);
}
 
#    else  // !__cplusplus
ZTH_EXPORT void* zth_zmq_socket(int type);
ZTH_EXPORT int zth_zmq_msg_send(zmq_msg_t* msg, void* socket, int flags);
ZTH_EXPORT int zth_zmq_msg_recv(zmq_msg_t* msg, void* socket, int flags);
ZTH_EXPORT int zth_zmq_send(void* socket, void const* buf, size_t len, int flags);
ZTH_EXPORT int zth_zmq_recv(void* socket, void* buf, size_t len, int flags);
ZTH_EXPORT int zth_zmq_send_const(void* socket, void const* buf, size_t len, int flags);
#    endif // __cplusplus
 
#    define zmq_ctx_new zth_zmq_context
#    define zmq_ctx_term(c)
#    define zmq_socket(c, t) zth_zmq_socket(t)
#    define zmq_msg_send     zth_zmq_msg_send
#    define zmq_msg_recv     zth_zmq_msg_recv
#    define zmq_send         zth_zmq_send
#    define zmq_recv         zth_zmq_recv
#    define zmq_send_const   zth_zmq_send_const
#  endif // ZTH_REDIRECT_ZMQ
 
#endif // ZTH_HAVE_LIBZMQ
#endif // ZTH_ZMQ_H