We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2cfd624 commit 7694665Copy full SHA for 7694665
pglogical_receiver.c
@@ -211,7 +211,7 @@ pglogical_receiver_main(Datum main_arg)
211
PGresult *res;
212
MtmReplicationMode mode;
213
214
- ByteBuffer buf;
+ ByteBuffer buf;
215
RepOriginId originId;
216
char* originName;
217
/* Buffer for COPY data */
@@ -222,6 +222,8 @@ pglogical_receiver_main(Datum main_arg)
222
char* connString = psprintf("replication=database %s", Mtm->nodes[nodeId-1].con.connStr);
223
static PortalData fakePortal;
224
225
+ ByteBufferAlloc(&buf);
226
+
227
slotName = psprintf(MULTIMASTER_SLOT_PATTERN, MtmNodeId);
228
229
MtmIsLogicalReceiver = true;
@@ -363,7 +365,6 @@ pglogical_receiver_main(Datum main_arg)
363
365
resetPQExpBuffer(query);
364
366
367
MtmReceiverStarted(nodeId);
- ByteBufferAlloc(&buf);
368
369
while (!got_sigterm)
370
{
0 commit comments