Home
last modified time | relevance | path

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

/trafficserver/iocore/net/quic/
H A DQUICBidirectionalStream.cc32 _remote_flow_controller(send_max_stream_data, _id), in QUICBidirectionalStream()
41 …QUICStreamFCDebug("[REMOTE] %" PRIu64 "/%" PRIu64, this->_remote_flow_controller.current_offset(), in QUICBidirectionalStream()
42 this->_remote_flow_controller.current_limit()); in QUICBidirectionalStream()
229 this->_remote_flow_controller.forward_limit(frame.maximum_stream_data()); in recv()
230 …QUICStreamFCDebug("[REMOTE] %" PRIu64 "/%" PRIu64, this->_remote_flow_controller.current_offset(), in recv()
231 this->_remote_flow_controller.current_limit()); in recv()
428 uint64_t stream_credit = this->_remote_flow_controller.credit(); in generate_frame()
466 int ret = this->_remote_flow_controller.update(this->_send_offset + len); in generate_frame()
473 this->_remote_flow_controller.current_limit()); in generate_frame()
474 …if (this->_remote_flow_controller.current_offset() == this->_remote_flow_controller.current_limit(… in generate_frame()
[all …]
H A DQUICUnidirectionalStream.cc34 …QUICStreamFCDebug("[REMOTE] %" PRIu64 "/%" PRIu64, this->_remote_flow_controller.current_offset(), in QUICSendStream()
35 this->_remote_flow_controller.current_limit()); in QUICSendStream()
183 uint64_t stream_credit = this->_remote_flow_controller.credit(); in generate_frame()
221 int ret = this->_remote_flow_controller.update(this->_send_offset + len); in generate_frame()
227 …QUICStreamFCDebug("[REMOTE] %" PRIu64 "/%" PRIu64, this->_remote_flow_controller.current_offset(), in generate_frame()
228 this->_remote_flow_controller.current_limit()); in generate_frame()
229 …if (this->_remote_flow_controller.current_offset() == this->_remote_flow_controller.current_limit(… in generate_frame()
257 this->_remote_flow_controller.forward_limit(frame.maximum_stream_data()); in recv()
258 …QUICStreamFCDebug("[REMOTE] %" PRIu64 "/%" PRIu64, this->_remote_flow_controller.current_offset(), in recv()
259 this->_remote_flow_controller.current_limit()); in recv()
[all …]
H A DQUICBidirectionalStream.h35 _remote_flow_controller(0, 0), in QUICBidirectionalStream()
93 QUICRemoteStreamFlowController _remote_flow_controller; member in QUICBidirectionalStream
H A DQUICUnidirectionalStream.h32 QUICSendStream() : _remote_flow_controller(0, 0), _state(nullptr, nullptr) {} in QUICSendStream()
67 QUICRemoteStreamFlowController _remote_flow_controller; member in QUICSendStream
/trafficserver/iocore/net/
H A DQUICNetVConnection.cc400 this->_remote_flow_controller = new QUICRemoteConnectionFlowController(UINT64_MAX); in start()
424 …this->_frame_generators.add_generator(*this->_remote_flow_controller, QUICFrameGeneratorWeight::BE… in start()
671 …this->_remote_flow_controller->forward_limit(static_cast<const QUICMaxDataFrame &>(frame).maximum_… in handle_frame()
672 QUICFCDebug("[REMOTE] %" PRIu64 "/%" PRIu64, this->_remote_flow_controller->current_offset(), in handle_frame()
673 this->_remote_flow_controller->current_limit()); in handle_frame()
1545 … int ret = this->_remote_flow_controller->update(this->_stream_manager->total_offset_sent()); in _packetize_frames()
1546 … QUICFCDebug("[REMOTE] %" PRIu64 "/%" PRIu64, this->_remote_flow_controller->current_offset(), in _packetize_frames()
1547 this->_remote_flow_controller->current_limit()); in _packetize_frames()
1739 this->_remote_flow_controller->set_limit(remote_initial_max_data); in _init_flow_control_params()
1742 QUICFCDebug("[REMOTE] %" PRIu64 "/%" PRIu64, this->_remote_flow_controller->current_offset(), in _init_flow_control_params()
[all …]
H A DP_QUICNetVConnection.h248 QUICRemoteFlowController *_remote_flow_controller = nullptr; member in QUICNetVConnection

Completed in 15 milliseconds