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