| 250 | } |
| 251 | |
| 252 | ssize_t ISocketStream::recv_at_least_mutable(struct iovec *iov, int iovcnt, |
| 253 | size_t least, int flags /*=0*/) { |
| 254 | iovector_view v(iov, iovcnt); |
| 255 | return DOIO_LOOP_LAMBDA(recv(v.iov, v.iovcnt, flags), { |
| 256 | auto r = v.extract_front(ret); |
| 257 | assert(r == ret); (void)r; |
| 258 | return n < least; |
| 259 | }); |
| 260 | } |
| 261 | |
| 262 | int do_get_name(int fd, Getter getter, EndPoint& addr) { |
| 263 | sockaddr_storage storage; |
nothing calls this directly
no test coverage detected