/*
 * 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 2008 Sun Microsystems, Inc.  All rights reserved.
 * Use is subject to license terms.
 */

#include <syslog.h>
#include <errno.h>
#include <unistd.h>
#include <stropts.h>

#include "mp_utils.h"

#include <libdevinfo.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <sys/stat.h>


static MP_STATUS doDevInfoStuffForIntPort(MP_OID oid)
{
	di_node_t root_node	= DI_NODE_NIL;

	di_node_t vh_node	= DI_NODE_NIL;
	di_node_t ph_node	= DI_NODE_NIL;
	di_node_t sv_node	= DI_NODE_NIL;


	di_path_t path = DI_PATH_NIL;

	struct stat buffer;

	int instNum = 0;
	int majorNum = 0;

	int oidInstNum = 0;
	int oidMajorNum = 0;

	int found = 0;
	int status = -1;


	char *pathName  = NULL;
	char *minorName = "c";

	char fullName[512];




	log(LOG_INFO, "doDevInfoStuffForIntPort()", " - enter");


	oidInstNum  = (int)MP_GET_INST_FROM_ID(oid.objectSequenceNumber);
	oidMajorNum = (int)MP_GET_MAJOR_FROM_ID(oid.objectSequenceNumber);


	root_node = di_init("/", DINFOCACHE);
	if (DI_NODE_NIL == root_node) {
		log(LOG_INFO, "doDevInfoStuffForIntPort()",
			" - di_init() failed");

		return (MP_STATUS_FAILED);
	}

	vh_node = di_vhci_first_node(root_node);

	while (DI_NODE_NIL != vh_node) {
		if ((di_driver_name(vh_node) != NULL) &&
		    (strncmp(di_driver_name(vh_node), "scsi_vhci", 9) == 0)) {
			ph_node = di_phci_first_node(vh_node);
			while (DI_NODE_NIL != ph_node) {

				instNum  = di_instance(ph_node);
				majorNum = di_driver_major(ph_node);

				if ((majorNum == oidMajorNum) &&
					(instNum == oidInstNum)) {

					log(LOG_INFO,
					    "doDevInfoStuffForIntPort()",
						"got a match");

					found = 1;

					break;
				}

				ph_node = di_phci_next_node(ph_node);
			}
		}

		if (found) {

			break;
		}

		vh_node = di_vhci_next_node(vh_node);
	}


	if (!found) {

		di_fini(root_node);

		log(LOG_INFO,
			"doDevInfoStuffForIntPort()",
			" - no match found, error exit");

		return (MP_STATUS_OBJECT_NOT_FOUND);
	}


	path = di_path_next(ph_node, DI_PATH_NIL);

	if (DI_PATH_NIL == path) {

		log(LOG_INFO, "doDevInfoStuffForIntPort()",
			" - path is DI_PATH_NIL");
	}

	while (DI_PATH_NIL != path) {

		sv_node = di_path_client_node(path);
		if (DI_NODE_NIL == sv_node) {

			log(LOG_INFO, "doDevInfoStuffForIntPort()",
				" - sv_node is DI_NODE_NIL");

		} else {

			pathName = di_devfs_path(sv_node);
			(void) snprintf(fullName, 511, "/devices%s:%s",
				pathName, minorName);

			(void) di_devfs_path_free(pathName);

			status = stat(fullName, &buffer);
			if (status < 0) {

				log(LOG_INFO,
					"doDevInfoStuffForIntPort()",
					" - stat() call failed: %d", status);

				log(LOG_INFO,
				    "doDevInfoStuffForIntPort()",
					" - errno: [%d].", errno);

				log(LOG_INFO,
				    "doDevInfoStuffForIntPort()",
					" - strerror(errno): [%s].",
					strerror(errno));


				di_fini(root_node);

				log(LOG_INFO,
					"doDevInfoStuffForIntPort()",
					" - error exit.");

				return (MP_STATUS_FAILED);
			}
		}

		path = di_path_next(ph_node, path);
	}


	di_fini(root_node);

	log(LOG_INFO, "doDevInfoStuffForIntPort()", " - exit");

	return (MP_STATUS_SUCCESS);
}


