| /dports/www/trafficserver/trafficserver-9.1.1/iocore/net/ |
| H A D | SSLClientUtils.cc | 51 SSLNetVConnection *netvc = SSLNetVCAccess(ssl); in verify_callback() local
54 if (netvc == nullptr) { in verify_callback()
76 if (netvc->options.sni_servername) { in verify_callback()
100 if (netvc->options.sni_servername) { in verify_callback()
111 if (netvc->options.sni_servername) { in verify_callback()
121 netvc->set_verify_cert(ctx); in verify_callback()
122 netvc->callHooks(TS_EVENT_SSL_VERIFY_SERVER); in verify_callback()
123 netvc->set_verify_cert(nullptr); in verify_callback()
127 if (netvc->options.sni_servername) { in verify_callback()
144 SSLNetVConnection *netvc = SSLNetVCAccess(ssl); in ssl_client_cert_callback() local
[all …]
|
| H A D | SSLNextProtocolAccept.cc | 75 SSLNetVConnection *netvc; in ioCompletionEvent() local
79 ink_assert(netvc != nullptr); in ioCompletionEvent()
86 netvc->do_io_close(); in ioCompletionEvent()
98 netvc->set_action(nullptr); in ioCompletionEvent()
100 Continuation *endpoint_cont = netvc->endpoint(); in ioCompletionEvent()
108 netvc->do_io_read(endpoint_cont, 0, nullptr); in ioCompletionEvent()
113 netvc->do_io_close(); in ioCompletionEvent()
131 ink_release_assert(netvc != nullptr); in mainEvent()
140 netvc->do_io_read(new SSLNextProtocolTrampoline(this, netvc->mutex), 0, this->buffer); in mainEvent()
143 if (netvc) { in mainEvent()
[all …]
|
| H A D | QUICNextProtocolAccept.cc | 51 QUICNetVConnection *netvc = quic_netvc_cast(event, edata); in mainEvent() local
53 Debug("v_quic", "[%s] event %d netvc %p", netvc->cids().data(), event, netvc); in mainEvent()
56 ink_release_assert(netvc != nullptr); in mainEvent()
57 netvc->registerNextProtocolSet(&this->protoset, this->protoenabled); in mainEvent()
60 netvc->do_io_close(); in mainEvent()
|
| H A D | SSLUtils.cc | 266 if (!netvc || netvc->ssl != ssl) {
321 setClientCertCACerts(ssl, netvc->get_ca_cert_file(), netvc->get_ca_cert_dir());
345 if (!netvc || netvc->ssl != ssl) {
350 netvc->set_verify_cert(ctx);
352 netvc->set_verify_cert(nullptr);
383 if (!netvc || netvc->ssl != s) {
408 if (!netvc || netvc->ssl != ssl) {
1028 if (!netvc || netvc->ssl != ssl) {
1673 SSLNetVConnection *netvc; local
1678 return netvc;
[all …]
|
| H A D | I_SessionAccept.h | 77 virtual int mainEvent(int event, void *netvc) = 0;
|
| H A D | P_QUICNextProtocolAccept.h | 53 int mainEvent(int event, void *netvc);
|
| H A D | P_SSLNextProtocolAccept.h | 57 int mainEvent(int event, void *netvc) override;
|
| H A D | SSLNetVConnection.cc | 1575 SSLNetVConnection *netvc = SSLNetVCAccess(ssl); in advertise_next_protocol() local
1577 ink_release_assert(netvc && netvc->ssl == ssl); in advertise_next_protocol()
1579 if (netvc->getNPN(out, outlen)) { in advertise_next_protocol()
1592 SSLNetVConnection *netvc = SSLNetVCAccess(ssl); in select_next_protocol() local
1594 ink_release_assert(netvc && netvc->ssl == ssl); in select_next_protocol()
1597 if (netvc->getNPN(&npnptr, &npnsize)) { in select_next_protocol()
|
| H A D | P_Socks.h | 132 void init(Ptr<ProxyMutex> &m, SocksNetVC *netvc, unsigned char socks_support, unsigned char ver);
|
| /dports/www/trafficserver/trafficserver-9.1.1/proxy/ |
| H A D | ProtocolProbeSessionAccept.cc | 69 NetVConnection *netvc; in ioCompletionEvent() local
74 netvc = static_cast<NetVConnection *>(vio->vc_server); in ioCompletionEvent()
90 ink_assert(netvc != nullptr); in ioCompletionEvent()
104 …if (netvc->get_is_proxy_protocol() && netvc->get_proxy_protocol_version() == ProxyProtocolVersion:… in ioCompletionEvent()
109 if (!pp_ipmap->contains(netvc->get_remote_addr(), &payload)) { in ioCompletionEvent()
124 if (netvc->has_proxy_protocol(reader)) { in ioCompletionEvent()
126 netvc->set_remote_addr(netvc->get_proxy_protocol_src_addr()); in ioCompletionEvent()
148 netvc->do_io_read(acceptor, 0, nullptr); in ioCompletionEvent()
151 if (!acceptor->accept(netvc, this->iobuf, reader)) { in ioCompletionEvent()
159 netvc->do_io_close(); in ioCompletionEvent()
[all …]
|
| H A D | ProtocolProbeSessionAccept.h | 59 int mainEvent(int event, void *netvc) override;
|
| /dports/www/trafficserver/trafficserver-9.1.1/proxy/http/ |
| H A D | HttpSessionAccept.cc | 30 HttpSessionAccept::accept(NetVConnection *netvc, MIOBuffer *iobuf, IOBufferReader *reader) in accept() argument
32 sockaddr const *client_ip = netvc->get_remote_addr(); in accept()
43 if (HttpProxyPort::TRANSPORT_NONE == netvc->attributes) { in accept()
44 netvc->attributes = transport_type; in accept()
48 …tp_seq", "[HttpSessionAccept:mainEvent %p] accepted connection from %s transport type = %d", netvc, in accept()
49 ats_ip_nptop(client_ip, ipb, sizeof(ipb)), netvc->attributes); in accept()
59 new_session->new_connection(netvc, iobuf, reader); in accept()
67 NetVConnection *netvc; in mainEvent() local
72 netvc = static_cast<NetVConnection *>(data); in mainEvent()
73 if (!this->accept(netvc, nullptr, nullptr)) { in mainEvent()
[all …]
|
| H A D | HttpSessionManager.h | 67 static bool validate_host_sni(HttpSM *sm, NetVConnection *netvc);
68 static bool validate_sni(HttpSM *sm, NetVConnection *netvc);
69 static bool validate_cert(HttpSM *sm, NetVConnection *netvc);
|
| H A D | HttpSessionManager.cc | 79 ServerSessionPool::validate_host_sni(HttpSM *sm, NetVConnection *netvc) in validate_host_sni() argument
87 const char *session_sni = netvc->get_sni_servername(); in validate_host_sni()
101 ServerSessionPool::validate_sni(HttpSM *sm, NetVConnection *netvc) in validate_sni() argument
108 const char *session_sni = netvc->get_sni_servername(); in validate_sni()
122 ServerSessionPool::validate_cert(HttpSM *sm, NetVConnection *netvc) in validate_cert() argument
129 const char *session_cert = netvc->options.ssl_client_cert_name.get(); in validate_cert()
|
| H A D | HttpSM.cc | 529 NetVConnection *netvc = client_vc->get_netvc(); in attach_client_session() local
530 if (!netvc) { in attach_client_session()
554 mptcp_state = netvc->get_mptcp_state(); in attach_client_session()
662 NetVConnection *netvc = ua_txn->get_netvc(); in setup_blind_tunnel_port() local
663 ink_release_assert(netvc); in setup_blind_tunnel_port()
711 NetVConnection *netvc = ua_txn->get_netvc(); in state_read_client_request_header() local
712 if (!netvc && event != VC_EVENT_EOS) { in state_read_client_request_header()
788 if (netvc) { in state_read_client_request_header()
789 netvc->do_io_read(nullptr, 0, nullptr); in state_read_client_request_header()
1000 if (netvc) { in state_watch_for_client_abort()
[all …]
|
| H A D | HttpSessionAccept.h | 197 int mainEvent(int event, void *netvc) override;
|
| H A D | HttpTunnel.cc | 1287 NetVConnection *netvc = dynamic_cast<NetVConnection *>(c->write_vio->vc_server); in consumer_reenable() local
1288 if (netvc) { // really, this should always be true. in consumer_reenable()
1289 netvc->trapWriteBufferEmpty(); in consumer_reenable()
|
| /dports/www/trafficserver/trafficserver-9.1.1/proxy/http2/ |
| H A D | Http2SessionAccept.cc | 37 Http2SessionAccept::accept(NetVConnection *netvc, MIOBuffer *iobuf, IOBufferReader *reader) in accept() argument
39 sockaddr const *client_ip = netvc->get_remote_addr(); in accept()
47 netvc->attributes = this->options.transport_type; in accept()
52 …2_seq", "[HttpSessionAccept2:mainEvent %p] accepted connection from %s transport type = %d", netvc, in accept()
53 ats_ip_nptop(client_ip, ipb, sizeof(ipb)), netvc->attributes); in accept()
62 new_session->new_connection(netvc, iobuf, reader); in accept()
74 NetVConnection *netvc = static_cast<NetVConnection *>(data); in mainEvent() local
75 if (!this->accept(netvc, nullptr, nullptr)) { in mainEvent()
76 netvc->do_io_close(); in mainEvent()
|
| H A D | Http2SessionAccept.h | 46 int mainEvent(int event, void *netvc) override;
|
| /dports/www/trafficserver/trafficserver-9.1.1/proxy/http3/ |
| H A D | Http3SessionAccept.cc | 42 Http3SessionAccept::accept(NetVConnection *netvc, MIOBuffer *iobuf, IOBufferReader *reader) in accept() argument
44 sockaddr const *client_ip = netvc->get_remote_addr(); in accept()
52 netvc->attributes = this->options.transport_type; in accept()
54 QUICNetVConnection *qvc = static_cast<QUICNetVConnection *>(netvc); in accept()
60 ats_ip_nptop(client_ip, ipb, sizeof(ipb)), netvc->attributes); in accept()
88 NetVConnection *netvc; in mainEvent() local
93 netvc = static_cast<NetVConnection *>(data); in mainEvent()
94 if (!this->accept(netvc, nullptr, nullptr)) { in mainEvent()
95 netvc->do_io_close(); in mainEvent()
|
| H A D | Http3SessionAccept.h | 47 int mainEvent(int event, void *netvc);
|
| /dports/www/trafficserver/trafficserver-9.1.1/plugins/experimental/memcache/ |
| H A D | tsmemcache.h | 84 int main_event(int event, void *netvc);
196 void new_connection(NetVConnection *netvc, EThread *thread);
|
| H A D | tsmemcache.cc | 126 NetVConnection *netvc = (NetVConnection *)data; in main_event() local
129 mc->new_connection(netvc, netvc->thread); in main_event()
131 mc->new_connection(netvc, mutex->thread_holding); in main_event()
141 MC::new_connection(NetVConnection *netvc, EThread *thread) in new_connection() argument
143 nvc = netvc; in new_connection()
|