51 brcmf_flowring_is_tdls_mac(struct brcmf_flowring *flow, u8 mac[ETH_ALEN])  in brcmf_flowring_is_tdls_mac()  argument
55 	search = flow->tdls_entry;  in brcmf_flowring_is_tdls_mac()
67 u32 brcmf_flowring_lookup(struct brcmf_flowring *flow, u8 da[ETH_ALEN],  in brcmf_flowring_lookup()  argument
79 	sta = (flow->addr_mode[ifidx] == ADDR_INDIRECT);  in brcmf_flowring_lookup()
85 	if ((sta) && (flow->tdls_active) &&  in brcmf_flowring_lookup()
86 	    (brcmf_flowring_is_tdls_mac(flow, da))) {  in brcmf_flowring_lookup()
92 	hash = flow->hash;  in brcmf_flowring_lookup()
109 u32 brcmf_flowring_create(struct brcmf_flowring *flow, u8 da[ETH_ALEN],  in brcmf_flowring_create()  argument
122 	sta = (flow->addr_mode[ifidx] == ADDR_INDIRECT);  in brcmf_flowring_create()
128 	if ((sta) && (flow->tdls_active) &&  in brcmf_flowring_create()
129 	    (brcmf_flowring_is_tdls_mac(flow, da))) {  in brcmf_flowring_create()
135 	hash = flow->hash;  in brcmf_flowring_create()
145 		for (i = 0; i < flow->nrofrings; i++) {  in brcmf_flowring_create()
146 			if (flow->rings[i] == NULL)  in brcmf_flowring_create()
149 		if (i == flow->nrofrings)  in brcmf_flowring_create()
164 		flow->rings[i] = ring;  in brcmf_flowring_create()
172 u8 brcmf_flowring_tid(struct brcmf_flowring *flow, u8 flowid)  in brcmf_flowring_tid()  argument
176 	ring = flow->rings[flowid];  in brcmf_flowring_tid()
178 	return flow->hash[ring->hash_id].fifo;  in brcmf_flowring_tid()
182 static void brcmf_flowring_block(struct brcmf_flowring *flow, u8 flowid,  in brcmf_flowring_block()  argument
194 	spin_lock_irqsave(&flow->block_lock, flags);  in brcmf_flowring_block()
196 	ring = flow->rings[flowid];  in brcmf_flowring_block()
198 		spin_unlock_irqrestore(&flow->block_lock, flags);  in brcmf_flowring_block()
201 	ifidx = brcmf_flowring_ifidx_get(flow, flowid);  in brcmf_flowring_block()
204 	for (i = 0; i < flow->nrofrings; i++) {  in brcmf_flowring_block()
205 		if ((flow->rings[i]) && (i != flowid)) {  in brcmf_flowring_block()
206 			ring = flow->rings[i];  in brcmf_flowring_block()
208 			    (brcmf_flowring_ifidx_get(flow, i) == ifidx)) {  in brcmf_flowring_block()
216 	flow->rings[flowid]->blocked = blocked;  in brcmf_flowring_block()
218 		spin_unlock_irqrestore(&flow->block_lock, flags);  in brcmf_flowring_block()
222 	bus_if = dev_get_drvdata(flow->dev);  in brcmf_flowring_block()
227 	spin_unlock_irqrestore(&flow->block_lock, flags);  in brcmf_flowring_block()
231 void brcmf_flowring_delete(struct brcmf_flowring *flow, u8 flowid)  in brcmf_flowring_delete()  argument
237 	ring = flow->rings[flowid];  in brcmf_flowring_delete()
240 	brcmf_flowring_block(flow, flowid, false);  in brcmf_flowring_delete()
242 	flow->hash[hash_idx].ifidx = BRCMF_FLOWRING_INVALID_IFIDX;  in brcmf_flowring_delete()
243 	eth_zero_addr(flow->hash[hash_idx].mac);  in brcmf_flowring_delete()
244 	flow->rings[flowid] = NULL;  in brcmf_flowring_delete()
256 u32 brcmf_flowring_enqueue(struct brcmf_flowring *flow, u8 flowid,  in brcmf_flowring_enqueue()  argument
261 	ring = flow->rings[flowid];  in brcmf_flowring_enqueue()
267 		brcmf_flowring_block(flow, flowid, true);  in brcmf_flowring_enqueue()
276 			brcmf_flowring_block(flow, flowid, false);  in brcmf_flowring_enqueue()
282 struct sk_buff *brcmf_flowring_dequeue(struct brcmf_flowring *flow, u8 flowid)  in brcmf_flowring_dequeue()  argument
287 	ring = flow->rings[flowid];  in brcmf_flowring_dequeue()
295 		brcmf_flowring_block(flow, flowid, false);  in brcmf_flowring_dequeue()
303 void brcmf_flowring_reinsert(struct brcmf_flowring *flow, u8 flowid,  in brcmf_flowring_reinsert()  argument
308 	ring = flow->rings[flowid];  in brcmf_flowring_reinsert()
314 u32 brcmf_flowring_qlen(struct brcmf_flowring *flow, u8 flowid)  in brcmf_flowring_qlen()  argument
318 	ring = flow->rings[flowid];  in brcmf_flowring_qlen()
329 void brcmf_flowring_open(struct brcmf_flowring *flow, u8 flowid)  in brcmf_flowring_open()  argument
333 	ring = flow->rings[flowid];  in brcmf_flowring_open()
343 u8 brcmf_flowring_ifidx_get(struct brcmf_flowring *flow, u8 flowid)  in brcmf_flowring_ifidx_get()  argument
348 	ring = flow->rings[flowid];  in brcmf_flowring_ifidx_get()
351 	return flow->hash[hash_idx].ifidx;  in brcmf_flowring_ifidx_get()
357 	struct brcmf_flowring *flow;  in brcmf_flowring_attach()  local
360 	flow = kzalloc(sizeof(*flow), GFP_KERNEL);  in brcmf_flowring_attach()
361 	if (flow) {  in brcmf_flowring_attach()
362 		flow->dev = dev;  in brcmf_flowring_attach()
363 		flow->nrofrings = nrofrings;  in brcmf_flowring_attach()
364 		spin_lock_init(&flow->block_lock);  in brcmf_flowring_attach()
365 		for (i = 0; i < ARRAY_SIZE(flow->addr_mode); i++)  in brcmf_flowring_attach()
366 			flow->addr_mode[i] = ADDR_INDIRECT;  in brcmf_flowring_attach()
367 		for (i = 0; i < ARRAY_SIZE(flow->hash); i++)  in brcmf_flowring_attach()
368 			flow->hash[i].ifidx = BRCMF_FLOWRING_INVALID_IFIDX;  in brcmf_flowring_attach()
369 		flow->rings = kcalloc(nrofrings, sizeof(*flow->rings),  in brcmf_flowring_attach()
371 		if (!flow->rings) {  in brcmf_flowring_attach()
372 			kfree(flow);  in brcmf_flowring_attach()
373 			flow = NULL;  in brcmf_flowring_attach()
377 	return flow;  in brcmf_flowring_attach()
381 void brcmf_flowring_detach(struct brcmf_flowring *flow)  in brcmf_flowring_detach()  argument
383 	struct brcmf_bus *bus_if = dev_get_drvdata(flow->dev);  in brcmf_flowring_detach()
389 	for (flowid = 0; flowid < flow->nrofrings; flowid++) {  in brcmf_flowring_detach()
390 		if (flow->rings[flowid])  in brcmf_flowring_detach()
394 	search = flow->tdls_entry;  in brcmf_flowring_detach()
400 	kfree(flow->rings);  in brcmf_flowring_detach()
401 	kfree(flow);  in brcmf_flowring_detach()
405 void brcmf_flowring_configure_addr_mode(struct brcmf_flowring *flow, int ifidx,  in brcmf_flowring_configure_addr_mode()  argument
408 	struct brcmf_bus *bus_if = dev_get_drvdata(flow->dev);  in brcmf_flowring_configure_addr_mode()
413 	if (flow->addr_mode[ifidx] != addr_mode) {  in brcmf_flowring_configure_addr_mode()
414 		for (i = 0; i < ARRAY_SIZE(flow->hash); i++) {  in brcmf_flowring_configure_addr_mode()
415 			if (flow->hash[i].ifidx == ifidx) {  in brcmf_flowring_configure_addr_mode()
416 				flowid = flow->hash[i].flowid;  in brcmf_flowring_configure_addr_mode()
417 				if (flow->rings[flowid]->status != RING_OPEN)  in brcmf_flowring_configure_addr_mode()
419 				flow->rings[flowid]->status = RING_CLOSING;  in brcmf_flowring_configure_addr_mode()
423 		flow->addr_mode[ifidx] = addr_mode;  in brcmf_flowring_configure_addr_mode()
428 void brcmf_flowring_delete_peer(struct brcmf_flowring *flow, int ifidx,  in brcmf_flowring_delete_peer()  argument
431 	struct brcmf_bus *bus_if = dev_get_drvdata(flow->dev);  in brcmf_flowring_delete_peer()
440 	sta = (flow->addr_mode[ifidx] == ADDR_INDIRECT);  in brcmf_flowring_delete_peer()
442 	search = flow->tdls_entry;  in brcmf_flowring_delete_peer()
453 	hash = flow->hash;  in brcmf_flowring_delete_peer()
457 			flowid = flow->hash[i].flowid;  in brcmf_flowring_delete_peer()
458 			if (flow->rings[flowid]->status == RING_OPEN) {  in brcmf_flowring_delete_peer()
459 				flow->rings[flowid]->status = RING_CLOSING;  in brcmf_flowring_delete_peer()
469 			flow->tdls_entry = search->next;  in brcmf_flowring_delete_peer()
471 		if (flow->tdls_entry == NULL)  in brcmf_flowring_delete_peer()
472 			flow->tdls_active = false;  in brcmf_flowring_delete_peer()
477 void brcmf_flowring_add_tdls_peer(struct brcmf_flowring *flow, int ifidx,  in brcmf_flowring_add_tdls_peer()  argument
489 	if (flow->tdls_entry == NULL) {  in brcmf_flowring_add_tdls_peer()
490 		flow->tdls_entry = tdls_entry;  in brcmf_flowring_add_tdls_peer()
492 		search = flow->tdls_entry;  in brcmf_flowring_add_tdls_peer()
503 	flow->tdls_active = true;  in brcmf_flowring_add_tdls_peer()