Async.py

Go to the documentation of this file.

#
# Copyright 2009, MeVis Medical Solutions AG
#
# The user may use this file in accordance with the license agreement provided with
# the Software or, alternatively, in accordance with the terms contained in a
# written agreement between the user and MeVis Medical Solutions AG.
#
# For further information use the contact form at https://www.mevislab.de/contact
#
 
 
 
# -- system imports ----------------------------------------------------------------------------{{{-
# ----------------------------------------------------------------------------------------------}}}-
 
# -- local imports -----------------------------------------------------------------------------{{{-
import mevis
from . import Base, Logging
# ----------------------------------------------------------------------------------------------}}}-
 
# -- global variables --------------------------------------------------------------------------{{{-
 
gFinished = None
# ----------------------------------------------------------------------------------------------}}}-
 
# -- def waitForModules ------------------------------------------------------------------------{{{-
 
def waitForModules (moduleList):
  for module in moduleList:
    waitForModule(module)
# ----------------------------------------------------------------------------------------------}}}-
 
# -- def waitForModule -------------------------------------------------------------------------{{{-
 
def waitForModule (module):
  global gFinished
  context = Base.getTestCaseContext()
 
  fldRunning = context.field("%s.taskRunning" % (module))
  fldFinished = context.field("%s.taskFinished" % (module))
 
  if not (fldRunning and fldFinished):
    Logging.warning("Module %s has either no field taskFinished or no field taskRunning." % (module))
    return
 
  # Task not running.
  if not fldRunning.value:
    return
 
  Logging.info("Waiting for module %s to finish processing its background task." % (module))
 
  gFinished = False
  fldListener = context.addFieldListener(fldFinished, "Async.setFinished", False)
  while not gFinished:
    mevis.MLAB.processEvents()
  context.removeFieldListener(fldListener)
# ----------------------------------------------------------------------------------------------}}}-
 
# -- def setFinished # -------------------------------------------------------------------------{{{-
 
def setFinished ():
  global gFinished
  gFinished = True
# ----------------------------------------------------------------------------------------------}}}-