Lines Matching refs:queue
84 p->opdl->queue[p->queue_id].external_qid; in update_on_dequeue()
99 p->opdl->queue[p->queue_id].external_qid; in update_on_dequeue()
299 struct opdl_queue *queue = &device->queue[q_id]; in opdl_add_deps() local
300 struct opdl_queue *queue_deps = &device->queue[deps_q_id]; in opdl_add_deps()
304 for (i = 0; i < queue->nb_ports; i++) { in opdl_add_deps()
306 opdl_stage_get_opdl_ring(stage_for_port(queue, i)); in opdl_add_deps()
332 for (i = 0; i < queue->nb_ports; i++) { in opdl_add_deps()
334 ring = opdl_stage_get_opdl_ring(stage_for_port(queue, i)); in opdl_add_deps()
337 stage_for_port(queue, i), in opdl_add_deps()
338 queue->ports[i]->num_instance, in opdl_add_deps()
339 queue->ports[i]->instance_id, in opdl_add_deps()
415 struct opdl_queue *queue = &device->queue[i]; in build_all_dependencies() local
416 if (!queue->initialized) in build_all_dependencies()
419 if (queue->q_pos == OPDL_Q_POS_START) { in build_all_dependencies()
424 if (queue->q_pos == OPDL_Q_POS_MIDDLE) { in build_all_dependencies()
430 queue->external_qid); in build_all_dependencies()
435 if (queue->q_pos == OPDL_Q_POS_END) { in build_all_dependencies()
442 queue->external_qid); in build_all_dependencies()
451 queue->external_qid); in build_all_dependencies()
472 struct opdl_queue *queue = &device->queue[i]; in check_queues_linked() local
474 if (!queue->initialized) in check_queues_linked()
477 if (queue->external_qid == OPDL_INVALID_QID) in check_queues_linked()
480 if (queue->nb_ports == 0) { in check_queues_linked()
514 memset(&device->queue, in destroy_queues_and_rings()
527 struct opdl_queue *queue = &device->queue[device->nb_queues]; in initialise_queue() local
530 queue->q_type = OPDL_Q_TYPE_ORDERED; in initialise_queue()
531 queue->external_qid = OPDL_INVALID_QID; in initialise_queue()
533 queue->q_type = device->q_md[i].type; in initialise_queue()
534 queue->external_qid = device->q_md[i].ext_id; in initialise_queue()
536 device->q_map_ex_to_in[queue->external_qid] = device->nb_queues; in initialise_queue()
538 queue->opdl_id = OPDL_ID(device); in initialise_queue()
539 queue->q_pos = pos; in initialise_queue()
540 queue->nb_ports = 0; in initialise_queue()
541 queue->configured = 1; in initialise_queue()
709 struct opdl_queue *queue = &device->queue[port->queue_id]; in initialise_all_other_ports() local
713 } else if (queue->q_type != OPDL_Q_TYPE_SINGLE_LINK) { in initialise_all_other_ports()
715 if (queue->q_pos == OPDL_Q_POS_MIDDLE) { in initialise_all_other_ports()
719 device->opdl[queue->opdl_id], in initialise_all_other_ports()
725 if (queue->q_type == OPDL_Q_TYPE_ATOMIC) in initialise_all_other_ports()
733 queue->ports[queue->nb_ports] = port; in initialise_all_other_ports()
734 port->instance_id = queue->nb_ports; in initialise_all_other_ports()
735 queue->nb_ports++; in initialise_all_other_ports()
739 } else if (queue->q_pos == OPDL_Q_POS_END) { in initialise_all_other_ports()
743 device->opdl[queue->opdl_id], in initialise_all_other_ports()
751 queue->ports[queue->nb_ports] = port; in initialise_all_other_ports()
752 port->instance_id = queue->nb_ports; in initialise_all_other_ports()
753 queue->nb_ports++; in initialise_all_other_ports()
761 queue->q_pos); in initialise_all_other_ports()
766 } else if (queue->q_type == OPDL_Q_TYPE_SINGLE_LINK) { in initialise_all_other_ports()
772 device->opdl[queue->opdl_id], in initialise_all_other_ports()
778 queue->ports[queue->nb_ports] = port; in initialise_all_other_ports()
779 port->instance_id = queue->nb_ports; in initialise_all_other_ports()
780 queue->nb_ports++; in initialise_all_other_ports()
782 if (queue->nb_ports > 1) { in initialise_all_other_ports()
787 queue->external_qid); in initialise_all_other_ports()
794 device->q_map_ex_to_in[queue->external_qid] + 1; in initialise_all_other_ports()
796 device->queue[next_qid].configured) { in initialise_all_other_ports()
799 queue = &device->queue[next_qid]; in initialise_all_other_ports()
802 device->opdl[queue->opdl_id], in initialise_all_other_ports()
808 queue->ports[queue->nb_ports] = port; in initialise_all_other_ports()
809 port->instance_id = queue->nb_ports; in initialise_all_other_ports()
810 queue->nb_ports++; in initialise_all_other_ports()
811 if (queue->nb_ports > 1) { in initialise_all_other_ports()
826 queue->initialized = 1; in initialise_all_other_ports()
837 struct opdl_queue *queue = in initialise_all_other_ports() local
838 &device->queue[port->queue_id]; in initialise_all_other_ports()
842 if (queue->nb_ports == 0) { in initialise_all_other_ports()
852 port->num_instance = queue->nb_ports; in initialise_all_other_ports()
854 queue->initialized = 1; in initialise_all_other_ports()
875 struct opdl_queue *queue = NULL; in initialise_queue_zero_ports() local
901 queue = &device->queue[port->queue_id]; in initialise_queue_zero_ports()
907 queue->ports[queue->nb_ports] = port; in initialise_queue_zero_ports()
908 port->instance_id = queue->nb_ports; in initialise_queue_zero_ports()
909 queue->nb_ports++; in initialise_queue_zero_ports()
932 struct opdl_queue *queue = in assign_internal_queue_ids() local
933 &device->queue[port->queue_id]; in assign_internal_queue_ids()
934 if (queue->q_pos == OPDL_Q_POS_END) in assign_internal_queue_ids()
936 device->queue[port->queue_id + 2].external_qid; in assign_internal_queue_ids()
939 device->queue[port->queue_id + 1].external_qid; in assign_internal_queue_ids()