Home
last modified time | relevance | path

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

12345678910

/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...]
/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/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...]
H A Dthread_group.h85 bool Join(pid_t tid) in Join() argument
90 return RTGCtrl::Instance().JoinThread(tgid, tid); in Join()
101 bool Leave(pid_t tid) in Leave() argument
106 return RTGCtrl::Instance().RemoveThread(tgid, tid); in Leave()
133 RTGLoadInfo GetLoad(pid_t tid) in GetLoad() argument
138 return RTGCtrl::Instance().UpdateAndGetLoad(tgid, tid); in GetLoad()
H A Drtg_perf_ctrl.cpp48 void SetTaskRtg(pid_t tid, unsigned int grpId) in SetTaskRtg() argument
50 struct RtgGroupTask data = {tid, grpId, 0}; in SetTaskRtg()
57 FFRT_LOGW("Error set rtg %d,%u. %s", tid, grpId, strerror(errno)); in SetTaskRtg()
117 void set_task_min_util(pid_t tid, unsigned int util) in set_task_min_util() argument
119 struct TaskConfig cfg = {tid, util}; in set_task_min_util()
126 FFRT_LOGW("Error set min util %d,%u. %s", tid, util, strerror(errno)); in set_task_min_util()
/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/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/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);
/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/multimedia/audio_framework/frameworks/native/audioschedule/include/
H A Daudio_schedule.h25 void ScheduleReportData(uint32_t pid, uint32_t tid, const char *bundleName);
26 void ScheduleThreadInServer(uint32_t pid, uint32_t tid);
27 void UnscheduleThreadInServer(uint32_t pid, uint32_t tid);
29 void UnscheduleReportData(uint32_t pid, uint32_t tid, const char* bundleName);
/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/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/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...]
/foundation/arkui/napi/native_engine/
H A Dnative_api_internal.h84 ThreadId tid = NativeEngine::GetCurSysTid(); \
85 if (tid != engine->GetSysTid()) { \
88 engine->GetSysTid(), tid); \
97 ThreadId tid = NativeEngine::GetCurSysTid(); \
98 if (tid != engine->GetSysTid()) { \
101 engine->GetSysTid(), tid); \
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/fuzztest/rstaskdispatcher_fuzzer/
H A Drstaskdispatcher_fuzzer.cpp67 int tid = GetData<int>(); in DoRegisterTaskDispatchFunc() local
75 RSTaskDispatcher::GetInstance().RegisterTaskDispatchFunc(tid, taskDispatchFunc); in DoRegisterTaskDispatchFunc()
89 int tid = GetData<int>(); in DoPostTask() local
92 RSTaskDispatcher::GetInstance().PostTask(tid, task); in DoPostTask()
106 int tid = GetData<int>(); in DoHasRegisteredTask() local
107 RSTaskDispatcher::GetInstance().HasRegisteredTask(tid); in DoHasRegisteredTask()
/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/
H A Dnstackx_dfile_send.c53 static IovList *GetFreeIovList(DFileSession *s, int32_t tid) in GetFreeIovList() argument
55 List *p = &s->freeIovList[tid]; in GetFreeIovList()
69 void DestroyIovList(const List *head, DFileSession *s, uint32_t tid) in DestroyIovList() argument
76 (void)tid; in DestroyIovList()
125 static int32_t SendFileDataFrame(DFileSession *session, PeerInfo *peerInfo, List *head, uint32_t tid) in SendFileDataFrame() argument
164 DestroyIovList(head, session, tid); in SendFileDataFrame()
169 static int32_t SendFileDataFrameEx(DFileSession *session, PeerInfo *peerInfo, List *head, uint32_t tid) in SendFileDataFrameEx() argument
171 return SendFileDataFrame(session, peerInfo, head, tid); in SendFileDataFrameEx()
196 static int32_t DoSendDataFrame(DFileSession *session, List *head, int32_t count, uint32_t tid, uint8_t socketIndex) in DoSendDataFrame() argument
208 ret = FileManagerFileRead(session->fileManager, tid, in DoSendDataFrame()
249 CheckSendByBackPress(DFileSession *session, uint32_t tid, uint8_t socketIndex) CheckSendByBackPress() argument
294 SendDataFrame(DFileSession *session, List *unsent, uint32_t tid, uint8_t socketIndex) SendDataFrame() argument
[all...]

Completed in 9 milliseconds

12345678910