OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "base/memory/ref_counted.h" | 5 #include "base/memory/ref_counted.h" |
6 #include "base/memory/scoped_ptr.h" | 6 #include "base/memory/scoped_ptr.h" |
7 #include "base/test/simple_test_tick_clock.h" | 7 #include "base/test/simple_test_tick_clock.h" |
8 #include "base/time/tick_clock.h" | 8 #include "base/time/tick_clock.h" |
9 #include "media/cast/cast_environment.h" | 9 #include "media/cast/cast_environment.h" |
10 #include "media/cast/logging/logging_defines.h" | 10 #include "media/cast/logging/logging_defines.h" |
(...skipping 23 matching lines...) Expand all Loading... |
34 | 34 |
35 base::SimpleTestTickClock* testing_clock_; // Owned by CastEnvironment. | 35 base::SimpleTestTickClock* testing_clock_; // Owned by CastEnvironment. |
36 scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_; | 36 scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_; |
37 scoped_refptr<CastEnvironment> cast_environment_; | 37 scoped_refptr<CastEnvironment> cast_environment_; |
38 SimpleEventSubscriber event_subscriber_; | 38 SimpleEventSubscriber event_subscriber_; |
39 }; | 39 }; |
40 | 40 |
41 TEST_F(SimpleEventSubscriberTest, GetAndResetEvents) { | 41 TEST_F(SimpleEventSubscriberTest, GetAndResetEvents) { |
42 // Log some frame events. | 42 // Log some frame events. |
43 cast_environment_->Logging()->InsertEncodedFrameEvent( | 43 cast_environment_->Logging()->InsertEncodedFrameEvent( |
44 testing_clock_->NowTicks(), kAudioFrameEncoded, /*rtp_timestamp*/ 100u, | 44 testing_clock_->NowTicks(), FRAME_ENCODED, AUDIO_EVENT, |
45 /*frame_id*/ 0u, /*frame_size*/ 123, /*key_frame*/ false, 0); | 45 /*rtp_timestamp*/ 100u, /*frame_id*/ 0u, /*frame_size*/ 123, |
| 46 /*key_frame*/ false, 0); |
46 cast_environment_->Logging()->InsertFrameEventWithDelay( | 47 cast_environment_->Logging()->InsertFrameEventWithDelay( |
47 testing_clock_->NowTicks(), kAudioPlayoutDelay, /*rtp_timestamp*/ 100u, | 48 testing_clock_->NowTicks(), FRAME_PLAYOUT, AUDIO_EVENT, |
| 49 /*rtp_timestamp*/ 100u, |
48 /*frame_id*/ 0u, /*delay*/ base::TimeDelta::FromMilliseconds(100)); | 50 /*frame_id*/ 0u, /*delay*/ base::TimeDelta::FromMilliseconds(100)); |
49 cast_environment_->Logging()->InsertFrameEvent( | 51 cast_environment_->Logging()->InsertFrameEvent( |
50 testing_clock_->NowTicks(), kAudioFrameDecoded, /*rtp_timestamp*/ 200u, | 52 testing_clock_->NowTicks(), FRAME_DECODED, AUDIO_EVENT, |
| 53 /*rtp_timestamp*/ 200u, |
51 /*frame_id*/ 0u); | 54 /*frame_id*/ 0u); |
52 | 55 |
53 // Log some packet events. | 56 // Log some packet events. |
54 cast_environment_->Logging()->InsertPacketEvent( | 57 cast_environment_->Logging()->InsertPacketEvent( |
55 testing_clock_->NowTicks(), kAudioPacketReceived, /*rtp_timestamp*/ 200u, | 58 testing_clock_->NowTicks(), PACKET_RECEIVED, AUDIO_EVENT, |
| 59 /*rtp_timestamp*/ 200u, |
56 /*frame_id*/ 0u, /*packet_id*/ 1u, /*max_packet_id*/ 5u, /*size*/ 100u); | 60 /*frame_id*/ 0u, /*packet_id*/ 1u, /*max_packet_id*/ 5u, /*size*/ 100u); |
57 cast_environment_->Logging()->InsertPacketEvent( | 61 cast_environment_->Logging()->InsertPacketEvent( |
58 testing_clock_->NowTicks(), kVideoFrameDecoded, /*rtp_timestamp*/ 200u, | 62 testing_clock_->NowTicks(), FRAME_DECODED, VIDEO_EVENT, |
59 /*frame_id*/ 0u, /*packet_id*/ 1u, /*max_packet_id*/ 5u, /*size*/ 100u); | 63 /*rtp_timestamp*/ 200u, /*frame_id*/ 0u, /*packet_id*/ 1u, |
| 64 /*max_packet_id*/ 5u, /*size*/ 100u); |
60 cast_environment_->Logging()->InsertPacketEvent( | 65 cast_environment_->Logging()->InsertPacketEvent( |
61 testing_clock_->NowTicks(), kVideoFrameDecoded, /*rtp_timestamp*/ 300u, | 66 testing_clock_->NowTicks(), FRAME_DECODED, VIDEO_EVENT, |
62 /*frame_id*/ 0u, /*packet_id*/ 1u, /*max_packet_id*/ 5u, /*size*/ 100u); | 67 /*rtp_timestamp*/ 300u, /*frame_id*/ 0u, /*packet_id*/ 1u, |
| 68 /*max_packet_id*/ 5u, /*size*/ 100u); |
63 | 69 |
64 std::vector<FrameEvent> frame_events; | 70 std::vector<FrameEvent> frame_events; |
65 event_subscriber_.GetFrameEventsAndReset(&frame_events); | 71 event_subscriber_.GetFrameEventsAndReset(&frame_events); |
66 EXPECT_EQ(3u, frame_events.size()); | 72 EXPECT_EQ(3u, frame_events.size()); |
67 | 73 |
68 std::vector<PacketEvent> packet_events; | 74 std::vector<PacketEvent> packet_events; |
69 event_subscriber_.GetPacketEventsAndReset(&packet_events); | 75 event_subscriber_.GetPacketEventsAndReset(&packet_events); |
70 EXPECT_EQ(3u, packet_events.size()); | 76 EXPECT_EQ(3u, packet_events.size()); |
71 | 77 |
72 // Calling this function again should result in empty vector because no events | 78 // Calling this function again should result in empty vector because no events |
73 // were logged since last call. | 79 // were logged since last call. |
74 event_subscriber_.GetFrameEventsAndReset(&frame_events); | 80 event_subscriber_.GetFrameEventsAndReset(&frame_events); |
75 event_subscriber_.GetPacketEventsAndReset(&packet_events); | 81 event_subscriber_.GetPacketEventsAndReset(&packet_events); |
76 EXPECT_TRUE(frame_events.empty()); | 82 EXPECT_TRUE(frame_events.empty()); |
77 EXPECT_TRUE(packet_events.empty()); | 83 EXPECT_TRUE(packet_events.empty()); |
78 } | 84 } |
79 | 85 |
80 } // namespace cast | 86 } // namespace cast |
81 } // namespace media | 87 } // namespace media |
OLD | NEW |