Lines Matching refs:queue
101 struct dsw_queue *queue = &dsw->queues[queue_id]; in dsw_queue_setup() local
113 queue->schedule_type = RTE_SCHED_TYPE_ATOMIC; in dsw_queue_setup()
118 queue->schedule_type = conf->schedule_type; in dsw_queue_setup()
121 queue->num_serving_ports = 0; in dsw_queue_setup()
145 queue_add_port(struct dsw_queue *queue, uint16_t port_id) in queue_add_port() argument
147 queue->serving_ports[queue->num_serving_ports] = port_id; in queue_add_port()
148 queue->num_serving_ports++; in queue_add_port()
152 queue_remove_port(struct dsw_queue *queue, uint16_t port_id) in queue_remove_port() argument
156 for (i = 0; i < queue->num_serving_ports; i++) in queue_remove_port()
157 if (queue->serving_ports[i] == port_id) { in queue_remove_port()
158 uint16_t last_idx = queue->num_serving_ports - 1; in queue_remove_port()
160 queue->serving_ports[i] = in queue_remove_port()
161 queue->serving_ports[last_idx]; in queue_remove_port()
162 queue->num_serving_ports--; in queue_remove_port()
255 struct dsw_queue *queue = &dsw->queues[queue_id]; in initial_flow_to_port_assignment() local
259 rte_rand() % queue->num_serving_ports; in initial_flow_to_port_assignment()
261 queue->serving_ports[port_idx]; in initial_flow_to_port_assignment()