/unit/docs/ |
H A D | unit-openapi.yaml | 27 socket. To use this specification with OpenAPI tools interactively, 29 with a TCP port as the control socket."
|
/unit/ |
H A D | CHANGES | 14 *) Feature: options to set control socket permissions. 29 *) Bugfix: abstract UNIX socket name could be corrupted during 195 *) Change: disallowed abstract Unix domain socket syntax in non-Linux 993 *) Bugfix: in parsing of IPv6 control socket addresses.
|
/unit/test/ |
H A D | test_reconfigure_tls.py | 1 import socket 41 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
H A D | test_settings.py | 2 import socket 265 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
|
H A D | test_static.py | 2 import socket 178 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
|
H A D | test_proxy_chunked.py | 3 import socket 36 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 37 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 38 sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
|
/unit/src/ |
H A D | nxt_router.c | 1363 s = skcf->listen->socket; in nxt_router_conf_error() 2717 ls->socket = -1; in nxt_router_socket_conf() 3689 lev->socket.data = joint; in nxt_router_listen_socket_create() 3712 fd = skcf->listen->socket; in nxt_router_listen_event() 3747 old = lev->socket.data; in nxt_router_listen_socket_update() 3748 lev->socket.data = joint; in nxt_router_listen_socket_update() 3782 lev->socket.fd); in nxt_router_listen_socket_delete() 3784 joint = lev->socket.data; in nxt_router_listen_socket_delete() 3823 lev->socket.fd); in nxt_router_listen_socket_close() 3827 joint = lev->socket.data; in nxt_router_listen_socket_close() [all …]
|
H A D | nxt_main_process.c | 25 nxt_socket_t socket; member 676 .socket = nxt_main_port_socket_handler, 742 port->socket.task = task; in nxt_main_process_whoami_handler() 1139 ls.socket = -1; in nxt_main_port_socket_handler() 1151 (size_t) sa->length, nxt_sockaddr_start(sa), ls.socket); in nxt_main_port_socket_handler() 1173 nxt_port_socket_write(task, port, type, ls.socket, msg->port_msg.stream, in nxt_main_port_socket_handler() 1187 s = socket(sa->u.sockaddr.sa_family, sa->type, 0); in nxt_main_listening_socket() 1297 ls->socket = s; in nxt_main_listening_socket()
|
H A D | nxt_listen_socket.c | 199 ls->socket = s; in nxt_listen_socket_create() 235 ls->socket = prev->socket; in nxt_listen_socket_update() 244 nxt_debug(task, "listen(%d, %d)", ls->socket, ls->backlog); in nxt_listen_socket_update() 246 if (listen(ls->socket, ls->backlog) != 0) { in nxt_listen_socket_update() 248 ls->socket, ls->backlog, nxt_socket_errno); in nxt_listen_socket_update()
|
H A D | nxt_runtime.c | 195 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() 1260 ls->socket = -1; in nxt_runtime_listen_socket_add()
|
H A D | nxt_conn_write.c | 28 c->socket.fd, c->socket.error, c->block_write); in nxt_conn_io_write() 45 sb.socket = c->socket.fd; in nxt_conn_io_write() 60 c->socket.write_ready = sb.ready; in nxt_conn_io_write() 61 c->socket.error = sb.error; in nxt_conn_io_write() 80 if (!c->socket.write_ready) { in nxt_conn_io_write() 159 c->io->write(task, c, c->socket.data); in nxt_conn_write_timer_handler() 476 nxt_debug(c->socket.task, "writev(%d, %ui): %z", c->socket.fd, niob, n); in nxt_event_conn_io_writev() 488 c->socket.write_ready = 0; in nxt_event_conn_io_writev() 496 c->socket.error = err; in nxt_event_conn_io_writev() 529 c->socket.write_ready = 0; in nxt_event_conn_io_send() [all …]
|
H A D | nxt_socket.c | 28 s = socket(domain, type, protocol); in nxt_socket_create()
|
H A D | nxt_openssl.c | 795 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 …]
|
/unit/auto/ |
H A D | help | 38 --control=ADDRESS set address of control API socket
|
/unit/tools/ |
H A D | setup-unit | 104 ctl Control a running unitd(8) instance via its control API socket. 125 sock Print the control API socket address. 238 Control a running unitd(8) instance through its control API socket. 246 http Send an HTTP request to the control API socket. 256 Use SOCK as the control API socket address. If not specified, 259 The socket can be a tcp(7) socket or a unix(7) socket; in 260 the case of a unix(7) socket, it can exist locally or on 373 sent back to the control API socket. 458 Send an HTTP request to the unitd(8) control API socket. 877 sfd = socket(PF_INET, SOCK_STREAM, 0);
|
H A D | README.md | 51 For local instances of Unit, the control socket is automatically detected. 68 For remote instances of NGINX Unit, the control socket on the remote host can 69 be set with the `$UNIT_CTRL` environment variable. The remote control socket 71 the type of control socket: 73 * `ssh://[user@]remote_host[:ssh_port]/path/to/control.socket` 75 * `docker://container_ID[/path/to/control.socket]` 78 > [security implications](https://unit.nginx.org/howto/security/#secure-socket-and-state) 83 | `ssh://…` | Specify the remote Unix control socket on the command line. 85 | `docker://…` | Specify the local container ID/name. The default Unix control socket can be overri…
|
/unit/src/nodejs/unit-http/ |
H A D | http_server.js | 25 this.socket = req.socket; 54 ServerResponse.prototype.assignSocket = function assignSocket(socket) { argument 57 ServerResponse.prototype.detachSocket = function detachSocket(socket) { argument 288 this.socket.writable = false; 360 function ServerRequest(server, socket) { argument 364 this.socket = socket; 365 this.connection = socket; 496 this.emit('upgrade', req, req.socket); 542 if (resp.socket.writable) { 546 resp.socket.writable = true; [all …]
|
H A D | unit.cpp | 315 napi_value socket, request, response, server_obj, emit_request; in request_handler() local 324 socket = create_socket(server_obj, req); in request_handler() 325 request = create_request(server_obj, socket, req); in request_handler() 674 Unit::create_request(napi_value server_obj, napi_value socket, in create_request() argument 682 res = new_instance(constructor, server_obj, socket); in create_request()
|
H A D | websocket_request.js | 87 function WebSocketRequest(socket, httpRequest, serverConfig) { argument 91 this.socket = socket; 94 this.remoteAddress = socket.remoteAddress; 101 this.socket.on('end', this._socketCloseHandler); 102 this.socket.on('close', this._socketCloseHandler); 427 …var connection = new WebSocketConnection(this.socket, [], acceptedProtocol, false, this.serverConf… 488 this.socket.removeListener('end', this._socketCloseHandler); 489 this.socket.removeListener('close', this._socketCloseHandler);
|
H A D | websocket_connection.js | 59 this.socket = socket; 62 this.remoteAddress = socket.remoteAddress; 92 this.socket.setTimeout(0); 98 this.socket.removeAllListeners('error'); 100 this._set_sock(this.socket); 185 this.socket.destroy(error); 204 this.socket.end(); 284 this.socket.destroy(); 314 this.socket.end(); 463 this.socket.end(); [all …]
|
/unit/pkg/rpm/ |
H A D | Makefile.python312 | 45 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/unit/control.sock http://localh…
|
H A D | Makefile.jsc17 | 73 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/unit/control.sock http://localh…
|
/unit/pkg/deb/ |
H A D | Makefile.jsc21 | 46 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
|
H A D | Makefile.python312 | 38 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
|
/unit/test/unit/ |
H A D | http.py | 7 import socket 34 'ipv4': socket.AF_INET, 35 'ipv6': socket.AF_INET6, 36 'unix': socket.AF_UNIX, 40 sock = socket.socket(sock_types[sock_type], socket.SOCK_STREAM) 43 sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
|