python.AtlCoolTool.AtlCoolTool Class Reference

Collaboration diagram for python.AtlCoolTool.AtlCoolTool:

Public Member Functions
def	__init__ (self, database)
def	connectString (self)
def	cd (self, node='/')
def	pwd (self)
def	usetag (self, tag="")
def	usechan (self, chan="ALL")
def	pws (self)
def	rmdir (self, node)
def	less (self, node, header=False, more=False)
def	more (self, node, header=False)
def	timeRep (self, value, istime, isend=False)
def	payloadRep (self, payload, istime)
def	defaultFolderInfo (self)
def	folderInfo (self, node, doCount=False)
def	defaultFolderSetInfo (self)
def	folderSetInfo (self, node)
def	ls (self, node='/', header=False, doCount=False)
def	lstags (self, node='/', pattern="")
def	listchans (self, node='/')
def	listinfo (self, node='/')
def	settag (self, argumentString)
def	setchan (self, argumentString)
def	settginfo (self, argumentString)
def	userunlumi (self, argumentString)
def	usetimes (self, argumentString)
def	rmtag (self, argumentString)
def	headtag (self, argumentString)
def	locktag (self, argumentString)
def	tracetags (self, argumentString)
def	clonetag (self, argumentString)
def	setdesc (self, argumentString)
def	__str__ (self)

Public Attributes
	db
	curdir
	curtag
	curchan
	currunlumi
	curtimes
	useoracle

Detailed Description

Definition at line 163 of file AtlCoolTool.py.

Constructor & Destructor Documentation

__init__()

def python.AtlCoolTool.AtlCoolTool.__init__	(		self,
			database
	)

Initialize the object to a given database.

If 'database' is of type string, it must be a RAL compliant connect 
string or an sqlite filename following the requirements described 
in CoolTool.connect.

Otherwise it must be a valid cool.IDatabase object.

Definition at line 165 of file AtlCoolTool.py.

    def __init__( self, database ):
        """
        Initialize the object to a given database.
        
        If 'database' is of type string, it must be a RAL compliant connect 
        string or an sqlite filename following the requirements described 
        in CoolTool.connect.
        
        Otherwise it must be a valid cool.IDatabase object.
        """
        if isinstance(database, str):
            self.db, connectString = connect( database )
        else:
            self.db = database
        self.curdir='/'
        self.curtag=""
        self.curchan=-1
        self.currunlumi=[cool.ValidityKeyMin,cool.ValidityKeyMax]
        self.curtimes=[cool.ValidityKeyMin,cool.ValidityKeyMax]
        self.useoracle=False
 
    

Member Function Documentation

__str__()

def python.AtlCoolTool.AtlCoolTool.__str__

(

self

)

Definition at line 938 of file AtlCoolTool.py.

    def __str__( self ):
        if self.db is not None:
            return "Connected to '%s'" % self.db.databaseId()
        else:
            return "Not connected"

cd()

def python.AtlCoolTool.AtlCoolTool.cd	(		self,
			node = '/'
	)

Definition at line 190 of file AtlCoolTool.py.

    def cd(self,node='/'):
        if node.startswith("/"):
            npath=normpath(node)
        else:
            npath=normpath(self.curdir+"/"+node)
            #Clean out possible double-slash at the beginning 
            if npath.startswith("//"): npath=npath[1:]
        
        if self.db.existsFolder(npath) or self.db.existsFolderSet(npath):
            self.curdir=npath
        else:
            raise Exception('Node %s does not exist' % node)
 
 

clonetag()

def python.AtlCoolTool.AtlCoolTool.clonetag	(		self,
			argumentString
	)

