WorkerState 610 dmtcp_coordinator.cpp s.minimumState==WorkerState::RUNNING);
WorkerState 657 dmtcp_coordinator.cpp void DmtcpCoordinator::updateMinimumState(WorkerState oldState)
WorkerState 659 dmtcp_coordinator.cpp WorkerState newState = minimumState();
WorkerState 661 dmtcp_coordinator.cpp if ( oldState == WorkerState::RUNNING
WorkerState 662 dmtcp_coordinator.cpp && newState == WorkerState::SUSPENDED )
WorkerState 667 dmtcp_coordinator.cpp if ( oldState == WorkerState::SUSPENDED
WorkerState 668 dmtcp_coordinator.cpp && newState == WorkerState::FD_LEADER_ELECTION )
WorkerState 673 dmtcp_coordinator.cpp if ( oldState == WorkerState::FD_LEADER_ELECTION
WorkerState 674 dmtcp_coordinator.cpp && newState == WorkerState::DRAINED )
WorkerState 681 dmtcp_coordinator.cpp if ( oldState == WorkerState::DRAINED
WorkerState 682 dmtcp_coordinator.cpp && newState == WorkerState::CHECKPOINTED )
WorkerState 695 dmtcp_coordinator.cpp if ( oldState == WorkerState::RESTARTING
WorkerState 696 dmtcp_coordinator.cpp && newState == WorkerState::CHECKPOINTED )
WorkerState 704 dmtcp_coordinator.cpp if ( oldState == WorkerState::CHECKPOINTED
WorkerState 705 dmtcp_coordinator.cpp && newState == WorkerState::NAME_SERVICE_DATA_REGISTERED ){
WorkerState 709 dmtcp_coordinator.cpp if ( oldState == WorkerState::NAME_SERVICE_DATA_REGISTERED
WorkerState 710 dmtcp_coordinator.cpp && newState == WorkerState::DONE_QUERYING ){
WorkerState 714 dmtcp_coordinator.cpp if ( oldState == WorkerState::DONE_QUERYING
WorkerState 715 dmtcp_coordinator.cpp && newState == WorkerState::REFILLED )
WorkerState 718 dmtcp_coordinator.cpp if ( oldState == WorkerState::DRAINED
WorkerState 719 dmtcp_coordinator.cpp && newState == WorkerState::CHECKPOINTED )
WorkerState 731 dmtcp_coordinator.cpp if ( oldState == WorkerState::RESTARTING
WorkerState 732 dmtcp_coordinator.cpp && newState == WorkerState::CHECKPOINTED )
WorkerState 739 dmtcp_coordinator.cpp if ( oldState == WorkerState::CHECKPOINTED
WorkerState 740 dmtcp_coordinator.cpp && newState == WorkerState::REFILLED )
WorkerState 781 dmtcp_coordinator.cpp WorkerState oldState = client->state();
WorkerState 784 dmtcp_coordinator.cpp WorkerState newState = s.minimumState;
WorkerState 1064 dmtcp_coordinator.cpp JASSERT(hello_remote.state == WorkerState::RUNNING ||
WorkerState 1065 dmtcp_coordinator.cpp hello_remote.state == WorkerState::UNKNOWN);
WorkerState 1126 dmtcp_coordinator.cpp JASSERT(hello_remote.state == WorkerState::RESTARTING) (hello_remote.state);
WorkerState 1129 dmtcp_coordinator.cpp JASSERT ( minimumState() == WorkerState::UNKNOWN )
WorkerState 1140 dmtcp_coordinator.cpp } else if (minimumState() != WorkerState::RESTARTING &&
WorkerState 1141 dmtcp_coordinator.cpp minimumState() != WorkerState::CHECKPOINTED) {
WorkerState 1205 dmtcp_coordinator.cpp JASSERT(hello_remote.state == WorkerState::RUNNING ||
WorkerState 1206 dmtcp_coordinator.cpp hello_remote.state == WorkerState::UNKNOWN) (hello_remote.state);
WorkerState 1215 dmtcp_coordinator.cpp JASSERT(s.minimumState != WorkerState::SUSPENDED) (s.minimumState);
WorkerState 1227 dmtcp_coordinator.cpp } else if (s.numPeers > 0 && s.minimumState != WorkerState::RUNNING &&
WorkerState 1228 dmtcp_coordinator.cpp s.minimumState != WorkerState::UNKNOWN) {
WorkerState 1285 dmtcp_coordinator.cpp if ( s.minimumState == WorkerState::RUNNING && s.minimumStateUnanimous
WorkerState 1337 dmtcp_coordinator.cpp const static int INITIAL_MIN = WorkerState::_MAX;
WorkerState 1338 dmtcp_coordinator.cpp const static int INITIAL_MAX = WorkerState::UNKNOWN;
WorkerState 1351 dmtcp_coordinator.cpp status.minimumState = ( min==INITIAL_MIN ? WorkerState::UNKNOWN
WorkerState 1352 dmtcp_coordinator.cpp : (WorkerState::eWorkerState)min );
WorkerState 1353 dmtcp_coordinator.cpp if( status.minimumState == WorkerState::CHECKPOINTED &&
WorkerState 1357 dmtcp_coordinator.cpp status.minimumState = WorkerState::RESTARTING;
WorkerState 1361 dmtcp_coordinator.cpp status.maximumState = ( max==INITIAL_MAX ? WorkerState::UNKNOWN
WorkerState 1362 dmtcp_coordinator.cpp : (WorkerState::eWorkerState)max );
WorkerState 45 dmtcp_coordinator.h WorkerState state() const { return _state; }
WorkerState 46 dmtcp_coordinator.h void setState ( WorkerState value ) { _state = value; }
WorkerState 63 dmtcp_coordinator.h WorkerState _state;
WorkerState 76 dmtcp_coordinator.h WorkerState minimumState;
WorkerState 77 dmtcp_coordinator.h WorkerState maximumState;
WorkerState 89 dmtcp_coordinator.h void updateMinimumState(WorkerState oldState);
WorkerState 110 dmtcp_coordinator.h WorkerState minimumState() const { return getStatus().minimumState; }
WorkerState 764 dmtcp_restart.cpp WorkerState::setCurrentState(WorkerState::RESTARTING);
WorkerState 26 dmtcpmessagetypes.cpp static WorkerState theState ( WorkerState::RUNNING );
WorkerState 28 dmtcpmessagetypes.cpp WorkerState WorkerState::currentState()
WorkerState 33 dmtcpmessagetypes.cpp void WorkerState::setCurrentState ( const WorkerState& theValue )
WorkerState 42 dmtcpmessagetypes.cpp ,state ( WorkerState::currentState() )
WorkerState 90 dmtcpmessagetypes.cpp WorkerState::eWorkerState WorkerState::value() const
WorkerState 96 dmtcpmessagetypes.cpp ostream& dmtcp::operator << ( dmtcp::ostream& o, const WorkerState& s )
WorkerState 101 dmtcpmessagetypes.cpp #define OSHIFTPRINTF(name) case WorkerState::name: o << #name; break;
WorkerState 120 dmtcpmessagetypes.cpp const char* WorkerState::toString() const{
WorkerState 91 dmtcpmessagetypes.h class WorkerState
WorkerState 115 dmtcpmessagetypes.h WorkerState ( eWorkerState s = UNKNOWN ) : _state ( s ) {}
WorkerState 117 dmtcpmessagetypes.h static void setCurrentState ( const WorkerState& theValue );
WorkerState 118 dmtcpmessagetypes.h static WorkerState currentState();
WorkerState 122 dmtcpmessagetypes.h bool operator== ( const WorkerState& v ) const{return _state == v.value();}
WorkerState 123 dmtcpmessagetypes.h bool operator!= ( const WorkerState& v ) const{return _state != v.value();}
WorkerState 142 dmtcpmessagetypes.h WorkerState state;
WorkerState 175 dmtcpmessagetypes.h dmtcp::ostream& operator << ( dmtcp::ostream& o, const WorkerState& s );
WorkerState 296 dmtcpplugin.cpp return WorkerState::currentState() == WorkerState::RUNNING;
WorkerState 310 dmtcpworker.cpp WorkerState::setCurrentState(WorkerState::UNKNOWN);
WorkerState 345 dmtcpworker.cpp WorkerState::setCurrentState (WorkerState::RUNNING);
WorkerState 381 dmtcpworker.cpp WorkerState::setCurrentState ( WorkerState::RUNNING );
WorkerState 388 dmtcpworker.cpp WorkerState::setCurrentState(WorkerState::UNKNOWN);
WorkerState 464 dmtcpworker.cpp msg.state = WorkerState::currentState();
WorkerState 500 dmtcpworker.cpp JASSERT(WorkerState::currentState() == WorkerState::RUNNING);
WorkerState 503 dmtcpworker.cpp msg.state = WorkerState::currentState();
WorkerState 511 dmtcpworker.cpp WorkerState::setCurrentState (WorkerState::RUNNING);
WorkerState 523 dmtcpworker.cpp WorkerState::setCurrentState (WorkerState::SUSPENDED);
WorkerState 540 dmtcpworker.cpp WorkerState::setCurrentState (WorkerState::FD_LEADER_ELECTION);
WorkerState 544 dmtcpworker.cpp WorkerState::setCurrentState (WorkerState::DRAINED);
WorkerState 562 dmtcpworker.cpp WorkerState::setCurrentState (WorkerState::CHECKPOINTED);
WorkerState 570 dmtcpworker.cpp WorkerState::setCurrentState(WorkerState::NAME_SERVICE_DATA_REGISTERED);
WorkerState 575 dmtcpworker.cpp WorkerState::setCurrentState(WorkerState::DONE_QUERYING);
WorkerState 587 dmtcpworker.cpp WorkerState::setCurrentState (WorkerState::REFILLED);
WorkerState 64 execwrappers.cpp if (WorkerState::currentState() != WorkerState::UNKNOWN &&
WorkerState 65 execwrappers.cpp WorkerState::currentState() != WorkerState::RUNNING) {
WorkerState 88 mtcpinterface.cpp WorkerState::setCurrentState(WorkerState::RESTARTING);
WorkerState 101 mtcpinterface.cpp WorkerState::setCurrentState( WorkerState::RUNNING );
WorkerState 130 threadsync.cpp JASSERT(WorkerState::currentState() == WorkerState::RUNNING);
WorkerState 165 threadsync.cpp JASSERT(WorkerState::currentState() == WorkerState::SUSPENDED);
WorkerState 343 threadsync.cpp if (WorkerState::currentState() == WorkerState::RUNNING &&
WorkerState 358 threadsync.cpp JASSERT (WorkerState::currentState() == WorkerState::RUNNING);
WorkerState 376 threadsync.cpp if (WorkerState::currentState() == WorkerState::RUNNING &&
WorkerState 450 threadsync.cpp if (WorkerState::currentState() == WorkerState::RUNNING) {
WorkerState 509 threadsync.cpp if (WorkerState::currentState() == WorkerState::RUNNING) {
WorkerState 541 threadsync.cpp if (WorkerState::currentState() != WorkerState::RUNNING) {
WorkerState 589 threadsync.cpp if (WorkerState::currentState() == WorkerState::RUNNING) {
WorkerState 603 threadsync.cpp if (WorkerState::currentState() == WorkerState::RUNNING) {