Home
last modified time | relevance | path

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

1234

/unit/docs/
H A Dunit-openapi.yaml27 socket. To use this specification with OpenAPI tools interactively,
29 with a TCP port as the control socket."
/unit/
H A DCHANGES14 *) 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 Dtest_reconfigure_tls.py1 import socket
41 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
H A Dtest_settings.py2 import socket
265 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
H A Dtest_static.py2 import socket
178 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
H A Dtest_proxy_chunked.py3 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 Dnxt_router.c1363 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 Dnxt_main_process.c25 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 Dnxt_listen_socket.c199 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 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()
1260 ls->socket = -1; in nxt_runtime_listen_socket_add()
H A Dnxt_conn_write.c28 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 Dnxt_socket.c28 s = socket(domain, type, protocol); in nxt_socket_create()
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 …]
/unit/auto/
H A Dhelp38 --control=ADDRESS set address of control API socket
/unit/tools/
H A Dsetup-unit104 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 DREADME.md51 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 Dhttp_server.js25 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 Dunit.cpp315 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 Dwebsocket_request.js87 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 Dwebsocket_connection.js59 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 DMakefile.python31245 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/unit/control.sock http://localh…
H A DMakefile.jsc1773 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/unit/control.sock http://localh…
/unit/pkg/deb/
H A DMakefile.jsc2146 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
H A DMakefile.python31238 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
/unit/test/unit/
H A Dhttp.py7 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)

1234