10c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel/* -*- mode: c; c-basic-offset: 8; -*- 20c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * vim: noexpandtab sw=8 ts=8 sts=0: 30c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * 40c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * Copyright (C) 2004, 2005 Oracle. All rights reserved. 50c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * 60c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * This program is free software; you can redistribute it and/or 70c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * modify it under the terms of the GNU General Public 80c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * License as published by the Free Software Foundation; either 90c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * version 2 of the License, or (at your option) any later version. 100c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * 110c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * This program is distributed in the hope that it will be useful, 120c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * but WITHOUT ANY WARRANTY; without even the implied warranty of 130c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 140c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * General Public License for more details. 150c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * 160c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * You should have received a copy of the GNU General Public 170c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * License along with this program; if not, write to the 180c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * Free Software Foundation, Inc., 59 Temple Place - Suite 330, 190c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * Boston, MA 021110-1307, USA. 200c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel */ 210c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 225a0e3ad6af8660be21ca98a971cd00f331318c05Tejun Heo#include <linux/slab.h> 230c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel#include <linux/kernel.h> 240c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel#include <linux/module.h> 250c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel#include <linux/configfs.h> 260c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 270c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel#include "tcp.h" 280c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel#include "nodemanager.h" 290c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel#include "heartbeat.h" 300c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel#include "masklog.h" 310c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel#include "sys.h" 320c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 330c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel/* for now we operate under the assertion that there can be only one 340c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * cluster active at a time. Changing this will require trickling 350c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * cluster references throughout where nodes are looked up */ 36296b75ed6a3b35f613961cefe4962ce1cf586d77Andrew Beekhofstruct o2nm_cluster *o2nm_single_cluster = NULL; 370c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 38f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushranchar *o2nm_fence_method_desc[O2NM_FENCE_METHODS] = { 39f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran "reset", /* O2NM_FENCE_RESET */ 40f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran "panic", /* O2NM_FENCE_PANIC */ 41f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran}; 420c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 430c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstruct o2nm_node *o2nm_get_node_by_num(u8 node_num) 440c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 450c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_node *node = NULL; 460c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 470c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (node_num >= O2NM_MAX_NODES || o2nm_single_cluster == NULL) 480c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel goto out; 490c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 500c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel read_lock(&o2nm_single_cluster->cl_nodes_lock); 510c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel node = o2nm_single_cluster->cl_nodes[node_num]; 520c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (node) 530c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel config_item_get(&node->nd_item); 540c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel read_unlock(&o2nm_single_cluster->cl_nodes_lock); 550c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelout: 560c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return node; 570c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 580c83ed8eeb28a045cdbd0b216679938aa9e665feKurt HackelEXPORT_SYMBOL_GPL(o2nm_get_node_by_num); 590c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 600c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelint o2nm_configured_node_map(unsigned long *map, unsigned bytes) 610c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 620c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_cluster *cluster = o2nm_single_cluster; 630c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 640c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel BUG_ON(bytes < (sizeof(cluster->cl_nodes_bitmap))); 650c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 660c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (cluster == NULL) 670c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -EINVAL; 680c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 690c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel read_lock(&cluster->cl_nodes_lock); 700c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel memcpy(map, cluster->cl_nodes_bitmap, sizeof(cluster->cl_nodes_bitmap)); 710c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel read_unlock(&cluster->cl_nodes_lock); 720c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 730c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return 0; 740c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 750c83ed8eeb28a045cdbd0b216679938aa9e665feKurt HackelEXPORT_SYMBOL_GPL(o2nm_configured_node_map); 760c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 770c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct o2nm_node *o2nm_node_ip_tree_lookup(struct o2nm_cluster *cluster, 780c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel __be32 ip_needle, 790c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct rb_node ***ret_p, 800c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct rb_node **ret_parent) 810c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 820c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct rb_node **p = &cluster->cl_node_ip_tree.rb_node; 830c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct rb_node *parent = NULL; 840c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_node *node, *ret = NULL; 850c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 860c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel while (*p) { 8779cd22d3ac921b9209bf813c7e75e6b69e74896cAkinobu Mita int cmp; 8879cd22d3ac921b9209bf813c7e75e6b69e74896cAkinobu Mita 890c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel parent = *p; 900c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel node = rb_entry(parent, struct o2nm_node, nd_ip_node); 910c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 9279cd22d3ac921b9209bf813c7e75e6b69e74896cAkinobu Mita cmp = memcmp(&ip_needle, &node->nd_ipv4_address, 9379cd22d3ac921b9209bf813c7e75e6b69e74896cAkinobu Mita sizeof(ip_needle)); 9479cd22d3ac921b9209bf813c7e75e6b69e74896cAkinobu Mita if (cmp < 0) 950c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel p = &(*p)->rb_left; 9679cd22d3ac921b9209bf813c7e75e6b69e74896cAkinobu Mita else if (cmp > 0) 970c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel p = &(*p)->rb_right; 980c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel else { 990c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ret = node; 1000c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel break; 1010c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 1020c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 1030c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1040c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (ret_p != NULL) 1050c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel *ret_p = p; 1060c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (ret_parent != NULL) 1070c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel *ret_parent = parent; 1080c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1090c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return ret; 1100c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 1110c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1120c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstruct o2nm_node *o2nm_get_node_by_ip(__be32 addr) 1130c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 1140c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_node *node = NULL; 1150c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_cluster *cluster = o2nm_single_cluster; 1160c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1170c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (cluster == NULL) 1180c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel goto out; 1190c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1200c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel read_lock(&cluster->cl_nodes_lock); 1210c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel node = o2nm_node_ip_tree_lookup(cluster, addr, NULL, NULL); 1220c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (node) 1230c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel config_item_get(&node->nd_item); 1240c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel read_unlock(&cluster->cl_nodes_lock); 1250c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1260c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelout: 1270c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return node; 1280c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 1290c83ed8eeb28a045cdbd0b216679938aa9e665feKurt HackelEXPORT_SYMBOL_GPL(o2nm_get_node_by_ip); 1300c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1310c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelvoid o2nm_node_put(struct o2nm_node *node) 1320c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 1330c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel config_item_put(&node->nd_item); 1340c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 1350c83ed8eeb28a045cdbd0b216679938aa9e665feKurt HackelEXPORT_SYMBOL_GPL(o2nm_node_put); 1360c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1370c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelvoid o2nm_node_get(struct o2nm_node *node) 1380c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 1390c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel config_item_get(&node->nd_item); 1400c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 1410c83ed8eeb28a045cdbd0b216679938aa9e665feKurt HackelEXPORT_SYMBOL_GPL(o2nm_node_get); 1420c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1430c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelu8 o2nm_this_node(void) 1440c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 1450c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel u8 node_num = O2NM_MAX_NODES; 1460c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1470c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (o2nm_single_cluster && o2nm_single_cluster->cl_has_local) 1480c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel node_num = o2nm_single_cluster->cl_local_node; 1490c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1500c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return node_num; 1510c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 1520c83ed8eeb28a045cdbd0b216679938aa9e665feKurt HackelEXPORT_SYMBOL_GPL(o2nm_this_node); 1530c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1540c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel/* node configfs bits */ 1550c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1560c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct o2nm_cluster *to_o2nm_cluster(struct config_item *item) 1570c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 1580c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return item ? 1590c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel container_of(to_config_group(item), struct o2nm_cluster, 1600c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cl_group) 1610c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel : NULL; 1620c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 1630c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1640c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct o2nm_node *to_o2nm_node(struct config_item *item) 1650c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 1660c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return item ? container_of(item, struct o2nm_node, nd_item) : NULL; 1670c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 1680c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1690c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic void o2nm_node_release(struct config_item *item) 1700c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 1710c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_node *node = to_o2nm_node(item); 1720c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel kfree(node); 1730c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 1740c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1750c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic ssize_t o2nm_node_num_read(struct o2nm_node *node, char *page) 1760c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 1770c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return sprintf(page, "%d\n", node->nd_num); 1780c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 1790c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1800c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct o2nm_cluster *to_o2nm_cluster_from_node(struct o2nm_node *node) 1810c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 1820c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel /* through the first node_set .parent 1830c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * mycluster/nodes/mynode == o2nm_cluster->o2nm_node_group->o2nm_node */ 1840c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return to_o2nm_cluster(node->nd_item.ci_parent->ci_parent); 1850c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 1860c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1870c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelenum { 1880c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel O2NM_NODE_ATTR_NUM = 0, 1890c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel O2NM_NODE_ATTR_PORT, 1900c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel O2NM_NODE_ATTR_ADDRESS, 1910c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel O2NM_NODE_ATTR_LOCAL, 1920c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 1930c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 1940c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic ssize_t o2nm_node_num_write(struct o2nm_node *node, const char *page, 1950c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel size_t count) 1960c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 1970c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_cluster *cluster = to_o2nm_cluster_from_node(node); 1980c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel unsigned long tmp; 1990c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel char *p = (char *)page; 2000c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2010c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel tmp = simple_strtoul(p, &p, 0); 2020c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (!p || (*p && (*p != '\n'))) 2030c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -EINVAL; 2040c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2050c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (tmp >= O2NM_MAX_NODES) 2060c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -ERANGE; 2070c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2080c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel /* once we're in the cl_nodes tree networking can look us up by 2090c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * node number and try to use our address and port attributes 2100c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * to connect to this node.. make sure that they've been set 2110c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * before writing the node attribute? */ 2120c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (!test_bit(O2NM_NODE_ATTR_ADDRESS, &node->nd_set_attributes) || 2130c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel !test_bit(O2NM_NODE_ATTR_PORT, &node->nd_set_attributes)) 2140c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -EINVAL; /* XXX */ 2150c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2160c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel write_lock(&cluster->cl_nodes_lock); 2170c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (cluster->cl_nodes[tmp]) 2180c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel p = NULL; 2190c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel else { 2200c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_nodes[tmp] = node; 2210c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel node->nd_num = tmp; 2220c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel set_bit(tmp, cluster->cl_nodes_bitmap); 2230c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 2240c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel write_unlock(&cluster->cl_nodes_lock); 2250c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (p == NULL) 2260c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -EEXIST; 2270c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2280c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return count; 2290c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 2300c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic ssize_t o2nm_node_ipv4_port_read(struct o2nm_node *node, char *page) 2310c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 2320c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return sprintf(page, "%u\n", ntohs(node->nd_ipv4_port)); 2330c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 2340c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2350c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic ssize_t o2nm_node_ipv4_port_write(struct o2nm_node *node, 2360c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel const char *page, size_t count) 2370c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 2380c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel unsigned long tmp; 2390c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel char *p = (char *)page; 2400c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2410c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel tmp = simple_strtoul(p, &p, 0); 2420c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (!p || (*p && (*p != '\n'))) 2430c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -EINVAL; 2440c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2450c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (tmp == 0) 2460c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -EINVAL; 2470c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (tmp >= (u16)-1) 2480c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -ERANGE; 2490c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2500c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel node->nd_ipv4_port = htons(tmp); 2510c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2520c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return count; 2530c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 2540c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2550c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic ssize_t o2nm_node_ipv4_address_read(struct o2nm_node *node, char *page) 2560c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 257be859405487324ed548f1ba11dc949b8230ab991Harvey Harrison return sprintf(page, "%pI4\n", &node->nd_ipv4_address); 2580c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 2590c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2600c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic ssize_t o2nm_node_ipv4_address_write(struct o2nm_node *node, 2610c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel const char *page, 2620c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel size_t count) 2630c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 2640c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_cluster *cluster = to_o2nm_cluster_from_node(node); 2650c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel int ret, i; 2660c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct rb_node **p, *parent; 2670c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel unsigned int octets[4]; 2680c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel __be32 ipv4_addr = 0; 2690c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2700c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ret = sscanf(page, "%3u.%3u.%3u.%3u", &octets[3], &octets[2], 2710c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel &octets[1], &octets[0]); 2720c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (ret != 4) 2730c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -EINVAL; 2740c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2750c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel for (i = 0; i < ARRAY_SIZE(octets); i++) { 2760c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (octets[i] > 255) 2770c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -ERANGE; 2780c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel be32_add_cpu(&ipv4_addr, octets[i] << (i * 8)); 2790c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 2800c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2810c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ret = 0; 2820c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel write_lock(&cluster->cl_nodes_lock); 2830c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (o2nm_node_ip_tree_lookup(cluster, ipv4_addr, &p, &parent)) 2840c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ret = -EEXIST; 2850c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel else { 2860c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel rb_link_node(&node->nd_ip_node, parent, p); 2870c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel rb_insert_color(&node->nd_ip_node, &cluster->cl_node_ip_tree); 2880c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 2890c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel write_unlock(&cluster->cl_nodes_lock); 2900c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (ret) 2910c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return ret; 2920c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2930c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel memcpy(&node->nd_ipv4_address, &ipv4_addr, sizeof(ipv4_addr)); 2940c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2950c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return count; 2960c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 2970c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 2980c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic ssize_t o2nm_node_local_read(struct o2nm_node *node, char *page) 2990c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 3000c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return sprintf(page, "%d\n", node->nd_local); 3010c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 3020c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3030c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic ssize_t o2nm_node_local_write(struct o2nm_node *node, const char *page, 3040c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel size_t count) 3050c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 3060c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_cluster *cluster = to_o2nm_cluster_from_node(node); 3070c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel unsigned long tmp; 3080c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel char *p = (char *)page; 3090c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ssize_t ret; 3100c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3110c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel tmp = simple_strtoul(p, &p, 0); 3120c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (!p || (*p && (*p != '\n'))) 3130c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -EINVAL; 3140c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3150c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel tmp = !!tmp; /* boolean of whether this node wants to be local */ 3160c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3170c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel /* setting local turns on networking rx for now so we require having 3180c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * set everything else first */ 3190c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (!test_bit(O2NM_NODE_ATTR_ADDRESS, &node->nd_set_attributes) || 3200c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel !test_bit(O2NM_NODE_ATTR_NUM, &node->nd_set_attributes) || 3210c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel !test_bit(O2NM_NODE_ATTR_PORT, &node->nd_set_attributes)) 3220c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -EINVAL; /* XXX */ 3230c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3240c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel /* the only failure case is trying to set a new local node 3250c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * when a different one is already set */ 3260c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (tmp && tmp == cluster->cl_has_local && 3270c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_local_node != node->nd_num) 3280c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -EBUSY; 3290c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3300c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel /* bring up the rx thread if we're setting the new local node. */ 3310c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (tmp && !cluster->cl_has_local) { 3320c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ret = o2net_start_listening(node); 3330c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (ret) 3340c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return ret; 3350c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 3360c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3370c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (!tmp && cluster->cl_has_local && 3380c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_local_node == node->nd_num) { 3390c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel o2net_stop_listening(node); 3400c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_local_node = O2NM_INVALID_NODE_NUM; 3410c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 3420c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3430c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel node->nd_local = tmp; 3440c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (node->nd_local) { 3450c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_has_local = tmp; 3460c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_local_node = node->nd_num; 3470c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 3480c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3490c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return count; 3500c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 3510c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3520c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstruct o2nm_node_attribute { 3530c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct configfs_attribute attr; 3540c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ssize_t (*show)(struct o2nm_node *, char *); 3550c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ssize_t (*store)(struct o2nm_node *, const char *, size_t); 3560c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 3570c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3580c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct o2nm_node_attribute o2nm_node_attr_num = { 3590c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .attr = { .ca_owner = THIS_MODULE, 3600c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ca_name = "num", 3610c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ca_mode = S_IRUGO | S_IWUSR }, 3620c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .show = o2nm_node_num_read, 3630c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .store = o2nm_node_num_write, 3640c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 3650c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3660c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct o2nm_node_attribute o2nm_node_attr_ipv4_port = { 3670c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .attr = { .ca_owner = THIS_MODULE, 3680c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ca_name = "ipv4_port", 3690c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ca_mode = S_IRUGO | S_IWUSR }, 3700c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .show = o2nm_node_ipv4_port_read, 3710c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .store = o2nm_node_ipv4_port_write, 3720c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 3730c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3740c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct o2nm_node_attribute o2nm_node_attr_ipv4_address = { 3750c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .attr = { .ca_owner = THIS_MODULE, 3760c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ca_name = "ipv4_address", 3770c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ca_mode = S_IRUGO | S_IWUSR }, 3780c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .show = o2nm_node_ipv4_address_read, 3790c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .store = o2nm_node_ipv4_address_write, 3800c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 3810c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3820c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct o2nm_node_attribute o2nm_node_attr_local = { 3830c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .attr = { .ca_owner = THIS_MODULE, 3840c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ca_name = "local", 3850c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ca_mode = S_IRUGO | S_IWUSR }, 3860c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .show = o2nm_node_local_read, 3870c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .store = o2nm_node_local_write, 3880c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 3890c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3900c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct configfs_attribute *o2nm_node_attrs[] = { 3910c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel [O2NM_NODE_ATTR_NUM] = &o2nm_node_attr_num.attr, 3920c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel [O2NM_NODE_ATTR_PORT] = &o2nm_node_attr_ipv4_port.attr, 3930c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel [O2NM_NODE_ATTR_ADDRESS] = &o2nm_node_attr_ipv4_address.attr, 3940c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel [O2NM_NODE_ATTR_LOCAL] = &o2nm_node_attr_local.attr, 3950c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel NULL, 3960c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 3970c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 3980c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic int o2nm_attr_index(struct configfs_attribute *attr) 3990c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 4000c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel int i; 4010c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel for (i = 0; i < ARRAY_SIZE(o2nm_node_attrs); i++) { 4020c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (attr == o2nm_node_attrs[i]) 4030c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return i; 4040c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 4050c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel BUG(); 4060c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return 0; 4070c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 4080c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 4090c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic ssize_t o2nm_node_show(struct config_item *item, 4100c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct configfs_attribute *attr, 4110c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel char *page) 4120c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 4130c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_node *node = to_o2nm_node(item); 4140c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_node_attribute *o2nm_node_attr = 4150c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel container_of(attr, struct o2nm_node_attribute, attr); 4160c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ssize_t ret = 0; 4170c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 4180c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (o2nm_node_attr->show) 4190c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ret = o2nm_node_attr->show(node, page); 4200c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return ret; 4210c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 4220c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 4230c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic ssize_t o2nm_node_store(struct config_item *item, 4240c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct configfs_attribute *attr, 4250c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel const char *page, size_t count) 4260c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 4270c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_node *node = to_o2nm_node(item); 4280c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_node_attribute *o2nm_node_attr = 4290c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel container_of(attr, struct o2nm_node_attribute, attr); 4300c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ssize_t ret; 4310c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel int attr_index = o2nm_attr_index(attr); 4320c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 4330c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (o2nm_node_attr->store == NULL) { 4340c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ret = -EINVAL; 4350c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel goto out; 4360c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 4370c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 4380c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (test_bit(attr_index, &node->nd_set_attributes)) 4390c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return -EBUSY; 4400c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 4410c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ret = o2nm_node_attr->store(node, page, count); 4420c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (ret < count) 4430c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel goto out; 4440c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 4450c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel set_bit(attr_index, &node->nd_set_attributes); 4460c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelout: 4470c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return ret; 4480c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 4490c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 4500c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct configfs_item_operations o2nm_node_item_ops = { 4510c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .release = o2nm_node_release, 4520c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .show_attribute = o2nm_node_show, 4530c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .store_attribute = o2nm_node_store, 4540c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 4550c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 4560c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct config_item_type o2nm_node_type = { 4570c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ct_item_ops = &o2nm_node_item_ops, 4580c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ct_attrs = o2nm_node_attrs, 4590c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ct_owner = THIS_MODULE, 4600c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 4610c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 4620c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel/* node set */ 4630c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 4640c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstruct o2nm_node_group { 4650c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct config_group ns_group; 4660c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel /* some stuff? */ 4670c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 4680c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 4690c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel#if 0 4700c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct o2nm_node_group *to_o2nm_node_group(struct config_group *group) 4710c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 4720c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return group ? 4730c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel container_of(group, struct o2nm_node_group, ns_group) 4740c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel : NULL; 4750c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 4760c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel#endif 4770c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 478b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystruct o2nm_cluster_attribute { 479b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney struct configfs_attribute attr; 480b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney ssize_t (*show)(struct o2nm_cluster *, char *); 481b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney ssize_t (*store)(struct o2nm_cluster *, const char *, size_t); 482b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney}; 483b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 484b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystatic ssize_t o2nm_cluster_attr_write(const char *page, ssize_t count, 485b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney unsigned int *val) 486b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney{ 487b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney unsigned long tmp; 488b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney char *p = (char *)page; 489b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 490b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney tmp = simple_strtoul(p, &p, 0); 491b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney if (!p || (*p && (*p != '\n'))) 492b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney return -EINVAL; 493b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 494b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney if (tmp == 0) 495b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney return -EINVAL; 496b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney if (tmp >= (u32)-1) 497b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney return -ERANGE; 498b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 499b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney *val = tmp; 500b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 501b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney return count; 502b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney} 503b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 504b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystatic ssize_t o2nm_cluster_attr_idle_timeout_ms_read( 505b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney struct o2nm_cluster *cluster, char *page) 506b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney{ 507b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney return sprintf(page, "%u\n", cluster->cl_idle_timeout_ms); 508b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney} 509b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 510b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystatic ssize_t o2nm_cluster_attr_idle_timeout_ms_write( 511b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney struct o2nm_cluster *cluster, const char *page, size_t count) 512b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney{ 513b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney ssize_t ret; 514b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney unsigned int val; 515b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 516b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney ret = o2nm_cluster_attr_write(page, count, &val); 517b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 518b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney if (ret > 0) { 519828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof if (cluster->cl_idle_timeout_ms != val 520828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof && o2net_num_connected_peers()) { 521828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof mlog(ML_NOTICE, 522828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof "o2net: cannot change idle timeout after " 523828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof "the first peer has agreed to it." 524828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof " %d connected peers\n", 525828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof o2net_num_connected_peers()); 526828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof ret = -EINVAL; 527828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof } else if (val <= cluster->cl_keepalive_delay_ms) { 528b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney mlog(ML_NOTICE, "o2net: idle timeout must be larger " 529b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney "than keepalive delay\n"); 530828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof ret = -EINVAL; 531828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof } else { 532828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof cluster->cl_idle_timeout_ms = val; 533b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney } 534b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney } 535b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 536b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney return ret; 537b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney} 538b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 539b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystatic ssize_t o2nm_cluster_attr_keepalive_delay_ms_read( 540b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney struct o2nm_cluster *cluster, char *page) 541b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney{ 542b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney return sprintf(page, "%u\n", cluster->cl_keepalive_delay_ms); 543b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney} 544b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 545b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystatic ssize_t o2nm_cluster_attr_keepalive_delay_ms_write( 546b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney struct o2nm_cluster *cluster, const char *page, size_t count) 547b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney{ 548b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney ssize_t ret; 549b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney unsigned int val; 550b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 551b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney ret = o2nm_cluster_attr_write(page, count, &val); 552b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 553b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney if (ret > 0) { 554828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof if (cluster->cl_keepalive_delay_ms != val 555828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof && o2net_num_connected_peers()) { 556828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof mlog(ML_NOTICE, 557828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof "o2net: cannot change keepalive delay after" 558828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof " the first peer has agreed to it." 559828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof " %d connected peers\n", 560828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof o2net_num_connected_peers()); 561828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof ret = -EINVAL; 562828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof } else if (val >= cluster->cl_idle_timeout_ms) { 563b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney mlog(ML_NOTICE, "o2net: keepalive delay must be " 564b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney "smaller than idle timeout\n"); 565828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof ret = -EINVAL; 566828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof } else { 567828ae6afbef03bfe107a4a8cc38798419d6a2765Andrew Beekhof cluster->cl_keepalive_delay_ms = val; 568b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney } 569b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney } 570b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 571b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney return ret; 572b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney} 573b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 574b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystatic ssize_t o2nm_cluster_attr_reconnect_delay_ms_read( 575b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney struct o2nm_cluster *cluster, char *page) 576b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney{ 577b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney return sprintf(page, "%u\n", cluster->cl_reconnect_delay_ms); 578b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney} 579b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 580b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystatic ssize_t o2nm_cluster_attr_reconnect_delay_ms_write( 581b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney struct o2nm_cluster *cluster, const char *page, size_t count) 582b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney{ 583b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney return o2nm_cluster_attr_write(page, count, 584b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney &cluster->cl_reconnect_delay_ms); 585b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney} 586f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran 587f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushranstatic ssize_t o2nm_cluster_attr_fence_method_read( 588f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran struct o2nm_cluster *cluster, char *page) 589f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran{ 590f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran ssize_t ret = 0; 591f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran 592f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran if (cluster) 593f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran ret = sprintf(page, "%s\n", 594f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran o2nm_fence_method_desc[cluster->cl_fence_method]); 595f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran return ret; 596f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran} 597f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran 598f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushranstatic ssize_t o2nm_cluster_attr_fence_method_write( 599f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran struct o2nm_cluster *cluster, const char *page, size_t count) 600f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran{ 601f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran unsigned int i; 602f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran 603f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran if (page[count - 1] != '\n') 604f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran goto bail; 605f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran 606f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran for (i = 0; i < O2NM_FENCE_METHODS; ++i) { 607f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran if (count != strlen(o2nm_fence_method_desc[i]) + 1) 608f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran continue; 609f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran if (strncasecmp(page, o2nm_fence_method_desc[i], count - 1)) 610f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran continue; 611f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran if (cluster->cl_fence_method != i) { 612f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran printk(KERN_INFO "ocfs2: Changing fence method to %s\n", 613f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran o2nm_fence_method_desc[i]); 614f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran cluster->cl_fence_method = i; 615f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran } 616f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran return count; 617f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran } 618f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran 619f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushranbail: 620f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran return -EINVAL; 621f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran} 622f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran 623b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystatic struct o2nm_cluster_attribute o2nm_cluster_attr_idle_timeout_ms = { 624b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .attr = { .ca_owner = THIS_MODULE, 625b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .ca_name = "idle_timeout_ms", 626b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .ca_mode = S_IRUGO | S_IWUSR }, 627b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .show = o2nm_cluster_attr_idle_timeout_ms_read, 628b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .store = o2nm_cluster_attr_idle_timeout_ms_write, 629b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney}; 630b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 631b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystatic struct o2nm_cluster_attribute o2nm_cluster_attr_keepalive_delay_ms = { 632b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .attr = { .ca_owner = THIS_MODULE, 633b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .ca_name = "keepalive_delay_ms", 634b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .ca_mode = S_IRUGO | S_IWUSR }, 635b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .show = o2nm_cluster_attr_keepalive_delay_ms_read, 636b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .store = o2nm_cluster_attr_keepalive_delay_ms_write, 637b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney}; 638b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 639b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystatic struct o2nm_cluster_attribute o2nm_cluster_attr_reconnect_delay_ms = { 640b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .attr = { .ca_owner = THIS_MODULE, 641b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .ca_name = "reconnect_delay_ms", 642b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .ca_mode = S_IRUGO | S_IWUSR }, 643b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .show = o2nm_cluster_attr_reconnect_delay_ms_read, 644b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .store = o2nm_cluster_attr_reconnect_delay_ms_write, 645b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney}; 646b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 647f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushranstatic struct o2nm_cluster_attribute o2nm_cluster_attr_fence_method = { 648f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran .attr = { .ca_owner = THIS_MODULE, 649f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran .ca_name = "fence_method", 650f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran .ca_mode = S_IRUGO | S_IWUSR }, 651f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran .show = o2nm_cluster_attr_fence_method_read, 652f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran .store = o2nm_cluster_attr_fence_method_write, 653f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran}; 654f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran 655b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystatic struct configfs_attribute *o2nm_cluster_attrs[] = { 656b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney &o2nm_cluster_attr_idle_timeout_ms.attr, 657b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney &o2nm_cluster_attr_keepalive_delay_ms.attr, 658b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney &o2nm_cluster_attr_reconnect_delay_ms.attr, 659f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran &o2nm_cluster_attr_fence_method.attr, 660b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney NULL, 661b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney}; 662b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystatic ssize_t o2nm_cluster_show(struct config_item *item, 663b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney struct configfs_attribute *attr, 664b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney char *page) 665b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney{ 666b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney struct o2nm_cluster *cluster = to_o2nm_cluster(item); 667b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney struct o2nm_cluster_attribute *o2nm_cluster_attr = 668b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney container_of(attr, struct o2nm_cluster_attribute, attr); 669b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney ssize_t ret = 0; 670b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 671b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney if (o2nm_cluster_attr->show) 672b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney ret = o2nm_cluster_attr->show(cluster, page); 673b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney return ret; 674b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney} 675b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 676b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneystatic ssize_t o2nm_cluster_store(struct config_item *item, 677b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney struct configfs_attribute *attr, 678b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney const char *page, size_t count) 679b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney{ 680b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney struct o2nm_cluster *cluster = to_o2nm_cluster(item); 681b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney struct o2nm_cluster_attribute *o2nm_cluster_attr = 682b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney container_of(attr, struct o2nm_cluster_attribute, attr); 683b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney ssize_t ret; 684b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 685b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney if (o2nm_cluster_attr->store == NULL) { 686b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney ret = -EINVAL; 687b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney goto out; 688b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney } 689b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 690b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney ret = o2nm_cluster_attr->store(cluster, page, count); 691b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney if (ret < count) 692b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney goto out; 693b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoneyout: 694b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney return ret; 695b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney} 696b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney 697f89ab8619e5320cc9c2576f5f8dcbaf6c0ba3950Joel Beckerstatic struct config_item *o2nm_node_group_make_item(struct config_group *group, 698f89ab8619e5320cc9c2576f5f8dcbaf6c0ba3950Joel Becker const char *name) 6990c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 7000c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_node *node = NULL; 7010c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 702f89ab8619e5320cc9c2576f5f8dcbaf6c0ba3950Joel Becker if (strlen(name) > O2NM_MAX_NAME_LEN) 703a6795e9ebb420d87af43789174689af0d66d1d35Joel Becker return ERR_PTR(-ENAMETOOLONG); 7040c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 705cd86128088554d64fea1679191509f00e6353c5bRobert P. J. Day node = kzalloc(sizeof(struct o2nm_node), GFP_KERNEL); 706f89ab8619e5320cc9c2576f5f8dcbaf6c0ba3950Joel Becker if (node == NULL) 707a6795e9ebb420d87af43789174689af0d66d1d35Joel Becker return ERR_PTR(-ENOMEM); 7080c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7090c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel strcpy(node->nd_name, name); /* use item.ci_namebuf instead? */ 7100c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel config_item_init_type_name(&node->nd_item, name, &o2nm_node_type); 7110c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel spin_lock_init(&node->nd_lock); 7120c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 71339a298563e0619b1b6e2e0974e58801de780621cSunil Mushran mlog(ML_CLUSTER, "o2nm: Registering node %s\n", name); 71439a298563e0619b1b6e2e0974e58801de780621cSunil Mushran 715a6795e9ebb420d87af43789174689af0d66d1d35Joel Becker return &node->nd_item; 7160c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 7170c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7180c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic void o2nm_node_group_drop_item(struct config_group *group, 7190c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct config_item *item) 7200c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 7210c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_node *node = to_o2nm_node(item); 7220c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_cluster *cluster = to_o2nm_cluster(group->cg_item.ci_parent); 7230c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7240c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel o2net_disconnect_node(node); 7250c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7260c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (cluster->cl_has_local && 7270c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel (cluster->cl_local_node == node->nd_num)) { 7280c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_has_local = 0; 7290c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_local_node = O2NM_INVALID_NODE_NUM; 7300c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel o2net_stop_listening(node); 7310c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 7320c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7330c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel /* XXX call into net to stop this node from trading messages */ 7340c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7350c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel write_lock(&cluster->cl_nodes_lock); 7360c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7370c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel /* XXX sloppy */ 7380c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (node->nd_ipv4_address) 7390c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel rb_erase(&node->nd_ip_node, &cluster->cl_node_ip_tree); 7400c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7410c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel /* nd_num might be 0 if the node number hasn't been set.. */ 7420c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (cluster->cl_nodes[node->nd_num] == node) { 7430c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_nodes[node->nd_num] = NULL; 7440c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel clear_bit(node->nd_num, cluster->cl_nodes_bitmap); 7450c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 7460c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel write_unlock(&cluster->cl_nodes_lock); 7470c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 74839a298563e0619b1b6e2e0974e58801de780621cSunil Mushran mlog(ML_CLUSTER, "o2nm: Unregistered node %s\n", 74939a298563e0619b1b6e2e0974e58801de780621cSunil Mushran config_item_name(&node->nd_item)); 75039a298563e0619b1b6e2e0974e58801de780621cSunil Mushran 7510c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel config_item_put(item); 7520c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 7530c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7540c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct configfs_group_operations o2nm_node_group_group_ops = { 7550c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .make_item = o2nm_node_group_make_item, 7560c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .drop_item = o2nm_node_group_drop_item, 7570c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 7580c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7590c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct config_item_type o2nm_node_group_type = { 7600c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ct_group_ops = &o2nm_node_group_group_ops, 7610c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ct_owner = THIS_MODULE, 7620c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 7630c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7640c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel/* cluster */ 7650c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7660c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic void o2nm_cluster_release(struct config_item *item) 7670c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 7680c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_cluster *cluster = to_o2nm_cluster(item); 7690c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7700c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel kfree(cluster->cl_group.default_groups); 7710c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel kfree(cluster); 7720c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 7730c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7740c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct configfs_item_operations o2nm_cluster_item_ops = { 7750c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .release = o2nm_cluster_release, 776b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .show_attribute = o2nm_cluster_show, 777b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .store_attribute = o2nm_cluster_store, 7780c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 7790c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7800c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct config_item_type o2nm_cluster_type = { 7810c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ct_item_ops = &o2nm_cluster_item_ops, 782b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney .ct_attrs = o2nm_cluster_attrs, 7830c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ct_owner = THIS_MODULE, 7840c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 7850c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7860c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel/* cluster set */ 7870c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7880c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstruct o2nm_cluster_group { 7890c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct configfs_subsystem cs_subsys; 7900c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel /* some stuff? */ 7910c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 7920c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 7930c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel#if 0 7940c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct o2nm_cluster_group *to_o2nm_cluster_group(struct config_group *group) 7950c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 7960c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return group ? 7970c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel container_of(to_configfs_subsystem(group), struct o2nm_cluster_group, cs_subsys) 7980c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel : NULL; 7990c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 8000c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel#endif 8010c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 802f89ab8619e5320cc9c2576f5f8dcbaf6c0ba3950Joel Beckerstatic struct config_group *o2nm_cluster_group_make_group(struct config_group *group, 803f89ab8619e5320cc9c2576f5f8dcbaf6c0ba3950Joel Becker const char *name) 8040c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 8050c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_cluster *cluster = NULL; 8060c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_node_group *ns = NULL; 807f89ab8619e5320cc9c2576f5f8dcbaf6c0ba3950Joel Becker struct config_group *o2hb_group = NULL, *ret = NULL; 8080c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel void *defs = NULL; 8090c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 8101b1dcc1b57a49136f118a0f16367256ff9994a69Jes Sorensen /* this runs under the parent dir's i_mutex; there can be only 8110c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel * one caller in here at a time */ 812f89ab8619e5320cc9c2576f5f8dcbaf6c0ba3950Joel Becker if (o2nm_single_cluster) 813a6795e9ebb420d87af43789174689af0d66d1d35Joel Becker return ERR_PTR(-ENOSPC); 8140c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 815cd86128088554d64fea1679191509f00e6353c5bRobert P. J. Day cluster = kzalloc(sizeof(struct o2nm_cluster), GFP_KERNEL); 816cd86128088554d64fea1679191509f00e6353c5bRobert P. J. Day ns = kzalloc(sizeof(struct o2nm_node_group), GFP_KERNEL); 8170c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel defs = kcalloc(3, sizeof(struct config_group *), GFP_KERNEL); 8180c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel o2hb_group = o2hb_alloc_hb_set(); 819f89ab8619e5320cc9c2576f5f8dcbaf6c0ba3950Joel Becker if (cluster == NULL || ns == NULL || o2hb_group == NULL || defs == NULL) 8200c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel goto out; 8210c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 8220c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel config_group_init_type_name(&cluster->cl_group, name, 8230c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel &o2nm_cluster_type); 8240c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel config_group_init_type_name(&ns->ns_group, "node", 8250c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel &o2nm_node_group_type); 8260c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 8270c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_group.default_groups = defs; 8280c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_group.default_groups[0] = &ns->ns_group; 8290c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_group.default_groups[1] = o2hb_group; 8300c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_group.default_groups[2] = NULL; 8310c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel rwlock_init(&cluster->cl_nodes_lock); 8320c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_node_ip_tree = RB_ROOT; 833b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney cluster->cl_reconnect_delay_ms = O2NET_RECONNECT_DELAY_MS_DEFAULT; 834b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney cluster->cl_idle_timeout_ms = O2NET_IDLE_TIMEOUT_MS_DEFAULT; 835b5dd80304da482d77b2320e1a01a189e656b9770Jeff Mahoney cluster->cl_keepalive_delay_ms = O2NET_KEEPALIVE_DELAY_MS_DEFAULT; 836f6656d26d17b2598f43cd41be088853fa2a03397Sunil Mushran cluster->cl_fence_method = O2NM_FENCE_RESET; 8370c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 838f89ab8619e5320cc9c2576f5f8dcbaf6c0ba3950Joel Becker ret = &cluster->cl_group; 8390c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel o2nm_single_cluster = cluster; 8400c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 8410c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelout: 842f89ab8619e5320cc9c2576f5f8dcbaf6c0ba3950Joel Becker if (ret == NULL) { 8430c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel kfree(cluster); 8440c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel kfree(ns); 8450c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel o2hb_free_hb_set(o2hb_group); 8460c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel kfree(defs); 847a6795e9ebb420d87af43789174689af0d66d1d35Joel Becker ret = ERR_PTR(-ENOMEM); 8480c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 8490c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 8500c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return ret; 8510c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 8520c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 8530c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic void o2nm_cluster_group_drop_item(struct config_group *group, struct config_item *item) 8540c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 8550c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct o2nm_cluster *cluster = to_o2nm_cluster(item); 8560c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel int i; 8570c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel struct config_item *killme; 8580c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 8590c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel BUG_ON(o2nm_single_cluster != cluster); 8600c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel o2nm_single_cluster = NULL; 8610c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 8620c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel for (i = 0; cluster->cl_group.default_groups[i]; i++) { 8630c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel killme = &cluster->cl_group.default_groups[i]->cg_item; 8640c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel cluster->cl_group.default_groups[i] = NULL; 8650c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel config_item_put(killme); 8660c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 8670c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 8680c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel config_item_put(item); 8690c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 8700c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 8710c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct configfs_group_operations o2nm_cluster_group_group_ops = { 8720c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .make_group = o2nm_cluster_group_make_group, 8730c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .drop_item = o2nm_cluster_group_drop_item, 8740c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 8750c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 8760c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct config_item_type o2nm_cluster_group_type = { 8770c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ct_group_ops = &o2nm_cluster_group_group_ops, 8780c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ct_owner = THIS_MODULE, 8790c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 8800c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 8810c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic struct o2nm_cluster_group o2nm_cluster_group = { 8820c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .cs_subsys = { 8830c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .su_group = { 8840c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .cg_item = { 8850c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ci_namebuf = "cluster", 8860c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel .ci_type = &o2nm_cluster_group_type, 8870c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel }, 8880c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel }, 8890c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel }, 8900c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel}; 8910c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 89214829422be6d6b6721f61b1e749acf5a9cb664d8Joel Beckerint o2nm_depend_item(struct config_item *item) 89314829422be6d6b6721f61b1e749acf5a9cb664d8Joel Becker{ 89414829422be6d6b6721f61b1e749acf5a9cb664d8Joel Becker return configfs_depend_item(&o2nm_cluster_group.cs_subsys, item); 89514829422be6d6b6721f61b1e749acf5a9cb664d8Joel Becker} 89614829422be6d6b6721f61b1e749acf5a9cb664d8Joel Becker 89714829422be6d6b6721f61b1e749acf5a9cb664d8Joel Beckervoid o2nm_undepend_item(struct config_item *item) 89814829422be6d6b6721f61b1e749acf5a9cb664d8Joel Becker{ 89914829422be6d6b6721f61b1e749acf5a9cb664d8Joel Becker configfs_undepend_item(&o2nm_cluster_group.cs_subsys, item); 90014829422be6d6b6721f61b1e749acf5a9cb664d8Joel Becker} 90114829422be6d6b6721f61b1e749acf5a9cb664d8Joel Becker 90216c6a4f24de2933b26477ad5dfb71f518220d641Joel Beckerint o2nm_depend_this_node(void) 90316c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker{ 90416c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker int ret = 0; 90516c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker struct o2nm_node *local_node; 90616c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker 90716c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker local_node = o2nm_get_node_by_num(o2nm_this_node()); 90816c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker if (!local_node) { 90916c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker ret = -EINVAL; 91016c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker goto out; 91116c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker } 91216c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker 91316c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker ret = o2nm_depend_item(&local_node->nd_item); 91416c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker o2nm_node_put(local_node); 91516c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker 91616c6a4f24de2933b26477ad5dfb71f518220d641Joel Beckerout: 91716c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker return ret; 91816c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker} 91916c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker 92016c6a4f24de2933b26477ad5dfb71f518220d641Joel Beckervoid o2nm_undepend_this_node(void) 92116c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker{ 92216c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker struct o2nm_node *local_node; 92316c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker 92416c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker local_node = o2nm_get_node_by_num(o2nm_this_node()); 92516c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker BUG_ON(!local_node); 92616c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker 92716c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker o2nm_undepend_item(&local_node->nd_item); 92816c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker o2nm_node_put(local_node); 92916c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker} 93016c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker 93116c6a4f24de2933b26477ad5dfb71f518220d641Joel Becker 9320c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic void __exit exit_o2nm(void) 9330c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 9340c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel /* XXX sync with hb callbacks and shut down hb? */ 9350c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel o2net_unregister_hb_callbacks(); 9360c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel configfs_unregister_subsystem(&o2nm_cluster_group.cs_subsys); 9370c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel o2cb_sys_shutdown(); 9380c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 9390c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel o2net_exit(); 94087d3d3f3931f3e0fca44fbb5c06ad45fc4dca9bcSunil Mushran o2hb_exit(); 9410c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 9420c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 9430c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelstatic int __init init_o2nm(void) 9440c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel{ 9450c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel int ret = -1; 9460c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 94787d3d3f3931f3e0fca44fbb5c06ad45fc4dca9bcSunil Mushran ret = o2hb_init(); 94887d3d3f3931f3e0fca44fbb5c06ad45fc4dca9bcSunil Mushran if (ret) 94987d3d3f3931f3e0fca44fbb5c06ad45fc4dca9bcSunil Mushran goto out; 9502309e9e040fe29469fb85a384636c455b62fe525Sunil Mushran 9512309e9e040fe29469fb85a384636c455b62fe525Sunil Mushran ret = o2net_init(); 9522309e9e040fe29469fb85a384636c455b62fe525Sunil Mushran if (ret) 95387d3d3f3931f3e0fca44fbb5c06ad45fc4dca9bcSunil Mushran goto out_o2hb; 9540c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 9550c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ret = o2net_register_hb_callbacks(); 9560c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (ret) 9573878f110f71a0971ff7acc15dd6db711b6ef37c6Joel Becker goto out_o2net; 9580c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 9590c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel config_group_init(&o2nm_cluster_group.cs_subsys.su_group); 960e6bd07aee739566803425acdbf5cdb29919164e1Joel Becker mutex_init(&o2nm_cluster_group.cs_subsys.su_mutex); 9610c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ret = configfs_register_subsystem(&o2nm_cluster_group.cs_subsys); 9620c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (ret) { 9630c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel printk(KERN_ERR "nodemanager: Registration returned %d\n", ret); 9640c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel goto out_callbacks; 9650c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel } 9660c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 9670c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel ret = o2cb_sys_init(); 9680c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel if (!ret) 9690c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel goto out; 9700c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 9710c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel configfs_unregister_subsystem(&o2nm_cluster_group.cs_subsys); 9720c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelout_callbacks: 9730c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel o2net_unregister_hb_callbacks(); 974895928b8380cc697ac56e9732cedf549c0a4f79cJeff Mahoneyout_o2net: 975895928b8380cc697ac56e9732cedf549c0a4f79cJeff Mahoney o2net_exit(); 97687d3d3f3931f3e0fca44fbb5c06ad45fc4dca9bcSunil Mushranout_o2hb: 97787d3d3f3931f3e0fca44fbb5c06ad45fc4dca9bcSunil Mushran o2hb_exit(); 9780c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelout: 9790c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel return ret; 9800c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel} 9810c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 9820c83ed8eeb28a045cdbd0b216679938aa9e665feKurt HackelMODULE_AUTHOR("Oracle"); 9830c83ed8eeb28a045cdbd0b216679938aa9e665feKurt HackelMODULE_LICENSE("GPL"); 984ff8fb335221e2c446b0d4cbea26be371fd2feb64Goldwyn RodriguesMODULE_DESCRIPTION("OCFS2 cluster management"); 9850c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackel 9860c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelmodule_init(init_o2nm) 9870c83ed8eeb28a045cdbd0b216679938aa9e665feKurt Hackelmodule_exit(exit_o2nm) 988