1
2
3
4
5
6
7
8
9
10 #ifndef PCMK__CRM_COMMON_MAINLOOP__H
11 #define PCMK__CRM_COMMON_MAINLOOP__H
12
13 #include <signal.h>
14 #include <glib.h>
15 #include <stdbool.h>
16
17 #ifdef __cplusplus
18 extern "C" {
19 #endif
20
21
22
23
24
25
26
27 enum mainloop_child_flags {
28
29 mainloop_leave_pid_group = 0x01,
30 };
31
32
33 typedef struct trigger_s crm_trigger_t;
34
35 typedef struct mainloop_io_s mainloop_io_t;
36 typedef struct mainloop_child_s mainloop_child_t;
37
38
39 typedef struct mainloop_timer_s mainloop_timer_t;
40
41 void mainloop_cleanup(void);
42
43
44 crm_trigger_t *mainloop_add_trigger(int priority, int (*dispatch) (gpointer user_data),
45 gpointer userdata);
46
47
48 void mainloop_set_trigger(crm_trigger_t * source);
49
50 void mainloop_trigger_complete(crm_trigger_t * trig);
51
52 gboolean mainloop_destroy_trigger(crm_trigger_t * source);
53
54 #ifndef HAVE_SIGHANDLER_T
55 typedef void (*sighandler_t)(int);
56 #endif
57
58 sighandler_t crm_signal_handler(int sig, sighandler_t dispatch);
59
60
61 gboolean mainloop_add_signal(int sig, void (*dispatch) (int sig));
62
63 gboolean mainloop_destroy_signal(int sig);
64
65 bool mainloop_timer_running(mainloop_timer_t *t);
66
67
68 void mainloop_timer_start(mainloop_timer_t *t);
69
70
71 void mainloop_timer_stop(mainloop_timer_t *t);
72
73 guint mainloop_timer_set_period(mainloop_timer_t *t, guint period_ms);
74
75
76 mainloop_timer_t *mainloop_timer_add(const char *name, guint period_ms, bool repeat, GSourceFunc cb, void *userdata);
77
78 void mainloop_timer_del(mainloop_timer_t *t);
79
80
81 #include <crm/common/ipc.h>
82 #include <qb/qbipcs.h>
83
84 struct ipc_client_callbacks {
85
86
87
88
89
90
91
92
93
94 int (*dispatch) (const char *buffer, ssize_t length, gpointer userdata);
95
96
97
98
99
100
101 void (*destroy) (gpointer userdata);
102 };
103
104 qb_ipcs_service_t *mainloop_add_ipc_server(const char *name, enum qb_ipc_type type,
105 struct qb_ipcs_service_handlers *callbacks);
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126 qb_ipcs_service_t *mainloop_add_ipc_server_with_prio(const char *name,
127 enum qb_ipc_type type,
128 struct qb_ipcs_service_handlers *callbacks,
129 enum qb_loop_priority prio);
130
131 void mainloop_del_ipc_server(qb_ipcs_service_t * server);
132
133 mainloop_io_t *mainloop_add_ipc_client(const char *name, int priority, size_t max_size,
134 void *userdata, struct ipc_client_callbacks *callbacks);
135
136 void mainloop_del_ipc_client(mainloop_io_t * client);
137
138 crm_ipc_t *mainloop_get_ipc_client(mainloop_io_t * client);
139
140 struct mainloop_fd_callbacks {
141
142
143
144
145
146
147
148 int (*dispatch) (gpointer userdata);
149
150
151
152
153
154
155 void (*destroy) (gpointer userdata);
156 };
157
158 mainloop_io_t *mainloop_add_fd(const char *name, int priority, int fd, void *userdata,
159 struct mainloop_fd_callbacks *callbacks);
160
161 void mainloop_del_fd(mainloop_io_t * client);
162
163
164
165
166
167 void mainloop_child_add(pid_t pid,
168 int timeout,
169 const char *desc,
170 void *userdata,
171 void (*callback) (mainloop_child_t * p, pid_t pid, int core, int signo, int exitcode));
172
173 void mainloop_child_add_with_flags(pid_t pid,
174 int timeout,
175 const char *desc,
176 void *userdata,
177 enum mainloop_child_flags,
178 void (*callback) (mainloop_child_t * p, pid_t pid, int core, int signo, int exitcode));
179
180 void *mainloop_child_userdata(mainloop_child_t * child);
181 int mainloop_child_timeout(mainloop_child_t * child);
182 const char *mainloop_child_name(mainloop_child_t * child);
183
184 pid_t mainloop_child_pid(mainloop_child_t * child);
185 void mainloop_clear_child_userdata(mainloop_child_t * child);
186 gboolean mainloop_child_kill(pid_t pid);
187
188 void pcmk_quit_main_loop(GMainLoop *mloop, unsigned int n);
189 void pcmk_drain_main_loop(GMainLoop *mloop, guint timer_ms,
190 bool (*check)(guint));
191
192 #define G_PRIORITY_MEDIUM (G_PRIORITY_HIGH/2)
193
194 #if !defined(PCMK_ALLOW_DEPRECATED) || (PCMK_ALLOW_DEPRECATED == 1)
195 #include <crm/common/mainloop_compat.h>
196 #endif
197
198 #ifdef __cplusplus
199 }
200 #endif
201
202 #endif