home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 10 Tools / 10-Tools.zip / fnb101.zip / Lib / site-packages / Fnorb / orb / IIOPAcceptor.py < prev    next >
Encoding:
Python Source  |  1999-06-28  |  5.1 KB  |  177 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/IIOPAcceptor.py,v $
  31. # Version:      @(#)$RCSfile: IIOPAcceptor.py,v $ $Revision: 1.6 $
  32. #
  33. #############################################################################
  34. """ IIOPAcceptor (part of the 'Reactor' pattern). """
  35.  
  36.  
  37. # Standard/built-in modules.
  38. import socket
  39.  
  40. # Fnorb modules.
  41. import Acceptor, CORBA, GIOPServer, EventHandler, Reactor
  42.  
  43. # IIOP protocol modules.
  44. import IIOPConnection
  45.  
  46.  
  47. class IIOPAcceptor(Acceptor.Acceptor, EventHandler.EventHandler):
  48.     """ Acceptor (part of the 'Reactor' pattern). """
  49.  
  50.     def __init__(self, address=None):
  51.     """ Constructor.
  52.  
  53.     'address'  is the address to use when creating my endpoint.
  54.  
  55.     """
  56.     # Unpack the address.
  57.     #
  58.     # fixme: address abstraction!
  59.     if address is None:
  60.         (host, port) = ('', 0)
  61.  
  62.     else:
  63.         (host, port) = address
  64.  
  65.     try:
  66.         # Create a socket on which to listen for connection requests.
  67.         self.__socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  68.         self.__socket.bind(host, port)
  69.         self.__socket.listen(5)
  70.  
  71.         # Get the host name, the IP address and the port number of the
  72.         # socket.
  73.         self.__host = socket.gethostname()
  74.         (self.__ip_address, self.__port) = self.__socket.getsockname()
  75.  
  76. ##        # Under OSF/1 if you specify '' as the host address then the IP
  77. ##        # address returned by 'getsockname' will be '0.0.0.0'!
  78. ##        if self.__ip_address == '0.0.0.0':
  79. ##        self.__ip_address = socket.gethostbyname(self.__host)
  80.  
  81.     except socket.error:
  82.         raise CORBA.COMM_FAILURE() # System exception.
  83.  
  84.     # Get a reference to the active reactor.
  85.     self.__reactor = Reactor.Reactor_init()
  86.  
  87.     # Register our interest in read events (ie. connection requests) with
  88.     # the Reactor.
  89.     self.__reactor.register_handler(self, Reactor.READ)
  90.  
  91.     return
  92.  
  93.     #########################################################################
  94.     # Acceptor interface.
  95.     #########################################################################
  96.  
  97.     def address(self):
  98.     """ Return the address of the acceptor's endpoint. """
  99.  
  100.     # fixme: Address abstraction!
  101.     return (self.__host, self.__port)
  102.  
  103.     #########################################################################
  104.     # EventHandler interface.
  105.     #########################################################################
  106.  
  107.     def handle_event(self, mask):
  108.     """ Callback method to handle all events except close events. """
  109.  
  110.     # Read event.
  111.     if mask & Reactor.READ:
  112.         self.__read_event()
  113.  
  114.     # Exception event.
  115.     elif mask & Reactor.EXCEPTION:
  116.         self.__exception_event()
  117.  
  118.     return
  119.  
  120.     def handle_close(self):
  121.     """ Callback method to handle close events. """
  122.  
  123.     # Withdraw my Reactor registration.
  124.     self.__reactor.unregister_handler(self, Reactor.READ)
  125.  
  126.     # Clean up my socket.
  127.     try:
  128.         self.__socket.close()
  129.  
  130.     except socket.error:
  131.         pass
  132.  
  133.     del self.__socket
  134.  
  135.     return
  136.  
  137.     def handle(self):
  138.     """ Return my underlying I/O handle.
  139.  
  140.     In this case, my I/O handle is the file descriptor of my socket. 
  141.  
  142.     """
  143.     return self.__socket.fileno()
  144.  
  145.     #########################################################################
  146.     # Private interface.
  147.     #########################################################################
  148.  
  149.     def __read_event(self):
  150.     """ Handle a read event. """
  151.  
  152.     try:
  153.         # 'Accept' the connection (in TCP/IP there is, in fact, no way to
  154.         # reject it!).
  155.         (client_socket, address) = self.__socket.accept()
  156.  
  157.         # Create a 'Connection' instance to look after the socket.
  158.         connection = IIOPConnection.IIOPConnection(client_socket)
  159.  
  160.         # Create a server to handle client operation requests.
  161.         GIOPServer.GIOPServer(connection)
  162.  
  163.     except socket.error:
  164.         self.__exception_event()
  165.  
  166.     return
  167.  
  168.     def __exception_event(self):
  169.     """ Handle an exception event. """
  170.  
  171.     # Clean up.
  172.     self.handle_close()
  173.  
  174.     return
  175.     
  176. #############################################################################
  177.