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,