Chromium Code Reviews| OLD | NEW |
|---|---|
| 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 "content/browser/renderer_host/media/audio_sync_reader.h" | 5 #include "content/browser/renderer_host/media/audio_sync_reader.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 | 8 |
| 9 #include "base/process_util.h" | 9 #include "base/process_util.h" |
| 10 #include "base/shared_memory.h" | 10 #include "base/shared_memory.h" |
| 11 #include "base/threading/platform_thread.h" | 11 #include "base/threading/platform_thread.h" |
| 12 #include "media/audio/audio_buffers_state.h" | 12 #include "media/audio/audio_buffers_state.h" |
| 13 #include "media/audio/audio_parameters.h" | 13 #include "media/audio/audio_parameters.h" |
| 14 #include "media/audio/shared_memory_util.h" | 14 #include "media/audio/shared_memory_util.h" |
| 15 | 15 |
| 16 #if defined(OS_WIN) | |
| 17 const int kMinIntervalBetweenReadCallsInMs = 10; | |
| 18 #endif | |
| 19 | |
| 20 using media::AudioBus; | 16 using media::AudioBus; |
| 21 | 17 |
| 22 namespace content { | 18 namespace content { |
| 23 | 19 |
| 24 AudioSyncReader::AudioSyncReader(base::SharedMemory* shared_memory, | 20 AudioSyncReader::AudioSyncReader(base::SharedMemory* shared_memory, |
| 25 const media::AudioParameters& params, | 21 const media::AudioParameters& params, |
| 26 int input_channels) | 22 int input_channels) |
| 27 : shared_memory_(shared_memory), | 23 : shared_memory_(shared_memory), |
| 28 input_channels_(input_channels) { | 24 input_channels_(input_channels) { |
| 29 packet_size_ = media::PacketSizeInBytes(shared_memory_->created_size()); | 25 packet_size_ = media::PacketSizeInBytes(shared_memory_->created_size()); |
| (...skipping 26 matching lines...) Expand all Loading... | |
| 56 media::SetUnknownDataSize(shared_memory_, packet_size_); | 52 media::SetUnknownDataSize(shared_memory_, packet_size_); |
| 57 } | 53 } |
| 58 | 54 |
| 59 if (socket_.get()) { | 55 if (socket_.get()) { |
| 60 socket_->Send(&bytes, sizeof(bytes)); | 56 socket_->Send(&bytes, sizeof(bytes)); |
| 61 } | 57 } |
| 62 } | 58 } |
| 63 | 59 |
| 64 int AudioSyncReader::Read(AudioBus* source, AudioBus* dest) { | 60 int AudioSyncReader::Read(AudioBus* source, AudioBus* dest) { |
| 65 #if defined(OS_WIN) | 61 #if defined(OS_WIN) |
| 66 // HACK: yield if reader is called too often. | 62 // HACK: Yield if Read() is called too often. On older platforms which are |
| 67 // Problem is lack of synchronization between host and renderer. We cannot be | 63 // still using the WaveOut back end, we run into synchronization issues where |
| 68 // sure if renderer already filled the buffer, and due to all the plugins we | 64 // the renderer has not finished filling the shared memory when Read() is |
| 69 // cannot change the API, so we yield if previous call was too recent. | 65 // called. Reading too early will lead to clicks and pops. See issues: |
| 70 // Optimization: if renderer is "new" one that writes length of data we can | 66 // http://crbug.com/161307 and http://crbug.com/61022 |
|
scherkus (not reviewing)
2012/11/20 21:08:46
does it make sense to add a run-time check for XP?
DaleCurtis
2012/11/20 21:33:47
I thought about that, but there are cases where we
| |
| 71 // stop yielding the moment length is written -- not ideal solution, | 67 while (!DataReady()) { |
| 72 // but better than nothing. | |
| 73 while (!DataReady() && | |
| 74 ((base::Time::Now() - previous_call_time_).InMilliseconds() < | |
| 75 kMinIntervalBetweenReadCallsInMs)) { | |
| 76 base::PlatformThread::YieldCurrentThread(); | 68 base::PlatformThread::YieldCurrentThread(); |
| 77 } | 69 } |
| 78 previous_call_time_ = base::Time::Now(); | |
| 79 #endif | 70 #endif |
| 80 | 71 |
| 81 // Copy optional synchronized live audio input for consumption by renderer | 72 // Copy optional synchronized live audio input for consumption by renderer |
| 82 // process. | 73 // process. |
| 83 if (source && input_bus_.get()) { | 74 if (source && input_bus_.get()) { |
| 84 DCHECK_EQ(source->channels(), input_bus_->channels()); | 75 DCHECK_EQ(source->channels(), input_bus_->channels()); |
| 85 DCHECK_LE(source->frames(), input_bus_->frames()); | 76 DCHECK_LE(source->frames(), input_bus_->frames()); |
| 86 source->CopyTo(input_bus_.get()); | 77 source->CopyTo(input_bus_.get()); |
| 87 } | 78 } |
| 88 | 79 |
| (...skipping 64 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 153 base::FileDescriptor* foreign_handle) { | 144 base::FileDescriptor* foreign_handle) { |
| 154 foreign_handle->fd = foreign_socket_->handle(); | 145 foreign_handle->fd = foreign_socket_->handle(); |
| 155 foreign_handle->auto_close = false; | 146 foreign_handle->auto_close = false; |
| 156 if (foreign_handle->fd != -1) | 147 if (foreign_handle->fd != -1) |
| 157 return true; | 148 return true; |
| 158 return false; | 149 return false; |
| 159 } | 150 } |
| 160 #endif | 151 #endif |
| 161 | 152 |
| 162 } // namespace content | 153 } // namespace content |
| OLD | NEW |