db/pgbackrest
1
0
Fork 0
mirror of https://github.com/pgbackrest/pgbackrest.git synced 2025-02-21 19:48:29 +02:00
Code Issues Releases Activity

Fix leaks in db module.

Browse Source
This commit is contained in:
David Steele 2023-01-12 14:22:09 +07:00
parent 7f7d515441
commit 9d42435ffb
1 changed files with 22 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/db/db.c
View File

@ -128,9 +128,11 @@ dbQuery(Db *this, const PgClientQueryResult resultType, const String *const quer
pckWriteStrIdP(param, resultType);
pckWriteStrP(param, query);
PackRead *const read = protocolClientExecute(this->remoteClient, command, true);
MEM_CONTEXT_PRIOR_BEGIN()
{
result = pckReadPackP(protocolClientExecute(this->remoteClient, command, true));
result = pckReadPackP(read);
}
MEM_CONTEXT_PRIOR_END();
}
@ -176,7 +178,11 @@ dbQueryColumn(Db *const this, const String *const query)
ASSERT(this != NULL);
ASSERT(query != NULL);
FUNCTION_LOG_RETURN(PACK_READ, pckReadNew(dbQuery(this, pgClientQueryResultColumn, query)));
Pack *const pack = dbQuery(this, pgClientQueryResultColumn, query);
PackRead *const result = pckReadNew(pack);
pckMove(pack, objMemContext(result));
FUNCTION_LOG_RETURN(PACK_READ, result);
}
/***********************************************************************************************************************************
@ -193,7 +199,11 @@ dbQueryRow(Db *const this, const String *const query)
ASSERT(this != NULL);
ASSERT(query != NULL);
FUNCTION_LOG_RETURN(PACK_READ, pckReadNew(dbQuery(this, pgClientQueryResultRow, query)));
Pack *const pack = dbQuery(this, pgClientQueryResultRow, query);
PackRead *const result = pckReadNew(pack);
pckMove(pack, objMemContext(result));
FUNCTION_LOG_RETURN(PACK_READ, result);
}
/***********************************************************************************************************************************
@ -208,7 +218,15 @@ dbIsInRecovery(Db *const this)
ASSERT(this != NULL);
FUNCTION_LOG_RETURN(BOOL, pckReadBoolP(dbQueryColumn(this, STRDEF("select pg_catalog.pg_is_in_recovery()"))));
bool result;
MEM_CONTEXT_TEMP_BEGIN()
{
result = pckReadBoolP(dbQueryColumn(this, STRDEF("select pg_catalog.pg_is_in_recovery()")));
}
MEM_CONTEXT_TEMP_END();
FUNCTION_LOG_RETURN(BOOL, result);
}
/**********************************************************************************************************************************/