---

/Go4EventServer/TGo4MbsRandom.cxx

Go to the documentation of this file.

//---------------------------------------------------------------
//        Go4 Release Package v2.10-5 (build 21005) 
//                      03-Nov-2005
//---------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//       Experiment Data Processing at DVEE department, GSI
//---------------------------------------------------------------
//
//Copyright (C) 2000- Gesellschaft f. Schwerionenforschung, GSI
//                    Planckstr. 1, 64291 Darmstadt, Germany
//Contact:            http://go4.gsi.de
//----------------------------------------------------------------
//This software can be used under the license agreements as stated
//in Go4License.txt file which is part of the distribution.
//----------------------------------------------------------------
#include "TGo4MbsRandom.h"

#include <stdlib.h>
#include <unistd.h>
#include <sys/time.h>
#include <math.h>
#include <iostream.h>

#include "Go4EventServer/TGo4MbsRandomParameter.h"
#include "Go4Log/TGo4Log.h"

extern "C"
{
#include "random-coll.h"
}


double TGo4MbsRandom::fgdPeak[NUM_PEAK]   = { 200., 302., 653., 1024., 2800.};
double TGo4MbsRandom::fgdSigma[NUM_PEAK]  = {  10.,  22., 153.,  104.,   38.};
double TGo4MbsRandom::fgdPeak2[NUM_PEAK]  = { 300., 402., 853., 2000., 3024.};
double TGo4MbsRandom::fgdSigma2[NUM_PEAK] = {  22., 153., 104.,  100.,   20.};


TGo4MbsRandom::TGo4MbsRandom(TGo4MbsRandomParameter* par) : 
   TGo4MbsSource(par->GetName(), 1), fiDLen(0), fiNumSub(0), fiNumDat(0), fxEventMem(0)
{
   TRACE((15,"TGo4MbsRandom::TGo4MbsRandom(TGo4MbsRandomParameter*)",__LINE__, __FILE__));

   TGo4Log::Debug(" New Event Source MbsRandom %s:  ",GetName());
   if(par)
      {
       // here we could specify special values of random source parameter

       }
  Open();
}

TGo4MbsRandom::TGo4MbsRandom(const char* name) : 
   TGo4MbsSource(name , 1), fiDLen(0), fiNumSub(0), fiNumDat(0), fxEventMem(0)
{
   TRACE((15,"TGo4MbsRandom::TGo4MbsRandom(Text_t*)",__LINE__, __FILE__));

   TGo4Log::Debug(" New Event Source MbsRandom %s:  ",name);
   Open();
}

TGo4MbsRandom::TGo4MbsRandom()
{
TRACE((15,"TGo4MbsRandom::TGo4MbsRandom()",__LINE__, __FILE__));

}


TGo4MbsRandom::~TGo4MbsRandom()
{
TRACE((15,"TGo4MbsRandom::~TGo4MbsRandom()",__LINE__, __FILE__));
Close();
}



Int_t TGo4MbsRandom::NextEvent()
{
TRACE((12,"TGo4MbsRandom::NextEvent()",__LINE__, __FILE__));
// here we fill mbs event structure at fxEvent ptr.
void* clearfield=(void*) (fxEvent+1); // we skip header and clear the rest
size_t clearlen=fiDLen*2 - 8;
memset(clearfield,0, clearlen); // clear old values
fxEvent->l_count++;
//cout <<"Eventcount "<<fxEvent->l_count << endl;
//cout <<" Cleared "<< clearlen<<" bytes at "<<clearfield << endl;
// now fill in some new values:
fxEvent->l_dlen=0;
s_ves10_1* subevt=(s_ves10_1*) clearfield;
for(Int_t i=0;i<fiNumSub;++i)
   {
      //cout <<"\tSubevt "<<i <<" at "<< subevt<< endl;
      int l_val_num = (int)(get_int(1., 7.)+0.5); // random number for number of data longwords
      if(l_val_num>fiNumDat) l_val_num=fiNumDat; // never exceed allocated field
      // setup subevent header:
      subevt->i_type=10;
      subevt->i_subtype=1;
      subevt->h_subcrate=i+1; // set subevent id numbers:
      subevt->h_control=2*i;
      subevt->i_procid=4*i;
      //subevt->l_dlen=fiNumDat*2+2; // length in short units + 2
      subevt->l_dlen=l_val_num*2+2; // subevent length in short units + 2
      fxEvent->l_dlen+=(l_val_num*sizeof(Int_t)) / 2 ; // add datalength to total length in shorts

      //cout <<"\t dlen="<<subevt->l_dlen << endl;
      Int_t* subdata= (Int_t*) (subevt+1); // data starts after subevt
      //cout <<"\t data="<<subdata << endl;
      for(Int_t j=0;j<l_val_num;++j)
         {
             *(subdata+j)=rand_event(j+1); // later use random generator here
             //cout <<"\t\t"<<"filled "<<j<<" with "<<*(subdata+j) <<"at "<<(subdata+j) << endl;
         } // for (... numdat ...)
      subevt=(s_ves10_1*) (subdata+l_val_num); // next subheader after last data
   } // for(...numsub)
   fxEvent->l_dlen+=(sizeof(s_ve10_1)-sizeof(s_evhe)+fiNumSub*sizeof(s_ves10_1))/2;
// finally, add length of headers  to totalevent length
return 0;
}


