home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 10 Tools / 10-Tools.zip / fnb101.zip / Lib / site-packages / Fnorb / orb / IOP.py < prev    next >
Text File  |  1999-06-28  |  13KB  |  301 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-1.0/orb/RCS/IOP.py,v $
  31. # Version:      @(#)$RCSfile: IOP.py,v $ $Revision: 1.18 $
  32. #
  33. #############################################################################
  34. """ CORBA Interoperability (IOP) module. """
  35.  
  36.  
  37. _FNORB_ID = "IDL:omg.org/IOP:1.0"
  38.  
  39.  
  40. # Standard/built-in modules.
  41. import new, string
  42.  
  43. # Fnorb modules.
  44. import CORBA, IIOP, OctetStream, TypeManager
  45.  
  46. # Fnorb extension modules.
  47. import cdr
  48.  
  49.  
  50. # Alias: IDL:omg.org/IOP/ProfileId:1.0
  51. TypeManager.TypeManager_init().add_type("IDL:omg.org/IOP/ProfileId:1.0", "0000000000000005", None)
  52.  
  53. # Constant: IDL:omg.org/IOP/TAG_INTERNET_IOP:1.0
  54. TAG_INTERNET_IOP = 0L
  55.  
  56. TypeManager.TypeManager_init().add_type("IDL:omg.org/IOP/TAG_INTERNET_IOP:1.0", "0000000000000005", TAG_INTERNET_IOP)
  57.  
  58. # Constant: IDL:omg.org/IOP/TAG_MULTIPLE_COMPONENTS:1.0
  59. TAG_MULTIPLE_COMPONENTS = 1L
  60.  
  61. TypeManager.TypeManager_init().add_type("IDL:omg.org/IOP/TAG_MULTIPLE_COMPONENTS:1.0", "0000000000000005", TAG_MULTIPLE_COMPONENTS)
  62.  
  63.  
  64. class TaggedProfile:
  65.     """ Struct: IDL:omg.org/IOP/TaggedProfile:1.0 """
  66.  
  67.     _FNORB_ID = "IDL:omg.org/IOP/TaggedProfile:1.0"
  68.  
  69.     def __init__(self, _tag, _profile_data):
  70.         """ Constructor. """
  71.  
  72.         self.tag = _tag
  73.         self.profile_data = _profile_data
  74.         return
  75.  
  76.     def __getinitargs__(self):
  77.         """ Return the constructor arguments for unpickling. """
  78.  
  79.         return (self.tag, self.profile_data)
  80.  
  81.     def _fnorb_marshal(self, cursor):
  82.     """ Marshal the structure onto an octet stream. """
  83.  
  84.     cursor.marshal('L', self.tag)
  85.  
  86.     # The profile data is an encapsulation.
  87.     encapsulation = OctetStream.Encapsulation()
  88.     encapsulation_cursor = encapsulation.cursor()
  89.  
  90.     if self.tag == TAG_INTERNET_IOP:
  91.         tc = CORBA.typecode('IDL:omg.org/IIOP/ProfileBody:1.0')
  92.         tc._fnorb_marshal_value(encapsulation_cursor, self.profile_data)
  93.         
  94.     elif self.tag == TAG_MULTIPLE_COMPONENTS:
  95.          tc = CORBA.typecode('IDL:omg.org/IOP/TaggedComponent:1.0')
  96.         encapsulation_cursor.marshal('L', len(self.profile_data))
  97.         for component in self.profile_data:
  98.         tc._fnorb_marshal_value(encapsulation_cursor, component)
  99.  
  100.     else:
  101.         # Unknown profile
  102.         encapsulation = self.profile_data
  103.  
  104.     cursor.marshal('O', encapsulation.data())
  105.     return
  106.  
  107.     def _fnorb_unmarshal(self, cursor):
  108.     """ Unmarshal the structure from an octet stream. """
  109.  
  110.     self.tag = cursor.unmarshal('L')
  111.  
  112.     # The profile data is an encapsulation.
  113.     encapsulation = OctetStream.Encapsulation(cursor.unmarshal('O'))
  114.     encapsulation_cursor = encapsulation.cursor()
  115.  
  116.     if self.tag == TAG_INTERNET_IOP:
  117.         tc = CORBA.typecode('IDL:omg.org/IIOP/ProfileBody:1.0')
  118.         self.profile_data = tc._fnorb_unmarshal_value(encapsulation_cursor)
  119.         
  120.     elif self.tag == TAG_MULTIPLE_COMPONENTS:
  121.         tc = CORBA.typecode('IDL:omg.org/IOP/TaggedComponent:1.0')
  122.         self.profile_data = [] # [TaggedComponent]
  123.         for i in range(encapsulation_cursor.unmarshal('L')):
  124.         component = tc._fnorb_unmarshal_value(encapsulation_cursor)
  125.         self.profile_data.append(component)
  126.  
  127.     else:
  128.         # Unknown profile, simply store it
  129.         self.profile_data = encapsulation
  130.  
  131.     return
  132.  
  133. TypeManager.TypeManager_init().add_type("IDL:omg.org/IOP/TaggedProfile:1.0", "000000000000000F000000B8000000000000002249444C3A6F6D672E6F72672F494F502F54616767656450726F66696C653A312E300000000000000E54616767656450726F66696C65000000000000020000000474616700000000150000003C000000000000001E49444C3A6F6D672E6F72672F494F502F50726F66696C6549643A312E300000000000000A50726F66696C654964000000000000050000000D70726F66696C655F6461746100000000000000130000000C000000000000000A00000000", TaggedProfile)
  134.  
  135. class IOR:
  136.     """ Struct: IDL:omg.org/IOP/IOR:1.0 """
  137.  
  138.     _FNORB_ID = "IDL:omg.org/IOP/IOR:1.0"
  139.  
  140.     # Custom default parameters used to create a 'nil' object reference.
  141.     def __init__(self, _type_id='', _profiles=[]):
  142.         """ Constructor. """
  143.  
  144.         self.type_id = _type_id
  145.         self.profiles = _profiles
  146.  
  147.         return
  148.  
  149.     def __getinitargs__(self):
  150.         """ Return the constructor arguments for unpickling. """
  151.  
  152.         return (self.type_id, self.profiles)
  153.  
  154.     def _fnorb_from_string(self, stringified_ior):
  155.     """ Initialise the IOR instance from the stringified IOR. """
  156.  
  157.     # Get rid of any dubious (and technically illegal) characters at the
  158.     # start of the IOR (apparently some Java ORBs do this 8^()
  159.     stringified_ior = stringified_ior[string.find(stringified_ior,"IOR:"):]
  160.  
  161.     # Get rid of any whitespace around the IOR (we're a pretty tolerant
  162.     # bunch round here ;^).
  163.     stringified_ior = string.strip(stringified_ior)
  164.  
  165.     # The first four characters MUST be 'IOR:'!
  166.     if stringified_ior[:4] != 'IOR:':
  167.         raise CORBA.INV_OBJREF() # System exception.
  168.  
  169.     # Convert the rest of the stringified IOR from ASCII into an octet
  170.     # stream (ie. a sequence of octets). Each pair of ASCII characters
  171.     # makes a single octet.
  172.     octets = cdr.ASCII_to_octet(stringified_ior[4:])
  173.  
  174.     # The IOR is contained in a CORBA 'encapsulation'.
  175.     octet_stream = OctetStream.Encapsulation(octets)
  176.     cursor = octet_stream.cursor()
  177.  
  178.     # Unmarshal the IOR from the encapsulation.
  179.     self._fnorb_unmarshal(cursor)
  180.     
  181.     return
  182.  
  183.     def _fnorb_to_string(self):
  184.     """ Convert the IOR instance into a stringified object reference. """
  185.  
  186.     # The IOR is marshalled into a CORBA 'encapsulation'.
  187.     encapsulation = OctetStream.Encapsulation()
  188.     cursor = encapsulation.cursor()
  189.  
  190.     # Marshal the IOR into the encapsulation.
  191.     self._fnorb_marshal(cursor)
  192.  
  193.     # Convert the octet stream into an ASCII string.  Each octet is
  194.     # represented by a pair of ASCII characters.
  195.     stringified_ior = cdr.octet_to_ASCII(encapsulation.data())
  196.  
  197.     return 'IOR:' + stringified_ior
  198.  
  199.     def _fnorb_iiop_profile(self):
  200.     """ Return the IOR's IIOP profile. """
  201.  
  202.     # Fnorb can only deal with IOR's that come from ORB's that support
  203.     # IIOP!  If the IOR does NOT contain an IIOP profile, then raise an
  204.     # appropriate system exception.
  205.     for p in self.profiles:
  206.         if p.tag == TAG_INTERNET_IOP:
  207.         break
  208.     else:
  209.         raise CORBA.INV_OBJREF() # System exception.
  210.  
  211.     return p.profile_data
  212.  
  213.     def _fnorb_marshal(self, cursor):
  214.         """ Marshal the structure onto an octet stream. """
  215.  
  216.         cursor.marshal('s', self.type_id)
  217.         cursor.marshal('L', len(self.profiles))
  218.         for i0 in range(len(self.profiles)):
  219.             self.profiles[i0]._fnorb_marshal(cursor)
  220.  
  221.         return
  222.  
  223.     def _fnorb_unmarshal(self, cursor):
  224.         """ Unmarshal the structure from an octet stream. """
  225.  
  226.         self.type_id = cursor.unmarshal('s')
  227.         self.profiles = []
  228.         for i0 in range(cursor.unmarshal('L')):
  229.             self.profiles_i0 = new.instance(TaggedProfile, {})
  230.         self.profiles_i0._fnorb_unmarshal(cursor)
  231.         self.profiles.append(self.profiles_i0)
  232.  
  233.     return
  234.  
  235. TypeManager.TypeManager_init().add_type("IDL:omg.org/IOP/IOR:1.0", "000000000000000F00000120000000000000001849444C3A6F6D672E6F72672F494F502F494F523A312E300000000004494F52000000000200000008747970655F69640000000012000000000000000970726F66696C65730000000000000013000000C8000000000000000F000000B8000000000000002249444C3A6F6D672E6F72672F494F502F54616767656450726F66696C653A312E300000000000000E54616767656450726F66696C65000000000000020000000474616700000000150000003C000000000000001E49444C3A6F6D672E6F72672F494F502F50726F66696C6549643A312E300000000000000A50726F66696C654964000000000000050000000D70726F66696C655F6461746100000000000000130000000C000000000000000A0000000000000000", IOR)
  236.  
  237. # Alias: IDL:omg.org/IOP/ComponentId:1.0
  238. TypeManager.TypeManager_init().add_type("IDL:omg.org/IOP/ComponentId:1.0", "0000000000000005", None)
  239.  
  240.  
  241. class TaggedComponent:
  242.     """ Struct: IDL:omg.org/IOP/TaggedComponent:1.0 """
  243.  
  244.     _FNORB_ID = "IDL:omg.org/IOP/TaggedComponent:1.0"
  245.  
  246.     def __init__(self, _tag, _component_data):
  247.         """ Constructor. """
  248.  
  249.         self.tag = _tag
  250.         self.component_data = _component_data
  251.         return
  252.  
  253.     def __getinitargs__(self):
  254.         """ Return the constructor arguments for unpickling. """
  255.  
  256.         return (self.tag, self.component_data)
  257.  
  258.  
  259. TypeManager.TypeManager_init().add_type("IDL:omg.org/IOP/TaggedComponent:1.0", "000000000000000F000000B8000000000000002449444C3A6F6D672E6F72672F494F502F546167676564436F6D706F6E656E743A312E300000000010546167676564436F6D706F6E656E7400000000020000000474616700000000150000003C000000000000002049444C3A6F6D672E6F72672F494F502F436F6D706F6E656E7449643A312E30000000000C436F6D706F6E656E74496400000000050000000F636F6D706F6E656E745F646174610000000000130000000C000000000000000A00000000", TaggedComponent)
  260.  
  261. # Alias: IDL:omg.org/IOP/MultipleComponentProfile:1.0
  262. TypeManager.TypeManager_init().add_type("IDL:omg.org/IOP/MultipleComponentProfile:1.0", "0000000000000013000000C8000000000000000F000000B8000000000000002449444C3A6F6D672E6F72672F494F502F546167676564436F6D706F6E656E743A312E300000000010546167676564436F6D706F6E656E7400000000020000000474616700000000150000003C000000000000002049444C3A6F6D672E6F72672F494F502F436F6D706F6E656E7449643A312E30000000000C436F6D706F6E656E74496400000000050000000F636F6D706F6E656E745F646174610000000000130000000C000000000000000A0000000000000000", None)
  263.  
  264. # Alias: IDL:omg.org/IOP/ServiceId:1.0
  265. TypeManager.TypeManager_init().add_type("IDL:omg.org/IOP/ServiceId:1.0", "0000000000000005", None)
  266.  
  267.  
  268. class ServiceContext:
  269.     """ Struct: IDL:omg.org/IOP/ServiceContext:1.0 """
  270.  
  271.     _FNORB_ID = "IDL:omg.org/IOP/ServiceContext:1.0"
  272.  
  273.     def __init__(self, _context_id, _context_data):
  274.         """ Constructor. """
  275.  
  276.         self.context_id = _context_id
  277.         self.context_data = _context_data
  278.         return
  279.  
  280.     def __getinitargs__(self):
  281.         """ Return the constructor arguments for unpickling. """
  282.  
  283.         return (self.context_id, self.context_data)
  284.  
  285. TypeManager.TypeManager_init().add_type("IDL:omg.org/IOP/ServiceContext:1.0", "000000000000000F000000C0000000000000002349444C3A6F6D672E6F72672F494F502F53657276696365436F6E746578743A312E3000000000000F53657276696365436F6E746578740000000000020000000B636F6E746578745F69640000000000150000003C000000000000001E49444C3A6F6D672E6F72672F494F502F5365727669636549643A312E300000000000000A536572766963654964000000000000050000000D636F6E746578745F6461746100000000000000130000000C000000000000000A00000000", ServiceContext)
  286.  
  287. # Alias: IDL:omg.org/IOP/ServiceContextList:1.0
  288. TypeManager.TypeManager_init().add_type("IDL:omg.org/IOP/ServiceContextList:1.0", "0000000000000013000000D0000000000000000F000000C0000000000000002349444C3A6F6D672E6F72672F494F502F53657276696365436F6E746578743A312E3000000000000F53657276696365436F6E746578740000000000020000000B636F6E746578745F69640000000000150000003C000000000000001E49444C3A6F6D672E6F72672F494F502F5365727669636549643A312E300000000000000A536572766963654964000000000000050000000D636F6E746578745F6461746100000000000000130000000C000000000000000A0000000000000000", None)
  289.  
  290. # Constant: IDL:omg.org/IOP/TransactionService:1.0
  291. TransactionService = 0L
  292.  
  293. TypeManager.TypeManager_init().add_type("IDL:omg.org/IOP/TransactionService:1.0", "0000000000000005", TransactionService)
  294.  
  295. # Constant: IDL:omg.org/IOP/CodeSets:1.0
  296. CodeSets = 1L
  297.  
  298. TypeManager.TypeManager_init().add_type("IDL:omg.org/IOP/CodeSets:1.0", "0000000000000005", CodeSets)
  299.  
  300. #############################################################################
  301.