This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new de856351f9b [fix](syncpoint) Fix incorrect syncpoint 'has_point()'
intorduced by (#43461) (#43784)
de856351f9b is described below
commit de856351f9b37f06d62840a71af083cf994587aa
Author: Gavin Chou <[email protected]>
AuthorDate: Tue Nov 12 21:29:10 2024 +0800
[fix](syncpoint) Fix incorrect syncpoint 'has_point()' intorduced by
(#43461) (#43784)
Related PR: #43461
---
common/cpp/sync_point.cpp | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/common/cpp/sync_point.cpp b/common/cpp/sync_point.cpp
index c2263415d30..02bdce1ec34 100644
--- a/common/cpp/sync_point.cpp
+++ b/common/cpp/sync_point.cpp
@@ -248,8 +248,7 @@ void SyncPoint::Data::disable_processing() {
bool SyncPoint::Data::has_point(const std::string& point) {
std::unique_lock lock(mutex_);
- auto marked_point_iter = marked_thread_id_.find(point);
- return marked_point_iter != marked_thread_id_.end();
+ return callbacks_.find(point) != callbacks_.end();
}
bool SyncPoint::Data::get_enable() {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
