Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(58)

Side by Side Diff: media/audio/virtual_audio_output_stream_unittest.cc

Issue 66183002: Replace MessageLoopProxy with SingleThreadTaskRunner for the rest of media/. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: fix win and audio tests Created 6 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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/bind.h" 5 #include "base/bind.h"
6 #include "base/bind_helpers.h" 6 #include "base/bind_helpers.h"
7 #include "base/message_loop/message_loop.h"
8 #include "base/message_loop/message_loop_proxy.h"
9 #include "base/synchronization/waitable_event.h" 7 #include "base/synchronization/waitable_event.h"
10 #include "base/threading/thread.h" 8 #include "base/threading/thread.h"
11 #include "media/audio/audio_manager.h" 9 #include "media/audio/audio_manager.h"
12 #include "media/audio/simple_sources.h" 10 #include "media/audio/simple_sources.h"
13 #include "media/audio/virtual_audio_input_stream.h" 11 #include "media/audio/virtual_audio_input_stream.h"
14 #include "media/audio/virtual_audio_output_stream.h" 12 #include "media/audio/virtual_audio_output_stream.h"
15 #include "testing/gmock/include/gmock/gmock.h" 13 #include "testing/gmock/include/gmock/gmock.h"
16 #include "testing/gtest/include/gtest/gtest.h" 14 #include "testing/gtest/include/gtest/gtest.h"
17 15
18 using ::testing::_; 16 using ::testing::_;
19 17
20 namespace media { 18 namespace media {
21 19
22 namespace { 20 namespace {
23 const AudioParameters kParams( 21 const AudioParameters kParams(
24 AudioParameters::AUDIO_PCM_LOW_LATENCY, CHANNEL_LAYOUT_MONO, 8000, 8, 128); 22 AudioParameters::AUDIO_PCM_LOW_LATENCY, CHANNEL_LAYOUT_MONO, 8000, 8, 128);
25 } 23 }
26 24
27 class MockVirtualAudioInputStream : public VirtualAudioInputStream { 25 class MockVirtualAudioInputStream : public VirtualAudioInputStream {
28 public: 26 public:
29 explicit MockVirtualAudioInputStream( 27 explicit MockVirtualAudioInputStream(
30 const scoped_refptr<base::MessageLoopProxy>& worker_loop) 28 const scoped_refptr<base::SingleThreadTaskRunner>& worker_task_runner)
31 : VirtualAudioInputStream( 29 : VirtualAudioInputStream(
32 kParams, 30 kParams,
33 worker_loop, 31 worker_task_runner,
34 base::Bind(&base::DeletePointer<VirtualAudioInputStream>)) {} 32 base::Bind(&base::DeletePointer<VirtualAudioInputStream>)) {}
35 ~MockVirtualAudioInputStream() {} 33 ~MockVirtualAudioInputStream() {}
36 34
37 MOCK_METHOD2(AddOutputStream, void(VirtualAudioOutputStream* stream, 35 MOCK_METHOD2(AddOutputStream, void(VirtualAudioOutputStream* stream,
38 const AudioParameters& output_params)); 36 const AudioParameters& output_params));
39 MOCK_METHOD2(RemoveOutputStream, void(VirtualAudioOutputStream* stream, 37 MOCK_METHOD2(RemoveOutputStream, void(VirtualAudioOutputStream* stream,
40 const AudioParameters& output_params)); 38 const AudioParameters& output_params));
41 39
42 private: 40 private:
43 DISALLOW_COPY_AND_ASSIGN(MockVirtualAudioInputStream); 41 DISALLOW_COPY_AND_ASSIGN(MockVirtualAudioInputStream);
44 }; 42 };
45 43
46 class MockAudioDeviceListener : public AudioManager::AudioDeviceListener { 44 class MockAudioDeviceListener : public AudioManager::AudioDeviceListener {
47 public: 45 public:
48 MOCK_METHOD0(OnDeviceChange, void()); 46 MOCK_METHOD0(OnDeviceChange, void());
49 }; 47 };
50 48
51 class VirtualAudioOutputStreamTest : public testing::Test { 49 class VirtualAudioOutputStreamTest : public testing::Test {
52 public: 50 public:
53 VirtualAudioOutputStreamTest() 51 VirtualAudioOutputStreamTest()
54 : audio_thread_(new base::Thread("AudioThread")) { 52 : audio_thread_(new base::Thread("AudioThread")) {
55 audio_thread_->Start(); 53 audio_thread_->Start();
56 audio_message_loop_ = audio_thread_->message_loop_proxy(); 54 audio_task_runner_ = audio_thread_->message_loop_proxy();
57 } 55 }
58 56
59 const scoped_refptr<base::MessageLoopProxy>& audio_message_loop() const { 57 const scoped_refptr<base::SingleThreadTaskRunner>& audio_task_runner() const {
60 return audio_message_loop_; 58 return audio_task_runner_;
61 } 59 }
62 60
63 void SyncWithAudioThread() { 61 void SyncWithAudioThread() {
64 base::WaitableEvent done(false, false); 62 base::WaitableEvent done(false, false);
65 audio_message_loop()->PostTask( 63 audio_task_runner()->PostTask(
66 FROM_HERE, base::Bind(&base::WaitableEvent::Signal, 64 FROM_HERE, base::Bind(&base::WaitableEvent::Signal,
67 base::Unretained(&done))); 65 base::Unretained(&done)));
68 done.Wait(); 66 done.Wait();
69 } 67 }
70 68
71 private: 69 private:
72 scoped_ptr<base::Thread> audio_thread_; 70 scoped_ptr<base::Thread> audio_thread_;
73 scoped_refptr<base::MessageLoopProxy> audio_message_loop_; 71 scoped_refptr<base::SingleThreadTaskRunner> audio_task_runner_;
74 72
75 DISALLOW_COPY_AND_ASSIGN(VirtualAudioOutputStreamTest); 73 DISALLOW_COPY_AND_ASSIGN(VirtualAudioOutputStreamTest);
76 }; 74 };
77 75
78 TEST_F(VirtualAudioOutputStreamTest, StartStopStartStop) { 76 TEST_F(VirtualAudioOutputStreamTest, StartStopStartStop) {
79 static const int kCycles = 3; 77 static const int kCycles = 3;
80 78
81 MockVirtualAudioInputStream* const input_stream = 79 MockVirtualAudioInputStream* const input_stream =
82 new MockVirtualAudioInputStream(audio_message_loop()); 80 new MockVirtualAudioInputStream(audio_task_runner());
83 audio_message_loop()->PostTask( 81 audio_task_runner()->PostTask(
84 FROM_HERE, base::Bind( 82 FROM_HERE, base::Bind(
85 base::IgnoreResult(&MockVirtualAudioInputStream::Open), 83 base::IgnoreResult(&MockVirtualAudioInputStream::Open),
86 base::Unretained(input_stream))); 84 base::Unretained(input_stream)));
87 85
88 VirtualAudioOutputStream* const output_stream = new VirtualAudioOutputStream( 86 VirtualAudioOutputStream* const output_stream = new VirtualAudioOutputStream(
89 kParams, 87 kParams,
90 input_stream, 88 input_stream,
91 base::Bind(&base::DeletePointer<VirtualAudioOutputStream>)); 89 base::Bind(&base::DeletePointer<VirtualAudioOutputStream>));
92 90
93 EXPECT_CALL(*input_stream, AddOutputStream(output_stream, _)) 91 EXPECT_CALL(*input_stream, AddOutputStream(output_stream, _))
94 .Times(kCycles); 92 .Times(kCycles);
95 EXPECT_CALL(*input_stream, RemoveOutputStream(output_stream, _)) 93 EXPECT_CALL(*input_stream, RemoveOutputStream(output_stream, _))
96 .Times(kCycles); 94 .Times(kCycles);
97 95
98 audio_message_loop()->PostTask( 96 audio_task_runner()->PostTask(
99 FROM_HERE, base::Bind(base::IgnoreResult(&VirtualAudioOutputStream::Open), 97 FROM_HERE, base::Bind(base::IgnoreResult(&VirtualAudioOutputStream::Open),
100 base::Unretained(output_stream))); 98 base::Unretained(output_stream)));
101 SineWaveAudioSource source(CHANNEL_LAYOUT_STEREO, 200.0, 128); 99 SineWaveAudioSource source(CHANNEL_LAYOUT_STEREO, 200.0, 128);
102 for (int i = 0; i < kCycles; ++i) { 100 for (int i = 0; i < kCycles; ++i) {
103 audio_message_loop()->PostTask( 101 audio_task_runner()->PostTask(
104 FROM_HERE, base::Bind(&VirtualAudioOutputStream::Start, 102 FROM_HERE, base::Bind(&VirtualAudioOutputStream::Start,
105 base::Unretained(output_stream), 103 base::Unretained(output_stream),
106 &source)); 104 &source));
107 audio_message_loop()->PostTask( 105 audio_task_runner()->PostTask(
108 FROM_HERE, base::Bind(&VirtualAudioOutputStream::Stop, 106 FROM_HERE, base::Bind(&VirtualAudioOutputStream::Stop,
109 base::Unretained(output_stream))); 107 base::Unretained(output_stream)));
110 } 108 }
111 audio_message_loop()->PostTask( 109 audio_task_runner()->PostTask(
112 FROM_HERE, base::Bind(&VirtualAudioOutputStream::Close, 110 FROM_HERE, base::Bind(&VirtualAudioOutputStream::Close,
113 base::Unretained(output_stream))); 111 base::Unretained(output_stream)));
114 112
115 audio_message_loop()->PostTask( 113 audio_task_runner()->PostTask(
116 FROM_HERE, base::Bind(&MockVirtualAudioInputStream::Close, 114 FROM_HERE, base::Bind(&MockVirtualAudioInputStream::Close,
117 base::Unretained(input_stream))); 115 base::Unretained(input_stream)));
118 116
119 SyncWithAudioThread(); 117 SyncWithAudioThread();
120 } 118 }
121 119
122 } // namespace media 120 } // namespace media
OLDNEW
« no previous file with comments | « media/audio/virtual_audio_input_stream_unittest.cc ('k') | media/audio/win/audio_manager_win.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698