external
/
pg_stat_monitor
mirror of https://github.com/percona/pg_stat_monitor.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

PG-180: Relations column is not showing all the relations in case of PostgreSQL Version 11.

pull/75/head
Ibrar Ahmed 2021-02-16 12:35:33 +00:00
parent a27a3798aa
commit 963e509c65
1 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
pg_stat_monitor.c
View File

@ -63,8 +63,6 @@ void _PG_fini(void);
/* Current nesting depth of ExecutorRun+ProcessUtility calls */ /* Current nesting depth of ExecutorRun+ProcessUtility calls */
static int nested_level = 0; static int nested_level = 0;
/* the current max level a query can nested */
int cur_max_nested_level;
/* The array to store outer layer query id*/ /* The array to store outer layer query id*/
uint64 *nested_queryids; uint64 *nested_queryids;
@ -245,8 +243,7 @@ _PG_init(void)
prev_ExecutorCheckPerms_hook = ExecutorCheckPerms_hook; prev_ExecutorCheckPerms_hook = ExecutorCheckPerms_hook;
ExecutorCheckPerms_hook = pgss_ExecutorCheckPerms; ExecutorCheckPerms_hook = pgss_ExecutorCheckPerms;
cur_max_nested_level = max_stack_depth; nested_queryids = (uint64*) malloc(sizeof(uint64) * max_stack_depth);
nested_queryids = (uint64*)palloc0(sizeof(uint64)*cur_max_nested_level);
system_init = true; system_init = true;
} }
@ -401,11 +398,6 @@ pgss_ExecutorRun(QueryDesc *queryDesc, ScanDirection direction, uint64 count,
bool execute_once) bool execute_once)
{ {
nested_queryids[nested_level] = queryDesc->plannedstmt->queryId; nested_queryids[nested_level] = queryDesc->plannedstmt->queryId;
if(nested_level + 1 >= cur_max_nested_level)
{
cur_max_nested_level *= 2;
nested_queryids = repalloc(nested_queryids, cur_max_nested_level);
}
nested_level++; nested_level++;
PG_TRY(); PG_TRY();
{ {
@ -2773,6 +2765,7 @@ get_histogram_timings(PG_FUNCTION_ARGS)
double b_min; double b_min;
double bucket_size; double bucket_size;
bool first = true; bool first = true;
char *tmp_str = palloc0(MAX_STRING_LEN);
char *text_str = palloc0(MAX_STRING_LEN); char *text_str = palloc0(MAX_STRING_LEN);
b_max = log(q_max - q_min); b_max = log(q_max - q_min);
@ -2789,9 +2782,11 @@ get_histogram_timings(PG_FUNCTION_ARGS)
} }
else else
{ {
sprintf(text_str, "%s, (%ld - %ld)}", text_str, b_start, b_end); sprintf(tmp_str, "%s, (%ld - %ld)}", text_str, b_start, b_end);
sprintf(text_str, "%s", tmp_str);
} }
} }
pfree(tmp_str);
return CStringGetTextDatum(text_str); return CStringGetTextDatum(text_str);
} }