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
132
133
134
135
136
137
138
139
140
141
142
|
// -*- C++ -*-
//=============================================================================
/**
* @file Options.h
*
* $Id$
*
* @author Douglas C. Schmidt
*/
//=============================================================================
#ifndef OPTIONS_H
#define OPTIONS_H
#include "../Gateway/Event.h"
#include "ace/svc_export.h"
/**
* @class Options
*
* @brief Singleton that consolidates all Options for a peerd.
*/
class ACE_Svc_Export Options
{
public:
// = Options that can be enabled/disabled.
enum
{
VERBOSE = 01,
SUPPLIER_ACCEPTOR = 02,
CONSUMER_ACCEPTOR = 04,
SUPPLIER_CONNECTOR = 010,
CONSUMER_CONNECTOR = 020
};
/// Return Singleton.
static Options *instance (void);
/// Parse the arguments and set the options.
void parse_args (int argc, ACE_TCHAR *argv[]);
// = Accessor methods.
/// Determine if an option is enabled.
int enabled (int option) const;
/**
* Our acceptor port number, i.e., the one that we passively listen
* on for connections to arrive from a gatewayd and create a
* Supplier.
*/
u_short supplier_acceptor_port (void) const;
/**
* Our acceptor port number, i.e., the one that we passively listen
* on for connections to arrive from a gatewayd and create a
* Consumer.
*/
u_short consumer_acceptor_port (void) const;
/// The connector port number, i.e., the one that we use to actively
/// establish connections with a gatewayd and create a Supplier.
u_short supplier_connector_port (void) const;
/// The connector port number, i.e., the one that we use to actively
/// establish connections with a gatewayd and create a Consumer.
u_short consumer_connector_port (void) const;
/// Our connector port host, i.e., the host running the gatewayd
/// process.
const ACE_TCHAR *connector_host (void) const;
/// Duration between disconnects.
long timeout (void) const;
/// The maximum size of the queue.
long max_queue_size (void) const;
/// Returns a reference to the connection id.
CONNECTION_ID &connection_id (void);
private:
enum
{
MAX_QUEUE_SIZE = 1024 * 1024 * 16,
// We'll allow up to 16 megabytes to be queued per-output
// channel!!!! This is clearly a policy in search of
// refinement...
DEFAULT_TIMEOUT = 60
// By default, disconnect the peer every minute.
};
/// Ensure Singleton.
Options (void);
/// Explain usage and exit.
void print_usage_and_die (void);
/// Singleton.
static Options *instance_;
/// Flag to indicate if we want verbose diagnostics.
u_long options_;
/**
* The acceptor port number, i.e., the one that we passively listen
* on for connections to arrive from a gatewayd and create a
* Supplier.
*/
u_short supplier_acceptor_port_;
/**
* The acceptor port number, i.e., the one that we passively listen
* on for connections to arrive from a gatewayd and create a
* Consumer.
*/
u_short consumer_acceptor_port_;
/// The connector port number, i.e., the one that we use to actively
/// establish connections with a gatewayd and create a Supplier.
u_short supplier_connector_port_;
/// The connector port number, i.e., the one that we use to actively
/// establish connections with a gatewayd and create a Consumer.
u_short consumer_connector_port_;
/// Our connector host, i.e., where the gatewayd process is running.
const ACE_TCHAR *connector_host_;
/// The amount of time to wait before disconnecting from the Peerd.
long timeout_;
/// The maximum size that the queue can grow to.
long max_queue_size_;
/// The connection id.
CONNECTION_ID connection_id_;
};
#endif /* OPTIONS_H */
|
