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; }