Home
last modified time | relevance | path

Searched refs:sequence_number (Results 1 – 25 of 86) sorted by relevance

1234

/external/webrtc/webrtc/modules/pacing/
Dpaced_sender_unittest.cc31 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 …]
Dpacket_router_unittest.cc42 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()
Dpacket_router.cc43 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()
Dpaced_sender.cc51 sequence_number(seq_number), in Packet()
60 uint16_t sequence_number; member
168 dupe_map_[packet.ssrc].insert(packet.sequence_number); in AddToDupeSet()
173 return it->second.insert(packet.sequence_number).second; in AddToDupeSet()
179 it->second.erase(packet.sequence_number); in RemoveFromDupeSet()
298 uint16_t sequence_number, in InsertPacket() argument
312 packets_->Push(paced_sender::Packet(priority, ssrc, sequence_number, in InsertPacket()
428 packet.sequence_number, in SendPacket()
/external/webrtc/webrtc/modules/rtp_rtcp/source/
Drtp_packet_history.cc119 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 …]
Drtp_packet_history.h55 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
Dpacket_loss_stats.cc29 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/
Dsend_time_history_unittest.cc34 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 …]
Dtransport_feedback_adapter_unittest.cc99 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 …]
Dsend_time_history.cc29 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()
Dtransport_feedback_adapter.cc53 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/
Dnack.cc52 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 …]
Ddelay_manager.cc72 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 …]
Dnack.h79 void UpdateLastDecodedPacket(uint16_t sequence_number, uint32_t timestamp);
83 void UpdateLastReceivedPacket(uint16_t sequence_number, uint32_t timestamp);
169 uint32_t EstimateTimestamp(uint16_t sequence_number);
/external/webrtc/webrtc/modules/bitrate_controller/
Dbitrate_controller_unittest.cc272 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/
Dbwe.cc51 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 …]
Dbwe_unittest.cc170 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 …]
Dpacket_sender.h114 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
Dbwe.h51 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/
Drtp_rtcp_defines.h175 : 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/autotest/client/site_tests/cellular_MbimComplianceDataTransfer/
Dcellular_MbimComplianceDTS0511.py46 if nth_2.sequence_number != nth_1.sequence_number + 1:
51 if nth_2.sequence_number != nth_1.sequence_number + 1:
/external/v8/src/
Delements-kind.cc94 ElementsKind GetFastElementsKindFromSequenceIndex(int sequence_number) { in GetFastElementsKindFromSequenceIndex() argument
95 DCHECK(sequence_number >= 0 && in GetFastElementsKindFromSequenceIndex()
96 sequence_number < kFastElementsKindCount); in GetFastElementsKindFromSequenceIndex()
97 return fast_elements_kind_sequence.Get()[sequence_number]; in GetFastElementsKindFromSequenceIndex()
/external/webrtc/webrtc/modules/include/
Dmodule_common_types.h732 inline bool IsNewerSequenceNumber(uint16_t sequence_number, in IsNewerSequenceNumber() argument
737 if (static_cast<uint16_t>(sequence_number - prev_sequence_number) == 0x8000) { in IsNewerSequenceNumber()
738 return sequence_number > prev_sequence_number; in IsNewerSequenceNumber()
740 return sequence_number != prev_sequence_number && in IsNewerSequenceNumber()
741 static_cast<uint16_t>(sequence_number - prev_sequence_number) < 0x8000; in IsNewerSequenceNumber()
775 int64_t UnwrapWithoutUpdate(uint16_t sequence_number) { in UnwrapWithoutUpdate() argument
777 return sequence_number; in UnwrapWithoutUpdate()
780 int64_t delta = sequence_number - cropped_last; in UnwrapWithoutUpdate()
781 if (IsNewerSequenceNumber(sequence_number, cropped_last)) { in UnwrapWithoutUpdate()
797 int64_t Unwrap(uint16_t sequence_number) { in Unwrap() argument
[all …]
/external/webrtc/webrtc/modules/remote_bitrate_estimator/test/estimators/
Dsend_side.cc66 int expected_packets = fb.packet_feedback_vector().back().sequence_number - in GiveFeedback()
75 packet_feedback_vector.back().sequence_number; in GiveFeedback()
84 packet_feedback_vector.back().sequence_number, last_acked_seq_num_); in GiveFeedback()
86 last_acked_seq_num_ = packet_feedback_vector.back().sequence_number; in GiveFeedback()
/external/webrtc/webrtc/modules/rtp_rtcp/test/testAPI/
Dtest_api_video.cc86 uint32_t sequence_number) { in BuildRTPheader() argument
89 ByteWriter<uint16_t>::WriteBigEndian(dataBuffer + 2, sequence_number); in BuildRTPheader()
98 uint32_t sequence_number, in PaddingPacket() argument
108 size_t header_length = BuildRTPheader(buffer, timestamp, sequence_number); in PaddingPacket()

1234