diff options
Diffstat (limited to 'modules/CIAO/tools/Config_Handlers/RT-CCM')
28 files changed, 10654 insertions, 0 deletions
diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/CB_Handler.cpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/CB_Handler.cpp new file mode 100644 index 00000000000..85a06851d78 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/CB_Handler.cpp @@ -0,0 +1,70 @@ +// $Id$ + +#include "CB_Handler.h" +#include "CIAOServerResources.hpp" +#include "ace/Basic_Types.h" + +namespace CIAO +{ + namespace Config_Handlers + { + // IDREF_Base CB_Handler::IDREF; + + bool + CB_Handler::connection_band (const ConnectionBandsDef &src, + ::CIAO::DAnCE::ORS_ConnectionBands &dest) + { + // Set the number of bands + CORBA::ULong num (dest.bands.length ()); + dest.bands.length (num + src.count_band ()); + + for (ConnectionBandsDef::band_const_iterator i = src.begin_band (); + i != src.end_band (); + ++i) + { + dest.bands[num].low = static_cast <ACE_INT32> ((i->low ())); + dest.bands[num].high = static_cast < ACE_INT32 > (i->high ()); + num++; + } + + if (src.id_p ()) + { + /* + ACE_CString cstr (src.id ().c_str ()); + if (!IDD_Handler::IDREF.bind_ref (cstr, dest)) + return false; + */ + dest.Id = CORBA::string_dup (src.id ().c_str ()); + } + + return true; + } + + + ConnectionBandsDef + CB_Handler::connection_band (const ::CIAO::DAnCE::ORS_ConnectionBands &src) + { + ConnectionBandsDef cb; + + for (CORBA::ULong i = 0; + i < src.bands.length (); + ++i) + { + cb.add_band (PriorityBandDef (src.bands[i].low, + src.bands[i].high)); + } + + /* + ACE_CString cstr; + if (CB_Handler::IDREF.find_ref (src, cstr)) + cb->id (cstr.c_str ()); + */ + + if (src.Id.in () != 0) + cb.id (src.Id.in ()); + + return cb; + } + + } +} diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/CB_Handler.h b/modules/CIAO/tools/Config_Handlers/RT-CCM/CB_Handler.h new file mode 100644 index 00000000000..9c1363ab420 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/CB_Handler.h @@ -0,0 +1,48 @@ +/** + * @file CB_Handler.h + * @author Will Otte <wotte@dre.vanderbilt.edu> + * + * $Id$ + */ + + + +#ifndef CIAO_CONFIG_HANDLERS_CB_HANDLER_H +#define CIAO_CONFIG_HANDLERS_CB_HANDLER_H + +#include /**/ "ace/pre.h" + +#include "RT_CCM_Handlers_Export.h" +#include "DAnCE/Deployment/CIAO_ServerResourcesC.h" +#include "IDREF_Base.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +namespace CIAO +{ + namespace Config_Handlers + { + class ConnectionBandsDef; + + /* + * @class CB_Handler + * A brief Handler class for <ConnectionBands> + */ + + class RT_CCM_Handlers_Export CB_Handler + { + public: + static bool connection_band (const ConnectionBandsDef &src, + ::CIAO::DAnCE::ORS_ConnectionBands &dest); + + static ConnectionBandsDef connection_band (const ::CIAO::DAnCE::ORS_ConnectionBands &src); + + // static IDREF_Base<::CIAO::DAnCE::ORS_ConnectionBands> IDREF; + }; + } +} + +#include /**/ "ace/post.h" +#endif /* CIAO_CONFIG_HANDLERS_CB_HANDLER_H */ diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/CIAOServerResources.cpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/CIAOServerResources.cpp new file mode 100644 index 00000000000..01f192d5201 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/CIAOServerResources.cpp @@ -0,0 +1,5890 @@ +/* $Id$ + * This code was generated by the XML Schema Compiler. + * + * Changes made to this code will most likely be overwritten + * when the handlers are recompiled. + * + * If you find errors or feel that there are bugfixes to be made, + * please contact the current XSC maintainer: + * Will Otte <wotte@dre.vanderbilt.edu> + */ + +// Fix for Borland compilers, which seem to have a broken +// <string> include. +#ifdef __BORLANDC__ +# include <string.h> +#endif + +#include "CIAOServerResources.hpp" + +namespace CIAO +{ + namespace Config_Handlers + { + // ServerResourcesDef + // + + ServerResourcesDef:: + ServerResourcesDef (::CIAO::Config_Handlers::ORBConfigs const& orbConfigs__) + : + ::XSCRT::Type (), + orbConfigs_ (new ::CIAO::Config_Handlers::ORBConfigs (orbConfigs__)), + regulator__ () + { + orbConfigs_->container (this); + } + + ServerResourcesDef:: + ServerResourcesDef (::CIAO::Config_Handlers::ServerResourcesDef const& s) + : + ::XSCRT::Type (), + cmdline_ (s.cmdline_.get () ? new ::CIAO::Config_Handlers::ServerCmdlineOptions (*s.cmdline_) : 0), + svcconf_ (s.svcconf_.get () ? new ::CIAO::Config_Handlers::ACESvcConf (*s.svcconf_) : 0), + orbConfigs_ (new ::CIAO::Config_Handlers::ORBConfigs (*s.orbConfigs_)), + id_ (s.id_.get () ? new ::XMLSchema::ID< ACE_TCHAR > (*s.id_) : 0), + regulator__ () + { + if (cmdline_.get ()) cmdline_->container (this); + if (svcconf_.get ()) svcconf_->container (this); + orbConfigs_->container (this); + if (id_.get ()) id_->container (this); + } + + ::CIAO::Config_Handlers::ServerResourcesDef& ServerResourcesDef:: + operator= (::CIAO::Config_Handlers::ServerResourcesDef const& s) + { + if (s.cmdline_.get ()) cmdline (*(s.cmdline_)); + else cmdline_ = ::std::auto_ptr< ::CIAO::Config_Handlers::ServerCmdlineOptions > (0); + + if (s.svcconf_.get ()) svcconf (*(s.svcconf_)); + else svcconf_ = ::std::auto_ptr< ::CIAO::Config_Handlers::ACESvcConf > (0); + + orbConfigs (s.orbConfigs ()); + + if (s.id_.get ()) id (*(s.id_)); + else id_ = ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > (0); + + return *this; + } + + + // ServerResourcesDef + // + bool ServerResourcesDef:: + cmdline_p () const + { + return cmdline_.get () != 0; + } + + ::CIAO::Config_Handlers::ServerCmdlineOptions const& ServerResourcesDef:: + cmdline () const + { + return *cmdline_; + } + + void ServerResourcesDef:: + cmdline (::CIAO::Config_Handlers::ServerCmdlineOptions const& e) + { + if (cmdline_.get ()) + { + *cmdline_ = e; + } + + else + { + cmdline_ = ::std::auto_ptr< ::CIAO::Config_Handlers::ServerCmdlineOptions > (new ::CIAO::Config_Handlers::ServerCmdlineOptions (e)); + cmdline_->container (this); + } + } + + // ServerResourcesDef + // + bool ServerResourcesDef:: + svcconf_p () const + { + return svcconf_.get () != 0; + } + + ::CIAO::Config_Handlers::ACESvcConf const& ServerResourcesDef:: + svcconf () const + { + return *svcconf_; + } + + void ServerResourcesDef:: + svcconf (::CIAO::Config_Handlers::ACESvcConf const& e) + { + if (svcconf_.get ()) + { + *svcconf_ = e; + } + + else + { + svcconf_ = ::std::auto_ptr< ::CIAO::Config_Handlers::ACESvcConf > (new ::CIAO::Config_Handlers::ACESvcConf (e)); + svcconf_->container (this); + } + } + + // ServerResourcesDef + // + ::CIAO::Config_Handlers::ORBConfigs const& ServerResourcesDef:: + orbConfigs () const + { + return *orbConfigs_; + } + + void ServerResourcesDef:: + orbConfigs (::CIAO::Config_Handlers::ORBConfigs const& e) + { + *orbConfigs_ = e; + } + + // ServerResourcesDef + // + bool ServerResourcesDef:: + id_p () const + { + return id_.get () != 0; + } + + ::XMLSchema::ID< ACE_TCHAR > const& ServerResourcesDef:: + id () const + { + return *id_; + } + + ::XMLSchema::ID< ACE_TCHAR >& ServerResourcesDef:: + id () + { + return *id_; + } + + void ServerResourcesDef:: + id (::XMLSchema::ID< ACE_TCHAR > const& e) + { + if (id_.get ()) + { + *id_ = e; + } + + else + { + id_ = ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > (new ::XMLSchema::ID< ACE_TCHAR > (e)); + id_->container (this); + } + } + + + // ServerCmdlineOptions + // + + ServerCmdlineOptions:: + ServerCmdlineOptions () + : + ::XSCRT::Type (), + regulator__ () + { + } + + ServerCmdlineOptions:: + ServerCmdlineOptions (::CIAO::Config_Handlers::ServerCmdlineOptions const& s) + : + ::XSCRT::Type (), + regulator__ () + { + { + for (arg_const_iterator i (s.arg_.begin ());i != s.arg_.end ();++i) add_arg (*i); + } + } + + ::CIAO::Config_Handlers::ServerCmdlineOptions& ServerCmdlineOptions:: + operator= (::CIAO::Config_Handlers::ServerCmdlineOptions const& s) + { + arg_.clear (); + { + for (arg_const_iterator i (s.arg_.begin ());i != s.arg_.end ();++i) add_arg (*i); + } + + return *this; + } + + + // ServerCmdlineOptions + // + ServerCmdlineOptions::arg_iterator ServerCmdlineOptions:: + begin_arg () + { + return arg_.begin (); + } + + ServerCmdlineOptions::arg_iterator ServerCmdlineOptions:: + end_arg () + { + return arg_.end (); + } + + ServerCmdlineOptions::arg_const_iterator ServerCmdlineOptions:: + begin_arg () const + { + return arg_.begin (); + } + + ServerCmdlineOptions::arg_const_iterator ServerCmdlineOptions:: + end_arg () const + { + return arg_.end (); + } + + void ServerCmdlineOptions:: + add_arg (::XMLSchema::string< ACE_TCHAR > const& e) + { + arg_.push_back (e); + } + + size_t ServerCmdlineOptions:: + count_arg(void) const + { + return arg_.size (); + } + + + // ACESvcConf + // + + ACESvcConf:: + ACESvcConf () + : + ::XSCRT::Type (), + regulator__ () + { + } + + ACESvcConf:: + ACESvcConf (::CIAO::Config_Handlers::ACESvcConf const& s) + : + ::XSCRT::Type (), + uri_ (s.uri_.get () ? new ::XMLSchema::string< ACE_TCHAR > (*s.uri_) : 0), + regulator__ () + { + if (uri_.get ()) uri_->container (this); + } + + ::CIAO::Config_Handlers::ACESvcConf& ACESvcConf:: + operator= (::CIAO::Config_Handlers::ACESvcConf const& s) + { + if (s.uri_.get ()) uri (*(s.uri_)); + else uri_ = ::std::auto_ptr< ::XMLSchema::string< ACE_TCHAR > > (0); + + return *this; + } + + + // ACESvcConf + // + bool ACESvcConf:: + uri_p () const + { + return uri_.get () != 0; + } + + ::XMLSchema::string< ACE_TCHAR > const& ACESvcConf:: + uri () const + { + return *uri_; + } + + void ACESvcConf:: + uri (::XMLSchema::string< ACE_TCHAR > const& e) + { + if (uri_.get ()) + { + *uri_ = e; + } + + else + { + uri_ = ::std::auto_ptr< ::XMLSchema::string< ACE_TCHAR > > (new ::XMLSchema::string< ACE_TCHAR > (e)); + uri_->container (this); + } + } + + + // ORBConfigs + // + + ORBConfigs:: + ORBConfigs () + : + ::XSCRT::Type (), + regulator__ () + { + } + + ORBConfigs:: + ORBConfigs (::CIAO::Config_Handlers::ORBConfigs const& s) + : + ::XSCRT::Type (), + resources_ (s.resources_.get () ? new ::CIAO::Config_Handlers::ORBResources (*s.resources_) : 0), + regulator__ () + { + if (resources_.get ()) resources_->container (this); + { + for (policySet_const_iterator i (s.policySet_.begin ());i != s.policySet_.end ();++i) add_policySet (*i); + } + } + + ::CIAO::Config_Handlers::ORBConfigs& ORBConfigs:: + operator= (::CIAO::Config_Handlers::ORBConfigs const& s) + { + if (s.resources_.get ()) resources (*(s.resources_)); + else resources_ = ::std::auto_ptr< ::CIAO::Config_Handlers::ORBResources > (0); + + policySet_.clear (); + { + for (policySet_const_iterator i (s.policySet_.begin ());i != s.policySet_.end ();++i) add_policySet (*i); + } + + return *this; + } + + + // ORBConfigs + // + bool ORBConfigs:: + resources_p () const + { + return resources_.get () != 0; + } + + ::CIAO::Config_Handlers::ORBResources const& ORBConfigs:: + resources () const + { + return *resources_; + } + + void ORBConfigs:: + resources (::CIAO::Config_Handlers::ORBResources const& e) + { + if (resources_.get ()) + { + *resources_ = e; + } + + else + { + resources_ = ::std::auto_ptr< ::CIAO::Config_Handlers::ORBResources > (new ::CIAO::Config_Handlers::ORBResources (e)); + resources_->container (this); + } + } + + // ORBConfigs + // + ORBConfigs::policySet_iterator ORBConfigs:: + begin_policySet () + { + return policySet_.begin (); + } + + ORBConfigs::policySet_iterator ORBConfigs:: + end_policySet () + { + return policySet_.end (); + } + + ORBConfigs::policySet_const_iterator ORBConfigs:: + begin_policySet () const + { + return policySet_.begin (); + } + + ORBConfigs::policySet_const_iterator ORBConfigs:: + end_policySet () const + { + return policySet_.end (); + } + + void ORBConfigs:: + add_policySet (::CIAO::Config_Handlers::PolicySet const& e) + { + policySet_.push_back (e); + } + + size_t ORBConfigs:: + count_policySet(void) const + { + return policySet_.size (); + } + + + // ORBResources + // + + ORBResources:: + ORBResources () + : + ::XSCRT::Type (), + regulator__ () + { + } + + ORBResources:: + ORBResources (::CIAO::Config_Handlers::ORBResources const& s) + : + ::XSCRT::Type (), + regulator__ () + { + { + for (threadpool_const_iterator i (s.threadpool_.begin ());i != s.threadpool_.end ();++i) add_threadpool (*i); + } + + { + for (threadpoolWithLanes_const_iterator i (s.threadpoolWithLanes_.begin ());i != s.threadpoolWithLanes_.end ();++i) add_threadpoolWithLanes (*i); + } + + { + for (connectionBands_const_iterator i (s.connectionBands_.begin ());i != s.connectionBands_.end ();++i) add_connectionBands (*i); + } + } + + ::CIAO::Config_Handlers::ORBResources& ORBResources:: + operator= (::CIAO::Config_Handlers::ORBResources const& s) + { + threadpool_.clear (); + { + for (threadpool_const_iterator i (s.threadpool_.begin ());i != s.threadpool_.end ();++i) add_threadpool (*i); + } + + threadpoolWithLanes_.clear (); + { + for (threadpoolWithLanes_const_iterator i (s.threadpoolWithLanes_.begin ());i != s.threadpoolWithLanes_.end ();++i) add_threadpoolWithLanes (*i); + } + + connectionBands_.clear (); + { + for (connectionBands_const_iterator i (s.connectionBands_.begin ());i != s.connectionBands_.end ();++i) add_connectionBands (*i); + } + + return *this; + } + + + // ORBResources + // + ORBResources::threadpool_iterator ORBResources:: + begin_threadpool () + { + return threadpool_.begin (); + } + + ORBResources::threadpool_iterator ORBResources:: + end_threadpool () + { + return threadpool_.end (); + } + + ORBResources::threadpool_const_iterator ORBResources:: + begin_threadpool () const + { + return threadpool_.begin (); + } + + ORBResources::threadpool_const_iterator ORBResources:: + end_threadpool () const + { + return threadpool_.end (); + } + + void ORBResources:: + add_threadpool (::CIAO::Config_Handlers::ThreadpoolDef const& e) + { + threadpool_.push_back (e); + } + + size_t ORBResources:: + count_threadpool(void) const + { + return threadpool_.size (); + } + + // ORBResources + // + ORBResources::threadpoolWithLanes_iterator ORBResources:: + begin_threadpoolWithLanes () + { + return threadpoolWithLanes_.begin (); + } + + ORBResources::threadpoolWithLanes_iterator ORBResources:: + end_threadpoolWithLanes () + { + return threadpoolWithLanes_.end (); + } + + ORBResources::threadpoolWithLanes_const_iterator ORBResources:: + begin_threadpoolWithLanes () const + { + return threadpoolWithLanes_.begin (); + } + + ORBResources::threadpoolWithLanes_const_iterator ORBResources:: + end_threadpoolWithLanes () const + { + return threadpoolWithLanes_.end (); + } + + void ORBResources:: + add_threadpoolWithLanes (::CIAO::Config_Handlers::ThreadpoolWithLanesDef const& e) + { + threadpoolWithLanes_.push_back (e); + } + + size_t ORBResources:: + count_threadpoolWithLanes(void) const + { + return threadpoolWithLanes_.size (); + } + + // ORBResources + // + ORBResources::connectionBands_iterator ORBResources:: + begin_connectionBands () + { + return connectionBands_.begin (); + } + + ORBResources::connectionBands_iterator ORBResources:: + end_connectionBands () + { + return connectionBands_.end (); + } + + ORBResources::connectionBands_const_iterator ORBResources:: + begin_connectionBands () const + { + return connectionBands_.begin (); + } + + ORBResources::connectionBands_const_iterator ORBResources:: + end_connectionBands () const + { + return connectionBands_.end (); + } + + void ORBResources:: + add_connectionBands (::CIAO::Config_Handlers::ConnectionBandsDef const& e) + { + connectionBands_.push_back (e); + } + + size_t ORBResources:: + count_connectionBands(void) const + { + return connectionBands_.size (); + } + + + // ThreadpoolDef + // + + ThreadpoolDef:: + ThreadpoolDef (::XMLSchema::unsignedLong const& stacksize__, + ::XMLSchema::unsignedLong const& static_threads__, + ::XMLSchema::unsignedLong const& dynamic_threads__, + ::XMLSchema::int_ const& default_priority__, + ::XMLSchema::boolean const& allow_request_buffering__, + ::XMLSchema::unsignedLong const& max_buffered_requests__, + ::XMLSchema::unsignedLong const& max_request_buffered_size__) + : + ::XSCRT::Type (), + stacksize_ (new ::XMLSchema::unsignedLong (stacksize__)), + static_threads_ (new ::XMLSchema::unsignedLong (static_threads__)), + dynamic_threads_ (new ::XMLSchema::unsignedLong (dynamic_threads__)), + default_priority_ (new ::XMLSchema::int_ (default_priority__)), + allow_request_buffering_ (new ::XMLSchema::boolean (allow_request_buffering__)), + max_buffered_requests_ (new ::XMLSchema::unsignedLong (max_buffered_requests__)), + max_request_buffered_size_ (new ::XMLSchema::unsignedLong (max_request_buffered_size__)), + regulator__ () + { + stacksize_->container (this); + static_threads_->container (this); + dynamic_threads_->container (this); + default_priority_->container (this); + allow_request_buffering_->container (this); + max_buffered_requests_->container (this); + max_request_buffered_size_->container (this); + } + + ThreadpoolDef:: + ThreadpoolDef (::CIAO::Config_Handlers::ThreadpoolDef const& s) + : + ::XSCRT::Type (), + stacksize_ (new ::XMLSchema::unsignedLong (*s.stacksize_)), + static_threads_ (new ::XMLSchema::unsignedLong (*s.static_threads_)), + dynamic_threads_ (new ::XMLSchema::unsignedLong (*s.dynamic_threads_)), + default_priority_ (new ::XMLSchema::int_ (*s.default_priority_)), + allow_request_buffering_ (new ::XMLSchema::boolean (*s.allow_request_buffering_)), + max_buffered_requests_ (new ::XMLSchema::unsignedLong (*s.max_buffered_requests_)), + max_request_buffered_size_ (new ::XMLSchema::unsignedLong (*s.max_request_buffered_size_)), + id_ (s.id_.get () ? new ::XMLSchema::ID< ACE_TCHAR > (*s.id_) : 0), + regulator__ () + { + stacksize_->container (this); + static_threads_->container (this); + dynamic_threads_->container (this); + default_priority_->container (this); + allow_request_buffering_->container (this); + max_buffered_requests_->container (this); + max_request_buffered_size_->container (this); + if (id_.get ()) id_->container (this); + } + + ::CIAO::Config_Handlers::ThreadpoolDef& ThreadpoolDef:: + operator= (::CIAO::Config_Handlers::ThreadpoolDef const& s) + { + stacksize (s.stacksize ()); + + static_threads (s.static_threads ()); + + dynamic_threads (s.dynamic_threads ()); + + default_priority (s.default_priority ()); + + allow_request_buffering (s.allow_request_buffering ()); + + max_buffered_requests (s.max_buffered_requests ()); + + max_request_buffered_size (s.max_request_buffered_size ()); + + if (s.id_.get ()) id (*(s.id_)); + else id_ = ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > (0); + + return *this; + } + + + // ThreadpoolDef + // + ::XMLSchema::unsignedLong const& ThreadpoolDef:: + stacksize () const + { + return *stacksize_; + } + + void ThreadpoolDef:: + stacksize (::XMLSchema::unsignedLong const& e) + { + *stacksize_ = e; + } + + // ThreadpoolDef + // + ::XMLSchema::unsignedLong const& ThreadpoolDef:: + static_threads () const + { + return *static_threads_; + } + + void ThreadpoolDef:: + static_threads (::XMLSchema::unsignedLong const& e) + { + *static_threads_ = e; + } + + // ThreadpoolDef + // + ::XMLSchema::unsignedLong const& ThreadpoolDef:: + dynamic_threads () const + { + return *dynamic_threads_; + } + + void ThreadpoolDef:: + dynamic_threads (::XMLSchema::unsignedLong const& e) + { + *dynamic_threads_ = e; + } + + // ThreadpoolDef + // + ::XMLSchema::int_ const& ThreadpoolDef:: + default_priority () const + { + return *default_priority_; + } + + void ThreadpoolDef:: + default_priority (::XMLSchema::int_ const& e) + { + *default_priority_ = e; + } + + // ThreadpoolDef + // + ::XMLSchema::boolean const& ThreadpoolDef:: + allow_request_buffering () const + { + return *allow_request_buffering_; + } + + void ThreadpoolDef:: + allow_request_buffering (::XMLSchema::boolean const& e) + { + *allow_request_buffering_ = e; + } + + // ThreadpoolDef + // + ::XMLSchema::unsignedLong const& ThreadpoolDef:: + max_buffered_requests () const + { + return *max_buffered_requests_; + } + + void ThreadpoolDef:: + max_buffered_requests (::XMLSchema::unsignedLong const& e) + { + *max_buffered_requests_ = e; + } + + // ThreadpoolDef + // + ::XMLSchema::unsignedLong const& ThreadpoolDef:: + max_request_buffered_size () const + { + return *max_request_buffered_size_; + } + + void ThreadpoolDef:: + max_request_buffered_size (::XMLSchema::unsignedLong const& e) + { + *max_request_buffered_size_ = e; + } + + // ThreadpoolDef + // + bool ThreadpoolDef:: + id_p () const + { + return id_.get () != 0; + } + + ::XMLSchema::ID< ACE_TCHAR > const& ThreadpoolDef:: + id () const + { + return *id_; + } + + ::XMLSchema::ID< ACE_TCHAR >& ThreadpoolDef:: + id () + { + return *id_; + } + + void ThreadpoolDef:: + id (::XMLSchema::ID< ACE_TCHAR > const& e) + { + if (id_.get ()) + { + *id_ = e; + } + + else + { + id_ = ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > (new ::XMLSchema::ID< ACE_TCHAR > (e)); + id_->container (this); + } + } + + + // ThreadpoolWithLanesDef + // + + ThreadpoolWithLanesDef:: + ThreadpoolWithLanesDef (::XMLSchema::unsignedLong const& stacksize__, + ::XMLSchema::boolean const& allow_borrowing__, + ::XMLSchema::boolean const& allow_request_buffering__, + ::XMLSchema::unsignedLong const& max_buffered_requests__, + ::XMLSchema::unsignedLong const& max_request_buffered_size__) + : + ::XSCRT::Type (), + stacksize_ (new ::XMLSchema::unsignedLong (stacksize__)), + allow_borrowing_ (new ::XMLSchema::boolean (allow_borrowing__)), + allow_request_buffering_ (new ::XMLSchema::boolean (allow_request_buffering__)), + max_buffered_requests_ (new ::XMLSchema::unsignedLong (max_buffered_requests__)), + max_request_buffered_size_ (new ::XMLSchema::unsignedLong (max_request_buffered_size__)), + regulator__ () + { + stacksize_->container (this); + allow_borrowing_->container (this); + allow_request_buffering_->container (this); + max_buffered_requests_->container (this); + max_request_buffered_size_->container (this); + } + + ThreadpoolWithLanesDef:: + ThreadpoolWithLanesDef (::CIAO::Config_Handlers::ThreadpoolWithLanesDef const& s) + : + ::XSCRT::Type (), + stacksize_ (new ::XMLSchema::unsignedLong (*s.stacksize_)), + allow_borrowing_ (new ::XMLSchema::boolean (*s.allow_borrowing_)), + allow_request_buffering_ (new ::XMLSchema::boolean (*s.allow_request_buffering_)), + max_buffered_requests_ (new ::XMLSchema::unsignedLong (*s.max_buffered_requests_)), + max_request_buffered_size_ (new ::XMLSchema::unsignedLong (*s.max_request_buffered_size_)), + id_ (s.id_.get () ? new ::XMLSchema::ID< ACE_TCHAR > (*s.id_) : 0), + regulator__ () + { + { + for (threadpoolLane_const_iterator i (s.threadpoolLane_.begin ());i != s.threadpoolLane_.end ();++i) add_threadpoolLane (*i); + } + + stacksize_->container (this); + allow_borrowing_->container (this); + allow_request_buffering_->container (this); + max_buffered_requests_->container (this); + max_request_buffered_size_->container (this); + if (id_.get ()) id_->container (this); + } + + ::CIAO::Config_Handlers::ThreadpoolWithLanesDef& ThreadpoolWithLanesDef:: + operator= (::CIAO::Config_Handlers::ThreadpoolWithLanesDef const& s) + { + threadpoolLane_.clear (); + { + for (threadpoolLane_const_iterator i (s.threadpoolLane_.begin ());i != s.threadpoolLane_.end ();++i) add_threadpoolLane (*i); + } + + stacksize (s.stacksize ()); + + allow_borrowing (s.allow_borrowing ()); + + allow_request_buffering (s.allow_request_buffering ()); + + max_buffered_requests (s.max_buffered_requests ()); + + max_request_buffered_size (s.max_request_buffered_size ()); + + if (s.id_.get ()) id (*(s.id_)); + else id_ = ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > (0); + + return *this; + } + + + // ThreadpoolWithLanesDef + // + ThreadpoolWithLanesDef::threadpoolLane_iterator ThreadpoolWithLanesDef:: + begin_threadpoolLane () + { + return threadpoolLane_.begin (); + } + + ThreadpoolWithLanesDef::threadpoolLane_iterator ThreadpoolWithLanesDef:: + end_threadpoolLane () + { + return threadpoolLane_.end (); + } + + ThreadpoolWithLanesDef::threadpoolLane_const_iterator ThreadpoolWithLanesDef:: + begin_threadpoolLane () const + { + return threadpoolLane_.begin (); + } + + ThreadpoolWithLanesDef::threadpoolLane_const_iterator ThreadpoolWithLanesDef:: + end_threadpoolLane () const + { + return threadpoolLane_.end (); + } + + void ThreadpoolWithLanesDef:: + add_threadpoolLane (::CIAO::Config_Handlers::ThreadpoolLaneDef const& e) + { + threadpoolLane_.push_back (e); + } + + size_t ThreadpoolWithLanesDef:: + count_threadpoolLane(void) const + { + return threadpoolLane_.size (); + } + + // ThreadpoolWithLanesDef + // + ::XMLSchema::unsignedLong const& ThreadpoolWithLanesDef:: + stacksize () const + { + return *stacksize_; + } + + void ThreadpoolWithLanesDef:: + stacksize (::XMLSchema::unsignedLong const& e) + { + *stacksize_ = e; + } + + // ThreadpoolWithLanesDef + // + ::XMLSchema::boolean const& ThreadpoolWithLanesDef:: + allow_borrowing () const + { + return *allow_borrowing_; + } + + void ThreadpoolWithLanesDef:: + allow_borrowing (::XMLSchema::boolean const& e) + { + *allow_borrowing_ = e; + } + + // ThreadpoolWithLanesDef + // + ::XMLSchema::boolean const& ThreadpoolWithLanesDef:: + allow_request_buffering () const + { + return *allow_request_buffering_; + } + + void ThreadpoolWithLanesDef:: + allow_request_buffering (::XMLSchema::boolean const& e) + { + *allow_request_buffering_ = e; + } + + // ThreadpoolWithLanesDef + // + ::XMLSchema::unsignedLong const& ThreadpoolWithLanesDef:: + max_buffered_requests () const + { + return *max_buffered_requests_; + } + + void ThreadpoolWithLanesDef:: + max_buffered_requests (::XMLSchema::unsignedLong const& e) + { + *max_buffered_requests_ = e; + } + + // ThreadpoolWithLanesDef + // + ::XMLSchema::unsignedLong const& ThreadpoolWithLanesDef:: + max_request_buffered_size () const + { + return *max_request_buffered_size_; + } + + void ThreadpoolWithLanesDef:: + max_request_buffered_size (::XMLSchema::unsignedLong const& e) + { + *max_request_buffered_size_ = e; + } + + // ThreadpoolWithLanesDef + // + bool ThreadpoolWithLanesDef:: + id_p () const + { + return id_.get () != 0; + } + + ::XMLSchema::ID< ACE_TCHAR > const& ThreadpoolWithLanesDef:: + id () const + { + return *id_; + } + + ::XMLSchema::ID< ACE_TCHAR >& ThreadpoolWithLanesDef:: + id () + { + return *id_; + } + + void ThreadpoolWithLanesDef:: + id (::XMLSchema::ID< ACE_TCHAR > const& e) + { + if (id_.get ()) + { + *id_ = e; + } + + else + { + id_ = ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > (new ::XMLSchema::ID< ACE_TCHAR > (e)); + id_->container (this); + } + } + + + // ThreadpoolLaneDef + // + + ThreadpoolLaneDef:: + ThreadpoolLaneDef (::XMLSchema::unsignedLong const& static_threads__, + ::XMLSchema::unsignedLong const& dynamic_threads__, + ::XMLSchema::int_ const& priority__) + : + ::XSCRT::Type (), + static_threads_ (new ::XMLSchema::unsignedLong (static_threads__)), + dynamic_threads_ (new ::XMLSchema::unsignedLong (dynamic_threads__)), + priority_ (new ::XMLSchema::int_ (priority__)), + regulator__ () + { + static_threads_->container (this); + dynamic_threads_->container (this); + priority_->container (this); + } + + ThreadpoolLaneDef:: + ThreadpoolLaneDef (::CIAO::Config_Handlers::ThreadpoolLaneDef const& s) + : + ::XSCRT::Type (), + static_threads_ (new ::XMLSchema::unsignedLong (*s.static_threads_)), + dynamic_threads_ (new ::XMLSchema::unsignedLong (*s.dynamic_threads_)), + priority_ (new ::XMLSchema::int_ (*s.priority_)), + regulator__ () + { + static_threads_->container (this); + dynamic_threads_->container (this); + priority_->container (this); + } + + ::CIAO::Config_Handlers::ThreadpoolLaneDef& ThreadpoolLaneDef:: + operator= (::CIAO::Config_Handlers::ThreadpoolLaneDef const& s) + { + static_threads (s.static_threads ()); + + dynamic_threads (s.dynamic_threads ()); + + priority (s.priority ()); + + return *this; + } + + + // ThreadpoolLaneDef + // + ::XMLSchema::unsignedLong const& ThreadpoolLaneDef:: + static_threads () const + { + return *static_threads_; + } + + void ThreadpoolLaneDef:: + static_threads (::XMLSchema::unsignedLong const& e) + { + *static_threads_ = e; + } + + // ThreadpoolLaneDef + // + ::XMLSchema::unsignedLong const& ThreadpoolLaneDef:: + dynamic_threads () const + { + return *dynamic_threads_; + } + + void ThreadpoolLaneDef:: + dynamic_threads (::XMLSchema::unsignedLong const& e) + { + *dynamic_threads_ = e; + } + + // ThreadpoolLaneDef + // + ::XMLSchema::int_ const& ThreadpoolLaneDef:: + priority () const + { + return *priority_; + } + + void ThreadpoolLaneDef:: + priority (::XMLSchema::int_ const& e) + { + *priority_ = e; + } + + + // ConnectionBandsDef + // + + ConnectionBandsDef:: + ConnectionBandsDef () + : + ::XSCRT::Type (), + regulator__ () + { + } + + ConnectionBandsDef:: + ConnectionBandsDef (::CIAO::Config_Handlers::ConnectionBandsDef const& s) + : + ::XSCRT::Type (), + id_ (s.id_.get () ? new ::XMLSchema::ID< ACE_TCHAR > (*s.id_) : 0), + regulator__ () + { + { + for (band_const_iterator i (s.band_.begin ());i != s.band_.end ();++i) add_band (*i); + } + + if (id_.get ()) id_->container (this); + } + + ::CIAO::Config_Handlers::ConnectionBandsDef& ConnectionBandsDef:: + operator= (::CIAO::Config_Handlers::ConnectionBandsDef const& s) + { + band_.clear (); + { + for (band_const_iterator i (s.band_.begin ());i != s.band_.end ();++i) add_band (*i); + } + + if (s.id_.get ()) id (*(s.id_)); + else id_ = ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > (0); + + return *this; + } + + + // ConnectionBandsDef + // + ConnectionBandsDef::band_iterator ConnectionBandsDef:: + begin_band () + { + return band_.begin (); + } + + ConnectionBandsDef::band_iterator ConnectionBandsDef:: + end_band () + { + return band_.end (); + } + + ConnectionBandsDef::band_const_iterator ConnectionBandsDef:: + begin_band () const + { + return band_.begin (); + } + + ConnectionBandsDef::band_const_iterator ConnectionBandsDef:: + end_band () const + { + return band_.end (); + } + + void ConnectionBandsDef:: + add_band (::CIAO::Config_Handlers::PriorityBandDef const& e) + { + band_.push_back (e); + } + + size_t ConnectionBandsDef:: + count_band(void) const + { + return band_.size (); + } + + // ConnectionBandsDef + // + bool ConnectionBandsDef:: + id_p () const + { + return id_.get () != 0; + } + + ::XMLSchema::ID< ACE_TCHAR > const& ConnectionBandsDef:: + id () const + { + return *id_; + } + + ::XMLSchema::ID< ACE_TCHAR >& ConnectionBandsDef:: + id () + { + return *id_; + } + + void ConnectionBandsDef:: + id (::XMLSchema::ID< ACE_TCHAR > const& e) + { + if (id_.get ()) + { + *id_ = e; + } + + else + { + id_ = ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > (new ::XMLSchema::ID< ACE_TCHAR > (e)); + id_->container (this); + } + } + + + // PriorityBandDef + // + + PriorityBandDef:: + PriorityBandDef (::XMLSchema::int_ const& low__, + ::XMLSchema::int_ const& high__) + : + ::XSCRT::Type (), + low_ (new ::XMLSchema::int_ (low__)), + high_ (new ::XMLSchema::int_ (high__)), + regulator__ () + { + low_->container (this); + high_->container (this); + } + + PriorityBandDef:: + PriorityBandDef (::CIAO::Config_Handlers::PriorityBandDef const& s) + : + ::XSCRT::Type (), + low_ (new ::XMLSchema::int_ (*s.low_)), + high_ (new ::XMLSchema::int_ (*s.high_)), + regulator__ () + { + low_->container (this); + high_->container (this); + } + + ::CIAO::Config_Handlers::PriorityBandDef& PriorityBandDef:: + operator= (::CIAO::Config_Handlers::PriorityBandDef const& s) + { + low (s.low ()); + + high (s.high ()); + + return *this; + } + + + // PriorityBandDef + // + ::XMLSchema::int_ const& PriorityBandDef:: + low () const + { + return *low_; + } + + void PriorityBandDef:: + low (::XMLSchema::int_ const& e) + { + *low_ = e; + } + + // PriorityBandDef + // + ::XMLSchema::int_ const& PriorityBandDef:: + high () const + { + return *high_; + } + + void PriorityBandDef:: + high (::XMLSchema::int_ const& e) + { + *high_ = e; + } + + + // PolicySet + // + + PolicySet:: + PolicySet () + : + ::XSCRT::Type (), + regulator__ () + { + } + + PolicySet:: + PolicySet (::CIAO::Config_Handlers::PolicySet const& s) + : + ::XSCRT::Type (), + id_ (s.id_.get () ? new ::XMLSchema::ID< ACE_TCHAR > (*s.id_) : 0), + regulator__ () + { + { + for (priorityModel_const_iterator i (s.priorityModel_.begin ());i != s.priorityModel_.end ();++i) add_priorityModel (*i); + } + + { + for (nwpriorityModel_const_iterator i (s.nwpriorityModel_.begin ());i != s.nwpriorityModel_.end ();++i) add_nwpriorityModel (*i); + } + + { + for (cnwpriorityModel_const_iterator i (s.cnwpriorityModel_.begin ());i != s.cnwpriorityModel_.end ();++i) add_cnwpriorityModel (*i); + } + + { + for (threadpool_const_iterator i (s.threadpool_.begin ());i != s.threadpool_.end ();++i) add_threadpool (*i); + } + + { + for (priorityBandedConnection_const_iterator i (s.priorityBandedConnection_.begin ());i != s.priorityBandedConnection_.end ();++i) add_priorityBandedConnection (*i); + } + + if (id_.get ()) id_->container (this); + } + + ::CIAO::Config_Handlers::PolicySet& PolicySet:: + operator= (::CIAO::Config_Handlers::PolicySet const& s) + { + priorityModel_.clear (); + { + for (priorityModel_const_iterator i (s.priorityModel_.begin ());i != s.priorityModel_.end ();++i) add_priorityModel (*i); + } + + nwpriorityModel_.clear (); + { + for (nwpriorityModel_const_iterator i (s.nwpriorityModel_.begin ());i != s.nwpriorityModel_.end ();++i) add_nwpriorityModel (*i); + } + + cnwpriorityModel_.clear (); + { + for (cnwpriorityModel_const_iterator i (s.cnwpriorityModel_.begin ());i != s.cnwpriorityModel_.end ();++i) add_cnwpriorityModel (*i); + } + + threadpool_.clear (); + { + for (threadpool_const_iterator i (s.threadpool_.begin ());i != s.threadpool_.end ();++i) add_threadpool (*i); + } + + priorityBandedConnection_.clear (); + { + for (priorityBandedConnection_const_iterator i (s.priorityBandedConnection_.begin ());i != s.priorityBandedConnection_.end ();++i) add_priorityBandedConnection (*i); + } + + if (s.id_.get ()) id (*(s.id_)); + else id_ = ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > (0); + + return *this; + } + + + // PolicySet + // + PolicySet::priorityModel_iterator PolicySet:: + begin_priorityModel () + { + return priorityModel_.begin (); + } + + PolicySet::priorityModel_iterator PolicySet:: + end_priorityModel () + { + return priorityModel_.end (); + } + + PolicySet::priorityModel_const_iterator PolicySet:: + begin_priorityModel () const + { + return priorityModel_.begin (); + } + + PolicySet::priorityModel_const_iterator PolicySet:: + end_priorityModel () const + { + return priorityModel_.end (); + } + + void PolicySet:: + add_priorityModel (::CIAO::Config_Handlers::PriorityModelPolicyDef const& e) + { + priorityModel_.push_back (e); + } + + size_t PolicySet:: + count_priorityModel(void) const + { + return priorityModel_.size (); + } + + // PolicySet + // + PolicySet::nwpriorityModel_iterator PolicySet:: + begin_nwpriorityModel () + { + return nwpriorityModel_.begin (); + } + + PolicySet::nwpriorityModel_iterator PolicySet:: + end_nwpriorityModel () + { + return nwpriorityModel_.end (); + } + + PolicySet::nwpriorityModel_const_iterator PolicySet:: + begin_nwpriorityModel () const + { + return nwpriorityModel_.begin (); + } + + PolicySet::nwpriorityModel_const_iterator PolicySet:: + end_nwpriorityModel () const + { + return nwpriorityModel_.end (); + } + + void PolicySet:: + add_nwpriorityModel (::CIAO::Config_Handlers::NWPriorityModelPolicyDef const& e) + { + nwpriorityModel_.push_back (e); + } + + size_t PolicySet:: + count_nwpriorityModel(void) const + { + return nwpriorityModel_.size (); + } + + // PolicySet + // + PolicySet::cnwpriorityModel_iterator PolicySet:: + begin_cnwpriorityModel () + { + return cnwpriorityModel_.begin (); + } + + PolicySet::cnwpriorityModel_iterator PolicySet:: + end_cnwpriorityModel () + { + return cnwpriorityModel_.end (); + } + + PolicySet::cnwpriorityModel_const_iterator PolicySet:: + begin_cnwpriorityModel () const + { + return cnwpriorityModel_.begin (); + } + + PolicySet::cnwpriorityModel_const_iterator PolicySet:: + end_cnwpriorityModel () const + { + return cnwpriorityModel_.end (); + } + + void PolicySet:: + add_cnwpriorityModel (::CIAO::Config_Handlers::CNWPriorityModelPolicyDef const& e) + { + cnwpriorityModel_.push_back (e); + } + + size_t PolicySet:: + count_cnwpriorityModel(void) const + { + return cnwpriorityModel_.size (); + } + + // PolicySet + // + PolicySet::threadpool_iterator PolicySet:: + begin_threadpool () + { + return threadpool_.begin (); + } + + PolicySet::threadpool_iterator PolicySet:: + end_threadpool () + { + return threadpool_.end (); + } + + PolicySet::threadpool_const_iterator PolicySet:: + begin_threadpool () const + { + return threadpool_.begin (); + } + + PolicySet::threadpool_const_iterator PolicySet:: + end_threadpool () const + { + return threadpool_.end (); + } + + void PolicySet:: + add_threadpool (::XMLSchema::IDREF< ACE_TCHAR > const& e) + { + threadpool_.push_back (e); + } + + size_t PolicySet:: + count_threadpool(void) const + { + return threadpool_.size (); + } + + // PolicySet + // + PolicySet::priorityBandedConnection_iterator PolicySet:: + begin_priorityBandedConnection () + { + return priorityBandedConnection_.begin (); + } + + PolicySet::priorityBandedConnection_iterator PolicySet:: + end_priorityBandedConnection () + { + return priorityBandedConnection_.end (); + } + + PolicySet::priorityBandedConnection_const_iterator PolicySet:: + begin_priorityBandedConnection () const + { + return priorityBandedConnection_.begin (); + } + + PolicySet::priorityBandedConnection_const_iterator PolicySet:: + end_priorityBandedConnection () const + { + return priorityBandedConnection_.end (); + } + + void PolicySet:: + add_priorityBandedConnection (::XMLSchema::IDREF< ACE_TCHAR > const& e) + { + priorityBandedConnection_.push_back (e); + } + + size_t PolicySet:: + count_priorityBandedConnection(void) const + { + return priorityBandedConnection_.size (); + } + + // PolicySet + // + bool PolicySet:: + id_p () const + { + return id_.get () != 0; + } + + ::XMLSchema::ID< ACE_TCHAR > const& PolicySet:: + id () const + { + return *id_; + } + + ::XMLSchema::ID< ACE_TCHAR >& PolicySet:: + id () + { + return *id_; + } + + void PolicySet:: + id (::XMLSchema::ID< ACE_TCHAR > const& e) + { + if (id_.get ()) + { + *id_ = e; + } + + else + { + id_ = ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > (new ::XMLSchema::ID< ACE_TCHAR > (e)); + id_->container (this); + } + } + + + // PriorityModel + // + + PriorityModel::Value PriorityModel:: + integral () const + { + return v_; + } + + bool + operator== (::CIAO::Config_Handlers::PriorityModel const& a, ::CIAO::Config_Handlers::PriorityModel const& b) + { + return a.v_ == b.v_; + } + + bool + operator!= (::CIAO::Config_Handlers::PriorityModel const& a, ::CIAO::Config_Handlers::PriorityModel const& b) + { + return a.v_ != b.v_; + } + + PriorityModel:: + PriorityModel (PriorityModel::Value v) + : v_ (v) + { + } + + // NWPriorityModel + // + + NWPriorityModel::Value NWPriorityModel:: + integral () const + { + return v_; + } + + bool + operator== (::CIAO::Config_Handlers::NWPriorityModel const& a, ::CIAO::Config_Handlers::NWPriorityModel const& b) + { + return a.v_ == b.v_; + } + + bool + operator!= (::CIAO::Config_Handlers::NWPriorityModel const& a, ::CIAO::Config_Handlers::NWPriorityModel const& b) + { + return a.v_ != b.v_; + } + + NWPriorityModel:: + NWPriorityModel (NWPriorityModel::Value v) + : v_ (v) + { + } + + // PriorityModelPolicyDef + // + + PriorityModelPolicyDef:: + PriorityModelPolicyDef (::CIAO::Config_Handlers::PriorityModel const& priority_model__) + : + ::XSCRT::Type (), + priority_model_ (new ::CIAO::Config_Handlers::PriorityModel (priority_model__)), + regulator__ () + { + priority_model_->container (this); + } + + PriorityModelPolicyDef:: + PriorityModelPolicyDef (::CIAO::Config_Handlers::PriorityModelPolicyDef const& s) + : + ::XSCRT::Type (), + priority_model_ (new ::CIAO::Config_Handlers::PriorityModel (*s.priority_model_)), + server_priority_ (s.server_priority_.get () ? new ::XMLSchema::int_ (*s.server_priority_) : 0), + regulator__ () + { + priority_model_->container (this); + if (server_priority_.get ()) server_priority_->container (this); + } + + ::CIAO::Config_Handlers::PriorityModelPolicyDef& PriorityModelPolicyDef:: + operator= (::CIAO::Config_Handlers::PriorityModelPolicyDef const& s) + { + priority_model (s.priority_model ()); + + if (s.server_priority_.get ()) server_priority (*(s.server_priority_)); + else server_priority_ = ::std::auto_ptr< ::XMLSchema::int_ > (0); + + return *this; + } + + + // PriorityModelPolicyDef + // + ::CIAO::Config_Handlers::PriorityModel const& PriorityModelPolicyDef:: + priority_model () const + { + return *priority_model_; + } + + void PriorityModelPolicyDef:: + priority_model (::CIAO::Config_Handlers::PriorityModel const& e) + { + *priority_model_ = e; + } + + // PriorityModelPolicyDef + // + bool PriorityModelPolicyDef:: + server_priority_p () const + { + return server_priority_.get () != 0; + } + + ::XMLSchema::int_ const& PriorityModelPolicyDef:: + server_priority () const + { + return *server_priority_; + } + + ::XMLSchema::int_& PriorityModelPolicyDef:: + server_priority () + { + return *server_priority_; + } + + void PriorityModelPolicyDef:: + server_priority (::XMLSchema::int_ const& e) + { + if (server_priority_.get ()) + { + *server_priority_ = e; + } + + else + { + server_priority_ = ::std::auto_ptr< ::XMLSchema::int_ > (new ::XMLSchema::int_ (e)); + server_priority_->container (this); + } + } + + + // NWPriorityModelPolicyDef + // + + NWPriorityModelPolicyDef:: + NWPriorityModelPolicyDef (::CIAO::Config_Handlers::NWPriorityModel const& nw_priority_model__, + ::XMLSchema::long_ const& request_dscp__, + ::XMLSchema::long_ const& reply_dscp__) + : + ::XSCRT::Type (), + nw_priority_model_ (new ::CIAO::Config_Handlers::NWPriorityModel (nw_priority_model__)), + request_dscp_ (new ::XMLSchema::long_ (request_dscp__)), + reply_dscp_ (new ::XMLSchema::long_ (reply_dscp__)), + regulator__ () + { + nw_priority_model_->container (this); + request_dscp_->container (this); + reply_dscp_->container (this); + } + + NWPriorityModelPolicyDef:: + NWPriorityModelPolicyDef (::CIAO::Config_Handlers::NWPriorityModelPolicyDef const& s) + : + ::XSCRT::Type (), + nw_priority_model_ (new ::CIAO::Config_Handlers::NWPriorityModel (*s.nw_priority_model_)), + request_dscp_ (new ::XMLSchema::long_ (*s.request_dscp_)), + reply_dscp_ (new ::XMLSchema::long_ (*s.reply_dscp_)), + regulator__ () + { + nw_priority_model_->container (this); + request_dscp_->container (this); + reply_dscp_->container (this); + } + + ::CIAO::Config_Handlers::NWPriorityModelPolicyDef& NWPriorityModelPolicyDef:: + operator= (::CIAO::Config_Handlers::NWPriorityModelPolicyDef const& s) + { + nw_priority_model (s.nw_priority_model ()); + + request_dscp (s.request_dscp ()); + + reply_dscp (s.reply_dscp ()); + + return *this; + } + + + // NWPriorityModelPolicyDef + // + ::CIAO::Config_Handlers::NWPriorityModel const& NWPriorityModelPolicyDef:: + nw_priority_model () const + { + return *nw_priority_model_; + } + + void NWPriorityModelPolicyDef:: + nw_priority_model (::CIAO::Config_Handlers::NWPriorityModel const& e) + { + *nw_priority_model_ = e; + } + + // NWPriorityModelPolicyDef + // + ::XMLSchema::long_ const& NWPriorityModelPolicyDef:: + request_dscp () const + { + return *request_dscp_; + } + + void NWPriorityModelPolicyDef:: + request_dscp (::XMLSchema::long_ const& e) + { + *request_dscp_ = e; + } + + // NWPriorityModelPolicyDef + // + ::XMLSchema::long_ const& NWPriorityModelPolicyDef:: + reply_dscp () const + { + return *reply_dscp_; + } + + void NWPriorityModelPolicyDef:: + reply_dscp (::XMLSchema::long_ const& e) + { + *reply_dscp_ = e; + } + + + // CNWPriorityModelPolicyDef + // + + CNWPriorityModelPolicyDef:: + CNWPriorityModelPolicyDef (::XMLSchema::long_ const& request_dscp__, + ::XMLSchema::long_ const& reply_dscp__) + : + ::XSCRT::Type (), + request_dscp_ (new ::XMLSchema::long_ (request_dscp__)), + reply_dscp_ (new ::XMLSchema::long_ (reply_dscp__)), + regulator__ () + { + request_dscp_->container (this); + reply_dscp_->container (this); + } + + CNWPriorityModelPolicyDef:: + CNWPriorityModelPolicyDef (::CIAO::Config_Handlers::CNWPriorityModelPolicyDef const& s) + : + ::XSCRT::Type (), + request_dscp_ (new ::XMLSchema::long_ (*s.request_dscp_)), + reply_dscp_ (new ::XMLSchema::long_ (*s.reply_dscp_)), + regulator__ () + { + request_dscp_->container (this); + reply_dscp_->container (this); + } + + ::CIAO::Config_Handlers::CNWPriorityModelPolicyDef& CNWPriorityModelPolicyDef:: + operator= (::CIAO::Config_Handlers::CNWPriorityModelPolicyDef const& s) + { + request_dscp (s.request_dscp ()); + + reply_dscp (s.reply_dscp ()); + + return *this; + } + + + // CNWPriorityModelPolicyDef + // + ::XMLSchema::long_ const& CNWPriorityModelPolicyDef:: + request_dscp () const + { + return *request_dscp_; + } + + void CNWPriorityModelPolicyDef:: + request_dscp (::XMLSchema::long_ const& e) + { + *request_dscp_ = e; + } + + // CNWPriorityModelPolicyDef + // + ::XMLSchema::long_ const& CNWPriorityModelPolicyDef:: + reply_dscp () const + { + return *reply_dscp_; + } + + void CNWPriorityModelPolicyDef:: + reply_dscp (::XMLSchema::long_ const& e) + { + *reply_dscp_ = e; + } + } +} + +namespace CIAO +{ + namespace Config_Handlers + { + // ServerResourcesDef + // + + ServerResourcesDef:: + ServerResourcesDef (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "cmdline") + { + ::CIAO::Config_Handlers::ServerCmdlineOptions t (e); + cmdline (t); + } + + else if (n == "svcconf") + { + ::CIAO::Config_Handlers::ACESvcConf t (e); + svcconf (t); + } + + else if (n == "orbConfigs") + { + orbConfigs_ = ::std::auto_ptr< ::CIAO::Config_Handlers::ORBConfigs > (new ::CIAO::Config_Handlers::ORBConfigs (e)); + orbConfigs_->container (this); + } + + else + { + } + } + + while (p.more_attributes ()) + { + ::XSCRT::XML::Attribute< ACE_TCHAR > a (p.next_attribute ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (a.name ())); + if (n == "id") + { + ::XMLSchema::ID< ACE_TCHAR > t (a); + id (t); + } + + else + { + } + } + } + + // ServerCmdlineOptions + // + + ServerCmdlineOptions:: + ServerCmdlineOptions (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "arg") + { + ::XMLSchema::string< ACE_TCHAR > t (e); + add_arg (t); + } + + else + { + } + } + } + + // ACESvcConf + // + + ACESvcConf:: + ACESvcConf (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "uri") + { + ::XMLSchema::string< ACE_TCHAR > t (e); + uri (t); + } + + else + { + } + } + } + + // ORBConfigs + // + + ORBConfigs:: + ORBConfigs (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "resources") + { + ::CIAO::Config_Handlers::ORBResources t (e); + resources (t); + } + + else if (n == "policySet") + { + ::CIAO::Config_Handlers::PolicySet t (e); + add_policySet (t); + } + + else + { + } + } + } + + // ORBResources + // + + ORBResources:: + ORBResources (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "threadpool") + { + ::CIAO::Config_Handlers::ThreadpoolDef t (e); + add_threadpool (t); + } + + else if (n == "threadpoolWithLanes") + { + ::CIAO::Config_Handlers::ThreadpoolWithLanesDef t (e); + add_threadpoolWithLanes (t); + } + + else if (n == "connectionBands") + { + ::CIAO::Config_Handlers::ConnectionBandsDef t (e); + add_connectionBands (t); + } + + else + { + } + } + } + + // ThreadpoolDef + // + + ThreadpoolDef:: + ThreadpoolDef (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "stacksize") + { + stacksize_ = ::std::auto_ptr< ::XMLSchema::unsignedLong > (new ::XMLSchema::unsignedLong (e)); + stacksize_->container (this); + } + + else if (n == "static_threads") + { + static_threads_ = ::std::auto_ptr< ::XMLSchema::unsignedLong > (new ::XMLSchema::unsignedLong (e)); + static_threads_->container (this); + } + + else if (n == "dynamic_threads") + { + dynamic_threads_ = ::std::auto_ptr< ::XMLSchema::unsignedLong > (new ::XMLSchema::unsignedLong (e)); + dynamic_threads_->container (this); + } + + else if (n == "default_priority") + { + default_priority_ = ::std::auto_ptr< ::XMLSchema::int_ > (new ::XMLSchema::int_ (e)); + default_priority_->container (this); + } + + else if (n == "allow_request_buffering") + { + allow_request_buffering_ = ::std::auto_ptr< ::XMLSchema::boolean > (new ::XMLSchema::boolean (e)); + allow_request_buffering_->container (this); + } + + else if (n == "max_buffered_requests") + { + max_buffered_requests_ = ::std::auto_ptr< ::XMLSchema::unsignedLong > (new ::XMLSchema::unsignedLong (e)); + max_buffered_requests_->container (this); + } + + else if (n == "max_request_buffered_size") + { + max_request_buffered_size_ = ::std::auto_ptr< ::XMLSchema::unsignedLong > (new ::XMLSchema::unsignedLong (e)); + max_request_buffered_size_->container (this); + } + + else + { + } + } + + while (p.more_attributes ()) + { + ::XSCRT::XML::Attribute< ACE_TCHAR > a (p.next_attribute ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (a.name ())); + if (n == "id") + { + ::XMLSchema::ID< ACE_TCHAR > t (a); + id (t); + } + + else + { + } + } + } + + // ThreadpoolWithLanesDef + // + + ThreadpoolWithLanesDef:: + ThreadpoolWithLanesDef (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "threadpoolLane") + { + ::CIAO::Config_Handlers::ThreadpoolLaneDef t (e); + add_threadpoolLane (t); + } + + else if (n == "stacksize") + { + stacksize_ = ::std::auto_ptr< ::XMLSchema::unsignedLong > (new ::XMLSchema::unsignedLong (e)); + stacksize_->container (this); + } + + else if (n == "allow_borrowing") + { + allow_borrowing_ = ::std::auto_ptr< ::XMLSchema::boolean > (new ::XMLSchema::boolean (e)); + allow_borrowing_->container (this); + } + + else if (n == "allow_request_buffering") + { + allow_request_buffering_ = ::std::auto_ptr< ::XMLSchema::boolean > (new ::XMLSchema::boolean (e)); + allow_request_buffering_->container (this); + } + + else if (n == "max_buffered_requests") + { + max_buffered_requests_ = ::std::auto_ptr< ::XMLSchema::unsignedLong > (new ::XMLSchema::unsignedLong (e)); + max_buffered_requests_->container (this); + } + + else if (n == "max_request_buffered_size") + { + max_request_buffered_size_ = ::std::auto_ptr< ::XMLSchema::unsignedLong > (new ::XMLSchema::unsignedLong (e)); + max_request_buffered_size_->container (this); + } + + else + { + } + } + + while (p.more_attributes ()) + { + ::XSCRT::XML::Attribute< ACE_TCHAR > a (p.next_attribute ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (a.name ())); + if (n == "id") + { + ::XMLSchema::ID< ACE_TCHAR > t (a); + id (t); + } + + else + { + } + } + } + + // ThreadpoolLaneDef + // + + ThreadpoolLaneDef:: + ThreadpoolLaneDef (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "static_threads") + { + static_threads_ = ::std::auto_ptr< ::XMLSchema::unsignedLong > (new ::XMLSchema::unsignedLong (e)); + static_threads_->container (this); + } + + else if (n == "dynamic_threads") + { + dynamic_threads_ = ::std::auto_ptr< ::XMLSchema::unsignedLong > (new ::XMLSchema::unsignedLong (e)); + dynamic_threads_->container (this); + } + + else if (n == "priority") + { + priority_ = ::std::auto_ptr< ::XMLSchema::int_ > (new ::XMLSchema::int_ (e)); + priority_->container (this); + } + + else + { + } + } + } + + // ConnectionBandsDef + // + + ConnectionBandsDef:: + ConnectionBandsDef (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "band") + { + ::CIAO::Config_Handlers::PriorityBandDef t (e); + add_band (t); + } + + else + { + } + } + + while (p.more_attributes ()) + { + ::XSCRT::XML::Attribute< ACE_TCHAR > a (p.next_attribute ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (a.name ())); + if (n == "id") + { + ::XMLSchema::ID< ACE_TCHAR > t (a); + id (t); + } + + else + { + } + } + } + + // PriorityBandDef + // + + PriorityBandDef:: + PriorityBandDef (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "low") + { + low_ = ::std::auto_ptr< ::XMLSchema::int_ > (new ::XMLSchema::int_ (e)); + low_->container (this); + } + + else if (n == "high") + { + high_ = ::std::auto_ptr< ::XMLSchema::int_ > (new ::XMLSchema::int_ (e)); + high_->container (this); + } + + else + { + } + } + } + + // PolicySet + // + + PolicySet:: + PolicySet (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "priorityModel") + { + ::CIAO::Config_Handlers::PriorityModelPolicyDef t (e); + add_priorityModel (t); + } + + else if (n == "nwpriorityModel") + { + ::CIAO::Config_Handlers::NWPriorityModelPolicyDef t (e); + add_nwpriorityModel (t); + } + + else if (n == "cnwpriorityModel") + { + ::CIAO::Config_Handlers::CNWPriorityModelPolicyDef t (e); + add_cnwpriorityModel (t); + } + + else if (n == "threadpool") + { + ::XMLSchema::IDREF< ACE_TCHAR > t (e); + add_threadpool (t); + } + + else if (n == "priorityBandedConnection") + { + ::XMLSchema::IDREF< ACE_TCHAR > t (e); + add_priorityBandedConnection (t); + } + + else + { + } + } + + while (p.more_attributes ()) + { + ::XSCRT::XML::Attribute< ACE_TCHAR > a (p.next_attribute ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (a.name ())); + if (n == "id") + { + ::XMLSchema::ID< ACE_TCHAR > t (a); + id (t); + } + + else + { + } + } + } + + // PriorityModel + // + + PriorityModel:: + PriorityModel (::XSCRT::XML::Element< ACE_TCHAR > const& e) + : ::XSCRT::Type (e) + { + ::std::basic_string< ACE_TCHAR > v (e.value ()); + + if (v == "SERVER_DECLARED") v_ = SERVER_DECLARED_l; + else if (v == "CLIENT_PROPAGATED") v_ = CLIENT_PROPAGATED_l; + else + { + } + } + + PriorityModel:: + PriorityModel (::XSCRT::XML::Attribute< ACE_TCHAR > const& a) + : ::XSCRT::Type (a) + { + ::std::basic_string< ACE_TCHAR > v (a.value ()); + + if (v == "SERVER_DECLARED") v_ = SERVER_DECLARED_l; + else if (v == "CLIENT_PROPAGATED") v_ = CLIENT_PROPAGATED_l; + else + { + } + } + + PriorityModel const PriorityModel::SERVER_DECLARED (PriorityModel::SERVER_DECLARED_l); + PriorityModel const PriorityModel::CLIENT_PROPAGATED (PriorityModel::CLIENT_PROPAGATED_l); + + // NWPriorityModel + // + + NWPriorityModel:: + NWPriorityModel (::XSCRT::XML::Element< ACE_TCHAR > const& e) + : ::XSCRT::Type (e) + { + ::std::basic_string< ACE_TCHAR > v (e.value ()); + + if (v == "SERVER_DECLARED_NWPRIORITY") v_ = SERVER_DECLARED_NWPRIORITY_l; + else if (v == "CLIENT_PROPAGATED_NWPRIORITY") v_ = CLIENT_PROPAGATED_NWPRIORITY_l; + else + { + } + } + + NWPriorityModel:: + NWPriorityModel (::XSCRT::XML::Attribute< ACE_TCHAR > const& a) + : ::XSCRT::Type (a) + { + ::std::basic_string< ACE_TCHAR > v (a.value ()); + + if (v == "SERVER_DECLARED_NWPRIORITY") v_ = SERVER_DECLARED_NWPRIORITY_l; + else if (v == "CLIENT_PROPAGATED_NWPRIORITY") v_ = CLIENT_PROPAGATED_NWPRIORITY_l; + else + { + } + } + + NWPriorityModel const NWPriorityModel::SERVER_DECLARED_NWPRIORITY (NWPriorityModel::SERVER_DECLARED_NWPRIORITY_l); + NWPriorityModel const NWPriorityModel::CLIENT_PROPAGATED_NWPRIORITY (NWPriorityModel::CLIENT_PROPAGATED_NWPRIORITY_l); + + // PriorityModelPolicyDef + // + + PriorityModelPolicyDef:: + PriorityModelPolicyDef (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "priority_model") + { + priority_model_ = ::std::auto_ptr< ::CIAO::Config_Handlers::PriorityModel > (new ::CIAO::Config_Handlers::PriorityModel (e)); + priority_model_->container (this); + } + + else + { + } + } + + while (p.more_attributes ()) + { + ::XSCRT::XML::Attribute< ACE_TCHAR > a (p.next_attribute ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (a.name ())); + if (n == "server_priority") + { + ::XMLSchema::int_ t (a); + server_priority (t); + } + + else + { + } + } + } + + // NWPriorityModelPolicyDef + // + + NWPriorityModelPolicyDef:: + NWPriorityModelPolicyDef (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "nw_priority_model") + { + nw_priority_model_ = ::std::auto_ptr< ::CIAO::Config_Handlers::NWPriorityModel > (new ::CIAO::Config_Handlers::NWPriorityModel (e)); + nw_priority_model_->container (this); + } + + else if (n == "request_dscp") + { + request_dscp_ = ::std::auto_ptr< ::XMLSchema::long_ > (new ::XMLSchema::long_ (e)); + request_dscp_->container (this); + } + + else if (n == "reply_dscp") + { + reply_dscp_ = ::std::auto_ptr< ::XMLSchema::long_ > (new ::XMLSchema::long_ (e)); + reply_dscp_->container (this); + } + + else + { + } + } + } + + // CNWPriorityModelPolicyDef + // + + CNWPriorityModelPolicyDef:: + CNWPriorityModelPolicyDef (::XSCRT::XML::Element< ACE_TCHAR > const& e) + :Base (e), regulator__ () + { + + ::XSCRT::Parser< ACE_TCHAR > p (e); + + while (p.more_elements ()) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (p.next_element ()); + ::std::basic_string< ACE_TCHAR > n (::XSCRT::XML::uq_name (e.name ())); + + if (n == "request_dscp") + { + request_dscp_ = ::std::auto_ptr< ::XMLSchema::long_ > (new ::XMLSchema::long_ (e)); + request_dscp_->container (this); + } + + else if (n == "reply_dscp") + { + reply_dscp_ = ::std::auto_ptr< ::XMLSchema::long_ > (new ::XMLSchema::long_ (e)); + reply_dscp_->container (this); + } + + else + { + } + } + } + } +} + +namespace CIAO +{ + namespace Config_Handlers + { + ::CIAO::Config_Handlers::ServerResourcesDef + ServerResources (xercesc::DOMDocument const* d) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (d->getDocumentElement ()); + if (e.name () == "ServerResources") + { + ::CIAO::Config_Handlers::ServerResourcesDef r (e); + return r; + } + + else + { + throw 1; + } + } + } +} + +#include "XMLSchema/TypeInfo.hpp" + +namespace CIAO +{ + namespace Config_Handlers + { + namespace + { + ::XMLSchema::TypeInfoInitializer < ACE_TCHAR > XMLSchemaTypeInfoInitializer_ (::XSCRT::extended_type_info_map ()); + + struct ServerResourcesDefTypeInfoInitializer + { + ServerResourcesDefTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (ServerResourcesDef)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + ServerResourcesDefTypeInfoInitializer ServerResourcesDefTypeInfoInitializer_; + + struct ServerCmdlineOptionsTypeInfoInitializer + { + ServerCmdlineOptionsTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (ServerCmdlineOptions)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + ServerCmdlineOptionsTypeInfoInitializer ServerCmdlineOptionsTypeInfoInitializer_; + + struct ACESvcConfTypeInfoInitializer + { + ACESvcConfTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (ACESvcConf)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + ACESvcConfTypeInfoInitializer ACESvcConfTypeInfoInitializer_; + + struct ORBConfigsTypeInfoInitializer + { + ORBConfigsTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (ORBConfigs)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + ORBConfigsTypeInfoInitializer ORBConfigsTypeInfoInitializer_; + + struct ORBResourcesTypeInfoInitializer + { + ORBResourcesTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (ORBResources)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + ORBResourcesTypeInfoInitializer ORBResourcesTypeInfoInitializer_; + + struct ThreadpoolDefTypeInfoInitializer + { + ThreadpoolDefTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (ThreadpoolDef)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + ThreadpoolDefTypeInfoInitializer ThreadpoolDefTypeInfoInitializer_; + + struct ThreadpoolWithLanesDefTypeInfoInitializer + { + ThreadpoolWithLanesDefTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (ThreadpoolWithLanesDef)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + ThreadpoolWithLanesDefTypeInfoInitializer ThreadpoolWithLanesDefTypeInfoInitializer_; + + struct ThreadpoolLaneDefTypeInfoInitializer + { + ThreadpoolLaneDefTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (ThreadpoolLaneDef)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + ThreadpoolLaneDefTypeInfoInitializer ThreadpoolLaneDefTypeInfoInitializer_; + + struct ConnectionBandsDefTypeInfoInitializer + { + ConnectionBandsDefTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (ConnectionBandsDef)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + ConnectionBandsDefTypeInfoInitializer ConnectionBandsDefTypeInfoInitializer_; + + struct PriorityBandDefTypeInfoInitializer + { + PriorityBandDefTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (PriorityBandDef)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + PriorityBandDefTypeInfoInitializer PriorityBandDefTypeInfoInitializer_; + + struct PolicySetTypeInfoInitializer + { + PolicySetTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (PolicySet)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + PolicySetTypeInfoInitializer PolicySetTypeInfoInitializer_; + + struct PriorityModelTypeInfoInitializer + { + PriorityModelTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (PriorityModel)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + PriorityModelTypeInfoInitializer PriorityModelTypeInfoInitializer_; + + struct NWPriorityModelTypeInfoInitializer + { + NWPriorityModelTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (NWPriorityModel)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + NWPriorityModelTypeInfoInitializer NWPriorityModelTypeInfoInitializer_; + + struct PriorityModelPolicyDefTypeInfoInitializer + { + PriorityModelPolicyDefTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (PriorityModelPolicyDef)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + PriorityModelPolicyDefTypeInfoInitializer PriorityModelPolicyDefTypeInfoInitializer_; + + struct NWPriorityModelPolicyDefTypeInfoInitializer + { + NWPriorityModelPolicyDefTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (NWPriorityModelPolicyDef)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + NWPriorityModelPolicyDefTypeInfoInitializer NWPriorityModelPolicyDefTypeInfoInitializer_; + + struct CNWPriorityModelPolicyDefTypeInfoInitializer + { + CNWPriorityModelPolicyDefTypeInfoInitializer () + { + ::XSCRT::TypeId id (typeid (CNWPriorityModelPolicyDef)); + ::XSCRT::ExtendedTypeInfo nf (id); + + nf.add_base (::XSCRT::ExtendedTypeInfo::Access::public_, false, typeid (::XSCRT::Type)); + ::XSCRT::extended_type_info_map ().insert (::std::make_pair (id, nf)); + } + }; + + CNWPriorityModelPolicyDefTypeInfoInitializer CNWPriorityModelPolicyDefTypeInfoInitializer_; + } + } +} + +namespace CIAO +{ + namespace Config_Handlers + { + namespace Traversal + { + // ServerResourcesDef + // + // + + void ServerResourcesDef:: + traverse (Type& o) + { + pre (o); + if (o.cmdline_p ()) cmdline (o); + else cmdline_none (o); + if (o.svcconf_p ()) svcconf (o); + else svcconf_none (o); + orbConfigs (o); + if (o.id_p ()) id (o); + else id_none (o); + post (o); + } + + void ServerResourcesDef:: + traverse (Type const& o) + { + pre (o); + if (o.cmdline_p ()) cmdline (o); + else cmdline_none (o); + if (o.svcconf_p ()) svcconf (o); + else svcconf_none (o); + orbConfigs (o); + if (o.id_p ()) id (o); + else id_none (o); + post (o); + } + + void ServerResourcesDef:: + pre (Type&) + { + } + + void ServerResourcesDef:: + pre (Type const&) + { + } + + void ServerResourcesDef:: + cmdline (Type& o) + { + dispatch (o.cmdline ()); + } + + void ServerResourcesDef:: + cmdline (Type const& o) + { + dispatch (o.cmdline ()); + } + + void ServerResourcesDef:: + cmdline_none (Type&) + { + } + + void ServerResourcesDef:: + cmdline_none (Type const&) + { + } + + void ServerResourcesDef:: + svcconf (Type& o) + { + dispatch (o.svcconf ()); + } + + void ServerResourcesDef:: + svcconf (Type const& o) + { + dispatch (o.svcconf ()); + } + + void ServerResourcesDef:: + svcconf_none (Type&) + { + } + + void ServerResourcesDef:: + svcconf_none (Type const&) + { + } + + void ServerResourcesDef:: + orbConfigs (Type& o) + { + dispatch (o.orbConfigs ()); + } + + void ServerResourcesDef:: + orbConfigs (Type const& o) + { + dispatch (o.orbConfigs ()); + } + + void ServerResourcesDef:: + id (Type& o) + { + dispatch (o.id ()); + } + + void ServerResourcesDef:: + id (Type const& o) + { + dispatch (o.id ()); + } + + void ServerResourcesDef:: + id_none (Type&) + { + } + + void ServerResourcesDef:: + id_none (Type const&) + { + } + + void ServerResourcesDef:: + post (Type&) + { + } + + void ServerResourcesDef:: + post (Type const&) + { + } + + // ServerCmdlineOptions + // + // + + void ServerCmdlineOptions:: + traverse (Type& o) + { + pre (o); + arg (o); + post (o); + } + + void ServerCmdlineOptions:: + traverse (Type const& o) + { + pre (o); + arg (o); + post (o); + } + + void ServerCmdlineOptions:: + pre (Type&) + { + } + + void ServerCmdlineOptions:: + pre (Type const&) + { + } + + void ServerCmdlineOptions:: + arg (Type& o) + { + // VC6 anathema strikes again + // + ServerCmdlineOptions::Type::arg_iterator b (o.begin_arg()), e (o.end_arg()); + + if (b != e) + { + arg_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) arg_next (o); + } + + arg_post (o); + } + } + + void ServerCmdlineOptions:: + arg (Type const& o) + { + // VC6 anathema strikes again + // + ServerCmdlineOptions::Type::arg_const_iterator b (o.begin_arg()), e (o.end_arg()); + + if (b != e) + { + arg_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) arg_next (o); + } + + arg_post (o); + } + } + + void ServerCmdlineOptions:: + arg_pre (Type&) + { + } + + void ServerCmdlineOptions:: + arg_pre (Type const&) + { + } + + void ServerCmdlineOptions:: + arg_next (Type&) + { + } + + void ServerCmdlineOptions:: + arg_next (Type const&) + { + } + + void ServerCmdlineOptions:: + arg_post (Type&) + { + } + + void ServerCmdlineOptions:: + arg_post (Type const&) + { + } + + void ServerCmdlineOptions:: + post (Type&) + { + } + + void ServerCmdlineOptions:: + post (Type const&) + { + } + + // ACESvcConf + // + // + + void ACESvcConf:: + traverse (Type& o) + { + pre (o); + if (o.uri_p ()) uri (o); + else uri_none (o); + post (o); + } + + void ACESvcConf:: + traverse (Type const& o) + { + pre (o); + if (o.uri_p ()) uri (o); + else uri_none (o); + post (o); + } + + void ACESvcConf:: + pre (Type&) + { + } + + void ACESvcConf:: + pre (Type const&) + { + } + + void ACESvcConf:: + uri (Type& o) + { + dispatch (o.uri ()); + } + + void ACESvcConf:: + uri (Type const& o) + { + dispatch (o.uri ()); + } + + void ACESvcConf:: + uri_none (Type&) + { + } + + void ACESvcConf:: + uri_none (Type const&) + { + } + + void ACESvcConf:: + post (Type&) + { + } + + void ACESvcConf:: + post (Type const&) + { + } + + // ORBConfigs + // + // + + void ORBConfigs:: + traverse (Type& o) + { + pre (o); + if (o.resources_p ()) resources (o); + else resources_none (o); + policySet (o); + post (o); + } + + void ORBConfigs:: + traverse (Type const& o) + { + pre (o); + if (o.resources_p ()) resources (o); + else resources_none (o); + policySet (o); + post (o); + } + + void ORBConfigs:: + pre (Type&) + { + } + + void ORBConfigs:: + pre (Type const&) + { + } + + void ORBConfigs:: + resources (Type& o) + { + dispatch (o.resources ()); + } + + void ORBConfigs:: + resources (Type const& o) + { + dispatch (o.resources ()); + } + + void ORBConfigs:: + resources_none (Type&) + { + } + + void ORBConfigs:: + resources_none (Type const&) + { + } + + void ORBConfigs:: + policySet (Type& o) + { + // VC6 anathema strikes again + // + ORBConfigs::Type::policySet_iterator b (o.begin_policySet()), e (o.end_policySet()); + + if (b != e) + { + policySet_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) policySet_next (o); + } + + policySet_post (o); + } + } + + void ORBConfigs:: + policySet (Type const& o) + { + // VC6 anathema strikes again + // + ORBConfigs::Type::policySet_const_iterator b (o.begin_policySet()), e (o.end_policySet()); + + if (b != e) + { + policySet_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) policySet_next (o); + } + + policySet_post (o); + } + } + + void ORBConfigs:: + policySet_pre (Type&) + { + } + + void ORBConfigs:: + policySet_pre (Type const&) + { + } + + void ORBConfigs:: + policySet_next (Type&) + { + } + + void ORBConfigs:: + policySet_next (Type const&) + { + } + + void ORBConfigs:: + policySet_post (Type&) + { + } + + void ORBConfigs:: + policySet_post (Type const&) + { + } + + void ORBConfigs:: + post (Type&) + { + } + + void ORBConfigs:: + post (Type const&) + { + } + + // ORBResources + // + // + + void ORBResources:: + traverse (Type& o) + { + pre (o); + threadpool (o); + threadpoolWithLanes (o); + connectionBands (o); + post (o); + } + + void ORBResources:: + traverse (Type const& o) + { + pre (o); + threadpool (o); + threadpoolWithLanes (o); + connectionBands (o); + post (o); + } + + void ORBResources:: + pre (Type&) + { + } + + void ORBResources:: + pre (Type const&) + { + } + + void ORBResources:: + threadpool (Type& o) + { + // VC6 anathema strikes again + // + ORBResources::Type::threadpool_iterator b (o.begin_threadpool()), e (o.end_threadpool()); + + if (b != e) + { + threadpool_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) threadpool_next (o); + } + + threadpool_post (o); + } + + else threadpool_none (o); + } + + void ORBResources:: + threadpool (Type const& o) + { + // VC6 anathema strikes again + // + ORBResources::Type::threadpool_const_iterator b (o.begin_threadpool()), e (o.end_threadpool()); + + if (b != e) + { + threadpool_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) threadpool_next (o); + } + + threadpool_post (o); + } + + else threadpool_none (o); + } + + void ORBResources:: + threadpool_pre (Type&) + { + } + + void ORBResources:: + threadpool_pre (Type const&) + { + } + + void ORBResources:: + threadpool_next (Type&) + { + } + + void ORBResources:: + threadpool_next (Type const&) + { + } + + void ORBResources:: + threadpool_post (Type&) + { + } + + void ORBResources:: + threadpool_post (Type const&) + { + } + + void ORBResources:: + threadpool_none (Type&) + { + } + + void ORBResources:: + threadpool_none (Type const&) + { + } + + void ORBResources:: + threadpoolWithLanes (Type& o) + { + // VC6 anathema strikes again + // + ORBResources::Type::threadpoolWithLanes_iterator b (o.begin_threadpoolWithLanes()), e (o.end_threadpoolWithLanes()); + + if (b != e) + { + threadpoolWithLanes_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) threadpoolWithLanes_next (o); + } + + threadpoolWithLanes_post (o); + } + + else threadpoolWithLanes_none (o); + } + + void ORBResources:: + threadpoolWithLanes (Type const& o) + { + // VC6 anathema strikes again + // + ORBResources::Type::threadpoolWithLanes_const_iterator b (o.begin_threadpoolWithLanes()), e (o.end_threadpoolWithLanes()); + + if (b != e) + { + threadpoolWithLanes_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) threadpoolWithLanes_next (o); + } + + threadpoolWithLanes_post (o); + } + + else threadpoolWithLanes_none (o); + } + + void ORBResources:: + threadpoolWithLanes_pre (Type&) + { + } + + void ORBResources:: + threadpoolWithLanes_pre (Type const&) + { + } + + void ORBResources:: + threadpoolWithLanes_next (Type&) + { + } + + void ORBResources:: + threadpoolWithLanes_next (Type const&) + { + } + + void ORBResources:: + threadpoolWithLanes_post (Type&) + { + } + + void ORBResources:: + threadpoolWithLanes_post (Type const&) + { + } + + void ORBResources:: + threadpoolWithLanes_none (Type&) + { + } + + void ORBResources:: + threadpoolWithLanes_none (Type const&) + { + } + + void ORBResources:: + connectionBands (Type& o) + { + // VC6 anathema strikes again + // + ORBResources::Type::connectionBands_iterator b (o.begin_connectionBands()), e (o.end_connectionBands()); + + if (b != e) + { + connectionBands_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) connectionBands_next (o); + } + + connectionBands_post (o); + } + + else connectionBands_none (o); + } + + void ORBResources:: + connectionBands (Type const& o) + { + // VC6 anathema strikes again + // + ORBResources::Type::connectionBands_const_iterator b (o.begin_connectionBands()), e (o.end_connectionBands()); + + if (b != e) + { + connectionBands_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) connectionBands_next (o); + } + + connectionBands_post (o); + } + + else connectionBands_none (o); + } + + void ORBResources:: + connectionBands_pre (Type&) + { + } + + void ORBResources:: + connectionBands_pre (Type const&) + { + } + + void ORBResources:: + connectionBands_next (Type&) + { + } + + void ORBResources:: + connectionBands_next (Type const&) + { + } + + void ORBResources:: + connectionBands_post (Type&) + { + } + + void ORBResources:: + connectionBands_post (Type const&) + { + } + + void ORBResources:: + connectionBands_none (Type&) + { + } + + void ORBResources:: + connectionBands_none (Type const&) + { + } + + void ORBResources:: + post (Type&) + { + } + + void ORBResources:: + post (Type const&) + { + } + + // ThreadpoolDef + // + // + + void ThreadpoolDef:: + traverse (Type& o) + { + pre (o); + stacksize (o); + static_threads (o); + dynamic_threads (o); + default_priority (o); + allow_request_buffering (o); + max_buffered_requests (o); + max_request_buffered_size (o); + if (o.id_p ()) id (o); + else id_none (o); + post (o); + } + + void ThreadpoolDef:: + traverse (Type const& o) + { + pre (o); + stacksize (o); + static_threads (o); + dynamic_threads (o); + default_priority (o); + allow_request_buffering (o); + max_buffered_requests (o); + max_request_buffered_size (o); + if (o.id_p ()) id (o); + else id_none (o); + post (o); + } + + void ThreadpoolDef:: + pre (Type&) + { + } + + void ThreadpoolDef:: + pre (Type const&) + { + } + + void ThreadpoolDef:: + stacksize (Type& o) + { + dispatch (o.stacksize ()); + } + + void ThreadpoolDef:: + stacksize (Type const& o) + { + dispatch (o.stacksize ()); + } + + void ThreadpoolDef:: + static_threads (Type& o) + { + dispatch (o.static_threads ()); + } + + void ThreadpoolDef:: + static_threads (Type const& o) + { + dispatch (o.static_threads ()); + } + + void ThreadpoolDef:: + dynamic_threads (Type& o) + { + dispatch (o.dynamic_threads ()); + } + + void ThreadpoolDef:: + dynamic_threads (Type const& o) + { + dispatch (o.dynamic_threads ()); + } + + void ThreadpoolDef:: + default_priority (Type& o) + { + dispatch (o.default_priority ()); + } + + void ThreadpoolDef:: + default_priority (Type const& o) + { + dispatch (o.default_priority ()); + } + + void ThreadpoolDef:: + allow_request_buffering (Type& o) + { + dispatch (o.allow_request_buffering ()); + } + + void ThreadpoolDef:: + allow_request_buffering (Type const& o) + { + dispatch (o.allow_request_buffering ()); + } + + void ThreadpoolDef:: + max_buffered_requests (Type& o) + { + dispatch (o.max_buffered_requests ()); + } + + void ThreadpoolDef:: + max_buffered_requests (Type const& o) + { + dispatch (o.max_buffered_requests ()); + } + + void ThreadpoolDef:: + max_request_buffered_size (Type& o) + { + dispatch (o.max_request_buffered_size ()); + } + + void ThreadpoolDef:: + max_request_buffered_size (Type const& o) + { + dispatch (o.max_request_buffered_size ()); + } + + void ThreadpoolDef:: + id (Type& o) + { + dispatch (o.id ()); + } + + void ThreadpoolDef:: + id (Type const& o) + { + dispatch (o.id ()); + } + + void ThreadpoolDef:: + id_none (Type&) + { + } + + void ThreadpoolDef:: + id_none (Type const&) + { + } + + void ThreadpoolDef:: + post (Type&) + { + } + + void ThreadpoolDef:: + post (Type const&) + { + } + + // ThreadpoolWithLanesDef + // + // + + void ThreadpoolWithLanesDef:: + traverse (Type& o) + { + pre (o); + threadpoolLane (o); + stacksize (o); + allow_borrowing (o); + allow_request_buffering (o); + max_buffered_requests (o); + max_request_buffered_size (o); + if (o.id_p ()) id (o); + else id_none (o); + post (o); + } + + void ThreadpoolWithLanesDef:: + traverse (Type const& o) + { + pre (o); + threadpoolLane (o); + stacksize (o); + allow_borrowing (o); + allow_request_buffering (o); + max_buffered_requests (o); + max_request_buffered_size (o); + if (o.id_p ()) id (o); + else id_none (o); + post (o); + } + + void ThreadpoolWithLanesDef:: + pre (Type&) + { + } + + void ThreadpoolWithLanesDef:: + pre (Type const&) + { + } + + void ThreadpoolWithLanesDef:: + threadpoolLane (Type& o) + { + // VC6 anathema strikes again + // + ThreadpoolWithLanesDef::Type::threadpoolLane_iterator b (o.begin_threadpoolLane()), e (o.end_threadpoolLane()); + + if (b != e) + { + threadpoolLane_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) threadpoolLane_next (o); + } + + threadpoolLane_post (o); + } + } + + void ThreadpoolWithLanesDef:: + threadpoolLane (Type const& o) + { + // VC6 anathema strikes again + // + ThreadpoolWithLanesDef::Type::threadpoolLane_const_iterator b (o.begin_threadpoolLane()), e (o.end_threadpoolLane()); + + if (b != e) + { + threadpoolLane_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) threadpoolLane_next (o); + } + + threadpoolLane_post (o); + } + } + + void ThreadpoolWithLanesDef:: + threadpoolLane_pre (Type&) + { + } + + void ThreadpoolWithLanesDef:: + threadpoolLane_pre (Type const&) + { + } + + void ThreadpoolWithLanesDef:: + threadpoolLane_next (Type&) + { + } + + void ThreadpoolWithLanesDef:: + threadpoolLane_next (Type const&) + { + } + + void ThreadpoolWithLanesDef:: + threadpoolLane_post (Type&) + { + } + + void ThreadpoolWithLanesDef:: + threadpoolLane_post (Type const&) + { + } + + void ThreadpoolWithLanesDef:: + stacksize (Type& o) + { + dispatch (o.stacksize ()); + } + + void ThreadpoolWithLanesDef:: + stacksize (Type const& o) + { + dispatch (o.stacksize ()); + } + + void ThreadpoolWithLanesDef:: + allow_borrowing (Type& o) + { + dispatch (o.allow_borrowing ()); + } + + void ThreadpoolWithLanesDef:: + allow_borrowing (Type const& o) + { + dispatch (o.allow_borrowing ()); + } + + void ThreadpoolWithLanesDef:: + allow_request_buffering (Type& o) + { + dispatch (o.allow_request_buffering ()); + } + + void ThreadpoolWithLanesDef:: + allow_request_buffering (Type const& o) + { + dispatch (o.allow_request_buffering ()); + } + + void ThreadpoolWithLanesDef:: + max_buffered_requests (Type& o) + { + dispatch (o.max_buffered_requests ()); + } + + void ThreadpoolWithLanesDef:: + max_buffered_requests (Type const& o) + { + dispatch (o.max_buffered_requests ()); + } + + void ThreadpoolWithLanesDef:: + max_request_buffered_size (Type& o) + { + dispatch (o.max_request_buffered_size ()); + } + + void ThreadpoolWithLanesDef:: + max_request_buffered_size (Type const& o) + { + dispatch (o.max_request_buffered_size ()); + } + + void ThreadpoolWithLanesDef:: + id (Type& o) + { + dispatch (o.id ()); + } + + void ThreadpoolWithLanesDef:: + id (Type const& o) + { + dispatch (o.id ()); + } + + void ThreadpoolWithLanesDef:: + id_none (Type&) + { + } + + void ThreadpoolWithLanesDef:: + id_none (Type const&) + { + } + + void ThreadpoolWithLanesDef:: + post (Type&) + { + } + + void ThreadpoolWithLanesDef:: + post (Type const&) + { + } + + // ThreadpoolLaneDef + // + // + + void ThreadpoolLaneDef:: + traverse (Type& o) + { + pre (o); + static_threads (o); + dynamic_threads (o); + priority (o); + post (o); + } + + void ThreadpoolLaneDef:: + traverse (Type const& o) + { + pre (o); + static_threads (o); + dynamic_threads (o); + priority (o); + post (o); + } + + void ThreadpoolLaneDef:: + pre (Type&) + { + } + + void ThreadpoolLaneDef:: + pre (Type const&) + { + } + + void ThreadpoolLaneDef:: + static_threads (Type& o) + { + dispatch (o.static_threads ()); + } + + void ThreadpoolLaneDef:: + static_threads (Type const& o) + { + dispatch (o.static_threads ()); + } + + void ThreadpoolLaneDef:: + dynamic_threads (Type& o) + { + dispatch (o.dynamic_threads ()); + } + + void ThreadpoolLaneDef:: + dynamic_threads (Type const& o) + { + dispatch (o.dynamic_threads ()); + } + + void ThreadpoolLaneDef:: + priority (Type& o) + { + dispatch (o.priority ()); + } + + void ThreadpoolLaneDef:: + priority (Type const& o) + { + dispatch (o.priority ()); + } + + void ThreadpoolLaneDef:: + post (Type&) + { + } + + void ThreadpoolLaneDef:: + post (Type const&) + { + } + + // ConnectionBandsDef + // + // + + void ConnectionBandsDef:: + traverse (Type& o) + { + pre (o); + band (o); + if (o.id_p ()) id (o); + else id_none (o); + post (o); + } + + void ConnectionBandsDef:: + traverse (Type const& o) + { + pre (o); + band (o); + if (o.id_p ()) id (o); + else id_none (o); + post (o); + } + + void ConnectionBandsDef:: + pre (Type&) + { + } + + void ConnectionBandsDef:: + pre (Type const&) + { + } + + void ConnectionBandsDef:: + band (Type& o) + { + // VC6 anathema strikes again + // + ConnectionBandsDef::Type::band_iterator b (o.begin_band()), e (o.end_band()); + + if (b != e) + { + band_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) band_next (o); + } + + band_post (o); + } + } + + void ConnectionBandsDef:: + band (Type const& o) + { + // VC6 anathema strikes again + // + ConnectionBandsDef::Type::band_const_iterator b (o.begin_band()), e (o.end_band()); + + if (b != e) + { + band_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) band_next (o); + } + + band_post (o); + } + } + + void ConnectionBandsDef:: + band_pre (Type&) + { + } + + void ConnectionBandsDef:: + band_pre (Type const&) + { + } + + void ConnectionBandsDef:: + band_next (Type&) + { + } + + void ConnectionBandsDef:: + band_next (Type const&) + { + } + + void ConnectionBandsDef:: + band_post (Type&) + { + } + + void ConnectionBandsDef:: + band_post (Type const&) + { + } + + void ConnectionBandsDef:: + id (Type& o) + { + dispatch (o.id ()); + } + + void ConnectionBandsDef:: + id (Type const& o) + { + dispatch (o.id ()); + } + + void ConnectionBandsDef:: + id_none (Type&) + { + } + + void ConnectionBandsDef:: + id_none (Type const&) + { + } + + void ConnectionBandsDef:: + post (Type&) + { + } + + void ConnectionBandsDef:: + post (Type const&) + { + } + + // PriorityBandDef + // + // + + void PriorityBandDef:: + traverse (Type& o) + { + pre (o); + low (o); + high (o); + post (o); + } + + void PriorityBandDef:: + traverse (Type const& o) + { + pre (o); + low (o); + high (o); + post (o); + } + + void PriorityBandDef:: + pre (Type&) + { + } + + void PriorityBandDef:: + pre (Type const&) + { + } + + void PriorityBandDef:: + low (Type& o) + { + dispatch (o.low ()); + } + + void PriorityBandDef:: + low (Type const& o) + { + dispatch (o.low ()); + } + + void PriorityBandDef:: + high (Type& o) + { + dispatch (o.high ()); + } + + void PriorityBandDef:: + high (Type const& o) + { + dispatch (o.high ()); + } + + void PriorityBandDef:: + post (Type&) + { + } + + void PriorityBandDef:: + post (Type const&) + { + } + + // PolicySet + // + // + + void PolicySet:: + traverse (Type& o) + { + pre (o); + priorityModel (o); + nwpriorityModel (o); + cnwpriorityModel (o); + threadpool (o); + priorityBandedConnection (o); + if (o.id_p ()) id (o); + else id_none (o); + post (o); + } + + void PolicySet:: + traverse (Type const& o) + { + pre (o); + priorityModel (o); + nwpriorityModel (o); + cnwpriorityModel (o); + threadpool (o); + priorityBandedConnection (o); + if (o.id_p ()) id (o); + else id_none (o); + post (o); + } + + void PolicySet:: + pre (Type&) + { + } + + void PolicySet:: + pre (Type const&) + { + } + + void PolicySet:: + priorityModel (Type& o) + { + // VC6 anathema strikes again + // + PolicySet::Type::priorityModel_iterator b (o.begin_priorityModel()), e (o.end_priorityModel()); + + if (b != e) + { + priorityModel_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) priorityModel_next (o); + } + + priorityModel_post (o); + } + + else priorityModel_none (o); + } + + void PolicySet:: + priorityModel (Type const& o) + { + // VC6 anathema strikes again + // + PolicySet::Type::priorityModel_const_iterator b (o.begin_priorityModel()), e (o.end_priorityModel()); + + if (b != e) + { + priorityModel_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) priorityModel_next (o); + } + + priorityModel_post (o); + } + + else priorityModel_none (o); + } + + void PolicySet:: + priorityModel_pre (Type&) + { + } + + void PolicySet:: + priorityModel_pre (Type const&) + { + } + + void PolicySet:: + priorityModel_next (Type&) + { + } + + void PolicySet:: + priorityModel_next (Type const&) + { + } + + void PolicySet:: + priorityModel_post (Type&) + { + } + + void PolicySet:: + priorityModel_post (Type const&) + { + } + + void PolicySet:: + priorityModel_none (Type&) + { + } + + void PolicySet:: + priorityModel_none (Type const&) + { + } + + void PolicySet:: + nwpriorityModel (Type& o) + { + // VC6 anathema strikes again + // + PolicySet::Type::nwpriorityModel_iterator b (o.begin_nwpriorityModel()), e (o.end_nwpriorityModel()); + + if (b != e) + { + nwpriorityModel_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) nwpriorityModel_next (o); + } + + nwpriorityModel_post (o); + } + + else nwpriorityModel_none (o); + } + + void PolicySet:: + nwpriorityModel (Type const& o) + { + // VC6 anathema strikes again + // + PolicySet::Type::nwpriorityModel_const_iterator b (o.begin_nwpriorityModel()), e (o.end_nwpriorityModel()); + + if (b != e) + { + nwpriorityModel_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) nwpriorityModel_next (o); + } + + nwpriorityModel_post (o); + } + + else nwpriorityModel_none (o); + } + + void PolicySet:: + nwpriorityModel_pre (Type&) + { + } + + void PolicySet:: + nwpriorityModel_pre (Type const&) + { + } + + void PolicySet:: + nwpriorityModel_next (Type&) + { + } + + void PolicySet:: + nwpriorityModel_next (Type const&) + { + } + + void PolicySet:: + nwpriorityModel_post (Type&) + { + } + + void PolicySet:: + nwpriorityModel_post (Type const&) + { + } + + void PolicySet:: + nwpriorityModel_none (Type&) + { + } + + void PolicySet:: + nwpriorityModel_none (Type const&) + { + } + + void PolicySet:: + cnwpriorityModel (Type& o) + { + // VC6 anathema strikes again + // + PolicySet::Type::cnwpriorityModel_iterator b (o.begin_cnwpriorityModel()), e (o.end_cnwpriorityModel()); + + if (b != e) + { + cnwpriorityModel_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) cnwpriorityModel_next (o); + } + + cnwpriorityModel_post (o); + } + + else cnwpriorityModel_none (o); + } + + void PolicySet:: + cnwpriorityModel (Type const& o) + { + // VC6 anathema strikes again + // + PolicySet::Type::cnwpriorityModel_const_iterator b (o.begin_cnwpriorityModel()), e (o.end_cnwpriorityModel()); + + if (b != e) + { + cnwpriorityModel_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) cnwpriorityModel_next (o); + } + + cnwpriorityModel_post (o); + } + + else cnwpriorityModel_none (o); + } + + void PolicySet:: + cnwpriorityModel_pre (Type&) + { + } + + void PolicySet:: + cnwpriorityModel_pre (Type const&) + { + } + + void PolicySet:: + cnwpriorityModel_next (Type&) + { + } + + void PolicySet:: + cnwpriorityModel_next (Type const&) + { + } + + void PolicySet:: + cnwpriorityModel_post (Type&) + { + } + + void PolicySet:: + cnwpriorityModel_post (Type const&) + { + } + + void PolicySet:: + cnwpriorityModel_none (Type&) + { + } + + void PolicySet:: + cnwpriorityModel_none (Type const&) + { + } + + void PolicySet:: + threadpool (Type& o) + { + // VC6 anathema strikes again + // + PolicySet::Type::threadpool_iterator b (o.begin_threadpool()), e (o.end_threadpool()); + + if (b != e) + { + threadpool_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) threadpool_next (o); + } + + threadpool_post (o); + } + + else threadpool_none (o); + } + + void PolicySet:: + threadpool (Type const& o) + { + // VC6 anathema strikes again + // + PolicySet::Type::threadpool_const_iterator b (o.begin_threadpool()), e (o.end_threadpool()); + + if (b != e) + { + threadpool_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) threadpool_next (o); + } + + threadpool_post (o); + } + + else threadpool_none (o); + } + + void PolicySet:: + threadpool_pre (Type&) + { + } + + void PolicySet:: + threadpool_pre (Type const&) + { + } + + void PolicySet:: + threadpool_next (Type&) + { + } + + void PolicySet:: + threadpool_next (Type const&) + { + } + + void PolicySet:: + threadpool_post (Type&) + { + } + + void PolicySet:: + threadpool_post (Type const&) + { + } + + void PolicySet:: + threadpool_none (Type&) + { + } + + void PolicySet:: + threadpool_none (Type const&) + { + } + + void PolicySet:: + priorityBandedConnection (Type& o) + { + // VC6 anathema strikes again + // + PolicySet::Type::priorityBandedConnection_iterator b (o.begin_priorityBandedConnection()), e (o.end_priorityBandedConnection()); + + if (b != e) + { + priorityBandedConnection_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) priorityBandedConnection_next (o); + } + + priorityBandedConnection_post (o); + } + + else priorityBandedConnection_none (o); + } + + void PolicySet:: + priorityBandedConnection (Type const& o) + { + // VC6 anathema strikes again + // + PolicySet::Type::priorityBandedConnection_const_iterator b (o.begin_priorityBandedConnection()), e (o.end_priorityBandedConnection()); + + if (b != e) + { + priorityBandedConnection_pre (o); + for (; b != e;) + { + dispatch (*b); + if (++b != e) priorityBandedConnection_next (o); + } + + priorityBandedConnection_post (o); + } + + else priorityBandedConnection_none (o); + } + + void PolicySet:: + priorityBandedConnection_pre (Type&) + { + } + + void PolicySet:: + priorityBandedConnection_pre (Type const&) + { + } + + void PolicySet:: + priorityBandedConnection_next (Type&) + { + } + + void PolicySet:: + priorityBandedConnection_next (Type const&) + { + } + + void PolicySet:: + priorityBandedConnection_post (Type&) + { + } + + void PolicySet:: + priorityBandedConnection_post (Type const&) + { + } + + void PolicySet:: + priorityBandedConnection_none (Type&) + { + } + + void PolicySet:: + priorityBandedConnection_none (Type const&) + { + } + + void PolicySet:: + id (Type& o) + { + dispatch (o.id ()); + } + + void PolicySet:: + id (Type const& o) + { + dispatch (o.id ()); + } + + void PolicySet:: + id_none (Type&) + { + } + + void PolicySet:: + id_none (Type const&) + { + } + + void PolicySet:: + post (Type&) + { + } + + void PolicySet:: + post (Type const&) + { + } + + // PriorityModelPolicyDef + // + // + + void PriorityModelPolicyDef:: + traverse (Type& o) + { + pre (o); + priority_model (o); + if (o.server_priority_p ()) server_priority (o); + else server_priority_none (o); + post (o); + } + + void PriorityModelPolicyDef:: + traverse (Type const& o) + { + pre (o); + priority_model (o); + if (o.server_priority_p ()) server_priority (o); + else server_priority_none (o); + post (o); + } + + void PriorityModelPolicyDef:: + pre (Type&) + { + } + + void PriorityModelPolicyDef:: + pre (Type const&) + { + } + + void PriorityModelPolicyDef:: + priority_model (Type& o) + { + dispatch (o.priority_model ()); + } + + void PriorityModelPolicyDef:: + priority_model (Type const& o) + { + dispatch (o.priority_model ()); + } + + void PriorityModelPolicyDef:: + server_priority (Type& o) + { + dispatch (o.server_priority ()); + } + + void PriorityModelPolicyDef:: + server_priority (Type const& o) + { + dispatch (o.server_priority ()); + } + + void PriorityModelPolicyDef:: + server_priority_none (Type&) + { + } + + void PriorityModelPolicyDef:: + server_priority_none (Type const&) + { + } + + void PriorityModelPolicyDef:: + post (Type&) + { + } + + void PriorityModelPolicyDef:: + post (Type const&) + { + } + + // NWPriorityModelPolicyDef + // + // + + void NWPriorityModelPolicyDef:: + traverse (Type& o) + { + pre (o); + nw_priority_model (o); + request_dscp (o); + reply_dscp (o); + post (o); + } + + void NWPriorityModelPolicyDef:: + traverse (Type const& o) + { + pre (o); + nw_priority_model (o); + request_dscp (o); + reply_dscp (o); + post (o); + } + + void NWPriorityModelPolicyDef:: + pre (Type&) + { + } + + void NWPriorityModelPolicyDef:: + pre (Type const&) + { + } + + void NWPriorityModelPolicyDef:: + nw_priority_model (Type& o) + { + dispatch (o.nw_priority_model ()); + } + + void NWPriorityModelPolicyDef:: + nw_priority_model (Type const& o) + { + dispatch (o.nw_priority_model ()); + } + + void NWPriorityModelPolicyDef:: + request_dscp (Type& o) + { + dispatch (o.request_dscp ()); + } + + void NWPriorityModelPolicyDef:: + request_dscp (Type const& o) + { + dispatch (o.request_dscp ()); + } + + void NWPriorityModelPolicyDef:: + reply_dscp (Type& o) + { + dispatch (o.reply_dscp ()); + } + + void NWPriorityModelPolicyDef:: + reply_dscp (Type const& o) + { + dispatch (o.reply_dscp ()); + } + + void NWPriorityModelPolicyDef:: + post (Type&) + { + } + + void NWPriorityModelPolicyDef:: + post (Type const&) + { + } + + // CNWPriorityModelPolicyDef + // + // + + void CNWPriorityModelPolicyDef:: + traverse (Type& o) + { + pre (o); + request_dscp (o); + reply_dscp (o); + post (o); + } + + void CNWPriorityModelPolicyDef:: + traverse (Type const& o) + { + pre (o); + request_dscp (o); + reply_dscp (o); + post (o); + } + + void CNWPriorityModelPolicyDef:: + pre (Type&) + { + } + + void CNWPriorityModelPolicyDef:: + pre (Type const&) + { + } + + void CNWPriorityModelPolicyDef:: + request_dscp (Type& o) + { + dispatch (o.request_dscp ()); + } + + void CNWPriorityModelPolicyDef:: + request_dscp (Type const& o) + { + dispatch (o.request_dscp ()); + } + + void CNWPriorityModelPolicyDef:: + reply_dscp (Type& o) + { + dispatch (o.reply_dscp ()); + } + + void CNWPriorityModelPolicyDef:: + reply_dscp (Type const& o) + { + dispatch (o.reply_dscp ()); + } + + void CNWPriorityModelPolicyDef:: + post (Type&) + { + } + + void CNWPriorityModelPolicyDef:: + post (Type const&) + { + } + } + } +} + +namespace CIAO +{ + namespace Config_Handlers + { + namespace Writer + { + // ServerResourcesDef + // + // + + ServerResourcesDef:: + ServerResourcesDef (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + ServerResourcesDef:: + ServerResourcesDef () + { + } + + void ServerResourcesDef:: + traverse (Type const& o) + { + Traversal::ServerResourcesDef::traverse (o); + } + + void ServerResourcesDef:: + cmdline (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("cmdline", top_ ())); + Traversal::ServerResourcesDef::cmdline (o); + pop_ (); + } + + void ServerResourcesDef:: + svcconf (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("svcconf", top_ ())); + Traversal::ServerResourcesDef::svcconf (o); + pop_ (); + } + + void ServerResourcesDef:: + orbConfigs (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("orbConfigs", top_ ())); + Traversal::ServerResourcesDef::orbConfigs (o); + pop_ (); + } + + void ServerResourcesDef:: + id (Type const& o) + { + ::XSCRT::XML::Attribute< ACE_TCHAR > a ("id", "", top_ ()); + attr_ (&a); + Traversal::ServerResourcesDef::id (o); + attr_ (0); + } + + // ServerCmdlineOptions + // + // + + ServerCmdlineOptions:: + ServerCmdlineOptions (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + ServerCmdlineOptions:: + ServerCmdlineOptions () + { + } + + void ServerCmdlineOptions:: + traverse (Type const& o) + { + Traversal::ServerCmdlineOptions::traverse (o); + } + + void ServerCmdlineOptions:: + arg_pre (Type const&) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("arg", top_ ())); + } + + void ServerCmdlineOptions:: + arg_next (Type const& o) + { + arg_post (o); + arg_pre (o); + } + + void ServerCmdlineOptions:: + arg_post (Type const&) + { + pop_ (); + } + + // ACESvcConf + // + // + + ACESvcConf:: + ACESvcConf (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + ACESvcConf:: + ACESvcConf () + { + } + + void ACESvcConf:: + traverse (Type const& o) + { + Traversal::ACESvcConf::traverse (o); + } + + void ACESvcConf:: + uri (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("uri", top_ ())); + Traversal::ACESvcConf::uri (o); + pop_ (); + } + + // ORBConfigs + // + // + + ORBConfigs:: + ORBConfigs (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + ORBConfigs:: + ORBConfigs () + { + } + + void ORBConfigs:: + traverse (Type const& o) + { + Traversal::ORBConfigs::traverse (o); + } + + void ORBConfigs:: + resources (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("resources", top_ ())); + Traversal::ORBConfigs::resources (o); + pop_ (); + } + + void ORBConfigs:: + policySet_pre (Type const&) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("policySet", top_ ())); + } + + void ORBConfigs:: + policySet_next (Type const& o) + { + policySet_post (o); + policySet_pre (o); + } + + void ORBConfigs:: + policySet_post (Type const&) + { + pop_ (); + } + + // ORBResources + // + // + + ORBResources:: + ORBResources (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + ORBResources:: + ORBResources () + { + } + + void ORBResources:: + traverse (Type const& o) + { + Traversal::ORBResources::traverse (o); + } + + void ORBResources:: + threadpool_pre (Type const&) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("threadpool", top_ ())); + } + + void ORBResources:: + threadpool_next (Type const& o) + { + threadpool_post (o); + threadpool_pre (o); + } + + void ORBResources:: + threadpool_post (Type const&) + { + pop_ (); + } + + void ORBResources:: + threadpoolWithLanes_pre (Type const&) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("threadpoolWithLanes", top_ ())); + } + + void ORBResources:: + threadpoolWithLanes_next (Type const& o) + { + threadpoolWithLanes_post (o); + threadpoolWithLanes_pre (o); + } + + void ORBResources:: + threadpoolWithLanes_post (Type const&) + { + pop_ (); + } + + void ORBResources:: + connectionBands_pre (Type const&) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("connectionBands", top_ ())); + } + + void ORBResources:: + connectionBands_next (Type const& o) + { + connectionBands_post (o); + connectionBands_pre (o); + } + + void ORBResources:: + connectionBands_post (Type const&) + { + pop_ (); + } + + // ThreadpoolDef + // + // + + ThreadpoolDef:: + ThreadpoolDef (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + ThreadpoolDef:: + ThreadpoolDef () + { + } + + void ThreadpoolDef:: + traverse (Type const& o) + { + Traversal::ThreadpoolDef::traverse (o); + } + + void ThreadpoolDef:: + stacksize (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("stacksize", top_ ())); + Traversal::ThreadpoolDef::stacksize (o); + pop_ (); + } + + void ThreadpoolDef:: + static_threads (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("static_threads", top_ ())); + Traversal::ThreadpoolDef::static_threads (o); + pop_ (); + } + + void ThreadpoolDef:: + dynamic_threads (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("dynamic_threads", top_ ())); + Traversal::ThreadpoolDef::dynamic_threads (o); + pop_ (); + } + + void ThreadpoolDef:: + default_priority (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("default_priority", top_ ())); + Traversal::ThreadpoolDef::default_priority (o); + pop_ (); + } + + void ThreadpoolDef:: + allow_request_buffering (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("allow_request_buffering", top_ ())); + Traversal::ThreadpoolDef::allow_request_buffering (o); + pop_ (); + } + + void ThreadpoolDef:: + max_buffered_requests (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("max_buffered_requests", top_ ())); + Traversal::ThreadpoolDef::max_buffered_requests (o); + pop_ (); + } + + void ThreadpoolDef:: + max_request_buffered_size (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("max_request_buffered_size", top_ ())); + Traversal::ThreadpoolDef::max_request_buffered_size (o); + pop_ (); + } + + void ThreadpoolDef:: + id (Type const& o) + { + ::XSCRT::XML::Attribute< ACE_TCHAR > a ("id", "", top_ ()); + attr_ (&a); + Traversal::ThreadpoolDef::id (o); + attr_ (0); + } + + // ThreadpoolWithLanesDef + // + // + + ThreadpoolWithLanesDef:: + ThreadpoolWithLanesDef (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + ThreadpoolWithLanesDef:: + ThreadpoolWithLanesDef () + { + } + + void ThreadpoolWithLanesDef:: + traverse (Type const& o) + { + Traversal::ThreadpoolWithLanesDef::traverse (o); + } + + void ThreadpoolWithLanesDef:: + threadpoolLane_pre (Type const&) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("threadpoolLane", top_ ())); + } + + void ThreadpoolWithLanesDef:: + threadpoolLane_next (Type const& o) + { + threadpoolLane_post (o); + threadpoolLane_pre (o); + } + + void ThreadpoolWithLanesDef:: + threadpoolLane_post (Type const&) + { + pop_ (); + } + + void ThreadpoolWithLanesDef:: + stacksize (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("stacksize", top_ ())); + Traversal::ThreadpoolWithLanesDef::stacksize (o); + pop_ (); + } + + void ThreadpoolWithLanesDef:: + allow_borrowing (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("allow_borrowing", top_ ())); + Traversal::ThreadpoolWithLanesDef::allow_borrowing (o); + pop_ (); + } + + void ThreadpoolWithLanesDef:: + allow_request_buffering (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("allow_request_buffering", top_ ())); + Traversal::ThreadpoolWithLanesDef::allow_request_buffering (o); + pop_ (); + } + + void ThreadpoolWithLanesDef:: + max_buffered_requests (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("max_buffered_requests", top_ ())); + Traversal::ThreadpoolWithLanesDef::max_buffered_requests (o); + pop_ (); + } + + void ThreadpoolWithLanesDef:: + max_request_buffered_size (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("max_request_buffered_size", top_ ())); + Traversal::ThreadpoolWithLanesDef::max_request_buffered_size (o); + pop_ (); + } + + void ThreadpoolWithLanesDef:: + id (Type const& o) + { + ::XSCRT::XML::Attribute< ACE_TCHAR > a ("id", "", top_ ()); + attr_ (&a); + Traversal::ThreadpoolWithLanesDef::id (o); + attr_ (0); + } + + // ThreadpoolLaneDef + // + // + + ThreadpoolLaneDef:: + ThreadpoolLaneDef (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + ThreadpoolLaneDef:: + ThreadpoolLaneDef () + { + } + + void ThreadpoolLaneDef:: + traverse (Type const& o) + { + Traversal::ThreadpoolLaneDef::traverse (o); + } + + void ThreadpoolLaneDef:: + static_threads (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("static_threads", top_ ())); + Traversal::ThreadpoolLaneDef::static_threads (o); + pop_ (); + } + + void ThreadpoolLaneDef:: + dynamic_threads (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("dynamic_threads", top_ ())); + Traversal::ThreadpoolLaneDef::dynamic_threads (o); + pop_ (); + } + + void ThreadpoolLaneDef:: + priority (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("priority", top_ ())); + Traversal::ThreadpoolLaneDef::priority (o); + pop_ (); + } + + // ConnectionBandsDef + // + // + + ConnectionBandsDef:: + ConnectionBandsDef (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + ConnectionBandsDef:: + ConnectionBandsDef () + { + } + + void ConnectionBandsDef:: + traverse (Type const& o) + { + Traversal::ConnectionBandsDef::traverse (o); + } + + void ConnectionBandsDef:: + band_pre (Type const&) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("band", top_ ())); + } + + void ConnectionBandsDef:: + band_next (Type const& o) + { + band_post (o); + band_pre (o); + } + + void ConnectionBandsDef:: + band_post (Type const&) + { + pop_ (); + } + + void ConnectionBandsDef:: + id (Type const& o) + { + ::XSCRT::XML::Attribute< ACE_TCHAR > a ("id", "", top_ ()); + attr_ (&a); + Traversal::ConnectionBandsDef::id (o); + attr_ (0); + } + + // PriorityBandDef + // + // + + PriorityBandDef:: + PriorityBandDef (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + PriorityBandDef:: + PriorityBandDef () + { + } + + void PriorityBandDef:: + traverse (Type const& o) + { + Traversal::PriorityBandDef::traverse (o); + } + + void PriorityBandDef:: + low (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("low", top_ ())); + Traversal::PriorityBandDef::low (o); + pop_ (); + } + + void PriorityBandDef:: + high (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("high", top_ ())); + Traversal::PriorityBandDef::high (o); + pop_ (); + } + + // PolicySet + // + // + + PolicySet:: + PolicySet (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + PolicySet:: + PolicySet () + { + } + + void PolicySet:: + traverse (Type const& o) + { + Traversal::PolicySet::traverse (o); + } + + void PolicySet:: + priorityModel_pre (Type const&) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("priorityModel", top_ ())); + } + + void PolicySet:: + priorityModel_next (Type const& o) + { + priorityModel_post (o); + priorityModel_pre (o); + } + + void PolicySet:: + priorityModel_post (Type const&) + { + pop_ (); + } + + void PolicySet:: + nwpriorityModel_pre (Type const&) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("nwpriorityModel", top_ ())); + } + + void PolicySet:: + nwpriorityModel_next (Type const& o) + { + nwpriorityModel_post (o); + nwpriorityModel_pre (o); + } + + void PolicySet:: + nwpriorityModel_post (Type const&) + { + pop_ (); + } + + void PolicySet:: + cnwpriorityModel_pre (Type const&) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("cnwpriorityModel", top_ ())); + } + + void PolicySet:: + cnwpriorityModel_next (Type const& o) + { + cnwpriorityModel_post (o); + cnwpriorityModel_pre (o); + } + + void PolicySet:: + cnwpriorityModel_post (Type const&) + { + pop_ (); + } + + void PolicySet:: + threadpool_pre (Type const&) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("threadpool", top_ ())); + } + + void PolicySet:: + threadpool_next (Type const& o) + { + threadpool_post (o); + threadpool_pre (o); + } + + void PolicySet:: + threadpool_post (Type const&) + { + pop_ (); + } + + void PolicySet:: + priorityBandedConnection_pre (Type const&) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("priorityBandedConnection", top_ ())); + } + + void PolicySet:: + priorityBandedConnection_next (Type const& o) + { + priorityBandedConnection_post (o); + priorityBandedConnection_pre (o); + } + + void PolicySet:: + priorityBandedConnection_post (Type const&) + { + pop_ (); + } + + void PolicySet:: + id (Type const& o) + { + ::XSCRT::XML::Attribute< ACE_TCHAR > a ("id", "", top_ ()); + attr_ (&a); + Traversal::PolicySet::id (o); + attr_ (0); + } + + // PriorityModel + // + // + + PriorityModel:: + PriorityModel (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + PriorityModel:: + PriorityModel () + { + } + + void PriorityModel:: + traverse (Type const& o) + { + ::std::basic_string< ACE_TCHAR > s; + + if (o == ::CIAO::Config_Handlers::PriorityModel::SERVER_DECLARED) s = "SERVER_DECLARED"; + else if (o == ::CIAO::Config_Handlers::PriorityModel::CLIENT_PROPAGATED) s = "CLIENT_PROPAGATED"; + else + { + } + + if (::XSCRT::XML::Attribute< ACE_TCHAR >* a = attr_ ()) + { + a->value (s); + } + + else + { + top_().value (s); + } + } + + // NWPriorityModel + // + // + + NWPriorityModel:: + NWPriorityModel (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + NWPriorityModel:: + NWPriorityModel () + { + } + + void NWPriorityModel:: + traverse (Type const& o) + { + ::std::basic_string< ACE_TCHAR > s; + + if (o == ::CIAO::Config_Handlers::NWPriorityModel::SERVER_DECLARED_NWPRIORITY) s = "SERVER_DECLARED_NWPRIORITY"; + else if (o == ::CIAO::Config_Handlers::NWPriorityModel::CLIENT_PROPAGATED_NWPRIORITY) s = "CLIENT_PROPAGATED_NWPRIORITY"; + else + { + } + + if (::XSCRT::XML::Attribute< ACE_TCHAR >* a = attr_ ()) + { + a->value (s); + } + + else + { + top_().value (s); + } + } + + // PriorityModelPolicyDef + // + // + + PriorityModelPolicyDef:: + PriorityModelPolicyDef (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + PriorityModelPolicyDef:: + PriorityModelPolicyDef () + { + } + + void PriorityModelPolicyDef:: + traverse (Type const& o) + { + Traversal::PriorityModelPolicyDef::traverse (o); + } + + void PriorityModelPolicyDef:: + priority_model (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("priority_model", top_ ())); + Traversal::PriorityModelPolicyDef::priority_model (o); + pop_ (); + } + + void PriorityModelPolicyDef:: + server_priority (Type const& o) + { + ::XSCRT::XML::Attribute< ACE_TCHAR > a ("server_priority", "", top_ ()); + attr_ (&a); + Traversal::PriorityModelPolicyDef::server_priority (o); + attr_ (0); + } + + // NWPriorityModelPolicyDef + // + // + + NWPriorityModelPolicyDef:: + NWPriorityModelPolicyDef (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + NWPriorityModelPolicyDef:: + NWPriorityModelPolicyDef () + { + } + + void NWPriorityModelPolicyDef:: + traverse (Type const& o) + { + Traversal::NWPriorityModelPolicyDef::traverse (o); + } + + void NWPriorityModelPolicyDef:: + nw_priority_model (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("nw_priority_model", top_ ())); + Traversal::NWPriorityModelPolicyDef::nw_priority_model (o); + pop_ (); + } + + void NWPriorityModelPolicyDef:: + request_dscp (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("request_dscp", top_ ())); + Traversal::NWPriorityModelPolicyDef::request_dscp (o); + pop_ (); + } + + void NWPriorityModelPolicyDef:: + reply_dscp (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("reply_dscp", top_ ())); + Traversal::NWPriorityModelPolicyDef::reply_dscp (o); + pop_ (); + } + + // CNWPriorityModelPolicyDef + // + // + + CNWPriorityModelPolicyDef:: + CNWPriorityModelPolicyDef (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + + CNWPriorityModelPolicyDef:: + CNWPriorityModelPolicyDef () + { + } + + void CNWPriorityModelPolicyDef:: + traverse (Type const& o) + { + Traversal::CNWPriorityModelPolicyDef::traverse (o); + } + + void CNWPriorityModelPolicyDef:: + request_dscp (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("request_dscp", top_ ())); + Traversal::CNWPriorityModelPolicyDef::request_dscp (o); + pop_ (); + } + + void CNWPriorityModelPolicyDef:: + reply_dscp (Type const& o) + { + push_ (::XSCRT::XML::Element< ACE_TCHAR > ("reply_dscp", top_ ())); + Traversal::CNWPriorityModelPolicyDef::reply_dscp (o); + pop_ (); + } + } + } +} + +namespace CIAO +{ + namespace Config_Handlers + { + void + ServerResources (::CIAO::Config_Handlers::ServerResourcesDef const& s, xercesc::DOMDocument* d) + { + ::XSCRT::XML::Element< ACE_TCHAR > e (d->getDocumentElement ()); + if (e.name () != "ServerResources") + { + throw 1; + } + + struct W : virtual ::CIAO::Config_Handlers::Writer::ServerResourcesDef, + virtual ::CIAO::Config_Handlers::Writer::ServerCmdlineOptions, + virtual ::XMLSchema::Writer::FundamentalType< ::XMLSchema::string< ACE_TCHAR >, ACE_TCHAR >, + virtual ::CIAO::Config_Handlers::Writer::ACESvcConf, + virtual ::CIAO::Config_Handlers::Writer::ORBConfigs, + virtual ::CIAO::Config_Handlers::Writer::ORBResources, + virtual ::CIAO::Config_Handlers::Writer::ThreadpoolDef, + virtual ::XMLSchema::Writer::FundamentalType< ::XMLSchema::unsignedLong, ACE_TCHAR >, + virtual ::XMLSchema::Writer::FundamentalType< ::XMLSchema::int_, ACE_TCHAR >, + virtual ::XMLSchema::Writer::FundamentalType< ::XMLSchema::boolean, ACE_TCHAR >, + virtual ::XMLSchema::Writer::FundamentalType< ::XMLSchema::ID< ACE_TCHAR >, ACE_TCHAR >, + virtual ::CIAO::Config_Handlers::Writer::ThreadpoolWithLanesDef, + virtual ::CIAO::Config_Handlers::Writer::ThreadpoolLaneDef, + virtual ::CIAO::Config_Handlers::Writer::ConnectionBandsDef, + virtual ::CIAO::Config_Handlers::Writer::PriorityBandDef, + virtual ::CIAO::Config_Handlers::Writer::PolicySet, + virtual ::CIAO::Config_Handlers::Writer::PriorityModelPolicyDef, + virtual ::CIAO::Config_Handlers::Writer::PriorityModel, + virtual ::CIAO::Config_Handlers::Writer::NWPriorityModelPolicyDef, + virtual ::CIAO::Config_Handlers::Writer::NWPriorityModel, + virtual ::XMLSchema::Writer::FundamentalType< ::XMLSchema::long_, ACE_TCHAR >, + virtual ::CIAO::Config_Handlers::Writer::CNWPriorityModelPolicyDef, + virtual ::XMLSchema::Writer::IDREF< ACE_TCHAR >, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + W (::XSCRT::XML::Element< ACE_TCHAR >& e) + : ::XSCRT::Writer< ACE_TCHAR > (e) + { + } + }; + + W w (e); + w.dispatch (s); + } + } +} + diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/CIAOServerResources.hpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/CIAOServerResources.hpp new file mode 100644 index 00000000000..a5a4cd9c951 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/CIAOServerResources.hpp @@ -0,0 +1,2940 @@ +/* $Id$ + * This code was generated by the XML Schema Compiler. + * + * Changes made to this code will most likely be overwritten + * when the handlers are recompiled. + * + * If you find errors or feel that there are bugfixes to be made, + * please contact the current XSC maintainer: + * Will Otte <wotte@dre.vanderbilt.edu> + */ + +// Fix for Borland compilers, which seem to have a broken +// <string> include. +#ifdef __BORLANDC__ +# include <string.h> +#endif + +#ifndef CIAOSERVER_RESOURCES_HPP +#define CIAOSERVER_RESOURCES_HPP + +#include "RT_CCM_Handlers_Export.h" +// Forward declarations. +// +namespace CIAO +{ + namespace Config_Handlers + { + class ServerResourcesDef; + class ServerCmdlineOptions; + class ACESvcConf; + class ORBConfigs; + class ORBResources; + class ThreadpoolDef; + class ThreadpoolWithLanesDef; + class ThreadpoolLaneDef; + class ConnectionBandsDef; + class PriorityBandDef; + class PolicySet; + class PriorityModel; + class NWPriorityModel; + class PriorityModelPolicyDef; + class NWPriorityModelPolicyDef; + class CNWPriorityModelPolicyDef; + } +} + +#include <memory> +#include <list> +#include "XMLSchema/Types.hpp" + +namespace CIAO +{ + namespace Config_Handlers + { + class RT_CCM_Handlers_Export ServerResourcesDef : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // cmdline + // + public: + bool cmdline_p () const; + ::CIAO::Config_Handlers::ServerCmdlineOptions const& cmdline () const; + void cmdline (::CIAO::Config_Handlers::ServerCmdlineOptions const& ); + + protected: + ::std::auto_ptr< ::CIAO::Config_Handlers::ServerCmdlineOptions > cmdline_; + + // svcconf + // + public: + bool svcconf_p () const; + ::CIAO::Config_Handlers::ACESvcConf const& svcconf () const; + void svcconf (::CIAO::Config_Handlers::ACESvcConf const& ); + + protected: + ::std::auto_ptr< ::CIAO::Config_Handlers::ACESvcConf > svcconf_; + + // orbConfigs + // + public: + ::CIAO::Config_Handlers::ORBConfigs const& orbConfigs () const; + void orbConfigs (::CIAO::Config_Handlers::ORBConfigs const& ); + + protected: + ::std::auto_ptr< ::CIAO::Config_Handlers::ORBConfigs > orbConfigs_; + + // id + // + public: + bool id_p () const; + ::XMLSchema::ID< ACE_TCHAR > const& id () const; + ::XMLSchema::ID< ACE_TCHAR >& id (); + void id (::XMLSchema::ID< ACE_TCHAR > const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > id_; + + public: + ServerResourcesDef (::CIAO::Config_Handlers::ORBConfigs const& orbConfigs__); + + ServerResourcesDef (::XSCRT::XML::Element< ACE_TCHAR > const&); + ServerResourcesDef (ServerResourcesDef const& s); + + ServerResourcesDef& + operator= (ServerResourcesDef const& s); + + private: + char regulator__; + }; + + + class RT_CCM_Handlers_Export ServerCmdlineOptions : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // arg + // + public: + typedef ::std::list< ::XMLSchema::string< ACE_TCHAR > >::iterator arg_iterator; + typedef ::std::list< ::XMLSchema::string< ACE_TCHAR > >::const_iterator arg_const_iterator; + arg_iterator begin_arg (); + arg_iterator end_arg (); + arg_const_iterator begin_arg () const; + arg_const_iterator end_arg () const; + void add_arg (::XMLSchema::string< ACE_TCHAR > const& ); + size_t count_arg (void) const; + + protected: + ::std::list< ::XMLSchema::string< ACE_TCHAR > > arg_; + + public: + ServerCmdlineOptions (); + + ServerCmdlineOptions (::XSCRT::XML::Element< ACE_TCHAR > const&); + ServerCmdlineOptions (ServerCmdlineOptions const& s); + + ServerCmdlineOptions& + operator= (ServerCmdlineOptions const& s); + + private: + char regulator__; + }; + + + class RT_CCM_Handlers_Export ACESvcConf : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // uri + // + public: + bool uri_p () const; + ::XMLSchema::string< ACE_TCHAR > const& uri () const; + void uri (::XMLSchema::string< ACE_TCHAR > const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::string< ACE_TCHAR > > uri_; + + public: + ACESvcConf (); + + ACESvcConf (::XSCRT::XML::Element< ACE_TCHAR > const&); + ACESvcConf (ACESvcConf const& s); + + ACESvcConf& + operator= (ACESvcConf const& s); + + private: + char regulator__; + }; + + + class RT_CCM_Handlers_Export ORBConfigs : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // resources + // + public: + bool resources_p () const; + ::CIAO::Config_Handlers::ORBResources const& resources () const; + void resources (::CIAO::Config_Handlers::ORBResources const& ); + + protected: + ::std::auto_ptr< ::CIAO::Config_Handlers::ORBResources > resources_; + + // policySet + // + public: + typedef ::std::list< ::CIAO::Config_Handlers::PolicySet >::iterator policySet_iterator; + typedef ::std::list< ::CIAO::Config_Handlers::PolicySet >::const_iterator policySet_const_iterator; + policySet_iterator begin_policySet (); + policySet_iterator end_policySet (); + policySet_const_iterator begin_policySet () const; + policySet_const_iterator end_policySet () const; + void add_policySet (::CIAO::Config_Handlers::PolicySet const& ); + size_t count_policySet (void) const; + + protected: + ::std::list< ::CIAO::Config_Handlers::PolicySet > policySet_; + + public: + ORBConfigs (); + + ORBConfigs (::XSCRT::XML::Element< ACE_TCHAR > const&); + ORBConfigs (ORBConfigs const& s); + + ORBConfigs& + operator= (ORBConfigs const& s); + + private: + char regulator__; + }; + + + class RT_CCM_Handlers_Export ORBResources : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // threadpool + // + public: + typedef ::std::list< ::CIAO::Config_Handlers::ThreadpoolDef >::iterator threadpool_iterator; + typedef ::std::list< ::CIAO::Config_Handlers::ThreadpoolDef >::const_iterator threadpool_const_iterator; + threadpool_iterator begin_threadpool (); + threadpool_iterator end_threadpool (); + threadpool_const_iterator begin_threadpool () const; + threadpool_const_iterator end_threadpool () const; + void add_threadpool (::CIAO::Config_Handlers::ThreadpoolDef const& ); + size_t count_threadpool (void) const; + + protected: + ::std::list< ::CIAO::Config_Handlers::ThreadpoolDef > threadpool_; + + // threadpoolWithLanes + // + public: + typedef ::std::list< ::CIAO::Config_Handlers::ThreadpoolWithLanesDef >::iterator threadpoolWithLanes_iterator; + typedef ::std::list< ::CIAO::Config_Handlers::ThreadpoolWithLanesDef >::const_iterator threadpoolWithLanes_const_iterator; + threadpoolWithLanes_iterator begin_threadpoolWithLanes (); + threadpoolWithLanes_iterator end_threadpoolWithLanes (); + threadpoolWithLanes_const_iterator begin_threadpoolWithLanes () const; + threadpoolWithLanes_const_iterator end_threadpoolWithLanes () const; + void add_threadpoolWithLanes (::CIAO::Config_Handlers::ThreadpoolWithLanesDef const& ); + size_t count_threadpoolWithLanes (void) const; + + protected: + ::std::list< ::CIAO::Config_Handlers::ThreadpoolWithLanesDef > threadpoolWithLanes_; + + // connectionBands + // + public: + typedef ::std::list< ::CIAO::Config_Handlers::ConnectionBandsDef >::iterator connectionBands_iterator; + typedef ::std::list< ::CIAO::Config_Handlers::ConnectionBandsDef >::const_iterator connectionBands_const_iterator; + connectionBands_iterator begin_connectionBands (); + connectionBands_iterator end_connectionBands (); + connectionBands_const_iterator begin_connectionBands () const; + connectionBands_const_iterator end_connectionBands () const; + void add_connectionBands (::CIAO::Config_Handlers::ConnectionBandsDef const& ); + size_t count_connectionBands (void) const; + + protected: + ::std::list< ::CIAO::Config_Handlers::ConnectionBandsDef > connectionBands_; + + public: + ORBResources (); + + ORBResources (::XSCRT::XML::Element< ACE_TCHAR > const&); + ORBResources (ORBResources const& s); + + ORBResources& + operator= (ORBResources const& s); + + private: + char regulator__; + }; + + + class RT_CCM_Handlers_Export ThreadpoolDef : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // stacksize + // + public: + ::XMLSchema::unsignedLong const& stacksize () const; + void stacksize (::XMLSchema::unsignedLong const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::unsignedLong > stacksize_; + + // static_threads + // + public: + ::XMLSchema::unsignedLong const& static_threads () const; + void static_threads (::XMLSchema::unsignedLong const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::unsignedLong > static_threads_; + + // dynamic_threads + // + public: + ::XMLSchema::unsignedLong const& dynamic_threads () const; + void dynamic_threads (::XMLSchema::unsignedLong const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::unsignedLong > dynamic_threads_; + + // default_priority + // + public: + ::XMLSchema::int_ const& default_priority () const; + void default_priority (::XMLSchema::int_ const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::int_ > default_priority_; + + // allow_request_buffering + // + public: + ::XMLSchema::boolean const& allow_request_buffering () const; + void allow_request_buffering (::XMLSchema::boolean const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::boolean > allow_request_buffering_; + + // max_buffered_requests + // + public: + ::XMLSchema::unsignedLong const& max_buffered_requests () const; + void max_buffered_requests (::XMLSchema::unsignedLong const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::unsignedLong > max_buffered_requests_; + + // max_request_buffered_size + // + public: + ::XMLSchema::unsignedLong const& max_request_buffered_size () const; + void max_request_buffered_size (::XMLSchema::unsignedLong const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::unsignedLong > max_request_buffered_size_; + + // id + // + public: + bool id_p () const; + ::XMLSchema::ID< ACE_TCHAR > const& id () const; + ::XMLSchema::ID< ACE_TCHAR >& id (); + void id (::XMLSchema::ID< ACE_TCHAR > const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > id_; + + public: + ThreadpoolDef (::XMLSchema::unsignedLong const& stacksize__, + ::XMLSchema::unsignedLong const& static_threads__, + ::XMLSchema::unsignedLong const& dynamic_threads__, + ::XMLSchema::int_ const& default_priority__, + ::XMLSchema::boolean const& allow_request_buffering__, + ::XMLSchema::unsignedLong const& max_buffered_requests__, + ::XMLSchema::unsignedLong const& max_request_buffered_size__); + + ThreadpoolDef (::XSCRT::XML::Element< ACE_TCHAR > const&); + ThreadpoolDef (ThreadpoolDef const& s); + + ThreadpoolDef& + operator= (ThreadpoolDef const& s); + + private: + char regulator__; + }; + + + class RT_CCM_Handlers_Export ThreadpoolWithLanesDef : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // threadpoolLane + // + public: + typedef ::std::list< ::CIAO::Config_Handlers::ThreadpoolLaneDef >::iterator threadpoolLane_iterator; + typedef ::std::list< ::CIAO::Config_Handlers::ThreadpoolLaneDef >::const_iterator threadpoolLane_const_iterator; + threadpoolLane_iterator begin_threadpoolLane (); + threadpoolLane_iterator end_threadpoolLane (); + threadpoolLane_const_iterator begin_threadpoolLane () const; + threadpoolLane_const_iterator end_threadpoolLane () const; + void add_threadpoolLane (::CIAO::Config_Handlers::ThreadpoolLaneDef const& ); + size_t count_threadpoolLane (void) const; + + protected: + ::std::list< ::CIAO::Config_Handlers::ThreadpoolLaneDef > threadpoolLane_; + + // stacksize + // + public: + ::XMLSchema::unsignedLong const& stacksize () const; + void stacksize (::XMLSchema::unsignedLong const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::unsignedLong > stacksize_; + + // allow_borrowing + // + public: + ::XMLSchema::boolean const& allow_borrowing () const; + void allow_borrowing (::XMLSchema::boolean const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::boolean > allow_borrowing_; + + // allow_request_buffering + // + public: + ::XMLSchema::boolean const& allow_request_buffering () const; + void allow_request_buffering (::XMLSchema::boolean const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::boolean > allow_request_buffering_; + + // max_buffered_requests + // + public: + ::XMLSchema::unsignedLong const& max_buffered_requests () const; + void max_buffered_requests (::XMLSchema::unsignedLong const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::unsignedLong > max_buffered_requests_; + + // max_request_buffered_size + // + public: + ::XMLSchema::unsignedLong const& max_request_buffered_size () const; + void max_request_buffered_size (::XMLSchema::unsignedLong const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::unsignedLong > max_request_buffered_size_; + + // id + // + public: + bool id_p () const; + ::XMLSchema::ID< ACE_TCHAR > const& id () const; + ::XMLSchema::ID< ACE_TCHAR >& id (); + void id (::XMLSchema::ID< ACE_TCHAR > const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > id_; + + public: + ThreadpoolWithLanesDef (::XMLSchema::unsignedLong const& stacksize__, + ::XMLSchema::boolean const& allow_borrowing__, + ::XMLSchema::boolean const& allow_request_buffering__, + ::XMLSchema::unsignedLong const& max_buffered_requests__, + ::XMLSchema::unsignedLong const& max_request_buffered_size__); + + ThreadpoolWithLanesDef (::XSCRT::XML::Element< ACE_TCHAR > const&); + ThreadpoolWithLanesDef (ThreadpoolWithLanesDef const& s); + + ThreadpoolWithLanesDef& + operator= (ThreadpoolWithLanesDef const& s); + + private: + char regulator__; + }; + + + class RT_CCM_Handlers_Export ThreadpoolLaneDef : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // static_threads + // + public: + ::XMLSchema::unsignedLong const& static_threads () const; + void static_threads (::XMLSchema::unsignedLong const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::unsignedLong > static_threads_; + + // dynamic_threads + // + public: + ::XMLSchema::unsignedLong const& dynamic_threads () const; + void dynamic_threads (::XMLSchema::unsignedLong const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::unsignedLong > dynamic_threads_; + + // priority + // + public: + ::XMLSchema::int_ const& priority () const; + void priority (::XMLSchema::int_ const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::int_ > priority_; + + public: + ThreadpoolLaneDef (::XMLSchema::unsignedLong const& static_threads__, + ::XMLSchema::unsignedLong const& dynamic_threads__, + ::XMLSchema::int_ const& priority__); + + ThreadpoolLaneDef (::XSCRT::XML::Element< ACE_TCHAR > const&); + ThreadpoolLaneDef (ThreadpoolLaneDef const& s); + + ThreadpoolLaneDef& + operator= (ThreadpoolLaneDef const& s); + + private: + char regulator__; + }; + + + class RT_CCM_Handlers_Export ConnectionBandsDef : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // band + // + public: + typedef ::std::list< ::CIAO::Config_Handlers::PriorityBandDef >::iterator band_iterator; + typedef ::std::list< ::CIAO::Config_Handlers::PriorityBandDef >::const_iterator band_const_iterator; + band_iterator begin_band (); + band_iterator end_band (); + band_const_iterator begin_band () const; + band_const_iterator end_band () const; + void add_band (::CIAO::Config_Handlers::PriorityBandDef const& ); + size_t count_band (void) const; + + protected: + ::std::list< ::CIAO::Config_Handlers::PriorityBandDef > band_; + + // id + // + public: + bool id_p () const; + ::XMLSchema::ID< ACE_TCHAR > const& id () const; + ::XMLSchema::ID< ACE_TCHAR >& id (); + void id (::XMLSchema::ID< ACE_TCHAR > const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > id_; + + public: + ConnectionBandsDef (); + + ConnectionBandsDef (::XSCRT::XML::Element< ACE_TCHAR > const&); + ConnectionBandsDef (ConnectionBandsDef const& s); + + ConnectionBandsDef& + operator= (ConnectionBandsDef const& s); + + private: + char regulator__; + }; + + + class RT_CCM_Handlers_Export PriorityBandDef : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // low + // + public: + ::XMLSchema::int_ const& low () const; + void low (::XMLSchema::int_ const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::int_ > low_; + + // high + // + public: + ::XMLSchema::int_ const& high () const; + void high (::XMLSchema::int_ const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::int_ > high_; + + public: + PriorityBandDef (::XMLSchema::int_ const& low__, + ::XMLSchema::int_ const& high__); + + PriorityBandDef (::XSCRT::XML::Element< ACE_TCHAR > const&); + PriorityBandDef (PriorityBandDef const& s); + + PriorityBandDef& + operator= (PriorityBandDef const& s); + + private: + char regulator__; + }; + + + class RT_CCM_Handlers_Export PolicySet : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // priorityModel + // + public: + typedef ::std::list< ::CIAO::Config_Handlers::PriorityModelPolicyDef >::iterator priorityModel_iterator; + typedef ::std::list< ::CIAO::Config_Handlers::PriorityModelPolicyDef >::const_iterator priorityModel_const_iterator; + priorityModel_iterator begin_priorityModel (); + priorityModel_iterator end_priorityModel (); + priorityModel_const_iterator begin_priorityModel () const; + priorityModel_const_iterator end_priorityModel () const; + void add_priorityModel (::CIAO::Config_Handlers::PriorityModelPolicyDef const& ); + size_t count_priorityModel (void) const; + + protected: + ::std::list< ::CIAO::Config_Handlers::PriorityModelPolicyDef > priorityModel_; + + // nwpriorityModel + // + public: + typedef ::std::list< ::CIAO::Config_Handlers::NWPriorityModelPolicyDef >::iterator nwpriorityModel_iterator; + typedef ::std::list< ::CIAO::Config_Handlers::NWPriorityModelPolicyDef >::const_iterator nwpriorityModel_const_iterator; + nwpriorityModel_iterator begin_nwpriorityModel (); + nwpriorityModel_iterator end_nwpriorityModel (); + nwpriorityModel_const_iterator begin_nwpriorityModel () const; + nwpriorityModel_const_iterator end_nwpriorityModel () const; + void add_nwpriorityModel (::CIAO::Config_Handlers::NWPriorityModelPolicyDef const& ); + size_t count_nwpriorityModel (void) const; + + protected: + ::std::list< ::CIAO::Config_Handlers::NWPriorityModelPolicyDef > nwpriorityModel_; + + // cnwpriorityModel + // + public: + typedef ::std::list< ::CIAO::Config_Handlers::CNWPriorityModelPolicyDef >::iterator cnwpriorityModel_iterator; + typedef ::std::list< ::CIAO::Config_Handlers::CNWPriorityModelPolicyDef >::const_iterator cnwpriorityModel_const_iterator; + cnwpriorityModel_iterator begin_cnwpriorityModel (); + cnwpriorityModel_iterator end_cnwpriorityModel (); + cnwpriorityModel_const_iterator begin_cnwpriorityModel () const; + cnwpriorityModel_const_iterator end_cnwpriorityModel () const; + void add_cnwpriorityModel (::CIAO::Config_Handlers::CNWPriorityModelPolicyDef const& ); + size_t count_cnwpriorityModel (void) const; + + protected: + ::std::list< ::CIAO::Config_Handlers::CNWPriorityModelPolicyDef > cnwpriorityModel_; + + // threadpool + // + public: + typedef ::std::list< ::XMLSchema::IDREF< ACE_TCHAR > >::iterator threadpool_iterator; + typedef ::std::list< ::XMLSchema::IDREF< ACE_TCHAR > >::const_iterator threadpool_const_iterator; + threadpool_iterator begin_threadpool (); + threadpool_iterator end_threadpool (); + threadpool_const_iterator begin_threadpool () const; + threadpool_const_iterator end_threadpool () const; + void add_threadpool (::XMLSchema::IDREF< ACE_TCHAR > const& ); + size_t count_threadpool (void) const; + + protected: + ::std::list< ::XMLSchema::IDREF< ACE_TCHAR > > threadpool_; + + // priorityBandedConnection + // + public: + typedef ::std::list< ::XMLSchema::IDREF< ACE_TCHAR > >::iterator priorityBandedConnection_iterator; + typedef ::std::list< ::XMLSchema::IDREF< ACE_TCHAR > >::const_iterator priorityBandedConnection_const_iterator; + priorityBandedConnection_iterator begin_priorityBandedConnection (); + priorityBandedConnection_iterator end_priorityBandedConnection (); + priorityBandedConnection_const_iterator begin_priorityBandedConnection () const; + priorityBandedConnection_const_iterator end_priorityBandedConnection () const; + void add_priorityBandedConnection (::XMLSchema::IDREF< ACE_TCHAR > const& ); + size_t count_priorityBandedConnection (void) const; + + protected: + ::std::list< ::XMLSchema::IDREF< ACE_TCHAR > > priorityBandedConnection_; + + // id + // + public: + bool id_p () const; + ::XMLSchema::ID< ACE_TCHAR > const& id () const; + ::XMLSchema::ID< ACE_TCHAR >& id (); + void id (::XMLSchema::ID< ACE_TCHAR > const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::ID< ACE_TCHAR > > id_; + + public: + PolicySet (); + + PolicySet (::XSCRT::XML::Element< ACE_TCHAR > const&); + PolicySet (PolicySet const& s); + + PolicySet& + operator= (PolicySet const& s); + + private: + char regulator__; + }; + + + class RT_CCM_Handlers_Export PriorityModel : public ::XSCRT::Type + { + public: + PriorityModel (::XSCRT::XML::Element< ACE_TCHAR > const&); + PriorityModel (::XSCRT::XML::Attribute< ACE_TCHAR > const&); + + static PriorityModel const SERVER_DECLARED; + static PriorityModel const CLIENT_PROPAGATED; + + enum Value + { + SERVER_DECLARED_l, CLIENT_PROPAGATED_l + }; + + + Value + integral () const; + + friend bool RT_CCM_Handlers_Export + operator== (PriorityModel const& a, PriorityModel const& b); + + friend bool RT_CCM_Handlers_Export + operator!= (PriorityModel const& a, PriorityModel const& b); + + private: + PriorityModel (Value v); + + Value v_; + }; + + bool RT_CCM_Handlers_Export operator== (PriorityModel const &a, PriorityModel const &b); + + bool RT_CCM_Handlers_Export operator!= (PriorityModel const &a, PriorityModel const &b); + + + class RT_CCM_Handlers_Export NWPriorityModel : public ::XSCRT::Type + { + public: + NWPriorityModel (::XSCRT::XML::Element< ACE_TCHAR > const&); + NWPriorityModel (::XSCRT::XML::Attribute< ACE_TCHAR > const&); + + static NWPriorityModel const SERVER_DECLARED_NWPRIORITY; + static NWPriorityModel const CLIENT_PROPAGATED_NWPRIORITY; + + enum Value + { + SERVER_DECLARED_NWPRIORITY_l, CLIENT_PROPAGATED_NWPRIORITY_l + }; + + + Value + integral () const; + + friend bool RT_CCM_Handlers_Export + operator== (NWPriorityModel const& a, NWPriorityModel const& b); + + friend bool RT_CCM_Handlers_Export + operator!= (NWPriorityModel const& a, NWPriorityModel const& b); + + private: + NWPriorityModel (Value v); + + Value v_; + }; + + bool RT_CCM_Handlers_Export operator== (NWPriorityModel const &a, NWPriorityModel const &b); + + bool RT_CCM_Handlers_Export operator!= (NWPriorityModel const &a, NWPriorityModel const &b); + + + class RT_CCM_Handlers_Export PriorityModelPolicyDef : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // priority_model + // + public: + ::CIAO::Config_Handlers::PriorityModel const& priority_model () const; + void priority_model (::CIAO::Config_Handlers::PriorityModel const& ); + + protected: + ::std::auto_ptr< ::CIAO::Config_Handlers::PriorityModel > priority_model_; + + // server_priority + // + public: + bool server_priority_p () const; + ::XMLSchema::int_ const& server_priority () const; + ::XMLSchema::int_& server_priority (); + void server_priority (::XMLSchema::int_ const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::int_ > server_priority_; + + public: + PriorityModelPolicyDef (::CIAO::Config_Handlers::PriorityModel const& priority_model__); + + PriorityModelPolicyDef (::XSCRT::XML::Element< ACE_TCHAR > const&); + PriorityModelPolicyDef (PriorityModelPolicyDef const& s); + + PriorityModelPolicyDef& + operator= (PriorityModelPolicyDef const& s); + + private: + char regulator__; + }; + + + class RT_CCM_Handlers_Export NWPriorityModelPolicyDef : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // nw_priority_model + // + public: + ::CIAO::Config_Handlers::NWPriorityModel const& nw_priority_model () const; + void nw_priority_model (::CIAO::Config_Handlers::NWPriorityModel const& ); + + protected: + ::std::auto_ptr< ::CIAO::Config_Handlers::NWPriorityModel > nw_priority_model_; + + // request_dscp + // + public: + ::XMLSchema::long_ const& request_dscp () const; + void request_dscp (::XMLSchema::long_ const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::long_ > request_dscp_; + + // reply_dscp + // + public: + ::XMLSchema::long_ const& reply_dscp () const; + void reply_dscp (::XMLSchema::long_ const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::long_ > reply_dscp_; + + public: + NWPriorityModelPolicyDef (::CIAO::Config_Handlers::NWPriorityModel const& nw_priority_model__, + ::XMLSchema::long_ const& request_dscp__, + ::XMLSchema::long_ const& reply_dscp__); + + NWPriorityModelPolicyDef (::XSCRT::XML::Element< ACE_TCHAR > const&); + NWPriorityModelPolicyDef (NWPriorityModelPolicyDef const& s); + + NWPriorityModelPolicyDef& + operator= (NWPriorityModelPolicyDef const& s); + + private: + char regulator__; + }; + + + class RT_CCM_Handlers_Export CNWPriorityModelPolicyDef : public ::XSCRT::Type + { + typedef ::XSCRT::Type Base; + + // request_dscp + // + public: + ::XMLSchema::long_ const& request_dscp () const; + void request_dscp (::XMLSchema::long_ const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::long_ > request_dscp_; + + // reply_dscp + // + public: + ::XMLSchema::long_ const& reply_dscp () const; + void reply_dscp (::XMLSchema::long_ const& ); + + protected: + ::std::auto_ptr< ::XMLSchema::long_ > reply_dscp_; + + public: + CNWPriorityModelPolicyDef (::XMLSchema::long_ const& request_dscp__, + ::XMLSchema::long_ const& reply_dscp__); + + CNWPriorityModelPolicyDef (::XSCRT::XML::Element< ACE_TCHAR > const&); + CNWPriorityModelPolicyDef (CNWPriorityModelPolicyDef const& s); + + CNWPriorityModelPolicyDef& + operator= (CNWPriorityModelPolicyDef const& s); + + private: + char regulator__; + }; + } +} + +namespace CIAO +{ + namespace Config_Handlers + { + RT_CCM_Handlers_Export + ::CIAO::Config_Handlers::ServerResourcesDef + ServerResources (xercesc::DOMDocument const*); + } +} + +#include "XMLSchema/Traversal.hpp" + +namespace CIAO +{ + namespace Config_Handlers + { + namespace Traversal + { + struct RT_CCM_Handlers_Export ServerResourcesDef : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::ServerResourcesDef > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + cmdline (Type&); + + virtual void + cmdline (Type const&); + + virtual void + cmdline_none (Type&); + + virtual void + cmdline_none (Type const&); + + virtual void + svcconf (Type&); + + virtual void + svcconf (Type const&); + + virtual void + svcconf_none (Type&); + + virtual void + svcconf_none (Type const&); + + virtual void + orbConfigs (Type&); + + virtual void + orbConfigs (Type const&); + + virtual void + id (Type&); + + virtual void + id (Type const&); + + virtual void + id_none (Type&); + + virtual void + id_none (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + + struct RT_CCM_Handlers_Export ServerCmdlineOptions : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::ServerCmdlineOptions > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + arg (Type&); + + virtual void + arg (Type const&); + + virtual void + arg_pre (Type&); + + virtual void + arg_pre (Type const&); + + virtual void + arg_next (Type&); + + virtual void + arg_next (Type const&); + + virtual void + arg_post (Type&); + + virtual void + arg_post (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + + struct RT_CCM_Handlers_Export ACESvcConf : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::ACESvcConf > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + uri (Type&); + + virtual void + uri (Type const&); + + virtual void + uri_none (Type&); + + virtual void + uri_none (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + + struct RT_CCM_Handlers_Export ORBConfigs : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::ORBConfigs > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + resources (Type&); + + virtual void + resources (Type const&); + + virtual void + resources_none (Type&); + + virtual void + resources_none (Type const&); + + virtual void + policySet (Type&); + + virtual void + policySet (Type const&); + + virtual void + policySet_pre (Type&); + + virtual void + policySet_pre (Type const&); + + virtual void + policySet_next (Type&); + + virtual void + policySet_next (Type const&); + + virtual void + policySet_post (Type&); + + virtual void + policySet_post (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + + struct RT_CCM_Handlers_Export ORBResources : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::ORBResources > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + threadpool (Type&); + + virtual void + threadpool (Type const&); + + virtual void + threadpool_pre (Type&); + + virtual void + threadpool_pre (Type const&); + + virtual void + threadpool_next (Type&); + + virtual void + threadpool_next (Type const&); + + virtual void + threadpool_post (Type&); + + virtual void + threadpool_post (Type const&); + + virtual void + threadpool_none (Type&); + + virtual void + threadpool_none (Type const&); + + virtual void + threadpoolWithLanes (Type&); + + virtual void + threadpoolWithLanes (Type const&); + + virtual void + threadpoolWithLanes_pre (Type&); + + virtual void + threadpoolWithLanes_pre (Type const&); + + virtual void + threadpoolWithLanes_next (Type&); + + virtual void + threadpoolWithLanes_next (Type const&); + + virtual void + threadpoolWithLanes_post (Type&); + + virtual void + threadpoolWithLanes_post (Type const&); + + virtual void + threadpoolWithLanes_none (Type&); + + virtual void + threadpoolWithLanes_none (Type const&); + + virtual void + connectionBands (Type&); + + virtual void + connectionBands (Type const&); + + virtual void + connectionBands_pre (Type&); + + virtual void + connectionBands_pre (Type const&); + + virtual void + connectionBands_next (Type&); + + virtual void + connectionBands_next (Type const&); + + virtual void + connectionBands_post (Type&); + + virtual void + connectionBands_post (Type const&); + + virtual void + connectionBands_none (Type&); + + virtual void + connectionBands_none (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + + struct RT_CCM_Handlers_Export ThreadpoolDef : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::ThreadpoolDef > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + stacksize (Type&); + + virtual void + stacksize (Type const&); + + virtual void + static_threads (Type&); + + virtual void + static_threads (Type const&); + + virtual void + dynamic_threads (Type&); + + virtual void + dynamic_threads (Type const&); + + virtual void + default_priority (Type&); + + virtual void + default_priority (Type const&); + + virtual void + allow_request_buffering (Type&); + + virtual void + allow_request_buffering (Type const&); + + virtual void + max_buffered_requests (Type&); + + virtual void + max_buffered_requests (Type const&); + + virtual void + max_request_buffered_size (Type&); + + virtual void + max_request_buffered_size (Type const&); + + virtual void + id (Type&); + + virtual void + id (Type const&); + + virtual void + id_none (Type&); + + virtual void + id_none (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + + struct RT_CCM_Handlers_Export ThreadpoolWithLanesDef : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::ThreadpoolWithLanesDef > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + threadpoolLane (Type&); + + virtual void + threadpoolLane (Type const&); + + virtual void + threadpoolLane_pre (Type&); + + virtual void + threadpoolLane_pre (Type const&); + + virtual void + threadpoolLane_next (Type&); + + virtual void + threadpoolLane_next (Type const&); + + virtual void + threadpoolLane_post (Type&); + + virtual void + threadpoolLane_post (Type const&); + + virtual void + stacksize (Type&); + + virtual void + stacksize (Type const&); + + virtual void + allow_borrowing (Type&); + + virtual void + allow_borrowing (Type const&); + + virtual void + allow_request_buffering (Type&); + + virtual void + allow_request_buffering (Type const&); + + virtual void + max_buffered_requests (Type&); + + virtual void + max_buffered_requests (Type const&); + + virtual void + max_request_buffered_size (Type&); + + virtual void + max_request_buffered_size (Type const&); + + virtual void + id (Type&); + + virtual void + id (Type const&); + + virtual void + id_none (Type&); + + virtual void + id_none (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + + struct RT_CCM_Handlers_Export ThreadpoolLaneDef : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::ThreadpoolLaneDef > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + static_threads (Type&); + + virtual void + static_threads (Type const&); + + virtual void + dynamic_threads (Type&); + + virtual void + dynamic_threads (Type const&); + + virtual void + priority (Type&); + + virtual void + priority (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + + struct RT_CCM_Handlers_Export ConnectionBandsDef : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::ConnectionBandsDef > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + band (Type&); + + virtual void + band (Type const&); + + virtual void + band_pre (Type&); + + virtual void + band_pre (Type const&); + + virtual void + band_next (Type&); + + virtual void + band_next (Type const&); + + virtual void + band_post (Type&); + + virtual void + band_post (Type const&); + + virtual void + id (Type&); + + virtual void + id (Type const&); + + virtual void + id_none (Type&); + + virtual void + id_none (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + + struct RT_CCM_Handlers_Export PriorityBandDef : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::PriorityBandDef > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + low (Type&); + + virtual void + low (Type const&); + + virtual void + high (Type&); + + virtual void + high (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + + struct RT_CCM_Handlers_Export PolicySet : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::PolicySet > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + priorityModel (Type&); + + virtual void + priorityModel (Type const&); + + virtual void + priorityModel_pre (Type&); + + virtual void + priorityModel_pre (Type const&); + + virtual void + priorityModel_next (Type&); + + virtual void + priorityModel_next (Type const&); + + virtual void + priorityModel_post (Type&); + + virtual void + priorityModel_post (Type const&); + + virtual void + priorityModel_none (Type&); + + virtual void + priorityModel_none (Type const&); + + virtual void + nwpriorityModel (Type&); + + virtual void + nwpriorityModel (Type const&); + + virtual void + nwpriorityModel_pre (Type&); + + virtual void + nwpriorityModel_pre (Type const&); + + virtual void + nwpriorityModel_next (Type&); + + virtual void + nwpriorityModel_next (Type const&); + + virtual void + nwpriorityModel_post (Type&); + + virtual void + nwpriorityModel_post (Type const&); + + virtual void + nwpriorityModel_none (Type&); + + virtual void + nwpriorityModel_none (Type const&); + + virtual void + cnwpriorityModel (Type&); + + virtual void + cnwpriorityModel (Type const&); + + virtual void + cnwpriorityModel_pre (Type&); + + virtual void + cnwpriorityModel_pre (Type const&); + + virtual void + cnwpriorityModel_next (Type&); + + virtual void + cnwpriorityModel_next (Type const&); + + virtual void + cnwpriorityModel_post (Type&); + + virtual void + cnwpriorityModel_post (Type const&); + + virtual void + cnwpriorityModel_none (Type&); + + virtual void + cnwpriorityModel_none (Type const&); + + virtual void + threadpool (Type&); + + virtual void + threadpool (Type const&); + + virtual void + threadpool_pre (Type&); + + virtual void + threadpool_pre (Type const&); + + virtual void + threadpool_next (Type&); + + virtual void + threadpool_next (Type const&); + + virtual void + threadpool_post (Type&); + + virtual void + threadpool_post (Type const&); + + virtual void + threadpool_none (Type&); + + virtual void + threadpool_none (Type const&); + + virtual void + priorityBandedConnection (Type&); + + virtual void + priorityBandedConnection (Type const&); + + virtual void + priorityBandedConnection_pre (Type&); + + virtual void + priorityBandedConnection_pre (Type const&); + + virtual void + priorityBandedConnection_next (Type&); + + virtual void + priorityBandedConnection_next (Type const&); + + virtual void + priorityBandedConnection_post (Type&); + + virtual void + priorityBandedConnection_post (Type const&); + + virtual void + priorityBandedConnection_none (Type&); + + virtual void + priorityBandedConnection_none (Type const&); + + virtual void + id (Type&); + + virtual void + id (Type const&); + + virtual void + id_none (Type&); + + virtual void + id_none (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + + typedef + ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::PriorityModel > + PriorityModel; + + typedef + ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::NWPriorityModel > + NWPriorityModel; + + struct RT_CCM_Handlers_Export PriorityModelPolicyDef : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::PriorityModelPolicyDef > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + priority_model (Type&); + + virtual void + priority_model (Type const&); + + virtual void + server_priority (Type&); + + virtual void + server_priority (Type const&); + + virtual void + server_priority_none (Type&); + + virtual void + server_priority_none (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + + struct RT_CCM_Handlers_Export NWPriorityModelPolicyDef : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::NWPriorityModelPolicyDef > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + nw_priority_model (Type&); + + virtual void + nw_priority_model (Type const&); + + virtual void + request_dscp (Type&); + + virtual void + request_dscp (Type const&); + + virtual void + reply_dscp (Type&); + + virtual void + reply_dscp (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + + struct RT_CCM_Handlers_Export CNWPriorityModelPolicyDef : ::XMLSchema::Traversal::Traverser< ::CIAO::Config_Handlers::CNWPriorityModelPolicyDef > + { + virtual void + traverse (Type&); + + virtual void + traverse (Type const&); + + virtual void + pre (Type&); + + virtual void + pre (Type const&); + + virtual void + request_dscp (Type&); + + virtual void + request_dscp (Type const&); + + virtual void + reply_dscp (Type&); + + virtual void + reply_dscp (Type const&); + + virtual void + post (Type&); + + virtual void + post (Type const&); + }; + } + } +} + +#include "XMLSchema/Writer.hpp" + +namespace CIAO +{ + namespace Config_Handlers + { + namespace Writer + { + struct ServerResourcesDef : Traversal::ServerResourcesDef, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::ServerResourcesDef Type; + ServerResourcesDef (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + cmdline (Type &o) + { + + this->cmdline (const_cast <Type const &> (o)); + } + + + virtual void + cmdline (Type const&); + + virtual void + svcconf (Type &o) + { + + this->svcconf (const_cast <Type const &> (o)); + } + + + virtual void + svcconf (Type const&); + + virtual void + orbConfigs (Type &o) + { + + this->orbConfigs (const_cast <Type const &> (o)); + } + + + virtual void + orbConfigs (Type const&); + + virtual void + id (Type &o) + { + + this->id (const_cast <Type const &> (o)); + } + + + virtual void + id (Type const&); + + protected: + ServerResourcesDef (); + }; + + struct ServerCmdlineOptions : Traversal::ServerCmdlineOptions, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::ServerCmdlineOptions Type; + ServerCmdlineOptions (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + arg_pre (Type &o) + { + + this->arg_pre (const_cast <Type const &> (o)); + } + + + virtual void + arg_pre (Type const&); + + virtual void + arg_next (Type &o) + { + + this->arg_next (const_cast <Type const &> (o)); + } + + + virtual void + arg_next (Type const&); + + virtual void + arg_post (Type &o) + { + + this->arg_post (const_cast <Type const &> (o)); + } + + + virtual void + arg_post (Type const&); + + protected: + ServerCmdlineOptions (); + }; + + struct ACESvcConf : Traversal::ACESvcConf, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::ACESvcConf Type; + ACESvcConf (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + uri (Type &o) + { + + this->uri (const_cast <Type const &> (o)); + } + + + virtual void + uri (Type const&); + + protected: + ACESvcConf (); + }; + + struct ORBConfigs : Traversal::ORBConfigs, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::ORBConfigs Type; + ORBConfigs (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + resources (Type &o) + { + + this->resources (const_cast <Type const &> (o)); + } + + + virtual void + resources (Type const&); + + virtual void + policySet_pre (Type &o) + { + + this->policySet_pre (const_cast <Type const &> (o)); + } + + + virtual void + policySet_pre (Type const&); + + virtual void + policySet_next (Type &o) + { + + this->policySet_next (const_cast <Type const &> (o)); + } + + + virtual void + policySet_next (Type const&); + + virtual void + policySet_post (Type &o) + { + + this->policySet_post (const_cast <Type const &> (o)); + } + + + virtual void + policySet_post (Type const&); + + protected: + ORBConfigs (); + }; + + struct ORBResources : Traversal::ORBResources, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::ORBResources Type; + ORBResources (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + threadpool_pre (Type &o) + { + + this->threadpool_pre (const_cast <Type const &> (o)); + } + + + virtual void + threadpool_pre (Type const&); + + virtual void + threadpool_next (Type &o) + { + + this->threadpool_next (const_cast <Type const &> (o)); + } + + + virtual void + threadpool_next (Type const&); + + virtual void + threadpool_post (Type &o) + { + + this->threadpool_post (const_cast <Type const &> (o)); + } + + + virtual void + threadpool_post (Type const&); + + virtual void + threadpoolWithLanes_pre (Type &o) + { + + this->threadpoolWithLanes_pre (const_cast <Type const &> (o)); + } + + + virtual void + threadpoolWithLanes_pre (Type const&); + + virtual void + threadpoolWithLanes_next (Type &o) + { + + this->threadpoolWithLanes_next (const_cast <Type const &> (o)); + } + + + virtual void + threadpoolWithLanes_next (Type const&); + + virtual void + threadpoolWithLanes_post (Type &o) + { + + this->threadpoolWithLanes_post (const_cast <Type const &> (o)); + } + + + virtual void + threadpoolWithLanes_post (Type const&); + + virtual void + connectionBands_pre (Type &o) + { + + this->connectionBands_pre (const_cast <Type const &> (o)); + } + + + virtual void + connectionBands_pre (Type const&); + + virtual void + connectionBands_next (Type &o) + { + + this->connectionBands_next (const_cast <Type const &> (o)); + } + + + virtual void + connectionBands_next (Type const&); + + virtual void + connectionBands_post (Type &o) + { + + this->connectionBands_post (const_cast <Type const &> (o)); + } + + + virtual void + connectionBands_post (Type const&); + + protected: + ORBResources (); + }; + + struct ThreadpoolDef : Traversal::ThreadpoolDef, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::ThreadpoolDef Type; + ThreadpoolDef (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + stacksize (Type &o) + { + + this->stacksize (const_cast <Type const &> (o)); + } + + + virtual void + stacksize (Type const&); + + virtual void + static_threads (Type &o) + { + + this->static_threads (const_cast <Type const &> (o)); + } + + + virtual void + static_threads (Type const&); + + virtual void + dynamic_threads (Type &o) + { + + this->dynamic_threads (const_cast <Type const &> (o)); + } + + + virtual void + dynamic_threads (Type const&); + + virtual void + default_priority (Type &o) + { + + this->default_priority (const_cast <Type const &> (o)); + } + + + virtual void + default_priority (Type const&); + + virtual void + allow_request_buffering (Type &o) + { + + this->allow_request_buffering (const_cast <Type const &> (o)); + } + + + virtual void + allow_request_buffering (Type const&); + + virtual void + max_buffered_requests (Type &o) + { + + this->max_buffered_requests (const_cast <Type const &> (o)); + } + + + virtual void + max_buffered_requests (Type const&); + + virtual void + max_request_buffered_size (Type &o) + { + + this->max_request_buffered_size (const_cast <Type const &> (o)); + } + + + virtual void + max_request_buffered_size (Type const&); + + virtual void + id (Type &o) + { + + this->id (const_cast <Type const &> (o)); + } + + + virtual void + id (Type const&); + + protected: + ThreadpoolDef (); + }; + + struct ThreadpoolWithLanesDef : Traversal::ThreadpoolWithLanesDef, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::ThreadpoolWithLanesDef Type; + ThreadpoolWithLanesDef (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + threadpoolLane_pre (Type &o) + { + + this->threadpoolLane_pre (const_cast <Type const &> (o)); + } + + + virtual void + threadpoolLane_pre (Type const&); + + virtual void + threadpoolLane_next (Type &o) + { + + this->threadpoolLane_next (const_cast <Type const &> (o)); + } + + + virtual void + threadpoolLane_next (Type const&); + + virtual void + threadpoolLane_post (Type &o) + { + + this->threadpoolLane_post (const_cast <Type const &> (o)); + } + + + virtual void + threadpoolLane_post (Type const&); + + virtual void + stacksize (Type &o) + { + + this->stacksize (const_cast <Type const &> (o)); + } + + + virtual void + stacksize (Type const&); + + virtual void + allow_borrowing (Type &o) + { + + this->allow_borrowing (const_cast <Type const &> (o)); + } + + + virtual void + allow_borrowing (Type const&); + + virtual void + allow_request_buffering (Type &o) + { + + this->allow_request_buffering (const_cast <Type const &> (o)); + } + + + virtual void + allow_request_buffering (Type const&); + + virtual void + max_buffered_requests (Type &o) + { + + this->max_buffered_requests (const_cast <Type const &> (o)); + } + + + virtual void + max_buffered_requests (Type const&); + + virtual void + max_request_buffered_size (Type &o) + { + + this->max_request_buffered_size (const_cast <Type const &> (o)); + } + + + virtual void + max_request_buffered_size (Type const&); + + virtual void + id (Type &o) + { + + this->id (const_cast <Type const &> (o)); + } + + + virtual void + id (Type const&); + + protected: + ThreadpoolWithLanesDef (); + }; + + struct ThreadpoolLaneDef : Traversal::ThreadpoolLaneDef, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::ThreadpoolLaneDef Type; + ThreadpoolLaneDef (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + static_threads (Type &o) + { + + this->static_threads (const_cast <Type const &> (o)); + } + + + virtual void + static_threads (Type const&); + + virtual void + dynamic_threads (Type &o) + { + + this->dynamic_threads (const_cast <Type const &> (o)); + } + + + virtual void + dynamic_threads (Type const&); + + virtual void + priority (Type &o) + { + + this->priority (const_cast <Type const &> (o)); + } + + + virtual void + priority (Type const&); + + protected: + ThreadpoolLaneDef (); + }; + + struct ConnectionBandsDef : Traversal::ConnectionBandsDef, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::ConnectionBandsDef Type; + ConnectionBandsDef (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + band_pre (Type &o) + { + + this->band_pre (const_cast <Type const &> (o)); + } + + + virtual void + band_pre (Type const&); + + virtual void + band_next (Type &o) + { + + this->band_next (const_cast <Type const &> (o)); + } + + + virtual void + band_next (Type const&); + + virtual void + band_post (Type &o) + { + + this->band_post (const_cast <Type const &> (o)); + } + + + virtual void + band_post (Type const&); + + virtual void + id (Type &o) + { + + this->id (const_cast <Type const &> (o)); + } + + + virtual void + id (Type const&); + + protected: + ConnectionBandsDef (); + }; + + struct PriorityBandDef : Traversal::PriorityBandDef, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::PriorityBandDef Type; + PriorityBandDef (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + low (Type &o) + { + + this->low (const_cast <Type const &> (o)); + } + + + virtual void + low (Type const&); + + virtual void + high (Type &o) + { + + this->high (const_cast <Type const &> (o)); + } + + + virtual void + high (Type const&); + + protected: + PriorityBandDef (); + }; + + struct PolicySet : Traversal::PolicySet, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::PolicySet Type; + PolicySet (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + priorityModel_pre (Type &o) + { + + this->priorityModel_pre (const_cast <Type const &> (o)); + } + + + virtual void + priorityModel_pre (Type const&); + + virtual void + priorityModel_next (Type &o) + { + + this->priorityModel_next (const_cast <Type const &> (o)); + } + + + virtual void + priorityModel_next (Type const&); + + virtual void + priorityModel_post (Type &o) + { + + this->priorityModel_post (const_cast <Type const &> (o)); + } + + + virtual void + priorityModel_post (Type const&); + + virtual void + nwpriorityModel_pre (Type &o) + { + + this->nwpriorityModel_pre (const_cast <Type const &> (o)); + } + + + virtual void + nwpriorityModel_pre (Type const&); + + virtual void + nwpriorityModel_next (Type &o) + { + + this->nwpriorityModel_next (const_cast <Type const &> (o)); + } + + + virtual void + nwpriorityModel_next (Type const&); + + virtual void + nwpriorityModel_post (Type &o) + { + + this->nwpriorityModel_post (const_cast <Type const &> (o)); + } + + + virtual void + nwpriorityModel_post (Type const&); + + virtual void + cnwpriorityModel_pre (Type &o) + { + + this->cnwpriorityModel_pre (const_cast <Type const &> (o)); + } + + + virtual void + cnwpriorityModel_pre (Type const&); + + virtual void + cnwpriorityModel_next (Type &o) + { + + this->cnwpriorityModel_next (const_cast <Type const &> (o)); + } + + + virtual void + cnwpriorityModel_next (Type const&); + + virtual void + cnwpriorityModel_post (Type &o) + { + + this->cnwpriorityModel_post (const_cast <Type const &> (o)); + } + + + virtual void + cnwpriorityModel_post (Type const&); + + virtual void + threadpool_pre (Type &o) + { + + this->threadpool_pre (const_cast <Type const &> (o)); + } + + + virtual void + threadpool_pre (Type const&); + + virtual void + threadpool_next (Type &o) + { + + this->threadpool_next (const_cast <Type const &> (o)); + } + + + virtual void + threadpool_next (Type const&); + + virtual void + threadpool_post (Type &o) + { + + this->threadpool_post (const_cast <Type const &> (o)); + } + + + virtual void + threadpool_post (Type const&); + + virtual void + priorityBandedConnection_pre (Type &o) + { + + this->priorityBandedConnection_pre (const_cast <Type const &> (o)); + } + + + virtual void + priorityBandedConnection_pre (Type const&); + + virtual void + priorityBandedConnection_next (Type &o) + { + + this->priorityBandedConnection_next (const_cast <Type const &> (o)); + } + + + virtual void + priorityBandedConnection_next (Type const&); + + virtual void + priorityBandedConnection_post (Type &o) + { + + this->priorityBandedConnection_post (const_cast <Type const &> (o)); + } + + + virtual void + priorityBandedConnection_post (Type const&); + + virtual void + id (Type &o) + { + + this->id (const_cast <Type const &> (o)); + } + + + virtual void + id (Type const&); + + protected: + PolicySet (); + }; + + struct PriorityModel : Traversal::PriorityModel, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + PriorityModel (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + this->traverse (const_cast <Type const &> (o)); + } + + virtual void + traverse (Type const&); + + protected: + PriorityModel (); + }; + + struct NWPriorityModel : Traversal::NWPriorityModel, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + NWPriorityModel (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + this->traverse (const_cast <Type const &> (o)); + } + + virtual void + traverse (Type const&); + + protected: + NWPriorityModel (); + }; + + struct PriorityModelPolicyDef : Traversal::PriorityModelPolicyDef, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::PriorityModelPolicyDef Type; + PriorityModelPolicyDef (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + priority_model (Type &o) + { + + this->priority_model (const_cast <Type const &> (o)); + } + + + virtual void + priority_model (Type const&); + + virtual void + server_priority (Type &o) + { + + this->server_priority (const_cast <Type const &> (o)); + } + + + virtual void + server_priority (Type const&); + + protected: + PriorityModelPolicyDef (); + }; + + struct NWPriorityModelPolicyDef : Traversal::NWPriorityModelPolicyDef, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::NWPriorityModelPolicyDef Type; + NWPriorityModelPolicyDef (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + nw_priority_model (Type &o) + { + + this->nw_priority_model (const_cast <Type const &> (o)); + } + + + virtual void + nw_priority_model (Type const&); + + virtual void + request_dscp (Type &o) + { + + this->request_dscp (const_cast <Type const &> (o)); + } + + + virtual void + request_dscp (Type const&); + + virtual void + reply_dscp (Type &o) + { + + this->reply_dscp (const_cast <Type const &> (o)); + } + + + virtual void + reply_dscp (Type const&); + + protected: + NWPriorityModelPolicyDef (); + }; + + struct CNWPriorityModelPolicyDef : Traversal::CNWPriorityModelPolicyDef, + virtual ::XSCRT::Writer< ACE_TCHAR > + { + typedef ::CIAO::Config_Handlers::CNWPriorityModelPolicyDef Type; + CNWPriorityModelPolicyDef (::XSCRT::XML::Element< ACE_TCHAR >&); + + virtual void + traverse (Type &o) + { + + this->traverse (const_cast <Type const &> (o)); + } + + + virtual void + traverse (Type const&); + + virtual void + request_dscp (Type &o) + { + + this->request_dscp (const_cast <Type const &> (o)); + } + + + virtual void + request_dscp (Type const&); + + virtual void + reply_dscp (Type &o) + { + + this->reply_dscp (const_cast <Type const &> (o)); + } + + + virtual void + reply_dscp (Type const&); + + protected: + CNWPriorityModelPolicyDef (); + }; + } + } +} + +namespace CIAO +{ + namespace Config_Handlers + { + RT_CCM_Handlers_Export + void + ServerResources (::CIAO::Config_Handlers::ServerResourcesDef const&, xercesc::DOMDocument*); + } +} + +#endif // CIAOSERVER_RESOURCES_HPP diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/CLA_Handler.cpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/CLA_Handler.cpp new file mode 100644 index 00000000000..39e2d72bbbf --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/CLA_Handler.cpp @@ -0,0 +1,44 @@ +// $Id$Exp + +#include "CLA_Handler.h" +#include "CIAOServerResources.hpp" + +namespace CIAO +{ + namespace Config_Handlers + { + bool CLA_Handler::commandline_arguments (const ServerResourcesDef &src, + ::CIAO::DAnCE::CommandlineArgs &dest) + { + ServerCmdlineOptions sco = src.cmdline(); + + for(ServerCmdlineOptions::arg_iterator loc = sco.begin_arg(); + loc != sco.end_arg(); + loc++) + { + CORBA::ULong len = dest.length(); + + dest.length(len+1); + + dest[len] = CORBA::string_dup (loc->c_str ()); + } + + return true; + } + + ServerCmdlineOptions + CLA_Handler::commandline_argument (const CIAO::DAnCE::CommandlineArgs &src) + { + ServerCmdlineOptions co; + + for (CORBA::ULong i = 0; + i < src.length (); + ++i) + { + co.add_arg (src[i].in ()); + } + + return co; + } + } +} diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/CLA_Handler.h b/modules/CIAO/tools/Config_Handlers/RT-CCM/CLA_Handler.h new file mode 100644 index 00000000000..e8676b54772 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/CLA_Handler.h @@ -0,0 +1,52 @@ +//======================================================= +/* @file CLA_Handler.h + * + * @author Lucas Seibert <lseibert@dre.vanderbilt.edu + * @author Will Otte <wotte@dre.vanderbilt.edu> + * + * $Id$ + */ +//======================================================= + +#ifndef CIAO_CONFIG_HANDLERS_CLA_HANDLER_H +#define CIAO_CONFIG_HANDLERS_CLA_HANDLER_H + +#include /**/ "ace/pre.h" + +#include "RT_CCM_Handlers_Export.h" +#include "DAnCE/Deployment/CIAO_ServerResourcesC.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +namespace CIAO +{ + namespace Config_Handlers + { + + class ServerResourcesDef; + class ServerCmdlineOptions; + + /* + * class CLA_Handler + * This is a brief Handler class for <CommandlineArg> + */ + + class RT_CCM_Handlers_Export CLA_Handler + { + public: + static bool + commandline_arguments ( + const ServerResourcesDef &src, + ::CIAO::DAnCE::CommandlineArgs &dest); + + static ServerCmdlineOptions + commandline_argument (const ::CIAO::DAnCE::CommandlineArgs &src); + + }; + } +} + +#include /**/ "ace/post.h" +#endif /* CLA_HANDLER_H */ diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/CNPM_Handler.cpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/CNPM_Handler.cpp new file mode 100755 index 00000000000..acc74ca8c99 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/CNPM_Handler.cpp @@ -0,0 +1,93 @@ +// $Id$ + +#include "CNPM_Handler.h" +#include "CIAOServerResources.hpp" +#include "ace/Auto_Ptr.h" + +#define IPDSFIELD_DSCP_DEFAULT 0x00 +#define IPDSFIELD_DSCP_CS1 0x08 +#define IPDSFIELD_DSCP_CS2 0x10 +#define IPDSFIELD_DSCP_CS3 0x18 +#define IPDSFIELD_DSCP_CS4 0x20 +#define IPDSFIELD_DSCP_CS5 0x28 +#define IPDSFIELD_DSCP_CS6 0x30 +#define IPDSFIELD_DSCP_CS7 0x38 +#define IPDSFIELD_DSCP_AF11 0x0A +#define IPDSFIELD_DSCP_AF12 0x0C +#define IPDSFIELD_DSCP_AF13 0x0E +#define IPDSFIELD_DSCP_AF21 0x12 +#define IPDSFIELD_DSCP_AF22 0x14 +#define IPDSFIELD_DSCP_AF23 0x16 +#define IPDSFIELD_DSCP_AF31 0x1A +#define IPDSFIELD_DSCP_AF32 0x1C +#define IPDSFIELD_DSCP_AF33 0x1E +#define IPDSFIELD_DSCP_AF41 0x22 +#define IPDSFIELD_DSCP_AF42 0x24 +#define IPDSFIELD_DSCP_AF43 0x26 +#define IPDSFIELD_ECT_MASK 0x02 +#define IPDSFIELD_CE_MASK 0x01 +#define IPDSFIELD_DSCP_EF 0x2E + +static int const dscp[] = +{ + IPDSFIELD_DSCP_DEFAULT , + IPDSFIELD_DSCP_CS1 , + IPDSFIELD_DSCP_CS2 , + IPDSFIELD_DSCP_CS3 , + IPDSFIELD_DSCP_CS4 , + IPDSFIELD_DSCP_CS5 , + IPDSFIELD_DSCP_CS6 , + IPDSFIELD_DSCP_CS7 , + IPDSFIELD_DSCP_AF11 , + IPDSFIELD_DSCP_AF12 , + IPDSFIELD_DSCP_AF13 , + IPDSFIELD_DSCP_AF21 , + IPDSFIELD_DSCP_AF22 , + IPDSFIELD_DSCP_AF23 , + IPDSFIELD_DSCP_AF31 , + IPDSFIELD_DSCP_AF32 , + IPDSFIELD_DSCP_AF33 , + IPDSFIELD_DSCP_AF41 , + IPDSFIELD_DSCP_AF42 , + IPDSFIELD_DSCP_AF43 , + IPDSFIELD_DSCP_EF +}; + + +namespace CIAO +{ + namespace Config_Handlers + { + + bool + CNPM_Handler::cnw_priority_pd (const CNWPriorityModelPolicyDef &src, + ::CIAO::DAnCE::CNWPriorityModelPolicyDef &dest) + { + int request_array_slot = 7; + long d = dscp[request_array_slot]; + + int a = static_cast <ACE_INT16> (d); + long b = static_cast <ACE_INT32> (a); + long c = static_cast <ACE_INT32> (a); + + ACE_DEBUG ((LM_DEBUG, "numbers are %d %X %X\n", a, b, c)); + + dest.request_dscp = + static_cast <ACE_INT32> (src.request_dscp ()); + dest.reply_dscp = + static_cast <ACE_INT32> (src.reply_dscp ()); + + return true; + } + + CNWPriorityModelPolicyDef + CNPM_Handler::cnw_priority_pd ( + const ::CIAO::DAnCE::CNWPriorityModelPolicyDef&) + { + auto_ptr <CNWPriorityModelPolicyDef> pmd; + pmd.reset (new CNWPriorityModelPolicyDef (0, 0)); + return *pmd; + } + } +} + diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/CNPM_Handler.h b/modules/CIAO/tools/Config_Handlers/RT-CCM/CNPM_Handler.h new file mode 100755 index 00000000000..39da8b2fae4 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/CNPM_Handler.h @@ -0,0 +1,45 @@ +/** + * @file CNPM_Handler.h + * + * $Id$ + */ + + +#ifndef CIAO_CONFIG_HANDLERS_CNPM_HANDLER_H +#define CIAO_CONFIG_HANDLERS_CNPM_HANDLER_H + +#include /**/ "ace/pre.h" + +#include "RT_CCM_Handlers_Export.h" +#include "DAnCE/Deployment/CIAO_ServerResourcesC.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +namespace CIAO +{ + namespace Config_Handlers + { + class CNWPriorityModelPolicyDef; + + /** + * @class CNPM_Handler + * @brief Handler class for client NetworkPriorityModelPolicyDefs + */ + + class RT_CCM_Handlers_Export CNPM_Handler + { + public: + static bool cnw_priority_pd (const CNWPriorityModelPolicyDef &src, + ::CIAO::DAnCE::CNWPriorityModelPolicyDef &dest); + + static CNWPriorityModelPolicyDef cnw_priority_pd ( + const ::CIAO::DAnCE::CNWPriorityModelPolicyDef &src); + }; + } + +} + +#include /**/ "ace/post.h" +#endif /* CIAO_CONFIG_HANDLERS_CNPM_HANDLER_H */ diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/NPM_Handler.cpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/NPM_Handler.cpp new file mode 100755 index 00000000000..d530b2169e2 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/NPM_Handler.cpp @@ -0,0 +1,131 @@ +// $Id$ + +#include "NPM_Handler.h" +#include "CIAOServerResources.hpp" +#include "ace/Auto_Ptr.h" + +#define IPDSFIELD_DSCP_DEFAULT 0x00 +#define IPDSFIELD_DSCP_CS1 0x08 +#define IPDSFIELD_DSCP_CS2 0x10 +#define IPDSFIELD_DSCP_CS3 0x18 +#define IPDSFIELD_DSCP_CS4 0x20 +#define IPDSFIELD_DSCP_CS5 0x28 +#define IPDSFIELD_DSCP_CS6 0x30 +#define IPDSFIELD_DSCP_CS7 0x38 +#define IPDSFIELD_DSCP_AF11 0x0A +#define IPDSFIELD_DSCP_AF12 0x0C +#define IPDSFIELD_DSCP_AF13 0x0E +#define IPDSFIELD_DSCP_AF21 0x12 +#define IPDSFIELD_DSCP_AF22 0x14 +#define IPDSFIELD_DSCP_AF23 0x16 +#define IPDSFIELD_DSCP_AF31 0x1A +#define IPDSFIELD_DSCP_AF32 0x1C +#define IPDSFIELD_DSCP_AF33 0x1E +#define IPDSFIELD_DSCP_AF41 0x22 +#define IPDSFIELD_DSCP_AF42 0x24 +#define IPDSFIELD_DSCP_AF43 0x26 +#define IPDSFIELD_ECT_MASK 0x02 +#define IPDSFIELD_CE_MASK 0x01 +#define IPDSFIELD_DSCP_EF 0x2E + +static int const dscp[] = +{ + IPDSFIELD_DSCP_DEFAULT , + IPDSFIELD_DSCP_CS1 , + IPDSFIELD_DSCP_CS2 , + IPDSFIELD_DSCP_CS3 , + IPDSFIELD_DSCP_CS4 , + IPDSFIELD_DSCP_CS5 , + IPDSFIELD_DSCP_CS6 , + IPDSFIELD_DSCP_CS7 , + IPDSFIELD_DSCP_AF11 , + IPDSFIELD_DSCP_AF12 , + IPDSFIELD_DSCP_AF13 , + IPDSFIELD_DSCP_AF21 , + IPDSFIELD_DSCP_AF22 , + IPDSFIELD_DSCP_AF23 , + IPDSFIELD_DSCP_AF31 , + IPDSFIELD_DSCP_AF32 , + IPDSFIELD_DSCP_AF33 , + IPDSFIELD_DSCP_AF41 , + IPDSFIELD_DSCP_AF42 , + IPDSFIELD_DSCP_AF43 , + IPDSFIELD_DSCP_EF +}; + + +namespace CIAO +{ + namespace Config_Handlers + { + + bool + NPM_Handler::nw_priority_model_pd (const NWPriorityModelPolicyDef &src, + ::CIAO::DAnCE::NWPriorityModelPolicyDef &dest) + { + switch (src.nw_priority_model ().integral ()) + { + case NWPriorityModel::SERVER_DECLARED_NWPRIORITY_l: + dest.nw_priority_model = ::CIAO::DAnCE::SERVER_DECLARED_NWPRIORITY; + break; + + case NWPriorityModel::CLIENT_PROPAGATED_NWPRIORITY_l: + dest.nw_priority_model = ::CIAO::DAnCE::CLIENT_PROPAGATED_NWPRIORITY; + break; + + default: + ACE_ERROR ((LM_ERROR, + "Unknown priority model passed to priority_model_pd\n")); + return false; + } + + int request_array_slot = 7; + long d = dscp[request_array_slot]; + + int a = static_cast <ACE_INT16> (d); + long b = static_cast <ACE_INT32> (a); + long c = static_cast <ACE_INT32> (a); + + ACE_DEBUG ((LM_DEBUG, "numbers are %d %X %X\n", a, b, c)); + + dest.request_dscp = + static_cast <ACE_INT32> (src.request_dscp ()); + dest.reply_dscp = + static_cast <ACE_INT32> (src.reply_dscp ()); + + return true; + } + + + NWPriorityModelPolicyDef + NPM_Handler::nw_priority_model_pd ( + const ::CIAO::DAnCE::NWPriorityModelPolicyDef &src) + { + auto_ptr <NWPriorityModelPolicyDef> pmd; + + switch (src.nw_priority_model) + { + case ::CIAO::DAnCE::CLIENT_PROPAGATED_NWPRIORITY: + pmd.reset (new NWPriorityModelPolicyDef +(NWPriorityModel::CLIENT_PROPAGATED_NWPRIORITY, 0, 0)); + break; + + case ::CIAO::DAnCE::SERVER_DECLARED_NWPRIORITY: + pmd.reset (new NWPriorityModelPolicyDef +(NWPriorityModel::SERVER_DECLARED_NWPRIORITY, 0, 0)); + break; + + default: + ACE_ERROR ((LM_ERROR, + "Invalid priority model given to nw_priority_model_pd\n")); + throw 1; + } + + return *pmd; + } + + + } + +} + diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/NPM_Handler.h b/modules/CIAO/tools/Config_Handlers/RT-CCM/NPM_Handler.h new file mode 100755 index 00000000000..bde507ba189 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/NPM_Handler.h @@ -0,0 +1,45 @@ +/** + * @file NPM_Handler.h + * + * $Id$ + */ + + +#ifndef CIAO_CONFIG_HANDLERS_NPM_HANDLER_H +#define CIAO_CONFIG_HANDLERS_NPM_HANDLER_H + +#include /**/ "ace/pre.h" + +#include "RT_CCM_Handlers_Export.h" +#include "DAnCE/Deployment/CIAO_ServerResourcesC.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +namespace CIAO +{ + namespace Config_Handlers + { + class NWPriorityModelPolicyDef; + + /** + * @class NPM_Handler + * @brief Handler class for NetworkPriorityModelPolicyDefs + */ + + class RT_CCM_Handlers_Export NPM_Handler + { + public: + static bool nw_priority_model_pd (const NWPriorityModelPolicyDef &src, + ::CIAO::DAnCE::NWPriorityModelPolicyDef &dest); + + static NWPriorityModelPolicyDef nw_priority_model_pd ( + const ::CIAO::DAnCE::NWPriorityModelPolicyDef &src); + }; + } + +} + +#include /**/ "ace/post.h" +#endif /* CIAO_CONFIG_HANDLERS_NPM_HANDLER_H */ diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/OC_Handler.cpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/OC_Handler.cpp new file mode 100644 index 00000000000..41c45ee7c96 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/OC_Handler.cpp @@ -0,0 +1,51 @@ +// $Id$ + +#include "OC_Handler.h" +#include "OR_Handler.h" +#include "PS_Handler.h" +#include "CIAOServerResources.hpp" + +namespace CIAO +{ + namespace Config_Handlers + { + + bool OC_Handler::orb_config ( + const ORBConfigs &src, + ::CIAO::DAnCE::ORBConfigs &dest) + { + if (src.resources_p ()) + OR_Handler::orb_resources (src.resources (), dest.orb_resources); + + CORBA::ULong pos (dest.policy_set.length ()); + + dest.policy_set.length (pos + src.count_policySet ()); + + for (ORBConfigs::policySet_const_iterator i = src.begin_policySet (); + i != src.end_policySet (); + ++i) + { + PS_Handler::policy_set (*i, dest.policy_set[pos++]); + } + + return true; + } + + + ORBConfigs OC_Handler::orb_config ( + const ::CIAO::DAnCE::ORBConfigs &src) + { + ORBConfigs oc; + + oc.resources(OR_Handler::orb_resources (src.orb_resources)); + + size_t len = src.policy_set.length(); + for(size_t i = 0; i < len; i++) + { + oc.add_policySet (PS_Handler::policy_set (src.policy_set [i])); + } + + return oc; + } + } +} diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/OC_Handler.h b/modules/CIAO/tools/Config_Handlers/RT-CCM/OC_Handler.h new file mode 100644 index 00000000000..abcd2c0a3c5 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/OC_Handler.h @@ -0,0 +1,50 @@ +//============================================ +/* + * @file OC_Handler.h + * + * @author Lucas Seibert <lseibert@dre.vanderbilt.edu> + * @author Will Otte <wotte@dre.vanderbilt.edu> + + * $Id$ + */ +//============================================ + +#ifndef CIAO_CONFIG_HANDLERS_OC_HANDLER_H +#define CIAO_CONFIG_HANDLERS_OC_HANDLER_H + +#include /**/ "ace/pre.h" + +#include "RT_CCM_Handlers_Export.h" +#include "DAnCE/Deployment/CIAO_ServerResourcesC.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +namespace CIAO +{ + namespace Config_Handlers + { + class ORBConfigs; + + /* + * @class OC_Handler + * + * @brief Handler class for <ORBConfigs> + */ + + class RT_CCM_Handlers_Export OC_Handler + { + public: + static bool orb_config (const ORBConfigs &src, + ::CIAO::DAnCE::ORBConfigs &dest); + + static ORBConfigs orb_config (const ::CIAO::DAnCE::ORBConfigs &src); + + }; + } +} + +#include /**/ "ace/post.h" +#endif /* OC_HANDLER_H */ + diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/OR_Handler.cpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/OR_Handler.cpp new file mode 100644 index 00000000000..28c829931e8 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/OR_Handler.cpp @@ -0,0 +1,90 @@ +// $Id$ + +#include "OR_Handler.h" +#include "TP_Handler.h" +#include "TPL_Handler.h" +#include "CB_Handler.h" +#include "CIAOServerResources.hpp" + +namespace CIAO +{ + namespace Config_Handlers + { + bool OR_Handler::orb_resources (const ORBResources &src, + ::CIAO::DAnCE::ORBResources &dest) + { + // We know that there should be only one. + dest.length (1); + + // Set the length of the threadpools + CORBA::ULong pos (dest[0].threadpool_list.length ()); + dest[0].threadpool_list.length (pos + src.count_threadpool ()); + + for (ORBResources::threadpool_const_iterator i = src.begin_threadpool (); + i != src.end_threadpool (); + ++i) + { + TP_Handler::thread_pool (*i, + dest[0].threadpool_list[pos++]); + } + + pos = dest[0].threadpool_with_lanes_list.length (); + dest[0].threadpool_with_lanes_list.length (pos + src.count_threadpoolWithLanes ()); + + for (ORBResources::threadpoolWithLanes_const_iterator j = src.begin_threadpoolWithLanes(); + j != src.end_threadpoolWithLanes(); + j++) + { + TPL_Handler::threadpool_with_lanes (*j, + dest[0].threadpool_with_lanes_list [pos++]); + } + + pos = dest[0].connection_bands_list.length (); + dest[0].connection_bands_list.length (pos + src.count_connectionBands ()); + + for (ORBResources::connectionBands_const_iterator k = src.begin_connectionBands(); + k != src.end_connectionBands(); + k++) + { + CB_Handler::connection_band (*k, + dest[0].connection_bands_list[pos++]); + } + return true; + } + + ORBResources OR_Handler::orb_resources (const ::CIAO::DAnCE::ORBResources &src) + { + if (src.length () == 0 || + src[0].threadpool_list.length () == 0 || + src[0].threadpool_with_lanes_list.length () == 0 || + src[0].connection_bands_list.length () == 0) + { + throw No_Resource (); + } + + size_t len; //For checking the length of sequences + + ORBResources ores; + + len = src[0].threadpool_list.length(); + for(size_t i = 0; i < len; ++i) + { + ores.add_threadpool (TP_Handler::thread_pool (src[0].threadpool_list[i])); + } + + len = src[0].threadpool_with_lanes_list.length(); + for(size_t j = 0; j < len; ++j) + { + ores.add_threadpoolWithLanes(TPL_Handler::threadpool_with_lanes (src[0].threadpool_with_lanes_list[j])); + } + + len = src[0].connection_bands_list.length(); + for(size_t k = 0; k < len; k++) + { + ores.add_connectionBands (CB_Handler::connection_band (src[0].connection_bands_list[k])); + } + + return ores; + } + } +} diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/OR_Handler.h b/modules/CIAO/tools/Config_Handlers/RT-CCM/OR_Handler.h new file mode 100644 index 00000000000..7720a230453 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/OR_Handler.h @@ -0,0 +1,53 @@ +//========================================================= +/* + * @file OR_Handler.h + * + * @author Lucas Seibert <lseibert@dre.vanderbilt.edu + * @author Will Otte <wotte@dre.vanderbilt.edu> + * + * $Id$ + */ +//========================================================= + +#ifndef CIAO_CONFIG_HANDLERS_OR_HANDLER_H +#define CIAO_CONFIG_HANDLERS_OR_HANDLER_H + +#include /**/ "ace/pre.h" + +#include "DAnCE/Deployment/CIAO_ServerResourcesC.h" +#include "RT_CCM_Handlers_Export.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +namespace CIAO +{ + namespace Config_Handlers + { + class ORBResources; + + /* Class description + * @class OR_Handler + * @function A brief Handler class for the <ORBResource> member + */ + + class RT_CCM_Handlers_Export OR_Handler + { + public: + + static bool orb_resources (const ORBResources &src, + ::CIAO::DAnCE::ORBResources &dest); + + class No_Resource {}; + + static ORBResources orb_resources (const ::CIAO::DAnCE::ORBResources &src); + + + }; + } +} + +#include /**/ "ace/post.h" + +#endif /* CIAO_CONFIG_HANDLERS_OR_HANDLER_H */ diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/PM_Handler.cpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/PM_Handler.cpp new file mode 100644 index 00000000000..088a426505c --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/PM_Handler.cpp @@ -0,0 +1,73 @@ +// $Id$ + +#include "PM_Handler.h" +#include "CIAOServerResources.hpp" +#include "ace/Auto_Ptr.h" + +namespace CIAO +{ + namespace Config_Handlers + { + + bool + PM_Handler::priority_model_pd (const PriorityModelPolicyDef &src, + ::CIAO::DAnCE::PriorityModelPolicyDef &dest) + { + switch (src.priority_model ().integral ()) + { + case PriorityModel::SERVER_DECLARED_l: + dest.priority_model = ::CIAO::DAnCE::SERVER_DECLARED; + break; + + case PriorityModel::CLIENT_PROPAGATED_l: + dest.priority_model = ::CIAO::DAnCE::CLIENT_PROPAGATED; + break; + + default: + ACE_ERROR ((LM_ERROR, + "Unknown priority model passed to priority_model_pd\n")); + return false; + } + + if (src.server_priority_p ()) + dest.server_priority = static_cast < ACE_INT32 > (src.server_priority ()); + else + dest.server_priority = 0; + + return true; + } + + + PriorityModelPolicyDef + PM_Handler::priority_model_pd (const ::CIAO::DAnCE::PriorityModelPolicyDef &src) + { + auto_ptr <PriorityModelPolicyDef> pmd; + + switch (src.priority_model) + { + case ::CIAO::DAnCE::CLIENT_PROPAGATED: + pmd.reset (new PriorityModelPolicyDef (PriorityModel::CLIENT_PROPAGATED)); + break; + + case ::CIAO::DAnCE::SERVER_DECLARED: + pmd.reset (new PriorityModelPolicyDef (PriorityModel::SERVER_DECLARED)); + break; + + default: + ACE_ERROR ((LM_ERROR, + "Invalid priority model given to priority_model_pd\n")); + throw 1; + } + + pmd->server_priority (XMLSchema::int_ (src.server_priority)); + + return *pmd; + } + + + } + + + +} + diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/PM_Handler.h b/modules/CIAO/tools/Config_Handlers/RT-CCM/PM_Handler.h new file mode 100644 index 00000000000..2063eec449a --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/PM_Handler.h @@ -0,0 +1,45 @@ +/** + * @file PM_Handler.h + * @author Will Otte <wotte@dre.vanderbilt.edu> + * + * $Id$ + */ + + +#ifndef CIAO_CONFIG_HANDLERS_PM_HANDLER_H +#define CIAO_CONFIG_HANDLERS_PM_HANDLER_H + +#include /**/ "ace/pre.h" + +#include "RT_CCM_Handlers_Export.h" +#include "DAnCE/Deployment/CIAO_ServerResourcesC.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +namespace CIAO +{ + namespace Config_Handlers + { + class PriorityModelPolicyDef; + + /** + * @class PS_Handler + * @brief Handler class for PriorityModelPolicyDefs + */ + + class RT_CCM_Handlers_Export PM_Handler + { + public: + static bool priority_model_pd (const PriorityModelPolicyDef &src, + ::CIAO::DAnCE::PriorityModelPolicyDef &dest); + + static PriorityModelPolicyDef priority_model_pd (const ::CIAO::DAnCE::PriorityModelPolicyDef &src); + }; + } + +} + +#include /**/ "ace/post.h" +#endif /* CIAO_CONFI_HANDLERS_PM_HANDLER_H */ diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/PS_Handler.cpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/PS_Handler.cpp new file mode 100644 index 00000000000..16a2f71f40a --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/PS_Handler.cpp @@ -0,0 +1,152 @@ +// $Id$ + +#include "PS_Handler.h" +#include "PM_Handler.h" +#include "NPM_Handler.h" +#include "CNPM_Handler.h" +#include "CIAOServerResources.hpp" + +namespace CIAO +{ + namespace Config_Handlers + { + bool + PS_Handler::policy_set (const PolicySet &src, + ::CIAO::DAnCE::PolicySet &dest) + { + if (src.id_p ()) + dest.Id = CORBA::string_dup (src.id ().c_str ()); + + // Make room for all of the policies + CORBA::ULong len (dest.policies.length ()); + dest.policies.length (len + + src.count_priorityModel () + + src.count_nwpriorityModel () + + src.count_cnwpriorityModel () + + src.count_threadpool () + + src.count_priorityBandedConnection ()); + + for (PolicySet::priorityModel_const_iterator i = src.begin_priorityModel (); + i != src.end_priorityModel (); + ++i) + { + ::CIAO::DAnCE::PriorityModelPolicyDef pmd; + + PM_Handler::priority_model_pd (*i, pmd); + + dest.policies[len++].PriorityModelDef (pmd); + } + + for (PolicySet::nwpriorityModel_const_iterator i = + src.begin_nwpriorityModel (); + i != src.end_nwpriorityModel (); + ++i) + { + ::CIAO::DAnCE::NWPriorityModelPolicyDef npmd; + + NPM_Handler::nw_priority_model_pd (*i, npmd); + + dest.policies[len++].NWPriorityModelDef (npmd); + } + + for (PolicySet::cnwpriorityModel_const_iterator i = + src.begin_cnwpriorityModel (); + i != src.end_cnwpriorityModel (); + ++i) + { + ::CIAO::DAnCE::CNWPriorityModelPolicyDef cnpmd; + + CNPM_Handler::cnw_priority_pd (*i, cnpmd); + + dest.policies[len++].CNWPriorityModelDef (cnpmd); + } + + for (PolicySet::threadpool_const_iterator i = src.begin_threadpool (); + i != src.end_threadpool (); + ++i) + { + ::CIAO::DAnCE::ThreadpoolPolicyDef tpd; + + tpd.Id = CORBA::string_dup (i->id ().c_str ()); + + dest.policies[len++].ThreadpoolDef (tpd); + } + + + for (PolicySet::priorityBandedConnection_const_iterator i = src.begin_priorityBandedConnection (); + i != src.end_priorityBandedConnection (); + ++i) + { + ::CIAO::DAnCE::PriorityBandedConnectionPolicyDef pbc; + + pbc.Id = CORBA::string_dup (i->id ().c_str ()); + + dest.policies[len++].PriorityBandedConnectionDef (pbc); + } + return true; + } + + PolicySet + PS_Handler::policy_set (const ::CIAO::DAnCE::PolicySet &src) + { + PolicySet ps; + + if (src.Id.in ()) + ps.id (src.Id.in ()); + + for (CORBA::ULong i = 0; + i < src.policies.length (); + ++i) + { + ACE_DEBUG ((LM_ERROR, + "Attempting switch for i = %d\n", + i)); + + switch (src.policies[i]._d ()) + { + case ::CIAO::DAnCE::PRIORITY_MODEL_POLICY_TYPE: + ps.add_priorityModel ( + PM_Handler::priority_model_pd ( + src.policies[i].PriorityModelDef ())); + break; + + case ::CIAO::DAnCE::NETWORK_PRIORITY_TYPE: + ps.add_nwpriorityModel ( + NPM_Handler::nw_priority_model_pd ( + src.policies[i].NWPriorityModelDef ())); + break; + + case ::CIAO::DAnCE::CLIENT_NETWORK_PRIORITY_TYPE: + ps.add_cnwpriorityModel ( + CNPM_Handler::cnw_priority_pd ( + src.policies[i].CNWPriorityModelDef ())); + break; + + case ::CIAO::DAnCE::THREADPOOL_POLICY_TYPE: + ps.add_threadpool (src.policies[i].ThreadpoolDef ().Id.in ()); + break; + + case ::CIAO::DAnCE::PRIORITY_BANDED_CONNECTION_POLICY_TYPE: + ps.add_priorityBandedConnection ( + src.policies[i].PriorityBandedConnectionDef ().Id.in ()); + break; + + case 0: + ACE_ERROR ((LM_ERROR, + "Skipping invalid policy.\n")); + break; + + default: + ACE_ERROR ((LM_ERROR, + "Bad policy stored in policy_set: %i\n", + src.policies[i]._d ())); + throw 1; + } + } + + return ps; + } + + } + +} diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/PS_Handler.h b/modules/CIAO/tools/Config_Handlers/RT-CCM/PS_Handler.h new file mode 100644 index 00000000000..5c3cb4ae996 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/PS_Handler.h @@ -0,0 +1,45 @@ +/** + * @file PS_Handler.h + * @author Will Otte <wotte@dre.vanderbilt.edu> + * + * $Id$ + */ + + +#ifndef CIAO_CONFIG_HANDLERS_PS_HANDLER_H +#define CIAO_CONFIG_HANDLERS_PS_HANDLER_H + +#include /**/ "ace/pre.h" + +#include "RT_CCM_Handlers_Export.h" +#include "DAnCE/Deployment/CIAO_ServerResourcesC.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +namespace CIAO +{ + namespace Config_Handlers + { + class PolicySet; + + /** + * @class PS_Handler + * @brief Handler class for PolicySets + */ + + class RT_CCM_Handlers_Export PS_Handler + { + public: + static bool policy_set (const PolicySet &src, + ::CIAO::DAnCE::PolicySet &dest); + + static PolicySet policy_set (const ::CIAO::DAnCE::PolicySet &src); + }; + + } +} + +#include /**/ "ace/post.h" +#endif /* CIAO_CONFI_HANDLERS_PS_HANDLER_H */ diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/RT-CCM-Handlers.mpc b/modules/CIAO/tools/Config_Handlers/RT-CCM/RT-CCM-Handlers.mpc new file mode 100644 index 00000000000..eb95e0788d5 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/RT-CCM-Handlers.mpc @@ -0,0 +1,63 @@ +//$Id$ + +project (RT_CCM_XML_Generation) : xscdefaults { + requires += xsc dummy_label + + xscflags += --cxx-banner-file $(CIAO_ROOT)/docs/schema/xsc-banner.cpp + xscflags += --cxx-header-banner-file $(CIAO_ROOT)/docs/schema/xsc-banner.h + xscflags += --cxx-export-symbol RT_CCM_Handlers_Export + xscflags += --cxx-namespace-regex <%quote%>%.*vanderbilt.*%CIAO/Config_Handlers%<%quote%> + xscflags += --cxx-export-header RT_CCM_Handlers_Export.h + xscflags += --search-path "$(CIAO_ROOT)/docs/schema" + + custom_only = 1 + + XSC_Files { + gendir = . + $(CIAO_ROOT)/docs/schema/CIAOServerResources.xsd + } +} + +project (RT_CCM_Config_Handlers) : acelib, dance_deployment_stub, ciao_config_handlers_base { + sharedname = RT_CCM_Config_Handlers + dynamicflags = RT_CCM_HANDLERS_BUILD_DLL + macros += XML_USE_PTHREADS + includes += $(CIAO_ROOT)/tools/Config_Handlers + includes += $(CIAO_ROOT)/ciao + + after += RT_CCM_XML_Generation + + requires += dummy_label + + Source_Files { + CIAOServerResources.cpp + CLA_Handler.cpp + OC_Handler.cpp + OR_Handler.cpp + PM_Handler.cpp + PS_Handler.cpp + CNPM_Handler.cpp + NPM_Handler.cpp + SRD_Handler.cpp + TP_Handler.cpp + TPL_Handler.cpp + CB_Handler.cpp + } + + Header_Files { + } +} + +//project (RT-CCM_Config_Handlers_Tests) : ciao_executor, xerces { +// requires += dummy_label +// exename = rt-ccm-test +// after += RT-CCM-Handlers +// dynamicflags = CONFIG_HANDLERS_BUILD_DLL +// macros += XML_USE_PTHREADS +// includes += $(CIAO_ROOT)/tools/Config_Handlers +// libs += CIAO_DnC_Server TAO_IFR_Client RT_CCM_Config_Handlers CIAO_XML_Utils + +// Source_Files { +// test.cpp +// } +//} diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/RT_CCM_Handlers_Export.h b/modules/CIAO/tools/Config_Handlers/RT-CCM/RT_CCM_Handlers_Export.h new file mode 100644 index 00000000000..fdba117ae61 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/RT_CCM_Handlers_Export.h @@ -0,0 +1,54 @@ + +// -*- C++ -*- +// $Id$ +// Definition for Win32 Export directives. +// This file is generated automatically by generate_export_file.pl RT_CCM_Handlers +// ------------------------------ +#ifndef RT_CCM_HANDLERS_EXPORT_H +#define RT_CCM_HANDLERS_EXPORT_H + +#include "ace/config-all.h" + +#if !defined (RT_CCM_HANDLERS_HAS_DLL) +# define RT_CCM_HANDLERS_HAS_DLL 1 +#endif /* ! RT_CCM_HANDLERS_HAS_DLL */ + +#if defined (RT_CCM_HANDLERS_HAS_DLL) && (RT_CCM_HANDLERS_HAS_DLL == 1) +# if defined (RT_CCM_HANDLERS_BUILD_DLL) +# define RT_CCM_Handlers_Export ACE_Proper_Export_Flag +# define RT_CCM_HANDLERS_SINGLETON_DECLARATION(T) ACE_EXPORT_SINGLETON_DECLARATION (T) +# define RT_CCM_HANDLERS_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_EXPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) +# else /* RT_CCM_HANDLERS_BUILD_DLL */ +# define RT_CCM_Handlers_Export ACE_Proper_Import_Flag +# define RT_CCM_HANDLERS_SINGLETON_DECLARATION(T) ACE_IMPORT_SINGLETON_DECLARATION (T) +# define RT_CCM_HANDLERS_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_IMPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) +# endif /* RT_CCM_HANDLERS_BUILD_DLL */ +#else /* RT_CCM_HANDLERS_HAS_DLL == 1 */ +# define RT_CCM_Handlers_Export +# define RT_CCM_HANDLERS_SINGLETON_DECLARATION(T) +# define RT_CCM_HANDLERS_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) +#endif /* RT_CCM_HANDLERS_HAS_DLL == 1 */ + +// Set RT_CCM_HANDLERS_NTRACE = 0 to turn on library specific tracing even if +// tracing is turned off for ACE. +#if !defined (RT_CCM_HANDLERS_NTRACE) +# if (ACE_NTRACE == 1) +# define RT_CCM_HANDLERS_NTRACE 1 +# else /* (ACE_NTRACE == 1) */ +# define RT_CCM_HANDLERS_NTRACE 0 +# endif /* (ACE_NTRACE == 1) */ +#endif /* !RT_CCM_HANDLERS_NTRACE */ + +#if (RT_CCM_HANDLERS_NTRACE == 1) +# define RT_CCM_HANDLERS_TRACE(X) +#else /* (RT_CCM_HANDLERS_NTRACE == 1) */ +# if !defined (ACE_HAS_TRACE) +# define ACE_HAS_TRACE +# endif /* ACE_HAS_TRACE */ +# define RT_CCM_HANDLERS_TRACE(X) ACE_TRACE_IMPL(X) +# include "ace/Trace.h" +#endif /* (RT_CCM_HANDLERS_NTRACE == 1) */ + +#endif /* RT_CCM_HANDLERS_EXPORT_H */ + +// End of auto generated file. diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/SRD_Handler.cpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/SRD_Handler.cpp new file mode 100644 index 00000000000..17ce790182e --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/SRD_Handler.cpp @@ -0,0 +1,156 @@ +// $Id$ +#include "Utils/XML_Typedefs.h" +#include "SRD_Handler.h" +#include "CIAOServerResources.hpp" +#include "CLA_Handler.h" +#include "OC_Handler.h" + +namespace CIAO +{ + namespace Config_Handlers + { + SRD_Handler::SRD_Handler (const ACE_TCHAR *file) : + idl_srd_(0), + srd_ (0), + retval_ (false) + { + XERCES_CPP_NAMESPACE::DOMDocument *dom = + XML_HELPER.create_dom (file); + + if (!dom) + throw SRD_Handler::NoSRD (); + + this->srd_.reset (new ServerResourcesDef + (ServerResources (dom))); + + if (!this->build_srd ()) + throw NoSRD (); + } + + SRD_Handler::SRD_Handler (ServerResourcesDef *srd): + idl_srd_(0), + srd_(srd), + retval_(false) + { + if(!this->build_srd()) + throw NoSRD (); + } + + SRD_Handler::SRD_Handler (::CIAO::DAnCE::ServerResource *srd): + idl_srd_(srd), + srd_(0), + retval_(false) + { + if(!this->build_xsc()) + throw NoSRD (); + } + + SRD_Handler::~SRD_Handler (void) + { + } + + bool + SRD_Handler::build_srd () + { + this->idl_srd_.reset ( new ::CIAO::DAnCE::ServerResource ); + + if(this->srd_->cmdline_p()) + { + this->retval_ = CLA_Handler::commandline_arguments(*this->srd_, + this->idl_srd_->args); + } + + if(this->srd_->svcconf_p()) + { + this->idl_srd_->svcconf = (srd_->svcconf().uri().c_str()); + } + + this->retval_ = OC_Handler::orb_config (this->srd_->orbConfigs (), + this->idl_srd_->orb_config); + + if (this->srd_->id_p ()) + { + this->idl_srd_->Id = srd_->id ().c_str (); + } + + return this->retval_; + } + + bool + SRD_Handler::build_xsc () + { + size_t len; //For checking the length of src data members + + // Load the ORBConfigs and create the XSC structure for SRD + this->srd_.reset (new ServerResourcesDef (OC_Handler::orb_config (this->idl_srd_->orb_config))); + + + //Note: Why did we make the CmdlineOptions a separate class instead of a + // vector of strings??? + + ServerCmdlineOptions sco; + + //First load up the CmdlineArgs if they exist + len = idl_srd_->args.length(); + for(size_t i = 0; i < len; i++) + { + XMLSchema::string < ACE_TCHAR > curr ((this->idl_srd_->args[i])); + sco.add_arg(curr); + } + this->srd_->cmdline (sco); + + //Then a similar thing for the svcconf + XMLSchema::string < ACE_TCHAR > curr (this->idl_srd_->svcconf); + ACESvcConf asc; + asc.uri(curr); + this->srd_->svcconf (asc); + + XMLSchema::string < ACE_TCHAR > id (this->idl_srd_->Id.in ()); + this->srd_->id (id); + + return true; + } + + ::CIAO::DAnCE::ServerResource const * + SRD_Handler::srd_idl () const + { + if(!this->idl_srd_.get()) + throw NoSRD (); + + //else + return this->idl_srd_.get(); + } + + ::CIAO::DAnCE::ServerResource * + SRD_Handler::srd_idl () + { + if(!this->idl_srd_.get()) + throw NoSRD(); + + //else + return this->idl_srd_.release(); + } + + ServerResourcesDef const * + SRD_Handler::srd_xsc () const + { + if(!this->srd_.get()) + throw NoSRD (); + + //else + return this->srd_.get(); + } + + ServerResourcesDef * + SRD_Handler::srd_xsc () + { + if(!this->srd_.get()) + throw NoSRD (); + + //else + return this->srd_.release(); + } + } +} + + diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/SRD_Handler.h b/modules/CIAO/tools/Config_Handlers/RT-CCM/SRD_Handler.h new file mode 100644 index 00000000000..c55447b5562 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/SRD_Handler.h @@ -0,0 +1,73 @@ +//====================================== +/** + * @file SRD_Handler.h + * + * @author Lucas Seibert <lseibert@dre.vanderbilt.edu> + * @author Will Otte <wotte@dre.vanderbilt.edu> + * + * $Id$ + */ +//====================================== + +#ifndef CIAO_CONFIG_HANDLERS_SRD_HANDLER_H +#define CIAO_CONFIG_HANDLERS_SRD_HANDLER_H +#include /**/ "ace/pre.h" + +#include "RT_CCM_Handlers_Export.h" +#include "DAnCE/Deployment/CIAO_ServerResourcesC.h" +#include "ace/Auto_Ptr.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +namespace CIAO +{ + namespace Config_Handlers + { + class ServerResourcesDef; + + /* + * @class SRD_Handler + * + * @brief Handler class for <ServerResourcesDef + */ + + class RT_CCM_Handlers_Export SRD_Handler + { + public: + class NoSRD {}; + + SRD_Handler (const ACE_TCHAR *file); + + SRD_Handler(ServerResourcesDef *srd); + + SRD_Handler(::CIAO::DAnCE::ServerResource *srd); + + ~SRD_Handler (void); + + ::CIAO::DAnCE::ServerResource const *srd_idl (void) const; + + ::CIAO::DAnCE::ServerResource *srd_idl (void); + + ServerResourcesDef const *srd_xsc (void) const; + + ServerResourcesDef *srd_xsc (void); + + private: + bool build_srd (); + + + bool build_xsc (); + + auto_ptr < ::CIAO::DAnCE::ServerResource > idl_srd_; + + auto_ptr <ServerResourcesDef> srd_; + + bool retval_; + }; + } +} + +#include /**/ "ace/post.h" +#endif /* SRD_HANDLER_H */ diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/TPL_Handler.cpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/TPL_Handler.cpp new file mode 100644 index 00000000000..4d65478d19c --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/TPL_Handler.cpp @@ -0,0 +1,81 @@ +// $Id$ + +#include "TPL_Handler.h" +#include "CIAOServerResources.hpp" + +namespace CIAO +{ + namespace Config_Handlers + { + bool + TPL_Handler::threadpool_with_lanes ( + const ThreadpoolWithLanesDef &src, + ::CIAO::DAnCE::ORS_ThreadpoolWithLanes &dest) + { + if (src.id_p ()) + { + dest.Id = CORBA::string_dup (src.id().c_str ()); + } + + for (ThreadpoolWithLanesDef::threadpoolLane_const_iterator loc = + src.begin_threadpoolLane (); + loc != src.end_threadpoolLane (); + loc++) + { + size_t len = dest.threadpool_lanes.length (); + + dest.threadpool_lanes.length (len + 1); + + dest.threadpool_lanes[len].lane_priority = + static_cast <ACE_INT16> (loc->priority ()); + + dest.threadpool_lanes[len].static_threads = + static_cast <ACE_UINT32> (loc->static_threads ()); + + dest.threadpool_lanes[len].dynamic_threads = + static_cast <ACE_UINT32> (loc->dynamic_threads ()); + } + + dest.stacksize = static_cast <ACE_INT16> (src.stacksize ()); + + dest.allow_borrowing = src.allow_borrowing (); + + dest.allow_request_buffering = src.allow_request_buffering (); + + dest.max_buffered_requests = + static_cast <ACE_UINT32> (src.max_buffered_requests ()); + + dest.max_request_buffer_size = + static_cast <ACE_UINT32> (src.max_request_buffered_size ()); + + return true; + } + + ThreadpoolWithLanesDef TPL_Handler::threadpool_with_lanes ( + const ::CIAO::DAnCE::ORS_ThreadpoolWithLanes &src) + { + ThreadpoolWithLanesDef tpl (XMLSchema::unsignedLong (src.stacksize), + XMLSchema::boolean ((src.allow_borrowing)), + XMLSchema::boolean ((src.allow_request_buffering)), + XMLSchema::unsignedLong ((src.max_buffered_requests)), + XMLSchema::unsignedLong ((src.max_request_buffer_size)) + ); + + //XMLSchema::ID <ACE_TCHAR> id = ((src.Id)); + tpl.id (src.Id.in ()); + + size_t len = src.threadpool_lanes.length (); + for (size_t i = 0; i < len; i++) + { + ThreadpoolLaneDef new_tplane ( + XMLSchema::unsignedLong (src.threadpool_lanes[i].static_threads), + XMLSchema::unsignedLong (src.threadpool_lanes[i].dynamic_threads), + XMLSchema::int_ (src.threadpool_lanes[i].lane_priority)); + + tpl.add_threadpoolLane (new_tplane); + } + + return tpl; + } + } +} diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/TPL_Handler.h b/modules/CIAO/tools/Config_Handlers/RT-CCM/TPL_Handler.h new file mode 100644 index 00000000000..6d1b3b72e98 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/TPL_Handler.h @@ -0,0 +1,48 @@ +//=============================================== +/* + * @file TPL_Handler.h + * + * @author Lucas Seibert <lseibert@dre.vanderbilt.edu> + * @author Will Otte <wotte@dre.vanderbilt.edu> + * + * $Id$ + */ +//=============================================== + +#ifndef CIAO_CONFIG_HANDLERS_TPL_HANDLER_H +#define CIAO_CONFIG_HANDLERS_TPL_HANDLER_H + +#include /**/ "ace/pre.h" + +#include "DAnCE/Deployment/CIAO_ServerResourcesC.h" + +#include "RT_CCM_Handlers_Export.h" + +namespace CIAO +{ + namespace Config_Handlers + { + class ThreadpoolWithLanesDef; + + /* + * @class TPL_Handler + * A brief Handler class for <ThreadpoolWithLanesDef> + */ + + class RT_CCM_Handlers_Export TPL_Handler + { + public: + + static bool threadpool_with_lanes ( + const ThreadpoolWithLanesDef &src, + ::CIAO::DAnCE::ORS_ThreadpoolWithLanes &dest); + + static ThreadpoolWithLanesDef threadpool_with_lanes ( + const ::CIAO::DAnCE::ORS_ThreadpoolWithLanes &src); + }; + } +} + +#include /**/ "ace/post.h" +#endif /* TPL_HANDLER_H */ + diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/TP_Handler.cpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/TP_Handler.cpp new file mode 100644 index 00000000000..3def524a0bb --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/TP_Handler.cpp @@ -0,0 +1,57 @@ +// $Id$Exp lseibert + +#include "TP_Handler.h" +#include "CIAOServerResources.hpp" + +namespace CIAO +{ + namespace Config_Handlers + { + bool TP_Handler::thread_pool (const ThreadpoolDef &src, + ::CIAO::DAnCE::ORS_Threadpool &dest) + { + dest.Id = CORBA::String_var (src.id ().c_str ()); + + dest.stacksize = + static_cast <ACE_UINT32> (src.stacksize ()); + + dest.static_threads = + static_cast <ACE_UINT32> (src.static_threads( )); + + dest.dynamic_threads = + static_cast <ACE_UINT32> (src.dynamic_threads()); + + dest.default_priority = + static_cast <ACE_INT16> (src.default_priority ()); + + dest.allow_request_buffering = src.allow_request_buffering (); + + dest.max_buffered_requests = + static_cast <ACE_UINT32> (src.max_buffered_requests ()); + + dest.max_request_buffer_size = + static_cast <ACE_UINT32> (src.max_request_buffered_size ()); + + return true; + } + + ThreadpoolDef + TP_Handler::thread_pool (const ::CIAO::DAnCE::ORS_Threadpool &src) + { + ThreadpoolDef tp (XMLSchema::unsignedLong (src.stacksize), + XMLSchema::unsignedLong (src.static_threads), + XMLSchema::unsignedLong (src.dynamic_threads), + XMLSchema::int_ (src.default_priority), + XMLSchema::boolean (src.allow_request_buffering), + XMLSchema::unsignedLong (src.max_buffered_requests), + XMLSchema::unsignedLong (src.max_request_buffer_size)); + + if (src.Id.in () == 0) + { + tp.id (src.Id.in ()); + } + + return tp; + } + } +} diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/TP_Handler.h b/modules/CIAO/tools/Config_Handlers/RT-CCM/TP_Handler.h new file mode 100644 index 00000000000..34172995405 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/TP_Handler.h @@ -0,0 +1,46 @@ +//============================================== +/* + * @file TP_Handler.h + * + * @author Lucas Seibert <lseibert@dre.vanderbilt.edu> + * @author Will Otte <wotte@dre.vanderbilt.edu> + * $Id$ + */ +//============================================== + +#ifndef CIAO_CONFIG_HANDLERS_TP_HANDLER_H +#define CIAO_CONFIG_HANDLERS_TP_HANDLER_H + +#include /**/ "ace/pre.h" + +#include "RT_CCM_Handlers_Export.h" +#include "DAnCE/Deployment/CIAO_ServerResourcesC.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +namespace CIAO +{ + namespace Config_Handlers + { + class ThreadpoolDef; + + /* + * @class TP_Handler + * A brief Handler class for <ThreadpoolDef> + */ + + class RT_CCM_Handlers_Export TP_Handler + { + public: + static bool thread_pool (const ThreadpoolDef &src, + ::CIAO::DAnCE::ORS_Threadpool &dest); + + static ThreadpoolDef thread_pool (const ::CIAO::DAnCE::ORS_Threadpool &src); + }; + } +} + +#include /**/ "ace/post.h" +#endif /* TP_HANDLER_H */ diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/input.csr b/modules/CIAO/tools/Config_Handlers/RT-CCM/input.csr new file mode 100644 index 00000000000..3a44faf9754 --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/input.csr @@ -0,0 +1,70 @@ + +<CIAO:ServerResources + xmlns:CIAO="http://www.dre.vanderbilt.edu/ServerResources" + xmlns:xmi="http://www.omg.org/XMI" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="http://www.dre.vanderbilt.edu/ServerResources CIAOServerResources.xsd"> + + <cmdline> + <arg> -ORBDebugLevel 10 -ORBEndpoint corbaloc://foo/bar</arg> + </cmdline> + + <svcconf> + <uri> + svcconf.uri + </uri> + </svcconf> + + <orbConfigs> + <resources> + <threadpool id="threadpool-1"> + <stacksize>100</stacksize> + <static_threads>50</static_threads> + <dynamic_threads>25</dynamic_threads> + <default_priority>5</default_priority> + <allow_request_buffering>true</allow_request_buffering> + <max_buffered_requests>10</max_buffered_requests> + <max_request_buffered_size>20</max_request_buffered_size> + </threadpool> + + <threadpoolWithLanes id="threadpool-2"> + <threadpoolLane> + <static_threads>50</static_threads> + <dynamic_threads>25</dynamic_threads> + <priority>36</priority> + </threadpoolLane> + <stacksize>100</stacksize> + <allow_borrowing>true</allow_borrowing> + <allow_request_buffering>true</allow_request_buffering> + <max_buffered_requests>10</max_buffered_requests> + <max_request_buffered_size>20</max_request_buffered_size> + </threadpoolWithLanes> + + <connectionBands id="cb-1"> + <band> + <low>0</low> + <high>10</high> + </band> + <band> + <low>11</low> + <high>20</high> + </band> + </connectionBands> + </resources> + + <policySet> + <priorityModel server_priority="10"> + <priority_model>SERVER_DECLARED</priority_model> + </priorityModel> + <priorityModel> + <priority_model>CLIENT_PROPAGATED</priority_model> + </priorityModel> + + <threadpool>threadpool-1</threadpool> + <threadpool>threadpool-2</threadpool> + + <priorityBandedConnection>cb-1</priorityBandedConnection> + + </policySet> + </orbConfigs> +</CIAO:ServerResources> diff --git a/modules/CIAO/tools/Config_Handlers/RT-CCM/test.cpp b/modules/CIAO/tools/Config_Handlers/RT-CCM/test.cpp new file mode 100644 index 00000000000..0476fddd6cc --- /dev/null +++ b/modules/CIAO/tools/Config_Handlers/RT-CCM/test.cpp @@ -0,0 +1,89 @@ +// $Id$ + +#include <iostream> + +#include "CIAOServerResources.hpp" +#include "SRD_Handler.h" +#include "ciao/ServerResourcesC.h" + +#include "ace/Get_Opt.h" +#include "Utils/XML_Typedefs.h" +#include "tao/ORB.h" + +static const char *input_file = "BasicSP.cdp"; + + +static int +parse_args (int argc, char *argv[]) +{ + ACE_Get_Opt get_opts (argc, argv, "i:"); + + int c; + + while ((c = get_opts ()) != -1) + switch (c) + { + case 'i': + input_file = get_opts.opt_arg (); + break; + case '?': + default: + ACE_ERROR_RETURN ((LM_ERROR, + "usage: %s " + "-i <input file> " + "\n", + argv [0]), + -1); + } + // Indicates sucessful parsing of the command-line + return 0; +} + +using namespace CIAO::Config_Handlers; + +int ACE_TMAIN (int argc, ACE_TCHAR *argv[]) +{ + + if (parse_args (argc, argv) != 0) + return 1; + + // Initialize an ORB so Any will work + CORBA::ORB_ptr orb = CORBA::ORB_init (argc, argv); + + //Create an XML_Helper for all the file work + XML_Helper the_helper; + + if (xercesc::DOMDocument *doc = the_helper.create_dom (input_file)) + { + //Read in the XSC type structure from the DOMDocument + ServerResourcesDef srd = ServerResources (doc); + + // Convert XSC to idl datatype + SRD_Handler srd_handler (&srd); + + std::cout << "Instance document import succeeded. Dumping contents to file\n"; + + CIAO::DAnCE::ServerResource *sr (srd_handler.srd_idl ()); + + SRD_Handler reverse_handler (sr); + + xercesc::DOMDocument *the_xsc (the_helper.create_dom ("CIAO:ServerResources", + "http://www.dre.vanderbilt.edu/ServerResources")); + + std::cout << "NS:" + << std::string (xercesc::XMLString::transcode (the_xsc->getDocumentElement ()->getNamespaceURI ())) << std::endl + << std::string (xercesc::XMLString::transcode (the_xsc->getDocumentElement ()->getPrefix ())) << std::endl + << std::string (xercesc::XMLString::transcode (the_xsc->getDocumentElement ()->getLocalName ())) << std::endl + << std::endl; + + ServerResources (*reverse_handler.srd_xsc (), the_xsc); + + // write out the result + the_helper.write_DOM (the_xsc, "output.srd"); + } + + std::cout << "Test completed!"; + + return 0; + +} |