summaryrefslogtreecommitdiff
path: root/TAO/CIAO/tools/XML_Helpers/RTConfig_Handlers.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/CIAO/tools/XML_Helpers/RTConfig_Handlers.cpp')
-rw-r--r--TAO/CIAO/tools/XML_Helpers/RTConfig_Handlers.cpp699
1 files changed, 0 insertions, 699 deletions
diff --git a/TAO/CIAO/tools/XML_Helpers/RTConfig_Handlers.cpp b/TAO/CIAO/tools/XML_Helpers/RTConfig_Handlers.cpp
deleted file mode 100644
index 4110348d1f9..00000000000
--- a/TAO/CIAO/tools/XML_Helpers/RTConfig_Handlers.cpp
+++ /dev/null
@@ -1,699 +0,0 @@
-// $Id$
-
-#include "RTConfig_Handlers.h"
-#include "ace/OS_String.h"
-#include "ciao/CIAO_common.h"
-
-#if !defined (__ACE_INLINE__)
-# include "RTConfig_Handlers.inl"
-#endif /* __ACE_INLINE__ */
-
-void
-CIAO::RTConfig_Handler::startElement (const ACEXML_Char *,
- const ACEXML_Char *,
- const ACEXML_Char *qName,
- ACEXML_Attributes *alist
- ACEXML_ENV_ARG_DECL)
- ACE_THROW_SPEC ((ACEXML_SAXException))
-{
- switch (this->state_)
- {
- case START:
- if (ACE_OS::strcmp (qName, "rtresources") == 0)
- {
- this->state_ = RTRESOURCES;
- }
- else if (ACE_OS::strcmp (qName, "rtpolicyset") == 0)
- {
- this->state_ = RTPOLICYSET;
- this->create_new_policyset (alist
- ACEXML_ENV_ARG_PARAMETER);
- }
- else if (ACE_OS::strcmp (qName, "rtcad_ext") == 0)
- {
- if (CIAO::debug_level () > 10)
- ACE_DEBUG ((LM_DEBUG, "Start parsing RT cad file extension\n"));
- }
- else
- ACEXML_THROW (ACEXML_SAXException
- ("Error parsing rtcad_ext child\n"));
-
- return;
-
- case RTRESOURCES:
- if (ACE_OS::strcmp (qName, "threadpool") == 0)
- {
- this->parse_threadpool_attrs (alist
- ACEXML_ENV_ARG_PARAMETER);
- }
- else if (ACE_OS::strcmp (qName, "threadpoolwithlanes") == 0)
- {
- this->state_ = TPWLANES;
- this->parse_threadpoollanes_attrs (alist
- ACEXML_ENV_ARG_PARAMETER);
- }
- else if (ACE_OS::strcmp (qName, "connectionbands") == 0)
- {
- this->bands_config_ = new CIAO::RTConfiguration::PriorityBands_Configuration;
- const char *id;
- XML_Utils::get_single_attribute ("id",
- id,
- alist
- ACEXML_ENV_ARG_PARAMETER);
- ACEXML_CHECK;
- this->bands_config_->name = id;
- this->state_ = CONNBANDS;
- }
- else
- ACEXML_THROW (ACEXML_SAXException
- ("Error parsing rtresource\n"));
-
- return;
-
- case RTPOLICYSET:
- if (ACE_OS::strcmp (qName, "rtpolicyset") == 0)
- {
- this->create_new_policyset (alist
- ACEXML_ENV_ARG_PARAMETER);
- }
- else
- {
- CIAO::RTConfiguration::Policy_Config_var newpolicy
- = new CIAO::RTConfiguration::Policy_Config;
-
- if (ACE_OS::strcmp (qName, "priority_model_policy") == 0)
- {
- CIAO::RTConfiguration::Priority_Model_Config config;
- this->parse_priority_model_config (alist,
- config
- ACEXML_ENV_ARG_PARAMETER);
- ACEXML_CHECK;
-
- newpolicy->type = RTCORBA::PRIORITY_MODEL_POLICY_TYPE;
- newpolicy->configuration <<= config;
- }
- else if (ACE_OS::strcmp (qName, "threadpool_policy") == 0)
- {
- const char *idref;
- XML_Utils::get_single_attribute ("idref",
- idref,
- alist
- ACEXML_ENV_ARG_PARAMETER);
- ACEXML_CHECK;
-
- newpolicy->type = RTCORBA::THREADPOOL_POLICY_TYPE;
- // @@ try to catch CORBA exceptions here
- newpolicy->configuration <<= idref;
- }
- else if (ACE_OS::strcmp (qName, "banded_connection_policy") == 0)
- {
- const char *idref;
- XML_Utils::get_single_attribute ("idref",
- idref,
- alist
- ACEXML_ENV_ARG_PARAMETER);
- ACEXML_CHECK;
-
- newpolicy->type = RTCORBA::PRIORITY_BANDED_CONNECTION_POLICY_TYPE;
- // @@ try to catch CORBA exceptions here
- newpolicy->configuration <<= idref;
- }
- else
- ACEXML_THROW (ACEXML_SAXException
- ("Error parsing child of rtpolicyset element"));
-
- // Store the good parsed results.
- CORBA::ULong len = this->policy_set_->configs.length ();
- this->policy_set_->configs.length (len+1);
- this->policy_set_->configs[len] = newpolicy.in ();
- }
- return;
-
- case TPWLANES:
- if (ACE_OS::strcmp (qName, "lane") == 0)
- {
- this->add_threadpoollane (alist
- ACEXML_ENV_ARG_PARAMETER);
- }
- return;
-
- case CONNBANDS:
- if (ACE_OS::strcmp (qName, "band") == 0)
- {
- this->add_priorityband (alist
- ACEXML_ENV_ARG_PARAMETER);
- }
- return;
-
- default:
- ACEXML_THROW (ACEXML_SAXException
- ("RTConfig handler internal error"));
- return;
- }
- ACEXML_THROW (ACEXML_SAXException
- ("RTConfig handler internal error"));
-}
-
-void
-CIAO::RTConfig_Handler::endElement (const ACEXML_Char *,
- const ACEXML_Char *,
- const ACEXML_Char *qName
- ACEXML_ENV_ARG_DECL)
- ACE_THROW_SPEC ((ACEXML_SAXException))
-{
- switch (this->state_)
- {
- case START:
- if (ACE_OS::strcmp (qName, "rtcad_ext") == 0)
- {
- if (CIAO::debug_level () > 10)
- ACE_DEBUG ((LM_DEBUG, "End parsing RT cad file extension\n"));
- }
- return;
-
- case RTRESOURCES:
- if (ACE_OS::strcmp (qName, "rtresources") == 0)
- this->state_ = RTPOLICYSET;
- return;
-
- case TPWLANES:
- if (ACE_OS::strcmp (qName, "threadpoolwithlanes") == 0)
- {
- // Store the good parsed results.
- CORBA::ULong len = this->rtresources.tpl_configs.length ();
- this->rtresources.tpl_configs.length (len+1);
- this->rtresources.tpl_configs[len] =
- this->tpl_config_.in ();
- this->state_ = RTRESOURCES;
- }
- return;
-
- case CONNBANDS:
- if (ACE_OS::strcmp (qName, "connectionbands") == 0)
- {
- // Store the good parsed results.
- CORBA::ULong len = this->rtresources.pb_configs.length ();
- this->rtresources.pb_configs.length (len+1);
- this->rtresources.pb_configs[len] =
- this->bands_config_.in ();
- this->state_ = RTRESOURCES;
- }
- return;
-
- case RTPOLICYSET:
- if (ACE_OS::strcmp (qName, "rtpolicyset") == 0)
- {
- // Store the good parsed results.
- CORBA::ULong len = this->policysets.length ();
- this->policysets.length (len+1);
- this->policysets[len] =
- this->policy_set_.in ();
- this->state_ = START;
- }
- return;
-
- default:
- ACEXML_THROW (ACEXML_SAXException
- ("RTConfig handler internal error"));
- return;
- }
- ACEXML_THROW (ACEXML_SAXException
- ("RTConfig handler internal error"));
-}
-
-// =================================================================
-
-void
-CIAO::RTConfig_Handler::parse_threadpool_attrs (ACEXML_Attributes *alist
- ACEXML_ENV_ARG_DECL)
- ACE_THROW_SPEC ((ACEXML_SAXException))
-{
- const int STACKSIZE_READ = 1;
- const int STATICTHR_READ = 2;
- const int DYNAMICTHR_READ = 4;
- const int DEFAULTPRIO_READ = 8;
- const int YES_BUFFERING_READ = 0X10;
- const int BUFFER_REQ_READ = 0X20;
- const int BUFFER_SIZE_READ = 0X40;
- const int TPNAME_READ = 0X80;
-
- // Initialize the attribute parse progress. We will turn off these
- // bits one by one. At the end, the att_status should be 0.
- int att_status =
- STACKSIZE_READ |
- STATICTHR_READ |
- DYNAMICTHR_READ |
- DEFAULTPRIO_READ |
- YES_BUFFERING_READ |
- BUFFER_REQ_READ |
- BUFFER_SIZE_READ |
- TPNAME_READ;
-
- char *endpos;
- CIAO::RTConfiguration::ThreadPool_Configuration_var tp_config
- = new CIAO::RTConfiguration::ThreadPool_Configuration;
-
- for (size_t i = 0; i < alist->getLength (); ++i)
- {
- const char *attName = alist->getQName (i);
- const char *attValue = alist->getValue (i);
-
- if (ACE_OS_String::strcmp (attName, "id") == 0)
- {
- tp_config->name = attValue;
- ACE_CLR_BITS (att_status,
- TPNAME_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "stacksize") == 0)
- {
- tp_config->stacksize =
- strtoul (attValue, &endpos, 10);
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'stacksize' attribute in threadpool config."));
-
- ACE_CLR_BITS (att_status,
- STACKSIZE_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "static_threads") == 0)
- {
- tp_config->static_threads =
- strtoul (attValue, &endpos, 10);
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'static_threads' attribute in threadpool config."));
-
- ACE_CLR_BITS (att_status,
- STATICTHR_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "dynamic_threads") == 0)
- {
- tp_config->dynamic_threads =
- strtoul (attValue, &endpos, 10);
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'dynamic_threads' attribute in threadpool config."));
-
- ACE_CLR_BITS (att_status,
- DYNAMICTHR_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "priority") == 0)
- {
- tp_config->default_priority =
- static_cast<RTCORBA::Priority> (ACE_OS::strtoul (attValue,
- &endpos,
- 10));
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'priority' attribute in threadpool config."));
-
- ACE_CLR_BITS (att_status,
- DEFAULTPRIO_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "buffering") == 0)
- {
- // Assuming we have a validating parser.
- if (ACE_OS_String::strcmp (attName, "yes") == 0)
- tp_config->allow_request_buffering = 1;
- else
- tp_config->allow_request_buffering = 0;
-
- ACE_CLR_BITS (att_status,
- YES_BUFFERING_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "max_buffer") == 0)
- {
- tp_config->max_buffered_requests =
- strtoul (attValue, &endpos, 10);
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'max_buffer' attribute in threadpool config."));
-
- ACE_CLR_BITS (att_status,
- BUFFER_REQ_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "buffer_size") == 0)
- {
- tp_config->max_request_buffer_size =
- strtoul (attValue, &endpos, 10);
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'buffer_size' attribute in threadpool config."));
-
- ACE_CLR_BITS (att_status,
- BUFFER_SIZE_READ);
- }
- else
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid attribute found"));
- }
- if (att_status != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Not all ThreadPool_Configuration attributes are set."));
-
- // Store the good parsed results.
- CORBA::ULong len = this->rtresources.tp_configs.length ();
- this->rtresources.tp_configs.length (len+1);
- this->rtresources.tp_configs[len] = tp_config.in ();
-}
-
-void
-CIAO::RTConfig_Handler::parse_threadpoollanes_attrs (ACEXML_Attributes *alist
- ACEXML_ENV_ARG_DECL)
- ACE_THROW_SPEC ((ACEXML_SAXException))
-{
- const int STACKSIZE_READ = 1;
- const int YES_BORROWING_READ = 2;
- const int YES_BUFFERING_READ = 4;
- const int BUFFER_REQ_READ = 8;
- const int BUFFER_SIZE_READ = 0X10;
- const int TPNAME_READ = 0X20;
-
- // Initialize the attribute parse progress. We will turn off these
- // bits one by one. At the end, the att_status should be 0.
- int att_status =
- STACKSIZE_READ |
- YES_BORROWING_READ |
- YES_BUFFERING_READ |
- BUFFER_REQ_READ |
- BUFFER_SIZE_READ |
- TPNAME_READ;
-
- char *endpos;
- this->tpl_config_
- = new CIAO::RTConfiguration::ThreadPoolLanes_Configuration;
-
- for (size_t i = 0; i < alist->getLength (); ++i)
- {
- const char *attName = alist->getQName (i);
- const char *attValue = alist->getValue (i);
-
- if (ACE_OS_String::strcmp (attName, "id") == 0)
- {
- this->tpl_config_->name = attValue;
- ACE_CLR_BITS (att_status,
- TPNAME_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "stacksize") == 0)
- {
- this->tpl_config_->stacksize =
- strtoul (attValue, &endpos, 10);
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'stacksize' attribute in threadpoolwithlanes config."));
-
- ACE_CLR_BITS (att_status,
- STACKSIZE_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "borrowing") == 0)
- {
- // Assuming we have a validating parser.
- if (ACE_OS_String::strcmp (attName, "yes") == 0)
- this->tpl_config_->allow_borrowing = 1;
- else
- this->tpl_config_->allow_borrowing = 0;
-
- ACE_CLR_BITS (att_status,
- YES_BORROWING_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "buffering") == 0)
- {
- // Assuming we have a validating parser.
- if (ACE_OS_String::strcmp (attName, "yes") == 0)
- this->tpl_config_->allow_request_buffering = 1;
- else
- this->tpl_config_->allow_request_buffering = 0;
-
- ACE_CLR_BITS (att_status,
- YES_BUFFERING_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "max_buffer") == 0)
- {
- this->tpl_config_->max_buffered_requests =
- strtoul (attValue, &endpos, 10);
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'max_buffer' attribute in threadpoolwitlanes config."));
-
- ACE_CLR_BITS (att_status,
- BUFFER_REQ_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "buffer_size") == 0)
- {
- this->tpl_config_->max_request_buffer_size =
- strtoul (attValue, &endpos, 10);
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'buffer_size' attribute in threadpoolwithlanes config."));
-
- ACE_CLR_BITS (att_status,
- BUFFER_SIZE_READ);
- }
- else
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid attribute in element 'threadpoolwithlanes' found"));
- }
- if (att_status != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Not all ThreadPoolLanes_Configuration attributes are set."));
-}
-
-void
-CIAO::RTConfig_Handler::add_threadpoollane (ACEXML_Attributes *alist
- ACEXML_ENV_ARG_DECL)
- ACE_THROW_SPEC ((ACEXML_SAXException))
-{
- const int PRIORITY_READ = 1;
- const int STATICTHR_READ = 2;
- const int DYNAMICTHR_READ = 4;
-
- // Initialize the attribute parse progress. We will turn off these
- // bits one by one. At the end, the att_status should be 0.
- int att_status =
- PRIORITY_READ |
- STATICTHR_READ |
- DYNAMICTHR_READ ;
-
- char *endpos;
- RTCORBA::ThreadpoolLane alane = {0, 0, 0};
-
- for (size_t i = 0; i < alist->getLength (); ++i)
- {
- const char *attName = alist->getQName (i);
- const char *attValue = alist->getValue (i);
-
- if (ACE_OS_String::strcmp (attName, "priority") == 0)
- {
- alane.lane_priority =
- static_cast<RTCORBA::Priority> (strtoul (attValue, &endpos, 10));
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'priority' attribute in lane config."));
-
- ACE_CLR_BITS (att_status,
- PRIORITY_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "static_threads") == 0)
- {
- alane.static_threads =
- strtoul (attValue, &endpos, 10);
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'static_threads' attribute in lane config."));
-
- ACE_CLR_BITS (att_status,
- STATICTHR_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "dynamic_threads") == 0)
- {
- alane.dynamic_threads =
- strtoul (attValue, &endpos, 10);
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'dynamic_threads' attribute in lane config."));
-
- ACE_CLR_BITS (att_status,
- DYNAMICTHR_READ);
- }
- else
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid attribute found in lane element"));
- }
- if (att_status != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Not all 'lane' attributes are set."));
-
- // Store the good parsed results.
- CORBA::ULong len = this->tpl_config_->lanes.length ();
- this->tpl_config_->lanes.length (len+1);
- this->tpl_config_->lanes[len] = alane;
-}
-
-void
-CIAO::RTConfig_Handler::add_priorityband (ACEXML_Attributes *alist
- ACEXML_ENV_ARG_DECL)
- ACE_THROW_SPEC ((ACEXML_SAXException))
-{
- const int LOW_READ = 1;
- const int HIGH_READ = 2;
-
- // Initialize the attribute parse progress. We will turn off these
- // bits one by one. At the end, the att_status should be 0.
- int att_status =
- LOW_READ |
- HIGH_READ ;
-
- char *endpos;
- RTCORBA::PriorityBand band = {0, 0};
-
- for (size_t i = 0; i < alist->getLength (); ++i)
- {
- const char *attName = alist->getQName (i);
- const char *attValue = alist->getValue (i);
-
- if (ACE_OS_String::strcmp (attName, "low") == 0)
- {
- band.low =
- static_cast<RTCORBA::Priority> (strtoul (attValue, &endpos, 10));
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'low' attribute in band config."));
-
- ACE_CLR_BITS (att_status,
- LOW_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "high") == 0)
- {
- band.high =
- static_cast<RTCORBA::Priority> (strtoul (attValue, &endpos, 10));
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'high' attribute in lane config."));
-
- ACE_CLR_BITS (att_status,
- HIGH_READ);
- }
- else
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid attribute found in band element"));
- }
- if (att_status != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Not all 'band' attributes are set."));
-
- // Store the good parsed results.
- CORBA::ULong len = this->bands_config_->bands.length ();
- this->bands_config_->bands.length (len+1);
- this->bands_config_->bands[len] = band;
-}
-
-void
-CIAO::RTConfig_Handler::create_new_policyset (ACEXML_Attributes *alist
- ACEXML_ENV_ARG_DECL)
- ACE_THROW_SPEC ((ACEXML_SAXException))
-{
- const char *id;
- XML_Utils::get_single_attribute ("id",
- id,
- alist
- ACEXML_ENV_ARG_PARAMETER);
- ACEXML_CHECK;
-
- this->policy_set_ = new CIAO::RTConfiguration::Policy_Set;
-
- this->policy_set_->name = id;
-}
-
-void
-CIAO::RTConfig_Handler::parse_priority_model_config (ACEXML_Attributes *alist,
- RTConfiguration::Priority_Model_Config &config
- ACEXML_ENV_ARG_DECL)
- ACE_THROW_SPEC ((ACEXML_SAXException))
-{
- const int MODEL_READ = 1;
- const int PRIORITY_READ = 2;
- int att_status =
- MODEL_READ |
- PRIORITY_READ ;
-
- for (size_t i = 0; i < alist->getLength (); ++i)
- {
- const char *attName = alist->getQName (i);
- const char *attValue = alist->getValue (i);
-
- if (ACE_OS_String::strcmp (attName, "type") == 0)
- {
- // Assuming we have a validating parser.
- if (ACE_OS_String::strcmp (attValue, "server_declared") == 0)
- config.model = RTCORBA::SERVER_DECLARED;
- else if (ACE_OS_String::strcmp (attValue, "client_propagated") == 0)
- config.model = RTCORBA::CLIENT_PROPAGATED;
- else
- ACEXML_THROW (ACEXML_SAXException
- ("RTConfig handler error while reading Priority Model Config."));
-
- ACE_CLR_BITS (att_status,
- MODEL_READ);
- }
- else if (ACE_OS_String::strcmp (attName, "priority") == 0)
- {
- char *endpos;
-
- config.default_priority =
- static_cast<RTCORBA::Priority> (strtoul (attValue, &endpos, 10));
-
- if (*endpos != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid 'priority' attribute in Priority Model Config."));
-
- ACE_CLR_BITS (att_status,
- PRIORITY_READ);
- }
- else
- ACEXML_THROW
- (ACEXML_SAXException
- ("Invalid attribute found in priority_model element"));
- }
- if (att_status != 0)
- ACEXML_THROW
- (ACEXML_SAXException
- ("Not all 'priority_model' attributes are set."));
-
-}
View Lorry Controller Status