client 764 dmtcp_coordinator.cpp void DmtcpCoordinator::onData(CoordClient *client)
client 767 dmtcp_coordinator.cpp JASSERT(client != NULL);
client 769 dmtcp_coordinator.cpp client->sock() >> msg;
client 774 dmtcp_coordinator.cpp client->sock().readAll(extraData, msg.extraBytes);
client 781 dmtcp_coordinator.cpp WorkerState oldState = client->state();
client 782 dmtcp_coordinator.cpp client->setState ( msg.state );
client 812 dmtcp_coordinator.cpp client->sock() << reply;
client 813 dmtcp_coordinator.cpp client->sock().writeAll(ckptDir.c_str(), reply.extraBytes);
client 830 dmtcp_coordinator.cpp JTRACE ("received REGISTER_NAME_SERVICE_DATA msg") (client->identity());
client 837 dmtcp_coordinator.cpp JTRACE ("received REGISTER_NAME_SERVICE_DATA_SYNC msg") (client->identity());
client 841 dmtcp_coordinator.cpp client->sock() << response;
client 846 dmtcp_coordinator.cpp JTRACE ("received NAME_SERVICE_QUERY msg") (client->identity());
client 847 dmtcp_coordinator.cpp lookupService.respondToQuery(client->sock(), msg,
client 856 dmtcp_coordinator.cpp (client->hostname()) (client->progname()) (msg.from) (client->identity());
client 857 dmtcp_coordinator.cpp client->identity(msg.from);
client 858 dmtcp_coordinator.cpp client->realPid(msg.realPid);
client 865 dmtcp_coordinator.cpp (progname) (msg.from) (client->identity());
client 866 dmtcp_coordinator.cpp client->progname(progname);
client 867 dmtcp_coordinator.cpp client->identity(msg.from);
client 873 dmtcp_coordinator.cpp onDisconnect(client);
client 900 dmtcp_coordinator.cpp void DmtcpCoordinator::onDisconnect(CoordClient *client)
client 902 dmtcp_coordinator.cpp if (client->isNSWorker()) {
client 903 dmtcp_coordinator.cpp client->sock().close();
client 904 dmtcp_coordinator.cpp delete client;
client 908 dmtcp_coordinator.cpp if (clients[i] == client) {
client 913 dmtcp_coordinator.cpp client->sock().close();
client 914 dmtcp_coordinator.cpp JNOTE ( "client disconnected" ) ( client->identity() );
client 915 dmtcp_coordinator.cpp _virtualPidToClientMap.erase(client->virtualPid());
client 935 dmtcp_coordinator.cpp updateMinimumState(client->state());
client 980 dmtcp_coordinator.cpp CoordClient *client = new CoordClient(remote, &remoteAddr, remoteLen,
client 983 dmtcp_coordinator.cpp addDataSocket(client);
client 1048 dmtcp_coordinator.cpp CoordClient *client = new CoordClient(remote, &remoteAddr, remoteLen,
client 1052 dmtcp_coordinator.cpp client->readProcessInfo(hello_remote);
client 1060 dmtcp_coordinator.cpp client->virtualPid(hello_remote.from.pid());
client 1061 dmtcp_coordinator.cpp _virtualPidToClientMap[client->virtualPid()] = client;
client 1067 dmtcp_coordinator.cpp client->virtualPid(getNewVirtualPid());
client 1068 dmtcp_coordinator.cpp if (!validateNewWorkerProcess(hello_remote, remote, client,
client 1072 dmtcp_coordinator.cpp _virtualPidToClientMap[client->virtualPid()] = client;
client 1081 dmtcp_coordinator.cpp clients.push_back(client);
client 1082 dmtcp_coordinator.cpp addDataSocket(client);
client 1195 dmtcp_coordinator.cpp CoordClient *client,
client 1202 dmtcp_coordinator.cpp hello_local.virtualPid = client->virtualPid();
client 1255 dmtcp_coordinator.cpp compId = UniquePid(hello_remote.from.hostid(), client->virtualPid(),
client 1267 dmtcp_coordinator.cpp (hello_remote.from) (client->virtualPid());
client 1741 dmtcp_coordinator.cpp void DmtcpCoordinator::addDataSocket(CoordClient *client)
client 1750 dmtcp_coordinator.cpp ev.data.ptr = client;
client 1751 dmtcp_coordinator.cpp JASSERT(epoll_ctl(epollFd, EPOLL_CTL_ADD, client->sock().sockfd(), &ev) != -1)
client 82 dmtcp_coordinator.h void onData(CoordClient *client);
client 84 dmtcp_coordinator.h void onDisconnect(CoordClient *client);
client 87 dmtcp_coordinator.h void addDataSocket(CoordClient *client);
client 101 dmtcp_coordinator.h CoordClient *client,