Lines Matching full:queues
353 struct netdev_queue_id *queues, in bind_rx_queue() argument
369 __netdev_bind_rx_req_set_queues(req, queues, n_queue_index); in bind_rx_queue()
438 struct netdev_queue_id *queues; in do_server() local
465 /* Configure RSS to divert all traffic from our devmem queues */ in do_server()
475 queues = malloc(sizeof(*queues) * num_queues); in do_server()
478 queues[i]._present.type = 1; in do_server()
479 queues[i]._present.id = 1; in do_server()
480 queues[i].type = NETDEV_QUEUE_TYPE_RX; in do_server()
481 queues[i].id = start_queue + i; in do_server()
484 if (bind_rx_queue(ifindex, mem->fd, queues, num_queues, &ys)) in do_server()
634 struct netdev_queue_id *queues; in run_devmem_tests() local
641 /* Configure RSS to divert all traffic from our devmem queues */ in run_devmem_tests()
645 queues = calloc(num_queues, sizeof(*queues)); in run_devmem_tests()
650 if (!bind_rx_queue(ifindex, mem->fd, queues, num_queues, &ys)) in run_devmem_tests()
651 error(1, 0, "Binding empty queues array should have failed\n"); in run_devmem_tests()
654 queues[i]._present.type = 1; in run_devmem_tests()
655 queues[i]._present.id = 1; in run_devmem_tests()
656 queues[i].type = NETDEV_QUEUE_TYPE_RX; in run_devmem_tests()
657 queues[i].id = start_queue + i; in run_devmem_tests()
663 if (!bind_rx_queue(ifindex, mem->fd, queues, num_queues, &ys)) in run_devmem_tests()
670 queues[i]._present.type = 1; in run_devmem_tests()
671 queues[i]._present.id = 1; in run_devmem_tests()
672 queues[i].type = NETDEV_QUEUE_TYPE_RX; in run_devmem_tests()
673 queues[i].id = start_queue + i; in run_devmem_tests()
676 if (bind_rx_queue(ifindex, mem->fd, queues, num_queues, &ys)) in run_devmem_tests()
736 error(1, 0, "couldn't detect number of queues\n"); in main()
739 "number of device queues is too low\n"); in main()
740 /* make sure can bind to multiple queues */ in main()
755 error(1, 0, "number of device queues is too low\n"); in main()
761 error(1, 0, "couldn't detect number of queues\n"); in main()
763 fprintf(stderr, "using queues %d..%d\n", start_queue, start_queue + num_queues); in main()