| /system/chre/platform/linux/tests/ |
| D | task_test.cc | 35 Task task(incrementGVar, waitTime, 0); in TEST() local
36 EXPECT_FALSE(task.isReadyToExecute()); in TEST()
38 EXPECT_TRUE(task.isReadyToExecute()); in TEST()
39 task.execute(); in TEST()
41 EXPECT_TRUE(task.isRepeating()); in TEST()
42 EXPECT_FALSE(task.isReadyToExecute()); in TEST()
44 std::chrono::steady_clock::now() - task.getExecutionTimestamp(); in TEST()
48 task.cancel(); in TEST()
49 EXPECT_FALSE(task.isRepeating()); in TEST()
55 Task task(incrementGVar, waitTime, 0); in TEST() local
[all …]
|
| /system/chre/platform/linux/task_util/ |
| D | task_manager.cc | 60 Task task(func, repeatInterval, returnId); in addTask() local
61 success = mQueue.push(task); in addTask()
104 Task task; in run() local
114 task = mQueue.top(); in run()
115 if (!task.isReadyToExecute()) { in run()
117 task.getExecutionTimestamp() - std::chrono::steady_clock::now(); in run()
132 mCurrentTask = &task; in run()
134 task.execute(); in run()
139 if (task.isRepeating() && !mQueue.push(task)) { in run()
|
| /system/core/storaged/ |
| D | uid_info.cpp | 45 task_info task; in readFromParcel() local
46 task.pid = parcel->readInt32(); in readFromParcel()
47 task.comm = parcel->readCString(); in readFromParcel()
48 parcel->read(&task.io, sizeof(task.io)); in readFromParcel()
49 tasks[task.pid] = task; in readFromParcel()
|
| D | storaged_utils.cpp | 82 const task_info& task = task_it.second; in log_console_running_uids_info() local
85 task.comm.c_str(), in log_console_running_uids_info()
86 … task.io[0].rchar, task.io[0].wchar, task.io[0].read_bytes, task.io[0].write_bytes, in log_console_running_uids_info()
87 … task.io[1].rchar, task.io[1].wchar, task.io[1].read_bytes, task.io[1].write_bytes, in log_console_running_uids_info()
88 task.io[0].fsync, task.io[1].fsync); in log_console_running_uids_info()
|
| D | storaged_uid_monitor.cpp | 339 const task_info& task = task_it.second; in update_curr_io_stats_locked() local
342 int64_t task_fg_rd_delta = task.io[FOREGROUND].read_bytes - in update_curr_io_stats_locked()
344 int64_t task_bg_rd_delta = task.io[BACKGROUND].read_bytes - in update_curr_io_stats_locked()
346 int64_t task_fg_wr_delta = task.io[FOREGROUND].write_bytes - in update_curr_io_stats_locked()
348 int64_t task_bg_wr_delta = task.io[BACKGROUND].write_bytes - in update_curr_io_stats_locked()
|
| /system/core/storaged/tools/ |
| D | ranker.py | 97 task_enabled = args.task
106 task = " ".join(words[1:i])
107 if task in uids[cur_uid][1]:
108 task_io = uids[cur_uid][1][task]
115 uids[cur_uid][1][task] = task_io
122 task_enabled = args.task
167 if args.task:
168 for task in uids[uid][1]:
169 task_stat = " ".join([str(task_io) for task_io in uids[uid][1][task]])
170 fout.write("-> " + task + " " + task_stat + "\n")
|
| /system/core/fastboot/ |
| D | task_test.cpp | 75 for (auto& task : tasks) { in TEST_F() local
76 ASSERT_TRUE(task != nullptr); in TEST_F()
80 auto task = tasks[i]->AsFlashTask(); in TEST_F() local
81 ASSERT_TRUE(task != nullptr); in TEST_F()
82 ASSERT_EQ(task->GetPartition(), expected_values[i][0]); in TEST_F()
83 ASSERT_EQ(task->GetPartitionAndSlot(), expected_values[i][1]); in TEST_F()
84 ASSERT_EQ(task->GetSlot(), expected_values[i][2]); in TEST_F()
85 ASSERT_EQ(task->GetImageName(), expected_values[i][3]); in TEST_F()
|
| D | task.cpp | 215 for (const auto& task : tasks) { in InitializeFromTasks() local
216 if (auto flash_task = task->AsFlashTask()) { in InitializeFromTasks()
229 auto remove_if_callback = [&](const auto& task) -> bool { in InitializeFromTasks() argument
230 if (auto flash_task = task->AsFlashTask()) { in InitializeFromTasks()
232 } else if (auto update_super_task = task->AsUpdateSuperTask()) { in InitializeFromTasks()
234 } else if (auto reboot_task = task->AsRebootTask()) { in InitializeFromTasks()
|
| /system/chre/platform/zephyr/ |
| D | Kconfig | 60 string "The name of the CHRE task"
64 int "The size of the CHRE task stack"
68 int "The priority of the CHRE task"
|
| /system/sepolicy/prebuilts/api/29.0/private/ |
| D | fs_use | 14 # Label inodes from task label.
18 # Label inodes from combination of task label and fs label.
|
| /system/sepolicy/prebuilts/api/30.0/private/ |
| D | fs_use | 15 # Label inodes from task label.
19 # Label inodes from combination of task label and fs label.
|
| /system/sepolicy/prebuilts/api/31.0/private/ |
| D | fs_use | 16 # Label inodes from task label.
20 # Label inodes from combination of task label and fs label.
|
| /system/sepolicy/prebuilts/api/33.0/private/ |
| D | fs_use | 16 # Label inodes from task label.
20 # Label inodes from combination of task label and fs label.
|
| /system/sepolicy/microdroid/system/private/ |
| D | fs_use | 16 # Label inodes from task label.
20 # Label inodes from combination of task label and fs label.
|
| /system/sepolicy/prebuilts/api/34.0/private/ |
| D | fs_use | 16 # Label inodes from task label.
20 # Label inodes from combination of task label and fs label.
|
| /system/sepolicy/private/ |
| D | fs_use | 16 # Label inodes from task label.
20 # Label inodes from combination of task label and fs label.
|
| /system/sepolicy/prebuilts/api/32.0/private/ |
| D | fs_use | 16 # Label inodes from task label.
20 # Label inodes from combination of task label and fs label.
|
| /system/extras/simpleperf/demo/JavaApi/ |
| D | build.gradle | 18 task clean(type: Delete) {
|
| /system/extras/simpleperf/demo/CppApi/ |
| D | build.gradle | 18 task clean(type: Delete) {
|
| /system/linkerconfig/ |
| D | main.cc | 359 void ExitOnFailure(Result<void> task) { in ExitOnFailure() argument
360 if (!task.ok()) { in ExitOnFailure()
361 LOG(FATAL) << task.error(); in ExitOnFailure()
|
| /system/sepolicy/prebuilts/api/29.0/public/ |
| D | performanced.te | 16 # Performanced also shields unbound kernel threads. It scans every task in the
|
| /system/sepolicy/prebuilts/api/30.0/public/ |
| D | performanced.te | 16 # Performanced also shields unbound kernel threads. It scans every task in the
|
| /system/chre/java/test/utils/src/com/google/android/utils/chre/ |
| D | ContextHubServiceTestHelper.java | 249 for (Runnable task : tasks) { in runConcurrentTasks()
250 executorService.submit(task); in runConcurrentTasks()
|
| /system/sepolicy/prebuilts/api/33.0/public/ |
| D | performanced.te | 16 # Performanced also shields unbound kernel threads. It scans every task in the
|
| /system/sepolicy/prebuilts/api/32.0/public/ |
| D | performanced.te | 16 # Performanced also shields unbound kernel threads. It scans every task in the
|