Home
last modified time | relevance | path

Searched refs:vc (Results 1 – 25 of 70) sorted by relevance

123

/trafficserver/iocore/net/
H A DUnixNetAccept.cc86 if (!vc) { in net_accept()
93 vc->con.move(con); in net_accept()
116 vc->mutex = h->mutex; in net_accept()
128 t->schedule_imm(vc); in net_accept()
331 if (unlikely(!vc)) { in do_blocking_accept()
337 vc->con.move(con); in do_blocking_accept()
345 vc->apply_options(); in do_blocking_accept()
362 vc->mutex = h->mutex; in do_blocking_accept()
487 vc->con.move(con); in acceptFastEvent()
495 vc->apply_options(); in acceptFastEvent()
[all …]
H A DUnixNetVConnection.cc45 if (vc->read.triggered && vc->read.enabled) { in read_reschedule()
56 if (vc->write.triggered && vc->write.enabled) { in write_reschedule()
81 vc->recursion++; in read_signal_and_update()
83 vc->read.vio.cont->handleEvent(event, &vc->read.vio); in read_signal_and_update()
99 if (!--vc->recursion && vc->closed) { in read_signal_and_update()
102 vc->nh->free_netevent(vc); in read_signal_and_update()
112 vc->recursion++; in write_signal_and_update()
114 vc->write.vio.cont->handleEvent(event, &vc->write.vio); in write_signal_and_update()
130 if (!--vc->recursion && vc->closed) { in write_signal_and_update()
133 vc->nh->free_netevent(vc); in write_signal_and_update()
[all …]
H A DQUICNetProcessor.cc86 QUICNetVConnection *vc; in allocate_vc() local
98 vc->ep.syscall = false; in allocate_vc()
99 return vc; in allocate_vc()
111 vc->options = *opt; in connect_re()
113 opt = &vc->options; in connect_re()
120 vc->free(t); in connect_re()
148 packet_handler->init(vc); in connect_re()
155 vc->mutex = cont->mutex; in connect_re()
156 vc->action_ = cont; in connect_re()
163 vc->connectUp(t, NO_FD); in connect_re()
[all …]
H A DQUICNet.cc73 SCOPED_MUTEX_LOCK(lock, vc->mutex, this_ethread()); in _process_long_header_packet()
74 vc->read.triggered = 1; in _process_long_header_packet()
75 vc->handle_received_packet(p); in _process_long_header_packet()
82 if (vc) { in _process_long_header_packet()
84 vc->read.triggered = 1; in _process_long_header_packet()
85 vc->handle_received_packet(p); in _process_long_header_packet()
91 if (vc != nullptr) { in _process_long_header_packet()
94 nh->read_enable_list.push(vc); in _process_long_header_packet()
108 vc->read.triggered = 1; in _process_short_header_packet()
109 vc->handle_received_packet(p); in _process_short_header_packet()
[all …]
H A DUnixNetPages.cc66 auto vc = dynamic_cast<UnixNetVConnection *>(ne); in showConnectionsOnThread() local
68 …if (vc == nullptr || (ats_is_ip(&addr) && !ats_ip_addr_port_eq(&addr.sa, vc->get_remote_addr()))) … in showConnectionsOnThread()
74 ats_ip_ntop(vc->get_remote_addr(), ipbuf, sizeof(ipbuf)); in showConnectionsOnThread()
77 …snprintf(interbuf, sizeof(interbuf), "[%s] %s:%d", vc->options.toString(vc->options.addr_binding), in showConnectionsOnThread()
78vc->options.local_ip.toString(opt_ipbuf, sizeof(opt_ipbuf)), vc->options.local_port); in showConnectionsOnThread()
100vc->id, ipbuf, ats_ip_port_host_order(vc->get_remote_addr()), vc->con.fd, interbuf, in showConnectionsOnThread()
102 …(int)((now - vc->submit_time) / HRTIME_SECOND), ethread->id, vc->read.enabled, vc->read.vio.nbytes… in showConnectionsOnThread()
103vc->read.vio.ndone, vc->write.enabled, vc->write.vio.nbytes, vc->write.vio.ndone, in showConnectionsOnThread()
104 … (int)(vc->inactivity_timeout_in / HRTIME_SECOND), (int)(vc->active_timeout_in / HRTIME_SECOND), in showConnectionsOnThread()
105 vc->f.shutdown, vc->closed ? "closed " : "")); in showConnectionsOnThread()
H A DQUICPacketHandler.cc296 if ((!vc && !QUICInvariants::is_long_header(buf)) || (vc && vc->in_closed_queue)) { in _recv_packet()
303 } else if (vc && vc->in_closed_queue) { in _recv_packet()
316 if (!vc) { in _recv_packet()
334 vc->con.move(con); in _recv_packet()
336 vc->thread = eth; in _recv_packet()
338 vc->action_ = *this->action_; in _recv_packet()
344 qc = vc; in _recv_packet()
346 eth = vc->thread; in _recv_packet()
362 …this->_send_packet(packet, vc->get_udp_con(), vc->con.addr, vc->pmtu(), &ph_protector, vc->peer_co… in send_packet()
368 this->_send_packet(vc->get_udp_con(), vc->con.addr, udp_payload); in send_packet()
[all …]
H A DUnixNetProcessor.cc190 vc->options = *opt; in connect_re_internal()
192 opt = &vc->options; in connect_re_internal()
210 vc->mutex = cont->mutex; in connect_re_internal()
211 Action *result = &vc->action_; in connect_re_internal()
214 vc->con.setRemote(target); in connect_re_internal()
234 vc->action_ = socksEntry; in connect_re_internal()
237 vc->action_ = cont; in connect_re_internal()
245 ret = vc->connectUp(t, NO_FD); in connect_re_internal()
254 t->schedule_imm(vc); in connect_re_internal()
331 UnixNetVConnection *vc; in allocate_vc() local
[all …]
H A DSSLDiags.h32 #define SSLErrorVC(vc, fmt, ...) SSLDiagnostic(MakeSourceLocation(), false, (vc), fmt, ##__VA_ARGS_… argument
35 #define SSLVCDebug(vc, fmt, ...) SSLDiagnostic(MakeSourceLocation(), true, (vc), fmt, ##__VA_ARGS__… argument
37 void SSLDiagnostic(const SourceLocation &loc, bool debug, SSLNetVConnection *vc, const char *fmt, .…
H A Dtest_P_Net.cc30 NetVConnection *vc; member
37 vc = _vc; in NetTesterSM()
41 read_vio = vc->do_io_read(this, INT64_MAX, buf); in NetTesterSM()
66 vc->do_io_close(); in handle_read()
83 NetVConnection *vc = (NetVConnection *)data; in handle_accept() local
84 new NetTesterSM(new_ProxyMutex(), vc); in handle_accept()
H A DSSLNetProcessor.cc101 SSLNetVConnection *vc; in allocate_vc() local
104 vc = THREAD_ALLOC_INIT(sslNetVCAllocator, t); in allocate_vc()
106 if (likely(vc = sslNetVCAllocator.alloc())) { in allocate_vc()
107 vc->from_accept_thread = true; in allocate_vc()
111 return vc; in allocate_vc()
H A DSSLDiags.cc125 SSLDiagnostic(const SourceLocation &loc, bool debug, SSLNetVConnection *vc, const char *fmt, ...) in SSLDiagnostic() argument
135 if (vc) { in SSLDiagnostic()
136 ats_ip_ntop(vc->get_remote_addr(), ip_buf, sizeof(ip_buf)); in SSLDiagnostic()
144 …(flags & ERR_TXT_STRING) ? ":" : "", (flags & ERR_TXT_STRING) ? data : "", vc ? ": peer address is… in SSLDiagnostic()
149 …(flags & ERR_TXT_STRING) ? ":" : "", (flags & ERR_TXT_STRING) ? data : "", vc ? ": peer address is… in SSLDiagnostic()
155 if (vc) { in SSLDiagnostic()
157 if (vc->get_context() == NET_VCONNECTION_OUT) { in SSLDiagnostic()
/trafficserver/example/plugins/c-api/intercept/
H A Dintercept.cc112 TSVConn vc; member
119 if (this->vc) { in close()
120 TSVConnClose(this->vc); in close()
145 return (istate->client.vc == vc) ? &istate->client : &istate->server; in InterceptGetThisSide()
152 return (istate->client.vc == vc) ? &istate->server : &istate->client; in InterceptGetOtherSide()
166 return (istate->client.vc && vc == istate->client.vc) ? "<client>" : in InterceptProxySideVC()
167 … (istate->server.vc && vc == istate->server.vc) ? "<server>" : "<unknown>"; in InterceptProxySideVC()
173 if (istate->server.vc == nullptr && istate->client.vc == nullptr) { in InterceptAttemptDestroy()
194 TSVConn vc; member
332 istate->client.vc = arg.vc; in InterceptInterceptionHook()
[all …]
/trafficserver/iocore/cache/
H A DCachePagesInternal.cc133 …for (CacheVC *vc = (CacheVC *)gvol[vol_index]->stat_cache_vcs.head; vc; vc = vc->stat_link.next) { in showVolConnections() local
140 if (vc->closed == 1) in showVolConnections()
142 sprintf(nbytes, "%d", vc->vio.nbytes); in showVolConnections()
143 sprintf(todo, "%d", vc->vio.ntodo()); in showVolConnections()
145 if (vc->f.frag_type == CACHE_FRAG_TYPE_HTTP && vc->request.valid()) { in showVolConnections()
146 URL *u = vc->request.url_get(&uu); in showVolConnections()
149 } else if (vc->alternate.valid()) { in showVolConnections()
150 URL *u = vc->alternate.request_url_get(&uu); in showVolConnections()
154 vc->key.string(url); in showVolConnections()
163 … ((vc->vio.op == VIO::READ) ? "Read" : "Write"), vc->vol->hash_id, url, vc->vio.ndone, in showVolConnections()
[all …]
H A DCacheWrite.cc750 uint32_t len = vc->write_len + vc->header_len + vc->frag_len + sizeof(Doc); in agg_copy()
754 dir_set_approx_size(&vc->dir, vc->agg_len); in agg_copy()
795 dir_set_head(&vc->dir, !vc->fragment); in agg_copy()
810 if (!vc->f.update && !vc->f.evac_vector) { in agg_copy()
817 if (vc->f.update && vc->total_len) { in agg_copy()
822 ink_assert(vc->header_len == vc->write_vector->marshal(doc->hdr(), vc->header_len)); in agg_copy()
824 memcpy(doc->hdr(), vc->header_to_write, vc->header_len); in agg_copy()
840 iobufferblock_memcpy(doc->data(), vc->write_len, vc->blocks.get(), vc->offset); in agg_copy()
885 vc->dir = vc->overwrite_dir; in agg_copy()
886 dir_set_offset(&vc->dir, vc->vol->offset_to_vol_offset(o)); in agg_copy()
[all …]
/trafficserver/proxy/http/
H A DHttpTunnel.h159 VConnection *vc = nullptr; member
176 bool is_downstream_from(VConnection *vc);
188 VConnection *vc = nullptr; member
298 HttpTunnelProducer *get_producer(VConnection *vc);
299 HttpTunnelConsumer *get_consumer(VConnection *vc);
418 HttpTunnel::get_producer(VConnection *vc) in get_producer() argument
421 if (producers[i].vc == vc) { in get_producer()
440 HttpTunnel::get_consumer(VConnection *vc) in get_consumer() argument
460 if (c.vc == vc) { in get_consumer()
518 HttpTunnelConsumer::is_downstream_from(VConnection *vc) in is_downstream_from() argument
[all …]
H A DHttpSM.cc157 if (vc_table[i].vc == vc) { in find_entry()
1299 ink_assert(c->vc == t_info->entry->vc); in state_common_wait_for_transform_read()
3101 ink_assert(server_entry->vc == p->vc); in tunnel_handler_server()
3334 ink_assert(ua_entry->vc == c->vc); in tunnel_handler_ua()
3637 ink_assert(ua_producer->vc == ua_entry->vc); in tunnel_handler_post_server()
3823 ink_assert(c->vc == i->entry->vc); in tunnel_handler_transform_write()
3826 ink_assert(c->vc == i->vc); in tunnel_handler_transform_write()
3827 ink_assert(c->vc == i->entry->vc); in tunnel_handler_transform_write()
3902 ink_assert(p->vc == transform_info.vc || p->vc == post_transform_info.vc); in tunnel_handler_transform_read()
6479 ink_assert(c->vc == transform_info.vc); in setup_transfer_from_transform()
[all …]
/trafficserver/plugins/experimental/slice/
H A DStage.h47 setForRead(TSVConn vc, TSCont contp, int64_t const bytesin //=INT64_MAX in setForRead()
50 TSAssert(nullptr != vc); in setForRead()
57 m_vio = TSVConnRead(vc, contp, m_iobuf, bytesin); in setForRead()
62 setForWrite(TSVConn vc, TSCont contp, int64_t const bytesout //=INT64_MAX in setForWrite()
65 TSAssert(nullptr != vc); in setForWrite()
72 m_vio = TSVConnWrite(vc, contp, m_reader, bytesout); in setForWrite()
110 setupConnection(TSVConn vc) in setupConnection()
115 m_vc = vc; in setupConnection()
/trafficserver/plugins/experimental/fastcgi/src/
H A Dserver_connection.cc41 InterceptIOChannel::read(TSVConn vc, TSCont contp) in read() argument
43 if (TSVConnClosedGet(vc)) { in read()
50 this->vio = TSVConnRead(vc, contp, this->iobuf, INT64_MAX); in read()
60 InterceptIOChannel::write(TSVConn vc, TSCont contp) in write() argument
69 this->vio = TSVConnWrite(vc, contp, this->reader, INT64_MAX); in write()
73 InterceptIOChannel::phpWrite(TSVConn vc, TSCont contp, unsigned char *buf, int data_size, bool endf… in phpWrite() argument
75 if (TSVConnClosedGet(vc)) { in phpWrite()
83 this->vio = TSVConnWrite(vc, contp, this->reader, INT64_MAX); in phpWrite()
/trafficserver/iocore/cache/test/
H A Dtest_RWW.cc106 if (this->_size != SMALL_FILE && !this->_wt->vc->fragment) { in process_write_event()
119 if (this->_latest_fragments == this->_wt->vc->fragment) { in process_write_event()
124 this->_latest_fragments = this->_wt->vc->fragment; in process_write_event()
213 if (this->_size != SMALL_FILE && !this->_wt->vc->fragment) { in process_write_event()
230 if (this->_latest_fragments == this->_wt->vc->fragment) { in process_write_event()
235 this->_latest_fragments = this->_wt->vc->fragment; in process_write_event()
325 if (this->_size != SMALL_FILE && !this->_wt->vc->fragment) { in process_write_event()
339 if (this->_latest_fragments == this->_wt->vc->fragment) { in process_write_event()
344 this->_latest_fragments = this->_wt->vc->fragment; in process_write_event()
/trafficserver/proxy/http3/
H A DHttp3Session.h35 HQSession(NetVConnection *vc) : _client_vc(vc){}; in HQSession() argument
70 Http3Session(NetVConnection *vc);
95 Http09Session(NetVConnection *vc) : HQSession(vc) {} in Http09Session() argument
/trafficserver/iocore/hostdb/
H A Dtest_P_HostDB.cc30 NetVConnection *vc; member
37 vc = _vc; in NetTesterSM()
41 read_vio = vc->do_io_read(this, INT64_MAX, buf); in NetTesterSM()
68 vc->do_io_close(); in handle_read()
/trafficserver/iocore/dns/
H A Dtest_P_DNS.cc30 NetVConnection *vc; member
37 vc = _vc; in NetTesterSM()
41 read_vio = vc->do_io_read(this, INT64_MAX, buf); in NetTesterSM()
66 vc->do_io_close(); in handle_read()
/trafficserver/example/plugins/c-api/disable_http2/
H A Ddisable_http2.cc44 auto vc = static_cast<TSVConn>(cb_data); in CB_SNI() local
45 TSSslConnection ssl_conn = TSVConnSslConnectionGet(vc); in CB_SNI()
51 TSVConnProtocolDisable(vc, TS_ALPN_PROTOCOL_HTTP_2_0); in CB_SNI()
55 TSVConnReenable(vc); in CB_SNI()
/trafficserver/proxy/
H A DProxyTransaction.cc88 NetVConnection *vc = this->get_netvc(); in adjust_thread() local
90 if (vc && vc->thread != this_thread) { in adjust_thread()
91 if (vc->thread->is_event_type(ET_NET)) { in adjust_thread()
92 return vc->thread->schedule_imm(cont, event, data); in adjust_thread()
94 vc->thread = this_thread; in adjust_thread()
H A DProxySession.cc233 auto vc = this->get_netvc(); in populate_protocol() local
234 return vc ? vc->populate_protocol(result, size) : 0; in populate_protocol()
240 auto vc = this->get_netvc(); in protocol_contains() local
241 return vc ? vc->protocol_contains(tag_prefix) : nullptr; in protocol_contains()

Completed in 160 milliseconds

123