home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 10 Tools / 10-Tools.zip / fnb101.zip / Lib / site-packages / Fnorb / orb / GIOPServerWorkerThreaded.py < prev    next >
Text File  |  1999-06-28  |  5KB  |  197 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/GIOPServerWorkerThreaded.py,v $
  31. # Version:      @(#)$RCSfile: GIOPServerWorkerThreaded.py,v $ $Revision: 1.5 $
  32. #
  33. #############################################################################
  34. """ GIOPServerWorkerThreaded class. """
  35.  
  36.  
  37. # For obvious reasons we import the *real* thread module, not 'fnorb_thread'!
  38. import thread
  39.  
  40. # Fnorb modules.
  41. import CORBA, GIOPConnectionHandler, GIOPServerWorker
  42.  
  43.  
  44. class GIOPServerWorkerThreaded(GIOPServerWorker.GIOPServerWorker):
  45.     """ IIOP Worker class. """
  46.  
  47.     def __init__(self, giop_server, connection):
  48.     """ Constructor.
  49.  
  50.     'giop_server' is the GIOPServer server that is creating the worker.
  51.     'connection'  is a connection to the 'client' ORB.
  52.  
  53.     """
  54.     self.__giop_server = giop_server
  55.     self.__connection = connection
  56.  
  57.     # Set the connection to BLOCKING mode.
  58.     self.__connection.blocking(1)
  59.     
  60.     # Create a handler to look after the connection.
  61.     self.__handler = GIOPConnectionHandler.GIOPConnectionHandler \
  62.              (self, self.__connection)
  63.  
  64.     # Flag used to detect closure in the worker thread.
  65.     self.__closed = 0
  66.  
  67.     # Mutex for the '__closed' flag.
  68.     self.__lk = thread.allocate_lock()
  69.  
  70.     # Start the worker thread.
  71.     thread.start_new_thread(self.__worker_thread, ())
  72.  
  73.     return
  74.  
  75.     def pseudo__del__(self):
  76.     """ Pseudo destructor to remove circular references.
  77.  
  78.     This method is called from '__close' only.
  79.  
  80.     """
  81.     # The GIOP server holds a (circular) reference to this instance so we
  82.     # have to explicitly clean it up.
  83.     self.__giop_server.pseudo__del__()
  84.  
  85.     # Clean up *our* reference to *it*!
  86.     del self.__giop_server
  87.  
  88.     # The handler also holds a (circular) reference to this instance so we
  89.     # have to explicitly clean it up.
  90.     self.__handler.pseudo__del__()
  91.  
  92.     # Clean up *our* reference to *it*!
  93.     del self.__handler
  94.  
  95.     return
  96.  
  97.     #########################################################################
  98.     # GIOPServerWorker interface.
  99.     #########################################################################
  100.  
  101.     def send(self, message):
  102.     """ Send a message. """
  103.  
  104.     self.__lk.acquire()
  105.     try:
  106.         # Send the entire message.
  107.         n = 0
  108.         while n < len(message):
  109.         n = n + self.__handler.send(message)
  110.  
  111.     # We can simply ignore any exceptions when sending a message as the
  112.     # worker thread will detect the error and close down the connection.
  113.         except CORBA.SystemException:
  114.         pass
  115.  
  116.     self.__lk.release()
  117.     return
  118.  
  119.     def close_connection(self):
  120.     """ Close down the server.
  121.  
  122.     Currently, Fnorb does not close down servers, so this is not used.
  123.  
  124.     """
  125.     # Close down the worker.
  126.     self.__close()
  127.  
  128.     return
  129.  
  130.     #########################################################################
  131.     # GIOPConnectionHandlerListener interface.
  132.     #########################################################################
  133.  
  134.     def message_received(self, message):
  135.     """ Called when a complete GIOP message has been received. """
  136.  
  137.     # Pass the message up to the GIOP layer.
  138.     self.__giop_server.process_giop_message(message)
  139.  
  140.     return
  141.  
  142.     def message_sent(self):
  143.     """ Called when a complete GIOP message has been sent. """
  144.  
  145.     pass
  146.  
  147.     #########################################################################
  148.     # Private interface.
  149.     #########################################################################
  150.  
  151.     def __worker_thread(self):
  152.     """ Read operation requests from the client. """
  153.  
  154.     try:
  155.         while not self.__is_closed():
  156.         # Blocking receive.
  157.         self.__handler.recv()
  158.  
  159.     except CORBA.SystemException:
  160.         pass
  161.  
  162.     # Close down the worker.
  163.     self.__close()
  164.  
  165.     # Explicitly exit the thread!
  166.     thread.exit()
  167.  
  168.     def __is_closed(self):
  169.     """ Are we closing down? """
  170.  
  171.     self.__lk.acquire()
  172.     closed = self.__closed
  173.     self.__lk.release()
  174.  
  175.     return closed
  176.  
  177.     def __close(self):
  178.     """ Close down the worker. """
  179.  
  180.      # Notify the worker thread that we are closing down.
  181.     self.__lk.acquire()
  182.     if not self.__closed:
  183.         # Close down the connection (via the handler)
  184.         self.__connection.disconnect()
  185.  
  186.         # All done!
  187.         self.__closed = 1
  188.  
  189.         # Remove circular reference.
  190.         self.pseudo__del__()
  191.  
  192.     self.__lk.release()
  193.  
  194.     return
  195.  
  196. #############################################################################
  197.