Home
last modified time | relevance | path

Searched refs:_local_flow_controller (Results 1 – 6 of 6) sorted by relevance

/trafficserver/iocore/net/quic/
H A DQUICBidirectionalStream.cc33 _local_flow_controller(rtt_provider, recv_max_stream_data, _id), in QUICBidirectionalStream()
39 QUICStreamFCDebug("[LOCAL] %" PRIu64 "/%" PRIu64, this->_local_flow_controller.current_offset(), in QUICBidirectionalStream()
40 this->_local_flow_controller.current_limit()); in QUICBidirectionalStream()
180 int ret = this->_local_flow_controller.update(frame.offset() + frame.data_length()); in recv()
181 QUICStreamFCDebug("[LOCAL] %" PRIu64 "/%" PRIu64, this->_local_flow_controller.current_offset(), in recv()
182 this->_local_flow_controller.current_limit()); in recv()
216 …this->_local_flow_controller.forward_limit(this->_reordered_bytes + this->_flow_control_buffer_siz… in recv()
217 … QUICStreamFCDebug("[LOCAL] %" PRIu64 "/%" PRIu64, this->_local_flow_controller.current_offset(), in recv()
218 this->_local_flow_controller.current_limit()); in recv()
358 …return this->_local_flow_controller.will_generate_frame(level, current_packet_size, ack_eliciting,… in will_generate_frame()
[all …]
H A DQUICUnidirectionalStream.cc406 _local_flow_controller(rtt_provider, recv_max_stream_data, _id), in QUICReceiveStream()
412 QUICStreamFCDebug("[LOCAL] %" PRIu64 "/%" PRIu64, this->_local_flow_controller.current_offset(), in QUICReceiveStream()
413 this->_local_flow_controller.current_limit()); in QUICReceiveStream()
532 …return this->_local_flow_controller.will_generate_frame(level, current_packet_size, ack_eliciting,… in will_generate_frame()
591 int ret = this->_local_flow_controller.update(frame.offset() + frame.data_length()); in recv()
592 QUICStreamFCDebug("[LOCAL] %" PRIu64 "/%" PRIu64, this->_local_flow_controller.current_offset(), in recv()
593 this->_local_flow_controller.current_limit()); in recv()
627 …this->_local_flow_controller.forward_limit(this->_reordered_bytes + this->_flow_control_buffer_siz… in recv()
628 … QUICStreamFCDebug("[LOCAL] %" PRIu64 "/%" PRIu64, this->_local_flow_controller.current_offset(), in recv()
629 this->_local_flow_controller.current_limit()); in recv()
[all …]
H A DQUICBidirectionalStream.h36 _local_flow_controller(nullptr, 0, 0), in QUICBidirectionalStream()
94 QUICLocalStreamFlowController _local_flow_controller; member in QUICBidirectionalStream
H A DQUICUnidirectionalStream.h81 QUICReceiveStream() : _local_flow_controller(nullptr, 0, 0), _state(nullptr, nullptr) {} in QUICReceiveStream()
125 QUICLocalStreamFlowController _local_flow_controller; member in QUICReceiveStream
/trafficserver/iocore/net/
H A DQUICNetVConnection.cc401 …this->_local_flow_controller = new QUICLocalConnectionFlowController(&this->_rtt_measure, UINT64_… in start()
423 …this->_frame_generators.add_generator(*this->_local_flow_controller, QUICFrameGeneratorWeight::BEF… in start()
1637 int ret = this->_local_flow_controller->update(this->_stream_manager->total_offset_received()); in _recv_and_ack()
1638 QUICFCDebug("[LOCAL] %" PRIu64 "/%" PRIu64, this->_local_flow_controller->current_offset(), in _recv_and_ack()
1639 this->_local_flow_controller->current_limit()); in _recv_and_ack()
1645 …this->_local_flow_controller->forward_limit(this->_stream_manager->total_reordered_bytes() + this-… in _recv_and_ack()
1646 QUICFCDebug("[LOCAL] %" PRIu64 "/%" PRIu64, this->_local_flow_controller->current_offset(), in _recv_and_ack()
1647 this->_local_flow_controller->current_limit()); in _recv_and_ack()
1738 this->_local_flow_controller->set_limit(local_initial_max_data); in _init_flow_control_params()
1740 QUICFCDebug("[LOCAL] %" PRIu64 "/%" PRIu64, this->_local_flow_controller->current_offset(), in _init_flow_control_params()
[all …]
H A DP_QUICNetVConnection.h249 QUICLocalFlowController *_local_flow_controller = nullptr; member in QUICNetVConnection

Completed in 10 milliseconds