zmq.h

Go to the documentation of this file.

#ifndef ZTH_ZMQ_H
#define ZTH_ZMQ_H
/*
 * Zth (libzth), a cooperative userspace multitasking library.
 * Copyright (C) 2019-2022  Jochem Rutgers
 *
 * This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at https://mozilla.org/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