Fix typos in decode.c and logical.c.

Per report by Ajin Cherian in email:
https://postgr.es/m/CAFPTHDYnRKDvzgDxoMn_CKqXA-D0MtrbyJvfvjBsO4G=UHDXkg@mail.gmail.com

diff --git a/src/backend/replication/logical/decode.c b/src/backend/replication/logical/decode.c
index 23ab3cf60524687459206862a2daaf50ed704b9b..afa1df00d0eafcfb44183ed308d083cdef27c2e1 100644 (file)
--- a/src/backend/replication/logical/decode.c
+++ b/src/backend/replication/logical/decode.c
@@ -685,10 +685,10 @@ DecodeCommit(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
     * 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
     * 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
-    * another database, the invalidations might be important, because they
-    * could be for shared catalogs and we might have loaded data into the
-    * relevant syscaches.
+    * But if we're "forgetting" this commit because it happened in another
+    * database, the invalidations might be important, because they could be
+    * for shared catalogs and we might have loaded data into the relevant
+    * syscaches.
     * ---
     */
    if (DecodeTXNNeedSkip(ctx, buf, parsed->dbId, origin_id))

diff --git a/src/backend/replication/logical/logical.c b/src/backend/replication/logical/logical.c
index 605ec0986caa311e625007eac9b82e532f123403..0977aec711cff529320f1e73285b2a3f02c2a80f 100644 (file)
--- a/src/backend/replication/logical/logical.c
+++ b/src/backend/replication/logical/logical.c
@@ -1371,7 +1371,7 @@ stream_commit_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn,
    ctx->write_xid = txn->xid;
    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)
        ereport(ERROR,
                (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),