1 files changed, 155 insertions, 0 deletions
diff --git a/TAO/CIAO/tools/Config_Handlers/CIAO_Events/CIAOEvents_Handler.cpp b/TAO/CIAO/tools/Config_Handlers/CIAO_Events/CIAOEvents_Handler.cpp
new file mode 100644
index 00000000000..6c265bea2a5
--- /dev/null
+++ b/TAO/CIAO/tools/Config_Handlers/CIAO_Events/CIAOEvents_Handler.cpp
@@ -0,0 +1,155 @@
+// $Id$
+#include "Utils/XML_Helper.h"
+#include "CIAOEvents_Handler.h"
+#include "CIAOEvents.hpp"
+#include "ciao/Deployment_EventsC.h"
+
+namespace CIAO
+{
+  namespace Config_Handlers
+  {
+    CIAOEvents_Handler::CIAOEvents_Handler (const ACE_TCHAR *file) :
+      idl_esd_(0),
+      esd_(0),
+      retval_ (false)
+    {
+      XML_Helper helper;
+
+      XERCES_CPP_NAMESPACE::DOMDocument *dom =
+        helper.create_dom (file);
+
+      if (!dom)
+        throw CIAOEvents_Handler::NoESD ();
+
+      this->esd_.reset (new CIAOEventsDef
+        (CIAOEvents (dom)));
+
+      if (!this->build_esd ())
+        throw NoESD ();
+    }
+
+    CIAOEvents_Handler::CIAOEvents_Handler (CIAOEventsDef *esd):
+      idl_esd_(0),
+      esd_(esd),
+      retval_(false)
+    {
+      if(!this->build_esd())
+        throw NoESD ();
+    }
+
+
+    CIAOEvents_Handler::~CIAOEvents_Handler (void)
+    {
+    }
+
+    bool
+    CIAOEvents_Handler::build_esd ()
+    {
+      this->idl_esd_.reset ( new ::CIAO::DAnCE::EventServiceDeploymentDescriptions );
+
+
+      this->idl_esd_->length (this->esd_->count_eventServiceConfiguration ());
+      CORBA::ULong pos_i = 0;
+      for (CIAOEventsDef::eventServiceConfiguration_const_iterator i = this->esd_->begin_eventServiceConfiguration ();
+           i != this->esd_->end_eventServiceConfiguration ();
+           i++)
+      {
+           CIAO::DAnCE::EventServiceDeploymentDescription a_esd;
+
+           a_esd.name = CORBA::string_dup (i->name ().c_str ());
+           a_esd.node = CORBA::string_dup (i->node ().c_str ());
+
+           switch (i->type ().integral ())
+           {
+             case ::CIAO::Config_Handlers::EventServiceType::EC_l:
+               a_esd.type = CIAO::DAnCE::EC;
+               break;
+             case ::CIAO::Config_Handlers::EventServiceType::NOTIFY_l:
+               a_esd.type = CIAO::DAnCE::NOTIFY;
+               break;
+             case ::CIAO::Config_Handlers::EventServiceType::RTEC_l:
+               a_esd.type = CIAO::DAnCE::RTEC;
+               break;
+             case ::CIAO::Config_Handlers::EventServiceType::RTNOTIFY_l:
+               a_esd.type = CIAO::DAnCE::RTNOTIFY;
+               break;
+             default:
+             ACE_ERROR ((LM_ERROR,
+                        "Invalid event service type\n"));
+             return false;
+           }
+
+           a_esd.svc_cfg_file = CORBA::string_dup  (i->svc_cfg_file ().c_str ());
+
+
+           a_esd.filters.length (i->count_filter ());
+           CORBA::ULong pos_j = 0;
+           for (EventServiceDescription::filter_const_iterator j = i->begin_filter ();
+                j != i->end_filter ();
+                j++)
+           {
+              a_esd.filters[pos_j].name = CORBA::string_dup (j->name ().c_str ());
+              switch (j->type ().integral ())
+              {
+                  case ::CIAO::Config_Handlers::FilterType::CONJUNCTION_l:
+                    a_esd.filters[pos_j].type = CIAO::DAnCE::CONJUNCTION;
+                    break;
+                  case ::CIAO::Config_Handlers::FilterType::DISJUNCTION_l:
+                    a_esd.filters[pos_j].type = CIAO::DAnCE::DISJUNCTION;
+                    break;
+                  case ::CIAO::Config_Handlers::FilterType::LOGICAL_AND_l:
+                    a_esd.filters[pos_j].type = CIAO::DAnCE::LOGICAL_AND;
+                    break;
+                  case ::CIAO::Config_Handlers::FilterType::NEGATE_l:
+                    a_esd.filters[pos_j].type = CIAO::DAnCE::NEGATE;
+                    break;
+                    default:
+                    ACE_ERROR ((LM_ERROR,
+                              "Invalid filter type\n"));
+                  return false;
+               }
+
+               a_esd.filters[pos_j].sources.length (j->count_source ());
+               CORBA::ULong pos_k = 0;
+               for (Filter::source_const_iterator k = j->begin_source ();
+                    k != j->end_source ();
+                    k++)
+               {
+                 a_esd.filters[pos_j].sources[pos_k] = CORBA::string_dup (k->c_str ());
+                 pos_k++;
+
+               }
+               pos_j++;
+            }
+
+           (*this->idl_esd_)[pos_i] = a_esd;
+           pos_i++;
+      }
+      return true;
+    }
+
+
+    ::CIAO::DAnCE::EventServiceDeploymentDescriptions const *
+        CIAOEvents_Handler::esd_idl () const
+      throw (CIAOEvents_Handler::NoESD)
+      {
+        if(!this->idl_esd_.get())
+          throw NoESD ();
+
+         //else
+        return this->idl_esd_.get();
+      }
+
+    ::CIAO::DAnCE::EventServiceDeploymentDescriptions *
+        CIAOEvents_Handler::esd_idl ()
+      throw (CIAOEvents_Handler::NoESD)
+      {
+        if(!this->idl_esd_.get())
+          throw NoESD();
+
+        //else
+        return this->idl_esd_.release();
+      }
+   }
+}
+