| 514 | } |
| 515 | |
| 516 | void Cancel() noexcept { |
| 517 | Canceled_ = true; |
| 518 | THandleRef h = ReleaseHandler(); |
| 519 | if (!h) { |
| 520 | return; |
| 521 | } |
| 522 | |
| 523 | TConnectionRef conn = ReleaseConn(); |
| 524 | if (!!conn && Id_.load(std::memory_order_acquire)) { |
| 525 | conn->Cancel(Id_.load(std::memory_order_acquire)); |
| 526 | } |
| 527 | h->NotifyError(new TError(canceled, TError::Cancelled)); |
| 528 | } |
| 529 | |
| 530 | void SetReqId(TRequestId reqId) noexcept { |
| 531 | auto guard = Guard(IdLock_); |
no test coverage detected