CMS 3D CMS Logo

List of all members | Public Member Functions | Public Attributes
pkg.AbstractPkg Class Reference
Inheritance diagram for pkg.AbstractPkg:

Public Member Functions

def __init__ (self, config=None)
 
def generate (self)
 
def get_kwds (self)
 
def parse_etags (self, line)
 
def print_etags (self)
 
def print_tags (self)
 
def tmpl_etags (self)
 
def tmpl_tags (self)
 
def write (self, fname, tmpl_name, kwds)
 

Public Attributes

 author
 
 config
 
 date
 
 debug
 
 not_in_dir
 
 pname
 
 tdir
 
 tmpl
 
 working_dir
 

Detailed Description

AbstractPkg takes care how to generate code from template/PKG
package area. The PKG can be any directory which may include
any types of files, e.g. C++ (.cc), python (.py), etc.
This class relies on specific logic which we outline here:

    - each template may use tags defined with double underscores
      enclosure, e.g. __class__, __record__, etc.
    - each template may have example tags, such tags should
      start with @example_. While processing template user may
      choose to strip them off or keep the code behind those tags
    - in addition user may specify pure python code which can
      operate with user defined tags. This code snipped should
      be enclosed with #python_begin and #python_end lines
      which declares start and end of python block

Definition at line 22 of file pkg.py.

Constructor & Destructor Documentation

def pkg.AbstractPkg.__init__ (   self,
  config = None 
)

Definition at line 39 of file pkg.py.

39  def __init__(self, config=None):
40  super(AbstractPkg, self).__init__()
41  if not config:
42  self.config = {}
43  else:
44  self.config = config
45  self.pname = self.config.get('pname', None)
46  self.tmpl = self.config.get('tmpl', None)
47  self.debug = self.config.get('debug', 0)
48  self.tdir = self.config.get('tmpl_dir')
49  self.author = user_info(self.config.get('author', None))
50  self.date = time.strftime("%a, %d %b %Y %H:%M:%S GMT", time.gmtime())
51  self.not_in_dir = self.config.get('not_in_dir', [])
52  self.working_dir = self.config.get('working_dir')
53 
def __init__(self, config=None)
Definition: pkg.py:39
def user_info(ainput=None)
Definition: utils.py:97

Member Function Documentation

def pkg.AbstractPkg.generate (   self)

Definition at line 160 of file pkg.py.

