fix core
This commit is contained in:
@ -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);
|
||||
}
|
||||
|
||||
@ -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);
|
||||
|
||||
Reference in New Issue
Block a user