Changeset 278

Timestamp:

09/21/11 09:42:30 (13 years ago)

Author:

hozdoba

Message:

Corrections

Location:

XMLIO_V2/dev/common/src/xmlio

Files:

• attribute_map.cpp (modified) (2 diffs)
• client.cpp (modified) (2 diffs)
• client.hpp (modified) (1 diff)
• config/context_attribute.conf (modified) (1 diff)
• data_treatment.cpp (modified) (2 diffs)
• data_treatment.hpp (modified) (4 diffs)
• exception.cpp (modified) (1 diff)
• fortran/icdata.cpp (modified) (2 diffs)
• fortran/icdate.cpp (modified) (1 diff)
• group_factory.hpp (modified) (1 diff)
• group_parser.hpp (modified) (2 diffs)
• main_server.cpp (modified) (2 diffs)
• manager/xios_manager.cpp (modified) (5 diffs)
• manager/xios_manager.hpp (modified) (2 diffs)
• node/context.cpp (modified) (3 diffs)
• node/domain.cpp (modified) (10 diffs)
• node/domain.hpp (modified) (1 diff)
• node/field.cpp (modified) (4 diffs)
• node/field.hpp (modified) (1 diff)
• node/grid.cpp (modified) (4 diffs)
• output/nc4_data_output.cpp (modified) (11 diffs)
• server.cpp (modified) (3 diffs)
• xml_node.cpp (modified) (3 diffs)
• xml_node.hpp (modified) (1 diff)
• xml_parser.cpp (modified) (3 diffs)
• xml_parser.hpp (modified) (2 diffs)

XMLIO_V2/dev/common/src/xmlio/attribute_map.cpp

@@ -96 +96 @@
                                                    it != attributes.end();
                                                    it ++)
+         {
             if ((*it).first.compare(StdString("id")) != 0 &&
                 (*it).first.compare(StdString("src"))!= 0)
@@ -102 +103 @@
                CAttributeMap::operator[]((*it).first)->fromString((*it).second);
             }
+         }
       }
       

XMLIO_V2/dev/common/src/xmlio/client.cpp

@@ -16 +16 @@
    CClient::~CClient(void)
    { 
-      this->finalize();
+      //this->finalize();
    } 
    
@@ -27 +27 @@
    boost::shared_ptr<CClient> CClient::CreateClient(MPIComm comm_client_server)
    {
-      if (CClient::Client.get() != NULL)
+      if (CClient::Client.get() == NULL)
          CClient::Client = boost::shared_ptr<CClient>(new CClient(comm_client_server));
       return (CClient::GetClient());

XMLIO_V2/dev/common/src/xmlio/client.hpp

@@ -24 +24 @@
          ~CClient(void);  
          
-      protected : 
+      public : 
       
          /// Accesseur ///

XMLIO_V2/dev/common/src/xmlio/config/context_attribute.conf

@@ -1 +1 @@
 DECLARE_ATTRIBUTE(StdString, calendar_type)
 DECLARE_ATTRIBUTE(StdString, start_date)
-
+DECLARE_ATTRIBUTE(StdString, timestep)
 DECLARE_ATTRIBUTE(StdString, output_dir)
 

XMLIO_V2/dev/common/src/xmlio/data_treatment.cpp

@@ -50 +50 @@
          // Mise à jour cÎté client
          this->currentContext->getCalendar()->setTimeStep(duration);
+         this->currentContext->timestep.setValue(duration.toString());
          std::cout << "timestep :" << duration << std::endl;
          if (CXIOSManager::GetStatus() == CXIOSManager::LOC_CLIENT)
@@ -79 +80 @@
             {
                if (field->updateDataServer(currDate, data))
+               {
                   file->getDataOutput()->writeFieldData(field);
+               }
                return;
             }

XMLIO_V2/dev/common/src/xmlio/data_treatment.hpp

@@ -47 +47 @@
 
             /// Création des sorties ///
-            template <class T> void createDataOutput(void);
+            template <class T> void createDataOutput(comm::MPIComm comm_server = CXIOSManager::Comm_Server);
 
             /// Destructeur ///
@@ -72 +72 @@
 
       template <class T>
-         void CDataTreatment::createDataOutput(void)
+         void CDataTreatment::createDataOutput(comm::MPIComm comm_server )
       {
          std::vector<boost::shared_ptr<CFile> >::const_iterator
@@ -79 +79 @@
          for (; it != end; it++)
          {
+            CXIOSManager::Comm_Server = comm_server;
             boost::shared_ptr<CFile> file = *it;
             StdString filename = (!file->name.isEmpty())
@@ -89 +90 @@
             if (!file->name_suffix.isEmpty())
                 oss << file->name_suffix.getValue();
-            if (comm::CMPIManager::GetCommSize() > 1)
-                oss << "_node" << comm::CMPIManager::GetCommRank();
-            oss << ".nc";
+            if (comm::CMPIManager::GetCommSize(comm_server) > 1)
+                     oss << "." << comm::CMPIManager::GetCommRank(comm_server);
+                 oss << ".nc";
             boost::shared_ptr<io::CDataOutput> dout(new T(oss.str(), false));
             file->initializeDataOutput(dout);

XMLIO_V2/dev/common/src/xmlio/exception.cpp

@@ -23 +23 @@
 
    CException::~CException(void)
-   { if (desc_rethrow) throw (*this); }
+   { 
+      if (desc_rethrow)
+#ifdef __XIOS_NOABORT
+        throw (*this); 
+#else
+      std::cerr << this->getMessage() << std::endl;
+      abort();
+#endif
+   }
 
    //---------------------------------------------------------------

XMLIO_V2/dev/common/src/xmlio/fortran/icdata.cpp

@@ -39 +39 @@
          CTreeManager::PrintTreeToFile(oss.str());
          oss.str("");
-
          boost::shared_ptr<CDataTreatment> dt(new CDataTreatment (context));
          context->setDataTreatment(dt);
@@ -67 +66 @@
                CMPIManager::Wait(request);  // Pas encore en mode RPC
             }
+            CXIOSManager::RunClient(false, CMPIManager::GetCommWorld());
+            CClient::CreateClient(comm_client_server);
          }
          else
          {
-            dt->createDataOutput<CNc4DataOutput>();
+            dt->createDataOutput<CNc4DataOutput>(CMPIManager::GetCommWorld());
          }
       }

