Lines Matching refs:curr

134     MppTaskStatusInfo *curr = NULL;  in _mpp_port_poll()  local
146 curr = &queue->info[port_impl->status_curr]; in _mpp_port_poll()
147 if (curr->count) { in _mpp_port_poll()
148 mpp_assert(!list_empty(&curr->list)); in _mpp_port_poll()
149 ret = (MPP_RET)curr->count; in _mpp_port_poll()
153 timeout, curr->count); in _mpp_port_poll()
155 mpp_assert(list_empty(&curr->list)); in _mpp_port_poll()
163 MppCond *cond = &curr->cond; in _mpp_port_poll()
178 if (curr->count) { in _mpp_port_poll()
179 mpp_assert(!list_empty(&curr->list)); in _mpp_port_poll()
180 ret = (MPP_RET)curr->count; in _mpp_port_poll()
201 MppTaskStatusInfo *curr = NULL; in _mpp_port_move() local
219 curr = &queue->info[task_impl->status]; in _mpp_port_move()
223 curr->count--; in _mpp_port_move()
248 MppTaskStatusInfo *curr = NULL; in _mpp_port_dequeue() local
264 curr = &queue->info[port_impl->status_curr]; in _mpp_port_dequeue()
268 if (curr->count == 0) { in _mpp_port_dequeue()
269 mpp_assert(list_empty(&curr->list)); in _mpp_port_dequeue()
278 mpp_assert(!list_empty(&curr->list)); in _mpp_port_dequeue()
279 task_impl = list_entry(curr->list.next, MppTaskImpl, list); in _mpp_port_dequeue()
283 curr->count--; in _mpp_port_dequeue()
284 mpp_assert(curr->count >= 0); in _mpp_port_dequeue()
310 MppTaskStatusInfo *curr = NULL; in _mpp_port_enqueue() local
330 curr = &queue->info[task_impl->status]; in _mpp_port_enqueue()
334 curr->count--; in _mpp_port_enqueue()
363 MppTaskStatusInfo *curr = NULL; in _mpp_port_awake() local
366 curr = &queue->info[port_impl->status_curr]; in _mpp_port_awake()
367 if (curr) { in _mpp_port_awake()
368 mpp_cond_signal(&curr->cond); in _mpp_port_awake()