aboutsummaryrefslogtreecommitdiffstats
path: root/lib
diff options
context:
space:
mode:
authorre4k <re4k@re4k.info>2013-05-04 18:09:28 +0900
committerre4k <re4k@re4k.info>2013-05-04 18:09:28 +0900
commit31e9e320cdc5aa1b26ebdda3da4db7f067667fa5 (patch)
treee60cf2095f93cb772ed277c293f8f7d119df547f /lib
parent2844d9159d6417f8c8d55e818c2ed6a4e30ea405 (diff)
downloadaclog-31e9e320cdc5aa1b26ebdda3da4db7f067667fa5.tar.gz
refactor, fix errors
Diffstat (limited to 'lib')
-rw-r--r--lib/receiver/worker.rb8
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
-
-