Commit 26ea28ed authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Minor changes. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban@inaf.it>
parent 364106fe

transfer_service/Dockerfile

+6 −2
Original line number Diff line number Diff line
@@ -24,8 +24,8 @@ RUN dnf update -y && dnf -y install epel-release 
# Install nano and openssh

RUN dnf -y install nano openssh-clients



# Install pika, redis and paramiko libraries

RUN dnf -y install python3-pika python3-redis python3-paramiko

# Install pika, redis, psycopg2 and paramiko

RUN dnf -y install python3-pika python3-redis python3-psycopg2 python3-paramiko

    

# Run commands as transfer_service user

#USER transfer_service
@@ -35,6 +35,10 @@ RUN mkdir /home/transfer_service/store && touch /home/transfer_service/store/foo 
    chown -R transfer_service:transfer_service /home/transfer_service/store && \

    chmod -R 755 /home/transfer_service/store



RUN mkdir /home/curban/store && touch /home/curban/store/foo.txt && \

    chown -R curban:curban /home/curban/store && \

    chmod -R 755 /home/curban/store    

    

RUN mkdir /home/ccarbone/store && touch /home/ccarbone/store/foo.txt && \

    chown -R ccarbone:ccarbone /home/ccarbone/store && \

    chmod -R 755 /home/ccarbone/store

transfer_service/store_amqp_server.py

+1 −1
Original line number Diff line number Diff line 
#  TODO:

#  - error codes and status codes list and description

#

#  - check what happens if the user folder does not exist (e.g. /home/ccarbone)

#

#

transfer_service/transfer_service.py

+2 −18
Original line number Diff line number Diff line 
import time

import os



from XRootD import client

from job_handler import JobHandler
@@ -23,20 +22,5 @@ class TransferService(object): 


ts = TransferService()

ts.run()

time.sleep(5)

print("Transfer service is RUNNING...")
 
 No newline at end of file
 


time.sleep(10)

print("Starting XRootD transfer test [remote-to-remote]...")

process = client.CopyProcess()

process.add_job(source = 'root://tape_frontend//home/tape_frontend/data/aaa/1.txt',

                target = 'root://transfer_node//home/transfer_node/data/aaa/1.txt',

                mkdir = True,

                force = True )

process.add_job(source = 'root://tape_frontend//home/tape_frontend/data/aaa/3.txt',

                target = 'root://transfer_node//home/transfer_node/data/aaa/3.txt',

                mkdir = True,

                force = True )

process.prepare()

process.run()

#time.sleep(3)

#os.system('du -a /home/centos')