src/Container/SALOME_ComponentPy.py

   1 #! /usr/bin/env python
   2 #
   3 #  SALOME Container : implementation of container and engine for Kernel
   4 #
   5 #  Copyright (C) 2003  OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
   6 #  CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
   7 #
   8 #  This library is free software; you can redistribute it and/or
   9 #  modify it under the terms of the GNU Lesser General Public
  10 #  License as published by the Free Software Foundation; either
  11 #  version 2.1 of the License.
  12 #
  13 #  This library is distributed in the hope that it will be useful,
  14 #  but WITHOUT ANY WARRANTY; without even the implied warranty of
  15 #  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  16 #  Lesser General Public License for more details.
  17 #
  18 #  You should have received a copy of the GNU Lesser General Public
  19 #  License along with this library; if not, write to the Free Software
  20 #  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
  21 #
  22 #  See http://www.opencascade.org/SALOME/ or email : webmaster.salome@opencascade.org
  23 #
  24 #
  25 #
  26 #  File   : SALOME_ComponentPy.py
  27 #  Author : Paul RASCLE, EDF
  28 #  Module : SALOME
  29 #  $Header$
  30
  31 import os
  32 import sys
  33 import time
  34 from omniORB import CORBA, PortableServer
  35 import Engines, Engines__POA
  36 import Registry
  37 from Utils_Identity import *
  38 from SALOME_NamingServicePy import *
  39 from libNOTIFICATION import *
  40
  41 from SALOME_utilities import *
  42
  43 from thread import *
  44
  45 #=============================================================================
  46
  47 #define an implementation of the component interface
  48
  49 class SALOME_ComponentPy_i (Engines__POA.Component):
  50     _orb = None
  51     _poa = None
  52
  53     #-------------------------------------------------------------------------
  54
  55     def __init__ (self, orb, poa, contID, containerName,
  56                   instanceName, interfaceName, notif):
  57         # Notif for notification services
  58         # NOT YET IMPLEMENTED
  59         MESSAGE(  "SALOME_ComponentPy_i::__init__" + " " + str (containerName) + " " + str(instanceName) + " " + str(interfaceName) )
  60         self._orb = orb
  61         self._poa = poa
  62         self._instanceName = instanceName
  63         self._interfaceName = interfaceName
  64         self._containerName = containerName
  65         self._notif = notif
  66         self._myConnexionToRegistry = 0
  67         self._graphName = ''
  68         self._nodeName = ''
  69         self._ThreadId = 0
  70         self._StartUsed = 0
  71         self._ThreadCpuUsed = 0
  72         self._Executed = 0
  73
  74         naming_service = SALOME_NamingServicePy_i(self._orb)
  75         Component_path = "/Containers/" +  os.getenv( "HOSTNAME" ) + "/" + self._containerName + "/" + self._interfaceName
  76         MESSAGE(  'SALOME_ComponentPy_i Register' + str( Component_path ) )
  77         naming_service.Register(self._this(), Component_path)
  78
  79         # Add componentinstance to registry
  80         obj = naming_service.Resolve('/Registry')
  81         if obj is None:
  82             MESSAGE(  "Registry Reference is invalid" )
  83         else:
  84             regist = obj._narrow(Registry.Components)
  85             if regist is None:
  86                 MESSAGE(  "Registry Reference is invalid" )
  87             else:
  88                 ior = orb.object_to_string(contID)
  89                 MESSAGE(  ior )
  90
  91                 lesInfos = Identity(self._instanceName)
  92                 infos = Registry.Infos(lesInfos._name,
  93                                        lesInfos._pid,
  94                                        lesInfos._machine,
  95                                        lesInfos._adip,
  96                                        lesInfos._uid,
  97                                        lesInfos._pwname,
  98                                        int(lesInfos._tc_start),
  99                                        0,0,0,
 100                                        lesInfos._cdir,
 101                                        -1,
 102                                        ior)
 103
 104                 res = regist.add(infos)
 105
 106         self._notifSupplier = NOTIFICATION_Supplier_Swig(instanceName, notif)
 107
 108     #-------------------------------------------------------------------------
 109
 110     def _get_instanceName(self):
 111         MESSAGE(  "SALOME_ComponentPy_i::_get_instanceName" )
 112         return self._instanceName
 113
 114     #-------------------------------------------------------------------------
 115
 116     def ping(self):
 117         MESSAGE(  "SALOME_ComponentPy_i::ping" )
 118
 119     #-------------------------------------------------------------------------
 120
 121     def destroy(self):
 122         MESSAGE(  "SALOME_ComponentPy_i::destroy" )
 123         poa.deactivate_object(self)
 124         CORBA.release(_poa)
 125
 126     #-------------------------------------------------------------------------
 127
 128     def GetContainerRef(self):
 129         MESSAGE(  "SALOME_ComponentPy_i::GetContainerRef" )
 130
 131     #-------------------------------------------------------------------------
 132
 133     def beginService(self , serviceName ):
 134         MESSAGE(  "Send BeginService notification for " + str(serviceName) + " for graph/node " + str(self._graphName) + " " + str(self._nodeName) )
 135         MESSAGE(  "Component instance : " + str ( self._instanceName ) )
 136         self._serviceName = str(serviceName)
 137         self._ThreadId = get_ident()
 138         self._StartUsed = 0
 139         self._StartUsed = self.CpuUsed_impl()
 140         self._ThreadCpuUsed = 0
 141         self._Executed = 1
 142         MESSAGE( "SALOME_ComponentPy_i::beginService _StartUsed " + str( self._ThreadId ) + " " + str( self._StartUsed ) )
 143
 144
 145     #-------------------------------------------------------------------------
 146
 147     def endService(self , serviceName ):
 148         MESSAGE(  "Send EndService notification for " + str( self._ThreadId ) + " " + str(serviceName) + " for graph/node " + str(self._graphName) + " " + str(self._nodeName) + " CpuUsed " + str( self.CpuUsed_impl() ) )
 149         MESSAGE(  "Component instance : " + str(self._instanceName) )
 150
 151     #-------------------------------------------------------------------------
 152
 153     def sendMessage(self , event_type , message ):
 154         self._notifSupplier.Send(self.graphName(), self.nodeName(), event_type, message)
 155
 156     #-------------------------------------------------------------------------
 157
 158     def Names(self , GraphName , NodeName ):
 159         MESSAGE(  "SALOME_ComponentPy_i::Names" + str(GraphName) + str(NodeName) )
 160         self._graphName = GraphName
 161         self._nodeName = NodeName
 162
 163     #-------------------------------------------------------------------------
 164
 165     def graphName(self):
 166         return self._graphName
 167
 168     #-------------------------------------------------------------------------
 169
 170     def nodeName(self):
 171         return self._nodeName
 172
 173     #-------------------------------------------------------------------------
 174
 175     def Kill(self):
 176         MESSAGE(  "SALOME_ComponentPy_i::Kill not yet implemented" )
 177
 178     #-------------------------------------------------------------------------
 179
 180     def Stop(self):
 181         MESSAGE(  "SALOME_ComponentPy_i::Stop not yet implemented" )
 182
 183     #-------------------------------------------------------------------------
 184
 185     def Suspend(self):
 186         MESSAGE(  "SALOME_ComponentPy_i::Suspend not yet implemented" )
 187
 188     #-------------------------------------------------------------------------
 189
 190     def Resume(self):
 191         MESSAGE(  "SALOME_ComponentPy_i::Resume not yet implemented" )
 192
 193     #-------------------------------------------------------------------------
 194
 195     def CpuUsed_impl(self):
 196         if ( self._ThreadId | self._Executed ) :
 197             if self._ThreadId == get_ident() :
 198                 cpu = time.clock()
 199                 self._ThreadCpuUsed = int(cpu) - self._StartUsed
 200                 MESSAGE( "SALOME_ComponentPy_i::CpuUsed_impl " + self._serviceName + " " + str( int(cpu) ) + " - " + str( self._StartUsed ) + " = " + str( self._ThreadCpuUsed ) )
 201                 return self._ThreadCpuUsed
 202             MESSAGE( "SALOME_ComponentPy_i::CpuUsed_impl " + self._serviceName + " " + str( self._ThreadCpuUsed ) )
 203             return self._ThreadCpuUsed
 204         MESSAGE( "SALOME_ComponentPy_i::CpuUsed_impl self._StartUsed " + self._serviceName + " " + str(self._StartUsed) )
 205         return 0
 206
 207     #-------------------------------------------------------------------------
 208