fileCollector2.py File Reference

Go to the source code of this file.

Namespaces
	fileCollector2

Functions
def	fileCollector2.convert
def	fileCollector2.filecheck
def	fileCollector2.isFileOpen
def	fileCollector2.logme
def	fileCollector2.processSiStrip
def	fileCollector2.uploadFile

Variables
list	fileCollector2.COLLECTING_DIR = sys.argv[1]
int	fileCollector2.COLLECTOR_WAIT_TIME = 10
list	fileCollector2.DROPBOX = sys.argv[3]
tuple	fileCollector2.EXEDIR = os.path.dirname(__file__)
string	fileCollector2.f = "%s/%s"
string	fileCollector2.finalTdir = "%s/%s/%s"
string	fileCollector2.finalTfile = "%s/%s"
tuple	fileCollector2.fList = sorted(glob("%s/*_%s_R%s*_d" % (finalTdir,subsystem, run)),cmp=lambda x,y: "_T" not in x and 1 or ("_T" in y and ( -1 * cmp(x,y))))
tuple	fileCollector2.fMatch = re.match('^(DQM|Playback)_V[0-9]{4}_(?P<subsys>.*)_R(?P<runnr>[0-9]{9})\.root$',f)
string	fileCollector2.fName = "%s/%s"
int	fileCollector2.KEEP = 2
tuple	fileCollector2.LAST_FILE_UPLOADED = time.time()
string	fileCollector2.LAST_SEEN_RUN = "0"
dictionary	fileCollector2.NEW = {}
	ENDLESS LOOP WITH SLEEP. More...
int	fileCollector2.RETRIES = 3
list	fileCollector2.run = NEW[rFile]
tuple	fileCollector2.runnr = fMatch.group("runnr")
string	fileCollector2.STOP_FILE = "%s/.stop"
tuple	fileCollector2.subsystem = fMatch.group("subsys")
list	fileCollector2.T_FILE_DONE_DIR = sys.argv[2]
tuple	fileCollector2.TAGS = sorted(glob('%s/tagfile_runend_*' % COLLECTING_DIR ),reverse=True)
tuple	fileCollector2.TMP_DROPBOX = os.path.join(DROPBOX,".uploading")
tuple	fileCollector2.tmpF = open(tmpFName,"w+")
string	fileCollector2.tmpFName = "%s/%s.root"
	fileCollector2.transferred = False
int	fileCollector2.WAIT_TIME_FILE_PT = 60