Lines Matching refs:fd

22     nxt_socket_t         fd;  member
58 nxt_fd_t fd, int events);
59 static nxt_int_t nxt_poll_set_delete(nxt_event_engine_t *engine, nxt_fd_t fd);
62 nxt_fd_t fd);
306 nxt_debug(ev->task, "poll change: fd:%d op:%d ev:%XD", ev->fd, op, events); in nxt_poll_change()
350 ret = nxt_poll_set_change(engine, ev->fd, change->events); in nxt_poll_commit_changes()
359 ret = nxt_poll_set_delete(engine, ev->fd); in nxt_poll_commit_changes()
394 nxt_debug(&engine->task, "poll add event: fd:%d ev:%04Xi", ev->fd, events); in nxt_poll_set_add()
413 phe->fd = ev->fd; in nxt_poll_set_add()
418 pfd->fd = ev->fd; in nxt_poll_set_add()
422 lhq.key_hash = nxt_murmur_hash2(&ev->fd, sizeof(nxt_fd_t)); in nxt_poll_set_add()
441 nxt_poll_set_change(nxt_event_engine_t *engine, nxt_fd_t fd, int events) in nxt_poll_set_change() argument
446 fd, events); in nxt_poll_set_change()
448 phe = nxt_poll_fd_hash_get(engine, fd); in nxt_poll_set_change()
460 nxt_poll_set_delete(nxt_event_engine_t *engine, nxt_fd_t fd) in nxt_poll_set_delete() argument
467 nxt_debug(&engine->task, "poll delete event: fd:%d", fd); in nxt_poll_set_delete()
469 lhq.key_hash = nxt_murmur_hash2(&fd, sizeof(nxt_fd_t)); in nxt_poll_set_delete()
488 phe = nxt_poll_fd_hash_get(engine, engine->u.poll.set[nfds].fd); in nxt_poll_set_delete()
503 nxt_fd_t fd; in nxt_poll() local
544 fd = pfd->fd; in nxt_poll()
546 phe = nxt_poll_fd_hash_get(engine, fd); in nxt_poll()
551 fd, pfd->events, events); in nxt_poll()
554 pfd->fd = -1; in nxt_poll()
561 fd, events, ev->read, ev->write); in nxt_poll()
565 fd, pfd->events, events); in nxt_poll()
568 pfd->fd = -1; in nxt_poll()
637 nxt_poll_fd_hash_get(nxt_event_engine_t *engine, nxt_fd_t fd) in nxt_poll_fd_hash_get() argument
642 lhq.key_hash = nxt_murmur_hash2(&fd, sizeof(nxt_fd_t)); in nxt_poll_fd_hash_get()
651 nxt_alert(&engine->task, "fd %d not found in hash", fd); in nxt_poll_fd_hash_get()
669 if (nxt_fast_path(phe->fd == engine->u.poll.set[phe->index].fd)) { in nxt_poll_fd_hash_test()
674 phe->fd, engine->u.poll.set[phe->index].fd); in nxt_poll_fd_hash_test()