Added tests dir for experiments.

import psycopg2

try:

    conn = psycopg2.connect(user = "postgres",

                            password = "postgres",

                            host = "127.0.0.1",

                            port = "5432",

                            database = "vospace_test")

    cursor = conn.cursor()

    # Print PostgreSQL Connection properties

    print ( conn.get_dsn_parameters(),"\n")

    # Print PostgreSQL version

    cursor.execute("SELECT version();")

    record = cursor.fetchone()

    print("You are connected to - ", record,"\n")

    cursor.execute("CREATE TABLE IF NOT EXISTS vospace_table_test (id serial PRIMARY KEY, checksum varchar, filename varchar);")

    cursor.execute("INSERT INTO vospace_table_test (checksum, filename) VALUES (%s, %s)", ("1d2a66d119d6cec60a9d6ccc9d61d7e3", "Brother.txt",))

    conn.commit()

except (Exception, psycopg2.Error) as error :

    print ("Error while connecting to PostgreSQL", error)

finally:

    #closing database connection.

        if(conn):

            cursor.close()

            conn.close()

            print("PostgreSQL connection is closed")

import redis

import json

data = {"menu":

              {

                   "id": "file",

                   "value": "File",

                   "popup": {

                       "menuitem": [

                           {"value": "New", "onclick": "CreateNewDoc()"},

                           {"value": "Open", "onclick": "OpenDoc()"},

                           {"value": "Close", "onclick": "CloseDoc()"}

                       ]

                   }

              }

       }

r = redis.StrictRedis(host = "192.168.0.26")

r.set("id", json.dumps(data))

reply = r.get("id").decode("utf-8")

r = json.loads(reply)

res = r["menu"]["popup"]["menuitem"]

for i in res:

    print(i["value"])

import redis

r = redis.StrictRedis(host = "172.17.0.3", db = 0)

r.set("foo", "bar")

a = r.get("foo")

print(a.decode("utf-8"))

r.set("fee", "ver")

a = r.get("fee")

print(a.decode("utf-8"))

r.set("faa", "var")

a = r.get("faa")

print(a.decode("utf-8"))

#a = r.get("bau")

#print(a.decode("utf-8"))

from XRootD import client

from XRootD.client.flags import DirListFlags

from XRootD.client.flags import OpenFlags

myclient = client.FileSystem('root://tape_frontend')

status, listing = myclient.dirlist('/home/centos/data/aaa/', DirListFlags.RECURSIVE )

#print(listing.parent)

#print(listing)

for entry in listing:

  print(entry.name)

status, locations = myclient.locate("/home/centos/data", OpenFlags.REFRESH)

print(locations)

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

process = client.CopyProcess()

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

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

p = process.prepare()

r = process.run()

print(p, r)

print("Transfer completed.") 

from XRootD import client

from XRootD.client.flags import DirListFlags

from XRootD.client.flags import StatInfoFlags

from XRootD.client.flags import OpenFlags

from pathlib import Path

myclient = client.FileSystem('root://tape_frontend')

status, listing = myclient.dirlist('/home/centos/data/aaa/', DirListFlags.STAT)

for entry in listing:

    if entry.statinfo.flags == 16:

        src = "root://tape_frontend//home/centos/data/aaa/" + entry.name

        dest = "/home/transfer_service/data/aaa/" + entry.name

        print(src, dest)

#status, listing = myclient.dirlist('/home/centos/data/aaa/', DirListFlags.RECURSIVE, 0)

for entry in listing:

    if entry.statinfo.flags == 16:

        src = "root://tape_frontend//home/centos/data/aaa/" + entry.name

        dest = "/home/transfer_service/" + entry.name

        process = client.CopyProcess()

        process.add_job(source = src, target = dest, mkdir = True)

        p = process.prepare()

        r = process.run()

        print(r, p)

    else:

       # it's a dir...

print("Transfer completed.")