def METHOD_NAME(self):
    error.context("Migration from %s to %s over protocol %s." %
                  (self.srchost, self.dsthost, mig_protocol),
                  logging.info)
    sync = SyncData(self.master_id(), self.hostid, self.hosts,
                    self.id, self.sync_server)
    def start_worker(mig_data):
        """
        force the Linux kernel to crash on src before migration
        :param mig_data: Data for migration
        """
        self.start_worker_guest_kdump(mig_data, self.login_timeout,
                                      self.crash_kernel_prob_cmd,
                                      self.kernel_param_cmd,
                                      self.kdump_enable_cmd,
                                      self.nvcpu,
                                      self.crash_cmd)
    def check_worker(mig_data):
        """
        check weather generate vmcore file on dst after migration
        :param mig_data: Data for migration
        """
        self.check_worker_kdump(mig_data, self.vmcore_chk_cmd,
                                self.vmcore_incomplete)
    super(TestMultihostMigration, self).ping_pong_migrate(
        mig_type, sync, start_worker, check_worker)