ext/iodine/redis_engine.c
/** a local static callback, called when the RESP message is complete. */
a local static callback, called when the RESP message is complete.
a local static callback called when the RESP message is complete .
static int resp_on_message(resp_parser_s *parser) {
  struct redis_engine_internal_s *i = parser2data(parser);
  FIOBJ msg = i->ary ? i->ary : i->str;
  i->on_message(i, msg);
  fiobj_free(msg);
  i->ary = FIOBJ_INVALID;
  i->str = FIOBJ_INVALID;
  return 0;
}
static int resp_on_message ( resp_parser_s * parser ) { struct redis_engine_internal_s * i = parser2data ( parser ) ; FIOBJ msg = i -> ary ? i -> ary : i -> str ; i -> on_message ( i , msg ) ; fiobj_free ( msg ) ; i -> ary = FIOBJ_INVALID ; i -> str = FIOBJ_INVALID ; return 0 ; }
a local static callback, called when the RESP message is complete.
a local static callback called when the RESP message is complete .
/* cleanup */