openstack中的rpc遠程調(diào)用的方法

class LiveMigrationTask(base.TaskBase):
    def __init__(self, context, instance, destination,
                 block_migration, disk_over_commit, migration, compute_rpcapi,
                 servicegroup_api, scheduler_client):
        super(LiveMigrationTask, self).__init__(context, instance)
    ... 

    def _execute(self):
        self._check_instance_is_active()
        self._check_host_is_up(self.source)

        if not self.destination:
            self.destination = self._find_destination()
            self.migration.dest_compute = self.destination
            self.migration.save()
        else:
            self._check_requested_destination()

        # TODO(johngarbutt) need to move complexity out of compute manager
        # TODO(johngarbutt) disk_over_commit?

        #調(diào)用 ComputeAPI 類中的 live_migration() RPC接口
        return self.compute_rpcapi.live_migration(self.context,
                host=self.source,
                instance=self.instance,
                dest=self.destination,
                block_migration=self.block_migration,
                migration=self.migration,
                migrate_data=self.migrate_data)

class ComputeAPI(object):

    # 這是一個RPC遠程調(diào)用的方法
    def live_migration(self, ctxt, instance, dest, block_migration, host,
                       migration, migrate_data=None):
        args = {'migration': migration}
        version = '4.2'
        if not self.client.can_send_version(version):
            version = '4.0'

        # 獲取目標 compute 主機(DEST HOST)的RPC client，即被調(diào)用的服務進程的HostIP
        cctxt = self.client.prepare(server=host, version=version)

        # 通過目標主機對象的 RPC cliient 來調(diào)用遠程過程方法 cast() ，以此來實現(xiàn)遠程調(diào)用
        cctxt.cast(ctxt, 'live_migration', instance=instance,
                   dest=dest, block_migration=block_migration,
                   migrate_data=migrate_data, **args)
        # cast()異步遠程調(diào)用，不會阻塞別的進程，適合于需要長時間進行的執(zhí)行過程
        # cast()的第二個參數(shù)是RPC client調(diào)用的函數(shù)名，case()后面的參數(shù)會繼續(xù)作為參數(shù)傳入該調(diào)用函數(shù)
        # cast()函數(shù)內(nèi)的live_migration()函數(shù)是 manager.live_migration() 視具體實現(xiàn)遷移功能的函數(shù)，在manager.py內(nèi)實現(xiàn)。

@wrap_exception()
    @wrap_instance_event(prefix='compute')
    @wrap_instance_fault
    def live_migration(self, context, dest, instance, block_migration,
                       migration, migrate_data):
        """執(zhí)行實時遷移。

        :param context: security context
        :param dest: destination host
        :param instance: a nova.objects.instance.Instance object
        :param block_migration: if true, prepare for block migration
        :param migration: an nova.objects.Migration object
        :param migrate_data: implementation specific params

        """
        self._set_migration_status(migration, 'queued')

        def dispatch_live_migration(*args, **kwargs):
            with self._live_migration_semaphore:
                # 調(diào)用_do_live_migration執(zhí)行遷移
                self._do_live_migration(*args, **kwargs)

        # NOTE(danms): We spawn here to return the RPC worker thread back to
        # the pool. Since what follows could take a really long time, we don't
        # want to tie up RPC workers.
        utils.spawn_n(dispatch_live_migration,
                      context, dest, instance,
                      block_migration, migration,
                      migrate_data)