Lines Matching refs:net
65 static struct tipc_bc_base *tipc_bc_base(struct net *net) in tipc_bc_base() argument
67 return tipc_net(net)->bcbase; in tipc_bc_base()
70 int tipc_bcast_get_mtu(struct net *net) in tipc_bcast_get_mtu() argument
72 return tipc_link_mtu(tipc_bc_sndlink(net)); in tipc_bcast_get_mtu()
78 static void tipc_bcbase_select_primary(struct net *net) in tipc_bcbase_select_primary() argument
80 struct tipc_bc_base *bb = tipc_bc_base(net); in tipc_bcbase_select_primary()
93 mtu = tipc_bearer_mtu(net, i); in tipc_bcbase_select_primary()
103 if ((i ^ tipc_own_addr(net)) & 1) in tipc_bcbase_select_primary()
108 void tipc_bcast_inc_bearer_dst_cnt(struct net *net, int bearer_id) in tipc_bcast_inc_bearer_dst_cnt() argument
110 struct tipc_bc_base *bb = tipc_bc_base(net); in tipc_bcast_inc_bearer_dst_cnt()
112 tipc_bcast_lock(net); in tipc_bcast_inc_bearer_dst_cnt()
114 tipc_bcbase_select_primary(net); in tipc_bcast_inc_bearer_dst_cnt()
115 tipc_bcast_unlock(net); in tipc_bcast_inc_bearer_dst_cnt()
118 void tipc_bcast_dec_bearer_dst_cnt(struct net *net, int bearer_id) in tipc_bcast_dec_bearer_dst_cnt() argument
120 struct tipc_bc_base *bb = tipc_bc_base(net); in tipc_bcast_dec_bearer_dst_cnt()
122 tipc_bcast_lock(net); in tipc_bcast_dec_bearer_dst_cnt()
124 tipc_bcbase_select_primary(net); in tipc_bcast_dec_bearer_dst_cnt()
125 tipc_bcast_unlock(net); in tipc_bcast_dec_bearer_dst_cnt()
138 static void tipc_bcbase_xmit(struct net *net, struct sk_buff_head *xmitq) in tipc_bcbase_xmit() argument
141 struct tipc_bc_base *bb = tipc_bc_base(net); in tipc_bcbase_xmit()
151 tipc_bearer_bc_xmit(net, bearer_id, xmitq); in tipc_bcbase_xmit()
167 tipc_bearer_bc_xmit(net, bearer_id, &_xmitq); in tipc_bcbase_xmit()
180 int tipc_bcast_xmit(struct net *net, struct sk_buff_head *list) in tipc_bcast_xmit() argument
182 struct tipc_link *l = tipc_bc_sndlink(net); in tipc_bcast_xmit()
194 tipc_bcast_lock(net); in tipc_bcast_xmit()
197 tipc_bcast_unlock(net); in tipc_bcast_xmit()
206 tipc_bcbase_xmit(net, &xmitq); in tipc_bcast_xmit()
207 tipc_sk_mcast_rcv(net, &rcvq, &inputq); in tipc_bcast_xmit()
216 int tipc_bcast_rcv(struct net *net, struct tipc_link *l, struct sk_buff *skb) in tipc_bcast_rcv() argument
219 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_rcv()
225 if (msg_mc_netid(hdr) != tipc_netid(net) || !tipc_link_is_up(l)) { in tipc_bcast_rcv()
230 tipc_bcast_lock(net); in tipc_bcast_rcv()
235 tipc_bcast_unlock(net); in tipc_bcast_rcv()
237 tipc_bcbase_xmit(net, &xmitq); in tipc_bcast_rcv()
241 tipc_sk_rcv(net, inputq); in tipc_bcast_rcv()
250 void tipc_bcast_ack_rcv(struct net *net, struct tipc_link *l, u32 acked) in tipc_bcast_ack_rcv() argument
252 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_ack_rcv()
257 tipc_bcast_lock(net); in tipc_bcast_ack_rcv()
259 tipc_bcast_unlock(net); in tipc_bcast_ack_rcv()
261 tipc_bcbase_xmit(net, &xmitq); in tipc_bcast_ack_rcv()
265 tipc_sk_rcv(net, inputq); in tipc_bcast_ack_rcv()
272 void tipc_bcast_sync_rcv(struct net *net, struct tipc_link *l, in tipc_bcast_sync_rcv() argument
275 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_sync_rcv()
280 tipc_bcast_lock(net); in tipc_bcast_sync_rcv()
287 tipc_bcast_unlock(net); in tipc_bcast_sync_rcv()
289 tipc_bcbase_xmit(net, &xmitq); in tipc_bcast_sync_rcv()
293 tipc_sk_rcv(net, inputq); in tipc_bcast_sync_rcv()
300 void tipc_bcast_add_peer(struct net *net, struct tipc_link *uc_l, in tipc_bcast_add_peer() argument
303 struct tipc_link *snd_l = tipc_bc_sndlink(net); in tipc_bcast_add_peer()
305 tipc_bcast_lock(net); in tipc_bcast_add_peer()
307 tipc_bcbase_select_primary(net); in tipc_bcast_add_peer()
308 tipc_bcast_unlock(net); in tipc_bcast_add_peer()
315 void tipc_bcast_remove_peer(struct net *net, struct tipc_link *rcv_l) in tipc_bcast_remove_peer() argument
317 struct tipc_link *snd_l = tipc_bc_sndlink(net); in tipc_bcast_remove_peer()
318 struct sk_buff_head *inputq = &tipc_bc_base(net)->inputq; in tipc_bcast_remove_peer()
323 tipc_bcast_lock(net); in tipc_bcast_remove_peer()
325 tipc_bcbase_select_primary(net); in tipc_bcast_remove_peer()
326 tipc_bcast_unlock(net); in tipc_bcast_remove_peer()
328 tipc_bcbase_xmit(net, &xmitq); in tipc_bcast_remove_peer()
332 tipc_sk_rcv(net, inputq); in tipc_bcast_remove_peer()
386 int tipc_nl_add_bc_link(struct net *net, struct tipc_nl_msg *msg) in tipc_nl_add_bc_link() argument
392 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_nl_add_bc_link()
398 tipc_bcast_lock(net); in tipc_nl_add_bc_link()
403 tipc_bcast_unlock(net); in tipc_nl_add_bc_link()
435 tipc_bcast_unlock(net); in tipc_nl_add_bc_link()
446 tipc_bcast_unlock(net); in tipc_nl_add_bc_link()
452 int tipc_bclink_reset_stats(struct net *net) in tipc_bclink_reset_stats() argument
454 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_bclink_reset_stats()
460 tipc_bcast_lock(net); in tipc_bclink_reset_stats()
462 tipc_bcast_unlock(net); in tipc_bclink_reset_stats()
466 static int tipc_bc_link_set_queue_limits(struct net *net, u32 limit) in tipc_bc_link_set_queue_limits() argument
468 struct tipc_link *l = tipc_bc_sndlink(net); in tipc_bc_link_set_queue_limits()
476 tipc_bcast_lock(net); in tipc_bc_link_set_queue_limits()
478 tipc_bcast_unlock(net); in tipc_bc_link_set_queue_limits()
482 int tipc_nl_bc_link_set(struct net *net, struct nlattr *attrs[]) in tipc_nl_bc_link_set() argument
500 return tipc_bc_link_set_queue_limits(net, win); in tipc_nl_bc_link_set()
503 int tipc_bcast_init(struct net *net) in tipc_bcast_init() argument
505 struct tipc_net *tn = tipc_net(net); in tipc_bcast_init()
513 spin_lock_init(&tipc_net(net)->bclock); in tipc_bcast_init()
515 if (!tipc_link_bc_create(net, 0, 0, in tipc_bcast_init()
533 void tipc_bcast_reinit(struct net *net) in tipc_bcast_reinit() argument
535 struct tipc_bc_base *b = tipc_bc_base(net); in tipc_bcast_reinit()
537 msg_set_prevnode(b->link->pmsg, tipc_own_addr(net)); in tipc_bcast_reinit()
540 void tipc_bcast_stop(struct net *net) in tipc_bcast_stop() argument
542 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_bcast_stop()