pacemaker  2.0.3-4b1f869f0f
Scalable High-Availability cluster resource manager
mainloop.h
Go to the documentation of this file.
1 /*
2  * Copyright 2009-2019 the Pacemaker project contributors
3  *
4  * The version control history for this file may have further details.
5  *
6  * This source code is licensed under the GNU Lesser General Public License
7  * version 2.1 or later (LGPLv2.1+) WITHOUT ANY WARRANTY.
8  */
9 
10 #ifndef CRM_COMMON_MAINLOOP__H
11 # define CRM_COMMON_MAINLOOP__H
12 
13 #ifdef __cplusplus
14 extern "C" {
15 #endif
16 
23 # include <signal.h> // sighandler_t
24 # include <glib.h>
25 
27  /* don't kill pid group on timeout, only kill the pid */
29 };
30 
31 typedef struct trigger_s crm_trigger_t;
32 typedef struct mainloop_io_s mainloop_io_t;
33 typedef struct mainloop_child_s mainloop_child_t;
34 typedef struct mainloop_timer_s mainloop_timer_t;
35 
36 void mainloop_cleanup(void);
37 
38 crm_trigger_t *mainloop_add_trigger(int priority, int (*dispatch) (gpointer user_data),
39  gpointer userdata);
40 
41 void mainloop_set_trigger(crm_trigger_t * source);
42 
44 
45 gboolean mainloop_destroy_trigger(crm_trigger_t * source);
46 
47 # ifndef HAVE_SIGHANDLER_T
48 typedef void (*sighandler_t)(int);
49 # endif
50 
52 gboolean crm_signal(int sig, void (*dispatch) (int sig)); // deprecated
53 
54 gboolean mainloop_add_signal(int sig, void (*dispatch) (int sig));
55 
56 gboolean mainloop_destroy_signal(int sig);
57 
59 
61 
63 
64 guint mainloop_timer_set_period(mainloop_timer_t *t, guint period_ms);
65 
66 mainloop_timer_t *mainloop_timer_add(const char *name, guint period_ms, bool repeat, GSourceFunc cb, void *userdata);
67 
69 
70 
71 # include <crm/common/ipc.h>
72 # include <qb/qbipcs.h>
73 
75  int (*dispatch) (const char *buffer, ssize_t length, gpointer userdata);
76  void (*destroy) (gpointer);
77 };
78 
79 qb_ipcs_service_t *mainloop_add_ipc_server(const char *name, enum qb_ipc_type type,
80  struct qb_ipcs_service_handlers *callbacks);
81 
101 qb_ipcs_service_t *mainloop_add_ipc_server_with_prio(const char *name,
102  enum qb_ipc_type type,
103  struct qb_ipcs_service_handlers *callbacks,
104  enum qb_loop_priority prio);
105 
106 void mainloop_del_ipc_server(qb_ipcs_service_t * server);
107 
108 mainloop_io_t *mainloop_add_ipc_client(const char *name, int priority, size_t max_size,
109  void *userdata, struct ipc_client_callbacks *callbacks);
110 
112 
114 
116  int (*dispatch) (gpointer userdata);
117  void (*destroy) (gpointer userdata);
118 };
119 
120 mainloop_io_t *mainloop_add_fd(const char *name, int priority, int fd, void *userdata,
121  struct mainloop_fd_callbacks *callbacks);
122 
123 void mainloop_del_fd(mainloop_io_t * client);
124 
125 /*
126  * Create a new tracked process
127  * To track a process group, use -pid
128  */
129 void mainloop_child_add(pid_t pid,
130  int timeout,
131  const char *desc,
132  void *userdata,
133  void (*callback) (mainloop_child_t * p, pid_t pid, int core, int signo, int exitcode));
134 
136  int timeout,
137  const char *desc,
138  void *userdata,
140  void (*callback) (mainloop_child_t * p, pid_t pid, int core, int signo, int exitcode));
141 
144 const char *mainloop_child_name(mainloop_child_t * child);
145 
146 pid_t mainloop_child_pid(mainloop_child_t * child);
148 gboolean mainloop_child_kill(pid_t pid);
149 
150 void pcmk_drain_main_loop(GMainLoop *mloop, guint timer_ms,
151  bool (*check)(guint));
152 
153 # define G_PRIORITY_MEDIUM (G_PRIORITY_HIGH/2)
154 
155 #ifdef __cplusplus
156 }
157 #endif
158 
159 #endif
mainloop_child_kill
gboolean mainloop_child_kill(pid_t pid)
Definition: mainloop.c:1181
sighandler_t
void(* sighandler_t)(int)
Definition: mainloop.h:48
mainloop_add_fd
mainloop_io_t * mainloop_add_fd(const char *name, int priority, int fd, void *userdata, struct mainloop_fd_callbacks *callbacks)
Definition: mainloop.c:941
mainloop_get_ipc_client
crm_ipc_t * mainloop_get_ipc_client(mainloop_io_t *client)
Definition: mainloop.c:932
mainloop_child_userdata
void * mainloop_child_userdata(mainloop_child_t *child)
Definition: mainloop.c:1019
ipc_client_callbacks::destroy
void(* destroy)(gpointer)
Definition: mainloop.h:76
mainloop_fd_callbacks
Definition: mainloop.h:115
mainloop_timer_start
void mainloop_timer_start(mainloop_timer_t *t)
Definition: mainloop.c:1324
mainloop_child_pid
pid_t mainloop_child_pid(mainloop_child_t *child)
Definition: mainloop.c:1001
type
enum crm_ais_msg_types type
Definition: internal.h:5
mainloop_timer_t
struct mainloop_timer_s mainloop_timer_t
Definition: mainloop.h:34
mainloop_child_timeout
int mainloop_child_timeout(mainloop_child_t *child)
Definition: mainloop.c:1013
mainloop_del_ipc_server
void mainloop_del_ipc_server(qb_ipcs_service_t *server)
Definition: mainloop.c:749
mainloop_timer_del
void mainloop_timer_del(mainloop_timer_t *t)
Definition: mainloop.c:1380
pcmk_drain_main_loop
void pcmk_drain_main_loop(GMainLoop *mloop, guint timer_ms, bool(*check)(guint))
Process main loop events while a certain condition is met.
Definition: mainloop.c:1416
mainloop_add_ipc_server
qb_ipcs_service_t * mainloop_add_ipc_server(const char *name, enum qb_ipc_type type, struct qb_ipcs_service_handlers *callbacks)
Definition: mainloop.c:702
mainloop_add_trigger
crm_trigger_t * mainloop_add_trigger(int priority, int(*dispatch)(gpointer user_data), gpointer userdata)
Definition: mainloop.c:204
mainloop_fd_callbacks::destroy
void(* destroy)(gpointer userdata)
Definition: mainloop.h:117
mainloop_child_name
const char * mainloop_child_name(mainloop_child_t *child)
Definition: mainloop.c:1007
mainloop_destroy_signal
gboolean mainloop_destroy_signal(int sig)
Definition: mainloop.c:441
mainloop_timer_stop
void mainloop_timer_stop(mainloop_timer_t *t)
Definition: mainloop.c:1333
mainloop_add_signal
gboolean mainloop_add_signal(int sig, void(*dispatch)(int sig))
Definition: mainloop.c:387
mainloop_destroy_trigger
gboolean mainloop_destroy_trigger(crm_trigger_t *source)
Definition: mainloop.c:224
crm_trigger_t
struct trigger_s crm_trigger_t
Definition: mainloop.h:31
mainloop_child_flags
mainloop_child_flags
Definition: mainloop.h:26
pid
uint32_t pid
Definition: internal.h:3
ipc_client_callbacks
Definition: mainloop.h:74
mainloop_leave_pid_group
@ mainloop_leave_pid_group
Definition: mainloop.h:28
mainloop_set_trigger
void mainloop_set_trigger(crm_trigger_t *source)
Definition: mainloop.c:216
mainloop_add_ipc_server_with_prio
qb_ipcs_service_t * mainloop_add_ipc_server_with_prio(const char *name, enum qb_ipc_type type, struct qb_ipcs_service_handlers *callbacks, enum qb_loop_priority prio)
Start server-side API end-point, hooked into the internal event loop.
Definition: mainloop.c:709
ipc.h
Wrappers for and extensions to libqb IPC.
mainloop_clear_child_userdata
void mainloop_clear_child_userdata(mainloop_child_t *child)
Definition: mainloop.c:1025
mainloop_fd_callbacks::dispatch
int(* dispatch)(gpointer userdata)
Definition: mainloop.h:116
mainloop_child_t
struct mainloop_child_s mainloop_child_t
Definition: mainloop.h:33
mainloop_del_fd
void mainloop_del_fd(mainloop_io_t *client)
Definition: mainloop.c:985
mainloop_timer_add
mainloop_timer_t * mainloop_timer_add(const char *name, guint period_ms, bool repeat, GSourceFunc cb, void *userdata)
Definition: mainloop.c:1359
mainloop_io_t
struct mainloop_io_s mainloop_io_t
Definition: mainloop.h:32
mainloop_del_ipc_client
void mainloop_del_ipc_client(mainloop_io_t *client)
Definition: mainloop.c:926
mainloop_timer_running
bool mainloop_timer_running(mainloop_timer_t *t)
Definition: mainloop.c:1316
mainloop_child_add_with_flags
void mainloop_child_add_with_flags(pid_t pid, int timeout, const char *desc, void *userdata, enum mainloop_child_flags, void(*callback)(mainloop_child_t *p, pid_t pid, int core, int signo, int exitcode))
Definition: mainloop.c:1237
mainloop_child_add
void mainloop_child_add(pid_t pid, int timeout, const char *desc, void *userdata, void(*callback)(mainloop_child_t *p, pid_t pid, int core, int signo, int exitcode))
Definition: mainloop.c:1271
mainloop_trigger_complete
void mainloop_trigger_complete(crm_trigger_t *trig)
Definition: mainloop.c:192
ipc_client_callbacks::dispatch
int(* dispatch)(const char *buffer, ssize_t length, gpointer userdata)
Definition: mainloop.h:75
crm_signal
gboolean crm_signal(int sig, void(*dispatch)(int sig))
Definition: mainloop.c:359
mainloop_timer_set_period
guint mainloop_timer_set_period(mainloop_timer_t *t, guint period_ms)
Definition: mainloop.c:1342
mainloop_cleanup
void mainloop_cleanup(void)
Definition: mainloop.c:461
crm_signal_handler
sighandler_t crm_signal_handler(int sig, sighandler_t dispatch)
Definition: mainloop.c:329
crm_ipc_t
struct crm_ipc_s crm_ipc_t
Definition: ipc.h:58
mainloop_add_ipc_client
mainloop_io_t * mainloop_add_ipc_client(const char *name, int priority, size_t max_size, void *userdata, struct ipc_client_callbacks *callbacks)
Definition: mainloop.c:898