Definition at line 838 of file AtlCoolTool.py.

    def clonetag(self,argumentString):
        args=argumentString.split()
        if len(args)<3:
            raise Exception('Usage: clonetag <folder> <sourcetag> <desttag>')
        node=args[0]
        tag1=args[1]
        tag2=args[2]
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        res=InfoList()
        if self.db.existsFolder(node):
            f=self.db.getFolder(node)
            # do not allow cloning to existing UPDx tags
            if (tag2.find('UPD')>=0 and tag2 in f.listTags()):
                raise Exception('Cannot clone to existing UPDx destination tag %s' % tag2)
            res.append('Cloning tag '+tag1+' for folder '+node+ ' to dest tag '+tag2)
            try:
                f.cloneTagAsUserTag(tag1,tag2)
                res.append('All done')
            except Exception as e:
                res.append('cloneTagAsUserTag failed with error %s' % e)
        elif self.db.existsFolderSet(node) :  #clone tags in folderset mantaining tags hierarchy
            addedtag = []
            res.append('Cloning tag '+tag1+' for folder '+node+ ' to dest tag '+tag2) 
            nodelist=self.db.listAllNodes()
            for inode in nodelist:
                if (inode[:len(node)+1]==node+'/') or (node=='/' and inode[:len(node)]==node):
                    if self.db.existsFolder(inode):
                        finode=inode[:inode.rfind('/')]
                        if finode==('') : finode='/'
                        while finode!=node:
                            inode=finode
                            finode=inode[:inode.rfind('/')]
                            if finode==('') : finode='/'
                        try:
                            subf=self.db.getFolder(inode)
                        except Exception:
                            subf=self.db.getFolderSet(inode)
                        try:
                            rtag=subf.resolveTag(tag1)
                            try:
                                if  rtag not in addedtag :
                                    addedtag.append(rtag)
                                    subf.createTagRelation(tag2,rtag)
                            except Exception as e:
                                print (e)
                                res.append('createTagRelation failed with error %s' %e)
                        except Exception:
                            res.append('Folder %s : no tag selected' % inode)
            res.append('All done')
        else:
            raise Exception("Node '%s' does not exist" % node)
        return res
 
 

connectString()

def python.AtlCoolTool.AtlCoolTool.connectString

(

self

)

Definition at line 187 of file AtlCoolTool.py.

    def connectString( self ):
        return self.db.databaseId()
 

defaultFolderInfo()

def python.AtlCoolTool.AtlCoolTool.defaultFolderInfo

(

self

)

Definition at line 381 of file AtlCoolTool.py.

    def defaultFolderInfo( self ):
        res = Info( '  %(name)-16s  %(description)-16s'
                    '  %(cardinality)-8s  %(size)-12s' )
        res['name'] = 'Name'
        res['description'] = 'Description'
        res['cardinality'] = 'Count'
        res['size'] = 'Size'
        return res
 
 

defaultFolderSetInfo()

def python.AtlCoolTool.AtlCoolTool.defaultFolderSetInfo

(

self

)

Definition at line 407 of file AtlCoolTool.py.

    def defaultFolderSetInfo( self ):
        res = Info( '  %(name)-16s  %(description)-16s' )
        res['name'] = 'Name'
        res['description'] = 'Description'
        return res
 
 

folderInfo()

def python.AtlCoolTool.AtlCoolTool.folderInfo	(		self,
			node,
			doCount = False
	)

Definition at line 391 of file AtlCoolTool.py.

    def folderInfo( self, node, doCount=False ):
        f = self.db.getFolder( node )
        res = self.defaultFolderInfo()
        res['name'] = node
        res['description'] = f.description()
        if (doCount):
            res['cardinality'] = f.countObjects( cool.ValidityKeyMin,
                                                 cool.ValidityKeyMax,
                                                 cool.ChannelSelection.all() )
            res['size'] = res['cardinality'] * byteSize( f.payloadSpecification() )
        else:
            res['cardinality']='-'
            res['size']='-'
        return res
        
 

folderSetInfo()

def python.AtlCoolTool.AtlCoolTool.folderSetInfo	(		self,
			node
	)

Definition at line 414 of file AtlCoolTool.py.

    def folderSetInfo( self, node ):
        f = self.db.getFolderSet( node )
        res = self.defaultFolderSetInfo()
        res['name'] = node
        res['description'] = f.description()
        return res
 
        

headtag()

def python.AtlCoolTool.AtlCoolTool.headtag	(		self,
			argumentString
	)

Definition at line 707 of file AtlCoolTool.py.

    def headtag(self,argumentString):
        args=argumentString.split()
        if len(args)<2:
            raise Exception('Usage: headtag <folder> <tag>')
        node=args[0]
        tag=args[1]
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        res=InfoList()
        f=None
        if self.db.existsFolder(node):
            f=self.db.getFolder(node)
            res.append('Applying tag '+tag+' to HEAD of folder '+node)
            try:
                f.tagCurrentHead(tag,"AtlCoolConsole tag")
            except Exception as e:
                print (e)
                res.append('tagCurrentHead fails')
        else:
            raise Exception("Node '%s' does not exist" % node)
        return res
 

