Lines Matching refs:net
68 static struct sk_buff *named_prepare_buf(struct net *net, u32 type, u32 size, in named_prepare_buf() argument
71 struct tipc_net *tn = net_generic(net, tipc_net_id); in named_prepare_buf()
87 struct sk_buff *tipc_named_publish(struct net *net, struct publication *publ) in tipc_named_publish() argument
89 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_named_publish()
99 buf = named_prepare_buf(net, PUBLICATION, ITEM_SIZE, 0); in tipc_named_publish()
113 struct sk_buff *tipc_named_withdraw(struct net *net, struct publication *publ) in tipc_named_withdraw() argument
123 buf = named_prepare_buf(net, WITHDRAWAL, ITEM_SIZE, 0); in tipc_named_withdraw()
140 static void named_distribute(struct net *net, struct sk_buff_head *list, in named_distribute() argument
146 u32 msg_dsz = ((tipc_node_get_mtu(net, dnode, 0) - INT_H_SIZE) / in named_distribute()
153 skb = named_prepare_buf(net, PUBLICATION, msg_rem, in named_distribute()
185 void tipc_named_node_up(struct net *net, u32 dnode) in tipc_named_node_up() argument
187 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_named_node_up()
193 named_distribute(net, &head, dnode, in tipc_named_node_up()
195 named_distribute(net, &head, dnode, in tipc_named_node_up()
199 tipc_node_xmit(net, &head, dnode, 0); in tipc_named_node_up()
208 static void tipc_publ_purge(struct net *net, struct publication *publ, u32 addr) in tipc_publ_purge() argument
210 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_publ_purge()
214 p = tipc_nametbl_remove_publ(net, publ->type, publ->lower, in tipc_publ_purge()
217 tipc_node_unsubscribe(net, &p->nodesub_list, addr); in tipc_publ_purge()
234 static void tipc_dist_queue_purge(struct net *net, u32 addr) in tipc_dist_queue_purge() argument
236 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_dist_queue_purge()
249 void tipc_publ_notify(struct net *net, struct list_head *nsub_list, u32 addr) in tipc_publ_notify() argument
254 tipc_publ_purge(net, publ, addr); in tipc_publ_notify()
255 tipc_dist_queue_purge(net, addr); in tipc_publ_notify()
265 static bool tipc_update_nametbl(struct net *net, struct distr_item *i, in tipc_update_nametbl() argument
271 publ = tipc_nametbl_insert_publ(net, ntohl(i->type), in tipc_update_nametbl()
277 tipc_node_subscribe(net, &publ->nodesub_list, node); in tipc_update_nametbl()
281 publ = tipc_nametbl_remove_publ(net, ntohl(i->type), in tipc_update_nametbl()
286 tipc_node_unsubscribe(net, &publ->nodesub_list, node); in tipc_update_nametbl()
300 static void tipc_named_add_backlog(struct net *net, struct distr_item *i, in tipc_named_add_backlog() argument
304 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_named_add_backlog()
321 void tipc_named_process_backlog(struct net *net) in tipc_named_process_backlog() argument
324 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_named_process_backlog()
330 if (!tipc_update_nametbl(net, &e->i, e->node, e->dtype)) in tipc_named_process_backlog()
348 void tipc_named_rcv(struct net *net, struct sk_buff_head *inputq) in tipc_named_rcv() argument
350 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_named_rcv()
367 if (!tipc_update_nametbl(net, item, node, mtype)) in tipc_named_rcv()
368 tipc_named_add_backlog(net, item, mtype, node); in tipc_named_rcv()
372 tipc_named_process_backlog(net); in tipc_named_rcv()
384 void tipc_named_reinit(struct net *net) in tipc_named_reinit() argument
386 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_named_reinit()