Skip to content

Commit d51bffd

Browse files
sowminivdavem330
sowminiv
authored and
davem330
committed
sunvnet: Use one Tx queue per vnet_port
Use multple Tx netdev queues for sunvnet by supporting a one-to-one mapping between vnet_port and Tx queue. Provide a ndo_select_queue indirection (vnet_select_queue()) which selects the queue based on the peer that would be selected in vnet_start_xmit() Signed-off-by: Sowmini Varadhan <sowmini.varadhan@oracle.com> Signed-off-by: David S. Miller <davem@davemloft.net>
1 parent 7bd68bf commit d51bffd

File tree

2 files changed

+65
-31
lines changed

2 files changed

+65
-31
lines changed

‎drivers/net/ethernet/sun/sunvnet.c

Lines changed: 63 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,8 @@ MODULE_DESCRIPTION("Sun LDOM virtual network driver");
4040
MODULE_LICENSE("GPL");
4141
MODULE_VERSION(DRV_MODULE_VERSION);
4242

43+
#define VNET_MAX_TXQS 16
44+
4345
/* Heuristic for the number of times to exponentially backoff and
4446
* retry sending an LDC trigger when EAGAIN is encountered
4547
*/
@@ -551,6 +553,8 @@ static int vnet_ack(struct vnet_port *port, void *msgbuf)
551553
struct vnet *vp;
552554
u32 end;
553555
struct vio_net_desc *desc;
556+
struct netdev_queue *txq;
557+
554558
if (unlikely(pkt->tag.stype_env != VIO_DRING_DATA))
555559
return 0;
556560

@@ -580,7 +584,8 @@ static int vnet_ack(struct vnet_port *port, void *msgbuf)
580584
}
581585
netif_tx_unlock(dev);
582586

583-
if (unlikely(netif_queue_stopped(dev) &&
587+
txq = netdev_get_tx_queue(dev, port->q_index);
588+
if (unlikely(netif_tx_queue_stopped(txq) &&
584589
vnet_tx_dring_avail(dr) >= VNET_TX_WAKEUP_THRESH(dr)))
585590
return 1;
586591

@@ -608,31 +613,23 @@ static int handle_mcast(struct vnet_port *port, void *msgbuf)
608613
return 0;
609614
}
610615

611-
static void maybe_tx_wakeup(struct vnet *vp)
616+
/* Got back a STOPPED LDC message on port. If the queue is stopped,
617+
* wake it up so that we'll send out another START message at the
618+
* next TX.
619+
*/
620+
static void maybe_tx_wakeup(struct vnet_port *port)
612621
{
613-
struct net_device *dev = vp->dev;
622+
struct netdev_queue *txq;
614623

615-
netif_tx_lock(dev);
616-
if (likely(netif_queue_stopped(dev))) {
617-
struct vnet_port *port;
618-
int wake = 1;
619-
620-
rcu_read_lock();
621-
list_for_each_entry_rcu(port, &vp->port_list, list) {
622-
struct vio_dring_state *dr;
623-
624-
dr = &port->vio.drings[VIO_DRIVER_TX_RING];
625-
if (vnet_tx_dring_avail(dr) <
626-
VNET_TX_WAKEUP_THRESH(dr)) {
627-
wake = 0;
628-
break;
629-
}
630-
}
631-
rcu_read_unlock();
632-
if (wake)
633-
netif_wake_queue(dev);
624+
txq = netdev_get_tx_queue(port->vp->dev, port->q_index);
625+
__netif_tx_lock(txq, smp_processor_id());
626+
if (likely(netif_tx_queue_stopped(txq))) {
627+
struct vio_dring_state *dr;
628+
629+
dr = &port->vio.drings[VIO_DRIVER_TX_RING];
630+
netif_tx_wake_queue(txq);
634631
}
635-
netif_tx_unlock(dev);
632+
__netif_tx_unlock(txq);
636633
}
637634

638635
static inline bool port_is_up(struct vnet_port *vnet)
@@ -748,7 +745,7 @@ static int vnet_event_napi(struct vnet_port *port, int budget)
748745
break;
749746
}
750747
if (unlikely(tx_wakeup && err != -ECONNRESET))
751-
maybe_tx_wakeup(port->vp);
748+
maybe_tx_wakeup(port);
752749
return npkts;
753750
}
754751

@@ -953,6 +950,16 @@ static inline struct sk_buff *vnet_skb_shape(struct sk_buff *skb, void **pstart,
953950
return skb;
954951
}
955952

953+
static u16
954+
vnet_select_queue(struct net_device *dev, struct sk_buff *skb,
955+
void *accel_priv, select_queue_fallback_t fallback)
956+
{
957+
struct vnet *vp = netdev_priv(dev);
958+
struct vnet_port *port = __tx_port_find(vp, skb);
959+
960+
return port->q_index;
961+
}
962+
956963
static int vnet_start_xmit(struct sk_buff *skb, struct net_device *dev)
957964
{
958965
struct vnet *vp = netdev_priv(dev);
@@ -965,6 +972,7 @@ static int vnet_start_xmit(struct sk_buff *skb, struct net_device *dev)
965972
void *start = NULL;
966973
int nlen = 0;
967974
unsigned pending = 0;
975+
struct netdev_queue *txq;
968976

969977
skb = vnet_skb_shape(skb, &start, &nlen);
970978
if (unlikely(!skb))
@@ -1008,9 +1016,11 @@ static int vnet_start_xmit(struct sk_buff *skb, struct net_device *dev)
10081016
}
10091017

