/********************************************************************\

  Name:         msgdump.c
  Created by:   Stefan Ritt

  Contents:     MIDAS message dump program. Attaches to the system
                message buffer and extracts messages.

  $Id$

\********************************************************************/

#include "midas.h"
#include "msystem.h"

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

char *type_name[] = {
   "ERROR",
   "INFO",
   "DEBUG" "USER",
   "LOG",
   "TALK",
   "CALL",
};

int main(int argc, char **argv)
{
   int msg_buf, i, status, size, id;
   char event[10000];
   EVENT_HEADER *pheader;
   BUFFER_HEADER buffer_header;
   char *pstring;
   char type_string[100];
   FILE *f;

   if (argc < 2) {
      printf("Usage: msgdump [-dwc]                             \n");
      printf("                                                  \n");
      printf("       -d display messages on screen              \n");
      printf("       -c display clients producing messages      \n");
      printf("       -w write messages to MSGDUMP.ASC           \n\n");
      return 1;
   }

   status = cm_connect_experiment("", "", "MsgDump", NULL);
   if (status != CM_SUCCESS)
      return 1;

   bm_open_buffer(MESSAGE_BUFFER_NAME, MESSAGE_BUFFER_SIZE, &msg_buf);

   bm_get_buffer_info(msg_buf, &buffer_header);

   bm_request_event(msg_buf, EVENTID_ALL, TRIGGER_ALL, GET_NONBLOCKING, &id, NULL);

   pstring = event + sizeof(EVENT_HEADER);
   pheader = (EVENT_HEADER *) event;

   if (argv[1][1] == 'd') {
      printf("Displaying messages. Hit Ctrl-C to abort.\n");
      printf("=========================================\n\n");

      do {
         size = 10000;
         status = bm_receive_event(msg_buf, event, &size, BM_WAIT);

         if (status != BM_SUCCESS) {
            printf("Error receiving event.\n");
            return 0;
         }

         type_string[0] = 0;
         for (i = 0; i < 8; i++)
            if (pheader->trigger_mask & (1 << i))
               strcat(type_string, type_name[i]);

         printf("serial %d, type %s, time %1.3lf\n",
                pheader->serial_number, type_string, pheader->time_stamp / 1000.0);
         printf("%s\n\n", pstring);
      } while (1);
   }

   if (argv[1][1] == 'c') {
      printf("Clients attached to current message system:\n");
      printf("===========================================\n\n");

      for (i = 0; i < buffer_header.max_client_index; i++)
         if (buffer_header.client[i].pid)
            printf("#%d: pid=%d name=%s\n", i, buffer_header.client[i].pid,
                   buffer_header.client[i].name);
   }

   if (argv[1][1] == 'w') {
      printf("Message collecting active, hit ENTER to stop.\n");

      getchar();

      printf("Writing MSGDUMP.ASC ...\n");

      f = fopen("MSGDUMP.ASC", "w");

      bm_get_buffer_info(msg_buf, &buffer_header);

      do {
         size = 10000;
         status = bm_receive_event(msg_buf, event, &size, BM_NO_WAIT);
         if (status == BM_ASYNC_RETURN) {
            fclose(f);
            break;
         }

         type_string[0] = 0;
         for (i = 0; i < 8; i++)
            if (pheader->trigger_mask & (1 << i))
               strcat(type_string, type_name[i]);

         fprintf(f, "serial %d, type %s, time %1.3lf\n",
                 pheader->serial_number, type_string, pheader->time_stamp / 1000.0);
         fprintf(f, "%s\n\n", pstring);
      } while (1);
   }


   cm_disconnect_experiment();
   return 1;
}