Commit 122a5f64 authored by Haiyang Zhang's avatar Haiyang Zhang Committed by Greg Kroah-Hartman

staging: hv: use delayed_work for netvsc_send_garp()

Instead of sleeping in a scheduled work, we now use delayed_work
for netvsc_send_garp().
Signed-off-by: default avatarHaiyang Zhang <haiyangz@microsoft.com>
Signed-off-by: default avatarHank Janssen <hjanssen@microsoft.com>
Signed-off-by: default avatarK. Y. Srinivasan <kys@microsoft.com>
Cc: Stephen Hemminger <shemminger@vyatta.com>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@suse.de>
parent 729a2849
...@@ -46,7 +46,7 @@ struct net_device_context { ...@@ -46,7 +46,7 @@ struct net_device_context {
/* point back to our device context */ /* point back to our device context */
struct hv_device *device_ctx; struct hv_device *device_ctx;
unsigned long avail; unsigned long avail;
struct work_struct work; struct delayed_work dwork;
}; };
...@@ -217,7 +217,7 @@ void netvsc_linkstatus_callback(struct hv_device *device_obj, ...@@ -217,7 +217,7 @@ void netvsc_linkstatus_callback(struct hv_device *device_obj,
netif_wake_queue(net); netif_wake_queue(net);
netif_notify_peers(net); netif_notify_peers(net);
ndev_ctx = netdev_priv(net); ndev_ctx = netdev_priv(net);
schedule_work(&ndev_ctx->work); schedule_delayed_work(&ndev_ctx->dwork, msecs_to_jiffies(20));
} else { } else {
netif_carrier_off(net); netif_carrier_off(net);
netif_stop_queue(net); netif_stop_queue(net);
...@@ -315,7 +315,7 @@ static const struct net_device_ops device_ops = { ...@@ -315,7 +315,7 @@ static const struct net_device_ops device_ops = {
* Send GARP packet to network peers after migrations. * Send GARP packet to network peers after migrations.
* After Quick Migration, the network is not immediately operational in the * After Quick Migration, the network is not immediately operational in the
* current context when receiving RNDIS_STATUS_MEDIA_CONNECT event. So, add * current context when receiving RNDIS_STATUS_MEDIA_CONNECT event. So, add
* another netif_notify_peers() into a scheduled work, otherwise GARP packet * another netif_notify_peers() into a delayed work, otherwise GARP packet
* will not be sent after quick migration, and cause network disconnection. * will not be sent after quick migration, and cause network disconnection.
*/ */
static void netvsc_send_garp(struct work_struct *w) static void netvsc_send_garp(struct work_struct *w)
...@@ -323,8 +323,7 @@ static void netvsc_send_garp(struct work_struct *w) ...@@ -323,8 +323,7 @@ static void netvsc_send_garp(struct work_struct *w)
struct net_device_context *ndev_ctx; struct net_device_context *ndev_ctx;
struct net_device *net; struct net_device *net;
msleep(20); ndev_ctx = container_of(w, struct net_device_context, dwork.work);
ndev_ctx = container_of(w, struct net_device_context, work);
net = dev_get_drvdata(&ndev_ctx->device_ctx->device); net = dev_get_drvdata(&ndev_ctx->device_ctx->device);
netif_notify_peers(net); netif_notify_peers(net);
} }
...@@ -348,7 +347,7 @@ static int netvsc_probe(struct hv_device *dev) ...@@ -348,7 +347,7 @@ static int netvsc_probe(struct hv_device *dev)
net_device_ctx->device_ctx = dev; net_device_ctx->device_ctx = dev;
net_device_ctx->avail = ring_size; net_device_ctx->avail = ring_size;
dev_set_drvdata(&dev->device, net); dev_set_drvdata(&dev->device, net);
INIT_WORK(&net_device_ctx->work, netvsc_send_garp); INIT_DELAYED_WORK(&net_device_ctx->dwork, netvsc_send_garp);
/* Notify the netvsc driver of the new device */ /* Notify the netvsc driver of the new device */
device_info.ring_size = ring_size; device_info.ring_size = ring_size;
...@@ -387,12 +386,16 @@ static int netvsc_probe(struct hv_device *dev) ...@@ -387,12 +386,16 @@ static int netvsc_probe(struct hv_device *dev)
static int netvsc_remove(struct hv_device *dev) static int netvsc_remove(struct hv_device *dev)
{ {
struct net_device *net = dev_get_drvdata(&dev->device); struct net_device *net = dev_get_drvdata(&dev->device);
struct net_device_context *ndev_ctx;
if (net == NULL) { if (net == NULL) {
dev_err(&dev->device, "No net device to remove\n"); dev_err(&dev->device, "No net device to remove\n");
return 0; return 0;
} }
ndev_ctx = netdev_priv(net);
cancel_delayed_work_sync(&ndev_ctx->dwork);
/* Stop outbound asap */ /* Stop outbound asap */
netif_stop_queue(net); netif_stop_queue(net);
......
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