Differential D24428 Diff 71767 sys/dev/smartpqi/smartpqi_response.c

Changeset View

Standalone View

sys/dev/smartpqi/smartpqi_response.c

	/*-			/*-
	* Copyright (c) 2018 Microsemi Corporation.			* Copyright (c) 2016-2019 Microsemi Corporation.
				* Copyright (c) 2020 Microchip Technology Inc. and it's subsidiaries.
				*
	* All rights reserved.			* All rights reserved.
	*			*
	* Redistribution and use in source and binary forms, with or without			* Redistribution and use in source and binary forms, with or without
	* modification, are permitted provided that the following conditions			* modification, are permitted provided that the following conditions
	* are met:			* are met:
	* 1. Redistributions of source code must retain the above copyright			* 1. Redistributions of source code must retain the above copyright
	* notice, this list of conditions and the following disclaimer.			* notice, this list of conditions and the following disclaimer.
	* 2. Redistributions in binary form must reproduce the above copyright			* 2. Redistributions in binary form must reproduce the above copyright
	Show All 15 Lines

	/* $FreeBSD$ */			/* $FreeBSD$ */

	#include "smartpqi_includes.h"			#include "smartpqi_includes.h"

	/*			/*
	* Process internal RAID response in the case of success.			* Process internal RAID response in the case of success.
	*/			*/
	void pqisrc_process_internal_raid_response_success(pqisrc_softstate_t *softs,			void
	rcb_t *rcb)			pqisrc_process_internal_raid_response_success(pqisrc_softstate_t softs,rcb_t rcb)
	{			{
	DBG_FUNC("IN");			DBG_FUNC("IN");

	rcb->status = REQUEST_SUCCESS;			rcb->status = REQUEST_SUCCESS;
	rcb->req_pending = false;			rcb->req_pending = false;

	DBG_FUNC("OUT");			DBG_FUNC("OUT");
	}			}

	/*			/*
	* Process internal RAID response in the case of failure.			* Process internal RAID response in the case of failure.
	*/			*/
	void pqisrc_process_internal_raid_response_error(pqisrc_softstate_t *softs,			void
				pqisrc_process_internal_raid_response_error(pqisrc_softstate_t *softs,
	rcb_t *rcb, uint16_t err_idx)			rcb_t *rcb, uint16_t err_idx)
	{			{
	raid_path_error_info_elem_t error_info;			raid_path_error_info_elem_t error_info;

	DBG_FUNC("IN");			DBG_FUNC("IN");

	rcb->error_info = (char *) (softs->err_buf_dma_mem.virt_addr) +			rcb->error_info = (char *) (softs->err_buf_dma_mem.virt_addr) +
	(err_idx * PQI_ERROR_BUFFER_ELEMENT_LENGTH);			(err_idx * PQI_ERROR_BUFFER_ELEMENT_LENGTH);
	rcb->status = REQUEST_SUCCESS;
	memcpy(&error_info, rcb->error_info, sizeof(error_info));			memcpy(&error_info, rcb->error_info, sizeof(error_info));

	DBG_INFO("error_status 0x%x data_in_result 0x%x data_out_result 0x%x\n",			DBG_INFO("error_status 0x%x data_in_result 0x%x data_out_result 0x%x\n",
	error_info.status, error_info.data_in_result, error_info.data_out_result);			error_info.status, error_info.data_in_result, error_info.data_out_result);

	if (error_info.status != 0)
	rcb->status = REQUEST_FAILED;			rcb->status = REQUEST_FAILED;
	if (error_info.data_in_result != PQI_RAID_DATA_IN_OUT_GOOD)
	rcb->status = REQUEST_FAILED;
	if (error_info.data_out_result != PQI_RAID_DATA_IN_OUT_GOOD)
	rcb->status = REQUEST_FAILED;

				switch (error_info.data_out_result) {
				case PQI_RAID_DATA_IN_OUT_GOOD:
				if (error_info.status == PQI_RAID_DATA_IN_OUT_GOOD)
				rcb->status = REQUEST_SUCCESS;
				break;
				case PQI_RAID_DATA_IN_OUT_UNDERFLOW:
				if (error_info.status == PQI_RAID_DATA_IN_OUT_GOOD \|\|
				error_info.status == PQI_RAID_STATUS_CHECK_CONDITION)
				rcb->status = REQUEST_SUCCESS;
				break;
				}

	rcb->req_pending = false;			rcb->req_pending = false;

	DBG_FUNC("OUT");			DBG_FUNC("OUT");
	}			}

	/*			/*
	* Process the AIO/RAID IO in the case of success.			* Process the AIO/RAID IO in the case of success.
	*/			*/
	void pqisrc_process_io_response_success(pqisrc_softstate_t *softs,			void
	rcb_t *rcb)			pqisrc_process_io_response_success(pqisrc_softstate_t softs, rcb_t rcb)
	{			{
	DBG_FUNC("IN");			DBG_FUNC("IN");

	os_io_response_success(rcb);			os_io_response_success(rcb);

	DBG_FUNC("OUT");			DBG_FUNC("OUT");
	}			}

				static void
				pqisrc_extract_sense_data(sense_data_u_t sense_data, uint8_t key, uint8_t asc, uint8_t ascq)
				{
				if (sense_data->fixed_format.response_code == SCSI_SENSE_RESPONSE_70 \|\|
				sense_data->fixed_format.response_code == SCSI_SENSE_RESPONSE_71)
				{
				sense_data_fixed_t *fixed = &sense_data->fixed_format;

				*key = fixed->sense_key;
				*asc = fixed->sense_code;
				*ascq = fixed->sense_qual;
				}
				else if (sense_data->descriptor_format.response_code == SCSI_SENSE_RESPONSE_72 \|\|
				sense_data->descriptor_format.response_code == SCSI_SENSE_RESPONSE_73)
				{
				sense_data_descriptor_t *desc = &sense_data->descriptor_format;

				*key = desc->sense_key;
				*asc = desc->sense_code;
				*ascq = desc->sense_qual;
				}
				else
				{
				*key = 0xFF;
				*asc = 0xFF;
				*ascq = 0xFF;
				}
				}

				static void
				pqisrc_show_sense_data_simple(pqisrc_softstate_t softs, rcb_t rcb, sense_data_u_t *sense_data)
				{
				uint8_t opcode = rcb->cdbp ? rcb->cdbp[0] : 0xFF;
				char *path = io_path_to_ascii(rcb->path);
				uint8_t key, asc, ascq;
				pqisrc_extract_sense_data(sense_data, &key, &asc, &ascq);

				DBG_NOTE("[ERR INFO] BTL: %d:%d:%d op=0x%x path=%s K:C:Q: %x:%x:%x\n",
				rcb->dvp->bus, rcb->dvp->target, rcb->dvp->lun,
				opcode, path, key, asc, ascq);
				}

				void
				pqisrc_show_sense_data_full(pqisrc_softstate_t softs, rcb_t rcb, sense_data_u_t *sense_data)
				{
				pqisrc_print_buffer(softs, "sense data", sense_data, 32, 0);

				pqisrc_show_sense_data_simple(softs, rcb, sense_data);

				/* add more detail here as needed */
				}


	/*			/*
	* Process the error info for AIO in the case of failure.			* Process the error info for AIO in the case of failure.
	*/			*/
	void pqisrc_process_aio_response_error(pqisrc_softstate_t *softs,			void
				pqisrc_process_aio_response_error(pqisrc_softstate_t *softs,
	rcb_t *rcb, uint16_t err_idx)			rcb_t *rcb, uint16_t err_idx)
	{			{
	aio_path_error_info_elem_t *err_info = NULL;			aio_path_error_info_elem_t *err_info = NULL;

	DBG_FUNC("IN");			DBG_FUNC("IN");

	err_info = (aio_path_error_info_elem_t*)			err_info = (aio_path_error_info_elem_t*)
	softs->err_buf_dma_mem.virt_addr +			softs->err_buf_dma_mem.virt_addr +
	err_idx;			err_idx;

	if(err_info == NULL) {			if(err_info == NULL) {
	DBG_ERR("err_info structure is NULL err_idx :%x", err_idx);			DBG_ERR("err_info structure is NULL err_idx :%x", err_idx);
	return;			return;
	}			}

	os_aio_response_error(rcb, err_info);			os_aio_response_error(rcb, err_info);

	DBG_FUNC("OUT");			DBG_FUNC("OUT");
	}			}

	/*			/*
	* Process the error info for RAID IO in the case of failure.			* Process the error info for RAID IO in the case of failure.
	*/			*/
	void pqisrc_process_raid_response_error(pqisrc_softstate_t *softs,			void
				pqisrc_process_raid_response_error(pqisrc_softstate_t *softs,
	rcb_t *rcb, uint16_t err_idx)			rcb_t *rcb, uint16_t err_idx)
	{			{
	raid_path_error_info_elem_t *err_info = NULL;			raid_path_error_info_elem_t *err_info = NULL;

	DBG_FUNC("IN");			DBG_FUNC("IN");

	err_info = (raid_path_error_info_elem_t*)			err_info = (raid_path_error_info_elem_t*)
	softs->err_buf_dma_mem.virt_addr +			softs->err_buf_dma_mem.virt_addr +
	err_idx;			err_idx;

	if(err_info == NULL) {			if(err_info == NULL) {
	DBG_ERR("err_info structure is NULL err_idx :%x", err_idx);			DBG_ERR("err_info structure is NULL err_idx :%x", err_idx);
	return;			return;
	}			}

	os_raid_response_error(rcb, err_info);			os_raid_response_error(rcb, err_info);

	DBG_FUNC("OUT");			DBG_FUNC("OUT");
	}			}

	/*			/*
	* Process the Task Management function response.			* Process the Task Management function response.
	*/			*/
	int pqisrc_process_task_management_response(pqisrc_softstate_t *softs,			int
				pqisrc_process_task_management_response(pqisrc_softstate_t *softs,
	pqi_tmf_resp_t *tmf_resp)			pqi_tmf_resp_t *tmf_resp)
	{			{
	int ret = REQUEST_SUCCESS;			int ret = REQUEST_SUCCESS;
	uint32_t tag = (uint32_t)tmf_resp->req_id;			uint32_t tag = (uint32_t)tmf_resp->req_id;
	rcb_t *rcb = &softs->rcb[tag];			rcb_t *rcb = &softs->rcb[tag];

	ASSERT(rcb->tag == tag);			ASSERT(rcb->tag == tag);

	DBG_FUNC("IN\n");			DBG_FUNC("IN\n");

	switch (tmf_resp->resp_code) {			switch (tmf_resp->resp_code) {
	case SOP_TASK_MANAGEMENT_FUNCTION_COMPLETE:			case SOP_TASK_MANAGEMENT_FUNCTION_COMPLETE:
	case SOP_TASK_MANAGEMENT_FUNCTION_SUCCEEDED:			case SOP_TASK_MANAGEMENT_FUNCTION_SUCCEEDED:
	ret = REQUEST_SUCCESS;			ret = REQUEST_SUCCESS;
	break;			break;
	default:			default:
	DBG_ERR("TMF Failed, Response code : 0x%x\n", tmf_resp->resp_code);			DBG_WARN("TMF Failed, Response code : 0x%x\n", tmf_resp->resp_code);
	ret = REQUEST_FAILED;			ret = REQUEST_FAILED;
	break;			break;
	}			}

	rcb->status = ret;			rcb->status = ret;
	rcb->req_pending = false;			rcb->req_pending = false;

	DBG_FUNC("OUT");			DBG_FUNC("OUT");
	return ret;			return ret;
	}			}

				static int
				pqisrc_process_vendor_general_response(pqi_vendor_general_response_t *response)
				{

				int ret = REQUEST_SUCCESS;

				switch(response->status) {
				case PQI_VENDOR_RESPONSE_IU_SUCCESS:
				break;
				case PQI_VENDOR_RESPONSE_IU_UNSUCCESS:
				case PQI_VENDOR_RESPONSE_IU_INVALID_PARAM:
				case PQI_VENDOR_RESPONSE_IU_INSUFF_RESRC:
				ret = REQUEST_FAILED;
				break;
				}

				return ret;
				}

	/*			/*
	* Function used to process the response from the adapter			* Function used to process the response from the adapter
	* which is invoked by IRQ handler.			* which is invoked by IRQ handler.
	*/			*/
	void			void
	pqisrc_process_response_queue(pqisrc_softstate_t *softs, int oq_id)			pqisrc_process_response_queue(pqisrc_softstate_t *softs, int oq_id)
	{			{
	ob_queue_t *ob_q;			ob_queue_t *ob_q;
	struct pqi_io_response *response;			struct pqi_io_response *response;
	uint32_t oq_pi, oq_ci;			uint32_t oq_pi, oq_ci;

	DBG_FUNC("IN");			DBG_FUNC("IN");

	OS_ATOMIC64_INC(softs, num_intrs);

	ob_q = &softs->op_ob_q[oq_id - 1]; /* zero for event Q */			ob_q = &softs->op_ob_q[oq_id - 1]; /* zero for event Q */
	oq_ci = ob_q->ci_local;			oq_ci = ob_q->ci_local;
	oq_pi = *(ob_q->pi_virt_addr);			oq_pi = *(ob_q->pi_virt_addr);

	DBG_INFO("ci : %d pi : %d qid : %d\n", oq_ci, oq_pi, ob_q->q_id);			DBG_INFO("ci : %d pi : %d qid : %d\n", oq_ci, oq_pi, ob_q->q_id);

	while (1) {			while (1) {
	rcb_t *rcb = NULL;			rcb_t *rcb = NULL;
	uint32_t tag = 0;			uint32_t tag = 0;
	uint32_t offset;			uint32_t offset;

	if (oq_pi == oq_ci)			if (oq_pi == oq_ci)
	break;			break;
	/* Get the response */			/* Get the response */
	offset = oq_ci * ob_q->elem_size;			offset = oq_ci * ob_q->elem_size;
	response = (struct pqi_io_response *)(ob_q->array_virt_addr +			response = (struct pqi_io_response *)(ob_q->array_virt_addr +
	offset);			offset);
	tag = response->request_id;			tag = response->request_id;
	rcb = &softs->rcb[tag];			rcb = &softs->rcb[tag];
	/* Make sure we are processing a valid response. */			/* Make sure we are processing a valid response. */
	ASSERT(rcb->tag == tag && rcb->req_pending);			if ((rcb->tag != tag) \|\| (rcb->req_pending == false)) {
	rcb->req_pending = false;			DBG_ERR("No such request pending with tag : %x", tag);
				oq_ci = (oq_ci + 1) % ob_q->num_elem;
				break;
				}
				/* Timedout request has been completed. This should not hit,
				* if timeout is set as TIMEOUT_INFINITE while calling
				* pqisrc_wait_on_condition(softs,rcb,timeout).
				*/
				if (rcb->timedout) {
				DBG_WARN("timed out request completing from firmware, driver already completed it with failure , free the tag %d\n", tag);
				oq_ci = (oq_ci + 1) % ob_q->num_elem;
				os_reset_rcb(rcb);
				pqisrc_put_tag(&softs->taglist, tag);
				break;
				}


	DBG_INFO("response.header.iu_type : %x \n", response->header.iu_type);			DBG_INFO("response.header.iu_type : %x \n", response->header.iu_type);

	switch (response->header.iu_type) {			switch (response->header.iu_type) {
	case PQI_RESPONSE_IU_RAID_PATH_IO_SUCCESS:			case PQI_RESPONSE_IU_RAID_PATH_IO_SUCCESS:
	case PQI_RESPONSE_IU_AIO_PATH_IO_SUCCESS:			case PQI_RESPONSE_IU_AIO_PATH_IO_SUCCESS:
				pqisrc_decrement_device_active_io(softs, rcb);
	rcb->success_cmp_callback(softs, rcb);			rcb->success_cmp_callback(softs, rcb);
	break;			break;
	case PQI_RESPONSE_IU_RAID_PATH_IO_ERROR:			case PQI_RESPONSE_IU_RAID_PATH_IO_ERROR:
	case PQI_RESPONSE_IU_AIO_PATH_IO_ERROR:			case PQI_RESPONSE_IU_AIO_PATH_IO_ERROR:
				pqisrc_decrement_device_active_io(softs, rcb);
	rcb->error_cmp_callback(softs, rcb, LE_16(response->error_index));			rcb->error_cmp_callback(softs, rcb, LE_16(response->error_index));
	break;			break;
	case PQI_RESPONSE_IU_GENERAL_MANAGEMENT:			case PQI_RESPONSE_IU_GENERAL_MANAGEMENT:
	rcb->req_pending = false;			rcb->req_pending = false;
				break;
				case PQI_RESPONSE_IU_VENDOR_GENERAL:
				rcb->req_pending = false;
				rcb->status = pqisrc_process_vendor_general_response(
				(pqi_vendor_general_response_t *)response);
	break;			break;
	case PQI_RESPONSE_IU_TASK_MANAGEMENT:			case PQI_RESPONSE_IU_TASK_MANAGEMENT:
	rcb->status = pqisrc_process_task_management_response(softs, (void *)response);			rcb->status = pqisrc_process_task_management_response(softs, (void *)response);
	break;			break;

	default:			default:
	DBG_ERR("Invalid Response IU 0x%x\n",response->header.iu_type);			DBG_ERR("Invalid Response IU 0x%x\n",response->header.iu_type);
	break;			break;
	}			}

	oq_ci = (oq_ci + 1) % ob_q->num_elem;			oq_ci = (oq_ci + 1) % ob_q->num_elem;
	}			}

	ob_q->ci_local = oq_ci;			ob_q->ci_local = oq_ci;
	PCI_MEM_PUT32(softs, ob_q->ci_register_abs,			PCI_MEM_PUT32(softs, ob_q->ci_register_abs,
	ob_q->ci_register_offset, ob_q->ci_local );			ob_q->ci_register_offset, ob_q->ci_local );
	DBG_FUNC("OUT");			DBG_FUNC("OUT");
	}			}