Lines Matching refs:node
61 unsigned int node; member
74 struct qrtr_node *node; in node_get() local
76 node = xa_load(&nodes, node_id); in node_get()
77 if (node) in node_get()
78 return node; in node_get()
81 node = kzalloc(sizeof(*node), GFP_KERNEL); in node_get()
82 if (!node) in node_get()
85 node->id = node_id; in node_get()
86 xa_init(&node->servers); in node_get()
88 if (xa_store(&nodes, node_id, node, GFP_KERNEL)) { in node_get()
89 kfree(node); in node_get()
93 return node; in node_get()
117 srv->node, srv->port); in service_announce_new()
126 pkt.server.node = cpu_to_le32(srv->node); in service_announce_new()
144 srv->node, srv->port); in service_announce_del()
153 pkt.server.node = cpu_to_le32(srv->node); in service_announce_del()
183 pkt.server.node = cpu_to_le32(srv->node); in lookup_notify()
198 struct qrtr_node *node; in announce_servers() local
202 node = node_get(qrtr_ns.local_node); in announce_servers()
203 if (!node) in announce_servers()
207 xa_for_each(&node->servers, index, srv) { in announce_servers()
227 struct qrtr_node *node; in server_add() local
238 srv->node = node_id; in server_add()
241 node = node_get(node_id); in server_add()
242 if (!node) in server_add()
246 old = xa_store(&node->servers, port, srv, GFP_KERNEL); in server_add()
258 srv->node, srv->port); in server_add()
267 static int server_del(struct qrtr_node *node, unsigned int port, bool bcast) in server_del() argument
273 srv = xa_load(&node->servers, port); in server_del()
277 xa_erase(&node->servers, port); in server_del()
280 if (srv->node == qrtr_ns.local_node && bcast) in server_del()
341 struct qrtr_node *node; in ctrl_cmd_bye() local
349 node = node_get(from->sq_node); in ctrl_cmd_bye()
350 if (!node) in ctrl_cmd_bye()
354 xa_for_each(&node->servers, index, srv) in ctrl_cmd_bye()
355 server_del(node, srv->port, true); in ctrl_cmd_bye()
364 pkt.client.node = cpu_to_le32(from->sq_node); in ctrl_cmd_bye()
368 sq.sq_node = srv->node; in ctrl_cmd_bye()
392 struct qrtr_node *node; in ctrl_cmd_del_client() local
426 node = node_get(node_id); in ctrl_cmd_del_client()
427 if (node) in ctrl_cmd_del_client()
428 server_del(node, port, false); in ctrl_cmd_del_client()
437 pkt.client.node = cpu_to_le32(node_id); in ctrl_cmd_del_client()
442 sq.sq_node = srv->node; in ctrl_cmd_del_client()
476 if (srv->node == qrtr_ns.local_node) { in ctrl_cmd_new_server()
502 struct qrtr_node *node; in ctrl_cmd_del_server() local
514 node = node_get(node_id); in ctrl_cmd_del_server()
515 if (!node) in ctrl_cmd_del_server()
518 server_del(node, port, true); in ctrl_cmd_del_server()
529 struct qrtr_node *node; in ctrl_cmd_new_lookup() local
550 xa_for_each(&nodes, node_idx, node) { in ctrl_cmd_new_lookup()
551 xa_for_each(&node->servers, srv_idx, srv) { in ctrl_cmd_new_lookup()
639 le32_to_cpu(pkt->client.node), in qrtr_ns_worker()
646 le32_to_cpu(pkt->server.node), in qrtr_ns_worker()
653 le32_to_cpu(pkt->server.node), in qrtr_ns_worker()