less()

def python.AtlCoolTool.AtlCoolTool.less	(		self,
			node,
			header = False,
			more = False
	)

Definition at line 279 of file AtlCoolTool.py.

    def less( self, node, header = False, more=False ):
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        res = InfoList()
        if self.db.existsFolder( node ):
            f = self.db.getFolder( node )
            fdesc=f.description()
            if (self.curchan==-1):
                chansel=cool.ChannelSelection.all()
            else:
                chansel=cool.ChannelSelection(self.curchan)
                res.append('Using channel: %i' % self.curchan)
            istime=(fdesc.find('<timeStamp>time')!=-1)
            if istime:
                limmin=self.curtimes[0]
                limmax=self.curtimes[1]
            else:
                limmin=self.currunlumi[0]
                limmax=self.currunlumi[1]
            if (limmin!=cool.ValidityKeyMin or limmax!=cool.ValidityKeyMax):
                res.append('Using rawIOV range [%i,%i]' % (limmin,limmax))
            if (self.curtag==''):
                restag=""
            else:
                if self.curtag not in f.listTags():
                    # tag is not defined here, try hierarchical tag
                    try:
                        restag=f.resolveTag(self.curtag)
                        res.append('Using tag selection: %s resolved to %s' % (self.curtag,restag))
                    except Exception:
                        res.append('Tag %s not defined here' % self.curtag)
                        return res
                else:
                    restag=self.curtag
                    res.append('Using tag selection: %s' % self.curtag)
            coolvec=(fdesc.find('CondAttrListVec')>=0 and fdesc.find('coracool')<0)
            if coolvec: print ("Folder has CoolVector payload")
            objs = f.browseObjects( limmin,limmax,chansel,restag )
            while objs.goToNext():
                if (more):
                    obj=objs.currentRef()
                    i=self.timeRep(obj.since(),istime)+" - "+self.timeRep(obj.until(),istime,True)+" ("+str(obj.channelId())+")"
                    if coolvec:
                        j=0
                        pitr=obj.payloadIterator()
                        while pitr.goToNext():
                            pobj=pitr.currentRef()
                            i+='\nVector element %i:' % j
                            i+=self.payloadRep(pobj,istime)
                            j+=1
                    else:
                        i+=self.payloadRep(obj.payload(),istime)
                else:
                    i = Info( '  %(str)s' )
                    i['str'] = str(objs.currentRef())
                res.append( i )
        else:
            raise Exception( "Node '%s' is not a folder" % node )
 
        return res
 

listchans()

def python.AtlCoolTool.AtlCoolTool.listchans	(		self,
			node = '/'
	)

Definition at line 493 of file AtlCoolTool.py.

    def listchans(self,node='/'):
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        res=InfoList()
        f=None
        if self.db.existsFolder(node):
            f=self.db.getFolder(node)
            res.append('Listing channel IDs, names, descriptions for folder'+node)
            chanlist=f.listChannels()
            res.append('Total number of channels defined: %i' % len(chanlist))
            res.append('Seq ChannelNum ChannelName Desc')
            iseq=0
            for ichan in chanlist:
                try:
                    channame=f.channelName(ichan)
                except Exception:
                    channame='<none>'
                try:
                    chandesc=f.channelDescription(ichan)
                except Exception:
                    chandesc='<none>'
                res.append('%i: %i %s %s' % (iseq,ichan,channame,chandesc))
                iseq+=1
        else:
            raise Exception("Node '%s' is not a folder" % node)
        return res
 

listinfo()

def python.AtlCoolTool.AtlCoolTool.listinfo	(		self,
			node = '/'
	)

Definition at line 522 of file AtlCoolTool.py.

    def listinfo(self,node='/'):
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        res=InfoList()
        if self.db.existsFolder(node):
            f=self.db.getFolder(node)
            if (f.versioningMode()==cool.FolderVersioning.MULTI_VERSION):
                vstr='multi'
            else:
                vstr='single'
            res.append('Specification for %s-version folder %s' % (vstr,node))
            fspec=f.payloadSpecification()
            for field in fspec:
                res.append(' %s (%s)' % ( field.name(),field.storageType().name()))
            res.append('Description: %s' % f.description())
        else:
            res.append('Node %s is not a folder' % node)
        return res
 

