home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 10 Tools / 10-Tools.zip / fnb101.zip / Lib / site-packages / Fnorb / orb / GIOPClientManager.py < prev    next >
Text File  |  1999-06-28  |  5KB  |  178 lines
  1. #!/usr/bin/env python
  2. #############################################################################
  3. # Copyright (C) DSTC Pty Ltd (ACN 052 372 577) 1997, 1998, 1999
  4. # All Rights Reserved.
  5. #
  6. # The software contained on this media is the property of the DSTC Pty
  7. # Ltd.  Use of this software is strictly in accordance with the
  8. # license agreement in the accompanying LICENSE.HTML file.  If your
  9. # distribution of this software does not contain a LICENSE.HTML file
  10. # then you have no rights to use this software in any manner and
  11. # should contact DSTC at the address below to determine an appropriate
  12. # licensing arrangement.
  13. # 
  14. #      DSTC Pty Ltd
  15. #      Level 7, GP South
  16. #      Staff House Road
  17. #      University of Queensland
  18. #      St Lucia, 4072
  19. #      Australia
  20. #      Tel: +61 7 3365 4310
  21. #      Fax: +61 7 3365 4311
  22. #      Email: enquiries@dstc.edu.au
  23. # 
  24. # This software is being provided "AS IS" without warranty of any
  25. # kind.  In no event shall DSTC Pty Ltd be liable for damage of any
  26. # kind arising out of or in connection with the use or performance of
  27. # this software.
  28. #
  29. # Project:      Fnorb
  30. # File:         $Source: /units/arch/src/Fnorb/orb/RCS/GIOPClientManager.py,v $
  31. # Version:      @(#)$RCSfile: GIOPClientManager.py,v $ $Revision: 1.4 $
  32. #
  33. #############################################################################
  34. """ GIOP Client Manager module. """
  35.  
  36.  
  37. # Fnorb modules.
  38. import fnorb_thread, CORBA, GIOPClient
  39.  
  40.  
  41. def GIOPClientManager_init():
  42.     """ Initialise the GIOP Client Manager.
  43.  
  44.     This is a factory function for the GIOPClientManager class (the
  45.     GIOPClientManager is a singleton (ie. there can only be one
  46.     GIOPClientManager instance per process)).
  47.  
  48.     """
  49.     GIOPClientManager._lk.acquire()
  50.     try:
  51.     gcm = GIOPClientManager()
  52.  
  53.     except GIOPClientManager, gcm:
  54.     pass
  55.     GIOPClientManager._lk.release()
  56.  
  57.     return gcm
  58.  
  59.  
  60. class GIOPClientManager:
  61.     """ The GIOPClientManager object.
  62.  
  63.     The GIOPClientManager is a singleton (ie. there can only be one
  64.     GIOPClientManager instance per process).
  65.  
  66.     """
  67.     # Singleton instance.
  68.     __instance = None
  69.  
  70.     # Mutex to make access via the factory function thread-safe.
  71.     _lk = fnorb_thread.allocate_lock()
  72.  
  73.     def __init__(self):
  74.     """ Constructor. """
  75.  
  76.     # The GIOPClientManager is a singleton (ie. there can only be one
  77.     # GIOPClientManager instance per process).
  78.     if GIOPClientManager.__instance is not None:
  79.         raise GIOPClientManager.__instance
  80.  
  81.     GIOPClientManager.__instance = self
  82.  
  83.     # A dictionary of GIOP clients that are connected to remote objects.
  84.     self.__clients = {} # {Address: (GIOPClient, ReferenceCount)}
  85.  
  86.     # A mutex to make access to the client dictionary thread-safe.
  87.     self.__lk = fnorb_thread.allocate_lock()
  88.  
  89.     return
  90.  
  91.     #########################################################################
  92.     # GIOPClientManager interface.
  93.     #########################################################################
  94.  
  95.     def get_client(self, ior, protocol=None):
  96.     """ Get a client for the specified IOR. """
  97.  
  98.     # If no particular protocol was specified then we use the first one
  99.     # that we can get an address from.
  100.     if protocol is None:
  101.         for protocol in CORBA.ORB_init()._fnorb_protocols():
  102.         address = protocol.get_address(ior)
  103.         if address is not None:
  104.             break
  105.  
  106.         else:
  107.         address = None
  108.  
  109.     # Otherwise, we get the address from the specified protocol.
  110.     else:
  111.         address = protocol.get_address(ior)
  112.  
  113.     # If no address was found then barf!
  114.     if address is None:
  115.         raise CORBA.INV_OBJREF() # System exception.
  116.  
  117.     # The dictionary of clients is keyed on the address.
  118.     self.__lk.acquire()
  119.     try:
  120.         # If we already have a client connected to this address then use
  121.         # that.
  122.         if self.__clients.has_key(address):
  123.         (client, refcount) = self.__clients[address]
  124.         self.__clients[address] = (client, refcount + 1)
  125.  
  126.         # Else create a new client and connect it to the remote object.
  127.         else:
  128.         client = GIOPClient.GIOPClient(protocol, address)
  129.         self.__clients[address] = (client, 1)
  130.         
  131.     finally:
  132.         self.__lk.release()
  133.  
  134.     return client
  135.  
  136.     def delete_client(self, ior, protocol=None):
  137.     """ Delete the client for the specified IOR. """
  138.  
  139.     # If no particular protocol was specified then we use the first one
  140.     # that we can get an address from.
  141.     if protocol is None:
  142.         for protocol in CORBA.ORB_init()._fnorb_protocols():
  143.         address = protocol.get_address(ior)
  144.         if address is not None:
  145.             break
  146.  
  147.         else:
  148.         address = None
  149.  
  150.     # Otherwise, we get the address from the specified protocol.
  151.     else:
  152.         address = protocol.get_address(ior)
  153.  
  154.     # If no address was found then barf!
  155.     if address is None:
  156.         raise CORBA.INV_OBJREF() # System exception.
  157.  
  158.     # The dictionary of clients is keyed on the address.
  159.     self.__lk.acquire()
  160.     try:
  161.         (client, refcount) = self.__clients[address]
  162.         if refcount == 1:
  163.         # Remove the client from our table.
  164.         del self.__clients[address]
  165.  
  166.         # Call the pseudo destructor to clean up circular references.
  167.         client.pseudo__del__()
  168.  
  169.         else:
  170.         self.__clients[address] = (client, refcount - 1)
  171.         
  172.     finally:
  173.         self.__lk.release()
  174.  
  175.     return
  176.  
  177. #############################################################################
  178.