forked frompostgres/postgres
- Notifications
You must be signed in to change notification settings - Fork6
Commit79243de

Amit Kapila
Restart the apply worker if the privileges have been revoked.
Restart the apply worker if the subscription owner's superuser privilegeshave been revoked. This is required so that the subscription connectionstring gets revalidated and use the password option to connect to thepublisher for non-superusers, if required.Author: Vignesh CReviewed-by: Amit KapilaDiscussion:http://postgr.es/m/CALDaNm2Dxmhq08nr4P6G+24QvdBo_GAVyZ_Q1TcGYK+8NHs9xw@mail.gmail.com1 parent2f04720 commit79243de
File tree
6 files changed
+60
-11
lines changed- src
- backend
- catalog
- commands
- replication/logical
- include/catalog
- test/subscription/t
6 files changed
+60
-11
lines changedLines changed: 3 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
108 | 108 |
| |
109 | 109 |
| |
110 | 110 |
| |
| 111 | + | |
| 112 | + | |
| 113 | + | |
111 | 114 |
| |
112 | 115 |
| |
113 | 116 |
| |
|
Lines changed: 2 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
869 | 869 |
| |
870 | 870 |
| |
871 | 871 |
| |
872 |
| - | |
| 872 | + | |
873 | 873 |
| |
874 | 874 |
| |
875 | 875 |
| |
| |||
1249 | 1249 |
| |
1250 | 1250 |
| |
1251 | 1251 |
| |
1252 |
| - | |
| 1252 | + | |
1253 | 1253 |
| |
1254 | 1254 |
| |
1255 | 1255 |
| |
|
Lines changed: 2 additions & 4 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1275 | 1275 |
| |
1276 | 1276 |
| |
1277 | 1277 |
| |
| 1278 | + | |
1278 | 1279 |
| |
1279 | 1280 |
| |
1280 | 1281 |
| |
1281 |
| - | |
1282 |
| - | |
1283 |
| - | |
1284 |
| - | |
| 1282 | + | |
1285 | 1283 |
| |
1286 | 1284 |
| |
1287 | 1285 |
| |
|
Lines changed: 28 additions & 5 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
3966 | 3966 |
| |
3967 | 3967 |
| |
3968 | 3968 |
| |
| 3969 | + | |
| 3970 | + | |
| 3971 | + | |
| 3972 | + | |
| 3973 | + | |
| 3974 | + | |
| 3975 | + | |
| 3976 | + | |
| 3977 | + | |
| 3978 | + | |
| 3979 | + | |
| 3980 | + | |
| 3981 | + | |
| 3982 | + | |
| 3983 | + | |
| 3984 | + | |
| 3985 | + | |
| 3986 | + | |
3969 | 3987 |
| |
3970 | 3988 |
| |
3971 | 3989 |
| |
| |||
4492 | 4510 |
| |
4493 | 4511 |
| |
4494 | 4512 |
| |
| 4513 | + | |
4495 | 4514 |
| |
4496 | 4515 |
| |
4497 | 4516 |
| |
4498 |
| - | |
4499 |
| - | |
4500 |
| - | |
4501 |
| - | |
| 4517 | + | |
4502 | 4518 |
| |
4503 | 4519 |
| |
4504 | 4520 |
| |
| |||
4621 | 4637 |
| |
4622 | 4638 |
| |
4623 | 4639 |
| |
4624 |
| - | |
| 4640 | + | |
| 4641 | + | |
| 4642 | + | |
| 4643 | + | |
4625 | 4644 |
| |
4626 | 4645 |
| |
4627 | 4646 |
| |
4628 | 4647 |
| |
| 4648 | + | |
| 4649 | + | |
| 4650 | + | |
| 4651 | + | |
4629 | 4652 |
| |
4630 | 4653 |
| |
4631 | 4654 |
| |
|
Lines changed: 1 addition & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
127 | 127 |
| |
128 | 128 |
| |
129 | 129 |
| |
| 130 | + | |
130 | 131 |
| |
131 | 132 |
| |
132 | 133 |
| |
|
Lines changed: 24 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
104 | 104 |
| |
105 | 105 |
| |
106 | 106 |
| |
| 107 | + | |
107 | 108 |
| |
108 | 109 |
| |
109 | 110 |
| |
| |||
303 | 304 |
| |
304 | 305 |
| |
305 | 306 |
| |
| 307 | + | |
| 308 | + | |
| 309 | + | |
| 310 | + | |
| 311 | + | |
| 312 | + | |
| 313 | + | |
| 314 | + | |
| 315 | + | |
| 316 | + | |
| 317 | + | |
| 318 | + | |
| 319 | + | |
| 320 | + | |
| 321 | + | |
| 322 | + | |
| 323 | + | |
| 324 | + | |
| 325 | + | |
| 326 | + | |
| 327 | + | |
| 328 | + | |
| 329 | + | |
306 | 330 |
|
0 commit comments
Comments
(0)