numPeers 248 coordinatorapi.cpp reply.numPeers = 1; numPeers 331 coordinatorapi.cpp if (numPeers != NULL) { numPeers 332 coordinatorapi.cpp *numPeers = reply.numPeers; numPeers 598 coordinatorapi.cpp hello_local.numPeers = np; numPeers 89 coordinatorapi.h int *numPeers = NULL, numPeers 131 dmtcp_command.cpp int numPeers; numPeers 154 dmtcp_command.cpp &numPeers, &isRunning, &ckptInterval); numPeers 200 dmtcp_command.cpp printf(" NUM_PEERS=%d\n", numPeers); numPeers 460 dmtcp_coordinator.cpp static int numPeers = -1; numPeers 547 dmtcp_coordinator.cpp if (reply != NULL) reply->numPeers = getStatus().numPeers; numPeers 612 dmtcp_coordinator.cpp reply->numPeers = s.numPeers; numPeers 616 dmtcp_coordinator.cpp printStatus(s.numPeers, running); numPeers 651 dmtcp_coordinator.cpp << "NUM_PEERS=" << numPeers << std::endl numPeers 665 dmtcp_coordinator.cpp broadcastMessage(DMT_DO_FD_LEADER_ELECTION, getStatus().numPeers ); numPeers 918 dmtcp_coordinator.cpp if (s.numPeers < 1) { numPeers 952 dmtcp_coordinator.cpp numPeers = -1; // Drop number of peers to unknown numPeers 1133 dmtcp_coordinator.cpp numPeers = hello_remote.numPeers; numPeers 1138 dmtcp_coordinator.cpp ( numPeers ) ( curTimeStamp ) ( compId ); numPeers 1214 dmtcp_coordinator.cpp JASSERT(s.numPeers > 0) (s.numPeers); numPeers 1227 dmtcp_coordinator.cpp } else if (s.numPeers > 0 && s.minimumState != WorkerState::RUNNING && numPeers 1233 dmtcp_coordinator.cpp (s.numPeers) (s.minimumState); numPeers 1262 dmtcp_coordinator.cpp numPeers = -1; numPeers 1291 dmtcp_coordinator.cpp JNOTE ( "starting checkpoint, suspending all nodes" )( s.numPeers ); numPeers 1303 dmtcp_coordinator.cpp if (s.numPeers > 0) { numPeers 1305 dmtcp_coordinator.cpp ( s.numPeers ); numPeers 1316 dmtcp_coordinator.cpp if (numPeers > 0) { numPeers 1317 dmtcp_coordinator.cpp msg.numPeers = numPeers; numPeers 1354 dmtcp_coordinator.cpp isRestarting && count < numPeers ){ numPeers 1356 dmtcp_coordinator.cpp " are connected yet. So we wait.") ( numPeers ) ( count ); numPeers 1363 dmtcp_coordinator.cpp status.numPeers = count; numPeers 1429 dmtcp_coordinator.cpp _restartFilenames.size(), getStatus().numPeers ); numPeers 79 dmtcp_coordinator.h int numPeers; numPeers 91 dmtcp_coordinator.h void broadcastMessage(DmtcpMessageType type, int numPeers = -1); numPeers 95 dmtcp_coordinator.h void printStatus(size_t numPeers, bool isRunning); numPeers 138 dmtcp_restart.cpp JTRACE("restore target") (_path) (_pInfo.numPeers()) (_pInfo.compGroup()); numPeers 150 dmtcp_restart.cpp int numPeers() { return _pInfo.numPeers(); } numPeers 211 dmtcp_restart.cpp _pInfo.numPeers(), numPeers 327 dmtcp_restart.cpp _pInfo.numPeers(), numPeers 48 dmtcpmessagetypes.cpp ,numPeers(0) numPeers 156 dmtcpmessagetypes.h uint32_t numPeers; numPeers 74 dmtcpplugin.cpp coordinatorAPI.connectAndSendUserCommand(c, coordCmdStatus, numPeers, numPeers 136 dmtcpplugin.cpp runCoordinatorCmd('s', &coordCmdStatus, numPeers, isRunning); numPeers 438 dmtcpworker.cpp ProcessInfo::instance().numPeers(1); numPeers 490 dmtcpworker.cpp JTRACE("Computation information") (msg.compGroup) (msg.numPeers); numPeers 492 dmtcpworker.cpp ProcessInfo::instance().numPeers(msg.numPeers); numPeers 76 processinfo.h uint32_t numPeers() { return _numPeers; } numPeers 77 processinfo.h void numPeers(uint32_t np) { _numPeers = np; }