aboutsummaryrefslogtreecommitdiffstats
path: root/fs/ocfs2/cluster
diff options
context:
space:
mode:
Diffstat (limited to 'fs/ocfs2/cluster')
-rw-r--r--fs/ocfs2/cluster/heartbeat.c17
-rw-r--r--fs/ocfs2/cluster/nodemanager.c45
2 files changed, 24 insertions, 38 deletions
diff --git a/fs/ocfs2/cluster/heartbeat.c b/fs/ocfs2/cluster/heartbeat.c
index 443d108211ab..f02ccb34604d 100644
--- a/fs/ocfs2/cluster/heartbeat.c
+++ b/fs/ocfs2/cluster/heartbeat.c
@@ -1489,28 +1489,25 @@ static struct o2hb_heartbeat_group *to_o2hb_heartbeat_group(struct config_group
1489 : NULL; 1489 : NULL;
1490} 1490}
1491 1491
1492static int o2hb_heartbeat_group_make_item(struct config_group *group, 1492static struct config_item *o2hb_heartbeat_group_make_item(struct config_group *group,
1493 const char *name, 1493 const char *name)
1494 struct config_item **new_item)
1495{ 1494{
1496 struct o2hb_region *reg = NULL; 1495 struct o2hb_region *reg = NULL;
1497 int ret = 0; 1496 struct config_item *ret = NULL;
1498 1497
1499 reg = kzalloc(sizeof(struct o2hb_region), GFP_KERNEL); 1498 reg = kzalloc(sizeof(struct o2hb_region), GFP_KERNEL);
1500 if (reg == NULL) { 1499 if (reg == NULL)
1501 ret = -ENOMEM; 1500 goto out; /* ENOMEM */
1502 goto out;
1503 }
1504 1501
1505 config_item_init_type_name(&reg->hr_item, name, &o2hb_region_type); 1502 config_item_init_type_name(&reg->hr_item, name, &o2hb_region_type);
1506 1503
1507 *new_item = &reg->hr_item; 1504 ret = &reg->hr_item;
1508 1505
1509 spin_lock(&o2hb_live_lock); 1506 spin_lock(&o2hb_live_lock);
1510 list_add_tail(&reg->hr_all_item, &o2hb_all_regions); 1507 list_add_tail(&reg->hr_all_item, &o2hb_all_regions);
1511 spin_unlock(&o2hb_live_lock); 1508 spin_unlock(&o2hb_live_lock);
1512out: 1509out:
1513 if (ret) 1510 if (ret == NULL)
1514 kfree(reg); 1511 kfree(reg);
1515 1512
1516 return ret; 1513 return ret;
diff --git a/fs/ocfs2/cluster/nodemanager.c b/fs/ocfs2/cluster/nodemanager.c
index b364b7052e46..cfdb08b484ed 100644
--- a/fs/ocfs2/cluster/nodemanager.c
+++ b/fs/ocfs2/cluster/nodemanager.c
@@ -644,32 +644,27 @@ out:
644 return ret; 644 return ret;
645} 645}
646 646
647static int o2nm_node_group_make_item(struct config_group *group, 647static struct config_item *o2nm_node_group_make_item(struct config_group *group,
648 const char *name, 648 const char *name)
649 struct config_item **new_item)
650{ 649{
651 struct o2nm_node *node = NULL; 650 struct o2nm_node *node = NULL;
652 int ret = 0; 651 struct config_item *ret = NULL;
653 652
654 if (strlen(name) > O2NM_MAX_NAME_LEN) { 653 if (strlen(name) > O2NM_MAX_NAME_LEN)
655 ret = -ENAMETOOLONG; 654 goto out; /* ENAMETOOLONG */
656 goto out;
657 }
658 655
659 node = kzalloc(sizeof(struct o2nm_node), GFP_KERNEL); 656 node = kzalloc(sizeof(struct o2nm_node), GFP_KERNEL);
660 if (node == NULL) { 657 if (node == NULL)
661 ret = -ENOMEM; 658 goto out; /* ENOMEM */
662 goto out;
663 }
664 659
665 strcpy(node->nd_name, name); /* use item.ci_namebuf instead? */ 660 strcpy(node->nd_name, name); /* use item.ci_namebuf instead? */
666 config_item_init_type_name(&node->nd_item, name, &o2nm_node_type); 661 config_item_init_type_name(&node->nd_item, name, &o2nm_node_type);
667 spin_lock_init(&node->nd_lock); 662 spin_lock_init(&node->nd_lock);
668 663
669 *new_item = &node->nd_item; 664 ret = &node->nd_item;
670 665
671out: 666out:
672 if (ret) 667 if (ret == NULL)
673 kfree(node); 668 kfree(node);
674 669
675 return ret; 670 return ret;
@@ -756,31 +751,25 @@ static struct o2nm_cluster_group *to_o2nm_cluster_group(struct config_group *gro
756} 751}
757#endif 752#endif
758 753
759static int o2nm_cluster_group_make_group(struct config_group *group, 754static struct config_group *o2nm_cluster_group_make_group(struct config_group *group,
760 const char *name, 755 const char *name)
761 struct config_group **new_group)
762{ 756{
763 struct o2nm_cluster *cluster = NULL; 757 struct o2nm_cluster *cluster = NULL;
764 struct o2nm_node_group *ns = NULL; 758 struct o2nm_node_group *ns = NULL;
765 struct config_group *o2hb_group = NULL; 759 struct config_group *o2hb_group = NULL, *ret = NULL;
766 void *defs = NULL; 760 void *defs = NULL;
767 int ret = 0;
768 761
769 /* this runs under the parent dir's i_mutex; there can be only 762 /* this runs under the parent dir's i_mutex; there can be only
770 * one caller in here at a time */ 763 * one caller in here at a time */
771 if (o2nm_single_cluster) { 764 if (o2nm_single_cluster)
772 ret = -ENOSPC; 765 goto out; /* ENOSPC */
773 goto out;
774 }
775 766
776 cluster = kzalloc(sizeof(struct o2nm_cluster), GFP_KERNEL); 767 cluster = kzalloc(sizeof(struct o2nm_cluster), GFP_KERNEL);
777 ns = kzalloc(sizeof(struct o2nm_node_group), GFP_KERNEL); 768 ns = kzalloc(sizeof(struct o2nm_node_group), GFP_KERNEL);
778 defs = kcalloc(3, sizeof(struct config_group *), GFP_KERNEL); 769 defs = kcalloc(3, sizeof(struct config_group *), GFP_KERNEL);
779 o2hb_group = o2hb_alloc_hb_set(); 770 o2hb_group = o2hb_alloc_hb_set();
780 if (cluster == NULL || ns == NULL || o2hb_group == NULL || defs == NULL) { 771 if (cluster == NULL || ns == NULL || o2hb_group == NULL || defs == NULL)
781 ret = -ENOMEM;
782 goto out; 772 goto out;
783 }
784 773
785 config_group_init_type_name(&cluster->cl_group, name, 774 config_group_init_type_name(&cluster->cl_group, name,
786 &o2nm_cluster_type); 775 &o2nm_cluster_type);
@@ -797,11 +786,11 @@ static int o2nm_cluster_group_make_group(struct config_group *group,
797 cluster->cl_idle_timeout_ms = O2NET_IDLE_TIMEOUT_MS_DEFAULT; 786 cluster->cl_idle_timeout_ms = O2NET_IDLE_TIMEOUT_MS_DEFAULT;
798 cluster->cl_keepalive_delay_ms = O2NET_KEEPALIVE_DELAY_MS_DEFAULT; 787 cluster->cl_keepalive_delay_ms = O2NET_KEEPALIVE_DELAY_MS_DEFAULT;
799 788
800 *new_group = &cluster->cl_group; 789 ret = &cluster->cl_group;
801 o2nm_single_cluster = cluster; 790 o2nm_single_cluster = cluster;
802 791
803out: 792out:
804 if (ret) { 793 if (ret == NULL) {
805 kfree(cluster); 794 kfree(cluster);
806 kfree(ns); 795 kfree(ns);
807 o2hb_free_hb_set(o2hb_group); 796 o2hb_free_hb_set(o2hb_group);