ViewVC Help
View File | Revision Log | Show Annotations | Root Listing
root/cvsroot/UserCode/OSUT3Analysis/AnaTools/scripts/mergeHists
(Generate patch)

Comparing UserCode/OSUT3Analysis/AnaTools/scripts/mergeHists (file contents):
Revision 1.1 by ahart, Thu Jun 14 17:42:30 2012 UTC vs.
Revision 1.14 by ahart, Fri Jan 4 07:35:41 2013 UTC

# Line 2 | Line 2
2  
3   use strict;
4   use Getopt::Long;
5 + use POSIX;
6 +
7 + sub processArgs;
8 + sub printHelp;
9 + sub getRunList;
10 + sub countEvents;
11  
12   my %opt;
13   Getopt::Long::Configure ("bundling");
14 < GetOptions (\%opt, "prefix|p=s", "help|h");
14 > GetOptions (\%opt, "cutflow|c=s", "luminosity|l=s", "prefix|p=s", "weight|w=s", "xsection|x=s", "help|h");
15  
16   printHelp () if $opt{"help"} || !$opt{"prefix"};
17   my $files = processArgs (\@ARGV);
18 < my @rootFiles;
19 < my $error = 0;
18 > my %rootFiles;
19 > my %weights;
20 > my @weights;
21 > my $nGoodJobs = 0;
22 > my $nBadJobs = 0;
23 > my $counting = 0;
24 > my %exitCodes;
25 > my %signals;
26 > my %crossSections;
27 > my %dirs;
28 > my $integratedLuminosity = 10000;
29 > $integratedLuminosity = $opt{"luminosity"} if $opt{"luminosity"};
30 > my $cutFlow = "cutFlow";
31 > $cutFlow = $opt{"cutflow"} if $opt{"cutflow"};
32   foreach my $file (@$files)
33    {
34      next if $file eq ".";
35      next if $file eq "..";
36 <    if ($file =~ m/\.root$/)
36 >    my $dir = $file;
37 >    $dir =~ s/^(.*)\/[^\/]*$/$1/;
38 >    if ($file =~ m/^.*\/condor_[^_]*\.log$/)
39        {
40 <        push (@rootFiles, $file);
41 <        next;
40 >        my $jobNumber = $file;
41 >        $jobNumber =~ s/^.*\/condor_([^_]*)\.log$/$1/;
42 >        open (FILE, "<$file");
43 >        my @fileContents = <FILE>;
44 >        close (FILE);
45 >        my $fileContents = join ("", @fileContents);
46 >        $fileContents =~ s/\n/ /g;
47 >        if ($fileContents =~ m/return value/)
48 >          {
49 >            $fileContents =~ s/.*\(return value ([^)]*)\).*/$1/g;
50 >            $nGoodJobs++;
51 >            print "WARNING: Nonzero exit code for job $jobNumber. (return value $fileContents)\n" if $fileContents != 0;
52 >            $exitCodes{$dir}{$jobNumber} = $fileContents;
53 >            $counting = 1;
54 >          }
55 >        if ($fileContents =~ m/signal/)
56 >          {
57 >            $fileContents =~ s/.*\(signal ([^)]*)\).*/$1/g;
58 >            $nBadJobs++;
59 >            print "WARNING: Skipping job $jobNumber. (signal $fileContents)\n";
60 >            $signals{$dir}{$jobNumber} = $fileContents;
61 >            $counting = 1;
62 >          }
63        }
64 <    open (FILE, "<$file");
24 <    my @fileContents = <FILE>;
25 <    close (FILE);
26 <    my $fileContents = join ("", @fileContents);
27 <    next if !($fileContents =~ m/\(return value [^)]*\)/);
28 <    $fileContents =~ s/\n/ /g;
29 <    $fileContents =~ s/.*\(return value ([^)]*)\).*/$1/g;
30 <    if ($fileContents != 0)
64 >    if ($file =~ m/^.*\/crossSectionInPicobarn\.txt$/)
65        {
66 <        printf "Error: return value of %2d in \"$file\"!\n", $fileContents;
67 <        $error = 1;
66 >        open (CROSS_SECTION, "<$file");
67 >        my $crossSection = <CROSS_SECTION>;
68 >        close (CROSS_SECTION);
69 >        $crossSections{$dir} = $crossSection;
70        }
71    }
72 < exit if $error;
73 < my $rootFiles = join (" ", @rootFiles);
74 < system ("mergeTFileServiceHistograms -i $rootFiles -o $opt{'prefix'}.root");
75 < system ("cutFlowTable $opt{'prefix'}.root cutFlow >& $opt{'prefix'}.tex");
72 > foreach my $file (@$files)
73 >  {
74 >    next if $file eq ".";
75 >    next if $file eq "..";
76 >    my $dir = $file;
77 >    $dir =~ s/^(.*)\/[^\/]*$/$1/;
78 >    my $badJob = 0;
79 >    if ($file =~ m/^.*_[^_]*\.root$/)
80 >      {
81 >        my $jobNumber = $file;
82 >        $jobNumber =~ s/^.*_([^_]*)\.root$/$1/;
83 >        $badJob = defined $signals{$dir} && defined $signals{$dir}{$jobNumber};
84 >      }
85 >    next if $badJob;
86 >    if ($file =~ m/^.*\.root$/)
87 >      {
88 >        foreach my $arg (@ARGV)
89 >          {
90 >            $dirs{$arg} = $dir;
91 >            if (substr ($file, 0, length ($arg)) eq $arg)
92 >              {
93 >                push (@{$rootFiles{$arg}}, $file);
94 >                push (@weights, $opt{"weight"}) if $opt{"weight"};
95 >                push (@weights, $opt{"xsection"} * $integratedLuminosity) if !$opt{"weight"} && $opt{"xsection"};
96 >                push (@weights, $crossSections{$dir} * $integratedLuminosity) if !$opt{"weight"} && !$opt{"xsection"} && defined $crossSections{$dir};
97 >                push (@weights, 1.0) if !$opt{"weight"} && !$opt{"xsection"} && !(defined $crossSections{$dir});
98 >                $weights{$arg} = $weights[-1];
99 >              }
100 >          }
101 >      }
102 >  }
103 > if (!%rootFiles)
104 >  {
105 >    print "Found no ROOT files to merge!\n";
106 >    exit;
107 >  }
108 > my %nTotalEvents;
109 > my $nTotalEvents = 0;
110 > my @mergedFiles;
111 > my @mergedWeights;
112 > foreach my $arg (@ARGV)
113 >  {
114 >    my $rootFiles = join (" ", @{$rootFiles{$arg}});
115 >    my $tmpName = $arg . "_" . "$opt{'prefix'}.root";
116 >    $tmpName =~ s/\//_/g;
117 >    system ("mergeTFileServiceHistograms -i $rootFiles -o $tmpName");
118 >    my $count = countEvents ($tmpName, $cutFlow);
119 >    system ("cutFlowLimits $tmpName");
120 >    $nTotalEvents{$arg} = $count;
121 >    $nTotalEvents += $count;
122 >    $weights{$arg} /= $count if !$opt{"weight"} && $opt{"xsection"};
123 >    $weights{$arg} /= $count if !$opt{"weight"} && !$opt{"xsection"} && defined $crossSections{$dirs{$arg}};
124 >    push (@mergedFiles, "$tmpName");
125 >    push (@mergedWeights, $weights{$arg});
126 >  }
127 > my $mergedFiles = join (" ", @mergedFiles);
128 > my $mergedWeights = join (",", @mergedWeights);
129 > system ("mergeTFileServiceHistograms -i $mergedFiles -o $opt{'prefix'}.root -w $mergedWeights");
130 > foreach my $mergedFile (@mergedFiles)
131 >  {
132 >    unlink ("$mergedFile");
133 >  }
134 > print "Weights:\n";
135 > foreach my $arg (keys %weights)
136 >  {
137 >    my $shortArg = $arg;
138 >    $shortArg =~ s/^.*\/([^\/]*)$/$1/;
139 >    printf "  $shortArg: %.5g (%.5g pb)\n", $weights{$arg}, $weights{$arg} / $integratedLuminosity;
140 >  }
141 > my $goodEvents = countEvents ("$opt{'prefix'}.root", $cutFlow);
142 > print "$nGoodJobs jobs ran successfully over $nTotalEvents ($goodEvents weighted) events.\n" if $counting;
143 > print "$nBadJobs jobs failed to run.\n" if $counting;
144  
145   sub
146   processArgs
# Line 80 | Line 184 | printHelp
184    my $exeName = $0;
185    $exeName =~ s/^.*\/([^\/]*)$/$1/;
186  
187 <  print "Usage: $exeName [OPTIONS] -p PREFIX DIRECTORIES_AND_FILES\n";
188 <  print "Merges ROOT files containing histograms and produces a cutflow table in the\n";
189 <  print "form of a LaTeX document from the histogram named \"cutFlow\". If there are\n";
190 <  print "Condor logs in the specified directories, checks for nonzero return values.\n";
187 >  print "Usage: $exeName [OPTION]... -p PREFIX DIRECTORIES_AND_FILES\n";
188 >  print "Merges ROOT files containing histograms. If there are Condor logs in the\n";
189 >  print "specified directories, checks for nonzero return values. If the directories\n";
190 >  print "where created by \"osusub\", uses the cross section from the database to weight\n";
191 >  print "all histograms.\n";
192    print "\n";
193    print "Mandatory arguments to long options are mandatory for short options too.\n";
194 +  printf "%-29s%s\n", "  -c, --cutflow HISTOGRAM", "name of histogram to use for the cutflow (default:";
195 +  printf "%-29s%s\n", "                  ", "cutFlow)";
196    printf "%-29s%s\n", "  -h, --help", "print this help message";
197 <  printf "%-29s%s\n", "  -p, --prefix PREFIX", "output files are named PREFIX.root and PREFIX.tex";
197 >  printf "%-29s%s\n", "  -l, --luminosity", "integrated luminosity to which the histograms are";
198 >  printf "%-29s%s\n", "                  ", "weighted (default: 10000/pb)";
199 >  printf "%-29s%s\n", "  -p, --prefix PREFIX", "output is  named PREFIX.root";
200 >  printf "%-29s%s\n", "  -w, --weight WEIGHT", "scale the output by WEIGHT, overriding the";
201 >  printf "%-29s%s\n", "                     ", "automatic weighting using the cross section from";
202 >  printf "%-29s%s\n", "                     ", "the database";
203 >  printf "%-29s%s\n", "  -x, --xsection XSECTION", "use XSECTION to weight the histograms instead of";
204 >  printf "%-29s%s\n", "                     ", "the value in the database";
205  
206    exit;
207   }
208 +
209 + sub
210 + getRunList
211 + {
212 +  my $runListFile = shift;
213 +
214 +  open (RUN_LIST, "<$runListFile");
215 +  my @runList0 = <RUN_LIST>;
216 +  close (RUN_LIST);
217 +  my @runList;
218 +  foreach my $file (@runList0)
219 +    {
220 +      next if !($file =~ m/^.*file:.*\.root.*/);
221 +      $file =~ s/.*file:(.*)\.root.*/$1.root/;
222 +      push (@runList, $file);
223 +    }
224 +
225 +  return \@runList;
226 + }
227 +
228 + sub
229 + countEvents
230 + {
231 +  my $file = shift;
232 +  my $cutFlow = shift;
233 +
234 +  my $output = `getEventsFromCutFlow $file $cutFlow`;
235 +  if ($output =~ m/Did not find a histogram named/)
236 +    {
237 +      print $output;
238 +      return -1;
239 +    }
240 +  $output =~ s/^.*: (.*)$/$1/;
241 +  $output =~ s/\n//g;
242 +
243 +  return $output;
244 + }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines