/unit/src/ |
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_conn_close.c | 30 nxt_debug(c->socket.task, "conn close fd:%d, to:%d", in nxt_conn_close() 31 c->socket.fd, c->socket.timedout); in nxt_conn_close() 39 if (c->socket.timedout) { in nxt_conn_close() 61 if (c->socket.error == 0 && !c->socket.closed && !c->socket.shutdown) { in nxt_conn_close() 85 c->socket.shutdown = 1; in nxt_conn_shutdown_handler() 119 nxt_socket_close(task, c->socket.fd); in nxt_conn_close_handler() 120 c->socket.fd = -1; in nxt_conn_close_handler() 156 if (c->socket.fd != -1) { in nxt_conn_close_timer_handler() 157 nxt_socket_close(task, c->socket.fd); in nxt_conn_close_timer_handler() 158 c->socket.fd = -1; in nxt_conn_close_timer_handler() [all …]
|
H A D | nxt_linux_sendfile.c | 113 c->socket.write_ready = 0; in nxt_linux_event_conn_io_sendfile() 120 c->socket.error = err; in nxt_linux_event_conn_io_sendfile() 135 c->socket.write_ready = 0; in nxt_linux_event_conn_io_sendfile() 159 c->socket.write_ready = 0; in nxt_linux_send() 166 c->socket.error = err; in nxt_linux_send() 180 c->socket.write_ready = 0; in nxt_linux_send() 203 n = sendmsg(c->socket.fd, &msg, flags); in nxt_linux_sendmsg() 208 c->socket.fd, niov, flags, n); in nxt_linux_sendmsg() 214 c->socket.write_ready = 0; in nxt_linux_sendmsg() 221 c->socket.error = err; in nxt_linux_sendmsg() [all …]
|
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_conn_accept.c | 46 lev->socket.fd = ls->socket; in nxt_listen_event() 55 lev->socket.log = &nxt_main_log; in nxt_listen_event() 69 lev->socket.task = &lev->task; in nxt_listen_event() 106 c->socket.read_work_queue = lev->socket.read_work_queue; in nxt_conn_accept_alloc() 107 c->socket.write_ready = 1; in nxt_conn_accept_alloc() 168 c->socket.fd = s; in nxt_conn_io_accept() 208 c->socket.data = NULL; in nxt_conn_accept() 297 c->socket.fd, c->socket.read_ready); in nxt_conn_accept_close_idle_handler() 299 if (!c->socket.read_ready) { in nxt_conn_accept_close_idle_handler() 304 c->read_state->close_handler(c->socket.task, c, c->socket.data); in nxt_conn_accept_close_idle_handler() [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 …]
|
H A D | nxt_macosx_sendfile.c | 48 nhd = nxt_sendbuf_mem_coalesce(c->socket.task, &sb); in nxt_macosx_event_conn_io_sendfile() 69 ntr = nxt_sendbuf_mem_coalesce(c->socket.task, &sb); in nxt_macosx_event_conn_io_sendfile() 104 nxt_log_debug(c->socket.log, in nxt_macosx_event_conn_io_sendfile() 106 fb->file->fd, c->socket.fd, fb->file_pos, sent, in nxt_macosx_event_conn_io_sendfile() 109 n = nxt_sys_sendfile(fb->file->fd, c->socket.fd, in nxt_macosx_event_conn_io_sendfile() 120 c->socket.write_ready = 0; in nxt_macosx_event_conn_io_sendfile() 127 c->socket.error = err; in nxt_macosx_event_conn_io_sendfile() 128 nxt_log(c->socket.task, nxt_socket_error_level(err), in nxt_macosx_event_conn_io_sendfile() 136 nxt_debug(c->socket.task, "sendfile() %E", err); in nxt_macosx_event_conn_io_sendfile() 142 nxt_log(c->socket.task, NXT_LOG_ERR, in nxt_macosx_event_conn_io_sendfile() [all …]
|
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_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_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_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_solaris_sendfilev.c | 45 nxt_debug(c->socket.task, "sendfilev(%d, %D)", c->socket.fd, nsfv); in nxt_solaris_event_conn_io_sendfilev() 52 n = sendfilev(c->socket.fd, sfv, nsfv, &sent); in nxt_solaris_event_conn_io_sendfilev() 56 nxt_debug(c->socket.task, "sendfilev(): %d sent:%uz", n, sent); in nxt_solaris_event_conn_io_sendfilev() 62 c->socket.write_ready = 0; in nxt_solaris_event_conn_io_sendfilev() 69 c->socket.error = err; in nxt_solaris_event_conn_io_sendfilev() 70 nxt_log(c->socket.task, nxt_socket_error_level(err), in nxt_solaris_event_conn_io_sendfilev() 71 "sendfilev(%d, %D) failed %E", c->socket.fd, nsfv, err); in nxt_solaris_event_conn_io_sendfilev() 76 nxt_debug(c->socket.task, "sendfilev() %E", err); in nxt_solaris_event_conn_io_sendfilev() 82 c->socket.write_ready = 0; in nxt_solaris_event_conn_io_sendfilev()
|
H A D | nxt_gnutls.c | 263 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 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_port_socket.c | 47 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 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_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_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 …]
|
H A D | nxt_kqueue_engine.c | 866 c->socket.write_ready = 1; in nxt_kqueue_conn_io_connect() 921 lev->socket.fd, lev->socket.kq_available); in nxt_kqueue_listen_handler() 944 lev->socket.kq_available--; in nxt_kqueue_conn_io_accept() 945 lev->socket.read_ready = (lev->socket.kq_available != 0); in nxt_kqueue_conn_io_accept() 956 c->socket.fd = s; in nxt_kqueue_conn_io_accept() 982 if (c->socket.kq_available == 0 && c->socket.kq_eof) { in nxt_kqueue_conn_io_read() 985 c->socket.closed = 1; in nxt_kqueue_conn_io_read() 1006 if (c->socket.kq_available == 0 && c->socket.kq_eof) { in nxt_kqueue_conn_io_recvbuf() 1007 c->socket.closed = 1; in nxt_kqueue_conn_io_recvbuf() 1021 c->socket.fd, c->socket.kq_available, c->socket.kq_eof); in nxt_kqueue_conn_io_recvbuf() [all …]
|
/unit/test/ |
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)
|
H A D | test_configuration.py | 1 import socket 276 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s: 277 s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
|
H A D | test_reconfigure_tls.py | 1 import socket 41 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
/unit/auto/ |
H A D | sockets | 14 #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/src/nodejs/unit-http/ |
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/test/unit/ |
H A D | utils.py | 3 import socket 60 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
|