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