msg 82 daemons/attrd/attrd_alerts.c config_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 129 daemons/attrd/attrd_alerts.c attrd_cib_updated_cb(const char *event, xmlNode * msg) msg 131 daemons/attrd/attrd_alerts.c if (!attrd_shutting_down() && pcmk__alert_in_patchset(msg, FALSE)) { msg 989 daemons/attrd/attrd_commands.c attrd_cib_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 192 daemons/attrd/attrd_utils.c attrd_cib_replaced_cb(const char *event, xmlNode * msg) msg 43 daemons/attrd/pacemaker-attrd.c uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len) msg 48 daemons/attrd/pacemaker-attrd.c char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from); msg 104 daemons/attrd/pacemaker-attrd.c attrd_erase_cb(xmlNode *msg, int call_id, int rc, xmlNode *output, msg 66 daemons/attrd/pacemaker-attrd.h void attrd_cib_replaced_cb(const char *event, xmlNode * msg); msg 67 daemons/attrd/pacemaker-attrd.h void attrd_cib_updated_cb(const char *event, xmlNode *msg); msg 122 daemons/attrd/pacemaker-attrd.h void attrd_peer_message(crm_node_t *client, xmlNode *msg); msg 844 daemons/based/based_callbacks.c send_peer_reply(xmlNode * msg, xmlNode * result_diff, const char *originator, gboolean broadcast) msg 846 daemons/based/based_callbacks.c CRM_ASSERT(msg != NULL); msg 876 daemons/based/based_callbacks.c crm_xml_add(msg, F_CIB_ISREPLY, originator); msg 877 daemons/based/based_callbacks.c crm_xml_add(msg, F_CIB_GLOBAL_UPDATE, XML_BOOLEAN_TRUE); msg 878 daemons/based/based_callbacks.c crm_xml_add(msg, F_CIB_OPERATION, CIB_OP_APPLY_DIFF); msg 879 daemons/based/based_callbacks.c crm_xml_add(msg, F_CIB_USER, CRM_DAEMON_USER); msg 885 daemons/based/based_callbacks.c add_message_xml(msg, F_CIB_UPDATE_DIFF, result_diff); msg 886 daemons/based/based_callbacks.c crm_log_xml_explicit(msg, "copy"); msg 887 daemons/based/based_callbacks.c return send_cluster_message(NULL, crm_msg_cib, msg, TRUE); msg 892 daemons/based/based_callbacks.c crm_xml_add(msg, F_CIB_ISREPLY, originator); msg 893 daemons/based/based_callbacks.c return send_cluster_message(crm_get_peer(0, originator), crm_msg_cib, msg, FALSE); msg 1377 daemons/based/based_callbacks.c cib_peer_callback(xmlNode * msg, void *private_data) msg 1380 daemons/based/based_callbacks.c const char *originator = crm_element_value(msg, F_ORIG); msg 1386 daemons/based/based_callbacks.c if (!(crm_element_value_int(msg, F_CIB_LOCAL_NOTIFY_ID, &bcast_id))) { msg 1396 daemons/based/based_callbacks.c if (crm_element_value(msg, F_CIB_CLIENTNAME) == NULL) { msg 1397 daemons/based/based_callbacks.c crm_xml_add(msg, F_CIB_CLIENTNAME, originator); msg 1401 daemons/based/based_callbacks.c cib_process_request(msg, TRUE, NULL); msg 1406 daemons/based/based_callbacks.c const char *seq = crm_element_value(msg, F_SEQ); msg 1407 daemons/based/based_callbacks.c const char *op = crm_element_value(msg, F_CIB_OPERATION); msg 200 daemons/based/based_common.c cib_msg_copy(xmlNode * msg, gboolean with_data) msg 246 daemons/based/based_common.c value = crm_element_value(msg, field); msg 253 daemons/based/based_common.c value_struct = get_message_xml(msg, field); msg 34 daemons/based/based_notify.c xmlNode *msg; msg 39 daemons/based/based_notify.c void attach_cib_generation(xmlNode * msg, const char *field, xmlNode * a_cib); msg 59 daemons/based/based_notify.c type = crm_element_value(update->msg, F_SUBTYPE); msg 98 daemons/based/based_notify.c pcmk__remote_send_xml(client->remote, update->msg); msg 118 daemons/based/based_notify.c update.msg = xml; msg 219 daemons/based/based_notify.c attach_cib_generation(xmlNode * msg, const char *field, xmlNode * a_cib) msg 226 daemons/based/based_notify.c add_message_xml(msg, field, generation); msg 562 daemons/based/based_remote.c construct_pam_passwd(int num_msg, const struct pam_message **msg, msg 576 daemons/based/based_remote.c switch (msg[count]->msg_style) { msg 578 daemons/based/based_remote.c crm_info("PAM: %s", msg[count]->msg); msg 591 daemons/based/based_remote.c crm_err("Unhandled conversation type: %d", msg[count]->msg_style); msg 604 daemons/based/based_remote.c switch (msg[count]->msg_style) { msg 48 daemons/based/cibmon.c void cibmon_diff(const char *event, xmlNode * msg); msg 190 daemons/based/cibmon.c cibmon_diff(const char *event, xmlNode * msg) msg 198 daemons/based/cibmon.c xmlNode *update = get_message_xml(msg, F_CIB_UPDATE); msg 200 daemons/based/cibmon.c if (msg == NULL) { msg 205 daemons/based/cibmon.c crm_element_value_int(msg, F_CIB_RC, &rc); msg 206 daemons/based/cibmon.c op = crm_element_value(msg, F_CIB_OPERATION); msg 207 daemons/based/cibmon.c diff = get_message_xml(msg, F_CIB_UPDATE_RESULT); msg 239 daemons/based/pacemaker-based.c uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len) msg 244 daemons/based/pacemaker-based.c char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from); msg 82 daemons/based/pacemaker-based.h void cib_peer_callback(xmlNode *msg, void *private_data); msg 136 daemons/based/pacemaker-based.h xmlNode *cib_msg_copy(xmlNode *msg, gboolean with_data); msg 24 daemons/controld/controld_based.c do_cib_updated(const char *event, xmlNode * msg) msg 26 daemons/controld/controld_based.c if (pcmk__alert_in_patchset(msg, TRUE)) { msg 32 daemons/controld/controld_based.c do_cib_replaced(const char *event, xmlNode * msg) msg 171 daemons/controld/controld_based.c cib_delete_callback(xmlNode *msg, int call_id, int rc, xmlNode *output, msg 27 daemons/controld/controld_callbacks.c crmd_ha_msg_filter(xmlNode * msg) msg 30 daemons/controld/controld_callbacks.c const char *sys_from = crm_element_value(msg, F_CRM_SYS_FROM); msg 33 daemons/controld/controld_callbacks.c const char *from = crm_element_value(msg, F_ORIG); msg 37 daemons/controld/controld_callbacks.c const char *op = crm_element_value(msg, F_CRM_TASK); msg 44 daemons/controld/controld_callbacks.c new_input.msg = msg; msg 55 daemons/controld/controld_callbacks.c const char *sys_to = crm_element_value(msg, F_CRM_SYS_TO); msg 63 daemons/controld/controld_callbacks.c route_message(C_HA_MESSAGE, msg); msg 13 daemons/controld/controld_callbacks.h extern void crmd_ha_msg_filter(xmlNode * msg); msg 116 daemons/controld/controld_control.c xmlNode *msg = NULL; msg 122 daemons/controld/controld_control.c msg = create_request(CRM_OP_SHUTDOWN_REQ, NULL, NULL, CRM_SYSTEM_CRMD, CRM_SYSTEM_CRMD, NULL); msg 124 daemons/controld/controld_control.c if (send_cluster_message(NULL, crm_msg_crmd, msg, TRUE) == FALSE) { msg 127 daemons/controld/controld_control.c free_xml(msg); msg 379 daemons/controld/controld_control.c xmlNode *msg = pcmk__client_data2xml(client, data, &id, &flags); msg 381 daemons/controld/controld_control.c if (msg == NULL) { msg 389 daemons/controld/controld_control.c pcmk__update_acl_user(msg, F_CRM_USER, client->user); msg 392 daemons/controld/controld_control.c crm_xml_add(msg, F_CRM_SYS_FROM, client->id); msg 393 daemons/controld/controld_control.c if (controld_authorize_ipc_message(msg, client, NULL)) { msg 395 daemons/controld/controld_control.c route_message(C_IPC_MESSAGE, msg); msg 399 daemons/controld/controld_control.c free_xml(msg); msg 681 daemons/controld/controld_control.c config_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 30 daemons/controld/controld_corosync.c uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len) msg 34 daemons/controld/controld_corosync.c char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from); msg 147 daemons/controld/controld_election.c rc = election_count_vote(fsa_election, vote->msg, cur_state != S_STARTING); msg 172 daemons/controld/controld_election.c feature_update_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 43 daemons/controld/controld_execd.c const char *operation, xmlNode *msg); msg 909 daemons/controld/controld_execd.c const char *from_sys = crm_element_value(input->msg, F_CRM_SYS_FROM); msg 910 daemons/controld/controld_execd.c const char *from_host = crm_element_value(input->msg, F_CRM_HOST_FROM); msg 1335 daemons/controld/controld_execd.c char *ref = crm_element_value_copy(request->msg, XML_ATTR_REFERENCE); msg 1578 daemons/controld/controld_execd.c handle_query_op(xmlNode *msg, lrm_state_t *lrm_state) msg 1581 daemons/controld/controld_execd.c xmlNode *reply = create_reply(msg, data); msg 1765 daemons/controld/controld_execd.c user_name = pcmk__update_acl_user(input->msg, F_CRM_USER, NULL); msg 1768 daemons/controld/controld_execd.c crm_op = crm_element_value(input->msg, F_CRM_TASK); msg 1769 daemons/controld/controld_execd.c from_sys = crm_element_value(input->msg, F_CRM_SYS_FROM); msg 1771 daemons/controld/controld_execd.c from_host = crm_element_value(input->msg, F_CRM_HOST_FROM); msg 1800 daemons/controld/controld_execd.c handle_query_op(input->msg, lrm_state); msg 1843 daemons/controld/controld_execd.c crm_log_xml_warn(input->msg, "invalid resource"); msg 1853 daemons/controld/controld_execd.c crm_log_xml_warn(input->msg, "failed registration"); msg 2219 daemons/controld/controld_execd.c const char *operation, xmlNode *msg) msg 2233 daemons/controld/controld_execd.c if (msg != NULL) { msg 2234 daemons/controld/controld_execd.c transition = crm_element_value(msg, XML_ATTR_TRANSITION_KEY); msg 2236 daemons/controld/controld_execd.c crm_log_xml_err(msg, "Missing transition number"); msg 2240 daemons/controld/controld_execd.c op = construct_op(lrm_state, msg, rsc->id, operation); msg 2360 daemons/controld/controld_execd.c if (crm_element_value_epoch(msg, XML_CONFIG_ATTR_SHUTDOWN_LOCK, msg 2389 daemons/controld/controld_execd.c cib_rsc_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 23 daemons/controld/controld_execd_state.c int lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg); msg 24 daemons/controld/controld_execd_state.c void lrmd_internal_set_proxy_callback(lrmd_t * lrmd, void *userdata, void (*callback)(lrmd_t *lrmd, void *userdata, xmlNode *msg)); msg 419 daemons/controld/controld_execd_state.c crmd_proxy_send(const char *session, xmlNode *msg) msg 427 daemons/controld/controld_execd_state.c crm_log_xml_trace(msg, "to-proxy"); msg 431 daemons/controld/controld_execd_state.c remote_proxy_relay_event(proxy, msg); msg 436 daemons/controld/controld_execd_state.c crmd_proxy_dispatch(const char *session, xmlNode *msg) msg 439 daemons/controld/controld_execd_state.c crm_log_xml_trace(msg, "controller[inbound]"); msg 440 daemons/controld/controld_execd_state.c crm_xml_add(msg, F_CRM_SYS_FROM, session); msg 441 daemons/controld/controld_execd_state.c if (controld_authorize_ipc_message(msg, NULL, session)) { msg 442 daemons/controld/controld_execd_state.c route_message(C_IPC_MESSAGE, msg); msg 448 daemons/controld/controld_execd_state.c remote_config_check(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 476 daemons/controld/controld_execd_state.c crmd_remote_proxy_cb(lrmd_t *lrmd, void *userdata, xmlNode *msg) msg 479 daemons/controld/controld_execd_state.c const char *session = crm_element_value(msg, F_LRMD_IPC_SESSION); msg 482 daemons/controld/controld_execd_state.c const char *op = crm_element_value(msg, F_LRMD_IPC_OP); msg 484 daemons/controld/controld_execd_state.c const char *channel = crm_element_value(msg, F_LRMD_IPC_IPC_SERVER); msg 527 daemons/controld/controld_execd_state.c xmlNode *request = get_message_xml(msg, F_LRMD_IPC_MSG); msg 553 daemons/controld/controld_execd_state.c crm_element_value_int(msg, F_LRMD_IPC_MSG_FLAGS, &flags); msg 561 daemons/controld/controld_execd_state.c crm_element_value_int(msg, F_LRMD_IPC_MSG_ID, &msg_id); msg 568 daemons/controld/controld_execd_state.c remote_proxy_cb(lrmd, lrm_state->node_name, msg); msg 158 daemons/controld/controld_fencing.c cib_fencing_updated(xmlNode *msg, int call_id, int rc, xmlNode *output, msg 164 daemons/controld/controld_fencing.c crm_log_xml_warn(msg, "Failed update"); msg 140 daemons/controld/controld_fsa.c crm_log_xml_debug(input->msg, __func__); msg 20 daemons/controld/controld_join_client.c void join_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data); msg 35 daemons/controld/controld_join_client.c update_dc_expected(xmlNode *msg) msg 37 daemons/controld/controld_join_client.c if (fsa_our_dc && crm_is_true(crm_element_value(msg, F_CRM_DC_LEAVING))) { msg 122 daemons/controld/controld_join_client.c welcome_from = crm_element_value(input->msg, F_CRM_HOST_FROM); msg 123 daemons/controld/controld_join_client.c join_id = crm_element_value(input->msg, F_CRM_JOIN_ID); msg 125 daemons/controld/controld_join_client.c welcome_from, crm_element_value(input->msg, F_CRM_JOIN_ID)); msg 134 daemons/controld/controld_join_client.c if (update_dc(input->msg) == FALSE) { msg 140 daemons/controld/controld_join_client.c update_dc_expected(input->msg); msg 152 daemons/controld/controld_join_client.c join_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 231 daemons/controld/controld_join_client.c const char *op = crm_element_value(input->msg, F_CRM_TASK); msg 232 daemons/controld/controld_join_client.c const char *ack_nack = crm_element_value(input->msg, CRM_OP_JOIN_ACKNAK); msg 233 daemons/controld/controld_join_client.c const char *welcome_from = crm_element_value(input->msg, F_CRM_HOST_FROM); msg 245 daemons/controld/controld_join_client.c crm_element_value_int(input->msg, F_CRM_JOIN_ID, &join_id); msg 259 daemons/controld/controld_join_client.c if (update_dc(input->msg) == FALSE) { msg 265 daemons/controld/controld_join_client.c update_dc_expected(input->msg); msg 25 daemons/controld/controld_join_dc.c void finalize_sync_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data); msg 103 daemons/controld/controld_join_dc.c xmlNode *msg = create_request(join_op, NULL, host_to, CRM_SYSTEM_CRMD, msg 107 daemons/controld/controld_join_dc.c crm_xml_add_int(msg, F_CRM_JOIN_ID, current_join_id); msg 112 daemons/controld/controld_join_dc.c crm_xml_add_boolean(msg, F_CRM_DC_LEAVING, msg 114 daemons/controld/controld_join_dc.c return msg; msg 232 daemons/controld/controld_join_dc.c join_to = crm_element_value(welcome->msg, F_CRM_HOST_FROM); msg 301 daemons/controld/controld_join_dc.c const char *join_from = crm_element_value(join_ack->msg, F_CRM_HOST_FROM); msg 302 daemons/controld/controld_join_dc.c const char *ref = crm_element_value(join_ack->msg, F_CRM_REFERENCE); msg 303 daemons/controld/controld_join_dc.c const char *join_version = crm_element_value(join_ack->msg, msg 313 daemons/controld/controld_join_dc.c crm_element_value_int(join_ack->msg, F_CRM_JOIN_ID, &join_id); msg 472 daemons/controld/controld_join_dc.c finalize_sync_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 509 daemons/controld/controld_join_dc.c join_update_complete_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 522 daemons/controld/controld_join_dc.c crm_log_xml_debug(msg, "failed"); msg 539 daemons/controld/controld_join_dc.c const char *op = crm_element_value(join_ack->msg, F_CRM_TASK); msg 540 daemons/controld/controld_join_dc.c const char *join_from = crm_element_value(join_ack->msg, F_CRM_HOST_FROM); msg 559 daemons/controld/controld_join_dc.c if (crm_element_value_int(join_ack->msg, F_CRM_JOIN_ID, &join_id) != 0) { msg 94 daemons/controld/controld_membership.c crmd_node_update_complete(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 105 daemons/controld/controld_membership.c crm_log_xml_debug(msg, "failed"); msg 110 daemons/controld/controld_membership.c crm_log_xml_debug(msg, "failed"); msg 188 daemons/controld/controld_membership.c remove_conflicting_node_callback(xmlNode * msg, int call_id, int rc, msg 199 daemons/controld/controld_membership.c search_conflicting_node_callback(xmlNode * msg, int call_id, int rc, msg 279 daemons/controld/controld_membership.c node_list_update_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 285 daemons/controld/controld_membership.c crm_log_xml_debug(msg, "update:failed"); msg 290 daemons/controld/controld_membership.c crm_log_xml_debug(msg, "update:failed"); msg 380 daemons/controld/controld_membership.c cib_quorum_update_complete(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 389 daemons/controld/controld_membership.c crm_log_xml_debug(msg, "failed"); msg 28 daemons/controld/controld_messages.c static enum crmd_fsa_input handle_message(xmlNode *msg, msg 34 daemons/controld/controld_messages.c static void send_msg_via_ipc(xmlNode * msg, const char *sys); msg 124 daemons/controld/controld_messages.c CRM_CHECK(((ha_msg_input_t *) data)->msg != NULL, msg 196 daemons/controld/controld_messages.c copy->msg = (orig && orig->msg)? copy_xml(orig->msg) : NULL; msg 197 daemons/controld/controld_messages.c copy->xml = get_message_xml(copy->msg, F_CRM_DATA); msg 284 daemons/controld/controld_messages.c route_message(msg_data->fsa_cause, input->msg); msg 293 daemons/controld/controld_messages.c fsa_input.msg = input; msg 326 daemons/controld/controld_messages.c relay_message(xmlNode * msg, gboolean originated_locally) msg 335 daemons/controld/controld_messages.c const char *host_to = crm_element_value(msg, F_CRM_HOST_TO); msg 336 daemons/controld/controld_messages.c const char *sys_to = crm_element_value(msg, F_CRM_SYS_TO); msg 337 daemons/controld/controld_messages.c const char *sys_from = crm_element_value(msg, F_CRM_SYS_FROM); msg 338 daemons/controld/controld_messages.c const char *type = crm_element_value(msg, F_TYPE); msg 339 daemons/controld/controld_messages.c const char *task = crm_element_value(msg, F_CRM_TASK); msg 340 daemons/controld/controld_messages.c const char *ref = crm_element_value(msg, XML_ATTR_REFERENCE); msg 346 daemons/controld/controld_messages.c if (msg == NULL) { msg 358 daemons/controld/controld_messages.c crm_log_xml_warn(msg, "[bad message type]"); msg 363 daemons/controld/controld_messages.c crm_log_xml_warn(msg, "[no subsystem]"); msg 398 daemons/controld/controld_messages.c xmlNode *msg_data = get_message_xml(msg, F_CRM_DATA); msg 410 daemons/controld/controld_messages.c send_msg_via_ipc(msg, sys_to); msg 425 daemons/controld/controld_messages.c send_cluster_message(host_to ? crm_get_peer(0, host_to) : NULL, dest, msg, TRUE); msg 442 daemons/controld/controld_messages.c crm_log_xml_trace(msg, "[IPC relay]"); msg 443 daemons/controld/controld_messages.c send_msg_via_ipc(msg, sys_to); msg 470 daemons/controld/controld_messages.c send_cluster_message(host_to ? node_to : NULL, dest, msg, TRUE); msg 569 daemons/controld/controld_messages.c handle_message(xmlNode *msg, enum crmd_fsa_cause cause) msg 573 daemons/controld/controld_messages.c CRM_CHECK(msg != NULL, return I_NULL); msg 575 daemons/controld/controld_messages.c type = crm_element_value(msg, F_CRM_MSG_TYPE); msg 577 daemons/controld/controld_messages.c return handle_request(msg, cause); msg 580 daemons/controld/controld_messages.c handle_response(msg); msg 731 daemons/controld/controld_messages.c handle_remote_state(xmlNode *msg) msg 733 daemons/controld/controld_messages.c const char *remote_uname = ID(msg); msg 734 daemons/controld/controld_messages.c const char *remote_is_up = crm_element_value(msg, XML_NODE_IN_CLUSTER); msg 756 daemons/controld/controld_messages.c handle_ping(xmlNode *msg) msg 764 daemons/controld/controld_messages.c value = crm_element_value(msg, F_CRM_SYS_TO); msg 777 daemons/controld/controld_messages.c msg = create_reply(msg, ping); msg 779 daemons/controld/controld_messages.c if (msg) { msg 780 daemons/controld/controld_messages.c (void) relay_message(msg, TRUE); msg 781 daemons/controld/controld_messages.c free_xml(msg); msg 832 daemons/controld/controld_messages.c handle_node_info_request(xmlNode *msg) msg 848 daemons/controld/controld_messages.c crm_element_value_int(msg, XML_ATTR_ID, &node_id); msg 852 daemons/controld/controld_messages.c value = crm_element_value(msg, XML_ATTR_UNAME); msg 870 daemons/controld/controld_messages.c msg = create_reply(msg, reply); msg 872 daemons/controld/controld_messages.c if (msg) { msg 873 daemons/controld/controld_messages.c (void) relay_message(msg, TRUE); msg 874 daemons/controld/controld_messages.c free_xml(msg); msg 882 daemons/controld/controld_messages.c verify_feature_set(xmlNode *msg) msg 884 daemons/controld/controld_messages.c const char *dc_version = crm_element_value(msg, XML_ATTR_CRM_VERSION); msg 971 daemons/controld/controld_messages.c xmlNode *msg = NULL; msg 1020 daemons/controld/controld_messages.c fsa_input.msg = stored_msg; msg 1042 daemons/controld/controld_messages.c fsa_input.msg = stored_msg; msg 1100 daemons/controld/controld_messages.c msg = create_request(CRM_OP_RM_NODE_CACHE, NULL, NULL, CRM_SYSTEM_CRMD, CRM_SYSTEM_CRMD, NULL); msg 1101 daemons/controld/controld_messages.c if (send_cluster_message(NULL, crm_msg_crmd, msg, TRUE) == FALSE) { msg 1106 daemons/controld/controld_messages.c free_xml(msg); msg 1160 daemons/controld/controld_messages.c fsa_input.msg = stored_msg; msg 1209 daemons/controld/controld_messages.c extern gboolean process_te_message(xmlNode * msg, xmlNode * xml_data); msg 1212 daemons/controld/controld_messages.c send_msg_via_ipc(xmlNode * msg, const char *sys) msg 1216 daemons/controld/controld_messages.c if (crm_element_value(msg, F_CRM_HOST_FROM) == NULL) { msg 1217 daemons/controld/controld_messages.c crm_xml_add(msg, F_CRM_HOST_FROM, fsa_our_uname); msg 1222 daemons/controld/controld_messages.c pcmk__ipc_send_xml(client_channel, 0, msg, crm_ipc_server_event); msg 1225 daemons/controld/controld_messages.c xmlNode *data = get_message_xml(msg, F_CRM_DATA); msg 1227 daemons/controld/controld_messages.c process_te_message(msg, data); msg 1233 daemons/controld/controld_messages.c fsa_input.msg = msg; msg 1234 daemons/controld/controld_messages.c fsa_input.xml = get_message_xml(msg, F_CRM_DATA); msg 1247 daemons/controld/controld_messages.c crmd_proxy_send(sys, msg); msg 1260 daemons/controld/controld_messages.c free_xml(orig->msg); msg 1279 daemons/controld/controld_messages.c xmlNode *msg = create_request(CRM_OP_REMOTE_STATE, NULL, fsa_our_dc, msg 1284 daemons/controld/controld_messages.c crm_xml_add(msg, XML_ATTR_ID, node_name); msg 1285 daemons/controld/controld_messages.c crm_xml_add_boolean(msg, XML_NODE_IN_CLUSTER, node_up); msg 1286 daemons/controld/controld_messages.c send_cluster_message(crm_get_peer(0, fsa_our_dc), crm_msg_crmd, msg, msg 1288 daemons/controld/controld_messages.c free_xml(msg); msg 20 daemons/controld/controld_messages.h xmlNode *msg; msg 74 daemons/controld/controld_messages.h void crmd_proxy_send(const char *session, xmlNode *msg); msg 80 daemons/controld/controld_messages.h extern gboolean send_request(xmlNode * msg, char **msg_reference); msg 54 daemons/controld/controld_schedulerd.c save_cib_contents(xmlNode *msg, int call_id, int rc, xmlNode *output, msg 131 daemons/controld/controld_schedulerd.c xmlNode *msg = string2xml(buffer); msg 133 daemons/controld/controld_schedulerd.c if (msg) { msg 134 daemons/controld/controld_schedulerd.c route_message(C_IPC_MESSAGE, msg); msg 136 daemons/controld/controld_schedulerd.c free_xml(msg); msg 191 daemons/controld/controld_schedulerd.c static void do_pe_invoke_callback(xmlNode *msg, int call_id, int rc, msg 266 daemons/controld/controld_schedulerd.c controld_expect_sched_reply(xmlNode *msg) msg 270 daemons/controld/controld_schedulerd.c if (msg) { msg 271 daemons/controld/controld_schedulerd.c ref = crm_element_value_copy(msg, XML_ATTR_REFERENCE); msg 408 daemons/controld/controld_schedulerd.c do_pe_invoke_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 330 daemons/controld/controld_te_actions.c .msg = cmd, msg 334 daemons/controld/controld_te_actions.c fsa_data_t msg = { msg 344 daemons/controld/controld_te_actions.c do_lrm_invoke(A_LRM_INVOKE, C_FSA_INTERNAL, fsa_state, I_NULL, &msg); msg 22 daemons/controld/controld_te_callbacks.c void te_update_confirm(const char *event, xmlNode * msg); msg 550 daemons/controld/controld_te_callbacks.c te_update_diff(const char *event, xmlNode * msg) msg 559 daemons/controld/controld_te_callbacks.c CRM_CHECK(msg != NULL, return); msg 560 daemons/controld/controld_te_callbacks.c crm_element_value_int(msg, F_CIB_RC, &rc); msg 579 daemons/controld/controld_te_callbacks.c op = crm_element_value(msg, F_CIB_OPERATION); msg 580 daemons/controld/controld_te_callbacks.c diff = get_message_xml(msg, F_CIB_UPDATE_RESULT); msg 602 daemons/controld/controld_te_callbacks.c process_te_message(xmlNode * msg, xmlNode * xml_data) msg 604 daemons/controld/controld_te_callbacks.c const char *from = crm_element_value(msg, F_ORIG); msg 605 daemons/controld/controld_te_callbacks.c const char *sys_to = crm_element_value(msg, F_CRM_SYS_TO); msg 606 daemons/controld/controld_te_callbacks.c const char *sys_from = crm_element_value(msg, F_CRM_SYS_FROM); msg 607 daemons/controld/controld_te_callbacks.c const char *ref = crm_element_value(msg, F_CRM_REFERENCE); msg 608 daemons/controld/controld_te_callbacks.c const char *op = crm_element_value(msg, F_CRM_TASK); msg 609 daemons/controld/controld_te_callbacks.c const char *type = crm_element_value(msg, F_CRM_MSG_TYPE); msg 612 daemons/controld/controld_te_callbacks.c crm_log_xml_trace(msg, "ipc"); msg 627 daemons/controld/controld_te_callbacks.c crm_log_xml_trace(msg, "Processing (N)ACK"); msg 628 daemons/controld/controld_te_callbacks.c crm_debug("Processing (N)ACK %s from %s", crm_element_value(msg, F_CRM_REFERENCE), from); msg 643 daemons/controld/controld_te_callbacks.c crm_log_xml_err(msg, "Invalid (N)ACK"); msg 658 daemons/controld/controld_te_callbacks.c cib_action_updated(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 21 daemons/controld/controld_transition.c global_cib_callback(const xmlNode * msg, int callid, int rc, xmlNode * output) msg 145 daemons/controld/controld_transition.c const char *ref = crm_element_value(input->msg, XML_ATTR_REFERENCE); msg 146 daemons/controld/controld_transition.c const char *graph_file = crm_element_value(input->msg, F_CRM_TGRAPH); msg 147 daemons/controld/controld_transition.c const char *graph_input = crm_element_value(input->msg, F_CRM_TGRAPH_INPUT); msg 150 daemons/controld/controld_transition.c crm_log_xml_err(input->msg, "Bad command"); msg 179 daemons/controld/controld_transition.c crm_log_xml_err(input->msg, "Bad command"); msg 31 daemons/controld/controld_transition.h extern gboolean process_te_message(xmlNode * msg, xmlNode * xml_data); msg 40 daemons/controld/controld_transition.h void cib_action_updated(xmlNode *msg, int call_id, int rc, xmlNode *output, msg 44 daemons/controld/controld_transition.h void te_update_diff(const char *event, xmlNode *msg); msg 691 daemons/controld/controld_utils.c update_dc(xmlNode * msg) msg 697 daemons/controld/controld_utils.c if (msg != NULL) { msg 700 daemons/controld/controld_utils.c dc_version = crm_element_value(msg, F_CRM_VERSION); msg 701 daemons/controld/controld_utils.c welcome_from = crm_element_value(msg, F_CRM_HOST_FROM); msg 74 daemons/controld/controld_utils.h void controld_expect_sched_reply(xmlNode *msg); msg 79 daemons/controld/controld_utils.h gboolean update_dc(xmlNode * msg); msg 32 daemons/controld/pacemaker-controld.c void crmd_hamsg_callback(const xmlNode * msg, void *private_data); msg 29 daemons/controld/pacemaker-controld.h void do_cib_updated(const char *event, xmlNode * msg); msg 30 daemons/controld/pacemaker-controld.h void do_cib_replaced(const char *event, xmlNode * msg); msg 246 daemons/execd/execd_commands.c build_rsc_from_xml(xmlNode * msg) msg 248 daemons/execd/execd_commands.c xmlNode *rsc_xml = get_xpath_object("//" F_LRMD_RSC, msg, LOG_ERR); msg 253 daemons/execd/execd_commands.c crm_element_value_int(msg, F_LRMD_CALLOPTS, &rsc->call_opts); msg 265 daemons/execd/execd_commands.c create_lrmd_cmd(xmlNode *msg, pcmk__client_t *client) msg 268 daemons/execd/execd_commands.c xmlNode *rsc_xml = get_xpath_object("//" F_LRMD_RSC, msg, LOG_ERR); msg 273 daemons/execd/execd_commands.c crm_element_value_int(msg, F_LRMD_CALLOPTS, &call_options); msg 277 daemons/execd/execd_commands.c crm_element_value_int(msg, F_LRMD_CALLID, &cmd->call_id); msg 506 daemons/execd/execd_commands.c const char *msg = NULL; msg 532 daemons/execd/execd_commands.c msg = "Disconnected"; msg 536 daemons/execd/execd_commands.c msg = pcmk_rc_str(rc); msg 541 daemons/execd/execd_commands.c client->name, client->id, msg, rc); msg 229 daemons/execd/pacemaker-execd.c lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg) msg 238 daemons/execd/pacemaker-execd.c return pcmk__ipc_send_xml(client, 0, msg, crm_ipc_server_event); msg 245 daemons/execd/pacemaker-execd.c return lrmd_tls_send_msg(client->remote, msg, 0, "notify"); msg 58 daemons/execd/pacemaker-execd.h int lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg); msg 70 daemons/execd/remoted_proxy.c xmlNode *msg; msg 98 daemons/execd/remoted_proxy.c msg = create_xml_node(NULL, T_LRMD_IPC_PROXY); msg 99 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_NEW); msg 100 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_IPC_SERVER, ipc_channel); msg 101 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id); msg 102 daemons/execd/remoted_proxy.c lrmd_server_send_notify(ipc_proxy, msg); msg 103 daemons/execd/remoted_proxy.c free_xml(msg); msg 145 daemons/execd/remoted_proxy.c xmlNode *msg = get_message_xml(xml, F_LRMD_IPC_MSG); msg 165 daemons/execd/remoted_proxy.c xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY); msg 166 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_DESTROY); msg 167 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_SESSION, session); msg 168 daemons/execd/remoted_proxy.c lrmd_server_send_notify(ipc_proxy, msg); msg 169 daemons/execd/remoted_proxy.c free_xml(msg); msg 189 daemons/execd/remoted_proxy.c rc = pcmk__ipc_send_xml(ipc_client, 0, msg, crm_ipc_server_event); msg 196 daemons/execd/remoted_proxy.c rc = pcmk__ipc_send_xml(ipc_client, msg_id, msg, FALSE); msg 222 daemons/execd/remoted_proxy.c xmlNode *msg = NULL; msg 259 daemons/execd/remoted_proxy.c msg = create_xml_node(NULL, T_LRMD_IPC_PROXY); msg 260 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_REQUEST); msg 261 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id); msg 262 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_CLIENT, pcmk__client_name(client)); msg 263 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_USER, client->user); msg 264 daemons/execd/remoted_proxy.c crm_xml_add_int(msg, F_LRMD_IPC_MSG_ID, id); msg 265 daemons/execd/remoted_proxy.c crm_xml_add_int(msg, F_LRMD_IPC_MSG_FLAGS, flags); msg 266 daemons/execd/remoted_proxy.c add_message_xml(msg, F_LRMD_IPC_MSG, request); msg 267 daemons/execd/remoted_proxy.c lrmd_server_send_notify(ipc_proxy, msg); msg 269 daemons/execd/remoted_proxy.c free_xml(msg); msg 283 daemons/execd/remoted_proxy.c xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY); msg 286 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_SHUTDOWN_REQ); msg 291 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_SESSION, "0"); msg 293 daemons/execd/remoted_proxy.c rc = (lrmd_server_send_notify(ipc_proxy, msg) != pcmk_rc_ok)? -1 : 0; msg 294 daemons/execd/remoted_proxy.c free_xml(msg); msg 313 daemons/execd/remoted_proxy.c xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY); msg 314 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_DESTROY); msg 315 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id); msg 316 daemons/execd/remoted_proxy.c lrmd_server_send_notify(ipc_proxy, msg); msg 317 daemons/execd/remoted_proxy.c free_xml(msg); msg 231 daemons/fenced/fenced_commands.c create_async_command(xmlNode * msg) msg 234 daemons/fenced/fenced_commands.c xmlNode *op = get_xpath_object("//@" F_STONITH_ACTION, msg, LOG_ERR); msg 237 daemons/fenced/fenced_commands.c CRM_CHECK(action != NULL, crm_log_xml_warn(msg, "NoAction"); return NULL); msg 239 daemons/fenced/fenced_commands.c crm_log_xml_trace(msg, "Command"); msg 241 daemons/fenced/fenced_commands.c crm_element_value_int(msg, F_STONITH_CALLID, &(cmd->id)); msg 242 daemons/fenced/fenced_commands.c crm_element_value_int(msg, F_STONITH_CALLOPTS, &(cmd->options)); msg 243 daemons/fenced/fenced_commands.c crm_element_value_int(msg, F_STONITH_TIMEOUT, &(cmd->default_timeout)); msg 246 daemons/fenced/fenced_commands.c crm_element_value_int(msg, F_STONITH_DELAY, &(cmd->start_delay)); msg 248 daemons/fenced/fenced_commands.c cmd->origin = crm_element_value_copy(msg, F_ORIG); msg 249 daemons/fenced/fenced_commands.c cmd->remote_op_id = crm_element_value_copy(msg, F_STONITH_REMOTE_OP_ID); msg 250 daemons/fenced/fenced_commands.c cmd->client = crm_element_value_copy(msg, F_STONITH_CLIENTID); msg 251 daemons/fenced/fenced_commands.c cmd->client_name = crm_element_value_copy(msg, F_STONITH_CLIENTNAME); msg 252 daemons/fenced/fenced_commands.c cmd->op = crm_element_value_copy(msg, F_STONITH_OPERATION); msg 258 daemons/fenced/fenced_commands.c CRM_CHECK(cmd->op != NULL, crm_log_xml_warn(msg, "NoOp"); free_async_command(cmd); return NULL); msg 259 daemons/fenced/fenced_commands.c CRM_CHECK(cmd->client != NULL, crm_log_xml_warn(msg, "NoClient")); msg 882 daemons/fenced/fenced_commands.c build_device_from_xml(xmlNode * msg) msg 885 daemons/fenced/fenced_commands.c xmlNode *dev = get_xpath_object("//" F_STONITH_DEVICE, msg, LOG_ERR); msg 1153 daemons/fenced/fenced_commands.c stonith_device_register(xmlNode * msg, const char **desc, gboolean from_cib) msg 1156 daemons/fenced/fenced_commands.c stonith_device_t *device = build_device_from_xml(msg); msg 1382 daemons/fenced/fenced_commands.c stonith_level_register(xmlNode *msg, char **desc) msg 1397 daemons/fenced/fenced_commands.c if (pcmk__str_eq(TYPE(msg), XML_TAG_FENCING_LEVEL, pcmk__str_casei)) { msg 1398 daemons/fenced/fenced_commands.c level = msg; msg 1400 daemons/fenced/fenced_commands.c level = get_xpath_object("//" XML_TAG_FENCING_LEVEL, msg, LOG_ERR); msg 1457 daemons/fenced/fenced_commands.c stonith_level_remove(xmlNode *msg, char **desc) msg 1464 daemons/fenced/fenced_commands.c xmlNode *level = get_xpath_object("//" XML_TAG_FENCING_LEVEL, msg, LOG_ERR); msg 1518 daemons/fenced/fenced_commands.c stonith_device_action(xmlNode * msg, char **output) msg 1520 daemons/fenced/fenced_commands.c xmlNode *dev = get_xpath_object("//" F_STONITH_DEVICE, msg, LOG_ERR); msg 1521 daemons/fenced/fenced_commands.c xmlNode *op = get_xpath_object("//@" F_STONITH_ACTION, msg, LOG_ERR); msg 1544 daemons/fenced/fenced_commands.c cmd = create_async_command(msg); msg 1986 daemons/fenced/fenced_commands.c stonith_query(xmlNode * msg, const char *remote_peer, const char *client_id, int call_options) msg 1992 daemons/fenced/fenced_commands.c xmlNode *dev = get_xpath_object("//@" F_STONITH_ACTION, msg, LOG_NEVER); msg 1994 daemons/fenced/fenced_commands.c crm_element_value_int(msg, F_STONITH_TIMEOUT, &timeout); msg 2006 daemons/fenced/fenced_commands.c crm_log_xml_debug(msg, "Query"); msg 2009 daemons/fenced/fenced_commands.c query->reply = stonith_construct_reply(msg, NULL, NULL, pcmk_ok); msg 2301 daemons/fenced/fenced_commands.c stonith_fence(xmlNode * msg) msg 2305 daemons/fenced/fenced_commands.c async_command_t *cmd = create_async_command(msg); msg 2306 daemons/fenced/fenced_commands.c xmlNode *dev = get_xpath_object("//@" F_STONITH_TARGET, msg, LOG_ERR); msg 400 daemons/fenced/fenced_history.c stonith_fence_history(xmlNode *msg, xmlNode **output, msg 405 daemons/fenced/fenced_history.c xmlNode *dev = get_xpath_object("//@" F_STONITH_TARGET, msg, LOG_NEVER); msg 425 daemons/fenced/fenced_history.c crm_element_value(msg, F_STONITH_CALLID) != NULL); msg 432 daemons/fenced/fenced_history.c if (crm_element_value(msg, F_STONITH_CALLID)) { msg 447 daemons/fenced/fenced_history.c msg, LOG_NEVER); msg 957 daemons/fenced/fenced_remote.c stonith_manual_ack(xmlNode * msg, remote_fencing_op_t * op) msg 959 daemons/fenced/fenced_remote.c xmlNode *dev = get_xpath_object("//@" F_STONITH_TARGET, msg, LOG_ERR); msg 968 daemons/fenced/fenced_remote.c remote_op_done(op, msg, pcmk_ok, FALSE); msg 1451 daemons/fenced/fenced_remote.c xmlNode *msg, int rc) msg 1495 daemons/fenced/fenced_remote.c remote_op_done(op, msg, rc, FALSE); msg 1889 daemons/fenced/fenced_remote.c process_remote_stonith_query(xmlNode * msg) msg 1899 daemons/fenced/fenced_remote.c xmlNode *dev = get_xpath_object("//@" F_STONITH_REMOTE_OP_ID, msg, LOG_ERR); msg 1906 daemons/fenced/fenced_remote.c dev = get_xpath_object("//@" F_STONITH_AVAILABLE_DEVICES, msg, LOG_ERR); msg 1924 daemons/fenced/fenced_remote.c host = crm_element_value(msg, F_ORIG); msg 1988 daemons/fenced/fenced_remote.c process_remote_stonith_exec(xmlNode * msg) msg 1994 daemons/fenced/fenced_remote.c xmlNode *dev = get_xpath_object("//@" F_STONITH_REMOTE_OP_ID, msg, LOG_ERR); msg 2001 daemons/fenced/fenced_remote.c dev = get_xpath_object("//@" F_STONITH_RC, msg, LOG_ERR); msg 2033 daemons/fenced/fenced_remote.c if (pcmk__str_eq(crm_element_value(msg, F_SUBTYPE), "broadcast", pcmk__str_casei)) { msg 2042 daemons/fenced/fenced_remote.c remote_op_done(op, msg, rc, FALSE); msg 2054 daemons/fenced/fenced_remote.c const char *device = crm_element_value(msg, F_STONITH_DEVICE); msg 2064 daemons/fenced/fenced_remote.c remote_op_done(op, msg, rc, FALSE); msg 2080 daemons/fenced/fenced_remote.c advance_topology_device_in_level(op, device, msg, rc); msg 2087 daemons/fenced/fenced_remote.c remote_op_done(op, msg, rc, FALSE); msg 2095 daemons/fenced/fenced_remote.c remote_op_done(op, msg, rc, FALSE); msg 2100 daemons/fenced/fenced_remote.c remote_op_done(op, msg, rc, FALSE); msg 167 daemons/fenced/pacemaker-fenced.c stonith_peer_callback(xmlNode * msg, void *private_data) msg 169 daemons/fenced/pacemaker-fenced.c const char *remote_peer = crm_element_value(msg, F_ORIG); msg 170 daemons/fenced/pacemaker-fenced.c const char *op = crm_element_value(msg, F_STONITH_OPERATION); msg 176 daemons/fenced/pacemaker-fenced.c crm_log_xml_trace(msg, "Peer[inbound]"); msg 177 daemons/fenced/pacemaker-fenced.c stonith_command(NULL, 0, 0, msg, remote_peer); msg 184 daemons/fenced/pacemaker-fenced.c uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len) msg 189 daemons/fenced/pacemaker-fenced.c char *data = pcmk_message_common_cs(handle, nodeid, pid, msg, &kind, &from); msg 714 daemons/fenced/pacemaker-fenced.c update_cib_stonith_devices_v2(const char *event, xmlNode * msg) msg 719 daemons/fenced/pacemaker-fenced.c xmlNode *patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT); msg 777 daemons/fenced/pacemaker-fenced.c update_cib_stonith_devices_v1(const char *event, xmlNode * msg) msg 784 daemons/fenced/pacemaker-fenced.c xpath_obj = xpath_search(msg, "//" F_CIB_UPDATE_RESULT "//" XML_CONS_TAG_RSC_LOCATION); msg 801 daemons/fenced/pacemaker-fenced.c xpath_obj = xpath_search(msg, "//" F_CIB_UPDATE_RESULT "//" XML_TAG_DIFF_REMOVED "//" XML_CIB_TAG_RESOURCE); msg 808 daemons/fenced/pacemaker-fenced.c xpath_obj = xpath_search(msg, "//" F_CIB_UPDATE_RESULT "//" XML_TAG_DIFF_ADDED "//" XML_CIB_TAG_RESOURCE); msg 838 daemons/fenced/pacemaker-fenced.c update_cib_stonith_devices(const char *event, xmlNode * msg) msg 841 daemons/fenced/pacemaker-fenced.c xmlNode *patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT); msg 847 daemons/fenced/pacemaker-fenced.c update_cib_stonith_devices_v1(event, msg); msg 850 daemons/fenced/pacemaker-fenced.c update_cib_stonith_devices_v2(event, msg); msg 895 daemons/fenced/pacemaker-fenced.c update_fencing_topology(const char *event, xmlNode * msg) msg 900 daemons/fenced/pacemaker-fenced.c xmlNode *patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT); msg 908 daemons/fenced/pacemaker-fenced.c xpathObj = xpath_search(msg, xpath); msg 915 daemons/fenced/pacemaker-fenced.c xpathObj = xpath_search(msg, xpath); msg 993 daemons/fenced/pacemaker-fenced.c update_cib_cache_cb(const char *event, xmlNode * msg) msg 1005 daemons/fenced/pacemaker-fenced.c } else if(msg == NULL) { msg 1017 daemons/fenced/pacemaker-fenced.c crm_element_value_int(msg, F_CIB_RC, &rc); msg 1022 daemons/fenced/pacemaker-fenced.c patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT); msg 1099 daemons/fenced/pacemaker-fenced.c update_fencing_topology(event, msg); msg 1100 daemons/fenced/pacemaker-fenced.c update_cib_stonith_devices(event, msg); msg 1105 daemons/fenced/pacemaker-fenced.c init_cib_cache_cb(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 217 daemons/fenced/pacemaker-fenced.h int stonith_device_register(xmlNode * msg, const char **desc, gboolean from_cib); msg 221 daemons/fenced/pacemaker-fenced.h char *stonith_level_key(xmlNode * msg, int mode); msg 222 daemons/fenced/pacemaker-fenced.h int stonith_level_kind(xmlNode * msg); msg 223 daemons/fenced/pacemaker-fenced.h int stonith_level_register(xmlNode * msg, char **desc); msg 225 daemons/fenced/pacemaker-fenced.h int stonith_level_remove(xmlNode * msg, char **desc); msg 246 daemons/fenced/pacemaker-fenced.h int process_remote_stonith_exec(xmlNode * msg); msg 248 daemons/fenced/pacemaker-fenced.h int process_remote_stonith_query(xmlNode * msg); msg 252 daemons/fenced/pacemaker-fenced.h int stonith_fence_history(xmlNode *msg, xmlNode **output, msg 259 daemons/fenced/pacemaker-fenced.h int stonith_manual_ack(xmlNode * msg, remote_fencing_op_t * op); msg 516 daemons/pacemakerd/pacemakerd.c pcmk_handle_ping_request(pcmk__client_t *c, xmlNode *msg, uint32_t id) msg 522 daemons/pacemakerd/pacemakerd.c const char *from = crm_element_value(msg, F_CRM_SYS_FROM); msg 526 daemons/pacemakerd/pacemakerd.c crm_str(crm_element_value(msg, F_CRM_ORIGIN)), msg 529 daemons/pacemakerd/pacemakerd.c value = crm_element_value(msg, F_CRM_SYS_TO); msg 534 daemons/pacemakerd/pacemakerd.c reply = create_reply(msg, ping); msg 567 daemons/pacemakerd/pacemakerd.c xmlNode *msg = NULL; msg 572 daemons/pacemakerd/pacemakerd.c msg = pcmk__client_data2xml(c, data, &id, &flags); msg 573 daemons/pacemakerd/pacemakerd.c if (msg == NULL) { msg 578 daemons/pacemakerd/pacemakerd.c task = crm_element_value(msg, F_CRM_TASK); msg 593 daemons/pacemakerd/pacemakerd.c crm_element_value(msg, F_CRM_REFERENCE), msg 594 daemons/pacemakerd/pacemakerd.c crm_element_value(msg, F_CRM_ORIGIN)); msg 610 daemons/pacemakerd/pacemakerd.c pcmk_handle_ping_request(c, msg, id); msg 618 daemons/pacemakerd/pacemakerd.c free_xml(msg); msg 55 daemons/schedulerd/pacemaker-schedulerd.c process_pe_message(xmlNode *msg, xmlNode *xml_data, pcmk__client_t *sender) msg 60 daemons/schedulerd/pacemaker-schedulerd.c const char *sys_to = crm_element_value(msg, F_CRM_SYS_TO); msg 61 daemons/schedulerd/pacemaker-schedulerd.c const char *op = crm_element_value(msg, F_CRM_TASK); msg 62 daemons/schedulerd/pacemaker-schedulerd.c const char *ref = crm_element_value(msg, F_CRM_REFERENCE); msg 72 daemons/schedulerd/pacemaker-schedulerd.c } else if (pcmk__str_eq(crm_element_value(msg, F_CRM_MSG_TYPE), XML_ATTR_RESPONSE, pcmk__str_casei)) { msg 151 daemons/schedulerd/pacemaker-schedulerd.c reply = create_reply(msg, sched_data_set->graph); msg 218 daemons/schedulerd/pacemaker-schedulerd.c gboolean process_pe_message(xmlNode *msg, xmlNode *xml_data, msg 227 daemons/schedulerd/pacemaker-schedulerd.c xmlNode *msg = pcmk__client_data2xml(c, data, &id, &flags); msg 230 daemons/schedulerd/pacemaker-schedulerd.c if (msg != NULL) { msg 231 daemons/schedulerd/pacemaker-schedulerd.c xmlNode *data_xml = get_message_xml(msg, F_CRM_DATA); msg 233 daemons/schedulerd/pacemaker-schedulerd.c process_pe_message(msg, data_xml, c); msg 234 daemons/schedulerd/pacemaker-schedulerd.c free_xml(msg); msg 789 include/config.h # define _GL_ATTRIBUTE_ERROR(msg) __attribute__ ((__error__ (msg))) msg 790 include/config.h # define _GL_ATTRIBUTE_WARNING(msg) __attribute__ ((__warning__ (msg))) msg 792 include/config.h # define _GL_ATTRIBUTE_ERROR(msg) __attribute__ ((__diagnose_if__ (1, msg, "error"))) msg 793 include/config.h # define _GL_ATTRIBUTE_WARNING(msg) __attribute__ ((__diagnose_if__ (1, msg, "warning"))) msg 795 include/config.h # define _GL_ATTRIBUTE_ERROR(msg) msg 796 include/config.h # define _GL_ATTRIBUTE_WARNING(msg) msg 78 include/crm/cib/cib_types.h int (*set_op_callback) (cib_t *cib, void (*callback) (const xmlNode *msg, msg 83 include/crm/cib/cib_types.h xmlNode *msg)); msg 86 include/crm/cib/cib_types.h xmlNode *msg)); msg 145 include/crm/cib/cib_types.h void (*op_callback) (const xmlNode *msg, int call_id, int rc, msg 81 include/crm/cib/internal.h void (*callback) (const char *event, xmlNode * msg); msg 128 include/crm/cib/internal.h void cib_native_callback(cib_t * cib, xmlNode * msg, int call_id, int rc); msg 158 include/crm/cluster.h char *pcmk_message_common_cs(cpg_handle_t handle, uint32_t nodeid, uint32_t pid, void *msg, msg 152 include/crm/cluster/internal.h # define ais_data_len(msg) (msg->is_compressed?msg->compressed_size:msg->size) msg 321 include/crm/cluster/internal.h gboolean check_message_sanity(const AIS_Message * msg, const char *data); msg 334 include/crm/cluster/internal.h gboolean send_cluster_message_cs(xmlNode * msg, gboolean local, msg 79 include/crm/common/alerts_internal.h bool pcmk__alert_in_patchset(xmlNode *msg, bool config); msg 17 include/crm/common/remote_internal.h int pcmk__remote_send_xml(pcmk__remote_t *remote, xmlNode *msg); msg 53 include/crm/common/xml.h gboolean add_message_xml(xmlNode * msg, const char *field, xmlNode * xml); msg 54 include/crm/common/xml.h xmlNode *get_message_xml(xmlNode * msg, const char *field); msg 131 include/crm/common/xml.h char *dump_xml_formatted(xmlNode * msg); msg 133 include/crm/common/xml.h char *dump_xml_formatted_with_text(xmlNode * msg); msg 135 include/crm/common/xml.h char *dump_xml_unformatted(xmlNode * msg); msg 32 include/crm/lrmd_internal.h int lrmd_tls_send_msg(pcmk__remote_t *session, xmlNode *msg, uint32_t id, msg 56 include/crm/lrmd_internal.h void remote_proxy_cb(lrmd_t *lrmd, const char *node_name, xmlNode *msg); msg 65 include/crm/lrmd_internal.h void remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg); msg 66 include/crm/lrmd_internal.h void remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, msg 30 lib/cib/cib_client.c int cib_client_set_op_callback(cib_t * cib, void (*callback) (const xmlNode * msg, int call_id, msg 34 lib/cib/cib_client.c void (*callback) (const char *event, xmlNode * msg)); msg 37 lib/cib/cib_client.c void (*callback) (const char *event, xmlNode * msg)); msg 437 lib/cib/cib_client.c cib_client_set_op_callback(cib_t * cib, void (*callback) (const xmlNode * msg, int call_id, msg 452 lib/cib/cib_client.c void (*callback) (const char *event, xmlNode * msg)) msg 503 lib/cib/cib_client.c void (*callback) (const char *event, xmlNode * msg)) msg 93 lib/cib/cib_native.c xmlNode *msg = NULL; msg 104 lib/cib/cib_native.c msg = string2xml(buffer); msg 106 lib/cib/cib_native.c if (msg == NULL) { msg 112 lib/cib/cib_native.c type = crm_element_value(msg, F_TYPE); msg 114 lib/cib/cib_native.c crm_log_xml_explicit(msg, "cib-reply"); msg 117 lib/cib/cib_native.c cib_native_callback(cib, msg, 0, 0); msg 120 lib/cib/cib_native.c g_list_foreach(cib->notify_list, cib_native_notify, msg); msg 126 lib/cib/cib_native.c free_xml(msg); msg 351 lib/cib/cib_remote.c xmlNode *msg = NULL; msg 357 lib/cib/cib_remote.c msg = pcmk__remote_message_xml(&private->callback); msg 358 lib/cib/cib_remote.c while (msg) { msg 359 lib/cib/cib_remote.c const char *type = crm_element_value(msg, F_TYPE); msg 364 lib/cib/cib_remote.c cib_native_callback(cib, msg, 0, 0); msg 367 lib/cib/cib_remote.c g_list_foreach(cib->notify_list, cib_native_notify, msg); msg 373 lib/cib/cib_remote.c free_xml(msg); msg 374 lib/cib/cib_remote.c msg = pcmk__remote_message_xml(&private->callback); msg 538 lib/cib/cib_utils.c cib_native_callback(cib_t * cib, xmlNode * msg, int call_id, int rc) msg 543 lib/cib/cib_utils.c if (msg != NULL) { msg 544 lib/cib/cib_utils.c crm_element_value_int(msg, F_CIB_RC, &rc); msg 545 lib/cib/cib_utils.c crm_element_value_int(msg, F_CIB_CALLID, &call_id); msg 546 lib/cib/cib_utils.c output = get_message_xml(msg, F_CIB_CALLDATA); msg 565 lib/cib/cib_utils.c blob->callback(msg, call_id, rc, output, blob->user_data); msg 569 lib/cib/cib_utils.c crm_log_xml_debug(msg, "Failed CIB Update"); msg 579 lib/cib/cib_utils.c cib->op_callback(msg, call_id, rc, output); msg 587 lib/cib/cib_utils.c xmlNode *msg = user_data; msg 591 lib/cib/cib_utils.c if (msg == NULL) { msg 596 lib/cib/cib_utils.c event = crm_element_value(msg, F_SUBTYPE); msg 612 lib/cib/cib_utils.c entry->callback(event, msg); msg 421 lib/cluster/corosync.c check_message_sanity(const AIS_Message * msg, const char *data) msg 424 lib/cluster/corosync.c int dest = msg->host.type; msg 425 lib/cluster/corosync.c int tmp_size = msg->header.size - sizeof(AIS_Message); msg 427 lib/cluster/corosync.c if (sane && msg->header.size == 0) { msg 432 lib/cluster/corosync.c if (sane && msg->header.error != CS_OK) { msg 433 lib/cluster/corosync.c crm_warn("Message header contains an error: %d", msg->header.error); msg 437 lib/cluster/corosync.c if (sane && ais_data_len(msg) != tmp_size) { msg 438 lib/cluster/corosync.c crm_warn("Message payload size is incorrect: expected %d, got %d", ais_data_len(msg), msg 443 lib/cluster/corosync.c if (sane && ais_data_len(msg) == 0) { msg 448 lib/cluster/corosync.c if (sane && data && msg->is_compressed == FALSE) { msg 451 lib/cluster/corosync.c if (ais_data_len(msg) != str_size) { msg 455 lib/cluster/corosync.c ais_data_len(msg), str_size); msg 457 lib/cluster/corosync.c for (lpc = (str_size - 10); lpc < msg->size; lpc++) { msg 468 lib/cluster/corosync.c msg->id, ais_dest(&(msg->host)), msg_type2text(dest), msg 469 lib/cluster/corosync.c ais_dest(&(msg->sender)), msg_type2text(msg->sender.type), msg 470 lib/cluster/corosync.c msg->sender.pid, msg->is_compressed, ais_data_len(msg), msg->header.size); msg 475 lib/cluster/corosync.c msg->id, ais_dest(&(msg->host)), msg_type2text(dest), ais_dest(&(msg->sender)), msg 476 lib/cluster/corosync.c msg_type2text(msg->sender.type), msg->sender.pid, msg->is_compressed, msg 477 lib/cluster/corosync.c ais_data_len(msg), msg->header.size); msg 256 lib/cluster/cpg.c AIS_Message *msg = (AIS_Message *) content; msg 263 lib/cluster/cpg.c if (msg->sender.id > 0 && msg->sender.id != nodeid) { msg 264 lib/cluster/cpg.c crm_err("Nodeid mismatch from %d.%d: claimed nodeid=%u", nodeid, pid, msg->sender.id); msg 267 lib/cluster/cpg.c } else if (msg->host.id != 0 && (local_nodeid != msg->host.id)) { msg 269 lib/cluster/cpg.c crm_trace("Not for us: %u != %u", msg->host.id, local_nodeid); msg 271 lib/cluster/cpg.c } else if (msg->host.size != 0 && !pcmk__str_eq(msg->host.uname, local_name, pcmk__str_casei)) { msg 273 lib/cluster/cpg.c crm_trace("Not for us: %s != %s", msg->host.uname, local_name); msg 277 lib/cluster/cpg.c msg->sender.id = nodeid; msg 278 lib/cluster/cpg.c if (msg->sender.size == 0) { msg 289 lib/cluster/cpg.c msg->sender.size = strlen(peer->uname); msg 290 lib/cluster/cpg.c memset(msg->sender.uname, 0, MAX_NAME); msg 291 lib/cluster/cpg.c memcpy(msg->sender.uname, peer->uname, msg->sender.size); msg 297 lib/cluster/cpg.c msg->is_compressed ? " compressed" : "", msg 298 lib/cluster/cpg.c ais_data_len(msg), msg->size, msg->compressed_size); msg 301 lib/cluster/cpg.c *kind = msg->header.id; msg 304 lib/cluster/cpg.c *from = msg->sender.uname; msg 307 lib/cluster/cpg.c if (msg->is_compressed && msg->size > 0) { msg 310 lib/cluster/cpg.c unsigned int new_size = msg->size + 1; msg 312 lib/cluster/cpg.c if (check_message_sanity(msg, NULL) == FALSE) { msg 318 lib/cluster/cpg.c rc = BZ2_bzBuffToBuffDecompress(uncompressed, &new_size, msg->data, msg->compressed_size, 1, 0); msg 328 lib/cluster/cpg.c CRM_ASSERT(new_size == msg->size); msg 332 lib/cluster/cpg.c } else if (check_message_sanity(msg, data) == FALSE) { msg 343 lib/cluster/cpg.c data = strdup(msg->data); msg 347 lib/cluster/cpg.c crm_get_peer(msg->sender.id, msg->sender.uname); msg 355 lib/cluster/cpg.c msg->id, ais_dest(&(msg->host)), msg_type2text(msg->host.type), msg 356 lib/cluster/cpg.c ais_dest(&(msg->sender)), msg_type2text(msg->sender.type), msg 357 lib/cluster/cpg.c msg->sender.pid, (int)sizeof(AIS_Message), msg 358 lib/cluster/cpg.c msg->header.size, msg->size, msg->compressed_size); msg 635 lib/cluster/cpg.c send_cluster_message_cs(xmlNode * msg, gboolean local, crm_node_t * node, enum crm_ais_msg_types dest) msg 640 lib/cluster/cpg.c data = dump_xml_unformatted(msg); msg 657 lib/cluster/cpg.c AIS_Message *msg = NULL; msg 689 lib/cluster/cpg.c msg = calloc(1, sizeof(AIS_Message)); msg 692 lib/cluster/cpg.c msg->id = msg_id; msg 693 lib/cluster/cpg.c msg->header.id = msg_class; msg 694 lib/cluster/cpg.c msg->header.error = CS_OK; msg 696 lib/cluster/cpg.c msg->host.type = dest; msg 697 lib/cluster/cpg.c msg->host.local = local; msg 702 lib/cluster/cpg.c msg->host.size = strlen(node->uname); msg 703 lib/cluster/cpg.c memset(msg->host.uname, 0, MAX_NAME); msg 704 lib/cluster/cpg.c memcpy(msg->host.uname, node->uname, msg->host.size); msg 708 lib/cluster/cpg.c msg->host.id = node->id; msg 713 lib/cluster/cpg.c msg->sender.id = 0; msg 714 lib/cluster/cpg.c msg->sender.type = sender; msg 715 lib/cluster/cpg.c msg->sender.pid = local_pid; msg 716 lib/cluster/cpg.c msg->sender.size = local_name_len; msg 717 lib/cluster/cpg.c memset(msg->sender.uname, 0, MAX_NAME); msg 718 lib/cluster/cpg.c if(local_name && msg->sender.size) { msg 719 lib/cluster/cpg.c memcpy(msg->sender.uname, local_name, msg->sender.size); msg 722 lib/cluster/cpg.c msg->size = 1 + strlen(data); msg 723 lib/cluster/cpg.c msg->header.size = sizeof(AIS_Message) + msg->size; msg 725 lib/cluster/cpg.c if (msg->size < CRM_BZ2_THRESHOLD) { msg 726 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); msg 727 lib/cluster/cpg.c memcpy(msg->data, data, msg->size); msg 734 lib/cluster/cpg.c if (pcmk__compress(uncompressed, (unsigned int) msg->size, 0, msg 737 lib/cluster/cpg.c msg->header.size = sizeof(AIS_Message) + new_size; msg 738 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); msg 739 lib/cluster/cpg.c memcpy(msg->data, compressed, new_size); msg 741 lib/cluster/cpg.c msg->is_compressed = TRUE; msg 742 lib/cluster/cpg.c msg->compressed_size = new_size; msg 747 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); msg 748 lib/cluster/cpg.c memcpy(msg->data, data, msg->size); msg 756 lib/cluster/cpg.c iov->iov_base = msg; msg 757 lib/cluster/cpg.c iov->iov_len = msg->header.size; msg 759 lib/cluster/cpg.c if (msg->compressed_size) { msg 761 lib/cluster/cpg.c msg->id, target, (unsigned long long) iov->iov_len, msg 762 lib/cluster/cpg.c msg->compressed_size, data); msg 765 lib/cluster/cpg.c msg->id, target, (unsigned long long) iov->iov_len, msg 766 lib/cluster/cpg.c msg->size, data); msg 199 lib/common/alerts.c pcmk__alert_in_patchset(xmlNode *msg, bool config) msg 203 lib/common/alerts.c xmlNode *patchset = get_message_xml(msg, F_CIB_UPDATE_RESULT); msg 207 lib/common/alerts.c CRM_CHECK(msg != NULL, return FALSE); msg 209 lib/common/alerts.c crm_element_value_int(msg, F_CIB_RC, &rc); msg 219 lib/common/alerts.c if ((xpathObj = xpath_search(msg, diff)) != NULL) { msg 220 lib/common/crmcommon_private.h void (*dispatch)(pcmk_ipc_api_t *api, xmlNode *msg); msg 321 lib/common/ipc_client.c xmlNode *msg; msg 331 lib/common/ipc_client.c msg = string2xml(buffer); msg 332 lib/common/ipc_client.c if (msg == NULL) { msg 337 lib/common/ipc_client.c call_api_dispatch(api, msg); msg 338 lib/common/ipc_client.c free_xml(msg); msg 327 lib/common/logging.c const char *msg) msg 154 lib/common/messages.c get_message_xml(xmlNode *msg, const char *field) msg 156 lib/common/messages.c xmlNode *tmp = first_named_child(msg, field); msg 162 lib/common/messages.c add_message_xml(xmlNode *msg, const char *field, xmlNode *xml) msg 164 lib/common/messages.c xmlNode *holder = create_xml_node(msg, field); msg 501 lib/common/remote.c pcmk__remote_send_xml(pcmk__remote_t *remote, xmlNode *msg) msg 510 lib/common/remote.c CRM_CHECK((remote != NULL) && (msg != NULL), return EINVAL); msg 512 lib/common/remote.c xml_text = dump_xml_unformatted(msg); msg 1308 lib/fencing/st_client.c stonith_perform_callback(stonith_t * stonith, xmlNode * msg, int call_id, int rc) msg 1324 lib/fencing/st_client.c if (msg != NULL) { msg 1325 lib/fencing/st_client.c crm_element_value_int(msg, F_STONITH_RC, &rc); msg 1326 lib/fencing/st_client.c crm_element_value_int(msg, F_STONITH_CALLID, &call_id); msg 1329 lib/fencing/st_client.c CRM_CHECK(call_id > 0, crm_log_xml_err(msg, "Bad result")); msg 1350 lib/fencing/st_client.c crm_log_xml_debug(msg, "Failed fence update"); msg 1739 lib/fencing/st_client.c xml_to_event(xmlNode * msg) msg 1742 lib/fencing/st_client.c const char *ntype = crm_element_value(msg, F_SUBTYPE); msg 1744 lib/fencing/st_client.c xmlNode *data = get_xpath_object(data_addr, msg, LOG_DEBUG); msg 1746 lib/fencing/st_client.c crm_log_xml_trace(msg, "stonith_notify"); msg 1748 lib/fencing/st_client.c crm_element_value_int(msg, F_STONITH_RC, &(event->result)); msg 1751 lib/fencing/st_client.c event->operation = crm_element_value_copy(msg, F_STONITH_OPERATION); msg 1764 lib/fencing/st_client.c crm_log_xml_notice(msg, "BadEvent"); msg 1971 lib/fencing/st_client.c const char *msg = crm_ipc_buffer(private->ipc); msg 1973 lib/fencing/st_client.c stonith_dispatch_internal(msg, strlen(msg), st); msg 56 lib/lrmd/lrmd_client.c int lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg); msg 57 lib/lrmd/lrmd_client.c static void lrmd_internal_proxy_dispatch(lrmd_t *lrmd, xmlNode *msg); msg 58 lib/lrmd/lrmd_client.c void lrmd_internal_set_proxy_callback(lrmd_t * lrmd, void *userdata, void (*callback)(lrmd_t *lrmd, void *userdata, xmlNode *msg)); msg 102 lib/lrmd/lrmd_client.c void (*proxy_callback)(lrmd_t *lrmd, void *userdata, xmlNode *msg); msg 255 lib/lrmd/lrmd_client.c lrmd_dispatch_internal(lrmd_t * lrmd, xmlNode * msg) msg 258 lib/lrmd/lrmd_client.c const char *proxy_session = crm_element_value(msg, F_LRMD_IPC_SESSION); msg 264 lib/lrmd/lrmd_client.c lrmd_internal_proxy_dispatch(lrmd, msg); msg 273 lib/lrmd/lrmd_client.c type = crm_element_value(msg, F_LRMD_OPERATION); msg 274 lib/lrmd/lrmd_client.c crm_element_value_int(msg, F_LRMD_CALLID, &event.call_id); msg 275 lib/lrmd/lrmd_client.c event.rsc_id = crm_element_value(msg, F_LRMD_RSC_ID); msg 284 lib/lrmd/lrmd_client.c crm_element_value_int(msg, F_LRMD_TIMEOUT, &event.timeout); msg 285 lib/lrmd/lrmd_client.c crm_element_value_ms(msg, F_LRMD_RSC_INTERVAL, &event.interval_ms); msg 286 lib/lrmd/lrmd_client.c crm_element_value_int(msg, F_LRMD_RSC_START_DELAY, &event.start_delay); msg 287 lib/lrmd/lrmd_client.c crm_element_value_int(msg, F_LRMD_EXEC_RC, (int *)&event.rc); msg 288 lib/lrmd/lrmd_client.c crm_element_value_int(msg, F_LRMD_OP_STATUS, &event.op_status); msg 289 lib/lrmd/lrmd_client.c crm_element_value_int(msg, F_LRMD_RSC_DELETED, &event.rsc_deleted); msg 291 lib/lrmd/lrmd_client.c crm_element_value_epoch(msg, F_LRMD_RSC_RUN_TIME, &epoch); msg 294 lib/lrmd/lrmd_client.c crm_element_value_epoch(msg, F_LRMD_RSC_RCCHANGE_TIME, &epoch); msg 297 lib/lrmd/lrmd_client.c crm_element_value_int(msg, F_LRMD_RSC_EXEC_TIME, (int *)&event.exec_time); msg 298 lib/lrmd/lrmd_client.c crm_element_value_int(msg, F_LRMD_RSC_QUEUE_TIME, (int *)&event.queue_time); msg 300 lib/lrmd/lrmd_client.c event.op_type = crm_element_value(msg, F_LRMD_RSC_ACTION); msg 301 lib/lrmd/lrmd_client.c event.user_data = crm_element_value(msg, F_LRMD_RSC_USERDATA_STR); msg 302 lib/lrmd/lrmd_client.c event.output = crm_element_value(msg, F_LRMD_RSC_OUTPUT); msg 303 lib/lrmd/lrmd_client.c event.exit_reason = crm_element_value(msg, F_LRMD_RSC_EXIT_REASON); msg 306 lib/lrmd/lrmd_client.c event.params = xml2list(msg); msg 329 lib/lrmd/lrmd_client.c xmlNode *msg; msg 337 lib/lrmd/lrmd_client.c msg = string2xml(buffer); msg 338 lib/lrmd/lrmd_client.c rc = lrmd_dispatch_internal(lrmd, msg); msg 339 lib/lrmd/lrmd_client.c free_xml(msg); msg 479 lib/lrmd/lrmd_client.c const char *msg = crm_ipc_buffer(private->ipc); msg 481 lib/lrmd/lrmd_client.c lrmd_ipc_dispatch(msg, strlen(msg), lrmd); msg 595 lib/lrmd/lrmd_client.c lrmd_tls_send_msg(pcmk__remote_t *session, xmlNode *msg, uint32_t id, msg 598 lib/lrmd/lrmd_client.c crm_xml_add_int(msg, F_LRMD_REMOTE_MSG_ID, id); msg 599 lib/lrmd/lrmd_client.c crm_xml_add(msg, F_LRMD_REMOTE_MSG_TYPE, msg_type); msg 600 lib/lrmd/lrmd_client.c return pcmk__remote_send_xml(session, msg); msg 693 lib/lrmd/lrmd_client.c lrmd_tls_send(lrmd_t * lrmd, xmlNode * msg) msg 703 lib/lrmd/lrmd_client.c rc = lrmd_tls_send_msg(native->remote, msg, global_remote_msg_id, "request"); msg 714 lib/lrmd/lrmd_client.c lrmd_tls_send_recv(lrmd_t * lrmd, xmlNode * msg, int timeout, xmlNode ** reply) msg 724 lib/lrmd/lrmd_client.c rc = lrmd_tls_send(lrmd, msg); msg 753 lib/lrmd/lrmd_client.c lrmd_send_xml(lrmd_t * lrmd, xmlNode * msg, int timeout, xmlNode ** reply) msg 760 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply); msg 764 lib/lrmd/lrmd_client.c rc = lrmd_tls_send_recv(lrmd, msg, timeout, reply); msg 775 lib/lrmd/lrmd_client.c lrmd_send_xml_no_reply(lrmd_t * lrmd, xmlNode * msg) msg 782 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL); msg 786 lib/lrmd/lrmd_client.c rc = lrmd_tls_send(lrmd, msg); msg 1699 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 1708 lib/lrmd/lrmd_client.c lrmd_internal_proxy_dispatch(lrmd_t *lrmd, xmlNode *msg) msg 1713 lib/lrmd/lrmd_client.c crm_log_xml_trace(msg, "PROXY_INBOUND"); msg 1714 lib/lrmd/lrmd_client.c native->proxy_callback(lrmd, native->proxy_callback_userdata, msg); msg 1719 lib/lrmd/lrmd_client.c lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg) msg 1724 lib/lrmd/lrmd_client.c crm_xml_add(msg, F_LRMD_OPERATION, CRM_OP_IPC_FWD); msg 1726 lib/lrmd/lrmd_client.c crm_log_xml_trace(msg, "PROXY_OUTBOUND"); msg 1727 lib/lrmd/lrmd_client.c return lrmd_send_xml_no_reply(lrmd, msg); msg 25 lib/lrmd/proxy_common.c int lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg); msg 32 lib/lrmd/proxy_common.c xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY); msg 33 lib/lrmd/proxy_common.c crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_DESTROY); msg 34 lib/lrmd/proxy_common.c crm_xml_add(msg, F_LRMD_IPC_SESSION, session_id); msg 35 lib/lrmd/proxy_common.c lrmd_internal_proxy_send(lrmd, msg); msg 36 lib/lrmd/proxy_common.c free_xml(msg); msg 47 lib/lrmd/proxy_common.c xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY); msg 48 lib/lrmd/proxy_common.c crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_SHUTDOWN_ACK); msg 49 lib/lrmd/proxy_common.c lrmd_internal_proxy_send(lrmd, msg); msg 50 lib/lrmd/proxy_common.c free_xml(msg); msg 62 lib/lrmd/proxy_common.c xmlNode *msg = create_xml_node(NULL, T_LRMD_IPC_PROXY); msg 63 lib/lrmd/proxy_common.c crm_xml_add(msg, F_LRMD_IPC_OP, LRMD_IPC_OP_SHUTDOWN_NACK); msg 64 lib/lrmd/proxy_common.c lrmd_internal_proxy_send(lrmd, msg); msg 65 lib/lrmd/proxy_common.c free_xml(msg); msg 69 lib/lrmd/proxy_common.c remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg) msg 75 lib/lrmd/proxy_common.c add_message_xml(event, F_LRMD_IPC_MSG, msg); msg 82 lib/lrmd/proxy_common.c remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, int msg_id) msg 89 lib/lrmd/proxy_common.c add_message_xml(response, F_LRMD_IPC_MSG, msg); msg 206 lib/lrmd/proxy_common.c remote_proxy_cb(lrmd_t *lrmd, const char *node_name, xmlNode *msg) msg 208 lib/lrmd/proxy_common.c const char *op = crm_element_value(msg, F_LRMD_IPC_OP); msg 209 lib/lrmd/proxy_common.c const char *session = crm_element_value(msg, F_LRMD_IPC_SESSION); msg 220 lib/lrmd/proxy_common.c crm_element_value_int(msg, F_LRMD_IPC_MSG_ID, &msg_id); msg 228 lib/lrmd/proxy_common.c xmlNode *request = get_message_xml(msg, F_LRMD_IPC_MSG); msg 229 lib/lrmd/proxy_common.c const char *name = crm_element_value(msg, F_LRMD_IPC_CLIENT); msg 248 lib/lrmd/proxy_common.c crm_element_value_int(msg, F_LRMD_IPC_MSG_FLAGS, &flags); msg 413 lib/services/dbus.c pcmk_dbus_send_recv(DBusMessage *msg, DBusConnection *connection, msg 420 lib/services/dbus.c CRM_ASSERT(dbus_message_get_type (msg) == DBUS_MESSAGE_TYPE_METHOD_CALL); msg 421 lib/services/dbus.c method = dbus_message_get_member (msg); msg 434 lib/services/dbus.c if (!dbus_connection_send_with_reply(connection, msg, &pending, timeout)) { msg 477 lib/services/dbus.c pcmk_dbus_send(DBusMessage *msg, DBusConnection *connection, msg 485 lib/services/dbus.c CRM_ASSERT(dbus_message_get_type(msg) == DBUS_MESSAGE_TYPE_METHOD_CALL); msg 486 lib/services/dbus.c method = dbus_message_get_member(msg); msg 494 lib/services/dbus.c if (!dbus_connection_send_with_reply(connection, msg, &pending, timeout)) { msg 517 lib/services/dbus.c pcmk_dbus_type_check(DBusMessage *msg, DBusMessageIter *field, int expected, msg 524 lib/services/dbus.c if (dbus_message_iter_init(msg, &lfield)) { msg 542 lib/services/dbus.c dbus_message_iter_init(msg, &args); msg 699 lib/services/dbus.c DBusMessage *msg; msg 710 lib/services/dbus.c msg = dbus_message_new_method_call(target, obj, BUS_PROPERTY_IFACE, "Get"); msg 711 lib/services/dbus.c if (msg == NULL) { msg 718 lib/services/dbus.c if (!dbus_message_append_args(msg, msg 724 lib/services/dbus.c dbus_message_unref(msg); msg 732 lib/services/dbus.c dbus_message_unref(msg); msg 745 lib/services/dbus.c dbus_message_unref(msg); msg 751 lib/services/dbus.c local_pending = pcmk_dbus_send(msg, connection, async_query_result_cb, msg 764 lib/services/dbus.c DBusMessage *reply = pcmk_dbus_send_recv(msg, connection, NULL, msg 774 lib/services/dbus.c dbus_message_unref(msg); msg 26 lib/services/pcmk-dbus.h DBusPendingCall *pcmk_dbus_send(DBusMessage *msg, DBusConnection *connection, msg 30 lib/services/pcmk-dbus.h DBusMessage *pcmk_dbus_send_recv(DBusMessage *msg, DBusConnection *connection, DBusError *error, int timeout); msg 33 lib/services/pcmk-dbus.h bool pcmk_dbus_type_check(DBusMessage *msg, DBusMessageIter *field, int expected, const char *function, int line); msg 44 lib/services/systemd.c systemd_send(DBusMessage *msg, msg 48 lib/services/systemd.c return pcmk_dbus_send(msg, systemd_proxy, done, user_data, timeout); msg 52 lib/services/systemd.c systemd_send_recv(DBusMessage *msg, DBusError *error, int timeout) msg 54 lib/services/systemd.c return pcmk_dbus_send_recv(msg, systemd_proxy, error, timeout); msg 71 lib/services/systemd.c DBusMessage *msg = systemd_new_method(method); msg 78 lib/services/systemd.c if (msg == NULL) { msg 84 lib/services/systemd.c reply = systemd_send_recv(msg, &error, DBUS_TIMEOUT_USE_DEFAULT); msg 85 lib/services/systemd.c dbus_message_unref(msg); msg 220 lib/services/systemd.c DBusMessage *msg = systemd_new_method("Reload"); msg 223 lib/services/systemd.c CRM_ASSERT(msg != NULL); msg 224 lib/services/systemd.c systemd_send(msg, systemd_daemon_reload_complete, msg 226 lib/services/systemd.c dbus_message_unref(msg); msg 317 lib/services/systemd.c DBusMessage *msg; msg 334 lib/services/systemd.c msg = systemd_new_method("LoadUnit"); msg 335 lib/services/systemd.c CRM_ASSERT(msg != NULL); msg 338 lib/services/systemd.c CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID)); msg 345 lib/services/systemd.c reply = systemd_send_recv(msg, NULL, msg 347 lib/services/systemd.c dbus_message_unref(msg); msg 359 lib/services/systemd.c pending = systemd_send(msg, systemd_loadunit_cb, op, op->timeout); msg 364 lib/services/systemd.c dbus_message_unref(msg); msg 726 lib/services/systemd.c DBusMessage *msg = NULL; msg 769 lib/services/systemd.c msg = systemd_new_method(method); msg 770 lib/services/systemd.c CRM_ASSERT(msg != NULL); msg 777 lib/services/systemd.c CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID)); msg 778 lib/services/systemd.c CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &replace_s, DBUS_TYPE_INVALID)); msg 784 lib/services/systemd.c DBusPendingCall *pending = systemd_send(msg, systemd_async_dispatch, msg 787 lib/services/systemd.c dbus_message_unref(msg); msg 797 lib/services/systemd.c reply = systemd_send_recv(msg, NULL, op->timeout); msg 798 lib/services/systemd.c dbus_message_unref(msg); msg 68 lib/services/upstart.c DBusMessage *msg; msg 75 lib/services/upstart.c msg = dbus_message_new_method_call(BUS_NAME, // target for the method call msg 81 lib/services/upstart.c CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &arg_name, DBUS_TYPE_INVALID)); msg 82 lib/services/upstart.c reply = pcmk_dbus_send_recv(msg, upstart_proxy, &error, timeout); msg 83 lib/services/upstart.c dbus_message_unref(msg); msg 154 lib/services/upstart.c DBusMessage *msg = NULL; msg 169 lib/services/upstart.c msg = dbus_message_new_method_call(BUS_NAME, // target for the method call msg 173 lib/services/upstart.c CRM_ASSERT(msg != NULL); msg 175 lib/services/upstart.c reply = pcmk_dbus_send_recv(msg, upstart_proxy, &error, DBUS_TIMEOUT_USE_DEFAULT); msg 176 lib/services/upstart.c dbus_message_unref(msg); msg 242 lib/services/upstart.c DBusMessage *msg; msg 248 lib/services/upstart.c msg = dbus_message_new_method_call(BUS_NAME, // target for the method call msg 252 lib/services/upstart.c CRM_ASSERT(msg != NULL); msg 254 lib/services/upstart.c dbus_message_append_args(msg, DBUS_TYPE_INVALID); msg 255 lib/services/upstart.c reply = pcmk_dbus_send_recv(msg, upstart_proxy, &error, timeout); msg 256 lib/services/upstart.c dbus_message_unref(msg); msg 426 lib/services/upstart.c DBusMessage *msg = NULL; msg 491 lib/services/upstart.c msg = dbus_message_new_method_call(BUS_NAME, // target for the method call msg 495 lib/services/upstart.c CRM_ASSERT(msg != NULL); msg 497 lib/services/upstart.c dbus_message_iter_init_append (msg, &iter); msg 507 lib/services/upstart.c CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_BOOLEAN, &arg_wait, DBUS_TYPE_INVALID)); msg 510 lib/services/upstart.c DBusPendingCall* pending = pcmk_dbus_send(msg, upstart_proxy, upstart_async_dispatch, op, op->timeout); msg 522 lib/services/upstart.c reply = pcmk_dbus_send_recv(msg, upstart_proxy, &error, op->timeout); msg 552 lib/services/upstart.c if(msg) { msg 553 lib/services/upstart.c dbus_message_unref(msg); msg 38 maint/mocked/based-notifyfenced.c xmlNode *msg; msg 52 maint/mocked/based-notifyfenced.c .msg = xml, msg 64 maint/mocked/based-notifyfenced.c type = crm_element_value(update.msg, F_SUBTYPE); msg 35 tools/cibadmin.c void cibadmin_op_callback(xmlNode *msg, int call_id, int rc, xmlNode *output, msg 751 tools/cibadmin.c cibadmin_op_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 765 tools/cibadmin.c crm_log_xml_err(msg, "no output"); msg 127 tools/crm_mon.c static void crm_diff_update(const char *event, xmlNode * msg); msg 1749 tools/crm_mon.c crm_diff_update_v2(const char *event, xmlNode * msg) msg 1752 tools/crm_mon.c xmlNode *diff = get_message_xml(msg, F_CIB_UPDATE_RESULT); msg 1856 tools/crm_mon.c crm_diff_update_v1(const char *event, xmlNode * msg) msg 1859 tools/crm_mon.c xmlXPathObject *xpathObj = xpath_search(msg, msg 1873 tools/crm_mon.c crm_diff_update(const char *event, xmlNode * msg) msg 1878 tools/crm_mon.c xmlNode *diff = get_message_xml(msg, F_CIB_UPDATE_RESULT); msg 1910 tools/crm_mon.c crm_diff_update_v1(event, msg); msg 1913 tools/crm_mon.c crm_diff_update_v2(event, msg); msg 1568 tools/crm_resource.c gchar *msg = NULL; msg 1586 tools/crm_resource.c msg = g_strjoinv("", strv); msg 1587 tools/crm_resource.c g_set_error(&error, PCMK__EXITC_ERROR, CRM_EX_USAGE, "%s", msg); msg 1588 tools/crm_resource.c g_free(msg); msg 1932 tools/crm_resource.c char *msg = crm_strdup_printf("%s\nError performing operation: %s", msg 1935 tools/crm_resource.c g_set_error(&error, PCMK__RC_ERROR, rc, "%s", msg); msg 1936 tools/crm_resource.c free(msg);