Home
last modified time | relevance | path

Searched refs:event (Results 1 – 25 of 380) sorted by relevance

12345678910>>...16

/trafficserver/iocore/cache/test/
H A Dtest_RWW.cc92 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
100 switch (event) { in process_write_event()
131 REQUIRE(event == 0); in process_write_event()
142 switch (event) { in process_read_event()
172 switch (event) { in handle_cache_event()
208 switch (event) { in process_write_event()
254 switch (event) { in process_read_event()
285 REQUIRE(event == 0); in process_read_event()
320 switch (event) { in process_write_event()
361 switch (event) { in process_read_event()
[all …]
H A Dmain.h76 start_event(int event, void *e) in start_event() argument
84 init_event(int event, void *e) in init_event() argument
86 switch (event) { in init_event()
93 this->handleEvent(event, e); in init_event()
119 init_handler(int event, void *e) in init_handler() argument
121 this->start_test(event, e); in init_handler()
129 process_event(int event) in process_event() argument
143 terminal_event(int event, void *e) in terminal_event() argument
194 int start_test(int event, void *e) override;
195 int write_event(int event, void *e);
[all …]
H A Dtest_Update_L_to_S.cc41 start_test(int event, void *e) in start_test() argument
43 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
49 handle_cache_event(int event, CacheTestBase *base) override in handle_cache_event() argument
51 switch (event) { in handle_cache_event()
84 start_test(int event, void *e) in start_test() argument
86 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
92 handle_cache_event(int event, CacheTestBase *base) override in handle_cache_event() argument
95 switch (event) { in handle_cache_event()
131 cache_init_success_callback(int event, void *e) override in cache_init_success_callback() argument
H A Dtest_Update_S_to_L.cc41 start_test(int event, void *e) in start_test() argument
43 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
49 handle_cache_event(int event, CacheTestBase *base) override in handle_cache_event() argument
51 switch (event) { in handle_cache_event()
84 start_test(int event, void *e) in start_test() argument
86 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
92 handle_cache_event(int event, CacheTestBase *base) override in handle_cache_event() argument
95 switch (event) { in handle_cache_event()
131 cache_init_success_callback(int event, void *e) override in cache_init_success_callback() argument
H A Dtest_Alternate_S_to_L_remove_S.cc52 start_test(int event, void *e) in start_test() argument
54 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
60 handle_cache_event(int event, CacheTestBase *base) override in handle_cache_event() argument
62 switch (event) { in handle_cache_event()
105 start_test(int event, void *e) in start_test() argument
107 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
115 switch (event) { in handle_cache_event()
165 start_test(int event, void *e) in start_test() argument
167 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
175 switch (event) { in handle_cache_event()
[all …]
H A Dtest_Alternate_L_to_S_remove_L.cc52 start_test(int event, void *e) in start_test() argument
54 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
60 handle_cache_event(int event, CacheTestBase *base) override in handle_cache_event() argument
62 switch (event) { in handle_cache_event()
105 start_test(int event, void *e) in start_test() argument
107 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
115 switch (event) { in handle_cache_event()
165 start_test(int event, void *e) in start_test() argument
167 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
175 switch (event) { in handle_cache_event()
[all …]
H A Dtest_Alternate_L_to_S_remove_S.cc45 start_test(int event, void *e) in start_test() argument
47 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
53 handle_cache_event(int event, CacheTestBase *base) override in handle_cache_event() argument
55 switch (event) { in handle_cache_event()
106 start_test(int event, void *e) in start_test() argument
108 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
116 switch (event) { in handle_cache_event()
166 start_test(int event, void *e) in start_test() argument
168 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
176 switch (event) { in handle_cache_event()
[all …]
H A Dtest_Alternate_S_to_L_remove_L.cc45 start_test(int event, void *e) in start_test() argument
47 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
53 handle_cache_event(int event, CacheTestBase *base) override in handle_cache_event() argument
55 switch (event) { in handle_cache_event()
106 start_test(int event, void *e) in start_test() argument
108 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
117 switch (event) { in handle_cache_event()
167 start_test(int event, void *e) in start_test() argument
169 REQUIRE(event == EVENT_IMMEDIATE); in start_test()
177 switch (event) { in handle_cache_event()
[all …]
/trafficserver/proxy/http/
H A DHttpSM.h278 int state_api_callback(int event, void *data);
279 int state_api_callout(int event, void *data);
353 int get_http_schedule(int event, void *data);
389 int main_handler(int event, void *data);
390 int tunnel_handler(int event, void *data);
391 int tunnel_handler_push(int event, void *data);
392 int tunnel_handler_post(int event, void *data);
404 int state_hostdb_lookup(int event, void *data);
406 int state_mark_os_down(int event, void *data);
408 int state_auth_callback(int event, void *data);
[all …]
/trafficserver/proxy/http3/
H A DHttp3Transaction.cc271 return event; in _send_tracked_event()
292 Http3TransVDebug("%s (%d)", get_vc_event_name(event), event); in _signal_read_event()
313 Http3TransVDebug("%s (%d)", get_vc_event_name(event), event); in _signal_write_event()
365 switch (event) { in state_stream_open()
368 Http3TransVDebug("%s (%d)", get_vc_event_name(event), event); in state_stream_open()
380 Http3TransVDebug("%s (%d)", get_vc_event_name(event), event); in state_stream_open()
394 Http3TransVDebug("%s (%d)", get_vc_event_name(event), event); in state_stream_open()
421 Http3TransVDebug("%s (%d)", get_vc_event_name(event), event); in state_stream_closed()
439 Http3TransVDebug("%s (%d)", get_vc_event_name(event), event); in state_stream_closed()
611 Http3TransVDebug("%s (%d)", get_vc_event_name(event), event); in state_stream_open()
[all …]
/trafficserver/iocore/cache/
H A DCachePages.cc221 return complete(event, e); in showMain()
233 return complete(event, e); in lookup_url_form()
249 return complete(event, e); in delete_url_form()
265 return complete(event, e); in lookup_regex_form()
281 return complete(event, e); in delete_regex_form()
297 return complete(event, e); in invalidate_regex_form()
304 switch (event) { in handleCacheEvent()
332 return complete(event, e); in handleCacheEvent()
441 return complete(event, e); in handleCacheEvent()
595 switch (event) { in handleCacheScanCallback()
[all …]
H A DCachePagesInternal.cc35 int showMain(int event, Event *e);
36 int showEvacuations(int event, Event *e);
38 int showVolumes(int event, Event *e);
39 int showVolVolumes(int event, Event *e);
40 int showSegments(int event, Event *e);
41 int showSegSegment(int event, Event *e);
104 return complete(event, e); in showMain()
171 return complete(event, e); in showVolConnections()
223 return complete(event, e); in showVolEvacuations()
288 return showSegments(event, e); in showVolVolumes()
[all …]
/trafficserver/src/traffic_server/
H A DSocksProxy.cc105 int acceptEvent(int event, void *data);
106 int mainEvent(int event, void *data);
172 ink_assert(event == NET_EVENT_ACCEPT); in acceptEvent()
197 switch (event) { in mainEvent()
290 if (event != VC_EVENT_READ_READY) { in state_read_client_request()
414 switch (event) { in state_send_socks5_auth_method()
442 if (event != VC_EVENT_READ_READY) { in state_read_socks5_client_request()
552 switch (event) { in state_handing_over_http_request()
587 switch (event) { in state_send_socks_reply()
688 ink_assert(event == NET_EVENT_ACCEPT); in mainEvent()
[all …]
/trafficserver/proxy/
H A DShow.h86 return complete_error(event, e);
89 finishConn(int event, Event *e) in finishConn()
99 return done(VIO::CLOSE, event, e); in finishConn()
103 complete(int event, Event *e) in complete()
106 return finishConn(event, e); in complete()
110 completeJson(int event, Event *e) in completeJson()
112 return finishConn(event, e); in completeJson()
116 complete_error(int event, Event *e) in complete_error()
123 return done(VIO::ABORT, event, e); in complete_error()
136 showError(int event, Event *e) in showError()
[all …]
/trafficserver/plugins/experimental/memcache/
H A Dtsmemcache.h87 int main_event(int event, void *netvc);
169 int read_from_client_event(int event, void *data);
170 int swallow_then_read_event(int event, void *data);
173 int read_ascii_from_client_event(int event, void *data);
174 int binary_get_event(int event, void *data);
175 int cache_read_event(int event, void *data);
176 int write_then_close_event(int event, void *data);
188 int ascii_get_event(int event, void *data);
189 int ascii_set_event(int event, void *data);
190 int ascii_delete_event(int event, void *data);
[all …]
/trafficserver/iocore/net/
H A DSSLNextProtocolAccept.cc27 send_plugin_event(Continuation *plugin, int event, void *edata) in send_plugin_event() argument
31 plugin->handleEvent(event, edata); in send_plugin_event()
33 plugin->handleEvent(event, edata); in send_plugin_event()
38 ssl_netvc_cast(int event, void *edata) in ssl_netvc_cast() argument
45 switch (event) { in ssl_netvc_cast()
71 ioCompletionEvent(int event, void *edata) in ioCompletionEvent()
81 switch (event) { in ioCompletionEvent()
123 SSLNextProtocolAccept::mainEvent(int event, void *edata) in mainEvent() argument
125 SSLNetVConnection *netvc = ssl_netvc_cast(event, edata); in mainEvent()
127 Debug("ssl", "[SSLNextProtocolAccept:mainEvent] event %d netvc %p", event, netvc); in mainEvent()
[all …]
H A DUnixUDPNet.cc311 return event; in getAction()
334 event(completionToken), in UDPReadContinuation()
355 event = nullptr; in free()
376 event = completionToken; in init_token()
399 event = nullptr; in ~UDPReadContinuation()
407 event->cancel(); in cancel()
438 if (event->cancelled) { in readPollEvent()
490 if (event->cancelled) { in readPollEvent()
539 c->init_token(event); in recvfrom_re()
544 return event; in recvfrom_re()
[all …]
/trafficserver/iocore/net/quic/
H A DQUICStream.cc223 if (event != nullptr) { in _send_tracked_event()
224 if (event->callback_event != send_event) { in _send_tracked_event()
225 event->cancel(); in _send_tracked_event()
226 event = nullptr; in _send_tracked_event()
230 if (event == nullptr) { in _send_tracked_event()
231 event = this_ethread()->schedule_imm(this, send_event, vio); in _send_tracked_event()
234 return event; in _send_tracked_event()
251 this->_read_vio.cont->handleEvent(event, &this->_read_vio); in _signal_read_event()
271 this->_write_vio.cont->handleEvent(event, &this->_write_vio); in _signal_write_event()
288 int event = VC_EVENT_EOS; in _signal_read_eos_event() local
[all …]
/trafficserver/tests/tools/plugins/
H A Dhook_add_plugin.cc28 transactionHandler(TSCont continuation, TSEvent event, void *d) in transactionHandler() argument
30 if (!(event == TS_EVENT_HTTP_PRE_REMAP || event == TS_EVENT_HTTP_TXN_CLOSE)) { in transactionHandler()
31 TSError("[" PLUGIN_TAG "] unexpected event on transactionHandler: %i\n", event); in transactionHandler()
37 switch (event) { in transactionHandler()
58 sessionHandler(TSCont continuation, TSEvent event, void *d) in sessionHandler() argument
63 switch (event) { in sessionHandler()
92 globalHandler(TSCont continuation, TSEvent event, void *data) in globalHandler() argument
96 switch (event) { in globalHandler()
H A Dcont_schedule.cc45 static int TSContSchedule_handler_1(TSCont contp, TSEvent event, void *edata);
46 static int TSContSchedule_handler_2(TSCont contp, TSEvent event, void *edata);
54 TSContSchedule_handler_1(TSCont contp, TSEvent event, void *edata) in TSContSchedule_handler_1() argument
84 TSContSchedule_handler_2(TSCont contp, TSEvent event, void *edata) in TSContSchedule_handler_2() argument
119 TSContScheduleOnPool_handler_1(TSCont contp, TSEvent event, void *edata) in TSContScheduleOnPool_handler_1() argument
138 TSContScheduleOnPool_handler_2(TSCont contp, TSEvent event, void *edata) in TSContScheduleOnPool_handler_2() argument
181 TSContScheduleOnThread_handler_1(TSCont contp, TSEvent event, void *edata) in TSContScheduleOnThread_handler_1() argument
205 TSContScheduleOnThread_handler_2(TSCont contp, TSEvent event, void *edata) in TSContScheduleOnThread_handler_2() argument
236 TSContThreadAffinity_handler(TSCont contp, TSEvent event, void *edata) in TSContThreadAffinity_handler() argument
278 LifecycleHookTracer(TSCont contp, TSEvent event, void *edata) in LifecycleHookTracer() argument
[all …]
H A Dtest_hooks.cc54 transactionContFunc(TSCont, TSEvent event, void *eventData) in transactionContFunc() argument
58 …TSDebug(PIName, "Transaction: event=%s(%d) eventData=%p", TSHttpEventNameLookup(event), event, eve… in transactionContFunc()
60 switch (event) { in transactionContFunc()
97 sessionContFunc(TSCont, TSEvent event, void *eventData) in sessionContFunc() argument
99 logFile << "Session: event=" << TSHttpEventNameLookup(event) << std::endl; in sessionContFunc()
101 …TSDebug(PIName, "Session: event=%s(%d) eventData=%p", TSHttpEventNameLookup(event), event, eventDa… in sessionContFunc()
103 switch (event) { in sessionContFunc()
165 globalContFunc(TSCont, TSEvent event, void *eventData) in globalContFunc() argument
167 logFile << "Global: event=" << TSHttpEventNameLookup(event) << std::endl; in globalContFunc()
169 …TSDebug(PIName, "Global: event=%s(%d) eventData=%p", TSHttpEventNameLookup(event), event, eventDat… in globalContFunc()
[all …]
H A Dcontinuations_verify.cc50 handle_msg(TSCont contp, TSEvent event, void *edata) in handle_msg() argument
52 if (event == TS_EVENT_LIFECYCLE_MSG) { // External trigger, such as traffic_ctl in handle_msg()
61 TSDebug(DEBUG_TAG_MSG, "event %d", event); in handle_msg()
73 handle_order_1(TSCont contp, TSEvent event, void *edata) in handle_order_1() argument
78 TSDebug(DEBUG_TAG_HOOK, "order_1 event %d", event); in handle_order_1()
81 switch (event) { in handle_order_1()
103 handle_order_2(TSCont contp, TSEvent event, void *edata) in handle_order_2() argument
108 TSDebug(DEBUG_TAG_HOOK, "order_2 event %d", event); in handle_order_2()
111 switch (event) { in handle_order_2()
/trafficserver/example/plugins/c-api/protocol/
H A DTxnSM.c81 if (event == TS_EVENT_ERROR) { in main_handler()
86 if (event == TS_EVENT_VCONN_EOS) { in main_handler()
218 switch (event) { in state_read_request_from_client()
273 switch (event) { in state_handle_cache_lookup()
370 switch (event) { in state_handle_cache_read_response()
420 switch (event) { in state_handle_cache_prepare_for_write()
519 if (event != TS_EVENT_NET_CONNECT) { in state_connect_to_server()
544 switch (event) { in state_send_request_to_server()
571 switch (event) { in state_interface_with_server()
686 switch (event) { in state_write_to_cache()
[all …]
/trafficserver/plugins/healthchecks/
H A Dhealthchecks.c223 while (finfo && !((event->wd == finfo->wd) || in hc_thread()
224 … ((event->wd == finfo->dir->wd) && !strncmp(event->name, finfo->basename, event->len)))) { in hc_thread()
411 if (event == TS_EVENT_VCONN_READ_READY) { in hc_process_read()
421 } else if (event == TS_EVENT_ERROR) { in hc_process_read()
423 } else if (event == TS_EVENT_VCONN_EOS) { in hc_process_read()
426 } else if (event == TS_EVENT_NET_ACCEPT_FAILED) { in hc_process_read()
437 if (event == TS_EVENT_VCONN_WRITE_READY) { in hc_process_write()
452 } else if (event == TS_EVENT_ERROR) { in hc_process_write()
475 if (event == TS_EVENT_NET_ACCEPT) { in hc_intercept()
479 hc_process_read(contp, event, my_state); in hc_intercept()
[all …]
/trafficserver/plugins/stats_over_http/
H A Dstats_over_http.c108 TSDebug(PLUGIN_NAME, "stats_process_read(%d)", event); in stats_process_read()
109 if (event == TS_EVENT_VCONN_READ_READY) { in stats_process_read()
113 } else if (event == TS_EVENT_ERROR) { in stats_process_read()
115 } else if (event == TS_EVENT_VCONN_EOS) { in stats_process_read()
118 } else if (event == TS_EVENT_NET_ACCEPT_FAILED) { in stats_process_read()
121 printf("Unexpected Event %d\n", event); in stats_process_read()
200 if (event == TS_EVENT_VCONN_WRITE_READY) { in stats_process_write()
210 } else if (event == TS_EVENT_ERROR) { in stats_process_write()
221 if (event == TS_EVENT_NET_ACCEPT) { in stats_dostuff()
225 stats_process_read(contp, event, my_state); in stats_dostuff()
[all …]

Completed in 161 milliseconds

12345678910>>...16