CMS 3D CMS Logo

MillePedeAlignmentAlgorithm.cc
Go to the documentation of this file.
1 
12 
17 
19 
24 #include "Alignment/MillePedeAlignmentAlgorithm/src/Mille.h" // 'unpublished' interface located in src
29 
32 
36 
40 
41 // includes to make known that they inherit from Alignable:
45 
50 
56 
60 
62 
63 #include <fstream>
64 #include <sstream>
65 #include <algorithm>
66 #include <sys/stat.h>
67 
68 #include <TMath.h>
72 
73 // Includes for PXB survey
80 
82 
83 using namespace gbl;
84 
85 // Constructor ----------------------------------------------------------------
86 //____________________________________________________
89  topoToken_(iC.esConsumes<TrackerTopology, TrackerTopologyRcd, edm::Transition::BeginRun>()),
90  aliThrToken_(iC.esConsumes<AlignPCLThresholdsHG, AlignPCLThresholdsHGRcd, edm::Transition::BeginRun>()),
91  geomToken_(iC.esConsumes<TrackerGeometry, TrackerDigiGeometryRecord, edm::Transition::BeginRun>()),
92  theConfig(cfg),
93  theMode(this->decodeMode(theConfig.getUntrackedParameter<std::string>("mode"))),
94  theDir(theConfig.getUntrackedParameter<std::string>("fileDir")),
95  theAlignmentParameterStore(nullptr),
96  theAlignables(),
97  theTrajectoryFactory(
98  TrajectoryFactoryPlugin::get()->create(theConfig.getParameter<edm::ParameterSet>("TrajectoryFactory")
99  .getParameter<std::string>("TrajectoryFactoryName"),
100  theConfig.getParameter<edm::ParameterSet>("TrajectoryFactory"),
101  iC)),
102  theMinNumHits(cfg.getParameter<unsigned int>("minNumHits")),
103  theMaximalCor2D(cfg.getParameter<double>("max2Dcorrelation")),
104  firstIOV_(cfg.getUntrackedParameter<AlignmentAlgorithmBase::RunNumber>("firstIOV")),
105  ignoreFirstIOVCheck_(cfg.getUntrackedParameter<bool>("ignoreFirstIOVCheck")),
106  enableAlignableUpdates_(cfg.getUntrackedParameter<bool>("enableAlignableUpdates")),
107  theLastWrittenIov(0),
108  theGblDoubleBinary(cfg.getParameter<bool>("doubleBinary")),
109  runAtPCL_(cfg.getParameter<bool>("runAtPCL")),
110  ignoreHitsWithoutGlobalDerivatives_(cfg.getParameter<bool>("ignoreHitsWithoutGlobalDerivatives")),
111  skipGlobalPositionRcdCheck_(cfg.getParameter<bool>("skipGlobalPositionRcdCheck")),
112  uniqueRunRanges_(align::makeUniqueRunRanges(cfg.getUntrackedParameter<edm::VParameterSet>("RunRangeSelection"),
113  cond::timeTypeSpecs[cond::runnumber].beginValue)),
114  enforceSingleIOVInput_(!(enableAlignableUpdates_ && areIOVsSpecified())),
115  lastProcessedRun_(cond::timeTypeSpecs[cond::runnumber].beginValue) {
116  if (!theDir.empty() && theDir.find_last_of('/') != theDir.size() - 1)
117  theDir += '/'; // may need '/'
118  edm::LogInfo("Alignment") << "@SUB=MillePedeAlignmentAlgorithm"
119  << "Start in mode '" << theConfig.getUntrackedParameter<std::string>("mode")
120  << "' with output directory '" << theDir << "'.";
121  if (this->isMode(myMilleBit)) {
122  theMille = std::make_unique<Mille>(
123  (theDir + theConfig.getParameter<std::string>("binaryFile")).c_str()); // add ', false);' for text output);
124  // use same file for GBL
125  theBinary = std::make_unique<MilleBinary>((theDir + theConfig.getParameter<std::string>("binaryFile")).c_str(),
127  }
128 }
129 
130 // Destructor ----------------------------------------------------------------
131 //____________________________________________________
133 
134 // Call at beginning of job ---------------------------------------------------
135 //____________________________________________________
139  AlignableExtras *extras,
140  AlignmentParameterStore *store) {
141  if (muon) {
142  edm::LogWarning("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::initialize"
143  << "Running with AlignabeMuon not yet tested.";
144  }
145 
149  const auto &iov_alignments = setup.get<TrackerAlignmentRcd>().validityInterval();
150  const auto &iov_surfaces = setup.get<TrackerSurfaceDeformationRcd>().validityInterval();
151  const auto &iov_errors = setup.get<TrackerAlignmentErrorExtendedRcd>().validityInterval();
152 
153  std::ostringstream message;
154  bool throwException{false};
155  if (iov_alignments.first().eventID().run() != MIN_VAL || iov_alignments.last().eventID().run() != MAX_VAL) {
156  message << "\nTrying to apply " << setup.get<TrackerAlignmentRcd>().key().name()
157  << " with multiple IOVs in tag without specifying 'RunRangeSelection'.\n"
158  << "Validity range is " << iov_alignments.first().eventID().run() << " - "
159  << iov_alignments.last().eventID().run() << "\n";
160  throwException = true;
161  }
162  if (iov_surfaces.first().eventID().run() != MIN_VAL || iov_surfaces.last().eventID().run() != MAX_VAL) {
163  message << "\nTrying to apply " << setup.get<TrackerSurfaceDeformationRcd>().key().name()
164  << " with multiple IOVs in tag without specifying 'RunRangeSelection'.\n"
165  << "Validity range is " << iov_surfaces.first().eventID().run() << " - "
166  << iov_surfaces.last().eventID().run() << "\n";
167  throwException = true;
168  }
169  if (iov_errors.first().eventID().run() != MIN_VAL || iov_errors.last().eventID().run() != MAX_VAL) {
170  message << "\nTrying to apply " << setup.get<TrackerAlignmentErrorExtendedRcd>().key().name()
171  << " with multiple IOVs in tag without specifying 'RunRangeSelection'.\n"
172  << "Validity range is " << iov_errors.first().eventID().run() << " - "
173  << iov_errors.last().eventID().run() << "\n";
174  throwException = true;
175  }
176  if (throwException) {
177  throw cms::Exception("DatabaseError") << "@SUB=MillePedeAlignmentAlgorithm::initialize" << message.str();
178  }
179  }
180 
181  //Retrieve tracker topology from geometry
182  const TrackerTopology *const tTopo = &setup.getData(topoToken_);
183 
184  //Retrieve the thresolds cuts from DB for the PCL
185  if (runAtPCL_) {
186  const auto &th = &setup.getData(aliThrToken_);
187  theThresholds = std::make_shared<AlignPCLThresholdsHG>();
188  storeThresholds(th->getNrecords(), th->getThreshold_Map(), th->getFloatMap());
189 
190  //Retrieve tracker geometry
191  const TrackerGeometry *tGeom = &setup.getData(geomToken_);
192  //Retrieve PixelTopologyMap
193  pixelTopologyMap = std::make_shared<PixelTopologyMap>(tGeom, tTopo);
194  }
195 
196  theAlignableNavigator = std::make_unique<AlignableNavigator>(extras, tracker, muon);
199 
200  edm::ParameterSet pedeLabelerCfg(theConfig.getParameter<edm::ParameterSet>("pedeLabeler"));
201  edm::VParameterSet RunRangeSelectionVPSet(theConfig.getUntrackedParameter<edm::VParameterSet>("RunRangeSelection"));
202  pedeLabelerCfg.addUntrackedParameter<edm::VParameterSet>("RunRangeSelection", RunRangeSelectionVPSet);
203 
204  std::string labelerPlugin = "PedeLabeler";
205  if (!RunRangeSelectionVPSet.empty()) {
206  labelerPlugin = "RunRangeDependentPedeLabeler";
207  if (pedeLabelerCfg.exists("plugin")) {
208  std::string labelerPluginCfg = pedeLabelerCfg.getParameter<std::string>("plugin");
209  if ((labelerPluginCfg != "PedeLabeler" && labelerPluginCfg != "RunRangeDependentPedeLabeler") ||
210  !pedeLabelerCfg.getUntrackedParameter<edm::VParameterSet>("parameterInstances").empty()) {
211  throw cms::Exception("BadConfig") << "MillePedeAlignmentAlgorithm::initialize"
212  << "both RunRangeSelection and generic labeler specified in config file. "
213  << "Please get rid of either one of them.\n";
214  }
215  }
216  } else {
217  if (pedeLabelerCfg.exists("plugin")) {
218  labelerPlugin = pedeLabelerCfg.getParameter<std::string>("plugin");
219  }
220  }
221 
222  if (!pedeLabelerCfg.exists("plugin")) {
223  pedeLabelerCfg.addUntrackedParameter<std::string>("plugin", labelerPlugin);
224  }
225 
226  edm::LogInfo("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::initialize"
227  << "Using plugin '" << labelerPlugin << "' to generate labels.";
228 
229  thePedeLabels = std::shared_ptr<PedeLabelerBase>(PedeLabelerPluginFactory::get()->create(
230  labelerPlugin, PedeLabelerBase::TopLevelAlignables(tracker, muon, extras), pedeLabelerCfg));
231 
232  // 1) Create PedeSteerer: correct alignable positions for coordinate system selection
233  edm::ParameterSet pedeSteerCfg(theConfig.getParameter<edm::ParameterSet>("pedeSteerer"));
234  thePedeSteer = std::make_unique<PedeSteerer>(tracker,
235  muon,
236  extras,
238  thePedeLabels.get(),
239  pedeSteerCfg,
240  theDir,
241  !this->isMode(myPedeSteerBit));
242 
243  // 2) If requested, directly read in and apply result of previous pede run,
244  // assuming that correction from 1) was also applied to create the result:
245  const std::vector<edm::ParameterSet> mprespset(
246  theConfig.getParameter<std::vector<edm::ParameterSet> >("pedeReaderInputs"));
247  if (!mprespset.empty()) {
248  edm::LogInfo("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::initialize"
249  << "Apply " << mprespset.end() - mprespset.begin()
250  << " previous MillePede constants from 'pedeReaderInputs'.";
251  }
252 
253  // FIXME: add selection of run range via 'pedeReaderInputs'
254  // Note: Results for parameters of IntegratedCalibration's cannot be treated...
256  for (std::vector<edm::ParameterSet>::const_iterator iSet = mprespset.begin(), iE = mprespset.end(); iSet != iE;
257  ++iSet) {
258  // This read will ignore calibrations as long as they are not yet passed to Millepede
259  // during/before initialize(..) - currently addCalibrations(..) is called later in AlignmentProducer
260  if (!this->readFromPede((*iSet), false, runrange)) { // false: do not erase SelectionUserVariables
261  throw cms::Exception("BadConfig")
262  << "MillePedeAlignmentAlgorithm::initialize: Problems reading input constants of "
263  << "pedeReaderInputs entry " << iSet - mprespset.begin() << '.';
264  }
266  // Needed to shut up later warning from checkAliParams:
268  }
269 
270  // 3) Now create steerings with 'final' start position:
271  thePedeSteer->buildSubSteer(tracker, muon, extras);
272 
273  // After (!) 1-3 of PedeSteerer which uses the SelectionUserVariables attached to the parameters:
274  this->buildUserVariables(theAlignables); // for hit statistics and/or pede result
275 
276  if (this->isMode(myMilleBit)) {
277  if (!theConfig.getParameter<std::vector<std::string> >("mergeBinaryFiles").empty() ||
278  !theConfig.getParameter<std::vector<std::string> >("mergeTreeFiles").empty()) {
279  throw cms::Exception("BadConfig") << "'vstring mergeTreeFiles' and 'vstring mergeBinaryFiles' must be empty for "
280  << "modes running mille.";
281  }
282  const std::string moniFile(theConfig.getUntrackedParameter<std::string>("monitorFile"));
283  if (!moniFile.empty())
284  theMonitor = std::make_unique<MillePedeMonitor>(tTopo, (theDir + moniFile).c_str());
285 
286  // Get trajectory factory. In case nothing found, FrameWork will throw...
287  }
288 
289  if (this->isMode(myPedeSteerBit)) {
290  // Get config for survey and set flag accordingly
291  const edm::ParameterSet pxbSurveyCfg(theConfig.getParameter<edm::ParameterSet>("surveyPixelBarrel"));
292  theDoSurveyPixelBarrel = pxbSurveyCfg.getParameter<bool>("doSurvey");
294  this->addPxbSurvey(pxbSurveyCfg);
295  }
296 }
297 
298 //____________________________________________________
300 
301 //____________________________________________________
302 bool MillePedeAlignmentAlgorithm::addCalibrations(const std::vector<IntegratedCalibrationBase *> &iCals) {
303  theCalibrations.insert(theCalibrations.end(), iCals.begin(), iCals.end());
304  thePedeLabels->addCalibrations(iCals);
305  return true;
306 }
307 
308 //____________________________________________________
310  const AlignPCLThresholdsHG::threshold_map &thresholdMap,
311  const AlignPCLThresholdsHG::param_map &floatMap) {
312  theThresholds->setAlignPCLThresholds(nRecords, thresholdMap);
313  theThresholds->setFloatMap(floatMap);
314  return true;
315 }
316 
317 //_____________________________________________________________________________
319  if (isMode(myMilleBit)) {
320  return true;
321  } else {
322  return false;
323  }
324 }
325 
326 //_____________________________________________________________________________
328  if (isMode(myPedeReadBit)) {
329  if (runAtPCL_) {
330  MillePedeFileReader mpReader(theConfig.getParameter<edm::ParameterSet>("MillePedeFileReader"),
334  mpReader.read();
335  return mpReader.storeAlignments();
336  } else {
337  return true;
338  }
339  } else {
340  return false;
341  }
342 }
343 
344 //____________________________________________________
346  if (this->isMode(myPedeReadBit)) {
347  if (not theAlignmentParameterStore) {
348  return false;
349  }
350  // restore initial positions, rotations and deformations
353  } else {
355  }
356 
357  // Needed to shut up later warning from checkAliParams:
359  // To avoid that they keep values from previous IOV if no new one in pede result
361 
362  if (!this->readFromPede(theConfig.getParameter<edm::ParameterSet>("pedeReader"), true, runrange)) {
363  edm::LogError("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::setParametersForRunRange"
364  << "Problems reading pede result, but applying!";
365  }
367 
368  this->doIO(++theLastWrittenIov); // pre-increment!
369  }
370 
371  return true;
372 }
373 
374 // Call at end of job ---------------------------------------------------------
375 //____________________________________________________
378  theMille.reset(); // delete to close binary before running pede below (flush would be enough...)
379  theBinary.reset();
380 
381  std::vector<std::string> files;
382  if (this->isMode(myMilleBit) || !theConfig.getParameter<std::string>("binaryFile").empty()) {
383  files.push_back(theDir + theConfig.getParameter<std::string>("binaryFile"));
384  } else {
385  const std::vector<std::string> plainFiles(theConfig.getParameter<std::vector<std::string> >("mergeBinaryFiles"));
386  files = getExistingFormattedFiles(plainFiles, theDir);
387  // Do some logging:
388  std::string filesForLogOutput;
389  for (const auto &file : files)
390  filesForLogOutput += " " + file + ",";
391  if (filesForLogOutput.length() != 0)
392  filesForLogOutput.pop_back();
393  edm::LogInfo("Alignment") << "Based on the config parameter mergeBinaryFiles, using the following "
394  << "files as input (assigned weights are indicated by ' -- <weight>'):"
395  << filesForLogOutput;
396  }
397 
399  return;
400 
401  // cache all positions, rotations and deformations
404  if (lastProcessedRun_ < uniqueRunRanges_.back().first) {
405  throw cms::Exception("BadConfig") << "@SUB=MillePedeAlignmentAlgorithm::terminate\n"
406  << "Last IOV of 'RunRangeSelection' has not been processed. "
407  << "Please reconfigure your source to process the runs at least up to "
408  << uniqueRunRanges_.back().first << ".";
409  }
410  auto lastCachedRun = uniqueRunRanges_.front().first;
411  for (const auto &runRange : uniqueRunRanges_) {
412  const auto run = runRange.first;
413  if (std::find(cachedRuns_.begin(), cachedRuns_.end(), run) == cachedRuns_.end()) {
416  } else {
417  lastCachedRun = run;
418  }
419  }
421  }
422 
423  const std::string masterSteer(thePedeSteer->buildMasterSteer(files)); // do only if myPedeSteerBit?
424  if (this->isMode(myPedeRunBit)) {
425  thePedeSteer->runPede(masterSteer);
426  }
427 
428  // parameters from pede are not yet applied,
429  // so we can still write start positions (but with hit statistics in case of mille):
430  this->doIO(0);
431  theLastWrittenIov = 0;
432 }
433 
435  const std::vector<std::string> &plainFiles, const std::string &theDir) {
436  std::vector<std::string> files;
437  for (const auto &plainFile : plainFiles) {
438  const std::string &theInputFileName = plainFile;
439  int theNumber = 0;
440  while (true) {
441  // Create a formatted version of the filename, with growing numbers
442  // If the parameter doesn't contain a formatting directive, it just stays unchanged
443  char theNumberedInputFileName[200];
444  sprintf(theNumberedInputFileName, theInputFileName.c_str(), theNumber);
445  std::string theCompleteInputFileName = theDir + theNumberedInputFileName;
446  const auto endOfStrippedFileName = theCompleteInputFileName.rfind(" --");
447  const auto strippedInputFileName = theCompleteInputFileName.substr(0, endOfStrippedFileName);
448  // Check if the file exists
449  struct stat buffer;
450  if (stat(strippedInputFileName.c_str(), &buffer) == 0) {
451  // If the file exists, add it to the list
452  files.push_back(theCompleteInputFileName);
453  if (theNumberedInputFileName == theInputFileName) {
454  // If the filename didn't contain a formatting directive, no reason to look any further, break out of the loop
455  break;
456  } else {
457  // Otherwise look for the next number
458  theNumber++;
459  }
460  } else {
461  // The file doesn't exist, break out of the loop
462  break;
463  }
464  }
465  // warning if unformatted (-> theNumber stays at 0) does not exist
466  if (theNumber == 0 && (files.empty() || files.back() != plainFile)) {
467  edm::LogWarning("Alignment") << "The input file '" << plainFile << "' does not exist.";
468  }
469  }
470  return files;
471 }
472 
473 // Run the algorithm on trajectories and tracks -------------------------------
474 //____________________________________________________
476  if (!this->isMode(myMilleBit))
477  return; // no theMille created...
478  const auto &tracks = eventInfo.trajTrackPairs();
479 
480  if (theMonitor) { // monitor input tracks
481  for (const auto &iTrajTrack : tracks) {
482  theMonitor->fillTrack(iTrajTrack.second);
483  }
484  }
485 
486  const RefTrajColl trajectories(theTrajectoryFactory->trajectories(setup, tracks, eventInfo.beamSpot()));
487 
488  // Now loop over ReferenceTrajectoryCollection
489  unsigned int refTrajCount = 0; // counter for track monitoring
490  const auto tracksPerTraj = theTrajectoryFactory->tracksPerTrajectory();
491  for (auto iRefTraj = trajectories.cbegin(), iRefTrajE = trajectories.cend(); iRefTraj != iRefTrajE;
492  ++iRefTraj, ++refTrajCount) {
493  const RefTrajColl::value_type &refTrajPtr = *iRefTraj;
494  if (theMonitor)
495  theMonitor->fillRefTrajectory(refTrajPtr);
496 
497  const auto nHitXy = this->addReferenceTrajectory(setup, eventInfo, refTrajPtr);
498 
499  if (theMonitor && (nHitXy.first || nHitXy.second)) {
500  // if trajectory used (i.e. some hits), fill monitoring
501  const auto offset = tracksPerTraj * refTrajCount;
502  for (unsigned int iTrack = 0; iTrack < tracksPerTraj; ++iTrack) {
503  theMonitor->fillUsedTrack(tracks[offset + iTrack].second, nHitXy.first, nHitXy.second);
504  }
505  }
506 
507  } // end of reference trajectory and track loop
508 }
509 
510 //____________________________________________________
511 std::pair<unsigned int, unsigned int> MillePedeAlignmentAlgorithm::addReferenceTrajectory(
512  const edm::EventSetup &setup, const EventInfo &eventInfo, const RefTrajColl::value_type &refTrajPtr) {
513  std::pair<unsigned int, unsigned int> hitResultXy(0, 0);
514  if (refTrajPtr->isValid()) {
515  // GblTrajectory?
516  if (!refTrajPtr->gblInput().empty()) {
517  // by construction: number of GblPoints == number of recHits or == zero !!!
518  unsigned int iHit = 0;
519  unsigned int numPointsWithMeas = 0;
520  std::vector<GblPoint>::iterator itPoint;
521  auto theGblInput = refTrajPtr->gblInput();
522  for (unsigned int iTraj = 0; iTraj < refTrajPtr->gblInput().size(); ++iTraj) {
523  for (itPoint = refTrajPtr->gblInput()[iTraj].first.begin(); itPoint < refTrajPtr->gblInput()[iTraj].first.end();
524  ++itPoint) {
525  if (this->addGlobalData(setup, eventInfo, refTrajPtr, iHit++, *itPoint) < 0)
526  return hitResultXy;
527  if (itPoint->numMeasurements() >= 1)
528  ++numPointsWithMeas;
529  }
530  }
531  hitResultXy.first = numPointsWithMeas;
532  // check #hits criterion
533  if (hitResultXy.first == 0 || hitResultXy.first < theMinNumHits)
534  return hitResultXy;
535  // construct GBL trajectory
536  if (refTrajPtr->gblInput().size() == 1) {
537  // from single track
538  GblTrajectory aGblTrajectory(refTrajPtr->gblInput()[0].first, refTrajPtr->nominalField() != 0);
539  // GBL fit trajectory
540  /*double Chi2;
541  int Ndf;
542  double lostWeight;
543  aGblTrajectory.fit(Chi2, Ndf, lostWeight);
544  std::cout << " GblFit: " << Chi2 << ", " << Ndf << ", " << lostWeight << std::endl; */
545  // write to MP binary file
546  if (aGblTrajectory.isValid() && aGblTrajectory.getNumPoints() >= theMinNumHits)
547  aGblTrajectory.milleOut(*theBinary);
548  }
549  if (refTrajPtr->gblInput().size() == 2) {
550  // from TwoBodyDecay
551  GblTrajectory aGblTrajectory(refTrajPtr->gblInput(),
552  refTrajPtr->gblExtDerivatives(),
553  refTrajPtr->gblExtMeasurements(),
554  refTrajPtr->gblExtPrecisions());
555  // write to MP binary file
556  if (aGblTrajectory.isValid() && aGblTrajectory.getNumPoints() >= theMinNumHits)
557  aGblTrajectory.milleOut(*theBinary);
558  }
559  } else {
560  // to add hits if all fine:
561  std::vector<AlignmentParameters *> parVec(refTrajPtr->recHits().size());
562  // collect hit statistics, assuming that there are no y-only hits
563  std::vector<bool> validHitVecY(refTrajPtr->recHits().size(), false);
564  // Use recHits from ReferenceTrajectory (since they have the right order!):
565  for (unsigned int iHit = 0; iHit < refTrajPtr->recHits().size(); ++iHit) {
566  const int flagXY = this->addMeasurementData(setup, eventInfo, refTrajPtr, iHit, parVec[iHit]);
567 
568  if (flagXY < 0) { // problem
569  hitResultXy.first = 0;
570  break;
571  } else { // hit is fine, increase x/y statistics
572  if (flagXY >= 1)
573  ++hitResultXy.first;
574  validHitVecY[iHit] = (flagXY >= 2);
575  }
576  } // end loop on hits
577 
578  // add virtual measurements
579  for (unsigned int iVirtualMeas = 0; iVirtualMeas < refTrajPtr->numberOfVirtualMeas(); ++iVirtualMeas) {
580  this->addVirtualMeas(refTrajPtr, iVirtualMeas);
581  }
582 
583  // kill or end 'track' for mille, depends on #hits criterion
584  if (hitResultXy.first == 0 || hitResultXy.first < theMinNumHits) {
585  theMille->kill();
586  hitResultXy.first = hitResultXy.second = 0; //reset
587  } else {
588  theMille->end();
589  // add x/y hit count to MillePedeVariables of parVec,
590  // returning number of y-hits of the reference trajectory
591  hitResultXy.second = this->addHitCount(parVec, validHitVecY);
592  //
593  }
594  }
595 
596  } // end if valid trajectory
597 
598  return hitResultXy;
599 }
600 
601 //____________________________________________________
602 unsigned int MillePedeAlignmentAlgorithm::addHitCount(const std::vector<AlignmentParameters *> &parVec,
603  const std::vector<bool> &validHitVecY) const {
604  // Loop on all hit information in the input arrays and count valid y-hits:
605  unsigned int nHitY = 0;
606  for (unsigned int iHit = 0; iHit < validHitVecY.size(); ++iHit) {
607  Alignable *ali = (parVec[iHit] ? parVec[iHit]->alignable() : nullptr);
608  // Loop upwards on hierarchy of alignables to add hits to all levels
609  // that are currently aligned. If only a non-selected alignable was hit,
610  // (i.e. flagXY == 0 in addReferenceTrajectory(..)), there is no loop at all...
611  while (ali) {
613  if (pars) { // otherwise hierarchy level not selected
614  // cast ensured by previous checks:
615  MillePedeVariables *mpVar = static_cast<MillePedeVariables *>(pars->userVariables());
616  // every hit has an x-measurement, cf. addReferenceTrajectory(..):
617  mpVar->increaseHitsX();
618  if (validHitVecY[iHit]) {
619  mpVar->increaseHitsY();
620  if (pars == parVec[iHit])
621  ++nHitY; // do not count hits twice
622  }
623  }
624  ali = ali->mother();
625  }
626  }
627 
628  return nHitY;
629 }
630 
632  if (run.run() < firstIOV_ && !ignoreFirstIOVCheck_) {
633  throw cms::Exception("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::beginRun\n"
634  << "Using data (run = " << run.run() << ") prior to the first defined IOV ("
635  << firstIOV_ << ").";
636  }
637 
638  lastProcessedRun_ = run.run();
639 
640  if (changed && enableAlignableUpdates_) {
641  const auto runNumber = run.run();
643  for (auto runRange = uniqueRunRanges_.crbegin(); runRange != uniqueRunRanges_.crend(); ++runRange) {
644  if (runNumber >= runRange->first) {
645  firstRun = runRange->first;
646  break;
647  }
648  }
649  if (std::find(cachedRuns_.begin(), cachedRuns_.end(), firstRun) != cachedRuns_.end()) {
650  const auto &geometryRcd = setup.get<IdealGeometryRecord>();
651  const auto &globalPosRcd = setup.get<GlobalPositionRcd>();
652  const auto &alignmentRcd = setup.get<TrackerAlignmentRcd>();
653  const auto &surfaceRcd = setup.get<TrackerSurfaceDeformationRcd>();
654  const auto &errorRcd = setup.get<TrackerAlignmentErrorExtendedRcd>();
655 
656  std::ostringstream message;
657  bool throwException{false};
658  message << "Trying to cache tracker alignment payloads for a run (" << runNumber << ") in an IOV (" << firstRun
659  << ") that was already cached.\n"
660  << "The following records in your input database tag have an IOV "
661  << "boundary that does not match your IOV definition:\n";
662  if (geometryRcd.validityInterval().first().eventID().run() > firstRun) {
663  message << " - IdealGeometryRecord '" << geometryRcd.key().name() << "' (since "
664  << geometryRcd.validityInterval().first().eventID().run() << ")\n";
665  throwException = true;
666  }
667  if (globalPosRcd.validityInterval().first().eventID().run() > firstRun) {
668  message << " - GlobalPositionRecord '" << globalPosRcd.key().name() << "' (since "
669  << globalPosRcd.validityInterval().first().eventID().run() << ")";
671  message << " --> ignored\n";
672  } else {
673  message << "\n";
674  throwException = true;
675  }
676  }
677  if (alignmentRcd.validityInterval().first().eventID().run() > firstRun) {
678  message << " - TrackerAlignmentRcd '" << alignmentRcd.key().name() << "' (since "
679  << alignmentRcd.validityInterval().first().eventID().run() << ")\n";
680  throwException = true;
681  }
682  if (surfaceRcd.validityInterval().first().eventID().run() > firstRun) {
683  message << " - TrackerSurfaceDeformationRcd '" << surfaceRcd.key().name() << "' (since "
684  << surfaceRcd.validityInterval().first().eventID().run() << ")\n";
685  throwException = true;
686  }
687  if (errorRcd.validityInterval().first().eventID().run() > firstRun) {
688  message << " - TrackerAlignmentErrorExtendedRcd '" << errorRcd.key().name() << "' (since "
689  << errorRcd.validityInterval().first().eventID().run() << ")\n";
690  throwException = true;
691  }
692 
693  if (throwException) {
694  throw cms::Exception("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::beginRun\n" << message.str();
695  }
696  } else {
697  cachedRuns_.push_back(firstRun);
699  }
700  }
701 }
702 
703 //____________________________________________________
705  const EndRunInfo &runInfo,
706  const edm::EventSetup &setup) {
707  if (runInfo.tkLasBeams() && runInfo.tkLasBeamTsoses()) {
708  // LAS beam treatment
709  this->addLaserData(eventInfo, *(runInfo.tkLasBeams()), *(runInfo.tkLasBeamTsoses()));
710  }
711  if (this->isMode(myMilleBit))
712  theMille->flushOutputFile();
713 }
714 
715 // Implementation of endRun that DOES get called. (Because we need it.)
717  if (this->isMode(myMilleBit))
718  theMille->flushOutputFile();
719 }
720 
721 //____________________________________________________
723  if (!runAtPCL_)
724  return;
725  if (this->isMode(myMilleBit)) {
726  theMille->resetOutputFile();
727  theBinary.reset(); // GBL output has to be considered since same binary file is used
728  theBinary = std::make_unique<MilleBinary>((theDir + theConfig.getParameter<std::string>("binaryFile")).c_str(),
730  }
731 }
732 
733 //____________________________________________________
735  if (!runAtPCL_)
736  return;
737  if (this->isMode(myMilleBit))
738  theMille->flushOutputFile();
739 }
740 
741 //____________________________________________________
743  const EventInfo &eventInfo,
745  unsigned int iHit,
747  params = nullptr;
748  theFloatBufferX.clear();
749  theFloatBufferY.clear();
750  theIntBuffer.clear();
751 
752  const TrajectoryStateOnSurface &tsos = refTrajPtr->trajectoryStates()[iHit];
753  const ConstRecHitPointer &recHitPtr = refTrajPtr->recHits()[iHit];
754  // ignore invalid hits
755  if (!recHitPtr->isValid())
756  return 0;
757 
758  // First add the derivatives from IntegratedCalibration's,
759  // should even be OK if problems for "usual" derivatives from Alignables
760  this->globalDerivativesCalibration(recHitPtr,
761  tsos,
762  setup,
763  eventInfo, // input
766  theIntBuffer); // output
767 
768  // get AlignableDet/Unit for this hit
769  AlignableDetOrUnitPtr alidet(theAlignableNavigator->alignableFromDetId(recHitPtr->geographicalId()));
770 
771  if (!this->globalDerivativesHierarchy(eventInfo,
772  tsos,
773  alidet,
774  alidet,
775  theFloatBufferX, // 2x alidet, sic!
777  theIntBuffer,
778  params)) {
779  return -1; // problem
781  return 0; // empty for X: no alignable for hit, nor calibrations
782  } else {
783  // store measurement even if no alignable or calibrations
784  // -> measurement used for pede-internal track-fit
785  return this->callMille(refTrajPtr, iHit, theIntBuffer, theFloatBufferX, theFloatBufferY);
786  }
787 }
788 
789 //____________________________________________________
790 
792  const EventInfo &eventInfo,
794  unsigned int iHit,
795  GblPoint &gblPoint) {
796  AlignmentParameters *params = nullptr;
797  std::vector<double> theDoubleBufferX, theDoubleBufferY;
798  theDoubleBufferX.clear();
799  theDoubleBufferY.clear();
800  theIntBuffer.clear();
801  int iret = 0;
802 
803  const TrajectoryStateOnSurface &tsos = refTrajPtr->trajectoryStates()[iHit];
804  const ConstRecHitPointer &recHitPtr = refTrajPtr->recHits()[iHit];
805  // ignore invalid hits
806  if (!recHitPtr->isValid())
807  return 0;
808 
809  // get AlignableDet/Unit for this hit
810  AlignableDetOrUnitPtr alidet(theAlignableNavigator->alignableFromDetId(recHitPtr->geographicalId()));
811 
812  if (!this->globalDerivativesHierarchy(eventInfo,
813  tsos,
814  alidet,
815  alidet,
816  theDoubleBufferX, // 2x alidet, sic!
817  theDoubleBufferY,
818  theIntBuffer,
819  params)) {
820  return -1; // problem
821  }
822  //calibration parameters
823  int globalLabel;
824  std::vector<IntegratedCalibrationBase::ValuesIndexPair> derivs;
825  for (auto iCalib = theCalibrations.begin(); iCalib != theCalibrations.end(); ++iCalib) {
826  // get all derivatives of this calibration // const unsigned int num =
827  (*iCalib)->derivatives(derivs, *recHitPtr, tsos, setup, eventInfo);
828  for (auto iValuesInd = derivs.begin(); iValuesInd != derivs.end(); ++iValuesInd) {
829  // transfer label and x/y derivatives
830  globalLabel = thePedeLabels->calibrationLabel(*iCalib, iValuesInd->second);
831  if (globalLabel > 0 && globalLabel <= 2147483647) {
832  theIntBuffer.push_back(globalLabel);
833  theDoubleBufferX.push_back(iValuesInd->first.first);
834  theDoubleBufferY.push_back(iValuesInd->first.second);
835  } else {
836  edm::LogError("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::addGlobalData"
837  << "Invalid label " << globalLabel << " <= 0 or > 2147483647";
838  }
839  }
840  }
841  unsigned int numGlobals = theIntBuffer.size();
842  if (numGlobals > 0) {
843  Eigen::Matrix<double, 2, Eigen::Dynamic> globalDer{2, numGlobals};
844  for (unsigned int i = 0; i < numGlobals; ++i) {
845  globalDer(0, i) = theDoubleBufferX[i];
846  globalDer(1, i) = theDoubleBufferY[i];
847  }
848  gblPoint.addGlobals(theIntBuffer, globalDer);
849  iret = 1;
850  }
851  return iret;
852 }
853 
854 //____________________________________________________
856  const TrajectoryStateOnSurface &tsos,
857  Alignable *ali,
858  const AlignableDetOrUnitPtr &alidet,
859  std::vector<float> &globalDerivativesX,
860  std::vector<float> &globalDerivativesY,
861  std::vector<int> &globalLabels,
862  AlignmentParameters *&lowestParams) const {
863  // derivatives and labels are recursively attached
864  if (!ali)
865  return true; // no mother might be OK
866 
867  if (false && theMonitor && alidet != ali)
868  theMonitor->fillFrameToFrame(alidet, ali);
869 
871 
872  if (params) {
873  if (!lowestParams)
874  lowestParams = params; // set parameters of lowest level
875 
876  bool hasSplitParameters = thePedeLabels->hasSplitParameters(ali);
877  const unsigned int alignableLabel = thePedeLabels->alignableLabel(ali);
878 
879  if (0 == alignableLabel) { // FIXME: what about regardAllHits in Markus' code?
880  edm::LogWarning("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::globalDerivativesHierarchy"
881  << "Label not found, skip Alignable.";
882  return false;
883  }
884 
885  const std::vector<bool> &selPars = params->selector();
886  const AlgebraicMatrix derivs(params->derivatives(tsos, alidet));
887 
888  // cols: 2, i.e. x&y, rows: parameters, usually RigidBodyAlignmentParameters::N_PARAM
889  for (unsigned int iSel = 0; iSel < selPars.size(); ++iSel) {
890  if (selPars[iSel]) {
891  globalDerivativesX.push_back(derivs[iSel][kLocalX] / thePedeSteer->cmsToPedeFactor(iSel));
892  if (hasSplitParameters == true) {
893  globalLabels.push_back(thePedeLabels->parameterLabel(ali, iSel, eventInfo, tsos));
894  } else {
895  globalLabels.push_back(thePedeLabels->parameterLabel(alignableLabel, iSel));
896  }
897  globalDerivativesY.push_back(derivs[iSel][kLocalY] / thePedeSteer->cmsToPedeFactor(iSel));
898  }
899  }
900  // Exclude mothers if Alignable selected to be no part of a hierarchy:
901  if (thePedeSteer->isNoHiera(ali))
902  return true;
903  }
904  // Call recursively for mother, will stop if mother == 0:
905  return this->globalDerivativesHierarchy(
906  eventInfo, tsos, ali->mother(), alidet, globalDerivativesX, globalDerivativesY, globalLabels, lowestParams);
907 }
908 
909 //____________________________________________________
911  const TrajectoryStateOnSurface &tsos,
912  Alignable *ali,
913  const AlignableDetOrUnitPtr &alidet,
914  std::vector<double> &globalDerivativesX,
915  std::vector<double> &globalDerivativesY,
916  std::vector<int> &globalLabels,
917  AlignmentParameters *&lowestParams) const {
918  // derivatives and labels are recursively attached
919  if (!ali)
920  return true; // no mother might be OK
921 
922  if (false && theMonitor && alidet != ali)
923  theMonitor->fillFrameToFrame(alidet, ali);
924 
926 
927  if (params) {
928  if (!lowestParams)
929  lowestParams = params; // set parameters of lowest level
930 
931  bool hasSplitParameters = thePedeLabels->hasSplitParameters(ali);
932  const unsigned int alignableLabel = thePedeLabels->alignableLabel(ali);
933 
934  if (0 == alignableLabel) { // FIXME: what about regardAllHits in Markus' code?
935  edm::LogWarning("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::globalDerivativesHierarchy"
936  << "Label not found, skip Alignable.";
937  return false;
938  }
939 
940  const std::vector<bool> &selPars = params->selector();
941  const AlgebraicMatrix derivs(params->derivatives(tsos, alidet));
942  int globalLabel;
943 
944  // cols: 2, i.e. x&y, rows: parameters, usually RigidBodyAlignmentParameters::N_PARAM
945  for (unsigned int iSel = 0; iSel < selPars.size(); ++iSel) {
946  if (selPars[iSel]) {
947  if (hasSplitParameters == true) {
948  globalLabel = thePedeLabels->parameterLabel(ali, iSel, eventInfo, tsos);
949  } else {
950  globalLabel = thePedeLabels->parameterLabel(alignableLabel, iSel);
951  }
952  if (globalLabel > 0 && globalLabel <= 2147483647) {
953  globalLabels.push_back(globalLabel);
954  globalDerivativesX.push_back(derivs[iSel][kLocalX] / thePedeSteer->cmsToPedeFactor(iSel));
955  globalDerivativesY.push_back(derivs[iSel][kLocalY] / thePedeSteer->cmsToPedeFactor(iSel));
956  } else {
957  edm::LogError("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::globalDerivativesHierarchy"
958  << "Invalid label " << globalLabel << " <= 0 or > 2147483647";
959  }
960  }
961  }
962  // Exclude mothers if Alignable selected to be no part of a hierarchy:
963  if (thePedeSteer->isNoHiera(ali))
964  return true;
965  }
966  // Call recursively for mother, will stop if mother == 0:
967  return this->globalDerivativesHierarchy(
968  eventInfo, tsos, ali->mother(), alidet, globalDerivativesX, globalDerivativesY, globalLabels, lowestParams);
969 }
970 
971 //____________________________________________________
973  const TrajectoryStateOnSurface &tsos,
974  const edm::EventSetup &setup,
975  const EventInfo &eventInfo,
976  std::vector<float> &globalDerivativesX,
977  std::vector<float> &globalDerivativesY,
978  std::vector<int> &globalLabels) const {
979  std::vector<IntegratedCalibrationBase::ValuesIndexPair> derivs;
980  for (auto iCalib = theCalibrations.begin(); iCalib != theCalibrations.end(); ++iCalib) {
981  // get all derivatives of this calibration // const unsigned int num =
982  (*iCalib)->derivatives(derivs, *recHit, tsos, setup, eventInfo);
983  for (auto iValuesInd = derivs.begin(); iValuesInd != derivs.end(); ++iValuesInd) {
984  // transfer label and x/y derivatives
985  globalLabels.push_back(thePedeLabels->calibrationLabel(*iCalib, iValuesInd->second));
986  globalDerivativesX.push_back(iValuesInd->first.first);
987  globalDerivativesY.push_back(iValuesInd->first.second);
988  }
989  }
990 }
991 
992 // //____________________________________________________
993 // void MillePedeAlignmentAlgorithm
994 // ::callMille(const ReferenceTrajectoryBase::ReferenceTrajectoryPtr &refTrajPtr,
995 // unsigned int iTrajHit, MeasurementDirection xOrY,
996 // const std::vector<float> &globalDerivatives, const std::vector<int> &globalLabels)
997 // {
998 // const unsigned int xyIndex = iTrajHit*2 + xOrY;
999 // // FIXME: here for residuum and sigma we could use KALMAN-Filter results
1000 // const float residuum =
1001 // refTrajPtr->measurements()[xyIndex] - refTrajPtr->trajectoryPositions()[xyIndex];
1002 // const float covariance = refTrajPtr->measurementErrors()[xyIndex][xyIndex];
1003 // const float sigma = (covariance > 0. ? TMath::Sqrt(covariance) : 0.);
1004 
1005 // const AlgebraicMatrix &locDerivMatrix = refTrajPtr->derivatives();
1006 
1007 // std::vector<float> localDerivs(locDerivMatrix.num_col());
1008 // for (unsigned int i = 0; i < localDerivs.size(); ++i) {
1009 // localDerivs[i] = locDerivMatrix[xyIndex][i];
1010 // }
1011 
1012 // // &(vector[0]) is valid - as long as vector is not empty
1013 // // cf. http://www.parashift.com/c++-faq-lite/containers.html#faq-34.3
1014 // theMille->mille(localDerivs.size(), &(localDerivs[0]),
1015 // globalDerivatives.size(), &(globalDerivatives[0]), &(globalLabels[0]),
1016 // residuum, sigma);
1017 // if (theMonitor) {
1018 // theMonitor->fillDerivatives(refTrajPtr->recHits()[iTrajHit],localDerivs, globalDerivatives,
1019 // (xOrY == kLocalY));
1020 // theMonitor->fillResiduals(refTrajPtr->recHits()[iTrajHit],
1021 // refTrajPtr->trajectoryStates()[iTrajHit],
1022 // iTrajHit, residuum, sigma, (xOrY == kLocalY));
1023 // }
1024 // }
1025 
1026 //____________________________________________________
1028  // FIXME: Check whether this is a reliable and recommended way to find out...
1029 
1030  if (recHit->dimension() < 2) {
1031  return false; // some muon and TIB/TOB stuff really has RecHit1D
1032  } else if (recHit->detUnit()) { // detunit in strip is 1D, in pixel 2D
1033  return recHit->detUnit()->type().isTrackerPixel();
1034  } else { // stereo strips (FIXME: endcap trouble due to non-parallel strips (wedge sensors)?)
1035  if (dynamic_cast<const ProjectedSiStripRecHit2D *>(recHit->hit())) { // check persistent hit
1036  // projected: 1D measurement on 'glued' module
1037  return false;
1038  } else {
1039  return true;
1040  }
1041  }
1042 }
1043 
1044 //__________________________________________________________________________________________________
1046  bool setUserVars,
1047  const RunRange &runrange) {
1048  bool allEmpty = this->areEmptyParams(theAlignables);
1049 
1050  PedeReader reader(mprespset, *thePedeSteer, *thePedeLabels, runrange);
1051  align::Alignables alis;
1052  bool okRead = reader.read(alis, setUserVars); // also may set params of IntegratedCalibration's
1053  bool numMatch = true;
1054 
1055  std::stringstream out;
1056  out << "Read " << alis.size() << " alignables";
1057  if (alis.size() != theAlignables.size()) {
1058  out << " while " << theAlignables.size() << " in store";
1059  numMatch = false; // FIXME: Should we check one by one? Or transfer 'alis' to the store?
1060  }
1061  if (!okRead)
1062  out << ", but problems in reading";
1063  if (!allEmpty)
1064  out << ", possibly overwriting previous settings";
1065  out << ".";
1066 
1067  if (okRead && allEmpty) {
1068  if (numMatch) { // as many alignables with result as trying to align
1069  edm::LogInfo("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::readFromPede" << out.str();
1070  } else if (!alis.empty()) { // dead module do not get hits and no pede result
1071  edm::LogWarning("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::readFromPede" << out.str();
1072  } else { // serious problem: no result read - and not all modules can be dead...
1073  edm::LogError("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::readFromPede" << out.str();
1074  return false;
1075  }
1076  return true;
1077  }
1078  // the rest is not OK:
1079  edm::LogError("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::readFromPede" << out.str();
1080  return false;
1081 }
1082 
1083 //__________________________________________________________________________________________________
1085  for (const auto &iAli : alignables) {
1086  const AlignmentParameters *params = iAli->alignmentParameters();
1087  if (params) {
1088  const auto &parVec(params->parameters());
1089  const auto &parCov(params->covariance());
1090  for (int i = 0; i < parVec.num_row(); ++i) {
1091  if (parVec[i] != 0.)
1092  return false;
1093  for (int j = i; j < parCov.num_col(); ++j) {
1094  if (parCov[i][j] != 0.)
1095  return false;
1096  }
1097  }
1098  }
1099  }
1100 
1101  return true;
1102 }
1103 
1104 //__________________________________________________________________________________________________
1105 unsigned int MillePedeAlignmentAlgorithm::doIO(int loop) const {
1106  unsigned int result = 0;
1107 
1108  const std::string outFilePlain(theConfig.getParameter<std::string>("treeFile"));
1109  if (outFilePlain.empty()) {
1110  edm::LogInfo("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::doIO"
1111  << "treeFile parameter empty => skip writing for 'loop' " << loop;
1112  return result;
1113  }
1114 
1115  const std::string outFile(theDir + outFilePlain);
1116 
1117  AlignmentIORoot aliIO;
1118  int ioerr = 0;
1119  if (loop == 0) {
1120  aliIO.writeAlignableOriginalPositions(theAlignables, outFile.c_str(), loop, false, ioerr);
1121  if (ioerr) {
1122  edm::LogError("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::doIO"
1123  << "Problem " << ioerr << " in writeAlignableOriginalPositions";
1124  ++result;
1125  }
1126  } else if (loop == 1) {
1127  // only for first iov add hit counts, else 2x, 3x,... number of hits in IOV 2, 3,...
1128  const std::vector<std::string> inFiles(theConfig.getParameter<std::vector<std::string> >("mergeTreeFiles"));
1129  const std::vector<std::string> binFiles(theConfig.getParameter<std::vector<std::string> >("mergeBinaryFiles"));
1130  if (inFiles.size() != binFiles.size()) {
1131  edm::LogWarning("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::doIO"
1132  << "'vstring mergeTreeFiles' and 'vstring mergeBinaryFiles' "
1133  << "differ in size";
1134  }
1135  this->addHitStatistics(0, outFile, inFiles); // add hit info from tree 0 in 'infiles'
1136  }
1137  MillePedeVariablesIORoot millePedeIO;
1138  millePedeIO.writeMillePedeVariables(theAlignables, outFile.c_str(), loop, false, ioerr);
1139  if (ioerr) {
1140  edm::LogError("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::doIO"
1141  << "Problem " << ioerr << " writing MillePedeVariables";
1142  ++result;
1143  }
1144 
1145  aliIO.writeOrigRigidBodyAlignmentParameters(theAlignables, outFile.c_str(), loop, false, ioerr);
1146  if (ioerr) {
1147  edm::LogError("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::doIO"
1148  << "Problem " << ioerr << " in writeOrigRigidBodyAlignmentParameters, " << loop;
1149  ++result;
1150  }
1151  aliIO.writeAlignableAbsolutePositions(theAlignables, outFile.c_str(), loop, false, ioerr);
1152  if (ioerr) {
1153  edm::LogError("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::doIO"
1154  << "Problem " << ioerr << " in writeAlignableAbsolutePositions, " << loop;
1155  ++result;
1156  }
1157 
1158  return result;
1159 }
1160 
1161 //__________________________________________________________________________________________________
1163  for (const auto &iAli : alis) {
1164  AlignmentParameters *params = iAli->alignmentParameters();
1165  if (!params) {
1166  throw cms::Exception("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::buildUserVariables"
1167  << "No parameters for alignable";
1168  }
1169  MillePedeVariables *userVars = dynamic_cast<MillePedeVariables *>(params->userVariables());
1170  if (userVars) { // Just re-use existing, keeping label and numHits:
1171  for (unsigned int iPar = 0; iPar < userVars->size(); ++iPar) {
1172  // if (params->hierarchyLevel() > 0) {
1173  //std::cout << params->hierarchyLevel() << "\nBefore: " << userVars->parameter()[iPar];
1174  // }
1175  userVars->setAllDefault(iPar);
1176  //std::cout << "\nAfter: " << userVars->parameter()[iPar] << std::endl;
1177  }
1178  } else { // Nothing yet or erase wrong type:
1179  userVars = new MillePedeVariables(
1180  params->size(),
1181  thePedeLabels->alignableLabel(iAli),
1182  thePedeLabels->alignableTracker()->objectIdProvider().typeToName(iAli->alignableObjectId()));
1183  params->setUserVariables(userVars);
1184  }
1185  }
1186 }
1187 
1188 //__________________________________________________________________________________________________
1190  if (mode == "full") {
1192  } else if (mode == "mille") {
1193  return myMilleBit; // + myPedeSteerBit; // sic! Including production of steerig file. NO!
1194  } else if (mode == "pede") {
1196  } else if (mode == "pedeSteer") {
1197  return myPedeSteerBit;
1198  } else if (mode == "pedeRun") {
1199  return myPedeSteerBit + myPedeRunBit + myPedeReadBit; // sic! Including steering and reading of result.
1200  } else if (mode == "pedeRead") {
1201  return myPedeReadBit;
1202  }
1203 
1204  throw cms::Exception("BadConfig") << "Unknown mode '" << mode
1205  << "', use 'full', 'mille', 'pede', 'pedeRun', 'pedeSteer' or 'pedeRead'.";
1206 
1207  return 0;
1208 }
1209 
1210 //__________________________________________________________________________________________________
1212  const std::string &outFile,
1213  const std::vector<std::string> &inFiles) const {
1214  bool allOk = true;
1215  int ierr = 0;
1216  MillePedeVariablesIORoot millePedeIO;
1217  for (std::vector<std::string>::const_iterator iFile = inFiles.begin(); iFile != inFiles.end(); ++iFile) {
1218  const std::string inFile(theDir + *iFile);
1219  const std::vector<AlignmentUserVariables *> mpVars =
1220  millePedeIO.readMillePedeVariables(theAlignables, inFile.c_str(), fromIov, ierr);
1221  if (ierr || !this->addHits(theAlignables, mpVars)) {
1222  edm::LogError("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::addHitStatistics"
1223  << "Error " << ierr << " reading from " << inFile << ", tree " << fromIov
1224  << ", or problems in addHits";
1225  allOk = false;
1226  }
1227  for (std::vector<AlignmentUserVariables *>::const_iterator i = mpVars.begin(); i != mpVars.end(); ++i) {
1228  delete *i; // clean created objects
1229  }
1230  }
1231 
1232  return allOk;
1233 }
1234 
1235 //__________________________________________________________________________________________________
1237  const std::vector<AlignmentUserVariables *> &mpVars) const {
1238  bool allOk = (mpVars.size() == alis.size());
1239  std::vector<AlignmentUserVariables *>::const_iterator iUser = mpVars.begin();
1240  for (auto iAli = alis.cbegin(); iAli != alis.cend() && iUser != mpVars.end(); ++iAli, ++iUser) {
1241  MillePedeVariables *mpVarNew = dynamic_cast<MillePedeVariables *>(*iUser);
1242  AlignmentParameters *ps = (*iAli)->alignmentParameters();
1243  MillePedeVariables *mpVarOld = (ps ? dynamic_cast<MillePedeVariables *>(ps->userVariables()) : nullptr);
1244  if (!mpVarNew || !mpVarOld || mpVarOld->size() != mpVarNew->size()) {
1245  allOk = false;
1246  continue; // FIXME error etc.?
1247  }
1248 
1249  mpVarOld->increaseHitsX(mpVarNew->hitsX());
1250  mpVarOld->increaseHitsY(mpVarNew->hitsY());
1251  }
1252 
1253  return allOk;
1254 }
1255 
1256 //__________________________________________________________________________________________________
1257 template <typename GlobalDerivativeMatrix>
1258 void MillePedeAlignmentAlgorithm::makeGlobDerivMatrix(const std::vector<float> &globalDerivativesx,
1259  const std::vector<float> &globalDerivativesy,
1260  Eigen::MatrixBase<GlobalDerivativeMatrix> &aGlobalDerivativesM) {
1261  static_assert(GlobalDerivativeMatrix::RowsAtCompileTime == 2, "global derivative matrix must have two rows");
1262 
1263  for (size_t i = 0; i < globalDerivativesx.size(); ++i) {
1264  aGlobalDerivativesM(0, i) = globalDerivativesx[i];
1265  aGlobalDerivativesM(1, i) = globalDerivativesy[i];
1266  }
1267 }
1268 
1269 //__________________________________________________________________________________________________
1270 template <typename CovarianceMatrix,
1271  typename LocalDerivativeMatrix,
1272  typename ResidualMatrix,
1273  typename GlobalDerivativeMatrix>
1274 void MillePedeAlignmentAlgorithm::diagonalize(Eigen::MatrixBase<CovarianceMatrix> &aHitCovarianceM,
1275  Eigen::MatrixBase<LocalDerivativeMatrix> &aLocalDerivativesM,
1276  Eigen::MatrixBase<ResidualMatrix> &aHitResidualsM,
1277  Eigen::MatrixBase<GlobalDerivativeMatrix> &aGlobalDerivativesM) const {
1279  "'aLocalDerivativesM' and 'aHitResidualsM' must have the "
1280  "same underlying scalar type");
1282  "'aLocalDerivativesM' and 'aGlobalDerivativesM' must have the "
1283  "same underlying scalar type");
1284 
1285  Eigen::SelfAdjointEigenSolver<typename CovarianceMatrix::PlainObject> myDiag{aHitCovarianceM};
1286  // eigenvectors of real symmetric matrices are orthogonal, i.e. invert == transpose
1287  auto aTranfoToDiagonalSystemInv =
1288  myDiag.eigenvectors().transpose().template cast<typename LocalDerivativeMatrix::Scalar>();
1289 
1290  aHitCovarianceM = myDiag.eigenvalues().asDiagonal();
1291  aLocalDerivativesM = aTranfoToDiagonalSystemInv * aLocalDerivativesM;
1292  aHitResidualsM = aTranfoToDiagonalSystemInv * aHitResidualsM;
1293  if (aGlobalDerivativesM.size() > 0) {
1294  // diagonalize only if measurement depends on alignables or calibrations
1295  aGlobalDerivativesM = aTranfoToDiagonalSystemInv * aGlobalDerivativesM;
1296  }
1297 }
1298 
1299 //__________________________________________________________________________________________________
1300 template <typename CovarianceMatrix, typename ResidualMatrix, typename LocalDerivativeMatrix>
1303  unsigned int iVirtualMeas,
1304  Eigen::MatrixBase<CovarianceMatrix> &aHitCovarianceM,
1305  Eigen::MatrixBase<ResidualMatrix> &aHitResidualsM,
1306  Eigen::MatrixBase<LocalDerivativeMatrix> &aLocalDerivativesM) {
1307  // This Method is valid for 1D measurements only
1308 
1309  const unsigned int xIndex = iVirtualMeas + refTrajPtr->numberOfHitMeas();
1310 
1311  aHitCovarianceM(0, 0) = refTrajPtr->measurementErrors()[xIndex][xIndex];
1312  aHitResidualsM(0, 0) = refTrajPtr->measurements()[xIndex];
1313 
1314  const auto &locDerivMatrix = refTrajPtr->derivatives();
1315  for (int i = 0; i < locDerivMatrix.num_col(); ++i) {
1316  aLocalDerivativesM(0, i) = locDerivMatrix[xIndex][i];
1317  }
1318 }
1319 
1320 //__________________________________________________________________________________________________
1321 template <typename CovarianceMatrix, typename ResidualMatrix, typename LocalDerivativeMatrix>
1323  unsigned int iTrajHit,
1324  Eigen::MatrixBase<CovarianceMatrix> &aHitCovarianceM,
1325  Eigen::MatrixBase<ResidualMatrix> &aHitResidualsM,
1326  Eigen::MatrixBase<LocalDerivativeMatrix> &aLocalDerivativesM) {
1327  // This Method is valid for 2D measurements only
1328 
1329  const unsigned int xIndex = iTrajHit * 2;
1330  const unsigned int yIndex = iTrajHit * 2 + 1;
1331 
1332  aHitCovarianceM(0, 0) = refTrajPtr->measurementErrors()[xIndex][xIndex];
1333  aHitCovarianceM(0, 1) = refTrajPtr->measurementErrors()[xIndex][yIndex];
1334  aHitCovarianceM(1, 0) = refTrajPtr->measurementErrors()[yIndex][xIndex];
1335  aHitCovarianceM(1, 1) = refTrajPtr->measurementErrors()[yIndex][yIndex];
1336 
1337  aHitResidualsM(0, 0) = refTrajPtr->measurements()[xIndex] - refTrajPtr->trajectoryPositions()[xIndex];
1338  aHitResidualsM(1, 0) = refTrajPtr->measurements()[yIndex] - refTrajPtr->trajectoryPositions()[yIndex];
1339 
1340  const auto &locDerivMatrix = refTrajPtr->derivatives();
1341  for (int i = 0; i < locDerivMatrix.num_col(); ++i) {
1342  aLocalDerivativesM(0, i) = locDerivMatrix[xIndex][i];
1343  aLocalDerivativesM(1, i) = locDerivMatrix[yIndex][i];
1344  }
1345 }
1346 
1347 //__________________________________________________________________________________________________
1349  unsigned int iTrajHit,
1350  const std::vector<int> &globalLabels,
1351  const std::vector<float> &globalDerivativesX,
1352  const std::vector<float> &globalDerivativesY) {
1353  const ConstRecHitPointer aRecHit(refTrajPtr->recHits()[iTrajHit]);
1354 
1355  if ((aRecHit)->dimension() == 1) {
1356  return this->callMille1D(refTrajPtr, iTrajHit, globalLabels, globalDerivativesX);
1357  } else {
1358  return this->callMille2D(refTrajPtr, iTrajHit, globalLabels, globalDerivativesX, globalDerivativesY);
1359  }
1360 }
1361 
1362 //__________________________________________________________________________________________________
1364  unsigned int iTrajHit,
1365  const std::vector<int> &globalLabels,
1366  const std::vector<float> &globalDerivativesX) {
1367  const ConstRecHitPointer aRecHit(refTrajPtr->recHits()[iTrajHit]);
1368  const unsigned int xIndex = iTrajHit * 2; // the even ones are local x
1369 
1370  // local derivatives
1371  const AlgebraicMatrix &locDerivMatrix = refTrajPtr->derivatives();
1372  const int nLocal = locDerivMatrix.num_col();
1373  std::vector<float> localDerivatives(nLocal);
1374  for (unsigned int i = 0; i < localDerivatives.size(); ++i) {
1375  localDerivatives[i] = locDerivMatrix[xIndex][i];
1376  }
1377 
1378  // residuum and error
1379  float residX = refTrajPtr->measurements()[xIndex] - refTrajPtr->trajectoryPositions()[xIndex];
1380  float hitErrX = TMath::Sqrt(refTrajPtr->measurementErrors()[xIndex][xIndex]);
1381 
1382  // number of global derivatives
1383  const int nGlobal = globalDerivativesX.size();
1384 
1385  // &(localDerivatives[0]) etc. are valid - as long as vector is not empty
1386  // cf. http://www.parashift.com/c++-faq-lite/containers.html#faq-34.3
1387  theMille->mille(
1388  nLocal, &(localDerivatives[0]), nGlobal, &(globalDerivativesX[0]), &(globalLabels[0]), residX, hitErrX);
1389 
1390  if (theMonitor) {
1391  theMonitor->fillDerivatives(
1392  aRecHit, &(localDerivatives[0]), nLocal, &(globalDerivativesX[0]), nGlobal, &(globalLabels[0]));
1393  theMonitor->fillResiduals(aRecHit, refTrajPtr->trajectoryStates()[iTrajHit], iTrajHit, residX, hitErrX, false);
1394  }
1395 
1396  return 1;
1397 }
1398 
1399 //__________________________________________________________________________________________________
1401  unsigned int iTrajHit,
1402  const std::vector<int> &globalLabels,
1403  const std::vector<float> &globalDerivativesx,
1404  const std::vector<float> &globalDerivativesy) {
1405  const ConstRecHitPointer aRecHit(refTrajPtr->recHits()[iTrajHit]);
1406 
1407  if ((aRecHit)->dimension() != 2) {
1408  edm::LogError("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::callMille2D"
1409  << "You try to call method for 2D hits for a " << (aRecHit)->dimension()
1410  << "D Hit. Hit gets ignored!";
1411  return -1;
1412  }
1413 
1414  Eigen::Matrix<double, 2, 2> aHitCovarianceM;
1415  Eigen::Matrix<float, 2, 1> aHitResidualsM;
1416  Eigen::Matrix<float, 2, Eigen::Dynamic> aLocalDerivativesM{2, refTrajPtr->derivatives().num_col()};
1417  // below method fills above 3 matrices
1418  this->addRefTrackData2D(refTrajPtr, iTrajHit, aHitCovarianceM, aHitResidualsM, aLocalDerivativesM);
1419  Eigen::Matrix<float, 2, Eigen::Dynamic> aGlobalDerivativesM{2, globalDerivativesx.size()};
1420  this->makeGlobDerivMatrix(globalDerivativesx, globalDerivativesy, aGlobalDerivativesM);
1421 
1422  // calculates correlation between Hit measurements
1423  // FIXME: Should take correlation (and resulting transformation) from original hit,
1424  // not 2x2 matrix from ReferenceTrajectory: That can come from error propagation etc.!
1425  const double corr = aHitCovarianceM(0, 1) / sqrt(aHitCovarianceM(0, 0) * aHitCovarianceM(1, 1));
1426  if (theMonitor)
1427  theMonitor->fillCorrelations2D(corr, aRecHit);
1428  bool diag = false; // diagonalise only tracker TID, TEC
1429  switch (aRecHit->geographicalId().subdetId()) {
1430  case SiStripDetId::TID:
1431  case SiStripDetId::TEC:
1432  if (aRecHit->geographicalId().det() == DetId::Tracker && TMath::Abs(corr) > theMaximalCor2D) {
1433  this->diagonalize(aHitCovarianceM, aLocalDerivativesM, aHitResidualsM, aGlobalDerivativesM);
1434  diag = true;
1435  }
1436  break;
1437  default:;
1438  }
1439 
1440  float newResidX = aHitResidualsM(0, 0);
1441  float newResidY = aHitResidualsM(1, 0);
1442  float newHitErrX = TMath::Sqrt(aHitCovarianceM(0, 0));
1443  float newHitErrY = TMath::Sqrt(aHitCovarianceM(1, 1));
1444 
1445  // change from column major (Eigen default) to row major to have row entries
1446  // in continuous memory
1447  std::vector<float> newLocalDerivs(aLocalDerivativesM.size());
1448  Eigen::Map<Eigen::Matrix<float, 2, Eigen::Dynamic, Eigen::RowMajor> >(
1449  newLocalDerivs.data(), aLocalDerivativesM.rows(), aLocalDerivativesM.cols()) = aLocalDerivativesM;
1450  float *newLocalDerivsX = &(newLocalDerivs[0]);
1451  float *newLocalDerivsY = &(newLocalDerivs[aLocalDerivativesM.cols()]);
1452 
1453  // change from column major (Eigen default) to row major to have row entries
1454  // in continuous memory
1455  std::vector<float> newGlobDerivs(aGlobalDerivativesM.size());
1456  Eigen::Map<Eigen::Matrix<float, 2, Eigen::Dynamic, Eigen::RowMajor> >(
1457  newGlobDerivs.data(), aGlobalDerivativesM.rows(), aGlobalDerivativesM.cols()) = aGlobalDerivativesM;
1458  float *newGlobDerivsX = &(newGlobDerivs[0]);
1459  float *newGlobDerivsY = &(newGlobDerivs[aGlobalDerivativesM.cols()]);
1460 
1461  const int nLocal = aLocalDerivativesM.cols();
1462  const int nGlobal = aGlobalDerivativesM.cols();
1463 
1464  if (diag && (newHitErrX > newHitErrY)) { // also for 2D hits?
1465  // measurement with smaller error is x-measurement (for !is2D do not fill y-measurement):
1466  std::swap(newResidX, newResidY);
1467  std::swap(newHitErrX, newHitErrY);
1468  std::swap(newLocalDerivsX, newLocalDerivsY);
1469  std::swap(newGlobDerivsX, newGlobDerivsY);
1470  }
1471 
1472  // &(globalLabels[0]) is valid - as long as vector is not empty
1473  // cf. http://www.parashift.com/c++-faq-lite/containers.html#faq-34.3
1474  theMille->mille(nLocal, newLocalDerivsX, nGlobal, newGlobDerivsX, &(globalLabels[0]), newResidX, newHitErrX);
1475 
1476  if (theMonitor) {
1477  theMonitor->fillDerivatives(aRecHit, newLocalDerivsX, nLocal, newGlobDerivsX, nGlobal, &(globalLabels[0]));
1478  theMonitor->fillResiduals(
1479  aRecHit, refTrajPtr->trajectoryStates()[iTrajHit], iTrajHit, newResidX, newHitErrX, false);
1480  }
1481  const bool isReal2DHit = this->is2D(aRecHit); // strip is 1D (except matched hits)
1482  if (isReal2DHit) {
1483  theMille->mille(nLocal, newLocalDerivsY, nGlobal, newGlobDerivsY, &(globalLabels[0]), newResidY, newHitErrY);
1484  if (theMonitor) {
1485  theMonitor->fillDerivatives(aRecHit, newLocalDerivsY, nLocal, newGlobDerivsY, nGlobal, &(globalLabels[0]));
1486  theMonitor->fillResiduals(
1487  aRecHit, refTrajPtr->trajectoryStates()[iTrajHit], iTrajHit, newResidY, newHitErrY, true); // true: y
1488  }
1489  }
1490 
1491  return (isReal2DHit ? 2 : 1);
1492 }
1493 
1494 //__________________________________________________________________________________________________
1496  unsigned int iVirtualMeas) {
1497  Eigen::Matrix<double, 1, 1> aHitCovarianceM;
1498  Eigen::Matrix<float, 1, 1> aHitResidualsM;
1499  Eigen::Matrix<float, 1, Eigen::Dynamic> aLocalDerivativesM{1, refTrajPtr->derivatives().num_col()};
1500  // below method fills above 3 'matrices'
1501  this->addRefTrackVirtualMeas1D(refTrajPtr, iVirtualMeas, aHitCovarianceM, aHitResidualsM, aLocalDerivativesM);
1502 
1503  // no global parameters (use dummy 0)
1504  auto aGlobalDerivativesM = Eigen::Matrix<float, 1, 1>::Zero();
1505 
1506  float newResidX = aHitResidualsM(0, 0);
1507  float newHitErrX = TMath::Sqrt(aHitCovarianceM(0, 0));
1508  std::vector<float> newLocalDerivsX(aLocalDerivativesM.size());
1509  Eigen::Map<Eigen::Matrix<float, Eigen::Dynamic, Eigen::Dynamic, Eigen::RowMajor> >(
1510  newLocalDerivsX.data(), aLocalDerivativesM.rows(), aLocalDerivativesM.cols()) = aLocalDerivativesM;
1511 
1512  std::vector<float> newGlobDerivsX(aGlobalDerivativesM.size());
1513  Eigen::Map<Eigen::Matrix<float, Eigen::Dynamic, Eigen::Dynamic, Eigen::RowMajor> >(
1514  newGlobDerivsX.data(), aGlobalDerivativesM.rows(), aGlobalDerivativesM.cols()) = aGlobalDerivativesM;
1515 
1516  const int nLocal = aLocalDerivativesM.cols();
1517  const int nGlobal = 0;
1518 
1519  theMille->mille(nLocal, newLocalDerivsX.data(), nGlobal, newGlobDerivsX.data(), &nGlobal, newResidX, newHitErrX);
1520 }
1521 
1522 //____________________________________________________
1524  const TkFittedLasBeamCollection &lasBeams,
1525  const TsosVectorCollection &lasBeamTsoses) {
1526  TsosVectorCollection::const_iterator iTsoses = lasBeamTsoses.begin();
1527  for (TkFittedLasBeamCollection::const_iterator iBeam = lasBeams.begin(), iEnd = lasBeams.end(); iBeam != iEnd;
1528  ++iBeam, ++iTsoses) { // beam/tsoses parallel!
1529 
1530  edm::LogInfo("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::addLaserData"
1531  << "Beam " << iBeam->getBeamId() << " with " << iBeam->parameters().size()
1532  << " parameters and " << iBeam->getData().size() << " hits.\n There are "
1533  << iTsoses->size() << " TSOSes.";
1534 
1535  this->addLasBeam(eventInfo, *iBeam, *iTsoses);
1536  }
1537 }
1538 
1539 //____________________________________________________
1541  const TkFittedLasBeam &lasBeam,
1542  const std::vector<TrajectoryStateOnSurface> &tsoses) {
1543  AlignmentParameters *dummyPtr = nullptr; // for globalDerivativesHierarchy()
1544  std::vector<float> lasLocalDerivsX; // buffer for local derivatives
1545  const unsigned int beamLabel = thePedeLabels->lasBeamLabel(lasBeam.getBeamId()); // for global par
1546 
1547  for (unsigned int iHit = 0; iHit < tsoses.size(); ++iHit) {
1548  if (!tsoses[iHit].isValid())
1549  continue;
1550  // clear buffer
1551  theFloatBufferX.clear();
1552  theFloatBufferY.clear();
1553  theIntBuffer.clear();
1554  lasLocalDerivsX.clear();
1555  // get alignables and global parameters
1556  const SiStripLaserRecHit2D &hit = lasBeam.getData()[iHit];
1557  AlignableDetOrUnitPtr lasAli(theAlignableNavigator->alignableFromDetId(hit.getDetId()));
1559  eventInfo, tsoses[iHit], lasAli, lasAli, theFloatBufferX, theFloatBufferY, theIntBuffer, dummyPtr);
1560  // fill derivatives vector from derivatives matrix
1561  for (unsigned int nFitParams = 0; nFitParams < static_cast<unsigned int>(lasBeam.parameters().size());
1562  ++nFitParams) {
1563  const float derivative = lasBeam.derivatives()[iHit][nFitParams];
1564  if (nFitParams < lasBeam.firstFixedParameter()) { // first local beam parameters
1565  lasLocalDerivsX.push_back(derivative);
1566  } else { // now global ones
1567  const unsigned int numPar = nFitParams - lasBeam.firstFixedParameter();
1568  theIntBuffer.push_back(thePedeLabels->parameterLabel(beamLabel, numPar));
1569  theFloatBufferX.push_back(derivative);
1570  }
1571  } // end loop over parameters
1572 
1573  const float residual = hit.localPosition().x() - tsoses[iHit].localPosition().x();
1574  // error from file or assume 0.003
1575  const float error = 0.003; // hit.localPositionError().xx(); sqrt???
1576 
1577  theMille->mille(lasLocalDerivsX.size(),
1578  &(lasLocalDerivsX[0]),
1579  theFloatBufferX.size(),
1580  &(theFloatBufferX[0]),
1581  &(theIntBuffer[0]),
1582  residual,
1583  error);
1584  } // end of loop over hits
1585 
1586  theMille->end();
1587 }
1588 
1590  // do some printing, if requested
1591  const bool doOutputOnStdout(pxbSurveyCfg.getParameter<bool>("doOutputOnStdout"));
1592  if (doOutputOnStdout) {
1593  edm::LogInfo("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::addPxbSurvey"
1594  << "# Output from addPxbSurvey follows below because "
1595  << "doOutputOnStdout is set to True";
1596  }
1597 
1598  // instantiate a dicer object
1599  SurveyPxbDicer dicer(pxbSurveyCfg.getParameter<std::vector<edm::ParameterSet> >("toySurveyParameters"),
1600  pxbSurveyCfg.getParameter<unsigned int>("toySurveySeed"));
1601  std::ofstream outfile(pxbSurveyCfg.getUntrackedParameter<std::string>("toySurveyFile").c_str());
1602 
1603  // read data from file
1604  std::vector<SurveyPxbImageLocalFit> measurements;
1605  std::string filename(pxbSurveyCfg.getParameter<edm::FileInPath>("infile").fullPath());
1607 
1608  // loop over photographs (=measurements) and perform the fit
1609  for (std::vector<SurveyPxbImageLocalFit>::size_type i = 0; i != measurements.size(); i++) {
1610  if (doOutputOnStdout) {
1611  edm::LogInfo("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::addPxbSurvey"
1612  << "Module " << i << ": ";
1613  }
1614 
1615  // get the Alignables and their surfaces
1616  AlignableDetOrUnitPtr mod1(theAlignableNavigator->alignableFromDetId(measurements[i].getIdFirst()));
1617  AlignableDetOrUnitPtr mod2(theAlignableNavigator->alignableFromDetId(measurements[i].getIdSecond()));
1618  const AlignableSurface &surf1 = mod1->surface();
1619  const AlignableSurface &surf2 = mod2->surface();
1620 
1621  // the position of the fiducial points in local frame of a PXB module
1622  const LocalPoint fidpoint0(-0.91, +3.30);
1623  const LocalPoint fidpoint1(+0.91, +3.30);
1624  const LocalPoint fidpoint2(+0.91, -3.30);
1625  const LocalPoint fidpoint3(-0.91, -3.30);
1626 
1627  // We choose the local frame of the first module as reference,
1628  // so take the fidpoints of the second module and calculate their
1629  // positions in the reference frame
1630  const GlobalPoint surf2point0(surf2.toGlobal(fidpoint0));
1631  const GlobalPoint surf2point1(surf2.toGlobal(fidpoint1));
1632  const LocalPoint fidpoint0inSurf1frame(surf1.toLocal(surf2point0));
1633  const LocalPoint fidpoint1inSurf1frame(surf1.toLocal(surf2point1));
1634 
1635  // Create the vector for the fit
1637  fidpointvec.push_back(fidpoint0inSurf1frame);
1638  fidpointvec.push_back(fidpoint1inSurf1frame);
1639  fidpointvec.push_back(fidpoint2);
1640  fidpointvec.push_back(fidpoint3);
1641 
1642  // if toy survey is requested, dice the values now
1643  if (pxbSurveyCfg.getParameter<bool>("doToySurvey")) {
1644  dicer.doDice(fidpointvec, measurements[i].getIdPair(), outfile);
1645  }
1646 
1647  // do the fit
1648  measurements[i].doFit(fidpointvec, thePedeLabels->alignableLabel(mod1), thePedeLabels->alignableLabel(mod2));
1649  SurveyPxbImageLocalFit::localpars_t a; // local pars from fit
1650  a = measurements[i].getLocalParameters();
1651  const SurveyPxbImageLocalFit::value_t chi2 = measurements[i].getChi2();
1652 
1653  // do some reporting, if requested
1654  if (doOutputOnStdout) {
1655  edm::LogInfo("Alignment") << "@SUB=MillePedeAlignmentAlgorithm::addPxbSurvey"
1656  << "a: " << a[0] << ", " << a[1] << ", " << a[2] << ", " << a[3]
1657  << " S= " << sqrt(a[2] * a[2] + a[3] * a[3]) << " phi= " << atan(a[3] / a[2])
1658  << " chi2= " << chi2 << std::endl;
1659  }
1660  if (theMonitor) {
1661  theMonitor->fillPxbSurveyHistsChi2(chi2);
1662  theMonitor->fillPxbSurveyHistsLocalPars(a[0], a[1], sqrt(a[2] * a[2] + a[3] * a[3]), atan(a[3] / a[2]));
1663  }
1664 
1665  // pass the results from the local fit to mille
1667  theMille->mille((int)measurements[i].getLocalDerivsSize(),
1668  measurements[i].getLocalDerivsPtr(j),
1669  (int)measurements[i].getGlobalDerivsSize(),
1670  measurements[i].getGlobalDerivsPtr(j),
1671  measurements[i].getGlobalDerivsLabelPtr(j),
1672  measurements[i].getResiduum(j),
1673  measurements[i].getSigma(j));
1674  }
1675  theMille->end();
1676  }
1677  outfile.close();
1678 }
1679 
1681  const auto runRangeSelection = theConfig.getUntrackedParameter<edm::VParameterSet>("RunRangeSelection");
1682 
1683  if (runRangeSelection.empty())
1684  return false;
1685 
1686  const auto runRanges =
1688 
1689  return !(runRanges.empty());
1690 }
bool processesEvents() override
Returns whether MP should process events in the current configuration.
align::GlobalPoints toGlobal(const align::LocalPoints &) const
Return in global coord given a set of local points.
const TimeTypeSpecs timeTypeSpecs[]
Definition: Time.cc:16
std::shared_ptr< AlignPCLThresholdsHG > theThresholds
const ConstTrajTrackPairCollection & trajTrackPairs() const
ESGetTokenH3DDVariant esConsumes(std::string const &Record, edm::ConsumesCollector &)
Definition: DeDxTools.cc:283
T getParameter(std::string const &) const
Definition: ParameterSet.h:307
void resetParameters(void)
reset parameters, correlations, user variables
const IOVSyncValue & first() const
AlignmentParameters * alignmentParameters() const
Get the AlignmentParameters.
Definition: Alignable.h:58
bool supportsCalibrations() override
Returns whether MP supports calibrations.
Alignable * mother() const
Return pointer to container alignable (if any)
Definition: Alignable.h:91
std::unordered_map< std::string, std::vector< float > > param_map
std::unique_ptr< MillePedeMonitor > theMonitor
void increaseHitsX(unsigned int add=1)
increase hits for x-measurement
bool setParametersForRunRange(const RunRange &runrange) override
void globalDerivativesCalibration(const TransientTrackingRecHit::ConstRecHitPointer &recHit, const TrajectoryStateOnSurface &tsos, const edm::EventSetup &setup, const EventInfo &eventInfo, std::vector< float > &globalDerivativesX, std::vector< float > &globalDerivativesY, std::vector< int > &globalLabels) const
adding derivatives from integrated calibrations
bool addCalibrations(const std::vector< IntegratedCalibrationBase *> &iCals) override
Pass integrated calibrations to Millepede (they are not owned by Millepede!)
Derivative< X, A >::type derivative(const A &_)
Definition: Derivative.h:18
virtual void endRun(const EventInfo &, const EndRunInfo &, const edm::EventSetup &)
Run on run products, e.g. TkLAS.
const AlignableSurface & surface() const
Return the Surface (global position and orientation) of the object.
Definition: Alignable.h:132
const bool isValid(const Frame &aFrame, const FrameQuality &aQuality, const uint16_t aExpectedPos)
std::vector< coord_t > fidpoint_t
def create(alignables, pedeDump, additionalData, outputFile, config)
std::map< std::string, AlignPCLThreshold > threshold_map
std::string fullPath() const
Definition: FileInPath.cc:161
void increaseHitsY(unsigned int add=1)
increase hits for y-measurement
Time_t beginValue
Definition: Time.h:41
void endLuminosityBlock(const edm::EventSetup &) override
called at end of luminosity block
static constexpr auto TID
Definition: SiStripDetId.h:38
TrajectoryFactoryBase::ReferenceTrajectoryCollection RefTrajColl
std::vector< ParameterSet > VParameterSet
Definition: ParameterSet.h:35
std::unique_ptr< TrajectoryFactoryBase > theTrajectoryFactory
bool areEmptyParams(const align::Alignables &alignables) const
std::unique_ptr< gbl::MilleBinary > theBinary
bool exists(std::string const &parameterName) const
checks if a parameter exists
const Time_t MIN_VAL(0)
int addGlobalData(const edm::EventSetup &setup, const EventInfo &eventInfo, const ReferenceTrajectoryBase::ReferenceTrajectoryPtr &refTrajPtr, unsigned int iHit, gbl::GblPoint &gblPoint)
void restoreCachedTransformations(void)
restore the previously cached position, rotation and other parameters
std::shared_ptr< PedeLabelerBase > thePedeLabels
bool globalDerivativesHierarchy(const EventInfo &eventInfo, const TrajectoryStateOnSurface &tsos, Alignable *ali, const AlignableDetOrUnitPtr &alidet, std::vector< float > &globalDerivativesX, std::vector< float > &globalDerivativesY, std::vector< int > &globalLabels, AlignmentParameters *&lowestParams) const
recursively adding derivatives and labels, false if problems
const align::Alignables & alignables(void) const
get all alignables
void applyParameters(void)
Obsolete: Use AlignableNavigator::alignableDetFromDetId and alignableFromAlignableDet.
std::vector< std::string > getExistingFormattedFiles(const std::vector< std::string > &plainFiles, const std::string &theDir)
reader
Definition: DQM.py:105
bool isMode(unsigned int testMode) const
const edm::ESGetToken< TrackerGeometry, TrackerDigiGeometryRecord > geomToken_
int callMille2D(const ReferenceTrajectoryBase::ReferenceTrajectoryPtr &refTrajPtr, unsigned int iTrajHit, const std::vector< int > &globalLabels, const std::vector< float > &globalDerivativesx, const std::vector< float > &globalDerivativesy)
Log< level::Error, false > LogError
const std::vector< SiStripLaserRecHit2D > & getData(void) const
access the collection of hits
Definition: TkLasBeam.h:26
void find(edm::Handle< EcalRecHitCollection > &hits, DetId thisDet, std::vector< EcalRecHitCollection::const_iterator > &hit, bool debug=false)
Definition: FindCaloHit.cc:19
void writeMillePedeVariables(const align::Alignables &alivec, const char *filename, int iter, bool validCheck, int &ierr)
void writeAlignableOriginalPositions(const align::Alignables &alivec, const char *filename, int iter, bool validCheck, int &ierr) override
write Alignable original (before misalignment) absolute positions
uint16_t size_type
void addLasBeam(const EventInfo &eventInfo, const TkFittedLasBeam &lasBeam, const std::vector< TrajectoryStateOnSurface > &tsoses)
void swap(Association< C > &lhs, Association< C > &rhs)
Definition: Association.h:112
define event information passed to algorithms
T getUntrackedParameter(std::string const &, T const &) const
int callMille(const ReferenceTrajectoryBase::ReferenceTrajectoryPtr &refTrajPtr, unsigned int iTrajHit, const std::vector< int > &globalLabels, const std::vector< float > &globalDerivativesX, const std::vector< float > &globalDerivativesY)
calls callMille1D or callMille2D
TransientTrackingRecHit::ConstRecHitPointer ConstRecHitPointer
U second(std::pair< T, U > const &p)
void beginLuminosityBlock(const edm::EventSetup &) override
called at begin of luminosity block (resets Mille binary in mille mode)
std::vector< align::RunNumber > cachedRuns_
std::string doDice(const fidpoint_t &fidpointvec, const idPair_t &id, const bool rotate=false)
unsigned int hitsX() const
get number of hits for x-measurement
int callMille1D(const ReferenceTrajectoryBase::ReferenceTrajectoryPtr &refTrajPtr, unsigned int iTrajHit, const std::vector< int > &globalLabels, const std::vector< float > &globalDerivativesX)
calls Mille for 1D hits
void addLaserData(const EventInfo &eventInfo, const TkFittedLasBeamCollection &tkLasBeams, const TsosVectorCollection &tkLasBeamTsoses)
int addMeasurementData(const edm::EventSetup &setup, const EventInfo &eventInfo, const ReferenceTrajectoryBase::ReferenceTrajectoryPtr &refTrajPtr, unsigned int iHit, AlignmentParameters *&params)
virtual bool storeThresholds(const int &nRecords, const AlignPCLThresholdsHG::threshold_map &thresholdMap, const AlignPCLThresholdsHG::param_map &floatMap)
void beginRun(const edm::Run &run, const edm::EventSetup &setup, bool changed) override
called at begin of run
dictionary corr
CLHEP::HepMatrix AlgebraicMatrix
RunRanges makeNonOverlappingRunRanges(const edm::VParameterSet &runRanges, const RunNumber &defaultRun)
Definition: Utilities.cc:202
bool is2D(const TransientTrackingRecHit::ConstRecHitPointer &recHit) const
true if hit belongs to 2D detector (currently tracker specific)
void makeGlobDerivMatrix(const std::vector< float > &globalDerivativesx, const std::vector< float > &globalDerivativesy, Eigen::MatrixBase< GlobalDerivativeMatrix > &aGlobalDerivativesM)
std::shared_ptr< TrackingRecHit const > ConstRecHitPointer
void writeOrigRigidBodyAlignmentParameters(const align::Alignables &alivec, const char *filename, int iter, bool validCheck, int &ierr) override
write RigidBodyAlignmentParameters as applied on top of original positions
const edm::ESGetToken< TrackerTopology, TrackerTopologyRcd > topoToken_
T sqrt(T t)
Definition: SSEVec.h:19
RunRanges makeUniqueRunRanges(const edm::VParameterSet &runRanges, const RunNumber &defaultRun)
Definition: Utilities.cc:241
const AlgebraicMatrix & derivatives() const
matrix of local derivatives: columns are parameters, rows are hits
std::shared_ptr< PixelTopologyMap > pixelTopologyMap
const edm::ESGetToken< AlignPCLThresholdsHG, AlignPCLThresholdsHGRcd > aliThrToken_
AlignmentParameterStore * theAlignmentParameterStore
directory for all kind of files
AlignmentUserVariables * userVariables(void) const
Get pointer to user variables.
bool addHitStatistics(int fromLoop, const std::string &outFile, const std::vector< std::string > &inFiles) const
void diagonalize(Eigen::MatrixBase< CovarianceMatrix > &aHitCovarianceM, Eigen::MatrixBase< LocalDerivativeMatrix > &aLocalDerivativesM, Eigen::MatrixBase< ResidualMatrix > &aHitResidualsM, Eigen::MatrixBase< GlobalDerivativeMatrix > &aGlobalDerivativesM) const
std::vector< AlignmentUserVariables * > readMillePedeVariables(const align::Alignables &alivec, const char *filename, int iter, int &ierr)
Transition
Definition: Transition.h:12
bool addHits(const align::Alignables &alis, const std::vector< AlignmentUserVariables *> &mpVars) const
void addRefTrackVirtualMeas1D(const ReferenceTrajectoryBase::ReferenceTrajectoryPtr &refTrajPtr, unsigned int iVirtualMeas, Eigen::MatrixBase< CovarianceMatrix > &aHitCovarianceM, Eigen::MatrixBase< ResidualMatrix > &aHitResidualsM, Eigen::MatrixBase< LocalDerivativeMatrix > &aLocalDerivativesM)
adds data for a specific virtual measurement from reference trajectory
key
prepare the HTCondor submission files and eventually submit them
void addRefTrackData2D(const ReferenceTrajectoryBase::ReferenceTrajectoryPtr &refTrajPtr, unsigned int iTrajHit, Eigen::MatrixBase< CovarianceMatrix > &aHitCovarianceM, Eigen::MatrixBase< ResidualMatrix > &aHitResidualsM, Eigen::MatrixBase< LocalDerivativeMatrix > &aLocalDerivativesM)
adds data from reference trajectory from a specific Hit
unsigned int decodeMode(const std::string &mode) const
unsigned int addHitCount(const std::vector< AlignmentParameters *> &parVec, const std::vector< bool > &validHitVecY) const
std::unique_ptr< PedeSteerer > thePedeSteer
bool storeAlignments() override
Returns whether MP produced results to be stored.
void terminate() override
Called at end of job.
unsigned int getBeamId(void) const
return the full beam identifier
Definition: TkLasBeam.h:23
void initialize(const edm::EventSetup &setup, AlignableTracker *tracker, AlignableMuon *muon, AlignableExtras *extras, AlignmentParameterStore *store) override
Called at beginning of job.
std::vector< ConstRecHitPointer > ConstRecHitContainer
unsigned int firstFixedParameter() const
Log< level::Info, false > LogInfo
void addVirtualMeas(const ReferenceTrajectoryBase::ReferenceTrajectoryPtr &refTrajPtr, unsigned int iVirtualMeas)
adds data for virtual measurements from reference trajectory
RunNumber_t run() const
Definition: EventID.h:38
bool readFromPede(const edm::ParameterSet &mprespset, bool setUserVars, const RunRange &runrange)
read pede input defined by &#39;psetName&#39;, flag to create/not create MillePedeVariables ...
std::pair< unsigned int, unsigned int > addReferenceTrajectory(const edm::EventSetup &setup, const EventInfo &eventInfo, const ReferenceTrajectoryBase::ReferenceTrajectoryPtr &refTrajPtr)
fill mille for a trajectory, returning number of x/y hits ([0,0] if &#39;bad&#39; trajectory) ...
void buildUserVariables(const align::Alignables &alignables) const
add MillePedeVariables for each AlignmentParameters (exception if no parameters...)
void addUntrackedParameter(std::string const &name, T const &value)
Definition: ParameterSet.h:193
std::vector< IntegratedCalibrationBase * > theCalibrations
Class to hold one picture of the BPix survey.
std::vector< value_t > localpars_t
void writeAlignableAbsolutePositions(const align::Alignables &alivec, const char *filename, int iter, bool validCheck, int &ierr) override
write Alignable current absolute positions
std::vector< Alignable * > Alignables
Definition: Utilities.h:31
const EventID & eventID() const
Definition: IOVSyncValue.h:40
void run(const edm::EventSetup &setup, const EventInfo &eventInfo) override
Run the algorithm on trajectories and tracks.
HLT enums.
~MillePedeAlignmentAlgorithm() override
Destructor.
MillePedeAlignmentAlgorithm(const edm::ParameterSet &cfg, edm::ConsumesCollector &iC)
Constructor.
align::RotationType toLocal(const align::RotationType &) const
Return in local frame a rotation given in global frame.
std::vector< TkFittedLasBeam > TkFittedLasBeamCollection
double a
Definition: hdecay.h:121
Eigen::Matrix< float, EcalPulseShape::TEMPLATESAMPLES, EcalPulseShape::TEMPLATESAMPLES > CovarianceMatrix
void cacheTransformations(void)
cache the current position, rotation and other parameters
TransientTrackingRecHit::ConstRecHitContainer ConstRecHitContainer
unsigned int size() const
number of parameters
static const count_t nMsrmts
eventInfo
add run, event number and lumi section
void addPxbSurvey(const edm::ParameterSet &pxbSurveyCfg)
add measurement data from PXB survey
#define get
std::unique_ptr< AlignableNavigator > theAlignableNavigator
Log< level::Warning, false > LogWarning
Time_t endValue
Definition: Time.h:42
const std::vector< Scalar > & parameters() const
parallel to derivatives()
std::vector< std::vector< TrajectoryStateOnSurface > > TsosVectorCollection
define run information passed to algorithms (in endRun)
unsigned int hitsY() const
get number of hits for y-measurement
Constructor of the full muon geometry.
Definition: AlignableMuon.h:38
uint32_t dimension(pat::CandKinResolution::Parametrization parametrization)
Returns the number of free parameters in a parametrization (3 or 4)
ValidityInterval validityInterval() const
const Time_t MAX_VAL(std::numeric_limits< Time_t >::max())
std::vector< ReferenceTrajectoryPtr > ReferenceTrajectoryCollection
void throwException(const std::string &message, const std::string &methodName)
Definition: Exception.cc:12
bool setAllDefault(unsigned int nParam)
set default values for all data concerning nParam (false if nParam out of range)
static constexpr auto TEC
Definition: SiStripDetId.h:40
Definition: Run.h:45