blob: 429f2eb71360c7c18f6468ca8b655b5ca1500ed3 (
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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
#ifndef MASTER_SERVICE_PRIVATE_H
#define MASTER_SERVICE_PRIVATE_H
#include "master-interface.h"
#include "master-service.h"
struct master_service_haproxy_conn;
struct master_service_listener {
struct master_service *service;
char *name;
/* settings */
bool ssl;
bool haproxy;
/* state */
bool closed;
int fd;
struct io *io;
};
struct master_service {
struct ioloop *ioloop;
char *name;
char *configured_name;
char *getopt_str;
enum master_service_flags flags;
int argc;
char **argv;
const char *version_string;
char *config_path;
ARRAY_TYPE(const_string) config_overrides;
int config_fd;
int syslog_facility;
data_stack_frame_t datastack_frame_id;
struct master_service_listener *listeners;
unsigned int socket_count;
struct io *io_status_write, *io_status_error;
unsigned int service_count_left;
unsigned int total_available_count;
unsigned int process_limit;
unsigned int process_min_avail;
unsigned int idle_kill_secs;
struct master_status master_status;
unsigned int last_sent_status_avail_count;
time_t last_sent_status_time;
struct timeout *to_status;
bool (*idle_die_callback)(void);
void (*die_callback)(void);
struct timeout *to_die;
master_service_avail_overflow_callback_t *avail_overflow_callback;
struct timeout *to_overflow_state, *to_overflow_call;
struct master_login *login;
master_service_connection_callback_t *callback;
pool_t set_pool;
const struct master_service_settings *set;
struct setting_parser_context *set_parser;
struct ssl_iostream_context *ssl_ctx;
time_t ssl_params_last_refresh;
struct stats_client *stats_client;
struct master_service_haproxy_conn *haproxy_conns;
struct event_filter *process_shutdown_filter;
bool killed:1;
bool stopping:1;
bool keep_environment:1;
bool log_directly:1;
bool initial_status_sent:1;
bool die_with_master:1;
bool call_avail_overflow:1;
bool config_path_changed_with_param:1;
bool want_ssl_server:1;
bool ssl_ctx_initialized:1;
bool config_path_from_master:1;
bool log_initialized:1;
bool init_finished:1;
};
void master_service_io_listeners_add(struct master_service *service);
void master_status_update(struct master_service *service);
void master_service_close_config_fd(struct master_service *service);
void master_service_io_listeners_remove(struct master_service *service);
void master_service_ssl_io_listeners_remove(struct master_service *service);
void master_service_client_connection_handled(struct master_service *service,
struct master_service_connection *conn);
void master_service_client_connection_callback(struct master_service *service,
struct master_service_connection *conn);
void master_service_haproxy_new(struct master_service *service,
struct master_service_connection *conn);
void master_service_haproxy_abort(struct master_service *service);
#endif
|
