Lines Matching refs:nxt_unit_ctx_t
97 nxt_unit_ctx_t *ctx;
136 int (*add_port)(nxt_unit_ctx_t *, nxt_unit_port_t *port);
139 void (*remove_port)(nxt_unit_t *, nxt_unit_ctx_t *,
146 void (*quit)(nxt_unit_ctx_t *);
149 void (*shm_ack_handler)(nxt_unit_ctx_t *);
152 ssize_t (*port_send)(nxt_unit_ctx_t *, nxt_unit_port_t *port,
157 ssize_t (*port_recv)(nxt_unit_ctx_t *, nxt_unit_port_t *port,
160 int (*ready_handler)(nxt_unit_ctx_t *);
201 nxt_unit_ctx_t *nxt_unit_init(nxt_unit_init_t *);
214 int nxt_unit_run(nxt_unit_ctx_t *);
216 int nxt_unit_run_ctx(nxt_unit_ctx_t *ctx);
218 int nxt_unit_run_shared(nxt_unit_ctx_t *ctx);
220 nxt_unit_request_info_t *nxt_unit_dequeue_request(nxt_unit_ctx_t *ctx);
229 int nxt_unit_run_once(nxt_unit_ctx_t *ctx);
231 int nxt_unit_process_port_msg(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port);
234 void nxt_unit_done(nxt_unit_ctx_t *);
240 nxt_unit_ctx_t *nxt_unit_ctx_alloc(nxt_unit_ctx_t *, void *);
336 void *nxt_unit_malloc(nxt_unit_ctx_t *ctx, size_t size);
338 void nxt_unit_free(nxt_unit_ctx_t *ctx, void *p);
358 void nxt_unit_log(nxt_unit_ctx_t *ctx, int level, const char* fmt, ...)