Commit03737b4

committed

Test on buildfarm: try to reconnect receiver on slot error

1 parentd65bd10 commit03737b4Copy full SHA for 03737b4

File tree

+14

-13

lines changed

+14

-13

lines changed

Lines changed: 14 additions & 13 deletions

Original file line number	Diff line number	Diff line change
`@@ -366,20 +366,21 @@ pglogical_receiver_main(Datum main_arg)`
`366`	`366`	`res=PQexec(conn,query->data);`
`367`	`367`	`if (PQresultStatus(res)!=PGRES_COPY_BOTH)`
`368`	`368`	`{`
`369`		`-inti,n_deleted_slots=0;`
	`369`	`+//int i, n_deleted_slots = 0;`
`370`	`370`
`371`		`-elog(WARNING,"Can't find slot on node%d. Shutting down receiver.",nodeId);`
`372`		`-Mtm->nodes[nodeId-1].slotDeleted= true;`
`373`		`-for (i=0;i<Mtm->nAllNodes;i++)`
`374`		`-{`
`375`		`-if (Mtm->nodes[i].slotDeleted)`
`376`		`-n_deleted_slots++;`
`377`		`-}`
`378`		`-if (n_deleted_slots==Mtm->nAllNodes-1)`
`379`		`-{`
`380`		`-elog(FATAL,"All neighbour nopes have no replication slot for us. Exiting.");`
`381`		`-}`
`382`		`-proc_exit(1);`
	`371`	`+elog(WARNING,"Can't find slot on node%d. Shutting down receiver. %s",nodeId,PQresultErrorMessage(res));`
	`372`	`+gotoOnError;`
	`373`	`+// Mtm->nodes[nodeId-1].slotDeleted = true;`
	`374`	`+// for (i = 0; i < Mtm->nAllNodes; i++)`
	`375`	`+// {`
	`376`	`+// if (Mtm->nodes[i].slotDeleted)`
	`377`	`+// n_deleted_slots++;`
	`378`	`+// }`
	`379`	`+// if (n_deleted_slots == Mtm->nAllNodes - 1)`
	`380`	`+// {`
	`381`	`+// elog(FATAL, "All neighbour nopes have no replication slot for us. Exiting.");`
	`382`	`+// }`
	`383`	`+// proc_exit(1);`
`383`	`384`	`}`
`384`	`385`	`PQclear(res);`
`385`	`386`	`resetPQExpBuffer(query);`

Comments

(0)