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.
*
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())
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();
}
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();
}
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())
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();
}
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();
}