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

Amit Kapila
Fix assertion failure in apply worker.
During exit, the logical replication apply worker tries to release sessionlevel locks, if any. However, if the apply worker exits due to an errorbefore its connection is initialized, trying to release locks can lead toassertion failure. The locks will be acquired once the worker isinitialized, so we don't need to release them till the workerinitialization is complete.Reported-by: Alexander LakhinAuthor: Hou Zhijie based on inputs from Sawada Masahiko and Amit KapilaReviewed-by: Amit KapilaDiscussion:https://postgr.es/m/2185d65f-5aae-3efa-c48f-fb42b173ef5c@gmail.com1 parent6489875 commitde63f8d
File tree
4 files changed
+17
-1
lines changed- src
- backend/replication/logical
- include/replication
4 files changed
+17
-1
lines changedLines changed: 4 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
873 | 873 |
| |
874 | 874 |
| |
875 | 875 |
| |
| 876 | + | |
| 877 | + | |
876 | 878 |
| |
877 | 879 |
| |
878 | 880 |
| |
| |||
940 | 942 |
| |
941 | 943 |
| |
942 | 944 |
| |
| 945 | + | |
| 946 | + | |
943 | 947 |
| |
944 | 948 |
| |
945 | 949 |
| |
|
Lines changed: 4 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
797 | 797 |
| |
798 | 798 |
| |
799 | 799 |
| |
| 800 | + | |
| 801 | + | |
800 | 802 |
| |
801 |
| - | |
| 803 | + | |
| 804 | + | |
802 | 805 |
| |
803 | 806 |
| |
804 | 807 |
| |
|
Lines changed: 7 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
331 | 331 |
| |
332 | 332 |
| |
333 | 333 |
| |
| 334 | + | |
| 335 | + | |
| 336 | + | |
334 | 337 |
| |
335 | 338 |
| |
336 | 339 |
| |
| |||
4526 | 4529 |
| |
4527 | 4530 |
| |
4528 | 4531 |
| |
| 4532 | + | |
| 4533 | + | |
4529 | 4534 |
| |
4530 | 4535 |
| |
4531 | 4536 |
| |
| |||
4548 | 4553 |
| |
4549 | 4554 |
| |
4550 | 4555 |
| |
| 4556 | + | |
| 4557 | + | |
4551 | 4558 |
| |
4552 | 4559 |
| |
4553 | 4560 |
| |
|
Lines changed: 2 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
225 | 225 |
| |
226 | 226 |
| |
227 | 227 |
| |
| 228 | + | |
| 229 | + | |
228 | 230 |
| |
229 | 231 |
| |
230 | 232 |
| |
|
0 commit comments
Comments
(0)