diff --git a/transfer_service/tape_client.py b/transfer_service/tape_client.py index ff8f18e334bc1e3d3831c00479b58a8f38323e17..43977e6b57f7f2c47823531be2141b86057befc6 100644 --- a/transfer_service/tape_client.py +++ b/transfer_service/tape_client.py @@ -71,7 +71,17 @@ class TapeClient(object): self.scp.put(srcPath, destPath) else: sys.exit("FATAL: invalid file/dir.") - self.scp.close() + self.scp.close() + + def migrate(self, fileList): + tmp = str(uuid.uuid1().hex) + "-vos_migrate.tmp" + fp = open(tmp, "a") + for f in fileList: + fp.write(f"{f}\n") + fp.close() + self.copy("./" + tmp, "/tmp/" + tmp) + cmd = "/opt/ibm/ltfsee/bin/eeadm migrate /tmp/" + tmp + " -p pl_generic_rw_01" + stdin, stdout, stderr = self.client.exec_command(cmd) def recall(self, fileList): tmp = str(uuid.uuid1().hex) + "-vos_recall.tmp" @@ -80,7 +90,7 @@ class TapeClient(object): fp.write(f"{f}\n") fp.close() self.copy("./" + tmp, "/tmp/" + tmp) - cmd = "eeadm recall /tmp/" + tmp + cmd = "/opt/ibm/ltfsee/bin/eeadm recall /tmp/" + tmp stdin, stdout, stderr = self.client.exec_command(cmd) def recallChecksumFiles(self, dirName):