home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 10 Tools / 10-Tools.zip / fnb101.zip / Lib / site-packages / Fnorb / orb / Nudger.py < prev    next >
Text File  |  1999-06-28  |  5KB  |  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/Nudger.py,v $
  31. # Version:      @(#)$RCSfile: Nudger.py,v $ $Revision: 1.7 $
  32. #
  33. #############################################################################
  34. """ Nudger (part of the 'Reactor' pattern). """
  35.  
  36.  
  37. # Standard/built-in modules.
  38. import socket
  39.  
  40. # Fnorb modules.
  41. import CORBA, EventHandler, Reactor
  42.  
  43.  
  44. class Nudger(EventHandler.EventHandler):
  45.     """ Nudger (part of the 'Reactor' pattern). """
  46.  
  47.     def __init__(self, host='', port=0):
  48.     """ Constructor.
  49.  
  50.     'host'    is the hostname to use when creating my socket.
  51.     'port'    is the port number to use when creating my socket.
  52.  
  53.     """
  54.     try:
  55.         # Create a socket on which to listen for connection requests.
  56.         listen_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  57.         listen_socket.bind(host, port)
  58.         listen_socket.listen(1)
  59.  
  60.         # Get the host name, the IP address and the port number of the
  61.         # socket.
  62.         listen_host = socket.gethostname()
  63.         (listen_ip_address, listen_port) = listen_socket.getsockname()
  64.  
  65.         # Under OSF/1 if you specify '' as the host address then the IP
  66.         # address returned by 'getsockname' will be '0.0.0.0'!
  67.         if listen_ip_address == '0.0.0.0':
  68.         listen_ip_address = socket.gethostbyname(listen_host)
  69.  
  70.         # Now create a client socket and connect it to the listening
  71.         # socket.  This uses the little-known semantics of the 'connect'
  72.         # function i.e. the call will succeed even *before* the 'accept'
  73.         # has been performed on the listening socket!  If you don't believe
  74.         # me read Stevens' Network Programming ;^)
  75.         self.__client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  76.         self.__client.connect(listen_host, listen_port)
  77.  
  78.         # And finally, we do an 'accept' to complete the connection.
  79.         (self.__server, address) = listen_socket.accept()
  80.  
  81.         # Set the server socket to NON-blocking mode.
  82.         self.__server.setblocking(0)
  83.  
  84.     except socket.error:
  85.         raise CORBA.COMM_FAILURE() # System exception.
  86.  
  87.     # Get a reference to the active reactor.
  88.     self.__reactor = Reactor.Reactor_init()
  89.  
  90.     # Register our interest in 'read' events with the Reactor.
  91.     self.__reactor.register_handler(self, Reactor.READ)
  92.  
  93.     return
  94.  
  95.     def __del__(self):
  96.     """ Destructor. """
  97.  
  98.     self.handle_close()
  99.     return
  100.  
  101.     #########################################################################
  102.     # Nudger interface.
  103.     #########################################################################
  104.  
  105.     def nudge(self):
  106.     """ Nudge myself! """
  107.  
  108.     self.__client.send('nudge!')
  109.     return
  110.  
  111.     #########################################################################
  112.     # EventHandler interface.
  113.     #########################################################################
  114.  
  115.     def handle_event(self, mask):
  116.     """ Callback method to handle all events except close events. """
  117.  
  118.     # Read event.
  119.     if mask & Reactor.READ:
  120.         self.__read_event()
  121.  
  122.     # Exception event.
  123.     if mask & Reactor.EXCEPTION:
  124.         self.__exception_event()
  125.  
  126.     return
  127.  
  128.     def handle_close(self):
  129.     """ Callback method to handle close events. """
  130.  
  131.     # Withdraw my Reactor registration.
  132.     self.__reactor.unregister_handler(self, Reactor.READ)
  133.  
  134.     # Clean up my sockets.
  135.     try:
  136.         self.__client.close()
  137.         self.__server.close()
  138.  
  139.     except socket.error:
  140.         pass
  141.  
  142.     del self.__client
  143.     del self.__server
  144.  
  145.     return
  146.  
  147.     def handle(self):
  148.     """ Return my underlying I/O handle.
  149.  
  150.     In this case, my I/O handle is the file descriptor of my socket. 
  151.  
  152.     """
  153.     return self.__server.fileno()
  154.  
  155.     #########################################################################
  156.     # Private interface.
  157.     #########################################################################
  158.  
  159.     def __read_event(self):
  160.     """ Handle a read event. """
  161.  
  162.     # We do nothing!  The sole purpose of the nudger is to trip the
  163.     # reactor out of a blocking select!
  164.     self.__server.recv(10)
  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.