| 458 | } |
| 459 | |
| 460 | void OnError(const TString& err, const i32 systemCode = 0) { |
| 461 | DBGOUT("TRequest::OnError: " << Id_.load(std::memory_order_acquire)); |
| 462 | THandleRef h = ReleaseHandler(); |
| 463 | if (!h) { |
| 464 | return; |
| 465 | } |
| 466 | |
| 467 | h->NotifyError(new TError(err, TError::UnknownType, 0, systemCode)); |
| 468 | ReleaseConn(); |
| 469 | } |
| 470 | |
| 471 | void SetConnection(TConnection* conn) noexcept { |
| 472 | auto g = Guard(AL_); |
no test coverage detected