Commit626dd6f

authored and

committed

Do not mark node as disabled on logical replication connection failure

1 parent0055b46 commit626dd6fCopy full SHA for 626dd6f

File tree

-2

lines changed

-2

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1076,7 +1076,7 @@ bool MtmRecoveryCaughtUp(int nodeId, XLogRecPtr slotLSN)`
`1076`	`1076`	`BIT_CLEAR(Mtm->nodeLockerMask,nodeId-1);`
`1077`	`1077`	`Mtm->nLockers-=1;`
`1078`	`1078`	`}else {`
`1079`		`-MTM_LOG1("%d:dode %d is caugth-up without locking cluster",MyProcPid,nodeId);`
	`1079`	`+MTM_LOG1("%d:node %d is caugth-up without locking cluster",MyProcPid,nodeId);`
`1080`	`1080`	`/* We are lucky: caugth-up without locking cluster! */`
`1081`	`1081`	`}`
`1082`	`1082`	`BIT_CLEAR(Mtm->disabledNodeMask,nodeId-1);`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -249,7 +249,7 @@ pglogical_receiver_main(Datum main_arg)`
`249`	`249`	`PQfinish(conn);`
`250`	`250`	`ereport(WARNING, (errmsg("%s: Could not establish connection to remote server",`
`251`	`251`	`worker_proc)));`
`252`		`-MtmOnNodeDisconnect(args->remote_node);`
	`252`	`+/MtmOnNodeDisconnect(args->remote_node); /`
`253`	`253`	`proc_exit(1);`
`254`	`254`	`}`
`255`	`255`

Comments

(0)