1 // Copyright (C) 2007-2024 CEA, EDF, OPEN CASCADE
3 // This library is free software; you can redistribute it and/or
4 // modify it under the terms of the GNU Lesser General Public
5 // License as published by the Free Software Foundation; either
6 // version 2.1 of the License, or (at your option) any later version.
8 // This library is distributed in the hope that it will be useful,
9 // but WITHOUT ANY WARRANTY; without even the implied warranty of
10 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
11 // Lesser General Public License for more details.
13 // You should have received a copy of the GNU Lesser General Public
14 // License along with this library; if not, write to the Free Software
15 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
19 // Author : Anthony GEAY (EDF R&D)
21 #ifndef __SALOMESDS_DATASERVERMANAGER_HXX__
22 #define __SALOMESDS_DATASERVERMANAGER_HXX__
24 #include "SALOMEconfig.h"
25 #include CORBA_SERVER_HEADER(SALOME_SDS)
27 #include "SALOMESDS_AutoRefCountPtr.hxx"
28 #include "SALOMESDS_DataScopeServer.hxx"
29 #include "SALOMESDS_RequestSwitcher.hxx"
31 #include "SALOMESDS_Defines.hxx"
36 class SALOME_NamingService_Abstract;
40 class DataServerManager;
42 class RequestSwitcherDSM : public RequestSwitcherBase, public virtual POA_SALOME::RequestSwitcherDSM
45 RequestSwitcherDSM(CORBA::ORB_ptr orb, DataServerManager *dsm):RequestSwitcherBase(orb),_dsm(dsm) { }
46 SALOME::StringVec *listScopes();
47 SALOME::DataScopeServerTransaction_ptr giveADataScopeTransactionCalled(const char *scopeName, CORBA::Boolean& isCreated);
48 void holdRequests()override;
49 void activeRequests()override;
51 DataServerManager *_dsm;
54 class DataScopeServer;
56 class SALOMESDS_EXPORT DataServerManager : public virtual POA_SALOME::DataServerManager
59 DataServerManager(const SALOME_CPythonHelper *pyHelper, CORBA::ORB_ptr orb, PortableServer::POA_ptr poa, SALOME_NamingService_Abstract *ns = nullptr);
61 SALOME::StringVec *listScopes();
62 SALOME::StringVec *listAliveAndKickingScopes();
63 SALOME::DataScopeServer_ptr getDefaultScope();
64 CORBA::Boolean isAliveAndKicking(const char *scopeName);
65 SALOME::DataScopeServerBase_ptr retriveDataScope(const char *scopeName);
67 SALOME::DataScopeServer_ptr createDataScope(const char *scopeName);
68 SALOME::DataScopeServer_ptr giveADataScopeCalled(const char *scopeName, CORBA::Boolean& isCreated);
70 SALOME::DataScopeServerTransaction_ptr createDataScopeTransaction(const char *scopeName);
71 SALOME::DataScopeServerTransaction_ptr giveADataScopeTransactionCalled(const char *scopeName, CORBA::Boolean& isCreated);
73 void removeDataScope(const char *scopeName);
74 void cleanScopesInNS();
75 void shutdownScopes();
76 SALOME::RequestSwitcherDSM_ptr getRequestSwitcher();
78 void activeRequests();
81 CORBA::ORB_var getORB() { return _orb; }
82 static std::string CreateAbsNameInNSFromScopeName(const std::string& scopeName);
83 static CORBA::Boolean IsAliveAndKicking(SALOME::DataScopeServerBase_ptr scopePtr);
84 static SALOME::DataScopeServerBase_var GetScopePtrGivenName(const std::string& scopeName, const std::vector<std::string>& scopes, SALOME_NamingService_Abstract *ns);
85 SALOME::StringVec *listScopes_unsafe();
86 SALOME::DataScopeServerTransaction_ptr giveADataScopeTransactionCalled_unsafe(
87 const char *scopeName, CORBA::Boolean& isCreated);
89 static const char NAME_IN_NS[];
90 static const char DFT_SCOPE_NAME_IN_NS[];
92 std::vector<std::string> listOfScopesCpp();
93 SALOME::DataScopeServerBase_var getScopePtrGivenName(const std::string& scopeName);
94 CORBA::Boolean isAliveAndKicking_unsafe(const char *scopeName);
95 SALOME::DataScopeServerBase_ptr retriveDataScope_unsafe(const char *scopeName);
97 //! naming service object is owned
98 SALOME_NamingService_Abstract *_ns = nullptr;
100 //! single thread poa
101 PortableServer::POA_var _poa;
102 AutoServantPtr<RequestSwitcherDSM> _rs;