blob: 7432f78f604948c625b1e4d51790281585e74564 (
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
|
/* -*- C++ -*- */
// $Id$
/* Option manager for ustreams */
#if !defined (_OPTIONS_H)
#define _OPTIONS_H
#include "ace/OS.h"
#include "ace/Profile_Timer.h"
#include "ace/Log_Msg.h"
#include "ace/Thread_Manager.h"
#if defined (ACE_HAS_THREADS)
class Options
{
public:
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 Options options;
#include "Options.i"
#endif /* ACE_HAS_THREADS */
#endif /* _OPTIONS_H */
|
