ext/iodine/fio.c
/**
 * Attaches an engine, so it's callback can be called by facil.io.
 *
 * The `subscribe` callback will be called for every existing channel.
 *
 * NOTE: the root (master) process will call `subscribe` for any channel in any
 * process, while all the other processes will call `subscribe` only for their
 * own channels. This allows engines to use the root (master) process as an
 * exclusive subscription process.
 */
Attaches an engine, so it's callback can be called by facil.io.
The `subscribe` callback will be called for every existing channel.

the root (master) process will call `subscribe` for any channel in any
process, while all the other processes will call `subscribe` only for their
own channels. This allows engines to use the root (master) process as an
exclusive subscription process.
Attaches an engine so it ' s callback can be called by facil . io . The ` subscribe ` callback will be called for every existing channel . the root ( master ) process will call ` subscribe ` for any channel in any process while all the other processes will call ` subscribe ` only for their own channels . This allows engines to use the root ( master ) process as an exclusive subscription process .
void fio_pubsub_attach(fio_pubsub_engine_s *engine) {
  fio_lock(&fio_postoffice.engines.lock);
  fio_engine_set_insert(&fio_postoffice.engines.set, (uintptr_t)engine, engine);
  fio_unlock(&fio_postoffice.engines.lock);
  fio_pubsub_reattach(engine);
}
void fio_pubsub_attach ( fio_pubsub_engine_s * engine ) { fio_lock ( & fio_postoffice . engines . lock ) ; fio_engine_set_insert ( & fio_postoffice . engines . set , ( uintptr_t ) engine , engine ) ; fio_unlock ( & fio_postoffice . engines . lock ) ; fio_pubsub_reattach ( engine ) ; }
Attaches an engine, so it's callback can be called by facil.io.
Attaches an engine so it ' s callback can be called by facil . io .