sock 656 coordinatorapi.cpp jalib::JSocket sock = _coordinatorSocket;
sock 665 coordinatorapi.cpp sock = _nsSock;
sock 666 coordinatorapi.cpp JASSERT(sock.isValid());
sock 669 coordinatorapi.cpp sock << msg;
sock 670 coordinatorapi.cpp sock.writeAll((const char *)key, key_len);
sock 671 coordinatorapi.cpp sock.writeAll((const char *)val, val_len);
sock 674 coordinatorapi.cpp sock >> msg;
sock 697 coordinatorapi.cpp jalib::JSocket sock = _coordinatorSocket;
sock 711 coordinatorapi.cpp sock = _nsSock;
sock 712 coordinatorapi.cpp JASSERT(sock.isValid());
sock 715 coordinatorapi.cpp sock << msg;
sock 716 coordinatorapi.cpp sock.writeAll((const char *)key, key_len);
sock 719 coordinatorapi.cpp sock >> msg;
sock 727 coordinatorapi.cpp sock.readAll((char*)val, *val_len);
sock 485 dmtcp_coordinator.cpp CoordClient::CoordClient(const jalib::JSocket& sock,
sock 490 dmtcp_coordinator.cpp : _sock(sock)
sock 589 dmtcp_coordinator.cpp clients[i]->sock().close();
sock 769 dmtcp_coordinator.cpp client->sock() >> msg;
sock 774 dmtcp_coordinator.cpp client->sock().readAll(extraData, msg.extraBytes);
sock 812 dmtcp_coordinator.cpp client->sock() << reply;
sock 813 dmtcp_coordinator.cpp client->sock().writeAll(ckptDir.c_str(), reply.extraBytes);
sock 841 dmtcp_coordinator.cpp client->sock() << response;
sock 847 dmtcp_coordinator.cpp lookupService.respondToQuery(client->sock(), msg,
sock 903 dmtcp_coordinator.cpp client->sock().close();
sock 913 dmtcp_coordinator.cpp client->sock().close();
sock 1329 dmtcp_coordinator.cpp clients[i]->sock() << msg;
sock 1751 dmtcp_coordinator.cpp JASSERT(epoll_ctl(epollFd, EPOLL_CTL_ADD, client->sock().sockfd(), &ev) != -1)
sock 34 dmtcp_coordinator.h CoordClient(const jalib::JSocket& sock,
sock 40 dmtcp_coordinator.h jalib::JSocket &sock() { return _sock; }
sock 483 plugin/ipc/connectionlist.cpp jalib::JSocket sock(_real_socket(AF_UNIX, SOCK_DGRAM, 0));
sock 484 plugin/ipc/connectionlist.cpp JASSERT(sock.isValid());
sock 485 plugin/ipc/connectionlist.cpp sock.changeFd(protected_fd);
sock 57 plugin/ipc/socket/kernelbufferdrainer.cpp void KernelBufferDrainer::onConnect(const jalib::JSocket& sock,
sock 61 plugin/ipc/socket/kernelbufferdrainer.cpp JWARNING(false) (sock.sockfd())
sock 64 plugin/ipc/socket/kernelbufferdrainer.cpp jalib::JSocket(sock).close();
sock 67 plugin/ipc/socket/kernelbufferdrainer.cpp void KernelBufferDrainer::onData(jalib::JReaderInterface* sock)
sock 69 plugin/ipc/socket/kernelbufferdrainer.cpp vector<char>& buffer = _drainedData[sock->socket().sockfd() ];
sock 70 plugin/ipc/socket/kernelbufferdrainer.cpp buffer.resize(buffer.size() + sock->bytesRead());
sock 71 plugin/ipc/socket/kernelbufferdrainer.cpp int startIdx = buffer.size() - sock->bytesRead();
sock 72 plugin/ipc/socket/kernelbufferdrainer.cpp memcpy(&buffer[startIdx],sock->buffer(),sock->bytesRead());
sock 74 plugin/ipc/socket/kernelbufferdrainer.cpp sock->reset();
sock 77 plugin/ipc/socket/kernelbufferdrainer.cpp void KernelBufferDrainer::onDisconnect(jalib::JReaderInterface* sock)
sock 81 plugin/ipc/socket/kernelbufferdrainer.cpp fd = sock->socket().sockfd();
sock 179 plugin/ipc/socket/kernelbufferdrainer.cpp jalib::JSocket sock(i->first);
sock 181 plugin/ipc/socket/kernelbufferdrainer.cpp JTRACE("requesting repeat buffer...") (sock.sockfd()) (size);
sock 183 plugin/ipc/socket/kernelbufferdrainer.cpp sock << msg;
sock 184 plugin/ipc/socket/kernelbufferdrainer.cpp if (size>0) sock.writeAll(&i->second[0],size);
sock 194 plugin/ipc/socket/kernelbufferdrainer.cpp jalib::JSocket sock(i->first);
sock 195 plugin/ipc/socket/kernelbufferdrainer.cpp sock >> msg;
sock 203 plugin/ipc/socket/kernelbufferdrainer.cpp sock.readAll(tmp,size);
sock 204 plugin/ipc/socket/kernelbufferdrainer.cpp sock.writeAll(tmp,size);
sock 45 plugin/ipc/socket/kernelbufferdrainer.h virtual void onData(jalib::JReaderInterface* sock);
sock 46 plugin/ipc/socket/kernelbufferdrainer.h virtual void onConnect(const jalib::JSocket& sock, const struct sockaddr* remoteAddr,socklen_t remoteLen);
sock 48 plugin/ipc/socket/kernelbufferdrainer.h virtual void onDisconnect(jalib::JReaderInterface* sock);
sock 89 plugin/ipc/ssh/dmtcp_ssh.cpp int sock = socket(AF_INET, SOCK_STREAM, 0);
sock 90 plugin/ipc/ssh/dmtcp_ssh.cpp if (sock == -1) {
sock 97 plugin/ipc/ssh/dmtcp_ssh.cpp if (bind(sock, (struct sockaddr*) &saddr, sizeof saddr) == -1) {
sock 101 plugin/ipc/ssh/dmtcp_ssh.cpp if (listen(sock, 1) == -1) {
sock 104 plugin/ipc/ssh/dmtcp_ssh.cpp return sock;
sock 25 plugin/ipc/ssh/dmtcp_sshd.cpp int sock = socket(AF_INET, SOCK_STREAM, 0);
sock 26 plugin/ipc/ssh/dmtcp_sshd.cpp if (sock == -1) {
sock 38 plugin/ipc/ssh/dmtcp_sshd.cpp if (connect(sock, (sockaddr *)&saddr, sizeof saddr) == -1) {
sock 42 plugin/ipc/ssh/dmtcp_sshd.cpp remotePeerSock = sock;
sock 114 plugin/ipc/ssh/ssh.cpp jalib::JSocket sock(_real_socket(AF_UNIX, SOCK_DGRAM, 0));
sock 115 plugin/ipc/ssh/ssh.cpp JASSERT(sock.isValid());
sock 116 plugin/ipc/ssh/ssh.cpp sock.changeFd(SSHD_RECEIVE_FD);
sock 229 plugin/ipc/ssh/ssh.cpp int sock, int noStrictChecking)
sock 243 plugin/ipc/ssh/ssh.cpp sshSockFd = sock;
sock 16 plugin/ipc/ssh/ssh.h int sock, int noStrictHostKeyChecking)
sock 13 plugin/ipc/ssh/sshdrainer.cpp void SSHDrainer::onConnect(const jalib::JSocket& sock,
sock 20 plugin/ipc/ssh/sshdrainer.cpp void SSHDrainer::onData(jalib::JReaderInterface* sock)
sock 22 plugin/ipc/ssh/sshdrainer.cpp vector<char>& buffer = _drainedData[sock->socket().sockfd() ];
sock 23 plugin/ipc/ssh/sshdrainer.cpp buffer.resize(buffer.size() + sock->bytesRead());
sock 24 plugin/ipc/ssh/sshdrainer.cpp int startIdx = buffer.size() - sock->bytesRead();
sock 25 plugin/ipc/ssh/sshdrainer.cpp memcpy(&buffer[startIdx],sock->buffer(),sock->bytesRead());
sock 27 plugin/ipc/ssh/sshdrainer.cpp sock->reset();
sock 30 plugin/ipc/ssh/sshdrainer.cpp void SSHDrainer::onDisconnect(jalib::JReaderInterface* sock)
sock 34 plugin/ipc/ssh/sshdrainer.cpp fd = sock->socket().sockfd();
sock 19 plugin/ipc/ssh/sshdrainer.h virtual void onData(jalib::JReaderInterface* sock);
sock 23 plugin/ipc/ssh/sshdrainer.h virtual void onDisconnect(jalib::JReaderInterface* sock);
sock 127 plugin/ipc/ssh/util_ssh.cpp void client_loop(int ssh_stdin, int ssh_stdout, int ssh_stderr, int sock)
sock 129 plugin/ipc/ssh/util_ssh.cpp remoteSock = sock;