ext/iodine/fio.c
/** Called when a ne client is available */
Called when a ne client is available
Called when a ne client is available
static void fio_cluster_listen_accept(intptr_t uuid, fio_protocol_s *protocol) {
  (void)protocol;
  intptr_t client;
  while ((client = fio_accept(uuid)) != -1) {
    fio_attach(client,
               fio_cluster_protocol_alloc(client, fio_cluster_server_handler,
                                          fio_cluster_server_sender));
    fio_lock(&cluster_data.lock);
    fio_ls_push(&cluster_data.clients, (void *)client);
    fio_unlock(&cluster_data.lock);
  }
}
static void fio_cluster_listen_accept ( intptr_t uuid , fio_protocol_s * protocol ) { ( void ) protocol ; intptr_t client ; while ( ( client = fio_accept ( uuid ) ) != -1 ) { fio_attach ( client , fio_cluster_protocol_alloc ( client , fio_cluster_server_handler , fio_cluster_server_sender ) ) ; fio_lock ( & cluster_data . lock ) ; fio_ls_push ( & cluster_data . clients , ( void * ) client ) ; fio_unlock ( & cluster_data . lock ) ; } }
Called when a ne client is available
Called when a ne client is available
/* prevent `accept` backlog in parent */