Home
last modified time | relevance | path

Searched refs:seq_num (Results 1 – 25 of 91) sorted by relevance

1234

/external/webrtc/modules/audio_coding/neteq/
Dnack_tracker_unittest.cc40 int seq_num = nack_list[k]; in IsNackListCorrect() local
43 if (seq_num == lost_sequence_numbers[n]) { in IsNackListCorrect()
60 int seq_num = 1; in TEST() local
65 nack->UpdateLastReceivedPacket(seq_num, timestamp); in TEST()
67 seq_num++; in TEST()
78 int seq_num = 1; in TEST() local
82 nack->UpdateLastReceivedPacket(seq_num, timestamp); in TEST()
90 seq_num + num_late_packets, in TEST()
113 uint16_t seq_num = sequence_num_lost_packets[0] - 1; in TEST() local
118 nack->UpdateLastReceivedPacket(seq_num, timestamp); in TEST()
[all …]
/external/webrtc/modules/video_coding/
Dpacket_buffer_unittest.cc52 result.push_back(packet->seq_num); in StartSeqNums()
60 MATCHER_P(StartSeqNumsAre, seq_num, "") {
61 return Matches(ElementsAre(seq_num))(StartSeqNums(arg.packets));
88 *os << "{sn: " << packet->seq_num << " }"; in PrintTo()
90 *os << "{sn: [" << packet->seq_num << "-"; in PrintTo()
92 *os << packet->seq_num << "] }, "; in PrintTo()
115 PacketBufferInsertResult Insert(uint16_t seq_num, // packet sequence number in Insert() argument
124 packet->seq_num = seq_num;
143 const uint16_t seq_num = Rand(); in TEST_F() local
144 EXPECT_THAT(Insert(seq_num, kKeyFrame, kFirst, kLast).packets, SizeIs(1)); in TEST_F()
[all …]
Dpacket_buffer.cc45 seq_num(rtp_packet.SequenceNumber()), in Packet()
83 uint16_t seq_num = packet->seq_num; in InsertPacket() local
84 size_t index = seq_num % buffer_.size(); in InsertPacket()
87 first_seq_num_ = seq_num; in InsertPacket()
89 } else if (AheadOf(first_seq_num_, seq_num)) { in InsertPacket()
96 first_seq_num_ = seq_num; in InsertPacket()
101 if (buffer_[index]->seq_num == packet->seq_num) { in InsertPacket()
106 while (ExpandBufferSize() && buffer_[seq_num % buffer_.size()] != nullptr) { in InsertPacket()
108 index = seq_num % buffer_.size(); in InsertPacket()
132 UpdateMissingPackets(seq_num); in InsertPacket()
[all …]
Dnack_module_unittest.cc81 for (int seq_num = 3; seq_num < 501; ++seq_num) in TEST_P() local
82 EXPECT_EQ(seq_num, sent_nacks_[seq_num - 3]); in TEST_P()
87 for (int seq_num = 502; seq_num < 1001; ++seq_num) in TEST_P() local
88 EXPECT_EQ(seq_num, sent_nacks_[seq_num - 502]); in TEST_P()
96 for (int seq_num = 3; seq_num < 501; ++seq_num) in TEST_P() local
97 EXPECT_EQ(seq_num, sent_nacks_[seq_num - 1]); in TEST_P()
98 for (int seq_num = 502; seq_num < 1001; ++seq_num) in TEST_P() local
99 EXPECT_EQ(seq_num, sent_nacks_[seq_num - 2]); in TEST_P()
114 for (int seq_num = 3; seq_num < 501; ++seq_num) in TEST_P() local
115 EXPECT_EQ(seq_num, sent_nacks_[seq_num - 3]); in TEST_P()
[all …]
Dnack_module2.cc49 : seq_num(0), send_at_seq_num(0), sent_at_time(-1), retries(0) {} in NackInfo()
51 NackModule2::NackInfo::NackInfo(uint16_t seq_num, in NackInfo() argument
54 : seq_num(seq_num), in NackInfo()
134 int NackModule2::OnReceivedPacket(uint16_t seq_num, bool is_keyframe) { in OnReceivedPacket() argument
136 return OnReceivedPacket(seq_num, is_keyframe, false); in OnReceivedPacket()
139 int NackModule2::OnReceivedPacket(uint16_t seq_num, in OnReceivedPacket() argument
150 newest_seq_num_ = seq_num; in OnReceivedPacket()
152 keyframe_list_.insert(seq_num); in OnReceivedPacket()
159 if (seq_num == newest_seq_num_) in OnReceivedPacket()
162 if (AheadOf(newest_seq_num_, seq_num)) { in OnReceivedPacket()
[all …]
Dnack_module2_unittest.cc133 for (int seq_num = 3; seq_num < 501; ++seq_num) in TEST_P() local
134 EXPECT_EQ(seq_num, sent_nacks_[seq_num - 3]); in TEST_P()
139 for (int seq_num = 502; seq_num < 1001; ++seq_num) in TEST_P() local
140 EXPECT_EQ(seq_num, sent_nacks_[seq_num - 502]); in TEST_P()
148 for (int seq_num = 3; seq_num < 501; ++seq_num) in TEST_P() local
149 EXPECT_EQ(seq_num, sent_nacks_[seq_num - 1]); in TEST_P()
150 for (int seq_num = 502; seq_num < 1001; ++seq_num) in TEST_P() local
151 EXPECT_EQ(seq_num, sent_nacks_[seq_num - 2]); in TEST_P()
166 for (int seq_num = 3; seq_num < 501; ++seq_num) in TEST_P() local
167 EXPECT_EQ(seq_num, sent_nacks_[seq_num - 3]); in TEST_P()
[all …]
Dnack_module2.h47 int OnReceivedPacket(uint16_t seq_num, bool is_keyframe);
48 int OnReceivedPacket(uint16_t seq_num, bool is_keyframe, bool is_recovered);
50 void ClearUpTo(uint16_t seq_num);
63 NackInfo(uint16_t seq_num,
67 uint16_t seq_num; member
97 void UpdateReorderingStatistics(uint16_t seq_num)
Dloss_notification_controller_unittest.cc29 uint16_t seq_num; member
39 uint16_t seq_num, in CreatePacket() argument
44 packet.seq_num = seq_num; in CreatePacket()
123 uut_.OnReceivedPacket(packet.seq_num, &frame); in OnReceivedPacket()
125 uut_.OnReceivedPacket(packet.seq_num, nullptr); in OnReceivedPacket()
254 uint16_t seq_num = std::numeric_limits<uint16_t>::max(); in TEST_P() local
255 OnReceivedPacket(CreatePacket(true, true, seq_num, 0, true)); in TEST_P()
256 OnAssembledFrame(seq_num, 0, false); in TEST_P()
259 OnReceivedPacket(CreatePacket(first, last, ++seq_num, 1, false, {0})); in TEST_P()
328 OnAssembledFrame(key_frame_packet.seq_num, key_frame_packet.frame_id, false); in TEST_P()
[all …]
Dpacket_buffer.h63 uint16_t seq_num = 0; member
87 InsertResult InsertPadding(uint16_t seq_num) ABSL_MUST_USE_RESULT
89 void ClearTo(uint16_t seq_num) RTC_LOCKS_EXCLUDED(mutex_);
108 bool PotentialNewFrame(uint16_t seq_num) const
113 std::vector<std::unique_ptr<Packet>> FindFrames(uint16_t seq_num)
116 void UpdateMissingPackets(uint16_t seq_num)
/external/webrtc/modules/video_coding/deprecated/
Dnack_module.cc49 : seq_num(0), send_at_seq_num(0), sent_at_time(-1), retries(0) {} in NackInfo()
51 DEPRECATED_NackModule::NackInfo::NackInfo(uint16_t seq_num, in NackInfo() argument
54 : seq_num(seq_num), in NackInfo()
110 int DEPRECATED_NackModule::OnReceivedPacket(uint16_t seq_num, in OnReceivedPacket() argument
112 return OnReceivedPacket(seq_num, is_keyframe, false); in OnReceivedPacket()
115 int DEPRECATED_NackModule::OnReceivedPacket(uint16_t seq_num, in OnReceivedPacket() argument
126 newest_seq_num_ = seq_num; in OnReceivedPacket()
128 keyframe_list_.insert(seq_num); in OnReceivedPacket()
135 if (seq_num == newest_seq_num_) in OnReceivedPacket()
138 if (AheadOf(newest_seq_num_, seq_num)) { in OnReceivedPacket()
[all …]
Dnack_module.h38 int OnReceivedPacket(uint16_t seq_num, bool is_keyframe);
39 int OnReceivedPacket(uint16_t seq_num, bool is_keyframe, bool is_recovered);
41 void ClearUpTo(uint16_t seq_num);
59 NackInfo(uint16_t seq_num,
63 uint16_t seq_num; member
92 void UpdateReorderingStatistics(uint16_t seq_num)
/external/webrtc/modules/rtp_rtcp/source/
Dulpfec_generator_unittest.cc34 void VerifyHeader(uint16_t seq_num, in VerifyHeader() argument
43 EXPECT_EQ(seq_num, (data[2] << 8) + data[3]); in VerifyHeader()
70 uint16_t seq_num; in TEST_F() member
91 packet.SetSequenceNumber(p.seq_num); in TEST_F()
129 uint16_t seq_num = packet_generator_.NextPacketSeqNum(); in TEST_F() local
130 fec_packets[0]->SetSequenceNumber(seq_num); in TEST_F()
135 VerifyHeader(seq_num, last_timestamp, kRedPayloadType, kFecPayloadType, false, in TEST_F()
168 const uint16_t seq_num = packet_generator_.NextPacketSeqNum(); in TEST_F() local
169 fec_packets[0]->SetSequenceNumber(seq_num); in TEST_F()
170 VerifyHeader(seq_num, last_timestamp, kRedPayloadType, kFecPayloadType, false, in TEST_F()
[all …]
Dforward_error_correction.cc60 return IsNewerSequenceNumber(second->seq_num, first->seq_num); in operator ()()
256 uint16_t seq_num = in GenerateFecPayloads() local
258 media_pkt_idx += static_cast<uint16_t>(seq_num - prev_seq_num); in GenerateFecPayloads()
259 prev_seq_num = seq_num; in GenerateFecPayloads()
312 uint16_t seq_num = ParseSequenceNumber((*media_packets_it)->data.data()); in InsertZerosInPacketMasks() local
314 static_cast<uint16_t>(seq_num - prev_seq_num - 1); in InsertZerosInPacketMasks()
326 prev_seq_num = seq_num; in InsertZerosInPacketMasks()
367 if (recovered_packet->seq_num == received_packet.seq_num) { in InsertMediaPacket()
379 recovered_packet->seq_num = received_packet.seq_num; in InsertMediaPacket()
396 (*protected_it)->seq_num == packet.seq_num) { in UpdateCoveringFecPackets()
[all …]
/external/webrtc/test/fuzzers/
Dulpfec_generator_fuzzer.cc37 uint16_t seq_num = data[i++]; in FuzzOneInput() local
50 ByteWriter<uint16_t>::WriteBigEndian(&packet[2], seq_num++); in FuzzOneInput()
57 if (protect && IsNewerSequenceNumber(seq_num, prev_seq_num) && in FuzzOneInput()
58 seq_num < prev_seq_num + kUlpfecMaxMediaPackets) { in FuzzOneInput()
64 prev_seq_num = seq_num; in FuzzOneInput()
/external/scapy/scapy/layers/tls/crypto/
Dcipher_aead.py128 def auth_encrypt(self, P, A, seq_num=None): argument
160 def auth_decrypt(self, A, C, seq_num=None, add_length=True): argument
296 def _get_nonce(self, seq_num): argument
297 padlen = self.fixed_iv_len - len(seq_num)
298 padded_seq_num = b"\x00" * padlen + seq_num
301 def auth_encrypt(self, P, A, seq_num): argument
314 self._cipher.mode._initialization_vector = self._get_nonce(seq_num)
322 res = self._cipher.encrypt(self._get_nonce(seq_num), P, A,
325 res = self._cipher.encrypt(self._get_nonce(seq_num), P, A)
328 def auth_decrypt(self, A, C, seq_num): argument
[all …]
/external/ltp/lib/
Dtst_crypto.c27 ses->seq_num = 0; in tst_crypto_open()
46 if (nh->nlmsg_seq != ses->seq_num) { in tst_crypto_recv_ack()
49 nh->nlmsg_type, nh->nlmsg_seq, ses->seq_num); in tst_crypto_recv_ack()
74 .nlmsg_seq = ++(ses->seq_num), in tst_crypto_add_alg()
95 nh.nlmsg_seq = ++(ses->seq_num), in tst_crypto_del_alg()
/external/webrtc/media/base/
Drtp_data_engine.cc77 RtpClock::Tick(double now, int* seq_num, uint32_t* timestamp) { in Tick() argument
78 *seq_num = ++last_seq_num_; in Tick()
217 << header.seq_num << " before SetReceive(true) called."; in OnPacketReceived()
241 params.seq_num = header.seq_num; in OnPacketReceived()
311 rtp_clock_by_send_ssrc_[header.ssrc]->Tick(now, &header.seq_num, in SendData()
324 << ", seqnum=" << header.seq_num in SendData()
Drtp_utils_unittest.cc114 int seq_num; in TEST() local
115 EXPECT_TRUE(GetRtpSeqNum(kPcmuFrame, sizeof(kPcmuFrame), &seq_num)); in TEST()
116 EXPECT_EQ(1, seq_num); in TEST()
129 EXPECT_EQ(1, header.seq_num); in TEST()
134 EXPECT_FALSE(GetRtpSeqNum(kInvalidPacket, sizeof(kInvalidPacket), &seq_num)); in TEST()
153 EXPECT_EQ(1111, header.seq_num); in TEST()
/external/scapy/scapy/layers/
Dipsec.py759 def __init__(self, proto, spi, seq_num=1, crypt_algo=None, crypt_key=None, argument
784 self.seq_num = seq_num
830 def _encrypt_esp(self, pkt, seq_num=None, iv=None): argument
838 esp = _ESPPlain(spi=self.spi, seq=seq_num or self.seq_num, iv=iv)
880 if seq_num is None:
881 self.seq_num += 1
885 def _encrypt_ah(self, pkt, seq_num=None): argument
887 ah = AH(spi=self.spi, seq=seq_num or self.seq_num,
930 if seq_num is None:
931 self.seq_num += 1
[all …]
/external/perfetto/src/traced/probes/ftrace/test/data/android_raven_AOSP.MASTER_5.10.43/events/dw3000/dw3000_nfcc_coex_header_check/
Dformat12 field:u8 seq_num; offset:46; size:1; signed:0;
15 …nature=%s, ver_id=%u, seq_num=%u, nb_tlv=%u", REC->dw_name, __print_array(REC->signature, 5, sizeo…
/external/webrtc/call/
Dfake_network_pipe_unittest.cc40 int seq_num; in DeliverPacket() local
41 memcpy(&seq_num, packet.data<uint8_t>(), sizeof(int)); in DeliverPacket()
42 delivered_sequence_numbers_.push_back(seq_num); in DeliverPacket()
336 for (int seq_num : receiver.delivered_sequence_numbers_) { in TEST_F() local
337 EXPECT_GT(seq_num, last_seq_num); in TEST_F()
338 last_seq_num = seq_num; in TEST_F()
353 for (int seq_num : receiver.delivered_sequence_numbers_) { in TEST_F() local
354 if (last_seq_num > seq_num) { in TEST_F()
358 last_seq_num = seq_num; in TEST_F()
/external/webrtc/test/network/
Dcross_traffic.cc217 auto seq_num = next_sequence_number_++; in SendPackets() local
219 send.sequence_number = seq_num; in SendPackets()
224 in_flight_.insert({seq_num, send}); in SendPackets()
225 task_queue_->PostDelayedTask(ToQueuedTask([this, seq_num] { in SendPackets()
226 HandlePacketTimeout(seq_num, in SendPackets()
233 void TcpMessageRouteImpl::HandlePacketTimeout(int seq_num, Timestamp at_time) { in HandlePacketTimeout() argument
234 auto lost = in_flight_.find(seq_num); in HandlePacketTimeout()
/external/webrtc/modules/rtp_rtcp/test/testFec/
Dtest_fec.cc133 uint16_t seq_num = 0; in RunTest() local
246 seq_num = 0; in RunTest()
278 ByteWriter<uint16_t>::WriteBigEndian(&data[2], seq_num); in RunTest()
286 seq_num++; in RunTest()
315 received_packet->seq_num = in RunTest()
334 received_packet->seq_num = fec_seq_num_offset + seq_num; in RunTest()
342 ++seq_num; in RunTest()
/external/webrtc/video/
Drtp_video_stream_receiver2.cc564 NotifyReceiverOfEmptyPacket(packet->seq_num); in OnReceivedPayloadData()
763 first_packet->seq_num, // in OnInsertedPacket()
764 last_packet.seq_num, // in OnInsertedPacket()
996 void RtpVideoStreamReceiver2::NotifyReceiverOfEmptyPacket(uint16_t seq_num) { in NotifyReceiverOfEmptyPacket() argument
999 reference_finder_->PaddingReceived(seq_num); in NotifyReceiverOfEmptyPacket()
1001 OnInsertedPacket(packet_buffer_.InsertPadding(seq_num)); in NotifyReceiverOfEmptyPacket()
1003 nack_module_->OnReceivedPacket(seq_num, /* is_keyframe = */ false, in NotifyReceiverOfEmptyPacket()
1061 int seq_num = -1; in FrameContinuous() local
1064 seq_num = seq_num_it->second; in FrameContinuous()
1065 if (seq_num != -1) in FrameContinuous()
[all …]
/external/scapy/scapy/layers/tls/
Drecord_sslv2.py96 read_seq_num = struct.pack("!I", self.tls_session.rcs.seq_num)
166 self.tls_session.prcs.seq_num += 1
167 self.tls_session.rcs.seq_num += 1
189 write_seq_num = struct.pack("!I", self.tls_session.wcs.seq_num)
269 self.tls_session.pwcs.seq_num += 1
270 self.tls_session.wcs.seq_num += 1

1234