Functions | |
def | convert |
def | filecheck |
def | isFileOpen |
def | logme |
def | processSiStrip |
def | uploadFile |
Variables | |
list | COLLECTING_DIR = sys.argv[1] |
int | COLLECTOR_WAIT_TIME = 10 |
list | DROPBOX = sys.argv[3] |
tuple | EXEDIR = os.path.dirname(__file__) |
string | f = "%s/%s" |
string | finalTdir = "%s/%s/%s" |
string | finalTfile = "%s/%s" |
tuple | 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 | fMatch = re.match('^(DQM|Playback)_V[0-9]{4}_(?P<subsys>.*)_R(?P<runnr>[0-9]{9})\.root$',f) |
string | fName = "%s/%s" |
int | KEEP = 2 |
tuple | LAST_FILE_UPLOADED = time.time() |
string | LAST_SEEN_RUN = "0" |
dictionary | NEW = {} |
ENDLESS LOOP WITH SLEEP. More... | |
int | RETRIES = 3 |
list | run = NEW[rFile] |
tuple | runnr = fMatch.group("runnr") |
string | STOP_FILE = "%s/.stop" |
tuple | subsystem = fMatch.group("subsys") |
list | T_FILE_DONE_DIR = sys.argv[2] |
tuple | TAGS = sorted(glob('%s/tagfile_runend_*' % COLLECTING_DIR ),reverse=True) |
tuple | TMP_DROPBOX = os.path.join(DROPBOX,".uploading") |
tuple | tmpF = open(tmpFName,"w+") |
string | tmpFName = "%s/%s.root" |
transferred = False | |
int | WAIT_TIME_FILE_PT = 60 |
def fileCollector2.convert | ( | infile, | |
ofile | |||
) |
Definition at line 69 of file fileCollector2.py.
def fileCollector2.filecheck | ( | rootfile | ) |
Definition at line 27 of file fileCollector2.py.
def fileCollector2.isFileOpen | ( | fName | ) |
Definition at line 42 of file fileCollector2.py.
def fileCollector2.logme | ( | msg, | |
args | |||
) |
Definition at line 23 of file fileCollector2.py.
def fileCollector2.processSiStrip | ( | fName, | |
finalTfile | |||
) |
Definition at line 121 of file fileCollector2.py.
def fileCollector2.uploadFile | ( | fName, | |
subsystem, | |||
run | |||
) |
Definition at line 73 of file fileCollector2.py.
list fileCollector2.COLLECTING_DIR = sys.argv[1] |
Definition at line 9 of file fileCollector2.py.
int fileCollector2.COLLECTOR_WAIT_TIME = 10 |
Definition at line 14 of file fileCollector2.py.
list fileCollector2.DROPBOX = sys.argv[3] |
Definition at line 11 of file fileCollector2.py.
tuple fileCollector2.EXEDIR = os.path.dirname(__file__) |
Definition at line 13 of file fileCollector2.py.
string fileCollector2.f = "%s/%s" |
Definition at line 159 of file fileCollector2.py.
string fileCollector2.finalTdir = "%s/%s/%s" |
Definition at line 193 of file fileCollector2.py.
string fileCollector2.finalTfile = "%s/%s" |
Definition at line 200 of file fileCollector2.py.
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)))) |
Definition at line 249 of file fileCollector2.py.
Referenced by FWTEventList.Add(), and FWTEventList.Enter().
tuple fileCollector2.fMatch = re.match('^(DQM|Playback)_V[0-9]{4}_(?P<subsys>.*)_R(?P<runnr>[0-9]{9})\.root$',f) |
Definition at line 155 of file fileCollector2.py.
string fileCollector2.fName = "%s/%s" |
Definition at line 280 of file fileCollector2.py.
int fileCollector2.KEEP = 2 |
Definition at line 17 of file fileCollector2.py.
tuple fileCollector2.LAST_FILE_UPLOADED = time.time() |
Definition at line 138 of file fileCollector2.py.
fileCollector2.LAST_SEEN_RUN = "0" |
Definition at line 137 of file fileCollector2.py.
dictionary fileCollector2.NEW = {} |
ENDLESS LOOP WITH SLEEP.
Definition at line 136 of file fileCollector2.py.
int fileCollector2.RETRIES = 3 |
Definition at line 18 of file fileCollector2.py.
Definition at line 191 of file fileCollector2.py.
tuple fileCollector2.runnr = fMatch.group("runnr") |
Definition at line 157 of file fileCollector2.py.
string fileCollector2.STOP_FILE = "%s/.stop" |
Definition at line 19 of file fileCollector2.py.
tuple fileCollector2.subsystem = fMatch.group("subsys") |
Definition at line 158 of file fileCollector2.py.
list fileCollector2.T_FILE_DONE_DIR = sys.argv[2] |
Definition at line 10 of file fileCollector2.py.
tuple fileCollector2.TAGS = sorted(glob('%s/tagfile_runend_*' % COLLECTING_DIR ),reverse=True) |
Definition at line 149 of file fileCollector2.py.
tuple fileCollector2.TMP_DROPBOX = os.path.join(DROPBOX,".uploading") |
Definition at line 16 of file fileCollector2.py.
tuple fileCollector2.tmpF = open(tmpFName,"w+") |
Definition at line 286 of file fileCollector2.py.
string fileCollector2.tmpFName = "%s/%s.root" |
Definition at line 273 of file fileCollector2.py.
fileCollector2.transferred = False |
Definition at line 190 of file fileCollector2.py.
int fileCollector2.WAIT_TIME_FILE_PT = 60 |
Definition at line 15 of file fileCollector2.py.