49 int FindThreadInWorkGroup(WorkGroup *workGroup, int tid)  in FindThreadInWorkGroup()  argument
52 …     FFRT_LOGE("[RSWorkGroup] find thread %{public}d in workGroup failed, workGroup is null", tid);  in FindThreadInWorkGroup()
56         if (workGroup->tids[i] == tid) {  in FindThreadInWorkGroup()
63 bool InsertThreadInWorkGroup(WorkGroup *workGroup, int tid)  in InsertThreadInWorkGroup()  argument
66 …   FFRT_LOGE("[RSWorkGroup] join thread %{public}d into workGroup failed, workGroup is null", tid);  in InsertThreadInWorkGroup()
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
112         FFRT_LOGI("[RSWorkGroup] LeaveRSWorkGroup rsWorkGroup is null ,tid:%{public}d", tid);  in LeaveRSWorkGroup()
115     int existIndex = FindThreadInWorkGroup(rsWorkGroup, tid);  in LeaveRSWorkGroup()
119 …FFRT_LOGI("[RSWorkGroup] LeaveRSWorkGroup ,tid: %{public}d, existIndex: %{public}d", tid, existInd…  in LeaveRSWorkGroup()
123 bool JoinRSWorkGroup(int tid)  in JoinRSWorkGroup()  argument
127 …OGE("[RSWorkGroup] join thread %{public}d into RSWorkGroup failed; Create RSWorkGroup first", tid);  in JoinRSWorkGroup()
130     int existIndex = FindThreadInWorkGroup(rsWorkGroup, tid);  in JoinRSWorkGroup()
134         rs.tid = tid;  in JoinRSWorkGroup()
137             bool success = InsertThreadInWorkGroup(rsWorkGroup, tid);  in JoinRSWorkGroup()
143     FFRT_LOGI("[RSWorkGroup] update thread %{public}d success", tid);  in JoinRSWorkGroup()
161 bool JoinWG(int tid)  in JoinWG()  argument
171         return JoinRSWorkGroup(tid);  in JoinWG()
173     int addRet = AddThreadToRtgAdapter(tid, wgId, 0);  in JoinWG()
175         FFRT_LOGI("[WorkGroup] update thread %{public}d success", tid);  in JoinWG()
177         FFRT_LOGE("[WorkGroup] update thread %{public}d failed, return %{public}d", tid, addRet);  in JoinWG()
182 bool LeaveWG(int tid)  in LeaveWG()  argument
186         return LeaveRSWorkGroup(tid);  in LeaveWG()
286 void WorkgroupJoin(struct WorkGroup* wg, int tid)  in WorkgroupJoin()  argument
296         rs.tid = tid;  in WorkgroupJoin()
298         FFRT_LOGI("[WorkGroup] join thread %{public}ld", tid);  in WorkgroupJoin()
301     int addRet = AddThreadToRtgAdapter(tid, wg->rtgId, 0);  in WorkgroupJoin()
303         FFRT_LOGI("[WorkGroup] join thread %{public}ld success", tid);  in WorkgroupJoin()
305         FFRT_LOGE("[WorkGroup] join fail with %{public}d threads for %{public}d", addRet, tid);  in WorkgroupJoin()