57 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_lock()  local
59 	spin_lock_bh(&tn->bclink->lock);  in tipc_bclink_lock()
64 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_unlock()  local
66 	spin_unlock_bh(&tn->bclink->lock);  in tipc_bclink_unlock()
71 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_input()  local
73 	tipc_sk_mcast_rcv(net, &tn->bclink->arrvq, &tn->bclink->inputq);  in tipc_bclink_input()
98 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_add_node()  local
101 	tipc_nmap_add(&tn->bclink->bcast_nodes, addr);  in tipc_bclink_add_node()
107 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_remove_node()  local
110 	tipc_nmap_remove(&tn->bclink->bcast_nodes, addr);  in tipc_bclink_remove_node()
116 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in bclink_set_last_sent()  local
117 	struct tipc_link *bcl = tn->bcl;  in bclink_set_last_sent()
128 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_get_last_sent()  local
130 	return tn->bcl->fsm_msg_cnt;  in tipc_bclink_get_last_sent()
146 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_retransmit_to()  local
148 	return tn->bclink->retransmit_to;  in tipc_bclink_retransmit_to()
158 static void bclink_retransmit_pkt(struct tipc_net *tn, u32 after, u32 to)  in bclink_retransmit_pkt()  argument
161 	struct tipc_link *bcl = tn->bcl;  in bclink_retransmit_pkt()
178 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_wakeup_users()  local
180 	tipc_sk_rcv(net, &tn->bclink->link.wakeupq);  in tipc_bclink_wakeup_users()
195 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_acknowledge()  local
203 	skb = skb_peek(&tn->bcl->transmq);  in tipc_bclink_acknowledge()
214 		if (tn->bclink->bcast_nodes.count)  in tipc_bclink_acknowledge()
215 			acked = tn->bcl->fsm_msg_cnt;  in tipc_bclink_acknowledge()
217 			acked = tn->bcl->next_out_no;  in tipc_bclink_acknowledge()
224 		    less(tn->bcl->fsm_msg_cnt, acked) ||  in tipc_bclink_acknowledge()
230 	skb_queue_walk(&tn->bcl->transmq, skb) {  in tipc_bclink_acknowledge()
236 	skb_queue_walk_from_safe(&tn->bcl->transmq, skb, tmp) {  in tipc_bclink_acknowledge()
242 			__skb_unlink(skb, &tn->bcl->transmq);  in tipc_bclink_acknowledge()
250 	if (unlikely(skb_peek(&tn->bcl->backlogq))) {  in tipc_bclink_acknowledge()
251 		tipc_link_push_packets(tn->bcl);  in tipc_bclink_acknowledge()
254 	if (unlikely(released && !skb_queue_empty(&tn->bcl->wakeupq)))  in tipc_bclink_acknowledge()
270 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_update_link_state()  local
300 		tipc_msg_init(tn->own_addr, msg, BCAST_PROTOCOL, STATE_MSG,  in tipc_bclink_update_link_state()
303 		msg_set_mc_netid(msg, tn->net_id);  in tipc_bclink_update_link_state()
310 		tn->bcl->stats.sent_nacks++;  in tipc_bclink_update_link_state()
349 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_xmit()  local
350 	struct tipc_link *bcl = tn->bcl;  in tipc_bclink_xmit()
351 	struct tipc_bclink *bclink = tn->bclink;  in tipc_bclink_xmit()
403 	struct tipc_net *tn = net_generic(node->net, tipc_net_id);  in bclink_accept_pkt()  local
408 	tn->bcl->stats.recv_info++;  in bclink_accept_pkt()
414 	if (((seqno - tn->own_addr) % TIPC_MIN_LINK_WIN) == 0) {  in bclink_accept_pkt()
417 		tn->bcl->stats.sent_acks++;  in bclink_accept_pkt()
428 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_rcv()  local
429 	struct tipc_link *bcl = tn->bcl;  in tipc_bclink_rcv()
440 	if (msg_mc_netid(msg) != tn->net_id)  in tipc_bclink_rcv()
455 		if (msg_destnode(msg) == tn->own_addr) {  in tipc_bclink_rcv()
459 			tn->bclink->retransmit_to = node;  in tipc_bclink_rcv()
460 			bclink_retransmit_pkt(tn, msg_bcgap_after(msg),  in tipc_bclink_rcv()
475 	arrvq = &tn->bclink->arrvq;  in tipc_bclink_rcv()
476 	inputq = &tn->bclink->inputq;  in tipc_bclink_rcv()
600 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bcbearer_send()  local
601 	struct tipc_bcbearer *bcbearer = tn->bcbearer;  in tipc_bcbearer_send()
602 	struct tipc_bclink *bclink = tn->bclink;  in tipc_bcbearer_send()
612 		msg_set_mc_netid(msg, tn->net_id);  in tipc_bcbearer_send()
613 		tn->bcl->stats.sent_info++;  in tipc_bcbearer_send()
666 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bcbearer_sort()  local
667 	struct tipc_bcbearer *bcbearer = tn->bcbearer;  in tipc_bcbearer_sort()
686 		b = rcu_dereference_rtnl(tn->bearer_list[b_index]);  in tipc_bcbearer_sort()
781 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_nl_add_bc_link()  local
782 	struct tipc_link *bcl = tn->bcl;  in tipc_nl_add_bc_link()
841 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_reset_stats()  local
842 	struct tipc_link *bcl = tn->bcl;  in tipc_bclink_reset_stats()
855 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_set_queue_limits()  local
856 	struct tipc_link *bcl = tn->bcl;  in tipc_bclink_set_queue_limits()
871 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_init()  local
905 	rcu_assign_pointer(tn->bearer_list[MAX_BEARERS], &bcbearer->bearer);  in tipc_bclink_init()
908 	msg_set_prevnode(bcl->pmsg, tn->own_addr);  in tipc_bclink_init()
910 	tn->bcbearer = bcbearer;  in tipc_bclink_init()
911 	tn->bclink = bclink;  in tipc_bclink_init()
912 	tn->bcl = bcl;  in tipc_bclink_init()
918 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bclink_stop()  local
921 	tipc_link_purge_queues(tn->bcl);  in tipc_bclink_stop()
924 	RCU_INIT_POINTER(tn->bearer_list[BCBEARER], NULL);  in tipc_bclink_stop()
926 	kfree(tn->bcbearer);  in tipc_bclink_stop()
927 	kfree(tn->bclink);  in tipc_bclink_stop()