Lines Matching refs:sock
107 if (!recvTCP(sock, &ni, sizeof(ni)))
109 nodes.push_back(make_pair(ni, sock));
167 sock = iface0->second;
172 if (!recvTCP(sock, &ni, sizeof(ni)))
188 sendTCP(sock, &ni, sizeof(ni));
195 sendTCP(sock, &ni, sizeof(ni));
198 if (!recvTCP(sock, &ni, sizeof(ni)))
204 sockRegistry.push_back(sock);
212 sock = ::accept(fdStatic, (struct sockaddr *)&sockaddr, &slen);
213 if (sock != -1) {
215 if (setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, (char *)&i,
229 sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
230 panic_if(sock < 0, "socket() failed: %s", strerror(errno));
233 if (setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, (char *)&fl, sizeof(fl)) < 0)
248 ret = ::connect(sock, (struct sockaddr *)(addr_results->ai_addr),
259 ret = close(sock);
264 TCPIface::sendTCP(int sock, const void *buf, unsigned length)
268 ret = ::send(sock, buf, length, MSG_NOSIGNAL);
281 TCPIface::recvTCP(int sock, void *buf, unsigned length)
285 ret = ::recv(sock, buf, length, MSG_WAITALL );
302 sendTCP(sock, &header, sizeof(header));
303 sendTCP(sock, packet->data, packet->length);
321 bool ret = recvTCP(sock, &header, sizeof(header));
331 bool ret = recvTCP(sock, packet->data, header.dataPacketLength);