| /external/perfetto/src/profiling/memory/ |
| D | bookkeeping_unittest.cc | 79 uint64_t sequence_number = 1; in TEST() local
83 hd.RecordMalloc({}, {}, 0x1, 5, 5, sequence_number, 100 * sequence_number); in TEST()
84 sequence_number++; in TEST()
85 hd.RecordFree(0x1, sequence_number, 100 * sequence_number); in TEST()
90 uint64_t sequence_number = 1; in TEST() local
95 sequence_number, 100 * sequence_number); in TEST()
96 sequence_number++; in TEST()
98 sequence_number, 100 * sequence_number); in TEST()
106 uint64_t sequence_number = 1; in TEST() local
111 sequence_number, 100 * sequence_number); in TEST()
[all …]
|
| D | bookkeeping.cc | 38 uint64_t sequence_number, in RecordMalloc() argument
58 PERFETTO_DCHECK(alloc.sequence_number != sequence_number); in RecordMalloc()
59 if (alloc.sequence_number < sequence_number) { in RecordMalloc()
68 if (alloc.sequence_number > committed_sequence_number_) { in RecordMalloc()
78 alloc.sequence_number = sequence_number; in RecordMalloc()
84 Allocation(sample_size, alloc_size, sequence_number, in RecordMalloc()
88 RecordOperation(sequence_number, {address, timestamp}); in RecordMalloc()
91 void HeapTracker::RecordOperation(uint64_t sequence_number, in RecordOperation() argument
93 if (sequence_number != committed_sequence_number_ + 1) { in RecordOperation()
94 pending_operations_.emplace(sequence_number, operation); in RecordOperation()
[all …]
|
| D | bookkeeping.h | 138 uint64_t sequence_number,
189 uint64_t sequence_number, in RecordFree() argument
191 RecordOperation(sequence_number, {address, timestamp}); in RecordFree()
215 : sample_size(size), alloc_size(asize), sequence_number(seq) { in Allocation()
224 sequence_number = other.sequence_number; in Allocation()
245 uint64_t sequence_number; member
269 void RecordOperation(uint64_t sequence_number,
280 void CommitOperation(uint64_t sequence_number,
292 if (max_sequence_number_ == alloc.sequence_number - 1) { in AddToCallstackAllocations()
309 max_sequence_number_ = alloc.sequence_number; in AddToCallstackAllocations()
|
| /external/webrtc/modules/rtp_rtcp/source/ |
| D | rtp_sequence_number_map.cc | 32 void RtpSequenceNumberMap::InsertPacket(uint16_t sequence_number, Info info) { in InsertPacket() argument
34 AheadOf(associations_.back().sequence_number, in InsertPacket()
35 associations_.front().sequence_number)); in InsertPacket()
38 associations_.emplace_back(sequence_number, info); in InsertPacket()
42 if (AheadOrAt(sequence_number, associations_.front().sequence_number) && in InsertPacket()
43 AheadOrAt(associations_.back().sequence_number, sequence_number)) { in InsertPacket()
48 associations_.emplace_back(sequence_number, info); in InsertPacket()
68 auto cmp = [](const Association& a, uint16_t sequence_number) { in InsertPacket() argument
69 return AheadOf(a.sequence_number, sequence_number); in InsertPacket()
73 std::lower_bound(erase_to, associations_.end(), sequence_number, cmp); in InsertPacket()
[all …]
|
| D | rtp_sequence_number_map_unittest.cc | 36 Association(uint16_t sequence_number, Info info) in Association()
37 : sequence_number(sequence_number), info(info) {} in Association()
39 uint16_t sequence_number; member
48 Association CreateAssociation(uint16_t sequence_number, uint32_t timestamp) { in CreateAssociation() argument
49 return Association(sequence_number, in CreateAssociation()
67 EXPECT_EQ(uut.Get(association->sequence_number), association->info); in VerifyAssociations()
109 const uint16_t sequence_number = in ProduceRandomAssociationSequence() local
110 associations[i - 1].sequence_number + random_.Rand(1, 100); in ProduceRandomAssociationSequence()
112 AheadOf(sequence_number, associations[0].sequence_number)); in ProduceRandomAssociationSequence()
118 sequence_number, in ProduceRandomAssociationSequence()
[all …]
|
| D | rtp_sequence_number_map.h | 55 void InsertPacket(uint16_t sequence_number, Info info);
60 absl::optional<Info> Get(uint16_t sequence_number) const;
66 explicit Association(uint16_t sequence_number) in Association()
67 : Association(sequence_number, Info(0, false, false)) {} in Association()
69 Association(uint16_t sequence_number, Info info) in Association()
70 : sequence_number(sequence_number), info(info) {} in Association()
72 uint16_t sequence_number; member
|
| D | rtp_packet_history.cc | 172 uint16_t sequence_number) { in GetPacketAndSetSendTime() argument
178 StoredPacket* packet = GetStoredPacket(sequence_number); in GetPacketAndSetSendTime()
202 uint16_t sequence_number) { in GetPacketAndMarkAsPending() argument
204 sequence_number, [](const RtpPacketToSend& packet) { in GetPacketAndMarkAsPending()
210 uint16_t sequence_number, in GetPacketAndMarkAsPending() argument
218 StoredPacket* packet = GetStoredPacket(sequence_number); in GetPacketAndMarkAsPending()
243 void RtpPacketHistory::MarkPacketAsSent(uint16_t sequence_number) { in MarkPacketAsSent() argument
249 StoredPacket* packet = GetStoredPacket(sequence_number); in MarkPacketAsSent()
265 uint16_t sequence_number) const { in GetPacketState()
271 int packet_index = GetPacketIndex(sequence_number); in GetPacketState()
[all …]
|
| D | rtp_packet_history.h | 85 uint16_t sequence_number);
92 uint16_t sequence_number);
100 uint16_t sequence_number,
106 void MarkPacketAsSent(uint16_t sequence_number);
110 absl::optional<PacketState> GetPacketState(uint16_t sequence_number) const;
132 bool SetPendingTransmission(uint16_t sequence_number);
187 int GetPacketIndex(uint16_t sequence_number) const
189 StoredPacket* GetStoredPacket(uint16_t sequence_number)
|
| D | receive_statistics_impl.cc | 54 int64_t sequence_number, in UpdateOutOfOrder() argument
72 last_report_seq_max_ = sequence_number - 2; in UpdateOutOfOrder()
73 received_seq_max_ = sequence_number - 2; in UpdateOutOfOrder()
78 if (std::abs(sequence_number - received_seq_max_) > in UpdateOutOfOrder()
93 if (sequence_number > received_seq_max_) in UpdateOutOfOrder()
112 int64_t sequence_number = in UpdateCounters() local
116 received_seq_first_ = sequence_number; in UpdateCounters()
117 last_report_seq_max_ = sequence_number - 1; in UpdateCounters()
118 received_seq_max_ = sequence_number - 1; in UpdateCounters()
120 } else if (UpdateOutOfOrder(packet, sequence_number, now_ms)) { in UpdateCounters()
[all …]
|
| D | rtcp_nack_stats.cc | 20 void RtcpNackStats::ReportRequest(uint16_t sequence_number) { in ReportRequest() argument
22 IsNewerSequenceNumber(sequence_number, max_sequence_number_)) { in ReportRequest()
23 max_sequence_number_ = sequence_number; in ReportRequest()
|
| /external/webrtc/modules/congestion_controller/rtp/ |
| D | transport_feedback_adapter_unittest.cc | 58 EXPECT_EQ(truth[i].sent_packet.sequence_number, in ComparePacketFeedbackVectors()
59 input[i].sent_packet.sequence_number); in ComparePacketFeedbackVectors()
68 int64_t sequence_number, in CreatePacket() argument
74 res.sent_packet.sequence_number = sequence_number; in CreatePacket()
113 packet_feedback.sent_packet.sequence_number; in OnSentPacket()
121 packet_feedback.sent_packet.sequence_number, in OnSentPacket()
143 feedback.SetBase(packets[0].sent_packet.sequence_number, in TEST_F()
147 EXPECT_TRUE(feedback.AddReceivedPacket(packet.sent_packet.sequence_number, in TEST_F()
177 feedback.SetBase(received_packets[0].sent_packet.sequence_number, in TEST_F()
181 EXPECT_TRUE(feedback.AddReceivedPacket(packet.sent_packet.sequence_number, in TEST_F()
[all …]
|
| /external/webrtc/modules/congestion_controller/goog_cc/ |
| D | robust_throughput_estimator_unittest.cc | 25 uint16_t* sequence_number) { in CreateFeedbackVector() argument
30 packet_feedback_vector[i].sent_packet.sequence_number = *sequence_number; in CreateFeedbackVector()
34 *sequence_number += 1; in CreateFeedbackVector()
53 uint16_t sequence_number = 100; in TEST() local
56 &send_clock, &recv_clock, &sequence_number); in TEST()
62 &send_clock, &recv_clock, &sequence_number); in TEST()
83 uint16_t sequence_number = 100; in TEST() local
86 &send_clock, &recv_clock, &sequence_number); in TEST()
100 &send_clock, &recv_clock, &sequence_number); in TEST()
111 &send_clock, &recv_clock, &sequence_number); in TEST()
[all …]
|
| /external/webrtc/modules/audio_coding/neteq/ |
| D | nack_tracker.cc | 51 void NackTracker::UpdateLastReceivedPacket(uint16_t sequence_number, in UpdateLastReceivedPacket() argument
56 sequence_num_last_received_rtp_ = sequence_number; in UpdateLastReceivedPacket()
62 sequence_num_last_decoded_rtp_ = sequence_number; in UpdateLastReceivedPacket()
68 if (sequence_number == sequence_num_last_received_rtp_) in UpdateLastReceivedPacket()
72 nack_list_.erase(sequence_number); in UpdateLastReceivedPacket()
75 if (IsNewerSequenceNumber(sequence_num_last_received_rtp_, sequence_number)) in UpdateLastReceivedPacket()
78 UpdateSamplesPerPacket(sequence_number, timestamp); in UpdateLastReceivedPacket()
80 UpdateList(sequence_number); in UpdateLastReceivedPacket()
82 sequence_num_last_received_rtp_ = sequence_number; in UpdateLastReceivedPacket()
150 void NackTracker::UpdateLastDecodedPacket(uint16_t sequence_number, in UpdateLastDecodedPacket() argument
[all …]
|
| D | packet.h | 72 uint16_t sequence_number; member
100 this->sequence_number == rhs.sequence_number &&
106 if (this->sequence_number == rhs.sequence_number) {
111 return (static_cast<uint16_t>(rhs.sequence_number -
112 this->sequence_number) < 0xFFFF / 2);
|
| /external/webrtc/modules/pacing/ |
| D | pacing_controller_unittest.cc | 56 uint16_t sequence_number, in BuildPacket() argument
62 packet->SetSequenceNumber(sequence_number); in BuildPacket()
97 uint16_t sequence_number,
240 uint16_t sequence_number, in Send() argument
244 BuildPacket(type, ssrc, sequence_number, capture_time_ms, size)); in Send()
249 uint16_t sequence_number, in SendAndExpectPacket() argument
252 Send(type, ssrc, sequence_number, capture_time_ms, size); in SendAndExpectPacket()
254 SendPacket(ssrc, sequence_number, capture_time_ms, in SendAndExpectPacket()
296 uint16_t sequence_number = 1234; in ConsumeInitialBudget() local
308 SendAndExpectPacket(RtpPacketMediaType::kVideo, kSsrc, sequence_number++, in ConsumeInitialBudget()
[all …]
|
| /external/rust/crates/ring/src/aead/ |
| D | chacha20_poly1305_openssh.rs | 62 sequence_number: u32, in seal_in_place()
66 let mut counter = make_counter(sequence_number);
76 .encrypt_in_place(make_counter(sequence_number), len_in_out);
106 sequence_number: u32, in decrypt_packet_length()
110 let counter = make_counter(sequence_number);
126 sequence_number: u32, in open_in_place()
130 let mut counter = make_counter(sequence_number);
168 fn make_counter(sequence_number: u32) -> Counter { in make_counter()
172 BigEndian::from(sequence_number), in make_counter()
|
| /external/openscreen/cast/streaming/ |
| D | receiver_session.cc | 111 SendErrorAnswerReply(pending_session_->sequence_number, in OnSocketInvalid()
122 return (selected_audio || selected_video) && sequence_number >= 0; in IsValid()
129 if (message.sequence_number < 0) { in OnOffer()
136 SendErrorAnswerReply(message.sequence_number, in OnOffer()
144 properties->sequence_number = message.sequence_number; in OnOffer()
158 SendErrorAnswerReply(message.sequence_number, in OnOffer()
167 SendErrorAnswerReply(message.sequence_number, in OnOffer()
188 SendErrorAnswerReply(properties.sequence_number, in InitializeSession()
197 ReceiverMessage::Type::kAnswer, properties.sequence_number, in InitializeSession()
298 void ReceiverSession::SendErrorAnswerReply(int sequence_number, in SendErrorAnswerReply() argument
[all …]
|
| D | session_messager.cc | 20 int sequence_number, in ReplyIfTimedOut() argument
26 if (it->first == sequence_number) { in ReplyIfTimedOut()
29 << sequence_number; in ReplyIfTimedOut()
30 it->second(ReceiverMessage{reply_type, sequence_number}); in ReplyIfTimedOut()
111 awaiting_replies_.emplace_back(message.sequence_number, std::move(cb)); in SendRequest()
114 seq_num = message.sequence_number] { in SendRequest()
148 int sequence_number; in OnMessage() local
150 &sequence_number)) { in OnMessage()
175 auto it = awaiting_replies_.find(sequence_number); in OnMessage()
178 << sequence_number; in OnMessage()
|
| /external/webrtc/test/network/ |
| D | cross_traffic.cc | 181 auto it = in_flight_.find(packet_info.sequence_number); in OnResponse()
186 auto lost_end = in_flight_.lower_bound(packet_info.sequence_number); in OnResponse()
192 if (packet_info.sequence_number - last_acked_seq_num_ > 1) { in OnResponse()
200 std::max(packet_info.sequence_number, last_acked_seq_num_); in OnResponse()
219 send.sequence_number = seq_num; in SendPackets()
264 void FakeTcpCrossTraffic::OnRequest(int sequence_number, Timestamp at_time) { in OnRequest() argument
266 route_.SendResponse(kAckPacketSize, sequence_number); in OnRequest()
269 void FakeTcpCrossTraffic::OnResponse(int sequence_number, Timestamp at_time) { in OnResponse() argument
271 auto it = in_flight_.find(sequence_number); in OnResponse()
273 last_rtt_ = at_time - in_flight_.at(sequence_number); in OnResponse()
[all …]
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | journal.cc | 34 int64* sequence_number) { in ParseSequenceNumber() argument
35 if (!RE2::FullMatch(journal_file, ".*_(\\d+)", sequence_number)) { in ParseSequenceNumber()
44 int64 sequence_number) { in DataServiceJournalFile() argument
46 absl::StrCat(kJournal, "_", sequence_number)); in DataServiceJournalFile()
61 int64 sequence_number; in EnsureInitialized() local
62 TF_RETURN_IF_ERROR(ParseSequenceNumber(file, &sequence_number)); in EnsureInitialized()
63 latest_sequence_number = std::max(latest_sequence_number, sequence_number); in EnsureInitialized()
|
| /external/webrtc/rtc_tools/network_tester/ |
| D | parse_packet_log.py | 98 first_sequence_number = packets[0].sequence_number
99 last_sequence_number = packets[-1].sequence_number
101 packets_look_up[packet.sequence_number] = packet
107 for sequence_number in range(first_sequence_number, last_sequence_number + 1):
108 if sequence_number in packets_look_up:
111 first_arrival_time = packets_look_up[sequence_number].arrival_timestamp
112 x_time = (packets_look_up[sequence_number].arrival_timestamp -
|
| /external/libcups/notifier/ |
| D | rss.c | 29 int sequence_number; /* notify-sequence-number */ member
51 static _cups_rss_t *new_message(int sequence_number, char *subject,
404 return (a->sequence_number - b->sequence_number); in compare_rss()
444 int sequence_number; /* Sequence number */ in load_rss() local
462 sequence_number = 0; in load_rss()
473 msg = new_message(sequence_number, subject, text, link_url, in load_rss()
496 sequence_number = 0; in load_rss()
538 sequence_number = atoi(start + 6); in load_rss()
559 new_message(int sequence_number, /* I - notify-sequence-number */ in new_message() argument
571 msg->sequence_number = sequence_number; in new_message()
[all …]
|
| /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:
|
| /external/webrtc/modules/video_coding/codecs/vp8/ |
| D | temporal_layers_checker.cc | 46 uint32_t sequence_number, in CheckAndUpdateBufferState() argument
53 state->sequence_number < *lowest_sequence_referenced) { in CheckAndUpdateBufferState()
54 *lowest_sequence_referenced = state->sequence_number; in CheckAndUpdateBufferState()
64 state->sequence_number = sequence_number; in CheckAndUpdateBufferState()
|
| /external/webrtc/modules/rtp_rtcp/source/rtcp_packet/ |
| D | transport_feedback.h | 28 ReceivedPacket(uint16_t sequence_number, int16_t delta_ticks) in ReceivedPacket() argument
29 : sequence_number_(sequence_number), in ReceivedPacket()
32 explicit ReceivedPacket(uint16_t sequence_number) in ReceivedPacket() argument
33 : sequence_number_(sequence_number), received_(false) {} in ReceivedPacket()
37 uint16_t sequence_number() const { return sequence_number_; } in sequence_number() function
70 bool AddReceivedPacket(uint16_t sequence_number, int64_t timestamp_us);
|