AFPDBBase.AFPDBTableBase Class Reference

Inheritance diagram for AFPDBBase.AFPDBTableBase:

Collaboration diagram for AFPDBBase.AFPDBTableBase:

Public Member Functions
def	__init__ (self)
def	serialiseHeader (self)
def	serialiseRecords (self)
def	serialiseTable (self)
def	saveToDB (self)
def	createOrGetFolder (self, db)

Public Attributes
	records
	iovStartRun
	iovStartLumiBlock
	iovEndRun
	iovEndLumiBlock
	tag
	folderName
	spec
	desc
	data
	folderSpec
	folder

Detailed Description

Definition at line 42 of file AFPDBBase.py.

Constructor & Destructor Documentation

__init__()

def AFPDBBase.AFPDBTableBase.__init__

(

self

)

Definition at line 43 of file AFPDBBase.py.

    def __init__ (self):
        self.records = []
        self.iovStartRun = 0
        self.iovStartLumiBlock = 0
        self.iovEndRun = 0
        self.iovEndLumiBlock = 0
 
        self.tag = "AFPTest-00-00-00"
        self.folderName = "/FWD/AFP/TEST"
        self.spec = cool.RecordSpecification()
#        self.spec.extend("data", cool.StorageType.Blob64k)
        self.spec.extend("data", cool.StorageType.String16M)
#        self.desc = '<timeStamp>run-lumi</timeStamp><addrHeader><address_header service_type="71" clid="1238547719" /></addrHeader><typeName>CondAttrListCollection</typeName>'
        self.desc = '<timeStamp>run-lumi</timeStamp><addrHeader><address_header service_type="71" clid="40774348" /></addrHeader><typeName>AthenaAttributeList</typeName>'
        self.data = cool.Record(self.spec)
        self.folderSpec = cool.FolderSpecification(cool.FolderVersioning.MULTI_VERSION, self.spec)
 
 
 

Member Function Documentation

createOrGetFolder()

def AFPDBBase.AFPDBTableBase.createOrGetFolder	(		self,
			db
	)

Definition at line 109 of file AFPDBBase.py.

    def createOrGetFolder (self, db):
        print (self.folderSpec)
        if(db.existsFolder(self.folderName)):
            self.folder=db.getFolder(self.folderName)
        else:
            self.folder=db.createFolder(self.folderName, self.folderSpec, self.desc, True)
 
 

saveToDB()

def AFPDBBase.AFPDBTableBase.saveToDB

(

self

)

Definition at line 100 of file AFPDBBase.py.

    def saveToDB (self):
        self.data['data'] = self.serialiseTable()
        iovStart=(self.iovStartRun<<32) + self.iovStartLumiBlock
        print ("before self.iovEndRun=" + str(self.iovEndRun))
        iovEnd=(self.iovEndRun<<32) + self.iovEndLumiBlock
        print ("after self.iovEndRun=" + str(self.iovEndRun))
        
        self.folder.storeObject(iovStart, iovEnd, self.data, 0, self.tag)
 

serialiseHeader()

def AFPDBBase.AFPDBTableBase.serialiseHeader

(

self

)

Definition at line 62 of file AFPDBBase.py.

    def serialiseHeader (self):
        output = '"node_description": '
#        output += '"<timeStamp>run-lumi</timeStamp><addrHeader><address_header service_type="71" clid="1238547719" /></addrHeader<typeName>CondAttrListCollection</typeName>"'
        output += '"<timeStamp>run-lumi</timeStamp><addrHeader><address_header service_type=\\"71\\" clid=\\"40774348\\" /></addrHeader><typeName>AthenaAttributeList</typeName> "'
        
        return output
 

serialiseRecords()

def AFPDBBase.AFPDBTableBase.serialiseRecords

(

self

)

Definition at line 69 of file AFPDBBase.py.

    def serialiseRecords (self):
        output = '"data_array": ['
        if (len(self.records) > 0):
            channelID = 1
 
            for entry in self.records:
                output += '{'
                output += '"' + str(channelID) + '" : '
                output += entry.serialiseValues()
                output += '}, '
                channelID += 1
 
            # remove the last comma and space ", "
            output = output[:-2] 
            # close bracket
            output += ']'
 
        return output
            

serialiseTable()

def AFPDBBase.AFPDBTableBase.serialiseTable

(

self

)

Definition at line 88 of file AFPDBBase.py.

    def serialiseTable (self):
        if (len(self.records) < 1):
            raise ValueError ("Empty records list. Please, fill records before serialising table.")
 
        output = '{'
        output += self.serialiseHeader() + ', '
        output += self.records[0].serialiseTypes() + ', '
        output += self.serialiseRecords()
        output += '}'
        
        return output
 

Member Data Documentation

data

AFPDBBase.AFPDBTableBase.data

Definition at line 57 of file AFPDBBase.py.

desc

AFPDBBase.AFPDBTableBase.desc

Definition at line 56 of file AFPDBBase.py.

folder

AFPDBBase.AFPDBTableBase.folder

Definition at line 112 of file AFPDBBase.py.

folderName

AFPDBBase.AFPDBTableBase.folderName

Definition at line 51 of file AFPDBBase.py.

folderSpec

AFPDBBase.AFPDBTableBase.folderSpec

Definition at line 58 of file AFPDBBase.py.

iovEndLumiBlock

AFPDBBase.AFPDBTableBase.iovEndLumiBlock

Definition at line 48 of file AFPDBBase.py.

iovEndRun

AFPDBBase.AFPDBTableBase.iovEndRun

Definition at line 47 of file AFPDBBase.py.

iovStartLumiBlock

AFPDBBase.AFPDBTableBase.iovStartLumiBlock

Definition at line 46 of file AFPDBBase.py.

iovStartRun

AFPDBBase.AFPDBTableBase.iovStartRun

Definition at line 45 of file AFPDBBase.py.

records

AFPDBBase.AFPDBTableBase.records

Definition at line 44 of file AFPDBBase.py.

spec

AFPDBBase.AFPDBTableBase.spec

Definition at line 52 of file AFPDBBase.py.

tag

AFPDBBase.AFPDBTableBase.tag

Definition at line 50 of file AFPDBBase.py.

---

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

• AFPDBBase.py