145039663SJohn Forte /*
245039663SJohn Forte  * CDDL HEADER START
345039663SJohn Forte  *
445039663SJohn Forte  * The contents of this file are subject to the terms of the
545039663SJohn Forte  * Common Development and Distribution License (the "License").
645039663SJohn Forte  * You may not use this file except in compliance with the License.
745039663SJohn Forte  *
845039663SJohn Forte  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
945039663SJohn Forte  * or http://www.opensolaris.org/os/licensing.
1045039663SJohn Forte  * See the License for the specific language governing permissions
1145039663SJohn Forte  * and limitations under the License.
1245039663SJohn Forte  *
1345039663SJohn Forte  * When distributing Covered Code, include this CDDL HEADER in each
1445039663SJohn Forte  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
1545039663SJohn Forte  * If applicable, add the following below this CDDL HEADER, with the
1645039663SJohn Forte  * fields enclosed by brackets "[]" replaced with your own identifying
1745039663SJohn Forte  * information: Portions Copyright [yyyy] [name of copyright owner]
1845039663SJohn Forte  *
1945039663SJohn Forte  * CDDL HEADER END
2045039663SJohn Forte  */
2145039663SJohn Forte /*
224558d122SViswanathan Kannappan  * Copyright (c) 2009, 2010, Oracle and/or its affiliates. All rights reserved.
23*ef3b9e2fSDan McDonald  * Copyright 2013, Nexenta Systems, Inc. All rights reserved.
2445039663SJohn Forte  */
2545039663SJohn Forte 
2645039663SJohn Forte #include <sys/cpuvar.h>
2745039663SJohn Forte #include <sys/types.h>
2845039663SJohn Forte #include <sys/conf.h>
2945039663SJohn Forte #include <sys/stat.h>
3045039663SJohn Forte #include <sys/file.h>
3145039663SJohn Forte #include <sys/ddi.h>
3245039663SJohn Forte #include <sys/sunddi.h>
3345039663SJohn Forte #include <sys/modctl.h>
3445039663SJohn Forte #include <sys/sysmacros.h>
3545039663SJohn Forte #include <sys/nvpair.h>
3645039663SJohn Forte #include <sys/door.h>
37e617f214Speter dunlap #include <sys/sdt.h>
3845039663SJohn Forte 
3945039663SJohn Forte #include <sys/stmf.h>
4045039663SJohn Forte #include <sys/stmf_ioctl.h>
4145039663SJohn Forte #include <sys/pppt_ioctl.h>
4245039663SJohn Forte #include <sys/portif.h>
434558d122SViswanathan Kannappan 
444558d122SViswanathan Kannappan #include "pppt.h"
4545039663SJohn Forte 
4645039663SJohn Forte #define	PPPT_VERSION		BUILD_DATE "-1.18dev"
4845039663SJohn Forte 
4945039663SJohn Forte /*
5045039663SJohn Forte  * DDI entry points.
5145039663SJohn Forte  */
5245039663SJohn Forte static int pppt_drv_attach(dev_info_t *, ddi_attach_cmd_t);
5345039663SJohn Forte static int pppt_drv_detach(dev_info_t *, ddi_detach_cmd_t);
5445039663SJohn Forte static int pppt_drv_getinfo(dev_info_t *, ddi_info_cmd_t, void *, void **);
5545039663SJohn Forte static int pppt_drv_open(dev_t *, int, int, cred_t *);
5645039663SJohn Forte static int pppt_drv_close(dev_t, int, int, cred_t *);
5745039663SJohn Forte static boolean_t pppt_drv_busy(void);
5845039663SJohn Forte static int pppt_drv_ioctl(dev_t, int, intptr_t, int, cred_t *, int *);
5945039663SJohn Forte 
6045039663SJohn Forte extern pppt_status_t pppt_ic_so_enable(boolean_t);
6145039663SJohn Forte extern void pppt_ic_so_disable();
6245039663SJohn Forte extern void stmf_ic_rx_msg(char *, size_t);
6345039663SJohn Forte 
6445039663SJohn Forte extern struct mod_ops mod_miscops;
6545039663SJohn Forte 
6645039663SJohn Forte static struct cb_ops pppt_cb_ops = {
6745039663SJohn Forte 	pppt_drv_open,	/* cb_open */
6845039663SJohn Forte 	pppt_drv_close,	/* cb_close */
6945039663SJohn Forte 	nodev,			/* cb_strategy */
7045039663SJohn Forte 	nodev,			/* cb_print */
7145039663SJohn Forte 	nodev,			/* cb_dump */
7245039663SJohn Forte 	nodev,			/* cb_read */
7345039663SJohn Forte 	nodev,			/* cb_write */
7445039663SJohn Forte 	pppt_drv_ioctl,		/* cb_ioctl */
7545039663SJohn Forte 	nodev,			/* cb_devmap */
7645039663SJohn Forte 	nodev,			/* cb_mmap */
7745039663SJohn Forte 	nodev,			/* cb_segmap */
7845039663SJohn Forte 	nochpoll,		/* cb_chpoll */
7945039663SJohn Forte 	ddi_prop_op,		/* cb_prop_op */
8045039663SJohn Forte 	NULL,			/* cb_streamtab */
8145039663SJohn Forte 	D_MP,			/* cb_flag */
8245039663SJohn Forte 	CB_REV,			/* cb_rev */
8345039663SJohn Forte 	nodev,			/* cb_aread */
8445039663SJohn Forte 	nodev,			/* cb_awrite */
8545039663SJohn Forte };
8645039663SJohn Forte 
8745039663SJohn Forte static struct dev_ops pppt_dev_ops = {
8845039663SJohn Forte 	DEVO_REV,		/* devo_rev */
8945039663SJohn Forte 	0,			/* devo_refcnt */
9045039663SJohn Forte 	pppt_drv_getinfo,	/* devo_getinfo */
9145039663SJohn Forte 	nulldev,		/* devo_identify */
9245039663SJohn Forte 	nulldev,		/* devo_probe */
9345039663SJohn Forte 	pppt_drv_attach,	/* devo_attach */
9445039663SJohn Forte 	pppt_drv_detach,	/* devo_detach */
9545039663SJohn Forte 	nodev,			/* devo_reset */
9645039663SJohn Forte 	&pppt_cb_ops,		/* devo_cb_ops */
9745039663SJohn Forte 	NULL,			/* devo_bus_ops */
9845039663SJohn Forte 	NULL,			/* devo_power */
9945039663SJohn Forte 	ddi_quiesce_not_needed,	/* quiesce */
10045039663SJohn Forte };
10145039663SJohn Forte 
10245039663SJohn Forte static struct modldrv modldrv = {
10345039663SJohn Forte 	&mod_driverops,
10445039663SJohn Forte 	"Proxy Port Provider",
10545039663SJohn Forte 	&pppt_dev_ops,
10645039663SJohn Forte };
10745039663SJohn Forte 
10845039663SJohn Forte static struct modlinkage modlinkage = {
10945039663SJohn Forte 	MODREV_1,
11045039663SJohn Forte 	&modldrv,
11145039663SJohn Forte 	NULL,
11245039663SJohn Forte };
11345039663SJohn Forte 
11445039663SJohn Forte pppt_global_t pppt_global;
11545039663SJohn Forte 
11645039663SJohn Forte int pppt_logging = 0;
11745039663SJohn Forte 
11845039663SJohn Forte static int pppt_enable_svc(void);
11945039663SJohn Forte 
12045039663SJohn Forte static void pppt_disable_svc(void);
12145039663SJohn Forte 
12245039663SJohn Forte static int pppt_task_avl_compare(const void *tgt1, const void *tgt2);
12345039663SJohn Forte 
12445039663SJohn Forte static stmf_data_buf_t *pppt_dbuf_alloc(scsi_task_t *task,
12545039663SJohn Forte     uint32_t size, uint32_t *pminsize, uint32_t flags);
12645039663SJohn Forte 
12745039663SJohn Forte static void pppt_dbuf_free(stmf_dbuf_store_t *ds, stmf_data_buf_t *dbuf);
12845039663SJohn Forte 
12945039663SJohn Forte static void pppt_sess_destroy_task(void *ps_void);
13045039663SJohn Forte 
13145039663SJohn Forte static void pppt_task_sent_status(pppt_task_t *ptask);
13245039663SJohn Forte 
13345039663SJohn Forte static pppt_status_t pppt_task_try_abort(pppt_task_t *ptask);
13445039663SJohn Forte 
13545039663SJohn Forte static void pppt_task_rele(pppt_task_t *ptask);
13645039663SJohn Forte 
13745039663SJohn Forte static void pppt_task_update_state(pppt_task_t *ptask,
13845039663SJohn Forte     pppt_task_state_t new_state);
13945039663SJohn Forte 
14045039663SJohn Forte /*
14145039663SJohn Forte  * Lock order:  global --> target --> session --> task
14245039663SJohn Forte  */
14345039663SJohn Forte 
14445039663SJohn Forte int
_init(void)14545039663SJohn Forte _init(void)
14645039663SJohn Forte {
14745039663SJohn Forte 	int rc;
14845039663SJohn Forte 
14945039663SJohn Forte 	mutex_init(&pppt_global.global_lock, NULL, MUTEX_DEFAULT, NULL);
15045039663SJohn Forte 	mutex_init(&pppt_global.global_door_lock, NULL, MUTEX_DEFAULT, NULL);
15145039663SJohn Forte 	pppt_global.global_svc_state = PSS_DETACHED;
15245039663SJohn Forte 
15345039663SJohn Forte 	if ((rc = mod_install(&modlinkage)) != 0) {
15445039663SJohn Forte 		mutex_destroy(&pppt_global.global_door_lock);
15545039663SJohn Forte 		mutex_destroy(&pppt_global.global_lock);
15645039663SJohn Forte 		return (rc);
15745039663SJohn Forte 	}
15845039663SJohn Forte 
15945039663SJohn Forte 	return (rc);
16045039663SJohn Forte }
16145039663SJohn Forte 
16245039663SJohn Forte int
_info(struct modinfo * modinfop)16345039663SJohn Forte _info(struct modinfo *modinfop)
16445039663SJohn Forte {
16545039663SJohn Forte 	return (mod_info(&modlinkage, modinfop));
16645039663SJohn Forte }
16745039663SJohn Forte 
16845039663SJohn Forte int
_fini(void)16945039663SJohn Forte _fini(void)
17045039663SJohn Forte {
17145039663SJohn Forte 	int rc;
17245039663SJohn Forte 
17345039663SJohn Forte 	rc = mod_remove(&modlinkage);
17445039663SJohn Forte 
17545039663SJohn Forte 	if (rc == 0) {
17645039663SJohn Forte 		mutex_destroy(&pppt_global.global_lock);
17745039663SJohn Forte 		mutex_destroy(&pppt_global.global_door_lock);
17845039663SJohn Forte 	}
17945039663SJohn Forte 
18045039663SJohn Forte 	return (rc);
18145039663SJohn Forte }
18245039663SJohn Forte 
18345039663SJohn Forte /*
18445039663SJohn Forte  * DDI entry points.
18545039663SJohn Forte  */
18645039663SJohn Forte 
18745039663SJohn Forte /* ARGSUSED */
18845039663SJohn Forte static int
pppt_drv_getinfo(dev_info_t * dip,ddi_info_cmd_t cmd,void * arg,void ** result)18945039663SJohn Forte pppt_drv_getinfo(dev_info_t *dip, ddi_info_cmd_t cmd, void *arg,
19045039663SJohn Forte     void **result)
19145039663SJohn Forte {
19245039663SJohn Forte 	ulong_t instance = getminor((dev_t)arg);
19345039663SJohn Forte 
19445039663SJohn Forte 	switch (cmd) {
19545039663SJohn Forte 	case DDI_INFO_DEVT2DEVINFO:
19645039663SJohn Forte 		*result = pppt_global.global_dip;
19745039663SJohn Forte 		return (DDI_SUCCESS);
19845039663SJohn Forte 
19945039663SJohn Forte 	case DDI_INFO_DEVT2INSTANCE:
20045039663SJohn Forte 		*result = (void *)instance;
20145039663SJohn Forte 		return (DDI_SUCCESS);
20245039663SJohn Forte 
20345039663SJohn Forte 	default:
20445039663SJohn Forte 		break;
20545039663SJohn Forte 	}
20645039663SJohn Forte 
20745039663SJohn Forte 	return (DDI_FAILURE);
20845039663SJohn Forte }
20945039663SJohn Forte 
21045039663SJohn Forte static int
pppt_drv_attach(dev_info_t * dip,ddi_attach_cmd_t cmd)21145039663SJohn Forte pppt_drv_attach(dev_info_t *dip, ddi_attach_cmd_t cmd)
21245039663SJohn Forte {
21345039663SJohn Forte 	if (cmd != DDI_ATTACH) {
21445039663SJohn Forte 		return (DDI_FAILURE);
21545039663SJohn Forte 	}
21645039663SJohn Forte 
21745039663SJohn Forte 	if (ddi_get_instance(dip) != 0) {
21845039663SJohn Forte 		/* we only allow instance 0 to attach */
21945039663SJohn Forte 		return (DDI_FAILURE);
22045039663SJohn Forte 	}
22145039663SJohn Forte 
22245039663SJohn Forte 	/* create the minor node */
22345039663SJohn Forte 	if (ddi_create_minor_node(dip, PPPT_MODNAME, S_IFCHR, 0,
22445039663SJohn Forte 	    DDI_PSEUDO, 0) != DDI_SUCCESS) {
22545039663SJohn Forte 		cmn_err(CE_WARN, "pppt_drv_attach: "
22645039663SJohn Forte 		    "failed creating minor node");
22745039663SJohn Forte 		return (DDI_FAILURE);
22845039663SJohn Forte 	}
22945039663SJohn Forte 
23045039663SJohn Forte 	pppt_global.global_svc_state = PSS_DISABLED;
23145039663SJohn Forte 	pppt_global.global_dip = dip;
23245039663SJohn Forte 
23345039663SJohn Forte 	return (DDI_SUCCESS);
23445039663SJohn Forte }
23545039663SJohn Forte 
23645039663SJohn Forte /*ARGSUSED*/
23745039663SJohn Forte static int
pppt_drv_detach(dev_info_t * dip,ddi_detach_cmd_t cmd)23845039663SJohn Forte pppt_drv_detach(dev_info_t *dip, ddi_detach_cmd_t cmd)
23945039663SJohn Forte {
24045039663SJohn Forte 	if (cmd != DDI_DETACH)
24145039663SJohn Forte 		return (DDI_FAILURE);
24245039663SJohn Forte 
24345039663SJohn Forte 	PPPT_GLOBAL_LOCK();
24445039663SJohn Forte 	if (pppt_drv_busy()) {
24545039663SJohn Forte 		PPPT_GLOBAL_UNLOCK();
24645039663SJohn Forte 		return (EBUSY);
24745039663SJohn Forte 	}
24845039663SJohn Forte 
24945039663SJohn Forte 	ddi_remove_minor_node(dip, NULL);
25045039663SJohn Forte 	ddi_prop_remove_all(dip);
25145039663SJohn Forte 
25245039663SJohn Forte 	pppt_global.global_svc_state = PSS_DETACHED;
25345039663SJohn Forte 
25445039663SJohn Forte 	PPPT_GLOBAL_UNLOCK();
25545039663SJohn Forte 
25645039663SJohn Forte 	return (DDI_SUCCESS);
25745039663SJohn Forte }
25845039663SJohn Forte 
25945039663SJohn Forte /*ARGSUSED*/
26045039663SJohn Forte static int
pppt_drv_open(dev_t * devp,int flag,int otyp,cred_t * credp)26145039663SJohn Forte pppt_drv_open(dev_t *devp, int flag, int otyp, cred_t *credp)
26245039663SJohn Forte {
26345039663SJohn Forte 	int	rc = 0;
26445039663SJohn Forte 
26545039663SJohn Forte 	PPPT_GLOBAL_LOCK();
26645039663SJohn Forte 
26745039663SJohn Forte 	switch (pppt_global.global_svc_state) {
26845039663SJohn Forte 	case PSS_DISABLED:
26945039663SJohn Forte 		pppt_global.global_svc_state = PSS_ENABLING;
27045039663SJohn Forte 		PPPT_GLOBAL_UNLOCK();
27145039663SJohn Forte 		rc = pppt_enable_svc();
27245039663SJohn Forte 		PPPT_GLOBAL_LOCK();
27345039663SJohn Forte 		if (rc == 0) {
27445039663SJohn Forte 			pppt_global.global_svc_state = PSS_ENABLED;
27545039663SJohn Forte 		} else {
27645039663SJohn Forte 			pppt_global.global_svc_state = PSS_DISABLED;
27745039663SJohn Forte 		}
27845039663SJohn Forte 		break;
27945039663SJohn Forte 	case PSS_DISABLING:
28045039663SJohn Forte 	case PSS_ENABLING:
28145039663SJohn Forte 	case PSS_ENABLED:
28245039663SJohn Forte 		rc = EBUSY;
28345039663SJohn Forte 		break;
28445039663SJohn Forte 	default:
28545039663SJohn Forte 		rc = EFAULT;
28645039663SJohn Forte 		break;
28745039663SJohn Forte 	}
28845039663SJohn Forte 
28945039663SJohn Forte 	PPPT_GLOBAL_UNLOCK();
29045039663SJohn Forte 
29145039663SJohn Forte 	return (rc);
29245039663SJohn Forte }
29345039663SJohn Forte 
29445039663SJohn Forte /* ARGSUSED */
29545039663SJohn Forte static int
pppt_drv_close(dev_t dev,int flag,int otyp,cred_t * credp)29645039663SJohn Forte pppt_drv_close(dev_t dev, int flag, int otyp, cred_t *credp)
29745039663SJohn Forte {
29845039663SJohn Forte 	int rc = 0;
29945039663SJohn Forte 
30045039663SJohn Forte 	PPPT_GLOBAL_LOCK();
30145039663SJohn Forte 
30245039663SJohn Forte 	switch (pppt_global.global_svc_state) {
30345039663SJohn Forte 	case PSS_ENABLED:
30445039663SJohn Forte 		pppt_global.global_svc_state = PSS_DISABLING;
30545039663SJohn Forte 		PPPT_GLOBAL_UNLOCK();
30645039663SJohn Forte 		pppt_disable_svc();
30745039663SJohn Forte 		PPPT_GLOBAL_LOCK();
30845039663SJohn Forte 		pppt_global.global_svc_state = PSS_DISABLED;
30945039663SJohn Forte 		/*
31045039663SJohn Forte 		 * release the door to the daemon
31145039663SJohn Forte 		 */
31245039663SJohn Forte 		mutex_enter(&pppt_global.global_door_lock);
31345039663SJohn Forte 		if (pppt_global.global_door != NULL) {
31445039663SJohn Forte 			door_ki_rele(pppt_global.global_door);
31545039663SJohn Forte 			pppt_global.global_door = NULL;
31645039663SJohn Forte 		}
31745039663SJohn Forte 		mutex_exit(&pppt_global.global_door_lock);
31845039663SJohn Forte 		break;
31945039663SJohn Forte 	default:
32045039663SJohn Forte 		rc = EFAULT;
32145039663SJohn Forte 		break;
32245039663SJohn Forte 	}
32345039663SJohn Forte 
32445039663SJohn Forte 	PPPT_GLOBAL_UNLOCK();
32545039663SJohn Forte 
32645039663SJohn Forte 	return (rc);
32745039663SJohn Forte }
32845039663SJohn Forte 
32945039663SJohn Forte static boolean_t
pppt_drv_busy(void)33045039663SJohn Forte pppt_drv_busy(void)
33145039663SJohn Forte {
33245039663SJohn Forte 	switch (pppt_global.global_svc_state) {
33345039663SJohn Forte 	case PSS_DISABLED:
33445039663SJohn Forte 	case PSS_DETACHED:
33545039663SJohn Forte 		return (B_FALSE);
33645039663SJohn Forte 	default:
33745039663SJohn Forte 		return (B_TRUE);
33845039663SJohn Forte 	}
33945039663SJohn Forte 	/* NOTREACHED */
34045039663SJohn Forte }
34145039663SJohn Forte 
34245039663SJohn Forte /* ARGSUSED */
34345039663SJohn Forte static int
pppt_drv_ioctl(dev_t drv,int cmd,intptr_t argp,int flag,cred_t * cred,int * retval)34445039663SJohn Forte pppt_drv_ioctl(dev_t drv, int cmd, intptr_t argp, int flag, cred_t *cred,
34545039663SJohn Forte     int *retval)
34645039663SJohn Forte {
34745039663SJohn Forte 	int				rc;
34845039663SJohn Forte 	void				*buf;
34945039663SJohn Forte 	size_t				buf_size;
35045039663SJohn Forte 	pppt_iocdata_t			iocd;
35145039663SJohn Forte 	door_handle_t			new_handle;
35245039663SJohn Forte 
35345039663SJohn Forte 	if (drv_priv(cred) != 0) {
35445039663SJohn Forte 		return (EPERM);
35545039663SJohn Forte 	}
35645039663SJohn Forte 
35745039663SJohn Forte 	rc = ddi_copyin((void *)argp, &iocd, sizeof (iocd), flag);
35845039663SJohn Forte 	if (rc)
35945039663SJohn Forte 		return (EFAULT);
36045039663SJohn Forte 
36145039663SJohn Forte 	if (iocd.pppt_version != PPPT_VERSION_1)
36245039663SJohn Forte 		return (EINVAL);
36345039663SJohn Forte 
36445039663SJohn Forte 	switch (cmd) {
36545039663SJohn Forte 	case PPPT_MESSAGE:
36645039663SJohn Forte 
36745039663SJohn Forte 		/* XXX limit buf_size ? */
36845039663SJohn Forte 		buf_size = (size_t)iocd.pppt_buf_size;
36945039663SJohn Forte 		buf = kmem_alloc(buf_size, KM_SLEEP);
37045039663SJohn Forte 		if (buf == NULL)
37145039663SJohn Forte 			return (ENOMEM);
37245039663SJohn Forte 
37345039663SJohn Forte 		rc = ddi_copyin((void *)(unsigned long)iocd.pppt_buf,
37445039663SJohn Forte 		    buf, buf_size, flag);
37545039663SJohn Forte 		if (rc) {
37645039663SJohn Forte 			kmem_free(buf, buf_size);
37745039663SJohn Forte 			return (EFAULT);
37845039663SJohn Forte 		}
37945039663SJohn Forte 
38045039663SJohn Forte 		stmf_ic_rx_msg(buf, buf_size);
38145039663SJohn Forte 
38245039663SJohn Forte 		kmem_free(buf, buf_size);
38345039663SJohn Forte 		break;
38445039663SJohn Forte 	case PPPT_INSTALL_DOOR:
38545039663SJohn Forte 
38645039663SJohn Forte 		new_handle = door_ki_lookup((int)iocd.pppt_door_fd);
38745039663SJohn Forte 		if (new_handle == NULL)
38845039663SJohn Forte 			return (EINVAL);
38945039663SJohn Forte 
39045039663SJohn Forte 		mutex_enter(&pppt_global.global_door_lock);
39145039663SJohn Forte 		ASSERT(pppt_global.global_svc_state == PSS_ENABLED);
39245039663SJohn Forte 		if (pppt_global.global_door != NULL) {
39345039663SJohn Forte 			/*
39445039663SJohn Forte 			 * There can only be one door installed
39545039663SJohn Forte 			 */
39645039663SJohn Forte 			mutex_exit(&pppt_global.global_door_lock);
39745039663SJohn Forte 			door_ki_rele(new_handle);
39845039663SJohn Forte 			return (EBUSY);
39945039663SJohn Forte 		}
40045039663SJohn Forte 		pppt_global.global_door = new_handle;
40145039663SJohn Forte 		mutex_exit(&pppt_global.global_door_lock);
40245039663SJohn Forte 		break;
40345039663SJohn Forte 	}
40445039663SJohn Forte 
40545039663SJohn Forte 	return (rc);
40645039663SJohn Forte }
40745039663SJohn Forte 
40845039663SJohn Forte /*
40945039663SJohn Forte  * pppt_enable_svc
41045039663SJohn Forte  *
41145039663SJohn Forte  * registers all the configured targets and target portals with STMF
41245039663SJohn Forte  */
41345039663SJohn Forte static int
pppt_enable_svc(void)41445039663SJohn Forte pppt_enable_svc(void)
41545039663SJohn Forte {
41645039663SJohn Forte 	stmf_port_provider_t	*pp;
41745039663SJohn Forte 	stmf_dbuf_store_t	*dbuf_store;
41845039663SJohn Forte 	int			rc = 0;
41945039663SJohn Forte 
42045039663SJohn Forte 	ASSERT(pppt_global.global_svc_state == PSS_ENABLING);
42145039663SJohn Forte 
42245039663SJohn Forte 	/*
42345039663SJohn Forte 	 * Make sure that can tell if we have partially allocated
42445039663SJohn Forte 	 * in case we need to exit and tear down anything allocated.
42545039663SJohn Forte 	 */
42645039663SJohn Forte 	pppt_global.global_dbuf_store = NULL;
42745039663SJohn Forte 	pp = NULL;
42845039663SJohn Forte 	pppt_global.global_pp = NULL;
42945039663SJohn Forte 	pppt_global.global_dispatch_taskq = NULL;
43045039663SJohn Forte 	pppt_global.global_sess_taskq = NULL;
43145039663SJohn Forte 
43245039663SJohn Forte 	avl_create(&pppt_global.global_target_list,
43345039663SJohn Forte 	    pppt_tgt_avl_compare, sizeof (pppt_tgt_t),
43445039663SJohn Forte 	    offsetof(pppt_tgt_t, target_global_ln));
43545039663SJohn Forte 
43645039663SJohn Forte 	avl_create(&pppt_global.global_sess_list,
43745039663SJohn Forte 	    pppt_sess_avl_compare_by_id, sizeof (pppt_sess_t),
43845039663SJohn Forte 	    offsetof(pppt_sess_t, ps_global_ln));
43945039663SJohn Forte 
44045039663SJohn Forte 	/*
44145039663SJohn Forte 	 * Setup STMF dbuf store.  Tf buffers are associated with a particular
44245039663SJohn Forte 	 * lport (FC, SRP) then the dbuf_store should stored in the lport
44345039663SJohn Forte 	 * context, otherwise (iSCSI) the dbuf_store should be global.
44445039663SJohn Forte 	 */
44545039663SJohn Forte 	dbuf_store = stmf_alloc(STMF_STRUCT_DBUF_STORE, 0, 0);
44645039663SJohn Forte 	if (dbuf_store == NULL) {
44745039663SJohn Forte 		rc = ENOMEM;
44845039663SJohn Forte 		goto tear_down_and_return;
44945039663SJohn Forte 	}
45045039663SJohn Forte 	dbuf_store->ds_alloc_data_buf = pppt_dbuf_alloc;
45145039663SJohn Forte 	dbuf_store->ds_free_data_buf = pppt_dbuf_free;
45245039663SJohn Forte 	dbuf_store->ds_port_private = NULL;
45345039663SJohn Forte 	pppt_global.global_dbuf_store = dbuf_store;
45445039663SJohn Forte 
45545039663SJohn Forte 	/* Register port provider */
45645039663SJohn Forte 	pp = stmf_alloc(STMF_STRUCT_PORT_PROVIDER, 0, 0);
45745039663SJohn Forte 	if (pp == NULL) {
45845039663SJohn Forte 		rc = ENOMEM;
45945039663SJohn Forte 		goto tear_down_and_return;
46045039663SJohn Forte 	}
46145039663SJohn Forte 
46245039663SJohn Forte 	pp->pp_portif_rev = PORTIF_REV_1;
46345039663SJohn Forte 	pp->pp_instance = 0;
46445039663SJohn Forte 	pp->pp_name = PPPT_MODNAME;
46545039663SJohn Forte 	pp->pp_cb = NULL;
46645039663SJohn Forte 
46745039663SJohn Forte 	pppt_global.global_pp = pp;
46845039663SJohn Forte 
46945039663SJohn Forte 	if (stmf_register_port_provider(pp) != STMF_SUCCESS) {
47045039663SJohn Forte 		rc = EIO;
47145039663SJohn Forte 		goto tear_down_and_return;
47245039663SJohn Forte 	}
47345039663SJohn Forte 
47445039663SJohn Forte 	pppt_global.global_dispatch_taskq = taskq_create("pppt_dispatch",
47545039663SJohn Forte 	    1, minclsyspri, 1, INT_MAX, TASKQ_PREPOPULATE);
47645039663SJohn Forte 
47745039663SJohn Forte 	pppt_global.global_sess_taskq = taskq_create("pppt_session",
47845039663SJohn Forte 	    1, minclsyspri, 1, INT_MAX, TASKQ_PREPOPULATE);
47945039663SJohn Forte 
48045039663SJohn Forte 	return (0);
48145039663SJohn Forte 
48245039663SJohn Forte tear_down_and_return:
48345039663SJohn Forte 
48445039663SJohn Forte 	if (pppt_global.global_sess_taskq) {
48545039663SJohn Forte 		taskq_destroy(pppt_global.global_sess_taskq);
48645039663SJohn Forte 		pppt_global.global_sess_taskq = NULL;
48745039663SJohn Forte 	}
48845039663SJohn Forte 
48945039663SJohn Forte 	if (pppt_global.global_dispatch_taskq) {
49045039663SJohn Forte 		taskq_destroy(pppt_global.global_dispatch_taskq);
49145039663SJohn Forte 		pppt_global.global_dispatch_taskq = NULL;
49245039663SJohn Forte 	}
49345039663SJohn Forte 
49445039663SJohn Forte 	if (pppt_global.global_pp)
49545039663SJohn Forte 		pppt_global.global_pp = NULL;
49645039663SJohn Forte 
49745039663SJohn Forte 	if (pp)
49845039663SJohn Forte 		stmf_free(pp);
49945039663SJohn Forte 
50045039663SJohn Forte 	if (pppt_global.global_dbuf_store) {
50145039663SJohn Forte 		stmf_free(pppt_global.global_dbuf_store);
50245039663SJohn Forte 		pppt_global.global_dbuf_store = NULL;
50345039663SJohn Forte 	}
50445039663SJohn Forte 
50545039663SJohn Forte 	avl_destroy(&pppt_global.global_sess_list);
50645039663SJohn Forte 	avl_destroy(&pppt_global.global_target_list);
50745039663SJohn Forte 
50845039663SJohn Forte 	return (rc);
50945039663SJohn Forte }
51045039663SJohn Forte 
51145039663SJohn Forte /*
51245039663SJohn Forte  * pppt_disable_svc
51345039663SJohn Forte  *
51445039663SJohn Forte  * clean up all existing sessions and deregister targets from STMF
51545039663SJohn Forte  */
51645039663SJohn Forte static void
pppt_disable_svc(void)51745039663SJohn Forte pppt_disable_svc(void)
51845039663SJohn Forte {
51945039663SJohn Forte 	pppt_tgt_t	*tgt, *next_tgt;
52045039663SJohn Forte 	avl_tree_t	delete_target_list;
52145039663SJohn Forte 
52245039663SJohn Forte 	ASSERT(pppt_global.global_svc_state == PSS_DISABLING);
52345039663SJohn Forte 
52445039663SJohn Forte 	avl_create(&delete_target_list,
52545039663SJohn Forte 	    pppt_tgt_avl_compare, sizeof (pppt_tgt_t),
52645039663SJohn Forte 	    offsetof(pppt_tgt_t, target_global_ln));
52745039663SJohn Forte 
52845039663SJohn Forte 	PPPT_GLOBAL_LOCK();
52945039663SJohn Forte 	for (tgt = avl_first(&pppt_global.global_target_list);
53045039663SJohn Forte 	    tgt != NULL;
53145039663SJohn Forte 	    tgt = next_tgt) {
53245039663SJohn Forte 		next_tgt = AVL_NEXT(&pppt_global.global_target_list, tgt);
53345039663SJohn Forte 		avl_remove(&pppt_global.global_target_list, tgt);
53445039663SJohn Forte 		avl_add(&delete_target_list, tgt);
53545039663SJohn Forte 		pppt_tgt_async_delete(tgt);
53645039663SJohn Forte 	}
53745039663SJohn Forte 	PPPT_GLOBAL_UNLOCK();
53845039663SJohn Forte 
53945039663SJohn Forte 	for (tgt = avl_first(&delete_target_list);
54045039663SJohn Forte 	    tgt != NULL;
54145039663SJohn Forte 	    tgt = next_tgt) {
54245039663SJohn Forte 		next_tgt = AVL_NEXT(&delete_target_list, tgt);
54345039663SJohn Forte 		mutex_enter(&tgt->target_mutex);
54445039663SJohn Forte 		while ((tgt->target_refcount > 0) ||
54545039663SJohn Forte 		    (tgt->target_state != TS_DELETING)) {
54645039663SJohn Forte 			cv_wait(&tgt->target_cv, &tgt->target_mutex);
54745039663SJohn Forte 		}
54845039663SJohn Forte 		mutex_exit(&tgt->target_mutex);
54945039663SJohn Forte 
55045039663SJohn Forte 		avl_remove(&delete_target_list, tgt);
55145039663SJohn Forte 		pppt_tgt_destroy(tgt);
55245039663SJohn Forte 	}
55345039663SJohn Forte 
55445039663SJohn Forte 	taskq_destroy(pppt_global.global_sess_taskq);
55545039663SJohn Forte 
55645039663SJohn Forte 	taskq_destroy(pppt_global.global_dispatch_taskq);
55745039663SJohn Forte 
55845039663SJohn Forte 	avl_destroy(&pppt_global.global_sess_list);
55945039663SJohn Forte 	avl_destroy(&pppt_global.global_target_list);
56045039663SJohn Forte 
56145039663SJohn Forte 	(void) stmf_deregister_port_provider(pppt_global.global_pp);
56245039663SJohn Forte 
56345039663SJohn Forte 	stmf_free(pppt_global.global_dbuf_store);
56445039663SJohn Forte 	pppt_global.global_dbuf_store = NULL;
56545039663SJohn Forte 
56645039663SJohn Forte 	stmf_free(pppt_global.global_pp);
56745039663SJohn Forte 	pppt_global.global_pp = NULL;
56845039663SJohn Forte }
56945039663SJohn Forte 
57045039663SJohn Forte /*
57145039663SJohn Forte  * STMF callbacks
57245039663SJohn Forte  */
57345039663SJohn Forte 
57445039663SJohn Forte /*ARGSUSED*/
57545039663SJohn Forte static stmf_data_buf_t *
pppt_dbuf_alloc(scsi_task_t * task,uint32_t size,uint32_t * pminsize,uint32_t flags)57645039663SJohn Forte pppt_dbuf_alloc(scsi_task_t *task, uint32_t size, uint32_t *pminsize,
57745039663SJohn Forte     uint32_t flags)
57845039663SJohn Forte {
57945039663SJohn Forte 	stmf_data_buf_t	*result;
58045039663SJohn Forte 	pppt_buf_t	*pbuf;
58145039663SJohn Forte 	uint8_t		*buf;
58245039663SJohn Forte 
58345039663SJohn Forte 	/* Get buffer */
58445039663SJohn Forte 	buf = kmem_alloc(size, KM_SLEEP);
58545039663SJohn Forte 
58645039663SJohn Forte 	/*
58745039663SJohn Forte 	 *  Allocate stmf buf with private port provider section
58845039663SJohn Forte 	 * (pppt_buf_t)
58945039663SJohn Forte 	 */
59045039663SJohn Forte 	result = stmf_alloc(STMF_STRUCT_DATA_BUF, sizeof (pppt_buf_t), 0);
59145039663SJohn Forte 	if (result != NULL) {
59245039663SJohn Forte 		/* Fill in pppt_buf_t */
59345039663SJohn Forte 		pbuf = result->db_port_private;
59445039663SJohn Forte 		pbuf->pbuf_stmf_buf = result;
59545039663SJohn Forte 		pbuf->pbuf_is_immed = B_FALSE;
59645039663SJohn Forte 
59745039663SJohn Forte 		/*
59845039663SJohn Forte 		 * Fill in stmf_data_buf_t.  DB_DONT CACHE tells
59945039663SJohn Forte 		 * stmf not to cache buffers but STMF doesn't do
60045039663SJohn Forte 		 * that yet so it's a no-op.  Port providers like
60145039663SJohn Forte 		 * FC and SRP that have buffers associated with the
60245039663SJohn Forte 		 * target port would want to let STMF cache
60345039663SJohn Forte 		 * the buffers.  Port providers like iSCSI would
60445039663SJohn Forte 		 * not want STMF to cache because the buffers are
60545039663SJohn Forte 		 * really associated with a connection, not an
60645039663SJohn Forte 		 * STMF target port so there is no way for STMF
60745039663SJohn Forte 		 * to cache the buffers effectively.  These port
60845039663SJohn Forte 		 * providers should cache buffers internally if
60945039663SJohn Forte 		 * there is significant buffer setup overhead.
61045039663SJohn Forte 		 *
61145039663SJohn Forte 		 * And of course, since STMF doesn't do any internal
61245039663SJohn Forte 		 * caching right now anyway, all port providers should
61345039663SJohn Forte 		 * do what they can to minimize buffer setup overhead.
61445039663SJohn Forte 		 */
61545039663SJohn Forte 		result->db_flags = DB_DONT_CACHE;
61645039663SJohn Forte 		result->db_buf_size = size;
61745039663SJohn Forte 		result->db_data_size = size;
61845039663SJohn Forte 		result->db_sglist_length = 1;
61945039663SJohn Forte 		result->db_sglist[0].seg_addr = buf;
62045039663SJohn Forte 		result->db_sglist[0].seg_length = size;
62145039663SJohn Forte 		return (result);
62245039663SJohn Forte 	} else {
62345039663SJohn Forte 		/*
62445039663SJohn Forte 		 * Couldn't get the stmf_data_buf_t so free the
62545039663SJohn Forte 		 * buffer
62645039663SJohn Forte 		 */
62745039663SJohn Forte 		kmem_free(buf, size);
62845039663SJohn Forte 	}
62945039663SJohn Forte 
63045039663SJohn Forte 	return (NULL);
63145039663SJohn Forte }
63245039663SJohn Forte 
63345039663SJohn Forte /*ARGSUSED*/
63445039663SJohn Forte static void
pppt_dbuf_free(stmf_dbuf_store_t * ds,stmf_data_buf_t * dbuf)63545039663SJohn Forte pppt_dbuf_free(stmf_dbuf_store_t *ds, stmf_data_buf_t *dbuf)
63645039663SJohn Forte {
63745039663SJohn Forte 	pppt_buf_t *pbuf = dbuf->db_port_private;
63845039663SJohn Forte 
63945039663SJohn Forte 	if (pbuf->pbuf_is_immed) {
64045039663SJohn Forte 		stmf_ic_msg_free(pbuf->pbuf_immed_msg);
64145039663SJohn Forte 	} else {
64245039663SJohn Forte 		kmem_free(dbuf->db_sglist[0].seg_addr,
64345039663SJohn Forte 		    dbuf->db_sglist[0].seg_length);
64445039663SJohn Forte 		stmf_free(dbuf);
64545039663SJohn Forte 	}
64645039663SJohn Forte }
64745039663SJohn Forte 
64845039663SJohn Forte /*ARGSUSED*/
64945039663SJohn Forte stmf_status_t
pppt_lport_xfer_data(scsi_task_t * task,stmf_data_buf_t * dbuf,uint32_t ioflags)65045039663SJohn Forte pppt_lport_xfer_data(scsi_task_t *task, stmf_data_buf_t *dbuf,
65145039663SJohn Forte     uint32_t ioflags)
65245039663SJohn Forte {
65345039663SJohn Forte 	pppt_task_t		*pppt_task = task->task_port_private;
65445039663SJohn Forte 	pppt_buf_t		*pbuf = dbuf->db_port_private;
65545039663SJohn Forte 	stmf_ic_msg_t		*msg;
65645039663SJohn Forte 	stmf_ic_msg_status_t	ic_msg_status;
65745039663SJohn Forte 
65845039663SJohn Forte 	/*
65945039663SJohn Forte 	 * If we are aborting then we can ignore this request, otherwise
66045039663SJohn Forte 	 * add a reference.
66145039663SJohn Forte 	 */
66245039663SJohn Forte 	if (pppt_task_hold(pppt_task) != PPPT_STATUS_SUCCESS) {
66345039663SJohn Forte 		return (STMF_SUCCESS);
66445039663SJohn Forte 	}
66545039663SJohn Forte 
66645039663SJohn Forte 	/*
66745039663SJohn Forte 	 * If it's not immediate data then start the transfer
66845039663SJohn Forte 	 */
66945039663SJohn Forte 	ASSERT(pbuf->pbuf_is_immed == B_FALSE);
67045039663SJohn Forte 	if (dbuf->db_flags & DB_DIRECTION_TO_RPORT) {
67145039663SJohn Forte 
67245039663SJohn Forte 		/* Send read data */
67345039663SJohn Forte 		msg = stmf_ic_scsi_data_msg_alloc(
67445039663SJohn Forte 		    pppt_task->pt_task_id,
67545039663SJohn Forte 		    pppt_task->pt_sess->ps_session_id,
67645039663SJohn Forte 		    pppt_task->pt_lun_id,
67745039663SJohn Forte 		    dbuf->db_sglist[0].seg_length,
67845039663SJohn Forte 		    dbuf->db_sglist[0].seg_addr, 0);
67945039663SJohn Forte 
68045039663SJohn Forte 		pppt_task->pt_read_buf = pbuf;
68145039663SJohn Forte 		pppt_task->pt_read_xfer_msgid = msg->icm_msgid;
68245039663SJohn Forte 
68345039663SJohn Forte 		ic_msg_status = stmf_ic_tx_msg(msg);
68445039663SJohn Forte 		pppt_task_rele(pppt_task);
68545039663SJohn Forte 		if (ic_msg_status != STMF_IC_MSG_SUCCESS) {
68645039663SJohn Forte 			return (STMF_FAILURE);
68745039663SJohn Forte 		} else {
68845039663SJohn Forte 			return (STMF_SUCCESS);
68945039663SJohn Forte 		}
69045039663SJohn Forte 	} else if (dbuf->db_flags & DB_DIRECTION_FROM_RPORT) {
69145039663SJohn Forte 		pppt_task_rele(pppt_task);
69245039663SJohn Forte 		return (STMF_FAILURE);
69345039663SJohn Forte 	}
69445039663SJohn Forte 
69545039663SJohn Forte 	pppt_task_rele(pppt_task);
69645039663SJohn Forte 
69745039663SJohn Forte 	return (STMF_INVALID_ARG);
69845039663SJohn Forte }
69945039663SJohn Forte 
70045039663SJohn Forte void
pppt_xfer_read_complete(pppt_task_t * pppt_task,stmf_status_t status)70145039663SJohn Forte pppt_xfer_read_complete(pppt_task_t *pppt_task, stmf_status_t status)
70245039663SJohn Forte {
70345039663SJohn Forte 	pppt_buf_t		*pppt_buf;
70445039663SJohn Forte 	stmf_data_buf_t		*dbuf;
70545039663SJohn Forte 
70645039663SJohn Forte 	/*
70745039663SJohn Forte 	 * Caller should have taken a task hold (likely via pppt_task_lookup)
70845039663SJohn Forte 	 *
70945039663SJohn Forte 	 * Get pppt_buf_t and stmf_data_buf_t pointers
71045039663SJohn Forte 	 */
71145039663SJohn Forte 	pppt_buf = pppt_task->pt_read_buf;
71245039663SJohn Forte 	dbuf = pppt_buf->pbuf_stmf_buf;
71345039663SJohn Forte 	dbuf->db_xfer_status = (status == STMF_SUCCESS) ?
71445039663SJohn Forte 	    STMF_SUCCESS : STMF_FAILURE;
71545039663SJohn Forte 
71645039663SJohn Forte 	/*
71745039663SJohn Forte 	 * COMSTAR currently requires port providers to support
71845039663SJohn Forte 	 * the DB_SEND_STATUS_GOOD flag even if phase collapse is
71945039663SJohn Forte 	 * not supported.  So we will roll our own... pretend we are
72045039663SJohn Forte 	 * COMSTAR and ask for a status message.
72145039663SJohn Forte 	 */
72245039663SJohn Forte 	if ((dbuf->db_flags & DB_SEND_STATUS_GOOD) &&
72345039663SJohn Forte 	    (status == STMF_SUCCESS)) {
72445039663SJohn Forte 		/*
72545039663SJohn Forte 		 * It's possible the task has been aborted since the time we
72645039663SJohn Forte 		 * looked it up.  We need to release the hold before calling
72745039663SJohn Forte 		 * pppt_lport_send_status and as soon as we release the hold
72845039663SJohn Forte 		 * the task may disappear.  Calling pppt_task_done allows us
72945039663SJohn Forte 		 * to determine whether the task has been aborted (in which
73045039663SJohn Forte 		 * case we will stop processing and return) and mark the task
73145039663SJohn Forte 		 * "done" which will prevent the task from being aborted while
73245039663SJohn Forte 		 * we are trying to send the status.
73345039663SJohn Forte 		 */
73445039663SJohn Forte 		if (pppt_task_done(pppt_task) != PPPT_STATUS_SUCCESS) {
73545039663SJohn Forte 			/* STMF will free task and buffer(s) */
73645039663SJohn Forte 			pppt_task_rele(pppt_task);
73745039663SJohn Forte 			return;
73845039663SJohn Forte 		}
73945039663SJohn Forte 		pppt_task_rele(pppt_task);
74045039663SJohn Forte 
74145039663SJohn Forte 		if (pppt_lport_send_status(pppt_task->pt_stmf_task, 0)
74245039663SJohn Forte 		    != STMF_SUCCESS) {
74345039663SJohn Forte 			/* Failed to send status */
74445039663SJohn Forte 			dbuf->db_xfer_status = STMF_FAILURE;
74545039663SJohn Forte 			stmf_data_xfer_done(pppt_task->pt_stmf_task, dbuf,
74645039663SJohn Forte 			    STMF_IOF_LPORT_DONE);
74745039663SJohn Forte 		}
74845039663SJohn Forte 	} else {
74945039663SJohn Forte 		pppt_task_rele(pppt_task);
75045039663SJohn Forte 		stmf_data_xfer_done(pppt_task->pt_stmf_task, dbuf, 0);
75145039663SJohn Forte 	}
75245039663SJohn Forte }
75345039663SJohn Forte 
75445039663SJohn Forte /*ARGSUSED*/
75545039663SJohn Forte stmf_status_t
pppt_lport_send_status(scsi_task_t * task,uint32_t ioflags)75645039663SJohn Forte pppt_lport_send_status(scsi_task_t *task, uint32_t ioflags)
75745039663SJohn Forte {
75845039663SJohn Forte 	pppt_task_t *ptask =		task->task_port_private;
75945039663SJohn Forte 	stmf_ic_msg_t			*msg;
76045039663SJohn Forte 	stmf_ic_msg_status_t		ic_msg_status;
76145039663SJohn Forte 
76245039663SJohn Forte 	/*
76345039663SJohn Forte 	 * Mark task completed.  If the state indicates it was aborted
76445039663SJohn Forte 	 * then we don't need to respond.
76545039663SJohn Forte 	 */
76645039663SJohn Forte 	if (pppt_task_done(ptask) == PPPT_STATUS_ABORTED) {
76745039663SJohn Forte 		return (STMF_SUCCESS);
76845039663SJohn Forte 	}
76945039663SJohn Forte 
77045039663SJohn Forte 	/*
77145039663SJohn Forte 	 * Send status.
77245039663SJohn Forte 	 */
77345039663SJohn Forte 	msg = stmf_ic_scsi_status_msg_alloc(
77445039663SJohn Forte 	    ptask->pt_task_id,
77545039663SJohn Forte 	    ptask->pt_sess->ps_session_id,
77645039663SJohn Forte 	    ptask->pt_lun_id,
77745039663SJohn Forte 	    0,
77845039663SJohn Forte 	    task->task_scsi_status,
77945039663SJohn Forte 	    task->task_status_ctrl, task->task_resid,
78045039663SJohn Forte 	    task->task_sense_length, task->task_sense_data, 0);
78145039663SJohn Forte 
78245039663SJohn Forte 	ic_msg_status = stmf_ic_tx_msg(msg);
78345039663SJohn Forte 
78445039663SJohn Forte 	if (ic_msg_status != STMF_IC_MSG_SUCCESS) {
78545039663SJohn Forte 		pppt_task_sent_status(ptask);
78645039663SJohn Forte 		stmf_send_status_done(ptask->pt_stmf_task,
78745039663SJohn Forte 		    STMF_FAILURE, STMF_IOF_LPORT_DONE);
78845039663SJohn Forte 		return (STMF_FAILURE);
78945039663SJohn Forte 	} else {
79045039663SJohn Forte 		pppt_task_sent_status(ptask);
79145039663SJohn Forte 		stmf_send_status_done(ptask->pt_stmf_task,
79245039663SJohn Forte 		    STMF_SUCCESS, STMF_IOF_LPORT_DONE);
79345039663SJohn Forte 		return (STMF_SUCCESS);
79445039663SJohn Forte 	}
79545039663SJohn Forte }
79645039663SJohn Forte 
79745039663SJohn Forte void
pppt_lport_task_free(scsi_task_t * task)79845039663SJohn Forte pppt_lport_task_free(scsi_task_t *task)
79945039663SJohn Forte {
80045039663SJohn Forte 	pppt_task_t *ptask = task->task_port_private;
80145039663SJohn Forte 	pppt_sess_t *ps = ptask->pt_sess;
80245039663SJohn Forte 
803*ef3b9e2fSDan McDonald 	pppt_task_rele(ptask);
80445039663SJohn Forte 	pppt_sess_rele(ps);
80545039663SJohn Forte }
80645039663SJohn Forte 
80745039663SJohn Forte /*ARGSUSED*/
80845039663SJohn Forte stmf_status_t
pppt_lport_abort(stmf_local_port_t * lport,int abort_cmd,void * arg,uint32_t flags)80945039663SJohn Forte pppt_lport_abort(stmf_local_port_t *lport, int abort_cmd, void *arg,
81045039663SJohn Forte     uint32_t flags)
81145039663SJohn Forte {
81245039663SJohn Forte 	scsi_task_t	*st = (scsi_task_t *)arg;
81345039663SJohn Forte 	pppt_task_t	*ptask;
81445039663SJohn Forte 
81545039663SJohn Forte 	ptask = st->task_port_private;
81645039663SJohn Forte 
81745039663SJohn Forte 	if (pppt_task_try_abort(ptask) == PPPT_STATUS_DONE) {
81845039663SJohn Forte 		/*
81945039663SJohn Forte 		 * This task is beyond the point where abort makes sense
82045039663SJohn Forte 		 * and we will soon be sending status.  Tell STMF to
82145039663SJohn Forte 		 * go away.
82245039663SJohn Forte 		 */
82345039663SJohn Forte 		return (STMF_BUSY);
82445039663SJohn Forte 	} else {
82545039663SJohn Forte 		return (STMF_ABORT_SUCCESS);
82645039663SJohn Forte 	}
82745039663SJohn Forte 	/*NOTREACHED*/
82845039663SJohn Forte }
82945039663SJohn Forte 
83045039663SJohn Forte /*ARGSUSED*/
83145039663SJohn Forte void
pppt_lport_ctl(stmf_local_port_t * lport,int cmd,void * arg)832