@@ -212,9 +212,9 @@ update_local_synced_slot(RemoteSlot *remote_slot, Oid remote_dbid,
212
212
* impact the users, so we used DEBUG1 level to log the message.
213
213
*/
214
214
ereport (slot -> data .persistency == RS_TEMPORARY ? LOG : DEBUG1 ,
215
- errmsg ("could not sync slot \"%s\" as remote slot precedes local slot" ,
215
+ errmsg ("could not synchronize replication slot \"%s\" because remote slot precedes local slot" ,
216
216
remote_slot -> name ),
217
- errdetail ("Remote slot has LSN %X/%X and catalog xmin %u, but local slot has LSN %X/%X and catalog xmin %u." ,
217
+ errdetail ("The remote slot has LSN %X/%X and catalog xmin %u, but the local slot has LSN %X/%X and catalog xmin %u." ,
218
218
LSN_FORMAT_ARGS (remote_slot -> restart_lsn ),
219
219
remote_slot -> catalog_xmin ,
220
220
LSN_FORMAT_ARGS (slot -> data .restart_lsn ),
@@ -456,7 +456,7 @@ drop_local_obsolete_slots(List *remote_slot_list)
456
456
0 , AccessShareLock );
457
457
458
458
ereport (LOG ,
459
- errmsg ("dropped replication slot \"%s\" of dbid %u" ,
459
+ errmsg ("dropped replication slot \"%s\" of database with OID %u" ,
460
460
NameStr (local_slot -> data .name ),
461
461
local_slot -> data .database ));
462
462
}
@@ -576,8 +576,8 @@ update_and_persist_local_synced_slot(RemoteSlot *remote_slot, Oid remote_dbid)
576
576
if (!found_consistent_snapshot )
577
577
{
578
578
ereport (LOG ,
579
- errmsg ("could not sync slot \"%s\"" , remote_slot -> name ),
580
- errdetail ("Logical decoding cannot find consistent point from local slot's LSN %X/%X." ,
579
+ errmsg ("could not synchronize replication slot \"%s\"" , remote_slot -> name ),
580
+ errdetail ("Logical decoding could not find consistent point from local slot's LSN %X/%X." ,
581
581
LSN_FORMAT_ARGS (slot -> data .restart_lsn )));
582
582
583
583
return false;
@@ -586,7 +586,7 @@ update_and_persist_local_synced_slot(RemoteSlot *remote_slot, Oid remote_dbid)
586
586
ReplicationSlotPersist ();
587
587
588
588
ereport (LOG ,
589
- errmsg ("newly created slot \"%s\" is sync-ready now" ,
589
+ errmsg ("newly created replication slot \"%s\" is sync-ready now" ,
590
590
remote_slot -> name ));
591
591
592
592
return true;
@@ -625,7 +625,7 @@ synchronize_one_slot(RemoteSlot *remote_slot, Oid remote_dbid)
625
625
*/
626
626
ereport (AmLogicalSlotSyncWorkerProcess () ? LOG : ERROR ,
627
627
errcode (ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE ),
628
- errmsg ("skipping slot synchronization as the received slot sync"
628
+ errmsg ("skipping slot synchronization because the received slot sync"
629
629
" LSN %X/%X for slot \"%s\" is ahead of the standby position %X/%X" ,
630
630
LSN_FORMAT_ARGS (remote_slot -> confirmed_lsn ),
631
631
remote_slot -> name ,
@@ -992,10 +992,9 @@ validate_remote_info(WalReceiverConn *wrconn)
992
992
if (!primary_slot_valid )
993
993
ereport (ERROR ,
994
994
errcode (ERRCODE_INVALID_PARAMETER_VALUE ),
995
- errmsg ("slot synchronization requires valid primary_slot_name" ),
996
995
/* translator: second %s is a GUC variable name */
997
- errdetail ( "The replication slot \"%s\" specified by %s does not exist on the primary server. " ,
998
- PrimarySlotName , "primary_slot_name" ));
996
+ errmsg ( " replication slot \"%s\" specified by \"%s\" does not exist on primary server" ,
997
+ PrimarySlotName , "primary_slot_name" ));
999
998
1000
999
ExecClearTuple (tupslot );
1001
1000
walrcv_clear_result (res );
@@ -1022,9 +1021,13 @@ CheckAndGetDbnameFromConninfo(void)
1022
1021
if (dbname == NULL )
1023
1022
ereport (ERROR ,
1024
1023
errcode (ERRCODE_INVALID_PARAMETER_VALUE ),
1025
- /* translator: dbname is a specific option; %s is a GUC variable name */
1026
- errmsg ("slot synchronization requires dbname to be specified in %s" ,
1027
- "primary_conninfo" ));
1024
+
1025
+ /*
1026
+ * translator: first %s is a connection option; second %s is a GUC
1027
+ * variable name
1028
+ */
1029
+ errmsg ("replication slot synchronization requires \"%s\" to be specified in \"%s\"" ,
1030
+ "dbname" , "primary_conninfo" ));
1028
1031
return dbname ;
1029
1032
}
1030
1033
@@ -1044,7 +1047,7 @@ ValidateSlotSyncParams(int elevel)
1044
1047
if (wal_level < WAL_LEVEL_LOGICAL )
1045
1048
ereport (ERROR ,
1046
1049
errcode (ERRCODE_INVALID_PARAMETER_VALUE ),
1047
- errmsg ("slot synchronization requires \"wal_level\" >= \"logical\"" ));
1050
+ errmsg ("replication slot synchronization requires \"wal_level\" >= \"logical\"" ));
1048
1051
1049
1052
/*
1050
1053
* A physical replication slot(primary_slot_name) is required on the
@@ -1057,7 +1060,7 @@ ValidateSlotSyncParams(int elevel)
1057
1060
ereport (elevel ,
1058
1061
errcode (ERRCODE_INVALID_PARAMETER_VALUE ),
1059
1062
/* translator: %s is a GUC variable name */
1060
- errmsg ("slot synchronization requires %s to be defined " , "primary_slot_name" ));
1063
+ errmsg ("replication slot synchronization requires \"%s\" to be set " , "primary_slot_name" ));
1061
1064
return false;
1062
1065
}
1063
1066
@@ -1071,7 +1074,7 @@ ValidateSlotSyncParams(int elevel)
1071
1074
ereport (elevel ,
1072
1075
errcode (ERRCODE_INVALID_PARAMETER_VALUE ),
1073
1076
/* translator: %s is a GUC variable name */
1074
- errmsg ("slot synchronization requires %s to be enabled" ,
1077
+ errmsg ("replication slot synchronization requires \"%s\" to be enabled" ,
1075
1078
"hot_standby_feedback" ));
1076
1079
return false;
1077
1080
}
@@ -1085,7 +1088,7 @@ ValidateSlotSyncParams(int elevel)
1085
1088
ereport (elevel ,
1086
1089
errcode (ERRCODE_INVALID_PARAMETER_VALUE ),
1087
1090
/* translator: %s is a GUC variable name */
1088
- errmsg ("slot synchronization requires %s to be defined " ,
1091
+ errmsg ("replication slot synchronization requires \"%s\" to be set " ,
1089
1092
"primary_conninfo" ));
1090
1093
return false;
1091
1094
}
@@ -1123,7 +1126,7 @@ slotsync_reread_config(void)
1123
1126
{
1124
1127
ereport (LOG ,
1125
1128
/* translator: %s is a GUC variable name */
1126
- errmsg ("slot sync worker will shutdown because %s is disabled" , "sync_replication_slots" ));
1129
+ errmsg ("replication slot synchronization worker will shut down because \"%s\" is disabled" , "sync_replication_slots" ));
1127
1130
proc_exit (0 );
1128
1131
}
1129
1132
@@ -1132,7 +1135,7 @@ slotsync_reread_config(void)
1132
1135
(old_hot_standby_feedback != hot_standby_feedback ))
1133
1136
{
1134
1137
ereport (LOG ,
1135
- errmsg ("slot sync worker will restart because of a parameter change" ));
1138
+ errmsg ("replication slot synchronization worker will restart because of a parameter change" ));
1136
1139
1137
1140
/*
1138
1141
* Reset the last-start time for this worker so that the postmaster
@@ -1156,7 +1159,7 @@ ProcessSlotSyncInterrupts(WalReceiverConn *wrconn)
1156
1159
if (ShutdownRequestPending )
1157
1160
{
1158
1161
ereport (LOG ,
1159
- errmsg ("slot sync worker is shutting down on receiving SIGINT" ));
1162
+ errmsg ("replication slot synchronization worker is shutting down on receiving SIGINT" ));
1160
1163
1161
1164
proc_exit (0 );
1162
1165
}
0 commit comments