XMLIO_V2/dev/common/src/xmlio/fortran/icdate.cpp

@@ -30 +30 @@
             (CObjectFactory::GetCurrentContextId());
          boost::shared_ptr<xmlioserver::data::CDataTreatment> dtreat = context->getDataTreatment();
-         dtreat->set_timestep(dur);
+         if (dtreat.get() != 0)
+         {
+            dtreat->set_timestep(dur);     
+         }
+         else
+         {
+            context->solveCalendar();
+            context->timestep.setValue(dur.toString());
+            context->getCalendar()->setTimeStep(dur);
+         }       
       }
       catch (xmlioserver::CException & exc)

XMLIO_V2/dev/common/src/xmlio/group_factory.hpp

@@ -10 +10 @@
 #include "object_factory.hpp"
 #include "group_template.hpp"
+#include "xml_parser.hpp"
 
 namespace xmlioserver

XMLIO_V2/dev/common/src/xmlio/group_parser.hpp

@@ -13 +13 @@
 
       StdString name = node.getElementName();
+      xml::THashAttributes attributes = node.getAttributes();
       if (withAttr)
+      {
          CGroupTemplate<U, V, W>::SuperClass::parse(node);
+         if (attributes.end() != attributes.find("src"))
+         {
+            StdIFStream ifs ( attributes["src"].c_str() , StdIFStream::in );
+            if (!ifs.good())
+               ERROR("CGroupTemplate<U, V, W>::parse(xml::CXMLNode & node, bool withAttr)",
+                     << "[ filename = " << attributes["src"] << " ] Bad xml stream !");
+            xml::CXMLParser::ParseInclude(ifs, *this);
+         }
+      }
 
       // PARSING POUR GESTION DES ENFANTS
-      xml::THashAttributes attributes;
       boost::shared_ptr<V> group_ptr = (this->hasId())
          ? CObjectFactory::GetObject<V>(this->getId())
@@ -61 +71 @@
                   << "\' ne peut contenir qu'un objet de type \'" << V::GetName()
                   << "\' ou de type \'" << U::GetName()
-                  << "\' !");
+                  << "\' (reçu : " << name << ") !");
 
          } while (node.goToNextElement());

XMLIO_V2/dev/common/src/xmlio/main_server.cpp

@@ -7 +7 @@
 #include "client.hpp"
 #include "server.hpp"
-
+extern "C"
+{
+   void xios_dtreatment_start(tree::CContext * context_hdl, int filetype, int comm_client_server, int comm_server);
+   void xios_set_timestep(double ts_year, double ts_month,  double ts_day,
+                          double ts_hour, double ts_minute, double ts_second);
+   void xios_write_data_k83(const char * fieldid, int fieldid_size, double * data_k8, int data_Xsize, int data_Ysize, int data_Zsize);
+   void xios_update_calendar(int step);
+}
 // Point d'entrée du programme principal
 
@@ -15 +22 @@
    {
       MPIComm comm_client, comm_client_server, comm_server;
-      comm::CMPIManager::Initialise(&argc, &argv); // < seulement en mode connecté
-      
-      CTreeManager::ParseFile  ("test/iodef_simple_test.xml");
-      CTreeManager::PrintTreeToFile("wk/def/test.xml");
-     
-      comm::CMPIManager::Finalize();               // < seulement en mode connecté
-
-      //CXIOSManager::Initialise (CXIOSManager::CLIENT_SERVER, &argc, &argv);
-      //CMPIManager::DispatchClient(true, comm_client, comm_client_server,  comm_server);
-      //CXIOSManager::RunServer("Nemo", comm_client_server, comm_server);
-      //CXIOSManager::Finalize ();
+      CXIOSManager::Initialise (CXIOSManager::CLIENT_SERVER, &argc, &argv);
+      CMPIManager::DispatchClient(true, comm_client, comm_client_server,  comm_server);
+      CXIOSManager::RunServer("Nemo", comm_client_server, comm_server);
+      CXIOSManager::Finalize ();         
    }
    catch (CException & exc)

