new_mevb.cpp File Reference

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

Go to the source code of this file.

Macros
#define	SERVER_CACHE_SIZE   100000 /* event cache before buffer */
#define	ODB_UPDATE_TIME   1000 /* 1 seconds for ODB update */
#define	DEFAULT_FE_TIMEOUT   60000 /* 60 seconds for watchdog timeout */
#define	EQUIPMENT_COMMON_STR   "\Event ID = WORD : 0\n\Trigger mask = WORD : 0\n\Buffer = STRING : [32] SYSTEM\n\Type = INT : 0\n\Source = INT : 0\n\Format = STRING : [8] FIXED\n\Enabled = BOOL : 0\n\Read on = INT : 0\n\Period = INT : 0\n\Event limit = DOUBLE : 0\n\Num subevents = DWORD : 0\n\Log history = INT : 0\n\Frontend host = STRING : [32] \n\Frontend name = STRING : [32] \n\Frontend file name = STRING : [256] \n\"
#define	EQUIPMENT_STATISTICS_STR   "\Events sent = DOUBLE : 0\n\Events per sec. = DOUBLE : 0\n\kBytes per sec. = DOUBLE : 0\n\"

Functions
INT	handFlush (void)
INT	source_booking (void)
INT	source_unbooking (void)
INT	close_buffers (void)
INT	source_scan (INT fmt, EQUIPMENT_INFO *eq_info)
INT	eb_mfragment_add (char *pdest, char *psrce, INT *size)
INT	eb_yfragment_add (char *pdest, char *psrce, INT *size)
INT	eb_begin_of_run (INT, char *, char *)
INT	eb_end_of_run (INT, char *)
INT	eb_user (INT, BOOL mismatch, EBUILDER_CHANNEL *, EVENT_HEADER *, void *, INT *)
INT	load_fragment (void)
INT	scan_fragment (void)
INT	ebuilder_init (void)
INT	ebuilder_exit (void)
INT	ebuilder_loop (void)
INT	ybos_event_swap (DWORD *pevt)
INT	register_equipment (void)
INT	tr_start (INT rn, char *error)
INT	tr_stop (INT rn, char *error)
void	free_event_buffer (INT nfrag)
int	main (unsigned int argc, char **argv)

Variables
EBUILDER_SETTINGS	ebset
EBUILDER_CHANNEL	ebch [MAX_CHANNELS]
INT	run_state
INT	run_number
DWORD	last_time
DWORD	actual_time
DWORD	actual_millitime
char	host_name [HOST_NAME_LENGTH]
char	expt_name [NAME_LENGTH]
char	full_frontend_name [256]
char	buffer_name [NAME_LENGTH]
INT	nfragment
char *	dest_event
HNDLE	hDB
HNDLE	hKey
HNDLE	hStatKey
HNDLE	hSubkey
HNDLE	hEqKey
HNDLE	hESetKey
BOOL	debug = FALSE
BOOL	debug1 = FALSE
BOOL	wheel = FALSE
char	bars [] = "|\\-/"
int	i_bar
BOOL	abort_requested = FALSE
BOOL	stop_requested = TRUE
DWORD	stop_time = 0
DWORD	request_stop_time = 0
INT(*	meb_fragment_add )(char *, char *, INT *)
char *	frontend_name
char *	frontend_file_name
BOOL	frontend_call_loop
INT	max_event_size
INT	max_event_size_frag
INT	event_buffer_size
INT	display_period
EQUIPMENT	equipment []

Macro Definition Documentation

#define DEFAULT_FE_TIMEOUT   60000 /* 60 seconds for watchdog timeout */

Definition at line 78 of file new_mevb.cpp.

#define EQUIPMENT_COMMON_STR   "\Event ID = WORD : 0\n\Trigger mask = WORD : 0\n\Buffer = STRING : [32] SYSTEM\n\Type = INT : 0\n\Source = INT : 0\n\Format = STRING : [8] FIXED\n\Enabled = BOOL : 0\n\Read on = INT : 0\n\Period = INT : 0\n\Event limit = DOUBLE : 0\n\Num subevents = DWORD : 0\n\Log history = INT : 0\n\Frontend host = STRING : [32] \n\Frontend name = STRING : [32] \n\Frontend file name = STRING : [256] \n\"

Definition at line 135 of file new_mevb.cpp.

Referenced by register_equipment().

