reply 438 daemons/attrd/attrd_commands.c xmlNode *reply = create_xml_node(NULL, __func__); reply 441 daemons/attrd/attrd_commands.c if (reply == NULL) { reply 444 daemons/attrd/attrd_commands.c crm_xml_add(reply, F_TYPE, T_ATTRD); reply 445 daemons/attrd/attrd_commands.c crm_xml_add(reply, PCMK__XA_ATTR_VERSION, ATTRD_PROTOCOL_VERSION); reply 453 daemons/attrd/attrd_commands.c crm_xml_add(reply, PCMK__XA_ATTR_NAME, attr); reply 464 daemons/attrd/attrd_commands.c host_value = create_xml_node(reply, XML_CIB_TAG_NODE); reply 466 daemons/attrd/attrd_commands.c free_xml(reply); reply 479 daemons/attrd/attrd_commands.c host_value = create_xml_node(reply, XML_CIB_TAG_NODE); reply 481 daemons/attrd/attrd_commands.c free_xml(reply); reply 489 daemons/attrd/attrd_commands.c return reply; reply 507 daemons/attrd/attrd_commands.c xmlNode *reply; reply 523 daemons/attrd/attrd_commands.c reply = build_query_reply(attr, crm_element_value(query, reply 525 daemons/attrd/attrd_commands.c if (reply == NULL) { reply 530 daemons/attrd/attrd_commands.c crm_log_xml_trace(reply, "Reply"); reply 535 daemons/attrd/attrd_commands.c int rc = pcmk__ipc_send_xml(client, id, reply, flags); reply 542 daemons/attrd/attrd_commands.c free_xml(reply); reply 57 daemons/based/based_callbacks.c static int cib_process_command(xmlNode *request, xmlNode **reply, reply 303 daemons/based/based_callbacks.c process_ping_reply(xmlNode *reply) reply 306 daemons/based/based_callbacks.c const char *host = crm_element_value(reply, F_ORIG); reply 308 daemons/based/based_callbacks.c xmlNode *pong = get_message_xml(reply, F_CIB_CALLDATA); reply 364 daemons/based/based_callbacks.c sync_our_cib(reply, FALSE); reply 1182 daemons/based/based_callbacks.c cib_process_command(xmlNode * request, xmlNode ** reply, xmlNode ** cib_diff, gboolean privileged) reply 1217 daemons/based/based_callbacks.c *reply = NULL; reply 1400 daemons/based/based_callbacks.c *reply = create_xml_node(NULL, "cib-reply"); reply 1401 daemons/based/based_callbacks.c crm_xml_add(*reply, F_TYPE, T_CIB); reply 1402 daemons/based/based_callbacks.c crm_xml_add(*reply, F_CIB_OPERATION, op); reply 1403 daemons/based/based_callbacks.c crm_xml_add(*reply, F_CIB_CALLID, call_id); reply 1404 daemons/based/based_callbacks.c crm_xml_add(*reply, F_CIB_CLIENTID, caller); reply 1405 daemons/based/based_callbacks.c crm_xml_add_int(*reply, F_CIB_CALLOPTS, call_options); reply 1406 daemons/based/based_callbacks.c crm_xml_add_int(*reply, F_CIB_RC, rc); reply 1410 daemons/based/based_callbacks.c add_message_xml(*reply, F_CIB_CALLDATA, output); reply 1413 daemons/based/based_callbacks.c crm_log_xml_explicit(*reply, "cib:reply"); reply 33 daemons/based/based_common.c extern int cib_perform_command(xmlNode * request, xmlNode ** reply, xmlNode ** cib_diff, reply 561 daemons/based/based_remote.c struct pam_response *reply; reply 567 daemons/based/based_remote.c reply = calloc(1, sizeof(struct pam_response)); reply 568 daemons/based/based_remote.c CRM_ASSERT(reply != NULL); reply 577 daemons/based/based_remote.c reply[count].resp_retcode = 0; reply 578 daemons/based/based_remote.c reply[count].resp = string; /* We already made a copy */ reply 591 daemons/based/based_remote.c *response = reply; reply 592 daemons/based/based_remote.c reply = NULL; reply 598 daemons/based/based_remote.c if (reply[count].resp != NULL) { reply 603 daemons/based/based_remote.c while (*(reply[count].resp)) { reply 604 daemons/based/based_remote.c *(reply[count].resp)++ = '\0'; reply 606 daemons/based/based_remote.c free(reply[count].resp); reply 609 daemons/based/based_remote.c reply[count].resp = NULL; reply 612 daemons/based/based_remote.c free(reply); reply 613 daemons/based/based_remote.c reply = NULL; reply 1567 daemons/controld/controld_execd.c xmlNode *reply = create_request(CRM_OP_INVOKE_LRM, fragment, from_host, reply 1573 daemons/controld/controld_execd.c if (relay_message(reply, TRUE) == FALSE) { reply 1574 daemons/controld/controld_execd.c crm_log_xml_err(reply, "Unable to route reply"); reply 1576 daemons/controld/controld_execd.c free_xml(reply); reply 1586 daemons/controld/controld_execd.c xmlNode *reply = create_reply(msg, data); reply 1588 daemons/controld/controld_execd.c if (relay_message(reply, TRUE) == FALSE) { reply 1590 daemons/controld/controld_execd.c crm_log_xml_err(reply, "reply"); reply 1592 daemons/controld/controld_execd.c free_xml(reply); reply 1606 daemons/controld/controld_execd.c xmlNode *reply = create_request(CRM_OP_INVOKE_LRM, NULL, from_host, reply 1612 daemons/controld/controld_execd.c if (relay_message(reply, TRUE) == FALSE) { reply 1613 daemons/controld/controld_execd.c crm_log_xml_err(reply, "Unable to route reply"); reply 1615 daemons/controld/controld_execd.c free_xml(reply); reply 2097 daemons/controld/controld_execd.c xmlNode *reply = NULL; reply 2122 daemons/controld/controld_execd.c reply = create_request(CRM_OP_INVOKE_LRM, update, to_host, to_sys, CRM_SYSTEM_LRMD, NULL); reply 2128 daemons/controld/controld_execd.c crm_element_value(reply, XML_ATTR_REFERENCE)); reply 2130 daemons/controld/controld_execd.c if (relay_message(reply, TRUE) == FALSE) { reply 2131 daemons/controld/controld_execd.c crm_log_xml_err(reply, "Unable to route reply"); reply 2135 daemons/controld/controld_execd.c free_xml(reply); reply 176 daemons/controld/controld_join_client.c xmlNode *reply = NULL; reply 181 daemons/controld/controld_join_client.c reply = create_request(CRM_OP_JOIN_REQUEST, generation, fsa_our_dc, reply 184 daemons/controld/controld_join_client.c crm_xml_add(reply, F_CRM_JOIN_ID, join_id); reply 185 daemons/controld/controld_join_client.c crm_xml_add(reply, XML_ATTR_CRM_VERSION, CRM_FEATURE_SET); reply 186 daemons/controld/controld_join_client.c send_cluster_message(crm_get_peer(0, fsa_our_dc), crm_msg_crmd, reply, TRUE); reply 187 daemons/controld/controld_join_client.c free_xml(reply); reply 273 daemons/controld/controld_join_client.c xmlNode *reply = create_request(CRM_OP_JOIN_CONFIRM, tmp1, fsa_our_dc, reply 276 daemons/controld/controld_join_client.c crm_xml_add_int(reply, F_CRM_JOIN_ID, join_id); reply 300 daemons/controld/controld_join_client.c send_cluster_message(crm_get_peer(0, fsa_our_dc), crm_msg_crmd, reply, TRUE); reply 301 daemons/controld/controld_join_client.c free_xml(reply); reply 792 daemons/controld/controld_messages.c xmlNode *reply = NULL; reply 807 daemons/controld/controld_messages.c reply = create_reply(request, reply_data); reply 809 daemons/controld/controld_messages.c if (reply) { reply 810 daemons/controld/controld_messages.c (void) relay_message(reply, TRUE); reply 811 daemons/controld/controld_messages.c free_xml(reply); reply 831 daemons/controld/controld_messages.c xmlNode *reply = NULL; reply 835 daemons/controld/controld_messages.c reply = create_xml_node(NULL, XML_CIB_TAG_NODE); reply 836 daemons/controld/controld_messages.c crm_xml_add(reply, XML_PING_ATTR_SYSFROM, CRM_SYSTEM_CRMD); reply 839 daemons/controld/controld_messages.c pcmk__xe_set_bool_attr(reply, XML_ATTR_HAVE_QUORUM, fsa_has_quorum); reply 855 daemons/controld/controld_messages.c crm_xml_add_int(reply, XML_ATTR_ID, node->id); reply 856 daemons/controld/controld_messages.c crm_xml_add(reply, XML_ATTR_UUID, node->uuid); reply 857 daemons/controld/controld_messages.c crm_xml_add(reply, XML_ATTR_UNAME, node->uname); reply 858 daemons/controld/controld_messages.c crm_xml_add(reply, XML_NODE_IS_PEER, node->state); reply 859 daemons/controld/controld_messages.c pcmk__xe_set_bool_attr(reply, XML_NODE_IS_REMOTE, reply 864 daemons/controld/controld_messages.c msg = create_reply(msg, reply); reply 865 daemons/controld/controld_messages.c free_xml(reply); reply 119 daemons/controld/controld_schedulerd.c handle_reply(pcmk_schedulerd_api_reply_t *reply) reply 127 daemons/controld/controld_schedulerd.c msg_ref = reply->data.graph.reference; reply 148 daemons/controld/controld_schedulerd.c crm_xml_add(fsa_input.msg, F_CRM_TGRAPH_INPUT, reply->data.graph.input); reply 151 daemons/controld/controld_schedulerd.c add_node_copy(crm_data_node, reply->data.graph.tgraph); reply 165 daemons/controld/controld_schedulerd.c pcmk_schedulerd_api_reply_t *reply = event_data; reply 173 daemons/controld/controld_schedulerd.c handle_reply(reply); reply 533 daemons/execd/execd_commands.c xmlNode *reply = create_xml_node(NULL, T_LRMD_REPLY); reply 535 daemons/execd/execd_commands.c crm_xml_add(reply, F_LRMD_ORIGIN, origin); reply 536 daemons/execd/execd_commands.c crm_xml_add_int(reply, F_LRMD_RC, rc); reply 537 daemons/execd/execd_commands.c crm_xml_add_int(reply, F_LRMD_CALLID, call_id); reply 538 daemons/execd/execd_commands.c return reply; reply 1460 daemons/execd/execd_commands.c xmlNode **reply) reply 1484 daemons/execd/execd_commands.c *reply = create_lrmd_reply(__func__, rc, call_id); reply 1485 daemons/execd/execd_commands.c crm_xml_add(*reply, F_LRMD_OPERATION, CRM_OP_REGISTER); reply 1486 daemons/execd/execd_commands.c crm_xml_add(*reply, F_LRMD_CLIENTID, client->id); reply 1487 daemons/execd/execd_commands.c crm_xml_add(*reply, F_LRMD_PROTOCOL_VERSION, LRMD_PROTOCOL_VERSION); reply 1519 daemons/execd/execd_commands.c xmlNode *reply = NULL; reply 1532 daemons/execd/execd_commands.c reply = create_lrmd_reply(__func__, rc, call_id); reply 1534 daemons/execd/execd_commands.c crm_xml_add(reply, F_LRMD_RSC_ID, rsc->rsc_id); reply 1535 daemons/execd/execd_commands.c crm_xml_add(reply, F_LRMD_CLASS, rsc->class); reply 1536 daemons/execd/execd_commands.c crm_xml_add(reply, F_LRMD_PROVIDER, rsc->provider); reply 1537 daemons/execd/execd_commands.c crm_xml_add(reply, F_LRMD_TYPE, rsc->type); reply 1539 daemons/execd/execd_commands.c return reply; reply 1717 daemons/execd/execd_commands.c add_recurring_op_xml(xmlNode *reply, lrmd_rsc_t *rsc) reply 1719 daemons/execd/execd_commands.c xmlNode *rsc_xml = create_xml_node(reply, F_LRMD_RSC); reply 1739 daemons/execd/execd_commands.c xmlNode *reply = NULL; reply 1761 daemons/execd/execd_commands.c reply = create_lrmd_reply(__func__, rc, call_id); reply 1771 daemons/execd/execd_commands.c add_recurring_op_xml(reply, rsc); reply 1774 daemons/execd/execd_commands.c add_recurring_op_xml(reply, rsc); reply 1776 daemons/execd/execd_commands.c return reply; reply 1787 daemons/execd/execd_commands.c xmlNode *reply = NULL; reply 1810 daemons/execd/execd_commands.c rc = process_lrmd_signon(client, request, call_id, &reply); reply 1822 daemons/execd/execd_commands.c reply = process_lrmd_get_rsc_info(request, call_id); reply 1873 daemons/execd/execd_commands.c reply = process_lrmd_get_recurring(request, call_id); reply 1896 daemons/execd/execd_commands.c if (reply == NULL) { reply 1897 daemons/execd/execd_commands.c reply = create_lrmd_reply(__func__, rc, call_id); reply 1899 daemons/execd/execd_commands.c send_rc = lrmd_server_send_reply(client, id, reply); reply 1900 daemons/execd/execd_commands.c free_xml(reply); reply 205 daemons/execd/pacemaker-execd.c lrmd_server_send_reply(pcmk__client_t *client, uint32_t id, xmlNode *reply) reply 210 daemons/execd/pacemaker-execd.c return pcmk__ipc_send_xml(client, id, reply, FALSE); reply 213 daemons/execd/pacemaker-execd.c return lrmd__remote_send_xml(client->remote, reply, id, "reply"); reply 62 daemons/execd/pacemaker-execd.h int lrmd_server_send_reply(pcmk__client_t *client, uint32_t id, xmlNode *reply); reply 69 daemons/fenced/fenced_commands.c static void stonith_send_reply(xmlNode * reply, int call_options, const char *remote_peer, reply 2135 daemons/fenced/fenced_commands.c xmlNode *reply; reply 2332 daemons/fenced/fenced_commands.c add_message_xml(query->reply, F_STONITH_CALLDATA, list); reply 2335 daemons/fenced/fenced_commands.c stonith_send_reply(query->reply, query->call_options, query->remote_peer, reply 2339 daemons/fenced/fenced_commands.c free_xml(query->reply); reply 2445 daemons/fenced/fenced_commands.c xmlNode *reply = NULL; reply 2460 daemons/fenced/fenced_commands.c reply = construct_async_reply(cmd, result); reply 2462 daemons/fenced/fenced_commands.c pcmk__xe_set_bool_attr(reply, F_STONITH_MERGED, true); reply 2472 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_SUBTYPE, "broadcast"); reply 2473 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_OPERATION, T_STONITH_NOTIFY); reply 2474 daemons/fenced/fenced_commands.c send_cluster_message(NULL, crm_msg_stonith_ng, reply, FALSE); reply 2477 daemons/fenced/fenced_commands.c stonith_send_reply(reply, cmd->options, cmd->origin, client); reply 2480 daemons/fenced/fenced_commands.c crm_log_xml_trace(reply, "Reply"); reply 2481 daemons/fenced/fenced_commands.c free_xml(reply); reply 2756 daemons/fenced/fenced_commands.c xmlNode *reply = NULL; reply 2758 daemons/fenced/fenced_commands.c reply = create_xml_node(NULL, T_STONITH_REPLY); reply 2760 daemons/fenced/fenced_commands.c crm_xml_add(reply, "st_origin", __func__); reply 2761 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_TYPE, T_STONITH_NG); reply 2762 daemons/fenced/fenced_commands.c stonith__xe_set_result(reply, result); reply 2792 daemons/fenced/fenced_commands.c crm_xml_add(reply, name, value); reply 2795 daemons/fenced/fenced_commands.c add_message_xml(reply, F_STONITH_CALLDATA, data); reply 2798 daemons/fenced/fenced_commands.c return reply; reply 2811 daemons/fenced/fenced_commands.c xmlNode *reply = create_xml_node(NULL, T_STONITH_REPLY); reply 2813 daemons/fenced/fenced_commands.c crm_xml_add(reply, "st_origin", __func__); reply 2814 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_TYPE, T_STONITH_NG); reply 2815 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_OPERATION, cmd->op); reply 2816 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_DEVICE, cmd->device); reply 2817 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_REMOTE_OP_ID, cmd->remote_op_id); reply 2818 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_CLIENTID, cmd->client); reply 2819 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_CLIENTNAME, cmd->client_name); reply 2820 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_TARGET, cmd->victim); reply 2821 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_ACTION, cmd->op); reply 2822 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_ORIGIN, cmd->origin); reply 2823 daemons/fenced/fenced_commands.c crm_xml_add_int(reply, F_STONITH_CALLID, cmd->id); reply 2824 daemons/fenced/fenced_commands.c crm_xml_add_int(reply, F_STONITH_CALLOPTS, cmd->options); reply 2826 daemons/fenced/fenced_commands.c stonith__xe_set_result(reply, result); reply 2827 daemons/fenced/fenced_commands.c return reply; reply 2903 daemons/fenced/fenced_commands.c stonith_send_reply(xmlNode *reply, int call_options, const char *remote_peer, reply 2906 daemons/fenced/fenced_commands.c CRM_CHECK((reply != NULL) && ((remote_peer != NULL) || (client != NULL)), reply 2910 daemons/fenced/fenced_commands.c do_local_reply(reply, client, call_options); reply 2913 daemons/fenced/fenced_commands.c reply, FALSE); reply 2998 daemons/fenced/fenced_commands.c xmlNode *reply = create_xml_node(NULL, "reply"); reply 3001 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_OPERATION, CRM_OP_REGISTER); reply 3002 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_CLIENTID, request->ipc_client->id); reply 3005 daemons/fenced/fenced_commands.c return reply; reply 3070 daemons/fenced/fenced_commands.c query->reply = fenced_construct_reply(request->xml, NULL, &request->result); reply 3236 daemons/fenced/fenced_commands.c xmlNode *reply = NULL; reply 3246 daemons/fenced/fenced_commands.c reply = fenced_construct_reply(request->xml, data, &request->result); reply 3249 daemons/fenced/fenced_commands.c return reply; reply 3396 daemons/fenced/fenced_commands.c xmlNode *reply = NULL; reply 3402 daemons/fenced/fenced_commands.c reply = pcmk__process_request(request, fenced_handlers); reply 3403 daemons/fenced/fenced_commands.c if (reply != NULL) { reply 3410 daemons/fenced/fenced_commands.c pcmk__ipc_send_xml(request->ipc_client, request->ipc_id, reply, reply 3414 daemons/fenced/fenced_commands.c stonith_send_reply(reply, request->call_options, reply 3417 daemons/fenced/fenced_commands.c free_xml(reply); reply 430 daemons/fenced/fenced_remote.c xmlNode *reply = NULL; reply 443 daemons/fenced/fenced_remote.c reply = fenced_construct_reply(op->request, data, &op->result); reply 444 daemons/fenced/fenced_remote.c crm_xml_add(reply, F_STONITH_DELEGATE, op->delegate); reply 451 daemons/fenced/fenced_remote.c do_local_reply(reply, client, op->call_options); reply 462 daemons/fenced/fenced_remote.c free_xml(reply); reply 216 daemons/pacemakerd/pacemakerd.c pcmk_pacemakerd_api_reply_t *reply = event_data; reply 231 daemons/pacemakerd/pacemakerd.c if (reply->reply_type != pcmk_pacemakerd_reply_shutdown) { reply 233 daemons/pacemakerd/pacemakerd.c reply->reply_type); reply 27 daemons/pacemakerd/pcmkd_messages.c xmlNode *reply = NULL; reply 41 daemons/pacemakerd/pcmkd_messages.c reply = create_reply(msg, ping); reply 43 daemons/pacemakerd/pcmkd_messages.c if (reply) { reply 44 daemons/pacemakerd/pcmkd_messages.c if (pcmk__ipc_send_xml(c, id, reply, crm_ipc_server_event) != reply 49 daemons/pacemakerd/pcmkd_messages.c free_xml(reply); reply 73 daemons/pacemakerd/pcmkd_messages.c xmlNode *reply = NULL; reply 94 daemons/pacemakerd/pcmkd_messages.c reply = create_reply(msg, shutdown); reply 96 daemons/pacemakerd/pcmkd_messages.c if (reply) { reply 97 daemons/pacemakerd/pcmkd_messages.c if (pcmk__ipc_send_xml(c, id, reply, crm_ipc_server_event) != pcmk_rc_ok) { reply 101 daemons/pacemakerd/pcmkd_messages.c free_xml(reply); reply 65 daemons/schedulerd/schedulerd_messages.c xmlNode *reply = NULL; reply 120 daemons/schedulerd/schedulerd_messages.c reply = create_reply(msg, data_set->graph); reply 121 daemons/schedulerd/schedulerd_messages.c CRM_ASSERT(reply != NULL); reply 133 daemons/schedulerd/schedulerd_messages.c crm_xml_add(reply, F_CRM_TGRAPH_INPUT, filename); reply 134 daemons/schedulerd/schedulerd_messages.c crm_xml_add_int(reply, "graph-errors", was_processing_error); reply 135 daemons/schedulerd/schedulerd_messages.c crm_xml_add_int(reply, "graph-warnings", was_processing_warning); reply 136 daemons/schedulerd/schedulerd_messages.c crm_xml_add_int(reply, "config-errors", crm_config_error); reply 137 daemons/schedulerd/schedulerd_messages.c crm_xml_add_int(reply, "config-warnings", crm_config_warning); reply 139 daemons/schedulerd/schedulerd_messages.c if (pcmk__ipc_send_xml(sender, 0, reply, reply 152 daemons/schedulerd/schedulerd_messages.c crm_xml_add(reply, F_CRM_TGRAPH, graph_file); reply 156 daemons/schedulerd/schedulerd_messages.c free_xml(first_named_child(reply, F_CRM_DATA)); reply 157 daemons/schedulerd/schedulerd_messages.c CRM_ASSERT(pcmk__ipc_send_xml(sender, 0, reply, reply 161 daemons/schedulerd/schedulerd_messages.c free_xml(reply); reply 172 include/crm/common/ipc.h int32_t ms_timeout, xmlNode ** reply); reply 210 lib/cib/cib_native.c xmlNode *reply = NULL; reply 218 lib/cib/cib_native.c if (crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply) > 0) { reply 219 lib/cib/cib_native.c const char *msg_type = crm_element_value(reply, F_CIB_OPERATION); reply 222 lib/cib/cib_native.c crm_log_xml_trace(reply, "reg-reply"); reply 230 lib/cib/cib_native.c native->token = crm_element_value_copy(reply, F_CIB_CLIENTID); reply 235 lib/cib/cib_native.c free_xml(reply); reply 619 lib/common/ipc_client.c xmlNode *reply = NULL; reply 636 lib/common/ipc_client.c rc = crm_ipc_send(api->ipc, request, flags, 0, &reply); reply 645 lib/common/ipc_client.c if (reply != NULL) { reply 646 lib/common/ipc_client.c bool more = call_api_dispatch(api, reply); reply 648 lib/common/ipc_client.c free_xml(reply); reply 1210 lib/common/ipc_client.c xmlNode ** reply) reply 1333 lib/common/ipc_client.c if (reply) { reply 1334 lib/common/ipc_client.c *reply = string2xml(crm_ipc_buffer(client)); reply 161 lib/common/ipc_controld.c dispatch(pcmk_ipc_api_t *api, xmlNode *reply) reply 185 lib/common/ipc_controld.c if (pcmk__str_eq(crm_element_name(reply), "ack", pcmk__str_none)) { reply 200 lib/common/ipc_controld.c value = crm_element_value(reply, F_CRM_MSG_TYPE); reply 209 lib/common/ipc_controld.c if (crm_element_value(reply, XML_ATTR_REFERENCE) == NULL) { reply 215 lib/common/ipc_controld.c value = crm_element_value(reply, F_CRM_TASK); reply 224 lib/common/ipc_controld.c reply_data.feature_set = crm_element_value(reply, XML_ATTR_VERSION); reply 225 lib/common/ipc_controld.c reply_data.host_from = crm_element_value(reply, F_CRM_HOST_FROM); reply 226 lib/common/ipc_controld.c msg_data = get_message_xml(reply, F_CRM_DATA); reply 137 lib/common/ipc_pacemakerd.c dispatch(pcmk_ipc_api_t *api, xmlNode *reply) reply 147 lib/common/ipc_pacemakerd.c if (pcmk__str_eq((const char *) reply->name, "ack", pcmk__str_casei)) { reply 149 lib/common/ipc_pacemakerd.c pcmk__scan_ll(crm_element_value(reply, "status"), &ack_status, CRM_EX_OK); reply 153 lib/common/ipc_pacemakerd.c value = crm_element_value(reply, F_CRM_MSG_TYPE); reply 161 lib/common/ipc_pacemakerd.c if (crm_element_value(reply, XML_ATTR_REFERENCE) == NULL) { reply 167 lib/common/ipc_pacemakerd.c value = crm_element_value(reply, F_CRM_TASK); reply 170 lib/common/ipc_pacemakerd.c msg_data = get_message_xml(reply, F_CRM_DATA); reply 78 lib/common/ipc_schedulerd.c dispatch(pcmk_ipc_api_t *api, xmlNode *reply) reply 87 lib/common/ipc_schedulerd.c if (pcmk__str_eq((const char *) reply->name, "ack", pcmk__str_casei)) { reply 91 lib/common/ipc_schedulerd.c value = crm_element_value(reply, F_CRM_MSG_TYPE); reply 99 lib/common/ipc_schedulerd.c if (crm_element_value(reply, XML_ATTR_REFERENCE) == NULL) { reply 106 lib/common/ipc_schedulerd.c msg_data = get_message_xml(reply, F_CRM_DATA); reply 107 lib/common/ipc_schedulerd.c value = crm_element_value(reply, F_CRM_TASK); reply 111 lib/common/ipc_schedulerd.c reply_data.data.graph.reference = crm_element_value(reply, XML_ATTR_REFERENCE); reply 112 lib/common/ipc_schedulerd.c reply_data.data.graph.input = crm_element_value(reply, F_CRM_TGRAPH_INPUT); reply 105 lib/common/messages.c xmlNode *reply = NULL; reply 124 lib/common/messages.c reply = create_xml_node(NULL, __func__); reply 125 lib/common/messages.c if (reply == NULL) { reply 130 lib/common/messages.c crm_xml_add(reply, F_CRM_ORIGIN, origin); reply 131 lib/common/messages.c crm_xml_add(reply, F_TYPE, T_CRM); reply 132 lib/common/messages.c crm_xml_add(reply, F_CRM_VERSION, CRM_FEATURE_SET); reply 133 lib/common/messages.c crm_xml_add(reply, F_CRM_MSG_TYPE, XML_ATTR_RESPONSE); reply 134 lib/common/messages.c crm_xml_add(reply, F_CRM_REFERENCE, crm_msg_reference); reply 135 lib/common/messages.c crm_xml_add(reply, F_CRM_TASK, operation); reply 138 lib/common/messages.c crm_xml_add(reply, F_CRM_SYS_TO, sys_from); reply 139 lib/common/messages.c crm_xml_add(reply, F_CRM_SYS_FROM, sys_to); reply 143 lib/common/messages.c crm_xml_add(reply, F_CRM_HOST_TO, host_from); reply 147 lib/common/messages.c add_message_xml(reply, F_CRM_DATA, xml_response_data); reply 150 lib/common/messages.c return reply; reply 700 lib/fencing/st_client.c xmlNode *reply = get_xpath_object("//" F_STONITH_HISTORY_LIST, output, reply 703 lib/fencing/st_client.c for (op = pcmk__xml_first_child(reply); op != NULL; reply 1109 lib/fencing/st_client.c xmlNode *reply = NULL; reply 1115 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply); reply 1122 lib/fencing/st_client.c } else if (reply == NULL) { reply 1127 lib/fencing/st_client.c const char *msg_type = crm_element_value(reply, F_STONITH_OPERATION); reply 1129 lib/fencing/st_client.c native->token = crm_element_value_copy(reply, F_STONITH_CLIENTID); reply 1133 lib/fencing/st_client.c crm_log_xml_debug(reply, "Invalid fencer reply"); reply 1138 lib/fencing/st_client.c crm_log_xml_debug(reply, "Invalid fencer reply"); reply 1148 lib/fencing/st_client.c free_xml(reply); reply 620 lib/lrmd/lrmd_client.c xmlNode **reply) reply 635 lib/lrmd/lrmd_client.c for (*reply = NULL; *reply == NULL; ) { reply 637 lib/lrmd/lrmd_client.c *reply = pcmk__remote_message_xml(native->remote); reply 638 lib/lrmd/lrmd_client.c if (*reply == NULL) { reply 654 lib/lrmd/lrmd_client.c *reply = pcmk__remote_message_xml(native->remote); reply 655 lib/lrmd/lrmd_client.c if (*reply == NULL) { reply 660 lib/lrmd/lrmd_client.c crm_element_value_int(*reply, F_LRMD_REMOTE_MSG_ID, &reply_id); reply 661 lib/lrmd/lrmd_client.c msg_type = crm_element_value(*reply, F_LRMD_REMOTE_MSG_TYPE); reply 665 lib/lrmd/lrmd_client.c free_xml(*reply); reply 666 lib/lrmd/lrmd_client.c *reply = NULL; reply 670 lib/lrmd/lrmd_client.c native->pending_notify = g_list_append(native->pending_notify, *reply); reply 675 lib/lrmd/lrmd_client.c *reply = NULL; reply 679 lib/lrmd/lrmd_client.c free_xml(*reply); reply 680 lib/lrmd/lrmd_client.c *reply = NULL; reply 687 lib/lrmd/lrmd_client.c free_xml(*reply); reply 688 lib/lrmd/lrmd_client.c *reply = NULL; reply 722 lib/lrmd/lrmd_client.c lrmd_tls_send_recv(lrmd_t * lrmd, xmlNode * msg, int timeout, xmlNode ** reply) reply 744 lib/lrmd/lrmd_client.c if (reply) { reply 745 lib/lrmd/lrmd_client.c *reply = xml; reply 755 lib/lrmd/lrmd_client.c lrmd_send_xml(lrmd_t * lrmd, xmlNode * msg, int timeout, xmlNode ** reply) reply 762 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply); reply 766 lib/lrmd/lrmd_client.c rc = lrmd_tls_send_recv(lrmd, msg, timeout, reply); reply 958 lib/lrmd/lrmd_client.c xmlNode *reply = NULL; reply 971 lib/lrmd/lrmd_client.c rc = lrmd_send_xml(lrmd, hello, -1, &reply); reply 976 lib/lrmd/lrmd_client.c } else if (reply == NULL) { reply 980 lib/lrmd/lrmd_client.c const char *version = crm_element_value(reply, F_LRMD_PROTOCOL_VERSION); reply 981 lib/lrmd/lrmd_client.c const char *msg_type = crm_element_value(reply, F_LRMD_OPERATION); reply 982 lib/lrmd/lrmd_client.c const char *tmp_ticket = crm_element_value(reply, F_LRMD_CLIENTID); reply 984 lib/lrmd/lrmd_client.c crm_element_value_int(reply, F_LRMD_RC, &rc); reply 989 lib/lrmd/lrmd_client.c crm_log_xml_err(reply, "Protocol Error"); reply 993 lib/lrmd/lrmd_client.c crm_log_xml_err(reply, "Bad reply"); reply 997 lib/lrmd/lrmd_client.c crm_log_xml_err(reply, "Bad reply"); reply 1007 lib/lrmd/lrmd_client.c free_xml(reply); reply 93 lib/pacemaker/pcmk_cluster_queries.c pcmk_controld_api_reply_t *reply = event_data; reply 123 lib/pacemaker/pcmk_cluster_queries.c if (reply->reply_type != pcmk_controld_reply_ping) { reply 125 lib/pacemaker/pcmk_cluster_queries.c reply->reply_type); reply 131 lib/pacemaker/pcmk_cluster_queries.c return reply; reply 141 lib/pacemaker/pcmk_cluster_queries.c pcmk_controld_api_reply_t *reply = controld_event_reply(data, controld_api, reply 144 lib/pacemaker/pcmk_cluster_queries.c if (reply != NULL) { reply 146 lib/pacemaker/pcmk_cluster_queries.c reply->data.ping.sys_from, reply 147 lib/pacemaker/pcmk_cluster_queries.c reply->host_from, reply 148 lib/pacemaker/pcmk_cluster_queries.c reply->data.ping.fsa_state, reply 149 lib/pacemaker/pcmk_cluster_queries.c reply->data.ping.result); reply 163 lib/pacemaker/pcmk_cluster_queries.c pcmk_controld_api_reply_t *reply = controld_event_reply(data, controld_api, reply 166 lib/pacemaker/pcmk_cluster_queries.c if (reply != NULL) { reply 167 lib/pacemaker/pcmk_cluster_queries.c out->message(out, "dc", reply->host_from); reply 181 lib/pacemaker/pcmk_cluster_queries.c pcmk_pacemakerd_api_reply_t *reply = event_data; reply 213 lib/pacemaker/pcmk_cluster_queries.c if (reply->reply_type != pcmk_pacemakerd_reply_ping) { reply 215 lib/pacemaker/pcmk_cluster_queries.c reply->reply_type); reply 222 lib/pacemaker/pcmk_cluster_queries.c crm_time_set_timet(crm_when, &reply->data.ping.last_good); reply 228 lib/pacemaker/pcmk_cluster_queries.c reply->data.ping.sys_from, reply 229 lib/pacemaker/pcmk_cluster_queries.c (reply->data.ping.status == pcmk_rc_ok)? reply 231 lib/pacemaker/pcmk_cluster_queries.c reply->data.ping.state):"query failed", reply 232 lib/pacemaker/pcmk_cluster_queries.c (reply->data.ping.status == pcmk_rc_ok)?pinged_buf:""); reply 78 lib/pacemaker/pcmk_status.c pcmk_pacemakerd_api_reply_t *reply = event_data; reply 89 lib/pacemaker/pcmk_status.c if (reply->reply_type == pcmk_pacemakerd_reply_ping && reply 90 lib/pacemaker/pcmk_status.c reply->data.ping.last_good != (time_t) 0 && reply 91 lib/pacemaker/pcmk_status.c reply->data.ping.status == pcmk_rc_ok) { reply 92 lib/pacemaker/pcmk_status.c *state = reply->data.ping.state; reply 330 lib/services/dbus.c pcmk_dbus_find_error(DBusPendingCall *pending, DBusMessage *reply, reply 340 lib/services/dbus.c } else if (reply == NULL) { reply 345 lib/services/dbus.c int dtype = dbus_message_get_type(reply); reply 352 lib/services/dbus.c dbus_message_iter_init(reply, &args); reply 373 lib/services/dbus.c dbus_set_error_from_message(&error, reply); reply 416 lib/services/dbus.c DBusMessage *reply = NULL; reply 448 lib/services/dbus.c reply = dbus_pending_call_steal_reply(pending); reply 451 lib/services/dbus.c (void) pcmk_dbus_find_error(pending, reply, error); reply 458 lib/services/dbus.c return reply; reply 589 lib/services/dbus.c handle_query_result(DBusMessage *reply, struct property_query *data) reply 598 lib/services/dbus.c if (pcmk_dbus_find_error((void*)&error, reply, &error)) { reply 606 lib/services/dbus.c dbus_message_iter_init(reply, &args); reply 607 lib/services/dbus.c if (!pcmk_dbus_type_check(reply, &args, DBUS_TYPE_VARIANT, reply 616 lib/services/dbus.c if (!pcmk_dbus_type_check(reply, &variant_iter, DBUS_TYPE_STRING, reply 657 lib/services/dbus.c DBusMessage *reply = NULL; reply 661 lib/services/dbus.c reply = dbus_pending_call_steal_reply(pending); reply 664 lib/services/dbus.c value = handle_query_result(reply, user_data); reply 667 lib/services/dbus.c if (reply) { reply 668 lib/services/dbus.c dbus_message_unref(reply); reply 763 lib/services/dbus.c DBusMessage *reply = pcmk_dbus_send_recv(msg, connection, NULL, reply 766 lib/services/dbus.c output = handle_query_result(reply, query_data); reply 768 lib/services/dbus.c if (reply) { reply 769 lib/services/dbus.c dbus_message_unref(reply); reply 42 lib/services/pcmk-dbus.h bool pcmk_dbus_find_error(DBusPendingCall *pending, DBusMessage *reply, reply 106 lib/services/systemd.c DBusMessage *reply = NULL; reply 118 lib/services/systemd.c reply = systemd_send_recv(msg, &error, DBUS_TIMEOUT_USE_DEFAULT); reply 127 lib/services/systemd.c } else if (reply == NULL) { reply 132 lib/services/systemd.c return reply; reply 254 lib/services/systemd.c DBusMessage *reply = NULL; reply 259 lib/services/systemd.c reply = dbus_pending_call_steal_reply(pending); reply 262 lib/services/systemd.c if (pcmk_dbus_find_error(pending, reply, &error)) { reply 274 lib/services/systemd.c if(reply) { reply 275 lib/services/systemd.c dbus_message_unref(reply); reply 339 lib/services/systemd.c execute_after_loadunit(DBusMessage *reply, svc_action_t *op) reply 347 lib/services/systemd.c if (pcmk_dbus_find_error((void *) &path, reply, &error)) { reply 353 lib/services/systemd.c } else if (!pcmk_dbus_type_check(reply, NULL, DBUS_TYPE_OBJECT_PATH, reply 366 lib/services/systemd.c dbus_message_get_args (reply, NULL, reply 396 lib/services/systemd.c DBusMessage *reply = NULL; reply 403 lib/services/systemd.c reply = dbus_pending_call_steal_reply(pending); reply 411 lib/services/systemd.c execute_after_loadunit(reply, user_data); reply 412 lib/services/systemd.c if (reply != NULL) { reply 413 lib/services/systemd.c dbus_message_unref(reply); reply 436 lib/services/systemd.c DBusMessage *reply = NULL; reply 470 lib/services/systemd.c reply = systemd_send_recv(msg, NULL, reply 474 lib/services/systemd.c unit = execute_after_loadunit(reply, op); reply 487 lib/services/systemd.c if (reply != NULL) { reply 488 lib/services/systemd.c dbus_message_unref(reply); reply 542 lib/services/systemd.c DBusMessage *reply = NULL; reply 554 lib/services/systemd.c reply = systemd_call_simple_method("ListUnitFiles"); reply 555 lib/services/systemd.c if (reply == NULL) { reply 558 lib/services/systemd.c if (!dbus_message_iter_init(reply, &args)) { reply 560 lib/services/systemd.c dbus_message_unref(reply); reply 563 lib/services/systemd.c if (!pcmk_dbus_type_check(reply, &args, DBUS_TYPE_ARRAY, reply 566 lib/services/systemd.c dbus_message_unref(reply); reply 579 lib/services/systemd.c if(!pcmk_dbus_type_check(reply, &unit, DBUS_TYPE_STRUCT, __func__, __LINE__)) { reply 585 lib/services/systemd.c if(!pcmk_dbus_type_check(reply, &elem, DBUS_TYPE_STRING, __func__, __LINE__)) { reply 624 lib/services/systemd.c dbus_message_unref(reply); reply 714 lib/services/systemd.c process_unit_method_reply(DBusMessage *reply, svc_action_t *op) reply 721 lib/services/systemd.c if (pcmk_dbus_find_error((void *) &error, reply, &error)) { reply 725 lib/services/systemd.c } else if (!pcmk_dbus_type_check(reply, NULL, DBUS_TYPE_OBJECT_PATH, reply 735 lib/services/systemd.c dbus_message_get_args(reply, NULL, reply 754 lib/services/systemd.c DBusMessage *reply = NULL; reply 761 lib/services/systemd.c reply = dbus_pending_call_steal_reply(pending); reply 769 lib/services/systemd.c process_unit_method_reply(reply, op); reply 771 lib/services/systemd.c if (reply != NULL) { reply 772 lib/services/systemd.c dbus_message_unref(reply); reply 929 lib/services/systemd.c DBusMessage *reply = NULL; reply 994 lib/services/systemd.c reply = systemd_send_recv(msg, NULL, op->timeout); reply 996 lib/services/systemd.c process_unit_method_reply(reply, op); reply 997 lib/services/systemd.c if (reply != NULL) { reply 998 lib/services/systemd.c dbus_message_unref(reply); reply 116 lib/services/upstart.c DBusMessage *reply = NULL; reply 134 lib/services/upstart.c reply = pcmk_dbus_send_recv(msg, upstart_proxy, &error, timeout); reply 142 lib/services/upstart.c } else if (!pcmk_dbus_type_check(reply, NULL, DBUS_TYPE_OBJECT_PATH, reply 149 lib/services/upstart.c dbus_message_get_args(reply, NULL, DBUS_TYPE_OBJECT_PATH, path, reply 158 lib/services/upstart.c if (reply != NULL) { reply 159 lib/services/upstart.c dbus_message_unref(reply); reply 207 lib/services/upstart.c DBusMessage *reply = NULL; reply 227 lib/services/upstart.c reply = pcmk_dbus_send_recv(msg, upstart_proxy, &error, DBUS_TIMEOUT_USE_DEFAULT); reply 235 lib/services/upstart.c } else if (!dbus_message_iter_init(reply, &args)) { reply 237 lib/services/upstart.c dbus_message_unref(reply); reply 241 lib/services/upstart.c if(!pcmk_dbus_type_check(reply, &args, DBUS_TYPE_ARRAY, __func__, __LINE__)) { reply 243 lib/services/upstart.c dbus_message_unref(reply); reply 253 lib/services/upstart.c if(!pcmk_dbus_type_check(reply, &unit, DBUS_TYPE_OBJECT_PATH, __func__, __LINE__)) { reply 277 lib/services/upstart.c dbus_message_unref(reply); reply 295 lib/services/upstart.c DBusMessage *reply; reply 307 lib/services/upstart.c reply = pcmk_dbus_send_recv(msg, upstart_proxy, &error, timeout); reply 315 lib/services/upstart.c } else if(reply == NULL) { reply 319 lib/services/upstart.c } else if (!dbus_message_iter_init(reply, &args)) { reply 324 lib/services/upstart.c if(!pcmk_dbus_type_check(reply, &args, DBUS_TYPE_ARRAY, __func__, __LINE__)) { reply 330 lib/services/upstart.c if(pcmk_dbus_type_check(reply, &unit, DBUS_TYPE_OBJECT_PATH, __func__, __LINE__)) { reply 342 lib/services/upstart.c if(reply) { reply 343 lib/services/upstart.c dbus_message_unref(reply); reply 450 lib/services/upstart.c DBusMessage *reply = NULL; reply 455 lib/services/upstart.c reply = dbus_pending_call_steal_reply(pending); reply 460 lib/services/upstart.c if (pcmk_dbus_find_error(pending, reply, &error)) { reply 469 lib/services/upstart.c } else if (!pcmk_dbus_type_check(reply, NULL, DBUS_TYPE_OBJECT_PATH, reply 478 lib/services/upstart.c dbus_message_get_args(reply, NULL, DBUS_TYPE_OBJECT_PATH, &path, reply 491 lib/services/upstart.c if (reply != NULL) { reply 492 lib/services/upstart.c dbus_message_unref(reply); reply 522 lib/services/upstart.c DBusMessage *reply = NULL; reply 658 lib/services/upstart.c reply = pcmk_dbus_send_recv(msg, upstart_proxy, &error, op->timeout); reply 668 lib/services/upstart.c } else if (!pcmk_dbus_type_check(reply, NULL, DBUS_TYPE_OBJECT_PATH, reply 677 lib/services/upstart.c dbus_message_get_args(reply, NULL, DBUS_TYPE_OBJECT_PATH, &path, reply 688 lib/services/upstart.c if (reply != NULL) { reply 689 lib/services/upstart.c dbus_message_unref(reply); reply 292 tools/attrd_updater.c send_attrd_query(const char *name, const char *host, xmlNode **reply) reply 316 tools/attrd_updater.c rc = crm_ipc_send(ipc, query, crm_ipc_client_response, 0, reply); reply 338 tools/attrd_updater.c validate_attrd_reply(xmlNode *reply, const char *attr_name) reply 343 tools/attrd_updater.c if (reply == NULL) { reply 350 tools/attrd_updater.c crm_log_xml_trace(reply, "Reply"); reply 352 tools/attrd_updater.c reply_attr = crm_element_value(reply, PCMK__XA_ATTR_NAME); reply 361 tools/attrd_updater.c if (!pcmk__str_eq(crm_element_value(reply, F_TYPE), T_ATTRD, pcmk__str_casei) reply 362 tools/attrd_updater.c || (crm_element_value(reply, PCMK__XA_ATTR_VERSION) == NULL) reply 383 tools/attrd_updater.c print_attrd_values(pcmk__output_t *out, xmlNode *reply, const char *attr_name) reply 390 tools/attrd_updater.c for (child = pcmk__xml_first_child(reply); child != NULL; reply 425 tools/attrd_updater.c xmlNode *reply = NULL; reply 439 tools/attrd_updater.c rc = send_attrd_query(attr_name, attr_node, &reply); reply 447 tools/attrd_updater.c rc = validate_attrd_reply(reply, attr_name); reply 449 tools/attrd_updater.c if (reply != NULL) { reply 450 tools/attrd_updater.c free_xml(reply); reply 456 tools/attrd_updater.c if (!print_attrd_values(out, reply, attr_name)) { reply 460 tools/attrd_updater.c free_xml(reply); reply 295 tools/crm_attribute.c pcmk_controld_api_reply_t *reply = event_data; reply 308 tools/crm_attribute.c if (reply->reply_type != pcmk_controld_reply_info) { reply 311 tools/crm_attribute.c "Unknown reply type %d from controller", reply->reply_type); reply 315 tools/crm_attribute.c if (reply->data.node_info.uname == NULL) { reply 322 tools/crm_attribute.c pcmk__str_update(&options.dest_uname, reply->data.node_info.uname); reply 878 tools/crm_mon.c pcmk_pacemakerd_api_reply_t *reply = event_data; reply 899 tools/crm_mon.c if (reply->reply_type != pcmk_pacemakerd_reply_ping) { reply 901 tools/crm_mon.c reply->reply_type); reply 903 tools/crm_mon.c if ((reply->data.ping.last_good != (time_t) 0) && reply 904 tools/crm_mon.c (reply->data.ping.status == pcmk_rc_ok)) { reply 905 tools/crm_mon.c *state = reply->data.ping.state; reply 150 tools/crm_node.c pcmk_controld_api_reply_t *reply = event_data; reply 176 tools/crm_node.c if (reply->reply_type != pcmk_controld_reply_info) { reply 179 tools/crm_node.c reply->reply_type); reply 182 tools/crm_node.c if (reply->data.node_info.id == 0) { reply 188 tools/crm_node.c printf("%d\n", reply->data.node_info.id); reply 193 tools/crm_node.c if (reply->reply_type != pcmk_controld_reply_info) { reply 196 tools/crm_node.c reply->reply_type); reply 199 tools/crm_node.c if (reply->data.node_info.uname == NULL) { reply 204 tools/crm_node.c printf("%s\n", reply->data.node_info.uname); reply 208 tools/crm_node.c if (reply->reply_type != pcmk_controld_reply_info) { reply 211 tools/crm_node.c reply->reply_type); reply 214 tools/crm_node.c printf("%d\n", reply->data.node_info.have_quorum); reply 215 tools/crm_node.c if (!(reply->data.node_info.have_quorum)) { reply 223 tools/crm_node.c if (reply->reply_type != pcmk_controld_reply_nodes) { reply 226 tools/crm_node.c reply->reply_type); reply 229 tools/crm_node.c reply->data.nodes = g_list_sort(reply->data.nodes, sort_node); reply 230 tools/crm_node.c for (GList *node_iter = reply->data.nodes;