Changeset 1761 for XIOS/dev/dev_ym/XIOS_SERVICES/src/node/context.hpp

Timestamp:

10/18/19 15:40:35 (5 years ago)

Author:

ymipsl

Message:

implementing first guess for service functionnalities.

YM

File:

• XIOS/dev/dev_ym/XIOS_SERVICES/src/node/context.hpp (modified) (8 diffs)

XIOS/dev/dev_ym/XIOS_SERVICES/src/node/context.hpp

@@ -12 +12 @@
 #include "registry.hpp"
 #include "mpi.hpp"
+#include "services_manager.hpp"
+#include "server_context.hpp"
 
 
@@ -89 +91 @@
          // Initialize server or client
          void initClient(MPI_Comm intraComm, MPI_Comm interComm, CContext* cxtServer = 0);
+         void init(CServerContext* parentServerContext, MPI_Comm intraComm, int serviceType);
+         void initClient(MPI_Comm intraComm, int serviceType);
+         
          void initServer(MPI_Comm intraComm, MPI_Comm interComm, CContext* cxtClient = 0);
+         void initServer(MPI_Comm intraComm, int serviceType );
+         void createClientInterComm(MPI_Comm interCommClient, MPI_Comm interCommServer)  ;
+         void createServerInterComm(void)  ;
+
          bool isInitialized(void);
 
@@ -96 +105 @@
          // Put sever or client into loop state
          bool checkBuffersAndListen(bool enableEventsProcessing=true);
+         bool eventLoop(bool enableEventsProcessing=true);
 
          // Finalize a context
          void finalize(void);
+         void finalize_old(void);
          bool isFinalized(void);
 
@@ -161 +172 @@
 
          const StdString& getIdServer();
+         void setIdServer(const StdString& idServer);
          const StdString& getIdServer(const int srvPoolNb);
+         std::string getContextId() {return contextId_;}
 
          // Client side: Receive and process messages
@@ -208 +221 @@
         static void ShowTree(StdOStream & out = std::clog);
         static void CleanTree(void);
+        int getServiceType(void) {return serviceType_;}
 
       public :
@@ -223 +237 @@
          virtual bool hasChild(void) const;
 
+         bool isProcessingEvent(void) {return isProcessingEvent_;}
+         bool setProcessingEvent(void) {isProcessingEvent_=true ;}
+         bool unsetProcessingEvent(void) {isProcessingEvent_=false ;}
 
       public :
@@ -252 +269 @@
          std::vector<CContextServer*> serverPrimServer;
          std::vector<CContextClient*> clientPrimServer;
+         std::vector<std::string> primServerId_;
 
          CRegistry* registryIn ;    //!< input registry which is read from file
          CRegistry* registryOut ;   //!< output registry which will be written into file at the finalize
+
+
+        MPI_Comm intraComm_ ; //! context intra communicator
 
       private:
@@ -265 +286 @@
          std::list<MPI_Comm> comms; //!< Communicators allocated internally
 
+         int serviceType_;  //!< service associated to the context
+         string contextId_ ; //!< context client id for the servers. For clients this is same as getId() 
+         bool isProcessingEvent_ ;
+         CServerContext* parentServerContext_ ;
+
       public: // Some function maybe removed in the near future
         // virtual void toBinary  (StdOStream & os) const;