WIP GPU scheduler + delayed activation / tile draw

gpu/command_buffer/service/command_executor.h

 // 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.
 
 #ifndef GPU_COMMAND_BUFFER_SERVICE_COMMAND_EXECUTOR_H_
 #define GPU_COMMAND_BUFFER_SERVICE_COMMAND_EXECUTOR_H_
 
 #include <stdint.h>
 
 #include <memory>
 #include <queue>
 
-#include "base/atomic_ref_count.h"
-#include "base/atomicops.h"
 #include "base/callback.h"
 #include "base/macros.h"
-#include "base/memory/ref_counted.h"
 #include "base/memory/shared_memory.h"
 #include "base/memory/weak_ptr.h"
 #include "gpu/command_buffer/service/cmd_buffer_engine.h"
 #include "gpu/command_buffer/service/cmd_parser.h"
 #include "gpu/command_buffer/service/command_buffer_service.h"
 #include "gpu/command_buffer/service/gles2_cmd_decoder.h"
 #include "gpu/gpu_export.h"
 
 namespace gpu {
 
-class PreemptionFlag : public base::RefCountedThreadSafe<PreemptionFlag> {
- public:
-  PreemptionFlag() : flag_(0) {}
-
-  bool IsSet() { return !base::AtomicRefCountIsZero(&flag_); }
-  void Set() { base::AtomicRefCountInc(&flag_); }
-  void Reset() { base::subtle::NoBarrier_Store(&flag_, 0); }
-
- private:
-  base::AtomicRefCount flag_;
-
-  ~PreemptionFlag() {}
-
-  friend class base::RefCountedThreadSafe<PreemptionFlag>;
-};
-
 // This class schedules commands that have been flushed. They are received via
 // a command buffer and forwarded to a command parser. TODO(apatrick): This
 // class should not know about the decoder. Do not add additional dependencies
 // on it.
 class GPU_EXPORT CommandExecutor
     : NON_EXPORTED_BASE(public CommandBufferEngine),
       public base::SupportsWeakPtr<CommandExecutor> {
  public:
   CommandExecutor(CommandBufferServiceBase* command_buffer,
                   AsyncAPIInterface* handler,
                   gles2::GLES2Decoder* decoder);
 
   ~CommandExecutor() override;
 
   void PutChanged();
 
-  void SetPreemptByFlag(scoped_refptr<PreemptionFlag> flag) {
-    preemption_flag_ = flag;
-  }
+  // This callback is checked regularly and execution is stopped if it returns
+  // true.
+  typedef base::Callback<bool(void)> PreemptionCallback;
+  void SetPreemptionCallback(const PreemptionCallback& callback);
 
   // Sets whether commands should be processed by this scheduler. Setting to
   // false unschedules. Setting to true reschedules.
   void SetScheduled(bool scheduled);
 
   bool scheduled() const { return scheduled_; }
 
   // Returns whether the scheduler needs to be polled again in the future to
   // process pending queries.
   bool HasPendingQueries() const;
@@ skipping 42 matching lines @@
   // reason for context lost.
   gles2::GLES2Decoder* decoder_;
 
   // TODO(apatrick): The CommandExecutor currently creates and owns the parser.
   // This should be an argument to the constructor.
   std::unique_ptr<CommandParser> parser_;
 
   // Whether the scheduler is currently able to process more commands.
   bool scheduled_;
 
+  PreemptionCallback preemption_callback_;
+
   base::Closure command_processed_callback_;
 
-  // If non-NULL and |preemption_flag_->IsSet()|, exit PutChanged early.
-  scoped_refptr<PreemptionFlag> preemption_flag_;
   bool was_preempted_;
 
   DISALLOW_COPY_AND_ASSIGN(CommandExecutor);
 };
 
 }  // namespace gpu
 
 #endif  // GPU_COMMAND_BUFFER_SERVICE_COMMAND_EXECUTOR_H_