locktag()

def python.AtlCoolTool.AtlCoolTool.locktag	(		self,
			argumentString
	)

Definition at line 731 of file AtlCoolTool.py.

    def locktag(self,argumentString):
        args=argumentString.split()
        if len(args)<2:
            raise Exception('Usage: locktag <folder> <tag> {action=l|p|u|r}')
        node=args[0]
        tag=args[1]
        action='L'
        if len(args)>2:
            action=args[2].upper()
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        res=InfoList()
        f=None
        if self.db.existsFolder(node):
            f=self.db.getFolder(node)
            if action=='R':
                action='L'
                res.append('Folder %s is a leaf node, ignoring recursion' % node)
        elif self.db.existsFolderSet(node):
            f=self.db.getFolderSet(node)
        else:
            raise Exception("Node '%s' does not exist" % node)
        if tag not in f.listTags():
            raise Exception('Tag %s does not exist in node %s' % (tag,node))
        state=cool.HvsTagLock.LOCKED
        if (action=='U'): state=cool.HvsTagLock.UNLOCKED
        if (action=='P'): state=cool.HvsTagLock.PARTIALLYLOCKED
        if (action=='R'):
            # find all the tags below this one and lock them too
            nmod=0
            nodelist=self.db.listAllNodes()
            for inode in nodelist:
                if (inode[:len(node)]==node):
                    # look only in multiversion folders
                    multi=True
                    if (self.db.existsFolder(inode)):
                        subf=self.db.getFolder(inode)
                        if (subf.versioningMode==cool.FolderVersioning.SINGLE_VERSION): multi=False
                    else:
                        subf=self.db.getFolderSet(inode)
                    if (multi):
                        try:
                            rtag=subf.resolveTag(tag)
                            # skip tags which are UPD1 or UPD2 - leave unlocked
                            if (rtag.find('UPD1')==-1 and rtag.find('UPD2')==-1):
                                curstate=subf.tagLockStatus(rtag)
                                if (curstate!=state):
                                    subf.setTagLockStatus(rtag,state)
                                    nmod+=1
                                    res.append('Set lock for tag %s to %i' % (rtag,subf.tagLockStatus(rtag)))
                                else:
                                    res.append('Tag %s already at state %i' % (rtag,curstate))
                            else:
                                res.append('Skip tag %s due to UPD mode' % rtag)
                        except Exception:
                            pass
            res.append('Changed state of %i tags' % nmod)
        else:
            # non-recursive tag
            f.setTagLockStatus(tag,state)
            res.append('Set lock for tag %s to %i' % (tag,f.tagLockStatus(tag)))
        return res
 
            

ls()

def python.AtlCoolTool.AtlCoolTool.ls	(		self,
			node = '/',
			header = False,
			doCount = False
	)

Definition at line 422 of file AtlCoolTool.py.

    def ls( self, node = '/', header = False, doCount=False ):
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        
        res = InfoList()
        if self.db.existsFolderSet( node ):
            fs = self.db.getFolderSet( node )
            
            if header and fs.listFolderSets():
                res.append( self.defaultFolderSetInfo() )
            for n in fs.listFolderSets():
                res.append( self.folderSetInfo( n ) )
            
            if header and fs.listFolders():
                res.append( self.defaultFolderInfo() )
            for n in fs.listFolders():
                res.append( self.folderInfo( n, doCount ) )
        else:
            raise Exception( "Node '%s' is not a folderset" % node )
        return res
 

lstags()

def python.AtlCoolTool.AtlCoolTool.lstags	(		self,
			node = '/',
			pattern = ""
	)

