15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2012 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "ppapi/shared_impl/tracked_callback.h" 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/bind.h" 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/compiler_specific.h" 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/logging.h" 109ab5563a3196760eb381d102cbb2bc0f7abc6a50Ben Murdoch#include "base/message_loop/message_loop.h" 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/synchronization/lock.h" 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "ppapi/c/pp_completion_callback.h" 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "ppapi/c/pp_errors.h" 142a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "ppapi/c/ppb_message_loop.h" 155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "ppapi/shared_impl/callback_tracker.h" 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "ppapi/shared_impl/ppapi_globals.h" 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "ppapi/shared_impl/ppb_message_loop_shared.h" 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "ppapi/shared_impl/proxy_lock.h" 195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "ppapi/shared_impl/resource.h" 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace ppapi { 225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace { 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool IsMainThread() { 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) PpapiGlobals::Get()->GetMainThreadMessageLoop()->BelongsToCurrentThread(); 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 304311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdochint32_t RunCompletionTask(TrackedCallback::CompletionTask completion_task, 314311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch int32_t result) { 324311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch int32_t task_result = completion_task.Run(result); 334311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch if (result != PP_ERROR_ABORTED) 344311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch result = task_result; 354311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch return result; 364311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch} 374311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// TrackedCallback ------------------------------------------------------------- 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Note: don't keep a Resource* since it may go out of scope before us. 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)TrackedCallback::TrackedCallback( 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Resource* resource, 455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const PP_CompletionCallback& callback) 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) : is_scheduled_(false), 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) resource_id_(resource ? resource->pp_resource() : 0), 485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) completed_(false), 495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) aborted_(false), 505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) callback_(callback), 515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) target_loop_(PpapiGlobals::Get()->GetCurrentMessageLoop()), 525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) result_for_blocked_callback_(PP_OK) { 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Note that target_loop_ may be NULL at this point, if the plugin has not 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // attached a loop to this thread, or if this is an in-process plugin. 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The Enter class should handle checking this for us. 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(dmichael): Add tracking at the instance level, for callbacks that only 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // have an instance (e.g. for MouseLock). 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (resource) { 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) tracker_ = PpapiGlobals::Get()->GetCallbackTrackerForInstance( 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) resource->pp_instance()); 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) tracker_->Add(make_scoped_refptr(this)); 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Lock* proxy_lock = PpapiGlobals::Get()->GetProxyLock(); 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (proxy_lock) { 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If the proxy_lock is valid, we're running out-of-process, and locking 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // is enabled. 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (is_blocking()) { 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // This is a blocking completion callback, so we will need a condition 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // variable for blocking & signalling the calling thread. 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) operation_completed_condvar_.reset( 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) new base::ConditionVariable(proxy_lock)); 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // It's a non-blocking callback, so we should have a MessageLoopResource 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // to dispatch to. Note that we don't error check here, though. Later, 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // EnterResource::SetResult will check to make sure the callback is valid 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // and take appropriate action. 795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)TrackedCallback::~TrackedCallback() { 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TrackedCallback::Abort() { 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Run(PP_ERROR_ABORTED); 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TrackedCallback::PostAbort() { 915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) PostRun(PP_ERROR_ABORTED); 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TrackedCallback::Run(int32_t result) { 955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Only allow the callback to be run once. Note that this also covers the case 965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // where the callback was previously Aborted because its associated Resource 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // went away. The callback may live on for a while because of a reference from 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // a Closure. But when the Closure runs, Run() quietly does nothing, and the 995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // callback will go away when all referring Closures go away. 1005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (completed()) 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return; 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result == PP_ERROR_ABORTED) 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) aborted_ = true; 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Note that this call of Run() may have been scheduled prior to Abort() or 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // PostAbort() being called. If we have been told to Abort, that always 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // trumps a result that was scheduled before, so we should make sure to pass 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // PP_ERROR_ABORTED. 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (aborted()) 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) result = PP_ERROR_ABORTED; 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (is_blocking()) { 1135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If the condition variable is invalid, there are two possibilities. One, 1145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // we're running in-process, in which case the call should have come in on 1155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // the main thread and we should have returned PP_ERROR_BLOCKS_MAIN_THREAD 1165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // well before this. Otherwise, this callback was not created as a 1175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // blocking callback. Either way, there's some internal error. 1185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!operation_completed_condvar_.get()) { 1195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 1205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return; 1215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) result_for_blocked_callback_ = result; 1235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Retain ourselves, since MarkAsCompleted will remove us from the 1245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // tracker. Then MarkAsCompleted before waking up the blocked thread, 1255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // which could potentially re-enter. 1265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scoped_refptr<TrackedCallback> thiz(this); 1275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) MarkAsCompleted(); 1285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Wake up the blocked thread. See BlockUntilComplete for where the thread 1295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Wait()s. 1305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) operation_completed_condvar_->Signal(); 1315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 1325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If there's a target_loop_, and we're not on the right thread, we need to 1335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // post to target_loop_. 134868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) if (target_loop_.get() && 135868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) target_loop_.get() != PpapiGlobals::Get()->GetCurrentMessageLoop()) { 1365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) PostRun(result); 1375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return; 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1394311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch 1404311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch // Copy callback fields now, since |MarkAsCompleted()| may delete us. 1415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) PP_CompletionCallback callback = callback_; 1424311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch CompletionTask completion_task = completion_task_; 1434311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch completion_task_.Reset(); 1444311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch // Do this before running the callback in case of reentrancy from running 1454311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch // the completion task. 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) MarkAsCompleted(); 1474311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch 1484311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch if (!completion_task.is_null()) 1494311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch result = RunCompletionTask(completion_task, result); 1504311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch 1515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(dmichael): Associate a message loop with the callback; if it's not 1525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // the same as the current thread's loop, then post it to the right loop. 1535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CallWhileUnlocked(PP_RunCompletionCallback, &callback, result); 1545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TrackedCallback::PostRun(int32_t result) { 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (completed()) { 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return; 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (result == PP_ERROR_ABORTED) 1635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) aborted_ = true; 1645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We might abort when there's already a scheduled callback, but callers 1655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // should never try to PostRun more than once otherwise. 1665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(result == PP_ERROR_ABORTED || !is_scheduled_); 1675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::Closure callback_closure( 1695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) RunWhileLocked(base::Bind(&TrackedCallback::Run, this, result))); 170868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) if (!target_loop_.get()) { 1715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We must be running in-process and on the main thread (the Enter 1725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // classes protect against having a null target_loop_ otherwise). 1735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(IsMainThread()); 1745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(PpapiGlobals::Get()->IsHostGlobals()); 175c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) base::MessageLoop::current()->PostTask(FROM_HERE, callback_closure); 1765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 1775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) target_loop_->PostClosure(FROM_HERE, callback_closure, 0); 1785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) is_scheduled_ = true; 1805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1824311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdochvoid TrackedCallback::set_completion_task( 1834311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch const CompletionTask& completion_task) { 1844311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch DCHECK(completion_task_.is_null()); 1854311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch completion_task_ = completion_task; 1864311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch} 1874311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch 1885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// static 1895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool TrackedCallback::IsPending( 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const scoped_refptr<TrackedCallback>& callback) { 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!callback.get()) 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 193fb250657ef40d7500f20882d5c9909c1013367d3Ben Murdoch if (callback->aborted()) 194fb250657ef40d7500f20882d5c9909c1013367d3Ben Murdoch return false; 1955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return !callback->completed(); 1965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 198558790d6acca3451cf3a6b497803a5f07d0bec58Ben Murdoch// static 199558790d6acca3451cf3a6b497803a5f07d0bec58Ben Murdochbool TrackedCallback::IsScheduledToRun( 200558790d6acca3451cf3a6b497803a5f07d0bec58Ben Murdoch const scoped_refptr<TrackedCallback>& callback) { 201558790d6acca3451cf3a6b497803a5f07d0bec58Ben Murdoch return IsPending(callback) && callback->is_scheduled_; 202558790d6acca3451cf3a6b497803a5f07d0bec58Ben Murdoch} 203558790d6acca3451cf3a6b497803a5f07d0bec58Ben Murdoch 2045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)int32_t TrackedCallback::BlockUntilComplete() { 2055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Note, we are already holding the proxy lock in all these methods, including 2065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // this one (see ppapi/thunk/enter.cc for where it gets acquired). 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // It doesn't make sense to wait on a non-blocking callback. Furthermore, 2095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // BlockUntilComplete should never be called for in-process plugins, where 2105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // blocking callbacks are not supported. 2115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CHECK(operation_completed_condvar_.get()); 2125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!is_blocking() || !operation_completed_condvar_.get()) { 2135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NOTREACHED(); 2145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return PP_ERROR_FAILED; 2155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) while (!completed()) 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) operation_completed_condvar_->Wait(); 2194311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch 2204311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch if (!completion_task_.is_null()) { 2214311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch result_for_blocked_callback_ = 2224311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch RunCompletionTask(completion_task_, result_for_blocked_callback_); 2234311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch completion_task_.Reset(); 2244311e82a78ceafbe0585f51d4c8a86df9f21aa0dBen Murdoch } 2255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return result_for_blocked_callback_; 2265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void TrackedCallback::MarkAsCompleted() { 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!completed()); 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We will be removed; maintain a reference to ensure we won't be deleted 2325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // until we're done. 2335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scoped_refptr<TrackedCallback> thiz = this; 2345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) completed_ = true; 2355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We may not have a valid resource, in which case we're not in the tracker. 2365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (resource_id_) 2375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) tracker_->Remove(thiz); 2385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) tracker_ = NULL; 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace ppapi 242