References DTDigiToRawModule.debug, CSCRPCData.debug, CSCDCCUnpacker.debug, ALIUtils.debug, CSCTMBScope.debug, crabFunctions.CrabController.debug, DTDigiToRaw.debug, EgammaProbeSelector.debug, DTTTrigCorrectionFirst.debug, DTSegmentsTask.debug, pkg.AbstractPkg.debug, DTTPDeadWriter.debug, CSCDCCEventData.debug, DTTTrigWriter.debug, DTT0CalibrationRMS.debug, SiPixelRawToDigi.debug, DTDDUUnpacker.debug, DTT0Calibration.debug, DTOccupancyPoint.debug, util.rrapi.RRApi.debug, DTNoiseComputation.debug, DTROS25Unpacker.debug, DTTTrigSyncT0Only.debug, DTTTrigCalibration.debug, DTEfficiencyTask.debug, CSCDDUEventData.debug, DTRunConditionVar.debug, HCALResponse.debug, DTChamberEfficiencyTask.debug, DTTMax.debug, DTChamberEfficiency.debug, CSCCLCTData.debug, DTVDriftCalibration.debug, PixelDataFormatter.debug, DTTTrigSyncFromDB.debug, CSCTMBData.debug, DTTTrigSyncTOFCorr.debug, BaseParticlePropagator.debug, RPCEfficiency.debug, CSCEventData.debug, CSCTMBHeader.debug, CSCALCTTrailer.debug, CSCALCTHeader.debug, crabFunctions.CrabTask.debug, spr.find(), pkg.AbstractPkg.get_kwds(), join(), pkg.AbstractPkg.not_in_dir, pkg.AbstractPkg.pname, edm.print(), python.rootplot.root2matplotlib.replace(), split, pkg.AbstractPkg.tdir, pkg.AbstractPkg.tmpl, pkg.AbstractPkg.working_dir, edm::ThreadSafeOutputFileStream.write(), Json::Writer.write(), AlignmentCorrelationsIO.write(), edm::RunLumiEntryInfo.write(), pos::PixelConfig.write(), FileBlob.write(), HcalSiPMParametersPopConAnalyzer.write(), HcalTPChannelParametersPopConAnalyzer.write(), AlignmentCorrelationsIORoot.write(), edm::EventEntryInfo.write(), HcalSiPMCharacteristicsPopConAnalyzer.write(), HcalTPParametersPopConAnalyzer.write(), SurveyOutput.write(), edm::AsciiOutputModule.write(), ExTestEcalChannelStatusAnalyzer.write(), HcalFrontEndMapPopConAnalyzer.write(), CastorRecoParamsPopConAnalyzer.write(), HcalLUTCorrsPopConAnalyzer.write(), HcalValidationCorrsPopConAnalyzer.write(), HcalPedestalWidthsPopConAnalyzer.write(), personalPlayback.Applet.write(), HcalDcsValuesPopConAnalyzer.write(), HcalRecoParamsPopConAnalyzer.write(), MultiFileBlob.write(), CastorChannelQualityPopConAnalyzer.write(), CastorElectronicsMapPopConAnalyzer.write(), CastorGainsPopConAnalyzer.write(), CastorGainWidthsPopConAnalyzer.write(), CastorPedestalsPopConAnalyzer.write(), CastorPedestalWidthsPopConAnalyzer.write(), CastorQIEDataPopConAnalyzer.write(), CastorSaturationCorrsPopConAnalyzer.write(), HcalChannelQualityPopConAnalyzer.write(), HcalDcsMapPopConAnalyzer.write(), HcalElectronicsMapPopConAnalyzer.write(), HcalFlagHFDigiTimeParamsPopConAnalyzer.write(), HcalGainsPopConAnalyzer.write(), HcalGainWidthsPopConAnalyzer.write(), HcalL1TriggerObjectsPopConAnalyzer.write(), HcalLongRecoParamsPopConAnalyzer.write(), HcalLutMetadataPopConAnalyzer.write(), HcalMCParamsPopConAnalyzer.write(), HcalPedestalsPopConAnalyzer.write(), HcalPFCorrsPopConAnalyzer.write(), HcalQIEDataPopConAnalyzer.write(), HcalQIETypesPopConAnalyzer.write(), HcalRespCorrsPopConAnalyzer.write(), HcalTimeCorrsPopConAnalyzer.write(), HcalTimingParamsPopConAnalyzer.write(), HcalZSThresholdsPopConAnalyzer.write(), edm::RunAuxiliary.write(), HcalZDCLowGainFractionsPopConAnalyzer.write(), SiPixelConfigWriter.write(), AlignmentParametersIO.write(), edm::EventEntryDescription.write(), Json::FastWriter.write(), AlignmentUserVariablesIO.write(), edm::LuminosityBlockAuxiliary.write(), SiStripConfigWriter.write(), edm::ProductProvenance.write(), edm::GetProductCheckerOutputModule.write(), RawEventOutputModuleForBU< Consumer >.write(), popcon::PopConAnalyzer< S >.write(), edm::ProvenanceCheckerOutputModule.write(), edm::Parentage.write(), popcon::PopCon.write(), edm::ModuleDescription.write(), MuonAlignmentOutputXML.write(), l1t::LUT.write(), electronCompare.flushfile.write(), electronStore.flushfile.write(), edm::StableProvenance.write(), edm::EventAuxiliary.write(), CSCPairResidualsConstraint.write(), XMLDOMBlock.write(), edmplugin::CacheParser.write(), Benchmark.write(), edm::BranchDescription.write(), XMLDocument.write, uploads.output.write(), Json::StyledWriter.write(), edm::Provenance.write(), amc13::Packet.write(), ztee.GZipLog.write(), MuonResidualsTwoBin.write(), presentation.SubsectionBase.write(), DTWorkflow.DTWorkflow.write(), edm::FileInPath.write(), pkg.AbstractPkg.write(), Json::StyledStreamWriter.write(), edm::ProductResolverBase.write(), XMLProcessor.write(), esMonitoring.LineHistoryEnd.write(), DQMRootOutputModule.write(), MuonResidualsFitter.write(), esMonitoring.LineHistoryStart.write(), edm::OutputModule.write(), betterConfigParser.BetterConfigParser.write(), edm::one::OutputModuleBase.write(), edm::global::OutputModuleBase.write(), edm::limited::OutputModuleBase.write(), and querying.connection.write().

