| /dports/databases/postgresql13-pltcl/postgresql-13.5/src/backend/replication/ |
| H A D | slot.c | 385 int active_pid; in ReplicationSlotAcquireInternal() local
428 active_pid = s->active_pid; in ReplicationSlotAcquireInternal()
448 return active_pid; in ReplicationSlotAcquireInternal()
514 slot->active_pid = 0; in ReplicationSlotRelease()
664 slot->active_pid = 0; in ReplicationSlotDropPtr()
968 int active_pid; in ReplicationSlotsDropDBSlots() local
988 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
989 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
1003 if (active_pid) in ReplicationSlotsDropDBSlots()
1184 active_pid = s->active_pid; in InvalidatePossiblyObsoleteSlot()
[all …]
|
| /dports/databases/postgresql13-server/postgresql-13.5/src/backend/replication/ |
| H A D | slot.c | 385 int active_pid; in ReplicationSlotAcquireInternal() local
428 active_pid = s->active_pid; in ReplicationSlotAcquireInternal()
448 return active_pid; in ReplicationSlotAcquireInternal()
514 slot->active_pid = 0; in ReplicationSlotRelease()
664 slot->active_pid = 0; in ReplicationSlotDropPtr()
968 int active_pid; in ReplicationSlotsDropDBSlots() local
988 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
989 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
1003 if (active_pid) in ReplicationSlotsDropDBSlots()
1184 active_pid = s->active_pid; in InvalidatePossiblyObsoleteSlot()
[all …]
|
| /dports/databases/postgresql13-client/postgresql-13.5/src/backend/replication/ |
| H A D | slot.c | 385 int active_pid; in ReplicationSlotAcquireInternal() local
428 active_pid = s->active_pid; in ReplicationSlotAcquireInternal()
448 return active_pid; in ReplicationSlotAcquireInternal()
514 slot->active_pid = 0; in ReplicationSlotRelease()
664 slot->active_pid = 0; in ReplicationSlotDropPtr()
968 int active_pid; in ReplicationSlotsDropDBSlots() local
988 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
989 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
1003 if (active_pid) in ReplicationSlotsDropDBSlots()
1184 active_pid = s->active_pid; in InvalidatePossiblyObsoleteSlot()
[all …]
|
| /dports/databases/postgresql13-docs/postgresql-13.5/src/backend/replication/ |
| H A D | slot.c | 385 int active_pid; in binlog_row_logging_function()
428 active_pid = s->active_pid; in binlog_row_logging_function()
448 return active_pid; in binlog_row_logging_function()
514 slot->active_pid = 0;
664 slot->active_pid = 0;
968 int active_pid;
988 active_pid = s->active_pid;
989 if (active_pid == 0)
1003 if (active_pid)
1184 active_pid = s->active_pid;
[all …]
|
| /dports/databases/postgresql13-contrib/postgresql-13.5/src/backend/replication/ |
| H A D | slot.c | 385 int active_pid; in ReplicationSlotAcquireInternal() local
428 active_pid = s->active_pid; in ReplicationSlotAcquireInternal()
448 return active_pid; in ReplicationSlotAcquireInternal()
514 slot->active_pid = 0; in ReplicationSlotRelease()
664 slot->active_pid = 0; in ReplicationSlotDropPtr()
968 int active_pid; in ReplicationSlotsDropDBSlots() local
988 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
989 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
1003 if (active_pid) in ReplicationSlotsDropDBSlots()
1184 active_pid = s->active_pid; in InvalidatePossiblyObsoleteSlot()
[all …]
|
| /dports/databases/postgresql13-plperl/postgresql-13.5/src/backend/replication/ |
| H A D | slot.c | 385 int active_pid; in ReplicationSlotAcquireInternal() local
428 active_pid = s->active_pid; in ReplicationSlotAcquireInternal()
448 return active_pid; in ReplicationSlotAcquireInternal()
514 slot->active_pid = 0; in ReplicationSlotRelease()
664 slot->active_pid = 0; in ReplicationSlotDropPtr()
968 int active_pid; in ReplicationSlotsDropDBSlots() local
988 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
989 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
1003 if (active_pid) in ReplicationSlotsDropDBSlots()
1184 active_pid = s->active_pid; in InvalidatePossiblyObsoleteSlot()
[all …]
|
| /dports/databases/postgresql13-plpython/postgresql-13.5/src/backend/replication/ |
| H A D | slot.c | 385 int active_pid; in ReplicationSlotAcquireInternal() local
428 active_pid = s->active_pid; in ReplicationSlotAcquireInternal()
448 return active_pid; in ReplicationSlotAcquireInternal()
514 slot->active_pid = 0; in ReplicationSlotRelease()
664 slot->active_pid = 0; in ReplicationSlotDropPtr()
968 int active_pid; in ReplicationSlotsDropDBSlots() local
988 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
989 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
1003 if (active_pid) in ReplicationSlotsDropDBSlots()
1184 active_pid = s->active_pid; in InvalidatePossiblyObsoleteSlot()
[all …]
|
| /dports/databases/postgresql14-pltcl/postgresql-14.1/src/backend/replication/ |
| H A D | slot.c | 382 int active_pid; in ReplicationSlotAcquire() local
423 active_pid = s->active_pid; in ReplicationSlotAcquire()
506 slot->active_pid = 0; in ReplicationSlotRelease()
657 slot->active_pid = 0; in ReplicationSlotDropPtr()
980 int active_pid; in ReplicationSlotsDropDBSlots() local
1000 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
1001 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
1015 if (active_pid) in ReplicationSlotsDropDBSlots()
1196 active_pid = s->active_pid; in InvalidatePossiblyObsoleteSlot()
1203 if (active_pid == 0) in InvalidatePossiblyObsoleteSlot()
[all …]
|
| /dports/databases/postgresql14-server/postgresql-14.1/src/backend/replication/ |
| H A D | slot.c | 382 int active_pid; in ReplicationSlotAcquire() local
423 active_pid = s->active_pid; in ReplicationSlotAcquire()
506 slot->active_pid = 0; in ReplicationSlotRelease()
657 slot->active_pid = 0; in ReplicationSlotDropPtr()
980 int active_pid; in ReplicationSlotsDropDBSlots() local
1000 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
1001 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
1015 if (active_pid) in ReplicationSlotsDropDBSlots()
1196 active_pid = s->active_pid; in InvalidatePossiblyObsoleteSlot()
1203 if (active_pid == 0) in InvalidatePossiblyObsoleteSlot()
[all …]
|
| /dports/databases/postgresql14-client/postgresql-14.1/src/backend/replication/ |
| H A D | slot.c | 382 int active_pid; in ReplicationSlotAcquire() local
423 active_pid = s->active_pid; in ReplicationSlotAcquire()
506 slot->active_pid = 0; in ReplicationSlotRelease()
657 slot->active_pid = 0; in ReplicationSlotDropPtr()
980 int active_pid; in ReplicationSlotsDropDBSlots() local
1000 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
1001 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
1015 if (active_pid) in ReplicationSlotsDropDBSlots()
1196 active_pid = s->active_pid; in InvalidatePossiblyObsoleteSlot()
1203 if (active_pid == 0) in InvalidatePossiblyObsoleteSlot()
[all …]
|
| /dports/databases/postgresql14-contrib/postgresql-14.1/src/backend/replication/ |
| H A D | slot.c | 382 int active_pid;
423 active_pid = s->active_pid;
506 slot->active_pid = 0;
657 slot->active_pid = 0;
980 int active_pid;
1000 active_pid = s->active_pid;
1001 if (active_pid == 0)
1015 if (active_pid)
1196 active_pid = s->active_pid;
1203 if (active_pid == 0)
[all …]
|
| /dports/databases/postgresql14-plpython/postgresql-14.1/src/backend/replication/ |
| H A D | slot.c | 382 int active_pid; in ReplicationSlotAcquire() local
423 active_pid = s->active_pid; in ReplicationSlotAcquire()
506 slot->active_pid = 0; in ReplicationSlotRelease()
657 slot->active_pid = 0; in ReplicationSlotDropPtr()
980 int active_pid; in ReplicationSlotsDropDBSlots() local
1000 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
1001 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
1015 if (active_pid) in ReplicationSlotsDropDBSlots()
1196 active_pid = s->active_pid; in InvalidatePossiblyObsoleteSlot()
1203 if (active_pid == 0) in InvalidatePossiblyObsoleteSlot()
[all …]
|
| /dports/databases/postgresql14-plperl/postgresql-14.1/src/backend/replication/ |
| H A D | slot.c | 382 int active_pid; in ReplicationSlotAcquire() local
423 active_pid = s->active_pid; in ReplicationSlotAcquire()
506 slot->active_pid = 0; in ReplicationSlotRelease()
657 slot->active_pid = 0; in ReplicationSlotDropPtr()
980 int active_pid; in ReplicationSlotsDropDBSlots() local
1000 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
1001 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
1015 if (active_pid) in ReplicationSlotsDropDBSlots()
1196 active_pid = s->active_pid; in InvalidatePossiblyObsoleteSlot()
1203 if (active_pid == 0) in InvalidatePossiblyObsoleteSlot()
[all …]
|
| /dports/databases/postgresql14-docs/postgresql-14.1/src/backend/replication/ |
| H A D | slot.c | 382 int active_pid; in ReplicationSlotAcquire() local
423 active_pid = s->active_pid; in ReplicationSlotAcquire()
506 slot->active_pid = 0; in ReplicationSlotRelease()
657 slot->active_pid = 0; in ReplicationSlotDropPtr()
980 int active_pid; in ReplicationSlotsDropDBSlots() local
1000 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
1001 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
1015 if (active_pid) in ReplicationSlotsDropDBSlots()
1196 active_pid = s->active_pid; in InvalidatePossiblyObsoleteSlot()
1203 if (active_pid == 0) in InvalidatePossiblyObsoleteSlot()
[all …]
|
| /dports/databases/postgresql10-plperl/postgresql-10.19/src/backend/replication/ |
| H A D | slot.c | 333 int active_pid; in ReplicationSlotAcquire() local
344 active_pid = 0; in ReplicationSlotAcquire()
368 active_pid = s->active_pid; in ReplicationSlotAcquire()
370 active_pid = s->active_pid = MyProcPid; in ReplicationSlotAcquire()
462 slot->active_pid = 0; in ReplicationSlotRelease()
590 slot->active_pid = 0; in ReplicationSlotDropPtr()
612 slot->active_pid = 0; in ReplicationSlotDropPtr()
910 int active_pid; in ReplicationSlotsDropDBSlots() local
930 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
931 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
[all …]
|
| /dports/databases/postgresql10-pltcl/postgresql-10.19/src/backend/replication/ |
| H A D | slot.c | 333 int active_pid; in ReplicationSlotAcquire() local
344 active_pid = 0; in ReplicationSlotAcquire()
368 active_pid = s->active_pid; in ReplicationSlotAcquire()
370 active_pid = s->active_pid = MyProcPid; in ReplicationSlotAcquire()
462 slot->active_pid = 0; in ReplicationSlotRelease()
590 slot->active_pid = 0; in ReplicationSlotDropPtr()
612 slot->active_pid = 0; in ReplicationSlotDropPtr()
910 int active_pid; in ReplicationSlotsDropDBSlots() local
930 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
931 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
[all …]
|
| /dports/databases/postgresql11-client/postgresql-11.14/src/backend/replication/ |
| H A D | slot.c | 333 int active_pid; in ReplicationSlotAcquire() local
344 active_pid = 0; in ReplicationSlotAcquire()
368 active_pid = s->active_pid; in ReplicationSlotAcquire()
370 active_pid = s->active_pid = MyProcPid; in ReplicationSlotAcquire()
462 slot->active_pid = 0; in ReplicationSlotRelease()
590 slot->active_pid = 0; in ReplicationSlotDropPtr()
612 slot->active_pid = 0; in ReplicationSlotDropPtr()
910 int active_pid; in ReplicationSlotsDropDBSlots() local
930 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
931 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
[all …]
|
| /dports/databases/postgresql10-contrib/postgresql-10.19/src/backend/replication/ |
| H A D | slot.c | 333 int active_pid; in ReplicationSlotAcquire() local
344 active_pid = 0; in ReplicationSlotAcquire()
368 active_pid = s->active_pid; in ReplicationSlotAcquire()
370 active_pid = s->active_pid = MyProcPid; in ReplicationSlotAcquire()
462 slot->active_pid = 0; in ReplicationSlotRelease()
590 slot->active_pid = 0; in ReplicationSlotDropPtr()
612 slot->active_pid = 0; in ReplicationSlotDropPtr()
910 int active_pid; in ReplicationSlotsDropDBSlots() local
930 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
931 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
[all …]
|
| /dports/databases/postgresql10-docs/postgresql-10.19/src/backend/replication/ |
| H A D | slot.c | 333 int active_pid; in ReplicationSlotAcquire() local
344 active_pid = 0; in ReplicationSlotAcquire()
368 active_pid = s->active_pid; in ReplicationSlotAcquire()
370 active_pid = s->active_pid = MyProcPid; in ReplicationSlotAcquire()
462 slot->active_pid = 0; in ReplicationSlotRelease()
590 slot->active_pid = 0; in ReplicationSlotDropPtr()
612 slot->active_pid = 0; in ReplicationSlotDropPtr()
910 int active_pid; in ReplicationSlotsDropDBSlots() local
930 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
931 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
[all …]
|
| /dports/databases/postgresql10-client/postgresql-10.19/src/backend/replication/ |
| H A D | slot.c | 333 int active_pid; in ReplicationSlotAcquire() local
344 active_pid = 0; in ReplicationSlotAcquire()
368 active_pid = s->active_pid; in ReplicationSlotAcquire()
370 active_pid = s->active_pid = MyProcPid; in ReplicationSlotAcquire()
462 slot->active_pid = 0; in ReplicationSlotRelease()
590 slot->active_pid = 0; in ReplicationSlotDropPtr()
612 slot->active_pid = 0; in ReplicationSlotDropPtr()
910 int active_pid; in ReplicationSlotsDropDBSlots() local
930 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
931 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
[all …]
|
| /dports/databases/postgresql10-plpython/postgresql-10.19/src/backend/replication/ |
| H A D | slot.c | 333 int active_pid; in ReplicationSlotAcquire() local
344 active_pid = 0; in ReplicationSlotAcquire()
368 active_pid = s->active_pid; in ReplicationSlotAcquire()
370 active_pid = s->active_pid = MyProcPid; in ReplicationSlotAcquire()
462 slot->active_pid = 0; in ReplicationSlotRelease()
590 slot->active_pid = 0; in ReplicationSlotDropPtr()
612 slot->active_pid = 0; in ReplicationSlotDropPtr()
910 int active_pid; in ReplicationSlotsDropDBSlots() local
930 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
931 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
[all …]
|
| /dports/databases/postgresql11-docs/postgresql-11.14/src/backend/replication/ |
| H A D | slot.c | 333 int active_pid; in ReplicationSlotAcquire() local
344 active_pid = 0; in ReplicationSlotAcquire()
368 active_pid = s->active_pid; in ReplicationSlotAcquire()
370 active_pid = s->active_pid = MyProcPid; in ReplicationSlotAcquire()
462 slot->active_pid = 0; in ReplicationSlotRelease()
590 slot->active_pid = 0; in ReplicationSlotDropPtr()
612 slot->active_pid = 0; in ReplicationSlotDropPtr()
910 int active_pid; in ReplicationSlotsDropDBSlots() local
930 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
931 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
[all …]
|
| /dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/replication/ |
| H A D | slot.c | 333 int active_pid; in ReplicationSlotAcquire() local
344 active_pid = 0; in ReplicationSlotAcquire()
368 active_pid = s->active_pid; in ReplicationSlotAcquire()
370 active_pid = s->active_pid = MyProcPid; in ReplicationSlotAcquire()
462 slot->active_pid = 0; in ReplicationSlotRelease()
590 slot->active_pid = 0; in ReplicationSlotDropPtr()
612 slot->active_pid = 0; in ReplicationSlotDropPtr()
910 int active_pid; in ReplicationSlotsDropDBSlots() local
930 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
931 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
[all …]
|
| /dports/databases/postgresql11-plpython/postgresql-11.14/src/backend/replication/ |
| H A D | slot.c | 333 int active_pid; in ReplicationSlotAcquire() local
344 active_pid = 0; in ReplicationSlotAcquire()
368 active_pid = s->active_pid; in ReplicationSlotAcquire()
370 active_pid = s->active_pid = MyProcPid; in ReplicationSlotAcquire()
462 slot->active_pid = 0; in ReplicationSlotRelease()
590 slot->active_pid = 0; in ReplicationSlotDropPtr()
612 slot->active_pid = 0; in ReplicationSlotDropPtr()
910 int active_pid; in ReplicationSlotsDropDBSlots() local
930 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
931 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
[all …]
|
| /dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/replication/ |
| H A D | slot.c | 333 int active_pid; in ReplicationSlotAcquire() local
344 active_pid = 0; in ReplicationSlotAcquire()
368 active_pid = s->active_pid; in ReplicationSlotAcquire()
370 active_pid = s->active_pid = MyProcPid; in ReplicationSlotAcquire()
462 slot->active_pid = 0; in ReplicationSlotRelease()
590 slot->active_pid = 0; in ReplicationSlotDropPtr()
612 slot->active_pid = 0; in ReplicationSlotDropPtr()
910 int active_pid; in ReplicationSlotsDropDBSlots() local
930 active_pid = s->active_pid; in ReplicationSlotsDropDBSlots()
931 if (active_pid == 0) in ReplicationSlotsDropDBSlots()
[all …]
|