Lines Matching refs:tid
48 int FindThreadInWorkGroup(WorkGroup *workGroup, int tid)
51 FFRT_LOGE("[RSWorkGroup] find thread %{public}d in workGroup failed, workGroup is null", tid);
55 if (workGroup->tids[i] == tid) {
62 bool InsertThreadInWorkGroup(WorkGroup *workGroup, int tid)
65 FFRT_LOGE("[RSWorkGroup] join thread %{public}d into workGroup failed, workGroup is null", tid);
71 workGroup->tids[i] = tid;
78 tid, MAX_WG_THREADS);
88 rs.tid = -1;
107 bool LeaveRSWorkGroup(int tid)
111 FFRT_LOGI("[RSWorkGroup] LeaveRSWorkGroup rsWorkGroup is null ,tid:%{public}d", tid);
114 int existIndex = FindThreadInWorkGroup(rsWorkGroup, tid);
118 FFRT_LOGI("[RSWorkGroup] LeaveRSWorkGroup ,tid:%{public}d,existIndex:%{public}d", tid, existIndex);
122 bool JoinRSWorkGroup(int tid)
126 FFRT_LOGE("[RSWorkGroup] join thread %{public}d into RSWorkGroup failed; Create RSWorkGroup first", tid);
129 int existIndex = FindThreadInWorkGroup(rsWorkGroup, tid);
133 rs.tid = tid;
136 bool success = InsertThreadInWorkGroup(rsWorkGroup, tid);
142 FFRT_LOGI("[RSWorkGroup] update thread %{public}d success", tid);
160 bool JoinWG(int tid)
171 return JoinRSWorkGroup(tid);
173 int addRet = AddThreadToRtgAdapter(tid, wgId, 0);
175 FFRT_LOGI("[WorkGroup] update thread %{public}d success", tid);
177 FFRT_LOGE("[WorkGroup] update thread %{public}d failed, return %{public}d", tid, addRet);
182 bool LeaveWG(int tid)
186 return LeaveRSWorkGroup(tid);
287 void WorkgroupJoin(struct WorkGroup* wg, int tid)
297 rs.tid = tid;
299 FFRT_LOGI("[WorkGroup] join thread %{public}ld", tid);
302 int addRet = AddThreadToRtgAdapter(tid, wg->rtgId, 0);
304 FFRT_LOGI("[WorkGroup] join thread %{public}ld success", tid);
306 FFRT_LOGE("[WorkGroup] join fail with %{public}d threads for %{public}d", addRet, tid);