160  def generate(self):
161  "Generate package templates in a given directory"
162 
163  # keep current location, since generate will switch directories
164  cdir = os.getcwd()
165 
166  # read from configutation which template files to create
167  tmpl_files = self.config.get('tmpl_files', 'all')
168 
169  # setup keyword arguments which we'll pass to write method
170  kwds = self.get_kwds()
171 
172  # create template package dir and cd into it
173  if tmpl_files == 'all' and self.tmpl not in self.not_in_dir:
174  if os.path.isdir(self.pname):
175  msg = "Can't create package '%s'\n" % self.pname
176  msg += "Directory %s is already exists" % self.pname
177  print(msg)
178  sys.exit(1)
179  os.makedirs(self.pname)
180  os.chdir(self.pname)
181 
182  # read directory driver information and create file list to generate
183  sdir = os.path.join(self.tdir, self.tmpl)
184  sources = [s for s in os.listdir(sdir) \
185  if s != 'Driver.dir' and s.find('~') == -1]
186  driver = os.path.join(sdir, 'Driver.dir')
187  if os.path.isfile(driver):
188  sources = [s.replace('\n', '') for s in open(driver, 'r').readlines()]
189  if 'CVS' in sources:
190  sources.remove('CVS')
191 
192  # special case of Skeleton, which requires to generate only given
193  # file type if self.pname has extension of that type
194  names = set([s.split('.')[0] for s in sources])
195  if names == set(['Skeleton']):
196  if self.pname.find('.') != -1:
197  _, ext = os.path.splitext(self.pname)
198  sources = [s for s in sources if s.rfind(ext) != -1]
199  self.pname = self.pname.replace(ext, '')
200  kwds = self.get_kwds()
201  if not sources:
202  msg = 'Unable to find skeleton for extension "%s"' % ext
203  print(msg)
204  sys.exit(1)
205  bdir = os.environ.get('CMSSW_BASE', '')
206  dirs = os.getcwd().replace(bdir, '').split('/')
207  ldir = os.getcwd().split('/')[-1]
208  idir = ''
209  subsys = kwds['__subsys__']
210  pkgname = kwds['__pkgname__']
211  if sources == ['Skeleton.cc', 'Skeleton.h']:
212  if ldir == 'interface' and os.getcwd().find(bdir) != -1:
213  idir = '%s/%s/interface/' % (subsys, pkgname)
214  # run within some directory of the Sybsystem/Pkg area
215  # and only for mkskel <file>.cc
216  elif sources == ['Skeleton.cc'] and \
217  len(dirs) == 5 and dirs[0] == '' and dirs[1] == 'src':
218  idir = '%s/%s/interface/' % (subsys, pkgname)
219  elif sources == ['Skeleton.h'] and ldir == 'interface' and \
220  len(dirs) == 5 and dirs[0] == '' and dirs[1] == 'src':
221  idir = '%s/%s/interface/' % (subsys, pkgname)
222  kwds.update({'__incdir__': idir})
223 
224  # loop over source files, create dirs as necessary and generate files
225  # names for writing templates
226  gen_files = []
227  for src in sources:
228  if tmpl_files != 'all':
229  fname, ext = os.path.splitext(src)
230  if tmpl_files != ext:
231  continue
232  #also reject if this is the wrong directory
233  if self.working_dir and src.split('/')[-2] != self.working_dir:
234  continue
235  src = src.split('/')[-1]
236  if self.debug:
237  print("Read", src)
238  items = src.split('/')
239  if items[-1] == '/':
240  items = items[:-1]
241  tname = items[-1] # template file name
242  tmpl_name = os.path.join(sdir, items[-1]) # full tmpl file name
243  if os.path.isfile(tmpl_name):
244  ftype = 'file'
245  else:
246  ftype = 'dir'
247  name2gen = src # new file we'll create
248  if items[-1] == 'testBuildFile.xml':
249  name2gen = '/'.join(src.split('/')[:-1])+'/BuildFile.xml'
250  if -1 !=tname.split('.')[0].find(self.tmpl): # need to substitute
251  name2gen = name2gen.replace(self.tmpl, self.pname)
252  name2gen = os.path.join(os.getcwd(), name2gen)
253  if self.debug:
254  print("Create", name2gen)
255  if ftype == 'dir':
256  if not os.path.isdir(name2gen):
257  os.makedirs(name2gen)
258  continue # we're done with dir
259  fdir = os.path.dirname(name2gen)
260  if not os.path.isdir(fdir):
261  os.makedirs(fdir)
262  self.write(name2gen, tmpl_name, kwds)
263  gen_files.append(name2gen.split('/')[-1])
264  if tmpl_files == 'all' and self.tmpl not in self.not_in_dir:
265  msg = 'New package "%s" of %s type is successfully generated' \
266  % (self.pname, self.tmpl)
267  else:
268  msg = 'Generated %s file' % ', '.join(gen_files)
269  if len(gen_files) > 1:
270  msg += 's'
271  print(msg)
272  # return back where we started
273  os.chdir(cdir)
274  if msg.find('New package') != -1:
275  tree(self.pname)
276 
def get_kwds(self)
Definition: pkg.py:143
def replace(string, replacements)
S & print(S &os, JobReport::InputFile const &f)
Definition: JobReport.cc:66
void find(edm::Handle< EcalRecHitCollection > &hits, DetId thisDet, std::vector< EcalRecHitCollection::const_iterator > &hit, bool debug=false)
Definition: FindCaloHit.cc:20
def generate(self)
Definition: pkg.py:160
static std::string join(char **cmd)
Definition: RemoteFile.cc:18
def write(self, fname, tmpl_name, kwds)
Definition: pkg.py:114
Definition: tree.py:1
double split
Definition: MVATrainer.cc:139
def pkg.AbstractPkg.get_kwds (   self)

