Add AsyncFlush when transferbuffer is > a certain size

gpu/command_buffer/client/transfer_buffer.cc

 // Copyright (c) 2012 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.
 
 // A class to Manage a growing transfer buffer.
 
 #include "../client/transfer_buffer.h"
 #include "../client/cmd_buffer_helper.h"
 
 namespace gpu {
 
 AlignedRingBuffer::~AlignedRingBuffer() {
 }
 
 TransferBuffer::TransferBuffer(
     CommandBufferHelper* helper)
     : helper_(helper),
       result_size_(0),
       min_buffer_size_(0),
       max_buffer_size_(0),
-      alignment_(),
+      alignment_(0),
+      size_to_flush_(0),
+      bytes_since_last_flush_(0),
       buffer_id_(-1),
       result_buffer_(NULL),
       result_shm_offset_(0),
       usable_(true) {
 }
 
 TransferBuffer::~TransferBuffer() {
   Free();
 }
 
 bool TransferBuffer::Initialize(
     unsigned int starting_buffer_size,
     unsigned int result_size,
     unsigned int min_buffer_size,
     unsigned int max_buffer_size,
-    unsigned int alignment) {
+    unsigned int alignment,
+    unsigned int size_to_flush) {
   result_size_ = result_size;
   min_buffer_size_ = min_buffer_size;
   max_buffer_size_ = max_buffer_size;
   alignment_ = alignment;
+  size_to_flush_ = size_to_flush;
   ReallocateRingBuffer(starting_buffer_size - result_size);
   return HaveBuffer();
 }
 
 void TransferBuffer::Free() {
   if (HaveBuffer()) {
     helper_->Finish();
     helper_->command_buffer()->DestroyTransferBuffer(buffer_id_);
     buffer_id_ = -1;
     buffer_.ptr = NULL;
     buffer_.size = 0;
     result_buffer_ = NULL;
     result_shm_offset_ = 0;
     ring_buffer_.reset();
+    bytes_since_last_flush_ = 0;
   }
 }
 
 bool TransferBuffer::HaveBuffer() const {
   return buffer_id_ != -1;
 }
 
 RingBuffer::Offset TransferBuffer::GetOffset(void* pointer) const {
   return ring_buffer_->GetOffset(pointer);
 }
 
 void TransferBuffer::FreePendingToken(void* p, unsigned int token) {
   ring_buffer_->FreePendingToken(p, token);
+  if (bytes_since_last_flush_ >= size_to_flush_ && size_to_flush_ > 0) {
+    helper_->Flush();
+    bytes_since_last_flush_ = 0;
+  }
 }
 
 void TransferBuffer::AllocateRingBuffer(unsigned int size) {
   for (;size >= min_buffer_size_; size /= 2) {
     int32 id = helper_->command_buffer()->CreateTransferBuffer(size, -1);
     if (id != -1) {
       buffer_ = helper_->command_buffer()->GetTransferBuffer(id);
       ring_buffer_.reset(new AlignedRingBuffer(
           alignment_,
           id,
@@ skipping 63 matching lines @@
   GPU_DCHECK(size_allocated);
 
   ReallocateRingBuffer(size);
 
   if (!HaveBuffer()) {
     return NULL;
   }
 
   unsigned int max_size = ring_buffer_->GetLargestFreeOrPendingSize();
   *size_allocated = std::min(max_size, size);
+  bytes_since_last_flush_ += *size_allocated;
   return ring_buffer_->Alloc(*size_allocated);
 }
 
 void* TransferBuffer::Alloc(unsigned int size) {
   ReallocateRingBuffer(size);
 
   if (!HaveBuffer()) {
     return NULL;
   }
 
   unsigned int max_size = ring_buffer_->GetLargestFreeOrPendingSize();
   if (size > max_size) {
     return NULL;
   }
 
+  bytes_since_last_flush_ += size;
   return ring_buffer_->Alloc(size);
 }
 
 void* TransferBuffer::GetResultBuffer() {
   ReallocateRingBuffer(result_size_);
   return result_buffer_;
 }
 
 int TransferBuffer::GetResultOffset() {
   ReallocateRingBuffer(result_size_);
@@ skipping 25 matching lines @@
   Release();
   // NOTE: we allocate buffers of size 0 so that HaveBuffer will be true, so
   // that address will return a pointer just like malloc, and so that GetShmId
   // will be valid. That has the side effect that we'll insert a token on free.
   // We could add code skip the token for a zero size buffer but it doesn't seem
   // worth the complication.
   buffer_ = transfer_buffer_->AllocUpTo(new_size, &size_);
 }
 
 }  // namespace gpu