/*
 * CDDL HEADER START
 *
 * The contents of this file are subject to the terms of the
 * Common Development and Distribution License (the "License").
 * You may not use this file except in compliance with the License.
 *
 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
 * or http://www.opensolaris.org/os/licensing.
 * See the License for the specific language governing permissions
 * and limitations under the License.
 *
 * When distributing Covered Code, include this CDDL HEADER in each
 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
 * If applicable, add the following below this CDDL HEADER, with the
 * fields enclosed by brackets "[]" replaced with your own identifying
 * information: Portions Copyright [yyyy] [name of copyright owner]
 *
 * CDDL HEADER END
 */

/*
 * Copyright 2009 Sun Microsystems, Inc.  All rights reserved.
 * Use is subject to license terms.
 */
/*
 * Copyright 2019 Joyent, Inc.
 */

#include <sun_sas.h>

/*
 * Combine uscsi command ans send it out via ioctl
 */
static HBA_STATUS
SendScsiInquiry(const char *devpath, HBA_UINT8 cdb1, HBA_UINT8 cdb2,
    void *responseBuffer, HBA_UINT32 *responseSize, HBA_UINT8 *scsiStatus,
    void *senseBuffer, HBA_UINT32 *senseSize)
{
	HBA_UINT32		status;
	struct uscsi_cmd	ucmd_buf;
	union scsi_cdb		cdb;

	bzero(&cdb, sizeof (cdb));
	bzero(&ucmd_buf, sizeof (ucmd_buf));
	bzero(senseBuffer, *senseSize);
	bzero(responseBuffer, *responseSize);

	cdb.scc_cmd = SCMD_INQUIRY;
	cdb.g0_addr1 = cdb2;
	cdb.g0_addr2 = cdb1;
	cdb.g0_count0 = *responseSize;

	ucmd_buf.uscsi_cdb = (char *)&cdb;
	ucmd_buf.uscsi_cdblen = CDB_GROUP0;
	ucmd_buf.uscsi_bufaddr = (caddr_t)responseBuffer;
	ucmd_buf.uscsi_buflen = *responseSize;
	ucmd_buf.uscsi_rqbuf = (caddr_t)senseBuffer;
	ucmd_buf.uscsi_rqlen = *senseSize;
	ucmd_buf.uscsi_flags = USCSI_READ | USCSI_SILENT | USCSI_RQENABLE;

	status = send_uscsi_cmd(devpath, &ucmd_buf);
	*scsiStatus = ucmd_buf.uscsi_status;
	return (status);
}


/*
 * Send a SCSI inquiry to a remote WWN
 */
