From 6a6a369679495fcadea8d1250ae3cfa8ce58d004 Mon Sep 17 00:00:00 2001
From: Jan Orel <jorel@opennebula.systems>
Date: Wed, 17 Jul 2019 15:01:45 +0200
Subject: [PATCH 1/3] F #3244: Better mixed modes

---
 include/VirtualMachineDisk.h     |   2 +-
 install.sh                       |  12 ++-
 src/tm/TransferManager.cc        | 140 +++++++++++++++++++++++++------
 src/tm_mad/ceph/clone            |  53 ++++--------
 src/tm_mad/ceph/clone.ssh        | 124 +++++++++++++++++++++++++++
 src/tm_mad/ceph/cpds             |  58 ++++---------
 src/tm_mad/ceph/cpds.ssh         | 128 ++++++++++++++++++++++++++++
 src/tm_mad/ceph/delete           |  26 +++---
 src/tm_mad/ceph/delete.ssh       |  20 +++++
 src/tm_mad/ceph/ln               |  28 +------
 src/tm_mad/ceph/ln.ssh           | 109 ++++++++++++++++++++++++
 src/tm_mad/ceph/mvds             | 106 +----------------------
 src/tm_mad/ceph/mvds.ssh         | 121 ++++++++++++++++++++++++++
 src/tm_mad/ceph/resize           |  15 +---
 src/tm_mad/ceph/resize.ssh       |  63 ++++++++++++++
 src/tm_mad/one_tm.rb             |  15 ++++
 src/tm_mad/qcow2/clone           |  16 +---
 src/tm_mad/qcow2/clone.ssh       | 125 +++++++++++++++++++++++++++
 src/tm_mad/qcow2/cpds.ssh        | 135 +++++++++++++++++++++++++++++
 src/tm_mad/qcow2/ln              |  23 +----
 src/tm_mad/qcow2/ln.ssh          | 104 +++++++++++++++++++++++
 src/tm_mad/qcow2/mvds.ssh        |  83 ++++++++++++++++++
 src/tm_mad/shared/mvds           |  57 +------------
 src/vm/VirtualMachineDisk.cc     |   2 +-
 src/vmm_mad/exec/one_vmm_exec.rb |   2 +-
 25 files changed, 1205 insertions(+), 362 deletions(-)
 create mode 100755 src/tm_mad/ceph/clone.ssh
 create mode 100755 src/tm_mad/ceph/cpds.ssh
 create mode 100755 src/tm_mad/ceph/delete.ssh
 create mode 100755 src/tm_mad/ceph/ln.ssh
 create mode 100755 src/tm_mad/ceph/mvds.ssh
 create mode 100755 src/tm_mad/ceph/resize.ssh
 create mode 100755 src/tm_mad/qcow2/clone.ssh
 create mode 100755 src/tm_mad/qcow2/cpds.ssh
 create mode 100755 src/tm_mad/qcow2/ln.ssh
 create mode 100755 src/tm_mad/qcow2/mvds.ssh

diff --git a/include/VirtualMachineDisk.h b/include/VirtualMachineDisk.h
index eb9fb0cccb8..ed26f369fe1 100644
--- a/include/VirtualMachineDisk.h
+++ b/include/VirtualMachineDisk.h
@@ -154,7 +154,7 @@ class VirtualMachineDisk : public VirtualMachineAttribute
     /**
      *  Return the TM_MAD_SYSTEM attribute
      */
-    std::string get_tm_mad_system();
+    std::string get_tm_mad_system() const;
 
     /* ---------------------------------------------------------------------- */
     /* Image Manager Interface                                                */
diff --git a/install.sh b/install.sh
index a0055ee90c4..7a312158032 100755
--- a/install.sh
+++ b/install.sh
@@ -1230,8 +1230,10 @@ TM_FS_LVM_ETC_FILES="src/tm_mad/fs_lvm/fs_lvm.conf"
 
 
 TM_QCOW2_FILES="src/tm_mad/qcow2/clone \
+                 src/tm_mad/qcow2/clone.ssh \
                  src/tm_mad/qcow2/delete \
                  src/tm_mad/qcow2/ln \
+                 src/tm_mad/qcow2/ln.ssh \
                  src/tm_mad/qcow2/monitor \
                  src/tm_mad/qcow2/mkswap \
                  src/tm_mad/qcow2/mkimage \
@@ -1241,11 +1243,13 @@ TM_QCOW2_FILES="src/tm_mad/qcow2/clone \
                  src/tm_mad/qcow2/postmigrate \
                  src/tm_mad/qcow2/failmigrate \
                  src/tm_mad/qcow2/mvds \
+                 src/tm_mad/qcow2/mvds.ssh \
                  src/tm_mad/qcow2/snap_create \
                  src/tm_mad/qcow2/snap_create_live \
                  src/tm_mad/qcow2/snap_delete \
                  src/tm_mad/qcow2/snap_revert \
                  src/tm_mad/qcow2/cpds \
+                 src/tm_mad/qcow2/cpds.ssh \
                  src/tm_mad/qcow2/resize"
 
 TM_SSH_FILES="src/tm_mad/ssh/clone \
@@ -1288,10 +1292,14 @@ TM_DUMMY_FILES="src/tm_mad/dummy/clone \
               src/tm_mad/dummy/resize"
 
 TM_CEPH_FILES="src/tm_mad/ceph/clone \
+                 src/tm_mad/ceph/clone.ssh \
                  src/tm_mad/ceph/ln \
+                 src/tm_mad/ceph/ln.ssh \
                  src/tm_mad/ceph/mv \
                  src/tm_mad/ceph/mvds \
+                 src/tm_mad/ceph/mvds.ssh \
                  src/tm_mad/ceph/cpds \
+                 src/tm_mad/ceph/cpds.ssh \
                  src/tm_mad/ceph/premigrate \
                  src/tm_mad/ceph/postmigrate \
                  src/tm_mad/ceph/snap_create \
@@ -1300,11 +1308,13 @@ TM_CEPH_FILES="src/tm_mad/ceph/clone \
                  src/tm_mad/ceph/snap_revert \
                  src/tm_mad/ceph/failmigrate \
                  src/tm_mad/ceph/delete \
+                 src/tm_mad/ceph/delete.ssh \
                  src/tm_mad/ceph/context \
                  src/tm_mad/ceph/mkimage \
                  src/tm_mad/ceph/monitor \
                  src/tm_mad/ceph/mkswap \
-                 src/tm_mad/ceph/resize"
+                 src/tm_mad/ceph/resize \
+                 src/tm_mad/ceph/resize.ssh"
 
 TM_DEV_FILES="src/tm_mad/dev/clone \
                  src/tm_mad/dev/ln \
diff --git a/src/tm/TransferManager.cc b/src/tm/TransferManager.cc
index 1706b356a5b..1c8cc5a91bd 100644
--- a/src/tm/TransferManager.cc
+++ b/src/tm/TransferManager.cc
@@ -333,6 +333,7 @@ int TransferManager::prolog_transfer_command(
     string size;
     string format;
     string tm_mad;
+    string tm_mad_system;
     string ds_id;
 
     int disk_id = disk->get_disk_id();
@@ -416,21 +417,27 @@ int TransferManager::prolog_transfer_command(
 
         one_util::toupper(clon);
 
+        std::string tsys = disk->get_tm_mad_system();
+        if (!tsys.empty())
+        {
+            tm_mad_system = "." + tsys;
+        }
+
         // -----------------------------------------------------------------
         // CLONE or LINK disk images
         // -----------------------------------------------------------------
 
-        // <CLONE|LN> tm_mad fe:SOURCE host:remote_system_ds/disk.i vmid dsid
+        // <CLONE|LN>(.tm_mad_system) tm_mad fe:SOURCE host:remote_system_ds/disk.i vmid dsid"
         if (clon == "YES")
         {
-            xfr << "CLONE ";
+            xfr << "CLONE";
         }
         else
         {
-            xfr << "LN ";
+            xfr << "LN";
         }
 
-        xfr << tm_mad << " ";
+        xfr << tm_mad_system << " " << tm_mad << " ";
 
         if ( source.find(":") == string::npos ) //Regular file
         {
@@ -722,6 +729,7 @@ void TransferManager::prolog_migr_action(int vid)
     string          xfr_name;
 
     string tm_mad;
+    string tm_mad_system;
     string vm_tm_mad;
 
     int ds_id;
@@ -791,9 +799,17 @@ void TransferManager::prolog_migr_action(int vid)
             }
         }
 
-        //MV tm_mad prev_host:remote_system_dir/disk.i host:remote_system_dir/disk.i vmid dsid(image)
-        xfr << "MV "
-            << tm_mad << " "
+		(*disk)->vector_value("TM_MAD");
+        string tsys = (*disk)->vector_value("TM_MAD_SYSTEM");
+        if (!tsys.empty())
+        {
+            tm_mad_system = "." + tsys;
+        }
+
+        //MV(.tm_mad_system) tm_mad prev_host:remote_system_dir/disk.i host:remote_system_dir/disk.i vmid dsid(image)
+        xfr << "MV"
+			<< tm_mad_system
+            << " " << tm_mad << " "
             << vm->get_previous_hostname() << ":"
             << vm->get_previous_system_dir() << "/disk." << disk_id << " "
             << vm->get_hostname() << ":"
@@ -852,6 +868,7 @@ void TransferManager::prolog_resume_action(int vid)
     string          xfr_name;
 
     string tm_mad;
+    string tm_mad_system;
     string vm_tm_mad;
     string token_password;
 
@@ -926,9 +943,17 @@ void TransferManager::prolog_resume_action(int vid)
             }
         }
 
-        //MV tm_mad fe:system_dir/disk.i host:remote_system_dir/disk.i vmid dsid(image)
-        xfr << "MV "
-            << tm_mad << " "
+		(*disk)->vector_value("TM_MAD");
+        string tsys = (*disk)->vector_value("TM_MAD_SYSTEM");
+        if (!tsys.empty())
+        {
+            tm_mad_system = "." + tsys;
+        }
+
+        //MV(.tm_mad_system) tm_mad fe:system_dir/disk.i host:remote_system_dir/disk.i vmid dsid(image)
+        xfr << "MV"
+			<< tm_mad_system
+            << " " << tm_mad << " "
             << nd.get_nebula_hostname() << ":"
             << vm->get_system_dir() << "/disk." << disk_id << " "
             << vm->get_hostname() << ":"
