hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

Fix master failed case && fix a corretness problem

Browse Source
This commit is contained in:
qianchanger
2022-11-21 12:35:53 +00:00
committed by wangzelin.wzl
parent 796ac0fd53
commit fdf88c9dc9
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/dtl/ob_dtl_channel_loop.h
View File

@ -88,6 +88,7 @@ public:
void reset_eof_cnt() { eof_channel_cnt_ = 0; } void reset_eof_cnt() { eof_channel_cnt_ = 0; }
void inc_eof_cnt() { eof_channel_cnt_ += 1; } 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 bool all_eof(const int64_t data_channel_cnt) const
{ {
return eof_channel_cnt_ >= data_channel_cnt; return eof_channel_cnt_ >= data_channel_cnt;
@ -190,6 +191,7 @@ OB_INLINE void ObDtlChannelLoop::reset()
first_data_get_ = false; first_data_get_ = false;
sentinel_node_.prev_link_ = &sentinel_node_; sentinel_node_.prev_link_ = &sentinel_node_;
sentinel_node_.next_link_ = &sentinel_node_; sentinel_node_.next_link_ = &sentinel_node_;
eof_channel_cnt_ = 0;
} }
OB_INLINE ObDtlChannelLoop &ObDtlChannelLoop::register_processor(Proc &proc) OB_INLINE ObDtlChannelLoop &ObDtlChannelLoop::register_processor(Proc &proc)