Lines Matching refs:task
267 MppDevTask *task; in process_task() local
287 list_for_each_entry_safe(task, n, &batch->link_tasks, MppDevTask, link_batch) { in process_task()
288 rk_s32 batch_slot_id = task->batch_slot_id; in process_task()
292 session = task->session; in process_task()
300 batch->batch_id, task->batch_slot_id, task->task_id); in process_task()
305 list_del_init(&task->link_batch); in process_task()
306 task->batch = NULL; in process_task()
309 batch->batch_id, task->batch_slot_id, session->client); in process_task()
404 task = NULL; in process_task()
406 task = list_first_entry_or_null(&server->pending_task, MppDevTask, link_server); in process_task()
407 list_del_init(&task->link_server); in process_task()
416 task->batch = batch; in process_task()
417 task->batch_slot_id = batch->fill_cnt++; in process_task()
418 mpp_assert(task->batch_slot_id < server->max_task_in_batch); in process_task()
419 list_add_tail(&task->link_batch, &batch->link_tasks); in process_task()
423 session = task->session; in process_task()
427 bat_cmd = batch->bat_cmd + task->batch_slot_id; in process_task()
444 for (i = 0; i < task->req_cnt; i++) in process_task()
445 batch->send_reqs[batch->send_req_cnt++] = task->req[i]; in process_task()
466 batch->batch_id, task->batch_slot_id, session->client, in process_task()
467 task->slot_idx, task->task_id); in process_task()
488 MppDevTask *task = NULL; in send_task() local
501 task = list_first_entry_or_null(&session->list_done, MppDevTask, link_session); in send_task()
502 mpp_assert(task); in send_task()
504 task->req = ctx->reqs; in send_task()
505 task->req_cnt = ctx->req_cnt; in send_task()
507 list_del_init(&task->link_session); in send_task()
508 list_add_tail(&task->link_session, &session->list_wait); in send_task()
514 task->task_id = server->task_id++; in send_task()
515 list_del_init(&task->link_server); in send_task()
516 list_add_tail(&task->link_server, &server->pending_task); in send_task()
519 session->client, task->slot_idx, server->pending_count); in send_task()
530 MppDevTask *task = NULL; in wait_task() local
539 task = list_first_entry_or_null(&session->list_wait, MppDevTask, link_session); in wait_task()
540 mpp_assert(task); in wait_task()
545 task->task_id, session->task_wait, session->task_done); in wait_task()
549 task->task_id, session->task_wait, session->task_done); in wait_task()
552 list_del_init(&task->link_session); in wait_task()
553 list_add_tail(&task->link_session, &session->list_done); in wait_task()
714 MppDevTask *task = &session->tasks[i]; in server_attach() local
716 INIT_LIST_HEAD(&task->link_server); in server_attach()
717 INIT_LIST_HEAD(&task->link_session); in server_attach()
718 INIT_LIST_HEAD(&task->link_batch); in server_attach()
719 task->session = session; in server_attach()
720 task->batch = NULL; in server_attach()
721 task->task_id = -1; in server_attach()
722 task->slot_idx = i; in server_attach()
724 list_add_tail(&task->link_session, &session->list_done); in server_attach()