| 195 | |
| 196 | private: |
| 197 | TPooledSocket::TImpl* GetImpl() { |
| 198 | TGuard<TMutex> guard(Mutex_); |
| 199 | |
| 200 | while (!Pool_.Empty()) { |
| 201 | THolder<TPooledSocket::TImpl> ret(Pool_.PopFront()); |
| 202 | |
| 203 | if (ret->IsOpen()) { |
| 204 | return ret.Release(); |
| 205 | } |
| 206 | } |
| 207 | return nullptr; |
| 208 | } |
| 209 | |
| 210 | void Release(TPooledSocket::TImpl* impl) noexcept { |
| 211 | TGuard<TMutex> guard(Mutex_); |
no test coverage detected