2  * net/tipc/bcast.c: TIPC broadcast code
72 static struct tipc_bc_base *tipc_bc_base(struct net *net)  in tipc_bc_base()  argument
74 	return tipc_net(net)->bcbase;  in tipc_bc_base()
81 int tipc_bcast_get_mtu(struct net *net)  in tipc_bcast_get_mtu()  argument
83 	return tipc_link_mtu(tipc_bc_sndlink(net)) - INT_H_SIZE;  in tipc_bcast_get_mtu()
86 void tipc_bcast_disable_rcast(struct net *net)  in tipc_bcast_disable_rcast()  argument
88 	tipc_bc_base(net)->rcast_support = false;  in tipc_bcast_disable_rcast()
91 static void tipc_bcbase_calc_bc_threshold(struct net *net)  in tipc_bcbase_calc_bc_threshold()  argument
93 	struct tipc_bc_base *bb = tipc_bc_base(net);  in tipc_bcbase_calc_bc_threshold()
94 	int cluster_size = tipc_link_bc_peers(tipc_bc_sndlink(net));  in tipc_bcbase_calc_bc_threshold()
102 static void tipc_bcbase_select_primary(struct net *net)  in tipc_bcbase_select_primary()  argument
104 	struct tipc_bc_base *bb = tipc_bc_base(net);  in tipc_bcbase_select_primary()
118 		mtu = tipc_bearer_mtu(net, i);  in tipc_bcbase_select_primary()
121 		bb->bcast_support &= tipc_bearer_bcast_support(net, i);  in tipc_bcbase_select_primary()
128 		if ((i ^ tipc_own_addr(net)) & 1)  in tipc_bcbase_select_primary()
133 		bb->bcast_support = tipc_bearer_bcast_support(net, prim);  in tipc_bcbase_select_primary()
136 void tipc_bcast_inc_bearer_dst_cnt(struct net *net, int bearer_id)  in tipc_bcast_inc_bearer_dst_cnt()  argument
138 	struct tipc_bc_base *bb = tipc_bc_base(net);  in tipc_bcast_inc_bearer_dst_cnt()
140 	tipc_bcast_lock(net);  in tipc_bcast_inc_bearer_dst_cnt()
142 	tipc_bcbase_select_primary(net);  in tipc_bcast_inc_bearer_dst_cnt()
143 	tipc_bcast_unlock(net);  in tipc_bcast_inc_bearer_dst_cnt()
146 void tipc_bcast_dec_bearer_dst_cnt(struct net *net, int bearer_id)  in tipc_bcast_dec_bearer_dst_cnt()  argument
148 	struct tipc_bc_base *bb = tipc_bc_base(net);  in tipc_bcast_dec_bearer_dst_cnt()
150 	tipc_bcast_lock(net);  in tipc_bcast_dec_bearer_dst_cnt()
152 	tipc_bcbase_select_primary(net);  in tipc_bcast_dec_bearer_dst_cnt()
153 	tipc_bcast_unlock(net);  in tipc_bcast_dec_bearer_dst_cnt()
166 static void tipc_bcbase_xmit(struct net *net, struct sk_buff_head *xmitq)  in tipc_bcbase_xmit()  argument
169 	struct tipc_bc_base *bb = tipc_bc_base(net);  in tipc_bcbase_xmit()
179 		tipc_bearer_bc_xmit(net, bearer_id, xmitq);  in tipc_bcbase_xmit()
195 		tipc_bearer_bc_xmit(net, bearer_id, &_xmitq);  in tipc_bcbase_xmit()
201 static void tipc_bcast_select_xmit_method(struct net *net, int dests,  in tipc_bcast_select_xmit_method()  argument
204 	struct tipc_bc_base *bb = tipc_bc_base(net);  in tipc_bcast_select_xmit_method()
227  * @net: the applicable net namespace
233 static int tipc_bcast_xmit(struct net *net, struct sk_buff_head *pkts,  in tipc_bcast_xmit()  argument
236 	struct tipc_link *l = tipc_bc_sndlink(net);  in tipc_bcast_xmit()
241 	tipc_bcast_lock(net);  in tipc_bcast_xmit()
244 	tipc_bcast_unlock(net);  in tipc_bcast_xmit()
245 	tipc_bcbase_xmit(net, &xmitq);  in tipc_bcast_xmit()
255  * @net: the applicable net namespace
262 static int tipc_rcast_xmit(struct net *net, struct sk_buff_head *pkts,  in tipc_rcast_xmit()  argument
278 		if (tipc_node_xmit(net, &_pkts, dnode, selector) == -ELINKCONG)  in tipc_rcast_xmit()
286  * @net: the applicable net namespace
294 int tipc_mcast_xmit(struct net *net, struct sk_buff_head *pkts,  in tipc_mcast_xmit()  argument
311 		tipc_bcast_select_xmit_method(net, dests->remote, method);  in tipc_mcast_xmit()
313 			rc = tipc_rcast_xmit(net, pkts, dests, cong_link_cnt);  in tipc_mcast_xmit()
315 			rc = tipc_bcast_xmit(net, pkts, cong_link_cnt);  in tipc_mcast_xmit()
319 		tipc_sk_mcast_rcv(net, &localq, &inputq);  in tipc_mcast_xmit()
330 int tipc_bcast_rcv(struct net *net, struct tipc_link *l, struct sk_buff *skb)  in tipc_bcast_rcv()  argument
333 	struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq;  in tipc_bcast_rcv()
339 	if (msg_mc_netid(hdr) != tipc_netid(net) || !tipc_link_is_up(l)) {  in tipc_bcast_rcv()
344 	tipc_bcast_lock(net);  in tipc_bcast_rcv()
349 	tipc_bcast_unlock(net);  in tipc_bcast_rcv()
351 	tipc_bcbase_xmit(net, &xmitq);  in tipc_bcast_rcv()
355 		tipc_sk_rcv(net, inputq);  in tipc_bcast_rcv()
364 void tipc_bcast_ack_rcv(struct net *net, struct tipc_link *l,  in tipc_bcast_ack_rcv()  argument
367 	struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq;  in tipc_bcast_ack_rcv()
377 	tipc_bcast_lock(net);  in tipc_bcast_ack_rcv()
379 	tipc_bcast_unlock(net);  in tipc_bcast_ack_rcv()
381 	tipc_bcbase_xmit(net, &xmitq);  in tipc_bcast_ack_rcv()
385 		tipc_sk_rcv(net, inputq);  in tipc_bcast_ack_rcv()
392 int tipc_bcast_sync_rcv(struct net *net, struct tipc_link *l,  in tipc_bcast_sync_rcv()  argument
395 	struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq;  in tipc_bcast_sync_rcv()
401 	tipc_bcast_lock(net);  in tipc_bcast_sync_rcv()
408 	tipc_bcast_unlock(net);  in tipc_bcast_sync_rcv()
410 	tipc_bcbase_xmit(net, &xmitq);  in tipc_bcast_sync_rcv()
414 		tipc_sk_rcv(net, inputq);  in tipc_bcast_sync_rcv()
422 void tipc_bcast_add_peer(struct net *net, struct tipc_link *uc_l,  in tipc_bcast_add_peer()  argument
425 	struct tipc_link *snd_l = tipc_bc_sndlink(net);  in tipc_bcast_add_peer()
427 	tipc_bcast_lock(net);  in tipc_bcast_add_peer()
429 	tipc_bcbase_select_primary(net);  in tipc_bcast_add_peer()
430 	tipc_bcbase_calc_bc_threshold(net);  in tipc_bcast_add_peer()
431 	tipc_bcast_unlock(net);  in tipc_bcast_add_peer()
438 void tipc_bcast_remove_peer(struct net *net, struct tipc_link *rcv_l)  in tipc_bcast_remove_peer()  argument
440 	struct tipc_link *snd_l = tipc_bc_sndlink(net);  in tipc_bcast_remove_peer()
441 	struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq;  in tipc_bcast_remove_peer()
446 	tipc_bcast_lock(net);  in tipc_bcast_remove_peer()
448 	tipc_bcbase_select_primary(net);  in tipc_bcast_remove_peer()
449 	tipc_bcbase_calc_bc_threshold(net);  in tipc_bcast_remove_peer()
450 	tipc_bcast_unlock(net);  in tipc_bcast_remove_peer()
452 	tipc_bcbase_xmit(net, &xmitq);  in tipc_bcast_remove_peer()
456 		tipc_sk_rcv(net, inputq);  in tipc_bcast_remove_peer()
459 int tipc_bclink_reset_stats(struct net *net)  in tipc_bclink_reset_stats()  argument
461 	struct tipc_link *l = tipc_bc_sndlink(net);  in tipc_bclink_reset_stats()
466 	tipc_bcast_lock(net);  in tipc_bclink_reset_stats()
468 	tipc_bcast_unlock(net);  in tipc_bclink_reset_stats()
472 static int tipc_bc_link_set_queue_limits(struct net *net, u32 limit)  in tipc_bc_link_set_queue_limits()  argument
474 	struct tipc_link *l = tipc_bc_sndlink(net);  in tipc_bc_link_set_queue_limits()
482 	tipc_bcast_lock(net);  in tipc_bc_link_set_queue_limits()
484 	tipc_bcast_unlock(net);  in tipc_bc_link_set_queue_limits()
488 int tipc_nl_bc_link_set(struct net *net, struct nlattr *attrs[])  in tipc_nl_bc_link_set()  argument
506 	return tipc_bc_link_set_queue_limits(net, win);  in tipc_nl_bc_link_set()
509 int tipc_bcast_init(struct net *net)  in tipc_bcast_init()  argument
511 	struct tipc_net *tn = tipc_net(net);  in tipc_bcast_init()
519 	spin_lock_init(&tipc_net(net)->bclock);  in tipc_bcast_init()
521 	if (!tipc_link_bc_create(net, 0, 0,  in tipc_bcast_init()
541 void tipc_bcast_stop(struct net *net)  in tipc_bcast_stop()  argument
543 	struct tipc_net *tn = net_generic(net, tipc_net_id);  in tipc_bcast_stop()