Changeset 1070 for XIOS/dev/branch_yushan/src/node
- Timestamp:
- 03/09/17 18:31:07 (7 years ago)
- Location:
- XIOS/dev/branch_yushan/src/node
- Files:
-
- 4 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/branch_yushan/src/node/context.cpp
r1067 r1070 390 390 void CContext::closeDefinition(void) 391 391 { 392 int myRank;393 MPI_Comm_rank(MPI_COMM_WORLD, &myRank);394 395 //printf("myRank = %d, hasClient = %d, hasServer = %d\n", myRank, hasClient, hasServer);396 392 397 393 // There is nothing client need to send to server … … 400 396 // After xml is parsed, there are some more works with post processing 401 397 postProcessing(); 402 //printf("myRank = %d, postProcessing OK\n", myRank); 403 } 404 setClientServerBuffer(); //printf("myRank = %d, setClientServerBuffer OK\n", myRank); 405 406 //printf("hasClient = %d, hasServer = %d\n", hasClient, hasServer); 398 } 399 setClientServerBuffer(); 407 400 408 401 if (hasClient && !hasServer) 409 402 { 410 403 // Send all attributes of current context to server 411 this->sendAllAttributesToServer(); //printf("myRank = %d, this->sendAllAttributesToServer OK\n", myRank);404 this->sendAllAttributesToServer(); 412 405 413 406 // Send all attributes of current calendar 414 407 CCalendarWrapper::get(CCalendarWrapper::GetDefName())->sendAllAttributesToServer(); 415 //printf("myRank = %d, CCalendarWrapper::get(CCalendarWrapper::GetDefName())->sendAllAttributesToServer OK\n", myRank);416 408 417 409 // We have enough information to send to server 418 410 // First of all, send all enabled files 419 sendEnabledFiles(); //printf("myRank = %d, sendEnabledFiles OK\n", myRank);411 sendEnabledFiles(); 420 412 421 413 // Then, send all enabled fields 422 sendEnabledFields(); //printf("myRank = %d, sendEnabledFields OK\n", myRank);414 sendEnabledFields(); 423 415 424 416 // At last, we have all info of domain and axis, then send them 425 sendRefDomainsAxis(); //printf("myRank = %d, sendRefDomainsAxis OK\n", myRank); 426 417 sendRefDomainsAxis(); 427 418 // After that, send all grid (if any) 428 sendRefGrid(); //printf("myRank = %d, sendRefGrid OK\n", myRank);419 sendRefGrid(); 429 420 } 430 421 … … 435 426 if (hasClient) 436 427 { 437 this->buildFilterGraphOfEnabledFields(); //printf("myRank = %d, buildFilterGraphOfEnabledFields OK\n", myRank);438 buildFilterGraphOfFieldsWithReadAccess(); //printf("myRank = %d, buildFilterGraphOfFieldsWithReadAccess OK\n", myRank);439 this->solveAllRefOfEnabledFields(true); //printf("myRank = %d, solveAllRefOfEnabledFields OK\n", myRank);428 this->buildFilterGraphOfEnabledFields(); 429 buildFilterGraphOfFieldsWithReadAccess(); 430 this->solveAllRefOfEnabledFields(true); 440 431 } 441 432 … … 448 439 if (hasClient) 449 440 { 450 sendCreateFileHeader(); //printf("myRank = %d, sendCreateFileHeader OK\n", myRank);451 452 startPrefetchingOfEnabledReadModeFiles(); //printf("myRank = %d, startPrefetchingOfEnabledReadModeFiles OK\n", myRank);441 sendCreateFileHeader(); 442 443 startPrefetchingOfEnabledReadModeFiles(); 453 444 } 454 445 } -
XIOS/dev/branch_yushan/src/node/domain.cpp
r1053 r1070 1303 1303 void CDomain::checkAttributesOnClientAfterTransformation() 1304 1304 { 1305 int myRank; 1306 MPI_Comm_rank(MPI_COMM_WORLD, &myRank); 1307 1308 CContext* context=CContext::getCurrent() ; //printf("myRank = %d, CContext::getCurrent OK\n", myRank); 1309 1310 //printf("myRank = %d, this->isClientAfterTransformationChecked = %d\n", myRank, this->isClientAfterTransformationChecked); 1305 1306 CContext* context=CContext::getCurrent() ; 1307 1311 1308 if (this->isClientAfterTransformationChecked) return; 1312 //printf("myRank = %d, context->hasClient = %d\n", myRank, context->hasClient);1313 1309 if (context->hasClient) 1314 1310 { 1315 this->checkMask(); //printf("myRank = %d, this->checkMask OK\n", myRank); 1316 //printf("myRank = %d, hasLonLat = %d, hasArea = %d, isCompressible_ = %d\n", myRank, hasLonLat, hasArea, isCompressible_); 1311 this->checkMask(); 1317 1312 if (hasLonLat || hasArea || isCompressible_) 1318 1313 { 1319 //printf("myRank = %d, start this->computeConnectedServer\n", myRank);1320 1314 this->computeConnectedServer(); 1321 //printf("myRank = %d, this->computeConnectedServer OK\n", myRank); 1322 } 1323 //printf("myRank = %d, hasLonLat = %d\n", myRank, hasLonLat); 1315 } 1324 1316 if (hasLonLat) 1325 1317 { 1326 1318 this->completeLonLatClient(); 1327 //printf("myRank = %d, this->completeLonLatClient OK\n", myRank);1328 1319 } 1329 1320 } … … 1460 1451 void CDomain::computeConnectedServer(void) 1461 1452 { 1462 int myRank;1463 MPI_Comm_rank(MPI_COMM_WORLD, &myRank);1464 1453 1465 1454 CContext* context=CContext::getCurrent() ; … … 1576 1565 else serverDescription.computeServerGlobalIndexInRange(std::make_pair<size_t,size_t>(indexBegin, indexEnd), 1); 1577 1566 1578 //printf("myRank = %d, check 7 OK\n", myRank);1579 1580 1567 CClientServerMapping* clientServerMap = new CClientServerMappingDistributed(serverDescription.getGlobalIndexRange(), 1581 1568 client->intraComm); 1582 //printf("myRank = %d new OK\n", myRank);1583 1584 1569 clientServerMap->computeServerIndexMapping(globalIndexDomain); 1585 //printf("myRank = %d, clientServerMap->computeServerIndexMapping(globalIndexDomain) OK\n", myRank);1586 1570 1587 1571 const CClientServerMapping::GlobalIndexMap& globalIndexDomainOnServer = clientServerMap->getGlobalIndexOnServer(); 1588 //printf("myRank = %d, clientServerMap->getGlobalIndexOnServer OK\n", myRank);1589 1572 1590 //printf("myRank = %d, check 8 OK\n", myRank);1591 1592 1573 CClientServerMapping::GlobalIndexMap::const_iterator it = globalIndexDomainOnServer.begin(), 1593 1574 ite = globalIndexDomainOnServer.end(); … … 1622 1603 } 1623 1604 1624 //printf("myRank = %d, check 9 OK\n", myRank);1625 1626 1605 connectedServerRank_.clear(); 1627 1606 for (it = globalIndexDomainOnServer.begin(); it != ite; ++it) { … … 1632 1611 1633 1612 delete clientServerMap; 1634 //printf("myRank = %d, check 10 OK\n", myRank);1635 1613 } 1636 1614 -
XIOS/dev/branch_yushan/src/node/field.cpp
r1037 r1070 621 621 void CField::solveAllReferenceEnabledField(bool doSending2Server) 622 622 { 623 int myRank; 624 MPI_Comm_rank(MPI_COMM_WORLD, &myRank); 625 626 CContext* context = CContext::getCurrent(); //printf("my_Rank = %d, CContext* context = CContext::getCurrent OK\n", myRank); 627 solveOnlyReferenceEnabledField(doSending2Server); //printf("my_Rank = %d, solveOnlyReferenceEnabledField(doSending2Server) OK\n", myRank); 623 624 CContext* context = CContext::getCurrent(); 625 solveOnlyReferenceEnabledField(doSending2Server); 628 626 629 627 if (!areAllReferenceSolved) … … 633 631 if (context->hasClient) 634 632 { 635 solveRefInheritance(true); //printf("my_Rank = %d, solveRefInheritance(true) OK\n", myRank);633 solveRefInheritance(true); 636 634 if (hasDirectFieldReference()) 637 635 { 638 636 getDirectFieldReference()->solveAllReferenceEnabledField(false); 639 //printf("my_Rank = %d, getDirectFieldReference()->solveAllReferenceEnabledField(false) OK\n", myRank);637 640 638 } 641 639 } … … 643 641 { 644 642 solveServerOperation(); 645 //printf("my_Rank = %d, solveServerOperation OK\n", myRank);643 646 644 } 647 645 648 solveGridReference(); //printf("my_Rank = %d, solveGridReference OK\n", myRank);649 } 650 651 solveGridDomainAxisRef(doSending2Server); //printf("my_Rank = %d, solveGridDomainAxisRef(doSending2Server) OK\n", myRank);646 solveGridReference(); 647 } 648 649 solveGridDomainAxisRef(doSending2Server); 652 650 653 651 if (context->hasClient) 654 652 { 655 solveTransformedGrid(); //printf("my_Rank = %d, solveTransformedGrid OK\n", myRank);656 } 657 658 solveCheckMaskIndex(doSending2Server); //printf("FIELD.CPP: my_Rank = %d, solveCheckMaskIndex(doSending2Server) OK\n", myRank);653 solveTransformedGrid(); 654 } 655 656 solveCheckMaskIndex(doSending2Server); 659 657 } 660 658 -
XIOS/dev/branch_yushan/src/node/grid.cpp
r1037 r1070 166 166 void CGrid::checkAttributesAfterTransformation() 167 167 { 168 int myRank; 169 MPI_Comm_rank(MPI_COMM_WORLD, &myRank); 170 171 setAxisList(); //printf("myRank = %d, setAxisList OK\n", myRank); 172 std::vector<CAxis*> axisListP = this->getAxis(); //printf("myRank = %d, this->getAxis OK\n", myRank); 168 169 setAxisList(); 170 std::vector<CAxis*> axisListP = this->getAxis(); 173 171 if (!axisListP.empty()) 174 172 { … … 183 181 axisPositionInGrid_.push_back(idx); 184 182 ++idx; 185 //printf("myRank = %d, axisPositionInGrid_.push_back OK\n", myRank);183 186 184 } 187 185 else if (2 == elementDimension) idx += 2; … … 191 189 { 192 190 axisListP[i]->checkAttributesOnClientAfterTransformation(globalDim_,axisPositionInGrid_[i]); 193 //printf("myRank = %d, axisListP[%d/%d]->checkAttributesOnClientAfterTransformation OK\n", myRank, i, axisListP.size()); 194 } 195 } 196 197 setDomainList(); //printf("myRank = %d, setDomainList OK\n", myRank); 198 std::vector<CDomain*> domListP = this->getDomains(); //printf("myRank = %d, this->getDomains OK\n", myRank); 191 } 192 } 193 194 setDomainList(); 195 std::vector<CDomain*> domListP = this->getDomains(); 199 196 if (!domListP.empty()) 200 197 { 201 198 for (int i = 0; i < domListP.size(); ++i) 202 199 { 203 //printf("myRank = %d, start domListP[%d]->checkAttributesOnClientAfterTransformation\n", myRank, i);204 200 domListP[i]->checkAttributesOnClientAfterTransformation(); 205 //printf("myRank = %d, domListP[%d]->checkAttributesOnClientAfterTransformation OK\n", myRank, i);206 201 } 207 202 }
Note: See TracChangeset
for help on using the changeset viewer.