thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-23 08:02:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #48687 from ClickHouse/processor-call-oncancel-once

Browse Source 
Call IProcessor::onCancel() once
This commit is contained in:
Alexey Milovidov 2023-04-16 00:25:06 +03:00 committed by GitHub
commit 44f05e3fca
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Processors/IProcessor.h
View File

@ -237,11 +237,12 @@ public:
/// In case if query was cancelled executor will wait till all processors finish their jobs.
/// Generally, there is no reason to check this flag. However, it may be reasonable for long operations (e.g. i/o).
bool isCancelled() const { return is_cancelled; }
bool isCancelled() const { return is_cancelled.load(std::memory_order_acquire); }
void cancel()
{
is_cancelled = true;
onCancel();
bool already_cancelled = is_cancelled.exchange(true, std::memory_order_acq_rel);
if (!already_cancelled)
onCancel();
}
/// Additional method which is called in case if ports were updated while work() method.