| /external/cronet/net/third_party/quiche/src/quiche/quic/core/congestion_control/ |
| D | bandwidth_sampler.cc | 31 QuicByteCount bytes_acked) { in Update() argument
43 if (expected_bytes_acked < best.bytes_acked) { in Update()
44 best.extra_acked = best.bytes_acked - expected_bytes_acked; in Update()
48 if (expected_bytes_acked < second_best.bytes_acked) { in Update()
50 second_best.extra_acked = second_best.bytes_acked - expected_bytes_acked; in Update()
54 if (expected_bytes_acked < third_best.bytes_acked) { in Update()
56 third_best.extra_acked = third_best.bytes_acked - expected_bytes_acked; in Update()
79 aggregation_epoch_bytes_ = bytes_acked; in Update()
104 << ", new_aggregation_bytes_acked:" << bytes_acked; in Update()
106 aggregation_epoch_bytes_ = bytes_acked; in Update()
[all …]
|
| D | bbr_sender.cc | 412 QuicByteCount bytes_acked = in OnCongestionEvent() local
418 CalculateCongestionWindow(bytes_acked, excess_acked); in OnCongestionEvent()
419 CalculateRecoveryWindow(bytes_acked, bytes_lost); in OnCongestionEvent()
761 void BbrSender::CalculateCongestionWindow(QuicByteCount bytes_acked, in CalculateCongestionWindow() argument
783 std::min(target_window, congestion_window_ + bytes_acked); in CalculateCongestionWindow()
788 congestion_window_ = congestion_window_ + bytes_acked; in CalculateCongestionWindow()
796 void BbrSender::CalculateRecoveryWindow(QuicByteCount bytes_acked, in CalculateRecoveryWindow() argument
804 recovery_window_ = unacked_packets_->bytes_in_flight() + bytes_acked; in CalculateRecoveryWindow()
818 recovery_window_ += bytes_acked; in CalculateRecoveryWindow()
823 recovery_window_, unacked_packets_->bytes_in_flight() + bytes_acked); in CalculateRecoveryWindow()
|
| D | bbr2_sender.cc | 329 UpdatePacingRate(congestion_event.bytes_acked); in OnCongestionEvent()
333 UpdateCongestionWindow(congestion_event.bytes_acked); in OnCongestionEvent()
373 void Bbr2Sender::UpdatePacingRate(QuicByteCount bytes_acked) { in UpdatePacingRate() argument
378 if (model_.total_bytes_acked() == bytes_acked) { in UpdatePacingRate()
406 void Bbr2Sender::UpdateCongestionWindow(QuicByteCount bytes_acked) { in UpdateCongestionWindow() argument
412 cwnd_ = std::min(prior_cwnd + bytes_acked, target_cwnd); in UpdateCongestionWindow()
414 cwnd_ = prior_cwnd + bytes_acked; in UpdateCongestionWindow()
426 << ", bytes_acked:" << bytes_acked in UpdateCongestionWindow()
|
| D | bbr2_misc.cc | 140 congestion_event->bytes_acked = total_bytes_acked() - prior_bytes_acked; in OnCongestionEventStart()
144 congestion_event->bytes_acked + congestion_event->bytes_lost) { in OnCongestionEventStart()
147 congestion_event->bytes_acked - congestion_event->bytes_lost; in OnCongestionEventStart()
152 << congestion_event->bytes_acked in OnCongestionEventStart()
162 if (congestion_event->bytes_acked > 0 && in OnCongestionEventStart()
|
| D | bbr2_sender.h | 143 void UpdatePacingRate(QuicByteCount bytes_acked);
144 void UpdateCongestionWindow(QuicByteCount bytes_acked);
|
| D | bbr_sender.h | 228 void CalculateCongestionWindow(QuicByteCount bytes_acked,
232 void CalculateRecoveryWindow(QuicByteCount bytes_acked,
|
| D | bandwidth_sampler.h | 84 QuicByteCount bytes_acked = 0; member
130 QuicTime ack_time, QuicByteCount bytes_acked);
|
| D | bbr2_probe_bw.cc | 354 cycle_.probe_up_acked += congestion_event.bytes_acked; in ProbeInflightHighUpward()
381 cycle_.probe_up_acked += congestion_event.bytes_acked; in ProbeInflightHighUpward()
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/ |
| D | simple_session_notifier.cc | 271 newly_acked.Difference(state->bytes_acked); in OnFrameAcked()
275 state->bytes_acked.Add(offset, offset + data_length); in OnFrameAcked()
289 newly_acked.Difference(state->bytes_acked); in OnFrameAcked()
294 state->bytes_acked.Add(offset, offset + data_length); in OnFrameAcked()
310 bytes_lost.Difference(state->bytes_acked); in OnFrameLost()
330 bytes_lost.Difference(state->bytes_acked); in OnFrameLost()
353 retransmission.Difference(state.bytes_acked); in RetransmitFrames()
397 retransmission.Difference(state.bytes_acked); in RetransmitFrames()
449 !crypto_state_[frame.crypto_frame->level].bytes_acked.Contains( in IsFrameOutstanding()
463 !state.bytes_acked.Contains(offset, offset + data_length)) || in IsFrameOutstanding()
[all …]
|
| D | simple_session_notifier.h | 102 QuicIntervalSet<QuicStreamOffset> bytes_acked; member
|
| /external/linux-kselftest/tools/testing/selftests/bpf/progs/ |
| D | test_tcpbpf_kern.c | 149 global.bytes_acked = skops->bytes_acked; in bpf_testcb()
|
| D | test_sock_fields.c | 108 dst->bytes_acked = src->bytes_acked; in tpcpy()
|
| /external/linux-kselftest/tools/testing/selftests/bpf/ |
| D | test_tcpbpf.h | 14 __u64 bytes_acked; member
|
| /external/linux-kselftest/tools/testing/selftests/bpf/prog_tests/ |
| D | sock_fields.c | 87 tp->bytes_received, tp->bytes_acked); in print_tp()
165 listen_tp.bytes_acked, in check_result()
174 srv_tp.bytes_acked < 2 * DATA_LEN, in check_result()
|
| D | tcpbpf_user.c | 30 ASSERT_EQ(result->bytes_acked, 1002, "bytes_acked"); in verify_result()
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/ |
| D | quic_types.h | 557 QuicPacketLength bytes_acked, in AckedPacket()
560 bytes_acked(bytes_acked), in AckedPacket()
568 QuicPacketLength bytes_acked; member
|
| D | quic_crypto_stream.cc | 232 QuicIntervalSet<QuicStreamOffset> to_ack = send_buffer->bytes_acked(); in NeuterStreamDataOfEncryptionLevel()
332 retransmission.Difference(bytes_acked()); in RetransmitStreamData()
420 retransmission.Difference(send_buffer->bytes_acked()); in RetransmitData()
|
| D | quic_stream_send_buffer.h | 122 const QuicIntervalSet<QuicStreamOffset>& bytes_acked() const { in bytes_acked() function
|
| D | quic_stream.cc | 1138 retransmission.Difference(bytes_acked()); in RetransmitStreamData()
1315 const QuicIntervalSet<QuicStreamOffset>& QuicStream::bytes_acked() const { in bytes_acked() function in quic::QuicStream
1316 return send_buffer_.bytes_acked(); in bytes_acked()
|
| /external/openthread/third_party/tcplp/ |
| D | tcplp.h | 59 uint32_t bytes_acked; member
|
| /external/webrtc/net/dcsctp/tx/ |
| D | outstanding_data_test.cc | 88 EXPECT_EQ(ack.bytes_acked, DataChunk::kHeaderSize + RoundUpTo4(1)); in TEST_F()
124 EXPECT_EQ(ack.bytes_acked, DataChunk::kHeaderSize + RoundUpTo4(1)); in TEST_F()
182 EXPECT_EQ(ack.bytes_acked, DataChunk::kHeaderSize + RoundUpTo4(1)); in TEST_F()
222 EXPECT_EQ(ack.bytes_acked, DataChunk::kHeaderSize + RoundUpTo4(1)); in TEST_F()
258 EXPECT_EQ(ack.bytes_acked, DataChunk::kHeaderSize + RoundUpTo4(1)); in TEST_F()
|
| D | retransmission_queue.cc | 319 ack_info.bytes_acked); in HandleSack()
329 if (ack_info.bytes_acked > 0) { in HandleSack()
|
| D | outstanding_data.h | 55 size_t bytes_acked = 0; member
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/http/ |
| D | quic_headers_stream.cc | 65 newly_acked.Difference(bytes_acked()); in OnStreamFrameAcked()
|
| /external/linux-kselftest/tools/testing/selftests/bpf/verifier/ |
| D | sock.c | 288 BPF_LDX_MEM(BPF_DW, BPF_REG_0, BPF_REG_0, offsetof(struct bpf_tcp_sock, bytes_acked)),
305 BPF_LDX_MEM(BPF_DW, BPF_REG_0, BPF_REG_0, offsetofend(struct bpf_tcp_sock, bytes_acked)),
|