Home
last modified time | relevance | path

Searched refs:PacketBuffer (Results 1 – 17 of 17) sorted by relevance

/external/webrtc/modules/audio_coding/neteq/
Dpacket_buffer_unittest.cc108 TEST(PacketBuffer, CreateAndDestroy) { in TEST() argument
110 PacketBuffer* buffer = new PacketBuffer(10, &tick_timer); // 10 packets. in TEST()
115 TEST(PacketBuffer, InsertPacket) { in TEST() argument
117 PacketBuffer buffer(10, &tick_timer); // 10 packets. in TEST()
125 EXPECT_EQ(PacketBuffer::kOK, buffer.NextTimestamp(&next_ts)); in TEST()
137 TEST(PacketBuffer, FlushBuffer) { in TEST() argument
139 PacketBuffer buffer(10, &tick_timer); // 10 packets. in TEST()
147 PacketBuffer::kOK, in TEST()
160 TEST(PacketBuffer, OverfillBuffer) { in TEST() argument
162 PacketBuffer buffer(10, &tick_timer); // 10 packets. in TEST()
[all …]
Dpacket_buffer.cc66 PacketBuffer::PacketBuffer(size_t max_number_of_packets, in PacketBuffer() function in webrtc::PacketBuffer
71 PacketBuffer::~PacketBuffer() { in ~PacketBuffer()
76 void PacketBuffer::Flush() { in Flush()
80 bool PacketBuffer::Empty() const { in Empty()
84 int PacketBuffer::InsertPacket(Packet&& packet, StatisticsCalculator* stats) { in InsertPacket()
132 int PacketBuffer::InsertPacketList( in InsertPacketList()
178 int PacketBuffer::NextTimestamp(uint32_t* next_timestamp) const { in NextTimestamp()
189 int PacketBuffer::NextHigherTimestamp(uint32_t timestamp, in NextHigherTimestamp()
208 const Packet* PacketBuffer::PeekNextPacket() const { in PeekNextPacket()
212 absl::optional<Packet> PacketBuffer::GetNextPacket() { in GetNextPacket()
[all …]
Dpacket_buffer.h27 class PacketBuffer {
40 PacketBuffer(size_t max_number_of_packets, const TickTimer* tick_timer);
43 virtual ~PacketBuffer();
152 RTC_DISALLOW_COPY_AND_ASSIGN(PacketBuffer);
Ddecision_logic_unittest.cc34 PacketBuffer packet_buffer(10, &tick_timer); in TEST()
Dneteq_impl.h50 class PacketBuffer; variable
111 std::unique_ptr<PacketBuffer> packet_buffer;
342 const std::unique_ptr<PacketBuffer> packet_buffer_ RTC_GUARDED_BY(mutex_);
Ddecision_logic.cc175 } else if (!PacketBuffer::IsObsoleteTimestamp(status.next_packet->timestamp, in GetDecision()
Dneteq_impl.cc110 new PacketBuffer(config.max_packets_in_buffer, tick_timer.get())), in Dependencies()
733 if (ret == PacketBuffer::kFlushed) { in InsertPacketInternal()
737 } else if (ret != PacketBuffer::kOK) { in InsertPacketInternal()
1092 PacketBuffer::kOK) { in GetDecision()
Dneteq_impl_unittest.cc68 return PacketBuffer::kOK; in DeletePacketsAndReturnOk()
244 PacketBuffer* packet_buffer_ = nullptr;
/external/webrtc/modules/video_coding/
Dpacket_buffer.cc39 PacketBuffer::Packet::Packet(const RtpPacketReceived& rtp_packet, in Packet()
57 PacketBuffer::PacketBuffer(Clock* clock, in PacketBuffer() function in webrtc::video_coding::PacketBuffer
74 PacketBuffer::~PacketBuffer() { in ~PacketBuffer()
78 PacketBuffer::InsertResult PacketBuffer::InsertPacket( in InsertPacket()
79 std::unique_ptr<PacketBuffer::Packet> packet) { in InsertPacket()
80 PacketBuffer::InsertResult result; in InsertPacket()
138 void PacketBuffer::ClearTo(uint16_t seq_num) { in ClearTo()
175 void PacketBuffer::Clear() { in Clear()
180 PacketBuffer::InsertResult PacketBuffer::InsertPadding(uint16_t seq_num) { in InsertPadding()
181 PacketBuffer::InsertResult result; in InsertPadding()
[all …]
Dpacket_buffer.h33 class PacketBuffer {
82 PacketBuffer(Clock* clock, size_t start_buffer_size, size_t max_buffer_size);
83 ~PacketBuffer();
Dpacket_buffer_unittest.cc41 void IgnoreResult(PacketBuffer::InsertResult /*result*/) {} in IgnoreResult()
46 rtc::ArrayView<const std::unique_ptr<PacketBuffer::Packet>> packets) { in StartSeqNums()
78 struct PacketBufferInsertResult : public PacketBuffer::InsertResult {
79 explicit PacketBufferInsertResult(PacketBuffer::InsertResult result) in PacketBufferInsertResult()
121 auto packet = std::make_unique<PacketBuffer::Packet>();
139 PacketBuffer packet_buffer_;
408 auto packet = std::make_unique<PacketBuffer::Packet>();
444 auto packet = std::make_unique<PacketBuffer::Packet>();
518 auto packet = std::make_unique<PacketBuffer::Packet>(); in TEST_P()
682 auto packet = std::make_unique<PacketBuffer::Packet>(); in TEST_F()
[all …]
/external/webrtc/test/fuzzers/
Dpacket_buffer_fuzzer.cc21 void IgnoreResult(video_coding::PacketBuffer::InsertResult result) {} in IgnoreResult()
28 video_coding::PacketBuffer packet_buffer(&clock, 8, 1024); in FuzzOneInput()
32 auto packet = std::make_unique<video_coding::PacketBuffer::Packet>(); in FuzzOneInput()
/external/webrtc/modules/audio_coding/neteq/mock/
Dmock_packet_buffer.h19 class MockPacketBuffer : public PacketBuffer {
22 : PacketBuffer(max_number_of_packets, tick_timer) {} in MockPacketBuffer()
/external/webrtc/video/
Drtp_video_stream_receiver2.h267 void OnInsertedPacket(video_coding::PacketBuffer::InsertResult result);
302 video_coding::PacketBuffer packet_buffer_;
Drtp_video_stream_receiver.h304 void OnInsertedPacket(video_coding::PacketBuffer::InsertResult result);
339 video_coding::PacketBuffer packet_buffer_;
Drtp_video_stream_receiver2.cc469 auto packet = std::make_unique<video_coding::PacketBuffer::Packet>( in OnReceivedPayloadData()
718 video_coding::PacketBuffer::InsertResult result) { in OnInsertedPacket()
720 video_coding::PacketBuffer::Packet* first_packet = nullptr; in OnInsertedPacket()
761 const video_coding::PacketBuffer::Packet& last_packet = *packet; in OnInsertedPacket()
Drtp_video_stream_receiver.cc501 auto packet = std::make_unique<video_coding::PacketBuffer::Packet>( in OnReceivedPayloadData()
748 video_coding::PacketBuffer::InsertResult result) { in OnInsertedPacket()
749 video_coding::PacketBuffer::Packet* first_packet = nullptr; in OnInsertedPacket()
790 const video_coding::PacketBuffer::Packet& last_packet = *packet; in OnInsertedPacket()