This is an automated email from the ASF dual-hosted git repository.

ztao1987 pushed a commit to branch taoz
in repository https://gitbox.apache.org/repos/asf/hawq.git

commit 9dddc2be656050503e2b8c7157e53067c1ca3183
Author: ztao1987 <zhenglin.ta...@gmail.com>
AuthorDate: Sat Sep 11 15:41:53 2021 +0800

    HAWQ-1805. checkQDConnectionAlive when SendEosUDP
---
 src/backend/cdb/motion/ic_udp.c | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/backend/cdb/motion/ic_udp.c b/src/backend/cdb/motion/ic_udp.c
index a4c1421..0c7030c 100644
--- a/src/backend/cdb/motion/ic_udp.c
+++ b/src/backend/cdb/motion/ic_udp.c
@@ -5461,7 +5461,7 @@ checkExceptions(ChunkTransportState *transportStates, 
ChunkTransportStateEntry *
                }
        }
 
-       if ((retry & 0x3) == 0)
+       if ((retry & 0x3) == 2)
        {
                checkDeadlock(pEntry, conn);
                checkRxThreadError();
@@ -5469,7 +5469,8 @@ checkExceptions(ChunkTransportState *transportStates, 
ChunkTransportStateEntry *
        }
 
        /* NIC on master (and thus the QD connection) may become bad, check it. 
*/
-       if ((retry & 0x3f) == 0)
+       /* We check modulo 2 in case that 'retry' all less than 0x3f */
+       if ((retry & 0x3f) == 2)
                checkQDConnectionAlive();
 }
 

Reply via email to