| /external/webrtc/modules/video_coding/ |
| D | session_info.cc | 40 packets_(), in VCMSessionInfo()
50 for (PacketIterator it = packets_.begin(); it != packets_.end(); ++it) in UpdateDataPointers()
58 if (packets_.empty()) in LowSequenceNumber()
60 return packets_.front().seqNum; in LowSequenceNumber()
64 if (packets_.empty()) in HighSequenceNumber()
67 return packets_.back().seqNum; in HighSequenceNumber()
68 return LatestSequenceNumber(packets_.back().seqNum, empty_seq_num_high_); in HighSequenceNumber()
72 if (packets_.empty()) in PictureId()
74 if (packets_.front().video_header.codec == kVideoCodecVP8) { in PictureId()
76 packets_.front().video_header.video_type_header) in PictureId()
[all …]
|
| D | session_info.h | 108 PacketList packets_; variable
|
| /external/webrtc/modules/video_coding/test/ |
| D | stream_generator.cc | 23 : packets_(), sequence_number_(start_seq_num), start_time_(current_time) {} in StreamGenerator()
26 packets_.clear(); in Init()
41 packets_.push_back(GeneratePacket(sequence_number_, timestamp, packet_size, in GenerateFrame()
46 packets_.push_back(GeneratePacket(sequence_number_, timestamp, 0, false, in GenerateFrame()
78 if (it == packets_.end()) in PopPacket()
82 packets_.erase(it); in PopPacket()
88 if (it == packets_.end()) in GetPacket()
96 if (packets_.empty()) in NextPacket()
99 *packet = packets_.front(); in NextPacket()
100 packets_.pop_front(); in NextPacket()
[all …]
|
| D | stream_generator.h | 63 std::list<VCMPacket> packets_; variable
|
| /external/webrtc/pc/ |
| D | data_channel_utils.cc | 16 return packets_.empty(); in Empty()
20 RTC_DCHECK(!packets_.empty()); in PopFront()
21 byte_count_ -= packets_.front()->size(); in PopFront()
22 std::unique_ptr<DataBuffer> packet = std::move(packets_.front()); in PopFront()
23 packets_.pop_front(); in PopFront()
29 packets_.push_front(std::move(packet)); in PushFront()
34 packets_.push_back(std::move(packet)); in PushBack()
38 packets_.clear(); in Clear()
47 other->packets_.swap(packets_); in Swap()
|
| D | data_channel_utils.h | 42 std::deque<std::unique_ptr<DataBuffer>> packets_;
|
| /external/webrtc/modules/rtp_rtcp/source/ |
| D | rtp_format_h264.cc | 67 while (!packets_.empty()) { in RtpPacketizerH264()
68 packets_.pop(); in RtpPacketizerH264()
147 packets_.push(PacketUnit(fragment.subview(offset, packet_length), in PacketizeFuA()
188 packets_.push(PacketUnit(fragment, aggregated_fragments == 0, false, true, in PacketizeStapA()
208 packets_.back().last_fragment = true; in PacketizeStapA()
231 packets_.push(PacketUnit(fragment, true /* first */, true /* last */, in PacketizeSingleNalu()
239 if (packets_.empty()) { in NextPacket()
243 PacketUnit packet = packets_.front(); in NextPacket()
249 packets_.pop(); in NextPacket()
256 rtp_packet->SetMarker(packets_.empty()); in NextPacket()
[all …]
|
| D | rtp_packetizer_av1.h | 32 size_t NumPackets() const override { return packets_.size() - packet_index_; } in NumPackets()
65 const std::vector<Packet> packets_; variable
|
| D | rtp_packetizer_av1.cc | 94 packets_(Packetize(obus_, limits)) {} in RtpPacketizerAv1()
318 const Packet& packet = packets_[packet_index_]; in AggregationHeader()
351 if (packet_index_ >= packets_.size()) { in NextPacket()
354 const Packet& next_packet = packets_[packet_index_]; in NextPacket()
417 if (packet_index_ == packets_.size()) { in NextPacket()
|
| D | rtp_format_h264.h | 84 std::queue<PacketUnit> packets_; variable
|
| D | rtp_sender_unittest.cc | 229 packets_ = std::move(packets)]() mutable { in EnqueuePackets()
230 sender->EnqueuePackets(std::move(packets_)); in EnqueuePackets()
|
| /external/webrtc/video/ |
| D | send_delay_stats.cc | 81 RemoveOld(now, &packets_); in OnSendPacket()
83 if (packets_.size() > kMaxPacketMapSize) { in OnSendPacket()
87 packets_.insert( in OnSendPacket()
97 auto it = packets_.find(packet_id); in OnSentPacket()
98 if (it == packets_.end()) in OnSentPacket()
105 packets_.erase(it); in OnSentPacket()
|
| D | send_delay_stats.h | 76 PacketMap packets_ RTC_GUARDED_BY(mutex_);
|
| /external/webrtc/rtc_base/ |
| D | test_client.cc | 79 if (packets_.size() != 0) { in NextPacket()
89 if (packets_.size() > 0) { in NextPacket()
90 packet = std::move(packets_.front()); in NextPacket()
91 packets_.erase(packets_.begin()); in NextPacket()
153 packets_.push_back( in OnPacket()
|
| D | test_client.h | 110 std::vector<std::unique_ptr<Packet>> packets_; variable
|
| /external/webrtc/test/ |
| D | rtp_file_reader.cc | 246 packets_(), in PcapReader()
277 } else if (result == kResultSuccess && packets_.size() == 1) { in Initialize()
279 PacketIterator it = packets_.begin(); in Initialize()
291 printf("Total RTP/RTCP packets: %" RTC_PRIuS "\n", packets_.size()); in Initialize()
297 uint8_t pt = packets_[packet_indices[0]].rtp_header.payloadType; in Initialize()
318 next_packet_it_ = packets_.begin(); in Initialize()
336 if (next_packet_it_ == packets_.end()) { in NextPcap()
439 packets_.push_back(marker); in ReadPacket()
449 static_cast<uint32_t>(packets_.size())); in ReadPacket()
450 packets_.push_back(marker); in ReadPacket()
[all …]
|
| /external/webrtc/modules/congestion_controller/goog_cc/ |
| D | trendline_estimator_unittest.cc | 29 packets_(0) {} in PacketTimeGenerator()
31 return initial_clock_ + time_between_packets_ * packets_++; in operator ()()
37 size_t packets_; member in webrtc::__anonddc486300111::PacketTimeGenerator
|
| /external/webrtc/test/network/ |
| D | network_emulation.cc | 31 packets_.emplace_back(StoredPacket{packet_id, std::move(packet), false}); in OnPacketReceived()
65 for (auto& stored_packet : packets_) { in Process()
80 while (!packets_.empty() && packets_.front().removed) { in Process()
81 packets_.pop_front(); in Process()
|
| D | network_emulation.h | 64 std::deque<StoredPacket> packets_ RTC_GUARDED_BY(task_queue_);
|
| /external/webrtc/p2p/base/ |
| D | dtls_transport.cc | 70 packets_(kMaxPendingPackets, kMaxDtlsPacketLen) {} in StreamInterfaceChannel()
81 if (!packets_.ReadFront(buffer, buffer_len, read)) { in Read()
105 if (packets_.size() > 0) { in OnPacketReceived()
108 bool ret = packets_.WriteBack(data, size, NULL); in OnPacketReceived()
125 packets_.Clear(); in Close()
|
| D | dtls_transport.h | 59 rtc::BufferQueue packets_; variable
|
| /external/webrtc/modules/pacing/ |
| D | task_queue_paced_sender.cc | 136 task_queue_.PostTask([this, packets_ = std::move(packets)]() mutable { in EnqueuePackets()
138 for (auto& packet : packets_) { in EnqueuePackets()
|