diff options
Diffstat (limited to 'fs/ocfs2/cluster/nodemanager.c')
-rw-r--r-- | fs/ocfs2/cluster/nodemanager.c | 49 |
1 files changed, 16 insertions, 33 deletions
diff --git a/fs/ocfs2/cluster/nodemanager.c b/fs/ocfs2/cluster/nodemanager.c index b364b7052e46..816a3f61330c 100644 --- a/fs/ocfs2/cluster/nodemanager.c +++ b/fs/ocfs2/cluster/nodemanager.c | |||
@@ -644,35 +644,23 @@ out: | |||
644 | return ret; | 644 | return ret; |
645 | } | 645 | } |
646 | 646 | ||
647 | static int o2nm_node_group_make_item(struct config_group *group, | 647 | static 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; | ||
653 | 651 | ||
654 | if (strlen(name) > O2NM_MAX_NAME_LEN) { | 652 | if (strlen(name) > O2NM_MAX_NAME_LEN) |
655 | ret = -ENAMETOOLONG; | 653 | return ERR_PTR(-ENAMETOOLONG); |
656 | goto out; | ||
657 | } | ||
658 | 654 | ||
659 | node = kzalloc(sizeof(struct o2nm_node), GFP_KERNEL); | 655 | node = kzalloc(sizeof(struct o2nm_node), GFP_KERNEL); |
660 | if (node == NULL) { | 656 | if (node == NULL) |
661 | ret = -ENOMEM; | 657 | return ERR_PTR(-ENOMEM); |
662 | goto out; | ||
663 | } | ||
664 | 658 | ||
665 | strcpy(node->nd_name, name); /* use item.ci_namebuf instead? */ | 659 | strcpy(node->nd_name, name); /* use item.ci_namebuf instead? */ |
666 | config_item_init_type_name(&node->nd_item, name, &o2nm_node_type); | 660 | config_item_init_type_name(&node->nd_item, name, &o2nm_node_type); |
667 | spin_lock_init(&node->nd_lock); | 661 | spin_lock_init(&node->nd_lock); |
668 | 662 | ||
669 | *new_item = &node->nd_item; | 663 | return &node->nd_item; |
670 | |||
671 | out: | ||
672 | if (ret) | ||
673 | kfree(node); | ||
674 | |||
675 | return ret; | ||
676 | } | 664 | } |
677 | 665 | ||
678 | static void o2nm_node_group_drop_item(struct config_group *group, | 666 | static void o2nm_node_group_drop_item(struct config_group *group, |
@@ -756,31 +744,25 @@ static struct o2nm_cluster_group *to_o2nm_cluster_group(struct config_group *gro | |||
756 | } | 744 | } |
757 | #endif | 745 | #endif |
758 | 746 | ||
759 | static int o2nm_cluster_group_make_group(struct config_group *group, | 747 | static struct config_group *o2nm_cluster_group_make_group(struct config_group *group, |
760 | const char *name, | 748 | const char *name) |
761 | struct config_group **new_group) | ||
762 | { | 749 | { |
763 | struct o2nm_cluster *cluster = NULL; | 750 | struct o2nm_cluster *cluster = NULL; |
764 | struct o2nm_node_group *ns = NULL; | 751 | struct o2nm_node_group *ns = NULL; |
765 | struct config_group *o2hb_group = NULL; | 752 | struct config_group *o2hb_group = NULL, *ret = NULL; |
766 | void *defs = NULL; | 753 | void *defs = NULL; |
767 | int ret = 0; | ||
768 | 754 | ||
769 | /* this runs under the parent dir's i_mutex; there can be only | 755 | /* this runs under the parent dir's i_mutex; there can be only |
770 | * one caller in here at a time */ | 756 | * one caller in here at a time */ |
771 | if (o2nm_single_cluster) { | 757 | if (o2nm_single_cluster) |
772 | ret = -ENOSPC; | 758 | return ERR_PTR(-ENOSPC); |
773 | goto out; | ||
774 | } | ||
775 | 759 | ||
776 | cluster = kzalloc(sizeof(struct o2nm_cluster), GFP_KERNEL); | 760 | cluster = kzalloc(sizeof(struct o2nm_cluster), GFP_KERNEL); |
777 | ns = kzalloc(sizeof(struct o2nm_node_group), GFP_KERNEL); | 761 | ns = kzalloc(sizeof(struct o2nm_node_group), GFP_KERNEL); |
778 | defs = kcalloc(3, sizeof(struct config_group *), GFP_KERNEL); | 762 | defs = kcalloc(3, sizeof(struct config_group *), GFP_KERNEL); |
779 | o2hb_group = o2hb_alloc_hb_set(); | 763 | o2hb_group = o2hb_alloc_hb_set(); |
780 | if (cluster == NULL || ns == NULL || o2hb_group == NULL || defs == NULL) { | 764 | if (cluster == NULL || ns == NULL || o2hb_group == NULL || defs == NULL) |
781 | ret = -ENOMEM; | ||
782 | goto out; | 765 | goto out; |
783 | } | ||
784 | 766 | ||
785 | config_group_init_type_name(&cluster->cl_group, name, | 767 | config_group_init_type_name(&cluster->cl_group, name, |
786 | &o2nm_cluster_type); | 768 | &o2nm_cluster_type); |
@@ -797,15 +779,16 @@ static int o2nm_cluster_group_make_group(struct config_group *group, | |||
797 | cluster->cl_idle_timeout_ms = O2NET_IDLE_TIMEOUT_MS_DEFAULT; | 779 | cluster->cl_idle_timeout_ms = O2NET_IDLE_TIMEOUT_MS_DEFAULT; |
798 | cluster->cl_keepalive_delay_ms = O2NET_KEEPALIVE_DELAY_MS_DEFAULT; | 780 | cluster->cl_keepalive_delay_ms = O2NET_KEEPALIVE_DELAY_MS_DEFAULT; |
799 | 781 | ||
800 | *new_group = &cluster->cl_group; | 782 | ret = &cluster->cl_group; |
801 | o2nm_single_cluster = cluster; | 783 | o2nm_single_cluster = cluster; |
802 | 784 | ||
803 | out: | 785 | out: |
804 | if (ret) { | 786 | if (ret == NULL) { |
805 | kfree(cluster); | 787 | kfree(cluster); |
806 | kfree(ns); | 788 | kfree(ns); |
807 | o2hb_free_hb_set(o2hb_group); | 789 | o2hb_free_hb_set(o2hb_group); |
808 | kfree(defs); | 790 | kfree(defs); |
791 | ret = ERR_PTR(-ENOMEM); | ||
809 | } | 792 | } |
810 | 793 | ||
811 | return ret; | 794 | return ret; |