blob: 6ae55d6a9e0bc32d516a911c77f9fbaccbf9b0cf (
plain)
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
82
83
|
#ifndef __PGQD_H__
#define __PGQD_H__
#include <string.h>
#define Assert(x)
#include <usual/list.h>
#include <usual/statlist.h>
#include <usual/logging.h>
#include <usual/pgsocket.h>
enum DbState {
DB_CLOSED,
DB_TICKER_CHECK_PGQ,
DB_TICKER_CHECK_VERSION,
DB_TICKER_RUN,
DB_MAINT_TEST_VERSION,
DB_MAINT_LOAD_OPS,
DB_MAINT_OP,
DB_MAINT_LOAD_QUEUES,
DB_MAINT_ROT1,
DB_MAINT_ROT2,
DB_MAINT_VACUUM_LIST,
DB_MAINT_DO_VACUUM,
};
struct MaintOp;
struct PgDatabase {
struct List head;
const char *name;
struct PgSocket *c_ticker;
struct PgSocket *c_maint;
struct PgSocket *c_retry;
bool has_pgq;
enum DbState state;
enum DbState maint_state;
bool dropped;
struct StrList *maint_item_list;
struct StatList maint_op_list;
struct MaintOp *cur_maint;
bool has_maint_operations;
};
struct Config {
const char *config_file;
const char *pidfile;
const char *base_connstr;
const char *initial_database;
const char *database_list;
double retry_period;
double check_period;
double maint_period;
double ticker_period;
double stats_period;
double connection_lifetime;
};
struct Stats {
int n_ticks;
int n_maint;
int n_retry;
};
extern struct Config cf;
extern struct Stats stats;
void launch_ticker(struct PgDatabase *db);
void launch_maint(struct PgDatabase *db);
void launch_retry(struct PgDatabase *db);
void free_maint(struct PgDatabase *db);
const char *make_connstr(const char *dbname);
#endif
|
