Home
last modified time | relevance | path

Searched refs:socket (Results 1 – 25 of 88) sorted by last modified time

1234

/unit/src/
H A Dnxt_runtime.c195 ls->socket = s; in nxt_runtime_inherited_listen_sockets()
264 ls->socket = s; in nxt_runtime_systemd_listen_sockets()
486 if (!c->socket.read_ready) { in nxt_runtime_close_idle_connections()
1139 ls->socket = -1; in nxt_runtime_listen_socket_add()
H A Dnxt_process.c1025 nxt_fd_event_close(task->thread->engine, &lev->socket); in nxt_process_quit()
1034 nxt_socket_close(task, ls->socket); in nxt_process_quit()
1035 ls->socket = -1; in nxt_process_quit()
H A Dnxt_router.c1225 s = skcf->listen->socket; in nxt_router_conf_error()
2463 ls->socket = -1; in nxt_router_socket_conf()
3435 lev->socket.data = joint; in nxt_router_listen_socket_create()
3458 fd = skcf->listen->socket; in nxt_router_listen_event()
3493 old = lev->socket.data; in nxt_router_listen_socket_update()
3494 lev->socket.data = joint; in nxt_router_listen_socket_update()
3528 lev->socket.fd); in nxt_router_listen_socket_delete()
3530 joint = lev->socket.data; in nxt_router_listen_socket_delete()
3569 lev->socket.fd); in nxt_router_listen_socket_close()
3573 joint = lev->socket.data; in nxt_router_listen_socket_close()
[all …]
H A Dnxt_controller.c643 ls->socket = -1; in nxt_runtime_controller_socket()
681 nxt_debug(task, "controller conn init fd:%d", c->socket.fd); in nxt_controller_conn_init()
707 c->socket.data = r; in nxt_controller_conn_init()
708 c->socket.read_ready = 1; in nxt_controller_conn_init()
840 c->socket.timedout = 1; in nxt_controller_conn_read_timeout()
841 c->socket.closed = 1; in nxt_controller_conn_read_timeout()
947 c->socket.timedout = 1; in nxt_controller_conn_write_timeout()
948 c->socket.closed = 1; in nxt_controller_conn_write_timeout()
H A Dnxt_port_socket.c47 port->socket.task = task; in nxt_port_socket_init()
122 nxt_socket_close(port->socket.task, port->socket.fd); in nxt_port_destroy()
130 port->socket.fd = port->pair[1]; in nxt_port_write_enable()
131 port->socket.log = &nxt_main_log; in nxt_port_write_enable()
132 port->socket.write_ready = 1; in nxt_port_write_enable()
537 } while (port->socket.write_ready); in nxt_port_write_handler()
550 &port->socket); in nxt_port_write_handler()
705 port->socket.fd = port->pair[0]; in nxt_port_read_enable()
706 port->socket.log = &nxt_main_log; in nxt_port_read_enable()
723 port->socket.read_ready = 0; in nxt_port_read_close()
[all …]
H A Dnxt_h1proto.c459 c->socket.data = h1p; in nxt_h1p_conn_proto_init()
1631 h1p = c->socket.data; in nxt_h1p_conn_request_timeout()
1656 h1p = c->socket.data; in nxt_h1p_conn_request_send_timeout()
1667 h1p = c->socket.data; in nxt_h1p_conn_request_timer_value()
1700 c->socket.task = task; in nxt_h1p_request_close()
2007 h1p = c->socket.data; in nxt_h1p_shutdown()
2051 c->socket.data = NULL; in nxt_h1p_closing()
2169 c->socket.data = peer; in nxt_h1p_peer_connect()
2180 socket = &client->socket; in nxt_h1p_peer_connect()
2456 peer = c->socket.data; in nxt_h1p_peer_io_read_handler()
[all …]
H A Dnxt_port.h18 nxt_port_handler_t socket; member
80 _NXT_PORT_MSG_SOCKET = nxt_port_handler_idx(socket),
223 nxt_fd_event_t socket; member
H A Dnxt_openssl.c795 nxt_debug(c->socket.task,
1191 ret = SSL_set_fd(s, c->socket.fd);
1253 if (c->socket.error != 0) {
1406 c->socket.write_ready = sb->ready;
1410 sb->ready = c->socket.write_ready;
1413 sb->error = c->socket.error;
1454 if (c->socket.timedout || c->socket.error != 0) {
1559 c->socket.read_ready = 0;
1572 c->socket.write_ready = 0;
1595 c->socket.closed = 1;
[all …]
H A Dnxt_main_process.c22 nxt_socket_t socket; member
601 .socket = nxt_main_port_socket_handler,
662 port->socket.task = task; in nxt_main_process_whoami_handler()
1055 ls.socket = -1; in nxt_main_port_socket_handler()
1067 (size_t) sa->length, nxt_sockaddr_start(sa), ls.socket); in nxt_main_port_socket_handler()
1089 nxt_port_socket_write(task, port, type, ls.socket, msg->port_msg.stream, in nxt_main_port_socket_handler()
1103 s = socket(sa->u.sockaddr.sa_family, sa->type, 0); in nxt_main_listening_socket()
1207 ls->socket = s; in nxt_main_listening_socket()
H A Dnxt_gnutls.c263 nxt_log_debug(c->socket.log, "gnutls conn init"); in nxt_gnutls_conn_init()
326 nxt_gnutls_conn_handshake(thr, c, c->socket.data); in nxt_gnutls_conn_init()
551 c->socket.fd, buf, size, n); in nxt_gnutls_conn_io_send()
590 if (c->socket.timedout || c->socket.error != 0) { in nxt_gnutls_conn_io_shutdown()
593 } else if (c->socket.closed) { in nxt_gnutls_conn_io_shutdown()
603 c->socket.fd, how, err); in nxt_gnutls_conn_io_shutdown()
619 c->socket.fd); in nxt_gnutls_conn_io_shutdown()
651 c->socket.read_ready = 0; in nxt_gnutls_conn_test_error()
652 c->socket.read_handler = handler; in nxt_gnutls_conn_test_error()
663 c->socket.write_ready = 0; in nxt_gnutls_conn_test_error()
[all …]
H A Dnxt_port.c180 msg->port->socket.fd, msg->port_msg.type, in nxt_port_handler()
190 msg->port->socket.fd, msg->port_msg.type); in nxt_port_handler()
301 port->socket.task = task; in nxt_port_new_port_handler()
/unit/test/unit/
H A Dhttp.py7 import socket
33 'ipv4': socket.AF_INET,
34 'ipv6': socket.AF_INET6,
35 'unix': socket.AF_UNIX,
39 sock = socket.socket(sock_types[sock_type], socket.SOCK_STREAM)
45 sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
/unit/auto/
H A Dsockets14 #include <sys/socket.h>
37 #include <sys/socket.h>
55 #include <sys/socket.h>
118 #include <sys/socket.h>
133 #include <sys/socket.h>
151 #include <sys/socket.h>
176 #include <sys/socket.h>
235 #include <sys/socket.h>
250 nxt_feature="socket(SOCK_NONBLOCK)"
256 #include <sys/socket.h>
[all …]
/unit/
H A DCHANGES765 *) Bugfix: in parsing of IPv6 control socket addresses.
H A DREADME.md95 usually available by default via a Unix domain socket:
98 # curl -X PUT --data-binary @config.json --unix-socket \
114 --unix-socket /path/to/control.unit.sock http://localhost/config/listeners
134 # curl --unix-socket /path/to/control.unit.sock http://localhost/config/
/unit/pkg/rpm/
H A DMakefile.python3949 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/unit/control.sock http://localh…
H A DMakefile.go71 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/unit/control.sock http://localh…
/unit/test/
H A Dtest_reconfigure_tls.py1 import socket
37 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
H A Dtest_static.py3 import socket
234 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
H A Dtest_tls_tickets.py1 import socket
55 sock = socket.create_connection(('127.0.0.1', port))
H A Dtest_settings.py2 import socket
171 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
H A Dtest_proxy_chunked.py3 import socket
19 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
20 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
21 sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
H A Dtest_proxy.py2 import socket
19 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
20 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
/unit/pkg/deb/
H A DMakefile.go42 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
/unit/pkg/docker/
H A Ddocker-entrypoint.sh7 …RET=`/usr/bin/curl -s -w '%{http_code}' -X PUT --data-binary @$1 --unix-socket /var/run/control.un…
32 /usr/bin/curl -s -X GET --unix-socket /var/run/control.unit.sock http://localhost/

1234