source: XIOS/dev/dev_olga/src/server.hpp @ 987

Last change on this file since 987 was 987, checked in by mhnguyen, 6 years ago

First working version.
There are more things to do with it

  • 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: 2.2 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 initialize(const StdString& serverId);
17        static void finalize(void);
18        static void eventLoop(void);
19        static void contextEventLoop(void);
20        static void listenContext(void);
21        static void listenFinalize(void);
22        static void recvContextMessage(void* buff,int count);
23        static void listenRootContext(void);
24        static void listenRootFinalize(void);
25        static void registerContext(void* buff,int count, int leaderRank=0);        // context registered by the primary server
26
27        // Communicators for the primary group of servers
28        static MPI_Comm intraComm;
29        static list<MPI_Comm> interComm;
30        static std::list<MPI_Comm> contextInterComms;
31        static CEventScheduler* eventScheduler;
32
33        struct contextMessage
34        {
35          int nbRecv;
36          int leaderRank;
37        };
38
39        static bool isRoot;
40
41        static map<string,CContext*> contextList;       // contexts on the primary server
42        static bool finished;
43        static bool is_MPI_Initialized;
44
45      public:
46        //! Get rank of the current process
47        static int getRank();
48
49        //! Open a file stream to write the info logs
50        static void openInfoStream(const StdString& fileName);
51        //! Write the info logs to standard output
52        static void openInfoStream();
53        //! Close the info logs file if it opens
54        static void closeInfoStream();
55
56        //! Open a file stream to write the error log
57        static void openErrorStream(const StdString& fileName);
58        //! Write the error log to standard error output
59        static void openErrorStream();
60        //! Close the error log file if it opens
61        static void closeErrorStream();
62
63      private:
64        static int rank;
65        static StdOFStream m_infoStream;
66        static StdOFStream m_errorStream;
67
68        static void openStream(const StdString& fileName, const StdString& ext, std::filebuf* fb);
69    };
70}
71
72#endif
Note: See TracBrowser for help on using the repository browser.