tmfe_rev0.cxx File Reference

#include <stdio.h>
#include <stdarg.h>
#include <assert.h>
#include <sys/time.h>
#include "tmfe_rev0.h"
#include "midas.h"
#include "msystem.h"
#include "mrpc.h"
#include "mstrlcpy.h"

Include dependency graph for tmfe_rev0.cxx:

Go to the source code of this file.

Functions
static int	tmfe_rpc_thread (void *param)
static int	tmfe_periodic_thread (void *param)
static INT	rpc_callback (INT index, void *prpc_param[])
static INT	tr_start (INT runno, char *errstr)
static INT	tr_stop (INT runno, char *errstr)
static INT	tr_pause (INT runno, char *errstr)
static INT	tr_resume (INT runno, char *errstr)
static INT	tr_startabort (INT runno, char *errstr)

Function Documentation

rpc_callback()

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

static

Definition at line 389 of file tmfe_rev0.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);
 
   TMFE* mfe = TMFE::Instance();
 
   for (unsigned i=0; i<mfe->fRpcHandlers.size(); i++) {
      std::string r = mfe->fRpcHandlers[i]->HandleRpc(cmd, args);
      if (r.length() > 0) {
         //printf("Handler reply [%s]\n", C(r));
         mstrlcpy(return_buf, r.c_str(), return_max_length);
         return RPC_SUCCESS;
      }
   }
 
   return_buf[0] = 0;
   return RPC_SUCCESS;
}

Here is the call graph for this function:

tmfe_periodic_thread()

static int tmfe_periodic_thread ( void *  param )

static

Definition at line 232 of file tmfe_rev0.cxx.

{
   fprintf(stderr, "tmfe_periodic_thread: periodic thread started\n");
   TMFE* mfe = TMFE::Instance();
   mfe->fPeriodicThreadRunning = true;
   while (!mfe->fShutdownRequested && !mfe->fPeriodicThreadShutdownRequested) {
      mfe->EquipmentPeriodicTasks();
      int status = ss_suspend(1000, 0);
      if (status == RPC_SHUTDOWN || status == SS_ABORT || status == SS_EXIT) {
         mfe->fShutdownRequested = true;
         fprintf(stderr, "tmfe_periodic_thread: ss_susend() status %d, shutdown requested...\n", status);
      }
   }
   ss_suspend_exit();
   fprintf(stderr, "tmfe_periodic_thread: periodic thread stopped\n");
   mfe->fPeriodicThreadRunning = false;
   return SUCCESS;
}

Here is the call graph for this function:

Here is the caller graph for this function:

tmfe_rpc_thread()

static int tmfe_rpc_thread ( void *  param )

static

Definition at line 209 of file tmfe_rev0.cxx.

{
   fprintf(stderr, "tmfe_rpc_thread: RPC thread started\n");
 
   int msec = 1000;
   TMFE* mfe = TMFE::Instance();
   mfe->fRpcThreadRunning = true;
   ss_suspend_set_rpc_thread(ss_gettid());
   while (!mfe->fShutdownRequested && !mfe->fRpcThreadShutdownRequested) {
 
      int status = cm_yield(msec);
 
      if (status == RPC_SHUTDOWN || status == SS_ABORT) {
         mfe->fShutdownRequested = true;
         fprintf(stderr, "tmfe_rpc_thread: cm_yield(%d) status %d, shutdown requested...\n", msec, status);
      }
   }
   ss_suspend_exit();
   fprintf(stderr, "tmfe_rpc_thread: RPC thread stopped\n");
   mfe->fRpcThreadRunning = false;
   return SUCCESS;
}

Here is the call graph for this function:

tr_pause()

static INT tr_pause ( INT  runno, char *  errstr  )

static

Definition at line 448 of file tmfe_rev0.cxx.

{
   cm_msg(MINFO, "tr_pause", "tr_pause");
 
   TMFE* mfe = TMFE::Instance();
   for (unsigned i=0; i<mfe->fRpcHandlers.size(); i++) {
      mfe->fRpcHandlers[i]->HandlePauseRun();
   }
 
   return SUCCESS;
}

Here is the call graph for this function:

tr_resume()

static INT tr_resume ( INT  runno, char *  errstr  )

static

Definition at line 460 of file tmfe_rev0.cxx.

{
   cm_msg(MINFO, "tr_resume", "tr_resume");
 
   TMFE* mfe = TMFE::Instance();
   for (unsigned i=0; i<mfe->fRpcHandlers.size(); i++) {
      mfe->fRpcHandlers[i]->HandleResumeRun();
   }
 
   return SUCCESS;
}

Here is the call graph for this function:

tr_start()

static INT tr_start ( INT  runno, char *  errstr  )

static

Definition at line 413 of file tmfe_rev0.cxx.

{
   cm_msg(MINFO, "tr_start", "tr_start");
 
   TMFE* mfe = TMFE::Instance();
   
   for (unsigned i=0; i<mfe->fEquipments.size(); i++) {
      mfe->fEquipments[i]->ZeroStatistics();
      mfe->fEquipments[i]->WriteStatistics();
   }
 
   for (unsigned i=0; i<mfe->fRpcHandlers.size(); i++) {
      mfe->fRpcHandlers[i]->HandleBeginRun();
   }
 
   return SUCCESS;
}

Here is the call graph for this function:

tr_startabort()

static INT tr_startabort ( INT  runno, char *  errstr  )

static

Definition at line 472 of file tmfe_rev0.cxx.

{
   cm_msg(MINFO, "tr_startabort", "tr_startabort");
 
   TMFE* mfe = TMFE::Instance();
   for (unsigned i=0; i<mfe->fRpcHandlers.size(); i++) {
      mfe->fRpcHandlers[i]->HandleStartAbortRun();
   }
 
   return SUCCESS;
}

Here is the call graph for this function:

tr_stop()

static INT tr_stop ( INT  runno, char *  errstr  )

static

Definition at line 431 of file tmfe_rev0.cxx.

{
   cm_msg(MINFO, "tr_stop", "tr_stop");
 
   TMFE* mfe = TMFE::Instance();
   for (unsigned i=0; i<mfe->fRpcHandlers.size(); i++) {
      mfe->fRpcHandlers[i]->HandleEndRun();
   }
 
   for (unsigned i=0; i<mfe->fEquipments.size(); i++) {
      mfe->fEquipments[i]->WriteStatistics();
   }
 
 
   return SUCCESS;
}

Here is the call graph for this function: