Synnefo » snf-ganeti

from ganeti import errors

               beparams, osparams, nics, opportunistic_tries,

               opportunistic_delay):

    @type opportunistic_tries: int or None

    @param opportunistic_tries: Number of opportunistic creation attempts to

                                perform

    @type opportunistic_delay: int or None

    @param opportunistic_delay: Delay between successive creation attempts, in

                                seconds

    if opportunistic_tries is not None:

      self.opportunistic_tries = opportunistic_tries

    else:

      self.opportunistic_tries = 0

    if opportunistic_delay is not None:

      self.opportunistic_delay = opportunistic_delay

    else:

      self.opportunistic_delay = constants.DEFAULT_OPPORTUNISTIC_RETRY_INTERVAL

    # Depending on whether opportunistic tries are enabled, we may have to

    # make multiple creation attempts

    creation_attempts = [True] * mrt.move.opportunistic_tries

    # But the last one is never opportunistic, and will block until completion

    # or failure

    creation_attempts.append(False)

    for is_attempt_opportunistic in creation_attempts:

      job_id = self._CreateInstance(dest_client, mrt.move.dest_instance_name,

                                    mrt.move.dest_pnode, mrt.move.dest_snode,

                                    mrt.move.compress,

                                    mrt.move.dest_iallocator,

                                    mrt.move.dest_disk_template,

                                    mrt.src_instinfo, mrt.src_expinfo,

                                    mrt.move.hvparams, mrt.move.beparams,

                                    mrt.move.beparams, mrt.move.nics,

                                    is_attempt_opportunistic

                                    )

      try:

        # The completion of this block signifies that the import has been

        # completed successfullly

        mrt.PollJob(dest_client, job_id,

                    remote_import_fn=compat.partial(self._SetImportInfo, mrt))

        logging.info("Import successful")

        return

      except errors.OpPrereqError, err:

        # Any exception in the non-opportunistic creation is to be passed on,

        # as well as exceptions apart from resources temporarily unavailable

        if not is_attempt_opportunistic or \

           err.args[1] != rapi.client.ECODE_TEMP_NORES:

          raise

      logging.info("Opportunistic attempt unsuccessful, waiting %d seconds"

                   " before another creation attempt is made",

                   mrt.move.opportunistic_delay)

      time.sleep(mrt.move.opportunistic_delay)

                      override_beparams, override_osparams, override_nics,

                      is_attempt_opportunistic):

    @type is_attempt_opportunistic: bool

    @param is_attempt_opportunistic: Whether to use opportunistic locking or not

                                                       override_osparams),

                             opportunistic_locking=is_attempt_opportunistic

                             )

                              options.nics,

                              options.opportunistic_tries,

                              options.opportunistic_delay))