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

修复开启备机归档时内存泄漏的bug

Browse Source
This commit is contained in:
luozihao
2021-06-22 20:55:01 +08:00
parent 395151567c
commit 257a313be8
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/gausskernel/storage/replication/walreceiver.cpp
View File

@ -3031,6 +3031,8 @@ static void InitArchiveStartPoint()
pfree(xlog_array); pfree(xlog_array);
xlog_array = NULL; xlog_array = NULL;
} }
FreeDir(xldir);
xldir = NULL;
} }
static bool CheckXlogNameValid(char* xlog) static bool CheckXlogNameValid(char* xlog)

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

@ -3203,7 +3203,9 @@ static int WalSndLoop(WalSndSendDataCallback send_data)
XLogRecPtr replayPtr; XLogRecPtr replayPtr;
bool amSync = false; bool amSync = false;
bool got_recptr = false; bool got_recptr = false;
int standby_nums = list_length(SyncRepGetSyncStandbys(&amSync)); List* sync_standbys = SyncRepGetSyncStandbys(&amSync);
int standby_nums = list_length(sync_standbys);
list_free(sync_standbys);
got_recptr = SyncRepGetSyncRecPtr(&receivePtr, &writePtr, &flushPtr, &replayPtr, &amSync, false); got_recptr = SyncRepGetSyncRecPtr(&receivePtr, &writePtr, &flushPtr, &replayPtr, &amSync, false);
if (got_recptr) { if (got_recptr) {
ArchiveXlogOnStandby(flushPtr); ArchiveXlogOnStandby(flushPtr);