File tree Expand file tree Collapse file tree 1 file changed +14
-8
lines changed Expand file tree Collapse file tree 1 file changed +14
-8
lines changed Original file line number Diff line number Diff line change @@ -66,13 +66,15 @@ def ==(other)
66
66
# @since 2.0.0
67
67
def add ( host )
68
68
address = Address . new ( host )
69
- if !addresses . include? ( address ) || direct_connection? ( address )
70
- log_debug ( [ "Adding #{ address . to_s } to the cluster." ] )
71
- addresses . push ( address )
72
- server = Server . new ( address , event_listeners ,
73
- options . merge ( slave_ok : @slave_ok ) )
74
- @servers . push ( server )
75
- server
69
+ if !addresses . include? ( address )
70
+ if addition_allowed? ( address )
71
+ log_debug ( [ "Adding #{ address . to_s } to the cluster." ] )
72
+ addresses . push ( address )
73
+ server = Server . new ( address , event_listeners ,
74
+ options . merge ( slave_ok : @slave_ok ) )
75
+ @servers . push ( server )
76
+ server
77
+ end
76
78
end
77
79
end
78
80
@@ -205,7 +207,11 @@ def self.create(client)
205
207
private
206
208
207
209
def direct_connection? ( address )
208
- @topology . single? && address . seed == @topology . seed
210
+ address . seed == @topology . seed
211
+ end
212
+
213
+ def addition_allowed? ( address )
214
+ !@topology . single? || direct_connection? ( address )
209
215
end
210
216
end
211
217
end
You can’t perform that action at this time.
0 commit comments