Add non-blocking frame rate limiting logic to display list 2D canvas

Source/platform/graphics/RecordingImageBufferSurface.cpp

 // Copyright 2014 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 "config.h"
 
 #include "platform/graphics/RecordingImageBufferSurface.h"
 
 #include "platform/graphics/GraphicsContext.h"
 #include "platform/graphics/ImageBuffer.h"
+#include "public/platform/Platform.h"
 #include "third_party/skia/include/core/SkCanvas.h"
 #include "third_party/skia/include/core/SkPictureRecorder.h"
 #include "wtf/PassOwnPtr.h"
 #include "wtf/PassRefPtr.h"
 
 namespace blink {
 
 RecordingImageBufferSurface::RecordingImageBufferSurface(const IntSize& size, OpacityMode opacityMode)
     : ImageBufferSurface(size, opacityMode)
     , m_graphicsContext(0)
     , m_initialSaveCount(0)
     , m_frameWasCleared(true)
-    , m_surfaceUsedSincePreviousFrameWasPresented(false)
+    , m_recordedSinceLastFrameWasFinalized(false)
 {
     initializeCurrentFrame();
 }
 
 RecordingImageBufferSurface::~RecordingImageBufferSurface()
-{ }
+{
+    if (m_recordedSinceLastFrameWasFinalized) {
+        blink::Platform::current()->currentThread()->removeTaskObserver(this);
+    }
+}
 
 void RecordingImageBufferSurface::initializeCurrentFrame()
 {
     static SkRTreeFactory rTreeFactory;
     m_currentFrame = adoptPtr(new SkPictureRecorder);
     m_currentFrame->beginRecording(size().width(), size().height(), &rTreeFactory);
     m_initialSaveCount = m_currentFrame->getRecordingCanvas()->getSaveCount();
     if (m_graphicsContext) {
         m_graphicsContext->resetCanvas(m_currentFrame->getRecordingCanvas());
         m_graphicsContext->setRegionTrackingMode(GraphicsContext::RegionTrackingOverwrite);
@@ skipping 43 matching lines @@
 {
     if (m_rasterCanvas)
         return m_rasterCanvas.get();
 
     ASSERT(m_currentFrame->getRecordingCanvas());
     return m_currentFrame->getRecordingCanvas();
 }
 
 PassRefPtr<SkPicture> RecordingImageBufferSurface::getPicture()
 {
-    if (handleOpaqueFrame()) {
-        m_surfaceUsedSincePreviousFrameWasPresented = false;
+    if (finalizeFrame()) {
         return m_previousFrame;
     }
 
     if (!m_rasterCanvas)
         fallBackToRasterCanvas();
     return nullptr;
 }
 
-void RecordingImageBufferSurface::willUse()
+void RecordingImageBufferSurface::didDraw()
 {
-    m_surfaceUsedSincePreviousFrameWasPresented = true;
+    if (!m_recordedSinceLastFrameWasFinalized && m_currentFrame) {
+        m_recordedSinceLastFrameWasFinalized = true;
+        blink::Platform::current()->currentThread()->addTaskObserver(this);
+    }
+}
+
+void RecordingImageBufferSurface::willProcessTask()
+{
+}
+
+void RecordingImageBufferSurface::didProcessTask()
+{
+    ASSERT(m_recordedSinceLastFrameWasFinalized);
+    // This is to insert a frame barrier at the end of each script execution
+    // task that touches the canvas. finalizeFrame() will discard the previous
+    // frame and replace it with the current frame even if it has not been
+    // consumed, thus allowing the renderer to skip ahead to the most recently
+    // recorded frame.
+    if (!finalizeFrame()) {
+        ASSERT(!m_rasterCanvas);
+        fallBackToRasterCanvas();
+    }
 }
 
 void RecordingImageBufferSurface::didClearCanvas()
 {
     m_frameWasCleared = true;
 }
 
-bool RecordingImageBufferSurface::handleOpaqueFrame()
+bool RecordingImageBufferSurface::finalizeFrame()
 {
-    if (!m_currentFrame)
+    if (!m_currentFrame) {
+        ASSERT(!m_recordedSinceLastFrameWasFinalized);
         return false;
+    }
+
+    bool canvasHasChanged = m_recordedSinceLastFrameWasFinalized;
+    if (m_recordedSinceLastFrameWasFinalized) {
+        blink::Platform::current()->currentThread()->removeTaskObserver(this);
+        m_recordedSinceLastFrameWasFinalized = false;
+    }
+
     IntRect canvasRect(IntPoint(0, 0), size());
     if (!m_frameWasCleared && !m_graphicsContext->opaqueRegion().asRect().contains(canvasRect)) {
         // No clear happened. If absolutely nothing was drawn, then we can just continue to use the previous frame.
-        return !m_surfaceUsedSincePreviousFrameWasPresented;
+        return !canvasHasChanged;
     }
 
     SkCanvas* oldCanvas = m_currentFrame->getRecordingCanvas(); // Could be raster or picture
 
     // FIXME(crbug.com/392614): handle transferring complex state from the current picture to the new one.
     if (oldCanvas->getSaveCount() > m_initialSaveCount)
         return false;
 
     if (!oldCanvas->isClipRect())
         return false;
 
     SkMatrix ctm = oldCanvas->getTotalMatrix();
     SkRect clip;
     oldCanvas->getClipBounds(&clip);
 
     m_previousFrame = adoptRef(m_currentFrame->endRecording());
     initializeCurrentFrame();
 
     SkCanvas* newCanvas = m_currentFrame->getRecordingCanvas();
     newCanvas->concat(ctm);
     newCanvas->clipRect(clip);
 
     m_frameWasCleared = false;
     return true;
 }
 
 } // namespace blink