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

Timestamp:

11/05/19 16:02:34 (5 years ago)

Author:

ymipsl

Message:

Some Update on XIOS services
Seems to work on Irène for :

• first level of servers
• fisrt + second level of servers
• attached mode

YM

File:

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

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

@@ -53 +53 @@
            EVENT_ID_POST_PROCESS, EVENT_ID_SEND_REGISTRY,
            EVENT_ID_POST_PROCESS_GLOBAL_ATTRIBUTES,
-           EVENT_ID_PROCESS_GRID_ENABLED_FIELDS
+           EVENT_ID_PROCESS_GRID_ENABLED_FIELDS,
+           EVENT_ID_CONTEXT_FINALIZE_CLIENT,
          };
 
@@ -106 +107 @@
          bool checkBuffersAndListen(bool enableEventsProcessing=true);
          bool eventLoop(bool enableEventsProcessing=true);
+         void globalEventLoop(void);
 
          // Finalize a context
          void finalize(void);
+
          void finalize_old(void);
          bool isFinalized(void);
@@ -170 +173 @@
          //!< after be gathered to the root process of the context, merged registry is sent to the root process of the servers
          void sendRegistry(void) ;
+         void sendFinalizeClient(CContextClient* contextClient, const string& contextClientId);
+
 
          const StdString& getIdServer();
@@ -191 +196 @@
          static void recvRegistry(CEventServer& event) ;
          void recvRegistry(CBufferIn& buffer) ; //!< registry is received by the servers
-
+         static void recvFinalizeClient(CEventServer& event) ;
+         void recvFinalizeClient(CBufferIn& buffer);
+         
          void freeComms(void);                  //!< Free internally allcoated communicators
          void releaseClientBuffers(void);       //! Deallocate buffers allocated by clientContexts
@@ -281 +288 @@
          bool allProcessed;
          bool finalized;
-         int countChildCtx_;        //!< Counter of child contexts (for now it is the number of secondary server pools)
+         int countChildContextFinalized_;        //!< Counter of child contexts (for now it is the number of secondary server pools)
          StdString idServer_;
          CGarbageCollector garbageCollector;