reply 78 daemons/attrd/attrd_corosync.c xmlNode *reply = NULL; reply 85 daemons/attrd/attrd_corosync.c reply = attrd_confirmation(callid); reply 93 daemons/attrd/attrd_corosync.c attrd_send_message(peer, reply, false); reply 94 daemons/attrd/attrd_corosync.c pcmk__xml_free(reply); reply 44 daemons/attrd/attrd_ipc.c xmlNode *reply = pcmk__xe_create(NULL, __func__); reply 47 daemons/attrd/attrd_ipc.c crm_xml_add(reply, PCMK__XA_T, PCMK__VALUE_ATTRD); reply 48 daemons/attrd/attrd_ipc.c crm_xml_add(reply, PCMK__XA_SUBT, PCMK__ATTRD_CMD_QUERY); reply 49 daemons/attrd/attrd_ipc.c crm_xml_add(reply, PCMK__XA_ATTR_VERSION, ATTRD_PROTOCOL_VERSION); reply 57 daemons/attrd/attrd_ipc.c crm_xml_add(reply, PCMK__XA_ATTR_NAME, attr); reply 68 daemons/attrd/attrd_ipc.c host_value = pcmk__xe_create(reply, PCMK_XE_NODE); reply 79 daemons/attrd/attrd_ipc.c host_value = pcmk__xe_create(reply, PCMK_XE_NODE); reply 85 daemons/attrd/attrd_ipc.c return reply; reply 191 daemons/attrd/attrd_ipc.c xmlNode *reply = NULL; reply 206 daemons/attrd/attrd_ipc.c reply = build_query_reply(attr, reply 208 daemons/attrd/attrd_ipc.c if (reply == NULL) { reply 218 daemons/attrd/attrd_ipc.c return reply; reply 261 daemons/attrd/attrd_messages.c xmlNode *reply = NULL; reply 269 daemons/attrd/attrd_messages.c reply = pcmk__process_request(request, attrd_handlers); reply 271 daemons/attrd/attrd_messages.c if (reply != NULL) { reply 272 daemons/attrd/attrd_messages.c crm_log_xml_trace(reply, "Reply"); reply 275 daemons/attrd/attrd_messages.c pcmk__ipc_send_xml(request->ipc_client, request->ipc_id, reply, reply 281 daemons/attrd/attrd_messages.c pcmk__xml_free(reply); reply 44 daemons/based/based_callbacks.c cib__op_fn_t op_function, xmlNode **reply, reply 143 daemons/based/based_callbacks.c xmlNode *reply = pcmk__xe_create(NULL, PCMK__XE_CIB_REPLY); reply 145 daemons/based/based_callbacks.c crm_xml_add(reply, PCMK__XA_T, PCMK__VALUE_CIB); reply 146 daemons/based/based_callbacks.c crm_xml_add(reply, PCMK__XA_CIB_OP, op); reply 147 daemons/based/based_callbacks.c crm_xml_add(reply, PCMK__XA_CIB_CALLID, call_id); reply 148 daemons/based/based_callbacks.c crm_xml_add(reply, PCMK__XA_CIB_CLIENTID, client_id); reply 149 daemons/based/based_callbacks.c crm_xml_add_int(reply, PCMK__XA_CIB_CALLOPT, call_options); reply 150 daemons/based/based_callbacks.c crm_xml_add_int(reply, PCMK__XA_CIB_RC, rc); reply 153 daemons/based/based_callbacks.c xmlNode *wrapper = pcmk__xe_create(reply, PCMK__XE_CIB_CALLDATA); reply 159 daemons/based/based_callbacks.c crm_log_xml_explicit(reply, "cib:reply"); reply 160 daemons/based/based_callbacks.c return reply; reply 433 daemons/based/based_callbacks.c process_ping_reply(xmlNode *reply) reply 436 daemons/based/based_callbacks.c const char *host = crm_element_value(reply, PCMK__XA_SRC); reply 438 daemons/based/based_callbacks.c xmlNode *wrapper = pcmk__xe_first_child(reply, PCMK__XE_CIB_CALLDATA, NULL, reply 512 daemons/based/based_callbacks.c sync_our_cib(reply, FALSE); reply 1067 daemons/based/based_callbacks.c cib__op_fn_t op_function, xmlNode **reply, reply 1097 daemons/based/based_callbacks.c *reply = NULL; reply 1235 daemons/based/based_callbacks.c *reply = create_cib_reply(op, call_id, client_id, call_options, rc, reply 1227 daemons/controld/controld_execd.c xmlNode *reply = pcmk__new_reply(msg, NULL); reply 1231 daemons/controld/controld_execd.c if (relay_message(reply, TRUE) == FALSE) { reply 1232 daemons/controld/controld_execd.c crm_log_xml_err(reply, "Unable to route reply"); reply 1234 daemons/controld/controld_execd.c pcmk__xml_free(reply); reply 1718 daemons/controld/controld_execd.c xmlNode *reply = NULL; reply 1752 daemons/controld/controld_execd.c reply = pcmk__new_message(pcmk_ipc_controld, "direct-ack", CRM_SYSTEM_LRMD, reply 1759 daemons/controld/controld_execd.c crm_element_value(reply, PCMK_XA_REFERENCE)); reply 1761 daemons/controld/controld_execd.c if (relay_message(reply, TRUE) == FALSE) { reply 1762 daemons/controld/controld_execd.c crm_log_xml_err(reply, "Unable to route reply"); reply 1766 daemons/controld/controld_execd.c pcmk__xml_free(reply); reply 447 daemons/controld/controld_messages.c xmlNode *reply = create_ping_reply(msg); reply 448 daemons/controld/controld_messages.c sys_to = crm_element_value(reply, PCMK__XA_CRM_SYS_TO); reply 450 daemons/controld/controld_messages.c send_msg_via_ipc(reply, sys_to, NULL); reply 451 daemons/controld/controld_messages.c pcmk__xml_free(reply); reply 831 daemons/controld/controld_messages.c xmlNode *reply = NULL; reply 848 daemons/controld/controld_messages.c reply = pcmk__new_reply(msg, ping); reply 850 daemons/controld/controld_messages.c return reply; reply 856 daemons/controld/controld_messages.c xmlNode *reply = create_ping_reply(msg); reply 857 daemons/controld/controld_messages.c if (reply != NULL) { reply 858 daemons/controld/controld_messages.c (void) relay_message(reply, TRUE); reply 859 daemons/controld/controld_messages.c pcmk__xml_free(reply); reply 878 daemons/controld/controld_messages.c xmlNode *reply = NULL; reply 894 daemons/controld/controld_messages.c reply = pcmk__new_reply(request, reply_data); reply 896 daemons/controld/controld_messages.c if (reply) { reply 897 daemons/controld/controld_messages.c (void) relay_message(reply, TRUE); reply 898 daemons/controld/controld_messages.c pcmk__xml_free(reply); reply 918 daemons/controld/controld_messages.c xmlNode *reply = NULL; reply 959 daemons/controld/controld_messages.c reply = pcmk__new_reply(msg, reply_data); reply 961 daemons/controld/controld_messages.c if (reply != NULL) { reply 962 daemons/controld/controld_messages.c (void) relay_message(reply, TRUE); reply 963 daemons/controld/controld_messages.c pcmk__xml_free(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 150 daemons/controld/controld_schedulerd.c reply->data.graph.input); reply 153 daemons/controld/controld_schedulerd.c pcmk__xml_copy(crm_data_node, reply->data.graph.tgraph); reply 167 daemons/controld/controld_schedulerd.c pcmk_schedulerd_api_reply_t *reply = event_data; reply 175 daemons/controld/controld_schedulerd.c handle_reply(reply); reply 553 daemons/execd/execd_commands.c xmlNode *reply = pcmk__xe_create(NULL, PCMK__XE_LRMD_REPLY); reply 555 daemons/execd/execd_commands.c crm_xml_add(reply, PCMK__XA_LRMD_ORIGIN, origin); reply 556 daemons/execd/execd_commands.c crm_xml_add_int(reply, PCMK__XA_LRMD_RC, rc); reply 557 daemons/execd/execd_commands.c crm_xml_add_int(reply, PCMK__XA_LRMD_CALLID, call_id); reply 558 daemons/execd/execd_commands.c return reply; reply 1517 daemons/execd/execd_commands.c xmlNode **reply) reply 1565 daemons/execd/execd_commands.c *reply = create_lrmd_reply(__func__, rc, call_id); reply 1566 daemons/execd/execd_commands.c crm_xml_add(*reply, PCMK__XA_LRMD_OP, CRM_OP_REGISTER); reply 1567 daemons/execd/execd_commands.c crm_xml_add(*reply, PCMK__XA_LRMD_CLIENTID, client->id); reply 1568 daemons/execd/execd_commands.c crm_xml_add(*reply, PCMK__XA_LRMD_PROTOCOL_VERSION, LRMD_PROTOCOL_VERSION); reply 1569 daemons/execd/execd_commands.c crm_xml_add_ll(*reply, PCMK__XA_UPTIME, now - start_time); reply 1572 daemons/execd/execd_commands.c crm_xml_add(*reply, PCMK__XA_NODE_START_STATE, start_state); reply 1607 daemons/execd/execd_commands.c xmlNode *reply = NULL; reply 1620 daemons/execd/execd_commands.c reply = create_lrmd_reply(__func__, rc, call_id); reply 1622 daemons/execd/execd_commands.c crm_xml_add(reply, PCMK__XA_LRMD_RSC_ID, rsc->rsc_id); reply 1623 daemons/execd/execd_commands.c crm_xml_add(reply, PCMK__XA_LRMD_CLASS, rsc->class); reply 1624 daemons/execd/execd_commands.c crm_xml_add(reply, PCMK__XA_LRMD_PROVIDER, rsc->provider); reply 1625 daemons/execd/execd_commands.c crm_xml_add(reply, PCMK__XA_LRMD_TYPE, rsc->type); reply 1627 daemons/execd/execd_commands.c return reply; reply 1811 daemons/execd/execd_commands.c add_recurring_op_xml(xmlNode *reply, lrmd_rsc_t *rsc) reply 1813 daemons/execd/execd_commands.c xmlNode *rsc_xml = pcmk__xe_create(reply, PCMK__XE_LRMD_RSC); reply 1833 daemons/execd/execd_commands.c xmlNode *reply = NULL; reply 1855 daemons/execd/execd_commands.c reply = create_lrmd_reply(__func__, rc, call_id); reply 1865 daemons/execd/execd_commands.c add_recurring_op_xml(reply, rsc); reply 1868 daemons/execd/execd_commands.c add_recurring_op_xml(reply, rsc); reply 1870 daemons/execd/execd_commands.c return reply; reply 1881 daemons/execd/execd_commands.c xmlNode *reply = NULL; reply 1904 daemons/execd/execd_commands.c rc = process_lrmd_signon(client, request, call_id, &reply); reply 1916 daemons/execd/execd_commands.c reply = process_lrmd_get_rsc_info(request, call_id); reply 1973 daemons/execd/execd_commands.c reply = process_lrmd_get_recurring(request, call_id); reply 1996 daemons/execd/execd_commands.c if (reply == NULL) { reply 1997 daemons/execd/execd_commands.c reply = create_lrmd_reply(__func__, rc, call_id); reply 1999 daemons/execd/execd_commands.c send_rc = lrmd_server_send_reply(client, id, reply); reply 2000 daemons/execd/execd_commands.c pcmk__xml_free(reply); reply 258 daemons/execd/pacemaker-execd.c lrmd_server_send_reply(pcmk__client_t *client, uint32_t id, xmlNode *reply) reply 263 daemons/execd/pacemaker-execd.c return pcmk__ipc_send_xml(client, id, reply, crm_ipc_flags_none); reply 266 daemons/execd/pacemaker-execd.c return lrmd__remote_send_xml(client->remote, reply, id, "reply"); reply 59 daemons/execd/pacemaker-execd.h int lrmd_server_send_reply(pcmk__client_t *client, uint32_t id, xmlNode *reply); reply 137 daemons/execd/remoted_schemas.c xmlNode *reply; reply 153 daemons/execd/remoted_schemas.c rc = cib->cmds->fetch_schemas(cib, &reply, pcmk__highest_schema_name(), reply 159 daemons/execd/remoted_schemas.c } else if (reply->children != NULL) { reply 188 daemons/execd/remoted_schemas.c pcmk__xpath_foreach_result(reply->doc, "//" PCMK__XE_FILE, reply 192 daemons/execd/remoted_schemas.c pcmk__xml_free(reply); reply 2244 daemons/fenced/fenced_commands.c xmlNode *reply; reply 2365 daemons/fenced/fenced_commands.c stonith_send_reply(const xmlNode *reply, int call_options, reply 2368 daemons/fenced/fenced_commands.c CRM_CHECK((reply != NULL) && ((remote_peer != NULL) || (client != NULL)), reply 2372 daemons/fenced/fenced_commands.c do_local_reply(reply, client, call_options); reply 2378 daemons/fenced/fenced_commands.c pcmk__cluster_send_message(node, pcmk_ipc_fenced, reply); reply 2402 daemons/fenced/fenced_commands.c wrapper = pcmk__xe_create(query->reply, PCMK__XE_ST_CALLDATA); reply 2484 daemons/fenced/fenced_commands.c stonith_send_reply(query->reply, query->call_options, query->remote_peer, reply 2488 daemons/fenced/fenced_commands.c pcmk__xml_free(query->reply); reply 2598 daemons/fenced/fenced_commands.c xmlNode *reply = NULL; reply 2613 daemons/fenced/fenced_commands.c reply = construct_async_reply(cmd, result); reply 2615 daemons/fenced/fenced_commands.c pcmk__xe_set_bool_attr(reply, PCMK__XA_ST_OP_MERGED, true); reply 2625 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_SUBT, PCMK__VALUE_BROADCAST); reply 2626 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_OP, STONITH_OP_NOTIFY); reply 2627 daemons/fenced/fenced_commands.c pcmk__cluster_send_message(NULL, pcmk_ipc_fenced, reply); reply 2630 daemons/fenced/fenced_commands.c stonith_send_reply(reply, cmd->options, cmd->origin, client); reply 2633 daemons/fenced/fenced_commands.c crm_log_xml_trace(reply, "Reply"); reply 2634 daemons/fenced/fenced_commands.c pcmk__xml_free(reply); reply 2909 daemons/fenced/fenced_commands.c xmlNode *reply = NULL; reply 2911 daemons/fenced/fenced_commands.c reply = pcmk__xe_create(NULL, PCMK__XE_ST_REPLY); reply 2913 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_ORIGIN, __func__); reply 2914 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_T, PCMK__VALUE_STONITH_NG); reply 2915 daemons/fenced/fenced_commands.c stonith__xe_set_result(reply, result); reply 2945 daemons/fenced/fenced_commands.c crm_xml_add(reply, name, value); reply 2948 daemons/fenced/fenced_commands.c xmlNode *wrapper = pcmk__xe_create(reply, PCMK__XE_ST_CALLDATA); reply 2953 daemons/fenced/fenced_commands.c return reply; reply 2967 daemons/fenced/fenced_commands.c xmlNode *reply = pcmk__xe_create(NULL, PCMK__XE_ST_REPLY); reply 2969 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_ORIGIN, __func__); reply 2970 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_T, PCMK__VALUE_STONITH_NG); reply 2971 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_OP, cmd->op); reply 2972 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_DEVICE_ID, cmd->device); reply 2973 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_REMOTE_OP, cmd->remote_op_id); reply 2974 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_CLIENTID, cmd->client); reply 2975 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_CLIENTNAME, cmd->client_name); reply 2976 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_TARGET, cmd->target); reply 2977 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_DEVICE_ACTION, cmd->op); reply 2978 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_ORIGIN, cmd->origin); reply 2979 daemons/fenced/fenced_commands.c crm_xml_add_int(reply, PCMK__XA_ST_CALLID, cmd->id); reply 2980 daemons/fenced/fenced_commands.c crm_xml_add_int(reply, PCMK__XA_ST_CALLOPT, cmd->options); reply 2982 daemons/fenced/fenced_commands.c stonith__xe_set_result(reply, result); reply 2983 daemons/fenced/fenced_commands.c return reply; reply 3120 daemons/fenced/fenced_commands.c xmlNode *reply = pcmk__xe_create(NULL, "reply"); reply 3123 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_OP, CRM_OP_REGISTER); reply 3124 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_CLIENTID, request->ipc_client->id); reply 3127 daemons/fenced/fenced_commands.c return reply; reply 3195 daemons/fenced/fenced_commands.c query->reply = fenced_construct_reply(request->xml, NULL, &request->result); reply 3368 daemons/fenced/fenced_commands.c xmlNode *reply = NULL; reply 3378 daemons/fenced/fenced_commands.c reply = fenced_construct_reply(request->xml, data, &request->result); reply 3381 daemons/fenced/fenced_commands.c return reply; reply 3525 daemons/fenced/fenced_commands.c xmlNode *reply = NULL; reply 3531 daemons/fenced/fenced_commands.c reply = pcmk__process_request(request, fenced_handlers); reply 3532 daemons/fenced/fenced_commands.c if (reply != NULL) { reply 3539 daemons/fenced/fenced_commands.c pcmk__ipc_send_xml(request->ipc_client, request->ipc_id, reply, reply 3543 daemons/fenced/fenced_commands.c stonith_send_reply(reply, request->call_options, reply 3546 daemons/fenced/fenced_commands.c pcmk__xml_free(reply); reply 453 daemons/fenced/fenced_remote.c xmlNode *reply = NULL; reply 466 daemons/fenced/fenced_remote.c reply = fenced_construct_reply(op->request, data, &op->result); reply 467 daemons/fenced/fenced_remote.c crm_xml_add(reply, PCMK__XA_ST_DELEGATE, op->delegate); reply 474 daemons/fenced/fenced_remote.c do_local_reply(reply, client, op->call_options); reply 486 daemons/fenced/fenced_remote.c pcmk__xml_free(reply); reply 236 daemons/pacemakerd/pacemakerd.c pcmk_pacemakerd_api_reply_t *reply = event_data; reply 251 daemons/pacemakerd/pacemakerd.c if (reply->reply_type != pcmk_pacemakerd_reply_shutdown) { reply 253 daemons/pacemakerd/pacemakerd.c reply->reply_type); reply 44 daemons/pacemakerd/pcmkd_messages.c xmlNode *reply = NULL; reply 63 daemons/pacemakerd/pcmkd_messages.c reply = pcmk__new_reply(msg, ping); reply 67 daemons/pacemakerd/pcmkd_messages.c if (reply == NULL) { reply 93 daemons/pacemakerd/pcmkd_messages.c return reply; reply 102 daemons/pacemakerd/pcmkd_messages.c xmlNode *reply = NULL; reply 126 daemons/pacemakerd/pcmkd_messages.c reply = pcmk__new_reply(msg, shutdown); reply 129 daemons/pacemakerd/pcmkd_messages.c if (reply == NULL) { reply 141 daemons/pacemakerd/pcmkd_messages.c return reply; reply 257 daemons/pacemakerd/pcmkd_messages.c xmlNode *reply = NULL; reply 272 daemons/pacemakerd/pcmkd_messages.c reply = pcmk__process_request(&request, pcmkd_handlers); reply 274 daemons/pacemakerd/pcmkd_messages.c if (reply != NULL) { reply 275 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_xml(c, id, reply, crm_ipc_server_event); reply 276 daemons/pacemakerd/pcmkd_messages.c pcmk__xml_free(reply); reply 66 daemons/schedulerd/schedulerd_messages.c xmlNode *reply = NULL; reply 130 daemons/schedulerd/schedulerd_messages.c reply = pcmk__new_reply(msg, scheduler->priv->graph); reply 132 daemons/schedulerd/schedulerd_messages.c if (reply == NULL) { reply 149 daemons/schedulerd/schedulerd_messages.c crm_xml_add(reply, PCMK__XA_CRM_TGRAPH_IN, filename); reply 174 daemons/schedulerd/schedulerd_messages.c return reply; reply 289 daemons/schedulerd/schedulerd_messages.c xmlNode *reply = NULL; reply 304 daemons/schedulerd/schedulerd_messages.c reply = pcmk__process_request(&request, schedulerd_handlers); reply 306 daemons/schedulerd/schedulerd_messages.c if (reply != NULL) { reply 307 daemons/schedulerd/schedulerd_messages.c pcmk__ipc_send_xml(c, id, reply, crm_ipc_server_event); reply 308 daemons/schedulerd/schedulerd_messages.c pcmk__xml_free(reply); reply 167 include/crm/common/ipc.h enum crm_ipc_flags flags, int32_t ms_timeout, xmlNode **reply); reply 287 include/crm/common/ipc_internal.h const char *pcmk__controld_api_reply2str(enum pcmk_controld_api_reply reply); reply 288 include/crm/common/ipc_internal.h const char *pcmk__pcmkd_api_reply2str(enum pcmk_pacemakerd_api_reply reply); reply 315 lib/cib/cib_native.c xmlNode *reply = NULL; reply 318 lib/cib/cib_native.c &reply) > 0) { reply 319 lib/cib/cib_native.c const char *msg_type = crm_element_value(reply, PCMK__XA_CIB_OP); reply 321 lib/cib/cib_native.c crm_log_xml_trace(reply, "reg-reply"); reply 330 lib/cib/cib_native.c native->token = crm_element_value_copy(reply, reply 336 lib/cib/cib_native.c pcmk__xml_free(reply); reply 60 lib/common/ipc_attrd.c dispatch(pcmk_ipc_api_t *api, xmlNode *reply) reply 69 lib/common/ipc_attrd.c if (pcmk__xe_is(reply, PCMK__XE_ACK)) { reply 74 lib/common/ipc_attrd.c value = crm_element_value(reply, PCMK__XA_T); reply 84 lib/common/ipc_attrd.c value = crm_element_value(reply, PCMK__XA_SUBT); reply 90 lib/common/ipc_attrd.c if (!xmlHasProp(reply, (const xmlChar *) PCMK__XA_ATTR_NAME)) { reply 95 lib/common/ipc_attrd.c set_pairs_data(&reply_data, reply); reply 687 lib/common/ipc_client.c xmlNode *reply = NULL; reply 708 lib/common/ipc_client.c rc = crm_ipc_send(api->ipc, request, flags, 0, &reply); reply 717 lib/common/ipc_client.c if (reply != NULL) { reply 718 lib/common/ipc_client.c bool more = call_api_dispatch(api, reply); reply 720 lib/common/ipc_client.c pcmk__xml_free(reply); reply 1196 lib/common/ipc_client.c ssize_t *bytes, xmlNode **reply) reply 1273 lib/common/ipc_client.c if (reply != NULL) { reply 1274 lib/common/ipc_client.c *reply = pcmk__xml_parse(crm_ipc_buffer(client)); reply 1353 lib/common/ipc_client.c enum crm_ipc_flags flags, int32_t ms_timeout, xmlNode **reply) reply 1482 lib/common/ipc_client.c rc = internal_ipc_get_reply(client, header->qb.id, ms_timeout, &bytes, reply); reply 45 lib/common/ipc_controld.c pcmk__controld_api_reply2str(enum pcmk_controld_api_reply reply) reply 47 lib/common/ipc_controld.c switch (reply) { reply 202 lib/common/ipc_controld.c dispatch(pcmk_ipc_api_t *api, xmlNode *reply) reply 213 lib/common/ipc_controld.c if (pcmk__xe_is(reply, PCMK__XE_ACK)) { reply 227 lib/common/ipc_controld.c value = crm_element_value(reply, PCMK__XA_SUBT); reply 244 lib/common/ipc_controld.c if (pcmk__str_empty(crm_element_value(reply, PCMK_XA_REFERENCE))) { reply 250 lib/common/ipc_controld.c value = crm_element_value(reply, PCMK__XA_CRM_TASK); reply 259 lib/common/ipc_controld.c reply_data.feature_set = crm_element_value(reply, PCMK_XA_VERSION); reply 260 lib/common/ipc_controld.c reply_data.host_from = crm_element_value(reply, PCMK__XA_SRC); reply 262 lib/common/ipc_controld.c wrapper = pcmk__xe_first_child(reply, PCMK__XE_CRM_XML, NULL, NULL); reply 110 lib/common/ipc_pacemakerd.c pcmk__pcmkd_api_reply2str(enum pcmk_pacemakerd_api_reply reply) reply 112 lib/common/ipc_pacemakerd.c switch (reply) { reply 194 lib/common/ipc_pacemakerd.c dispatch(pcmk_ipc_api_t *api, xmlNode *reply) reply 205 lib/common/ipc_pacemakerd.c if (pcmk__xe_is(reply, PCMK__XE_ACK)) { reply 207 lib/common/ipc_pacemakerd.c const char *status = crm_element_value(reply, PCMK_XA_STATUS); reply 218 lib/common/ipc_pacemakerd.c value = crm_element_value(reply, PCMK__XA_T); reply 229 lib/common/ipc_pacemakerd.c value = crm_element_value(reply, PCMK__XA_SUBT); reply 238 lib/common/ipc_pacemakerd.c if (pcmk__str_empty(crm_element_value(reply, PCMK_XA_REFERENCE))) { reply 245 lib/common/ipc_pacemakerd.c value = crm_element_value(reply, PCMK__XA_CRM_TASK); reply 248 lib/common/ipc_pacemakerd.c wrapper = pcmk__xe_first_child(reply, PCMK__XE_CRM_XML, NULL, NULL); reply 77 lib/common/ipc_schedulerd.c dispatch(pcmk_ipc_api_t *api, xmlNode *reply) reply 87 lib/common/ipc_schedulerd.c if (pcmk__xe_is(reply, PCMK__XE_ACK)) { reply 91 lib/common/ipc_schedulerd.c value = crm_element_value(reply, PCMK__XA_T); reply 100 lib/common/ipc_schedulerd.c value = crm_element_value(reply, PCMK__XA_SUBT); reply 109 lib/common/ipc_schedulerd.c if (pcmk__str_empty(crm_element_value(reply, PCMK_XA_REFERENCE))) { reply 116 lib/common/ipc_schedulerd.c wrapper = pcmk__xe_first_child(reply, PCMK__XE_CRM_XML, NULL, NULL); reply 119 lib/common/ipc_schedulerd.c value = crm_element_value(reply, PCMK__XA_CRM_TASK); reply 123 lib/common/ipc_schedulerd.c reply_data.data.graph.reference = crm_element_value(reply, reply 125 lib/common/ipc_schedulerd.c reply_data.data.graph.input = crm_element_value(reply, reply 732 lib/fencing/st_client.c xmlNode *reply = pcmk__xpath_find_one(output->doc, reply 736 lib/fencing/st_client.c for (op = pcmk__xe_first_child(reply, NULL, NULL, NULL); op != NULL; reply 1163 lib/fencing/st_client.c xmlNode *reply = NULL; reply 1169 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply); reply 1176 lib/fencing/st_client.c } else if (reply == NULL) { reply 1181 lib/fencing/st_client.c const char *msg_type = crm_element_value(reply, PCMK__XA_ST_OP); reply 1183 lib/fencing/st_client.c native->token = crm_element_value_copy(reply, PCMK__XA_ST_CLIENTID); reply 1187 lib/fencing/st_client.c crm_log_xml_debug(reply, "Invalid fencer reply"); reply 1192 lib/fencing/st_client.c crm_log_xml_debug(reply, "Invalid fencer reply"); reply 1202 lib/fencing/st_client.c pcmk__xml_free(reply); reply 105 lib/lrmd/lrmd_client.c static int process_lrmd_handshake_reply(xmlNode *reply, lrmd_private_t *native); reply 679 lib/lrmd/lrmd_client.c xmlNode **reply) reply 694 lib/lrmd/lrmd_client.c for (*reply = NULL; *reply == NULL; ) { reply 696 lib/lrmd/lrmd_client.c *reply = pcmk__remote_message_xml(native->remote); reply 697 lib/lrmd/lrmd_client.c if (*reply == NULL) { reply 713 lib/lrmd/lrmd_client.c *reply = pcmk__remote_message_xml(native->remote); reply 714 lib/lrmd/lrmd_client.c if (*reply == NULL) { reply 719 lib/lrmd/lrmd_client.c crm_element_value_int(*reply, PCMK__XA_LRMD_REMOTE_MSG_ID, &reply_id); reply 720 lib/lrmd/lrmd_client.c msg_type = crm_element_value(*reply, PCMK__XA_LRMD_REMOTE_MSG_TYPE); reply 724 lib/lrmd/lrmd_client.c pcmk__xml_free(*reply); reply 725 lib/lrmd/lrmd_client.c *reply = NULL; reply 729 lib/lrmd/lrmd_client.c native->pending_notify = g_list_append(native->pending_notify, *reply); reply 734 lib/lrmd/lrmd_client.c *reply = NULL; reply 738 lib/lrmd/lrmd_client.c pcmk__xml_free(*reply); reply 739 lib/lrmd/lrmd_client.c *reply = NULL; reply 746 lib/lrmd/lrmd_client.c pcmk__xml_free(*reply); reply 747 lib/lrmd/lrmd_client.c *reply = NULL; reply 781 lib/lrmd/lrmd_client.c lrmd_tls_send_recv(lrmd_t * lrmd, xmlNode * msg, int timeout, xmlNode ** reply) reply 803 lib/lrmd/lrmd_client.c if (reply) { reply 804 lib/lrmd/lrmd_client.c *reply = xml; reply 813 lib/lrmd/lrmd_client.c lrmd_send_xml(lrmd_t * lrmd, xmlNode * msg, int timeout, xmlNode ** reply) reply 820 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply); reply 823 lib/lrmd/lrmd_client.c rc = lrmd_tls_send_recv(lrmd, msg, timeout, reply); reply 1023 lib/lrmd/lrmd_client.c process_lrmd_handshake_reply(xmlNode *reply, lrmd_private_t *native) reply 1026 lib/lrmd/lrmd_client.c const char *version = crm_element_value(reply, PCMK__XA_LRMD_PROTOCOL_VERSION); reply 1027 lib/lrmd/lrmd_client.c const char *msg_type = crm_element_value(reply, PCMK__XA_LRMD_OP); reply 1028 lib/lrmd/lrmd_client.c const char *tmp_ticket = crm_element_value(reply, PCMK__XA_LRMD_CLIENTID); reply 1029 lib/lrmd/lrmd_client.c const char *start_state = crm_element_value(reply, PCMK__XA_NODE_START_STATE); reply 1032 lib/lrmd/lrmd_client.c crm_element_value_int(reply, PCMK__XA_LRMD_RC, &rc); reply 1039 lib/lrmd/lrmd_client.c crm_element_value_ll(reply, PCMK__XA_UPTIME, &uptime); reply 1049 lib/lrmd/lrmd_client.c crm_log_xml_err(reply, "Protocol Error"); reply 1052 lib/lrmd/lrmd_client.c crm_log_xml_err(reply, "Bad reply"); reply 1056 lib/lrmd/lrmd_client.c crm_log_xml_err(reply, "Bad reply"); reply 1073 lib/lrmd/lrmd_client.c xmlNode *reply = NULL; reply 1076 lib/lrmd/lrmd_client.c rc = lrmd_send_xml(lrmd, hello, -1, &reply); reply 1081 lib/lrmd/lrmd_client.c } else if (reply == NULL) { reply 1085 lib/lrmd/lrmd_client.c rc = process_lrmd_handshake_reply(reply, native); reply 1088 lib/lrmd/lrmd_client.c pcmk__xml_free(reply); reply 115 lib/pacemaker/pcmk_cluster_queries.c const pcmk_controld_api_reply_t *reply = NULL; reply 122 lib/pacemaker/pcmk_cluster_queries.c reply = (const pcmk_controld_api_reply_t *) event_data; reply 124 lib/pacemaker/pcmk_cluster_queries.c if (reply->reply_type != expected_type) { reply 126 lib/pacemaker/pcmk_cluster_queries.c pcmk__controld_api_reply2str(reply->reply_type)); reply 155 lib/pacemaker/pcmk_cluster_queries.c const pcmk_pacemakerd_api_reply_t *reply = NULL; reply 162 lib/pacemaker/pcmk_cluster_queries.c reply = (const pcmk_pacemakerd_api_reply_t *) event_data; reply 164 lib/pacemaker/pcmk_cluster_queries.c if (reply->reply_type != expected_type) { reply 166 lib/pacemaker/pcmk_cluster_queries.c pcmk__pcmkd_api_reply2str(reply->reply_type)); reply 192 lib/pacemaker/pcmk_cluster_queries.c const pcmk_controld_api_reply_t *reply = NULL; reply 201 lib/pacemaker/pcmk_cluster_queries.c reply = (const pcmk_controld_api_reply_t *) event_data; reply 203 lib/pacemaker/pcmk_cluster_queries.c reply->data.ping.sys_from, reply->host_from, reply 204 lib/pacemaker/pcmk_cluster_queries.c reply->data.ping.fsa_state, reply->data.ping.result); reply 227 lib/pacemaker/pcmk_cluster_queries.c const pcmk_controld_api_reply_t *reply = NULL; reply 236 lib/pacemaker/pcmk_cluster_queries.c reply = (const pcmk_controld_api_reply_t *) event_data; reply 237 lib/pacemaker/pcmk_cluster_queries.c out->message(out, "dc", reply->host_from); reply 238 lib/pacemaker/pcmk_cluster_queries.c data->rc = reply->host_from ? pcmk_rc_ok : pcmk_rc_no_dc; reply 259 lib/pacemaker/pcmk_cluster_queries.c const pcmk_controld_api_reply_t *reply = NULL; reply 268 lib/pacemaker/pcmk_cluster_queries.c reply = (const pcmk_controld_api_reply_t *) event_data; reply 270 lib/pacemaker/pcmk_cluster_queries.c if (reply->data.node_info.uname == NULL) { reply 276 lib/pacemaker/pcmk_cluster_queries.c data->node_info.have_quorum = reply->data.node_info.have_quorum; reply 277 lib/pacemaker/pcmk_cluster_queries.c data->node_info.is_remote = reply->data.node_info.is_remote; reply 278 lib/pacemaker/pcmk_cluster_queries.c data->node_info.id = (uint32_t) reply->data.node_info.id; reply 280 lib/pacemaker/pcmk_cluster_queries.c pcmk__str_update(data->node_info.node_name, reply->data.node_info.uname); reply 281 lib/pacemaker/pcmk_cluster_queries.c pcmk__str_update(data->node_info.uuid, reply->data.node_info.uuid); reply 282 lib/pacemaker/pcmk_cluster_queries.c pcmk__str_update(data->node_info.state, reply->data.node_info.state); reply 286 lib/pacemaker/pcmk_cluster_queries.c (uint32_t) reply->data.node_info.id, reply->data.node_info.uname, reply 287 lib/pacemaker/pcmk_cluster_queries.c reply->data.node_info.uuid, reply->data.node_info.state, reply 288 lib/pacemaker/pcmk_cluster_queries.c reply->data.node_info.have_quorum, reply 289 lib/pacemaker/pcmk_cluster_queries.c reply->data.node_info.is_remote); reply 313 lib/pacemaker/pcmk_cluster_queries.c const pcmk_pacemakerd_api_reply_t *reply = NULL; reply 323 lib/pacemaker/pcmk_cluster_queries.c reply = (const pcmk_pacemakerd_api_reply_t *) event_data; reply 325 lib/pacemaker/pcmk_cluster_queries.c data->pcmkd_state = reply->data.ping.state; reply 332 lib/pacemaker/pcmk_cluster_queries.c if (reply->data.ping.status == pcmk_rc_ok) { reply 334 lib/pacemaker/pcmk_cluster_queries.c reply->data.ping.sys_from, reply->data.ping.state, NULL, reply 335 lib/pacemaker/pcmk_cluster_queries.c reply->data.ping.last_good); reply 338 lib/pacemaker/pcmk_cluster_queries.c reply->data.ping.sys_from, reply->data.ping.state, reply 330 lib/services/dbus.c pcmk_dbus_find_error(const 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 600 lib/services/dbus.c if (pcmk_dbus_find_error((void*)&error, reply, &error)) { reply 608 lib/services/dbus.c dbus_message_iter_init(reply, &args); reply 609 lib/services/dbus.c if (!pcmk_dbus_type_check(reply, &args, DBUS_TYPE_VARIANT, reply 618 lib/services/dbus.c if (!pcmk_dbus_type_check(reply, &variant_iter, DBUS_TYPE_STRING, reply 659 lib/services/dbus.c DBusMessage *reply = NULL; reply 663 lib/services/dbus.c reply = dbus_pending_call_steal_reply(pending); reply 666 lib/services/dbus.c value = handle_query_result(reply, user_data); reply 669 lib/services/dbus.c if (reply) { reply 670 lib/services/dbus.c dbus_message_unref(reply); reply 765 lib/services/dbus.c DBusMessage *reply = pcmk_dbus_send_recv(msg, connection, NULL, reply 768 lib/services/dbus.c output = handle_query_result(reply, query_data); reply 770 lib/services/dbus.c if (reply) { reply 771 lib/services/dbus.c dbus_message_unref(reply); reply 49 lib/services/pcmk-dbus.h bool pcmk_dbus_find_error(const DBusPendingCall *pending, DBusMessage *reply, reply 114 lib/services/systemd.c DBusMessage *reply = NULL; reply 128 lib/services/systemd.c reply = systemd_send_recv(msg, &error, DBUS_TIMEOUT_USE_DEFAULT); reply 137 lib/services/systemd.c } else if (reply == NULL) { reply 142 lib/services/systemd.c return reply; reply 162 lib/services/systemd.c DBusMessage *reply = NULL; reply 179 lib/services/systemd.c reply = systemd_call_simple_method("Subscribe"); reply 180 lib/services/systemd.c if (reply == NULL) { reply 185 lib/services/systemd.c dbus_message_unref(reply); reply 305 lib/services/systemd.c DBusMessage *reply = NULL; reply 310 lib/services/systemd.c reply = dbus_pending_call_steal_reply(pending); reply 313 lib/services/systemd.c if (pcmk_dbus_find_error(pending, reply, &error)) { reply 325 lib/services/systemd.c if(reply) { reply 326 lib/services/systemd.c dbus_message_unref(reply); reply 405 lib/services/systemd.c execute_after_loadunit(DBusMessage *reply, svc_action_t *op) reply 413 lib/services/systemd.c if (pcmk_dbus_find_error((void *) &path, reply, &error)) { reply 419 lib/services/systemd.c } else if (!pcmk_dbus_type_check(reply, NULL, DBUS_TYPE_OBJECT_PATH, reply 432 lib/services/systemd.c dbus_message_get_args (reply, NULL, reply 466 lib/services/systemd.c DBusMessage *reply = NULL; reply 473 lib/services/systemd.c reply = dbus_pending_call_steal_reply(pending); reply 481 lib/services/systemd.c execute_after_loadunit(reply, user_data); reply 482 lib/services/systemd.c if (reply != NULL) { reply 483 lib/services/systemd.c dbus_message_unref(reply); reply 506 lib/services/systemd.c DBusMessage *reply = NULL; reply 547 lib/services/systemd.c reply = systemd_send_recv(msg, NULL, reply 551 lib/services/systemd.c unit = execute_after_loadunit(reply, op); reply 564 lib/services/systemd.c if (reply != NULL) { reply 565 lib/services/systemd.c dbus_message_unref(reply); reply 619 lib/services/systemd.c DBusMessage *reply = NULL; reply 631 lib/services/systemd.c reply = systemd_call_simple_method("ListUnitFiles"); reply 632 lib/services/systemd.c if (reply == NULL) { reply 635 lib/services/systemd.c if (!dbus_message_iter_init(reply, &args)) { reply 637 lib/services/systemd.c dbus_message_unref(reply); reply 640 lib/services/systemd.c if (!pcmk_dbus_type_check(reply, &args, DBUS_TYPE_ARRAY, reply 643 lib/services/systemd.c dbus_message_unref(reply); reply 656 lib/services/systemd.c if(!pcmk_dbus_type_check(reply, &unit, DBUS_TYPE_STRUCT, __func__, __LINE__)) { reply 662 lib/services/systemd.c if(!pcmk_dbus_type_check(reply, &elem, DBUS_TYPE_STRING, __func__, __LINE__)) { reply 701 lib/services/systemd.c dbus_message_unref(reply); reply 805 lib/services/systemd.c process_unit_method_reply(DBusMessage *reply, svc_action_t *op) reply 816 lib/services/systemd.c if (pcmk_dbus_find_error((void *) &error, reply, &error)) { reply 820 lib/services/systemd.c } else if (!pcmk_dbus_type_check(reply, NULL, DBUS_TYPE_OBJECT_PATH, reply 845 lib/services/systemd.c dbus_message_get_args(reply, NULL, reply 971 lib/services/systemd.c DBusMessage *reply = NULL; reply 978 lib/services/systemd.c reply = dbus_pending_call_steal_reply(pending); reply 985 lib/services/systemd.c process_unit_method_reply(reply, op); reply 987 lib/services/systemd.c if (reply != NULL) { reply 988 lib/services/systemd.c dbus_message_unref(reply); reply 1241 lib/services/systemd.c DBusMessage *reply = NULL; reply 1324 lib/services/systemd.c reply = systemd_send_recv(msg, NULL, op->timeout); reply 1326 lib/services/systemd.c process_unit_method_reply(reply, op); reply 1327 lib/services/systemd.c if (reply != NULL) { reply 1328 lib/services/systemd.c dbus_message_unref(reply); reply 400 tools/attrd_updater.c print_attrd_values(pcmk__output_t *out, const GList *reply) reply 402 tools/attrd_updater.c for (const GList *iter = reply; iter != NULL; iter = iter->next) { reply 416 tools/attrd_updater.c pcmk__attrd_api_reply_t *reply = event_data; reply 423 tools/attrd_updater.c if (reply->reply_type == pcmk__attrd_reply_query) { reply 424 tools/attrd_updater.c print_attrd_values(out, reply->data.pairs); reply 339 tools/crm_node.c pcmk_controld_api_reply_t *reply = event_data; reply 365 tools/crm_node.c if (reply->reply_type != pcmk_controld_reply_nodes) { reply 368 tools/crm_node.c reply->reply_type); reply 372 tools/crm_node.c reply->data.nodes = g_list_sort(reply->data.nodes, sort_node); reply 375 tools/crm_node.c out->message(out, "partition-list", reply->data.nodes); reply 377 tools/crm_node.c out->message(out, "simple-node-list", reply->data.nodes);