#define EQUIPMENT_STATISTICS_STR   "\Events sent = DOUBLE : 0\n\Events per sec. = DOUBLE : 0\n\kBytes per sec. = DOUBLE : 0\n\"

Definition at line 153 of file new_mevb.cpp.

Referenced by register_equipment().

#define ODB_UPDATE_TIME   1000 /* 1 seconds for ODB update */

Definition at line 76 of file new_mevb.cpp.

#define SERVER_CACHE_SIZE   100000 /* event cache before buffer */

dox

Definition at line 74 of file new_mevb.cpp.

Referenced by register_equipment().

Function Documentation

INT close_buffers

(

void

)

INT eb_begin_of_run	(	INT	,
		char *	,
		char *
	)

Hook to the event builder task at PreStart transition.

Parameters

rn	run number
UserField	argument from /Ebuilder/Settings
error	error string to be passed back to the system.

Returns

EB_SUCCESS

eb_begin_of_run()

Hook to the event builder task at PreStart transition. {verbatim} {verbatim}

Parameters

rn	run number
UserField	argument from /Ebuilder/Settings
error	error string to be passed back to the system.

Returns

EB_SUCCESS

eb_begin_of_run()

Hook to the event builder task at PreStart transition. {verbatim} {verbatim}

Parameters

rn	run number
UserField	argument from /Ebuilder/Settings
error	error string to be passed back to the system.

Returns

EB_SUCCESS

Definition at line 145 of file ebuser.cpp.

{
#if 0
  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;
#endif

  // Initialize online compression
  compress_load_all();

  return EB_SUCCESS;
}

INT eb_end_of_run	(	INT	,
		char *
	)

Hook to the event builder task at completion of event collection after receiving the Stop transition.

Parameters

rn	run number
error	error string to be passed back to the system.

Returns

EB_SUCCESS

eb_end_of_run()

Hook to the event builder task at completion of event collection after receiving the Stop transition. {verbatim} {verbatim}

Parameters

rn	run number
error	error string to be passed back to the system.

Returns

EB_SUCCESS

eb_end_of_run()

Hook to the event builder task at completion of event collection after receiving the Stop transition. {verbatim} {verbatim}

Parameters

rn	run number
error	error string to be passed back to the system.

Returns

EB_SUCCESS

Definition at line 193 of file ebuser.cpp.

{
   return EB_SUCCESS;
}

INT eb_mfragment_add	(	char *	pdest,
		char *	psrce,
		INT *	size
	)

INT eb_user	(	INT	nfrag,
		BOOL	mismatch,
		EBUILDER_CHANNEL *	ebch,
		EVENT_HEADER *	pheader,
		void *	pevent,
		INT *	dest_size
	)

Hook to the event builder task after the reception of all fragments of the same serial number. The destination event has already the final EVENT_HEADER setup with the data size set to 0. It is than possible to add private data at this point using the proper bank calls.

The ebch[] array structure points to nfragment channel structure with the following content:

typedef struct {
    char  name[32];         // Fragment name (Buffer name).
    DWORD serial;           // Serial fragment number.
    char *pfragment;        // Pointer to fragment (EVENT_HEADER *)
    ...
} EBUILDER_CHANNEL;

The correct code for including your own MIDAS bank is shown below where TID_xxx is one of the valid Bank type starting with TID_ for midas format or xxx_BKTYPE for Ybos data format. bank_name is a 4 character descriptor. pdata has to be declared accordingly with the bank type. Refers to the ebuser.c source code for further description.

It is not possible to mix within the same destination event different event format!

// Event is empty, fill it with BANK_HEADER
// If you need to add your own bank at this stage

bk_init(pevent);
bk_create(pevent, bank_name, TID_xxxx, &pdata);
 pdata++ = ...;
 dest_size = bk_close(pevent, pdata);
pheader->data_size = *dest_size + sizeof(EVENT_HEADER);

For YBOS format, use the following example.

ybk_init(pevent);
ybk_create(pevent, "EBBK", I4_BKTYPE, &pdata);
 pdata++ = 0x12345678;
 pdata++ = 0x87654321;
 dest_size = ybk_close(pevent, pdata);
 dest_size *= 4;
pheader->data_size = *dest_size + sizeof(YBOS_BANK_HEADER);

Parameters

