home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 10 Tools / 10-Tools.zip / fnb101.zip / Lib / site-packages / Fnorb / orb / IIOPProtocol.py < prev    next >
Encoding:
Python Source  |  1999-06-28  |  4.5 KB  |  155 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/IIOPProtocol.py,v $
  31. # Version:      @(#)$RCSfile: IIOPProtocol.py,v $ $Revision: 1.8 $
  32. #
  33. #############################################################################
  34. """ IIOP Protocol module. """
  35.  
  36.  
  37. # Fnorb modules.
  38. import CORBA, IIOP, IOP, Nudger, Protocol, Reactor
  39.  
  40. # IIOP protocol modules.
  41. import IIOPAcceptor, IIOPConnection
  42.  
  43.  
  44. class IIOPProtocol(Protocol.Protocol):
  45.     """ IIOP Protocol. """
  46.  
  47.     #########################################################################
  48.     # Protocol interface.
  49.     #########################################################################
  50.  
  51.     def enable(self, host, port):
  52.     """ Create an endpoint for connection requests. """
  53.  
  54.     # Create/initialise a reactor.
  55.     self.__reactor = Reactor.Reactor_init()
  56.  
  57.     # Create an acceptor to listen for client connection requests.
  58.     self.__acceptor = IIOPAcceptor.IIOPAcceptor((host, port))
  59.  
  60.     # Create a nudger.
  61.     self.__nudger = Nudger.Nudger()
  62.  
  63.     return
  64.  
  65.     def disable(self):
  66.     """ Destroy the endpoint that is listening for connection requests. """
  67.  
  68.     pass
  69.  
  70.     def start(self, timeout=0):
  71.     """ Start the protocol event loop. """
  72.  
  73.     # Start the reactor's event loop.
  74.     self.__reactor.start_event_loop(timeout)
  75.  
  76.     return
  77.  
  78.     def stop(self):
  79.     """ Stop the protocol event loop. """
  80.  
  81.     # Stop the reactor's event loop.
  82.     self.__reactor.stop_event_loop()
  83.  
  84.     # Give the reactor a nudge so that it can realise that it has been
  85.     # stopped!
  86.     self.__nudger.nudge()
  87.  
  88.     return
  89.  
  90.     def create_connection(self):
  91.     """ Create a connection. """
  92.  
  93.     return IIOPConnection.IIOPConnection()
  94.  
  95.     def create_profile(self, id):
  96.     """ Create an IOR profile for the protocol. """
  97.  
  98.     # Get the host and port number of the acceptor.
  99.     (host, port) = self.__acceptor.address()
  100.     
  101.     # Create an IIOP tagged profile.
  102.     version = IIOP.Version(chr(1), chr(0))
  103.     profile_body = IIOP.ProfileBody(version, host, port, id)
  104.     profile = IOP.TaggedProfile(IOP.TAG_INTERNET_IOP, profile_body)
  105.  
  106.     return profile
  107.  
  108.     def get_object_key(self, ior):
  109.     """ Extract the object key from an IOR. """
  110.  
  111.     try:
  112.         # If the object reference does NOT contain an IIOP profile, then
  113.         # this call will raise an 'INV_OBJREF' exception.
  114.         object_key = ior._fnorb_iiop_profile().object_key
  115.  
  116.     except CORBA.INV_OBJREF:
  117.         object_key = None
  118.  
  119.     return object_key
  120.  
  121.     def get_address(self, ior):
  122.     """ Extract the address from an IOR. """
  123.  
  124.     try:
  125.         # If the object reference does NOT contain an IIOP profile, then
  126.         # this call will raise an 'INV_OBJREF' exception.
  127.         iiop_profile = ior._fnorb_iiop_profile()
  128.         address = (iiop_profile.host, iiop_profile.port)
  129.  
  130.     except CORBA.INV_OBJREF:
  131.         address = None
  132.  
  133.     return address
  134.  
  135.     def is_local(self, ior):
  136.     """ Does the IOR reference an object in *this* ORB? """
  137.  
  138.     try:
  139.         # If the object reference does NOT contain an IIOP profile, then
  140.         # this call will raise an 'INV_OBJREF' exception.
  141.         iiop_profile = ior._fnorb_iiop_profile()
  142.  
  143.         # Get the host and port number of the acceptor.
  144.         (host, port) = self.__acceptor.address()
  145.  
  146.         # Is the object in *this* ORB?
  147.         result = (iiop_profile.host == host and iiop_profile.port == port)
  148.  
  149.     except CORBA.INV_OBJREF:
  150.         result = 0
  151.         
  152.     return result
  153.  
  154. #############################################################################
  155.