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(fio_pubsub_engine_s *e, FIOBJ response,
                                         void *udata) {
  struct redis_callback_data d = {.response = response, .block = (VALUE)udata};
  if (d.block == Qnil) {
    return;
  }
  IodineCaller.enterGVL(iodine_pubsub_redis_callback_in_gil, &d);
  IodineStore.remove(d.block);
  (void)e;
}
static void iodine_pubsub_redis_callback ( fio_pubsub_engine_s * e , FIOBJ response , void * udata ) { struct redis_callback_data d = { . response = response , . block = ( VALUE ) udata } ; if ( d . block == Qnil ) { return ; } IodineCaller . enterGVL ( iodine_pubsub_redis_callback_in_gil , & d ) ; IodineStore . remove ( d . block ) ; ( void ) e ; }
A callback for Redis commands.
A callback for Redis commands .