ext/iodine/redis_engine.c
/* listens to filter -1 and publishes and messages */
listens to filter -1 and publishes and messages
listens to filter - 1 and publishes and messages
static void redis_on_internal_publish(fio_msg_s *msg) {
  if (msg->channel.len < 8)
    return; 
  void *en = (void *)fio_str2u64(msg->channel.data);
  if (en != msg->udata1)
    return; 
  msg->channel.len -= 8;
  msg->channel.data += 8;
  FIO_LOG_DEBUG("Forwarding to engine %p, on channel %s", msg->udata1,
                msg->channel.data);
  redis_on_publish_root(msg->udata1, msg->channel, msg->msg, msg->is_json);
}
static void redis_on_internal_publish ( fio_msg_s * msg ) { if ( msg -> channel . len < 8 ) return ; void * en = ( void * ) fio_str2u64 ( msg -> channel . data ) ; if ( en != msg -> udata1 ) return ; msg -> channel . len -= 8 ; msg -> channel . data += 8 ; FIO_LOG_DEBUG ( " " , msg -> udata1 , msg -> channel . data ) ; redis_on_publish_root ( msg -> udata1 , msg -> channel , msg -> msg , msg -> is_json ) ; }
listens to filter -1 and publishes and messages
listens to filter - 1 and publishes and messages
/* internal error, unexpected data */ /* should be delivered by a different engine */ /* step after the engine data */ /* forward to publishing */