static MP_STATUS doDevInfoStuffForTargetPort(MP_OID oid)
{
	di_node_t root_node	= DI_NODE_NIL;
	di_node_t sv_node	= DI_NODE_NIL;
	di_node_t child_node = DI_NODE_NIL;

	di_path_t path = DI_PATH_NIL;

	int match = 0;
	int count = 0;
	int ioctlStatus = 0;
	int status = -1;

	struct stat buffer;

	char *pathName  = NULL;
	char *minorName = "c";

	char fullName[512];

	uchar_t *targetPort = NULL;

	mp_iocdata_t mp_ioctl;

	mp_target_port_prop_t tpInfo;

	MP_STATUS mpStatus = MP_STATUS_SUCCESS;


	log(LOG_INFO, "doDevInfoStuffForTargetPort()", " - enter");


	log(LOG_INFO, "doDevInfoStuffForTargetPort()",
		"oid.objectSequenceNumber = %llx",
		oid.objectSequenceNumber);

	(void) memset(&mp_ioctl, 0, sizeof (mp_iocdata_t));
	(void) memset(&tpInfo,   0, sizeof (mp_target_port_prop_t));

	mp_ioctl.mp_cmd  = MP_GET_TARGET_PORT_PROP;
	mp_ioctl.mp_ibuf = (caddr_t)&oid.objectSequenceNumber;
	mp_ioctl.mp_ilen = sizeof (oid.objectSequenceNumber);
	mp_ioctl.mp_obuf = (caddr_t)&tpInfo;
	mp_ioctl.mp_olen = sizeof (mp_target_port_prop_t);
	mp_ioctl.mp_xfer = MP_XFER_READ;

	log(LOG_INFO, "doDevInfoStuffForTargetPort()",
		"mp_ioctl.mp_cmd (MP_GET_TARGET_PORT_PROP) : %d",
		mp_ioctl.mp_cmd);

	ioctlStatus = ioctl(g_scsi_vhci_fd, MP_CMD, &mp_ioctl);

	log(LOG_INFO, "doDevInfoStuffForTargetPort()",
		" IOCTL call returned: %d", ioctlStatus);

	if (ioctlStatus < 0) {
		ioctlStatus = errno;
	}

	if (ioctlStatus != 0) {
		log(LOG_INFO, "doDevInfoStuffForTargetPort()",
			"IOCTL call failed.  IOCTL error is: %d",
			ioctlStatus);
		log(LOG_INFO, "doDevInfoStuffForTargetPort()",
			"IOCTL call failed.  IOCTL error is: %s",
			strerror(ioctlStatus));
		log(LOG_INFO, "doDevInfoStuffForTargetPort()",
			"IOCTL call failed.  mp_ioctl.mp_errno: %x",
			mp_ioctl.mp_errno);

		if (ENOTSUP == ioctlStatus) {
			mpStatus = MP_STATUS_UNSUPPORTED;
		} else if (0 == mp_ioctl.mp_errno) {
			mpStatus = MP_STATUS_FAILED;
		} else {
			mpStatus =
				getStatus4ErrorCode(mp_ioctl.mp_errno);
		}

		log(LOG_INFO, "doDevInfoStuffForTargetPort()",
			" - error exit");

		return (mpStatus);
	}

	root_node = di_init("/", DINFOCACHE);

	if (DI_NODE_NIL == root_node) {
		log(LOG_INFO, "doDevInfoStuffForTargetPort()",
			" - di_init() failed");

		return (MP_STATUS_FAILED);
	}


	sv_node = di_drv_first_node("scsi_vhci", root_node);
	if (DI_NODE_NIL == sv_node) {
		log(LOG_INFO, "doDevInfoStuffForTargetPort()",
			" - di_drv_first_node() failed");

		di_fini(root_node);

		return (MP_STATUS_FAILED);
	}

	child_node = di_child_node(sv_node);

	while (DI_NODE_NIL != child_node) {

		path = di_path_next(child_node, path);

		match = 0;

		while (DI_PATH_NIL != path) {

			count = di_path_prop_lookup_bytes(path,
						"target-port",
						&targetPort);

			if (NULL != targetPort) {

				if (0 == memcmp(targetPort,
						tpInfo.portName,
						count)) {

					match = 1;

					break;
				}
			}

			path = di_path_next(child_node, path);
		}

		if (match) {

			log(LOG_INFO, "doDevInfoStuffForTargetPort()",
				" - got a match");

			pathName = di_devfs_path(child_node);

			(void) snprintf(fullName, 511, "/devices%s:%s",
				pathName, minorName);

			(void) di_devfs_path_free(pathName);

			status = stat(fullName, &buffer);
			if (status < 0) {

				log(LOG_INFO,
					"doDevInfoStuffForTargetPort()",
					" - stat() call failed: %d", status);

				log(LOG_INFO,
				    "doDevInfoStuffForTargetPort()",
					" - errno: [%d].", errno);

				log(LOG_INFO,
				    "doDevInfoStuffForTargetPort()",
					" - strerror(errno): [%s].",
					strerror(errno));


				di_fini(root_node);

				log(LOG_INFO,
					"doDevInfoStuffForTargetPort()",
					" - error exit.");

				return (MP_STATUS_FAILED);
			}
		}

		child_node = di_sibling_node(child_node);
	}


	di_fini(root_node);

	log(LOG_INFO, "doDevInfoStuffForTargetPort()", " - exit");

	return (MP_STATUS_SUCCESS);
}



