125cf1a30Sjl /* 225cf1a30Sjl * CDDL HEADER START 325cf1a30Sjl * 425cf1a30Sjl * The contents of this file are subject to the terms of the 525cf1a30Sjl * Common Development and Distribution License (the "License"). 625cf1a30Sjl * You may not use this file except in compliance with the License. 725cf1a30Sjl * 825cf1a30Sjl * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 925cf1a30Sjl * or http://www.opensolaris.org/os/licensing. 1025cf1a30Sjl * See the License for the specific language governing permissions 1125cf1a30Sjl * and limitations under the License. 1225cf1a30Sjl * 1325cf1a30Sjl * When distributing Covered Code, include this CDDL HEADER in each 1425cf1a30Sjl * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 1525cf1a30Sjl * If applicable, add the following below this CDDL HEADER, with the 1625cf1a30Sjl * fields enclosed by brackets "[]" replaced with your own identifying 1725cf1a30Sjl * information: Portions Copyright [yyyy] [name of copyright owner] 1825cf1a30Sjl * 1925cf1a30Sjl * CDDL HEADER END 2025cf1a30Sjl */ 2125cf1a30Sjl /* 22*19397407SSherry Moore * Copyright 2008 Sun Microsystems, Inc. All rights reserved. 2325cf1a30Sjl * Use is subject to license terms. 2425cf1a30Sjl */ 2525cf1a30Sjl 2625cf1a30Sjl 2725cf1a30Sjl /* 2825cf1a30Sjl * OPL IPSec Key Management Driver. 2925cf1a30Sjl * 3025cf1a30Sjl * This driver runs on a OPL Domain. It processes requests received 3125cf1a30Sjl * from the OPL Service Processor (SP) via mailbox message. It passes 3225cf1a30Sjl * these requests to the sckmd daemon by means of an /ioctl interface. 3325cf1a30Sjl * 3425cf1a30Sjl * Requests received from the SP consist of IPsec security associations 3525cf1a30Sjl * (SAs) needed to secure the communication between SC and Domain daemons 3625cf1a30Sjl * communicating using DSCP. 3725cf1a30Sjl */ 3825cf1a30Sjl 3925cf1a30Sjl #include <sys/types.h> 4025cf1a30Sjl #include <sys/cmn_err.h> 4125cf1a30Sjl #include <sys/kmem.h> 4225cf1a30Sjl #include <sys/errno.h> 4325cf1a30Sjl #include <sys/file.h> 4425cf1a30Sjl #include <sys/open.h> 4525cf1a30Sjl #include <sys/stat.h> 4625cf1a30Sjl #include <sys/conf.h> 4725cf1a30Sjl #include <sys/ddi.h> 4825cf1a30Sjl #include <sys/cmn_err.h> 4925cf1a30Sjl #include <sys/sunddi.h> 5025cf1a30Sjl #include <sys/sunndi.h> 5125cf1a30Sjl #include <sys/ddi_impldefs.h> 5225cf1a30Sjl #include <sys/ndi_impldefs.h> 5325cf1a30Sjl #include <sys/modctl.h> 5425cf1a30Sjl #include <sys/disp.h> 5525cf1a30Sjl #include <sys/note.h> 5625cf1a30Sjl #include <sys/byteorder.h> 5725cf1a30Sjl #include <sys/sdt.h> 5825cf1a30Sjl 5925cf1a30Sjl #include <sys/scfd/scfdscpif.h> 6025cf1a30Sjl #include <sys/oplkm_msg.h> 6125cf1a30Sjl #include <sys/sckm_io.h> 6225cf1a30Sjl #include <sys/oplkm.h> 6325cf1a30Sjl 6425cf1a30Sjl #define OKM_NODENAME "oplkmdrv" /* Node name */ 6525cf1a30Sjl #define OKM_TARGET_ID 0 /* Target ID */ 6625cf1a30Sjl #define OKM_SM_TOUT 5000 /* small timeout (5msec) */ 6725cf1a30Sjl #define OKM_LG_TOUT 50000 /* large timeout (50msec) */ 6825cf1a30Sjl #define OKM_MB_TOUT 10000000 /* Mailbox timeout (10sec) */ 6925cf1a30Sjl 7025cf1a30Sjl okms_t okms_global; /* Global instance structure */ 7125cf1a30Sjl 7225cf1a30Sjl #ifdef DEBUG 7325cf1a30Sjl uint32_t okm_debug = DBG_WARN; 7425cf1a30Sjl #endif 7525cf1a30Sjl 7625cf1a30Sjl /* 7725cf1a30Sjl * Prototypes for the module related functions. 7825cf1a30Sjl */ 7925cf1a30Sjl int okm_attach(dev_info_t *devi, ddi_attach_cmd_t cmd); 8025cf1a30Sjl int okm_detach(dev_info_t *devi, ddi_detach_cmd_t cmd); 8125cf1a30Sjl int okm_info(dev_info_t *dip, ddi_info_cmd_t infocmd, void *arg, void **result); 8225cf1a30Sjl int okm_open(dev_t *devp, int flag, int otyp, struct cred *cred); 8325cf1a30Sjl int okm_close(dev_t dev, int flag, int otyp, struct cred *cred); 8425cf1a30Sjl int okm_ioctl(dev_t dev, int cmd, intptr_t data, int flag, 8525cf1a30Sjl cred_t *cred, int *rvalp); 8625cf1a30Sjl 8725cf1a30Sjl /* 8825cf1a30Sjl * Prototypes for the internal functions. 8925cf1a30Sjl */ 9025cf1a30Sjl int okm_get_req(okms_t *okmsp, sckm_ioctl_getreq_t *ireqp, 9125cf1a30Sjl intptr_t data, int flag); 9225cf1a30Sjl int okm_process_req(okms_t *okmsp, okm_req_hdr_t *reqp, uint32_t len, 9325cf1a30Sjl sckm_ioctl_getreq_t *ireqp, intptr_t data, int flag); 9425cf1a30Sjl int okm_process_status(okms_t *okmsp, sckm_ioctl_status_t *ireply); 9525cf1a30Sjl void okm_event_handler(scf_event_t event, void *arg); 9625cf1a30Sjl int okm_send_reply(okms_t *okmsp, uint32_t transid, uint32_t status, 9725cf1a30Sjl uint32_t sadb_err, uint32_t sadb_ver); 9825cf1a30Sjl int block_until_ready(okms_t *okmsp); 9925cf1a30Sjl static int okm_copyin_ioctl_getreq(intptr_t userarg, 10025cf1a30Sjl sckm_ioctl_getreq_t *driverarg, int flag); 10125cf1a30Sjl static int okm_copyout_ioctl_getreq(sckm_ioctl_getreq_t *driverarg, 10225cf1a30Sjl intptr_t userarg, int flag); 10325cf1a30Sjl static void okm_cleanup(okms_t *okmsp); 10425cf1a30Sjl static int okm_mbox_init(okms_t *okmsp); 10525cf1a30Sjl static void okm_mbox_fini(okms_t *okmsp); 10625cf1a30Sjl static clock_t okm_timeout_val(int error); 10725cf1a30Sjl 10825cf1a30Sjl 10925cf1a30Sjl struct cb_ops okm_cb_ops = { 11025cf1a30Sjl okm_open, /* open */ 11125cf1a30Sjl okm_close, /* close */ 11225cf1a30Sjl nodev, /* strategy */ 11325cf1a30Sjl nodev, /* print */ 11425cf1a30Sjl nodev, /* dump */ 11525cf1a30Sjl nodev, /* read */ 11625cf1a30Sjl nodev, /* write */ 11725cf1a30Sjl okm_ioctl, /* ioctl */ 11825cf1a30Sjl nodev, /* devmap */ 11925cf1a30Sjl nodev, /* mmap */ 12025cf1a30Sjl nodev, /* segmap */ 12125cf1a30Sjl nochpoll, /* poll */ 12225cf1a30Sjl ddi_prop_op, /* prop_op */ 12325cf1a30Sjl 0, /* streamtab */ 12425cf1a30Sjl D_NEW | D_MP /* Driver compatibility flag */ 12525cf1a30Sjl }; 12625cf1a30Sjl 12725cf1a30Sjl struct dev_ops okm_ops = { 12825cf1a30Sjl DEVO_REV, /* devo_rev, */ 12925cf1a30Sjl 0, /* refcnt */ 13025cf1a30Sjl okm_info, /* get_dev_info */ 13125cf1a30Sjl nulldev, /* identify */ 13225cf1a30Sjl nulldev, /* probe */ 13325cf1a30Sjl okm_attach, /* attach */ 13425cf1a30Sjl okm_detach, /* detach */ 13525cf1a30Sjl nodev, /* reset */ 13625cf1a30Sjl &okm_cb_ops, /* driver operations */ 137*19397407SSherry Moore (struct bus_ops *)0, /* no bus operations */ 138*19397407SSherry Moore NULL, /* power */ 139*19397407SSherry Moore ddi_quiesce_not_needed, /* quiesce */ 14025cf1a30Sjl }; 14125cf1a30Sjl 14225cf1a30Sjl struct modldrv modldrv = { 14325cf1a30Sjl &mod_driverops, 144*19397407SSherry Moore "OPL Key Management Driver", 14525cf1a30Sjl &okm_ops, 14625cf1a30Sjl }; 14725cf1a30Sjl 14825cf1a30Sjl struct modlinkage modlinkage = { 14925cf1a30Sjl MODREV_1, 15025cf1a30Sjl &modldrv, 15125cf1a30Sjl NULL 15225cf1a30Sjl }; 15325cf1a30Sjl 15425cf1a30Sjl 15525cf1a30Sjl /* 15625cf1a30Sjl * _init - Module's init routine. 15725cf1a30Sjl */ 15825cf1a30Sjl int 15925cf1a30Sjl _init(void) 16025cf1a30Sjl { 16125cf1a30Sjl int ret; 16225cf1a30Sjl 16325cf1a30Sjl if ((ret = mod_install(&modlinkage)) != 0) { 16425cf1a30Sjl cmn_err(CE_WARN, "mod_install failed, error = %d", ret); 16525cf1a30Sjl } 16625cf1a30Sjl return (ret); 16725cf1a30Sjl } 16825cf1a30Sjl 16925cf1a30Sjl /* 17025cf1a30Sjl * _fini - Module's fini routine. 17125cf1a30Sjl */ 17225cf1a30Sjl int 17325cf1a30Sjl _fini(void) 17425cf1a30Sjl { 17525cf1a30Sjl int ret; 17625cf1a30Sjl 17725cf1a30Sjl if ((ret = mod_remove(&modlinkage)) != 0) { 17825cf1a30Sjl return (ret); 17925cf1a30Sjl } 18025cf1a30Sjl return (ret); 18125cf1a30Sjl } 18225cf1a30Sjl 18325cf1a30Sjl /* 18425cf1a30Sjl * _info - Module's info routine. 18525cf1a30Sjl */ 18625cf1a30Sjl int 18725cf1a30Sjl _info(struct modinfo *modinfop) 18825cf1a30Sjl { 18925cf1a30Sjl return (mod_info(&modlinkage, modinfop)); 19025cf1a30Sjl } 19125cf1a30Sjl 19225cf1a30Sjl /* 19325cf1a30Sjl * okm_attach - Module's attach routine. 19425cf1a30Sjl * 19525cf1a30Sjl * Description: Initializes the modules state structure and create 19625cf1a30Sjl * the minor device node. 19725cf1a30Sjl */ 19825cf1a30Sjl int 19925cf1a30Sjl okm_attach(dev_info_t *dip, ddi_attach_cmd_t cmd) 20025cf1a30Sjl { 20125cf1a30Sjl int instance; 20225cf1a30Sjl okms_t *okmsp = &okms_global; 20325cf1a30Sjl 20425cf1a30Sjl instance = ddi_get_instance(dip); 20525cf1a30Sjl 20625cf1a30Sjl /* Only one instance is supported. */ 20725cf1a30Sjl if (instance != 0) { 20825cf1a30Sjl return (DDI_FAILURE); 20925cf1a30Sjl } 21025cf1a30Sjl 21125cf1a30Sjl if (cmd != DDI_ATTACH) { 21225cf1a30Sjl return (DDI_FAILURE); 21325cf1a30Sjl } 21425cf1a30Sjl 21525cf1a30Sjl okmsp->km_dip = dip; 21625cf1a30Sjl okmsp->km_major = ddi_name_to_major(ddi_get_name(dip)); 21725cf1a30Sjl okmsp->km_inst = instance; 21825cf1a30Sjl 21925cf1a30Sjl /* 22025cf1a30Sjl * Get an interrupt block cookie corresponding to the 22125cf1a30Sjl * interrupt priority of the event handler. 22225cf1a30Sjl * Assert that the event priority is not redefined to 22325cf1a30Sjl * some other priority. 22425cf1a30Sjl */ 22525cf1a30Sjl /* LINTED */ 22625cf1a30Sjl ASSERT(SCF_EVENT_PRI == DDI_SOFTINT_LOW); 22725cf1a30Sjl if (ddi_get_soft_iblock_cookie(dip, SCF_EVENT_PRI, 22825cf1a30Sjl &okmsp->km_ibcookie) != DDI_SUCCESS) { 22925cf1a30Sjl cmn_err(CE_WARN, "ddi_get_soft_iblock_cookie failed."); 23025cf1a30Sjl return (DDI_FAILURE); 23125cf1a30Sjl } 23225cf1a30Sjl mutex_init(&okmsp->km_lock, NULL, MUTEX_DRIVER, 23325cf1a30Sjl (void *)okmsp->km_ibcookie); 23425cf1a30Sjl okmsp->km_clean |= OKM_CLEAN_LOCK; 23525cf1a30Sjl cv_init(&okmsp->km_wait, NULL, CV_DRIVER, NULL); 23625cf1a30Sjl okmsp->km_clean |= OKM_CLEAN_CV; 23725cf1a30Sjl 23825cf1a30Sjl /* 23925cf1a30Sjl * set clean_node ahead as remove_node has to be called even 24025cf1a30Sjl * if create node fails. 24125cf1a30Sjl */ 24225cf1a30Sjl okmsp->km_clean |= OKM_CLEAN_NODE; 24325cf1a30Sjl if (ddi_create_minor_node(dip, OKM_NODENAME, S_IFCHR, 24425cf1a30Sjl instance, NULL, NULL) == DDI_FAILURE) { 24525cf1a30Sjl cmn_err(CE_WARN, "Device node creation failed"); 24625cf1a30Sjl okm_cleanup(okmsp); 24725cf1a30Sjl return (DDI_FAILURE); 24825cf1a30Sjl } 24925cf1a30Sjl 25025cf1a30Sjl ddi_set_driver_private(dip, (caddr_t)okmsp); 25125cf1a30Sjl ddi_report_dev(dip); 25225cf1a30Sjl return (DDI_SUCCESS); 25325cf1a30Sjl } 25425cf1a30Sjl 25525cf1a30Sjl /* 25625cf1a30Sjl * okm_detach - Module's detach routine. 25725cf1a30Sjl * 25825cf1a30Sjl * Description: Cleans up the module's state structures and any other 25925cf1a30Sjl * relevant data. 26025cf1a30Sjl */ 26125cf1a30Sjl int 26225cf1a30Sjl okm_detach(dev_info_t *dip, ddi_detach_cmd_t cmd) 26325cf1a30Sjl { 26425cf1a30Sjl okms_t *okmsp; 26525cf1a30Sjl 26625cf1a30Sjl if (cmd != DDI_DETACH) { 26725cf1a30Sjl return (DDI_FAILURE); 26825cf1a30Sjl } 26925cf1a30Sjl 27025cf1a30Sjl if ((okmsp = ddi_get_driver_private(dip)) == NULL) { 27125cf1a30Sjl return (DDI_FAILURE); 27225cf1a30Sjl } 27325cf1a30Sjl 27425cf1a30Sjl mutex_enter(&okmsp->km_lock); 27525cf1a30Sjl /* 27625cf1a30Sjl * Check if the mailbox is still in use. 27725cf1a30Sjl */ 27825cf1a30Sjl if (okmsp->km_state & OKM_MB_INITED) { 27925cf1a30Sjl mutex_exit(&okmsp->km_lock); 28025cf1a30Sjl cmn_err(CE_WARN, "Detach failure: Mailbox in use"); 28125cf1a30Sjl return (DDI_FAILURE); 28225cf1a30Sjl } 28325cf1a30Sjl mutex_exit(&okmsp->km_lock); 28425cf1a30Sjl okm_cleanup(okmsp); 28525cf1a30Sjl ddi_set_driver_private(dip, NULL); 28625cf1a30Sjl return (DDI_SUCCESS); 28725cf1a30Sjl } 28825cf1a30Sjl 28925cf1a30Sjl /* 29025cf1a30Sjl * okm_info - Module's info routine. 29125cf1a30Sjl */ 29225cf1a30Sjl /* ARGSUSED */ 29325cf1a30Sjl int 29425cf1a30Sjl okm_info(dev_info_t *dip, ddi_info_cmd_t infocmd, void *arg, void **result) 29525cf1a30Sjl { 29625cf1a30Sjl okms_t *okmsp; 29725cf1a30Sjl minor_t minor; 29825cf1a30Sjl int ret = DDI_FAILURE; 29925cf1a30Sjl 30025cf1a30Sjl switch (infocmd) { 30125cf1a30Sjl case DDI_INFO_DEVT2DEVINFO: 30225cf1a30Sjl minor = getminor((dev_t)arg); 30325cf1a30Sjl okmsp = ddi_get_driver_private(dip); 30425cf1a30Sjl if (okmsp == NULL) { 30525cf1a30Sjl *result = NULL; 30625cf1a30Sjl } else { 30725cf1a30Sjl *result = okmsp->km_dip; 30825cf1a30Sjl ret = DDI_SUCCESS; 30925cf1a30Sjl } 31025cf1a30Sjl break; 31125cf1a30Sjl 31225cf1a30Sjl case DDI_INFO_DEVT2INSTANCE: 31325cf1a30Sjl minor = getminor((dev_t)arg); 31425cf1a30Sjl *result = (void *)(uintptr_t)minor; 31525cf1a30Sjl ret = DDI_SUCCESS; 31625cf1a30Sjl 31725cf1a30Sjl default: 31825cf1a30Sjl break; 31925cf1a30Sjl } 32025cf1a30Sjl return (ret); 32125cf1a30Sjl } 32225cf1a30Sjl 32325cf1a30Sjl /* 32425cf1a30Sjl * okm_open - Device open routine. 32525cf1a30Sjl * 32625cf1a30Sjl * Description: Initializes the mailbox and waits until the mailbox 32725cf1a30Sjl * gets connected. Only one open at a time is supported. 32825cf1a30Sjl */ 32925cf1a30Sjl /*ARGSUSED*/ 33025cf1a30Sjl int 33125cf1a30Sjl okm_open(dev_t *devp, int flag, int otyp, struct cred *cred) 33225cf1a30Sjl { 33325cf1a30Sjl okms_t *okmsp = &okms_global; 33425cf1a30Sjl int ret = 0; 33525cf1a30Sjl 33625cf1a30Sjl DPRINTF(DBG_DRV, ("okm_open: called\n")); 33725cf1a30Sjl mutex_enter(&okmsp->km_lock); 33825cf1a30Sjl if (okmsp->km_state & OKM_OPENED) { 33925cf1a30Sjl /* Only one open supported */ 34025cf1a30Sjl mutex_exit(&okmsp->km_lock); 34125cf1a30Sjl DPRINTF(DBG_WARN, ("okm_open: already opened\n")); 34225cf1a30Sjl return (EBUSY); 34325cf1a30Sjl } 34425cf1a30Sjl okmsp->km_state |= OKM_OPENED; 34525cf1a30Sjl ret = block_until_ready(okmsp); 34625cf1a30Sjl if (ret != 0) { 34725cf1a30Sjl okmsp->km_state &= ~OKM_OPENED; 34825cf1a30Sjl } 34925cf1a30Sjl mutex_exit(&okmsp->km_lock); 35025cf1a30Sjl DPRINTF(DBG_DRV, ("okm_open: ret=%d\n", ret)); 35125cf1a30Sjl return (ret); 35225cf1a30Sjl } 35325cf1a30Sjl 35425cf1a30Sjl /* 35525cf1a30Sjl * block_until_ready - Function to wait until the mailbox is ready to use. 35625cf1a30Sjl * 35725cf1a30Sjl * Description: It initializes the mailbox and waits for the mailbox 35825cf1a30Sjl * state to transition to connected. 35925cf1a30Sjl */ 36025cf1a30Sjl int 36125cf1a30Sjl block_until_ready(okms_t *okmsp) 36225cf1a30Sjl { 36325cf1a30Sjl int ret = 0; 36425cf1a30Sjl 36525cf1a30Sjl DPRINTF(DBG_DRV, ("block_until_ready: called\n")); 36625cf1a30Sjl ASSERT(MUTEX_HELD(&okmsp->km_lock)); 36725cf1a30Sjl 36825cf1a30Sjl if (okmsp->km_state & OKM_MB_DISC) { 36925cf1a30Sjl DPRINTF(DBG_DRV, ("block_until_ready: closing the mailbox\n")); 37025cf1a30Sjl okm_mbox_fini(okmsp); 37125cf1a30Sjl } 37225cf1a30Sjl if (okmsp->km_state & OKM_MB_CONN) { 37325cf1a30Sjl DPRINTF(DBG_DRV, ("block_until_ready: mailbox connected\n")); 37425cf1a30Sjl return (0); 37525cf1a30Sjl } 37625cf1a30Sjl /* 37725cf1a30Sjl * Initialize mailbox. 37825cf1a30Sjl */ 37925cf1a30Sjl if ((ret = okm_mbox_init(okmsp)) != 0) { 38025cf1a30Sjl DPRINTF(DBG_MBOX, 38125cf1a30Sjl ("block_until_ready: mailbox init failed ret=%d\n", ret)); 38225cf1a30Sjl return (ret); 38325cf1a30Sjl } 38425cf1a30Sjl DPRINTF(DBG_DRV, ("block_until_ready: ret=%d", ret)); 38525cf1a30Sjl return (ret); 38625cf1a30Sjl } 38725cf1a30Sjl 38825cf1a30Sjl /* 38925cf1a30Sjl * okm_close - Device close routine. 39025cf1a30Sjl * 39125cf1a30Sjl * Description: Closes the mailbox. 39225cf1a30Sjl */ 39325cf1a30Sjl /*ARGSUSED*/ 39425cf1a30Sjl int 39525cf1a30Sjl okm_close(dev_t dev, int flag, int otyp, struct cred *cred) 39625cf1a30Sjl { 39725cf1a30Sjl okms_t *okmsp = &okms_global; 39825cf1a30Sjl 39925cf1a30Sjl DPRINTF(DBG_DRV, ("okm_close: called\n")); 40025cf1a30Sjl /* Close the lower layer first */ 40125cf1a30Sjl mutex_enter(&okmsp->km_lock); 40225cf1a30Sjl okm_mbox_fini(okmsp); 40325cf1a30Sjl okmsp->km_state = 0; 40425cf1a30Sjl mutex_exit(&okmsp->km_lock); 40525cf1a30Sjl return (0); 40625cf1a30Sjl } 40725cf1a30Sjl 40825cf1a30Sjl 40925cf1a30Sjl /* 41025cf1a30Sjl * okm_ioctl - Device ioctl routine. 41125cf1a30Sjl * 41225cf1a30Sjl * Description: Processes ioctls from the daemon. 41325cf1a30Sjl */ 41425cf1a30Sjl /*ARGSUSED*/ 41525cf1a30Sjl int 41625cf1a30Sjl okm_ioctl(dev_t dev, int cmd, intptr_t data, int flag, cred_t *cred, int *rvalp) 41725cf1a30Sjl { 41825cf1a30Sjl okms_t *okmsp = &okms_global; 41925cf1a30Sjl sckm_ioctl_getreq_t ireq; 42025cf1a30Sjl sckm_ioctl_status_t istatus; 42125cf1a30Sjl int ret = 0; 42225cf1a30Sjl 42325cf1a30Sjl switch (cmd) { 42425cf1a30Sjl case SCKM_IOCTL_GETREQ: 42525cf1a30Sjl 42625cf1a30Sjl DPRINTF(DBG_DRV, ("okm_ioctl: GETREQ\n")); 42725cf1a30Sjl if (okm_copyin_ioctl_getreq(data, &ireq, flag)) { 42825cf1a30Sjl return (EFAULT); 42925cf1a30Sjl } 43025cf1a30Sjl 43125cf1a30Sjl ret = okm_get_req(okmsp, &ireq, data, flag); 43225cf1a30Sjl DPRINTF(DBG_DRV, ("okm_ioctl: GETREQ ret=%d\n", ret)); 43325cf1a30Sjl break; 43425cf1a30Sjl 43525cf1a30Sjl case SCKM_IOCTL_STATUS: 43625cf1a30Sjl 43725cf1a30Sjl DPRINTF(DBG_DRV, ("okm_ioctl: STATUS\n")); 43825cf1a30Sjl if (ddi_copyin((caddr_t)data, &istatus, 43925cf1a30Sjl sizeof (sckm_ioctl_status_t), flag)) { 44025cf1a30Sjl return (EFAULT); 44125cf1a30Sjl } 44225cf1a30Sjl ret = okm_process_status(okmsp, &istatus); 44325cf1a30Sjl DPRINTF(DBG_DRV, ("okm_ioctl: STATUS ret=%d\n", ret)); 44425cf1a30Sjl break; 44525cf1a30Sjl 44625cf1a30Sjl default: 44725cf1a30Sjl DPRINTF(DBG_DRV, ("okm_ioctl: UNKNOWN ioctl\n")); 44825cf1a30Sjl ret = EINVAL; 44925cf1a30Sjl } 45025cf1a30Sjl return (ret); 45125cf1a30Sjl } 45225cf1a30Sjl 45325cf1a30Sjl /* 45425cf1a30Sjl * okm_get_req - Get a request from the mailbox. 45525cf1a30Sjl * 45625cf1a30Sjl * Description: It blocks until a message is received, then processes 45725cf1a30Sjl * the message and returns it to the requestor. 45825cf1a30Sjl */ 45925cf1a30Sjl int 46025cf1a30Sjl okm_get_req(okms_t *okmsp, sckm_ioctl_getreq_t *ireqp, intptr_t data, int flag) 46125cf1a30Sjl { 46225cf1a30Sjl okm_req_hdr_t *reqp; 46325cf1a30Sjl caddr_t msgbuf; 46425cf1a30Sjl uint32_t len; 46525cf1a30Sjl int ret; 46625cf1a30Sjl 46725cf1a30Sjl DPRINTF(DBG_DRV, ("okm_getreq: called\n")); 46825cf1a30Sjl mutex_enter(&okmsp->km_lock); 46925cf1a30Sjl if ((ret = block_until_ready(okmsp)) != 0) { 47025cf1a30Sjl mutex_exit(&okmsp->km_lock); 47125cf1a30Sjl DPRINTF(DBG_WARN, ("okm_getreq: failed ret=%d\n", ret)); 47225cf1a30Sjl return (ret); 47325cf1a30Sjl } 47425cf1a30Sjl 47525cf1a30Sjl if (okmsp->km_reqp != NULL) { 47625cf1a30Sjl DPRINTF(DBG_DRV, ("okm_getreq: req cached\n")); 47725cf1a30Sjl reqp = okmsp->km_reqp; 47825cf1a30Sjl len = okmsp->km_reqlen; 47925cf1a30Sjl okmsp->km_reqp = NULL; 48025cf1a30Sjl okmsp->km_reqlen = 0; 48125cf1a30Sjl } else { 48225cf1a30Sjl retry: 48325cf1a30Sjl while (OKM_MBOX_READY(okmsp) && 48425cf1a30Sjl ((ret = scf_mb_canget(okmsp->km_target, 48525cf1a30Sjl okmsp->km_key, &len)) != 0)) { 48625cf1a30Sjl if (ret != ENOMSG) { 48725cf1a30Sjl DPRINTF(DBG_WARN, ("okm_getreq: Unknown " 48825cf1a30Sjl "mbox failure=%d\n", ret)); 48925cf1a30Sjl mutex_exit(&okmsp->km_lock); 49025cf1a30Sjl return (EIO); 49125cf1a30Sjl } 49225cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_getreq: waiting for mesg\n")); 49325cf1a30Sjl if (cv_wait_sig(&okmsp->km_wait, 49425cf1a30Sjl &okmsp->km_lock) <= 0) { 49525cf1a30Sjl mutex_exit(&okmsp->km_lock); 49625cf1a30Sjl DPRINTF(DBG_DRV, ("okm_getreq:interrupted\n")); 49725cf1a30Sjl return (EINTR); 49825cf1a30Sjl } 49925cf1a30Sjl } 50025cf1a30Sjl if (!OKM_MBOX_READY(okmsp)) { 50125cf1a30Sjl mutex_exit(&okmsp->km_lock); 50225cf1a30Sjl DPRINTF(DBG_WARN, ("okm_getreq: mailbox not ready\n")); 50325cf1a30Sjl return (EIO); 50425cf1a30Sjl } 50525cf1a30Sjl ASSERT(len != 0); 50625cf1a30Sjl msgbuf = kmem_alloc(len, KM_SLEEP); 50725cf1a30Sjl okmsp->km_sg_rcv.msc_dptr = msgbuf; 50825cf1a30Sjl okmsp->km_sg_rcv.msc_len = len; 50925cf1a30Sjl 51025cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_getreq: getmsg\n")); 51125cf1a30Sjl ret = scf_mb_getmsg(okmsp->km_target, okmsp->km_key, len, 1, 51225cf1a30Sjl &okmsp->km_sg_rcv, 0); 51325cf1a30Sjl if (ret == ENOMSG || ret == EMSGSIZE) { 51425cf1a30Sjl kmem_free(msgbuf, len); 51525cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_getreq: nomsg ret=%d\n", ret)); 51625cf1a30Sjl goto retry; 51725cf1a30Sjl } else if (ret != 0) { 51825cf1a30Sjl kmem_free(msgbuf, len); 51925cf1a30Sjl mutex_exit(&okmsp->km_lock); 52025cf1a30Sjl DPRINTF(DBG_WARN, 52125cf1a30Sjl ("okm_getreq: Unknown mbox failure=%d\n", ret)); 52225cf1a30Sjl return (EIO); 52325cf1a30Sjl } 52425cf1a30Sjl 52525cf1a30Sjl /* check message length */ 52625cf1a30Sjl if (len < sizeof (okm_req_hdr_t)) { 52725cf1a30Sjl /* protocol error, drop message */ 52825cf1a30Sjl kmem_free(msgbuf, len); 52925cf1a30Sjl mutex_exit(&okmsp->km_lock); 53025cf1a30Sjl DPRINTF(DBG_WARN, ("okm_getreq: Bad message\n")); 53125cf1a30Sjl return (EBADMSG); 53225cf1a30Sjl } 53325cf1a30Sjl 53425cf1a30Sjl reqp = (okm_req_hdr_t *)msgbuf; 53525cf1a30Sjl reqp->krq_version = ntohl(reqp->krq_version); 53625cf1a30Sjl reqp->krq_transid = ntohl(reqp->krq_transid); 53725cf1a30Sjl reqp->krq_cmd = ntohl(reqp->krq_cmd); 53825cf1a30Sjl reqp->krq_reserved = ntohl(reqp->krq_reserved); 53925cf1a30Sjl 54025cf1a30Sjl /* check version of the message received */ 54125cf1a30Sjl if (reqp->krq_version != OKM_PROTOCOL_VERSION) { 54225cf1a30Sjl okm_send_reply(okmsp, reqp->krq_transid, 54325cf1a30Sjl OKM_ERR_VERSION, 0, 0); 54425cf1a30Sjl kmem_free(msgbuf, len); 54525cf1a30Sjl mutex_exit(&okmsp->km_lock); 54625cf1a30Sjl DPRINTF(DBG_WARN, ("okm_getreq: Unknown version=%d\n", 54725cf1a30Sjl reqp->krq_version)); 54825cf1a30Sjl return (EBADMSG); 54925cf1a30Sjl } 55025cf1a30Sjl } 55125cf1a30Sjl 55225cf1a30Sjl /* process message */ 55325cf1a30Sjl ret = okm_process_req(okmsp, reqp, len, ireqp, data, flag); 55425cf1a30Sjl if (okmsp->km_reqp == NULL) { 55525cf1a30Sjl /* 55625cf1a30Sjl * The message is not saved, so free the buffer. 55725cf1a30Sjl */ 55825cf1a30Sjl kmem_free(reqp, len); 55925cf1a30Sjl } 56025cf1a30Sjl mutex_exit(&okmsp->km_lock); 56125cf1a30Sjl DPRINTF(DBG_DRV, ("okm_getreq: ret=%d\n", ret)); 56225cf1a30Sjl return (ret); 56325cf1a30Sjl } 56425cf1a30Sjl 56525cf1a30Sjl 56625cf1a30Sjl /* 56725cf1a30Sjl * okm_process_req - Process the request. 56825cf1a30Sjl * 56925cf1a30Sjl * Description: Validate the request and then give the request to the 57025cf1a30Sjl * daemon. 57125cf1a30Sjl */ 57225cf1a30Sjl int 57325cf1a30Sjl okm_process_req(okms_t *okmsp, okm_req_hdr_t *reqp, uint32_t len, 57425cf1a30Sjl sckm_ioctl_getreq_t *ireqp, intptr_t data, int flag) 57525cf1a30Sjl { 57625cf1a30Sjl void *req_datap = (void *)(((char *)reqp) + sizeof (okm_req_hdr_t)); 57725cf1a30Sjl int sadb_msglen = len - sizeof (okm_req_hdr_t); 57825cf1a30Sjl 57925cf1a30Sjl DPRINTF(DBG_DRV, ("okm_process_req: called\n")); 58025cf1a30Sjl DUMP_REQ(reqp, len); 58125cf1a30Sjl 58225cf1a30Sjl switch (reqp->krq_cmd) { 58325cf1a30Sjl case OKM_MSG_SADB: 58425cf1a30Sjl /* sanity check request */ 58525cf1a30Sjl if (sadb_msglen <= 0) { 58625cf1a30Sjl okm_send_reply(okmsp, reqp->krq_transid, 58725cf1a30Sjl OKM_ERR_SADB_MSG, 0, 0); 58825cf1a30Sjl DPRINTF(DBG_WARN, ("okm_process_req: bad message\n")); 58925cf1a30Sjl return (EBADMSG); 59025cf1a30Sjl } 59125cf1a30Sjl 59225cf1a30Sjl /* 59325cf1a30Sjl * Save the message, prior to giving it to the daemon. 59425cf1a30Sjl */ 59525cf1a30Sjl okmsp->km_reqp = reqp; 59625cf1a30Sjl okmsp->km_reqlen = len; 59725cf1a30Sjl 59825cf1a30Sjl if (ireqp->buf_len < len) { 59925cf1a30Sjl DPRINTF(DBG_WARN, 60025cf1a30Sjl ("okm_process_req: not enough space\n")); 60125cf1a30Sjl return (ENOSPC); 60225cf1a30Sjl } 60325cf1a30Sjl 60425cf1a30Sjl ireqp->transid = reqp->krq_transid; 60525cf1a30Sjl ireqp->type = SCKM_IOCTL_REQ_SADB; 60625cf1a30Sjl if (ddi_copyout(req_datap, ireqp->buf, sadb_msglen, flag)) { 60725cf1a30Sjl DPRINTF(DBG_WARN, 60825cf1a30Sjl ("okm_process_req: copyout failed\n")); 60925cf1a30Sjl return (EFAULT); 61025cf1a30Sjl } 61125cf1a30Sjl ireqp->buf_len = sadb_msglen; 61225cf1a30Sjl if (okm_copyout_ioctl_getreq(ireqp, data, flag)) { 61325cf1a30Sjl DPRINTF(DBG_WARN, 61425cf1a30Sjl ("okm_process_req: copyout failed\n")); 61525cf1a30Sjl return (EFAULT); 61625cf1a30Sjl } 61725cf1a30Sjl break; 61825cf1a30Sjl 61925cf1a30Sjl default: 62025cf1a30Sjl cmn_err(CE_WARN, "Unknown cmd 0x%x received", reqp->krq_cmd); 62125cf1a30Sjl /* 62225cf1a30Sjl * Received an unknown command, send corresponding 62325cf1a30Sjl * error message. 62425cf1a30Sjl */ 62525cf1a30Sjl okm_send_reply(okmsp, reqp->krq_transid, OKM_ERR_BAD_CMD, 0, 0); 62625cf1a30Sjl return (EBADMSG); 62725cf1a30Sjl } 62825cf1a30Sjl DPRINTF(DBG_DRV, ("okm_process_req: ret=0\n")); 62925cf1a30Sjl return (0); 63025cf1a30Sjl } 63125cf1a30Sjl 63225cf1a30Sjl /* 63325cf1a30Sjl * okm_process_status - Process the status from the daemon. 63425cf1a30Sjl * 63525cf1a30Sjl * Description: Processes the status received from the daemon and sends 63625cf1a30Sjl * corresponding message to the SP. 63725cf1a30Sjl */ 63825cf1a30Sjl int 63925cf1a30Sjl okm_process_status(okms_t *okmsp, sckm_ioctl_status_t *ireply) 64025cf1a30Sjl { 64125cf1a30Sjl uint32_t status; 64225cf1a30Sjl uint32_t sadb_msg_errno = 0; 64325cf1a30Sjl uint32_t sadb_msg_version = 0; 64425cf1a30Sjl okm_req_hdr_t *reqp = okmsp->km_reqp; 64525cf1a30Sjl int ret; 64625cf1a30Sjl 64725cf1a30Sjl DPRINTF(DBG_DRV, ("okm_process_status: called\n")); 64825cf1a30Sjl mutex_enter(&okmsp->km_lock); 64925cf1a30Sjl if ((ret = block_until_ready(okmsp)) != 0) { 65025cf1a30Sjl mutex_exit(&okmsp->km_lock); 65125cf1a30Sjl DPRINTF(DBG_WARN, 65225cf1a30Sjl ("okm_process_status: Unknown failure=%d\n", ret)); 65325cf1a30Sjl return (ret); 65425cf1a30Sjl } 65525cf1a30Sjl 65625cf1a30Sjl /* fail if no status is expected, or if it does not match */ 65725cf1a30Sjl if (!okmsp->km_reqp || (reqp->krq_transid != ireply->transid)) { 65825cf1a30Sjl mutex_exit(&okmsp->km_lock); 65925cf1a30Sjl DPRINTF(DBG_WARN, 66025cf1a30Sjl ("okm_process_status: req/transid mismatch\n")); 66125cf1a30Sjl return (EINVAL); 66225cf1a30Sjl } 66325cf1a30Sjl 66425cf1a30Sjl switch (ireply->status) { 66525cf1a30Sjl case SCKM_IOCTL_STAT_SUCCESS: 66625cf1a30Sjl DPRINTF(DBG_DRV, ("okm_process_status: SUCCESS\n")); 66725cf1a30Sjl status = OKM_SUCCESS; 66825cf1a30Sjl break; 66925cf1a30Sjl case SCKM_IOCTL_STAT_ERR_PFKEY: 67025cf1a30Sjl DPRINTF(DBG_DRV, ("okm_process_status: PFKEY ERROR\n")); 67125cf1a30Sjl status = OKM_ERR_SADB_PFKEY; 67225cf1a30Sjl sadb_msg_errno = ireply->sadb_msg_errno; 67325cf1a30Sjl break; 67425cf1a30Sjl case SCKM_IOCTL_STAT_ERR_REQ: 67525cf1a30Sjl DPRINTF(DBG_DRV, ("okm_process_status: REQ ERROR\n")); 67625cf1a30Sjl status = OKM_ERR_DAEMON; 67725cf1a30Sjl break; 67825cf1a30Sjl case SCKM_IOCTL_STAT_ERR_VERSION: 67925cf1a30Sjl DPRINTF(DBG_DRV, ("okm_process_status: SADB VERSION ERROR\n")); 68025cf1a30Sjl status = OKM_ERR_SADB_VERSION; 68125cf1a30Sjl sadb_msg_version = ireply->sadb_msg_version; 68225cf1a30Sjl break; 68325cf1a30Sjl case SCKM_IOCTL_STAT_ERR_TIMEOUT: 68425cf1a30Sjl DPRINTF(DBG_DRV, ("okm_process_status: TIMEOUT ERR\n")); 68525cf1a30Sjl status = OKM_ERR_SADB_TIMEOUT; 68625cf1a30Sjl break; 68725cf1a30Sjl case SCKM_IOCTL_STAT_ERR_OTHER: 68825cf1a30Sjl DPRINTF(DBG_DRV, ("okm_process_status: OTHER ERR\n")); 68925cf1a30Sjl status = OKM_ERR_DAEMON; 69025cf1a30Sjl break; 69125cf1a30Sjl case SCKM_IOCTL_STAT_ERR_SADB_TYPE: 69225cf1a30Sjl DPRINTF(DBG_DRV, ("okm_process_status: SADB TYPE ERR\n")); 69325cf1a30Sjl status = OKM_ERR_SADB_BAD_TYPE; 69425cf1a30Sjl break; 69525cf1a30Sjl default: 69625cf1a30Sjl cmn_err(CE_WARN, "SCKM daemon returned invalid status %d\n", 69725cf1a30Sjl ireply->status); 69825cf1a30Sjl status = OKM_ERR_DAEMON; 69925cf1a30Sjl } 70025cf1a30Sjl ret = okm_send_reply(okmsp, ireply->transid, status, 70125cf1a30Sjl sadb_msg_errno, sadb_msg_version); 70225cf1a30Sjl /* 70325cf1a30Sjl * Clean up the cached request now. 70425cf1a30Sjl */ 70525cf1a30Sjl if (ret == 0) { 70625cf1a30Sjl kmem_free(okmsp->km_reqp, okmsp->km_reqlen); 70725cf1a30Sjl okmsp->km_reqp = NULL; 70825cf1a30Sjl okmsp->km_reqlen = 0; 70925cf1a30Sjl } 71025cf1a30Sjl mutex_exit(&okmsp->km_lock); 71125cf1a30Sjl DPRINTF(DBG_DRV, ("okm_process_status: ret=%d\n", ret)); 71225cf1a30Sjl return (ret); 71325cf1a30Sjl } 71425cf1a30Sjl 71525cf1a30Sjl /* 71625cf1a30Sjl * okm_copyin_ioctl_getreq - copy-in the ioctl request from the daemon. 71725cf1a30Sjl */ 71825cf1a30Sjl 71925cf1a30Sjl static int 72025cf1a30Sjl okm_copyin_ioctl_getreq(intptr_t userarg, sckm_ioctl_getreq_t *driverarg, 72125cf1a30Sjl int flag) 72225cf1a30Sjl { 72325cf1a30Sjl #ifdef _MULTI_DATAMODEL 72425cf1a30Sjl switch (ddi_model_convert_from(flag & FMODELS)) { 72525cf1a30Sjl case DDI_MODEL_ILP32: { 72625cf1a30Sjl sckm_ioctl_getreq32_t driverarg32; 72725cf1a30Sjl if (ddi_copyin((caddr_t)userarg, &driverarg32, 72825cf1a30Sjl sizeof (sckm_ioctl_getreq32_t), flag)) { 72925cf1a30Sjl return (EFAULT); 73025cf1a30Sjl } 73125cf1a30Sjl driverarg->transid = driverarg32.transid; 73225cf1a30Sjl driverarg->type = driverarg32.type; 73325cf1a30Sjl driverarg->buf = (caddr_t)(uintptr_t)driverarg32.buf; 73425cf1a30Sjl driverarg->buf_len = driverarg32.buf_len; 73525cf1a30Sjl break; 73625cf1a30Sjl } 73725cf1a30Sjl case DDI_MODEL_NONE: { 73825cf1a30Sjl if (ddi_copyin((caddr_t)userarg, &driverarg, 73925cf1a30Sjl sizeof (sckm_ioctl_getreq_t), flag)) { 74025cf1a30Sjl return (EFAULT); 74125cf1a30Sjl } 74225cf1a30Sjl break; 74325cf1a30Sjl } 74425cf1a30Sjl } 74525cf1a30Sjl #else /* ! _MULTI_DATAMODEL */ 74625cf1a30Sjl if (ddi_copyin((caddr_t)userarg, &driverarg, 74725cf1a30Sjl sizeof (sckm_ioctl_getreq_t), flag)) { 74825cf1a30Sjl return (EFAULT); 74925cf1a30Sjl } 75025cf1a30Sjl #endif /* _MULTI_DATAMODEL */ 75125cf1a30Sjl return (0); 75225cf1a30Sjl } 75325cf1a30Sjl 75425cf1a30Sjl 75525cf1a30Sjl /* 75625cf1a30Sjl * okm_copyout_ioctl_getreq - copy-out the request to the daemon. 75725cf1a30Sjl */ 75825cf1a30Sjl static int 75925cf1a30Sjl okm_copyout_ioctl_getreq(sckm_ioctl_getreq_t *driverarg, intptr_t userarg, 76025cf1a30Sjl int flag) 76125cf1a30Sjl { 76225cf1a30Sjl #ifdef _MULTI_DATAMODEL 76325cf1a30Sjl switch (ddi_model_convert_from(flag & FMODELS)) { 76425cf1a30Sjl case DDI_MODEL_ILP32: { 76525cf1a30Sjl sckm_ioctl_getreq32_t driverarg32; 76625cf1a30Sjl driverarg32.transid = driverarg->transid; 76725cf1a30Sjl driverarg32.type = driverarg->type; 76825cf1a30Sjl driverarg32.buf = (caddr32_t)(uintptr_t)driverarg->buf; 76925cf1a30Sjl driverarg32.buf_len = driverarg->buf_len; 77025cf1a30Sjl if (ddi_copyout(&driverarg32, (caddr_t)userarg, 77125cf1a30Sjl sizeof (sckm_ioctl_getreq32_t), flag)) { 77225cf1a30Sjl return (EFAULT); 77325cf1a30Sjl } 77425cf1a30Sjl break; 77525cf1a30Sjl } 77625cf1a30Sjl case DDI_MODEL_NONE: 77725cf1a30Sjl if (ddi_copyout(driverarg, (caddr_t)userarg, 77825cf1a30Sjl sizeof (sckm_ioctl_getreq_t), flag)) { 77925cf1a30Sjl return (EFAULT); 78025cf1a30Sjl } 78125cf1a30Sjl break; 78225cf1a30Sjl } 78325cf1a30Sjl #else /* ! _MULTI_DATAMODEL */ 78425cf1a30Sjl if (ddi_copyout(driverarg, (caddr_t)userarg, 78525cf1a30Sjl sizeof (sckm_ioctl_getreq_t), flag)) { 78625cf1a30Sjl return (EFAULT); 78725cf1a30Sjl } 78825cf1a30Sjl #endif /* _MULTI_DATAMODEL */ 78925cf1a30Sjl return (0); 79025cf1a30Sjl } 79125cf1a30Sjl 79225cf1a30Sjl /* 79325cf1a30Sjl * okm_cleanup - Cleanup routine. 79425cf1a30Sjl */ 79525cf1a30Sjl static void 79625cf1a30Sjl okm_cleanup(okms_t *okmsp) 79725cf1a30Sjl { 79825cf1a30Sjl 79925cf1a30Sjl ASSERT(okmsp != NULL); 80025cf1a30Sjl if (okmsp->km_clean & OKM_CLEAN_NODE) { 80125cf1a30Sjl ddi_remove_minor_node(okmsp->km_dip, NULL); 80225cf1a30Sjl } 80325cf1a30Sjl if (okmsp->km_clean & OKM_CLEAN_LOCK) 80425cf1a30Sjl mutex_destroy(&okmsp->km_lock); 80525cf1a30Sjl if (okmsp->km_clean & OKM_CLEAN_CV) 80625cf1a30Sjl cv_destroy(&okmsp->km_wait); 80725cf1a30Sjl if (okmsp->km_reqp != NULL) { 80825cf1a30Sjl kmem_free(okmsp->km_reqp, okmsp->km_reqlen); 80925cf1a30Sjl okmsp->km_reqp = NULL; 81025cf1a30Sjl okmsp->km_reqlen = 0; 81125cf1a30Sjl } 81225cf1a30Sjl ddi_set_driver_private(okmsp->km_dip, NULL); 81325cf1a30Sjl } 81425cf1a30Sjl 81525cf1a30Sjl /* 81625cf1a30Sjl * okm_mbox_init - Mailbox specific initialization. 81725cf1a30Sjl */ 81825cf1a30Sjl static int 81925cf1a30Sjl okm_mbox_init(okms_t *okmsp) 82025cf1a30Sjl { 82125cf1a30Sjl int ret; 82225cf1a30Sjl clock_t tout; 82325cf1a30Sjl 82425cf1a30Sjl ASSERT(MUTEX_HELD(&okmsp->km_lock)); 82525cf1a30Sjl okmsp->km_target = OKM_TARGET_ID; 82625cf1a30Sjl okmsp->km_key = DKMD_KEY; 82725cf1a30Sjl okmsp->km_state &= ~OKM_MB_INITED; 82825cf1a30Sjl 82925cf1a30Sjl /* Iterate until mailbox gets connected */ 83025cf1a30Sjl while (!(okmsp->km_state & OKM_MB_CONN)) { 83125cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_mbox_init: calling mb_init\n")); 83225cf1a30Sjl ret = scf_mb_init(okmsp->km_target, okmsp->km_key, 83325cf1a30Sjl okm_event_handler, (void *)okmsp); 83425cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_mbox_init: mb_init ret=%d\n", ret)); 83525cf1a30Sjl 836030f3a8fSraghuram if (ret != 0) { 837030f3a8fSraghuram DPRINTF(DBG_MBOX, 838030f3a8fSraghuram ("okm_mbox_init: failed ret =%d\n", ret)); 839030f3a8fSraghuram DTRACE_PROBE1(okm_mbox_fail, int, ret); 840030f3a8fSraghuram } else { 84125cf1a30Sjl okmsp->km_state |= OKM_MB_INITED; 84225cf1a30Sjl 84325cf1a30Sjl /* Block until the mailbox is ready to communicate. */ 84425cf1a30Sjl while (!(okmsp->km_state & 84525cf1a30Sjl (OKM_MB_CONN | OKM_MB_DISC))) { 84625cf1a30Sjl 84725cf1a30Sjl if (cv_wait_sig(&okmsp->km_wait, 84825cf1a30Sjl &okmsp->km_lock) <= 0) { 84925cf1a30Sjl /* interrupted */ 85025cf1a30Sjl ret = EINTR; 85125cf1a30Sjl break; 85225cf1a30Sjl } 85325cf1a30Sjl } 85425cf1a30Sjl } 85525cf1a30Sjl 856030f3a8fSraghuram if ((ret != 0) || (okmsp->km_state & OKM_MB_DISC)) { 85725cf1a30Sjl 858030f3a8fSraghuram if (okmsp->km_state & OKM_MB_INITED) { 859030f3a8fSraghuram (void) scf_mb_fini(okmsp->km_target, 860030f3a8fSraghuram okmsp->km_key); 861030f3a8fSraghuram } 862030f3a8fSraghuram if (okmsp->km_state & OKM_MB_DISC) { 863030f3a8fSraghuram DPRINTF(DBG_WARN, 864030f3a8fSraghuram ("okm_mbox_init: mbox DISC_ERROR\n")); 865030f3a8fSraghuram DTRACE_PROBE1(okm_mbox_fail, 866030f3a8fSraghuram int, OKM_MB_DISC); 867030f3a8fSraghuram } 86825cf1a30Sjl 869030f3a8fSraghuram okmsp->km_state &= ~(OKM_MB_INITED | OKM_MB_DISC | 870030f3a8fSraghuram OKM_MB_CONN); 87125cf1a30Sjl 872030f3a8fSraghuram if (ret == EINTR) { 873030f3a8fSraghuram return (ret); 874030f3a8fSraghuram } 87525cf1a30Sjl 87625cf1a30Sjl /* 87725cf1a30Sjl * If there was failure, then wait for 87825cf1a30Sjl * OKM_MB_TOUT secs and retry again. 87925cf1a30Sjl */ 88025cf1a30Sjl 88125cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_mbox_init: waiting...\n")); 88225cf1a30Sjl tout = ddi_get_lbolt() + drv_usectohz(OKM_MB_TOUT); 88325cf1a30Sjl ret = cv_timedwait_sig(&okmsp->km_wait, 88425cf1a30Sjl &okmsp->km_lock, tout); 88525cf1a30Sjl if (ret == 0) { 88625cf1a30Sjl /* if interrupted, return immediately. */ 88725cf1a30Sjl DPRINTF(DBG_MBOX, 88825cf1a30Sjl ("okm_mbox_init: interrupted\n")); 88925cf1a30Sjl return (EINTR); 89025cf1a30Sjl } 89125cf1a30Sjl } 89225cf1a30Sjl } 89325cf1a30Sjl 89425cf1a30Sjl ret = scf_mb_ctrl(okmsp->km_target, okmsp->km_key, 89525cf1a30Sjl SCF_MBOP_MAXMSGSIZE, &okmsp->km_maxsz); 89625cf1a30Sjl 89725cf1a30Sjl /* 89825cf1a30Sjl * The max msg size should be at least the size of reply 89925cf1a30Sjl * we need to send. 90025cf1a30Sjl */ 90125cf1a30Sjl if ((ret == 0) && (okmsp->km_maxsz < sizeof (okm_rep_hdr_t))) { 90225cf1a30Sjl cmn_err(CE_WARN, "Max message size expected >= %ld " 90325cf1a30Sjl "but found %d\n", sizeof (okm_rep_hdr_t), okmsp->km_maxsz); 90425cf1a30Sjl ret = EIO; 90525cf1a30Sjl } 90625cf1a30Sjl if (ret != 0) { 90725cf1a30Sjl okmsp->km_state &= ~OKM_MB_INITED; 90825cf1a30Sjl (void) scf_mb_fini(okmsp->km_target, okmsp->km_key); 90925cf1a30Sjl } 91025cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_mbox_init: mb_init ret=%d\n", ret)); 91125cf1a30Sjl return (ret); 91225cf1a30Sjl } 91325cf1a30Sjl 91425cf1a30Sjl /* 91525cf1a30Sjl * okm_mbox_fini - Mailbox de-initialization. 91625cf1a30Sjl */ 91725cf1a30Sjl static void 91825cf1a30Sjl okm_mbox_fini(okms_t *okmsp) 91925cf1a30Sjl { 92025cf1a30Sjl int ret = 0; 92125cf1a30Sjl 92225cf1a30Sjl ASSERT(MUTEX_HELD(&okmsp->km_lock)); 92325cf1a30Sjl if (okmsp->km_state & OKM_MB_INITED) { 92425cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_mbox_fini: calling mb_fini\n")); 92525cf1a30Sjl ret = scf_mb_fini(okmsp->km_target, okmsp->km_key); 92625cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_mbox_fini: mb_fini ret=%d\n", ret)); 92725cf1a30Sjl if (ret != 0) { 92825cf1a30Sjl cmn_err(CE_WARN, 92925cf1a30Sjl "Failed to close the Mailbox error=%d", ret); 93025cf1a30Sjl } 93125cf1a30Sjl okmsp->km_state &= ~(OKM_MB_INITED | OKM_MB_CONN | OKM_MB_DISC); 93225cf1a30Sjl } 93325cf1a30Sjl } 93425cf1a30Sjl 93525cf1a30Sjl /* 93625cf1a30Sjl * okm_event_handler - Mailbox event handler. 93725cf1a30Sjl * 93825cf1a30Sjl * Description: Implements a state machine to handle all the mailbox 93925cf1a30Sjl * events. For each event, it sets the appropriate state 94025cf1a30Sjl * flag and wakes up the threads waiting for that event. 94125cf1a30Sjl */ 94225cf1a30Sjl void 94325cf1a30Sjl okm_event_handler(scf_event_t event, void *arg) 94425cf1a30Sjl { 94525cf1a30Sjl okms_t *okmsp = (okms_t *)arg; 94625cf1a30Sjl 94725cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_event_handler: called\n")); 94825cf1a30Sjl ASSERT(okmsp != NULL); 94925cf1a30Sjl mutex_enter(&okmsp->km_lock); 95025cf1a30Sjl if (!(okmsp->km_state & OKM_MB_INITED)) { 95125cf1a30Sjl /* 95225cf1a30Sjl * Ignore all events if the state flag indicates that the 95325cf1a30Sjl * mailbox not initialized, this may happen during the close. 95425cf1a30Sjl */ 95525cf1a30Sjl mutex_exit(&okmsp->km_lock); 95625cf1a30Sjl DPRINTF(DBG_MBOX, 95725cf1a30Sjl ("okm_event_handler: event=0x%X - mailbox not inited \n", 95825cf1a30Sjl event)); 95925cf1a30Sjl return; 96025cf1a30Sjl } 96125cf1a30Sjl switch (event) { 96225cf1a30Sjl case SCF_MB_CONN_OK: 96325cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_event_handler: Event CONN_OK\n")); 96425cf1a30Sjl /* 96525cf1a30Sjl * Now the mailbox is ready to use, lets wake up 96625cf1a30Sjl * any one waiting for this event. 96725cf1a30Sjl */ 96825cf1a30Sjl okmsp->km_state |= OKM_MB_CONN; 96925cf1a30Sjl cv_broadcast(&okmsp->km_wait); 97025cf1a30Sjl break; 97125cf1a30Sjl 97225cf1a30Sjl case SCF_MB_MSG_DATA: 97325cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_event_handler: Event MSG_DATA\n")); 97425cf1a30Sjl /* 97525cf1a30Sjl * A message is available in the mailbox, 97625cf1a30Sjl * wakeup if any one is ready to read the message. 97725cf1a30Sjl */ 97825cf1a30Sjl if (OKM_MBOX_READY(okmsp)) { 97925cf1a30Sjl cv_broadcast(&okmsp->km_wait); 98025cf1a30Sjl } 98125cf1a30Sjl break; 98225cf1a30Sjl 98325cf1a30Sjl case SCF_MB_SPACE: 98425cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_event_handler: Event MB_SPACE\n")); 98525cf1a30Sjl /* 98625cf1a30Sjl * Now the mailbox is ready to transmit, lets 98725cf1a30Sjl * wakeup if any one is waiting to write. 98825cf1a30Sjl */ 98925cf1a30Sjl if (OKM_MBOX_READY(okmsp)) { 99025cf1a30Sjl cv_broadcast(&okmsp->km_wait); 99125cf1a30Sjl } 99225cf1a30Sjl break; 99325cf1a30Sjl case SCF_MB_DISC_ERROR: 99425cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_event_handler: Event DISC_ERROR\n")); 99525cf1a30Sjl okmsp->km_state &= ~OKM_MB_CONN; 99625cf1a30Sjl okmsp->km_state |= OKM_MB_DISC; 99725cf1a30Sjl cv_broadcast(&okmsp->km_wait); 99825cf1a30Sjl break; 99925cf1a30Sjl default: 100025cf1a30Sjl cmn_err(CE_WARN, "Unexpected event received\n"); 100125cf1a30Sjl } 100225cf1a30Sjl mutex_exit(&okmsp->km_lock); 100325cf1a30Sjl } 100425cf1a30Sjl 100525cf1a30Sjl /* 100625cf1a30Sjl * okm_send_reply - Send a mailbox reply message. 100725cf1a30Sjl */ 100825cf1a30Sjl int 100925cf1a30Sjl okm_send_reply(okms_t *okmsp, uint32_t transid, 101025cf1a30Sjl uint32_t status, uint32_t sadb_err, uint32_t sadb_ver) 101125cf1a30Sjl { 101225cf1a30Sjl okm_rep_hdr_t reply; 101325cf1a30Sjl int ret = EIO; 101425cf1a30Sjl 101525cf1a30Sjl DPRINTF(DBG_DRV, ("okm_send_reply: called\n")); 101625cf1a30Sjl ASSERT(MUTEX_HELD(&okmsp->km_lock)); 101725cf1a30Sjl reply.krp_version = htonl(OKM_PROTOCOL_VERSION); 101825cf1a30Sjl reply.krp_transid = htonl(transid); 101925cf1a30Sjl reply.krp_status = htonl(status); 102025cf1a30Sjl reply.krp_sadb_errno = htonl(sadb_err); 102125cf1a30Sjl reply.krp_sadb_version = htonl(sadb_ver); 102225cf1a30Sjl okmsp->km_sg_tx.msc_dptr = (caddr_t)&reply; 102325cf1a30Sjl okmsp->km_sg_tx.msc_len = sizeof (reply); 102425cf1a30Sjl DUMP_REPLY(&reply); 102525cf1a30Sjl 102625cf1a30Sjl while (OKM_MBOX_READY(okmsp)) { 102725cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_send_reply: sending reply\n")); 102825cf1a30Sjl ret = scf_mb_putmsg(okmsp->km_target, okmsp->km_key, 102925cf1a30Sjl sizeof (reply), 1, &okmsp->km_sg_tx, 0); 103025cf1a30Sjl DPRINTF(DBG_MBOX, ("okm_send_reply: putmsg ret=%d\n", ret)); 103125cf1a30Sjl if (ret == EBUSY || ret == ENOSPC) { 103225cf1a30Sjl /* mailbox is busy, poll/retry */ 103325cf1a30Sjl if (cv_timedwait_sig(&okmsp->km_wait, 103425cf1a30Sjl &okmsp->km_lock, okm_timeout_val(ret)) == 0) { 103525cf1a30Sjl /* interrupted */ 103625cf1a30Sjl ret = EINTR; 103725cf1a30Sjl DPRINTF(DBG_DRV, 103825cf1a30Sjl ("okm_send_reply: interrupted\n")); 103925cf1a30Sjl break; 104025cf1a30Sjl } 104125cf1a30Sjl } else { 104225cf1a30Sjl break; 104325cf1a30Sjl } 104425cf1a30Sjl } 104525cf1a30Sjl DPRINTF(DBG_DRV, ("okm_send_reply: ret=%d\n", ret)); 104625cf1a30Sjl return (ret); 104725cf1a30Sjl } 104825cf1a30Sjl 104925cf1a30Sjl /* 105025cf1a30Sjl * okm_timeout_val -- Return appropriate timeout value. 105125cf1a30Sjl * 105225cf1a30Sjl * A small timeout value is returned for EBUSY as the mailbox busy 105325cf1a30Sjl * condition may go away sooner and we are expected to poll. 105425cf1a30Sjl * 105525cf1a30Sjl * A larger timeout value is returned for ENOSPC case, as the condition 105625cf1a30Sjl * depends on the peer to release buffer space. 105725cf1a30Sjl * NOTE: there will also be an event(SCF_MB_SPACE) but a timeout is 105825cf1a30Sjl * used for reliability purposes. 105925cf1a30Sjl */ 106025cf1a30Sjl static clock_t 106125cf1a30Sjl okm_timeout_val(int error) 106225cf1a30Sjl { 106325cf1a30Sjl clock_t tval; 106425cf1a30Sjl 106525cf1a30Sjl ASSERT(error == EBUSY || error == ENOSPC); 106625cf1a30Sjl 106725cf1a30Sjl if (error == EBUSY) { 106825cf1a30Sjl tval = OKM_SM_TOUT; 106925cf1a30Sjl } else { 107025cf1a30Sjl tval = OKM_LG_TOUT; 107125cf1a30Sjl } 107225cf1a30Sjl return (drv_usectohz(tval)); 107325cf1a30Sjl } 107425cf1a30Sjl 107525cf1a30Sjl #ifdef DEBUG 107625cf1a30Sjl static void 107725cf1a30Sjl okm_print_req(okm_req_hdr_t *reqp, uint32_t len) 107825cf1a30Sjl { 107925cf1a30Sjl uint8_t *datap = (uint8_t *)(((char *)reqp) + sizeof (okm_req_hdr_t)); 108025cf1a30Sjl int msglen = len - sizeof (okm_req_hdr_t); 108125cf1a30Sjl int i, j; 108225cf1a30Sjl #define BYTES_PER_LINE 20 108325cf1a30Sjl char bytestr[BYTES_PER_LINE * 3 + 1]; 108425cf1a30Sjl 108525cf1a30Sjl if (!(okm_debug & DBG_MESG)) 108625cf1a30Sjl return; 108725cf1a30Sjl printf("OKM: Request ver=%d transid=%d cmd=%s\n", 108825cf1a30Sjl reqp->krq_version, reqp->krq_transid, 108925cf1a30Sjl ((reqp->krq_cmd == OKM_MSG_SADB) ? "MSG_SADB" : "UNKNOWN")); 109025cf1a30Sjl for (i = 0; i < msglen; ) { 109125cf1a30Sjl for (j = 0; (j < BYTES_PER_LINE) && (i < msglen); j++, i++) { 109225cf1a30Sjl sprintf(&bytestr[j * 3], "%02X ", datap[i]); 109325cf1a30Sjl } 109425cf1a30Sjl if (j != 0) { 109525cf1a30Sjl printf("\t%s\n", bytestr); 109625cf1a30Sjl } 109725cf1a30Sjl } 109825cf1a30Sjl } 109925cf1a30Sjl 110025cf1a30Sjl static void 110125cf1a30Sjl okm_print_rep(okm_rep_hdr_t *repp) 110225cf1a30Sjl { 110325cf1a30Sjl if (!(okm_debug & DBG_MESG)) 110425cf1a30Sjl return; 110525cf1a30Sjl printf("OKM: Reply Ver=%d Transid=%d Status=%d ", 110625cf1a30Sjl repp->krp_version, repp->krp_transid, repp->krp_status); 110725cf1a30Sjl printf("Sadb_errno=%d Sadb_ver=%d\n", repp->krp_sadb_errno, 110825cf1a30Sjl repp->krp_sadb_version); 110925cf1a30Sjl } 111025cf1a30Sjl #endif 1111