WIP: Massive pacemaker-based refactors

daemons/attrd/attrd_corosync.c

@@ -487,6 +487,12 @@ broadcast_unseen_local_values(void)
     }
 }
 
+/*!
+ * \internal
+ * \brief Initialize \c attrd_cluster and connect to the cluster layer
+ *
+ * \return Standard Pacemaker return code
+ */
 int
 attrd_cluster_connect(void)
 {
@@ -512,11 +518,19 @@ attrd_cluster_connect(void)
     return rc;
 }
 
+/*!
+ * \internal
+ * \brief Disconnect from the cluster layer and free \c attrd_cluster
+ */
 void
 attrd_cluster_disconnect(void)
 {
+    if (attrd_cluster == NULL) {
+        return;
+    }
+
     pcmk_cluster_disconnect(attrd_cluster);
-    pcmk_cluster_free(attrd_cluster);
+    g_clear_pointer(&attrd_cluster, pcmk_cluster_free);
 }
 
 void

daemons/attrd/attrd_messages.c

@@ -348,7 +348,7 @@ attrd_send_protocol(const pcmk__node_status_t *peer)
     pcmk__xml_free(attrd_op);
 }
 
-gboolean
+void
 attrd_send_message(const pcmk__node_status_t *node, xmlNode *data, bool confirm)
 {
     const char *op = pcmk__xe_get(data, PCMK_XA_TASK);
@@ -365,5 +365,5 @@ attrd_send_message(const pcmk__node_status_t *node, xmlNode *data, bool confirm)
     }
 
     attrd_xml_add_writer(data);
-    return pcmk__cluster_send_message(node, pcmk_ipc_attrd, data);
+    pcmk__cluster_send_message(node, pcmk_ipc_attrd, data);
 }

daemons/attrd/attrd_utils.c

@@ -57,28 +57,16 @@ attrd_shutdown(int nsig)
     // Tell various functions not to do anthing
     shutting_down = true;
 
-    // Don't respond to signals while shutting down
-    mainloop_destroy_signal(SIGTERM);
-    mainloop_destroy_signal(SIGCHLD);
-    mainloop_destroy_signal(SIGPIPE);
-    mainloop_destroy_signal(SIGUSR1);
-    mainloop_destroy_signal(SIGUSR2);
-    mainloop_destroy_signal(SIGTRAP);
-
     attrd_free_waitlist();
     attrd_free_confirmations();
 
     g_clear_pointer(&peer_protocol_vers, g_hash_table_destroy);
 
-    if ((mloop == NULL) || !g_main_loop_is_running(mloop)) {
-        /* If there's no main loop active, just exit. This should be possible
-         * only if we get SIGTERM in brief windows at start-up and shutdown.
-         */
-        crm_exit(CRM_EX_OK);
-    } else {
-        g_main_loop_quit(mloop);
-        g_main_loop_unref(mloop);
-    }
+    // There should be no way to get here without the main loop running
+    CRM_CHECK((mloop != NULL) && g_main_loop_is_running(mloop),
+              crm_exit(CRM_EX_OK));
+
+    g_main_loop_quit(mloop);
 }
 
 /*!
@@ -99,6 +87,7 @@ void
 attrd_run_mainloop(void)
 {
     g_main_loop_run(mloop);
+    g_clear_pointer(&mloop, g_main_loop_unref);
 }
 
 /* strlen("value") */

daemons/attrd/pacemaker-attrd.h

@@ -8,7 +8,7 @@
  */
 
 #ifndef PACEMAKER_ATTRD__H
-#  define PACEMAKER_ATTRD__H
+#define PACEMAKER_ATTRD__H
 
 #include <regex.h>
 #include <stdbool.h>
@@ -210,8 +210,8 @@ void attrd_client_clear_failure(pcmk__request_t *request);
 void attrd_client_update(pcmk__request_t *request);
 void attrd_client_refresh(pcmk__request_t *request);
 xmlNode *attrd_client_query(pcmk__request_t *request);
-gboolean attrd_send_message(const pcmk__node_status_t *node, xmlNode *data,
-                            bool confirm);
+void attrd_send_message(const pcmk__node_status_t *node, xmlNode *data,
+                        bool confirm);
 
 xmlNode *attrd_add_value_xml(xmlNode *parent, const attribute_t *a,
                              const attribute_value_t *v, bool force_write);
@@ -267,4 +267,4 @@ void attrd_set_node_xml_id(const char *node_name, const char *node_xml_id);
 void attrd_forget_node_xml_id(const char *node_name);
 void attrd_cleanup_xml_ids(void);
 
-#endif /* PACEMAKER_ATTRD__H */
+#endif  // PACEMAKER_ATTRD__H

daemons/based/Makefile.am

@@ -15,7 +15,9 @@ halibdir	= $(CRM_DAEMON_DIR)
 halib_PROGRAMS	= pacemaker-based
 
 noinst_HEADERS = based_callbacks.h
+noinst_HEADERS += based_corosync.h
 noinst_HEADERS += based_io.h
+noinst_HEADERS += based_ipc.h
 noinst_HEADERS += based_messages.h
 noinst_HEADERS += based_notify.h
 noinst_HEADERS += based_operation.h
@@ -33,6 +35,7 @@ pacemaker_based_LDADD += $(CLUSTERLIBS) $(PAM_LIBS)
 
 pacemaker_based_SOURCES = pacemaker-based.c
 pacemaker_based_SOURCES += based_callbacks.c
+pacemaker_based_SOURCES += based_corosync.c
 pacemaker_based_SOURCES += based_io.c
 pacemaker_based_SOURCES += based_ipc.c
 pacemaker_based_SOURCES += based_messages.c