| 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
|
|
|