开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 网格计算 > 查看源码
hod
资源名称：hadoop-0.20.0.tar.gz　[点击查看]
上传用户：quxuerui
上传日期：2018-01-08
资源大小：41811k
文件大小：23k
源码类别：

网格计算

开发平台：

Java

hod：源码内容
  1. #!/bin/sh
  3. # Licensed to the Apache Software Foundation (ASF) under one or more
  4. # contributor license agreements.  See the NOTICE file distributed with
  5. # this work for additional information regarding copyright ownership.
  6. # The ASF licenses this file to You under the Apache License, Version 2.0
  7. # (the "License"); you may not use this file except in compliance with
  8. # the License.  You may obtain a copy of the License at
  9. #
  10. #     http://www.apache.org/licenses/LICENSE-2.0
  11. #
  12. # Unless required by applicable law or agreed to in writing, software
  13. # distributed under the License is distributed on an "AS IS" BASIS,
  14. # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15. # See the License for the specific language governing permissions and
  16. # limitations under the License.
  19. """:"
  20. work_dir=$(dirname $0)
  21. base_name=$(basename $0)
  22. original_dir=$PWD
  23. cd $work_dir
  25. if [ $HOD_PYTHON_HOME ]; then
  26.     exec $HOD_PYTHON_HOME -u -OO $base_name ${1+"$@"} --hod.original-dir $original_dir
  27. elif [ -e /usr/bin/python ]; then
  28.     exec /usr/bin/python -u -OO $base_name ${1+"$@"} --hod.original-dir $original_dir
  29. elif [ -e /usr/local/bin/python ]; then
  30.     exec /usr/local/bin/python -u -OO $base_name ${1+"$@"} --hod.original-dir $original_dir
  31. else
  32.     exec python -u -OO $base_name ${1+"$@"} --hod.original-dir $work_dir
  33. fi
  34. ":"""
  36. """The executable to be used by the user"""
  37. import sys, os, re, pwd, threading, sys
  39. myName          = os.path.basename(sys.argv[0])
  40. myName          = re.sub(".*/", "", myName)
  41. binDirectory    = os.path.realpath(sys.argv[0])
  42. rootDirectory   = re.sub("/bin/.*", "", binDirectory)
  43. libDirectory    = rootDirectory
  45. sys.path.append(libDirectory)
  47. from hodlib.Hod.hod import hodRunner
  48. from hodlib.Common.setup import *
  49. from hodlib.Common.descGenerator import *
  50. from hodlib.Common.util import local_fqdn, need_to_allocate, filter_warnings,
  51.     get_exception_error_string, hodInterrupt, 
  52.     HOD_INTERRUPTED_MESG, HOD_INTERRUPTED_CODE,
  53.     TORQUE_USER_LIMITS_COMMENT_FIELD
  54. from hodlib.Common.tcp import tcpError, tcpSocket
  55. from hodlib.Hod.hod import hodHelp
  57. filter_warnings()
  59. reVersion = re.compile(".*(d+_d+).*")
  61. VERSION = None
  62. if os.path.exists("./VERSION"):
  63.   vFile = open("./VERSION", 'r')
  64.   VERSION = vFile.readline()
  65.   vFile.close()
  67. # Always look for hodrc file here unless otherwise specified with -c:   
  68. DEFAULT_LOC = os.path.join(rootDirectory, 'conf')
  69. DEFAULT_HOD_DIR = os.path.join(os.environ['HOME'], ".hod")
  71. if not os.path.isdir(DEFAULT_HOD_DIR):
  72.   os.mkdir(DEFAULT_HOD_DIR, 0777)
  74. DEFAULT_CONFIG = os.path.join(DEFAULT_HOD_DIR, 'hodrc')
  75. if not os.path.exists(DEFAULT_CONFIG):
  76.   if os.environ.has_key('HOD_CONF_DIR') and os.environ['HOD_CONF_DIR'] is not None:
  77.     DEFAULT_CONFIG = os.path.join(os.environ['HOD_CONF_DIR'], 'hodrc')
  79. # Definition tuple is of the form:
  80. #  (name, type, description, help?, default value, required?, validate?, 
  81. #   short option)
  82. #
  83. defList = { 'hod' : (      
  84.              ('original-dir', 'directory', 'hod original start directory',
  85.               False, None, True, True, 'r'),
  87.              ('clusterdir', 'directory', 
  88.              'Directory where cluster state information and hadoop-site.xml' +
  89.              ' will be stored.',
  90.               True, None, False, False, 'd'),
  92.              ('syslog-address', 'address', 'Syslog address.',
  93.               False, None, False, True, 'y'),
  94.               
  95.              ('java-home', 'directory', 'Java home directory.',
  96.               True, None, True, True, 'j'),
  97.             
  98.              ('debug', 'pos_int', 'Debugging level, 0-4.',
  99.               True, 3, True, True, 'b'),
  100.             
  101.              ('stream', 'bool', 'Output to stderr.',
  102.               False, True, False, True),
  104.              ('nodecount', 'pos_int', 
  105.               'Number of nodes to allocate at startup. ',
  106.               True, None, False, True, 'n'),
  108.              ('script', 'file', 'Hadoop script to execute.',
  109.               True, None, False, False, 's'), 
  111.              ('userid', 'user_account', 
  112.               'User ID the hod shell is running under.',
  113.               False, pwd.getpwuid(os.getuid())[0], False, True, 'u'),
  114.              
  115.              ('allocate-wait-time', 'pos_int', 
  116.               'Time to wait for cluster allocation.',
  117.               False, 300, True, True, 'e'),         
  118.               
  119.              ('operation', 'string',
  120.               'Initiate a hod operation. (help, allocate, deallocate ...)',
  121.               False, None, False, True, 'o'),
  122.              
  123.              ('cluster-factor', 'pos_float',
  124.               'The number of grid slots per machines', False, 1.9, False, True,
  125.               'x'),
  126.              
  127.              ('cluster', 'string', 'Name of cluster being used.',
  128.               False, None, True, True, 'w'),
  130.              ('proxy-xrs-address', 'address', 
  131.               'Address to Allocation Manager XML RPC proxy.',
  132.               False, None, False, True, 'p'),
  133.               
  134.              ('xrs-port-range', 'range', 'XML-RPC port range n-m.',
  135.               False, None, True, True),
  137.              ('client-params', 'keyval', 'Hadoop client xml key/value list',
  138.               True, None, False, True, 'C'), 
  140.              ('hadoop-ui-log-dir', 'directory', 'Directory to store Web UI Logs of Hadoop',
  141.               True, None, False, True),
  143.              ('temp-dir', 'directory', 'HOD temporary directories.',
  144.               False, None, True, False),
  146.              ('update-worker-info', 'bool', 'Specifies whether to update Worker Info after allocation',
  147.               False, False, False, True),
  149.              ('job-feasibility-attr', 'string', 'Specifies whether to check job feasibility - resource manager and/or scheduler limits, also gives the attribute value',
  150.               False, None, False, True),
  152.              ('title', 'string', 'Title for the current HOD allocation.',
  153.                True, "HOD", False, True, 'N'),
  155.              ('walltime', 'pos_int', 'Walltime in seconds for the current HOD allocation',
  156.               True, None, False, True, 'l'),
  158.              ('script-wait-time', 'pos_int', 'Specifies the time to wait before running the script. Used with the hod.script option.',
  159.               True, 10, False, True, 'W'),
  161.              ('log-rollover-count', 'pos_int', 'Specifies the number of rolled-over log files of HOD client. A zero value disables rollover.',
  162.               True, 5, False, True, 'L'),
  164.              ('job-status-query-interval', 'pos_int', 'Specifies the time between checking for job status', 
  165.               False, 30, False, True),
  167.              ('job-command-failure-interval', 'pos_int', 'Specifies the time between checking for failed job status or submission commands', 
  168.               False, 10, False, True),
  170.              ('job-status-query-failure-retries', 'pos_int', 'Specifies the number of times job status failure queries are retried', 
  171.               False, 3, False, True),
  173.              ('job-submission-failure-retries', 'pos_int', 'Specifies the number of times job submission failure queries are retried',
  174.               False, 3, False, True)),
  176.             'resource_manager' : (
  177.              ('id', 'string', 'Batch scheduler ID: torque|condor.',
  178.               False, None, True, True),
  179.              
  180.              ('pbs-user', 'user_account', 'User ID jobs are submitted under.',
  181.               False, None, False, True),
  182.               
  183.              ('pbs-account', 'string', 'User Account jobs are submitted under.',
  184.               True, None, False, False, 'A'),
  185.               
  186.              ('queue', 'string', 'Queue of the batch scheduler to query.',
  187.               True, 'batch', False, True, 'Q'),
  188.              
  189.              ('batch-home', 'directory', 'Scheduler installation directory.',
  190.               False, None, True, True),
  191.              
  192.              ('options', 'keyval', 'Options to pass to the scheduler.',
  193.               False, None, False, True),
  195.              ('env-vars', 'keyval', 'Environment variables to pass to the submitted jobs.',
  196.               False, None, False, True)),
  197.                             
  198.             'ringmaster' : (
  199.              ('work-dirs', 'list', 'hod work directories',
  200.               False, None, True, False),
  202.              ('temp-dir', 'directory', 'Ringmaster temporary directory.',
  203.               False, None, True, False),
  204.               
  205.              ('log-dir', 'directory', 'hod logging directory.', 
  206.               False, os.path.join(rootDirectory, 'logs'), False, False),
  208.              ('syslog-address', 'address', 'Syslog address.',
  209.               False, None, False, True),
  211.              ('xrs-port-range', 'range', 'XML-RPC port range n-m.',
  212.               False, None, True, True),
  213.               
  214.              ('http-port-range', 'range', 'HTTP port range n-m.',
  215.               False, None, True, True),
  216.               
  217.              ('debug', 'pos_int', 'Debugging level, 0-4.',
  218.               False, 4, True,   True),
  219.                
  220.              ('register', 'bool', 'Register with service registry?',
  221.               False, True, True, True),
  222.                
  223.              ('stream', 'bool', 'Output to stderr.',
  224.               False, False, False, True),
  225.               
  226.              ('userid', 'user_account', 
  227.               'User ID the hod shell is running under.',
  228.               False, pwd.getpwuid(os.getuid())[0], False, True),
  229.                
  230.              ('svcrgy-addr', 'address', 'Download HTTP address.',
  231.               False, None, False, False),             
  232.              
  233.              ('hadoop-tar-ball', 'uri', 'hadoop program tar ball.',
  234.               True, None, False, False, 't'),
  236.              ('max-connect','pos_int','max connections allowed for a single tarball server',
  237.              False, 30, False, True),
  239.              ('jt-poll-interval', 'pos_int', 'How often to poll the Job tracker for idleness',
  240.              False, 120, False, True),
  242.              ('idleness-limit', 'pos_int', 'Limit after which to deallocate the cluster',
  243.              False, 3600, False, True),
  245.              ('max-master-failures', 'pos_int', 
  246.               'Defines how many times a master can fail before' 
  247.               ' failing cluster allocation', False, 5, True, True),
  249.              ('workers_per_ring', 'pos_int', 'Defines number of workers per service per hodring',
  250.              False, 1, False, True)),
  252.             'gridservice-mapred' : (
  253.              ('external', 'bool', "Connect to an already running MapRed?",
  254.               False, False, True, True),
  255.               
  256.              ('host', 'hostname', 'Mapred hostname.', 
  257.               False, 'localhost', False, False),
  259.              ('info_port', 'pos_int', 'Mapred info port.',
  260.               False, None, False, False),
  261.              
  262.              ('tracker_port', 'pos_int', 'Mapred job tracker port.',
  263.               False, None, False, False),
  264.                         
  265.              ('cmdline-params', 'keyval', 'Hadoop cmdline key/value list.',
  266.               False, None, False, False),
  268.              ('server-params', 'keyval', 'Hadoop xml key/value list',
  269.               True, None, False, True, 'M'),
  270.                
  271.              ('envs', 'keyval', 'environment to run this package in',
  272.               False, None, False, True),
  274.              ('final-server-params', 'keyval', 'Hadoop final xml key/val list',
  275.               False, None, False, True, 'F'),
  277.              ('pkgs', 'directory', "directory where the package is installed",
  278.               False, None, False, False)), 
  279.                
  280.                
  281.             'gridservice-hdfs' : (
  282.              ('external', 'bool', "Connect to an already running HDFS?",
  283.               False, False, True, True),
  284.              
  285.              ('host', 'hostname', 'HDFS hostname.', 
  286.               False, 'localhost', False, False),
  287.              
  288.              ('fs_port', 'pos_int', 'HDFS port.',
  289.               False, None, False, False),
  290.               
  291.              ('info_port', 'pos_int', 'HDFS info port.',
  292.               False, None, False, False), 
  293.              
  294.              ('cmdline-params', 'keyval', 'Hadoop cmdline key/value list.',
  295.               False, None, False, False),
  297.              ('server-params', 'keyval', 'Hadoop xml key/value list',
  298.               False, None, False, True, 'H'),
  300.              ('final-server-params', 'keyval', 'Hadoop final xml key/value list',
  301.               False, None, False, True, 'S'),
  302.            
  303.              ('envs', 'keyval', 'Environment in which to run this package.',
  304.               False, None, False, True),
  306.              ('pkgs', 'directory', "directory where the package is installed",
  307.               False, None, False, False)),           
  308.              
  309.              
  310.             'hodring' : (
  311.              ('temp-dir', 'list', 'hodring temporary directory.',
  312.               False, None, True, False),
  313.               
  314.              ('log-dir', 'directory', 'hod logging directory.', 
  315.               False, os.path.join(rootDirectory, 'logs'), False, False), 
  316.               
  317.              ('log-destination-uri', 'string', 
  318.               'URI to store logs to, local://some_path or '
  319.               + 'hdfs://host:port/some_path', 
  320.               False, None, False, True),
  322.              ('pkgs', 'directory', 'Path to Hadoop to use in case of uploading to HDFS',
  323.               False, None, False, False),
  324.               
  325.              ('syslog-address', 'address', 'Syslog address.',
  326.               False, None, False, True),
  327.           
  328.              ('java-home', 'directory', 'Java home directory.',
  329.               False, None, True, False),
  330.               
  331.              ('debug', 'pos_int', 'Debugging level, 0-4.',
  332.               False, 3, True, True),
  333.                
  334.              ('register', 'bool', 'Register with service registry?',
  335.               False, True, True, True),
  336.                
  337.              ('stream', 'bool', 'Output to stderr.',
  338.               False, False, False, True),
  340.              ('userid', 'user_account', 
  341.               'User ID the hod shell is running under.',
  342.               False, pwd.getpwuid(os.getuid())[0], False, True),
  343.                
  344.              ('command', 'string', 'Command for hodring to run.',
  345.               False, None, False, True),
  347.              ('xrs-port-range', 'range', 'XML-RPC port range n-m.',
  348.               False, None, True, True),
  349.                
  350.              ('http-port-range', 'range', 'HTTP port range n-m.',
  351.               False, None, True, True),
  352.               
  353.              ('service-id', 'string', 'Service ID.',
  354.               False, None, False, True),
  355.               
  356.              ('download-addr', 'string', 'Download HTTP address.',
  357.               False, None, False, True),
  358.                
  359.              ('svcrgy-addr', 'address', 'Download HTTP address.',
  360.               False, None, False, True), 
  361.     
  362.              ('ringmaster-xrs-addr', 'address', 'Ringmaster XML-RPC address.',
  363.               False, None, False, True),
  365.              ('tarball-retry-initial-time', 'pos_float','Initial Retry time for tarball download',
  366.               False, 1, False, True),
  367.               
  368.              ('tarball-retry-interval', 'pos_float','interval to spread retries for tarball download',
  369.               False, 3, False, True),
  370.               
  371.              ('cmd-retry-initial-time', 'pos_float','Initial retry time for getting commands',
  372.               False, 2, False, True),
  373.              
  374.              ('cmd-retry-interval', 'pos_float','interval to spread retries for getting commands',
  375.               False, 2, False, True),
  377.              ('mapred-system-dir-root', 'string', 'Root under which mapreduce system directory names are generated by HOD.',
  378.               False, '/mapredsystem', False, False))
  379.               }   
  381. defOrder = [ 'hod', 'ringmaster', 'hodring', 'resource_manager', 
  382.              'gridservice-mapred', 'gridservice-hdfs' ]
  384. def printErrors(msgs):
  385.   for msg in msgs:
  386.     print msg
  388. def op_requires_pkgs(config):
  389.   if config['hod'].has_key('operation'):
  390.     return config['hod']['operation'].startswith('allocate')
  391.   else:
  392.     return config['hod'].has_key('script')
  394. if __name__ == '__main__':  
  395.   try:
  396.     confDef = definition()
  397.     confDef.add_defs(defList, defOrder)
  398.     hodhelp = hodHelp()
  399.     usage = hodhelp.help()
  400.             
  401.     hodOptions = options(confDef, usage,
  402.                       VERSION, withConfig=True, defaultConfig=DEFAULT_CONFIG,
  403.                       name=myName )
  404.     # hodConfig is a dict like object, hodConfig[section][name]
  405.     try:
  406.       hodConfig = config(hodOptions['config'], configDef=confDef, 
  407.                        originalDir=hodOptions['hod']['original-dir'],
  408.                        options=hodOptions) 
  409.     except IOError, e:
  410.       print >>sys.stderr,"error: %s not found. Specify the path to the HOD configuration file, or define the environment variable %s under which a file named hodrc can be found." % (hodOptions['config'], 'HOD_CONF_DIR')
  411.       sys.exit(1)
  412.   
  413.     # Conditional validation
  414.     statusMsgs = []
  416.     if hodConfig.normalizeValue('gridservice-hdfs', 'external'):
  417.       # For external HDFS
  418.       statusMsgs.extend(hodConfig.validateValue('gridservice-hdfs',
  419.                                                 'fs_port'))
  420.       statusMsgs.extend(hodConfig.validateValue('gridservice-hdfs',
  421.                                                 'info_port'))
  422.       statusMsgs.extend(hodConfig.validateValue('gridservice-hdfs',
  423.                                                 'host'))
  424.     else:
  425.       hodConfig['gridservice-hdfs']['fs_port'] = 0 # Dummy
  426.       hodConfig['gridservice-hdfs']['info_port'] = 0 # Not used at all
  428.     if hodConfig.normalizeValue('gridservice-mapred', 'external'):
  429.       statusMsgs.extend(hodConfig.validateValue('gridservice-mapred',
  430.                                                 'tracker_port'))
  431.       statusMsgs.extend(hodConfig.validateValue('gridservice-mapred',
  432.                                                 'info_port'))
  433.       statusMsgs.extend(hodConfig.validateValue('gridservice-mapred',
  434.                                                 'host'))
  435.     else:
  436.       hodConfig['gridservice-mapred']['tracker_port'] = 0 # Dummy
  437.       hodConfig['gridservice-mapred']['info_port'] = 0 # Not used at all
  439.     if len(statusMsgs) != 0:
  440.       for msg in statusMsgs:
  441.         print >>sys.stderr, msg
  442.       sys.exit(1)
  443.     # End of conditional validation
  445.     status = True
  446.     statusMsgs = []
  447.   
  448.     (status,statusMsgs) = hodConfig.verify()
  449.     if not status:
  450.       print >>sys.stderr,"error: bin/hod failed to start."
  451.       for msg in statusMsgs:
  452.         print >>sys.stderr,"%s" % (msg)
  453.       sys.exit(1)
  454.   
  455.     ## TODO : should move the dependency verification to hodConfig.verify
  456.     if hodConfig['hod'].has_key('operation') and 
  457.       hodConfig['hod'].has_key('script'):
  458.       print "Script operation is mutually exclusive with other HOD operations"
  459.       hodOptions.print_help(sys.stderr)
  460.       sys.exit(1)
  461.     
  462.     if 'operation' not in hodConfig['hod'] and 'script' not in hodConfig['hod']:
  463.       print "HOD requires at least a script or operation be specified."
  464.       hodOptions.print_help(sys.stderr)
  465.       sys.exit(1)    
  466.     
  467.     if hodConfig['gridservice-hdfs']['external']:
  468.       hdfsAddress = "%s:%s" % (hodConfig['gridservice-hdfs']['host'], 
  469.                                hodConfig['gridservice-hdfs']['fs_port'])
  470.   
  471.       hdfsSocket = tcpSocket(hdfsAddress)
  472.         
  473.       try:
  474.         hdfsSocket.open()
  475.         hdfsSocket.close()
  476.       except tcpError:
  477.         printErrors(hodConfig.var_error('hod', 'gridservice-hdfs', 
  478.           "Failed to open a connection to external hdfs address: %s." % 
  479.           hdfsAddress))
  480.         sys.exit(1)
  481.     else:
  482.       hodConfig['gridservice-hdfs']['host'] = 'localhost'
  483.   
  484.     if hodConfig['gridservice-mapred']['external']:
  485.       mapredAddress = "%s:%s" % (hodConfig['gridservice-mapred']['host'], 
  486.                                  hodConfig['gridservice-mapred']['tracker_port'])
  487.   
  488.       mapredSocket = tcpSocket(mapredAddress)
  489.         
  490.       try:
  491.         mapredSocket.open()
  492.         mapredSocket.close()
  493.       except tcpError:
  494.         printErrors(hodConfig.var_error('hod', 'gridservice-mapred', 
  495.           "Failed to open a connection to external mapred address: %s." % 
  496.           mapredAddress))
  497.         sys.exit(1)
  498.     else:
  499.       hodConfig['gridservice-mapred']['host'] = 'localhost'
  500.   
  501.     if not hodConfig['ringmaster'].has_key('hadoop-tar-ball') and 
  502.       not hodConfig['gridservice-hdfs'].has_key('pkgs') and 
  503.       op_requires_pkgs(hodConfig):
  504.       printErrors(hodConfig.var_error('gridservice-hdfs', 'pkgs', 
  505.         "gridservice-hdfs.pkgs must be defined if ringmaster.hadoop-tar-ball "
  506.         + "is not defined."))
  507.       sys.exit(1)
  508.   
  509.     if not hodConfig['ringmaster'].has_key('hadoop-tar-ball') and 
  510.       not hodConfig['gridservice-mapred'].has_key('pkgs') and 
  511.       op_requires_pkgs(hodConfig):
  512.       printErrors(hodConfig.var_error('gridservice-mapred', 'pkgs', 
  513.         "gridservice-mapred.pkgs must be defined if ringmaster.hadoop-tar-ball "
  514.         + "is not defined."))
  515.       sys.exit(1)
  516.   
  517.     if hodConfig['hodring'].has_key('log-destination-uri'):
  518.       if hodConfig['hodring']['log-destination-uri'].startswith('file://'):
  519.         pass
  520.       elif hodConfig['hodring']['log-destination-uri'].startswith('hdfs://'):
  521.         hostPort = hodConfig['hodring']['log-destination-uri'][7:].split("/")
  522.         hostPort = hostPort[0]
  523.         socket = tcpSocket(hostPort)
  524.         try:
  525.           socket.open()
  526.           socket.close()
  527.         except:
  528.           printErrors(hodConfig.var_error('hodring', 'log-destination-uri', 
  529.           "Unable to contact host/port specified in log destination uri: %s" % 
  530.           hodConfig['hodring']['log-destination-uri']))
  531.           sys.exit(1)
  532.       else:
  533.         printErrors(hodConfig.var_error('hodring', 'log-destination-uri', 
  534.           "The log destiniation uri must be of type local:// or hdfs://."))
  535.         sys.exit(1)
  536.   
  537.     if hodConfig['ringmaster']['workers_per_ring'] < 1:
  538.       printErrors(hodConfig.var_error('ringmaster', 'workers_per_ring',
  539.                 "ringmaster.workers_per_ring must be a positive integer " +
  540.                 "greater than or equal to 1"))
  541.       sys.exit(1)
  542.                         
  543.     ## TODO : end of should move the dependency verification to hodConfig.verif
  544.       
  545.     hodConfig['hod']['base-dir'] = rootDirectory
  546.     hodConfig['hod']['user_state'] = DEFAULT_HOD_DIR
  547.   
  548.     dGen = DescGenerator(hodConfig)
  549.     hodConfig = dGen.initializeDesc()
  550.     
  551.     os.environ['JAVA_HOME'] = hodConfig['hod']['java-home']
  552.     
  553.     if hodConfig['hod']['debug'] == 4:
  554.       print ""
  555.       print "Using Python: %s" % sys.version
  556.       print ""
  557.    
  558.     hod = hodRunner(hodConfig)
  559.   
  560.     # Initiate signal handling
  561.     hodInterrupt.set_log(hod.get_logger())
  562.     hodInterrupt.init_signals()
  563.     # Interrupts set up. Now on we handle signals only when we wish to.
  564.   except KeyboardInterrupt:
  565.     print HOD_INTERRUPTED_MESG
  566.     sys.exit(HOD_INTERRUPTED_CODE)
  567.   
  568.   opCode = 0
  569.   try:
  570.     if hodConfig['hod'].has_key('script'):
  571.       opCode = hod.script()
  572.     else:  
  573.       opCode = hod.operation()
  574.   except Exception, e:
  575.     print "Uncaught Exception : %s" % e
  576.   finally:
  577.     sys.exit(opCode)