| /dports/databases/postgresql12-client/postgresql-12.9/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot); in create_physical_replication_slot()
61 MyReplicationSlot->data.restart_lsn = restart_lsn; in create_physical_replication_slot()
132 Assert(!MyReplicationSlot); in create_logical_replication_slot()
369 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
370 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
371 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
527 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
566 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
780 SpinLockAcquire(&MyReplicationSlot->mutex); in copy_replication_slot()
784 MyReplicationSlot->data.xmin = copy_xmin; in copy_replication_slot()
[all …]
|
| /dports/databases/postgresql12-contrib/postgresql-12.9/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot);
61 MyReplicationSlot->data.restart_lsn = restart_lsn;
132 Assert(!MyReplicationSlot);
369 SpinLockAcquire(&MyReplicationSlot->mutex);
370 MyReplicationSlot->data.restart_lsn = moveto;
371 SpinLockRelease(&MyReplicationSlot->mutex);
527 Assert(!MyReplicationSlot);
566 minlsn = MyReplicationSlot->data.restart_lsn;
780 SpinLockAcquire(&MyReplicationSlot->mutex);
784 MyReplicationSlot->data.xmin = copy_xmin;
[all …]
|
| /dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot); in create_physical_replication_slot()
61 MyReplicationSlot->data.restart_lsn = restart_lsn; in create_physical_replication_slot()
132 Assert(!MyReplicationSlot); in create_logical_replication_slot()
369 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
370 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
371 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
527 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
566 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
780 SpinLockAcquire(&MyReplicationSlot->mutex); in copy_replication_slot()
784 MyReplicationSlot->data.xmin = copy_xmin; in copy_replication_slot()
[all …]
|
| /dports/databases/postgresql12-pltcl/postgresql-12.9/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot);
61 MyReplicationSlot->data.restart_lsn = restart_lsn;
132 Assert(!MyReplicationSlot);
369 SpinLockAcquire(&MyReplicationSlot->mutex);
370 MyReplicationSlot->data.restart_lsn = moveto;
371 SpinLockRelease(&MyReplicationSlot->mutex);
527 Assert(!MyReplicationSlot);
566 minlsn = MyReplicationSlot->data.restart_lsn;
780 SpinLockAcquire(&MyReplicationSlot->mutex);
784 MyReplicationSlot->data.xmin = copy_xmin;
[all …]
|
| /dports/databases/postgresql12-server/postgresql-12.9/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot);
61 MyReplicationSlot->data.restart_lsn = restart_lsn;
132 Assert(!MyReplicationSlot);
369 SpinLockAcquire(&MyReplicationSlot->mutex);
370 MyReplicationSlot->data.restart_lsn = moveto;
371 SpinLockRelease(&MyReplicationSlot->mutex);
527 Assert(!MyReplicationSlot);
566 minlsn = MyReplicationSlot->data.restart_lsn;
780 SpinLockAcquire(&MyReplicationSlot->mutex);
784 MyReplicationSlot->data.xmin = copy_xmin;
[all …]
|
| /dports/databases/postgresql12-plpython/postgresql-12.9/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot); in create_physical_replication_slot()
61 MyReplicationSlot->data.restart_lsn = restart_lsn; in create_physical_replication_slot()
132 Assert(!MyReplicationSlot); in create_logical_replication_slot()
369 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
370 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
371 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
527 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
566 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
780 SpinLockAcquire(&MyReplicationSlot->mutex); in copy_replication_slot()
784 MyReplicationSlot->data.xmin = copy_xmin; in copy_replication_slot()
[all …]
|
| /dports/databases/postgresql12-docs/postgresql-12.9/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot); in create_physical_replication_slot()
61 MyReplicationSlot->data.restart_lsn = restart_lsn; in create_physical_replication_slot()
132 Assert(!MyReplicationSlot); in create_logical_replication_slot()
369 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
370 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
371 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
527 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
566 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
780 SpinLockAcquire(&MyReplicationSlot->mutex); in copy_replication_slot()
784 MyReplicationSlot->data.xmin = copy_xmin; in copy_replication_slot()
[all …]
|
| /dports/databases/postgresql13-docs/postgresql-13.5/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot); in create_physical_replication_slot()
61 MyReplicationSlot->data.restart_lsn = restart_lsn; in create_physical_replication_slot()
132 Assert(!MyReplicationSlot); in create_logical_replication_slot()
464 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
465 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
466 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
618 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
659 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
870 SpinLockAcquire(&MyReplicationSlot->mutex); in copy_replication_slot()
874 MyReplicationSlot->data.xmin = copy_xmin; in copy_replication_slot()
[all …]
|
| /dports/databases/postgresql13-server/postgresql-13.5/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot); in create_physical_replication_slot()
61 MyReplicationSlot->data.restart_lsn = restart_lsn; in create_physical_replication_slot()
132 Assert(!MyReplicationSlot); in create_logical_replication_slot()
464 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
465 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
466 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
618 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
659 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
870 SpinLockAcquire(&MyReplicationSlot->mutex); in copy_replication_slot()
874 MyReplicationSlot->data.xmin = copy_xmin; in copy_replication_slot()
[all …]
|
| /dports/databases/postgresql13-pltcl/postgresql-13.5/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot); in create_physical_replication_slot()
61 MyReplicationSlot->data.restart_lsn = restart_lsn; in create_physical_replication_slot()
132 Assert(!MyReplicationSlot); in create_logical_replication_slot()
464 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
465 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
466 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
618 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
659 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
870 SpinLockAcquire(&MyReplicationSlot->mutex); in copy_replication_slot()
874 MyReplicationSlot->data.xmin = copy_xmin; in copy_replication_slot()
[all …]
|
| /dports/databases/postgresql13-contrib/postgresql-13.5/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot); in create_physical_replication_slot()
61 MyReplicationSlot->data.restart_lsn = restart_lsn; in create_physical_replication_slot()
132 Assert(!MyReplicationSlot); in create_logical_replication_slot()
464 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
465 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
466 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
618 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
659 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
870 SpinLockAcquire(&MyReplicationSlot->mutex); in copy_replication_slot()
874 MyReplicationSlot->data.xmin = copy_xmin; in copy_replication_slot()
[all …]
|
| /dports/databases/postgresql13-plperl/postgresql-13.5/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot); in create_physical_replication_slot()
61 MyReplicationSlot->data.restart_lsn = restart_lsn; in create_physical_replication_slot()
132 Assert(!MyReplicationSlot); in create_logical_replication_slot()
464 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
465 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
466 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
618 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
659 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
870 SpinLockAcquire(&MyReplicationSlot->mutex); in copy_replication_slot()
874 MyReplicationSlot->data.xmin = copy_xmin; in copy_replication_slot()
[all …]
|
| /dports/databases/postgresql13-plpython/postgresql-13.5/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot);
61 MyReplicationSlot->data.restart_lsn = restart_lsn;
132 Assert(!MyReplicationSlot);
464 SpinLockAcquire(&MyReplicationSlot->mutex);
465 MyReplicationSlot->data.restart_lsn = moveto;
466 SpinLockRelease(&MyReplicationSlot->mutex);
618 Assert(!MyReplicationSlot);
659 minlsn = MyReplicationSlot->data.restart_lsn;
870 SpinLockAcquire(&MyReplicationSlot->mutex);
874 MyReplicationSlot->data.xmin = copy_xmin;
[all …]
|
| /dports/databases/postgresql13-client/postgresql-13.5/src/backend/replication/ |
| H A D | slotfuncs.c | 49 Assert(!MyReplicationSlot); in create_physical_replication_slot()
61 MyReplicationSlot->data.restart_lsn = restart_lsn; in create_physical_replication_slot()
132 Assert(!MyReplicationSlot); in create_logical_replication_slot()
464 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
465 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
466 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
618 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
659 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
870 SpinLockAcquire(&MyReplicationSlot->mutex); in copy_replication_slot()
874 MyReplicationSlot->data.xmin = copy_xmin; in copy_replication_slot()
[all …]
|
| /dports/databases/postgresql11-client/postgresql-11.14/src/backend/replication/ |
| H A D | slotfuncs.c | 54 Assert(!MyReplicationSlot); in pg_create_physical_replication_slot()
114 Assert(!MyReplicationSlot); in pg_create_logical_replication_slot()
320 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
321 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
322 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
373 startlsn = MyReplicationSlot->data.restart_lsn; in pg_logical_replication_slot_advance()
376 retlsn = MyReplicationSlot->data.confirmed_flush; in pg_logical_replication_slot_advance()
478 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
514 if (OidIsValid(MyReplicationSlot->data.database)) in pg_replication_slot_advance()
517 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
[all …]
|
| /dports/databases/postgresql11-docs/postgresql-11.14/src/backend/replication/ |
| H A D | slotfuncs.c | 54 Assert(!MyReplicationSlot); in pg_create_physical_replication_slot()
114 Assert(!MyReplicationSlot); in pg_create_logical_replication_slot()
320 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
321 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
322 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
373 startlsn = MyReplicationSlot->data.restart_lsn; in pg_logical_replication_slot_advance()
376 retlsn = MyReplicationSlot->data.confirmed_flush; in pg_logical_replication_slot_advance()
478 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
514 if (OidIsValid(MyReplicationSlot->data.database)) in pg_replication_slot_advance()
517 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
[all …]
|
| /dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/replication/ |
| H A D | slotfuncs.c | 54 Assert(!MyReplicationSlot); in pg_create_physical_replication_slot()
114 Assert(!MyReplicationSlot); in pg_create_logical_replication_slot()
320 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
321 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
322 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
373 startlsn = MyReplicationSlot->data.restart_lsn; in pg_logical_replication_slot_advance()
376 retlsn = MyReplicationSlot->data.confirmed_flush; in pg_logical_replication_slot_advance()
478 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
514 if (OidIsValid(MyReplicationSlot->data.database)) in pg_replication_slot_advance()
517 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
[all …]
|
| /dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/replication/ |
| H A D | slotfuncs.c | 54 Assert(!MyReplicationSlot); in pg_create_physical_replication_slot()
114 Assert(!MyReplicationSlot); in pg_create_logical_replication_slot()
320 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
321 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
322 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
373 startlsn = MyReplicationSlot->data.restart_lsn; in pg_logical_replication_slot_advance()
376 retlsn = MyReplicationSlot->data.confirmed_flush; in pg_logical_replication_slot_advance()
478 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
514 if (OidIsValid(MyReplicationSlot->data.database)) in pg_replication_slot_advance()
517 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
[all …]
|
| /dports/databases/postgresql11-server/postgresql-11.14/src/backend/replication/ |
| H A D | slotfuncs.c | 54 Assert(!MyReplicationSlot); in pg_create_physical_replication_slot()
114 Assert(!MyReplicationSlot); in pg_create_logical_replication_slot()
320 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
321 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
322 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
373 startlsn = MyReplicationSlot->data.restart_lsn; in pg_logical_replication_slot_advance()
376 retlsn = MyReplicationSlot->data.confirmed_flush; in pg_logical_replication_slot_advance()
478 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
514 if (OidIsValid(MyReplicationSlot->data.database)) in pg_replication_slot_advance()
517 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
[all …]
|
| /dports/databases/postgresql11-pltcl/postgresql-11.14/src/backend/replication/ |
| H A D | slotfuncs.c | 54 Assert(!MyReplicationSlot); in pg_create_physical_replication_slot()
114 Assert(!MyReplicationSlot); in pg_create_logical_replication_slot()
320 SpinLockAcquire(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
321 MyReplicationSlot->data.restart_lsn = moveto; in pg_physical_replication_slot_advance()
322 SpinLockRelease(&MyReplicationSlot->mutex); in pg_physical_replication_slot_advance()
373 startlsn = MyReplicationSlot->data.restart_lsn; in pg_logical_replication_slot_advance()
376 retlsn = MyReplicationSlot->data.confirmed_flush; in pg_logical_replication_slot_advance()
478 Assert(!MyReplicationSlot); in pg_replication_slot_advance()
514 if (OidIsValid(MyReplicationSlot->data.database)) in pg_replication_slot_advance()
517 minlsn = MyReplicationSlot->data.restart_lsn; in pg_replication_slot_advance()
[all …]
|
| /dports/databases/postgresql11-plpython/postgresql-11.14/src/backend/replication/ |
| H A D | slotfuncs.c | 54 Assert(!MyReplicationSlot);
114 Assert(!MyReplicationSlot);
320 SpinLockAcquire(&MyReplicationSlot->mutex);
321 MyReplicationSlot->data.restart_lsn = moveto;
322 SpinLockRelease(&MyReplicationSlot->mutex);
373 startlsn = MyReplicationSlot->data.restart_lsn;
376 retlsn = MyReplicationSlot->data.confirmed_flush;
478 Assert(!MyReplicationSlot);
514 if (OidIsValid(MyReplicationSlot->data.database))
517 minlsn = MyReplicationSlot->data.restart_lsn;
[all …]
|
| /dports/databases/postgresql96-server/postgresql-9.6.24/src/backend/replication/logical/ |
| H A D | logical.c | 133 slot = MyReplicationSlot; in StartupDecodingContext()
231 slot = MyReplicationSlot; in CreateInitDecodingContext()
355 slot = MyReplicationSlot; in CreateDecodingContext()
780 slot = MyReplicationSlot; in LogicalIncreaseXminForSlot()
837 slot = MyReplicationSlot; in LogicalIncreaseRestartDecodingForSlot()
920 SpinLockAcquire(&MyReplicationSlot->mutex); in LogicalConfirmReceivedLocation()
938 MyReplicationSlot->data.catalog_xmin != MyReplicationSlot->candidate_catalog_xmin) in LogicalConfirmReceivedLocation()
940 MyReplicationSlot->data.catalog_xmin = MyReplicationSlot->candidate_catalog_xmin; in LogicalConfirmReceivedLocation()
952 MyReplicationSlot->data.restart_lsn = MyReplicationSlot->candidate_restart_lsn; in LogicalConfirmReceivedLocation()
958 SpinLockRelease(&MyReplicationSlot->mutex); in LogicalConfirmReceivedLocation()
[all …]
|
| /dports/databases/postgresql96-plpython/postgresql-9.6.24/src/backend/replication/logical/ |
| H A D | logical.c | 133 slot = MyReplicationSlot; in StartupDecodingContext()
231 slot = MyReplicationSlot; in CreateInitDecodingContext()
355 slot = MyReplicationSlot; in CreateDecodingContext()
780 slot = MyReplicationSlot; in LogicalIncreaseXminForSlot()
837 slot = MyReplicationSlot; in LogicalIncreaseRestartDecodingForSlot()
920 SpinLockAcquire(&MyReplicationSlot->mutex); in LogicalConfirmReceivedLocation()
938 MyReplicationSlot->data.catalog_xmin != MyReplicationSlot->candidate_catalog_xmin) in LogicalConfirmReceivedLocation()
940 MyReplicationSlot->data.catalog_xmin = MyReplicationSlot->candidate_catalog_xmin; in LogicalConfirmReceivedLocation()
952 MyReplicationSlot->data.restart_lsn = MyReplicationSlot->candidate_restart_lsn; in LogicalConfirmReceivedLocation()
958 SpinLockRelease(&MyReplicationSlot->mutex); in LogicalConfirmReceivedLocation()
[all …]
|
| /dports/databases/postgresql96-pltcl/postgresql-9.6.24/src/backend/replication/logical/ |
| H A D | logical.c | 133 slot = MyReplicationSlot; in StartupDecodingContext()
231 slot = MyReplicationSlot; in CreateInitDecodingContext()
355 slot = MyReplicationSlot; in CreateDecodingContext()
780 slot = MyReplicationSlot; in LogicalIncreaseXminForSlot()
837 slot = MyReplicationSlot; in LogicalIncreaseRestartDecodingForSlot()
920 SpinLockAcquire(&MyReplicationSlot->mutex); in LogicalConfirmReceivedLocation()
938 MyReplicationSlot->data.catalog_xmin != MyReplicationSlot->candidate_catalog_xmin) in LogicalConfirmReceivedLocation()
940 MyReplicationSlot->data.catalog_xmin = MyReplicationSlot->candidate_catalog_xmin; in LogicalConfirmReceivedLocation()
952 MyReplicationSlot->data.restart_lsn = MyReplicationSlot->candidate_restart_lsn; in LogicalConfirmReceivedLocation()
958 SpinLockRelease(&MyReplicationSlot->mutex); in LogicalConfirmReceivedLocation()
[all …]
|
| /dports/databases/postgresql10-plperl/postgresql-10.19/src/backend/replication/logical/ |
| H A D | logical.c | 134 slot = MyReplicationSlot; in StartupDecodingContext()
235 slot = MyReplicationSlot; in CreateInitDecodingContext()
360 slot = MyReplicationSlot; in CreateDecodingContext()
798 slot = MyReplicationSlot; in LogicalIncreaseXminForSlot()
855 slot = MyReplicationSlot; in LogicalIncreaseRestartDecodingForSlot()
938 SpinLockAcquire(&MyReplicationSlot->mutex); in LogicalConfirmReceivedLocation()
956 MyReplicationSlot->data.catalog_xmin != MyReplicationSlot->candidate_catalog_xmin) in LogicalConfirmReceivedLocation()
958 MyReplicationSlot->data.catalog_xmin = MyReplicationSlot->candidate_catalog_xmin; in LogicalConfirmReceivedLocation()
970 MyReplicationSlot->data.restart_lsn = MyReplicationSlot->candidate_restart_lsn; in LogicalConfirmReceivedLocation()
976 SpinLockRelease(&MyReplicationSlot->mutex); in LogicalConfirmReceivedLocation()
[all …]
|