NotificationsYou must be signed in to change notification settings
Fork6
Star31

Commitddd7b22

committed

Stop table sync workers when subscription relation entry is removed

When a table sync worker is in waiting state and the subscription tableentry is removed because of a concurrent subscription refresh, theworker could be left orphaned. To avoid that, explicitly stop theworker when the pg_subscription_rel entry is removed.Reported-by: Masahiko Sawada <sawada.mshk@gmail.com>

1 parenteab8689 commitddd7b22Copy full SHA for ddd7b22

File tree

1 file changed

-0

lines changed

src/backend/commands
- subscriptioncmds.c

1 file changed

-0

lines changed

`‎src/backend/commands/subscriptioncmds.c‎`

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -600,6 +600,8 @@ AlterSubscription_refresh(Subscription *sub, bool copy_data)`
`600`	`600`
`601`	`601`	`RemoveSubscriptionRel(sub->oid,relid);`
`602`	`602`
	`603`	`+logicalrep_worker_stop(sub->oid,relid);`
	`604`	`+`
`603`	`605`	`namespace=get_namespace_name(get_rel_namespace(relid));`
`604`	`606`	`ereport(NOTICE,`
`605`	`607`	`(errmsg("removed subscription for table %s.%s",`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commitddd7b22

File tree

1 file changed

1 file changed

`‎src/backend/commands/subscriptioncmds.c‎`

0 commit comments