diff options
author | re4k <re4k@re4k.info> | 2013-05-04 18:09:28 +0900 |
---|---|---|
committer | re4k <re4k@re4k.info> | 2013-05-04 18:09:28 +0900 |
commit | 31e9e320cdc5aa1b26ebdda3da4db7f067667fa5 (patch) | |
tree | e60cf2095f93cb772ed277c293f8f7d119df547f /lib | |
parent | 2844d9159d6417f8c8d55e818c2ed6a4e30ea405 (diff) | |
download | aclog-31e9e320cdc5aa1b26ebdda3da4db7f067667fa5.tar.gz |
refactor, fix errors
Diffstat (limited to 'lib')
-rw-r--r-- | lib/receiver/worker.rb | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/lib/receiver/worker.rb b/lib/receiver/worker.rb index baf0afe..19ee4af 100644 --- a/lib/receiver/worker.rb +++ b/lib/receiver/worker.rb @@ -155,7 +155,7 @@ class Receiver::Worker < DaemonSpawn::Base Rails.logger.debug("Received Tweet(#{@worker_number}): #{msg["id"]}") unless @@saved_tweets.include?(msg["id"]) @@saved_tweets << msg["id"] - if @@saved_tweets.size > 10000 + if @@saved_tweets.size > 100000 Rails.logger.debug("Tweet id dropped from cache: #{@@saved_tweets.shift}") end @@ -214,7 +214,7 @@ class Receiver::Worker < DaemonSpawn::Base def receive_data(data) @pac.feed_each(data) do |msg| - p msg + Rails.logger.debug(msg.to_s) unless msg["type"] Rails.logger.error("Unknown message") send_object({:type => "fatal", :message => "Unknown message"}) @@ -259,8 +259,6 @@ class Receiver::Worker < DaemonSpawn::Base EM.stop end Signal.trap(:INT, &stop) - Signal.trap(:QUIT, &stop) - Signal.trap(:TERM, &stop) end end @@ -268,5 +266,3 @@ class Receiver::Worker < DaemonSpawn::Base end end - - |