Inheritance diagram for edmIntegrityCheck.PublishToFileSystem:

Public Member Functions
def	__init__ (self, parent)

def	get (self, dir)

def	publish (self, report)

def	read (self, lfn, local=False)

Public Attributes
	parent

Detailed Description

Write a report to storage

Definition at line 16 of file edmIntegrityCheck.py.

Constructor & Destructor Documentation

def edmIntegrityCheck.PublishToFileSystem.__init__	(	self,
		parent
	)

Definition at line 19 of file edmIntegrityCheck.py.

     def __init__(self, parent):
         if isinstance(parent, type("")):
             self.parent = parent
         else:
             self.parent = parent.__class__.__name__
     

Member Function Documentation

def edmIntegrityCheck.PublishToFileSystem.get	(	self,
		dir
	)

Finds the lastest file and reads it

Definition at line 63 of file edmIntegrityCheck.py.

References edmIntegrityCheck.PublishToFileSystem.parent, confdb.HLTProcess.parent, EmDQMReco::FourVectorMonitorElements.parent, FWPSetTableManager::PSetData.parent, emtf::Node.parent, options.HLTProcessOptions.parent, BeautifulSoup.PageElement.parent, globcontrol.parent, readConfig.fileINI.read(), SectorProcessorLUT.read(), cond::FileReader.read(), PtLUTReader.read(), FileBlob.read(), PtAssignmentEngine.read(), AlignmentCorrelationsIO.read(), edm::RawInputSource.read(), MillePedeFileReader.read(), AlignmentCorrelationsIORoot.read(), SimBeamSpotObjects.read(), MultiFileBlob.read(), pos::PixelROCMaskBits.read(), pos::PixelROCTrimBits.read(), LMap::impl.read(), AlignmentUserVariablesIO.read(), personalPlayback.Applet.read(), pos::PixelROCDACSettings.read(), AlignmentParametersIO.read(), SurveyPxbImageReader< T >.read(), PythonProcessDesc.read(), bistream_iterator< T >.read(), l1t::LUT.read(), RawFile.read(), MixingInputConfig.read(), FedRawDataInputSource.read(), PedeReader.read(), edmIntegrityCheck.PublishToFileSystem.read(), CSCPairResidualsConstraint.read(), NuclearInteractionSimulator.read(), edmplugin::CacheParser.read(), BuildTrackerMapPlugin.read(), npstat::StorableMultivariateFunctor.read(), MixingModuleConfig.read(), npstat::UniformAxis.read(), LMap.read(), fastsim::NuclearInteraction.read(), edm::StreamerInputSource.read(), MuonResidualsTwoBin.read(), npstat::NUHistoAxis.read(), npstat::StorableHistoNDFunctor< Numeric, Axis, Converter >.read(), edm::FileInPath.read(), npstat::DualAxis.read(), npstat::GridAxis.read(), npstat::HistoAxis.read(), npstat::DualHistoAxis.read(), npstat::StorableInterpolationFunctor< Numeric, Axis, Converter >.read(), MuonResidualsFitter.read(), npstat::LinInterpolatedTableND< Numeric, Axis >.read(), BitArray< N >.read(), DTTFBitArray< N >.read(), Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor.read(), and npstat::HistoND< Numeric, Axis >.read().

Referenced by Options.Options.__getitem__(), betterConfigParser.BetterConfigParser.__updateDict(), betterConfigParser.BetterConfigParser.getCompares(), and betterConfigParser.BetterConfigParser.getResultingSection().

     def get(self, dir):
         """Finds the lastest file and reads it"""
         reg = '^%s_.*\.txt$' % self.parent
         files = castortools.matchingFiles(dir, reg)
         files = sorted([ (os.path.basename(f), f) for f in files])
         if not files:
             return None
         return self.read(files[-1][1])
                 
 

def edmIntegrityCheck.PublishToFileSystem.publish	(	self,
		report
	)

Publish a file

Definition at line 25 of file edmIntegrityCheck.py.

References FrontierConditions_GlobalTag_cff.file, edmIntegrityCheck.PublishToFileSystem.parent, confdb.HLTProcess.parent, EmDQMReco::FourVectorMonitorElements.parent, emtf::Node.parent, FWPSetTableManager::PSetData.parent, options.HLTProcessOptions.parent, BeautifulSoup.PageElement.parent, globcontrol.parent, and edm.print().

     def publish(self, report):
         """Publish a file"""
         for path in report['PathList']:
             _, name = tempfile.mkstemp('.txt', text=True)
             json.dump(report, file(name,'w'), sort_keys=True, indent=4)
             
             fname = '%s_%s.txt' % (self.parent, report['DateCreated'])
             #rename the file locally - TODO: This is a potential problem
             nname = os.path.join(os.path.dirname(name),fname)
             os.rename(name, nname)
             
             castor_path = castortools.lfnToCastor(path)
             new_name = '%s/%s' % (castor_path, fname)
             castortools.xrdcp(nname,path)
             time.sleep(1)
             
             if castortools.fileExists(new_name):
                 
                 #castortools.move(old_name, new_name)
                 #castortools.chmod(new_name, '644')
 
                 print("File published: '%s'" % castortools.castorToLFN(new_name))
                 os.remove(nname)
             else:
                 pathhash = path.replace('/','.')
                 hashed_name = 'PublishToFileSystem-%s-%s' % (pathhash, fname)
                 shutil.move(nname, hashed_name)
                 print("Cannot write to directory '%s' - written to local file '%s' instead." % (castor_path, hashed_name), file=sys.stderr)
                 

def edmIntegrityCheck.PublishToFileSystem.read	(	self,
		lfn,
		local = `False`
	)

Reads a report from storage

Definition at line 54 of file edmIntegrityCheck.py.

References FrontierConditions_GlobalTag_cff.file.

Referenced by edmIntegrityCheck.PublishToFileSystem.get().

     def read(self, lfn, local = False):
         """Reads a report from storage"""
         if local:
             cat = file(lfn).read()
         else:
             cat = castortools.cat(castortools.lfnToCastor(lfn))
         #print "the cat is: ", cat
         return json.loads(cat)
     

Member Data Documentation

edmIntegrityCheck.PublishToFileSystem.parent

Definition at line 21 of file edmIntegrityCheck.py.

Public Member Functions

Public Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation