test/Producer_Finuda.C

#include "FROOT.h"

#include <Riostream.h>
#include "TH1F.h"
#include "TH2F.h"
#include "TProfile.h"
#include "TRandom.h"

//     FORCE FROOT SETTING      //
#undef _FND_ONL_USE_SHARED_FILES_
#undef _FND_ONL_USE_MAP_FILES_

#define _FND_ONL_USE_MAP_FILES_
//#define _FND_ONL_USE_SHARED_FILES_

#if defined _FND_ONL_USE_MAP_FILES_
#include "TMapFile.h"
#elif defined _FND_ONL_USE_SHARED_FILES_
#include "TFile.h"
#endif


#include "TSystem.h"
#include "TString.h"

void HandleConsumerActions(const Char_t *sh_msg_file, Bool_t allow){
  // the content of the shared text file 'shared_msg.txt' is
  // used by the consumer(s).
  // Consumer(s) can act (open, read...map-files) if 'allow' is true

  TString com = TString("echo ");
  Int_t size1 = com.Sizeof()-1;
  if(allow) com+="\"go\" > ";
  else com+="\"wait\" > ";
  com+=sh_msg_file;
  gSystem->Exec(com.Data());

  com.Resize(size1);
  com+="\"\" >> ";
  com+=sh_msg_file;
  gSystem->Exec(com.Data());

}

void Producer_Finuda(){

  gROOT->Reset();
  //  TMapFile::SetMapAddress(FROOT::K_MapsStartAddress);

  gSystem->Setenv("FND_SHR","./");
  TString mnam = TString(gSystem->Getenv("FND_SHR"));
  mnam+="/hsimple.map";
  TString msgnam = TString(gSystem->Getenv("FND_SHR"));
  msgnam+="/shared_msg.txt";

  TString comm1 = TString("touch ");
  comm1+=msgnam.Data();
  gSystem->Exec(comm1.Data());

  HandleConsumerActions(msgnam.Data(),0); // deny consumer(s) actions
#if defined _FND_ONL_USE_MAP_FILES_
  TMapFile::SetMapAddress(0x40028000);
#endif
  // --- remove mapped file
  TString command_rm = TString("rm -f ");
  command_rm+=mnam.Data();
  gSystem->Exec(command_rm.Data());
  // --- recreate mapped file
  gSystem->Sleep(300); 
#if defined _FND_ONL_USE_MAP_FILES_
  cout << "Creating map file" << endl;
  TMapFile *mfile = TMapFile::Create(mnam.Data(),"RECREATE", 10000,"Demo memory mapped file");
  cout << "Map file created" << endl;
  cout << "mfile is: " << mfile << endl;
  mfile->Print();
#elif defined _FND_ONL_USE_SHARED_FILES_
  cout << "Creating shared file" << endl;
  TFile *mfile = new TFile(mnam.Data(),"RECREATE");
  cout << "Shared file created" << endl;
#endif
  gSystem->Sleep(300); 
  

  TH1F *h1    = new TH1F("h1","Histogram 1",100,-4,4);
  h1->SetFillColor(48);
  HandleConsumerActions(msgnam.Data(),0); // deny consumer(s) actions
#if defined _FND_ONL_USE_MAP_FILES_
  mfile->Update();
#elif defined _FND_ONL_USE_SHARED_FILES_
  mfile->cd();
  h1->Write();
  mfile->Purge();
  mfile->Flush();
#endif

  HandleConsumerActions(msgnam.Data(),1); // allow consumer(s) actions

  mfile->ls();
  
  
  TString command_touch = TString("touch ");
  command_touch+=mnam.Data();
  int ev = 0;
  while (1) {
    cout << "Macro message: Filling" << endl;
    h1->Fill(3);
#if defined _FND_ONL_USE_MAP_FILES_
    cout << "Macro message: Updating mapfile" << endl;
    mfile->Update();
    cout << "Macro message: mapfile updated: now touching it" << endl;
#elif defined _FND_ONL_USE_SHARED_FILES_
    cout << "Macro message: Updating shared file" << endl;
    mfile->cd();
    h1->Write();
    mfile->Purge();
    mfile->Flush();
    cout << "Macro message: shared file updated: now touching it" << endl;
#endif
    gSystem->Exec(command_touch.Data());
#if defined _FND_ONL_USE_MAP_FILES_
    cout << "Macro message: mapfile touched" << endl;
#elif defined _FND_ONL_USE_SHARED_FILES_
    cout << "Macro message: shared file touched" << endl;
#endif
    gSystem->ProcessEvents();
    mfile->ls();
    Char_t a[10];
    cout << "press any key to continue (fill and update)" << endl;
    cin >> a;
    if(!strcmp(a,"q")) break;
    ev++;
  }
  HandleConsumerActions(msgnam.Data(),0); // deny consumer(s) actions
  mfile->Close();
  
}

---