Lines Matching refs:ev_queue

735 			   struct dlb_eventdev_queue *ev_queue)  in dlb_event_queue_detach_ldb()  argument
745 ev_port->link[i].queue_id == ev_queue->id) in dlb_event_queue_detach_ldb()
754 ev_queue->qm_queue.id, in dlb_event_queue_detach_ldb()
761 ev_queue->qm_queue.id); in dlb_event_queue_detach_ldb()
800 struct dlb_eventdev_queue *ev_queue; in dlb_eventdev_port_unlink() local
809 ev_queue = &dlb->ev_queues[queues[i]]; in dlb_eventdev_port_unlink()
820 ret = dlb_event_queue_detach_ldb(dlb, ev_port, ev_queue); in dlb_eventdev_port_unlink()
830 ev_queue->num_links--; in dlb_eventdev_port_unlink()
1431 struct dlb_eventdev_queue *ev_queue, in dlb_eventdev_ldb_queue_setup() argument
1441 &ev_queue->qm_queue, in dlb_eventdev_ldb_queue_setup()
1449 dlb->qm_ldb_to_ev_queue_id[qm_qid] = ev_queue->id; in dlb_eventdev_ldb_queue_setup()
1451 ev_queue->qm_queue.id = qm_qid; in dlb_eventdev_ldb_queue_setup()
1471 struct dlb_eventdev_queue *ev_queue) in dlb_queue_link_teardown() argument
1481 ev_port->link[j].queue_id != ev_queue->id) in dlb_queue_link_teardown()
1489 ev_queue->num_links = 0; in dlb_queue_link_teardown()
1498 struct dlb_eventdev_queue *ev_queue; in dlb_eventdev_queue_setup() local
1507 ev_queue = &dlb->ev_queues[ev_qid]; in dlb_eventdev_queue_setup()
1509 ev_queue->qm_queue.is_directed = queue_conf->event_queue_cfg & in dlb_eventdev_queue_setup()
1511 ev_queue->id = ev_qid; in dlb_eventdev_queue_setup()
1512 ev_queue->conf = *queue_conf; in dlb_eventdev_queue_setup()
1514 if (!ev_queue->qm_queue.is_directed) { in dlb_eventdev_queue_setup()
1515 ret = dlb_eventdev_ldb_queue_setup(dev, ev_queue, queue_conf); in dlb_eventdev_queue_setup()
1524 ev_queue->qm_queue.config_state = DLB_NOT_CONFIGURED; in dlb_eventdev_queue_setup()
1526 if (ev_queue->setup_done || in dlb_eventdev_queue_setup()
1533 dlb_queue_link_teardown(dlb, ev_queue); in dlb_eventdev_queue_setup()
1536 ev_queue->setup_done = true; in dlb_eventdev_queue_setup()
1545 struct dlb_eventdev_queue *ev_queue; in dlb_port_link_teardown() local
1552 ev_queue = &dlb->ev_queues[ev_port->link[i].queue_id]; in dlb_port_link_teardown()
1556 ev_queue->num_links--; in dlb_port_link_teardown()
1678 struct dlb_eventdev_queue *ev_queue; in dlb_eventdev_reapply_configuration() local
1680 ev_queue = &dlb->ev_queues[i]; in dlb_eventdev_reapply_configuration()
1682 if (ev_queue->qm_queue.config_state != DLB_PREV_CONFIGURED) in dlb_eventdev_reapply_configuration()
1685 ret = dlb_eventdev_queue_setup(dev, i, &ev_queue->conf); in dlb_eventdev_reapply_configuration()
1786 struct dlb_eventdev_queue *ev_queue; in dlb_validate_port_link() local
1796 ev_queue = &dlb->ev_queues[queue_id]; in dlb_validate_port_link()
1798 if (!ev_queue->setup_done && in dlb_validate_port_link()
1799 ev_queue->qm_queue.config_state != DLB_PREV_CONFIGURED) { in dlb_validate_port_link()
1806 queue_is_dir = ev_queue->qm_queue.is_directed; in dlb_validate_port_link()
1810 queue_is_dir ? "DIR" : "LDB", ev_queue->id, in dlb_validate_port_link()
1834 if (ev_queue->qm_queue.is_directed && ev_queue->num_links > 0 && in dlb_validate_port_link()
1837 ev_queue->id); in dlb_validate_port_link()
1870 struct dlb_eventdev_queue *ev_queue, in dlb_eventdev_dir_queue_setup() argument
1882 dlb->qm_dir_to_ev_queue_id[qm_qid] = ev_queue->id; in dlb_eventdev_dir_queue_setup()
1884 ev_queue->qm_queue.id = qm_qid; in dlb_eventdev_dir_queue_setup()
1928 struct dlb_eventdev_queue *ev_queue, in dlb_event_queue_join_ldb() argument
1936 if (ev_port->link[i].queue_id == ev_queue->id && in dlb_event_queue_join_ldb()
1955 ev_queue->qm_queue.id, in dlb_event_queue_join_ldb()
1966 struct dlb_eventdev_queue *ev_queue, in dlb_do_port_link() argument
1977 if (ev_queue->qm_queue.is_directed) in dlb_do_port_link()
1978 err = dlb_eventdev_dir_queue_setup(dlb, ev_queue, ev_port); in dlb_do_port_link()
1980 err = dlb_event_queue_join_ldb(dlb, ev_port, ev_queue, prio); in dlb_do_port_link()
1984 ev_queue->qm_queue.is_directed ? "DIR" : "LDB", in dlb_do_port_link()
1985 ev_queue->id, ev_port->id); in dlb_do_port_link()
2006 struct dlb_eventdev_queue *ev_queue; in dlb_eventdev_apply_port_links() local
2018 ev_queue = &dlb->ev_queues[queue_id]; in dlb_eventdev_apply_port_links()
2020 if (dlb_do_port_link(dev, ev_queue, ev_port, prio)) in dlb_eventdev_apply_port_links()
2069 struct dlb_eventdev_queue *ev_queue; in dlb_eventdev_port_link() local
2101 ev_queue = &dlb->ev_queues[queue_id]; in dlb_eventdev_port_link()
2103 if (dlb_do_port_link(dev, ev_queue, ev_port, prio)) in dlb_eventdev_port_link()
2106 ev_queue->num_links++; in dlb_eventdev_port_link()
2311 struct dlb_eventdev_queue *ev_queue; in dlb_event_enqueue_prep() local
2315 ev_queue = &dlb->ev_queues[ev->queue_id]; in dlb_event_enqueue_prep()
2316 qm_queue = &ev_queue->qm_queue; in dlb_event_enqueue_prep()