fr_worker_channel_create() should be used instead
return worker->kq;
}
-/** Get the control-plane queue for the worker
- *
- * @param[in] worker the worker data structure
- * @return the atomic queue for the control plane
- */
-fr_atomic_queue_t *fr_worker_control_plane(fr_worker_t *worker)
-{
- return worker->aq_control;
-}
/** Signal a worker to exit
*
fr_worker_t *fr_worker_create(TALLOC_CTX *ctx, uint32_t num_transports, fr_transport_t **transports);
void fr_worker_destroy(fr_worker_t *worker) CC_HINT(nonnull);
int fr_worker_kq(fr_worker_t *worker) CC_HINT(nonnull);
-fr_atomic_queue_t *fr_worker_control_plane(fr_worker_t *worker) CC_HINT(nonnull);
void fr_worker(fr_worker_t *worker) CC_HINT(nonnull);
void fr_worker_exit(fr_worker_t *worker) CC_HINT(nonnull);
void fr_worker_debug(fr_worker_t *worker, FILE *fp) CC_HINT(nonnull);