nfrag	Number of fragment.
mismatch	Midas Serial number mismatch flag.
ebch	Structure to all the fragments.
pheader	Destination pointer to the header.
pevent	Destination pointer to the bank header.
dest_size	Destination event size in bytes.

Returns

EB_SUCCESS

Definition at line 259 of file ebuser.cpp.

References compress_event(), EB_SUCCESS, EB_USER_ERROR, i, EBUILDER_CHANNEL::pfragment, and printf().

Referenced by source_scan().

{
  if (mismatch){
    printf("Serial number do not match across fragments\n");
    for (int i = 0; i < nfrag; i++) {
      int serial = ((EVENT_HEADER *) ebch[i].pfragment)->serial_number;
      printf("Ser[%i]:%d ", i + 1, serial);
    }
    printf("\n");
    return EB_USER_ERROR;
  }

  // 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;

}

INT eb_yfragment_add	(	char *	pdest,
		char *	psrce,
		INT *	size
	)

INT ebuilder_exit

(

void

)

Definition at line 126 of file ebuser.cpp.

References EB_SUCCESS.

Referenced by main().

{
  return EB_SUCCESS;
}

INT ebuilder_init

(

void

)

Definition at line 120 of file ebuser.cpp.

References EB_SUCCESS.

Referenced by main().

{
  return EB_SUCCESS;
}

INT ebuilder_loop

(

void

)

Definition at line 132 of file ebuser.cpp.

References EB_SUCCESS.

{
  return EB_SUCCESS;
}

void free_event_buffer

(

INT

nfrag)

Definition at line 701 of file new_mevb.cpp.

References i, and EBUILDER_CHANNEL::pfragment.

{
   INT i;
   for (i = 0; i < nfrag; i++) {
      if (ebch[i].pfragment) {
         free(ebch[i].pfragment);
         ebch[i].pfragment = NULL;
      }
   }
}

INT handFlush

(

void

)

INT load_fragment

(

void

)

int main	(	unsigned int	argc,
		char **	argv
	)

Definition at line 1067 of file new_mevb.cpp.

References buffer_name, cm_get_environment(), debug, EB_SUCCESS, ebuilder_exit(), ebuilder_init(), expt_name, FALSE, free_event_buffer(), frontend_name, full_frontend_name, hDB, hKey, host_name, i, load_fragment(), EBUILDER_SETTINGS::nfragment, printf(), register_equipment(), scan_fragment(), source_unbooking(), status, SUCCESS, tr_start(), tr_stop, TRUE, usage(), and wheel.

{
  INT status;
  unsigned int i;
  BOOL daemon = FALSE;
  
  /* init structure */
  memset(&ebch[0], 0, sizeof(ebch));

  /* set default */
  cm_get_environment(host_name, sizeof(host_name), expt_name, sizeof(expt_name));

  /* get parameters */
  for (i = 1; i < argc; i++) {
    if (argv[i][0] == '-' && argv[i][1] == 'd')
      debug = TRUE;
    else if (argv[i][0] == '-' && argv[i][1] == 'D')
      daemon = TRUE;
    else if (argv[i][0] == '-' && argv[i][1] == 'w')
      wheel = TRUE;
    else if (argv[i][0] == '-') {
      if (i + 1 >= argc || argv[i + 1][0] == '-')
        goto usage;
      if (strncmp(argv[i], "-e", 2) == 0)
        strcpy(expt_name, argv[++i]);
      else if (strncmp(argv[i], "-h", 2) == 0)
        strcpy(host_name, argv[++i]);
      else if (strncmp(argv[i], "-b", 2) == 0)
        strcpy(buffer_name, argv[++i]);
    } else {
usage:
      printf("usage: mevb [-h <Hostname>] [-e <Experiment>] -b <buffername> [-d debug]\n");
      printf("             -w show wheel -D to start as a daemon\n\n");
      return 0;
    }
  }

  printf("Program mevb version 5 started\n\n");
  if (daemon) {
    printf("Becoming a daemon...\n");
    ss_daemon_init(FALSE);
  }

  /* Check buffer arg */
  if (buffer_name[0] == 0) {
    printf("Buffer name must be specified with -b argument\n");
    goto exit;
  }

  /* Compose frontend name */
   strcpy(full_frontend_name, frontend_name);

  /* Connect to experiment */
  status = cm_connect_experiment(host_name, expt_name, full_frontend_name, NULL);
  if (status != CM_SUCCESS) {
    ss_sleep(5000);
    goto exit;
  }

  if (debug)
    cm_set_watchdog_params(TRUE, 0);

  /* Connect to ODB */
  status = cm_get_experiment_database(&hDB, &hKey);
  if (status != EB_SUCCESS) {
    ss_sleep(5000);
    goto exit;
  }
  
  /* check if Ebuilder is already running */
  status = cm_exist(full_frontend_name, TRUE);
  if (status == CM_SUCCESS) {
    cm_msg(MERROR, "Ebuilder", "%s running already!.", full_frontend_name);
    cm_disconnect_experiment();
    goto exit;
  }

  if (ebuilder_init() != SUCCESS) {
    cm_disconnect_experiment();
    /* let user read message before window might close */
    ss_sleep(5000);
    goto exit;
  }

  /* Register single equipment */
  status = register_equipment();
  if (status != EB_SUCCESS) {
    ss_sleep(5000);
    goto exit;
  }

  /* Load Fragment info */
  status = load_fragment();
  if (status != EB_SUCCESS) {
    ss_sleep(5000);
    goto exit;
  }

  /* Register transition for reset counters */
  if (cm_register_transition(TR_START, tr_start, 300) != CM_SUCCESS)
    return status;
  if (cm_register_transition(TR_STOP, tr_stop, 700) != CM_SUCCESS)
    goto exit;

  /* Scan fragments... will stay in */
  status = scan_fragment();
  printf("%s-Out of scan_fragment\n", full_frontend_name);

  /* Detach all source from midas */
  printf("%s-Unbooking\n", full_frontend_name);
  source_unbooking();
  
  ebuilder_exit();

exit:
  /* Free local memory */
  free_event_buffer(ebset.nfragment);

  /* Clean disconnect from midas */
  cm_disconnect_experiment();
  return 0;
}

