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;