ebuser.cxx

Go to the documentation of this file.

/********************************************************************\
 
  Name:         ebuser.c
  Created by:   Pierre-Andre Amaudruz
 
  Contents:     User section for the Event builder
 
  $Id$
 
\********************************************************************/
#include <stdio.h>
#include <string.h>
#include <stdlib.h> // atoi()
#include "midas.h"
#include "mevb.h"
 
/* data type sizes */
extern INT tid_size[];
/*-- Globals -------------------------------------------------------*/
 
/* The frontend name (client name) as seen by other MIDAS clients   */
const char *frontend_name = "Ebuilder";
 
/* The frontend file name, don't change it */
const char *frontend_file_name = __FILE__;
 
/* frontend_loop is called periodically if this variable is TRUE    */
BOOL ebuilder_call_loop = FALSE;
 
/* A frontend status page is displayed with this frequency in ms */
INT display_period = 3000;
 
/* maximum event size produced by this frontend */
INT max_event_size = 500000;
 
/* maximum event size for fragmented events (EQ_FRAGMENTED) */
INT max_event_size_frag = 5 * 1024 * 1024;
 
/* buffer size to hold events */
INT event_buffer_size = 20 * 50000;
 
INT lModulo = 100;              
 
/*-- Function declarations -----------------------------------------*/
INT ebuilder_init();
INT ebuilder_exit();
INT eb_begin_of_run(INT, char *, char *);
INT eb_end_of_run(INT, char *);
INT ebuilder_loop();
INT ebuser(INT, BOOL mismatch, EBUILDER_CHANNEL *, EVENT_HEADER *, void *, INT *);
INT read_scaler_event(char *pevent, INT off);
extern EBUILDER_SETTINGS ebset;
extern BOOL debug;
 
/*-- Equipment list ------------------------------------------------*/
EQUIPMENT equipment[] = {
   {"EB",                /* equipment name */
    {1, 0,                   /* event ID, trigger mask */
     "SYSTEM",               /* event buffer */
     0,                      /* equipment type */
     0,                      /* event source */
     "MIDAS",                /* format */
     TRUE,                   /* enabled */
     },
    },
 
  {""}
};
 
 
/********************************************************************/
/********************************************************************/
INT ebuilder_init()
{
  setbuf(stdout, NULL);
  setbuf(stderr, NULL);
  return EB_SUCCESS;
}
 
/********************************************************************/
INT ebuilder_exit()
{
  return EB_SUCCESS;
}
 
/********************************************************************/
INT ebuilder_loop()
{
  return EB_SUCCESS;
}
 
/********************************************************************/
INT eb_begin_of_run(INT rn, char *UserField, char *error)
{
  printf("In eb_begin_of_run for run:%d User_field:%s \n", rn, UserField);
   lModulo = atoi(UserField);
   return EB_SUCCESS;
}
 
/********************************************************************/
INT eb_end_of_run(INT rn, char *error)
{
   printf("In eb_end_of_run\n");
   return EB_SUCCESS;
}
 
/********************************************************************/
INT eb_user(INT nfrag, BOOL mismatch, EBUILDER_CHANNEL * ebch
            , EVENT_HEADER * pheader, void *pevent, INT * dest_size)
{
  INT i, frag_size, serial, status;
  DWORD  *pdata;
 
 
  //
  // Do some extra fragment consistency check
  if (mismatch){
    printf("Serial number do not match across fragments\n");
    for (i = 0; i < nfrag; i++) {
      serial = ((EVENT_HEADER *) ebch[i].pfragment)->serial_number;
      printf("Ser[%i]:%d ", i + 1, serial);
    }
    printf("\n");
    return EB_USER_ERROR;
  }
 
  //
  // Include my own bank
  bk_init(pevent);
  bk_create(pevent, "MYOW", TID_DWORD, (void**)&pdata);
  for (i = 0; i < nfrag; i++) {
     if (ebset.preqfrag[i]) { // if channel enable
        *pdata++ = ((EVENT_HEADER *) ebch[i].pfragment)->serial_number;
        *pdata++ = ((EVENT_HEADER *) ebch[i].pfragment)->time_stamp;
     }
  }
  *dest_size = bk_close(pevent, pdata);
  pheader->data_size = *dest_size + sizeof(EVENT_HEADER);
 
  // Copy the bank TC01 if found from fragment0 to the destination
  status = bk_copy((char*)pevent, ebch[0].pfragment, "TC01");
  if (status == EB_BANK_NOT_FOUND) {
    printf("bank TC01 not found\n");
  }
 
  // Destination access
  // dest_serial = pheader->serial_number;
  // printf("DSer#:%d ", dest_serial);
 
  // Stop run if condition requires
  // if (dest_serial == 505) return EB_USER_ERROR;
 
  // Skip event if condition requires
  // if (dest_serial == 505) return EB_SKIP;
 
  //
  // Loop over fragments.
  if (debug) {
    for (i = 0; i < nfrag; i++) {
      if (1) {
   if (ebset.preqfrag[i]) { // printf if channel enable
     frag_size = ((EVENT_HEADER *) ebch[i].pfragment)->data_size;
     serial = ((EVENT_HEADER *) ebch[i].pfragment)->serial_number;
     printf("Frg#:%d Dsz:%d Ser:%d ", i, frag_size, serial);
     // For Data fragment Access.
     // psrcData = (DWORD *) (((EVENT_HEADER *) ebch[i].pfragment) + 1);
   }
      }
    }
    printf("\n");
  }
  return EB_SUCCESS;
}