Home
last modified time | relevance | path

Searched refs:tid (Results 1 - 25 of 261) sorted by relevance

1234567891011

/foundation/resourceschedule/qos_manager/qos/
H A Dqos.cpp36 int QosController::SetThreadQosForOtherThread(enum QosLevel level, int tid) in SetThreadQosForOtherThread() argument
41 CONCUR_LOGD("[Qos] qoslevel %{public}d apply for tid %{public}d disable", static_cast<int>(level), tid); in SetThreadQosForOtherThread()
50 int ret = QosApplyForOther(qos, tid); in SetThreadQosForOtherThread()
52 CONCUR_LOGD("[Qos] qoslevel %{public}d apply for tid %{public}d success", qos, tid); in SetThreadQosForOtherThread()
54 CONCUR_LOGD("[Qos] qoslevel %{public}d apply for tid %{public}d failure", qos, tid); in SetThreadQosForOtherThread()
60 int QosController::ResetThreadQosForOtherThread(int tid) in ResetThreadQosForOtherThread() argument
65 CONCUR_LOGD("[Qos] qoslevel reset disable for tid in ResetThreadQosForOtherThread()
79 GetThreadQosForOtherThread(enum QosLevel &level, int tid) GetThreadQosForOtherThread() argument
100 int tid = gettid(); SetThreadQos() local
104 SetQosForOtherThread(enum QosLevel level, int tid) SetQosForOtherThread() argument
111 int tid = gettid(); ResetThreadQos() local
115 ResetQosForOtherThread(int tid) ResetQosForOtherThread() argument
125 GetQosForOtherThread(enum QosLevel &level, int tid) GetQosForOtherThread() argument
[all...]
/foundation/multimedia/audio_framework/frameworks/native/audioschedule/
H A Daudio_schedule.cpp51 void ConfigPayload(uint32_t pid, uint32_t tid, const char *bundleName, int32_t qosLevel, in ConfigPayload() argument
56 std::string strTid = std::to_string(tid); in ConfigPayload()
63 void ScheduleReportData(uint32_t pid, uint32_t tid, const char *bundleName) in ScheduleReportData() argument
66 ", tid " + std::to_string(tid), REPORTDATA_TIMEOUT); in ScheduleReportData()
68 AUDIO_INFO_LOG("Report tid %{public}u", tid); in ScheduleReportData()
70 ConfigPayload(pid, tid, bundleName, AUDIO_QOS_LEVEL, mapPayload); in ScheduleReportData()
74 void UnscheduleReportData(uint32_t pid, uint32_t tid, const char* bundleName) in UnscheduleReportData() argument
77 ", tid " in UnscheduleReportData()
84 UnscheduleThreadInServer(uint32_t pid, uint32_t tid) UnscheduleThreadInServer() argument
94 ScheduleThreadInServer(uint32_t pid, uint32_t tid) ScheduleThreadInServer() argument
126 AudioScheduleGuard(uint32_t pid, uint32_t tid, const std::string &bundleName) AudioScheduleGuard() argument
[all...]
/foundation/resourceschedule/ffrt/src/sched/
H A Dmulti_workgroup.cpp48 int FindThreadInWorkGroup(WorkGroup *workGroup, int tid) in FindThreadInWorkGroup() argument
51 FFRT_LOGE("[RSWorkGroup] find thread %{public}d in workGroup failed, workGroup is null", tid); in FindThreadInWorkGroup()
55 if (workGroup->tids[i] == tid) { in FindThreadInWorkGroup()
62 bool InsertThreadInWorkGroup(WorkGroup *workGroup, int tid) in InsertThreadInWorkGroup() argument
65 FFRT_LOGE("[RSWorkGroup] join thread %{public}d into workGroup failed, workGroup is null", tid); in InsertThreadInWorkGroup()
71 workGroup->tids[i] = tid; in InsertThreadInWorkGroup()
78 tid, MAX_WG_THREADS); in InsertThreadInWorkGroup()
88 rs.tid = -1; in CreateRSWorkGroup()
107 bool LeaveRSWorkGroup(int tid) in LeaveRSWorkGroup() argument
111 FFRT_LOGI("[RSWorkGroup] LeaveRSWorkGroup rsWorkGroup is null ,tid in LeaveRSWorkGroup()
122 JoinRSWorkGroup(int tid) JoinRSWorkGroup() argument
160 JoinWG(int tid) JoinWG() argument
182 LeaveWG(int tid) LeaveWG() argument
287 WorkgroupJoin(struct WorkGroup* wg, int tid) WorkgroupJoin() argument
[all...]
H A Dworkgroup_internal.h50 bool JoinWG(int tid);
51 bool LeaveWG(int tid);
57 bool JoinRSWorkGroup(int tid);
58 bool LeaveRSWorkGroup(int tid);
90 inline bool JoinWG(int tid) in JoinWG() argument
95 return JoinRSWorkGroup(tid); in JoinWG()
98 (void)tid; in JoinWG()
102 inline bool LeaveWG(int tid) in LeaveWG() argument
107 return LeaveRSWorkGroup(tid); in LeaveWG()
110 (void)tid; in LeaveWG()
140 WorkgroupJoin(struct WorkGroup* wg, int tid) WorkgroupJoin() argument
[all...]
/test/xts/acts/kernel_lite/process_posix/src/
H A DPthreadBasicApiTest.cpp42 pthread_t tid; in HWTEST_F() local
44 ASSERT_EQ(pthread_create(&tid, nullptr, ThreadPthreadCreateBasic, (void*)str), 0) << "> return errno"; in HWTEST_F()
46 EXPECT_EQ(pthread_join(tid, nullptr), 0) << "> return errno"; in HWTEST_F()
63 pthread_t tid; in HWTEST_F() local
65 ASSERT_EQ(pthread_create(&tid, nullptr, ThreadPthreadJoinWait, nullptr), 0) << "> return errno"; in HWTEST_F()
66 EXPECT_EQ(pthread_join(tid, nullptr), 0) << "> return errno"; in HWTEST_F()
77 pthread_t tid; in HWTEST_F() local
81 ASSERT_EQ(pthread_create(&tid, nullptr, ThreadPublic, (void*)&num), 0) << "> return errno"; in HWTEST_F()
82 EXPECT_EQ(pthread_join(tid, &joinRe), 0) << "> return errno"; in HWTEST_F()
95 pthread_t tid; in HWTEST_F() local
114 pthread_t tid; HWTEST_F() local
142 pthread_t tid; HWTEST_F() local
159 pthread_t tid; HWTEST_F() local
167 pthread_t *tid = (pthread_t*)arg; ThreadPthreadEqual() local
180 pthread_t tid; HWTEST_F() local
321 pthread_t tid; HWTEST_F() local
354 pthread_t tid; HWTEST_F() local
384 pthread_t tid; HWTEST_F() local
419 pthread_t tid; HWTEST_F() local
491 pthread_t tid; HWTEST_F() local
534 pthread_t tid; HWTEST_F() local
603 pthread_t tid; HWTEST_F() local
630 pthread_t tid; HWTEST_F() local
657 pthread_t tid; HWTEST_F() local
685 pthread_t tid; HWTEST_F() local
713 pthread_t tid; HWTEST_F() local
742 pthread_t tid; HWTEST_F() local
871 pthread_t tid; HWTEST_F() local
903 pthread_t tid[2]; HWTEST_F() local
[all...]
H A DPthreadAttrTest.cpp35 pthread_t tid; in HWTEST_F() local
45 ASSERT_EQ(pthread_create(&tid, &attr, ThreadPublic, nullptr), 0) << "> return errno"; in HWTEST_F()
47 EXPECT_EQ(pthread_join(tid, nullptr), EINVAL) << "> return errno"; in HWTEST_F()
55 ASSERT_EQ(pthread_create(&tid, &attr, ThreadPublic, nullptr), 0) << "> return errno"; in HWTEST_F()
57 EXPECT_EQ(pthread_join(tid, nullptr), 0) << "> return errno"; in HWTEST_F()
80 pthread_t tid; in HWTEST_F() local
93 ASSERT_EQ(pthread_create(&tid, &attr, ThreadPthreadAttrSetscope, nullptr), 0) << "> return errno"; in HWTEST_F()
96 pthread_join(tid, nullptr); in HWTEST_F()
120 pthread_t tid; in HWTEST_F() local
133 ASSERT_EQ(pthread_create(&tid, in HWTEST_F()
163 pthread_t tid; HWTEST_F() local
220 pthread_t tid; HWTEST_F() local
296 pthread_t tid; HWTEST_F() local
[all...]
/test/xts/acts/kernel_lite/futex_posix/src/
H A DPthreadRwlockTest.cpp60 pthread_t tid[2]; in HWTEST_F() local
64 EXPECT_EQ(pthread_create(&tid[0], nullptr, PthreadRWlockWW1, nullptr), 0) << "> return errno"; in HWTEST_F()
65 EXPECT_EQ(pthread_create(&tid[1], nullptr, PthreadRWlockWW2, nullptr), 0) << "> return errno"; in HWTEST_F()
67 EXPECT_EQ(pthread_join(tid[0], nullptr), 0) << "> return errno"; in HWTEST_F()
68 EXPECT_EQ(pthread_join(tid[1], nullptr), 0) << "> return errno"; in HWTEST_F()
102 pthread_t tid[2]; in HWTEST_F() local
106 EXPECT_EQ(pthread_create(&tid[0], nullptr, PthreadRWlockWR1, nullptr), 0) << "> return errno"; in HWTEST_F()
107 EXPECT_EQ(pthread_create(&tid[1], nullptr, PthreadRWlockWR2, nullptr), 0) << "> return errno"; in HWTEST_F()
109 EXPECT_EQ(pthread_join(tid[0], nullptr), 0) << "> return errno"; in HWTEST_F()
110 EXPECT_EQ(pthread_join(tid[ in HWTEST_F()
144 pthread_t tid[2]; HWTEST_F() local
186 pthread_t tid[2]; HWTEST_F() local
227 pthread_t tid[2]; HWTEST_F() local
268 pthread_t tid[2]; HWTEST_F() local
312 pthread_t tid[2]; HWTEST_F() local
362 pthread_t tid[2]; HWTEST_F() local
412 pthread_t tid[2]; HWTEST_F() local
456 pthread_t tid[2]; HWTEST_F() local
[all...]
H A DPthreadCondTest.cpp140 pthread_t tid[2]; in HWTEST_F() local
143 ASSERT_EQ(pthread_create(&tid[0], nullptr, ThreadPthreadCondSignalBefore1, nullptr), 0) << "> return errno"; in HWTEST_F()
144 ASSERT_EQ(pthread_create(&tid[1], nullptr, ThreadPthreadCondSignalBefore2, nullptr), 0) << "> return errno"; in HWTEST_F()
147 pthread_join(tid[0], nullptr); in HWTEST_F()
148 pthread_join(tid[1], nullptr); in HWTEST_F()
185 pthread_t tid[2]; in HWTEST_F() local
188 ASSERT_EQ(pthread_create(&tid[0], nullptr, ThreadTestCondSignalWaitAfter1, nullptr), 0) << "> return errno"; in HWTEST_F()
189 ASSERT_EQ(pthread_create(&tid[1], nullptr, ThreadTestCondSignalWaitAfter2, nullptr), 0) << "> return errno"; in HWTEST_F()
192 pthread_join(tid[0], nullptr); in HWTEST_F()
193 pthread_join(tid[ in HWTEST_F()
232 pthread_t tid[3]; HWTEST_F() local
332 pthread_t tid; HWTEST_F() local
370 pthread_t tid; HWTEST_F() local
[all...]
H A DPthreadMutexTest.cpp54 pthread_t tid[loopNum]; in HWTEST_F() local
59 EXPECT_EQ(pthread_create(&tid[i], nullptr, ThreadMutex, (void*)&mtx), 0) << "> return errno"; in HWTEST_F()
62 EXPECT_EQ(pthread_join(tid[i], nullptr), 0) << "> return errno"; in HWTEST_F()
98 pthread_t tid[2]; in HWTEST_F() local
102 EXPECT_EQ(pthread_create(&tid[0], nullptr, ThreadMtrylock1, (void*)&mtx), 0) << "> return errno"; in HWTEST_F()
103 EXPECT_EQ(pthread_create(&tid[1], nullptr, ThreadMtrylock2, (void*)&mtx), 0) << "> return errno"; in HWTEST_F()
105 EXPECT_EQ(pthread_join(tid[0], nullptr), 0) << "> return errno"; in HWTEST_F()
106 EXPECT_EQ(pthread_join(tid[1], nullptr), 0) << "> return errno"; in HWTEST_F()
173 pthread_t tid[2]; in HWTEST_F() local
175 EXPECT_EQ(pthread_create(&tid[ in HWTEST_F()
211 pthread_t tid; HWTEST_F() local
248 pthread_t tid; HWTEST_F() local
319 pthread_t tid; HWTEST_F() local
396 pthread_t tid; HWTEST_F() local
508 pthread_t tid[loopNum]; HWTEST_F() local
552 pthread_t tid[2]; HWTEST_F() local
[all...]
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/pipeline/
H A Dsk_resource_manager.cpp31 auto tid = gettid(); in HoldResource() local
32 if (!RSTaskDispatcher::GetInstance().HasRegisteredTask(tid)) { in HoldResource()
36 if (images_.find(tid) != images_.end()) { in HoldResource()
37 images_[tid]->HoldResource(img); in HoldResource()
41 images_.emplace(tid, holder); in HoldResource()
49 auto tid = gettid(); in HoldResource() local
50 if (!RSTaskDispatcher::GetInstance().HasRegisteredTask(tid)) { in HoldResource()
54 if (std::any_of(skSurfaces_[tid].cbegin(), skSurfaces_[tid].cend(), in HoldResource()
58 skSurfaces_[tid] in HoldResource()
[all...]
H A Drs_task_dispatcher.cpp27 void RSTaskDispatcher::RegisterTaskDispatchFunc(pid_t tid, const std::function<void(RSTask, bool)>& taskDispatchFunc) in RegisterTaskDispatchFunc() argument
30 taskDispatchFuncMap_.emplace(tid, taskDispatchFunc); in RegisterTaskDispatchFunc()
34 void RSTaskDispatcher::PostTask(pid_t tid, const RSTask& task, bool isSyncTask) in PostTask() argument
36 if (taskDispatchFuncMap_.count(tid)) { in PostTask()
37 taskDispatchFuncMap_.at(tid)(task, isSyncTask); in PostTask()
45 bool RSTaskDispatcher::HasRegisteredTask(pid_t tid) const in HasRegisteredTask()
47 if (taskDispatchFuncMap_.count(tid)) { in HasRegisteredTask()
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/
H A Dthread_utils.cpp25 void SetThreadName(pthread_t tid, const std::string& name) in SetThreadName() argument
32 int ret = pthread_setname_np(tid, threadName.c_str()); in SetThreadName()
34 static_cast<long>(pthread_gettid_np(tid)), threadName.c_str(), ret); in SetThreadName()
39 pid_t tid = pthread_gettid_np(handle); in SetThreadPriority() local
40 int currPri = getpriority(PRIO_PROCESS, tid); in SetThreadPriority()
44 int ret = setpriority(PRIO_PROCESS, tid, priority); in SetThreadPriority()
46 DP_DEBUG_LOG("succeed for tid (%ld) with priority (%{public}d).", static_cast<long>(tid), priority); in SetThreadPriority()
48 DP_DEBUG_LOG("failed for tid (%ld) with priority (%{public}d), ret = %{public}d.", in SetThreadPriority()
49 static_cast<long>(tid), priorit in SetThreadPriority()
55 pid_t tid = pthread_gettid_np(handle); GetThreadPriority() local
[all...]
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/framework/process_group/src/
H A Dsched_policy.cpp28 int SetThreadSchedPolicy(int tid, int policy) in SetThreadSchedPolicy() argument
30 if (tid < 0) { in SetThreadSchedPolicy()
33 if (tid == 0) { in SetThreadSchedPolicy()
34 tid = gettid(); in SetThreadSchedPolicy()
37 int ret = CgroupAction::GetInstance().SetThreadSchedPolicy(tid, schedPolicy) ? 0 : -1; in SetThreadSchedPolicy()
39 ret = CgroupAction::GetInstance().SetSchedPolicyByExecutor(tid, policy, in SetThreadSchedPolicy()
62 int GetThreadSchedPolicy(int tid, SchedPolicy* policy) in GetThreadSchedPolicy() argument
64 if (tid < 0) { in GetThreadSchedPolicy()
67 if (tid == 0) { in GetThreadSchedPolicy()
68 tid in GetThreadSchedPolicy()
[all...]
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_rtg.cpp173 pid_t tid = RTGCtrl::GetTID(); in HWTEST_F()
177 tids.emplace_back(tid); in HWTEST_F()
195 for (auto tid : tids) { in HWTEST_F()
196 ret = RTGCtrl::Instance().JoinThread(tgid, tid); in HWTEST_F()
198 FFRT_LOGE("Failed To Join Thread %d", tid); in HWTEST_F()
203 for (auto tid : tids) { in HWTEST_F()
204 auto [t_load, t_runtime] = RTGCtrl::Instance().UpdateAndGetLoad(tgid, tid); in HWTEST_F()
206 ret = RTGCtrl::Instance().RemoveThread(tgid, tid); in HWTEST_F()
208 FFRT_LOGE("Failed To Leave Thread %d", tid); in HWTEST_F()
241 pid_t tid in HWTEST_F()
[all...]
/foundation/resourceschedule/ffrt/src/eu/
H A Dworker_manager.cpp25 pid_t tid = thread.first->Id(); in JoinRtg() local
26 if (!JoinWG(tid)) { in JoinRtg()
27 FFRT_LOGE("Failed to Join Thread %d", tid); in JoinRtg()
51 pid_t tid = thread.first->Id(); in JoinTG() local
52 if (!(tgwrap.tg->Join(tid))) { in JoinTG()
53 FFRT_LOGE("Failed to Join Thread %d", tid); in JoinTG()
75 pid_t tid = thread.first->Id(); in LeaveTG() local
76 if (!(tgwrap.tg->Leave(tid))) { in LeaveTG()
77 FFRT_LOGE("Failed to Leave Thread %d", tid); in LeaveTG()
H A Dworker_thread.h98 while (!exited && tid < 0) { in Id()
100 return tid; in Id()
136 if (tid > 0) { in Join()
139 tid = -1; in Join()
144 if (tid > 0) { in Detach()
149 tid = -1; in Detach()
172 tid = -1; in Join()
182 tid = -1; in Detach()
198 std::atomic<pid_t> tid; member in ffrt::WorkerThread
H A Dqos_interface.cpp219 int tid = GET_TID(); in FFRTQosApply() local
222 ret = FFRTQosApplyForOther(level, tid); in FFRTQosApply()
226 int FFRTQosApplyForOther(unsigned int level, int tid) in FFRTQosApplyForOther() argument
240 data.pid = tid; in FFRTQosApplyForOther()
244 FFRT_LOGW("qos apply warn for tid %d, ret:%d, eno:%d, %s\n", tid, ret, errno, strerror(errno)); in FFRTQosApplyForOther()
273 int FFRTQosLeaveForOther(int tid) in FFRTQosLeaveForOther() argument
285 data.pid = tid; in FFRTQosLeaveForOther()
289 FFRT_LOGE("qos leave failed for task %d\n", tid); in FFRTQosLeaveForOther()
314 int FFRTThreadCtrl(int tid, struc argument
334 int tid = GET_TID(); FFRTQosGet() local
338 FFRTQosGetForOther(int tid, struct QosCtrlData &data) FFRTQosGetForOther() argument
[all...]
/foundation/ability/ability_runtime/test/unittest/lifecycle_test/
H A Dlifecycle_test.cpp154 pthread_t tid = 0; in HWTEST_F() local
155 pthread_create(&tid, nullptr, LifecycleTest::AbilityStartThread, command_.get()); in HWTEST_F()
161 pthread_join(tid, nullptr); in HWTEST_F()
184 pthread_t tid = 0; in HWTEST_F() local
185 pthread_create(&tid, nullptr, LifecycleTest::AbilityStartThread, command_.get()); in HWTEST_F()
191 pthread_join(tid, nullptr); in HWTEST_F()
194 pthread_join(tid, nullptr); in HWTEST_F()
217 pthread_t tid = 0; in HWTEST_F() local
219 pthread_create(&tid, nullptr, LifecycleTest::AbilityStartThread, command_.get()); in HWTEST_F()
225 pthread_join(tid, nullpt in HWTEST_F()
253 pthread_t tid = 0; HWTEST_F() local
282 pthread_t tid = 0; HWTEST_F() local
337 pthread_t tid = 0; HWTEST_F() local
400 pthread_t tid = 0; HWTEST_F() local
433 pthread_t tid = 0; HWTEST_F() local
469 pthread_t tid = 0; HWTEST_F() local
[all...]
/foundation/resourceschedule/qos_manager/test/unittest/phone/
H A Dconcurrent_task_controller_test.cpp236 int tid = gettid(); in HWTEST_F() local
237 fore.NewForeground(uid, tid); in HWTEST_F()
238 fore.NewBackground(uid, tid); in HWTEST_F()
239 fore.NewAppStart(uid, tid, ""); in HWTEST_F()
240 fore.NewForeground(uid, tid); in HWTEST_F()
241 fore.NewBackground(uid, tid); in HWTEST_F()
242 fore.ContinuousTaskProcess(uid, tid, static_cast<int>(MSG_CONTINUOUS_TASK_START)); in HWTEST_F()
243 fore.FocusStatusProcess(uid, tid, static_cast<int>(MSG_GET_FOCUS)); in HWTEST_F()
244 fore.FocusStatusProcess(uid, tid, static_cast<int>(MSG_LOSE_FOCUS)); in HWTEST_F()
245 fore.AppKilled(uid, tid); in HWTEST_F()
285 int tid = 45; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/relational_store/frameworks/js/napi/common/src/
H A Djs_df_manager.cpp41 auto tid = it->second; in GetFreedTid() local
42 if (tid != 0) { in GetFreedTid()
43 freedTid = tid; in GetFreedTid()
46 tid = 0; in GetFreedTid()
48 tid = gettid(); in GetFreedTid()
50 instances_[data] = tid; in GetFreedTid()
/foundation/resourceschedule/qos_manager/interfaces/inner_api/
H A Dqos.h36 int SetThreadQosForOtherThread(enum QosLevel level, int tid);
37 int ResetThreadQosForOtherThread(int tid);
38 int GetThreadQosForOtherThread(enum QosLevel &level, int tid);
51 int SetQosForOtherThread(enum QosLevel level, int tid);
53 int ResetQosForOtherThread(int tid);
55 int GetQosForOtherThread(enum QosLevel &level, int tid);
/test/xts/acts/kernel_lite/time_posix/src/
H A DAlarmTest.cpp218 timer_t tid = nullptr; in HWTEST_F() local
225 EXPECT_EQ(timer_create(CLOCK_REALTIME, &ev, &tid), 0) << "ERROR: timer_create() != 0"; in HWTEST_F()
226 LOG("tid = %p", tid); in HWTEST_F()
232 EXPECT_EQ(timer_settime(tid, 0, &its, NULL), 0) << "ERROR: timer_settime() != 0"; in HWTEST_F()
237 EXPECT_EQ(timer_delete(tid), 0) << "ERROR: timer_delete() != 0"; in HWTEST_F()
250 timer_t tid = nullptr; in HWTEST_F() local
254 EXPECT_EQ(timer_create(CLOCK_REALTIME, NULL, &tid), 0) << "ERROR: timer_create() != 0"; in HWTEST_F()
255 LOG("tid = %p", tid); in HWTEST_F()
293 timer_t tid = NULL; HWTEST_F() local
338 timer_t tid = nullptr; HWTEST_F() local
377 timer_t tid = nullptr; HWTEST_F() local
391 timer_t tid = nullptr; HWTEST_F() local
452 timer_t tid = nullptr; HWTEST_F() local
[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)
79 def replace_sched_switch_log(fake_log, mark, pid, label, gid, tid):
83 if "prev_pid=%d" % tid in mark:
90 elif "next_pid=%d" % tid in mark:
128 def convert_worker_log_to_task(mark, pid, label, gid, tid):
135 return replace_sched_switch_log(fake_log, mark, pid, label, gid, tid)
[all...]
/foundation/resourceschedule/qos_manager/services/src/
H A Dqos_interface.cpp234 int tid = gettid(); in QosApply() local
237 ret = QosApplyForOther(level, tid); in QosApply()
241 int QosApplyForOther(unsigned int level, int tid) in QosApplyForOther() argument
255 data.pid = tid; in QosApplyForOther()
259 CONCUR_LOGE("[Interface] task %{public}d apply qos failed, errno = %{public}d", tid, errno); in QosApplyForOther()
287 int QosLeaveForOther(int tid) in QosLeaveForOther() argument
299 data.pid = tid; in QosLeaveForOther()
303 CONCUR_LOGE("[Interface] task %{public}d leave qos failed, errno = %{public}d", tid, errno); in QosLeaveForOther()
329 int tid = gettid(); in QosGet() local
330 return QosGetForOther(tid, leve in QosGet()
333 QosGetForOther(int tid, int &level) QosGetForOther() argument
[all...]
/foundation/ability/ability_runtime/frameworks/native/runtime/
H A Dconnect_server_manager.cpp26 const std::string& messageType, int32_t instanceId, const std::string& instanceName, int32_t tid) in GetInstanceMapMessage()
35 message.append("\",\"tid\":"); in GetInstanceMapMessage()
36 message.append(std::to_string(tid)); in GetInstanceMapMessage()
135 bool ConnectServerManager::StoreInstanceMessage(int32_t tid, int32_t instanceId, const std::string& instanceName) in StoreInstanceMessage() argument
139 auto result = instanceMap_.try_emplace(instanceId, std::make_pair(instanceName, tid)); in StoreInstanceMessage()
148 void ConnectServerManager::StoreDebuggerInfo(int32_t tid, void* vm, const panda::JSNApi::DebugOption& debugOption, in StoreDebuggerInfo() argument
152 if (g_debuggerInfo.find(tid) == g_debuggerInfo.end()) { in StoreDebuggerInfo()
153 g_debuggerInfo.emplace(tid, std::make_pair(vm, debuggerPostTask)); in StoreDebuggerInfo()
161 panda::JSNApi::StoreDebugInfo(tid, reinterpret_cast<panda::EcmaVM*>(vm), debugOption, debuggerPostTask, isDebugApp); in StoreDebuggerInfo()
171 auto tid in SendDebuggerInfo() local
25 GetInstanceMapMessage( const std::string& messageType, int32_t instanceId, const std::string& instanceName, int32_t tid) GetInstanceMapMessage() argument
246 SendInstanceMessage(int32_t tid, int32_t instanceId, const std::string& instanceName) SendInstanceMessage() argument
263 AddInstance(int32_t tid, int32_t instanceId, const std::string& instanceName) AddInstance() argument
310 int32_t tid; RemoveInstance() local
408 GetDebuggerPostTask(int32_t tid) GetDebuggerPostTask() argument
[all...]

Completed in 11 milliseconds

1234567891011