htc_recv.c 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707
  1. /*
  2. * Copyright (c) 2013-2018 The Linux Foundation. All rights reserved.
  3. *
  4. * Permission to use, copy, modify, and/or distribute this software for
  5. * any purpose with or without fee is hereby granted, provided that the
  6. * above copyright notice and this permission notice appear in all
  7. * copies.
  8. *
  9. * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL
  10. * WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED
  11. * WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE
  12. * AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL
  13. * DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR
  14. * PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER
  15. * TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
  16. * PERFORMANCE OF THIS SOFTWARE.
  17. */
  18. #include "htc_debug.h"
  19. #include "htc_internal.h"
  20. #include "htc_credit_history.h"
  21. #include <qdf_nbuf.h> /* qdf_nbuf_t */
  22. /* HTC Control message receive timeout msec */
  23. #define HTC_CONTROL_RX_TIMEOUT 6000
  24. #if defined(WLAN_DEBUG) || defined(DEBUG)
  25. void debug_dump_bytes(uint8_t *buffer, uint16_t length, char *pDescription)
  26. {
  27. int8_t stream[60];
  28. int8_t byteOffsetStr[10];
  29. uint32_t i;
  30. uint16_t offset, count, byteOffset;
  31. A_PRINTF("<---------Dumping %d Bytes : %s ------>\n", length,
  32. pDescription);
  33. count = 0;
  34. offset = 0;
  35. byteOffset = 0;
  36. for (i = 0; i < length; i++) {
  37. A_SNPRINTF(stream + offset, (sizeof(stream) - offset),
  38. "%02X ", buffer[i]);
  39. count++;
  40. offset += 3;
  41. if (count == 16) {
  42. count = 0;
  43. offset = 0;
  44. A_SNPRINTF(byteOffsetStr, sizeof(byteOffset), "%4.4X",
  45. byteOffset);
  46. A_PRINTF("[%s]: %s\n", byteOffsetStr, stream);
  47. qdf_mem_zero(stream, 60);
  48. byteOffset += 16;
  49. }
  50. }
  51. if (offset != 0) {
  52. A_SNPRINTF(byteOffsetStr, sizeof(byteOffset), "%4.4X",
  53. byteOffset);
  54. A_PRINTF("[%s]: %s\n", byteOffsetStr, stream);
  55. }
  56. A_PRINTF("<------------------------------------------------->\n");
  57. }
  58. #else
  59. void debug_dump_bytes(uint8_t *buffer, uint16_t length, char *pDescription)
  60. {
  61. }
  62. #endif
  63. static A_STATUS htc_process_trailer(HTC_TARGET *target,
  64. uint8_t *pBuffer,
  65. int Length, HTC_ENDPOINT_ID FromEndpoint);
  66. static void do_recv_completion_pkt(HTC_ENDPOINT *pEndpoint,
  67. HTC_PACKET *pPacket)
  68. {
  69. if (pEndpoint->EpCallBacks.EpRecv == NULL) {
  70. AR_DEBUG_PRINTF(ATH_DEBUG_ERR,
  71. ("HTC ep %d has NULL recv callback on packet %pK\n",
  72. pEndpoint->Id,
  73. pPacket));
  74. if (pPacket)
  75. qdf_nbuf_free(pPacket->pPktContext);
  76. } else {
  77. AR_DEBUG_PRINTF(ATH_DEBUG_RECV,
  78. ("HTC calling ep %d recv callback on packet %pK\n",
  79. pEndpoint->Id, pPacket));
  80. pEndpoint->EpCallBacks.EpRecv(pEndpoint->EpCallBacks.pContext,
  81. pPacket);
  82. }
  83. }
  84. static void do_recv_completion(HTC_ENDPOINT *pEndpoint,
  85. HTC_PACKET_QUEUE *pQueueToIndicate)
  86. {
  87. HTC_PACKET *pPacket;
  88. if (HTC_QUEUE_EMPTY(pQueueToIndicate)) {
  89. /* nothing to indicate */
  90. return;
  91. }
  92. while (!HTC_QUEUE_EMPTY(pQueueToIndicate)) {
  93. pPacket = htc_packet_dequeue(pQueueToIndicate);
  94. do_recv_completion_pkt(pEndpoint, pPacket);
  95. }
  96. }
  97. void htc_control_rx_complete(void *Context, HTC_PACKET *pPacket)
  98. {
  99. /* TODO, can't really receive HTC control messages yet.... */
  100. AR_DEBUG_PRINTF(ATH_DEBUG_ERR,
  101. ("Invalid call to htc_control_rx_complete\n"));
  102. }
  103. void htc_unblock_recv(HTC_HANDLE HTCHandle)
  104. {
  105. /* TODO find the Need in new model */
  106. }
  107. void htc_enable_recv(HTC_HANDLE HTCHandle)
  108. {
  109. /* TODO find the Need in new model */
  110. }
  111. void htc_disable_recv(HTC_HANDLE HTCHandle)
  112. {
  113. /* TODO find the Need in new model */
  114. }
  115. int htc_get_num_recv_buffers(HTC_HANDLE HTCHandle, HTC_ENDPOINT_ID Endpoint)
  116. {
  117. HTC_TARGET *target = GET_HTC_TARGET_FROM_HANDLE(HTCHandle);
  118. HTC_ENDPOINT *pEndpoint = &target->endpoint[Endpoint];
  119. return HTC_PACKET_QUEUE_DEPTH(&pEndpoint->RxBufferHoldQueue);
  120. }
  121. HTC_PACKET *allocate_htc_packet_container(HTC_TARGET *target)
  122. {
  123. HTC_PACKET *pPacket;
  124. LOCK_HTC_RX(target);
  125. if (NULL == target->pHTCPacketStructPool) {
  126. UNLOCK_HTC_RX(target);
  127. return NULL;
  128. }
  129. pPacket = target->pHTCPacketStructPool;
  130. target->pHTCPacketStructPool = (HTC_PACKET *) pPacket->ListLink.pNext;
  131. UNLOCK_HTC_RX(target);
  132. pPacket->ListLink.pNext = NULL;
  133. return pPacket;
  134. }
  135. void free_htc_packet_container(HTC_TARGET *target, HTC_PACKET *pPacket)
  136. {
  137. pPacket->ListLink.pPrev = NULL;
  138. LOCK_HTC_RX(target);
  139. if (NULL == target->pHTCPacketStructPool) {
  140. target->pHTCPacketStructPool = pPacket;
  141. pPacket->ListLink.pNext = NULL;
  142. } else {
  143. pPacket->ListLink.pNext =
  144. (DL_LIST *) target->pHTCPacketStructPool;
  145. target->pHTCPacketStructPool = pPacket;
  146. }
  147. UNLOCK_HTC_RX(target);
  148. }
  149. #ifdef RX_SG_SUPPORT
  150. qdf_nbuf_t rx_sg_to_single_netbuf(HTC_TARGET *target)
  151. {
  152. qdf_nbuf_t skb;
  153. uint8_t *anbdata;
  154. uint8_t *anbdata_new;
  155. uint32_t anblen;
  156. qdf_nbuf_t new_skb = NULL;
  157. uint32_t sg_queue_len;
  158. qdf_nbuf_queue_t *rx_sg_queue = &target->RxSgQueue;
  159. sg_queue_len = qdf_nbuf_queue_len(rx_sg_queue);
  160. if (sg_queue_len <= 1) {
  161. AR_DEBUG_PRINTF(ATH_DEBUG_ERR,
  162. ("rx_sg_to_single_netbuf: invalid sg queue len %u\n"));
  163. goto _failed;
  164. }
  165. new_skb = qdf_nbuf_alloc(target->ExpRxSgTotalLen, 0, 4, false);
  166. if (new_skb == NULL) {
  167. AR_DEBUG_PRINTF(ATH_DEBUG_ERR,
  168. ("rx_sg_to_single_netbuf: can't allocate %u size netbuf\n",
  169. target->ExpRxSgTotalLen));
  170. goto _failed;
  171. }
  172. qdf_nbuf_peek_header(new_skb, &anbdata_new, &anblen);
  173. skb = qdf_nbuf_queue_remove(rx_sg_queue);
  174. do {
  175. qdf_nbuf_peek_header(skb, &anbdata, &anblen);
  176. qdf_mem_copy(anbdata_new, anbdata, qdf_nbuf_len(skb));
  177. qdf_nbuf_put_tail(new_skb, qdf_nbuf_len(skb));
  178. anbdata_new += qdf_nbuf_len(skb);
  179. qdf_nbuf_free(skb);
  180. skb = qdf_nbuf_queue_remove(rx_sg_queue);
  181. } while (skb != NULL);
  182. RESET_RX_SG_CONFIG(target);
  183. return new_skb;
  184. _failed:
  185. while ((skb = qdf_nbuf_queue_remove(rx_sg_queue)) != NULL)
  186. qdf_nbuf_free(skb);
  187. RESET_RX_SG_CONFIG(target);
  188. return NULL;
  189. }
  190. #endif
  191. #ifdef CONFIG_WIN
  192. #define HTC_MSG_NACK_SUSPEND 7
  193. #endif
  194. QDF_STATUS htc_rx_completion_handler(void *Context, qdf_nbuf_t netbuf,
  195. uint8_t pipeID)
  196. {
  197. QDF_STATUS status = QDF_STATUS_SUCCESS;
  198. HTC_FRAME_HDR *HtcHdr;
  199. HTC_TARGET *target = (HTC_TARGET *) Context;
  200. uint8_t *netdata;
  201. uint32_t netlen;
  202. HTC_ENDPOINT *pEndpoint;
  203. HTC_PACKET *pPacket;
  204. uint16_t payloadLen;
  205. uint32_t trailerlen = 0;
  206. uint8_t htc_ep_id;
  207. #ifdef HTC_MSG_WAKEUP_FROM_SUSPEND_ID
  208. struct htc_init_info *info;
  209. #endif
  210. #ifdef RX_SG_SUPPORT
  211. LOCK_HTC_RX(target);
  212. if (target->IsRxSgInprogress) {
  213. target->CurRxSgTotalLen += qdf_nbuf_len(netbuf);
  214. qdf_nbuf_queue_add(&target->RxSgQueue, netbuf);
  215. if (target->CurRxSgTotalLen == target->ExpRxSgTotalLen) {
  216. netbuf = rx_sg_to_single_netbuf(target);
  217. if (netbuf == NULL) {
  218. UNLOCK_HTC_RX(target);
  219. goto _out;
  220. }
  221. } else {
  222. netbuf = NULL;
  223. UNLOCK_HTC_RX(target);
  224. goto _out;
  225. }
  226. }
  227. UNLOCK_HTC_RX(target);
  228. #endif
  229. netdata = qdf_nbuf_data(netbuf);
  230. netlen = qdf_nbuf_len(netbuf);
  231. HtcHdr = (HTC_FRAME_HDR *) netdata;
  232. do {
  233. htc_ep_id = HTC_GET_FIELD(HtcHdr, HTC_FRAME_HDR, ENDPOINTID);
  234. if (htc_ep_id >= ENDPOINT_MAX) {
  235. AR_DEBUG_PRINTF(ATH_DEBUG_ERR,
  236. ("HTC Rx: invalid EndpointID=%d\n",
  237. htc_ep_id));
  238. debug_dump_bytes((uint8_t *) HtcHdr,
  239. sizeof(HTC_FRAME_HDR),
  240. "BAD HTC Header");
  241. status = QDF_STATUS_E_FAILURE;
  242. QDF_BUG(0);
  243. break;
  244. }
  245. pEndpoint = &target->endpoint[htc_ep_id];
  246. /*
  247. * If this endpoint that received a message from the target has
  248. * a to-target HIF pipe whose send completions are polled rather
  249. * than interrupt driven, this is a good point to ask HIF to
  250. * check whether it has any completed sends to handle.
  251. */
  252. if (pEndpoint->ul_is_polled)
  253. htc_send_complete_check(pEndpoint, 1);
  254. payloadLen = HTC_GET_FIELD(HtcHdr, HTC_FRAME_HDR, PAYLOADLEN);
  255. if (netlen < (payloadLen + HTC_HDR_LENGTH)) {
  256. #ifdef RX_SG_SUPPORT
  257. LOCK_HTC_RX(target);
  258. target->IsRxSgInprogress = true;
  259. qdf_nbuf_queue_init(&target->RxSgQueue);
  260. qdf_nbuf_queue_add(&target->RxSgQueue, netbuf);
  261. target->ExpRxSgTotalLen = (payloadLen + HTC_HDR_LENGTH);
  262. target->CurRxSgTotalLen += netlen;
  263. UNLOCK_HTC_RX(target);
  264. netbuf = NULL;
  265. break;
  266. #else
  267. AR_DEBUG_PRINTF(ATH_DEBUG_ERR,
  268. ("HTC Rx: insufficient length, got:%d expected =%zu\n",
  269. netlen, payloadLen + HTC_HDR_LENGTH));
  270. debug_dump_bytes((uint8_t *) HtcHdr,
  271. sizeof(HTC_FRAME_HDR),
  272. "BAD RX packet length");
  273. status = QDF_STATUS_E_FAILURE;
  274. QDF_BUG(0);
  275. break;
  276. #endif
  277. }
  278. #ifdef HTC_EP_STAT_PROFILING
  279. LOCK_HTC_RX(target);
  280. INC_HTC_EP_STAT(pEndpoint, RxReceived, 1);
  281. UNLOCK_HTC_RX(target);
  282. #endif
  283. /* if (IS_TX_CREDIT_FLOW_ENABLED(pEndpoint)) { */
  284. {
  285. uint8_t temp;
  286. A_STATUS temp_status;
  287. /* get flags to check for trailer */
  288. temp = HTC_GET_FIELD(HtcHdr, HTC_FRAME_HDR, FLAGS);
  289. if (temp & HTC_FLAGS_RECV_TRAILER) {
  290. /* extract the trailer length */
  291. temp =
  292. HTC_GET_FIELD(HtcHdr, HTC_FRAME_HDR,
  293. CONTROLBYTES0);
  294. if ((temp < sizeof(HTC_RECORD_HDR))
  295. || (temp > payloadLen)) {
  296. AR_DEBUG_PRINTF(ATH_DEBUG_ERR,
  297. ("htc_rx_completion_handler, invalid header (payloadlength should be :%d, CB[0] is:%d)\n",
  298. payloadLen, temp));
  299. status = QDF_STATUS_E_INVAL;
  300. break;
  301. }
  302. trailerlen = temp;
  303. /* process trailer data that follows HDR +
  304. * application payload
  305. */
  306. temp_status = htc_process_trailer(target,
  307. ((uint8_t *) HtcHdr +
  308. HTC_HDR_LENGTH +
  309. payloadLen - temp),
  310. temp, htc_ep_id);
  311. if (A_FAILED(temp_status)) {
  312. status = QDF_STATUS_E_FAILURE;
  313. break;
  314. }
  315. }
  316. }
  317. if (((int)payloadLen - (int)trailerlen) <= 0) {
  318. /* 0 length packet with trailer data, just drop these */
  319. break;
  320. }
  321. if (htc_ep_id == ENDPOINT_0) {
  322. uint16_t message_id;
  323. HTC_UNKNOWN_MSG *htc_msg;
  324. bool wow_nack;
  325. /* remove HTC header */
  326. qdf_nbuf_pull_head(netbuf, HTC_HDR_LENGTH);
  327. netdata = qdf_nbuf_data(netbuf);
  328. netlen = qdf_nbuf_len(netbuf);
  329. htc_msg = (HTC_UNKNOWN_MSG *) netdata;
  330. message_id = HTC_GET_FIELD(htc_msg, HTC_UNKNOWN_MSG,
  331. MESSAGEID);
  332. switch (message_id) {
  333. default:
  334. /* handle HTC control message */
  335. if (target->CtrlResponseProcessing) {
  336. /* this is a fatal error, target should
  337. * not be sending unsolicited messages
  338. * on the endpoint 0
  339. */
  340. AR_DEBUG_PRINTF(ATH_DEBUG_ERR,
  341. ("HTC Rx Ctrl still processing\n"));
  342. status = QDF_STATUS_E_FAILURE;
  343. QDF_BUG(false);
  344. break;
  345. }
  346. LOCK_HTC_RX(target);
  347. target->CtrlResponseLength =
  348. min((int)netlen,
  349. HTC_MAX_CONTROL_MESSAGE_LENGTH);
  350. qdf_mem_copy(target->CtrlResponseBuffer,
  351. netdata,
  352. target->CtrlResponseLength);
  353. /* Requester will clear this flag */
  354. target->CtrlResponseProcessing = true;
  355. UNLOCK_HTC_RX(target);
  356. qdf_event_set(&target->ctrl_response_valid);
  357. break;
  358. #ifdef HTC_MSG_WAKEUP_FROM_SUSPEND_ID
  359. case HTC_MSG_WAKEUP_FROM_SUSPEND_ID:
  360. AR_DEBUG_PRINTF(ATH_DEBUG_ANY,
  361. ("Received initial wake up"));
  362. htc_credit_record(HTC_INITIAL_WAKE_UP,
  363. pEndpoint->TxCredits,
  364. HTC_PACKET_QUEUE_DEPTH(
  365. &pEndpoint->TxQueue));
  366. info = &target->HTCInitInfo;
  367. if (info && info->target_initial_wakeup_cb)
  368. info->target_initial_wakeup_cb(
  369. info->target_psoc);
  370. else
  371. AR_DEBUG_PRINTF(ATH_DEBUG_ANY,
  372. ("No initial wake up cb"));
  373. break;
  374. #endif
  375. case HTC_MSG_SEND_SUSPEND_COMPLETE:
  376. wow_nack = false;
  377. htc_credit_record(HTC_SUSPEND_ACK,
  378. pEndpoint->TxCredits,
  379. HTC_PACKET_QUEUE_DEPTH(
  380. &pEndpoint->TxQueue));
  381. target->HTCInitInfo.TargetSendSuspendComplete(
  382. target->HTCInitInfo.target_psoc,
  383. wow_nack);
  384. break;
  385. case HTC_MSG_NACK_SUSPEND:
  386. wow_nack = true;
  387. htc_credit_record(HTC_SUSPEND_ACK,
  388. pEndpoint->TxCredits,
  389. HTC_PACKET_QUEUE_DEPTH(
  390. &pEndpoint->TxQueue));
  391. target->HTCInitInfo.TargetSendSuspendComplete(
  392. target->HTCInitInfo.target_psoc,
  393. wow_nack);
  394. break;
  395. }
  396. qdf_nbuf_free(netbuf);
  397. netbuf = NULL;
  398. break;
  399. }
  400. /* the current message based HIF architecture allocates net bufs
  401. * for recv packets since this layer bridges that HIF to upper
  402. * layers , which expects HTC packets, we form the packets here
  403. * TODO_FIXME
  404. */
  405. pPacket = allocate_htc_packet_container(target);
  406. if (NULL == pPacket) {
  407. status = QDF_STATUS_E_RESOURCES;
  408. break;
  409. }
  410. pPacket->Status = QDF_STATUS_SUCCESS;
  411. pPacket->Endpoint = htc_ep_id;
  412. pPacket->pPktContext = netbuf;
  413. pPacket->pBuffer = qdf_nbuf_data(netbuf) + HTC_HDR_LENGTH;
  414. pPacket->ActualLength = netlen - HTC_HEADER_LEN - trailerlen;
  415. qdf_nbuf_pull_head(netbuf, HTC_HEADER_LEN);
  416. qdf_nbuf_set_pktlen(netbuf, pPacket->ActualLength);
  417. do_recv_completion_pkt(pEndpoint, pPacket);
  418. /* recover the packet container */
  419. free_htc_packet_container(target, pPacket);
  420. netbuf = NULL;
  421. } while (false);
  422. #ifdef RX_SG_SUPPORT
  423. _out:
  424. #endif
  425. if (netbuf != NULL)
  426. qdf_nbuf_free(netbuf);
  427. return status;
  428. }
  429. A_STATUS htc_add_receive_pkt_multiple(HTC_HANDLE HTCHandle,
  430. HTC_PACKET_QUEUE *pPktQueue)
  431. {
  432. HTC_TARGET *target = GET_HTC_TARGET_FROM_HANDLE(HTCHandle);
  433. HTC_ENDPOINT *pEndpoint;
  434. HTC_PACKET *pFirstPacket;
  435. A_STATUS status = A_OK;
  436. HTC_PACKET *pPacket;
  437. pFirstPacket = htc_get_pkt_at_head(pPktQueue);
  438. if (NULL == pFirstPacket) {
  439. A_ASSERT(false);
  440. return A_EINVAL;
  441. }
  442. AR_DEBUG_ASSERT(pFirstPacket->Endpoint < ENDPOINT_MAX);
  443. AR_DEBUG_PRINTF(ATH_DEBUG_RECV,
  444. ("+- htc_add_receive_pkt_multiple : endPointId: %d, cnt:%d, length: %d\n",
  445. pFirstPacket->Endpoint,
  446. HTC_PACKET_QUEUE_DEPTH(pPktQueue),
  447. pFirstPacket->BufferLength));
  448. pEndpoint = &target->endpoint[pFirstPacket->Endpoint];
  449. LOCK_HTC_RX(target);
  450. do {
  451. if (HTC_STOPPING(target)) {
  452. status = A_ERROR;
  453. break;
  454. }
  455. /* store receive packets */
  456. HTC_PACKET_QUEUE_TRANSFER_TO_TAIL(&pEndpoint->RxBufferHoldQueue,
  457. pPktQueue);
  458. } while (false);
  459. UNLOCK_HTC_RX(target);
  460. if (A_FAILED(status)) {
  461. /* walk through queue and mark each one canceled */
  462. HTC_PACKET_QUEUE_ITERATE_ALLOW_REMOVE(pPktQueue, pPacket) {
  463. pPacket->Status = QDF_STATUS_E_CANCELED;
  464. }
  465. HTC_PACKET_QUEUE_ITERATE_END;
  466. do_recv_completion(pEndpoint, pPktQueue);
  467. }
  468. return status;
  469. }
  470. void htc_flush_rx_hold_queue(HTC_TARGET *target, HTC_ENDPOINT *pEndpoint)
  471. {
  472. HTC_PACKET *pPacket;
  473. LOCK_HTC_RX(target);
  474. while (1) {
  475. pPacket = htc_packet_dequeue(&pEndpoint->RxBufferHoldQueue);
  476. if (pPacket == NULL)
  477. break;
  478. UNLOCK_HTC_RX(target);
  479. pPacket->Status = QDF_STATUS_E_CANCELED;
  480. pPacket->ActualLength = 0;
  481. AR_DEBUG_PRINTF(ATH_DEBUG_RECV,
  482. ("Flushing RX packet:%pK, length:%d, ep:%d\n",
  483. pPacket, pPacket->BufferLength,
  484. pPacket->Endpoint));
  485. /* give the packet back */
  486. do_recv_completion_pkt(pEndpoint, pPacket);
  487. LOCK_HTC_RX(target);
  488. }
  489. UNLOCK_HTC_RX(target);
  490. }
  491. void htc_recv_init(HTC_TARGET *target)
  492. {
  493. /* Initialize ctrl_response_valid to block */
  494. qdf_event_create(&target->ctrl_response_valid);
  495. }
  496. /* polling routine to wait for a control packet to be received */
  497. QDF_STATUS htc_wait_recv_ctrl_message(HTC_TARGET *target)
  498. {
  499. /* int count = HTC_TARGET_MAX_RESPONSE_POLL; */
  500. AR_DEBUG_PRINTF(ATH_DEBUG_TRC, ("+HTCWaitCtrlMessageRecv\n"));
  501. /* Wait for BMI request/response transaction to complete */
  502. if (qdf_wait_single_event(&target->ctrl_response_valid,
  503. HTC_CONTROL_RX_TIMEOUT)) {
  504. AR_DEBUG_PRINTF(ATH_DEBUG_ERR,
  505. ("Failed to receive control message\n"));
  506. return QDF_STATUS_E_FAILURE;
  507. }
  508. LOCK_HTC_RX(target);
  509. /* caller will clear this flag */
  510. target->CtrlResponseProcessing = true;
  511. UNLOCK_HTC_RX(target);
  512. AR_DEBUG_PRINTF(ATH_DEBUG_TRC, ("-HTCWaitCtrlMessageRecv success\n"));
  513. return QDF_STATUS_SUCCESS;
  514. }
  515. static A_STATUS htc_process_trailer(HTC_TARGET *target,
  516. uint8_t *pBuffer,
  517. int Length, HTC_ENDPOINT_ID FromEndpoint)
  518. {
  519. HTC_RECORD_HDR *pRecord;
  520. uint8_t htc_rec_id;
  521. uint8_t htc_rec_len;
  522. uint8_t *pRecordBuf;
  523. uint8_t *pOrigBuffer;
  524. int origLength;
  525. A_STATUS status;
  526. AR_DEBUG_PRINTF(ATH_DEBUG_RECV,
  527. ("+htc_process_trailer (length:%d)\n", Length));
  528. if (AR_DEBUG_LVL_CHECK(ATH_DEBUG_RECV))
  529. AR_DEBUG_PRINTBUF(pBuffer, Length, "Recv Trailer");
  530. pOrigBuffer = pBuffer;
  531. origLength = Length;
  532. status = A_OK;
  533. while (Length > 0) {
  534. if (Length < sizeof(HTC_RECORD_HDR)) {
  535. status = A_EPROTO;
  536. break;
  537. }
  538. /* these are byte aligned structs */
  539. pRecord = (HTC_RECORD_HDR *) pBuffer;
  540. Length -= sizeof(HTC_RECORD_HDR);
  541. pBuffer += sizeof(HTC_RECORD_HDR);
  542. htc_rec_len = HTC_GET_FIELD(pRecord, HTC_RECORD_HDR, LENGTH);
  543. htc_rec_id = HTC_GET_FIELD(pRecord, HTC_RECORD_HDR, RECORDID);
  544. if (htc_rec_len > Length) {
  545. /* no room left in buffer for record */
  546. AR_DEBUG_PRINTF(ATH_DEBUG_ERR,
  547. ("invalid record length: %d (id:%d) buffer has: %d bytes left\n",
  548. htc_rec_len, htc_rec_id, Length));
  549. status = A_EPROTO;
  550. break;
  551. }
  552. /* start of record follows the header */
  553. pRecordBuf = pBuffer;
  554. switch (htc_rec_id) {
  555. case HTC_RECORD_CREDITS:
  556. AR_DEBUG_ASSERT(htc_rec_len >=
  557. sizeof(HTC_CREDIT_REPORT));
  558. htc_process_credit_rpt(target,
  559. (HTC_CREDIT_REPORT *) pRecordBuf,
  560. htc_rec_len /
  561. (sizeof(HTC_CREDIT_REPORT)),
  562. FromEndpoint);
  563. break;
  564. #ifdef HIF_SDIO
  565. case HTC_RECORD_LOOKAHEAD:
  566. /* Process in HIF layer */
  567. break;
  568. case HTC_RECORD_LOOKAHEAD_BUNDLE:
  569. /* Process in HIF layer */
  570. break;
  571. #endif /* HIF_SDIO */
  572. default:
  573. AR_DEBUG_PRINTF(ATH_DEBUG_ERR,
  574. ("HTC unhandled record: id:%d length:%d\n",
  575. htc_rec_id, htc_rec_len));
  576. break;
  577. }
  578. if (A_FAILED(status)) {
  579. break;
  580. }
  581. /* advance buffer past this record for next time around */
  582. pBuffer += htc_rec_len;
  583. Length -= htc_rec_len;
  584. }
  585. if (A_FAILED(status))
  586. debug_dump_bytes(pOrigBuffer, origLength, "BAD Recv Trailer");
  587. AR_DEBUG_PRINTF(ATH_DEBUG_RECV, ("-htc_process_trailer\n"));
  588. return status;
  589. }