lib/zold/node/async_entrance.rb in zold-0.20.1 vs lib/zold/node/async_entrance.rb in zold-0.20.2
- old
+ new
@@ -58,13 +58,17 @@
end
def start
raise 'Block must be given to start()' unless block_given?
FileUtils.mkdir_p(@dir)
- DirItems.new(@dir).fetch.select { |f| f =~ /^[0-9a-f]{16}-/ }.each do |f|
+ DirItems.new(@dir).fetch.each do |f|
file = File.join(@dir, f)
- id = f.split('-')[0]
- @queue << { id: Id.new(id), file: file }
+ if /^[0-9a-f]{16}-/.match?(f)
+ id = f.split('-')[0]
+ @queue << { id: Id.new(id), file: file }
+ else
+ File.delete(file)
+ end
end
@log.info("#{@queue.size} wallets pre-loaded into async_entrace from #{@dir}") unless @queue.size.zero?
@entrance.start do
(0..@threads).map do |i|
@pool.add do