diff options
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/feed2imap/feed2imap.rb | 14 |
1 files changed, 11 insertions, 3 deletions
diff --git a/lib/feed2imap/feed2imap.rb b/lib/feed2imap/feed2imap.rb index d892eda..68051c7 100644 --- a/lib/feed2imap/feed2imap.rb +++ b/lib/feed2imap/feed2imap.rb @@ -135,16 +135,24 @@ class Feed2Imap else @logger.warn("No way to fetch feed #{feed.name} !") end - if feed.filter + if feed.filter and s != nil # avoid running more than one command at the same time. # We need it because the called command might not be # thread-safe, and we need to get the right exitcode. mutex.lock - Open3::popen3(feed.filter) do |stdin, stdout| + # hack hack hack, avoid buffering problems + stdin, stdout, stderr = Open3::popen3(feed.filter) + inth = Thread::new do stdin.puts s stdin.close - s = stdout.read end + output = nil + outh = Thread::new do + output = stdout.read + end + inth.join + outh.join + s = output if $?.exitstatus != 0 @logger.warn("Filter command for #{feed.name} exited with status #{$?.exitstatus}. Output might be corrupted !") end |