| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_relational_store.cpp | 1119 …LOGI("sync mode:%d, pri:%d, comp:%d", option.mode, option.priorityTask, option.compensatedSyncOnly… in Sync()
1178 if (!option.priorityTask && !isFromTable) { in CheckQueryValid()
1197 return CheckObjectValid(option.priorityTask, object, isFromTable); in CheckQueryValid()
1200 int SQLiteRelationalStore::CheckObjectValid(bool priorityTask, const std::vector<QuerySyncObject> &… in CheckObjectValid() argument
1205 if (priorityTask && !item.IsContainQueryNodes() && !isFromTable) { in CheckObjectValid()
1213 if (!priorityTask || isFromTable) { in CheckObjectValid()
1271 info.priorityTask = option.priorityTask; in FillSyncInfo()
1421 if (info.priorityTask && actualTable.size() != info.table.size()) { in ReFillSyncInfoTable()
|
| H A D | sqlite_relational_store.h | 152 …int CheckObjectValid(bool priorityTask, const std::vector<QuerySyncObject> &object, bool isFromTab…
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/eu/ |
| H A D | cpu_worker.cpp | 152 …ffrt_executor_task_t* priorityTask = reinterpret_cast<ffrt_executor_task_t*>(worker->priority_task… in RunTaskLifo() local
156 RunTask(priorityTask, worker); in RunTaskLifo()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | icloud_syncer.h | 30 bool priorityTask = false; member
|
| H A D | cloud_syncer.cpp | 90 if (taskInfo.priorityTask) { in Sync()
1384 return cloudTaskInfos_[taskId].priorityTask; in IsPriorityTask()
1483 int CloudSyncer::CheckQueueSizeWithNoLock(bool priorityTask) in CheckQueueSizeWithNoLock() argument
1486 if (!priorityTask && taskQueue_.size() >= static_cast<size_t>(limit)) { in CheckQueueSizeWithNoLock()
1489 } else if (priorityTask && priorityTaskQueue_.size() >= static_cast<size_t>(limit)) { in CheckQueueSizeWithNoLock()
1822 if (!cloudTaskInfos_[currentContext_.currentTaskId].priorityTask) { in MarkCurrentTaskPausedIfNeed()
|
| H A D | cloud_syncer_extend.cpp | 754 errCode = CheckQueueSizeWithNoLock(taskInfo.priorityTask); in TryToAddSyncTask()
764 if (cloudTaskInfos_[taskId].priorityTask) { in TryToAddSyncTask()
841 return !taskInfo.compensatedTask && !taskInfo.priorityTask && in IsTaskCanMerge()
|
| H A D | cloud_syncer.h | 209 int CheckQueueSizeWithNoLock(bool priorityTask);
|
| H A D | cloud_sync_utils.cpp | 613 taskInfo.priorityTask = true; in InitCompensatedSyncTaskInfo()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/cloud/ |
| H A D | cloud_store_types.h | 153 bool priorityTask = false; member
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_check_sync_test.cpp | 78 option.priorityTask = isPriorityTask; in PrepareOption()
105 option.priorityTask = prioritySync; in BlockSync()
2058 option.priorityTask = true;
2214 option.priorityTask = false;
2221 option.priorityTask = true;
|
| H A D | distributeddb_cloud_task_merge_test.cpp | 87 option.priorityTask = false; in PrepareOption()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_syncer_lock_test.cpp | 310 option.priorityTask = isPriorityTask; in PrepareOption()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_multi_sub_user_test.cpp | 369 option.priorityTask = false; in PrepareOption()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_relational_remove_device_data_test.cpp | 763 option.priorityTask = true; in GetSyncOption()
|
| H A D | distributeddb_interfaces_nb_delegate_rd_test.cpp | 2274 .priorityTask = false,
|