summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorWilliam R. Otte <wotte@dre.vanderbilt.edu>2010-08-29 15:36:01 +0000
committerWilliam R. Otte <wotte@dre.vanderbilt.edu>2010-08-29 15:36:01 +0000
commit4c9f0887d7ee33043584fb86c9dc0b20e915d65f (patch)
treef45f0f2fdda400dd967fa86071c1d6c2eff1f023
parent0375e5c09b2484918d54fdfddca54acf4c9b7b5e (diff)
downloadATCD-4c9f0887d7ee33043584fb86c9dc0b20e915d65f.tar.gz
Sun Aug 29 15:34:43 UTC 2010 William R. Otte <wotte@dre.vanderbilt.edu>
* DAnCE/LocalityManager/Handler/LocalityActivator_Impl.cpp: * DAnCE/NodeApplicationManager/NodeApplicationManager_Impl.cpp: * DAnCE/NodeManager/NodeManager_Impl.cpp: Bugfixes for localityconfiguration command line option. * DAnCE/tools/System_Health/Interceptors/SHS_CORBA_Transport.cpp: * DAnCE/tools/System_Health/Interceptors/SHS_Interceptor.mpc: Bugfixes. * examples/Hello/descriptors/run_test_shs.pl: * examples/Hello/descriptors/shs.localityconfig: Modified test to load SHS interceptor from localityconfig file.
-rw-r--r--CIAO/ChangeLog18
-rw-r--r--CIAO/DAnCE/LocalityManager/Handler/LocalityActivator_Impl.cpp30
-rw-r--r--CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_Impl.cpp15
-rw-r--r--CIAO/DAnCE/NodeManager/NodeManager_Impl.cpp2
-rw-r--r--CIAO/DAnCE/tools/System_Health/Interceptors/SHS_CORBA_Transport.cpp30
-rw-r--r--CIAO/DAnCE/tools/System_Health/Interceptors/SHS_Interceptor.mpc2
-rwxr-xr-xCIAO/examples/Hello/descriptors/run_test_shs.pl2
-rw-r--r--CIAO/examples/Hello/descriptors/shs.localityconfig7
8 files changed, 71 insertions, 35 deletions
diff --git a/CIAO/ChangeLog b/CIAO/ChangeLog
index 27e5e8799e0..f69f423baba 100644
--- a/CIAO/ChangeLog
+++ b/CIAO/ChangeLog
@@ -1,3 +1,21 @@
+Sun Aug 29 15:34:43 UTC 2010 William R. Otte <wotte@dre.vanderbilt.edu>
+
+ * DAnCE/LocalityManager/Handler/LocalityActivator_Impl.cpp:
+ * DAnCE/NodeApplicationManager/NodeApplicationManager_Impl.cpp:
+ * DAnCE/NodeManager/NodeManager_Impl.cpp:
+
+ Bugfixes for localityconfiguration command line option.
+
+ * DAnCE/tools/System_Health/Interceptors/SHS_CORBA_Transport.cpp:
+ * DAnCE/tools/System_Health/Interceptors/SHS_Interceptor.mpc:
+
+ Bugfixes.
+
+ * examples/Hello/descriptors/run_test_shs.pl:
+ * examples/Hello/descriptors/shs.localityconfig:
+
+ Modified test to load SHS interceptor from localityconfig file.
+
Sat Aug 28 21:03:06 UTC 2010 William R. Otte <wotte@dre.vanderbilt.edu>
* DAnCE/DAnCE/DAnCE_Properties.idl:
diff --git a/CIAO/DAnCE/LocalityManager/Handler/LocalityActivator_Impl.cpp b/CIAO/DAnCE/LocalityManager/Handler/LocalityActivator_Impl.cpp
index 49c0584fb69..a32f1181de6 100644
--- a/CIAO/DAnCE/LocalityManager/Handler/LocalityActivator_Impl.cpp
+++ b/CIAO/DAnCE/LocalityManager/Handler/LocalityActivator_Impl.cpp
@@ -327,35 +327,7 @@ namespace DAnCE
ACE_TEXT ("DAnCE_LocalityActivator_i::construct_command_line - ")
ACE_TEXT ("Adding provided locality configuration file %C\n"), args));
- cmd_options += ' ';
- cmd_options += args;
- cmd_options += ' ';
- }
-
- if (server.cmap_->find (DAnCE::DANCE_LM_CONFIGFILE, val) == 0)
- {
- const char *args = 0;
- val >>= args;
-
- DANCE_DEBUG (9, (LM_TRACE, DLINFO
- ACE_TEXT ("DAnCE_LocalityActivator_i::construct_command_line - ")
- ACE_TEXT ("Adding provided locality configuration file %C\n"), args));
-
- cmd_options += ' ';
- cmd_options += args;
- cmd_options += ' ';
- }
-
- if (server.cmap_->find (DAnCE::DANCE_LM_CONFIGFILE, val) == 0)
- {
- const char *args = 0;
- val >>= args;
-
- DANCE_DEBUG (9, (LM_TRACE, DLINFO
- ACE_TEXT ("DAnCE_LocalityActivator_i::construct_command_line - ")
- ACE_TEXT ("Adding provided locality configuration file %C\n"), args));
-
- cmd_options += ' ';
+ cmd_options += " --plugin-config ";
cmd_options += args;
cmd_options += ' ';
}
diff --git a/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_Impl.cpp b/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_Impl.cpp
index 9d76f33dd6d..3fbca976327 100644
--- a/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_Impl.cpp
+++ b/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_Impl.cpp
@@ -248,8 +248,19 @@ NodeApplicationManager_Impl::preparePlan (const Deployment::DeploymentPlan& plan
new_path.c_str ());
#endif
}
-
- // Need to add naming service reference to config properties.
+
+ const char *config_file;
+
+ if (DAnCE::Utility::get_property_value (DAnCE::DANCE_LM_CONFIGFILE,
+ this->properties_,
+ config_file))
+ {
+ DAnCE::Utility::update_property_value<const char *> (DAnCE::DANCE_LM_CONFIGFILE,
+ lm_idd.configProperty,
+ config_file);
+ }
+
+
DAnCE::Utility::update_property_value<CosNaming::NamingContext_ptr> (
DAnCE::LOCALITY_NAMINGCONTEXT,
lm_idd.configProperty,
diff --git a/CIAO/DAnCE/NodeManager/NodeManager_Impl.cpp b/CIAO/DAnCE/NodeManager/NodeManager_Impl.cpp
index e99e09d5a6c..253a63fd739 100644
--- a/CIAO/DAnCE/NodeManager/NodeManager_Impl.cpp
+++ b/CIAO/DAnCE/NodeManager/NodeManager_Impl.cpp
@@ -41,6 +41,8 @@ namespace DAnCE
::Deployment::Properties prop;
::DAnCE::Utility::build_property_sequence (prop, properties);
PLUGIN_MANAGER::instance ()->set_configuration (prop);
+ PLUGIN_MANAGER::instance ()->set_orb (this->orb_);
+
Plugin_Manager::IH_DEPS deps;
CORBA::String_var safe_type =
PLUGIN_MANAGER::instance ()->register_installation_handler (ACE_TEXT_CHAR_TO_TCHAR ("DAnCE_Locality_Handler"),
diff --git a/CIAO/DAnCE/tools/System_Health/Interceptors/SHS_CORBA_Transport.cpp b/CIAO/DAnCE/tools/System_Health/Interceptors/SHS_CORBA_Transport.cpp
index e1ea8c7e32c..f648259581f 100644
--- a/CIAO/DAnCE/tools/System_Health/Interceptors/SHS_CORBA_Transport.cpp
+++ b/CIAO/DAnCE/tools/System_Health/Interceptors/SHS_CORBA_Transport.cpp
@@ -4,6 +4,7 @@
#include "orbsvcs/CosNamingC.h"
#include "DAnCE/DAnCE_PropertiesC.h"
#include "DAnCE/Logger/Log_Macros.h"
+#include "LocalityManager/Scheduler/Plugin_Manager.h"
namespace DAnCE
{
@@ -24,15 +25,40 @@ namespace DAnCE
for (CORBA::ULong i = 0; i < props.length (); ++i)
{
+ DANCE_DEBUG (10, (LM_TRACE, DLINFO
+ ACE_TEXT ("SHS_CORBA_Transport::configure - ")
+ ACE_TEXT ("Considering property <%C>\n"),
+ props[i].name.in ()));
+
if ((ACE_OS::strcmp (props[i].name.in (),
DAnCE::LOCALITY_NAMINGCONTEXT) == 0) ||
(ACE_OS::strcmp (props[i].name.in (),
DAnCE::INSTANCE_NC) == 0))
{
+ DANCE_DEBUG (7, (LM_DEBUG, DLINFO
+ ACE_TEXT ("SHS_CORBA_Transport::configure - ")
+ ACE_TEXT ("Found property <%C>\n"),
+ props[i].name.in ()));
+
CORBA::Object_var obj;
- props[i].value >>= CORBA::Any::to_object (obj);
- CORBA::is_nil (obj);
+ if (!(props[i].value >>= CORBA::Any::to_object (obj)))
+ {
+ const char *val;
+ props[i].value >>= CORBA::Any::to_string (val, 0);
+
+ CORBA::ORB_var orb = PLUGIN_MANAGER::instance ()->get_orb ();
+ obj = orb->string_to_object (val);
+ }
+
+ if (CORBA::is_nil (obj))
+ {
+ DANCE_ERROR (3, (LM_NOTICE, DLINFO
+ ACE_TEXT ("Unable to extract an object reference from ")
+ ACE_TEXT ("property <%C>\n"),
+ props[i].name.in ()));
+ return;
+ }
ctx = CosNaming::NamingContext::_narrow (obj.in ());
break;
diff --git a/CIAO/DAnCE/tools/System_Health/Interceptors/SHS_Interceptor.mpc b/CIAO/DAnCE/tools/System_Health/Interceptors/SHS_Interceptor.mpc
index d234e421abc..b8a0c931694 100644
--- a/CIAO/DAnCE/tools/System_Health/Interceptors/SHS_Interceptor.mpc
+++ b/CIAO/DAnCE/tools/System_Health/Interceptors/SHS_Interceptor.mpc
@@ -1,7 +1,7 @@
// $Id$
project (DAnCE_SHS_CORBA_Transport) : dance_lib, dance_output, dance_logger, \
- dance_shs_daemon, naming {
+ dance_shs_daemon, naming, dance_deployment_scheduler {
dynamicflags += DANCE_SHS_CORBA_TRANSPORT_BUILD_DLL
diff --git a/CIAO/examples/Hello/descriptors/run_test_shs.pl b/CIAO/examples/Hello/descriptors/run_test_shs.pl
index 0d714d40c3a..9dedca9c3dc 100755
--- a/CIAO/examples/Hello/descriptors/run_test_shs.pl
+++ b/CIAO/examples/Hello/descriptors/run_test_shs.pl
@@ -133,7 +133,7 @@ sub run_node_daemons {
$node_app = $tg_daemons[$i]->GetArchDir("$DANCE_ROOT/bin/") . "dance_locality_manager";
$d_cmd = "$DANCE_ROOT/bin/dance_node_manager";
- $d_param = "-ORBEndpoint $iiop -s $node_app -n $nodename=$iorfile -t 30 --instance-nc corbaloc:rir:/NameService";
+ $d_param = "-ORBEndpoint $iiop -s $node_app -n $nodename=$iorfile -t 30 --instance-nc corbaloc:rir:/NameService --locality-config shs.localityconfig";
print "Run dance_node_manager with $d_param\n";
diff --git a/CIAO/examples/Hello/descriptors/shs.localityconfig b/CIAO/examples/Hello/descriptors/shs.localityconfig
new file mode 100644
index 00000000000..dd6ba826aba
--- /dev/null
+++ b/CIAO/examples/Hello/descriptors/shs.localityconfig
@@ -0,0 +1,7 @@
+edu.vanderbilt.dre.DAnCE.InstanceHandler CIAO_Deployment_Handlers create_Container_Handler
+edu.vanderbilt.dre.DAnCE.InstanceHandler CIAO_Deployment_Handlers create_Home_Handler
+edu.vanderbilt.dre.DAnCE.InstanceHandler CIAO_Deployment_Handlers create_Component_Handler
+edu.vanderbilt.dre.DAnCE.InstanceHandler CIAO_Deployment_Handlers create_Homed_Component_Handler
+edu.vanderbilt.dre.DAnCE.DeploymentInterceptor CIAO_Deployment_Interceptors create_CIAO_StoreReferences
+edu.vanderbilt.dre.DAnCE.DeploymentInterceptor DAnCE_SHS_Interceptors create_DAnCE_SHS_Interceptor
+edu.vanderbilt.dre.DAnCE.DeploymentInterceptor DAnCE_Error_Interceptors create_DAnCE_Standard_Error