INT register_equipment

(

void

)

Definition at line 160 of file new_mevb.cpp.

References EB_SUCCESS, equipment, EQUIPMENT_COMMON_STR, EQUIPMENT_STATISTICS_STR, frontend_file_name, full_frontend_name, hDB, hKey, printf(), run_number, run_state, SERVER_CACHE_SIZE, size, sprintf(), status, SUCCESS, and TRUE.

{
  INT index, size, status;
  char str[256];
  EQUIPMENT_INFO *eq_info;
  EQUIPMENT_STATS *eq_stats;
  HNDLE hKey;

  /* get current ODB run state */
  size = sizeof(run_state);
  run_state = STATE_STOPPED;
  db_get_value(hDB, 0, "/Runinfo/State", &run_state, &size, TID_INT, TRUE);
  size = sizeof(run_number);
  run_number = 1;
  status = db_get_value(hDB, 0, "/Runinfo/Run number", &run_number, &size, TID_INT, TRUE);
  assert(status == SUCCESS);

  /* scan EQUIPMENT table from mevb.C */
  for (index = 0; equipment[index].name[0]; index++) {
    eq_info = &equipment[index].info;
    eq_stats = &equipment[index].stats;

    if (eq_info->event_id == 0) {
      printf("\nEvent ID 0 for %s not allowed\n", equipment[index].name);
      cm_disconnect_experiment();
      ss_sleep(5000);
      exit(0);
    }

    /* init status */
    equipment[index].status = EB_SUCCESS;

    sprintf(str, "/Equipment/%s/Common", equipment[index].name);

    /* get last event limit from ODB */
    if (eq_info->eq_type != EQ_SLOW) {
      db_find_key(hDB, 0, str, &hKey);
      size = sizeof(double);
      if (hKey)
        db_get_value(hDB, hKey, "Event limit", &eq_info->event_limit, &size,
        TID_DOUBLE, TRUE);
    }

    /* Create common subtree */
    status = db_check_record(hDB, 0, str, EQUIPMENT_COMMON_STR, TRUE);
    if (status != DB_SUCCESS) {
      printf("Cannot check equipment record, status = %d\n", status);
      ss_sleep(3000);
    }
    db_find_key(hDB, 0, str, &hKey);

    if (equal_ustring(eq_info->format, "YBOS"))
      equipment[index].format = FORMAT_YBOS;
    else if (equal_ustring(eq_info->format, "FIXED"))
      equipment[index].format = FORMAT_FIXED;
    else    /* default format is MIDAS */
      equipment[index].format = FORMAT_MIDAS;

    gethostname(eq_info->frontend_host, sizeof(eq_info->frontend_host));
    strcpy(eq_info->frontend_name, full_frontend_name);
    strcpy(eq_info->frontend_file_name, frontend_file_name);

    /* set record from equipment[] table in frontend.c */
    db_set_record(hDB, hKey, eq_info, sizeof(EQUIPMENT_INFO), 0);

    /* get record once at the start equipment info */
    size = sizeof(EQUIPMENT_INFO);
    db_get_record(hDB, hKey, eq_info, &size, 0);

    /*---- Create just the key , leave it empty ---------------------------------*/
    sprintf(str, "/Equipment/%s/Variables", equipment[index].name);
    db_create_key(hDB, 0, str, TID_KEY);
    db_find_key(hDB, 0, str, &hKey);
    equipment[index].hkey_variables = hKey;

    /*---- Create and initialize statistics tree -------------------*/
    sprintf(str, "/Equipment/%s/Statistics", equipment[index].name);

    status = db_check_record(hDB, 0, str, EQUIPMENT_STATISTICS_STR, TRUE);
    if (status != DB_SUCCESS) {
      printf("Cannot create/check statistics record, error %d\n", status);
      ss_sleep(3000);
    }

    status = db_find_key(hDB, 0, str, &hKey);
    if (status != DB_SUCCESS) {
      printf("Cannot find statistics record, error %d\n", status);
      ss_sleep(3000);
    }

    eq_stats->events_sent = 0;
    eq_stats->events_per_sec = 0;
    eq_stats->kbytes_per_sec = 0;

    /* open hot link to statistics tree */
    status = db_open_record(hDB, hKey, eq_stats, sizeof(EQUIPMENT_STATS)
      , MODE_WRITE, NULL, NULL);
    if (status != DB_SUCCESS) {
      cm_msg(MERROR, "register_equipment", 
        "Cannot open statistics record, error %d. Probably other FE is using it",
        status);
      ss_sleep(3000);
    }

    /*---- open event buffer ---------------------------------------*/
    if (eq_info->buffer[0]) {
      status = bm_open_buffer(eq_info->buffer, EVENT_BUFFER_SIZE,
        &equipment[index].buffer_handle);
      if (status != BM_SUCCESS && status != BM_CREATED) {
        cm_msg(MERROR, "register_equipment",
          "Cannot open event buffer. Try to reduce EVENT_BUFFER_SIZE in midas.h \
          and rebuild the system.");
        return 0;
      }

      /* set the default buffer cache size */
      bm_set_cache_size(equipment[index].buffer_handle, 0, SERVER_CACHE_SIZE);
    } else {
      cm_msg(MERROR, "register_equipment", "Destination buffer must be present");
      ss_sleep(3000);
      exit(0);
    }
  }
  return SUCCESS;
}

