fileCollector Namespace Reference

Functions
def	convert
def	filecheck
def	logme
def	sendmail

Variables
list	COLLECTDIR = sys.argv[2]
	done = False
string	donefile = "%s/%s/%s/%s"
tuple	dqmfile = Tfile.replace('Playback','DQM')
list	DROPBOX = sys.argv[4]
list	EMAIL = sys.argv[1]
int	EMAILINTERVAL = 15
string	f = "%s/%s"
string	finalfile = "%s/V%04d/DQM_V0001_%s_R%09d.root"
string	finalTdir = "%s/%s/%s"
string	finalTfile = "%s/%s/%s/%s"
string	finalTMPfile = "%s/DQM_V0001_%s_R%09d.root.%s"
tuple	fMatch = re.match('^DQM_V[0-9]{4}_(?P<subsys>.*)_R(?P<runnr>[0-9]{9})(|_T[0-9]*)\.root$',f)
tuple	HOSTNAME = socket.gethostname()
int	keeper = 0
tuple	lastEmailSent = datetime.now()
tuple	lFile = open("%s/lock" % TMPDROPBOX ,"a")
tuple	md5Digest = md5(file(Tfile).read())
dictionary	NEW = {}
int	NFOUND = 0
tuple	now = datetime.now()
int	NRUNS = 0
tuple	originFile = open(originTMPFile,"w")
string	originFileName = "%s.origin"
string	originStr = "md5:%s %d %s"
string	originTMPFile = "%s.origin"
int	RETRIES = 3
tuple	runnr = int(fMatch.group("runnr"))
string	runstr = "%09d"
tuple	SBASEDIR = os.path.abspath(__file__)
tuple	seed = HOSTNAME.replace("-","t")
string	SENDMAIL = "/usr/sbin/sendmail"
tuple	subsystem = fMatch.group("subsys")
tuple	TAGRUNEND = long(sorted(NEW.keys(),reverse=True)[1])
list	TAGS = []
	Tfile = dqmfile
list	TFILEDONEDIR = sys.argv[3]
tuple	Tfiles = sorted(files,cmp=lambda x,y: "_T" not in x and x != y and 1 or cmp(x,y))
string	TMPDROPBOX = "%s/.tmpdropbox"
int	version = 1
int	WAITTIME = 10

Function Documentation

def fileCollector.convert	(		infile,
			ofile
	)

Definition at line 45 of file fileCollector.py.

Referenced by helper::CollectionStoreManager< OutputCollection, ClonePolicy >.cloneAndStore(), ConsRegRequestBuilder.ConsRegRequestBuilder(), ConsRegResponseBuilder.ConsRegResponseBuilder(), DQMEventMsgBuilder.DQMEventMsgBuilder(), EventMsgBuilder.EventMsgBuilder(), MsgTools.fillNames(), edm::EdmEventItemGetter< RefType >.get(), Header.Header(), InitHeader.InitHeader(), InitMsgBuilder.InitMsgBuilder(), lhef::JetMatchingMLM.match(), DQMEventMsgBuilder.setCompressionFlag(), InitMsgBuilder.setDataLength(), EventMsgBuilder.setEventLength(), DQMEventMsgBuilder.setEventLength(), CmsShowCommon.setFrom(), DQMEventMsgBuilder.setFUGuid(), DQMEventMsgBuilder.setFUProcessId(), DQMEventMsgBuilder.setMergeCount(), EventMsgBuilder.setOrigDataSize(), and ConsRegResponseBuilder.setStreamSelectionTable().

def convert(infile, ofile):
  cmd = 'root -l -b -q %s/sistrip_reduce_file.C++"' \
        '(\\"%s\\", \\"%s\\")" >& /dev/null' % (SBASEDIR,infile, ofile)
  os.system(cmd)