]> SALOME platform Git repositories - modules/kernel.git/blob - src/SALOMESDS/SALOMESDS_DataServerManager.hxx
Salome HOME
Fix SIZEOF_INT and SIZEOF_LONG not defined when compiling manually
[modules/kernel.git] / src / SALOMESDS / SALOMESDS_DataServerManager.hxx
1 // Copyright (C) 2007-2024  CEA, EDF, OPEN CASCADE
2 //
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.
7 //
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.
12 //
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
16 //
17 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
18 //
19 // Author : Anthony GEAY (EDF R&D)
20
21 #ifndef __SALOMESDS_DATASERVERMANAGER_HXX__
22 #define __SALOMESDS_DATASERVERMANAGER_HXX__
23
24 #include "SALOMEconfig.h"
25 #include CORBA_SERVER_HEADER(SALOME_SDS)
26
27 #include "SALOMESDS_AutoRefCountPtr.hxx"
28 #include "SALOMESDS_DataScopeServer.hxx"
29 #include "SALOMESDS_RequestSwitcher.hxx"
30
31 #include "SALOMESDS_Defines.hxx"
32
33 #include <string>
34 #include <mutex>
35
36 class SALOME_NamingService_Abstract;
37
38 namespace SALOMESDS
39 {
40   class DataServerManager;
41   
42   class RequestSwitcherDSM : public RequestSwitcherBase, public virtual POA_SALOME::RequestSwitcherDSM
43   {
44   public:
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;
50   private:
51     DataServerManager *_dsm;
52   };
53   
54   class DataScopeServer;
55     
56   class SALOMESDS_EXPORT DataServerManager : public virtual POA_SALOME::DataServerManager
57   {
58   public:
59     DataServerManager(const SALOME_CPythonHelper *pyHelper, CORBA::ORB_ptr orb, PortableServer::POA_ptr poa, SALOME_NamingService_Abstract *ns = nullptr);
60     ~DataServerManager();
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);
66     //
67     SALOME::DataScopeServer_ptr createDataScope(const char *scopeName);
68     SALOME::DataScopeServer_ptr giveADataScopeCalled(const char *scopeName, CORBA::Boolean& isCreated);
69     //
70     SALOME::DataScopeServerTransaction_ptr createDataScopeTransaction(const char *scopeName);
71     SALOME::DataScopeServerTransaction_ptr giveADataScopeTransactionCalled(const char *scopeName, CORBA::Boolean& isCreated);
72     //
73     void removeDataScope(const char *scopeName);
74     void cleanScopesInNS();
75     void shutdownScopes();
76     SALOME::RequestSwitcherDSM_ptr getRequestSwitcher();
77     void holdRequests();
78     void activeRequests();
79
80   public:
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);
88   public:
89     static const char NAME_IN_NS[];
90     static const char DFT_SCOPE_NAME_IN_NS[];
91   private:
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);
96   private:
97     //! naming service object is owned
98     SALOME_NamingService_Abstract *_ns = nullptr;
99     CORBA::ORB_var _orb;
100     //! single thread poa
101     PortableServer::POA_var _poa;
102     AutoServantPtr<RequestSwitcherDSM> _rs;
103     std::mutex _mutex;
104   };
105 }
106
107 #endif