Base class of communicator for UG Framework. More...
Go to the source code of this file.
Classes | |
class | ParaComm |
Base class of communicator object. More... | |
Namespaces | |
UG | |
Macros | |
#define | PARA_COMM_CALL(paracommcall) |
Variables | |
static const int | TYPE_FIRST = 0 |
standard transfer data types More... | |
static const int | ParaCHAR = TYPE_FIRST + 0 |
static const int | ParaSHORT = TYPE_FIRST + 1 |
static const int | ParaINT = TYPE_FIRST + 2 |
static const int | ParaLONG = TYPE_FIRST + 3 |
static const int | ParaLONG_LONG = TYPE_FIRST + 4 |
static const int | ParaSIGNED_CHAR = TYPE_FIRST + 5 |
static const int | ParaUNSIGNED_CHAR = TYPE_FIRST + 6 |
static const int | ParaUNSIGNED_SHORT = TYPE_FIRST + 7 |
static const int | ParaUNSIGNED = TYPE_FIRST + 8 |
static const int | ParaUNSIGNED_LONG = TYPE_FIRST + 9 |
static const int | ParaUNSIGNED_LONG_LONG = TYPE_FIRST + 10 |
static const int | ParaFLOAT = TYPE_FIRST + 11 |
static const int | ParaDOUBLE = TYPE_FIRST + 12 |
static const int | ParaLONG_DOUBLE = TYPE_FIRST + 13 |
static const int | ParaBOOL = TYPE_FIRST + 14 |
static const int | ParaBYTE = TYPE_FIRST + 15 |
static const int | TYPE_LAST = TYPE_FIRST + 15 |
static const int | TYPE_LIST_SIZE = TYPE_LAST - TYPE_FIRST + 1 |
static const int | NumMaxWorkers = 20000 |
Base class of communicator for UG Framework.
Definition in file paraComm.h.
#define PARA_COMM_CALL | ( | paracommcall | ) |
Definition at line 47 of file paraComm.h.
Referenced by BbParaSolverPool::activateSolver(), ScipDiffParamSetMpi::bcast(), ScipDiffParamSetTh::bcast(), ScipParaSolutionTh::bcast(), ScipParaSolutionMpi::bcast(), BbParaNodeTh::bcast(), BbParaNodeMpi::bcast(), ScipParaDiffSubproblemMpi::bcast(), ParaParamSetMpi::bcast(), ScipParaInstanceMpi::bcast(), ScipParaInstanceTh::bcast(), BbParaLoadCoordinator::changeSearchStrategyOfAllSolversToOriginalSearch(), BbParaSolverPool::enforcedSwitchOutCollectingMode(), ScipParaInitiator::init(), BbParaSolver::iReceiveMessages(), ScipParaSolver::lbBoundTightened(), main(), BbParaLoadCoordinator::newRacing(), BbParaSolver::notifySelfSplitFinished(), BbParaLoadCoordinator::processRacingRampUpTagCompletionOfCalculation(), BbParaLoadCoordinator::processRacingRampUpTagSolverState(), BbParaLoadCoordinator::processTagAllowToBeInCollectingMode(), BbParaLoadCoordinator::processTagAnotherNodeRequest(), BbParaSolver::processTagBreaking(), BbParaSolver::processTagCollectAllNodes(), BbParaLoadCoordinator::processTagCompletionOfCalculation(), BbParaSolver::processTagCutOffValue(), BbParaSolver::processTagGivenGapIsReached(), BbParaSolver::processTagGlobalBestDualBoundValueAtWarmStart(), ParaLoadCoordinator::processTagHardTimeLimit(), BbParaSolver::processTagInCollectingMode(), BbParaSolver::processTagIncumbentValue(), BbParaSolver::processTagInterruptRequest(), BbParaSolver::processTagKeepRacing(), BbParaLoadCoordinator::processTagLbBoundTightened(), BbParaSolver::processTagLCBestBoundValue(), BbParaSolver::processTagLightWeightRootNodeProcess(), BbParaSolver::processTagNoNodes(), BbParaSolver::processTagNoTestDualBoundGain(), BbParaSolver::processTagNotificationId(), BbParaSolver::processTagNoWaitModeSend(), BbParaSolver::processTagOutCollectingMode(), BbParaSolver::processTagRampUp(), BbParaSolver::processTagRestart(), BbParaSolver::processTagRetryRampUp(), BbParaLoadCoordinator::processTagSelfSlpitNodeCalcuationState(), BbParaLoadCoordinator::processTagSelfSplitFinished(), BbParaLoadCoordinator::processTagSelfSplitTermStateForInterruption(), BbParaLoadCoordinator::processTagSolverState(), BbParaLoadCoordinator::processTagTask(), BbParaSolver::processTagTaskReceived(), ParaLoadCoordinator::processTagTerminated(), BbParaSolver::processTagTerminateRequest(), BbParaSolver::processTagTerminateSolvingToRestart(), BbParaLoadCoordinator::processTagTermStateForInterruption(), BbParaSolver::processTagTestDualBoundGain(), BbParaSolver::processTagToken(), ParaLoadCoordinator::processTagToken(), BbParaLoadCoordinator::processTagUbBoundTightened(), BbParaSolver::processTagWinner(), BbParaSolver::processTagWinnerRacingRampUpParamSet(), ScipParaRacingRampUpParamSetTh::receive(), ScipParaRacingRampUpParamSetMpi::receive(), ScipDiffParamSetMpi::receive(), ScipDiffParamSetTh::receive(), ScipParaSolutionTh::receive(), ScipParaSolutionMpi::receive(), BbParaSolverStateTh::receive(), BbParaSolverStateMpi::receive(), ScipParaInitialStatTh::receive(), ScipParaInitialStatMpi::receive(), BbParaCalculationStateTh::receive(), BbParaCalculationStateMpi::receive(), ScipParaDiffSubproblemMpi::receive(), BbParaNodeTh::receive(), BbParaNodeMpi::receive(), BbParaSolverTerminationStateTh::receive(), BbParaSolverTerminationStateMpi::receive(), BbParaNodeTh::receiveNewSubtreeRoot(), BbParaNodeMpi::receiveNewSubtreeRoot(), BbParaNodeTh::receiveSubtreeRootNodeId(), BbParaNodeMpi::receiveSubtreeRootNodeId(), BbParaLoadCoordinator::restartRacing(), BbParaSolver::restartRacing(), ParaTimeLimitMonitorTh::run(), BbParaLoadCoordinator::run(), BbParaSolver::run(), runSolverThread(), ScipParaObjCommPointHdlr::scip_exec(), ScipParaRacingRampUpParamSetTh::send(), ScipDiffParamSetMpi::send(), ScipParaRacingRampUpParamSetMpi::send(), ScipDiffParamSetTh::send(), ScipParaSolutionTh::send(), ScipParaSolutionMpi::send(), BbParaSolverStateTh::send(), BbParaSolverStateMpi::send(), BbParaCalculationStateTh::send(), ScipParaInitialStatTh::send(), BbParaCalculationStateMpi::send(), ScipParaInitialStatMpi::send(), BbParaNodeTh::send(), ScipParaDiffSubproblemMpi::send(), BbParaNodeMpi::send(), BbParaSolverTerminationStateTh::send(), BbParaSolverTerminationStateMpi::send(), BbParaSolver::sendAnotherNodeRequest(), BbParaLoadCoordinator::sendCutOffValue(), BbParaLoadCoordinator::sendIncumbentValue(), BbParaLoadCoordinator::sendInterruptRequest(), BbParaNodeTh::sendNewSubtreeRoot(), BbParaNodeMpi::sendNewSubtreeRoot(), BbParaLoadCoordinator::sendParaTasksToIdleSolvers(), ParaLoadCoordinator::sendRampUpToAllSolvers(), BbParaLoadCoordinator::sendRetryRampUpToAllSolvers(), BbParaNodeTh::sendSubtreeRootNodeId(), BbParaNodeMpi::sendSubtreeRootNodeId(), BbParaSolverPool::sendSwitchOutCollectingModeIfNecessary(), ParaLoadCoordinator::sendTagToAllSolvers(), BbParaSolverPoolForMinimization::switchInCollectingMode(), BbParaSolverPool::switchInCollectingToSolver(), BbParaSolverPool::switchOutCollectingMode(), BbParaLoadCoordinator::terminateAllSolvers(), ParaLoadCoordinator::terminateAllSolvers(), ScipParaSolver::ubBoundTightened(), BbParaSolverPoolForMinimization::updateSolverStatus(), and BbParaSolver::waitAckCompletion().