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

Format source using pgindent

pull/481/head
Diego Fronza 2024-08-15 17:14:57 -03:00
parent f4b1f35877
commit ea76553232
1 changed files with 40 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
pg_stat_monitor.c
View File

@ -241,7 +241,8 @@ static void pgsm_update_entry(pgsmEntry *entry,
static void pgsm_store_ex(pgsmEntry *entry, ParamListInfo params); static void pgsm_store_ex(pgsmEntry *entry, ParamListInfo params);
/* Stores query entry in normalized form */ /* Stores query entry in normalized form */
static inline void pgsm_store(pgsmEntry * entry) static inline void
pgsm_store(pgsmEntry *entry)
{ {
pgsm_store_ex(entry, NULL); pgsm_store_ex(entry, NULL);
} }
@ -1889,7 +1890,8 @@ pgsm_create_hash_entry(uint64 bucket_id, uint64 queryid, PlanInfo *plan_info)
* inserted or if the time to execute the query exceeds the average * inserted or if the time to execute the query exceeds the average
* time computed for the same query. * time computed for the same query.
*/ */
void pgsm_store_ex(pgsmEntry *entry, ParamListInfo params) void
pgsm_store_ex(pgsmEntry *entry, ParamListInfo params)
{ {
pgsmEntry *shared_hash_entry; pgsmEntry *shared_hash_entry;
pgsmSharedState *pgsm; pgsmSharedState *pgsm;
@ -1994,7 +1996,8 @@ void pgsm_store_ex(pgsmEntry *entry, ParamListInfo params)
char *query_buff; char *query_buff;
/* Denormalize the query if normalization is off */ /* Denormalize the query if normalization is off */
if (!pgsm_normalized_query && params != NULL) { if (!pgsm_normalized_query && params != NULL)
{
query_info = get_denormalized_query(params, query); query_info = get_denormalized_query(params, query);
query = query_info.data; query = query_info.data;
query_len = query_info.len; query_len = query_info.len;
@ -2088,15 +2091,19 @@ void pgsm_store_ex(pgsmEntry *entry, ParamListInfo params)
snprintf(shared_hash_entry->datname, sizeof(shared_hash_entry->datname), "%s", entry->datname); snprintf(shared_hash_entry->datname, sizeof(shared_hash_entry->datname), "%s", entry->datname);
snprintf(shared_hash_entry->username, sizeof(shared_hash_entry->username), "%s", entry->username); snprintf(shared_hash_entry->username, sizeof(shared_hash_entry->username), "%s", entry->username);
} }
/* Entry already exists, if query normalization is disabled and
* the query execution time exceeds the mean time for this query, /*
* then we denormalize the query so users can inspect which arguments * Entry already exists, if query normalization is disabled and the query
* caused the query to take more time to execute */ * execution time exceeds the mean time for this query, then we
* denormalize the query so users can inspect which arguments caused the
* query to take more time to execute
*/
else if ( else if (
!pgsm_normalized_query && !pgsm_normalized_query &&
params != NULL && params != NULL &&
entry->counters.time.total_time > shared_hash_entry->counters.time.mean_time entry->counters.time.total_time > shared_hash_entry->counters.time.mean_time
){ )
{
dsa_pointer dsa_query_pointer; dsa_pointer dsa_query_pointer;
dsa_area *query_dsa_area; dsa_area *query_dsa_area;
char *query_buff; char *query_buff;
@ -2114,7 +2121,10 @@ void pgsm_store_ex(pgsmEntry *entry, ParamListInfo params)
dsa_query_pointer = dsa_allocate_extended(query_dsa_area, query_len + 1, DSA_ALLOC_NO_OOM | DSA_ALLOC_ZERO); dsa_query_pointer = dsa_allocate_extended(query_dsa_area, query_len + 1, DSA_ALLOC_NO_OOM | DSA_ALLOC_ZERO);
if (DsaPointerIsValid(dsa_query_pointer)) if (DsaPointerIsValid(dsa_query_pointer))
{ {
/* Get the memory address from DSA pointer and copy the query text to it. */ /*
* Get the memory address from DSA pointer and copy the query text
* to it.
*/
query_buff = dsa_get_address(query_dsa_area, dsa_query_pointer); query_buff = dsa_get_address(query_dsa_area, dsa_query_pointer);
memcpy(query_buff, query, query_len); memcpy(query_buff, query, query_len);
@ -4125,35 +4135,35 @@ get_denormalized_query(const ParamListInfo paramlist, const char *query_text)
do do
{ {
// advance cursor until detecting a placeholder '$' start. /* advance cursor until detecting a placeholder '$' start. */
while (*cursor_ori && *cursor_ori != '$') while (*cursor_ori && *cursor_ori != '$')
++cursor_ori; ++cursor_ori;
// calculate length of query text before placeholder. /* calculate length of query text before placeholder. */
len = cursor_ori - cursor_curr; len = cursor_ori - cursor_curr;
// check if end of string is reached /* check if end of string is reached */
if (!*cursor_ori) if (!*cursor_ori)
{ {
// there may have remaining query data to append /* there may have remaining query data to append */
if (len > 0) if (len > 0)
appendBinaryStringInfo(&result_buf, cursor_curr, len); appendBinaryStringInfo(&result_buf, cursor_curr, len);
break; break;
} }
// append query text before the '$' sign found. /* append query text before the '$' sign found. */
if (len > 0) if (len > 0)
appendBinaryStringInfo(&result_buf, cursor_curr, len); appendBinaryStringInfo(&result_buf, cursor_curr, len);
// skip '$' /* skip '$' */
++cursor_ori; ++cursor_ori;
/* skip the placeholder */ /* skip the placeholder */
while (*cursor_ori && *cursor_ori >= '0' && *cursor_ori <= '9') while (*cursor_ori && *cursor_ori >= '0' && *cursor_ori <= '9')
cursor_ori++; cursor_ori++;
// advance current cursor /* advance current cursor */
cursor_curr = cursor_ori; cursor_curr = cursor_ori;
/* replace the placeholder with actual value */ /* replace the placeholder with actual value */