JPseudoExperiment.hh

Go to the documentation of this file.

#ifndef __JASTRONOMY__JPSEUDOEXPERIMENT__
#define __JASTRONOMY__JPSEUDOEXPERIMENT__
 
#include <istream>
#include <ostream>
#include <vector>
 
#include "TObject.h"
#include "TH1.h"
#include "TH2.h"
#include "TH3.h"
#include "TRandom3.h"
 
#include "JLang/JException.hh"
 
#include "JAstronomy/JExperiment.hh"
#include "JAstronomy/JAspera.hh"
#include "JAstronomy/JNuisance.hh"
 
 
/**
 * \file
 *
 * Pseudo experiment.
 * \author mdejong
 */
namespace JASTRONOMY {}
namespace JPP { using namespace JASTRONOMY; }
 
namespace JASTRONOMY {
 
 
  using JLANG::JValueOutOfRange;
 
  /**
   * Auxiliary interface for pseudo experiment.
   */
  struct JPseudoExperiment_t :
    public JExperiment
  {
    /**
     * Statistics of pseudo experiment.
     */
    struct stats_type {
 
      stats_type& operator+=(const stats_type& px)
      {
        this->ns += px.ns;
        this->nb += px.nb;
 
        return *this;
      }
 
      size_t ns  =  0;                              //!< number of generated signal events
      size_t nb  =  0;                              //!< number of generated background events
    };
 
 
    typedef JAspera::fit_type  fit_type;            //!< fit type
 
 
    /**
     * Result of combined pseudo experiment and fit.
     */
    struct result_type :
      public stats_type,
      public fit_type
    {};
 
 
    /**
     * Get fit method.
     *
     * \return            fit
     */
    virtual JAspera& getAspera() = 0;
 
 
    /*
     * Generate pseudo experiment and transfer S/N values to fit method.
     *
     * \param  out        output
     * \return            result
     */
    virtual stats_type run(JAspera& out) const = 0;
 
 
    /**
     * Generate pseudo experiment and fit signal strength.
     *
     * \return            result
     */
    inline result_type operator()()
    {
      JAspera& aspera = getAspera();
 
      // reset
 
      aspera.clear();
      aspera.setSignal(0.0);
 
      return { run(aspera), aspera() };
    }
 
 
    /**
     * Run pseudo experiments using given storage.
     *
     * \param  storage             storage
     */
    inline void operator()(std::vector<result_type>& storage)
    {
      for (auto& i : storage) {
        i = (*this)();
      }
    }
 
 
    /**
     * Run pseudo experiments using given storage.
     *
     * \param  pm                  pointer to data member of result
     * \param  storage             storage
     */
    template<class T, class JValue_t> 
    inline void operator()(JValue_t result_type::*pm, std::vector<T>& storage)
    {
      for (auto& i : storage) {
        i = (*this)().*pm;
      }
    }
 
 
    /**
     * Run pseudo experiments using given storage.
     *
     * \param  pm                  pointer to data member of result
     * \param  storage             storage
     */
    template<class T, class JValue_t> 
    inline void operator()(JValue_t JAspera::fit_type::*pm, std::vector<T>& storage)
    {
      (*this)(static_cast<JValue_t result_type::*>(pm), storage);
    }
  };
 
 
  /**
   * Pseudo experiment using CDF for combined generation and likelihood evaluation.
   */
  struct JPseudoExperiment :
    public JPseudoExperiment_t
  {
    /**
     * Default constructor.
     */
    JPseudoExperiment()
    {}
 
 
    /**
     * Constructor.
     *
     * \param  hs         histogram with PDF of signal
     * \param  hb         histogram with PDF of background
     */
    template<class H_t>
    JPseudoExperiment(const H_t&   hs,
                      const H_t&   hb)
    {
      add(hs, hb);
    }
 
 
    /**
     * Constructor.
     *
     * \param  hS         histogram with PDF for generation of signal
     * \param  hB         histogram with PDF for generation of background
     * \param  hs         histogram with PDF for evaluation of signal
     * \param  hb         histogram with PDF for evaluation of background
     */
    template<class H_t>
    JPseudoExperiment(const H_t&   hS,
                      const H_t&   hB,
                      const H_t&   hs,
                      const H_t&   hb)
    {
      add(hS, hB, hs, hb);
    }
 
 
    /**
     * Add objects with PDFs of signal and background.
     *
     * \param  ps         pointer to object with PDF of signal
     * \param  pb         pointer to object with PDF of background
     */
    void add(const TObject* ps,
             const TObject* pb)
    {
      if (add<TH3>(ps, pb)) { return; }
      if (add<TH2>(ps, pb)) { return; }
      if (add<TH1>(ps, pb)) { return; }
    }
 
 
    /**
     * Add objects with PDFs of signal and background.
     *
     * \param  pS         pointer to object with PDF for generation of signal
     * \param  pB         pointer to object with PDF for generation of background
     * \param  ps         pointer to object with PDF for evaluation of signal
     * \param  pb         pointer to object with PDF for evaluation of background
     */
    void add(const TObject* pS,
             const TObject* pB,
             const TObject* ps,
             const TObject* pb)
    {
      if (add<TH3>(pS, pB, ps, pb)) { return; }
      if (add<TH2>(pS, pB, ps, pb)) { return; }
      if (add<TH1>(pS, pB, ps, pb)) { return; }
    }
 
 
    /**
     * Add histograms with PDFs of signal and background.
     *
     * \param  hs         histogram with PDF of signal
     * \param  hb         histogram with PDF of background
     */
    void add(const TH1&   hs,
             const TH1&   hb)
    {
      for (Int_t ix = 1; ix <= hs.GetXaxis()->GetNbins(); ++ix) {
        add(hs.GetBinContent(ix),
            hb.GetBinContent(ix));
      }
    }
 
 
    /**
     * Add histograms with PDFs of signal and background.
     *
     * \param  hS         histogram with PDF for generation of signal
     * \param  hB         histogram with PDF for generation of background
     * \param  hs         histogram with PDF for evaluation of signal
     * \param  hb         histogram with PDF for evaluation of background
     */
    void add(const TH1&   hS,
             const TH1&   hB,
             const TH1&   hs,
             const TH1&   hb)
    {
      for (Int_t ix = 1; ix <= hs.GetXaxis()->GetNbins(); ++ix) {
        add(hS.GetBinContent(ix),
            hB.GetBinContent(ix),
            hs.GetBinContent(ix),
            hb.GetBinContent(ix));
      }
    }
 
 
    /**
     * Add histograms with PDFs of signal and background.
     *
     * \param  hs         histogram with PDF of signal
     * \param  hb         histogram with PDF of background
     */
    void add(const TH2&   hs,
             const TH2&   hb)
    {
      for (Int_t ix = 1; ix <= hs.GetXaxis()->GetNbins(); ++ix) {
        for (Int_t iy = 1; iy <= hs.GetYaxis()->GetNbins(); ++iy) {
          add(hs.GetBinContent(ix, iy),
              hb.GetBinContent(ix, iy));
        }
      }
    }
 
 
    /**
     * Add histograms with PDFs of signal and background.
     *
     * \param  hS         histogram with PDF for generation of signal
     * \param  hB         histogram with PDF for generation of background
     * \param  hs         histogram with PDF for evaluation of signal
     * \param  hb         histogram with PDF for evaluation of background
     */
    void add(const TH2&   hS,
             const TH2&   hB,
             const TH2&   hs,
             const TH2&   hb)
    {
      for (Int_t ix = 1; ix <= hs.GetXaxis()->GetNbins(); ++ix) {
        for (Int_t iy = 1; iy <= hs.GetYaxis()->GetNbins(); ++iy) {
          add(hS.GetBinContent(ix, iy),
              hB.GetBinContent(ix, iy),
              hs.GetBinContent(ix, iy),
              hb.GetBinContent(ix, iy));
        }
      }
    }
 
 
    /**
     * Add histograms with PDFs of signal and background.
     *
     * \param  hs         histogram with PDF of signal
     * \param  hb         histogram with PDF of background
     */
    void add(const TH3&   hs,
             const TH3&   hb)
    {
      for (Int_t ix = 1; ix <= hs.GetXaxis()->GetNbins(); ++ix) {
        for (Int_t iy = 1; iy <= hs.GetYaxis()->GetNbins(); ++iy) {
          for (Int_t iz = 1; iz <= hs.GetZaxis()->GetNbins(); ++iz) {
            add(hs.GetBinContent(ix, iy, iz),
                hb.GetBinContent(ix, iy, iz));
          }
        }
      }
    }
 
 
    /**
     * Add histograms with PDFs of signal and background.
     *
     * \param  hS         histogram with PDF for generation of signal
     * \param  hB         histogram with PDF for generation of background
     * \param  hs         histogram with PDF for evaluation of signal
     * \param  hb         histogram with PDF for evaluation of background
     */
    void add(const TH3&   hS,
             const TH3&   hB,
             const TH3&   hs,
             const TH3&   hb)
    {
      for (Int_t ix = 1; ix <= hs.GetXaxis()->GetNbins(); ++ix) {
        for (Int_t iy = 1; iy <= hs.GetYaxis()->GetNbins(); ++iy) {
          for (Int_t iz = 1; iz <= hs.GetZaxis()->GetNbins(); ++iz) {
            add(hS.GetBinContent(ix, iy, iz),
                hB.GetBinContent(ix, iy, iz),
                hs.GetBinContent(ix, iy, iz),
                hb.GetBinContent(ix, iy, iz));
          }
        }
      }
    }
 
 
    /**
     * Add signal and background.
     *
     * \param  s          signal
     * \param  b          background
     */
    void add(const double s,
             const double b)
    {
      if (check(s, b)) {
 
        cs.put(s);
        cb.put(b);
 
        aspera.put(s, b);
      }
    }
 
 
    /**
     * Add signal and background.
     *
     * \param  S          signal for generation
     * \param  B          background for generation
     * \param  s          signal for evaluation
     * \param  b          background for evaluation
     */
    void add(const double S,
             const double B,
             const double s,
             const double b)
    {
      if (//check(S, B) &&
          check(s, b)) {
 
        cs.put(S);
        cb.put(B);
 
        aspera.put(s, b);
      }
    }
 
 
    /**
     * Get total signal.
     *
     * \return           signal
     */
    double getSignal() const
    {
      return cs.back() * this->fs;
    }
 
 
    /**
     * Get total background.
     *
     * \return           background
     */
    double getBackground() const
    {
      return cb.back() * this->fb;
    }
 
 
    /**
     * Set scaling factors of signal and background strengths.
     *
     * \param  fS        signal strength
     * \param  fB        background strength
     */
    void set(const double fS, const double fB)
    {
      for (auto& i : aspera) {
        i *= fB / this->fb;
      }
      
      this->fs = fS;
      this->fb = fB;
    }
 
 
    /**
     * Get fit method.
     *
     * \return            fit
     */
    virtual JAspera& getAspera() override
    {
      return this->fit;
    }
 
 
    /*
     * Generate pseudo experiment and transfer values to fit method.
     *
     * \param  out        output
     * \return            result
     */
    virtual stats_type run(JAspera& out) const
    {
      out.addSignal(aspera.getSignal());
 
      const size_t ns = gRandom->Poisson(getSignal()     * nuisance.signal    ->get());           // number of signal events
      const size_t nb = gRandom->Poisson(getBackground() * nuisance.background->get());           // number of background events
 
      for (size_t i = ns; i != 0; --i) { out.push_back(aspera[cs.get_index(gRandom->Rndm())]); }  // store distributed signal events
      for (size_t i = nb; i != 0; --i) { out.push_back(aspera[cb.get_index(gRandom->Rndm())]); }  // store distributed background events
 
      return { ns, nb };
    }
 
 
    /**
     * Nuisance parameters.
     */
    struct parameters_type {
 
      /**
       * Read parameters from input stream.
       *
       * \param  in                 input stream
       * \param  parameters         parameters
       * \return                    input stream
       */
      friend inline std::istream& operator>>(std::istream& in, parameters_type& parameters)
      {
        return in >> parameters.signal
                  >> parameters.background;
      }
 
 
      /**
       * Write parameters to output stream.
       *
       * \param  out                output stream
       * \param  parameters         parameters
       * \return                    output stream
       */
      friend inline std::ostream& operator<<(std::ostream& out, const parameters_type& parameters)
      {
        return out << parameters.signal     << ' '
                   << parameters.background;
      }
 
      JNuisance_t  signal;
      JNuisance_t  background;
 
    } nuisance;
 
  protected:
    /**
     * Add objects with PDF of signal and background.
     *
     * \param  ps         pointer to object with PDF of signal
     * \param  pb         pointer to object with PDF of background
     * \return            true if added; else false
     */
    template<class H_t>
    bool add(const TObject* ps,
             const TObject* pb)
    {
      if (dynamic_cast<const H_t*>(ps) != NULL &&
          dynamic_cast<const H_t*>(pb) != NULL) {
 
        const H_t& hs = dynamic_cast<const H_t&>(*ps);
        const H_t& hb = dynamic_cast<const H_t&>(*pb);
 
        if (check(hs, hb)) {
 
          add(hs, hb);
 
          return true;
        }
      }
 
      return false;
    }
 
 
    /**
     * Add objects with PDF of signal and background.
     *
     * \param  pS         pointer to object with PDF for generation of signal
     * \param  pB         pointer to object with PDF for generation of background
     * \param  ps         pointer to object with PDF for evaluation of signal
     * \param  pb         pointer to object with PDF for evaluation of background
     * \return            true if added; else false
     */
    template<class H_t>
    bool add(const TObject* pS,
             const TObject* pB,
             const TObject* ps,
             const TObject* pb)
    {
      if (dynamic_cast<const H_t*>(pS) != NULL &&
          dynamic_cast<const H_t*>(pB) != NULL &&
          dynamic_cast<const H_t*>(ps) != NULL &&
          dynamic_cast<const H_t*>(pb) != NULL) {
 
        const H_t& hS = dynamic_cast<const H_t&>(*pS);
        const H_t& hB = dynamic_cast<const H_t&>(*pB);
        const H_t& hs = dynamic_cast<const H_t&>(*ps);
        const H_t& hb = dynamic_cast<const H_t&>(*pb);
 
        if (check(hS, hB) && check(hB, hs) && check(hs, hb)) {
 
          add(hS, hB, hs, hb);
 
          return true;
        }
      }
 
      return false;
    }
 
 
    /**
     * Auxiliary data structure for CDF.
     */
    struct cdf_type :
      public std::vector<double>
    {
      /**
       * Get index corresponding to given random value.
       *
       * \param  rv         random value [0,1>
       * \return            index
       */
      inline size_t get_index(const double rv) const
      {
        const double value = this->back() * rv;
 
        size_t first = 0;
        size_t count = this->size();
 
        for (size_t i, step; count != 0; ) {
 
          step = count / 2;
          i    = first + step;
 
          if ((*this)[i] < value) {
            first  = ++i;
            count -= step + 1;
          } else {
            count  = step;
          }
        }
 
        return first;
      }
 
 
      /**
       * Put given value.
       *
       * \param  x          value
       */
      void put(const double x)
      {
        if (this->empty())
          this->push_back(x);
        else
          this->push_back(this->back() + x);
      }
    };
 
 
    cdf_type cs;                                             //!< CDF of signal
    cdf_type cb;                                             //!< CDF of background
 
    JAspera  aspera;                                         //!< pre-computed N/S values
 
    double   fs  =  1.0;                                     //!< scaling factor signal strength
    double   fb  =  1.0;                                     //!< scaling factor background strength
 
    JAspera  fit;                                            //!< fit
  };
}
 
#endif