request 46 daemons/attrd/attrd_corosync.c pcmk__request_t request = { request 56 daemons/attrd/attrd_corosync.c request.op = crm_element_value_copy(request.xml, PCMK__XA_TASK); request 57 daemons/attrd/attrd_corosync.c CRM_CHECK(request.op != NULL, return); request 59 daemons/attrd/attrd_corosync.c attrd_handle_request(&request); request 60 daemons/attrd/attrd_corosync.c pcmk__reset_request(&request); request 414 daemons/attrd/attrd_corosync.c attrd_peer_clear_failure(pcmk__request_t *request) request 416 daemons/attrd/attrd_corosync.c xmlNode *xml = request->xml; request 426 daemons/attrd/attrd_corosync.c crm_node_t *peer = crm_get_peer(0, request->peer); request 99 daemons/attrd/attrd_ipc.c attrd_client_clear_failure(pcmk__request_t *request) request 101 daemons/attrd/attrd_ipc.c xmlNode *xml = request->xml; request 104 daemons/attrd/attrd_ipc.c attrd_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags); request 111 daemons/attrd/attrd_ipc.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 152 daemons/attrd/attrd_ipc.c return attrd_client_update(request); request 156 daemons/attrd/attrd_ipc.c attrd_client_peer_remove(pcmk__request_t *request) request 158 daemons/attrd/attrd_ipc.c xmlNode *xml = request->xml; request 164 daemons/attrd/attrd_ipc.c attrd_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags); request 188 daemons/attrd/attrd_ipc.c pcmk__client_name(request->ipc_client), host); request 193 daemons/attrd/attrd_ipc.c pcmk__client_name(request->ipc_client)); request 196 daemons/attrd/attrd_ipc.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 201 daemons/attrd/attrd_ipc.c attrd_client_query(pcmk__request_t *request) request 203 daemons/attrd/attrd_ipc.c xmlNode *query = request->xml; request 207 daemons/attrd/attrd_ipc.c crm_debug("Query arrived from %s", pcmk__client_name(request->ipc_client)); request 212 daemons/attrd/attrd_ipc.c pcmk__format_result(&request->result, CRM_EX_ERROR, PCMK_EXEC_ERROR, request 214 daemons/attrd/attrd_ipc.c pcmk__client_name(request->ipc_client)); request 222 daemons/attrd/attrd_ipc.c pcmk__format_result(&request->result, CRM_EX_ERROR, PCMK_EXEC_ERROR, request 224 daemons/attrd/attrd_ipc.c pcmk__client_name(request->ipc_client)); request 227 daemons/attrd/attrd_ipc.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 230 daemons/attrd/attrd_ipc.c request->ipc_client->request_id = 0; request 235 daemons/attrd/attrd_ipc.c attrd_client_refresh(pcmk__request_t *request) request 239 daemons/attrd/attrd_ipc.c attrd_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags); request 242 daemons/attrd/attrd_ipc.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 289 daemons/attrd/attrd_ipc.c attrd_client_update(pcmk__request_t *request) request 291 daemons/attrd/attrd_ipc.c xmlNode *xml = request->xml; request 312 daemons/attrd/attrd_ipc.c if (handle_value_expansion(&value, child, request->op, attr) == EINVAL) { request 313 daemons/attrd/attrd_ipc.c pcmk__format_result(&request->result, CRM_EX_NOSUCH, PCMK_EXEC_ERROR, request 320 daemons/attrd/attrd_ipc.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 329 daemons/attrd/attrd_ipc.c request->xml = child; request 333 daemons/attrd/attrd_ipc.c attrd_client_update(request); request 351 daemons/attrd/attrd_ipc.c pcmk__format_result(&request->result, CRM_EX_ERROR, PCMK_EXEC_ERROR, request 353 daemons/attrd/attrd_ipc.c pcmk__client_name(request->ipc_client)); request 367 daemons/attrd/attrd_ipc.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 376 daemons/attrd/attrd_ipc.c pcmk__format_result(&request->result, CRM_EX_ERROR, PCMK_EXEC_ERROR, request 378 daemons/attrd/attrd_ipc.c pcmk__client_name(request->ipc_client)); request 384 daemons/attrd/attrd_ipc.c if (handle_value_expansion(&value, xml, request->op, attr) == EINVAL) { request 385 daemons/attrd/attrd_ipc.c pcmk__format_result(&request->result, CRM_EX_NOSUCH, PCMK_EXEC_ERROR, request 394 daemons/attrd/attrd_ipc.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 485 daemons/attrd/attrd_ipc.c pcmk__request_t request = { request 498 daemons/attrd/attrd_ipc.c request.op = crm_element_value_copy(request.xml, PCMK__XA_TASK); request 499 daemons/attrd/attrd_ipc.c CRM_CHECK(request.op != NULL, return 0); request 501 daemons/attrd/attrd_ipc.c attrd_handle_request(&request); request 502 daemons/attrd/attrd_ipc.c pcmk__reset_request(&request); request 24 daemons/attrd/attrd_messages.c handle_unknown_request(pcmk__request_t *request) request 27 daemons/attrd/attrd_messages.c request->op, pcmk__request_origin_type(request), request 28 daemons/attrd/attrd_messages.c pcmk__request_origin(request)); request 29 daemons/attrd/attrd_messages.c pcmk__format_result(&request->result, CRM_EX_PROTOCOL, PCMK_EXEC_INVALID, request 30 daemons/attrd/attrd_messages.c "Unknown request type '%s' (bug?)", request->op); request 35 daemons/attrd/attrd_messages.c handle_clear_failure_request(pcmk__request_t *request) request 37 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 41 daemons/attrd/attrd_messages.c attrd_peer_clear_failure(request); request 42 daemons/attrd/attrd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 45 daemons/attrd/attrd_messages.c return attrd_client_clear_failure(request); request 50 daemons/attrd/attrd_messages.c handle_flush_request(pcmk__request_t *request) request 52 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 56 daemons/attrd/attrd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 59 daemons/attrd/attrd_messages.c return handle_unknown_request(request); request 64 daemons/attrd/attrd_messages.c handle_query_request(pcmk__request_t *request) request 66 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 67 daemons/attrd/attrd_messages.c return handle_unknown_request(request); request 69 daemons/attrd/attrd_messages.c return attrd_client_query(request); request 74 daemons/attrd/attrd_messages.c handle_remove_request(pcmk__request_t *request) request 76 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 77 daemons/attrd/attrd_messages.c const char *host = crm_element_value(request->xml, PCMK__XA_ATTR_NODE_NAME); request 78 daemons/attrd/attrd_messages.c attrd_peer_remove(host, true, request->peer); request 79 daemons/attrd/attrd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 82 daemons/attrd/attrd_messages.c return attrd_client_peer_remove(request); request 87 daemons/attrd/attrd_messages.c handle_refresh_request(pcmk__request_t *request) request 89 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 90 daemons/attrd/attrd_messages.c return handle_unknown_request(request); request 92 daemons/attrd/attrd_messages.c return attrd_client_refresh(request); request 97 daemons/attrd/attrd_messages.c handle_sync_request(pcmk__request_t *request) request 99 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 100 daemons/attrd/attrd_messages.c crm_node_t *peer = crm_get_peer(0, request->peer); request 102 daemons/attrd/attrd_messages.c attrd_peer_sync(peer, request->xml); request 103 daemons/attrd/attrd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 106 daemons/attrd/attrd_messages.c return handle_unknown_request(request); request 111 daemons/attrd/attrd_messages.c handle_sync_response_request(pcmk__request_t *request) request 113 daemons/attrd/attrd_messages.c if (request->ipc_client != NULL) { request 114 daemons/attrd/attrd_messages.c return handle_unknown_request(request); request 116 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 117 daemons/attrd/attrd_messages.c crm_node_t *peer = crm_get_peer(0, request->peer); request 118 daemons/attrd/attrd_messages.c bool peer_won = attrd_check_for_new_writer(peer, request->xml); request 121 daemons/attrd/attrd_messages.c attrd_peer_sync_response(peer, peer_won, request->xml); request 125 daemons/attrd/attrd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 131 daemons/attrd/attrd_messages.c handle_update_request(pcmk__request_t *request) request 133 daemons/attrd/attrd_messages.c if (request->peer != NULL) { request 134 daemons/attrd/attrd_messages.c const char *host = crm_element_value(request->xml, PCMK__XA_ATTR_NODE_NAME); request 135 daemons/attrd/attrd_messages.c crm_node_t *peer = crm_get_peer(0, request->peer); request 137 daemons/attrd/attrd_messages.c attrd_peer_update(peer, request->xml, host, false); request 138 daemons/attrd/attrd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 144 daemons/attrd/attrd_messages.c attrd_send_ack(request->ipc_client, request->ipc_id, request 145 daemons/attrd/attrd_messages.c request->flags|crm_ipc_client_response); request 146 daemons/attrd/attrd_messages.c return attrd_client_update(request); request 180 daemons/attrd/attrd_messages.c attrd_handle_request(pcmk__request_t *request) request 190 daemons/attrd/attrd_messages.c reply = pcmk__process_request(request, attrd_handlers); request 195 daemons/attrd/attrd_messages.c if (request->ipc_client != NULL) { request 196 daemons/attrd/attrd_messages.c pcmk__ipc_send_xml(request->ipc_client, request->ipc_id, reply, request 197 daemons/attrd/attrd_messages.c request->ipc_flags); request 205 daemons/attrd/attrd_messages.c reason = request->result.exit_reason; request 207 daemons/attrd/attrd_messages.c request->op, pcmk__request_origin_type(request), request 208 daemons/attrd/attrd_messages.c pcmk__request_origin(request), request 209 daemons/attrd/attrd_messages.c pcmk_exec_status_str(request->result.execution_status), request 214 daemons/attrd/attrd_messages.c if (!pcmk__result_ok(&request->result)) { request 221 daemons/attrd/attrd_messages.c pcmk__reset_request(request); request 154 daemons/attrd/pacemaker-attrd.h void attrd_peer_clear_failure(pcmk__request_t *request); request 159 daemons/attrd/pacemaker-attrd.h xmlNode *attrd_client_peer_remove(pcmk__request_t *request); request 160 daemons/attrd/pacemaker-attrd.h xmlNode *attrd_client_clear_failure(pcmk__request_t *request); request 161 daemons/attrd/pacemaker-attrd.h xmlNode *attrd_client_update(pcmk__request_t *request); request 162 daemons/attrd/pacemaker-attrd.h xmlNode *attrd_client_refresh(pcmk__request_t *request); request 163 daemons/attrd/pacemaker-attrd.h xmlNode *attrd_client_query(pcmk__request_t *request); request 183 daemons/attrd/pacemaker-attrd.h void attrd_handle_request(pcmk__request_t *request); request 53 daemons/based/based_callbacks.c static void cib_process_request(xmlNode *request, gboolean privileged, request 57 daemons/based/based_callbacks.c static int cib_process_command(xmlNode *request, xmlNode **reply, request 274 daemons/based/based_callbacks.c int sync_our_cib(xmlNode * request, gboolean all); request 598 daemons/based/based_callbacks.c parse_peer_options_v1(int call_type, xmlNode * request, request 605 daemons/based/based_callbacks.c const char *originator = crm_element_value(request, F_ORIG); request 606 daemons/based/based_callbacks.c const char *reply_to = crm_element_value(request, F_CIB_ISREPLY); request 610 daemons/based/based_callbacks.c if (pcmk__xe_attr_is_true(request, F_CIB_GLOBAL_UPDATE)) { request 622 daemons/based/based_callbacks.c op = crm_element_value(request, F_CIB_OPERATION); request 637 daemons/based/based_callbacks.c process_ping_reply(request); request 649 daemons/based/based_callbacks.c host = crm_element_value(request, F_CIB_HOST); request 665 daemons/based/based_callbacks.c delegated = crm_element_value(request, F_CIB_DELEGATED); request 689 daemons/based/based_callbacks.c crm_log_xml_err(request, "Peer[inbound]"); request 696 daemons/based/based_callbacks.c parse_peer_options_v2(int call_type, xmlNode * request, request 701 daemons/based/based_callbacks.c const char *delegated = crm_element_value(request, F_CIB_DELEGATED); request 702 daemons/based/based_callbacks.c const char *op = crm_element_value(request, F_CIB_OPERATION); request 703 daemons/based/based_callbacks.c const char *originator = crm_element_value(request, F_ORIG); request 704 daemons/based/based_callbacks.c const char *reply_to = crm_element_value(request, F_CIB_ISREPLY); request 720 daemons/based/based_callbacks.c process_ping_reply(request); request 734 daemons/based/based_callbacks.c const char *max = crm_element_value(request, F_CIB_SCHEMA_MAX); request 735 daemons/based/based_callbacks.c const char *upgrade_rc = crm_element_value(request, F_CIB_UPGRADE_RC); request 744 daemons/based/based_callbacks.c crm_xml_add(request, F_CIB_RC, upgrade_rc); request 759 daemons/based/based_callbacks.c } else if (pcmk__xe_attr_is_true(request, F_CIB_GLOBAL_UPDATE)) { request 797 daemons/based/based_callbacks.c host = crm_element_value(request, F_CIB_HOST); request 813 daemons/based/based_callbacks.c crm_element_value(request, F_CIB_CLIENTNAME), request 814 daemons/based/based_callbacks.c crm_element_value(request, F_CIB_CALLID), request 820 daemons/based/based_callbacks.c parse_peer_options(int call_type, xmlNode * request, request 830 daemons/based/based_callbacks.c call_type, request, local_notify, needs_reply, process, needs_forward); request 833 daemons/based/based_callbacks.c call_type, request, local_notify, needs_reply, process, needs_forward); request 838 daemons/based/based_callbacks.c forward_request(xmlNode *request, int call_options) request 840 daemons/based/based_callbacks.c const char *op = crm_element_value(request, F_CIB_OPERATION); request 841 daemons/based/based_callbacks.c const char *host = crm_element_value(request, F_CIB_HOST); request 843 daemons/based/based_callbacks.c crm_xml_add(request, F_CIB_DELEGATED, cib_our_uname); request 847 daemons/based/based_callbacks.c send_cluster_message(crm_get_peer(0, host), crm_msg_cib, request, FALSE); request 851 daemons/based/based_callbacks.c send_cluster_message(NULL, crm_msg_cib, request, FALSE); request 855 daemons/based/based_callbacks.c xml_remove_prop(request, F_CIB_DELEGATED); request 928 daemons/based/based_callbacks.c cib_process_request(xmlNode *request, gboolean privileged, request 944 daemons/based/based_callbacks.c const char *op = crm_element_value(request, F_CIB_OPERATION); request 945 daemons/based/based_callbacks.c const char *originator = crm_element_value(request, F_ORIG); request 946 daemons/based/based_callbacks.c const char *host = crm_element_value(request, F_CIB_HOST); request 948 daemons/based/based_callbacks.c const char *call_id = crm_element_value(request, F_CIB_CALLID); request 949 daemons/based/based_callbacks.c const char *client_id = crm_element_value(request, F_CIB_CLIENTID); request 950 daemons/based/based_callbacks.c const char *client_name = crm_element_value(request, F_CIB_CLIENTNAME); request 951 daemons/based/based_callbacks.c const char *reply_to = crm_element_value(request, F_CIB_ISREPLY); request 953 daemons/based/based_callbacks.c crm_element_value_int(request, F_CIB_CALLOPTS, &call_options); request 973 daemons/based/based_callbacks.c crm_xml_add(request, F_ORIG, cib_our_uname); request 988 daemons/based/based_callbacks.c } else if (parse_peer_options(call_type, request, &local_notify, request 1005 daemons/based/based_callbacks.c const char *section = crm_element_value(request, F_CIB_SECTION); request 1020 daemons/based/based_callbacks.c forward_request(request, call_options); request 1025 daemons/based/based_callbacks.c const char *call = crm_element_value(request, F_CIB_CALLID); request 1048 daemons/based/based_callbacks.c const char *section = crm_element_value(request, F_CIB_SECTION); request 1050 daemons/based/based_callbacks.c rc = cib_process_command(request, &op_reply, &result_diff, privileged); request 1055 daemons/based/based_callbacks.c } else if (pcmk__xe_attr_is_true(request, F_CIB_GLOBAL_UPDATE)) { request 1089 daemons/based/based_callbacks.c crm_log_xml_err(request, "null reply"); request 1109 daemons/based/based_callbacks.c crm_xml_add_int(request, F_CIB_LOCAL_NOTIFY_ID, cib_local_bcast_num); request 1110 daemons/based/based_callbacks.c broadcast = send_peer_reply(request, result_diff, originator, TRUE); request 1152 daemons/based/based_callbacks.c do_local_notify(request, client_id, request 1186 daemons/based/based_callbacks.c cib_process_command(xmlNode * request, xmlNode ** reply, xmlNode ** cib_diff, gboolean privileged) request 1198 daemons/based/based_callbacks.c const char *call_id = crm_element_value(request, F_CIB_CALLID); request 1228 daemons/based/based_callbacks.c op = crm_element_value(request, F_CIB_OPERATION); request 1229 daemons/based/based_callbacks.c crm_element_value_int(request, F_CIB_CALLOPTS, &call_options); request 1236 daemons/based/based_callbacks.c rc2 = cib_op_prepare(call_type, request, &input, §ion); request 1247 daemons/based/based_callbacks.c section, request, input, FALSE, &config_changed, request 1255 daemons/based/based_callbacks.c if (pcmk__xe_attr_is_true(request, F_CIB_GLOBAL_UPDATE)) { request 1262 daemons/based/based_callbacks.c crm_log_xml_err(request, "bad op")); request 1291 daemons/based/based_callbacks.c section, request, input, manage_counters, &config_changed, request 1405 daemons/based/based_callbacks.c const char *client = crm_element_value(request, F_CIB_CLIENTNAME); request 1413 daemons/based/based_callbacks.c const char *origin = crm_element_value(request, F_ORIG); request 1421 daemons/based/based_callbacks.c const char *caller = crm_element_value(request, F_CIB_CLIENTID); request 33 daemons/based/based_common.c extern int cib_perform_command(xmlNode * request, xmlNode ** reply, xmlNode ** cib_diff, request 63 daemons/based/based_common.c cib_prepare_none(xmlNode * request, xmlNode ** data, const char **section) request 66 daemons/based/based_common.c *section = crm_element_value(request, F_CIB_SECTION); request 71 daemons/based/based_common.c cib_prepare_data(xmlNode * request, xmlNode ** data, const char **section) request 73 daemons/based/based_common.c xmlNode *input_fragment = get_message_xml(request, F_CIB_CALLDATA); request 75 daemons/based/based_common.c *section = crm_element_value(request, F_CIB_SECTION); request 82 daemons/based/based_common.c cib_prepare_sync(xmlNode * request, xmlNode ** data, const char **section) request 85 daemons/based/based_common.c *section = crm_element_value(request, F_CIB_SECTION); request 90 daemons/based/based_common.c cib_prepare_diff(xmlNode * request, xmlNode ** data, const char **section) request 97 daemons/based/based_common.c if (pcmk__xe_attr_is_true(request, F_CIB_GLOBAL_UPDATE)) { request 98 daemons/based/based_common.c input_fragment = get_message_xml(request, F_CIB_UPDATE_DIFF); request 100 daemons/based/based_common.c input_fragment = get_message_xml(request, F_CIB_CALLDATA); request 103 daemons/based/based_common.c CRM_CHECK(input_fragment != NULL, crm_log_xml_warn(request, "no input")); request 351 daemons/based/based_common.c cib_op_prepare(int call_type, xmlNode * request, xmlNode ** input, const char **section) request 354 daemons/based/based_common.c return cib_server_ops[call_type].prepare(request, input, section); request 49 daemons/based/based_messages.c int sync_our_cib(xmlNode * request, gboolean all); request 391 daemons/based/based_messages.c sync_our_cib(xmlNode * request, gboolean all) request 395 daemons/based/based_messages.c const char *host = crm_element_value(request, F_ORIG); request 396 daemons/based/based_messages.c const char *op = crm_element_value(request, F_CIB_OPERATION); request 402 daemons/based/based_messages.c replace_request = cib_msg_copy(request, FALSE); request 407 daemons/based/based_messages.c crm_log_xml_err(request, "bad sync"); request 135 daemons/based/pacemaker-based.h xmlNode *cib_construct_reply(xmlNode *request, xmlNode *output, int rc); request 139 daemons/based/pacemaker-based.h int cib_op_prepare(int call_type, xmlNode *request, xmlNode **input, request 1313 daemons/controld/controld_execd.c ha_msg_input_t * request, request 1329 daemons/controld/controld_execd.c if (request) { request 1331 daemons/controld/controld_execd.c char *ref = crm_element_value_copy(request->msg, XML_ATTR_REFERENCE); request 1335 daemons/controld/controld_execd.c op->input = copy_ha_msg_input(request); request 1345 daemons/controld/controld_execd.c delete_rsc_entry(lrm_state, request, id, gIter, rc, user); request 526 daemons/controld/controld_execd_state.c xmlNode *request = get_message_xml(msg, F_LRMD_IPC_MSG); request 528 daemons/controld/controld_execd_state.c CRM_CHECK(request != NULL, return); request 530 daemons/controld/controld_execd_state.c crm_xml_add(request, XML_ACL_TAG_ROLE, "pacemaker-remote"); request 531 daemons/controld/controld_execd_state.c pcmk__update_acl_user(request, F_LRMD_IPC_USER, lrm_state->node_name); request 538 daemons/controld/controld_execd_state.c if (pcmk__str_eq(crm_element_value(request, F_CRM_TASK), CRM_OP_NODE_INFO, pcmk__str_casei)) { request 541 daemons/controld/controld_execd_state.c crm_element_value_int(request, XML_ATTR_ID, &node_id); request 543 daemons/controld/controld_execd_state.c && (crm_element_value(request, XML_ATTR_UNAME) == NULL)) { request 544 daemons/controld/controld_execd_state.c crm_xml_add(request, XML_ATTR_UNAME, lrm_state->node_name); request 548 daemons/controld/controld_execd_state.c crmd_proxy_dispatch(session, request); request 790 daemons/controld/controld_messages.c handle_node_list(const xmlNode *request) request 809 daemons/controld/controld_messages.c reply = create_reply(request, reply_data); request 104 daemons/execd/execd_alerts.c process_lrmd_alert_exec(pcmk__client_t *client, uint32_t id, xmlNode *request) request 108 daemons/execd/execd_alerts.c xmlNode *alert_xml = get_xpath_object("//" F_LRMD_ALERT, request, LOG_ERR); request 146 daemons/execd/execd_alerts.c crm_element_value_int(request, F_LRMD_CALLID, &(cb_data->call_id)); request 682 daemons/execd/execd_commands.c send_generic_notify(int rc, xmlNode * request) request 687 daemons/execd/execd_commands.c xmlNode *rsc_xml = get_xpath_object("//" F_LRMD_RSC, request, LOG_ERR); request 689 daemons/execd/execd_commands.c const char *op = crm_element_value(request, F_LRMD_OPERATION); request 691 daemons/execd/execd_commands.c crm_element_value_int(request, F_LRMD_CALLID, &call_id); request 1471 daemons/execd/execd_commands.c process_lrmd_signon(pcmk__client_t *client, xmlNode *request, int call_id, request 1475 daemons/execd/execd_commands.c const char *protocol_version = crm_element_value(request, F_LRMD_PROTOCOL_VERSION); request 1483 daemons/execd/execd_commands.c if (pcmk__xe_attr_is_true(request, F_LRMD_IS_IPC_PROVIDER)) { request 1508 daemons/execd/execd_commands.c process_lrmd_rsc_register(pcmk__client_t *client, uint32_t id, xmlNode *request) request 1511 daemons/execd/execd_commands.c lrmd_rsc_t *rsc = build_rsc_from_xml(request); request 1529 daemons/execd/execd_commands.c process_lrmd_get_rsc_info(xmlNode *request, int call_id) request 1532 daemons/execd/execd_commands.c xmlNode *rsc_xml = get_xpath_object("//" F_LRMD_RSC, request, LOG_ERR); request 1559 daemons/execd/execd_commands.c xmlNode *request) request 1563 daemons/execd/execd_commands.c xmlNode *rsc_xml = get_xpath_object("//" F_LRMD_RSC, request, LOG_ERR); request 1590 daemons/execd/execd_commands.c process_lrmd_rsc_exec(pcmk__client_t *client, uint32_t id, xmlNode *request) request 1594 daemons/execd/execd_commands.c xmlNode *rsc_xml = get_xpath_object("//" F_LRMD_RSC, request, LOG_ERR); request 1607 daemons/execd/execd_commands.c cmd = create_lrmd_cmd(request, client); request 1715 daemons/execd/execd_commands.c process_lrmd_rsc_cancel(pcmk__client_t *client, uint32_t id, xmlNode *request) request 1717 daemons/execd/execd_commands.c xmlNode *rsc_xml = get_xpath_object("//" F_LRMD_RSC, request, LOG_ERR); request 1749 daemons/execd/execd_commands.c process_lrmd_get_recurring(xmlNode *request, int call_id) request 1758 daemons/execd/execd_commands.c rsc_xml = first_named_child(request, F_LRMD_CALLDATA); request 1795 daemons/execd/execd_commands.c process_lrmd_message(pcmk__client_t *client, uint32_t id, xmlNode *request) request 1799 daemons/execd/execd_commands.c const char *op = crm_element_value(request, F_LRMD_OPERATION); request 1811 daemons/execd/execd_commands.c crm_element_value_int(request, F_LRMD_CALLID, &call_id); request 1816 daemons/execd/execd_commands.c ipc_proxy_forward_client(client, request); request 1825 daemons/execd/execd_commands.c rc = process_lrmd_signon(client, request, call_id, &reply); request 1829 daemons/execd/execd_commands.c rc = process_lrmd_rsc_register(client, id, request); request 1837 daemons/execd/execd_commands.c reply = process_lrmd_get_rsc_info(request, call_id); request 1844 daemons/execd/execd_commands.c rc = process_lrmd_rsc_unregister(client, id, request); request 1855 daemons/execd/execd_commands.c rc = process_lrmd_rsc_exec(client, id, request); request 1862 daemons/execd/execd_commands.c rc = process_lrmd_rsc_cancel(client, id, request); request 1872 daemons/execd/execd_commands.c xmlNode *data = get_message_xml(request, F_LRMD_CALLDATA); request 1881 daemons/execd/execd_commands.c rc = process_lrmd_alert_exec(client, id, request); request 1888 daemons/execd/execd_commands.c reply = process_lrmd_get_recurring(request, call_id); request 1923 daemons/execd/execd_commands.c send_generic_notify(rc, request); request 109 daemons/execd/pacemaker-execd.c xmlNode *request = pcmk__client_data2xml(client, data, &id, &flags); request 119 daemons/execd/pacemaker-execd.c if (!request) { request 124 daemons/execd/pacemaker-execd.c const char *value = crm_element_value(request, F_LRMD_CLIENTNAME); request 138 daemons/execd/pacemaker-execd.c crm_xml_add(request, F_LRMD_CLIENTID, client->id); request 139 daemons/execd/pacemaker-execd.c crm_xml_add(request, F_LRMD_CLIENTNAME, client->name); request 140 daemons/execd/pacemaker-execd.c crm_xml_add_int(request, F_LRMD_CALLID, lrmd_call_id); request 142 daemons/execd/pacemaker-execd.c process_lrmd_message(client, id, request); request 144 daemons/execd/pacemaker-execd.c free_xml(request); request 69 daemons/execd/pacemaker-execd.h xmlNode *request); request 106 daemons/execd/pacemaker-execd.h xmlNode *request); request 228 daemons/execd/remoted_proxy.c xmlNode *request = NULL; request 249 daemons/execd/remoted_proxy.c request = pcmk__client_data2xml(client, data, &id, &flags); request 251 daemons/execd/remoted_proxy.c if (!request) { request 256 daemons/execd/remoted_proxy.c free_xml(request); return FALSE); request 258 daemons/execd/remoted_proxy.c free_xml(request); return FALSE); request 273 daemons/execd/remoted_proxy.c add_message_xml(msg, F_LRMD_IPC_MSG, request); request 275 daemons/execd/remoted_proxy.c free_xml(request); request 92 daemons/execd/remoted_tls.c xmlNode *request = NULL; request 112 daemons/execd/remoted_tls.c request = pcmk__remote_message_xml(client->remote); request 113 daemons/execd/remoted_tls.c while (request) { request 114 daemons/execd/remoted_tls.c crm_element_value_int(request, F_LRMD_REMOTE_MSG_ID, &id); request 117 daemons/execd/remoted_tls.c const char *value = crm_element_value(request, F_LRMD_CLIENTNAME); request 129 daemons/execd/remoted_tls.c crm_xml_add(request, F_LRMD_CLIENTID, client->id); request 130 daemons/execd/remoted_tls.c crm_xml_add(request, F_LRMD_CLIENTNAME, client->name); request 131 daemons/execd/remoted_tls.c crm_xml_add_int(request, F_LRMD_CALLID, lrmd_call_id); request 133 daemons/execd/remoted_tls.c process_lrmd_message(client, id, request); request 134 daemons/execd/remoted_tls.c free_xml(request); request 137 daemons/execd/remoted_tls.c request = pcmk__remote_message_xml(client->remote); request 2925 daemons/fenced/fenced_commands.c fenced_construct_reply(const xmlNode *request, xmlNode *data, request 2936 daemons/fenced/fenced_commands.c if (request == NULL) { request 2963 daemons/fenced/fenced_commands.c value = crm_element_value(request, name); request 3080 daemons/fenced/fenced_commands.c remove_relay_op(xmlNode * request) request 3082 daemons/fenced/fenced_commands.c xmlNode *dev = get_xpath_object("//@" F_STONITH_ACTION, request, LOG_TRACE); request 3093 daemons/fenced/fenced_commands.c relay_op_id = crm_element_value(request, F_STONITH_REMOTE_OP_ID_RELAY); request 3094 daemons/fenced/fenced_commands.c op_id = crm_element_value(request, F_STONITH_REMOTE_OP_ID); request 3095 daemons/fenced/fenced_commands.c client_name = crm_element_value(request, F_STONITH_CLIENTNAME); request 3161 daemons/fenced/fenced_commands.c handle_register_request(pcmk__request_t *request) request 3165 daemons/fenced/fenced_commands.c CRM_ASSERT(request->ipc_client != NULL); request 3167 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_CLIENTID, request->ipc_client->id); request 3168 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3169 daemons/fenced/fenced_commands.c pcmk__set_request_flags(request, pcmk__request_reuse_options); request 3175 daemons/fenced/fenced_commands.c handle_agent_request(pcmk__request_t *request) request 3177 daemons/fenced/fenced_commands.c execute_agent_action(request->xml, &request->result); request 3178 daemons/fenced/fenced_commands.c if (request->result.execution_status == PCMK_EXEC_PENDING) { request 3181 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3186 daemons/fenced/fenced_commands.c handle_update_timeout_request(pcmk__request_t *request) request 3188 daemons/fenced/fenced_commands.c const char *call_id = crm_element_value(request->xml, F_STONITH_CALLID); request 3189 daemons/fenced/fenced_commands.c const char *client_id = crm_element_value(request->xml, F_STONITH_CLIENTID); request 3192 daemons/fenced/fenced_commands.c crm_element_value_int(request->xml, F_STONITH_TIMEOUT, &op_timeout); request 3194 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3200 daemons/fenced/fenced_commands.c handle_query_request(pcmk__request_t *request) request 3206 daemons/fenced/fenced_commands.c const char *client_id = crm_element_value(request->xml, F_STONITH_CLIENTID); request 3209 daemons/fenced/fenced_commands.c if (request->peer != NULL) { request 3211 daemons/fenced/fenced_commands.c create_remote_stonith_op(client_id, request->xml, TRUE); request 3215 daemons/fenced/fenced_commands.c remove_relay_op(request->xml); request 3217 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3219 daemons/fenced/fenced_commands.c dev = get_xpath_object("//@" F_STONITH_ACTION, request->xml, LOG_NEVER); request 3230 daemons/fenced/fenced_commands.c crm_log_xml_trace(request->xml, "Query"); request 3235 daemons/fenced/fenced_commands.c query->reply = fenced_construct_reply(request->xml, NULL, &request->result); request 3236 daemons/fenced/fenced_commands.c pcmk__str_update(&query->remote_peer, request->peer); request 3240 daemons/fenced/fenced_commands.c query->call_options = request->call_options; request 3242 daemons/fenced/fenced_commands.c crm_element_value_int(request->xml, F_STONITH_TIMEOUT, &timeout); request 3251 daemons/fenced/fenced_commands.c handle_notify_request(pcmk__request_t *request) request 3255 daemons/fenced/fenced_commands.c CRM_ASSERT(request->ipc_client != NULL); request 3256 daemons/fenced/fenced_commands.c flag_name = crm_element_value(request->xml, F_STONITH_NOTIFY_ACTIVATE); request 3259 daemons/fenced/fenced_commands.c flag_name, pcmk__request_origin(request)); request 3260 daemons/fenced/fenced_commands.c pcmk__set_client_flags(request->ipc_client, get_stonith_flag(flag_name)); request 3263 daemons/fenced/fenced_commands.c flag_name = crm_element_value(request->xml, F_STONITH_NOTIFY_DEACTIVATE); request 3266 daemons/fenced/fenced_commands.c flag_name, pcmk__request_origin(request)); request 3267 daemons/fenced/fenced_commands.c pcmk__clear_client_flags(request->ipc_client, request 3271 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3272 daemons/fenced/fenced_commands.c pcmk__set_request_flags(request, pcmk__request_reuse_options); request 3274 daemons/fenced/fenced_commands.c return pcmk__ipc_create_ack(request->ipc_flags, "ack", NULL, CRM_EX_OK); request 3279 daemons/fenced/fenced_commands.c handle_relay_request(pcmk__request_t *request) request 3281 daemons/fenced/fenced_commands.c xmlNode *dev = get_xpath_object("//@" F_STONITH_TARGET, request->xml, request 3286 daemons/fenced/fenced_commands.c pcmk__request_origin_type(request), request 3287 daemons/fenced/fenced_commands.c pcmk__request_origin(request), request 3291 daemons/fenced/fenced_commands.c if (initiate_remote_stonith_op(NULL, request->xml, FALSE) == NULL) { request 3292 daemons/fenced/fenced_commands.c fenced_set_protocol_error(&request->result); request 3293 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3296 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_PENDING, NULL); request 3302 daemons/fenced/fenced_commands.c handle_fence_request(pcmk__request_t *request) request 3304 daemons/fenced/fenced_commands.c if ((request->peer != NULL) || stand_alone) { request 3305 daemons/fenced/fenced_commands.c fence_locally(request->xml, &request->result); request 3307 daemons/fenced/fenced_commands.c } else if (pcmk_is_set(request->call_options, st_opt_manual_ack)) { request 3308 daemons/fenced/fenced_commands.c switch (fenced_handle_manual_confirmation(request->ipc_client, request 3309 daemons/fenced/fenced_commands.c request->xml)) { request 3311 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, request 3315 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_PENDING, request 3319 daemons/fenced/fenced_commands.c fenced_set_protocol_error(&request->result); request 3325 daemons/fenced/fenced_commands.c xmlNode *dev = get_xpath_object("//@" F_STONITH_TARGET, request->xml, request 3331 daemons/fenced/fenced_commands.c if (request->ipc_client != NULL) { request 3335 daemons/fenced/fenced_commands.c pcmk__request_origin(request), action, request 3339 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, request 3341 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, request 3342 daemons/fenced/fenced_commands.c &request->result); request 3348 daemons/fenced/fenced_commands.c request->peer, action, target, request 3356 daemons/fenced/fenced_commands.c if (request->ipc_client->id == 0) { request 3357 daemons/fenced/fenced_commands.c client_id = crm_element_value(request->xml, F_STONITH_CLIENTID); request 3359 daemons/fenced/fenced_commands.c client_id = request->ipc_client->id; request 3366 daemons/fenced/fenced_commands.c op = create_remote_stonith_op(client_id, request->xml, FALSE); request 3368 daemons/fenced/fenced_commands.c crm_xml_add(request->xml, F_STONITH_OPERATION, STONITH_OP_RELAY); request 3369 daemons/fenced/fenced_commands.c crm_xml_add(request->xml, F_STONITH_CLIENTID, request 3370 daemons/fenced/fenced_commands.c request->ipc_client->id); request 3371 daemons/fenced/fenced_commands.c crm_xml_add(request->xml, F_STONITH_REMOTE_OP_ID, op->id); request 3373 daemons/fenced/fenced_commands.c crm_msg_stonith_ng, request->xml, FALSE); request 3374 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_PENDING, request 3377 daemons/fenced/fenced_commands.c } else if (initiate_remote_stonith_op(request->ipc_client, request->xml, request 3379 daemons/fenced/fenced_commands.c fenced_set_protocol_error(&request->result); request 3382 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_PENDING, request 3387 daemons/fenced/fenced_commands.c if (request->result.execution_status == PCMK_EXEC_PENDING) { request 3390 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3395 daemons/fenced/fenced_commands.c handle_history_request(pcmk__request_t *request) request 3400 daemons/fenced/fenced_commands.c stonith_fence_history(request->xml, &data, request->peer, request 3401 daemons/fenced/fenced_commands.c request->call_options); request 3402 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3403 daemons/fenced/fenced_commands.c if (!pcmk_is_set(request->call_options, st_opt_discard_reply)) { request 3407 daemons/fenced/fenced_commands.c reply = fenced_construct_reply(request->xml, data, &request->result); request 3415 daemons/fenced/fenced_commands.c handle_device_add_request(pcmk__request_t *request) request 3417 daemons/fenced/fenced_commands.c const char *op = crm_element_value(request->xml, F_STONITH_OPERATION); request 3418 daemons/fenced/fenced_commands.c xmlNode *dev = get_xpath_object("//" F_STONITH_DEVICE, request->xml, request 3421 daemons/fenced/fenced_commands.c if (is_privileged(request->ipc_client, op)) { request 3424 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, request 3429 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_INSUFFICIENT_PRIV, request 3433 daemons/fenced/fenced_commands.c fenced_send_device_notification(op, &request->result, request 3435 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3440 daemons/fenced/fenced_commands.c handle_device_delete_request(pcmk__request_t *request) request 3442 daemons/fenced/fenced_commands.c xmlNode *dev = get_xpath_object("//" F_STONITH_DEVICE, request->xml, request 3445 daemons/fenced/fenced_commands.c const char *op = crm_element_value(request->xml, F_STONITH_OPERATION); request 3447 daemons/fenced/fenced_commands.c if (is_privileged(request->ipc_client, op)) { request 3449 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3451 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_INSUFFICIENT_PRIV, request 3455 daemons/fenced/fenced_commands.c fenced_send_device_notification(op, &request->result, device_id); request 3456 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3461 daemons/fenced/fenced_commands.c handle_level_add_request(pcmk__request_t *request) request 3464 daemons/fenced/fenced_commands.c const char *op = crm_element_value(request->xml, F_STONITH_OPERATION); request 3466 daemons/fenced/fenced_commands.c if (is_privileged(request->ipc_client, op)) { request 3467 daemons/fenced/fenced_commands.c fenced_register_level(request->xml, &desc, &request->result); request 3469 daemons/fenced/fenced_commands.c unpack_level_request(request->xml, NULL, NULL, NULL, &desc); request 3470 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_INSUFFICIENT_PRIV, request 3474 daemons/fenced/fenced_commands.c fenced_send_level_notification(op, &request->result, desc); request 3476 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3481 daemons/fenced/fenced_commands.c handle_level_delete_request(pcmk__request_t *request) request 3484 daemons/fenced/fenced_commands.c const char *op = crm_element_value(request->xml, F_STONITH_OPERATION); request 3486 daemons/fenced/fenced_commands.c if (is_privileged(request->ipc_client, op)) { request 3487 daemons/fenced/fenced_commands.c fenced_unregister_level(request->xml, &desc, &request->result); request 3489 daemons/fenced/fenced_commands.c unpack_level_request(request->xml, NULL, NULL, NULL, &desc); request 3490 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_INSUFFICIENT_PRIV, request 3494 daemons/fenced/fenced_commands.c fenced_send_level_notification(op, &request->result, desc); request 3496 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3501 daemons/fenced/fenced_commands.c handle_cache_request(pcmk__request_t *request) request 3506 daemons/fenced/fenced_commands.c crm_element_value_int(request->xml, XML_ATTR_ID, &node_id); request 3507 daemons/fenced/fenced_commands.c name = crm_element_value(request->xml, XML_ATTR_UNAME); request 3509 daemons/fenced/fenced_commands.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 3514 daemons/fenced/fenced_commands.c handle_unknown_request(pcmk__request_t *request) request 3517 daemons/fenced/fenced_commands.c request->op, pcmk__request_origin_type(request), request 3518 daemons/fenced/fenced_commands.c pcmk__request_origin(request)); request 3519 daemons/fenced/fenced_commands.c pcmk__format_result(&request->result, CRM_EX_PROTOCOL, PCMK_EXEC_INVALID, request 3520 daemons/fenced/fenced_commands.c "Unknown IPC request type '%s' (bug?)", request->op); request 3521 daemons/fenced/fenced_commands.c return fenced_construct_reply(request->xml, NULL, &request->result); request 3557 daemons/fenced/fenced_commands.c handle_request(pcmk__request_t *request) request 3565 daemons/fenced/fenced_commands.c reply = pcmk__process_request(request, fenced_handlers); request 3567 daemons/fenced/fenced_commands.c if (pcmk_is_set(request->flags, pcmk__request_reuse_options) request 3568 daemons/fenced/fenced_commands.c && (request->ipc_client != NULL)) { request 3573 daemons/fenced/fenced_commands.c pcmk__ipc_send_xml(request->ipc_client, request->ipc_id, reply, request 3574 daemons/fenced/fenced_commands.c request->ipc_flags); request 3575 daemons/fenced/fenced_commands.c request->ipc_client->request_id = 0; request 3577 daemons/fenced/fenced_commands.c stonith_send_reply(reply, request->call_options, request 3578 daemons/fenced/fenced_commands.c request->peer, request->ipc_client); request 3583 daemons/fenced/fenced_commands.c reason = request->result.exit_reason; request 3585 daemons/fenced/fenced_commands.c request->op, pcmk__request_origin_type(request), request 3586 daemons/fenced/fenced_commands.c pcmk__request_origin(request), request 3587 daemons/fenced/fenced_commands.c pcmk_exec_status_str(request->result.execution_status), request 3594 daemons/fenced/fenced_commands.c handle_reply(pcmk__client_t *client, xmlNode *request, const char *remote_peer) request 3597 daemons/fenced/fenced_commands.c char *op = crm_element_value_copy(request, F_STONITH_OPERATION); request 3600 daemons/fenced/fenced_commands.c process_remote_stonith_query(request); request 3602 daemons/fenced/fenced_commands.c fenced_process_fencing_reply(request); request 3607 daemons/fenced/fenced_commands.c crm_log_xml_warn(request, "UnknownOp"); request 3654 daemons/fenced/fenced_commands.c pcmk__request_t request = { request 3664 daemons/fenced/fenced_commands.c request.op = crm_element_value_copy(request.xml, F_STONITH_OPERATION); request 3665 daemons/fenced/fenced_commands.c CRM_CHECK(request.op != NULL, return); request 3667 daemons/fenced/fenced_commands.c if (pcmk_is_set(request.call_options, st_opt_sync_call)) { request 3668 daemons/fenced/fenced_commands.c pcmk__set_request_flags(&request, pcmk__request_sync); request 3671 daemons/fenced/fenced_commands.c handle_request(&request); request 3672 daemons/fenced/fenced_commands.c pcmk__reset_request(&request); request 246 daemons/fenced/fenced_remote.c crm_log_xml_debug(op->request, "Destroying"); request 261 daemons/fenced/fenced_remote.c if (op->request) { request 262 daemons/fenced/fenced_remote.c free_xml(op->request); request 263 daemons/fenced/fenced_remote.c op->request = NULL; request 454 daemons/fenced/fenced_remote.c reply = fenced_construct_reply(op->request, data, &op->result); request 629 daemons/fenced/fenced_remote.c if (op->request) { request 630 daemons/fenced/fenced_remote.c free_xml(op->request); request 631 daemons/fenced/fenced_remote.c op->request = NULL; request 1129 daemons/fenced/fenced_remote.c create_remote_stonith_op(const char *client, xmlNode *request, gboolean peer) request 1132 daemons/fenced/fenced_remote.c xmlNode *dev = get_xpath_object("//@" F_STONITH_TARGET, request, LOG_NEVER); request 1156 daemons/fenced/fenced_remote.c crm_element_value_int(request, F_STONITH_TIMEOUT, &(op->base_timeout)); request 1158 daemons/fenced/fenced_remote.c crm_element_value_int(request, F_STONITH_DELAY, &(op->delay)); request 1187 daemons/fenced/fenced_remote.c operation = crm_element_value(request, F_STONITH_OPERATION); request 1193 daemons/fenced/fenced_remote.c op->client_name = crm_element_value_copy(request, F_STONITH_CLIENTNAME); request 1197 daemons/fenced/fenced_remote.c op->request = copy_xml(request); /* TODO: Figure out how to avoid this */ request 1198 daemons/fenced/fenced_remote.c crm_element_value_int(request, F_STONITH_CALLOPTS, &call_options); request 1201 daemons/fenced/fenced_remote.c crm_element_value_int(request, F_STONITH_CALLID, &(op->client_callid)); request 1254 daemons/fenced/fenced_remote.c initiate_remote_stonith_op(const pcmk__client_t *client, xmlNode *request, request 1267 daemons/fenced/fenced_remote.c client_id = crm_element_value(request, F_STONITH_CLIENTID); request 1271 daemons/fenced/fenced_remote.c op = create_remote_stonith_op(client_id, request, FALSE); request 1317 daemons/fenced/fenced_remote.c operation = crm_element_value(request, F_STONITH_OPERATION); request 1319 daemons/fenced/fenced_remote.c relay_op_id = crm_element_value(request, F_STONITH_REMOTE_OP_ID); request 1597 daemons/fenced/fenced_remote.c } else if (!op->request) { request 1602 daemons/fenced/fenced_remote.c client_node = crm_element_value(op->request, F_STONITH_CLIENTNODE); request 1603 daemons/fenced/fenced_remote.c call_id = crm_element_value(op->request, F_STONITH_CALLID); request 1604 daemons/fenced/fenced_remote.c client_id = crm_element_value(op->request, F_STONITH_CLIENTID); request 96 daemons/fenced/pacemaker-fenced.c xmlNode *request = NULL; request 105 daemons/fenced/pacemaker-fenced.c request = pcmk__client_data2xml(c, data, &id, &flags); request 106 daemons/fenced/pacemaker-fenced.c if (request == NULL) { request 112 daemons/fenced/pacemaker-fenced.c op = crm_element_value(request, F_CRM_TASK); request 114 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_TYPE, T_STONITH_NG); request 115 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_OPERATION, op); request 116 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTID, c->id); request 117 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTNAME, pcmk__client_name(c)); request 118 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTNODE, stonith_our_uname); request 120 daemons/fenced/pacemaker-fenced.c send_cluster_message(NULL, crm_msg_stonith_ng, request, FALSE); request 121 daemons/fenced/pacemaker-fenced.c free_xml(request); request 126 daemons/fenced/pacemaker-fenced.c const char *value = crm_element_value(request, F_STONITH_CLIENTNAME); request 134 daemons/fenced/pacemaker-fenced.c crm_element_value_int(request, F_STONITH_CALLOPTS, &call_options); request 144 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTID, c->id); request 145 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTNAME, pcmk__client_name(c)); request 146 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTNODE, stonith_our_uname); request 148 daemons/fenced/pacemaker-fenced.c crm_log_xml_trace(request, "ipc-received"); request 149 daemons/fenced/pacemaker-fenced.c stonith_command(c, id, flags, request, NULL); request 151 daemons/fenced/pacemaker-fenced.c free_xml(request); request 135 daemons/fenced/pacemaker-fenced.h xmlNode *request; request 237 daemons/fenced/pacemaker-fenced.h xmlNode *fenced_construct_reply(const xmlNode *request, xmlNode *data, request 254 daemons/fenced/pacemaker-fenced.h xmlNode *request, request 261 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 52 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags, request 67 daemons/pacemakerd/pcmkd_messages.c pcmk__format_result(&request->result, CRM_EX_ERROR, PCMK_EXEC_ERROR, request 69 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(request->ipc_client)); request 71 daemons/pacemakerd/pcmkd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 81 daemons/pacemakerd/pcmkd_messages.c shutdown_complete_state_reported_to = request->ipc_client->pid; request 94 daemons/pacemakerd/pcmkd_messages.c handle_shutdown_request(pcmk__request_t *request) request 96 daemons/pacemakerd/pcmkd_messages.c xmlNode *msg = request->xml; request 105 daemons/pacemakerd/pcmkd_messages.c bool allowed = pcmk_is_set(request->ipc_client->flags, pcmk__client_privileged); request 107 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags, request 119 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(request->ipc_client)); request 127 daemons/pacemakerd/pcmkd_messages.c pcmk__format_result(&request->result, CRM_EX_ERROR, PCMK_EXEC_ERROR, request 129 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(request->ipc_client)); request 131 daemons/pacemakerd/pcmkd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 142 daemons/pacemakerd/pcmkd_messages.c handle_unknown_request(pcmk__request_t *request) request 144 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags, request 147 daemons/pacemakerd/pcmkd_messages.c pcmk__format_result(&request->result, CRM_EX_PROTOCOL, PCMK_EXEC_INVALID, request 149 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(request->ipc_client)); request 228 daemons/pacemakerd/pcmkd_messages.c pcmk__request_t request = { request 238 daemons/pacemakerd/pcmkd_messages.c request.op = crm_element_value_copy(request.xml, F_CRM_TASK); request 239 daemons/pacemakerd/pcmkd_messages.c CRM_CHECK(request.op != NULL, return 0); request 241 daemons/pacemakerd/pcmkd_messages.c reply = pcmk__process_request(&request, pcmkd_handlers); request 248 daemons/pacemakerd/pcmkd_messages.c reason = request.result.exit_reason; request 251 daemons/pacemakerd/pcmkd_messages.c request.op, pcmk__request_origin_type(&request), request 252 daemons/pacemakerd/pcmkd_messages.c pcmk__request_origin(&request), request 253 daemons/pacemakerd/pcmkd_messages.c pcmk_exec_status_str(request.result.execution_status), request 258 daemons/pacemakerd/pcmkd_messages.c if (!pcmk__result_ok(&request.result)) { request 265 daemons/pacemakerd/pcmkd_messages.c pcmk__reset_request(&request); request 43 daemons/schedulerd/schedulerd_messages.c handle_pecalc_request(pcmk__request_t *request) request 59 daemons/schedulerd/schedulerd_messages.c xmlNode *msg = request->xml; request 77 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 171 daemons/schedulerd/schedulerd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 181 daemons/schedulerd/schedulerd_messages.c handle_unknown_request(pcmk__request_t *request) request 183 daemons/schedulerd/schedulerd_messages.c pcmk__ipc_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags, request 186 daemons/schedulerd/schedulerd_messages.c pcmk__format_result(&request->result, CRM_EX_PROTOCOL, PCMK_EXEC_INVALID, request 188 daemons/schedulerd/schedulerd_messages.c pcmk__client_name(request->ipc_client)); request 193 daemons/schedulerd/schedulerd_messages.c handle_hello_request(pcmk__request_t *request) request 195 daemons/schedulerd/schedulerd_messages.c pcmk__ipc_send_ack(request->ipc_client, request->ipc_id, request->ipc_flags, request 198 daemons/schedulerd/schedulerd_messages.c crm_trace("Received IPC hello from %s", pcmk__client_name(request->ipc_client)); request 200 daemons/schedulerd/schedulerd_messages.c pcmk__set_result(&request->result, CRM_EX_OK, PCMK_EXEC_DONE, NULL); request 264 daemons/schedulerd/schedulerd_messages.c pcmk__request_t request = { request 274 daemons/schedulerd/schedulerd_messages.c request.op = crm_element_value_copy(request.xml, F_CRM_TASK); request 275 daemons/schedulerd/schedulerd_messages.c CRM_CHECK(request.op != NULL, return 0); request 277 daemons/schedulerd/schedulerd_messages.c reply = pcmk__process_request(&request, schedulerd_handlers); request 284 daemons/schedulerd/schedulerd_messages.c reason = request.result.exit_reason; request 287 daemons/schedulerd/schedulerd_messages.c request.op, pcmk__request_origin_type(&request), request 288 daemons/schedulerd/schedulerd_messages.c pcmk__request_origin(&request), request 289 daemons/schedulerd/schedulerd_messages.c pcmk_exec_status_str(request.result.execution_status), request 294 daemons/schedulerd/schedulerd_messages.c if (!pcmk__result_ok(&request.result)) { request 301 daemons/schedulerd/schedulerd_messages.c pcmk__reset_request(&request); request 18 include/crm/common/acl_internal.h const char *pcmk__update_acl_user(xmlNode *request, const char *field, request 37 include/crm/common/ipc.h #define create_reply(request, xml_response_data) \ request 38 include/crm/common/ipc.h create_reply_adv(request, xml_response_data, __func__) request 40 include/crm/common/ipc.h xmlNode *create_reply_adv(const xmlNode *request, xmlNode *xml_response_data, request 241 include/crm/common/ipc_internal.h uint32_t request, uint32_t flags, const char *tag, request 246 include/crm/common/ipc_internal.h int pcmk__ipc_prepare_iov(uint32_t request, xmlNode *message, request 249 include/crm/common/ipc_internal.h int pcmk__ipc_send_xml(pcmk__client_t *c, uint32_t request, xmlNode *message, request 63 include/crm/common/messages_internal.h #define pcmk__set_request_flags(request, flags_to_set) do { \ request 64 include/crm/common/messages_internal.h (request)->flags = pcmk__set_flags_as(__func__, __LINE__, \ request 65 include/crm/common/messages_internal.h LOG_TRACE, "Request", "message", (request)->flags, \ request 72 include/crm/common/messages_internal.h xmlNode *(*handler)(pcmk__request_t *request); request 77 include/crm/common/messages_internal.h xmlNode *pcmk__process_request(pcmk__request_t *request, GHashTable *handlers); request 78 include/crm/common/messages_internal.h void pcmk__reset_request(pcmk__request_t *request); request 90 include/crm/common/messages_internal.h pcmk__request_origin_type(const pcmk__request_t *request) request 92 include/crm/common/messages_internal.h if ((request != NULL) && (request->ipc_client != NULL)) { request 94 include/crm/common/messages_internal.h } else if ((request != NULL) && (request->peer != NULL)) { request 111 include/crm/common/messages_internal.h pcmk__request_origin(const pcmk__request_t *request) request 113 include/crm/common/messages_internal.h if ((request != NULL) && (request->ipc_client != NULL)) { request 114 include/crm/common/messages_internal.h return pcmk__client_name(request->ipc_client); request 115 include/crm/common/messages_internal.h } else if ((request != NULL) && (request->peer != NULL)) { request 116 include/crm/common/messages_internal.h return request->peer; request 196 include/crm/common/output_internal.h gchar *request; request 808 lib/cib/cib_file.c xmlNode *request = NULL; request 849 lib/cib/cib_file.c request = cib_create_op(cib->call_id, "dummy-token", op, host, section, data, call_options, user_name); request 851 lib/cib/cib_file.c crm_xml_add(request, XML_ACL_TAG_USER, user_name); request 860 lib/cib/cib_file.c section, request, data, TRUE, &changed, in_mem_cib, &result_cib, &cib_diff, request 863 lib/cib/cib_file.c free_xml(request); request 796 lib/common/acl.c pcmk__update_acl_user(xmlNode *request, const char *field, request 812 lib/common/acl.c requested_user = crm_element_value(request, XML_ACL_TAG_USER); request 819 lib/common/acl.c requested_user = crm_element_value(request, field); request 854 lib/common/acl.c if (user != crm_element_value(request, XML_ACL_TAG_USER)) { request 855 lib/common/acl.c crm_xml_add(request, XML_ACL_TAG_USER, user); request 858 lib/common/acl.c if (field != NULL && user != crm_element_value(request, field)) { request 859 lib/common/acl.c crm_xml_add(request, field, user); request 180 lib/common/crmcommon_private.h bool (*reply_expected)(pcmk_ipc_api_t *api, xmlNode *request); request 225 lib/common/crmcommon_private.h int pcmk__send_ipc_request(pcmk_ipc_api_t *api, xmlNode *request); request 47 lib/common/ipc_attrd.c reply_expected(pcmk_ipc_api_t *api, xmlNode *request) request 49 lib/common/ipc_attrd.c const char *command = crm_element_value(request, PCMK__XA_TASK); request 172 lib/common/ipc_attrd.c connect_and_send_attrd_request(pcmk_ipc_api_t *api, xmlNode *request) request 182 lib/common/ipc_attrd.c rc = pcmk__send_ipc_request(api, request); request 197 lib/common/ipc_attrd.c send_attrd_request(pcmk_ipc_api_t *api, xmlNode *request) request 199 lib/common/ipc_attrd.c return pcmk__send_ipc_request(api, request); request 209 lib/common/ipc_attrd.c xmlNode *request = create_attrd_op(user_name); request 218 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_TASK, PCMK__ATTRD_CMD_CLEAR_FAILURE); request 219 lib/common/ipc_attrd.c pcmk__xe_add_node(request, node, 0); request 220 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_ATTR_RESOURCE, resource); request 221 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_ATTR_OPERATION, operation); request 222 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_ATTR_INTERVAL, interval_spec); request 223 lib/common/ipc_attrd.c crm_xml_add_int(request, PCMK__XA_ATTR_IS_REMOTE, request 232 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 236 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 239 lib/common/ipc_attrd.c rc = send_attrd_request(api, request); request 242 lib/common/ipc_attrd.c free_xml(request); request 286 lib/common/ipc_attrd.c xmlNode *request = NULL; request 294 lib/common/ipc_attrd.c request = create_attrd_op(NULL); request 296 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_TASK, PCMK__ATTRD_CMD_PEER_REMOVE); request 297 lib/common/ipc_attrd.c pcmk__xe_add_node(request, node, 0); request 305 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 309 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 312 lib/common/ipc_attrd.c rc = send_attrd_request(api, request); request 315 lib/common/ipc_attrd.c free_xml(request); request 328 lib/common/ipc_attrd.c xmlNode *request = NULL; request 341 lib/common/ipc_attrd.c request = create_attrd_op(NULL); request 343 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_ATTR_NAME, name); request 344 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_TASK, PCMK__ATTRD_CMD_QUERY); request 345 lib/common/ipc_attrd.c pcmk__xe_add_node(request, node, 0); request 347 lib/common/ipc_attrd.c rc = send_attrd_request(api, request); request 348 lib/common/ipc_attrd.c free_xml(request); request 365 lib/common/ipc_attrd.c xmlNode *request = NULL; request 373 lib/common/ipc_attrd.c request = create_attrd_op(NULL); request 375 lib/common/ipc_attrd.c crm_xml_add(request, PCMK__XA_TASK, PCMK__ATTRD_CMD_REFRESH); request 376 lib/common/ipc_attrd.c pcmk__xe_add_node(request, node, 0); request 384 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 388 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 391 lib/common/ipc_attrd.c rc = send_attrd_request(api, request); request 394 lib/common/ipc_attrd.c free_xml(request); request 442 lib/common/ipc_attrd.c xmlNode *request = NULL; request 456 lib/common/ipc_attrd.c request = create_attrd_op(user_name); request 457 lib/common/ipc_attrd.c populate_update_op(request, node, name, value, dampen, set, options); request 465 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 469 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 472 lib/common/ipc_attrd.c rc = send_attrd_request(api, request); request 475 lib/common/ipc_attrd.c free_xml(request); request 489 lib/common/ipc_attrd.c xmlNode *request = NULL; request 525 lib/common/ipc_attrd.c if (request == NULL) { request 526 lib/common/ipc_attrd.c request = create_attrd_op(user_name); request 527 lib/common/ipc_attrd.c add_op_attr(request, options); request 535 lib/common/ipc_attrd.c child = create_xml_node(request, XML_ATTR_OP); request 565 lib/common/ipc_attrd.c rc = connect_and_send_attrd_request(api, request); request 566 lib/common/ipc_attrd.c free_xml(request); request 619 lib/common/ipc_client.c pcmk__send_ipc_request(pcmk_ipc_api_t *api, xmlNode *request) request 625 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL) || (request == NULL)) { request 628 lib/common/ipc_client.c crm_log_xml_trace(request, "ipc-sent"); request 634 lib/common/ipc_client.c && (api->cmds->reply_expected(api, request))) { request 639 lib/common/ipc_client.c rc = crm_ipc_send(api->ipc, request, flags, 0, &reply); request 704 lib/common/ipc_client.c xmlNode *request = NULL; request 709 lib/common/ipc_client.c request = create_xml_node(NULL, __func__); request 710 lib/common/ipc_client.c crm_xml_add(request, F_TYPE, T_ATTRD); request 711 lib/common/ipc_client.c crm_xml_add(request, F_ORIG, crm_system_name); request 712 lib/common/ipc_client.c crm_xml_add(request, PCMK__XA_TASK, PCMK__ATTRD_CMD_PEER_REMOVE); request 713 lib/common/ipc_client.c pcmk__xe_add_node(request, node_name, nodeid); request 719 lib/common/ipc_client.c request = create_request(CRM_OP_RM_NODE_CACHE, NULL, NULL, request 722 lib/common/ipc_client.c crm_xml_set_id(request, "%lu", (unsigned long) nodeid); request 724 lib/common/ipc_client.c crm_xml_add(request, XML_ATTR_UNAME, node_name); request 732 lib/common/ipc_client.c return request; request 750 lib/common/ipc_client.c xmlNode *request = NULL; request 759 lib/common/ipc_client.c request = create_purge_node_request(api, node_name, nodeid); request 760 lib/common/ipc_client.c if (request == NULL) { request 763 lib/common/ipc_client.c rc = pcmk__send_ipc_request(api, request); request 764 lib/common/ipc_client.c free_xml(request); request 144 lib/common/ipc_controld.c reply_expected(pcmk_ipc_api_t *api, xmlNode *request) request 146 lib/common/ipc_controld.c const char *command = crm_element_value(request, F_CRM_TASK); request 310 lib/common/ipc_controld.c send_controller_request(pcmk_ipc_api_t *api, xmlNode *request, request 315 lib/common/ipc_controld.c if (crm_element_value(request, XML_ATTR_REFERENCE) == NULL) { request 318 lib/common/ipc_controld.c rc = pcmk__send_ipc_request(api, request); request 354 lib/common/ipc_controld.c xmlNode *request; request 368 lib/common/ipc_controld.c request = create_controller_request(api, CRM_OP_REPROBE, router_node, request 370 lib/common/ipc_controld.c rc = send_controller_request(api, request, true); request 372 lib/common/ipc_controld.c free_xml(request); request 388 lib/common/ipc_controld.c xmlNode *request; request 391 lib/common/ipc_controld.c request = create_controller_request(api, CRM_OP_NODE_INFO, NULL, NULL); request 392 lib/common/ipc_controld.c if (request == NULL) { request 396 lib/common/ipc_controld.c crm_xml_set_id(request, "%lu", (unsigned long) nodeid); request 399 lib/common/ipc_controld.c rc = send_controller_request(api, request, true); request 400 lib/common/ipc_controld.c free_xml(request); request 416 lib/common/ipc_controld.c xmlNode *request; request 419 lib/common/ipc_controld.c request = create_controller_request(api, CRM_OP_PING, node_name, NULL); request 420 lib/common/ipc_controld.c if (request == NULL) { request 423 lib/common/ipc_controld.c rc = send_controller_request(api, request, true); request 424 lib/common/ipc_controld.c free_xml(request); request 439 lib/common/ipc_controld.c xmlNode *request; request 442 lib/common/ipc_controld.c request = create_controller_request(api, PCMK__CONTROLD_CMD_NODES, NULL, request 444 lib/common/ipc_controld.c if (request != NULL) { request 445 lib/common/ipc_controld.c rc = send_controller_request(api, request, true); request 446 lib/common/ipc_controld.c free_xml(request); request 461 lib/common/ipc_controld.c xmlNode *request, *msg_data, *xml_rsc, *params; request 506 lib/common/ipc_controld.c request = create_controller_request(api, op, router_node, msg_data); request 507 lib/common/ipc_controld.c rc = send_controller_request(api, request, true); request 509 lib/common/ipc_controld.c free_xml(request); request 157 lib/common/ipc_pacemakerd.c reply_expected(pcmk_ipc_api_t *api, xmlNode *request) request 159 lib/common/ipc_pacemakerd.c const char *command = crm_element_value(request, F_CRM_TASK); request 65 lib/common/ipc_schedulerd.c reply_expected(pcmk_ipc_api_t *api, xmlNode *request) request 67 lib/common/ipc_schedulerd.c const char *command = crm_element_value(request, F_CRM_TASK); request 580 lib/common/ipc_server.c pcmk__ipc_prepare_iov(uint32_t request, xmlNode *message, request 654 lib/common/ipc_server.c header->qb.id = (int32_t)request; /* Replying to a specific request */ request 744 lib/common/ipc_server.c pcmk__ipc_send_xml(pcmk__client_t *c, uint32_t request, xmlNode *message, request 753 lib/common/ipc_server.c rc = pcmk__ipc_prepare_iov(request, message, crm_ipc_default_buffer_size(), request 813 lib/common/ipc_server.c uint32_t request, uint32_t flags, const char *tag, request 823 lib/common/ipc_server.c rc = pcmk__ipc_send_xml(c, request, ack, flags); request 48 lib/common/messages.c xmlNode *request = NULL; request 64 lib/common/messages.c request = create_xml_node(NULL, __func__); request 65 lib/common/messages.c crm_xml_add(request, F_CRM_ORIGIN, origin); request 66 lib/common/messages.c crm_xml_add(request, F_TYPE, T_CRM); request 67 lib/common/messages.c crm_xml_add(request, F_CRM_VERSION, CRM_FEATURE_SET); request 68 lib/common/messages.c crm_xml_add(request, F_CRM_MSG_TYPE, XML_ATTR_REQUEST); request 69 lib/common/messages.c crm_xml_add(request, F_CRM_REFERENCE, reference); request 70 lib/common/messages.c crm_xml_add(request, F_CRM_TASK, task); request 71 lib/common/messages.c crm_xml_add(request, F_CRM_SYS_TO, sys_to); request 72 lib/common/messages.c crm_xml_add(request, F_CRM_SYS_FROM, true_from); request 76 lib/common/messages.c crm_xml_add(request, F_CRM_HOST_TO, host_to); request 80 lib/common/messages.c add_message_xml(request, F_CRM_DATA, msg_data); request 85 lib/common/messages.c return request; request 251 lib/common/messages.c pcmk__process_request(pcmk__request_t *request, GHashTable *handlers) request 253 lib/common/messages.c xmlNode *(*handler)(pcmk__request_t *request) = NULL; request 255 lib/common/messages.c CRM_CHECK((request != NULL) && (request->op != NULL) && (handlers != NULL), request 258 lib/common/messages.c if (pcmk_is_set(request->flags, pcmk__request_sync) request 259 lib/common/messages.c && (request->ipc_client != NULL)) { request 260 lib/common/messages.c CRM_CHECK(request->ipc_client->request_id == request->ipc_id, request 264 lib/common/messages.c handler = g_hash_table_lookup(handlers, request->op); request 269 lib/common/messages.c request->op, pcmk__request_origin_type(request), request 270 lib/common/messages.c pcmk__request_origin(request)); request 275 lib/common/messages.c return (*handler)(request); request 285 lib/common/messages.c pcmk__reset_request(pcmk__request_t *request) request 287 lib/common/messages.c free(request->op); request 288 lib/common/messages.c request->op = NULL; request 290 lib/common/messages.c pcmk__reset_result(&(request->result)); request 37 lib/common/output.c g_free(out->request); request 159 lib/common/output_html.c } else if (out->request != NULL) { request 160 lib/common/output_html.c pcmk_create_xml_text_node(head_node, "title", out->request); request 403 lib/common/output_html.c retval->request = pcmk__quote_cmdline(argv); request 280 lib/common/output_log.c retval->request = pcmk__quote_cmdline(argv); request 124 lib/common/output_none.c retval->request = pcmk__quote_cmdline(argv); request 302 lib/common/output_text.c retval->request = pcmk__quote_cmdline(argv); request 125 lib/common/output_xml.c if (out->request != NULL) { request 126 lib/common/output_xml.c crm_xml_add(priv->root, "request", out->request); request 408 lib/common/output_xml.c retval->request = pcmk__quote_cmdline(argv); request 228 lib/lrmd/proxy_common.c xmlNode *request = get_message_xml(msg, F_LRMD_IPC_MSG); request 231 lib/lrmd/proxy_common.c CRM_CHECK(request != NULL, return); request 249 lib/lrmd/proxy_common.c crm_xml_add(request, XML_ACL_TAG_ROLE, "pacemaker-remote"); request 252 lib/lrmd/proxy_common.c pcmk__update_acl_user(request, F_LRMD_IPC_USER, node_name); request 255 lib/lrmd/proxy_common.c const char *type = crm_element_value(request, F_TYPE); request 259 lib/lrmd/proxy_common.c && crm_element_value(request, request 261 lib/lrmd/proxy_common.c && pcmk__str_any_of(crm_element_value(request, PCMK__XA_TASK), request 265 lib/lrmd/proxy_common.c pcmk__xe_add_node(request, proxy->node_name, 0); request 268 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 5000, NULL); request 297 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 10000, &op_reply); request 53 maint/gnulib/lib/fd-hook.c int fd, int request, void *arg) request 57 maint/gnulib/lib/fd-hook.c return primary (fd, request, arg); request 60 maint/gnulib/lib/fd-hook.c primary, fd, request, arg); request 65 maint/gnulib/lib/fd-hook.c int fd, int request, void *arg) request 67 maint/gnulib/lib/fd-hook.c return execute_ioctl_hooks (anchor.private_next, primary, fd, request, arg); request 35 maint/gnulib/lib/fd-hook.h typedef int (*gl_ioctl_fn) (int fd, int request, void *arg); request 57 maint/gnulib/lib/fd-hook.h int fd, int request, void *arg); request 88 maint/gnulib/lib/fd-hook.h int fd, int request, void *arg); request 94 maint/gnulib/lib/fd-hook.h int fd, int request, void *arg); request 99 maint/gnulib/lib/fd-hook.h int fd, int request, void *arg); request 31 maint/gnulib/lib/ioctl.c rpl_ioctl (int fd, int request, ... /* {void *,char *} arg */) request 36 maint/gnulib/lib/ioctl.c va_start (args, request); request 42 maint/gnulib/lib/ioctl.c return ioctl (fd, (unsigned int) request, buf); request 62 maint/gnulib/lib/ioctl.c primary_ioctl (int fd, int request, void *arg) request 76 maint/gnulib/lib/ioctl.c ioctl (int fd, int request, ... /* {void *,char *} arg */) request 81 maint/gnulib/lib/ioctl.c va_start (args, request); request 86 maint/gnulib/lib/ioctl.c return execute_all_ioctl_hooks (primary_ioctl, fd, request, arg); request 88 maint/gnulib/lib/ioctl.c return primary_ioctl (fd, request, arg); request 84 maint/gnulib/lib/sockets.c int fd, int request, void *arg) request 96 maint/gnulib/lib/sockets.c if (ioctlsocket (sock, request, arg) < 0) request 106 maint/gnulib/lib/sockets.c return execute_ioctl_hooks (remaining_list, primary, fd, request, arg); request 54 maint/gnulib/lib/sys_ioctl.in.h (int fd, int request, ... /* {void *,char *} arg */)); request 56 maint/gnulib/lib/sys_ioctl.in.h (int fd, int request, ... /* {void *,char *} arg */)); request 60 maint/gnulib/lib/sys_ioctl.in.h (int fd, int request, ... /* {void *,char *} arg */)); request 63 maint/gnulib/lib/sys_ioctl.in.h (int fd, int request, ... /* {void *,char *} arg */)); request 348 tools/crm_mon_curses.c retval->request = pcmk__quote_cmdline(argv);