minife.c File Reference

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

Include dependency graph for minife.c:

Go to the source code of this file.

Functions
INT	tr_start (INT rn, char *error)
INT	tr_stop (INT rn, char *error)
int	main (void)

Variables
INT	running
INT	serial = 0
INT	run_number = 0
HNDLE	hBuf

Function Documentation

main()

int main

(

void

)

Definition at line 55 of file minife.c.

{
   INT status, size, *pdata, id=0;
   INT convert_flags;
   DWORD last_time = 0;
   char event[2000];
   char host_name[256];
   char dash[] = "-/|\\";
   BOOL blocked = FALSE;
 
#ifdef OS_VXWORKS
   strcpy(host_name, ahost_name);
#else
   printf("Host to connect: ");
   ss_gets(host_name, 256);
#endif
 
   /* now connect to server */
   status = cm_connect_experiment(host_name, "", "MiniFE", NULL);
   if (status != CM_SUCCESS)
      return 1;
 
   if (cm_register_transition(TR_START, tr_start, 500) != CM_SUCCESS ||
       cm_register_transition(TR_STOP, tr_stop, 500) != CM_SUCCESS) {
      printf("Cannot start server");
      return 0;
   }
#ifdef _DEBUG
   cm_set_watchdog_params(TRUE, 0);
#endif
 
   /* open the "system" buffer, 2x maximal event size */
   bm_open_buffer(EVENT_BUFFER_NAME, 2*MAX_EVENT_SIZE, &hBuf);
 
   /* set the buffer cache size on the server */
   bm_set_cache_size(hBuf, 0, 100000);
 
   pdata = (INT *) (event + sizeof(EVENT_HEADER));
   size = 1000;
 
   /* compose an event */
   bm_compose_event((EVENT_HEADER *) event, 1, 1, size, serial);
 
   pdata[0] = size;             /* simulate data for consume.exe */
   pdata[size / 4 - 1] = size;
 
   /* convert test data if necessary to format on server */
   rpc_get_convert_flags(&convert_flags);
   if (convert_flags) {
      rpc_convert_single(&pdata[0], TID_DWORD, RPC_OUTGOING, convert_flags);
      rpc_convert_single(&pdata[size / 4 - 1], TID_DWORD, RPC_OUTGOING, convert_flags);
   }
 
   do {
      if (!running) {
         /* if run is not started, call yield with a timeout of 1s */
         status = cm_yield(1000);
         if (status == RPC_SHUTDOWN || status == SS_ABORT)
            break;
      } else {
         /* if run is started, call yield with a timeout of 0 once each second.
            This minimizes the calls to select() inside rpc_server_yield and
            increases the network speed */
         if (ss_millitime() - last_time > 300) {
            printf("%c\r", dash[id++ % 4]);
            fflush(stdout);
 
            status = cm_yield(0);
            if (status == RPC_SHUTDOWN || status == SS_ABORT)
               break;
            last_time = ss_millitime();
         }
      }
 
      /* if run is started, send event */
      if (running) {
         /* only compose new event if not blocked by previous send */
         if (!blocked) {
            /* increment serial number */
            ((EVENT_HEADER *) event)->serial_number = serial++;
         }
 
         status = rpc_send_event(hBuf, event, size + sizeof(EVENT_HEADER), BM_NO_WAIT, 1);
         if (status == BM_ASYNC_RETURN)
            blocked = TRUE;
         else if (status == BM_SUCCESS)
            blocked = FALSE;
         else if (status != BM_SUCCESS) {
            printf("Error sending event");
            goto error;
         }
 
      }
 
   } while (run_number < 1000);
 
   cm_disconnect_experiment();
 
 error:
 
   return 1;
}

Here is the call graph for this function:

tr_start()

INT tr_start	(	INT	rn,
		char *	error
	)

Definition at line 25 of file minife.c.

{
   printf("Start run %d\n", rn);
 
   serial = 0;
   run_number = rn;
   running = TRUE;
 
   return CM_SUCCESS;
}

Here is the caller graph for this function:

tr_stop()

INT tr_stop	(	INT	rn,
		char *	error
	)

Definition at line 36 of file minife.c.

{
   printf("Stop run %d -", rn);
 
   running = FALSE;
 
   rpc_flush_event();              /* send events in TCP cache */
   bm_flush_cache(hBuf, BM_WAIT);  /* flush buffer cache */
 
   printf(" done\n");
 
   return CM_SUCCESS;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

hBuf

HNDLE hBuf

Definition at line 23 of file minife.c.

run_number

INT run_number = 0

Definition at line 21 of file minife.c.

running

INT running

Definition at line 19 of file minife.c.

serial

INT serial = 0

Definition at line 20 of file minife.c.