source: XIOS/dev/dev_trunk_omp/src/server.hpp @ 1601

Last change on this file since 1601 was 1601, checked in by yushan, 5 years ago

branch_openmp merged with trunk r1597

  • 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: 3.1 KB
Line 
1#ifndef __SERVER_HPP__
2#define __SERVER_HPP__
3
4#include "xios_spl.hpp"
5#include "context.hpp"
6#include "context_client.hpp"
7#include "mpi.hpp"
8#include "event_scheduler.hpp"
9
10namespace xios
11{
12    class CServer
13    {
14      public:
15        static void initialize(void);
16        static void finalize(void);
17        static void eventLoop(void);
18        static void contextEventLoop(bool enableEventsProcessing=true);
19        static void listenContext(void);
20        static void listenFinalize(void);
21        static void recvContextMessage(void* buff,int count);
22        static void listenRootContext(void);
23        static void listenRootFinalize(void);
24        static void listenRootOasisEnddef(void);
25        static void listenOasisEnddef(void);
26        static void registerContext(void* buff,int count, int leaderRank=0);
27
28        static ep_lib::MPI_Comm intraComm;
29        static std::list<ep_lib::MPI_Comm> interCommLeft;           // interComm between server (primary, classical or secondary) and its client (client or primary server)
30        static std::list<ep_lib::MPI_Comm> interCommRight;          // interComm between primary server and secondary server (non-empty only for primary server pool)
31        static std::list<ep_lib::MPI_Comm> contextInterComms;  // list of context intercomms
32        static std::list<ep_lib::MPI_Comm> contextIntraComms;  // list of context intercomms (needed only in case of secondary servers)
33        static CEventScheduler* eventScheduler;
34
35        static int serverLevel ;
36
37        struct contextMessage
38        {
39          int nbRecv;
40          int leaderRank;
41        };
42
43        static bool isRoot;
44
45        static map<string,CContext*> contextList;
46        static bool finished;
47        static bool is_MPI_Initialized;
48
49      public:
50        //! Get rank of the current process in the intraComm
51        static int getRank();
52
53        //!< Get global ranks of secondary server processes
54        static vector<int>& getSecondaryServerGlobalRanks();
55
56        //! Open a file stream to write the info logs
57        static void openInfoStream(const StdString& fileName);
58        //! Write the info logs to standard output
59        static void openInfoStream();
60        //! Close the info logs file if it opens
61        static void closeInfoStream();
62
63        //! Open a file stream to write the error log
64        static void openErrorStream(const StdString& fileName);
65        //! Write the error log to standard error output
66        static void openErrorStream();
67        //! Close the error log file if it opens
68        static void closeErrorStream();
69
70      private:
71        static vector<int> sndServerGlobalRanks;  //!< Global ranks of pool leaders on the secondary server
72        static int rank_;                         //!< If (!oasis) global rank, else rank in the intraComm returned by oasis
73        static int nbContexts;                    //!< Number of contexts registered by server
74        static StdOFStream m_infoStream;
75        static StdOFStream m_errorStream;
76        static void openStream(const StdString& fileName, const StdString& ext, std::filebuf* fb);
77    };
78}
79
80#endif
Note: See TracBrowser for help on using the repository browser.