10101018
dr = &port->vio.drings[VIO_DRIVER_TX_RING];
1019+
i = skb_get_queue_mapping(skb);
1020+
txq = netdev_get_tx_queue(dev, i);
10111021
if (unlikely(vnet_tx_dring_avail(dr) < 1)) {
1012-
if (!netif_queue_stopped(dev)) {
1013-
netif_stop_queue(dev);
1022+
if (!netif_tx_queue_stopped(txq)) {
1023+
netif_tx_stop_queue(txq);
10141024

10151025
/* This is a hard error, log it. */
10161026
netdev_err(dev, "BUG! Tx Ring full when queue awake!\n");
@@ -1104,9 +1114,9 @@ static int vnet_start_xmit(struct sk_buff *skb, struct net_device *dev)
11041114

11051115
dr->prod = (dr->prod + 1) & (VNET_TX_RING_SIZE - 1);
11061116
if (unlikely(vnet_tx_dring_avail(dr) < 1)) {
1107-
netif_stop_queue(dev);
1117+
netif_tx_stop_queue(txq);
11081118
if (vnet_tx_dring_avail(dr) > VNET_TX_WAKEUP_THRESH(dr))
1109-
netif_wake_queue(dev);
1119+
netif_tx_wake_queue(txq);
11101120
}
11111121

11121122
(void)mod_timer(&port->clean_timer, jiffies + VNET_CLEAN_TIMEOUT);
@@ -1139,14 +1149,14 @@ static void vnet_tx_timeout(struct net_device *dev)
11391149
static int vnet_open(struct net_device *dev)
11401150
{
11411151
netif_carrier_on(dev);
1142-
netif_start_queue(dev);
1152+
netif_tx_start_all_queues(dev);
11431153

11441154
return 0;
11451155
}
11461156

11471157
static int vnet_close(struct net_device *dev)
11481158
{
1149-
netif_stop_queue(dev);
1159+
netif_tx_stop_all_queues(dev);
11501160
netif_carrier_off(dev);
11511161

11521162
return 0;
@@ -1420,6 +1430,7 @@ static const struct net_device_ops vnet_ops = {
14201430
.ndo_tx_timeout = vnet_tx_timeout,
14211431
.ndo_change_mtu = vnet_change_mtu,
14221432
.ndo_start_xmit = vnet_start_xmit,
1433+
.ndo_select_queue = vnet_select_queue,
14231434
#ifdef CONFIG_NET_POLL_CONTROLLER
14241435
.ndo_poll_controller = vnet_poll_controller,
14251436
#endif
@@ -1431,7 +1442,7 @@ static struct vnet *vnet_new(const u64 *local_mac)
14311442
struct vnet *vp;
14321443
int err, i;
14331444

1434-
dev = alloc_etherdev(sizeof(*vp));
1445+
dev = alloc_etherdev_mqs(sizeof(*vp), VNET_MAX_TXQS, 1);
14351446
if (!dev)
14361447
return ERR_PTR(-ENOMEM);
14371448
dev->needed_headroom = VNET_PACKET_SKIP + 8;
@@ -1556,6 +1567,25 @@ static void print_version(void)
15561567

15571568
const char *remote_macaddr_prop = "remote-mac-address";
15581569

1570+
static void
1571+
vnet_port_add_txq(struct vnet_port *port)
1572+
{
1573+
struct vnet *vp = port->vp;
1574+
int n;
1575+
1576+
n = vp->nports++;
1577+
n = n & (VNET_MAX_TXQS - 1);
1578+
port->q_index = n;
1579+
netif_tx_wake_queue(netdev_get_tx_queue(vp->dev, port->q_index));
1580+
}
1581+
1582+
static void
1583+
vnet_port_rm_txq(struct vnet_port *port)
1584+
{
1585+
port->vp->nports--;
1586+
netif_tx_stop_queue(netdev_get_tx_queue(port->vp->dev, port->q_index));
1587+
}
1588+
15591589
static int vnet_port_probe(struct vio_dev *vdev, const struct vio_device_id *id)
15601590
{
15611591
struct mdesc_handle *hp;
@@ -1624,6 +1654,7 @@ static int vnet_port_probe(struct vio_dev *vdev, const struct vio_device_id *id)
16241654
list_add_tail_rcu(&port->list, &vp->port_list);
16251655
hlist_add_head_rcu(&port->hash,
16261656
&vp->port_hash[vnet_hashfn(port->raddr)]);
1657+
vnet_port_add_txq(port);
16271658
spin_unlock_irqrestore(&vp->lock, flags);
16281659

16291660
dev_set_drvdata(&vdev->dev, port);
@@ -1668,6 +1699,7 @@ static int vnet_port_remove(struct vio_dev *vdev)
16681699

16691700
synchronize_rcu();
16701701
del_timer_sync(&port->clean_timer);
1702+
vnet_port_rm_txq(port);
16711703
netif_napi_del(&port->napi);
16721704
vnet_port_free_tx_bufs(port);
16731705
vio_ldc_free(&port->vio);

‎drivers/net/ethernet/sun/sunvnet.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ struct vnet_port {
6161
u32 napi_stop_idx;
6262
bool napi_resume;
6363
int rx_event;
64+
u16 q_index;
6465
};
6566

6667
static inline struct vnet_port *to_vnet_port(struct vio_driver_state *vio)
@@ -102,6 +103,7 @@ struct vnet {
102103
struct list_head list;
103104
u64 local_mac;
104105

106+
int nports;
105107
};
106108

107109
#endif /* _SUNVNET_H */

0 commit comments

Comments
 (0)