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
|
// Copyright 2019 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 "gpu/ipc/scheduler_sequence.h"
#include "base/no_destructor.h"
#include "base/threading/thread_local.h"
#include "gpu/command_buffer/service/scheduler.h"
namespace gpu {
namespace {
#if DCHECK_IS_ON()
base::ThreadLocalBoolean* GetScheduleTaskDisallowed() {
static base::NoDestructor<base::ThreadLocalBoolean> disallowed;
return disallowed.get();
}
#endif // DCHECK_IS_ON()
} // namespace
ScopedAllowScheduleGpuTask::ScopedAllowScheduleGpuTask()
#if DCHECK_IS_ON()
: original_value_(GetScheduleTaskDisallowed()->Get())
#endif // DCHECK_IS_ON()
{
#if DCHECK_IS_ON()
GetScheduleTaskDisallowed()->Set(false);
#endif // DCHECK_IS_ON()
}
ScopedAllowScheduleGpuTask::~ScopedAllowScheduleGpuTask() {
#if DCHECK_IS_ON()
GetScheduleTaskDisallowed()->Set(original_value_);
#endif // DCHECK_IS_ON()
}
// static
void SchedulerSequence::DefaultDisallowScheduleTaskOnCurrentThread() {
#if DCHECK_IS_ON()
GetScheduleTaskDisallowed()->Set(true);
#endif
}
SchedulerSequence::SchedulerSequence(
Scheduler* scheduler,
scoped_refptr<base::SingleThreadTaskRunner> task_runner)
: SingleTaskSequence(),
scheduler_(scheduler),
sequence_id_(scheduler->CreateSequence(SchedulingPriority::kHigh,
std::move(task_runner))) {}
// Note: this drops tasks not executed yet.
SchedulerSequence::~SchedulerSequence() {
scheduler_->DestroySequence(sequence_id_);
}
// SingleTaskSequence implementation.
SequenceId SchedulerSequence::GetSequenceId() {
return sequence_id_;
}
bool SchedulerSequence::ShouldYield() {
return scheduler_->ShouldYield(sequence_id_);
}
void SchedulerSequence::ScheduleTask(base::OnceClosure task,
std::vector<SyncToken> sync_token_fences,
ReportingCallback report_callback) {
// If your CL is failing this DCHECK, then that means you are probably calling
// ScheduleGpuTask at a point that cannot be supported by Android Webview.
// Consider using ScheduleOrRetainGpuTask which will delay (not reorder) the
// task in Android Webview until the next DrawAndSwap.
#if DCHECK_IS_ON()
DCHECK(!GetScheduleTaskDisallowed()->Get())
<< "If your CL is failing this DCHECK, then that means you are probably "
"calling ScheduleGpuTask at a point that cannot be supported by "
"Android Webview. Consider using ScheduleOrRetainGpuTask which will "
"delay (not reorder) the task in Android Webview until the next "
"DrawAndSwap.";
#endif
ScheduleOrRetainTask(std::move(task), std::move(sync_token_fences),
std::move(report_callback));
}
void SchedulerSequence::ScheduleOrRetainTask(
base::OnceClosure task,
std::vector<gpu::SyncToken> sync_token_fences,
ReportingCallback report_callback) {
scheduler_->ScheduleTask(Scheduler::Task(sequence_id_, std::move(task),
std::move(sync_token_fences),
std::move(report_callback)));
}
void SchedulerSequence::ContinueTask(base::OnceClosure task) {
scheduler_->ContinueTask(sequence_id_, std::move(task));
}
} // namespace gpu
|
