Lines Matching refs:msgbuf
291 static void brcmf_msgbuf_rxbuf_ioctlresp_post(struct brcmf_msgbuf *msgbuf);
416 static void brcmf_msgbuf_release_pktids(struct brcmf_msgbuf *msgbuf) in brcmf_msgbuf_release_pktids() argument
418 if (msgbuf->rx_pktids) in brcmf_msgbuf_release_pktids()
419 brcmf_msgbuf_release_array(msgbuf->drvr->bus_if->dev, in brcmf_msgbuf_release_pktids()
420 msgbuf->rx_pktids); in brcmf_msgbuf_release_pktids()
421 if (msgbuf->tx_pktids) in brcmf_msgbuf_release_pktids()
422 brcmf_msgbuf_release_array(msgbuf->drvr->bus_if->dev, in brcmf_msgbuf_release_pktids()
423 msgbuf->tx_pktids); in brcmf_msgbuf_release_pktids()
430 struct brcmf_msgbuf *msgbuf = (struct brcmf_msgbuf *)drvr->proto->pd; in brcmf_msgbuf_tx_ioctl() local
437 commonring = msgbuf->commonrings[BRCMF_H2D_MSGRING_CONTROL_SUBMIT]; in brcmf_msgbuf_tx_ioctl()
446 msgbuf->reqid++; in brcmf_msgbuf_tx_ioctl()
455 request->trans_id = cpu_to_le16(msgbuf->reqid); in brcmf_msgbuf_tx_ioctl()
459 request->req_buf_addr.high_addr = cpu_to_le32(msgbuf->ioctbuf_phys_hi); in brcmf_msgbuf_tx_ioctl()
460 request->req_buf_addr.low_addr = cpu_to_le32(msgbuf->ioctbuf_phys_lo); in brcmf_msgbuf_tx_ioctl()
462 memcpy(msgbuf->ioctbuf, buf, buf_len); in brcmf_msgbuf_tx_ioctl()
464 memset(msgbuf->ioctbuf, 0, buf_len); in brcmf_msgbuf_tx_ioctl()
473 static int brcmf_msgbuf_ioctl_resp_wait(struct brcmf_msgbuf *msgbuf) in brcmf_msgbuf_ioctl_resp_wait() argument
475 return wait_event_timeout(msgbuf->ioctl_resp_wait, in brcmf_msgbuf_ioctl_resp_wait()
476 msgbuf->ctl_completed, in brcmf_msgbuf_ioctl_resp_wait()
481 static void brcmf_msgbuf_ioctl_resp_wake(struct brcmf_msgbuf *msgbuf) in brcmf_msgbuf_ioctl_resp_wake() argument
483 msgbuf->ctl_completed = true; in brcmf_msgbuf_ioctl_resp_wake()
484 wake_up(&msgbuf->ioctl_resp_wait); in brcmf_msgbuf_ioctl_resp_wake()
491 struct brcmf_msgbuf *msgbuf = (struct brcmf_msgbuf *)drvr->proto->pd; in brcmf_msgbuf_query_dcmd() local
498 msgbuf->ctl_completed = false; in brcmf_msgbuf_query_dcmd()
503 timeout = brcmf_msgbuf_ioctl_resp_wait(msgbuf); in brcmf_msgbuf_query_dcmd()
509 skb = brcmf_msgbuf_get_pktid(msgbuf->drvr->bus_if->dev, in brcmf_msgbuf_query_dcmd()
510 msgbuf->rx_pktids, in brcmf_msgbuf_query_dcmd()
511 msgbuf->ioctl_resp_pktid); in brcmf_msgbuf_query_dcmd()
512 if (msgbuf->ioctl_resp_ret_len != 0) { in brcmf_msgbuf_query_dcmd()
516 memcpy(buf, skb->data, (len < msgbuf->ioctl_resp_ret_len) ? in brcmf_msgbuf_query_dcmd()
517 len : msgbuf->ioctl_resp_ret_len); in brcmf_msgbuf_query_dcmd()
521 *fwerr = msgbuf->ioctl_resp_status; in brcmf_msgbuf_query_dcmd()
545 brcmf_msgbuf_remove_flowring(struct brcmf_msgbuf *msgbuf, u16 flowid) in brcmf_msgbuf_remove_flowring() argument
553 dma_buf = msgbuf->flowrings[flowid]->buf_addr; in brcmf_msgbuf_remove_flowring()
554 dma_free_coherent(msgbuf->drvr->bus_if->dev, dma_sz, dma_buf, in brcmf_msgbuf_remove_flowring()
555 msgbuf->flowring_dma_handle[flowid]); in brcmf_msgbuf_remove_flowring()
557 brcmf_flowring_delete(msgbuf->flow, flowid); in brcmf_msgbuf_remove_flowring()
562 brcmf_msgbuf_dequeue_work(struct brcmf_msgbuf *msgbuf) in brcmf_msgbuf_dequeue_work() argument
567 spin_lock_irqsave(&msgbuf->flowring_work_lock, flags); in brcmf_msgbuf_dequeue_work()
568 if (!list_empty(&msgbuf->work_queue)) { in brcmf_msgbuf_dequeue_work()
569 work = list_first_entry(&msgbuf->work_queue, in brcmf_msgbuf_dequeue_work()
573 spin_unlock_irqrestore(&msgbuf->flowring_work_lock, flags); in brcmf_msgbuf_dequeue_work()
580 brcmf_msgbuf_flowring_create_worker(struct brcmf_msgbuf *msgbuf, in brcmf_msgbuf_flowring_create_worker() argument
583 struct brcmf_pub *drvr = msgbuf->drvr; in brcmf_msgbuf_flowring_create_worker()
595 dma_buf = dma_alloc_coherent(msgbuf->drvr->bus_if->dev, dma_sz, in brcmf_msgbuf_flowring_create_worker()
596 &msgbuf->flowring_dma_handle[flowid], in brcmf_msgbuf_flowring_create_worker()
600 brcmf_flowring_delete(msgbuf->flow, flowid); in brcmf_msgbuf_flowring_create_worker()
604 brcmf_commonring_config(msgbuf->flowrings[flowid], in brcmf_msgbuf_flowring_create_worker()
608 commonring = msgbuf->commonrings[BRCMF_H2D_MSGRING_CONTROL_SUBMIT]; in brcmf_msgbuf_flowring_create_worker()
614 brcmf_msgbuf_remove_flowring(msgbuf, flowid); in brcmf_msgbuf_flowring_create_worker()
622 create->tid = brcmf_flowring_tid(msgbuf->flow, flowid); in brcmf_msgbuf_flowring_create_worker()
627 address = (u64)msgbuf->flowring_dma_handle[flowid]; in brcmf_msgbuf_flowring_create_worker()
640 brcmf_msgbuf_remove_flowring(msgbuf, flowid); in brcmf_msgbuf_flowring_create_worker()
650 struct brcmf_msgbuf *msgbuf; in brcmf_msgbuf_flowring_worker() local
653 msgbuf = container_of(work, struct brcmf_msgbuf, flowring_work); in brcmf_msgbuf_flowring_worker()
655 while ((create = brcmf_msgbuf_dequeue_work(msgbuf))) { in brcmf_msgbuf_flowring_worker()
656 brcmf_msgbuf_flowring_create_worker(msgbuf, create); in brcmf_msgbuf_flowring_worker()
662 static u32 brcmf_msgbuf_flowring_create(struct brcmf_msgbuf *msgbuf, int ifidx, in brcmf_msgbuf_flowring_create() argument
674 flowid = brcmf_flowring_create(msgbuf->flow, eh->h_dest, in brcmf_msgbuf_flowring_create()
686 spin_lock_irqsave(&msgbuf->flowring_work_lock, flags); in brcmf_msgbuf_flowring_create()
687 list_add_tail(&create->queue, &msgbuf->work_queue); in brcmf_msgbuf_flowring_create()
688 spin_unlock_irqrestore(&msgbuf->flowring_work_lock, flags); in brcmf_msgbuf_flowring_create()
689 schedule_work(&msgbuf->flowring_work); in brcmf_msgbuf_flowring_create()
695 static void brcmf_msgbuf_txflow(struct brcmf_msgbuf *msgbuf, u16 flowid) in brcmf_msgbuf_txflow() argument
697 struct brcmf_flowring *flow = msgbuf->flow; in brcmf_msgbuf_txflow()
698 struct brcmf_pub *drvr = msgbuf->drvr; in brcmf_msgbuf_txflow()
708 commonring = msgbuf->flowrings[flowid]; in brcmf_msgbuf_txflow()
723 if (brcmf_msgbuf_alloc_pktid(msgbuf->drvr->bus_if->dev, in brcmf_msgbuf_txflow()
724 msgbuf->tx_pktids, skb, ETH_HLEN, in brcmf_msgbuf_txflow()
732 brcmf_msgbuf_get_pktid(msgbuf->drvr->bus_if->dev, in brcmf_msgbuf_txflow()
733 msgbuf->tx_pktids, pktid); in brcmf_msgbuf_txflow()
771 struct brcmf_msgbuf *msgbuf; in brcmf_msgbuf_txflow_worker() local
774 msgbuf = container_of(worker, struct brcmf_msgbuf, txflow_work); in brcmf_msgbuf_txflow_worker()
775 for_each_set_bit(flowid, msgbuf->flow_map, msgbuf->max_flowrings) { in brcmf_msgbuf_txflow_worker()
776 clear_bit(flowid, msgbuf->flow_map); in brcmf_msgbuf_txflow_worker()
777 brcmf_msgbuf_txflow(msgbuf, flowid); in brcmf_msgbuf_txflow_worker()
782 static int brcmf_msgbuf_schedule_txdata(struct brcmf_msgbuf *msgbuf, u32 flowid, in brcmf_msgbuf_schedule_txdata() argument
787 set_bit(flowid, msgbuf->flow_map); in brcmf_msgbuf_schedule_txdata()
788 commonring = msgbuf->flowrings[flowid]; in brcmf_msgbuf_schedule_txdata()
791 queue_work(msgbuf->txflow_wq, &msgbuf->txflow_work); in brcmf_msgbuf_schedule_txdata()
800 struct brcmf_msgbuf *msgbuf = (struct brcmf_msgbuf *)drvr->proto->pd; in brcmf_msgbuf_tx_queue_data() local
801 struct brcmf_flowring *flow = msgbuf->flow; in brcmf_msgbuf_tx_queue_data()
809 flowid = brcmf_msgbuf_flowring_create(msgbuf, ifidx, skb); in brcmf_msgbuf_tx_queue_data()
815 brcmf_msgbuf_schedule_txdata(msgbuf, flowid, force); in brcmf_msgbuf_tx_queue_data()
825 struct brcmf_msgbuf *msgbuf = (struct brcmf_msgbuf *)drvr->proto->pd; in brcmf_msgbuf_configure_addr_mode() local
827 brcmf_flowring_configure_addr_mode(msgbuf->flow, ifidx, addr_mode); in brcmf_msgbuf_configure_addr_mode()
834 struct brcmf_msgbuf *msgbuf = (struct brcmf_msgbuf *)drvr->proto->pd; in brcmf_msgbuf_delete_peer() local
836 brcmf_flowring_delete_peer(msgbuf->flow, ifidx, peer); in brcmf_msgbuf_delete_peer()
843 struct brcmf_msgbuf *msgbuf = (struct brcmf_msgbuf *)drvr->proto->pd; in brcmf_msgbuf_add_tdls_peer() local
845 brcmf_flowring_add_tdls_peer(msgbuf->flow, ifidx, peer); in brcmf_msgbuf_add_tdls_peer()
850 brcmf_msgbuf_process_ioctl_complete(struct brcmf_msgbuf *msgbuf, void *buf) in brcmf_msgbuf_process_ioctl_complete() argument
856 msgbuf->ioctl_resp_status = in brcmf_msgbuf_process_ioctl_complete()
858 msgbuf->ioctl_resp_ret_len = le16_to_cpu(ioctl_resp->resp_len); in brcmf_msgbuf_process_ioctl_complete()
859 msgbuf->ioctl_resp_pktid = le32_to_cpu(ioctl_resp->msg.request_id); in brcmf_msgbuf_process_ioctl_complete()
861 brcmf_msgbuf_ioctl_resp_wake(msgbuf); in brcmf_msgbuf_process_ioctl_complete()
863 if (msgbuf->cur_ioctlrespbuf) in brcmf_msgbuf_process_ioctl_complete()
864 msgbuf->cur_ioctlrespbuf--; in brcmf_msgbuf_process_ioctl_complete()
865 brcmf_msgbuf_rxbuf_ioctlresp_post(msgbuf); in brcmf_msgbuf_process_ioctl_complete()
870 brcmf_msgbuf_process_txstatus(struct brcmf_msgbuf *msgbuf, void *buf) in brcmf_msgbuf_process_txstatus() argument
882 skb = brcmf_msgbuf_get_pktid(msgbuf->drvr->bus_if->dev, in brcmf_msgbuf_process_txstatus()
883 msgbuf->tx_pktids, idx); in brcmf_msgbuf_process_txstatus()
887 set_bit(flowid, msgbuf->txstatus_done_map); in brcmf_msgbuf_process_txstatus()
888 commonring = msgbuf->flowrings[flowid]; in brcmf_msgbuf_process_txstatus()
891 brcmf_txfinalize(brcmf_get_ifp(msgbuf->drvr, tx_status->msg.ifidx), in brcmf_msgbuf_process_txstatus()
896 static u32 brcmf_msgbuf_rxbuf_data_post(struct brcmf_msgbuf *msgbuf, u32 count) in brcmf_msgbuf_rxbuf_data_post() argument
898 struct brcmf_pub *drvr = msgbuf->drvr; in brcmf_msgbuf_rxbuf_data_post()
910 commonring = msgbuf->commonrings[BRCMF_H2D_MSGRING_RXPOST_SUBMIT]; in brcmf_msgbuf_rxbuf_data_post()
932 if (brcmf_msgbuf_alloc_pktid(msgbuf->drvr->bus_if->dev, in brcmf_msgbuf_rxbuf_data_post()
933 msgbuf->rx_pktids, skb, 0, in brcmf_msgbuf_rxbuf_data_post()
941 if (msgbuf->rx_metadata_offset) { in brcmf_msgbuf_rxbuf_data_post()
944 cpu_to_le16(msgbuf->rx_metadata_offset); in brcmf_msgbuf_rxbuf_data_post()
950 skb_pull(skb, msgbuf->rx_metadata_offset); in brcmf_msgbuf_rxbuf_data_post()
952 physaddr += msgbuf->rx_metadata_offset; in brcmf_msgbuf_rxbuf_data_post()
975 brcmf_msgbuf_rxbuf_data_fill(struct brcmf_msgbuf *msgbuf) in brcmf_msgbuf_rxbuf_data_fill() argument
980 fillbufs = msgbuf->max_rxbufpost - msgbuf->rxbufpost; in brcmf_msgbuf_rxbuf_data_fill()
983 retcount = brcmf_msgbuf_rxbuf_data_post(msgbuf, fillbufs); in brcmf_msgbuf_rxbuf_data_fill()
986 msgbuf->rxbufpost += retcount; in brcmf_msgbuf_rxbuf_data_fill()
993 brcmf_msgbuf_update_rxbufpost_count(struct brcmf_msgbuf *msgbuf, u16 rxcnt) in brcmf_msgbuf_update_rxbufpost_count() argument
995 msgbuf->rxbufpost -= rxcnt; in brcmf_msgbuf_update_rxbufpost_count()
996 if (msgbuf->rxbufpost <= (msgbuf->max_rxbufpost - in brcmf_msgbuf_update_rxbufpost_count()
998 brcmf_msgbuf_rxbuf_data_fill(msgbuf); in brcmf_msgbuf_update_rxbufpost_count()
1003 brcmf_msgbuf_rxbuf_ctrl_post(struct brcmf_msgbuf *msgbuf, bool event_buf, in brcmf_msgbuf_rxbuf_ctrl_post() argument
1006 struct brcmf_pub *drvr = msgbuf->drvr; in brcmf_msgbuf_rxbuf_ctrl_post()
1018 commonring = msgbuf->commonrings[BRCMF_H2D_MSGRING_CONTROL_SUBMIT]; in brcmf_msgbuf_rxbuf_ctrl_post()
1042 if (brcmf_msgbuf_alloc_pktid(msgbuf->drvr->bus_if->dev, in brcmf_msgbuf_rxbuf_ctrl_post()
1043 msgbuf->rx_pktids, skb, 0, in brcmf_msgbuf_rxbuf_ctrl_post()
1076 static void brcmf_msgbuf_rxbuf_ioctlresp_post(struct brcmf_msgbuf *msgbuf) in brcmf_msgbuf_rxbuf_ioctlresp_post() argument
1080 count = msgbuf->max_ioctlrespbuf - msgbuf->cur_ioctlrespbuf; in brcmf_msgbuf_rxbuf_ioctlresp_post()
1081 count = brcmf_msgbuf_rxbuf_ctrl_post(msgbuf, false, count); in brcmf_msgbuf_rxbuf_ioctlresp_post()
1082 msgbuf->cur_ioctlrespbuf += count; in brcmf_msgbuf_rxbuf_ioctlresp_post()
1086 static void brcmf_msgbuf_rxbuf_event_post(struct brcmf_msgbuf *msgbuf) in brcmf_msgbuf_rxbuf_event_post() argument
1090 count = msgbuf->max_eventbuf - msgbuf->cur_eventbuf; in brcmf_msgbuf_rxbuf_event_post()
1091 count = brcmf_msgbuf_rxbuf_ctrl_post(msgbuf, true, count); in brcmf_msgbuf_rxbuf_event_post()
1092 msgbuf->cur_eventbuf += count; in brcmf_msgbuf_rxbuf_event_post()
1096 static void brcmf_msgbuf_process_event(struct brcmf_msgbuf *msgbuf, void *buf) in brcmf_msgbuf_process_event() argument
1098 struct brcmf_pub *drvr = msgbuf->drvr; in brcmf_msgbuf_process_event()
1109 if (msgbuf->cur_eventbuf) in brcmf_msgbuf_process_event()
1110 msgbuf->cur_eventbuf--; in brcmf_msgbuf_process_event()
1111 brcmf_msgbuf_rxbuf_event_post(msgbuf); in brcmf_msgbuf_process_event()
1113 skb = brcmf_msgbuf_get_pktid(msgbuf->drvr->bus_if->dev, in brcmf_msgbuf_process_event()
1114 msgbuf->rx_pktids, idx); in brcmf_msgbuf_process_event()
1118 if (msgbuf->rx_dataoffset) in brcmf_msgbuf_process_event()
1119 skb_pull(skb, msgbuf->rx_dataoffset); in brcmf_msgbuf_process_event()
1123 ifp = brcmf_get_ifp(msgbuf->drvr, event->msg.ifidx); in brcmf_msgbuf_process_event()
1140 brcmf_msgbuf_process_rx_complete(struct brcmf_msgbuf *msgbuf, void *buf) in brcmf_msgbuf_process_rx_complete() argument
1142 struct brcmf_pub *drvr = msgbuf->drvr; in brcmf_msgbuf_process_rx_complete()
1151 brcmf_msgbuf_update_rxbufpost_count(msgbuf, 1); in brcmf_msgbuf_process_rx_complete()
1159 skb = brcmf_msgbuf_get_pktid(msgbuf->drvr->bus_if->dev, in brcmf_msgbuf_process_rx_complete()
1160 msgbuf->rx_pktids, idx); in brcmf_msgbuf_process_rx_complete()
1166 else if (msgbuf->rx_dataoffset) in brcmf_msgbuf_process_rx_complete()
1167 skb_pull(skb, msgbuf->rx_dataoffset); in brcmf_msgbuf_process_rx_complete()
1173 ifp = msgbuf->drvr->mon_if; in brcmf_msgbuf_process_rx_complete()
1185 ifp = brcmf_get_ifp(msgbuf->drvr, rx_complete->msg.ifidx); in brcmf_msgbuf_process_rx_complete()
1197 static void brcmf_msgbuf_process_gen_status(struct brcmf_msgbuf *msgbuf, in brcmf_msgbuf_process_gen_status() argument
1201 struct brcmf_pub *drvr = msgbuf->drvr; in brcmf_msgbuf_process_gen_status()
1209 static void brcmf_msgbuf_process_ring_status(struct brcmf_msgbuf *msgbuf, in brcmf_msgbuf_process_ring_status() argument
1213 struct brcmf_pub *drvr = msgbuf->drvr; in brcmf_msgbuf_process_ring_status()
1226 brcmf_msgbuf_process_flow_ring_create_response(struct brcmf_msgbuf *msgbuf, in brcmf_msgbuf_process_flow_ring_create_response() argument
1229 struct brcmf_pub *drvr = msgbuf->drvr; in brcmf_msgbuf_process_flow_ring_create_response()
1242 brcmf_msgbuf_remove_flowring(msgbuf, flowid); in brcmf_msgbuf_process_flow_ring_create_response()
1248 brcmf_flowring_open(msgbuf->flow, flowid); in brcmf_msgbuf_process_flow_ring_create_response()
1250 brcmf_msgbuf_schedule_txdata(msgbuf, flowid, true); in brcmf_msgbuf_process_flow_ring_create_response()
1255 brcmf_msgbuf_process_flow_ring_delete_response(struct brcmf_msgbuf *msgbuf, in brcmf_msgbuf_process_flow_ring_delete_response() argument
1258 struct brcmf_pub *drvr = msgbuf->drvr; in brcmf_msgbuf_process_flow_ring_delete_response()
1271 brcmf_flowring_delete(msgbuf->flow, flowid); in brcmf_msgbuf_process_flow_ring_delete_response()
1277 brcmf_msgbuf_remove_flowring(msgbuf, flowid); in brcmf_msgbuf_process_flow_ring_delete_response()
1281 static void brcmf_msgbuf_process_msgtype(struct brcmf_msgbuf *msgbuf, void *buf) in brcmf_msgbuf_process_msgtype() argument
1283 struct brcmf_pub *drvr = msgbuf->drvr; in brcmf_msgbuf_process_msgtype()
1290 brcmf_msgbuf_process_gen_status(msgbuf, buf); in brcmf_msgbuf_process_msgtype()
1294 brcmf_msgbuf_process_ring_status(msgbuf, buf); in brcmf_msgbuf_process_msgtype()
1298 brcmf_msgbuf_process_flow_ring_create_response(msgbuf, buf); in brcmf_msgbuf_process_msgtype()
1302 brcmf_msgbuf_process_flow_ring_delete_response(msgbuf, buf); in brcmf_msgbuf_process_msgtype()
1309 brcmf_msgbuf_process_ioctl_complete(msgbuf, buf); in brcmf_msgbuf_process_msgtype()
1313 brcmf_msgbuf_process_event(msgbuf, buf); in brcmf_msgbuf_process_msgtype()
1317 brcmf_msgbuf_process_txstatus(msgbuf, buf); in brcmf_msgbuf_process_msgtype()
1321 brcmf_msgbuf_process_rx_complete(msgbuf, buf); in brcmf_msgbuf_process_msgtype()
1330 static void brcmf_msgbuf_process_rx(struct brcmf_msgbuf *msgbuf, in brcmf_msgbuf_process_rx() argument
1344 brcmf_msgbuf_process_msgtype(msgbuf, in brcmf_msgbuf_process_rx()
1345 buf + msgbuf->rx_dataoffset); in brcmf_msgbuf_process_rx()
1366 struct brcmf_msgbuf *msgbuf = (struct brcmf_msgbuf *)drvr->proto->pd; in brcmf_proto_msgbuf_rx_trigger() local
1372 buf = msgbuf->commonrings[BRCMF_D2H_MSGRING_RX_COMPLETE]; in brcmf_proto_msgbuf_rx_trigger()
1373 brcmf_msgbuf_process_rx(msgbuf, buf); in brcmf_proto_msgbuf_rx_trigger()
1374 buf = msgbuf->commonrings[BRCMF_D2H_MSGRING_TX_COMPLETE]; in brcmf_proto_msgbuf_rx_trigger()
1375 brcmf_msgbuf_process_rx(msgbuf, buf); in brcmf_proto_msgbuf_rx_trigger()
1376 buf = msgbuf->commonrings[BRCMF_D2H_MSGRING_CONTROL_COMPLETE]; in brcmf_proto_msgbuf_rx_trigger()
1377 brcmf_msgbuf_process_rx(msgbuf, buf); in brcmf_proto_msgbuf_rx_trigger()
1379 for_each_set_bit(flowid, msgbuf->txstatus_done_map, in brcmf_proto_msgbuf_rx_trigger()
1380 msgbuf->max_flowrings) { in brcmf_proto_msgbuf_rx_trigger()
1381 clear_bit(flowid, msgbuf->txstatus_done_map); in brcmf_proto_msgbuf_rx_trigger()
1382 commonring = msgbuf->flowrings[flowid]; in brcmf_proto_msgbuf_rx_trigger()
1383 qlen = brcmf_flowring_qlen(msgbuf->flow, flowid); in brcmf_proto_msgbuf_rx_trigger()
1387 brcmf_msgbuf_schedule_txdata(msgbuf, flowid, true); in brcmf_proto_msgbuf_rx_trigger()
1396 struct brcmf_msgbuf *msgbuf = (struct brcmf_msgbuf *)drvr->proto->pd; in brcmf_msgbuf_delete_flowring() local
1406 brcmf_msgbuf_remove_flowring(msgbuf, flowid); in brcmf_msgbuf_delete_flowring()
1410 commonring = msgbuf->commonrings[BRCMF_H2D_MSGRING_CONTROL_SUBMIT]; in brcmf_msgbuf_delete_flowring()
1416 brcmf_msgbuf_remove_flowring(msgbuf, flowid); in brcmf_msgbuf_delete_flowring()
1422 ifidx = brcmf_flowring_ifidx_get(msgbuf->flow, flowid); in brcmf_msgbuf_delete_flowring()
1439 brcmf_msgbuf_remove_flowring(msgbuf, flowid); in brcmf_msgbuf_delete_flowring()
1448 struct brcmf_msgbuf *msgbuf = (struct brcmf_msgbuf *)drvr->proto->pd; in brcmf_msgbuf_stats_read() local
1454 commonring = msgbuf->commonrings[BRCMF_H2D_MSGRING_CONTROL_SUBMIT]; in brcmf_msgbuf_stats_read()
1457 commonring = msgbuf->commonrings[BRCMF_H2D_MSGRING_RXPOST_SUBMIT]; in brcmf_msgbuf_stats_read()
1460 commonring = msgbuf->commonrings[BRCMF_D2H_MSGRING_CONTROL_COMPLETE]; in brcmf_msgbuf_stats_read()
1463 commonring = msgbuf->commonrings[BRCMF_D2H_MSGRING_TX_COMPLETE]; in brcmf_msgbuf_stats_read()
1466 commonring = msgbuf->commonrings[BRCMF_D2H_MSGRING_RX_COMPLETE]; in brcmf_msgbuf_stats_read()
1473 for (i = 0; i < msgbuf->flow->nrofrings; i++) { in brcmf_msgbuf_stats_read()
1474 if (!msgbuf->flow->rings[i]) in brcmf_msgbuf_stats_read()
1476 ring = msgbuf->flow->rings[i]; in brcmf_msgbuf_stats_read()
1479 commonring = msgbuf->flowrings[i]; in brcmf_msgbuf_stats_read()
1480 hash = &msgbuf->flow->hash[ring->hash_id]; in brcmf_msgbuf_stats_read()
1505 struct brcmf_msgbuf *msgbuf; in brcmf_proto_msgbuf_attach() local
1509 if_msgbuf = drvr->bus_if->msgbuf; in brcmf_proto_msgbuf_attach()
1517 msgbuf = kzalloc(sizeof(*msgbuf), GFP_KERNEL); in brcmf_proto_msgbuf_attach()
1518 if (!msgbuf) in brcmf_proto_msgbuf_attach()
1521 msgbuf->txflow_wq = create_singlethread_workqueue("msgbuf_txflow"); in brcmf_proto_msgbuf_attach()
1522 if (msgbuf->txflow_wq == NULL) { in brcmf_proto_msgbuf_attach()
1526 INIT_WORK(&msgbuf->txflow_work, brcmf_msgbuf_txflow_worker); in brcmf_proto_msgbuf_attach()
1529 msgbuf->flow_map = kzalloc(count, GFP_KERNEL); in brcmf_proto_msgbuf_attach()
1530 if (!msgbuf->flow_map) in brcmf_proto_msgbuf_attach()
1533 msgbuf->txstatus_done_map = kzalloc(count, GFP_KERNEL); in brcmf_proto_msgbuf_attach()
1534 if (!msgbuf->txstatus_done_map) in brcmf_proto_msgbuf_attach()
1537 msgbuf->drvr = drvr; in brcmf_proto_msgbuf_attach()
1538 msgbuf->ioctbuf = dma_alloc_coherent(drvr->bus_if->dev, in brcmf_proto_msgbuf_attach()
1540 &msgbuf->ioctbuf_handle, in brcmf_proto_msgbuf_attach()
1542 if (!msgbuf->ioctbuf) in brcmf_proto_msgbuf_attach()
1544 address = (u64)msgbuf->ioctbuf_handle; in brcmf_proto_msgbuf_attach()
1545 msgbuf->ioctbuf_phys_hi = address >> 32; in brcmf_proto_msgbuf_attach()
1546 msgbuf->ioctbuf_phys_lo = address & 0xffffffff; in brcmf_proto_msgbuf_attach()
1557 drvr->proto->pd = msgbuf; in brcmf_proto_msgbuf_attach()
1559 init_waitqueue_head(&msgbuf->ioctl_resp_wait); in brcmf_proto_msgbuf_attach()
1561 msgbuf->commonrings = in brcmf_proto_msgbuf_attach()
1563 msgbuf->flowrings = (struct brcmf_commonring **)if_msgbuf->flowrings; in brcmf_proto_msgbuf_attach()
1564 msgbuf->max_flowrings = if_msgbuf->max_flowrings; in brcmf_proto_msgbuf_attach()
1565 msgbuf->flowring_dma_handle = in brcmf_proto_msgbuf_attach()
1566 kcalloc(msgbuf->max_flowrings, in brcmf_proto_msgbuf_attach()
1567 sizeof(*msgbuf->flowring_dma_handle), GFP_KERNEL); in brcmf_proto_msgbuf_attach()
1568 if (!msgbuf->flowring_dma_handle) in brcmf_proto_msgbuf_attach()
1571 msgbuf->rx_dataoffset = if_msgbuf->rx_dataoffset; in brcmf_proto_msgbuf_attach()
1572 msgbuf->max_rxbufpost = if_msgbuf->max_rxbufpost; in brcmf_proto_msgbuf_attach()
1574 msgbuf->max_ioctlrespbuf = BRCMF_MSGBUF_MAX_IOCTLRESPBUF_POST; in brcmf_proto_msgbuf_attach()
1575 msgbuf->max_eventbuf = BRCMF_MSGBUF_MAX_EVENTBUF_POST; in brcmf_proto_msgbuf_attach()
1577 msgbuf->tx_pktids = brcmf_msgbuf_init_pktids(NR_TX_PKTIDS, in brcmf_proto_msgbuf_attach()
1579 if (!msgbuf->tx_pktids) in brcmf_proto_msgbuf_attach()
1581 msgbuf->rx_pktids = brcmf_msgbuf_init_pktids(NR_RX_PKTIDS, in brcmf_proto_msgbuf_attach()
1583 if (!msgbuf->rx_pktids) in brcmf_proto_msgbuf_attach()
1586 msgbuf->flow = brcmf_flowring_attach(drvr->bus_if->dev, in brcmf_proto_msgbuf_attach()
1588 if (!msgbuf->flow) in brcmf_proto_msgbuf_attach()
1593 msgbuf->max_rxbufpost, msgbuf->max_eventbuf, in brcmf_proto_msgbuf_attach()
1594 msgbuf->max_ioctlrespbuf); in brcmf_proto_msgbuf_attach()
1597 brcmf_msgbuf_rxbuf_data_fill(msgbuf); in brcmf_proto_msgbuf_attach()
1598 if (msgbuf->max_rxbufpost != msgbuf->rxbufpost) in brcmf_proto_msgbuf_attach()
1604 brcmf_msgbuf_rxbuf_event_post(msgbuf); in brcmf_proto_msgbuf_attach()
1605 brcmf_msgbuf_rxbuf_ioctlresp_post(msgbuf); in brcmf_proto_msgbuf_attach()
1607 INIT_WORK(&msgbuf->flowring_work, brcmf_msgbuf_flowring_worker); in brcmf_proto_msgbuf_attach()
1608 spin_lock_init(&msgbuf->flowring_work_lock); in brcmf_proto_msgbuf_attach()
1609 INIT_LIST_HEAD(&msgbuf->work_queue); in brcmf_proto_msgbuf_attach()
1614 if (msgbuf) { in brcmf_proto_msgbuf_attach()
1615 kfree(msgbuf->flow_map); in brcmf_proto_msgbuf_attach()
1616 kfree(msgbuf->txstatus_done_map); in brcmf_proto_msgbuf_attach()
1617 brcmf_msgbuf_release_pktids(msgbuf); in brcmf_proto_msgbuf_attach()
1618 kfree(msgbuf->flowring_dma_handle); in brcmf_proto_msgbuf_attach()
1619 if (msgbuf->ioctbuf) in brcmf_proto_msgbuf_attach()
1622 msgbuf->ioctbuf, in brcmf_proto_msgbuf_attach()
1623 msgbuf->ioctbuf_handle); in brcmf_proto_msgbuf_attach()
1624 if (msgbuf->txflow_wq) in brcmf_proto_msgbuf_attach()
1625 destroy_workqueue(msgbuf->txflow_wq); in brcmf_proto_msgbuf_attach()
1626 kfree(msgbuf); in brcmf_proto_msgbuf_attach()
1634 struct brcmf_msgbuf *msgbuf; in brcmf_proto_msgbuf_detach() local
1639 msgbuf = (struct brcmf_msgbuf *)drvr->proto->pd; in brcmf_proto_msgbuf_detach()
1640 cancel_work_sync(&msgbuf->flowring_work); in brcmf_proto_msgbuf_detach()
1641 while (!list_empty(&msgbuf->work_queue)) { in brcmf_proto_msgbuf_detach()
1642 work = list_first_entry(&msgbuf->work_queue, in brcmf_proto_msgbuf_detach()
1648 kfree(msgbuf->flow_map); in brcmf_proto_msgbuf_detach()
1649 kfree(msgbuf->txstatus_done_map); in brcmf_proto_msgbuf_detach()
1650 if (msgbuf->txflow_wq) in brcmf_proto_msgbuf_detach()
1651 destroy_workqueue(msgbuf->txflow_wq); in brcmf_proto_msgbuf_detach()
1653 brcmf_flowring_detach(msgbuf->flow); in brcmf_proto_msgbuf_detach()
1656 msgbuf->ioctbuf, msgbuf->ioctbuf_handle); in brcmf_proto_msgbuf_detach()
1657 brcmf_msgbuf_release_pktids(msgbuf); in brcmf_proto_msgbuf_detach()
1658 kfree(msgbuf->flowring_dma_handle); in brcmf_proto_msgbuf_detach()
1659 kfree(msgbuf); in brcmf_proto_msgbuf_detach()