Skip to content

Commit a7fa87d

Browse files
committed
RUBY-1096 Small typo fixes and spec cleanup
1 parent 9fe5a5a commit a7fa87d

File tree

10 files changed

+16
-19
lines changed

10 files changed

+16
-19
lines changed

lib/mongo/cluster/topology/sharded.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ def elect_primary(description, servers); self; end
6868
# @param [ ServerSelector ] server_selector The server
6969
# selector.
7070
#
71-
# @return [ true, false ] If a readable server is present.
71+
# @return [ true ] A Sharded cluster always has a readable server.
7272
#
7373
# @since 2.4.0
7474
def has_readable_server?(cluster, server_selector = nil); true; end
@@ -81,7 +81,7 @@ def has_readable_server?(cluster, server_selector = nil); true; end
8181
#
8282
# @param [ Cluster ] cluster The cluster.
8383
#
84-
# @return [ true, false ] If a writable server is present.
84+
# @return [ true ] A Sharded cluster always has a writable server.
8585
#
8686
# @since 2.4.0
8787
def has_writable_server?(cluster); true; end

lib/mongo/cluster/topology/single.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ def elect_primary(description, servers); self; end
7171
# @param [ ServerSelector ] server_selector The server
7272
# selector.
7373
#
74-
# @return [ true, false ] If a readable server is present.
74+
# @return [ true ] A standalone always has a readable server.
7575
#
7676
# @since 2.4.0
7777
def has_readable_server?(cluster, server_selector = nil); true; end
@@ -84,7 +84,7 @@ def has_readable_server?(cluster, server_selector = nil); true; end
8484
#
8585
# @param [ Cluster ] cluster The cluster.
8686
#
87-
# @return [ true, false ] If a writable server is present.
87+
# @return [ true ] A standalone always has a writable server.
8888
#
8989
# @since 2.4.0
9090
def has_writable_server?(cluster); true; end

lib/mongo/cluster/topology/unknown.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ def elect_primary(description, servers)
7777
# @param [ ServerSelector ] server_selector The server
7878
# selector.
7979
#
80-
# @return [ true, false ] If a readable server is present.
80+
# @return [ false ] An Unknown topology will never have a readable server.
8181
#
8282
# @since 2.4.0
8383
def has_readable_server?(cluster, server_selector = nil); false; end
@@ -90,7 +90,7 @@ def has_readable_server?(cluster, server_selector = nil); false; end
9090
#
9191
# @param [ Cluster ] cluster The cluster.
9292
#
93-
# @return [ true, false ] If a writable server is present.
93+
# @return [ false ] An Unknown topology will never have a writable server.
9494
#
9595
# @since 2.4.0
9696
def has_writable_server?(cluster); false; end

lib/mongo/event/description_changed.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ module Event
2222
class DescriptionChanged
2323
include Monitoring::Publishable
2424

25-
# @return [ Mongo::Cluster ] cluster The event publisher.
25+
# @return [ Mongo::Cluster ] cluster The cluster.
2626
attr_reader :cluster
2727

2828
# @return [ Hash ] options The options.

lib/mongo/event/member_discovered.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ module Event
2121
class MemberDiscovered
2222
include Monitoring::Publishable
2323

24-
# @return [ Mongo::Cluster ] cluster The event publisher.
24+
# @return [ Mongo::Cluster ] cluster The cluster.
2525
attr_reader :cluster
2626

2727
# @return [ Hash ] options The options.
@@ -44,7 +44,7 @@ def initialize(cluster)
4444
@monitoring = cluster.monitoring
4545
end
4646

47-
# This event tells the cluster that a member of a known topology is discovered.
47+
# This event tells the cluster that a member of a topology is discovered.
4848
#
4949
# @example Handle the event.
5050
# member_discovered.handle(previous_description, description)

lib/mongo/event/primary_elected.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ module Event
2020
# @since 2.0.0
2121
class PrimaryElected
2222

23-
# @return [ Mongo::Cluster ] cluster The event publisher.
23+
# @return [ Mongo::Cluster ] cluster The cluster.
2424
attr_reader :cluster
2525

2626
# Initialize the new primary elected event handler.

lib/mongo/event/standalone_discovered.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ module Event
2020
# @since 2.0.6
2121
class StandaloneDiscovered
2222

23-
# @return [ Mongo::Cluster ] cluster The event publisher.
23+
# @return [ Mongo::Cluster ] cluster The cluster.
2424
attr_reader :cluster
2525

2626
# Initialize the new standalone discovered event handler.

lib/mongo/server/description.rb

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -519,7 +519,8 @@ def standalone?
519519
#
520520
# @since 2.0.0
521521
def unknown?
522-
config.empty? || config[Operation::Result::OK] != 1
522+
config.empty? || (config[Operation::Result::OK] &&
523+
config[Operation::Result::OK] != 1)
523524
end
524525

525526
# A result from another server's ismaster command before this server has
@@ -610,14 +611,15 @@ def me_mismatch?
610611
# @since 2.0.6
611612
def ==(other)
612613
return false if self.class != other.class
614+
return false if unknown? || other.unknown?
613615
compare_config(other)
614616
end
615617
alias_method :eql?, :==
616618

617619
private
618620

619621
def compare_config(other)
620-
!config.keys.empty? && config.keys.all? do |k|
622+
config.keys.all? do |k|
621623
config[k] == other.config[k] || EXCLUDE_FOR_COMPARISON.include?(k)
622624
end
623625
end

lib/mongo/server/description/inspector/description_changed.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ def initialize(event_listeners)
4646
#
4747
# @since 2.0.0
4848
def run(description, updated)
49-
unless (description.config.empty? && updated.config.empty?) || (description == updated)
49+
unless (description.unknown? && updated.unknown?) || (description == updated)
5050
publish(Event::DESCRIPTION_CHANGED, description, updated)
5151
end
5252
end

spec/mongo/cluster_spec.rb

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -344,7 +344,6 @@
344344
let(:topology) do
345345
double('topology').tap do |t|
346346
allow(t).to receive(:add_hosts?).and_return(true)
347-
allow(t).to receive(:changed!).and_return(true)
348347
end
349348
end
350349

@@ -359,7 +358,6 @@
359358
let(:topology) do
360359
double('topology').tap do |t|
361360
allow(t).to receive(:add_hosts?).and_return(false)
362-
allow(t).to receive(:changed!).and_return(true)
363361
end
364362
end
365363

@@ -408,7 +406,6 @@
408406
double('topology').tap do |t|
409407
allow(t).to receive(:remove_hosts?).and_return(true)
410408
allow(t).to receive(:remove_server?).and_return(true)
411-
allow(t).to receive(:changed!).and_return(true)
412409
end
413410
end
414411

@@ -429,7 +426,6 @@
429426
double('topology').tap do |t|
430427
allow(t).to receive(:remove_hosts?).and_return(true)
431428
allow(t).to receive(:remove_server?).and_return(false)
432-
allow(t).to receive(:changed!).and_return(true)
433429
end
434430
end
435431

@@ -450,7 +446,6 @@
450446
let(:topology) do
451447
double('topology').tap do |t|
452448
allow(t).to receive(:remove_hosts?).and_return(false)
453-
allow(t).to receive(:changed!).and_return(true)
454449
end
455450
end
456451

0 commit comments

Comments
 (0)