You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by ch...@apache.org on 2013/08/07 19:54:35 UTC
svn commit: r1511420 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-examples/src/main/scripts/runducc
Author: challngr
Date: Wed Aug 7 17:54:35 2013
New Revision: 1511420
URL: http://svn.apache.org/r1511420
Log:
UIMA-2935 Mega (system test) support to verify this feature.
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-examples/src/main/scripts/runducc
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-examples/src/main/scripts/runducc
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-examples/src/main/scripts/runducc?rev=1511420&r1=1511419&r2=1511420&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-examples/src/main/scripts/runducc (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-examples/src/main/scripts/runducc Wed Aug 7 17:54:35 2013
@@ -245,7 +245,10 @@ class DuccProcess(Thread):
CMD = CMD + ' --process_per_item_time_max ' + self.runner.process_timeout # in minutes
CMD = CMD + ' --process_initialization_failures_cap ' + self.runner.init_fail_cap
-
+
+ if ( self.runner.init_timeout > 0 ):
+ CMD = CMD + ' --process_initialization_time_max ' + str(self.runner.init_timeout)
+
CMD = CMD + ' --process_environment ' \
+ '"' \
+ ' AE_INIT_TIME=' + str(self.runner.init_time) \
@@ -573,7 +576,8 @@ class RunDucc(DuccUtil):
continue
def usage(self, msg):
- print msg
+ if ( msg != None ):
+ print msg
print 'Usage:'
print ' runducc.py [optons]'
print 'Options:'
@@ -596,6 +600,10 @@ class RunDucc(DuccUtil):
print ' -i, --init_time seconds'
print ' This is the AE initialization minimum time in seconds. Default:', self.init_time
print ''
+ print ' --init_timeout minutes'
+ print ' Max time in minutes NOTE MINUTES a process is allowed to initialize. Best used n conjunction with careful choice of'
+ print ' -i and -r'
+ print ''
print ' --init_fail_cap number-of-failures.'
print ' This is the max init failures tolerated before the system starts to cap processes. Default:', self.init_fail_cap
print ''
@@ -649,6 +657,7 @@ class RunDucc(DuccUtil):
self.memory_override = None
self.init_time = 10000
self.init_range = 1000
+ self.init_timeout = 0
self.process_timeout = str(60*24) # 24 hour default - nothing in current megas will fail on this
self.style = 'AE'
self.service_pid = None
@@ -662,12 +671,16 @@ class RunDucc(DuccUtil):
self.use_ibm_package = False
self.submit_package = 'org.apache.uima.ducc'
- opts, args = getopt.getopt(argv, 'b:d:i:r:m:p:wx:y:?h', ['AE', 'DD', 'SE=', 'IB=', 'PB=', 'directory=', 'batchfile=', 'init_time=',
- 'init_fail_cap=', 'range=', 'memory_override=', 'process_timeout=',
+ try:
+ opts, args = getopt.getopt(argv, 'b:d:i:r:m:p:wx:y:?h', ['AE', 'DD', 'SE=', 'IB=', 'PB=', 'directory=', 'batchfile=', 'init_time=',
+ 'init_fail_cap=', 'range=', 'memory_override=', 'process_timeout=', 'init_timeout=',
'watch',
- 'jd_uima_log=', 'jp_uima_log=',
- 'use_jar'
- ])
+ 'jd_uima_log=', 'jp_uima_log=',
+ 'use_jar'
+ ])
+ except:
+ print "Unknown option"
+ self.usage(None)
for ( o, a ) in opts:
if o in ('-d', '--directory'):
@@ -686,6 +699,8 @@ class RunDucc(DuccUtil):
self.process_timeout = a
elif o in ('-w', '--watch' ):
self.watch = True
+ elif o in ('--init_timeout' ):
+ self.init_timeout = int(a)
elif o in ('--jd_uima_log' ):
self.jd_uima_log = a
elif o in ('--jp_uima_log' ):
@@ -713,8 +728,8 @@ class RunDucc(DuccUtil):
elif ( o == '-?'):
self.usage(None)
else:
- print 'badarg', a
- self.usage('bad arg: ' + a)
+ print 'Invalud argument:', o
+ self.usage(None)
if ( self.test_dir == None ):
self.usage("Missing test_dir")
@@ -725,6 +740,7 @@ class RunDucc(DuccUtil):
print ' style :', self.style
print ' init-time :', self.init_time / 1000
print ' init-range :', self.init_range / 1000
+ print ' init-timeout :', self.init_timeout
print ' init-bloat :', self.init_bloat
print ' process-bloat :', self.process_bloat
print ' watch :', self.watch