request 57 daemons/attrd/attrd_corosync.c pcmk__request_t request = { request 67 daemons/attrd/attrd_corosync.c request.op = crm_element_value_copy(request.xml, PCMK_XA_TASK); request 68 daemons/attrd/attrd_corosync.c CRM_CHECK(request.op != NULL, return); request 70 daemons/attrd/attrd_corosync.c attrd_handle_request(&request); request 76 daemons/attrd/attrd_corosync.c !pcmk__str_eq(request.op, PCMK__ATTRD_CMD_CONFIRM, pcmk__str_none)) { request 97 daemons/attrd/attrd_corosync.c pcmk__reset_request(&request); request 453 daemons/attrd/attrd_corosync.c attrd_peer_clear_failure(pcmk__request_t *request) request 455 daemons/attrd/attrd_corosync.c xmlNode *xml = request->xml; request 467 daemons/attrd/attrd_corosync.c pcmk__get_node(0, request->peer, NULL, request 89 daemons/attrd/attrd_ipc.c attrd_client_clear_failure(pcmk__request_t *request) request 91 daemons/attrd/attrd_ipc.c xmlNode *xml = request->xml; request 99 daemons/attrd/attrd_ipc.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 137 daemons/attrd/attrd_ipc.c return attrd_client_update(request); request 141 daemons/attrd/attrd_ipc.c attrd_client_peer_remove(pcmk__request_t *request) request 143 daemons/attrd/attrd_ipc.c xmlNode *xml = request->xml; request 149 daemons/attrd/attrd_ipc.c attrd_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags); request 175 daemons/attrd/attrd_ipc.c pcmk__client_name(request->ipc_client), host); request 180 daemons/attrd/attrd_ipc.c pcmk__client_name(request->ipc_client)); request 183 daemons/attrd/attrd_ipc.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 188 daemons/attrd/attrd_ipc.c attrd_client_query(pcmk__request_t *request) request 190 daemons/attrd/attrd_ipc.c xmlNode *query = request->xml; request 194 daemons/attrd/attrd_ipc.c crm_debug("Query arrived from %s", pcmk__client_name(request->ipc_client)); request 199 daemons/attrd/attrd_ipc.c pcmk__format_result(&request->result, CRM_EX_ERROR, PCMK_EXEC_ERROR, request 201 daemons/attrd/attrd_ipc.c pcmk__client_name(request->ipc_client)); request 209 daemons/attrd/attrd_ipc.c pcmk__format_result(&request->result, CRM_EX_ERROR, PCMK_EXEC_ERROR, request 211 daemons/attrd/attrd_ipc.c pcmk__client_name(request->ipc_client)); request 214 daemons/attrd/attrd_ipc.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 217 daemons/attrd/attrd_ipc.c request->ipc_client->request_id = 0; request 222 daemons/attrd/attrd_ipc.c attrd_client_refresh(pcmk__request_t *request) request 226 daemons/attrd/attrd_ipc.c attrd_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags); request 229 daemons/attrd/attrd_ipc.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 300 daemons/attrd/attrd_ipc.c handle_regexes(pcmk__request_t *request) request 302 daemons/attrd/attrd_ipc.c xmlNode *xml = request->xml; request 312 daemons/attrd/attrd_ipc.c pcmk__format_result(&request->result, CRM_EX_ERROR, PCMK_EXEC_ERROR, request 314 daemons/attrd/attrd_ipc.c pcmk__client_name(request->ipc_client)); request 318 daemons/attrd/attrd_ipc.c pcmk__format_result(&request->result, CRM_EX_ERROR, PCMK_EXEC_ERROR, request 320 daemons/attrd/attrd_ipc.c pcmk__client_name(request->ipc_client)); request 358 daemons/attrd/attrd_ipc.c send_update_msg_to_cluster(pcmk__request_t *request, xmlNode *xml) request 365 daemons/attrd/attrd_ipc.c attrd_expect_confirmations(request, attrd_cluster_sync_point_update); request 382 daemons/attrd/attrd_ipc.c pcmk__request_t *request = (pcmk__request_t *) data; request 387 daemons/attrd/attrd_ipc.c request->xml = child; request 388 daemons/attrd/attrd_ipc.c attrd_client_update(request); request 393 daemons/attrd/attrd_ipc.c attrd_client_update(pcmk__request_t *request) request 398 daemons/attrd/attrd_ipc.c CRM_CHECK((request != NULL) && (request->xml != NULL), return NULL); request 400 daemons/attrd/attrd_ipc.c xml = request->xml; request 422 daemons/attrd/attrd_ipc.c if (handle_value_expansion(&value, child, request->op, attr) == EINVAL) { request 423 daemons/attrd/attrd_ipc.c pcmk__format_result(&request->result, CRM_EX_NOSUCH, PCMK_EXEC_ERROR, request 429 daemons/attrd/attrd_ipc.c send_update_msg_to_cluster(request, xml); request 430 daemons/attrd/attrd_ipc.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 436 daemons/attrd/attrd_ipc.c xmlNode *orig_xml = request->xml; request 442 daemons/attrd/attrd_ipc.c pcmk__xe_foreach_child(xml, PCMK_XE_OP, send_child_update, request); request 443 daemons/attrd/attrd_ipc.c request->xml = orig_xml; request 453 daemons/attrd/attrd_ipc.c if (handle_regexes(request) != pcmk_rc_ok) { request 461 daemons/attrd/attrd_ipc.c return attrd_client_update(request); request 466 daemons/attrd/attrd_ipc.c if (handle_value_expansion(&value, xml, request->op, attr) == EINVAL) { request 467 daemons/attrd/attrd_ipc.c pcmk__format_result(&request->result, CRM_EX_NOSUCH, PCMK_EXEC_ERROR, request 476 daemons/attrd/attrd_ipc.c send_update_msg_to_cluster(request, xml); request 477 daemons/attrd/attrd_ipc.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 604 daemons/attrd/attrd_ipc.c pcmk__request_t request = { request 617 daemons/attrd/attrd_ipc.c request.op = crm_element_value_copy(request.xml, PCMK_XA_TASK); request 618 daemons/attrd/attrd_ipc.c CRM_CHECK(request.op != NULL, return 0); request 620 daemons/attrd/attrd_ipc.c attrd_handle_request(&request); request 621 daemons/attrd/attrd_ipc.c pcmk__reset_request(&request); request 45 daemons/attrd/attrd_messages.c remove_unsupported_sync_points(pcmk__request_t *request) request 47 daemons/attrd/attrd_messages.c if (request->xml->children != NULL && !ATTRD_SUPPORTS_MULTI_MESSAGE(minimum_protocol_version) && request 48 daemons/attrd/attrd_messages.c attrd_request_has_sync_point(request->xml)) { request 50 daemons/attrd/attrd_messages.c pcmk__request_origin(request)); request 51 daemons/attrd/attrd_messages.c remove_sync_point_attribute(request->xml, NULL); request 56 daemons/attrd/attrd_messages.c handle_unknown_request(pcmk__request_t *request) request 59 daemons/attrd/attrd_messages.c request->op, pcmk__request_origin_type(request), request 60 daemons/attrd/attrd_messages.c pcmk__request_origin(request)); request 61 daemons/attrd/attrd_messages.c pcmk__format_result(&request->result, CRM_EX_PROTOCOL, PCMK_EXEC_INVALID, request 62 daemons/attrd/attrd_messages.c "Unknown request type '%s' (bug?)", request->op); request 67 daemons/attrd/attrd_messages.c handle_clear_failure_request(pcmk__request_t *request) request 69 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 73 daemons/attrd/attrd_messages.c attrd_peer_clear_failure(request); request 74 daemons/attrd/attrd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 77 daemons/attrd/attrd_messages.c remove_unsupported_sync_points(request); request 79 daemons/attrd/attrd_messages.c if (attrd_request_has_sync_point(request->xml)) { request 87 daemons/attrd/attrd_messages.c attrd_add_client_to_waitlist(request); request 94 daemons/attrd/attrd_messages.c attrd_send_ack(request->ipc_client, request->ipc_id, request 95 daemons/attrd/attrd_messages.c request->ipc_flags); request 98 daemons/attrd/attrd_messages.c return attrd_client_clear_failure(request); request 103 daemons/attrd/attrd_messages.c handle_confirm_request(pcmk__request_t *request) request 105 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 108 daemons/attrd/attrd_messages.c crm_debug("Received confirmation from %s", request->peer); request 110 daemons/attrd/attrd_messages.c if (crm_element_value_int(request->xml, PCMK__XA_CALL_ID, request 112 daemons/attrd/attrd_messages.c pcmk__set_result(&request->result, CRM_EX_PROTOCOL, PCMK_EXEC_INVALID, request 115 daemons/attrd/attrd_messages.c attrd_handle_confirmation(callid, request->peer); request 118 daemons/attrd/attrd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 121 daemons/attrd/attrd_messages.c return handle_unknown_request(request); request 126 daemons/attrd/attrd_messages.c handle_query_request(pcmk__request_t *request) request 128 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 129 daemons/attrd/attrd_messages.c return handle_unknown_request(request); request 131 daemons/attrd/attrd_messages.c return attrd_client_query(request); request 136 daemons/attrd/attrd_messages.c handle_remove_request(pcmk__request_t *request) request 138 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 139 daemons/attrd/attrd_messages.c const char *host = crm_element_value(request->xml, PCMK__XA_ATTR_HOST); request 142 daemons/attrd/attrd_messages.c if (pcmk__xe_get_bool_attr(request->xml, PCMK__XA_REAP, request 146 daemons/attrd/attrd_messages.c attrd_peer_remove(host, reap, request->peer); request 147 daemons/attrd/attrd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 150 daemons/attrd/attrd_messages.c return attrd_client_peer_remove(request); request 155 daemons/attrd/attrd_messages.c handle_refresh_request(pcmk__request_t *request) request 157 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 158 daemons/attrd/attrd_messages.c return handle_unknown_request(request); request 160 daemons/attrd/attrd_messages.c return attrd_client_refresh(request); request 165 daemons/attrd/attrd_messages.c handle_sync_response_request(pcmk__request_t *request) request 167 daemons/attrd/attrd_messages.c if (request->ipc_client != NULL) { request 168 daemons/attrd/attrd_messages.c return handle_unknown_request(request); request 170 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 172 daemons/attrd/attrd_messages.c pcmk__get_node(0, request->peer, NULL, request 174 daemons/attrd/attrd_messages.c bool peer_won = attrd_check_for_new_writer(peer, request->xml); request 178 daemons/attrd/attrd_messages.c attrd_peer_sync_response(peer, peer_won, request->xml); request 182 daemons/attrd/attrd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 188 daemons/attrd/attrd_messages.c handle_update_request(pcmk__request_t *request) request 190 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 191 daemons/attrd/attrd_messages.c const char *host = crm_element_value(request->xml, PCMK__XA_ATTR_HOST); request 193 daemons/attrd/attrd_messages.c pcmk__get_node(0, request->peer, NULL, request 196 daemons/attrd/attrd_messages.c attrd_peer_update(peer, request->xml, host, false); request 197 daemons/attrd/attrd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 201 daemons/attrd/attrd_messages.c remove_unsupported_sync_points(request); request 203 daemons/attrd/attrd_messages.c if (attrd_request_has_sync_point(request->xml)) { request 211 daemons/attrd/attrd_messages.c attrd_add_client_to_waitlist(request); request 222 daemons/attrd/attrd_messages.c attrd_send_ack(request->ipc_client, request->ipc_id, request 223 daemons/attrd/attrd_messages.c request->flags|crm_ipc_client_response); request 226 daemons/attrd/attrd_messages.c return attrd_client_update(request); request 259 daemons/attrd/attrd_messages.c attrd_handle_request(pcmk__request_t *request) request 269 daemons/attrd/attrd_messages.c reply = pcmk__process_request(request, attrd_handlers); request 274 daemons/attrd/attrd_messages.c if (request->ipc_client != NULL) { request 275 daemons/attrd/attrd_messages.c pcmk__ipc_send_xml(request->ipc_client, request->ipc_id, reply, request 276 daemons/attrd/attrd_messages.c request->ipc_flags); request 284 daemons/attrd/attrd_messages.c reason = request->result.exit_reason; request 286 daemons/attrd/attrd_messages.c request->op, pcmk__request_origin_type(request), request 287 daemons/attrd/attrd_messages.c pcmk__request_origin(request), request 288 daemons/attrd/attrd_messages.c pcmk_exec_status_str(request->result.execution_status), request 293 daemons/attrd/attrd_messages.c if (!pcmk__result_ok(&request->result)) { request 300 daemons/attrd/attrd_messages.c pcmk__reset_request(request); request 135 daemons/attrd/attrd_sync.c attrd_add_client_to_waitlist(pcmk__request_t *request) request 137 daemons/attrd/attrd_sync.c const char *sync_point = attrd_request_sync_point(request->xml); request 159 daemons/attrd/attrd_sync.c wl->client_id = pcmk__str_copy(request->ipc_client->id); request 160 daemons/attrd/attrd_sync.c wl->ipc_id = request->ipc_id; request 161 daemons/attrd/attrd_sync.c wl->flags = request->flags; request 173 daemons/attrd/attrd_sync.c crm_xml_add_int(request->xml, PCMK__XA_CALL_ID, waitlist_client); request 475 daemons/attrd/attrd_sync.c attrd_expect_confirmations(pcmk__request_t *request, attrd_confirmation_action_fn fn) request 487 daemons/attrd/attrd_sync.c if (crm_element_value_int(request->xml, PCMK__XA_CALL_ID, &callid) == -1) { request 509 daemons/attrd/attrd_sync.c action->xml = pcmk__xml_copy(NULL, request->xml); request 510 daemons/attrd/attrd_sync.c action->client_id = pcmk__str_copy(request->ipc_client->id); request 511 daemons/attrd/attrd_sync.c action->ipc_id = request->ipc_id; request 512 daemons/attrd/attrd_sync.c action->flags = request->flags; request 193 daemons/attrd/pacemaker-attrd.h void attrd_peer_clear_failure(pcmk__request_t *request); request 198 daemons/attrd/pacemaker-attrd.h xmlNode *attrd_client_peer_remove(pcmk__request_t *request); request 199 daemons/attrd/pacemaker-attrd.h xmlNode *attrd_client_clear_failure(pcmk__request_t *request); request 200 daemons/attrd/pacemaker-attrd.h xmlNode *attrd_client_update(pcmk__request_t *request); request 201 daemons/attrd/pacemaker-attrd.h xmlNode *attrd_client_refresh(pcmk__request_t *request); request 202 daemons/attrd/pacemaker-attrd.h xmlNode *attrd_client_query(pcmk__request_t *request); request 231 daemons/attrd/pacemaker-attrd.h void attrd_handle_request(pcmk__request_t *request); request 240 daemons/attrd/pacemaker-attrd.h void attrd_add_client_to_waitlist(pcmk__request_t *request); request 245 daemons/attrd/pacemaker-attrd.h void attrd_expect_confirmations(pcmk__request_t *request, attrd_confirmation_action_fn fn); request 42 daemons/based/based_callbacks.c static int cib_process_command(xmlNode *request, request 578 daemons/based/based_callbacks.c parse_peer_options(const cib__operation_t *operation, xmlNode *request, request 590 daemons/based/based_callbacks.c const char *delegated = crm_element_value(request, request 592 daemons/based/based_callbacks.c const char *op = crm_element_value(request, PCMK__XA_CIB_OP); request 593 daemons/based/based_callbacks.c const char *originator = crm_element_value(request, PCMK__XA_SRC); request 594 daemons/based/based_callbacks.c const char *reply_to = crm_element_value(request, PCMK__XA_CIB_ISREPLYTO); request 614 daemons/based/based_callbacks.c process_ping_reply(request); request 628 daemons/based/based_callbacks.c const char *max = crm_element_value(request, PCMK__XA_CIB_SCHEMA_MAX); request 629 daemons/based/based_callbacks.c const char *upgrade_rc = crm_element_value(request, request 639 daemons/based/based_callbacks.c crm_xml_add(request, PCMK__XA_CIB_RC, upgrade_rc); request 654 daemons/based/based_callbacks.c } else if (pcmk__xe_attr_is_true(request, PCMK__XA_CIB_UPDATE)) { request 690 daemons/based/based_callbacks.c host = crm_element_value(request, PCMK__XA_CIB_HOST); request 707 daemons/based/based_callbacks.c pcmk__s(crm_element_value(request, PCMK__XA_CIB_CLIENTNAME), request 709 daemons/based/based_callbacks.c pcmk__s(crm_element_value(request, PCMK__XA_CIB_CALLID), request 722 daemons/based/based_callbacks.c forward_request(xmlNode *request) request 724 daemons/based/based_callbacks.c const char *op = crm_element_value(request, PCMK__XA_CIB_OP); request 725 daemons/based/based_callbacks.c const char *section = crm_element_value(request, PCMK__XA_CIB_SECTION); request 726 daemons/based/based_callbacks.c const char *host = crm_element_value(request, PCMK__XA_CIB_HOST); request 727 daemons/based/based_callbacks.c const char *originator = crm_element_value(request, PCMK__XA_SRC); request 728 daemons/based/based_callbacks.c const char *client_name = crm_element_value(request, request 730 daemons/based/based_callbacks.c const char *call_id = crm_element_value(request, PCMK__XA_CIB_CALLID); request 748 daemons/based/based_callbacks.c crm_xml_add(request, PCMK__XA_CIB_DELEGATED_FROM, OUR_NODENAME); request 753 daemons/based/based_callbacks.c pcmk__cluster_send_message(peer, pcmk_ipc_based, request); request 756 daemons/based/based_callbacks.c pcmk__xe_remove_attr(request, PCMK__XA_CIB_DELEGATED_FROM); request 789 daemons/based/based_callbacks.c cib_process_request(xmlNode *request, gboolean privileged, request 805 daemons/based/based_callbacks.c const char *op = crm_element_value(request, PCMK__XA_CIB_OP); request 806 daemons/based/based_callbacks.c const char *originator = crm_element_value(request, PCMK__XA_SRC); request 807 daemons/based/based_callbacks.c const char *host = crm_element_value(request, PCMK__XA_CIB_HOST); request 808 daemons/based/based_callbacks.c const char *call_id = crm_element_value(request, PCMK__XA_CIB_CALLID); request 809 daemons/based/based_callbacks.c const char *client_id = crm_element_value(request, PCMK__XA_CIB_CLIENTID); request 810 daemons/based/based_callbacks.c const char *client_name = crm_element_value(request, request 812 daemons/based/based_callbacks.c const char *reply_to = crm_element_value(request, PCMK__XA_CIB_ISREPLYTO); request 817 daemons/based/based_callbacks.c rc = pcmk__xe_get_flags(request, PCMK__XA_CIB_CALLOPT, &call_options, request 832 daemons/based/based_callbacks.c crm_xml_add(request, PCMK__XA_SRC, OUR_NODENAME); request 857 daemons/based/based_callbacks.c } else if (!parse_peer_options(operation, request, &local_notify, request 889 daemons/based/based_callbacks.c forward_request(request); request 904 daemons/based/based_callbacks.c const char *section = crm_element_value(request, PCMK__XA_CIB_SECTION); request 909 daemons/based/based_callbacks.c rc = cib_process_command(request, operation, op_function, &op_reply, request 915 daemons/based/based_callbacks.c } else if (pcmk__xe_attr_is_true(request, PCMK__XA_CIB_UPDATE)) { request 956 daemons/based/based_callbacks.c crm_log_xml_err(request, "null reply"); request 993 daemons/based/based_callbacks.c do_local_notify(request, client_id, request 1023 daemons/based/based_callbacks.c prepare_input(const xmlNode *request, enum cib__op_type type, request 1026 daemons/based/based_callbacks.c xmlNode *wrapper = pcmk__xe_first_child(request, PCMK__XE_CIB_CALLDATA, request 1033 daemons/based/based_callbacks.c *section = crm_element_value(request, PCMK__XA_CIB_SECTION); request 1066 daemons/based/based_callbacks.c cib_process_command(xmlNode *request, const cib__operation_t *operation, request 1078 daemons/based/based_callbacks.c const char *call_id = crm_element_value(request, PCMK__XA_CIB_CALLID); request 1079 daemons/based/based_callbacks.c const char *client_id = crm_element_value(request, PCMK__XA_CIB_CLIENTID); request 1080 daemons/based/based_callbacks.c const char *client_name = crm_element_value(request, request 1082 daemons/based/based_callbacks.c const char *originator = crm_element_value(request, PCMK__XA_SRC); request 1101 daemons/based/based_callbacks.c op = crm_element_value(request, PCMK__XA_CIB_OP); request 1102 daemons/based/based_callbacks.c rc = pcmk__xe_get_flags(request, PCMK__XA_CIB_CALLOPT, &call_options, request 1114 daemons/based/based_callbacks.c input = prepare_input(request, operation->type, §ion); request 1118 daemons/based/based_callbacks.c request, input, false, &config_changed, &the_cib, request 1132 daemons/based/based_callbacks.c if (pcmk__xe_attr_is_true(request, PCMK__XA_CIB_UPDATE)) { request 1147 daemons/based/based_callbacks.c request, input, manage_counters, &config_changed, request 1197 daemons/based/based_callbacks.c sync_our_cib(request, TRUE); request 409 daemons/based/based_messages.c sync_our_cib(xmlNode * request, gboolean all) request 413 daemons/based/based_messages.c const char *host = crm_element_value(request, PCMK__XA_SRC); request 414 daemons/based/based_messages.c const char *op = crm_element_value(request, PCMK__XA_CIB_OP); request 424 daemons/based/based_messages.c replace_request = cib_msg_copy(request); request 58 daemons/based/based_transaction.c for (xmlNode *request = pcmk__xe_first_child(transaction, request 61 daemons/based/based_transaction.c request != NULL; request 62 daemons/based/based_transaction.c request = pcmk__xe_next(request, PCMK__XE_CIB_COMMAND)) { request 64 daemons/based/based_transaction.c const char *op = crm_element_value(request, PCMK__XA_CIB_OP); request 65 daemons/based/based_transaction.c const char *host = crm_element_value(request, PCMK__XA_CIB_HOST); request 78 daemons/based/based_transaction.c rc = cib_process_request(request, TRUE, client); request 87 daemons/based/based_transaction.c crm_log_xml_info(request, "Failed request"); request 93 daemons/based/based_transaction.c crm_log_xml_trace(request, "Successful request"); request 73 daemons/based/pacemaker-based.h int cib_process_request(xmlNode *request, gboolean privileged, request 125 daemons/based/pacemaker-based.h int sync_our_cib(xmlNode *request, gboolean all); request 969 daemons/controld/controld_execd.c ha_msg_input_t *request, bool unregister, bool from_cib) request 984 daemons/controld/controld_execd.c if (request) { request 986 daemons/controld/controld_execd.c char *ref = crm_element_value_copy(request->msg, PCMK_XA_REFERENCE); request 990 daemons/controld/controld_execd.c op->input = copy_ha_msg_input(request); request 1000 daemons/controld/controld_execd.c delete_rsc_entry(lrm_state, request, id, iter, rc, user, from_cib); request 557 daemons/controld/controld_execd_state.c xmlNode *request = pcmk__xe_first_child(wrapper, NULL, NULL, NULL); request 559 daemons/controld/controld_execd_state.c CRM_CHECK(request != NULL, return); request 561 daemons/controld/controld_execd_state.c crm_xml_add(request, PCMK_XE_ACL_ROLE, "pacemaker-remote"); request 562 daemons/controld/controld_execd_state.c pcmk__update_acl_user(request, PCMK__XA_LRMD_IPC_USER, request 570 daemons/controld/controld_execd_state.c if (pcmk__str_eq(crm_element_value(request, PCMK__XA_CRM_TASK), request 574 daemons/controld/controld_execd_state.c crm_element_value_int(request, PCMK_XA_ID, &node_id); request 576 daemons/controld/controld_execd_state.c && (crm_element_value(request, PCMK_XA_UNAME) == NULL)) { request 577 daemons/controld/controld_execd_state.c crm_xml_add(request, PCMK_XA_UNAME, lrm_state->node_name); request 581 daemons/controld/controld_execd_state.c crmd_proxy_dispatch(session, request); request 874 daemons/controld/controld_messages.c handle_node_list(const xmlNode *request) request 894 daemons/controld/controld_messages.c reply = pcmk__new_reply(request, reply_data); request 105 daemons/execd/execd_alerts.c process_lrmd_alert_exec(pcmk__client_t *client, uint32_t id, xmlNode *request) request 109 daemons/execd/execd_alerts.c xmlNode *alert_xml = pcmk__xpath_find_one(request->doc, request 142 daemons/execd/execd_alerts.c crm_element_value_int(request, PCMK__XA_LRMD_CALLID, &(cb_data->call_id)); request 700 daemons/execd/execd_commands.c send_generic_notify(int rc, xmlNode * request) request 705 daemons/execd/execd_commands.c xmlNode *rsc_xml = pcmk__xpath_find_one(request->doc, request 709 daemons/execd/execd_commands.c const char *op = crm_element_value(request, PCMK__XA_LRMD_OP); request 711 daemons/execd/execd_commands.c crm_element_value_int(request, PCMK__XA_LRMD_CALLID, &call_id); request 1516 daemons/execd/execd_commands.c process_lrmd_signon(pcmk__client_t *client, xmlNode *request, int call_id, request 1522 daemons/execd/execd_commands.c crm_element_value(request, PCMK__XA_LRMD_PROTOCOL_VERSION); request 1531 daemons/execd/execd_commands.c if (pcmk__xe_attr_is_true(request, PCMK__XA_LRMD_IS_IPC_PROVIDER)) { request 1536 daemons/execd/execd_commands.c const char *op = crm_element_value(request, PCMK__XA_LRMD_OP); request 1579 daemons/execd/execd_commands.c process_lrmd_rsc_register(pcmk__client_t *client, uint32_t id, xmlNode *request) request 1582 daemons/execd/execd_commands.c lrmd_rsc_t *rsc = build_rsc_from_xml(request); request 1600 daemons/execd/execd_commands.c process_lrmd_get_rsc_info(xmlNode *request, int call_id) request 1603 daemons/execd/execd_commands.c xmlNode *rsc_xml = pcmk__xpath_find_one(request->doc, request 1632 daemons/execd/execd_commands.c xmlNode *request) request 1636 daemons/execd/execd_commands.c xmlNode *rsc_xml = pcmk__xpath_find_one(request->doc, request 1665 daemons/execd/execd_commands.c process_lrmd_rsc_exec(pcmk__client_t *client, uint32_t id, xmlNode *request) request 1669 daemons/execd/execd_commands.c xmlNode *rsc_xml = pcmk__xpath_find_one(request->doc, request 1684 daemons/execd/execd_commands.c cmd = create_lrmd_cmd(request, client); request 1792 daemons/execd/execd_commands.c process_lrmd_rsc_cancel(pcmk__client_t *client, uint32_t id, xmlNode *request) request 1794 daemons/execd/execd_commands.c xmlNode *rsc_xml = pcmk__xpath_find_one(request->doc, request 1828 daemons/execd/execd_commands.c process_lrmd_get_recurring(xmlNode *request, int call_id) request 1837 daemons/execd/execd_commands.c rsc_xml = pcmk__xe_first_child(request, PCMK__XE_LRMD_CALLDATA, NULL, NULL); request 1874 daemons/execd/execd_commands.c process_lrmd_message(pcmk__client_t *client, uint32_t id, xmlNode *request) request 1878 daemons/execd/execd_commands.c const char *op = crm_element_value(request, PCMK__XA_LRMD_OP); request 1890 daemons/execd/execd_commands.c crm_element_value_int(request, PCMK__XA_LRMD_CALLID, &call_id); request 1895 daemons/execd/execd_commands.c ipc_proxy_forward_client(client, request); request 1904 daemons/execd/execd_commands.c rc = process_lrmd_signon(client, request, call_id, &reply); request 1908 daemons/execd/execd_commands.c rc = process_lrmd_rsc_register(client, id, request); request 1916 daemons/execd/execd_commands.c reply = process_lrmd_get_rsc_info(request, call_id); request 1923 daemons/execd/execd_commands.c rc = process_lrmd_rsc_unregister(client, id, request); request 1934 daemons/execd/execd_commands.c rc = process_lrmd_rsc_exec(client, id, request); request 1941 daemons/execd/execd_commands.c rc = process_lrmd_rsc_cancel(client, id, request); request 1951 daemons/execd/execd_commands.c xmlNode *wrapper = pcmk__xe_first_child(request, request 1966 daemons/execd/execd_commands.c rc = process_lrmd_alert_exec(client, id, request); request 1973 daemons/execd/execd_commands.c reply = process_lrmd_get_recurring(request, call_id); request 2008 daemons/execd/execd_commands.c send_generic_notify(rc, request); request 130 daemons/execd/pacemaker-execd.c xmlNode *request = NULL; request 147 daemons/execd/pacemaker-execd.c request = pcmk__client_data2xml(client, &id, &flags); request 168 daemons/execd/pacemaker-execd.c if (!request) { request 177 daemons/execd/pacemaker-execd.c const char *value = crm_element_value(request, request 192 daemons/execd/pacemaker-execd.c crm_xml_add(request, PCMK__XA_LRMD_CLIENTID, client->id); request 193 daemons/execd/pacemaker-execd.c crm_xml_add(request, PCMK__XA_LRMD_CLIENTNAME, client->name); request 194 daemons/execd/pacemaker-execd.c crm_xml_add_int(request, PCMK__XA_LRMD_CALLID, lrmd_call_id); request 196 daemons/execd/pacemaker-execd.c process_lrmd_message(client, id, request); request 198 daemons/execd/pacemaker-execd.c pcmk__xml_free(request); request 66 daemons/execd/pacemaker-execd.h xmlNode *request); request 104 daemons/execd/pacemaker-execd.h xmlNode *request); request 236 daemons/execd/remoted_proxy.c xmlNode *request = NULL; request 267 daemons/execd/remoted_proxy.c request = pcmk__client_data2xml(client, &id, &flags); request 285 daemons/execd/remoted_proxy.c if (!request) { request 290 daemons/execd/remoted_proxy.c pcmk__xml_free(request); return FALSE); request 292 daemons/execd/remoted_proxy.c pcmk__xml_free(request); return FALSE); request 310 daemons/execd/remoted_proxy.c pcmk__xml_copy(wrapper, request); request 314 daemons/execd/remoted_proxy.c pcmk__xml_free(request); request 90 daemons/execd/remoted_tls.c xmlNode *request = NULL; request 127 daemons/execd/remoted_tls.c request = pcmk__remote_message_xml(client->remote); request 128 daemons/execd/remoted_tls.c if (request == NULL) { request 132 daemons/execd/remoted_tls.c crm_element_value_int(request, PCMK__XA_LRMD_REMOTE_MSG_ID, &id); request 135 daemons/execd/remoted_tls.c client->name = crm_element_value_copy(request, request 144 daemons/execd/remoted_tls.c crm_xml_add(request, PCMK__XA_LRMD_CLIENTID, client->id); request 145 daemons/execd/remoted_tls.c crm_xml_add(request, PCMK__XA_LRMD_CLIENTNAME, client->name); request 146 daemons/execd/remoted_tls.c crm_xml_add_int(request, PCMK__XA_LRMD_CALLID, lrmd_call_id); request 148 daemons/execd/remoted_tls.c process_lrmd_message(client, id, request); request 149 daemons/execd/remoted_tls.c pcmk__xml_free(request); request 2906 daemons/fenced/fenced_commands.c fenced_construct_reply(const xmlNode *request, xmlNode *data, request 2917 daemons/fenced/fenced_commands.c if (request == NULL) { request 2944 daemons/fenced/fenced_commands.c value = crm_element_value(request, name); request 3034 daemons/fenced/fenced_commands.c remove_relay_op(xmlNode * request) request 3036 daemons/fenced/fenced_commands.c xmlNode *dev = pcmk__xpath_find_one(request->doc, request 3049 daemons/fenced/fenced_commands.c relay_op_id = crm_element_value(request, PCMK__XA_ST_REMOTE_OP_RELAY); request 3050 daemons/fenced/fenced_commands.c op_id = crm_element_value(request, PCMK__XA_ST_REMOTE_OP); request 3051 daemons/fenced/fenced_commands.c client_name = crm_element_value(request, PCMK__XA_ST_CLIENTNAME); request 3118 daemons/fenced/fenced_commands.c handle_register_request(pcmk__request_t *request) request 3122 daemons/fenced/fenced_commands.c pcmk__assert(request->ipc_client != NULL); request 3124 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_CLIENTID, request->ipc_client->id); request 3125 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3126 daemons/fenced/fenced_commands.c pcmk__set_request_flags(request, pcmk__request_reuse_options); request 3132 daemons/fenced/fenced_commands.c handle_agent_request(pcmk__request_t *request) request 3134 daemons/fenced/fenced_commands.c execute_agent_action(request->xml, &request->result); request 3135 daemons/fenced/fenced_commands.c if (request->result.execution_status == PCMK_EXEC_PENDING) { request 3138 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3143 daemons/fenced/fenced_commands.c handle_update_timeout_request(pcmk__request_t *request) request 3145 daemons/fenced/fenced_commands.c const char *call_id = crm_element_value(request->xml, PCMK__XA_ST_CALLID); request 3146 daemons/fenced/fenced_commands.c const char *client_id = crm_element_value(request->xml, request 3150 daemons/fenced/fenced_commands.c crm_element_value_int(request->xml, PCMK__XA_ST_TIMEOUT, &op_timeout); request 3152 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3158 daemons/fenced/fenced_commands.c handle_query_request(pcmk__request_t *request) request 3164 daemons/fenced/fenced_commands.c const char *client_id = crm_element_value(request->xml, request 3168 daemons/fenced/fenced_commands.c if (request->peer != NULL) { request 3170 daemons/fenced/fenced_commands.c create_remote_stonith_op(client_id, request->xml, TRUE); request 3174 daemons/fenced/fenced_commands.c remove_relay_op(request->xml); request 3176 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3178 daemons/fenced/fenced_commands.c dev = pcmk__xpath_find_one(request->xml->doc, request 3191 daemons/fenced/fenced_commands.c crm_log_xml_trace(request->xml, "Query"); request 3195 daemons/fenced/fenced_commands.c query->reply = fenced_construct_reply(request->xml, NULL, &request->result); request 3196 daemons/fenced/fenced_commands.c query->remote_peer = pcmk__str_copy(request->peer); request 3200 daemons/fenced/fenced_commands.c query->call_options = request->call_options; request 3202 daemons/fenced/fenced_commands.c crm_element_value_int(request->xml, PCMK__XA_ST_TIMEOUT, &timeout); request 3212 daemons/fenced/fenced_commands.c handle_notify_request(pcmk__request_t *request) request 3216 daemons/fenced/fenced_commands.c pcmk__assert(request->ipc_client != NULL); request 3217 daemons/fenced/fenced_commands.c flag_name = crm_element_value(request->xml, PCMK__XA_ST_NOTIFY_ACTIVATE); request 3220 daemons/fenced/fenced_commands.c flag_name, pcmk__request_origin(request)); request 3221 daemons/fenced/fenced_commands.c pcmk__set_client_flags(request->ipc_client, request 3225 daemons/fenced/fenced_commands.c flag_name = crm_element_value(request->xml, PCMK__XA_ST_NOTIFY_DEACTIVATE); request 3228 daemons/fenced/fenced_commands.c flag_name, pcmk__request_origin(request)); request 3229 daemons/fenced/fenced_commands.c pcmk__clear_client_flags(request->ipc_client, request 3233 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3234 daemons/fenced/fenced_commands.c pcmk__set_request_flags(request, pcmk__request_reuse_options); request 3236 daemons/fenced/fenced_commands.c return pcmk__ipc_create_ack(request->ipc_flags, PCMK__XE_ACK, NULL, request 3242 daemons/fenced/fenced_commands.c handle_relay_request(pcmk__request_t *request) request 3244 daemons/fenced/fenced_commands.c xmlNode *dev = pcmk__xpath_find_one(request->xml->doc, request 3250 daemons/fenced/fenced_commands.c pcmk__request_origin_type(request), request 3251 daemons/fenced/fenced_commands.c pcmk__request_origin(request), request 3255 daemons/fenced/fenced_commands.c if (initiate_remote_stonith_op(NULL, request->xml, FALSE) == NULL) { request 3256 daemons/fenced/fenced_commands.c set_bad_request_result(&request->result); request 3257 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3260 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_PENDING, NULL); request 3266 daemons/fenced/fenced_commands.c handle_fence_request(pcmk__request_t *request) request 3268 daemons/fenced/fenced_commands.c if (request->peer != NULL) { request 3269 daemons/fenced/fenced_commands.c fence_locally(request->xml, &request->result); request 3271 daemons/fenced/fenced_commands.c } else if (pcmk_is_set(request->call_options, st_opt_manual_ack)) { request 3272 daemons/fenced/fenced_commands.c switch (fenced_handle_manual_confirmation(request->ipc_client, request 3273 daemons/fenced/fenced_commands.c request->xml)) { request 3275 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, request 3279 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_PENDING, request 3283 daemons/fenced/fenced_commands.c set_bad_request_result(&request->result); request 3289 daemons/fenced/fenced_commands.c xmlNode *dev = pcmk__xpath_find_one(request->xml->doc, request 3296 daemons/fenced/fenced_commands.c if (request->ipc_client != NULL) { request 3300 daemons/fenced/fenced_commands.c pcmk__request_origin(request), action, request 3304 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, request 3306 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, request 3307 daemons/fenced/fenced_commands.c &request->result); request 3313 daemons/fenced/fenced_commands.c request->peer, action, target, request 3324 daemons/fenced/fenced_commands.c if (request->ipc_client->id == 0) { request 3325 daemons/fenced/fenced_commands.c client_id = crm_element_value(request->xml, request 3328 daemons/fenced/fenced_commands.c client_id = request->ipc_client->id; request 3335 daemons/fenced/fenced_commands.c op = create_remote_stonith_op(client_id, request->xml, FALSE); request 3337 daemons/fenced/fenced_commands.c crm_xml_add(request->xml, PCMK__XA_ST_OP, STONITH_OP_RELAY); request 3338 daemons/fenced/fenced_commands.c crm_xml_add(request->xml, PCMK__XA_ST_CLIENTID, request 3339 daemons/fenced/fenced_commands.c request->ipc_client->id); request 3340 daemons/fenced/fenced_commands.c crm_xml_add(request->xml, PCMK__XA_ST_REMOTE_OP, op->id); request 3343 daemons/fenced/fenced_commands.c pcmk__cluster_send_message(node, pcmk_ipc_fenced, request->xml); request 3345 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_PENDING, request 3348 daemons/fenced/fenced_commands.c } else if (initiate_remote_stonith_op(request->ipc_client, request->xml, request 3350 daemons/fenced/fenced_commands.c set_bad_request_result(&request->result); request 3353 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_PENDING, request 3358 daemons/fenced/fenced_commands.c if (request->result.execution_status == PCMK_EXEC_PENDING) { request 3361 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3366 daemons/fenced/fenced_commands.c handle_history_request(pcmk__request_t *request) request 3371 daemons/fenced/fenced_commands.c stonith_fence_history(request->xml, &data, request->peer, request 3372 daemons/fenced/fenced_commands.c request->call_options); request 3373 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3374 daemons/fenced/fenced_commands.c if (!pcmk_is_set(request->call_options, st_opt_discard_reply)) { request 3378 daemons/fenced/fenced_commands.c reply = fenced_construct_reply(request->xml, data, &request->result); request 3386 daemons/fenced/fenced_commands.c handle_device_add_request(pcmk__request_t *request) request 3388 daemons/fenced/fenced_commands.c const char *op = crm_element_value(request->xml, PCMK__XA_ST_OP); request 3389 daemons/fenced/fenced_commands.c xmlNode *dev = pcmk__xpath_find_one(request->xml->doc, request 3392 daemons/fenced/fenced_commands.c if (is_privileged(request->ipc_client, op)) { request 3396 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, request 3401 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_INSUFFICIENT_PRIV, request 3405 daemons/fenced/fenced_commands.c fenced_send_config_notification(op, &request->result, request 3407 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3412 daemons/fenced/fenced_commands.c handle_device_delete_request(pcmk__request_t *request) request 3414 daemons/fenced/fenced_commands.c xmlNode *dev = pcmk__xpath_find_one(request->xml->doc, request 3417 daemons/fenced/fenced_commands.c const char *op = crm_element_value(request->xml, PCMK__XA_ST_OP); request 3419 daemons/fenced/fenced_commands.c if (is_privileged(request->ipc_client, op)) { request 3421 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3423 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_INSUFFICIENT_PRIV, request 3427 daemons/fenced/fenced_commands.c fenced_send_config_notification(op, &request->result, device_id); request 3428 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3433 daemons/fenced/fenced_commands.c handle_level_add_request(pcmk__request_t *request) request 3435 daemons/fenced/fenced_commands.c const char *op = crm_element_value(request->xml, PCMK__XA_ST_OP); request 3437 daemons/fenced/fenced_commands.c if (is_privileged(request->ipc_client, op)) { request 3438 daemons/fenced/fenced_commands.c fenced_register_level(request->xml, &request->result); request 3440 daemons/fenced/fenced_commands.c unpack_level_request(request->xml, NULL, NULL, NULL); request 3441 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_INSUFFICIENT_PRIV, request 3445 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3450 daemons/fenced/fenced_commands.c handle_level_delete_request(pcmk__request_t *request) request 3452 daemons/fenced/fenced_commands.c const char *op = crm_element_value(request->xml, PCMK__XA_ST_OP); request 3454 daemons/fenced/fenced_commands.c if (is_privileged(request->ipc_client, op)) { request 3455 daemons/fenced/fenced_commands.c fenced_unregister_level(request->xml, &request->result); request 3457 daemons/fenced/fenced_commands.c unpack_level_request(request->xml, NULL, NULL, NULL); request 3458 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_INSUFFICIENT_PRIV, request 3462 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3467 daemons/fenced/fenced_commands.c handle_cache_request(pcmk__request_t *request) request 3472 daemons/fenced/fenced_commands.c crm_element_value_int(request->xml, PCMK_XA_ID, &node_id); request 3473 daemons/fenced/fenced_commands.c name = crm_element_value(request->xml, PCMK_XA_UNAME); request 3475 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3480 daemons/fenced/fenced_commands.c handle_unknown_request(pcmk__request_t *request) request 3483 daemons/fenced/fenced_commands.c request->op, pcmk__request_origin_type(request), request 3484 daemons/fenced/fenced_commands.c pcmk__request_origin(request)); request 3485 daemons/fenced/fenced_commands.c pcmk__format_result(&request->result, CRM_EX_PROTOCOL, PCMK_EXEC_INVALID, request 3486 daemons/fenced/fenced_commands.c "Unknown IPC request type '%s' (bug?)", request->op); request 3487 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3523 daemons/fenced/fenced_commands.c handle_request(pcmk__request_t *request) request 3531 daemons/fenced/fenced_commands.c reply = pcmk__process_request(request, fenced_handlers); request 3533 daemons/fenced/fenced_commands.c if (pcmk_is_set(request->flags, pcmk__request_reuse_options) request 3534 daemons/fenced/fenced_commands.c && (request->ipc_client != NULL)) { request 3539 daemons/fenced/fenced_commands.c pcmk__ipc_send_xml(request->ipc_client, request->ipc_id, reply, request 3540 daemons/fenced/fenced_commands.c request->ipc_flags); request 3541 daemons/fenced/fenced_commands.c request->ipc_client->request_id = 0; request 3543 daemons/fenced/fenced_commands.c stonith_send_reply(reply, request->call_options, request 3544 daemons/fenced/fenced_commands.c request->peer, request->ipc_client); request 3549 daemons/fenced/fenced_commands.c reason = request->result.exit_reason; request 3551 daemons/fenced/fenced_commands.c request->op, pcmk__request_origin_type(request), request 3552 daemons/fenced/fenced_commands.c pcmk__request_origin(request), request 3553 daemons/fenced/fenced_commands.c pcmk_exec_status_str(request->result.execution_status), request 3560 daemons/fenced/fenced_commands.c handle_reply(pcmk__client_t *client, xmlNode *request, const char *remote_peer) request 3563 daemons/fenced/fenced_commands.c char *op = crm_element_value_copy(request, PCMK__XA_ST_OP); request 3566 daemons/fenced/fenced_commands.c process_remote_stonith_query(request); request 3570 daemons/fenced/fenced_commands.c fenced_process_fencing_reply(request); request 3576 daemons/fenced/fenced_commands.c crm_log_xml_warn(request, "UnknownOp"); request 3631 daemons/fenced/fenced_commands.c pcmk__request_t request = { request 3641 daemons/fenced/fenced_commands.c request.op = crm_element_value_copy(request.xml, PCMK__XA_ST_OP); request 3642 daemons/fenced/fenced_commands.c CRM_CHECK(request.op != NULL, return); request 3644 daemons/fenced/fenced_commands.c if (pcmk_is_set(request.call_options, st_opt_sync_call)) { request 3645 daemons/fenced/fenced_commands.c pcmk__set_request_flags(&request, pcmk__request_sync); request 3648 daemons/fenced/fenced_commands.c handle_request(&request); request 3649 daemons/fenced/fenced_commands.c pcmk__reset_request(&request); request 256 daemons/fenced/fenced_remote.c crm_log_xml_debug(op->request, "Destroying"); request 271 daemons/fenced/fenced_remote.c if (op->request) { request 272 daemons/fenced/fenced_remote.c pcmk__xml_free(op->request); request 273 daemons/fenced/fenced_remote.c op->request = NULL; request 466 daemons/fenced/fenced_remote.c reply = fenced_construct_reply(op->request, data, &op->result); request 647 daemons/fenced/fenced_remote.c if (op->request) { request 648 daemons/fenced/fenced_remote.c pcmk__xml_free(op->request); request 649 daemons/fenced/fenced_remote.c op->request = NULL; request 1163 daemons/fenced/fenced_remote.c create_remote_stonith_op(const char *client, xmlNode *request, gboolean peer) request 1166 daemons/fenced/fenced_remote.c xmlNode *dev = pcmk__xpath_find_one(request->doc, request 1191 daemons/fenced/fenced_remote.c crm_element_value_int(request, PCMK__XA_ST_TIMEOUT, &(op->base_timeout)); request 1193 daemons/fenced/fenced_remote.c crm_element_value_int(request, PCMK__XA_ST_DELAY, &(op->client_delay)); request 1227 daemons/fenced/fenced_remote.c operation = crm_element_value(request, PCMK__XA_ST_OP); request 1233 daemons/fenced/fenced_remote.c op->client_name = crm_element_value_copy(request, request 1240 daemons/fenced/fenced_remote.c op->request = pcmk__xml_copy(NULL, request); request 1242 daemons/fenced/fenced_remote.c rc = pcmk__xe_get_flags(request, PCMK__XA_ST_CALLOPT, &(op->call_options), request 1249 daemons/fenced/fenced_remote.c crm_element_value_int(request, PCMK__XA_ST_CALLID, &(op->client_callid)); request 1303 daemons/fenced/fenced_remote.c initiate_remote_stonith_op(const pcmk__client_t *client, xmlNode *request, request 1316 daemons/fenced/fenced_remote.c client_id = crm_element_value(request, PCMK__XA_ST_CLIENTID); request 1320 daemons/fenced/fenced_remote.c op = create_remote_stonith_op(client_id, request, FALSE); request 1366 daemons/fenced/fenced_remote.c operation = crm_element_value(request, PCMK__XA_ST_OP); request 1368 daemons/fenced/fenced_remote.c relay_op_id = crm_element_value(request, PCMK__XA_ST_REMOTE_OP); request 1735 daemons/fenced/fenced_remote.c } else if (!op->request) { request 1740 daemons/fenced/fenced_remote.c client_node = crm_element_value(op->request, PCMK__XA_ST_CLIENTNODE); request 1741 daemons/fenced/fenced_remote.c call_id = crm_element_value(op->request, PCMK__XA_ST_CALLID); request 1742 daemons/fenced/fenced_remote.c client_id = crm_element_value(op->request, PCMK__XA_ST_CLIENTID); request 93 daemons/fenced/pacemaker-fenced.c xmlNode *request = NULL; request 113 daemons/fenced/pacemaker-fenced.c request = pcmk__client_data2xml(c, &id, &flags); request 131 daemons/fenced/pacemaker-fenced.c if (request == NULL) { request 136 daemons/fenced/pacemaker-fenced.c op = crm_element_value(request, PCMK__XA_CRM_TASK); request 138 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, PCMK__XA_T, PCMK__VALUE_STONITH_NG); request 139 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, PCMK__XA_ST_OP, op); request 140 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, PCMK__XA_ST_CLIENTID, c->id); request 141 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, PCMK__XA_ST_CLIENTNAME, pcmk__client_name(c)); request 142 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, PCMK__XA_ST_CLIENTNODE, fenced_get_local_node()); request 144 daemons/fenced/pacemaker-fenced.c pcmk__cluster_send_message(NULL, pcmk_ipc_fenced, request); request 145 daemons/fenced/pacemaker-fenced.c pcmk__xml_free(request); request 150 daemons/fenced/pacemaker-fenced.c const char *value = crm_element_value(request, PCMK__XA_ST_CLIENTNAME); request 155 daemons/fenced/pacemaker-fenced.c rc = pcmk__xe_get_flags(request, PCMK__XA_ST_CALLOPT, &call_options, request 171 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, PCMK__XA_ST_CLIENTID, c->id); request 172 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, PCMK__XA_ST_CLIENTNAME, pcmk__client_name(c)); request 173 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, PCMK__XA_ST_CLIENTNODE, fenced_get_local_node()); request 175 daemons/fenced/pacemaker-fenced.c crm_log_xml_trace(request, "ipc-received"); request 176 daemons/fenced/pacemaker-fenced.c stonith_command(c, id, flags, request, NULL); request 178 daemons/fenced/pacemaker-fenced.c pcmk__xml_free(request); request 234 daemons/fenced/pacemaker-fenced.h xmlNode *request; request 328 daemons/fenced/pacemaker-fenced.h xmlNode *fenced_construct_reply(const xmlNode *request, xmlNode *data, request 342 daemons/fenced/pacemaker-fenced.h xmlNode *request, request 349 daemons/fenced/pacemaker-fenced.h void *create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer); request 26 daemons/pacemakerd/pcmkd_messages.c handle_node_cache_request(pcmk__request_t *request) request 30 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(request->ipc_client)); request 32 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags, request 38 daemons/pacemakerd/pcmkd_messages.c handle_ping_request(pcmk__request_t *request) request 40 daemons/pacemakerd/pcmkd_messages.c xmlNode *msg = request->xml; request 53 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags, request 68 daemons/pacemakerd/pcmkd_messages.c pcmk__format_result(&request->result, CRM_EX_ERROR, PCMK_EXEC_ERROR, request 70 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(request->ipc_client)); request 72 daemons/pacemakerd/pcmkd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 83 daemons/pacemakerd/pcmkd_messages.c shutdown_complete_state_reported_to = request->ipc_client->pid; request 97 daemons/pacemakerd/pcmkd_messages.c handle_shutdown_request(pcmk__request_t *request) request 99 daemons/pacemakerd/pcmkd_messages.c xmlNode *msg = request->xml; request 108 daemons/pacemakerd/pcmkd_messages.c bool allowed = pcmk_is_set(request->ipc_client->flags, pcmk__client_privileged); request 110 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags, request 122 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(request->ipc_client)); request 130 daemons/pacemakerd/pcmkd_messages.c pcmk__format_result(&request->result, CRM_EX_ERROR, PCMK_EXEC_ERROR, request 132 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(request->ipc_client)); request 134 daemons/pacemakerd/pcmkd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 145 daemons/pacemakerd/pcmkd_messages.c handle_unknown_request(pcmk__request_t *request) request 147 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags, request 150 daemons/pacemakerd/pcmkd_messages.c pcmk__format_result(&request->result, CRM_EX_PROTOCOL, PCMK_EXEC_INVALID, request 152 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(request->ipc_client)); request 259 daemons/pacemakerd/pcmkd_messages.c pcmk__request_t request = { request 269 daemons/pacemakerd/pcmkd_messages.c request.op = crm_element_value_copy(request.xml, PCMK__XA_CRM_TASK); request 270 daemons/pacemakerd/pcmkd_messages.c CRM_CHECK(request.op != NULL, return 0); request 272 daemons/pacemakerd/pcmkd_messages.c reply = pcmk__process_request(&request, pcmkd_handlers); request 279 daemons/pacemakerd/pcmkd_messages.c reason = request.result.exit_reason; request 282 daemons/pacemakerd/pcmkd_messages.c request.op, pcmk__request_origin_type(&request), request 283 daemons/pacemakerd/pcmkd_messages.c pcmk__request_origin(&request), request 284 daemons/pacemakerd/pcmkd_messages.c pcmk_exec_status_str(request.result.execution_status), request 289 daemons/pacemakerd/pcmkd_messages.c if (!pcmk__result_ok(&request.result)) { request 296 daemons/pacemakerd/pcmkd_messages.c pcmk__reset_request(&request); request 36 daemons/schedulerd/schedulerd_messages.c handle_pecalc_request(pcmk__request_t *request) request 52 daemons/schedulerd/schedulerd_messages.c xmlNode *msg = request->xml; request 71 daemons/schedulerd/schedulerd_messages.c pcmk__ipc_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags, request 133 daemons/schedulerd/schedulerd_messages.c pcmk__format_result(&request->result, CRM_EX_ERROR, PCMK_EXEC_ERROR, request 135 daemons/schedulerd/schedulerd_messages.c pcmk__client_name(request->ipc_client)); request 168 daemons/schedulerd/schedulerd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 178 daemons/schedulerd/schedulerd_messages.c handle_unknown_request(pcmk__request_t *request) request 180 daemons/schedulerd/schedulerd_messages.c pcmk__ipc_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags, request 183 daemons/schedulerd/schedulerd_messages.c pcmk__format_result(&request->result, CRM_EX_PROTOCOL, PCMK_EXEC_INVALID, request 185 daemons/schedulerd/schedulerd_messages.c pcmk__client_name(request->ipc_client)); request 190 daemons/schedulerd/schedulerd_messages.c handle_hello_request(pcmk__request_t *request) request 192 daemons/schedulerd/schedulerd_messages.c pcmk__ipc_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags, request 195 daemons/schedulerd/schedulerd_messages.c crm_trace("Received IPC hello from %s", pcmk__client_name(request->ipc_client)); request 197 daemons/schedulerd/schedulerd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 291 daemons/schedulerd/schedulerd_messages.c pcmk__request_t request = { request 301 daemons/schedulerd/schedulerd_messages.c request.op = crm_element_value_copy(request.xml, PCMK__XA_CRM_TASK); request 302 daemons/schedulerd/schedulerd_messages.c CRM_CHECK(request.op != NULL, return 0); request 304 daemons/schedulerd/schedulerd_messages.c reply = pcmk__process_request(&request, schedulerd_handlers); request 311 daemons/schedulerd/schedulerd_messages.c reason = request.result.exit_reason; request 314 daemons/schedulerd/schedulerd_messages.c request.op, pcmk__request_origin_type(&request), request 315 daemons/schedulerd/schedulerd_messages.c pcmk__request_origin(&request), request 316 daemons/schedulerd/schedulerd_messages.c pcmk_exec_status_str(request.result.execution_status), request 321 daemons/schedulerd/schedulerd_messages.c if (!pcmk__result_ok(&request.result)) { request 328 daemons/schedulerd/schedulerd_messages.c pcmk__reset_request(&request); request 186 include/crm/cib/internal.h int cib__extend_transaction(cib_t *cib, xmlNode *request); request 25 include/crm/common/acl_internal.h const char *pcmk__update_acl_user(xmlNode *request, const char *field, request 244 include/crm/common/ipc_internal.h uint32_t request, uint32_t flags, const char *tag, request 249 include/crm/common/ipc_internal.h int pcmk__ipc_prepare_iov(uint32_t request, const GString *message, request 251 include/crm/common/ipc_internal.h int pcmk__ipc_send_xml(pcmk__client_t *c, uint32_t request, request 68 include/crm/common/messages_internal.h #define pcmk__set_request_flags(request, flags_to_set) do { \ request 69 include/crm/common/messages_internal.h (request)->flags = pcmk__set_flags_as(__func__, __LINE__, \ request 70 include/crm/common/messages_internal.h LOG_TRACE, "Request", "message", (request)->flags, \ request 77 include/crm/common/messages_internal.h xmlNode *(*handler)(pcmk__request_t *request); request 175 include/crm/common/messages_internal.h xmlNode *pcmk__process_request(pcmk__request_t *request, GHashTable *handlers); request 176 include/crm/common/messages_internal.h void pcmk__reset_request(pcmk__request_t *request); request 188 include/crm/common/messages_internal.h pcmk__request_origin_type(const pcmk__request_t *request) request 190 include/crm/common/messages_internal.h if ((request != NULL) && (request->ipc_client != NULL)) { request 192 include/crm/common/messages_internal.h } else if ((request != NULL) && (request->peer != NULL)) { request 209 include/crm/common/messages_internal.h pcmk__request_origin(const pcmk__request_t *request) request 211 include/crm/common/messages_internal.h if ((request != NULL) && (request->ipc_client != NULL)) { request 212 include/crm/common/messages_internal.h return pcmk__client_name(request->ipc_client); request 213 include/crm/common/messages_internal.h } else if ((request != NULL) && (request->peer != NULL)) { request 214 include/crm/common/messages_internal.h return request->peer; request 189 include/crm/common/output_internal.h gchar *request; request 213 lib/cib/cib_file.c cib_file_process_request(cib_t *cib, xmlNode *request, xmlNode **output) request 221 lib/cib/cib_file.c const char *op = crm_element_value(request, PCMK__XA_CIB_OP); request 222 lib/cib/cib_file.c const char *section = crm_element_value(request, PCMK__XA_CIB_SECTION); request 223 lib/cib/cib_file.c xmlNode *wrapper = pcmk__xe_first_child(request, PCMK__XE_CIB_CALLDATA, request 238 lib/cib/cib_file.c crm_element_value_int(request, PCMK__XA_CIB_CALLID, &call_id); request 239 lib/cib/cib_file.c rc = pcmk__xe_get_flags(request, PCMK__XA_CIB_CALLOPT, &call_options, request 254 lib/cib/cib_file.c request, data, true, &changed, &private->cib_xml, request 293 lib/cib/cib_file.c xmlNode *request = NULL; request 327 lib/cib/cib_file.c NULL, &request); request 331 lib/cib/cib_file.c crm_xml_add(request, PCMK__XA_ACL_TARGET, user_name); request 332 lib/cib/cib_file.c crm_xml_add(request, PCMK__XA_CIB_CLIENTID, private->id); request 335 lib/cib/cib_file.c rc = cib__extend_transaction(cib, request); request 339 lib/cib/cib_file.c rc = cib_file_process_request(cib, request, &output); request 356 lib/cib/cib_file.c pcmk__xml_free(request); request 1063 lib/cib/cib_file.c for (xmlNode *request = pcmk__xe_first_child(transaction, request 1066 lib/cib/cib_file.c request != NULL; request 1067 lib/cib/cib_file.c request = pcmk__xe_next(request, PCMK__XE_CIB_COMMAND)) { request 1070 lib/cib/cib_file.c const char *op = crm_element_value(request, PCMK__XA_CIB_OP); request 1072 lib/cib/cib_file.c int rc = cib_file_process_request(cib, request, &output); request 1079 lib/cib/cib_file.c crm_log_xml_info(request, "Failed request"); request 1086 lib/cib/cib_file.c crm_log_xml_trace(request, "Successful request"); request 601 lib/cib/cib_utils.c validate_transaction_request(const xmlNode *request) request 603 lib/cib/cib_utils.c const char *op = crm_element_value(request, PCMK__XA_CIB_OP); request 604 lib/cib/cib_utils.c const char *host = crm_element_value(request, PCMK__XA_CIB_HOST); request 637 lib/cib/cib_utils.c cib__extend_transaction(cib_t *cib, xmlNode *request) request 641 lib/cib/cib_utils.c pcmk__assert((cib != NULL) && (request != NULL)); request 643 lib/cib/cib_utils.c rc = validate_transaction_request(request); request 650 lib/cib/cib_utils.c pcmk__xml_copy(cib->transaction, request); request 653 lib/cib/cib_utils.c const char *op = crm_element_value(request, PCMK__XA_CIB_OP); request 659 lib/cib/cib_utils.c crm_log_xml_info(request, "failed"); request 853 lib/common/acl.c pcmk__update_acl_user(xmlNode *request, const char *field, request 868 lib/common/acl.c requested_user = crm_element_value(request, PCMK__XA_ACL_TARGET); request 878 lib/common/acl.c requested_user = crm_element_value(request, field); request 913 lib/common/acl.c if (user != crm_element_value(request, PCMK__XA_ACL_TARGET)) { request 914 lib/common/acl.c crm_xml_add(request, PCMK__XA_ACL_TARGET, user); request 917 lib/common/acl.c if (field != NULL && user != crm_element_value(request, field)) { request 918 lib/common/acl.c crm_xml_add(request, field, user); request 272 lib/common/crmcommon_private.h bool (*reply_expected)(pcmk_ipc_api_t *api, const xmlNode *request); request 316 lib/common/crmcommon_private.h int pcmk__send_ipc_request(pcmk_ipc_api_t *api, const xmlNode *request); request 45 lib/common/ipc_attrd.c reply_expected(pcmk_ipc_api_t *api, const xmlNode *request) request 47 lib/common/ipc_attrd.c const char *command = crm_element_value(request, PCMK_XA_TASK); request 151 lib/common/ipc_attrd.c connect_and_send_attrd_request(pcmk_ipc_api_t *api, const xmlNode *request) request 178 lib/common/ipc_attrd.c rc = pcmk__send_ipc_request(api, request); request 196 lib/common/ipc_attrd.c xmlNode *request = create_attrd_op(user_name); request 216 lib/common/ipc_attrd.c crm_xml_add(request, PCMK_XA_TASK, PCMK__ATTRD_CMD_CLEAR_FAILURE); request 217 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_ATTR_HOST, node); request 218 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_ATTR_RESOURCE, resource); request 219 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_ATTR_CLEAR_OPERATION, operation); request 220 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_ATTR_CLEAR_INTERVAL, interval_spec); request 221 lib/common/ipc_attrd.c crm_xml_add_int(request, PCMK__XA_ATTR_IS_REMOTE, request 224 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 226 lib/common/ipc_attrd.c pcmk__xml_free(request); request 257 lib/common/ipc_attrd.c xmlNode *request = NULL; request 269 lib/common/ipc_attrd.c request = create_attrd_op(NULL); request 271 lib/common/ipc_attrd.c crm_xml_add(request, PCMK_XA_TASK, PCMK__ATTRD_CMD_PEER_REMOVE); request 272 lib/common/ipc_attrd.c pcmk__xe_set_bool_attr(request, PCMK__XA_REAP, reap); request 273 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_ATTR_HOST, node); request 275 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 277 lib/common/ipc_attrd.c pcmk__xml_free(request); request 286 lib/common/ipc_attrd.c xmlNode *request = NULL; request 309 lib/common/ipc_attrd.c request = create_attrd_op(NULL); request 311 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_ATTR_NAME, name); request 312 lib/common/ipc_attrd.c crm_xml_add(request, PCMK_XA_TASK, PCMK__ATTRD_CMD_QUERY); request 313 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_ATTR_HOST, node); request 315 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 316 lib/common/ipc_attrd.c pcmk__xml_free(request); request 324 lib/common/ipc_attrd.c xmlNode *request = NULL; request 334 lib/common/ipc_attrd.c request = create_attrd_op(NULL); request 336 lib/common/ipc_attrd.c crm_xml_add(request, PCMK_XA_TASK, PCMK__ATTRD_CMD_REFRESH); request 337 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_ATTR_HOST, node); request 339 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 341 lib/common/ipc_attrd.c pcmk__xml_free(request); request 397 lib/common/ipc_attrd.c xmlNode *request = NULL; request 414 lib/common/ipc_attrd.c request = create_attrd_op(user_name); request 415 lib/common/ipc_attrd.c populate_update_op(request, node, name, value, dampen, set, options); request 417 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 419 lib/common/ipc_attrd.c pcmk__xml_free(request); request 429 lib/common/ipc_attrd.c xmlNode *request = NULL; request 465 lib/common/ipc_attrd.c if (request == NULL) { request 466 lib/common/ipc_attrd.c request = create_attrd_op(user_name); request 467 lib/common/ipc_attrd.c add_op_attr(request, options); request 475 lib/common/ipc_attrd.c child = pcmk__xe_create(request, PCMK_XE_OP); request 494 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 495 lib/common/ipc_attrd.c pcmk__xml_free(request); request 684 lib/common/ipc_client.c pcmk__send_ipc_request(pcmk_ipc_api_t *api, const xmlNode *request) request 690 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL) || (request == NULL)) { request 693 lib/common/ipc_client.c crm_log_xml_trace(request, "ipc-sent"); request 699 lib/common/ipc_client.c && (api->cmds->reply_expected(api, request))) { request 708 lib/common/ipc_client.c rc = crm_ipc_send(api->ipc, request, flags, 0, &reply); request 774 lib/common/ipc_client.c xmlNode *request = NULL; request 779 lib/common/ipc_client.c request = pcmk__xe_create(NULL, __func__); request 780 lib/common/ipc_client.c crm_xml_add(request, PCMK__XA_T, PCMK__VALUE_ATTRD); request 781 lib/common/ipc_client.c crm_xml_add(request, PCMK__XA_SRC, crm_system_name); request 782 lib/common/ipc_client.c crm_xml_add(request, PCMK_XA_TASK, PCMK__ATTRD_CMD_PEER_REMOVE); request 783 lib/common/ipc_client.c pcmk__xe_set_bool_attr(request, PCMK__XA_REAP, true); request 784 lib/common/ipc_client.c crm_xml_add(request, PCMK__XA_ATTR_HOST, node_name); request 786 lib/common/ipc_client.c crm_xml_add_int(request, PCMK__XA_ATTR_HOST_ID, nodeid); request 793 lib/common/ipc_client.c request = pcmk__new_request(api->server, client, NULL, request 797 lib/common/ipc_client.c crm_xml_add_ll(request, PCMK_XA_ID, (long long) nodeid); request 799 lib/common/ipc_client.c crm_xml_add(request, PCMK_XA_UNAME, node_name); request 810 lib/common/ipc_client.c return request; request 828 lib/common/ipc_client.c xmlNode *request = NULL; request 837 lib/common/ipc_client.c request = create_purge_node_request(api, node_name, nodeid); request 838 lib/common/ipc_client.c if (request == NULL) { request 841 lib/common/ipc_client.c rc = pcmk__send_ipc_request(api, request); request 842 lib/common/ipc_client.c pcmk__xml_free(request); request 187 lib/common/ipc_controld.c reply_expected(pcmk_ipc_api_t *api, const xmlNode *request) request 190 lib/common/ipc_controld.c return pcmk__str_any_of(crm_element_value(request, PCMK__XA_CRM_TASK), request 331 lib/common/ipc_controld.c xmlNode *request = NULL; request 344 lib/common/ipc_controld.c request = pcmk__new_request(pcmk_ipc_controld, sender_system, node, sys_to, request 347 lib/common/ipc_controld.c return request; request 352 lib/common/ipc_controld.c send_controller_request(pcmk_ipc_api_t *api, const xmlNode *request, request 355 lib/common/ipc_controld.c if (crm_element_value(request, PCMK_XA_REFERENCE) == NULL) { request 363 lib/common/ipc_controld.c return pcmk__send_ipc_request(api, request); request 393 lib/common/ipc_controld.c xmlNode *request; request 407 lib/common/ipc_controld.c request = create_controller_request(api, CRM_OP_REPROBE, router_node, request 409 lib/common/ipc_controld.c rc = send_controller_request(api, request, true); request 411 lib/common/ipc_controld.c pcmk__xml_free(request); request 427 lib/common/ipc_controld.c xmlNode *request; request 430 lib/common/ipc_controld.c request = create_controller_request(api, CRM_OP_NODE_INFO, NULL, NULL); request 431 lib/common/ipc_controld.c if (request == NULL) { request 435 lib/common/ipc_controld.c crm_xml_add_ll(request, PCMK_XA_ID, nodeid); request 438 lib/common/ipc_controld.c rc = send_controller_request(api, request, true); request 439 lib/common/ipc_controld.c pcmk__xml_free(request); request 455 lib/common/ipc_controld.c xmlNode *request; request 458 lib/common/ipc_controld.c request = create_controller_request(api, CRM_OP_PING, node_name, NULL); request 459 lib/common/ipc_controld.c if (request == NULL) { request 462 lib/common/ipc_controld.c rc = send_controller_request(api, request, true); request 463 lib/common/ipc_controld.c pcmk__xml_free(request); request 478 lib/common/ipc_controld.c xmlNode *request; request 481 lib/common/ipc_controld.c request = create_controller_request(api, PCMK__CONTROLD_CMD_NODES, NULL, request 483 lib/common/ipc_controld.c if (request != NULL) { request 484 lib/common/ipc_controld.c rc = send_controller_request(api, request, true); request 485 lib/common/ipc_controld.c pcmk__xml_free(request); request 500 lib/common/ipc_controld.c xmlNode *request, *msg_data, *xml_rsc, *params; request 545 lib/common/ipc_controld.c request = create_controller_request(api, op, router_node, msg_data); request 546 lib/common/ipc_controld.c rc = send_controller_request(api, request, true); request 548 lib/common/ipc_controld.c pcmk__xml_free(request); request 181 lib/common/ipc_pacemakerd.c reply_expected(pcmk_ipc_api_t *api, const xmlNode *request) request 183 lib/common/ipc_pacemakerd.c const char *command = crm_element_value(request, PCMK__XA_CRM_TASK); request 64 lib/common/ipc_schedulerd.c reply_expected(pcmk_ipc_api_t *api, const xmlNode *request) request 66 lib/common/ipc_schedulerd.c const char *command = crm_element_value(request, PCMK__XA_CRM_TASK); request 595 lib/common/ipc_server.c pcmk__ipc_prepare_iov(uint32_t request, const GString *message, uint16_t index, request 677 lib/common/ipc_server.c header->qb.id = (int32_t)request; /* Replying to a specific request */ request 822 lib/common/ipc_server.c pcmk__ipc_send_xml(pcmk__client_t *c, uint32_t request, const xmlNode *message, request 851 lib/common/ipc_server.c rc = pcmk__ipc_prepare_iov(request, iov_buffer, index, &iov, NULL); request 984 lib/common/ipc_server.c uint32_t request, uint32_t flags, const char *tag, request 995 lib/common/ipc_server.c rc = pcmk__ipc_send_xml(c, request, ack, flags); request 210 lib/common/messages.c pcmk__process_request(pcmk__request_t *request, GHashTable *handlers) request 212 lib/common/messages.c xmlNode *(*handler)(pcmk__request_t *request) = NULL; request 214 lib/common/messages.c CRM_CHECK((request != NULL) && (request->op != NULL) && (handlers != NULL), request 217 lib/common/messages.c if (pcmk_is_set(request->flags, pcmk__request_sync) request 218 lib/common/messages.c && (request->ipc_client != NULL)) { request 219 lib/common/messages.c CRM_CHECK(request->ipc_client->request_id == request->ipc_id, request 223 lib/common/messages.c handler = g_hash_table_lookup(handlers, request->op); request 228 lib/common/messages.c request->op, pcmk__request_origin_type(request), request 229 lib/common/messages.c pcmk__request_origin(request)); request 234 lib/common/messages.c return (*handler)(request); request 244 lib/common/messages.c pcmk__reset_request(pcmk__request_t *request) request 246 lib/common/messages.c free(request->op); request 247 lib/common/messages.c request->op = NULL; request 249 lib/common/messages.c pcmk__reset_result(&(request->result)); request 41 lib/common/output.c g_free(out->request); request 169 lib/common/output_html.c } else if (out->request != NULL) { request 171 lib/common/output_html.c pcmk__xe_set_content(child_node, "%s", out->request); request 421 lib/common/output_html.c retval->request = pcmk__quote_cmdline(argv); request 323 lib/common/output_log.c retval->request = pcmk__quote_cmdline(argv); request 120 lib/common/output_none.c retval->request = pcmk__quote_cmdline(argv); request 320 lib/common/output_text.c retval->request = pcmk__quote_cmdline(argv); request 123 lib/common/output_xml.c pcmk__s(out->request, "libpacemaker")); request 451 lib/common/output_xml.c retval->request = pcmk__quote_cmdline(argv); request 244 lib/lrmd/proxy_common.c xmlNode *request = pcmk__xe_first_child(wrapper, NULL, NULL, NULL); request 246 lib/lrmd/proxy_common.c CRM_CHECK(request != NULL, return); request 263 lib/lrmd/proxy_common.c crm_xml_add(request, PCMK_XE_ACL_ROLE, "pacemaker-remote"); request 272 lib/lrmd/proxy_common.c pcmk__update_acl_user(request, PCMK__XA_LRMD_IPC_USER, node_name); request 275 lib/lrmd/proxy_common.c const char *type = crm_element_value(request, PCMK__XA_T); request 279 lib/lrmd/proxy_common.c && (crm_element_value(request, PCMK__XA_ATTR_HOST) == NULL) request 280 lib/lrmd/proxy_common.c && pcmk__str_any_of(crm_element_value(request, PCMK_XA_TASK), request 285 lib/lrmd/proxy_common.c crm_xml_add(request, PCMK__XA_ATTR_HOST, proxy->node_name); request 288 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 5000, NULL); request 317 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 10000, &op_reply); request 346 tools/crm_mon_curses.c retval->request = pcmk__quote_cmdline(argv);