fejrpc.cxx File Reference

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <stdint.h>
#include <sys/time.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <errno.h>
#include <math.h>
#include <ctype.h>
#include <assert.h>
#include <string.h>
#include "midas.h"
#include "mrpc.h"
#include "mfe.h"

Include dependency graph for fejrpc.cxx:

Go to the source code of this file.

Macros
#define	FE_NAME   "fejrpc"
#define	EQ_NAME   "RpcExample"
#define	EQ_EVID   1

Functions
INT	frontend_init ()
	Frontend initialization.
INT	frontend_exit ()
	Frontend exit.
INT	begin_of_run (INT run_number, char *error)
	Begin of Run.
INT	end_of_run (INT run_number, char *error)
	End of Run.
INT	pause_run (INT run_number, char *error)
	Pause Run.
INT	resume_run (INT run_number, char *error)
	Resume Run.
INT	frontend_loop ()
	Frontend loop.
int	read_slow_event (char *pevent, int off)
static int	configure ()
INT	rpc_callback (INT index, void *prpc_param[])
INT	poll_event (INT source, INT count, BOOL test)
INT	interrupt_configure (INT cmd, INT source, PTYPE adr)
double	get_time ()

Variables
const char *	frontend_name = FE_NAME
const char *	frontend_file_name = __FILE__
BOOL	frontend_call_loop = TRUE
INT	display_period = 0
INT	max_event_size = 2000
INT	max_event_size_frag = 0
INT	event_buffer_size = 10*2000
INT	gbl_run_number
EQUIPMENT	equipment []
int	count_slow = 0

Macro Definition Documentation

EQ_EVID

#define EQ_EVID   1

Definition at line 30 of file fejrpc.cxx.

EQ_NAME

#define EQ_NAME   "RpcExample"

Definition at line 29 of file fejrpc.cxx.

FE_NAME

#define FE_NAME   "fejrpc"

Definition at line 28 of file fejrpc.cxx.

Function Documentation

begin_of_run()

INT begin_of_run	(	INT	run_number,
		char *	error
	)

Begin of Run.

Called every run start transition. Set equipment status in ODB, start acquisition on the modules.

Parameters

[in]	run_number	Number of the run being started
[out]	error	Can be used to write a message string to midas.log

Definition at line 188 of file fejrpc.cxx.

{
   cm_msg(MINFO, "begin_of_run", "Begin run %d", run_number);
 
   gbl_run_number = run_number;
 
   configure();
   
   count_slow = 0;
   
   return SUCCESS;
}

Here is the call graph for this function:

configure()

static int configure ( )

static

Definition at line 122 of file fejrpc.cxx.

{
   int size, status;
   int example_int = 0;
 
   size = sizeof(int);
   status = db_get_value(hDB, 0, "/Equipment/" EQ_NAME "/Settings/example_int", &example_int, &size, TID_INT, TRUE);
   printf("Example_int: %d\n", example_int);
   
   return SUCCESS;
}

Here is the call graph for this function:

Here is the caller graph for this function:

end_of_run()

INT end_of_run	(	INT	run_number,
		char *	error
	)

End of Run.

Called every stop run transition. Set equipment status in ODB, stop acquisition on the modules.

Parameters

[in]	run_number	Number of the run being ended
[out]	error	Can be used to write a message string to midas.log

Definition at line 203 of file fejrpc.cxx.

{
   cm_msg(MINFO, "end_of_run", "End run %d", run_number);
 
   cm_msg(MINFO, frontend_name, "read %d slow events", count_slow);
 
   return SUCCESS;
}

Here is the call graph for this function:

frontend_exit()

INT frontend_exit

(

void

)

Frontend exit.

Runs at frontend shutdown. Disconnect hardware and set equipment status in ODB

Returns

Midas status code

Definition at line 180 of file fejrpc.cxx.

{
   cm_msg(MINFO, "frontend_exit", "Frontend exit");
   return SUCCESS;
}

Here is the call graph for this function:

frontend_init()

INT frontend_init

(

void

)

Frontend initialization.

Runs once at application startup. We initialize the hardware and optical interfaces and set the equipment status in ODB. We also lock the frontend to once physical cpu core.

Returns

Midas status code

Definition at line 162 of file fejrpc.cxx.

{
   int status;
 
   cm_msg(MINFO, "frontend_init", "Frontend init");
 
   //cm_set_watchdog_params (FALSE, 0);
 
   status = cm_register_function(RPC_JRPC, rpc_callback);
   assert(status == SUCCESS);
 
   configure();
 
   return SUCCESS;
}

Here is the call graph for this function:

frontend_loop()

INT frontend_loop

(

void

)

Frontend loop.

If frontend_call_loop is true, this routine gets called when the frontend is idle or once between every event.

Returns

Midas status code

Definition at line 230 of file fejrpc.cxx.

{
  /* if frontend_call_loop is true, this routine gets called when
     the frontend is idle or once between every event */
  //printf("frontend_loop!\n");
  ss_sleep(10);
  return SUCCESS;
}

Here is the call graph for this function:

get_time()

double get_time

(

)

Definition at line 278 of file fejrpc.cxx.

{
  struct timeval tv;
  gettimeofday(&tv, NULL);
  return tv.tv_sec + 0.000001*tv.tv_usec;
}

Here is the call graph for this function:

interrupt_configure()

INT interrupt_configure	(	INT	cmd,
		INT	source,
		PTYPE	adr
	)

Definition at line 260 of file fejrpc.cxx.

