Commita380fe6

committed

Undo changes around MtmRecoveryCaughtUp

1 parent4147df0 commita380fe6Copy full SHA for a380fe6

File tree

-9

lines changed

-9

lines changed

Lines changed: 1 addition & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -997,7 +997,6 @@ bool MtmRecoveryCaughtUp(int nodeId, XLogRecPtr slotLSN)`
`997`	`997`	`if (MtmIsRecoveredNode(nodeId)) {`
`998`	`998`	`XLogRecPtrwalLSN=GetXLogInsertRecPtr();`
`999`	`999`	`MtmLock(LW_EXCLUSIVE);`
`1000`		`-#if0`
`1001`	`1000`	`if (slotLSN==walLSN) {`
`1002`	`1001`	`if (BIT_CHECK(Mtm->nodeLockerMask,nodeId-1)) {`
`1003`	`1002`	`elog(WARNING,"Node %d is caught-up",nodeId);`
`@@ -1011,9 +1010,7 @@ bool MtmRecoveryCaughtUp(int nodeId, XLogRecPtr slotLSN)`
`1011`	`1010`	`BIT_CLEAR(Mtm->disabledNodeMask,nodeId-1);`
`1012`	`1011`	`Mtm->nNodes+=1;`
`1013`	`1012`	`caughtUp= true;`
`1014`		`-}else`
`1015`		`-#endif`
`1016`		`-if (!BIT_CHECK(Mtm->nodeLockerMask,nodeId-1)`
	`1013`	`+}elseif (!BIT_CHECK(Mtm->nodeLockerMask,nodeId-1)`
`1017`	`1014`	`&&slotLSN+MtmMinRecoveryLag>walLSN)`
`1018`	`1015`	`{`
`1019`	`1016`	`/*`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -499,12 +499,12 @@ process_remote_commit(StringInfo in)`
`499`	`499`	`uint8flags;`
`500`	`500`	`csn_tcsn;`
`501`	`501`	`constchar*gid=NULL;`
`502`		`-boolcaughtUp= false;`
	`502`	`+boolcaughtUp;`
`503`	`503`
`504`	`504`	`/* read flags */`
`505`	`505`	`flags=pq_getmsgbyte(in);`
`506`	`506`	`MtmReplicationNode=pq_getmsgbyte(in);`
`507`		`-/caughtUp = pq_getmsgbyte(in) != 0;/`
	`507`	`+caughtUp=pq_getmsgbyte(in)!=0;`
`508`	`508`
`509`	`509`	`/* read fields */`
`510`	`510`	`replorigin_session_origin_lsn=pq_getmsgint64(in);/* commit_lsn */`

Lines changed: 1 addition & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -147,16 +147,14 @@ pglogical_write_commit(StringInfo out, PGLogicalOutputData *data,`
`147`	`147`	`return;`
`148`	`148`	`}`
`149`	`149`	`}`
`150`		`-MtmRecoveryCaughtUp(MtmReplicationNodeId,txn->end_lsn);`
`151`		`-`
`152`	`150`	`pq_sendbyte(out,'C');/* sending COMMIT */`
`153`	`151`
`154`	`152`	`MTM_INFO("PGLOGICAL_SEND commit: event=%d, gid=%s, commit_lsn=%lx, txn->end_lsn=%lx, xlog=%lx\n",flags,txn->gid,commit_lsn,txn->end_lsn,GetXLogInsertRecPtr());`
`155`	`153`
`156`	`154`	`/* send the flags field */`
`157`	`155`	`pq_sendbyte(out,flags);`
`158`	`156`	`pq_sendbyte(out,MtmNodeId);`
`159`		`-/pq_sendbyte(out, MtmRecoveryCaughtUp(MtmReplicationNodeId, txn->end_lsn));/`
	`157`	`+pq_sendbyte(out,MtmRecoveryCaughtUp(MtmReplicationNodeId,txn->end_lsn));`
`160`	`158`
`161`	`159`	`/* send fixed fields */`
`162`	`160`	`pq_sendint64(out,commit_lsn);`

Comments

(0)