@@ -463,9 +463,10 @@ static int MtmConnectSocket(char const* host, int port, int timeout)
463463gotoRetry ;
464464}
465465
466- /* Some node considered that I am dead, so switch to recovery mode */
467466MtmLock (LW_EXCLUSIVE );
468467Mtm -> nodes [resp .node - 1 ].sendSeqNo = resp .seqno ;
468+
469+ /* Some node considered that I am dead, so switch to recovery mode */
469470if (BIT_CHECK (resp .disabledNodeMask ,MtmNodeId - 1 )) {
470471elog (WARNING ,"Node %d thinks that I was dead" ,resp .node );
471472BIT_SET (Mtm -> disabledNodeMask ,MtmNodeId - 1 );
@@ -861,7 +862,7 @@ static void MtmTransReceiver(Datum arg)
861862continue ;
862863}
863864if (msg -> seqno <=Mtm -> nodes [msg -> node - 1 ].recvSeqNo ) {
864- elog (WARNING ,"Ignore duplicated message %ld from node %d" ,msg -> seqno ,msg -> node );
865+ elog (WARNING ,"Ignore duplicated message %ld(<=%ld) from node %d" ,msg -> seqno , Mtm -> nodes [ msg -> node - 1 ]. recvSeqNo ,msg -> node );
865866continue ;
866867}
867868Mtm -> nodes [msg -> node - 1 ].recvSeqNo = msg -> seqno ;