cc: Check for completed raster tasks at interval.

cc/thread_proxy.cc

 // Copyright 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 "cc/thread_proxy.h"
 
 #include "base/auto_reset.h"
 #include "base/bind.h"
 #include "base/debug/trace_event.h"
 #include "cc/delay_based_time_source.h"
@@ skipping 11 matching lines @@
 using WebKit::WebSharedGraphicsContext3D;
 
 namespace {
 
 // Measured in seconds.
 const double contextRecreationTickRate = 0.03;
 
 // Measured in seconds.
 const double smoothnessTakesPriorityExpirationDelay = 0.25;
 
+// Measured in seconds.
+const double checkForCompletedRasterTasksDelay = 0.004;
+
 }  // namespace
 
 namespace cc {
 
 scoped_ptr<Proxy> ThreadProxy::create(LayerTreeHost* layerTreeHost, scoped_ptr<Thread> implThread)
 {
     return make_scoped_ptr(new ThreadProxy(layerTreeHost, implThread.Pass())).PassAs<Proxy>();
 }
 
 ThreadProxy::ThreadProxy(LayerTreeHost* layerTreeHost, scoped_ptr<Thread> implThread)
     : Proxy(implThread.Pass())
     , m_animateRequested(false)
     , m_commitRequested(false)
     , m_commitRequestSentToImplThread(false)
     , m_layerTreeHost(layerTreeHost)
     , m_rendererInitialized(false)
     , m_started(false)
     , m_texturesAcquired(true)
     , m_inCompositeAndReadback(false)
     , m_manageTilesPending(false)
     , m_weakFactoryOnImplThread(ALLOW_THIS_IN_INITIALIZER_LIST(this))
     , m_weakFactory(ALLOW_THIS_IN_INITIALIZER_LIST(this))
+    , m_weakCheckForCompletedRasterTasksFactory(
+        ALLOW_THIS_IN_INITIALIZER_LIST(this))
     , m_beginFrameCompletionEventOnImplThread(0)
     , m_readbackRequestOnImplThread(0)
     , m_commitCompletionEventOnImplThread(0)
     , m_completionEventForCommitHeldOnTreeActivation(0)
     , m_textureAcquisitionCompletionEventOnImplThread(0)
     , m_nextFrameIsNewlyCommittedFrameOnImplThread(false)
     , m_renderVSyncEnabled(layerTreeHost->settings().renderVSyncEnabled)
     , m_insideDraw(false)
     , m_totalCommitCount(0)
     , m_deferCommits(false)
     , m_renewTreePriorityOnImplThreadPending(false)
+    , m_checkForCompletedRasterTasksPending(false)
 {
     TRACE_EVENT0("cc", "ThreadProxy::ThreadProxy");
     DCHECK(isMainThread());
 }
 
 ThreadProxy::~ThreadProxy()
 {
     TRACE_EVENT0("cc", "ThreadProxy::~ThreadProxy");
     DCHECK(isMainThread());
     DCHECK(!m_started);
@@ skipping 273 matching lines @@
 
 void ThreadProxy::setNeedsCommitOnImplThread()
 {
     DCHECK(isImplThread());
     TRACE_EVENT0("cc", "ThreadProxy::setNeedsCommitOnImplThread");
     m_schedulerOnImplThread->setNeedsCommit();
 }
 
 void ThreadProxy::setNeedsManageTilesOnImplThread()
 {
+    DCHECK(isImplThread());
     if (m_manageTilesPending)
       return;
     Proxy::implThread()->postTask(base::Bind(&ThreadProxy::manageTilesOnImplThread, m_implThreadWeakPtr));
     m_manageTilesPending = true;
 }
 
 void ThreadProxy::manageTilesOnImplThread()
 {
+    DCHECK(isImplThread());
     // TODO(nduca): If needed, move this into CCSchedulerStateMachine.
     m_manageTilesPending = false;
     if (m_layerTreeHostImpl)
         m_layerTreeHostImpl->manageTiles();
 }
 
+void ThreadProxy::setNeedsCheckForCompletedRasterTasksOnImplThread()
+{
+     DCHECK(isImplThread());
+     if (m_checkForCompletedRasterTasksPending)
+       return;
+    Proxy::implThread()->postDelayedTask(
+        base::Bind(&ThreadProxy::checkForCompletedRasterTasksOnImplThread,
+                   m_weakCheckForCompletedRasterTasksFactory.GetWeakPtr()),
+        checkForCompletedRasterTasksDelay * 1000);
+    m_checkForCompletedRasterTasksPending = true;
+}
+
+void ThreadProxy::checkForCompletedRasterTasksOnImplThread()
+{
+    DCHECK(isImplThread());
+    m_checkForCompletedRasterTasksPending = false;
+    if (m_layerTreeHostImpl)
+        m_layerTreeHostImpl->checkForCompletedRasterTasks();
+}
+
 void ThreadProxy::setNeedsForcedCommitOnImplThread()
 {
     DCHECK(isImplThread());
     TRACE_EVENT0("cc", "ThreadProxy::setNeedsForcedCommitOnImplThread");
     m_schedulerOnImplThread->setNeedsForcedCommit();
 }
 
 void ThreadProxy::postAnimationEventsToMainThreadOnImplThread(scoped_ptr<AnimationEventsVector> events, base::Time wallClockTime)
 {
     DCHECK(isImplThread());
@@ skipping 97 matching lines @@
    m_schedulerOnImplThread->didSwapUseIncompleteTile();
 }
 
 void ThreadProxy::didUploadVisibleHighResolutionTileOnImplThread()
 {
    DCHECK(isImplThread());
    TRACE_EVENT0("cc", "ThreadProxy::didUploadVisibleHighResolutionTileOnImplThread");
    m_schedulerOnImplThread->setNeedsRedraw();
 }
 
+void ThreadProxy::didDetectIdleRasterOnImplThread()
+{
+   DCHECK(isImplThread());
+   TRACE_EVENT0("cc", "ThreadProxy::didDetectIdleRasterOnImplThread");
+
+   // Cancel pending check.
+   m_weakCheckForCompletedRasterTasksFactory.InvalidateWeakPtrs();
+   m_checkForCompletedRasterTasksPending = false;
+
+   // Perform immediate check.
+   if (m_layerTreeHostImpl)
+       m_layerTreeHostImpl->checkForCompletedRasterTasks();
+}
+
 void ThreadProxy::mainThreadHasStoppedFlinging()
 {
     if (m_inputHandlerOnImplThread)
         m_inputHandlerOnImplThread->mainThreadHasStoppedFlinging();
 }
 
 void ThreadProxy::start()
 {
     DCHECK(isMainThread());
     DCHECK(Proxy::implThread());
@@ skipping 539 matching lines @@
 
 void ThreadProxy::layerTreeHostClosedOnImplThread(CompletionEvent* completion)
 {
     TRACE_EVENT0("cc", "ThreadProxy::layerTreeHostClosedOnImplThread");
     DCHECK(isImplThread());
     m_layerTreeHost->deleteContentsTexturesOnImplThread(m_layerTreeHostImpl->resourceProvider());
     m_inputHandlerOnImplThread.reset();
     m_layerTreeHostImpl.reset();
     m_schedulerOnImplThread.reset();
     m_weakFactoryOnImplThread.InvalidateWeakPtrs();
+    m_weakCheckForCompletedRasterTasksFactory.InvalidateWeakPtrs();
     completion->signal();
 }
 
 void ThreadProxy::setFullRootLayerDamageOnImplThread()
 {
     DCHECK(isImplThread());
     m_layerTreeHostImpl->setFullRootLayerDamage();
 }
 
 size_t ThreadProxy::maxPartialTextureUpdates() const
@@ skipping 153 matching lines @@
 
 void ThreadProxy::renewTreePriorityOnImplThread()
 {
     DCHECK(m_renewTreePriorityOnImplThreadPending);
     m_renewTreePriorityOnImplThreadPending = false;
 
     renewTreePriority();
 }
 
 }  // namespace cc