Definition at line 277 of file DistributedAccess.h. References Impala::Core::Database::RawDataSet::GetDatabase(), Impala::Core::Database::RawDataSet::GetFilePathPrecomputedKernels(), Impala::Util::PropertySet::GetInt(), Impala::Util::Database::GetIOBuffer(), Impala::Core::Database::RawDataSet::GetSetName(), ILOG_DEBUG, ILOG_ERROR, mColumns, mRows, and Impala::Util::IOBuffer::ReadLine(). Referenced by DistributedAccess(). 00279 { 00280 String description; 00281 if(Link::Mpi::MyId() == 0) 00282 { 00283 Util::Database* db; 00284 String filename = filenamebase + ".info"; 00285 if (set2) 00286 { 00287 filename = set2->GetFilePathPrecomputedKernels(filename, 00288 set->GetSetName(), 00289 false, false); 00290 db = set2->GetDatabase(); 00291 } 00292 else 00293 { 00294 filename = set->GetFilePathPrecomputedKernels(filename, 00295 "", false, false); 00296 db = set->GetDatabase(); 00297 } 00298 Util::IOBuffer* buf = db->GetIOBuffer(filename, true, true, ""); 00299 if (!buf) 00300 { 00301 ILOG_ERROR("could not open " << filenamebase << ".info"); 00302 return false; 00303 } 00304 description = buf->ReadLine(); 00305 delete buf; 00306 } 00307 description = Link::Mpi::BroadcastString(description); 00308 ILOG_DEBUG("description = " << description); 00309 Util::PropertySet properties(description); 00310 // read the properties 00311 mRows = new IndexConverter(properties.GetInt("totalrows"), properties.GetInt("rowparts")); 00312 mColumns = new IndexConverter(properties.GetInt("totalcolumns"), properties.GetInt("columnparts")); 00313 //ILOG_DEBUG_NODE("ReadInfo done: " << mTotalColumns << " " << mColumnParts); 00314 return true; 00315 }
Here is the call graph for this function:
|