client_options.cpp

这是广泛使用的通信开源项目,对于大容量,高并发的通讯要求完全能够胜任,他广泛可用于网络游戏医学图像网关的高qos要求.更详细的内容可阅读相应的材料

/**
 * @file Client_Options.cpp
 *
 * Client_Options.cpp,v 1.3 2002/04/19 19:13:45 ossama Exp
 *
 * @author Carlos O'Ryan <[e-mail]>
 */

#include "Client_Options.h"

#include "ace/Arg_Shifter.h"
#include "ace/Log_Msg.h"
#include "ace/OS.h"

ACE_RCSID (TAO_PERF_RTEC,
           Client_Options,
           "Client_Options.cpp,v 1.3 2002/04/19 19:13:45 ossama Exp")

Client_Options::Client_Options (int &argc, char *argv[])
  : ior ("file://test.ior")
  , iterations (1000)
  , nthreads (0)
  , high_priority_period (0)
  , high_priority_workload (0)
  , low_priority_period (0)
  , low_priority_workload (0)
  , low_priority_consumers (0)
  , dump_history (0)
  , use_rt_corba (0)
  , global_low_priority_rate (0)
  , unique_low_priority_event (0)
  , funky_supplier_publication (0)
  , high_priority_is_last (0)
{
  ACE_Arg_Shifter arg_shifter (argc, argv);

  while (arg_shifter.is_anything_left ())
    {
      const char *arg = arg_shifter.get_current ();

      if (ACE_OS::strcmp (arg, "-k") == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              this->ior = arg_shifter.get_current ();
              arg_shifter.consume_arg ();
            }
        }

      else if (option (arg_shifter, "-i", iterations)) {}
      else if (option (arg_shifter, "-n", nthreads)) {}
      else if (option (arg_shifter, "-h", high_priority_period)) {}
      else if (option (arg_shifter, "-l", low_priority_period)) {}
      else if (option (arg_shifter, "-w", low_priority_workload)) {}
      else if (option (arg_shifter, "-v", high_priority_workload)) {}
      else if (option (arg_shifter, "-c", low_priority_consumers)) {}

      else if (boolean_option (arg_shifter, "-d", dump_history)) {}
      else if (boolean_option (arg_shifter, "-r", use_rt_corba)) {}
      else if (boolean_option (arg_shifter, "-g", global_low_priority_rate)) {}
      else if (boolean_option (arg_shifter, "-u", unique_low_priority_event)) {}
      else if (boolean_option (arg_shifter, "-f", funky_supplier_publication)) {}
      else if (boolean_option (arg_shifter, "-x", high_priority_is_last)) {}

      else
        {
          arg_shifter.ignore_arg ();
        }
    }
}

int
Client_Options::option (ACE_Arg_Shifter &arg_shifter,
                 const char *option_name,
                 int &option_value)
{
  if (ACE_OS::strcmp (arg_shifter.get_current (), option_name) != 0)
    return 0;
  arg_shifter.consume_arg ();
  if (arg_shifter.is_parameter_next ())
    {
      option_value = ACE_OS::atoi (arg_shifter.get_current ());
      arg_shifter.consume_arg ();
    }
  else
    {
      ACE_DEBUG ((LM_DEBUG,
                  "Missing value for option '%s'\n", option_name));
    }
  return 1;
}

int
Client_Options::boolean_option (ACE_Arg_Shifter &arg_shifter,
                         const char *option_name,
                         int &option_value)
{
  if (ACE_OS::strcmp (arg_shifter.get_current (), option_name) != 0)
    return 0;
  arg_shifter.consume_arg ();
  option_value = 1;
  return 1;
}