casa6

#!/usr/bin/env python

import thread # To handle service threads like monitoring

import time # To handle sleep times

import traceback # To pretty-print tracebacks

​

from taskinit import casalog

​

# Import MPIEnvironment static class

from MPIEnvironment import MPIEnvironment

​

# Import MPICommunicator singleton

from MPICommunicator import MPICommunicator

​

class MPIMonitorClient:

    # Storage for the MPIMonitorClient singleton instance reference

    __instance = None

​

​

    def __init__(self,start_services=True):

        """ Create MPIMonitorClient singleton instance """

        casalog_call_origin = "MPIMonitorClient::__init__"

        # Check if MPI is effectively enabled

        if not MPIEnvironment.is_mpi_enabled:

            msg = "MPI is not enabled"

            casalog.post(msg,"SEVERE",casalog_call_origin)

            raise Exception(msg)

        # Check if MPIMonitorClient can be instantiated

        if not MPIEnvironment.is_mpi_client:

            msg = "MPIMonitorClient can only be instantiated at master MPI process"

            casalog.post(msg,"SEVERE",casalog_call_origin)

            raise Exception(msg)

        # Check whether we already have a MPIMonitorClient singleton instance

        if MPIMonitorClient.__instance is None:

            # Create MPIMonitorClient singleton instance

            MPIMonitorClient.__instance = MPIMonitorClient.__MPIMonitorClientImpl(start_services=start_services)

​

        # Store MPIMonitorClient singleton instance reference as the only member in the handle

        self.__dict__['_MPIMonitorClient__instance'] = MPIMonitorClient.__instance        

​

    def __getattr__(self, attr):

        """ Delegate access to MPIMonitorClient implementation """

        return getattr(self.__instance, attr)

​

​

    def __setattr__(self, attr, value):

        """ Delegate access to MPIMonitorClient implementation """

        return setattr(self.__instance, attr, value)    

    class __MPIMonitorClientImpl:

        """ Implementation of the MPIMonitorClient singleton interface """

        def __init__(self,start_services=True):