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

Amit Kapila
Add a common function to generate the origin name.
Make a common replication origin name formatting function to replacemultiple snprintf() expressions. This also includes logic previously doneby ReplicationOriginNameForTablesync().This makes the code to generate the origin name consistent among applyworker and tablesync worker.Author: Peter SmithReviewed-By: Aleksander AlekseevDiscussion:https://postgr.es/m/CAHut%2BPsa8hhfSE6ozUK-ih7GkQziAVAf4f3bqiXEj2nQiu-43g%40mail.gmail.com1 parent8432a81 commit776e1c8
File tree
4 files changed
+52
-38
lines changed- src
- backend
- commands
- replication/logical
- include/replication
4 files changed
+52
-38
lines changedLines changed: 8 additions & 7 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
657 | 657 |
| |
658 | 658 |
| |
659 | 659 |
| |
660 |
| - | |
| 660 | + | |
661 | 661 |
| |
662 | 662 |
| |
663 | 663 |
| |
| |||
946 | 946 |
| |
947 | 947 |
| |
948 | 948 |
| |
949 |
| - | |
950 |
| - | |
| 949 | + | |
| 950 | + | |
951 | 951 |
| |
952 | 952 |
| |
953 | 953 |
| |
| |||
1315 | 1315 |
| |
1316 | 1316 |
| |
1317 | 1317 |
| |
1318 |
| - | |
| 1318 | + | |
| 1319 | + | |
1319 | 1320 |
| |
1320 | 1321 |
| |
1321 | 1322 |
| |
| |||
1521 | 1522 |
| |
1522 | 1523 |
| |
1523 | 1524 |
| |
1524 |
| - | |
1525 |
| - | |
| 1525 | + | |
| 1526 | + | |
1526 | 1527 |
| |
1527 | 1528 |
| |
1528 | 1529 |
| |
| |||
1533 | 1534 |
| |
1534 | 1535 |
| |
1535 | 1536 |
| |
1536 |
| - | |
| 1537 | + | |
1537 | 1538 |
| |
1538 | 1539 |
| |
1539 | 1540 |
| |
|
Lines changed: 12 additions & 24 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
353 | 353 |
| |
354 | 354 |
| |
355 | 355 |
| |
356 |
| - | |
357 |
| - | |
358 |
| - | |
359 |
| - | |
| 356 | + | |
| 357 | + | |
| 358 | + | |
| 359 | + | |
360 | 360 |
| |
361 | 361 |
| |
362 | 362 |
| |
| |||
505 | 505 |
| |
506 | 506 |
| |
507 | 507 |
| |
508 |
| - | |
509 |
| - | |
510 |
| - | |
511 |
| - | |
| 508 | + | |
| 509 | + | |
| 510 | + | |
| 511 | + | |
512 | 512 |
| |
513 | 513 |
| |
514 | 514 |
| |
| |||
1193 | 1193 |
| |
1194 | 1194 |
| |
1195 | 1195 |
| |
1196 |
| - | |
1197 |
| - | |
1198 |
| - | |
1199 |
| - | |
1200 |
| - | |
1201 |
| - | |
1202 |
| - | |
1203 |
| - | |
1204 |
| - | |
1205 |
| - | |
1206 |
| - | |
1207 |
| - | |
1208 | 1196 |
| |
1209 | 1197 |
| |
1210 | 1198 |
| |
| |||
1274 | 1262 |
| |
1275 | 1263 |
| |
1276 | 1264 |
| |
1277 |
| - | |
1278 |
| - | |
1279 |
| - | |
1280 |
| - | |
| 1265 | + | |
| 1266 | + | |
| 1267 | + | |
| 1268 | + | |
1281 | 1269 |
| |
1282 | 1270 |
| |
1283 | 1271 |
| |
|
Lines changed: 30 additions & 5 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
364 | 364 |
| |
365 | 365 |
| |
366 | 366 |
| |
| 367 | + | |
| 368 | + | |
| 369 | + | |
| 370 | + | |
| 371 | + | |
| 372 | + | |
| 373 | + | |
| 374 | + | |
| 375 | + | |
| 376 | + | |
| 377 | + | |
| 378 | + | |
| 379 | + | |
| 380 | + | |
| 381 | + | |
| 382 | + | |
| 383 | + | |
| 384 | + | |
| 385 | + | |
| 386 | + | |
| 387 | + | |
| 388 | + | |
| 389 | + | |
| 390 | + | |
367 | 391 |
| |
368 | 392 |
| |
369 | 393 |
| |
| |||
3679 | 3703 |
| |
3680 | 3704 |
| |
3681 | 3705 |
| |
3682 |
| - | |
3683 |
| - | |
3684 |
| - | |
3685 |
| - | |
| 3706 | + | |
| 3707 | + | |
| 3708 | + | |
| 3709 | + | |
3686 | 3710 |
| |
3687 | 3711 |
| |
3688 | 3712 |
| |
| |||
3707 | 3731 |
| |
3708 | 3732 |
| |
3709 | 3733 |
| |
3710 |
| - | |
| 3734 | + | |
| 3735 | + | |
3711 | 3736 |
| |
3712 | 3737 |
| |
3713 | 3738 |
| |
|
Lines changed: 2 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
92 | 92 |
| |
93 | 93 |
| |
94 | 94 |
| |
95 |
| - | |
96 |
| - | |
| 95 | + | |
| 96 | + | |
97 | 97 |
| |
98 | 98 |
| |
99 | 99 |
| |
|
0 commit comments
Comments
(0)