docs: def _ensureAtomicity(fn):
      """Ensure atomicity of passed elements on the whole worker pool"""
      @ensureScoopStartedProperly
      def wrapper(*args, **kwargs):
          """setConst(**kwargs)
          Set a constant that will be shared to every workers.
          This call blocks until the constant has propagated to at least one
          worker.
  
          :param \*\*kwargs: One or more combination(s) key=value. Key being the
              variable name and value the object to share.
  
          :returns: None.
  
          Usage: setConst(name=value)
          """
          # Note that the docstring is the one of setConst.
          # This is because of the documentation framework (sphinx) limitations.
  
          from . import _control
  
          # Enforce retrieval of currently awaiting constants
          _control.execQueue.socket.pumpInfoSocket()
  
          for key, value in kwargs.items():
              # Object name existence check
              if key in itertools.chain(*(elem.keys() for elem in elements.values())):
                  raise TypeError("This constant already exists: {0}.".format(key))
  
          # Retry element propagation until it is returned
          while all(key in elements.get(scoop.worker, []) for key in kwargs.keys()) is not True:
              scoop.logger.debug("Sending global variables {0}...".format(
                  list(kwargs.keys())
              ))
              # Call the function
              fn(*args, **kwargs)
  
              # Enforce retrieval of currently awaiting constants
              _control.execQueue.socket.pumpInfoSocket()
  
              # TODO: Make previous blocking instead of sleep
              time.sleep(0.1)
  
          # Atomicity check
          elementNames = list(itertools.chain(*(elem.keys() for elem in elements.values())))
          if len(elementNames) != len(set(elementNames)):
              raise TypeError("This constant already exists: {0}.".format(key))
  
      return wrapper