Impala Documentation

void Impala::Persistency::DistributedAccessRepositoryInFile::LoadParts	(	DistributedAccess *	da,
		const KernelMatrixLocator &	loc
	)			`[inline, private]`

Definition at line 258 of file DistributedAccessRepositoryInFile.h.

References Impala::Core::Matrix::DistributedAccess::AddPart(), Impala::Core::Matrix::DistributedAccess::GetColumnPartCount(), GetDir(), Impala::Persistency::KernelMatrixLocator::GetDoParts(), Impala::Persistency::KernelMatrixLocator::GetEmployReal32(), Impala::Persistency::KernelMatrixLocator::GetFeature(), Impala::Persistency::RepositoryInFileSystem::GetFile(), Impala::Core::Matrix::DistributedAccess::GetOwnerOfPart(), Impala::Core::Matrix::DistributedAccess::GetPartNr(), Impala::Core::Matrix::DistributedAccess::GetRowPartCount(), ILOG_ERROR, Impala::MakeString(), and RepFS().

Referenced by Get().

00259     {
00260         typedef Core::Matrix::VirtualMatrixFactory VirtualMatrixFactory;
00261         typedef Core::Matrix::VirtualMatrix VirtualMatrix;
00262         String dir = GetDir(loc);
00263         VirtualMatrixFactory& vmf = VirtualMatrixFactory::GetInstance();
00264         for (int r=0 ; r<da->GetRowPartCount() ; r++)
00265         {
00266             for (int c=0 ; c<da->GetColumnPartCount() ; c++)
00267             {
00268                 int i = da->GetPartNr(r,c);
00269                 if (Link::Mpi::MyId() == da->GetOwnerOfPart(i))
00270                 {
00271                     String filename = loc.GetFeature() + ".precomputed.part-R" +
00272                                MakeString(r) + "-C" + MakeString(c) + ".raw";
00273                     File file = RepFS().GetFile(loc, dir, filename, false,
00274                                                 false);
00275                     VirtualMatrix* vm;
00276                     if (loc.GetDoParts() == 1)
00277                         vm = vmf.ConstructMemory(file, loc.GetEmployReal32());
00278                     else if (loc.GetDoParts() == 2)
00279                         vm = vmf.ConstructIOBufferReader(file);
00280                     else
00281                         ILOG_ERROR("[LoadParts] Do not understand GetDoParts");
00282                     da->AddPart(vm);
00283                 }
00284             }
00285         }
00286     }

Here is the call graph for this function: