diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/backend/nodes/copyfuncs.c | 3 | ||||
| -rw-r--r-- | src/backend/nodes/equalfuncs.c | 3 | ||||
| -rw-r--r-- | src/include/replication/worker_internal.h | 2 |
3 files changed, 7 insertions, 1 deletions
diff --git a/src/backend/nodes/copyfuncs.c b/src/backend/nodes/copyfuncs.c index 67c7de670bb..93d4eb207f1 100644 --- a/src/backend/nodes/copyfuncs.c +++ b/src/backend/nodes/copyfuncs.c @@ -4450,7 +4450,10 @@ _copyAlterSubscriptionStmt(const AlterSubscriptionStmt *from) { AlterSubscriptionStmt *newnode = makeNode(AlterSubscriptionStmt); + COPY_SCALAR_FIELD(kind); COPY_STRING_FIELD(subname); + COPY_STRING_FIELD(conninfo); + COPY_NODE_FIELD(publication); COPY_NODE_FIELD(options); return newnode; diff --git a/src/backend/nodes/equalfuncs.c b/src/backend/nodes/equalfuncs.c index 4d8e7fe9b00..6b40b56f71e 100644 --- a/src/backend/nodes/equalfuncs.c +++ b/src/backend/nodes/equalfuncs.c @@ -2199,7 +2199,10 @@ static bool _equalAlterSubscriptionStmt(const AlterSubscriptionStmt *a, const AlterSubscriptionStmt *b) { + COMPARE_SCALAR_FIELD(kind); COMPARE_STRING_FIELD(subname); + COMPARE_STRING_FIELD(conninfo); + COMPARE_NODE_FIELD(publication); COMPARE_NODE_FIELD(options); return true; diff --git a/src/include/replication/worker_internal.h b/src/include/replication/worker_internal.h index bf96d340caa..5bebca34ef8 100644 --- a/src/include/replication/worker_internal.h +++ b/src/include/replication/worker_internal.h @@ -46,7 +46,7 @@ typedef struct LogicalRepWorker } LogicalRepWorker; /* Memory context for cached variables in apply worker. */ -MemoryContext ApplyCacheContext; +extern MemoryContext ApplyCacheContext; /* libpqreceiver connection */ extern struct WalReceiverConn *wrconn; |