INT scan_fragment

(

void

)

INT source_booking

(

void

)

INT source_scan	(	INT	fmt,
		EQUIPMENT_INFO *	eq_info
	)

Scan all the fragment source once per call.

1. This will retrieve the full midas event not swapped (except the MIDAS_HEADER) for each fragment if possible. The fragment will be stored in the channel event pointer.
2. if after a full nfrag path some frag are still not cellected, it returns with the frag# missing for timeout check.
3. If ALL fragments are present it will check the midas serial# for a full match across all the fragments.
4. If the serial check fails it returns with "event mismatch" and will abort the event builder but not stop the run for now.
5. If the serial check is passed, it will call the user_build function where the destination event is going to be composed.

Parameters

fmt	Fragment format type
eq_info	Equipement pointer
dest_hBuf	Destination buffer handle

Returns

EB_NO_MORE_EVENT, EB_COMPOSE_TIMEOUT if different then SUCCESS (bm_compose, rpc_sent error)

INT source_unbooking

(

void

)

INT tr_start	(	INT	rn,
		char *	error
	)

Definition at line 588 of file new_mevb.cpp.

References abort_requested, eb_begin_of_run(), EB_SUCCESS, EBUILDER, equipment, FALSE, full_frontend_name, hDB, hKey, i, key, EBUILDER_SETTINGS::nfragment, nfragment, EBUILDER_SETTINGS::preqfrag, printf(), EBUILDER_SETTINGS::received, run_number, run_state, size, source_booking(), sprintf(), status, stop_requested, SUCCESS, TRUE, EBUILDER_SETTINGS::user_build, and EBUILDER_SETTINGS::user_field.

