]> git.karo-electronics.de Git - karo-tx-linux.git/blob - drivers/net/wireless/ath/ath9k/wmi.c
ath9k_htc: Add a timer to cleanup WMI events
[karo-tx-linux.git] / drivers / net / wireless / ath / ath9k / wmi.c
1 /*
2  * Copyright (c) 2010 Atheros Communications Inc.
3  *
4  * Permission to use, copy, modify, and/or distribute this software for any
5  * purpose with or without fee is hereby granted, provided that the above
6  * copyright notice and this permission notice appear in all copies.
7  *
8  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
9  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
10  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
11  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
12  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
13  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
14  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
15  */
16
17 #include "htc.h"
18
19 static const char *wmi_cmd_to_name(enum wmi_cmd_id wmi_cmd)
20 {
21         switch (wmi_cmd) {
22         case WMI_ECHO_CMDID:
23                 return "WMI_ECHO_CMDID";
24         case WMI_ACCESS_MEMORY_CMDID:
25                 return "WMI_ACCESS_MEMORY_CMDID";
26         case WMI_GET_FW_VERSION:
27                 return "WMI_GET_FW_VERSION";
28         case WMI_DISABLE_INTR_CMDID:
29                 return "WMI_DISABLE_INTR_CMDID";
30         case WMI_ENABLE_INTR_CMDID:
31                 return "WMI_ENABLE_INTR_CMDID";
32         case WMI_ATH_INIT_CMDID:
33                 return "WMI_ATH_INIT_CMDID";
34         case WMI_ABORT_TXQ_CMDID:
35                 return "WMI_ABORT_TXQ_CMDID";
36         case WMI_STOP_TX_DMA_CMDID:
37                 return "WMI_STOP_TX_DMA_CMDID";
38         case WMI_ABORT_TX_DMA_CMDID:
39                 return "WMI_ABORT_TX_DMA_CMDID";
40         case WMI_DRAIN_TXQ_CMDID:
41                 return "WMI_DRAIN_TXQ_CMDID";
42         case WMI_DRAIN_TXQ_ALL_CMDID:
43                 return "WMI_DRAIN_TXQ_ALL_CMDID";
44         case WMI_START_RECV_CMDID:
45                 return "WMI_START_RECV_CMDID";
46         case WMI_STOP_RECV_CMDID:
47                 return "WMI_STOP_RECV_CMDID";
48         case WMI_FLUSH_RECV_CMDID:
49                 return "WMI_FLUSH_RECV_CMDID";
50         case WMI_SET_MODE_CMDID:
51                 return "WMI_SET_MODE_CMDID";
52         case WMI_NODE_CREATE_CMDID:
53                 return "WMI_NODE_CREATE_CMDID";
54         case WMI_NODE_REMOVE_CMDID:
55                 return "WMI_NODE_REMOVE_CMDID";
56         case WMI_VAP_REMOVE_CMDID:
57                 return "WMI_VAP_REMOVE_CMDID";
58         case WMI_VAP_CREATE_CMDID:
59                 return "WMI_VAP_CREATE_CMDID";
60         case WMI_REG_READ_CMDID:
61                 return "WMI_REG_READ_CMDID";
62         case WMI_REG_WRITE_CMDID:
63                 return "WMI_REG_WRITE_CMDID";
64         case WMI_RC_STATE_CHANGE_CMDID:
65                 return "WMI_RC_STATE_CHANGE_CMDID";
66         case WMI_RC_RATE_UPDATE_CMDID:
67                 return "WMI_RC_RATE_UPDATE_CMDID";
68         case WMI_TARGET_IC_UPDATE_CMDID:
69                 return "WMI_TARGET_IC_UPDATE_CMDID";
70         case WMI_TGT_STATS_CMDID:
71                 return "WMI_TGT_STATS_CMDID";
72         case WMI_TX_AGGR_ENABLE_CMDID:
73                 return "WMI_TX_AGGR_ENABLE_CMDID";
74         case WMI_TGT_DETACH_CMDID:
75                 return "WMI_TGT_DETACH_CMDID";
76         case WMI_AGGR_LIMIT_CMD:
77                 return "WMI_AGGR_LIMIT_CMD";
78         }
79
80         return "Bogus";
81 }
82
83 struct wmi *ath9k_init_wmi(struct ath9k_htc_priv *priv)
84 {
85         struct wmi *wmi;
86
87         wmi = kzalloc(sizeof(struct wmi), GFP_KERNEL);
88         if (!wmi)
89                 return NULL;
90
91         wmi->drv_priv = priv;
92         wmi->stopped = false;
93         skb_queue_head_init(&wmi->wmi_event_queue);
94         spin_lock_init(&wmi->wmi_lock);
95         spin_lock_init(&wmi->event_lock);
96         mutex_init(&wmi->op_mutex);
97         mutex_init(&wmi->multi_write_mutex);
98         init_completion(&wmi->cmd_wait);
99         INIT_LIST_HEAD(&wmi->pending_tx_events);
100         tasklet_init(&wmi->wmi_event_tasklet, ath9k_wmi_event_tasklet,
101                      (unsigned long)wmi);
102
103         return wmi;
104 }
105
106 void ath9k_deinit_wmi(struct ath9k_htc_priv *priv)
107 {
108         struct wmi *wmi = priv->wmi;
109
110         mutex_lock(&wmi->op_mutex);
111         wmi->stopped = true;
112         mutex_unlock(&wmi->op_mutex);
113
114         kfree(priv->wmi);
115 }
116
117 void ath9k_wmi_event_drain(struct ath9k_htc_priv *priv)
118 {
119         unsigned long flags;
120
121         tasklet_kill(&priv->wmi->wmi_event_tasklet);
122         spin_lock_irqsave(&priv->wmi->wmi_lock, flags);
123         __skb_queue_purge(&priv->wmi->wmi_event_queue);
124         spin_unlock_irqrestore(&priv->wmi->wmi_lock, flags);
125 }
126
127 void ath9k_wmi_event_tasklet(unsigned long data)
128 {
129         struct wmi *wmi = (struct wmi *)data;
130         struct ath9k_htc_priv *priv = wmi->drv_priv;
131         struct wmi_cmd_hdr *hdr;
132         void *wmi_event;
133         struct wmi_event_swba *swba;
134         struct sk_buff *skb = NULL;
135         unsigned long flags;
136         u16 cmd_id;
137 #ifdef CONFIG_ATH9K_HTC_DEBUGFS
138         __be32 txrate;
139 #endif
140
141         do {
142                 spin_lock_irqsave(&wmi->wmi_lock, flags);
143                 skb = __skb_dequeue(&wmi->wmi_event_queue);
144                 if (!skb) {
145                         spin_unlock_irqrestore(&wmi->wmi_lock, flags);
146                         return;
147                 }
148                 spin_unlock_irqrestore(&wmi->wmi_lock, flags);
149
150                 hdr = (struct wmi_cmd_hdr *) skb->data;
151                 cmd_id = be16_to_cpu(hdr->command_id);
152                 wmi_event = skb_pull(skb, sizeof(struct wmi_cmd_hdr));
153
154                 switch (cmd_id) {
155                 case WMI_SWBA_EVENTID:
156                         swba = (struct wmi_event_swba *) wmi_event;
157                         ath9k_htc_swba(priv, swba);
158                         break;
159                 case WMI_FATAL_EVENTID:
160                         ieee80211_queue_work(wmi->drv_priv->hw,
161                                              &wmi->drv_priv->fatal_work);
162                         break;
163                 case WMI_TXRATE_EVENTID:
164 #ifdef CONFIG_ATH9K_HTC_DEBUGFS
165                         txrate = ((struct wmi_event_txrate *)wmi_event)->txrate;
166                         wmi->drv_priv->debug.txrate = be32_to_cpu(txrate);
167 #endif
168                         break;
169                 case WMI_TXSTATUS_EVENTID:
170                         spin_lock_bh(&priv->tx.tx_lock);
171                         if (priv->tx.flags & ATH9K_HTC_OP_TX_DRAIN) {
172                                 spin_unlock_bh(&priv->tx.tx_lock);
173                                 break;
174                         }
175                         spin_unlock_bh(&priv->tx.tx_lock);
176
177                         ath9k_htc_txstatus(priv, wmi_event);
178                         break;
179                 default:
180                         break;
181                 }
182
183                 kfree_skb(skb);
184         } while (1);
185 }
186
187 void ath9k_fatal_work(struct work_struct *work)
188 {
189         struct ath9k_htc_priv *priv = container_of(work, struct ath9k_htc_priv,
190                                                    fatal_work);
191         struct ath_common *common = ath9k_hw_common(priv->ah);
192
193         ath_dbg(common, ATH_DBG_FATAL, "FATAL Event received, resetting device\n");
194         ath9k_htc_reset(priv);
195 }
196
197 static void ath9k_wmi_rsp_callback(struct wmi *wmi, struct sk_buff *skb)
198 {
199         skb_pull(skb, sizeof(struct wmi_cmd_hdr));
200
201         if (wmi->cmd_rsp_buf != NULL && wmi->cmd_rsp_len != 0)
202                 memcpy(wmi->cmd_rsp_buf, skb->data, wmi->cmd_rsp_len);
203
204         complete(&wmi->cmd_wait);
205 }
206
207 static void ath9k_wmi_ctrl_rx(void *priv, struct sk_buff *skb,
208                               enum htc_endpoint_id epid)
209 {
210         struct wmi *wmi = (struct wmi *) priv;
211         struct wmi_cmd_hdr *hdr;
212         u16 cmd_id;
213
214         if (unlikely(wmi->stopped))
215                 goto free_skb;
216
217         hdr = (struct wmi_cmd_hdr *) skb->data;
218         cmd_id = be16_to_cpu(hdr->command_id);
219
220         if (cmd_id & 0x1000) {
221                 spin_lock(&wmi->wmi_lock);
222                 __skb_queue_tail(&wmi->wmi_event_queue, skb);
223                 spin_unlock(&wmi->wmi_lock);
224                 tasklet_schedule(&wmi->wmi_event_tasklet);
225                 return;
226         }
227
228         /* Check if there has been a timeout. */
229         spin_lock(&wmi->wmi_lock);
230         if (cmd_id != wmi->last_cmd_id) {
231                 spin_unlock(&wmi->wmi_lock);
232                 goto free_skb;
233         }
234         spin_unlock(&wmi->wmi_lock);
235
236         /* WMI command response */
237         ath9k_wmi_rsp_callback(wmi, skb);
238
239 free_skb:
240         kfree_skb(skb);
241 }
242
243 static void ath9k_wmi_ctrl_tx(void *priv, struct sk_buff *skb,
244                               enum htc_endpoint_id epid, bool txok)
245 {
246         kfree_skb(skb);
247 }
248
249 int ath9k_wmi_connect(struct htc_target *htc, struct wmi *wmi,
250                       enum htc_endpoint_id *wmi_ctrl_epid)
251 {
252         struct htc_service_connreq connect;
253         int ret;
254
255         wmi->htc = htc;
256
257         memset(&connect, 0, sizeof(connect));
258
259         connect.ep_callbacks.priv = wmi;
260         connect.ep_callbacks.tx = ath9k_wmi_ctrl_tx;
261         connect.ep_callbacks.rx = ath9k_wmi_ctrl_rx;
262         connect.service_id = WMI_CONTROL_SVC;
263
264         ret = htc_connect_service(htc, &connect, &wmi->ctrl_epid);
265         if (ret)
266                 return ret;
267
268         *wmi_ctrl_epid = wmi->ctrl_epid;
269
270         return 0;
271 }
272
273 static int ath9k_wmi_cmd_issue(struct wmi *wmi,
274                                struct sk_buff *skb,
275                                enum wmi_cmd_id cmd, u16 len)
276 {
277         struct wmi_cmd_hdr *hdr;
278
279         hdr = (struct wmi_cmd_hdr *) skb_push(skb, sizeof(struct wmi_cmd_hdr));
280         hdr->command_id = cpu_to_be16(cmd);
281         hdr->seq_no = cpu_to_be16(++wmi->tx_seq_id);
282
283         return htc_send_epid(wmi->htc, skb, wmi->ctrl_epid);
284 }
285
286 int ath9k_wmi_cmd(struct wmi *wmi, enum wmi_cmd_id cmd_id,
287                   u8 *cmd_buf, u32 cmd_len,
288                   u8 *rsp_buf, u32 rsp_len,
289                   u32 timeout)
290 {
291         struct ath_hw *ah = wmi->drv_priv->ah;
292         struct ath_common *common = ath9k_hw_common(ah);
293         u16 headroom = sizeof(struct htc_frame_hdr) +
294                        sizeof(struct wmi_cmd_hdr);
295         struct sk_buff *skb;
296         u8 *data;
297         int time_left, ret = 0;
298         unsigned long flags;
299
300         if (ah->ah_flags & AH_UNPLUGGED)
301                 return 0;
302
303         skb = alloc_skb(headroom + cmd_len, GFP_ATOMIC);
304         if (!skb)
305                 return -ENOMEM;
306
307         skb_reserve(skb, headroom);
308
309         if (cmd_len != 0 && cmd_buf != NULL) {
310                 data = (u8 *) skb_put(skb, cmd_len);
311                 memcpy(data, cmd_buf, cmd_len);
312         }
313
314         mutex_lock(&wmi->op_mutex);
315
316         /* check if wmi stopped flag is set */
317         if (unlikely(wmi->stopped)) {
318                 ret = -EPROTO;
319                 goto out;
320         }
321
322         /* record the rsp buffer and length */
323         wmi->cmd_rsp_buf = rsp_buf;
324         wmi->cmd_rsp_len = rsp_len;
325
326         spin_lock_irqsave(&wmi->wmi_lock, flags);
327         wmi->last_cmd_id = cmd_id;
328         spin_unlock_irqrestore(&wmi->wmi_lock, flags);
329
330         ret = ath9k_wmi_cmd_issue(wmi, skb, cmd_id, cmd_len);
331         if (ret)
332                 goto out;
333
334         time_left = wait_for_completion_timeout(&wmi->cmd_wait, timeout);
335         if (!time_left) {
336                 ath_dbg(common, ATH_DBG_WMI,
337                         "Timeout waiting for WMI command: %s\n",
338                         wmi_cmd_to_name(cmd_id));
339                 mutex_unlock(&wmi->op_mutex);
340                 return -ETIMEDOUT;
341         }
342
343         mutex_unlock(&wmi->op_mutex);
344
345         return 0;
346
347 out:
348         ath_dbg(common, ATH_DBG_WMI,
349                 "WMI failure for: %s\n", wmi_cmd_to_name(cmd_id));
350         mutex_unlock(&wmi->op_mutex);
351         kfree_skb(skb);
352
353         return ret;
354 }