msg                63 attrd/attrd_common.h void attrd_cib_updated_cb(const char *event, xmlNode *msg);
msg                90 attrd/attrd_common_alerts.c config_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               141 attrd/attrd_common_alerts.c attrd_cib_updated_cb(const char *event, xmlNode * msg)
msg               143 attrd/attrd_common_alerts.c     if (crm_patchset_contains_alert(msg, FALSE)) {
msg               933 attrd/commands.c attrd_cib_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg                56 attrd/internal.h void attrd_peer_message(crm_node_t *client, xmlNode *msg);
msg                81 attrd/legacy.c void attrd_local_callback(xmlNode * msg);
msg                85 attrd/legacy.c static void update_local_attr(xmlNode *msg, attr_hash_entry_t *hash_entry);
msg               113 attrd/legacy.c     xmlNode *msg = crm_ipcs_recv(client, data, size, &id, &flags);
msg               116 attrd/legacy.c     if (msg == NULL) {
msg               122 attrd/legacy.c     crm_acl_get_set_user(msg, F_ATTRD_USER, client->user);
msg               126 attrd/legacy.c     crm_log_xml_trace(msg, __FUNCTION__);
msg               128 attrd/legacy.c     attrd_local_callback(msg);
msg               130 attrd/legacy.c     free_xml(msg);
msg               170 attrd/legacy.c find_hash_entry(xmlNode * msg)
msg               173 attrd/legacy.c     const char *attr = crm_element_value(msg, F_ATTRD_ATTRIBUTE);
msg               194 attrd/legacy.c     value = crm_element_value(msg, F_ATTRD_SET);
msg               201 attrd/legacy.c     value = crm_element_value(msg, F_ATTRD_SECTION);
msg               209 attrd/legacy.c     value = crm_element_value(msg, F_ATTRD_DAMPEN);
msg               221 attrd/legacy.c     value = crm_element_value(msg, F_ATTRD_USER);
msg               273 attrd/legacy.c remote_clear_callback(xmlNode *msg, int call_id, int rc, xmlNode *output,
msg               447 attrd/legacy.c attrd_ha_callback(HA_Message * msg, void *private_data)
msg               449 attrd/legacy.c     xmlNode *xml = convert_ha_message(NULL, msg, __FUNCTION__);
msg               461 attrd/legacy.c                  uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len)
msg               466 attrd/legacy.c     char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from);
msg               550 attrd/legacy.c do_cib_replaced(const char *event, xmlNode * msg)
msg               774 attrd/legacy.c attrd_cib_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               915 attrd/legacy.c update_local_attr(xmlNode *msg, attr_hash_entry_t *hash_entry)
msg               917 attrd/legacy.c     const char *value = crm_element_value(msg, F_ATTRD_VALUE);
msg               921 attrd/legacy.c         const char *key = crm_element_value(msg, F_ATTRD_KEY);
msg               978 attrd/legacy.c remote_attr_callback(xmlNode *msg, int id, int rc, xmlNode *output, void *data)
msg              1061 attrd/legacy.c attrd_client_clear_failure(xmlNode *msg)
msg              1063 attrd/legacy.c     const char *host = crm_element_value(msg, F_ATTRD_HOST);
msg              1068 attrd/legacy.c         send_cluster_message(NULL, crm_msg_attrd, msg, FALSE);
msg              1071 attrd/legacy.c         remote_clear_failure(msg);
msg              1074 attrd/legacy.c         local_clear_failure(msg);
msg              1080 attrd/legacy.c         crm_element_value_int(msg, F_ATTRD_IS_REMOTE, &is_remote);
msg              1084 attrd/legacy.c             remote_clear_failure(msg);
msg              1088 attrd/legacy.c             send_cluster_message(peer, crm_msg_attrd, msg, FALSE);
msg              1094 attrd/legacy.c attrd_local_callback(xmlNode * msg)
msg              1097 attrd/legacy.c     const char *from = crm_element_value(msg, F_ORIG);
msg              1098 attrd/legacy.c     const char *op = crm_element_value(msg, F_ATTRD_TASK);
msg              1099 attrd/legacy.c     const char *attr = crm_element_value(msg, F_ATTRD_ATTRIBUTE);
msg              1100 attrd/legacy.c     const char *pattern = crm_element_value(msg, F_ATTRD_REGEX);
msg              1101 attrd/legacy.c     const char *value = crm_element_value(msg, F_ATTRD_VALUE);
msg              1102 attrd/legacy.c     const char *host = crm_element_value(msg, F_ATTRD_HOST);
msg              1105 attrd/legacy.c     crm_element_value_int(msg, F_ATTRD_IS_REMOTE, &is_remote);
msg              1115 attrd/legacy.c             send_cluster_message(NULL, crm_msg_attrd, msg, FALSE);
msg              1120 attrd/legacy.c         attrd_client_clear_failure(msg);
msg              1130 attrd/legacy.c         const char *section = crm_element_value(msg, F_ATTRD_SECTION);
msg              1131 attrd/legacy.c         const char *user_name = crm_element_value(msg, F_ATTRD_USER);
msg              1151 attrd/legacy.c         send_cluster_message(crm_get_peer(0, host), crm_msg_attrd, msg, FALSE);
msg              1158 attrd/legacy.c         hash_entry = find_hash_entry(msg);
msg              1160 attrd/legacy.c             update_local_attr(msg, hash_entry);
msg              1182 attrd/legacy.c                 update_local_attr(msg, hash_entry);
msg              1203 attrd/legacy.c     xmlNode *msg = NULL;
msg              1210 attrd/legacy.c     msg = create_xml_node(NULL, __FUNCTION__);
msg              1211 attrd/legacy.c     crm_xml_add(msg, F_TYPE, T_ATTRD);
msg              1212 attrd/legacy.c     crm_xml_add(msg, F_ORIG, attrd_uname);
msg              1213 attrd/legacy.c     crm_xml_add(msg, F_ATTRD_TASK, "flush");
msg              1214 attrd/legacy.c     crm_xml_add(msg, F_ATTRD_ATTRIBUTE, hash_entry->id);
msg              1215 attrd/legacy.c     crm_xml_add(msg, F_ATTRD_SET, hash_entry->set);
msg              1216 attrd/legacy.c     crm_xml_add(msg, F_ATTRD_SECTION, hash_entry->section);
msg              1217 attrd/legacy.c     crm_xml_add(msg, F_ATTRD_DAMPEN, hash_entry->dampen);
msg              1218 attrd/legacy.c     crm_xml_add(msg, F_ATTRD_VALUE, hash_entry->value);
msg              1221 attrd/legacy.c         crm_xml_add(msg, F_ATTRD_USER, hash_entry->user);
msg              1226 attrd/legacy.c         crm_xml_add(msg, F_ATTRD_IGNORE_LOCALLY, hash_entry->value);
msg              1230 attrd/legacy.c     send_cluster_message(NULL, crm_msg_attrd, msg, FALSE);
msg              1231 attrd/legacy.c     free_xml(msg);
msg                55 attrd/main.c                    uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len)
msg                60 attrd/main.c       char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from);
msg                96 attrd/main.c   attrd_cib_replaced_cb(const char *event, xmlNode * msg)
msg               125 attrd/main.c   attrd_erase_cb(xmlNode *msg, int call_id, int rc, xmlNode *output,
msg               874 cib/callbacks.c send_peer_reply(xmlNode * msg, xmlNode * result_diff, const char *originator, gboolean broadcast)
msg               876 cib/callbacks.c     CRM_ASSERT(msg != NULL);
msg               906 cib/callbacks.c         crm_xml_add(msg, F_CIB_ISREPLY, originator);
msg               907 cib/callbacks.c         crm_xml_add(msg, F_CIB_GLOBAL_UPDATE, XML_BOOLEAN_TRUE);
msg               908 cib/callbacks.c         crm_xml_add(msg, F_CIB_OPERATION, CIB_OP_APPLY_DIFF);
msg               909 cib/callbacks.c         crm_xml_add(msg, F_CIB_USER, CRM_DAEMON_USER);
msg               915 cib/callbacks.c         add_message_xml(msg, F_CIB_UPDATE_DIFF, result_diff);
msg               916 cib/callbacks.c         crm_log_xml_explicit(msg, "copy");
msg               917 cib/callbacks.c         return send_cluster_message(NULL, crm_msg_cib, msg, TRUE);
msg               922 cib/callbacks.c         crm_xml_add(msg, F_CIB_ISREPLY, originator);
msg               923 cib/callbacks.c         return send_cluster_message(crm_get_peer(0, originator), crm_msg_cib, msg, FALSE);
msg              1431 cib/callbacks.c cib_ha_peer_callback(HA_Message * msg, void *private_data)
msg              1433 cib/callbacks.c     xmlNode *xml = convert_ha_message(NULL, msg, __FUNCTION__);
msg              1441 cib/callbacks.c cib_peer_callback(xmlNode * msg, void *private_data)
msg              1444 cib/callbacks.c     const char *originator = crm_element_value(msg, F_ORIG);
msg              1450 cib/callbacks.c         if (!(crm_element_value_int(msg, F_CIB_LOCAL_NOTIFY_ID, &bcast_id))) {
msg              1460 cib/callbacks.c     if (crm_element_value(msg, F_CIB_CLIENTNAME) == NULL) {
msg              1461 cib/callbacks.c         crm_xml_add(msg, F_CIB_CLIENTNAME, originator);
msg              1465 cib/callbacks.c     cib_process_request(msg, FALSE, TRUE, TRUE, NULL);
msg              1470 cib/callbacks.c         const char *seq = crm_element_value(msg, F_SEQ);
msg              1471 cib/callbacks.c         const char *op = crm_element_value(msg, F_CIB_OPERATION);
msg                70 cib/callbacks.h extern void cib_peer_callback(xmlNode * msg, void *private_data);
msg                83 cib/callbacks.h extern void cib_ha_peer_callback(HA_Message * msg, void *private_data);
msg                60 cib/cibmon.c   void cibmon_diff(const char *event, xmlNode * msg);
msg               199 cib/cibmon.c   cibmon_diff(const char *event, xmlNode * msg)
msg               207 cib/cibmon.c       xmlNode *update = get_message_xml(msg, F_CIB_UPDATE);
msg               209 cib/cibmon.c       if (msg == NULL) {
msg               214 cib/cibmon.c       crm_element_value_int(msg, F_CIB_RC, &rc);
msg               215 cib/cibmon.c       op = crm_element_value(msg, F_CIB_OPERATION);
msg               216 cib/cibmon.c       diff = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg               245 cib/common.c   cib_msg_copy(xmlNode * msg, gboolean with_data)
msg               291 cib/common.c           value = crm_element_value(msg, field);
msg               298 cib/common.c           value_struct = get_message_xml(msg, field);
msg                21 cib/common.h   extern xmlNode *cib_msg_copy(xmlNode * msg, gboolean with_data);
msg               377 cib/main.c                      uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len)
msg               382 cib/main.c         char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from);
msg                64 cib/messages.c extern xmlNode *cib_msg_copy(const xmlNode * msg, gboolean with_data);
msg                44 cib/notify.c       xmlNode *msg;
msg                49 cib/notify.c   void attach_cib_generation(xmlNode * msg, const char *field, xmlNode * a_cib);
msg                95 cib/notify.c       type = crm_element_value(update->msg, F_SUBTYPE);
msg               128 cib/notify.c                   crm_remote_send(client->remote, update->msg);
msg               148 cib/notify.c           update.msg = xml;
msg               324 cib/notify.c   attach_cib_generation(xmlNode * msg, const char *field, xmlNode * a_cib)
msg               331 cib/notify.c       add_message_xml(msg, field, generation);
msg               566 cib/remote.c   construct_pam_passwd(int num_msg, const struct pam_message **msg,
msg               580 cib/remote.c           switch (msg[count]->msg_style) {
msg               582 cib/remote.c                   crm_info("PAM: %s", msg[count]->msg);
msg               595 cib/remote.c                   crm_err("Unhandled conversation type: %d", msg[count]->msg_style);
msg               608 cib/remote.c               switch (msg[count]->msg_style) {
msg                60 crmd/callbacks.c crmd_ha_msg_filter(xmlNode * msg)
msg                63 crmd/callbacks.c         const char *sys_from = crm_element_value(msg, F_CRM_SYS_FROM);
msg                66 crmd/callbacks.c             const char *from = crm_element_value(msg, F_ORIG);
msg                70 crmd/callbacks.c                 const char *op = crm_element_value(msg, F_CRM_TASK);
msg                77 crmd/callbacks.c                     new_input.msg = msg;
msg                88 crmd/callbacks.c         const char *sys_to = crm_element_value(msg, F_CRM_SYS_TO);
msg                96 crmd/callbacks.c     route_message(C_HA_MESSAGE, msg);
msg                39 crmd/cib.c     do_cib_updated(const char *event, xmlNode * msg)
msg                41 crmd/cib.c         if (crm_patchset_contains_alert(msg, TRUE)) {
msg                47 crmd/cib.c     revision_check_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg                80 crmd/cib.c     do_cib_replaced(const char *event, xmlNode * msg)
msg               221 crmd/control.c     xmlNode *msg = NULL;
msg               226 crmd/control.c     msg = create_request(CRM_OP_SHUTDOWN_REQ, NULL, NULL, CRM_SYSTEM_CRMD, CRM_SYSTEM_CRMD, NULL);
msg               229 crmd/control.c     if (send_cluster_message(NULL, crm_msg_crmd, msg, TRUE) == FALSE) {
msg               232 crmd/control.c     free_xml(msg);
msg               714 crmd/control.c     xmlNode *msg = crm_ipcs_recv(client, data, size, &id, &flags);
msg               719 crmd/control.c     if (msg == NULL) {
msg               725 crmd/control.c     crm_acl_get_set_user(msg, F_CRM_USER, client->user);
msg               729 crmd/control.c     crm_log_xml_trace(msg, "CRMd[inbound]");
msg               731 crmd/control.c     crm_xml_add(msg, F_CRM_SYS_FROM, client->id);
msg               732 crmd/control.c     if (crmd_authorize_message(msg, client, NULL)) {
msg               733 crmd/control.c         route_message(C_IPC_MESSAGE, msg);
msg               737 crmd/control.c     free_xml(msg);
msg               851 crmd/control.c             HA_Message *msg = NULL;
msg               854 crmd/control.c             msg = fsa_cluster_conn->llc_ops->readmsg(fsa_cluster_conn, 0);
msg               855 crmd/control.c             if (msg != NULL) {
msg               857 crmd/control.c                 ha_msg_del(msg);
msg               996 crmd/control.c config_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg                47 crmd/corosync.c                          uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len)
msg                57 crmd/corosync.c     char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from);
msg                21 crmd/crmd_callbacks.h extern void crmd_ha_msg_filter(xmlNode * msg);
msg                35 crmd/crmd_callbacks.h extern void msg_ccm_join(const xmlNode * msg, void *foo);
msg                28 crmd/crmd_messages.h     xmlNode *msg;
msg                89 crmd/crmd_messages.h extern void process_message(xmlNode * msg, gboolean originated_locally, const char *src_node_name);
msg                97 crmd/crmd_messages.h extern gboolean send_msg_via_ipc(xmlNode * msg, const char *sys);
msg               104 crmd/crmd_messages.h void crmd_proxy_send(const char *session, xmlNode *msg);
msg               108 crmd/crmd_messages.h extern gboolean send_request(xmlNode * msg, char **msg_reference);
msg                87 crmd/crmd_utils.h gboolean update_dc(xmlNode * msg);
msg               116 crmd/election.c     rc = election_count_vote(fsa_election, vote->msg, cur_state != S_STARTING);
msg               153 crmd/election.c feature_update_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg                81 crmd/fsa.c     void dump_rsc_info_callback(const xmlNode * msg, int call_id, int rc,
msg               474 crmd/heartbeat.c     xmlNode *msg = convert_ha_message(NULL, hamsg, __FUNCTION__);
msg               475 crmd/heartbeat.c     const char *from = crm_element_value(msg, F_ORIG);
msg               476 crmd/heartbeat.c     const char *op = crm_element_value(msg, F_CRM_TASK);
msg               477 crmd/heartbeat.c     const char *sys_from = crm_element_value(msg, F_CRM_SYS_FROM);
msg               479 crmd/heartbeat.c     CRM_CHECK(from != NULL, crm_log_xml_err(msg, "anon"); goto bail);
msg               486 crmd/heartbeat.c         crm_log_xml_trace(msg, "HA[inbound]: Ignore (No CCM)");
msg               505 crmd/heartbeat.c         crm_log_xml_trace(msg, "HA[inbound]: CCM Discard");
msg               508 crmd/heartbeat.c         crmd_ha_msg_filter(msg);
msg               512 crmd/heartbeat.c     free_xml(msg);
msg                29 crmd/join_client.c void join_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data);
msg                44 crmd/join_client.c update_dc_expected(xmlNode *msg)
msg                46 crmd/join_client.c     if (fsa_our_dc && crm_is_true(crm_element_value(msg, F_CRM_DC_LEAVING))) {
msg               123 crmd/join_client.c     const char *welcome_from = crm_element_value(input->msg, F_CRM_HOST_FROM);
msg               124 crmd/join_client.c     const char *join_id = crm_element_value(input->msg, F_CRM_JOIN_ID);
msg               136 crmd/join_client.c               welcome_from, crm_element_value(input->msg, F_CRM_JOIN_ID));
msg               145 crmd/join_client.c     if (update_dc(input->msg) == FALSE) {
msg               151 crmd/join_client.c     update_dc_expected(input->msg);
msg               163 crmd/join_client.c join_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               241 crmd/join_client.c     const char *op = crm_element_value(input->msg, F_CRM_TASK);
msg               242 crmd/join_client.c     const char *ack_nack = crm_element_value(input->msg, CRM_OP_JOIN_ACKNAK);
msg               243 crmd/join_client.c     const char *welcome_from = crm_element_value(input->msg, F_CRM_HOST_FROM);
msg               255 crmd/join_client.c     crm_element_value_int(input->msg, F_CRM_JOIN_ID, &join_id);
msg               269 crmd/join_client.c     if (update_dc(input->msg) == FALSE) {
msg               275 crmd/join_client.c     update_dc_expected(input->msg);
msg                36 crmd/join_dc.c void finalize_sync_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data);
msg               119 crmd/join_dc.c     xmlNode *msg = create_request(join_op, NULL, host_to, CRM_SYSTEM_CRMD,
msg               123 crmd/join_dc.c     crm_xml_add_int(msg, F_CRM_JOIN_ID, current_join_id);
msg               128 crmd/join_dc.c     crm_xml_add_boolean(msg, F_CRM_DC_LEAVING,
msg               130 crmd/join_dc.c     return msg;
msg               241 crmd/join_dc.c     join_to = crm_element_value(welcome->msg, F_CRM_HOST_FROM);
msg               248 crmd/join_dc.c     op = crm_element_value(welcome->msg, F_CRM_TASK);
msg               316 crmd/join_dc.c     const char *join_from = crm_element_value(join_ack->msg, F_CRM_HOST_FROM);
msg               317 crmd/join_dc.c     const char *ref = crm_element_value(join_ack->msg, F_CRM_REFERENCE);
msg               324 crmd/join_dc.c     crm_element_value_int(join_ack->msg, F_CRM_JOIN_ID, &join_id);
msg               460 crmd/join_dc.c finalize_sync_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               489 crmd/join_dc.c join_update_complete_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               499 crmd/join_dc.c         crm_log_xml_debug(msg, "failed");
msg               515 crmd/join_dc.c     const char *op = crm_element_value(join_ack->msg, F_CRM_TASK);
msg               516 crmd/join_dc.c     const char *join_from = crm_element_value(join_ack->msg, F_CRM_HOST_FROM);
msg               525 crmd/join_dc.c     crm_element_value_int(join_ack->msg, F_CRM_JOIN_ID, &join_id);
msg                59 crmd/lrm.c                               xmlNode * msg, xmlNode * request);
msg               881 crmd/lrm.c         const char *from_sys = crm_element_value(input->msg, F_CRM_SYS_FROM);
msg               882 crmd/lrm.c         const char *from_host = crm_element_value(input->msg, F_CRM_HOST_FROM);
msg              1329 crmd/lrm.c                 char *ref = crm_element_value_copy(request->msg, XML_ATTR_REFERENCE);
msg              1510 crmd/lrm.c         user_name = crm_acl_get_set_user(input->msg, F_CRM_USER, NULL);
msg              1514 crmd/lrm.c         crm_op = crm_element_value(input->msg, F_CRM_TASK);
msg              1515 crmd/lrm.c         from_sys = crm_element_value(input->msg, F_CRM_SYS_FROM);
msg              1517 crmd/lrm.c             from_host = crm_element_value(input->msg, F_CRM_HOST_FROM);
msg              1576 crmd/lrm.c                 crm_log_xml_warn(input->msg, "bad input");
msg              1611 crmd/lrm.c             xmlNode *reply = create_reply(input->msg, data);
msg              1664 crmd/lrm.c                 crm_log_xml_warn(input->msg, "bad input");
msg              1790 crmd/lrm.c                 do_lrm_rsc_op(lrm_state, rsc, operation, input->xml, input->msg);
msg              2100 crmd/lrm.c     do_lrm_rsc_op(lrm_state_t * lrm_state, lrmd_rsc_info_t * rsc, const char *operation, xmlNode * msg,
msg              2115 crmd/lrm.c         if (msg != NULL) {
msg              2116 crmd/lrm.c             transition = crm_element_value(msg, XML_ATTR_TRANSITION_KEY);
msg              2118 crmd/lrm.c                 crm_log_xml_err(msg, "Missing transition number");
msg              2122 crmd/lrm.c         op = construct_op(lrm_state, msg, rsc->id, operation);
msg              2270 crmd/lrm.c     cib_rsc_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg                37 crmd/lrm_state.c int lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg);
msg                38 crmd/lrm_state.c void lrmd_internal_set_proxy_callback(lrmd_t * lrmd, void *userdata, void (*callback)(lrmd_t *lrmd, void *userdata, xmlNode *msg));
msg               433 crmd/lrm_state.c crmd_proxy_send(const char *session, xmlNode *msg)
msg               441 crmd/lrm_state.c     crm_log_xml_trace(msg, "to-proxy");
msg               445 crmd/lrm_state.c         remote_proxy_relay_event(proxy, msg);
msg               450 crmd/lrm_state.c crmd_proxy_dispatch(const char *session, xmlNode *msg)
msg               453 crmd/lrm_state.c     crm_log_xml_trace(msg, "CRMd-PROXY[inbound]");
msg               455 crmd/lrm_state.c     crm_xml_add(msg, F_CRM_SYS_FROM, session);
msg               456 crmd/lrm_state.c     if (crmd_authorize_message(msg, NULL, session)) {
msg               457 crmd/lrm_state.c         route_message(C_IPC_MESSAGE, msg);
msg               464 crmd/lrm_state.c remote_config_check(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               492 crmd/lrm_state.c crmd_remote_proxy_cb(lrmd_t *lrmd, void *userdata, xmlNode *msg)
msg               495 crmd/lrm_state.c     const char *session = crm_element_value(msg, F_LRMD_IPC_SESSION);
msg               498 crmd/lrm_state.c     const char *op = crm_element_value(msg, F_LRMD_IPC_OP);
msg               500 crmd/lrm_state.c         const char *channel = crm_element_value(msg, F_LRMD_IPC_IPC_SERVER);
msg               540 crmd/lrm_state.c         xmlNode *request = get_message_xml(msg, F_LRMD_IPC_MSG);
msg               550 crmd/lrm_state.c         crm_element_value_int(msg, F_LRMD_IPC_MSG_FLAGS, &flags);
msg               558 crmd/lrm_state.c             crm_element_value_int(msg, F_LRMD_IPC_MSG_ID, &msg_id);
msg               565 crmd/lrm_state.c         remote_proxy_cb(lrmd, lrm_state->node_name, msg);
msg                43 crmd/main.c    void crmd_hamsg_callback(const xmlNode * msg, void *private_data);
msg               110 crmd/membership.c crmd_node_update_complete(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               121 crmd/membership.c         crm_log_xml_debug(msg, "failed");
msg               126 crmd/membership.c         crm_log_xml_debug(msg, "failed");
msg               204 crmd/membership.c remove_conflicting_node_callback(xmlNode * msg, int call_id, int rc,
msg               215 crmd/membership.c search_conflicting_node_callback(xmlNode * msg, int call_id, int rc,
msg               295 crmd/membership.c node_list_update_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               301 crmd/membership.c         crm_log_xml_debug(msg, "update:failed");
msg               306 crmd/membership.c         crm_log_xml_debug(msg, "update:failed");
msg               404 crmd/membership.c cib_quorum_update_complete(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               413 crmd/membership.c         crm_log_xml_debug(msg, "failed");
msg               136 crmd/messages.c                 CRM_CHECK(((ha_msg_input_t *) data)->msg != NULL,
msg               215 crmd/messages.c         data = copy_xml(orig->msg);
msg               221 crmd/messages.c     if (orig && orig->msg != NULL) {
msg               222 crmd/messages.c         CRM_CHECK(copy->msg != NULL, crm_err("copy failed"));
msg               317 crmd/messages.c     route_message(msg_data->fsa_cause, input->msg);
msg               326 crmd/messages.c     fsa_input.msg = input;
msg               359 crmd/messages.c relay_message(xmlNode * msg, gboolean originated_locally)
msg               369 crmd/messages.c     const char *host_to = crm_element_value(msg, F_CRM_HOST_TO);
msg               370 crmd/messages.c     const char *sys_to = crm_element_value(msg, F_CRM_SYS_TO);
msg               371 crmd/messages.c     const char *sys_from = crm_element_value(msg, F_CRM_SYS_FROM);
msg               372 crmd/messages.c     const char *type = crm_element_value(msg, F_TYPE);
msg               375 crmd/messages.c     crm_trace("Routing message %s", crm_element_value(msg, XML_ATTR_REFERENCE));
msg               377 crmd/messages.c     if (msg == NULL) {
msg               380 crmd/messages.c     } else if (safe_str_eq(CRM_OP_HELLO, crm_element_value(msg, F_CRM_TASK))) {
msg               394 crmd/messages.c         crm_log_xml_warn(msg, "bad msg");
msg               428 crmd/messages.c             send_msg_via_ipc(msg, sys_to);
msg               449 crmd/messages.c             send_cluster_message(host_to ? crm_get_peer(0, host_to) : NULL, dest, msg, TRUE);
msg               462 crmd/messages.c         send_msg_via_ipc(msg, sys_to);
msg               486 crmd/messages.c         send_cluster_message(host_to ? node_to : NULL, dest, msg, TRUE);
msg               601 crmd/messages.c handle_message(xmlNode * msg, enum crmd_fsa_cause cause)
msg               605 crmd/messages.c     CRM_CHECK(msg != NULL, return I_NULL);
msg               607 crmd/messages.c     type = crm_element_value(msg, F_CRM_MSG_TYPE);
msg               609 crmd/messages.c         return handle_request(msg, cause);
msg               612 crmd/messages.c         handle_response(msg);
msg               670 crmd/messages.c handle_remote_state(xmlNode *msg)
msg               672 crmd/messages.c     const char *remote_uname = ID(msg);
msg               673 crmd/messages.c     const char *remote_is_up = crm_element_value(msg, XML_NODE_IN_CLUSTER);
msg               690 crmd/messages.c     xmlNode *msg = NULL;
msg               754 crmd/messages.c         fsa_input.msg = stored_msg;
msg               775 crmd/messages.c         fsa_input.msg = stored_msg;
msg               847 crmd/messages.c         msg = create_reply(stored_msg, ping);
msg               848 crmd/messages.c         if (msg) {
msg               849 crmd/messages.c             (void)relay_message(msg, TRUE);
msg               853 crmd/messages.c         free_xml(msg);
msg               863 crmd/messages.c             msg = create_request(CRM_OP_RM_NODE_CACHE, NULL, NULL, CRM_SYSTEM_CRMD, CRM_SYSTEM_CRMD, NULL);
msg               864 crmd/messages.c             if (send_cluster_message(NULL, crm_msg_crmd, msg, TRUE) == FALSE) {
msg               869 crmd/messages.c             free_xml(msg);
msg               912 crmd/messages.c             fsa_input.msg = stored_msg;
msg               962 crmd/messages.c extern gboolean process_te_message(xmlNode * msg, xmlNode * xml_data);
msg               965 crmd/messages.c send_msg_via_ipc(xmlNode * msg, const char *sys)
msg               970 crmd/messages.c     if (crm_element_value(msg, F_CRM_HOST_FROM) == NULL) {
msg               971 crmd/messages.c         crm_xml_add(msg, F_CRM_HOST_FROM, fsa_our_uname);
msg               976 crmd/messages.c         send_ok = crm_ipcs_send(client_channel, 0, msg, crm_ipc_server_event);
msg               979 crmd/messages.c         xmlNode *data = get_message_xml(msg, F_CRM_DATA);
msg               981 crmd/messages.c         process_te_message(msg, data);
msg               987 crmd/messages.c         fsa_input.msg = msg;
msg               988 crmd/messages.c         fsa_input.xml = get_message_xml(msg, F_CRM_DATA);
msg              1004 crmd/messages.c         crmd_proxy_send(sys, msg);
msg              1020 crmd/messages.c     input_copy->msg = orig;
msg              1021 crmd/messages.c     input_copy->xml = get_message_xml(input_copy->msg, F_CRM_DATA);
msg              1031 crmd/messages.c     free_xml(orig->msg);
msg              1050 crmd/messages.c         xmlNode *msg = create_request(CRM_OP_REMOTE_STATE, NULL, fsa_our_dc,
msg              1055 crmd/messages.c         crm_xml_add(msg, XML_ATTR_ID, node_name);
msg              1056 crmd/messages.c         crm_xml_add_boolean(msg, XML_NODE_IN_CLUSTER, node_up);
msg              1057 crmd/messages.c         send_cluster_message(crm_get_peer(0, fsa_our_dc), crm_msg_crmd, msg,
msg              1059 crmd/messages.c         free_xml(msg);
msg                51 crmd/misc.c            crm_log_xml_debug(input->msg, __FUNCTION__);
msg                35 crmd/pengine.c void do_pe_invoke_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data);
msg                38 crmd/pengine.c save_cib_contents(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               110 crmd/pengine.c     xmlNode *msg = string2xml(buffer);
msg               112 crmd/pengine.c     if (msg) {
msg               113 crmd/pengine.c         route_message(C_IPC_MESSAGE, msg);
msg               116 crmd/pengine.c     free_xml(msg);
msg               284 crmd/pengine.c do_pe_invoke_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               465 crmd/te_actions.c             .msg = cmd,
msg               469 crmd/te_actions.c         fsa_data_t msg = {
msg               479 crmd/te_actions.c         do_lrm_invoke(A_LRM_INVOKE, C_FSA_INTERNAL, fsa_state, I_NULL, &msg);
msg                33 crmd/te_callbacks.c void te_update_confirm(const char *event, xmlNode * msg);
msg               365 crmd/te_callbacks.c te_update_diff(const char *event, xmlNode * msg)
msg               377 crmd/te_callbacks.c     CRM_CHECK(msg != NULL, return);
msg               378 crmd/te_callbacks.c     crm_element_value_int(msg, F_CIB_RC, &rc);
msg               396 crmd/te_callbacks.c     op = crm_element_value(msg, F_CIB_OPERATION);
msg               397 crmd/te_callbacks.c     diff = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg               578 crmd/te_callbacks.c process_te_message(xmlNode * msg, xmlNode * xml_data)
msg               580 crmd/te_callbacks.c     const char *from = crm_element_value(msg, F_ORIG);
msg               581 crmd/te_callbacks.c     const char *sys_to = crm_element_value(msg, F_CRM_SYS_TO);
msg               582 crmd/te_callbacks.c     const char *sys_from = crm_element_value(msg, F_CRM_SYS_FROM);
msg               583 crmd/te_callbacks.c     const char *ref = crm_element_value(msg, F_CRM_REFERENCE);
msg               584 crmd/te_callbacks.c     const char *op = crm_element_value(msg, F_CRM_TASK);
msg               585 crmd/te_callbacks.c     const char *type = crm_element_value(msg, F_CRM_MSG_TYPE);
msg               588 crmd/te_callbacks.c     crm_log_xml_trace(msg, "ipc");
msg               603 crmd/te_callbacks.c         crm_log_xml_trace(msg, "Processing (N)ACK");
msg               604 crmd/te_callbacks.c         crm_debug("Processing (N)ACK %s from %s", crm_element_value(msg, F_CRM_REFERENCE), from);
msg               619 crmd/te_callbacks.c             crm_log_xml_err(msg, "Invalid (N)ACK");
msg               853 crmd/te_callbacks.c cib_fencing_updated(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               858 crmd/te_callbacks.c         crm_log_xml_warn(msg, "Failed update");
msg               867 crmd/te_callbacks.c cib_action_updated(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg                21 crmd/te_callbacks.h extern void cib_fencing_updated(xmlNode * msg, int call_id, int rc,
msg                24 crmd/te_callbacks.h extern void cib_action_updated(xmlNode * msg, int call_id, int rc,
msg                32 crmd/te_callbacks.h extern void te_update_diff(const char *event, xmlNode * msg);
msg                37 crmd/tengine.c global_cib_callback(const xmlNode * msg, int callid, int rc, xmlNode * output)
msg               159 crmd/tengine.c         const char *ref = crm_element_value(input->msg, XML_ATTR_REFERENCE);
msg               160 crmd/tengine.c         const char *graph_file = crm_element_value(input->msg, F_CRM_TGRAPH);
msg               161 crmd/tengine.c         const char *graph_input = crm_element_value(input->msg, F_CRM_TGRAPH_INPUT);
msg               164 crmd/tengine.c             crm_log_xml_err(input->msg, "Bad command");
msg               193 crmd/tengine.c                   crm_log_xml_err(input->msg, "Bad command");
msg                50 crmd/tengine.h extern gboolean process_te_message(xmlNode * msg, xmlNode * xml_data);
msg               922 crmd/utils.c   update_dc(xmlNode * msg)
msg               928 crmd/utils.c       if (msg != NULL) {
msg               931 crmd/utils.c           dc_version = crm_element_value(msg, F_CRM_VERSION);
msg               932 crmd/utils.c           welcome_from = crm_element_value(msg, F_CRM_HOST_FROM);
msg               988 crmd/utils.c   erase_xpath_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               242 fencing/commands.c create_async_command(xmlNode * msg)
msg               245 fencing/commands.c     xmlNode *op = get_xpath_object("//@" F_STONITH_ACTION, msg, LOG_ERR);
msg               248 fencing/commands.c     CRM_CHECK(action != NULL, crm_log_xml_warn(msg, "NoAction"); return NULL);
msg               250 fencing/commands.c     crm_log_xml_trace(msg, "Command");
msg               252 fencing/commands.c     crm_element_value_int(msg, F_STONITH_CALLID, &(cmd->id));
msg               253 fencing/commands.c     crm_element_value_int(msg, F_STONITH_CALLOPTS, &(cmd->options));
msg               254 fencing/commands.c     crm_element_value_int(msg, F_STONITH_TIMEOUT, &(cmd->default_timeout));
msg               257 fencing/commands.c     cmd->origin = crm_element_value_copy(msg, F_ORIG);
msg               258 fencing/commands.c     cmd->remote_op_id = crm_element_value_copy(msg, F_STONITH_REMOTE_OP_ID);
msg               259 fencing/commands.c     cmd->client = crm_element_value_copy(msg, F_STONITH_CLIENTID);
msg               260 fencing/commands.c     cmd->client_name = crm_element_value_copy(msg, F_STONITH_CLIENTNAME);
msg               261 fencing/commands.c     cmd->op = crm_element_value_copy(msg, F_STONITH_OPERATION);
msg               267 fencing/commands.c     CRM_CHECK(cmd->op != NULL, crm_log_xml_warn(msg, "NoOp"); free_async_command(cmd); return NULL);
msg               268 fencing/commands.c     CRM_CHECK(cmd->client != NULL, crm_log_xml_warn(msg, "NoClient"));
msg               887 fencing/commands.c build_device_from_xml(xmlNode * msg)
msg               890 fencing/commands.c     xmlNode *dev = get_xpath_object("//" F_STONITH_DEVICE, msg, LOG_ERR);
msg              1148 fencing/commands.c stonith_device_register(xmlNode * msg, const char **desc, gboolean from_cib)
msg              1151 fencing/commands.c     stonith_device_t *device = build_device_from_xml(msg);
msg              1359 fencing/commands.c stonith_level_register(xmlNode *msg, char **desc)
msg              1374 fencing/commands.c     if (safe_str_eq(TYPE(msg), XML_TAG_FENCING_LEVEL)) {
msg              1375 fencing/commands.c         level = msg;
msg              1377 fencing/commands.c         level = get_xpath_object("//" XML_TAG_FENCING_LEVEL, msg, LOG_ERR);
msg              1434 fencing/commands.c stonith_level_remove(xmlNode *msg, char **desc)
msg              1441 fencing/commands.c     xmlNode *level = get_xpath_object("//" XML_TAG_FENCING_LEVEL, msg, LOG_ERR);
msg              1479 fencing/commands.c stonith_device_action(xmlNode * msg, char **output)
msg              1482 fencing/commands.c     xmlNode *dev = get_xpath_object("//" F_STONITH_DEVICE, msg, LOG_ERR);
msg              1497 fencing/commands.c         cmd = create_async_command(msg);
msg              1940 fencing/commands.c stonith_query(xmlNode * msg, const char *remote_peer, const char *client_id, int call_options)
msg              1946 fencing/commands.c     xmlNode *dev = get_xpath_object("//@" F_STONITH_ACTION, msg, LOG_DEBUG_3);
msg              1948 fencing/commands.c     crm_element_value_int(msg, F_STONITH_TIMEOUT, &timeout);
msg              1960 fencing/commands.c     crm_log_xml_debug(msg, "Query");
msg              1963 fencing/commands.c     query->reply = stonith_construct_reply(msg, NULL, NULL, pcmk_ok);
msg              2269 fencing/commands.c stonith_fence(xmlNode * msg)
msg              2273 fencing/commands.c     async_command_t *cmd = create_async_command(msg);
msg              2274 fencing/commands.c     xmlNode *dev = get_xpath_object("//@" F_STONITH_TARGET, msg, LOG_ERR);
msg               178 fencing/internal.h int stonith_device_register(xmlNode * msg, const char **desc, gboolean from_cib);
msg               182 fencing/internal.h char *stonith_level_key(xmlNode * msg, int mode);
msg               183 fencing/internal.h int stonith_level_kind(xmlNode * msg);
msg               184 fencing/internal.h int stonith_level_register(xmlNode * msg, char **desc);
msg               186 fencing/internal.h int stonith_level_remove(xmlNode * msg, char **desc);
msg               206 fencing/internal.h int process_remote_stonith_exec(xmlNode * msg);
msg               208 fencing/internal.h int process_remote_stonith_query(xmlNode * msg);
msg               212 fencing/internal.h int stonith_fence_history(xmlNode * msg, xmlNode ** output);
msg               220 fencing/internal.h int stonith_manual_ack(xmlNode * msg, remote_fencing_op_t * op);
msg               183 fencing/main.c stonith_peer_callback(xmlNode * msg, void *private_data)
msg               185 fencing/main.c     const char *remote_peer = crm_element_value(msg, F_ORIG);
msg               186 fencing/main.c     const char *op = crm_element_value(msg, F_STONITH_OPERATION);
msg               192 fencing/main.c     crm_log_xml_trace(msg, "Peer[inbound]");
msg               193 fencing/main.c     stonith_command(NULL, 0, 0, msg, remote_peer);
msg               198 fencing/main.c stonith_peer_hb_callback(HA_Message * msg, void *private_data)
msg               200 fencing/main.c     xmlNode *xml = convert_ha_message(NULL, msg, __FUNCTION__);
msg               222 fencing/main.c                           uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len)
msg               227 fencing/main.c     char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from);
msg               746 fencing/main.c update_cib_stonith_devices_v2(const char *event, xmlNode * msg)
msg               751 fencing/main.c     xmlNode *patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg               809 fencing/main.c update_cib_stonith_devices_v1(const char *event, xmlNode * msg)
msg               816 fencing/main.c     xpath_obj = xpath_search(msg, "//" F_CIB_UPDATE_RESULT "//" XML_CONS_TAG_RSC_LOCATION);
msg               833 fencing/main.c     xpath_obj = xpath_search(msg, "//" F_CIB_UPDATE_RESULT "//" XML_TAG_DIFF_REMOVED "//" XML_CIB_TAG_RESOURCE);
msg               840 fencing/main.c     xpath_obj = xpath_search(msg, "//" F_CIB_UPDATE_RESULT "//" XML_TAG_DIFF_ADDED "//" XML_CIB_TAG_RESOURCE);
msg               870 fencing/main.c update_cib_stonith_devices(const char *event, xmlNode * msg)
msg               873 fencing/main.c     xmlNode *patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg               879 fencing/main.c             update_cib_stonith_devices_v1(event, msg);
msg               882 fencing/main.c             update_cib_stonith_devices_v2(event, msg);
msg               927 fencing/main.c update_fencing_topology(const char *event, xmlNode * msg)
msg               932 fencing/main.c     xmlNode *patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg               940 fencing/main.c         xpathObj = xpath_search(msg, xpath);
msg               947 fencing/main.c         xpathObj = xpath_search(msg, xpath);
msg              1024 fencing/main.c update_cib_cache_cb(const char *event, xmlNode * msg)
msg              1036 fencing/main.c     } else if(msg == NULL) {
msg              1048 fencing/main.c         crm_element_value_int(msg, F_CIB_RC, &rc);
msg              1053 fencing/main.c         patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg              1123 fencing/main.c         update_fencing_topology(event, msg);
msg              1124 fencing/main.c         update_cib_stonith_devices(event, msg);
msg              1129 fencing/main.c init_cib_cache_cb(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               906 fencing/remote.c stonith_manual_ack(xmlNode * msg, remote_fencing_op_t * op)
msg               908 fencing/remote.c     xmlNode *dev = get_xpath_object("//@" F_STONITH_TARGET, msg, LOG_ERR);
msg               917 fencing/remote.c     remote_op_done(op, msg, pcmk_ok, FALSE);
msg              1393 fencing/remote.c advance_op_topology(remote_fencing_op_t *op, const char *device, xmlNode *msg,
msg              1431 fencing/remote.c         remote_op_done(op, msg, rc, FALSE);
msg              1811 fencing/remote.c process_remote_stonith_query(xmlNode * msg)
msg              1821 fencing/remote.c     xmlNode *dev = get_xpath_object("//@" F_STONITH_REMOTE_OP_ID, msg, LOG_ERR);
msg              1828 fencing/remote.c     dev = get_xpath_object("//@" F_STONITH_AVAILABLE_DEVICES, msg, LOG_ERR);
msg              1843 fencing/remote.c     host = crm_element_value(msg, F_ORIG);
msg              1907 fencing/remote.c process_remote_stonith_exec(xmlNode * msg)
msg              1913 fencing/remote.c     xmlNode *dev = get_xpath_object("//@" F_STONITH_REMOTE_OP_ID, msg, LOG_ERR);
msg              1920 fencing/remote.c     dev = get_xpath_object("//@" F_STONITH_RC, msg, LOG_ERR);
msg              1952 fencing/remote.c     if (safe_str_eq(crm_element_value(msg, F_SUBTYPE), "broadcast")) {
msg              1961 fencing/remote.c         remote_op_done(op, msg, rc, FALSE);
msg              1973 fencing/remote.c         const char *device = crm_element_value(msg, F_STONITH_DEVICE);
msg              1982 fencing/remote.c             remote_op_done(op, msg, rc, FALSE);
msg              1998 fencing/remote.c             advance_op_topology(op, device, msg, rc);
msg              2005 fencing/remote.c                 remote_op_done(op, msg, rc, FALSE);
msg              2013 fencing/remote.c         remote_op_done(op, msg, rc, FALSE);
msg              2018 fencing/remote.c         remote_op_done(op, msg, rc, FALSE);
msg              2032 fencing/remote.c stonith_fence_history(xmlNode * msg, xmlNode ** output)
msg              2036 fencing/remote.c     xmlNode *dev = get_xpath_object("//@" F_STONITH_TARGET, msg, LOG_TRACE);
msg              2043 fencing/remote.c         crm_element_value_int(msg, F_STONITH_CALLOPTS, &options);
msg                91 include/crm/cib.h     int (*set_op_callback) (cib_t * cib, void (*callback) (const xmlNode * msg, int callid,
msg                95 include/crm/cib.h                                 void (*callback) (const char *event, xmlNode * msg));
msg                98 include/crm/cib.h                                 void (*callback) (const char *event, xmlNode * msg));
msg               159 include/crm/cib.h     void (*op_callback) (const xmlNode * msg, int call_id, int rc, xmlNode * output);
msg                99 include/crm/cib/internal.h     void (*callback) (const char *event, xmlNode * msg);
msg               134 include/crm/cib/internal.h void cib_native_callback(cib_t * cib, xmlNode * msg, int call_id, int rc);
msg               103 include/crm/cluster.h     void (*hb_dispatch) (HA_Message * msg, void *private);
msg               234 include/crm/cluster.h char *pcmk_message_common_cs(cpg_handle_t handle, uint32_t nodeid, uint32_t pid, void *msg,
msg               208 include/crm/cluster/internal.h #  define ais_data_len(msg) (msg->is_compressed?msg->compressed_size:msg->size)
msg               390 include/crm/cluster/internal.h char *get_ais_data(const AIS_Message * msg);
msg               391 include/crm/cluster/internal.h gboolean check_message_sanity(const AIS_Message * msg, const char *data);
msg               395 include/crm/cluster/internal.h gboolean send_ha_message(ll_cluster_t * hb_conn, xmlNode * msg,
msg               400 include/crm/cluster/internal.h xmlNode *convert_ha_message(xmlNode * parent, HA_Message * msg, const char *field);
msg               415 include/crm/cluster/internal.h void plugin_handle_membership(AIS_Message *msg);
msg               425 include/crm/cluster/internal.h gboolean send_cluster_message_cs(xmlNode * msg, gboolean local,
msg                94 include/crm/common/alerts_internal.h bool crm_patchset_contains_alert(xmlNode *msg, bool config);
msg                54 include/crm/common/xml.h gboolean add_message_xml(xmlNode * msg, const char *field, xmlNode * xml);
msg                55 include/crm/common/xml.h xmlNode *get_message_xml(xmlNode * msg, const char *field);
msg               163 include/crm/common/xml.h char *dump_xml_formatted(xmlNode * msg);
msg               165 include/crm/common/xml.h char *dump_xml_formatted_with_text(xmlNode * msg);
msg               167 include/crm/common/xml.h char *dump_xml_unformatted(xmlNode * msg);
msg               198 include/crm_internal.h int crm_remote_send(crm_remote_t * remote, xmlNode * msg);
msg               380 include/crm_internal.h void remote_proxy_cb(lrmd_t *lrmd, const char *node_name, xmlNode *msg);
msg               388 include/crm_internal.h void remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg);
msg               389 include/crm_internal.h void remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, int msg_id);
msg               113 lib/ais/plugin.c gboolean check_message_sanity(const AIS_Message * msg, const char *data);
msg               128 lib/ais/plugin.c void pcmk_ipc(void *conn, ais_void_ptr * msg);
msg               131 lib/ais/plugin.c void pcmk_cluster_swab(void *msg);
msg               134 lib/ais/plugin.c void pcmk_nodeid(void *conn, ais_void_ptr * msg);
msg               135 lib/ais/plugin.c void pcmk_nodes(void *conn, ais_void_ptr * msg);
msg               136 lib/ais/plugin.c void pcmk_notify(void *conn, ais_void_ptr * msg);
msg               137 lib/ais/plugin.c void pcmk_remove_member(void *conn, ais_void_ptr * msg);
msg               138 lib/ais/plugin.c void pcmk_quorum(void *conn, ais_void_ptr * msg);
msg               140 lib/ais/plugin.c void pcmk_cluster_id_swab(void *msg);
msg               871 lib/ais/plugin.c pcmk_cluster_swab(void *msg)
msg               873 lib/ais/plugin.c     AIS_Message *ais_msg = msg;
msg               921 lib/ais/plugin.c pcmk_cluster_id_swab(void *msg)
msg               923 lib/ais/plugin.c     struct crm_identify_msg_s *ais_msg = msg;
msg               940 lib/ais/plugin.c     const struct crm_identify_msg_s *msg = message;
msg               942 lib/ais/plugin.c     if (nodeid != msg->id) {
msg               943 lib/ais/plugin.c         ais_err("Invalid message: Node %u claimed to be node %d", nodeid, msg->id);
msg               946 lib/ais/plugin.c     ais_debug("Node update: %s (%s)", msg->uname, msg->version);
msg               948 lib/ais/plugin.c         update_member(nodeid, msg->born_on, membership_seq, msg->votes, msg->processes, msg->uname,
msg               949 lib/ais/plugin.c                       NULL, msg->version);
msg               978 lib/ais/plugin.c pcmk_ipc(void *conn, ais_void_ptr * msg)
msg               983 lib/ais/plugin.c     const AIS_Message *ais_msg = (const AIS_Message *)msg;
msg               988 lib/ais/plugin.c     if (check_message_sanity(msg, ((const AIS_Message *)msg)->data) == FALSE) {
msg               991 lib/ais/plugin.c         msg = NULL;
msg              1059 lib/ais/plugin.c     msg = NULL;
msg              1207 lib/ais/plugin.c pcmk_nodes(void *conn, ais_void_ptr * msg)
msg              1216 lib/ais/plugin.c     msg = NULL;
msg              1225 lib/ais/plugin.c pcmk_remove_member(void *conn, ais_void_ptr * msg)
msg              1227 lib/ais/plugin.c     const AIS_Message *ais_msg = msg;
msg              1231 lib/ais/plugin.c     msg = NULL;
msg              1261 lib/ais/plugin.c pcmk_quorum(void *conn, ais_void_ptr * msg)
msg              1264 lib/ais/plugin.c     const AIS_Message *ais_msg = msg;
msg              1268 lib/ais/plugin.c     msg = NULL;
msg              1286 lib/ais/plugin.c pcmk_notify(void *conn, ais_void_ptr * msg)
msg              1288 lib/ais/plugin.c     const AIS_Message *ais_msg = msg;
msg              1296 lib/ais/plugin.c     msg = NULL;
msg              1313 lib/ais/plugin.c pcmk_nodeid(void *conn, ais_void_ptr * msg)
msg              1356 lib/ais/plugin.c check_message_sanity(const AIS_Message * msg, const char *data)
msg              1360 lib/ais/plugin.c     int dest = msg->host.type;
msg              1361 lib/ais/plugin.c     int tmp_size = msg->header.size - sizeof(AIS_Message);
msg              1363 lib/ais/plugin.c     if (sane && msg->header.size == 0) {
msg              1368 lib/ais/plugin.c     if (sane && msg->header.error != CS_OK) {
msg              1369 lib/ais/plugin.c         ais_err("Message header contains an error: %d", msg->header.error);
msg              1373 lib/ais/plugin.c     AIS_CHECK(msg->header.size > sizeof(AIS_Message),
msg              1375 lib/ais/plugin.c                       msg->header.id, msg->header.size,
msg              1379 lib/ais/plugin.c     if (sane && ais_data_len(msg) != tmp_size) {
msg              1380 lib/ais/plugin.c         ais_warn("Message payload size is incorrect: expected %d, got %d", ais_data_len(msg),
msg              1385 lib/ais/plugin.c     if (sane && ais_data_len(msg) == 0) {
msg              1390 lib/ais/plugin.c     if (sane && data && msg->is_compressed == FALSE) {
msg              1393 lib/ais/plugin.c         if (ais_data_len(msg) != str_size) {
msg              1397 lib/ais/plugin.c                     ais_data_len(msg), str_size);
msg              1399 lib/ais/plugin.c             for (lpc = (str_size - 10); lpc < msg->size; lpc++) {
msg              1412 lib/ais/plugin.c                    msg->id, ais_dest(&(msg->host)), msg_type2text(dest), ais_dest(&(msg->sender)),
msg              1413 lib/ais/plugin.c                    msg_type2text(msg->sender.type), msg->sender.pid, msg->is_compressed,
msg              1414 lib/ais/plugin.c                    ais_data_len(msg), msg->header.size));
msg              1419 lib/ais/plugin.c              msg->id, ais_dest(&(msg->host)), msg_type2text(dest), ais_dest(&(msg->sender)),
msg              1420 lib/ais/plugin.c              msg_type2text(msg->sender.type), msg->sender.pid, msg->is_compressed,
msg              1421 lib/ais/plugin.c              ais_data_len(msg), msg->header.size);
msg              1425 lib/ais/plugin.c              msg->id, ais_dest(&(msg->host)), msg_type2text(dest), ais_dest(&(msg->sender)),
msg              1426 lib/ais/plugin.c              msg_type2text(msg->sender.type), msg->sender.pid, msg->is_compressed,
msg              1427 lib/ais/plugin.c              ais_data_len(msg), msg->header.size);
msg              1454 lib/ais/plugin.c route_ais_message(const AIS_Message * msg, gboolean local_origin)
msg              1457 lib/ais/plugin.c     int dest = msg->host.type;
msg              1459 lib/ais/plugin.c     AIS_Message *mutable = ais_msg_copy(msg);
msg              1610 lib/ais/plugin.c     struct crm_identify_msg_s *msg = NULL;
msg              1636 lib/ais/plugin.c     ais_malloc0(msg, sizeof(struct crm_identify_msg_s));
msg              1637 lib/ais/plugin.c     msg->header.size = sizeof(struct crm_identify_msg_s);
msg              1639 lib/ais/plugin.c     msg->id = local_nodeid;
msg              1641 lib/ais/plugin.c     msg->header.id = SERVICE_ID_MAKE(PCMK_SERVICE_ID, 1);
msg              1644 lib/ais/plugin.c     memset(msg->uname, 0, MAX_NAME);
msg              1645 lib/ais/plugin.c     memcpy(msg->uname, local_uname, len);
msg              1648 lib/ais/plugin.c     memset(msg->version, 0, MAX_NAME);
msg              1649 lib/ais/plugin.c     memcpy(msg->version, VERSION, len);
msg              1651 lib/ais/plugin.c     msg->votes = 1;
msg              1652 lib/ais/plugin.c     msg->pid = getpid();
msg              1653 lib/ais/plugin.c     msg->processes = get_process_list();
msg              1654 lib/ais/plugin.c     msg->born_on = local_born_on;
msg              1658 lib/ais/plugin.c     update_member(local_nodeid, local_born_on, membership_seq, msg->votes, msg->processes, NULL,
msg              1661 lib/ais/plugin.c     iovec.iov_base = (char *)msg;
msg              1662 lib/ais/plugin.c     iovec.iov_len = msg->header.size;
msg              1668 lib/ais/plugin.c     ais_free(msg);
msg              1744 lib/ais/plugin.c process_ais_message(const AIS_Message * msg)
msg              1746 lib/ais/plugin.c     int len = ais_data_len(msg);
msg              1747 lib/ais/plugin.c     char *data = get_ais_data(msg);
msg              1751 lib/ais/plugin.c                msg->id, ais_dest(&(msg->host)), msg_type2text(msg->host.type),
msg              1752 lib/ais/plugin.c                ais_dest(&(msg->sender)), msg_type2text(msg->sender.type),
msg              1753 lib/ais/plugin.c                msg->sender.pid,
msg              1754 lib/ais/plugin.c                msg->sender.uname == local_uname ? "false" : "true", ais_data_len(msg), data);
msg                43 lib/ais/utils.c log_ais_message(int level, const AIS_Message * msg)
msg                45 lib/ais/utils.c     char *data = get_ais_data(msg);
msg                50 lib/ais/utils.c                                 msg->id, ais_dest(&(msg->host)), msg_type2text(msg->host.type),
msg                51 lib/ais/utils.c                                 ais_dest(&(msg->sender)), msg_type2text(msg->sender.type),
msg                52 lib/ais/utils.c                                 msg->sender.pid,
msg                53 lib/ais/utils.c                                 msg->sender.uname == local_uname ? "false" : "true",
msg                54 lib/ais/utils.c                                 ais_data_len(msg), data);
msg               435 lib/ais/utils.c swap_sender(AIS_Message * msg)
msg               440 lib/ais/utils.c     tmp = msg->host.type;
msg               441 lib/ais/utils.c     msg->host.type = msg->sender.type;
msg               442 lib/ais/utils.c     msg->sender.type = tmp;
msg               444 lib/ais/utils.c     tmp = msg->host.type;
msg               445 lib/ais/utils.c     msg->host.size = msg->sender.type;
msg               446 lib/ais/utils.c     msg->sender.type = tmp;
msg               448 lib/ais/utils.c     memcpy(tmp_s, msg->host.uname, 256);
msg               449 lib/ais/utils.c     memcpy(msg->host.uname, msg->sender.uname, 256);
msg               450 lib/ais/utils.c     memcpy(msg->sender.uname, tmp_s, 256);
msg               454 lib/ais/utils.c get_ais_data(const AIS_Message * msg)
msg               458 lib/ais/utils.c     unsigned int new_size = msg->size + 1;
msg               460 lib/ais/utils.c     if (msg->is_compressed == FALSE) {
msg               461 lib/ais/utils.c         uncompressed = strdup(msg->data);
msg               466 lib/ais/utils.c         rc = BZ2_bzBuffToBuffDecompress(uncompressed, &new_size, (char *)msg->data,
msg               467 lib/ais/utils.c                                         msg->compressed_size, 1, 0);
msg               469 lib/ais/utils.c             ais_info("rc=%d, new=%u expected=%u", rc, new_size, msg->size);
msg               472 lib/ais/utils.c         AIS_ASSERT(new_size == msg->size);
msg                46 lib/ais/utils.h extern int openais_response_send(void *conn, void *msg, int mlen);
msg                47 lib/ais/utils.h extern int openais_dispatch_send(void *conn, void *msg, int mlen);
msg                94 lib/ais/utils.h extern void swap_sender(AIS_Message * msg);
msg                95 lib/ais/utils.h extern char *get_ais_data(const AIS_Message * msg);
msg                97 lib/ais/utils.h extern gboolean route_ais_message(const AIS_Message * msg, gboolean local);
msg                98 lib/ais/utils.h extern gboolean process_ais_message(const AIS_Message * msg);
msg               104 lib/ais/utils.h extern void log_ais_message(int level, const AIS_Message * msg);
msg                39 lib/cib/cib_client.c int cib_client_set_op_callback(cib_t * cib, void (*callback) (const xmlNode * msg, int call_id,
msg                43 lib/cib/cib_client.c                                    void (*callback) (const char *event, xmlNode * msg));
msg                46 lib/cib/cib_client.c                                    void (*callback) (const char *event, xmlNode * msg));
msg               446 lib/cib/cib_client.c cib_client_set_op_callback(cib_t * cib, void (*callback) (const xmlNode * msg, int call_id,
msg               461 lib/cib/cib_client.c                                void (*callback) (const char *event, xmlNode * msg))
msg               512 lib/cib/cib_client.c                                void (*callback) (const char *event, xmlNode * msg))
msg                96 lib/cib/cib_native.c     xmlNode *msg = NULL;
msg               107 lib/cib/cib_native.c     msg = string2xml(buffer);
msg               109 lib/cib/cib_native.c     if (msg == NULL) {
msg               115 lib/cib/cib_native.c     type = crm_element_value(msg, F_TYPE);
msg               117 lib/cib/cib_native.c     crm_log_xml_explicit(msg, "cib-reply");
msg               120 lib/cib/cib_native.c         cib_native_callback(cib, msg, 0, 0);
msg               123 lib/cib/cib_native.c         g_list_foreach(cib->notify_list, cib_native_notify, msg);
msg               129 lib/cib/cib_native.c     free_xml(msg);
msg               149 lib/cib/cib_native.c             const char *msg = crm_ipc_buffer(native->ipc);
msg               151 lib/cib/cib_native.c             cib_native_dispatch_internal(msg, strlen(msg), cib);
msg               345 lib/cib/cib_remote.c     xmlNode *msg = NULL;
msg               352 lib/cib/cib_remote.c     msg = crm_remote_parse_buffer(&private->callback);
msg               353 lib/cib/cib_remote.c     while (msg) {
msg               354 lib/cib/cib_remote.c         const char *type = crm_element_value(msg, F_TYPE);
msg               359 lib/cib/cib_remote.c             cib_native_callback(cib, msg, 0, 0);
msg               362 lib/cib/cib_remote.c             g_list_foreach(cib->notify_list, cib_native_notify, msg);
msg               368 lib/cib/cib_remote.c         free_xml(msg);
msg               369 lib/cib/cib_remote.c         msg = crm_remote_parse_buffer(&private->callback);
msg               623 lib/cib/cib_utils.c cib_native_callback(cib_t * cib, xmlNode * msg, int call_id, int rc)
msg               628 lib/cib/cib_utils.c     if (msg != NULL) {
msg               629 lib/cib/cib_utils.c         crm_element_value_int(msg, F_CIB_RC, &rc);
msg               630 lib/cib/cib_utils.c         crm_element_value_int(msg, F_CIB_CALLID, &call_id);
msg               631 lib/cib/cib_utils.c         output = get_message_xml(msg, F_CIB_CALLDATA);
msg               650 lib/cib/cib_utils.c         blob->callback(msg, call_id, rc, output, blob->user_data);
msg               654 lib/cib/cib_utils.c         crm_log_xml_debug(msg, "Failed CIB Update");
msg               664 lib/cib/cib_utils.c         cib->op_callback(msg, call_id, rc, output);
msg               672 lib/cib/cib_utils.c     xmlNode *msg = user_data;
msg               676 lib/cib/cib_utils.c     if (msg == NULL) {
msg               681 lib/cib/cib_utils.c     event = crm_element_value(msg, F_SUBTYPE);
msg               697 lib/cib/cib_utils.c     entry->callback(event, msg);
msg               377 lib/cluster/corosync.c check_message_sanity(const AIS_Message * msg, const char *data)
msg               380 lib/cluster/corosync.c     int dest = msg->host.type;
msg               381 lib/cluster/corosync.c     int tmp_size = msg->header.size - sizeof(AIS_Message);
msg               383 lib/cluster/corosync.c     if (sane && msg->header.size == 0) {
msg               388 lib/cluster/corosync.c     if (sane && msg->header.error != CS_OK) {
msg               389 lib/cluster/corosync.c         crm_warn("Message header contains an error: %d", msg->header.error);
msg               393 lib/cluster/corosync.c     if (sane && ais_data_len(msg) != tmp_size) {
msg               394 lib/cluster/corosync.c         crm_warn("Message payload size is incorrect: expected %d, got %d", ais_data_len(msg),
msg               399 lib/cluster/corosync.c     if (sane && ais_data_len(msg) == 0) {
msg               404 lib/cluster/corosync.c     if (sane && data && msg->is_compressed == FALSE) {
msg               407 lib/cluster/corosync.c         if (ais_data_len(msg) != str_size) {
msg               411 lib/cluster/corosync.c                      ais_data_len(msg), str_size);
msg               413 lib/cluster/corosync.c             for (lpc = (str_size - 10); lpc < msg->size; lpc++) {
msg               424 lib/cluster/corosync.c                 msg->id, ais_dest(&(msg->host)), msg_type2text(dest),
msg               425 lib/cluster/corosync.c                 ais_dest(&(msg->sender)), msg_type2text(msg->sender.type),
msg               426 lib/cluster/corosync.c                 msg->sender.pid, msg->is_compressed, ais_data_len(msg), msg->header.size);
msg               431 lib/cluster/corosync.c              msg->id, ais_dest(&(msg->host)), msg_type2text(dest), ais_dest(&(msg->sender)),
msg               432 lib/cluster/corosync.c              msg_type2text(msg->sender.type), msg->sender.pid, msg->is_compressed,
msg               433 lib/cluster/corosync.c              ais_data_len(msg), msg->header.size);
msg               237 lib/cluster/cpg.c     AIS_Message *msg = (AIS_Message *) content;
msg               246 lib/cluster/cpg.c         if (msg->sender.id > 0 && msg->sender.id != nodeid) {
msg               247 lib/cluster/cpg.c             crm_err("Nodeid mismatch from %d.%d: claimed nodeid=%u", nodeid, pid, msg->sender.id);
msg               250 lib/cluster/cpg.c         } else if (msg->host.id != 0 && (local_nodeid != msg->host.id)) {
msg               252 lib/cluster/cpg.c             crm_trace("Not for us: %u != %u", msg->host.id, local_nodeid);
msg               254 lib/cluster/cpg.c         } else if (msg->host.size != 0 && safe_str_neq(msg->host.uname, local_name)) {
msg               256 lib/cluster/cpg.c             crm_trace("Not for us: %s != %s", msg->host.uname, local_name);
msg               260 lib/cluster/cpg.c         msg->sender.id = nodeid;
msg               261 lib/cluster/cpg.c         if (msg->sender.size == 0) {
msg               272 lib/cluster/cpg.c                 msg->sender.size = strlen(peer->uname);
msg               273 lib/cluster/cpg.c                 memset(msg->sender.uname, 0, MAX_NAME);
msg               274 lib/cluster/cpg.c                 memcpy(msg->sender.uname, peer->uname, msg->sender.size);
msg               280 lib/cluster/cpg.c               msg->is_compressed ? " compressed" : "",
msg               281 lib/cluster/cpg.c               ais_data_len(msg), msg->size, msg->compressed_size);
msg               284 lib/cluster/cpg.c         *kind = msg->header.id;
msg               287 lib/cluster/cpg.c         *from = msg->sender.uname;
msg               290 lib/cluster/cpg.c     if (msg->is_compressed && msg->size > 0) {
msg               293 lib/cluster/cpg.c         unsigned int new_size = msg->size + 1;
msg               295 lib/cluster/cpg.c         if (check_message_sanity(msg, NULL) == FALSE) {
msg               301 lib/cluster/cpg.c         rc = BZ2_bzBuffToBuffDecompress(uncompressed, &new_size, msg->data, msg->compressed_size, 1, 0);
msg               310 lib/cluster/cpg.c         CRM_ASSERT(new_size == msg->size);
msg               314 lib/cluster/cpg.c     } else if (check_message_sanity(msg, data) == FALSE) {
msg               325 lib/cluster/cpg.c         data = strdup(msg->data);
msg               328 lib/cluster/cpg.c     if (msg->header.id != crm_class_members) {
msg               330 lib/cluster/cpg.c         crm_get_peer(msg->sender.id, msg->sender.uname);
msg               333 lib/cluster/cpg.c     if (msg->header.id == crm_class_rmpeer) {
msg               343 lib/cluster/cpg.c         plugin_handle_membership(msg);
msg               353 lib/cluster/cpg.c             msg->id, ais_dest(&(msg->host)), msg_type2text(msg->host.type),
msg               354 lib/cluster/cpg.c             ais_dest(&(msg->sender)), msg_type2text(msg->sender.type),
msg               355 lib/cluster/cpg.c             msg->sender.pid, (int)sizeof(AIS_Message),
msg               356 lib/cluster/cpg.c             msg->header.size, msg->size, msg->compressed_size);
msg               509 lib/cluster/cpg.c send_cluster_message_cs(xmlNode * msg, gboolean local, crm_node_t * node, enum crm_ais_msg_types dest)
msg               514 lib/cluster/cpg.c     data = dump_xml_unformatted(msg);
msg               531 lib/cluster/cpg.c     AIS_Message *msg = NULL;
msg               561 lib/cluster/cpg.c     msg = calloc(1, sizeof(AIS_Message));
msg               564 lib/cluster/cpg.c     msg->id = msg_id;
msg               565 lib/cluster/cpg.c     msg->header.id = class;
msg               566 lib/cluster/cpg.c     msg->header.error = CS_OK;
msg               568 lib/cluster/cpg.c     msg->host.type = dest;
msg               569 lib/cluster/cpg.c     msg->host.local = local;
msg               574 lib/cluster/cpg.c             msg->host.size = strlen(node->uname);
msg               575 lib/cluster/cpg.c             memset(msg->host.uname, 0, MAX_NAME);
msg               576 lib/cluster/cpg.c             memcpy(msg->host.uname, node->uname, msg->host.size);
msg               580 lib/cluster/cpg.c         msg->host.id = node->id;
msg               585 lib/cluster/cpg.c     msg->sender.id = 0;
msg               586 lib/cluster/cpg.c     msg->sender.type = sender;
msg               587 lib/cluster/cpg.c     msg->sender.pid = local_pid;
msg               588 lib/cluster/cpg.c     msg->sender.size = local_name_len;
msg               589 lib/cluster/cpg.c     memset(msg->sender.uname, 0, MAX_NAME);
msg               590 lib/cluster/cpg.c     if(local_name && msg->sender.size) {
msg               591 lib/cluster/cpg.c         memcpy(msg->sender.uname, local_name, msg->sender.size);
msg               594 lib/cluster/cpg.c     msg->size = 1 + strlen(data);
msg               595 lib/cluster/cpg.c     msg->header.size = sizeof(AIS_Message) + msg->size;
msg               597 lib/cluster/cpg.c     if (msg->size < CRM_BZ2_THRESHOLD) {
msg               598 lib/cluster/cpg.c         msg = realloc_safe(msg, msg->header.size);
msg               599 lib/cluster/cpg.c         memcpy(msg->data, data, msg->size);
msg               606 lib/cluster/cpg.c         if (crm_compress_string(uncompressed, msg->size, 0, &compressed, &new_size)) {
msg               608 lib/cluster/cpg.c             msg->header.size = sizeof(AIS_Message) + new_size;
msg               609 lib/cluster/cpg.c             msg = realloc_safe(msg, msg->header.size);
msg               610 lib/cluster/cpg.c             memcpy(msg->data, compressed, new_size);
msg               612 lib/cluster/cpg.c             msg->is_compressed = TRUE;
msg               613 lib/cluster/cpg.c             msg->compressed_size = new_size;
msg               616 lib/cluster/cpg.c             msg = realloc_safe(msg, msg->header.size);
msg               617 lib/cluster/cpg.c             memcpy(msg->data, data, msg->size);
msg               625 lib/cluster/cpg.c     iov->iov_base = msg;
msg               626 lib/cluster/cpg.c     iov->iov_len = msg->header.size;
msg               628 lib/cluster/cpg.c     if (msg->compressed_size) {
msg               630 lib/cluster/cpg.c                   msg->id, target, (unsigned long long) iov->iov_len,
msg               631 lib/cluster/cpg.c                   msg->compressed_size, data);
msg               634 lib/cluster/cpg.c                   msg->id, target, (unsigned long long) iov->iov_len,
msg               635 lib/cluster/cpg.c                   msg->size, data);
msg                50 lib/cluster/heartbeat.c     HA_Message *msg = msg_v;
msg                60 lib/cluster/heartbeat.c     CRM_CHECK(msg != NULL, return);
msg                62 lib/cluster/heartbeat.c     name = msg->names[lpc];
msg                63 lib/cluster/heartbeat.c     type = cl_get_type(msg, name);
msg                67 lib/cluster/heartbeat.c             convert_ha_message(parent, msg->values[lpc], name);
msg                71 lib/cluster/heartbeat.c             convert_ha_message(parent, cl_get_struct(msg, name), name);
msg                74 lib/cluster/heartbeat.c             value = msg->values[lpc];
msg                94 lib/cluster/heartbeat.c             value = cl_get_binary(msg, name, &orig_len);
msg               151 lib/cluster/heartbeat.c convert_ha_message(xmlNode * parent, HA_Message * msg, const char *field)
msg               157 lib/cluster/heartbeat.c     CRM_CHECK(msg != NULL, crm_err("Empty message for %s", field);
msg               160 lib/cluster/heartbeat.c     tag = cl_get_string(msg, F_XML_TAGNAME);
msg               179 lib/cluster/heartbeat.c     for (lpc = 0; lpc < msg->nfields; lpc++) {
msg               180 lib/cluster/heartbeat.c         convert_ha_field(child, msg, lpc);
msg               252 lib/cluster/heartbeat.c convert_xml_child(HA_Message * msg, xmlNode * xml)
msg               266 lib/cluster/heartbeat.c         ha_msg_add(msg, name, buffer);
msg               278 lib/cluster/heartbeat.c         convert_xml_message_struct(msg, xml, name);
msg               285 lib/cluster/heartbeat.c     ha_msg_addbin(msg, name, buffer, len);
msg               408 lib/cluster/heartbeat.c     HA_Message *msg = convert_xml_message(xml);
msg               410 lib/cluster/heartbeat.c     if (msg == NULL) {
msg               425 lib/cluster/heartbeat.c         if (hb_conn->llc_ops->send_ordered_nodemsg(hb_conn, msg, host_lowercase) != HA_OK) {
msg               432 lib/cluster/heartbeat.c         if (hb_conn->llc_ops->send_ordered_clustermsg(hb_conn, msg) != HA_OK) {
msg               438 lib/cluster/heartbeat.c         if (hb_conn->llc_ops->sendclustermsg(hb_conn, msg) != HA_OK) {
msg               467 lib/cluster/heartbeat.c     if (msg != NULL) {
msg               468 lib/cluster/heartbeat.c         ha_msg_del(msg);
msg               488 lib/cluster/heartbeat.c         struct ha_msg *msg;
msg               494 lib/cluster/heartbeat.c         msg = cluster_conn->llc_ops->readmsg(cluster_conn, 0);
msg               495 lib/cluster/heartbeat.c         if (msg) {
msg               499 lib/cluster/heartbeat.c             const char *msg_type = ha_msg_value(msg, F_TYPE) ?: "[type not set]";
msg               500 lib/cluster/heartbeat.c             const char *msg_to_id = ha_msg_value(msg, F_TOID);
msg               511 lib/cluster/heartbeat.c             ha_msg_del(msg);
msg               222 lib/cluster/legacy.c plugin_handle_membership(AIS_Message *msg)
msg               224 lib/cluster/legacy.c     if (msg->header.id == crm_class_members || msg->header.id == crm_class_quorum) {
msg               228 lib/cluster/legacy.c         xmlNode *xml = string2xml(msg->data);
msg               231 lib/cluster/legacy.c             crm_err("Invalid membership update: %s", msg->data);
msg               280 lib/cluster/legacy.c                                uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len)
msg               284 lib/cluster/legacy.c     char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from);
msg               566 lib/cluster/legacy.c     xmlNode *msg = string2xml(buffer);
msg               568 lib/cluster/legacy.c     if (msg && is_classic_ais_cluster()) {
msg               571 lib/cluster/legacy.c         for (node = __xml_first_child(msg); node != NULL; node = __xml_next(node)) {
msg               579 lib/cluster/legacy.c                 crm_log_xml_err(msg, "Bad Update");
msg               588 lib/cluster/legacy.c     free_xml(msg);
msg               730 lib/cluster/legacy.c check_message_sanity(const AIS_Message * msg, const char *data)
msg               733 lib/cluster/legacy.c     int dest = msg->host.type;
msg               734 lib/cluster/legacy.c     int tmp_size = msg->header.size - sizeof(AIS_Message);
msg               736 lib/cluster/legacy.c     if (sane && msg->header.size == 0) {
msg               741 lib/cluster/legacy.c     if (sane && msg->header.error != CS_OK) {
msg               742 lib/cluster/legacy.c         crm_warn("Message header contains an error: %d", msg->header.error);
msg               746 lib/cluster/legacy.c     if (sane && ais_data_len(msg) != tmp_size) {
msg               747 lib/cluster/legacy.c         crm_warn("Message payload size is incorrect: expected %d, got %d", ais_data_len(msg),
msg               752 lib/cluster/legacy.c     if (sane && ais_data_len(msg) == 0) {
msg               757 lib/cluster/legacy.c     if (sane && data && msg->is_compressed == FALSE) {
msg               760 lib/cluster/legacy.c         if (ais_data_len(msg) != str_size) {
msg               764 lib/cluster/legacy.c                      ais_data_len(msg), str_size);
msg               766 lib/cluster/legacy.c             for (lpc = (str_size - 10); lpc < msg->size; lpc++) {
msg               777 lib/cluster/legacy.c                 msg->id, ais_dest(&(msg->host)), msg_type2text(dest),
msg               778 lib/cluster/legacy.c                 ais_dest(&(msg->sender)), msg_type2text(msg->sender.type),
msg               779 lib/cluster/legacy.c                 msg->sender.pid, msg->is_compressed, ais_data_len(msg), msg->header.size);
msg               784 lib/cluster/legacy.c              msg->id, ais_dest(&(msg->host)), msg_type2text(dest), ais_dest(&(msg->sender)),
msg               785 lib/cluster/legacy.c              msg_type2text(msg->sender.type), msg->sender.pid, msg->is_compressed,
msg               786 lib/cluster/legacy.c              ais_data_len(msg), msg->header.size);
msg               233 lib/common/alerts.c crm_patchset_contains_alert(xmlNode *msg, bool config)
msg               237 lib/common/alerts.c     xmlNode *patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg               241 lib/common/alerts.c     CRM_CHECK(msg != NULL, return FALSE);
msg               243 lib/common/alerts.c     crm_element_value_int(msg, F_CIB_RC, &rc);
msg               253 lib/common/alerts.c         if ((xpathObj = xpath_search(msg, diff)) != NULL) {
msg               354 lib/common/logging.c blackbox_logger(int32_t t, struct qb_log_callsite *cs, time_t timestamp, const char *msg)
msg               335 lib/common/remote.c crm_remote_send(crm_remote_t * remote, xmlNode * msg)
msg               339 lib/common/remote.c     char *xml_text = dump_xml_unformatted(msg);
msg              3163 lib/common/xml.c get_message_xml(xmlNode * msg, const char *field)
msg              3165 lib/common/xml.c     xmlNode *tmp = first_named_child(msg, field);
msg              3171 lib/common/xml.c add_message_xml(xmlNode * msg, const char *field, xmlNode * xml)
msg              3173 lib/common/xml.c     xmlNode *holder = create_xml_node(msg, field);
msg               150 lib/fencing/st_client.c void stonith_perform_callback(stonith_t * stonith, xmlNode * msg, int call_id, int rc);
msg              2071 lib/fencing/st_client.c stonith_perform_callback(stonith_t * stonith, xmlNode * msg, int call_id, int rc)
msg              2087 lib/fencing/st_client.c     if (msg != NULL) {
msg              2088 lib/fencing/st_client.c         crm_element_value_int(msg, F_STONITH_RC, &rc);
msg              2089 lib/fencing/st_client.c         crm_element_value_int(msg, F_STONITH_CALLID, &call_id);
msg              2092 lib/fencing/st_client.c     CRM_CHECK(call_id > 0, crm_log_xml_err(msg, "Bad result"));
msg              2113 lib/fencing/st_client.c         crm_log_xml_debug(msg, "Failed STONITH Update");
msg              2143 lib/fencing/st_client.c xml_to_event(xmlNode * msg)
msg              2146 lib/fencing/st_client.c     const char *ntype = crm_element_value(msg, F_SUBTYPE);
msg              2148 lib/fencing/st_client.c     xmlNode *data = get_xpath_object(data_addr, msg, LOG_DEBUG);
msg              2150 lib/fencing/st_client.c     crm_log_xml_trace(msg, "stonith_notify");
msg              2152 lib/fencing/st_client.c     crm_element_value_int(msg, F_STONITH_RC, &(event->result));
msg              2155 lib/fencing/st_client.c         event->operation = crm_element_value_copy(msg, F_STONITH_OPERATION);
msg              2168 lib/fencing/st_client.c             crm_log_xml_notice(msg, "BadEvent");
msg              2351 lib/fencing/st_client.c             const char *msg = crm_ipc_buffer(private->ipc);
msg              2353 lib/fencing/st_client.c             stonith_dispatch_internal(msg, strlen(msg), st);
msg                63 lib/lrmd/lrmd_client.c int lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg);
msg                64 lib/lrmd/lrmd_client.c static void lrmd_internal_proxy_dispatch(lrmd_t *lrmd, xmlNode *msg);
msg                65 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                73 lib/lrmd/lrmd_client.c int lrmd_tls_send_msg(crm_remote_t * session, xmlNode * msg, uint32_t id, const char *msg_type);
msg               110 lib/lrmd/lrmd_client.c     void (*proxy_callback)(lrmd_t *lrmd, void *userdata, xmlNode *msg);
msg               233 lib/lrmd/lrmd_client.c lrmd_dispatch_internal(lrmd_t * lrmd, xmlNode * msg)
msg               236 lib/lrmd/lrmd_client.c     const char *proxy_session = crm_element_value(msg, F_LRMD_IPC_SESSION);
msg               242 lib/lrmd/lrmd_client.c         lrmd_internal_proxy_dispatch(lrmd, msg);
msg               251 lib/lrmd/lrmd_client.c     type = crm_element_value(msg, F_LRMD_OPERATION);
msg               252 lib/lrmd/lrmd_client.c     crm_element_value_int(msg, F_LRMD_CALLID, &event.call_id);
msg               253 lib/lrmd/lrmd_client.c     event.rsc_id = crm_element_value(msg, F_LRMD_RSC_ID);
msg               260 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_TIMEOUT, &event.timeout);
msg               261 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_RSC_INTERVAL, &event.interval);
msg               262 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_RSC_START_DELAY, &event.start_delay);
msg               263 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_EXEC_RC, (int *)&event.rc);
msg               264 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_OP_STATUS, &event.op_status);
msg               265 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_RSC_DELETED, &event.rsc_deleted);
msg               267 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_RSC_RUN_TIME, (int *)&event.t_run);
msg               268 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_RSC_RCCHANGE_TIME, (int *)&event.t_rcchange);
msg               269 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_RSC_EXEC_TIME, (int *)&event.exec_time);
msg               270 lib/lrmd/lrmd_client.c         crm_element_value_int(msg, F_LRMD_RSC_QUEUE_TIME, (int *)&event.queue_time);
msg               272 lib/lrmd/lrmd_client.c         event.op_type = crm_element_value(msg, F_LRMD_RSC_ACTION);
msg               273 lib/lrmd/lrmd_client.c         event.user_data = crm_element_value(msg, F_LRMD_RSC_USERDATA_STR);
msg               274 lib/lrmd/lrmd_client.c         event.output = crm_element_value(msg, F_LRMD_RSC_OUTPUT);
msg               275 lib/lrmd/lrmd_client.c         event.exit_reason = crm_element_value(msg, F_LRMD_RSC_EXIT_REASON);
msg               278 lib/lrmd/lrmd_client.c         event.params = xml2list(msg);
msg               301 lib/lrmd/lrmd_client.c     xmlNode *msg;
msg               309 lib/lrmd/lrmd_client.c     msg = string2xml(buffer);
msg               310 lib/lrmd/lrmd_client.c     rc = lrmd_dispatch_internal(lrmd, msg);
msg               311 lib/lrmd/lrmd_client.c     free_xml(msg);
msg               439 lib/lrmd/lrmd_client.c                     const char *msg = crm_ipc_buffer(private->ipc);
msg               441 lib/lrmd/lrmd_client.c                     lrmd_ipc_dispatch(msg, strlen(msg), lrmd);
msg               554 lib/lrmd/lrmd_client.c lrmd_tls_send_msg(crm_remote_t * session, xmlNode * msg, uint32_t id, const char *msg_type)
msg               556 lib/lrmd/lrmd_client.c     crm_xml_add_int(msg, F_LRMD_REMOTE_MSG_ID, id);
msg               557 lib/lrmd/lrmd_client.c     crm_xml_add(msg, F_LRMD_REMOTE_MSG_TYPE, msg_type);
msg               558 lib/lrmd/lrmd_client.c     return crm_remote_send(session, msg);
msg               646 lib/lrmd/lrmd_client.c lrmd_tls_send(lrmd_t * lrmd, xmlNode * msg)
msg               656 lib/lrmd/lrmd_client.c     rc = lrmd_tls_send_msg(native->remote, msg, global_remote_msg_id, "request");
msg               666 lib/lrmd/lrmd_client.c lrmd_tls_send_recv(lrmd_t * lrmd, xmlNode * msg, int timeout, xmlNode ** reply)
msg               676 lib/lrmd/lrmd_client.c     rc = lrmd_tls_send(lrmd, msg);
msg               705 lib/lrmd/lrmd_client.c lrmd_send_xml(lrmd_t * lrmd, xmlNode * msg, int timeout, xmlNode ** reply)
msg               712 lib/lrmd/lrmd_client.c             rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply);
msg               716 lib/lrmd/lrmd_client.c             rc = lrmd_tls_send_recv(lrmd, msg, timeout, reply);
msg               727 lib/lrmd/lrmd_client.c lrmd_send_xml_no_reply(lrmd_t * lrmd, xmlNode * msg)
msg               734 lib/lrmd/lrmd_client.c             rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL);
msg               738 lib/lrmd/lrmd_client.c             rc = lrmd_tls_send(lrmd, msg);
msg              1539 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              1548 lib/lrmd/lrmd_client.c lrmd_internal_proxy_dispatch(lrmd_t *lrmd, xmlNode *msg)
msg              1553 lib/lrmd/lrmd_client.c         crm_log_xml_trace(msg, "PROXY_INBOUND");
msg              1554 lib/lrmd/lrmd_client.c         native->proxy_callback(lrmd, native->proxy_callback_userdata, msg);
msg              1559 lib/lrmd/lrmd_client.c lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg)
msg              1564 lib/lrmd/lrmd_client.c     crm_xml_add(msg, F_LRMD_OPERATION, CRM_OP_IPC_FWD);
msg              1566 lib/lrmd/lrmd_client.c     crm_log_xml_trace(msg, "PROXY_OUTBOUND");
msg              1567 lib/lrmd/lrmd_client.c     return lrmd_send_xml_no_reply(lrmd, msg);
msg                34 lib/lrmd/proxy_common.c int lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg);
msg                41 lib/lrmd/proxy_common.c     xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg                42 lib/lrmd/proxy_common.c     crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_DESTROY);
msg                43 lib/lrmd/proxy_common.c     crm_xml_add(msg, F_LRMD_IPC_SESSION, session_id);
msg                44 lib/lrmd/proxy_common.c     lrmd_internal_proxy_send(lrmd, msg);
msg                45 lib/lrmd/proxy_common.c     free_xml(msg);
msg                56 lib/lrmd/proxy_common.c     xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg                57 lib/lrmd/proxy_common.c     crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_SHUTDOWN_ACK);
msg                58 lib/lrmd/proxy_common.c     lrmd_internal_proxy_send(lrmd, msg);
msg                59 lib/lrmd/proxy_common.c     free_xml(msg);
msg                71 lib/lrmd/proxy_common.c     xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg                72 lib/lrmd/proxy_common.c     crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_SHUTDOWN_NACK);
msg                73 lib/lrmd/proxy_common.c     lrmd_internal_proxy_send(lrmd, msg);
msg                74 lib/lrmd/proxy_common.c     free_xml(msg);
msg                78 lib/lrmd/proxy_common.c remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg)
msg                84 lib/lrmd/proxy_common.c     add_message_xml(event, F_LRMD_IPC_MSG, msg);
msg                91 lib/lrmd/proxy_common.c remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, int msg_id)
msg                98 lib/lrmd/proxy_common.c     add_message_xml(response, F_LRMD_IPC_MSG, msg);
msg               215 lib/lrmd/proxy_common.c remote_proxy_cb(lrmd_t *lrmd, const char *node_name, xmlNode *msg)
msg               217 lib/lrmd/proxy_common.c     const char *op = crm_element_value(msg, F_LRMD_IPC_OP);
msg               218 lib/lrmd/proxy_common.c     const char *session = crm_element_value(msg, F_LRMD_IPC_SESSION);
msg               229 lib/lrmd/proxy_common.c     crm_element_value_int(msg, F_LRMD_IPC_MSG_ID, &msg_id);
msg               237 lib/lrmd/proxy_common.c         xmlNode *request = get_message_xml(msg, F_LRMD_IPC_MSG);
msg               238 lib/lrmd/proxy_common.c         const char *name = crm_element_value(msg, F_LRMD_IPC_CLIENT);
msg               257 lib/lrmd/proxy_common.c         crm_element_value_int(msg, F_LRMD_IPC_MSG_FLAGS, &flags);
msg               150 lib/services/dbus.c pcmk_dbus_send_recv(DBusMessage *msg, DBusConnection *connection,
msg               157 lib/services/dbus.c     CRM_ASSERT(dbus_message_get_type (msg) == DBUS_MESSAGE_TYPE_METHOD_CALL);
msg               158 lib/services/dbus.c     method = dbus_message_get_member (msg);
msg               171 lib/services/dbus.c     if (!dbus_connection_send_with_reply(connection, msg, &pending, timeout)) {
msg               200 lib/services/dbus.c pcmk_dbus_send(DBusMessage *msg, DBusConnection *connection,
msg               208 lib/services/dbus.c     CRM_ASSERT(dbus_message_get_type (msg) == DBUS_MESSAGE_TYPE_METHOD_CALL);
msg               209 lib/services/dbus.c     method = dbus_message_get_member (msg);
msg               218 lib/services/dbus.c     if (!dbus_connection_send_with_reply(connection, msg, &pending, timeout)) {
msg               247 lib/services/dbus.c pcmk_dbus_type_check(DBusMessage *msg, DBusMessageIter *field, int expected,
msg               254 lib/services/dbus.c         if(dbus_message_iter_init(msg, &lfield)) {
msg               271 lib/services/dbus.c         dbus_message_iter_init(msg, &args);
msg               394 lib/services/dbus.c     DBusMessage *msg;
msg               400 lib/services/dbus.c     msg = dbus_message_new_method_call(target, // target for the method call
msg               404 lib/services/dbus.c     if (NULL == msg) {
msg               409 lib/services/dbus.c     CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &iface, DBUS_TYPE_INVALID));
msg               429 lib/services/dbus.c         _pending = pcmk_dbus_send(msg, connection, pcmk_dbus_lookup_cb, query_data, timeout);
msg               435 lib/services/dbus.c         DBusMessage *reply = pcmk_dbus_send_recv(msg, connection, NULL, timeout);
msg               444 lib/services/dbus.c     dbus_message_unref(msg);
msg                27 lib/services/pcmk-dbus.h DBusPendingCall *pcmk_dbus_send(DBusMessage *msg, DBusConnection *connection,
msg                31 lib/services/pcmk-dbus.h DBusMessage *pcmk_dbus_send_recv(DBusMessage *msg, DBusConnection *connection, DBusError *error, int timeout);
msg                34 lib/services/pcmk-dbus.h bool pcmk_dbus_type_check(DBusMessage *msg, DBusMessageIter *field, int expected, const char *function, int line);
msg                42 lib/services/systemd.c systemd_send(DBusMessage *msg,
msg                46 lib/services/systemd.c     return pcmk_dbus_send(msg, systemd_proxy, done, user_data, timeout);
msg                50 lib/services/systemd.c systemd_send_recv(DBusMessage *msg, DBusError *error, int timeout)
msg                52 lib/services/systemd.c     return pcmk_dbus_send_recv(msg, systemd_proxy, error, timeout);
msg                69 lib/services/systemd.c     DBusMessage *msg = systemd_new_method(method);
msg                76 lib/services/systemd.c     if (msg == NULL) {
msg                82 lib/services/systemd.c     reply = systemd_send_recv(msg, &error, DBUS_TIMEOUT_USE_DEFAULT);
msg                83 lib/services/systemd.c     dbus_message_unref(msg);
msg               214 lib/services/systemd.c     DBusMessage *msg = systemd_new_method("Reload");
msg               217 lib/services/systemd.c     CRM_ASSERT(msg != NULL);
msg               218 lib/services/systemd.c     systemd_send(msg, systemd_daemon_reload_complete,
msg               220 lib/services/systemd.c     dbus_message_unref(msg);
msg               306 lib/services/systemd.c     DBusMessage *msg;
msg               323 lib/services/systemd.c     msg = systemd_new_method("LoadUnit");
msg               324 lib/services/systemd.c     CRM_ASSERT(msg != NULL);
msg               327 lib/services/systemd.c     CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID));
msg               334 lib/services/systemd.c         reply = systemd_send_recv(msg, NULL,
msg               336 lib/services/systemd.c         dbus_message_unref(msg);
msg               348 lib/services/systemd.c     pending = systemd_send(msg, systemd_loadunit_cb, op, op->timeout);
msg               353 lib/services/systemd.c     dbus_message_unref(msg);
msg               606 lib/services/systemd.c     DBusMessage *msg = NULL;
msg               695 lib/services/systemd.c     msg = systemd_new_method(method);
msg               696 lib/services/systemd.c     CRM_ASSERT(msg != NULL);
msg               703 lib/services/systemd.c         CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID));
msg               704 lib/services/systemd.c         CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &replace_s, DBUS_TYPE_INVALID));
msg               710 lib/services/systemd.c         DBusPendingCall *pending = systemd_send(msg, systemd_async_dispatch,
msg               713 lib/services/systemd.c         dbus_message_unref(msg);
msg               723 lib/services/systemd.c         reply = systemd_send_recv(msg, NULL, op->timeout);
msg               724 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               241 lib/services/upstart.c     DBusMessage *msg;
msg               247 lib/services/upstart.c     msg = dbus_message_new_method_call(BUS_NAME, // target for the method call
msg               251 lib/services/upstart.c     CRM_ASSERT(msg != NULL);
msg               253 lib/services/upstart.c     dbus_message_append_args(msg, DBUS_TYPE_INVALID);
msg               254 lib/services/upstart.c     reply = pcmk_dbus_send_recv(msg, upstart_proxy, &error, timeout);
msg               255 lib/services/upstart.c     dbus_message_unref(msg);
msg               425 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                80 lrmd/ipc_proxy.c     xmlNode *msg;
msg               103 lrmd/ipc_proxy.c     msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg               104 lrmd/ipc_proxy.c     crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_NEW);
msg               105 lrmd/ipc_proxy.c     crm_xml_add(msg, F_LRMD_IPC_IPC_SERVER, ipc_channel);
msg               106 lrmd/ipc_proxy.c     crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id);
msg               107 lrmd/ipc_proxy.c     lrmd_server_send_notify(ipc_proxy, msg);
msg               108 lrmd/ipc_proxy.c     free_xml(msg);
msg               154 lrmd/ipc_proxy.c     xmlNode *msg = get_message_xml(xml, F_LRMD_IPC_MSG);
msg               174 lrmd/ipc_proxy.c         xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg               175 lrmd/ipc_proxy.c         crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_DESTROY);
msg               176 lrmd/ipc_proxy.c         crm_xml_add(msg, F_LRMD_IPC_SESSION, session);
msg               177 lrmd/ipc_proxy.c         lrmd_server_send_notify(ipc_proxy, msg);
msg               178 lrmd/ipc_proxy.c         free_xml(msg);
msg               196 lrmd/ipc_proxy.c         rc = crm_ipcs_send(ipc_client, 0, msg, crm_ipc_server_event);
msg               203 lrmd/ipc_proxy.c         rc = crm_ipcs_send(ipc_client, msg_id, msg, FALSE);
msg               228 lrmd/ipc_proxy.c     xmlNode *msg = NULL;
msg               262 lrmd/ipc_proxy.c     msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg               263 lrmd/ipc_proxy.c     crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_REQUEST);
msg               264 lrmd/ipc_proxy.c     crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id);
msg               265 lrmd/ipc_proxy.c     crm_xml_add(msg, F_LRMD_IPC_CLIENT, crm_client_name(client));
msg               266 lrmd/ipc_proxy.c     crm_xml_add(msg, F_LRMD_IPC_USER, client->user);
msg               267 lrmd/ipc_proxy.c     crm_xml_add_int(msg, F_LRMD_IPC_MSG_ID, id);
msg               268 lrmd/ipc_proxy.c     crm_xml_add_int(msg, F_LRMD_IPC_MSG_FLAGS, flags);
msg               269 lrmd/ipc_proxy.c     add_message_xml(msg, F_LRMD_IPC_MSG, request);
msg               270 lrmd/ipc_proxy.c     lrmd_server_send_notify(ipc_proxy, msg);
msg               272 lrmd/ipc_proxy.c     free_xml(msg);
msg               286 lrmd/ipc_proxy.c     xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg               289 lrmd/ipc_proxy.c     crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_SHUTDOWN_REQ);
msg               294 lrmd/ipc_proxy.c     crm_xml_add(msg, F_LRMD_IPC_SESSION, "0");
msg               296 lrmd/ipc_proxy.c     rc = (lrmd_server_send_notify(ipc_proxy, msg) < 0)? -1 : 0;
msg               297 lrmd/ipc_proxy.c     free_xml(msg);
msg               316 lrmd/ipc_proxy.c         xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY);
msg               317 lrmd/ipc_proxy.c         crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_DESTROY);
msg               318 lrmd/ipc_proxy.c         crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id);
msg               319 lrmd/ipc_proxy.c         lrmd_server_send_notify(ipc_proxy, msg);
msg               320 lrmd/ipc_proxy.c         free_xml(msg);
msg               147 lrmd/lrmd.c    build_rsc_from_xml(xmlNode * msg)
msg               149 lrmd/lrmd.c        xmlNode *rsc_xml = get_xpath_object("//" F_LRMD_RSC, msg, LOG_ERR);
msg               154 lrmd/lrmd.c        crm_element_value_int(msg, F_LRMD_CALLOPTS, &rsc->call_opts);
msg               165 lrmd/lrmd.c    create_lrmd_cmd(xmlNode * msg, crm_client_t * client, lrmd_rsc_t *rsc)
msg               168 lrmd/lrmd.c        xmlNode *rsc_xml = get_xpath_object("//" F_LRMD_RSC, msg, LOG_ERR);
msg               173 lrmd/lrmd.c        crm_element_value_int(msg, F_LRMD_CALLOPTS, &call_options);
msg               177 lrmd/lrmd.c        crm_element_value_int(msg, F_LRMD_CALLID, &cmd->call_id);
msg                68 lrmd/lrmd_private.h extern int lrmd_tls_send_msg(crm_remote_t * session, xmlNode * msg, uint32_t id,
msg                75 lrmd/lrmd_private.h int lrmd_server_send_notify(crm_client_t * client, xmlNode * msg);
msg               242 lrmd/main.c    lrmd_server_send_notify(crm_client_t * client, xmlNode * msg)
msg               251 lrmd/main.c                return crm_ipcs_send(client, 0, msg, crm_ipc_server_event);
msg               258 lrmd/main.c                return lrmd_tls_send_msg(client->remote, msg, 0, "notify");
msg                35 lrmd/remote_ctl.c void lrmd_internal_set_proxy_callback(lrmd_t * lrmd, void *userdata, void (*callback)(lrmd_t *lrmd, void *userdata, xmlNode *msg));
msg               252 lrmd/remote_ctl.c ctl_remote_proxy_cb(lrmd_t *lrmd, void *userdata, xmlNode *msg)
msg               254 lrmd/remote_ctl.c     const char *op = crm_element_value(msg, F_LRMD_IPC_OP);
msg               255 lrmd/remote_ctl.c     const char *session = crm_element_value(msg, F_LRMD_IPC_SESSION);
msg               258 lrmd/remote_ctl.c         const char *channel = crm_element_value(msg, F_LRMD_IPC_IPC_SERVER);
msg               268 lrmd/remote_ctl.c         remote_proxy_cb(lrmd, options.node_name, msg);
msg               488 mcp/pacemaker.c     xmlNode *msg = crm_ipcs_recv(c, data, size, &id, &flags);
msg               491 mcp/pacemaker.c     if (msg == NULL) {
msg               495 mcp/pacemaker.c     task = crm_element_value(msg, F_CRM_TASK);
msg               499 mcp/pacemaker.c                    crm_element_value(msg, F_CRM_REFERENCE), crm_element_value(msg, F_CRM_ORIGIN));
msg               508 mcp/pacemaker.c         crm_element_value_int(msg, XML_ATTR_ID, &id);
msg               509 mcp/pacemaker.c         name = crm_element_value(msg, XML_ATTR_UNAME);
msg               513 mcp/pacemaker.c         iov->iov_base = dump_xml_unformatted(msg);
msg               521 mcp/pacemaker.c     free_xml(msg);
msg               826 mcp/pacemaker.c                  uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len)
msg               828 mcp/pacemaker.c     xmlNode *xml = string2xml(msg);
msg               832 mcp/pacemaker.c               (task? task : "process list"), (char*)msg);
msg                62 pengine/main.c gboolean process_pe_message(xmlNode * msg, xmlNode * xml_data, crm_client_t * sender);
msg                70 pengine/main.c     xmlNode *msg = crm_ipcs_recv(c, data, size, &id, &flags);
msg                73 pengine/main.c     if (msg != NULL) {
msg                74 pengine/main.c         xmlNode *data_xml = get_message_xml(msg, F_CRM_DATA);
msg                76 pengine/main.c         process_pe_message(msg, data_xml, c);
msg                77 pengine/main.c         free_xml(msg);
msg                60 pengine/pengine.c gboolean process_pe_message(xmlNode * msg, xmlNode * xml_data, crm_client_t * sender);
msg                63 pengine/pengine.c process_pe_message(xmlNode * msg, xmlNode * xml_data, crm_client_t * sender)
msg                69 pengine/pengine.c     const char *sys_to = crm_element_value(msg, F_CRM_SYS_TO);
msg                70 pengine/pengine.c     const char *op = crm_element_value(msg, F_CRM_TASK);
msg                71 pengine/pengine.c     const char *ref = crm_element_value(msg, F_CRM_REFERENCE);
msg                81 pengine/pengine.c     } else if (safe_str_eq(crm_element_value(msg, F_CRM_MSG_TYPE), XML_ATTR_RESPONSE)) {
msg               151 pengine/pengine.c         reply = create_reply(msg, data_set.graph);
msg                52 tools/cibadmin.c void cibadmin_op_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data);
msg               560 tools/cibadmin.c cibadmin_op_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data)
msg               571 tools/cibadmin.c         crm_log_xml_err(msg, "no output");
msg                55 tools/crm_mon.c void crm_diff_update(const char *event, xmlNode * msg);
msg              3925 tools/crm_mon.c static void crm_diff_update_v2(const char *event, xmlNode * msg) 
msg              3928 tools/crm_mon.c     xmlNode *diff = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg              4026 tools/crm_mon.c static void crm_diff_update_v1(const char *event, xmlNode * msg) 
msg              4029 tools/crm_mon.c     xmlXPathObject *xpathObj = xpath_search(msg,
msg              4043 tools/crm_mon.c crm_diff_update(const char *event, xmlNode * msg)
msg              4050 tools/crm_mon.c     xmlNode *diff = get_message_xml(msg, F_CIB_UPDATE_RESULT);
msg              4086 tools/crm_mon.c                 crm_diff_update_v1(event, msg);
msg              4089 tools/crm_mon.c                 crm_diff_update_v2(event, msg);
msg               231 tools/crm_node.c     xmlNode *msg = string2xml(buffer);
msg               233 tools/crm_node.c     if (msg) {
msg               237 tools/crm_node.c         const char *quorate = crm_element_value(msg, "quorate");
msg               239 tools/crm_node.c         crm_log_xml_trace(msg, "message");
msg               248 tools/crm_node.c         for (node = __xml_first_child(msg); node != NULL; node = __xml_next(node)) {
msg               275 tools/crm_node.c         free_xml(msg);
msg               693 tools/crm_node.c                           uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len)
msg               697 tools/crm_node.c     char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from);
msg                78 tools/crm_resource.c     xmlNode *msg = string2xml(buffer);
msg                81 tools/crm_resource.c     crm_log_xml_trace(msg, "[inbound]");
msg                92 tools/crm_resource.c     free_xml(msg);
msg               428 tools/crmadmin.c validate_crm_message(xmlNode * msg, const char *sys, const char *uuid, const char *msg_type)
msg               433 tools/crmadmin.c     if (msg == NULL) {
msg               437 tools/crmadmin.c     type = crm_element_value(msg, F_CRM_MSG_TYPE);
msg               438 tools/crmadmin.c     crm_msg_reference = crm_element_value(msg, XML_ATTR_REFERENCE);