Flow in ParaSolver

[nariaki3551]

commit: e6625d0

1. Get a task from LC (LoadCoordinator)
   

   cmapdeepbkz/src/ug_deepbkz/cmapDeepBkzParaSolver.cpp

   Line 323 in e6625d0

   CMapLapParaTask *cmapLapParaTask = dynamic_cast<CMapLapParaTask *>(currentTask);

2. Execute DeepLLL algorithm implemented in LapTools
   

   cmapdeepbkz/src/ug_deepbkz/cmapDeepBkzParaSolver.cpp

   Lines 341 to 344 in e6625d0

   	// LLL reduction
   	CmapDeepBkz<int, double, double> lllObj{
   	L, this, getRank(), getThreadId(), 0, false};
   	lllObj.deeplll();

3. Execute ExDeepBKZ (Extended DeepBKZ)
   

   cmapdeepbkz/src/ug_deepbkz/cmapDeepBkzParaSolver.cpp

   Lines 349 to 363 in e6625d0

   	CmapExDeepBkz<int, double, double> reductionObj{
   	L, this, getRank(), getThreadId(), verbose, mergeBasisFromLC};
   	// reduction (DeepBKZ)
   	int startBlocksize = paraParams->getIntParamValue(DeepBkzStartBlockSize);
   	int endBlocksize = paraParams->getIntParamValue(DeepBkzEndBlockSize);
   	int intervalBlocksize = paraParams->getIntParamValue(DeepBkzBlockSizeInterval);
   	int blocksize;
   	int _start = 1, _end = L->n, gamma = L->n, abort = 4;
   	double alpha = 0.99;
   	for( blocksize = startBlocksize; blocksize <= endBlocksize; blocksize += intervalBlocksize )
   	{
   	if( blocksize > endBlocksize ){ break; }
   	reductionObj.DeepBKZ(_start, _end, blocksize, alpha, gamma, abort);
   	}

   
   3-1. Run a tour of DeepBKZ (by DeepBKZ/DeepBKZ.h)
   3-2. Enter receiving phase per tour
   

   cmapdeepbkz/src/DeepBKZ/DeepBKZ/DeepBKZ.h

   Lines 77 to 78 in e6625d0

   	communicate(shouldAbort);
   	if (shouldAbort) return true;

   
   3-3. Fetch the global sub basis when ParaSolver has received if from LC, and merge it to own basis using LapTools::Lattice::merge() function. Then, synchronize merged basis to NLT matrix in DeepBKZ::Lattice class by syncBasisToNTL()
   

   cmapdeepbkz/src/ug_deepbkz/cmapDeepBkzParaSolver.cpp

   Lines 156 to 170 in e6625d0

   	// check that it has received basis
   	if( mergeBasisFromLC & cmapLapParaSolver->hasReceivedBasis() )
   	{
   	LapTools::LatticeBasis<BasisFloat> receivedSubBasis(cmapLapParaSolver->getReceivedBasis<BasisFloat>());
   	LapTools::Lattice<BasisFloat, GSFloat> receivedSubLattice{receivedSubBasis};
   	int index = 0;
   	if( receivedSubLattice.isMoreReducedThan(*L, index) )
   	{
   	// double startMergeTime = LapTools::Timer::getElapsedTime();
   	L->merge(receivedSubLattice);
   	syncBasisToNTL();
   	// this->mergeTime += LapTools::Timer::getElapsedTime() - startMergeTime;
   	// updateBestObjectiveValue('U');
   	}
   	}

   
   3-4. Send status message to LC
   

   cmapdeepbkz/src/ug_deepbkz/cmapDeepBkzParaSolver.cpp

   Lines 172 to 176 in e6625d0

   	// check to be necessary to send the status
   	if( cmapLapParaSolver->notificationIsNecessary() )
   	{
   	sendStatus();
   	}