Sha256: c8f2bd474b764b90931dcbadfea4754dec86f157416e7d3b3539794d4e3f5b02
Contents?: true
Size: 830 Bytes
Versions: 10
Compression:
Stored size: 830 Bytes
Contents
#ifndef RBCZMQ_BEACON_H
#define RBCZMQ_BEACON_H
typedef struct {
zbeacon_t *beacon;
} zmq_beacon_wrapper;
#define ZmqAssertBeacon(obj) ZmqAssertType(obj, rb_cZmqBeacon, "ZMQ::Beacon")
#define GetZmqBeacon(obj) \
zmq_beacon_wrapper *beacon = NULL; \
ZmqAssertBeacon(obj); \
Data_Get_Struct(obj, zmq_beacon_wrapper, beacon); \
if (!beacon) rb_raise(rb_eTypeError, "uninitialized ZMQ beacon!!"); \
struct nogvl_beacon_destroy_args {
zmq_beacon_wrapper *beacon;
};
struct nogvl_beacon_interval_args {
zmq_beacon_wrapper *beacon;
int interval;
};
struct nogvl_beacon_publish_args {
zmq_beacon_wrapper *beacon;
char *transmit;
int length;
};
struct nogvl_beacon_subscribe_args {
zmq_beacon_wrapper *beacon;
char *filter;
int length;
};
void _init_rb_czmq_beacon();
#endif
Version data entries
10 entries across 10 versions & 1 rubygems