Home
last modified time | relevance | path

Searched refs:gid (Results 1 - 25 of 174) sorted by relevance

1234567

/foundation/resourceschedule/ffrt/src/dfx/watchdog/
H A Dwatchdog_util.cpp38 bool IsValidTimeout(uint64_t gid, uint64_t timeout_ms) in IsValidTimeout() argument
42 FFRT_LOGI("task gid=%llu with timeout [%llu ms] is valid", gid, timeout_ms); in IsValidTimeout()
45 FFRT_LOGE("task gid=%llu with timeout [%llu ms] is invalid", gid, timeout_ms); in IsValidTimeout()
50 void AddTaskToWatchdog(uint64_t gid) in AddTaskToWatchdog() argument
53 taskStatusMap.insert(std::make_pair(gid, SEND_COUNT_MIN)); in AddTaskToWatchdog()
56 void RemoveTaskFromWatchdog(uint64_t gid) in RemoveTaskFromWatchdog() argument
59 taskStatusMap.erase(gid); in RemoveTaskFromWatchdog()
62 bool SendTimeoutWatchdog(uint64_t gid, uint64_ argument
91 RunTimeOutCallback(uint64_t gid, uint64_t timeout) RunTimeOutCallback() argument
[all...]
H A Dwatchdog_util.h21 bool IsValidTimeout(uint64_t gid, uint64_t timeout_ms);
22 void AddTaskToWatchdog(uint64_t gid);
23 void RemoveTaskFromWatchdog(uint64_t gid);
24 bool SendTimeoutWatchdog(uint64_t gid, uint64_t timeout, uint64_t delay);
25 void RunTimeOutCallback(uint64_t gid, uint64_t timeout);
/foundation/resourceschedule/ffrt/src/dfx/trace/
H A Dffrt_trace.h237 #define FFRT_SUBMIT_MARKER(tag, gid) \
239 FFRT_TRACE_ASYNC_END("P", gid); \
241 #define FFRT_READY_MARKER(gid) \
243 FFRT_TRACE_ASYNC_END("R", gid); \
245 #define FFRT_BLOCK_MARKER(gid) \
247 FFRT_TRACE_ASYNC_END("B", gid); \
249 #define FFRT_TASKDONE_MARKER(gid) \
251 FFRT_TRACE_ASYNC_END("F", gid); \
253 #define FFRT_FAKE_TRACE_MARKER(gid) \
255 FFRT_TRACE_ASYNC_END("Co", gid); \
[all...]
/foundation/resourceschedule/ffrt/tools/ffrt_trace_process/
H A Dffrt_trace_recover.py51 def make_costart_fake_log(mark, pid, label, gid, tid, tname, prio):
58 tname, tid, pid, cpu_id, timestamp, tname, tid, prio, label, pid, gid, prio)
63 def make_coyield_fake_log(mark, pid, label, gid, tid, tname, prio):
70 label, pid, gid, pid, cpu_id, timestamp, label, pid, gid, prio, tname, tid, prio)
74 (label, pid, gid, pid, cpu_id, timestamp, pid) + fake_log
79 def replace_sched_switch_log(fake_log, mark, pid, label, gid, tid):
85 fake_log = " %s-%d0%d " % (label, pid, gid) + fake_log[index:]
88 fake_log = fake_log[:fake_log.index("prev_pid=")] + "prev_pid=%d0%d " % (pid, gid) + \
93 fake_log = fake_log[:fake_log.index("next_pid=")] + "next_pid=%d0%d " % (pid, gid)
[all...]
H A Dffrt_trace_process.py221 def generate_counter_info(suffix, task_records, next_status, gid, pid_counters_dict, pid):
226 prev_counter = task_records[gid]["status"] + "_task"
239 task_records[gid]["status"] = next_status
292 gid = task_marker[1]
296 if gid not in task_records.keys():
298 task_records[gid] = {
299 "gid": gid,
319 infos = generate_counter_info(suffix, task_records, "pending", gid, pid_counters_dict, pid)
328 if gid i
[all...]
/foundation/resourceschedule/ffrt/src/tm/
H A Dqueue_task.cpp28 label = handler->GetName() + "_" + attr->name_ + "_" + std::to_string(gid); in QueueTask()
30 label = handler->GetName() + "_" + std::to_string(gid); in QueueTask()
46 FFRT_LOGD("ctor task [gid=%llu], delay=%lluus, type=%lu, prio=%d", gid, delay_, type, prio_); in QueueTask()
51 FFRT_LOGD("dtor task [gid=%llu]", gid); in ~QueueTask()
65 FFRT_SERIAL_QUEUE_TASK_FINISH_MARKER(gid); in Notify()
75 FFRT_LOGD("Execute stask[%lu], name[%s]", gid, label.c_str()); in Execute()
77 FFRT_LOGE("task [gid=%llu] is complete, no need to execute again", gid); in Execute()
[all...]
H A Dscpu_task.cpp48 FFRT_LOGD("Undependency completed, enter ready queue, task[%lu], name[%s]", gid, label.c_str()); in DecDepRef()
49 FFRT_WAKE_TRACER(this->gid); in DecDepRef()
59 parent->label.c_str(), parent->childRefCnt.load(), gid, label.c_str()); in DecChildRef()
76 FFRT_LOGD("free CPUEUTask:%s gid=%lu", parent->label.c_str(), parent->gid); in DecChildRef()
92 FFRT_WAKE_TRACER(parent->gid); in DecChildRef()
117 FFRT_WAKE_TRACER(this->gid); in DecWaitDataRef()
127 FFRT_LOGD("free SCPUEUTask:%s gid=%lu", label.c_str(), gid); in RecycleTask()
H A Dcpu_task.cpp55 FFRT_LOGD("Execute task[%lu], name[%s]", gid, label.c_str()); in Execute()
65 FFRT_TASKDONE_MARKER(gid); in Execute()
88 FFRT_SUBMIT_MARKER(label, gid); in CPUEUTask()
105 FFRT_LOGD("create task name:%s gid=%lu taskLocal:%d", label.c_str(), gid, taskLocal); in CPUEUTask()
/foundation/graphic/graphic_2d/rosen/modules/texgine/src/opentype_parser/
H A Dranges.cpp27 singles_[range.start] = range.gid; in AddRange()
39 for (const auto &[start, end, gid] : ranges_) { in GetGlyphId()
41 return codepoint + gid; in GetGlyphId()
50 for (const auto &[start, end, gid] : ranges_) { in Dump()
57 for (const auto &[codepoint, gid] : singles_) { in Dump()
60 << ": glyphid " << std::dec << (codepoint + gid) % (1 << 16); in Dump()
/foundation/filemanagement/storage_service/services/storage_daemon/utils/test/
H A Dfile_utils_test.cpp42 int32_t ChOwn(const std::string &path, uid_t uid, gid_t gid);
119 gid_t gid = 01; in HWTEST_F() local
120 int32_t ret = ChOwn(PATH_CHOWN, uid, gid); in HWTEST_F()
127 EXPECT_TRUE(st.st_gid == gid); in HWTEST_F()
130 gid = 00; in HWTEST_F()
131 ret = ChOwn(PATH_CHOWN, uid, gid); in HWTEST_F()
137 EXPECT_TRUE(st.st_gid == gid); in HWTEST_F()
199 gid_t gid = 01; in HWTEST_F() local
203 bool ret = PrepareDir(PATH_MKDIR, mode, uid, gid); in HWTEST_F()
225 gid_t gid in HWTEST_F() local
251 gid_t gid = 01; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/
H A Dasset_loader_test.cpp34 std::string gid; in HWTEST_F() local
37 auto ret = loader.Download(tableName, gid, prefix, assets); in HWTEST_F()
50 std::string gid; in HWTEST_F() local
53 auto ret = loader.RemoveLocalAssets(tableName, gid, prefix, assets); in HWTEST_F()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/
H A Dstore_debug_info.cpp25 SetValue(node[GET_NAME(gid)], gid); in Marshal()
36 GetValue(node, GET_NAME(gid), gid); in Unmarshal()
/foundation/resourceschedule/ffrt/src/queue/
H A Dqueue_handler.cpp125 uint64_t gid = task->gid; in Submit() local
126 FFRT_SERIAL_QUEUE_TASK_SUBMIT_MARKER(GetQueueId(), gid); in Submit() local
135 FFRT_LOGD("submit task[%lu] into %s", gid, name_.c_str()); in Submit()
148 FFRT_LOGD("task [%llu] activate %s", gid, name_.c_str()); in Submit()
151 FFRT_LOGD("task [%llu] with delay [%llu] activate %s", gid, task->GetDelay(), name_.c_str()); in Submit()
195 FFRT_LOGD("cancel task[%llu] %s succ", task->gid, task->label.c_str()); in Cancel()
199 FFRT_LOGD("cancel task[%llu] %s failed, task may have been executed", task->gid, task->label.c_str()); in Cancel()
210 QueueMonitor::GetInstance().UpdateQueueInfo(GetQueueId(), task->gid); in Dispatch()
213 FFRT_LOGD("run task [gid in Dispatch()
[all...]
H A Dqueue_strategy.h50 FFRT_LOGD("dequeue [gid=%llu -> gid=%llu], %u other tasks in [queueId=%u] ", in DequeBatch()
51 head->gid, node->gid, whenMap.size(), queueId); in DequeBatch()
73 FFRT_LOGD("dequeue [gid=%llu], %u other tasks in [queueId=%u] ", head->gid, whenMap.size(), queueId); in DequeSingleByPriority()
106 FFRT_LOGD("dequeue [gid=%llu], %u other tasks in [queueId=%u] ", head->gid, whenMap.size(), queueId); in DequeSingleAgainstStarvation()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dvirtual_asset_loader.cpp19 DBStatus VirtualAssetLoader::Download(const std::string &tableName, const std::string &gid, const Type &prefix, in Download() argument
28 LOGD("Download GID:%s", gid.c_str()); in Download()
49 DBStatus VirtualAssetLoader::RemoveLocalAssets(const std::string &tableName, const std::string &gid, const Type &prefix, in RemoveLocalAssets() argument
61 LOGD("RemoveLocalAssets GID:%s", gid.c_str()); in RemoveLocalAssets()
/foundation/bundlemanager/bundle_framework/interfaces/inner_api/appexecfwk_base/src/
H A Ddata_group_info.cpp30 const char* GID = "gid";
39 gid = parcel.ReadInt32(); in ReadFromParcel()
50 WRITE_PARCEL_AND_RETURN_FALSE_IF_FAIL(Int32, parcel, gid); in Marshalling()
73 {GID, dataGroupInfo.gid}, in to_json()
105 dataGroupInfo.gid, in from_json()
128 + ", gid = " + std::to_string(gid) in ToString()
/foundation/resourceschedule/ffrt/src/sched/
H A Dscheduler.cpp91 task->gid, task->type, task->label.c_str()); in WakeupTask()
97 uint64_t gid = task->gid; in WakeupTask() local
101 FFRT_READY_MARKER(gid); // ffrt normal task ready to enque in WakeupTask()
109 FFRT_LOGD("qos[%d] task[%lu] entered q", level, gid); in WakeupTask()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/
H A Dasset_loader_impl.cpp35 const std::string &tableName, const std::string &gid, const DBValue &prefix, DBVBucket &assets) in Download()
45 .gid = reinterpret_cast<const unsigned char *>(gid.c_str()), in Download()
46 .gidLen = gid.size(), in Download()
71 const std::string &tableName, const std::string &gid, const DBValue &prefix, DBVBucket &assets) in RemoveLocalAssets()
34 Download( const std::string &tableName, const std::string &gid, const DBValue &prefix, DBVBucket &assets) Download() argument
70 RemoveLocalAssets( const std::string &tableName, const std::string &gid, const DBValue &prefix, DBVBucket &assets) RemoveLocalAssets() argument
H A Dasset_loader_impl.h34 int32_t Download(const std::string &tableName, const std::string &gid, const DBValue &prefix,
36 int32_t RemoveLocalAssets(const std::string &tableName, const std::string &gid,
/foundation/resourceschedule/ffrt/src/dm/
H A Dsdependence_manager.cpp95 FFRT_TRACE_BEGIN(("submit|" + std::to_string(task->gid)).c_str()); in onSubmit()
96 FFRT_LOGD("submit task[%lu], name[%s]", task->gid, task->label.c_str()); in onSubmit()
111 if (attr != nullptr && IsValidTimeout(task->gid, attr->timeout_)) { in onSubmit()
113 AddTaskToWatchdog(task->gid); in onSubmit()
114 SendTimeoutWatchdog(task->gid, attr->timeout_, attr->delay_); in onSubmit()
150 FFRT_BLOCK_TRACER(task->gid, dep); in onSubmit()
160 FFRT_LOGD("Submit completed, enter ready queue, task[%lu], name[%s]", task->gid, task->label.c_str()); in onSubmit()
175 FFRT_LOGD("onWait name:%s gid=%lu", task->label.c_str(), task->gid); in onWait()
193 FFRT_BLOCK_TRACER(task->gid, ch in onWait()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/
H A Dasset_loader.cpp19 const std::string &tableName, const std::string &gid, const Value &prefix, VBucket &assets) in Download()
25 const std::string &tableName, const std::string &gid, const Value &prefix, VBucket &assets) in RemoveLocalAssets()
18 Download( const std::string &tableName, const std::string &gid, const Value &prefix, VBucket &assets) Download() argument
24 RemoveLocalAssets( const std::string &tableName, const std::string &gid, const Value &prefix, VBucket &assets) RemoveLocalAssets() argument
/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/ipc/
H A Dfile_stat.cpp25 gid = parcel.ReadInt32(); in ReadFromParcel()
35 WRITE_PARCEL_AND_RETURN_FALSE_IF_FAIL(Int32, parcel, gid); in Marshalling()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/cloud/
H A DiAssetLoader.h31 virtual DBStatus Download(const std::string &tableName, const std::string &gid, const Type &prefix, in Download() argument
42 virtual DBStatus RemoveLocalAssets(const std::string &tableName, const std::string &gid, const Type &prefix, in RemoveLocalAssets() argument
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/
H A Dasset_loader.h26 const std::string &tableName, const std::string &gid, const Value &prefix, VBucket &assets);
28 const std::string &tableName, const std::string &gid, const Value &prefix, VBucket &assets);
/foundation/ability/ability_runtime/services/appmgr/src/
H A Dapp_spawn_msg_wrapper.cpp34 constexpr const char* DATAGROUPINFOLIST_GID = "gid";
62 dataGroupInfoListJson[DATAGROUPINFOLIST_GID].emplace_back(std::to_string(dataGroupInfo.gid)); in DumpToJson()
99 msg_->gid = startMsg.gid; in AssembleMsg()
113 msg_->gidTable[i] = startMsg.dataGroupInfoList[i - startMsg.gids.size()].gid; in AssembleMsg()
191 if (startMsg.gid < 0) { in VerifyMsg()
192 TAG_LOGE(AAFwkTag::APPMGR, "invalid gid! [%{public}d]", startMsg.gid); in VerifyMsg()
231 TAG_LOGD(AAFwkTag::APPMGR, "uid: %{public}d, gid: %{public}d, procName: %{public}s, accessTokenIdEx :%{public}s", in DumpMsg()
232 msg_->uid, msg_->gid, msg in DumpMsg()
[all...]

Completed in 8 milliseconds

1234567