blob: f353d536e2d60319897f50b114a1efec57ab0c36 [file] [log] [blame]
// Copyright (c) 2011 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 "ppapi/c/pp_errors.h"
#include "ppapi/c/private/ppb_testing_private.h"
#include "ppapi/native_client/tests/ppapi_test_lib/get_browser_interface.h"
#include "ppapi/native_client/tests/ppapi_test_lib/testable_callback.h"
TestableCallback::TestableCallback(PP_Instance instance, bool force_async)
: have_result_(false),
result_(PP_OK_COMPLETIONPENDING),
force_async_(force_async),
post_quit_task_(false),
run_count_(0),
instance_(instance) {
}
int32_t TestableCallback::WaitForResult() {
if (!have_result_) {
result_ = PP_OK_COMPLETIONPENDING; // Reset
post_quit_task_ = true;
// This waits until PPBTestingDev()->QuitMessageLoop() is called
// by the "Handler" which represents the actual callback code.
PPBTestingPrivate()->RunMessageLoop(instance_);
}
have_result_ = false;
return result_;
}
PP_CompletionCallback TestableCallback::GetCallback() {
int32_t flags = force_async_ ? 0 : PP_COMPLETIONCALLBACK_FLAG_OPTIONAL;
PP_CompletionCallback cc =
PP_MakeCompletionCallback(&TestableCallback::Handler, this);
cc.flags = flags;
return cc;
}
// static, so we can take it's address
// This is the actual callback, all it does is record
// the result and wake up whoever is block on
// "WaitForResult"
void TestableCallback::Handler(void* user_data, int32_t result) {
TestableCallback* callback = static_cast<TestableCallback*>(user_data);
callback->result_ = result;
callback->have_result_ = true;
++callback->run_count_;
if (callback->post_quit_task_) {
callback->post_quit_task_ = false;
PPBTestingPrivate()->QuitMessageLoop(callback->instance_);
}
}