msg 82 daemons/attrd/attrd_alerts.c config_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 49 daemons/attrd/attrd_cib.c attrd_cib_updated_cb(const char *event, xmlNode *msg) msg 55 daemons/attrd/attrd_cib.c if (cib__get_notify_patchset(msg, &patchset) != pcmk_rc_ok) { msg 69 daemons/attrd/attrd_cib.c client_name = crm_element_value(msg, PCMK__XA_CIB_CLIENTNAME); msg 95 daemons/attrd/attrd_cib.c client_name = crm_element_value(msg, PCMK__XA_CIB_CLIENTID); msg 166 daemons/attrd/attrd_cib.c attrd_erase_cb(xmlNode *msg, int call_id, int rc, xmlNode *output, msg 247 daemons/attrd/attrd_cib.c attrd_cib_callback(xmlNode *msg, int call_id, int rc, xmlNode *output, void *user_data) msg 104 daemons/attrd/attrd_corosync.c uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len) msg 108 daemons/attrd/attrd_corosync.c char *data = pcmk__cpg_message_data(handle, nodeid, pid, msg, &from); msg 760 daemons/based/based_callbacks.c send_peer_reply(xmlNode *msg, const char *originator) msg 764 daemons/based/based_callbacks.c if ((msg == NULL) || (originator == NULL)) { msg 773 daemons/based/based_callbacks.c crm_xml_add(msg, PCMK__XA_CIB_ISREPLYTO, originator); msg 774 daemons/based/based_callbacks.c pcmk__cluster_send_message(node, pcmk_ipc_based, msg); msg 1247 daemons/based/based_callbacks.c cib_peer_callback(xmlNode * msg, void *private_data) msg 1250 daemons/based/based_callbacks.c const char *originator = crm_element_value(msg, PCMK__XA_SRC); msg 1257 daemons/based/based_callbacks.c if (crm_element_value(msg, PCMK__XA_CIB_CLIENTNAME) == NULL) { msg 1258 daemons/based/based_callbacks.c crm_xml_add(msg, PCMK__XA_CIB_CLIENTNAME, originator); msg 1262 daemons/based/based_callbacks.c cib_process_request(msg, TRUE, NULL); msg 1267 daemons/based/based_callbacks.c const char *op = crm_element_value(msg, PCMK__XA_CIB_OP); msg 374 daemons/based/based_messages.c cib_msg_copy(xmlNode *msg) msg 398 daemons/based/based_messages.c const char *value = crm_element_value(msg, field); msg 35 daemons/based/based_notify.c const xmlNode *msg; msg 55 daemons/based/based_notify.c type = crm_element_value(update->msg, PCMK__XA_SUBT); msg 100 daemons/based/based_notify.c pcmk__remote_send_xml(client->remote, update->msg); msg 132 daemons/based/based_notify.c update.msg = xml; msg 528 daemons/based/based_remote.c construct_pam_passwd(int num_msg, const struct pam_message **msg, msg 535 daemons/based/based_remote.c CRM_CHECK((num_msg == 1) && (msg != NULL) && (response != NULL) msg 538 daemons/based/based_remote.c switch (msg[0]->msg_style) { msg 544 daemons/based/based_remote.c crm_info("PAM: %s", msg[0]->msg); msg 556 daemons/based/based_remote.c msg[0]->msg_style); msg 319 daemons/based/pacemaker-based.c uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len) msg 323 daemons/based/pacemaker-based.c char *data = pcmk__cpg_message_data(handle, nodeid, pid, msg, &from); msg 69 daemons/based/pacemaker-based.h void cib_peer_callback(xmlNode *msg, void *private_data); msg 31 daemons/controld/controld_callbacks.c crmd_ha_msg_filter(xmlNode * msg) msg 34 daemons/controld/controld_callbacks.c const char *sys_from = crm_element_value(msg, PCMK__XA_CRM_SYS_FROM); msg 37 daemons/controld/controld_callbacks.c const char *from = crm_element_value(msg, PCMK__XA_SRC); msg 41 daemons/controld/controld_callbacks.c const char *op = crm_element_value(msg, PCMK__XA_CRM_TASK); msg 48 daemons/controld/controld_callbacks.c new_input.msg = msg; msg 59 daemons/controld/controld_callbacks.c const char *sys_to = crm_element_value(msg, PCMK__XA_CRM_SYS_TO); msg 67 daemons/controld/controld_callbacks.c route_message(C_HA_MESSAGE, msg); msg 15 daemons/controld/controld_callbacks.h extern void crmd_ha_msg_filter(xmlNode * msg); msg 50 daemons/controld/controld_cib.c do_cib_updated(const char *event, xmlNode * msg) msg 57 daemons/controld/controld_cib.c if (cib__get_notify_patchset(msg, &patchset) != pcmk_rc_ok) { msg 72 daemons/controld/controld_cib.c client_name = crm_element_value(msg, PCMK__XA_CIB_CLIENTNAME); msg 86 daemons/controld/controld_cib.c client_name = crm_element_value(msg, PCMK__XA_CIB_CLIENTID); msg 131 daemons/controld/controld_cib.c void (*update_cb) (const char *event, xmlNodePtr msg) = do_cib_updated; msg 251 daemons/controld/controld_cib.c cib_delete_callback(xmlNode *msg, int call_id, int rc, xmlNode *output, msg 760 daemons/controld/controld_cib.c cib_rsc_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 115 daemons/controld/controld_control.c xmlNode *msg = NULL; msg 121 daemons/controld/controld_control.c msg = pcmk__new_request(pcmk_ipc_controld, CRM_SYSTEM_CRMD, NULL, msg 124 daemons/controld/controld_control.c if (!pcmk__cluster_send_message(NULL, pcmk_ipc_controld, msg)) { msg 127 daemons/controld/controld_control.c pcmk__xml_free(msg); msg 385 daemons/controld/controld_control.c xmlNode *msg = NULL; msg 397 daemons/controld/controld_control.c msg = pcmk__client_data2xml(client, &id, &flags); msg 415 daemons/controld/controld_control.c if (msg == NULL) { msg 424 daemons/controld/controld_control.c pcmk__update_acl_user(msg, PCMK__XA_CRM_USER, client->user); msg 426 daemons/controld/controld_control.c crm_xml_add(msg, PCMK__XA_CRM_SYS_FROM, client->id); msg 427 daemons/controld/controld_control.c if (controld_authorize_ipc_message(msg, client, NULL)) { msg 430 daemons/controld/controld_control.c route_message(C_IPC_MESSAGE, msg); msg 434 daemons/controld/controld_control.c pcmk__xml_free(msg); msg 553 daemons/controld/controld_control.c config_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 34 daemons/controld/controld_corosync.c uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len) msg 37 daemons/controld/controld_corosync.c char *data = pcmk__cpg_message_data(handle, nodeid, pid, msg, &from); msg 146 daemons/controld/controld_election.c rc = election_count_vote(controld_globals.cluster, vote->msg, msg 174 daemons/controld/controld_election.c feature_update_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 44 daemons/controld/controld_execd.c xmlNode *msg, struct ra_metadata_s *md); msg 668 daemons/controld/controld_execd.c const char *from_sys = crm_element_value(input->msg, PCMK__XA_CRM_SYS_FROM); msg 669 daemons/controld/controld_execd.c const char *from_host = crm_element_value(input->msg, PCMK__XA_SRC); msg 986 daemons/controld/controld_execd.c char *ref = crm_element_value_copy(request->msg, PCMK_XA_REFERENCE); msg 1218 daemons/controld/controld_execd.c handle_reprobe_op(lrm_state_t *lrm_state, xmlNode *msg, const char *from_sys, msg 1227 daemons/controld/controld_execd.c xmlNode *reply = pcmk__new_reply(msg, NULL); msg 1422 daemons/controld/controld_execd.c user_name = pcmk__update_acl_user(input->msg, PCMK__XA_CRM_USER, NULL); msg 1423 daemons/controld/controld_execd.c crm_op = crm_element_value(input->msg, PCMK__XA_CRM_TASK); msg 1424 daemons/controld/controld_execd.c from_sys = crm_element_value(input->msg, PCMK__XA_CRM_SYS_FROM); msg 1426 daemons/controld/controld_execd.c from_host = crm_element_value(input->msg, PCMK__XA_SRC); msg 1458 daemons/controld/controld_execd.c handle_reprobe_op(lrm_state, input->msg, from_sys, from_host, user_name, msg 1495 daemons/controld/controld_execd.c crm_log_xml_warn(input->msg, "invalid resource"); msg 1506 daemons/controld/controld_execd.c crm_log_xml_warn(input->msg, "failed registration"); msg 1890 daemons/controld/controld_execd.c do_lrm_rsc_op(lrm_state_t *lrm_state, lrmd_rsc_info_t *rsc, xmlNode *msg, msg 1902 daemons/controld/controld_execd.c CRM_CHECK((rsc != NULL) && (msg != NULL), return); msg 1904 daemons/controld/controld_execd.c operation = crm_element_value(msg, PCMK_XA_OPERATION); msg 1907 daemons/controld/controld_execd.c transition = crm_element_value(msg, PCMK__XA_TRANSITION_KEY); msg 1909 daemons/controld/controld_execd.c crm_log_xml_err(msg, "Missing transition number"); msg 1917 daemons/controld/controld_execd.c synthesize_lrmd_failure(NULL, msg, PCMK_EXEC_INVALID, msg 1938 daemons/controld/controld_execd.c op = construct_op(lrm_state, msg, rsc->id, operation); msg 2009 daemons/controld/controld_execd.c if (crm_element_value_epoch(msg, PCMK_OPT_SHUTDOWN_LOCK, msg 24 daemons/controld/controld_execd_state.c int lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg); msg 25 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 435 daemons/controld/controld_execd_state.c crmd_proxy_send(const char *session, xmlNode *msg) msg 443 daemons/controld/controld_execd_state.c crm_log_xml_trace(msg, "to-proxy"); msg 447 daemons/controld/controld_execd_state.c remote_proxy_relay_event(proxy, msg); msg 452 daemons/controld/controld_execd_state.c crmd_proxy_dispatch(const char *session, xmlNode *msg) msg 455 daemons/controld/controld_execd_state.c crm_log_xml_trace(msg, "controller[inbound]"); msg 456 daemons/controld/controld_execd_state.c crm_xml_add(msg, PCMK__XA_CRM_SYS_FROM, session); msg 457 daemons/controld/controld_execd_state.c if (controld_authorize_ipc_message(msg, NULL, session)) { msg 458 daemons/controld/controld_execd_state.c route_message(C_IPC_MESSAGE, msg); msg 464 daemons/controld/controld_execd_state.c remote_config_check(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 495 daemons/controld/controld_execd_state.c crmd_remote_proxy_cb(lrmd_t *lrmd, void *userdata, xmlNode *msg) msg 498 daemons/controld/controld_execd_state.c const char *session = crm_element_value(msg, PCMK__XA_LRMD_IPC_SESSION); msg 501 daemons/controld/controld_execd_state.c const char *op = crm_element_value(msg, PCMK__XA_LRMD_IPC_OP); msg 503 daemons/controld/controld_execd_state.c const char *channel = crm_element_value(msg, PCMK__XA_LRMD_IPC_SERVER); msg 555 daemons/controld/controld_execd_state.c xmlNode *wrapper = pcmk__xe_first_child(msg, PCMK__XE_LRMD_IPC_MSG, msg 583 daemons/controld/controld_execd_state.c rc = pcmk__xe_get_flags(msg, PCMK__XA_LRMD_IPC_MSG_FLAGS, &flags, 0U); msg 595 daemons/controld/controld_execd_state.c crm_element_value_int(msg, PCMK__XA_LRMD_IPC_MSG_ID, &msg_id); msg 602 daemons/controld/controld_execd_state.c remote_proxy_cb(lrmd, lrm_state->node_name, msg); msg 195 daemons/controld/controld_fencing.c cib_fencing_updated(xmlNode *msg, int call_id, int rc, xmlNode *output, msg 201 daemons/controld/controld_fencing.c crm_log_xml_warn(msg, "Failed update"); msg 77 daemons/controld/controld_fsa.c crm_log_xml_debug(input->msg, __func__); msg 18 daemons/controld/controld_join_client.c void join_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data); msg 33 daemons/controld/controld_join_client.c update_dc_expected(const xmlNode *msg) msg 36 daemons/controld/controld_join_client.c && pcmk__xe_attr_is_true(msg, PCMK__XA_DC_LEAVING)) { msg 117 daemons/controld/controld_join_client.c welcome_from = crm_element_value(input->msg, PCMK__XA_SRC); msg 118 daemons/controld/controld_join_client.c join_id = crm_element_value(input->msg, PCMK__XA_JOIN_ID); msg 120 daemons/controld/controld_join_client.c welcome_from, crm_element_value(input->msg, PCMK__XA_JOIN_ID)); msg 129 daemons/controld/controld_join_client.c if (update_dc(input->msg) == FALSE) { msg 135 daemons/controld/controld_join_client.c update_dc_expected(input->msg); msg 148 daemons/controld/controld_join_client.c join_query_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 268 daemons/controld/controld_join_client.c const char *op = crm_element_value(input->msg, PCMK__XA_CRM_TASK); msg 269 daemons/controld/controld_join_client.c const char *welcome_from = crm_element_value(input->msg, PCMK__XA_SRC); msg 277 daemons/controld/controld_join_client.c if (pcmk__xe_attr_is_true(input->msg, CRM_OP_JOIN_ACKNAK)) { msg 281 daemons/controld/controld_join_client.c crm_element_value_int(input->msg, PCMK__XA_JOIN_ID, &join_id); msg 296 daemons/controld/controld_join_client.c if (update_dc(input->msg) == FALSE) { msg 302 daemons/controld/controld_join_client.c update_dc_expected(input->msg); msg 362 daemons/controld/controld_join_client.c remotes = pcmk__xe_first_child(input->msg, PCMK_XE_NODES, NULL, NULL); msg 43 daemons/controld/controld_join_dc.c void finalize_sync_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data); msg 233 daemons/controld/controld_join_dc.c xmlNode *msg = pcmk__new_request(pcmk_ipc_controld, CRM_SYSTEM_DC, host_to, msg 237 daemons/controld/controld_join_dc.c crm_xml_add_int(msg, PCMK__XA_JOIN_ID, current_join_id); msg 242 daemons/controld/controld_join_dc.c pcmk__xe_set_bool_attr(msg, PCMK__XA_DC_LEAVING, msg 245 daemons/controld/controld_join_dc.c return msg; msg 369 daemons/controld/controld_join_dc.c join_to = crm_element_value(welcome->msg, PCMK__XA_SRC); msg 454 daemons/controld/controld_join_dc.c const char *join_from = crm_element_value(join_ack->msg, PCMK__XA_SRC); msg 455 daemons/controld/controld_join_dc.c const char *ref = crm_element_value(join_ack->msg, PCMK_XA_REFERENCE); msg 456 daemons/controld/controld_join_dc.c const char *join_version = crm_element_value(join_ack->msg, msg 467 daemons/controld/controld_join_dc.c crm_element_value_int(join_ack->msg, PCMK__XA_JOIN_ID, &join_id); msg 692 daemons/controld/controld_join_dc.c finalize_sync_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 738 daemons/controld/controld_join_dc.c join_node_state_commit_callback(xmlNode *msg, int call_id, int rc, msg 749 daemons/controld/controld_join_dc.c crm_log_xml_debug(msg, "failed"); msg 769 daemons/controld/controld_join_dc.c const char *op = crm_element_value(join_ack->msg, PCMK__XA_CRM_TASK); msg 770 daemons/controld/controld_join_dc.c char *join_from = crm_element_value_copy(join_ack->msg, PCMK__XA_SRC); msg 798 daemons/controld/controld_join_dc.c if (crm_element_value_int(join_ack->msg, PCMK__XA_JOIN_ID, &join_id) != 0) { msg 97 daemons/controld/controld_membership.c crmd_node_update_complete(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 106 daemons/controld/controld_membership.c crm_log_xml_debug(msg, "failed"); msg 111 daemons/controld/controld_membership.c crm_log_xml_debug(msg, "failed"); msg 204 daemons/controld/controld_membership.c remove_conflicting_node_callback(xmlNode * msg, int call_id, int rc, msg 215 daemons/controld/controld_membership.c search_conflicting_node_callback(xmlNode * msg, int call_id, int rc, msg 346 daemons/controld/controld_membership.c node_list_update_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 352 daemons/controld/controld_membership.c crm_log_xml_debug(msg, "update:failed"); msg 357 daemons/controld/controld_membership.c crm_log_xml_debug(msg, "update:failed"); msg 423 daemons/controld/controld_membership.c cib_quorum_update_complete(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 432 daemons/controld/controld_membership.c crm_log_xml_debug(msg, "failed"); msg 26 daemons/controld/controld_messages.c static enum crmd_fsa_input handle_message(xmlNode *msg, msg 28 daemons/controld/controld_messages.c static xmlNode* create_ping_reply(const xmlNode *msg); msg 33 daemons/controld/controld_messages.c static void send_msg_via_ipc(xmlNode * msg, const char *sys, const char *src); msg 124 daemons/controld/controld_messages.c CRM_CHECK(((ha_msg_input_t *) data)->msg != NULL, msg 197 daemons/controld/controld_messages.c copy->msg = (orig != NULL)? pcmk__xml_copy(NULL, orig->msg) : NULL; msg 199 daemons/controld/controld_messages.c wrapper = pcmk__xe_first_child(copy->msg, PCMK__XE_CRM_XML, NULL, NULL); msg 289 daemons/controld/controld_messages.c route_message(msg_data->fsa_cause, input->msg); msg 298 daemons/controld/controld_messages.c fsa_input.msg = input; msg 330 daemons/controld/controld_messages.c relay_message(xmlNode * msg, gboolean originated_locally) msg 348 daemons/controld/controld_messages.c CRM_CHECK(msg != NULL, return TRUE); msg 350 daemons/controld/controld_messages.c host_to = crm_element_value(msg, PCMK__XA_CRM_HOST_TO); msg 351 daemons/controld/controld_messages.c sys_to = crm_element_value(msg, PCMK__XA_CRM_SYS_TO); msg 352 daemons/controld/controld_messages.c sys_from = crm_element_value(msg, PCMK__XA_CRM_SYS_FROM); msg 353 daemons/controld/controld_messages.c type = crm_element_value(msg, PCMK__XA_T); msg 354 daemons/controld/controld_messages.c task = crm_element_value(msg, PCMK__XA_CRM_TASK); msg 355 daemons/controld/controld_messages.c ref = crm_element_value(msg, PCMK_XA_REFERENCE); msg 366 daemons/controld/controld_messages.c crm_log_xml_trace(msg, "hello"); msg 375 daemons/controld/controld_messages.c crm_log_xml_trace(msg, "ignored"); msg 383 daemons/controld/controld_messages.c crm_log_xml_trace(msg, "ignored"); msg 432 daemons/controld/controld_messages.c xmlNode *wrapper = pcmk__xe_first_child(msg, PCMK__XE_CRM_XML, NULL, msg 447 daemons/controld/controld_messages.c xmlNode *reply = create_ping_reply(msg); msg 462 daemons/controld/controld_messages.c crm_log_xml_trace(msg, sys_to); msg 463 daemons/controld/controld_messages.c send_msg_via_ipc(msg, sys_to, controld_globals.cluster->priv->node_name); msg 476 daemons/controld/controld_messages.c crm_log_xml_trace(msg, "relayed"); msg 481 daemons/controld/controld_messages.c pcmk__cluster_send_message(node_to, dest, msg); msg 489 daemons/controld/controld_messages.c crm_log_xml_trace(msg, "ignored"); msg 499 daemons/controld/controld_messages.c crm_log_xml_trace(msg, "IPC-relay"); msg 500 daemons/controld/controld_messages.c send_msg_via_ipc(msg, sys_to, controld_globals.cluster->priv->node_name); msg 510 daemons/controld/controld_messages.c crm_log_xml_trace(msg, "ignored"); msg 517 daemons/controld/controld_messages.c crm_log_xml_trace(msg, "relayed"); msg 518 daemons/controld/controld_messages.c pcmk__cluster_send_message(node_to, dest, msg); msg 614 daemons/controld/controld_messages.c handle_message(xmlNode *msg, enum crmd_fsa_cause cause) msg 618 daemons/controld/controld_messages.c CRM_CHECK(msg != NULL, return I_NULL); msg 620 daemons/controld/controld_messages.c type = crm_element_value(msg, PCMK__XA_SUBT); msg 622 daemons/controld/controld_messages.c return handle_request(msg, cause); msg 626 daemons/controld/controld_messages.c handle_response(msg); msg 632 daemons/controld/controld_messages.c crm_log_xml_trace(msg, "bad"); msg 789 daemons/controld/controld_messages.c handle_remote_state(const xmlNode *msg) msg 792 daemons/controld/controld_messages.c const char *remote_uname = pcmk__xe_id(msg); msg 797 daemons/controld/controld_messages.c rc = pcmk__xe_get_bool_attr(msg, PCMK__XA_IN_CCM, &remote_is_up); msg 808 daemons/controld/controld_messages.c conn_host = crm_element_value(msg, PCMK__XA_CONNECTION_HOST); msg 827 daemons/controld/controld_messages.c create_ping_reply(const xmlNode *msg) msg 836 daemons/controld/controld_messages.c value = crm_element_value(msg, PCMK__XA_CRM_SYS_TO); msg 848 daemons/controld/controld_messages.c reply = pcmk__new_reply(msg, ping); msg 854 daemons/controld/controld_messages.c handle_ping(const xmlNode *msg) msg 856 daemons/controld/controld_messages.c xmlNode *reply = create_ping_reply(msg); msg 913 daemons/controld/controld_messages.c handle_node_info_request(const xmlNode *msg) msg 936 daemons/controld/controld_messages.c crm_element_value_int(msg, PCMK_XA_ID, &node_id); msg 940 daemons/controld/controld_messages.c value = crm_element_value(msg, PCMK_XA_UNAME); msg 959 daemons/controld/controld_messages.c reply = pcmk__new_reply(msg, reply_data); msg 971 daemons/controld/controld_messages.c verify_feature_set(xmlNode *msg) msg 973 daemons/controld/controld_messages.c const char *dc_version = crm_element_value(msg, PCMK_XA_CRM_FEATURE_SET); msg 1061 daemons/controld/controld_messages.c xmlNode *msg = NULL; msg 1108 daemons/controld/controld_messages.c fsa_input.msg = stored_msg; msg 1134 daemons/controld/controld_messages.c fsa_input.msg = stored_msg; msg 1182 daemons/controld/controld_messages.c msg = pcmk__new_request(pcmk_ipc_controld, CRM_SYSTEM_CRMD, NULL, msg 1185 daemons/controld/controld_messages.c if (!pcmk__cluster_send_message(NULL, pcmk_ipc_controld, msg)) { msg 1190 daemons/controld/controld_messages.c pcmk__xml_free(msg); msg 1248 daemons/controld/controld_messages.c fsa_input.msg = stored_msg; msg 1297 daemons/controld/controld_messages.c send_msg_via_ipc(xmlNode * msg, const char *sys, const char *src) msg 1305 daemons/controld/controld_messages.c if (crm_element_value(msg, PCMK__XA_SRC) == NULL) { msg 1306 daemons/controld/controld_messages.c crm_xml_add(msg, PCMK__XA_SRC, src); msg 1311 daemons/controld/controld_messages.c pcmk__ipc_send_xml(client_channel, 0, msg, crm_ipc_server_event); msg 1314 daemons/controld/controld_messages.c xmlNode *wrapper = pcmk__xe_first_child(msg, PCMK__XE_CRM_XML, NULL, msg 1318 daemons/controld/controld_messages.c process_te_message(msg, data); msg 1325 daemons/controld/controld_messages.c fsa_input.msg = msg; msg 1327 daemons/controld/controld_messages.c wrapper = pcmk__xe_first_child(msg, PCMK__XE_CRM_XML, NULL, NULL); msg 1342 daemons/controld/controld_messages.c crmd_proxy_send(sys, msg); msg 1355 daemons/controld/controld_messages.c pcmk__xml_free(orig->msg); msg 1369 daemons/controld/controld_messages.c xmlNode *msg = pcmk__new_request(pcmk_ipc_controld, CRM_SYSTEM_CRMD, NULL, msg 1376 daemons/controld/controld_messages.c crm_xml_add(msg, PCMK_XA_ID, node_name); msg 1377 daemons/controld/controld_messages.c pcmk__xe_set_bool_attr(msg, PCMK__XA_IN_CCM, node_up); msg 1380 daemons/controld/controld_messages.c crm_xml_add(msg, PCMK__XA_CONNECTION_HOST, msg 1384 daemons/controld/controld_messages.c pcmk__cluster_send_message(NULL, pcmk_ipc_controld, msg); msg 1385 daemons/controld/controld_messages.c pcmk__xml_free(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 58 daemons/controld/controld_schedulerd.c save_cib_contents(xmlNode *msg, int call_id, int rc, xmlNode *output, msg 147 daemons/controld/controld_schedulerd.c fsa_input.msg = pcmk__xe_create(NULL, "dummy-reply"); msg 148 daemons/controld/controld_schedulerd.c crm_xml_add(fsa_input.msg, PCMK_XA_REFERENCE, msg_ref); msg 149 daemons/controld/controld_schedulerd.c crm_xml_add(fsa_input.msg, PCMK__XA_CRM_TGRAPH_IN, msg 152 daemons/controld/controld_schedulerd.c crm_data_node = pcmk__xe_create(fsa_input.msg, PCMK__XE_CRM_XML); msg 156 daemons/controld/controld_schedulerd.c pcmk__xml_free(fsa_input.msg); msg 212 daemons/controld/controld_schedulerd.c static void do_pe_invoke_callback(xmlNode *msg, int call_id, int rc, msg 448 daemons/controld/controld_schedulerd.c do_pe_invoke_callback(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 406 daemons/controld/controld_te_actions.c .msg = cmd, msg 410 daemons/controld/controld_te_actions.c fsa_data_t msg = { msg 421 daemons/controld/controld_te_actions.c I_NULL, &msg); msg 357 daemons/controld/controld_te_callbacks.c te_update_diff(const char *event, xmlNode * msg) msg 367 daemons/controld/controld_te_callbacks.c CRM_CHECK(msg != NULL, return); msg 368 daemons/controld/controld_te_callbacks.c crm_element_value_int(msg, PCMK__XA_CIB_RC, &rc); msg 387 daemons/controld/controld_te_callbacks.c op = crm_element_value(msg, PCMK__XA_CIB_OP); msg 389 daemons/controld/controld_te_callbacks.c wrapper = pcmk__xe_first_child(msg, PCMK__XE_CIB_UPDATE_RESULT, NULL, NULL); msg 411 daemons/controld/controld_te_callbacks.c process_te_message(xmlNode * msg, xmlNode * xml_data) msg 417 daemons/controld/controld_te_callbacks.c CRM_CHECK(msg != NULL, return); msg 420 daemons/controld/controld_te_callbacks.c value = crm_element_value(msg, PCMK__XA_CRM_SYS_TO); msg 429 daemons/controld/controld_te_callbacks.c value = crm_element_value(msg, PCMK__XA_CRM_TASK); msg 437 daemons/controld/controld_te_callbacks.c value = crm_element_value(msg, PCMK__XA_CRM_SYS_FROM); msg 445 daemons/controld/controld_te_callbacks.c pcmk__s(crm_element_value(msg, PCMK_XA_REFERENCE), ""), msg 446 daemons/controld/controld_te_callbacks.c pcmk__s(crm_element_value(msg, PCMK__XA_SRC), "")); msg 467 daemons/controld/controld_te_callbacks.c cib_action_updated(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 128 daemons/controld/controld_transition.c const char *ref = crm_element_value(input->msg, PCMK_XA_REFERENCE); msg 129 daemons/controld/controld_transition.c const char *graph_input = crm_element_value(input->msg, msg 133 daemons/controld/controld_transition.c crm_log_xml_err(input->msg, "Bad command"); msg 162 daemons/controld/controld_transition.c crm_log_xml_err(input->msg, "Bad command"); msg 38 daemons/controld/controld_transition.h void process_te_message(xmlNode *msg, xmlNode *xml_data); msg 44 daemons/controld/controld_transition.h void cib_action_updated(xmlNode *msg, int call_id, int rc, xmlNode *output, msg 47 daemons/controld/controld_transition.h void te_update_diff(const char *event, xmlNode *msg); msg 706 daemons/controld/controld_utils.c update_dc(xmlNode * msg) msg 712 daemons/controld/controld_utils.c if (msg != NULL) { msg 715 daemons/controld/controld_utils.c dc_version = crm_element_value(msg, PCMK_XA_VERSION); msg 716 daemons/controld/controld_utils.c welcome_from = crm_element_value(msg, PCMK__XA_SRC); msg 62 daemons/controld/controld_utils.h gboolean update_dc(xmlNode * msg); msg 282 daemons/execd/execd_commands.c build_rsc_from_xml(xmlNode * msg) msg 284 daemons/execd/execd_commands.c xmlNode *rsc_xml = pcmk__xpath_find_one(msg->doc, "//" PCMK__XE_LRMD_RSC, msg 290 daemons/execd/execd_commands.c crm_element_value_int(msg, PCMK__XA_LRMD_CALLOPT, &rsc->call_opts); msg 306 daemons/execd/execd_commands.c create_lrmd_cmd(xmlNode *msg, pcmk__client_t *client) msg 309 daemons/execd/execd_commands.c xmlNode *rsc_xml = pcmk__xpath_find_one(msg->doc, "//" PCMK__XE_LRMD_RSC, msg 315 daemons/execd/execd_commands.c crm_element_value_int(msg, PCMK__XA_LRMD_CALLOPT, &call_options); msg 319 daemons/execd/execd_commands.c crm_element_value_int(msg, PCMK__XA_LRMD_CALLID, &cmd->call_id); msg 568 daemons/execd/execd_commands.c const char *msg = NULL; msg 594 daemons/execd/execd_commands.c msg = "Disconnected"; msg 598 daemons/execd/execd_commands.c msg = pcmk_rc_str(rc); msg 602 daemons/execd/execd_commands.c pcmk__client_name(client), msg, rc); msg 278 daemons/execd/pacemaker-execd.c lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg) msg 287 daemons/execd/pacemaker-execd.c return pcmk__ipc_send_xml(client, 0, msg, crm_ipc_server_event); msg 294 daemons/execd/pacemaker-execd.c return lrmd__remote_send_xml(client->remote, msg, 0, "notify"); msg 61 daemons/execd/pacemaker-execd.h int lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg); msg 77 daemons/execd/remoted_proxy.c xmlNode *msg; msg 105 daemons/execd/remoted_proxy.c msg = pcmk__xe_create(NULL, PCMK__XE_LRMD_IPC_PROXY); msg 106 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_OP, LRMD_IPC_OP_NEW); msg 107 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_SERVER, ipc_channel); msg 108 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_SESSION, client->id); msg 109 daemons/execd/remoted_proxy.c lrmd_server_send_notify(ipc_proxy, msg); msg 110 daemons/execd/remoted_proxy.c pcmk__xml_free(msg); msg 161 daemons/execd/remoted_proxy.c xmlNode *msg = pcmk__xe_first_child(wrapper, NULL, NULL, NULL); msg 178 daemons/execd/remoted_proxy.c xmlNode *msg = pcmk__xe_create(NULL, PCMK__XE_LRMD_IPC_PROXY); msg 179 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_OP, LRMD_IPC_OP_DESTROY); msg 180 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_SESSION, session); msg 181 daemons/execd/remoted_proxy.c lrmd_server_send_notify(ipc_proxy, msg); msg 182 daemons/execd/remoted_proxy.c pcmk__xml_free(msg); msg 202 daemons/execd/remoted_proxy.c rc = pcmk__ipc_send_xml(ipc_client, 0, msg, crm_ipc_server_event); msg 209 daemons/execd/remoted_proxy.c rc = pcmk__ipc_send_xml(ipc_client, msg_id, msg, crm_ipc_flags_none); msg 237 daemons/execd/remoted_proxy.c xmlNode *msg = NULL; msg 300 daemons/execd/remoted_proxy.c msg = pcmk__xe_create(NULL, PCMK__XE_LRMD_IPC_PROXY); msg 301 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_OP, LRMD_IPC_OP_REQUEST); msg 302 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_SESSION, client->id); msg 303 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_CLIENT, pcmk__client_name(client)); msg 304 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_USER, client->user); msg 305 daemons/execd/remoted_proxy.c crm_xml_add_int(msg, PCMK__XA_LRMD_IPC_MSG_ID, id); msg 306 daemons/execd/remoted_proxy.c crm_xml_add_int(msg, PCMK__XA_LRMD_IPC_MSG_FLAGS, flags); msg 308 daemons/execd/remoted_proxy.c wrapper = pcmk__xe_create(msg, PCMK__XE_LRMD_IPC_MSG); msg 312 daemons/execd/remoted_proxy.c lrmd_server_send_notify(ipc_proxy, msg); msg 315 daemons/execd/remoted_proxy.c pcmk__xml_free(msg); msg 330 daemons/execd/remoted_proxy.c xmlNode *msg = pcmk__xe_create(NULL, PCMK__XE_LRMD_IPC_PROXY); msg 333 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_OP, LRMD_IPC_OP_SHUTDOWN_REQ); msg 338 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_SESSION, "0"); msg 340 daemons/execd/remoted_proxy.c rc = (lrmd_server_send_notify(ipc_proxy, msg) != pcmk_rc_ok)? -1 : 0; msg 341 daemons/execd/remoted_proxy.c pcmk__xml_free(msg); msg 360 daemons/execd/remoted_proxy.c xmlNode *msg = pcmk__xe_create(NULL, PCMK__XE_LRMD_IPC_PROXY); msg 361 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_OP, LRMD_IPC_OP_DESTROY); msg 362 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_SESSION, client->id); msg 363 daemons/execd/remoted_proxy.c lrmd_server_send_notify(ipc_proxy, msg); msg 364 daemons/execd/remoted_proxy.c pcmk__xml_free(msg); msg 384 daemons/fenced/fenced_cib.c update_fencing_topology(const char *event, xmlNode *msg) msg 386 daemons/fenced/fenced_cib.c xmlNode *wrapper = pcmk__xe_first_child(msg, PCMK__XE_CIB_UPDATE_RESULT, msg 476 daemons/fenced/fenced_cib.c update_cib_cache_cb(const char *event, xmlNode * msg) msg 486 daemons/fenced/fenced_cib.c } else if(msg == NULL) { msg 498 daemons/fenced/fenced_cib.c crm_element_value_int(msg, PCMK__XA_CIB_RC, &rc); msg 503 daemons/fenced/fenced_cib.c wrapper = pcmk__xe_first_child(msg, PCMK__XE_CIB_UPDATE_RESULT, NULL, msg 549 daemons/fenced/fenced_cib.c update_fencing_topology(event, msg); msg 557 daemons/fenced/fenced_cib.c init_cib_cache_cb(xmlNode * msg, int call_id, int rc, xmlNode * output, void *user_data) msg 397 daemons/fenced/fenced_commands.c create_async_command(xmlNode *msg) msg 403 daemons/fenced/fenced_commands.c if (msg == NULL) { msg 407 daemons/fenced/fenced_commands.c op = pcmk__xpath_find_one(msg->doc, "//*[@" PCMK__XA_ST_DEVICE_ACTION "]", msg 417 daemons/fenced/fenced_commands.c cmd->op = crm_element_value_copy(msg, PCMK__XA_ST_OP); msg 418 daemons/fenced/fenced_commands.c cmd->client = crm_element_value_copy(msg, PCMK__XA_ST_CLIENTID); msg 424 daemons/fenced/fenced_commands.c crm_element_value_int(msg, PCMK__XA_ST_CALLID, &(cmd->id)); msg 425 daemons/fenced/fenced_commands.c crm_element_value_int(msg, PCMK__XA_ST_DELAY, &(cmd->start_delay)); msg 426 daemons/fenced/fenced_commands.c crm_element_value_int(msg, PCMK__XA_ST_TIMEOUT, &(cmd->default_timeout)); msg 429 daemons/fenced/fenced_commands.c rc = pcmk__xe_get_flags(msg, PCMK__XA_ST_CALLOPT, &(cmd->options), msg 435 daemons/fenced/fenced_commands.c cmd->origin = crm_element_value_copy(msg, PCMK__XA_SRC); msg 436 daemons/fenced/fenced_commands.c cmd->remote_op_id = crm_element_value_copy(msg, PCMK__XA_ST_REMOTE_OP); msg 437 daemons/fenced/fenced_commands.c cmd->client_name = crm_element_value_copy(msg, PCMK__XA_ST_CLIENTNAME); msg 1667 daemons/fenced/fenced_commands.c fenced_register_level(xmlNode *msg, pcmk__action_result_t *result) msg 1677 daemons/fenced/fenced_commands.c CRM_CHECK(msg != NULL, return); msg 1679 daemons/fenced/fenced_commands.c level = unpack_level_request(msg, &mode, &target, &id); msg 1783 daemons/fenced/fenced_commands.c fenced_unregister_level(xmlNode *msg, pcmk__action_result_t *result) msg 1790 daemons/fenced/fenced_commands.c level = unpack_level_request(msg, NULL, &target, &id); msg 1894 daemons/fenced/fenced_commands.c execute_agent_action(xmlNode *msg, pcmk__action_result_t *result) msg 1896 daemons/fenced/fenced_commands.c xmlNode *dev = pcmk__xpath_find_one(msg->doc, "//" PCMK__XE_ST_DEVICE_ID, msg 1898 daemons/fenced/fenced_commands.c xmlNode *op = pcmk__xpath_find_one(msg->doc, msg 1953 daemons/fenced/fenced_commands.c cmd = create_async_command(msg); msg 1955 daemons/fenced/fenced_commands.c crm_log_xml_warn(msg, "invalid"); msg 2516 daemons/fenced/fenced_commands.c GString *msg = g_string_sized_new(80); // Reasonable starting size msg 2537 daemons/fenced/fenced_commands.c pcmk__g_strcat(msg, "Operation '", cmd->action, "' ", NULL); msg 2539 daemons/fenced/fenced_commands.c g_string_append_printf(msg, "[%d] ", pid); msg 2542 daemons/fenced/fenced_commands.c pcmk__g_strcat(msg, "targeting ", cmd->target, " ", NULL); msg 2545 daemons/fenced/fenced_commands.c pcmk__g_strcat(msg, "using ", cmd->device, " ", NULL); msg 2550 daemons/fenced/fenced_commands.c g_string_append_printf(msg, "returned %d", result->exit_status); msg 2552 daemons/fenced/fenced_commands.c pcmk__g_strcat(msg, "could not be executed: ", msg 2558 daemons/fenced/fenced_commands.c pcmk__g_strcat(msg, " (", result->exit_reason, ")", NULL); msg 2561 daemons/fenced/fenced_commands.c pcmk__g_strcat(msg, ", retrying with ", next, NULL); msg 2564 daemons/fenced/fenced_commands.c g_string_append_printf(msg, " (%u device%s remaining)", msg 2568 daemons/fenced/fenced_commands.c g_string_append_printf(msg, " " QB_XS " %scall %d from %s", msg 2573 daemons/fenced/fenced_commands.c do_crm_log(log_level, "%s", msg->str); msg 2574 daemons/fenced/fenced_commands.c g_string_free(msg, TRUE); msg 2836 daemons/fenced/fenced_commands.c fence_locally(xmlNode *msg, pcmk__action_result_t *result) msg 2843 daemons/fenced/fenced_commands.c CRM_CHECK((msg != NULL) && (result != NULL), return); msg 2845 daemons/fenced/fenced_commands.c dev = pcmk__xpath_find_one(msg->doc, "//*[@" PCMK__XA_ST_TARGET "]", msg 2848 daemons/fenced/fenced_commands.c cmd = create_async_command(msg); msg 2850 daemons/fenced/fenced_commands.c crm_log_xml_warn(msg, "invalid"); msg 478 daemons/fenced/fenced_history.c stonith_fence_history(xmlNode *msg, xmlNode **output, msg 482 daemons/fenced/fenced_history.c xmlNode *dev = pcmk__xpath_find_one(msg->doc, msg 504 daemons/fenced/fenced_history.c const char *call_id = crm_element_value(msg, PCMK__XA_ST_CALLID); msg 517 daemons/fenced/fenced_history.c if (crm_element_value(msg, PCMK__XA_ST_CALLID) != NULL) { msg 532 daemons/fenced/fenced_history.c xmlNode *history = pcmk__xpath_find_one(msg->doc, msg 1122 daemons/fenced/fenced_remote.c fenced_handle_manual_confirmation(const pcmk__client_t *client, xmlNode *msg) msg 1125 daemons/fenced/fenced_remote.c xmlNode *dev = pcmk__xpath_find_one(msg->doc, msg 1134 daemons/fenced/fenced_remote.c op = initiate_remote_stonith_op(client, msg, TRUE); msg 1143 daemons/fenced/fenced_remote.c finalize_op(op, msg, false); msg 1785 daemons/fenced/fenced_remote.c xmlNode *msg) msg 1833 daemons/fenced/fenced_remote.c finalize_op(op, msg, false); msg 2344 daemons/fenced/fenced_remote.c process_remote_stonith_query(xmlNode *msg) msg 2354 daemons/fenced/fenced_remote.c xmlNode *dev = pcmk__xpath_find_one(msg->doc, msg 2363 daemons/fenced/fenced_remote.c dev = pcmk__xpath_find_one(msg->doc, msg 2383 daemons/fenced/fenced_remote.c host = crm_element_value(msg, PCMK__XA_SRC); msg 2451 daemons/fenced/fenced_remote.c fenced_process_fencing_reply(xmlNode *msg) msg 2456 daemons/fenced/fenced_remote.c xmlNode *dev = pcmk__xpath_find_one(msg->doc, msg 2466 daemons/fenced/fenced_remote.c dev = stonith__find_xe_with_result(msg); msg 2502 daemons/fenced/fenced_remote.c if (pcmk__str_eq(crm_element_value(msg, PCMK__XA_SUBT), msg 2510 daemons/fenced/fenced_remote.c finalize_op(op, msg, false); msg 2530 daemons/fenced/fenced_remote.c finalize_op(op, msg, false); msg 2534 daemons/fenced/fenced_remote.c device = crm_element_value(msg, PCMK__XA_ST_DEVICE_ID); msg 2564 daemons/fenced/fenced_remote.c advance_topology_device_in_level(op, device, msg); msg 2571 daemons/fenced/fenced_remote.c finalize_op(op, msg, false); msg 2578 daemons/fenced/fenced_remote.c finalize_op(op, msg, false); msg 2585 daemons/fenced/fenced_remote.c finalize_op(op, msg, false); msg 207 daemons/fenced/pacemaker-fenced.c stonith_peer_callback(xmlNode * msg, void *private_data) msg 209 daemons/fenced/pacemaker-fenced.c const char *remote_peer = crm_element_value(msg, PCMK__XA_SRC); msg 210 daemons/fenced/pacemaker-fenced.c const char *op = crm_element_value(msg, PCMK__XA_ST_OP); msg 216 daemons/fenced/pacemaker-fenced.c crm_log_xml_trace(msg, "Peer[inbound]"); msg 217 daemons/fenced/pacemaker-fenced.c stonith_command(NULL, 0, 0, msg, remote_peer); msg 223 daemons/fenced/pacemaker-fenced.c uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len) msg 227 daemons/fenced/pacemaker-fenced.c char *data = pcmk__cpg_message_data(handle, nodeid, pid, msg, &from); msg 319 daemons/fenced/pacemaker-fenced.h char *stonith_level_key(const xmlNode *msg, enum fenced_target_by); msg 320 daemons/fenced/pacemaker-fenced.h void fenced_register_level(xmlNode *msg, pcmk__action_result_t *result); msg 321 daemons/fenced/pacemaker-fenced.h void fenced_unregister_level(xmlNode *msg, pcmk__action_result_t *result); msg 345 daemons/fenced/pacemaker-fenced.h void fenced_process_fencing_reply(xmlNode *msg); msg 347 daemons/fenced/pacemaker-fenced.h int process_remote_stonith_query(xmlNode * msg); msg 351 daemons/fenced/pacemaker-fenced.h void stonith_fence_history(xmlNode *msg, xmlNode **output, msg 361 daemons/fenced/pacemaker-fenced.h xmlNode *msg); msg 40 daemons/pacemakerd/pcmkd_messages.c xmlNode *msg = request->xml; msg 45 daemons/pacemakerd/pcmkd_messages.c const char *from = crm_element_value(msg, PCMK__XA_CRM_SYS_FROM); msg 51 daemons/pacemakerd/pcmkd_messages.c pcmk__s(crm_element_value(msg, PCMK_XA_ORIGIN), "")); msg 57 daemons/pacemakerd/pcmkd_messages.c value = crm_element_value(msg, PCMK__XA_CRM_SYS_TO); msg 63 daemons/pacemakerd/pcmkd_messages.c reply = pcmk__new_reply(msg, ping); msg 99 daemons/pacemakerd/pcmkd_messages.c xmlNode *msg = request->xml; msg 117 daemons/pacemakerd/pcmkd_messages.c crm_element_value(msg, PCMK_XA_REFERENCE), msg 118 daemons/pacemakerd/pcmkd_messages.c crm_element_value(msg, PCMK_XA_ORIGIN)); msg 126 daemons/pacemakerd/pcmkd_messages.c reply = pcmk__new_reply(msg, shutdown); msg 213 daemons/pacemakerd/pcmkd_messages.c xmlNode *msg = NULL; msg 232 daemons/pacemakerd/pcmkd_messages.c msg = pcmk__client_data2xml(c, &id, &flags); msg 250 daemons/pacemakerd/pcmkd_messages.c if (msg == NULL) { msg 264 daemons/pacemakerd/pcmkd_messages.c .xml = msg, msg 299 daemons/pacemakerd/pcmkd_messages.c pcmk__xml_free(msg); msg 280 daemons/pacemakerd/pcmkd_subdaemons.c char *msg = NULL; msg 284 daemons/pacemakerd/pcmkd_subdaemons.c msg = crm_strdup_printf("Subdaemon %s[%d] requested panic", msg 286 daemons/pacemakerd/pcmkd_subdaemons.c pcmk__panic(msg); msg 289 daemons/pacemakerd/pcmkd_subdaemons.c free(msg); msg 52 daemons/schedulerd/schedulerd_messages.c xmlNode *msg = request->xml; msg 53 daemons/schedulerd/schedulerd_messages.c xmlNode *wrapper = pcmk__xe_first_child(msg, PCMK__XE_CRM_XML, NULL, NULL); msg 130 daemons/schedulerd/schedulerd_messages.c reply = pcmk__new_reply(msg, scheduler->priv->graph); msg 229 daemons/schedulerd/schedulerd_messages.c xmlNode *msg = NULL; msg 249 daemons/schedulerd/schedulerd_messages.c msg = pcmk__client_data2xml(c, &id, &flags); msg 267 daemons/schedulerd/schedulerd_messages.c if (msg == NULL) { msg 272 daemons/schedulerd/schedulerd_messages.c sys_to = crm_element_value(msg, PCMK__XA_CRM_SYS_TO); msg 274 daemons/schedulerd/schedulerd_messages.c if (pcmk__str_eq(crm_element_value(msg, PCMK__XA_SUBT), msg 296 daemons/schedulerd/schedulerd_messages.c .xml = msg, msg 331 daemons/schedulerd/schedulerd_messages.c pcmk__xml_free(msg); msg 134 include/crm/cib/cib_types.h xmlNode *msg)); msg 139 include/crm/cib/cib_types.h xmlNode *msg)); msg 103 include/crm/cib/internal.h void (*callback) (const char *event, xmlNode * msg); msg 173 include/crm/cib/internal.h int cib__get_notify_patchset(const xmlNode *msg, const xmlNode **patchset); msg 188 include/crm/cib/internal.h void cib_native_callback(cib_t * cib, xmlNode * msg, int call_id, int rc); msg 65 include/crm/common/logging_internal.h typedef void (*pcmk__config_error_func) (void *ctx, const char *msg, ...) msg 67 include/crm/common/logging_internal.h typedef void (*pcmk__config_warning_func) (void *ctx, const char *msg, ...) msg 30 include/crm/common/remote_internal.h int pcmk__remote_send_xml(pcmk__remote_t *remote, const xmlNode *msg); msg 40 include/crm/lrmd_internal.h int lrmd__remote_send_xml(pcmk__remote_t *session, xmlNode *msg, uint32_t id, msg 78 include/crm/lrmd_internal.h void remote_proxy_cb(lrmd_t *lrmd, const char *node_name, xmlNode *msg); msg 87 include/crm/lrmd_internal.h void remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg); msg 88 include/crm/lrmd_internal.h void remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, msg 56 lib/cib/cib_client.c xmlNode * msg)) msg 110 lib/cib/cib_client.c xmlNode *msg)) msg 178 lib/cib/cib_native.c xmlNode *msg = NULL; msg 189 lib/cib/cib_native.c msg = pcmk__xml_parse(buffer); msg 191 lib/cib/cib_native.c if (msg == NULL) { msg 197 lib/cib/cib_native.c type = crm_element_value(msg, PCMK__XA_T); msg 199 lib/cib/cib_native.c crm_log_xml_explicit(msg, "cib-reply"); msg 202 lib/cib/cib_native.c cib_native_callback(cib, msg, 0, 0); msg 205 lib/cib/cib_native.c g_list_foreach(cib->notify_list, cib_native_notify, msg); msg 211 lib/cib/cib_native.c pcmk__xml_free(msg); msg 207 lib/cib/cib_remote.c xmlNode *msg = NULL; msg 243 lib/cib/cib_remote.c msg = pcmk__remote_message_xml(&private->callback); msg 244 lib/cib/cib_remote.c if (msg == NULL) { msg 249 lib/cib/cib_remote.c type = crm_element_value(msg, PCMK__XA_T); msg 254 lib/cib/cib_remote.c cib_native_callback(cib, msg, 0, 0); msg 256 lib/cib/cib_remote.c g_list_foreach(cib->notify_list, cib_native_notify, msg); msg 261 lib/cib/cib_remote.c pcmk__xml_free(msg); msg 74 lib/cib/cib_utils.c cib__get_notify_patchset(const xmlNode *msg, const xmlNode **patchset) msg 82 lib/cib/cib_utils.c if (msg == NULL) { msg 87 lib/cib/cib_utils.c if ((crm_element_value_int(msg, PCMK__XA_CIB_RC, &rc) != 0) msg 92 lib/cib/cib_utils.c crm_log_xml_debug(msg, "failed"); msg 96 lib/cib/cib_utils.c wrapper = pcmk__xe_first_child(msg, PCMK__XE_CIB_UPDATE_RESULT, NULL, NULL); msg 665 lib/cib/cib_utils.c cib_native_callback(cib_t * cib, xmlNode * msg, int call_id, int rc) msg 670 lib/cib/cib_utils.c if (msg != NULL) { msg 673 lib/cib/cib_utils.c crm_element_value_int(msg, PCMK__XA_CIB_RC, &rc); msg 674 lib/cib/cib_utils.c crm_element_value_int(msg, PCMK__XA_CIB_CALLID, &call_id); msg 675 lib/cib/cib_utils.c wrapper = pcmk__xe_first_child(msg, PCMK__XE_CIB_CALLDATA, NULL, NULL); msg 697 lib/cib/cib_utils.c blob->callback(msg, call_id, rc, output, blob->user_data); msg 701 lib/cib/cib_utils.c crm_log_xml_debug(msg, "Failed CIB Update"); msg 715 lib/cib/cib_utils.c xmlNode *msg = user_data; msg 719 lib/cib/cib_utils.c if (msg == NULL) { msg 724 lib/cib/cib_utils.c event = crm_element_value(msg, PCMK__XA_SUBT); msg 740 lib/cib/cib_utils.c entry->callback(event, msg); msg 84 lib/cluster/cpg.c #define msg_data_len(msg) (msg->is_compressed?msg->compressed_size:msg->size) msg 315 lib/cluster/cpg.c check_message_sanity(const pcmk__cpg_msg_t *msg) msg 317 lib/cluster/cpg.c int32_t payload_size = msg->header.size - sizeof(pcmk__cpg_msg_t); msg 323 lib/cluster/cpg.c (msg->is_compressed? "Compressed " : ""), msg 324 lib/cluster/cpg.c msg->id, ais_dest(&(msg->sender)), msg 325 lib/cluster/cpg.c (int) msg->header.size, msg 326 lib/cluster/cpg.c msg_type2text(msg->sender.type), msg->sender.pid, msg 327 lib/cluster/cpg.c msg_type2text(msg->host.type), ais_dest(&(msg->host))); msg 331 lib/cluster/cpg.c if (msg->header.error != CS_OK) { msg 335 lib/cluster/cpg.c (msg->is_compressed? "Compressed " : ""), msg 336 lib/cluster/cpg.c msg->id, ais_dest(&(msg->sender)), msg 337 lib/cluster/cpg.c msg->header.error, msg 338 lib/cluster/cpg.c msg_type2text(msg->sender.type), msg->sender.pid, msg 339 lib/cluster/cpg.c msg_type2text(msg->host.type), ais_dest(&(msg->host))); msg 343 lib/cluster/cpg.c if (msg_data_len(msg) != payload_size) { msg 347 lib/cluster/cpg.c (msg->is_compressed? "Compressed " : ""), msg 348 lib/cluster/cpg.c msg->id, ais_dest(&(msg->sender)), msg 349 lib/cluster/cpg.c (int) msg->header.size, (int) msg_data_len(msg), msg 350 lib/cluster/cpg.c msg_type2text(msg->sender.type), msg->sender.pid, msg 351 lib/cluster/cpg.c msg_type2text(msg->host.type), ais_dest(&(msg->host))); msg 355 lib/cluster/cpg.c if (!msg->is_compressed && msg 359 lib/cluster/cpg.c (((msg->size > 1) && (msg->data[msg->size - 2] == '\0')) msg 360 lib/cluster/cpg.c || (msg->data[msg->size - 1] != '\0'))) { msg 364 lib/cluster/cpg.c msg->id, ais_dest(&(msg->sender)), msg->size, msg 365 lib/cluster/cpg.c msg_type2text(msg->sender.type), msg->sender.pid, msg 366 lib/cluster/cpg.c msg_type2text(msg->host.type), ais_dest(&(msg->host))); msg 371 lib/cluster/cpg.c (int) msg->header.size, (msg->is_compressed? "compressed " : ""), msg 372 lib/cluster/cpg.c msg->id, msg_type2text(msg->sender.type), msg->sender.pid, msg 373 lib/cluster/cpg.c ais_dest(&(msg->sender)), msg 374 lib/cluster/cpg.c msg_type2text(msg->host.type), ais_dest(&(msg->host))); msg 399 lib/cluster/cpg.c pcmk__cpg_msg_t *msg = content; msg 410 lib/cluster/cpg.c if (msg->sender.id == 0) { msg 411 lib/cluster/cpg.c msg->sender.id = sender_id; msg 412 lib/cluster/cpg.c } else if (msg->sender.id != sender_id) { msg 415 lib/cluster/cpg.c sender_id, pid, msg->sender.id); msg 420 lib/cluster/cpg.c if ((msg->host.id != 0) && (local_nodeid != msg->host.id)) { msg 423 lib/cluster/cpg.c sender_id, pid, msg->host.id, local_nodeid); msg 426 lib/cluster/cpg.c if ((msg->host.size > 0) msg 427 lib/cluster/cpg.c && !pcmk__str_eq(msg->host.uname, local_name, pcmk__str_casei)) { msg 431 lib/cluster/cpg.c sender_id, pid, msg->host.uname, local_name); msg 436 lib/cluster/cpg.c if (msg->sender.size == 0) { msg 447 lib/cluster/cpg.c msg->sender.size = strlen(peer->name); msg 448 lib/cluster/cpg.c memset(msg->sender.uname, 0, MAX_NAME); msg 449 lib/cluster/cpg.c memcpy(msg->sender.uname, peer->name, msg->sender.size); msg 455 lib/cluster/cpg.c pcmk__get_node(msg->sender.id, msg->sender.uname, NULL, msg 459 lib/cluster/cpg.c *from = msg->sender.uname; msg 462 lib/cluster/cpg.c if (!check_message_sanity(msg)) { msg 466 lib/cluster/cpg.c if (msg->is_compressed && (msg->size > 0)) { msg 468 lib/cluster/cpg.c unsigned int new_size = msg->size + 1; msg 471 lib/cluster/cpg.c rc = BZ2_bzBuffToBuffDecompress(uncompressed, &new_size, msg->data, msg 472 lib/cluster/cpg.c msg->compressed_size, 1, 0); msg 474 lib/cluster/cpg.c if ((rc == pcmk_rc_ok) && (msg->size != new_size)) { // libbz2 bug? msg 481 lib/cluster/cpg.c msg->id, ais_dest(&(msg->sender)), sender_id, pid, msg 488 lib/cluster/cpg.c data = pcmk__str_copy(msg->data); msg 493 lib/cluster/cpg.c (msg->is_compressed? "compressed " : ""), msg 494 lib/cluster/cpg.c msg->id, ais_dest(&(msg->sender)), sender_id, pid, msg->data); msg 926 lib/cluster/cpg.c pcmk__cpg_msg_t *msg = NULL; msg 943 lib/cluster/cpg.c msg = pcmk__assert_alloc(1, sizeof(pcmk__cpg_msg_t)); msg 946 lib/cluster/cpg.c msg->id = msg_id; msg 947 lib/cluster/cpg.c msg->header.error = CS_OK; msg 949 lib/cluster/cpg.c msg->host.type = dest; msg 954 lib/cluster/cpg.c msg->host.size = strlen(node->name); msg 955 lib/cluster/cpg.c memset(msg->host.uname, 0, MAX_NAME); msg 956 lib/cluster/cpg.c memcpy(msg->host.uname, node->name, msg->host.size); msg 961 lib/cluster/cpg.c msg->host.id = node->cluster_layer_id; msg 967 lib/cluster/cpg.c msg->sender.id = 0; msg 968 lib/cluster/cpg.c msg->sender.type = pcmk__parse_server(crm_system_name); msg 969 lib/cluster/cpg.c msg->sender.pid = local_pid; msg 970 lib/cluster/cpg.c msg->sender.size = local_name_len; msg 971 lib/cluster/cpg.c memset(msg->sender.uname, 0, MAX_NAME); msg 973 lib/cluster/cpg.c if ((local_name != NULL) && (msg->sender.size != 0)) { msg 974 lib/cluster/cpg.c memcpy(msg->sender.uname, local_name, msg->sender.size); msg 977 lib/cluster/cpg.c msg->size = 1 + strlen(data); msg 978 lib/cluster/cpg.c msg->header.size = sizeof(pcmk__cpg_msg_t) + msg->size; msg 980 lib/cluster/cpg.c if (msg->size < CRM_BZ2_THRESHOLD) { msg 981 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); msg 982 lib/cluster/cpg.c memcpy(msg->data, data, msg->size); msg 988 lib/cluster/cpg.c if (pcmk__compress(data, (unsigned int) msg->size, 0, &compressed, msg 991 lib/cluster/cpg.c msg->header.size = sizeof(pcmk__cpg_msg_t) + new_size; msg 992 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); msg 993 lib/cluster/cpg.c memcpy(msg->data, compressed, new_size); msg 995 lib/cluster/cpg.c msg->is_compressed = TRUE; msg 996 lib/cluster/cpg.c msg->compressed_size = new_size; msg 999 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); msg 1000 lib/cluster/cpg.c memcpy(msg->data, data, msg->size); msg 1007 lib/cluster/cpg.c iov->iov_base = msg; msg 1008 lib/cluster/cpg.c iov->iov_len = msg->header.size; msg 1010 lib/cluster/cpg.c if (msg->compressed_size > 0) { msg 1013 lib/cluster/cpg.c msg->id, target, iov->iov_len, msg->compressed_size, data); msg 1017 lib/cluster/cpg.c msg->id, target, iov->iov_len, msg->size, data); msg 1039 lib/cluster/cpg.c pcmk__cpg_send_xml(const xmlNode *msg, const pcmk__node_status_t *node, msg 1045 lib/cluster/cpg.c pcmk__xml_string(msg, 0, data, 0); msg 74 lib/cluster/crmcluster_private.h bool pcmk__cpg_send_xml(const xmlNode *msg, const pcmk__node_status_t *node, msg 23 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len) msg 30 lib/cluster/tests/cpg/pcmk_cpg_set_deliver_fn_test.c uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len) msg 283 lib/common/crmcommon_private.h bool (*dispatch)(pcmk_ipc_api_t *api, xmlNode *msg); msg 317 lib/common/ipc_client.c xmlNode *msg; msg 325 lib/common/ipc_client.c msg = pcmk__xml_parse(buffer); msg 326 lib/common/ipc_client.c if (msg == NULL) { msg 332 lib/common/ipc_client.c more = call_api_dispatch(api, msg); msg 333 lib/common/ipc_client.c pcmk__xml_free(msg); msg 436 lib/common/logging.c const char *msg) msg 239 lib/common/remote.c pcmk__remote_send_xml(pcmk__remote_t *remote, const xmlNode *msg) msg 248 lib/common/remote.c CRM_CHECK((remote != NULL) && (msg != NULL), return EINVAL); msg 251 lib/common/remote.c pcmk__xml_string(msg, 0, xml_text, 0); msg 143 lib/common/tls.c _gnutls_log_func(int level, const char *msg) msg 145 lib/common/tls.c crm_trace("%s", msg); msg 455 lib/common/utils.c _gnutls_log_func(int level, const char *msg) msg 457 lib/common/utils.c crm_trace("%s", msg); msg 949 lib/fencing/st_client.c invoke_registered_callbacks(stonith_t *stonith, const xmlNode *msg, int call_id) msg 960 lib/fencing/st_client.c if (msg == NULL) { msg 968 lib/fencing/st_client.c if ((crm_element_value_int(msg, PCMK__XA_ST_CALLID, &call_id) != 0) msg 970 lib/fencing/st_client.c crm_log_xml_warn(msg, "Bad fencer reply"); msg 972 lib/fencing/st_client.c stonith__xe_get_result(msg, &result); msg 993 lib/fencing/st_client.c crm_log_xml_debug(msg, "Failed fence update"); msg 1387 lib/fencing/st_client.c get_event_data_xml(xmlNode *msg, const char *ntype) msg 1390 lib/fencing/st_client.c xmlNode *data = pcmk__xpath_find_one(msg->doc, data_addr, LOG_DEBUG); msg 1416 lib/fencing/st_client.c xml_to_event(xmlNode *msg) msg 1424 lib/fencing/st_client.c crm_log_xml_trace(msg, "stonith_notify"); msg 1427 lib/fencing/st_client.c stonith__xe_get_result(msg, &event_private->result); msg 1428 lib/fencing/st_client.c event->operation = crm_element_value_copy(msg, PCMK__XA_ST_OP); msg 1437 lib/fencing/st_client.c xmlNode *data = get_event_data_xml(msg, event->operation); msg 1441 lib/fencing/st_client.c crm_log_xml_notice(msg, "BadEvent"); msg 1459 lib/fencing/st_client.c xmlNode *data = get_event_data_xml(msg, event->operation); msg 1463 lib/fencing/st_client.c crm_log_xml_notice(msg, "BadEvent"); msg 1686 lib/fencing/st_client.c const char *msg = crm_ipc_buffer(private->ipc); msg 1688 lib/fencing/st_client.c stonith_dispatch_internal(msg, strlen(msg), stonith_api); 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 100 lib/lrmd/lrmd_client.c void (*proxy_callback)(lrmd_t *lrmd, void *userdata, xmlNode *msg); msg 266 lib/lrmd/lrmd_client.c xmlNode *msg = data; msg 270 lib/lrmd/lrmd_client.c const char *proxy_session = crm_element_value(msg, msg 277 lib/lrmd/lrmd_client.c lrmd_internal_proxy_dispatch(lrmd, msg); msg 286 lib/lrmd/lrmd_client.c type = crm_element_value(msg, PCMK__XA_LRMD_OP); msg 287 lib/lrmd/lrmd_client.c crm_element_value_int(msg, PCMK__XA_LRMD_CALLID, &event.call_id); msg 288 lib/lrmd/lrmd_client.c event.rsc_id = crm_element_value(msg, PCMK__XA_LRMD_RSC_ID); msg 300 lib/lrmd/lrmd_client.c crm_element_value_int(msg, PCMK__XA_LRMD_TIMEOUT, &event.timeout); msg 301 lib/lrmd/lrmd_client.c crm_element_value_ms(msg, PCMK__XA_LRMD_RSC_INTERVAL, msg 303 lib/lrmd/lrmd_client.c crm_element_value_int(msg, PCMK__XA_LRMD_RSC_START_DELAY, msg 306 lib/lrmd/lrmd_client.c crm_element_value_int(msg, PCMK__XA_LRMD_EXEC_RC, &rc); msg 309 lib/lrmd/lrmd_client.c crm_element_value_int(msg, PCMK__XA_LRMD_EXEC_OP_STATUS, msg 311 lib/lrmd/lrmd_client.c crm_element_value_int(msg, PCMK__XA_LRMD_RSC_DELETED, msg 314 lib/lrmd/lrmd_client.c crm_element_value_epoch(msg, PCMK__XA_LRMD_RUN_TIME, &epoch); msg 317 lib/lrmd/lrmd_client.c crm_element_value_epoch(msg, PCMK__XA_LRMD_RCCHANGE_TIME, &epoch); msg 320 lib/lrmd/lrmd_client.c crm_element_value_int(msg, PCMK__XA_LRMD_EXEC_TIME, &exec_time); msg 324 lib/lrmd/lrmd_client.c crm_element_value_int(msg, PCMK__XA_LRMD_QUEUE_TIME, &queue_time); msg 328 lib/lrmd/lrmd_client.c event.op_type = crm_element_value(msg, PCMK__XA_LRMD_RSC_ACTION); msg 329 lib/lrmd/lrmd_client.c event.user_data = crm_element_value(msg, msg 334 lib/lrmd/lrmd_client.c event.output = crm_element_value_copy(msg, PCMK__XA_LRMD_RSC_OUTPUT); msg 336 lib/lrmd/lrmd_client.c crm_element_value(msg, PCMK__XA_LRMD_RSC_EXIT_REASON)); msg 338 lib/lrmd/lrmd_client.c event.params = xml2list(msg); msg 364 lib/lrmd/lrmd_client.c xmlNode *msg = pcmk__xml_parse(buffer); msg 366 lib/lrmd/lrmd_client.c lrmd_dispatch_internal(msg, lrmd); msg 367 lib/lrmd/lrmd_client.c pcmk__xml_free(msg); msg 538 lib/lrmd/lrmd_client.c const char *msg = crm_ipc_buffer(private->ipc); msg 540 lib/lrmd/lrmd_client.c lrmd_ipc_dispatch(msg, strlen(msg), lrmd); msg 668 lib/lrmd/lrmd_client.c lrmd__remote_send_xml(pcmk__remote_t *session, xmlNode *msg, uint32_t id, msg 671 lib/lrmd/lrmd_client.c crm_xml_add_int(msg, PCMK__XA_LRMD_REMOTE_MSG_ID, id); msg 672 lib/lrmd/lrmd_client.c crm_xml_add(msg, PCMK__XA_LRMD_REMOTE_MSG_TYPE, msg_type); msg 673 lib/lrmd/lrmd_client.c return pcmk__remote_send_xml(session, msg); msg 760 lib/lrmd/lrmd_client.c send_remote_message(lrmd_t *lrmd, xmlNode *msg) msg 770 lib/lrmd/lrmd_client.c rc = lrmd__remote_send_xml(native->remote, msg, global_remote_msg_id, msg 781 lib/lrmd/lrmd_client.c lrmd_tls_send_recv(lrmd_t * lrmd, xmlNode * msg, int timeout, xmlNode ** reply) msg 790 lib/lrmd/lrmd_client.c rc = send_remote_message(lrmd, msg); msg 813 lib/lrmd/lrmd_client.c lrmd_send_xml(lrmd_t * lrmd, xmlNode * msg, int timeout, xmlNode ** reply) msg 820 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply); msg 823 lib/lrmd/lrmd_client.c rc = lrmd_tls_send_recv(lrmd, msg, timeout, reply); msg 835 lib/lrmd/lrmd_client.c lrmd_send_xml_no_reply(lrmd_t * lrmd, xmlNode * msg) msg 842 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL); msg 845 lib/lrmd/lrmd_client.c rc = send_remote_message(lrmd, msg); msg 2029 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 2038 lib/lrmd/lrmd_client.c lrmd_internal_proxy_dispatch(lrmd_t *lrmd, xmlNode *msg) msg 2043 lib/lrmd/lrmd_client.c crm_log_xml_trace(msg, "PROXY_INBOUND"); msg 2044 lib/lrmd/lrmd_client.c native->proxy_callback(lrmd, native->proxy_callback_userdata, msg); msg 2049 lib/lrmd/lrmd_client.c lrmd_internal_proxy_send(lrmd_t * lrmd, xmlNode *msg) msg 2054 lib/lrmd/lrmd_client.c crm_xml_add(msg, PCMK__XA_LRMD_OP, CRM_OP_IPC_FWD); msg 2056 lib/lrmd/lrmd_client.c crm_log_xml_trace(msg, "PROXY_OUTBOUND"); msg 2057 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 = pcmk__xe_create(NULL, PCMK__XE_LRMD_IPC_PROXY); msg 33 lib/lrmd/proxy_common.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_OP, LRMD_IPC_OP_DESTROY); msg 34 lib/lrmd/proxy_common.c crm_xml_add(msg, PCMK__XA_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 pcmk__xml_free(msg); msg 48 lib/lrmd/proxy_common.c xmlNode *msg = pcmk__xe_create(NULL, PCMK__XE_LRMD_IPC_PROXY); msg 49 lib/lrmd/proxy_common.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_OP, LRMD_IPC_OP_SHUTDOWN_ACK); msg 50 lib/lrmd/proxy_common.c lrmd_internal_proxy_send(lrmd, msg); msg 51 lib/lrmd/proxy_common.c pcmk__xml_free(msg); msg 63 lib/lrmd/proxy_common.c xmlNode *msg = pcmk__xe_create(NULL, PCMK__XE_LRMD_IPC_PROXY); msg 64 lib/lrmd/proxy_common.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_OP, LRMD_IPC_OP_SHUTDOWN_NACK); msg 65 lib/lrmd/proxy_common.c lrmd_internal_proxy_send(lrmd, msg); msg 66 lib/lrmd/proxy_common.c pcmk__xml_free(msg); msg 70 lib/lrmd/proxy_common.c remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg) msg 80 lib/lrmd/proxy_common.c pcmk__xml_copy(wrapper, msg); msg 88 lib/lrmd/proxy_common.c remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, int msg_id) msg 99 lib/lrmd/proxy_common.c pcmk__xml_copy(wrapper, msg); msg 217 lib/lrmd/proxy_common.c remote_proxy_cb(lrmd_t *lrmd, const char *node_name, xmlNode *msg) msg 219 lib/lrmd/proxy_common.c const char *op = crm_element_value(msg, PCMK__XA_LRMD_IPC_OP); msg 220 lib/lrmd/proxy_common.c const char *session = crm_element_value(msg, PCMK__XA_LRMD_IPC_SESSION); msg 231 lib/lrmd/proxy_common.c crm_element_value_int(msg, PCMK__XA_LRMD_IPC_MSG_ID, &msg_id); msg 240 lib/lrmd/proxy_common.c const char *name = crm_element_value(msg, PCMK__XA_LRMD_IPC_CLIENT); msg 242 lib/lrmd/proxy_common.c xmlNode *wrapper = pcmk__xe_first_child(msg, PCMK__XE_LRMD_IPC_MSG, msg 265 lib/lrmd/proxy_common.c rc = pcmk__xe_get_flags(msg, PCMK__XA_LRMD_IPC_MSG_FLAGS, &flags, 0U); msg 759 lib/pacemaker/pcmk_output.c char *msg = NULL; msg 780 lib/pacemaker/pcmk_output.c msg = crm_strdup_printf("Status of %s: '%s' (last updated %s)", msg 783 lib/pacemaker/pcmk_output.c pcmk__output_create_html_node(out, "li", NULL, NULL, msg); msg 785 lib/pacemaker/pcmk_output.c free(msg); msg 412 lib/services/dbus.c pcmk_dbus_send_recv(DBusMessage *msg, DBusConnection *connection, msg 419 lib/services/dbus.c pcmk__assert(dbus_message_get_type(msg) == DBUS_MESSAGE_TYPE_METHOD_CALL); msg 420 lib/services/dbus.c method = dbus_message_get_member (msg); msg 433 lib/services/dbus.c if (!dbus_connection_send_with_reply(connection, msg, &pending, timeout)) { msg 476 lib/services/dbus.c pcmk_dbus_send(DBusMessage *msg, DBusConnection *connection, msg 484 lib/services/dbus.c pcmk__assert(dbus_message_get_type(msg) == DBUS_MESSAGE_TYPE_METHOD_CALL); msg 485 lib/services/dbus.c method = dbus_message_get_member(msg); msg 493 lib/services/dbus.c if (!dbus_connection_send_with_reply(connection, msg, &pending, timeout)) { msg 516 lib/services/dbus.c pcmk_dbus_type_check(DBusMessage *msg, DBusMessageIter *field, int expected, msg 523 lib/services/dbus.c if (dbus_message_iter_init(msg, &lfield)) { msg 541 lib/services/dbus.c dbus_message_iter_init(msg, &args); msg 700 lib/services/dbus.c DBusMessage *msg; msg 711 lib/services/dbus.c msg = dbus_message_new_method_call(target, obj, BUS_PROPERTY_IFACE, "Get"); msg 712 lib/services/dbus.c if (msg == NULL) { msg 719 lib/services/dbus.c if (!dbus_message_append_args(msg, msg 725 lib/services/dbus.c dbus_message_unref(msg); msg 733 lib/services/dbus.c dbus_message_unref(msg); msg 746 lib/services/dbus.c dbus_message_unref(msg); msg 752 lib/services/dbus.c local_pending = pcmk_dbus_send(msg, connection, async_query_result_cb, msg 765 lib/services/dbus.c DBusMessage *reply = pcmk_dbus_send_recv(msg, connection, NULL, msg 775 lib/services/dbus.c dbus_message_unref(msg); msg 33 lib/services/pcmk-dbus.h DBusPendingCall *pcmk_dbus_send(DBusMessage *msg, DBusConnection *connection, msg 37 lib/services/pcmk-dbus.h DBusMessage *pcmk_dbus_send_recv(DBusMessage *msg, DBusConnection *connection, DBusError *error, int timeout); msg 40 lib/services/pcmk-dbus.h bool pcmk_dbus_type_check(DBusMessage *msg, DBusMessageIter *field, int expected, const char *function, int line); msg 86 lib/services/systemd.c systemd_send(DBusMessage *msg, msg 90 lib/services/systemd.c return pcmk_dbus_send(msg, systemd_proxy, done, user_data, timeout); msg 94 lib/services/systemd.c systemd_send_recv(DBusMessage *msg, DBusError *error, int timeout) msg 96 lib/services/systemd.c return pcmk_dbus_send_recv(msg, systemd_proxy, error, timeout); msg 113 lib/services/systemd.c DBusMessage *msg = NULL; msg 120 lib/services/systemd.c msg = systemd_new_method(method); msg 122 lib/services/systemd.c if (msg == NULL) { msg 128 lib/services/systemd.c reply = systemd_send_recv(msg, &error, DBUS_TIMEOUT_USE_DEFAULT); msg 129 lib/services/systemd.c dbus_message_unref(msg); msg 334 lib/services/systemd.c DBusMessage *msg = systemd_new_method("Reload"); msg 337 lib/services/systemd.c pcmk__assert(msg != NULL); msg 338 lib/services/systemd.c systemd_send(msg, systemd_daemon_reload_complete, msg 340 lib/services/systemd.c dbus_message_unref(msg); msg 505 lib/services/systemd.c DBusMessage *msg; msg 530 lib/services/systemd.c msg = systemd_new_method("LoadUnit"); msg 531 lib/services/systemd.c pcmk__assert(msg != NULL); msg 538 lib/services/systemd.c CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &name, msg 547 lib/services/systemd.c reply = systemd_send_recv(msg, NULL, msg 549 lib/services/systemd.c dbus_message_unref(msg); msg 571 lib/services/systemd.c pending = systemd_send(msg, loadunit_completed, op, op->timeout); msg 575 lib/services/systemd.c dbus_message_unref(msg); msg 582 lib/services/systemd.c dbus_message_unref(msg); msg 1240 lib/services/systemd.c DBusMessage *msg = NULL; msg 1306 lib/services/systemd.c msg = systemd_new_method(method); msg 1307 lib/services/systemd.c pcmk__assert(msg != NULL); msg 1317 lib/services/systemd.c CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID)); msg 1318 lib/services/systemd.c CRM_LOG_ASSERT(dbus_message_append_args(msg, DBUS_TYPE_STRING, &replace_s, DBUS_TYPE_INVALID)); msg 1324 lib/services/systemd.c reply = systemd_send_recv(msg, NULL, op->timeout); msg 1325 lib/services/systemd.c dbus_message_unref(msg); msg 1332 lib/services/systemd.c DBusPendingCall *pending = systemd_send(msg, unit_method_complete, op, msg 1335 lib/services/systemd.c dbus_message_unref(msg); msg 230 tools/crm_mon.c static void crm_diff_update(const char *event, xmlNode * msg); msg 778 tools/crm_mon.c const char *msg = "Connection to the cluster lost"; msg 785 tools/crm_mon.c out->transient(out, "%s", msg); msg 787 tools/crm_mon.c out->message(out, "crm-mon-disconnected", msg, pcmkd_state); msg 1916 tools/crm_mon.c crm_diff_update(const char *event, xmlNode * msg) msg 1921 tools/crm_mon.c xmlNode *wrapper = pcmk__xe_first_child(msg, PCMK__XE_CIB_UPDATE_RESULT, msg 1955 tools/crm_mon.c xmlNode *wrapper = pcmk__xe_first_child(msg, msg 2114 tools/crm_resource.c GString *msg = g_string_sized_new(128); msg 2117 tools/crm_resource.c g_string_append(msg, "non-option ARGV-elements:"); msg 2120 tools/crm_resource.c g_string_append_printf(msg, "\n[%d of %u] %s", msg 2124 tools/crm_resource.c g_set_error(&error, PCMK__EXITC_ERROR, exit_code, "%s", msg->str); msg 2125 tools/crm_resource.c g_string_free(msg, TRUE); msg 2354 tools/crm_resource.c char *msg = crm_strdup_printf("%s\nError performing operation: %s", msg 2357 tools/crm_resource.c g_set_error(&error, PCMK__EXITC_ERROR, exit_code, "%s", msg); msg 2358 tools/crm_resource.c free(msg); msg 99 tools/crm_shadow.c const char *msg = va_arg(args, const char *); msg 101 tools/crm_shadow.c if (msg == NULL) { msg 104 tools/crm_shadow.c return out->info(out, "%s", msg); msg 123 tools/crm_shadow.c const char *msg = va_arg(args, const char *); msg 125 tools/crm_shadow.c if (msg == NULL) { msg 128 tools/crm_shadow.c pcmk__output_create_xml_text_node(out, "instruction", msg); msg 607 tools/crm_shadow.c char *msg = NULL; msg 615 tools/crm_shadow.c msg = crm_strdup_printf("%s, enter the following into your shell:\n" msg 618 tools/crm_shadow.c out->message(out, "instruction", msg); msg 619 tools/crm_shadow.c free(msg); msg 125 tools/crm_verify.c output_config_error(void *ctx, const char *msg, ...) msg 131 tools/crm_verify.c va_start(ap, msg); msg 132 tools/crm_verify.c pcmk__assert(vasprintf(&buf, msg, ap) > 0); msg 149 tools/crm_verify.c output_config_warning(void *ctx, const char *msg, ...) msg 155 tools/crm_verify.c va_start(ap, msg); msg 156 tools/crm_verify.c pcmk__assert(vasprintf(&buf, msg, ap) > 0);