| bool Impala::Persistency::DistributedAccessRepositoryInFile::WriteInfoFile | ( | DistributedAccess * | da, | |
| const KernelMatrixLocator & | loc | |||
| ) | [inline, private] |
Definition at line 289 of file DistributedAccessRepositoryInFile.h.
References Impala::Util::PropertySet::Add(), Impala::Core::Matrix::DistributedAccess::GetColumnPartCount(), Impala::Core::Matrix::DistributedAccess::GetColumns(), GetDir(), Impala::Persistency::KernelMatrixLocator::GetDoParts(), Impala::Persistency::KernelMatrixLocator::GetFeature(), Impala::Persistency::RepositoryInFileSystem::GetFile(), Impala::Core::Matrix::DistributedAccess::GetRowPartCount(), Impala::Core::Matrix::DistributedAccess::GetRows(), Impala::Core::Matrix::DistributedAccess::GetStartNode(), Impala::Persistency::File::GetWriteBuffer(), ILOG_ERROR, ILOG_INFO, Impala::Util::PropertySet::Print(), RepFS(), and Impala::Persistency::File::Valid().
Referenced by Add().
00290 { 00291 if (Link::Mpi::MyId() != da->GetStartNode()) 00292 return true; 00293 00294 String filename = loc.GetFeature() + ".info"; 00295 String dir = GetDir(loc); 00296 Persistency::File file = RepFS().GetFile(loc, dir, filename, true, 00297 false); 00298 if (!file.Valid()) 00299 return false; 00300 00301 ILOG_INFO("Saving info in " << filename); 00302 Util::IOBuffer* buf = file.GetWriteBuffer(); 00303 if (!buf) 00304 { 00305 ILOG_ERROR("Could not open " << loc.GetFeature() << ".info"); 00306 return false; 00307 } 00308 Util::PropertySet ps; 00309 ps.Add("totalrows", da->GetRows()); 00310 ps.Add("totalcolumns", da->GetColumns()); 00311 if (loc.GetDoParts() == 3) 00312 { 00313 ps.Add("rowparts", 1); 00314 ps.Add("columnparts", 1); 00315 } 00316 else 00317 { 00318 ps.Add("rowparts", da->GetRowPartCount()); 00319 ps.Add("columnparts", da->GetColumnPartCount()); 00320 } 00321 ps.Print(buf); 00322 delete buf; 00323 return true; 00324 }
Here is the call graph for this function:
