Lines Matching refs:ev_queue
795 struct dlb2_eventdev_queue *ev_queue, in dlb2_hw_create_ldb_queue() argument
799 struct dlb2_queue *queue = &ev_queue->qm_queue; in dlb2_hw_create_ldb_queue()
847 if (ev_queue->depth_threshold == 0) { in dlb2_hw_create_ldb_queue()
849 ev_queue->depth_threshold = RTE_PMD_DLB2_DEFAULT_DEPTH_THRESH; in dlb2_hw_create_ldb_queue()
851 cfg.depth_threshold = ev_queue->depth_threshold; in dlb2_hw_create_ldb_queue()
880 struct dlb2_eventdev_queue *ev_queue, in dlb2_eventdev_ldb_queue_setup() argument
889 qm_qid = dlb2_hw_create_ldb_queue(dlb2, ev_queue, queue_conf); in dlb2_eventdev_ldb_queue_setup()
896 dlb2->qm_ldb_to_ev_queue_id[qm_qid] = ev_queue->id; in dlb2_eventdev_ldb_queue_setup()
898 ev_queue->qm_queue.id = qm_qid; in dlb2_eventdev_ldb_queue_setup()
918 struct dlb2_eventdev_queue *ev_queue) in dlb2_queue_link_teardown() argument
928 ev_port->link[j].queue_id != ev_queue->id) in dlb2_queue_link_teardown()
936 ev_queue->num_links = 0; in dlb2_queue_link_teardown()
945 struct dlb2_eventdev_queue *ev_queue; in dlb2_eventdev_queue_setup() local
954 ev_queue = &dlb2->ev_queues[ev_qid]; in dlb2_eventdev_queue_setup()
956 ev_queue->qm_queue.is_directed = queue_conf->event_queue_cfg & in dlb2_eventdev_queue_setup()
958 ev_queue->id = ev_qid; in dlb2_eventdev_queue_setup()
959 ev_queue->conf = *queue_conf; in dlb2_eventdev_queue_setup()
961 if (!ev_queue->qm_queue.is_directed) { in dlb2_eventdev_queue_setup()
962 ret = dlb2_eventdev_ldb_queue_setup(dev, ev_queue, queue_conf); in dlb2_eventdev_queue_setup()
971 ev_queue->qm_queue.config_state = DLB2_NOT_CONFIGURED; in dlb2_eventdev_queue_setup()
973 if (ev_queue->setup_done || in dlb2_eventdev_queue_setup()
980 dlb2_queue_link_teardown(dlb2, ev_queue); in dlb2_eventdev_queue_setup()
983 ev_queue->setup_done = true; in dlb2_eventdev_queue_setup()
1275 struct dlb2_eventdev_queue *ev_queue; in dlb2_port_link_teardown() local
1282 ev_queue = &dlb2->ev_queues[ev_port->link[i].queue_id]; in dlb2_port_link_teardown()
1286 ev_queue->num_links--; in dlb2_port_link_teardown()
1556 struct dlb2_eventdev_queue *ev_queue, in dlb2_event_queue_join_ldb() argument
1564 if (ev_port->link[i].queue_id == ev_queue->id && in dlb2_event_queue_join_ldb()
1581 ev_queue->qm_queue.id, in dlb2_event_queue_join_ldb()
1592 struct dlb2_eventdev_queue *ev_queue, in dlb2_hw_create_dir_queue() argument
1602 if (ev_queue->depth_threshold == 0) { in dlb2_hw_create_dir_queue()
1604 ev_queue->depth_threshold = RTE_PMD_DLB2_DEFAULT_DEPTH_THRESH; in dlb2_hw_create_dir_queue()
1606 cfg.depth_threshold = ev_queue->depth_threshold; in dlb2_hw_create_dir_queue()
1620 struct dlb2_eventdev_queue *ev_queue, in dlb2_eventdev_dir_queue_setup() argument
1625 qm_qid = dlb2_hw_create_dir_queue(dlb2, ev_queue, ev_port->qm_port.id); in dlb2_eventdev_dir_queue_setup()
1632 dlb2->qm_dir_to_ev_queue_id[qm_qid] = ev_queue->id; in dlb2_eventdev_dir_queue_setup()
1634 ev_queue->qm_queue.id = qm_qid; in dlb2_eventdev_dir_queue_setup()
1641 struct dlb2_eventdev_queue *ev_queue, in dlb2_do_port_link() argument
1652 if (ev_queue->qm_queue.is_directed) in dlb2_do_port_link()
1653 err = dlb2_eventdev_dir_queue_setup(dlb2, ev_queue, ev_port); in dlb2_do_port_link()
1655 err = dlb2_event_queue_join_ldb(dlb2, ev_port, ev_queue, prio); in dlb2_do_port_link()
1659 ev_queue->qm_queue.is_directed ? "DIR" : "LDB", in dlb2_do_port_link()
1660 ev_queue->id, ev_port->id); in dlb2_do_port_link()
1676 struct dlb2_eventdev_queue *ev_queue; in dlb2_validate_port_link() local
1684 ev_queue = &dlb2->ev_queues[queue_id]; in dlb2_validate_port_link()
1686 if (!ev_queue->setup_done && in dlb2_validate_port_link()
1687 ev_queue->qm_queue.config_state != DLB2_PREV_CONFIGURED) { in dlb2_validate_port_link()
1693 queue_is_dir = ev_queue->qm_queue.is_directed; in dlb2_validate_port_link()
1697 queue_is_dir ? "DIR" : "LDB", ev_queue->id, in dlb2_validate_port_link()
1721 if (ev_queue->qm_queue.is_directed && ev_queue->num_links > 0 && in dlb2_validate_port_link()
1724 ev_queue->id); in dlb2_validate_port_link()
1773 struct dlb2_eventdev_queue *ev_queue; in dlb2_eventdev_port_link() local
1804 ev_queue = &dlb2->ev_queues[queue_id]; in dlb2_eventdev_port_link()
1806 if (dlb2_do_port_link(dev, ev_queue, ev_port, prio)) in dlb2_eventdev_port_link()
1809 ev_queue->num_links++; in dlb2_eventdev_port_link()
1846 struct dlb2_eventdev_queue *ev_queue) in dlb2_event_queue_detach_ldb() argument
1856 ev_port->link[i].queue_id == ev_queue->id) in dlb2_event_queue_detach_ldb()
1865 ev_queue->qm_queue.id, in dlb2_event_queue_detach_ldb()
1872 ev_queue->qm_queue.id); in dlb2_event_queue_detach_ldb()
1911 struct dlb2_eventdev_queue *ev_queue; in dlb2_eventdev_port_unlink() local
1920 ev_queue = &dlb2->ev_queues[queues[i]]; in dlb2_eventdev_port_unlink()
1931 ret = dlb2_event_queue_detach_ldb(dlb2, ev_port, ev_queue); in dlb2_eventdev_port_unlink()
1941 ev_queue->num_links--; in dlb2_eventdev_port_unlink()
1990 struct dlb2_eventdev_queue *ev_queue; in dlb2_eventdev_reapply_configuration() local
1992 ev_queue = &dlb2->ev_queues[i]; in dlb2_eventdev_reapply_configuration()
1994 if (ev_queue->qm_queue.config_state != DLB2_PREV_CONFIGURED) in dlb2_eventdev_reapply_configuration()
1997 ret = dlb2_eventdev_queue_setup(dev, i, &ev_queue->conf); in dlb2_eventdev_reapply_configuration()
2033 struct dlb2_eventdev_queue *ev_queue; in dlb2_eventdev_apply_port_links() local
2045 ev_queue = &dlb2->ev_queues[queue_id]; in dlb2_eventdev_apply_port_links()
2047 if (dlb2_do_port_link(dev, ev_queue, ev_port, prio)) in dlb2_eventdev_apply_port_links()
2496 struct dlb2_eventdev_queue *ev_queue; in dlb2_event_enqueue_prep() local
2500 ev_queue = &dlb2->ev_queues[ev->queue_id]; in dlb2_event_enqueue_prep()
2501 qm_queue = &ev_queue->qm_queue; in dlb2_event_enqueue_prep()