diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/XML_Loader.cpp')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/XML_Loader.cpp | 234 |
1 files changed, 0 insertions, 234 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/XML_Loader.cpp b/TAO/orbsvcs/orbsvcs/Notify/XML_Loader.cpp deleted file mode 100644 index 7dd33e5deb6..00000000000 --- a/TAO/orbsvcs/orbsvcs/Notify/XML_Loader.cpp +++ /dev/null @@ -1,234 +0,0 @@ -// $Id$ - -#include "orbsvcs/Notify/XML_Loader.h" -#include "orbsvcs/Notify/Topology_Object.h" - -#include "ACEXML/common/DefaultHandler.h" -#include "ACEXML/parser/parser/Parser.h" -#include "ACEXML/common/FileCharStream.h" - -#include "ace/Containers_T.h" -#include "tao/debug.h" -#include "ace/OS_NS_unistd.h" - -//#define DEBUG_LEVEL 9 -#ifndef DEBUG_LEVEL -# define DEBUG_LEVEL TAO_debug_level -#endif //DEBUG_LEVEL - -using namespace TAO_Notify; - -TAO_BEGIN_VERSIONED_NAMESPACE_DECL - -namespace TAO_Notify { - extern const char TOPOLOGY_ID_NAME[]; -} - -TAO_END_VERSIONED_NAMESPACE_DECL - -namespace { - CORBA::Long makeNVPList (NVPList& nvp, ACEXML_Attributes* attrs) - { - CORBA::Long id = 0; - for (size_t i = 0; i < attrs->getLength (); ++i) - { - const char * name = attrs->getQName (i); - const char * value = attrs->getValue (i); - if (ACE_OS::strcmp (name, - TAO_VERSIONED_NAMESPACE_NAME::TAO_Notify::TOPOLOGY_ID_NAME) == 0) - { - id = ACE_OS::atoi (value); - } - nvp.push_back (NVP (name, value)); - } - return id; - } -} - -TAO_BEGIN_VERSIONED_NAMESPACE_DECL - -namespace TAO_Notify -{ - XML_Loader::XML_Loader () - : input_ (0) - , live_ (false) - { - } - - XML_Loader::~XML_Loader () - { - } - - bool - XML_Loader::open (const ACE_CString & base_name) - { - bool result = false; - - // if *.xml exists, use it - // if it does not exist then - // use the previous one was renamed to *.000 - // If neither *.xml nor *.000 exist then something - // "impossible" happened (or its a new system with no saved state). - - this->file_name_ = base_name; - this->file_name_ += ".xml"; - - // 4 is "read permission" - result = (0 == ACE_OS::access (this->file_name_.c_str (), 4)); - if (result) - { - this->live_ = false; - ACEXML_FileCharStream* fstm = new ACEXML_FileCharStream; - // xml input source will take ownership - - if (fstm->open (this->file_name_.c_str ()) == 0) - { - // InputSource takes ownership - ACEXML_InputSource input (fstm); - - ACEXML_Parser parser; - parser.setContentHandler (this); - parser.setDTDHandler (this); - parser.setErrorHandler (this); - parser.setEntityResolver (this); - - ACEXML_TRY_NEW_ENV - { - parser.parse (&input ACEXML_ENV_ARG_PARAMETER); - ACEXML_TRY_CHECK; - } - ACEXML_CATCH (ACEXML_Exception, ex) - { - // The only way to find out what it is, it to let it print itself, so... - ACE_ERROR ((LM_ERROR, "Unable to load \"%s\".\n Will try backup file.\n", this->file_name_.c_str ())); - ex.print (); - result = false; - } - ACEXML_ENDTRY; - } - else - { - ACE_DEBUG((LM_DEBUG, ACE_TEXT("Unable to open the XML input file: %s.\n Will try backup file.\n"), file_name_.c_str())); - result = false; - } - } - - if (! result) - { - this->file_name_ = base_name; - this->file_name_ += ".000"; - result = (0 == ACE_OS::access (this->file_name_.c_str (), 4)); - } - return result; - } - - //virtual - void - XML_Loader::load (Topology_Object *root ACE_ENV_ARG_DECL) - { - ACE_ASSERT (root != 0); - this->live_ = true; - - ACEXML_FileCharStream* fstm = new ACEXML_FileCharStream; - // xml input source will take ownership - - if (fstm->open (this->file_name_.c_str ()) == 0) - { - // InputSource takes ownership - ACEXML_InputSource input (fstm); - - ACEXML_Parser parser; - parser.setContentHandler (this); - parser.setDTDHandler (this); - parser.setErrorHandler (this); - parser.setEntityResolver (this); - - ACEXML_TRY_NEW_ENV - { - object_stack_.push (root); - parser.parse (&input ACEXML_ENV_ARG_PARAMETER); - ACEXML_TRY_CHECK; - ACE_ASSERT (object_stack_.size () == 1); - Topology_Object* cur; - object_stack_.pop (cur); - } - ACEXML_CATCH (ACEXML_Exception, ex) - { - // The only way to find out what it is, it to let it print itself, so... - ACE_ERROR ((LM_ERROR, "Unable to load \"%s\".\n", this->file_name_.c_str ())); - ex.print (); - ACE_THROW(CORBA::INTERNAL()); - } - ACEXML_ENDTRY; - } - else - { - ACE_DEBUG((LM_DEBUG, ACE_TEXT("Unable to open the XML input file: %s.\n"), file_name_.c_str())); - ACE_THROW(CORBA::INTERNAL()); - } - } - - void - XML_Loader::startElement (const ACEXML_Char*, - const ACEXML_Char*, - const ACEXML_Char* name, - ACEXML_Attributes* xml_attrs ACEXML_ENV_ARG_DECL) - ACE_THROW_SPEC ( (ACEXML_SAXException)) - { - ACE_ASSERT (name != 0); - ACE_ASSERT (xml_attrs != 0); - if (this->live_) - { - ACE_ASSERT (object_stack_.size () > 0); - Topology_Object* cur = 0; - if (object_stack_.top (cur) == 0) - { - ACE_DECLARE_NEW_ENV; - ACE_TRY - { - NVPList attrs; - CORBA::Long id = makeNVPList (attrs, xml_attrs); - - if (DEBUG_LEVEL > 5) ACE_DEBUG ((LM_INFO, - ACE_TEXT("(%P|%t) XML_Loader: Element %s\n"), - name - )); - - ACE_CString cname (name); - Topology_Object* next = cur->load_child ( - cname, id, attrs ACE_ENV_ARG_PARAMETER); - ACE_ASSERT(next != 0); - ACE_TRY_CHECK; - object_stack_.push (next); - } - ACE_CATCHANY - { - ACEXML_THROW (ACEXML_SAXException (ACE_ANY_EXCEPTION._info ().c_str ())); - } - ACE_ENDTRY; - } - } - } - - void - XML_Loader::endElement (const ACEXML_Char*, - const ACEXML_Char*, - const ACEXML_Char* name ACEXML_ENV_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ( (ACEXML_SAXException)) - { - ACE_UNUSED_ARG (name); - if (this->live_) - { - ACE_ASSERT (object_stack_.size () > 0); - if (DEBUG_LEVEL > 5) ACE_DEBUG ((LM_INFO, - ACE_TEXT("(%P|%t) XML_Loader: End Element %s\n"), - name - )); - Topology_Object* cur; - object_stack_.pop (cur); - } - } - -} /* namespace TAO_Notify */ - -TAO_END_VERSIONED_NAMESPACE_DECL |