@@ -65,8 +65,7 @@ def match_pattern_cluster_status(cluster_status, pattern)
65
65
Chef ::Application . fatal! ( '[rabbitmq_cluster] cluster_status should not be empty' )
66
66
end
67
67
match = cluster_status . match ( pattern )
68
- result = match && match [ 2 ]
69
- result
68
+ match && match [ 2 ]
70
69
end
71
70
72
71
# Get currently joined cluster name from result string of "rabbitmqctl cluster_status"
@@ -81,25 +80,26 @@ def current_cluster_name(cluster_status)
81
80
def running_nodes ( cluster_status )
82
81
pattern = '({running_nodes,\[\'*)(.*?)(\'*\]})'
83
82
match = match_pattern_cluster_status ( cluster_status , pattern )
84
- result = match && match . split ( ',' )
83
+ result = match && match . gsub! ( /'/ , '' ) . split ( ',' )
85
84
Chef ::Log . debug ( "[rabbitmq_cluster] running_nodes : #{ result } " )
86
- result
87
85
end
88
86
89
87
# Get disc nodes
90
88
def disc_nodes ( cluster_status )
91
89
pattern = '({disc,\[\'*)(.*?)(\'*\]})'
92
- result = match_pattern_cluster_status ( cluster_status , pattern )
90
+ match = match_pattern_cluster_status ( cluster_status , pattern )
91
+ result = match && match . gsub! ( /'/ , '' ) . split ( ',' )
93
92
Chef ::Log . debug ( "[rabbitmq_cluster] disc_nodes : #{ result } " )
94
- result . split ( ',' )
93
+ ! result . nil? ? result : [ ]
95
94
end
96
95
97
96
# Get ram nodes
98
97
def ram_nodes ( cluster_status )
99
98
pattern = '({ram,\[\'*)(.*?)(\'*\]})'
100
- result = match_pattern_cluster_status ( cluster_status , pattern )
99
+ match = match_pattern_cluster_status ( cluster_status , pattern )
100
+ result = match && match . gsub! ( /'/ , '' ) . split ( ',' )
101
101
Chef ::Log . debug ( "[rabbitmq_cluster] ram_nodes : #{ result } " )
102
- result . split ( ',' )
102
+ ! result . nil? ? result : [ ]
103
103
end
104
104
105
105
# Get node name
@@ -110,8 +110,7 @@ def node_name
110
110
cmd = get_shellout ( cmd )
111
111
cmd . run_command
112
112
cmd . error!
113
- result = cmd . stdout . chomp
114
- result . gsub! ( /'/ , '' )
113
+ result = cmd . stdout . chomp . gsub! ( /'/ , '' )
115
114
Chef ::Log . debug ( "[rabbitmq_cluster] node name : #{ result } " )
116
115
result
117
116
end
@@ -124,6 +123,7 @@ def current_cluster_node_type(node_name, cluster_status)
124
123
elsif ram_nodes ( cluster_status ) . include? ( node_name )
125
124
var_cluster_node_type = 'ram'
126
125
end
126
+ Chef ::Log . debug ( "[rabbitmq_cluster] current cluster node type : #{ var_cluster_node_type } " )
127
127
var_cluster_node_type
128
128
end
129
129
@@ -234,7 +234,7 @@ def change_cluster_node_type(cluster_node_type)
234
234
var_cluster_status = cluster_status
235
235
var_node_name = node_name
236
236
var_current_cluster_node_type = current_cluster_node_type ( var_node_name , var_cluster_status )
237
- var_cluster_node_type = parse_cluster_nodes_string ( new_resource . cluster_nodes ) . select { |node | node [ 'name' ] == var_node_name } . first [ 'type' ] # ~FC039
237
+ var_cluster_node_type = parse_cluster_nodes_string ( new_resource . cluster_nodes ) . each { |node | node [ 'name' ] == var_node_name } . first [ 'type' ] # ~FC039
238
238
239
239
if var_current_cluster_node_type == var_cluster_node_type
240
240
Chef ::Log . warn ( '[rabbitmq_cluster] Skip changing cluster node type : trying to change to same cluster node type' )
0 commit comments