ev2hist read whole data block, can save trace or hist

This commit is contained in:
Ryan Tang 2022-01-11 19:19:56 -05:00
parent dbb57d0025
commit 8eaffa22ff
5 changed files with 265 additions and 48 deletions

View File

@ -154,13 +154,14 @@ void Analyzer::Save2ev2(){
} }
out0[0] = count; out0[0] = count;
fwrite(out0, 1, 1, outEV2); if( count == 0 ) return;
fwrite(out0, 1, 1, outEV2);
for( int i = 0; i < count; i++){ for( int i = 0; i < count; i++){
if( TMath::IsNaN(eCal[i]) ) continue; if( TMath::IsNaN(eCal[i]) ) continue;
outa[0] = i; outa[0] = i;
fwrite(outa, 1, 1, outEV2); fwrite(outa, 1, 1, outEV2);
outb[0] = eCal[i]; outb[0] = TMath::Nint(eCal[i]);
fwrite(outb, 2, 1, outEV2); fwrite(outb, 2, 1, outEV2);
} }

View File

@ -5,15 +5,19 @@
#include <string.h> #include <string.h>
#include <vector> #include <vector>
#include "TSystem.h"
#include "TObject.h"
#include "TFile.h" #include "TFile.h"
#include "TTree.h" #include "TTree.h"
#include "TString.h" #include "TString.h"
#include "TMath.h" #include "TMath.h"
#include "TGraph.h"
#include "TLatex.h"
#include "TBenchmark.h" #include "TBenchmark.h"
#include "TH1F.h" #include "TH1F.h"
#include "TApplication.h" #include "TApplication.h"
#include "TCanvas.h" #include "TCanvas.h"
#include "TSystem.h" #include "TClonesArray.h"
#include "../mapping.h" #include "../mapping.h"
#include "../armory/AnalysisLibrary.h" #include "../armory/AnalysisLibrary.h"
@ -24,11 +28,9 @@
#define BOARD_START 2 #define BOARD_START 2
//#############################TODO //#############################TODO
// 1) Get ADC data // 1) multiple file
// 2) Change to GUI // 2) Change to GUI
// 3) calibration gamma // 4) eventBuilding
int rawEnergyThreshold = 100;
class measurment{ class measurment{
@ -49,7 +51,7 @@ public:
Int_t leading; Int_t leading;
Int_t gap; Int_t gap;
Int_t baseline; Int_t baseline;
Int_t ADC[8]; Int_t QDCsum[8];
UShort_t id; UShort_t id;
Int_t detID; Int_t detID;
@ -82,7 +84,7 @@ public:
leading = 0; leading = 0;
gap = 0; gap = 0;
baseline = 0; baseline = 0;
for( int i = 0; i < 8; i++) ADC[i] = -1; for( int i = 0; i < 8; i++) QDCsum[i] = -1;
for( int i = 0; i < 1024; i++) trace[i] = 0; for( int i = 0; i < 1024; i++) trace[i] = 0;
} }
@ -98,8 +100,8 @@ public:
printf(" gap : %d\n", gap); printf(" gap : %d\n", gap);
printf(" baseLine : %d\n", baseline); printf(" baseLine : %d\n", baseline);
} }
printf(" ADC : \n"); printf(" QDCsum : \n");
for( int i = 0; i < 8; i++) printf(" %-10d\n", ADC[i]); for( int i = 0; i < 8; i++) printf(" %-10d\n", QDCsum[i]);
} }
if( eventLength > headerLength ){ if( eventLength > headerLength ){
printf(" trace:\n"); printf(" trace:\n");
@ -114,10 +116,14 @@ public:
//############################################### //###############################################
int main(int argn, char **argv) { int main(int argn, char **argv) {
if (argn != 2 && argn != 3 ) { if (argn < 2 || argn > 6 ) {
printf("Usage :\n"); printf("Usage :\n");
printf("%s [evt File] [E corr]\n", argv[0]); printf("%s [evt File] [E corr] [raw E threshold] [Save Hist] [Save Root]\n", argv[0]);
printf(" [E corr] : correction file for gamma energy \n"); printf(" [E corr] : correction file for gamma energy \n");
printf(" [raw E threshold] : min raw E \n");
printf(" [save Hist] : 1/0 \n");
printf(" [save Root] : 1/0 \n");
return 1; return 1;
} }
@ -131,6 +137,16 @@ int main(int argn, char **argv) {
eCorr = LoadCorrectionParameters(corrFile); eCorr = LoadCorrectionParameters(corrFile);
} }
int rawEnergyThreshold = 100;
if( argn >= 4 ) rawEnergyThreshold = atoi(argv[3]);
bool isSaveHist = false; ///save gamma hist for calibration
if( argn >= 5 ) isSaveHist = atoi(argv[5]);
bool isSaveRoot = false; ///save data into root
if( argn >= 6 ) isSaveRoot = atoi(argv[6]);
long int inFilePos; long int inFilePos;
TBenchmark gClock; TBenchmark gClock;
gClock.Reset(); gClock.Reset();
@ -148,10 +164,23 @@ int main(int argn, char **argv) {
return -404; return -404;
} }
printf(" in file: \003[1;31m%s\033[m\n", inFileName.Data()); printf(" in file: \033[1;31m%s\033[m\n", inFileName.Data());
printf(" Gamma energy correction file : %s\n", corrFile == "" ? "Not provided." : corrFile.Data()); printf(" Gamma energy correction file : %s\n", corrFile == "" ? "Not provided." : corrFile.Data());
printf("--------------------------------\n"); printf("--------------------------------\n");
TFile * fFile = NULL;
TTree * tree = NULL;
if( isSaveRoot ){
fFile = new TFile("temp.root", "RECREATE");
tree = new TTree("tree", "tree");
tree->Branch("detID", &data.detID, "detID/s");
tree->Branch("e", &data.energy, "energy/s");
tree->Branch("e_t", &data.time, "timestamp/l");
tree->Branch("qdc", data.QDCsum, "QDC_sum[8]/I");
tree->Branch("trace_length", &data.trace_length, "trace_length/s");
tree->Branch("trace", data.trace, "trace[trace_length]/s");
}
//================ get file size //================ get file size
fseek(inFile, 0L, SEEK_END); fseek(inFile, 0L, SEEK_END);
@ -162,7 +191,7 @@ int main(int argn, char **argv) {
//================ Historgrams //================ Historgrams
TH1F * he[NCRYSTAL]; TH1F * he[NCRYSTAL];
for( int i = 0 ; i < NCRYSTAL; i++){ for( int i = 0 ; i < NCRYSTAL; i++){
he[i] = new TH1F(Form("he%02d", i), Form("e-%2d", i), 1000, 0, 2000); he[i] = new TH1F(Form("he%02d", i), Form("e-%2d", i), 2000, 0, 2000);
switch (i % 4){ switch (i % 4){
case 0 : he[i]->SetLineColor(2); break; case 0 : he[i]->SetLineColor(2); break;
case 1 : he[i]->SetLineColor(4); break; case 1 : he[i]->SetLineColor(4); break;
@ -171,11 +200,18 @@ int main(int argn, char **argv) {
} }
} }
TGraph * gTrace = new TGraph();
TLatex text;
text.SetNDC();
text.SetTextFont(82);
text.SetTextSize(0.04);
text.SetTextColor(2);
//================ Set Canvas //================ Set Canvas
TApplication * app = new TApplication ("app", &argn, argv); TApplication * app = new TApplication ("app", &argn, argv);
TCanvas * canvas = new TCanvas("fCanvas", "Online Spectrum", 1800, 2000);
TCanvas * canvas = new TCanvas("fCanvas", "Online Spectrum", 1800, 1400);
canvas->Divide(1, 9, 0); canvas->Divide(1, 9, 0);
canvas->SetCrosshair(1); canvas->SetCrosshair(1);
for( int i = 0; i < 9 ; i++){ for( int i = 0; i < 9 ; i++){
@ -183,6 +219,7 @@ int main(int argn, char **argv) {
canvas->cd(i+1)->SetRightMargin(0.002); canvas->cd(i+1)->SetRightMargin(0.002);
} }
///TCanvas * cTrace = new TCanvas("cTrace", "Trace", 100, 100, 1000, 500);
//=============== Read File //=============== Read File
@ -210,11 +247,10 @@ int main(int argn, char **argv) {
data.id = data.crate*MAX_BOARDS_PER_CRATE*MAX_CHANNELS_PER_BOARD + (data.slot-BOARD_START)*MAX_CHANNELS_PER_BOARD + data.ch; data.id = data.crate*MAX_BOARDS_PER_CRATE*MAX_CHANNELS_PER_BOARD + (data.slot-BOARD_START)*MAX_CHANNELS_PER_BOARD + data.ch;
data.detID = mapping[data.id]; data.detID = mapping[data.id];
///======== read ADC ///======== read QDCsum
if( data.headerLength >= 4 ){ if( data.headerLength >= 4 ){
unsigned int extraHeader[data.headerLength-4]; unsigned int extraHeader[data.headerLength-4];
fread(extraHeader, sizeof(extraHeader), 1, inFile); fread(extraHeader, sizeof(extraHeader), 1, inFile);
//if( measureID < 10 ) for(int i = 0; i < data.headerLength - 4; i++) printf(" %x\n", extraHeader[i]);
if( data.headerLength > 12){ if( data.headerLength > 12){
data.trailing = extraHeader[0]; data.trailing = extraHeader[0];
data.leading = extraHeader[1]; data.leading = extraHeader[1];
@ -225,7 +261,7 @@ int main(int argn, char **argv) {
for( int i = 0; i < 8; i++){ for( int i = 0; i < 8; i++){
int startID = 0; int startID = 0;
if( data.headerLength > 12) startID = 4; ///the 1st 4 words if( data.headerLength > 12) startID = 4; ///the 1st 4 words
data.ADC[i] = extraHeader[i+startID]; data.QDCsum[i] = extraHeader[i+startID];
} }
} }
///====== read trace ///====== read trace
@ -239,11 +275,11 @@ int main(int argn, char **argv) {
} }
} }
if( measureID < 10 ) { ///if( measureID < 10 ) {
printf("----------------------event Length: %u, fpos: %llu byte (%lld words)\n", data.eventLength, fpos, fpos/4); /// printf("----------------------event Length: %u, fpos: %llu byte (%lld words)\n", data.eventLength, fpos, fpos/4);
for(int i = 0; i < 4; i++) printf(" %x\n", header[i]); /// for(int i = 0; i < 4; i++) printf(" %x\n", header[i]);
data.Print(); /// data.Print();
} ///}
//=== jump to next measurement. obsolete, we read the whole block //=== jump to next measurement. obsolete, we read the whole block
///if( data.eventLength > 4 ) { ///if( data.eventLength > 4 ) {
@ -268,6 +304,20 @@ int main(int argn, char **argv) {
} }
//===== Trace
if( data.trace_length > 0 ) {
gTrace->Clear();
gTrace->Set(data.trace_length);
gTrace->SetTitle(Form("eventID : %llu, detID: %d", data.eventID, data.detID));
for( int i = 0; i < data.trace_length; i++){
gTrace->SetPoint(i, i, data.trace[i]);
}
}
if( isSaveRoot ){
fFile->cd();
tree->Fill();
}
//==== event stats, print status every 10000 events //==== event stats, print status every 10000 events
if ( measureID % 10000 == 0 ) { if ( measureID % 10000 == 0 ) {
@ -288,34 +338,69 @@ int main(int argn, char **argv) {
gClock.Stop("timer"); gClock.Stop("timer");
int time = TMath::Floor(gClock.GetRealTime("timer")*1000); // in millisec int time = TMath::Floor(gClock.GetRealTime("timer")*1000); // in millisec
gClock.Start("timer"); gClock.Start("timer");
if( time % 1000 == 0 ){ if( time % 1000 == 0 || time < 10){
for( int i = 0; i < NCRYSTAL; i++){
canvas->cd(i/4 +1); //==== for clover
//canvas->cd(i/4 +1)->SetLogy(); for( int i = 0; i < NCLOVER; i++){
if( i % 4 == 0 ) { double maxY = 0;
he[i]->Draw(); double y = 0;
}else{ for( int j = 0; j < 4; j++){
he[i]->Draw("same"); int mBin = he[4*i+j]->GetMaximumBin();
y = he[4*i+j]->GetBinContent(mBin);
if( maxY < y ) maxY = y;
}
for( int j = 0; j < 4; j++){
canvas->cd(i+1);
he[4*i+j]->GetYaxis()->SetRangeUser(0, maxY*1.2);
if ( j == 0) {
he[4*i]->Draw();
}else{
he[4*i+j]->Draw("same");
}
} }
} }
canvas->Modified(); canvas->Modified();
canvas->Update(); canvas->Update();
//==== for trace
///if( data.trace_length > 0 ){
/// cTrace->cd();
/// gTrace->Draw("AL");
///
/// for( int i = 0; i < 8; i++){
/// text.DrawLatex(0.2, 0.8-0.05*i, Form("%d", data.QDCsum[i]));
/// }
/// cTrace->Modified();
/// cTrace->Update();
///}
gSystem->ProcessEvents(); gSystem->ProcessEvents();
} }
}//---- end of file loop }//---- end of file loop
for( int i = 0; i < NCRYSTAL; i++){ for( int i = 0; i < NCLOVER; i++){
canvas->cd(i/4 +1); double maxY = 0;
//canvas->cd(i/4 +1)->SetLogy(); double y = 0;
if( i % 4 == 0 ) { for( int j = 0; j < 4; j++){
he[i]->Draw(); int mBin = he[4*i+j]->GetMaximumBin();
}else{ y = he[4*i+j]->GetBinContent(mBin);
he[i]->Draw("same"); if( maxY < y ) maxY = y;
}
for( int j = 0; j < 4; j++){
canvas->cd(i+1);
he[4*i+j]->GetYaxis()->SetRangeUser(0, maxY*1.2);
if ( j == 0) {
he[4*i]->Draw();
}else{
he[4*i+j]->Draw("same");
}
} }
} }
canvas->Modified(); canvas->Modified();
canvas->Update(); canvas->Update();
gSystem->ProcessEvents(); gSystem->ProcessEvents();
@ -328,8 +413,24 @@ int main(int argn, char **argv) {
fclose(inFile); fclose(inFile);
printf("\n============= reasched end of file\n"); printf("\n\n\n============= reached end of file\n");
printf("\nCrtl+C to end program.\n");
if( isSaveHist ) {
printf(" save gamma histograms : \033[1;3mhist.root\033[m\n");
TFile * fHist = new TFile("hist.root", "RECREATE");
for( int i = 0; i < NCRYSTAL; i++) he[i]->Write("", TObject::kOverwrite);
fHist->Close();
}
if( isSaveRoot){
printf(" save into Root : \033[1;3mtemp.root\033[m\n");
fFile->cd();
tree->Write();
fFile->Close();
}
printf("Crtl+C to end program.\n");
app->Run(); app->Run();

View File

@ -7,8 +7,9 @@ Other : 200 - 299
//==================== mapping //==================== mapping
#define NCRYSTAL 36 #define NCLOVER 9
#define NBGO 9 #define NCRYSTAL NCLOVER*4
#define NBGO NCLOVER
#define NOTHER 52 #define NOTHER 52
// 0 1 2 3 4 5 6 7 8 9 // 0 1 2 3 4 5 6 7 8 9

View File

@ -20,7 +20,7 @@ if [ $# -eq 0 ] || [ $1 == "-help" ]; then
echo "" echo ""
if [ $Method -eq 1 ]; then if [ $Method -eq 1 ]; then
ls -l --color $DATA_DIR/ ls -l --color $DATA_DIR/data/
fi fi
exit 1 exit 1
@ -101,7 +101,7 @@ if [ $Method -eq 1 ]; then
echo -e "$RED>>> `date` >>>>>>>>>>>>>>>>>>>>>>> Build Events $NC" echo -e "$RED>>> `date` >>>>>>>>>>>>>>>>>>>>>>> Build Events $NC"
if [ ${isBuildEvents} -eq 1 ]; then if [ ${isBuildEvents} -eq 1 ]; then
if [ -f ${rootFolder} ]; then # root exist if [ -f ${rootFile} ]; then # root exist
toDateTime=`stat -c "%Z" ${toFile} | sort -rn | head -1` toDateTime=`stat -c "%Z" ${toFile} | sort -rn | head -1`
rootDateTime=`stat -c "%Z" ${rootFile} | sort -rn | head -1` rootDateTime=`stat -c "%Z" ${rootFile} | sort -rn | head -1`
if [ ${toDateTime} -gt ${rootDateTime} ]; then if [ ${toDateTime} -gt ${rootDateTime} ]; then

114
readRawTrace.C Normal file
View File

@ -0,0 +1,114 @@
#include <TROOT.h>
#include <TChain.h>
#include <TFile.h>
#include <TSelector.h>
#include <TCanvas.h>
#include <TGraph.h>
#include <TClonesArray.h>
#include <TBenchmark.h>
#include <TMath.h>
#include <TF1.h>
#include <TLatex.h>
#include <TLine.h>
#include <iostream>
void readRawTrace(TString fileName, int minDetID = 0, int maxDetID = 1000){
/**///==============================================================
TFile * f1 = new TFile (fileName, "read");
TTree * tree = (TTree *) f1->Get("tree");
if( tree == NULL ) {
printf("===== Are you using gen_runXXX.root ? please use runXXX.root\n");
return;
}
int totnumEntry = tree->GetEntries();
printf( "========== total Entry : %d \n", totnumEntry);
TCanvas * cRead = new TCanvas("cRead", "Read Trace", 0, 1500, 800, 300);
cRead->Divide(1,1);
for( int i = 1; i <= 2 ; i++){
cRead->cd(i)->SetGrid();
}
cRead->SetGrid();
gStyle->SetOptFit(0);
/**///==============================================================
UShort_t detID;
UShort_t trace[1024];
UShort_t traceLength;
Int_t QDC[8];
tree->SetBranchAddress("detID", &detID);
tree->SetBranchAddress("trace", trace);
tree->SetBranchAddress("trace_length", &traceLength);
tree->SetBranchAddress("qdc", QDC);
TLatex text ;
text.SetNDC();
text.SetTextFont(62);
text.SetTextSize(0.06);
text.SetTextColor(2);
bool breakFlag = false;
bool lastEvFlag = false;
int oldEv = 0;
TGraph * g = new TGraph();
for( int ev = 0; ev < totnumEntry; ev++){
if( lastEvFlag ) {
ev = oldEv;
lastEvFlag = false;
}
tree->GetEntry(ev);
if( !(minDetID <= detID && detID <= maxDetID ) ) continue;
printf("-------------------------------- ev : %d \n", ev);
printf("id : %d, trace Length : %u ( enter = next , q = stop, w = last)\n", detID, traceLength);
g->Clear();
g->Set(traceLength);
for( int k = 0; k < traceLength ; k++) g->SetPoint(k, k, trace[k]);
g->SetTitle(Form("ev: %d, id : %d, trace Length : %u\n", ev, detID, traceLength));
cRead->cd(1);
cRead->Clear();
g->Draw("AL");
for( int i = 0; i < 8; i++) text.DrawLatex(0.2, 0.8-0.05*i, Form("%d", QDC[i]));
cRead->Update();
gSystem->ProcessEvents();
char s[80];
fgets(s, sizeof s, stdin);
if( s[0] == 113 ) { // 'q' = 113
breakFlag = true;
break;
}else if( s[0] == 119 ) { // 'w' = 119
if( ev > 0 ) {
lastEvFlag = true;
oldEv = ev -1;
}else{
printf(" the first event!!! \n");
}
}
if( breakFlag ) break;
}
//gROOT->ProcessLine(".q");
}