Int_t TGo4MbsRandom::Open()
{
TRACE((12,"TGo4MbsRandom::Open()",__LINE__, __FILE__));
//
if(fbIsOpen)
   return -1;

get_rand_seed();
fiNumSub=2; // number of subevents, fix
fiNumDat=16; // maximum allocated data longs per subevent
fiDLen=(sizeof(s_ve10_1)-sizeof(s_evhe)+fiNumSub*(sizeof(s_ves10_1)+fiNumDat*sizeof(Int_t))) / 2 ;
   // fiDLen is not in char (=size_t), but short units
fxEventMem =new Short_t[fiDLen+sizeof(s_evhe)];
fxEvent= (s_ve10_1*) fxEventMem;
fxEvent->l_dlen=fiDLen;
fxEvent->i_subtype=1;
fxEvent->i_type=10;
fxEvent->i_trigger=1; 
fxEvent->l_count=0;
return 0;
}


Int_t TGo4MbsRandom::Close()
{
TRACE((12,"TGo4MbsRandom::Close()",__LINE__, __FILE__));
if(!fbIsOpen)
   return -1;
delete [] fxEventMem;
fxEvent=0;
return 0;
}


void TGo4MbsRandom::get_rand_seed()                         /* obtains seed for generator      */
{
  struct timeval tv;
  struct timezone tz;

  gettimeofday(&tv, &tz);          /* may not be supported in your C  */
  fuSeed=tv.tv_sec + tv.tv_usec;     /* if not, replace with clock()    */
  srand48(fuSeed);

}


double TGo4MbsRandom::gauss_rnd(double mean, double sigma)
{
  static int iset=0;
  static double gset;
  double v1, v2, s, u1;

  if(sigma < 0.)
    {
      v1 = drand48();
      return (log(1-v1)/sigma + mean);
    }
  else
    {
      if(iset == 0)
   {
     do
       {
         v1 = 2.*drand48()-1.;
         v2 = 2.*drand48()-1.;

         s = v1*v1+v2*v2;
       } while (s >= 1.0 || s == 0.0);

     u1 = sigma*v1*(sqrt(-2.*log(s)/s)) + mean;
     gset = u1;
     iset = 1;

     return (sigma*v2*(sqrt(-2.*log(s)/s)) + mean);
   }
      else
   {
     iset = 0;
     return gset;
   }
    }
}


double TGo4MbsRandom::get_int(double low, double high)
{
  return ((high-low)*drand48()+low);
}


long TGo4MbsRandom::rand_event(long choice)
{
  int cnt;
  switch(choice)
    {
  case 1:
    cnt = (int)(get_int(0., (double)NUM_PEAK));
    return ((long)(gauss_rnd(fgdPeak[cnt], fgdSigma[cnt])));
    break;
  case 2:
    cnt = (int)(get_int(0., (double)NUM_PEAK));
    return ((long)(p_dNormal(fgdPeak2[cnt], fgdSigma2[cnt], &fuSeed)));
    break;
  case 3:
    return ((long)(4096*p_dUniform(&fuSeed)));
    break;
  case 4:
    return ((long)(gauss_rnd(0., -.001)));
    break;
  case 5:
    return ((long)(p_dExponential(100., &fuSeed)));
    break;
  case 6:
    cnt = (int)(get_int(0., (double)NUM_PEAK));
    return ((long)((p_dExponential(200., &fuSeed)) + gauss_rnd(fgdPeak[cnt], fgdSigma[cnt])));
    break;
  case 7:
    cnt = (int)(get_int(3., (double)NUM_PEAK));
    return ((long)((4096*p_dUniform(&fuSeed)) + gauss_rnd(fgdPeak[cnt], fgdSigma[cnt])));
    break;

  default:
    return 0;
    break;
    }

  return 0;
}


s_bufhe * TGo4MbsRandom::GetBufferHeader()
{
   return 0;
}

ClassImp(TGo4MbsRandom)

//----------------------------END OF GO4 SOURCE FILE ---------------------

---