Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit 18f3d86

Browse files
knizhnikkelvich
authored andcommitted
Print expected seqno
1 parent 712d82e commit 18f3d86

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

arbiter.c

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -463,9 +463,10 @@ static int MtmConnectSocket(char const* host, int port, int timeout)
463463
goto Retry;
464464
}
465465

466-
/* Some node considered that I am dead, so switch to recovery mode */
467466
MtmLock(LW_EXCLUSIVE);
468467
Mtm->nodes[resp.node-1].sendSeqNo = resp.seqno;
468+
469+
/* Some node considered that I am dead, so switch to recovery mode */
469470
if (BIT_CHECK(resp.disabledNodeMask, MtmNodeId-1)) {
470471
elog(WARNING, "Node %d thinks that I was dead", resp.node);
471472
BIT_SET(Mtm->disabledNodeMask, MtmNodeId-1);
@@ -861,7 +862,7 @@ static void MtmTransReceiver(Datum arg)
861862
continue;
862863
}
863864
if (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);
865866
continue;
866867
}
867868
Mtm->nodes[msg->node-1].recvSeqNo = msg->seqno;

0 commit comments

Comments
 (0)