diff options
Diffstat (limited to 'ACE/apps/Gateway/Gateway/Options.cpp')
| -rw-r--r-- | ACE/apps/Gateway/Gateway/Options.cpp | 288 |
1 files changed, 288 insertions, 0 deletions
diff --git a/ACE/apps/Gateway/Gateway/Options.cpp b/ACE/apps/Gateway/Gateway/Options.cpp new file mode 100644 index 00000000000..4e08e686235 --- /dev/null +++ b/ACE/apps/Gateway/Gateway/Options.cpp @@ -0,0 +1,288 @@ +// $Id$ + +#define ACE_BUILD_SVC_DLL + +#include "Event.h" +#include "Options.h" +#include "ace/Get_Opt.h" +#include "ace/Log_Msg.h" +#include "ace/OS_NS_string.h" +#include "ace/OS_NS_strings.h" +#include "ace/os_include/os_fcntl.h" + +ACE_RCSID(Gateway, Options, "$Id$") + +// Static initialization. +Options *Options::instance_ = 0; + +// Let's have a usage prompt. +void +Options::print_usage (void) +{ + ACE_DEBUG ((LM_INFO, + "gatewayd [-a {C|S}:acceptor-port] [-c {C|S}:connector-port]" + " [-C consumer_config_file] [-P connection_config_filename]" + " [-q socket_queue_size] [-t OUTPUT_MT|INPUT_MT] [-w time_out]" + " [-b] [-d] [-v] [-T]\n" + "" + "\t-a Become an Acceptor\n" + "\t-b Use blocking connection establishment\n" + "\t-c Become a Connector\n" + "\t-d debugging\n" + "\t-q Use a different socket queue size\n" + "\t-t Use a different threading strategy\n" + "\t-v Verbose mode\n" + "\t-w Time performance for a designated amount of time\n" + "\t-C Use a different proxy config filename\n" + "\t-P Use a different consumer config filename\n" + "\t-T Tracing\n" + )); +} +Options * +Options::instance (void) +{ + if (Options::instance_ == 0) + ACE_NEW_RETURN (Options::instance_, Options, 0); + + return Options::instance_; +} + +Options::Options (void) + : locking_strategy_ (0), + performance_window_ (0), + blocking_semantics_ (ACE_NONBLOCK), + socket_queue_size_ (0), + threading_strategy_ (REACTIVE), + options_ (0), + supplier_acceptor_port_ (DEFAULT_GATEWAY_SUPPLIER_PORT), + consumer_acceptor_port_ (DEFAULT_GATEWAY_CONSUMER_PORT), + supplier_connector_port_ (DEFAULT_PEER_SUPPLIER_PORT), + consumer_connector_port_ (DEFAULT_PEER_CONSUMER_PORT), + max_timeout_ (MAX_TIMEOUT), + max_queue_size_ (MAX_QUEUE_SIZE), + connection_id_ (1) +{ + ACE_OS::strcpy (this->connection_config_file_, ACE_TEXT("connection_config")); + ACE_OS::strcpy (this->consumer_config_file_, ACE_TEXT("consumer_config")); +} + +int +Options::enabled (int option) const +{ + return ACE_BIT_ENABLED (this->options_, option); +} + +Options::~Options (void) +{ + delete this->locking_strategy_; +} + +ACE_Lock_Adapter<ACE_SYNCH_MUTEX> * +Options::locking_strategy (void) const +{ + return this->locking_strategy_; +} + +void +Options::locking_strategy (ACE_Lock_Adapter<ACE_SYNCH_MUTEX> *ls) +{ + this->locking_strategy_ = ls; +} + +long +Options::performance_window (void) const +{ + return this->performance_window_; +} + +CONNECTION_ID & +Options::connection_id (void) +{ + return this->connection_id_; +} + +long +Options::max_timeout (void) const +{ + return this->max_timeout_; +} + +int +Options::blocking_semantics (void) const +{ + return this->blocking_semantics_; +} + +int +Options::socket_queue_size (void) const +{ + return this->socket_queue_size_; +} + +u_long +Options::threading_strategy (void) const +{ + return this->threading_strategy_; +} + +const ACE_TCHAR * +Options::connection_config_file (void) const +{ + return this->connection_config_file_; +} + +const ACE_TCHAR * +Options::consumer_config_file (void) const +{ + return this->consumer_config_file_; +} + +u_short +Options::consumer_acceptor_port (void) const +{ + return this->consumer_acceptor_port_; +} + +u_short +Options::supplier_acceptor_port (void) const +{ + return this->supplier_acceptor_port_; +} + +u_short +Options::consumer_connector_port (void) const +{ + return this->consumer_connector_port_; +} + +long +Options::max_queue_size (void) const +{ + return this->max_queue_size_; +} + +u_short +Options::supplier_connector_port (void) const +{ + return this->supplier_connector_port_; +} + +// Parse the "command-line" arguments and set the corresponding flags. + +int +Options::parse_args (int argc, ACE_TCHAR *argv[]) +{ + // Assign defaults. + ACE_Get_Opt get_opt (argc, + argv, + ACE_TEXT("a:bC:c:dm:P:p:q:r:t:vw:"), + 0); + + for (int c; (c = get_opt ()) != EOF; ) + { + switch (c) + { + case 'a': + { + // Become an Acceptor. + + for (ACE_TCHAR *flag = ACE_OS::strtok (get_opt.opt_arg (), ACE_TEXT("|")); + flag != 0; + flag = ACE_OS::strtok (0, ACE_TEXT("|"))) + if (ACE_OS::strncasecmp (flag, ACE_TEXT("C"), 1) == 0) + { + ACE_SET_BITS (this->options_, + Options::CONSUMER_ACCEPTOR); + if (ACE_OS::strlen (flag) > 1) + // Set the Consumer Acceptor port number. + this->consumer_acceptor_port_ = ACE_OS::atoi (flag + 2); + } + else if (ACE_OS::strncasecmp (flag, ACE_TEXT("S"), 1) == 0) + { + ACE_SET_BITS (this->options_, + Options::SUPPLIER_ACCEPTOR); + if (ACE_OS::strlen (flag) > 1) + // Set the Supplier Acceptor port number. + this->supplier_acceptor_port_ = ACE_OS::atoi (flag + 2); + } + } + break; + /* NOTREACHED */ + case 'b': // Use blocking connection establishment. + this->blocking_semantics_ = 1; + break; + case 'C': // Use a different proxy config filename. + ACE_OS::strncpy (this->consumer_config_file_, + get_opt.opt_arg (), + sizeof this->consumer_config_file_ + / sizeof (ACE_TCHAR)); + break; + case 'c': + { + // Become a Connector. + + for (ACE_TCHAR *flag = ACE_OS::strtok (get_opt.opt_arg (), ACE_TEXT("|")); + flag != 0; + flag = ACE_OS::strtok (0, ACE_TEXT("|"))) + if (ACE_OS::strncasecmp (flag, ACE_TEXT("C"), 1) == 0) + { + ACE_SET_BITS (this->options_, + Options::CONSUMER_CONNECTOR); + if (ACE_OS::strlen (flag) > 1) + // Set the Consumer Connector port number. + this->consumer_connector_port_ = ACE_OS::atoi (flag + 2); + } + else if (ACE_OS::strncasecmp (flag, ACE_TEXT("S"), 1) == 0) + { + ACE_SET_BITS (this->options_, + Options::SUPPLIER_CONNECTOR); + if (ACE_OS::strlen (flag) > 1) + // Set the Supplier Connector port number. + this->supplier_connector_port_ = ACE_OS::atoi (flag + 2); + } + } + break; + /* NOTREACHED */ + case 'd': // We are debugging. + ACE_SET_BITS (this->options_, + Options::DEBUGGING); + break; + case 'P': // Use a different connection config filename. + ACE_OS::strncpy (this->connection_config_file_, + get_opt.opt_arg (), + sizeof this->connection_config_file_); + break; + case 'q': // Use a different socket queue size. + this->socket_queue_size_ = ACE_OS::atoi (get_opt.opt_arg ()); + break; + case 't': // Use a different threading strategy. + { + for (ACE_TCHAR *flag = ACE_OS::strtok (get_opt.opt_arg (), ACE_TEXT("|")); + flag != 0; + flag = ACE_OS::strtok (0, ACE_TEXT("|"))) + if (ACE_OS::strcmp (flag, ACE_TEXT("OUTPUT_MT")) == 0) + ACE_SET_BITS (this->threading_strategy_, + Options::OUTPUT_MT); + else if (ACE_OS::strcmp (flag, ACE_TEXT("INPUT_MT")) == 0) + ACE_SET_BITS (this->threading_strategy_, + Options::INPUT_MT); + break; + } + case 'v': // Verbose mode. + ACE_SET_BITS (this->options_, + Options::VERBOSE); + break; + case 'w': // Time performance for a designated amount of time. + this->performance_window_ = ACE_OS::atoi (get_opt.opt_arg ()); + // Use blocking connection semantics so that we get accurate + // timings (since all connections start at once). + this->blocking_semantics_ = 0; + break; + default: + this->print_usage(); // It's nice to have a usage prompt. + break; + } + } + + return 0; +} |