Home
last modified time | relevance | path

Searched refs:fd (Results 26 – 50 of 73) sorted by path

123

/unit/src/
H A Dnxt_fd_event.h59 nxt_socket_t fd; member
H A Dnxt_file.c32 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 Dnxt_file.h79 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 Dnxt_freebsd_sendfile.c21 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 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_h1proto.c926 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 Dnxt_hpux_sendfile.c15 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 Dnxt_http_request.c850 && 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 Dnxt_http_static.c410 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 Dnxt_job_cache_file.c19 jbc->file.fd = NXT_FILE_INVALID; in nxt_job_cache_file_create()
H A Dnxt_kqueue_engine.c178 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 Dnxt_linux_sendfile.c99 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 Dnxt_macosx_sendfile.c17 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 Dnxt_main_process.c435 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 Dnxt_mem_map.c12 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 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_openssl.c1191 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 Dnxt_poll_engine.c22 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 Dnxt_pollset_engine.c408 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 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_port.h198 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 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_port_memory.h31 nxt_fd_t fd);
H A Dnxt_port_memory_int.h66 nxt_fd_t fd; member
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()

123