Linux Audio

Check our new training course

Loading...
v3.1
  1/*
  2 * Copyright (c) 2010-2011 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
 19static int htc_issue_send(struct htc_target *target, struct sk_buff* skb,
 20			  u16 len, u8 flags, u8 epid)
 21
 22{
 23	struct htc_frame_hdr *hdr;
 24	struct htc_endpoint *endpoint = &target->endpoint[epid];
 25	int status;
 26
 27	hdr = (struct htc_frame_hdr *)
 28		skb_push(skb, sizeof(struct htc_frame_hdr));
 29	hdr->endpoint_id = epid;
 30	hdr->flags = flags;
 31	hdr->payload_len = cpu_to_be16(len);
 32
 33	status = target->hif->send(target->hif_dev, endpoint->ul_pipeid, skb);
 34
 35	return status;
 36}
 37
 38static struct htc_endpoint *get_next_avail_ep(struct htc_endpoint *endpoint)
 39{
 40	enum htc_endpoint_id avail_epid;
 41
 42	for (avail_epid = (ENDPOINT_MAX - 1); avail_epid > ENDPOINT0; avail_epid--)
 43		if (endpoint[avail_epid].service_id == 0)
 44			return &endpoint[avail_epid];
 45	return NULL;
 46}
 47
 48static u8 service_to_ulpipe(u16 service_id)
 49{
 50	switch (service_id) {
 51	case WMI_CONTROL_SVC:
 52		return 4;
 53	case WMI_BEACON_SVC:
 54	case WMI_CAB_SVC:
 55	case WMI_UAPSD_SVC:
 56	case WMI_MGMT_SVC:
 57	case WMI_DATA_VO_SVC:
 58	case WMI_DATA_VI_SVC:
 59	case WMI_DATA_BE_SVC:
 60	case WMI_DATA_BK_SVC:
 61		return 1;
 62	default:
 63		return 0;
 64	}
 65}
 66
 67static u8 service_to_dlpipe(u16 service_id)
 68{
 69	switch (service_id) {
 70	case WMI_CONTROL_SVC:
 71		return 3;
 72	case WMI_BEACON_SVC:
 73	case WMI_CAB_SVC:
 74	case WMI_UAPSD_SVC:
 75	case WMI_MGMT_SVC:
 76	case WMI_DATA_VO_SVC:
 77	case WMI_DATA_VI_SVC:
 78	case WMI_DATA_BE_SVC:
 79	case WMI_DATA_BK_SVC:
 80		return 2;
 81	default:
 82		return 0;
 83	}
 84}
 85
 86static void htc_process_target_rdy(struct htc_target *target,
 87				   void *buf)
 88{
 89	struct htc_endpoint *endpoint;
 90	struct htc_ready_msg *htc_ready_msg = (struct htc_ready_msg *) buf;
 91
 92	target->credit_size = be16_to_cpu(htc_ready_msg->credit_size);
 93
 94	endpoint = &target->endpoint[ENDPOINT0];
 95	endpoint->service_id = HTC_CTRL_RSVD_SVC;
 96	endpoint->max_msglen = HTC_MAX_CONTROL_MESSAGE_LENGTH;
 97	atomic_inc(&target->tgt_ready);
 98	complete(&target->target_wait);
 99}
100
101static void htc_process_conn_rsp(struct htc_target *target,
102				 struct htc_frame_hdr *htc_hdr)
103{
104	struct htc_conn_svc_rspmsg *svc_rspmsg;
105	struct htc_endpoint *endpoint, *tmp_endpoint = NULL;
106	u16 service_id;
107	u16 max_msglen;
108	enum htc_endpoint_id epid, tepid;
109
110	svc_rspmsg = (struct htc_conn_svc_rspmsg *)
111		((void *) htc_hdr + sizeof(struct htc_frame_hdr));
112
113	if (svc_rspmsg->status == HTC_SERVICE_SUCCESS) {
114		epid = svc_rspmsg->endpoint_id;
115		service_id = be16_to_cpu(svc_rspmsg->service_id);
116		max_msglen = be16_to_cpu(svc_rspmsg->max_msg_len);
117		endpoint = &target->endpoint[epid];
118
119		for (tepid = (ENDPOINT_MAX - 1); tepid > ENDPOINT0; tepid--) {
120			tmp_endpoint = &target->endpoint[tepid];
121			if (tmp_endpoint->service_id == service_id) {
122				tmp_endpoint->service_id = 0;
123				break;
124			}
125		}
126
127		if (tepid == ENDPOINT0)
128			return;
129
130		endpoint->service_id = service_id;
131		endpoint->max_txqdepth = tmp_endpoint->max_txqdepth;
132		endpoint->ep_callbacks = tmp_endpoint->ep_callbacks;
133		endpoint->ul_pipeid = tmp_endpoint->ul_pipeid;
134		endpoint->dl_pipeid = tmp_endpoint->dl_pipeid;
135		endpoint->max_msglen = max_msglen;
136		target->conn_rsp_epid = epid;
137		complete(&target->cmd_wait);
138	} else {
139		target->conn_rsp_epid = ENDPOINT_UNUSED;
140	}
141}
142
143static int htc_config_pipe_credits(struct htc_target *target)
144{
145	struct sk_buff *skb;
146	struct htc_config_pipe_msg *cp_msg;
147	int ret, time_left;
 
148
149	skb = alloc_skb(50 + sizeof(struct htc_frame_hdr), GFP_ATOMIC);
150	if (!skb) {
151		dev_err(target->dev, "failed to allocate send buffer\n");
152		return -ENOMEM;
153	}
154	skb_reserve(skb, sizeof(struct htc_frame_hdr));
155
156	cp_msg = (struct htc_config_pipe_msg *)
157		skb_put(skb, sizeof(struct htc_config_pipe_msg));
158
159	cp_msg->message_id = cpu_to_be16(HTC_MSG_CONFIG_PIPE_ID);
160	cp_msg->pipe_id = USB_WLAN_TX_PIPE;
161	cp_msg->credits = target->credits;
162
163	target->htc_flags |= HTC_OP_CONFIG_PIPE_CREDITS;
164
165	ret = htc_issue_send(target, skb, skb->len, 0, ENDPOINT0);
166	if (ret)
167		goto err;
168
169	time_left = wait_for_completion_timeout(&target->cmd_wait, HZ);
170	if (!time_left) {
171		dev_err(target->dev, "HTC credit config timeout\n");
172		return -ETIMEDOUT;
173	}
174
175	return 0;
176err:
177	kfree_skb(skb);
178	return -EINVAL;
179}
180
181static int htc_setup_complete(struct htc_target *target)
182{
183	struct sk_buff *skb;
184	struct htc_comp_msg *comp_msg;
185	int ret = 0, time_left;
 
186
187	skb = alloc_skb(50 + sizeof(struct htc_frame_hdr), GFP_ATOMIC);
188	if (!skb) {
189		dev_err(target->dev, "failed to allocate send buffer\n");
190		return -ENOMEM;
191	}
192	skb_reserve(skb, sizeof(struct htc_frame_hdr));
193
194	comp_msg = (struct htc_comp_msg *)
195		skb_put(skb, sizeof(struct htc_comp_msg));
196	comp_msg->msg_id = cpu_to_be16(HTC_MSG_SETUP_COMPLETE_ID);
197
198	target->htc_flags |= HTC_OP_START_WAIT;
199
200	ret = htc_issue_send(target, skb, skb->len, 0, ENDPOINT0);
201	if (ret)
202		goto err;
203
204	time_left = wait_for_completion_timeout(&target->cmd_wait, HZ);
205	if (!time_left) {
206		dev_err(target->dev, "HTC start timeout\n");
207		return -ETIMEDOUT;
208	}
209
210	return 0;
211
212err:
213	kfree_skb(skb);
214	return -EINVAL;
215}
216
217/* HTC APIs */
218
219int htc_init(struct htc_target *target)
220{
221	int ret;
222
223	ret = htc_config_pipe_credits(target);
224	if (ret)
225		return ret;
226
227	return htc_setup_complete(target);
228}
229
230int htc_connect_service(struct htc_target *target,
231		     struct htc_service_connreq *service_connreq,
232		     enum htc_endpoint_id *conn_rsp_epid)
233{
234	struct sk_buff *skb;
235	struct htc_endpoint *endpoint;
236	struct htc_conn_svc_msg *conn_msg;
237	int ret, time_left;
 
238
239	/* Find an available endpoint */
240	endpoint = get_next_avail_ep(target->endpoint);
241	if (!endpoint) {
242		dev_err(target->dev, "Endpoint is not available for"
243			"service %d\n", service_connreq->service_id);
244		return -EINVAL;
245	}
246
247	endpoint->service_id = service_connreq->service_id;
248	endpoint->max_txqdepth = service_connreq->max_send_qdepth;
249	endpoint->ul_pipeid = service_to_ulpipe(service_connreq->service_id);
250	endpoint->dl_pipeid = service_to_dlpipe(service_connreq->service_id);
251	endpoint->ep_callbacks = service_connreq->ep_callbacks;
252
253	skb = alloc_skb(sizeof(struct htc_conn_svc_msg) +
254			    sizeof(struct htc_frame_hdr), GFP_ATOMIC);
255	if (!skb) {
256		dev_err(target->dev, "Failed to allocate buf to send"
257			"service connect req\n");
258		return -ENOMEM;
259	}
260
261	skb_reserve(skb, sizeof(struct htc_frame_hdr));
262
263	conn_msg = (struct htc_conn_svc_msg *)
264			skb_put(skb, sizeof(struct htc_conn_svc_msg));
265	conn_msg->service_id = cpu_to_be16(service_connreq->service_id);
266	conn_msg->msg_id = cpu_to_be16(HTC_MSG_CONNECT_SERVICE_ID);
267	conn_msg->con_flags = cpu_to_be16(service_connreq->con_flags);
268	conn_msg->dl_pipeid = endpoint->dl_pipeid;
269	conn_msg->ul_pipeid = endpoint->ul_pipeid;
270
271	ret = htc_issue_send(target, skb, skb->len, 0, ENDPOINT0);
272	if (ret)
273		goto err;
274
275	time_left = wait_for_completion_timeout(&target->cmd_wait, HZ);
276	if (!time_left) {
277		dev_err(target->dev, "Service connection timeout for: %d\n",
278			service_connreq->service_id);
279		return -ETIMEDOUT;
280	}
281
282	*conn_rsp_epid = target->conn_rsp_epid;
283	return 0;
284err:
285	kfree_skb(skb);
286	return ret;
287}
288
289int htc_send(struct htc_target *target, struct sk_buff *skb)
290{
291	struct ath9k_htc_tx_ctl *tx_ctl;
292
293	tx_ctl = HTC_SKB_CB(skb);
294	return htc_issue_send(target, skb, skb->len, 0, tx_ctl->epid);
295}
296
297int htc_send_epid(struct htc_target *target, struct sk_buff *skb,
298		  enum htc_endpoint_id epid)
299{
300	return htc_issue_send(target, skb, skb->len, 0, epid);
301}
302
303void htc_stop(struct htc_target *target)
304{
305	target->hif->stop(target->hif_dev);
306}
307
308void htc_start(struct htc_target *target)
309{
310	target->hif->start(target->hif_dev);
311}
312
313void htc_sta_drain(struct htc_target *target, u8 idx)
314{
315	target->hif->sta_drain(target->hif_dev, idx);
316}
317
318void ath9k_htc_txcompletion_cb(struct htc_target *htc_handle,
319			       struct sk_buff *skb, bool txok)
320{
321	struct htc_endpoint *endpoint;
322	struct htc_frame_hdr *htc_hdr = NULL;
323
324	if (htc_handle->htc_flags & HTC_OP_CONFIG_PIPE_CREDITS) {
325		complete(&htc_handle->cmd_wait);
326		htc_handle->htc_flags &= ~HTC_OP_CONFIG_PIPE_CREDITS;
327		goto ret;
328	}
329
330	if (htc_handle->htc_flags & HTC_OP_START_WAIT) {
331		complete(&htc_handle->cmd_wait);
332		htc_handle->htc_flags &= ~HTC_OP_START_WAIT;
333		goto ret;
334	}
335
336	if (skb) {
337		htc_hdr = (struct htc_frame_hdr *) skb->data;
338		endpoint = &htc_handle->endpoint[htc_hdr->endpoint_id];
339		skb_pull(skb, sizeof(struct htc_frame_hdr));
340
341		if (endpoint->ep_callbacks.tx) {
342			endpoint->ep_callbacks.tx(endpoint->ep_callbacks.priv,
343						  skb, htc_hdr->endpoint_id,
344						  txok);
 
 
345		}
346	}
347
348	return;
349ret:
350	/* HTC-generated packets are freed here. */
351	if (htc_hdr && htc_hdr->endpoint_id != ENDPOINT0)
352		dev_kfree_skb_any(skb);
353	else
354		kfree_skb(skb);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
355}
356
357/*
358 * HTC Messages are handled directly here and the obtained SKB
359 * is freed.
360 *
361 * Service messages (Data, WMI) passed to the corresponding
362 * endpoint RX handlers, which have to free the SKB.
363 */
364void ath9k_htc_rx_msg(struct htc_target *htc_handle,
365		      struct sk_buff *skb, u32 len, u8 pipe_id)
366{
367	struct htc_frame_hdr *htc_hdr;
368	enum htc_endpoint_id epid;
369	struct htc_endpoint *endpoint;
370	__be16 *msg_id;
371
372	if (!htc_handle || !skb)
373		return;
374
375	htc_hdr = (struct htc_frame_hdr *) skb->data;
376	epid = htc_hdr->endpoint_id;
377
378	if (epid >= ENDPOINT_MAX) {
 
 
 
 
 
 
379		if (pipe_id != USB_REG_IN_PIPE)
380			dev_kfree_skb_any(skb);
381		else
382			kfree_skb(skb);
383		return;
384	}
385
386	if (epid == ENDPOINT0) {
387
388		/* Handle trailer */
389		if (htc_hdr->flags & HTC_FLAGS_RECV_TRAILER) {
390			if (be32_to_cpu(*(__be32 *) skb->data) == 0x00C60000)
391				/* Move past the Watchdog pattern */
392				htc_hdr = (struct htc_frame_hdr *)(skb->data + 4);
393		}
394
395		/* Get the message ID */
396		msg_id = (__be16 *) ((void *) htc_hdr +
397				     sizeof(struct htc_frame_hdr));
398
399		/* Now process HTC messages */
400		switch (be16_to_cpu(*msg_id)) {
401		case HTC_MSG_READY_ID:
402			htc_process_target_rdy(htc_handle, htc_hdr);
403			break;
404		case HTC_MSG_CONNECT_SERVICE_RESPONSE_ID:
405			htc_process_conn_rsp(htc_handle, htc_hdr);
406			break;
407		default:
408			break;
409		}
410
411		kfree_skb(skb);
412
413	} else {
414		if (htc_hdr->flags & HTC_FLAGS_RECV_TRAILER)
415			skb_trim(skb, len - htc_hdr->control[0]);
416
417		skb_pull(skb, sizeof(struct htc_frame_hdr));
418
419		endpoint = &htc_handle->endpoint[epid];
420		if (endpoint->ep_callbacks.rx)
421			endpoint->ep_callbacks.rx(endpoint->ep_callbacks.priv,
422						  skb, epid);
423	}
424}
425
426struct htc_target *ath9k_htc_hw_alloc(void *hif_handle,
427				      struct ath9k_htc_hif *hif,
428				      struct device *dev)
429{
430	struct htc_endpoint *endpoint;
431	struct htc_target *target;
432
433	target = kzalloc(sizeof(struct htc_target), GFP_KERNEL);
434	if (!target) {
435		printk(KERN_ERR "Unable to allocate memory for"
436			"target device\n");
437		return NULL;
438	}
439
440	init_completion(&target->target_wait);
441	init_completion(&target->cmd_wait);
442
443	target->hif = hif;
444	target->hif_dev = hif_handle;
445	target->dev = dev;
446
447	/* Assign control endpoint pipe IDs */
448	endpoint = &target->endpoint[ENDPOINT0];
449	endpoint->ul_pipeid = hif->control_ul_pipe;
450	endpoint->dl_pipeid = hif->control_dl_pipe;
451
452	atomic_set(&target->tgt_ready, 0);
453
454	return target;
455}
456
457void ath9k_htc_hw_free(struct htc_target *htc)
458{
459	kfree(htc);
460}
461
462int ath9k_htc_hw_init(struct htc_target *target,
463		      struct device *dev, u16 devid,
464		      char *product, u32 drv_info)
465{
466	if (ath9k_htc_probe_device(target, dev, devid, product, drv_info)) {
467		printk(KERN_ERR "Failed to initialize the device\n");
468		return -ENODEV;
469	}
470
471	return 0;
472}
473
474void ath9k_htc_hw_deinit(struct htc_target *target, bool hot_unplug)
475{
476	if (target)
477		ath9k_htc_disconnect_device(target, hot_unplug);
478}
v4.6
  1/*
  2 * Copyright (c) 2010-2011 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#define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
 18
 19#include "htc.h"
 20
 21static int htc_issue_send(struct htc_target *target, struct sk_buff* skb,
 22			  u16 len, u8 flags, u8 epid)
 23
 24{
 25	struct htc_frame_hdr *hdr;
 26	struct htc_endpoint *endpoint = &target->endpoint[epid];
 27	int status;
 28
 29	hdr = (struct htc_frame_hdr *)
 30		skb_push(skb, sizeof(struct htc_frame_hdr));
 31	hdr->endpoint_id = epid;
 32	hdr->flags = flags;
 33	hdr->payload_len = cpu_to_be16(len);
 34
 35	status = target->hif->send(target->hif_dev, endpoint->ul_pipeid, skb);
 36
 37	return status;
 38}
 39
 40static struct htc_endpoint *get_next_avail_ep(struct htc_endpoint *endpoint)
 41{
 42	enum htc_endpoint_id avail_epid;
 43
 44	for (avail_epid = (ENDPOINT_MAX - 1); avail_epid > ENDPOINT0; avail_epid--)
 45		if (endpoint[avail_epid].service_id == 0)
 46			return &endpoint[avail_epid];
 47	return NULL;
 48}
 49
 50static u8 service_to_ulpipe(u16 service_id)
 51{
 52	switch (service_id) {
 53	case WMI_CONTROL_SVC:
 54		return 4;
 55	case WMI_BEACON_SVC:
 56	case WMI_CAB_SVC:
 57	case WMI_UAPSD_SVC:
 58	case WMI_MGMT_SVC:
 59	case WMI_DATA_VO_SVC:
 60	case WMI_DATA_VI_SVC:
 61	case WMI_DATA_BE_SVC:
 62	case WMI_DATA_BK_SVC:
 63		return 1;
 64	default:
 65		return 0;
 66	}
 67}
 68
 69static u8 service_to_dlpipe(u16 service_id)
 70{
 71	switch (service_id) {
 72	case WMI_CONTROL_SVC:
 73		return 3;
 74	case WMI_BEACON_SVC:
 75	case WMI_CAB_SVC:
 76	case WMI_UAPSD_SVC:
 77	case WMI_MGMT_SVC:
 78	case WMI_DATA_VO_SVC:
 79	case WMI_DATA_VI_SVC:
 80	case WMI_DATA_BE_SVC:
 81	case WMI_DATA_BK_SVC:
 82		return 2;
 83	default:
 84		return 0;
 85	}
 86}
 87
 88static void htc_process_target_rdy(struct htc_target *target,
 89				   void *buf)
 90{
 91	struct htc_endpoint *endpoint;
 92	struct htc_ready_msg *htc_ready_msg = (struct htc_ready_msg *) buf;
 93
 94	target->credit_size = be16_to_cpu(htc_ready_msg->credit_size);
 95
 96	endpoint = &target->endpoint[ENDPOINT0];
 97	endpoint->service_id = HTC_CTRL_RSVD_SVC;
 98	endpoint->max_msglen = HTC_MAX_CONTROL_MESSAGE_LENGTH;
 99	atomic_inc(&target->tgt_ready);
100	complete(&target->target_wait);
101}
102
103static void htc_process_conn_rsp(struct htc_target *target,
104				 struct htc_frame_hdr *htc_hdr)
105{
106	struct htc_conn_svc_rspmsg *svc_rspmsg;
107	struct htc_endpoint *endpoint, *tmp_endpoint = NULL;
108	u16 service_id;
109	u16 max_msglen;
110	enum htc_endpoint_id epid, tepid;
111
112	svc_rspmsg = (struct htc_conn_svc_rspmsg *)
113		((void *) htc_hdr + sizeof(struct htc_frame_hdr));
114
115	if (svc_rspmsg->status == HTC_SERVICE_SUCCESS) {
116		epid = svc_rspmsg->endpoint_id;
117		service_id = be16_to_cpu(svc_rspmsg->service_id);
118		max_msglen = be16_to_cpu(svc_rspmsg->max_msg_len);
119		endpoint = &target->endpoint[epid];
120
121		for (tepid = (ENDPOINT_MAX - 1); tepid > ENDPOINT0; tepid--) {
122			tmp_endpoint = &target->endpoint[tepid];
123			if (tmp_endpoint->service_id == service_id) {
124				tmp_endpoint->service_id = 0;
125				break;
126			}
127		}
128
129		if (tepid == ENDPOINT0)
130			return;
131
132		endpoint->service_id = service_id;
133		endpoint->max_txqdepth = tmp_endpoint->max_txqdepth;
134		endpoint->ep_callbacks = tmp_endpoint->ep_callbacks;
135		endpoint->ul_pipeid = tmp_endpoint->ul_pipeid;
136		endpoint->dl_pipeid = tmp_endpoint->dl_pipeid;
137		endpoint->max_msglen = max_msglen;
138		target->conn_rsp_epid = epid;
139		complete(&target->cmd_wait);
140	} else {
141		target->conn_rsp_epid = ENDPOINT_UNUSED;
142	}
143}
144
145static int htc_config_pipe_credits(struct htc_target *target)
146{
147	struct sk_buff *skb;
148	struct htc_config_pipe_msg *cp_msg;
149	int ret;
150	unsigned long time_left;
151
152	skb = alloc_skb(50 + sizeof(struct htc_frame_hdr), GFP_ATOMIC);
153	if (!skb) {
154		dev_err(target->dev, "failed to allocate send buffer\n");
155		return -ENOMEM;
156	}
157	skb_reserve(skb, sizeof(struct htc_frame_hdr));
158
159	cp_msg = (struct htc_config_pipe_msg *)
160		skb_put(skb, sizeof(struct htc_config_pipe_msg));
161
162	cp_msg->message_id = cpu_to_be16(HTC_MSG_CONFIG_PIPE_ID);
163	cp_msg->pipe_id = USB_WLAN_TX_PIPE;
164	cp_msg->credits = target->credits;
165
166	target->htc_flags |= HTC_OP_CONFIG_PIPE_CREDITS;
167
168	ret = htc_issue_send(target, skb, skb->len, 0, ENDPOINT0);
169	if (ret)
170		goto err;
171
172	time_left = wait_for_completion_timeout(&target->cmd_wait, HZ);
173	if (!time_left) {
174		dev_err(target->dev, "HTC credit config timeout\n");
175		return -ETIMEDOUT;
176	}
177
178	return 0;
179err:
180	kfree_skb(skb);
181	return -EINVAL;
182}
183
184static int htc_setup_complete(struct htc_target *target)
185{
186	struct sk_buff *skb;
187	struct htc_comp_msg *comp_msg;
188	int ret = 0;
189	unsigned long time_left;
190
191	skb = alloc_skb(50 + sizeof(struct htc_frame_hdr), GFP_ATOMIC);
192	if (!skb) {
193		dev_err(target->dev, "failed to allocate send buffer\n");
194		return -ENOMEM;
195	}
196	skb_reserve(skb, sizeof(struct htc_frame_hdr));
197
198	comp_msg = (struct htc_comp_msg *)
199		skb_put(skb, sizeof(struct htc_comp_msg));
200	comp_msg->msg_id = cpu_to_be16(HTC_MSG_SETUP_COMPLETE_ID);
201
202	target->htc_flags |= HTC_OP_START_WAIT;
203
204	ret = htc_issue_send(target, skb, skb->len, 0, ENDPOINT0);
205	if (ret)
206		goto err;
207
208	time_left = wait_for_completion_timeout(&target->cmd_wait, HZ);
209	if (!time_left) {
210		dev_err(target->dev, "HTC start timeout\n");
211		return -ETIMEDOUT;
212	}
213
214	return 0;
215
216err:
217	kfree_skb(skb);
218	return -EINVAL;
219}
220
221/* HTC APIs */
222
223int htc_init(struct htc_target *target)
224{
225	int ret;
226
227	ret = htc_config_pipe_credits(target);
228	if (ret)
229		return ret;
230
231	return htc_setup_complete(target);
232}
233
234int htc_connect_service(struct htc_target *target,
235		     struct htc_service_connreq *service_connreq,
236		     enum htc_endpoint_id *conn_rsp_epid)
237{
238	struct sk_buff *skb;
239	struct htc_endpoint *endpoint;
240	struct htc_conn_svc_msg *conn_msg;
241	int ret;
242	unsigned long time_left;
243
244	/* Find an available endpoint */
245	endpoint = get_next_avail_ep(target->endpoint);
246	if (!endpoint) {
247		dev_err(target->dev, "Endpoint is not available for"
248			"service %d\n", service_connreq->service_id);
249		return -EINVAL;
250	}
251
252	endpoint->service_id = service_connreq->service_id;
253	endpoint->max_txqdepth = service_connreq->max_send_qdepth;
254	endpoint->ul_pipeid = service_to_ulpipe(service_connreq->service_id);
255	endpoint->dl_pipeid = service_to_dlpipe(service_connreq->service_id);
256	endpoint->ep_callbacks = service_connreq->ep_callbacks;
257
258	skb = alloc_skb(sizeof(struct htc_conn_svc_msg) +
259			    sizeof(struct htc_frame_hdr), GFP_ATOMIC);
260	if (!skb) {
261		dev_err(target->dev, "Failed to allocate buf to send"
262			"service connect req\n");
263		return -ENOMEM;
264	}
265
266	skb_reserve(skb, sizeof(struct htc_frame_hdr));
267
268	conn_msg = (struct htc_conn_svc_msg *)
269			skb_put(skb, sizeof(struct htc_conn_svc_msg));
270	conn_msg->service_id = cpu_to_be16(service_connreq->service_id);
271	conn_msg->msg_id = cpu_to_be16(HTC_MSG_CONNECT_SERVICE_ID);
272	conn_msg->con_flags = cpu_to_be16(service_connreq->con_flags);
273	conn_msg->dl_pipeid = endpoint->dl_pipeid;
274	conn_msg->ul_pipeid = endpoint->ul_pipeid;
275
276	ret = htc_issue_send(target, skb, skb->len, 0, ENDPOINT0);
277	if (ret)
278		goto err;
279
280	time_left = wait_for_completion_timeout(&target->cmd_wait, HZ);
281	if (!time_left) {
282		dev_err(target->dev, "Service connection timeout for: %d\n",
283			service_connreq->service_id);
284		return -ETIMEDOUT;
285	}
286
287	*conn_rsp_epid = target->conn_rsp_epid;
288	return 0;
289err:
290	kfree_skb(skb);
291	return ret;
292}
293
294int htc_send(struct htc_target *target, struct sk_buff *skb)
295{
296	struct ath9k_htc_tx_ctl *tx_ctl;
297
298	tx_ctl = HTC_SKB_CB(skb);
299	return htc_issue_send(target, skb, skb->len, 0, tx_ctl->epid);
300}
301
302int htc_send_epid(struct htc_target *target, struct sk_buff *skb,
303		  enum htc_endpoint_id epid)
304{
305	return htc_issue_send(target, skb, skb->len, 0, epid);
306}
307
308void htc_stop(struct htc_target *target)
309{
310	target->hif->stop(target->hif_dev);
311}
312
313void htc_start(struct htc_target *target)
314{
315	target->hif->start(target->hif_dev);
316}
317
318void htc_sta_drain(struct htc_target *target, u8 idx)
319{
320	target->hif->sta_drain(target->hif_dev, idx);
321}
322
323void ath9k_htc_txcompletion_cb(struct htc_target *htc_handle,
324			       struct sk_buff *skb, bool txok)
325{
326	struct htc_endpoint *endpoint;
327	struct htc_frame_hdr *htc_hdr = NULL;
328
329	if (htc_handle->htc_flags & HTC_OP_CONFIG_PIPE_CREDITS) {
330		complete(&htc_handle->cmd_wait);
331		htc_handle->htc_flags &= ~HTC_OP_CONFIG_PIPE_CREDITS;
332		goto ret;
333	}
334
335	if (htc_handle->htc_flags & HTC_OP_START_WAIT) {
336		complete(&htc_handle->cmd_wait);
337		htc_handle->htc_flags &= ~HTC_OP_START_WAIT;
338		goto ret;
339	}
340
341	if (skb) {
342		htc_hdr = (struct htc_frame_hdr *) skb->data;
343		endpoint = &htc_handle->endpoint[htc_hdr->endpoint_id];
344		skb_pull(skb, sizeof(struct htc_frame_hdr));
345
346		if (endpoint->ep_callbacks.tx) {
347			endpoint->ep_callbacks.tx(endpoint->ep_callbacks.priv,
348						  skb, htc_hdr->endpoint_id,
349						  txok);
350		} else {
351			kfree_skb(skb);
352		}
353	}
354
355	return;
356ret:
357	kfree_skb(skb);
358}
359
360static void ath9k_htc_fw_panic_report(struct htc_target *htc_handle,
361				      struct sk_buff *skb)
362{
363	uint32_t *pattern = (uint32_t *)skb->data;
364
365	switch (*pattern) {
366	case 0x33221199:
367		{
368		struct htc_panic_bad_vaddr *htc_panic;
369		htc_panic = (struct htc_panic_bad_vaddr *) skb->data;
370		dev_err(htc_handle->dev, "ath: firmware panic! "
371			"exccause: 0x%08x; pc: 0x%08x; badvaddr: 0x%08x.\n",
372			htc_panic->exccause, htc_panic->pc,
373			htc_panic->badvaddr);
374		break;
375		}
376	case 0x33221299:
377		{
378		struct htc_panic_bad_epid *htc_panic;
379		htc_panic = (struct htc_panic_bad_epid *) skb->data;
380		dev_err(htc_handle->dev, "ath: firmware panic! "
381			"bad epid: 0x%08x\n", htc_panic->epid);
382		break;
383		}
384	default:
385		dev_err(htc_handle->dev, "ath: uknown panic pattern!\n");
386		break;
387	}
388}
389
390/*
391 * HTC Messages are handled directly here and the obtained SKB
392 * is freed.
393 *
394 * Service messages (Data, WMI) passed to the corresponding
395 * endpoint RX handlers, which have to free the SKB.
396 */
397void ath9k_htc_rx_msg(struct htc_target *htc_handle,
398		      struct sk_buff *skb, u32 len, u8 pipe_id)
399{
400	struct htc_frame_hdr *htc_hdr;
401	enum htc_endpoint_id epid;
402	struct htc_endpoint *endpoint;
403	__be16 *msg_id;
404
405	if (!htc_handle || !skb)
406		return;
407
408	htc_hdr = (struct htc_frame_hdr *) skb->data;
409	epid = htc_hdr->endpoint_id;
410
411	if (epid == 0x99) {
412		ath9k_htc_fw_panic_report(htc_handle, skb);
413		kfree_skb(skb);
414		return;
415	}
416
417	if (epid < 0 || epid >= ENDPOINT_MAX) {
418		if (pipe_id != USB_REG_IN_PIPE)
419			dev_kfree_skb_any(skb);
420		else
421			kfree_skb(skb);
422		return;
423	}
424
425	if (epid == ENDPOINT0) {
426
427		/* Handle trailer */
428		if (htc_hdr->flags & HTC_FLAGS_RECV_TRAILER) {
429			if (be32_to_cpu(*(__be32 *) skb->data) == 0x00C60000)
430				/* Move past the Watchdog pattern */
431				htc_hdr = (struct htc_frame_hdr *)(skb->data + 4);
432		}
433
434		/* Get the message ID */
435		msg_id = (__be16 *) ((void *) htc_hdr +
436				     sizeof(struct htc_frame_hdr));
437
438		/* Now process HTC messages */
439		switch (be16_to_cpu(*msg_id)) {
440		case HTC_MSG_READY_ID:
441			htc_process_target_rdy(htc_handle, htc_hdr);
442			break;
443		case HTC_MSG_CONNECT_SERVICE_RESPONSE_ID:
444			htc_process_conn_rsp(htc_handle, htc_hdr);
445			break;
446		default:
447			break;
448		}
449
450		kfree_skb(skb);
451
452	} else {
453		if (htc_hdr->flags & HTC_FLAGS_RECV_TRAILER)
454			skb_trim(skb, len - htc_hdr->control[0]);
455
456		skb_pull(skb, sizeof(struct htc_frame_hdr));
457
458		endpoint = &htc_handle->endpoint[epid];
459		if (endpoint->ep_callbacks.rx)
460			endpoint->ep_callbacks.rx(endpoint->ep_callbacks.priv,
461						  skb, epid);
462	}
463}
464
465struct htc_target *ath9k_htc_hw_alloc(void *hif_handle,
466				      struct ath9k_htc_hif *hif,
467				      struct device *dev)
468{
469	struct htc_endpoint *endpoint;
470	struct htc_target *target;
471
472	target = kzalloc(sizeof(struct htc_target), GFP_KERNEL);
473	if (!target)
 
 
474		return NULL;
 
475
476	init_completion(&target->target_wait);
477	init_completion(&target->cmd_wait);
478
479	target->hif = hif;
480	target->hif_dev = hif_handle;
481	target->dev = dev;
482
483	/* Assign control endpoint pipe IDs */
484	endpoint = &target->endpoint[ENDPOINT0];
485	endpoint->ul_pipeid = hif->control_ul_pipe;
486	endpoint->dl_pipeid = hif->control_dl_pipe;
487
488	atomic_set(&target->tgt_ready, 0);
489
490	return target;
491}
492
493void ath9k_htc_hw_free(struct htc_target *htc)
494{
495	kfree(htc);
496}
497
498int ath9k_htc_hw_init(struct htc_target *target,
499		      struct device *dev, u16 devid,
500		      char *product, u32 drv_info)
501{
502	if (ath9k_htc_probe_device(target, dev, devid, product, drv_info)) {
503		pr_err("Failed to initialize the device\n");
504		return -ENODEV;
505	}
506
507	return 0;
508}
509
510void ath9k_htc_hw_deinit(struct htc_target *target, bool hot_unplug)
511{
512	if (target)
513		ath9k_htc_disconnect_device(target, hot_unplug);
514}