zpc_gitlink
/
openGauss-server
forked from huawei/openGauss-server
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

完善备机归档复制槽刷盘步骤

This commit is contained in:
luozihao 2021-11-03 17:42:10 +08:00
parent a10f3f8702
commit e54711814b
1 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/gausskernel/storage/replication/slot.cpp
View File

@ -1918,6 +1918,18 @@ ReplicationSlot *getObsReplicationSlot()
return NULL;
}
static inline void flushSlot(long current)
{
ReplicationSlotMarkDirty();
ReplicationSlotsComputeRequiredXmin(false);
ReplicationSlotsComputeRequiredLSN(NULL);
ReplicationSlotSave();
if (!RecoveryInProgress()) {
log_slot_advance(&t_thrd.slot_cxt.MyReplicationSlot->data);
t_thrd.arch.last_advance_slot_time = current;
}
}
void advanceObsSlot(XLogRecPtr restart_pos)
{
volatile int *slot_idx = &g_instance.archive_obs_cxt.obs_slot_idx;
@ -1929,10 +1941,11 @@ void advanceObsSlot(XLogRecPtr restart_pos)
SpinLockRelease(&slot->mutex);
struct timeval tv;
gettimeofday(&tv, NULL);
long diff = TIME_GET_MILLISEC(tv) - t_thrd.arch.last_advance_slot_time;
if (!RecoveryInProgress() && diff > t_thrd.arch.advance_slot_wait_interval) {
log_slot_advance(&slot->data);
t_thrd.arch.last_advance_slot_time = TIME_GET_MILLISEC(tv);
long current = TIME_GET_MILLISEC(tv);
long diff = current - t_thrd.arch.last_advance_slot_time;
if (diff > t_thrd.arch.advance_slot_wait_interval) {
t_thrd.slot_cxt.MyReplicationSlot = slot;
flushSlot(current);
}
} else {
ereport(WARNING,