diff --git a/nova/compute/api.py b/nova/compute/api.py
index f0d5ff2cb22f..6b26283782a0 100644
--- a/nova/compute/api.py
+++ b/nova/compute/api.py
@@ -379,7 +379,7 @@ class API(base.Base):
         kwargs = {'method': method, 'args': params}
         return rpc.call(context, queue, kwargs)
 
-    def _cast_scheduler_message(self, context, args)
+    def _cast_scheduler_message(self, context, args):
         """Generic handler for RPC calls to the scheduler"""
         rpc.cast(context, FLAGS.scheduler_topic, args)
 
diff --git a/nova/virt/xenapi/vmops.py b/nova/virt/xenapi/vmops.py
index 4688813555bf..4b835c707bbe 100644
--- a/nova/virt/xenapi/vmops.py
+++ b/nova/virt/xenapi/vmops.py
@@ -220,6 +220,14 @@ class VMOps(object):
 
         logging.debug(_("Finished snapshot and upload for VM %s"), instance)
 
+    def transfer_disk(self, instance, dest):
+        """ Copies a VHD from one host machine to another
+
+        :param instance: the instance that owns the VHD in question
+        :param dest: the destination host machine
+        """
+           
+
     def resize(self, instance, flavor):
         """Resize a running instance by changing it's RAM and disk size """
         raise NotImplementedError()
diff --git a/nova/virt/xenapi_conn.py b/nova/virt/xenapi_conn.py
index 726106b37174..2e587117a3a3 100644
--- a/nova/virt/xenapi_conn.py
+++ b/nova/virt/xenapi_conn.py
@@ -193,7 +193,7 @@ class XenAPIConnection(object):
         self._vmops.power_on(instance)
 
     def transfer_disk(self, instance, dest, callback):
-        self._vmops.transfer_disk(dest)
+        self._vmops.transfer_disk(instance, dest)
     
     def suspend(self, instance, callback):
         """suspend the specified instance"""
diff --git a/plugins/xenserver/xenapi/etc/xapi.d/plugins/data_transfer b/plugins/xenserver/xenapi/etc/xapi.d/plugins/data_transfer
index cde7bb823c39..2af4a758b470 100644
--- a/plugins/xenserver/xenapi/etc/xapi.d/plugins/data_transfer
+++ b/plugins/xenserver/xenapi/etc/xapi.d/plugins/data_transfer
@@ -46,11 +46,11 @@ def _key_scan_and_add(host):
     null.close()
     known_hosts.close()
 
-def transfer_vhd(host, vhd_path):
+def transfer_file(host, file_path):
     """Rsyncs a VHD to an adjacent host"""
     _key_scan_and_add(host)
-    if subprocess.call([RSYNC, vhd_path, "%s:/root/" % host]) != 0:
+    if subprocess.call([RSYNC, file_path, "%s:/root/" % host]) != 0:
         raise Exception("Unexpected VHD transfer failure")
 
 if __name__ == '__main__':
-    XenAPIPlugin.dispatch({'transfer_vhd': transfer_vhd})
+    XenAPIPlugin.dispatch({'transfer_file': transfer_file})