database/postgres
database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-05-06 19:59:18 +03:00
Code

Make lsn argument of walrcv_create_slot() optional

Browse Source 
Some callers are not using it, so it's wasteful to have to specify it.

Reviewed-by: Masahiko Sawada <masahiko.sawada@2ndquadrant.com>
Discussion: https://www.postgresql.org/message-id/CA+fd4k4BcYrYucNfTnK-CQX3+jsG+PRPEhHAUSo-W4P0Lec57A@mail.gmail.com
This commit is contained in:
Peter Eisentraut 2020-01-11 09:00:19 +01:00
parent c096a804d9
commit c67a55da4e
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/backend/commands/subscriptioncmds.c
View File

@ -428,7 +428,6 @@ CreateSubscription(CreateSubscriptionStmt *stmt, bool isTopLevel)
*/ */
if (connect) if (connect)
{ {
XLogRecPtr lsn;
char *err; char *err;
WalReceiverConn *wrconn; WalReceiverConn *wrconn;
List *tables; List *tables;
@ -479,7 +478,7 @@ CreateSubscription(CreateSubscriptionStmt *stmt, bool isTopLevel)
Assert(slotname); Assert(slotname);
walrcv_create_slot(wrconn, slotname, false, walrcv_create_slot(wrconn, slotname, false,
CRS_NOEXPORT_SNAPSHOT, &lsn); CRS_NOEXPORT_SNAPSHOT, NULL);
ereport(NOTICE, ereport(NOTICE,
(errmsg("created replication slot \"%s\" on publisher", (errmsg("created replication slot \"%s\" on publisher",
slotname))); slotname)));

6
src/backend/replication/libpqwalreceiver/libpqwalreceiver.c
View File

@ -844,8 +844,10 @@ libpqrcv_create_slot(WalReceiverConn *conn, const char *slotname,
slotname, pchomp(PQerrorMessage(conn->streamConn))))); slotname, pchomp(PQerrorMessage(conn->streamConn)))));
} }
*lsn = DatumGetLSN(DirectFunctionCall1Coll(pg_lsn_in, InvalidOid, if (lsn)
CStringGetDatum(PQgetvalue(res, 0, 1)))); *lsn = DatumGetLSN(DirectFunctionCall1Coll(pg_lsn_in, InvalidOid,
CStringGetDatum(PQgetvalue(res, 0, 1))));
if (!PQgetisnull(res, 0, 2)) if (!PQgetisnull(res, 0, 2))
snapshot = pstrdup(PQgetvalue(res, 0, 2)); snapshot = pstrdup(PQgetvalue(res, 0, 2));
else else