Lines Matching refs:queue
933 struct netdev_rx_queue *queue = to_rx_queue(kobj); in rx_queue_attr_show() local
938 return attribute->show(queue, buf); in rx_queue_attr_show()
945 struct netdev_rx_queue *queue = to_rx_queue(kobj); in rx_queue_attr_store() local
950 return attribute->store(queue, buf, count); in rx_queue_attr_store()
959 static ssize_t show_rps_map(struct netdev_rx_queue *queue, char *buf) in show_rps_map() argument
969 map = rcu_dereference(queue->rps_map); in show_rps_map()
981 static int netdev_rx_queue_set_rps_mask(struct netdev_rx_queue *queue, in netdev_rx_queue_set_rps_mask() argument
1006 old_map = rcu_dereference_protected(queue->rps_map, in netdev_rx_queue_set_rps_mask()
1008 rcu_assign_pointer(queue->rps_map, map); in netdev_rx_queue_set_rps_mask()
1033 static ssize_t store_rps_map(struct netdev_rx_queue *queue, in store_rps_map() argument
1053 err = netdev_rx_queue_set_rps_mask(queue, mask); in store_rps_map()
1060 static ssize_t show_rps_dev_flow_table_cnt(struct netdev_rx_queue *queue, in show_rps_dev_flow_table_cnt() argument
1067 flow_table = rcu_dereference(queue->rps_flow_table); in show_rps_dev_flow_table_cnt()
1082 static ssize_t store_rps_dev_flow_table_cnt(struct netdev_rx_queue *queue, in store_rps_dev_flow_table_cnt() argument
1130 old_table = rcu_dereference_protected(queue->rps_flow_table, in store_rps_dev_flow_table_cnt()
1132 rcu_assign_pointer(queue->rps_flow_table, table); in store_rps_dev_flow_table_cnt()
1160 struct netdev_rx_queue *queue = to_rx_queue(kobj); in rx_queue_release() local
1165 map = rcu_dereference_protected(queue->rps_map, 1); in rx_queue_release()
1167 RCU_INIT_POINTER(queue->rps_map, NULL); in rx_queue_release()
1171 flow_table = rcu_dereference_protected(queue->rps_flow_table, 1); in rx_queue_release()
1173 RCU_INIT_POINTER(queue->rps_flow_table, NULL); in rx_queue_release()
1179 netdev_put(queue->dev, &queue->dev_tracker); in rx_queue_release()
1184 struct netdev_rx_queue *queue = to_rx_queue(kobj); in rx_queue_namespace() local
1185 struct device *dev = &queue->dev->dev; in rx_queue_namespace()
1210 struct netdev_rx_queue *queue) in rx_queue_default_mask() argument
1220 res = netdev_rx_queue_set_rps_mask(queue, rps_default_mask); in rx_queue_default_mask()
1232 struct netdev_rx_queue *queue = dev->_rx + index; in rx_queue_add_kobject() local
1233 struct kobject *kobj = &queue->kobj; in rx_queue_add_kobject()
1255 netdev_hold(queue->dev, &queue->dev_tracker, GFP_KERNEL); in rx_queue_add_kobject()
1263 queue->groups = rx_queue_default_groups; in rx_queue_add_kobject()
1264 error = sysfs_create_groups(kobj, queue->groups); in rx_queue_add_kobject()
1274 error = rx_queue_default_mask(dev, queue); in rx_queue_add_kobject()
1283 sysfs_remove_groups(kobj, queue->groups); in rx_queue_add_kobject()
1292 struct netdev_rx_queue *queue = dev->_rx + index; in rx_queue_change_owner() local
1293 struct kobject *kobj = &queue->kobj; in rx_queue_change_owner()
1328 struct netdev_rx_queue *queue = &dev->_rx[i]; in net_rx_queue_update_kobjects() local
1329 struct kobject *kobj = &queue->kobj; in net_rx_queue_update_kobjects()
1335 sysfs_remove_groups(kobj, queue->groups); in net_rx_queue_update_kobjects()
1375 struct netdev_queue *queue, char *buf);
1377 struct netdev_queue *queue, const char *buf,
1390 struct netdev_queue *queue = to_netdev_queue(kobj); in netdev_queue_attr_show() local
1395 return attribute->show(kobj, attr, queue, buf); in netdev_queue_attr_show()
1404 struct netdev_queue *queue = to_netdev_queue(kobj); in netdev_queue_attr_store() local
1409 return attribute->store(kobj, attr, queue, buf, count); in netdev_queue_attr_store()
1418 struct netdev_queue *queue, char *buf) in tx_timeout_show() argument
1420 unsigned long trans_timeout = atomic_long_read(&queue->trans_timeout); in tx_timeout_show()
1425 static unsigned int get_netdev_queue_index(struct netdev_queue *queue) in get_netdev_queue_index() argument
1427 struct net_device *dev = queue->dev; in get_netdev_queue_index()
1430 i = queue - dev->_tx; in get_netdev_queue_index()
1437 struct netdev_queue *queue, char *buf) in traffic_class_show() argument
1439 struct net_device *dev = queue->dev; in traffic_class_show()
1445 ret = sysfs_rtnl_lock(kobj, attr, queue->dev); in traffic_class_show()
1449 index = get_netdev_queue_index(queue); in traffic_class_show()
1475 struct netdev_queue *queue, char *buf) in tx_maxrate_show() argument
1477 return sysfs_emit(buf, "%lu\n", queue->tx_maxrate); in tx_maxrate_show()
1481 struct netdev_queue *queue, const char *buf, in tx_maxrate_store() argument
1484 int err, index = get_netdev_queue_index(queue); in tx_maxrate_store()
1485 struct net_device *dev = queue->dev; in tx_maxrate_store()
1512 queue->tx_maxrate = rate; in tx_maxrate_store()
1562 struct netdev_queue *queue, char *buf) in bql_show_hold_time() argument
1564 struct dql *dql = &queue->dql; in bql_show_hold_time()
1570 struct netdev_queue *queue, const char *buf, in bql_set_hold_time() argument
1573 struct dql *dql = &queue->dql; in bql_set_hold_time()
1591 struct netdev_queue *queue, char *buf) in bql_show_stall_thrs() argument
1593 struct dql *dql = &queue->dql; in bql_show_stall_thrs()
1599 struct netdev_queue *queue, const char *buf, in bql_set_stall_thrs() argument
1602 struct dql *dql = &queue->dql; in bql_set_stall_thrs()
1627 struct netdev_queue *queue, char *buf) in bql_show_stall_max() argument
1629 return sysfs_emit(buf, "%u\n", READ_ONCE(queue->dql.stall_max)); in bql_show_stall_max()
1633 struct netdev_queue *queue, const char *buf, in bql_set_stall_max() argument
1636 WRITE_ONCE(queue->dql.stall_max, 0); in bql_set_stall_max()
1644 struct netdev_queue *queue, char *buf) in bql_show_stall_cnt() argument
1646 struct dql *dql = &queue->dql; in bql_show_stall_cnt()
1655 struct netdev_queue *queue, char *buf) in bql_show_inflight() argument
1657 struct dql *dql = &queue->dql; in bql_show_inflight()
1668 struct netdev_queue *queue, char *buf) \
1670 return bql_show(buf, queue->dql.FIELD); \
1675 struct netdev_queue *queue, \
1678 return bql_set(buf, len, &queue->dql.FIELD); \
1762 struct netdev_queue *queue, char *buf) in xps_cpus_show() argument
1764 struct net_device *dev = queue->dev; in xps_cpus_show()
1771 index = get_netdev_queue_index(queue); in xps_cpus_show()
1773 ret = sysfs_rtnl_lock(kobj, attr, queue->dev); in xps_cpus_show()
1799 struct netdev_queue *queue, const char *buf, in xps_cpus_store() argument
1802 struct net_device *dev = queue->dev; in xps_cpus_store()
1816 index = get_netdev_queue_index(queue); in xps_cpus_store()
1842 struct netdev_queue *queue, char *buf) in xps_rxqs_show() argument
1844 struct net_device *dev = queue->dev; in xps_rxqs_show()
1848 index = get_netdev_queue_index(queue); in xps_rxqs_show()
1868 struct netdev_queue *queue, const char *buf, in xps_rxqs_store() argument
1871 struct net_device *dev = queue->dev; in xps_rxqs_store()
1884 index = get_netdev_queue_index(queue); in xps_rxqs_store()
1926 struct netdev_queue *queue = to_netdev_queue(kobj); in netdev_queue_release() local
1929 netdev_put(queue->dev, &queue->dev_tracker); in netdev_queue_release()
1934 struct netdev_queue *queue = to_netdev_queue(kobj); in netdev_queue_namespace() local
1935 struct device *dev = &queue->dev->dev; in netdev_queue_namespace()
1969 struct netdev_queue *queue = dev->_tx + index; in netdev_queue_add_kobject() local
1970 struct kobject *kobj = &queue->kobj; in netdev_queue_add_kobject()
1992 netdev_hold(queue->dev, &queue->dev_tracker, GFP_KERNEL); in netdev_queue_add_kobject()
2000 queue->groups = netdev_queue_default_groups; in netdev_queue_add_kobject()
2001 error = sysfs_create_groups(kobj, queue->groups); in netdev_queue_add_kobject()
2015 sysfs_remove_groups(kobj, queue->groups); in netdev_queue_add_kobject()
2024 struct netdev_queue *queue = ndev->_tx + index; in tx_queue_change_owner() local
2025 struct kobject *kobj = &queue->kobj; in tx_queue_change_owner()
2062 struct netdev_queue *queue = dev->_tx + i; in netdev_queue_update_kobjects() local
2065 queue->kobj.uevent_suppress = 1; in netdev_queue_update_kobjects()
2068 sysfs_remove_group(&queue->kobj, &dql_group); in netdev_queue_update_kobjects()
2070 sysfs_remove_groups(&queue->kobj, queue->groups); in netdev_queue_update_kobjects()
2071 kobject_put(&queue->kobj); in netdev_queue_update_kobjects()