XMLIO_V2/dev/common/src/xmlio/manager/xios_manager.cpp

@@ -27 +27 @@
       {
          if (CXIOSManager::Type != CLIENT)
+
          {
             // Finalisation de la biliothÚque MPI si nécessaire
@@ -53 +54 @@
       {
          using namespace comm;
+         CXIOSManager::Comm_Client_Server = comm_client_server;
+         CXIOSManager::Comm_Server        = comm_server;
+         CXIOSManager::Status             = LOC_SERVER;
          
          // Reconstruction de l'arborescence d'objet à l'aide des données envoyées par chacun des
@@ -67 +71 @@
          StdString main_data_tree = clientBuffer[0]->getString(0);        
          tree::CTreeManager::FromBinary(main_data_tree);
-         std::cout << "main_data_tree" << main_data_tree.size() << std::endl;
          
          // Obtention des sous-domaines clients.
@@ -156 +159 @@
          using namespace comm;
          typedef std::pair<StdString, XIOSClient> StdPairStrClient;
+         CXIOSManager::Comm_Client_Server = comm_client_server;
+         CXIOSManager::Comm_Server        = comm_client_server;
          
          CXIOSManager::ShowInformation_CS(comm_client_server);
@@ -244 +249 @@
          if (launch)
          {
-            CXIOSManager::Status  = LOC_CLIENT_SERVER;         
+            CXIOSManager::Status       = LOC_CLIENT_SERVER;    
+            CXIOSManager::Comm_Server  = comm_client;    
             (CXIOSManager::Clients.begin()->second.entry)
                (comm_client, comm_client, comm_client);

XMLIO_V2/dev/common/src/xmlio/manager/xios_manager.hpp

@@ -55 +55 @@
          static StdString  GetClientName(void);
          
-      protected :
+      public :
          
          static StdSize GetNbClient(void);
@@ -63 +63 @@
          static StdSize GetNbLocServer(const StdString & clientName = CXIOSManager::ClientName);
          
-      private :
+      public :
       
          /// Information ///

XMLIO_V2/dev/common/src/xmlio/node/context.cpp

@@ -8 +8 @@
 
 #include "calendar_type.hpp"
+#include "duration.hpp"
 
 #include "data_treatment.hpp"
@@ -82 +83 @@
                << "Impossible de définir un calendrier (un attribut est manquant).");
 
-#define DECLARE_CALENDAR(MType  , mtype)                        \
-   if (calendar_type.getValue().compare(#mtype) == 0)           \
-   {                                                            \
-      this->calendar =  boost::shared_ptr<date::CCalendar>      \
-         (new date::C##MType##Calendar(start_date.getValue())); \
-      return;                                                   \
+#define DECLARE_CALENDAR(MType  , mtype)                            \
+   if (calendar_type.getValue().compare(#mtype) == 0)               \
+   {                                                                \
+      this->calendar =  boost::shared_ptr<date::CCalendar>          \
+         (new date::C##MType##Calendar(start_date.getValue()));     \
+      if (!this->timestep.isEmpty())                                \
+       this->calendar->setTimeStep                                  \
+          (date::CDuration::FromString(this->timestep.getValue())); \
+      return;                                                       \
    }
 #include "calendar_type.conf"
@@ -103 +107 @@
 
       // PARSING POUR GESTION DES ENFANTS
-      xml::THashAttributes attributes;
+      xml::THashAttributes attributes = node.getAttributes();
+
+      if (attributes.end() != attributes.find("src"))
+      {
+         StdIFStream ifs ( attributes["src"].c_str() , StdIFStream::in );
+         if (!ifs.good())
+            ERROR("CContext::parse(xml::CXMLNode & node)",
+                  << "[ filename = " << attributes["src"] << " ] Bad xml stream !");
+         xml::CXMLParser::ParseInclude(ifs, *this);
+      }
 
       if (node.getElementName().compare(CContext::GetName()))

XMLIO_V2/dev/common/src/xmlio/node/domain.cpp

@@ -20 +20 @@
       , isChecked(false), local_mask(new CArray<int, 2>(boost::extents[0][0])), relFiles()
       , ibegin_sub(), iend_sub(), jbegin_sub(), jend_sub()
-      , ibegin_zoom_sub(), jbegin_zoom_sub()
+      , ibegin_zoom_sub(), jbegin_zoom_sub(), ni_zoom_sub(), nj_zoom_sub()
       , lonvalue_sub(), latvalue_sub()
    { /* Ne rien faire de plus */ }
@@ -28 +28 @@
       , isChecked(false), local_mask(new CArray<int, 2>(boost::extents[0][0])), relFiles()
       , ibegin_sub(), iend_sub(), jbegin_sub(), jend_sub()
-      , ibegin_zoom_sub(), jbegin_zoom_sub()
+      , ibegin_zoom_sub(), jbegin_zoom_sub(),ni_zoom_sub(), nj_zoom_sub()
       , lonvalue_sub(), latvalue_sub()
    { /* Ne rien faire de plus */ }
@@ -100 +100 @@
          this->ibegin_zoom_sub.push_back(this->zoom_ibegin_loc.getValue());
          this->jbegin_zoom_sub.push_back(this->zoom_jbegin_loc.getValue());
+         this->ni_zoom_sub.push_back(this->zoom_ni_loc.getValue());
+         this->nj_zoom_sub.push_back(this->zoom_nj_loc.getValue());
       
          this->latvalue_sub.push_back(this->latvalue.getValue());
@@ -151 +153 @@
           (nj_glo.isEmpty() || nj_glo.getValue() <= 0 ))
       {
-         abort();
          ERROR("CDomain::checkAttributes(void)",
                << "[ Id = " << this->getId() << " ] "
@@ -454 +455 @@
             for (int j = 0; j < zoom_nj_client; j++)
             {
-               (*lonvalue_temp)[i + j * zoom_ni_client] = (*lonvalue_)[(i + zoom_ibegin_client -1)+(j + zoom_jbegin_client -1)*ni.getValue()];              
-               (*latvalue_temp)[i + j * zoom_ni_client] = (*latvalue_)[(i + zoom_ibegin_client -1)+(j + zoom_jbegin_client -1)*ni.getValue()];
+               (*lonvalue_temp)[i + j * zoom_ni_client] =
+               (*lonvalue_)[(i + zoom_ibegin_client -1)+(j + zoom_jbegin_client -1)*ni.getValue()];              
+               (*latvalue_temp)[i + j * zoom_ni_client] =
+               (*latvalue_)[(i + zoom_ibegin_client -1)+(j + zoom_jbegin_client -1)*ni.getValue()];
             }
          }
@@ -488 +491 @@
       ARRAY_CREATE(latvalue_temp, double, 1, [0]);
       
-      const int ibegin_serv  = ibegin.getValue(),
-                jbegin_serv  = jbegin.getValue(),
-                zoom_ni_serv = zoom_ni_loc.getValue(),
-                zoom_nj_serv = zoom_nj_loc.getValue();
+      const int ibegin_serv     = ibegin.getValue(),
+                jbegin_serv     = jbegin.getValue(),
+                zoom_ni_serv    = zoom_ni_loc.getValue(),
+                zoom_nj_serv    = zoom_nj_loc.getValue(),
+                ibegin_zoom_srv = zoom_ibegin_loc.getValue(),
+                jbegin_zoom_srv = zoom_jbegin_loc.getValue();
                       
       /*std::cout << "Rang du serveur :" << comm::CMPIManager::GetCommRank()   << std::endl
@@ -498 +503 @@
                 << "Zoom_loc begin : " << zoom_ibegin_loc << ", " << zoom_jbegin_loc <<  std::endl
                 << "Zoom_loc size : "  << zoom_ni_loc << ", " << zoom_nj_loc <<  std::endl;*/
-      
-      
-      ARRAY(double, 1) lonvalue_ = this->lonvalue.getValue(),
-                       latvalue_ = this->latvalue.getValue();
                        
       if (this->data_dim.getValue() == 2)
       {
-         StdSize dm = zoom_ni_serv * zoom_nj_serv;
-         StdSize dn = this->ni.getValue() * this->nj.getValue();
-         
-         lonvalue_->resize(boost::extents[dn]);
-         latvalue_->resize(boost::extents[dn]);
+         StdSize dm = zoom_ni_serv * zoom_nj_serv;      
+         
          lonvalue_temp->resize(boost::extents[dm]);
          latvalue_temp->resize(boost::extents[dm]);
@@ -515 +513 @@
          for (StdSize k = 0; k < lonvalue_sub.size(); k++)
          {
-            int l = 0;
             ARRAY(double, 1) lonvalue_loc = this->lonvalue_sub[k],
                              latvalue_loc = this->latvalue_sub[k];
-            const int ibegin_loc = ibegin_sub[k], iend_loc = iend_sub[k],
-                      jbegin_loc = jbegin_sub[k], jend_loc = jend_sub[k];
+            const int zoom_ibegin_cl = ibegin_zoom_sub[k], zoom_ni_cl = ni_zoom_sub[k],
+                      zoom_jbegin_cl = jbegin_zoom_sub[k], zoom_nj_cl = nj_zoom_sub[k],
+                      ni_cl = iend_sub[k] - ibegin_sub[k] + 1;
                       
-            for (int i = ibegin_loc - ibegin_serv; i < (iend_loc - ibegin_serv + 1); i++)
+            for (int i = 0; i < zoom_ni_cl; i++)
             {
-               for (int j = jbegin_loc - jbegin_serv; j < (jend_loc - jbegin_serv + 1); j++)
+               for (int j = 0; j < zoom_nj_cl; j++)
                {
-                  (*lonvalue_)[i + j * this->ni.getValue()] = (*lonvalue_loc)[l];      // erreur        
-                  (*latvalue_)[i + j * this->ni.getValue()] = (*latvalue_loc)[l++];    // erreur
+                  int ii = i /*- (ibegin_serv - 1)*/ + (zoom_ibegin_cl - 1) - (ibegin_zoom_srv - 1);
+                  int jj = j /*- (jbegin_serv - 1)*/ + (zoom_jbegin_cl - 1) - (jbegin_zoom_srv - 1);
+                  (*lonvalue_temp)[ii + jj * zoom_ni_serv] =
+                  (*lonvalue_loc)[i + j * zoom_ni_cl];
+                  (*latvalue_temp)[ii + jj * zoom_ni_serv] = 
+                  (*latvalue_loc)[i + j * zoom_ni_cl];
                }
             }
@@ -535 +537 @@
       else
       {
-         lonvalue_->resize(boost::extents[this->ni.getValue()]);
-         latvalue_->resize(boost::extents[this->nj.getValue()]);
          lonvalue_temp->resize(boost::extents[zoom_ni_serv]);
          latvalue_temp->resize(boost::extents[zoom_nj_serv]);
@@ -542 +542 @@
          for (StdSize k = 0; k < lonvalue_sub.size(); k++)
          {
-            int l = 0;
             ARRAY(double, 1) lonvalue_loc = this->lonvalue_sub[k],
                              latvalue_loc = this->latvalue_sub[k];
-            const int ibegin_loc = ibegin_sub[k], iend_loc = iend_sub[k],
-                      jbegin_loc = jbegin_sub[k], jend_loc = jend_sub[k];
+            const int zoom_ibegin_cl = ibegin_zoom_sub[k], zoom_ni_cl = ni_zoom_sub[k],
+                      zoom_jbegin_cl = jbegin_zoom_sub[k], zoom_nj_cl = nj_zoom_sub[k];
                       
-            for (int i = ibegin_loc - ibegin_serv; i < (iend_loc - ibegin_loc + 1); i++)
-               (*lonvalue_)[i] = (*lonvalue_loc)[l++];
+            for (int i = 0; i < zoom_ni_cl; i++)
+               (*lonvalue_temp)[i /*- (ibegin_serv - 1)*/ + (zoom_ibegin_cl - 1) - (ibegin_zoom_srv - 1)] =
+               (*lonvalue_loc)[i];
                
-            for (int j = jbegin_loc - jbegin_serv; j < (jend_loc - jbegin_loc + 1); j++)
-               (*latvalue_)[j] = (*latvalue_loc)[l++];
+            for (int j = 0; j < zoom_nj_cl; j++)
+               (*latvalue_temp)[j /*- (jbegin_serv - 1)*/ + (zoom_jbegin_cl - 1) - (jbegin_zoom_srv - 1)] =
+               (*latvalue_loc)[j];
          }       
          this->lonvalue.setValue(lonvalue_temp);

XMLIO_V2/dev/common/src/xmlio/node/domain.hpp

@@ -113 +113 @@
 
          std::vector<int> ibegin_sub, iend_sub, jbegin_sub, jend_sub;
-         std::vector<int> ibegin_zoom_sub, jbegin_zoom_sub;
+         std::vector<int> ibegin_zoom_sub, jbegin_zoom_sub, ni_zoom_sub, nj_zoom_sub;
          std::vector<ARRAY(double, 1)> lonvalue_sub, latvalue_sub;
 

XMLIO_V2/dev/common/src/xmlio/node/field.cpp

@@ -47 +47 @@
 
    bool CField::updateDataServer
-      (const date::CDate & currDate, const std::deque<ARRAY(double, 1)> storedClient)
-   {
-      if ((*last_operation + freq_operation) >= currDate)
-      {
-         ARRAY_CREATE(input, double, 1, [0]);
-         this->grid->inputFieldServer(storedClient, input);
+      (const date::CDate & currDate,
+       const std::deque<ARRAY(double, 1)> storedClient)
+   {
+      const date::CDate opeDate      = *last_operation + freq_operation;
+      const date::CDate writeDate    = *last_Write     + freq_write; 
+      
+      if (opeDate <= currDate)
+      {
+         if (this->data->num_elements() != this->grid->storeIndex[0]->num_elements())
+         {
+            this->data->resize(boost::extents[this->grid->storeIndex[0] ->num_elements()]);
+         }  
+         ARRAY_CREATE(input, double, 1, [this->data->num_elements()]);
+         this->grid->inputFieldServer(storedClient, input);          
          (*this->foperation)(input);
          *last_operation = currDate;
       }
-
-      if ((*last_Write + freq_write) >= currDate)
-      {
-         *last_Write = currDate;
-         return (true);
+      if (writeDate < (currDate + freq_operation))
+      {
+         this->foperation->final();
+         this->incrementNStep();
+         *last_Write = writeDate;
+         return (true);        
       }
       return (false);
@@ -232 +241 @@
                << "Impossible de définir une opération pour le champ !");
       }
+      
+      CDuration freq_offset_ = NoneDu;
+      if (!freq_offset.isEmpty())
+      {
+         freq_offset_ = CDuration::FromString(freq_offset.getValue());
+      }
+      else
+      {
+         freq_offset.setValue(NoneDu.toString());
+      }  
 
       if (CXIOSManager::GetStatus() == CXIOSManager::LOC_SERVER)
@@ -245 +264 @@
          this->foperation     =
              boost::shared_ptr<func::CFunctor>(new CInstant(this->data));
+             
+         const CDuration toffset = this->freq_operation - freq_offset_ - _context->getCalendar()->getTimeStep(); 
+         *this->last_operation   = *this->last_operation - toffset; 
       }
       else
-      {
-         CDuration freq_offset_ = NoneDu;
-         if (!freq_offset.isEmpty())
-         {
-            freq_offset_ = CDuration::FromString(freq_offset.getValue());
-         }
-         else
-         {
-            freq_offset.setValue(NoneDu.toString());
-         }   
-                  
+      {                  
          this->freq_operation = CDuration::FromString(freq_op.getValue());
          this->freq_write     = CDuration::FromString(this->file->output_freq.getValue());
@@ -264 +276 @@
          this->last_operation = boost::shared_ptr<xmlioserver::date::CDate>
                         (new date::CDate(_context->getCalendar()->getInitDate()));
+                        
          const CDuration toffset = this->freq_operation - freq_offset_ - _context->getCalendar()->getTimeStep(); 
-         *this->last_operation  = *this->last_operation - toffset;  
+         *this->last_operation   = *this->last_operation - toffset;  
          
 #define DECLARE_FUNCTOR(MType, mtype)              \

XMLIO_V2/dev/common/src/xmlio/node/field.hpp

@@ -170 +170 @@
       {
          //std::cout << "> " << currDate << ": Operation du champs" << this->getBaseFieldId() << std::endl;
-         
          if (this->data->num_elements() != this->grid->storeIndex[0]->num_elements())
          {

XMLIO_V2/dev/common/src/xmlio/node/grid.cpp

@@ -463 +463 @@
          ARRAY(int, 1) out_j_index_cl  =  this->out_j_index[i + 1];
          ARRAY(int, 1) out_l_index_cl  =  this->out_l_index[i + 1];
-         
-         const int ibegin_cl = ibegin[i];
-         const int jbegin_cl = jbegin[i];
-         
+                 
          int ibegin_zoom_cl = ibegin[i]; //ibegin_zoom[i];
          int jbegin_zoom_cl = jbegin[i]; //jbegin_zoom[i];
@@ -480 +477 @@
             (*storeIndex_srv)[n]  = (*storeIndex_cl)[m]; // Faux mais inutile dans le cas serveur.
             (*out_i_index_srv)[n] = (*out_i_index_cl)[m] 
-                                  /*+ (ibegin_cl - 1)*/ - (ibegin_srv - 1) + (ibegin_zoom_cl - 1) - (ibegin_zoom_srv - 1); 
+                                  /*+ (ibegin_cl - 1) - (ibegin_srv - 1)*/ + (ibegin_zoom_cl - 1) - (ibegin_zoom_srv - 1);
             (*out_j_index_srv)[n] = (*out_j_index_cl)[m]
-                                  /*+ (jbegin_cl - 1)*/ - (jbegin_srv - 1) + (jbegin_zoom_cl - 1) - (jbegin_zoom_srv - 1);
+                                  /*+ (jbegin_cl - 1) - (jbegin_srv - 1)*/ + (jbegin_zoom_cl - 1) - (jbegin_zoom_srv - 1);
             (*out_l_index_srv)[n] = (*out_l_index_cl)[m];
          }
@@ -532 +529 @@
       this->out_i_index[0] = out_i_index_srv;
       this->out_j_index[0] = out_j_index_srv;
-      this->out_l_index[0] = out_l_index_srv;
-      
-      this->storeIndex.resize(1);
-      this->out_i_index.resize(1);
-      this->out_j_index.resize(1);
-      this->out_l_index.resize(1);
-      
+      this->out_l_index[0] = out_l_index_srv;      
    }
    
@@ -552 +543 @@
                 << "Les données d'un client sont manquantes !") ;
       if (storedServer.get() != NULL)
-         storedServer->resize(boost::extents[this->storeIndex.size()-1]);
+         storedServer->resize(boost::extents[this->storeIndex[0]->num_elements()]);
       else 
-         ARRAY_ASSIGN(storedServer, double, 1, [this->storeIndex.size()-1]);
+         ARRAY_ASSIGN(storedServer, double, 1, [this->storeIndex[0]->num_elements()]);
          
       for (StdSize i = 0, n = 0; i < storedClient.size(); i++)

XMLIO_V2/dev/common/src/xmlio/output/nc4_data_output.cpp

@@ -8 +8 @@
 #include "file.hpp"
 #include "calendar.hpp"
+#include "xios_manager.hpp"
+#include "context.hpp"
 
 namespace xmlioserver
@@ -75 +77 @@
          StdString lonid     = StdString("lon_").append(domid);
          StdString latid     = StdString("lat_").append(domid);
-         StdString lonid_loc = StdString("lon_").append(domid).append("_local");
-         StdString latid_loc = StdString("lat_").append(domid).append("_local");
+         StdString lonid_loc = (comm::CMPIManager::GetCommSize(CXIOSManager::Comm_Server) > 1)
+                             ? StdString("lon_").append(domid).append("_local")
+                             : lonid;
+         StdString latid_loc = (comm::CMPIManager::GetCommSize(CXIOSManager::Comm_Server) > 1)
+                             ? StdString("lat_").append(domid).append("_local")
+                             : latid;
          StdString maskid    = StdString("mask_").append(domid).append("_local");
 
@@ -84 +90 @@
          bool isCurvilinear = (domain->lonvalue.getValue()->size() == ssize);
 
-         SuperClassWriter::addDimension(lonid, domain->ni_glo.getValue());
-         SuperClassWriter::addDimension(latid, domain->nj_glo.getValue());
+         if (comm::CMPIManager::GetCommSize(CXIOSManager::Comm_Server) > 1)
+         {
+            SuperClassWriter::addDimension(lonid, domain->zoom_ni.getValue());
+            SuperClassWriter::addDimension(latid, domain->zoom_nj.getValue());
+         }
 
          if (isCurvilinear)
@@ -104 +113 @@
                SuperClassWriter::addDimension(lonid_loc, domain->zoom_ni_loc.getValue());
                SuperClassWriter::addDimension(latid_loc, domain->zoom_nj_loc.getValue());
-               this->writeLocalAttributes(domain->zoom_ibegin_loc.getValue(),
-                                          domain->zoom_ni_loc.getValue(),
-                                          domain->zoom_jbegin_loc.getValue(),
-                                          domain->zoom_nj_loc.getValue(),
-                                          domid);
+               if (comm::CMPIManager::GetCommSize(CXIOSManager::Comm_Server) > 1)
+               {
+                  this->writeLocalAttributes(domain->zoom_ibegin_loc.getValue(),
+                                             domain->zoom_ni_loc.getValue(),
+                                             domain->zoom_jbegin_loc.getValue(),
+                                             domain->zoom_nj_loc.getValue(),
+                                             domid);
+               }
+               
                if (isCurvilinear)
                {
@@ -128 +141 @@
                dim0.push_back(lonid_loc);
 
-               SuperClassWriter::addVariable(maskid, NC_INT, dim0);
-
-               this->writeMaskAttributes(maskid,
-                  domain->data_dim.getValue()/*,
-                  domain->data_ni.getValue(),
-                  domain->data_nj.getValue(),
-                  domain->data_ibegin.getValue(),
-                  domain->data_jbegin.getValue()*/);
+               if (comm::CMPIManager::GetCommSize(CXIOSManager::Comm_Server) > 1)
+               {
+                  SuperClassWriter::addVariable(maskid, NC_INT, dim0);
+
+                  this->writeMaskAttributes(maskid,
+                     domain->data_dim.getValue()/*,
+                     domain->data_ni.getValue(),
+                     domain->data_nj.getValue(),
+                     domain->data_ibegin.getValue(),
+                     domain->data_jbegin.getValue()*/);
+               }
                   
                //SuperClassWriter::setDefaultValue(maskid, &dvm);
@@ -142 +158 @@
                SuperClassWriter::writeData(domain->latvalue.getValue(), latid, true, 0);
                SuperClassWriter::writeData(domain->lonvalue.getValue(), lonid, true, 0);
-               SuperClassWriter::writeData(mask, maskid);
+               if (comm::CMPIManager::GetCommSize(CXIOSManager::Comm_Server) > 1)
+                  SuperClassWriter::writeData(mask, maskid);
                SuperClassWriter::definition_start();
 
@@ -169 +186 @@
          switch (SuperClass::type)
          {
+            case (ONE_FILE) :
             case (MULTI_FILE) :
             {
@@ -218 +236 @@
          StdString lonid     = StdString("lon_").append(domid);
          StdString latid     = StdString("lat_").append(domid);
-         StdString lonid_loc = StdString("lon_").append(domid).append("_local");
-         StdString latid_loc = StdString("lat_").append(domid).append("_local");
+         StdString lonid_loc = (comm::CMPIManager::GetCommSize(CXIOSManager::Comm_Server) > 1)
+                             ? StdString("lon_").append(domid).append("_local")
+                             : lonid;
+         StdString latid_loc = (comm::CMPIManager::GetCommSize(CXIOSManager::Comm_Server) > 1)
+                             ? StdString("lat_").append(domid).append("_local")
+                             : latid;
          StdString fieldid   = (!field->name.isEmpty())
                              ? field->name.getValue() : field->getBaseFieldReference()->getId();
@@ -376 +398 @@
                              ? field->name.getValue() 
                              : field->getBaseFieldReference()->getId();
+         boost::shared_ptr<xmlioserver::tree::CContext> context =
+            CObjectFactory::GetObject<xmlioserver::tree::CContext>
+               (CObjectFactory::GetCurrentContextId());
+                             
+         StdOStringStream oss;
+         oss << "time_" << field->operation.getValue()
+             << "_" << field->getRelFile()->output_freq.getValue();
+             
          ARRAY(double, 1) field_data = field->getData();
+         ARRAY_CREATE(time_data, double, 1, [1]);
+         (*time_data)[0] = date::Time(*field->getLastWriteDate());
          
          if (grid->hasAxis()) // 3D
@@ -383 +415 @@
             grid->outputField(field_data, field_data3D);
             SuperClassWriter::writeData(field_data3D, fieldid, true, field->getNStep()-1);
+            SuperClassWriter::writeData(time_data, oss.str(), true, field->getNStep()-1);
             
          }
@@ -390 +423 @@
             grid->outputField(field_data,  field_data2D);
             SuperClassWriter::writeData(field_data2D, fieldid, true, field->getNStep()-1);
+            SuperClassWriter::writeData(time_data, oss.str(), true, field->getNStep()-1);
          }
       }

XMLIO_V2/dev/common/src/xmlio/server.cpp

@@ -33 +33 @@
    boost::shared_ptr<CServer> CServer::CreateServer(MPIComm comm_client_server)
    {
-      if (CServer::Server.get() != NULL)
+      if (CServer::Server.get() == NULL)
          CServer::Server = boost::shared_ptr<CServer>(new CServer(comm_client_server));
       return (CServer::GetServer());
@@ -140 +140 @@
    void CServer::initialize(void) // manager 0, method 0
    {
-      // Ne rien faire de plus
+      std::cout << "initialize" << std::endl;
    }
    
@@ -147 +147 @@
    void CServer::finalize(void) // manager 0, method 1
    {
+      std::cout << "finalize" << std::endl;
        comm::CMPIManager::Barrier();
    }   

XMLIO_V2/dev/common/src/xmlio/xml_node.cpp

@@ -11 +11 @@
       CXMLNode::CXMLNode(rapidxml::xml_node<char> * const root)
          : node(root)
+         , level(0)
       { /* Ne rien faire de plus */ }
 
@@ -48 +49 @@
                else if (nextElement->type() == rapidxml::node_element)
                { 
-                  node = nextElement; 
+                  node = nextElement;
+                  level++;
                   return (!retvalue); 
                }
@@ -59 +61 @@
       {
          bool retvalue = false;
-         if (!(this->getElementName().compare(CXMLNode::RootName)))
+         if (!(this->getElementName().compare(CXMLNode::RootName)) || (level == 0))
             return (retvalue);
          node = node->parent();
+         level--;
          return (!retvalue);
       }

XMLIO_V2/dev/common/src/xmlio/xml_node.hpp

@@ -46 +46 @@
 
             rapidxml::xml_node<char> * node;
+            int level;
 
             static StdString RootName;

XMLIO_V2/dev/common/src/xmlio/xml_parser.cpp

@@ -1 +1 @@
 #include "xml_parser.hpp"
+
+#include "context.hpp"
 
 #include "attribute_template_impl.hpp"
@@ -12 +14 @@
 
       void CXMLParser::ParseFile(const StdString & filename)
-      { StdIFStream ifs ( filename.c_str() , StdIFStream::in );
-        CXMLParser::ParseStream(ifs); }
+      {
+         StdIFStream ifs ( filename.c_str() , StdIFStream::in );
+         CXMLParser::ParseStream(ifs);
+      }
 
       void CXMLParser::ParseString(const StdString & xmlContent)
@@ -86 +90 @@
          }
       }
+
    }// namespace xml
 } // namespace xmlioserver

XMLIO_V2/dev/common/src/xmlio/xml_parser.hpp

@@ -4 +4 @@
 /// xmlioserver headers ///
 #include "xmlioserver_spl.hpp"
+#include "exception.hpp"
 #include "xml_node.hpp"
-#include "context.hpp"
+
 
 namespace xmlioserver
@@ -19 +20 @@
             static void ParseString(const StdString & xmlContent);
             static void ParseStream(StdIStream & stream);
+            template <class T>
+               static inline void ParseInclude(StdIStream & stream, T & object);
 
       }; //class CXMLParser
+
+      template <class T>
+         void CXMLParser::ParseInclude(StdIStream & stream, T& object)
+      {
+         StdOStringStream oss;
+         while(!stream.eof() && !stream.fail ())
+            oss.put(stream.get());
+         try
+         {
+            const StdString xmlcontent( oss.str(), 0, oss.str().size()-1 );
+            rapidxml::xml_document<char> doc;
+            doc.parse<0>(const_cast<char*>(xmlcontent.c_str()));
+            CXMLNode node(doc.first_node());
+            object.parse(node);
+         }
+         catch (rapidxml::parse_error & exc)
+         {
+            ERROR("CXMLParser::ParseStream(StdIStream & stream)",
+                  << "RapidXML error : " << exc.what() << " !");
+         }
+      }
 
    }// namespace xml