summaryrefslogtreecommitdiff
path: root/bin
diff options
context:
space:
mode:
Diffstat (limited to 'bin')
-rwxr-xr-xbin/custodian-dequeue26
1 files changed, 18 insertions, 8 deletions
diff --git a/bin/custodian-dequeue b/bin/custodian-dequeue
index 9edc353..99ea63f 100755
--- a/bin/custodian-dequeue
+++ b/bin/custodian-dequeue
@@ -6,10 +6,11 @@
# SYNOPSIS
# custodian-dequeue [ -h | --help ]
# [ -m | --manual]
-# [ --server 1.2.3.4:123 ]
+# [ -f | --flush ]
+# [ -l | --logfile FILE]
+# [ -S | --server 1.2.3.4:123 ]
# [ -s | --single ]
# [ -v | --verbose ]
-# [ -f | --flush ]
#
# OPTIONS
#
@@ -19,10 +20,15 @@
#
# -f, --flush Flush the queue, removing all jobs.
#
+# -l, --logfile Specify the path to the logfile to run.
+#
+# -S, --server Specify the host:port for the beanstalkd queue.
+#
# -s, --single Run a single test and exit. Don't poll the queue for more.
#
# -v, --verbose Be noisy.
#
+#
# ABOUT
#
# This tool is designed to pull JSON-encoded network/protocol-tests from
@@ -156,13 +162,13 @@ class Custodian
#
# Constructor: Connect to the queue
#
- def initialize( server )
+ def initialize( server, logfile )
# Connect to the queue
@queue = Beanstalk::Pool.new([server])
# Instantiate the logger.
- @logger = Logger.new( "worker.log", "daily" )
+ @logger = Logger.new( logfile, "daily" )
if ( ENV['REPEAT'] )
@retry_count=ENV['REPEAT'].to_i
@@ -343,15 +349,17 @@ end
#
if __FILE__ == $0 then
- $SERVER = "127.0.0.1:11300"
- $help = false
- $manual = false
+ $SERVER = "127.0.0.1:11300"
+ $LOGFILE = "custodian-dequeue.log"
+ $help = false
+ $manual = false
begin
opts = GetoptLong.new(
[ "--flush", "-f", GetoptLong::NO_ARGUMENT ],
[ "--help", "-h", GetoptLong::NO_ARGUMENT ],
[ "--manual", "-m", GetoptLong::NO_ARGUMENT ],
+ [ "--logfile", "-l", GetoptLong::REQUIRED_ARGUMENT ],
[ "--repeat", "-r", GetoptLong::REQUIRED_ARGUMENT ],
[ "--server", "-S", GetoptLong::REQUIRED_ARGUMENT ],
[ "--single", "-s", GetoptLong::NO_ARGUMENT ],
@@ -363,6 +371,8 @@ if __FILE__ == $0 then
ENV["VERBOSE"] = "1"
when "--flush":
ENV["FLUSH"] = "1"
+ when "--logfile":
+ $LOGFILE = arg
when "--repeat":
ENV["REPEAT"] = arg
when "--server":
@@ -414,7 +424,7 @@ if __FILE__ == $0 then
#
# Create the object
#
- worker = Custodian.new( $SERVER )
+ worker = Custodian.new( $SERVER, $LOGFILE )
#
# Are we flushing the queue?