|
52 | 52 | AllocateCollectorMem(void)
|
53 | 53 | {
|
54 | 54 | boolfound;
|
55 |
| -Sizesegsize=CollectorShmemSize(); |
| 55 | +Sizesegsize=CollectorShmemSize(); |
56 | 56 |
|
57 | 57 | pgsw=ShmemInitStruct("pg_stat_wait",segsize,&found);
|
58 | 58 |
|
@@ -96,7 +96,7 @@ RegisterWaitsCollector(void)
|
96 | 96 | /* set up common data for all our workers */
|
97 | 97 | worker.bgw_flags=BGWORKER_SHMEM_ACCESS |
|
98 | 98 | BGWORKER_BACKEND_DATABASE_CONNECTION;
|
99 |
| -worker.bgw_start_time=BgWorkerStart_RecoveryFinished; |
| 99 | +worker.bgw_start_time=BgWorkerStart_ConsistentState; |
100 | 100 | worker.bgw_restart_time=BGW_NEVER_RESTART;
|
101 | 101 | worker.bgw_main=collector_main;
|
102 | 102 | worker.bgw_notify_pid=0;
|
@@ -233,6 +233,7 @@ collector_main(Datum main_arg)
|
233 | 233 | BackgroundWorkerUnblockSignals();
|
234 | 234 |
|
235 | 235 | hdr->latch=&MyProc->procLatch;
|
| 236 | + |
236 | 237 | CurrentResourceOwner=ResourceOwnerCreate(NULL,"pg_stat_wait collector");
|
237 | 238 | collector_context=AllocSetContextCreate(TopMemoryContext,
|
238 | 239 | "pg_stat_wait context",
|
|