/unit/src/ |
H A D | nxt_fd_event.h | 59 nxt_socket_t fd; member
|
H A D | nxt_file.c | 32 if (file->fd != -1) { in nxt_file_open() 74 if (file->fd != -1) { in nxt_file_openat2() 94 if (close(file->fd) != 0) { in nxt_file_close() 555 n = read(fd, buf, size); in nxt_fd_read() 575 nxt_fd_close(nxt_fd_t fd) in nxt_fd_close() argument 630 nxt_thread_log_debug("dup2(%FD, %FD, \"%FN\")", fd, file->fd, file->name); in nxt_file_redirect() 632 if (dup2(fd, file->fd) == -1) { in nxt_file_redirect() 634 fd, file->fd, file->name, nxt_errno); in nxt_file_redirect() 638 if (close(fd) != 0) { in nxt_file_redirect() 689 int flags, fd; in nxt_stderr_start() local [all …]
|
H A D | nxt_file.h | 79 nxt_fd_t fd; member 185 NXT_EXPORT nxt_int_t nxt_fd_nonblocking(nxt_task_t *task, nxt_fd_t fd); 186 NXT_EXPORT nxt_int_t nxt_fd_blocking(nxt_task_t *task, nxt_fd_t fd); 187 NXT_EXPORT ssize_t nxt_fd_write(nxt_fd_t fd, u_char *buf, size_t size); 188 NXT_EXPORT ssize_t nxt_fd_read(nxt_fd_t fd, u_char *buf, size_t size); 189 NXT_EXPORT void nxt_fd_close(nxt_fd_t fd); 195 NXT_EXPORT nxt_int_t nxt_file_redirect(nxt_file_t *file, nxt_fd_t fd); 205 #define nxt_write_console(fd, buf, size) \ argument 206 write(fd, buf, size)
|
H A D | nxt_freebsd_sendfile.c | 21 static int nxt_sys_sendfile(int fd, int s, off_t offset, size_t nbytes, in nxt_sys_sendfile() argument 96 fb->file->fd, c->socket.fd, fb->file_pos, file_size, in nxt_freebsd_event_conn_io_sendfile() 100 n = nxt_sys_sendfile(fb->file->fd, c->socket.fd, fb->file_pos, in nxt_freebsd_event_conn_io_sendfile() 121 fb->file->fd, c->socket.fd, fb->file_pos, file_size, err, in nxt_freebsd_event_conn_io_sendfile()
|
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_h1proto.c | 926 b->file->fd = -1; in nxt_h1p_request_body_read() 933 b->file->fd = mkstemp((char *) tmp_name.start); in nxt_h1p_request_body_read() 934 if (nxt_slow_path(b->file->fd == -1)) { in nxt_h1p_request_body_read() 942 &tmp_name, b->file->fd); in nxt_h1p_request_body_read() 957 res = nxt_fd_write(b->file->fd, in->mem.pos, size); in nxt_h1p_request_body_read() 1052 res = nxt_fd_write(b->file->fd, b->mem.pos, size); in nxt_h1p_conn_request_body_read() 2840 if (c->socket.fd != -1) { in nxt_h1p_peer_close()
|
H A D | nxt_hpux_sendfile.c | 15 static ssize_t nxt_sys_sendfile(int s, int fd, off_t offset, size_t nbytes, in nxt_sys_sendfile() argument 25 sbsize_t sendfile(int s, int fd, off_t offset, bsize_t nbytes, 97 c->socket.fd, fb->file->fd, fb->file_pos, file_size, in nxt_hpux_event_conn_io_sendfile() 100 n = nxt_sys_sendfile(c->socket.fd, fb->file->fd, fb->file_pos, in nxt_hpux_event_conn_io_sendfile() 121 c->socket.fd, fb->file_pos, file_size, &fb->file->name, in nxt_hpux_event_conn_io_sendfile()
|
H A D | nxt_http_request.c | 850 && r->body->file->fd != -1) in nxt_http_request_close_handler() 852 nxt_fd_close(r->body->file->fd); in nxt_http_request_close_handler() 854 r->body->file->fd = -1; in nxt_http_request_close_handler()
|
H A D | nxt_http_static.c | 410 file.fd = AT_FDCWD; in nxt_http_static_send_ready() 422 NXT_FILE_OPEN, 0, af.fd, resolve); in nxt_http_static_send_ready() 424 if (af.fd != AT_FDCWD) { in nxt_http_static_send_ready()
|
H A D | nxt_job_cache_file.c | 19 jbc->file.fd = NXT_FILE_INVALID; in nxt_job_cache_file_create()
|
H A D | nxt_kqueue_engine.c | 178 engine->u.kqueue.fd = -1; in nxt_kqueue_create() 193 engine->u.kqueue.fd = kqueue(); in nxt_kqueue_create() 194 if (engine->u.kqueue.fd == -1) { in nxt_kqueue_create() 222 nxt_fd_t fd; in nxt_kqueue_free() local 224 fd = engine->u.kqueue.fd; in nxt_kqueue_free() 231 if (close(fd) != 0) { in nxt_kqueue_free() 423 engine->u.kqueue.fd, ev->file->fd, EVFILT_VNODE, flags, fflags); in nxt_kqueue_enable_file() 427 kev->ident = ev->file->fd; in nxt_kqueue_enable_file() 450 engine->u.kqueue.fd, ev->fd, filter, flags); in nxt_kqueue_fd_set() 454 kev->ident = ev->fd; in nxt_kqueue_fd_set() [all …]
|
H A D | nxt_linux_sendfile.c | 99 c->socket.fd, fb->file->fd, fb->file_pos, size); in nxt_linux_event_conn_io_sendfile() 103 n = nxt_sys_sendfile(c->socket.fd, fb->file->fd, &offset, size); in nxt_linux_event_conn_io_sendfile() 123 c->socket.fd, fb->file->fd, fb->file_pos, size, in nxt_linux_event_conn_io_sendfile() 148 n = send(c->socket.fd, buf, size, flags); in nxt_linux_send() 153 c->socket.fd, buf, size, flags, n); in nxt_linux_send() 169 c->socket.fd, buf, size, flags, err); in nxt_linux_send() 203 n = sendmsg(c->socket.fd, &msg, flags); in nxt_linux_sendmsg() 208 c->socket.fd, niov, flags, n); in nxt_linux_sendmsg() 224 c->socket.fd, niov, flags, err); in nxt_linux_sendmsg()
|
H A D | nxt_macosx_sendfile.c | 17 static int nxt_sys_sendfile(int fd, int s, off_t offset, off_t *len, in nxt_sys_sendfile() argument 106 fb->file->fd, c->socket.fd, fb->file_pos, sent, in nxt_macosx_event_conn_io_sendfile() 109 n = nxt_sys_sendfile(fb->file->fd, c->socket.fd, in nxt_macosx_event_conn_io_sendfile() 130 fb->file->fd, c->socket.fd, fb->file_pos, sent, err, in nxt_macosx_event_conn_io_sendfile()
|
H A D | nxt_main_process.c | 435 msg->fd[1] = -1; in nxt_main_new_port_handler() 598 msg->fd[0] = -1; in nxt_main_start_process_handler() 599 msg->fd[1] = -1; in nxt_main_start_process_handler() 619 msg->fd[0] = -1; in nxt_main_start_process_handler() 622 msg->fd[1] = -1; in nxt_main_start_process_handler() 725 msg->fd[0]); in nxt_main_process_whoami_handler() 727 if (msg->fd[0] != -1) { in nxt_main_process_whoami_handler() 738 msg->fd[0] = -1; in nxt_main_process_whoami_handler() 770 if (msg->fd[0] != -1) { in nxt_main_process_whoami_handler() 1626 msg->fd[0] = -1; in nxt_main_port_conf_store_handler() [all …]
|
H A D | nxt_mem_map.c | 12 nxt_fd_t fd, nxt_off_t offset) in nxt_mem_mmap() argument 16 p = mmap(addr, len, protection, flags, fd, offset); in nxt_mem_mmap() 20 addr, len, protection, flags, fd, offset, p); in nxt_mem_mmap() 24 addr, len, protection, flags, fd, offset, nxt_errno); in nxt_mem_mmap()
|
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_openssl.c | 1191 ret = SSL_set_fd(s, c->socket.fd); 1195 c->socket.fd); 1251 nxt_debug(task, "openssl conn handshake fd:%d", c->socket.fd); 1273 nxt_debug(task, "SSL_do_handshake(%d): %d err:%d", c->socket.fd, ret, err); 1318 c->socket.fd); 1348 c->socket.fd, b->mem.free, size, ret, err); 1359 c->socket.fd, b->mem.free, size); 1436 nxt_debug(task, "openssl conn shutdown fd:%d", c->socket.fd); 1480 c->socket.fd, mode, quiet, ret, err); 1531 c->socket.fd);
|
H A D | nxt_poll_engine.c | 22 nxt_socket_t fd; member 58 nxt_fd_t fd, int events); 62 nxt_fd_t fd); 413 phe->fd = ev->fd; in nxt_poll_set_add() 418 pfd->fd = ev->fd; in nxt_poll_set_add() 446 fd, events); in nxt_poll_set_change() 544 fd = pfd->fd; in nxt_poll() 554 pfd->fd = -1; in nxt_poll() 568 pfd->fd = -1; in nxt_poll() 669 if (nxt_fast_path(phe->fd == engine->u.poll.set[phe->index].fd)) { in nxt_poll_fd_hash_test() [all …]
|
H A D | nxt_pollset_engine.c | 408 ctl->fd = ev->fd; in nxt_pollset_commit_changes() 414 ctl->fd = ev->fd; in nxt_pollset_commit_changes() 475 ev->fd, 1); in nxt_pollset_change_error() 477 nxt_pollset_remove(engine, ev->fd); in nxt_pollset_change_error() 488 pfd.fd = fd; in nxt_pollset_remove() 495 engine->u.pollset.ps, fd, n); in nxt_pollset_remove() 511 engine->u.pollset.ps, fd); in nxt_pollset_remove() 515 ctl.fd = fd; in nxt_pollset_remove() 548 nxt_fd_t fd; in nxt_pollset_poll() local 587 fd = pfd->fd; in nxt_pollset_poll() [all …]
|
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_port.h | 198 nxt_fd_t fd[2]; member 209 nxt_fd_t fd[2]; member 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() argument 345 return nxt_port_socket_write2(task, port, type, fd, -1, stream, reply_port, in nxt_port_socket_write() 354 nxt_uint_t slot, nxt_fd_t fd);
|
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_port_memory.h | 31 nxt_fd_t fd);
|
H A D | nxt_port_memory_int.h | 66 nxt_fd_t fd; member
|
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()
|