{
  switch(cmd)
    {
    case CMD_INTERRUPT_ENABLE:
      break;
    case CMD_INTERRUPT_DISABLE:
      break;
    case CMD_INTERRUPT_ATTACH:
      break;
    case CMD_INTERRUPT_DETACH:
      break;
    }
  return SUCCESS;
}

pause_run()

INT pause_run	(	INT	run_number,
		char *	error
	)

Pause Run.

Called every pause run transition.

Parameters

[in]	run_number	Number of the run being ended
[out]	error	Can be used to write a message string to midas.log

Returns

Midas status code

Definition at line 214 of file fejrpc.cxx.

{
   cm_msg(MINFO, "pause_run", "Pause run %d", run_number);
   return SUCCESS;
}

Here is the call graph for this function:

poll_event()

INT poll_event	(	INT	source,
		INT	count,
		BOOL	test
	)

Definition at line 247 of file fejrpc.cxx.

{
  if (test) {
    ss_sleep (count);
  }
  return (0);
}

Here is the call graph for this function:

read_slow_event()

int read_slow_event	(	char *	pevent,
		int	off
	)

Definition at line 285 of file fejrpc.cxx.

{
  bk_init32(pevent);
 
  count_slow++;
 
  double* pdatad;
  bk_create(pevent, "SLOW", TID_DOUBLE, (void**)&pdatad);
 
  time_t t = time(NULL);
  pdatad[0] = count_slow;
  pdatad[1] = t;
  pdatad[2] = 100.0*sin(M_PI*t/60);
  //pdatad[0] = 0.0/0.0; // nan
  //pdatad[1] = 1.0/0.0; // inf
  //pdatad[2] = -1.0/0.0; // -inf
  printf("time %d, data %f\n", (int)t, pdatad[2]);
 
  bk_close(pevent, pdatad + 3);
 
  return bk_size(pevent);
}

Here is the call graph for this function:

resume_run()

INT resume_run	(	INT	run_number,
		char *	error
	)

Resume Run.

Called every resume run transition.

Parameters

[in]	run_number	Number of the run being ended
[out]	error	Can be used to write a message string to midas.log

Returns

Midas status code

Definition at line 222 of file fejrpc.cxx.

{
   cm_msg(MINFO, "resume_run", "Resume run %d", run_number);
   return SUCCESS;
}

Here is the call graph for this function:

rpc_callback()

INT rpc_callback	(	INT	index,
		void *	prpc_param[]
	)

Definition at line 136 of file fejrpc.cxx.

{
   const char* cmd  = CSTRING(0);
   const char* args = CSTRING(1);
   char* return_buf = CSTRING(2);
   int   return_max_length = CINT(3);
 
   cm_msg(MINFO, "rpc_callback", "--------> rpc_callback: index %d, max_length %d, cmd [%s], args [%s]", index, return_max_length, cmd, args);
 
   int example_int = strtol(args, NULL, 0);
   int size = sizeof(int);
   int status = db_set_value(hDB, 0, "/Equipment/" EQ_NAME "/Settings/example_int", &example_int, size, 1, TID_INT);
   if (status != DB_SUCCESS)
     printf("db_set_value() status %d\n", status);
 
   char tmp[256];
   time_t now = time(NULL);
   sprintf(tmp, "current time is %d %s", (int)now, ctime(&now));
 
   strlcpy(return_buf, tmp, return_max_length);
 
   return RPC_SUCCESS;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

count_slow

int count_slow = 0

Definition at line 120 of file fejrpc.cxx.

display_period

INT display_period = 0

Definition at line 46 of file fejrpc.cxx.

equipment

EQUIPMENT equipment[]

Initial value:

= {
 
  { EQ_NAME,         
    {
      EQ_EVID, (1<<EQ_EVID), 
      "SYSTEM",              
      EQ_PERIODIC,          
      0,                    
      "MIDAS",              
      TRUE,                 
      RO_RUNNING|RO_STOPPED|RO_PAUSED|RO_ODB, 
      1000,                 
      0,                    
      0,                    
      1,                    
      "", "", ""
    },
    read_slow_event, 
  },
  { "" }
}

Definition at line 72 of file fejrpc.cxx.

                        {
 
  { EQ_NAME,         /* equipment name */
    {
      EQ_EVID, (1<<EQ_EVID), /* event ID, trigger mask */
      "SYSTEM",              /* event buffer */
      EQ_PERIODIC,          /* equipment type */
      0,                    /* event source */
      "MIDAS",              /* format */
      TRUE,                 /* enabled */
      RO_RUNNING|RO_STOPPED|RO_PAUSED|RO_ODB, /* When to read */
      1000,                 /* poll every so milliseconds */
      0,                    /* stop run after this event limit */
      0,                    /* number of sub events */
      1,                    /* history period*/
      "", "", ""
    },
    read_slow_event, /* readout routine */
  },
  { "" }
};

event_buffer_size

INT event_buffer_size = 10*2000

Definition at line 53 of file fejrpc.cxx.

frontend_call_loop

BOOL frontend_call_loop = TRUE

Definition at line 42 of file fejrpc.cxx.

frontend_file_name

const char* frontend_file_name = __FILE__

Definition at line 39 of file fejrpc.cxx.

frontend_name

const char* frontend_name = FE_NAME

Definition at line 36 of file fejrpc.cxx.

gbl_run_number

INT gbl_run_number

Definition at line 66 of file fejrpc.cxx.

max_event_size

INT max_event_size = 2000

Definition at line 49 of file fejrpc.cxx.

max_event_size_frag

INT max_event_size_frag = 0

Definition at line 50 of file fejrpc.cxx.