Commit f580aec4 authored by Vitaly Kuznetsov's avatar Vitaly Kuznetsov Committed by David S. Miller

hv_netvsc: move start_remove flag to net_device_context

struct netvsc_device is destroyed on mtu change so keeping the
protection flag there is not a good idea. Move it to struct
net_device_context which is preserved.
Signed-off-by: default avatarVitaly Kuznetsov <vkuznets@redhat.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent da47b457
...@@ -672,6 +672,9 @@ struct net_device_context { ...@@ -672,6 +672,9 @@ struct net_device_context {
/* Ethtool settings */ /* Ethtool settings */
u8 duplex; u8 duplex;
u32 speed; u32 speed;
/* the device is going away */
bool start_remove;
}; };
/* Per netvsc device */ /* Per netvsc device */
...@@ -682,7 +685,6 @@ struct netvsc_device { ...@@ -682,7 +685,6 @@ struct netvsc_device {
atomic_t num_outstanding_sends; atomic_t num_outstanding_sends;
wait_queue_head_t wait_drain; wait_queue_head_t wait_drain;
bool start_remove;
bool destroy; bool destroy;
/* Receive buffer allocated by us but manages by NetVSP */ /* Receive buffer allocated by us but manages by NetVSP */
......
...@@ -74,7 +74,6 @@ static struct netvsc_device *alloc_net_device(struct hv_device *device) ...@@ -74,7 +74,6 @@ static struct netvsc_device *alloc_net_device(struct hv_device *device)
} }
init_waitqueue_head(&net_device->wait_drain); init_waitqueue_head(&net_device->wait_drain);
net_device->start_remove = false;
net_device->destroy = false; net_device->destroy = false;
atomic_set(&net_device->open_cnt, 0); atomic_set(&net_device->open_cnt, 0);
atomic_set(&net_device->vf_use_cnt, 0); atomic_set(&net_device->vf_use_cnt, 0);
...@@ -691,7 +690,7 @@ static void netvsc_send_completion(struct netvsc_device *net_device, ...@@ -691,7 +690,7 @@ static void netvsc_send_completion(struct netvsc_device *net_device,
wake_up(&net_device->wait_drain); wake_up(&net_device->wait_drain);
if (netif_tx_queue_stopped(netdev_get_tx_queue(ndev, q_idx)) && if (netif_tx_queue_stopped(netdev_get_tx_queue(ndev, q_idx)) &&
!net_device->start_remove && !net_device->nd_ctx->start_remove &&
(hv_ringbuf_avail_percent(&channel->outbound) > (hv_ringbuf_avail_percent(&channel->outbound) >
RING_AVAIL_PERCENT_HIWATER || queue_sends < 1)) RING_AVAIL_PERCENT_HIWATER || queue_sends < 1))
netif_tx_wake_queue(netdev_get_tx_queue( netif_tx_wake_queue(netdev_get_tx_queue(
......
...@@ -793,7 +793,7 @@ static int netvsc_set_channels(struct net_device *net, ...@@ -793,7 +793,7 @@ static int netvsc_set_channels(struct net_device *net,
goto out; goto out;
do_set: do_set:
nvdev->start_remove = true; net_device_ctx->start_remove = true;
rndis_filter_device_remove(dev); rndis_filter_device_remove(dev);
nvdev->num_chn = channels->combined_count; nvdev->num_chn = channels->combined_count;
...@@ -837,6 +837,7 @@ static int netvsc_set_channels(struct net_device *net, ...@@ -837,6 +837,7 @@ static int netvsc_set_channels(struct net_device *net,
out: out:
netvsc_open(net); netvsc_open(net);
net_device_ctx->start_remove = false;
return ret; return ret;
...@@ -927,7 +928,7 @@ static int netvsc_change_mtu(struct net_device *ndev, int mtu) ...@@ -927,7 +928,7 @@ static int netvsc_change_mtu(struct net_device *ndev, int mtu)
num_chn = nvdev->num_chn; num_chn = nvdev->num_chn;
nvdev->start_remove = true; ndevctx->start_remove = true;
rndis_filter_device_remove(hdev); rndis_filter_device_remove(hdev);
ndev->mtu = mtu; ndev->mtu = mtu;
...@@ -943,6 +944,7 @@ static int netvsc_change_mtu(struct net_device *ndev, int mtu) ...@@ -943,6 +944,7 @@ static int netvsc_change_mtu(struct net_device *ndev, int mtu)
out: out:
netvsc_open(ndev); netvsc_open(ndev);
ndevctx->start_remove = false;
return ret; return ret;
} }
...@@ -1358,6 +1360,9 @@ static int netvsc_probe(struct hv_device *dev, ...@@ -1358,6 +1360,9 @@ static int netvsc_probe(struct hv_device *dev,
} }
hv_set_drvdata(dev, net); hv_set_drvdata(dev, net);
net_device_ctx->start_remove = false;
INIT_DELAYED_WORK(&net_device_ctx->dwork, netvsc_link_change); INIT_DELAYED_WORK(&net_device_ctx->dwork, netvsc_link_change);
INIT_WORK(&net_device_ctx->work, do_set_multicast); INIT_WORK(&net_device_ctx->work, do_set_multicast);
INIT_WORK(&net_device_ctx->gwrk.dwrk, netvsc_notify_peers); INIT_WORK(&net_device_ctx->gwrk.dwrk, netvsc_notify_peers);
...@@ -1419,9 +1424,10 @@ static int netvsc_remove(struct hv_device *dev) ...@@ -1419,9 +1424,10 @@ static int netvsc_remove(struct hv_device *dev)
return 0; return 0;
} }
net_device->start_remove = true;
ndev_ctx = netdev_priv(net); ndev_ctx = netdev_priv(net);
ndev_ctx->start_remove = true;
cancel_delayed_work_sync(&ndev_ctx->dwork); cancel_delayed_work_sync(&ndev_ctx->dwork);
cancel_work_sync(&ndev_ctx->work); cancel_work_sync(&ndev_ctx->work);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment