Index: content/browser/renderer_host/media/audio_input_sync_writer.cc |
=================================================================== |
--- content/browser/renderer_host/media/audio_input_sync_writer.cc (revision 186364) |
+++ content/browser/renderer_host/media/audio_input_sync_writer.cc (working copy) |
@@ -11,8 +11,16 @@ |
namespace content { |
-AudioInputSyncWriter::AudioInputSyncWriter(base::SharedMemory* shared_memory) |
- : shared_memory_(shared_memory) { |
+AudioInputSyncWriter::AudioInputSyncWriter( |
+ base::SharedMemory* shared_memory, |
+ int shared_memory_segment_count) |
+ : shared_memory_(shared_memory), |
+ shared_memory_segment_count_(shared_memory_segment_count), |
+ current_segment_id_(0) { |
+ DCHECK_GT(shared_memory_segment_count, 0); |
+ DCHECK_EQ(shared_memory->created_size() % shared_memory_segment_count, 0u); |
+ shared_memory_segment_size_ = |
+ shared_memory->created_size() / shared_memory_segment_count; |
} |
AudioInputSyncWriter::~AudioInputSyncWriter() {} |
@@ -22,14 +30,19 @@ |
socket_->Send(&bytes, sizeof(bytes)); |
} |
-uint32 AudioInputSyncWriter::Write(const void* data, uint32 size, |
- double volume) { |
+uint32 AudioInputSyncWriter::Write( |
+ const void* data, uint32 size, double volume) { |
+ uint8* ptr = static_cast<uint8*>(shared_memory_->memory()); |
+ ptr += current_segment_id_ * shared_memory_segment_size_; |
media::AudioInputBuffer* buffer = |
- reinterpret_cast<media::AudioInputBuffer*>(shared_memory_->memory()); |
+ reinterpret_cast<media::AudioInputBuffer*>(ptr); |
buffer->params.volume = volume; |
buffer->params.size = size; |
memcpy(buffer->audio, data, size); |
+ if (++current_segment_id_ >= shared_memory_segment_count_) |
+ current_segment_id_ = 0; |
+ |
return size; |
} |