Commit7694665

committed

Fix possible segfault

1 parent2cfd624 commit7694665Copy full SHA for 7694665

File tree

-2

lines changed

-2

lines changed

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -211,7 +211,7 @@ pglogical_receiver_main(Datum main_arg)`
`211`	`211`	`PGresult*res;`
`212`	`212`	`MtmReplicationModemode;`
`213`	`213`
`214`		`-ByteBufferbuf;`
	`214`	`+ByteBufferbuf;`
`215`	`215`	`RepOriginIdoriginId;`
`216`	`216`	`char*originName;`
`217`	`217`	`/* Buffer for COPY data */`
`@@ -222,6 +222,8 @@ pglogical_receiver_main(Datum main_arg)`
`222`	`222`	`char*connString=psprintf("replication=database %s",Mtm->nodes[nodeId-1].con.connStr);`
`223`	`223`	`staticPortalDatafakePortal;`
`224`	`224`
	`225`	`+ByteBufferAlloc(&buf);`
	`226`	`+`
`225`	`227`	`slotName=psprintf(MULTIMASTER_SLOT_PATTERN,MtmNodeId);`
`226`	`228`
`227`	`229`	`MtmIsLogicalReceiver= true;`
`@@ -363,7 +365,6 @@ pglogical_receiver_main(Datum main_arg)`
`363`	`365`	`resetPQExpBuffer(query);`
`364`	`366`
`365`	`367`	`MtmReceiverStarted(nodeId);`
`366`		`-ByteBufferAlloc(&buf);`
`367`	`368`
`368`	`369`	`while (!got_sigterm)`
`369`	`370`	`{`

Comments

(0)