UG
Ubiquity Generator framework
Ubiquity Generator framework
Class for LoadCoordinator termination state which contains calculation state in a ParaLoadCoordinator. More...
#include <bbParaLoadCoordinatorTerminationState.h>
Public Member Functions | |
| BbParaLoadCoordinatorTerminationState () | |
| default constructor More... | |
| virtual | ~BbParaLoadCoordinatorTerminationState () |
| destructor More... | |
| std::string | toString () |
| stringfy ParaCalculationState More... | |
| void | write (gzstream::ogzstream &out) |
| write to checkpoint file More... | |
| bool | read (ParaComm *comm, gzstream::igzstream &in) |
| read from checkpoint file More... | |
 Public Member Functions inherited from ParaLoadCoordinatorTerminationState | |
| ParaLoadCoordinatorTerminationState () | |
| default constructor More... | |
| virtual | ~ParaLoadCoordinatorTerminationState () |
| destructor More... | |
| virtual std::string | toString ()=0 |
| stringfy ParaCalculationState More... | |
| virtual void | write (gzstream::ogzstream &out)=0 |
| write to checkpoint file More... | |
| virtual bool | read (ParaComm *comm, gzstream::igzstream &in)=0 |
| read from checkpoint file More... | |
Public Attributes | |
| unsigned long long | nSentBackImmediately |
| Counters related to this ParaLoadCoordinator TODO: The numbers should be classified depending on solvers. More... | |
| unsigned long long | nSentBackImmediatelyAnotherNode |
| number of ParaNodes sent back immediately after AnotherNode request from LC More... | |
| unsigned long long | nDeletedInLc |
| number of ParaNodes deleted in LC More... | |
| unsigned long long | nDeletedByMerging |
| number of ParaNodes deleted by merging More... | |
| unsigned long long | nFailedToSendBack |
| number of ParaNodes failed to send back More... | |
| unsigned long long | nFailedToSendBackAnotherNode |
| number of ParaNodes failed to send back after AnotherNode request More... | |
| unsigned long long | nMaxUsageOfNodePool |
| maximum number of ParaNodes in ParaNodePool More... | |
| unsigned long long | nInitialP |
| initial p value, which indicates the number of good ParaNodes try to keep in LC More... | |
| unsigned long long | mMaxCollectingNodes |
| maximum multiplier for the number of collecting nodes More... | |
| unsigned long long | nNodesInNodePool |
| number of nodes in ParaNodePool More... | |
| unsigned long long | nNodesLeftInAllSolvers |
| number of nodes left in all Solvers More... | |
| unsigned long long | nNodesOutputLog |
| count for next logging of the number of transferred ParaNodes More... | |
| double | tNodesOutputLog |
| keep time for next logging of the number of transferred ParaNodes More... | |
| double | globalBestDualBoundValue |
| global best dual bound value (internal value) More... | |
| double | externalGlobalBestDualBoundValue |
| global best dual bound value (external value) More... | |
| double | idleTime |
| idle time of this LoadCoordinator More... | |
| double | runningTime |
| this ParaLoadCoordinator running time More... | |
| double | addingNodeToMergeStructTime |
| time when a ParaNode is added to merge struct More... | |
| double | generateMergeNodesCandidatesTime |
| time when merge ParaNode candidates are generated More... | |
| double | regenerateMergeNodesCandidatesTime |
| time when merge ParaNode candidates are regenerated More... | |
| double | mergeNodeTime |
| time when ParaNode is merged More... | |
| Public Attributes inherited from ParaLoadCoordinatorTerminationState | |
| bool | isCheckpointState |
| indicate if this state is at checkpoint or not More... | |
| int | rank |
| rank of this ParaLoadCoordinator More... | |
| unsigned long long | nWarmStart |
| number of warm starts (restarts) More... | |
| unsigned long long | nSent |
| number of ParaTasks sent from LC More... | |
| unsigned long long | nReceived |
| number of ParaTasks received from Solvers More... | |
| double | idleTime |
| idle time of this LoadCoordinator More... | |
| double | runningTime |
| this ParaLoadCoordinator running time More... | |
Class for LoadCoordinator termination state which contains calculation state in a ParaLoadCoordinator.
Definition at line 56 of file bbParaLoadCoordinatorTerminationState.h.
default constructor
Definition at line 101 of file bbParaLoadCoordinatorTerminationState.h.
|
virtual |
destructor
Definition at line 131 of file bbParaLoadCoordinatorTerminationState.h.
|
virtual |
read from checkpoint file
| comm | communicator used |
| in | gzstream for input |
Implements ParaLoadCoordinatorTerminationState.
Definition at line 124 of file bbParaLoadCoordinatorTerminationState.cpp.
References BbParaLoadCoordinatorTerminationState::addingNodeToMergeStructTime, BbParaLoadCoordinatorTerminationState::externalGlobalBestDualBoundValue, BbParaLoadCoordinatorTerminationState::generateMergeNodesCandidatesTime, BbParaLoadCoordinatorTerminationState::globalBestDualBoundValue, BbParaLoadCoordinatorTerminationState::idleTime, ParaLoadCoordinatorTerminationState::isCheckpointState, BbParaLoadCoordinatorTerminationState::mergeNodeTime, BbParaLoadCoordinatorTerminationState::nDeletedInLc, BbParaLoadCoordinatorTerminationState::nFailedToSendBack, BbParaLoadCoordinatorTerminationState::nFailedToSendBackAnotherNode, BbParaLoadCoordinatorTerminationState::nMaxUsageOfNodePool, BbParaLoadCoordinatorTerminationState::nNodesInNodePool, BbParaLoadCoordinatorTerminationState::nNodesLeftInAllSolvers, ParaLoadCoordinatorTerminationState::nReceived, ParaLoadCoordinatorTerminationState::nSent, BbParaLoadCoordinatorTerminationState::nSentBackImmediately, BbParaLoadCoordinatorTerminationState::nSentBackImmediatelyAnotherNode, ParaLoadCoordinatorTerminationState::nWarmStart, ParaLoadCoordinatorTerminationState::rank, BbParaLoadCoordinatorTerminationState::regenerateMergeNodesCandidatesTime, and BbParaLoadCoordinatorTerminationState::runningTime.
Referenced by BbParaLoadCoordinator::writePreviousStatisticsInformation().
|
virtual |
stringfy ParaCalculationState
stringfy ParaCalculationState
Implements ParaLoadCoordinatorTerminationState.
Definition at line 44 of file bbParaLoadCoordinatorTerminationState.cpp.
References BbParaLoadCoordinatorTerminationState::addingNodeToMergeStructTime, BbParaLoadCoordinatorTerminationState::externalGlobalBestDualBoundValue, BbParaLoadCoordinatorTerminationState::generateMergeNodesCandidatesTime, BbParaLoadCoordinatorTerminationState::globalBestDualBoundValue, BbParaLoadCoordinatorTerminationState::idleTime, ParaLoadCoordinatorTerminationState::isCheckpointState, BbParaLoadCoordinatorTerminationState::mergeNodeTime, BbParaLoadCoordinatorTerminationState::mMaxCollectingNodes, BbParaLoadCoordinatorTerminationState::nDeletedByMerging, BbParaLoadCoordinatorTerminationState::nDeletedInLc, BbParaLoadCoordinatorTerminationState::nFailedToSendBack, BbParaLoadCoordinatorTerminationState::nFailedToSendBackAnotherNode, BbParaLoadCoordinatorTerminationState::nInitialP, BbParaLoadCoordinatorTerminationState::nMaxUsageOfNodePool, BbParaLoadCoordinatorTerminationState::nNodesInNodePool, BbParaLoadCoordinatorTerminationState::nNodesLeftInAllSolvers, ParaLoadCoordinatorTerminationState::nReceived, ParaLoadCoordinatorTerminationState::nSent, BbParaLoadCoordinatorTerminationState::nSentBackImmediately, BbParaLoadCoordinatorTerminationState::nSentBackImmediatelyAnotherNode, ParaLoadCoordinatorTerminationState::rank, BbParaLoadCoordinatorTerminationState::regenerateMergeNodesCandidatesTime, and BbParaLoadCoordinatorTerminationState::runningTime.
Referenced by BbParaLoadCoordinator::writePreviousStatisticsInformation(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
|
virtual |
write to checkpoint file
| out | gzstream for output |
Implements ParaLoadCoordinatorTerminationState.
Definition at line 96 of file bbParaLoadCoordinatorTerminationState.cpp.
References BbParaLoadCoordinatorTerminationState::addingNodeToMergeStructTime, BbParaLoadCoordinatorTerminationState::externalGlobalBestDualBoundValue, BbParaLoadCoordinatorTerminationState::generateMergeNodesCandidatesTime, BbParaLoadCoordinatorTerminationState::globalBestDualBoundValue, BbParaLoadCoordinatorTerminationState::idleTime, ParaLoadCoordinatorTerminationState::isCheckpointState, BbParaLoadCoordinatorTerminationState::mergeNodeTime, BbParaLoadCoordinatorTerminationState::nDeletedInLc, BbParaLoadCoordinatorTerminationState::nFailedToSendBack, BbParaLoadCoordinatorTerminationState::nFailedToSendBackAnotherNode, BbParaLoadCoordinatorTerminationState::nMaxUsageOfNodePool, BbParaLoadCoordinatorTerminationState::nNodesInNodePool, BbParaLoadCoordinatorTerminationState::nNodesLeftInAllSolvers, ParaLoadCoordinatorTerminationState::nReceived, ParaLoadCoordinatorTerminationState::nSent, BbParaLoadCoordinatorTerminationState::nSentBackImmediately, BbParaLoadCoordinatorTerminationState::nSentBackImmediatelyAnotherNode, ParaLoadCoordinatorTerminationState::nWarmStart, ParaLoadCoordinatorTerminationState::rank, BbParaLoadCoordinatorTerminationState::regenerateMergeNodesCandidatesTime, and BbParaLoadCoordinatorTerminationState::runningTime.
Referenced by BbParaLoadCoordinator::writeLoadCoordinatorStatisticsToCheckpointFile().
| double addingNodeToMergeStructTime |
time when a ParaNode is added to merge struct
Definition at line 92 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), and BbParaLoadCoordinator::writeLoadCoordinatorStatisticsToCheckpointFile().
| double externalGlobalBestDualBoundValue |
global best dual bound value (external value)
times of this LoadCoordinator
Definition at line 83 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinator::outputTabularSolvingStatus(), BbParaLoadCoordinator::processRacingRampUpTagCompletionOfCalculation(), BbParaLoadCoordinator::processRacingRampUpTagSolverState(), BbParaLoadCoordinator::processTagCompletionOfCalculation(), BbParaLoadCoordinator::processTagSolverState(), BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinator::restartRacing(), BbParaLoadCoordinator::run(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinator::updateCheckpointFiles(), BbParaLoadCoordinator::warmStart(), BbParaLoadCoordinatorTerminationState::write(), BbParaLoadCoordinator::writeLoadCoordinatorStatisticsToCheckpointFile(), BbParaLoadCoordinator::writePreviousStatisticsInformation(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| double generateMergeNodesCandidatesTime |
time when merge ParaNode candidates are generated
Definition at line 93 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), and BbParaLoadCoordinator::writeLoadCoordinatorStatisticsToCheckpointFile().
| double globalBestDualBoundValue |
global best dual bound value (internal value)
Definition at line 82 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinator::outputTabularSolvingStatus(), BbParaLoadCoordinator::processRacingRampUpTagCompletionOfCalculation(), BbParaLoadCoordinator::processRacingRampUpTagSolverState(), BbParaLoadCoordinator::processTagAnotherNodeRequest(), BbParaLoadCoordinator::processTagCompletionOfCalculation(), BbParaLoadCoordinator::processTagSelfSlpitNodeCalcuationState(), BbParaLoadCoordinator::processTagSolverState(), BbParaLoadCoordinator::processTagTask(), BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinator::restartRacing(), BbParaLoadCoordinator::run(), BbParaLoadCoordinator::sendParaTasksToIdleSolvers(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinator::updateCheckpointFiles(), BbParaLoadCoordinator::warmStart(), BbParaLoadCoordinatorTerminationState::write(), BbParaLoadCoordinator::writeLoadCoordinatorStatisticsToCheckpointFile(), BbParaLoadCoordinator::writePreviousStatisticsInformation(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| double idleTime |
idle time of this LoadCoordinator
Definition at line 87 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinator::restartInRampDownPhase(), BbParaLoadCoordinator::run(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| double mergeNodeTime |
time when ParaNode is merged
Definition at line 95 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), and BbParaLoadCoordinator::writeLoadCoordinatorStatisticsToCheckpointFile().
| unsigned long long mMaxCollectingNodes |
maximum multiplier for the number of collecting nodes
Definition at line 74 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinatorTerminationState::toString(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| unsigned long long nDeletedByMerging |
number of ParaNodes deleted by merging
Definition at line 69 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinatorTerminationState::toString().
| unsigned long long nDeletedInLc |
number of ParaNodes deleted in LC
Definition at line 68 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinator::processTagAnotherNodeRequest(), BbParaLoadCoordinator::processTagSubtreeRootNodeToBeRemoved(), BbParaLoadCoordinator::processTagTask(), BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinator::sendCutOffValue(), BbParaLoadCoordinator::sendIncumbentValue(), BbParaLoadCoordinator::sendParaTasksToIdleSolvers(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| unsigned long long nFailedToSendBack |
number of ParaNodes failed to send back
Definition at line 70 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinator::processTagSelfSplitTermStateForInterruption(), BbParaLoadCoordinator::processTagTermStateForInterruption(), BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| unsigned long long nFailedToSendBackAnotherNode |
number of ParaNodes failed to send back after AnotherNode request
Definition at line 71 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinator::processTagAnotherNodeRequest(), BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| unsigned long long nInitialP |
initial p value, which indicates the number of good ParaNodes try to keep in LC
Definition at line 73 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinatorTerminationState::toString(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| unsigned long long nMaxUsageOfNodePool |
maximum number of ParaNodes in ParaNodePool
Definition at line 72 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), BbParaLoadCoordinator::writeLoadCoordinatorStatisticsToCheckpointFile(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| unsigned long long nNodesInNodePool |
number of nodes in ParaNodePool
Definition at line 75 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), BbParaLoadCoordinator::writeLoadCoordinatorStatisticsToCheckpointFile(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| unsigned long long nNodesLeftInAllSolvers |
number of nodes left in all Solvers
Definition at line 76 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), BbParaLoadCoordinator::writeLoadCoordinatorStatisticsToCheckpointFile(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| unsigned long long nNodesOutputLog |
count for next logging of the number of transferred ParaNodes
Definition at line 77 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinator::processTagSolverState().
| unsigned long long nSentBackImmediately |
Counters related to this ParaLoadCoordinator TODO: The numbers should be classified depending on solvers.
number of ParaNodes sent back immediately from LC
Definition at line 66 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinator::processTagSelfSplitTermStateForInterruption(), BbParaLoadCoordinator::processTagTermStateForInterruption(), BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| unsigned long long nSentBackImmediatelyAnotherNode |
number of ParaNodes sent back immediately after AnotherNode request from LC
Definition at line 67 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinator::processTagAnotherNodeRequest(), BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| double regenerateMergeNodesCandidatesTime |
time when merge ParaNode candidates are regenerated
Definition at line 94 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), and BbParaLoadCoordinator::writeLoadCoordinatorStatisticsToCheckpointFile().
| double runningTime |
this ParaLoadCoordinator running time
times used for merging
Definition at line 88 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinatorTerminationState::read(), BbParaLoadCoordinatorTerminationState::toString(), BbParaLoadCoordinatorTerminationState::write(), BbParaLoadCoordinator::writeLoadCoordinatorStatisticsToCheckpointFile(), and BbParaLoadCoordinator::~BbParaLoadCoordinator().
| double tNodesOutputLog |
keep time for next logging of the number of transferred ParaNodes
current dual bound value
Definition at line 78 of file bbParaLoadCoordinatorTerminationState.h.
Referenced by BbParaLoadCoordinator::processTagSolverState().