viewer.c

Go to the documentation of this file.

#include "../../SharedMemory/SMcommon.h"
#include <iostream>
#include <time.h>
#include <stdio.h>

class DataTaking{
 private:
  SharedMemory sm;
  int shd_param_id;
  struct SHM_PARAM *param_ptr;
  double *data_ptr;
  key_t key;
  char *fmttm(char *buf , struct tm *st);
  
  time_t t;
  struct tm* ltm;
  char s[50];
  

 public:
  int ShMemory();
  void run();
  void start_time();  
  
};

int DataTaking::ShMemory(){
  //  key = ftok("~/study/ROOT/jikken3/DataTaking/viewer",PROJ_CHAR);
  key = ftok("viewer",PROJ_CHAR);
  if( key == -1 ) {
    perror("ftok()");
    return 1;
  }
  sm.shm_access(key,sizeof(struct SHM_PARAM),&shd_param_id,(int *)&param_ptr);
  return 0;
}

void DataTaking::start_time(){
  time(&t);        //time_t type
  //  printf("%d\n",t);
  
  ltm = localtime(&t);   //change time_t type -> tm structure(local)
  fmttm(s,ltm);
  printf("%s\n",s);

}

char *DataTaking::fmttm(char *buf , struct tm *st){
  char *a[7] = {"sun","man","tue","wed","the","fri","sat",};
                                                                                
  sprintf(buf,"start [%d/%d/%d (%s) %02d:%02d:%02d]",
          st->tm_year +1900,
          st->tm_mon +1,
          st->tm_mday,
          a[st->tm_wday],
          st->tm_hour,
          st->tm_min,
          st->tm_sec);

  sprintf(param_ptr->StartTime,"%d / %d / %d  (%s) %02d:%02d:%02d",
          st->tm_year +1900,
          st->tm_mon +1,
          st->tm_mday,
          a[st->tm_wday],
          st->tm_hour,
          st->tm_min,
          st->tm_sec);
  return buf;

}

void DataTaking::run(){
  ShMemory();
  sm.shm_initialize(key,sizeof(struct SHM_PARAM), &shd_param_id, (int *)&param_ptr);
  param_ptr->shd_param_id = shd_param_id;
  param_ptr->nEvent=0;
  param_ptr->nOverFlow=0;

  start_time();
  
  //printf(param_ptr->StartTime);
  std::cout<<param_ptr->StartTime<<std::endl;
  //  printf("%s",param_ptr->StartTime);
  
  while(1){
    param_ptr->nEvent++;
    int eve;
    eve=rand()%280;
    if(eve<250)param_ptr->Hist[eve]++;
    else if(eve>250)param_ptr->nOverFlow++;
    std::cout<<"eve = "<<eve<<"  ";
    std::cout<<param_ptr->nEvent<<" "<<param_ptr->nOverFlow<<std::endl;
    if( param_ptr->status == FIN )break;
    if( param_ptr->status == PAUSE )std::cout<<"Pause  "<<std::endl;
    if( param_ptr->status == RESTART );
    //    usleep(50000);
    sleep(1);
  }
  sm.erase_shm(param_ptr);


}

int main(int argc, char **argv)
{
  DataTaking dt;
  dt.run();
  //  SharedMemory sm;
  
}

---