{
  EBUILDER(ebuilder_str);
  INT status, size, i;
  char   str[128];
  KEY    key;
  HNDLE  hKey, hEqkey, hEqFRkey;
  EQUIPMENT_INFO *eq_info;
  

  eq_info = &equipment[0].info;

  /* Get update eq_info from ODB */
  sprintf(str, "/Equipment/%s/Common", equipment[0].name);
  status = db_find_key(hDB, 0, str, &hKey);
  size = sizeof(EQUIPMENT_INFO);
  db_get_record(hDB, hKey, eq_info, &size, 0);

  ebset.nfragment = nfragment;

  /* reset serial numbers */
  for (i = 0; equipment[i].name[0]; i++) {
    equipment[i].serial_number = 1;
    equipment[i].subevent_number = 0;
    equipment[i].stats.events_sent = 0;
    equipment[i].odb_in = equipment[i].odb_out = 0;
  }

  /* Get / Set Settings */
  sprintf(str, "/Equipment/%s/Settings", equipment[0].name);
  if (db_find_key(hDB, 0, str, &hEqkey) != DB_SUCCESS) {
    status = db_create_record(hDB, 0, str, strcomb(ebuilder_str));
  }

  /* Keep Key on Ebuilder/Settings */
  sprintf(str, "/Equipment/%s/Settings", equipment[0].name);
  if (db_find_key(hDB, 0, str, &hEqkey) != DB_SUCCESS) {
    cm_msg(MINFO, "load_fragment", "/Equipment/%s/Settings not found", equipment[0].name);
  }
  
  /* Update or Create User_field */
  size = sizeof(ebset.user_field);
  status = db_get_value(hDB, hEqkey, "User Field", ebset.user_field, &size, TID_STRING, TRUE);

  /* Update or Create User_Build */
  size = sizeof(ebset.user_build);
  status = db_get_value(hDB, hEqkey, "User Build", &ebset.user_build, &size, TID_BOOL, TRUE);

  /* update ODB */
  size = sizeof(INT);
  status = db_set_value(hDB, hEqkey, "Number of Fragment", &ebset.nfragment, size, 1, TID_INT);  

    /* Create or update the fragment request list */
  status = db_find_key(hDB, hEqkey, "Fragment Required", &hEqFRkey);
  status = db_get_key (hDB, hEqFRkey, &key);
  if (key.num_values != ebset.nfragment) {
    cm_msg(MINFO, "mevb", "Number of Fragment mismatch ODB:%d - CUR:%d", key.num_values, ebset.nfragment);
    free (ebset.preqfrag);
    size = ebset.nfragment*sizeof(BOOL);
    ebset.preqfrag = malloc(size);
    for (i=0 ; i<ebset.nfragment ; i++)
      ebset.preqfrag[i] = TRUE;
    status = db_set_value(hDB, hEqkey, "Fragment Required", ebset.preqfrag, size, ebset.nfragment, TID_BOOL);  
  } else {  // Take from ODBedit
    size = key.total_size;
    free (ebset.preqfrag);
    ebset.preqfrag = malloc(size);
    status = db_get_data(hDB, hEqkey, ebset.preqfrag, &size, TID_BOOL);
  }
  /* Cleanup fragment flags */
  free (ebset.received);
  ebset.received = malloc(size);
  for (i=0 ; i < ebset.nfragment ; i++) 
    ebset.received[i] = FALSE;

  /* Call BOR user function */
  status = eb_begin_of_run(run_number, ebset.user_field, error);
  if (status != EB_SUCCESS) {
    cm_msg(MERROR, "eb_prestart", "run start aborted due to eb_begin_of_run (%d)",
      status);
    return status;
  }

  /* Book all fragment */
  status = source_booking();
  if (status != SUCCESS)
    return status;

  /* local run state */
  run_state = STATE_RUNNING;
  run_number = rn;
  stop_requested = FALSE;
  abort_requested = FALSE;
  printf("%s-Starting New Run: %d\n", full_frontend_name, rn);

  /* Reset global trigger mask */
  return CM_SUCCESS;
}

INT tr_stop	(	INT	rn,
		char *	error
	)

Definition at line 688 of file new_mevb.cpp.

References full_frontend_name, printf(), request_stop_time, stop_requested, and TRUE.