@@ -1102,6 +1127,7 @@ void TransferManager::epilog_transfer_command(
 {
     string save = disk->vector_value("SAVE");
     int    disk_id = disk->get_disk_id();
+	string tm_mad_system;
 
     if ( one_util::toupper(save) == "YES" )
     {
@@ -1121,9 +1147,14 @@ void TransferManager::epilog_transfer_command(
             return;
         }
 
-        //MVDS tm_mad hostname:remote_system_dir/disk.0 <fe:SOURCE|SOURCE> vmid dsid
-        xfr << "MVDS "
-            << tm_mad << " "
+        string tsys = disk->vector_value("TM_MAD_SYSTEM");
+        if (!tsys.empty())
+        {
+            tm_mad_system = "." + tsys;
+        }
+        //MVDS(.tm_mad_system) tm_mad hostname:remote_system_dir/disk.0 <fe:SOURCE|SOURCE> vmid dsid
+        xfr << "MVDS" << tm_mad_system
+            << " " << tm_mad << " "
             << host << ":" << vm->get_system_dir() << "/disk." << disk_id << " "
             << source << " "
             << vm->get_oid() << " "
@@ -1148,10 +1179,17 @@ void TransferManager::epilog_transfer_command(
             vv_rc  = disk->vector_value("DATASTORE_ID", ds_id_i);
         }
 
+        string tsys = disk->vector_value("TM_MAD_SYSTEM");
+        if (!tsys.empty())
+        {
+            tm_mad_system = "." + tsys;
+        }
+
         if ( !tm_mad.empty() && vv_rc == 0)
         {
-            //DELETE tm_mad hostname:remote_system_dir/disk.i vmid ds_id
-            xfr << "DELETE "
+            //DELETE(.tm_mad_system) tm_mad hostname:remote_system_dir/disk.i vmid ds_id
+            xfr << "DELETE"
+                << tm_mad_system << " "
                 << tm_mad << " "
                 << host << ":" << vm->get_system_dir() << "/disk." << disk_id << " "
                 << vm->get_oid() << " "
@@ -1278,6 +1316,7 @@ void TransferManager::epilog_stop_action(int vid)
 
     string xfr_name;
     string tm_mad;
+    string tm_mad_system;
     string vm_tm_mad;
 
     int ds_id;
@@ -1346,9 +1385,16 @@ void TransferManager::epilog_stop_action(int vid)
             }
         }
 
+        string tsys = (*disk)->vector_value("TM_MAD_SYSTEM");
+        if (!tsys.empty())
+        {
+            tm_mad_system = "." + tsys;
+        }
+
         //MV tm_mad host:remote_system_dir/disk.i fe:system_dir/disk.i vmid dsid(image)
-        xfr << "MV "
-            << tm_mad << " "
+        xfr << "MV"
+			<< tm_mad_system
+            << " " << tm_mad << " "
             << vm->get_hostname() << ":"
             << vm->get_system_dir() << "/disk." << disk_id << " "
             << nd.get_nebula_hostname() << ":"
@@ -1409,6 +1455,7 @@ int TransferManager::epilog_delete_commands(VirtualMachine *vm,
 
     string vm_tm_mad;
     string tm_mad;
+    string tm_mad_system;
     string host;
     string system_dir;
 
@@ -1487,11 +1534,17 @@ int TransferManager::epilog_delete_commands(VirtualMachine *vm,
             }
         }
 
-        //DELETE tm_mad host:remote_system_dir/disk.i vmid dsid(image)
+        string tsys = (*disk)->vector_value("TM_MAD_SYSTEM");
+        if (!tsys.empty())
+        {
+           tm_mad_system = "." + tsys;
+        }
+
+        //DELETE tm_mad(.tm_mad_system) host:remote_system_dir/disk.i vmid dsid(image)
         // *local* DELETE tm_mad fe:system_dir/disk.i vmid dsid(image)
         // *prev*  DELETE tm_mad prev_host:remote_system_dir/disk.i vmid ds_id(image)
-        xfr << "DELETE "
-            << tm_mad << " "
+        xfr << "DELETE" << tm_mad_system
+            << " " << tm_mad << " "
             << host << ":"
             << system_dir << "/disk." << disk_id << " "
             << vm->get_oid() << " "
@@ -1898,6 +1951,8 @@ void TransferManager::saveas_hot_action(int vid)
     string snap_id;
     string tm_mad;
     string ds_id;
+    string tsys;
+    string tm_mad_system;
 
     ostringstream os;
 
@@ -1906,6 +1961,7 @@ void TransferManager::saveas_hot_action(int vid)
 
     VirtualMachine * vm;
     const TransferManagerDriver * tm_md;
+    VirtualMachineDisk * disk;
 
     Nebula& nd = Nebula::instance();
 
@@ -1944,9 +2000,19 @@ void TransferManager::saveas_hot_action(int vid)
         goto error_file;
     }
 
+    disk = vm->get_disk(disk_id);
+    if (disk != 0)
+    {
+        tsys = disk->vector_value("TM_MAD_SYSTEM");
+        if (!tsys.empty())
+        {
+            tm_mad_system = "." + tsys;
+        }
+    }
+
     //CPDS tm_mad hostname:remote_system_dir/disk.0 source snapid vmid dsid
-    xfr << "CPDS "
-        << tm_mad << " "
+    xfr << "CPDS" << tm_mad_system
+        << " " << tm_mad << " "
         << vm->get_hostname() << ":"
         << vm->get_system_dir() << "/disk." << disk_id << " "
         << src << " "
@@ -2015,9 +2081,12 @@ int TransferManager::snapshot_transfer_command(
         VirtualMachine * vm, const char * snap_action, ostream& xfr)
 {
     string tm_mad;
+    string tsys;
+    string tm_mad_system;
     int    ds_id;
     int    disk_id;
     int    snap_id;
+    VirtualMachineDisk * disk;
 
     if (vm->get_snapshot_disk(ds_id, tm_mad, disk_id, snap_id) == -1)
     {
@@ -2026,8 +2095,18 @@ int TransferManager::snapshot_transfer_command(
         return -1;
     }
 
-    //SNAP_CREATE tm_mad host:remote_system_dir/disk.0 snapid vmid dsid
-    xfr << snap_action << " "
+    disk = vm->get_disk(disk_id);
+    if (disk != 0)
+    {
+        tsys = disk->vector_value("TM_MAD_SYSTEM");
+        if (!tsys.empty())
+        {
+            tm_mad_system = "." + tsys;
+        }
+    }
+
+    //SNAP_CREATE(.tm_mad_system) tm_mad host:remote_system_dir/disk.0 snapid vmid dsid
+    xfr << snap_action << tm_mad_system << " "
         << tm_mad << " "
         << vm->get_hostname() << ":"
         << vm->get_system_dir() << "/disk." << disk_id << " "
@@ -2141,6 +2220,7 @@ void TransferManager::resize_command(VirtualMachine * vm,
         const VirtualMachineDisk * disk, ostream& xfr)
 {
     string tm_mad;
+    string tm_mad_system;
     string ds_id;
 
     if ( disk->is_volatile() )
@@ -2154,9 +2234,15 @@ void TransferManager::resize_command(VirtualMachine * vm,
         ds_id  = disk->vector_value("DATASTORE_ID");
     }
 
-    //RESIZE tm_mad host:remote_system_dir/disk.i size vmid dsid
-    xfr << "RESIZE "
-        << tm_mad << " "
+    string tsys = disk->vector_value("TM_MAD_SYSTEM");
+    if (!tsys.empty())
+    {
+        tm_mad_system = "." + tsys;
+    }
+
+    //RESIZE.(tm_mad_system) tm_mad host:remote_system_dir/disk.i size vmid dsid
+    xfr << "RESIZE" << tm_mad_system
+        << " " << tm_mad << " "
         << vm->get_hostname() << ":"
         << vm->get_system_dir()<< "/disk."<< disk->vector_value("DISK_ID")<< " "
         << disk->vector_value("SIZE") << " "
diff --git a/src/tm_mad/ceph/clone b/src/tm_mad/ceph/clone
index 888059eb2ad..6d1fc72ed15 100755
--- a/src/tm_mad/ceph/clone
+++ b/src/tm_mad/ceph/clone
@@ -74,15 +74,13 @@ done < <(onevm show -x $VM_ID| $XPATH  \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_KEY \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_CONF \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/SIZE \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/ORIGINAL_SIZE \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/TYPE )
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/ORIGINAL_SIZE )
 
 CEPH_USER="${XPATH_ELEMENTS[j++]}"
 CEPH_KEY="${XPATH_ELEMENTS[j++]}"
 CEPH_CONF="${XPATH_ELEMENTS[j++]}"
 SIZE="${XPATH_ELEMENTS[j++]}"
 ORIGINAL_SIZE="${XPATH_ELEMENTS[j++]}"
-TYPE="${XPATH_ELEMENTS[j++]}"
 
 #-------------------------------------------------------------------------------
 # Get Datastore information
@@ -117,49 +115,26 @@ if [ -n "$EC_POOL_NAME" ]; then
     EC_POOL_OPT="--data-pool ${EC_POOL_NAME}"
 fi
 
-if [ "${TYPE}" = 'FILE' ]; then
-    ssh_make_path $DST_HOST $DST_DIR 'ssh'
+CLONE_CMD=$(cat <<EOF
+    RBD="${RBD}"
 
-    CLONE_CMD=$(cat <<EOF
-        RBD="${RBD}"
+    $RBD info $RBD_DST >/dev/null 2>&1 && exit 0
 
-        rbd_make_snap $SRC_PATH
+    rbd_make_snap $SRC_PATH
 
-        set -e -o pipefail
+    set -e -o pipefail
 
-        if [ "\$(rbd_format $SRC_PATH)" = "2" ]; then
-            $RBD export "$SRC_PATH@snap" $DST_PATH
-        else
-            $RBD export $SRC_PATH $DST_PATH
-        fi
+    if [ "\$(rbd_format $SRC_PATH)" = "2" ]; then
+        $RBD ${EC_POOL_OPT} clone "$SRC_PATH@snap" $RBD_DST
+    else
+        $RBD copy $SRC_PATH $RBD_DST
+    fi
 
-        if [ -n "$ORIGINAL_SIZE" -a "$SIZE" -gt "$ORIGINAL_SIZE" ]; then
-            qemu-img resize ${DST_PATH} ${SIZE}M
-        fi
+    if [ -n "$ORIGINAL_SIZE" -a "$SIZE" -gt "$ORIGINAL_SIZE" ]; then
+        $RBD resize $RBD_DST --size $SIZE
+    fi
 EOF
 )
-else
-    CLONE_CMD=$(cat <<EOF
-        RBD="${RBD}"
-
-        $RBD info $RBD_DST >/dev/null 2>&1 && exit 0
-
-        rbd_make_snap $SRC_PATH
-
-        set -e -o pipefail
-
-        if [ "\$(rbd_format $SRC_PATH)" = "2" ]; then
-            $RBD ${EC_POOL_OPT} clone "$SRC_PATH@snap" $RBD_DST
-        else
-            $RBD copy $SRC_PATH $RBD_DST
-        fi
-
-        if [ -n "$ORIGINAL_SIZE" -a "$SIZE" -gt "$ORIGINAL_SIZE" ]; then
-            $RBD resize $RBD_DST --size $SIZE
-        fi
-EOF
-)
-fi
 
 ssh_exec_and_log_stdin "$DST_HOST" "$CLONE_CMD" "$CEPH_UTILS" \
                  "Error cloning $SRC_PATH to $RBD_DST in $DST_HOST"
diff --git a/src/tm_mad/ceph/clone.ssh b/src/tm_mad/ceph/clone.ssh
new file mode 100755
index 00000000000..1517d91192a
--- /dev/null
+++ b/src/tm_mad/ceph/clone.ssh
@@ -0,0 +1,124 @@
+#!/bin/bash
+
+# -------------------------------------------------------------------------- #
+# Copyright 2002-2019, OpenNebula Project, OpenNebula Systems                #
+#                                                                            #
+# 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.                                             #
+#--------------------------------------------------------------------------- #
+
+# clone.ssh fe:SOURCE host:remote_system_ds/disk.i size
+#   - fe is the front-end hostname
+#   - SOURCE is the path of the disk image in the form DS_BASE_PATH/disk
+#   - host is the target host to deploy the VM
+#   - remote_system_ds is the path for the system datastore in the host
+
+SRC=$1
+DST=$2
+VM_ID=$3
+DS_ID=$4
+
+#--------------------------------------------------------------------------------
+
+if [ -z "${ONE_LOCATION}" ]; then
+    TMCOMMON=/var/lib/one/remotes/tm/tm_common.sh
+    LIB_LOCATION=/usr/lib/one
+else
+    TMCOMMON=$ONE_LOCATION/var/remotes/tm/tm_common.sh
+    LIB_LOCATION=$ONE_LOCATION/lib
+fi
+
+DRIVER_PATH=$(dirname $0)
+
+source $TMCOMMON
+source ${DRIVER_PATH}/../../etc/datastore/ceph/ceph.conf
+
+CEPH_UTILS=${DRIVER_PATH}/../../datastore/ceph/ceph_utils.sh
+
+#-------------------------------------------------------------------------------
+# Compute the destination image name
+#-------------------------------------------------------------------------------
+
+DST_HOST=`arg_host $DST`
+
+SRC_PATH=`arg_path $SRC`
+DST_PATH=`arg_path $DST`
+
+DST_DIR=`dirname $DST_PATH`
+
+DISK_ID=$(echo $DST|awk -F. '{print $NF}')
+RBD_DST="${SRC_PATH}-${VM_ID}-${DISK_ID}"
+
+#-------------------------------------------------------------------------------
+# Get Image information
+#-------------------------------------------------------------------------------
+
+XPATH="${DRIVER_PATH}/../../datastore/xpath.rb --stdin"
+
+unset i j XPATH_ELEMENTS
+
+while IFS= read -r -d '' element; do
+        XPATH_ELEMENTS[i++]="$element"
+done < <(onevm show -x $VM_ID| $XPATH  \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_USER \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_KEY \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_CONF \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/SIZE \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/ORIGINAL_SIZE)
+
+CEPH_USER="${XPATH_ELEMENTS[j++]}"
+CEPH_KEY="${XPATH_ELEMENTS[j++]}"
+CEPH_CONF="${XPATH_ELEMENTS[j++]}"
+SIZE="${XPATH_ELEMENTS[j++]}"
+ORIGINAL_SIZE="${XPATH_ELEMENTS[j++]}"
+
+#-------------------------------------------------------------------------------
+# Create @snap and export it
+#-------------------------------------------------------------------------------
+
+if [ -n "$CEPH_USER" ]; then
+    RBD="$RBD --id ${CEPH_USER}"
+fi
+
+if [ -n "$CEPH_KEY" ]; then
+    RBD="$RBD --keyfile ${CEPH_KEY}"
+fi
+
+if [ -n "$CEPH_CONF" ]; then
+    RBD="$RBD --conf ${CEPH_CONF}"
+fi
+
+
+ssh_make_path $DST_HOST $DST_DIR 'ssh'
+
+CLONE_CMD=$(cat <<EOF
+    RBD="${RBD}"
+
+    rbd_make_snap $SRC_PATH
+
+    set -e -o pipefail
+
+    if [ "\$(rbd_format $SRC_PATH)" = "2" ]; then
+        $RBD export "$SRC_PATH@snap" $DST_PATH
+    else
+        $RBD export $SRC_PATH $DST_PATH
+    fi
+
+    if [ -n "$ORIGINAL_SIZE" -a "$SIZE" -gt "$ORIGINAL_SIZE" ]; then
+        qemu-img resize ${DST_PATH} ${SIZE}M
+    fi
+EOF
+)
+
+ssh_exec_and_log_stdin "$DST_HOST" "$CLONE_CMD" "$CEPH_UTILS" \
+                 "Error cloning $SRC_PATH to $RBD_DST in $DST_HOST"
+exit 0
diff --git a/src/tm_mad/ceph/cpds b/src/tm_mad/ceph/cpds
index ecfdadbe614..e09a32a4a34 100755
--- a/src/tm_mad/ceph/cpds
+++ b/src/tm_mad/ceph/cpds
@@ -51,7 +51,6 @@ CEPH_UTILS=${DRIVER_PATH}/../../datastore/ceph/ceph_utils.sh
 # Set dst path and dir
 #-------------------------------------------------------------------------------
 
-SRC_PATH=`arg_path $SRC`
 SRC_HOST=`arg_host $SRC`
 RBD_SRC=`arg_path $SRC`
 
@@ -68,21 +67,17 @@ unset i j XPATH_ELEMENTS
 while IFS= read -r -d '' element; do
     XPATH_ELEMENTS[i++]="$element"
 done < <(onevm show -x $VM_ID| $XPATH \
-                    /VM/DEPLOY_ID \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/SOURCE \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CLONE \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_USER \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_KEY \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_CONF \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/TYPE )
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_CONF)
 
-DEPLOY_ID="${XPATH_ELEMENTS[j++]}"
 RBD_SRC="${XPATH_ELEMENTS[j++]}"
 CLONE="${XPATH_ELEMENTS[j++]}"
 CEPH_USER="${XPATH_ELEMENTS[j++]}"
 CEPH_KEY="${XPATH_ELEMENTS[j++]}"
 CEPH_CONF="${XPATH_ELEMENTS[j++]}"
-TYPE="${XPATH_ELEMENTS[j++]}"
 
 #-------------------------------------------------------------------------------
 # Get Datastore information
@@ -119,56 +114,31 @@ if [ -n "$CEPH_CONF" ]; then
     RBD="$RBD --conf ${CEPH_CONF}"
 fi
 
-if [ "$RBD_FORMAT" = "2" ]; then
-    FORMAT_OPT="--image-format 2"
-fi
-
 if [ -n "$EC_POOL_NAME" ]; then
     EC_POOL_OPT="--data-pool ${EC_POOL_NAME}"
 fi
 
-if [ "${TYPE}" = 'FILE' ]; then
+COPY_CMD=$(cat <<EOF
+    RBD="${RBD}"
+
     if [ "$SNAP_ID" != "-1" ]; then
-        error_message "$script_name: Operation not supported on disk type ${TYPE} with snapshots"
-        exit 1
-    fi
+        rbd_check_2 $RBD_DST
 
-    COPY_CMD=$(cat <<EOF
-        if virsh -c $LIBVIRT_URI domfsfreeze $DEPLOY_ID ; then
-            trap "virsh -c $LIBVIRT_URI domfsthaw $DEPLOY_ID" EXIT TERM INT HUP
-        elif virsh -c $LIBVIRT_URI suspend $DEPLOY_ID; then
-            trap "virsh -c $LIBVIRT_URI resume $DEPLOY_ID" EXIT TERM INT HUP
-        else
-            echo "Could not domfsfreeze or suspend domain" >&2
+        RBD_DST=\$(rbd_find_snap $RBD_DST $SNAP_ID)
+
+        if [ -z "\$RBD_DST" ]; then
+            echo "Target RBD not found." >&2
             exit 1
         fi
 
-        $RBD import $FORMAT_OPT $SRC_PATH $DST
-EOF
-)
-else
-    COPY_CMD=$(cat <<EOF
-        RBD="${RBD}"
-
-        if [ "$SNAP_ID" != "-1" ]; then
-            rbd_check_2 $RBD_DST
-
-            RBD_DST=\$(rbd_find_snap $RBD_DST $SNAP_ID)
-
-            if [ -z "\$RBD_DST" ]; then
-                echo "Target RBD not found." >&2
-                exit 1
-            fi
-
-            RBD_DST=\$RBD_DST@$SNAP_ID
-        else
-            RBD_DST=$RBD_DST
-        fi
+        RBD_DST=\$RBD_DST@$SNAP_ID
+    else
+        RBD_DST=$RBD_DST
+    fi
 
-        $RBD ${EC_POOL_OPT} copy \$RBD_DST $DST
+    $RBD ${EC_POOL_OPT} copy \$RBD_DST $DST
 EOF
 )
-fi
 
 ssh_exec_and_log_stdin "$SRC_HOST" "$COPY_CMD" "$CEPH_UTILS" \
                  "Error cloning $RBD_DST to $DST in $SRC_HOST"
diff --git a/src/tm_mad/ceph/cpds.ssh b/src/tm_mad/ceph/cpds.ssh
new file mode 100755
index 00000000000..a22f9075e2e
--- /dev/null
+++ b/src/tm_mad/ceph/cpds.ssh
@@ -0,0 +1,128 @@
+#!/bin/bash
+
+# -------------------------------------------------------------------------- #
+# Copyright 2002-2019, OpenNebula Project, OpenNebula Systems                #
+#                                                                            #
+# 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.                                             #
+#--------------------------------------------------------------------------- #
+
+# cpds host:remote_system_ds/disk.i fe:SOURCE snapid vmid dsid
+#   - fe is the front-end hostname
+#   - SOURCE is the path of the disk image in the form DS_BASE_PATH/disk
+#   - host is the target host to deploy the VM
+#   - remote_system_ds is the path for the system datastore in the host
+#   - snapid is the snapshot id. "-1" for none
+
+SRC=$1
+DST=$2
+SNAP_ID=$3
+VM_ID=$4
+DS_ID=$5
+
+#--------------------------------------------------------------------------------
+
+if [ -z "${ONE_LOCATION}" ]; then
+    TMCOMMON=/var/lib/one/remotes/tm/tm_common.sh
+    LIB_LOCATION=/usr/lib/one
+else
+    TMCOMMON=$ONE_LOCATION/var/remotes/tm/tm_common.sh
+    LIB_LOCATION=$ONE_LOCATION/lib
+fi
+
+DRIVER_PATH=$(dirname $0)
+
+source $TMCOMMON
+source ${DRIVER_PATH}/../../etc/datastore/ceph/ceph.conf
+source ${DRIVER_PATH}/../../etc/vmm/kvm/kvmrc
+
+CEPH_UTILS=${DRIVER_PATH}/../../datastore/ceph/ceph_utils.sh
+
+#-------------------------------------------------------------------------------
+# Set dst path and dir
+#-------------------------------------------------------------------------------
+
+SRC_PATH=`arg_path $SRC`
+SRC_HOST=`arg_host $SRC`
+RBD_SRC=`arg_path $SRC`
+
+#-------------------------------------------------------------------------------
+# Get Image information
+#-------------------------------------------------------------------------------
+
+DISK_ID=$(echo "$RBD_SRC" | $AWK -F. '{print $NF}')
+
+XPATH="${DRIVER_PATH}/../../datastore/xpath.rb --stdin"
+
+unset i j XPATH_ELEMENTS
+
+while IFS= read -r -d '' element; do
+    XPATH_ELEMENTS[i++]="$element"
+done < <(onevm show -x $VM_ID| $XPATH \
+                    /VM/DEPLOY_ID \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/SOURCE \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CLONE \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_USER \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_KEY \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_CONF \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/TYPE )
+
+DEPLOY_ID="${XPATH_ELEMENTS[j++]}"
+RBD_SRC="${XPATH_ELEMENTS[j++]}"
+CLONE="${XPATH_ELEMENTS[j++]}"
+CEPH_USER="${XPATH_ELEMENTS[j++]}"
+CEPH_KEY="${XPATH_ELEMENTS[j++]}"
+CEPH_CONF="${XPATH_ELEMENTS[j++]}"
+TYPE="${XPATH_ELEMENTS[j++]}"
+
+
+#-------------------------------------------------------------------------------
+# Copy Image back to the datastore
+#-------------------------------------------------------------------------------
+
+if [ -n "$CEPH_USER" ]; then
+    RBD="$RBD --id ${CEPH_USER}"
+fi
+
+if [ -n "$CEPH_KEY" ]; then
+    RBD="$RBD --keyfile ${CEPH_KEY}"
+fi
+
+if [ -n "$CEPH_CONF" ]; then
+    RBD="$RBD --conf ${CEPH_CONF}"
+fi
+
+if [ "$RBD_FORMAT" = "2" ]; then
+    FORMAT_OPT="--image-format 2"
+fi
+
+if [ "$SNAP_ID" != "-1" ]; then
+    error_message "$script_name: Operation not supported on disk type ${TYPE} with snapshots"
+    exit 1
+fi
+
+COPY_CMD=$(cat <<EOF
+    if virsh -c $LIBVIRT_URI domfsfreeze $DEPLOY_ID ; then
+        trap "virsh -c $LIBVIRT_URI domfsthaw $DEPLOY_ID" EXIT TERM INT HUP
+    elif virsh -c $LIBVIRT_URI suspend $DEPLOY_ID; then
+        trap "virsh -c $LIBVIRT_URI resume $DEPLOY_ID" EXIT TERM INT HUP
+    else
+        echo "Could not domfsfreeze or suspend domain" >&2
+        exit 1
+    fi
+
+    $RBD import $FORMAT_OPT $SRC_PATH $DST
+EOF
+)
+
+ssh_exec_and_log_stdin "$SRC_HOST" "$COPY_CMD" "$CEPH_UTILS" \
+                 "Error cloning $RBD_DST to $DST in $SRC_HOST"
diff --git a/src/tm_mad/ceph/delete b/src/tm_mad/ceph/delete
index f0937e9dd6f..fa2033ea9a7 100755
--- a/src/tm_mad/ceph/delete
+++ b/src/tm_mad/ceph/delete
@@ -115,8 +115,7 @@ done < <(onevm show -x $VM_ID | $XPATH \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_USER \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_KEY \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_CONF \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/POOL_NAME \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/TYPE )
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/POOL_NAME)
 
 SRC="${XPATH_ELEMENTS[j++]}"
 CLONE="${XPATH_ELEMENTS[j++]}"
@@ -124,7 +123,6 @@ CEPH_USER="${XPATH_ELEMENTS[j++]}"
 CEPH_KEY="${XPATH_ELEMENTS[j++]}"
 CEPH_CONF="${XPATH_ELEMENTS[j++]}"
 POOL_NAME="${XPATH_ELEMENTS[j++]:-$POOL_NAME}"
-TYPE="${XPATH_ELEMENTS[j++]}"
 
 # No need to delete no cloned images
 if [ "$CLONE" = "NO" ]; then
@@ -159,24 +157,20 @@ fi
 
 log "Deleting $DST_PATH"
 
-if [ "${TYPE}" = 'FILE' ]; then
-    exit 0
-else
-    DELETE_CMD=$(cat <<EOF
-        RBD="${RBD}"
+DELETE_CMD=$(cat <<EOF
+    RBD="${RBD}"
 
-        if [ "\$(rbd_format $RBD_SRC)" = "2" ]; then
-            rbd_rm_r \$(rbd_top_parent $RBD_SRC)
+    if [ "\$(rbd_format $RBD_SRC)" = "2" ]; then
+        rbd_rm_r \$(rbd_top_parent $RBD_SRC)
 
-            if [ -n "$RBD_SNAP" ]; then
-                rbd_rm_snap $SRC $RBD_SNAP
-            fi
-        else
-            $RBD rm $RBD_SRC
+        if [ -n "$RBD_SNAP" ]; then
+            rbd_rm_snap $SRC $RBD_SNAP
         fi
+    else
+        $RBD rm $RBD_SRC
+    fi
 EOF
 )
-fi
 
 ssh_exec_and_log_stdin "$DST_HOST" "$DELETE_CMD" "$CEPH_UTILS" \
                  "Error deleting $RBD_SRC in $DST_HOST"
diff --git a/src/tm_mad/ceph/delete.ssh b/src/tm_mad/ceph/delete.ssh
new file mode 100755
index 00000000000..ee8a3f1a46b
--- /dev/null
+++ b/src/tm_mad/ceph/delete.ssh
@@ -0,0 +1,20 @@
+#!/bin/bash
+
+# -------------------------------------------------------------------------- #
+# Copyright 2002-2019, OpenNebula Project, OpenNebula Systems                #
+#                                                                            #
+# 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.                                             #
+#--------------------------------------------------------------------------- #
+
+# Nothing to do
+exit 0
diff --git a/src/tm_mad/ceph/ln b/src/tm_mad/ceph/ln
index 8fdf18952d4..73cf09bb9e2 100755
--- a/src/tm_mad/ceph/ln
+++ b/src/tm_mad/ceph/ln
@@ -56,9 +56,6 @@ DISK_ID=$(echo $DST|awk -F. '{print $NF}')
 #-------------------------------------------------------------------------------
 
 SRC_PATH=`arg_path $SRC`
-DST_PATH=`arg_path $DST`
-
-DST_DIR=`dirname $DST_PATH`
 
 XPATH="${DRIVER_PATH}/../../datastore/xpath.rb --stdin"
 
@@ -69,13 +66,11 @@ while IFS= read -r -d '' element; do
 done < <(onevm show -x $VM_ID| $XPATH  \
                      /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_USER \
                      /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_KEY \
-                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_CONF \
-                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/TYPE )
+                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_CONF)
 
 CEPH_USER="${XPATH_ELEMENTS[j++]}"
 CEPH_KEY="${XPATH_ELEMENTS[j++]}"
 CEPH_CONF="${XPATH_ELEMENTS[j++]}"
-TYPE="${XPATH_ELEMENTS[j++]}"
 
 #-------------------------------------------------------------------------------
 # Remove any @snap in image (non persistent -> persistnet)
@@ -93,27 +88,12 @@ if [ -n "$CEPH_CONF" ]; then
     RBD="$RBD --conf ${CEPH_CONF}"
 fi
 
-if [ "${TYPE}" = 'FILE' ]; then
-    ssh_make_path $DST_HOST $DST_DIR 'ssh'
-
-    LN_CMD=$(cat <<EOF
-        RBD="${RBD}"
-
-        rbd_rm_snap $SRC_PATH
+LN_CMD=$(cat <<EOF
+    RBD="${RBD}"
 
-        set -e -o pipefail
-
-        $RBD export $SRC_PATH $DST_PATH
+    rbd_rm_snap $SRC_PATH
 EOF
 )
-else
-    LN_CMD=$(cat <<EOF
-        RBD="${RBD}"
-
-        rbd_rm_snap $SRC_PATH
-EOF
-)
-fi
 
 ssh_exec_and_log_stdin "$DST_HOST" "$LN_CMD" "$CEPH_UTILS" \
                  "Error cloning $SRC_PATH to $RBD_DST in $DST_HOST"
diff --git a/src/tm_mad/ceph/ln.ssh b/src/tm_mad/ceph/ln.ssh
new file mode 100755
index 00000000000..4e219a34ea7
--- /dev/null
+++ b/src/tm_mad/ceph/ln.ssh
@@ -0,0 +1,109 @@
+#!/bin/bash
+
+# -------------------------------------------------------------------------- #
+# Copyright 2002-2019, OpenNebula Project, OpenNebula Systems                #
+#                                                                            #
+# 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.                                             #
+#--------------------------------------------------------------------------- #
+
+# clone fe:SOURCE host:remote_system_ds/disk.i size
+#   - fe is the front-end hostname
+#   - SOURCE is the path of the disk image in the form DS_BASE_PATH/disk
+#   - host is the target host to deploy the VM
+#   - remote_system_ds is the path for the system datastore in the host
+
+SRC=$1
+DST=$2
+VM_ID=$3
+DS_ID=$4
+
+#--------------------------------------------------------------------------------
+
+if [ -z "${ONE_LOCATION}" ]; then
+    TMCOMMON=/var/lib/one/remotes/tm/tm_common.sh
+    LIB_LOCATION=/usr/lib/one
+else
+    TMCOMMON=$ONE_LOCATION/var/remotes/tm/tm_common.sh
+    LIB_LOCATION=$ONE_LOCATION/lib
+fi
+
+DRIVER_PATH=$(dirname $0)
+
+source $TMCOMMON
+source ${DRIVER_PATH}/../../etc/datastore/ceph/ceph.conf
+
+CEPH_UTILS=${DRIVER_PATH}/../../datastore/ceph/ceph_utils.sh
+
+#-------------------------------------------------------------------------------
+# Process destination
+#-------------------------------------------------------------------------------
+
+DST_HOST=`arg_host $DST`
+DISK_ID=$(echo $DST|awk -F. '{print $NF}')
+
+#-------------------------------------------------------------------------------
+# Get Image information & destination image
+#-------------------------------------------------------------------------------
+
+SRC_PATH=`arg_path $SRC`
+DST_PATH=`arg_path $DST`
+
+DST_DIR=`dirname $DST_PATH`
+
+XPATH="${DRIVER_PATH}/../../datastore/xpath.rb --stdin"
+
+unset i j XPATH_ELEMENTS
+
+while IFS= read -r -d '' element; do
+        XPATH_ELEMENTS[i++]="$element"
+done < <(onevm show -x $VM_ID| $XPATH  \
+                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_USER \
+                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_KEY \
+                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_CONF)
+
+CEPH_USER="${XPATH_ELEMENTS[j++]}"
+CEPH_KEY="${XPATH_ELEMENTS[j++]}"
+CEPH_CONF="${XPATH_ELEMENTS[j++]}"
+
+#-------------------------------------------------------------------------------
+# Remove any @snap in image (non persistent -> persistnet)
+#-------------------------------------------------------------------------------
+
+if [ -n "$CEPH_USER" ]; then
+    RBD="$RBD --id ${CEPH_USER}"
+fi
+
+if [ -n "$CEPH_KEY" ]; then
+    RBD="$RBD --keyfile ${CEPH_KEY}"
+fi
+
+if [ -n "$CEPH_CONF" ]; then
+    RBD="$RBD --conf ${CEPH_CONF}"
+fi
+
+ssh_make_path $DST_HOST $DST_DIR 'ssh'
+
+LN_CMD=$(cat <<EOF
+    RBD="${RBD}"
+
+    rbd_rm_snap $SRC_PATH
+
+    set -e -o pipefail
+
+    $RBD export $SRC_PATH $DST_PATH
+EOF
+)
+
+ssh_exec_and_log_stdin "$DST_HOST" "$LN_CMD" "$CEPH_UTILS" \
+                 "Error cloning $SRC_PATH to $RBD_DST in $DST_HOST"
+exit 0
diff --git a/src/tm_mad/ceph/mvds b/src/tm_mad/ceph/mvds
index 6bbf52cd1f2..dcc1e60d2ce 100755
--- a/src/tm_mad/ceph/mvds
+++ b/src/tm_mad/ceph/mvds
@@ -23,107 +23,5 @@
 #   - remote_system_ds is the path for the system datastore in the host
 #   - vmid is the id of the VM
 #   - dsid is the target datastore (0 is the system datastore)
-
-SRC=$1
-DST=$2
-VMID=$3
-DSID=$4
-
-#--------------------------------------------------------------------------------
-
-if [ -z "${ONE_LOCATION}" ]; then
-    TMCOMMON=/var/lib/one/remotes/tm/tm_common.sh
-    LIB_LOCATION=/usr/lib/one
-else
-    TMCOMMON=$ONE_LOCATION/var/remotes/tm/tm_common.sh
-    LIB_LOCATION=$ONE_LOCATION/lib
-fi
-
-DRIVER_PATH=$(dirname $0)
-
-source $TMCOMMON
-source ${DRIVER_PATH}/../../etc/datastore/ceph/ceph.conf
-
-CEPH_UTILS=${DRIVER_PATH}/../../datastore/ceph/ceph_utils.sh
-
-#-------------------------------------------------------------------------------
-# Set dst path and dir
-#-------------------------------------------------------------------------------
-
-SRC_PATH=`arg_path $SRC`
-SRC_HOST=`arg_host $SRC`
-RBD_SRC=`arg_path $SRC`
-
-#-------------------------------------------------------------------------------
-# Get Image information
-#-------------------------------------------------------------------------------
-
-DISK_ID=$(echo "$RBD_SRC" | $AWK -F. '{print $NF}')
-
-XPATH="${DRIVER_PATH}/../../datastore/xpath.rb --stdin"
-
-unset i j XPATH_ELEMENTS
-
-while IFS= read -r -d '' element; do
-    XPATH_ELEMENTS[i++]="$element"
-done < <(onevm show -x $VMID| $XPATH \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/SOURCE \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CLONE \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_USER \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_KEY \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_CONF \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/TYPE \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/SIZE \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/ORIGINAL_SIZE )
-
-RBD_SRC="${XPATH_ELEMENTS[j++]}"
-CLONE="${XPATH_ELEMENTS[j++]}"
-CEPH_USER="${XPATH_ELEMENTS[j++]}"
-CEPH_KEY="${XPATH_ELEMENTS[j++]}"
-CEPH_CONF="${XPATH_ELEMENTS[j++]}"
-TYPE="${XPATH_ELEMENTS[j++]}"
-SIZE="${XPATH_ELEMENTS[j++]}"
-ORIGINAL_SIZE="${XPATH_ELEMENTS[j++]}"
-
-#-------------------------------------------------------------------------------
-# Copy Image back to the datastore
-#-------------------------------------------------------------------------------
-
-QEMU_OPTS=''
-
-if [ -n "$CEPH_USER" ]; then
-    RBD="$RBD --id ${CEPH_USER}"
-    QEMU_OPTS="${QEMU_OPTS}:id=${CEPH_USER}"
-fi
-
-if [ -n "$CEPH_KEY" ]; then
-    RBD="$RBD --keyfile ${CEPH_KEY}"
-    QEMU_OPTS="${QEMU_OPTS}:keyfile=${CEPH_KEY}"
-fi
-
-if [ -n "$CEPH_CONF" ]; then
-    RBD="$RBD --conf ${CEPH_CONF}"
-    QEMU_OPTS="${QEMU_OPTS}:conf=${CEPH_CONF}"
-fi
-
-if [ "${TYPE}" = 'FILE' ]; then
-    MVDS_CMD=$(cat <<EOF
-        RBD="${RBD}"
-
-        set -e -o pipefail
-
-        if [ -n "$ORIGINAL_SIZE" -a "$SIZE" -gt "$ORIGINAL_SIZE" ]; then
-            $RBD resize $RBD_SRC --size $SIZE
-        fi
-
-        ${QEMU_IMG} convert -n \
-            -f raw "${SRC_PATH}" \
-            -O rbd "rbd:${RBD_SRC}${QEMU_OPTS}"
-EOF
-)
-else
-    exit 0
-fi
-
-ssh_exec_and_log_stdin "$SRC_HOST" "$MVDS_CMD" "$CEPH_UTILS" \
-                 "Error copying $RBD_SRC to $DST in $SRC_HOST" #??
+# Nothing to do
+exit 0
diff --git a/src/tm_mad/ceph/mvds.ssh b/src/tm_mad/ceph/mvds.ssh
new file mode 100755
index 00000000000..9b0c06f3e12
--- /dev/null
+++ b/src/tm_mad/ceph/mvds.ssh
@@ -0,0 +1,121 @@
+#!/bin/bash
+
+# -------------------------------------------------------------------------- #
+# Copyright 2002-2019, OpenNebula Project, OpenNebula Systems                #
+#                                                                            #
+# 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.                                             #
+#--------------------------------------------------------------------------- #
+
+# mvds host:remote_system_ds/disk.i fe:SOURCE vmid dsid
+#   - fe is the front-end hostname
+#   - SOURCE is the path of the disk image in the form DS_BASE_PATH/disk
+#   - host is the target host to deploy the VM
+#   - remote_system_ds is the path for the system datastore in the host
+#   - vmid is the id of the VM
+#   - dsid is the target datastore (0 is the system datastore)
+
+SRC=$1
+DST=$2
+VMID=$3
+DSID=$4
+
+#--------------------------------------------------------------------------------
+
+if [ -z "${ONE_LOCATION}" ]; then
+    TMCOMMON=/var/lib/one/remotes/tm/tm_common.sh
+    LIB_LOCATION=/usr/lib/one
+else
+    TMCOMMON=$ONE_LOCATION/var/remotes/tm/tm_common.sh
+    LIB_LOCATION=$ONE_LOCATION/lib
+fi
+
+DRIVER_PATH=$(dirname $0)
+
+source $TMCOMMON
+source ${DRIVER_PATH}/../../etc/datastore/ceph/ceph.conf
+
+CEPH_UTILS=${DRIVER_PATH}/../../datastore/ceph/ceph_utils.sh
+
+#-------------------------------------------------------------------------------
+# Set dst path and dir
+#-------------------------------------------------------------------------------
+
+SRC_PATH=`arg_path $SRC`
+SRC_HOST=`arg_host $SRC`
+RBD_SRC=`arg_path $SRC`
+
+#-------------------------------------------------------------------------------
+# Get Image information
+#-------------------------------------------------------------------------------
+
+DISK_ID=$(echo "$RBD_SRC" | $AWK -F. '{print $NF}')
+
+XPATH="${DRIVER_PATH}/../../datastore/xpath.rb --stdin"
+
+unset i j XPATH_ELEMENTS
+
+while IFS= read -r -d '' element; do
+    XPATH_ELEMENTS[i++]="$element"
+done < <(onevm show -x $VMID| $XPATH \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/SOURCE \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_USER \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_KEY \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_CONF \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/SIZE \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/ORIGINAL_SIZE )
+
+RBD_SRC="${XPATH_ELEMENTS[j++]}"
+CEPH_USER="${XPATH_ELEMENTS[j++]}"
+CEPH_KEY="${XPATH_ELEMENTS[j++]}"
+CEPH_CONF="${XPATH_ELEMENTS[j++]}"
+SIZE="${XPATH_ELEMENTS[j++]}"
+ORIGINAL_SIZE="${XPATH_ELEMENTS[j++]}"
+
+#-------------------------------------------------------------------------------
+# Copy Image back to the datastore
+#-------------------------------------------------------------------------------
+
+QEMU_OPTS=''
+
+if [ -n "$CEPH_USER" ]; then
+    RBD="$RBD --id ${CEPH_USER}"
+    QEMU_OPTS="${QEMU_OPTS}:id=${CEPH_USER}"
+fi
+
+if [ -n "$CEPH_KEY" ]; then
+    RBD="$RBD --keyfile ${CEPH_KEY}"
+    QEMU_OPTS="${QEMU_OPTS}:keyfile=${CEPH_KEY}"
+fi
+
+if [ -n "$CEPH_CONF" ]; then
+    RBD="$RBD --conf ${CEPH_CONF}"
+    QEMU_OPTS="${QEMU_OPTS}:conf=${CEPH_CONF}"
+fi
+
+MVDS_CMD=$(cat <<EOF
+    RBD="${RBD}"
+
+    set -e -o pipefail
+
+    if [ -n "$ORIGINAL_SIZE" -a "$SIZE" -gt "$ORIGINAL_SIZE" ]; then
+        $RBD resize $RBD_SRC --size $SIZE
+    fi
+
+    ${QEMU_IMG} convert -n \
+        -f raw "${SRC_PATH}" \
+        -O rbd "rbd:${RBD_SRC}${QEMU_OPTS}"
+EOF
+)
+
+ssh_exec_and_log_stdin "$SRC_HOST" "$MVDS_CMD" "$CEPH_UTILS" \
+                 "Error copying $RBD_SRC to $DST in $SRC_HOST" #??
diff --git a/src/tm_mad/ceph/resize b/src/tm_mad/ceph/resize
index 7ec5135cb50..9088a1b976b 100755
--- a/src/tm_mad/ceph/resize
+++ b/src/tm_mad/ceph/resize
@@ -64,8 +64,7 @@ done < <(onevm show -x $VM_ID| $XPATH \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_KEY \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CEPH_CONF \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/PERSISTENT \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/POOL_NAME \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/TYPE )
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/POOL_NAME)
 
 RBD_SRC="${XPATH_ELEMENTS[j++]}"
 CEPH_USER="${XPATH_ELEMENTS[j++]}"
@@ -73,7 +72,6 @@ CEPH_KEY="${XPATH_ELEMENTS[j++]}"
 CEPH_CONF="${XPATH_ELEMENTS[j++]}"
 PERSISTENT="${XPATH_ELEMENTS[j++]}"
 POOL_NAME="${XPATH_ELEMENTS[j++]:-$POOL_NAME}"
-TYPE="${XPATH_ELEMENTS[j++]}"
 
 if [ -n "${RBD_SRC}" ]; then
     if [ "${PERSISTENT}" = 'YES' ]; then
@@ -109,17 +107,10 @@ if [ `lcm_state $VM_ID` -eq 62 ]; then
     exit 0
 fi
 
-if [ "${TYPE}" = 'FILE' ]; then
-    RESIZE_CMD=$(cat <<EOF
-        ${QEMU_IMG} resize "${SRC_PATH}" "${SIZE}M"
+RESIZE_CMD=$(cat <<EOF
+    $RBD resize --size ${SIZE} $RBD_DST
 EOF
 )
-else
-    RESIZE_CMD=$(cat <<EOF
-        $RBD resize --size ${SIZE} $RBD_DST
-EOF
-)
-fi
 
 ssh_exec_and_log_stdin "$SRC_HOST" "$RESIZE_CMD" "$CEPH_UTILS" \
                  "Error resizing disk $RBD_DST"
diff --git a/src/tm_mad/ceph/resize.ssh b/src/tm_mad/ceph/resize.ssh
new file mode 100755
index 00000000000..4bdeb556798
--- /dev/null
+++ b/src/tm_mad/ceph/resize.ssh
@@ -0,0 +1,63 @@
+#!/bin/bash
+
+# -------------------------------------------------------------------------- #
+# Copyright 2002-2019, OpenNebula Project, OpenNebula Systems                #
+#                                                                            #
+# 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.                                             #
+#--------------------------------------------------------------------------- #
+
+# resize image size vmid
+
+SRC=$1
+SIZE=$2
+VM_ID=$3
+
+#--------------------------------------------------------------------------------
+
+if [ -z "${ONE_LOCATION}" ]; then
+    TMCOMMON=/var/lib/one/remotes/tm/tm_common.sh
+    LIB_LOCATION=/usr/lib/one
+else
+    TMCOMMON=$ONE_LOCATION/var/remotes/tm/tm_common.sh
+    LIB_LOCATION=$ONE_LOCATION/lib
+fi
+
+DRIVER_PATH=$(dirname $0)
+
+source $TMCOMMON
+
+#-------------------------------------------------------------------------------
+# Set dst path and dir
+#-------------------------------------------------------------------------------
+
+SRC_HOST=`arg_host $SRC`
+SRC_PATH=`arg_path $SRC`
+
+#-------------------------------------------------------------------------------
+# Resize disk
+#-------------------------------------------------------------------------------
+
+# for running VMs, leave disk resize on kvm/resize_disk
+if [ `lcm_state $VM_ID` -eq 62 ]; then
+    log "Not resizing disk ${SRC_PATH} for running virt. machine directly"
+    exit 0
+fi
+
+RESIZE_CMD=$(cat <<EOF
+    ${QEMU_IMG} resize "${SRC_PATH}" "${SIZE}M"
+EOF
+)
+
+ssh_exec_and_log "$SRC_HOST" "$RESIZE_CMD" "Error resizing disk $SRC_PATH"
+
+exit 0
diff --git a/src/tm_mad/one_tm.rb b/src/tm_mad/one_tm.rb
index 0c7f3700b97..e71d5684207 100755
--- a/src/tm_mad/one_tm.rb
+++ b/src/tm_mad/one_tm.rb
@@ -106,6 +106,21 @@ def do_transfer_action(id, command)
         end
 
         path = File.join(@local_scripts_path, tm, cmd)
+
+        if !File.exists?(path)
+            md  = cmd.match(/(.*)\.(.*)/)
+            if md && md[1]
+                path_shortened = File.join(@local_scripts_path, tm, md[1])
+                if !File.exists?(path_shortened)
+                    return RESULT[:failure],
+                        "Driver path '#{path}' nor '#{path_shortened}' does not exists"
+                end
+                path = path_shortened
+            else
+                return RESULT[:failure], "Driver path '#{path}' does not exists"
+            end
+        end
+
         path << " " << args
         rc = LocalCommand.run(path, log_method(id))
 
diff --git a/src/tm_mad/qcow2/clone b/src/tm_mad/qcow2/clone
index 37f6d8ba8a7..63978e0e5a2 100755
--- a/src/tm_mad/qcow2/clone
+++ b/src/tm_mad/qcow2/clone
@@ -70,24 +70,12 @@ while IFS= read -r -d '' element; do
     XPATH_ELEMENTS[i++]="$element"
 done < <(onevm show -x $VMID| $XPATH \
                     /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/SIZE \
-                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/ORIGINAL_SIZE \
-                    /VM/HISTORY_RECORDS/HISTORY[last\(\)]/TM_MAD)
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/ORIGINAL_SIZE)
 
 SIZE="${XPATH_ELEMENTS[j++]}"
 ORIGINAL_SIZE="${XPATH_ELEMENTS[j++]}"
-TM_MAD="${XPATH_ELEMENTS[j++]}"
 
-if [ "$TM_MAD" = "ssh" ]; then
-    MONITOR="ssh"
-else
-    MONITOR=""
-fi
-
-#-------------------------------------------------------------------------------
-# Create DST path
-#-------------------------------------------------------------------------------
-
-ssh_make_path $DST_HOST $DST_DIR $MONITOR
+ssh_make_path $DST_HOST $DST_DIR
 
 #-------------------------------------------------------------------------------
 # Clone (cp) SRC into DST
diff --git a/src/tm_mad/qcow2/clone.ssh b/src/tm_mad/qcow2/clone.ssh
new file mode 100755
index 00000000000..9b5ac798773
--- /dev/null
+++ b/src/tm_mad/qcow2/clone.ssh
@@ -0,0 +1,125 @@
+#!/bin/bash
+
+# -------------------------------------------------------------------------- #
+# Copyright 2002-2019, OpenNebula Project, OpenNebula Systems                #
+#                                                                            #
+# 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.                                             #
+#--------------------------------------------------------------------------- #
+
+# clone fe:SOURCE host:remote_system_ds/disk.i vmid dsid
+#   - fe is the front-end hostname
+#   - SOURCE is the path of the disk image in the form DS_BASE_PATH/disk
+#   - host is the target host to deploy the VM
+#   - remote_system_ds is the path for the system datastore in the host
+#   - vmid is the id of the VM
+#   - dsid is the target datastore (0 is the system datastore)
+
+SRC=$1
+DST=$2
+
+VMID=$3
+DSID=$4
+
+if [ -z "${ONE_LOCATION}" ]; then
+    TMCOMMON=/var/lib/one/remotes/tm/tm_common.sh
+else
+    TMCOMMON=$ONE_LOCATION/var/remotes/tm/tm_common.sh
+fi
+
+. $TMCOMMON
+
+DRIVER_PATH=$(dirname $0)
+
+#-------------------------------------------------------------------------------
+# Set dst path and dir
+#-------------------------------------------------------------------------------
+DST_PATH=`arg_path $DST`
+DST_HOST=`arg_host $DST`
+DST_DIR=`dirname $DST_PATH`
+
+SRC_ARG_PATH=`arg_path $SRC`
+
+DST_DS_PATH="$(dirname $(dirname $(dirname $DST_PATH)))"
+SRC_DS_PATH="$(dirname $(dirname $SRC_ARG_PATH))"
+
+SRC_PATH="${DST_DS_PATH}${SRC_ARG_PATH##$SRC_DS_PATH}"
+
+DST_FILE=$(basename "$DST_PATH")
+
+#-------------------------------------------------------------------------------
+# Get Image information
+#-------------------------------------------------------------------------------
+
+DISK_ID=$(basename ${DST_PATH} | cut -d. -f2)
+
+XPATH="${DRIVER_PATH}/../../datastore/xpath.rb --stdin"
+
+unset i j XPATH_ELEMENTS
+
+while IFS= read -r -d '' element; do
+    XPATH_ELEMENTS[i++]="$element"
+done < <(onevm show -x $VMID| $XPATH \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/SIZE \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/ORIGINAL_SIZE)
+
+SIZE="${XPATH_ELEMENTS[j++]}"
+ORIGINAL_SIZE="${XPATH_ELEMENTS[j++]}"
+
+#-------------------------------------------------------------------------------
+# Create DST path
+#-------------------------------------------------------------------------------
+
+ssh_make_path $DST_HOST $DST_DIR 'ssh'
+
+#-------------------------------------------------------------------------------
+# Clone (cp) SRC into DST
+#-------------------------------------------------------------------------------
+
+type="$(file -b --mime-type $SRC_PATH)"
+
+if [ "$type" == "application/x-iso9660-image" ]; then
+    CLONE_CMD="cp ${SRC_PATH} ${DST_PATH}"
+else
+    if [ -n "$ORIGINAL_SIZE" -a "$SIZE" -gt "$ORIGINAL_SIZE" ]; then
+       RESIZE_CMD="qemu-img resize ${DST_PATH} ${SIZE}M"
+    fi
+
+    CLONE_CMD=$(cat <<EOF
+set -e -o pipefail
+
+cd $DST_DIR
+
+rm -rf "${DST_PATH}.snap"
+
+mkdir -p "${DST_PATH}.snap"
+
+B_FORMAT=\$($QEMU_IMG info $SRC_PATH | grep "^file format:" | awk '{print \$3}' || :)
+$QEMU_IMG create -o backing_fmt=\${B_FORMAT:-raw} -b $SRC_PATH -f qcow2 $QCOW2_OPTIONS ${DST_PATH}.snap/0
+
+rm -f "${DST_PATH}"
+
+ln -s ${DST_FILE}.snap/0 ${DST_PATH}
+
+cd ${DST_PATH}.snap
+
+ln -s . ${DST_PATH}.snap/${DST_FILE}.snap
+
+${RESIZE_CMD}
+EOF
+)
+fi
+
+log "Cloning $SRC_PATH in $DST"
+ssh_exec_and_log "$DST_HOST" "$CLONE_CMD" "Error copying $SRC to $DST"
+
+exit 0
diff --git a/src/tm_mad/qcow2/cpds.ssh b/src/tm_mad/qcow2/cpds.ssh
new file mode 100755
index 00000000000..5c37677b837
--- /dev/null
+++ b/src/tm_mad/qcow2/cpds.ssh
@@ -0,0 +1,135 @@
+#!/bin/bash
+
+# -------------------------------------------------------------------------- #
+# Copyright 2002-2019, OpenNebula Project, OpenNebula Systems                #
+#                                                                            #
+# 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.                                             #
+#--------------------------------------------------------------------------- #
+
+# mvds host:remote_system_ds/disk.i fe:SOURCE snapid vmid dsid
+#   - fe is the front-end hostname
+#   - SOURCE is the path of the disk image in the form DS_BASE_PATH/disk
+#   - host is the target host to deploy the VM
+#   - remote_system_ds is the path for the system datastore in the host
+#   - vmid is the id of the VM
+#   - dsid is the target datastore (0 is the system datastore)
+#   - snapid is the snapshot id. "-1" for none
+
+SRC=$1
+DST=$2
+SNAP_ID=$3
+VMID=$4
+DSID=$5
+
+if [ -z "${ONE_LOCATION}" ]; then
+    TMCOMMON=/var/lib/one/remotes/tm/tm_common.sh
+else
+    TMCOMMON=$ONE_LOCATION/var/remotes/tm/tm_common.sh
+fi
+
+DRIVER_PATH=$(dirname $0)
+
+. $TMCOMMON
+. ${DRIVER_PATH}/../../etc/vmm/kvm/kvmrc
+
+#-------------------------------------------------------------------------------
+# Get Image information
+#-------------------------------------------------------------------------------
+
+DISK_ID=$(basename ${SRC} | cut -d. -f2)
+
+XPATH="${DRIVER_PATH}/../../datastore/xpath.rb --stdin"
+
+unset i j XPATH_ELEMENTS
+
+while IFS= read -r -d '' element; do
+    XPATH_ELEMENTS[i++]="$element"
+done < <(onevm show -x $VMID| $XPATH \
+                    /VM/DEPLOY_ID \
+                    /VM/LCM_STATE \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/TARGET \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/SOURCE \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CLONE)
+
+DEPLOY_ID="${XPATH_ELEMENTS[j++]}"
+LCM_STATE="${XPATH_ELEMENTS[j++]}"
+DISK_TARGET="${XPATH_ELEMENTS[j++]}"
+DISK_SRC="${XPATH_ELEMENTS[j++]}"
+CLONE="${XPATH_ELEMENTS[j++]}"
+
+#-------------------------------------------------------------------------------
+# Set dst path and dir
+#-------------------------------------------------------------------------------
+SRC_PATH=`arg_path $SRC`
+SRC_HOST=`arg_host $SRC`
+SRC_DIR=`dirname $SRC_PATH`
+
+DST_ARG_PATH=`arg_path $DST`
+
+SRC_DS_PATH="$(dirname $(dirname $(dirname $SRC_PATH)))"
+DST_DS_PATH="$(dirname $(dirname $DST_ARG_PATH))"
+
+DST_PATH="${SRC_DS_PATH}${DST_ARG_PATH##$DST_DS_PATH}"
+
+if [ "$SNAP_ID" != "-1" ]; then
+    [ "$CLONE" != "YES" ] && SRC_PATH="$DISK_SRC"
+    SRC_PATH="$SRC_PATH.snap/$SNAP_ID"
+fi
+
+#-------------------------------------------------------------------------------
+# Move the image back to the datastore
+#-------------------------------------------------------------------------------
+
+# For current image of the running VMs, don't touch the image directly,
+# but export the content via blockcopy. If that's not possible (old QEMU),
+# domfsfreeze or suspend the domain before.
+if [ "${LCM_STATE}" = '26' ] && [ "${SNAP_ID}" = '-1' ]; then
+    CPDS_CMD_EXPORT=$(cat <<EOF
+touch ${DST_PATH}
+if ! virsh -c ${LIBVIRT_URI} blockcopy ${DEPLOY_ID} ${DISK_TARGET} ${DST_PATH} --wait --finish; then
+    if virsh -c ${LIBVIRT_URI} domfsfreeze ${DEPLOY_ID}; then
+        trap "virsh -c ${LIBVIRT_URI} domfsthaw ${DEPLOY_ID}" EXIT TERM INT HUP
+    elif virsh -c ${LIBVIRT_URI} suspend ${DEPLOY_ID}; then
+        trap "virsh -c ${LIBVIRT_URI} resume ${DEPLOY_ID}" EXIT TERM INT HUP
+    else
+        echo "Could not domfsfreeze or suspend domain" >&2
+        exit 1
+    fi
+
+    ${QEMU_IMG} convert ${SRC_PATH} -O qcow2 ${DST_PATH}
+fi
+EOF
+)
+else
+    CPDS_CMD_EXPORT="${QEMU_IMG} convert ${SRC_PATH} -O qcow2 ${DST_PATH}"
+fi
+
+CPDS_CMD=$(cat <<EOF
+set -e -o pipefail
+
+SRC_READLN=\$($READLINK -f $SRC_PATH)
+DST_READLN=\$($READLINK -f $DST_PATH)
+
+if [ \( -L $SRC_PATH \) -a \( "\$SRC_READLN" = "\$DST_READLN" \) ] ; then
+    echo "Not moving files to image repo, they are the same"
+else
+    ${CPDS_CMD_EXPORT}
+fi
+EOF
+)
+
+log "Copying $SRC_PATH to datastore as $DST_PATH"
+
+ssh_exec_and_log $SRC_HOST "$CPDS_CMD" "Could not move image $DST_PATH"
+
+exit 0
diff --git a/src/tm_mad/qcow2/ln b/src/tm_mad/qcow2/ln
index de6bb4afd8b..2f71761efd3 100755
--- a/src/tm_mad/qcow2/ln
+++ b/src/tm_mad/qcow2/ln
@@ -56,32 +56,11 @@ SRC_PATH="${DST_DS_PATH}${SRC_ARG_PATH##$SRC_DS_PATH}"
 SNAP_DIR="${SRC_PATH}.snap"
 SNAP_NAME="$(basename $SNAP_DIR)"
 
-#-------------------------------------------------------------------------------
-# Get Image information
-#-------------------------------------------------------------------------------
-
-XPATH="${DRIVER_PATH}/../../datastore/xpath.rb --stdin"
-
-unset i j XPATH_ELEMENTS
-
-while IFS= read -r -d '' element; do
-    XPATH_ELEMENTS[i++]="$element"
-done < <(onevm show -x $VMID| $XPATH \
-                    /VM/HISTORY_RECORDS/HISTORY[last\(\)]/TM_MAD)
-
-TM_MAD="${XPATH_ELEMENTS[j++]}"
-
-if [ "$TM_MAD" = "ssh" ]; then
-    MONITOR="ssh"
-else
-    MONITOR=""
-fi
-
 #-------------------------------------------------------------------------------
 # Create DST path
 #-------------------------------------------------------------------------------
 
-ssh_make_path $DST_HOST $DST_DIR $MONITOR
+ssh_make_path $DST_HOST $DST_DIR
 
 #-------------------------------------------------------------------------------
 # Link (ln) SRC into DST
diff --git a/src/tm_mad/qcow2/ln.ssh b/src/tm_mad/qcow2/ln.ssh
new file mode 100755
index 00000000000..0cf962cf1d2
--- /dev/null
+++ b/src/tm_mad/qcow2/ln.ssh
@@ -0,0 +1,104 @@
+#!/bin/bash
+
+# -------------------------------------------------------------------------- #
+# Copyright 2002-2019, OpenNebula Project, OpenNebula Systems                #
+#                                                                            #
+# 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.                                             #
+#--------------------------------------------------------------------------- #
+
+# ln fe:SOURCE host:remote_system_ds/disk.i vmid dsid
+#   - fe is the front-end hostname
+#   - SOURCE is the path of the disk image in the form DS_BASE_PATH/disk
+#   - host is the target host to deploy the VM
+#   - remote_system_ds is the path for the system datastore in the host
+#   - vmid is the id of the VM
+#   - dsid is the target datastore (0 is the system datastore)
+
+SRC=$1
+DST=$2
+
+VMID=$3
+DSID=$4
+
+if [ -z "${ONE_LOCATION}" ]; then
+    TMCOMMON=/var/lib/one/remotes/tm/tm_common.sh
+else
+    TMCOMMON=$ONE_LOCATION/var/remotes/tm/tm_common.sh
+fi
+
+. $TMCOMMON
+
+DRIVER_PATH=$(dirname $0)
+
+#-------------------------------------------------------------------------------
+# Set dst path and dir
+#-------------------------------------------------------------------------------
+DST_PATH=`arg_path $DST`
+DST_HOST=`arg_host $DST`
+DST_DIR=`dirname $DST_PATH`
+
+SRC_ARG_PATH=`arg_path $SRC`
+
+DST_DS_PATH="$(dirname $(dirname $(dirname $DST_PATH)))"
+SRC_DS_PATH="$(dirname $(dirname $SRC_ARG_PATH))"
+
+SRC_PATH="${DST_DS_PATH}${SRC_ARG_PATH##$SRC_DS_PATH}"
+SNAP_DIR="${SRC_PATH}.snap"
+SNAP_NAME="$(basename $SNAP_DIR)"
+
+#-------------------------------------------------------------------------------
+# Create DST path
+#-------------------------------------------------------------------------------
+
+ssh_make_path $DST_HOST $DST_DIR 'ssh'
+
+#-------------------------------------------------------------------------------
+# Link (ln) SRC into DST
+#-------------------------------------------------------------------------------
+log "Linking $SRC_PATH in $DST"
+
+type="$(file -b --mime-type $SRC_PATH)"
+
+if [ "$type" == "application/x-iso9660-image" ]; then
+    CMD="ln -sf ${SRC_PATH} ${DST_PATH}"
+else
+    CMD=$(cat <<EOT
+set -ex -o pipefail
+
+mkdir -p "${SNAP_DIR}"
+
+if [ ! -L "${SNAP_DIR}/${SNAP_NAME}" ]; then
+    ln -s "${SNAP_DIR}" "${SNAP_DIR}/${SNAP_NAME}"
+fi
+
+SNAP="\$(ls ${SNAP_DIR} | grep '^[[:digit:]]*$' | sort -n | tail -n 1 || :)"
+
+if [ -z "\${SNAP}" ]; then
+    SNAP=0
+    ln -sf "$SRC_PATH" "$SNAP_DIR/0"
+fi
+
+rm -f "${DST_PATH}"
+
+ln -sf "$SNAP_DIR/\$SNAP" "$DST_PATH"
+
+rm -rf "${DST_PATH}.snap"
+
+ln -sf "$SNAP_DIR" "${DST_PATH}.snap"
+EOT
+)
+fi
+
+ssh_exec_and_log $DST_HOST "$CMD" "Error linking $SRC to $DST"
+
+exit 0
diff --git a/src/tm_mad/qcow2/mvds.ssh b/src/tm_mad/qcow2/mvds.ssh
new file mode 100755
index 00000000000..f796af2c7c4
--- /dev/null
+++ b/src/tm_mad/qcow2/mvds.ssh
@@ -0,0 +1,83 @@
+#!/bin/bash
+
+# -------------------------------------------------------------------------- #
+# Copyright 2002-2019, OpenNebula Project, OpenNebula Systems                #
+#                                                                            #
+# 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.                                             #
+#--------------------------------------------------------------------------- #
+
+# mvds host:remote_system_ds/disk.i fe:SOURCE vmid dsid
+#   - fe is the front-end hostname
+#   - SOURCE is the path of the disk image in the form DS_BASE_PATH/disk
+#   - host is the target host to deploy the VM
+#   - remote_system_ds is the path for the system datastore in the host
+#   - vmid is the id of the VM
+#   - dsid is the target datastore (0 is the system datastore)
+
+SRC=$1
+DST=$2
+
+VMID=$3
+DSID=$4
+
+if [ -z "${ONE_LOCATION}" ]; then
+    TMCOMMON=/var/lib/one/remotes/tm/tm_common.sh
+else
+    TMCOMMON=$ONE_LOCATION/var/remotes/tm/tm_common.sh
+fi
+
+. $TMCOMMON
+
+DRIVER_PATH=$(dirname $0)
+
+#-------------------------------------------------------------------------------
+# Get Image information
+#-------------------------------------------------------------------------------
+
+DISK_ID=$(basename ${SRC} | cut -d. -f2)
+
+XPATH="${DRIVER_PATH}/../../datastore/xpath.rb --stdin"
+
+unset i j XPATH_ELEMENTS
+
+while IFS= read -r -d '' element; do
+    XPATH_ELEMENTS[i++]="$element"
+done < <(onevm show -x $VMID| $XPATH \
+                    /VM/TEMPLATE/DISK[DISK_ID=$DISK_ID]/CLONE)
+
+CLONE="${XPATH_ELEMENTS[j++]}"
+if [ "$CLONE" != "YES" ]; then
+  # it's persistent image, nothing to do
+  exit 0
+fi
+
+#-------------------------------------------------------------------------------
+# Set dst path and dir
+#-------------------------------------------------------------------------------
+
+SRC_PATH="$(arg_path $SRC)"
+SRC_HOST="$(arg_host $SRC)"
+
+DST_PATH="$(arg_path $DST)"
+
+#-------------------------------------------------------------------------------
+# Move the image back to the datastore
+#-------------------------------------------------------------------------------
+
+log "Moving $SRC to datastore as $DST"
+
+ssh_exec_and_log "${SRC_HOST}" \
+    "cp -r ${SRC_PATH} ${DST_PATH}" \
+    "Error copying ${SRC} to ${DST}" >&2
+
+exit 0
diff --git a/src/tm_mad/shared/mvds b/src/tm_mad/shared/mvds
index c8f103aece0..b123e037422 100755
--- a/src/tm_mad/shared/mvds
+++ b/src/tm_mad/shared/mvds
@@ -24,60 +24,5 @@
 #   - vmid is the id of the VM
 #   - dsid is the target datastore (0 is the system datastore)
 
-SRC=$1
-DST=$2
-
-VMID=$3
-DSID=$4
-
-if [ -z "${ONE_LOCATION}" ]; then
-    TMCOMMON=/var/lib/one/remotes/tm/tm_common.sh
-else
-    TMCOMMON=$ONE_LOCATION/var/remotes/tm/tm_common.sh
-fi
-
-. $TMCOMMON
-
-DRIVER_PATH=$(dirname $0)
-
-#-------------------------------------------------------------------------------
-# Set dst path and dir
-#-------------------------------------------------------------------------------
-
-SRC_PATH="$(arg_path $SRC)"
-SRC_HOST="$(arg_host $SRC)"
-
-DST_PATH="$(arg_path $DST)"
-
-#-------------------------------------------------------------------------------
-# Get Image information
-#-------------------------------------------------------------------------------
-
-DISK_ID=$(basename ${SRC_PATH} | cut -d. -f2)
-
-XPATH="${DRIVER_PATH}/../../datastore/xpath.rb --stdin"
-
-unset i j XPATH_ELEMENTS
-
-set -x
-
-while IFS= read -r -d '' element; do
-    XPATH_ELEMENTS[i++]="$element"
-done < <(onevm show -x $VMID| $XPATH \
-                    /VM/HISTORY_RECORDS/HISTORY[last\(\)]/TM_MAD)
-
-TM_MAD="${XPATH_ELEMENTS[j++]}"
-
-#-------------------------------------------------------------------------------
-# Move the image back to the datastore
-#-------------------------------------------------------------------------------
-
-if [ "${TM_MAD}" = 'ssh' ]; then
-    log "Moving $SRC to datastore as $DST"
-
-    ssh_exec_and_log "${SRC_HOST}" \
-        "cp -r ${SRC_PATH} ${DST_PATH}" \
-        "Error copying ${SRC} to ${DST}" >&2
-fi
-
+# Nothing to do
 exit 0
diff --git a/src/vm/VirtualMachineDisk.cc b/src/vm/VirtualMachineDisk.cc
index 1374e298cb7..30b230d5a61 100644
--- a/src/vm/VirtualMachineDisk.cc
+++ b/src/vm/VirtualMachineDisk.cc
@@ -140,7 +140,7 @@ int VirtualMachineDisk::get_image_id(int &id, int uid)
 /* -------------------------------------------------------------------------- */
 /* -------------------------------------------------------------------------- */
 
-string VirtualMachineDisk::get_tm_mad_system()
+string VirtualMachineDisk::get_tm_mad_system() const
 {
     std::string tm_mad_system;
 
diff --git a/src/vmm_mad/exec/one_vmm_exec.rb b/src/vmm_mad/exec/one_vmm_exec.rb
index 2de809b0db2..215d39faa98 100755
--- a/src/vmm_mad/exec/one_vmm_exec.rb
+++ b/src/vmm_mad/exec/one_vmm_exec.rb
@@ -1094,7 +1094,7 @@ def disk_snapshot_create(id, drv_message)
         tm_command = ensure_xpath(xml_data, id, action, 'TM_COMMAND') || return
 
         tm_command_split     = tm_command.split
-        tm_command_split[0] += '_LIVE'
+        tm_command_split[0].sub!('.', '_LIVE.') or tm_command_split[0] += '_LIVE'
 
         action = VmmAction.new(self, id, :disk_snapshot_create, drv_message)
 

From 327377e0a9bedb0df30a104f77a292bdc50317ad Mon Sep 17 00:00:00 2001
From: "Ruben S. Montero" <rsmontero@opennebula.systems>
Date: Wed, 7 Aug 2019 11:25:52 +0200
Subject: [PATCH 2/3] Update TransferManager.cc

---
 src/tm/TransferManager.cc | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/src/tm/TransferManager.cc b/src/tm/TransferManager.cc
index 1c8cc5a91bd..e6ad36f754b 100644
--- a/src/tm/TransferManager.cc
+++ b/src/tm/TransferManager.cc
@@ -799,7 +799,6 @@ void TransferManager::prolog_migr_action(int vid)
             }
         }
 
-		(*disk)->vector_value("TM_MAD");
         string tsys = (*disk)->vector_value("TM_MAD_SYSTEM");
         if (!tsys.empty())
         {
@@ -943,7 +942,6 @@ void TransferManager::prolog_resume_action(int vid)
             }
         }
 
-		(*disk)->vector_value("TM_MAD");
         string tsys = (*disk)->vector_value("TM_MAD_SYSTEM");
         if (!tsys.empty())
         {
@@ -1152,6 +1150,7 @@ void TransferManager::epilog_transfer_command(
         {
             tm_mad_system = "." + tsys;
         }
+	    
         //MVDS(.tm_mad_system) tm_mad hostname:remote_system_dir/disk.0 <fe:SOURCE|SOURCE> vmid dsid
         xfr << "MVDS" << tm_mad_system
             << " " << tm_mad << " "
@@ -2001,7 +2000,8 @@ void TransferManager::saveas_hot_action(int vid)
     }
 
     disk = vm->get_disk(disk_id);
-    if (disk != 0)
+
+    if (disk != nullptr)
     {
         tsys = disk->vector_value("TM_MAD_SYSTEM");
         if (!tsys.empty())
@@ -2096,7 +2096,8 @@ int TransferManager::snapshot_transfer_command(
     }
 
     disk = vm->get_disk(disk_id);
-    if (disk != 0)
+
+    if (disk != nullptr)
     {
         tsys = disk->vector_value("TM_MAD_SYSTEM");
         if (!tsys.empty())

From 7c4195301ac9fe9092fd5e1ecb1263768f139994 Mon Sep 17 00:00:00 2001
From: "Ruben S. Montero" <rsmontero@opennebula.systems>
Date: Wed, 7 Aug 2019 11:32:25 +0200
Subject: [PATCH 3/3] Update one_tm.rb

---
 src/tm_mad/one_tm.rb | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/tm_mad/one_tm.rb b/src/tm_mad/one_tm.rb
index e71d5684207..dec2c62d00e 100755
--- a/src/tm_mad/one_tm.rb
+++ b/src/tm_mad/one_tm.rb
@@ -113,7 +113,7 @@ def do_transfer_action(id, command)
                 path_shortened = File.join(@local_scripts_path, tm, md[1])
                 if !File.exists?(path_shortened)
                     return RESULT[:failure],
-                        "Driver path '#{path}' nor '#{path_shortened}' does not exists"
+                        "Driver path '#{path}' nor '#{path_shortened}' exists"
                 end
                 path = path_shortened
             else