DmtcpMessage 120 coordinatorapi.cpp DmtcpMessage msg (DMT_UPDATE_PROCESS_INFO_AFTER_INIT_OR_EXEC); DmtcpMessage 142 coordinatorapi.cpp DmtcpMessage msg (DMT_UPDATE_PROCESS_INFO_AFTER_FORK); DmtcpMessage 225 coordinatorapi.cpp DmtcpMessage msg; DmtcpMessage 226 coordinatorapi.cpp DmtcpMessage reply(DMT_USER_CMD_RESULT); DmtcpMessage 301 coordinatorapi.cpp DmtcpMessage msg, reply; DmtcpMessage 349 coordinatorapi.cpp DmtcpMessage msg(DMT_GET_CKPT_DIR); DmtcpMessage 366 coordinatorapi.cpp DmtcpMessage msg(DMT_UPDATE_CKPT_DIR); DmtcpMessage 479 coordinatorapi.cpp DmtcpMessage CoordinatorAPI::sendRecvHandshake(DmtcpMessage msg, DmtcpMessage 535 coordinatorapi.cpp DmtcpMessage hello_local(DMT_NEW_WORKER); DmtcpMessage 538 coordinatorapi.cpp DmtcpMessage hello_remote = sendRecvHandshake(hello_local, progname); DmtcpMessage 568 coordinatorapi.cpp DmtcpMessage hello_local(DMT_NEW_WORKER); DmtcpMessage 569 coordinatorapi.cpp DmtcpMessage hello_remote = sendRecvHandshake(hello_local, progname); DmtcpMessage 596 coordinatorapi.cpp DmtcpMessage hello_local(DMT_RESTART_WORKER); DmtcpMessage 601 coordinatorapi.cpp DmtcpMessage hello_remote = sendRecvHandshake(hello_local, progname, DmtcpMessage 627 coordinatorapi.cpp DmtcpMessage msg; DmtcpMessage 647 coordinatorapi.cpp DmtcpMessage msg (DMT_REGISTER_NAME_SERVICE_DATA); DmtcpMessage 662 coordinatorapi.cpp DmtcpMessage m(DMT_NAME_SERVICE_WORKER); DmtcpMessage 691 coordinatorapi.cpp DmtcpMessage msg (DMT_NAME_SERVICE_QUERY); DmtcpMessage 708 coordinatorapi.cpp DmtcpMessage m(DMT_NAME_SERVICE_WORKER); DmtcpMessage 82 coordinatorapi.h void sendMsgToCoordinator(const DmtcpMessage &msg, DmtcpMessage 85 coordinatorapi.h void recvMsgFromCoordinator(DmtcpMessage *msg, DmtcpMessage 109 coordinatorapi.h DmtcpMessage sendRecvHandshake(DmtcpMessage msg, string progname, DmtcpMessage 752 dmtcp_coordinator.cpp DmtcpMessage blockUntilDoneReply(DMT_USER_CMD_RESULT); DmtcpMessage 766 dmtcp_coordinator.cpp DmtcpMessage msg; DmtcpMessage 810 dmtcp_coordinator.cpp DmtcpMessage reply(DMT_GET_CKPT_DIR_RESULT); DmtcpMessage 839 dmtcp_coordinator.cpp DmtcpMessage response(DMT_REGISTER_NAME_SERVICE_DATA_SYNC_RESPONSE); DmtcpMessage 969 dmtcp_coordinator.cpp DmtcpMessage hello_remote; DmtcpMessage 1016 dmtcp_coordinator.cpp DmtcpMessage response(DMT_REGISTER_NAME_SERVICE_DATA_SYNC_RESPONSE); DmtcpMessage 1035 dmtcp_coordinator.cpp DmtcpMessage msg; DmtcpMessage 1092 dmtcp_coordinator.cpp DmtcpMessage reply; DmtcpMessage 1124 dmtcp_coordinator.cpp DmtcpMessage hello_local ( DMT_ACCEPT ); DmtcpMessage 1201 dmtcp_coordinator.cpp DmtcpMessage hello_local(DMT_ACCEPT); DmtcpMessage 1223 dmtcp_coordinator.cpp DmtcpMessage suspendMsg (DMT_DO_SUSPEND); DmtcpMessage 1313 dmtcp_coordinator.cpp DmtcpMessage msg; DmtcpMessage 37 dmtcp_coordinator.h DmtcpMessage &hello_remote, DmtcpMessage 57 dmtcp_coordinator.h void readProcessInfo(DmtcpMessage& msg); DmtcpMessage 94 dmtcp_coordinator.h void handleUserCommand(char cmd, DmtcpMessage* reply = NULL); DmtcpMessage 97 dmtcp_coordinator.h void processDmtUserCmd(DmtcpMessage& hello_remote, DmtcpMessage 99 dmtcp_coordinator.h bool validateNewWorkerProcess(DmtcpMessage& hello_remote, DmtcpMessage 104 dmtcp_coordinator.h bool validateRestartingWorkerProcess(DmtcpMessage& hello_remote, DmtcpMessage 38 dmtcpmessagetypes.cpp DmtcpMessage::DmtcpMessage ( DmtcpMessageType t /*= DMT_NULL*/ ) DmtcpMessage 63 dmtcpmessagetypes.cpp void DmtcpMessage::assertValid() const DmtcpMessage 68 dmtcpmessagetypes.cpp JASSERT ( _msgSize == sizeof ( DmtcpMessage ) ) ( _msgSize ) ( sizeof ( DmtcpMessage ) ) DmtcpMessage 72 dmtcpmessagetypes.cpp bool DmtcpMessage::isValid() const DmtcpMessage 79 dmtcpmessagetypes.cpp if (_msgSize == sizeof(DmtcpMessage)) { DmtcpMessage 81 dmtcpmessagetypes.cpp (_msgSize) (sizeof(DmtcpMessage)); DmtcpMessage 87 dmtcpmessagetypes.cpp void DmtcpMessage::poison() { memset ( _magicBits,0,sizeof ( _magicBits ) ); } DmtcpMessage 168 dmtcpmessagetypes.h DmtcpMessage ( DmtcpMessageType t = DMT_NULL ); DmtcpMessage 456 dmtcpworker.cpp DmtcpMessage msg; DmtcpMessage 498 dmtcpworker.cpp DmtcpMessage msg; DmtcpMessage 103 lookup_service.cpp DmtcpMessage reply (DMT_NAME_SERVICE_QUERY_RESPONSE); DmtcpMessage 72 lookup_service.h void registerData(const DmtcpMessage& msg, const void *data); DmtcpMessage 74 lookup_service.h const DmtcpMessage& msg, const void *data);