Rick Harris
6392ad2924
The dom0 plugin code had been using `pickle` for serializing input and `json` for serializing output which was needlessly inconsistent. This patch makes the code use `pickle`--chosen for its better handling of `datetime` objects--for both sending and receiving data. This patch also refactors the code so that neither the caller nor the callee need to explicitly worry about serialization: the caller just passes in args and kwargs, and the callee's function signature just accepts the args and kwargs as usual. Bonus: Removes unecessary imports Change-Id: I3abb42eeebd8d37d67e6c26fa7bcae66d876b3ee
62 lines
2.1 KiB
Python
Executable File
62 lines
2.1 KiB
Python
Executable File
#!/usr/bin/env python
|
|
|
|
# Copyright 2010 OpenStack LLC.
|
|
# All Rights Reserved.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
"""
|
|
XenAPI Plugin for transfering data between host nodes
|
|
"""
|
|
import utils
|
|
|
|
from pluginlib_nova import *
|
|
configure_logging('migration')
|
|
|
|
|
|
def move_vhds_into_sr(session, instance_uuid, sr_path, uuid_stack):
|
|
"""Moves the VHDs from their copied location to the SR"""
|
|
staging_path = "/images/instance%s" % instance_uuid
|
|
imported_vhds = utils.import_vhds(sr_path, staging_path, uuid_stack)
|
|
utils.cleanup_staging_area(staging_path)
|
|
return imported_vhds
|
|
|
|
|
|
def _rsync_vhds(instance_uuid, host, staging_path, user="root"):
|
|
ssh_cmd = '\"ssh -o StrictHostKeyChecking=no\"'
|
|
|
|
if not staging_path.endswith('/'):
|
|
staging_path += '/'
|
|
|
|
dest_path = '%s@%s:/images/instance%s/' % (user, host, instance_uuid)
|
|
|
|
rsync_cmd = "nohup /usr/bin/rsync -av -e %(ssh_cmd)s %(staging_path)s"\
|
|
" %(dest_path)s" % locals()
|
|
rsync_proc = utils.make_subprocess(rsync_cmd, stdout=True, stderr=True)
|
|
utils.finish_subprocess(rsync_proc, rsync_cmd)
|
|
|
|
|
|
def transfer_vhd(session, instance_uuid, host, vdi_uuid, sr_path, seq_num):
|
|
"""Rsyncs a VHD to an adjacent host"""
|
|
staging_path = utils.make_staging_area(sr_path)
|
|
try:
|
|
utils.prepare_staging_area(
|
|
sr_path, staging_path, [vdi_uuid], seq_num=seq_num)
|
|
_rsync_vhds(instance_uuid, host, staging_path)
|
|
finally:
|
|
utils.cleanup_staging_area(staging_path)
|
|
|
|
|
|
if __name__ == '__main__':
|
|
utils.register_plugin_calls(move_vhds_into_sr, transfer_vhd)
|