lib/zold/node/spread_entrance.rb in zold-0.22.4 vs lib/zold/node/spread_entrance.rb in zold-0.22.5

- old
+ new

@@ -94,10 +94,10 @@ # This method is thread-safe def push(id, body) mods = @entrance.push(id, body) return mods if @remotes.all.empty? - (mods + [id]).each do |m| + mods.each do |m| next if @seen.include?(m) @mutex.synchronize { @seen << m } @modified.push(m) @log.debug("Spread-push scheduled for #{m}, queue size is #{@modified.size}") end