Lines Matching refs:queue
618 struct netdev_rx_queue *queue = to_rx_queue(kobj); in rx_queue_attr_show() local
623 return attribute->show(queue, attribute, buf); in rx_queue_attr_show()
630 struct netdev_rx_queue *queue = to_rx_queue(kobj); in rx_queue_attr_store() local
635 return attribute->store(queue, attribute, buf, count); in rx_queue_attr_store()
644 static ssize_t show_rps_map(struct netdev_rx_queue *queue, in show_rps_map() argument
655 map = rcu_dereference(queue->rps_map); in show_rps_map()
667 static ssize_t store_rps_map(struct netdev_rx_queue *queue, in store_rps_map() argument
708 old_map = rcu_dereference_protected(queue->rps_map, in store_rps_map()
710 rcu_assign_pointer(queue->rps_map, map); in store_rps_map()
723 static ssize_t show_rps_dev_flow_table_cnt(struct netdev_rx_queue *queue, in show_rps_dev_flow_table_cnt() argument
731 flow_table = rcu_dereference(queue->rps_flow_table); in show_rps_dev_flow_table_cnt()
746 static ssize_t store_rps_dev_flow_table_cnt(struct netdev_rx_queue *queue, in store_rps_dev_flow_table_cnt() argument
794 old_table = rcu_dereference_protected(queue->rps_flow_table, in store_rps_dev_flow_table_cnt()
796 rcu_assign_pointer(queue->rps_flow_table, table); in store_rps_dev_flow_table_cnt()
824 struct netdev_rx_queue *queue = to_rx_queue(kobj); in rx_queue_release() local
830 map = rcu_dereference_protected(queue->rps_map, 1); in rx_queue_release()
832 RCU_INIT_POINTER(queue->rps_map, NULL); in rx_queue_release()
836 flow_table = rcu_dereference_protected(queue->rps_flow_table, 1); in rx_queue_release()
838 RCU_INIT_POINTER(queue->rps_flow_table, NULL); in rx_queue_release()
844 dev_put(queue->dev); in rx_queue_release()
849 struct netdev_rx_queue *queue = to_rx_queue(kobj); in rx_queue_namespace() local
850 struct device *dev = &queue->dev->dev; in rx_queue_namespace()
868 struct netdev_rx_queue *queue = dev->_rx + index; in rx_queue_add_kobject() local
869 struct kobject *kobj = &queue->kobj; in rx_queue_add_kobject()
885 dev_hold(queue->dev); in rx_queue_add_kobject()
932 ssize_t (*show)(struct netdev_queue *queue,
934 ssize_t (*store)(struct netdev_queue *queue,
946 struct netdev_queue *queue = to_netdev_queue(kobj); in netdev_queue_attr_show() local
951 return attribute->show(queue, attribute, buf); in netdev_queue_attr_show()
959 struct netdev_queue *queue = to_netdev_queue(kobj); in netdev_queue_attr_store() local
964 return attribute->store(queue, attribute, buf, count); in netdev_queue_attr_store()
972 static ssize_t show_trans_timeout(struct netdev_queue *queue, in show_trans_timeout() argument
978 spin_lock_irq(&queue->_xmit_lock); in show_trans_timeout()
979 trans_timeout = queue->trans_timeout; in show_trans_timeout()
980 spin_unlock_irq(&queue->_xmit_lock); in show_trans_timeout()
986 static inline unsigned int get_netdev_queue_index(struct netdev_queue *queue) in get_netdev_queue_index() argument
988 struct net_device *dev = queue->dev; in get_netdev_queue_index()
992 if (queue == &dev->_tx[i]) in get_netdev_queue_index()
1000 static ssize_t show_tx_maxrate(struct netdev_queue *queue, in show_tx_maxrate() argument
1004 return sprintf(buf, "%lu\n", queue->tx_maxrate); in show_tx_maxrate()
1007 static ssize_t set_tx_maxrate(struct netdev_queue *queue, in set_tx_maxrate() argument
1011 struct net_device *dev = queue->dev; in set_tx_maxrate()
1012 int err, index = get_netdev_queue_index(queue); in set_tx_maxrate()
1028 queue->tx_maxrate = rate; in set_tx_maxrate()
1072 static ssize_t bql_show_hold_time(struct netdev_queue *queue, in bql_show_hold_time() argument
1076 struct dql *dql = &queue->dql; in bql_show_hold_time()
1081 static ssize_t bql_set_hold_time(struct netdev_queue *queue, in bql_set_hold_time() argument
1085 struct dql *dql = &queue->dql; in bql_set_hold_time()
1102 static ssize_t bql_show_inflight(struct netdev_queue *queue, in bql_show_inflight() argument
1106 struct dql *dql = &queue->dql; in bql_show_inflight()
1115 static ssize_t bql_show_ ## NAME(struct netdev_queue *queue, \
1119 return bql_show(buf, queue->dql.FIELD); \
1122 static ssize_t bql_set_ ## NAME(struct netdev_queue *queue, \
1126 return bql_set(buf, len, &queue->dql.FIELD); \
1153 static ssize_t show_xps_map(struct netdev_queue *queue, in show_xps_map() argument
1156 struct net_device *dev = queue->dev; in show_xps_map()
1165 index = get_netdev_queue_index(queue); in show_xps_map()
1191 static ssize_t store_xps_map(struct netdev_queue *queue, in store_xps_map() argument
1195 struct net_device *dev = queue->dev; in store_xps_map()
1206 index = get_netdev_queue_index(queue); in store_xps_map()
1236 struct netdev_queue *queue = to_netdev_queue(kobj); in netdev_queue_release() local
1239 dev_put(queue->dev); in netdev_queue_release()
1244 struct netdev_queue *queue = to_netdev_queue(kobj); in netdev_queue_namespace() local
1245 struct device *dev = &queue->dev->dev; in netdev_queue_namespace()
1263 struct netdev_queue *queue = dev->_tx + index; in netdev_queue_add_kobject() local
1264 struct kobject *kobj = &queue->kobj; in netdev_queue_add_kobject()
1280 dev_hold(queue->dev); in netdev_queue_add_kobject()
1305 struct netdev_queue *queue = dev->_tx + i; in netdev_queue_update_kobjects() local
1308 sysfs_remove_group(&queue->kobj, &dql_group); in netdev_queue_update_kobjects()
1310 kobject_put(&queue->kobj); in netdev_queue_update_kobjects()