| // Copyright 2014 The Chromium Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #include "base/memory/ref_counted.h" |
| #include "base/memory/scoped_ptr.h" |
| #include "base/test/simple_test_tick_clock.h" |
| #include "base/time/tick_clock.h" |
| #include "media/cast/cast_environment.h" |
| #include "media/cast/logging/logging_defines.h" |
| #include "media/cast/net/rtcp/receiver_rtcp_event_subscriber.h" |
| #include "media/cast/test/fake_single_thread_task_runner.h" |
| #include "testing/gtest/include/gtest/gtest.h" |
| |
| namespace media { |
| namespace cast { |
| |
| namespace { |
| |
| const size_t kMaxEventEntries = 10u; |
| const int64 kDelayMs = 20L; |
| |
| } // namespace |
| |
| class ReceiverRtcpEventSubscriberTest : public ::testing::Test { |
| protected: |
| ReceiverRtcpEventSubscriberTest() |
| : testing_clock_(new base::SimpleTestTickClock()), |
| task_runner_(new test::FakeSingleThreadTaskRunner(testing_clock_)), |
| cast_environment_(new CastEnvironment( |
| scoped_ptr<base::TickClock>(testing_clock_).Pass(), |
| task_runner_, |
| task_runner_, |
| task_runner_)) {} |
| |
| virtual ~ReceiverRtcpEventSubscriberTest() {} |
| |
| virtual void TearDown() override { |
| if (event_subscriber_) { |
| cast_environment_->Logging()->RemoveRawEventSubscriber( |
| event_subscriber_.get()); |
| } |
| } |
| |
| void Init(EventMediaType type) { |
| event_subscriber_.reset( |
| new ReceiverRtcpEventSubscriber(kMaxEventEntries, type)); |
| cast_environment_->Logging()->AddRawEventSubscriber( |
| event_subscriber_.get()); |
| } |
| |
| void InsertEvents() { |
| // Video events |
| cast_environment_->Logging()->InsertFrameEventWithDelay( |
| testing_clock_->NowTicks(), FRAME_PLAYOUT, VIDEO_EVENT, |
| /*rtp_timestamp*/ 100u, /*frame_id*/ 2u, |
| base::TimeDelta::FromMilliseconds(kDelayMs)); |
| cast_environment_->Logging()->InsertFrameEvent( |
| testing_clock_->NowTicks(), FRAME_DECODED, VIDEO_EVENT, |
| /*rtp_timestamp*/ 200u, /*frame_id*/ 1u); |
| cast_environment_->Logging()->InsertPacketEvent( |
| testing_clock_->NowTicks(), PACKET_RECEIVED, VIDEO_EVENT, |
| /*rtp_timestamp */ 200u, /*frame_id*/ 2u, /*packet_id*/ 1u, |
| /*max_packet_id*/ 10u, /*size*/ 1024u); |
| |
| // Audio events |
| cast_environment_->Logging()->InsertFrameEventWithDelay( |
| testing_clock_->NowTicks(), FRAME_PLAYOUT, AUDIO_EVENT, |
| /*rtp_timestamp*/ 300u, /*frame_id*/ 4u, |
| base::TimeDelta::FromMilliseconds(kDelayMs)); |
| cast_environment_->Logging()->InsertFrameEvent( |
| testing_clock_->NowTicks(), FRAME_DECODED, AUDIO_EVENT, |
| /*rtp_timestamp*/ 400u, /*frame_id*/ 3u); |
| cast_environment_->Logging()->InsertPacketEvent( |
| testing_clock_->NowTicks(), PACKET_RECEIVED, AUDIO_EVENT, |
| /*rtp_timestamp */ 400u, /*frame_id*/ 5u, /*packet_id*/ 1u, |
| /*max_packet_id*/ 10u, /*size*/ 128u); |
| |
| // Unrelated events |
| cast_environment_->Logging()->InsertFrameEvent(testing_clock_->NowTicks(), |
| FRAME_CAPTURE_END, |
| VIDEO_EVENT, |
| /*rtp_timestamp*/ 100u, |
| /*frame_id*/ 1u); |
| cast_environment_->Logging()->InsertFrameEvent(testing_clock_->NowTicks(), |
| FRAME_CAPTURE_END, |
| AUDIO_EVENT, |
| /*rtp_timestamp*/ 100u, |
| /*frame_id*/ 1u); |
| } |
| |
| base::SimpleTestTickClock* testing_clock_; // Owned by CastEnvironment. |
| scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_; |
| scoped_refptr<CastEnvironment> cast_environment_; |
| scoped_ptr<ReceiverRtcpEventSubscriber> event_subscriber_; |
| }; |
| |
| TEST_F(ReceiverRtcpEventSubscriberTest, LogVideoEvents) { |
| Init(VIDEO_EVENT); |
| |
| InsertEvents(); |
| ReceiverRtcpEventSubscriber::RtcpEventMultiMap rtcp_events; |
| event_subscriber_->GetRtcpEventsAndReset(&rtcp_events); |
| EXPECT_EQ(3u, rtcp_events.size()); |
| } |
| |
| TEST_F(ReceiverRtcpEventSubscriberTest, LogAudioEvents) { |
| Init(AUDIO_EVENT); |
| |
| InsertEvents(); |
| ReceiverRtcpEventSubscriber::RtcpEventMultiMap rtcp_events; |
| event_subscriber_->GetRtcpEventsAndReset(&rtcp_events); |
| EXPECT_EQ(3u, rtcp_events.size()); |
| } |
| |
| TEST_F(ReceiverRtcpEventSubscriberTest, DropEventsWhenSizeExceeded) { |
| Init(VIDEO_EVENT); |
| |
| for (uint32 i = 1u; i <= 10u; ++i) { |
| cast_environment_->Logging()->InsertFrameEvent( |
| testing_clock_->NowTicks(), FRAME_DECODED, VIDEO_EVENT, |
| /*rtp_timestamp*/ i * 10, /*frame_id*/ i); |
| } |
| |
| ReceiverRtcpEventSubscriber::RtcpEventMultiMap rtcp_events; |
| event_subscriber_->GetRtcpEventsAndReset(&rtcp_events); |
| EXPECT_EQ(10u, rtcp_events.size()); |
| } |
| |
| } // namespace cast |
| } // namespace media |