Lines Matching refs:node
61 unsigned int node;
74 struct qrtr_node *node;
76 node = xa_load(&nodes, node_id);
77 if (node)
78 return node;
80 /* If node didn't exist, allocate and insert it to the tree */
81 node = kzalloc(sizeof(*node), GFP_KERNEL);
82 if (!node)
85 node->id = node_id;
86 xa_init(&node->servers);
88 if (xa_store(&nodes, node_id, node, GFP_KERNEL)) {
89 kfree(node);
93 return node;
117 srv->node, srv->port);
126 pkt.server.node = cpu_to_le32(srv->node);
144 srv->node, srv->port);
153 pkt.server.node = cpu_to_le32(srv->node);
183 pkt.server.node = cpu_to_le32(srv->node);
198 struct qrtr_node *node;
202 node = node_get(qrtr_ns.local_node);
203 if (!node)
206 /* Announce the list of servers registered in this node */
207 xa_for_each(&node->servers, index, srv) {
224 struct qrtr_node *node;
235 srv->node = node_id;
238 node = node_get(node_id);
239 if (!node)
243 old = xa_store(&node->servers, port, srv, GFP_KERNEL);
255 srv->node, srv->port);
264 static int server_del(struct qrtr_node *node, unsigned int port, bool bcast)
270 srv = xa_load(&node->servers, port);
274 xa_erase(&node->servers, port);
277 if (srv->node == qrtr_ns.local_node && bcast)
319 /* Announce the list of servers registered on the local node */
338 struct qrtr_node *node;
346 node = node_get(from->sq_node);
347 if (!node)
350 /* Advertise removal of this client to all servers of remote node */
351 xa_for_each(&node->servers, index, srv)
352 server_del(node, srv->port, true);
361 pkt.client.node = cpu_to_le32(from->sq_node);
365 sq.sq_node = srv->node;
389 struct qrtr_node *node;
423 node = node_get(node_id);
424 if (node)
425 server_del(node, port, false);
434 pkt.client.node = cpu_to_le32(node_id);
439 sq.sq_node = srv->node;
463 /* Ignore specified node and port for local servers */
473 if (srv->node == qrtr_ns.local_node) {
499 struct qrtr_node *node;
501 /* Ignore specified node and port for local servers*/
511 node = node_get(node_id);
512 if (!node)
515 server_del(node, port, true);
526 struct qrtr_node *node;
547 xa_for_each(&nodes, node_idx, node) {
548 xa_for_each(&node->servers, srv_idx, srv) {
636 le32_to_cpu(pkt->client.node),
643 le32_to_cpu(pkt->server.node),
650 le32_to_cpu(pkt->server.node),