summaryrefslogtreecommitdiff
path: root/CIAO/DAnCE
diff options
context:
space:
mode:
authorAbdullah Sowayan <sowayan@users.noreply.github.com>2007-08-23 22:22:12 +0000
committerAbdullah Sowayan <sowayan@users.noreply.github.com>2007-08-23 22:22:12 +0000
commitefd2579f1af6fd75ff4d79c88e7b5ea24001d666 (patch)
tree8900d210c013428941e7792df3be4c307b512c28 /CIAO/DAnCE
parent88bfc6032f93f3edd03a976b5da7a546c599b933 (diff)
downloadATCD-efd2579f1af6fd75ff4d79c88e7b5ea24001d666.tar.gz
Thu Aug 23 22:21:16 UTC 2007 Abdullah Sowayan <abdullah.sowayan@lmco.com>
Diffstat (limited to 'CIAO/DAnCE')
-rw-r--r--CIAO/DAnCE/Deployment/CIAO_NodeApplication_CallBack.idl2
-rw-r--r--CIAO/DAnCE/NodeApplication/NodeApplication_Impl.cpp87
-rw-r--r--CIAO/DAnCE/RepositoryManager/ZIP_Wrapper.cpp22
3 files changed, 56 insertions, 55 deletions
diff --git a/CIAO/DAnCE/Deployment/CIAO_NodeApplication_CallBack.idl b/CIAO/DAnCE/Deployment/CIAO_NodeApplication_CallBack.idl
index 9398507a0ad..b68fa81bf78 100644
--- a/CIAO/DAnCE/Deployment/CIAO_NodeApplication_CallBack.idl
+++ b/CIAO/DAnCE/Deployment/CIAO_NodeApplication_CallBack.idl
@@ -18,6 +18,6 @@ module CIAO
{
Deployment::NodeApplicationManager
register_node_application (in Deployment::NodeApplication na,
- out Deployment::Properties properties);
+ out Deployment::Properties properties);
};
};
diff --git a/CIAO/DAnCE/NodeApplication/NodeApplication_Impl.cpp b/CIAO/DAnCE/NodeApplication/NodeApplication_Impl.cpp
index ab956c1821c..39c773bbee3 100644
--- a/CIAO/DAnCE/NodeApplication/NodeApplication_Impl.cpp
+++ b/CIAO/DAnCE/NodeApplication/NodeApplication_Impl.cpp
@@ -559,7 +559,7 @@ install_es (const ::CIAO::DAnCE::EventServiceDeploymentDescription & es_info)
CIAO_Event_Service_var ciao_es =
es_factory_.create (es_info.type, es_info.name.in ());
- // Set up the event channel federations
+ // Set up the event channel federations
if (es_info.type == CIAO::RTEC)
{
// Narrow the event service to CIAO_RT_Event_Service
@@ -571,48 +571,49 @@ install_es (const ::CIAO::DAnCE::EventServiceDeploymentDescription & es_info)
// Set up the event channel federations
for (CORBA::ULong j = 0; j < es_info.addr_servs.length (); ++j)
- {
- bool retv =
- ciao_rtes->create_addr_serv (
- es_info.addr_servs[j].name.in (),
- es_info.addr_servs[j].port,
- es_info.addr_servs[j].address);
-
- if (retv == false)
- {
- ACE_DEBUG ((LM_ERROR, "RTEC failed to create addr serv object\t\n"));
- throw ::Deployment::InstallationFailure ();
- }
- }
-
- for (CORBA::ULong j = 0; j < es_info.senders.length (); ++j)
- {
- bool retv =
- ciao_rtes->create_sender (
- es_info.senders[j].addr_serv_id.in ());
-
- if (retv == false)
- {
- ACE_DEBUG ((LM_ERROR, "RTEC failed to create UDP sender object\t\n"));
- throw ::Deployment::InstallationFailure ();
- }
- }
-
- for (CORBA::ULong j = 0; j < es_info.receivers.length (); ++j)
- {
- bool retv =
- ciao_rtes->create_receiver (
- es_info.receivers[j].addr_serv_id.in (),
- es_info.receivers[j].is_multicast,
- es_info.receivers[j].listen_port);
-
- if (retv == false)
- {
- ACE_DEBUG ((LM_ERROR, "RTEC failed to create UDP receiver object\t\n"));
- throw ::Deployment::InstallationFailure ();
- }
- }
+ {
+ bool retv =
+ ciao_rtes->create_addr_serv (
+ es_info.addr_servs[j].name.in (),
+ es_info.addr_servs[j].port,
+ es_info.addr_servs[j].address);
+
+ if (retv == false)
+ {
+ ACE_DEBUG ((LM_ERROR, "RTEC failed to create addr serv object\t\n"));
+ throw ::Deployment::InstallationFailure ();
+ }
+ }
+
+ for (CORBA::ULong j = 0; j < es_info.senders.length (); ++j)
+ {
+ bool retv =
+ ciao_rtes->create_sender (
+ es_info.senders[j].addr_serv_id.in ());
+
+ if (retv == false)
+ {
+ ACE_DEBUG ((LM_ERROR, "RTEC failed to create UDP sender object\t\n"));
+ throw ::Deployment::InstallationFailure ();
+ }
+ }
+
+ for (CORBA::ULong j = 0; j < es_info.receivers.length (); ++j)
+ {
+ bool retv =
+ ciao_rtes->create_receiver (
+ es_info.receivers[j].addr_serv_id.in (),
+ es_info.receivers[j].is_multicast,
+ es_info.receivers[j].listen_port);
+
+ if (retv == false)
+ {
+ ACE_DEBUG ((LM_ERROR, "RTEC failed to create UDP receiver object\t\n"));
+ throw ::Deployment::InstallationFailure ();
+ }
+ }
}
+
return ciao_es._retn ();
}
catch (const CORBA::Exception& ex)
@@ -620,10 +621,8 @@ install_es (const ::CIAO::DAnCE::EventServiceDeploymentDescription & es_info)
ex._tao_print_exception ("NodeApplication_Impl::finishLaunch\t\n");
throw ::Deployment::InstallationFailure ();
}
-
}
-
ACE_CString *
CIAO::NodeApplication_Impl::
create_connection_key (const Deployment::Connection & connection)
diff --git a/CIAO/DAnCE/RepositoryManager/ZIP_Wrapper.cpp b/CIAO/DAnCE/RepositoryManager/ZIP_Wrapper.cpp
index ae5fb0b06d6..382b11d3082 100644
--- a/CIAO/DAnCE/RepositoryManager/ZIP_Wrapper.cpp
+++ b/CIAO/DAnCE/RepositoryManager/ZIP_Wrapper.cpp
@@ -104,15 +104,17 @@ int ZIP_Wrapper::file_list_info (char* zip_name,
/* add information about current file to the list */
list.insert_tail (next);
if ((i+1)<gi.number_entry)
- {
- err = unzGoToNextFile(uf);
- if (err!=UNZ_OK)
- {
- ACE_DEBUG((LM_DEBUG,ACE_TEXT(" unzGoToNextFile failed"
- " while trying to go to next file\n"), err));
- break;
- }
- }
+ {
+ err = unzGoToNextFile(uf);
+ if (err!=UNZ_OK)
+ {
+ ACE_DEBUG((LM_DEBUG,
+ ACE_TEXT(" unzGoToNextFile failed"
+ " while trying to go to next file\n"),
+ err));
+ break;
+ }
+ }
}
unzCloseCurrentFile(uf);
return gi.number_entry;
@@ -244,7 +246,7 @@ bool ZIP_Wrapper::uncompress (char* zip_archive, char* path, bool verbose)
makethedir(filename_inzip, arch_dir);
}
/* If it is a file, we read its data and write the uncompressed
- data to the file with proper path.*/
+ data to the file with proper path.*/
else if (direc==0)
{
handlethefile(filename_inzip, uf, file_info, verbose, arch_dir);