/unit/src/ |
H A D | nxt_freebsd_sendfile.c | 53 nhd = nxt_sendbuf_mem_coalesce(c->socket.task, &sb); in nxt_freebsd_event_conn_io_sendfile() 73 ntr = nxt_sendbuf_mem_coalesce(c->socket.task, &sb); in nxt_freebsd_event_conn_io_sendfile() 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() 105 nxt_debug(c->socket.task, "sendfile(): %d sent:%O", n, sent); in nxt_freebsd_event_conn_io_sendfile() 111 c->socket.write_ready = 0; in nxt_freebsd_event_conn_io_sendfile() 118 c->socket.error = err; in nxt_freebsd_event_conn_io_sendfile() 119 nxt_log(c->socket.task, nxt_socket_error_level(err), in nxt_freebsd_event_conn_io_sendfile() 127 nxt_debug(c->socket.task, "sendfile() %E", err); in nxt_freebsd_event_conn_io_sendfile() 132 nxt_log(c->socket.task, NXT_LOG_ERR, in nxt_freebsd_event_conn_io_sendfile() [all …]
|
H A D | nxt_hpux_sendfile.c | 51 nhd = nxt_sendbuf_mem_coalesce(c->socket.task, &sb); in nxt_hpux_event_conn_io_sendfile() 72 ntr = nxt_sendbuf_mem_coalesce(c->socket.task, &sb); in nxt_hpux_event_conn_io_sendfile() 96 nxt_debug(c->socket.task, "sendfile(%d, %FD, @%O, %uz) hd:%ui tr:%ui", in nxt_hpux_event_conn_io_sendfile() 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() 105 nxt_debug(c->socket.task, "sendfile(): %uz", n); in nxt_hpux_event_conn_io_sendfile() 111 c->socket.write_ready = 0; in nxt_hpux_event_conn_io_sendfile() 118 c->socket.error = err; in nxt_hpux_event_conn_io_sendfile() 119 nxt_log(c->socket.task, nxt_socket_error_level(err), in nxt_hpux_event_conn_io_sendfile() 127 nxt_debug(c->socket.task, "sendfile() %E", err); in nxt_hpux_event_conn_io_sendfile() [all …]
|
H A D | nxt_epoll_engine.c | 1031 c->socket.fd = s; in nxt_epoll_conn_io_accept4() 1072 c->socket.write_ready = 1; in nxt_epoll_edge_conn_io_connect() 1083 nxt_epoll_enable(engine, &c->socket); in nxt_epoll_edge_conn_io_connect() 1084 c->socket.read = NXT_EVENT_BLOCKED; in nxt_epoll_edge_conn_io_connect() 1100 c->socket.read_ready = 1; in nxt_epoll_edge_conn_io_connect() 1101 c->socket.write_ready = 1; in nxt_epoll_edge_conn_io_connect() 1110 c->socket.read = NXT_EVENT_BLOCKED; in nxt_epoll_edge_conn_io_connect() 1138 if (!c->socket.epoll_error) { in nxt_epoll_edge_conn_connected() 1139 c->socket.write = NXT_EVENT_BLOCKED; in nxt_epoll_edge_conn_connected() 1167 if (n > 0 && c->socket.epoll_eof) { in nxt_epoll_edge_conn_io_recvbuf() [all …]
|
H A D | nxt_conn_proxy.c | 85 peer->socket.data = client->socket.data; in nxt_conn_proxy_create() 384 sink->socket.fd, sink->socket.error); in nxt_conn_proxy_read_process() 756 c->socket.closed = 1; in nxt_conn_proxy_read_timeout() 774 c->socket.closed = 1; in nxt_conn_proxy_write_timeout() 809 peer->socket.fd = -1; in nxt_conn_proxy_refused() 832 p = peer->socket.data; in nxt_conn_proxy_reconnect_handler() 858 source->socket.fd, source->socket.closed, source->socket.error); in nxt_conn_proxy_shutdown() 862 sink->socket.fd, sink->socket.closed, sink->socket.error); in nxt_conn_proxy_shutdown() 869 if (sink->socket.error == 0 && !sink->socket.closed) { in nxt_conn_proxy_shutdown() 948 p->client->socket.fd, p->peer->socket.fd); in nxt_conn_proxy_complete() [all …]
|
H A D | nxt_conn_read.c | 17 c->socket.fd, c->socket.read_ready); in nxt_conn_wait() 22 if (c->socket.read_ready) { in nxt_conn_wait() 24 c->socket.task, c, c->socket.data); in nxt_conn_wait() 49 c->socket.fd, c->socket.read_ready, c->socket.closed, in nxt_conn_io_read() 66 if (c->socket.read_ready) { in nxt_conn_io_read() 107 if (c->socket.read_ready) { in nxt_conn_io_read() 157 nxt_debug(c->socket.task, "readv(%d, %ui): %z", c->socket.fd, niov, n); in nxt_conn_io_recvbuf() 168 c->socket.closed = 1; in nxt_conn_io_recvbuf() 187 c->socket.error = err; in nxt_conn_io_recvbuf() 220 c->socket.closed = 1; in nxt_conn_io_recv() [all …]
|
H A D | nxt_cyassl.c | 183 nxt_log_debug(c->socket.log, "cyassl conn init"); in nxt_cyassl_conn_init() 217 nxt_cyassl_conn_handshake(thr, c, c->socket.data); in nxt_cyassl_conn_init() 327 c->socket.fd); in nxt_cyassl_conn_handshake() 416 nxt_log_debug(c->socket.log, "cyassl send"); in nxt_cyassl_conn_io_send() 424 c->socket.error = err; in nxt_cyassl_conn_io_send() 431 c->socket.fd, buf, size, ret); in nxt_cyassl_conn_io_send() 492 c->socket.read_ready = 0; in nxt_cyassl_conn_test_error() 493 c->socket.read_handler = handler; in nxt_cyassl_conn_test_error() 504 c->socket.write_ready = 0; in nxt_cyassl_conn_test_error() 505 c->socket.write_handler = handler; in nxt_cyassl_conn_test_error() [all …]
|
H A D | nxt_event_conn_job_sendfile.c | 32 nxt_fd_event_disable(task->thread->engine, &c->socket); in nxt_event_conn_job_sendfile() 49 nxt_debug(task, "event conn sendfile fd:%d", c->socket.fd); in nxt_event_conn_job_sendfile_start() 58 c->socket.write_handler = nxt_event_conn_job_sendfile_start; in nxt_event_conn_job_sendfile_start() 59 c->socket.error_handler = c->write_state->error_handler; in nxt_event_conn_job_sendfile_start() 78 jbs->job.log = c->socket.log; in nxt_event_conn_job_sendfile_start() 109 first = c->socket.write_ready; in nxt_event_conn_job_sendfile_handler() 142 } while (c->socket.write_ready); in nxt_event_conn_job_sendfile_handler() 212 if (c->socket.error == 0 in nxt_event_conn_job_sendfile_return() 223 task, c, c->socket.data); in nxt_event_conn_job_sendfile_return() 230 if (nxt_slow_path(c->socket.error != 0)) { in nxt_event_conn_job_sendfile_return() [all …]
|
H A D | nxt_conn.c | 55 c->socket.fd = -1; in nxt_conn_create() 57 c->socket.log = &c->log; in nxt_conn_create() 72 c->socket.task = &c->task; in nxt_conn_create() 80 c->socket.read_work_queue = &thr->engine->fast_work_queue; in nxt_conn_create() 81 c->socket.write_work_queue = &thr->engine->fast_work_queue; in nxt_conn_create() 83 nxt_conn_timer_init(&c->read_timer, c, c->socket.read_work_queue); in nxt_conn_create() 84 nxt_conn_timer_init(&c->write_timer, c, c->socket.write_work_queue); in nxt_conn_create() 169 ret = getsockname(c->socket.fd, &sa->u.sockaddr, &socklen); in nxt_conn_local_addr() 171 nxt_alert(task, "getsockname(%d) failed", c->socket.fd); in nxt_conn_local_addr()
|
H A D | nxt_conn_connect.c | 22 c->socket.write_work_queue = c->write_work_queue; in nxt_conn_sys_socket() 49 c->socket.write_ready = 1; in nxt_conn_io_connect() 54 c->socket.write_handler = nxt_conn_connect_test; in nxt_conn_io_connect() 55 c->socket.error_handler = nxt_conn_connect_error; in nxt_conn_io_connect() 61 nxt_fd_event_enable_write(engine, &c->socket); in nxt_conn_io_connect() 104 c->socket.fd = s; in nxt_conn_socket() 106 c->socket.task = task; in nxt_conn_socket() 157 err = c->socket.error; in nxt_conn_connect_error() 192 err = nxt_socket_error(c->socket.fd); in nxt_conn_connect_test_error() 195 c->socket.error = err; in nxt_conn_connect_test_error() [all …]
|
H A D | nxt_aix_send_file.c | 35 nhd = nxt_sendbuf_mem_coalesce(c->socket.task, &sb); in nxt_aix_event_conn_io_send_file() 56 ntr = nxt_sendbuf_mem_coalesce(c->socket.task, &sb); in nxt_aix_event_conn_io_send_file() 74 nxt_debug(c->socket.task, "send_file(%d) fd:%FD @%O:%O hd:%ui tr:%ui", in nxt_aix_event_conn_io_send_file() 77 n = send_file(&c->socket.fd, &sfp, 0); in nxt_aix_event_conn_io_send_file() 82 nxt_debug(c->socket.task, "send_file(%d): %d sent:%O", in nxt_aix_event_conn_io_send_file() 83 c->socket.fd, n, sent); in nxt_aix_event_conn_io_send_file() 96 c->socket.write_ready = 0; in nxt_aix_event_conn_io_send_file() 103 c->socket.error = err; in nxt_aix_event_conn_io_send_file() 104 nxt_log(c->socket.task, nxt_socket_error_level(err), in nxt_aix_event_conn_io_send_file() 112 nxt_debug(c->socket.task, "sendfile() %E", err); in nxt_aix_event_conn_io_send_file() [all …]
|
/unit/src/nodejs/unit-http/ |
H A D | websocket_server.js | 161 WebSocketServer.prototype.handleUpgrade = function(request, socket) { argument 162 var wsRequest = new WebSocketRequest(socket, request, this.config);
|
/unit/pkg/rpm/ |
H A D | Makefile.jsc11 | 60 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/unit/control.sock http://localh…
|
H A D | Makefile.jsc8 | 62 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/unit/control.sock http://localh…
|
/unit/pkg/deb/ |
H A D | Makefile.python27 | 38 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
|
H A D | Makefile.python36 | 38 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
|
H A D | Makefile.python37 | 38 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
|
H A D | Makefile.python38 | 38 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
|
H A D | Makefile.ruby | 40 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
|
H A D | Makefile.jsc10 | 46 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
|
H A D | Makefile.jsc8 | 46 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
|
H A D | Makefile.perl | 38 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
|
H A D | Makefile.php | 45 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
|
H A D | Makefile.jsc11 | 46 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
|