diff mbox series

[V3,07/15] core/pldm: Encode PLDM PDR Repository Change eventData

Message ID 20220913102724.65563-8-clombard@linux.vnet.ibm.com
State Superseded
Headers show
Series Complete PLDM responder and enable PLDM support | expand

Commit Message

Christophe Lombard Sept. 13, 2022, 10:27 a.m. UTC
Encode the platform PDR repository change event message request that tells
the BMC that a specific PDR entry has changed.

Signed-off-by: Christophe Lombard <clombard@linux.vnet.ibm.com>
---
 core/pldm/pldm-platform-requests.c | 119 +++++++++++++++++++++++++++++
 1 file changed, 119 insertions(+)

Comments

Abhishek Singh Tomar Sept. 30, 2022, 12:23 p.m. UTC | #1
On Tue, Sep 13, 2022 at 12:27:16PM +0200, Christophe Lombard wrote:
> Encode the platform PDR repository change event message request that tells
> the BMC that a specific PDR entry has changed.
> 
> Signed-off-by: Christophe Lombard <clombard@linux.vnet.ibm.com>
Reviewed-by: Abhishek Singh Tomar <abhishek@linux.ibm.com>
> ---
>  core/pldm/pldm-platform-requests.c | 119 +++++++++++++++++++++++++++++
>  1 file changed, 119 insertions(+)
> 
> diff --git a/core/pldm/pldm-platform-requests.c b/core/pldm/pldm-platform-requests.c
> index f355d9aa..280cc238 100644
> --- a/core/pldm/pldm-platform-requests.c
> +++ b/core/pldm/pldm-platform-requests.c
> @@ -244,6 +244,125 @@ int pldm_platform_restart(void)
>  	return set_state_effecter_states_req(effecter_id, &field, true);
>  }
> 
> +static int send_repository_changed_event(uint32_t num_changed_pdrs,
> +					 uint32_t *record_handle)
> +{
> +	size_t actual_change_records_size = 0;
> +	uint8_t number_of_change_entries[1];
> +	size_t max_change_records_size = 0;
> +	size_t response_len, payload_len;
> +	uint8_t event_data_operation[1];
> +	uint32_t *change_entries[1];
> +	uint8_t *event_data = NULL;
> +	uint32_t request_length;
> +	void *response_msg;
> +	char *request_msg;
> +	int rc, i;
> +
> +	struct pldm_platform_event_message_req event_message_req = {
> +		.format_version = PLDM_PLATFORM_EVENT_MESSAGE_FORMAT_VERSION,
> +		.tid = HOST_TID,
> +		.event_class = PLDM_PDR_REPOSITORY_CHG_EVENT,
> +	};
> +
> +	struct pldm_platform_event_message_resp response;
> +
> +	prlog(PR_DEBUG, "%s - num_changed_pdrs: %d\n", __func__, num_changed_pdrs);
> +
> +	if (num_changed_pdrs == 0)
> +		return OPAL_PARAMETER;
> +
> +	/* encode the platform change event data */
> +	event_data_operation[0] = PLDM_RECORDS_ADDED;
> +	number_of_change_entries[0] = num_changed_pdrs;
> +	change_entries[0] = record_handle;
> +
> +	/*
> +	 * The first time around this loop, event_data is nullptr which
> +	 * instructs the encoder to not actually do the encoding, but
> +	 * rather fill out actual_change_records_size with the correct
> +	 * size, stop and return PLDM_SUCCESS. Then we allocate the
> +	 * proper amount of memory and call the encoder again, which
> +	 * will cause it to actually encode the message.
> +	 */
> +	for (i = 0; i < 2; i++) {
> +		rc = encode_pldm_pdr_repository_chg_event_data(
> +					FORMAT_IS_PDR_HANDLES,
> +					1, /* only one change record (RECORDS_ADDED) */
> +					event_data_operation,
> +					number_of_change_entries,
> +					(const uint32_t * const*)change_entries,
> +					(struct pldm_pdr_repository_chg_event_data *)event_data,
> +					&actual_change_records_size,
> +					max_change_records_size);
> +		if (rc) {
> +			prlog(PR_ERR, "Encode PldmPdrRepositoryChgEventData Error, rc: %d\n", rc);
> +			return OPAL_PARAMETER;
> +		}
> +
> +		if (event_data == NULL) {
> +			max_change_records_size = actual_change_records_size;
> +			event_data = zalloc(max_change_records_size);
> +		}
> +	}
> +
> +	/* Send the event request */
> +	payload_len = PLDM_PLATFORM_EVENT_MESSAGE_MIN_REQ_BYTES + max_change_records_size;
> +
> +	request_length = sizeof(struct pldm_msg_hdr) +
> +			 sizeof(struct pldm_platform_event_message_req) +
> +			 max_change_records_size;
> +	request_msg = zalloc(request_length);
> +
> +	/* Encode the platform event message request */
> +	rc = encode_platform_event_message_req(
> +			DEFAULT_INSTANCE_ID,
> +			event_message_req.format_version,
> +			event_message_req.tid,
> +			event_message_req.event_class,
> +			(const uint8_t *)event_data,
> +			max_change_records_size,
> +			(struct pldm_msg *)request_msg,
> +			payload_len);
> +	if (rc != PLDM_SUCCESS) {
> +		prlog(PR_ERR, "Encode PlatformEventMessage Error, rc: %d\n", rc);
> +		free(event_data);
> +		free(request_msg);
> +		return OPAL_PARAMETER;
> +	}
> +	free(event_data);
> +
> +	/* Send and get the response message bytes */
> +	rc = pldm_requester_queue_and_wait(
> +				request_msg, request_length - 1,
> +				&response_msg, &response_len);
> +	if (rc) {
> +		prlog(PR_ERR, "Communication Error, req: PlatformEventMessage, rc: %d\n", rc);
> +		free(request_msg);
> +		return rc;
> +	}
> +	free(request_msg);
> +
> +	/* Decode the message */
> +	payload_len = response_len - sizeof(struct pldm_msg_hdr);
> +	rc = decode_platform_event_message_resp(
> +				response_msg,
> +				payload_len,
> +				&response.completion_code,
> +				&response.platform_event_status);
> +	if (rc != PLDM_SUCCESS || response.completion_code != PLDM_SUCCESS) {
> +		prlog(PR_ERR, "Decode PlatformEventMessage Error, rc: %d, cc: %d, pes: %d\n",
> +			      rc, response.completion_code,
> +			      response.platform_event_status);
> +		free(response_msg);
> +		return OPAL_PARAMETER;
> +	}
> +
> +	free(response_msg);
> +
> +	return OPAL_SUCCESS;
> +}
> +
>  struct get_pdr_response {
>  	uint8_t completion_code;
>  	uint32_t next_record_hndl;
> -- 
> 2.37.3
> 
> _______________________________________________
> Skiboot mailing list
> Skiboot@lists.ozlabs.org
> https://lists.ozlabs.org/listinfo/skiboot
diff mbox series

Patch

diff --git a/core/pldm/pldm-platform-requests.c b/core/pldm/pldm-platform-requests.c
index f355d9aa..280cc238 100644
--- a/core/pldm/pldm-platform-requests.c
+++ b/core/pldm/pldm-platform-requests.c
@@ -244,6 +244,125 @@  int pldm_platform_restart(void)
 	return set_state_effecter_states_req(effecter_id, &field, true);
 }
 
