From fe4b3d7278df61193a8aaa7ae32f5f3c08bb658f Mon Sep 17 00:00:00 2001 From: luqichao Date: Thu, 27 Jun 2024 20:59:44 +0800 Subject: [PATCH] fix core --- src/gausskernel/storage/gs_uwal/gs_uwal.cpp | 2 +- src/gausskernel/storage/replication/walrcvwriter.cpp | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/gausskernel/storage/gs_uwal/gs_uwal.cpp b/src/gausskernel/storage/gs_uwal/gs_uwal.cpp index b0e330302..6937708a1 100644 --- a/src/gausskernel/storage/gs_uwal/gs_uwal.cpp +++ b/src/gausskernel/storage/gs_uwal/gs_uwal.cpp @@ -1105,7 +1105,7 @@ int GsUwalWriteSync(int nBytes, char *buf, UwalNodeInfo *infos, bool specified, params.cb = NULL; if (!specified) { - ock_uwal_append(¶ms, &offset, infos); + return ock_uwal_append(¶ms, &offset, infos); } return ock_uwal_append_with_offset(¶ms, targetOffset, &offset, infos); } diff --git a/src/gausskernel/storage/replication/walrcvwriter.cpp b/src/gausskernel/storage/replication/walrcvwriter.cpp index 5bad3a1e9..8d8a63742 100755 --- a/src/gausskernel/storage/replication/walrcvwriter.cpp +++ b/src/gausskernel/storage/replication/walrcvwriter.cpp @@ -1209,7 +1209,7 @@ static void uwalRcvStateFree() volatile WalRcvData *walrcv = t_thrd.walreceiverfuncs_cxt.WalRcv; SpinLockAcquire(&walrcv->uwalMutex); if (walrcv->uwalRcvState != NULL) { - pfree(walrcv->uwalRcvState = NULL); + pfree(walrcv->uwalRcvState); walrcv->uwalRcvState = NULL; } SpinLockRelease(&walrcv->uwalMutex);