Searched refs:poll (Results 1 – 9 of 9) sorted by relevance
/unit/src/ |
H A D | nxt_poll_engine.c | 128 nxt_free(engine->u.poll.set); in nxt_poll_free() 308 if (engine->u.poll.nchanges >= engine->u.poll.mchanges) { in nxt_poll_change() 314 change = &engine->u.poll.changes[engine->u.poll.nchanges++]; in nxt_poll_change() 379 engine->u.poll.nchanges = 0; in nxt_poll_commit_changes() 396 if (engine->u.poll.nfds >= engine->u.poll.max_nfds) { in nxt_poll_set_add() 404 engine->u.poll.set = pfd; in nxt_poll_set_add() 417 pfd = &engine->u.poll.set[engine->u.poll.nfds++]; in nxt_poll_set_add() 482 engine->u.poll.nfds--; in nxt_poll_set_delete() 483 nfds = engine->u.poll.nfds; in nxt_poll_set_delete() 486 engine->u.poll.set[index] = engine->u.poll.set[nfds]; in nxt_poll_set_delete() [all …]
|
H A D | nxt_event_engine.h | 156 void (*poll)(nxt_event_engine_t *engine, member 423 nxt_poll_engine_t poll; member
|
H A D | nxt_event_engine.c | 549 engine->event.poll(engine, timeout); in nxt_event_engine_start()
|
H A D | nxt_unit.c | 4675 nevents = poll(fds, nfds, -1); in nxt_unit_read_buf()
|
/unit/auto/ |
H A D | events | 143 # Solaris, HP-UX, IRIX, Tru64 UNIX /dev/poll. 145 nxt_feature="/dev/poll" 158 n = open(\"/dev/poll\", O_RDWR); 179 #include <sys/poll.h>
|
/unit/src/nodejs/unit-http/ |
H A D | unit.cpp | 34 uv_poll_t poll; member 69 err = uv_timer_init(poll.loop, &timer); in process_port_msg() 92 uv_poll_stop(&poll); in stop() 94 uv_close((uv_handle_t *) &poll, delete_data); in stop() 496 err = uv_poll_init(loop, &data->poll, port->in_fd); in add_port() 503 err = uv_poll_start(&data->poll, UV_READABLE, in add_port() 514 data->poll.data = data; in add_port()
|
/unit/test/ |
H A D | conftest.py | 363 if p.poll() is not None:
|
/unit/src/java/nginx/unit/websocket/ |
H A D | Util.java | 146 SecureRandom sr = randoms.poll(); in generateMask()
|
H A D | WsRemoteEndpointImplBase.java | 363 mpNext = messagePartQueue.poll(); in endMessage()
|