Changeset 1056 for XIOS/dev


Ignore:
Timestamp:
02/21/17 08:40:09 (7 years ago)
Author:
yushan
Message:

one file mode OK. Tested with test_client

Location:
XIOS/dev/branch_yushan
Files:
15 edited

Legend:

Unmodified
Added
Removed

  • XIOS/dev/branch_yushan/extern/src_ep_dev/ep_fortran.cpp

    r1053 r1056  
    3232    { 
    3333      fc_comm_map.insert(std::make_pair( std::make_pair( fint, omp_get_thread_num()) , comm)); 
    34       printf("MAP insert: %d, %d, %p\n", fint, omp_get_thread_num(), &comm); 
     34      printf("EP_Comm_c2f : MAP insert: %d, %d, %p\n", fint, omp_get_thread_num(), &comm); 
    3535    } 
    3636     
    … …  
    5252      MPI_Comm comm_ptr; 
    5353      comm_ptr =  it->second; 
    54       printf("MAP find: %d, %d, %p\n", it->first.first, it->first.second, &comm_ptr); 
     54      printf("EP_Comm_f2c : MAP find: %d, %d, %p\n", it->first.first, it->first.second, &comm_ptr); 
    5555      return  comm_ptr; 
    5656    } 

  • XIOS/dev/branch_yushan/extern/src_ep_dev/ep_gatherv.cpp

    r1053 r1056  
    323323  { 
    324324   
    325      
    326      
    327  
    328325    if(!comm.is_ep && comm.mpi_comm) 
    329326    { 
    … …  
    350347    mpi_size = comm.ep_comm_ptr->size_rank_info[2].second; 
    351348     
     349    if(ep_rank != root) 
     350    { 
     351      recvcounts = new int[ep_size]; 
     352      displs = new int[ep_size]; 
     353    } 
     354     
    352355    MPI_Bcast(const_cast< int* >(recvcounts), ep_size, MPI_INT, root, comm); 
    353356    MPI_Bcast(const_cast< int* >(displs), ep_size, MPI_INT, root, comm); 
    … …  
    441444        delete[] static_cast<char*>(local_gather_recvbuf); 
    442445      } 
     446    } 
     447    else 
     448    { 
     449      delete[] recvcounts; 
     450      delete[] displs; 
    443451    } 
    444452    return 0; 

  • XIOS/dev/branch_yushan/extern/src_ep_dev/ep_scatterv.cpp

    r1053 r1056  
    318318    num_ep = comm.ep_comm_ptr->size_rank_info[1].second; 
    319319    mpi_size = comm.ep_comm_ptr->size_rank_info[2].second; 
     320 
     321    if(ep_rank != root) 
     322    { 
     323      sendcounts = new int[ep_size]; 
     324      displs = new int[ep_size]; 
     325    } 
    320326     
    321327    MPI_Bcast(const_cast<int*>(sendcounts), ep_size, MPI_INT, root, comm); 
    … …  
    414420      } 
    415421    } 
     422    else 
     423    { 
     424      delete[] sendcounts; 
     425      delete[] displs; 
     426    } 
    416427 
    417428  } 

  • XIOS/dev/branch_yushan/extern/src_ep_dev/ep_split.cpp

    r1053 r1056  
    7474 
    7575 
    76     while(color_list.size()) 
     76    while(!color_list.empty()) 
    7777    { 
    7878      int target_color = color_list.front(); 
    … …  
    124124      if(color == all_color[i]) 
    125125      { 
    126         color_index = i; 
     126        //color_index = i; 
    127127        for(int j=0; j<colored_key_loc[i].size(); j++) 
    128128        { 

  • XIOS/dev/branch_yushan/inputs/iodef.xml

    r787 r1056  
    1212 
    1313 
    14    <file_definition type="multiple_file" par_access="collective" output_freq="6h" output_level="10" enabled=".TRUE."> 
     14   <file_definition type="one_file" par_access="collective" output_freq="6h" output_level="10" enabled=".TRUE."> 
    1515     <file id="output" name="output"> 
    1616        <field field_ref="field_A_zoom" name="field_A" /> 

  • XIOS/dev/branch_yushan/src/filter/filter.cpp

    r1053 r1056  
    1515    if (outputPacket) 
    1616    { 
    17       printf("filter/filter.cpp : deliverOuput(outputPacket)\n"); 
    1817      deliverOuput(outputPacket); 
    19       printf("filter/filter.cpp : deliverOuput(outputPacket) OKOK\n"); 
    2018    } 
    2119  } 

  • XIOS/dev/branch_yushan/src/filter/input_pin.cpp

    r1053 r1056  
    3333      // Unregister before calling onInputReady in case the filter registers again 
    3434      gc.unregisterFilter(this, packet->timestamp); 
    35       printf("filter/input_pin.cpp : onInputReady\n"); 
    3635      onInputReady(it->second.packets); 
    37       printf("filter/input_pin.cpp : onInputReady OKOK\n"); 
    3836      inputs.erase(it); 
    3937    } 

  • XIOS/dev/branch_yushan/src/filter/output_pin.cpp

    r1053 r1056  
    2222    for (it = outputs.begin(), itEnd = outputs.end(); it != itEnd; ++it) 
    2323    { 
    24       printf("filter/output_pin.cpp : setInput\n"); 
    2524      it->first->setInput(it->second, packet); 
    26       printf("filter/output_pin.cpp : setInput OKOK\n"); 
    2725    } 
    2826  } 

  • XIOS/dev/branch_yushan/src/filter/source_filter.cpp

    r1053 r1056  
    2929    grid->inputField(data, packet->data); 
    3030 
    31     printf("filter/source_filter.cpp : deliverOuput(packet) \n"); 
    3231    deliverOuput(packet); 
    33     printf("filter/source_filter.cpp : deliverOuput(packet) OKOK\n"); 
     32 
    3433  } 
    3534 

  • XIOS/dev/branch_yushan/src/io/netcdf.hpp

    r1053 r1056  
    3030namespace xios 
    3131{ 
    32   inline int nc_create_par(const char *path, int cmode, ep_lib::MPI_Comm comm, MPI_Info info,int *ncidp) 
     32  inline int nc_create_par(const char *path, int cmode, MPI_Comm comm, MPI_Info info,int *ncidp) 
    3333  { 
    3434#if defined(USING_NETCDF_PAR) 
    35     return ::nc_create_par(path, cmode, static_cast<MPI_Comm>(comm.mpi_comm), info, ncidp) ; 
     35    return ::nc_create_par(path, cmode, comm, info, ncidp) ; 
    3636#else 
    3737    ERROR("int nc_create_par(const char *path, int cmode, MPI_Comm comm, MPI_Info info,int *ncidp)", 
    … …  
    4141  } 
    4242 
    43   inline int nc_open_par(const char *path, int mode, ep_lib::MPI_Comm comm, MPI_Info info,int *ncidp) 
     43  inline int nc_open_par(const char *path, int mode, MPI_Comm comm, MPI_Info info,int *ncidp) 
    4444  { 
    4545#if defined(USING_NETCDF_PAR) 
    46     return ::nc_open_par(path, mode, static_cast<MPI_Comm>(comm.mpi_comm), info, ncidp) ; 
     46    return ::nc_open_par(path, mode, comm, info, ncidp) ; 
    4747#else 
    4848    ERROR("int nc_open_par(const char *path, int mode, MPI_Comm comm, MPI_Info info,int *ncidp)", 

  • XIOS/dev/branch_yushan/src/io/onetcdf4.cpp

    r1053 r1056  
    4747         wmpi = comm && !multifile; 
    4848          
    49          MPI_Info info_null; 
     49         ep_lib::MPI_Info info_null; 
    5050 
    5151         if (wmpi) 
    … …  
    5757            if (wmpi) 
    5858            { 
    59                CNetCdfInterface::createPar(filename, mode, static_cast<MPI_Comm>(comm->mpi_comm), info_null, this->ncidp); 
     59               CNetCdfInterface::createPar(filename, mode, static_cast<MPI_Comm>(comm->mpi_comm), static_cast<MPI_Info>(info_null.mpi_info), this->ncidp); 
    6060               printf("creating file with createPar\n"); 
    6161            } 
    … …  
    7474            if (wmpi) 
    7575            { 
    76                CNetCdfInterface::openPar(filename, mode, static_cast<MPI_Comm>(comm->mpi_comm), info_null, this->ncidp); 
     76               CNetCdfInterface::openPar(filename, mode, static_cast<MPI_Comm>(comm->mpi_comm), static_cast<MPI_Info>(info_null.mpi_info), this->ncidp); 
    7777               printf("opening file with openPar\n"); 
    7878            } 

  • XIOS/dev/branch_yushan/src/node/context.cpp

    r1053 r1056  
    2020  shared_ptr<CContextGroup> CContext::root; 
    2121 
    22    /// ////////////////////// Définitions ////////////////////// /// 
     22   /// ////////////////////// Dfinitions ////////////////////// /// 
    2323 
    2424   CContext::CContext(void) 
    … …  
    177177      if (!this->hasChild()) 
    178178      { 
    179          //oss << "<!-- No definition -->" << std::endl; // fait planter l'incrémentation 
     179         //oss << "<!-- No definition -->" << std::endl; // fait planter l'incrmentation 
    180180      } 
    181181      else 
    … …  
    404404     setClientServerBuffer(); //printf("myRank = %d, setClientServerBuffer OK\n", myRank); 
    405405 
     406     //printf("hasClient = %d, hasServer = %d\n", hasClient, hasServer); 
     407 
    406408     if (hasClient && !hasServer) 
    407409     { 
    … …  
    550552   void CContext::solveAllInheritance(bool apply) 
    551553   { 
    552      // Résolution des héritages descendants (càd des héritages de groupes) 
     554     // Rsolution des hritages descendants (cd des hritages de groupes) 
    553555     // pour chacun des contextes. 
    554556      solveDescInheritance(apply); 
    555557 
    556      // Résolution des héritages par référence au niveau des fichiers. 
     558     // Rsolution des hritages par rfrence au niveau des fichiers. 
    557559      const vector<CFile*> allFiles=CFile::getAll(); 
    558560      const vector<CGrid*> allGrids= CGrid::getAll(); 
    … …  
    577579 
    578580      for (unsigned int i = 0; i < allFiles.size(); i++) 
    579          if (!allFiles[i]->enabled.isEmpty()) // Si l'attribut 'enabled' est défini. 
     581         if (!allFiles[i]->enabled.isEmpty()) // Si l'attribut 'enabled' est dfini. 
    580582         { 
    581             if (allFiles[i]->enabled.getValue()) // Si l'attribut 'enabled' est fixé à vrai. 
     583            if (allFiles[i]->enabled.getValue()) // Si l'attribut 'enabled' est fix  vrai. 
    582584               enabledFiles.push_back(allFiles[i]); 
    583585         } 
    … …  
    586588 
    587589      if (enabledFiles.size() == 0) 
    588          DEBUG(<<"Aucun fichier ne va être sorti dans le contexte nommé \"" 
     590         DEBUG(<<"Aucun fichier ne va tre sorti dans le contexte nomm \"" 
    589591               << getId() << "\" !"); 
    590592   } 
    … …  
    827829      prepareTimeseries();  //printf("myRank = %d, prepareTimeseries OK\n", myRank); 
    828830 
    829       //Initialisation du vecteur 'enabledFiles' contenant la liste des fichiers à sortir. 
     831      //Initialisation du vecteur 'enabledFiles' contenant la liste des fichiers sortir. 
    830832      this->findEnabledFiles();  //printf("myRank = %d, this->findEnabledFiles OK\n", myRank); 
    831833      this->findEnabledReadModeFiles();  //printf("myRank = %d, this->findEnabledReadModeFiles OK\n", myRank); 

  • XIOS/dev/branch_yushan/src/node/field_impl.hpp

    r1053 r1056  
    2020    if (clientSourceFilter) 
    2121    { 
    22       printf("file_impl.hpp : clientSourceFilter->streamData\n"); 
    2322      clientSourceFilter->streamData(CContext::getCurrent()->getCalendar()->getCurrentDate(), _data); 
    24       printf("file_impl.hpp : clientSourceFilter->streamData OKOK\n"); 
    2523    } 
    2624    else if (!field_ref.isEmpty() || !content.empty()) 

  • XIOS/dev/branch_yushan/src/registry.cpp

    r1053 r1056  
    260260  void CRegistry::hierarchicalGatherRegistry(void) 
    261261  { 
    262     hierarchicalGatherRegistry(communicator) ; 
     262   // hierarchicalGatherRegistry(communicator) ; 
     263    gatherRegistry(communicator) ; 
    263264  } 
    264265 

  • XIOS/dev/branch_yushan/src/test/test_client.f90

    r1055 r1056  
    138138 
    139139  PRINT*,"field field_A is active ? ",xios_field_is_active("field_A") 
     140 
     141 
     142  call MPI_Barrier(comm, ierr) 
     143  PRINT*,"MPI_Barrier OK " 
     144 
    140145  !DO ts=1,24*10 
    141146  DO ts=1,6 
Note: See TracChangeset for help on using the changeset viewer.