Home
last modified time | relevance | path

Searched refs:VC_EVENT_WRITE_COMPLETE (Results 1 – 25 of 39) sorted by relevance

12

/trafficserver/iocore/net/
H A DNetVCTest.cc48 {"basic", 2000, 2000, 2000, 2000, 50, 10, VC_EVENT_READ_COMPLETE, VC_EVENT_WRITE_COMPLETE},
49 {"basic", 2000, 2000, 2000, 2000, 50, 10, VC_EVENT_READ_COMPLETE, VC_EVENT_WRITE_COMPLETE},
61 {"eos", 4000, 4000, 10, 10, 8192, 10, VC_EVENT_READ_COMPLETE, VC_EVENT_WRITE_COMPLETE},
62 {"eos", 10, 10, 6000, 6000, 8192, 10, VC_EVENT_EOS, VC_EVENT_WRITE_COMPLETE},
65 {"werr", 10, 10, 10, 10, 129, 10, VC_EVENT_READ_COMPLETE, VC_EVENT_WRITE_COMPLETE},
68 {"itimeout", 10, 10, 6000, 8000, 512, 20, VC_EVENT_EOS, VC_EVENT_WRITE_COMPLETE},
71 {"smallt", 400, 400, 500, 500, 1, 15, VC_EVENT_READ_COMPLETE, VC_EVENT_WRITE_COMPLETE},
72 {"smallt", 500, 500, 400, 400, 1, 15, VC_EVENT_READ_COMPLETE, VC_EVENT_WRITE_COMPLETE},
78 {"overflow", 50, 50, 0, 35000, 1024, 35, EVENT_NONE, VC_EVENT_WRITE_COMPLETE}
220 if (nbytes_write != write_vio->ndone && expected_write_term == VC_EVENT_WRITE_COMPLETE) { in write_finished()
[all …]
/trafficserver/iocore/cache/test/
H A Dtest_RWW.cc127 case VC_EVENT_WRITE_COMPLETE: in process_write_event()
176 case VC_EVENT_WRITE_COMPLETE: in handle_cache_event()
239 case VC_EVENT_WRITE_COMPLETE: in process_write_event()
348 case VC_EVENT_WRITE_COMPLETE: in process_write_event()
H A DCacheTestHandler.cc54 case VC_EVENT_WRITE_COMPLETE: in handle_cache_event()
H A Dtest_Update_L_to_S.cc102 case VC_EVENT_WRITE_COMPLETE: in handle_cache_event()
H A Dtest_Update_S_to_L.cc102 case VC_EVENT_WRITE_COMPLETE: in handle_cache_event()
H A Dtest_Alternate_L_to_S.cc126 case VC_EVENT_WRITE_COMPLETE: in handle_cache_event()
H A Dtest_Alternate_S_to_L.cc126 case VC_EVENT_WRITE_COMPLETE: in handle_cache_event()
H A Dtest_Alternate_S_to_L_remove_S.cc182 case VC_EVENT_WRITE_COMPLETE: in handle_cache_event()
/trafficserver/src/traffic_server/
H A DEventName.cc56 case VC_EVENT_WRITE_COMPLETE: in event_int_to_string()
H A DSocksProxy.cc201 case VC_EVENT_WRITE_COMPLETE: in mainEvent()
415 case VC_EVENT_WRITE_COMPLETE: in state_send_socks5_auth_method()
553 case VC_EVENT_WRITE_COMPLETE: { in state_handing_over_http_request()
588 case VC_EVENT_WRITE_COMPLETE: in state_send_socks_reply()
/trafficserver/proxy/
H A DTransform.cc213 m_write_vio.cont->handleEvent(VC_EVENT_WRITE_COMPLETE, &m_write_vio); in handle_event()
582 case VC_EVENT_WRITE_COMPLETE: in handle_event()
637 case VC_EVENT_WRITE_COMPLETE: in handle_event()
703 m_write_vio.cont->handleEvent(VC_EVENT_WRITE_COMPLETE, &m_write_vio); in handle_event()
796 case VC_EVENT_WRITE_COMPLETE: in handle_event()
909 int cb_event = (m_write_vio.ntodo() > 0) ? VC_EVENT_EOS : VC_EVENT_WRITE_COMPLETE; in transform_to_range()
/trafficserver/proxy/http3/
H A DHttp3Transaction.cc304 int event = this->_write_vio.ntodo() ? VC_EVENT_WRITE_READY : VC_EVENT_WRITE_COMPLETE; in _signal_write_event()
379 case VC_EVENT_WRITE_COMPLETE: { in state_stream_open()
430 case VC_EVENT_WRITE_COMPLETE: { in state_stream_closed()
641 case VC_EVENT_WRITE_COMPLETE: { in state_stream_open()
683 case VC_EVENT_WRITE_COMPLETE: { in state_stream_closed()
H A DHttp09App.cc93 case VC_EVENT_WRITE_COMPLETE: in main_event_handler()
/trafficserver/iocore/net/quic/
H A DQUICEchoApp.cc69 case VC_EVENT_WRITE_COMPLETE: { in main_event_handler()
H A DQUICUnidirectionalStream.cc52 case VC_EVENT_WRITE_COMPLETE: { in state_stream_open()
108 case VC_EVENT_WRITE_COMPLETE: { in state_stream_closed()
433 case VC_EVENT_WRITE_COMPLETE: { in state_stream_open()
486 case VC_EVENT_WRITE_COMPLETE: { in state_stream_closed()
H A DQUICBidirectionalStream.cc62 case VC_EVENT_WRITE_COMPLETE: { in state_stream_open()
118 case VC_EVENT_WRITE_COMPLETE: { in state_stream_closed()
/trafficserver/iocore/eventsystem/
H A DP_VConnection.h43 case VC_EVENT_WRITE_COMPLETE: in get_vc_event_name()
H A DI_VConnection.h64 #define VC_EVENT_WRITE_COMPLETE (VC_EVENT_EVENTS_START + 3) macro
/trafficserver/iocore/cache/
H A DCacheTest.cc148 case VC_EVENT_WRITE_COMPLETE: in event_handler()
304 write_test.expect_event = VC_EVENT_WRITE_COMPLETE; in EXCLUSIVE_REGRESSION_TEST()
343 replace_write_test.expect_event = VC_EVENT_WRITE_COMPLETE; in EXCLUSIVE_REGRESSION_TEST()
362 replace_test.expect_event = VC_EVENT_WRITE_COMPLETE; in EXCLUSIVE_REGRESSION_TEST()
386 large_write_test.expect_event = VC_EVENT_WRITE_COMPLETE; in EXCLUSIVE_REGRESSION_TEST()
/trafficserver/proxy/http/
H A DHttpDebugNames.cc130 case VC_EVENT_WRITE_COMPLETE: in get_event_name()
131 …static_assert(static_cast<int>(VC_EVENT_WRITE_COMPLETE) == static_cast<int>(TS_EVENT_VCONN_WRITE_C… in get_event_name()
H A DHttpTunnel.cc934 consumer_handler(VC_EVENT_WRITE_COMPLETE, c); in producer_run()
1213 case VC_EVENT_WRITE_COMPLETE: in producer_handler()
1308 case VC_EVENT_WRITE_COMPLETE: in consumer_handler()
1325 if (event == VC_EVENT_WRITE_COMPLETE) { in consumer_handler()
1507 consumer_handler(VC_EVENT_WRITE_COMPLETE, c); in finish_all_internal()
/trafficserver/src/traffic_quic/
H A Dquic_client.cc233 case VC_EVENT_WRITE_COMPLETE: in main_event_handler()
378 case VC_EVENT_WRITE_COMPLETE: in main_event_handler()
/trafficserver/proxy/http2/
H A DHttp2Stream.cc120 case VC_EVENT_WRITE_COMPLETE: in main_event_handler()
472 Http2StreamDebug("handle write from destroy (event=%d)", VC_EVENT_WRITE_COMPLETE); in initiating_close()
473 write_event = send_tracked_event(write_event, VC_EVENT_WRITE_COMPLETE, &write_vio); in initiating_close()
689 int send_event = this->write_vio.ntodo() == 0 ? VC_EVENT_WRITE_COMPLETE : VC_EVENT_WRITE_READY; in signal_write_event()
/trafficserver/plugins/experimental/memcache/
H A Dtsmemcache.cc398 case VC_EVENT_WRITE_COMPLETE: \
1495 case VC_EVENT_WRITE_COMPLETE: in read_from_client_event()
1515 case VC_EVENT_WRITE_COMPLETE: in stream_event()
1544 case VC_EVENT_WRITE_COMPLETE: in stream_event()
1579 case VC_EVENT_WRITE_COMPLETE: in tunnel_event()
1589 case VC_EVENT_WRITE_COMPLETE: in tunnel_event()
/trafficserver/iocore/utils/
H A DOneWayMultiTunnel.cc198 case VC_EVENT_WRITE_COMPLETE: in startEvent()

Completed in 92 milliseconds

12