Changeset 1765 for XIOS/dev/dev_ym/XIOS_SERVICES/src/manager
- Timestamp:
- 11/06/19 11:03:38 (5 years ago)
- Location:
- XIOS/dev/dev_ym/XIOS_SERVICES/src/manager
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/dev_ym/XIOS_SERVICES/src/manager/contexts_manager.cpp
r1764 r1765 101 101 else return false ; 102 102 } 103 104 /*105 auto eventScheduler=CServer::getServersRessource()->getPoolRessource()->getService(serviceId,partitionId)->getEventScheduler() ;106 std::hash<string> hashString ;107 size_t hashId = hashString(getServerContextName(poolId, serviceId, partitionId, contextId)) ;108 size_t currentTimeLine=0 ;109 CServer::eventScheduler->registerEvent(currentTimeLine,hashId);110 while (!eventScheduler->queryEvent(currentTimeLine,hashId))111 {112 CXios::getDaemonsManager()->eventLoop() ;113 }114 115 MPI_Bcast(&ok, 1, MPI_INT, 0, intraComm) ;116 117 if (ok)118 {119 120 MPI_Intercomm_create(intraComm, 0, xiosComm_, contextLeader, 3141, &interComm) ;121 return true ;122 }123 else return false ;124 }125 */126 127 103 128 104 void CContextsManager::sendNotification(int rank) -
XIOS/dev/dev_ym/XIOS_SERVICES/src/manager/contexts_manager.hpp
r1764 r1765 31 31 32 32 bool createServerContext(const std::string& poolId, const std::string& serviceId, const int& partitionId, const string& contextId, bool wait=true) ; 33 /* bool createServerContextIntercomm(const std::string& poolId, const std::string& serviceId, const int& partitionId, const std::string& contextId, 34 const MPI_Comm& intraComm, MPI_Comm& InterComm, bool wait=true) ;*/ 35 33 36 34 bool createServerContextIntercomm(const std::string& poolId, const std::string& serviceId, const int& partitionId, 37 35 const std::string& contextId, const string& sourceContext, bool wait=true) ; -
XIOS/dev/dev_ym/XIOS_SERVICES/src/manager/server_context.cpp
r1764 r1765 90 90 MPI_Test(&req,&flag,&status) ; 91 91 } 92 // auto eventScheduler=parentService_->getEventScheduler() ; 93 // std::hash<string> hashString ; 94 // size_t hashId = hashString(name_) ; 95 // size_t currentTimeLine=0 ; 96 // eventScheduler->registerEvent(currentTimeLine,hashId); 97 // 98 // while (!eventScheduler->queryEvent(currentTimeLine,hashId)) 99 // { 100 // CXios::getDaemonsManager()->servicesEventLoop() ; 101 // eventScheduler->checkEvent() ; 102 // } 103 92 104 93 MPI_Bcast(&ok, 1, MPI_INT, 0, intraComm) ; 105 94
Note: See TracChangeset
for help on using the changeset viewer.