Definition at line 143 of file pkg.py.

References pkg.AbstractPkg.author, pkg.AbstractPkg.date, DTDigiToRawModule.debug, CSCRPCData.debug, CSCDCCUnpacker.debug, ALIUtils.debug, CSCTMBScope.debug, DTDigiToRaw.debug, crabFunctions.CrabController.debug, EgammaProbeSelector.debug, DTTTrigCorrectionFirst.debug, DTSegmentsTask.debug, pkg.AbstractPkg.debug, DTTPDeadWriter.debug, CSCDCCEventData.debug, DTT0CalibrationRMS.debug, DTTTrigWriter.debug, SiPixelRawToDigi.debug, DTDDUUnpacker.debug, DTT0Calibration.debug, DTOccupancyPoint.debug, util.rrapi.RRApi.debug, DTNoiseComputation.debug, DTROS25Unpacker.debug, DTTTrigSyncT0Only.debug, DTTTrigCalibration.debug, DTEfficiencyTask.debug, CSCDDUEventData.debug, DTRunConditionVar.debug, HCALResponse.debug, DTChamberEfficiencyTask.debug, DTTMax.debug, DTChamberEfficiency.debug, CSCCLCTData.debug, DTVDriftCalibration.debug, PixelDataFormatter.debug, DTTTrigSyncFromDB.debug, CSCTMBData.debug, DTTTrigSyncTOFCorr.debug, BaseParticlePropagator.debug, RPCEfficiency.debug, CSCEventData.debug, CSCTMBHeader.debug, CSCALCTTrailer.debug, CSCALCTHeader.debug, crabFunctions.CrabTask.debug, pkg.AbstractPkg.pname, and edm.print().

Referenced by pkg.AbstractPkg.generate().

