Home
last modified time | relevance | path

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

1234

/unit/src/
H A Dnxt_freebsd_sendfile.c53 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 Dnxt_hpux_sendfile.c51 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 Dnxt_epoll_engine.c1031 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 Dnxt_conn_proxy.c85 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 Dnxt_conn_read.c17 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 Dnxt_cyassl.c183 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 Dnxt_event_conn_job_sendfile.c32 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 Dnxt_conn.c55 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 Dnxt_conn_connect.c22 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 Dnxt_aix_send_file.c35 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 Dwebsocket_server.js161 WebSocketServer.prototype.handleUpgrade = function(request, socket) { argument
162 var wsRequest = new WebSocketRequest(socket, request, this.config);
/unit/pkg/rpm/
H A DMakefile.jsc1160 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/unit/control.sock http://localh…
H A DMakefile.jsc862 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/unit/control.sock http://localh…
/unit/pkg/deb/
H A DMakefile.python2738 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
H A DMakefile.python3638 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
H A DMakefile.python3738 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
H A DMakefile.python3838 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
H A DMakefile.ruby40 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
H A DMakefile.jsc1046 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
H A DMakefile.jsc846 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
H A DMakefile.perl38 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
H A DMakefile.php45 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…
H A DMakefile.jsc1146 …sudo curl -X PUT --data-binary @unit.config --unix-socket /var/run/control.unit.sock http://localh…

1234