ACE/performance-tests/Synch-Benchmarks/Perf_Test/Performance_Test_Options.h

   1 /* -*- C++ -*- */
   2 // Option manager for performance tests.
   3
   4 #ifndef _PERFORMANCE_TEST_OPTIONS_H
   5 #define _PERFORMANCE_TEST_OPTIONS_H
   6
   7 #include "ace/config-all.h"
   8
   9 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  10 # pragma once
  11 #endif /* ACE_LACKS_PRAGMA_ONCE */
  12
  13 #include "ace/Profile_Timer.h"
  14 #include "ace/Log_Msg.h"
  15 #include "ace/Thread_Manager.h"
  16 #include "ace/Atomic_Op.h"
  17 #include "ace/svc_export.h"
  18
  19 #if defined (ACE_HAS_THREADS)
  20
  21 class ACE_Svc_Export Performance_Test_Options
  22 {
  23 public:
  24   Performance_Test_Options ();
  25   void   parse_args (int argc, ACE_TCHAR *argv[]);
  26
  27   void   init ();
  28
  29   void   start_timer ();
  30   void   stop_timer ();
  31
  32   void   thr_count (size_t count);
  33   size_t thr_count ();
  34
  35   void   pipe_addr (ACE_TCHAR pipe[]);
  36   ACE_TCHAR *pipe_addr ();
  37
  38   void   mapped_file (ACE_TCHAR filename[]);
  39   ACE_TCHAR *mapped_file ();
  40
  41   void   service_entry (ACE_TCHAR *service_entry);
  42   ACE_TCHAR *service_entry ();
  43
  44   void   sleep_time (size_t count);
  45   size_t sleep_time ();
  46
  47   void   logical_connections (size_t count);
  48   size_t logical_connections ();
  49
  50   void   physical_connections (size_t count);
  51   size_t physical_connections ();
  52
  53   void   consecutive_ports (size_t count);
  54   size_t consecutive_ports ();
  55
  56   void   initial_queue_length (size_t length);
  57   size_t initial_queue_length ();
  58
  59   void   high_water_mark (size_t size);
  60   size_t high_water_mark ();
  61
  62   void   low_water_mark (size_t size);
  63   size_t low_water_mark ();
  64
  65   void   msg_size (size_t size);
  66   size_t msg_size ();
  67
  68   void   iterations (size_t n);
  69   size_t iterations ();
  70
  71   void   n_lwps (size_t n);
  72   size_t n_lwps ();
  73
  74   void   t_flags (long flag);
  75   long   t_flags ();
  76
  77   size_t count ();
  78
  79   int    debug ();
  80   int    verbose ();
  81   int    do_checksum ();
  82   int    do_generate ();
  83   int    do_ack ();
  84   int    do_delete ();
  85   int    do_eager_exit ();
  86   int    do_print_summary ();
  87   int    do_udp ();
  88   int    do_xdr ();
  89   int    do_zero_copy ();
  90   void   print_results ();
  91
  92   ACE_Atomic_Op<ACE_Thread_Mutex, size_t> msg_count;        // Keep track of number of messages atomically.
  93   int *thr_work_count;  // Count activity per-thread.
  94   int thr_wc_size;           // Max number of threads.
  95
  96 private:
  97   ACE_Profile_Timer _itimer;            // Keep track of time.
  98   ACE_TCHAR     *_service_entry;        // Name of the shared object file and shared object.
  99   ACE_TCHAR     *_mapped_file;          // Name of the mapped file.
 100   ACE_TCHAR     *_pipe_addr;            // Name of the STREAM pipe.
 101   size_t        _sleep_time;            // Time to sleep.
 102   size_t        _n_lwps;                // Number of LWPs.
 103   size_t        _thr_count;             // Number of threads to spawn.
 104   long          _t_flags;               // Flags to thr_create().
 105   size_t        _high_water_mark;       // ACE_Queue high water mark.
 106   size_t        _low_water_mark;        // ACE_Queue low water mark.
 107   size_t        _msg_size;              // Size of a message.
 108   size_t        _initial_queue_length;  // Initial number of items in the queue.
 109   size_t        _logical_connections;   // Number of logical connections.
 110   size_t        _physical_connections;  // Number of physical connections.
 111   size_t        _iterations;            // Number of iterations to run the test program.
 112   int           _generate;              // Generate the data.
 113   int           _udp;                   // Use UDP format.
 114   int           _debugging;             // Extra debugging info.
 115   int           _verbosity;             // Extra verbose messages.
 116   int           _ack;                   // Do an acknowledgement.
 117   int           _checksum;              // Is checksumming enabled?.
 118   int           _xdr;                   // Is xdr conversion enabled?.
 119   int           _free_memory;           // Are we freeing up memory?.
 120   int           _zero_copy;             // Implement a zero-copy driver?.
 121   int           _print_summary;         // Print a summary of the results only.
 122   size_t        _consecutive_ports;     // Number of consecutive messages from same port.
 123   int           _eager_exit;            // Exit eagerly, without cleaning up.
 124 };
 125
 126 // Make this available to any code that wants to see it!
 127 extern ACE_Svc_Export Performance_Test_Options performance_test_options;
 128
 129 #include "Performance_Test_Options.inl"
 130 #endif /* ACE_HAS_THREADS */
 131 #endif /* _PERFORMANCE_TEST_OPTIONS_H */