ext/iodine/iodine_pubsub.c
/** A callback for Redis commands. */
A callback for Redis commands.
A callback for Redis commands .
static void *iodine_pubsub_redis_callback_in_gil(void *data_) {
  struct redis_callback_data *d = data_;
  VALUE rb = Qnil;
  if (!FIOBJ_IS_NULL(d->response)) {
    rb = fiobj2rb_deep(d->response, 0);
  }
  IodineCaller.call2(d->block, call_id, 1, &rb);
  IodineStore.remove(rb);
  return NULL;
}
static void * iodine_pubsub_redis_callback_in_gil ( void * data_ ) { struct redis_callback_data * d = data_ ; VALUE rb = Qnil ; if ( ! FIOBJ_IS_NULL ( d -> response ) ) { rb = fiobj2rb_deep ( d -> response , 0 ) ; } IodineCaller . call2 ( d -> block , call_id , 1 , & rb ) ; IodineStore . remove ( rb ) ; return NULL ; }
A callback for Redis commands.
A callback for Redis commands .