Definition at line 445 of file AtlCoolTool.py.

    def lstags(self,node='/',pattern=""):
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        res=InfoList()
        f=None
        if self.db.existsFolder(node):
            f=self.db.getFolder(node)
            res.append('Listing tags for folder '+node)
        elif self.db.existsFolderSet(node):
            f=self.db.getFolderSet(node)
            res.append('Listing tags for folderset '+node)
        # Print obsolete tags if pattern is "showObsolete" 
        showObsolete=False
        if pattern=="showObsolete":
            showObsolete=True
            pattern=""
        if pattern!="":
            res.append('Only listing tags containing: "%s"' % pattern)
        if f is not None:
            staglist=[]
            taglist=f.listTags()
            # sort the tags in alphabetical order - convert to a list
            for tag in taglist:
                staglist+=[str(tag)]
            staglist.sort()
            for tag in staglist:
                # check match against pattern if defined
                if pattern!="":
                    if tag.find(pattern)<0: continue
                else:
                    # Filter Obsolete tags
                    if (not showObsolete) and (f.tagDescription(tag).find('OBSOLETE')>-1): continue
                # check the lock status of each tag
                locked=f.tagLockStatus(tag)
                if (locked==cool.HvsTagLock.UNLOCKED):
                    strlock='unlocked'
                elif (locked==cool.HvsTagLock.PARTIALLYLOCKED):
                    strlock='partially locked'
                else:
                    strlock='locked'
                desc=f.tagDescription(tag)
                res.append('%s (%s) [%s]' % (tag,strlock,desc))
        else:
            raise Exception("Node '%s' does not exist" % node)
        return res
 

more()

def python.AtlCoolTool.AtlCoolTool.more	(		self,
			node,
			header = False
	)

Definition at line 342 of file AtlCoolTool.py.

    def more( self, node, header=False ):
        return self.less(node,header,True)
 

payloadRep()

def python.AtlCoolTool.AtlCoolTool.payloadRep	(		self,
			payload,
			istime
	)

Definition at line 360 of file AtlCoolTool.py.

    def payloadRep(self,payload,istime):
        "Pretty-print the payload of an object - helper function for more cmd"
        spec=payload.specification()
        i=""
        for idx in range(spec.size()):
            if (idx>0): i+=","
            typename=spec[idx].storageType().name()
            i+= " ["+spec[idx].name() + " (" + typename + ") : "
            if (typename.startswith("Blob")):
                blob=payload[idx]
                blobdata=blob.read()
                if isinstance(blobdata,bytes):
                    chksum=crc32(blobdata)
                else:
                    chksum=crc32(blobdata.encode())
                i+= "size=%i,chk=%d" % (blob.size(),chksum)
            else:
                i+= str(payload[idx])
            i+="]"
        return i
 

pwd()

def python.AtlCoolTool.AtlCoolTool.pwd

(

self

)

Definition at line 204 of file AtlCoolTool.py.

    def pwd(self):
        res=InfoList()
        res.append('Current directory: %s' % self.curdir)
        return res
 
 

pws()

def python.AtlCoolTool.AtlCoolTool.pws

(

self

)

Definition at line 249 of file AtlCoolTool.py.

    def pws(self):
        res=InfoList()
        res.append('Current tag selection: %s' % self.curtag)
        if (self.curchan==-1):
            res.append('Current channel selection: ALL')
        else:
            res.append('Current channel selection: %i' % self.curchan)
        return res
 

rmdir()

def python.AtlCoolTool.AtlCoolTool.rmdir	(		self,
			node
	)

Definition at line 258 of file AtlCoolTool.py.

    def rmdir(self, node):
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        res=InfoList()
        chk=input('Delete folder(set) '+node+' ? (y/n)')
        if not (chk=='y' or chk=='Y'):
            res.append('Deletion aborted!')
            return res
        if self.db.existsFolder(node) or self.db.existsFolderSet(node):
            try:
                retcode=self.db.dropNode(node)
                res.append('Folder dropped with return code '+str(retcode))
            except Exception as e:
                print (e)
                res.append('Could not drop folder')
        else:
            res.append('Folder '+node+' does not exist')
        return res
 

rmtag()

def python.AtlCoolTool.AtlCoolTool.rmtag	(		self,
			argumentString
	)

