Lines Matching refs:ops
155 CPUEUTask* task = worker->ops.PickUpTaskBatch(worker);
162 worker->ops.NotifyTaskPicked(worker);
181 PollerRet ret = worker->ops.TryPoll(worker, timeout);
197 if (worker->ops.IsBlockAwareInit()) {
209 worker->ops.WorkerPrepare(worker);
214 worker->ops.WorkerLooper(worker);
217 worker->ops.WorkerRetired(worker);
226 if (!worker->ops.IsExceedRunningThreshold(worker)) {
233 worker->ops.TryPoll(worker, 0);
246 CPUEUTask* task = worker->ops.PickUpTaskBatch(worker);
252 worker->ops.NotifyTaskPicked(worker);
266 worker->ops.StealTaskBatch(worker);
283 auto action = worker->ops.WaitForNewAction(worker);