|
|
@@ -1269,7 +1269,9 @@ static int virtnet_poll(struct napi_struct *napi, int budget)
|
|
|
{
|
|
|
struct receive_queue *rq =
|
|
|
container_of(napi, struct receive_queue, napi);
|
|
|
- unsigned int received;
|
|
|
+ struct virtnet_info *vi = rq->vq->vdev->priv;
|
|
|
+ struct send_queue *sq;
|
|
|
+ unsigned int received, qp;
|
|
|
bool xdp_xmit = false;
|
|
|
|
|
|
virtnet_poll_cleantx(rq);
|
|
|
@@ -1280,8 +1282,13 @@ static int virtnet_poll(struct napi_struct *napi, int budget)
|
|
|
if (received < budget)
|
|
|
virtqueue_napi_complete(napi, rq->vq, received);
|
|
|
|
|
|
- if (xdp_xmit)
|
|
|
+ if (xdp_xmit) {
|
|
|
+ qp = vi->curr_queue_pairs - vi->xdp_queue_pairs +
|
|
|
+ smp_processor_id();
|
|
|
+ sq = &vi->sq[qp];
|
|
|
+ virtqueue_kick(sq->vq);
|
|
|
xdp_do_flush_map();
|
|
|
+ }
|
|
|
|
|
|
return received;
|
|
|
}
|