We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3bab874 commit 0bb7c75Copy full SHA for 0bb7c75
1 file changed
libs/server-sdk/src/data_systems/fdv2/conditions.cpp
@@ -26,14 +26,16 @@ async::Future<IFDv2Condition::Type> TimedCondition::Execute() {
26
}
27
28
void TimedCondition::Close() {
29
- std::lock_guard lock(state_->mutex);
30
- if (state_->closed) {
31
- return;
32
- }
33
- state_->closed = true;
34
- if (state_->timer_cancel) {
35
- state_->timer_cancel->Cancel();
36
- state_->timer_cancel.reset();
+ {
+ std::lock_guard lock(state_->mutex);
+ if (state_->closed) {
+ return;
+ }
+ state_->closed = true;
+ if (state_->timer_cancel) {
+ state_->timer_cancel->Cancel();
37
+ state_->timer_cancel.reset();
38
39
40
state_->promise.Resolve(IFDv2Condition::Type::kCancelled);
41
0 commit comments