Scippy

UG

Ubiquity Generator framework

paraComm.h File Reference

Base class of communicator for UG Framework. More...

#include <sstream>
#include "paraDef.h"
#include "paraTagDef.h"
#include "paraParamSet.h"

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
 

Detailed Description

Base class of communicator for UG Framework.

Author
Yuji Shinano

Definition in file paraComm.h.

Macro Definition Documentation

◆ PARA_COMM_CALL

#define PARA_COMM_CALL (   paracommcall)
Value:
{ \
int _status = paracommcall; \
if( _status ) \
{ \
std::ostringstream s_; \
s_ << "[PARA_COMM_CALL ERROR: " << __FILE__ << "] func = " \
<< __func__ << ", line = " << __LINE__ << ": " \
<< "error_code = " << _status << std::endl; \
throw std::logic_error( s_.str() ); \
}\
}

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().