| 151 | } |
| 152 | |
| 153 | void |
| 154 | UringInputStream::OnReadError(int error) noexcept |
| 155 | { |
| 156 | read_operation.reset(); |
| 157 | |
| 158 | const std::lock_guard protect{mutex}; |
| 159 | |
| 160 | postponed_exception = std::make_exception_ptr(MakeErrno(error, "Read failed")); |
| 161 | InvokeOnAvailable(); |
| 162 | } |
| 163 | |
| 164 | InputStreamPtr |
| 165 | OpenUringInputStream(const char *path, Mutex &mutex) |