MCPcopy Create free account
hub / github.com/apache/trafficserver / _on_read_ready

Method _on_read_ready

src/proxy/http3/QPACK.cc:1064–1080  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1062}
1063
1064int
1065QPACK::_on_read_ready(VIO *vio)
1066{
1067 int nread = 0;
1068 QUICStreamId stream_id = static_cast<QUICStreamVCAdapter *>(vio->vc_server)->stream().id();
1069
1070 if (stream_id == this->_decoder_stream_id) {
1071 nread = this->_on_decoder_stream_read_ready(*vio->get_reader());
1072 } else if (stream_id == this->_encoder_stream_id) {
1073 nread = this->_on_encoder_stream_read_ready(*vio->get_reader());
1074 } else {
1075 ink_assert(!"The stream ID must match either encoder stream id or decoder stream id");
1076 }
1077
1078 vio->ndone += nread;
1079 return EVENT_DONE;
1080}
1081
1082int
1083QPACK::_on_write_ready(VIO *vio)

Callers 1

event_handlerMethod · 0.95

Calls 4

get_readerMethod · 0.80
idMethod · 0.45

Tested by

no test coverage detected