From fdf88c9dc96e088e080654075feb082bfb36d8d7 Mon Sep 17 00:00:00 2001 From: qianchanger Date: Mon, 21 Nov 2022 12:35:53 +0000 Subject: [PATCH] Fix master failed case && fix a corretness problem --- src/sql/dtl/ob_dtl_channel_loop.h | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/sql/dtl/ob_dtl_channel_loop.h b/src/sql/dtl/ob_dtl_channel_loop.h index 9ddd01992e..11925eab9e 100644 --- a/src/sql/dtl/ob_dtl_channel_loop.h +++ b/src/sql/dtl/ob_dtl_channel_loop.h @@ -88,6 +88,7 @@ public: void reset_eof_cnt() { eof_channel_cnt_ = 0; } void inc_eof_cnt() { eof_channel_cnt_ += 1; } + int64_t get_eof_cnt() { return eof_channel_cnt_; } bool all_eof(const int64_t data_channel_cnt) const { return eof_channel_cnt_ >= data_channel_cnt; @@ -190,6 +191,7 @@ OB_INLINE void ObDtlChannelLoop::reset() first_data_get_ = false; sentinel_node_.prev_link_ = &sentinel_node_; sentinel_node_.next_link_ = &sentinel_node_; + eof_channel_cnt_ = 0; } OB_INLINE ObDtlChannelLoop &ObDtlChannelLoop::register_processor(Proc &proc)