- Notifications
You must be signed in to change notification settings - Fork28
Commiteb4da3e
committed
Add option to control snapshot export to CREATE_REPLICATION_SLOT
We used to export snapshots unconditionally in CREATE_REPLICATION_SLOTin the replication protocol, but several upcoming patches want morecontrol over what happens.Suppress snapshot export in pg_recvlogical, which neither needs nor canuse the exported snapshot. Since snapshot exporting can fail thisimproves reliability.This also paves the way for allowing the creation of replication slotson standbys, which cannot export snapshots because they cannot allocatenew XIDs.Author: Petr Jelinek <petr.jelinek@2ndquadrant.com>1 parent7150402 commiteb4da3e
File tree
10 files changed
+141
-26
lines changed- doc/src/sgml
- src
- backend
- commands
- replication
- libpqwalreceiver
- bin/pg_basebackup
- include
- nodes
- replication
10 files changed
+141
-26
lines changedLines changed: 9 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
271 | 271 |
| |
272 | 272 |
| |
273 | 273 |
| |
274 |
| - | |
275 |
| - | |
| 274 | + | |
| 275 | + | |
| 276 | + | |
276 | 277 |
| |
277 | 278 |
| |
278 | 279 |
| |
| |||
282 | 283 |
| |
283 | 284 |
| |
284 | 285 |
| |
| 286 | + | |
| 287 | + | |
| 288 | + | |
| 289 | + | |
| 290 | + | |
| 291 | + | |
285 | 292 |
| |
286 | 293 |
| |
287 | 294 |
| |
|
Lines changed: 17 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1486 | 1486 |
| |
1487 | 1487 |
| |
1488 | 1488 |
| |
1489 |
| - | |
1490 |
| - | |
| 1489 | + | |
| 1490 | + | |
1491 | 1491 |
| |
1492 | 1492 |
| |
1493 | 1493 |
| |
| |||
1538 | 1538 |
| |
1539 | 1539 |
| |
1540 | 1540 |
| |
| 1541 | + | |
| 1542 | + | |
| 1543 | + | |
| 1544 | + | |
| 1545 | + | |
| 1546 | + | |
| 1547 | + | |
| 1548 | + | |
| 1549 | + | |
| 1550 | + | |
| 1551 | + | |
| 1552 | + | |
| 1553 | + | |
| 1554 | + | |
| 1555 | + | |
1541 | 1556 |
| |
1542 | 1557 |
| |
1543 | 1558 |
| |
|
Lines changed: 5 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
314 | 314 |
| |
315 | 315 |
| |
316 | 316 |
| |
317 |
| - | |
| 317 | + | |
| 318 | + | |
| 319 | + | |
| 320 | + | |
| 321 | + | |
318 | 322 |
| |
319 | 323 |
| |
320 | 324 |
| |
|
Lines changed: 11 additions & 4 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
68 | 68 |
| |
69 | 69 |
| |
70 | 70 |
| |
| 71 | + | |
71 | 72 |
| |
72 | 73 |
| |
73 | 74 |
| |
| |||
720 | 721 |
| |
721 | 722 |
| |
722 | 723 |
| |
723 |
| - | |
| 724 | + | |
724 | 725 |
| |
725 | 726 |
| |
726 | 727 |
| |
727 | 728 |
| |
728 | 729 |
| |
729 | 730 |
| |
730 | 731 |
| |
731 |
| - | |
| 732 | + | |
732 | 733 |
| |
733 | 734 |
| |
734 |
| - | |
| 735 | + | |
735 | 736 |
| |
736 | 737 |
| |
737 |
| - | |
| 738 | + | |
| 739 | + | |
| 740 | + | |
| 741 | + | |
| 742 | + | |
| 743 | + | |
| 744 | + | |
738 | 745 |
| |
739 | 746 |
| |
740 | 747 |
| |
|
Lines changed: 34 additions & 9 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
79 | 79 |
| |
80 | 80 |
| |
81 | 81 |
| |
| 82 | + | |
| 83 | + | |
82 | 84 |
| |
83 | 85 |
| |
84 | 86 |
| |
| |||
91 | 93 |
| |
92 | 94 |
| |
93 | 95 |
| |
94 |
| - | |
| 96 | + | |
| 97 | + | |
| 98 | + | |
95 | 99 |
| |
96 | 100 |
| |
97 | 101 |
| |
| |||
202 | 206 |
| |
203 | 207 |
| |
204 | 208 |
| |
205 |
| - | |
| 209 | + | |
206 | 210 |
| |
207 | 211 |
| |
208 | 212 |
| |
209 | 213 |
| |
210 | 214 |
| |
211 | 215 |
| |
212 |
| - | |
| 216 | + | |
213 | 217 |
| |
214 | 218 |
| |
215 | 219 |
| |
216 |
| - | |
| 220 | + | |
217 | 221 |
| |
218 | 222 |
| |
219 | 223 |
| |
220 | 224 |
| |
221 | 225 |
| |
222 | 226 |
| |
223 | 227 |
| |
| 228 | + | |
224 | 229 |
| |
225 | 230 |
| |
226 | 231 |
| |
227 | 232 |
| |
| 233 | + | |
| 234 | + | |
| 235 | + | |
| 236 | + | |
| 237 | + | |
| 238 | + | |
| 239 | + | |
| 240 | + | |
| 241 | + | |
| 242 | + | |
| 243 | + | |
| 244 | + | |
| 245 | + | |
| 246 | + | |
| 247 | + | |
| 248 | + | |
| 249 | + | |
| 250 | + | |
| 251 | + | |
| 252 | + | |
| 253 | + | |
| 254 | + | |
| 255 | + | |
| 256 | + | |
| 257 | + | |
228 | 258 |
| |
229 | 259 |
| |
230 | 260 |
| |
| |||
291 | 321 |
| |
292 | 322 |
| |
293 | 323 |
| |
294 |
| - | |
295 |
| - | |
296 |
| - | |
297 |
| - | |
298 |
| - | |
299 | 324 |
| |
300 | 325 |
| |
301 | 326 |
| |
|
Lines changed: 2 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
100 | 100 |
| |
101 | 101 |
| |
102 | 102 |
| |
| 103 | + | |
| 104 | + | |
103 | 105 |
| |
104 | 106 |
| |
105 | 107 |
| |
|
Lines changed: 54 additions & 4 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
51 | 51 |
| |
52 | 52 |
| |
53 | 53 |
| |
| 54 | + | |
54 | 55 |
| |
55 | 56 |
| |
56 | 57 |
| |
| |||
737 | 738 |
| |
738 | 739 |
| |
739 | 740 |
| |
| 741 | + | |
| 742 | + | |
| 743 | + | |
| 744 | + | |
| 745 | + | |
| 746 | + | |
| 747 | + | |
| 748 | + | |
| 749 | + | |
| 750 | + | |
| 751 | + | |
| 752 | + | |
| 753 | + | |
| 754 | + | |
| 755 | + | |
| 756 | + | |
| 757 | + | |
| 758 | + | |
| 759 | + | |
| 760 | + | |
| 761 | + | |
| 762 | + | |
| 763 | + | |
| 764 | + | |
| 765 | + | |
| 766 | + | |
| 767 | + | |
| 768 | + | |
| 769 | + | |
| 770 | + | |
| 771 | + | |
| 772 | + | |
| 773 | + | |
| 774 | + | |
| 775 | + | |
| 776 | + | |
| 777 | + | |
| 778 | + | |
| 779 | + | |
| 780 | + | |
| 781 | + | |
| 782 | + | |
740 | 783 |
| |
741 | 784 |
| |
742 | 785 |
| |
| |||
746 | 789 |
| |
747 | 790 |
| |
748 | 791 |
| |
| 792 | + | |
| 793 | + | |
749 | 794 |
| |
750 | 795 |
| |
751 | 796 |
| |
| |||
754 | 799 |
| |
755 | 800 |
| |
756 | 801 |
| |
| 802 | + | |
| 803 | + | |
757 | 804 |
| |
758 | 805 |
| |
759 | 806 |
| |
| |||
799 | 846 |
| |
800 | 847 |
| |
801 | 848 |
| |
802 |
| - | |
803 |
| - | |
| 849 | + | |
| 850 | + | |
| 851 | + | |
| 852 | + | |
804 | 853 |
| |
805 |
| - | |
| 854 | + | |
| 855 | + | |
806 | 856 |
| |
807 | 857 |
| |
808 | 858 |
| |
809 | 859 |
| |
810 | 860 |
| |
811 | 861 |
| |
812 | 862 |
| |
813 |
| - | |
| 863 | + | |
814 | 864 |
| |
815 | 865 |
| |
816 | 866 |
| |
|
Lines changed: 5 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
338 | 338 |
| |
339 | 339 |
| |
340 | 340 |
| |
| 341 | + | |
341 | 342 |
| |
342 | 343 |
| |
| 344 | + | |
| 345 | + | |
| 346 | + | |
| 347 | + | |
343 | 348 |
| |
344 | 349 |
| |
345 | 350 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
56 | 56 |
| |
57 | 57 |
| |
58 | 58 |
| |
59 |
| - | |
| 59 | + | |
60 | 60 |
| |
61 | 61 |
| |
62 | 62 |
| |
|
Lines changed: 3 additions & 3 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
183 | 183 |
| |
184 | 184 |
| |
185 | 185 |
| |
186 |
| - | |
| 186 | + | |
187 | 187 |
| |
188 | 188 |
| |
189 | 189 |
| |
| |||
224 | 224 |
| |
225 | 225 |
| |
226 | 226 |
| |
227 |
| - | |
228 |
| - | |
| 227 | + | |
| 228 | + | |
229 | 229 |
| |
230 | 230 |
| |
231 | 231 |
| |
|
0 commit comments
Comments
(0)