This source file includes following definitions.
- TEST_F
- TEST_F
- TEST_F
#include "media/cast/transport/rtp_sender/packet_storage/packet_storage.h"
#include <stdint.h>
#include <vector>
#include "base/test/simple_test_tick_clock.h"
#include "base/time/time.h"
#include "testing/gmock/include/gmock/gmock.h"
namespace media {
namespace cast {
namespace transport {
static const int kMaxDeltaStoredMs = 500;
static const base::TimeDelta kDeltaBetweenFrames =
base::TimeDelta::FromMilliseconds(33);
static const int64 kStartMillisecond = INT64_C(12345678900000);
class PacketStorageTest : public ::testing::Test {
protected:
PacketStorageTest() : packet_storage_(&testing_clock_, kMaxDeltaStoredMs) {
testing_clock_.Advance(
base::TimeDelta::FromMilliseconds(kStartMillisecond));
}
base::SimpleTestTickClock testing_clock_;
PacketStorage packet_storage_;
DISALLOW_COPY_AND_ASSIGN(PacketStorageTest);
};
TEST_F(PacketStorageTest, TimeOut) {
Packet test_123(100, 123);
PacketList packets;
for (uint32 frame_id = 0; frame_id < 30; ++frame_id) {
for (uint16 packet_id = 0; packet_id < 10; ++packet_id) {
packet_storage_.StorePacket(frame_id, packet_id, &test_123);
}
testing_clock_.Advance(kDeltaBetweenFrames);
}
for (uint32 frame_id = 0; frame_id < 14; ++frame_id) {
for (uint16 packet_id = 0; packet_id < 10; ++packet_id) {
Packet packet;
EXPECT_FALSE(packet_storage_.GetPacket(frame_id, packet_id, &packets));
}
}
for (uint32 frame_id = 14; frame_id < 30; ++frame_id) {
for (uint16 packet_id = 0; packet_id < 10; ++packet_id) {
EXPECT_TRUE(packet_storage_.GetPacket(frame_id, packet_id, &packets));
EXPECT_TRUE(packets.front() == test_123);
}
}
}
TEST_F(PacketStorageTest, MaxNumberOfPackets) {
Packet test_123(100, 123);
PacketList packets;
uint32 frame_id = 0;
for (uint16 packet_id = 0; packet_id <= PacketStorage::kMaxStoredPackets;
++packet_id) {
packet_storage_.StorePacket(frame_id, packet_id, &test_123);
}
Packet packet;
uint16 packet_id = 0;
EXPECT_FALSE(packet_storage_.GetPacket(frame_id, packet_id, &packets));
++packet_id;
for (; packet_id <= PacketStorage::kMaxStoredPackets; ++packet_id) {
EXPECT_TRUE(packet_storage_.GetPacket(frame_id, packet_id, &packets));
EXPECT_TRUE(packets.back() == test_123);
}
}
TEST_F(PacketStorageTest, PacketContent) {
Packet test_123(100, 123);
Packet test_234(200, 234);
PacketList packets;
for (uint32 frame_id = 0; frame_id < 10; ++frame_id) {
for (uint16 packet_id = 0; packet_id < 10; ++packet_id) {
if (packet_id % 2 == 0) {
packet_storage_.StorePacket(frame_id, packet_id, &test_123);
} else {
packet_storage_.StorePacket(frame_id, packet_id, &test_234);
}
}
testing_clock_.Advance(kDeltaBetweenFrames);
}
for (uint32 frame_id = 0; frame_id < 10; ++frame_id) {
for (uint16 packet_id = 0; packet_id < 10; ++packet_id) {
EXPECT_TRUE(packet_storage_.GetPacket(frame_id, packet_id, &packets));
if (packet_id % 2 == 0) {
EXPECT_TRUE(packets.back() == test_123);
} else {
EXPECT_TRUE(packets.back() == test_234);
}
}
}
}
}
}
}