tmfe_example_multithread.cxx File Reference

#include <stdio.h>
#include <signal.h>
#include <assert.h>
#include <stdlib.h>
#include <unistd.h>
#include <math.h>
#include "midas.h"
#include "tmfe.h"

Include dependency graph for tmfe_example_multithread.cxx:

Go to the source code of this file.

Classes
class	Myfe

Functions
static void	usage ()
int	main (int argc, char *argv[])

Function Documentation

main()

int main	(	int	argc,
		char *	argv[]
	)

Definition at line 89 of file tmfe_example_multithread.cxx.

{
   setbuf(stdout, NULL);
   setbuf(stderr, NULL);
 
   signal(SIGPIPE, SIG_IGN);
 
   std::vector<std::string> eq_args;
 
   //std::string name = "";
   //
   //if (argc == 2) {
   //   name = argv[1];
   //} else {
   //   usage(); // DOES NOT RETURN
   //}
 
   TMFE* mfe = TMFE::Instance();
 
   TMFeResult result = mfe->Connect("tmfe_example_mt", __FILE__);
   if (result.error_flag) {
      fprintf(stderr, "Cannot connect to MIDAS, error \"%s\", bye.\n", result.error_message.c_str());
      return 1;
   }
 
   //mfe->SetWatchdogSec(0);
 
   TMFeEquipment* eq = new Myfe("tmfe_example_mt", __FILE__);
   eq->fEqConfEventID = 1;
   eq->fEqConfLogHistory = 1;
   eq->fEqConfPeriodMilliSec = 1000; // milliseconds
   eq->fEqConfBuffer = "SYSTEM";
 
   eq->EqInit(eq_args);
   eq->EqSetStatus("Starting...", "white");
 
   mfe->AddRpcHandler(eq);
 
   //mfe->SetTransitionSequenceStart(910);
   //mfe->SetTransitionSequenceStop(90);
 
   //mfe->DeregisterTransitionPause();
   //mfe->DeregisterTransitionResume();
 
   //mfe->RegisterTransitionStartAbort();
 
   printf("Main thread is %s\n", TMFE::GetThreadId().c_str());
 
   mfe->StartRpcThread();
   //mfe->StartPeriodicThread();
 
   eq->EqSetStatus("Started...", "white");
 
   while (!mfe->fShutdownRequested) {
      ::sleep(1);
   }
 
   mfe->Disconnect();
 
   return 0;
}

Here is the call graph for this function:

usage()

static void usage ( )

static

Definition at line 83 of file tmfe_example_multithread.cxx.

{
   fprintf(stderr, "Usage: tmfe_example_mt ...\n");
   exit(1);
}