Lines Matching full:cluster
34 * cluster active at a time. Changing this will require trickling
35 * cluster references throughout where nodes are looked up */
65 struct o2nm_cluster *cluster = o2nm_single_cluster; in o2nm_configured_node_map() local
67 BUG_ON(bytes < (sizeof(cluster->cl_nodes_bitmap))); in o2nm_configured_node_map()
69 if (cluster == NULL) in o2nm_configured_node_map()
72 read_lock(&cluster->cl_nodes_lock); in o2nm_configured_node_map()
73 memcpy(map, cluster->cl_nodes_bitmap, sizeof(cluster->cl_nodes_bitmap)); in o2nm_configured_node_map()
74 read_unlock(&cluster->cl_nodes_lock); in o2nm_configured_node_map()
80 static struct o2nm_node *o2nm_node_ip_tree_lookup(struct o2nm_cluster *cluster, in o2nm_node_ip_tree_lookup() argument
85 struct rb_node **p = &cluster->cl_node_ip_tree.rb_node; in o2nm_node_ip_tree_lookup()
118 struct o2nm_cluster *cluster = o2nm_single_cluster; in o2nm_get_node_by_ip() local
120 if (cluster == NULL) in o2nm_get_node_by_ip()
123 read_lock(&cluster->cl_nodes_lock); in o2nm_get_node_by_ip()
124 node = o2nm_node_ip_tree_lookup(cluster, addr, NULL, NULL); in o2nm_get_node_by_ip()
127 read_unlock(&cluster->cl_nodes_lock); in o2nm_get_node_by_ip()
203 struct o2nm_cluster *cluster; in o2nm_node_num_store() local
224 cluster = to_o2nm_cluster_from_node(node); in o2nm_node_num_store()
225 if (!cluster) { in o2nm_node_num_store()
230 write_lock(&cluster->cl_nodes_lock); in o2nm_node_num_store()
231 if (cluster->cl_nodes[tmp]) in o2nm_node_num_store()
237 cluster->cl_nodes[tmp] = node; in o2nm_node_num_store()
239 set_bit(tmp, cluster->cl_nodes_bitmap); in o2nm_node_num_store()
241 write_unlock(&cluster->cl_nodes_lock); in o2nm_node_num_store()
287 struct o2nm_cluster *cluster; in o2nm_node_ipv4_address_store() local
305 cluster = to_o2nm_cluster_from_node(node); in o2nm_node_ipv4_address_store()
306 if (!cluster) { in o2nm_node_ipv4_address_store()
312 write_lock(&cluster->cl_nodes_lock); in o2nm_node_ipv4_address_store()
313 if (o2nm_node_ip_tree_lookup(cluster, ipv4_addr, &p, &parent)) in o2nm_node_ipv4_address_store()
320 rb_insert_color(&node->nd_ip_node, &cluster->cl_node_ip_tree); in o2nm_node_ipv4_address_store()
322 write_unlock(&cluster->cl_nodes_lock); in o2nm_node_ipv4_address_store()
342 struct o2nm_cluster *cluster; in o2nm_node_local_store() local
361 cluster = to_o2nm_cluster_from_node(node); in o2nm_node_local_store()
362 if (!cluster) { in o2nm_node_local_store()
369 if (tmp && tmp == cluster->cl_has_local && in o2nm_node_local_store()
370 cluster->cl_local_node != node->nd_num) { in o2nm_node_local_store()
376 if (tmp && !cluster->cl_has_local) { in o2nm_node_local_store()
382 if (!tmp && cluster->cl_has_local && in o2nm_node_local_store()
383 cluster->cl_local_node == node->nd_num) { in o2nm_node_local_store()
385 cluster->cl_local_node = O2NM_INVALID_NODE_NUM; in o2nm_node_local_store()
390 cluster->cl_has_local = tmp; in o2nm_node_local_store()
391 cluster->cl_local_node = node->nd_num; in o2nm_node_local_store()
469 struct o2nm_cluster *cluster = to_o2nm_cluster(item); in o2nm_cluster_idle_timeout_ms_store() local
476 if (cluster->cl_idle_timeout_ms != val in o2nm_cluster_idle_timeout_ms_store()
484 } else if (val <= cluster->cl_keepalive_delay_ms) { in o2nm_cluster_idle_timeout_ms_store()
489 cluster->cl_idle_timeout_ms = val; in o2nm_cluster_idle_timeout_ms_store()
506 struct o2nm_cluster *cluster = to_o2nm_cluster(item); in o2nm_cluster_keepalive_delay_ms_store() local
513 if (cluster->cl_keepalive_delay_ms != val in o2nm_cluster_keepalive_delay_ms_store()
521 } else if (val >= cluster->cl_idle_timeout_ms) { in o2nm_cluster_keepalive_delay_ms_store()
526 cluster->cl_keepalive_delay_ms = val; in o2nm_cluster_keepalive_delay_ms_store()
550 struct o2nm_cluster *cluster = to_o2nm_cluster(item); in o2nm_cluster_fence_method_show() local
553 if (cluster) in o2nm_cluster_fence_method_show()
555 o2nm_fence_method_desc[cluster->cl_fence_method]); in o2nm_cluster_fence_method_show()
622 struct o2nm_cluster *cluster = to_o2nm_cluster(group->cg_item.ci_parent); in o2nm_node_group_drop_item() local
624 if (cluster->cl_nodes[node->nd_num] == node) { in o2nm_node_group_drop_item()
627 if (cluster->cl_has_local && in o2nm_node_group_drop_item()
628 (cluster->cl_local_node == node->nd_num)) { in o2nm_node_group_drop_item()
629 cluster->cl_has_local = 0; in o2nm_node_group_drop_item()
630 cluster->cl_local_node = O2NM_INVALID_NODE_NUM; in o2nm_node_group_drop_item()
637 write_lock(&cluster->cl_nodes_lock); in o2nm_node_group_drop_item()
641 rb_erase(&node->nd_ip_node, &cluster->cl_node_ip_tree); in o2nm_node_group_drop_item()
644 if (cluster->cl_nodes[node->nd_num] == node) { in o2nm_node_group_drop_item()
645 cluster->cl_nodes[node->nd_num] = NULL; in o2nm_node_group_drop_item()
646 clear_bit(node->nd_num, cluster->cl_nodes_bitmap); in o2nm_node_group_drop_item()
648 write_unlock(&cluster->cl_nodes_lock); in o2nm_node_group_drop_item()
666 /* cluster */
670 struct o2nm_cluster *cluster = to_o2nm_cluster(item); in o2nm_cluster_release() local
672 kfree(cluster); in o2nm_cluster_release()
685 /* cluster set */
704 struct o2nm_cluster *cluster = NULL; in o2nm_cluster_group_make_group() local
713 cluster = kzalloc(sizeof(struct o2nm_cluster), GFP_KERNEL); in o2nm_cluster_group_make_group()
716 if (cluster == NULL || ns == NULL || o2hb_group == NULL) in o2nm_cluster_group_make_group()
719 config_group_init_type_name(&cluster->cl_group, name, in o2nm_cluster_group_make_group()
721 configfs_add_default_group(&ns->ns_group, &cluster->cl_group); in o2nm_cluster_group_make_group()
725 configfs_add_default_group(o2hb_group, &cluster->cl_group); in o2nm_cluster_group_make_group()
727 rwlock_init(&cluster->cl_nodes_lock); in o2nm_cluster_group_make_group()
728 cluster->cl_node_ip_tree = RB_ROOT; in o2nm_cluster_group_make_group()
729 cluster->cl_reconnect_delay_ms = O2NET_RECONNECT_DELAY_MS_DEFAULT; in o2nm_cluster_group_make_group()
730 cluster->cl_idle_timeout_ms = O2NET_IDLE_TIMEOUT_MS_DEFAULT; in o2nm_cluster_group_make_group()
731 cluster->cl_keepalive_delay_ms = O2NET_KEEPALIVE_DELAY_MS_DEFAULT; in o2nm_cluster_group_make_group()
732 cluster->cl_fence_method = O2NM_FENCE_RESET; in o2nm_cluster_group_make_group()
734 ret = &cluster->cl_group; in o2nm_cluster_group_make_group()
735 o2nm_single_cluster = cluster; in o2nm_cluster_group_make_group()
739 kfree(cluster); in o2nm_cluster_group_make_group()
750 struct o2nm_cluster *cluster = to_o2nm_cluster(item); in o2nm_cluster_group_drop_item() local
752 BUG_ON(o2nm_single_cluster != cluster); in o2nm_cluster_group_drop_item()
755 configfs_remove_default_groups(&cluster->cl_group); in o2nm_cluster_group_drop_item()
773 .ci_namebuf = "cluster",
882 MODULE_DESCRIPTION("OCFS2 cluster management");