msg                82 daemons/attrd/attrd_alerts.c config_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               129 daemons/attrd/attrd_alerts.c attrd_cib_updated_cb(const char *event, xmlNode * msg)
msg               131 daemons/attrd/attrd_alerts.c     if (!attrd_shutting_down() && pcmk__alert_in_patchset(msg, FALSE)) {
msg              1003 daemons/attrd/attrd_commands.c attrd_cib_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               225 daemons/attrd/attrd_utils.c attrd_cib_replaced_cb(const char *event, xmlNode * msg)
msg                43 daemons/attrd/pacemaker-attrd.c                  uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len)
msg                48 daemons/attrd/pacemaker-attrd.c     char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from);
msg               104 daemons/attrd/pacemaker-attrd.c attrd_erase_cb(xmlNode *msg, int call_id, int rc, xmlNode *output,
msg                69 daemons/attrd/pacemaker-attrd.h void attrd_cib_replaced_cb(const char *event, xmlNode * msg);
msg                70 daemons/attrd/pacemaker-attrd.h void attrd_cib_updated_cb(const char *event, xmlNode *msg);
msg               125 daemons/attrd/pacemaker-attrd.h void attrd_peer_message(crm_node_t *client, xmlNode *msg);
msg               861 daemons/based/based_callbacks.c send_peer_reply(xmlNode * msg, xmlNode * result_diff, const char *originator, gboolean broadcast)
msg               863 daemons/based/based_callbacks.c     CRM_ASSERT(msg != NULL);
msg               893 daemons/based/based_callbacks.c         crm_xml_add(msg, F_CIB_ISREPLY, originator);
msg               894 daemons/based/based_callbacks.c         crm_xml_add(msg, F_CIB_GLOBAL_UPDATE, XML_BOOLEAN_TRUE);
msg               895 daemons/based/based_callbacks.c         crm_xml_add(msg, F_CIB_OPERATION, CIB_OP_APPLY_DIFF);
msg               896 daemons/based/based_callbacks.c         crm_xml_add(msg, F_CIB_USER, CRM_DAEMON_USER);
msg               902 daemons/based/based_callbacks.c         add_message_xml(msg, F_CIB_UPDATE_DIFF, result_diff);
msg               903 daemons/based/based_callbacks.c         crm_log_xml_explicit(msg, "copy");
msg               904 daemons/based/based_callbacks.c         return send_cluster_message(NULL, crm_msg_cib, msg, TRUE);
msg               909 daemons/based/based_callbacks.c         crm_xml_add(msg, F_CIB_ISREPLY, originator);
msg               910 daemons/based/based_callbacks.c         return send_cluster_message(crm_get_peer(0, originator), crm_msg_cib, msg, FALSE);
msg              1394 daemons/based/based_callbacks.c cib_peer_callback(xmlNode * msg, void *private_data)
msg              1397 daemons/based/based_callbacks.c     const char *originator = crm_element_value(msg, F_ORIG);
msg              1403 daemons/based/based_callbacks.c         if (!(crm_element_value_int(msg, F_CIB_LOCAL_NOTIFY_ID, &bcast_id))) {
msg              1413 daemons/based/based_callbacks.c     if (crm_element_value(msg, F_CIB_CLIENTNAME) == NULL) {
msg              1414 daemons/based/based_callbacks.c         crm_xml_add(msg, F_CIB_CLIENTNAME, originator);
msg              1418 daemons/based/based_callbacks.c     cib_process_request(msg, TRUE, NULL);
msg              1423 daemons/based/based_callbacks.c         const char *seq = crm_element_value(msg, F_SEQ);
msg              1424 daemons/based/based_callbacks.c         const char *op = crm_element_value(msg, F_CIB_OPERATION);
msg               202 daemons/based/based_common.c cib_msg_copy(xmlNode * msg, gboolean with_data)
msg               246 daemons/based/based_common.c         value = crm_element_value(msg, field);
msg               253 daemons/based/based_common.c         value_struct = get_message_xml(msg, field);
msg                35 daemons/based/based_notify.c     xmlNode *msg;
msg                40 daemons/based/based_notify.c void attach_cib_generation(xmlNode * msg, const char *field, xmlNode * a_cib);
msg                61 daemons/based/based_notify.c     type = crm_element_value(update->msg, F_SUBTYPE);
msg               104 daemons/based/based_notify.c                 pcmk__remote_send_xml(client->remote, update->msg);
msg               124 daemons/based/based_notify.c         update.msg = xml;
msg               225 daemons/based/based_notify.c attach_cib_generation(xmlNode * msg, const char *field, xmlNode * a_cib)
msg               232 daemons/based/based_notify.c     add_message_xml(msg, field, generation);
msg               558 daemons/based/based_remote.c construct_pam_passwd(int num_msg, const struct pam_message **msg,
msg               572 daemons/based/based_remote.c         switch (msg[count]->msg_style) {
msg               574 daemons/based/based_remote.c                 crm_info("PAM: %s", msg[count]->msg);
msg               587 daemons/based/based_remote.c                 crm_err("Unhandled conversation type: %d", msg[count]->msg_style);
msg               600 daemons/based/based_remote.c             switch (msg[count]->msg_style) {
msg               239 daemons/based/pacemaker-based.c                  uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len)
msg               244 daemons/based/pacemaker-based.c     char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from);
msg                82 daemons/based/pacemaker-based.h void cib_peer_callback(xmlNode *msg, void *private_data);
msg               136 daemons/based/pacemaker-based.h xmlNode *cib_msg_copy(xmlNode *msg, gboolean with_data);
msg                24 daemons/controld/controld_based.c do_cib_updated(const char *event, xmlNode * msg)
msg                26 daemons/controld/controld_based.c     if (pcmk__alert_in_patchset(msg, TRUE)) {
msg                32 daemons/controld/controld_based.c do_cib_replaced(const char *event, xmlNode * msg)
msg               171 daemons/controld/controld_based.c cib_delete_callback(xmlNode *msg, int call_id, int rc, xmlNode *output,
msg                27 daemons/controld/controld_callbacks.c crmd_ha_msg_filter(xmlNode * msg)
msg                30 daemons/controld/controld_callbacks.c         const char *sys_from = crm_element_value(msg, F_CRM_SYS_FROM);
msg                33 daemons/controld/controld_callbacks.c             const char *from = crm_element_value(msg, F_ORIG);
msg                37 daemons/controld/controld_callbacks.c                 const char *op = crm_element_value(msg, F_CRM_TASK);
msg                44 daemons/controld/controld_callbacks.c                     new_input.msg = msg;
msg                55 daemons/controld/controld_callbacks.c         const char *sys_to = crm_element_value(msg, F_CRM_SYS_TO);
msg                63 daemons/controld/controld_callbacks.c     route_message(C_HA_MESSAGE, msg);
msg                15 daemons/controld/controld_callbacks.h extern void crmd_ha_msg_filter(xmlNode * msg);
msg               116 daemons/controld/controld_control.c     xmlNode *msg = NULL;
msg               122 daemons/controld/controld_control.c     msg = create_request(CRM_OP_SHUTDOWN_REQ, NULL, NULL, CRM_SYSTEM_CRMD, CRM_SYSTEM_CRMD, NULL);
msg               124 daemons/controld/controld_control.c     if (send_cluster_message(NULL, crm_msg_crmd, msg, TRUE) == FALSE) {
msg               127 daemons/controld/controld_control.c     free_xml(msg);
msg               379 daemons/controld/controld_control.c     xmlNode *msg = pcmk__client_data2xml(client, data, &id, &flags);
msg               381 daemons/controld/controld_control.c     if (msg == NULL) {
msg               388 daemons/controld/controld_control.c     pcmk__update_acl_user(msg, F_CRM_USER, client->user);
msg               390 daemons/controld/controld_control.c     crm_xml_add(msg, F_CRM_SYS_FROM, client->id);
msg               391 daemons/controld/controld_control.c     if (controld_authorize_ipc_message(msg, client, NULL)) {
msg               394 daemons/controld/controld_control.c         route_message(C_IPC_MESSAGE, msg);
msg               398 daemons/controld/controld_control.c     free_xml(msg);
msg               681 daemons/controld/controld_control.c config_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg                30 daemons/controld/controld_corosync.c                  uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len)
msg                34 daemons/controld/controld_corosync.c     char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from);
msg               147 daemons/controld/controld_election.c     rc = election_count_vote(fsa_election, vote->msg, cur_state != S_STARTING);
msg               172 daemons/controld/controld_election.c feature_update_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg                43 daemons/controld/controld_execd.c                           const char *operation, xmlNode *msg);
msg               906 daemons/controld/controld_execd.c     const char *from_sys = crm_element_value(input->msg, F_CRM_SYS_FROM);
msg               907 daemons/controld/controld_execd.c     const char *from_host = crm_element_value(input->msg, F_CRM_HOST_FROM);
msg              1332 daemons/controld/controld_execd.c             char *ref = crm_element_value_copy(request->msg, XML_ATTR_REFERENCE);
msg              1573 daemons/controld/controld_execd.c handle_query_op(xmlNode *msg, lrm_state_t *lrm_state)
msg              1576 daemons/controld/controld_execd.c     xmlNode *reply = create_reply(msg, data);
msg              1756 daemons/controld/controld_execd.c     user_name = pcmk__update_acl_user(input->msg, F_CRM_USER, NULL);
msg              1757 daemons/controld/controld_execd.c     crm_op = crm_element_value(input->msg, F_CRM_TASK);
msg              1758 daemons/controld/controld_execd.c     from_sys = crm_element_value(input->msg, F_CRM_SYS_FROM);
msg              1760 daemons/controld/controld_execd.c         from_host = crm_element_value(input->msg, F_CRM_HOST_FROM);
msg              1784 daemons/controld/controld_execd.c         handle_query_op(input->msg, lrm_state);
msg              1827 daemons/controld/controld_execd.c             crm_log_xml_warn(input->msg, "invalid resource");
msg              1837 daemons/controld/controld_execd.c             crm_log_xml_warn(input->msg, "failed registration");
msg              2222 daemons/controld/controld_execd.c               const char *operation, xmlNode *msg)
msg              2236 daemons/controld/controld_execd.c     if (msg != NULL) {
msg              2237 daemons/controld/controld_execd.c         transition = crm_element_value(msg, XML_ATTR_TRANSITION_KEY);
msg              2239 daemons/controld/controld_execd.c             crm_log_xml_err(msg, "Missing transition number");
msg              2243 daemons/controld/controld_execd.c     op = construct_op(lrm_state, msg, rsc->id, operation);
msg              2363 daemons/controld/controld_execd.c         if (crm_element_value_epoch(msg, XML_CONFIG_ATTR_SHUTDOWN_LOCK,
msg              2392 daemons/controld/controld_execd.c cib_rsc_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg                23 daemons/controld/controld_execd_state.c int lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg);
msg                24 daemons/controld/controld_execd_state.c void lrmd_internal_set_proxy_callback(lrmd_t * lrmd, void *userdata, void (*callback)(lrmd_t *lrmd, void *userdata, xmlNode *msg));
msg               407 daemons/controld/controld_execd_state.c crmd_proxy_send(const char *session, xmlNode *msg)
msg               415 daemons/controld/controld_execd_state.c     crm_log_xml_trace(msg, "to-proxy");
msg               419 daemons/controld/controld_execd_state.c         remote_proxy_relay_event(proxy, msg);
msg               424 daemons/controld/controld_execd_state.c crmd_proxy_dispatch(const char *session, xmlNode *msg)
msg               427 daemons/controld/controld_execd_state.c     crm_log_xml_trace(msg, "controller[inbound]");
msg               428 daemons/controld/controld_execd_state.c     crm_xml_add(msg, F_CRM_SYS_FROM, session);
msg               429 daemons/controld/controld_execd_state.c     if (controld_authorize_ipc_message(msg, NULL, session)) {
msg               430 daemons/controld/controld_execd_state.c         route_message(C_IPC_MESSAGE, msg);
msg               436 daemons/controld/controld_execd_state.c remote_config_check(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               464 daemons/controld/controld_execd_state.c crmd_remote_proxy_cb(lrmd_t *lrmd, void *userdata, xmlNode *msg)
msg               467 daemons/controld/controld_execd_state.c     const char *session = crm_element_value(msg, F_LRMD_IPC_SESSION);
msg               470 daemons/controld/controld_execd_state.c     const char *op = crm_element_value(msg, F_LRMD_IPC_OP);
msg               472 daemons/controld/controld_execd_state.c         const char *channel = crm_element_value(msg, F_LRMD_IPC_IPC_SERVER);
msg               514 daemons/controld/controld_execd_state.c         xmlNode *request = get_message_xml(msg, F_LRMD_IPC_MSG);
msg               538 daemons/controld/controld_execd_state.c         crm_element_value_int(msg, F_LRMD_IPC_MSG_FLAGS, &flags);
msg               546 daemons/controld/controld_execd_state.c             crm_element_value_int(msg, F_LRMD_IPC_MSG_ID, &msg_id);
msg               553 daemons/controld/controld_execd_state.c         remote_proxy_cb(lrmd, lrm_state->node_name, msg);
msg               156 daemons/controld/controld_fencing.c cib_fencing_updated(xmlNode *msg, int call_id, int rc, xmlNode *output,
msg               162 daemons/controld/controld_fencing.c         crm_log_xml_warn(msg, "Failed update");
msg               140 daemons/controld/controld_fsa.c         crm_log_xml_debug(input->msg, __func__);
msg                20 daemons/controld/controld_join_client.c void join_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data);
msg                35 daemons/controld/controld_join_client.c update_dc_expected(xmlNode *msg)
msg                37 daemons/controld/controld_join_client.c     if (fsa_our_dc && crm_is_true(crm_element_value(msg, F_CRM_DC_LEAVING))) {
msg               122 daemons/controld/controld_join_client.c     welcome_from = crm_element_value(input->msg, F_CRM_HOST_FROM);
msg               123 daemons/controld/controld_join_client.c     join_id = crm_element_value(input->msg, F_CRM_JOIN_ID);
msg               125 daemons/controld/controld_join_client.c               welcome_from, crm_element_value(input->msg, F_CRM_JOIN_ID));
msg               134 daemons/controld/controld_join_client.c     if (update_dc(input->msg) == FALSE) {
msg               140 daemons/controld/controld_join_client.c     update_dc_expected(input->msg);
msg               152 daemons/controld/controld_join_client.c join_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               231 daemons/controld/controld_join_client.c     const char *op = crm_element_value(input->msg, F_CRM_TASK);
msg               232 daemons/controld/controld_join_client.c     const char *ack_nack = crm_element_value(input->msg, CRM_OP_JOIN_ACKNAK);
msg               233 daemons/controld/controld_join_client.c     const char *welcome_from = crm_element_value(input->msg, F_CRM_HOST_FROM);
msg               245 daemons/controld/controld_join_client.c     crm_element_value_int(input->msg, F_CRM_JOIN_ID, &join_id);
msg               259 daemons/controld/controld_join_client.c     if (update_dc(input->msg) == FALSE) {
msg               265 daemons/controld/controld_join_client.c     update_dc_expected(input->msg);
msg                25 daemons/controld/controld_join_dc.c void finalize_sync_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data);
msg               103 daemons/controld/controld_join_dc.c     xmlNode *msg = create_request(join_op, NULL, host_to, CRM_SYSTEM_CRMD,
msg               107 daemons/controld/controld_join_dc.c     crm_xml_add_int(msg, F_CRM_JOIN_ID, current_join_id);
msg               112 daemons/controld/controld_join_dc.c     crm_xml_add_boolean(msg, F_CRM_DC_LEAVING,
msg               114 daemons/controld/controld_join_dc.c     return msg;
msg               232 daemons/controld/controld_join_dc.c     join_to = crm_element_value(welcome->msg, F_CRM_HOST_FROM);
msg               304 daemons/controld/controld_join_dc.c     const char *join_from = crm_element_value(join_ack->msg, F_CRM_HOST_FROM);
msg               305 daemons/controld/controld_join_dc.c     const char *ref = crm_element_value(join_ack->msg, F_CRM_REFERENCE);
msg               306 daemons/controld/controld_join_dc.c     const char *join_version = crm_element_value(join_ack->msg,
msg               316 daemons/controld/controld_join_dc.c     crm_element_value_int(join_ack->msg, F_CRM_JOIN_ID, &join_id);
msg               475 daemons/controld/controld_join_dc.c finalize_sync_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               512 daemons/controld/controld_join_dc.c join_update_complete_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               525 daemons/controld/controld_join_dc.c         crm_log_xml_debug(msg, "failed");
msg               542 daemons/controld/controld_join_dc.c     const char *op = crm_element_value(join_ack->msg, F_CRM_TASK);
msg               543 daemons/controld/controld_join_dc.c     const char *join_from = crm_element_value(join_ack->msg, F_CRM_HOST_FROM);
msg               562 daemons/controld/controld_join_dc.c     if (crm_element_value_int(join_ack->msg, F_CRM_JOIN_ID, &join_id) != 0) {
msg                94 daemons/controld/controld_membership.c crmd_node_update_complete(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               105 daemons/controld/controld_membership.c         crm_log_xml_debug(msg, "failed");
msg               110 daemons/controld/controld_membership.c         crm_log_xml_debug(msg, "failed");
msg               188 daemons/controld/controld_membership.c remove_conflicting_node_callback(xmlNode * msg, int call_id, int rc,
msg               199 daemons/controld/controld_membership.c search_conflicting_node_callback(xmlNode * msg, int call_id, int rc,
msg               279 daemons/controld/controld_membership.c node_list_update_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               285 daemons/controld/controld_membership.c         crm_log_xml_debug(msg, "update:failed");
msg               290 daemons/controld/controld_membership.c         crm_log_xml_debug(msg, "update:failed");
msg               380 daemons/controld/controld_membership.c cib_quorum_update_complete(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               389 daemons/controld/controld_membership.c         crm_log_xml_debug(msg, "failed");
msg                28 daemons/controld/controld_messages.c static enum crmd_fsa_input handle_message(xmlNode *msg,
msg                34 daemons/controld/controld_messages.c static void send_msg_via_ipc(xmlNode * msg, const char *sys);
msg               124 daemons/controld/controld_messages.c                 CRM_CHECK(((ha_msg_input_t *) data)->msg != NULL,
msg               196 daemons/controld/controld_messages.c     copy->msg = (orig && orig->msg)? copy_xml(orig->msg) : NULL;
msg               197 daemons/controld/controld_messages.c     copy->xml = get_message_xml(copy->msg, F_CRM_DATA);
msg               284 daemons/controld/controld_messages.c     route_message(msg_data->fsa_cause, input->msg);
msg               293 daemons/controld/controld_messages.c     fsa_input.msg = input;
msg               326 daemons/controld/controld_messages.c relay_message(xmlNode * msg, gboolean originated_locally)
msg               335 daemons/controld/controld_messages.c     const char *host_to = crm_element_value(msg, F_CRM_HOST_TO);
msg               336 daemons/controld/controld_messages.c     const char *sys_to = crm_element_value(msg, F_CRM_SYS_TO);
msg               337 daemons/controld/controld_messages.c     const char *sys_from = crm_element_value(msg, F_CRM_SYS_FROM);
msg               338 daemons/controld/controld_messages.c     const char *type = crm_element_value(msg, F_TYPE);
msg               339 daemons/controld/controld_messages.c     const char *task = crm_element_value(msg, F_CRM_TASK);
msg               340 daemons/controld/controld_messages.c     const char *ref = crm_element_value(msg, XML_ATTR_REFERENCE);
msg               346 daemons/controld/controld_messages.c     if (msg == NULL) {
msg               358 daemons/controld/controld_messages.c         crm_log_xml_warn(msg, "[bad message type]");
msg               363 daemons/controld/controld_messages.c         crm_log_xml_warn(msg, "[no subsystem]");
msg               398 daemons/controld/controld_messages.c         xmlNode *msg_data = get_message_xml(msg, F_CRM_DATA);
msg               410 daemons/controld/controld_messages.c             send_msg_via_ipc(msg, sys_to);
msg               425 daemons/controld/controld_messages.c             send_cluster_message(host_to ? crm_get_peer(0, host_to) : NULL, dest, msg, TRUE);
msg               442 daemons/controld/controld_messages.c         crm_log_xml_trace(msg, "[IPC relay]");
msg               443 daemons/controld/controld_messages.c         send_msg_via_ipc(msg, sys_to);
msg               470 daemons/controld/controld_messages.c         send_cluster_message(host_to ? node_to : NULL, dest, msg, TRUE);
msg               564 daemons/controld/controld_messages.c handle_message(xmlNode *msg, enum crmd_fsa_cause cause)
msg               568 daemons/controld/controld_messages.c     CRM_CHECK(msg != NULL, return I_NULL);
msg               570 daemons/controld/controld_messages.c     type = crm_element_value(msg, F_CRM_MSG_TYPE);
msg               572 daemons/controld/controld_messages.c         return handle_request(msg, cause);
msg               575 daemons/controld/controld_messages.c         handle_response(msg);
msg               722 daemons/controld/controld_messages.c handle_remote_state(xmlNode *msg)
msg               724 daemons/controld/controld_messages.c     const char *remote_uname = ID(msg);
msg               725 daemons/controld/controld_messages.c     const char *remote_is_up = crm_element_value(msg, XML_NODE_IN_CLUSTER);
msg               747 daemons/controld/controld_messages.c handle_ping(xmlNode *msg)
msg               755 daemons/controld/controld_messages.c     value = crm_element_value(msg, F_CRM_SYS_TO);
msg               768 daemons/controld/controld_messages.c     msg = create_reply(msg, ping);
msg               770 daemons/controld/controld_messages.c     if (msg) {
msg               771 daemons/controld/controld_messages.c         (void) relay_message(msg, TRUE);
msg               772 daemons/controld/controld_messages.c         free_xml(msg);
msg               823 daemons/controld/controld_messages.c handle_node_info_request(xmlNode *msg)
msg               839 daemons/controld/controld_messages.c     crm_element_value_int(msg, XML_ATTR_ID, &node_id);
msg               843 daemons/controld/controld_messages.c     value = crm_element_value(msg, XML_ATTR_UNAME);
msg               861 daemons/controld/controld_messages.c     msg = create_reply(msg, reply);
msg               863 daemons/controld/controld_messages.c     if (msg) {
msg               864 daemons/controld/controld_messages.c         (void) relay_message(msg, TRUE);
msg               865 daemons/controld/controld_messages.c         free_xml(msg);
msg               873 daemons/controld/controld_messages.c verify_feature_set(xmlNode *msg)
msg               875 daemons/controld/controld_messages.c     const char *dc_version = crm_element_value(msg, XML_ATTR_CRM_VERSION);
msg               962 daemons/controld/controld_messages.c     xmlNode *msg = NULL;
msg              1010 daemons/controld/controld_messages.c         fsa_input.msg = stored_msg;
msg              1032 daemons/controld/controld_messages.c         fsa_input.msg = stored_msg;
msg              1090 daemons/controld/controld_messages.c             msg = create_request(CRM_OP_RM_NODE_CACHE, NULL, NULL, CRM_SYSTEM_CRMD, CRM_SYSTEM_CRMD, NULL);
msg              1091 daemons/controld/controld_messages.c             if (send_cluster_message(NULL, crm_msg_crmd, msg, TRUE) == FALSE) {
msg              1096 daemons/controld/controld_messages.c             free_xml(msg);
msg              1150 daemons/controld/controld_messages.c             fsa_input.msg = stored_msg;
msg              1198 daemons/controld/controld_messages.c extern gboolean process_te_message(xmlNode * msg, xmlNode * xml_data);
msg              1201 daemons/controld/controld_messages.c send_msg_via_ipc(xmlNode * msg, const char *sys)
msg              1205 daemons/controld/controld_messages.c     if (crm_element_value(msg, F_CRM_HOST_FROM) == NULL) {
msg              1206 daemons/controld/controld_messages.c         crm_xml_add(msg, F_CRM_HOST_FROM, fsa_our_uname);
msg              1211 daemons/controld/controld_messages.c         pcmk__ipc_send_xml(client_channel, 0, msg, crm_ipc_server_event);
msg              1214 daemons/controld/controld_messages.c         xmlNode *data = get_message_xml(msg, F_CRM_DATA);
msg              1216 daemons/controld/controld_messages.c         process_te_message(msg, data);
msg              1222 daemons/controld/controld_messages.c         fsa_input.msg = msg;
msg              1223 daemons/controld/controld_messages.c         fsa_input.xml = get_message_xml(msg, F_CRM_DATA);
msg              1236 daemons/controld/controld_messages.c         crmd_proxy_send(sys, msg);
msg              1249 daemons/controld/controld_messages.c     free_xml(orig->msg);
msg              1268 daemons/controld/controld_messages.c         xmlNode *msg = create_request(CRM_OP_REMOTE_STATE, NULL, fsa_our_dc,
msg              1273 daemons/controld/controld_messages.c         crm_xml_add(msg, XML_ATTR_ID, node_name);
msg              1274 daemons/controld/controld_messages.c         crm_xml_add_boolean(msg, XML_NODE_IN_CLUSTER, node_up);
msg              1275 daemons/controld/controld_messages.c         send_cluster_message(crm_get_peer(0, fsa_our_dc), crm_msg_crmd, msg,
msg              1277 daemons/controld/controld_messages.c         free_xml(msg);
msg                20 daemons/controld/controld_messages.h     xmlNode *msg;
msg                74 daemons/controld/controld_messages.h void crmd_proxy_send(const char *session, xmlNode *msg);
msg                80 daemons/controld/controld_messages.h extern gboolean send_request(xmlNode * msg, char **msg_reference);
msg                54 daemons/controld/controld_schedulerd.c save_cib_contents(xmlNode *msg, int call_id, int rc, xmlNode *output,
msg               131 daemons/controld/controld_schedulerd.c     xmlNode *msg = string2xml(buffer);
msg               133 daemons/controld/controld_schedulerd.c     if (msg) {
msg               134 daemons/controld/controld_schedulerd.c         route_message(C_IPC_MESSAGE, msg);
msg               136 daemons/controld/controld_schedulerd.c     free_xml(msg);
msg               201 daemons/controld/controld_schedulerd.c static void do_pe_invoke_callback(xmlNode *msg, int call_id, int rc,
msg               276 daemons/controld/controld_schedulerd.c controld_expect_sched_reply(xmlNode *msg)
msg               280 daemons/controld/controld_schedulerd.c     if (msg) {
msg               281 daemons/controld/controld_schedulerd.c         ref = crm_element_value_copy(msg, XML_ATTR_REFERENCE);
msg               418 daemons/controld/controld_schedulerd.c do_pe_invoke_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               330 daemons/controld/controld_te_actions.c             .msg = cmd,
msg               334 daemons/controld/controld_te_actions.c         fsa_data_t msg = {
msg               344 daemons/controld/controld_te_actions.c         do_lrm_invoke(A_LRM_INVOKE, C_FSA_INTERNAL, fsa_state, I_NULL, &msg);
msg                22 daemons/controld/controld_te_callbacks.c void te_update_confirm(const char *event, xmlNode * msg);
msg               532 daemons/controld/controld_te_callbacks.c te_update_diff(const char *event, xmlNode * msg)
msg               541 daemons/controld/controld_te_callbacks.c     CRM_CHECK(msg != NULL, return);
msg               542 daemons/controld/controld_te_callbacks.c     crm_element_value_int(msg, F_CIB_RC, &rc);
msg               561 daemons/controld/controld_te_callbacks.c     op = crm_element_value(msg, F_CIB_OPERATION);
msg               562 daemons/controld/controld_te_callbacks.c     diff = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg               584 daemons/controld/controld_te_callbacks.c process_te_message(xmlNode * msg, xmlNode * xml_data)
msg               586 daemons/controld/controld_te_callbacks.c     const char *from = crm_element_value(msg, F_ORIG);
msg               587 daemons/controld/controld_te_callbacks.c     const char *sys_to = crm_element_value(msg, F_CRM_SYS_TO);
msg               588 daemons/controld/controld_te_callbacks.c     const char *sys_from = crm_element_value(msg, F_CRM_SYS_FROM);
msg               589 daemons/controld/controld_te_callbacks.c     const char *ref = crm_element_value(msg, F_CRM_REFERENCE);
msg               590 daemons/controld/controld_te_callbacks.c     const char *op = crm_element_value(msg, F_CRM_TASK);
msg               591 daemons/controld/controld_te_callbacks.c     const char *type = crm_element_value(msg, F_CRM_MSG_TYPE);
msg               594 daemons/controld/controld_te_callbacks.c     crm_log_xml_trace(msg, "ipc");
msg               609 daemons/controld/controld_te_callbacks.c         crm_log_xml_trace(msg, "Processing (N)ACK");
msg               610 daemons/controld/controld_te_callbacks.c         crm_debug("Processing (N)ACK %s from %s", crm_element_value(msg, F_CRM_REFERENCE), from);
msg               625 daemons/controld/controld_te_callbacks.c             crm_log_xml_err(msg, "Invalid (N)ACK");
msg               640 daemons/controld/controld_te_callbacks.c cib_action_updated(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg                21 daemons/controld/controld_transition.c global_cib_callback(const xmlNode * msg, int callid, int rc, xmlNode * output)
msg               145 daemons/controld/controld_transition.c         const char *ref = crm_element_value(input->msg, XML_ATTR_REFERENCE);
msg               146 daemons/controld/controld_transition.c         const char *graph_file = crm_element_value(input->msg, F_CRM_TGRAPH);
msg               147 daemons/controld/controld_transition.c         const char *graph_input = crm_element_value(input->msg, F_CRM_TGRAPH_INPUT);
msg               150 daemons/controld/controld_transition.c             crm_log_xml_err(input->msg, "Bad command");
msg               179 daemons/controld/controld_transition.c                   crm_log_xml_err(input->msg, "Bad command");
msg                31 daemons/controld/controld_transition.h extern gboolean process_te_message(xmlNode * msg, xmlNode * xml_data);
msg                40 daemons/controld/controld_transition.h void cib_action_updated(xmlNode *msg, int call_id, int rc, xmlNode *output,
msg                44 daemons/controld/controld_transition.h void te_update_diff(const char *event, xmlNode *msg);
msg               691 daemons/controld/controld_utils.c update_dc(xmlNode * msg)
msg               697 daemons/controld/controld_utils.c     if (msg != NULL) {
msg               700 daemons/controld/controld_utils.c         dc_version = crm_element_value(msg, F_CRM_VERSION);
msg               701 daemons/controld/controld_utils.c         welcome_from = crm_element_value(msg, F_CRM_HOST_FROM);
msg                74 daemons/controld/controld_utils.h void controld_expect_sched_reply(xmlNode *msg);
msg                79 daemons/controld/controld_utils.h gboolean update_dc(xmlNode * msg);
msg                32 daemons/controld/pacemaker-controld.c void crmd_hamsg_callback(const xmlNode * msg, void *private_data);
msg                29 daemons/controld/pacemaker-controld.h void do_cib_updated(const char *event, xmlNode * msg);
msg                30 daemons/controld/pacemaker-controld.h void do_cib_replaced(const char *event, xmlNode * msg);
msg               254 daemons/execd/execd_commands.c build_rsc_from_xml(xmlNode * msg)
msg               256 daemons/execd/execd_commands.c     xmlNode *rsc_xml = get_xpath_object("//" F_LRMD_RSC, msg, LOG_ERR);
msg               261 daemons/execd/execd_commands.c     crm_element_value_int(msg, F_LRMD_CALLOPTS, &rsc->call_opts);
msg               273 daemons/execd/execd_commands.c create_lrmd_cmd(xmlNode *msg, pcmk__client_t *client)
msg               276 daemons/execd/execd_commands.c     xmlNode *rsc_xml = get_xpath_object("//" F_LRMD_RSC, msg, LOG_ERR);
msg               281 daemons/execd/execd_commands.c     crm_element_value_int(msg, F_LRMD_CALLOPTS, &call_options);
msg               285 daemons/execd/execd_commands.c     crm_element_value_int(msg, F_LRMD_CALLID, &cmd->call_id);
msg               526 daemons/execd/execd_commands.c     const char *msg = NULL;
msg               552 daemons/execd/execd_commands.c             msg = "Disconnected";
msg               556 daemons/execd/execd_commands.c             msg = pcmk_rc_str(rc);
msg               560 daemons/execd/execd_commands.c                pcmk__client_name(client), msg, rc);
msg               225 daemons/execd/pacemaker-execd.c lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg)
msg               234 daemons/execd/pacemaker-execd.c             return pcmk__ipc_send_xml(client, 0, msg, crm_ipc_server_event);
msg               241 daemons/execd/pacemaker-execd.c                 return lrmd__remote_send_xml(client->remote, msg, 0, "notify");
msg                58 daemons/execd/pacemaker-execd.h int lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg);
msg                71 daemons/execd/remoted_proxy.c     xmlNode *msg;
msg                99 daemons/execd/remoted_proxy.c     msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg               100 daemons/execd/remoted_proxy.c     crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_NEW);
msg               101 daemons/execd/remoted_proxy.c     crm_xml_add(msg, F_LRMD_IPC_IPC_SERVER, ipc_channel);
msg               102 daemons/execd/remoted_proxy.c     crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id);
msg               103 daemons/execd/remoted_proxy.c     lrmd_server_send_notify(ipc_proxy, msg);
msg               104 daemons/execd/remoted_proxy.c     free_xml(msg);
msg               152 daemons/execd/remoted_proxy.c     xmlNode *msg = get_message_xml(xml, F_LRMD_IPC_MSG);
msg               172 daemons/execd/remoted_proxy.c         xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg               173 daemons/execd/remoted_proxy.c         crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_DESTROY);
msg               174 daemons/execd/remoted_proxy.c         crm_xml_add(msg, F_LRMD_IPC_SESSION, session);
msg               175 daemons/execd/remoted_proxy.c         lrmd_server_send_notify(ipc_proxy, msg);
msg               176 daemons/execd/remoted_proxy.c         free_xml(msg);
msg               196 daemons/execd/remoted_proxy.c         rc = pcmk__ipc_send_xml(ipc_client, 0, msg, crm_ipc_server_event);
msg               203 daemons/execd/remoted_proxy.c         rc = pcmk__ipc_send_xml(ipc_client, msg_id, msg, FALSE);
msg               229 daemons/execd/remoted_proxy.c     xmlNode *msg = NULL;
msg               266 daemons/execd/remoted_proxy.c     msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg               267 daemons/execd/remoted_proxy.c     crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_REQUEST);
msg               268 daemons/execd/remoted_proxy.c     crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id);
msg               269 daemons/execd/remoted_proxy.c     crm_xml_add(msg, F_LRMD_IPC_CLIENT, pcmk__client_name(client));
msg               270 daemons/execd/remoted_proxy.c     crm_xml_add(msg, F_LRMD_IPC_USER, client->user);
msg               271 daemons/execd/remoted_proxy.c     crm_xml_add_int(msg, F_LRMD_IPC_MSG_ID, id);
msg               272 daemons/execd/remoted_proxy.c     crm_xml_add_int(msg, F_LRMD_IPC_MSG_FLAGS, flags);
msg               273 daemons/execd/remoted_proxy.c     add_message_xml(msg, F_LRMD_IPC_MSG, request);
msg               274 daemons/execd/remoted_proxy.c     lrmd_server_send_notify(ipc_proxy, msg);
msg               276 daemons/execd/remoted_proxy.c     free_xml(msg);
msg               290 daemons/execd/remoted_proxy.c     xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg               293 daemons/execd/remoted_proxy.c     crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_SHUTDOWN_REQ);
msg               298 daemons/execd/remoted_proxy.c     crm_xml_add(msg, F_LRMD_IPC_SESSION, "0");
msg               300 daemons/execd/remoted_proxy.c     rc = (lrmd_server_send_notify(ipc_proxy, msg) != pcmk_rc_ok)? -1 : 0;
msg               301 daemons/execd/remoted_proxy.c     free_xml(msg);
msg               320 daemons/execd/remoted_proxy.c         xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg               321 daemons/execd/remoted_proxy.c         crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_DESTROY);
msg               322 daemons/execd/remoted_proxy.c         crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id);
msg               323 daemons/execd/remoted_proxy.c         lrmd_server_send_notify(ipc_proxy, msg);
msg               324 daemons/execd/remoted_proxy.c         free_xml(msg);
msg               232 daemons/fenced/fenced_commands.c create_async_command(xmlNode * msg)
msg               235 daemons/fenced/fenced_commands.c     xmlNode *op = get_xpath_object("//@" F_STONITH_ACTION, msg, LOG_ERR);
msg               238 daemons/fenced/fenced_commands.c     CRM_CHECK(action != NULL, crm_log_xml_warn(msg, "NoAction"); return NULL);
msg               240 daemons/fenced/fenced_commands.c     crm_log_xml_trace(msg, "Command");
msg               242 daemons/fenced/fenced_commands.c     crm_element_value_int(msg, F_STONITH_CALLID, &(cmd->id));
msg               243 daemons/fenced/fenced_commands.c     crm_element_value_int(msg, F_STONITH_CALLOPTS, &(cmd->options));
msg               244 daemons/fenced/fenced_commands.c     crm_element_value_int(msg, F_STONITH_TIMEOUT, &(cmd->default_timeout));
msg               247 daemons/fenced/fenced_commands.c     crm_element_value_int(msg, F_STONITH_DELAY, &(cmd->start_delay));
msg               249 daemons/fenced/fenced_commands.c     cmd->origin = crm_element_value_copy(msg, F_ORIG);
msg               250 daemons/fenced/fenced_commands.c     cmd->remote_op_id = crm_element_value_copy(msg, F_STONITH_REMOTE_OP_ID);
msg               251 daemons/fenced/fenced_commands.c     cmd->client = crm_element_value_copy(msg, F_STONITH_CLIENTID);
msg               252 daemons/fenced/fenced_commands.c     cmd->client_name = crm_element_value_copy(msg, F_STONITH_CLIENTNAME);
msg               253 daemons/fenced/fenced_commands.c     cmd->op = crm_element_value_copy(msg, F_STONITH_OPERATION);
msg               258 daemons/fenced/fenced_commands.c     CRM_CHECK(cmd->op != NULL, crm_log_xml_warn(msg, "NoOp"); free_async_command(cmd); return NULL);
msg               259 daemons/fenced/fenced_commands.c     CRM_CHECK(cmd->client != NULL, crm_log_xml_warn(msg, "NoClient"));
msg               908 daemons/fenced/fenced_commands.c build_device_from_xml(xmlNode * msg)
msg               911 daemons/fenced/fenced_commands.c     xmlNode *dev = get_xpath_object("//" F_STONITH_DEVICE, msg, LOG_ERR);
msg              1189 daemons/fenced/fenced_commands.c stonith_device_register(xmlNode * msg, const char **desc, gboolean from_cib)
msg              1192 daemons/fenced/fenced_commands.c     stonith_device_t *device = build_device_from_xml(msg);
msg              1428 daemons/fenced/fenced_commands.c stonith_level_register(xmlNode *msg, char **desc)
msg              1443 daemons/fenced/fenced_commands.c     if (pcmk__str_eq(TYPE(msg), XML_TAG_FENCING_LEVEL, pcmk__str_casei)) {
msg              1444 daemons/fenced/fenced_commands.c         level = msg;
msg              1446 daemons/fenced/fenced_commands.c         level = get_xpath_object("//" XML_TAG_FENCING_LEVEL, msg, LOG_ERR);
msg              1507 daemons/fenced/fenced_commands.c stonith_level_remove(xmlNode *msg, char **desc)
msg              1514 daemons/fenced/fenced_commands.c     xmlNode *level = get_xpath_object("//" XML_TAG_FENCING_LEVEL, msg, LOG_ERR);
msg              1578 daemons/fenced/fenced_commands.c stonith_device_action(xmlNode * msg, char **output)
msg              1580 daemons/fenced/fenced_commands.c     xmlNode *dev = get_xpath_object("//" F_STONITH_DEVICE, msg, LOG_ERR);
msg              1581 daemons/fenced/fenced_commands.c     xmlNode *op = get_xpath_object("//@" F_STONITH_ACTION, msg, LOG_ERR);
msg              1604 daemons/fenced/fenced_commands.c     cmd = create_async_command(msg);
msg              2053 daemons/fenced/fenced_commands.c stonith_query(xmlNode * msg, const char *remote_peer, const char *client_id, int call_options)
msg              2059 daemons/fenced/fenced_commands.c     xmlNode *dev = get_xpath_object("//@" F_STONITH_ACTION, msg, LOG_NEVER);
msg              2061 daemons/fenced/fenced_commands.c     crm_element_value_int(msg, F_STONITH_TIMEOUT, &timeout);
msg              2073 daemons/fenced/fenced_commands.c     crm_log_xml_debug(msg, "Query");
msg              2076 daemons/fenced/fenced_commands.c     query->reply = stonith_construct_reply(msg, NULL, NULL, pcmk_ok);
msg              2372 daemons/fenced/fenced_commands.c stonith_fence(xmlNode * msg)
msg              2376 daemons/fenced/fenced_commands.c     async_command_t *cmd = create_async_command(msg);
msg              2377 daemons/fenced/fenced_commands.c     xmlNode *dev = get_xpath_object("//@" F_STONITH_TARGET, msg, LOG_ERR);
msg               432 daemons/fenced/fenced_history.c stonith_fence_history(xmlNode *msg, xmlNode **output,
msg               437 daemons/fenced/fenced_history.c     xmlNode *dev = get_xpath_object("//@" F_STONITH_TARGET, msg, LOG_NEVER);
msg               459 daemons/fenced/fenced_history.c             crm_element_value(msg, F_STONITH_CALLID) != NULL);
msg               466 daemons/fenced/fenced_history.c         if (crm_element_value(msg, F_STONITH_CALLID)) {
msg               481 daemons/fenced/fenced_history.c                                                 msg, LOG_NEVER);
msg               974 daemons/fenced/fenced_remote.c stonith_manual_ack(xmlNode * msg, remote_fencing_op_t * op)
msg               976 daemons/fenced/fenced_remote.c     xmlNode *dev = get_xpath_object("//@" F_STONITH_TARGET, msg, LOG_ERR);
msg               985 daemons/fenced/fenced_remote.c     remote_op_done(op, msg, pcmk_ok, FALSE);
msg              1477 daemons/fenced/fenced_remote.c                                  xmlNode *msg, int rc)
msg              1521 daemons/fenced/fenced_remote.c         remote_op_done(op, msg, rc, FALSE);
msg              1914 daemons/fenced/fenced_remote.c process_remote_stonith_query(xmlNode * msg)
msg              1924 daemons/fenced/fenced_remote.c     xmlNode *dev = get_xpath_object("//@" F_STONITH_REMOTE_OP_ID, msg, LOG_ERR);
msg              1931 daemons/fenced/fenced_remote.c     dev = get_xpath_object("//@" F_STONITH_AVAILABLE_DEVICES, msg, LOG_ERR);
msg              1949 daemons/fenced/fenced_remote.c     host = crm_element_value(msg, F_ORIG);
msg              2016 daemons/fenced/fenced_remote.c process_remote_stonith_exec(xmlNode * msg)
msg              2022 daemons/fenced/fenced_remote.c     xmlNode *dev = get_xpath_object("//@" F_STONITH_REMOTE_OP_ID, msg, LOG_ERR);
msg              2029 daemons/fenced/fenced_remote.c     dev = get_xpath_object("//@" F_STONITH_RC, msg, LOG_ERR);
msg              2061 daemons/fenced/fenced_remote.c     if (pcmk__str_eq(crm_element_value(msg, F_SUBTYPE), "broadcast", pcmk__str_casei)) {
msg              2071 daemons/fenced/fenced_remote.c         remote_op_done(op, msg, rc, FALSE);
msg              2083 daemons/fenced/fenced_remote.c         const char *device = crm_element_value(msg, F_STONITH_DEVICE);
msg              2093 daemons/fenced/fenced_remote.c             remote_op_done(op, msg, rc, FALSE);
msg              2109 daemons/fenced/fenced_remote.c             advance_topology_device_in_level(op, device, msg, rc);
msg              2116 daemons/fenced/fenced_remote.c                 remote_op_done(op, msg, rc, FALSE);
msg              2124 daemons/fenced/fenced_remote.c         remote_op_done(op, msg, rc, FALSE);
msg              2129 daemons/fenced/fenced_remote.c         remote_op_done(op, msg, rc, FALSE);
msg               175 daemons/fenced/pacemaker-fenced.c stonith_peer_callback(xmlNode * msg, void *private_data)
msg               177 daemons/fenced/pacemaker-fenced.c     const char *remote_peer = crm_element_value(msg, F_ORIG);
msg               178 daemons/fenced/pacemaker-fenced.c     const char *op = crm_element_value(msg, F_STONITH_OPERATION);
msg               184 daemons/fenced/pacemaker-fenced.c     crm_log_xml_trace(msg, "Peer[inbound]");
msg               185 daemons/fenced/pacemaker-fenced.c     stonith_command(NULL, 0, 0, msg, remote_peer);
msg               192 daemons/fenced/pacemaker-fenced.c                           uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len)
msg               197 daemons/fenced/pacemaker-fenced.c     char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from);
msg               791 daemons/fenced/pacemaker-fenced.c update_cib_stonith_devices_v2(const char *event, xmlNode * msg)
msg               796 daemons/fenced/pacemaker-fenced.c     xmlNode *patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg               854 daemons/fenced/pacemaker-fenced.c update_cib_stonith_devices_v1(const char *event, xmlNode * msg)
msg               861 daemons/fenced/pacemaker-fenced.c     xpath_obj = xpath_search(msg, "//" F_CIB_UPDATE_RESULT "//" XML_CONS_TAG_RSC_LOCATION);
msg               878 daemons/fenced/pacemaker-fenced.c     xpath_obj = xpath_search(msg, "//" F_CIB_UPDATE_RESULT "//" XML_TAG_DIFF_REMOVED "//" XML_CIB_TAG_RESOURCE);
msg               885 daemons/fenced/pacemaker-fenced.c     xpath_obj = xpath_search(msg, "//" F_CIB_UPDATE_RESULT "//" XML_TAG_DIFF_ADDED "//" XML_CIB_TAG_RESOURCE);
msg               915 daemons/fenced/pacemaker-fenced.c update_cib_stonith_devices(const char *event, xmlNode * msg)
msg               918 daemons/fenced/pacemaker-fenced.c     xmlNode *patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg               924 daemons/fenced/pacemaker-fenced.c             update_cib_stonith_devices_v1(event, msg);
msg               927 daemons/fenced/pacemaker-fenced.c             update_cib_stonith_devices_v2(event, msg);
msg               972 daemons/fenced/pacemaker-fenced.c update_fencing_topology(const char *event, xmlNode * msg)
msg               977 daemons/fenced/pacemaker-fenced.c     xmlNode *patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg               985 daemons/fenced/pacemaker-fenced.c         xpathObj = xpath_search(msg, xpath);
msg               992 daemons/fenced/pacemaker-fenced.c         xpathObj = xpath_search(msg, xpath);
msg              1070 daemons/fenced/pacemaker-fenced.c update_cib_cache_cb(const char *event, xmlNode * msg)
msg              1081 daemons/fenced/pacemaker-fenced.c     } else if(msg == NULL) {
msg              1093 daemons/fenced/pacemaker-fenced.c         crm_element_value_int(msg, F_CIB_RC, &rc);
msg              1098 daemons/fenced/pacemaker-fenced.c         patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg              1152 daemons/fenced/pacemaker-fenced.c         update_fencing_topology(event, msg);
msg              1153 daemons/fenced/pacemaker-fenced.c         update_cib_stonith_devices(event, msg);
msg              1158 daemons/fenced/pacemaker-fenced.c init_cib_cache_cb(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               219 daemons/fenced/pacemaker-fenced.h int stonith_device_register(xmlNode * msg, const char **desc, gboolean from_cib);
msg               223 daemons/fenced/pacemaker-fenced.h char *stonith_level_key(xmlNode * msg, int mode);
msg               224 daemons/fenced/pacemaker-fenced.h int stonith_level_kind(xmlNode * msg);
msg               225 daemons/fenced/pacemaker-fenced.h int stonith_level_register(xmlNode * msg, char **desc);
msg               227 daemons/fenced/pacemaker-fenced.h int stonith_level_remove(xmlNode * msg, char **desc);
msg               248 daemons/fenced/pacemaker-fenced.h int process_remote_stonith_exec(xmlNode * msg);
msg               250 daemons/fenced/pacemaker-fenced.h int process_remote_stonith_query(xmlNode * msg);
msg               254 daemons/fenced/pacemaker-fenced.h int stonith_fence_history(xmlNode *msg, xmlNode **output,
msg               261 daemons/fenced/pacemaker-fenced.h int stonith_manual_ack(xmlNode * msg, remote_fencing_op_t * op);
msg               507 daemons/pacemakerd/pacemakerd.c pcmk_handle_ping_request(pcmk__client_t *c, xmlNode *msg, uint32_t id)
msg               513 daemons/pacemakerd/pacemakerd.c     const char *from = crm_element_value(msg, F_CRM_SYS_FROM);
msg               517 daemons/pacemakerd/pacemakerd.c               crm_str(crm_element_value(msg, F_CRM_ORIGIN)),
msg               520 daemons/pacemakerd/pacemakerd.c     value = crm_element_value(msg, F_CRM_SYS_TO);
msg               525 daemons/pacemakerd/pacemakerd.c     reply = create_reply(msg, ping);
msg               560 daemons/pacemakerd/pacemakerd.c     xmlNode *msg = NULL;
msg               565 daemons/pacemakerd/pacemakerd.c     msg = pcmk__client_data2xml(c, data, &id, &flags);
msg               566 daemons/pacemakerd/pacemakerd.c     if (msg == NULL) {
msg               571 daemons/pacemakerd/pacemakerd.c     task = crm_element_value(msg, F_CRM_TASK);
msg               581 daemons/pacemakerd/pacemakerd.c                        crm_element_value(msg, F_CRM_REFERENCE),
msg               582 daemons/pacemakerd/pacemakerd.c                        crm_element_value(msg, F_CRM_ORIGIN));
msg               598 daemons/pacemakerd/pacemakerd.c         pcmk_handle_ping_request(c, msg, id);
msg               606 daemons/pacemakerd/pacemakerd.c     free_xml(msg);
msg                70 daemons/schedulerd/pacemaker-schedulerd.c handle_pecalc_op(xmlNode *msg, xmlNode *xml_data, pcmk__client_t *sender)
msg               148 daemons/schedulerd/pacemaker-schedulerd.c     reply = create_reply(msg, sched_data_set->graph);
msg               210 daemons/schedulerd/pacemaker-schedulerd.c process_pe_message(xmlNode *msg, xmlNode *xml_data, pcmk__client_t *sender)
msg               212 daemons/schedulerd/pacemaker-schedulerd.c     const char *sys_to = crm_element_value(msg, F_CRM_SYS_TO);
msg               213 daemons/schedulerd/pacemaker-schedulerd.c     const char *op = crm_element_value(msg, F_CRM_TASK);
msg               214 daemons/schedulerd/pacemaker-schedulerd.c     const char *ref = crm_element_value(msg, F_CRM_REFERENCE);
msg               224 daemons/schedulerd/pacemaker-schedulerd.c     } else if (pcmk__str_eq(crm_element_value(msg, F_CRM_MSG_TYPE), XML_ATTR_RESPONSE, pcmk__str_casei)) {
msg               232 daemons/schedulerd/pacemaker-schedulerd.c         handle_pecalc_op(msg, xml_data, sender);
msg               248 daemons/schedulerd/pacemaker-schedulerd.c gboolean process_pe_message(xmlNode *msg, xmlNode *xml_data,
msg               257 daemons/schedulerd/pacemaker-schedulerd.c     xmlNode *msg = pcmk__client_data2xml(c, data, &id, &flags);
msg               260 daemons/schedulerd/pacemaker-schedulerd.c     if (msg != NULL) {
msg               261 daemons/schedulerd/pacemaker-schedulerd.c         xmlNode *data_xml = get_message_xml(msg, F_CRM_DATA);
msg               263 daemons/schedulerd/pacemaker-schedulerd.c         process_pe_message(msg, data_xml, c);
msg               264 daemons/schedulerd/pacemaker-schedulerd.c         free_xml(msg);
msg               768 include/config.h # define _GL_ATTRIBUTE_ERROR(msg) __attribute__ ((__error__ (msg)))
msg               769 include/config.h # define _GL_ATTRIBUTE_WARNING(msg) __attribute__ ((__warning__ (msg)))
msg               771 include/config.h # define _GL_ATTRIBUTE_ERROR(msg) __attribute__ ((__diagnose_if__ (1, msg, "error")))
msg               772 include/config.h # define _GL_ATTRIBUTE_WARNING(msg) __attribute__ ((__diagnose_if__ (1, msg, "warning")))
msg               774 include/config.h # define _GL_ATTRIBUTE_ERROR(msg)
msg               775 include/config.h # define _GL_ATTRIBUTE_WARNING(msg)
msg                78 include/crm/cib/cib_types.h     int (*set_op_callback) (cib_t *cib, void (*callback) (const xmlNode *msg,
msg                83 include/crm/cib/cib_types.h                                                   xmlNode *msg));
msg                86 include/crm/cib/cib_types.h                                                   xmlNode *msg));
msg               145 include/crm/cib/cib_types.h     void (*op_callback) (const xmlNode *msg, int call_id, int rc,
msg                82 include/crm/cib/internal.h     void (*callback) (const char *event, xmlNode * msg);
msg               129 include/crm/cib/internal.h void cib_native_callback(cib_t * cib, xmlNode * msg, int call_id, int rc);
msg               158 include/crm/cluster.h char *pcmk_message_common_cs(cpg_handle_t handle, uint32_t nodeid, uint32_t pid, void *msg,
msg                79 include/crm/common/alerts_internal.h bool pcmk__alert_in_patchset(xmlNode *msg, bool config);
msg                17 include/crm/common/remote_internal.h int pcmk__remote_send_xml(pcmk__remote_t *remote, xmlNode *msg);
msg                53 include/crm/common/xml.h gboolean add_message_xml(xmlNode * msg, const char *field, xmlNode * xml);
msg                54 include/crm/common/xml.h xmlNode *get_message_xml(xmlNode * msg, const char *field);
msg               131 include/crm/common/xml.h char *dump_xml_formatted(xmlNode * msg);
msg               133 include/crm/common/xml.h char *dump_xml_formatted_with_text(xmlNode * msg);
msg               135 include/crm/common/xml.h char *dump_xml_unformatted(xmlNode * msg);
msg                33 include/crm/lrmd_internal.h int lrmd__remote_send_xml(pcmk__remote_t *session, xmlNode *msg, uint32_t id,
msg                57 include/crm/lrmd_internal.h void remote_proxy_cb(lrmd_t *lrmd, const char *node_name, xmlNode *msg);
msg                66 include/crm/lrmd_internal.h void remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg);
msg                67 include/crm/lrmd_internal.h void remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg,
msg                30 lib/cib/cib_client.c int cib_client_set_op_callback(cib_t * cib, void (*callback) (const xmlNode * msg, int call_id,
msg                34 lib/cib/cib_client.c                                    void (*callback) (const char *event, xmlNode * msg));
msg                37 lib/cib/cib_client.c                                    void (*callback) (const char *event, xmlNode * msg));
msg               451 lib/cib/cib_client.c cib_client_set_op_callback(cib_t * cib, void (*callback) (const xmlNode * msg, int call_id,
msg               466 lib/cib/cib_client.c                                void (*callback) (const char *event, xmlNode * msg))
msg               517 lib/cib/cib_client.c                                void (*callback) (const char *event, xmlNode * msg))
msg                93 lib/cib/cib_native.c     xmlNode *msg = NULL;
msg               104 lib/cib/cib_native.c     msg = string2xml(buffer);
msg               106 lib/cib/cib_native.c     if (msg == NULL) {
msg               112 lib/cib/cib_native.c     type = crm_element_value(msg, F_TYPE);
msg               114 lib/cib/cib_native.c     crm_log_xml_explicit(msg, "cib-reply");
msg               117 lib/cib/cib_native.c         cib_native_callback(cib, msg, 0, 0);
msg               120 lib/cib/cib_native.c         g_list_foreach(cib->notify_list, cib_native_notify, msg);
msg               126 lib/cib/cib_native.c     free_xml(msg);
msg               341 lib/cib/cib_remote.c     xmlNode *msg = NULL;
msg               347 lib/cib/cib_remote.c     msg = pcmk__remote_message_xml(&private->callback);
msg               348 lib/cib/cib_remote.c     while (msg) {
msg               349 lib/cib/cib_remote.c         const char *type = crm_element_value(msg, F_TYPE);
msg               354 lib/cib/cib_remote.c             cib_native_callback(cib, msg, 0, 0);
msg               357 lib/cib/cib_remote.c             g_list_foreach(cib->notify_list, cib_native_notify, msg);
msg               363 lib/cib/cib_remote.c         free_xml(msg);
msg               364 lib/cib/cib_remote.c         msg = pcmk__remote_message_xml(&private->callback);
msg               547 lib/cib/cib_utils.c cib_native_callback(cib_t * cib, xmlNode * msg, int call_id, int rc)
msg               552 lib/cib/cib_utils.c     if (msg != NULL) {
msg               553 lib/cib/cib_utils.c         crm_element_value_int(msg, F_CIB_RC, &rc);
msg               554 lib/cib/cib_utils.c         crm_element_value_int(msg, F_CIB_CALLID, &call_id);
msg               555 lib/cib/cib_utils.c         output = get_message_xml(msg, F_CIB_CALLDATA);
msg               574 lib/cib/cib_utils.c         blob->callback(msg, call_id, rc, output, blob->user_data);
msg               578 lib/cib/cib_utils.c         crm_log_xml_debug(msg, "Failed CIB Update");
msg               588 lib/cib/cib_utils.c         cib->op_callback(msg, call_id, rc, output);
msg               596 lib/cib/cib_utils.c     xmlNode *msg = user_data;
msg               600 lib/cib/cib_utils.c     if (msg == NULL) {
msg               605 lib/cib/cib_utils.c     event = crm_element_value(msg, F_SUBTYPE);
msg               621 lib/cib/cib_utils.c     entry->callback(event, msg);
msg                76 lib/cluster/cpg.c #define msg_data_len(msg) (msg->is_compressed?msg->compressed_size:msg->size)
msg               363 lib/cluster/cpg.c check_message_sanity(const pcmk__cpg_msg_t *msg)
msg               365 lib/cluster/cpg.c     int32_t payload_size = msg->header.size - sizeof(pcmk__cpg_msg_t);
msg               371 lib/cluster/cpg.c                 (msg->is_compressed? "Compressed " : ""),
msg               372 lib/cluster/cpg.c                 msg->id, ais_dest(&(msg->sender)),
msg               373 lib/cluster/cpg.c                 (int) msg->header.size,
msg               374 lib/cluster/cpg.c                 msg_type2text(msg->sender.type), msg->sender.pid,
msg               375 lib/cluster/cpg.c                 msg_type2text(msg->host.type), ais_dest(&(msg->host)));
msg               379 lib/cluster/cpg.c     if (msg->header.error != CS_OK) {
msg               383 lib/cluster/cpg.c                 (msg->is_compressed? "Compressed " : ""),
msg               384 lib/cluster/cpg.c                 msg->id, ais_dest(&(msg->sender)),
msg               385 lib/cluster/cpg.c                 msg->header.error,
msg               386 lib/cluster/cpg.c                 msg_type2text(msg->sender.type), msg->sender.pid,
msg               387 lib/cluster/cpg.c                 msg_type2text(msg->host.type), ais_dest(&(msg->host)));
msg               391 lib/cluster/cpg.c     if (msg_data_len(msg) != payload_size) {
msg               395 lib/cluster/cpg.c                 (msg->is_compressed? "Compressed " : ""),
msg               396 lib/cluster/cpg.c                 msg->id, ais_dest(&(msg->sender)),
msg               397 lib/cluster/cpg.c                 (int) msg->header.size, (int) msg_data_len(msg),
msg               398 lib/cluster/cpg.c                 msg_type2text(msg->sender.type), msg->sender.pid,
msg               399 lib/cluster/cpg.c                 msg_type2text(msg->host.type), ais_dest(&(msg->host)));
msg               403 lib/cluster/cpg.c     if (!msg->is_compressed &&
msg               407 lib/cluster/cpg.c         (((msg->size > 1) && (msg->data[msg->size - 2] == '\0'))
msg               408 lib/cluster/cpg.c          || (msg->data[msg->size - 1] != '\0'))) {
msg               412 lib/cluster/cpg.c                 msg->id, ais_dest(&(msg->sender)),
msg               413 lib/cluster/cpg.c                 (unsigned long long) msg->size,
msg               414 lib/cluster/cpg.c                 msg_type2text(msg->sender.type), msg->sender.pid,
msg               415 lib/cluster/cpg.c                 msg_type2text(msg->host.type), ais_dest(&(msg->host)));
msg               420 lib/cluster/cpg.c               (int) msg->header.size, (msg->is_compressed? "compressed " : ""),
msg               421 lib/cluster/cpg.c               msg->id, msg_type2text(msg->sender.type), msg->sender.pid,
msg               422 lib/cluster/cpg.c               ais_dest(&(msg->sender)),
msg               423 lib/cluster/cpg.c               msg_type2text(msg->host.type), ais_dest(&(msg->host)));
msg               448 lib/cluster/cpg.c     pcmk__cpg_msg_t *msg = (pcmk__cpg_msg_t *) content;
msg               455 lib/cluster/cpg.c         if (msg->sender.id > 0 && msg->sender.id != nodeid) {
msg               456 lib/cluster/cpg.c             crm_err("Nodeid mismatch from %d.%d: claimed nodeid=%u", nodeid, pid, msg->sender.id);
msg               459 lib/cluster/cpg.c         } else if (msg->host.id != 0 && (local_nodeid != msg->host.id)) {
msg               461 lib/cluster/cpg.c             crm_trace("Not for us: %u != %u", msg->host.id, local_nodeid);
msg               463 lib/cluster/cpg.c         } else if (msg->host.size != 0 && !pcmk__str_eq(msg->host.uname, local_name, pcmk__str_casei)) {
msg               465 lib/cluster/cpg.c             crm_trace("Not for us: %s != %s", msg->host.uname, local_name);
msg               469 lib/cluster/cpg.c         msg->sender.id = nodeid;
msg               470 lib/cluster/cpg.c         if (msg->sender.size == 0) {
msg               481 lib/cluster/cpg.c                 msg->sender.size = strlen(peer->uname);
msg               482 lib/cluster/cpg.c                 memset(msg->sender.uname, 0, MAX_NAME);
msg               483 lib/cluster/cpg.c                 memcpy(msg->sender.uname, peer->uname, msg->sender.size);
msg               489 lib/cluster/cpg.c               msg->is_compressed ? " compressed" : "",
msg               490 lib/cluster/cpg.c               msg_data_len(msg), msg->size, msg->compressed_size);
msg               493 lib/cluster/cpg.c         *kind = msg->header.id;
msg               496 lib/cluster/cpg.c         *from = msg->sender.uname;
msg               499 lib/cluster/cpg.c     if (msg->is_compressed && msg->size > 0) {
msg               502 lib/cluster/cpg.c         unsigned int new_size = msg->size + 1;
msg               504 lib/cluster/cpg.c         if (!check_message_sanity(msg)) {
msg               510 lib/cluster/cpg.c         rc = BZ2_bzBuffToBuffDecompress(uncompressed, &new_size, msg->data, msg->compressed_size, 1, 0);
msg               520 lib/cluster/cpg.c         CRM_ASSERT(new_size == msg->size);
msg               524 lib/cluster/cpg.c     } else if (!check_message_sanity(msg)) {
msg               528 lib/cluster/cpg.c         data = strdup(msg->data);
msg               532 lib/cluster/cpg.c     crm_get_peer(msg->sender.id, msg->sender.uname);
msg               540 lib/cluster/cpg.c             msg->id, ais_dest(&(msg->host)), msg_type2text(msg->host.type),
msg               541 lib/cluster/cpg.c             ais_dest(&(msg->sender)), msg_type2text(msg->sender.type),
msg               542 lib/cluster/cpg.c             msg->sender.pid, (int)sizeof(pcmk__cpg_msg_t),
msg               543 lib/cluster/cpg.c             msg->header.size, msg->size, msg->compressed_size);
msg               877 lib/cluster/cpg.c pcmk__cpg_send_xml(xmlNode *msg, crm_node_t *node, enum crm_ais_msg_types dest)
msg               882 lib/cluster/cpg.c     data = dump_xml_unformatted(msg);
msg               911 lib/cluster/cpg.c     pcmk__cpg_msg_t *msg = NULL;
msg               943 lib/cluster/cpg.c     msg = calloc(1, sizeof(pcmk__cpg_msg_t));
msg               946 lib/cluster/cpg.c     msg->id = msg_id;
msg               947 lib/cluster/cpg.c     msg->header.id = msg_class;
msg               948 lib/cluster/cpg.c     msg->header.error = CS_OK;
msg               950 lib/cluster/cpg.c     msg->host.type = dest;
msg               951 lib/cluster/cpg.c     msg->host.local = local;
msg               956 lib/cluster/cpg.c             msg->host.size = strlen(node->uname);
msg               957 lib/cluster/cpg.c             memset(msg->host.uname, 0, MAX_NAME);
msg               958 lib/cluster/cpg.c             memcpy(msg->host.uname, node->uname, msg->host.size);
msg               962 lib/cluster/cpg.c         msg->host.id = node->id;
msg               967 lib/cluster/cpg.c     msg->sender.id = 0;
msg               968 lib/cluster/cpg.c     msg->sender.type = sender;
msg               969 lib/cluster/cpg.c     msg->sender.pid = local_pid;
msg               970 lib/cluster/cpg.c     msg->sender.size = local_name_len;
msg               971 lib/cluster/cpg.c     memset(msg->sender.uname, 0, MAX_NAME);
msg               972 lib/cluster/cpg.c     if ((local_name != NULL) && (msg->sender.size != 0)) {
msg               973 lib/cluster/cpg.c         memcpy(msg->sender.uname, local_name, msg->sender.size);
msg               976 lib/cluster/cpg.c     msg->size = 1 + strlen(data);
msg               977 lib/cluster/cpg.c     msg->header.size = sizeof(pcmk__cpg_msg_t) + msg->size;
msg               979 lib/cluster/cpg.c     if (msg->size < CRM_BZ2_THRESHOLD) {
msg               980 lib/cluster/cpg.c         msg = pcmk__realloc(msg, msg->header.size);
msg               981 lib/cluster/cpg.c         memcpy(msg->data, data, msg->size);
msg               988 lib/cluster/cpg.c         if (pcmk__compress(uncompressed, (unsigned int) msg->size, 0,
msg               991 lib/cluster/cpg.c             msg->header.size = sizeof(pcmk__cpg_msg_t) + new_size;
msg               992 lib/cluster/cpg.c             msg = pcmk__realloc(msg, msg->header.size);
msg               993 lib/cluster/cpg.c             memcpy(msg->data, compressed, new_size);
msg               995 lib/cluster/cpg.c             msg->is_compressed = TRUE;
msg               996 lib/cluster/cpg.c             msg->compressed_size = new_size;
msg              1001 lib/cluster/cpg.c             msg = pcmk__realloc(msg, msg->header.size);
msg              1002 lib/cluster/cpg.c             memcpy(msg->data, data, msg->size);
msg              1010 lib/cluster/cpg.c     iov->iov_base = msg;
msg              1011 lib/cluster/cpg.c     iov->iov_len = msg->header.size;
msg              1013 lib/cluster/cpg.c     if (msg->compressed_size) {
msg              1015 lib/cluster/cpg.c                   msg->id, target, (unsigned long long) iov->iov_len,
msg              1016 lib/cluster/cpg.c                   msg->compressed_size, data);
msg              1019 lib/cluster/cpg.c                   msg->id, target, (unsigned long long) iov->iov_len,
msg              1020 lib/cluster/cpg.c                   msg->size, data);
msg                44 lib/cluster/crmcluster_private.h gboolean pcmk__cpg_send_xml(xmlNode *msg, crm_node_t *node,
msg               199 lib/common/alerts.c pcmk__alert_in_patchset(xmlNode *msg, bool config)
msg               203 lib/common/alerts.c     xmlNode *patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg               207 lib/common/alerts.c     CRM_CHECK(msg != NULL, return FALSE);
msg               209 lib/common/alerts.c     crm_element_value_int(msg, F_CIB_RC, &rc);
msg               219 lib/common/alerts.c         if ((xpathObj = xpath_search(msg, diff)) != NULL) {
msg               214 lib/common/crmcommon_private.h     void (*dispatch)(pcmk_ipc_api_t *api, xmlNode *msg);
msg               321 lib/common/ipc_client.c     xmlNode *msg;
msg               331 lib/common/ipc_client.c     msg = string2xml(buffer);
msg               332 lib/common/ipc_client.c     if (msg == NULL) {
msg               337 lib/common/ipc_client.c     call_api_dispatch(api, msg);
msg               338 lib/common/ipc_client.c     free_xml(msg);
msg               382 lib/common/logging.c                 const char *msg)
msg               154 lib/common/messages.c get_message_xml(xmlNode *msg, const char *field)
msg               156 lib/common/messages.c     xmlNode *tmp = first_named_child(msg, field);
msg               162 lib/common/messages.c add_message_xml(xmlNode *msg, const char *field, xmlNode *xml)
msg               164 lib/common/messages.c     xmlNode *holder = create_xml_node(msg, field);
msg               488 lib/common/remote.c pcmk__remote_send_xml(pcmk__remote_t *remote, xmlNode *msg)
msg               497 lib/common/remote.c     CRM_CHECK((remote != NULL) && (msg != NULL), return EINVAL);
msg               499 lib/common/remote.c     xml_text = dump_xml_unformatted(msg);
msg              1299 lib/fencing/st_client.c stonith_perform_callback(stonith_t * stonith, xmlNode * msg, int call_id, int rc)
msg              1315 lib/fencing/st_client.c     if (msg != NULL) {
msg              1316 lib/fencing/st_client.c         crm_element_value_int(msg, F_STONITH_RC, &rc);
msg              1317 lib/fencing/st_client.c         crm_element_value_int(msg, F_STONITH_CALLID, &call_id);
msg              1320 lib/fencing/st_client.c     CRM_CHECK(call_id > 0, crm_log_xml_err(msg, "Bad result"));
msg              1341 lib/fencing/st_client.c         crm_log_xml_debug(msg, "Failed fence update");
msg              1732 lib/fencing/st_client.c xml_to_event(xmlNode * msg)
msg              1735 lib/fencing/st_client.c     const char *ntype = crm_element_value(msg, F_SUBTYPE);
msg              1737 lib/fencing/st_client.c     xmlNode *data = get_xpath_object(data_addr, msg, LOG_DEBUG);
msg              1739 lib/fencing/st_client.c     crm_log_xml_trace(msg, "stonith_notify");
msg              1741 lib/fencing/st_client.c     crm_element_value_int(msg, F_STONITH_RC, &(event->result));
msg              1744 lib/fencing/st_client.c         event->operation = crm_element_value_copy(msg, F_STONITH_OPERATION);
msg              1757 lib/fencing/st_client.c             crm_log_xml_notice(msg, "BadEvent");
msg              1964 lib/fencing/st_client.c             const char *msg = crm_ipc_buffer(private->ipc);
msg              1966 lib/fencing/st_client.c             stonith_dispatch_internal(msg, strlen(msg), st);
msg                57 lib/lrmd/lrmd_client.c int lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg);
msg                58 lib/lrmd/lrmd_client.c static void lrmd_internal_proxy_dispatch(lrmd_t *lrmd, xmlNode *msg);
msg                59 lib/lrmd/lrmd_client.c void lrmd_internal_set_proxy_callback(lrmd_t * lrmd, void *userdata, void (*callback)(lrmd_t *lrmd, void *userdata, xmlNode *msg));
msg               102 lib/lrmd/lrmd_client.c     void (*proxy_callback)(lrmd_t *lrmd, void *userdata, xmlNode *msg);
msg               259 lib/lrmd/lrmd_client.c lrmd_dispatch_internal(lrmd_t * lrmd, xmlNode * msg)
msg               262 lib/lrmd/lrmd_client.c     const char *proxy_session = crm_element_value(msg, F_LRMD_IPC_SESSION);
msg               268 lib/lrmd/lrmd_client.c         lrmd_internal_proxy_dispatch(lrmd, msg);
msg               277 lib/lrmd/lrmd_client.c     type = crm_element_value(msg, F_LRMD_OPERATION);
msg               278 lib/lrmd/lrmd_client.c     crm_element_value_int(msg, F_LRMD_CALLID, &event.call_id);
msg               279 lib/lrmd/lrmd_client.c     event.rsc_id = crm_element_value(msg, F_LRMD_RSC_ID);
msg               288 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_TIMEOUT, &event.timeout);
msg               289 lib/lrmd/lrmd_client.c         crm_element_value_ms(msg, F_LRMD_RSC_INTERVAL, &event.interval_ms);
msg               290 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_RSC_START_DELAY, &event.start_delay);
msg               291 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_EXEC_RC, (int *)&event.rc);
msg               292 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_OP_STATUS, &event.op_status);
msg               293 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_RSC_DELETED, &event.rsc_deleted);
msg               295 lib/lrmd/lrmd_client.c         crm_element_value_epoch(msg, F_LRMD_RSC_RUN_TIME, &epoch);
msg               298 lib/lrmd/lrmd_client.c         crm_element_value_epoch(msg, F_LRMD_RSC_RCCHANGE_TIME, &epoch);
msg               301 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_RSC_EXEC_TIME, (int *)&event.exec_time);
msg               302 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_RSC_QUEUE_TIME, (int *)&event.queue_time);
msg               304 lib/lrmd/lrmd_client.c         event.op_type = crm_element_value(msg, F_LRMD_RSC_ACTION);
msg               305 lib/lrmd/lrmd_client.c         event.user_data = crm_element_value(msg, F_LRMD_RSC_USERDATA_STR);
msg               306 lib/lrmd/lrmd_client.c         event.output = crm_element_value(msg, F_LRMD_RSC_OUTPUT);
msg               307 lib/lrmd/lrmd_client.c         event.exit_reason = crm_element_value(msg, F_LRMD_RSC_EXIT_REASON);
msg               310 lib/lrmd/lrmd_client.c         event.params = xml2list(msg);
msg               335 lib/lrmd/lrmd_client.c         xmlNode *msg = string2xml(buffer);
msg               337 lib/lrmd/lrmd_client.c         lrmd_dispatch_internal(lrmd, msg);
msg               338 lib/lrmd/lrmd_client.c         free_xml(msg);
msg               486 lib/lrmd/lrmd_client.c                     const char *msg = crm_ipc_buffer(private->ipc);
msg               488 lib/lrmd/lrmd_client.c                     lrmd_ipc_dispatch(msg, strlen(msg), lrmd);
msg               603 lib/lrmd/lrmd_client.c lrmd__remote_send_xml(pcmk__remote_t *session, xmlNode *msg, uint32_t id,
msg               606 lib/lrmd/lrmd_client.c     crm_xml_add_int(msg, F_LRMD_REMOTE_MSG_ID, id);
msg               607 lib/lrmd/lrmd_client.c     crm_xml_add(msg, F_LRMD_REMOTE_MSG_TYPE, msg_type);
msg               608 lib/lrmd/lrmd_client.c     return pcmk__remote_send_xml(session, msg);
msg               695 lib/lrmd/lrmd_client.c send_remote_message(lrmd_t *lrmd, xmlNode *msg)
msg               705 lib/lrmd/lrmd_client.c     rc = lrmd__remote_send_xml(native->remote, msg, global_remote_msg_id,
msg               716 lib/lrmd/lrmd_client.c lrmd_tls_send_recv(lrmd_t * lrmd, xmlNode * msg, int timeout, xmlNode ** reply)
msg               725 lib/lrmd/lrmd_client.c     rc = send_remote_message(lrmd, msg);
msg               749 lib/lrmd/lrmd_client.c lrmd_send_xml(lrmd_t * lrmd, xmlNode * msg, int timeout, xmlNode ** reply)
msg               756 lib/lrmd/lrmd_client.c             rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply);
msg               760 lib/lrmd/lrmd_client.c             rc = lrmd_tls_send_recv(lrmd, msg, timeout, reply);
msg               773 lib/lrmd/lrmd_client.c lrmd_send_xml_no_reply(lrmd_t * lrmd, xmlNode * msg)
msg               780 lib/lrmd/lrmd_client.c             rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL);
msg               784 lib/lrmd/lrmd_client.c             rc = send_remote_message(lrmd, msg);
msg              1875 lib/lrmd/lrmd_client.c lrmd_internal_set_proxy_callback(lrmd_t * lrmd, void *userdata, void (*callback)(lrmd_t *lrmd, void *userdata, xmlNode *msg))
msg              1884 lib/lrmd/lrmd_client.c lrmd_internal_proxy_dispatch(lrmd_t *lrmd, xmlNode *msg)
msg              1889 lib/lrmd/lrmd_client.c         crm_log_xml_trace(msg, "PROXY_INBOUND");
msg              1890 lib/lrmd/lrmd_client.c         native->proxy_callback(lrmd, native->proxy_callback_userdata, msg);
msg              1895 lib/lrmd/lrmd_client.c lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg)
msg              1900 lib/lrmd/lrmd_client.c     crm_xml_add(msg, F_LRMD_OPERATION, CRM_OP_IPC_FWD);
msg              1902 lib/lrmd/lrmd_client.c     crm_log_xml_trace(msg, "PROXY_OUTBOUND");
msg              1903 lib/lrmd/lrmd_client.c     return lrmd_send_xml_no_reply(lrmd, msg);
msg                25 lib/lrmd/proxy_common.c int lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg);
msg                32 lib/lrmd/proxy_common.c     xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg                33 lib/lrmd/proxy_common.c     crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_DESTROY);
msg                34 lib/lrmd/proxy_common.c     crm_xml_add(msg, F_LRMD_IPC_SESSION, session_id);
msg                35 lib/lrmd/proxy_common.c     lrmd_internal_proxy_send(lrmd, msg);
msg                36 lib/lrmd/proxy_common.c     free_xml(msg);
msg                47 lib/lrmd/proxy_common.c     xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg                48 lib/lrmd/proxy_common.c     crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_SHUTDOWN_ACK);
msg                49 lib/lrmd/proxy_common.c     lrmd_internal_proxy_send(lrmd, msg);
msg                50 lib/lrmd/proxy_common.c     free_xml(msg);
msg                62 lib/lrmd/proxy_common.c     xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg                63 lib/lrmd/proxy_common.c     crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_SHUTDOWN_NACK);
msg                64 lib/lrmd/proxy_common.c     lrmd_internal_proxy_send(lrmd, msg);
msg                65 lib/lrmd/proxy_common.c     free_xml(msg);
msg                69 lib/lrmd/proxy_common.c remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg)
msg                75 lib/lrmd/proxy_common.c     add_message_xml(event, F_LRMD_IPC_MSG, msg);
msg                82 lib/lrmd/proxy_common.c remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, int msg_id)
msg                89 lib/lrmd/proxy_common.c     add_message_xml(response, F_LRMD_IPC_MSG, msg);
msg               206 lib/lrmd/proxy_common.c remote_proxy_cb(lrmd_t *lrmd, const char *node_name, xmlNode *msg)
msg               208 lib/lrmd/proxy_common.c     const char *op = crm_element_value(msg, F_LRMD_IPC_OP);
msg               209 lib/lrmd/proxy_common.c     const char *session = crm_element_value(msg, F_LRMD_IPC_SESSION);
msg               220 lib/lrmd/proxy_common.c     crm_element_value_int(msg, F_LRMD_IPC_MSG_ID, &msg_id);
msg               228 lib/lrmd/proxy_common.c         xmlNode *request = get_message_xml(msg, F_LRMD_IPC_MSG);
msg               229 lib/lrmd/proxy_common.c         const char *name = crm_element_value(msg, F_LRMD_IPC_CLIENT);
msg               248 lib/lrmd/proxy_common.c         crm_element_value_int(msg, F_LRMD_IPC_MSG_FLAGS, &flags);
msg               413 lib/services/dbus.c pcmk_dbus_send_recv(DBusMessage *msg, DBusConnection *connection,
msg               420 lib/services/dbus.c     CRM_ASSERT(dbus_message_get_type (msg) == DBUS_MESSAGE_TYPE_METHOD_CALL);
msg               421 lib/services/dbus.c     method = dbus_message_get_member (msg);
msg               434 lib/services/dbus.c     if (!dbus_connection_send_with_reply(connection, msg, &pending, timeout)) {
msg               477 lib/services/dbus.c pcmk_dbus_send(DBusMessage *msg, DBusConnection *connection,
msg               485 lib/services/dbus.c     CRM_ASSERT(dbus_message_get_type(msg) == DBUS_MESSAGE_TYPE_METHOD_CALL);
msg               486 lib/services/dbus.c     method = dbus_message_get_member(msg);
msg               494 lib/services/dbus.c     if (!dbus_connection_send_with_reply(connection, msg, &pending, timeout)) {
msg               517 lib/services/dbus.c pcmk_dbus_type_check(DBusMessage *msg, DBusMessageIter *field, int expected,
msg               524 lib/services/dbus.c         if (dbus_message_iter_init(msg, &lfield)) {
msg               542 lib/services/dbus.c         dbus_message_iter_init(msg, &args);
msg               699 lib/services/dbus.c     DBusMessage *msg;
msg               710 lib/services/dbus.c     msg = dbus_message_new_method_call(target, obj, BUS_PROPERTY_IFACE, "Get");
msg               711 lib/services/dbus.c     if (msg == NULL) {
msg               718 lib/services/dbus.c     if (!dbus_message_append_args(msg,
msg               724 lib/services/dbus.c         dbus_message_unref(msg);
msg               732 lib/services/dbus.c         dbus_message_unref(msg);
msg               745 lib/services/dbus.c               dbus_message_unref(msg);
msg               751 lib/services/dbus.c         local_pending = pcmk_dbus_send(msg, connection, async_query_result_cb,
msg               764 lib/services/dbus.c         DBusMessage *reply = pcmk_dbus_send_recv(msg, connection, NULL,
msg               774 lib/services/dbus.c     dbus_message_unref(msg);
msg                26 lib/services/pcmk-dbus.h DBusPendingCall *pcmk_dbus_send(DBusMessage *msg, DBusConnection *connection,
msg                30 lib/services/pcmk-dbus.h DBusMessage *pcmk_dbus_send_recv(DBusMessage *msg, DBusConnection *connection, DBusError *error, int timeout);
msg                33 lib/services/pcmk-dbus.h bool pcmk_dbus_type_check(DBusMessage *msg, DBusMessageIter *field, int expected, const char *function, int line);
msg                44 lib/services/systemd.c systemd_send(DBusMessage *msg,
msg                48 lib/services/systemd.c     return pcmk_dbus_send(msg, systemd_proxy, done, user_data, timeout);
msg                52 lib/services/systemd.c systemd_send_recv(DBusMessage *msg, DBusError *error, int timeout)
msg                54 lib/services/systemd.c     return pcmk_dbus_send_recv(msg, systemd_proxy, error, timeout);
msg                71 lib/services/systemd.c     DBusMessage *msg = systemd_new_method(method);
msg                78 lib/services/systemd.c     if (msg == NULL) {
msg                84 lib/services/systemd.c     reply = systemd_send_recv(msg, &error, DBUS_TIMEOUT_USE_DEFAULT);
msg                85 lib/services/systemd.c     dbus_message_unref(msg);
msg               220 lib/services/systemd.c     DBusMessage *msg = systemd_new_method("Reload");
msg               223 lib/services/systemd.c     CRM_ASSERT(msg != NULL);
msg               224 lib/services/systemd.c     systemd_send(msg, systemd_daemon_reload_complete,
msg               226 lib/services/systemd.c     dbus_message_unref(msg);
msg               317 lib/services/systemd.c     DBusMessage *msg;
msg               334 lib/services/systemd.c     msg = systemd_new_method("LoadUnit");
msg               335 lib/services/systemd.c     CRM_ASSERT(msg != NULL);
msg               338 lib/services/systemd.c     CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID));
msg               345 lib/services/systemd.c         reply = systemd_send_recv(msg, NULL,
msg               347 lib/services/systemd.c         dbus_message_unref(msg);
msg               359 lib/services/systemd.c     pending = systemd_send(msg, systemd_loadunit_cb, op, op->timeout);
msg               364 lib/services/systemd.c     dbus_message_unref(msg);
msg               730 lib/services/systemd.c     DBusMessage *msg = NULL;
msg               773 lib/services/systemd.c     msg = systemd_new_method(method);
msg               774 lib/services/systemd.c     CRM_ASSERT(msg != NULL);
msg               781 lib/services/systemd.c         CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID));
msg               782 lib/services/systemd.c         CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &replace_s, DBUS_TYPE_INVALID));
msg               788 lib/services/systemd.c         DBusPendingCall *pending = systemd_send(msg, systemd_async_dispatch,
msg               791 lib/services/systemd.c         dbus_message_unref(msg);
msg               801 lib/services/systemd.c         reply = systemd_send_recv(msg, NULL, op->timeout);
msg               802 lib/services/systemd.c         dbus_message_unref(msg);
msg                68 lib/services/upstart.c     DBusMessage *msg;
msg                75 lib/services/upstart.c     msg = dbus_message_new_method_call(BUS_NAME, // target for the method call
msg                81 lib/services/upstart.c     CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &arg_name, DBUS_TYPE_INVALID));
msg                82 lib/services/upstart.c     reply = pcmk_dbus_send_recv(msg, upstart_proxy, &error, timeout);
msg                83 lib/services/upstart.c     dbus_message_unref(msg);
msg               154 lib/services/upstart.c     DBusMessage *msg = NULL;
msg               169 lib/services/upstart.c     msg = dbus_message_new_method_call(BUS_NAME, // target for the method call
msg               173 lib/services/upstart.c     CRM_ASSERT(msg != NULL);
msg               175 lib/services/upstart.c     reply = pcmk_dbus_send_recv(msg, upstart_proxy, &error, DBUS_TIMEOUT_USE_DEFAULT);
msg               176 lib/services/upstart.c     dbus_message_unref(msg);
msg               242 lib/services/upstart.c     DBusMessage *msg;
msg               248 lib/services/upstart.c     msg = dbus_message_new_method_call(BUS_NAME, // target for the method call
msg               252 lib/services/upstart.c     CRM_ASSERT(msg != NULL);
msg               254 lib/services/upstart.c     dbus_message_append_args(msg, DBUS_TYPE_INVALID);
msg               255 lib/services/upstart.c     reply = pcmk_dbus_send_recv(msg, upstart_proxy, &error, timeout);
msg               256 lib/services/upstart.c     dbus_message_unref(msg);
msg               426 lib/services/upstart.c     DBusMessage *msg = NULL;
msg               491 lib/services/upstart.c     msg = dbus_message_new_method_call(BUS_NAME, // target for the method call
msg               495 lib/services/upstart.c     CRM_ASSERT(msg != NULL);
msg               497 lib/services/upstart.c     dbus_message_iter_init_append (msg, &iter);
msg               507 lib/services/upstart.c     CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_BOOLEAN, &arg_wait, DBUS_TYPE_INVALID));
msg               510 lib/services/upstart.c         DBusPendingCall* pending = pcmk_dbus_send(msg, upstart_proxy, upstart_async_dispatch, op, op->timeout);
msg               522 lib/services/upstart.c     reply = pcmk_dbus_send_recv(msg, upstart_proxy, &error, op->timeout);
msg               552 lib/services/upstart.c     if(msg) {
msg               553 lib/services/upstart.c         dbus_message_unref(msg);
msg                38 maint/mocked/based-notifyfenced.c     xmlNode *msg;
msg                52 maint/mocked/based-notifyfenced.c         .msg = xml,
msg                64 maint/mocked/based-notifyfenced.c     type = crm_element_value(update.msg, F_SUBTYPE);
msg                35 tools/cibadmin.c void cibadmin_op_callback(xmlNode *msg, int call_id, int rc, xmlNode *output,
msg               751 tools/cibadmin.c cibadmin_op_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               765 tools/cibadmin.c         crm_log_xml_err(msg, "no output");
msg               132 tools/crm_mon.c static void crm_diff_update(const char *event, xmlNode * msg);
msg              1967 tools/crm_mon.c crm_diff_update_v2(const char *event, xmlNode * msg)
msg              1970 tools/crm_mon.c     xmlNode *diff = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg              2074 tools/crm_mon.c crm_diff_update_v1(const char *event, xmlNode * msg)
msg              2077 tools/crm_mon.c     xmlXPathObject *xpathObj = xpath_search(msg,
msg              2091 tools/crm_mon.c crm_diff_update(const char *event, xmlNode * msg)
msg              2096 tools/crm_mon.c     xmlNode *diff = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg              2128 tools/crm_mon.c                 crm_diff_update_v1(event, msg);
msg              2131 tools/crm_mon.c                 crm_diff_update_v2(event, msg);
msg              1596 tools/crm_resource.c         gchar *msg = NULL;
msg              1615 tools/crm_resource.c         msg = g_strjoinv("", strv);
msg              1616 tools/crm_resource.c         g_set_error(&error, PCMK__EXITC_ERROR, exit_code, "%s", msg);
msg              1617 tools/crm_resource.c         g_free(msg);
msg              2091 tools/crm_resource.c             char *msg = crm_strdup_printf("%s\nError performing operation: %s",
msg              2094 tools/crm_resource.c             g_set_error(&error, PCMK__EXITC_ERROR, exit_code, "%s", msg);
msg              2095 tools/crm_resource.c             free(msg);