diff options
Diffstat (limited to 'src/backend/replication/walsender.c')
| -rw-r--r-- | src/backend/replication/walsender.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/backend/replication/walsender.c b/src/backend/replication/walsender.c index d46374ddce..5f52e33207 100644 --- a/src/backend/replication/walsender.c +++ b/src/backend/replication/walsender.c @@ -1516,7 +1516,7 @@ exec_replication_command(const char *cmd_string) break; case T_BaseBackupCmd: - PreventTransactionChain(true, "BASE_BACKUP"); + PreventInTransactionBlock(true, "BASE_BACKUP"); SendBaseBackup((BaseBackupCmd *) cmd_node); break; @@ -1532,7 +1532,7 @@ exec_replication_command(const char *cmd_string) { StartReplicationCmd *cmd = (StartReplicationCmd *) cmd_node; - PreventTransactionChain(true, "START_REPLICATION"); + PreventInTransactionBlock(true, "START_REPLICATION"); if (cmd->kind == REPLICATION_KIND_PHYSICAL) StartReplication(cmd); @@ -1542,7 +1542,7 @@ exec_replication_command(const char *cmd_string) } case T_TimeLineHistoryCmd: - PreventTransactionChain(true, "TIMELINE_HISTORY"); + PreventInTransactionBlock(true, "TIMELINE_HISTORY"); SendTimeLineHistory((TimeLineHistoryCmd *) cmd_node); break; |