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

Method _set_qpack_stream

src/proxy/http3/Http3App.cc:396–419  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

394}
395
396void
397Http3App::_set_qpack_stream(Http3StreamType type, QUICStreamVCAdapter *adapter)
398{
399 // Change app to QPACK from Http3
400 if (type == Http3StreamType::QPACK_ENCODER) {
401 if (this->_qc->direction() == NET_VCONNECTION_IN) {
402 this->_ssn->remote_qpack()->set_encoder_stream(adapter->stream().id());
403 this->_update_vio_cont_to_QPACK(this->_ssn->remote_qpack(), adapter);
404 } else {
405 this->_ssn->local_qpack()->set_encoder_stream(adapter->stream().id());
406 this->_update_vio_cont_to_QPACK(this->_ssn->local_qpack(), adapter);
407 }
408 } else if (type == Http3StreamType::QPACK_DECODER) {
409 if (this->_qc->direction() == NET_VCONNECTION_IN) {
410 this->_ssn->local_qpack()->set_decoder_stream(adapter->stream().id());
411 this->_update_vio_cont_to_QPACK(this->_ssn->local_qpack(), adapter);
412 } else {
413 this->_ssn->remote_qpack()->set_decoder_stream(adapter->stream().id());
414 this->_update_vio_cont_to_QPACK(this->_ssn->remote_qpack(), adapter);
415 }
416 } else {
417 ink_abort("unknown stream type");
418 }
419}
420
421QUICStreamVCAdapter::IOInfo &
422Http3App::_get_stream_info(QUICStreamId stream_id)

Calls 8

set_encoder_streamMethod · 0.80
local_qpackMethod · 0.80
set_decoder_streamMethod · 0.80
ink_abortFunction · 0.50
directionMethod · 0.45
remote_qpackMethod · 0.45
idMethod · 0.45

Tested by

no test coverage detected