37 #ifndef __PARA_SOLVER_TERMINATION_STATE_H__ 38 #define __PARA_SOLVER_TERMINATION_STATE_H__ 92 nParaTasksReceived(-1),
95 idleTimeToFirstParaTask(0.0),
96 idleTimeBetweenParaTasks(0.0),
97 idleTimeAfterLastParaTask(0.0),
98 idleTimeToWaitNotificationId(0.0),
99 idleTimeToWaitAckCompletion(0.0),
100 idleTimeToWaitToken(0.0),
115 int inNParaTasksReceived,
116 int inNParaTasksSolved,
117 double inRunningTime,
118 double inIdleTimeToFirstParaTask,
119 double inIdleTimeBetweenParaTasks,
120 double inIddleTimeAfterLastParaTask,
121 double inIdleTimeToWaitNotificationId,
122 double inIdleTimeToWaitAckCompletion,
123 double inIdleTimeToWaitToken,
126 : interrupted(inInterrupted),
128 nParaTasksReceived(inNParaTasksReceived),
129 nParaTasksSolved(inNParaTasksSolved),
130 runningTime(inRunningTime),
131 idleTimeToFirstParaTask(inIdleTimeToFirstParaTask),
132 idleTimeBetweenParaTasks(inIdleTimeBetweenParaTasks),
133 idleTimeAfterLastParaTask(inIddleTimeAfterLastParaTask),
134 idleTimeToWaitNotificationId(inIdleTimeToWaitNotificationId),
135 idleTimeToWaitAckCompletion(inIdleTimeToWaitAckCompletion),
136 idleTimeToWaitToken(inIdleTimeToWaitToken),
183 gzstream::ogzstream &out
191 gzstream::igzstream &in
220 #endif // __PARA_SOLVER_TERMINATION_STATE_H__ int interrupted
indicate that this solver is interrupted or not. 0: not interrupted, 1: interrupted, 2: checkpoint, 3: racing-ramp up
virtual std::string toString(ParaInitiator *initiator)=0
stringfy ParaSolverTerminationState object
static ScipParaCommTh * comm
int getInterruptedMode()
getter of interrupted flag
ParaSolverTerminationState(int inInterrupted, int inRank, int inNParaTasksReceived, int inNParaTasksSolved, double inRunningTime, double inIdleTimeToFirstParaTask, double inIdleTimeBetweenParaTasks, double inIddleTimeAfterLastParaTask, double inIdleTimeToWaitNotificationId, double inIdleTimeToWaitAckCompletion, double inIdleTimeToWaitToken, double inDetTime)
constructor
int rank
rank of this solver Counters related to this ParaSolver
double getDeterministicTime()
getter of deterministic time
int nParaTasksReceived
number of ParaTasks received in this ParaSolver
int nParaTasksSolved
number of ParaTasks solved ( received ) in this ParaSolvere times of this solver
virtual void receive(ParaComm *comm, int source, int tag)=0
receive this object
double idleTimeToWaitAckCompletion
idle time to wait ack completion message
double idleTimeToFirstParaTask
idle time to start solving the first ParaTask
double idleTimeAfterLastParaTask
idle time after the last ParaTask was solved
double runningTime
this solver running time
Base class of communicator for UG Framework.
virtual void send(ParaComm *comm, int destination, int tag)=0
send this object
class ParaSolverTerminationState (Solver termination state in a ParaSolver)
virtual ~ParaSolverTerminationState()
destructor
double idleTimeToWaitNotificationId
idle time to wait notification Id messages
void read(ParaComm *comm, const char *filename)
read ParaParams from file
ParaSolverTerminationState()
default constructor
Base class of initiator that maintains original problem and incumbent solution.
double detTime
deterministic time, -1: should be non-deterministic
double idleTimeToWaitToken
idle time to wait token times for root task process
Base class of communicator object.
double idleTimeBetweenParaTasks
idle time between ParaTasks processing