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: Haiyang Zhang <haiyangz@microsoft.com> Signed-off-by: Hank Janssen <hjanssen@microsoft.com> Signed-off-by: K. Y. Srinivasan <kys@microsoft.com> Cc: Stephen Hemminger <shemminger@vyatta.com> Signed-off-by: Greg Kroah-Hartman <gregkh@suse.de>
This commit is contained in:
parent
729a28495d
commit
122a5f6410
@ -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,
|
|||||||
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 = {
|
|||||||
* 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)
|
|||||||
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)
|
|||||||
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)
|
|||||||
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);
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user