Ignore:
Timestamp:
10/21/11 19:01:35 (13 years ago)
Author:
ymipsl
Message:

reprise en main de la version de H. Ozdoba. Correction de différentes erreurs de conception et bug.
Version NEMO operationnel en client/server, interoperabilita avec OASIS, reconstition de fichiers via netcdf4/HDF5

YM

File:
1 edited

Legend:

Unmodified
Added
Removed
  • XMLIO_V2/dev/common/src/xmlio/server.cpp

    r278 r286  
     1#include "xmlioserver_spl.hpp" 
    12#include "server.hpp" 
    23 
     
    1112   /// ////////////////////// Définitions ////////////////////// /// 
    1213    
    13    CServer::CServer(MPIComm comm_client_server) 
     14   CServer::CServer(MPI_Comm comm_client_server) 
    1415      : blist(comm_client_server) 
    1516   { /* Ne rien faire de plus */ }   
     
    3132   ///-------------------------------------------------------------- 
    3233 
    33    boost::shared_ptr<CServer> CServer::CreateServer(MPIComm comm_client_server) 
     34   boost::shared_ptr<CServer> CServer::CreateServer(MPI_Comm comm_client_server) 
    3435   { 
    3536      if (CServer::Server.get() == NULL) 
     
    7677            { 
    7778               case (0) : 
     79//                  std::cout<<"--> Request initialize()"<<std::endl ; 
    7880                  this->initialize(); 
    7981                  continue; 
    8082               case (1) : 
     83//                  std::cout<<"--> Request finalize()"<<std::endl ; 
    8184                  this->finalize(); 
    8285                  return; 
     
    9497            { 
    9598               case (0) : 
     99//                  std::cout<<"--> Request setContext()"<<std::endl ; 
    96100                  this->setContext(lbuffer); 
    97101                  continue; 
    98102               case (1) : 
     103//                  std::cout<<"--> Request updateCalendar()"<<std::endl ; 
    99104                  this->updateCalendar(lbuffer); 
    100105                  continue; 
    101106               case (2) : 
     107//                  std::cout<<"--> Request setTimestep()"<<std::endl ; 
    102108                  this->setTimestep(lbuffer); 
    103109                  continue; 
     
    115121            { 
    116122               case (0) : 
     123//                  std::cout<<"--> Request writeData()"<<std::endl ; 
    117124                  this->writeData(lbuffer, 4); 
    118125                  continue; 
    119126               case (1) : 
     127//                  std::cout<<"--> Request writeData()"<<std::endl ; 
    120128                  this->writeData(lbuffer, 8); 
    121129                  continue; 
     
    140148   void CServer::initialize(void) // manager 0, method 0 
    141149   { 
    142       std::cout << "initialize" << std::endl; 
    143150   } 
    144151    
     
    147154   void CServer::finalize(void) // manager 0, method 1 
    148155   { 
    149       std::cout << "finalize" << std::endl; 
    150        comm::CMPIManager::Barrier(); 
     156      boost::shared_ptr<CContext> context = 
     157         CObjectFactory::GetObject<CContext>(CObjectFactory::GetCurrentContextId()); 
     158      boost::shared_ptr<data::CDataTreatment> dtreat = context->getDataTreatment(); 
     159      dtreat->finalize() ; 
     160 
     161       comm::CMPIManager::Barrier(CMPIManager::GetCommClientServer()); 
    151162   }    
    152163 
     
    173184 
    174185      } 
    175       std::cout << "setTimestep called " << durationstr << std::endl; 
    176186      dtreat->set_timestep(date::CDuration::FromString(durationstr)); 
    177187   } 
     
    195205          
    196206      } 
    197       std::cout << "setContext called " << contextId << std::endl; 
    198207      CTreeManager::SetCurrentContextId(contextId); 
    199208   } 
     
    220229         else timestep = timestep_; 
    221230      } 
    222       std::cout << "updateCalendar called " << timestep <<std::endl; 
    223231      dtreat->update_calendar(timestep); 
    224232   } 
Note: See TracChangeset for help on using the changeset viewer.