|
@@ -1209,6 +1209,10 @@ static struct hv_device *netvsc_channel_to_device(struct vmbus_channel *channel)
|
|
|
return primary ? primary->device_obj : channel->device_obj;
|
|
|
}
|
|
|
|
|
|
+/* Network processing softirq
|
|
|
+ * Process data in incoming ring buffer from host
|
|
|
+ * Stops when ring is empty or budget is met or exceeded.
|
|
|
+ */
|
|
|
int netvsc_poll(struct napi_struct *napi, int budget)
|
|
|
{
|
|
|
struct netvsc_channel *nvchan
|
|
@@ -1238,7 +1242,11 @@ int netvsc_poll(struct napi_struct *napi, int budget)
|
|
|
}
|
|
|
hv_pkt_iter_close(channel);
|
|
|
|
|
|
- /* If ring is empty and NAPI is not doing polling */
|
|
|
+ /* If budget was not exhausted and
|
|
|
+ * not doing busy poll
|
|
|
+ * then re-enable host interrupts
|
|
|
+ * and reschedule if ring is not empty.
|
|
|
+ */
|
|
|
if (work_done < budget &&
|
|
|
napi_complete_done(napi, work_done) &&
|
|
|
hv_end_read(&channel->inbound) != 0)
|
|
@@ -1248,23 +1256,17 @@ int netvsc_poll(struct napi_struct *napi, int budget)
|
|
|
return work_done;
|
|
|
}
|
|
|
|
|
|
+/* Call back when data is available in host ring buffer.
|
|
|
+ * Processing is deferred until network softirq (NAPI)
|
|
|
+ */
|
|
|
void netvsc_channel_cb(void *context)
|
|
|
{
|
|
|
- struct vmbus_channel *channel = context;
|
|
|
- struct hv_device *device = netvsc_channel_to_device(channel);
|
|
|
- u16 q_idx = channel->offermsg.offer.sub_channel_index;
|
|
|
- struct netvsc_device *net_device;
|
|
|
- struct net_device *ndev;
|
|
|
-
|
|
|
- ndev = hv_get_drvdata(device);
|
|
|
- if (unlikely(!ndev))
|
|
|
- return;
|
|
|
+ struct netvsc_channel *nvchan = context;
|
|
|
|
|
|
/* disable interupts from host */
|
|
|
- hv_begin_read(&channel->inbound);
|
|
|
+ hv_begin_read(&nvchan->channel->inbound);
|
|
|
|
|
|
- net_device = net_device_to_netvsc_device(ndev);
|
|
|
- napi_schedule(&net_device->chan_table[q_idx].napi);
|
|
|
+ napi_schedule(&nvchan->napi);
|
|
|
}
|
|
|
|
|
|
/*
|
|
@@ -1294,7 +1296,8 @@ int netvsc_device_add(struct hv_device *device,
|
|
|
/* Open the channel */
|
|
|
ret = vmbus_open(device->channel, ring_size * PAGE_SIZE,
|
|
|
ring_size * PAGE_SIZE, NULL, 0,
|
|
|
- netvsc_channel_cb, device->channel);
|
|
|
+ netvsc_channel_cb,
|
|
|
+ net_device->chan_table);
|
|
|
|
|
|
if (ret != 0) {
|
|
|
netdev_err(ndev, "unable to open channel: %d\n", ret);
|