/ohos5.0/foundation/resourceschedule/qos_manager/qos/ |
H A D | qos.cpp | 36 int QosController::SetThreadQosForOtherThread(enum QosLevel level, int tid) in SetThreadQosForOtherThread() argument 50 int ret = QosApplyForOther(qos, tid); in SetThreadQosForOtherThread() 60 int QosController::ResetThreadQosForOtherThread(int tid) in ResetThreadQosForOtherThread() argument 69 int ret = QosLeaveForOther(tid); in ResetThreadQosForOtherThread() 82 int ret = QosGetForOther(tid, qos); in GetThreadQosForOtherThread() 86 CONCUR_LOGE("[Qos] not set qoslevel for tid %{public}d", tid); in GetThreadQosForOtherThread() 100 int tid = gettid(); in SetThreadQos() local 104 int SetQosForOtherThread(enum QosLevel level, int tid) in SetQosForOtherThread() argument 111 int tid = gettid(); in ResetThreadQos() local 115 int ResetQosForOtherThread(int tid) in ResetQosForOtherThread() argument [all …]
|
/ohos5.0/base/hiviewdfx/faultloggerd/test/unittest/process_dump/ |
H A D | lock_parser_test.cpp | 91 if (tid > 0) { in WaitThreadBlock() 113 int tid = 0; variable 115 tid = gettid(); in __anon7b59231d0202() 167 int tid = 0; variable 169 tid = gettid(); in __anon7b59231d0302() 219 int tid = 0; variable 221 tid = gettid(); in __anon7b59231d0402() 258 int tid = 0; variable 260 tid = gettid(); in __anon7b59231d0502() 297 int tid = 0; variable [all …]
|
H A D | process_dump_test.cpp | 88 auto keyThread = DfxThread::Create(pid, tid, tid); 143 pthread_t tid; variable 148 pthread_join(tid, NULL); 164 auto thread = DfxThread::Create(pid, tid, tid); 178 std::shared_ptr<DfxThread> thread = std::make_shared<DfxThread>(pid, tid, tid); 195 pid_t tid = pid; variable 196 std::shared_ptr<DfxThread> thread = DfxThread::Create(pid, tid, tid); 219 pid_t tid = pid; variable 228 std::shared_ptr<DfxThread> thread = DfxThread::Create(pid, tid, tid); 286 pid_t tid = pid; variable [all …]
|
/ohos5.0/foundation/resourceschedule/ffrt/src/sched/ |
H A D | multi_workgroup.cpp | 72 workGroup->tids[i] = tid; in InsertThreadInWorkGroup() 79 tid, MAX_WG_THREADS); in InsertThreadInWorkGroup() 89 rs.tid = -1; in CreateRSWorkGroup() 108 bool LeaveRSWorkGroup(int tid) in LeaveRSWorkGroup() argument 123 bool JoinRSWorkGroup(int tid) in JoinRSWorkGroup() argument 134 rs.tid = tid; in JoinRSWorkGroup() 161 bool JoinWG(int tid) in JoinWG() argument 171 return JoinRSWorkGroup(tid); in JoinWG() 182 bool LeaveWG(int tid) in LeaveWG() argument 186 return LeaveRSWorkGroup(tid); in LeaveWG() [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() [all …]
|
/ohos5.0/base/hiviewdfx/faultloggerd/interfaces/innerkits/unwinder/ |
H A D | thread_context.cpp | 70 auto it = g_contextMap.find(tid); in GetContextLocked() 73 threadContext->tid = tid; in GetContextLocked() 76 g_contextMap[tid] = threadContext; in GetContextLocked() 81 it->second->tid = tid; in GetContextLocked() 90 AT_UNUSED bool RemoveContextLocked(int32_t tid) in RemoveContextLocked() argument 92 auto it = g_contextMap.find(tid); in RemoveContextLocked() 140 auto it = g_contextMap.find(tid); in GetThreadContext() 151 auto it = g_contextMap.find(tid); in ReleaseThread() 167 auto threadContext = GetContextLocked(tid); in CollectThreadContext() 208 int tid = gettid(); in CopyContextAndWaitTimeout() local [all …]
|
H A D | dfx_ptrace.cpp | 33 void DfxPtrace::Detach(pid_t tid) in Detach() argument 35 if (tid > 0) { in Detach() 36 ptrace(PTRACE_CONT, tid, 0, 0); in Detach() 37 ptrace(PTRACE_DETACH, tid, nullptr, nullptr); in Detach() 41 bool DfxPtrace::Attach(pid_t tid, int timeout) in Attach() argument 43 if (tid <= 0) { in Attach() 47 if (ptrace(PTRACE_SEIZE, tid, 0, 0) != 0) { in Attach() 52 if (ptrace(PTRACE_INTERRUPT, tid, 0, 0) != 0) { in Attach() 54 ptrace(PTRACE_DETACH, tid, nullptr, nullptr); in Attach() 61 if (waitpid(tid, nullptr, WNOHANG) > 0) { in Attach() [all …]
|
/ohos5.0/base/request/request/frameworks/native/src/ |
H A D | request_service_proxy.cpp | 132 data.WriteString(tid); in GetTask() 155 data.WriteString(tid); in Start() 172 data.WriteString(tid); in Stop() 188 data.WriteString(tid); in Query() 210 data.WriteString(tid); in Touch() 258 data.WriteString(tid); in Show() 281 data.WriteString(tid); in Pause() 297 data.WriteString(tid); in QueryMimeType() 321 data.WriteString(tid); in Remove() 344 data.WriteString(tid); in Resume() [all …]
|
H A D | request_manager.cpp | 36 int32_t RequestManager::Start(const std::string &tid) in Start() argument 38 return RequestManagerImpl::GetInstance()->Start(tid); in Start() 40 int32_t RequestManager::Stop(const std::string &tid) in Stop() argument 42 return RequestManagerImpl::GetInstance()->Stop(tid); in Stop() 47 return RequestManagerImpl::GetInstance()->Query(tid, info); in Query() 60 int32_t RequestManager::Show(const std::string &tid, TaskInfo &info) in Show() argument 62 return RequestManagerImpl::GetInstance()->Show(tid, info); in Show() 67 return RequestManagerImpl::GetInstance()->Pause(tid, version); in Pause() 77 return RequestManagerImpl::GetInstance()->Remove(tid, version); in Remove() 80 int32_t RequestManager::Resume(const std::string &tid) in Resume() argument [all …]
|
/ohos5.0/foundation/multimedia/audio_framework/frameworks/native/audioschedule/ |
H A D | audio_schedule.cpp | 53 std::string strTid = std::to_string(tid); in ConfigPayload() 65 AUDIO_INFO_LOG("Report tid %{public}u", tid); in ScheduleReportData() 86 g_tidToReport.erase(tid); in UnscheduleThreadInServer() 88 UnscheduleReportData(pid, tid, "audio_server"); in UnscheduleThreadInServer() 91 void ScheduleThreadInServer(uint32_t pid, uint32_t tid) in ScheduleThreadInServer() argument 96 g_tidToReport.insert(tid); in ScheduleThreadInServer() 98 ScheduleReportData(pid, tid, "audio_server"); in ScheduleThreadInServer() 104 for (auto tid : g_tidToReport) { in OnAddResSchedService() local 112 void UnscheduleThreadInServer(uint32_t tid) {}; in UnscheduleThreadInServer() argument 124 : pid_(pid), tid_(tid), bundleName_(bundleName) in AudioScheduleGuard() [all …]
|
/ohos5.0/base/hiviewdfx/faultloggerd/test/benchmarktest/unwinder/ |
H A D | unwind_local_tid_benchmark.cpp | 43 tid->store(gettid()); in TestFunc6() 51 int val = TestFunc6(tid, done); in TestFunc5() 57 int val = TestFunc5(tid, done); in TestFunc4() 63 int val = TestFunc4(tid, done); in TestFunc3() 69 int val = TestFunc3(tid, done); in TestFunc2() 75 int val = TestFunc2(tid, done); in TestFunc1() 88 std::atomic_int tid(0); in BenchmarkUnwinderLocalWithTid() local 90 std::thread th([&tid, &done] { TestFunc1(&tid, &done); }); in BenchmarkUnwinderLocalWithTid() 91 while (tid.load() == 0) { in BenchmarkUnwinderLocalWithTid() 95 LOGU("+++tid: %d", tid.load()); in BenchmarkUnwinderLocalWithTid() [all …]
|
/ohos5.0/base/request/request/test/unittest/cpp_test/fwkTest/src/ |
H A D | request_manager_impl_test.cpp | 123 std::string tid = "1"; variable 146 string tid = "tid"; variable 159 string tid = "tid"; variable 172 string tid = "tid"; variable 186 string tid = "tid"; variable 200 string tid = "tid"; variable 229 string tid = "tid"; variable 242 string tid = "tid"; variable 255 string tid = "tid"; variable 269 string tid = "tid"; variable [all …]
|
H A D | request_manager_test.cpp | 84 std::string tid = "1"; variable 101 std::string tid = "1"; variable 128 std::string tid = "tid"; variable 129 RequestManager::GetInstance()->Stop(tid); 141 std::string tid = "tid"; variable 155 std::string tid = "tid"; variable 184 std::string tid = "tid"; variable 198 std::string tid = "tid"; variable 212 std::string tid = "tid"; variable 226 std::string tid = "tid"; variable [all …]
|
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/pipeline/ |
H A D | sk_resource_manager.cpp | 34 auto tid = gettid(); in HoldResource() local 39 if (images_.find(tid) != images_.end()) { in HoldResource() 40 images_[tid]->HoldResource(img); in HoldResource() 44 images_.emplace(tid, holder); in HoldResource() 52 auto tid = gettid(); in HoldResource() local 57 if (std::any_of(skSurfaces_[tid].cbegin(), skSurfaces_[tid].cend(), in HoldResource() 61 skSurfaces_[tid].push_back(surface); in HoldResource() 107 auto tid = gettid(); in ReleaseResource() local 109 images_[tid]->ReleaseResource(); in ReleaseResource() 117 auto tid = gettid(); in ReleaseResource() local [all …]
|
/ohos5.0/base/hiviewdfx/faultloggerd/interfaces/innerkits/backtrace/ |
H A D | backtrace_local.cpp | 42 std::string GetThreadHead(int32_t tid) in GetThreadHead() argument 46 if (tid == BACKTRACE_CURRENT_THREAD) { in GetThreadHead() 47 tid = gettid(); in GetThreadHead() 49 ReadThreadName(tid, threadName); in GetThreadHead() 50 threadHead << "Tid:" << tid << ", Name:" << threadName << "\n"; in GetThreadHead() 60 if (fast || (tid != BACKTRACE_CURRENT_THREAD)) { in GetBacktraceFramesByTid() 67 BacktraceLocalThread thread(tid, unwinder); in GetBacktraceFramesByTid() 89 std::string threadHead = GetThreadHead(tid); in GetBacktraceStringByTid() 148 std::function<bool(int)> func = [&](int tid) { in GetProcessStacktrace() argument 149 if (tid <= 0 || tid == getproctid()) { in GetProcessStacktrace() [all …]
|
/ohos5.0/base/request/request/frameworks/native/include/ |
H A D | request_service_proxy.h | 32 int32_t Create(const Config &config, std::string &tid) override; 34 int32_t Start(const std::string &tid) override; 35 int32_t Pause(const std::string &tid, Version version) override; 36 int32_t QueryMimeType(const std::string &tid, std::string &mimeType) override; 37 int32_t Remove(const std::string &tid, Version version) override; 38 int32_t Resume(const std::string &tid) override; 40 int32_t Stop(const std::string &tid) override; 41 int32_t Query(const std::string &tid, TaskInfo &info) override; 44 int32_t Show(const std::string &tid, TaskInfo &info) override; 47 int32_t Subscribe(const std::string &tid) override; [all …]
|
H A D | request_service_interface.h | 32 virtual int32_t GetTask(const std::string &tid, const std::string &token, Config &config) = 0; 33 virtual int32_t Start(const std::string &tid) = 0; 34 virtual int32_t Pause(const std::string &tid, Version version) = 0; 35 virtual int32_t QueryMimeType(const std::string &tid, std::string &mimeType) = 0; 36 virtual int32_t Remove(const std::string &tid, Version version) = 0; 37 virtual int32_t Resume(const std::string &tid) = 0; 39 virtual int32_t Stop(const std::string &tid) = 0; 40 virtual int32_t Query(const std::string &tid, TaskInfo &info) = 0; 41 virtual int32_t Touch(const std::string &tid, const std::string &token, TaskInfo &info) = 0; 43 virtual int32_t Show(const std::string &tid, TaskInfo &info) = 0;
|
/ohos5.0/base/request/request/services/src/service/client/ |
H A D | manager.rs | 87 ClientEvent::Unsubscribe(tid, tx) => self.handle_unsubscribe(tid, tx), in run() 88 ClientEvent::TaskFinished(tid) => self.handle_task_finished(tid), in run() 94 tid, in run() 151 tid: u32, in handle_subscribe() 158 self.pid_map.insert(tid, pid); in handle_subscribe() 167 if let Some(&pid) = self.pid_map.get(&tid) { in handle_unsubscribe() 168 self.pid_map.remove(&tid); in handle_unsubscribe() 181 fn handle_task_finished(&mut self, tid: u32) { in handle_task_finished() 182 if self.pid_map.contains_key(&tid) { in handle_task_finished() 183 self.pid_map.remove(&tid); in handle_task_finished() [all …]
|
/ohos5.0/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() 49 static_cast<long>(tid), priority, ret); in SetThreadPriority() 55 pid_t tid = pthread_gettid_np(handle); in GetThreadPriority() local 56 return getpriority(PRIO_PROCESS, tid); in GetThreadPriority()
|
/ohos5.0/foundation/resourceschedule/resource_schedule_service/cgroup_sched/framework/process_group/src/ |
H A D | sched_policy.cpp | 22 int SetThreadSchedPolicy(int tid, int policy) in SetThreadSchedPolicy() argument 24 if (tid < 0) { in SetThreadSchedPolicy() 27 if (tid == 0) { in SetThreadSchedPolicy() 28 tid = gettid(); in SetThreadSchedPolicy() 31 return CgroupAction::GetInstance().SetThreadSchedPolicy(tid, schedPolicy) ? 0 : -1; in SetThreadSchedPolicy() 46 int GetThreadSchedPolicy(int tid, SchedPolicy* policy) in GetThreadSchedPolicy() argument 48 if (tid < 0) { in GetThreadSchedPolicy() 51 if (tid == 0) { in GetThreadSchedPolicy() 52 tid = gettid(); in GetThreadSchedPolicy() 54 return CgroupAction::GetInstance().GetSchedPolicy(tid, policy); in GetThreadSchedPolicy()
|
/ohos5.0/foundation/ability/ability_runtime/test/unittest/lifecycle_test/ |
H A D | lifecycle_test.cpp | 154 pthread_t tid = 0; variable 161 pthread_join(tid, nullptr); 184 pthread_t tid = 0; variable 194 pthread_join(tid, nullptr); 217 pthread_t tid = 0; variable 253 pthread_t tid = 0; variable 282 pthread_t tid = 0; variable 337 pthread_t tid = 0; variable 400 pthread_t tid = 0; variable 433 pthread_t tid = 0; variable [all …]
|
/ohos5.0/foundation/resourceschedule/qos_manager/test/unittest/phone/ |
H A D | concurrent_task_controller_test.cpp | 236 int tid = gettid(); variable 237 fore.NewForeground(uid, tid); 238 fore.NewBackground(uid, tid); 240 fore.NewForeground(uid, tid); 241 fore.NewBackground(uid, tid); 245 fore.AppKilled(uid, tid); 246 tid = 574; 252 fore.NewForeground(uid, tid); 253 fore.NewBackground(uid, tid); 258 fore.AppKilled(uid, tid); [all …]
|
/ohos5.0/foundation/resourceschedule/ffrt/tools/ffrt_trace_process/ |
H A D | ffrt_trace_recover.py | 58 tname, tid, pid, cpu_id, timestamp, tname, tid, prio, label, pid, gid, prio) 83 if "prev_pid=%d" % tid in mark: 90 elif "next_pid=%d" % tid in mark: 172 if tid not in trace_map.keys(): 173 trace_map[tid] = [] 174 trace_map[tid].append(lineno) 180 if tid not in trace_map.keys(): 181 trace_map[tid] = [] 182 trace_map[tid].append(lineno) 225 for tid in tids.keys(): [all …]
|
/ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/ |
H A D | ut_rtg.cpp | 173 pid_t tid = RTGCtrl::GetTID(); in __anone3ead2840102() local 177 tids.emplace_back(tid); in __anone3ead2840102() 195 for (auto tid : tids) { variable 196 ret = RTGCtrl::Instance().JoinThread(tgid, tid); 198 FFRT_LOGE("Failed To Join Thread %d", tid); 203 for (auto tid : tids) { variable 241 pid_t tid = RTGCtrl::GetTID(); in __anone3ead2840202() local 245 tids.emplace_back(tid); in __anone3ead2840202() 263 for (auto tid : tids) { variable 266 FFRT_LOGE("Failed To Join Thread %d", tid); [all …]
|
/ohos5.0/drivers/peripheral/camera/hal_c/hdi_cif/include/ |
H A D | camera.h | 49 pid_t tid = gettid(); \ 50 printf("%s %4u %4u E " fmt "\n", now, (uint32_t)pid, (uint32_t)tid, ##__VA_ARGS__); \ 58 pid_t tid = gettid(); \ 59 printf("%s %4u %4u W " fmt "\n", now, (uint32_t)pid, (uint32_t)tid, ##__VA_ARGS__); \ 67 pid_t tid = gettid(); \ 68 printf("%s %4u %4u I " fmt "\n", now, (uint32_t)pid, (uint32_t)tid, ##__VA_ARGS__); \ 76 pid_t tid = gettid(); \ 77 printf("%s %4u %4u V " fmt "\n", now, (uint32_t)pid, (uint32_t)tid, ##__VA_ARGS__); \ 85 pid_t tid = gettid(); \ 86 printf("%s %4u %4u D " fmt "\n", now, (uint32_t)pid, (uint32_t)tid, ##__VA_ARGS__); \
|