home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 10 Tools / 10-Tools.zip / fnb101.zip / Lib / site-packages / Fnorb / cos / naming / BindingIterator.py next >
Text File  |  1999-06-28  |  4KB  |  166 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/cos/naming/RCS/BindingIterator.py,v $
  31. # Version:      @(#)$RCSfile: BindingIterator.py,v $ $Revision: 1.7 $
  32. #
  33. #############################################################################
  34. """ Cos Naming Service Binding Iterators. """
  35.  
  36.  
  37. # Fnorb modules.
  38. from Fnorb.orb import fnorb_thread, BOA
  39.  
  40. # Types.
  41. import CosNaming
  42.  
  43. # Server skeleton.
  44. import CosNaming_skel
  45.  
  46.  
  47. def BindingIteratorFactory_init():
  48.     """ Initialise the Binding Iterator Factory.
  49.  
  50.     This is a factory function for the BindingIteratorFactory class (the 
  51.     factory is a singleton (ie. there can only be one instance per process)).
  52.  
  53.     """
  54.     try:
  55.     bif = BindingIteratorFactory()
  56.  
  57.     except BindingIteratorFactory, bif:
  58.     pass
  59.  
  60.     return bif
  61.  
  62.  
  63. class BindingIteratorFactory:
  64.     """ Factory for binding iterators.
  65.  
  66.     The factory is a singleton (ie. there can only be one instance per
  67.     process).
  68.  
  69.     """
  70.     # Singleton instance.
  71.     __instance = None
  72.  
  73.     def __init__(self):
  74.     """ Constructor. """
  75.  
  76.     # The factory is a singleton (ie. there can only be one instance per
  77.     # process).
  78.     if BindingIteratorFactory.__instance is not None:
  79.         raise BindingIteratorFactory.__instance
  80.  
  81.     BindingIteratorFactory.__instance = self
  82.  
  83.     return
  84.  
  85.     def create_binding_iterator(self, bindings):
  86.     """ Create a new binding iterator instance. """
  87.  
  88.     # Create the instance.
  89.     impl = BindingIterator(bindings)
  90.  
  91.     # Create an object reference with a 'random' object key.
  92.     boa = BOA.BOA_init()
  93.     obj = boa.create(str(id(impl)), BindingIterator._FNORB_ID)
  94.  
  95.     # Activate the implementation (ie. connect the generated object
  96.     # reference to the implementation).
  97.     boa.obj_is_ready(obj, impl)
  98.  
  99.     return obj
  100.  
  101.  
  102. class BindingIterator(CosNaming_skel.BindingIterator_skel):
  103.     """ Binding Iterator. """
  104.  
  105.     def __init__(self, bindings):
  106.     """ Constructor. """
  107.  
  108.     self.__bindings = bindings
  109.     self.__index = 0
  110.  
  111.     # Mutex to make access to the list of bindings safe in threaded
  112.     # environments.
  113.     self.__lk = fnorb_thread.allocate_lock()
  114.  
  115.     return
  116.  
  117.     def __del__(self):
  118.     pass
  119.  
  120.     def next_one(self):
  121.     """ Return the next binding. """
  122.  
  123.     self.__lk.acquire()
  124.     if self.__index >= len(self.__bindings):
  125.         result = 0
  126.         binding = self.__bindings[-1]
  127.  
  128.     else:
  129.         result = 1
  130.         binding = self.__bindings[self.__index]
  131.         self.__index = self.__index + 1
  132.     self.__lk.release()
  133.  
  134.     return (result, binding)
  135.  
  136.     def next_n(self, how_many):
  137.     """ Return the next 'how_many' bindings. """
  138.  
  139.     self.__lk.acquire()
  140.     if self.__index >= len(self.__bindings):
  141.         result = 0
  142.         binding_list = []
  143.  
  144.     else:
  145.         result = 1
  146.         binding_list = self.__bindings[self.__index:self.__index+how_many]
  147.         self.__index = self.__index + how_many
  148.     self.__lk.release()
  149.  
  150.     return (result, binding_list)
  151.  
  152.     def destroy(self):
  153.     """ Destroy the iterator. """
  154.  
  155.     self.__lk.acquire()
  156.     del self.__bindings
  157.     self.__lk.release()
  158.  
  159.     # Disconnect the implementation from the BOA.
  160.     boa = BOA.BOA_init()
  161.     boa.deactivate_obj(self)
  162.  
  163.     return
  164.  
  165. #############################################################################
  166.