62 lines
2.1 KiB
Ruby
62 lines
2.1 KiB
Ruby
require 'json'
|
|
require 'resque'
|
|
require 'resque-lonely_job'
|
|
require 'net/http'
|
|
require 'digest/md5'
|
|
|
|
module JamRuby
|
|
|
|
# http://blog.bignerdranch.com/1643-never-use-resque-for-serial-jobs/
|
|
# periodically scheduled to find sources that need to be brought down, or alternatively, it seems the client failed to start sourcing
|
|
class IcecastSourceCheck
|
|
extend Resque::Plugins::LonelyJob
|
|
|
|
@queue = :icecast_source_check
|
|
|
|
@@log = Logging.logger[IcecastSourceCheck]
|
|
|
|
def self.lock_timeout
|
|
# this should be enough time to make sure the job has finished, but not so long that the system isn't recovering from a abandoned job
|
|
120
|
|
end
|
|
|
|
def self.perform
|
|
@@log.debug("waking up")
|
|
|
|
JamWebEventMachine.run_wait_stop do
|
|
IcecastSourceCheck.new.run
|
|
end
|
|
|
|
@@log.debug("done")
|
|
end
|
|
|
|
|
|
def run # if we haven't seen updated_at be tickled in 5 minutes, but config_changed is still set to TRUE, this record has gotten stale
|
|
IcecastMount.find_each(lock: true, :conditions => "sourced_needs_changing_at < (NOW() - interval '#{APP_CONFIG.icecast_max_sourced_changed} second')", :batch_size => 100) do |mount|
|
|
if mount.music_session_id
|
|
mount.with_lock do
|
|
handle_notifications(mount)
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
def handle_notifications(mount)
|
|
if mount.listeners == 0 && mount.sourced
|
|
# if no listeners, but we are sourced, then ask it to stop sourcing
|
|
@@log.debug("SOURCE_DOWN_REQUEST called on mount #{mount.name}")
|
|
|
|
mount.update_attribute(:sourced_needs_changing_at, Time.now) # we send out a source request, so we need to update the time
|
|
mount.notify_source_down_requested
|
|
|
|
elsif mount.listeners > 0 && !mount.sourced
|
|
# if we have some listeners, and still are not sourced, then ask to start sourcing again
|
|
@@log.debug("SOURCE_UP_REQUEST called on mount #{mount.name}")
|
|
|
|
mount.update_attribute(:sourced_needs_changing_at, Time.now) # we send out a source request, so we need to update the time
|
|
mount.notify_source_up_requested
|
|
|
|
end
|
|
end
|
|
end
|
|
end |