remote 755 dmtcp_coordinator.cpp jalib::JSocket remote ( blockUntilDoneRemote ); remote 756 dmtcp_coordinator.cpp remote << blockUntilDoneReply; remote 757 dmtcp_coordinator.cpp remote.close(); remote 961 dmtcp_coordinator.cpp jalib::JSocket remote = listenSock->accept(&remoteAddr, &remoteLen); remote 962 dmtcp_coordinator.cpp JTRACE("accepting new connection") (remote.sockfd()) (JASSERT_ERRNO); remote 964 dmtcp_coordinator.cpp if (!remote.isValid()) { remote 965 dmtcp_coordinator.cpp remote.close(); remote 972 dmtcp_coordinator.cpp remote >> hello_remote; remote 973 dmtcp_coordinator.cpp if (!remote.isValid()) { remote 974 dmtcp_coordinator.cpp remote.close(); remote 980 dmtcp_coordinator.cpp CoordClient *client = new CoordClient(remote, &remoteAddr, remoteLen, remote 989 dmtcp_coordinator.cpp remote.readAll(extraData, hello_remote.extraBytes); remote 992 dmtcp_coordinator.cpp lookupService.respondToQuery(remote, hello_remote, extraData); remote 994 dmtcp_coordinator.cpp remote.close(); remote 1000 dmtcp_coordinator.cpp remote.readAll(extraData, hello_remote.extraBytes); remote 1005 dmtcp_coordinator.cpp remote.close(); remote 1011 dmtcp_coordinator.cpp remote.readAll(extraData, hello_remote.extraBytes); remote 1018 dmtcp_coordinator.cpp remote << response; remote 1019 dmtcp_coordinator.cpp remote.close(); remote 1028 dmtcp_coordinator.cpp processDmtUserCmd(hello_remote, remote); remote 1037 dmtcp_coordinator.cpp remote << msg; remote 1038 dmtcp_coordinator.cpp remote.close(); remote 1048 dmtcp_coordinator.cpp CoordClient *client = new CoordClient(remote, &remoteAddr, remoteLen, remote 1056 dmtcp_coordinator.cpp if (!validateRestartingWorkerProcess(hello_remote, remote, remote 1068 dmtcp_coordinator.cpp if (!validateNewWorkerProcess(hello_remote, remote, client, remote 1088 dmtcp_coordinator.cpp jalib::JSocket& remote ) remote 1098 dmtcp_coordinator.cpp blockUntilDoneRemote = remote.sockfd(); remote 1105 dmtcp_coordinator.cpp remote << reply; remote 1106 dmtcp_coordinator.cpp remote.close(); remote 1109 dmtcp_coordinator.cpp remote << reply; remote 1110 dmtcp_coordinator.cpp remote.close(); remote 1117 dmtcp_coordinator.cpp jalib::JSocket& remote, remote 1146 dmtcp_coordinator.cpp remote << hello_local; remote 1147 dmtcp_coordinator.cpp remote.close(); remote 1154 dmtcp_coordinator.cpp remote << hello_local; remote 1155 dmtcp_coordinator.cpp remote.close(); remote 1171 dmtcp_coordinator.cpp remote << hello_local; remote 1194 dmtcp_coordinator.cpp jalib::JSocket& remote, remote 1219 dmtcp_coordinator.cpp remote << hello_local; remote 1225 dmtcp_coordinator.cpp remote << suspendMsg; remote 1235 dmtcp_coordinator.cpp remote << hello_local; remote 1236 dmtcp_coordinator.cpp remote.close(); remote 1246 dmtcp_coordinator.cpp remote << hello_local; remote 1247 dmtcp_coordinator.cpp remote.close(); remote 1276 dmtcp_coordinator.cpp remote << hello_local; remote 98 dmtcp_coordinator.h jalib::JSocket& remote); remote 100 dmtcp_coordinator.h jalib::JSocket& remote, remote 105 dmtcp_coordinator.h jalib::JSocket& remote, remote 92 lookup_service.cpp void LookupService::respondToQuery(jalib::JSocket& remote, remote 108 lookup_service.cpp remote << reply; remote 110 lookup_service.cpp remote.writeAll((char*)val, valLen); remote 73 lookup_service.h void respondToQuery(jalib::JSocket& remote, remote 249 plugin/ipc/socket/connectionrewirer.cpp ConnectionRewirer::registerOutgoing(const ConnectionIdentifier& remote, remote 252 plugin/ipc/socket/connectionrewirer.cpp _pendingOutgoing[remote] = con; remote 253 plugin/ipc/socket/connectionrewirer.cpp JTRACE("announcing pending outgoing") (remote); remote 294 plugin/ipc/socket/connectionrewirer.cpp struct RemoteAddr remote; remote 295 plugin/ipc/socket/connectionrewirer.cpp uint32_t len = sizeof(remote.addr); remote 298 plugin/ipc/socket/connectionrewirer.cpp &remote.addr, &len); remote 299 plugin/ipc/socket/connectionrewirer.cpp remote.len = len; remote 306 plugin/ipc/socket/connectionrewirer.cpp _remoteInfo[id] = remote; remote 52 plugin/ipc/socket/connectionrewirer.h void registerOutgoing(const ConnectionIdentifier& remote, remote 340 plugin/ipc/socket/socketconnection.cpp const ConnectionIdentifier& remote) remote 345 plugin/ipc/socket/socketconnection.cpp , _remotePeerId(remote) remote 348 plugin/ipc/socket/socketconnection.cpp JTRACE("Accepting.") (id()) (parent.id()) (remote); remote 594 plugin/ipc/socket/socketconnection.cpp jalib::JSocket remote(remotefd); remote 598 plugin/ipc/socket/socketconnection.cpp remote << msg; remote 604 plugin/ipc/socket/socketconnection.cpp jalib::JSocket remote(remotefd); remote 607 plugin/ipc/socket/socketconnection.cpp remote >> msg; remote 99 plugin/ipc/socket/socketconnection.h const ConnectionIdentifier& remote);