Incrementally flush GrDrawTarget

src/gpu/GrDrawTarget.cpp

 
 /*
  * Copyright 2010 Google Inc.
  *
  * Use of this source code is governed by a BSD-style license that can be
  * found in the LICENSE file.
  */
 
 #include "GrDrawTarget.h"
 
@@ skipping 18 matching lines @@
 #include "batches/GrStencilPathBatch.h"
 
 #include "SkStrokeRec.h"
 
 ////////////////////////////////////////////////////////////////////////////////
 
 GrDrawTarget::GrDrawTarget(GrGpu* gpu, GrResourceProvider* resourceProvider)
     : fGpu(SkRef(gpu))
     , fResourceProvider(resourceProvider)
     , fFlushing(false)
-    , fLastFlushToken(0) {
+    , fLastFlushToken(0)
+    , fLastFlushedBatch(0) {
     // TODO: Stop extracting the context (currently needed by GrClipMaskManager)
     fContext = fGpu->getContext();
     fClipMaskManager.reset(new GrClipMaskManager(this));
 }
 
 GrDrawTarget::~GrDrawTarget() {
     fGpu->unref();
 }
 
 ////////////////////////////////////////////////////////////////////////////////
@@ skipping 54 matching lines @@
         SkDebugf("Failed to create temporary copy of destination texture.\n");
         return false;
     }
     SkIPoint dstPoint = {0, 0};
     this->copySurface(copy, rt, copyRect, dstPoint);
     dstTexture->setTexture(copy);
     dstTexture->setOffset(copyRect.fLeft, copyRect.fTop);
     return true;
 }
 
-void GrDrawTarget::flush() {
+void GrDrawTarget::flushN(int N) {
+    SkASSERT(fLastFlushedBatch + N <= fBatches.count());
     if (fFlushing) {
         return;
     }
     fFlushing = true;
 
     GrBatchFlushState flushState(fGpu, fResourceProvider, fLastFlushToken);
 
+    int flushTo = fLastFlushedBatch + N;
+
     // Loop over all batches and generate geometry
-    for (int i = 0; i < fBatches.count(); ++i) {
+    for (int i = fLastFlushedBatch; i < flushTo; ++i) {
         fBatches[i]->prepare(&flushState);
     }
 
     // Upload all data to the GPU
     flushState.preIssueDraws();
 
     // Draw all the generated geometry.
-    for (int i = 0; i < fBatches.count(); ++i) {
+    for (int i = fLastFlushedBatch; i < flushTo; ++i) {
         fBatches[i]->draw(&flushState);
     }
 
     fLastFlushToken = flushState.lastFlushedToken();
 
     fFlushing = false;
+}
+
+void GrDrawTarget::flush() {
+    this->flushN(fBatches.count() - fLastFlushedBatch);
     this->reset();
 }
 
 void GrDrawTarget::reset() {
+    fLastFlushedBatch = 0;
     fBatches.reset();
 }
 
 void GrDrawTarget::drawBatch(const GrPipelineBuilder& pipelineBuilder, GrDrawBatch* batch) {
     // Setup clip
     GrScissorState scissorState;
     GrPipelineBuilder::AutoRestoreFragmentProcessorState arfps;
     GrPipelineBuilder::AutoRestoreStencil ars;
     if (!fClipMaskManager->setupClipping(pipelineBuilder, &arfps, &ars, &scissorState,
                                          &batch->bounds())) {
@@ skipping 275 matching lines @@
             ++i;
             if (i == maxCandidates) {
                 GrBATCH_INFO("\t\tReached max lookback or beginning of batch array %d\n", i);
                 break;
             }
         }
     } else {
         GrBATCH_INFO("\t\tFirstBatch\n");
     }
     fBatches.push_back().reset(SkRef(batch));
+    if (fBatches.count() > kMaxLookback) {
+        this->flushN(1);

[bsalomon, 2015/10/02 13:56:37]

Maybe assert that we're only 1 ahead? Otherwise, lgtm.

+        fLastFlushedBatch++;
+    }
 }
 
 ///////////////////////////////////////////////////////////////////////////////
 
 bool GrDrawTarget::installPipelineInDrawBatch(const GrPipelineBuilder* pipelineBuilder,
                                               const GrScissorState* scissor,
                                               GrDrawBatch* batch) {
     GrPipeline::CreateArgs args;
     args.fPipelineBuilder = pipelineBuilder;
     args.fCaps = this->caps();
@@ skipping 11 matching lines @@
     }
 
     return true;
 }
 
 void GrDrawTarget::clearStencilClip(const SkIRect& rect, bool insideClip, GrRenderTarget* rt) {
     GrBatch* batch = new GrClearStencilClipBatch(rect, insideClip, rt);
     this->recordBatch(batch);
     batch->unref();
 }