old_ebuser.cpp

Go to the documentation of this file.

/********************************************************************\

  Name:         ebuser.c
  Created by:   Pierre-Andre Amaudruz

  Contents:     User section for the Event builder

  $Log: ebuser.cpp,v $
  Revision 1.2  2004/05/31 14:26:34  mucap
  Commented out compression.  (Leftover uncommitted change from run7)

  Revision 1.1  2003/07/17 18:52:54  fegray
  Converted eventbuilder to C++.

  Revision 1.3  2003/05/13 19:27:04  mucap
  Fixes to allow a subset of the crates to participate in an event.  Also,
  this pulls in Pierre's CVS changes to the generic eventbuilder code.

  Revision 1.2  2003/05/13 17:02:47  fegray
  Changes to allow a subset of the crates to run.

  Revision 1.1  2003/05/13 16:21:16  mucap
  First commit of MIDAS (Ethernet-based) event-builder.

  Revision 1.6  2002/09/28 00:49:08  pierre
  Add EB_USER_ERROR example

  Revision 1.5  2002/09/25 18:38:03  pierre
  correct: header passing, user field, abort run

  Revision 1.4  2002/07/13 05:46:10  pierre
  added ybos comments

  Revision 1.3  2002/06/14 04:59:46  pierre
  revised for ybos

  Revision 1.2  2002/01/17 23:34:29  pierre
  doc++ format

  Revision 1.1.1.1  2002/01/17 19:49:54  pierre
  Initial Version

\********************************************************************/

#include <stdio.h>
#include "midas.h"
#include "mevb.h"
#include "ybos.h"

#include "mucap_compress.h"

#define NUMCRATES 5

INT eb_begin_of_run(INT, char *, char *);
INT eb_end_of_run(INT, char *);
INT ebuser(INT, EBUILDER_CHANNEL *, EVENT_HEADER *, void *, INT *);

/* Globals */
INT  lModulo = 100;

/*--------------------------------------------------------------------*/
INT eb_begin_of_run(INT rn, char * UserField, char * error)
{
  extern EBUILDER_SETTINGS ebset;
  extern EBUILDER_CHANNEL  ebch[MAX_CHANNELS];
  extern HNDLE hDB;

  int n;
  int mask = 0;

  char keyName[256];
  BOOL enabled;
  int size;

  /* 
   * Determine which crates are enabled and set up the mask 
   * accordingly.
   */
  for(n = 1; n <= NUMCRATES; n++) {
    sprintf(keyName, "/Equipment/Crate %d/Settings/Enabled", n);
    size = sizeof(enabled);
    db_get_value(hDB, 0, keyName, &enabled, &size, TID_BOOL, FALSE);
    if(size == sizeof(enabled) && enabled) {
       ebch[n-1].trigger_mask = (1 << (n-1));
       mask |= ebch[n-1].trigger_mask;
    } else {
       ebch[n-1].trigger_mask = 0;
    }
  }

  cm_msg(MINFO, "eb_begin_of_run", "Setting event mask to 0x%x", mask);
  ebset.trigger_mask = mask;
 
  // Initialize online compression
  compress_load_all();
  
  return EB_SUCCESS;
}

/*--------------------------------------------------------------------*/
INT eb_end_of_run(INT rn, char * error)
{
  return EB_SUCCESS;
}

/*--------------------------------------------------------------------*/
INT eb_user(INT nfrag
    , EBUILDER_CHANNEL * ebch, EVENT_HEADER *pheader
    , void *pevent, INT * dest_size)
{
  // Initialize output event
  bk_init32(pevent);

  // Loop over the event fragments, performing compression into the output event
  for(int i = 0; i < nfrag; i++) {
    void *fragment =  ebch[i].pfragment;

    if(fragment != NULL) {
      compress_event(((EVENT_HEADER *) fragment) + 1, pevent);
      pheader->serial_number = 
        ((EVENT_HEADER *) ebch[i].pfragment)->serial_number;
    }
  }

  // Set the size of the output event properly
  pheader->data_size = *dest_size = bk_size(pevent);

  printf("Returning size %d\n", pheader->data_size);

  return EB_SUCCESS;
}