Definition at line 667 of file AtlCoolTool.py.

    def rmtag(self,argumentString):
        args=argumentString.split()
        if len(args)<2:
            raise Exception('Usage: rmtag <folder> <parenttag>')
        node=args[0]
        tag1=args[1]
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        res=InfoList()
        f=None
        if self.db.existsFolder(node):
            f=self.db.getFolder(node)
            res.append('Removing association of tag '+tag1+' to folder '+node)
        elif self.db.existsFolderSet(node):
            f=self.db.getFolderSet(node)
            res.append('Removing association of tag '+tag1+' to folderset '+node)
        if f is not None:
            # tag1 can be a leaf tag in the folder, or a parent tag
            taglist=f.listTags()
            if (tag1 in taglist):
                # tag1 is in the folder itself
                try:
                    f.deleteTag(tag1)
                    res.append('Removal of leaf tag '+tag1+' succeeded')
                except Exception as e:
                    print (e)
                    res.append('deleteTag fails')
            else:
                # tag1 is a tag relation to a parent
                try:
                    f.deleteTagRelation(tag1)
                except Exception as e:
                    print (e)
                    res.append('deleteTagRelation fails')
        else:
            raise Exception("Node '%s' does not exist" % node)
        return res
 

setchan()

def python.AtlCoolTool.AtlCoolTool.setchan	(		self,
			argumentString
	)

Definition at line 578 of file AtlCoolTool.py.

    def setchan(self,argumentString):
        args=argumentString.split()
        if len(args)<3:
            raise Exception('Usage: setchan <folder> <chanID> <chanName> {<chanDescr>}')
        node=args[0]
        chanid=int(args[1])
        channame=args[2]
        if (len(args)>3):
            chandesc=args[3]
        else:
            chandesc=""
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        res=InfoList()
        f=None
        if self.db.existsFolder(node):
            f=self.db.getFolder(node)
            if (f.existsChannel(chanid)):
                res.append('Resetting data for existing channel %i %s %s' % (chanid,channame,chandesc))
                f.setChannelName(chanid,channame)
                if (chandesc!=""):
                    f.setChannelDescription(chanid,chandesc)
            else:
                # have to create channel
                res.append('Creating data for channel %i %s %s' % (chanid ,channame,chandesc))
                f.createChannel(chanid,channame,chandesc)
            res.append('Done')
        else:
            res.append('Node %s is not a folder' % node)
        return res
 

setdesc()

def python.AtlCoolTool.AtlCoolTool.setdesc	(		self,
			argumentString
	)

Definition at line 895 of file AtlCoolTool.py.

    def setdesc(self,argumentString):
        args=argumentString.split()
        if len(args)<1:
            raise Exception('Usage: setdesc <folder> {<descrption>}')
        node=args[0]
        if (len(args)>1):
            desc=args[1]
        else:
            desc=""
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        # special strings to expand
        if desc=="ATTRTIME" :
            # code for an inline CondAttrListCollection stored by timestamp
            desc='<timeStamp>time</timeStamp><addrHeader><address_header service_type="71" clid="40774348" /></addrHeader><typeName>AthenaAttributeList</typeName>'
        elif desc=="ATTRRUN" :
            # code for a inline AthenaAttributeList stored by run-event
            desc='<timeStamp>run-event</timeStamp><addrHeader><address_header service_type="71" clid="40774348" /></addrHeader><typeName>AthenaAttributeList</typeName>'
        elif desc=="ATTRCOLLTIME" :
            # code for an inline CondAttrListCollection stored by timestamp
            desc='<timeStamp>time</timeStamp><addrHeader><address_header service_type="71" clid="1238547719" /></addrHeader><typeName>CondAttrListCollection</typeName>'
        elif desc=="ATTRCOLLRUN" :
            # code for an inline CondAttrListCollection stored by run-event
            desc='<timeStamp>run-event</timeStamp><addrHeader><address_header service_type="71" clid="1238547719" /></addrHeader><typeName>CondAttrListCollection</typeName>'
 
        res=InfoList()
        f=None
        if self.db.existsFolder(node):
            f=self.db.getFolder(node)
            res.append('Current folder description: %s' % f.description())
            if (desc!=""):
                res.append('Set folder description to: %s' % desc)
                try:
                    f.setDescription(desc)
                except Exception as e:
                    print (e)
                    res.append('Set folder description failed')
        else:
            raise Exception("Node '%s' does not exist" % node)
        return res
 

settag()

def python.AtlCoolTool.AtlCoolTool.settag	(		self,
			argumentString
	)

