Lines Matching refs:net
71 static struct sk_buff *named_prepare_buf(struct net *net, u32 type, u32 size, in named_prepare_buf() argument
74 struct tipc_net *tn = net_generic(net, tipc_net_id); in named_prepare_buf()
87 void named_cluster_distribute(struct net *net, struct sk_buff *skb) in named_cluster_distribute() argument
89 struct tipc_net *tn = net_generic(net, tipc_net_id); in named_cluster_distribute()
97 if (in_own_node(net, dnode)) in named_cluster_distribute()
105 tipc_link_xmit_skb(net, oskb, dnode, dnode); in named_cluster_distribute()
115 struct sk_buff *tipc_named_publish(struct net *net, struct publication *publ) in tipc_named_publish() argument
117 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_named_publish()
127 buf = named_prepare_buf(net, PUBLICATION, ITEM_SIZE, 0); in tipc_named_publish()
141 struct sk_buff *tipc_named_withdraw(struct net *net, struct publication *publ) in tipc_named_withdraw() argument
151 buf = named_prepare_buf(net, WITHDRAWAL, ITEM_SIZE, 0); in tipc_named_withdraw()
168 static void named_distribute(struct net *net, struct sk_buff_head *list, in named_distribute() argument
174 uint msg_dsz = (tipc_node_get_mtu(net, dnode, 0) / ITEM_SIZE) * in named_distribute()
181 skb = named_prepare_buf(net, PUBLICATION, msg_rem, in named_distribute()
212 void tipc_named_node_up(struct net *net, u32 dnode) in tipc_named_node_up() argument
214 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_named_node_up()
220 named_distribute(net, &head, dnode, in tipc_named_node_up()
222 named_distribute(net, &head, dnode, in tipc_named_node_up()
226 tipc_link_xmit(net, &head, dnode, dnode); in tipc_named_node_up()
229 static void tipc_publ_subscribe(struct net *net, struct publication *publ, in tipc_publ_subscribe() argument
234 if (in_own_node(net, addr)) in tipc_publ_subscribe()
237 node = tipc_node_find(net, addr); in tipc_publ_subscribe()
250 static void tipc_publ_unsubscribe(struct net *net, struct publication *publ, in tipc_publ_unsubscribe() argument
255 node = tipc_node_find(net, addr); in tipc_publ_unsubscribe()
271 static void tipc_publ_purge(struct net *net, struct publication *publ, u32 addr) in tipc_publ_purge() argument
273 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_publ_purge()
277 p = tipc_nametbl_remove_publ(net, publ->type, publ->lower, in tipc_publ_purge()
280 tipc_publ_unsubscribe(net, p, addr); in tipc_publ_purge()
293 void tipc_publ_notify(struct net *net, struct list_head *nsub_list, u32 addr) in tipc_publ_notify() argument
298 tipc_publ_purge(net, publ, addr); in tipc_publ_notify()
308 static bool tipc_update_nametbl(struct net *net, struct distr_item *i, in tipc_update_nametbl() argument
314 publ = tipc_nametbl_insert_publ(net, ntohl(i->type), in tipc_update_nametbl()
320 tipc_publ_subscribe(net, publ, node); in tipc_update_nametbl()
324 publ = tipc_nametbl_remove_publ(net, ntohl(i->type), in tipc_update_nametbl()
329 tipc_publ_unsubscribe(net, publ, node); in tipc_update_nametbl()
362 void tipc_named_process_backlog(struct net *net) in tipc_named_process_backlog() argument
370 if (!tipc_update_nametbl(net, &e->i, e->node, e->dtype)) in tipc_named_process_backlog()
388 void tipc_named_rcv(struct net *net, struct sk_buff_head *inputq) in tipc_named_rcv() argument
390 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_named_rcv()
406 if (!tipc_update_nametbl(net, item, node, mtype)) in tipc_named_rcv()
411 tipc_named_process_backlog(net); in tipc_named_rcv()
423 void tipc_named_reinit(struct net *net) in tipc_named_reinit() argument
425 struct tipc_net *tn = net_generic(net, tipc_net_id); in tipc_named_reinit()