ext/iodine/fio.c
/* *****************************************************************************
 * Master (server) IPC Connections
 **************************************************************************** */
Master (server) IPC Connections
Master ( server ) IPC Connections
static void fio_cluster_server_sender(void *m_, intptr_t avoid_uuid) {
  fio_msg_internal_s *m = m_;
  fio_lock(&cluster_data.lock);
  FIO_LS_FOR(&cluster_data.clients, pos) {
    if ((intptr_t)pos->obj != -1) {
      if ((intptr_t)pos->obj != avoid_uuid) {
        fio_msg_internal_send_dup((intptr_t)pos->obj, m);
      }
    }
  }
  fio_unlock(&cluster_data.lock);
  fio_msg_internal_free(m);
}
static void fio_cluster_server_sender ( void * m_ , intptr_t avoid_uuid ) { fio_msg_internal_s * m = m_ ; fio_lock ( & cluster_data . lock ) ; FIO_LS_FOR ( & cluster_data . clients , pos ) { if ( ( intptr_t ) pos -> obj != -1 ) { if ( ( intptr_t ) pos -> obj != avoid_uuid ) { fio_msg_internal_send_dup ( ( intptr_t ) pos -> obj , m ) ; } } } fio_unlock ( & cluster_data . lock ) ; fio_msg_internal_free ( m ) ; }
Master (server) IPC Connections
Master ( server ) IPC Connections