database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixbug: divided by zero

Browse Source
This commit is contained in:
chenxiaobin
2021-04-25 10:15:03 +08:00
parent b0d23d9d84
commit d1028fd621
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/gausskernel/storage/replication/walsender.cpp
View File

@ -5493,7 +5493,8 @@ static void CalCatchupRate() {
SpinLockRelease(&walsnd->mutex);
return;
}
if (TimestampDifferenceExceeds(walsnd->lastCalTime, now, CALCULATE_CATCHUP_RATE_TIME)) {
if (TimestampDifferenceExceeds(walsnd->lastCalTime, now, CALCULATE_CATCHUP_RATE_TIME) &&
XLByteLT(walsnd->lastCalWrite, write)) {
double tempRate = (double)(now - walsnd->lastCalTime) /
(double)XLByteDifference(write, walsnd->lastCalWrite);
walsnd->catchupRate = walsnd->catchupRate == 0 ? tempRate : (walsnd->catchupRate + tempRate) / 2;