brcm80211/brcmfmac/msgbuf.c

223 	u32 flowid;
548 brcmf_msgbuf_remove_flowring(struct brcmf_msgbuf *msgbuf, u16 flowid)
553 	brcmf_dbg(MSGBUF, "Removing flowring %d\n", flowid);
556 	dma_buf = msgbuf->flowrings[flowid]->buf_addr;
558 			  msgbuf->flowring_dma_handle[flowid]);
560 	brcmf_flowring_delete(msgbuf->flow, flowid);
590 	u32 flowid;
596 	flowid = work->flowid;
599 				     &msgbuf->flowring_dma_handle[flowid],
603 		brcmf_flowring_delete(msgbuf->flow, flowid);
607 	brcmf_commonring_config(msgbuf->flowrings[flowid],
617 		brcmf_msgbuf_remove_flowring(msgbuf, flowid);
625 	create->tid = brcmf_flowring_tid(msgbuf->flow, flowid);
626 	create->flow_ring_id = cpu_to_le16(flowid +
630 	address = (u64)msgbuf->flowring_dma_handle[flowid];
637 		  flowid, work->da, create->tid, work->ifidx);
643 		brcmf_msgbuf_remove_flowring(msgbuf, flowid);
647 	return flowid;
670 	u32 flowid;
677 	flowid = brcmf_flowring_create(msgbuf->flow, eh->h_dest,
679 	if (flowid == BRCMF_FLOWRING_INVALID_ID) {
681 		return flowid;
684 	create->flowid = flowid;
694 	return flowid;
698 static void brcmf_msgbuf_txflow(struct brcmf_msgbuf *msgbuf, u16 flowid)
711 	commonring = msgbuf->flowrings[flowid];
718 	while (brcmf_flowring_qlen(flow, flowid)) {
719 		skb = brcmf_flowring_dequeue(flow, flowid);
722 				 brcmf_flowring_qlen(flow, flowid));
729 			brcmf_flowring_reinsert(flow, flowid, skb);
737 			brcmf_flowring_reinsert(flow, flowid, skb);
746 		tx_msghdr->msg.ifidx = brcmf_flowring_ifidx_get(flow, flowid);
775 	u32 flowid;
778 	for_each_set_bit(flowid, msgbuf->flow_map, msgbuf->max_flowrings) {
779 		clear_bit(flowid, msgbuf->flow_map);
780 		brcmf_msgbuf_txflow(msgbuf, flowid);
785 static int brcmf_msgbuf_schedule_txdata(struct brcmf_msgbuf *msgbuf, u32 flowid,
790 	set_bit(flowid, msgbuf->flow_map);
791 	commonring = msgbuf->flowrings[flowid];
806 	u32 flowid;
810 	flowid = brcmf_flowring_lookup(flow, eh->h_dest, skb->priority, ifidx);
811 	if (flowid == BRCMF_FLOWRING_INVALID_ID) {
812 		flowid = brcmf_msgbuf_flowring_create(msgbuf, ifidx, skb);
813 		if (flowid == BRCMF_FLOWRING_INVALID_ID) {
816 			brcmf_flowring_enqueue(flow, flowid, skb);
820 	queue_count = brcmf_flowring_enqueue(flow, flowid, skb);
822 	brcmf_msgbuf_schedule_txdata(msgbuf, flowid, force);
883 	u16 flowid;
887 	flowid = le16_to_cpu(tx_status->compl_hdr.flow_ring_id);
888 	flowid -= BRCMF_H2D_MSGRING_FLOWRING_IDSTART;
894 	set_bit(flowid, msgbuf->txstatus_done_map);
895 	commonring = msgbuf->flowrings[flowid];
1239 	u16 flowid;
1243 	flowid = le16_to_cpu(flowring_create_resp->compl_hdr.flow_ring_id);
1244 	flowid -= BRCMF_H2D_MSGRING_FLOWRING_IDSTART;
1249 		brcmf_msgbuf_remove_flowring(msgbuf, flowid);
1252 	brcmf_dbg(MSGBUF, "Flowring %d Create response status %d\n", flowid,
1255 	brcmf_flowring_open(msgbuf->flow, flowid);
1257 	brcmf_msgbuf_schedule_txdata(msgbuf, flowid, true);
1268 	u16 flowid;
1272 	flowid = le16_to_cpu(flowring_delete_resp->compl_hdr.flow_ring_id);
1273 	flowid -= BRCMF_H2D_MSGRING_FLOWRING_IDSTART;
1278 		brcmf_flowring_delete(msgbuf->flow, flowid);
1281 	brcmf_dbg(MSGBUF, "Flowring %d Delete response status %d\n", flowid,
1284 	brcmf_msgbuf_remove_flowring(msgbuf, flowid);
1376 	u32 flowid;
1386 	for_each_set_bit(flowid, msgbuf->txstatus_done_map,
1388 		clear_bit(flowid, msgbuf->txstatus_done_map);
1389 		commonring = msgbuf->flowrings[flowid];
1390 		qlen = brcmf_flowring_qlen(msgbuf->flow, flowid);
1394 			brcmf_msgbuf_schedule_txdata(msgbuf, flowid, true);
1401 void brcmf_msgbuf_delete_flowring(struct brcmf_pub *drvr, u16 flowid)
1406 	struct brcmf_commonring *commonring_del = msgbuf->flowrings[flowid];
1415 	flow->rings[flowid]->status = RING_CLOSING;
1431 		brcmf_msgbuf_remove_flowring(msgbuf, flowid);
1441 		brcmf_msgbuf_remove_flowring(msgbuf, flowid);
1447 	ifidx = brcmf_flowring_ifidx_get(msgbuf->flow, flowid);
1453 	delete->flow_ring_id = cpu_to_le16(flowid +
1458 		  flowid, ifidx);
1464 		brcmf_msgbuf_remove_flowring(msgbuf, flowid);