Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

Repository URL to install this package:

Details    
Size: Mime:
ó
±EYc@sdZddlmZddlZddlmZddlZ	ddl	m
Z
ddl	mZddlm
Z
mZmZddl	mZdd	lmZdd
lmZddlmZddl	mZe	jjZejeƒZdad
„Z de!fd„ƒYZ"dS(s%
Client side of the compute RPC API.
iÿÿÿÿ(tlogN(t	jsonutils(tcontext(t	exception(t_t_LIt_LE(tobjects(tbase(tmigrate_data(tservice(trpccCsW|r
|S|s(tjtdƒƒ‚n|jsPtjtdƒ|jƒ‚n|jS(sàGet the destination host for a message.

    :param host: explicit host to send the message to.
    :param instance: If an explicit host was not specified, use
                     instance['host']

    :returns: A host
    sNo compute host specifieds#Unable to find host for Instance %s(Rt
NovaExceptionRthosttuuid(R
tinstance((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyt
_compute_host&s		t
ComputeAPIc	BsmeZdZidd6dd6dd6dd6d	d
6Zd„Zd„Zd
„Zed„Zd„Z	d„Z
d„Zd„Zd„Z
d„Zed„Zeed„Zd„Zed„Zed„Zed„Zd„Zd„Zd„Zd„Zd„Zd „Zd!„Zd"„Zd#„Zd$„Zd%„Z d&„Z!d'„Z"d(„Z#ed)„Z$d*„Z%d+„Z&d,„Z'd-„Z(ed.„Z)eeeeed/„Z*d0„Z+e,e,eee,eeed1„Z-ed2„Z.d3„Z/d4„Z0eed5„Z1d6„Z2eed7„Z3d8„Z4ed9„Z5eed:„Z6d;„Z7d<„Z8d=„Z9d>„Z:eed?„Z;d@„Z<dA„Z=dB„Z>eedC„Z?dD„Z@eedE„ZAdF„ZBdG„ZCedH„ZDdI„ZEeedJ„ZFedK„ZGeeedL„ZHdM„ZIdN„ZJedO„ZKeeeeeeedP„ZLdQ„ZMedR„ZNdS„ZOdT„ZPRS(Usy7Client side of the compute rpc API.

    API version history:

        * 1.0 - Initial version.
        * 1.1 - Adds get_host_uptime()
        * 1.2 - Adds check_can_live_migrate_[destination|source]
        * 1.3 - Adds change_instance_metadata()
        * 1.4 - Remove instance_uuid, add instance argument to
                reboot_instance()
        * 1.5 - Remove instance_uuid, add instance argument to
                pause_instance(), unpause_instance()
        * 1.6 - Remove instance_uuid, add instance argument to
                suspend_instance()
        * 1.7 - Remove instance_uuid, add instance argument to
                get_console_output()
        * 1.8 - Remove instance_uuid, add instance argument to
                add_fixed_ip_to_instance()
        * 1.9 - Remove instance_uuid, add instance argument to attach_volume()
        * 1.10 - Remove instance_id, add instance argument to
                 check_can_live_migrate_destination()
        * 1.11 - Remove instance_id, add instance argument to
                 check_can_live_migrate_source()
        * 1.12 - Remove instance_uuid, add instance argument to
                 confirm_resize()
        * 1.13 - Remove instance_uuid, add instance argument to detach_volume()
        * 1.14 - Remove instance_uuid, add instance argument to finish_resize()
        * 1.15 - Remove instance_uuid, add instance argument to
                 finish_revert_resize()
        * 1.16 - Remove instance_uuid, add instance argument to
                 get_diagnostics()
        * 1.17 - Remove instance_uuid, add instance argument to
                 get_vnc_console()
        * 1.18 - Remove instance_uuid, add instance argument to inject_file()
        * 1.19 - Remove instance_uuid, add instance argument to
                 inject_network_info()
        * 1.20 - Remove instance_id, add instance argument to
                 post_live_migration_at_destination()
        * 1.21 - Remove instance_uuid, add instance argument to
                 power_off_instance() and stop_instance()
        * 1.22 - Remove instance_uuid, add instance argument to
                 power_on_instance() and start_instance()
        * 1.23 - Remove instance_id, add instance argument to
                 pre_live_migration()
        * 1.24 - Remove instance_uuid, add instance argument to
                 rebuild_instance()
        * 1.25 - Remove instance_uuid, add instance argument to
                 remove_fixed_ip_from_instance()
        * 1.26 - Remove instance_id, add instance argument to
                 remove_volume_connection()
        * 1.27 - Remove instance_uuid, add instance argument to
                 rescue_instance()
        * 1.28 - Remove instance_uuid, add instance argument to reset_network()
        * 1.29 - Remove instance_uuid, add instance argument to
                 resize_instance()
        * 1.30 - Remove instance_uuid, add instance argument to
                 resume_instance()
        * 1.31 - Remove instance_uuid, add instance argument to revert_resize()
        * 1.32 - Remove instance_id, add instance argument to
                 rollback_live_migration_at_destination()
        * 1.33 - Remove instance_uuid, add instance argument to
                 set_admin_password()
        * 1.34 - Remove instance_uuid, add instance argument to
                 snapshot_instance()
        * 1.35 - Remove instance_uuid, add instance argument to
                 unrescue_instance()
        * 1.36 - Remove instance_uuid, add instance argument to
                 change_instance_metadata()
        * 1.37 - Remove instance_uuid, add instance argument to
                 terminate_instance()
        * 1.38 - Changes to prep_resize():
            * remove instance_uuid, add instance
            * remove instance_type_id, add instance_type
            * remove topic, it was unused
        * 1.39 - Remove instance_uuid, add instance argument to run_instance()
        * 1.40 - Remove instance_id, add instance argument to live_migration()
        * 1.41 - Adds refresh_instance_security_rules()
        * 1.42 - Add reservations arg to prep_resize(), resize_instance(),
                 finish_resize(), confirm_resize(), revert_resize() and
                 finish_revert_resize()
        * 1.43 - Add migrate_data to live_migration()
        * 1.44 - Adds reserve_block_device_name()

        * 2.0 - Remove 1.x backwards compat
        * 2.1 - Adds orig_sys_metadata to rebuild_instance()
        * 2.2 - Adds slave_info parameter to add_aggregate_host() and
                remove_aggregate_host()
        * 2.3 - Adds volume_id to reserve_block_device_name()
        * 2.4 - Add bdms to terminate_instance
        * 2.5 - Add block device and network info to reboot_instance
        * 2.6 - Remove migration_id, add migration to resize_instance
        * 2.7 - Remove migration_id, add migration to confirm_resize
        * 2.8 - Remove migration_id, add migration to finish_resize
        * 2.9 - Add publish_service_capabilities()
        * 2.10 - Adds filter_properties and request_spec to prep_resize()
        * 2.11 - Adds soft_delete_instance() and restore_instance()
        * 2.12 - Remove migration_id, add migration to revert_resize
        * 2.13 - Remove migration_id, add migration to finish_revert_resize
        * 2.14 - Remove aggregate_id, add aggregate to add_aggregate_host
        * 2.15 - Remove aggregate_id, add aggregate to remove_aggregate_host
        * 2.16 - Add instance_type to resize_instance
        * 2.17 - Add get_backdoor_port()
        * 2.18 - Add bdms to rebuild_instance
        * 2.19 - Add node to run_instance
        * 2.20 - Add node to prep_resize
        * 2.21 - Add migrate_data dict param to pre_live_migration()
        * 2.22 - Add recreate, on_shared_storage and host arguments to
                 rebuild_instance()
        * 2.23 - Remove network_info from reboot_instance
        * 2.24 - Added get_spice_console method
        * 2.25 - Add attach_interface() and detach_interface()
        * 2.26 - Add validate_console_port to ensure the service connects to
                 vnc on the correct port
        * 2.27 - Adds 'reservations' to terminate_instance() and
                 soft_delete_instance()

        ... Grizzly supports message version 2.27.  So, any changes to existing
        methods in 2.x after that point should be done such that they can
        handle the version_cap being set to 2.27.

        * 2.28 - Adds check_instance_shared_storage()
        * 2.29 - Made start_instance() and stop_instance() take new-world
                 instance objects
        * 2.30 - Adds live_snapshot_instance()
        * 2.31 - Adds shelve_instance(), shelve_offload_instance, and
                 unshelve_instance()
        * 2.32 - Make reboot_instance take a new world instance object
        * 2.33 - Made suspend_instance() and resume_instance() take new-world
                 instance objects
        * 2.34 - Added swap_volume()
        * 2.35 - Made terminate_instance() and soft_delete_instance() take
                 new-world instance objects
        * 2.36 - Made pause_instance() and unpause_instance() take new-world
                 instance objects
        * 2.37 - Added the legacy_bdm_in_spec parameter to run_instance
        * 2.38 - Made check_can_live_migrate_[destination|source] take
                 new-world instance objects
        * 2.39 - Made revert_resize() and confirm_resize() take new-world
                 instance objects
        * 2.40 - Made reset_network() take new-world instance object
        * 2.41 - Make inject_network_info take new-world instance object
        * 2.42 - Splits snapshot_instance() into snapshot_instance() and
                 backup_instance() and makes them take new-world instance
                 objects.
        * 2.43 - Made prep_resize() take new-world instance object
        * 2.44 - Add volume_snapshot_create(), volume_snapshot_delete()
        * 2.45 - Made resize_instance() take new-world objects
        * 2.46 - Made finish_resize() take new-world objects
        * 2.47 - Made finish_revert_resize() take new-world objects

        ... Havana supports message version 2.47.  So, any changes to existing
        methods in 2.x after that point should be done such that they can
        handle the version_cap being set to 2.47.

        * 2.48 - Make add_aggregate_host() and remove_aggregate_host() take
          new-world objects
        * ... - Remove live_snapshot() that was never actually used

        * 3.0 - Remove 2.x compatibility
        * 3.1 - Update get_spice_console() to take an instance object
        * 3.2 - Update get_vnc_console() to take an instance object
        * 3.3 - Update validate_console_port() to take an instance object
        * 3.4 - Update rebuild_instance() to take an instance object
        * 3.5 - Pass preserve_ephemeral flag to rebuild_instance()
        * 3.6 - Make volume_snapshot_{create,delete} use new-world objects
        * 3.7 - Update change_instance_metadata() to take an instance object
        * 3.8 - Update set_admin_password() to take an instance object
        * 3.9 - Update rescue_instance() to take an instance object
        * 3.10 - Added get_rdp_console method
        * 3.11 - Update unrescue_instance() to take an object
        * 3.12 - Update add_fixed_ip_to_instance() to take an object
        * 3.13 - Update remove_fixed_ip_from_instance() to take an object
        * 3.14 - Update post_live_migration_at_destination() to take an object
        * 3.15 - Adds filter_properties and node to unshelve_instance()
        * 3.16 - Make reserve_block_device_name and attach_volume use new-world
                 objects, and add disk_bus and device_type params to
                 reserve_block_device_name, and bdm param to attach_volume
        * 3.17 - Update attach_interface and detach_interface to take an object
        * 3.18 - Update get_diagnostics() to take an instance object
            * Removed inject_file(), as it was unused.
        * 3.19 - Update pre_live_migration to take instance object
        * 3.20 - Make restore_instance take an instance object
        * 3.21 - Made rebuild take new-world BDM objects
        * 3.22 - Made terminate_instance take new-world BDM objects
        * 3.23 - Added external_instance_event()
            * build_and_run_instance was added in Havana and not used or
              documented.

        ... Icehouse supports message version 3.23.  So, any changes to
        existing methods in 3.x after that point should be done such that they
        can handle the version_cap being set to 3.23.

        * 3.24 - Update rescue_instance() to take optional rescue_image_ref
        * 3.25 - Make detach_volume take an object
        * 3.26 - Make live_migration() and
          rollback_live_migration_at_destination() take an object
        * ... Removed run_instance()
        * 3.27 - Make run_instance() accept a new-world object
        * 3.28 - Update get_console_output() to accept a new-world object
        * 3.29 - Make check_instance_shared_storage accept a new-world object
        * 3.30 - Make remove_volume_connection() accept a new-world object
        * 3.31 - Add get_instance_diagnostics
        * 3.32 - Add destroy_disks and migrate_data optional parameters to
                 rollback_live_migration_at_destination()
        * 3.33 - Make build_and_run_instance() take a NetworkRequestList object
        * 3.34 - Add get_serial_console method
        * 3.35 - Make reserve_block_device_name return a BDM object

        ... Juno supports message version 3.35.  So, any changes to
        existing methods in 3.x after that point should be done such that they
        can handle the version_cap being set to 3.35.

        * 3.36 - Make build_and_run_instance() send a Flavor object
        * 3.37 - Add clean_shutdown to stop, resize, rescue, shelve, and
                 shelve_offload
        * 3.38 - Add clean_shutdown to prep_resize
        * 3.39 - Add quiesce_instance and unquiesce_instance methods
        * 3.40 - Make build_and_run_instance() take a new-world topology
                 limits object

        ... Kilo supports messaging version 3.40. So, any changes to
        existing methods in 3.x after that point should be done so that they
        can handle the version_cap being set to 3.40

        ... Version 4.0 is equivalent to 3.40. Kilo sends version 4.0 by
        default, can accept 3.x calls from Juno nodes, and can be pinned to
        3.x for Juno compatibility. All new changes should go against 4.x.

        * 4.0  - Remove 3.x compatibility
        * 4.1  - Make prep_resize() and resize_instance() send Flavor object
        * 4.2  - Add migration argument to live_migration()
        * 4.3  - Added get_mks_console method
        * 4.4  - Make refresh_instance_security_rules send an instance object
        * 4.5  - Add migration, scheduler_node and limits arguments to
                 rebuild_instance()

        ... Liberty supports messaging version 4.5. So, any changes to
        existing methods in 4.x after that point should be done so that they
        can handle the version_cap being set to 4.5

        * ...  - Remove refresh_security_group_members()
        * ...  - Remove refresh_security_group_rules()
        * 4.6  - Add trigger_crash_dump()
        * 4.7  - Add attachment_id argument to detach_volume()
        * 4.8  - Send migrate_data in object format for live_migration,
                 rollback_live_migration_at_destination, and
                 pre_live_migration.
        * ...  - Remove refresh_provider_fw_rules()
        * 4.9  - Add live_migration_force_complete()
        * 4.10  - Add live_migration_abort()
        * 4.11 - Allow block_migration and disk_over_commit be None

        ... Mitaka supports messaging version 4.11. So, any changes to
        existing methods in 4.x after that point should be done so that they
        can handle the version_cap being set to 4.11

        * 4.12 - Remove migration_id from live_migration_force_complete
        * 4.13 - Make get_instance_diagnostics send an instance object
    s3.23ticehouses3.35tjunos4.0tkilos4.5tlibertys4.11tmitakacCs¤tt|ƒjƒtjdtjddƒ}tjj}|dkrX|j	|ƒ}n|j
j||ƒ}tj
ƒ}|j|||ƒ}tj|ƒ|_dS(Nttopictversions4.0tauto(tsuperRt__init__t	messagingtTargettCONFt
compute_topictupgrade_levelstcomputet_determine_version_captVERSION_ALIASEStgettobjects_basetNovaObjectSerializert
get_clientRtClientRoutertrouter(tselfttargett
upgrade_leveltversion_capt
serializertdefault_client((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRFs	cCstr
tStjjtjƒdƒ}|dkrItjdƒ|jdSt	j
}y||d}Wnztk
r¯tjt
dƒi|d6ƒtjdt	jd	|ƒ‚n2tk
ràtjt
d
ƒi|d6ƒ|jSX|atjtdƒi|d6|d
6ƒ|S(Nsnova-computeis—Not caching compute RPC version_cap, because min service_version is 0. Please ensure a nova-compute service has been started. Defaulting to Mitaka RPC.Rtcompute_rpcstFailed to extract compute RPC version from service history because I am too old (minimum version is now %(version)i)RtthisvertminversRFailed to extract compute RPC version from service history for version %(version)is[Automatically selected compute RPC version %(rpc)s from minimum service version %(service)iRR
(tLAST_VERSIONRtServicetget_minimum_versionRtget_admin_contexttLOGtdebugR#tservice_objtSERVICE_VERSION_HISTORYt
IndexErrorterrorRRt
ServiceTooOldtSERVICE_VERSIONtKeyErrorRtinfoR(R*R+tservice_versionthistoryR-((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR"Ss0	
	


cCstj|d|d|ƒS(NR-R.(RR'(R*R+R-R.((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR'{sc	CsSd}|jj||ƒjd|d|ƒ}|j|dd|d|d|ƒdS(	s&Add aggregate host.

        :param ctxt: request context
        :param aggregate:
        :param host_param: This value is placed in the message to be the 'host'
                           parameter for the remote method.
        :param host: This is the host to send the message to.
        s4.0tserverRtadd_aggregate_hostt	aggregateR
t
slave_infoN(R)tby_hosttpreparetcast(R*tctxtR
REt
host_paramRFRtcctxt((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRD€s
cCsVd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒdS(Ns4.0RCRtadd_fixed_ip_to_instanceRt
network_id(R)tby_instanceRHRtNoneRI(R*RJRRNRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRM‘s
cCs^d}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|d|d|ƒS(	Ns4.0RCRtattach_interfaceRRNtport_idtrequested_ip(R)RORHRRPtcall(R*RJRRNRRRSRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRQ˜scCsVd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒdS(Ns4.0RCRt
attach_volumeRtbdm(R)RORHRRPRI(R*RJRRVRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRU¡scCsVd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒdS(Ns4.0RCRtchange_instance_metadataRtdiff(R)RORHRRPRI(R*RJRRXRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRW§s
c

CsÊd}|jj||ƒ}|j|ƒsZ|dksB|dkrQtjƒ‚qZd}n|jd|d|ƒ}|j|dd|d|d|ƒ}	t|	t	j
ƒr¬|	S|	rÂt	j
j|	ƒS|	SdS(	Ns4.11s4.0RCRt"check_can_live_migrate_destinationRtblock_migrationtdisk_over_commit(R)RGtcan_send_versionRPRt$LiveMigrationWithOldNovaNotSupportedRHRTt
isinstancetmigrate_data_objtLiveMigrateDatatdetect_implementation(
R*RJRtdestinationRZR[RtclientRLtresult((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRY®s"			c
CsÎ|}d}|jj||ƒ}|j|ƒsNd}|rN|jƒ}qNntd|ƒ}|jd|d|ƒ}|j|dd|d|ƒ}	t|	t	j
ƒr©|	S|rÆ|	rÆ|j|	ƒ|S|	SdS(Ns4.8s4.0RCRtcheck_can_live_migrate_sourceRtdest_check_data(R)ROR\tto_legacy_dictRRPRHRTR^R_R`tfrom_legacy_dict(
R*RJRRftdest_check_data_objRRctsourceRLRd((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyReÊs$	
cCsvd}|s$|jj||ƒ}n|jj||ƒ}|jdt||ƒd|ƒ}|j|dd|d|ƒS(Ns4.0RCRtcheck_instance_shared_storageRtdata(R)RORGRHRRT(R*RJRRlR
RRcRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRkßs	c	Cs‘d}|s$|jj||ƒ}n|jj||ƒ}|jdt||ƒd|ƒ}	|ri|	jn|	j}
|
|dd|d|d|ƒS(Ns4.0RCRtconfirm_resizeRt	migrationtreservations(R)RORGRHRRIRT(R*RJRRnR
RoRIRRcRLt
rpc_method((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRmës	cCsVd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒdS(Ns4.0RCRtdetach_interfaceRRR(R)RORHRRPRI(R*RJRRRRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRqùs
c	Cs‘i|d6}d}|jj||ƒ}|j|ƒsMd}|jdƒn|jdtd|ƒd|ƒ}|j|dd|d||dS(	Nt
attachment_ids4.7s4.0RCRt
detach_volumeRt	volume_id(R)ROR\tpopRHRRPRI(	R*RJRRtRrtextraRRcRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRss
	c

Cs_d}|jj||ƒjd|d|ƒ}	|	j|dd|d|d|d|d	|ƒdS(
Ns4.0RCRt
finish_resizeRRntimaget	disk_infoRo(R)RGRHRI(
R*RJRRnRxRyR
RoRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRwsc	CsSd}|jj||ƒjd|d|ƒ}|j|dd|d|d|ƒdS(Ns4.0RCRtfinish_revert_resizeRRnRo(R)RGRHRI(R*RJRRnR
RoRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRzscCsRd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒS(Ns4.0RCRtget_console_outputRttail_length(R)RORHRRPRT(R*RJRR|RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR{s
cCsCd}|jj||ƒjd|d|ƒ}|j|dd|ƒS(Ns4.0RCRtget_console_pool_infotconsole_type(R)RGRHRT(R*RJR
R~RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR}%s
cCs=d}|jj||ƒjd|d|ƒ}|j|dƒS(Ns4.0RCRtget_console_topic(R)RGRHRT(R*RJR
RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR,scCsLd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|ƒS(Ns4.0RCRtget_diagnosticsR(R)RORHRRPRT(R*RJRRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR€2scCsyd}|jj||ƒ}|j|ƒsBd}tj|ƒ}n|jdtd|ƒd|ƒ}|j|dd|ƒS(Ns4.13s4.0RCRtget_instance_diagnosticsR(	R)ROR\R%tobj_to_primitiveRHRRPRT(R*RJRRRcRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR8s	cCsRd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒS(Ns4.0RCRtget_vnc_consoleRR~(R)RORHRRPRT(R*RJRR~RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRƒBs
cCsRd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒS(Ns4.0RCRtget_spice_consoleRR~(R)RORHRRPRT(R*RJRR~RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR„Is
cCsRd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒS(Ns4.0RCRtget_rdp_consoleRR~(R)RORHRRPRT(R*RJRR~RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR…Ps
cCsRd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒS(Ns4.3RCRtget_mks_consoleRR~(R)RORHRRPRT(R*RJRR~RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR†Ws
cCsRd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒS(Ns4.0RCRtget_serial_consoleRR~(R)RORHRRPRT(R*RJRR~RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR‡^s
c	CsXd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|d|ƒS(Ns4.0RCRtvalidate_console_portRtportR~(R)RORHRRPRT(R*RJRR‰R~RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRˆescCsId}|jj||ƒjd|d|ƒ}|j|dd|d|ƒS(s'Set host maintenance mode

        :param ctxt: request context
        :param host_param: This value is placed in the message to be the 'host'
                           parameter for the remote method.
        :param mode:
        :param host: This is the host to send the message to.
        s4.0RCRthost_maintenance_modeR
tmode(R)RGRHRT(R*RJR
RKR‹RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRŠms
	cCsCd}|jj||ƒjd|d|ƒ}|j|dd|ƒS(Ns4.0RCRthost_power_actiontaction(R)RGRHRT(R*RJR
RRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRŒ|scCsPd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|ƒdS(Ns4.0RCRtinject_network_infoR(R)RORHRRPRI(R*RJRRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRŽ‚scCsÇi|d6}d}	|jj||ƒ}
|
j|	ƒs[d}	|r[|jdtƒ}q[n|
j|	ƒs€d}	|jdƒn|
jd|d|	ƒ}|j|dd	|d
|d|d||dS(
NRns4.8s4.2tpre_migration_results4.0RCRtlive_migrationRtdestRZR	(R)RGR\RgtTrueRuRHRI(R*RJRR‘RZR
RnR	targsRRcRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRˆs
	cCs«d}i}|js-|jj||ƒ}n|jj||jƒ}|j|ƒsjd}|j|d<n|jdt|j|ƒd|ƒ}|j|dd||dS(Ns4.12s4.9tmigration_idRCRtlive_migration_force_completeR(	tsource_computeR)RORGR\tidRHRRI(R*RJRRnRtkwargsRcRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR•šs			cCsVd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒdS(Ns4.10RCRtlive_migration_abortRR”(R)RORHRRPRI(R*RJRR”RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR™ªs
cCsPd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|ƒdS(Ns4.0RCRtpause_instanceR(R)RORHRRPRI(R*RJRRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRš±scCsMd}|jj||ƒjd|d|ƒ}|j|dd|d|ƒdS(Ns4.0RCRt"post_live_migration_at_destinationRRZ(R)RGRHRI(R*RJRRZR
RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR›·s
cCsÒ|}d}|jj||ƒ}	|	j|ƒsNd}|rN|jƒ}qNn|	jd|d|ƒ}
|
j|dd|d|d|d	|ƒ}t|tjƒr¦|S|rÊ|rÊ|j	i|d
6ƒ|S|SdS(Ns4.8s4.0RCRtpre_live_migrationRRZtdiskR	tpre_live_migration_result(
R)RGR\RgRHRTR^R_R`Rh(R*RJRRZRR
R	tmigrate_data_origRRcRLRd((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRœ¿s&cCsÂtj|ƒ}i|d6|d6|d6|d6|d6|d6|	d6|
d6}d	}
|jj||ƒ}|j|
ƒs“d
}
tj|ƒ|d<n|jd|d|
ƒ}|j|d
|dS(NRt
instance_typeRxRotrequest_spectfilter_propertiestnodetclean_shutdowns4.1s4.0RCRtprep_resize(	Rtto_primitiveR)RGR\R%R‚RHRI(R*RJRRxR R
RoR¡R¢R£R¤timage_ptmsg_argsRRcRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR¥Ös"

c	Cs\d}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|d|ƒdS(Ns4.0RCRtreboot_instanceRtblock_device_infotreboot_type(R)RORHRRPRI(R*RJRRªR«RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR©ìscCsi|
d6|d6|d6|d6}d}|sF|jj||ƒ}n|jj||ƒ}|j|ƒsšd}|jdƒ|jdƒ|jdƒn|jdt||ƒd|ƒ}|j|d	d
|d|d|d
|d|d|d|d|	d|
|	dS(Ntpreserve_ephemeralRntscheduled_nodetlimitss4.5s4.0RCRtrebuild_instanceRtnew_passtinjected_filest	image_reftorig_image_reftorig_sys_metadatatbdmstrecreateton_shared_storage(R)RORGR\RuRHRRI(R*RJRR°R±R²R³R´RµR¶R·R
R£R¬RnR®R˜RvRRcRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR¯ös,



		c	CsSd}|jj||ƒjd|d|ƒ}|j|dd|d|d|ƒdS(	s)Remove aggregate host.

        :param ctxt: request context
        :param aggregate:
        :param host_param: This value is placed in the message to be the 'host'
                           parameter for the remote method.
        :param host: This is the host to send the message to.
        s4.0RCRtremove_aggregate_hostRER
RFN(R)RGRHRI(R*RJR
RERKRFRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR¸s
cCsVd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒdS(Ns4.0RCRtremove_fixed_ip_from_instanceRtaddress(R)RORHRRPRI(R*RJRRºRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR¹&s
cCsId}|jj||ƒjd|d|ƒ}|j|dd|d|ƒS(Ns4.0RCRtremove_volume_connectionRRt(R)RGRHRT(R*RJRRtR
RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR»-s
c	Csod}i|d6|d6|d6|d6}|jj||ƒjdtd|ƒd|ƒ}|j|d|dS(	Ns4.0trescue_passwordR¤trescue_image_refRRCRtrescue_instance(R)RORHRRPRI(	R*RJRR¼R½R¤RR¨RL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR¾4s

cCsPd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|ƒdS(Ns4.0RCRt
reset_networkR(R)RORHRRPRI(R*RJRRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR¿@scCs®i|d6|d6|d6|d6|d6|d6}d}	|jj||ƒ}
|
j|	ƒsvtj|ƒ|d<d}	n|
jd	td|ƒd
|	ƒ}|j|d|dS(NRRnRxRoR R¤s4.1s4.0RCRtresize_instance(	R)ROR\R%R‚RHRRPRI(R*RJRRnRxR RoR¤R¨RRcRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRÀFs

		cCsPd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|ƒdS(Ns4.0RCRtresume_instanceR(R)RORHRRPRI(R*RJRRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRÁWsc		Cs€d}|s$|jj||ƒ}n|jj||ƒ}|jdt||ƒd|ƒ}|j|dd|d|d|ƒdS(Ns4.0RCRt
revert_resizeRRnRo(R)RORGRHRRI(	R*RJRRnR
RoRRcRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRÂ]s	c
Cs‘d}|jj||ƒ}|j|ƒsHd}|rH|jƒ}qHni|d6|d6}|jd|d|ƒ}	|	j|dd||dS(	Ns4.8s4.0t
destroy_disksR	RCRt&rollback_live_migration_at_destinationR(R)RGR\RgRHRI(
R*RJRR
RÃR	RRcRvRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRÄjs

cCsRd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒS(Ns4.0RCRtset_admin_passwordRR°(R)RORHRRPRT(R*RJRR°RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRÅzs
cCsCd}|jj||ƒjd|d|ƒ}|j|dd|ƒS(Ns4.0RCRtset_host_enabledtenabled(R)RGRHRT(R*RJR
RÇRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRƁsc	Cs\d}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|d|ƒdS(Ns4.0RCRtswap_volumeRt
old_volume_idt
new_volume_id(R)RORHRRPRI(R*RJRRÉRÊRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRȇscCs=d}|jj||ƒjd|d|ƒ}|j|dƒS(Ns4.0RCRtget_host_uptime(R)RGRHRT(R*RJR
RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRˏsc
Csri|d6|d6|d6|d6|d6}d}|jj||ƒjdtd|ƒd|ƒ}	|	j|d	|S(
NRtdeviceRttdisk_bustdevice_types4.0RCRtreserve_block_device_name(R)RORHRRPRT(
R*RJRRÌRtRÍRÎtkwRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRϕs
cCsbd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|d|d|ƒdS(	Ns4.0RCRtbackup_instanceRtimage_idtbackup_typetrotation(R)RORHRRPRI(R*RJRRÒRÓRÔRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRÑ scCsVd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒdS(Ns4.0RCRtsnapshot_instanceRRÒ(R)RORHRRPRI(R*RJRRÒRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRÕ«scCsPd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|ƒdS(Ns4.0RCRtstart_instanceR(R)RORHRRPRI(R*RJRRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRÖ³sc	Csri|d6|d6}d}|jj||ƒjdtd|ƒd|ƒ}|rY|jn|j}||d|S(NRR¤s4.0RCRt
stop_instance(R)RORHRRPRIRT(	R*RJRtdo_castR¤R¨RRLRp((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR×¹s

cCsPd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|ƒdS(Ns4.0RCRtsuspend_instanceR(R)RORHRRPRI(R*RJRRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRÙÂsc	Cs\d}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|d|ƒdS(Ns4.0RCRtterminate_instanceRRµRo(R)RORHRRPRI(R*RJRRµRotdelete_typeRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRÚÈscCsPd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|ƒdS(Ns4.0RCRtunpause_instanceR(R)RORHRRPRI(R*RJRRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRÜÔscCsPd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|ƒdS(Ns4.0RCRtunrescue_instanceR(R)RORHRRPRI(R*RJRRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRÝÚscCsVd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒdS(Ns4.0RCRtsoft_delete_instanceRRo(R)RORHRRPRI(R*RJRRoRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRÞàs
cCsPd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|ƒdS(Ns4.0RCRtrestore_instanceR(R)RORHRRPRI(R*RJRRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRßçscCshi|d6|d6|d6}d}|jj||ƒjdtd|ƒd|ƒ}|j|d|dS(NRRÒR¤s4.0RCRtshelve_instance(R)RORHRRPRI(R*RJRRÒR¤R¨RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRàís
cCsai|d6|d6}d}|jj||ƒjdtd|ƒd|ƒ}|j|d|dS(NRR¤s4.0RCRtshelve_offload_instance(R)RORHRRPRI(R*RJRR¤R¨RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRáös
c
Csfd}i|d6|d6|d6|d6}|jj||ƒjd|d|ƒ}	|	j|d|dS(	Ns4.0RRxR¢R£RCRtunshelve_instance(R)RGRHRI(
R*RJRR
RxR¢R£Rt
msg_kwargsRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRâþs
c	Cs\d}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|d|ƒdS(Ns4.0RCRtvolume_snapshot_createRRttcreate_info(R)RORHRRPRI(R*RJRRtRåRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRäs
cCsbd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|d|d|ƒdS(	Ns4.0RCRtvolume_snapshot_deleteRRttsnapshot_idtdelete_info(R)RORHRRPRI(R*RJRRtRçRèRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRæscCsZ|d}|jj||ƒjdt||ƒddƒ}|j|dd|d|ƒdS(NiRCRs4.0texternal_instance_eventt	instancestevents(R)RORHRRI(R*RJRêRëR
RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRés
	cCsƒd}|jj||ƒjd|d|ƒ}|j|dd|d|d|d|d	|d
|d|	d|
d
|d|d|
ƒdS(Ns4.0RCRtbuild_and_run_instanceRRxR¡R¢tadmin_passwordR±trequested_networkstsecurity_groupstblock_device_mappingR£R®(R)RGRHRI(R*RJRR
RxR¡R¢RíR±RîRïRðR£R®RRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRì$scCsLd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|ƒS(Ns4.0RCRtquiesce_instanceR(R)RORHRRPRT(R*RJRRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRñ6scCsVd}|jj||ƒjdtd|ƒd|ƒ}|j|dd|d|ƒdS(Ns4.0RCRtunquiesce_instanceRtmapping(R)RORHRRPRI(R*RJRRóRRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRò<s
cCs}d}|jj||ƒ}|j|ƒsBd}tj|ƒ}n|jdtd|ƒd|ƒ}|j|dd|ƒdS(Ns4.4s4.0RCRtrefresh_instance_security_rulesR(	R)ROR\R%R‚RHRRPRI(R*RJRR
RRcRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRôCs	cCspd}|jj||ƒ}|j|ƒs9tjƒ‚n|jdtd|ƒd|ƒ}|j|dd|ƒS(Ns4.6RCRttrigger_crash_dumpR(	R)ROR\RtTriggerCrashDumpNotSupportedRHRRPRI(R*RJRRRcRL((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyRõNs	(Qt__name__t
__module__t__doc__R#RR"R'RPRDRMRQRURWRYReRkR’RmRqRsRwRzR{R}RR€RRƒR„R…R†R‡RˆRŠRŒRŽRR•R™RšR›RœR¥R©tFalseR¯R¸R¹R»R¾R¿RÀRÁRÂRÄRÅRÆRÈRËRÏRÑRÕRÖR×RÙRÚRÜRÝRÞRßRàRáRâRäRæRéRìRñRòRôRõ(((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyR9s¸ÿ
	
	(								

	
						
																				
				
															(#Rùtoslo_logRtloggingtoslo_messagingRtoslo_serializationRt	nova.conftnovaRRt	nova.i18nRRRRtnova.objectsRR%R	R_R
R9RtconfRt	getLoggerR÷R7RPR3RtobjectR(((sH/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/rpcapi.pyt<module>s"