Fix untranslatable log message assembly
authorPeter Eisentraut <[email protected]>
Thu, 13 Jul 2023 10:56:35 +0000 (12:56 +0200)
committerPeter Eisentraut <[email protected]>
Thu, 13 Jul 2023 11:21:43 +0000 (13:21 +0200)
We can't inject the name of the logical replication worker into a log
message like that.  But for these messages we don't really need the
precision of knowing what kind of worker it was, so just write
"logical replication worker" and keep the message in one piece.

Discussion: https://www.postgresql.org/message-id/flat/CAHut%2BPt1xwATviPGjjtJy5L631SGf3qjV9XUCmxLu16cHamfgg%40mail.gmail.com

src/backend/replication/logical/worker.c

index 0ee764d68f1cbef803ee6555ed79a237a5c6b621..dd353fd1cb0a304ffbaed2a57366a9efb2824eef 100644 (file)
@@ -435,20 +435,6 @@ static inline void reset_apply_error_context_info(void);
 static TransApplyAction get_transaction_apply_action(TransactionId xid,
                                                     ParallelApplyWorkerInfo **winfo);
 
-/*
- * Return the name of the logical replication worker.
- */
-static const char *
-get_worker_name(void)
-{
-   if (am_tablesync_worker())
-       return _("logical replication table synchronization worker");
-   else if (am_parallel_apply_worker())
-       return _("logical replication parallel apply worker");
-   else
-       return _("logical replication apply worker");
-}
-
 /*
  * Form the origin name for the subscription.
  *
@@ -3904,9 +3890,8 @@ maybe_reread_subscription(void)
    if (!newsub)
    {
        ereport(LOG,
-       /* translator: first %s is the name of logical replication worker */
-               (errmsg("%s for subscription \"%s\" will stop because the subscription was removed",
-                       get_worker_name(), MySubscription->name)));
+               (errmsg("logical replication worker for subscription \"%s\" will stop because the subscription was removed",
+                       MySubscription->name)));
 
        /* Ensure we remove no-longer-useful entry for worker's start time */
        if (!am_tablesync_worker() && !am_parallel_apply_worker())
@@ -3918,9 +3903,8 @@ maybe_reread_subscription(void)
    if (!newsub->enabled)
    {
        ereport(LOG,
-       /* translator: first %s is the name of logical replication worker */
-               (errmsg("%s for subscription \"%s\" will stop because the subscription was disabled",
-                       get_worker_name(), MySubscription->name)));
+               (errmsg("logical replication worker for subscription \"%s\" will stop because the subscription was disabled",
+                       MySubscription->name)));
 
        apply_worker_exit();
    }
@@ -3954,9 +3938,8 @@ maybe_reread_subscription(void)
                            MySubscription->name)));
        else
            ereport(LOG,
-           /* translator: first %s is the name of logical replication worker */
-                   (errmsg("%s for subscription \"%s\" will restart because of a parameter change",
-                           get_worker_name(), MySubscription->name)));
+                   (errmsg("logical replication worker for subscription \"%s\" will restart because of a parameter change",
+                           MySubscription->name)));
 
        apply_worker_exit();
    }
@@ -4478,9 +4461,8 @@ InitializeApplyWorker(void)
    if (!MySubscription)
    {
        ereport(LOG,
-       /* translator: %s is the name of logical replication worker */
-               (errmsg("%s for subscription %u will not start because the subscription was removed during startup",
-                       get_worker_name(), MyLogicalRepWorker->subid)));
+               (errmsg("logical replication worker for subscription %u will not start because the subscription was removed during startup",
+                       MyLogicalRepWorker->subid)));
 
        /* Ensure we remove no-longer-useful entry for worker's start time */
        if (!am_tablesync_worker() && !am_parallel_apply_worker())
@@ -4494,9 +4476,8 @@ InitializeApplyWorker(void)
    if (!MySubscription->enabled)
    {
        ereport(LOG,
-       /* translator: first %s is the name of logical replication worker */
-               (errmsg("%s for subscription \"%s\" will not start because the subscription was disabled during startup",
-                       get_worker_name(), MySubscription->name)));
+               (errmsg("logical replication worker for subscription \"%s\" will not start because the subscription was disabled during startup",
+                       MySubscription->name)));
 
        apply_worker_exit();
    }
@@ -4517,9 +4498,8 @@ InitializeApplyWorker(void)
                        get_rel_name(MyLogicalRepWorker->relid))));
    else
        ereport(LOG,
-       /* translator: first %s is the name of logical replication worker */
-               (errmsg("%s for subscription \"%s\" has started",
-                       get_worker_name(), MySubscription->name)));
+               (errmsg("logical replication apply worker for subscription \"%s\" has started",
+                       MySubscription->name)));
 
    CommitTransactionCommand();
 }