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