| /external/webrtc/webrtc/modules/video_coding/ |
| D | session_info.cc | 31 packets_(), in VCMSessionInfo()
39 for (PacketIterator it = packets_.begin(); it != packets_.end(); ++it) in UpdateDataPointers()
47 if (packets_.empty()) in LowSequenceNumber()
49 return packets_.front().seqNum; in LowSequenceNumber()
53 if (packets_.empty()) in HighSequenceNumber()
56 return packets_.back().seqNum; in HighSequenceNumber()
57 return LatestSequenceNumber(packets_.back().seqNum, empty_seq_num_high_); in HighSequenceNumber()
61 if (packets_.empty()) in PictureId()
63 if (packets_.front().codecSpecificHeader.codec == kRtpVideoVp8) { in PictureId()
64 return packets_.front().codecSpecificHeader.codecHeader.VP8.pictureId; in PictureId()
[all …]
|
| D | session_info.h | 155 PacketList packets_; variable
|
| /external/webrtc/webrtc/modules/video_coding/test/ |
| D | stream_generator.cc | 25 : packets_(), sequence_number_(start_seq_num), start_time_(current_time) {} in StreamGenerator()
28 packets_.clear(); in Init()
43 packets_.push_back(GeneratePacket(sequence_number_, timestamp, packet_size, in GenerateFrame()
48 packets_.push_back(GeneratePacket(sequence_number_, timestamp, 0, false, in GenerateFrame()
80 if (it == packets_.end()) in PopPacket()
84 packets_.erase(it); in PopPacket()
90 if (it == packets_.end()) in GetPacket()
98 if (packets_.empty()) in NextPacket()
101 *packet = packets_.front(); in NextPacket()
102 packets_.pop_front(); in NextPacket()
[all …]
|
| D | rtp_player.cc | 80 packets_(), in LostPackets()
91 while (!packets_.empty()) { in ~LostPackets()
92 delete packets_.back(); in ~LostPackets()
93 packets_.pop_back(); in ~LostPackets()
105 packets_.push_back(packet); in AddPacket()
113 for (RtpPacketIterator it = packets_.begin(); it != packets_.end(); ++it) { in SetResendTime()
130 for (RtpPacketIterator it = packets_.begin(); it != packets_.end(); ++it) { in NextPacketToResend()
134 packets_.erase(it); in NextPacketToResend()
144 for (ConstRtpPacketIterator it = packets_.begin(); it != packets_.end(); in NumberOfPacketsToResend()
166 printf("Packets still lost: %zd\n", packets_.size()); in Print()
[all …]
|
| D | stream_generator.h | 62 std::list<VCMPacket> packets_; variable
|
| /external/webrtc/webrtc/base/ |
| D | testclient.cc | 23 packets_ = new std::vector<Packet*>(); in TestClient()
30 for (unsigned i = 0; i < packets_->size(); i++) in ~TestClient()
31 delete (*packets_)[i]; in ~TestClient()
32 delete packets_; in ~TestClient()
70 if (packets_->size() != 0) { in NextPacket()
80 if (packets_->size() > 0) { in NextPacket()
81 packet = packets_->front(); in NextPacket()
82 packets_->erase(packets_->begin()); in NextPacket()
125 packets_->push_back(new Packet(remote_addr, buf, size)); in OnPacket()
|
| D | testclient.h | 90 std::vector<Packet*>* packets_; variable
|
| /external/webrtc/webrtc/modules/pacing/ |
| D | paced_sender.cc | 262 packets_(new paced_sender::PacketQueue(clock)), in PacedSender()
312 packets_->Push(paced_sender::Packet(priority, ssrc, sequence_number, in InsertPacket()
320 return static_cast<int64_t>(packets_->SizeInBytes() * 8 / max_bitrate_kbps_); in ExpectedQueueTimeMs()
325 return packets_->SizeInPackets(); in QueueSizePackets()
331 int64_t oldest_packet = packets_->OldestEnqueueTimeMs(); in QueueInMs()
340 packets_->UpdateQueueTime(clock_->TimeInMilliseconds()); in AverageQueueTimeMs()
341 return packets_->AverageQueueTimeMs(); in AverageQueueTimeMs()
364 size_t queue_size_bytes = packets_->SizeInBytes(); in Process()
369 packets_->UpdateQueueTime(clock_->TimeInMilliseconds()); in Process()
371 1, kMaxQueueLengthMs - packets_->AverageQueueTimeMs()); in Process()
[all …]
|
| D | paced_sender.h | 160 rtc::scoped_ptr<paced_sender::PacketQueue> packets_ GUARDED_BY(critsect_);
|
| /external/webrtc/webrtc/modules/rtp_rtcp/source/ |
| D | rtp_format_h264.cc | 166 assert(packets_.empty()); in SetPayloadData()
202 packets_.push(Packet(offset, in PacketizeFuA()
224 packets_.push(Packet(fragment_offset, in PacketizeStapA()
248 packets_.back().last_fragment = true; in PacketizeStapA()
256 if (packets_.empty()) { in NextPacket()
262 Packet packet = packets_.front(); in NextPacket()
268 packets_.pop(); in NextPacket()
277 *last_packet = packets_.empty(); in NextPacket()
283 Packet packet = packets_.front(); in NextAggregatePacket()
298 packets_.pop(); in NextAggregatePacket()
[all …]
|
| D | rtp_format_vp9.cc | 537 while (!packets_.empty()) in GeneratePackets()
538 packets_.pop(); in GeneratePackets()
542 rem_bytes == packet_bytes, &packets_); in GeneratePackets()
551 if (packets_.empty()) { in NextPacket()
554 PacketInfo packet_info = packets_.front(); in NextPacket()
555 packets_.pop(); in NextPacket()
561 packets_.empty() && (hdr_.spatial_idx == kNoSpatialIdx || in NextPacket()
|
| D | rtp_format_vp8.cc | 214 if (packets_.empty()) { in NextPacket()
217 InfoStruct packet_info = packets_.front(); in NextPacket()
218 packets_.pop(); in NextPacket()
226 *last_packet = packets_.empty(); in NextPacket()
458 packets_.push(packet_info); in QueuePacket()
|
| D | rtp_format_vp9.h | 92 PacketInfoQueue packets_; variable
|
| D | rtp_format_h264.h | 86 PacketQueue packets_; variable
|
| D | rtp_format_vp8.h | 212 InfoQueue packets_; variable
|
| /external/webrtc/talk/app/webrtc/ |
| D | datachannel.cc | 90 return packets_.empty(); in Empty()
94 return packets_.front(); in Front()
98 if (packets_.empty()) { in Pop()
102 byte_count_ -= packets_.front()->size(); in Pop()
103 packets_.pop_front(); in Pop()
108 packets_.push_back(packet); in Push()
112 while (!packets_.empty()) { in Clear()
113 delete packets_.front(); in Clear()
114 packets_.pop_front(); in Clear()
124 other->packets_.swap(packets_); in Swap()
|
| D | datachannel.h | 230 std::deque<DataBuffer*> packets_;
|
| /external/webrtc/webrtc/test/ |
| D | rtp_file_reader.cc | 260 packets_(), in PcapReader()
297 } else if (result == kResultSuccess && packets_.size() == 1) { in Initialize()
299 PacketIterator it = packets_.begin(); in Initialize()
311 printf("Total RTP/RTCP packets: %" PRIuS "\n", packets_.size()); in Initialize()
317 uint8_t pt = packets_[packet_indices[0]].rtp_header.payloadType; in Initialize()
338 next_packet_it_ = packets_.begin(); in Initialize()
356 if (next_packet_it_ == packets_.end()) { in NextPcap()
459 packets_.push_back(marker); in ReadPacket()
469 static_cast<uint32_t>(packets_.size())); in ReadPacket()
470 packets_.push_back(marker); in ReadPacket()
[all …]
|
| /external/webrtc/webrtc/p2p/base/ |
| D | dtlstransportchannel.cc | 47 packets_(kMaxPendingPackets, kMaxDtlsPacketLen) { in StreamInterfaceChannel()
59 if (!packets_.ReadFront(buffer, buffer_len, read)) { in Read()
83 bool ret = packets_.WriteBack(data, size, NULL); in OnPacketReceived()
|
| D | dtlstransportchannel.h | 50 rtc::BufferQueue packets_; variable
|
| /external/webrtc/webrtc/modules/remote_bitrate_estimator/test/ |
| D | bwe_test.h | 143 Packets packets_; variable
|
| D | bwe_test.cc | 110 for (Packet* packet : packets_) in ~BweTest()
181 link->Run(simulation_interval_ms_, time_now_ms_, &packets_); in RunFor()
|