Elgato_dark/hypopg
1
0
Fork 0
mirror of https://github.com/HypoPG/hypopg synced 2026-05-24 09:38:21 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Create and use a dedicated MemoryContext

Browse source
This commit is contained in:
Julien Rouhaud 2018-03-02 21:02:00 +01:00
parent be905d13ca
commit d8d723a262
1 changed files with 19 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
hypopg.c
View file

@ -88,6 +88,8 @@ static Oid BLOOM_AM_OID = InvalidOid;
/* GUC for enabling / disabling hypopg during EXPLAIN */
static bool hypo_is_enabled;
static MemoryContext HypoMemoryContext = NULL;
/*--------------------------------------------------------
* Hypothetical index storage, pretty much an IndexOptInfo
* Some dynamic informations such as pages and lines are not stored but
@ -260,6 +262,17 @@ _PG_init(void)
prev_explain_get_index_name_hook = explain_get_index_name_hook;
explain_get_index_name_hook = hypo_explain_get_index_name_hook;
HypoMemoryContext = AllocSetContextCreate(TopMemoryContext,
"HypoPG context",
#if PG_VERSION_NUM >= 90600
ALLOCSET_DEFAULT_SIZES
#else
ALLOCSET_DEFAULT_MINSIZE,
ALLOCSET_DEFAULT_INITSIZE,
ALLOCSET_DEFAULT_MAXSIZE
#endif
);
DefineCustomBoolVariable("hypopg.enabled",
"Enable / Disable hypopg",
NULL,
@ -317,7 +330,7 @@ hypo_newEntry(Oid relid, char *accessMethod, int nkeycolumns, int ninccolumns,
hypo_discover_am(accessMethod, HeapTupleGetOid(tuple));
oldcontext = MemoryContextSwitchTo(TopMemoryContext);
oldcontext = MemoryContextSwitchTo(HypoMemoryContext);
entry = palloc0(sizeof(hypoEntry));
@ -436,7 +449,7 @@ hypo_newEntry(Oid relid, char *accessMethod, int nkeycolumns, int ninccolumns,
}
PG_CATCH();
{
/* Free what was palloc'd in TopMemoryContext */
/* Free what was palloc'd in HypoMemoryContext */
hypo_entry_pfree(entry);
PG_RE_THROW();
@ -487,7 +500,7 @@ hypo_addEntry(hypoEntry *entry)
{
MemoryContext oldcontext;
oldcontext = MemoryContextSwitchTo(TopMemoryContext);
oldcontext = MemoryContextSwitchTo(HypoMemoryContext);
entries = lappend(entries, entry);
@ -605,7 +618,7 @@ hypo_entry_store_parsetree(IndexStmt *node, const char *queryString)
CheckPredicate((Expr *) node->whereClause);
pred = make_ands_implicit((Expr *) node->whereClause);
oldcontext = MemoryContextSwitchTo(TopMemoryContext);
oldcontext = MemoryContextSwitchTo(HypoMemoryContext);
entry->indpred = (List *) copyObject(pred);
MemoryContextSwitchTo(oldcontext);
@ -720,7 +733,7 @@ hypo_entry_store_parsetree(IndexStmt *node, const char *queryString)
entry->indexkeys[attn] = 0; /* marks expression */
oldcontext = MemoryContextSwitchTo(TopMemoryContext);
oldcontext = MemoryContextSwitchTo(HypoMemoryContext);
entry->indexprs = lappend(entry->indexprs,
(Node *) copyObject(attribute->expr));
MemoryContextSwitchTo(oldcontext);
@ -953,7 +966,7 @@ hypo_entry_store_parsetree(IndexStmt *node, const char *queryString)
}
PG_CATCH();
{
/* Free what was palloc'd in TopMemoryContext */
/* Free what was palloc'd in HypoMemoryContext */
hypo_entry_pfree(entry);
PG_RE_THROW();