Definition at line 543 of file AtlCoolTool.py.

    def settag(self,argumentString):
        args=argumentString.split()
        if len(args)<3:
            raise Exception('Usage: settag <folder> <foldertag> <parenttag>')
        node=args[0]
        tag1=args[1]
        tag2=args[2]
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        res=InfoList()
        f=None
        if self.db.existsFolder(node):
            f=self.db.getFolder(node)
            res.append('Setting tag '+tag1+' for folder '+node+ ' to parent tag '+tag2)
        elif self.db.existsFolderSet(node):
            f=self.db.getFolderSet(node)
            res.append('Setting tag '+tag1+' for folderset '+node+' to parent tag '+tag2)
        if f is not None:
            # check tag exists, confirm action if not
            if tag1 not in f.listTags():
                print ("WARNING: Tag %s does not exist in node %s" % (tag1,node))
                chk=input("Do you want to proceed anyway (y/n)")
                if (chk.upper()!="Y"):
                    raise Exception('ABORTED - Tag %s does not exist' % tag1)
            try:
                f.createTagRelation(tag2,tag1)
            except Exception as e:
                print (e)
                res.append('createTagRelation fails')
        else:
            raise Exception("Node '%s' does not exist" % node)
        return res
 

settginfo()

def python.AtlCoolTool.AtlCoolTool.settginfo	(		self,
			argumentString
	)

Definition at line 611 of file AtlCoolTool.py.

    def settginfo(self,argumentString):
        args=argumentString.split()
        if len(args)<2:
            raise Exception('Usage: settginfo <folder> <tag> <description>')
        node=args[0]
        tag=args[1]
        desc=' '.join(args[2:])
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        res=InfoList()
        f=None
        if self.db.existsFolder(node):
            f=self.db.getFolder(node)
        elif self.db.existsFolderSet(node):
            f=self.db.getFolderSet(node)
        else:
            res.append('Node %s does not exist' % node)
            return res
        res.append('Setting description for tag %s to %s' % (tag,desc))
        f.setTagDescription(tag,desc)
        return res
 

timeRep()

def python.AtlCoolTool.AtlCoolTool.timeRep	(		self,
			value,
			istime,
			isend = False
	)

Definition at line 345 of file AtlCoolTool.py.

    def timeRep(self,value,istime,isend=False):
        "Print COOL Validity Key in run/LB or time notation"
        trail=']'
        if isend: trail=')'
        if istime:
            if (value==cool.ValidityKeyMin):
                return "ValidityKeyMin"
            elif (cool.ValidityKeyMax-value<1000000000):
                return "ValidityKeyMax"
            else:
                stime=int(value/1000000000)
                return time.asctime(time.gmtime(stime))+" UTC"
        else:
            return "[%i,%i%s" % (value >> 32, value & 0xFFFFFFFF,trail)
 

tracetags()

def python.AtlCoolTool.AtlCoolTool.tracetags	(		self,
			argumentString
	)

Definition at line 797 of file AtlCoolTool.py.

    def tracetags(self,argumentString):
        args=argumentString.split()
        if len(args)<2:
            raise Exception('Usage: tracetags <folder> <foldertag>')
        node=args[0]
        tag=args[1]
        if node is None or node == '' or node == '.':
            node=self.curdir
        elif not node.startswith('/'): node=self.curdir+'/'+node
        if (node.startswith('//')): node=node[1:]
        res=InfoList()
        # node must be a folderset, not a folder for this command to make sense
        if self.db.existsFolderSet(node):
            f=self.db.getFolderSet(node)
        else:
            raise Exception("Node '%s' does not exist" % node)
        # check the given tag is actually defined in this folder
        taglist=f.listTags()
        if tag not in taglist:
            raise Exception("Tag '%s' does not exist in node '%s'" % (tag,node))
        # find all folder(sets) under this node
        res.append('Searching under %s for tags referenced by %s' % (node,tag))
        nodelist=self.db.listAllNodes()
        for inode in nodelist:
            inode = str(inode)
            if (inode[:len(node)]==node):
                # look only in multiversion folders
                multi=True
                if (self.db.existsFolder(inode)):
                    subf=self.db.getFolder(inode)
                    if (subf.versioningMode==cool.FolderVersioning.SINGLE_VERSION): multi=False
                else:
                    subf=self.db.getFolderSet(inode)
                if (multi):
                    try:
                        rtag=subf.resolveTag(tag)
                    except Exception:
                        rtag='<nothing>'
                    res.append('Folder %s : tag %s' % (inode,rtag))
        return res
 

