cmsLHEtoEOSManager Namespace Reference

Functions
def	articleExist
def	fileUpload
def	findXrdDir
def	lastArticle

Variables
string	__version__ = "$Revision: 1.13 $"
string	action = 'store_true'
string	default = ''
string	defaultEOSchecksumCommand = 'xrdfs '
string	defaultEOScpCommand = 'xrdcp -np '
string	defaultEOSfeCommand = 'xrdfs '
string	defaultEOSlistCommand = 'xrdfs '
string	defaultEOSLoadPath = 'root://eoscms.cern.ch/'
string	defaultEOSmkdirCommand = 'xrdfs '
string	defaultEOSRootPath = '/eos/cms/store/lhe'
string	dest = 'fileList'
tuple	exeCheckIntegrity = subprocess.Popen(["/bin/sh","-c", theCheckIntegrityCommand])
tuple	exeCheckSum = subprocess.Popen(["/afs/cern.ch/cms/caf/bin/cms_adler32",f], stdout=subprocess.PIPE, universal_newlines=True)
tuple	exeCompression = subprocess.Popen(["/bin/sh","-c",theCompressionCommand])
tuple	exeFullList = subprocess.Popen(["/bin/sh","-c",theCommand])
tuple	exeList = subprocess.Popen(["/bin/sh","-c",theCommand], stdout=subprocess.PIPE, universal_newlines=True)
tuple	exeUpload = subprocess.Popen(["/bin/sh","-c",theCommand])
tuple	f = open(options.files_from)
tuple	getCheckSum = subprocess.Popen(["awk", "{print $1}"], stdin=exeCheckSum.stdout, stdout=subprocess.PIPE, universal_newlines=True)
string	help = 'LHE local file list to be uploaded, separated by ","'
tuple	intCode = exeCheckIntegrity.wait()
tuple	l = l.strip()
string	listPath = defaultEOSRootPath+'/'
int	newArt = 0
tuple	oldArt = lastArticle()
tuple	parser = optparse.OptionParser(usage)
	reallyDoIt = notoptions.dryRun
string	theCheckIntegrityCommand = 'xmllint -noout '
list	theCheckSumList = []
string	theCommand = defaultEOSmkdirCommand+' '
list	theCompressedFilesList = []
string	theCompressionCommand = 'xz '
list	theList = []
	type = int,
string	uploadPath = ''
string	usage = 'cmsLHEtoEOSManager.py <options>'

Function Documentation

def cmsLHEtoEOSManager.articleExist

(

artId

)

Definition at line 31 of file cmsLHEtoEOSManager.py.

References findXrdDir(), and str.

def articleExist(artId):

    itExists = False
    theCommand = defaultEOSlistCommand+' '+defaultEOSRootPath
    dirList = subprocess.Popen(["/bin/sh","-c",theCommand], stdout=subprocess.PIPE, universal_newlines=True)
    for line in dirList.stdout.readlines():
        if findXrdDir(line) == str(artId): 
            itExists = True

    return itExists