| 217 | } |
| 218 | |
| 219 | void AddRequestAck(const TGUID& guid) override { |
| 220 | UpdateInFly(); |
| 221 | TInFly::iterator it = InFly_.find(guid); |
| 222 | |
| 223 | Y_ABORT_UNLESS(it != InFly_.end(), "incorrect complete notification"); |
| 224 | |
| 225 | it->second->OnRequestAck(); |
| 226 | } |
| 227 | |
| 228 | private: |
| 229 | TLockFreeQueue<TRequestRef> Q_; |
nothing calls this directly
no test coverage detected