aboutsummaryrefslogtreecommitdiffstats
path: root/lib
diff options
context:
space:
mode:
authorre4k <re4k@re4k.info>2013-03-13 23:46:38 +0900
committerre4k <re4k@re4k.info>2013-03-13 23:46:38 +0900
commitc57c8f1cc950e1be5abc0cac7553338426462f4b (patch)
tree674a066b79a29db86b3f84eac89ba03491efb0c6 /lib
parenteffc12efe76e7c3455d45b2756eaa92f269e2d6d (diff)
downloadaclog-c57c8f1cc950e1be5abc0cac7553338426462f4b.tar.gz
Fix error
Diffstat (limited to 'lib')
-rw-r--r--lib/receiver/worker.rb5
1 files changed, 4 insertions, 1 deletions
diff --git a/lib/receiver/worker.rb b/lib/receiver/worker.rb
index 63f9f24..7c2c11e 100644
--- a/lib/receiver/worker.rb
+++ b/lib/receiver/worker.rb
@@ -94,7 +94,7 @@ class Receiver::Worker < DaemonSpawn::Base
end
def send_account_all
- Account.where("user_id % ? = ?", $worker_count, @worker_number).each do |account|
+ Account.where("id % ? = ?", $worker_count, @worker_number).each do |account|
puts "Sent #{account.id}/#{account.user_id}"
send_account(account)
end
@@ -134,6 +134,9 @@ class Receiver::Worker < DaemonSpawn::Base
send_chunk("ERROR Invalid Secret Token")
close_connection_after_writing
end
+ when "UNAUTHORIZED"
+ $logger.warn("Unauthorized: #{arg.last}")
+ # unregister
when "QUIT"
$logger.info("Quit: #{@worker_number}")
send_chunk("BYE")