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

Delete redundant channel aliving check

Browse Source
This commit is contained in:
obdev 2023-04-11 12:18:54 +08:00 committed by ob-robot
parent e9aee7d60f
commit 7286c78491
2 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/sql/dtl/ob_dtl_channel_loop.cpp
View File

@ -373,12 +373,7 @@ int ObDtlChannelLoop::process_channels(ObIDltChannelLoopPred *pred, int64_t &nth
LOG_WARN("unexpect next idx", K(next_idx_), K(chan_cnt), K(ret));
} else {
chan = chans_[next_idx_];
if (OB_UNLIKELY(ObPxCheckAlive::is_in_blacklist(chan->get_peer(), get_process_query_time()))) {
ret = OB_RPC_CONNECT_ERROR;
LOG_WARN("peer no in communication, maybe crashed", K(ret), K(chan->get_peer()),
K(static_cast<int64_t>(GCONF.cluster_id)));
break;
} else if (nullptr == pred || pred->pred_process(next_idx_, chan)) {
if (nullptr == pred || pred->pred_process(next_idx_, chan)) {
if (OB_SUCC(chan->process1(&process_func_, 0, last_row_in_buffer))) {
nth_channel = next_idx_;
first_data_get_ = true;

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

@ -123,7 +123,7 @@ public:
void set_interm_result(bool flag) { use_interm_result_ = flag; }
private:
static const int64_t INTERRUPT_CHECK_TIMES = 16;
static const int64_t SERVER_ALIVE_CHECK_TIMES = 256;
static const int64_t SERVER_ALIVE_CHECK_TIMES = 4096;
Proc *proc_map_[MAX_PROCS];
InterruptProc *interrupt_proc_;
common::ObSEArray<ObDtlChannel*, 128> chans_;