Contents

#ifndef RBCZMQ_CONTEXT_H
#define RBCZMQ_CONTEXT_H

#include "socket.h"

#define ZMQ_CONTEXT_DESTROYED 0x01

typedef struct {
    zctx_t *ctx;
    int flags;
    pid_t pid; /* this is the pid for the process that created the context. Only this process can use the context. */
    VALUE pidValue; /* this is the key used to ensure one context per process */
    zlist_t* sockets; /* list of socket wrapper objects owned by this context. */
} zmq_ctx_wrapper;

#define ZmqAssertContext(obj) ZmqAssertType(obj, rb_cZmqContext, "ZMQ::Context")
#define ZmqGetContext(obj) \
    zmq_ctx_wrapper *ctx = NULL; \
    ZmqAssertContext(obj); \
    Data_Get_Struct(obj, zmq_ctx_wrapper, ctx); \
    if (!ctx) rb_raise(rb_eTypeError, "uninitialized ZMQ context!"); \
    if (ctx->flags & ZMQ_CONTEXT_DESTROYED) rb_raise(rb_eZmqError, "ZMQ::Context instance %p has been destroyed by the ZMQ framework", (void *)obj);

struct nogvl_socket_args {
    zctx_t *ctx;
    int type;
};

#define ZmqAssertContextPidMatches(wrapper) \
    if (ctx->pid != getpid()) { \
        rb_raise(rb_eZmqError, "ZMQ::Context instance belongs to another process. Create a new context for this process!"); \
    }

VALUE rb_czmq_socket_alloc(VALUE context, zctx_t *ctx, void *s);

void _init_rb_czmq_context();

void rb_czmq_context_destroy_socket(zmq_sock_wrapper* socket);

#endif

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
rbczmq-1.7.7	ext/rbczmq/context.h
rbczmq-1.7.6	ext/rbczmq/context.h
rbczmq-1.7.5	ext/rbczmq/context.h