/foundation/resourceschedule/qos_manager/qos/ |
H A D | qos.cpp | 36 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...] |
/test/xts/acts/kernel_lite/process_posix/src/ |
H A D | PthreadBasicApiTest.cpp | 42 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 D | PthreadAttrTest.cpp | 35 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...] |
/foundation/resourceschedule/ffrt/src/sched/ |
H A D | multi_workgroup.cpp | 48 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 D | workgroup_internal.h | 50 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/multimedia/audio_framework/frameworks/native/audioschedule/ |
H A D | audio_schedule.cpp | 51 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...] |
/third_party/musl/libc-test/src/functionalext/thread/ |
H A D | pthread_rwlock_rdlock.c | 48 pthread_t tid[2]; in pthread_rwlock_clockrdlock_0010() local 51 TEST(pthread_create(&tid[0], NULL, PthreadClockRdlockNoOutRealTimeW1, NULL) == 0); in pthread_rwlock_clockrdlock_0010() 52 TEST(pthread_create(&tid[1], NULL, PthreadClockRdlockNoOutRealTimeR2, NULL) == 0); in pthread_rwlock_clockrdlock_0010() 54 TEST(pthread_join(tid[0], NULL) == 0); in pthread_rwlock_clockrdlock_0010() 55 TEST(pthread_join(tid[1], NULL) == 0); in pthread_rwlock_clockrdlock_0010() 92 pthread_t tid[2]; in pthread_rwlock_clockrdlock_0020() local 95 TEST(pthread_create(&tid[0], NULL, PthreadClockRdlockOutRealTimeW1, NULL) == 0); in pthread_rwlock_clockrdlock_0020() 96 TEST(pthread_create(&tid[1], NULL, PthreadClockRdlockOutRealTimeR2, NULL) == 0); in pthread_rwlock_clockrdlock_0020() 98 TEST(pthread_join(tid[0], NULL) == 0); in pthread_rwlock_clockrdlock_0020() 99 TEST(pthread_join(tid[ in pthread_rwlock_clockrdlock_0020() 133 pthread_t tid[2]; pthread_rwlock_clockrdlock_0030() local 177 pthread_t tid[2]; pthread_rwlock_clockrdlock_0040() local 217 pthread_t tid[2]; pthread_rwlock_timedrdlock_monotonic_np_0010() local 261 pthread_t tid[2]; pthread_rwlock_timedrdlock_monotonic_np_0020() local [all...] |
H A D | pthread_rwlock_wrlock.c | 253 pthread_t tid[2]; in pthread_rwlock_timedwrlock_0050() local 256 EXPECT_EQ(pthread_create(&tid[0], NULL, RwlockClockRealTimeWait1, NULL), 0); in pthread_rwlock_timedwrlock_0050() 257 EXPECT_EQ(pthread_create(&tid[1], NULL, RwlockClockRealTimeWait2, NULL), 0); in pthread_rwlock_timedwrlock_0050() 259 EXPECT_EQ(pthread_join(tid[0], NULL), 0); in pthread_rwlock_timedwrlock_0050() 260 EXPECT_EQ(pthread_join(tid[1], NULL), 0); in pthread_rwlock_timedwrlock_0050() 271 pthread_t tid[2]; in pthread_rwlock_timedwrlock_0060() local 274 EXPECT_EQ(pthread_create(&tid[0], NULL, RwlockClockRealTimeOut1, NULL), 0); in pthread_rwlock_timedwrlock_0060() 275 EXPECT_EQ(pthread_create(&tid[1], NULL, RwlockClockRealTimeOut2, NULL), 0); in pthread_rwlock_timedwrlock_0060() 277 EXPECT_EQ(pthread_join(tid[0], NULL), 0); in pthread_rwlock_timedwrlock_0060() 278 EXPECT_EQ(pthread_join(tid[ in pthread_rwlock_timedwrlock_0060() 289 pthread_t tid[2]; pthread_rwlock_timedwrlock_0070() local 307 pthread_t tid[2]; pthread_rwlock_timedwrlock_0080() local 325 pthread_t tid[2]; pthread_rwlock_timedwrlock_0090() local 343 pthread_t tid[2]; pthread_rwlock_timedwrlock_0100() local [all...] |
H A D | pthread_mutex_ext.c | 45 pthread_t tid; in pthread_mutex_clocklock_0010() local 46 TEST(pthread_create(&tid, NULL, PthreadClocklockOutRealTime, (void*)&mtx) == 0); in pthread_mutex_clocklock_0010() 53 TEST(pthread_join(tid, NULL) == 0); in pthread_mutex_clocklock_0010() 77 pthread_t tid; in pthread_mutex_clocklock_0020() local 78 TEST(pthread_create(&tid, NULL, PthreadClocklockNoOutRealTime, (void*)&mtx) == 0); in pthread_mutex_clocklock_0020() 84 TEST(pthread_join(tid, NULL) == 0); in pthread_mutex_clocklock_0020() 113 pthread_t tid; in pthread_mutex_clocklock_0030() local 114 TEST(pthread_create(&tid, NULL, PthreadClocklockOutMonoTime, (void*)&mtx) == 0); in pthread_mutex_clocklock_0030() 121 TEST(pthread_join(tid, NULL) == 0); in pthread_mutex_clocklock_0030() 145 pthread_t tid; in pthread_mutex_clocklock_0040() local 185 pthread_t tid; pthread_mutex_clocklock_0050() local 217 pthread_t tid; pthread_mutex_clocklock_0060() local 260 pthread_t tid; pthread_mutex_timedlock_monotonic_np_0010() local 292 pthread_t tid; pthread_mutex_timedlock_monotonic_np_0020() local 343 pthread_t tid; pthread_mutex_lock_timeout_np_0010() local 376 pthread_t tid; pthread_mutex_lock_timeout_np_0020() local [all...] |
/third_party/alsa-lib/src/timer/ |
H A D | timer_query.c | 215 * \param tid timer identification 218 * if tid->dev_class is -1, then the first device is returned 219 * if result tid->dev_class is -1, no more devices are left 221 int snd_timer_query_next_device(snd_timer_query_t *timer, snd_timer_id_t *tid) in snd_timer_query_next_device() argument 224 assert(tid); in snd_timer_query_next_device() 225 return timer->ops->next_device(timer, tid); in snd_timer_query_next_device() 281 * \param tid pointer to #snd_timer_id_t structure 284 int snd_timer_ginfo_set_tid(snd_timer_ginfo_t *obj, snd_timer_id_t *tid) in snd_timer_ginfo_set_tid() argument 286 obj->tid = *((snd_timer_id_t *)tid); in snd_timer_ginfo_set_tid() 489 snd_timer_id_set_class(snd_timer_id_t * tid, int dev_class) snd_timer_id_set_class() argument 500 snd_timer_id_get_class(snd_timer_id_t * tid) snd_timer_id_get_class() argument 511 snd_timer_id_set_sclass(snd_timer_id_t * tid, int dev_sclass) snd_timer_id_set_sclass() argument 522 snd_timer_id_get_sclass(snd_timer_id_t * tid) snd_timer_id_get_sclass() argument 533 snd_timer_id_set_card(snd_timer_id_t * tid, int card) snd_timer_id_set_card() argument 544 snd_timer_id_get_card(snd_timer_id_t * tid) snd_timer_id_get_card() argument 555 snd_timer_id_set_device(snd_timer_id_t * tid, int device) snd_timer_id_set_device() argument 566 snd_timer_id_get_device(snd_timer_id_t * tid) snd_timer_id_get_device() argument 577 snd_timer_id_set_subdevice(snd_timer_id_t * tid, int subdevice) snd_timer_id_set_subdevice() argument 588 snd_timer_id_get_subdevice(snd_timer_id_t * tid) snd_timer_id_get_subdevice() argument [all...] |
/test/xts/acts/kernel_lite/futex_posix/src/ |
H A D | PthreadRwlockTest.cpp | 60 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 D | PthreadMutexTest.cpp | 54 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...] |
H A D | PthreadCondTest.cpp | 140 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...] |
/third_party/musl/src/malloc/liteos_a/user_debug/ |
H A D | memory_check.c | 65 static inline void lock_stat_bin(int tid) in lock_stat_bin() argument 67 lock(mem_stat.bins[tid].lock); in lock_stat_bin() 68 if (!mem_stat.bins[tid].head.next) in lock_stat_bin() 69 mem_stat.bins[tid].head.next = mem_stat.bins[tid].head.prev = &mem_stat.bins[tid].head; in lock_stat_bin() 72 static inline void unlock_stat_bin(int tid) in unlock_stat_bin() argument 74 unlock(mem_stat.bins[tid].lock); in unlock_stat_bin() 88 static int try_delete_node(int tid, void *ptr) in try_delete_node() argument 93 lock_stat_bin(tid); in try_delete_node() 113 int tid = ((struct pthread *)pthread_self())->tid; delete_node() local 179 create_node(int tid, void *ptr, size_t size) create_node() argument 203 int tid = ((struct pthread *)pthread_self())->tid; insert_node() local 355 check_mem_integrity(int tid, void *ptr) check_mem_integrity() argument 396 int tid = ((struct pthread *)pthread_self())->tid; get_integrity_info() local 506 int tid = ((struct pthread *)pthread_self())->tid; get_free_trace() local 546 int tid, ret; watch_mem() local 686 int tid, nptr; check_leak() local [all...] |
/third_party/musl/porting/liteos_a/user_debug/src/malloc/ |
H A D | memory_check.c | 50 static inline void lock_stat_bin(int tid) in lock_stat_bin() argument 52 lock(mem_stat.bins[tid].lock); in lock_stat_bin() 53 if (!mem_stat.bins[tid].head.next) in lock_stat_bin() 54 mem_stat.bins[tid].head.next = mem_stat.bins[tid].head.prev = &mem_stat.bins[tid].head; in lock_stat_bin() 57 static inline void unlock_stat_bin(int tid) in unlock_stat_bin() argument 59 unlock(mem_stat.bins[tid].lock); in unlock_stat_bin() 73 static int try_delete_node(int tid, void *ptr) in try_delete_node() argument 78 lock_stat_bin(tid); in try_delete_node() 98 int tid = ((struct pthread *)pthread_self())->tid; delete_node() local 164 create_node(int tid, void *ptr, size_t size) create_node() argument 188 int tid = ((struct pthread *)pthread_self())->tid; insert_node() local 340 check_mem_integrity(int tid, void *ptr) check_mem_integrity() argument 381 int tid = ((struct pthread *)pthread_self())->tid; get_integrity_info() local 491 int tid = ((struct pthread *)pthread_self())->tid; get_free_trace() local 531 int tid, ret; watch_mem() local 671 int tid, nptr; check_leak() local [all...] |
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/pipeline/ |
H A D | sk_resource_manager.cpp | 31 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 D | rs_task_dispatcher.cpp | 27 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()
|
/third_party/musl/src/sched/ |
H A D | affinity.c | 7 int sched_setaffinity(pid_t tid, size_t size, const cpu_set_t *set) in sched_setaffinity() argument 14 return syscall(SYS_sched_setaffinity, tid, (unsigned short)(set->__bits[0]), MUSL_TYPE_PROCESS); in sched_setaffinity() 16 return syscall(SYS_sched_setaffinity, tid, size, set); in sched_setaffinity() 26 return -__syscall(SYS_sched_setaffinity, td->tid, (unsigned short)(set->__bits[0]), MUSL_TYPE_THREAD); in pthread_setaffinity_np() 28 return -__syscall(SYS_sched_setaffinity, td->tid, size, set); in pthread_setaffinity_np() 33 static int do_getaffinity(pid_t tid, size_t size, cpu_set_t *set, int flag) in do_getaffinity() argument 39 int ret = __syscall(SYS_sched_getaffinity, tid, &cpuset, flag); in do_getaffinity() 47 static int do_getaffinity(pid_t tid, size_t size, cpu_set_t *set) in do_getaffinity() argument 49 long ret = __syscall(SYS_sched_getaffinity, tid, size, set); in do_getaffinity() 56 int sched_getaffinity(pid_t tid, size_ argument [all...] |
/third_party/ltp/testcases/realtime/func/prio-preempt/ |
H A D | prio-preempt.c | 138 int policy, mypri = 0, tid; in busy_thread() local 139 tid = (intptr_t) (((struct thread *)arg)->arg); in busy_thread() 149 printf("Busy Thread %d(%d): Running...\n", tid, mypri); in busy_thread() 157 printf("Busy Thread %d(%d): Exiting\n", tid, mypri); in busy_thread() 164 int policy, rc, mypri = 0, tid, times = 0; in worker_thread() local 165 tid = (intptr_t) (((struct thread *)arg)->arg); in worker_thread() 179 rc = pthread_mutex_lock(&mutex[tid]); in worker_thread() 180 if (tid == 0) in worker_thread() 182 rc = pthread_cond_wait(&cond[tid], &mutex[tid]); in worker_thread() [all...] |
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/ |
H A D | thread_utils.cpp | 25 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 D | sched_policy.cpp | 28 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/ability/ability_runtime/test/unittest/lifecycle_test/ |
H A D | lifecycle_test.cpp | 154 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 D | concurrent_task_controller_test.cpp | 236 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/resourceschedule/ffrt/test/ut/testcase/ |
H A D | ut_rtg.cpp | 173 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...] |
/third_party/elfutils/libdwfl/ |
H A D | linux-pid-attach.c | 75 __libdwfl_ptrace_attach (pid_t tid, bool *tid_was_stoppedp) in __libdwfl_ptrace_attach() argument 77 if (ptrace (PTRACE_ATTACH, tid, NULL, NULL) != 0) in __libdwfl_ptrace_attach() 82 *tid_was_stoppedp = linux_proc_pid_is_stopped (tid); in __libdwfl_ptrace_attach() 91 syscall (__NR_tkill, tid, SIGSTOP); in __libdwfl_ptrace_attach() 92 ptrace (PTRACE_CONT, tid, NULL, NULL); in __libdwfl_ptrace_attach() 97 if (waitpid (tid, &status, __WALL) != tid || !WIFSTOPPED (status)) in __libdwfl_ptrace_attach() 100 ptrace (PTRACE_DETACH, tid, NULL, NULL); in __libdwfl_ptrace_attach() 107 if (ptrace (PTRACE_CONT, tid, NULL, in __libdwfl_ptrace_attach() 111 ptrace (PTRACE_DETACH, tid, NUL in __libdwfl_ptrace_attach() 196 pid_t tid = pid_arg->tid_attached; pid_memory_read() local 281 pid_t tid = tidl; pid_next_thread() local 293 pid_getthread(Dwfl *dwfl __attribute__ ((unused)), pid_t tid, void *dwfl_arg, void **thread_argp) pid_getthread() argument 328 pid_t tid = INTUSE(dwfl_thread_tid) (thread); pid_set_initial_registers() local 352 __libdwfl_ptrace_detach(pid_t tid, bool tid_was_stopped) __libdwfl_ptrace_detach() argument 367 pid_t tid = INTUSE(dwfl_thread_tid) (thread); pid_thread_detach() local [all...] |