Commit8427f4a

authored

Merge pull request#100 from valeriy-zainullin/master

Check that collector has started in pg_wait_sampling_reset_profile.

2 parentsfafeda0 +930a67a commit8427f4aCopy full SHA for 8427f4a

File tree

+12

-0

lines changed

+12

-0

lines changed

Lines changed: 12 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -649,6 +649,10 @@ receive_array(SHMRequest request, Size item_size, Size *count)`
`649`	`649`	`pgws_collector_hdr->request=request;`
`650`	`650`	`LockRelease(&collectorTag,ExclusiveLock, false);`
`651`	`651`
	`652`	`+/*`
	`653`	`+ * Check that the collector was started to avoid NULL`
	`654`	`+ * pointer dereference.`
	`655`	`+ */`
`652`	`656`	`if (!pgws_collector_hdr->latch)`
`653`	`657`	`ereport(ERROR, (errcode(ERRCODE_INTERNAL_ERROR),`
`654`	`658`	`errmsg("pg_wait_sampling collector wasn't started")));`
`@@ -819,6 +823,14 @@ pg_wait_sampling_reset_profile(PG_FUNCTION_ARGS)`
`819`	`823`	`pgws_collector_hdr->request=PROFILE_RESET;`
`820`	`824`	`LockRelease(&collectorTag,ExclusiveLock, false);`
`821`	`825`
	`826`	`+/*`
	`827`	`+ * Check that the collector was started to avoid NULL`
	`828`	`+ * pointer dereference.`
	`829`	`+ */`
	`830`	`+if (!pgws_collector_hdr->latch)`
	`831`	`+ereport(ERROR, (errcode(ERRCODE_INTERNAL_ERROR),`
	`832`	`+errmsg("pg_wait_sampling collector wasn't started")));`
	`833`	`+`
`822`	`834`	`SetLatch(pgws_collector_hdr->latch);`
`823`	`835`
`824`	`836`	`LockRelease(&queueTag,ExclusiveLock, false);`

Comments

(0)