Skip to content

Commit

Permalink
Merge pull request #101 from yuhanz/master
Browse files Browse the repository at this point in the history
bug fix in member_config for having _id > 255
  • Loading branch information
shortdudey123 authored Dec 9, 2016
2 parents 1a99248 + 5141e5a commit 025c0c4
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions libraries/mongodb.rb
Original file line number Diff line number Diff line change
Expand Up @@ -156,7 +156,7 @@ def self.configure_replicaset(node, name, members)
Chef::Log.error("configuring replicaset returned: #{result.inspect}") unless result.fetch('errmsg', nil).nil?
else
# remove removed members from the replicaset and add the new ones
max_id = config['members'].map { |member| member['_id'] }.max
old_ids = config['members'].map { |member| member['_id'] }
rs_members.map! { |member| member['host'] }
config['version'] += 1
old_members = config['members'].map { |member| member['host'] }
Expand All @@ -166,10 +166,11 @@ def self.configure_replicaset(node, name, members)
host = m['host']
{ '_id' => m['_id'], 'host' => host }.merge(rs_options[host])
end
ids = (0...256).to_a - old_ids
members_add = rs_members - old_members
members_add.each do |m|
max_id += 1
config['members'] << { '_id' => max_id, 'host' => m }.merge(rs_options[m])
new_id = ids.shift
config['members'] << { '_id' => new_id, 'host' => m }.merge(rs_options[m])
end

rs_connection = nil
Expand Down

0 comments on commit 025c0c4

Please sign in to comment.