Home
last modified time | relevance | path

Searched refs:nxt_fd_t (Results 1 – 25 of 31) sorted by relevance

12

/unit/src/
H A Dnxt_fd_event.c11 static void nxt_fd_event_hash_error(nxt_task_t *task, nxt_fd_t fd);
33 nxt_fd_event_hash_add(nxt_lvlhsh_t *lvlhsh, nxt_fd_t fd, nxt_fd_event_t *ev) in nxt_fd_event_hash_add()
38 lhq.key_hash = nxt_murmur_hash2(&fd, sizeof(nxt_fd_t)); in nxt_fd_event_hash_add()
56 nxt_fd_event_hash_get(nxt_task_t *task, nxt_lvlhsh_t *lvlhsh, nxt_fd_t fd) in nxt_fd_event_hash_get()
61 lhq.key_hash = nxt_murmur_hash2(&fd, sizeof(nxt_fd_t)); in nxt_fd_event_hash_get()
77 nxt_fd_event_hash_delete(nxt_task_t *task, nxt_lvlhsh_t *lvlhsh, nxt_fd_t fd, in nxt_fd_event_hash_delete()
83 lhq.key_hash = nxt_murmur_hash2(&fd, sizeof(nxt_fd_t)); in nxt_fd_event_hash_delete()
109 nxt_fd_event_hash_error(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_event_hash_error()
H A Dnxt_file.h11 typedef int nxt_fd_t; typedef
79 nxt_fd_t fd;
107 nxt_uint_t mode, nxt_uint_t create, nxt_file_access_t access, nxt_fd_t dfd,
183 NXT_EXPORT nxt_int_t nxt_fd_nonblocking(nxt_task_t *task, nxt_fd_t fd);
184 NXT_EXPORT nxt_int_t nxt_fd_blocking(nxt_task_t *task, nxt_fd_t fd);
185 NXT_EXPORT ssize_t nxt_fd_write(nxt_fd_t fd, u_char *buf, size_t size);
186 NXT_EXPORT ssize_t nxt_fd_read(nxt_fd_t fd, u_char *buf, size_t size);
187 NXT_EXPORT void nxt_fd_close(nxt_fd_t fd);
189 NXT_EXPORT nxt_int_t nxt_file_redirect(nxt_file_t *file, nxt_fd_t fd);
205 NXT_EXPORT nxt_int_t nxt_pipe_create(nxt_task_t *task, nxt_fd_t *pp,
[all …]
H A Dnxt_file.c49 nxt_uint_t create, nxt_file_access_t access, nxt_fd_t dfd, in nxt_file_openat2()
362 nxt_fd_nonblocking(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_nonblocking()
380 nxt_fd_blocking(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_blocking()
398 nxt_fd_nonblocking(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_nonblocking()
422 nxt_fd_blocking(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_blocking()
448 nxt_fd_write(nxt_fd_t fd, u_char *buf, size_t size) in nxt_fd_write()
468 nxt_fd_read(nxt_fd_t fd, u_char *buf, size_t size) in nxt_fd_read()
493 nxt_fd_close(nxt_fd_t fd) in nxt_fd_close()
509 nxt_file_redirect(nxt_file_t *file, nxt_fd_t fd) in nxt_file_redirect()
587 nxt_pipe_create(nxt_task_t *task, nxt_fd_t *pp, nxt_bool_t nbread, in nxt_pipe_create()
[all …]
H A Dnxt_select_engine.c130 nxt_fd_t fd; in nxt_select_enable_read()
136 if (fd < 0 || fd >= (nxt_fd_t) FD_SETSIZE) { in nxt_select_enable_read()
157 nxt_fd_t fd; in nxt_select_enable_write()
163 if (fd < 0 || fd >= (nxt_fd_t) FD_SETSIZE) { in nxt_select_enable_write()
198 nxt_fd_t fd; in nxt_select_disable_read()
204 if (fd < 0 || fd >= (nxt_fd_t) FD_SETSIZE) { in nxt_select_disable_read()
222 nxt_fd_t fd; in nxt_select_disable_write()
228 if (fd < 0 || fd >= (nxt_fd_t) FD_SETSIZE) { in nxt_select_disable_write()
H A Dnxt_port.h189 nxt_fd_t fd[2];
200 nxt_fd_t fd[2];
272 nxt_fd_t queue_fd;
328 nxt_uint_t type, nxt_fd_t fd, nxt_fd_t fd2, uint32_t stream,
333 nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_port_id_t reply_port, in nxt_port_socket_write()
345 nxt_uint_t slot, nxt_fd_t fd);
H A Dnxt_poll_engine.c58 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);
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()
460 nxt_poll_set_delete(nxt_event_engine_t *engine, nxt_fd_t fd) in nxt_poll_set_delete()
469 lhq.key_hash = nxt_murmur_hash2(&fd, sizeof(nxt_fd_t)); in nxt_poll_set_delete()
503 nxt_fd_t fd; in nxt_poll()
637 nxt_poll_fd_hash_get(nxt_event_engine_t *engine, nxt_fd_t fd) in nxt_poll_fd_hash_get()
642 lhq.key_hash = nxt_murmur_hash2(&fd, sizeof(nxt_fd_t)); in nxt_poll_fd_hash_get()
H A Dnxt_application.h106 nxt_fd_t shared_port_fd;
107 nxt_fd_t shared_queue_fd;
H A Dnxt_router_request.h12 nxt_fd_t body_fd;
H A Dnxt_mem_map.c12 nxt_fd_t fd, nxt_off_t offset) in nxt_mem_mmap()
H A Dnxt_event_engine.h345 nxt_int_t nxt_fd_event_hash_add(nxt_lvlhsh_t *lvlhsh, nxt_fd_t fd,
348 nxt_fd_t fd);
350 nxt_fd_t fd, nxt_bool_t ignore);
414 nxt_fd_t fds[2];
H A Dnxt_mem_map.h58 nxt_uint_t flags, nxt_fd_t fd, nxt_off_t offset);
H A Dnxt_port_memory.h31 nxt_fd_t fd);
H A Dnxt_socket_msg.h127 nxt_socket_msg_oob_get_fds(nxt_recv_oob_t *oob, nxt_fd_t *fd) in nxt_socket_msg_oob_get_fds()
158 nxt_socket_msg_oob_get(nxt_recv_oob_t *oob, nxt_fd_t *fd, nxt_pid_t *pid) in nxt_socket_msg_oob_get()
H A Dnxt_tls.h57 nxt_fd_t chain_file;
H A Dnxt_socket.h115 NXT_EXPORT ssize_t nxt_socketpair_send(nxt_fd_event_t *ev, nxt_fd_t *fd,
H A Dnxt_devpoll_engine.c58 static void nxt_devpoll_remove(nxt_event_engine_t *engine, nxt_fd_t fd);
150 nxt_fd_t fd; in nxt_devpoll_free()
496 nxt_devpoll_remove(nxt_event_engine_t *engine, nxt_fd_t fd) in nxt_devpoll_remove()
559 nxt_fd_t fd; in nxt_devpoll_poll()
H A Dnxt_socketpair.c86 nxt_socketpair_send(nxt_fd_event_t *ev, nxt_fd_t *fd, nxt_iobuf_t *iob, in nxt_socketpair_send()
H A Dnxt_solaris_sendfilev.c94 nxt_fd_t fd, last_fd; in nxt_solaris_buf_coalesce()
H A Dnxt_port_memory_int.h66 nxt_fd_t fd;
H A Dnxt_pollset_engine.c53 static void nxt_pollset_remove(nxt_event_engine_t *engine, nxt_fd_t fd);
482 nxt_pollset_remove(nxt_event_engine_t *engine, nxt_fd_t fd) in nxt_pollset_remove()
548 nxt_fd_t fd; in nxt_pollset_poll()
H A Dnxt_router.h229 nxt_fd_t fd;
H A Dnxt_port_memory.c205 nxt_fd_t fd) in nxt_port_incoming_port_mmap()
291 nxt_fd_t fd; in nxt_port_new_port_mmap()
370 nxt_fd_t fd; in nxt_shm_open()
H A Dnxt_port_socket.c26 nxt_inline void nxt_port_close_fds(nxt_fd_t *fd);
161 nxt_fd_t fd, nxt_fd_t fd2, uint32_t stream, nxt_port_id_t reply_port, in nxt_port_socket_write2()
603 nxt_port_close_fds(nxt_fd_t *fd) in nxt_port_close_fds()
H A Dnxt_cert.c38 nxt_fd_t fd;
42 static nxt_cert_t *nxt_cert_fd(nxt_task_t *task, nxt_fd_t fd);
78 nxt_cert_fd(nxt_task_t *task, nxt_fd_t fd) in nxt_cert_fd()
H A Dnxt_process.c506 nxt_fd_t fd; in nxt_process_whoami()
863 nxt_fd_t fd; in nxt_process_daemon()

12