#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)
{
}
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)
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() )
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;
}