database/postgres
database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-05-01 01:04:50 +03:00
Code

Fix typos in decode.c and logical.c.

Browse Source 
Per report by Ajin Cherian in email:
https://postgr.es/m/CAFPTHDYnRKDvzgDxoMn_CKqXA-D0MtrbyJvfvjBsO4G=UHDXkg@mail.gmail.com
This commit is contained in:
Amit Kapila 2021-01-06 08:56:19 +05:30
parent 25dde58357
commit e02e840ff7
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/backend/replication/logical/decode.c
View File

@ -685,10 +685,10 @@ DecodeCommit(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
* so during startup, to get to the first transaction the client needs. As * so during startup, to get to the first transaction the client needs. As
* we have reset the catalog caches before starting to read WAL, and we * we have reset the catalog caches before starting to read WAL, and we
* haven't yet touched any catalogs, there can't be anything to invalidate. * haven't yet touched any catalogs, there can't be anything to invalidate.
* But if we're "forgetting" this commit because it's it happened in * But if we're "forgetting" this commit because it happened in another
* another database, the invalidations might be important, because they * database, the invalidations might be important, because they could be
* could be for shared catalogs and we might have loaded data into the * for shared catalogs and we might have loaded data into the relevant
* relevant syscaches. * syscaches.
* --- * ---
*/ */
if (DecodeTXNNeedSkip(ctx, buf, parsed->dbId, origin_id)) if (DecodeTXNNeedSkip(ctx, buf, parsed->dbId, origin_id))

2
src/backend/replication/logical/logical.c
View File

@ -1371,7 +1371,7 @@ stream_commit_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn,
ctx->write_xid = txn->xid; ctx->write_xid = txn->xid;
ctx->write_location = txn->end_lsn; ctx->write_location = txn->end_lsn;
/* in streaming mode, stream_abort_cb is required */ /* in streaming mode, stream_commit_cb is required */
if (ctx->callbacks.stream_commit_cb == NULL) if (ctx->callbacks.stream_commit_cb == NULL)
ereport(ERROR, ereport(ERROR,
(errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE), (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),