Home
last modified time | relevance | path

Searched refs:packet_ (Results 1 – 25 of 49) sorted by relevance

12

/external/webrtc/modules/video_coding/
Dsession_info_unittest.cc26 packet_.video_header.frame_type = VideoFrameType::kVideoFrameDelta; in SetUp()
27 packet_.sizeBytes = packet_buffer_size(); in SetUp()
28 packet_.dataPtr = packet_buffer_; in SetUp()
29 packet_.seqNum = 0; in SetUp()
30 packet_.timestamp = 0; in SetUp()
59 VCMPacket packet_; member in webrtc::TestSessionInfo
67 packet_.video_header.codec = kVideoCodecVP8; in SetUp()
116 packet_.video_header.is_first_packet_in_frame = true; in TEST_F()
117 packet_.seqNum = 0xFFFE; in TEST_F()
118 packet_.sizeBytes = packet_buffer_size(); in TEST_F()
[all …]
Djitter_buffer_unittest.cc67 packet_.reset(new VCMPacket(data_, size_, rtp_header, video_header, in SetUp()
120 std::unique_ptr<VCMPacket> packet_; member in webrtc::TestBasicJitterBuffer
242 packet_->video_header.frame_type = VideoFrameType::kVideoFrameKey; in TEST_F()
243 packet_->video_header.is_first_packet_in_frame = true; in TEST_F()
244 packet_->markerBit = true; in TEST_F()
245 packet_->timestamp += 123 * 90; in TEST_F()
250 jitter_buffer_->InsertPacket(*packet_, &retransmitted)); in TEST_F()
258 packet_->video_header.frame_type = VideoFrameType::kVideoFrameKey; in TEST_F()
259 packet_->video_header.is_first_packet_in_frame = true; in TEST_F()
260 packet_->markerBit = false; in TEST_F()
[all …]
/external/webrtc/modules/audio_coding/neteq/tools/
Dneteq_replacement_input.cc29 packet_ = source_->PopPacket(); in NetEqReplacementInput()
34 return packet_ in NextPacketTime()
35 ? absl::optional<int64_t>(static_cast<int64_t>(packet_->time_ms)) in NextPacketTime()
44 std::unique_ptr<PacketData> to_return = std::move(packet_); in PopPacket()
46 packet_ = source_->PopPacket(); in PopPacket()
47 if (!packet_) in PopPacket()
49 if (packet_->payload.size() > packet_->header.paddingLength) { in PopPacket()
74 packet_.reset(); in ReplacePacket()
78 RTC_DCHECK(packet_); in ReplacePacket()
80 RTC_CHECK_EQ(forbidden_types_.count(packet_->header.payloadType), 0) in ReplacePacket()
[all …]
Dneteq_packet_source_input.cc26 return packet_ in NextPacketTime()
27 ? absl::optional<int64_t>(static_cast<int64_t>(packet_->time_ms())) in NextPacketTime()
32 return packet_ ? absl::optional<RTPHeader>(packet_->header()) : absl::nullopt; in NextHeader()
36 packet_ = source()->NextPacket(); in LoadNextPacket()
40 if (!packet_) { in PopPacket()
44 packet_data->header = packet_->header(); in PopPacket()
45 if (packet_->payload_length_bytes() == 0 && in PopPacket()
46 packet_->virtual_payload_length_bytes() > 0) { in PopPacket()
49 packet_data->payload.SetSize(packet_->virtual_payload_length_bytes()); in PopPacket()
52 packet_data->payload.SetData(packet_->payload(), in PopPacket()
[all …]
Dpacket.cc25 : packet_(std::move(packet)), in Packet()
97 bool padding = (packet_[0] & 0b0010'0000); in ParseHeader()
101 rtc::CopyOnWriteBuffer packet(packet_); in ParseHeader()
113 if (!rtp_packet.Parse(packet_)) { in ParseHeader()
117 rtp_payload_ = rtc::MakeArrayView(packet_.data() + rtp_packet.headers_size(), in ParseHeader()
/external/cronet/net/third_party/quiche/src/quiche/quic/core/
Dquic_packet_creator.cc81 packet_(packet) { in ScopedPacketContextSwitcher()
82 packet_->packet_number = packet_number, in ScopedPacketContextSwitcher()
83 packet_->packet_number_length = packet_number_length; in ScopedPacketContextSwitcher()
84 packet_->encryption_level = encryption_level; in ScopedPacketContextSwitcher()
88 packet_->packet_number = saved_packet_number_; in ~ScopedPacketContextSwitcher()
89 packet_->packet_number_length = saved_packet_number_length_; in ~ScopedPacketContextSwitcher()
90 packet_->encryption_level = saved_encryption_level_; in ~ScopedPacketContextSwitcher()
97 SerializedPacket* packet_; member in quic::__anonf37b83570111::ScopedPacketContextSwitcher
125 packet_(QuicPacketNumber(), PACKET_1BYTE_PACKET_NUMBER, nullptr, 0, false, in QuicPacketCreator()
144 DeleteFrames(&packet_.retransmittable_frames); in ~QuicPacketCreator()
[all …]
Dquic_buffered_packet_store_test.cc69 packet_(packet_content_.data(), packet_content_.size(), packet_time_), in QuicBufferedPacketStoreTest()
82 QuicReceivedPacket packet_; member in quic::test::__anonee55a8950111::QuicBufferedPacketStoreTest
89 store_.EnqueuePacket(connection_id, false, packet_, self_address_, in TEST_F()
111 store_.EnqueuePacket(connection_id, false, packet_, self_address_, in TEST_F()
113 store_.EnqueuePacket(connection_id, false, packet_, self_address_, in TEST_F()
128 store_.EnqueuePacket(connection_id, false, packet_, self_address_, in TEST_F()
130 store_.EnqueuePacket(connection_id, false, packet_, self_address_, in TEST_F()
153 store_.EnqueuePacket(connection_id, false, packet_, self_address_, in TEST_F()
158 store_.EnqueuePacket(connection_id, false, packet_, self_address_, in TEST_F()
180 store_.EnqueuePacket(connection_id, false, packet_, self_address_, in TEST_F()
[all …]
Dchlo_extractor_test.cc99 packet_ = std::make_unique<QuicEncryptedPacket>(buffer_, encrypted_length); in MakePacket()
100 EXPECT_TRUE(packet_ != nullptr); in MakePacket()
107 std::unique_ptr<QuicEncryptedPacket> packet_; member in quic::test::__anon2cca8b5f0111::ChloExtractorTest
124 EXPECT_TRUE(ChloExtractor::Extract(*packet_, version_, {}, &delegate_, in TEST_P()
142 EXPECT_FALSE(ChloExtractor::Extract(*packet_, version_, {}, &delegate_, in TEST_P()
153 EXPECT_FALSE(ChloExtractor::Extract(*packet_, version_, {}, &delegate_, in TEST_P()
160 EXPECT_FALSE(ChloExtractor::Extract(*packet_, version_, {}, &delegate_, in TEST_P()
/external/webrtc/logging/rtc_event_log/events/
Drtc_event_rtp_packet_outgoing.h46 size_t packet_length() const { return packet_.size(); } in packet_length()
49 return rtc::MakeArrayView(packet_.data(), header_length()); in RawHeader()
51 uint32_t Ssrc() const { return packet_.Ssrc(); } in Ssrc()
52 uint32_t Timestamp() const { return packet_.Timestamp(); } in Timestamp()
53 uint16_t SequenceNumber() const { return packet_.SequenceNumber(); } in SequenceNumber()
54 uint8_t PayloadType() const { return packet_.PayloadType(); } in PayloadType()
55 bool Marker() const { return packet_.Marker(); } in Marker()
58 return packet_.GetExtension<ExtensionTrait>(std::forward<Args>(args)...); in GetExtension()
62 return packet_.HasExtension<ExtensionTrait>(); in HasExtension()
65 size_t payload_length() const { return packet_.payload_size(); } in payload_length()
[all …]
Drtc_event_rtp_packet_incoming.h45 size_t packet_length() const { return packet_.size(); } in packet_length()
48 return rtc::MakeArrayView(packet_.data(), header_length()); in RawHeader()
50 uint32_t Ssrc() const { return packet_.Ssrc(); } in Ssrc()
51 uint32_t Timestamp() const { return packet_.Timestamp(); } in Timestamp()
52 uint16_t SequenceNumber() const { return packet_.SequenceNumber(); } in SequenceNumber()
53 uint8_t PayloadType() const { return packet_.PayloadType(); } in PayloadType()
54 bool Marker() const { return packet_.Marker(); } in Marker()
57 return packet_.GetExtension<ExtensionTrait>(std::forward<Args>(args)...); in GetExtension()
61 return packet_.HasExtension<ExtensionTrait>(); in HasExtension()
64 size_t payload_length() const { return packet_.payload_size(); } in payload_length()
[all …]
Drtc_event_rtcp_packet_outgoing.cc19 : packet_(packet.data(), packet.size()) {} in RtcEventRtcpPacketOutgoing()
24 packet_(other.packet_.data(), other.packet_.size()) {} in RtcEventRtcpPacketOutgoing()
Drtc_event_rtcp_packet_incoming.cc19 : packet_(packet.data(), packet.size()) {} in RtcEventRtcpPacketIncoming()
24 packet_(other.packet_.data(), other.packet_.size()) {} in RtcEventRtcpPacketIncoming()
Drtc_event_rtp_packet_incoming.cc21 : packet_(packet) {} in RtcEventRtpPacketIncoming()
25 : RtcEvent(other.timestamp_us_), packet_(other.packet_) {} in RtcEventRtpPacketIncoming()
Drtc_event_rtp_packet_outgoing.cc22 : packet_(packet), probe_cluster_id_(probe_cluster_id) {} in RtcEventRtpPacketOutgoing()
27 packet_(other.packet_), in RtcEventRtpPacketOutgoing()
/external/webrtc/test/fuzzers/
Dneteq_rtp_fuzzer.cc67 packet_ = input_->PopPacket(); in FuzzRtpInput()
73 return packet_->time_ms; in NextPacketTime()
81 RTC_DCHECK(packet_); in PopPacket()
82 std::unique_ptr<PacketData> packet_to_return = std::move(packet_); in PopPacket()
83 packet_ = input_->PopPacket(); in PopPacket()
94 RTC_DCHECK(packet_); in NextHeader()
95 return packet_->header; in NextHeader()
105 RTC_DCHECK(packet_); in FuzzHeader()
107 packet_->header.payloadType = in FuzzHeader()
109 packet_->header.payloadType &= 0x7F; in FuzzHeader()
[all …]
Dneteq_signal_fuzzer.cc83 packet_ = input_->PopPacket(); in FuzzSignalInput()
93 return packet_->time_ms; in NextPacketTime()
101 RTC_DCHECK(packet_); in PopPacket()
102 std::unique_ptr<PacketData> packet_to_return = std::move(packet_); in PopPacket()
104 packet_ = input_->PopPacket(); in PopPacket()
112 packet_->time_ms = std::max(packet_to_return->time_ms, in PopPacket()
113 packet_->time_ms + arrival_time_offset_ms); in PopPacket()
129 RTC_DCHECK(packet_); in NextHeader()
130 return packet_->header; in NextHeader()
137 std::unique_ptr<PacketData> packet_; member in webrtc::test::__anon4a342dd60111::FuzzSignalInput
/external/cronet/net/quic/
Dquic_chromium_packet_writer.cc89 packet_(base::MakeRefCounted<ReusableIOBuffer>( in QuicChromiumPacketWriter()
106 if (UNLIKELY(!packet_)) { in SetPacket()
107 packet_ = base::MakeRefCounted<ReusableIOBuffer>( in SetPacket()
111 if (UNLIKELY(packet_->capacity() < buf_len)) { in SetPacket()
112 packet_ = base::MakeRefCounted<ReusableIOBuffer>(buf_len); in SetPacket()
115 if (UNLIKELY(!packet_->HasOneRef())) { in SetPacket()
116 packet_ = base::MakeRefCounted<ReusableIOBuffer>( in SetPacket()
120 packet_->Set(buffer, buf_len); in SetPacket()
137 packet_ = std::move(packet); in WritePacketToSocket()
146 int rv = socket_->Write(packet_.get(), packet_->size(), write_callback_, in WritePacketToSocketImpl()
[all …]
/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/
Dquic_packet_creator_peer.cc29 creator->packet_.encryption_level = ENCRYPTION_FORWARD_SECURE; in SetSendVersionInPacket()
32 QUICHE_DCHECK(creator->packet_.encryption_level < ENCRYPTION_FORWARD_SECURE); in SetSendVersionInPacket()
38 creator->packet_.packet_number_length = packet_number_length; in SetPacketNumberLength()
62 creator->packet_.packet_number = QuicPacketNumber(s); in SetPacketNumber()
67 creator->packet_.packet_number = num; in SetPacketNumber()
72 creator->packet_.packet_number.Clear(); in ClearPacketNumber()
113 SerializedPacket packet = std::move(creator->packet_); in SerializeAllFrames()
115 creator->packet_.encrypted_buffer = nullptr; in SerializeAllFrames()
136 return creator->packet_.encryption_level; in GetEncryptionLevel()
/external/pigweed/pw_router/
Dstatic_router_test.cc43 constexpr BasicPacketParser() : packet_(nullptr) {} in BasicPacketParser()
46 packet_ = reinterpret_cast<const BasicPacket*>(packet.data()); in Parse()
47 return packet_->magic == BasicPacket::kMagic; in Parse()
51 PW_DCHECK_NOTNULL(packet_); in GetDestinationAddress()
52 return packet_->address; in GetDestinationAddress()
56 PW_DCHECK_NOTNULL(packet_); in priority()
57 return packet_->priority; in priority()
61 const BasicPacket* packet_; member in pw::router::__anonfecbb8fb0111::BasicPacketParser
/external/cronet/base/trace_event/
Dtyped_macros_embedder_support.h97 explicit operator bool() const { return static_cast<bool>(packet_); }
98 TracePacket& operator*() const { return *packet_; }
99 TracePacket* operator->() const { return packet_.get(); }
100 TracePacket* get() const { return packet_.get(); } in get()
102 PerfettoPacketHandle TakePerfettoHandle() { return std::move(packet_); } in TakePerfettoHandle()
105 PerfettoPacketHandle packet_;
/external/webrtc/modules/rtp_rtcp/source/
Drtp_packet_history.cc30 : packet_(std::move(packet)), in StoredPacket()
125 packet_history_[packet_index].packet_ != nullptr) { in PutRtpPacket()
143 RTC_DCHECK(packet_history_[packet_index].packet_ == nullptr); in PutRtpPacket()
191 encapsulate(*packet->packet_); in GetPacketAndMarkAsPending()
230 if (packet.packet_ == nullptr) { in GetPacketState()
277 if (it->packet_ != nullptr) { in GetPayloadPaddingPacket()
296 auto padding_packet = encapsulate(*best_packet->packet_); in GetPayloadPaddingPacket()
374 std::move(packet_history_[packet_index].packet_); in RemovePacket()
383 packet_history_.front().packet_ == nullptr) { in RemovePacket()
396 RTC_DCHECK(packet_history_.front().packet_ != nullptr); in GetPacketIndex()
[all …]
/external/pigweed/pw_router/size_report/
Dstatic_router_with_one_route.cc42 constexpr BasicPacketParser() : packet_(nullptr) {} in BasicPacketParser()
45 packet_ = reinterpret_cast<const BasicPacket*>(packet.data()); in Parse()
46 return packet_->magic == BasicPacket::kMagic; in Parse()
50 return packet_->address; in GetDestinationAddress()
54 const BasicPacket* packet_; member in __anon052b1b2b0211::BasicPacketParser
/external/openscreen/cast/standalone_receiver/
Ddecoder.cc70 parser_.get(), context_.get(), &packet_->data, &packet_->size, in Decode()
76 if (!packet_->data) { in Decode()
84 avcodec_send_packet(context_.get(), packet_.get()); in Decode()
156 packet_ = MakeUniqueAVPacket(); in Initialize()
157 if (!packet_) { in Initialize()
/external/webrtc/modules/audio_coding/neteq/test/
Dneteq_decoding_test.cc103 while (packet_ && clock_.TimeInMilliseconds() >= packet_->time_ms()) { in Process()
104 if (packet_->payload_length_bytes() > 0) { in Process()
107 if (packet_->header().payloadType != 104) in Process()
111 packet_->header(), in Process()
113 packet_->payload(), packet_->payload_length_bytes()))); in Process()
116 packet_ = rtp_source_->NextPacket(); in Process()
149 packet_ = rtp_source_->NextPacket(); in DecodeAndCompare()
153 while (packet_) { in DecodeAndCompare()
/external/cronet/net/dns/
Ddns_response.cc123 : packet_(reinterpret_cast<const char*>(packet)), in DnsRecordParser()
126 cur_(packet_ + offset) { in DnsRecordParser()
135 DCHECK(packet_); in ReadName()
136 DCHECK_LE(packet_, pos); in ReadName()
137 DCHECK_LE(pos, packet_ + length_); in ReadName()
140 const char* end = packet_ + length_; in ReadName()
183 p = packet_ + offset; in ReadName()
230 DCHECK(packet_); in ReadRecord()
241 packet_ + length_ - (cur_ + consumed)); in ReadRecord()
262 if (next > packet_ + length_) in ReadQuestion()

12