LArSoft  v09_90_00
Liquid Argon Software toolkit - https://larsoft.org/
CalWireAna_module.cc
Go to the documentation of this file.
1 //
3 // CalWireAna class designed to make histos.
4 //
5 //
6 //
8 
10 
11 // C++ includes
12 #include <algorithm>
13 #include <string>
14 
15 // Framework includes
20 #include "art_root_io/TFileService.h"
23 #include "fhiclcpp/ParameterSet.h"
25 
26 // LArSoft includes
31 #include "larevt/CalibrationDBI/Interface/ChannelStatusProvider.h"
32 #include "larevt/CalibrationDBI/Interface/ChannelStatusService.h"
33 
34 // ROOT includes
35 #include "TComplex.h"
36 #include "TH1.h"
37 #include "TH2.h"
38 #include "TMath.h"
39 
40 namespace caldata {
41 
43  class CalWireAna : public art::EDAnalyzer {
44 
45  public:
46  explicit CalWireAna(fhicl::ParameterSet const& pset);
47 
49  void analyze(const art::Event& evt);
50  void beginJob();
51  void endJob();
52 
53  private:
54  std::string fCalWireModuleLabel;
55  std::string fDetSimModuleLabel; //< name of module that produced the digits
56 
57  TH1F* fDiffsR;
58  TH1F* fDiffsW;
59  TH1F* fDiffsRW;
60  TH1F* fDiffsRWgph;
61  TH1F* fMin;
62  TH1F* fMax;
63  TH1F* fIR;
64  TH1F* fCR;
65  TH1F* fIW;
66  TH1F* fCW;
67  TH1F* fRawIndPeak; //Raw Induction Peak Values
68  TH1F* fRawColPeak; //Raw Collection Peak Values
69  TH1F* fCalIndPeak; //Calibrated Induction Peak Values
70  TH1F* fCalColPeak; //Calibrated Collection Peak Values
71  TH1F* fNoiseHist; //Noise Frequency Spectrum
72  TH1F* fNoiseRMS; //Noise RMS values
73  TH2F* fWireSig;
74  TH2F* fRawSig;
75  TH2F*
77  TH2F*
79  TH2F* fDiffsRWvsR;
81  TH2F* fWindow;
82 
83  }; // class CalWireAna
84 
85 } // End caldata namespace.
86 
87 namespace caldata {
88 
89  //-------------------------------------------------
91  : EDAnalyzer(pset)
92  , fCalWireModuleLabel(pset.get<std::string>("CalWireModuleLabel"))
93  , fDetSimModuleLabel(pset.get<std::string>("DetSimModuleLabel"))
94  {}
95 
96  //-------------------------------------------------
98  {
99  // get access to the TFile service
101 
102  fDiffsR = tfs->make<TH1F>("One timestamp diffs in RawDigits", ";#Delta ADC;", 40, -19.5, 20.5);
103  fDiffsW = tfs->make<TH1F>("One timestamp diffs in Wires", ";#Delta ADC;", 20, -9.5, 10.5);
104  fDiffsRW = tfs->make<TH1F>("Same timestamp diffs in RD-Wires", ";#Delta ADC;", 20, -9.5, 10.5);
105  fDiffsRWvsR = tfs->make<TH2F>(
106  "Same timestamp diffs in RD-Wires vs R", ";#Delta ADC;", 481, -0.5, 480.5, 20, -9.5, 10.5);
107  fDiffsRWgph =
108  tfs->make<TH1F>("Same timestamp diffs in RD-Wires gph", ";#Delta ADC;", 20, -9.5, 10.5);
109  fDiffsRWvsRgph = tfs->make<TH2F>("Same timestamp diffs in RD-Wires vs R gph",
110  ";#Delta ADC;",
111  481,
112  -0.5,
113  480.5,
114  20,
115  -9.5,
116  10.5);
117  fRawSig =
118  tfs->make<TH2F>("One event, one channel Raw", "timestamp", 481, -0.5, 480.5, 21, -0.5, 20.5);
119  fWireSig =
120  tfs->make<TH2F>("One event, one channel Wire", "timestamp", 481, -0.5, 480.5, 21, -0.5, 20.5);
121 
122  fRD_WireMeanDiff2D = tfs->make<TH2F>(
123  "Mean (Raw-CALD)-over-Raw in Window gph", "Wire number", 481, -0.05, 480.5, 40, -1., 1.);
124  fRD_WireRMSDiff2D = tfs->make<TH2F>(
125  "RMS (Raw-CALD)-over-Raw in Window gph", "Wire number", 481, -0.05, 480.5, 10, 0., 2.);
126 
127  fWindow = tfs->make<TH2F>("tmax-tmin vs indMax", "ticks", 200, 0, 2000, 20, -2.5, 60.5);
128  fMin = tfs->make<TH1F>("Value of min", "ticks", 21, -20.5, 0.5);
129  fMax = tfs->make<TH1F>("Value of max", "ticks", 21, 0.5, 20.5);
130  fRawIndPeak = tfs->make<TH1F>("indPeakRaw", ";Induction Peaks Raw;", 40, 5, 45);
131  fRawColPeak = tfs->make<TH1F>("colPeakRaw", ";Collection Peaks Raw;", 40, 5, 45);
132  fCalIndPeak = tfs->make<TH1F>("indPeakCal", ";Induction Peaks Calibrated;", 40, 5, 45);
133  fCalColPeak = tfs->make<TH1F>("colPeakCal", ";Collection Peaks Calibrated;", 40, 5, 45);
134 
135  fIR = tfs->make<TH1F>("Raw Ind signal", "time ticks", 4096, 0.0, 4096.);
136  fCR = tfs->make<TH1F>("Raw Coll signal", "time ticks", 4096, 0.0, 4096.);
137  fIW = tfs->make<TH1F>("Wire Ind signal", "time ticks", 4096, 0.0, 4096.);
138  fCW = tfs->make<TH1F>("Wire Coll signal", "time ticks", 4096, 0.0, 4096.);
139  fNoiseHist = tfs->make<TH1F>("Noise Histogram", "FFT Bins", 2049, 0, 2049);
140  fNoiseRMS = tfs->make<TH1F>("Noise RMS", "RMS", 25, 0, 2.0);
141 
142  return;
143  }
144 
145  //-------------------------------------------------
147 
148  //-------------------------------------------------
150  {
151 
152  // loop over the raw digits and get the adc vector for each, then compress it and uncompress it
153 
154  lariov::ChannelStatusProvider const& channelStatus =
157  evt.getByLabel(fDetSimModuleLabel, rdHandle);
159  evt.getByLabel(fCalWireModuleLabel, wHandle);
160 
161  // get the raw::RawDigit associated by fCalWireModuleLabel to wires in wHandle;
162  // RawDigitsFromWire.at(index) will be a art::Ptr<raw::RawDigit>
163  art::FindOneP<raw::RawDigit> RawDigitsFromWire(wHandle, evt, fCalWireModuleLabel);
164 
166  for (unsigned int i = 0; i < wHandle->size(); ++i) {
167  art::Ptr<recob::Wire> w(wHandle, i);
168  wvec.push_back(w);
169  }
171  for (unsigned int i = 0; i < rdHandle->size(); ++i) {
172  art::Ptr<raw::RawDigit> r(rdHandle, i);
173  rdvec.push_back(r);
174  }
175 
178  double pedestal = rdvec[0]->GetPedestal();
179  double threshold = 9.0;
180  double signalSize = rdvec[0]->Samples();
181  uint32_t indChan0 = 64;
182  uint32_t indChan1 = 110;
183  uint32_t colChan0 = 312;
184  uint32_t colChan1 = 354;
185  std::vector<double> ir(fft->FFTSize()), iw(fft->FFTSize()), cr(fft->FFTSize()),
186  cw(fft->FFTSize());
187  ir[signalSize] = iw[signalSize] = cr[signalSize] = cw[signalSize] = 1.0;
189  for (unsigned int rd = 0; rd < rdvec.size(); ++rd) {
190  // Find corresponding wire.
191  std::vector<double> signal(fft->FFTSize());
192  for (unsigned int wd = 0; wd < wvec.size(); ++wd) {
193  // if (wvec[wd]->RawDigit() == rdvec[rd]){
194  if (RawDigitsFromWire.at(wd) == rdvec[rd]) {
195  std::vector<float> wirSig = wvec[wd]->Signal();
196  if (wirSig.size() > signal.size()) {
197  MF_LOG_DEBUG("CalWireAna")
198  << "Incompatible vector size " << wirSig.size() << " " << signal.size();
199  return;
200  }
201  for (unsigned int ii = 0; ii < wirSig.size(); ++ii) {
202  signal[ii] = wirSig[ii];
203  }
204  break;
205  }
206  if (wd == (wvec.size() - 1)) {
207  MF_LOG_DEBUG("CalWireAna")
208  << "caldata::CalWireAna:Big problem! No matching Wire for RawDigit. Bailing." << rd;
209  return;
210  }
211  }
212 
213  std::vector<double> adc(fft->FFTSize());
214 
215  for (unsigned int t = 1; t < rdvec[rd]->Samples(); ++t) {
216  fDiffsR->Fill(rdvec[rd]->ADC(t) - rdvec[rd]->ADC(t - 1));
217  adc[t - 1] = rdvec[rd]->ADC(t - 1);
218  fRawSig->Fill(rd, rdvec[rd]->ADC(t));
219  }
220  //get the last one for the adc vector
221  adc[rdvec[rd]->Samples() - 1] = rdvec[rd]->ADC(rdvec[rd]->Samples() - 1);
222  if (!channelStatus.IsBad(rdvec[rd]->Channel()) &&
223  (*max_element(adc.begin(), adc.end()) < pedestal + threshold &&
224  *min_element(adc.begin(), adc.end()) > pedestal - threshold)) {
225  double sum = 0;
226  for (int i = 0; i < signalSize; i++)
227  sum += pow(adc[i] - pedestal, 2.0);
228  fNoiseRMS->Fill(TMath::Sqrt(sum / (double)signalSize));
229  std::vector<double> temp(fft->FFTSize());
230  std::vector<TComplex> fTemp(fft->FFTSize() / 2 + 1);
231  for (int i = 0; i < signalSize; i++)
232  temp[i] = (adc[i] - pedestal) * sin(TMath::Pi() * (double)i / signalSize);
233  fft->DoFFT(temp, fTemp);
234  for (int i = 0; i < fft->FFTSize() / 2 + 1; i++)
235  fNoiseHist->Fill(i, fTemp[i].Rho());
236  }
237  if (geom->SignalType(rdvec[rd]->Channel()) == geo::kInduction &&
238  rdvec[rd]->Channel() > indChan0 && rdvec[rd]->Channel() < indChan1) {
239  fft->AlignedSum(ir, adc);
240  fft->AlignedSum(iw, signal);
241  }
242  if (geom->SignalType(rdvec[rd]->Channel()) == geo::kCollection &&
243  rdvec[rd]->Channel() > colChan0 && rdvec[rd]->Channel() < colChan1) {
244  fft->AlignedSum(cr, adc);
245  fft->AlignedSum(cw, signal);
246  }
247  if (geom->SignalType(rdvec[rd]->Channel()) == geo::kInduction) {
248  if (*max_element(adc.begin(), adc.end()) > pedestal + threshold)
249  fRawIndPeak->Fill(*max_element(adc.begin(), adc.end()));
250  if (*max_element(signal.begin(), signal.end()) > pedestal + threshold)
251  fCalIndPeak->Fill(*max_element(signal.begin(), signal.end()));
252  }
253  if (geom->SignalType(rdvec[rd]->Channel()) == geo::kCollection) {
254  if (*max_element(adc.begin(), adc.end()) > pedestal + threshold)
255  fRawColPeak->Fill(*max_element(adc.begin(), adc.end()));
256  if (*max_element(signal.begin(), signal.end()) > pedestal + threshold)
257  fCalColPeak->Fill(*max_element(signal.begin(), signal.end()));
258  }
259 
260  int window = 8;
261  static unsigned int pulseHeight = 5;
262  unsigned int tmin = 1;
263  unsigned int tmax = 1;
264  int indMax = TMath::LocMax(signalSize, &adc[0]);
265  double sigMin = 0.0;
266  double sigMax = TMath::MaxElement(signalSize, &adc[0]);
267  if (geom->SignalType(rdvec[rd]->Channel()) == geo::kInduction && sigMax >= pulseHeight) {
268  int indMin = TMath::LocMin(signalSize, &adc[0]);
269  sigMin = TMath::MinElement(signalSize, &adc[0]);
270  tmin = std::max(indMax - window, 0);
271  tmax = std::min(indMin + window, (int)signalSize - 1);
272  MF_LOG_DEBUG("CalWireAna") << "Induction channel, indMin,tmin,tmax " << rd << " " << indMin
273  << " " << tmin << " " << tmax;
274  }
275  else if (sigMax >= pulseHeight) {
276  tmin = std::max(indMax - window, 0);
277  tmax = std::min(indMax + window, (int)signalSize - 1);
278  MF_LOG_DEBUG("CalWireAna")
279  << "Collection channel, tmin,tmax " << rd << " " << tmin << " " << tmax;
280  }
281 
282  fMin->Fill(sigMin);
283  fMax->Fill(sigMax);
284  fWindow->Fill(indMax, tmax - tmin);
285 
286  std::vector<double> winDiffs;
287  int cnt = 0;
288  // for(unsigned int t = tmin; t < tmax; ++t)
289  static unsigned int tRawLead = 0;
290  for (unsigned int t = 1; t < signalSize; ++t) {
291  fDiffsW->Fill(signal[t] - signal[t - 1]);
292  fWireSig->Fill(rd, signal[t]);
293 
294  if (t >= tmin && t <= tmax && tmax >= pulseHeight && (t + tRawLead) < signalSize) {
295  cnt++;
296  winDiffs.push_back((adc[t + tRawLead] - signal[t]) / adc[t + tRawLead]);
297  fDiffsRW->Fill(adc[t + tRawLead] - signal[t]);
298  fDiffsRWvsR->Fill(rd, adc[t + tRawLead] - signal[t]);
299  if (sigMax >= pulseHeight) {
300  fDiffsRWgph->Fill(adc[t + tRawLead] - signal[t]);
301  fDiffsRWvsRgph->Fill(rd, adc[t + tRawLead] - signal[t]);
302  }
303  }
304  }
305 
306  MF_LOG_DEBUG("CalWireAna") << "on channel " << rdvec[rd]->Channel();
307  // TMath::Mean with iterators doesn't work. EC,23-Sep-2010.
308  double tmp = TMath::Mean(winDiffs.size(), &winDiffs[0]);
309  double tmp2 = TMath::RMS(winDiffs.size(), &winDiffs[0]);
310  for (int i = 0; i < fft->FFTSize(); i++) {
311  fIR->Fill(i, ir[i]);
312  fIW->Fill(i, iw[i]);
313  fCR->Fill(i, cr[i]);
314  fCW->Fill(i, cw[i]);
315  }
316  fRD_WireMeanDiff2D->Fill(rd, tmp);
317  fRD_WireRMSDiff2D->Fill(rd, tmp2);
318 
319  } //end loop over rawDigits
320 
321  return;
322  } //end analyze method
323 
325 
326 } //end namespace
TRandom r
Definition: spectrum.C:23
TH2F * fRD_WireMeanDiff2D
histogram of difference between original tdc value and compressesed value vs original value ...
void analyze(const art::Event &evt)
read/write access to event
STL namespace.
Definition of basic raw digits.
Float_t tmp
Definition: plot.C:35
void DoFFT(std::vector< T > &input, std::vector< TComplex > &output)
Definition: LArFFT.h:95
EDAnalyzer(fhicl::ParameterSet const &pset)
Definition: EDAnalyzer.cc:6
creation of calibrated signals on wires
TH1F * fDiffsR
histogram of Raw tdc to tdc differences
int FFTSize() const
Definition: LArFFT.h:66
TH2F * fRD_WireRMSDiff2D
histogram of difference between original tdc value and compressesed value vs original value ...
#define DEFINE_ART_MODULE(klass)
Definition: ModuleMacros.h:65
void push_back(Ptr< U > const &p)
Definition: PtrVector.h:435
Signal from induction planes.
Definition: geo_types.h:151
size_type size() const
Definition: PtrVector.h:302
std::string fCalWireModuleLabel
name of module that produced the wires
CalWireAna(fhicl::ParameterSet const &pset)
SigType_t SignalType(PlaneID const &pid) const
Returns the type of signal on the channels of specified TPC plane.
decltype(auto) get(T &&obj)
ADL-aware version of std::to_string.
Definition: StdUtils.h:120
bool getByLabel(std::string const &label, std::string const &instance, Handle< PROD > &result) const
void AlignedSum(std::vector< T > &input, std::vector< T > &output, bool add=true)
Definition: LArFFT.h:241
std::string fDetSimModuleLabel
#define MF_LOG_DEBUG(id)
TH1F * fDiffsW
histogram of Wire (post-deconvoution) tdc to tdc differences
Declaration of basic channel signal object.
TCEvent evt
Definition: DataStructs.cxx:8
Double_t sum
Definition: plot.C:31
Float_t w
Definition: plot.C:20
Base class for creation of raw signals on wires.
Definition: fwd.h:26
art framework interface to geometry description
Signal from collection planes.
Definition: geo_types.h:152