221 	u32 flowid;  member
543 brcmf_msgbuf_remove_flowring(struct brcmf_msgbuf *msgbuf, u16 flowid)  in brcmf_msgbuf_remove_flowring()  argument
548 	brcmf_dbg(MSGBUF, "Removing flowring %d\n", flowid);  in brcmf_msgbuf_remove_flowring()
551 	dma_buf = msgbuf->flowrings[flowid]->buf_addr;  in brcmf_msgbuf_remove_flowring()
553 			  msgbuf->flowring_dma_handle[flowid]);  in brcmf_msgbuf_remove_flowring()
555 	brcmf_flowring_delete(msgbuf->flow, flowid);  in brcmf_msgbuf_remove_flowring()
585 	u32 flowid;  in brcmf_msgbuf_flowring_create_worker()  local
591 	flowid = work->flowid;  in brcmf_msgbuf_flowring_create_worker()
594 				     &msgbuf->flowring_dma_handle[flowid],  in brcmf_msgbuf_flowring_create_worker()
598 		brcmf_flowring_delete(msgbuf->flow, flowid);  in brcmf_msgbuf_flowring_create_worker()
602 	brcmf_commonring_config(msgbuf->flowrings[flowid],  in brcmf_msgbuf_flowring_create_worker()
612 		brcmf_msgbuf_remove_flowring(msgbuf, flowid);  in brcmf_msgbuf_flowring_create_worker()
620 	create->tid = brcmf_flowring_tid(msgbuf->flow, flowid);  in brcmf_msgbuf_flowring_create_worker()
621 	create->flow_ring_id = cpu_to_le16(flowid +  in brcmf_msgbuf_flowring_create_worker()
625 	address = (u64)msgbuf->flowring_dma_handle[flowid];  in brcmf_msgbuf_flowring_create_worker()
632 		  flowid, work->da, create->tid, work->ifidx);  in brcmf_msgbuf_flowring_create_worker()
638 		brcmf_msgbuf_remove_flowring(msgbuf, flowid);  in brcmf_msgbuf_flowring_create_worker()
642 	return flowid;  in brcmf_msgbuf_flowring_create_worker()
665 	u32 flowid;  in brcmf_msgbuf_flowring_create()  local
672 	flowid = brcmf_flowring_create(msgbuf->flow, eh->h_dest,  in brcmf_msgbuf_flowring_create()
674 	if (flowid == BRCMF_FLOWRING_INVALID_ID) {  in brcmf_msgbuf_flowring_create()
676 		return flowid;  in brcmf_msgbuf_flowring_create()
679 	create->flowid = flowid;  in brcmf_msgbuf_flowring_create()
689 	return flowid;  in brcmf_msgbuf_flowring_create()
693 static void brcmf_msgbuf_txflow(struct brcmf_msgbuf *msgbuf, u16 flowid)  in brcmf_msgbuf_txflow()  argument
706 	commonring = msgbuf->flowrings[flowid];  in brcmf_msgbuf_txflow()
713 	while (brcmf_flowring_qlen(flow, flowid)) {  in brcmf_msgbuf_txflow()
714 		skb = brcmf_flowring_dequeue(flow, flowid);  in brcmf_msgbuf_txflow()
717 				 brcmf_flowring_qlen(flow, flowid));  in brcmf_msgbuf_txflow()
724 			brcmf_flowring_reinsert(flow, flowid, skb);  in brcmf_msgbuf_txflow()
732 			brcmf_flowring_reinsert(flow, flowid, skb);  in brcmf_msgbuf_txflow()
741 		tx_msghdr->msg.ifidx = brcmf_flowring_ifidx_get(flow, flowid);  in brcmf_msgbuf_txflow()
770 	u32 flowid;  in brcmf_msgbuf_txflow_worker()  local
773 	for_each_set_bit(flowid, msgbuf->flow_map, msgbuf->max_flowrings) {  in brcmf_msgbuf_txflow_worker()
774 		clear_bit(flowid, msgbuf->flow_map);  in brcmf_msgbuf_txflow_worker()
775 		brcmf_msgbuf_txflow(msgbuf, flowid);  in brcmf_msgbuf_txflow_worker()
780 static int brcmf_msgbuf_schedule_txdata(struct brcmf_msgbuf *msgbuf, u32 flowid,  in brcmf_msgbuf_schedule_txdata()  argument
785 	set_bit(flowid, msgbuf->flow_map);  in brcmf_msgbuf_schedule_txdata()
786 	commonring = msgbuf->flowrings[flowid];  in brcmf_msgbuf_schedule_txdata()
801 	u32 flowid;  in brcmf_msgbuf_tx_queue_data()  local
805 	flowid = brcmf_flowring_lookup(flow, eh->h_dest, skb->priority, ifidx);  in brcmf_msgbuf_tx_queue_data()
806 	if (flowid == BRCMF_FLOWRING_INVALID_ID) {  in brcmf_msgbuf_tx_queue_data()
807 		flowid = brcmf_msgbuf_flowring_create(msgbuf, ifidx, skb);  in brcmf_msgbuf_tx_queue_data()
808 		if (flowid == BRCMF_FLOWRING_INVALID_ID)  in brcmf_msgbuf_tx_queue_data()
811 	queue_count = brcmf_flowring_enqueue(flow, flowid, skb);  in brcmf_msgbuf_tx_queue_data()
813 	brcmf_msgbuf_schedule_txdata(msgbuf, flowid, force);  in brcmf_msgbuf_tx_queue_data()
874 	u16 flowid;  in brcmf_msgbuf_process_txstatus()  local
878 	flowid = le16_to_cpu(tx_status->compl_hdr.flow_ring_id);  in brcmf_msgbuf_process_txstatus()
879 	flowid -= BRCMF_H2D_MSGRING_FLOWRING_IDSTART;  in brcmf_msgbuf_process_txstatus()
885 	set_bit(flowid, msgbuf->txstatus_done_map);  in brcmf_msgbuf_process_txstatus()
886 	commonring = msgbuf->flowrings[flowid];  in brcmf_msgbuf_process_txstatus()
1230 	u16 flowid;  in brcmf_msgbuf_process_flow_ring_create_response()  local
1234 	flowid = le16_to_cpu(flowring_create_resp->compl_hdr.flow_ring_id);  in brcmf_msgbuf_process_flow_ring_create_response()
1235 	flowid -= BRCMF_H2D_MSGRING_FLOWRING_IDSTART;  in brcmf_msgbuf_process_flow_ring_create_response()
1240 		brcmf_msgbuf_remove_flowring(msgbuf, flowid);  in brcmf_msgbuf_process_flow_ring_create_response()
1243 	brcmf_dbg(MSGBUF, "Flowring %d Create response status %d\n", flowid,  in brcmf_msgbuf_process_flow_ring_create_response()
1246 	brcmf_flowring_open(msgbuf->flow, flowid);  in brcmf_msgbuf_process_flow_ring_create_response()
1248 	brcmf_msgbuf_schedule_txdata(msgbuf, flowid, true);  in brcmf_msgbuf_process_flow_ring_create_response()
1259 	u16 flowid;  in brcmf_msgbuf_process_flow_ring_delete_response()  local
1263 	flowid = le16_to_cpu(flowring_delete_resp->compl_hdr.flow_ring_id);  in brcmf_msgbuf_process_flow_ring_delete_response()
1264 	flowid -= BRCMF_H2D_MSGRING_FLOWRING_IDSTART;  in brcmf_msgbuf_process_flow_ring_delete_response()
1269 		brcmf_flowring_delete(msgbuf->flow, flowid);  in brcmf_msgbuf_process_flow_ring_delete_response()
1272 	brcmf_dbg(MSGBUF, "Flowring %d Delete response status %d\n", flowid,  in brcmf_msgbuf_process_flow_ring_delete_response()
1275 	brcmf_msgbuf_remove_flowring(msgbuf, flowid);  in brcmf_msgbuf_process_flow_ring_delete_response()
1367 	u32 flowid;  in brcmf_proto_msgbuf_rx_trigger()  local
1377 	for_each_set_bit(flowid, msgbuf->txstatus_done_map,  in brcmf_proto_msgbuf_rx_trigger()
1379 		clear_bit(flowid, msgbuf->txstatus_done_map);  in brcmf_proto_msgbuf_rx_trigger()
1380 		commonring = msgbuf->flowrings[flowid];  in brcmf_proto_msgbuf_rx_trigger()
1381 		qlen = brcmf_flowring_qlen(msgbuf->flow, flowid);  in brcmf_proto_msgbuf_rx_trigger()
1385 			brcmf_msgbuf_schedule_txdata(msgbuf, flowid, true);  in brcmf_proto_msgbuf_rx_trigger()
1392 void brcmf_msgbuf_delete_flowring(struct brcmf_pub *drvr, u16 flowid)  in brcmf_msgbuf_delete_flowring()  argument
1404 		brcmf_msgbuf_remove_flowring(msgbuf, flowid);  in brcmf_msgbuf_delete_flowring()
1414 		brcmf_msgbuf_remove_flowring(msgbuf, flowid);  in brcmf_msgbuf_delete_flowring()
1420 	ifidx = brcmf_flowring_ifidx_get(msgbuf->flow, flowid);  in brcmf_msgbuf_delete_flowring()
1426 	delete->flow_ring_id = cpu_to_le16(flowid +  in brcmf_msgbuf_delete_flowring()
1431 		  flowid, ifidx);  in brcmf_msgbuf_delete_flowring()
1437 		brcmf_msgbuf_remove_flowring(msgbuf, flowid);  in brcmf_msgbuf_delete_flowring()