forked frompostgres/postgres
- Notifications
You must be signed in to change notification settings - Fork6
Commitc6e1f62
committed
Wake up a subscription's replication worker processes after DDL.
Waken related worker processes immediately at commit of a transactionthat has performed ALTER SUBSCRIPTION (including the RENAME andOWNER variants). This reduces the response time for such operations.In the real world that might not be worth much, but it shaves severalseconds off the runtime for the subscription test suite.In the case of PREPARE, we just throw away this notification state;it doesn't seem worth the work to preserve it. The workers willstill react after the eventual COMMIT PREPARED, but not as quickly.Nathan BossartDiscussion:https://postgr.es/m/20221122004119.GA132961@nathanxps131 parent4c032dd commitc6e1f62
File tree
5 files changed
+72
-0
lines changed- src
- backend
- access/transam
- commands
- replication/logical
- include/replication
5 files changed
+72
-0
lines changedLines changed: 6 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
47 | 47 |
| |
48 | 48 |
| |
49 | 49 |
| |
| 50 | + | |
50 | 51 |
| |
51 | 52 |
| |
52 | 53 |
| |
| |||
2360 | 2361 |
| |
2361 | 2362 |
| |
2362 | 2363 |
| |
| 2364 | + | |
2363 | 2365 |
| |
2364 | 2366 |
| |
2365 | 2367 |
| |
| |||
2647 | 2649 |
| |
2648 | 2650 |
| |
2649 | 2651 |
| |
| 2652 | + | |
| 2653 | + | |
| 2654 | + | |
2650 | 2655 |
| |
2651 | 2656 |
| |
2652 | 2657 |
| |
| |||
2860 | 2865 |
| |
2861 | 2866 |
| |
2862 | 2867 |
| |
| 2868 | + | |
2863 | 2869 |
| |
2864 | 2870 |
| |
2865 | 2871 |
| |
|
Lines changed: 4 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
59 | 59 |
| |
60 | 60 |
| |
61 | 61 |
| |
| 62 | + | |
62 | 63 |
| |
63 | 64 |
| |
64 | 65 |
| |
| |||
279 | 280 |
| |
280 | 281 |
| |
281 | 282 |
| |
| 283 | + | |
| 284 | + | |
| 285 | + | |
282 | 286 |
| |
283 | 287 |
| |
284 | 288 |
| |
|
Lines changed: 6 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
34 | 34 |
| |
35 | 35 |
| |
36 | 36 |
| |
| 37 | + | |
37 | 38 |
| |
38 | 39 |
| |
39 | 40 |
| |
| |||
1362 | 1363 |
| |
1363 | 1364 |
| |
1364 | 1365 |
| |
| 1366 | + | |
| 1367 | + | |
| 1368 | + | |
1365 | 1369 |
| |
1366 | 1370 |
| |
1367 | 1371 |
| |
| |||
1732 | 1736 |
| |
1733 | 1737 |
| |
1734 | 1738 |
| |
| 1739 | + | |
1735 | 1740 |
| |
| 1741 | + | |
1736 | 1742 |
| |
1737 | 1743 |
| |
1738 | 1744 |
| |
|
Lines changed: 52 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
254 | 254 |
| |
255 | 255 |
| |
256 | 256 |
| |
| 257 | + | |
| 258 | + | |
257 | 259 |
| |
258 | 260 |
| |
259 | 261 |
| |
| |||
4092 | 4094 |
| |
4093 | 4095 |
| |
4094 | 4096 |
| |
| 4097 | + | |
| 4098 | + | |
| 4099 | + | |
| 4100 | + | |
| 4101 | + | |
| 4102 | + | |
| 4103 | + | |
| 4104 | + | |
| 4105 | + | |
| 4106 | + | |
| 4107 | + | |
| 4108 | + | |
| 4109 | + | |
| 4110 | + | |
| 4111 | + | |
| 4112 | + | |
| 4113 | + | |
| 4114 | + | |
| 4115 | + | |
| 4116 | + | |
| 4117 | + | |
| 4118 | + | |
| 4119 | + | |
| 4120 | + | |
| 4121 | + | |
| 4122 | + | |
| 4123 | + | |
| 4124 | + | |
| 4125 | + | |
| 4126 | + | |
| 4127 | + | |
| 4128 | + | |
| 4129 | + | |
| 4130 | + | |
| 4131 | + | |
| 4132 | + | |
| 4133 | + | |
| 4134 | + | |
| 4135 | + | |
| 4136 | + | |
| 4137 | + | |
| 4138 | + | |
| 4139 | + | |
| 4140 | + | |
| 4141 | + | |
| 4142 | + | |
| 4143 | + | |
| 4144 | + | |
| 4145 | + | |
| 4146 | + |
Lines changed: 4 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
16 | 16 |
| |
17 | 17 |
| |
18 | 18 |
| |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
19 | 23 |
|
0 commit comments
Comments
(0)