Commit fa23bd32 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Modified transfer_service.py and job_handler.py. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban.slack@gmail.com>
parent a2bdf240

docker/transfer_service/job_handler.py

+1 −1
Original line number Diff line number Diff line
@@ -19,7 +19,7 @@ class JobHandler(object): 
        elif srvType == 'abort':

            self.amqpServerList.append(AbortJobAMQPServer(self.host, rpcQueue))

        else:

            sys.exit(f"FATAL:: unknown server type {srvType}.")

            sys.exit(f"FATAL: unknown server type {srvType}.")



    def run(self):

        for srv in self.amqpServerList:

docker/transfer_service/transfer_service.py

+9 −9
Original line number Diff line number Diff line 
import time

import os



#from XRootD import client

from XRootD import client

from job_handler import JobHandler
@@ -20,11 +20,11 @@ ts = TransferService() 
ts.run()

print("Transfer service is RUNNING...")



#time.sleep(10)

#print("Starting XRootD transfer test...")

#process = client.CopyProcess()

#process.add_job( 'root://tape_frontend//home/centos/data/aaa/1.txt', '/home/transfer_service' )

#process.prepare()

#process.run()

#time.sleep(3)

#os.system('du -a /home/transfer_service')
 
 No newline at end of file
 
time.sleep(10)

print("Starting XRootD transfer test...")

process = client.CopyProcess()

process.add_job(source = 'root://tape_frontend//home/centos/data/aaa/1.txt', target = '/home/transfer_service', force = True )

process.prepare()

process.run()

time.sleep(3)

os.system('du -a /home/transfer_service')
 
 No newline at end of file