reply 226 coordinatorapi.cpp DmtcpMessage reply(DMT_USER_CMD_RESULT); reply 238 coordinatorapi.cpp reply.coordCmdStatus = CoordCmdStatus::NOERROR; reply 248 coordinatorapi.cpp reply.numPeers = 1; reply 249 coordinatorapi.cpp reply.isRunning = 1; reply 261 coordinatorapi.cpp reply.coordCmdStatus = CoordCmdStatus::ERROR_INVALID_COMMAND; reply 263 coordinatorapi.cpp cmdSock << reply; reply 301 coordinatorapi.cpp DmtcpMessage msg, reply; reply 323 coordinatorapi.cpp reply.poison(); reply 324 coordinatorapi.cpp _coordinatorSocket >> reply; reply 325 coordinatorapi.cpp reply.assertValid(); reply 326 coordinatorapi.cpp JASSERT(reply.type == DMT_USER_CMD_RESULT); reply 329 coordinatorapi.cpp *coordCmdStatus = reply.coordCmdStatus; reply 332 coordinatorapi.cpp *numPeers = reply.numPeers; reply 335 coordinatorapi.cpp *isRunning = reply.isRunning; reply 338 coordinatorapi.cpp *ckptInterval = reply.theCheckpointInterval; reply 531 dmtcp_coordinator.cpp void DmtcpCoordinator::handleUserCommand(char cmd, DmtcpMessage* reply /*= NULL*/) reply 533 dmtcp_coordinator.cpp if (reply != NULL) reply->coordCmdStatus = CoordCmdStatus::NOERROR; reply 547 dmtcp_coordinator.cpp if (reply != NULL) reply->numPeers = getStatus().numPeers; reply 549 dmtcp_coordinator.cpp if (reply != NULL) reply->coordCmdStatus = CoordCmdStatus::ERROR_NOT_RUNNING_STATE; reply 611 dmtcp_coordinator.cpp if (reply != NULL) { reply 612 dmtcp_coordinator.cpp reply->numPeers = s.numPeers; reply 613 dmtcp_coordinator.cpp reply->isRunning = running; reply 614 dmtcp_coordinator.cpp reply->theCheckpointInterval = theCheckpointInterval; reply 625 dmtcp_coordinator.cpp if (reply != NULL){ reply 626 dmtcp_coordinator.cpp reply->coordCmdStatus = CoordCmdStatus::ERROR_INVALID_COMMAND; reply 810 dmtcp_coordinator.cpp DmtcpMessage reply(DMT_GET_CKPT_DIR_RESULT); reply 811 dmtcp_coordinator.cpp reply.extraBytes = ckptDir.length() + 1; reply 812 dmtcp_coordinator.cpp client->sock() << reply; reply 813 dmtcp_coordinator.cpp client->sock().writeAll(ckptDir.c_str(), reply.extraBytes); reply 1092 dmtcp_coordinator.cpp DmtcpMessage reply; reply 1093 dmtcp_coordinator.cpp reply.type = DMT_USER_CMD_RESULT; reply 1099 dmtcp_coordinator.cpp handleUserCommand( hello_remote.coordCmd, &reply ); reply 1104 dmtcp_coordinator.cpp handleUserCommand( hello_remote.coordCmd, &reply ); reply 1105 dmtcp_coordinator.cpp remote << reply; reply 1108 dmtcp_coordinator.cpp handleUserCommand( hello_remote.coordCmd, &reply ); reply 1109 dmtcp_coordinator.cpp remote << reply; reply 94 dmtcp_coordinator.h void handleUserCommand(char cmd, DmtcpMessage* reply = NULL); reply 103 lookup_service.cpp DmtcpMessage reply (DMT_NAME_SERVICE_QUERY_RESPONSE); reply 104 lookup_service.cpp reply.keyLen = 0; reply 105 lookup_service.cpp reply.valLen = valLen; reply 106 lookup_service.cpp reply.extraBytes = reply.valLen; reply 108 lookup_service.cpp remote << reply;