| 264 | return true; |
| 265 | } |
| 266 | TObj<IObjectBase> GetObject(i64 key, EGetOp op) { |
| 267 | TGuard<TMutex> gg(Lock); |
| 268 | SetDataFromQueueLocked(); |
| 269 | TDataHash::iterator z = Data.find(key); |
| 270 | if (z == Data.end()) { |
| 271 | Y_ASSERT(0); |
| 272 | return nullptr; |
| 273 | } |
| 274 | if (op == DO_COPY) |
| 275 | return z->second.GetObject(); |
| 276 | else { |
| 277 | TObj<IObjectBase> obj = z->second.GetObject(); |
| 278 | Data.erase(z); |
| 279 | return obj; |
| 280 | } |
| 281 | } |
| 282 | }; |
| 283 | |
| 284 | class TWriteBufferHandler: public ICmdProcessor { |
no test coverage detected