Home
last modified time | relevance | path

Searched refs:fd (Results 1 – 25 of 72) sorted by last modified time

123

/unit/src/
H A Dnxt_unit.c111 int fd);
972 recv_msg.fd[0] = -1; in nxt_unit_process_msg()
1001 recv_msg.fd[0], recv_msg.fd[1]); in nxt_unit_process_msg()
1193 (int) new_port_msg->id, recv_msg->fd[0], recv_msg->fd[1]); in nxt_unit_process_new_port()
3880 return fd; in nxt_unit_shm_open()
4669 fds[0].fd, fds[1].fd, strerror(err), err); in nxt_unit_read_buf()
4677 fds[0].fd, fds[1].fd, nevents, fds[0].revents, in nxt_unit_read_buf()
4699 fds[0].fd, fds[1].fd, nevents, fds[0].revents, in nxt_unit_read_buf()
6207 fd = port->in_fd; in nxt_unit_port_recv()
6312 nxt_unit_close(int fd) in nxt_unit_close() argument
[all …]
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_http_static.c402 file.fd = AT_FDCWD; in nxt_http_static_send_ready()
414 NXT_FILE_OPEN, 0, af.fd, resolve); in nxt_http_static_send_ready()
416 if (af.fd != AT_FDCWD) { in nxt_http_static_send_ready()
H A Dnxt_http_request.c820 && r->body->file->fd != -1) in nxt_http_request_close_handler()
822 nxt_fd_close(r->body->file->fd); in nxt_http_request_close_handler()
824 r->body->file->fd = -1; in nxt_http_request_close_handler()
H A Dnxt_router.c803 msg->fd[0] = -1; in nxt_router_conf_data_handler()
845 msg->fd[0] = -1; in nxt_router_conf_data_handler()
2262 nxt_int_t fd; in nxt_router_app_queue_init() local
2279 port->queue_fd = fd; in nxt_router_app_queue_init()
2290 nxt_int_t fd; in nxt_router_port_queue_init() local
2646 s = msg->fd[0]; in nxt_router_listen_socket_ready()
3510 if (fd == lev->socket.fd) { in nxt_router_listen_event()
3947 access_log->fd = msg->fd[0]; in nxt_router_access_log_ready()
4112 if (nxt_slow_path(dup2(msg->fd[0], access_log->fd) == -1)) { in nxt_router_access_log_reopen_ready()
4114 msg->fd[0], access_log->fd, nxt_errno); in nxt_router_access_log_reopen_ready()
[all …]
H A Dnxt_router.h226 nxt_fd_t fd; member
H A Dnxt_h1proto.c916 b->file->fd = -1; in nxt_h1p_request_body_read()
923 b->file->fd = mkstemp((char *) tmp_name.start); in nxt_h1p_request_body_read()
924 if (nxt_slow_path(b->file->fd == -1)) { in nxt_h1p_request_body_read()
932 &tmp_name, b->file->fd); in nxt_h1p_request_body_read()
947 res = nxt_fd_write(b->file->fd, in->mem.pos, size); in nxt_h1p_request_body_read()
1042 res = nxt_fd_write(b->file->fd, b->mem.pos, size); in nxt_h1p_conn_request_body_read()
2829 if (c->socket.fd != -1) { in nxt_h1p_peer_close()
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_port.h184 nxt_fd_t fd[2]; member
195 nxt_fd_t fd[2]; member
323 nxt_uint_t type, nxt_fd_t fd, nxt_fd_t fd2, uint32_t stream,
328 nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_port_id_t reply_port, in nxt_port_socket_write() argument
331 return nxt_port_socket_write2(task, port, type, fd, -1, stream, reply_port, in nxt_port_socket_write()
340 nxt_uint_t slot, nxt_fd_t fd);
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_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_file.h79 nxt_fd_t fd; member
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);
189 NXT_EXPORT nxt_int_t nxt_file_redirect(nxt_file_t *file, nxt_fd_t fd);
198 #define nxt_write_console(fd, buf, size) \ argument
199 write(fd, buf, size)
H A Dnxt_fd_event.h59 nxt_socket_t fd; member
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_main_process.c351 && msg->fd[1] != -1) in nxt_main_new_port_handler()
360 msg->fd[1] = -1; in nxt_main_new_port_handler()
523 msg->fd[0] = -1; in nxt_main_start_process_handler()
524 msg->fd[1] = -1; in nxt_main_start_process_handler()
544 msg->fd[0] = -1; in nxt_main_start_process_handler()
547 msg->fd[1] = -1; in nxt_main_start_process_handler()
645 msg->fd[0]); in nxt_main_process_whoami_handler()
647 if (msg->fd[0] != -1) { in nxt_main_process_whoami_handler()
658 msg->fd[0] = -1; in nxt_main_process_whoami_handler()
1493 msg->fd[0] = -1; in nxt_main_port_conf_store_handler()
[all …]
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_clone.c41 int fd, n; in nxt_clone_credential_setgroups() local
54 fd = open((char *)path, O_RDWR); in nxt_clone_credential_setgroups()
56 if (fd == -1) { in nxt_clone_credential_setgroups()
71 n = write(fd, str, strlen(str)); in nxt_clone_credential_setgroups()
72 close(fd); in nxt_clone_credential_setgroups()
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()
/unit/src/ruby/
H A Dnxt_ruby.c1061 int fd; member
1077 res = pread(file->fd, dst, size, file->pos); in nxt_ruby_rack_file_read()
1104 int fd, rc; in nxt_ruby_rack_result_body_file_write() local
1109 fd = open(RSTRING_PTR(filepath), O_RDONLY, 0); in nxt_ruby_rack_result_body_file_write()
1110 if (nxt_slow_path(fd == -1)) { in nxt_ruby_rack_result_body_file_write()
1118 rc = fstat(fd, &finfo); in nxt_ruby_rack_result_body_file_write()
1124 close(fd); in nxt_ruby_rack_result_body_file_write()
1129 ruby_file.fd = fd; in nxt_ruby_rack_result_body_file_write()
1144 close(fd); in nxt_ruby_rack_result_body_file_write()
/unit/src/python/
H A Dnxt_python_asgi.c378 PyObject *res, *fd; in nxt_py_asgi_remove_reader() local
389 fd = PyLong_FromLong(port->in_fd); in nxt_py_asgi_remove_reader()
390 if (nxt_slow_path(fd == NULL)) { in nxt_py_asgi_remove_reader()
397 res = PyObject_CallFunctionObjArgs(ctx_data->loop_remove_reader, fd, NULL); in nxt_py_asgi_remove_reader()
406 Py_DECREF(fd); in nxt_py_asgi_remove_reader()
919 PyObject *res, *fd, *py_ctx, *py_port; in nxt_py_asgi_add_reader() local
926 fd = PyLong_FromLong(port->in_fd); in nxt_py_asgi_add_reader()
927 if (nxt_slow_path(fd == NULL)) { in nxt_py_asgi_add_reader()
953 fd, nxt_py_port_read, in nxt_py_asgi_add_reader()
973 Py_DECREF(fd); in nxt_py_asgi_add_reader()
/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()

123