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

Unified Diff: ppapi/cpp/dev/video_capture_dev.cc

Issue 9965080: Change the cpp wrappers of audio input/video capture to use CompletionCallbackWithOutput. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Avoid extra copies in Dispatcher*::operator(). Created 8 years, 9 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 side-by-side diff with in-line comments
Download patch
Index: ppapi/cpp/dev/video_capture_dev.cc
diff --git a/ppapi/cpp/dev/video_capture_dev.cc b/ppapi/cpp/dev/video_capture_dev.cc
index 94ed933fec77a4e21f42d99bb1a7879899a7c74e..223f67fed311eba30fd7a9c752f9ef1565f204b0 100644
--- a/ppapi/cpp/dev/video_capture_dev.cc
+++ b/ppapi/cpp/dev/video_capture_dev.cc
@@ -6,10 +6,9 @@
#include "ppapi/c/dev/ppb_video_capture_dev.h"
#include "ppapi/c/pp_errors.h"
-#include "ppapi/cpp/completion_callback.h"
-#include "ppapi/cpp/dev/device_ref_dev.h"
#include "ppapi/cpp/dev/resource_array_dev.h"
#include "ppapi/cpp/instance_handle.h"
+#include "ppapi/cpp/logging.h"
#include "ppapi/cpp/module.h"
#include "ppapi/cpp/module_impl.h"
@@ -27,25 +26,8 @@ template <> const char* interface_name<PPB_VideoCapture_Dev_0_1>() {
} // namespace
-struct VideoCapture_Dev::EnumerateDevicesState {
- EnumerateDevicesState(std::vector<DeviceRef_Dev>* in_devices,
- const CompletionCallback& in_callback,
- VideoCapture_Dev* in_video_capture)
- : devices_resource(0),
- devices(in_devices),
- callback(in_callback),
- video_capture(in_video_capture) {
- }
-
- PP_Resource devices_resource;
- std::vector<DeviceRef_Dev>* devices;
- CompletionCallback callback;
- VideoCapture_Dev* video_capture;
-};
-
VideoCapture_Dev::VideoCapture_Dev(const InstanceHandle& instance)
- : enum_state_(NULL),
- requested_info_(),
+ : requested_info_(),
buffer_count_(0) {
if (has_interface<PPB_VideoCapture_Dev_0_2>()) {
PassRefFromConstructor(get_interface<PPB_VideoCapture_Dev_0_2>()->Create(
@@ -58,30 +40,11 @@ VideoCapture_Dev::VideoCapture_Dev(const InstanceHandle& instance)
VideoCapture_Dev::VideoCapture_Dev(PP_Resource resource)
: Resource(resource),
- enum_state_(NULL),
requested_info_(),
buffer_count_(0) {
}
-VideoCapture_Dev::VideoCapture_Dev(const VideoCapture_Dev& other)
- : Resource(other),
- enum_state_(NULL),
- requested_info_(other.requested_info_),
- buffer_count_(other.buffer_count_) {
-}
-
VideoCapture_Dev::~VideoCapture_Dev() {
- AbortEnumerateDevices();
-}
-
-VideoCapture_Dev& VideoCapture_Dev::operator=(
- const VideoCapture_Dev& other) {
- AbortEnumerateDevices();
-
- Resource::operator=(other);
- requested_info_ = other.requested_info_;
- buffer_count_ = other.buffer_count_;
- return *this;
}
// static
@@ -90,23 +53,22 @@ bool VideoCapture_Dev::IsAvailable() {
has_interface<PPB_VideoCapture_Dev_0_1>();
}
-int32_t VideoCapture_Dev::EnumerateDevices(std::vector<DeviceRef_Dev>* devices,
- const CompletionCallback& callback) {
+int32_t VideoCapture_Dev::EnumerateDevices(
+ const CompletionCallbackWithOutput<std::vector<DeviceRef_Dev> >& callback) {
if (!has_interface<PPB_VideoCapture_Dev_0_2>())
return callback.MayForce(PP_ERROR_NOINTERFACE);
- if (!devices)
- return callback.MayForce(PP_ERROR_BADARGUMENT);
if (!callback.pp_completion_callback().func)
return callback.MayForce(PP_ERROR_BLOCKS_MAIN_THREAD);
- if (enum_state_)
- return callback.MayForce(PP_ERROR_INPROGRESS);
- // It will be deleted in OnEnumerateDevicesComplete().
- enum_state_ = new EnumerateDevicesState(devices, callback, this);
+ // CallbackConverter is responsible to delete it.
+ EnumerateCallbackData0_2* data = new EnumerateCallbackData0_2;
+ data->devices = 0;
+ data->output = callback.output();
+ data->original_callback = callback.pp_completion_callback();
+
return get_interface<PPB_VideoCapture_Dev_0_2>()->EnumerateDevices(
- pp_resource(), &enum_state_->devices_resource,
- PP_MakeCompletionCallback(&VideoCapture_Dev::OnEnumerateDevicesComplete,
- enum_state_));
+ pp_resource(), &data->devices,
+ PP_MakeCompletionCallback(&CallbackConverter, data));
}
int32_t VideoCapture_Dev::Open(
@@ -179,43 +141,31 @@ void VideoCapture_Dev::Close() {
get_interface<PPB_VideoCapture_Dev_0_2>()->Close(pp_resource());
}
-void VideoCapture_Dev::AbortEnumerateDevices() {
- if (enum_state_) {
- enum_state_->devices = NULL;
- Module::Get()->core()->CallOnMainThread(0, enum_state_->callback,
- PP_ERROR_ABORTED);
- enum_state_->video_capture = NULL;
- enum_state_ = NULL;
- }
-}
// static
-void VideoCapture_Dev::OnEnumerateDevicesComplete(void* user_data,
- int32_t result) {
- EnumerateDevicesState* enum_state =
- static_cast<EnumerateDevicesState*>(user_data);
-
- bool need_to_callback = !!enum_state->video_capture;
-
- if (result == PP_OK) {
- // It will take care of releasing the reference.
- ResourceArray_Dev resources(pp::PASS_REF, enum_state->devices_resource);
-
- if (need_to_callback) {
- enum_state->devices->clear();
- for (uint32_t index = 0; index < resources.size(); ++index) {
- DeviceRef_Dev device(resources[index]);
- enum_state->devices->push_back(device);
- }
+void VideoCapture_Dev::CallbackConverter(void* user_data, int32_t result) {
+ EnumerateCallbackData0_2* data =
+ static_cast<EnumerateCallbackData0_2*>(user_data);
+
+ // data->devices should remain 0 if the call to EnumerateDevices failed.
+ ResourceArray_Dev resources(PASS_REF, data->devices);
+ PP_DCHECK(resources.is_null() || result == PP_OK);
+
+ // Need to issue the "GetDataBuffer" even for error cases and when the number
+ // of items is 0.
+ PP_Resource* output_buf = static_cast<PP_Resource*>(
+ data->output.GetDataBuffer(
+ data->output.user_data, resources.is_null() ? 0 : resources.size(),
+ sizeof(PP_Resource)));
+ if (output_buf) {
+ for (uint32_t index = 0; index < resources.size(); ++index) {
+ output_buf[index] = resources[index];
+ Module::Get()->core()->AddRefResource(output_buf[index]);
}
}
- if (need_to_callback) {
- enum_state->video_capture->enum_state_ = NULL;
- enum_state->callback.Run(result);
- }
-
- delete enum_state;
+ PP_RunCompletionCallback(&data->original_callback, result);
+ delete data;
}
} // namespace pp

Powered by Google App Engine
This is Rietveld 408576698