|
|
@ -661,7 +661,7 @@ ReplicationSlotsComputeRequiredLSN(void) |
|
|
|
/*
|
|
|
|
/*
|
|
|
|
* Compute the oldest WAL LSN required by *logical* decoding slots.. |
|
|
|
* Compute the oldest WAL LSN required by *logical* decoding slots.. |
|
|
|
* |
|
|
|
* |
|
|
|
* Returns InvalidXLogRecPtr if logical decoding is disabled or no logicals |
|
|
|
* Returns InvalidXLogRecPtr if logical decoding is disabled or no logical |
|
|
|
* slots exist. |
|
|
|
* slots exist. |
|
|
|
* |
|
|
|
* |
|
|
|
* NB: this returns a value >= ReplicationSlotsComputeRequiredLSN(), since it |
|
|
|
* NB: this returns a value >= ReplicationSlotsComputeRequiredLSN(), since it |
|
|
@ -876,7 +876,7 @@ StartupReplicationSlots(void) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/* ----
|
|
|
|
/* ----
|
|
|
|
* Manipulation of ondisk state of replication slots |
|
|
|
* Manipulation of on-disk state of replication slots |
|
|
|
* |
|
|
|
* |
|
|
|
* NB: none of the routines below should take any notice whether a slot is the |
|
|
|
* NB: none of the routines below should take any notice whether a slot is the |
|
|
|
* current one or not, that's all handled a layer above. |
|
|
|
* current one or not, that's all handled a layer above. |
|
|
|