blob: 199ddfa4402bd4abc143cde3dc438d218f325720 (
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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
// 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 <memory>
#include "base/command_line.h"
#include "cc/trees/frame_token_allocator.h"
#include "content/common/view_messages.h"
#include "content/public/common/content_switches.h"
#include "content/public/renderer/render_thread.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::DidActivate() {
#if DCHECK_IS_ON()
DCHECK(!completed_);
#endif
message_queue_->DidActivate(source_frame_number_);
// The OutputSurface will take care of the Drain+Send.
}
void QueueMessageSwapPromise::WillSwap(
viz::CompositorFrameMetadata* metadata,
cc::FrameTokenAllocator* frame_token_allocator) {
#if DCHECK_IS_ON()
DCHECK(!completed_);
#endif
message_queue_->DidSwap(source_frame_number_);
if (!message_queue_->AreFramesDiscarded()) {
std::unique_ptr<FrameSwapMessageQueue::SendMessageScope>
send_message_scope = message_queue_->AcquireSendMessageScope();
std::vector<std::unique_ptr<IPC::Message>> messages;
message_queue_->DrainMessages(&messages);
std::vector<IPC::Message> messages_to_send;
FrameSwapMessageQueue::TransferMessages(&messages, &messages_to_send);
if (!messages_to_send.empty()) {
metadata->frame_token = frame_token_allocator->GetOrAllocateFrameToken();
message_sender_->Send(new ViewHostMsg_FrameSwapMessages(
message_queue_->routing_id(), metadata->frame_token,
messages_to_send));
}
}
PromiseCompleted();
}
void QueueMessageSwapPromise::DidSwap() {}
cc::SwapPromise::DidNotSwapAction QueueMessageSwapPromise::DidNotSwap(
DidNotSwapReason reason) {
#if DCHECK_IS_ON()
DCHECK(!completed_);
#endif
// TODO(eseckler): Deliver messages with the next swap instead of sending
// them here directly.
std::vector<std::unique_ptr<IPC::Message>> messages;
message_queue_->DidNotSwap(source_frame_number_, reason, &messages);
for (auto& msg : messages) {
message_sender_->Send(msg.release());
}
PromiseCompleted();
return DidNotSwapAction::BREAK_PROMISE;
}
void QueueMessageSwapPromise::PromiseCompleted() {
#if DCHECK_IS_ON()
completed_ = true;
#endif
}
int64_t QueueMessageSwapPromise::TraceId() const {
return 0;
}
} // namespace content
|
