Home
last modified time | relevance | path

Searched refs:cont (Results 1 – 25 of 122) sorted by relevance

12345

/trafficserver/iocore/cache/
H A DP_CacheInternal.h575 if (cont->trigger) { in free_CacheVC()
589 cont->vector.clear(); in free_CacheVC()
599 cont->mutex.clear(); in free_CacheVC()
600 cont->buf.clear(); in free_CacheVC()
602 cont->blocks.clear(); in free_CacheVC()
608 memset((char *)&cont->vio, 0, cont->size_to_init); in free_CacheVC()
610 ink_assert(!cont->stat_link.next && !cont->stat_link.prev); in free_CacheVC()
761 stat_cache_vcs.remove(cont, cont->stat_link); in close_write()
762 ink_assert(!cont->stat_link.next && !cont->stat_link.prev); in close_write()
786 ink_assert(!cont->stat_link.next && !cont->stat_link.prev); in open_write()
[all …]
H A DI_Cache.h77 …inkcoreapi Action *lookup(Continuation *cont, const CacheKey *key, CacheFragType frag_type = CACHE…
79 …inkcoreapi Action *open_read(Continuation *cont, const CacheKey *key, CacheFragType frag_type = CA…
81 …inkcoreapi Action *open_write(Continuation *cont, CacheKey *key, CacheFragType frag_type = CACHE_F…
84 …inkcoreapi Action *remove(Continuation *cont, const CacheKey *key, CacheFragType frag_type = CACHE…
86 …Action *scan(Continuation *cont, char *hostname = nullptr, int host_len = 0, int KB_per_second = S…
87 …Action *lookup(Continuation *cont, const HttpCacheKey *key, CacheFragType frag_type = CACHE_FRAG_T…
88 inkcoreapi Action *open_read(Continuation *cont, const HttpCacheKey *key, CacheHTTPHdr *request,
91 …Action *open_write(Continuation *cont, int expected_size, const HttpCacheKey *key, CacheHTTPHdr *r…
93 …Action *remove(Continuation *cont, const HttpCacheKey *key, CacheFragType frag_type = CACHE_FRAG_T…
94 …Action *link(Continuation *cont, CacheKey *from, CacheKey *to, CacheFragType frag_type = CACHE_FRA…
[all …]
H A DCacheLink.cc27 Cache::link(Continuation *cont, const CacheKey *from, const CacheKey *to, CacheFragType type, const… in link() argument
30 cont->handleEvent(CACHE_EVENT_LINK_FAILED, nullptr); in link()
36 CacheVC *c = new_CacheVC(cont); in link()
77 Cache::deref(Continuation *cont, const CacheKey *key, CacheFragType type, const char *hostname, int… in deref() argument
80 cont->handleEvent(CACHE_EVENT_DEREF_FAILED, nullptr); in deref()
91 MUTEX_TRY_LOCK(lock, vol->mutex, cont->mutex->thread_holding); in deref()
94 cont->handleEvent(CACHE_EVENT_DEREF_FAILED, (void *)-ECACHE_NO_DOC); in deref()
98 c = new_CacheVC(cont); in deref()
/trafficserver/iocore/eventsystem/
H A DP_UnixEThread.h39 EThread::schedule_imm(Continuation *cont, int callback_event, void *cookie) in schedule_imm() argument
44 return schedule(e->init(cont, 0, 0)); in schedule_imm()
53 return schedule(e->init(cont, t, 0)); in schedule_at()
62 return schedule(e->init(cont, get_hrtime() + t, 0)); in schedule_in()
72 return schedule(e->init(cont, t, t)); in schedule_every()
74 return schedule(e->init(cont, get_hrtime() + t, t)); in schedule_every()
104 return schedule_local(e->init(cont, 0, 0)); in schedule_imm_local()
113 return schedule_local(e->init(cont, t, 0)); in schedule_at_local()
122 return schedule_local(e->init(cont, get_hrtime() + t, 0)); in schedule_in_local()
132 return schedule(e->init(cont, t, t)); in schedule_every_local()
[all …]
H A DP_UnixEventProcessor.h74 EventProcessor::assign_affinity_by_type(Continuation *cont, EventType etype) in assign_affinity_by_type() argument
76 EThread *ethread = cont->mutex->thread_holding; in assign_affinity_by_type()
78 ethread = cont->getThreadAffinity(); in assign_affinity_by_type()
84 if (cont->getThreadAffinity() == nullptr) { in assign_affinity_by_type()
85 cont->setThreadAffinity(ethread); in assign_affinity_by_type()
124 EventProcessor::schedule_imm(Continuation *cont, EventType et, int callback_event, void *cookie) in schedule_imm() argument
134 return schedule(e->init(cont, 0, 0), et); in schedule_imm()
146 return schedule(e->init(cont, t, 0), et); in schedule_at()
157 return schedule(e->init(cont, Thread::get_hrtime() + t, 0), et); in schedule_in()
170 return schedule(e->init(cont, t, t), et); in schedule_every()
[all …]
/trafficserver/iocore/dns/
H A DI_DNSProcessor.h106 Action *gethostbyname(Continuation *cont, const char *name, Options const &opt);
107 Action *getSRVbyname(Continuation *cont, const char *name, Options const &opt);
109 Action *gethostbyaddr(Continuation *cont, IpAddr const *ip, Options const &opt);
138 Action *getby(const char *x, int len, int type, Continuation *cont, Options const &opt);
153 DNSProcessor::getSRVbyname(Continuation *cont, const char *name, Options const &opt) in getSRVbyname() argument
155 return getby(name, 0, T_SRV, cont, opt); in getSRVbyname()
159 DNSProcessor::gethostbyname(Continuation *cont, const char *name, Options const &opt) in gethostbyname() argument
161 return getby(name, 0, T_A, cont, opt); in gethostbyname()
167 return getby(name, len, T_A, cont, opt); in gethostbyname()
171 DNSProcessor::gethostbyaddr(Continuation *cont, IpAddr const *addr, Options const &opt) in gethostbyaddr() argument
[all …]
/trafficserver/tests/tools/plugins/
H A Dssl_hook_test.cc39 ReenableSSL(TSCont cont, TSEvent event, void *edata) in ReenableSSL() argument
44 TSContDestroy(cont); in ReenableSSL()
49 CB_Pre_Accept(TSCont cont, TSEvent event, void *edata) in CB_Pre_Accept() argument
63 CB_Pre_Accept_Delay(TSCont cont, TSEvent event, void *edata) in CB_Pre_Accept_Delay() argument
82 CB_out_start(TSCont cont, TSEvent event, void *edata) in CB_out_start() argument
97 CB_out_start_delay(TSCont cont, TSEvent event, void *edata) in CB_out_start_delay() argument
117 CB_close(TSCont cont, TSEvent event, void *edata) in CB_close() argument
131 CB_out_close(TSCont cont, TSEvent event, void *edata) in CB_out_close() argument
159 CB_Client_Hello(TSCont cont, TSEvent event, void *edata) in CB_Client_Hello() argument
178 CB_SNI(TSCont cont, TSEvent event, void *edata) in CB_SNI() argument
[all …]
H A Dhook_add_plugin.cc99 TSCont cont = TSContCreate(sessionHandler, TSMutexCreate()); in globalHandler() local
101 TSHttpSsnHookAdd(session, TS_HTTP_PRE_REMAP_HOOK, cont); in globalHandler()
102 TSHttpSsnHookAdd(session, TS_HTTP_SSN_CLOSE_HOOK, cont); in globalHandler()
104 TSDebug(PLUGIN_TAG, "New session, cont is %p", cont); in globalHandler()
/trafficserver/iocore/net/
H A DP_SNIActionPerformer.h41 virtual int SNIAction(Continuation *cont) const = 0;
52 SNIAction(Continuation *cont) const override in SNIAction()
54 auto ssl_vc = dynamic_cast<SSLNetVConnection *>(cont); in SNIAction()
76 SNIAction(Continuation *cont) const override in SNIAction()
79 SSLNetVConnection *ssl_netvc = dynamic_cast<SSLNetVConnection *>(cont); in SNIAction()
98 SNIAction(Continuation *cont) const override in SNIAction()
100 auto ssl_vc = dynamic_cast<SSLNetVConnection *>(cont); in SNIAction()
121 SNIAction(Continuation *cont) const override in SNIAction()
124 auto ssl_vc = dynamic_cast<SSLNetVConnection *>(cont); in SNIAction()
161 SNIAction(Continuation *cont) const override in SNIAction()
[all …]
H A DUnixNetProcessor.cc72 NetProcessor::accept(Continuation *cont, AcceptOptions const &opt) in accept() argument
86 return this_unp->accept_internal(cont, fd, opt); in main_accept()
136 SessionAccept *sa = dynamic_cast<SessionAccept *>(cont); in accept_internal()
138 na->snpa = dynamic_cast<SSLNextProtocolAccept *>(cont); in accept_internal()
141 *na->action_ = cont; in accept_internal()
210 vc->mutex = cont->mutex; in connect_re_internal()
223 socksEntry->action_ = cont; in connect_re_internal()
224 cont = socksEntry; in connect_re_internal()
237 vc->action_ = cont; in connect_re_internal()
240 MUTEX_TRY_LOCK(lock, cont->mutex, t); in connect_re_internal()
[all …]
H A DP_UnixNetProcessor.h37 virtual Action *accept_internal(Continuation *cont, int fd, AcceptOptions const &opt);
39 …Action *connect_re_internal(Continuation *cont, sockaddr const *target, NetVCOptions *options = nu…
40 …Action *connect(Continuation *cont, UnixNetVConnection **vc, sockaddr const *target, NetVCOptions …
60 NetProcessor::connect_re(Continuation *cont, sockaddr const *addr, NetVCOptions *opts) in connect_re() argument
62 return static_cast<UnixNetProcessor *>(this)->connect_re_internal(cont, addr, opts); in connect_re()
H A DQUICNetProcessor.cc103 QUICNetProcessor::connect_re(Continuation *cont, sockaddr const *remote_addr, NetVCOptions *opt) in connect_re() argument
106 EThread *t = cont->mutex->thread_holding; in connect_re()
155 vc->mutex = cont->mutex; in connect_re()
156 vc->action_ = cont; in connect_re()
159 MUTEX_TRY_LOCK(lock, cont->mutex, t); in connect_re()
180 QUICNetProcessor::main_accept(Continuation *cont, SOCKET fd, AcceptOptions const &opt) in main_accept() argument
213 *na->action_ = cont; in main_accept()
/trafficserver/iocore/net/quic/
H A DQUICStream.cc243 if (this->_read_vio.cont == nullptr || this->_read_vio.op == VIO::NONE) { in _signal_read_event()
251 this->_read_vio.cont->handleEvent(event, &this->_read_vio); in _signal_read_event()
253 this_ethread()->schedule_imm(this->_read_vio.cont, event, &this->_read_vio); in _signal_read_event()
263 if (this->_write_vio.cont == nullptr || this->_write_vio.op == VIO::NONE) { in _signal_write_event()
271 this->_write_vio.cont->handleEvent(event, &this->_write_vio); in _signal_write_event()
273 this_ethread()->schedule_imm(this->_write_vio.cont, event, &this->_write_vio); in _signal_write_event()
283 if (this->_read_vio.cont == nullptr || this->_read_vio.op == VIO::NONE) { in _signal_read_eos_event()
291 this->_write_vio.cont->handleEvent(event, &this->_write_vio); in _signal_read_eos_event()
293 this_ethread()->schedule_imm(this->_read_vio.cont, event, &this->_read_vio); in _signal_read_eos_event()
300 if (this->_read_vio.cont == nullptr || this->_read_vio.op == VIO::NONE) { in _process_read_vio()
[all …]
/trafficserver/proxy/http2/
H A DHttp2Stream.cc100 read_vio.cont->handleEvent(event, &read_vio); in main_event_handler()
110 write_vio.cont->handleEvent(event, &write_vio); in main_event_handler()
126 write_vio.cont->handleEvent(event, &write_vio); in main_event_handler()
145 read_vio.cont->handleEvent(event, &read_vio); in main_event_handler()
336 read_vio.cont = c; in do_io_read()
356 write_vio.cont = c; in do_io_write()
468 if (write_vio.cont) { in initiating_close()
482 if (_sm && read_vio.cont) { in initiating_close()
544 if (read_vio.cont && this->_sm) { in update_read_request()
662 …if (this->read_vio.cont == nullptr || this->read_vio.cont->mutex == nullptr || this->read_vio.op =… in signal_read_event()
[all …]
/trafficserver/plugins/experimental/sslheaders/
H A Dsslheaders.cc29 SslHdrExpandRequestHook(TSCont cont, TSEvent event, void *edata) in SslHdrExpandRequestHook() argument
37 hdr = static_cast<const SslHdrInstance *>(TSContDataGet(cont)); in SslHdrExpandRequestHook()
275 TSHttpHookAdd(TS_HTTP_SEND_REQUEST_HDR_HOOK, hdr->cont); in TSPluginInit()
279 TSHttpHookAdd(TS_HTTP_READ_REQUEST_HDR_HOOK, hdr->cont); in TSPluginInit()
280 TSHttpHookAdd(TS_HTTP_SEND_REQUEST_HDR_HOOK, hdr->cont); in TSPluginInit()
320 TSHttpTxnHookAdd(txn, TS_HTTP_SEND_REQUEST_HDR_HOOK, hdr->cont); in TSRemapDoRemap()
324 TSHttpTxnHookAdd(txn, TS_HTTP_READ_REQUEST_HDR_HOOK, hdr->cont); in TSRemapDoRemap()
325 TSHttpTxnHookAdd(txn, TS_HTTP_SEND_REQUEST_HDR_HOOK, hdr->cont); in TSRemapDoRemap()
332 SslHdrInstance::SslHdrInstance() : expansions(), cont(TSContCreate(SslHdrExpandRequestHook, nullptr… in SslHdrInstance()
334 TSContDataSet(cont, this); in SslHdrInstance()
[all …]
/trafficserver/src/tscpp/api/
H A DContinuation.cc28 Continuation::_generalEventFunc(TSCont cont, TSEvent event, void *edata) in _generalEventFunc() argument
30 TSReleaseAssert(cont != nullptr); in _generalEventFunc()
32 Continuation *p = static_cast<Continuation *>(TSContDataGet(cont)); in _generalEventFunc()
H A DInterceptPlugin.cc88 State(TSCont cont, InterceptPlugin *plugin) : cont_(cont), plugin_(plugin) in State()
108 int handleEvents(TSCont cont, TSEvent event, void *edata);
114 TSCont cont = TSContCreate(handleEvents, TSMutexCreate()); in InterceptPlugin() local
115 state_ = new State(cont, this); in InterceptPlugin()
116 TSContDataSet(cont, state_); in InterceptPlugin()
119 TSHttpTxnServerIntercept(cont, txn); in InterceptPlugin()
121 TSHttpTxnIntercept(cont, txn); in InterceptPlugin()
356 handleEvents(TSCont cont, TSEvent pristine_event, void *pristine_edata) in handleEvents() argument
362 InterceptPlugin::State *state = static_cast<InterceptPlugin::State *>(TSContDataGet(cont)); in handleEvents()
374 state->timeout_action_ = TSContScheduleOnPool(cont, 1, TS_THREAD_POOL_NET); in handleEvents()
[all …]
H A Dutils_internal.cc53 handleTransactionEvents(TSCont cont, TSEvent event, void *edata) in handleTransactionEvents() argument
58 …d on continuation %p for transaction (ats pointer %p, object %p)", event, cont, ats_txn_handle, in handleTransactionEvents()
105 TSCont cont = TSContCreate(handleTransactionEvents, mutex); in setupTransactionManagement() local
106 TSHttpHookAdd(TS_HTTP_POST_REMAP_HOOK, cont); in setupTransactionManagement()
107 TSHttpHookAdd(TS_HTTP_SEND_REQUEST_HDR_HOOK, cont); in setupTransactionManagement()
108 TSHttpHookAdd(TS_HTTP_READ_RESPONSE_HDR_HOOK, cont); in setupTransactionManagement()
109 TSHttpHookAdd(TS_HTTP_SEND_RESPONSE_HDR_HOOK, cont); in setupTransactionManagement()
110 TSHttpHookAdd(TS_HTTP_READ_CACHE_HDR_HOOK, cont); in setupTransactionManagement()
111 TSHttpHookAdd(TS_HTTP_TXN_CLOSE_HOOK, cont); in setupTransactionManagement()
/trafficserver/plugins/escalate/
H A Descalate.cc56 cont = TSContCreate(EscalateResponse, nullptr); in EscalationState()
57 TSContDataSet(cont, this); in EscalationState()
60 ~EscalationState() { TSContDestroy(cont); } in ~EscalationState()
61 TSCont cont; member
85 EscalateResponse(TSCont cont, TSEvent event, void *edata) in EscalateResponse() argument
88 EscalationState *es = static_cast<EscalationState *>(TSContDataGet(cont)); in EscalateResponse()
227 TSHttpTxnHookAdd(txn, TS_HTTP_READ_RESPONSE_HDR_HOOK, es->cont); in TSRemapDoRemap()
/trafficserver/plugins/experimental/collapsed_forwarding/
H A Dcollapsed_forwarding.cc244 TSCont cont = TSContCreate(collapsed_cont, TSMutexCreate()); in setup_transaction_cont() local
256 TSContDataSet(cont, req_data); in setup_transaction_cont()
258 TSHttpTxnHookAdd(rh, TS_HTTP_SEND_REQUEST_HDR_HOOK, cont); in setup_transaction_cont()
259 TSHttpTxnHookAdd(rh, TS_HTTP_SEND_RESPONSE_HDR_HOOK, cont); in setup_transaction_cont()
260 TSHttpTxnHookAdd(rh, TS_HTTP_READ_RESPONSE_HDR_HOOK, cont); in setup_transaction_cont()
261 TSHttpTxnHookAdd(rh, TS_HTTP_OS_DNS_HOOK, cont); in setup_transaction_cont()
262 TSHttpTxnHookAdd(rh, TS_HTTP_TXN_CLOSE_HOOK, cont); in setup_transaction_cont()
339 TSCont cont = TSContCreate(collapsed_cont, TSMutexCreate()); in TSPluginInit() local
343 TSHttpHookAdd(TS_HTTP_READ_REQUEST_HDR_HOOK, cont); in TSPluginInit()
/trafficserver/plugins/background_fetch/
H A Dconfigs.h42 …explicit BgFetchConfig(TSCont cont) : _cont(cont) { TSContDataSet(cont, static_cast<void *>(this))… in BgFetchConfig() argument
/trafficserver/proxy/
H A DTransform.cc82 TransformProcessor::open(Continuation *cont, APIHook *hooks) in open() argument
85 return new TransformVConnection(cont, hooks); in open()
223 m_read_vio.cont->handleEvent(VC_EVENT_EOS, &m_read_vio); in handle_event()
225 m_read_vio.cont->handleEvent(VC_EVENT_READ_READY, &m_read_vio); in handle_event()
253 ink_assert(m_read_vio.cont != nullptr); in handle_event()
254 m_read_vio.cont->handleEvent(ev, &m_read_vio); in handle_event()
382 : TransformVCChain(cont->mutex.get()), m_cont(cont), m_terminus(this), m_closed(0) in TransformVConnection()
635 m_write_vio.cont->handleEvent(VC_EVENT_ERROR, &m_write_vio); in handle_event()
794 m_write_vio.cont->handleEvent(VC_EVENT_ERROR, &m_write_vio); in handle_event()
910 m_write_vio.cont->handleEvent(cb_event, &m_write_vio); in transform_to_range()
[all …]
/trafficserver/plugins/experimental/uri_signing/
H A Duri_signing.c103 add_cookie(TSCont cont, TSEvent event, void *edata) in add_cookie() argument
109 char *cookie = TSContDataGet(cont); in add_cookie()
141 TSContDestroy(cont); in add_cookie()
151 TSCont cont = TSContCreate(add_cookie, NULL); in cont_new() local
152 if (!cont) { in cont_new()
157 TSContDataSet(cont, cookie); in cont_new()
158 return cont; in cont_new()
339 TSCont cont = cont_new(cookie); in TSRemapDoRemap() local
340 TSHttpTxnHookAdd(txnp, TS_HTTP_SEND_RESPONSE_HDR_HOOK, cont); in TSRemapDoRemap()
/trafficserver/iocore/hostdb/
H A DI_HostDBProcessor.h398 Action *iterate(Continuation *cont);
443 …inkcoreapi Action *getbyname_re(Continuation *cont, const char *hostname, int len, Options const &…
445 …Action *getbynameport_re(Continuation *cont, const char *hostname, int len, Options const &opt = D…
447 …Action *getSRVbyname_imm(Continuation *cont, cb_process_result_pfn process_srv_info, const char *h…
450 …Action *getbyname_imm(Continuation *cont, cb_process_result_pfn process_hostdb_info, const char *h…
453 Action *iterate(Continuation *cont);
456 Action *getbyaddr_re(Continuation *cont, sockaddr const *aip);
495 …Action *getby(Continuation *cont, cb_process_result_pfn cb_process_result, HostDBHash &hash, Optio…
/trafficserver/proxy/http3/
H A DHttp3Transaction.cc131 this->_read_vio.cont = c; in do_io_read()
153 this->_write_vio.cont = c; in do_io_write()
181 this->_read_vio.cont = nullptr; in do_io_close()
186 this->_write_vio.cont = nullptr; in do_io_close()
280 if (this->_read_vio.cont == nullptr || this->_read_vio.op == VIO::NONE) { in _signal_read_event()
287 this->_read_vio.cont->handleEvent(event, &this->_read_vio); in _signal_read_event()
301 if (this->_write_vio.cont == nullptr || this->_write_vio.op == VIO::NONE) { in _signal_write_event()
308 this->_write_vio.cont->handleEvent(event, &this->_write_vio); in _signal_write_event()
471 if (this->_read_vio.cont == nullptr || this->_read_vio.op == VIO::NONE) { in _process_read_vio()
494 if (this->_write_vio.cont == nullptr || this->_write_vio.op == VIO::NONE) { in _process_write_vio()
[all …]

Completed in 206 milliseconds

12345