Home
last modified time | relevance | path

Searched refs:nxt_fd_t (Results 1 – 25 of 33) 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);
193 NXT_EXPORT nxt_int_t nxt_file_redirect(nxt_file_t *file, nxt_fd_t fd);
210 NXT_EXPORT nxt_int_t nxt_pipe_create(nxt_task_t *task, nxt_fd_t *pp,
[all …]
H A Dnxt_process.c36 const nxt_fd_t *gc_pipe);
39 nxt_fd_t *pid_pipe, nxt_fd_t *gc_pipe, nxt_bool_t use_pidns);
41 const nxt_process_t *process, nxt_fd_t *pid_pipe, nxt_fd_t *gc_pipe,
332 nxt_process_pipe_timer(nxt_fd_t fd, short event) in nxt_process_pipe_timer()
371 nxt_process_check_pid_status(const nxt_fd_t *gc_pipe) in nxt_process_check_pid_status()
394 nxt_process_recv_pid(const nxt_fd_t *pid_pipe, const nxt_fd_t *gc_pipe) in nxt_process_recv_pid()
442 nxt_fd_t *pid_pipe, nxt_fd_t *gc_pipe, in nxt_process_unshare()
501 nxt_fd_t *pid_pipe, nxt_fd_t *gc_pipe, in nxt_process_init_pidns()
548 nxt_fd_t pid_pipe[2], gc_pipe[2]; in nxt_process_create()
762 nxt_fd_t fd; in nxt_process_whoami()
[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()
546 nxt_file_redirect(nxt_file_t *file, nxt_fd_t fd) in nxt_file_redirect()
643 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.h198 nxt_fd_t fd[2];
209 nxt_fd_t fd[2];
281 nxt_fd_t queue_fd;
337 nxt_uint_t type, nxt_fd_t fd, nxt_fd_t fd2, uint32_t stream,
342 nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_port_id_t reply_port, in nxt_port_socket_write()
354 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_router_request.h12 nxt_fd_t body_fd;
H A Dnxt_application.h125 nxt_fd_t shared_port_fd;
126 nxt_fd_t shared_queue_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_script.h34 nxt_int_t nxt_script_file_read(nxt_fd_t fd, nxt_str_t *str);
H A Dnxt_socket_msg.h141 nxt_socket_msg_oob_get_fds(nxt_recv_oob_t *oob, nxt_fd_t *fd) in nxt_socket_msg_oob_get_fds()
172 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_script.c27 nxt_fd_t fd;
32 nxt_fd_t fd);
110 nxt_script_get(nxt_task_t *task, nxt_str_t *name, nxt_fd_t fd) in nxt_script_get()
674 nxt_script_file_read(nxt_fd_t fd, nxt_str_t *str) in nxt_script_file_read()
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.h237 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()

12