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)
@@ skipping 13 matching lines @@
     , 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 287 matching lines @@
 }
 
 void ThreadProxy::manageTilesOnImplThread()
 {
     // TODO(nduca): If needed, move this into CCSchedulerStateMachine.
     m_manageTilesPending = false;
     if (m_layerTreeHostImpl)
         m_layerTreeHostImpl->manageTiles();
 }
 
+void ThreadProxy::setNeedsCheckForCompletedRasterTasksOnImplThread()
+{

[brianderson, 2013/02/12 01:44:31]

DCHECK(isImplThread())?

[reveman, 2013/02/12 02:29:52]

Sure. I'll add that to setNeedsManageTilesOnImplThread() above too.

+     if (m_checkForCompletedRasterTasksPending)
+       return;
+    Proxy::implThread()->postDelayedTask(
+        base::Bind(&ThreadProxy::checkForCompletedRasterTasksOnImplThread,
+                   m_weakFactoryOnImplThread.GetWeakPtr()),
+        checkForCompletedRasterTasksDelay * 1000);
+    m_checkForCompletedRasterTasksPending = true;
+}
+
+void ThreadProxy::checkForCompletedRasterTasksOnImplThread()
+{

[brianderson, 2013/02/12 01:44:31]

DCHECK(isImplThread())?

[reveman, 2013/02/12 02:29:52]

Done.

+    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 806 matching lines @@
 
 void ThreadProxy::renewTreePriorityOnImplThread()
 {
     DCHECK(m_renewTreePriorityOnImplThreadPending);
     m_renewTreePriorityOnImplThreadPending = false;
 
     renewTreePriority();
 }
 
 }  // namespace cc