Thu Nov 18 12:39:59 2004 Ciju John <john_c@ociweb.com>

Fri Oct 29 10:53:56 2004  Dale Wilson  <wilson_d@ociweb.com>
Wed Oct 27 11:59:01 2004  Dale Wilson  <wilson_d@ociweb.com>
Mon Oct 25 20:41:00 2004  Dale Wilson  <wilson_d@ociweb.com>
Mon Oct 25 14:51:09 2004  Dale Wilson  <wilson_d@ociweb.com>
Wed Oct 20 11:38:11 2004  Dale Wilson  <wilson_d@ociweb.com>
Tue Oct 19 10:43:28 2004  Dale Wilson  <wilson_d@ociweb.com>
Mon Oct 18 15:21:49 2004  Dale Wilson  <wilson_d@ociweb.com>
Mon Oct 18 10:29:48 2004  Dale Wilson  <wilson_d@ociweb.com>
Mon Oct 18 10:11:47 2004  Dale Wilson  <wilson_d@ociweb.com>
Tue Oct 12 14:10:43 2004  Dale Wilson  <wilson_d@ociweb.com>
Mon Oct 11 14:39:15 2004  Dale Wilson  <wilson_d@ociweb.com>
Thu Oct  7 09:40:51 2004  Dale Wilson  <wilson_d@ociweb.com>
Mon Oct 18 13:02:11 2004  Dale Wilson  <wilson_d@ociweb.com>
ed Oct 13 15:44:58 2004  Dale Wilson  <wilson_d@ociweb.com>

1 files changed, 228 insertions, 0 deletions

diff --git a/TAO/orbsvcs/orbsvcs/Notify/XML_Loader.cpp b/TAO/orbsvcs/orbsvcs/Notify/XML_Loader.cpp
new file mode 100644
index 00000000000..3e32458b1e3
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/Notify/XML_Loader.cpp
@@ -0,0 +1,228 @@
+// $Id$
+
+#include "XML_Loader.h"
+#include "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;
+
+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, TOPOLOGY_ID_NAME) == 0)
+      {
+        id = ACE_OS::atoi (value);
+      }
+      nvp.push_back (NVP (name, value));
+    }
+    return id;
+  }
+}
+
+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, "Error during load of \"%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, "Error during load of \"%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;
+      if (object_stack_.top (cur) == 0)
+      {
+        ACE_TRY_NEW_ENV
+        {
+          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 */
+
+#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
+template class ACE_Unbounded_Stack<TAO_Notify::Topology_Object*>;
+template class ACE_Node<TAO_Notify::Topology_Object*>;
+#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
+#pragma instantiate ACE_Unbounded_Stack<TAO_Notify::Topology_Object*>
+#pragma instantiate ACE_Node<TAO_Notify::Topology_Object*>
+#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */