Lines Matching refs:node
51 u32 node; member
91 struct tipc_node *node; in named_cluster_distribute() local
95 list_for_each_entry_rcu(node, &tn->node_list, list) { in named_cluster_distribute()
96 dnode = node->addr; in named_cluster_distribute()
99 if (!tipc_node_active_links(node)) in named_cluster_distribute()
232 struct tipc_node *node; in tipc_publ_subscribe() local
237 node = tipc_node_find(net, addr); in tipc_publ_subscribe()
238 if (!node) { in tipc_publ_subscribe()
244 tipc_node_lock(node); in tipc_publ_subscribe()
245 list_add_tail(&publ->nodesub_list, &node->publ_list); in tipc_publ_subscribe()
246 tipc_node_unlock(node); in tipc_publ_subscribe()
247 tipc_node_put(node); in tipc_publ_subscribe()
253 struct tipc_node *node; in tipc_publ_unsubscribe() local
255 node = tipc_node_find(net, addr); in tipc_publ_unsubscribe()
256 if (!node) in tipc_publ_unsubscribe()
259 tipc_node_lock(node); in tipc_publ_unsubscribe()
261 tipc_node_unlock(node); in tipc_publ_unsubscribe()
262 tipc_node_put(node); in tipc_publ_unsubscribe()
278 publ->node, publ->ref, publ->key); in tipc_publ_purge()
286 publ->type, publ->lower, publ->node, publ->ref, in tipc_publ_purge()
309 u32 node, u32 dtype) in tipc_update_nametbl() argument
317 TIPC_CLUSTER_SCOPE, node, in tipc_update_nametbl()
320 tipc_publ_subscribe(net, publ, node); in tipc_update_nametbl()
326 node, ntohl(i->ref), in tipc_update_nametbl()
329 tipc_publ_unsubscribe(net, publ, node); in tipc_update_nametbl()
343 static void tipc_named_add_backlog(struct distr_item *i, u32 type, u32 node) in tipc_named_add_backlog() argument
352 e->node = node; in tipc_named_add_backlog()
370 if (!tipc_update_nametbl(net, &e->i, e->node, e->dtype)) in tipc_named_process_backlog()
373 tipc_addr_string_fill(addr, e->node); in tipc_named_process_backlog()
394 u32 node; in tipc_named_rcv() local
404 node = msg_orignode(msg); in tipc_named_rcv()
406 if (!tipc_update_nametbl(net, item, node, mtype)) in tipc_named_rcv()
407 tipc_named_add_backlog(item, mtype, node); in tipc_named_rcv()
434 publ->node = tn->own_addr; in tipc_named_reinit()