143  def get_kwds(self):
144  "Return keyword arguments to be used in methods"
145  kwds = {'__pkgname__': self.config.get('pkgname', 'Package'),
146  '__author__': self.author,
147  '__user__': os.getlogin(),
148  '__date__': self.date,
149  '__class__': self.pname,
150  '__class_lowercase__': self.pname.lower(),
151  '__name__': self.pname,
152  '__subsys__': self.config.get('subsystem', 'Subsystem')}
153  args = self.config.get('args', None)
154  kwds.update(args)
155  if self.debug:
156  print("Template tags:")
157  pprint.pprint(kwds)
158  return kwds
159 
def get_kwds(self)
Definition: pkg.py:143
S & print(S &os, JobReport::InputFile const &f)
Definition: JobReport.cc:66
def pkg.AbstractPkg.parse_etags (   self,
  line 
)
Determine either skip or keep given line based on class tags
meta-strings

Definition at line 97 of file pkg.py.

References pkg.AbstractPkg.tmpl_etags().

Referenced by pkg.AbstractPkg.write().

97  def parse_etags(self, line):
98  """
99  Determine either skip or keep given line based on class tags
100  meta-strings
101  """
102  tmpl_etags = self.tmpl_etags()
103  keep_etags = self.config.get('tmpl_etags', [])
104  for tag in tmpl_etags:
105  for valid_tag in keep_etags:
106  if line.find(valid_tag) != -1:
107  line = line.replace(valid_tag, '')
108  return line
109  if line.find(tag) != -1:
110  line = ''
111  return line
112  return line
113 
def parse_etags(self, line)
Definition: pkg.py:97
def tmpl_etags(self)
Definition: pkg.py:54
def pkg.AbstractPkg.print_etags (   self)

Definition at line 71 of file pkg.py.

References edm.print(), and pkg.AbstractPkg.tmpl_etags().

71  def print_etags(self):
72  "Print out template example tags"
73  for key in self.tmpl_etags():
74  print(key)
75 
def print_etags(self)
Definition: pkg.py:71
S & print(S &os, JobReport::InputFile const &f)
Definition: JobReport.cc:66
def tmpl_etags(self)
Definition: pkg.py:54
def pkg.AbstractPkg.print_tags (   self)

Definition at line 92 of file pkg.py.

References edm.print(), and pkg.AbstractPkg.tmpl_tags().

92  def print_tags(self):
93  "Print out template keys"
94  for key in self.tmpl_tags():
95  print(key)
96 
S & print(S &os, JobReport::InputFile const &f)
Definition: JobReport.cc:66
def print_tags(self)
Definition: pkg.py:92
def tmpl_tags(self)
Definition: pkg.py:76
def pkg.AbstractPkg.tmpl_etags (   self)

Definition at line 54 of file pkg.py.

References pkg.AbstractPkg.tdir, and pkg.AbstractPkg.tmpl.

Referenced by pkg.AbstractPkg.parse_etags(), and pkg.AbstractPkg.print_etags().

54  def tmpl_etags(self):
55  "Scan template files and return example tags"
56  keys = []
57  sdir = '%s/%s' % (self.tdir, self.tmpl)
58  for name in os.listdir(sdir):
59  if name[-1] == '~':
60  continue
61  if name == 'CVS':
62  continue
63  fname = os.path.join(sdir, name)
64  with open(fname, 'r') as stream:
65  for line in stream.readlines():
66  if line.find('@example_') != -1: # possible tag
67  keys += [k for k in line.split() if \
68  k.find('@example_') != -1]
69  return set(keys)
70 
def tmpl_etags(self)
Definition: pkg.py:54
def pkg.AbstractPkg.tmpl_tags (   self)

Definition at line 76 of file pkg.py.

References utils.parse_word(), pkg.AbstractPkg.tdir, and pkg.AbstractPkg.tmpl.

Referenced by pkg.AbstractPkg.print_tags().