{
   printf("\n%s-Stopping Run: %d detected\n", full_frontend_name, rn);

   /* local stop */
   stop_requested = TRUE;

   /* local stop time */
   request_stop_time = ss_millitime();
   return CM_SUCCESS;
}

INT ybos_event_swap

(

DWORD *

pevt)

Variable Documentation

BOOL abort_requested = FALSE

Definition at line 101 of file new_mevb.cpp.

DWORD actual_millitime

Definition at line 87 of file new_mevb.cpp.

DWORD actual_time

Definition at line 86 of file new_mevb.cpp.

char bars[] = "|\\-/"

Definition at line 99 of file new_mevb.cpp.

char buffer_name[NAME_LENGTH]

Definition at line 92 of file new_mevb.cpp.

BOOL debug = FALSE

Definition at line 96 of file new_mevb.cpp.

BOOL debug1 = FALSE

Definition at line 96 of file new_mevb.cpp.

char* dest_event

Definition at line 94 of file new_mevb.cpp.

INT display_period

Definition at line 43 of file crate.cpp.

Referenced by main(), manual_trigger(), register_equipment(), scheduler(), tr_pause(), tr_prepause(), tr_prestop(), tr_resume(), tr_start(), and tr_stop().

EBUILDER_CHANNEL ebch[MAX_CHANNELS]

Definition at line 81 of file new_mevb.cpp.

EBUILDER_SETTINGS ebset

Definition at line 80 of file new_mevb.cpp.

EQUIPMENT equipment[]

Definition at line 72 of file crate.cpp.

Referenced by close_buffers(), display(), frontend_early_init(), load_fragment(), main(), manual_trigger(), register_equipment(), rpc_end_of_cycle(), scan_fragment(), scheduler(), send_all_periodic_events(), send_event(), source_scan(), tr_prestop(), tr_start(), and tr_stop().

INT event_buffer_size

Definition at line 53 of file crate.cpp.

Referenced by main().

char expt_name[NAME_LENGTH]

Definition at line 90 of file new_mevb.cpp.

BOOL frontend_call_loop

Definition at line 39 of file crate.cpp.

Referenced by scheduler().

char* frontend_file_name

Definition at line 36 of file crate.cpp.

Referenced by register_equipment().

char* frontend_name

Definition at line 33 of file crate.cpp.

Referenced by diag_print_impl(), display(), dl403_init(), frontend_early_init(), main(), read_separator_event(), and register_equipment().

char full_frontend_name[256]

Definition at line 91 of file new_mevb.cpp.

HNDLE hDB

Definition at line 95 of file new_mevb.cpp.

HNDLE hEqKey

Definition at line 95 of file new_mevb.cpp.

HNDLE hESetKey

Definition at line 95 of file new_mevb.cpp.

HNDLE hKey

Definition at line 95 of file new_mevb.cpp.

char host_name[HOST_NAME_LENGTH]

Definition at line 89 of file new_mevb.cpp.

HNDLE hStatKey

Definition at line 95 of file new_mevb.cpp.

HNDLE hSubkey

Definition at line 95 of file new_mevb.cpp.

int i_bar

Definition at line 100 of file new_mevb.cpp.

DWORD last_time

Definition at line 85 of file new_mevb.cpp.

INT max_event_size

Definition at line 47 of file crate.cpp.

Referenced by handFlush(), load_fragment(), main(), scheduler(), send_event(), source_booking(), and source_scan().

INT max_event_size_frag

Definition at line 50 of file crate.cpp.

Referenced by main(), and send_event().

INT(* meb_fragment_add)(char *, char *, INT *)

Definition at line 104 of file new_mevb.cpp.

INT nfragment

Definition at line 93 of file new_mevb.cpp.

DWORD request_stop_time = 0

Definition at line 102 of file new_mevb.cpp.

INT run_number

Definition at line 84 of file new_mevb.cpp.

INT run_state

PROGRAM: crate.cpp DESCRIPTION: Control and readout of CAEN V1724 digitizers. author: V.Tishchenko date: 12-Aug-2012

Modifications:

Definition at line 83 of file new_mevb.cpp.

BOOL stop_requested = TRUE

Definition at line 101 of file new_mevb.cpp.

DWORD stop_time = 0

Definition at line 102 of file new_mevb.cpp.

BOOL wheel = FALSE

Definition at line 98 of file new_mevb.cpp.