Home
last modified time | relevance | path

Searched refs:batch (Results 1 – 10 of 10) sorted by relevance

/unit/src/
H A Dnxt_event_engine.c44 nxt_uint_t flags, nxt_uint_t batch) in nxt_event_engine_create() argument
63 engine->batch = batch; in nxt_event_engine_create()
116 events = (batch != 0) ? batch : 32; in nxt_event_engine_create()
384 const nxt_event_interface_t *interface, nxt_uint_t batch) in nxt_event_engine_change() argument
388 engine->batch = batch; in nxt_event_engine_change()
418 events = (batch != 0) ? batch : 32; in nxt_event_engine_change()
H A Dnxt_stream_source.c106 if (task->thread->engine->batch != 0) { in nxt_stream_source_connected()
244 nxt_bool_t batch; in nxt_stream_source_read_done() local
261 batch = (task->thread->engine->batch != 0); in nxt_stream_source_read_done()
263 if (batch) { in nxt_stream_source_read_done()
278 if (!batch) { in nxt_stream_source_read_done()
H A Dnxt_source.h27 if (thr->engine->batch != 0) { \
H A Dnxt_event_engine.h475 uint32_t batch; member
494 nxt_uint_t flags, nxt_uint_t batch);
496 const nxt_event_interface_t *interface, nxt_uint_t batch);
H A Dnxt_conn_accept.c49 lev->batch = engine->batch; in nxt_listen_event()
129 lev->ready = lev->batch; in nxt_conn_listen_handler()
H A Dnxt_runtime.h55 uint8_t batch; member
H A Dnxt_runtime.c403 rt->batch); in nxt_runtime_initial_start()
625 if (engine->batch == rt->batch in nxt_runtime_event_engine_change()
634 return nxt_event_engine_change(engine, interface, rt->batch); in nxt_runtime_event_engine_change()
H A Dnxt_conn.h102 uint32_t batch; member
H A Dnxt_process.c394 if (nxt_event_engine_change(engine, interface, rt->batch) != NXT_OK) { in nxt_process_setup()
H A Dnxt_kqueue_engine.c922 lev->ready = nxt_min(lev->batch, (uint32_t) lev->socket.kq_available); in nxt_kqueue_listen_handler()