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