Move the Pepper implementation from webkit/glue/plugins/pepper_* to...

webkit/glue/plugins/pepper_audio.cc

Index: webkit/glue/plugins/pepper_audio.cc
===================================================================
--- webkit/glue/plugins/pepper_audio.cc	(revision 69282)
+++ webkit/glue/plugins/pepper_audio.cc	(working copy)
@@ -1,351 +0,0 @@
-// Copyright (c) 2010 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 "webkit/glue/plugins/pepper_audio.h"
-
-#include "base/logging.h"
-#include "ppapi/c/dev/ppb_audio_dev.h"
-#include "ppapi/c/dev/ppb_audio_trusted_dev.h"
-#include "ppapi/c/pp_completion_callback.h"
-#include "webkit/glue/plugins/pepper_common.h"
-
-namespace pepper {
-
-namespace {
-
-// PPB_AudioConfig -------------------------------------------------------------
-
-uint32_t RecommendSampleFrameCount(uint32_t requested_sample_frame_count);
-
-PP_Resource CreateStereo16bit(PP_Module module_id,
-                              PP_AudioSampleRate_Dev sample_rate,
-                              uint32_t sample_frame_count) {
-  PluginModule* module = ResourceTracker::Get()->GetModule(module_id);
-  if (!module)
-    return 0;
-
-  // TODO(brettw): Currently we don't actually check what the hardware
-  // supports, so just allow sample rates of the "guaranteed working" ones.
-  if (sample_rate != PP_AUDIOSAMPLERATE_44100 &&
-      sample_rate != PP_AUDIOSAMPLERATE_48000)
-    return 0;
-
-  // TODO(brettw): Currently we don't actually query to get a value from the
-  // hardware, so just validate the range.
-  if (RecommendSampleFrameCount(sample_frame_count) != sample_frame_count)
-    return 0;
-
-  scoped_refptr<AudioConfig> config(new AudioConfig(module,
-                                                    sample_rate,
-                                                    sample_frame_count));
-  return config->GetReference();
-}
-
-uint32_t RecommendSampleFrameCount(uint32_t requested_sample_frame_count) {
-  // TODO(brettw) Currently we don't actually query to get a value from the
-  // hardware, so we always return the input for in-range values.
-  if (requested_sample_frame_count < PP_AUDIOMINSAMPLEFRAMECOUNT)
-    return PP_AUDIOMINSAMPLEFRAMECOUNT;
-  if (requested_sample_frame_count > PP_AUDIOMAXSAMPLEFRAMECOUNT)
-    return PP_AUDIOMAXSAMPLEFRAMECOUNT;
-  return requested_sample_frame_count;
-}
-
-PP_Bool IsAudioConfig(PP_Resource resource) {
-  scoped_refptr<AudioConfig> config = Resource::GetAs<AudioConfig>(resource);
-  return BoolToPPBool(!!config);
-}
-
-PP_AudioSampleRate_Dev GetSampleRate(PP_Resource config_id) {
-  scoped_refptr<AudioConfig> config = Resource::GetAs<AudioConfig>(config_id);
-  return config ? config->sample_rate() : PP_AUDIOSAMPLERATE_NONE;
-}
-
-uint32_t GetSampleFrameCount(PP_Resource config_id) {
-  scoped_refptr<AudioConfig> config = Resource::GetAs<AudioConfig>(config_id);
-  return config ? config->sample_frame_count() : 0;
-}
-
-const PPB_AudioConfig_Dev ppb_audioconfig = {
-  &CreateStereo16bit,
-  &RecommendSampleFrameCount,
-  &IsAudioConfig,
-  &GetSampleRate,
-  &GetSampleFrameCount
-};
-
-// PPB_Audio -------------------------------------------------------------------
-
-PP_Resource Create(PP_Instance instance_id, PP_Resource config_id,
-                   PPB_Audio_Callback user_callback, void* user_data) {
-  PluginInstance* instance = ResourceTracker::Get()->GetInstance(instance_id);
-  if (!instance)
-    return 0;
-  if (!user_callback)
-    return 0;
-  scoped_refptr<Audio> audio(new Audio(instance->module(), instance_id));
-  if (!audio->Init(instance->delegate(), config_id,
-                   user_callback, user_data))
-    return 0;
-  return audio->GetReference();
-}
-
-PP_Bool IsAudio(PP_Resource resource) {
-  scoped_refptr<Audio> audio = Resource::GetAs<Audio>(resource);
-  return BoolToPPBool(!!audio);
-}
-
-PP_Resource GetCurrentConfig(PP_Resource audio_id) {
-  scoped_refptr<Audio> audio = Resource::GetAs<Audio>(audio_id);
-  return audio ? audio->GetCurrentConfig() : 0;
-}
-
-PP_Bool StartPlayback(PP_Resource audio_id) {
-  scoped_refptr<Audio> audio = Resource::GetAs<Audio>(audio_id);
-  return audio ? BoolToPPBool(audio->StartPlayback()) : PP_FALSE;
-}
-
-PP_Bool StopPlayback(PP_Resource audio_id) {
-  scoped_refptr<Audio> audio = Resource::GetAs<Audio>(audio_id);
-  return audio ? BoolToPPBool(audio->StopPlayback()) : PP_FALSE;
-}
-
-const PPB_Audio_Dev ppb_audio = {
-  &Create,
-  &IsAudio,
-  &GetCurrentConfig,
-  &StartPlayback,
-  &StopPlayback,
-};
-
-// PPB_AudioTrusted ------------------------------------------------------------
-
-PP_Resource CreateTrusted(PP_Instance instance_id) {
-  PluginInstance* instance = ResourceTracker::Get()->GetInstance(instance_id);
-  if (!instance)
-    return 0;
-  scoped_refptr<Audio> audio(new Audio(instance->module(), instance_id));
-  return audio->GetReference();
-}
-
-int32_t Open(PP_Resource audio_id,
-             PP_Resource config_id,
-             PP_CompletionCallback created) {
-  scoped_refptr<Audio> audio = Resource::GetAs<Audio>(audio_id);
-  if (!audio)
-    return PP_ERROR_BADRESOURCE;
-  if (!created.func)
-    return PP_ERROR_BADARGUMENT;
-  PP_Instance instance_id = audio->pp_instance();
-  PluginInstance* instance = ResourceTracker::Get()->GetInstance(instance_id);
-  if (!instance)
-    return PP_ERROR_FAILED;
-  return audio->Open(instance->delegate(), config_id, created);
-}
-
-int32_t GetSyncSocket(PP_Resource audio_id, int* sync_socket) {
-  scoped_refptr<Audio> audio = Resource::GetAs<Audio>(audio_id);
-  if (audio)
-    return audio->GetSyncSocket(sync_socket);
-  return PP_ERROR_BADRESOURCE;
-}
-
-int32_t GetSharedMemory(PP_Resource audio_id,
-                        int* shm_handle,
-                        uint32_t* shm_size) {
-  scoped_refptr<Audio> audio = Resource::GetAs<Audio>(audio_id);
-  if (audio)
-    return audio->GetSharedMemory(shm_handle, shm_size);
-  return PP_ERROR_BADRESOURCE;
-}
-
-const PPB_AudioTrusted_Dev ppb_audiotrusted = {
-  &CreateTrusted,
-  &Open,
-  &GetSyncSocket,
-  &GetSharedMemory,
-};
-
-}  // namespace
-
-// AudioConfig -----------------------------------------------------------------
-
-AudioConfig::AudioConfig(PluginModule* module,
-                         PP_AudioSampleRate_Dev sample_rate,
-                         uint32_t sample_frame_count)
-    : Resource(module),
-      sample_rate_(sample_rate),
-      sample_frame_count_(sample_frame_count) {
-}
-
-const PPB_AudioConfig_Dev* AudioConfig::GetInterface() {
-  return &ppb_audioconfig;
-}
-
-size_t AudioConfig::BufferSize() {
-  // TODO(audio): as more options become available, we'll need to
-  // have additional code here to correctly calculate the size in
-  // bytes of an audio buffer.  For now, only support two channel
-  // int16_t sample buffers.
-  const int kChannels = 2;
-  const int kSizeOfSample = sizeof(int16_t);
-  return static_cast<size_t>(sample_frame_count_ * kSizeOfSample * kChannels);
-}
-
-AudioConfig* AudioConfig::AsAudioConfig() {
-  return this;
-}
-
-// Audio -----------------------------------------------------------------------
-
-Audio::Audio(PluginModule* module, PP_Instance instance_id)
-    : Resource(module),
-      pp_instance_(instance_id),
-      audio_(NULL),
-      create_callback_pending_(false) {
-  create_callback_ = PP_MakeCompletionCallback(NULL, NULL);
-}
-
-Audio::~Audio() {
-  // Calling ShutDown() makes sure StreamCreated cannot be called anymore.
-  audio_->ShutDown();
-  audio_ = NULL;
-
-  // If the completion callback hasn't fired yet, do so here
-  // with an error condition.
-  if (create_callback_pending_) {
-    PP_RunCompletionCallback(&create_callback_, PP_ERROR_ABORTED);
-    create_callback_pending_ = false;
-  }
-}
-
-const PPB_Audio_Dev* Audio::GetInterface() {
-  return &ppb_audio;
-}
-
-const PPB_AudioTrusted_Dev* Audio::GetTrustedInterface() {
-  return &ppb_audiotrusted;
-}
-
-Audio* Audio::AsAudio() {
-  return this;
-}
-
-bool Audio::Init(PluginDelegate* plugin_delegate,
-                 PP_Resource config_id,
-                 PPB_Audio_Callback callback, void* user_data) {
-  CHECK(!audio_);
-  config_ = Resource::GetAs<AudioConfig>(config_id);
-  if (!config_)
-    return false;
-  SetCallback(callback, user_data);
-
-  // When the stream is created, we'll get called back on StreamCreated().
-  audio_ = plugin_delegate->CreateAudio(config_->sample_rate(),
-                                        config_->sample_frame_count(),
-                                        this);
-  return audio_ != NULL;
-}
-
-PP_Resource Audio::GetCurrentConfig() {
-  return config_->GetReference();
-}
-
-bool Audio::StartPlayback() {
-  if (playing())
-    return true;
-  SetStartPlaybackState();
-  return audio_->StartPlayback();
-}
-
-bool Audio::StopPlayback() {
-  if (!playing())
-    return true;
-  if (!audio_->StopPlayback())
-    return false;
-  SetStopPlaybackState();
-  return true;
-}
-
-int32_t Audio::Open(PluginDelegate* plugin_delegate,
-                    PP_Resource config_id,
-                    PP_CompletionCallback create_callback) {
-  DCHECK(!audio_);
-  config_ = Resource::GetAs<AudioConfig>(config_id);
-  if (!config_)
-    return PP_ERROR_BADRESOURCE;
-
-  // When the stream is created, we'll get called back on StreamCreated().
-  audio_ = plugin_delegate->CreateAudio(config_->sample_rate(),
-                                        config_->sample_frame_count(),
-                                        this);
-  if (!audio_)
-    return PP_ERROR_FAILED;
-
-  // At this point, we are guaranteeing ownership of the completion
-  // callback.  Audio promises to fire the completion callback
-  // once and only once.
-  create_callback_ = create_callback;
-  create_callback_pending_ = true;
-  return PP_ERROR_WOULDBLOCK;
-}
-
-int32_t Audio::GetSyncSocket(int* sync_socket) {
-  if (socket_for_create_callback_.get()) {
-#if defined(OS_POSIX)
-    *sync_socket = socket_for_create_callback_->handle();
-#elif defined(OS_WIN)
-    *sync_socket = reinterpret_cast<int>(socket_for_create_callback_->handle());
-#else
-    #error "Platform not supported."
-#endif
-    return PP_OK;
-  }
-  return PP_ERROR_FAILED;
-}
-
-int32_t Audio::GetSharedMemory(int* shm_handle, uint32_t* shm_size) {
-  if (shared_memory_for_create_callback_.get()) {
-#if defined(OS_POSIX)
-    *shm_handle = shared_memory_for_create_callback_->handle().fd;
-#elif defined(OS_WIN)
-    *shm_handle = reinterpret_cast<int>(
-        shared_memory_for_create_callback_->handle());
-#else
-    #error "Platform not supported."
-#endif
-    *shm_size = shared_memory_size_for_create_callback_;
-    return PP_OK;
-  }
-  return PP_ERROR_FAILED;
-}
-
-void Audio::StreamCreated(base::SharedMemoryHandle shared_memory_handle,
-                          size_t shared_memory_size,
-                          base::SyncSocket::Handle socket_handle) {
-  if (create_callback_pending_) {
-    // Trusted side of proxy can specify a callback to recieve handles. In
-    // this case we don't need to map any data or start the thread since it
-    // will be handled by the proxy.
-    shared_memory_for_create_callback_.reset(
-        new base::SharedMemory(shared_memory_handle, false));
-    shared_memory_size_for_create_callback_ = shared_memory_size;
-    socket_for_create_callback_.reset(new base::SyncSocket(socket_handle));
-
-    PP_RunCompletionCallback(&create_callback_, 0);
-    create_callback_pending_ = false;
-
-    // It might be nice to close the handles here to free up some system
-    // resources, but we can't since there's a race condition. The handles must
-    // be valid until they're sent over IPC, which is done from the I/O thread
-    // which will often get done after this code executes. We could do
-    // something more elaborate like an ACK from the plugin or post a task to
-    // the I/O thread and back, but this extra complexity doesn't seem worth it
-    // just to clean up these handles faster.
-  } else {
-    SetStreamInfo(shared_memory_handle, shared_memory_size, socket_handle);
-  }
-}
-
-}  // namespace pepper