+static int send_repository_changed_event(uint32_t num_changed_pdrs,
+					 uint32_t *record_handle)
+{
+	size_t actual_change_records_size = 0;
+	uint8_t number_of_change_entries[1];
+	size_t max_change_records_size = 0;
+	size_t response_len, payload_len;
+	uint8_t event_data_operation[1];
+	uint32_t *change_entries[1];
+	uint8_t *event_data = NULL;
+	uint32_t request_length;
+	void *response_msg;
+	char *request_msg;
+	int rc, i;
+
+	struct pldm_platform_event_message_req event_message_req = {
+		.format_version = PLDM_PLATFORM_EVENT_MESSAGE_FORMAT_VERSION,
+		.tid = HOST_TID,
+		.event_class = PLDM_PDR_REPOSITORY_CHG_EVENT,
+	};
+
+	struct pldm_platform_event_message_resp response;
+
+	prlog(PR_DEBUG, "%s - num_changed_pdrs: %d\n", __func__, num_changed_pdrs);
+
+	if (num_changed_pdrs == 0)
+		return OPAL_PARAMETER;
+
+	/* encode the platform change event data */
+	event_data_operation[0] = PLDM_RECORDS_ADDED;
+	number_of_change_entries[0] = num_changed_pdrs;
+	change_entries[0] = record_handle;
+
+	/*
+	 * The first time around this loop, event_data is nullptr which
+	 * instructs the encoder to not actually do the encoding, but
+	 * rather fill out actual_change_records_size with the correct
+	 * size, stop and return PLDM_SUCCESS. Then we allocate the
+	 * proper amount of memory and call the encoder again, which
+	 * will cause it to actually encode the message.
+	 */
+	for (i = 0; i < 2; i++) {
+		rc = encode_pldm_pdr_repository_chg_event_data(
+					FORMAT_IS_PDR_HANDLES,
+					1, /* only one change record (RECORDS_ADDED) */
+					event_data_operation,
+					number_of_change_entries,
+					(const uint32_t * const*)change_entries,
+					(struct pldm_pdr_repository_chg_event_data *)event_data,
+					&actual_change_records_size,
+					max_change_records_size);
+		if (rc) {
+			prlog(PR_ERR, "Encode PldmPdrRepositoryChgEventData Error, rc: %d\n", rc);
+			return OPAL_PARAMETER;
+		}
+
+		if (event_data == NULL) {
+			max_change_records_size = actual_change_records_size;
+			event_data = zalloc(max_change_records_size);
+		}
+	}
+
+	/* Send the event request */
+	payload_len = PLDM_PLATFORM_EVENT_MESSAGE_MIN_REQ_BYTES + max_change_records_size;
+
+	request_length = sizeof(struct pldm_msg_hdr) +
+			 sizeof(struct pldm_platform_event_message_req) +
+			 max_change_records_size;
+	request_msg = zalloc(request_length);
+
+	/* Encode the platform event message request */
+	rc = encode_platform_event_message_req(
+			DEFAULT_INSTANCE_ID,
+			event_message_req.format_version,
+			event_message_req.tid,
+			event_message_req.event_class,
+			(const uint8_t *)event_data,
+			max_change_records_size,
+			(struct pldm_msg *)request_msg,
+			payload_len);
+	if (rc != PLDM_SUCCESS) {
+		prlog(PR_ERR, "Encode PlatformEventMessage Error, rc: %d\n", rc);
+		free(event_data);
+		free(request_msg);
+		return OPAL_PARAMETER;
+	}
+	free(event_data);
+
+	/* Send and get the response message bytes */
+	rc = pldm_requester_queue_and_wait(
+				request_msg, request_length - 1,
+				&response_msg, &response_len);
+	if (rc) {
+		prlog(PR_ERR, "Communication Error, req: PlatformEventMessage, rc: %d\n", rc);
+		free(request_msg);
+		return rc;
+	}
+	free(request_msg);
+
+	/* Decode the message */
+	payload_len = response_len - sizeof(struct pldm_msg_hdr);
+	rc = decode_platform_event_message_resp(
+				response_msg,
+				payload_len,
+				&response.completion_code,
+				&response.platform_event_status);
+	if (rc != PLDM_SUCCESS || response.completion_code != PLDM_SUCCESS) {
+		prlog(PR_ERR, "Decode PlatformEventMessage Error, rc: %d, cc: %d, pes: %d\n",
+			      rc, response.completion_code,
+			      response.platform_event_status);
+		free(response_msg);
+		return OPAL_PARAMETER;
+	}
+
+	free(response_msg);
+
+	return OPAL_SUCCESS;
+}
+
 struct get_pdr_response {
 	uint8_t completion_code;
 	uint32_t next_record_hndl;