Lines Matching refs:u

95     engine->u.pollset.ps = -1;  in nxt_pollset_create()
96 engine->u.pollset.mchanges = mchanges; in nxt_pollset_create()
97 engine->u.pollset.mevents = mevents; in nxt_pollset_create()
104 engine->u.pollset.changes = changes; in nxt_pollset_create()
115 engine->u.pollset.write_changes = changes; in nxt_pollset_create()
117 engine->u.pollset.events = nxt_malloc(sizeof(struct pollfd) * mevents); in nxt_pollset_create()
118 if (engine->u.pollset.events == NULL) { in nxt_pollset_create()
122 engine->u.pollset.ps = pollset_create(-1); in nxt_pollset_create()
124 if (engine->u.pollset.ps == -1) { in nxt_pollset_create()
129 nxt_debug(&engine->task, "pollset_create(): %d", engine->u.pollset.ps); in nxt_pollset_create()
146 ps = engine->u.pollset.ps; in nxt_pollset_free()
155 nxt_free(engine->u.pollset.events); in nxt_pollset_free()
156 nxt_free(engine->u.pollset.write_changes); in nxt_pollset_free()
157 nxt_free(engine->u.pollset.changes); in nxt_pollset_free()
158 nxt_fd_event_hash_destroy(&engine->u.pollset.fd_hash); in nxt_pollset_free()
160 nxt_memzero(&engine->u.pollset, sizeof(nxt_pollset_engine_t)); in nxt_pollset_free()
363 engine->u.pollset.ps, ev->fd, op, events); in nxt_pollset_change()
365 if (engine->u.pollset.nchanges >= engine->u.pollset.mchanges) { in nxt_pollset_change()
371 change = &engine->u.pollset.changes[engine->u.pollset.nchanges++]; in nxt_pollset_change()
389 engine->u.pollset.ps, engine->u.pollset.nchanges); in nxt_pollset_commit_changes()
393 write_changes = engine->u.pollset.write_changes; in nxt_pollset_commit_changes()
394 change = engine->u.pollset.changes; in nxt_pollset_commit_changes()
395 end = change + engine->u.pollset.nchanges; in nxt_pollset_commit_changes()
420 change = engine->u.pollset.changes; in nxt_pollset_commit_changes()
421 end = change + engine->u.pollset.nchanges; in nxt_pollset_commit_changes()
432 engine->u.pollset.nchanges = 0; in nxt_pollset_commit_changes()
441 ret = nxt_fd_event_hash_add(&engine->u.pollset.fd_hash, ev->fd, ev); in nxt_pollset_commit_changes()
449 nxt_fd_event_hash_delete(&engine->task, &engine->u.pollset.fd_hash, in nxt_pollset_commit_changes()
459 engine->u.pollset.nchanges = 0; in nxt_pollset_commit_changes()
474 nxt_fd_event_hash_delete(&engine->task, &engine->u.pollset.fd_hash, in nxt_pollset_change_error()
492 n = pollset_query(engine->u.pollset.ps, &pfd); in nxt_pollset_remove()
495 engine->u.pollset.ps, fd, n); in nxt_pollset_remove()
504 engine->u.pollset.ps, fd, nxt_errno); in nxt_pollset_remove()
511 engine->u.pollset.ps, fd); in nxt_pollset_remove()
526 ps = engine->u.pollset.ps; in nxt_pollset_write()
555 if (engine->u.pollset.nchanges != 0) { in nxt_pollset_poll()
563 engine->u.pollset.ps, timeout); in nxt_pollset_poll()
565 nevents = pollset_poll(engine->u.pollset.ps, engine->u.pollset.events, in nxt_pollset_poll()
566 engine->u.pollset.mevents, timeout); in nxt_pollset_poll()
573 engine->u.pollset.ps, nevents); in nxt_pollset_poll()
579 engine->u.pollset.ps, err); in nxt_pollset_poll()
586 pfd = &engine->u.pollset.events[i]; in nxt_pollset_poll()
590 ev = nxt_fd_event_hash_get(&engine->task, &engine->u.pollset.fd_hash, in nxt_pollset_poll()
597 engine->u.pollset.ps, fd, pfd->events, events); in nxt_pollset_poll()
608 engine->u.pollset.ps, fd, pfd->events, events); in nxt_pollset_poll()