forked frompostgres/postgres
- Notifications
You must be signed in to change notification settings - Fork6
Commitabfb296
committed
Rename RBTXN_PREPARE to RBTXN_IS_PREPARE for better clarification.
RBTXN_PREPARE flag and rbtxn_prepared macro could be misinterpreted aseither indicating the transaction type (e.g. a prepared transaction ora normal transaction) or its currentstate (e.g. skipped or its preparemessage is sent), especially after commit072ee84 introduced theRBTXN_SENT_PREPARE flag and the rbtxn_sent_prepare macro.The RBTXN_PREPARE flag (and its corresponding macro) have been renamedto RBTXN_IS_PREPARE to explicitly indicate the transactiontype. Therefore, this commit also adds the RBTXN_IS_PREPARE flag tothe transaction that is a prepared transaction and has been skipped,which previously had only the RBTXN_SKIPPED_PREPARE flag.Reviewed-by: Amit Kapila, Peter SmithDiscussion:https://postgr.es/m/CAA4eK1KgNmBsG%3D155E7QQ6TX9RoWnM4z5Z20SvsbwxSe_QXYsg%40mail.gmail.com1 parent072ee84 commitabfb296
File tree
4 files changed
+38
-24
lines changed- src
- backend/replication/logical
- include/replication
4 files changed
+38
-24
lines changedLines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
164 | 164 |
| |
165 | 165 |
| |
166 | 166 |
| |
167 |
| - | |
| 167 | + | |
168 | 168 |
| |
169 | 169 |
| |
170 | 170 |
| |
|
Lines changed: 31 additions & 19 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1793 | 1793 |
| |
1794 | 1794 |
| |
1795 | 1795 |
| |
1796 |
| - | |
| 1796 | + | |
1797 | 1797 |
| |
1798 | 1798 |
| |
1799 | 1799 |
| |
| |||
1968 | 1968 |
| |
1969 | 1969 |
| |
1970 | 1970 |
| |
1971 |
| - | |
| 1971 | + | |
1972 | 1972 |
| |
1973 | 1973 |
| |
1974 | 1974 |
| |
| |||
2150 | 2150 |
| |
2151 | 2151 |
| |
2152 | 2152 |
| |
2153 |
| - | |
| 2153 | + | |
2154 | 2154 |
| |
2155 | 2155 |
| |
2156 | 2156 |
| |
| |||
2238 | 2238 |
| |
2239 | 2239 |
| |
2240 | 2240 |
| |
2241 |
| - | |
| 2241 | + | |
2242 | 2242 |
| |
2243 | 2243 |
| |
2244 | 2244 |
| |
| |||
2280 | 2280 |
| |
2281 | 2281 |
| |
2282 | 2282 |
| |
2283 |
| - | |
| 2283 | + | |
2284 | 2284 |
| |
2285 | 2285 |
| |
2286 | 2286 |
| |
| |||
2625 | 2625 |
| |
2626 | 2626 |
| |
2627 | 2627 |
| |
2628 |
| - | |
| 2628 | + | |
2629 | 2629 |
| |
2630 | 2630 |
| |
2631 | 2631 |
| |
| |||
2680 | 2680 |
| |
2681 | 2681 |
| |
2682 | 2682 |
| |
2683 |
| - | |
| 2683 | + | |
2684 | 2684 |
| |
2685 | 2685 |
| |
2686 | 2686 |
| |
2687 | 2687 |
| |
2688 |
| - | |
| 2688 | + | |
2689 | 2689 |
| |
2690 | 2690 |
| |
2691 | 2691 |
| |
| |||
2729 | 2729 |
| |
2730 | 2730 |
| |
2731 | 2731 |
| |
2732 |
| - | |
| 2732 | + | |
2733 | 2733 |
| |
2734 | 2734 |
| |
2735 | 2735 |
| |
| |||
2816 | 2816 |
| |
2817 | 2817 |
| |
2818 | 2818 |
| |
2819 |
| - | |
| 2819 | + | |
2820 | 2820 |
| |
2821 | 2821 |
| |
2822 | 2822 |
| |
| |||
2853 | 2853 |
| |
2854 | 2854 |
| |
2855 | 2855 |
| |
2856 |
| - | |
| 2856 | + | |
| 2857 | + | |
2857 | 2858 |
| |
2858 | 2859 |
| |
2859 | 2860 |
| |
| |||
2879 | 2880 |
| |
2880 | 2881 |
| |
2881 | 2882 |
| |
| 2883 | + | |
| 2884 | + | |
| 2885 | + | |
| 2886 | + | |
2882 | 2887 |
| |
2883 | 2888 |
| |
2884 | 2889 |
| |
| |||
2894 | 2899 |
| |
2895 | 2900 |
| |
2896 | 2901 |
| |
| 2902 | + | |
| 2903 | + | |
2897 | 2904 |
| |
2898 | 2905 |
| |
2899 | 2906 |
| |
| |||
2915 | 2922 |
| |
2916 | 2923 |
| |
2917 | 2924 |
| |
2918 |
| - | |
2919 |
| - | |
2920 |
| - | |
2921 |
| - | |
| 2925 | + | |
| 2926 | + | |
| 2927 | + | |
| 2928 | + | |
| 2929 | + | |
| 2930 | + | |
2922 | 2931 |
| |
2923 | 2932 |
| |
| 2933 | + | |
| 2934 | + | |
2924 | 2935 |
| |
2925 | 2936 |
| |
2926 | 2937 |
| |
| |||
2976 | 2987 |
| |
2977 | 2988 |
| |
2978 | 2989 |
| |
2979 |
| - | |
2980 |
| - | |
2981 | 2990 |
| |
2982 |
| - | |
2983 |
| - | |
| 2991 | + | |
| 2992 | + | |
| 2993 | + | |
2984 | 2994 |
| |
| 2995 | + | |
| 2996 | + | |
2985 | 2997 |
| |
2986 | 2998 |
| |
2987 | 2999 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
761 | 761 |
| |
762 | 762 |
| |
763 | 763 |
| |
764 |
| - | |
| 764 | + | |
765 | 765 |
| |
766 | 766 |
| |
767 | 767 |
| |
|
Lines changed: 5 additions & 3 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
170 | 170 |
| |
171 | 171 |
| |
172 | 172 |
| |
173 |
| - | |
| 173 | + | |
174 | 174 |
| |
175 | 175 |
| |
176 | 176 |
| |
177 | 177 |
| |
178 | 178 |
| |
179 | 179 |
| |
| 180 | + | |
| 181 | + | |
180 | 182 |
| |
181 | 183 |
| |
182 | 184 |
| |
| |||
234 | 236 |
| |
235 | 237 |
| |
236 | 238 |
| |
237 |
| - | |
| 239 | + | |
238 | 240 |
| |
239 |
| - | |
| 241 | + | |
240 | 242 |
| |
241 | 243 |
| |
242 | 244 |
| |
|
0 commit comments
Comments
(0)