YACS in SSL mode

[modules/kernel.git] / src / NamingService / SALOME_Fake_NamingService.cxx

diff --git a/src/NamingService/SALOME_Fake_NamingService.cxx b/src/NamingService/SALOME_Fake_NamingService.cxx
index f521034a2a98fa6286b21d76a520860d92532246..e9e19f30d489934edb247937cef95c1ffc612de8 100644 (file)
--- a/src/NamingService/SALOME_Fake_NamingService.cxx
+++ b/src/NamingService/SALOME_Fake_NamingService.cxx
@@ -19,14 +19,33 @@
 
 #include "SALOME_Fake_NamingService.hxx"
 #include "Utils_SALOME_Exception.hxx"
+#include "SALOME_KernelORB.hxx"
+
+#include CORBA_CLIENT_HEADER(SALOME_Component)
+
+#include <sstream>
+#include <fstream>
 
 std::mutex SALOME_Fake_NamingService::_mutex;
 std::map<std::string,CORBA::Object_var> SALOME_Fake_NamingService::_map;
+bool SALOME_Fake_NamingService::_log_container_file_thread_launched = false;
+std::string SALOME_Fake_NamingService::_log_container_file_name;
 
 SALOME_Fake_NamingService::SALOME_Fake_NamingService(CORBA::ORB_ptr orb)
 {
 }
 
+std::vector< std::string > SALOME_Fake_NamingService::repr()
+{
+  std::lock_guard<std::mutex> g(_mutex);
+  std::vector< std::string > ret;
+  for(auto it : _map)
+  {
+    ret.push_back( it.first );
+  }
+  return ret;
+}
+
 void SALOME_Fake_NamingService::init_orb(CORBA::ORB_ptr orb)
 {
 }
@@ -36,6 +55,7 @@ void SALOME_Fake_NamingService::Register(CORBA::Object_ptr ObjRef, const char* P
   std::lock_guard<std::mutex> g(_mutex);
   CORBA::Object_var ObjRefAuto = CORBA::Object::_duplicate(ObjRef);
   _map[Path] = ObjRefAuto;
+  FlushLogContainersFile_NoThreadSafe();
 }
 
 void SALOME_Fake_NamingService::Destroy_Name(const char* Path)
@@ -65,8 +85,14 @@ std::vector<std::string> SALOME_Fake_NamingService::list_directory()
   return std::vector<std::string>();
 }
 
+std::vector<std::string> SALOME_Fake_NamingService::list_directory_recurs()
+{
+  return std::vector<std::string>();
+}
+
 CORBA::Object_ptr SALOME_Fake_NamingService::Resolve(const char* Path)
 {
+  std::lock_guard<std::mutex> g(_mutex);
   std::string pathCpp(Path);
   auto it = _map.find(pathCpp);
   if( it != _map.end() )
@@ -86,5 +112,76 @@ SALOME_NamingService_Abstract *SALOME_Fake_NamingService::clone()
 
 CORBA::Object_ptr SALOME_Fake_NamingService::ResolveComponent(const char* hostname, const char* containerName, const char* componentName, const int nbproc)
 {
-  THROW_SALOME_EXCEPTION("SALOME_Fake_NamingService::ResolveComponent : " << hostname << " " << containerName << " " << componentName << " " << nbproc);
+  std::ostringstream oss;
+  oss << SEP << "Containers" << SEP << hostname << SEP << containerName << SEP << componentName;
+  std::string entryToFind(oss.str());
+  return Resolve(entryToFind.c_str());
+}
+
+std::vector< std::pair< std::string, Engines::Container_var> > SALOME_Fake_NamingService::ListOfContainersInNS_NoThreadSafe()
+{
+  std::vector< std::pair< std::string, Engines::Container_var> > ret;
+  for(auto it : _map)
+  {
+    Engines::Container_var elt = Engines::Container::_narrow(it.second);
+    if(!CORBA::is_nil(elt))
+      ret.push_back({it.first,elt});
+  }
+  return ret;
+}
+
+std::string SALOME_Fake_NamingService::ReprOfContainersIORS_NoThreadSafe()
+{
+  std::vector< std::pair< std::string, Engines::Container_var> > conts( ListOfContainersInNS_NoThreadSafe() );
+  std::ostringstream oss;
+  CORBA::ORB_ptr orb = KERNEL::getORB();
+  char SEP[2] = { '\0', '\0' };
+  constexpr char SEP2[] = " : ";
+  for(auto it : conts)
+  {
+    CORBA::String_var ior(orb->object_to_string(it.second));
+    oss << SEP << it.first << SEP2 << ior;
+    SEP[0] = '\n';
+  }
+  return oss.str();
+}
+
+std::string SALOME_Fake_NamingService::ReprOfContainersIORS()
+{
+  std::lock_guard<std::mutex> g(_mutex);
+  return ReprOfContainersIORS_NoThreadSafe();
+}
+
+std::string SALOME_Fake_NamingService::GetLogContainersFile()
+{
+  return _log_container_file_name;
+}
+
+void SALOME_Fake_NamingService::FlushLogContainersFile()
+{
+  std::lock_guard<std::mutex> g(_mutex);
+  FlushLogContainersFile_NoThreadSafe();
+}
+
+void SALOME_Fake_NamingService::FlushLogContainersFile_NoThreadSafe()
+{
+  if(!_log_container_file_name.empty())
+  {
+    std::string content( ReprOfContainersIORS_NoThreadSafe() );
+    std::ofstream ofs(_log_container_file_name);
+    ofs.write(content.c_str(),content.length());
+  }
+}
+
+void SALOME_Fake_NamingService::SetLogContainersFile(const std::string& logFileName)
+{
+  if(logFileName.empty())
+    THROW_SALOME_EXCEPTION("SALOME_Fake_NamingService::SetLogContainersFile : empty log name !");
+  constexpr char EXPT_CONTENT[] = "SALOME_Fake_NamingService::SetLogContainersFile : input logFileName write access failed ! no log file set !";
+  {
+    std::ofstream ofs(logFileName);
+    if(!ofs)
+      THROW_SALOME_EXCEPTION(EXPT_CONTENT);
+  }
+  _log_container_file_name = logFileName;
 }