ext/iodine/fio.c
/* *****************************************************************************
 * Worker (client) IPC connections
 **************************************************************************** */
Worker (client) IPC connections
Worker ( client ) IPC connections
static void fio_cluster_client_handler(struct cluster_pr_s *pr) {
  switch ((fio_cluster_message_type_e)pr->type) {
  case FIO_CLUSTER_MSG_FORWARD: 
  case FIO_CLUSTER_MSG_JSON:
    fio_publish2process(fio_msg_internal_dup(pr->msg));
    break;
  case FIO_CLUSTER_MSG_SHUTDOWN:
    fio_stop();
  case FIO_CLUSTER_MSG_ERROR:         
  case FIO_CLUSTER_MSG_PING:          
  case FIO_CLUSTER_MSG_ROOT:          
  case FIO_CLUSTER_MSG_ROOT_JSON:     
  case FIO_CLUSTER_MSG_PUBSUB_SUB:    
  case FIO_CLUSTER_MSG_PUBSUB_UNSUB:  
  case FIO_CLUSTER_MSG_PATTERN_SUB:   
  case FIO_CLUSTER_MSG_PATTERN_UNSUB: 
  default:
    break;
  }
}
static void fio_cluster_client_handler ( struct cluster_pr_s * pr ) { switch ( ( fio_cluster_message_type_e ) pr -> type ) { case FIO_CLUSTER_MSG_FORWARD : case FIO_CLUSTER_MSG_JSON : fio_publish2process ( fio_msg_internal_dup ( pr -> msg ) ) ; break ; case FIO_CLUSTER_MSG_SHUTDOWN : fio_stop ( ) ; case FIO_CLUSTER_MSG_ERROR : case FIO_CLUSTER_MSG_PING : case FIO_CLUSTER_MSG_ROOT : case FIO_CLUSTER_MSG_ROOT_JSON : case FIO_CLUSTER_MSG_PUBSUB_SUB : case FIO_CLUSTER_MSG_PUBSUB_UNSUB : case FIO_CLUSTER_MSG_PATTERN_SUB : case FIO_CLUSTER_MSG_PATTERN_UNSUB : default : break ; } }
Worker (client) IPC connections
Worker ( client ) IPC connections
/* what to do? */ /* fallthrough */ /* fallthrough */ /* fallthrough */ /* fallthrough */ /* fallthrough */ /* fallthrough */ /* fallthrough */ /* fallthrough */ /* fallthrough */