brcm80211/brcmfmac/msgbuf.c

266 	struct brcmf_flowring *flow;
560 	brcmf_flowring_delete(msgbuf->flow, flowid);
603 		brcmf_flowring_delete(msgbuf->flow, flowid);
625 	create->tid = brcmf_flowring_tid(msgbuf->flow, flowid);
636 	brcmf_dbg(MSGBUF, "Send Flow Create Req flow ID %d for peer %pM prio %d ifindex %d\n",
677 	flowid = brcmf_flowring_create(msgbuf->flow, eh->h_dest,
700 	struct brcmf_flowring *flow = msgbuf->flow;
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);
804 	struct brcmf_flowring *flow = msgbuf->flow;
810 	flowid = brcmf_flowring_lookup(flow, eh->h_dest, skb->priority, ifidx);
816 			brcmf_flowring_enqueue(flow, flowid, skb);
820 	queue_count = brcmf_flowring_enqueue(flow, flowid, skb);
834 	brcmf_flowring_configure_addr_mode(msgbuf->flow, ifidx, addr_mode);
843 	brcmf_flowring_delete_peer(msgbuf->flow, ifidx, peer);
852 	brcmf_flowring_add_tdls_peer(msgbuf->flow, ifidx, peer);
1255 	brcmf_flowring_open(msgbuf->flow, flowid);
1278 		brcmf_flowring_delete(msgbuf->flow, flowid);
1390 		qlen = brcmf_flowring_qlen(msgbuf->flow, flowid);
1407 	struct brcmf_flowring *flow = msgbuf->flow;
1415 	flow->rings[flowid]->status = RING_CLOSING;
1447 	ifidx = brcmf_flowring_ifidx_get(msgbuf->flow, flowid);
1457 	brcmf_dbg(MSGBUF, "Send Flow Delete Req flow ID %d, ifindex %d\n",
1498 	for (i = 0; i < msgbuf->flow->nrofrings; i++) {
1499 		if (!msgbuf->flow->rings[i])
1501 		ring = msgbuf->flow->rings[i];
1505 		hash = &msgbuf->flow->hash[ring->hash_id];
1611 	msgbuf->flow = brcmf_flowring_attach(drvr->bus_if->dev,
1613 	if (!msgbuf->flow)
1678 		brcmf_flowring_detach(msgbuf->flow);