patch_mevb.cpp File Reference

Go to the source code of this file.

Functions
home data midas examples eventbuilder mevb Created v v this pulls in Pierre s CVS changes to the generic eventbuilder code INT	eb_end_of_run (INT, char *)
INT	eb_user (INT, EBUILDER_CHANNEL *, EVENT_HEADER *, void *, INT *)
INT	ybos_event_swap (DWORD *pevt)
INT	source_unbooking (nfrag)+INT source_unbooking(INT nfrag)
	free_event_buffer (nfrag)
	for (i=0;i< nfragment;i++)
	if (debug)
	if (!ebset.user_build)
memset &[0]	ebch (ebch)
	cm_get_environment (host_name, expt_name)
	cm_get_environment (host_name, sizeof(host_name),+expt_name, sizeof(expt_name))
	if (cm_register_transition(TR_PRESTART, tr_prestart)!=CM_SUCCESS)+if(cm_register_transition(TR_START
	if (cm_register_transition(TR_STOP, tr_stop)!=CM_SUCCESS)+if(cm_register_transition(TR_STOP

Variables
home data midas examples eventbuilder mevb	c
home data midas examples eventbuilder mevb Created	by
home data midas examples eventbuilder mevb Created v	$Log
home data midas examples eventbuilder mevb Created v v	Revision
BOOL	found
BOOL	event_mismatch
BANK_HEADER *	psbh
	status = SUCCESS
	else
	tr_prestart
	tr_stop

Function Documentation

cm_get_environment	(	host_name	,
		expt_name
	)

Referenced by main(), and process_file().

cm_get_environment	(	host_name	,
		sizeof(host_name)	,
		+	expt_name,
		sizeof(expt_name)
	)

home data midas examples eventbuilder mevb Created v v this pulls in Pierre s CVS changes to the generic eventbuilder code 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.

References EB_SUCCESS.

Referenced by close_buffers(), and main().

{
   return EB_SUCCESS;
}

INT eb_user	(	INT	,
		EBUILDER_CHANNEL *	,
		EVENT_HEADER *	,
		void *	,
		INT *
	)

Definition at line 187 of file old_ebuser.cpp.

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

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

memset&[0] ebch

(

ebch

)

for

(

)

Definition at line 82 of file patch_mevb.cpp.

                                {
     /* Check if current channel needs to be received */
@@ -562,6 +581,9 @@
         sprintf (strsub, "Ser[%d]:%d ", j, ebch[j].serial);
         strcat (str, strsub);
       }

free_event_buffer

(

nfrag

)

if

(

debug

)

Definition at line 88 of file patch_mevb.cpp.

                 {
+       printf("%s\n", str);
+      }

if

(

!ebset.

user_build)

Definition at line 96 of file patch_mevb.cpp.

                              {
         for (j=0 ; j<nfragment ; j++) {
+          if (ebch[j].set.emask) {
           status = meb_fragment_add(dest_event, ebch[j].pfragment, &act_size);
           if (status != EB_SUCCESS) {
             cm_msg(MERROR,"source_scan","compose fragment:%d current size:%d (%d)"
@@ -597,6 +620,7 @@
             return EB_ERROR;
           }
         }
+        }
       } /* skip user_build */

if

(

cm_register_transition(TR_PRESTART, tr_prestart)!

= CM_SUCCESS)

if

(

cm_register_transition(TR_STOP, tr_stop)!

= CM_SUCCESS)

INT source_unbooking

(

nfrag

)

Definition at line 46 of file patch_mevb.cpp.

 {   
   INT i, status;
 
   /* Skip unbooking if already done */
+#if 0
   if (ebch[0].pfragment == NULL)
     return EB_SUCCESS;
+#endif
 
   /* unbook all source channels */
   for (i=nfrag-1; i>=0 ; i--)
   {
     bm_empty_buffers();
 
+    if (ebch[i].set.emask)
+    {
     /* Remove event ID registration */
     status = bm_delete_request(ebch[i].req_id);
     if (debug)
@@ -435,6 +451,7 @@
       return status;
     }
   }
+  }

INT ybos_event_swap

(

DWORD *

pevt)

Variable Documentation

home data midas examples eventbuilder mevb Created v $Log

Definition at line 3 of file patch_mevb.cpp.

home data midas examples eventbuilder mevb Created by

Definition at line 3 of file patch_mevb.cpp.

home data midas examples eventbuilder mevb c

Definition at line 3 of file patch_mevb.cpp.

Referenced by A3818UpgradeFromFile(), A3818UpgradeFromMem(), PulseTemplate::AddPulse(), checkCommand(), cnaf_callback(), con_kbhit(), cvUpgrade(), WireMap::Load(), main(), MD5Transform(), processIsland(), and Quad::Quad().

else

Definition at line 94 of file patch_mevb.cpp.

BOOL event_mismatch

Definition at line 75 of file patch_mevb.cpp.

Referenced by source_scan().

BOOL found

Definition at line 75 of file patch_mevb.cpp.

Referenced by epics_ca_connection_handler(), epics_ca_event_handler(), epics_ca_init(), PrePulse::FindPrePulses(), and source_scan().

BANK_HEADER* psbh

Definition at line 77 of file patch_mevb.cpp.

Referenced by eb_mfragment_add(), and source_scan().

home data midas examples eventbuilder mevb Created v v this pulls in Pierre s CVS changes to the generic eventbuilder code Revision

Definition at line 3 of file patch_mevb.cpp.

status = SUCCESS

Definition at line 79 of file patch_mevb.cpp.

Referenced by begin_of_run(), caenV767_eor(), caenV767_fifo_read(), caenV767_poll1(), caenV767_poll_live(), caenV767_read(), caenV767_read1(), cam16i_q(), cam16i_r(), cam16o_q(), cam24i(), cam24i_q(), cam24i_r(), cam24o_q(), cam8i(), cam8i_q(), cam_inhibit_test(), cam_init(), cam_interrupt_test(), camc_q(), cami(), PulseTemplate::Chi2Fit(), close_buffers(), consider_start(), display(), dt5720_init(), eb_yfragment_add(), end_of_run(), epics_ca(), epics_ca_connection_handler(), epics_ca_exit(), epics_ca_get(), epics_ca_init(), epics_ca_set(), epics_ca_set_all(), epics_ca_set_label(), epics_ca_set_pending(), eraseBlock(), floppy_ttl_init(), frontend_init(), frontend_loop(), ge_ln2_read(), get_run_number(), getObjectFromSocket(), handFlush(), initialize(), logger_root(), lrs2249_read(), main(), new_fadc_pre_bor(), odb_connect(), odb_find_key(), odb_get_bool(), odb_get_boolarray(), odb_get_dword(), odb_get_int(), odb_get_word(), openSocket(), pio_read(), pio_write(), pre_begin_of_run(), process_event(), read_periodic_event(), read_trigger_event(), receivePackets(), register_equipment(), release_dma(), replog(), TOnlineFrame::runMacro(), scan_fragment(), scheduler(), send_event(), sis3600_eor(), sis3600_fifo_read(), sis3600_poll1(), sis3600_poll_live(), sis3600_read(), sis3600_read1(), source_booking(), source_scan(), source_unbooking(), start_dma(), tr_pause(), tr_prepause(), tr_prestart(), tr_prestop(), tr_resume(), tr_start(), tr_stop(), TVacuumData::TVacuumData(), update_odb(), v1290_DataRead(), v1724_init(), vacuum_gauge_read(), vme_close(), vme_dma_read(), vme_dma_write(), vme_read_d16_checked(), vme_read_d32_checked(), vme_read_d8_checked(), vme_write_d16_checked(), vme_write_d32_checked(), vme_write_d8_checked(), vmedrv_interrupt(), vmic_read_input(), and vmic_ttl_init().

tr_prestart

Definition at line 125 of file patch_mevb.cpp.

Referenced by main().

tr_stop

Definition at line 128 of file patch_mevb.cpp.

Referenced by main().