Commit 0364a882 authored by Juergen Gross's avatar Juergen Gross Committed by David S. Miller

xen-netback: switch to threaded irq for control ring

Instead of open coding it use the threaded irq mechanism in
xen-netback.
Signed-off-by: default avatarJuergen Gross <jgross@suse.com>
Acked-by: default avatarWei Liu <wei.liu2@citrix.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent f6f7d9c0
...@@ -292,8 +292,6 @@ struct xenvif { ...@@ -292,8 +292,6 @@ struct xenvif {
#endif #endif
struct xen_netif_ctrl_back_ring ctrl; struct xen_netif_ctrl_back_ring ctrl;
struct task_struct *ctrl_task;
wait_queue_head_t ctrl_wq;
unsigned int ctrl_irq; unsigned int ctrl_irq;
/* Miscellaneous private stuff. */ /* Miscellaneous private stuff. */
...@@ -359,7 +357,7 @@ void xenvif_kick_thread(struct xenvif_queue *queue); ...@@ -359,7 +357,7 @@ void xenvif_kick_thread(struct xenvif_queue *queue);
int xenvif_dealloc_kthread(void *data); int xenvif_dealloc_kthread(void *data);
int xenvif_ctrl_kthread(void *data); irqreturn_t xenvif_ctrl_irq_fn(int irq, void *data);
void xenvif_rx_queue_tail(struct xenvif_queue *queue, struct sk_buff *skb); void xenvif_rx_queue_tail(struct xenvif_queue *queue, struct sk_buff *skb);
......
...@@ -128,15 +128,6 @@ irqreturn_t xenvif_interrupt(int irq, void *dev_id) ...@@ -128,15 +128,6 @@ irqreturn_t xenvif_interrupt(int irq, void *dev_id)
return IRQ_HANDLED; return IRQ_HANDLED;
} }
irqreturn_t xenvif_ctrl_interrupt(int irq, void *dev_id)
{
struct xenvif *vif = dev_id;
wake_up(&vif->ctrl_wq);
return IRQ_HANDLED;
}
int xenvif_queue_stopped(struct xenvif_queue *queue) int xenvif_queue_stopped(struct xenvif_queue *queue)
{ {
struct net_device *dev = queue->vif->dev; struct net_device *dev = queue->vif->dev;
...@@ -570,8 +561,7 @@ int xenvif_connect_ctrl(struct xenvif *vif, grant_ref_t ring_ref, ...@@ -570,8 +561,7 @@ int xenvif_connect_ctrl(struct xenvif *vif, grant_ref_t ring_ref,
struct net_device *dev = vif->dev; struct net_device *dev = vif->dev;
void *addr; void *addr;
struct xen_netif_ctrl_sring *shared; struct xen_netif_ctrl_sring *shared;
struct task_struct *task; int err;
int err = -ENOMEM;
err = xenbus_map_ring_valloc(xenvif_to_xenbus_device(vif), err = xenbus_map_ring_valloc(xenvif_to_xenbus_device(vif),
&ring_ref, 1, &addr); &ring_ref, 1, &addr);
...@@ -581,11 +571,7 @@ int xenvif_connect_ctrl(struct xenvif *vif, grant_ref_t ring_ref, ...@@ -581,11 +571,7 @@ int xenvif_connect_ctrl(struct xenvif *vif, grant_ref_t ring_ref,
shared = (struct xen_netif_ctrl_sring *)addr; shared = (struct xen_netif_ctrl_sring *)addr;
BACK_RING_INIT(&vif->ctrl, shared, XEN_PAGE_SIZE); BACK_RING_INIT(&vif->ctrl, shared, XEN_PAGE_SIZE);
init_waitqueue_head(&vif->ctrl_wq); err = bind_interdomain_evtchn_to_irq(vif->domid, evtchn);
err = bind_interdomain_evtchn_to_irqhandler(vif->domid, evtchn,
xenvif_ctrl_interrupt,
0, dev->name, vif);
if (err < 0) if (err < 0)
goto err_unmap; goto err_unmap;
...@@ -593,19 +579,13 @@ int xenvif_connect_ctrl(struct xenvif *vif, grant_ref_t ring_ref, ...@@ -593,19 +579,13 @@ int xenvif_connect_ctrl(struct xenvif *vif, grant_ref_t ring_ref,
xenvif_init_hash(vif); xenvif_init_hash(vif);
task = kthread_create(xenvif_ctrl_kthread, (void *)vif, err = request_threaded_irq(vif->ctrl_irq, NULL, xenvif_ctrl_irq_fn,
"%s-control", dev->name); IRQF_ONESHOT, "xen-netback-ctrl", vif);
if (IS_ERR(task)) { if (err) {
pr_warn("Could not allocate kthread for %s\n", dev->name); pr_warn("Could not setup irq handler for %s\n", dev->name);
err = PTR_ERR(task);
goto err_deinit; goto err_deinit;
} }
get_task_struct(task);
vif->ctrl_task = task;
wake_up_process(vif->ctrl_task);
return 0; return 0;
err_deinit: err_deinit:
...@@ -774,12 +754,6 @@ void xenvif_disconnect_data(struct xenvif *vif) ...@@ -774,12 +754,6 @@ void xenvif_disconnect_data(struct xenvif *vif)
void xenvif_disconnect_ctrl(struct xenvif *vif) void xenvif_disconnect_ctrl(struct xenvif *vif)
{ {
if (vif->ctrl_task) {
kthread_stop(vif->ctrl_task);
put_task_struct(vif->ctrl_task);
vif->ctrl_task = NULL;
}
if (vif->ctrl_irq) { if (vif->ctrl_irq) {
xenvif_deinit_hash(vif); xenvif_deinit_hash(vif);
unbind_from_irqhandler(vif->ctrl_irq, vif); unbind_from_irqhandler(vif->ctrl_irq, vif);
......
...@@ -2359,24 +2359,14 @@ static bool xenvif_ctrl_work_todo(struct xenvif *vif) ...@@ -2359,24 +2359,14 @@ static bool xenvif_ctrl_work_todo(struct xenvif *vif)
return 0; return 0;
} }
int xenvif_ctrl_kthread(void *data) irqreturn_t xenvif_ctrl_irq_fn(int irq, void *data)
{ {
struct xenvif *vif = data; struct xenvif *vif = data;
for (;;) { while (xenvif_ctrl_work_todo(vif))
wait_event_interruptible(vif->ctrl_wq, xenvif_ctrl_action(vif);
xenvif_ctrl_work_todo(vif) ||
kthread_should_stop());
if (kthread_should_stop())
break;
while (xenvif_ctrl_work_todo(vif))
xenvif_ctrl_action(vif);
cond_resched(); return IRQ_HANDLED;
}
return 0;
} }
static int __init netback_init(void) static int __init netback_init(void)
......
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