TAO/utils/logWalker/logWalker.cpp

   1 // Utility to traverse and simplify verbose log files.
   2 //
   3 // The goal is to take a collection of log files and extract details
   4 // related to connections, objects, and invocations to separate out
   5 // perhaps multiple processes, or at least threads to get a sense of
   6 // invocation lifecycle.
   7 //
   8 // Ideally a collection of files could be used so that invocations
   9 // that traverse many processes could be tracked.
  10
  11 #include "ace/OS_NS_stdio.h"
  12 #include "ace/Log_Msg.h"
  13 #include "ace/streams.h"
  14 #include "ace/OS_NS_strings.h"
  15 #include "ace/Tokenizer_T.h"
  16
  17 #include "Invocation.h"
  18 #include "PeerObject.h"
  19 #include "PeerProcess.h"
  20 #include "Session.h"
  21 #include "Log.h"
  22
  23 ACE_TCHAR *outfile = 0;
  24
  25 void
  26 parse_filename (Session &session, char * buffer)
  27 {
  28   Log log(session);
  29   if (ACE_OS::strchr(buffer,'=') == 0)
  30     {
  31       log.process_file (ACE_TEXT_CHAR_TO_TCHAR(buffer));
  32     }
  33   else
  34     {
  35       ACE_Tokenizer_T<char> tokens(buffer);
  36       tokens.delimiter_replace('=', 0);
  37       char *alias = tokens.next();
  38       ACE_TString filename = ACE_TEXT_CHAR_TO_TCHAR(tokens.next());
  39       log.process_file (filename.c_str(), alias);
  40     }
  41 }
  42
  43 void
  44 parse_manifest (Session &session, ACE_TCHAR *filename)
  45 {
  46   // get list of logs, aliases, and other config from file
  47   ifstream strm (ACE_TEXT_ALWAYS_CHAR (filename));
  48   if (!strm.is_open())
  49     {
  50       ACE_DEBUG ((LM_DEBUG,"cannot open manifest file %C\n", filename));
  51       return;
  52     }
  53   char buffer[500];
  54   while (!strm.eof())
  55     {
  56       strm.getline(buffer,500);
  57       if (buffer[0] == '\0' ||
  58           buffer[0] == '#')
  59         {
  60           continue;
  61         }
  62       if (buffer[0] == '-')
  63         {
  64           if (buffer[1] == 'o')
  65             {
  66               if (session.has_dir())
  67                 {
  68                   ACE_ERROR ((LM_ERROR,
  69                               "supply either output file "
  70                               "or directory but not both\n"));
  71                   ACE_OS::exit (0);
  72                 }
  73               session.outfile (buffer+3);
  74               continue;
  75             }
  76           if (buffer[1] == 'd')
  77             {
  78               if (session.has_outfile())
  79                 {
  80                   ACE_ERROR ((LM_ERROR,
  81                               "supply either output file "
  82                               "or directory but not both\n"));
  83                   ACE_OS::exit (0);
  84                 }
  85               if (buffer[2] == 'd')
  86                 {
  87                   session.make_dir (buffer+4, true);
  88                 }
  89               else
  90                 {
  91                   session.make_dir (buffer+3, false);
  92                 }
  93               continue;
  94             }
  95           if (buffer[1] == 't')
  96             {
  97               Session::set_tao_version (ACE_TEXT_CHAR_TO_TCHAR (buffer + 3));
  98               continue;
  99             }
 100           if (buffer[1] == 'a')
 101             {
 102               session.alternate_address(buffer+3);
 103               continue;
 104             }
 105           if (buffer[1] == 'p')
 106             {
 107               session.default_service (buffer+3);
 108               continue;
 109             }
 110         }
 111       parse_filename (session, buffer);
 112     }
 113 }
 114
 115 void
 116 print_help ()
 117 {
 118   ACE_DEBUG ((LM_DEBUG, "tao_logWalker recongizes the following arguments\n"));
 119   ACE_DEBUG ((LM_DEBUG, "-o <filename> - write all output to specified file\n"));
 120   ACE_DEBUG ((LM_DEBUG, "-d[d] <directory> - create separate output files, one per log, and put them in specified directory.\n   Either -o or -d may be set but not both. Default output to stdout.\n   Use -dd to further split thread and peer process details onto multiple files."));
 121   ACE_DEBUG ((LM_DEBUG, "-m <manifest> - Take inputs from named manifest file\n"));
 122   ACE_DEBUG ((LM_DEBUG, "-t <1.5 .. 2.0>  - set source TAO version, default 2.0\n"));
 123   ACE_DEBUG ((LM_DEBUG, "-a <name=address> - bind an alias to a host address.\n   Repeat as many times as necessary.\n"));
 124   ACE_DEBUG ((LM_DEBUG, "-p <service=address> - bind a service such as Naming to a specific peer endpoint address\n"));
 125   ACE_DEBUG ((LM_DEBUG, "[alias=]filename - provide a source file with an altenate name"));
 126 }
 127
 128 int
 129 ACE_TMAIN (int argc, ACE_TCHAR **argv)
 130 {
 131   if (argc < 2)
 132     {
 133       ACE_ERROR ((LM_ERROR,
 134                   " At least one log file must be specified\n"));
 135       return 0;
 136     }
 137   Session session;
 138   for (int i = 1; i < argc; i++)
 139     {
 140       if (ACE_OS::strcasecmp (argv[i], ACE_TEXT("-o")) == 0)
 141         {
 142           if (session.has_dir())
 143             ACE_ERROR_RETURN ((LM_ERROR,
 144                                "supply either output file "
 145                                "or directory but not both\n"), 0);
 146           session.outfile(ACE_TEXT_ALWAYS_CHAR(argv[++i]));
 147           continue;
 148         }
 149       if (ACE_OS::strcasecmp (argv[i], ACE_TEXT("-d")) == 0 ||
 150           ACE_OS::strcasecmp (argv[i], ACE_TEXT("-dd")) == 0)
 151         {
 152           if (session.has_outfile())
 153             ACE_ERROR_RETURN ((LM_ERROR,
 154                                "supply either output file "
 155                                "or directory but not both\n"), 0);
 156           bool split = ACE_OS::strcasecmp (argv[i], ACE_TEXT("-dd")) == 0;
 157           session.make_dir (ACE_TEXT_ALWAYS_CHAR(argv[++i]), split);
 158           continue;
 159         }
 160       if (ACE_OS::strcasecmp (argv[i], ACE_TEXT("-m")) == 0)
 161         {
 162           parse_manifest (session, argv[++i]);
 163           continue;
 164         }
 165       if (ACE_OS::strcasecmp (argv[i], ACE_TEXT("-t")) == 0)
 166         {
 167           if (Session::set_tao_version (argv[++i]))
 168             continue;
 169           else
 170             ACE_ERROR_RETURN ((LM_ERROR,
 171                                ACE_TEXT("TAO version must be 1.5, 1.6, 1.7, 1.8, or 2.0 \n")), 0);
 172         }
 173       if (ACE_OS::strcasecmp (argv[i], ACE_TEXT("-a")) == 0)
 174         {
 175           session.alternate_address (ACE_TEXT_ALWAYS_CHAR (argv[++i]));
 176           continue;
 177         }
 178       if (ACE_OS::strcasecmp (argv[i], ACE_TEXT("-p")) == 0)
 179         {
 180           session.default_service (ACE_TEXT_ALWAYS_CHAR (argv[++i]));
 181           continue;
 182         }
 183       if (argv[i][0] == ACE_TEXT('-'))
 184         {
 185           print_help ();
 186           return 0;
 187         }
 188
 189       Log log(session);
 190
 191       parse_filename (session, ACE_TEXT_ALWAYS_CHAR (argv[i]));
 192     }
 193
 194   session.reconcile();
 195
 196   session.dump();
 197
 198   return 0;
 199 }