home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 10 Tools / 10-Tools.zip / fnb101.zip / Lib / site-packages / Fnorb / orb / DII.py < prev    next >
Text File  |  1999-06-28  |  10KB  |  341 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/DII.py,v $
  31. # Version:      @(#)$RCSfile: DII.py,v $ $Revision: 1.14 $
  32. #
  33. #############################################################################
  34. """ Implementation of the Dynamic Invocation Interface (DII). """
  35.  
  36.  
  37. class Request:
  38.     """ Implementation of the PIDL Request interface.
  39.  
  40.     Request objects are not thread-safe. This is not a problem as it really
  41.     only makes sense to handle requests from within a single thread. If you
  42.     are trying to do otherwise I suggest you take a step back and have a good,
  43.     long, hard look at yourself ;^)
  44.  
  45.     """
  46.     def __init__(self, object, operation, inputs, outputs, exceptions, **kw):
  47.     """ Constructor. """
  48.  
  49.     self.__object = object
  50.     self.__operation = operation
  51.     self.__inputs = inputs
  52.     self.__outputs = outputs
  53.     self.__exceptions = exceptions
  54.  
  55.     # Keyword arguments (as specified in the language mapping document).
  56.     #
  57.     # The 'flags' keyword argument is currently ignored as it is only
  58.     # used in compiled languages to specify memory management policy.
  59.     try:
  60.         self.__flags = kw['flags']
  61.  
  62.     except KeyError:
  63.         self.__flags = 0
  64.  
  65.     try:
  66.         self.__context = kw['context']
  67.  
  68.     except KeyError:
  69.         self.__context = []
  70.  
  71.     # Request arguments can be specified either at invocation time, or via
  72.     # a call to the 'arguments' method.
  73.     self.__arguments = ()
  74.  
  75.     return
  76.  
  77.     #########################################################################
  78.     # CORBA Request interface.
  79.     #########################################################################
  80.  
  81.     def object(self):
  82.     """ Return the object reference that we invoke the request on. """
  83.     
  84.     return self.__object
  85.  
  86.     def operation(self):
  87.     """ Return the operation name. """
  88.  
  89.     return self.__operation
  90.     
  91.     def inputs(self):
  92.     """ Return the input typecodes. """
  93.  
  94.     return self.__inputs
  95.  
  96.     def outputs(self):
  97.     """ Return the output typecodes. """
  98.  
  99.     return self.__outputs
  100.  
  101.     def exceptions(self):
  102.     """ Return the exception typecodes. """
  103.  
  104.     return self.__exceptions
  105.  
  106.     def flags(self):
  107.     """ Return the request flags.
  108.  
  109.     Request flags are currently ignored in Fnorb!
  110.  
  111.     """
  112.     return self.__flags
  113.  
  114.     def context(self):
  115.     """ Return the request context.
  116.  
  117.     Contexts are currently ignored in Fnorb!
  118.  
  119.     """
  120.     return self.__context
  121.  
  122.     def arguments(self, *args):
  123.     """ Initialise the request arguments. """
  124.  
  125.     self.__arguments = args
  126.     return
  127.  
  128.     def results(self):
  129.     """ Return the results of the previous invocation. """
  130.  
  131.     # fixme: Raise an exception here if we have not been invoked!!!!!!!!!
  132.     return self.__results
  133.  
  134. ##     def invoke(self, *args, **kw):
  135. ##     """ Invoke the request (synchronous). """
  136.  
  137. ##     apply(self.send, args, kw)
  138. ##     return self.get_response()
  139.  
  140.  
  141.     def invoke(self, *args, **kw):
  142.     """ Invoke the request (synchronous). """
  143.  
  144.     # Request arguments can be specified either at invocation time, or via
  145.     # a call to the 'arguments' method.
  146.     if len(args) == 0:
  147.         args = self.__arguments
  148.  
  149.     else:
  150.         self.__arguments = args
  151.  
  152.     # Make sure we have the right number of arguments!
  153.     if len(args) != len(self.__inputs):
  154.         raise TypeError, 'Wrong number of arguments'
  155.  
  156.     # Get the object's GIOP client.
  157.     client = self.__object._fnorb_client()
  158.  
  159.     # Ask the client to make the request, and to wait for the reply.
  160.     (forwarded, self.__results) = client.synchronous(self, args)
  161.  
  162.     # If we have been forwarded/unforwarded then try again.
  163.     if forwarded:
  164.         # Try again.
  165.         self.__results = self.invoke()
  166.  
  167.     # Return the results for convenience.
  168.     return self.__results
  169.  
  170.     def send(self, *args, **kw):
  171.     """ Invoke the request (deferred synchronous). """
  172.  
  173.     # Request arguments can be specified either at invocation time, or via
  174.     # a call to the 'arguments' method.
  175.     if len(args) == 0:
  176.         args = self.__arguments
  177.  
  178.     else:
  179.         self.__arguments = args
  180.  
  181.     # Make sure we have the right number of arguments!
  182.     if len(args) != len(self.__inputs):
  183.         raise TypeError, 'Wrong number of arguments'
  184.  
  185.     # Get the object's GIOP client.
  186.     client = self.__object._fnorb_client()
  187.  
  188.     # Ask the client to make the request.
  189.     self.__request_id = client.deferred(self, args)
  190.  
  191.     return
  192.  
  193.     def get_response(self):
  194.     """ Get the response for a deferred request. """
  195.  
  196.     # Get the object's GIOP client.
  197.     client = self.__object._fnorb_client()
  198.  
  199.     # Get the reply to the last operation request.
  200.     (forwarded, self.__results) = client.reply(self)
  201.  
  202.     # If we have been forwarded/unforwarded then try again.
  203.     if forwarded:
  204.         # Try again.
  205.         self.__results = self.invoke()
  206.  
  207.     # Return the results for convenience.
  208.     return self.__results
  209.  
  210.     def poll_response(self):
  211.     """ Has a reply been received? """
  212.  
  213.     # Get the object's GIOP client.
  214.     client = self.__object._fnorb_client()
  215.  
  216.     # Poll for the reply to the last operation request.
  217.     (forwarded, result) = client.poll(self)
  218.  
  219.     # If we have been forwarded/unforwarded then try again.
  220.     if forwarded:
  221.         # Try again.
  222.         self.send()
  223.  
  224.     return result
  225.  
  226.     def invoke_oneway(self, *args, **kw):
  227.     """ Invoke the request as 'oneway'. """
  228.  
  229.     # Request arguments can be specified either at invocation time, or via
  230.     # a call to the 'arguments' method.
  231.     if len(args) == 0:
  232.         args = self.__arguments
  233.  
  234.     else:
  235.         self.__arguments = args
  236.  
  237.     # Make sure we have the right number of arguments!
  238.     if len(args) != len(self.__inputs):
  239.         raise TypeError, 'Wrong number of arguments'
  240.  
  241.     # Get the object's GIOP client.
  242.     client = self.__object._fnorb_client()
  243.  
  244.     # Ask the client to make the request.
  245.     client.oneway(self, args)
  246.  
  247.     return
  248.  
  249.     #########################################################################
  250.     # Fnorb-specific interface.
  251.     #########################################################################
  252.  
  253.     def _fnorb_request_id(self):
  254.     """ Return the request id of the current request. """
  255.  
  256.     return self.__request_id
  257.  
  258.  
  259. class LocalRequest(Request):
  260.     """ Request interface for local requests (ie. in same address space). """
  261.  
  262.     #########################################################################
  263.     # CORBA Request interface.
  264.     #########################################################################
  265.  
  266.     def invoke(self, *args):
  267.     """ Invoke the request (synchronous). """
  268.  
  269.     # Request arguments can be specified either at invocation time, or via
  270.     # a call to the 'arguments' method.
  271.     if len(args) == 0:
  272.         args = self.__arguments
  273.  
  274.     # Make sure we have the right number of arguments!
  275.     if len(args) != len(self.__inputs):
  276.         raise TypeError, 'Wrong number of arguments'
  277.     
  278.     # Find the method on the implementation (via the 'LocalObject'
  279.     # instance).
  280.     method = getattr(self.__object, self.__operation)
  281.  
  282.     # Invoke the operation!
  283.     self.__results = apply(method, args)
  284.  
  285.     # Return the results for convenience!
  286.     return self.__results
  287.  
  288.     def invoke_oneway(self, *args):
  289.     """ Invoke the request as 'oneway'. """
  290.  
  291.     # Request arguments can be specified either at invocation time, or via
  292.     # a call to the 'arguments' method.
  293.     if len(args) == 0:
  294.         args = self.__arguments
  295.  
  296.     # Make sure we have the right number of arguments!
  297.     if len(args) != len(self.__inputs):
  298.         raise TypeError
  299.  
  300.     # Find the method on the implementation (via the 'LocalObject'
  301.     # instance).
  302.     method = getattr(self.__object, self.__operation)
  303.  
  304.     # Invoke the operation and throw away any results!
  305.     apply(method, args)
  306.  
  307.     return
  308.  
  309.     def send(self, *args):
  310.     """ Invoke the request (deferred synchronous). """
  311.  
  312.     # Request arguments can be specified either at invocation time, or via
  313.     # a call to the 'arguments' method.
  314.     if len(args) == 0:
  315.         args = self.__arguments
  316.  
  317.     # Make sure we have the right number of arguments!
  318.     if len(args) != len(self.__inputs):
  319.         raise TypeError
  320.  
  321.     # Find the method on the implementation (via the 'LocalObject'
  322.     # instance).
  323.     method = getattr(self.__object, self.__operation)
  324.  
  325.     # Invoke the operation!
  326.     self.__results = apply(method, args)
  327.  
  328.     return
  329.  
  330.     def poll_response(self):
  331.     """ Has a reply been received? """
  332.  
  333.     return 1
  334.  
  335.     def get_response(self):
  336.     """ Get the response for a deferred request. """
  337.  
  338.     return self.__results
  339.  
  340. #############################################################################
  341.