Merge pull request #63 from HPC-SimTools/remove_pytau

Remove pytau timings

Author: rosswhitfield

ipsframework/component.py

@@ -7,16 +7,6 @@
 import weakref
 from copy import copy
 
-try:
-    if os.environ['IPS_TIMING'] == '1':
-        try:
-            import pytau
-        except ImportError:
-            raise
-        IPS_TIMING = True
-except KeyError:
-    pass
-
 
 class Component:
     """
@@ -28,9 +18,6 @@ def __init__(self, services, config):
         """
         Set up config values and reference to services.
         """
-        # pytau.setNode(1)
-        # timer = pytau.profileTimer("component.__init__", "", str(os.getpid()))
-        # pytau.start(timer)
         self.component_id = None
         self.invocation_q = None
         self.services = weakref.proxy(services)
@@ -42,11 +29,8 @@ def __init__(self, services, config):
                 setattr(self, i, config[i])
             except Exception as e:
                 print('Error setting Component parameter : ', i, ' - ', e)
-                # pytau.stop(timer)
                 raise
 
-        # pytau.stop(timer)
-
     def __copy__(self):
         cls = self.__class__
         result = cls.__new__(cls)
@@ -61,16 +45,11 @@ def __initialize__(self, component_id, invocation_q, start_time=0.0):
         """
         Establish connection to *invocation_q*.
         """
-        # timer = pytau.profileTimer("component.__initialize__", "", str(os.getpid()))
-        # pytau.start(timer)
         self.component_id = component_id
         self.invocation_q = invocation_q
         self.start_time = start_time
 #        setattr(sys, 'exit', sys.exit)
 
-        # pytau.stop(timer)
-        return
-
     def __my_exit__(self, arg=0):
         """
         Produce message and exception about exit.
@@ -86,8 +65,6 @@ def __run__(self):
         Wait for incoming commands delivered via the *invocation_q*, and
         dispatch the incoming methods accordingly.
         """
-        # timer = pytau.profileTimer(self.component_id.__str__() + ".__run__", "", str(os.getpid()))
-        # pytau.start(timer)
 
         tmp = sys.exit
         sys.exit = self.__my_exit__
@@ -131,7 +108,6 @@ def __run__(self):
                 (errno, strerror) = oserr.args
                 self.services.exception('Error creating directory %s : %s',
                                         workdir, strerror)
-                # pytau.stop(timer)
                 raise
             os.chdir(workdir)
         self.services.debug('Running - CompID =  %s',
@@ -140,9 +116,6 @@ def __run__(self):
         if (self.services.profile):
             self.services.debug('Instrumenting - CompID =  %s',
                                 self.component_id.get_serialization())
-            pytau.setNode(int(self.component_id.get_seq_num()))
-            pytau.dbPurge()
-            self.services._make_timers()
         self.services._init_event_service()
 
         while True:
@@ -175,7 +148,6 @@ def __run__(self):
                                                    call_id,
                                                    Message.SUCCESS, retval)
             self.services.fwk_in_q.put(response_msg)
-        # pytau.stop(timer)
 
     def init(self, timestamp=0.0, **keywords):
         """
@@ -241,7 +213,6 @@ def terminate(self, status):
         Clean up services and call :py:obj:`sys_exit`.
         """
         # print self.services.full_comp_id, ": terminate() method called"
-        self.services._cleanup()
 #        self.services.debug('###(1) %s %s', str(self), str(self.__dict__))
 
         if (status == Message.SUCCESS):