diff options
Diffstat (limited to 'lib/feed2imap')
| -rw-r--r-- | lib/feed2imap/feed2imap.rb | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/lib/feed2imap/feed2imap.rb b/lib/feed2imap/feed2imap.rb index c7d8a2a..41c75eb 100644 --- a/lib/feed2imap/feed2imap.rb +++ b/lib/feed2imap/feed2imap.rb @@ -102,34 +102,34 @@ class Feed2Imap ths = [] mutex = Mutex::new @config.feeds.each do |f| - ths << Thread::new(f) do + ths << Thread::new(f) do |feed| begin mutex.lock - lastcheck = @cache.get_last_check(f.name) - if f.needfetch(lastcheck) + lastcheck = @cache.get_last_check(feed.name) + if feed.needfetch(lastcheck) mutex.unlock - s = HTTPFetcher::fetch(f.url, @cache.get_last_check(f.name)) + s = HTTPFetcher::fetch(feed.url, @cache.get_last_check(feed.name)) mutex.lock - f.body = s - @cache.set_last_check(f.name, Time::now) + feed.body = s + @cache.set_last_check(feed.name, Time::now) end mutex.unlock # dump if requested if @config.dumpdir mutex.synchronize do - if f.body - fname = @config.dumpdir + '/' + f.name + '-' + Time::now.xmlschema - File::open(fname, 'w') { |file| file.puts f.body } + if feed.body + fname = @config.dumpdir + '/' + feed.name + '-' + Time::now.xmlschema + File::open(fname, 'w') { |file| file.puts feed.body } end end end rescue Timeout::Error mutex.synchronize do - @logger.fatal("Timeout::Error while fetching #{f.url}: #{$!}") + @logger.fatal("Timeout::Error while fetching #{feed.url}: #{$!}") end rescue mutex.synchronize do - @logger.fatal("Error while fetching #{f.url}: #{$!}") + @logger.fatal("Error while fetching #{feed.url}: #{$!}") end end end |