| 967 | } |
| 968 | |
| 969 | inline void Put(THttpConnRef& conn, size_t addrId) { |
| 970 | if (Y_LIKELY(!Shutdown_ && !ExceedHardLimit() && !CacheDisabled())) { |
| 971 | if (Y_UNLIKELY(addrId > (size_t)AtomicGet(MaxConnId_))) { |
| 972 | AtomicSet(MaxConnId_, addrId); |
| 973 | } |
| 974 | Cache_.Put(conn, addrId); |
| 975 | } else { |
| 976 | conn->Close(); |
| 977 | conn.Drop(); |
| 978 | } |
| 979 | } |
| 980 | |
| 981 | inline size_t OnConnError(size_t addrId) { |
| 982 | return Cache_.Validate(addrId); |
no test coverage detected