Home
last modified time | relevance | path

Searched refs:fd (Results 26 – 50 of 73) sorted by last modified time

123

/unit/src/
H A Dnxt_port.c181 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 Dnxt_conn.h199 ret = nxt_socket_setsockopt(task, (c)->socket.fd, IPPROTO_TCP, \
213 ret = nxt_socket_setsockopt(task, (c)->socket.fd, IPPROTO_TCP, \
H A Dnxt_conn_close.c31 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 Dnxt_event_engine.h173 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 Dnxt_conn_accept.c46 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 Dnxt_port_memory_int.h66 nxt_fd_t fd; member
H A Dnxt_port_socket.c178 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 Dnxt_port_memory.h31 nxt_fd_t fd);
H A Dnxt_port_rpc.c392 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 Dnxt_port_memory.c37 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 Dnxt_socket.h115 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 Dnxt_mem_map.h49 #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 Dnxt_fd_event.h59 nxt_socket_t fd; member
H A Dnxt_gnutls.c494 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 Dnxt_cert.c38 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 Dnxt_external.c31 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 Dnxt_socketpair.c93 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 Dnxt_event_engine.c204 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 Dnxt_sendbuf.c167 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 Dnxt_test_build.h47 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 Dshmem27 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 Dsendfile152 sbsize_t sendfile(int s, int fd, off_t offset,
H A Dfiles76 int fd = syscall(SYS_openat2, AT_FDCWD, \".\",
78 if (fd == -1)
/unit/src/perl/
H A Dnxt_perl_psgi_layer.c23 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 Dport.go73 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)

123