Commit64efec7

committed

Add history reset

1 parent46af7da commit64efec7Copy full SHA for 64efec7

File tree

+43

-0

lines changed

+43

-0

lines changed

Lines changed: 6 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -961,6 +961,12 @@ pgws_collector_main(Datum main_arg)`
`961`	`961`	`}`
`962`	`962`	`shm_mq_detach(mqh);`
`963`	`963`	`}`
	`964`	`+elseif (request==HISTORY_RESET)`
	`965`	`+{`
	`966`	`+/* Reset history */`
	`967`	`+pfree(observations.items);`
	`968`	`+alloc_history(&observations,pgws_historySize);`
	`969`	`+}`
`964`	`970`	`elseif (request==PROFILE_RESET)`
`965`	`971`	`{`
`966`	`972`	`/* Reset profile hash */`

Lines changed: 8 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -102,6 +102,14 @@ CREATE VIEW pg_wait_sampling_profile_extended AS`
`102`	`102`
`103`	`103`	`GRANTSELECTON pg_wait_sampling_profile_extended TO PUBLIC;`
`104`	`104`
	`105`	`+CREATEFUNCTIONpg_wait_sampling_reset_history()`
	`106`	`+RETURNS void`
	`107`	`+AS'MODULE_PATHNAME'`
	`108`	`+LANGUAGE C VOLATILE STRICT;`
	`109`	`+`
	`110`	`+-- Don't want this to be available to non-superusers.`
	`111`	`+REVOKE ALLON FUNCTION pg_wait_sampling_reset_history()FROM PUBLIC;`
	`112`	`+`
`105`	`113`	`--CREATE VIEW pg_wait_sampling_profile AS`
`106`	`114`	`--SELECT pid, event_type, event, queryid, SUM(count) FROM pg_wait_sampling_profile_extended`
`107`	`115`	`--GROUP BY pid, event_type, event, queryid;`

Lines changed: 28 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1439,6 +1439,34 @@ pg_wait_sampling_reset_profile(PG_FUNCTION_ARGS)`
`1439`	`1439`	`PG_RETURN_VOID();`
`1440`	`1440`	`}`
`1441`	`1441`
	`1442`	`+PG_FUNCTION_INFO_V1(pg_wait_sampling_reset_history);`
	`1443`	`+Datum`
	`1444`	`+pg_wait_sampling_reset_history(PG_FUNCTION_ARGS)`
	`1445`	`+{`
	`1446`	`+LOCKTAGcollectorTag;`
	`1447`	`+`
	`1448`	`+check_shmem();`
	`1449`	`+`
	`1450`	`+pgws_init_lock_tag(&queueTag,PGWS_QUEUE_LOCK);`
	`1451`	`+`
	`1452`	`+LockAcquire(&queueTag,ExclusiveLock, false, false);`
	`1453`	`+`
	`1454`	`+pgws_init_lock_tag(&collectorTag,PGWS_COLLECTOR_LOCK);`
	`1455`	`+LockAcquire(&collectorTag,ExclusiveLock, false, false);`
	`1456`	`+pgws_collector_hdr->request=HISTORY_RESET;`
	`1457`	`+LockRelease(&collectorTag,ExclusiveLock, false);`
	`1458`	`+`
	`1459`	`+if (!pgws_collector_hdr->latch)`
	`1460`	`+ereport(ERROR, (errcode(ERRCODE_INTERNAL_ERROR),`
	`1461`	`+errmsg("pg_wait_sampling collector wasn't started")));`
	`1462`	`+`
	`1463`	`+SetLatch(pgws_collector_hdr->latch);`
	`1464`	`+`
	`1465`	`+LockRelease(&queueTag,ExclusiveLock, false);`
	`1466`	`+`
	`1467`	`+PG_RETURN_VOID();`
	`1468`	`+}`
	`1469`	`+`
`1442`	`1470`	`//TODO OBSOLETE`
`1443`	`1471`	`PG_FUNCTION_INFO_V1(pg_wait_sampling_get_history);`
`1444`	`1472`	`Datum`

Lines changed: 1 addition & 0 deletions

Comments

(0)