| 229 | } |
| 230 | |
| 231 | bool release(const EndPoint& ep, ISocketStream* stream) { |
| 232 | auto fd = stream->get_underlay_fd(); |
| 233 | ERRNO err; |
| 234 | if (!stream_reusable(fd)) return false; |
| 235 | auto node = new StreamListNode(ep, stream, fd, TTL_us); |
| 236 | push_into_pool(node); |
| 237 | errno = err.no; |
| 238 | return true; |
| 239 | } |
| 240 | |
| 241 | void collect() { |
| 242 | StreamListNode* nodes[16]; |
no test coverage detected