1 /**
2 * Copyright (c) 2023 Huawei Device Co., Ltd.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15
16 #include "runtime/mem/gc/g1/update_remset_task_queue.h"
17
18 #include "libpandabase/taskmanager/task_scheduler.h"
19 #include "runtime/include/language_config.h"
20 #include "runtime/mem/gc/g1/g1-gc.h"
21
22 namespace panda::mem {
23
24 template <class LanguageConfig>
UpdateRemsetTaskQueue(G1GC<LanguageConfig> * gc,GCG1BarrierSet::ThreadLocalCardQueues * queue,os::memory::Mutex * queueLock,size_t regionSize,bool updateConcurrent,size_t minConcurrentCardsToProcess)25 UpdateRemsetTaskQueue<LanguageConfig>::UpdateRemsetTaskQueue(G1GC<LanguageConfig> *gc,
26 GCG1BarrierSet::ThreadLocalCardQueues *queue,
27 os::memory::Mutex *queueLock, size_t regionSize,
28 bool updateConcurrent, size_t minConcurrentCardsToProcess)
29 : UpdateRemsetWorker<LanguageConfig>(gc, queue, queueLock, regionSize, updateConcurrent,
30 minConcurrentCardsToProcess)
31 {
32 }
33
34 template <class LanguageConfig>
35 UpdateRemsetTaskQueue<LanguageConfig>::~UpdateRemsetTaskQueue() = default;
36
37 template <class LanguageConfig>
StartProcessCards()38 void UpdateRemsetTaskQueue<LanguageConfig>::StartProcessCards()
39 {
40 // If we already have process cards task in task manager then no need to add a new task
41 if (hasTaskInTaskmanager_) {
42 return;
43 }
44 auto updateRemsetRunner = [this]() {
45 os::memory::LockHolder lh(this->updateRemsetLock_);
46 ASSERT(this->hasTaskInTaskmanager_);
47 // GC notified us to pause cards processing, or we are destroing runtime and notifiy STOP_WORKER
48 if (!this->IsFlag(UpdateRemsetWorker<LanguageConfig>::UpdateRemsetWorkerFlags::IS_PROCESS_CARD)) {
49 this->hasTaskInTaskmanager_ = false;
50 return;
51 }
52 ASSERT(!this->pausedByGcThread_);
53 this->ProcessAllCards();
54 // After cards processing add new cards processing task to task manager
55 this->hasTaskInTaskmanager_ = false;
56 this->StartProcessCards();
57 };
58 auto processCardsTask = taskmanager::Task::Create(UPDATE_REMSET_TASK_PROPERTIES, updateRemsetRunner);
59 hasTaskInTaskmanager_ = true;
60 this->GetGC()->GetWorkersTaskQueue()->AddTask(std::move(processCardsTask));
61 }
62
63 template <class LanguageConfig>
ContinueProcessCards()64 void UpdateRemsetTaskQueue<LanguageConfig>::ContinueProcessCards()
65 {
66 StartProcessCards();
67 }
68
69 template <class LanguageConfig>
CreateWorkerImpl()70 void UpdateRemsetTaskQueue<LanguageConfig>::CreateWorkerImpl()
71 {
72 os::memory::LockHolder lh(this->updateRemsetLock_);
73 ASSERT(!hasTaskInTaskmanager_);
74 StartProcessCards();
75 }
76
77 template <class LanguageConfig>
DestroyWorkerImpl()78 void UpdateRemsetTaskQueue<LanguageConfig>::DestroyWorkerImpl()
79 {
80 taskmanager::TaskScheduler::GetTaskScheduler()->WaitForFinishAllTasksWithProperties(UPDATE_REMSET_TASK_PROPERTIES);
81 [[maybe_unused]] os::memory::LockHolder lh(this->updateRemsetLock_);
82 ASSERT(!hasTaskInTaskmanager_);
83 }
84
85 TEMPLATE_CLASS_LANGUAGE_CONFIG(UpdateRemsetTaskQueue);
86 } // namespace panda::mem
87