hello_remote 538 coordinatorapi.cpp DmtcpMessage hello_remote = sendRecvHandshake(hello_local, progname);
hello_remote 540 coordinatorapi.cpp JASSERT(hello_remote.virtualPid != -1);
hello_remote 541 coordinatorapi.cpp JTRACE("Got virtual pid from coordinator") (hello_remote.virtualPid);
hello_remote 544 coordinatorapi.cpp Util::setVirtualPidEnvVar(hello_remote.virtualPid, ppid, ppid);
hello_remote 547 coordinatorapi.cpp *compId = hello_remote.compGroup.upid();
hello_remote 548 coordinatorapi.cpp coordInfo->id = hello_remote.from.upid();
hello_remote 549 coordinatorapi.cpp coordInfo->timeStamp = hello_remote.coordTimeStamp;
hello_remote 555 coordinatorapi.cpp memcpy(localIP, &hello_remote.ipAddr, sizeof hello_remote.ipAddr);
hello_remote 569 coordinatorapi.cpp DmtcpMessage hello_remote = sendRecvHandshake(hello_local, progname);
hello_remote 570 coordinatorapi.cpp JASSERT(hello_remote.virtualPid != -1);
hello_remote 573 coordinatorapi.cpp JTRACE("Got virtual pid from coordinator") (hello_remote.virtualPid);
hello_remote 576 coordinatorapi.cpp Util::setVirtualPidEnvVar(hello_remote.virtualPid, pid, realPid);
hello_remote 601 coordinatorapi.cpp DmtcpMessage hello_remote = sendRecvHandshake(hello_local, progname,
hello_remote 605 coordinatorapi.cpp coordInfo->id = hello_remote.from.upid();
hello_remote 606 coordinatorapi.cpp coordInfo->timeStamp = hello_remote.coordTimeStamp;
hello_remote 614 coordinatorapi.cpp memcpy(localIP, &hello_remote.ipAddr, sizeof hello_remote.ipAddr);
hello_remote 488 dmtcp_coordinator.cpp DmtcpMessage &hello_remote,
hello_remote 493 dmtcp_coordinator.cpp _realPid = hello_remote.realPid;
hello_remote 495 dmtcp_coordinator.cpp _identity = hello_remote.from;
hello_remote 496 dmtcp_coordinator.cpp _state = hello_remote.state;
hello_remote 969 dmtcp_coordinator.cpp DmtcpMessage hello_remote;
hello_remote 970 dmtcp_coordinator.cpp hello_remote.poison();
hello_remote 972 dmtcp_coordinator.cpp remote >> hello_remote;
hello_remote 979 dmtcp_coordinator.cpp if (hello_remote.type == DMT_NAME_SERVICE_WORKER) {
hello_remote 981 dmtcp_coordinator.cpp hello_remote);
hello_remote 986 dmtcp_coordinator.cpp if (hello_remote.type == DMT_NAME_SERVICE_QUERY) {
hello_remote 987 dmtcp_coordinator.cpp JASSERT(hello_remote.extraBytes > 0) (hello_remote.extraBytes);
hello_remote 988 dmtcp_coordinator.cpp char *extraData = new char[hello_remote.extraBytes];
hello_remote 989 dmtcp_coordinator.cpp remote.readAll(extraData, hello_remote.extraBytes);
hello_remote 991 dmtcp_coordinator.cpp JTRACE ("received NAME_SERVICE_QUERY msg on running") (hello_remote.from);
hello_remote 992 dmtcp_coordinator.cpp lookupService.respondToQuery(remote, hello_remote, extraData);
hello_remote 997 dmtcp_coordinator.cpp if (hello_remote.type == DMT_REGISTER_NAME_SERVICE_DATA) {
hello_remote 998 dmtcp_coordinator.cpp JASSERT(hello_remote.extraBytes > 0) (hello_remote.extraBytes);
hello_remote 999 dmtcp_coordinator.cpp char *extraData = new char[hello_remote.extraBytes];
hello_remote 1000 dmtcp_coordinator.cpp remote.readAll(extraData, hello_remote.extraBytes);
hello_remote 1002 dmtcp_coordinator.cpp JTRACE ("received REGISTER_NAME_SERVICE_DATA msg on running") (hello_remote.from);
hello_remote 1003 dmtcp_coordinator.cpp lookupService.registerData(hello_remote, (const void*) extraData);
hello_remote 1008 dmtcp_coordinator.cpp if (hello_remote.type == DMT_REGISTER_NAME_SERVICE_DATA_SYNC) {
hello_remote 1009 dmtcp_coordinator.cpp JASSERT(hello_remote.extraBytes > 0) (hello_remote.extraBytes);
hello_remote 1010 dmtcp_coordinator.cpp char *extraData = new char[hello_remote.extraBytes];
hello_remote 1011 dmtcp_coordinator.cpp remote.readAll(extraData, hello_remote.extraBytes);
hello_remote 1013 dmtcp_coordinator.cpp JTRACE ("received REGISTER_NAME_SERVICE_DATA msg on running") (hello_remote.from);
hello_remote 1014 dmtcp_coordinator.cpp lookupService.registerData(hello_remote, (const void*) extraData);
hello_remote 1024 dmtcp_coordinator.cpp if (hello_remote.type == DMT_USER_CMD) {
hello_remote 1027 dmtcp_coordinator.cpp updateCheckpointInterval(hello_remote.theCheckpointInterval);
hello_remote 1028 dmtcp_coordinator.cpp processDmtUserCmd(hello_remote, remote);
hello_remote 1049 dmtcp_coordinator.cpp hello_remote);
hello_remote 1051 dmtcp_coordinator.cpp if( hello_remote.extraBytes > 0 ){
hello_remote 1052 dmtcp_coordinator.cpp client->readProcessInfo(hello_remote);
hello_remote 1055 dmtcp_coordinator.cpp if (hello_remote.type == DMT_RESTART_WORKER) {
hello_remote 1056 dmtcp_coordinator.cpp if (!validateRestartingWorkerProcess(hello_remote, remote,
hello_remote 1060 dmtcp_coordinator.cpp client->virtualPid(hello_remote.from.pid());
hello_remote 1063 dmtcp_coordinator.cpp } else if (hello_remote.type == DMT_NEW_WORKER) {
hello_remote 1064 dmtcp_coordinator.cpp JASSERT(hello_remote.state == WorkerState::RUNNING ||
hello_remote 1065 dmtcp_coordinator.cpp hello_remote.state == WorkerState::UNKNOWN);
hello_remote 1066 dmtcp_coordinator.cpp JASSERT(hello_remote.virtualPid == -1);
hello_remote 1068 dmtcp_coordinator.cpp if (!validateNewWorkerProcess(hello_remote, remote, client,
hello_remote 1074 dmtcp_coordinator.cpp JASSERT(false) (hello_remote.type)
hello_remote 1078 dmtcp_coordinator.cpp updateCheckpointInterval(hello_remote.theCheckpointInterval);
hello_remote 1079 dmtcp_coordinator.cpp JNOTE ( "worker connected" ) ( hello_remote.from );
hello_remote 1087 dmtcp_coordinator.cpp void DmtcpCoordinator::processDmtUserCmd(DmtcpMessage& hello_remote,
hello_remote 1091 dmtcp_coordinator.cpp JTRACE("got user command from dmtcp_command")(hello_remote.coordCmd);
hello_remote 1096 dmtcp_coordinator.cpp hello_remote.coordCmd == 'c') {
hello_remote 1099 dmtcp_coordinator.cpp handleUserCommand( hello_remote.coordCmd, &reply );
hello_remote 1100 dmtcp_coordinator.cpp } else if ( (hello_remote.coordCmd == 'i')
hello_remote 1101 dmtcp_coordinator.cpp && hello_remote.theCheckpointInterval >= 0 ) {
hello_remote 1104 dmtcp_coordinator.cpp handleUserCommand( hello_remote.coordCmd, &reply );
hello_remote 1108 dmtcp_coordinator.cpp handleUserCommand( hello_remote.coordCmd, &reply );
hello_remote 1116 dmtcp_coordinator.cpp DmtcpMessage& hello_remote,
hello_remote 1126 dmtcp_coordinator.cpp JASSERT(hello_remote.state == WorkerState::RESTARTING) (hello_remote.state);
hello_remote 1132 dmtcp_coordinator.cpp compId = hello_remote.compGroup;
hello_remote 1133 dmtcp_coordinator.cpp numPeers = hello_remote.numPeers;
hello_remote 1144 dmtcp_coordinator.cpp (compId) (hello_remote.compGroup) (minimumState());
hello_remote 1149 dmtcp_coordinator.cpp } else if ( hello_remote.compGroup != compId) {
hello_remote 1152 dmtcp_coordinator.cpp ( compId ) ( hello_remote.compGroup );
hello_remote 1163 dmtcp_coordinator.cpp ( compId ) ( hello_remote.compGroup ) ( minimumState() );
hello_remote 1193 dmtcp_coordinator.cpp DmtcpMessage& hello_remote,
hello_remote 1205 dmtcp_coordinator.cpp JASSERT(hello_remote.state == WorkerState::RUNNING ||
hello_remote 1206 dmtcp_coordinator.cpp hello_remote.state == WorkerState::UNKNOWN) (hello_remote.state);
hello_remote 1232 dmtcp_coordinator.cpp (compId) (hello_remote.from)
hello_remote 1239 dmtcp_coordinator.cpp } else if (hello_remote.compGroup != UniquePid()) {
hello_remote 1243 dmtcp_coordinator.cpp (hello_remote.compGroup);
hello_remote 1255 dmtcp_coordinator.cpp compId = UniquePid(hello_remote.from.hostid(), client->virtualPid(),
hello_remote 1256 dmtcp_coordinator.cpp hello_remote.from.time(),
hello_remote 1257 dmtcp_coordinator.cpp hello_remote.from.computationGeneration());
hello_remote 1267 dmtcp_coordinator.cpp (hello_remote.from) (client->virtualPid());
hello_remote 37 dmtcp_coordinator.h DmtcpMessage &hello_remote,
hello_remote 97 dmtcp_coordinator.h void processDmtUserCmd(DmtcpMessage& hello_remote,
hello_remote 99 dmtcp_coordinator.h bool validateNewWorkerProcess(DmtcpMessage& hello_remote,
hello_remote 104 dmtcp_coordinator.h bool validateRestartingWorkerProcess(DmtcpMessage& hello_remote,