diff options
-rw-r--r-- | drivers/connector/cn_queue.c | 5 | ||||
-rw-r--r-- | drivers/connector/connector.c | 16 | ||||
-rw-r--r-- | include/linux/connector.h | 2 |
3 files changed, 10 insertions, 13 deletions
diff --git a/drivers/connector/cn_queue.c b/drivers/connector/cn_queue.c index b418b16e910e..296f51002b55 100644 --- a/drivers/connector/cn_queue.c +++ b/drivers/connector/cn_queue.c | |||
@@ -34,7 +34,7 @@ | |||
34 | void cn_queue_wrapper(struct work_struct *work) | 34 | void cn_queue_wrapper(struct work_struct *work) |
35 | { | 35 | { |
36 | struct cn_callback_entry *cbq = | 36 | struct cn_callback_entry *cbq = |
37 | container_of(work, struct cn_callback_entry, work.work); | 37 | container_of(work, struct cn_callback_entry, work); |
38 | struct cn_callback_data *d = &cbq->data; | 38 | struct cn_callback_data *d = &cbq->data; |
39 | 39 | ||
40 | d->callback(d->callback_priv); | 40 | d->callback(d->callback_priv); |
@@ -59,13 +59,12 @@ static struct cn_callback_entry *cn_queue_alloc_callback_entry(char *name, struc | |||
59 | memcpy(&cbq->id.id, id, sizeof(struct cb_id)); | 59 | memcpy(&cbq->id.id, id, sizeof(struct cb_id)); |
60 | cbq->data.callback = callback; | 60 | cbq->data.callback = callback; |
61 | 61 | ||
62 | INIT_DELAYED_WORK(&cbq->work, &cn_queue_wrapper); | 62 | INIT_WORK(&cbq->work, &cn_queue_wrapper); |
63 | return cbq; | 63 | return cbq; |
64 | } | 64 | } |
65 | 65 | ||
66 | static void cn_queue_free_callback(struct cn_callback_entry *cbq) | 66 | static void cn_queue_free_callback(struct cn_callback_entry *cbq) |
67 | { | 67 | { |
68 | cancel_delayed_work(&cbq->work); | ||
69 | flush_workqueue(cbq->pdev->cn_queue); | 68 | flush_workqueue(cbq->pdev->cn_queue); |
70 | 69 | ||
71 | kfree(cbq); | 70 | kfree(cbq); |
diff --git a/drivers/connector/connector.c b/drivers/connector/connector.c index 4cec1a82fd43..a44db75bc25b 100644 --- a/drivers/connector/connector.c +++ b/drivers/connector/connector.c | |||
@@ -135,16 +135,15 @@ static int cn_call_callback(struct cn_msg *msg, void (*destruct_data)(void *), v | |||
135 | spin_lock_bh(&dev->cbdev->queue_lock); | 135 | spin_lock_bh(&dev->cbdev->queue_lock); |
136 | list_for_each_entry(__cbq, &dev->cbdev->queue_list, callback_entry) { | 136 | list_for_each_entry(__cbq, &dev->cbdev->queue_list, callback_entry) { |
137 | if (cn_cb_equal(&__cbq->id.id, &msg->id)) { | 137 | if (cn_cb_equal(&__cbq->id.id, &msg->id)) { |
138 | if (likely(!work_pending(&__cbq->work.work) && | 138 | if (likely(!work_pending(&__cbq->work) && |
139 | __cbq->data.ddata == NULL)) { | 139 | __cbq->data.ddata == NULL)) { |
140 | __cbq->data.callback_priv = msg; | 140 | __cbq->data.callback_priv = msg; |
141 | 141 | ||
142 | __cbq->data.ddata = data; | 142 | __cbq->data.ddata = data; |
143 | __cbq->data.destruct_data = destruct_data; | 143 | __cbq->data.destruct_data = destruct_data; |
144 | 144 | ||
145 | if (queue_delayed_work( | 145 | if (queue_work(dev->cbdev->cn_queue, |
146 | dev->cbdev->cn_queue, | 146 | &__cbq->work)) |
147 | &__cbq->work, 0)) | ||
148 | err = 0; | 147 | err = 0; |
149 | } else { | 148 | } else { |
150 | struct cn_callback_data *d; | 149 | struct cn_callback_data *d; |
@@ -158,12 +157,11 @@ static int cn_call_callback(struct cn_msg *msg, void (*destruct_data)(void *), v | |||
158 | d->destruct_data = destruct_data; | 157 | d->destruct_data = destruct_data; |
159 | d->free = __cbq; | 158 | d->free = __cbq; |
160 | 159 | ||
161 | INIT_DELAYED_WORK(&__cbq->work, | 160 | INIT_WORK(&__cbq->work, |
162 | &cn_queue_wrapper); | 161 | &cn_queue_wrapper); |
163 | 162 | ||
164 | if (queue_delayed_work( | 163 | if (queue_work(dev->cbdev->cn_queue, |
165 | dev->cbdev->cn_queue, | 164 | &__cbq->work)) |
166 | &__cbq->work, 0)) | ||
167 | err = 0; | 165 | err = 0; |
168 | else { | 166 | else { |
169 | kfree(__cbq); | 167 | kfree(__cbq); |
diff --git a/include/linux/connector.h b/include/linux/connector.h index 3ea1cd58de97..10eb56b2940a 100644 --- a/include/linux/connector.h +++ b/include/linux/connector.h | |||
@@ -133,7 +133,7 @@ struct cn_callback_data { | |||
133 | struct cn_callback_entry { | 133 | struct cn_callback_entry { |
134 | struct list_head callback_entry; | 134 | struct list_head callback_entry; |
135 | struct cn_callback *cb; | 135 | struct cn_callback *cb; |
136 | struct delayed_work work; | 136 | struct work_struct work; |
137 | struct cn_queue_dev *pdev; | 137 | struct cn_queue_dev *pdev; |
138 | 138 | ||
139 | struct cn_callback_id id; | 139 | struct cn_callback_id id; |