| /external/perfetto/src/profiling/memory/ |
| D | bookkeeping_unittest.cc | 57 uint64_t sequence_number = 1; in TEST() local
61 hd.RecordMalloc(stack(), 1, 5, sequence_number, 100 * sequence_number); in TEST()
62 sequence_number++; in TEST()
63 hd.RecordMalloc(stack2(), 2, 2, sequence_number, 100 * sequence_number); in TEST()
64 sequence_number++; in TEST()
67 ASSERT_EQ(hd.GetTimestampForTesting(), 100 * (sequence_number - 1)); in TEST()
68 hd.RecordFree(2, sequence_number, 100 * sequence_number); in TEST()
69 sequence_number++; in TEST()
72 ASSERT_EQ(hd.GetTimestampForTesting(), 100 * (sequence_number - 1)); in TEST()
73 hd.RecordFree(1, sequence_number, 100 * sequence_number); in TEST()
[all …]
|
| D | bookkeeping.cc | 50 uint64_t sequence_number, in RecordMalloc() argument
55 PERFETTO_DCHECK(alloc.sequence_number != sequence_number); in RecordMalloc()
56 if (alloc.sequence_number < sequence_number) { in RecordMalloc()
65 if (alloc.sequence_number > committed_sequence_number_) { in RecordMalloc()
74 alloc.sequence_number = sequence_number; in RecordMalloc()
80 Allocation(size, sequence_number, in RecordMalloc()
84 RecordOperation(sequence_number, {address, timestamp}); in RecordMalloc()
87 void HeapTracker::RecordOperation(uint64_t sequence_number, in RecordOperation() argument
89 if (sequence_number != committed_sequence_number_ + 1) { in RecordOperation()
90 pending_operations_.emplace(sequence_number, operation); in RecordOperation()
[all …]
|
| D | wire_protocol_unittest.cc | 33 return std::tie(one.sequence_number, one.alloc_size, one.alloc_address, in operator ==()
35 std::tie(other.sequence_number, other.alloc_size, in operator ==()
47 if (std::tie(one.entries[i].sequence_number, one.entries[i].addr) != in operator ==()
48 std::tie(other.entries[i].sequence_number, other.entries[i].addr)) in operator ==()
77 metadata.sequence_number = 0xA1A2A3A4A5A6A7A8; in TEST()
115 batch.entries[i].sequence_number = 0x111111111111111; in TEST()
|
| D | bookkeeping.h | 271 uint64_t sequence_number,
278 uint64_t sequence_number, in RecordFree() argument
280 RecordOperation(sequence_number, {address, timestamp}); in RecordFree()
309 : total_size(size), sequence_number(seq), callstack_allocations(csa) { in Allocation()
317 sequence_number = other.sequence_number; in Allocation()
338 uint64_t sequence_number; member
360 void RecordOperation(uint64_t sequence_number,
371 void CommitOperation(uint64_t sequence_number,
|
| /external/webrtc/webrtc/modules/pacing/ |
| D | paced_sender_unittest.cc | 31 uint16_t sequence_number,
43 uint16_t sequence_number, in TimeToSendPacket() argument
71 uint16_t sequence_number, in TimeToSendPacket() argument
123 uint16_t sequence_number, in SendAndExpectPacket() argument
127 send_bucket_->InsertPacket(priority, ssrc, sequence_number, capture_time_ms, in SendAndExpectPacket()
130 TimeToSendPacket(ssrc, sequence_number, capture_time_ms, false)) in SendAndExpectPacket()
142 uint16_t sequence_number = 1234; in TEST_F() local
146 sequence_number++, in TEST_F()
152 sequence_number++, in TEST_F()
158 sequence_number++, in TEST_F()
[all …]
|
| D | packet_router_unittest.cc | 42 uint16_t sequence_number = 17; in TEST_F() local
49 EXPECT_CALL(rtp_1, TimeToSendPacket(kSsrc1, sequence_number, timestamp, in TEST_F()
54 EXPECT_TRUE(packet_router_->TimeToSendPacket(kSsrc1, sequence_number, in TEST_F()
58 ++sequence_number; in TEST_F()
66 EXPECT_CALL(rtp_2, TimeToSendPacket(kSsrc2, sequence_number, timestamp, in TEST_F()
70 EXPECT_TRUE(packet_router_->TimeToSendPacket(kSsrc2, sequence_number, in TEST_F()
78 EXPECT_TRUE(packet_router_->TimeToSendPacket(kSsrc1, sequence_number, in TEST_F()
88 EXPECT_TRUE(packet_router_->TimeToSendPacket(kSsrc1 + kSsrc2, sequence_number, in TEST_F()
98 EXPECT_TRUE(packet_router_->TimeToSendPacket(kSsrc1, sequence_number, in TEST_F()
|
| D | packet_router.cc | 43 uint16_t sequence_number, in TimeToSendPacket() argument
49 return rtp_module->TimeToSendPacket(ssrc, sequence_number, in TimeToSendPacket()
71 void PacketRouter::SetTransportWideSequenceNumber(uint16_t sequence_number) { in SetTransportWideSequenceNumber() argument
72 rtc::AtomicOps::ReleaseStore(&transport_seq_, sequence_number); in SetTransportWideSequenceNumber()
|
| /external/webrtc/webrtc/modules/rtp_rtcp/source/ |
| D | rtp_packet_history.cc | 119 stored_packets_[prev_index_].sequence_number = seq_num; in PutRTPPacket()
133 bool RTPPacketHistory::HasRTPPacket(uint16_t sequence_number) const { in HasRTPPacket()
140 bool found = FindSeqNum(sequence_number, &index); in HasRTPPacket()
152 bool RTPPacketHistory::SetSent(uint16_t sequence_number) { in SetSent() argument
159 bool found = FindSeqNum(sequence_number, &index); in SetSent()
173 bool RTPPacketHistory::GetPacketAndSetSendTime(uint16_t sequence_number, in GetPacketAndSetSendTime() argument
185 bool found = FindSeqNum(sequence_number, &index); in GetPacketAndSetSendTime()
187 LOG(LS_WARNING) << "No match for getting seqNum " << sequence_number; in GetPacketAndSetSendTime()
194 LOG(LS_WARNING) << "No match for getting seqNum " << sequence_number in GetPacketAndSetSendTime()
246 bool RTPPacketHistory::FindSeqNum(uint16_t sequence_number, in FindSeqNum() argument
[all …]
|
| D | rtp_packet_history.h | 55 bool GetPacketAndSetSendTime(uint16_t sequence_number,
65 bool HasRTPPacket(uint16_t sequence_number) const;
67 bool SetSent(uint16_t sequence_number);
79 bool FindSeqNum(uint16_t sequence_number, int32_t* index) const
92 uint16_t sequence_number = 0; member
|
| D | packet_loss_stats.cc | 29 void PacketLossStats::AddLostPacket(uint16_t sequence_number) { in AddLostPacket() argument
32 static_cast<int>(*(lost_packets_buffer_.rbegin())) - sequence_number in AddLostPacket()
35 lost_packets_wrapped_buffer_.insert(sequence_number); in AddLostPacket()
37 lost_packets_buffer_.insert(sequence_number); in AddLostPacket()
|
| /external/webrtc/webrtc/modules/remote_bitrate_estimator/ |
| D | send_time_history_unittest.cc | 34 void AddPacketWithSendTime(uint16_t sequence_number, in AddPacketWithSendTime() argument
38 history_.AddAndRemoveOld(sequence_number, length, was_paced); in AddPacketWithSendTime()
39 history_.OnSentPacket(sequence_number, send_time_ms); in AddPacketWithSendTime()
50 PacketInfo(int64_t arrival_time_ms, uint16_t sequence_number) in PacketInfo() argument
51 : PacketInfo(arrival_time_ms, 0, sequence_number, 0, false) {} in PacketInfo()
54 uint16_t sequence_number, in PacketInfo() argument
60 sequence_number, in PacketInfo()
66 sequence_number == other.sequence_number && in operator ==()
101 EXPECT_EQ(kSeqNo, info.sequence_number); in TEST_F()
122 history_.AddAndRemoveOld(sent_packets[i].sequence_number, in TEST_F()
[all …]
|
| D | transport_feedback_adapter_unittest.cc | 99 EXPECT_EQ(truth[i].sequence_number, input[i].sequence_number); in ComparePacketVectors()
108 adapter_->AddPacket(info.sequence_number, info.payload_size, in OnSentPacket()
110 adapter_->OnSentPacket(info.sequence_number, info.send_time_ms); in OnSentPacket()
133 feedback.WithBase(packets[0].sequence_number, in TEST_F()
137 EXPECT_TRUE(feedback.WithReceivedPacket(packet.sequence_number, in TEST_F()
164 if (packet.sequence_number >= kSendSideDropBefore) in TEST_F()
169 feedback.WithBase(packets[0].sequence_number, in TEST_F()
173 if (packet.sequence_number <= kReceiveSideDropAfter) { in TEST_F()
174 EXPECT_TRUE(feedback.WithReceivedPacket(packet.sequence_number, in TEST_F()
209 feedback->WithBase(packets[i].sequence_number, in TEST_F()
[all …]
|
| D | send_time_history.cc | 29 void SendTimeHistory::AddAndRemoveOld(uint16_t sequence_number, in AddAndRemoveOld() argument
35 oldest_sequence_number_ = sequence_number; in AddAndRemoveOld()
38 sequence_number, PacketInfo(clock_->TimeInMilliseconds(), 0, -1, in AddAndRemoveOld()
39 sequence_number, length, was_paced))); in AddAndRemoveOld()
42 bool SendTimeHistory::OnSentPacket(uint16_t sequence_number, in OnSentPacket() argument
44 auto it = history_.find(sequence_number); in OnSentPacket()
87 auto it = history_.find(packet->sequence_number); in GetInfo()
95 if (packet->sequence_number == oldest_sequence_number_) in GetInfo()
|
| D | transport_feedback_adapter.cc | 53 void TransportFeedbackAdapter::AddPacket(uint16_t sequence_number, in AddPacket() argument
57 send_time_history_.AddAndRemoveOld(sequence_number, length, was_paced); in AddPacket()
60 void TransportFeedbackAdapter::OnSentPacket(uint16_t sequence_number, in OnSentPacket() argument
63 send_time_history_.OnSentPacket(sequence_number, send_time_ms); in OnSentPacket()
88 uint16_t sequence_number = feedback.GetBaseSequence(); in OnTransportFeedback() local
103 PacketInfo info(timestamp_ms, sequence_number); in OnTransportFeedback()
110 ++sequence_number; in OnTransportFeedback()
|
| /external/webrtc/webrtc/modules/audio_coding/neteq/ |
| D | nack.cc | 52 void Nack::UpdateLastReceivedPacket(uint16_t sequence_number, in UpdateLastReceivedPacket() argument
57 sequence_num_last_received_rtp_ = sequence_number; in UpdateLastReceivedPacket()
63 sequence_num_last_decoded_rtp_ = sequence_number; in UpdateLastReceivedPacket()
69 if (sequence_number == sequence_num_last_received_rtp_) in UpdateLastReceivedPacket()
73 nack_list_.erase(sequence_number); in UpdateLastReceivedPacket()
76 if (IsNewerSequenceNumber(sequence_num_last_received_rtp_, sequence_number)) in UpdateLastReceivedPacket()
79 UpdateSamplesPerPacket(sequence_number, timestamp); in UpdateLastReceivedPacket()
81 UpdateList(sequence_number); in UpdateLastReceivedPacket()
83 sequence_num_last_received_rtp_ = sequence_number; in UpdateLastReceivedPacket()
150 void Nack::UpdateLastDecodedPacket(uint16_t sequence_number, in UpdateLastDecodedPacket() argument
[all …]
|
| D | delay_manager.cc | 72 int DelayManager::Update(uint16_t sequence_number, in Update() argument
82 last_seq_no_ = sequence_number; in Update()
91 !IsNewerSequenceNumber(sequence_number, last_seq_no_)) { in Update()
98 static_cast<uint16_t>(sequence_number - last_seq_no_); in Update()
110 UpdateCumulativeSums(packet_len_ms, sequence_number); in Update()
114 if (IsNewerSequenceNumber(sequence_number, last_seq_no_ + 1)) { in Update()
118 iat_packets -= static_cast<uint16_t>(sequence_number - last_seq_no_ - 1); in Update()
120 } else if (!IsNewerSequenceNumber(sequence_number, last_seq_no_)) { in Update()
121 iat_packets += static_cast<uint16_t>(last_seq_no_ + 1 - sequence_number); in Update()
139 last_seq_no_ = sequence_number; in Update()
[all …]
|
| /external/webrtc/webrtc/modules/bitrate_controller/ |
| D | bitrate_controller_unittest.cc | 272 uint32_t sequence_number[2] = {0, 0xFF00}; in TEST_F() local
282 report_blocks.push_back(CreateReportBlock(1, 2, 0, sequence_number[0])); in TEST_F()
294 report_blocks.push_back(CreateReportBlock(1, 2, 0, sequence_number[0])); in TEST_F()
295 report_blocks.push_back(CreateReportBlock(1, 3, 0, sequence_number[1])); in TEST_F()
303 sequence_number[0] += 20; in TEST_F()
304 sequence_number[1] += 1; in TEST_F()
311 report_blocks.push_back(CreateReportBlock(1, 2, 50, sequence_number[0])); in TEST_F()
312 report_blocks.push_back(CreateReportBlock(1, 3, 0, sequence_number[1])); in TEST_F()
318 sequence_number[0] += 20; in TEST_F()
319 sequence_number[1] += 20; in TEST_F()
[all …]
|
| /external/webrtc/webrtc/modules/remote_bitrate_estimator/test/ |
| D | bwe.cc | 51 received_packets_.Insert(media_packet.sequence_number(), in ReceivePacket()
190 uint16_t oldest_seq_num = (*node_it)->sequence_number; in RecentPacketLossRatio()
197 uint16_t seq_num = (*node_it)->sequence_number; in RecentPacketLossRatio()
219 void LinkedSet::Insert(uint16_t sequence_number, in Insert() argument
223 auto it = map_.find(sequence_number); in Insert()
231 map_[sequence_number] = list_.begin(); in Insert()
237 UpdateHead(new PacketIdentifierNode(sequence_number, send_time_ms, in Insert()
243 Insert(packet_identifier.sequence_number, packet_identifier.send_time_ms, in Insert()
248 map_.erase(list_.back()->sequence_number); in RemoveTail()
254 map_[new_head->sequence_number] = list_.begin(); in UpdateHead()
[all …]
|
| D | bwe_unittest.cc | 170 uint16_t sequence_number = i; in TEST_F() local
172 sequence_number); in TEST_F()
196 uint16_t sequence_number = static_cast<uint16_t>(i); in TEST_F() local
198 const MediaPacket media_packet(kFlowId, 0, 0, sequence_number); in TEST_F()
205 uint16_t sequence_number = static_cast<uint16_t>(i); in TEST_F() local
207 const MediaPacket media_packet(kFlowId, 0, 0, sequence_number); in TEST_F()
215 uint16_t sequence_number = static_cast<uint16_t>(i); in TEST_F() local
216 const MediaPacket media_packet(kFlowId, 0, 0, sequence_number); in TEST_F()
224 uint16_t sequence_number = static_cast<uint16_t>(i); in TEST_F() local
225 const MediaPacket media_packet(kFlowId, 0, 0, sequence_number); in TEST_F()
[all …]
|
| D | packet_sender.h | 114 uint16_t sequence_number,
154 : sequence_number(packet.header().sequenceNumber), in InFlight()
158 : sequence_number(seq_num), time_ms(now_ms) {} in InFlight()
161 return sequence_number < rhs.sequence_number;
164 uint16_t sequence_number; // Sequence number of a packet in flight, or a member
|
| D | bwe.h | 51 PacketIdentifierNode(uint16_t sequence_number, in PacketIdentifierNode()
55 : sequence_number(sequence_number), in PacketIdentifierNode()
60 uint16_t sequence_number; member
80 void Insert(uint16_t sequence_number,
|
| /external/webrtc/webrtc/modules/rtp_rtcp/include/ |
| D | rtp_rtcp_defines.h | 175 : sequence_number(0), in RtpState()
181 uint16_t sequence_number; member
260 PacketInfo(int64_t arrival_time_ms, uint16_t sequence_number) in PacketInfo()
261 : PacketInfo(-1, arrival_time_ms, -1, sequence_number, 0, false) {} in PacketInfo()
265 uint16_t sequence_number, in PacketInfo()
271 sequence_number, in PacketInfo()
278 uint16_t sequence_number, in PacketInfo()
284 sequence_number(sequence_number), in PacketInfo()
298 uint16_t sequence_number; member
312 virtual void AddPacket(uint16_t sequence_number,
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | numa_map_and_batch_dataset_op.cc | 429 uint64* index, size_t* sequence_number) { in RetrieveInput() argument
452 *sequence_number = next_input_; in RetrieveInput()
473 size_t sequence_number, in GetBatchTensors() argument
476 DCHECK(sequence_number < kWindowSize) << sequence_number; in GetBatchTensors()
477 DCHECK(batches_[sequence_number].state == BatchState::kInputsFilled || in GetBatchTensors()
478 batches_[sequence_number].state == BatchState::kAllMapsStarted) in GetBatchTensors()
479 << sequence_number; in GetBatchTensors()
481 if (batches_[sequence_number].outputs.empty()) { in GetBatchTensors()
482 allocate_output(batches_[sequence_number].inputs.size(), in GetBatchTensors()
483 &batches_[sequence_number].outputs); in GetBatchTensors()
[all …]
|
| /external/u-boot/net/ |
| D | fastboot.c | 31 static unsigned short sequence_number = 1; variable
63 .seq = htons(sequence_number) in fastboot_udp_send_info()
65 ++sequence_number; in fastboot_udp_send_info()
155 tmp = htons(sequence_number); in fastboot_send()
193 if (header.seq != sequence_number) { in fastboot_send()
194 response_header.seq = htons(sequence_number); in fastboot_send()
287 if (header.seq == sequence_number) { in fastboot_handler()
290 sequence_number++; in fastboot_handler()
291 } else if (header.seq == sequence_number - 1) { in fastboot_handler()
|
| /external/autotest/client/site_tests/cellular_MbimComplianceDataTransfer/ |
| D | cellular_MbimComplianceDTS0511.py | 46 if nth_2.sequence_number != nth_1.sequence_number + 1:
51 if nth_2.sequence_number != nth_1.sequence_number + 1:
|