Sha256: 5f7b67eebf7df8d21c600953e7b1cdd51df0e7688f6afabb3114655331af8d44
Contents?: true
Size: 1.11 KB
Versions: 23
Compression:
Stored size: 1.11 KB
Contents
# Worker used to clean up the queue deleting expired jobs module RestFtpDaemon class ConchitaWorker < Worker protected def worker_init # Load corker conf config_section :conchita # Check that everything is OK return "invalid timer" unless @config[:timer].to_i > 0 return false end def worker_after # Sleep for a few seconds worker_status WORKER_STATUS_WAITING sleep @config[:timer] end def worker_process # Announce we are working worker_status WORKER_STATUS_CLEANING # Cleanup queues according to configured max-age RestFtpDaemon::JobQueue.instance.expire JOB_STATUS_FINISHED, maxage(JOB_STATUS_FINISHED), @config[:debug] RestFtpDaemon::JobQueue.instance.expire JOB_STATUS_FAILED, maxage(JOB_STATUS_FAILED), @config[:debug] RestFtpDaemon::JobQueue.instance.expire JOB_STATUS_QUEUED, maxage(JOB_STATUS_QUEUED), @config[:debug] # Force garbage collector GC.start if @config["garbage_collector"] end private def maxage status @config["clean_#{status}"] || 0 end end end
Version data entries
23 entries across 23 versions & 1 rubygems