From 0665abc59fba0fd39f857dfdde9d8f7a00a87e45 Mon Sep 17 00:00:00 2001 From: Mijamind Date: Mon, 5 Jun 2023 16:11:12 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E8=B5=84=E6=BA=90=E6=B1=A0?= =?UTF-8?q?=E5=8C=96ndp=E6=8F=92=E4=BB=B6=20IO=E4=B8=A2=E5=A4=B1=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- contrib/ndpplugin/ndpplugin.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/contrib/ndpplugin/ndpplugin.cpp b/contrib/ndpplugin/ndpplugin.cpp index f89d95f31..5e5ca4abf 100644 --- a/contrib/ndpplugin/ndpplugin.cpp +++ b/contrib/ndpplugin/ndpplugin.cpp @@ -317,7 +317,7 @@ static bool NdpScanGetPage(NdpScanDesc ndpScan) if (resp < req) { pg_usleep(NDP_RPC_WAIT_USEC); // if normal page finish, io request failed, pages been added to normal queue, can't return directly. - } else if (ndpScan->normalPagesId->Empty() && !NdpScanGetPageQueue(ndpScan)) { + } else if (ndpScan->normalPagesId->Empty() && ndpScan->respIO->Empty()) { return false; } #else