pacemaker  1.1.12-561c4cf
Scalable High-Availability cluster resource manager
 All Data Structures Files Functions Variables Typedefs Enumerations Enumerator Macros Modules Pages
mainloop.h
Go to the documentation of this file.
1 /*
2  * Copyright (C) 2009 Andrew Beekhof <andrew@beekhof.net>
3  *
4  * This program is free software; you can redistribute it and/or
5  * modify it under the terms of the GNU General Public
6  * License as published by the Free Software Foundation; either
7  * version 2 of the License, or (at your option) any later version.
8  *
9  * This software is distributed in the hope that it will be useful,
10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12  * General Public License for more details.
13  *
14  * You should have received a copy of the GNU General Public
15  * License along with this library; if not, write to the Free Software
16  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
17  */
18 #ifndef CRM_COMMON_MAINLOOP__H
19 # define CRM_COMMON_MAINLOOP__H
20 
27 # include <glib.h>
28 
29 typedef struct trigger_s crm_trigger_t;
30 typedef struct mainloop_io_s mainloop_io_t;
31 typedef struct mainloop_child_s mainloop_child_t;
32 typedef struct mainloop_timer_s mainloop_timer_t;
33 
34 void mainloop_cleanup(void);
35 
36 crm_trigger_t *mainloop_add_trigger(int priority, int (*dispatch) (gpointer user_data),
37  gpointer userdata);
38 
39 void mainloop_set_trigger(crm_trigger_t * source);
40 
42 
43 gboolean mainloop_destroy_trigger(crm_trigger_t * source);
44 
45 gboolean crm_signal(int sig, void (*dispatch) (int sig));
46 
47 gboolean mainloop_add_signal(int sig, void (*dispatch) (int sig));
48 
49 gboolean mainloop_destroy_signal(int sig);
50 
52 
54 
56 
57 guint mainloop_timer_set_period(mainloop_timer_t *t, guint period_ms);
58 
59 mainloop_timer_t *mainloop_timer_add(const char *name, guint period_ms, bool repeat, GSourceFunc cb, void *userdata);
60 
62 
63 
64 # include <crm/common/ipc.h>
65 # include <qb/qbipcs.h>
66 
68  int (*dispatch) (const char *buffer, ssize_t length, gpointer userdata);
69  void (*destroy) (gpointer);
70 };
71 
72 qb_ipcs_service_t *mainloop_add_ipc_server(const char *name, enum qb_ipc_type type,
73  struct qb_ipcs_service_handlers *callbacks);
74 
75 void mainloop_del_ipc_server(qb_ipcs_service_t * server);
76 
77 mainloop_io_t *mainloop_add_ipc_client(const char *name, int priority, size_t max_size,
78  void *userdata, struct ipc_client_callbacks *callbacks);
79 
81 
83 
85  int (*dispatch) (gpointer userdata);
86  void (*destroy) (gpointer userdata);
87 };
88 
89 mainloop_io_t *mainloop_add_fd(const char *name, int priority, int fd, void *userdata,
90  struct mainloop_fd_callbacks *callbacks);
91 
92 void mainloop_del_fd(mainloop_io_t * client);
93 
94 /*
95  * Create a new tracked process
96  * To track a process group, use -pid
97  */
98 void mainloop_child_add(pid_t pid,
99  int timeout,
100  const char *desc,
101  void *userdata,
102  void (*callback) (mainloop_child_t * p, pid_t pid, int core, int signo, int exitcode));
103 
106 const char *mainloop_child_name(mainloop_child_t * child);
107 
108 pid_t mainloop_child_pid(mainloop_child_t * child);
110 gboolean mainloop_child_kill(pid_t pid);
111 
112 # define G_PRIORITY_MEDIUM (G_PRIORITY_HIGH/2)
113 
114 #endif
gboolean mainloop_add_signal(int sig, void(*dispatch)(int sig))
mainloop_io_t * mainloop_add_fd(const char *name, int priority, int fd, void *userdata, struct mainloop_fd_callbacks *callbacks)
void mainloop_timer_start(mainloop_timer_t *t)
guint mainloop_timer_set_period(mainloop_timer_t *t, guint period_ms)
void mainloop_timer_del(mainloop_timer_t *t)
gboolean mainloop_child_kill(pid_t pid)
struct mainloop_timer_s mainloop_timer_t
Definition: mainloop.h:32
struct mainloop_io_s mainloop_io_t
Definition: mainloop.h:30
struct mainloop_child_s mainloop_child_t
Definition: mainloop.h:31
void mainloop_set_trigger(crm_trigger_t *source)
void mainloop_cleanup(void)
int(* dispatch)(gpointer userdata)
Definition: mainloop.h:85
pid_t mainloop_child_pid(mainloop_child_t *child)
uint32_t pid
Definition: internal.h:49
gboolean mainloop_destroy_trigger(crm_trigger_t *source)
void mainloop_timer_stop(mainloop_timer_t *t)
struct trigger_s crm_trigger_t
Definition: mainloop.h:29
void(* destroy)(gpointer)
Definition: mainloop.h:69
void * mainloop_child_userdata(mainloop_child_t *child)
struct crm_ipc_s crm_ipc_t
Definition: ipc.h:61
void(* destroy)(gpointer userdata)
Definition: mainloop.h:86
gboolean crm_signal(int sig, void(*dispatch)(int sig))
crm_trigger_t * mainloop_add_trigger(int priority, int(*dispatch)(gpointer user_data), gpointer userdata)
void mainloop_del_ipc_client(mainloop_io_t *client)
bool mainloop_timer_running(mainloop_timer_t *t)
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))
void mainloop_trigger_complete(crm_trigger_t *trig)
crm_ipc_t * mainloop_get_ipc_client(mainloop_io_t *client)
void mainloop_clear_child_userdata(mainloop_child_t *child)
Wrappers for and extensions to libqb IPC.
void mainloop_del_fd(mainloop_io_t *client)
void mainloop_del_ipc_server(qb_ipcs_service_t *server)
mainloop_timer_t * mainloop_timer_add(const char *name, guint period_ms, bool repeat, GSourceFunc cb, void *userdata)
gboolean mainloop_destroy_signal(int sig)
mainloop_io_t * mainloop_add_ipc_client(const char *name, int priority, size_t max_size, void *userdata, struct ipc_client_callbacks *callbacks)
qb_ipcs_service_t * mainloop_add_ipc_server(const char *name, enum qb_ipc_type type, struct qb_ipcs_service_handlers *callbacks)
const char * mainloop_child_name(mainloop_child_t *child)
int(* dispatch)(const char *buffer, ssize_t length, gpointer userdata)
Definition: mainloop.h:68
enum crm_ais_msg_types type
Definition: internal.h:51
int mainloop_child_timeout(mainloop_child_t *child)