| // Copyright (c) 2012 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 "content/browser/renderer_host/media/audio_input_sync_writer.h" |
| |
| #include <algorithm> |
| |
| #include "base/memory/shared_memory.h" |
| |
| namespace content { |
| |
| 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->requested_size() % shared_memory_segment_count, 0u); |
| shared_memory_segment_size_ = |
| shared_memory->requested_size() / shared_memory_segment_count; |
| } |
| |
| AudioInputSyncWriter::~AudioInputSyncWriter() {} |
| |
| // TODO(henrika): Combine into one method (including Write). |
| void AudioInputSyncWriter::UpdateRecordedBytes(uint32 bytes) { |
| socket_->Send(&bytes, sizeof(bytes)); |
| } |
| |
| uint32 AudioInputSyncWriter::Write(const void* data, |
| uint32 size, |
| double volume, |
| bool key_pressed) { |
| uint8* ptr = static_cast<uint8*>(shared_memory_->memory()); |
| ptr += current_segment_id_ * shared_memory_segment_size_; |
| media::AudioInputBuffer* buffer = |
| reinterpret_cast<media::AudioInputBuffer*>(ptr); |
| buffer->params.volume = volume; |
| buffer->params.size = size; |
| buffer->params.key_pressed = key_pressed; |
| memcpy(buffer->audio, data, size); |
| |
| if (++current_segment_id_ >= shared_memory_segment_count_) |
| current_segment_id_ = 0; |
| |
| return size; |
| } |
| |
| void AudioInputSyncWriter::Close() { |
| socket_->Close(); |
| } |
| |
| bool AudioInputSyncWriter::Init() { |
| socket_.reset(new base::CancelableSyncSocket()); |
| foreign_socket_.reset(new base::CancelableSyncSocket()); |
| return base::CancelableSyncSocket::CreatePair(socket_.get(), |
| foreign_socket_.get()); |
| } |
| |
| #if defined(OS_WIN) |
| |
| bool AudioInputSyncWriter::PrepareForeignSocketHandle( |
| base::ProcessHandle process_handle, |
| base::SyncSocket::Handle* foreign_handle) { |
| ::DuplicateHandle(GetCurrentProcess(), foreign_socket_->handle(), |
| process_handle, foreign_handle, |
| 0, FALSE, DUPLICATE_SAME_ACCESS); |
| return (*foreign_handle != 0); |
| } |
| |
| #else |
| |
| bool AudioInputSyncWriter::PrepareForeignSocketHandle( |
| base::ProcessHandle process_handle, |
| base::FileDescriptor* foreign_handle) { |
| foreign_handle->fd = foreign_socket_->handle(); |
| foreign_handle->auto_close = false; |
| return (foreign_handle->fd != -1); |
| } |
| |
| #endif |
| |
| } // namespace content |