HBA_STATUS
Sun_sasScsiInquiry(HBA_HANDLE handle, HBA_WWN portWWN, HBA_WWN targetPortWWN,
    HBA_WWN domainPortWWN, SMHBA_SCSILUN smhbaLUN, HBA_UINT8 cdb1,
    HBA_UINT8 cdb2, void *responseBuffer, HBA_UINT32 *responseSize,
    HBA_UINT8 *scsiStatus, void *senseBuffer, HBA_UINT32 *senseSize)
{
	const char		ROUTINE[] = "Sun_sasScsiInquiry";
	HBA_STATUS		status;
	int			index = 0;
	int			domainPortFound = 0;
	int			hbaPortFound = 0;
	int			chkDomainPort = 0;
	struct sun_sas_hba	*hba_ptr = NULL;
	struct sun_sas_port	*hba_port_ptr, *hba_disco_port;
	struct ScsiEntryList	*mapping_ptr;
	hrtime_t		start, end;
	double			duration;
	HBA_SCSILUN		hba_lun;

	start = gethrtime();
	/* Validate the arguments */
	if (responseBuffer == NULL) {
		log(LOG_DEBUG, ROUTINE, "NULL response buffer");
		return (HBA_STATUS_ERROR_ARG);
	}
	if (senseBuffer == NULL) {
		log(LOG_DEBUG, ROUTINE, "NULL sense buffer");
		return (HBA_STATUS_ERROR_ARG);
	}
	if (responseSize == NULL) {
		log(LOG_DEBUG, ROUTINE, "NULL response size");
		return (HBA_STATUS_ERROR_ARG);
	}
	if (senseSize == NULL) {
		log(LOG_DEBUG, ROUTINE, "NULL sense size");
		return (HBA_STATUS_ERROR_ARG);
	}
	if (scsiStatus == NULL) {
		log(LOG_DEBUG, ROUTINE, "NULL scsi status");
		return (HBA_STATUS_ERROR_ARG);
	}

	lock(&all_hbas_lock);
	index = RetrieveIndex(handle);
	lock(&open_handles_lock);
	if ((hba_ptr = RetrieveHandle(index)) == NULL) {
		log(LOG_DEBUG, ROUTINE, "Invalid handle %08lx", handle);
		unlock(&open_handles_lock);
		unlock(&all_hbas_lock);
		return (HBA_STATUS_ERROR_INVALID_HANDLE);
	}

	/* Check for stale data */
	status = verifyAdapter(hba_ptr);
	if (status != HBA_STATUS_OK) {
		log(LOG_DEBUG, ROUTINE, "Verify adapter failed");
		unlock(&open_handles_lock);
		unlock(&all_hbas_lock);
		return (status);
	}

	/*
	 * We are not checking to see if our data is stale.
	 * By verifying this information here, we will take a big performance
	 * hit.  This check will be done later only if the Inquiry ioctl fails
	 */
	if (hba_ptr->device_path[0] == '\0') {
		log(LOG_DEBUG, ROUTINE,
		    "HBA handle had empty device path. \
		    Unable to send SCSI cmd");
		unlock(&open_handles_lock);
		unlock(&all_hbas_lock);
		return (HBA_STATUS_ERROR);
	}

	if (wwnConversion(domainPortWWN.wwn))
		chkDomainPort = 1;

	/* Determine which port to use */
	for (hba_port_ptr = hba_ptr->first_port;
	    hba_port_ptr != NULL;
	    hba_port_ptr = hba_port_ptr->next) {

		if (hbaPortFound == 0) {
			if (wwnConversion(hba_port_ptr->port_attributes.
			    PortSpecificAttribute.SASPort->LocalSASAddress.wwn)
			    != wwnConversion(portWWN.wwn)) {
				/*
				 * Since all the ports under the same HBA have
				 * the same LocalSASAddress, we should break
				 * the loop once we find it dosn't match.
				 */
				break;
			} else {
				hbaPortFound = 1;
			}
		}

		if (chkDomainPort) {
			if (hba_port_ptr->first_phy != NULL &&
			    wwnConversion(hba_port_ptr->first_phy->
			    phy.domainPortWWN.wwn) ==
			    wwnConversion(domainPortWWN.wwn)) {
				domainPortFound = 1;
			}
			if (!(domainPortFound)) {
				continue;
			}
		}

		for (hba_disco_port = hba_port_ptr->first_attached_port;
		    hba_disco_port != NULL;
		    hba_disco_port = hba_disco_port->next) {

			/*
			 * If discoveredPort is not given targetPort, just skip
			 */
			if (wwnConversion(hba_disco_port->port_attributes.\
			    PortSpecificAttribute.SASPort->LocalSASAddress.wwn)
			    != wwnConversion(targetPortWWN.wwn)) {
				/* Does not match */
				continue;
			}

			/*
			 * If discoveredPort is not a SAS/SATA port, it is not a
			 * target port
			 */
			if ((hba_disco_port->port_attributes.PortType !=
			    HBA_PORTTYPE_SATADEVICE) &&
			    (hba_disco_port->port_attributes.PortType !=
			    HBA_PORTTYPE_SASDEVICE)) {
				unlock(&open_handles_lock);
				unlock(&all_hbas_lock);
				log(LOG_DEBUG, ROUTINE, "Target Port WWN "
				    "%016llx on handle %08lx is not a Target",
				    wwnConversion(targetPortWWN.wwn), handle);
				return (HBA_STATUS_ERROR_NOT_A_TARGET);
			}

			/*
			 * Iterating and matching is needed.
			 */
			for (mapping_ptr = hba_disco_port->scsiInfo;
			    mapping_ptr != NULL;
			    mapping_ptr = mapping_ptr->next) {

				if (memcmp(
				    &mapping_ptr->entry.PortLun.TargetLun,
				    &smhbaLUN, sizeof (HBA_SCSILUN))
				    != 0) {
					continue;
				}

				status = SendScsiInquiry(
				    mapping_ptr->entry.ScsiId.OSDeviceName,
				    cdb1, cdb2,
				    responseBuffer, responseSize,
				    scsiStatus, senseBuffer,
				    senseSize);

				unlock(&open_handles_lock);
				unlock(&all_hbas_lock);
				end = gethrtime();
				duration = end - start;
				duration /= HR_SECOND;
				log(LOG_DEBUG, ROUTINE, "Took total\
				    of %.4f seconds", duration);
				return (status);
			}
			unlock(&open_handles_lock);
			unlock(&all_hbas_lock);
			(void *) memcpy(&hba_lun, &smhbaLUN,
			    sizeof (HBA_SCSILUN));
			log(LOG_DEBUG, ROUTINE, "Unable to locate lun"
			    " %08lx for target %016llx on handle %08lx",
			    hba_lun, wwnConversion(targetPortWWN.wwn), handle);
			return (HBA_STATUS_ERROR_INVALID_LUN);
		}
		if (chkDomainPort) {
			unlock(&open_handles_lock);
			unlock(&all_hbas_lock);
			log(LOG_DEBUG, ROUTINE, "Unable to locate requested "
			    "Port WWN %016llx on handle %08lx",
			    wwnConversion(targetPortWWN.wwn), handle);
			return (HBA_STATUS_ERROR_ILLEGAL_WWN);
		}
	}

	unlock(&open_handles_lock);
	unlock(&all_hbas_lock);
	if (hbaPortFound == 0) {
		log(LOG_DEBUG, ROUTINE,
		    "Unable to locate requested Port WWN %016llx on "
		    "handle %08lx", wwnConversion(portWWN.wwn), handle);
	} else if (chkDomainPort && !domainPortFound) {
		log(LOG_DEBUG, ROUTINE, "Unable to locate requested"
		    " domainPortWWN %016llx on handle %08lx",
		    wwnConversion(domainPortWWN.wwn), handle);
	} else {
		log(LOG_DEBUG, ROUTINE, "Unable to locate requested "
		    "Port WWN %016llx on handle %08lx",
		    wwnConversion(targetPortWWN.wwn), handle);
	}
	return (HBA_STATUS_ERROR_ILLEGAL_WWN);
}