1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
/*
* pg_wait_sampling.h
* Headers for pg_wait_sampling extension.
*
* Copyright (c) 2015-2025, Postgres Professional
*
* IDENTIFICATION
* contrib/pg_wait_sampling/pg_wait_sampling.h
*/
#ifndef __PG_WAIT_SAMPLING_H__
#define __PG_WAIT_SAMPLING_H__
#include "datatype/timestamp.h"
#include "storage/latch.h"
#include "storage/lock.h"
#include "storage/shm_mq.h"
#define PG_WAIT_SAMPLING_MAGIC 0xCA94B107
#define COLLECTOR_QUEUE_SIZE (16 * 1024)
#define HISTORY_TIME_MULTIPLIER 10
#define PGWS_QUEUE_LOCK 0
#define PGWS_COLLECTOR_LOCK 1
typedef struct
{
int pid;
uint32 wait_event_info;
uint64 queryId;
uint64 count;
} ProfileItem;
typedef struct
{
int pid;
uint32 wait_event_info;
uint64 queryId;
TimestampTz ts;
} HistoryItem;
typedef struct
{
bool wraparound;
Size index;
Size count;
HistoryItem *items;
} History;
typedef enum
{
NO_REQUEST,
HISTORY_REQUEST,
PROFILE_REQUEST,
PROFILE_RESET
} SHMRequest;
typedef struct
{
Latch *latch;
SHMRequest request;
} CollectorShmqHeader;
/* GUC variables */
extern int pgws_historySize;
extern int pgws_historyPeriod;
extern int pgws_profilePeriod;
extern bool pgws_profilePid;
extern int pgws_profileQueries;
extern bool pgws_sampleCpu;
/* pg_wait_sampling.c */
extern CollectorShmqHeader *pgws_collector_hdr;
extern shm_mq *pgws_collector_mq;
extern uint64 *pgws_proc_queryids;
extern void pgws_init_lock_tag(LOCKTAG *tag, uint32 lock);
extern bool pgws_should_sample_proc(PGPROC *proc, int *pid_p, uint32 *wait_event_info_p);
/* collector.c */
extern void pgws_register_wait_collector(void);
extern PGDLLEXPORT void pgws_collector_main(Datum main_arg);
#endif
|
