修复资源池化ndp插件 IO丢失问题

2023-06-05 16:11:12 +08:00
parent f600987700
commit 0665abc59f
1 changed files with 1 additions and 1 deletions
--- 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