source: XIOS3/trunk/src/cxios.hpp @ 2547

Last change on this file since 2547 was 2547, checked in by ymipsl, 9 months ago

Major update :

  • New method to lock and unlock one-sided windows (window_dynamic) to avoid network overhead
  • Introducing multithreading on server sided to manage more efficiently dead-lock occuring (similar to co-routine which will be available and implemented in futur c++ standard), based on c++ threads
  • Suprression of old "attached mode" which is replaced by online writer and reder filters

YM
  • Property copyright set to
    Software name : XIOS (Xml I/O Server)
    http://forge.ipsl.jussieu.fr/ioserver
    Creation date : January 2009
    Licence : CeCCIL version2
    see license file in root directory : Licence_CeCILL_V2-en.txt
    or http://www.cecill.info/licences/Licence_CeCILL_V2-en.html
    Holder : CEA/LSCE (Laboratoire des Sciences du CLimat et de l'Environnement)
    CNRS/IPSL (Institut Pierre Simon Laplace)
    Project Manager : Yann Meurdesoif
    yann.meurdesoif@cea.fr
File size: 6.2 KB
Line 
1#ifndef __XIOS_HPP__
2#define __XIOS_HPP__
3
4#include "xios_spl.hpp"
5#include "mpi.hpp"
6#include "registry.hpp"
7#include "ressources_manager.hpp"
8#include "services_manager.hpp"
9#include "contexts_manager.hpp"
10#include "daemons_manager.hpp"
11#include "coupler_manager.hpp"
12#include "registry_manager.hpp"
13#include "thread_manager.hpp"
14#include "mpi_garbage_collector.hpp"
15
16namespace xios
17{
18  /*!
19  \class CXios
20  */
21  class CXios
22  {
23    public:
24     static void initialize(void) ;
25     static void initClientSide(const string & codeId, MPI_Comm& localComm, MPI_Comm& returnComm) ;
26     static void initServerSide(void) ;
27     static void clientFinalize(void) ;
28     static void parseFile(const string& filename) ;
29
30     template <typename T>
31     static T getin(const string& id,const T& defaultValue) ;
32
33     template <typename T>
34     static T getin(const string& id) ;
35
36    public:
37     static string rootFile ; //!< Configuration filename
38     static string xiosCodeId ; //!< Identity for XIOS
39     static string clientFile;        //!< Filename template for client
40     static string serverFile;        //!< Filename template for server
41     static string serverPrmFile;  //!< Filename template for primary server in case of two server levels
42     static string serverSndFile;  //!< Filename template for secondary server in case of two server levels
43
44     static bool xiosStack;    //!< Exception handling
45     static bool systemStack;  //!< Exception handling
46
47     static bool isClient ; //!< Check if xios is client
48     static bool isServer ; //!< Check if xios is server
49
50     static MPI_Comm globalComm ; //!< Global communicator
51     static MPI_Comm xiosComm ; //!< Global communicator
52
53     static bool printLogs2Files; //!< Printing out logs into files
54     static bool usingOasis ;     //!< Using Oasis
55     static bool usingServer ;    //!< Using server (server mode)
56     static bool usingServer2 ;   //!< Using secondary server (server mode). IMPORTANT: Use this variable ONLY in CServer::initialize().
57     static int ratioServer2 ;    //!< Percentage of server processors dedicated to secondary server
58     static int nbPoolsServer2 ;  //!< Number of pools created on the secondary server
59     static double bufferSizeFactor; //!< Factor used to tune the buffer size
60     static const double defaultBufferSizeFactor; //!< Default factor value
61     static StdSize minBufferSize; //!< Minimum buffer size
62     static StdSize maxBufferSize; //!< Maximum buffer size
63     static bool isOptPerformance; //!< Check if buffer size is for performance (as large as possible)
64     static CRegistry* globalRegistry ; //!< global registry which is wrote by the root process of the servers
65     static double recvFieldTimeout; //!< Time to wait for data before issuing an error when receiving a field
66     static bool checkEventSync; //!< For debuuging, check if event are coherent and synchrone on client side
67
68     static bool checkSumSend; //!< For debugging, compute a checksum of fields sent by the model to the XIOS client (very expensive !)
69     static bool checkSumRecv; //!< For debugging, compute a checksum of fields received by the model through the XIOS client
70
71     static bool logMemory; //!< Activate memory monitoring for all XIOS process (generate CSV file for https://forge.ipsl.jussieu.fr/ioserver/chrome/site/XIOS_TOOLS/xios_memory.html)
72     static bool reportMemory; //!< Activate memory reporting for all XIOS process (report in log files)
73
74     static const string defaultPoolId ;
75     static const string defaultServerId ;
76     static const string defaultGathererId ;
77     static const string defaultWriterId ;
78     static const string defaultReaderId ;
79     static const string defaultServicesId ;
80
81     static CRegistryManager* registryManager_ ;
82     static CRessourcesManager* ressourcesManager_ ;
83     static CCouplerManager* couplerManager_ ;
84     static CServicesManager* servicesManager_ ;
85     static CContextsManager* contextsManager_ ;
86     static CDaemonsManager* daemonsManager_ ;
87     static CMpiGarbageCollector MpiGarbageCollector_  ;
88    public:
89     static CMpiGarbageCollector& getMpiGarbageCollector(void) { return MpiGarbageCollector_ ; }
90    public:
91     //! Setting xios to use server mode
92     static void setUsingServer();
93
94     //! Setting xios NOT to use server mode
95     static void setNotUsingServer();
96     
97     //! is using server mode
98     static bool isUsingServer() {return usingServer;}
99
100     //! Initialize server (if any)
101     static  void initServer();
102
103     static void launchServicesManager( bool isXiosServer) ;
104     static void launchContextsManager(bool isXiosServer) ;
105     static void launchDaemonsManager(bool isXiosServer) ;
106     static void launchRessourcesManager(bool isXiosServer) ;
107     static void launchCouplerManager(bool isXiosServer) ;
108     static void launchRegistryManager(bool isXiosServer) ;
109     static void launchThreadManager(bool isXiosServer) ;
110   
111     static void finalizeServicesManager() ;
112     static void finalizeContextsManager() ;
113     static void finalizeDaemonsManager() ;
114     static void finalizeRessourcesManager() ;
115     static void finalizeCouplerManager() ;
116     static void finalizeRegistryManager() ;
117     static void finalizeThreadManager() ;
118
119     static CRegistryManager*   getRegistryManager(void) { return registryManager_ ;}
120     static CRessourcesManager* getRessourcesManager(void) { return ressourcesManager_ ;}
121     static CCouplerManager*    getCouplerManager(void) { return couplerManager_ ;}
122     static CServicesManager*   getServicesManager(void) { return servicesManager_ ;}
123     static CContextsManager*   getContextsManager(void) { return contextsManager_ ;}
124     static CDaemonsManager*    getDaemonsManager(void) { return daemonsManager_ ;}
125     static CPoolRessource*     getPoolRessource(void) ;
126     
127     static MPI_Comm getGlobalComm(void) { return globalComm ;}
128     static MPI_Comm getXiosComm(void) { return xiosComm ;}
129     static void setXiosComm(MPI_Comm comm) { xiosComm=comm ;}
130     static CRegistry* getGlobalRegistry(void) { return globalRegistry ;}
131     static void setGlobalRegistry(CRegistry* registry) { globalRegistry=registry ;}
132
133    private:
134      //! Parse only Xios part of configuration file
135      static void parseXiosConfig();
136  } ;
137}
138
139//#include "cxios_impl.hpp"
140#endif // __XIOS_HPP__
Note: See TracBrowser for help on using the repository browser.