Lines Matching defs:queue

787 	struct netdev_rx_queue *queue = to_rx_queue(kobj);
792 return attribute->show(queue, buf);
799 struct netdev_rx_queue *queue = to_rx_queue(kobj);
804 return attribute->store(queue, buf, count);
813 static ssize_t show_rps_map(struct netdev_rx_queue *queue, char *buf)
823 map = rcu_dereference(queue->rps_map);
835 static int netdev_rx_queue_set_rps_mask(struct netdev_rx_queue *queue,
860 old_map = rcu_dereference_protected(queue->rps_map,
862 rcu_assign_pointer(queue->rps_map, map);
887 static ssize_t store_rps_map(struct netdev_rx_queue *queue,
907 err = netdev_rx_queue_set_rps_mask(queue, mask);
914 static ssize_t show_rps_dev_flow_table_cnt(struct netdev_rx_queue *queue,
921 flow_table = rcu_dereference(queue->rps_flow_table);
936 static ssize_t store_rps_dev_flow_table_cnt(struct netdev_rx_queue *queue,
984 old_table = rcu_dereference_protected(queue->rps_flow_table,
986 rcu_assign_pointer(queue->rps_flow_table, table);
1014 struct netdev_rx_queue *queue = to_rx_queue(kobj);
1019 map = rcu_dereference_protected(queue->rps_map, 1);
1021 RCU_INIT_POINTER(queue->rps_map, NULL);
1025 flow_table = rcu_dereference_protected(queue->rps_flow_table, 1);
1027 RCU_INIT_POINTER(queue->rps_flow_table, NULL);
1033 netdev_put(queue->dev, &queue->dev_tracker);
1038 struct netdev_rx_queue *queue = to_rx_queue(kobj);
1039 struct device *dev = &queue->dev->dev;
1065 struct netdev_rx_queue *queue)
1071 return netdev_rx_queue_set_rps_mask(queue, rps_default_mask);
1078 struct netdev_rx_queue *queue = dev->_rx + index;
1079 struct kobject *kobj = &queue->kobj;
1085 netdev_hold(queue->dev, &queue->dev_tracker, GFP_KERNEL);
1099 error = rx_queue_default_mask(dev, queue);
1115 struct netdev_rx_queue *queue = dev->_rx + index;
1116 struct kobject *kobj = &queue->kobj;
1195 ssize_t (*show)(struct netdev_queue *queue, char *buf);
1196 ssize_t (*store)(struct netdev_queue *queue,
1209 struct netdev_queue *queue = to_netdev_queue(kobj);
1214 return attribute->show(queue, buf);
1223 struct netdev_queue *queue = to_netdev_queue(kobj);
1228 return attribute->store(queue, buf, count);
1236 static ssize_t tx_timeout_show(struct netdev_queue *queue, char *buf)
1238 unsigned long trans_timeout = atomic_long_read(&queue->trans_timeout);
1243 static unsigned int get_netdev_queue_index(struct netdev_queue *queue)
1245 struct net_device *dev = queue->dev;
1248 i = queue - dev->_tx;
1254 static ssize_t traffic_class_show(struct netdev_queue *queue,
1257 struct net_device *dev = queue->dev;
1267 index = get_netdev_queue_index(queue);
1269 /* If queue belongs to subordinate dev use its TC mapping */
1283 * subordinate device 2 will be reported as "0-2". If the queue
1292 static ssize_t tx_maxrate_show(struct netdev_queue *queue,
1295 return sysfs_emit(buf, "%lu\n", queue->tx_maxrate);
1298 static ssize_t tx_maxrate_store(struct netdev_queue *queue,
1301 struct net_device *dev = queue->dev;
1302 int err, index = get_netdev_queue_index(queue);
1327 queue->tx_maxrate = rate;
1345 * Byte queue limits sysfs structures and functions.
1373 static ssize_t bql_show_hold_time(struct netdev_queue *queue,
1376 struct dql *dql = &queue->dql;
1381 static ssize_t bql_set_hold_time(struct netdev_queue *queue,
1384 struct dql *dql = &queue->dql;
1401 static ssize_t bql_show_inflight(struct netdev_queue *queue,
1404 struct dql *dql = &queue->dql;
1413 static ssize_t bql_show_ ## NAME(struct netdev_queue *queue, \
1416 return bql_show(buf, queue->dql.FIELD); \
1419 static ssize_t bql_set_ ## NAME(struct netdev_queue *queue, \
1422 return bql_set(buf, len, &queue->dql.FIELD); \
1499 static ssize_t xps_cpus_show(struct netdev_queue *queue, char *buf)
1501 struct net_device *dev = queue->dev;
1508 index = get_netdev_queue_index(queue);
1513 /* If queue belongs to subordinate dev use its map */
1532 static ssize_t xps_cpus_store(struct netdev_queue *queue,
1535 struct net_device *dev = queue->dev;
1549 index = get_netdev_queue_index(queue);
1573 static ssize_t xps_rxqs_show(struct netdev_queue *queue, char *buf)
1575 struct net_device *dev = queue->dev;
1579 index = get_netdev_queue_index(queue);
1592 static ssize_t xps_rxqs_store(struct netdev_queue *queue, const char *buf,
1595 struct net_device *dev = queue->dev;
1608 index = get_netdev_queue_index(queue);
1649 struct netdev_queue *queue = to_netdev_queue(kobj);
1652 netdev_put(queue->dev, &queue->dev_tracker);
1657 struct netdev_queue *queue = to_netdev_queue(kobj);
1658 struct device *dev = &queue->dev->dev;
1685 struct netdev_queue *queue = dev->_tx + index;
1686 struct kobject *kobj = &queue->kobj;
1692 netdev_hold(queue->dev, &queue->dev_tracker, GFP_KERNEL);
1717 struct netdev_queue *queue = ndev->_tx + index;
1718 struct kobject *kobj = &queue->kobj;
1739 /* Tx queue kobjects are allowed to be updated when a device is being
1755 struct netdev_queue *queue = dev->_tx + i;
1758 queue->kobj.uevent_suppress = 1;
1760 sysfs_remove_group(&queue->kobj, &dql_group);
1762 kobject_put(&queue->kobj);