76  def tmpl_tags(self):
77  "Scan template files and return template tags"
78  keys = []
79  sdir = '%s/%s' % (self.tdir, self.tmpl)
80  for name in os.listdir(sdir):
81  if name[-1] == '~':
82  continue
83  if name == 'CVS':
84  continue
85  fname = os.path.join(sdir, name)
86  with open(fname, 'r') as stream:
87  for line in stream.readlines():
88  if line.find('__') != -1: # possible key
89  keys += [k for k in parse_word(line)]
90  return set(keys)
91 
def tmpl_tags(self)
Definition: pkg.py:76
def parse_word(word)
Definition: utils.py:22
def pkg.AbstractPkg.write (   self,
  fname,
  tmpl_name,
  kwds 
)

Definition at line 114 of file pkg.py.

References DTDigiToRawModule.debug, CSCRPCData.debug, CSCDCCUnpacker.debug, CSCTMBScope.debug, ALIUtils.debug, DTDigiToRaw.debug, crabFunctions.CrabController.debug, EgammaProbeSelector.debug, DTTTrigCorrectionFirst.debug, DTSegmentsTask.debug, pkg.AbstractPkg.debug, DTTPDeadWriter.debug, CSCDCCEventData.debug, DTTTrigWriter.debug, DTT0CalibrationRMS.debug, SiPixelRawToDigi.debug, DTDDUUnpacker.debug, DTT0Calibration.debug, DTOccupancyPoint.debug, util.rrapi.RRApi.debug, DTNoiseComputation.debug, DTROS25Unpacker.debug, DTTTrigSyncT0Only.debug, DTTTrigCalibration.debug, DTEfficiencyTask.debug, DTRunConditionVar.debug, CSCDDUEventData.debug, HCALResponse.debug, DTChamberEfficiencyTask.debug, DTTMax.debug, DTChamberEfficiency.debug, CSCCLCTData.debug, DTVDriftCalibration.debug, PixelDataFormatter.debug, DTTTrigSyncFromDB.debug, CSCTMBData.debug, DTTTrigSyncTOFCorr.debug, BaseParticlePropagator.debug, RPCEfficiency.debug, CSCEventData.debug, CSCTMBHeader.debug, CSCALCTTrailer.debug, CSCALCTHeader.debug, crabFunctions.CrabTask.debug, utils.functor(), and pkg.AbstractPkg.parse_etags().

Referenced by pkg.AbstractPkg.generate().

114  def write(self, fname, tmpl_name, kwds):
115  "Create new file from given template name and set of arguments"
116  code = ""
117  read_code = False
118  if os.path.exists(fname):
119  return
120  with open(fname, 'w') as stream:
121  for line in open(tmpl_name, 'r').readlines():
122  line = self.parse_etags(line)
123  if not line:
124  continue
125  if line.find('#python_begin') != -1:
126  read_code = True
127  continue
128  if line.find('#python_end') != -1:
129  read_code = False
130  if read_code:
131  code += line
132  if code and not read_code:
133  res = functor(code, kwds, self.debug)
134  stream.write(res)
135  code = ""
136  continue
137  if not read_code:
138  for key, val in kwds.items():
139  if isinstance(val, str):
140  line = line.replace(key, val)
141  stream.write(line)
142 
def parse_etags(self, line)
Definition: pkg.py:97
def write(self, fname, tmpl_name, kwds)
Definition: pkg.py:114
def functor(code, kwds, debug=0)
Definition: utils.py:55

Member Data Documentation

pkg.AbstractPkg.author

Definition at line 49 of file pkg.py.

Referenced by pkg.AbstractPkg.get_kwds().

pkg.AbstractPkg.config

Definition at line 42 of file pkg.py.

pkg.AbstractPkg.date

Definition at line 50 of file pkg.py.

Referenced by pkg.AbstractPkg.get_kwds().

pkg.AbstractPkg.debug
pkg.AbstractPkg.not_in_dir

Definition at line 51 of file pkg.py.

Referenced by pkg.AbstractPkg.generate().

pkg.AbstractPkg.pname

Definition at line 45 of file pkg.py.

Referenced by pkg.AbstractPkg.generate(), and pkg.AbstractPkg.get_kwds().

pkg.AbstractPkg.tdir
pkg.AbstractPkg.tmpl
pkg.AbstractPkg.working_dir

Definition at line 52 of file pkg.py.

Referenced by pkg.AbstractPkg.generate().