content/renderer/gpu/queue_message_swap_promise.cc

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "content/renderer/gpu/queue_message_swap_promise.h"
   6
   7 #include "content/renderer/gpu/frame_swap_message_queue.h"
   8 #include "ipc/ipc_sync_message_filter.h"
   9
  10 namespace content {
  11
  12 QueueMessageSwapPromise::QueueMessageSwapPromise(
  13     scoped_refptr<IPC::SyncMessageFilter> message_sender,
  14     scoped_refptr<content::FrameSwapMessageQueue> message_queue,
  15     int source_frame_number)
  16     : message_sender_(message_sender),
  17       message_queue_(message_queue),
  18       source_frame_number_(source_frame_number)
  19 #if DCHECK_IS_ON()
  20       ,
  21       completed_(false)
  22 #endif
  23 {
  24   DCHECK(message_sender_.get());
  25   DCHECK(message_queue_.get());
  26 }
  27
  28 QueueMessageSwapPromise::~QueueMessageSwapPromise() {
  29   // The promise should have either been kept or broken before it's deleted.
  30 #if DCHECK_IS_ON()
  31   DCHECK(completed_);
  32 #endif
  33 }
  34
  35 void QueueMessageSwapPromise::DidSwap(cc::CompositorFrameMetadata* metadata) {
  36 #if DCHECK_IS_ON()
  37   DCHECK(!completed_);
  38 #endif
  39   message_queue_->DidSwap(source_frame_number_);
  40   // The OutputSurface will take care of the Drain+Send.
  41   PromiseCompleted();
  42 }
  43
  44 void QueueMessageSwapPromise::DidNotSwap(DidNotSwapReason reason) {
  45 #if DCHECK_IS_ON()
  46   DCHECK(!completed_);
  47 #endif
  48   ScopedVector<IPC::Message> messages;
  49   message_queue_->DidNotSwap(source_frame_number_, reason, &messages);
  50   for (ScopedVector<IPC::Message>::iterator i = messages.begin();
  51        i != messages.end();
  52        ++i) {
  53     message_sender_->Send(*i);
  54   }
  55   messages.weak_clear();
  56   PromiseCompleted();
  57 }
  58
  59 void QueueMessageSwapPromise::PromiseCompleted() {
  60 #if DCHECK_IS_ON()
  61   completed_ = true;
  62 #endif
  63 }
  64
  65 int64 QueueMessageSwapPromise::TraceId() const {
  66   return 0;
  67 }
  68
  69 }  // namespace content