MP_STATUS
MP_GetAssociatedPathOidList(MP_OID oid, MP_OID_LIST **ppList)
{
	mp_iocdata_t mp_ioctl;

	uint64_t *objList = NULL;

	int numOBJ = 0;
	int i = 0;
	int ioctlStatus = 0;

	MP_STATUS mpStatus = MP_STATUS_SUCCESS;

	int request = MP_GET_PATH_LIST_FOR_MP_LU;


	log(LOG_INFO, "MP_GetAssociatedPathOidList()", " - enter");


	log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		" set default request to MP_GET_PATH_LIST_FOR_MP_LU");

	log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		"oid.objectSequenceNumber = %llx",
		oid.objectSequenceNumber);


	if (g_scsi_vhci_fd < 0) {
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		    "invalid driver file handle");
		log(LOG_INFO, "MP_GetAssociatedPathOidList()", " - error exit");
		return (MP_STATUS_FAILED);
	}

	if (MP_OBJECT_TYPE_INITIATOR_PORT == oid.objectType) {
		request = MP_GET_PATH_LIST_FOR_INIT_PORT;
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			" set request to MP_GET_PATH_LIST_FOR_INIT_PORT");

		mpStatus = doDevInfoStuffForIntPort(oid);
		if (MP_STATUS_SUCCESS != mpStatus) {

			return (mpStatus);
		}
	} else if (MP_OBJECT_TYPE_TARGET_PORT == oid.objectType) {
		request = MP_GET_PATH_LIST_FOR_TARGET_PORT;
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			" set request to MP_GET_PATH_LIST_FOR_TARGET_PORT");

		mpStatus = doDevInfoStuffForTargetPort(oid);
		if (MP_STATUS_SUCCESS != mpStatus) {

			return (mpStatus);
		}
	}

	objList = (uint64_t *)calloc(1, DEFAULT_BUFFER_SIZE_PATH_LIST);
	if (NULL == objList) {
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			"no memory for objList(1)");
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			" - error exit");
		return (MP_STATUS_INSUFFICIENT_MEMORY);
	}

	(void) memset(&mp_ioctl, 0, sizeof (mp_iocdata_t));

	mp_ioctl.mp_cmd  = request;
	mp_ioctl.mp_ibuf = (caddr_t)&oid.objectSequenceNumber;
	mp_ioctl.mp_ilen = sizeof (oid.objectSequenceNumber);
	mp_ioctl.mp_obuf = (caddr_t)objList;
	mp_ioctl.mp_olen = DEFAULT_BUFFER_SIZE_PATH_LIST;
	mp_ioctl.mp_xfer = MP_XFER_READ;

	log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		"mp_ioctl.mp_cmd : %d", mp_ioctl.mp_cmd);
	log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		"mp_ioctl.mp_obuf: %x", mp_ioctl.mp_obuf);
	log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		"mp_ioctl.mp_olen: %d", mp_ioctl.mp_olen);
	log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		"mp_ioctl.mp_xfer: %d (MP_XFER_READ)",
		mp_ioctl.mp_xfer);

	ioctlStatus = ioctl(g_scsi_vhci_fd, MP_CMD, &mp_ioctl);
	log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		"ioctl call returned ioctlStatus: %d",
		ioctlStatus);

	if (ioctlStatus < 0) {
		ioctlStatus = errno;
	}

	if ((ioctlStatus != 0) && (MP_MORE_DATA != mp_ioctl.mp_errno)) {

		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		    "IOCTL call failed.  IOCTL error is: %d",
			ioctlStatus);
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		    "IOCTL call failed.  IOCTL error is: %s",
			strerror(ioctlStatus));
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		    "IOCTL call failed.  mp_ioctl.mp_errno: %x",
			mp_ioctl.mp_errno);


		free(objList);

		if (ENOTSUP == ioctlStatus) {
			mpStatus = MP_STATUS_UNSUPPORTED;
		} else if (0 == mp_ioctl.mp_errno) {
			mpStatus = MP_STATUS_FAILED;
		} else {
			mpStatus = getStatus4ErrorCode(mp_ioctl.mp_errno);
		}

		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			" - error exit");

		return (mpStatus);
	}

	log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		" - mp_ioctl.mp_alen : %d",
		mp_ioctl.mp_alen);
	log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		" - sizeof (uint64_t): %d",
		sizeof (uint64_t));

	numOBJ = mp_ioctl.mp_alen / sizeof (uint64_t);
	log(LOG_INFO, "MP_GetAssociatedPathOidList()",
	    "Length of list: %d", numOBJ);

	if (numOBJ < 1) {
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			"driver returned empty list.");

		free(objList);

		*ppList = createOidList(1);
		if (NULL == *ppList) {
			log(LOG_INFO,
				"MP_GetAssociatedPathOidList()",
				"no memory for MP_OID_LIST");
			log(LOG_INFO,
				"MP_GetAssociatedPathOidList()",
				" - error exit");
			return (MP_STATUS_INSUFFICIENT_MEMORY);
		}

		return (MP_STATUS_SUCCESS);
	}

	if (mp_ioctl.mp_alen > DEFAULT_BUFFER_SIZE_PATH_LIST) {

		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			"buffer size too small, need : %d",
			mp_ioctl.mp_alen);

		free(objList);

		objList = (uint64_t *)calloc(1, numOBJ * sizeof (uint64_t));
		if (NULL == objList) {
			log(LOG_INFO, "MP_GetAssociatedPathOidList()",
				"no memory for objList(2)");
			log(LOG_INFO, "MP_GetAssociatedPathOidList()",
				" - error exit");
			return (MP_STATUS_INSUFFICIENT_MEMORY);
		}

		(void) memset(&mp_ioctl, 0, sizeof (mp_iocdata_t));

		mp_ioctl.mp_cmd  = request;
		mp_ioctl.mp_ibuf = (caddr_t)&oid.objectSequenceNumber;
		mp_ioctl.mp_ilen = sizeof (oid.objectSequenceNumber);
		mp_ioctl.mp_obuf = (caddr_t)objList;
		mp_ioctl.mp_olen = numOBJ * sizeof (uint64_t);
		mp_ioctl.mp_xfer = MP_XFER_READ;

		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			"mp_ioctl.mp_cmd : %d", mp_ioctl.mp_cmd);
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			"mp_ioctl.mp_obuf: %x", mp_ioctl.mp_obuf);
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			"mp_ioctl.mp_olen: %d", mp_ioctl.mp_olen);
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			"mp_ioctl.mp_xfer: %d (MP_XFER_READ)",
			mp_ioctl.mp_xfer);


		ioctlStatus = ioctl(g_scsi_vhci_fd, MP_CMD, &mp_ioctl);
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			"ioctl call returned ioctlStatus: %d",
			ioctlStatus);

		if (ioctlStatus < 0) {
			ioctlStatus = errno;
		}

		if (ioctlStatus != 0) {

			log(LOG_INFO, "MP_GetAssociatedPathOidList()",
				"IOCTL call failed.  IOCTL error is: %d",
				ioctlStatus);
			log(LOG_INFO, "MP_GetAssociatedPathOidList()",
				"IOCTL call failed.  IOCTL error is: %s",
				strerror(ioctlStatus));
			log(LOG_INFO, "MP_GetAssociatedPathOidList()",
				"IOCTL call failed.  mp_ioctl.mp_errno: %x",
				mp_ioctl.mp_errno);


			free(objList);

			if (ENOTSUP == ioctlStatus) {
				mpStatus = MP_STATUS_UNSUPPORTED;
			} else if (0 == mp_ioctl.mp_errno) {
				mpStatus = MP_STATUS_FAILED;
			} else {
				mpStatus =
					getStatus4ErrorCode(mp_ioctl.mp_errno);
			}

			log(LOG_INFO, "MP_GetAssociatedPathOidList()",
				" - error exit");

			return (mpStatus);
		}
	}


	*ppList = createOidList(numOBJ);
	if (NULL == *ppList) {
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			"no memory for *ppList");
		free(objList);
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			" - error exit");
		return (MP_STATUS_INSUFFICIENT_MEMORY);
	}

	(*ppList)->oidCount = numOBJ;

	log(LOG_INFO, "MP_GetAssociatedPathOidList()",
		"(*ppList)->oidCount = %d",
		(*ppList)->oidCount);

	for (i = 0; i < numOBJ; i++) {
		(*ppList)->oids[i].objectType = MP_OBJECT_TYPE_PATH_LU;
		(*ppList)->oids[i].ownerId = g_pluginOwnerID;
		(*ppList)->oids[i].objectSequenceNumber = objList[i];

		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			"(*ppList)->oids[%d].objectType           = %d",
			i, (*ppList)->oids[i].objectType);
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			"(*ppList)->oids[%d].ownerId              = %d",
			i, (*ppList)->oids[i].ownerId);
		log(LOG_INFO, "MP_GetAssociatedPathOidList()",
			"(*ppList)->oids[%d].objectSequenceNumber = %llx",
			i, (*ppList)->oids[i].objectSequenceNumber);
	}

	free(objList);


	log(LOG_INFO, "MP_GetAssociatedPathOidList()", " - exit");

	return (MP_STATUS_SUCCESS);
}