/unit/src/ |
H A D | nxt_port.c | 181 msg->fd[0], msg->fd[1]); in nxt_port_handler() 282 nxt_fd_close(msg->fd[0]); in nxt_port_new_port_handler() 283 msg->fd[0] = -1; in nxt_port_new_port_handler() 294 nxt_fd_nonblocking(task, msg->fd[0]); in nxt_port_new_port_handler() 297 port->pair[1] = msg->fd[0]; in nxt_port_new_port_handler() 333 if (msg->fd[0] != -1) { in nxt_port_process_ready_handler() 334 port->queue_fd = msg->fd[0]; in nxt_port_process_ready_handler() 352 if (nxt_slow_path(msg->fd[0] == -1)) { in nxt_port_mmap_handler() 370 nxt_fd_close(msg->fd[0]); in nxt_port_mmap_handler() 376 nxt_fd_t fd) in nxt_port_change_log_file() argument [all …]
|
H A D | nxt_conn.h | 199 ret = nxt_socket_setsockopt(task, (c)->socket.fd, IPPROTO_TCP, \ 213 ret = nxt_socket_setsockopt(task, (c)->socket.fd, IPPROTO_TCP, \
|
H A D | nxt_conn_close.c | 31 c->socket.fd, c->socket.timedout); in nxt_conn_close() 50 c->socket.fd, nxt_socket_errno); in nxt_conn_close() 83 nxt_debug(task, "conn shutdown handler fd:%d", c->socket.fd); in nxt_conn_shutdown_handler() 87 nxt_socket_shutdown(task, c->socket.fd, SHUT_RDWR); in nxt_conn_shutdown_handler() 104 nxt_debug(task, "conn close handler fd:%d", c->socket.fd); in nxt_conn_close_handler() 119 nxt_socket_close(task, c->socket.fd); in nxt_conn_close_handler() 120 c->socket.fd = -1; in nxt_conn_close_handler() 152 nxt_debug(task, "conn close timer handler fd:%d", c->socket.fd); in nxt_conn_close_timer_handler() 156 if (c->socket.fd != -1) { in nxt_conn_close_timer_handler() 157 nxt_socket_close(task, c->socket.fd); in nxt_conn_close_timer_handler() [all …]
|
H A D | nxt_event_engine.h | 173 int fd; member 199 int fd; member 237 int fd; member 264 int fd; member 345 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);
|
H A D | nxt_conn_accept.c | 46 lev->socket.fd = ls->socket; in nxt_listen_event() 161 s = accept(lev->socket.fd, sa, &socklen); in nxt_conn_io_accept() 168 c->socket.fd = s; in nxt_conn_io_accept() 181 nxt_debug(task, "accept(%d): %d", lev->socket.fd, s); in nxt_conn_io_accept() 297 c->socket.fd, c->socket.read_ready); in nxt_conn_accept_close_idle_handler() 329 nxt_debug(task, "%s(%d) %E", accept_syscall, lev->socket.fd, err); in nxt_conn_accept_error() 335 accept_syscall, lev->socket.fd, err); in nxt_conn_accept_error() 343 accept_syscall, lev->socket.fd, err); in nxt_conn_accept_error() 350 accept_syscall, lev->socket.fd, err); in nxt_conn_accept_error() 385 nxt_alert(task, "accept(%d) event error", ev->fd); in nxt_conn_listen_event_error()
|
H A D | nxt_port_memory_int.h | 66 nxt_fd_t fd; member
|
H A D | nxt_port_socket.c | 178 msg.fd[0] = fd; in nxt_port_socket_write2() 179 msg.fd[1] = fd2; in nxt_port_socket_write2() 605 if (fd[0] != -1) { in nxt_port_close_fds() 607 fd[0] = -1; in nxt_port_close_fds() 612 fd[1] = -1; in nxt_port_close_fds() 867 msg.fd[0] = smsg->fd[0]; in nxt_port_queue_read_handler() 868 msg.fd[1] = smsg->fd[1]; in nxt_port_queue_read_handler() 981 smsg->fd[0] = msg.fd[0]; in nxt_port_queue_read_handler() 982 smsg->fd[1] = msg.fd[1]; in nxt_port_queue_read_handler() 1221 msg->fd[0] = fmsg->fd[0]; in nxt_port_read_msg_process() [all …]
|
H A D | nxt_port_memory.h | 31 nxt_fd_t fd);
|
H A D | nxt_port_rpc.c | 392 msg.fd[0] = -1; in nxt_port_rpc_remove_peer() 393 msg.fd[1] = -1; in nxt_port_rpc_remove_peer() 504 msg.fd[0] = -1; in nxt_port_rpc_close() 505 msg.fd[1] = -1; in nxt_port_rpc_close()
|
H A D | nxt_port_memory.c | 37 if (mmap_handler->fd != -1) { in nxt_port_mmap_handler_use() 205 nxt_fd_t fd) in nxt_port_incoming_port_mmap() argument 214 fd, process->pid); in nxt_port_incoming_port_mmap() 257 mmap_handler->fd = -1; in nxt_port_incoming_port_mmap() 291 nxt_fd_t fd; in nxt_port_new_port_mmap() local 314 if (nxt_slow_path(fd == -1)) { in nxt_port_new_port_mmap() 322 nxt_fd_close(fd); in nxt_port_new_port_mmap() 327 mmap_handler->fd = fd; in nxt_port_new_port_mmap() 370 nxt_fd_t fd; in nxt_shm_open() local 435 nxt_fd_close(fd); in nxt_shm_open() [all …]
|
H A D | nxt_socket.h | 115 NXT_EXPORT ssize_t nxt_socketpair_send(nxt_fd_event_t *ev, nxt_fd_t *fd, 121 #define nxt_socket_nonblocking(task, fd) \ argument 122 nxt_fd_nonblocking(task, fd) 124 #define nxt_socket_blocking(task, fd) \ argument 125 nxt_fd_blocking(task, fd)
|
H A D | nxt_mem_map.h | 49 #define nxt_mem_map(addr, ctx, len, protection, flags, fd, offset) \ argument 50 nxt_mem_mmap(addr, len, protection, flags, fd, offset) 58 nxt_uint_t flags, nxt_fd_t fd, nxt_off_t offset);
|
H A D | nxt_fd_event.h | 59 nxt_socket_t fd; member
|
H A D | nxt_gnutls.c | 494 c->socket.fd, b->mem.free, b->mem.end - b->mem.free, n); in nxt_gnutls_conn_io_read() 514 c->socket.fd, b->mem.free, in nxt_gnutls_conn_io_read() 551 c->socket.fd, buf, size, n); in nxt_gnutls_conn_io_send() 563 c->socket.fd, buf, size); in nxt_gnutls_conn_io_send() 603 c->socket.fd, how, err); in nxt_gnutls_conn_io_shutdown() 619 c->socket.fd); in nxt_gnutls_conn_io_shutdown()
|
H A D | nxt_cert.c | 38 nxt_fd_t fd; member 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() argument 83 bio = BIO_new_fd(fd, 0); in nxt_cert_fd() 352 cert = nxt_cert_fd(task, items[i].fd); in nxt_cert_info_init() 869 item->fd = -1; in nxt_cert_store_load() 901 item->fd = file.fd; in nxt_cert_store_load() 942 nxt_fd_close(items[i].fd); in nxt_cert_store_release() 1153 file.fd = -1; in nxt_cert_store_get_handler() 1186 (void) nxt_port_socket_write(task, port, type, file.fd, in nxt_cert_store_get_handler()
|
H A D | nxt_external.c | 31 nxt_external_fd_no_cloexec(nxt_task_t *task, nxt_socket_t fd) in nxt_external_fd_no_cloexec() argument 35 if (fd == -1) { in nxt_external_fd_no_cloexec() 39 flags = fcntl(fd, F_GETFD); in nxt_external_fd_no_cloexec() 42 nxt_alert(task, "fcntl(%d, F_GETFD) failed %E", fd, nxt_errno); in nxt_external_fd_no_cloexec() 48 res = fcntl(fd, F_SETFD, flags); in nxt_external_fd_no_cloexec() 51 nxt_alert(task, "fcntl(%d, F_SETFD) failed %E", fd, nxt_errno); in nxt_external_fd_no_cloexec()
|
H A D | nxt_socketpair.c | 93 nxt_socket_msg_oob_init(&oob, fd); in nxt_socketpair_send() 96 n = nxt_sendmsg(ev->fd, iob, niob, &oob); in nxt_socketpair_send() 100 nxt_debug(ev->task, "sendmsg(%d, %FD, %FD, %ui): %z", ev->fd, fd[0], in nxt_socketpair_send() 101 fd[1], niob, n); in nxt_socketpair_send() 112 nxt_debug(ev->task, "sendmsg(%d) not ready", ev->fd); in nxt_socketpair_send() 119 nxt_debug(ev->task, "sendmsg(%d) no buffers", ev->fd); in nxt_socketpair_send() 123 nxt_debug(ev->task, "sendmsg(%d) interrupted", ev->fd); in nxt_socketpair_send() 128 ev->fd, fd[0], fd[1], niob, err); in nxt_socketpair_send() 148 n = nxt_recvmsg(ev->fd, iob, niob, oob); in nxt_socketpair_recv() 171 nxt_debug(ev->task, "recvmsg(%d) not ready", ev->fd); in nxt_socketpair_recv() [all …]
|
H A D | nxt_event_engine.c | 204 pipe->event.fd = pipe->fds[0]; in nxt_event_engine_signal_pipe_create() 304 n = nxt_fd_read(ev->fd, buf, sizeof(buf)); in nxt_event_engine_signal_pipe()
|
H A D | nxt_sendbuf.c | 167 nxt_fd_t fd; in nxt_sendbuf_file_coalesce() local 172 fd = b->file->fd; in nxt_sendbuf_file_coalesce() 196 if (b->file_pos != last || b->file->fd != fd) { in nxt_sendbuf_file_coalesce()
|
H A D | nxt_test_build.h | 47 int fd; member 83 int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event); 87 int signalfd(int fd, const sigset_t *mask, int flags); 194 int fd; member 237 ssize_t sendfilev(int fd, const struct sendfilevec *vec, int sfvcnt,
|
/unit/auto/ |
H A D | shmem | 27 int fd = shm_open(name, O_CREAT | O_EXCL | O_RDWR, 29 if (fd == -1) 70 int fd = shm_open(name, O_CREAT | O_EXCL | O_RDWR, 72 if (fd == -1) 98 int fd = shm_open(SHM_ANON, O_RDWR, S_IRUSR | S_IWUSR); 99 if (fd == -1) 125 int fd = syscall(SYS_memfd_create, name, MFD_CLOEXEC); 126 if (fd == -1)
|
H A D | sendfile | 152 sbsize_t sendfile(int s, int fd, off_t offset,
|
H A D | files | 76 int fd = syscall(SYS_openat2, AT_FDCWD, \".\", 78 if (fd == -1)
|
/unit/src/perl/ |
H A D | nxt_perl_psgi_layer.c | 23 const char *mode, int fd, int imode, int perm, 128 const char *mode, int fd, int imode, int perm, in nxt_perl_psgi_layer_stream_open() argument 135 PERL_UNUSED_ARG(fd); in nxt_perl_psgi_layer_stream_open()
|
/unit/go/ |
H A D | port.go | 73 func getUnixConn(fd int) *net.UnixConn { 74 if fd < 0 { 78 f := os.NewFile(uintptr(fd), "sock") 89 nxt_go_alert("Not a Unix-domain socket %d", fd)
|