1 |
#include <iostream>
|
2 |
#include <vector>
|
3 |
#include <sys/stat.h>
|
4 |
#include <fstream>
|
5 |
#include <pthread.h>
|
6 |
|
7 |
#include <TCut.h>
|
8 |
#include <TROOT.h>
|
9 |
#include <TCanvas.h>
|
10 |
#include <TMath.h>
|
11 |
#include <TColor.h>
|
12 |
#include <TPaveText.h>
|
13 |
#include <TRandom.h>
|
14 |
#include <TH1.h>
|
15 |
#include <TH2.h>
|
16 |
#include <TF1.h>
|
17 |
#include <TSQLResult.h>
|
18 |
#include <TProfile.h>
|
19 |
|
20 |
//#include "TTbar_stuff.C"
|
21 |
using namespace std;
|
22 |
|
23 |
using namespace PlottingSetup;
|
24 |
|
25 |
void susy_scan_axis_labeling(TH2F *histo) {
|
26 |
histo->GetXaxis()->SetTitle("#Chi_{2}^{0}-LSP");
|
27 |
histo->GetXaxis()->CenterTitle();
|
28 |
histo->GetYaxis()->SetTitle("m_{#tilde{q}}");
|
29 |
histo->GetYaxis()->CenterTitle();
|
30 |
}
|
31 |
|
32 |
bool isThreadActive=false;
|
33 |
|
34 |
struct limit_args {
|
35 |
float mceff;
|
36 |
float toterr;
|
37 |
int ibin;
|
38 |
string mcjzb;
|
39 |
vector<float> sigmas;
|
40 |
};
|
41 |
|
42 |
void* compute_one_upper_limit_wrapper(void* data) {
|
43 |
isThreadActive=true;
|
44 |
limit_args* args = (limit_args*) data;
|
45 |
std::cout << "Thread to compute limits has been started" << std::endl;
|
46 |
args->sigmas=compute_one_upper_limit(args->mceff,args->toterr,args->ibin,args->mcjzb);
|
47 |
std::cout << "Thread to compute limits has finished" << std::endl;
|
48 |
isThreadActive=false;
|
49 |
return NULL; // oder in C++: return 0;// Damit kann man Werte zurückgeben
|
50 |
}
|
51 |
|
52 |
void do_limit_wrapper(float mceff,float toterr,int ibin,string mcjzb,vector<float> &sigmas) {
|
53 |
pthread_t limitthread;
|
54 |
limit_args limargs={mceff,toterr,ibin,mcjzb,sigmas};
|
55 |
pthread_create( &limitthread, NULL, compute_one_upper_limit_wrapper, (void*) &limargs);
|
56 |
int counter=0;
|
57 |
sleep(1); //waiting a second for the process to become active
|
58 |
while(counter<limitpatience*60 && isThreadActive) {
|
59 |
std::cout << "Limits are being calculated; Checking round " << counter << " ( corresponds to " << seconds_to_time(counter) << " ) , patience will end in " << seconds_to_time(60*60*limitpatience-counter) << std::endl;
|
60 |
counter++;
|
61 |
sleep(1);
|
62 |
}
|
63 |
|
64 |
if(!isThreadActive) {
|
65 |
cout << "Thread finished sucessfully" << endl;
|
66 |
pthread_join( limitthread, NULL );
|
67 |
std::cout<< __FUNCTION__ << " : going to save sigmas " << std::endl;
|
68 |
sigmas=limargs.sigmas;
|
69 |
} else {
|
70 |
pthread_cancel(limitthread);
|
71 |
std::cout << "DID NOT TERMINATE IN TIME - ABORTED!" << std::endl;
|
72 |
sigmas.push_back(-1);sigmas.push_back(-1);sigmas.push_back(-1);
|
73 |
}
|
74 |
}
|
75 |
|
76 |
void prepare_scan_axis(TH2 *variablemap,bool ismSUGRA) {
|
77 |
variablemap->GetXaxis()->SetTitle("m_{glu}");
|
78 |
variablemap->GetYaxis()->SetTitle("m_{LSP}");
|
79 |
|
80 |
if(ismSUGRA) {
|
81 |
variablemap->GetXaxis()->SetTitle("m_{0}");
|
82 |
variablemap->GetYaxis()->SetTitle("m_{1/2}");
|
83 |
}
|
84 |
|
85 |
variablemap->GetXaxis()->CenterTitle();
|
86 |
variablemap->GetYaxis()->CenterTitle();
|
87 |
}
|
88 |
|
89 |
void scan_SUSY_parameter_space(string mcjzb,string datajzb,vector<float> jzb_cut,bool requireZ, float peakerror, int ibin,float njobs=-1, float jobnumber=-1, bool systematicsonly=false,bool efficiencyonly=false) {
|
90 |
bool runninglocally=true;
|
91 |
if(njobs>-1&&jobnumber>-1) {
|
92 |
runninglocally=false;
|
93 |
dout << "Running on the GRID (this is job " << jobnumber << "/" << njobs << ") for a jzb cut at " << jzb_cut[ibin] << endl;
|
94 |
} else {
|
95 |
dout << "Running locally " << endl;
|
96 |
dout << "This will take a really, really long time - if you want to see the results THIS week try running the LimitWorkerScript on the grid (DistributedModelCalculation/Limits/)" << endl;
|
97 |
}
|
98 |
|
99 |
cout << "FILE USED: " << (scansample.collection)[0].filename << endl;
|
100 |
jzbSel=jzb_cut[ibin];
|
101 |
geqleq="geq";
|
102 |
automatized=true;
|
103 |
mcjzbexpression=mcjzb;
|
104 |
|
105 |
string massgluname="MassGlu";
|
106 |
string massLSPname="MassLSP";
|
107 |
|
108 |
// up to here, everything is set up for SMS; now we need to switch stuff around if we're dealing with an mSUGRA scan!
|
109 |
bool ismSUGRA=false;
|
110 |
if(Contains((scansample.collection)[0].filename,"mSUGRA")) ismSUGRA=true;
|
111 |
if(ismSUGRA) {
|
112 |
massgluname="M0"; // this is the "x axis" in the limit plot (like the gluino in the SMS case)
|
113 |
massLSPname="M12"; // this is the "y axis" in the limit plot (like the LSP in the SMS case)
|
114 |
mglustart=m0start;
|
115 |
mgluend=m0end;
|
116 |
mglustep=m0step;
|
117 |
mLSPstart=m12start;
|
118 |
mLSPend=m12end;
|
119 |
mLSPstep=m12step;
|
120 |
}
|
121 |
|
122 |
Int_t MyPalette[100];
|
123 |
Double_t r[] = {0., 0.0, 1.0, 1.0, 1.0};
|
124 |
Double_t g[] = {0., 0.0, 0.0, 1.0, 1.0};
|
125 |
Double_t b[] = {0., 1.0, 0.0, 0.0, 1.0};
|
126 |
Double_t stop[] = {0., .25, .50, .75, 1.0};
|
127 |
Int_t FI = TColor::CreateGradientColorTable(5, stop, r, g, b, 110);
|
128 |
for (int i=0;i<100;i++) MyPalette[i] = FI+i;
|
129 |
|
130 |
gStyle->SetPalette(100, MyPalette);
|
131 |
|
132 |
TH2F *limitmap = new TH2F(("limitmap"+any2string(jzbSel)).c_str(), "",(mgluend-mglustart)/mglustep+1,mglustart-0.5*mglustep,mgluend+0.5*mglustep,(mLSPend-mLSPstart)/mLSPstep+1,mLSPstart-0.5*mLSPstep,mLSPend+0.5*mLSPstep);
|
133 |
TH2F *exclmap = new TH2F(("exclusionmap"+any2string(jzbSel)).c_str(), "",(mgluend-mglustart)/mglustep+1,mglustart-0.5*mglustep,mgluend+0.5*mglustep,(mLSPend-mLSPstart)/mLSPstep+1,mLSPstart-0.5*mLSPstep,mLSPend+0.5*mLSPstep);
|
134 |
TH2F *sysjesmap = new TH2F(("sysjes"+any2string(jzbSel)).c_str(), "",(mgluend-mglustart)/mglustep+1,mglustart-0.5*mglustep,mgluend+0.5*mglustep,(mLSPend-mLSPstart)/mLSPstep+1,mLSPstart-0.5*mLSPstep,mLSPend+0.5*mLSPstep);
|
135 |
TH2F *sysjsumap = new TH2F(("sysjsu"+any2string(jzbSel)).c_str(), "",(mgluend-mglustart)/mglustep+1,mglustart-0.5*mglustep,mgluend+0.5*mglustep,(mLSPend-mLSPstart)/mLSPstep+1,mLSPstart-0.5*mLSPstep,mLSPend+0.5*mLSPstep);
|
136 |
TH2F *sysresmap = new TH2F(("sysresmap"+any2string(jzbSel)).c_str(),"",(mgluend-mglustart)/mglustep+1,mglustart-0.5*mglustep,mgluend+0.5*mglustep,(mLSPend-mLSPstart)/mLSPstep+1,mLSPstart-0.5*mLSPstep,mLSPend+0.5*mLSPstep);
|
137 |
TH2F *efficiencymap = new TH2F("efficiencymap","",(mgluend-mglustart)/mglustep+1,mglustart-0.5*mglustep,mgluend+0.5*mglustep,(mLSPend-mLSPstart)/mLSPstep+1,mLSPstart-0.5*mLSPstep,mLSPend+0.5*mLSPstep);
|
138 |
TH2F *Neventsmap = new TH2F("Neventsmap","", (mgluend-mglustart)/mglustep+1,mglustart-0.5*mglustep,mgluend+0.5*mglustep,(mLSPend-mLSPstart)/mLSPstep+1,mLSPstart-0.5*mLSPstep,mLSPend+0.5*mLSPstep);
|
139 |
float rightmargin=gStyle->GetPadRightMargin();
|
140 |
gStyle->SetPadRightMargin(0.15);
|
141 |
|
142 |
TCanvas *limcanvas = new TCanvas("limcanvas","Limit canvas");
|
143 |
|
144 |
int Npoints=0;
|
145 |
for(int mglu=mglustart;mglu<=mgluend;mglu+=mglustep) {
|
146 |
for (int mlsp=mLSPstart;mlsp<=mLSPend&&mlsp<=mglu;mlsp+=mLSPstep) Npoints++;
|
147 |
}
|
148 |
|
149 |
int ipoint=-1;
|
150 |
for(int mglu=mglustart;mglu<=mgluend;mglu+=mglustep) {
|
151 |
for (int mlsp=mLSPstart;mlsp<=mLSPend&&mlsp<=mglu;mlsp+=mLSPstep)
|
152 |
{
|
153 |
ipoint++;
|
154 |
if(!runninglocally&&!do_this_point(ipoint,Npoints,jobnumber,njobs)) continue;
|
155 |
float result=-987,resulterr=-987;
|
156 |
stringstream addcut;
|
157 |
addcut << "(TMath::Abs("<<massgluname<<"-"<<mglu<<")<5)&&(TMath::Abs("<<massLSPname<<"-"<<mlsp<<")<5)";
|
158 |
(scansample.collection)[0].events->Draw("eventNum",addcut.str().c_str(),"goff");
|
159 |
float nevents = (scansample.collection)[0].events->GetSelectedRows();
|
160 |
vector<vector<float> > systematics;
|
161 |
if(nevents==0) {
|
162 |
dout << "This configuration ("<<massgluname<<"="<<mglu<<" , "<<massLSPname<<"="<<mlsp << ") contains no events and will be skipped."<< endl;
|
163 |
continue;
|
164 |
} else {
|
165 |
dout << "OK! This configuration ("<<massgluname<<"="<<mglu<<" , "<<massLSPname<<"="<<mlsp << ") contains " << nevents << " and will therefore not be skipped."<< endl;
|
166 |
}
|
167 |
if(nevents!=0&&efficiencyonly) {
|
168 |
MCefficiency((scansample.collection)[0].events,result,resulterr,mcjzb,requireZ,nevents,addcut.str());
|
169 |
efficiencymap->Fill(mglu,mlsp,result);
|
170 |
}
|
171 |
Neventsmap->Fill(mglu,mlsp,nevents);
|
172 |
if(efficiencyonly) continue;
|
173 |
|
174 |
do_systematics_for_one_file((scansample.collection)[0].events,nevents,"SUSY SCAN", systematics,mcjzb,datajzb,peakerror,requireZ, addcut.str(),ismSUGRA);
|
175 |
float JZBcutat = systematics[0][0];
|
176 |
float mceff = systematics[0][1];
|
177 |
float mcefferr = systematics[0][2];//MC stat error
|
178 |
float toterr = systematics[0][4];
|
179 |
float sys_jes = systematics[0][5]; // Jet Energy Scale
|
180 |
float sys_jsu = systematics[0][6]; // JZB scale uncertainty
|
181 |
float sys_res = systematics[0][7]; // resolution
|
182 |
efficiencymap->Fill(mglu,mlsp,mceff);
|
183 |
efficiencymap->SetBinError(efficiencymap->FindBin(mglu,mlsp),mcefferr);//blublu
|
184 |
|
185 |
if(mceff!=mceff||toterr!=toterr||mceff<0) {
|
186 |
dout << "Limits can't be calculated for this configuration (mglu="<<mglu<<" , mlsp="<<mlsp << ") as either the efficiency or its error are not positive numbers! (mceff="<<mceff<<" and toterr="<<toterr<<")"<< endl;
|
187 |
continue;
|
188 |
} else {
|
189 |
if(!systematicsonly&&!efficiencyonly) {
|
190 |
dout << "Calculating limit now for "<<massgluname<<"="<<mglu<<" , "<<massLSPname<<"="<<mlsp <<endl;
|
191 |
vector<float> sigmas;
|
192 |
do_limit_wrapper(mceff,toterr,ibin,mcjzb,sigmas);
|
193 |
cout << "back in " << __FUNCTION__ << endl;
|
194 |
if(sigmas[0]>-0.5) { // negative sigmas are the error signature of do_limit_wrapper, so we want to exclude them.
|
195 |
limitmap->Fill(mglu,mlsp,sigmas[0]);
|
196 |
sysjesmap->Fill(mglu,mlsp,sys_jes);
|
197 |
sysjsumap->Fill(mglu,mlsp,sys_jsu);
|
198 |
sysresmap->Fill(mglu,mlsp,sys_res);
|
199 |
efficiencymap->Fill(mglu,mlsp,result);
|
200 |
dout << "A limit has been added at " << sigmas[0] << " for m_{glu}="<<mglu << " and m_{lsp}="<<mlsp<<endl;
|
201 |
} //end of if sigma is positive
|
202 |
//end of not systematics only condition
|
203 |
}
|
204 |
if(systematicsonly) {
|
205 |
sysjesmap->Fill(mglu,mlsp,sys_jes);
|
206 |
sysjsumap->Fill(mglu,mlsp,sys_jsu);
|
207 |
sysresmap->Fill(mglu,mlsp,sys_res);
|
208 |
efficiencymap->Fill(mglu,mlsp,result);
|
209 |
}
|
210 |
}//efficiency is valid
|
211 |
}
|
212 |
}
|
213 |
|
214 |
prepare_scan_axis(limitmap,ismSUGRA);
|
215 |
prepare_scan_axis(sysjesmap,ismSUGRA);
|
216 |
prepare_scan_axis(sysjsumap,ismSUGRA);
|
217 |
prepare_scan_axis(sysresmap,ismSUGRA);
|
218 |
|
219 |
if(!systematicsonly&&!efficiencyonly) {
|
220 |
limcanvas->cd();
|
221 |
limitmap->Draw("COLZ");
|
222 |
string titletobewritten="Limits in LSP-Glu plane";
|
223 |
if(ismSUGRA) titletobewritten="Limits in m_{1/2}-m_{0} plane";
|
224 |
TText *title = write_title(titletobewritten);
|
225 |
title->Draw();
|
226 |
if(runninglocally) {
|
227 |
CompleteSave(limcanvas,"SUSYScan/Limits_JZB_geq"+any2string(jzb_cut[ibin]));
|
228 |
} else {
|
229 |
TFile *outputfile;
|
230 |
if(systematicsonly) outputfile=new TFile(("output/DistributedSystematics_job"+string(any2string(jobnumber))+"_of_"+string(any2string(njobs))+".root").c_str(),"UPDATE");//needs to be "UPDATE" as we can get to this point for different JZB cuts and don't want to erase the previous data :-)
|
231 |
else outputfile=new TFile(("output/DistributedLimits_job"+string(any2string(jobnumber))+"_of_"+string(any2string(njobs))+".root").c_str(),"UPDATE");//needs to be "UPDATE" as we can get to this point for
|
232 |
limitmap->Write();
|
233 |
sysjesmap->Write();
|
234 |
sysjsumap->Write();
|
235 |
efficiencymap->Write();
|
236 |
Neventsmap->Write();
|
237 |
outputfile->Close();
|
238 |
}
|
239 |
}
|
240 |
if(systematicsonly) { // systematics only :
|
241 |
limcanvas->cd();
|
242 |
sysjesmap->Draw("COLZ");
|
243 |
string titletobewritten="Jet Energy scale in LSP-Glu plane";
|
244 |
if(ismSUGRA) titletobewritten="Limits in m_{1/2}-m_{0} plane";
|
245 |
TText *title = write_title(titletobewritten);
|
246 |
title->Draw();
|
247 |
if(runninglocally) {
|
248 |
CompleteSave(limcanvas,"SUSYScan/JES_geq"+any2string(jzb_cut[ibin]));
|
249 |
}
|
250 |
sysjsumap->Draw("COLZ");
|
251 |
titletobewritten="JZB Scale Uncertainty in LSP-Glu plane";
|
252 |
if(ismSUGRA) titletobewritten="JZB Scale Uncertainty in m_{1/2}-m_{0} plane";
|
253 |
TText *title2 = write_title(titletobewritten);
|
254 |
title2->Draw();
|
255 |
if(runninglocally) {
|
256 |
CompleteSave(limcanvas,"SUSYScan/JSU_geq"+any2string(jzb_cut[ibin]));
|
257 |
}
|
258 |
sysresmap->Draw("COLZ");
|
259 |
titletobewritten="Resolution in LSP-Glu plane";
|
260 |
if(ismSUGRA) titletobewritten="Resolution in m_{1/2}-m_{0} plane";
|
261 |
TText *title3 = write_title(titletobewritten);
|
262 |
title3->Draw();
|
263 |
if(runninglocally) {
|
264 |
CompleteSave(limcanvas,"SUSYScan/Resolution_geq"+any2string(jzb_cut[ibin]));
|
265 |
}
|
266 |
|
267 |
if(!runninglocally) {
|
268 |
TFile *outputfile=new TFile(("output/DistributedSystematics_job"+string(any2string(jobnumber))+"_of_"+string(any2string(njobs))+".root").c_str(),"UPDATE");
|
269 |
sysjesmap->Write();
|
270 |
sysjsumap->Write();
|
271 |
sysresmap->Write();
|
272 |
efficiencymap->Write();
|
273 |
Neventsmap->Write();
|
274 |
outputfile->Close();
|
275 |
}
|
276 |
}//end of systematics only
|
277 |
if(efficiencyonly) {
|
278 |
limcanvas->cd();
|
279 |
efficiencymap->Draw("COLZ");
|
280 |
string titletobewritten="Efficiencies in LSP-Glu plane";
|
281 |
if(ismSUGRA) titletobewritten="Efficiencies in m_{1/2}-m_{0} plane";
|
282 |
TText *title = write_title(titletobewritten);
|
283 |
title->Draw();
|
284 |
if(runninglocally) {
|
285 |
CompleteSave(limcanvas,"SUSYScan/Efficiency_geq"+any2string(jzb_cut[ibin]));
|
286 |
}
|
287 |
limcanvas->cd();
|
288 |
sysjesmap->Draw("COLZ");
|
289 |
titletobewritten="N(events) in LSP-Glu plane";
|
290 |
if(ismSUGRA) titletobewritten="N(events) in m_{1/2}-m_{0} plane";
|
291 |
TText *title2 = write_title(titletobewritten);
|
292 |
title2->Draw();
|
293 |
if(runninglocally) {
|
294 |
CompleteSave(limcanvas,"SUSYScan/Nevents_geq"+any2string(jzb_cut[ibin]));
|
295 |
}
|
296 |
if(!runninglocally) {
|
297 |
TFile *outputfile=new TFile(("output/DistributedSystematics_job"+string(any2string(jobnumber))+"_of_"+string(any2string(njobs))+".root").c_str(),"UPDATE");
|
298 |
Neventsmap->Write();
|
299 |
efficiencymap->Write();
|
300 |
outputfile->Close();
|
301 |
}
|
302 |
}//end of efficiencies only
|
303 |
delete limcanvas;
|
304 |
}
|
305 |
|
306 |
void scan_SUSY_parameter_space(string mcjzb,string datajzb,vector<float> jzb_cut,bool requireZ, float peakerror, float njobs=-1, float jobnumber=-1, bool systonly=false, bool effonly=false) {
|
307 |
dout << "Starting the SUSY scan now with all " << jzb_cut.size() << " bin(s)" << endl;
|
308 |
for(int ibin=0;ibin<jzb_cut.size();ibin++) {
|
309 |
scan_SUSY_parameter_space(mcjzb,datajzb,jzb_cut,requireZ, peakerror, ibin, njobs, jobnumber,systonly,effonly);
|
310 |
}
|
311 |
}
|