Commit 9b430741 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Added setup of 'async_trans' and 'sticky' flags. 



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

transfer_service/import_amqp_server.py

+4 −3
Original line number Diff line number Diff line 
import os

import sys

import json



from amqp_server import AMQPServer

from checksum import Checksum

from db_connector import DbConnector
@@ -107,6 +104,8 @@ class ImportAMQPServer(AMQPServer): 
                        cnode.setContentLength(0)

                        if not self.dbConn.nodeExists(cnode):

                            self.dbConn.insertNode(cnode)

                            self.dbConn.setAsyncTrans(vospacePath, True)

                            self.dbConn.setSticky(vospacePath, True)



                for flist in files:

                    for file in flist:
@@ -133,6 +132,8 @@ class ImportAMQPServer(AMQPServer): 
                            

                            if not self.dbConn.nodeExists(dnode):

                                self.dbConn.insertNode(dnode)

                                self.dbConn.setAsyncTrans(vospacePath, True)

                                self.dbConn.setSticky(vospacePath, True)



            self.dbConn.disconnect()

            # add a counter to track the number of nodes (files and dirs) + log file