45 	struct o2nm_node *node = NULL;  in o2nm_get_node_by_num()  local
51 	node = o2nm_single_cluster->cl_nodes[node_num];  in o2nm_get_node_by_num()
52 	if (node)  in o2nm_get_node_by_num()
53 		config_item_get(&node->nd_item);  in o2nm_get_node_by_num()
56 	return node;  in o2nm_get_node_by_num()
84 	struct o2nm_node *node, *ret = NULL;  in o2nm_node_ip_tree_lookup()  local
90 		node = rb_entry(parent, struct o2nm_node, nd_ip_node);  in o2nm_node_ip_tree_lookup()
92 		cmp = memcmp(&ip_needle, &node->nd_ipv4_address,  in o2nm_node_ip_tree_lookup()
99 			ret = node;  in o2nm_node_ip_tree_lookup()
114 	struct o2nm_node *node = NULL;  in o2nm_get_node_by_ip()  local
121 	node = o2nm_node_ip_tree_lookup(cluster, addr, NULL, NULL);  in o2nm_get_node_by_ip()
122 	if (node)  in o2nm_get_node_by_ip()
123 		config_item_get(&node->nd_item);  in o2nm_get_node_by_ip()
127 	return node;  in o2nm_get_node_by_ip()
131 void o2nm_node_put(struct o2nm_node *node)  in o2nm_node_put()  argument
133 	config_item_put(&node->nd_item);  in o2nm_node_put()
137 void o2nm_node_get(struct o2nm_node *node)  in o2nm_node_get()  argument
139 	config_item_get(&node->nd_item);  in o2nm_node_get()
171 	struct o2nm_node *node = to_o2nm_node(item);  in o2nm_node_release()  local
172 	kfree(node);  in o2nm_node_release()
180 static struct o2nm_cluster *to_o2nm_cluster_from_node(struct o2nm_node *node)  in to_o2nm_cluster_from_node()  argument
184 	return to_o2nm_cluster(node->nd_item.ci_parent->ci_parent);  in to_o2nm_cluster_from_node()
196 	struct o2nm_node *node = to_o2nm_node(item);  in o2nm_node_num_store()  local
197 	struct o2nm_cluster *cluster = to_o2nm_cluster_from_node(node);  in o2nm_node_num_store()
213 	if (!test_bit(O2NM_NODE_ATTR_ADDRESS, &node->nd_set_attributes) ||  in o2nm_node_num_store()
214 	    !test_bit(O2NM_NODE_ATTR_PORT, &node->nd_set_attributes))  in o2nm_node_num_store()
221 			&node->nd_set_attributes))  in o2nm_node_num_store()
224 		cluster->cl_nodes[tmp] = node;  in o2nm_node_num_store()
225 		node->nd_num = tmp;  in o2nm_node_num_store()
242 	struct o2nm_node *node = to_o2nm_node(item);  in o2nm_node_ipv4_port_store()  local
255 	if (test_and_set_bit(O2NM_NODE_ATTR_PORT, &node->nd_set_attributes))  in o2nm_node_ipv4_port_store()
257 	node->nd_ipv4_port = htons(tmp);  in o2nm_node_ipv4_port_store()
271 	struct o2nm_node *node = to_o2nm_node(item);  in o2nm_node_ipv4_address_store()  local
272 	struct o2nm_cluster *cluster = to_o2nm_cluster_from_node(node);  in o2nm_node_ipv4_address_store()
294 			&node->nd_set_attributes))  in o2nm_node_ipv4_address_store()
297 		rb_link_node(&node->nd_ip_node, parent, p);  in o2nm_node_ipv4_address_store()
298 		rb_insert_color(&node->nd_ip_node, &cluster->cl_node_ip_tree);  in o2nm_node_ipv4_address_store()
304 	memcpy(&node->nd_ipv4_address, &ipv4_addr, sizeof(ipv4_addr));  in o2nm_node_ipv4_address_store()
317 	struct o2nm_node *node = to_o2nm_node(item);  in o2nm_node_local_store()  local
318 	struct o2nm_cluster *cluster = to_o2nm_cluster_from_node(node);  in o2nm_node_local_store()
331 	if (!test_bit(O2NM_NODE_ATTR_ADDRESS, &node->nd_set_attributes) ||  in o2nm_node_local_store()
332 	    !test_bit(O2NM_NODE_ATTR_NUM, &node->nd_set_attributes) ||  in o2nm_node_local_store()
333 	    !test_bit(O2NM_NODE_ATTR_PORT, &node->nd_set_attributes))  in o2nm_node_local_store()
339 	    cluster->cl_local_node != node->nd_num)  in o2nm_node_local_store()
344 		ret = o2net_start_listening(node);  in o2nm_node_local_store()
350 	    cluster->cl_local_node == node->nd_num) {  in o2nm_node_local_store()
351 		o2net_stop_listening(node);  in o2nm_node_local_store()
355 	node->nd_local = tmp;  in o2nm_node_local_store()
356 	if (node->nd_local) {  in o2nm_node_local_store()
358 		cluster->cl_local_node = node->nd_num;  in o2nm_node_local_store()
563 	struct o2nm_node *node = NULL;  in o2nm_node_group_make_item()  local
568 	node = kzalloc(sizeof(struct o2nm_node), GFP_KERNEL);  in o2nm_node_group_make_item()
569 	if (node == NULL)  in o2nm_node_group_make_item()
572 	strcpy(node->nd_name, name); /* use item.ci_namebuf instead? */  in o2nm_node_group_make_item()
573 	config_item_init_type_name(&node->nd_item, name, &o2nm_node_type);  in o2nm_node_group_make_item()
574 	spin_lock_init(&node->nd_lock);  in o2nm_node_group_make_item()
578 	return &node->nd_item;  in o2nm_node_group_make_item()
584 	struct o2nm_node *node = to_o2nm_node(item);  in o2nm_node_group_drop_item()  local
587 	o2net_disconnect_node(node);  in o2nm_node_group_drop_item()
590 	    (cluster->cl_local_node == node->nd_num)) {  in o2nm_node_group_drop_item()
593 		o2net_stop_listening(node);  in o2nm_node_group_drop_item()
601 	if (node->nd_ipv4_address)  in o2nm_node_group_drop_item()
602 		rb_erase(&node->nd_ip_node, &cluster->cl_node_ip_tree);  in o2nm_node_group_drop_item()
605 	if (cluster->cl_nodes[node->nd_num] == node) {  in o2nm_node_group_drop_item()
606 		cluster->cl_nodes[node->nd_num] = NULL;  in o2nm_node_group_drop_item()
607 		clear_bit(node->nd_num, cluster->cl_nodes_bitmap);  in o2nm_node_group_drop_item()
612 	     config_item_name(&node->nd_item));  in o2nm_node_group_drop_item()