usechan()

def python.AtlCoolTool.AtlCoolTool.usechan	(		self,
			chan = "ALL"
	)

Definition at line 236 of file AtlCoolTool.py.

    def usechan(self,chan="ALL"):
        if (chan=="ALL" or chan=="all"):
            ichan=-1
        else:
            ichan=int(chan)
        res=InfoList()
        self.curchan=ichan
        if (ichan!=-1):
            res.append('Changed current channel selection to %i' % self.curchan)
        else:
            res.append('Changed current channel selection to ALL')
        return res
    

userunlumi()

def python.AtlCoolTool.AtlCoolTool.userunlumi	(		self,
			argumentString
	)

Definition at line 635 of file AtlCoolTool.py.

    def userunlumi(self,argumentString):
        args=argumentString.split()
        if len(args)==1:
            run1=int(args[0])
            run2=run1
            lb1=0
            lb2=0xFFFFFFFF
        elif len(args)<4:
            raise Exception('Usage: userunlumi <run1> {<LB1> <run2> <LB2>}')
        else:
            run1=int(args[0])
            lb1=int(args[1])
            run2=int(args[2])
            lb2=int(args[3])
        self.currunlumi[0]=(run1 << 32)+lb1
        self.currunlumi[1]=(run2 << 32)+lb2
 

usetag()

def python.AtlCoolTool.AtlCoolTool.usetag	(		self,
			tag = ""
	)

Definition at line 210 of file AtlCoolTool.py.

    def usetag(self,tag=""):
        res=InfoList()
        try:
            itag=int(tag)
            if self.db.existsFolder(self.curdir):
                f=self.db.getFolder(self.curdir)
            else:
                f=self.db.getFolderSet(self.curdir)
            taglist=f.listTags()
            # sort the tags in alphabetical order - convert to a list
            staglist=[]
            for tag in taglist:
                staglist+=[str(tag)]
            staglist.sort()
            if (itag<len(staglist)):
                self.curtag=staglist[itag]
            else:
                self.curtag=staglist[-1]
        except ValueError:
            if (tag!="HEAD"):
                self.curtag=tag.strip()
            else:
                self.curtag=""
        res.append('Changed current tag selection to %s' % self.curtag)
        return res
 

usetimes()

def python.AtlCoolTool.AtlCoolTool.usetimes	(		self,
			argumentString
	)

Definition at line 652 of file AtlCoolTool.py.

    def usetimes(self,argumentString):
        args=argumentString.split()
        if len(args)<2:
            raise Exception('Usage: usetimes <t1> <t2>')
        for i in range(0,2):
            try:
                self.curtimes[i]=int(args[i])
            except ValueError:
                try:
                    ts=time.strptime(args[i]+'/UTC','%Y-%m-%d:%H:%M:%S/%Z')
                    self.curtimes[i]=int(calendar.timegm(ts))*1000000000
                except ValueError:
                    print ("ERROR in time specification, use e.g. 2007-05-25:14:01:00")
                    
 

Member Data Documentation

curchan

python.AtlCoolTool.AtlCoolTool.curchan

Definition at line 181 of file AtlCoolTool.py.

curdir

python.AtlCoolTool.AtlCoolTool.curdir

Definition at line 179 of file AtlCoolTool.py.

currunlumi

python.AtlCoolTool.AtlCoolTool.currunlumi

Definition at line 182 of file AtlCoolTool.py.

curtag

python.AtlCoolTool.AtlCoolTool.curtag

Definition at line 180 of file AtlCoolTool.py.

curtimes

python.AtlCoolTool.AtlCoolTool.curtimes

Definition at line 183 of file AtlCoolTool.py.

db

python.AtlCoolTool.AtlCoolTool.db

Definition at line 178 of file AtlCoolTool.py.

useoracle

python.AtlCoolTool.AtlCoolTool.useoracle

Definition at line 184 of file AtlCoolTool.py.

---

The documentation for this class was generated from the following file:

• AtlCoolTool.py