/*
    This code is the Statistics/Rates task
*/


#include <string.h>
#include <stdio.h>
#include <sys/types.h>
#include <stdlib.h> /* getenv, exit */
#include <errno.h>

#include <pthread.h>
#include <unistd.h>

#include "common.h"
#include "message.h"

#include "stats.h"
#include "netvar.h"

void MERGE_ZeroStats();

int * StatsMem[NUMCOUNTERS];   /* MAXCOUNTERS + (MAXCOUNTERS * (NUMLINKS+2));  MAXOUNTERS=64  NUMLINKS=64  */
int * RatesMem[NUMCOUNTERS];

int Counts[NUMCOUNTERS];

char message [160];    /*  message logger message buffer   */


/* --------------------------------------------------------------------- */


void MERGE_Stats()
{

   int i, j;
   int ScratchNetInt;
   int *delay;
   int *MERGE_State;
   int maxcounters=MAXCOUNTERS;
   int numcounters=NUMCOUNTERS;


     printf("MERGE Statistics thread starting\n");

    signal_block();       //    mask off signals handled by the main thread

//   adjust priority - run just above main data acquisition program

     nice(-2);

//    initialise Stats Rates NetVar arrays

       readNetInt("MERGE_Stats", 0, 1, &ScratchNetInt); 
       for (i=1; i<(numcounters/maxcounters); i++) {
          sprintf(message,"MERGE_Stats%d",i);
          readNetInt(message, 0, 1, &ScratchNetInt);
       }

       readNetInt("MERGE_Rates", 0, 1, &ScratchNetInt); 
       for (i=1; i<(numcounters/maxcounters); i++) {
          sprintf(message,"MERGE_Rates%d",i);
          readNetInt(message, 0, 1, &ScratchNetInt);
       }

       for(i=0;i<numcounters;i++) {
           Counts[i]=0;
           if (i < maxcounters) {
               StatsMem[i] = (int *)getNetIntArrayMem("MERGE_Stats",i);
               RatesMem[i] = (int *)getNetIntArrayMem("MERGE_Rates",i);
           } else {
               j = i-((i/maxcounters)*maxcounters);
               sprintf(message,"MERGE_Stats%d",(i/maxcounters));
               StatsMem[i] = (int *)getNetIntArrayMem(message,j);
               sprintf(message,"MERGE_Rates%d",(i/maxcounters));
               RatesMem[i] = (int *)getNetIntArrayMem(message,j);
           }
       }

   MERGE_State = (int *)getNetIntMem("MERGE_State");   /* data acquisition state */
   delay = (int *)getNetIntMem("MERGE_StatsTime");
   if (*delay == 0) *delay = 1;

  for (;;)
  {

     if (*MERGE_State != GOING) {

         for(i=0;i<numcounters;i++) {*RatesMem[i] = 0;}
     }

     usleep ((*delay)*1000000);  /* delay in secs */ 

       readNetInt("MERGE_ZeroStats", 0, 1, &ScratchNetInt);
       if (ScratchNetInt == 1) {
           assignNetInt("MERGE_ZeroStats", 0, 1, 0);
           MERGE_ZeroStats();
       }

//    update rates

     for(i=0;i<numcounters;i++) {
         *RatesMem[i]=(*StatsMem[i]-Counts[i])/(*delay);
         Counts[i]=*StatsMem[i];
     }

  }
}

/* --------------------------------------------------------------------- */

void MERGE_ZeroStats()
{
   int i;

/*    clear stats counters   */

   for(i=0;i<NUMCOUNTERS;i++) {*StatsMem[i] = 0; Counts[i] = 0;}

  printf("MERGE Statistics counters now cleared\n");
}

/* --------------------------------------------------------------------- */