msg 120 coordinatorapi.cpp DmtcpMessage msg (DMT_UPDATE_PROCESS_INFO_AFTER_INIT_OR_EXEC);
msg 122 coordinatorapi.cpp msg.extraBytes = progname.length() + 1;
msg 126 coordinatorapi.cpp instance()._coordinatorSocket << msg;
msg 142 coordinatorapi.cpp DmtcpMessage msg (DMT_UPDATE_PROCESS_INFO_AFTER_FORK);
msg 144 coordinatorapi.cpp msg.realPid = dmtcp_virtual_to_real_pid(getpid());
msg 146 coordinatorapi.cpp msg.realPid = getpid();
msg 148 coordinatorapi.cpp instance()._coordinatorSocket << msg;
msg 225 coordinatorapi.cpp DmtcpMessage msg;
msg 230 coordinatorapi.cpp msg.poison();
msg 232 coordinatorapi.cpp cmdSock >> msg;
msg 235 coordinatorapi.cpp JASSERT(msg.type == DMT_USER_CMD) (msg.type)
msg 241 coordinatorapi.cpp switch (msg.coordCmd) {
msg 260 coordinatorapi.cpp JTRACE("unhandled user command") (msg.coordCmd);
msg 301 coordinatorapi.cpp DmtcpMessage msg, reply;
msg 304 coordinatorapi.cpp msg.type = DMT_USER_CMD;
msg 305 coordinatorapi.cpp msg.coordCmd = c;
msg 310 coordinatorapi.cpp msg.theCheckpointInterval = jalib::StringToInt (interval);
msg 314 coordinatorapi.cpp _coordinatorSocket << msg;
msg 349 coordinatorapi.cpp DmtcpMessage msg(DMT_GET_CKPT_DIR);
msg 350 coordinatorapi.cpp _coordinatorSocket << msg;
msg 352 coordinatorapi.cpp msg.poison();
msg 353 coordinatorapi.cpp _coordinatorSocket >> msg;
msg 354 coordinatorapi.cpp msg.assertValid();
msg 355 coordinatorapi.cpp JASSERT(msg.type == DMT_GET_CKPT_DIR_RESULT) (msg.type);
msg 357 coordinatorapi.cpp JASSERT(msg.extraBytes > 0);
msg 358 coordinatorapi.cpp _coordinatorSocket.readAll(buf, msg.extraBytes);
msg 366 coordinatorapi.cpp DmtcpMessage msg(DMT_UPDATE_CKPT_DIR);
msg 367 coordinatorapi.cpp msg.extraBytes = strlen(dir) + 1;
msg 368 coordinatorapi.cpp _coordinatorSocket << msg;
msg 372 coordinatorapi.cpp void CoordinatorAPI::sendMsgToCoordinator(const DmtcpMessage &msg,
msg 377 coordinatorapi.cpp _coordinatorSocket << msg;
msg 378 coordinatorapi.cpp if (msg.extraBytes > 0) {
msg 380 coordinatorapi.cpp JASSERT(len == msg.extraBytes);
msg 381 coordinatorapi.cpp _coordinatorSocket.writeAll((const char *)extraData, msg.extraBytes);
msg 385 coordinatorapi.cpp void CoordinatorAPI::recvMsgFromCoordinator(DmtcpMessage *msg, void **extraData)
msg 388 coordinatorapi.cpp msg->poison();
msg 389 coordinatorapi.cpp _coordinatorSocket >> (*msg);
msg 392 coordinatorapi.cpp msg->assertValid();
msg 393 coordinatorapi.cpp JASSERT(msg->extraBytes > 0);
msg 395 coordinatorapi.cpp void *buf = JALLOC_HELPER_MALLOC(msg->extraBytes);
msg 396 coordinatorapi.cpp _coordinatorSocket.readAll((char*)buf, msg->extraBytes);
msg 479 coordinatorapi.cpp DmtcpMessage CoordinatorAPI::sendRecvHandshake(DmtcpMessage msg,
msg 484 coordinatorapi.cpp msg.realPid = dmtcp_virtual_to_real_pid(getpid());
msg 486 coordinatorapi.cpp msg.realPid = getpid();
msg 489 coordinatorapi.cpp msg.theCheckpointInterval = getCkptInterval();
msg 491 coordinatorapi.cpp msg.extraBytes = hostname.length() + 1 + progname.length() + 1;
msg 493 coordinatorapi.cpp _coordinatorSocket << msg;
msg 497 coordinatorapi.cpp msg.poison();
msg 498 coordinatorapi.cpp _coordinatorSocket >> msg;
msg 499 coordinatorapi.cpp msg.assertValid();
msg 500 coordinatorapi.cpp if (msg.type == DMT_KILL_PEER) {
msg 504 coordinatorapi.cpp if (msg.type == DMT_REJECT_NOT_RUNNING) {
msg 509 coordinatorapi.cpp } else if (msg.type == DMT_REJECT_WRONG_COMP) {
msg 515 coordinatorapi.cpp JASSERT(msg.type == DMT_ACCEPT);
msg 516 coordinatorapi.cpp return msg;
msg 627 coordinatorapi.cpp DmtcpMessage msg;
msg 629 coordinatorapi.cpp msg.type = DMT_UNIQUE_CKPT_FILENAME;
msg 631 coordinatorapi.cpp msg.type = DMT_CKPT_FILENAME;
msg 633 coordinatorapi.cpp msg.extraBytes = ckptFilename.length() + 1 + hostname.length() + 1;
msg 634 coordinatorapi.cpp _coordinatorSocket << msg;
msg 647 coordinatorapi.cpp DmtcpMessage msg (DMT_REGISTER_NAME_SERVICE_DATA);
msg 649 coordinatorapi.cpp msg.type = DMT_REGISTER_NAME_SERVICE_DATA_SYNC;
msg 651 coordinatorapi.cpp JWARNING(strlen(id) < sizeof(msg.nsid));
msg 652 coordinatorapi.cpp strncpy(msg.nsid, id, 8);
msg 653 coordinatorapi.cpp msg.keyLen = key_len;
msg 654 coordinatorapi.cpp msg.valLen = val_len;
msg 655 coordinatorapi.cpp msg.extraBytes = key_len + val_len;
msg 669 coordinatorapi.cpp sock << msg;
msg 673 coordinatorapi.cpp msg.poison();
msg 674 coordinatorapi.cpp sock >> msg;
msg 675 coordinatorapi.cpp JASSERT(msg.type == DMT_REGISTER_NAME_SERVICE_DATA_SYNC_RESPONSE)(msg.type);
msg 691 coordinatorapi.cpp DmtcpMessage msg (DMT_NAME_SERVICE_QUERY);
msg 692 coordinatorapi.cpp JWARNING(strlen(id) < sizeof(msg.nsid));
msg 693 coordinatorapi.cpp strncpy(msg.nsid, id, 8);
msg 694 coordinatorapi.cpp msg.keyLen = key_len;
msg 695 coordinatorapi.cpp msg.valLen = 0;
msg 696 coordinatorapi.cpp msg.extraBytes = key_len;
msg 715 coordinatorapi.cpp sock << msg;
msg 718 coordinatorapi.cpp msg.poison();
msg 719 coordinatorapi.cpp sock >> msg;
msg 720 coordinatorapi.cpp msg.assertValid();
msg 721 coordinatorapi.cpp JASSERT(msg.type == DMT_NAME_SERVICE_QUERY_RESPONSE &&
msg 722 coordinatorapi.cpp msg.extraBytes == msg.valLen);
msg 724 coordinatorapi.cpp JASSERT (*val_len >= msg.valLen);
msg 725 coordinatorapi.cpp *val_len = msg.valLen;
msg 82 coordinatorapi.h void sendMsgToCoordinator(const DmtcpMessage &msg,
msg 85 coordinatorapi.h void recvMsgFromCoordinator(DmtcpMessage *msg,
msg 109 coordinatorapi.h DmtcpMessage sendRecvHandshake(DmtcpMessage msg, string progname,
msg 501 dmtcp_coordinator.cpp void CoordClient::readProcessInfo(DmtcpMessage& msg)
msg 503 dmtcp_coordinator.cpp if (msg.extraBytes > 0) {
msg 504 dmtcp_coordinator.cpp char* extraData = new char[msg.extraBytes];
msg 505 dmtcp_coordinator.cpp _sock.readAll(extraData, msg.extraBytes);
msg 766 dmtcp_coordinator.cpp DmtcpMessage msg;
msg 769 dmtcp_coordinator.cpp client->sock() >> msg;
msg 770 dmtcp_coordinator.cpp msg.assertValid();
msg 772 dmtcp_coordinator.cpp if (msg.extraBytes > 0) {
msg 773 dmtcp_coordinator.cpp extraData = new char[msg.extraBytes];
msg 774 dmtcp_coordinator.cpp client->sock().readAll(extraData, msg.extraBytes);
msg 777 dmtcp_coordinator.cpp switch ( msg.type )
msg 782 dmtcp_coordinator.cpp client->setState ( msg.state );
msg 787 dmtcp_coordinator.cpp ( oldState )( msg.from )( msg.state )( newState );
msg 831 dmtcp_coordinator.cpp lookupService.registerData(msg, (const void*) extraData);
msg 838 dmtcp_coordinator.cpp lookupService.registerData(msg, (const void*) extraData);
msg 847 dmtcp_coordinator.cpp lookupService.respondToQuery(client->sock(), msg,
msg 856 dmtcp_coordinator.cpp (client->hostname()) (client->progname()) (msg.from) (client->identity());
msg 857 dmtcp_coordinator.cpp client->identity(msg.from);
msg 858 dmtcp_coordinator.cpp client->realPid(msg.realPid);
msg 865 dmtcp_coordinator.cpp (progname) (msg.from) (client->identity());
msg 867 dmtcp_coordinator.cpp client->identity(msg.from);
msg 872 dmtcp_coordinator.cpp JWARNING(false) (msg.type) .Text("unexpected message from worker. Closing connection");
msg 876 dmtcp_coordinator.cpp JASSERT ( false ) ( msg.from ) ( msg.type )
msg 1035 dmtcp_coordinator.cpp DmtcpMessage msg;
msg 1036 dmtcp_coordinator.cpp msg.type = DMT_KILL_PEER;
msg 1037 dmtcp_coordinator.cpp remote << msg;
msg 1313 dmtcp_coordinator.cpp DmtcpMessage msg;
msg 1314 dmtcp_coordinator.cpp msg.type = type;
msg 1315 dmtcp_coordinator.cpp msg.compGroup = compId;
msg 1317 dmtcp_coordinator.cpp msg.numPeers = numPeers;
msg 1320 dmtcp_coordinator.cpp if (msg.type == DMT_KILL_PEER && clients.size() > 0) {
msg 1322 dmtcp_coordinator.cpp } else if (msg.type == DMT_DO_FD_LEADER_ELECTION) {
msg 1329 dmtcp_coordinator.cpp clients[i]->sock() << msg;
msg 57 dmtcp_coordinator.h void readProcessInfo(DmtcpMessage& msg);
msg 456 dmtcpworker.cpp DmtcpMessage msg;
msg 463 dmtcpworker.cpp msg.type = DMT_OK;
msg 464 dmtcpworker.cpp msg.state = WorkerState::currentState();
msg 465 dmtcpworker.cpp CoordinatorAPI::instance().sendMsgToCoordinator(msg);
msg 469 dmtcpworker.cpp CoordinatorAPI::instance().recvMsgFromCoordinator(&msg);
msg 475 dmtcpworker.cpp msg.assertValid();
msg 476 dmtcpworker.cpp if (msg.type == DMT_KILL_PEER) {
msg 481 dmtcpworker.cpp JASSERT(msg.type == type) (msg.type) (type);
msg 486 dmtcpworker.cpp SharedData::updateGeneration(msg.compGroup.computationGeneration());
msg 487 dmtcpworker.cpp JASSERT(SharedData::getCompId() == msg.compGroup.upid())
msg 488 dmtcpworker.cpp (SharedData::getCompId()) (msg.compGroup);
msg 490 dmtcpworker.cpp JTRACE("Computation information") (msg.compGroup) (msg.numPeers);
msg 491 dmtcpworker.cpp ProcessInfo::instance().compGroup(msg.compGroup);
msg 492 dmtcpworker.cpp ProcessInfo::instance().numPeers(msg.numPeers);
msg 498 dmtcpworker.cpp DmtcpMessage msg;
msg 502 dmtcpworker.cpp msg.type = DMT_OK;
msg 503 dmtcpworker.cpp msg.state = WorkerState::currentState();
msg 504 dmtcpworker.cpp CoordinatorAPI::instance().sendMsgToCoordinator(msg);
msg 79 lookup_service.cpp void LookupService::registerData(const DmtcpMessage& msg,
msg 82 lookup_service.cpp JASSERT (msg.keyLen > 0 && msg.valLen > 0 &&
msg 83 lookup_service.cpp msg.keyLen + msg.valLen == msg.extraBytes)
msg 84 lookup_service.cpp (msg.keyLen) (msg.valLen) (msg.extraBytes);
msg 86 lookup_service.cpp const void *val = (char *)key + msg.keyLen;
msg 87 lookup_service.cpp size_t keyLen = msg.keyLen;
msg 88 lookup_service.cpp size_t valLen = msg.valLen;
msg 89 lookup_service.cpp addKeyValue(msg.nsid, key, keyLen, val, valLen);
msg 93 lookup_service.cpp const DmtcpMessage& msg,
msg 96 lookup_service.cpp JASSERT (msg.keyLen > 0 && msg.keyLen == msg.extraBytes)
msg 97 lookup_service.cpp (msg.keyLen) (msg.extraBytes);
msg 101 lookup_service.cpp query(msg.nsid, key, msg.keyLen, &val, &valLen);
msg 72 lookup_service.h void registerData(const DmtcpMessage& msg, const void *data);
msg 74 lookup_service.h const DmtcpMessage& msg, const void *data);
msg 177 plugin/ipc/socket/kernelbufferdrainer.cpp ConnMsg msg(ConnMsg::REFILL);
msg 178 plugin/ipc/socket/kernelbufferdrainer.cpp msg.extraBytes = size;
msg 183 plugin/ipc/socket/kernelbufferdrainer.cpp sock << msg;
msg 192 plugin/ipc/socket/kernelbufferdrainer.cpp ConnMsg msg;
msg 193 plugin/ipc/socket/kernelbufferdrainer.cpp msg.poison();
msg 195 plugin/ipc/socket/kernelbufferdrainer.cpp sock >> msg;
msg 197 plugin/ipc/socket/kernelbufferdrainer.cpp msg.assertValid(ConnMsg::REFILL);
msg 198 plugin/ipc/socket/kernelbufferdrainer.cpp int size = msg.extraBytes;
msg 595 plugin/ipc/socket/socketconnection.cpp ConnMsg msg(ConnMsg::HANDSHAKE);
msg 596 plugin/ipc/socket/socketconnection.cpp msg.from = id();
msg 597 plugin/ipc/socket/socketconnection.cpp msg.coordId = coordId;
msg 598 plugin/ipc/socket/socketconnection.cpp remote << msg;
msg 605 plugin/ipc/socket/socketconnection.cpp ConnMsg msg;
msg 606 plugin/ipc/socket/socketconnection.cpp msg.poison();
msg 607 plugin/ipc/socket/socketconnection.cpp remote >> msg;
msg 609 plugin/ipc/socket/socketconnection.cpp msg.assertValid(ConnMsg::HANDSHAKE);
msg 610 plugin/ipc/socket/socketconnection.cpp JASSERT(msg.coordId == coordId) (msg.coordId) (coordId)
msg 616 plugin/ipc/socket/socketconnection.cpp _remotePeerId = msg.from;
msg 621 plugin/ipc/socket/socketconnection.cpp JASSERT(_remotePeerId == msg.from)
msg 622 plugin/ipc/socket/socketconnection.cpp (_remotePeerId) (msg.from)
msg 867 plugin/svipc/sysvipc.cpp struct msgbuf msg;
msg 868 plugin/svipc/sysvipc.cpp msg.mtype = getpid();
msg 869 plugin/svipc/sysvipc.cpp JASSERT(_real_msgsnd(_realId, &msg, 0, IPC_NOWAIT) == 0) (_id) (JASSERT_ERRNO);