Changeset 314 for XIOS/trunk
- Timestamp:
- 02/20/12 11:22:02 (12 years ago)
- Location:
- XIOS/trunk
- Files:
-
- 34 added
- 20 deleted
- 16 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/trunk/bld.cfg
r313 r314 27 27 bld::lib xios 28 28 bld::target libxios.a 29 #bld::target main_server.exe test_xios.exe30 bld::target generate_fortran_interface.exe server_main.exe test_cs.exe29 bld::target generate_fortran_interface.exe 30 bld::target xios_server.exe test_cs.exe 31 31 bld::exe_dep 32 32 -
XIOS/trunk/src/client_ym.cpp
r300 r314 4 4 #include <boost/functional/hash.hpp> 5 5 #include "type.hpp" 6 #include "buffer.hpp"7 6 #include "context.hpp" 8 7 #include "context_client.hpp" … … 130 129 131 130 132 133 134 /*135 void CClient::initialize(const string& codeId,MPI_Comm& localComm,MPI_Comm& returnComm)136 {137 boost::hash<string> hashString ;138 139 unsigned long hashClient=hashString(codeId) ;140 unsigned long hashServer=hashString(CXios::xiosCodeId) ;141 unsigned long* hashAll ;142 int rank ;143 int size ;144 int myColor ;145 int i,c ;146 MPI_Comm newComm ;147 148 MPI_Comm_size(CXios::globalComm,&size) ;149 MPI_Comm_rank(CXios::globalComm,&rank);150 hashAll=new unsigned long[size] ;151 152 MPI_Allgather(&hashClient,1,MPI_LONG,hashAll,1,MPI_LONG,CXios::globalComm) ;153 154 map<unsigned long, int> colors ;155 map<unsigned long, int> leaders ;156 157 for(i=0,c=0;i<size;i++)158 {159 if (colors.find(hashAll[i])==colors.end())160 {161 colors[hashAll[i]] =c ;162 leaders[hashAll[i]]=i ;163 c++ ;164 }165 166 }167 168 myColor=colors[hashClient] ;169 170 MPI_Comm_split(CXios::globalComm,myColor,rank,&intraComm) ;171 172 if (!CXios::isServer)173 {174 int clientLeader=leaders[hashClient] ;175 serverLeader=leaders[hashServer] ;176 MPI_Intercomm_create(intraComm,0,CXios::globalComm,serverLeader,0,&interComm) ;177 }178 else179 {180 MPI_Comm_dup(intraComm,&interComm) ;181 }182 183 delete [] hashAll ;184 }185 */186 187 131 void CClient::registerContext(const string& id,MPI_Comm contextComm) 188 132 { -
XIOS/trunk/src/context_client.cpp
r300 r314 8 8 #include "message.hpp" 9 9 #include "event_client.hpp" 10 #include "transfert_parameters.hpp"11 10 #include "context.hpp" 12 11 #include <mpi.h> -
XIOS/trunk/src/context_server.cpp
r300 r314 2 2 #include "buffer_in.hpp" 3 3 #include "type.hpp" 4 #include "transfert_parameters.hpp"5 4 #include "context.hpp" 6 5 #include "object_template_impl.hpp" -
XIOS/trunk/src/fortran/icdata.cpp
r312 r314 17 17 18 18 #include "icutil.hpp" 19 #include "mpi_manager.hpp"20 #include "buffer.hpp"21 19 #include "cxios.hpp" 22 20 #include "client_ym.hpp" -
XIOS/trunk/src/node/axis.cpp
r313 r314 4 4 #include "object_template_impl.hpp" 5 5 #include "group_template_impl.hpp" 6 #include "transfert_parameters.hpp"7 6 8 7 namespace xmlioserver { -
XIOS/trunk/src/node/context.cpp
r300 r314 9 9 #include "duration.hpp" 10 10 11 #include "data_treatment.hpp"12 11 #include "context_client.hpp" 13 12 #include "context_server.hpp" -
XIOS/trunk/src/node/domain.cpp
r300 r314 4 4 #include "object_template_impl.hpp" 5 5 #include "group_template_impl.hpp" 6 7 #include "mpi_manager.hpp"8 6 9 7 #include "tree_manager.hpp" -
XIOS/trunk/src/node/field.cpp
r310 r314 7 7 #include "node_type.hpp" 8 8 #include "calendar_util.hpp" 9 #include "xios_manager.hpp"10 9 11 10 namespace xmlioserver{ -
XIOS/trunk/src/node/grid.cpp
r300 r314 6 6 #include "group_template_impl.hpp" 7 7 #include <iostream> 8 #include "mpi_manager.hpp"9 8 10 9 namespace xmlioserver { … … 533 532 534 533 535 534 /* 536 535 void CGrid::computeIndexServer(void) 537 536 { … … 669 668 this->out_l_index[0] = out_l_index_srv; 670 669 } 671 670 */ 672 671 673 672 void CGrid::inputFieldServer -
XIOS/trunk/src/object_template_impl.hpp
r313 r314 4 4 #include "object_factory.hpp" 5 5 #include "context.hpp" 6 #include "transfert_parameters.hpp"7 6 #include "buffer_in.hpp" 8 7 #include "attribute.hpp" -
XIOS/trunk/src/output/nc4_data_output.cpp
r313 r314 8 8 #include "file.hpp" 9 9 #include "calendar.hpp" 10 #include "xios_manager.hpp"11 10 #include "context.hpp" 12 11 #include "context_server.hpp" -
XIOS/trunk/src/output/onetcdf4.cpp
r300 r314 1 1 #include "onetcdf4.hpp" 2 2 #include "group_template_impl.hpp" 3 #include "mpi_manager.hpp"4 3 5 4 namespace xmlioserver … … 404 403 void CONetCDF4::sync(void) 405 404 { 406 407 comm::CMPIManager::Barrier(comm::CMPIManager::GetCommServer());408 405 CheckError(nc_sync(this->ncidp)) ; 409 406 } -
XIOS/trunk/src/output/onetcdf4.hpp
r286 r314 7 7 #include "array.hpp" 8 8 #include "data_output.hpp" 9 #include "mpi_manager.hpp"10 9 11 10 #include <mpi.h> -
XIOS/trunk/src/server_ym.cpp
r300 r314 3 3 #include "server_ym.hpp" 4 4 #include "type.hpp" 5 #include "buffer.hpp"6 5 #include "context.hpp" 7 6 #include "object_template_impl.hpp" … … 350 349 <<"Context has already been registred") ; 351 350 352 // tree::CContext* ptr ;353 // if (tree::CContext::has(contextId)) ptr=tree::CContext::get(contextId).get() ;354 // else ptr=tree::CContext::create(contextId).get() ;355 351 shared_ptr<CContext> context=tree::CTreeManager::CreateContext(contextId) ; 356 352 contextList[contextId]=context.get() ; -
XIOS/trunk/src/xmlioserver.hpp
r219 r314 5 5 6 6 /// xmlioserver headers /// 7 #include "mpi_manager.hpp"8 7 #include "tree_manager.hpp" 9 #include "xios_manager.hpp"10 #include "data_treatment.hpp"11 8 #include "nc4_data_output.hpp" 12 9 … … 19 16 using namespace xmlioserver::tree; 20 17 using namespace xmlioserver::xml; 21 using namespace xmlioserver::comm;22 18 using namespace xmlioserver::func; 23 19
Note: See TracChangeset
for help on using the changeset viewer.