Commitcd0546f

Alexander Korotkov

committed

Better comments.

1 parent365263b commitcd0546fCopy full SHA for cd0546f

File tree

+10

-3

lines changed

+10

-3

lines changed

Lines changed: 6 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -298,6 +298,7 @@ collector_main(Datum main_arg)`
`298`	`298`	`alloc_history(&observations,collector_hdr->historySize);`
`299`	`299`	`MemoryContextSwitchTo(old_context);`
`300`	`300`
	`301`	`+/* Start counting time for history and profile samples */`
`301`	`302`	`profile_ts=history_ts=GetCurrentTimestamp();`
`302`	`303`
`303`	`304`	`while (1)`
`@@ -311,6 +312,7 @@ collector_main(Datum main_arg)`
`311`	`312`	`boolwrite_history,`
`312`	`313`	`write_profile;`
`313`	`314`
	`315`	`+/* Wait calculate time to next sample for history or profile */`
`314`	`316`	`current_ts=GetCurrentTimestamp();`
`315`	`317`
`316`	`318`	`history_diff=millisecs_diff(history_ts,current_ts);`
`@@ -343,6 +345,10 @@ collector_main(Datum main_arg)`
`343`	`345`	`if (shutdown_requested)`
`344`	`346`	`break;`
`345`	`347`
	`348`	`+/*`
	`349`	`+ * Wait until next sample time or request to do something through`
	`350`	`+ * shared memory.`
	`351`	`+ */`
`346`	`352`	`rc=WaitLatch(&MyProc->procLatch,WL_LATCH_SET \|WL_TIMEOUT \|WL_POSTMASTER_DEATH,`
`347`	`353`	`Min(history_period- (int)history_diff,`
`348`	`354`	`profile_period- (int)profile_diff));`

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -290,6 +290,7 @@ pg_wait_sampling_get_current(PG_FUNCTION_ARGS)`
`290`	`290`
`291`	`291`	`item=&params->items[funcctx->call_cntr];`
`292`	`292`
	`293`	`+/* Make and return next tuple to caller */`
`293`	`294`	`MemSet(values,0,sizeof(values));`
`294`	`295`	`MemSet(nulls,0,sizeof(nulls));`
`295`	`296`
`@@ -439,7 +440,7 @@ pg_wait_sampling_get_profile(PG_FUNCTION_ARGS)`
`439`	`440`	`MemSet(values,0,sizeof(values));`
`440`	`441`	`MemSet(nulls,0,sizeof(nulls));`
`441`	`442`
`442`		`-/Values available to all callers /`
	`443`	`+/Make and return next tuple to caller /`
`443`	`444`	`event_type=pgstat_get_wait_event_type(item->wait_event_info);`
`444`	`445`	`event=pgstat_get_wait_event(item->wait_event_info);`
`445`	`446`	`values[0]=Int32GetDatum(item->pid);`
`@@ -538,10 +539,10 @@ pg_wait_sampling_get_history(PG_FUNCTION_ARGS)`
`538`	`539`
`539`	`540`	`item=&history->items[history->index];`
`540`	`541`
	`542`	`+/* Make and return next tuple to caller */`
`541`	`543`	`MemSet(values,0,sizeof(values));`
`542`	`544`	`MemSet(nulls,0,sizeof(nulls));`
`543`	`545`
`544`		`-/* Values available to all callers */`
`545`	`546`	`event_type=pgstat_get_wait_event_type(item->wait_event_info);`
`546`	`547`	`event=pgstat_get_wait_event(item->wait_event_info);`
`547`	`548`	`values[0]=Int32GetDatum(item->pid);`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,5 @@`
`1`	`1`	`# pg_wait_sampling extension`
`2`		`-comment = 'trackstatistics of wait eventsusing sampling'`
	`2`	`+comment = 'sampling basedstatistics of wait events '`
`3`	`3`	`default_version = '1.0'`
`4`	`4`	`module_pathname = '$libdir/pg_wait_sampling'`
`5`	`5`	`relocatable = true`

Comments

(0)