1ef270ab1SKenneth D. Merry /*- 2ef270ab1SKenneth D. Merry * Copyright (c) 2017 Broadcom. All rights reserved. 3ef270ab1SKenneth D. Merry * The term "Broadcom" refers to Broadcom Limited and/or its subsidiaries. 4ef270ab1SKenneth D. Merry * 5ef270ab1SKenneth D. Merry * Redistribution and use in source and binary forms, with or without 6ef270ab1SKenneth D. Merry * modification, are permitted provided that the following conditions are met: 7ef270ab1SKenneth D. Merry * 8ef270ab1SKenneth D. Merry * 1. Redistributions of source code must retain the above copyright notice, 9ef270ab1SKenneth D. Merry * this list of conditions and the following disclaimer. 10ef270ab1SKenneth D. Merry * 11ef270ab1SKenneth D. Merry * 2. Redistributions in binary form must reproduce the above copyright notice, 12ef270ab1SKenneth D. Merry * this list of conditions and the following disclaimer in the documentation 13ef270ab1SKenneth D. Merry * and/or other materials provided with the distribution. 14ef270ab1SKenneth D. Merry * 15ef270ab1SKenneth D. Merry * 3. Neither the name of the copyright holder nor the names of its contributors 16ef270ab1SKenneth D. Merry * may be used to endorse or promote products derived from this software 17ef270ab1SKenneth D. Merry * without specific prior written permission. 18ef270ab1SKenneth D. Merry * 19ef270ab1SKenneth D. Merry * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" 20ef270ab1SKenneth D. Merry * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 21ef270ab1SKenneth D. Merry * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 22ef270ab1SKenneth D. Merry * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE 23ef270ab1SKenneth D. Merry * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 24ef270ab1SKenneth D. Merry * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 25ef270ab1SKenneth D. Merry * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 26ef270ab1SKenneth D. Merry * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 27ef270ab1SKenneth D. Merry * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) 28ef270ab1SKenneth D. Merry * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 29ef270ab1SKenneth D. Merry * POSSIBILITY OF SUCH DAMAGE. 30ef270ab1SKenneth D. Merry * 31ef270ab1SKenneth D. Merry * $FreeBSD$ 32ef270ab1SKenneth D. Merry */ 33ef270ab1SKenneth D. Merry 34ef270ab1SKenneth D. Merry /** 35ef270ab1SKenneth D. Merry * @defgroup scsi_api_target SCSI Target API 36ef270ab1SKenneth D. Merry * @defgroup scsi_api_initiator SCSI Initiator API 37ef270ab1SKenneth D. Merry * @defgroup cam_api Common Access Method (CAM) API 38ef270ab1SKenneth D. Merry * @defgroup cam_io CAM IO 39ef270ab1SKenneth D. Merry */ 40ef270ab1SKenneth D. Merry 41ef270ab1SKenneth D. Merry /** 42ef270ab1SKenneth D. Merry * @file 43ef270ab1SKenneth D. Merry * Provides CAM functionality. 44ef270ab1SKenneth D. Merry */ 45ef270ab1SKenneth D. Merry 46ef270ab1SKenneth D. Merry #include "ocs.h" 47ef270ab1SKenneth D. Merry #include "ocs_scsi.h" 48ef270ab1SKenneth D. Merry #include "ocs_device.h" 49ef270ab1SKenneth D. Merry 50ef270ab1SKenneth D. Merry /* Default IO timeout value for initiators is 30 seconds */ 51ef270ab1SKenneth D. Merry #define OCS_CAM_IO_TIMEOUT 30 52ef270ab1SKenneth D. Merry 53ef270ab1SKenneth D. Merry typedef struct { 54ef270ab1SKenneth D. Merry ocs_scsi_sgl_t *sgl; 55ef270ab1SKenneth D. Merry uint32_t sgl_max; 56ef270ab1SKenneth D. Merry uint32_t sgl_count; 57ef270ab1SKenneth D. Merry int32_t rc; 58ef270ab1SKenneth D. Merry } ocs_dmamap_load_arg_t; 59ef270ab1SKenneth D. Merry 60ef270ab1SKenneth D. Merry static void ocs_action(struct cam_sim *, union ccb *); 61ef270ab1SKenneth D. Merry static void ocs_poll(struct cam_sim *); 62ef270ab1SKenneth D. Merry 63ef270ab1SKenneth D. Merry static ocs_tgt_resource_t *ocs_tgt_resource_get(ocs_fcport *, 64ef270ab1SKenneth D. Merry struct ccb_hdr *, uint32_t *); 65ef270ab1SKenneth D. Merry static int32_t ocs_tgt_resource_abort(struct ocs_softc *, ocs_tgt_resource_t *); 66ef270ab1SKenneth D. Merry static uint32_t ocs_abort_initiator_io(struct ocs_softc *ocs, union ccb *accb); 67ef270ab1SKenneth D. Merry static void ocs_abort_inot(struct ocs_softc *ocs, union ccb *ccb); 68ef270ab1SKenneth D. Merry static void ocs_abort_atio(struct ocs_softc *ocs, union ccb *ccb); 69ef270ab1SKenneth D. Merry static int32_t ocs_target_tmf_cb(ocs_io_t *, ocs_scsi_io_status_e, uint32_t, void *); 70ef270ab1SKenneth D. Merry static int32_t ocs_io_abort_cb(ocs_io_t *, ocs_scsi_io_status_e, uint32_t, void *); 71ef270ab1SKenneth D. Merry static int32_t ocs_task_set_full_or_busy(ocs_io_t *io); 72ef270ab1SKenneth D. Merry static int32_t ocs_initiator_tmf_cb(ocs_io_t *, ocs_scsi_io_status_e, 73ef270ab1SKenneth D. Merry ocs_scsi_cmd_resp_t *, uint32_t, void *); 74ef270ab1SKenneth D. Merry static uint32_t 75ef270ab1SKenneth D. Merry ocs_fcp_change_role(struct ocs_softc *ocs, ocs_fcport *fcp, uint32_t new_role); 76ef270ab1SKenneth D. Merry 776affb8ebSRam Kishore Vegesna static void ocs_ldt(void *arg); 786affb8ebSRam Kishore Vegesna static void ocs_ldt_task(void *arg, int pending); 796affb8ebSRam Kishore Vegesna static void ocs_delete_target(ocs_t *ocs, ocs_fcport *fcp, int tgt); 806affb8ebSRam Kishore Vegesna uint32_t ocs_add_new_tgt(ocs_node_t *node, ocs_fcport *fcp); 816affb8ebSRam Kishore Vegesna uint32_t ocs_update_tgt(ocs_node_t *node, ocs_fcport *fcp, uint32_t tgt_id); 826affb8ebSRam Kishore Vegesna 836affb8ebSRam Kishore Vegesna int32_t ocs_tgt_find(ocs_fcport *fcp, ocs_node_t *node); 846affb8ebSRam Kishore Vegesna 85ef270ab1SKenneth D. Merry static inline ocs_io_t *ocs_scsi_find_io(struct ocs_softc *ocs, uint32_t tag) 86ef270ab1SKenneth D. Merry { 87ef270ab1SKenneth D. Merry 88ef270ab1SKenneth D. Merry return ocs_io_get_instance(ocs, tag); 89ef270ab1SKenneth D. Merry } 90ef270ab1SKenneth D. Merry 91ef270ab1SKenneth D. Merry static inline void ocs_target_io_free(ocs_io_t *io) 92ef270ab1SKenneth D. Merry { 93ef270ab1SKenneth D. Merry io->tgt_io.state = OCS_CAM_IO_FREE; 94ef270ab1SKenneth D. Merry io->tgt_io.flags = 0; 95ef270ab1SKenneth D. Merry io->tgt_io.app = NULL; 96ef270ab1SKenneth D. Merry ocs_scsi_io_complete(io); 97ef270ab1SKenneth D. Merry if(io->ocs->io_in_use != 0) 98ef270ab1SKenneth D. Merry atomic_subtract_acq_32(&io->ocs->io_in_use, 1); 99ef270ab1SKenneth D. Merry } 100ef270ab1SKenneth D. Merry 101ef270ab1SKenneth D. Merry static int32_t 102ef270ab1SKenneth D. Merry ocs_attach_port(ocs_t *ocs, int chan) 103ef270ab1SKenneth D. Merry { 104ef270ab1SKenneth D. Merry 105ef270ab1SKenneth D. Merry struct cam_sim *sim = NULL; 106ef270ab1SKenneth D. Merry struct cam_path *path = NULL; 107ef270ab1SKenneth D. Merry uint32_t max_io = ocs_scsi_get_property(ocs, OCS_SCSI_MAX_IOS); 108ef270ab1SKenneth D. Merry ocs_fcport *fcp = FCPORT(ocs, chan); 109ef270ab1SKenneth D. Merry 110ef270ab1SKenneth D. Merry if (NULL == (sim = cam_sim_alloc(ocs_action, ocs_poll, 111ef270ab1SKenneth D. Merry device_get_name(ocs->dev), ocs, 112ef270ab1SKenneth D. Merry device_get_unit(ocs->dev), &ocs->sim_lock, 113ef270ab1SKenneth D. Merry max_io, max_io, ocs->devq))) { 114ef270ab1SKenneth D. Merry device_printf(ocs->dev, "Can't allocate SIM\n"); 115ef270ab1SKenneth D. Merry return 1; 116ef270ab1SKenneth D. Merry } 117ef270ab1SKenneth D. Merry 118ef270ab1SKenneth D. Merry mtx_lock(&ocs->sim_lock); 119ef270ab1SKenneth D. Merry if (CAM_SUCCESS != xpt_bus_register(sim, ocs->dev, chan)) { 120ef270ab1SKenneth D. Merry device_printf(ocs->dev, "Can't register bus %d\n", 0); 121ef270ab1SKenneth D. Merry mtx_unlock(&ocs->sim_lock); 122ef270ab1SKenneth D. Merry cam_sim_free(sim, FALSE); 123ef270ab1SKenneth D. Merry return 1; 124ef270ab1SKenneth D. Merry } 125ef270ab1SKenneth D. Merry mtx_unlock(&ocs->sim_lock); 126ef270ab1SKenneth D. Merry 127ef270ab1SKenneth D. Merry if (CAM_REQ_CMP != xpt_create_path(&path, NULL, cam_sim_path(sim), 128ef270ab1SKenneth D. Merry CAM_TARGET_WILDCARD, CAM_LUN_WILDCARD)) { 129ef270ab1SKenneth D. Merry device_printf(ocs->dev, "Can't create path\n"); 130ef270ab1SKenneth D. Merry xpt_bus_deregister(cam_sim_path(sim)); 131ef270ab1SKenneth D. Merry mtx_unlock(&ocs->sim_lock); 132ef270ab1SKenneth D. Merry cam_sim_free(sim, FALSE); 133ef270ab1SKenneth D. Merry return 1; 134ef270ab1SKenneth D. Merry } 135ef270ab1SKenneth D. Merry 1366affb8ebSRam Kishore Vegesna fcp->ocs = ocs; 137ef270ab1SKenneth D. Merry fcp->sim = sim; 138ef270ab1SKenneth D. Merry fcp->path = path; 139ef270ab1SKenneth D. Merry 1406affb8ebSRam Kishore Vegesna callout_init_mtx(&fcp->ldt, &ocs->sim_lock, 0); 1416affb8ebSRam Kishore Vegesna TASK_INIT(&fcp->ltask, 1, ocs_ldt_task, fcp); 142ef270ab1SKenneth D. Merry 1436affb8ebSRam Kishore Vegesna return 0; 144ef270ab1SKenneth D. Merry } 145ef270ab1SKenneth D. Merry 146ef270ab1SKenneth D. Merry static int32_t 147ef270ab1SKenneth D. Merry ocs_detach_port(ocs_t *ocs, int32_t chan) 148ef270ab1SKenneth D. Merry { 149ef270ab1SKenneth D. Merry ocs_fcport *fcp = NULL; 150ef270ab1SKenneth D. Merry struct cam_sim *sim = NULL; 151ef270ab1SKenneth D. Merry struct cam_path *path = NULL; 152ef270ab1SKenneth D. Merry fcp = FCPORT(ocs, chan); 153ef270ab1SKenneth D. Merry 154ef270ab1SKenneth D. Merry sim = fcp->sim; 155ef270ab1SKenneth D. Merry path = fcp->path; 156ef270ab1SKenneth D. Merry 1576affb8ebSRam Kishore Vegesna callout_drain(&fcp->ldt); 1586affb8ebSRam Kishore Vegesna ocs_ldt_task(fcp, 0); 1596affb8ebSRam Kishore Vegesna 160ef270ab1SKenneth D. Merry if (fcp->sim) { 161ef270ab1SKenneth D. Merry mtx_lock(&ocs->sim_lock); 162ef270ab1SKenneth D. Merry ocs_tgt_resource_abort(ocs, &fcp->targ_rsrc_wildcard); 163ef270ab1SKenneth D. Merry if (path) { 164ef270ab1SKenneth D. Merry xpt_async(AC_LOST_DEVICE, path, NULL); 165ef270ab1SKenneth D. Merry xpt_free_path(path); 166ef270ab1SKenneth D. Merry fcp->path = NULL; 167ef270ab1SKenneth D. Merry } 168ef270ab1SKenneth D. Merry xpt_bus_deregister(cam_sim_path(sim)); 169ef270ab1SKenneth D. Merry 170ef270ab1SKenneth D. Merry cam_sim_free(sim, FALSE); 171ef270ab1SKenneth D. Merry fcp->sim = NULL; 172ef270ab1SKenneth D. Merry mtx_unlock(&ocs->sim_lock); 173ef270ab1SKenneth D. Merry } 174ef270ab1SKenneth D. Merry 175ef270ab1SKenneth D. Merry return 0; 176ef270ab1SKenneth D. Merry } 177ef270ab1SKenneth D. Merry 178ef270ab1SKenneth D. Merry int32_t 179ef270ab1SKenneth D. Merry ocs_cam_attach(ocs_t *ocs) 180ef270ab1SKenneth D. Merry { 181ef270ab1SKenneth D. Merry struct cam_devq *devq = NULL; 182ef270ab1SKenneth D. Merry int i = 0; 183ef270ab1SKenneth D. Merry uint32_t max_io = ocs_scsi_get_property(ocs, OCS_SCSI_MAX_IOS); 184ef270ab1SKenneth D. Merry 185ef270ab1SKenneth D. Merry if (NULL == (devq = cam_simq_alloc(max_io))) { 186ef270ab1SKenneth D. Merry device_printf(ocs->dev, "Can't allocate SIMQ\n"); 187ef270ab1SKenneth D. Merry return -1; 188ef270ab1SKenneth D. Merry } 189ef270ab1SKenneth D. Merry 190ef270ab1SKenneth D. Merry ocs->devq = devq; 191ef270ab1SKenneth D. Merry 192ef270ab1SKenneth D. Merry if (mtx_initialized(&ocs->sim_lock) == 0) { 193ef270ab1SKenneth D. Merry mtx_init(&ocs->sim_lock, "ocs_sim_lock", NULL, MTX_DEF); 194ef270ab1SKenneth D. Merry } 195ef270ab1SKenneth D. Merry 196ef270ab1SKenneth D. Merry for (i = 0; i < (ocs->num_vports + 1); i++) { 197ef270ab1SKenneth D. Merry if (ocs_attach_port(ocs, i)) { 198ef270ab1SKenneth D. Merry ocs_log_err(ocs, "Attach port failed for chan: %d\n", i); 199ef270ab1SKenneth D. Merry goto detach_port; 200ef270ab1SKenneth D. Merry } 201ef270ab1SKenneth D. Merry } 202ef270ab1SKenneth D. Merry 203ef270ab1SKenneth D. Merry ocs->io_high_watermark = max_io; 204ef270ab1SKenneth D. Merry ocs->io_in_use = 0; 205ef270ab1SKenneth D. Merry return 0; 206ef270ab1SKenneth D. Merry 207ef270ab1SKenneth D. Merry detach_port: 208ef270ab1SKenneth D. Merry while (--i >= 0) { 209ef270ab1SKenneth D. Merry ocs_detach_port(ocs, i); 210ef270ab1SKenneth D. Merry } 211ef270ab1SKenneth D. Merry 212ef270ab1SKenneth D. Merry cam_simq_free(ocs->devq); 213ef270ab1SKenneth D. Merry 214ef270ab1SKenneth D. Merry if (mtx_initialized(&ocs->sim_lock)) 215ef270ab1SKenneth D. Merry mtx_destroy(&ocs->sim_lock); 216ef270ab1SKenneth D. Merry 217ef270ab1SKenneth D. Merry return 1; 218ef270ab1SKenneth D. Merry } 219ef270ab1SKenneth D. Merry 220ef270ab1SKenneth D. Merry int32_t 221ef270ab1SKenneth D. Merry ocs_cam_detach(ocs_t *ocs) 222ef270ab1SKenneth D. Merry { 223ef270ab1SKenneth D. Merry int i = 0; 224ef270ab1SKenneth D. Merry 225ef270ab1SKenneth D. Merry for (i = (ocs->num_vports); i >= 0; i--) { 226ef270ab1SKenneth D. Merry ocs_detach_port(ocs, i); 227ef270ab1SKenneth D. Merry } 228ef270ab1SKenneth D. Merry 229ef270ab1SKenneth D. Merry cam_simq_free(ocs->devq); 230ef270ab1SKenneth D. Merry 231ef270ab1SKenneth D. Merry if (mtx_initialized(&ocs->sim_lock)) 232ef270ab1SKenneth D. Merry mtx_destroy(&ocs->sim_lock); 233ef270ab1SKenneth D. Merry 234ef270ab1SKenneth D. Merry return 0; 235ef270ab1SKenneth D. Merry } 236ef270ab1SKenneth D. Merry 237ef270ab1SKenneth D. Merry /*************************************************************************** 238ef270ab1SKenneth D. Merry * Functions required by SCSI base driver API 239ef270ab1SKenneth D. Merry */ 240ef270ab1SKenneth D. Merry 241ef270ab1SKenneth D. Merry /** 242ef270ab1SKenneth D. Merry * @ingroup scsi_api_target 243ef270ab1SKenneth D. Merry * @brief Attach driver to the BSD SCSI layer (a.k.a CAM) 244ef270ab1SKenneth D. Merry * 245ef270ab1SKenneth D. Merry * Allocates + initializes CAM related resources and attaches to the CAM 246ef270ab1SKenneth D. Merry * 247ef270ab1SKenneth D. Merry * @param ocs the driver instance's software context 248ef270ab1SKenneth D. Merry * 249ef270ab1SKenneth D. Merry * @return 0 on success, non-zero otherwise 250ef270ab1SKenneth D. Merry */ 251ef270ab1SKenneth D. Merry int32_t 252ef270ab1SKenneth D. Merry ocs_scsi_tgt_new_device(ocs_t *ocs) 253ef270ab1SKenneth D. Merry { 254ef270ab1SKenneth D. Merry ocs->enable_task_set_full = ocs_scsi_get_property(ocs, 255ef270ab1SKenneth D. Merry OCS_SCSI_ENABLE_TASK_SET_FULL); 256ef270ab1SKenneth D. Merry ocs_log_debug(ocs, "task set full processing is %s\n", 257ef270ab1SKenneth D. Merry ocs->enable_task_set_full ? "enabled" : "disabled"); 258ef270ab1SKenneth D. Merry 259ef270ab1SKenneth D. Merry return 0; 260ef270ab1SKenneth D. Merry } 261ef270ab1SKenneth D. Merry 262ef270ab1SKenneth D. Merry /** 263ef270ab1SKenneth D. Merry * @ingroup scsi_api_target 264ef270ab1SKenneth D. Merry * @brief Tears down target members of ocs structure. 265ef270ab1SKenneth D. Merry * 266ef270ab1SKenneth D. Merry * Called by OS code when device is removed. 267ef270ab1SKenneth D. Merry * 268ef270ab1SKenneth D. Merry * @param ocs pointer to ocs 269ef270ab1SKenneth D. Merry * 270ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 271ef270ab1SKenneth D. Merry */ 272ef270ab1SKenneth D. Merry int32_t 273ef270ab1SKenneth D. Merry ocs_scsi_tgt_del_device(ocs_t *ocs) 274ef270ab1SKenneth D. Merry { 275ef270ab1SKenneth D. Merry 276ef270ab1SKenneth D. Merry return 0; 277ef270ab1SKenneth D. Merry } 278ef270ab1SKenneth D. Merry 279ef270ab1SKenneth D. Merry /** 280ef270ab1SKenneth D. Merry * @ingroup scsi_api_target 281ef270ab1SKenneth D. Merry * @brief accept new domain notification 282ef270ab1SKenneth D. Merry * 283ef270ab1SKenneth D. Merry * Called by base drive when new domain is discovered. A target-server 284ef270ab1SKenneth D. Merry * will use this call to prepare for new remote node notifications 285ef270ab1SKenneth D. Merry * arising from ocs_scsi_new_initiator(). 286ef270ab1SKenneth D. Merry * 287ef270ab1SKenneth D. Merry * The domain context has an element <b>ocs_scsi_tgt_domain_t tgt_domain</b> 288ef270ab1SKenneth D. Merry * which is declared by the target-server code and is used for target-server 289ef270ab1SKenneth D. Merry * private data. 290ef270ab1SKenneth D. Merry * 291ef270ab1SKenneth D. Merry * This function will only be called if the base-driver has been enabled for 292ef270ab1SKenneth D. Merry * target capability. 293ef270ab1SKenneth D. Merry * 294ef270ab1SKenneth D. Merry * Note that this call is made to target-server backends, 295ef270ab1SKenneth D. Merry * the ocs_scsi_ini_new_domain() function is called to initiator-client backends. 296ef270ab1SKenneth D. Merry * 297ef270ab1SKenneth D. Merry * @param domain pointer to domain 298ef270ab1SKenneth D. Merry * 299ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 300ef270ab1SKenneth D. Merry */ 301ef270ab1SKenneth D. Merry int32_t 302ef270ab1SKenneth D. Merry ocs_scsi_tgt_new_domain(ocs_domain_t *domain) 303ef270ab1SKenneth D. Merry { 304ef270ab1SKenneth D. Merry return 0; 305ef270ab1SKenneth D. Merry } 306ef270ab1SKenneth D. Merry 307ef270ab1SKenneth D. Merry /** 308ef270ab1SKenneth D. Merry * @ingroup scsi_api_target 309ef270ab1SKenneth D. Merry * @brief accept domain lost notification 310ef270ab1SKenneth D. Merry * 311ef270ab1SKenneth D. Merry * Called by base-driver when a domain goes away. A target-server will 312ef270ab1SKenneth D. Merry * use this call to clean up all domain scoped resources. 313ef270ab1SKenneth D. Merry * 314ef270ab1SKenneth D. Merry * Note that this call is made to target-server backends, 315ef270ab1SKenneth D. Merry * the ocs_scsi_ini_del_domain() function is called to initiator-client backends. 316ef270ab1SKenneth D. Merry * 317ef270ab1SKenneth D. Merry * @param domain pointer to domain 318ef270ab1SKenneth D. Merry * 319ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 320ef270ab1SKenneth D. Merry */ 321ef270ab1SKenneth D. Merry void 322ef270ab1SKenneth D. Merry ocs_scsi_tgt_del_domain(ocs_domain_t *domain) 323ef270ab1SKenneth D. Merry { 324ef270ab1SKenneth D. Merry } 325ef270ab1SKenneth D. Merry 326ef270ab1SKenneth D. Merry /** 327ef270ab1SKenneth D. Merry * @ingroup scsi_api_target 328ef270ab1SKenneth D. Merry * @brief accept new sli port (sport) notification 329ef270ab1SKenneth D. Merry * 330ef270ab1SKenneth D. Merry * Called by base drive when new sport is discovered. A target-server 331ef270ab1SKenneth D. Merry * will use this call to prepare for new remote node notifications 332ef270ab1SKenneth D. Merry * arising from ocs_scsi_new_initiator(). 333ef270ab1SKenneth D. Merry * 334ef270ab1SKenneth D. Merry * The domain context has an element <b>ocs_scsi_tgt_sport_t tgt_sport</b> 335ef270ab1SKenneth D. Merry * which is declared by the target-server code and is used for 336ef270ab1SKenneth D. Merry * target-server private data. 337ef270ab1SKenneth D. Merry * 338ef270ab1SKenneth D. Merry * This function will only be called if the base-driver has been enabled for 339ef270ab1SKenneth D. Merry * target capability. 340ef270ab1SKenneth D. Merry * 341ef270ab1SKenneth D. Merry * Note that this call is made to target-server backends, 342ef270ab1SKenneth D. Merry * the ocs_scsi_tgt_new_domain() is called to initiator-client backends. 343ef270ab1SKenneth D. Merry * 344ef270ab1SKenneth D. Merry * @param sport pointer to SLI port 345ef270ab1SKenneth D. Merry * 346ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 347ef270ab1SKenneth D. Merry */ 348ef270ab1SKenneth D. Merry int32_t 349ef270ab1SKenneth D. Merry ocs_scsi_tgt_new_sport(ocs_sport_t *sport) 350ef270ab1SKenneth D. Merry { 351ef270ab1SKenneth D. Merry ocs_t *ocs = sport->ocs; 352ef270ab1SKenneth D. Merry 353ef270ab1SKenneth D. Merry if(!sport->is_vport) { 354ef270ab1SKenneth D. Merry sport->tgt_data = FCPORT(ocs, 0); 355ef270ab1SKenneth D. Merry } 356ef270ab1SKenneth D. Merry 357ef270ab1SKenneth D. Merry return 0; 358ef270ab1SKenneth D. Merry } 359ef270ab1SKenneth D. Merry 360ef270ab1SKenneth D. Merry /** 361ef270ab1SKenneth D. Merry * @ingroup scsi_api_target 362ef270ab1SKenneth D. Merry * @brief accept SLI port gone notification 363ef270ab1SKenneth D. Merry * 364ef270ab1SKenneth D. Merry * Called by base-driver when a sport goes away. A target-server will 365ef270ab1SKenneth D. Merry * use this call to clean up all sport scoped resources. 366ef270ab1SKenneth D. Merry * 367ef270ab1SKenneth D. Merry * Note that this call is made to target-server backends, 368ef270ab1SKenneth D. Merry * the ocs_scsi_ini_del_sport() is called to initiator-client backends. 369ef270ab1SKenneth D. Merry * 370ef270ab1SKenneth D. Merry * @param sport pointer to SLI port 371ef270ab1SKenneth D. Merry * 372ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 373ef270ab1SKenneth D. Merry */ 374ef270ab1SKenneth D. Merry void 375ef270ab1SKenneth D. Merry ocs_scsi_tgt_del_sport(ocs_sport_t *sport) 376ef270ab1SKenneth D. Merry { 377ef270ab1SKenneth D. Merry return; 378ef270ab1SKenneth D. Merry } 379ef270ab1SKenneth D. Merry 380ef270ab1SKenneth D. Merry /** 381ef270ab1SKenneth D. Merry * @ingroup scsi_api_target 382ef270ab1SKenneth D. Merry * @brief receive notification of a new SCSI initiator node 383ef270ab1SKenneth D. Merry * 384ef270ab1SKenneth D. Merry * Sent by base driver to notify a target-server of the presense of a new 385ef270ab1SKenneth D. Merry * remote initiator. The target-server may use this call to prepare for 386ef270ab1SKenneth D. Merry * inbound IO from this node. 387ef270ab1SKenneth D. Merry * 388ef270ab1SKenneth D. Merry * The ocs_node_t structure has and elment of type ocs_scsi_tgt_node_t named 389ef270ab1SKenneth D. Merry * tgt_node that is declared and used by a target-server for private 390ef270ab1SKenneth D. Merry * information. 391ef270ab1SKenneth D. Merry * 392ef270ab1SKenneth D. Merry * This function is only called if the target capability is enabled in driver. 393ef270ab1SKenneth D. Merry * 394ef270ab1SKenneth D. Merry * @param node pointer to new remote initiator node 395ef270ab1SKenneth D. Merry * 396ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 397ef270ab1SKenneth D. Merry * 398ef270ab1SKenneth D. Merry * @note 399ef270ab1SKenneth D. Merry */ 400ef270ab1SKenneth D. Merry int32_t 401ef270ab1SKenneth D. Merry ocs_scsi_new_initiator(ocs_node_t *node) 402ef270ab1SKenneth D. Merry { 403ef270ab1SKenneth D. Merry ocs_t *ocs = node->ocs; 404ef270ab1SKenneth D. Merry struct ac_contract ac; 405ef270ab1SKenneth D. Merry struct ac_device_changed *adc; 406ef270ab1SKenneth D. Merry 407ef270ab1SKenneth D. Merry ocs_fcport *fcp = NULL; 408ef270ab1SKenneth D. Merry 409ef270ab1SKenneth D. Merry fcp = node->sport->tgt_data; 410ef270ab1SKenneth D. Merry if (fcp == NULL) { 411ef270ab1SKenneth D. Merry ocs_log_err(ocs, "FCP is NULL \n"); 412ef270ab1SKenneth D. Merry return 1; 413ef270ab1SKenneth D. Merry } 414ef270ab1SKenneth D. Merry 415ef270ab1SKenneth D. Merry /* 416ef270ab1SKenneth D. Merry * Update the IO watermark by decrementing it by the 417ef270ab1SKenneth D. Merry * number of IOs reserved for each initiator. 418ef270ab1SKenneth D. Merry */ 419ef270ab1SKenneth D. Merry atomic_subtract_acq_32(&ocs->io_high_watermark, OCS_RSVD_INI_IO); 420ef270ab1SKenneth D. Merry 421ef270ab1SKenneth D. Merry ac.contract_number = AC_CONTRACT_DEV_CHG; 422ef270ab1SKenneth D. Merry adc = (struct ac_device_changed *) ac.contract_data; 423ef270ab1SKenneth D. Merry adc->wwpn = ocs_node_get_wwpn(node); 424ef270ab1SKenneth D. Merry adc->port = node->rnode.fc_id; 425ef270ab1SKenneth D. Merry adc->target = node->instance_index; 426ef270ab1SKenneth D. Merry adc->arrived = 1; 427ef270ab1SKenneth D. Merry xpt_async(AC_CONTRACT, fcp->path, &ac); 428ef270ab1SKenneth D. Merry 429ef270ab1SKenneth D. Merry return 0; 430ef270ab1SKenneth D. Merry } 431ef270ab1SKenneth D. Merry 432ef270ab1SKenneth D. Merry /** 433ef270ab1SKenneth D. Merry * @ingroup scsi_api_target 434ef270ab1SKenneth D. Merry * @brief validate new initiator 435ef270ab1SKenneth D. Merry * 436ef270ab1SKenneth D. Merry * Sent by base driver to validate a remote initiatiator. The target-server 437ef270ab1SKenneth D. Merry * returns TRUE if this initiator should be accepted. 438ef270ab1SKenneth D. Merry * 439ef270ab1SKenneth D. Merry * This function is only called if the target capability is enabled in driver. 440ef270ab1SKenneth D. Merry * 441ef270ab1SKenneth D. Merry * @param node pointer to remote initiator node to validate 442ef270ab1SKenneth D. Merry * 443ef270ab1SKenneth D. Merry * @return TRUE if initiator should be accepted, FALSE if it should be rejected 444ef270ab1SKenneth D. Merry * 445ef270ab1SKenneth D. Merry * @note 446ef270ab1SKenneth D. Merry */ 447ef270ab1SKenneth D. Merry 448ef270ab1SKenneth D. Merry int32_t 449ef270ab1SKenneth D. Merry ocs_scsi_validate_initiator(ocs_node_t *node) 450ef270ab1SKenneth D. Merry { 451ef270ab1SKenneth D. Merry return 1; 452ef270ab1SKenneth D. Merry } 453ef270ab1SKenneth D. Merry 454ef270ab1SKenneth D. Merry /** 455ef270ab1SKenneth D. Merry * @ingroup scsi_api_target 456ef270ab1SKenneth D. Merry * @brief Delete a SCSI initiator node 457ef270ab1SKenneth D. Merry * 458ef270ab1SKenneth D. Merry * Sent by base driver to notify a target-server that a remote initiator 459ef270ab1SKenneth D. Merry * is now gone. The base driver will have terminated all outstanding IOs 460ef270ab1SKenneth D. Merry * and the target-server will receive appropriate completions. 461ef270ab1SKenneth D. Merry * 462ef270ab1SKenneth D. Merry * This function is only called if the base driver is enabled for 463ef270ab1SKenneth D. Merry * target capability. 464ef270ab1SKenneth D. Merry * 465ef270ab1SKenneth D. Merry * @param node pointer node being deleted 466ef270ab1SKenneth D. Merry * @param reason Reason why initiator is gone. 467ef270ab1SKenneth D. Merry * 468ef270ab1SKenneth D. Merry * @return OCS_SCSI_CALL_COMPLETE to indicate that all work was completed 469ef270ab1SKenneth D. Merry * 470ef270ab1SKenneth D. Merry * @note 471ef270ab1SKenneth D. Merry */ 472ef270ab1SKenneth D. Merry int32_t 473ef270ab1SKenneth D. Merry ocs_scsi_del_initiator(ocs_node_t *node, ocs_scsi_del_initiator_reason_e reason) 474ef270ab1SKenneth D. Merry { 475ef270ab1SKenneth D. Merry ocs_t *ocs = node->ocs; 476ef270ab1SKenneth D. Merry 477ef270ab1SKenneth D. Merry struct ac_contract ac; 478ef270ab1SKenneth D. Merry struct ac_device_changed *adc; 479ef270ab1SKenneth D. Merry ocs_fcport *fcp = NULL; 480ef270ab1SKenneth D. Merry 481ef270ab1SKenneth D. Merry fcp = node->sport->tgt_data; 482ef270ab1SKenneth D. Merry if (fcp == NULL) { 483ef270ab1SKenneth D. Merry ocs_log_err(ocs, "FCP is NULL \n"); 484ef270ab1SKenneth D. Merry return 1; 485ef270ab1SKenneth D. Merry } 486ef270ab1SKenneth D. Merry 487ef270ab1SKenneth D. Merry ac.contract_number = AC_CONTRACT_DEV_CHG; 488ef270ab1SKenneth D. Merry adc = (struct ac_device_changed *) ac.contract_data; 489ef270ab1SKenneth D. Merry adc->wwpn = ocs_node_get_wwpn(node); 490ef270ab1SKenneth D. Merry adc->port = node->rnode.fc_id; 491ef270ab1SKenneth D. Merry adc->target = node->instance_index; 492ef270ab1SKenneth D. Merry adc->arrived = 0; 493ef270ab1SKenneth D. Merry xpt_async(AC_CONTRACT, fcp->path, &ac); 494ef270ab1SKenneth D. Merry 495ef270ab1SKenneth D. Merry if (reason == OCS_SCSI_INITIATOR_MISSING) { 496ef270ab1SKenneth D. Merry return OCS_SCSI_CALL_COMPLETE; 497ef270ab1SKenneth D. Merry } 498ef270ab1SKenneth D. Merry 499ef270ab1SKenneth D. Merry /* 500ef270ab1SKenneth D. Merry * Update the IO watermark by incrementing it by the 501ef270ab1SKenneth D. Merry * number of IOs reserved for each initiator. 502ef270ab1SKenneth D. Merry */ 503ef270ab1SKenneth D. Merry atomic_add_acq_32(&ocs->io_high_watermark, OCS_RSVD_INI_IO); 504ef270ab1SKenneth D. Merry 505ef270ab1SKenneth D. Merry return OCS_SCSI_CALL_COMPLETE; 506ef270ab1SKenneth D. Merry } 507ef270ab1SKenneth D. Merry 508ef270ab1SKenneth D. Merry /** 509ef270ab1SKenneth D. Merry * @ingroup scsi_api_target 510ef270ab1SKenneth D. Merry * @brief receive FCP SCSI Command 511ef270ab1SKenneth D. Merry * 512ef270ab1SKenneth D. Merry * Called by the base driver when a new SCSI command has been received. The 513ef270ab1SKenneth D. Merry * target-server will process the command, and issue data and/or response phase 514ef270ab1SKenneth D. Merry * requests to the base driver. 515ef270ab1SKenneth D. Merry * 516ef270ab1SKenneth D. Merry * The IO context (ocs_io_t) structure has and element of type 517ef270ab1SKenneth D. Merry * ocs_scsi_tgt_io_t named tgt_io that is declared and used by 518ef270ab1SKenneth D. Merry * a target-server for private information. 519ef270ab1SKenneth D. Merry * 520ef270ab1SKenneth D. Merry * @param io pointer to IO context 521ef270ab1SKenneth D. Merry * @param lun LUN for this IO 522ef270ab1SKenneth D. Merry * @param cdb pointer to SCSI CDB 523ef270ab1SKenneth D. Merry * @param cdb_len length of CDB in bytes 524ef270ab1SKenneth D. Merry * @param flags command flags 525ef270ab1SKenneth D. Merry * 526ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 527ef270ab1SKenneth D. Merry */ 528ef270ab1SKenneth D. Merry int32_t ocs_scsi_recv_cmd(ocs_io_t *io, uint64_t lun, uint8_t *cdb, 529ef270ab1SKenneth D. Merry uint32_t cdb_len, uint32_t flags) 530ef270ab1SKenneth D. Merry { 531ef270ab1SKenneth D. Merry ocs_t *ocs = io->ocs; 532ef270ab1SKenneth D. Merry struct ccb_accept_tio *atio = NULL; 533ef270ab1SKenneth D. Merry ocs_node_t *node = io->node; 534ef270ab1SKenneth D. Merry ocs_tgt_resource_t *trsrc = NULL; 535ef270ab1SKenneth D. Merry int32_t rc = -1; 536ef270ab1SKenneth D. Merry ocs_fcport *fcp = NULL; 537ef270ab1SKenneth D. Merry 538ef270ab1SKenneth D. Merry fcp = node->sport->tgt_data; 539ef270ab1SKenneth D. Merry if (fcp == NULL) { 540ef270ab1SKenneth D. Merry ocs_log_err(ocs, "FCP is NULL \n"); 541ef270ab1SKenneth D. Merry return 1; 542ef270ab1SKenneth D. Merry } 543ef270ab1SKenneth D. Merry 544ef270ab1SKenneth D. Merry atomic_add_acq_32(&ocs->io_in_use, 1); 545ef270ab1SKenneth D. Merry 546ef270ab1SKenneth D. Merry /* set target io timeout */ 547ef270ab1SKenneth D. Merry io->timeout = ocs->target_io_timer_sec; 548ef270ab1SKenneth D. Merry 549ef270ab1SKenneth D. Merry if (ocs->enable_task_set_full && 550ef270ab1SKenneth D. Merry (ocs->io_in_use >= ocs->io_high_watermark)) { 551ef270ab1SKenneth D. Merry return ocs_task_set_full_or_busy(io); 552ef270ab1SKenneth D. Merry } else { 553ef270ab1SKenneth D. Merry atomic_store_rel_32(&io->node->tgt_node.busy_sent, FALSE); 554ef270ab1SKenneth D. Merry } 555ef270ab1SKenneth D. Merry 556ef270ab1SKenneth D. Merry if ((lun < OCS_MAX_LUN) && fcp->targ_rsrc[lun].enabled) { 557ef270ab1SKenneth D. Merry trsrc = &fcp->targ_rsrc[lun]; 558ef270ab1SKenneth D. Merry } else if (fcp->targ_rsrc_wildcard.enabled) { 559ef270ab1SKenneth D. Merry trsrc = &fcp->targ_rsrc_wildcard; 560ef270ab1SKenneth D. Merry } 561ef270ab1SKenneth D. Merry 562ef270ab1SKenneth D. Merry if (trsrc) { 563ef270ab1SKenneth D. Merry atio = (struct ccb_accept_tio *)STAILQ_FIRST(&trsrc->atio); 564ef270ab1SKenneth D. Merry } 565ef270ab1SKenneth D. Merry 566ef270ab1SKenneth D. Merry if (atio) { 567ef270ab1SKenneth D. Merry STAILQ_REMOVE_HEAD(&trsrc->atio, sim_links.stqe); 568ef270ab1SKenneth D. Merry 569ef270ab1SKenneth D. Merry atio->ccb_h.status = CAM_CDB_RECVD; 570ef270ab1SKenneth D. Merry atio->ccb_h.target_lun = lun; 571ef270ab1SKenneth D. Merry atio->sense_len = 0; 572ef270ab1SKenneth D. Merry 573ef270ab1SKenneth D. Merry atio->init_id = node->instance_index; 574ef270ab1SKenneth D. Merry atio->tag_id = io->tag; 575ef270ab1SKenneth D. Merry atio->ccb_h.ccb_io_ptr = io; 576ef270ab1SKenneth D. Merry 577ef270ab1SKenneth D. Merry if (flags & OCS_SCSI_CMD_SIMPLE) 578ef270ab1SKenneth D. Merry atio->tag_action = MSG_SIMPLE_Q_TAG; 579eb5a54f8SAlexander Motin else if (flags & OCS_SCSI_CMD_HEAD_OF_QUEUE) 580ef270ab1SKenneth D. Merry atio->tag_action = MSG_HEAD_OF_Q_TAG; 581eb5a54f8SAlexander Motin else if (flags & OCS_SCSI_CMD_ORDERED) 582ef270ab1SKenneth D. Merry atio->tag_action = MSG_ORDERED_Q_TAG; 58388364968SAlexander Motin else if (flags & OCS_SCSI_CMD_ACA) 58488364968SAlexander Motin atio->tag_action = MSG_ACA_TASK; 585ef270ab1SKenneth D. Merry else 58688364968SAlexander Motin atio->tag_action = CAM_TAG_ACTION_NONE; 58788364968SAlexander Motin atio->priority = (flags & OCS_SCSI_PRIORITY_MASK) >> 58888364968SAlexander Motin OCS_SCSI_PRIORITY_SHIFT; 589ef270ab1SKenneth D. Merry 590ef270ab1SKenneth D. Merry atio->cdb_len = cdb_len; 591ef270ab1SKenneth D. Merry ocs_memcpy(atio->cdb_io.cdb_bytes, cdb, cdb_len); 592ef270ab1SKenneth D. Merry 593ef270ab1SKenneth D. Merry io->tgt_io.flags = 0; 594ef270ab1SKenneth D. Merry io->tgt_io.state = OCS_CAM_IO_COMMAND; 595ef270ab1SKenneth D. Merry io->tgt_io.lun = lun; 596ef270ab1SKenneth D. Merry 597ef270ab1SKenneth D. Merry xpt_done((union ccb *)atio); 598ef270ab1SKenneth D. Merry 599ef270ab1SKenneth D. Merry rc = 0; 600ef270ab1SKenneth D. Merry } else { 601ef270ab1SKenneth D. Merry device_printf( 602ef270ab1SKenneth D. Merry ocs->dev, "%s: no ATIO for LUN %lx (en=%s) OX_ID %#x\n", 603ef270ab1SKenneth D. Merry __func__, (unsigned long)lun, 604ef270ab1SKenneth D. Merry trsrc ? (trsrc->enabled ? "T" : "F") : "X", 605ef270ab1SKenneth D. Merry be16toh(io->init_task_tag)); 606ef270ab1SKenneth D. Merry 607ef270ab1SKenneth D. Merry io->tgt_io.state = OCS_CAM_IO_MAX; 608ef270ab1SKenneth D. Merry ocs_target_io_free(io); 609ef270ab1SKenneth D. Merry } 610ef270ab1SKenneth D. Merry 611ef270ab1SKenneth D. Merry return rc; 612ef270ab1SKenneth D. Merry } 613ef270ab1SKenneth D. Merry 614ef270ab1SKenneth D. Merry /** 615ef270ab1SKenneth D. Merry * @ingroup scsi_api_target 616ef270ab1SKenneth D. Merry * @brief receive FCP SCSI Command with first burst data. 617ef270ab1SKenneth D. Merry * 618ef270ab1SKenneth D. Merry * Receive a new FCP SCSI command from the base driver with first burst data. 619ef270ab1SKenneth D. Merry * 620ef270ab1SKenneth D. Merry * @param io pointer to IO context 621ef270ab1SKenneth D. Merry * @param lun LUN for this IO 622ef270ab1SKenneth D. Merry * @param cdb pointer to SCSI CDB 623ef270ab1SKenneth D. Merry * @param cdb_len length of CDB in bytes 624ef270ab1SKenneth D. Merry * @param flags command flags 625ef270ab1SKenneth D. Merry * @param first_burst_buffers first burst buffers 626ef270ab1SKenneth D. Merry * @param first_burst_buffer_count The number of bytes received in the first burst 627ef270ab1SKenneth D. Merry * 628ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 629ef270ab1SKenneth D. Merry */ 630ef270ab1SKenneth D. Merry int32_t ocs_scsi_recv_cmd_first_burst(ocs_io_t *io, uint64_t lun, uint8_t *cdb, 631ef270ab1SKenneth D. Merry uint32_t cdb_len, uint32_t flags, 632ef270ab1SKenneth D. Merry ocs_dma_t first_burst_buffers[], 633ef270ab1SKenneth D. Merry uint32_t first_burst_buffer_count) 634ef270ab1SKenneth D. Merry { 635ef270ab1SKenneth D. Merry return -1; 636ef270ab1SKenneth D. Merry } 637ef270ab1SKenneth D. Merry 638ef270ab1SKenneth D. Merry /** 639ef270ab1SKenneth D. Merry * @ingroup scsi_api_target 640ef270ab1SKenneth D. Merry * @brief receive a TMF command IO 641ef270ab1SKenneth D. Merry * 642ef270ab1SKenneth D. Merry * Called by the base driver when a SCSI TMF command has been received. The 643ef270ab1SKenneth D. Merry * target-server will process the command, aborting commands as needed, and post 644ef270ab1SKenneth D. Merry * a response using ocs_scsi_send_resp() 645ef270ab1SKenneth D. Merry * 646ef270ab1SKenneth D. Merry * The IO context (ocs_io_t) structure has and element of type ocs_scsi_tgt_io_t named 647ef270ab1SKenneth D. Merry * tgt_io that is declared and used by a target-server for private information. 648ef270ab1SKenneth D. Merry * 649ef270ab1SKenneth D. Merry * If the target-server walks the nodes active_ios linked list, and starts IO 650ef270ab1SKenneth D. Merry * abort processing, the code <b>must</b> be sure not to abort the IO passed into the 651ef270ab1SKenneth D. Merry * ocs_scsi_recv_tmf() command. 652ef270ab1SKenneth D. Merry * 653ef270ab1SKenneth D. Merry * @param tmfio pointer to IO context 654ef270ab1SKenneth D. Merry * @param lun logical unit value 655ef270ab1SKenneth D. Merry * @param cmd command request 656ef270ab1SKenneth D. Merry * @param abortio pointer to IO object to abort for TASK_ABORT (NULL for all other TMF) 657ef270ab1SKenneth D. Merry * @param flags flags 658ef270ab1SKenneth D. Merry * 659ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 660ef270ab1SKenneth D. Merry */ 661ef270ab1SKenneth D. Merry int32_t ocs_scsi_recv_tmf(ocs_io_t *tmfio, uint64_t lun, ocs_scsi_tmf_cmd_e cmd, 662ef270ab1SKenneth D. Merry ocs_io_t *abortio, uint32_t flags) 663ef270ab1SKenneth D. Merry { 664ef270ab1SKenneth D. Merry ocs_t *ocs = tmfio->ocs; 665ef270ab1SKenneth D. Merry ocs_node_t *node = tmfio->node; 666ef270ab1SKenneth D. Merry ocs_tgt_resource_t *trsrc = NULL; 667ef270ab1SKenneth D. Merry struct ccb_immediate_notify *inot = NULL; 668ef270ab1SKenneth D. Merry int32_t rc = -1; 669ef270ab1SKenneth D. Merry ocs_fcport *fcp = NULL; 670ef270ab1SKenneth D. Merry 671ef270ab1SKenneth D. Merry fcp = node->sport->tgt_data; 672ef270ab1SKenneth D. Merry if (fcp == NULL) { 673ef270ab1SKenneth D. Merry ocs_log_err(ocs, "FCP is NULL \n"); 674ef270ab1SKenneth D. Merry return 1; 675ef270ab1SKenneth D. Merry } 676ef270ab1SKenneth D. Merry 677ef270ab1SKenneth D. Merry if ((lun < OCS_MAX_LUN) && fcp->targ_rsrc[lun].enabled) { 678ef270ab1SKenneth D. Merry trsrc = &fcp->targ_rsrc[lun]; 679ef270ab1SKenneth D. Merry } else if (fcp->targ_rsrc_wildcard.enabled) { 680ef270ab1SKenneth D. Merry trsrc = &fcp->targ_rsrc_wildcard; 681ef270ab1SKenneth D. Merry } 682ef270ab1SKenneth D. Merry 683ef270ab1SKenneth D. Merry device_printf(tmfio->ocs->dev, "%s: io=%p cmd=%#x LU=%lx en=%s\n", 684ef270ab1SKenneth D. Merry __func__, tmfio, cmd, (unsigned long)lun, 685ef270ab1SKenneth D. Merry trsrc ? (trsrc->enabled ? "T" : "F") : "X"); 686ef270ab1SKenneth D. Merry if (trsrc) { 687ef270ab1SKenneth D. Merry inot = (struct ccb_immediate_notify *)STAILQ_FIRST(&trsrc->inot); 688ef270ab1SKenneth D. Merry } 689ef270ab1SKenneth D. Merry 690ef270ab1SKenneth D. Merry if (!inot) { 691ef270ab1SKenneth D. Merry device_printf( 692ef270ab1SKenneth D. Merry ocs->dev, "%s: no INOT for LUN %llx (en=%s) OX_ID %#x\n", 693ef270ab1SKenneth D. Merry __func__, (unsigned long long)lun, trsrc ? (trsrc->enabled ? "T" : "F") : "X", 694ef270ab1SKenneth D. Merry be16toh(tmfio->init_task_tag)); 695ef270ab1SKenneth D. Merry 696ef270ab1SKenneth D. Merry if (abortio) { 697ef270ab1SKenneth D. Merry ocs_scsi_io_complete(abortio); 698ef270ab1SKenneth D. Merry } 699ef270ab1SKenneth D. Merry ocs_scsi_io_complete(tmfio); 700ef270ab1SKenneth D. Merry goto ocs_scsi_recv_tmf_out; 701ef270ab1SKenneth D. Merry } 702ef270ab1SKenneth D. Merry 703ef270ab1SKenneth D. Merry tmfio->tgt_io.app = abortio; 704ef270ab1SKenneth D. Merry 705ef270ab1SKenneth D. Merry STAILQ_REMOVE_HEAD(&trsrc->inot, sim_links.stqe); 706ef270ab1SKenneth D. Merry 707ef270ab1SKenneth D. Merry inot->tag_id = tmfio->tag; 708ef270ab1SKenneth D. Merry inot->seq_id = tmfio->tag; 709ef270ab1SKenneth D. Merry 710ef270ab1SKenneth D. Merry if ((lun < OCS_MAX_LUN) && fcp->targ_rsrc[lun].enabled) { 711ef270ab1SKenneth D. Merry inot->initiator_id = node->instance_index; 712ef270ab1SKenneth D. Merry } else { 713ef270ab1SKenneth D. Merry inot->initiator_id = CAM_TARGET_WILDCARD; 714ef270ab1SKenneth D. Merry } 715ef270ab1SKenneth D. Merry 716ef270ab1SKenneth D. Merry inot->ccb_h.status = CAM_MESSAGE_RECV; 717ef270ab1SKenneth D. Merry inot->ccb_h.target_lun = lun; 718ef270ab1SKenneth D. Merry 719ef270ab1SKenneth D. Merry switch (cmd) { 720ef270ab1SKenneth D. Merry case OCS_SCSI_TMF_ABORT_TASK: 721ef270ab1SKenneth D. Merry inot->arg = MSG_ABORT_TASK; 722ef270ab1SKenneth D. Merry inot->seq_id = abortio->tag; 723ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: ABTS IO.%#x st=%#x\n", 724ef270ab1SKenneth D. Merry __func__, abortio->tag, abortio->tgt_io.state); 725ef270ab1SKenneth D. Merry abortio->tgt_io.flags |= OCS_CAM_IO_F_ABORT_RECV; 726ef270ab1SKenneth D. Merry abortio->tgt_io.flags |= OCS_CAM_IO_F_ABORT_NOTIFY; 727ef270ab1SKenneth D. Merry break; 728ef270ab1SKenneth D. Merry case OCS_SCSI_TMF_QUERY_TASK_SET: 729ef270ab1SKenneth D. Merry device_printf(ocs->dev, 730ef270ab1SKenneth D. Merry "%s: OCS_SCSI_TMF_QUERY_TASK_SET not supported\n", 731ef270ab1SKenneth D. Merry __func__); 732ef270ab1SKenneth D. Merry STAILQ_INSERT_TAIL(&trsrc->inot, &inot->ccb_h, sim_links.stqe); 733ef270ab1SKenneth D. Merry ocs_scsi_io_complete(tmfio); 734ef270ab1SKenneth D. Merry goto ocs_scsi_recv_tmf_out; 735ef270ab1SKenneth D. Merry break; 736ef270ab1SKenneth D. Merry case OCS_SCSI_TMF_ABORT_TASK_SET: 737ef270ab1SKenneth D. Merry inot->arg = MSG_ABORT_TASK_SET; 738ef270ab1SKenneth D. Merry break; 739ef270ab1SKenneth D. Merry case OCS_SCSI_TMF_CLEAR_TASK_SET: 740ef270ab1SKenneth D. Merry inot->arg = MSG_CLEAR_TASK_SET; 741ef270ab1SKenneth D. Merry break; 742ef270ab1SKenneth D. Merry case OCS_SCSI_TMF_QUERY_ASYNCHRONOUS_EVENT: 743ef270ab1SKenneth D. Merry inot->arg = MSG_QUERY_ASYNC_EVENT; 744ef270ab1SKenneth D. Merry break; 745ef270ab1SKenneth D. Merry case OCS_SCSI_TMF_LOGICAL_UNIT_RESET: 746ef270ab1SKenneth D. Merry inot->arg = MSG_LOGICAL_UNIT_RESET; 747ef270ab1SKenneth D. Merry break; 748ef270ab1SKenneth D. Merry case OCS_SCSI_TMF_CLEAR_ACA: 749ef270ab1SKenneth D. Merry inot->arg = MSG_CLEAR_ACA; 750ef270ab1SKenneth D. Merry break; 751ef270ab1SKenneth D. Merry case OCS_SCSI_TMF_TARGET_RESET: 752ef270ab1SKenneth D. Merry inot->arg = MSG_TARGET_RESET; 753ef270ab1SKenneth D. Merry break; 754ef270ab1SKenneth D. Merry default: 755ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: unsupported TMF %#x\n", 756ef270ab1SKenneth D. Merry __func__, cmd); 757ef270ab1SKenneth D. Merry STAILQ_INSERT_TAIL(&trsrc->inot, &inot->ccb_h, sim_links.stqe); 758ef270ab1SKenneth D. Merry goto ocs_scsi_recv_tmf_out; 759ef270ab1SKenneth D. Merry } 760ef270ab1SKenneth D. Merry 761ef270ab1SKenneth D. Merry rc = 0; 762ef270ab1SKenneth D. Merry 763ef270ab1SKenneth D. Merry xpt_print(inot->ccb_h.path, "%s: func=%#x stat=%#x id=%#x lun=%#x" 764ef270ab1SKenneth D. Merry " flags=%#x tag=%#x seq=%#x ini=%#x arg=%#x\n", 765ef270ab1SKenneth D. Merry __func__, inot->ccb_h.func_code, inot->ccb_h.status, 766ef270ab1SKenneth D. Merry inot->ccb_h.target_id, 767ef270ab1SKenneth D. Merry (unsigned int)inot->ccb_h.target_lun, inot->ccb_h.flags, 768ef270ab1SKenneth D. Merry inot->tag_id, inot->seq_id, inot->initiator_id, 769ef270ab1SKenneth D. Merry inot->arg); 770ef270ab1SKenneth D. Merry xpt_done((union ccb *)inot); 771ef270ab1SKenneth D. Merry 772ef270ab1SKenneth D. Merry if (abortio) { 773ef270ab1SKenneth D. Merry abortio->tgt_io.flags |= OCS_CAM_IO_F_ABORT_DEV; 774ef270ab1SKenneth D. Merry rc = ocs_scsi_tgt_abort_io(abortio, ocs_io_abort_cb, tmfio); 775ef270ab1SKenneth D. Merry } 776ef270ab1SKenneth D. Merry 777ef270ab1SKenneth D. Merry ocs_scsi_recv_tmf_out: 778ef270ab1SKenneth D. Merry return rc; 779ef270ab1SKenneth D. Merry } 780ef270ab1SKenneth D. Merry 781ef270ab1SKenneth D. Merry /** 782ef270ab1SKenneth D. Merry * @ingroup scsi_api_initiator 783ef270ab1SKenneth D. Merry * @brief Initializes any initiator fields on the ocs structure. 784ef270ab1SKenneth D. Merry * 785ef270ab1SKenneth D. Merry * Called by OS initialization code when a new device is discovered. 786ef270ab1SKenneth D. Merry * 787ef270ab1SKenneth D. Merry * @param ocs pointer to ocs 788ef270ab1SKenneth D. Merry * 789ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 790ef270ab1SKenneth D. Merry */ 791ef270ab1SKenneth D. Merry int32_t 792ef270ab1SKenneth D. Merry ocs_scsi_ini_new_device(ocs_t *ocs) 793ef270ab1SKenneth D. Merry { 794ef270ab1SKenneth D. Merry 795ef270ab1SKenneth D. Merry return 0; 796ef270ab1SKenneth D. Merry } 797ef270ab1SKenneth D. Merry 798ef270ab1SKenneth D. Merry /** 799ef270ab1SKenneth D. Merry * @ingroup scsi_api_initiator 800ef270ab1SKenneth D. Merry * @brief Tears down initiator members of ocs structure. 801ef270ab1SKenneth D. Merry * 802ef270ab1SKenneth D. Merry * Called by OS code when device is removed. 803ef270ab1SKenneth D. Merry * 804ef270ab1SKenneth D. Merry * @param ocs pointer to ocs 805ef270ab1SKenneth D. Merry * 806ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 807ef270ab1SKenneth D. Merry */ 808ef270ab1SKenneth D. Merry 809ef270ab1SKenneth D. Merry int32_t 810ef270ab1SKenneth D. Merry ocs_scsi_ini_del_device(ocs_t *ocs) 811ef270ab1SKenneth D. Merry { 812ef270ab1SKenneth D. Merry 813ef270ab1SKenneth D. Merry return 0; 814ef270ab1SKenneth D. Merry } 815ef270ab1SKenneth D. Merry 816ef270ab1SKenneth D. Merry /** 817ef270ab1SKenneth D. Merry * @ingroup scsi_api_initiator 818ef270ab1SKenneth D. Merry * @brief accept new domain notification 819ef270ab1SKenneth D. Merry * 820ef270ab1SKenneth D. Merry * Called by base drive when new domain is discovered. An initiator-client 821ef270ab1SKenneth D. Merry * will accept this call to prepare for new remote node notifications 822ef270ab1SKenneth D. Merry * arising from ocs_scsi_new_target(). 823ef270ab1SKenneth D. Merry * 824ef270ab1SKenneth D. Merry * The domain context has the element <b>ocs_scsi_ini_domain_t ini_domain</b> 825ef270ab1SKenneth D. Merry * which is declared by the initiator-client code and is used for 826ef270ab1SKenneth D. Merry * initiator-client private data. 827ef270ab1SKenneth D. Merry * 828ef270ab1SKenneth D. Merry * This function will only be called if the base-driver has been enabled for 829ef270ab1SKenneth D. Merry * initiator capability. 830ef270ab1SKenneth D. Merry * 831ef270ab1SKenneth D. Merry * Note that this call is made to initiator-client backends, 832ef270ab1SKenneth D. Merry * the ocs_scsi_tgt_new_domain() function is called to target-server backends. 833ef270ab1SKenneth D. Merry * 834ef270ab1SKenneth D. Merry * @param domain pointer to domain 835ef270ab1SKenneth D. Merry * 836ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 837ef270ab1SKenneth D. Merry */ 838ef270ab1SKenneth D. Merry int32_t 839ef270ab1SKenneth D. Merry ocs_scsi_ini_new_domain(ocs_domain_t *domain) 840ef270ab1SKenneth D. Merry { 841ef270ab1SKenneth D. Merry return 0; 842ef270ab1SKenneth D. Merry } 843ef270ab1SKenneth D. Merry 844ef270ab1SKenneth D. Merry /** 845ef270ab1SKenneth D. Merry * @ingroup scsi_api_initiator 846ef270ab1SKenneth D. Merry * @brief accept domain lost notification 847ef270ab1SKenneth D. Merry * 848ef270ab1SKenneth D. Merry * Called by base-driver when a domain goes away. An initiator-client will 849ef270ab1SKenneth D. Merry * use this call to clean up all domain scoped resources. 850ef270ab1SKenneth D. Merry * 851ef270ab1SKenneth D. Merry * This function will only be called if the base-driver has been enabled for 852ef270ab1SKenneth D. Merry * initiator capability. 853ef270ab1SKenneth D. Merry * 854ef270ab1SKenneth D. Merry * Note that this call is made to initiator-client backends, 855ef270ab1SKenneth D. Merry * the ocs_scsi_tgt_del_domain() function is called to target-server backends. 856ef270ab1SKenneth D. Merry * 857ef270ab1SKenneth D. Merry * @param domain pointer to domain 858ef270ab1SKenneth D. Merry * 859ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 860ef270ab1SKenneth D. Merry */ 861ef270ab1SKenneth D. Merry void 862ef270ab1SKenneth D. Merry ocs_scsi_ini_del_domain(ocs_domain_t *domain) 863ef270ab1SKenneth D. Merry { 864ef270ab1SKenneth D. Merry } 865ef270ab1SKenneth D. Merry 866ef270ab1SKenneth D. Merry /** 867ef270ab1SKenneth D. Merry * @ingroup scsi_api_initiator 868ef270ab1SKenneth D. Merry * @brief accept new sli port notification 869ef270ab1SKenneth D. Merry * 870ef270ab1SKenneth D. Merry * Called by base drive when new sli port (sport) is discovered. 871ef270ab1SKenneth D. Merry * A target-server will use this call to prepare for new remote node 872ef270ab1SKenneth D. Merry * notifications arising from ocs_scsi_new_initiator(). 873ef270ab1SKenneth D. Merry * 874ef270ab1SKenneth D. Merry * This function will only be called if the base-driver has been enabled for 875ef270ab1SKenneth D. Merry * target capability. 876ef270ab1SKenneth D. Merry * 877ef270ab1SKenneth D. Merry * Note that this call is made to target-server backends, 878ef270ab1SKenneth D. Merry * the ocs_scsi_ini_new_sport() function is called to initiator-client backends. 879ef270ab1SKenneth D. Merry * 880ef270ab1SKenneth D. Merry * @param sport pointer to sport 881ef270ab1SKenneth D. Merry * 882ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 883ef270ab1SKenneth D. Merry */ 884ef270ab1SKenneth D. Merry int32_t 885ef270ab1SKenneth D. Merry ocs_scsi_ini_new_sport(ocs_sport_t *sport) 886ef270ab1SKenneth D. Merry { 887ef270ab1SKenneth D. Merry ocs_t *ocs = sport->ocs; 888b9732f78SRam Kishore Vegesna ocs_fcport *fcp = FCPORT(ocs, 0); 889ef270ab1SKenneth D. Merry 890ef270ab1SKenneth D. Merry if (!sport->is_vport) { 891b9732f78SRam Kishore Vegesna sport->tgt_data = fcp; 892b9732f78SRam Kishore Vegesna fcp->fc_id = sport->fc_id; 893ef270ab1SKenneth D. Merry } 894ef270ab1SKenneth D. Merry 895ef270ab1SKenneth D. Merry return 0; 896ef270ab1SKenneth D. Merry } 897ef270ab1SKenneth D. Merry 898ef270ab1SKenneth D. Merry /** 899ef270ab1SKenneth D. Merry * @ingroup scsi_api_initiator 900ef270ab1SKenneth D. Merry * @brief accept sli port gone notification 901ef270ab1SKenneth D. Merry * 902ef270ab1SKenneth D. Merry * Called by base-driver when a sport goes away. A target-server will 903ef270ab1SKenneth D. Merry * use this call to clean up all sport scoped resources. 904ef270ab1SKenneth D. Merry * 905ef270ab1SKenneth D. Merry * Note that this call is made to target-server backends, 906ef270ab1SKenneth D. Merry * the ocs_scsi_ini_del_sport() function is called to initiator-client backends. 907ef270ab1SKenneth D. Merry * 908ef270ab1SKenneth D. Merry * @param sport pointer to SLI port 909ef270ab1SKenneth D. Merry * 910ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 911ef270ab1SKenneth D. Merry */ 912ef270ab1SKenneth D. Merry void 913ef270ab1SKenneth D. Merry ocs_scsi_ini_del_sport(ocs_sport_t *sport) 914ef270ab1SKenneth D. Merry { 915b9732f78SRam Kishore Vegesna ocs_t *ocs = sport->ocs; 916b9732f78SRam Kishore Vegesna ocs_fcport *fcp = FCPORT(ocs, 0); 917b9732f78SRam Kishore Vegesna 918b9732f78SRam Kishore Vegesna if (!sport->is_vport) { 919b9732f78SRam Kishore Vegesna fcp->fc_id = 0; 920b9732f78SRam Kishore Vegesna } 921ef270ab1SKenneth D. Merry } 922ef270ab1SKenneth D. Merry 923ef270ab1SKenneth D. Merry void 924ef270ab1SKenneth D. Merry ocs_scsi_sport_deleted(ocs_sport_t *sport) 925ef270ab1SKenneth D. Merry { 926ef270ab1SKenneth D. Merry ocs_t *ocs = sport->ocs; 927ef270ab1SKenneth D. Merry ocs_fcport *fcp = NULL; 928ef270ab1SKenneth D. Merry 929ef270ab1SKenneth D. Merry ocs_xport_stats_t value; 930ef270ab1SKenneth D. Merry 931ef270ab1SKenneth D. Merry if (!sport->is_vport) { 932ef270ab1SKenneth D. Merry return; 933ef270ab1SKenneth D. Merry } 934ef270ab1SKenneth D. Merry 935ef270ab1SKenneth D. Merry fcp = sport->tgt_data; 936ef270ab1SKenneth D. Merry 937ef270ab1SKenneth D. Merry ocs_xport_status(ocs->xport, OCS_XPORT_PORT_STATUS, &value); 938ef270ab1SKenneth D. Merry 939ef270ab1SKenneth D. Merry if (value.value == 0) { 940ef270ab1SKenneth D. Merry ocs_log_debug(ocs, "PORT offline,.. skipping\n"); 941ef270ab1SKenneth D. Merry return; 942ef270ab1SKenneth D. Merry } 943ef270ab1SKenneth D. Merry 944ef270ab1SKenneth D. Merry if ((fcp->role != KNOB_ROLE_NONE)) { 945ef270ab1SKenneth D. Merry if(fcp->vport->sport != NULL) { 946ef270ab1SKenneth D. Merry ocs_log_debug(ocs,"sport is not NULL, skipping\n"); 947ef270ab1SKenneth D. Merry return; 948ef270ab1SKenneth D. Merry } 949ef270ab1SKenneth D. Merry 950ef270ab1SKenneth D. Merry ocs_sport_vport_alloc(ocs->domain, fcp->vport); 951ef270ab1SKenneth D. Merry return; 952ef270ab1SKenneth D. Merry } 953ef270ab1SKenneth D. Merry 954ef270ab1SKenneth D. Merry } 955ef270ab1SKenneth D. Merry 9566affb8ebSRam Kishore Vegesna int32_t 9576affb8ebSRam Kishore Vegesna ocs_tgt_find(ocs_fcport *fcp, ocs_node_t *node) 9586affb8ebSRam Kishore Vegesna { 9596affb8ebSRam Kishore Vegesna ocs_fc_target_t *tgt = NULL; 9606affb8ebSRam Kishore Vegesna uint32_t i; 9616affb8ebSRam Kishore Vegesna 9626affb8ebSRam Kishore Vegesna for (i = 0; i < OCS_MAX_TARGETS; i++) { 9636affb8ebSRam Kishore Vegesna tgt = &fcp->tgt[i]; 9646affb8ebSRam Kishore Vegesna 9656affb8ebSRam Kishore Vegesna if (tgt->state == OCS_TGT_STATE_NONE) 9666affb8ebSRam Kishore Vegesna continue; 9676affb8ebSRam Kishore Vegesna 9686affb8ebSRam Kishore Vegesna if (ocs_node_get_wwpn(node) == tgt->wwpn) { 9696affb8ebSRam Kishore Vegesna return i; 9706affb8ebSRam Kishore Vegesna } 9716affb8ebSRam Kishore Vegesna } 9726affb8ebSRam Kishore Vegesna 9736affb8ebSRam Kishore Vegesna return -1; 9746affb8ebSRam Kishore Vegesna } 9756affb8ebSRam Kishore Vegesna 976ef270ab1SKenneth D. Merry /** 977ef270ab1SKenneth D. Merry * @ingroup scsi_api_initiator 978ef270ab1SKenneth D. Merry * @brief receive notification of a new SCSI target node 979ef270ab1SKenneth D. Merry * 980ef270ab1SKenneth D. Merry * Sent by base driver to notify an initiator-client of the presense of a new 981ef270ab1SKenneth D. Merry * remote target. The initiator-server may use this call to prepare for 982ef270ab1SKenneth D. Merry * inbound IO from this node. 983ef270ab1SKenneth D. Merry * 984ef270ab1SKenneth D. Merry * This function is only called if the base driver is enabled for 985ef270ab1SKenneth D. Merry * initiator capability. 986ef270ab1SKenneth D. Merry * 987ef270ab1SKenneth D. Merry * @param node pointer to new remote initiator node 988ef270ab1SKenneth D. Merry * 989ef270ab1SKenneth D. Merry * @return none 990ef270ab1SKenneth D. Merry * 991ef270ab1SKenneth D. Merry * @note 992ef270ab1SKenneth D. Merry */ 9936affb8ebSRam Kishore Vegesna 9946affb8ebSRam Kishore Vegesna uint32_t 9956affb8ebSRam Kishore Vegesna ocs_update_tgt(ocs_node_t *node, ocs_fcport *fcp, uint32_t tgt_id) 996ef270ab1SKenneth D. Merry { 9976affb8ebSRam Kishore Vegesna ocs_fc_target_t *tgt = NULL; 9986affb8ebSRam Kishore Vegesna 9996affb8ebSRam Kishore Vegesna tgt = &fcp->tgt[tgt_id]; 10006affb8ebSRam Kishore Vegesna 10016affb8ebSRam Kishore Vegesna tgt->node_id = node->instance_index; 10026affb8ebSRam Kishore Vegesna tgt->state = OCS_TGT_STATE_VALID; 10036affb8ebSRam Kishore Vegesna 10046affb8ebSRam Kishore Vegesna tgt->port_id = node->rnode.fc_id; 10056affb8ebSRam Kishore Vegesna tgt->wwpn = ocs_node_get_wwpn(node); 10066affb8ebSRam Kishore Vegesna tgt->wwnn = ocs_node_get_wwnn(node); 10076affb8ebSRam Kishore Vegesna return 0; 10086affb8ebSRam Kishore Vegesna } 10096affb8ebSRam Kishore Vegesna 10106affb8ebSRam Kishore Vegesna uint32_t 10116affb8ebSRam Kishore Vegesna ocs_add_new_tgt(ocs_node_t *node, ocs_fcport *fcp) 10126affb8ebSRam Kishore Vegesna { 10136affb8ebSRam Kishore Vegesna uint32_t i; 10146affb8ebSRam Kishore Vegesna 1015ef270ab1SKenneth D. Merry struct ocs_softc *ocs = node->ocs; 1016ef270ab1SKenneth D. Merry union ccb *ccb = NULL; 10176affb8ebSRam Kishore Vegesna for (i = 0; i < OCS_MAX_TARGETS; i++) { 10186affb8ebSRam Kishore Vegesna if (fcp->tgt[i].state == OCS_TGT_STATE_NONE) 10196affb8ebSRam Kishore Vegesna break; 1020ef270ab1SKenneth D. Merry } 1021ef270ab1SKenneth D. Merry 1022ef270ab1SKenneth D. Merry if (NULL == (ccb = xpt_alloc_ccb_nowait())) { 1023ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: ccb allocation failed\n", __func__); 1024ef270ab1SKenneth D. Merry return -1; 1025ef270ab1SKenneth D. Merry } 1026ef270ab1SKenneth D. Merry 1027ef270ab1SKenneth D. Merry if (CAM_REQ_CMP != xpt_create_path(&ccb->ccb_h.path, xpt_periph, 1028ef270ab1SKenneth D. Merry cam_sim_path(fcp->sim), 10296affb8ebSRam Kishore Vegesna i, CAM_LUN_WILDCARD)) { 1030ef270ab1SKenneth D. Merry device_printf( 1031ef270ab1SKenneth D. Merry ocs->dev, "%s: target path creation failed\n", __func__); 1032ef270ab1SKenneth D. Merry xpt_free_ccb(ccb); 1033ef270ab1SKenneth D. Merry return -1; 1034ef270ab1SKenneth D. Merry } 1035ef270ab1SKenneth D. Merry 10366affb8ebSRam Kishore Vegesna ocs_update_tgt(node, fcp, i); 1037ef270ab1SKenneth D. Merry xpt_rescan(ccb); 1038ef270ab1SKenneth D. Merry return 0; 1039ef270ab1SKenneth D. Merry } 1040ef270ab1SKenneth D. Merry 10416affb8ebSRam Kishore Vegesna int32_t 10426affb8ebSRam Kishore Vegesna ocs_scsi_new_target(ocs_node_t *node) 10436affb8ebSRam Kishore Vegesna { 10446affb8ebSRam Kishore Vegesna ocs_fcport *fcp = NULL; 10456affb8ebSRam Kishore Vegesna int32_t i; 10466affb8ebSRam Kishore Vegesna 10476affb8ebSRam Kishore Vegesna fcp = node->sport->tgt_data; 10486affb8ebSRam Kishore Vegesna if (fcp == NULL) { 10496affb8ebSRam Kishore Vegesna printf("%s:FCP is NULL \n", __func__); 10506affb8ebSRam Kishore Vegesna return 0; 10516affb8ebSRam Kishore Vegesna } 10526affb8ebSRam Kishore Vegesna 10536affb8ebSRam Kishore Vegesna i = ocs_tgt_find(fcp, node); 10546affb8ebSRam Kishore Vegesna 10556affb8ebSRam Kishore Vegesna if (i < 0) { 10566affb8ebSRam Kishore Vegesna ocs_add_new_tgt(node, fcp); 10576affb8ebSRam Kishore Vegesna return 0; 10586affb8ebSRam Kishore Vegesna } 10596affb8ebSRam Kishore Vegesna 10606affb8ebSRam Kishore Vegesna ocs_update_tgt(node, fcp, i); 10616affb8ebSRam Kishore Vegesna return 0; 10626affb8ebSRam Kishore Vegesna } 10636affb8ebSRam Kishore Vegesna 10646affb8ebSRam Kishore Vegesna static void 10656affb8ebSRam Kishore Vegesna ocs_delete_target(ocs_t *ocs, ocs_fcport *fcp, int tgt) 10666affb8ebSRam Kishore Vegesna { 10676affb8ebSRam Kishore Vegesna struct cam_path *cpath = NULL; 10686affb8ebSRam Kishore Vegesna 10696affb8ebSRam Kishore Vegesna if (!fcp->sim) { 10706affb8ebSRam Kishore Vegesna device_printf(ocs->dev, "%s: calling with NULL sim\n", __func__); 10716affb8ebSRam Kishore Vegesna return; 10726affb8ebSRam Kishore Vegesna } 10736affb8ebSRam Kishore Vegesna 10746affb8ebSRam Kishore Vegesna if (CAM_REQ_CMP == xpt_create_path(&cpath, NULL, cam_sim_path(fcp->sim), 10756affb8ebSRam Kishore Vegesna tgt, CAM_LUN_WILDCARD)) { 10766affb8ebSRam Kishore Vegesna xpt_async(AC_LOST_DEVICE, cpath, NULL); 10776affb8ebSRam Kishore Vegesna 10786affb8ebSRam Kishore Vegesna xpt_free_path(cpath); 10796affb8ebSRam Kishore Vegesna } 10806affb8ebSRam Kishore Vegesna } 10816affb8ebSRam Kishore Vegesna 10826affb8ebSRam Kishore Vegesna /* 10836affb8ebSRam Kishore Vegesna * Device Lost Timer Function- when we have decided that a device was lost, 10846affb8ebSRam Kishore Vegesna * we wait a specific period of time prior to telling the OS about lost device. 10856affb8ebSRam Kishore Vegesna * 10866affb8ebSRam Kishore Vegesna * This timer function gets activated when the device was lost. 10876affb8ebSRam Kishore Vegesna * This function fires once a second and then scans the port database 10886affb8ebSRam Kishore Vegesna * for devices that are marked dead but still have a virtual target assigned. 10896affb8ebSRam Kishore Vegesna * We decrement a counter for that port database entry, and when it hits zero, 10906affb8ebSRam Kishore Vegesna * we tell the OS the device was lost. Timer will be stopped when the device 10916affb8ebSRam Kishore Vegesna * comes back active or removed from the OS. 10926affb8ebSRam Kishore Vegesna */ 10936affb8ebSRam Kishore Vegesna static void 10946affb8ebSRam Kishore Vegesna ocs_ldt(void *arg) 10956affb8ebSRam Kishore Vegesna { 10966affb8ebSRam Kishore Vegesna ocs_fcport *fcp = arg; 10976affb8ebSRam Kishore Vegesna taskqueue_enqueue(taskqueue_thread, &fcp->ltask); 10986affb8ebSRam Kishore Vegesna } 10996affb8ebSRam Kishore Vegesna 11006affb8ebSRam Kishore Vegesna static void 11016affb8ebSRam Kishore Vegesna ocs_ldt_task(void *arg, int pending) 11026affb8ebSRam Kishore Vegesna { 11036affb8ebSRam Kishore Vegesna ocs_fcport *fcp = arg; 11046affb8ebSRam Kishore Vegesna ocs_t *ocs = fcp->ocs; 11056affb8ebSRam Kishore Vegesna int i, more_to_do = 0; 11066affb8ebSRam Kishore Vegesna ocs_fc_target_t *tgt = NULL; 11076affb8ebSRam Kishore Vegesna 11086affb8ebSRam Kishore Vegesna for (i = 0; i < OCS_MAX_TARGETS; i++) { 11096affb8ebSRam Kishore Vegesna tgt = &fcp->tgt[i]; 11106affb8ebSRam Kishore Vegesna 11116affb8ebSRam Kishore Vegesna if (tgt->state != OCS_TGT_STATE_LOST) { 11126affb8ebSRam Kishore Vegesna continue; 11136affb8ebSRam Kishore Vegesna } 11146affb8ebSRam Kishore Vegesna 11156affb8ebSRam Kishore Vegesna if ((tgt->gone_timer != 0) && (ocs->attached)){ 11166affb8ebSRam Kishore Vegesna tgt->gone_timer -= 1; 11176affb8ebSRam Kishore Vegesna more_to_do++; 11186affb8ebSRam Kishore Vegesna continue; 11196affb8ebSRam Kishore Vegesna } 11206affb8ebSRam Kishore Vegesna 11216affb8ebSRam Kishore Vegesna if (tgt->is_target) { 11226affb8ebSRam Kishore Vegesna tgt->is_target = 0; 11236affb8ebSRam Kishore Vegesna ocs_delete_target(ocs, fcp, i); 11246affb8ebSRam Kishore Vegesna } 11256affb8ebSRam Kishore Vegesna 11266affb8ebSRam Kishore Vegesna tgt->state = OCS_TGT_STATE_NONE; 11276affb8ebSRam Kishore Vegesna } 11286affb8ebSRam Kishore Vegesna 11296affb8ebSRam Kishore Vegesna if (more_to_do) { 11306affb8ebSRam Kishore Vegesna callout_reset(&fcp->ldt, hz, ocs_ldt, fcp); 11316affb8ebSRam Kishore Vegesna } else { 11326affb8ebSRam Kishore Vegesna callout_deactivate(&fcp->ldt); 11336affb8ebSRam Kishore Vegesna } 11346affb8ebSRam Kishore Vegesna 11356affb8ebSRam Kishore Vegesna } 11366affb8ebSRam Kishore Vegesna 1137ef270ab1SKenneth D. Merry /** 1138ef270ab1SKenneth D. Merry * @ingroup scsi_api_initiator 1139ef270ab1SKenneth D. Merry * @brief Delete a SCSI target node 1140ef270ab1SKenneth D. Merry * 1141ef270ab1SKenneth D. Merry * Sent by base driver to notify a initiator-client that a remote target 1142ef270ab1SKenneth D. Merry * is now gone. The base driver will have terminated all outstanding IOs 1143ef270ab1SKenneth D. Merry * and the initiator-client will receive appropriate completions. 1144ef270ab1SKenneth D. Merry * 1145ef270ab1SKenneth D. Merry * The ocs_node_t structure has and elment of type ocs_scsi_ini_node_t named 1146ef270ab1SKenneth D. Merry * ini_node that is declared and used by a target-server for private 1147ef270ab1SKenneth D. Merry * information. 1148ef270ab1SKenneth D. Merry * 1149ef270ab1SKenneth D. Merry * This function is only called if the base driver is enabled for 1150ef270ab1SKenneth D. Merry * initiator capability. 1151ef270ab1SKenneth D. Merry * 1152ef270ab1SKenneth D. Merry * @param node pointer node being deleted 1153ef270ab1SKenneth D. Merry * @param reason reason for deleting the target 1154ef270ab1SKenneth D. Merry * 1155ef270ab1SKenneth D. Merry * @return Returns OCS_SCSI_CALL_ASYNC if target delete is queued for async 1156ef270ab1SKenneth D. Merry * completion and OCS_SCSI_CALL_COMPLETE if call completed or error. 1157ef270ab1SKenneth D. Merry * 1158ef270ab1SKenneth D. Merry * @note 1159ef270ab1SKenneth D. Merry */ 1160ef270ab1SKenneth D. Merry int32_t 1161ef270ab1SKenneth D. Merry ocs_scsi_del_target(ocs_node_t *node, ocs_scsi_del_target_reason_e reason) 1162ef270ab1SKenneth D. Merry { 1163ef270ab1SKenneth D. Merry struct ocs_softc *ocs = node->ocs; 1164ef270ab1SKenneth D. Merry ocs_fcport *fcp = NULL; 11656affb8ebSRam Kishore Vegesna ocs_fc_target_t *tgt = NULL; 11664915e5c7SRam Kishore Vegesna int32_t tgt_id; 11674915e5c7SRam Kishore Vegesna 11684915e5c7SRam Kishore Vegesna if (ocs == NULL) { 11694915e5c7SRam Kishore Vegesna ocs_log_err(ocs,"OCS is NULL \n"); 11704915e5c7SRam Kishore Vegesna return -1; 11714915e5c7SRam Kishore Vegesna } 1172ef270ab1SKenneth D. Merry 1173ef270ab1SKenneth D. Merry fcp = node->sport->tgt_data; 1174ef270ab1SKenneth D. Merry if (fcp == NULL) { 1175ef270ab1SKenneth D. Merry ocs_log_err(ocs,"FCP is NULL \n"); 11764915e5c7SRam Kishore Vegesna return -1; 1177ef270ab1SKenneth D. Merry } 1178ef270ab1SKenneth D. Merry 11796affb8ebSRam Kishore Vegesna tgt_id = ocs_tgt_find(fcp, node); 11804915e5c7SRam Kishore Vegesna if (tgt_id == -1) { 11814915e5c7SRam Kishore Vegesna ocs_log_err(ocs,"target is invalid\n"); 11824915e5c7SRam Kishore Vegesna return -1; 11834915e5c7SRam Kishore Vegesna } 11846affb8ebSRam Kishore Vegesna 11856affb8ebSRam Kishore Vegesna tgt = &fcp->tgt[tgt_id]; 11866affb8ebSRam Kishore Vegesna 11876affb8ebSRam Kishore Vegesna // IF in shutdown delete target. 11886affb8ebSRam Kishore Vegesna if(!ocs->attached) { 11896affb8ebSRam Kishore Vegesna ocs_delete_target(ocs, fcp, tgt_id); 11906affb8ebSRam Kishore Vegesna } else { 11916affb8ebSRam Kishore Vegesna tgt->state = OCS_TGT_STATE_LOST; 11926affb8ebSRam Kishore Vegesna tgt->gone_timer = 30; 11936affb8ebSRam Kishore Vegesna if (!callout_active(&fcp->ldt)) { 11946affb8ebSRam Kishore Vegesna callout_reset(&fcp->ldt, hz, ocs_ldt, fcp); 11956affb8ebSRam Kishore Vegesna } 1196ef270ab1SKenneth D. Merry } 1197ef270ab1SKenneth D. Merry 11986affb8ebSRam Kishore Vegesna return 0; 1199ef270ab1SKenneth D. Merry } 1200ef270ab1SKenneth D. Merry 1201ef270ab1SKenneth D. Merry /** 1202ef270ab1SKenneth D. Merry * @brief Initialize SCSI IO 1203ef270ab1SKenneth D. Merry * 1204ef270ab1SKenneth D. Merry * Initialize SCSI IO, this function is called once per IO during IO pool 1205ef270ab1SKenneth D. Merry * allocation so that the target server may initialize any of its own private 1206ef270ab1SKenneth D. Merry * data. 1207ef270ab1SKenneth D. Merry * 1208ef270ab1SKenneth D. Merry * @param io pointer to SCSI IO object 1209ef270ab1SKenneth D. Merry * 1210ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 1211ef270ab1SKenneth D. Merry */ 1212ef270ab1SKenneth D. Merry int32_t 1213ef270ab1SKenneth D. Merry ocs_scsi_tgt_io_init(ocs_io_t *io) 1214ef270ab1SKenneth D. Merry { 1215ef270ab1SKenneth D. Merry return 0; 1216ef270ab1SKenneth D. Merry } 1217ef270ab1SKenneth D. Merry 1218ef270ab1SKenneth D. Merry /** 1219ef270ab1SKenneth D. Merry * @brief Uninitialize SCSI IO 1220ef270ab1SKenneth D. Merry * 1221ef270ab1SKenneth D. Merry * Uninitialize target server private data in a SCSI io object 1222ef270ab1SKenneth D. Merry * 1223ef270ab1SKenneth D. Merry * @param io pointer to SCSI IO object 1224ef270ab1SKenneth D. Merry * 1225ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 1226ef270ab1SKenneth D. Merry */ 1227ef270ab1SKenneth D. Merry int32_t 1228ef270ab1SKenneth D. Merry ocs_scsi_tgt_io_exit(ocs_io_t *io) 1229ef270ab1SKenneth D. Merry { 1230ef270ab1SKenneth D. Merry return 0; 1231ef270ab1SKenneth D. Merry } 1232ef270ab1SKenneth D. Merry 1233ef270ab1SKenneth D. Merry /** 1234ef270ab1SKenneth D. Merry * @brief Initialize SCSI IO 1235ef270ab1SKenneth D. Merry * 1236ef270ab1SKenneth D. Merry * Initialize SCSI IO, this function is called once per IO during IO pool 1237ef270ab1SKenneth D. Merry * allocation so that the initiator client may initialize any of its own private 1238ef270ab1SKenneth D. Merry * data. 1239ef270ab1SKenneth D. Merry * 1240ef270ab1SKenneth D. Merry * @param io pointer to SCSI IO object 1241ef270ab1SKenneth D. Merry * 1242ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 1243ef270ab1SKenneth D. Merry */ 1244ef270ab1SKenneth D. Merry int32_t 1245ef270ab1SKenneth D. Merry ocs_scsi_ini_io_init(ocs_io_t *io) 1246ef270ab1SKenneth D. Merry { 1247ef270ab1SKenneth D. Merry return 0; 1248ef270ab1SKenneth D. Merry } 1249ef270ab1SKenneth D. Merry 1250ef270ab1SKenneth D. Merry /** 1251ef270ab1SKenneth D. Merry * @brief Uninitialize SCSI IO 1252ef270ab1SKenneth D. Merry * 1253ef270ab1SKenneth D. Merry * Uninitialize initiator client private data in a SCSI io object 1254ef270ab1SKenneth D. Merry * 1255ef270ab1SKenneth D. Merry * @param io pointer to SCSI IO object 1256ef270ab1SKenneth D. Merry * 1257ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 1258ef270ab1SKenneth D. Merry */ 1259ef270ab1SKenneth D. Merry int32_t 1260ef270ab1SKenneth D. Merry ocs_scsi_ini_io_exit(ocs_io_t *io) 1261ef270ab1SKenneth D. Merry { 1262ef270ab1SKenneth D. Merry return 0; 1263ef270ab1SKenneth D. Merry } 1264ef270ab1SKenneth D. Merry /* 1265ef270ab1SKenneth D. Merry * End of functions required by SCSI base driver API 1266ef270ab1SKenneth D. Merry ***************************************************************************/ 1267ef270ab1SKenneth D. Merry 1268ef270ab1SKenneth D. Merry static __inline void 1269ef270ab1SKenneth D. Merry ocs_set_ccb_status(union ccb *ccb, cam_status status) 1270ef270ab1SKenneth D. Merry { 1271ef270ab1SKenneth D. Merry ccb->ccb_h.status &= ~CAM_STATUS_MASK; 1272ef270ab1SKenneth D. Merry ccb->ccb_h.status |= status; 1273ef270ab1SKenneth D. Merry } 1274ef270ab1SKenneth D. Merry 1275ef270ab1SKenneth D. Merry static int32_t 1276ef270ab1SKenneth D. Merry ocs_task_set_full_or_busy_cb(ocs_io_t *io, ocs_scsi_io_status_e scsi_status, 1277ef270ab1SKenneth D. Merry uint32_t flags, void *arg) 1278ef270ab1SKenneth D. Merry { 1279ef270ab1SKenneth D. Merry 1280ef270ab1SKenneth D. Merry ocs_target_io_free(io); 1281ef270ab1SKenneth D. Merry 1282ef270ab1SKenneth D. Merry return 0; 1283ef270ab1SKenneth D. Merry } 1284ef270ab1SKenneth D. Merry 1285ef270ab1SKenneth D. Merry /** 1286ef270ab1SKenneth D. Merry * @brief send SCSI task set full or busy status 1287ef270ab1SKenneth D. Merry * 1288ef270ab1SKenneth D. Merry * A SCSI task set full or busy response is sent depending on whether 1289ef270ab1SKenneth D. Merry * another IO is already active on the LUN. 1290ef270ab1SKenneth D. Merry * 1291ef270ab1SKenneth D. Merry * @param io pointer to IO context 1292ef270ab1SKenneth D. Merry * 1293ef270ab1SKenneth D. Merry * @return returns 0 for success, a negative error code value for failure. 1294ef270ab1SKenneth D. Merry */ 1295ef270ab1SKenneth D. Merry 1296ef270ab1SKenneth D. Merry static int32_t 1297ef270ab1SKenneth D. Merry ocs_task_set_full_or_busy(ocs_io_t *io) 1298ef270ab1SKenneth D. Merry { 1299ef270ab1SKenneth D. Merry ocs_scsi_cmd_resp_t rsp = { 0 }; 1300ef270ab1SKenneth D. Merry ocs_t *ocs = io->ocs; 1301ef270ab1SKenneth D. Merry 1302ef270ab1SKenneth D. Merry /* 1303ef270ab1SKenneth D. Merry * If there is another command for the LUN, then send task set full, 1304ef270ab1SKenneth D. Merry * if this is the first one, then send the busy status. 1305ef270ab1SKenneth D. Merry * 1306ef270ab1SKenneth D. Merry * if 'busy sent' is FALSE, set it to TRUE and send BUSY 1307ef270ab1SKenneth D. Merry * otherwise send FULL 1308ef270ab1SKenneth D. Merry */ 1309ef270ab1SKenneth D. Merry if (atomic_cmpset_acq_32(&io->node->tgt_node.busy_sent, FALSE, TRUE)) { 1310ef270ab1SKenneth D. Merry rsp.scsi_status = SCSI_STATUS_BUSY; /* Busy */ 1311ef270ab1SKenneth D. Merry printf("%s: busy [%s] tag=%x iiu=%d ihw=%d\n", __func__, 1312ef270ab1SKenneth D. Merry io->node->display_name, io->tag, 1313ef270ab1SKenneth D. Merry io->ocs->io_in_use, io->ocs->io_high_watermark); 1314ef270ab1SKenneth D. Merry } else { 1315ef270ab1SKenneth D. Merry rsp.scsi_status = SCSI_STATUS_TASK_SET_FULL; /* Task set full */ 1316ef270ab1SKenneth D. Merry printf("%s: full tag=%x iiu=%d\n", __func__, io->tag, 1317ef270ab1SKenneth D. Merry io->ocs->io_in_use); 1318ef270ab1SKenneth D. Merry } 1319ef270ab1SKenneth D. Merry 1320ef270ab1SKenneth D. Merry /* Log a message here indicating a busy or task set full state */ 1321ef270ab1SKenneth D. Merry if (OCS_LOG_ENABLE_Q_FULL_BUSY_MSG(ocs)) { 1322ef270ab1SKenneth D. Merry /* Log Task Set Full */ 1323ef270ab1SKenneth D. Merry if (rsp.scsi_status == SCSI_STATUS_TASK_SET_FULL) { 1324ef270ab1SKenneth D. Merry /* Task Set Full Message */ 1325ef270ab1SKenneth D. Merry ocs_log_info(ocs, "OCS CAM TASK SET FULL. Tasks >= %d\n", 1326ef270ab1SKenneth D. Merry ocs->io_high_watermark); 1327ef270ab1SKenneth D. Merry } 1328ef270ab1SKenneth D. Merry else if (rsp.scsi_status == SCSI_STATUS_BUSY) { 1329ef270ab1SKenneth D. Merry /* Log Busy Message */ 1330ef270ab1SKenneth D. Merry ocs_log_info(ocs, "OCS CAM SCSI BUSY\n"); 1331ef270ab1SKenneth D. Merry } 1332ef270ab1SKenneth D. Merry } 1333ef270ab1SKenneth D. Merry 1334ef270ab1SKenneth D. Merry /* Send the response */ 1335ef270ab1SKenneth D. Merry return 1336ef270ab1SKenneth D. Merry ocs_scsi_send_resp(io, 0, &rsp, ocs_task_set_full_or_busy_cb, NULL); 1337ef270ab1SKenneth D. Merry } 1338ef270ab1SKenneth D. Merry 1339ef270ab1SKenneth D. Merry /** 1340ef270ab1SKenneth D. Merry * @ingroup cam_io 1341ef270ab1SKenneth D. Merry * @brief Process target IO completions 1342ef270ab1SKenneth D. Merry * 1343ef270ab1SKenneth D. Merry * @param io 1344ef270ab1SKenneth D. Merry * @param scsi_status did the IO complete successfully 1345ef270ab1SKenneth D. Merry * @param flags 1346ef270ab1SKenneth D. Merry * @param arg application specific pointer provided in the call to ocs_target_io() 1347ef270ab1SKenneth D. Merry * 1348ef270ab1SKenneth D. Merry * @todo 1349ef270ab1SKenneth D. Merry */ 1350ef270ab1SKenneth D. Merry static int32_t ocs_scsi_target_io_cb(ocs_io_t *io, 1351ef270ab1SKenneth D. Merry ocs_scsi_io_status_e scsi_status, 1352ef270ab1SKenneth D. Merry uint32_t flags, void *arg) 1353ef270ab1SKenneth D. Merry { 1354ef270ab1SKenneth D. Merry union ccb *ccb = arg; 1355ef270ab1SKenneth D. Merry struct ccb_scsiio *csio = &ccb->csio; 1356ef270ab1SKenneth D. Merry struct ocs_softc *ocs = csio->ccb_h.ccb_ocs_ptr; 1357ef270ab1SKenneth D. Merry uint32_t cam_dir = ccb->ccb_h.flags & CAM_DIR_MASK; 1358ef270ab1SKenneth D. Merry uint32_t io_is_done = 1359ef270ab1SKenneth D. Merry (ccb->ccb_h.flags & CAM_SEND_STATUS) == CAM_SEND_STATUS; 1360ef270ab1SKenneth D. Merry 1361ef270ab1SKenneth D. Merry ccb->ccb_h.status &= ~CAM_SIM_QUEUED; 1362ef270ab1SKenneth D. Merry 1363ef270ab1SKenneth D. Merry if (CAM_DIR_NONE != cam_dir) { 1364ef270ab1SKenneth D. Merry bus_dmasync_op_t op; 1365ef270ab1SKenneth D. Merry 1366ef270ab1SKenneth D. Merry if (CAM_DIR_IN == cam_dir) { 1367ef270ab1SKenneth D. Merry op = BUS_DMASYNC_POSTREAD; 1368ef270ab1SKenneth D. Merry } else { 1369ef270ab1SKenneth D. Merry op = BUS_DMASYNC_POSTWRITE; 1370ef270ab1SKenneth D. Merry } 1371ef270ab1SKenneth D. Merry /* Synchronize the DMA memory with the CPU and free the mapping */ 1372ef270ab1SKenneth D. Merry bus_dmamap_sync(ocs->buf_dmat, io->tgt_io.dmap, op); 1373ef270ab1SKenneth D. Merry if (io->tgt_io.flags & OCS_CAM_IO_F_DMAPPED) { 1374ef270ab1SKenneth D. Merry bus_dmamap_unload(ocs->buf_dmat, io->tgt_io.dmap); 1375ef270ab1SKenneth D. Merry } 1376ef270ab1SKenneth D. Merry } 1377ef270ab1SKenneth D. Merry 1378ef270ab1SKenneth D. Merry if (io->tgt_io.sendresp) { 1379ef270ab1SKenneth D. Merry io->tgt_io.sendresp = 0; 1380ef270ab1SKenneth D. Merry ocs_scsi_cmd_resp_t resp = { 0 }; 1381ef270ab1SKenneth D. Merry io->tgt_io.state = OCS_CAM_IO_RESP; 1382ef270ab1SKenneth D. Merry resp.scsi_status = scsi_status; 1383ef270ab1SKenneth D. Merry if (ccb->ccb_h.flags & CAM_SEND_SENSE) { 1384ef270ab1SKenneth D. Merry resp.sense_data = (uint8_t *)&csio->sense_data; 1385ef270ab1SKenneth D. Merry resp.sense_data_length = csio->sense_len; 1386ef270ab1SKenneth D. Merry } 1387ef270ab1SKenneth D. Merry resp.residual = io->exp_xfer_len - io->transferred; 1388ef270ab1SKenneth D. Merry 1389ef270ab1SKenneth D. Merry return ocs_scsi_send_resp(io, 0, &resp, ocs_scsi_target_io_cb, ccb); 1390ef270ab1SKenneth D. Merry } 1391ef270ab1SKenneth D. Merry 1392ef270ab1SKenneth D. Merry switch (scsi_status) { 1393ef270ab1SKenneth D. Merry case OCS_SCSI_STATUS_GOOD: 1394ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP); 1395ef270ab1SKenneth D. Merry break; 1396ef270ab1SKenneth D. Merry case OCS_SCSI_STATUS_ABORTED: 1397ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_ABORTED); 1398ef270ab1SKenneth D. Merry break; 1399ef270ab1SKenneth D. Merry default: 1400ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP_ERR); 1401ef270ab1SKenneth D. Merry } 1402ef270ab1SKenneth D. Merry 1403ef270ab1SKenneth D. Merry if (io_is_done) { 1404ef270ab1SKenneth D. Merry if ((io->tgt_io.flags & OCS_CAM_IO_F_ABORT_NOTIFY) == 0) { 1405ef270ab1SKenneth D. Merry ocs_target_io_free(io); 1406ef270ab1SKenneth D. Merry } 1407ef270ab1SKenneth D. Merry } else { 1408ef270ab1SKenneth D. Merry io->tgt_io.state = OCS_CAM_IO_DATA_DONE; 1409ef270ab1SKenneth D. Merry /*device_printf(ocs->dev, "%s: CTIO state=%d tag=%#x\n", 1410ef270ab1SKenneth D. Merry __func__, io->tgt_io.state, io->tag);*/ 1411ef270ab1SKenneth D. Merry } 1412ef270ab1SKenneth D. Merry 1413ef270ab1SKenneth D. Merry xpt_done(ccb); 1414ef270ab1SKenneth D. Merry 1415ef270ab1SKenneth D. Merry return 0; 1416ef270ab1SKenneth D. Merry } 1417ef270ab1SKenneth D. Merry 1418ef270ab1SKenneth D. Merry /** 1419ef270ab1SKenneth D. Merry * @note 1. Since the CCB is assigned to the ocs_io_t on an XPT_CONT_TARGET_IO 1420ef270ab1SKenneth D. Merry * action, if an initiator aborts a command prior to the SIM receiving 1421ef270ab1SKenneth D. Merry * a CTIO, the IO's CCB will be NULL. 1422ef270ab1SKenneth D. Merry */ 1423ef270ab1SKenneth D. Merry static int32_t 1424ef270ab1SKenneth D. Merry ocs_io_abort_cb(ocs_io_t *io, ocs_scsi_io_status_e scsi_status, uint32_t flags, void *arg) 1425ef270ab1SKenneth D. Merry { 1426ef270ab1SKenneth D. Merry struct ocs_softc *ocs = NULL; 1427ef270ab1SKenneth D. Merry ocs_io_t *tmfio = arg; 1428ef270ab1SKenneth D. Merry ocs_scsi_tmf_resp_e tmf_resp = OCS_SCSI_TMF_FUNCTION_COMPLETE; 1429ef270ab1SKenneth D. Merry int32_t rc = 0; 1430ef270ab1SKenneth D. Merry 1431ef270ab1SKenneth D. Merry ocs = io->ocs; 1432ef270ab1SKenneth D. Merry 1433ef270ab1SKenneth D. Merry io->tgt_io.flags &= ~OCS_CAM_IO_F_ABORT_DEV; 1434ef270ab1SKenneth D. Merry 1435ef270ab1SKenneth D. Merry /* A good status indicates the IO was aborted and will be completed in 1436ef270ab1SKenneth D. Merry * the IO's completion handler. Handle the other cases here. */ 1437ef270ab1SKenneth D. Merry switch (scsi_status) { 1438ef270ab1SKenneth D. Merry case OCS_SCSI_STATUS_GOOD: 1439ef270ab1SKenneth D. Merry break; 1440ef270ab1SKenneth D. Merry case OCS_SCSI_STATUS_NO_IO: 1441ef270ab1SKenneth D. Merry break; 1442ef270ab1SKenneth D. Merry default: 1443ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: unhandled status %d\n", 1444ef270ab1SKenneth D. Merry __func__, scsi_status); 1445ef270ab1SKenneth D. Merry tmf_resp = OCS_SCSI_TMF_FUNCTION_REJECTED; 1446ef270ab1SKenneth D. Merry rc = -1; 1447ef270ab1SKenneth D. Merry } 1448ef270ab1SKenneth D. Merry 1449ef270ab1SKenneth D. Merry ocs_scsi_send_tmf_resp(tmfio, tmf_resp, NULL, ocs_target_tmf_cb, NULL); 1450ef270ab1SKenneth D. Merry 1451ef270ab1SKenneth D. Merry return rc; 1452ef270ab1SKenneth D. Merry } 1453ef270ab1SKenneth D. Merry 1454ef270ab1SKenneth D. Merry /** 1455ef270ab1SKenneth D. Merry * @ingroup cam_io 1456ef270ab1SKenneth D. Merry * @brief Process initiator IO completions 1457ef270ab1SKenneth D. Merry * 1458ef270ab1SKenneth D. Merry * @param io 1459ef270ab1SKenneth D. Merry * @param scsi_status did the IO complete successfully 1460ef270ab1SKenneth D. Merry * @param rsp pointer to response buffer 1461ef270ab1SKenneth D. Merry * @param flags 1462ef270ab1SKenneth D. Merry * @param arg application specific pointer provided in the call to ocs_target_io() 1463ef270ab1SKenneth D. Merry * 1464ef270ab1SKenneth D. Merry * @todo 1465ef270ab1SKenneth D. Merry */ 1466ef270ab1SKenneth D. Merry static int32_t ocs_scsi_initiator_io_cb(ocs_io_t *io, 1467ef270ab1SKenneth D. Merry ocs_scsi_io_status_e scsi_status, 1468ef270ab1SKenneth D. Merry ocs_scsi_cmd_resp_t *rsp, 1469ef270ab1SKenneth D. Merry uint32_t flags, void *arg) 1470ef270ab1SKenneth D. Merry { 1471ef270ab1SKenneth D. Merry union ccb *ccb = arg; 1472ef270ab1SKenneth D. Merry struct ccb_scsiio *csio = &ccb->csio; 1473ef270ab1SKenneth D. Merry struct ocs_softc *ocs = csio->ccb_h.ccb_ocs_ptr; 1474ef270ab1SKenneth D. Merry uint32_t cam_dir = ccb->ccb_h.flags & CAM_DIR_MASK; 1475ef270ab1SKenneth D. Merry cam_status ccb_status= CAM_REQ_CMP_ERR; 1476ef270ab1SKenneth D. Merry 1477ef270ab1SKenneth D. Merry if (CAM_DIR_NONE != cam_dir) { 1478ef270ab1SKenneth D. Merry bus_dmasync_op_t op; 1479ef270ab1SKenneth D. Merry 1480ef270ab1SKenneth D. Merry if (CAM_DIR_IN == cam_dir) { 1481ef270ab1SKenneth D. Merry op = BUS_DMASYNC_POSTREAD; 1482ef270ab1SKenneth D. Merry } else { 1483ef270ab1SKenneth D. Merry op = BUS_DMASYNC_POSTWRITE; 1484ef270ab1SKenneth D. Merry } 1485ef270ab1SKenneth D. Merry /* Synchronize the DMA memory with the CPU and free the mapping */ 1486ef270ab1SKenneth D. Merry bus_dmamap_sync(ocs->buf_dmat, io->tgt_io.dmap, op); 1487ef270ab1SKenneth D. Merry if (io->tgt_io.flags & OCS_CAM_IO_F_DMAPPED) { 1488ef270ab1SKenneth D. Merry bus_dmamap_unload(ocs->buf_dmat, io->tgt_io.dmap); 1489ef270ab1SKenneth D. Merry } 1490ef270ab1SKenneth D. Merry } 1491ef270ab1SKenneth D. Merry 1492ef270ab1SKenneth D. Merry if (scsi_status == OCS_SCSI_STATUS_CHECK_RESPONSE) { 1493ef270ab1SKenneth D. Merry csio->scsi_status = rsp->scsi_status; 14941af49c2eSRam Kishore Vegesna if (SCSI_STATUS_OK != rsp->scsi_status) 1495ef270ab1SKenneth D. Merry ccb_status = CAM_SCSI_STATUS_ERROR; 14961af49c2eSRam Kishore Vegesna else 14971af49c2eSRam Kishore Vegesna ccb_status = CAM_REQ_CMP; 1498ef270ab1SKenneth D. Merry 1499ef270ab1SKenneth D. Merry csio->resid = rsp->residual; 15001af49c2eSRam Kishore Vegesna 15011af49c2eSRam Kishore Vegesna /* 15021af49c2eSRam Kishore Vegesna * If we've already got a SCSI error, prefer that because it 15031af49c2eSRam Kishore Vegesna * will have more detail. 15041af49c2eSRam Kishore Vegesna */ 15051af49c2eSRam Kishore Vegesna if ((rsp->residual < 0) && (ccb_status == CAM_REQ_CMP)) { 1506ef270ab1SKenneth D. Merry ccb_status = CAM_DATA_RUN_ERR; 1507ef270ab1SKenneth D. Merry } 1508ef270ab1SKenneth D. Merry 1509ef270ab1SKenneth D. Merry if ((rsp->sense_data_length) && 1510ef270ab1SKenneth D. Merry !(ccb->ccb_h.flags & (CAM_SENSE_PHYS | CAM_SENSE_PTR))) { 1511ef270ab1SKenneth D. Merry uint32_t sense_len = 0; 1512ef270ab1SKenneth D. Merry 1513ef270ab1SKenneth D. Merry ccb->ccb_h.status |= CAM_AUTOSNS_VALID; 1514ef270ab1SKenneth D. Merry if (rsp->sense_data_length < csio->sense_len) { 1515ef270ab1SKenneth D. Merry csio->sense_resid = 1516ef270ab1SKenneth D. Merry csio->sense_len - rsp->sense_data_length; 1517ef270ab1SKenneth D. Merry sense_len = rsp->sense_data_length; 1518ef270ab1SKenneth D. Merry } else { 1519ef270ab1SKenneth D. Merry csio->sense_resid = 0; 1520ef270ab1SKenneth D. Merry sense_len = csio->sense_len; 1521ef270ab1SKenneth D. Merry } 1522ef270ab1SKenneth D. Merry ocs_memcpy(&csio->sense_data, rsp->sense_data, sense_len); 1523ef270ab1SKenneth D. Merry } 1524ef270ab1SKenneth D. Merry } else if (scsi_status != OCS_SCSI_STATUS_GOOD) { 1525ef270ab1SKenneth D. Merry ccb_status = CAM_REQ_CMP_ERR; 1526ef270ab1SKenneth D. Merry } else { 1527ef270ab1SKenneth D. Merry ccb_status = CAM_REQ_CMP; 1528ef270ab1SKenneth D. Merry } 1529ef270ab1SKenneth D. Merry 1530ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, ccb_status); 1531ef270ab1SKenneth D. Merry 1532ef270ab1SKenneth D. Merry ocs_scsi_io_free(io); 1533ef270ab1SKenneth D. Merry 1534ef270ab1SKenneth D. Merry csio->ccb_h.ccb_io_ptr = NULL; 1535ef270ab1SKenneth D. Merry csio->ccb_h.ccb_ocs_ptr = NULL; 1536d063d1bcSRam Kishore Vegesna 1537ef270ab1SKenneth D. Merry ccb->ccb_h.status &= ~CAM_SIM_QUEUED; 1538ef270ab1SKenneth D. Merry 1539d063d1bcSRam Kishore Vegesna if ((ccb_status != CAM_REQ_CMP) && 1540d063d1bcSRam Kishore Vegesna ((ccb->ccb_h.status & CAM_DEV_QFRZN) == 0)) { 1541d063d1bcSRam Kishore Vegesna ccb->ccb_h.status |= CAM_DEV_QFRZN; 1542d063d1bcSRam Kishore Vegesna xpt_freeze_devq(ccb->ccb_h.path, 1); 1543d063d1bcSRam Kishore Vegesna } 1544d063d1bcSRam Kishore Vegesna 1545ef270ab1SKenneth D. Merry xpt_done(ccb); 1546ef270ab1SKenneth D. Merry 1547ef270ab1SKenneth D. Merry return 0; 1548ef270ab1SKenneth D. Merry } 1549ef270ab1SKenneth D. Merry 1550ef270ab1SKenneth D. Merry /** 1551ef270ab1SKenneth D. Merry * @brief Load scatter-gather list entries into an IO 1552ef270ab1SKenneth D. Merry * 1553ef270ab1SKenneth D. Merry * This routine relies on the driver instance's software context pointer and 1554ef270ab1SKenneth D. Merry * the IO object pointer having been already assigned to hooks in the CCB. 1555ef270ab1SKenneth D. Merry * Although the routine does not return success/fail, callers can look at the 1556ef270ab1SKenneth D. Merry * n_sge member to determine if the mapping failed (0 on failure). 1557ef270ab1SKenneth D. Merry * 1558ef270ab1SKenneth D. Merry * @param arg pointer to the CAM ccb for this IO 1559ef270ab1SKenneth D. Merry * @param seg DMA address/length pairs 1560ef270ab1SKenneth D. Merry * @param nseg number of DMA address/length pairs 1561ef270ab1SKenneth D. Merry * @param error any errors while mapping the IO 1562ef270ab1SKenneth D. Merry */ 1563ef270ab1SKenneth D. Merry static void 1564ef270ab1SKenneth D. Merry ocs_scsi_dmamap_load(void *arg, bus_dma_segment_t *seg, int nseg, int error) 1565ef270ab1SKenneth D. Merry { 1566ef270ab1SKenneth D. Merry ocs_dmamap_load_arg_t *sglarg = (ocs_dmamap_load_arg_t*) arg; 1567ef270ab1SKenneth D. Merry 1568ef270ab1SKenneth D. Merry if (error) { 1569ef270ab1SKenneth D. Merry printf("%s: seg=%p nseg=%d error=%d\n", 1570ef270ab1SKenneth D. Merry __func__, seg, nseg, error); 1571ef270ab1SKenneth D. Merry sglarg->rc = -1; 1572ef270ab1SKenneth D. Merry } else { 1573ef270ab1SKenneth D. Merry uint32_t i = 0; 1574ef270ab1SKenneth D. Merry uint32_t c = 0; 1575ef270ab1SKenneth D. Merry 1576ef270ab1SKenneth D. Merry if ((sglarg->sgl_count + nseg) > sglarg->sgl_max) { 1577ef270ab1SKenneth D. Merry printf("%s: sgl_count=%d nseg=%d max=%d\n", __func__, 1578ef270ab1SKenneth D. Merry sglarg->sgl_count, nseg, sglarg->sgl_max); 1579ef270ab1SKenneth D. Merry sglarg->rc = -2; 1580ef270ab1SKenneth D. Merry return; 1581ef270ab1SKenneth D. Merry } 1582ef270ab1SKenneth D. Merry 1583ef270ab1SKenneth D. Merry for (i = 0, c = sglarg->sgl_count; i < nseg; i++, c++) { 1584ef270ab1SKenneth D. Merry sglarg->sgl[c].addr = seg[i].ds_addr; 1585ef270ab1SKenneth D. Merry sglarg->sgl[c].len = seg[i].ds_len; 1586ef270ab1SKenneth D. Merry } 1587ef270ab1SKenneth D. Merry 1588ef270ab1SKenneth D. Merry sglarg->sgl_count = c; 1589ef270ab1SKenneth D. Merry 1590ef270ab1SKenneth D. Merry sglarg->rc = 0; 1591ef270ab1SKenneth D. Merry } 1592ef270ab1SKenneth D. Merry } 1593ef270ab1SKenneth D. Merry 1594ef270ab1SKenneth D. Merry /** 1595ef270ab1SKenneth D. Merry * @brief Build a scatter-gather list from a CAM CCB 1596ef270ab1SKenneth D. Merry * 1597ef270ab1SKenneth D. Merry * @param ocs the driver instance's software context 1598ef270ab1SKenneth D. Merry * @param ccb pointer to the CCB 1599ef270ab1SKenneth D. Merry * @param io pointer to the previously allocated IO object 1600ef270ab1SKenneth D. Merry * @param sgl pointer to SGL 1601ef270ab1SKenneth D. Merry * @param sgl_max number of entries in sgl 1602ef270ab1SKenneth D. Merry * 1603ef270ab1SKenneth D. Merry * @return 0 on success, non-zero otherwise 1604ef270ab1SKenneth D. Merry */ 1605ef270ab1SKenneth D. Merry static int32_t 1606ef270ab1SKenneth D. Merry ocs_build_scsi_sgl(struct ocs_softc *ocs, union ccb *ccb, ocs_io_t *io, 1607ef270ab1SKenneth D. Merry ocs_scsi_sgl_t *sgl, uint32_t sgl_max) 1608ef270ab1SKenneth D. Merry { 1609ef270ab1SKenneth D. Merry ocs_dmamap_load_arg_t dmaarg; 1610ef270ab1SKenneth D. Merry int32_t err = 0; 1611ef270ab1SKenneth D. Merry 1612ef270ab1SKenneth D. Merry if (!ocs || !ccb || !io || !sgl) { 1613ef270ab1SKenneth D. Merry printf("%s: bad param o=%p c=%p i=%p s=%p\n", __func__, 1614ef270ab1SKenneth D. Merry ocs, ccb, io, sgl); 1615ef270ab1SKenneth D. Merry return -1; 1616ef270ab1SKenneth D. Merry } 1617ef270ab1SKenneth D. Merry 1618ef270ab1SKenneth D. Merry io->tgt_io.flags &= ~OCS_CAM_IO_F_DMAPPED; 1619ef270ab1SKenneth D. Merry 1620ef270ab1SKenneth D. Merry dmaarg.sgl = sgl; 1621ef270ab1SKenneth D. Merry dmaarg.sgl_count = 0; 1622ef270ab1SKenneth D. Merry dmaarg.sgl_max = sgl_max; 1623ef270ab1SKenneth D. Merry dmaarg.rc = 0; 1624ef270ab1SKenneth D. Merry 1625ef270ab1SKenneth D. Merry err = bus_dmamap_load_ccb(ocs->buf_dmat, io->tgt_io.dmap, ccb, 1626ef270ab1SKenneth D. Merry ocs_scsi_dmamap_load, &dmaarg, 0); 1627ef270ab1SKenneth D. Merry 1628ef270ab1SKenneth D. Merry if (err || dmaarg.rc) { 1629ef270ab1SKenneth D. Merry device_printf( 1630ef270ab1SKenneth D. Merry ocs->dev, "%s: bus_dmamap_load_ccb error (%d %d)\n", 1631ef270ab1SKenneth D. Merry __func__, err, dmaarg.rc); 1632ef270ab1SKenneth D. Merry return -1; 1633ef270ab1SKenneth D. Merry } 1634ef270ab1SKenneth D. Merry 1635ef270ab1SKenneth D. Merry io->tgt_io.flags |= OCS_CAM_IO_F_DMAPPED; 1636ef270ab1SKenneth D. Merry return dmaarg.sgl_count; 1637ef270ab1SKenneth D. Merry } 1638ef270ab1SKenneth D. Merry 1639ef270ab1SKenneth D. Merry /** 1640ef270ab1SKenneth D. Merry * @ingroup cam_io 1641ef270ab1SKenneth D. Merry * @brief Send a target IO 1642ef270ab1SKenneth D. Merry * 1643ef270ab1SKenneth D. Merry * @param ocs the driver instance's software context 1644ef270ab1SKenneth D. Merry * @param ccb pointer to the CCB 1645ef270ab1SKenneth D. Merry * 1646ef270ab1SKenneth D. Merry * @return 0 on success, non-zero otherwise 1647ef270ab1SKenneth D. Merry */ 1648ef270ab1SKenneth D. Merry static int32_t 1649ef270ab1SKenneth D. Merry ocs_target_io(struct ocs_softc *ocs, union ccb *ccb) 1650ef270ab1SKenneth D. Merry { 1651ef270ab1SKenneth D. Merry struct ccb_scsiio *csio = &ccb->csio; 1652ef270ab1SKenneth D. Merry ocs_io_t *io = NULL; 1653ef270ab1SKenneth D. Merry uint32_t cam_dir = ccb->ccb_h.flags & CAM_DIR_MASK; 1654ef270ab1SKenneth D. Merry bool sendstatus = ccb->ccb_h.flags & CAM_SEND_STATUS; 1655ef270ab1SKenneth D. Merry uint32_t xferlen = csio->dxfer_len; 1656ef270ab1SKenneth D. Merry int32_t rc = 0; 1657ef270ab1SKenneth D. Merry 1658ef270ab1SKenneth D. Merry io = ocs_scsi_find_io(ocs, csio->tag_id); 1659ef270ab1SKenneth D. Merry if (io == NULL) { 1660ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP_ERR); 1661ef270ab1SKenneth D. Merry panic("bad tag value"); 1662ef270ab1SKenneth D. Merry return 1; 1663ef270ab1SKenneth D. Merry } 1664ef270ab1SKenneth D. Merry 1665ef270ab1SKenneth D. Merry /* Received an ABORT TASK for this IO */ 1666ef270ab1SKenneth D. Merry if (io->tgt_io.flags & OCS_CAM_IO_F_ABORT_RECV) { 1667ef270ab1SKenneth D. Merry /*device_printf(ocs->dev, 1668ef270ab1SKenneth D. Merry "%s: XPT_CONT_TARGET_IO state=%d tag=%#x xid=%#x flags=%#x\n", 1669ef270ab1SKenneth D. Merry __func__, io->tgt_io.state, io->tag, io->init_task_tag, 1670ef270ab1SKenneth D. Merry io->tgt_io.flags);*/ 1671ef270ab1SKenneth D. Merry io->tgt_io.flags |= OCS_CAM_IO_F_ABORT_CAM; 1672ef270ab1SKenneth D. Merry 1673ef270ab1SKenneth D. Merry if (ccb->ccb_h.flags & CAM_SEND_STATUS) { 1674ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP); 1675ef270ab1SKenneth D. Merry ocs_target_io_free(io); 1676ef270ab1SKenneth D. Merry return 1; 1677ef270ab1SKenneth D. Merry } 1678ef270ab1SKenneth D. Merry 1679ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_ABORTED); 1680ef270ab1SKenneth D. Merry 1681ef270ab1SKenneth D. Merry return 1; 1682ef270ab1SKenneth D. Merry } 1683ef270ab1SKenneth D. Merry 1684ef270ab1SKenneth D. Merry io->tgt_io.app = ccb; 1685ef270ab1SKenneth D. Merry 1686ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_INPROG); 1687ef270ab1SKenneth D. Merry ccb->ccb_h.status |= CAM_SIM_QUEUED; 1688ef270ab1SKenneth D. Merry 1689ef270ab1SKenneth D. Merry csio->ccb_h.ccb_ocs_ptr = ocs; 1690ef270ab1SKenneth D. Merry csio->ccb_h.ccb_io_ptr = io; 1691ef270ab1SKenneth D. Merry 1692ef270ab1SKenneth D. Merry if ((sendstatus && (xferlen == 0))) { 1693ef270ab1SKenneth D. Merry ocs_scsi_cmd_resp_t resp = { 0 }; 1694ef270ab1SKenneth D. Merry 1695ef270ab1SKenneth D. Merry ocs_assert(ccb->ccb_h.flags & CAM_SEND_STATUS, -1); 1696ef270ab1SKenneth D. Merry 1697ef270ab1SKenneth D. Merry io->tgt_io.state = OCS_CAM_IO_RESP; 1698ef270ab1SKenneth D. Merry 1699ef270ab1SKenneth D. Merry resp.scsi_status = csio->scsi_status; 1700ef270ab1SKenneth D. Merry 1701ef270ab1SKenneth D. Merry if (ccb->ccb_h.flags & CAM_SEND_SENSE) { 1702ef270ab1SKenneth D. Merry resp.sense_data = (uint8_t *)&csio->sense_data; 1703ef270ab1SKenneth D. Merry resp.sense_data_length = csio->sense_len; 1704ef270ab1SKenneth D. Merry } 1705ef270ab1SKenneth D. Merry 1706ef270ab1SKenneth D. Merry resp.residual = io->exp_xfer_len - io->transferred; 1707ef270ab1SKenneth D. Merry rc = ocs_scsi_send_resp(io, 0, &resp, ocs_scsi_target_io_cb, ccb); 1708ef270ab1SKenneth D. Merry 1709ef270ab1SKenneth D. Merry } else if (xferlen != 0) { 1710322dbb8cSRam Kishore Vegesna ocs_scsi_sgl_t *sgl; 1711ef270ab1SKenneth D. Merry int32_t sgl_count = 0; 1712ef270ab1SKenneth D. Merry 1713ef270ab1SKenneth D. Merry io->tgt_io.state = OCS_CAM_IO_DATA; 1714ef270ab1SKenneth D. Merry 1715ef270ab1SKenneth D. Merry if (sendstatus) 1716ef270ab1SKenneth D. Merry io->tgt_io.sendresp = 1; 1717ef270ab1SKenneth D. Merry 1718322dbb8cSRam Kishore Vegesna sgl = io->sgl; 1719322dbb8cSRam Kishore Vegesna 1720322dbb8cSRam Kishore Vegesna sgl_count = ocs_build_scsi_sgl(ocs, ccb, io, sgl, io->sgl_allocated); 1721ef270ab1SKenneth D. Merry if (sgl_count > 0) { 1722ef270ab1SKenneth D. Merry if (cam_dir == CAM_DIR_IN) { 1723ef270ab1SKenneth D. Merry rc = ocs_scsi_send_rd_data(io, 0, NULL, sgl, 1724ef270ab1SKenneth D. Merry sgl_count, csio->dxfer_len, 1725ef270ab1SKenneth D. Merry ocs_scsi_target_io_cb, ccb); 1726ef270ab1SKenneth D. Merry } else if (cam_dir == CAM_DIR_OUT) { 1727ef270ab1SKenneth D. Merry rc = ocs_scsi_recv_wr_data(io, 0, NULL, sgl, 1728ef270ab1SKenneth D. Merry sgl_count, csio->dxfer_len, 1729ef270ab1SKenneth D. Merry ocs_scsi_target_io_cb, ccb); 1730ef270ab1SKenneth D. Merry } else { 1731ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s:" 1732ef270ab1SKenneth D. Merry " unknown CAM direction %#x\n", 1733ef270ab1SKenneth D. Merry __func__, cam_dir); 1734ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_INVALID); 1735ef270ab1SKenneth D. Merry rc = 1; 1736ef270ab1SKenneth D. Merry } 1737ef270ab1SKenneth D. Merry } else { 1738ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: building SGL failed\n", 1739ef270ab1SKenneth D. Merry __func__); 1740ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP_ERR); 1741ef270ab1SKenneth D. Merry rc = 1; 1742ef270ab1SKenneth D. Merry } 1743ef270ab1SKenneth D. Merry } else { 1744ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: Wrong value xfer and sendstatus" 1745ef270ab1SKenneth D. Merry " are 0 \n", __func__); 1746ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_INVALID); 1747ef270ab1SKenneth D. Merry rc = 1; 1748ef270ab1SKenneth D. Merry } 1749ef270ab1SKenneth D. Merry 1750ef270ab1SKenneth D. Merry if (rc) { 1751ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP_ERR); 1752ef270ab1SKenneth D. Merry ccb->ccb_h.status &= ~CAM_SIM_QUEUED; 1753ef270ab1SKenneth D. Merry io->tgt_io.state = OCS_CAM_IO_DATA_DONE; 1754ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: CTIO state=%d tag=%#x\n", 1755ef270ab1SKenneth D. Merry __func__, io->tgt_io.state, io->tag); 1756ef270ab1SKenneth D. Merry if ((sendstatus && (xferlen == 0))) { 1757ef270ab1SKenneth D. Merry ocs_target_io_free(io); 1758ef270ab1SKenneth D. Merry } 1759ef270ab1SKenneth D. Merry } 1760ef270ab1SKenneth D. Merry 1761ef270ab1SKenneth D. Merry return rc; 1762ef270ab1SKenneth D. Merry } 1763ef270ab1SKenneth D. Merry 1764ef270ab1SKenneth D. Merry static int32_t 1765ef270ab1SKenneth D. Merry ocs_target_tmf_cb(ocs_io_t *io, ocs_scsi_io_status_e scsi_status, uint32_t flags, 1766ef270ab1SKenneth D. Merry void *arg) 1767ef270ab1SKenneth D. Merry { 1768ef270ab1SKenneth D. Merry 1769ef270ab1SKenneth D. Merry /*device_printf(io->ocs->dev, "%s: tag=%x io=%p s=%#x\n", 1770ef270ab1SKenneth D. Merry __func__, io->tag, io, scsi_status);*/ 1771ef270ab1SKenneth D. Merry ocs_scsi_io_complete(io); 1772ef270ab1SKenneth D. Merry 1773ef270ab1SKenneth D. Merry return 0; 1774ef270ab1SKenneth D. Merry } 1775ef270ab1SKenneth D. Merry 1776ef270ab1SKenneth D. Merry /** 1777ef270ab1SKenneth D. Merry * @ingroup cam_io 1778ef270ab1SKenneth D. Merry * @brief Send an initiator IO 1779ef270ab1SKenneth D. Merry * 1780ef270ab1SKenneth D. Merry * @param ocs the driver instance's software context 1781ef270ab1SKenneth D. Merry * @param ccb pointer to the CCB 1782ef270ab1SKenneth D. Merry * 1783ef270ab1SKenneth D. Merry * @return 0 on success, non-zero otherwise 1784ef270ab1SKenneth D. Merry */ 1785ef270ab1SKenneth D. Merry static int32_t 1786ef270ab1SKenneth D. Merry ocs_initiator_io(struct ocs_softc *ocs, union ccb *ccb) 1787ef270ab1SKenneth D. Merry { 1788ef270ab1SKenneth D. Merry int32_t rc; 1789ef270ab1SKenneth D. Merry struct ccb_scsiio *csio = &ccb->csio; 1790ef270ab1SKenneth D. Merry struct ccb_hdr *ccb_h = &csio->ccb_h; 1791ef270ab1SKenneth D. Merry ocs_node_t *node = NULL; 1792ef270ab1SKenneth D. Merry ocs_io_t *io = NULL; 1793322dbb8cSRam Kishore Vegesna ocs_scsi_sgl_t *sgl; 179488364968SAlexander Motin int32_t flags, sgl_count; 17954915e5c7SRam Kishore Vegesna ocs_fcport *fcp; 1796ef270ab1SKenneth D. Merry 17976affb8ebSRam Kishore Vegesna fcp = FCPORT(ocs, cam_sim_bus(xpt_path_sim((ccb)->ccb_h.path))); 17986affb8ebSRam Kishore Vegesna 17996affb8ebSRam Kishore Vegesna if (fcp->tgt[ccb_h->target_id].state == OCS_TGT_STATE_LOST) { 18006affb8ebSRam Kishore Vegesna device_printf(ocs->dev, "%s: device LOST %d\n", __func__, 18016affb8ebSRam Kishore Vegesna ccb_h->target_id); 18026affb8ebSRam Kishore Vegesna return CAM_REQUEUE_REQ; 18036affb8ebSRam Kishore Vegesna } 18046affb8ebSRam Kishore Vegesna 18056affb8ebSRam Kishore Vegesna if (fcp->tgt[ccb_h->target_id].state == OCS_TGT_STATE_NONE) { 18066affb8ebSRam Kishore Vegesna device_printf(ocs->dev, "%s: device not ready %d\n", __func__, 18076affb8ebSRam Kishore Vegesna ccb_h->target_id); 18086affb8ebSRam Kishore Vegesna return CAM_SEL_TIMEOUT; 18096affb8ebSRam Kishore Vegesna } 18106affb8ebSRam Kishore Vegesna 18116affb8ebSRam Kishore Vegesna node = ocs_node_get_instance(ocs, fcp->tgt[ccb_h->target_id].node_id); 1812ef270ab1SKenneth D. Merry if (node == NULL) { 1813ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: no device %d\n", __func__, 1814ef270ab1SKenneth D. Merry ccb_h->target_id); 18156affb8ebSRam Kishore Vegesna return CAM_SEL_TIMEOUT; 1816ef270ab1SKenneth D. Merry } 1817ef270ab1SKenneth D. Merry 1818ef270ab1SKenneth D. Merry if (!node->targ) { 1819ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: not target device %d\n", __func__, 1820ef270ab1SKenneth D. Merry ccb_h->target_id); 18216affb8ebSRam Kishore Vegesna return CAM_SEL_TIMEOUT; 1822ef270ab1SKenneth D. Merry } 1823ef270ab1SKenneth D. Merry 1824ef270ab1SKenneth D. Merry io = ocs_scsi_io_alloc(node, OCS_SCSI_IO_ROLE_ORIGINATOR); 1825ef270ab1SKenneth D. Merry if (io == NULL) { 1826ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: unable to alloc IO\n", __func__); 1827ef270ab1SKenneth D. Merry return -1; 1828ef270ab1SKenneth D. Merry } 1829ef270ab1SKenneth D. Merry 1830ef270ab1SKenneth D. Merry /* eventhough this is INI, use target structure as ocs_build_scsi_sgl 1831ef270ab1SKenneth D. Merry * only references the tgt_io part of an ocs_io_t */ 1832ef270ab1SKenneth D. Merry io->tgt_io.app = ccb; 1833ef270ab1SKenneth D. Merry 1834ef270ab1SKenneth D. Merry csio->ccb_h.ccb_ocs_ptr = ocs; 1835ef270ab1SKenneth D. Merry csio->ccb_h.ccb_io_ptr = io; 1836322dbb8cSRam Kishore Vegesna sgl = io->sgl; 1837ef270ab1SKenneth D. Merry 1838322dbb8cSRam Kishore Vegesna sgl_count = ocs_build_scsi_sgl(ocs, ccb, io, sgl, io->sgl_allocated); 1839ef270ab1SKenneth D. Merry if (sgl_count < 0) { 1840ef270ab1SKenneth D. Merry ocs_scsi_io_free(io); 1841ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: building SGL failed\n", __func__); 1842ef270ab1SKenneth D. Merry return -1; 1843ef270ab1SKenneth D. Merry } 1844ef270ab1SKenneth D. Merry 1845ef270ab1SKenneth D. Merry if (ccb->ccb_h.timeout == CAM_TIME_INFINITY) { 1846ef270ab1SKenneth D. Merry io->timeout = 0; 1847ef270ab1SKenneth D. Merry } else if (ccb->ccb_h.timeout == CAM_TIME_DEFAULT) { 1848ef270ab1SKenneth D. Merry io->timeout = OCS_CAM_IO_TIMEOUT; 1849ef270ab1SKenneth D. Merry } else { 1850ef270ab1SKenneth D. Merry io->timeout = ccb->ccb_h.timeout; 1851ef270ab1SKenneth D. Merry } 1852ef270ab1SKenneth D. Merry 185388364968SAlexander Motin switch (csio->tag_action) { 185488364968SAlexander Motin case MSG_HEAD_OF_Q_TAG: 185588364968SAlexander Motin flags = OCS_SCSI_CMD_HEAD_OF_QUEUE; 185688364968SAlexander Motin break; 185788364968SAlexander Motin case MSG_ORDERED_Q_TAG: 185888364968SAlexander Motin flags = OCS_SCSI_CMD_ORDERED; 185988364968SAlexander Motin break; 186088364968SAlexander Motin case MSG_ACA_TASK: 186188364968SAlexander Motin flags = OCS_SCSI_CMD_ACA; 186288364968SAlexander Motin break; 186388364968SAlexander Motin case CAM_TAG_ACTION_NONE: 186488364968SAlexander Motin case MSG_SIMPLE_Q_TAG: 186588364968SAlexander Motin default: 186688364968SAlexander Motin flags = OCS_SCSI_CMD_SIMPLE; 186788364968SAlexander Motin break; 186888364968SAlexander Motin } 186988364968SAlexander Motin flags |= (csio->priority << OCS_SCSI_PRIORITY_SHIFT) & 187088364968SAlexander Motin OCS_SCSI_PRIORITY_MASK; 187188364968SAlexander Motin 1872ef270ab1SKenneth D. Merry switch (ccb->ccb_h.flags & CAM_DIR_MASK) { 1873ef270ab1SKenneth D. Merry case CAM_DIR_NONE: 1874ef270ab1SKenneth D. Merry rc = ocs_scsi_send_nodata_io(node, io, ccb_h->target_lun, 1875ef270ab1SKenneth D. Merry ccb->ccb_h.flags & CAM_CDB_POINTER ? 1876ef270ab1SKenneth D. Merry csio->cdb_io.cdb_ptr: csio->cdb_io.cdb_bytes, 1877ef270ab1SKenneth D. Merry csio->cdb_len, 187888364968SAlexander Motin ocs_scsi_initiator_io_cb, ccb, flags); 1879ef270ab1SKenneth D. Merry break; 1880ef270ab1SKenneth D. Merry case CAM_DIR_IN: 1881ef270ab1SKenneth D. Merry rc = ocs_scsi_send_rd_io(node, io, ccb_h->target_lun, 1882ef270ab1SKenneth D. Merry ccb->ccb_h.flags & CAM_CDB_POINTER ? 1883ef270ab1SKenneth D. Merry csio->cdb_io.cdb_ptr: csio->cdb_io.cdb_bytes, 1884ef270ab1SKenneth D. Merry csio->cdb_len, 1885ef270ab1SKenneth D. Merry NULL, 1886ef270ab1SKenneth D. Merry sgl, sgl_count, csio->dxfer_len, 188788364968SAlexander Motin ocs_scsi_initiator_io_cb, ccb, flags); 1888ef270ab1SKenneth D. Merry break; 1889ef270ab1SKenneth D. Merry case CAM_DIR_OUT: 1890ef270ab1SKenneth D. Merry rc = ocs_scsi_send_wr_io(node, io, ccb_h->target_lun, 1891ef270ab1SKenneth D. Merry ccb->ccb_h.flags & CAM_CDB_POINTER ? 1892ef270ab1SKenneth D. Merry csio->cdb_io.cdb_ptr: csio->cdb_io.cdb_bytes, 1893ef270ab1SKenneth D. Merry csio->cdb_len, 1894ef270ab1SKenneth D. Merry NULL, 1895ef270ab1SKenneth D. Merry sgl, sgl_count, csio->dxfer_len, 189688364968SAlexander Motin ocs_scsi_initiator_io_cb, ccb, flags); 1897ef270ab1SKenneth D. Merry break; 1898ef270ab1SKenneth D. Merry default: 1899ef270ab1SKenneth D. Merry panic("%s invalid data direction %08x\n", __func__, 1900ef270ab1SKenneth D. Merry ccb->ccb_h.flags); 1901ef270ab1SKenneth D. Merry break; 1902ef270ab1SKenneth D. Merry } 1903ef270ab1SKenneth D. Merry 1904ef270ab1SKenneth D. Merry return rc; 1905ef270ab1SKenneth D. Merry } 1906ef270ab1SKenneth D. Merry 1907ef270ab1SKenneth D. Merry static uint32_t 1908ef270ab1SKenneth D. Merry ocs_fcp_change_role(struct ocs_softc *ocs, ocs_fcport *fcp, uint32_t new_role) 1909ef270ab1SKenneth D. Merry { 1910ef270ab1SKenneth D. Merry 1911ef270ab1SKenneth D. Merry uint32_t rc = 0, was = 0, i = 0; 1912ef270ab1SKenneth D. Merry ocs_vport_spec_t *vport = fcp->vport; 1913ef270ab1SKenneth D. Merry 1914ef270ab1SKenneth D. Merry for (was = 0, i = 0; i < (ocs->num_vports + 1); i++) { 1915ef270ab1SKenneth D. Merry if (FCPORT(ocs, i)->role != KNOB_ROLE_NONE) 1916ef270ab1SKenneth D. Merry was++; 1917ef270ab1SKenneth D. Merry } 1918ef270ab1SKenneth D. Merry 1919ef270ab1SKenneth D. Merry // Physical port 1920ef270ab1SKenneth D. Merry if ((was == 0) || (vport == NULL)) { 1921ef270ab1SKenneth D. Merry fcp->role = new_role; 1922ef270ab1SKenneth D. Merry if (vport == NULL) { 1923ef270ab1SKenneth D. Merry ocs->enable_ini = (new_role & KNOB_ROLE_INITIATOR)? 1:0; 1924ef270ab1SKenneth D. Merry ocs->enable_tgt = (new_role & KNOB_ROLE_TARGET)? 1:0; 1925ef270ab1SKenneth D. Merry } else { 1926ef270ab1SKenneth D. Merry vport->enable_ini = (new_role & KNOB_ROLE_INITIATOR)? 1:0; 1927ef270ab1SKenneth D. Merry vport->enable_tgt = (new_role & KNOB_ROLE_TARGET)? 1:0; 1928ef270ab1SKenneth D. Merry } 1929ef270ab1SKenneth D. Merry 1930ef270ab1SKenneth D. Merry rc = ocs_xport_control(ocs->xport, OCS_XPORT_PORT_OFFLINE); 1931ef270ab1SKenneth D. Merry if (rc) { 1932ef270ab1SKenneth D. Merry ocs_log_debug(ocs, "port offline failed : %d\n", rc); 1933ef270ab1SKenneth D. Merry } 1934ef270ab1SKenneth D. Merry 1935ef270ab1SKenneth D. Merry rc = ocs_xport_control(ocs->xport, OCS_XPORT_PORT_ONLINE); 1936ef270ab1SKenneth D. Merry if (rc) { 1937ef270ab1SKenneth D. Merry ocs_log_debug(ocs, "port online failed : %d\n", rc); 1938ef270ab1SKenneth D. Merry } 1939ef270ab1SKenneth D. Merry 1940ef270ab1SKenneth D. Merry return 0; 1941ef270ab1SKenneth D. Merry } 1942ef270ab1SKenneth D. Merry 1943ef270ab1SKenneth D. Merry if ((fcp->role != KNOB_ROLE_NONE)){ 1944ef270ab1SKenneth D. Merry fcp->role = new_role; 1945ef270ab1SKenneth D. Merry vport->enable_ini = (new_role & KNOB_ROLE_INITIATOR)? 1:0; 1946ef270ab1SKenneth D. Merry vport->enable_tgt = (new_role & KNOB_ROLE_TARGET)? 1:0; 1947ef270ab1SKenneth D. Merry /* New Sport will be created in sport deleted cb */ 1948ef270ab1SKenneth D. Merry return ocs_sport_vport_del(ocs, ocs->domain, vport->wwpn, vport->wwnn); 1949ef270ab1SKenneth D. Merry } 1950ef270ab1SKenneth D. Merry 1951ef270ab1SKenneth D. Merry fcp->role = new_role; 1952ef270ab1SKenneth D. Merry 1953ef270ab1SKenneth D. Merry vport->enable_ini = (new_role & KNOB_ROLE_INITIATOR)? 1:0; 1954ef270ab1SKenneth D. Merry vport->enable_tgt = (new_role & KNOB_ROLE_TARGET)? 1:0; 1955ef270ab1SKenneth D. Merry 1956ef270ab1SKenneth D. Merry if (fcp->role != KNOB_ROLE_NONE) { 1957ef270ab1SKenneth D. Merry return ocs_sport_vport_alloc(ocs->domain, vport); 1958ef270ab1SKenneth D. Merry } 1959ef270ab1SKenneth D. Merry 1960ef270ab1SKenneth D. Merry return (0); 1961ef270ab1SKenneth D. Merry } 1962ef270ab1SKenneth D. Merry 1963ef270ab1SKenneth D. Merry /** 1964ef270ab1SKenneth D. Merry * @ingroup cam_api 1965ef270ab1SKenneth D. Merry * @brief Process CAM actions 1966ef270ab1SKenneth D. Merry * 1967ef270ab1SKenneth D. Merry * The driver supplies this routine to the CAM during intialization and 1968ef270ab1SKenneth D. Merry * is the main entry point for processing CAM Control Blocks (CCB) 1969ef270ab1SKenneth D. Merry * 1970ef270ab1SKenneth D. Merry * @param sim pointer to the SCSI Interface Module 1971ef270ab1SKenneth D. Merry * @param ccb CAM control block 1972ef270ab1SKenneth D. Merry * 1973ef270ab1SKenneth D. Merry * @todo 1974ef270ab1SKenneth D. Merry * - populate path inquiry data via info retrieved from SLI port 1975ef270ab1SKenneth D. Merry */ 1976ef270ab1SKenneth D. Merry static void 1977ef270ab1SKenneth D. Merry ocs_action(struct cam_sim *sim, union ccb *ccb) 1978ef270ab1SKenneth D. Merry { 1979ef270ab1SKenneth D. Merry struct ocs_softc *ocs = (struct ocs_softc *)cam_sim_softc(sim); 1980ef270ab1SKenneth D. Merry struct ccb_hdr *ccb_h = &ccb->ccb_h; 1981ef270ab1SKenneth D. Merry 1982ef270ab1SKenneth D. Merry int32_t rc, bus; 1983ef270ab1SKenneth D. Merry bus = cam_sim_bus(sim); 1984ef270ab1SKenneth D. Merry 1985ef270ab1SKenneth D. Merry switch (ccb_h->func_code) { 1986ef270ab1SKenneth D. Merry case XPT_SCSI_IO: 1987ef270ab1SKenneth D. Merry 1988ef270ab1SKenneth D. Merry if ((ccb->ccb_h.flags & CAM_CDB_POINTER) != 0) { 1989ef270ab1SKenneth D. Merry if ((ccb->ccb_h.flags & CAM_CDB_PHYS) != 0) { 1990ef270ab1SKenneth D. Merry ccb->ccb_h.status = CAM_REQ_INVALID; 1991ef270ab1SKenneth D. Merry xpt_done(ccb); 1992ef270ab1SKenneth D. Merry break; 1993ef270ab1SKenneth D. Merry } 1994ef270ab1SKenneth D. Merry } 1995ef270ab1SKenneth D. Merry 1996ef270ab1SKenneth D. Merry rc = ocs_initiator_io(ocs, ccb); 1997ef270ab1SKenneth D. Merry if (0 == rc) { 1998ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_INPROG | CAM_SIM_QUEUED); 1999ef270ab1SKenneth D. Merry break; 2000ef270ab1SKenneth D. Merry } else { 20016affb8ebSRam Kishore Vegesna if (rc == CAM_REQUEUE_REQ) { 20026affb8ebSRam Kishore Vegesna cam_freeze_devq(ccb->ccb_h.path); 20036affb8ebSRam Kishore Vegesna cam_release_devq(ccb->ccb_h.path, RELSIM_RELEASE_AFTER_TIMEOUT, 0, 100, 0); 20046affb8ebSRam Kishore Vegesna ccb->ccb_h.status = CAM_REQUEUE_REQ; 20056affb8ebSRam Kishore Vegesna xpt_done(ccb); 20066affb8ebSRam Kishore Vegesna break; 20076affb8ebSRam Kishore Vegesna } 20086affb8ebSRam Kishore Vegesna 2009ef270ab1SKenneth D. Merry ccb->ccb_h.status &= ~CAM_SIM_QUEUED; 2010ef270ab1SKenneth D. Merry if (rc > 0) { 2011ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, rc); 2012ef270ab1SKenneth D. Merry } else { 2013ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_SEL_TIMEOUT); 2014ef270ab1SKenneth D. Merry } 2015ef270ab1SKenneth D. Merry } 2016ef270ab1SKenneth D. Merry xpt_done(ccb); 2017ef270ab1SKenneth D. Merry break; 2018ef270ab1SKenneth D. Merry case XPT_PATH_INQ: 2019ef270ab1SKenneth D. Merry { 2020ef270ab1SKenneth D. Merry struct ccb_pathinq *cpi = &ccb->cpi; 2021ef270ab1SKenneth D. Merry struct ccb_pathinq_settings_fc *fc = &cpi->xport_specific.fc; 2022b9732f78SRam Kishore Vegesna ocs_fcport *fcp = FCPORT(ocs, bus); 2023ef270ab1SKenneth D. Merry 2024ef270ab1SKenneth D. Merry uint64_t wwn = 0; 2025ef270ab1SKenneth D. Merry ocs_xport_stats_t value; 2026ef270ab1SKenneth D. Merry 2027ef270ab1SKenneth D. Merry cpi->version_num = 1; 2028ef270ab1SKenneth D. Merry 2029ef270ab1SKenneth D. Merry cpi->protocol = PROTO_SCSI; 2030ef270ab1SKenneth D. Merry cpi->protocol_version = SCSI_REV_SPC; 2031ef270ab1SKenneth D. Merry 2032ef270ab1SKenneth D. Merry if (ocs->ocs_xport == OCS_XPORT_FC) { 2033ef270ab1SKenneth D. Merry cpi->transport = XPORT_FC; 2034ef270ab1SKenneth D. Merry } else { 2035ef270ab1SKenneth D. Merry cpi->transport = XPORT_UNKNOWN; 2036ef270ab1SKenneth D. Merry } 2037ef270ab1SKenneth D. Merry 2038ef270ab1SKenneth D. Merry cpi->transport_version = 0; 2039ef270ab1SKenneth D. Merry 2040ef270ab1SKenneth D. Merry /* Set the transport parameters of the SIM */ 2041ef270ab1SKenneth D. Merry ocs_xport_status(ocs->xport, OCS_XPORT_LINK_SPEED, &value); 2042ef270ab1SKenneth D. Merry fc->bitrate = value.value * 1000; /* speed in Mbps */ 2043ef270ab1SKenneth D. Merry 2044ef270ab1SKenneth D. Merry wwn = *((uint64_t *)ocs_scsi_get_property_ptr(ocs, OCS_SCSI_WWPN)); 2045ef270ab1SKenneth D. Merry fc->wwpn = be64toh(wwn); 2046ef270ab1SKenneth D. Merry 2047ef270ab1SKenneth D. Merry wwn = *((uint64_t *)ocs_scsi_get_property_ptr(ocs, OCS_SCSI_WWNN)); 2048ef270ab1SKenneth D. Merry fc->wwnn = be64toh(wwn); 2049ef270ab1SKenneth D. Merry 2050b9732f78SRam Kishore Vegesna fc->port = fcp->fc_id; 2051ef270ab1SKenneth D. Merry 2052ef270ab1SKenneth D. Merry if (ocs->config_tgt) { 2053ef270ab1SKenneth D. Merry cpi->target_sprt = 2054ef270ab1SKenneth D. Merry PIT_PROCESSOR | PIT_DISCONNECT | PIT_TERM_IO; 2055ef270ab1SKenneth D. Merry } 2056ef270ab1SKenneth D. Merry 2057ef270ab1SKenneth D. Merry cpi->hba_misc = PIM_NOBUSRESET | PIM_UNMAPPED; 2058ef270ab1SKenneth D. Merry cpi->hba_misc |= PIM_EXTLUNS | PIM_NOSCAN; 2059ef270ab1SKenneth D. Merry 2060ef270ab1SKenneth D. Merry cpi->hba_inquiry = PI_TAG_ABLE; 2061ef270ab1SKenneth D. Merry cpi->max_target = OCS_MAX_TARGETS; 2062ef270ab1SKenneth D. Merry cpi->initiator_id = ocs->max_remote_nodes + 1; 2063ef270ab1SKenneth D. Merry 2064ef270ab1SKenneth D. Merry if (!ocs->enable_ini) { 2065ef270ab1SKenneth D. Merry cpi->hba_misc |= PIM_NOINITIATOR; 2066ef270ab1SKenneth D. Merry } 2067ef270ab1SKenneth D. Merry 2068ef270ab1SKenneth D. Merry cpi->max_lun = OCS_MAX_LUN; 2069ef270ab1SKenneth D. Merry cpi->bus_id = cam_sim_bus(sim); 2070ef270ab1SKenneth D. Merry 2071ef270ab1SKenneth D. Merry /* Need to supply a base transfer speed prior to linking up 2072ef270ab1SKenneth D. Merry * Worst case, this would be FC 1Gbps */ 2073ef270ab1SKenneth D. Merry cpi->base_transfer_speed = 1 * 1000 * 1000; 2074ef270ab1SKenneth D. Merry 2075ef270ab1SKenneth D. Merry /* Calculate the max IO supported 2076ef270ab1SKenneth D. Merry * Worst case would be an OS page per SGL entry */ 2077322dbb8cSRam Kishore Vegesna 2078ef270ab1SKenneth D. Merry cpi->maxio = PAGE_SIZE * 2079ef270ab1SKenneth D. Merry (ocs_scsi_get_property(ocs, OCS_SCSI_MAX_SGL) - 1); 2080ef270ab1SKenneth D. Merry 2081ef270ab1SKenneth D. Merry strncpy(cpi->sim_vid, "FreeBSD", SIM_IDLEN); 2082ef270ab1SKenneth D. Merry strncpy(cpi->hba_vid, "Emulex", HBA_IDLEN); 2083ef270ab1SKenneth D. Merry strncpy(cpi->dev_name, cam_sim_name(sim), DEV_IDLEN); 2084ef270ab1SKenneth D. Merry cpi->unit_number = cam_sim_unit(sim); 2085ef270ab1SKenneth D. Merry 2086ef270ab1SKenneth D. Merry cpi->ccb_h.status = CAM_REQ_CMP; 2087ef270ab1SKenneth D. Merry xpt_done(ccb); 2088ef270ab1SKenneth D. Merry break; 2089ef270ab1SKenneth D. Merry } 2090ef270ab1SKenneth D. Merry case XPT_GET_TRAN_SETTINGS: 2091ef270ab1SKenneth D. Merry { 2092ef270ab1SKenneth D. Merry struct ccb_trans_settings *cts = &ccb->cts; 2093ef270ab1SKenneth D. Merry struct ccb_trans_settings_scsi *scsi = &cts->proto_specific.scsi; 2094ef270ab1SKenneth D. Merry struct ccb_trans_settings_fc *fc = &cts->xport_specific.fc; 2095ef270ab1SKenneth D. Merry ocs_xport_stats_t value; 20966affb8ebSRam Kishore Vegesna ocs_fcport *fcp = FCPORT(ocs, bus); 2097b9732f78SRam Kishore Vegesna ocs_fc_target_t *tgt = NULL; 2098ef270ab1SKenneth D. Merry 2099ef270ab1SKenneth D. Merry if (ocs->ocs_xport != OCS_XPORT_FC) { 2100ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_INVALID); 2101ef270ab1SKenneth D. Merry xpt_done(ccb); 2102ef270ab1SKenneth D. Merry break; 2103ef270ab1SKenneth D. Merry } 2104ef270ab1SKenneth D. Merry 2105b9732f78SRam Kishore Vegesna if (cts->ccb_h.target_id > OCS_MAX_TARGETS) { 2106b9732f78SRam Kishore Vegesna ocs_set_ccb_status(ccb, CAM_DEV_NOT_THERE); 2107b9732f78SRam Kishore Vegesna xpt_done(ccb); 2108b9732f78SRam Kishore Vegesna break; 2109b9732f78SRam Kishore Vegesna } 2110b9732f78SRam Kishore Vegesna 2111b9732f78SRam Kishore Vegesna tgt = &fcp->tgt[cts->ccb_h.target_id]; 2112b9732f78SRam Kishore Vegesna if (tgt->state == OCS_TGT_STATE_NONE) { 2113ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_DEV_NOT_THERE); 2114ef270ab1SKenneth D. Merry xpt_done(ccb); 2115ef270ab1SKenneth D. Merry break; 2116ef270ab1SKenneth D. Merry } 2117ef270ab1SKenneth D. Merry 2118ef270ab1SKenneth D. Merry cts->protocol = PROTO_SCSI; 2119ef270ab1SKenneth D. Merry cts->protocol_version = SCSI_REV_SPC2; 2120ef270ab1SKenneth D. Merry cts->transport = XPORT_FC; 2121ef270ab1SKenneth D. Merry cts->transport_version = 2; 2122ef270ab1SKenneth D. Merry 2123ef270ab1SKenneth D. Merry scsi->valid = CTS_SCSI_VALID_TQ; 2124ef270ab1SKenneth D. Merry scsi->flags = CTS_SCSI_FLAGS_TAG_ENB; 2125ef270ab1SKenneth D. Merry 2126ef270ab1SKenneth D. Merry /* speed in Mbps */ 2127ef270ab1SKenneth D. Merry ocs_xport_status(ocs->xport, OCS_XPORT_LINK_SPEED, &value); 2128ef270ab1SKenneth D. Merry fc->bitrate = value.value * 100; 2129ef270ab1SKenneth D. Merry 2130b9732f78SRam Kishore Vegesna fc->wwpn = tgt->wwpn; 2131ef270ab1SKenneth D. Merry 2132b9732f78SRam Kishore Vegesna fc->wwnn = tgt->wwnn; 2133ef270ab1SKenneth D. Merry 2134b9732f78SRam Kishore Vegesna fc->port = tgt->port_id; 2135ef270ab1SKenneth D. Merry 2136ef270ab1SKenneth D. Merry fc->valid = CTS_FC_VALID_SPEED | 2137ef270ab1SKenneth D. Merry CTS_FC_VALID_WWPN | 2138ef270ab1SKenneth D. Merry CTS_FC_VALID_WWNN | 2139ef270ab1SKenneth D. Merry CTS_FC_VALID_PORT; 2140ef270ab1SKenneth D. Merry 2141ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP); 2142ef270ab1SKenneth D. Merry xpt_done(ccb); 2143ef270ab1SKenneth D. Merry break; 2144ef270ab1SKenneth D. Merry } 2145ef270ab1SKenneth D. Merry case XPT_SET_TRAN_SETTINGS: 2146ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP); 2147ef270ab1SKenneth D. Merry xpt_done(ccb); 2148ef270ab1SKenneth D. Merry break; 2149ef270ab1SKenneth D. Merry 2150ef270ab1SKenneth D. Merry case XPT_CALC_GEOMETRY: 2151ef270ab1SKenneth D. Merry cam_calc_geometry(&ccb->ccg, TRUE); 2152ef270ab1SKenneth D. Merry xpt_done(ccb); 2153ef270ab1SKenneth D. Merry break; 2154ef270ab1SKenneth D. Merry 2155ef270ab1SKenneth D. Merry case XPT_GET_SIM_KNOB: 2156ef270ab1SKenneth D. Merry { 2157ef270ab1SKenneth D. Merry struct ccb_sim_knob *knob = &ccb->knob; 2158ef270ab1SKenneth D. Merry uint64_t wwn = 0; 2159ef270ab1SKenneth D. Merry ocs_fcport *fcp = FCPORT(ocs, bus); 2160ef270ab1SKenneth D. Merry 2161ef270ab1SKenneth D. Merry if (ocs->ocs_xport != OCS_XPORT_FC) { 2162ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_INVALID); 2163ef270ab1SKenneth D. Merry xpt_done(ccb); 2164ef270ab1SKenneth D. Merry break; 2165ef270ab1SKenneth D. Merry } 2166ef270ab1SKenneth D. Merry 2167ef270ab1SKenneth D. Merry if (bus == 0) { 2168ef270ab1SKenneth D. Merry wwn = *((uint64_t *)ocs_scsi_get_property_ptr(ocs, 2169ef270ab1SKenneth D. Merry OCS_SCSI_WWNN)); 2170ef270ab1SKenneth D. Merry knob->xport_specific.fc.wwnn = be64toh(wwn); 2171ef270ab1SKenneth D. Merry 2172ef270ab1SKenneth D. Merry wwn = *((uint64_t *)ocs_scsi_get_property_ptr(ocs, 2173ef270ab1SKenneth D. Merry OCS_SCSI_WWPN)); 2174ef270ab1SKenneth D. Merry knob->xport_specific.fc.wwpn = be64toh(wwn); 2175ef270ab1SKenneth D. Merry } else { 2176ef270ab1SKenneth D. Merry knob->xport_specific.fc.wwnn = fcp->vport->wwnn; 2177ef270ab1SKenneth D. Merry knob->xport_specific.fc.wwpn = fcp->vport->wwpn; 2178ef270ab1SKenneth D. Merry } 2179ef270ab1SKenneth D. Merry 2180ef270ab1SKenneth D. Merry knob->xport_specific.fc.role = fcp->role; 2181ef270ab1SKenneth D. Merry knob->xport_specific.fc.valid = KNOB_VALID_ADDRESS | 2182ef270ab1SKenneth D. Merry KNOB_VALID_ROLE; 2183ef270ab1SKenneth D. Merry 2184ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP); 2185ef270ab1SKenneth D. Merry xpt_done(ccb); 2186ef270ab1SKenneth D. Merry break; 2187ef270ab1SKenneth D. Merry } 2188ef270ab1SKenneth D. Merry case XPT_SET_SIM_KNOB: 2189ef270ab1SKenneth D. Merry { 2190ef270ab1SKenneth D. Merry struct ccb_sim_knob *knob = &ccb->knob; 2191ef270ab1SKenneth D. Merry bool role_changed = FALSE; 2192ef270ab1SKenneth D. Merry ocs_fcport *fcp = FCPORT(ocs, bus); 2193ef270ab1SKenneth D. Merry 2194ef270ab1SKenneth D. Merry if (ocs->ocs_xport != OCS_XPORT_FC) { 2195ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_INVALID); 2196ef270ab1SKenneth D. Merry xpt_done(ccb); 2197ef270ab1SKenneth D. Merry break; 2198ef270ab1SKenneth D. Merry } 2199ef270ab1SKenneth D. Merry 2200ef270ab1SKenneth D. Merry if (knob->xport_specific.fc.valid & KNOB_VALID_ADDRESS) { 2201ef270ab1SKenneth D. Merry device_printf(ocs->dev, 2202ef270ab1SKenneth D. Merry "%s: XPT_SET_SIM_KNOB wwnn=%llx wwpn=%llx\n", 2203ef270ab1SKenneth D. Merry __func__, 2204ef270ab1SKenneth D. Merry (unsigned long long)knob->xport_specific.fc.wwnn, 2205ef270ab1SKenneth D. Merry (unsigned long long)knob->xport_specific.fc.wwpn); 2206ef270ab1SKenneth D. Merry } 2207ef270ab1SKenneth D. Merry 2208ef270ab1SKenneth D. Merry if (knob->xport_specific.fc.valid & KNOB_VALID_ROLE) { 2209ef270ab1SKenneth D. Merry switch (knob->xport_specific.fc.role) { 2210ef270ab1SKenneth D. Merry case KNOB_ROLE_NONE: 2211ef270ab1SKenneth D. Merry if (fcp->role != KNOB_ROLE_NONE) { 2212ef270ab1SKenneth D. Merry role_changed = TRUE; 2213ef270ab1SKenneth D. Merry } 2214ef270ab1SKenneth D. Merry break; 2215ef270ab1SKenneth D. Merry case KNOB_ROLE_TARGET: 2216ef270ab1SKenneth D. Merry if (fcp->role != KNOB_ROLE_TARGET) { 2217ef270ab1SKenneth D. Merry role_changed = TRUE; 2218ef270ab1SKenneth D. Merry } 2219ef270ab1SKenneth D. Merry break; 2220ef270ab1SKenneth D. Merry case KNOB_ROLE_INITIATOR: 2221ef270ab1SKenneth D. Merry if (fcp->role != KNOB_ROLE_INITIATOR) { 2222ef270ab1SKenneth D. Merry role_changed = TRUE; 2223ef270ab1SKenneth D. Merry } 2224ef270ab1SKenneth D. Merry break; 2225ef270ab1SKenneth D. Merry case KNOB_ROLE_BOTH: 2226ef270ab1SKenneth D. Merry if (fcp->role != KNOB_ROLE_BOTH) { 2227ef270ab1SKenneth D. Merry role_changed = TRUE; 2228ef270ab1SKenneth D. Merry } 2229ef270ab1SKenneth D. Merry break; 2230ef270ab1SKenneth D. Merry default: 2231ef270ab1SKenneth D. Merry device_printf(ocs->dev, 2232ef270ab1SKenneth D. Merry "%s: XPT_SET_SIM_KNOB unsupported role: %d\n", 2233ef270ab1SKenneth D. Merry __func__, knob->xport_specific.fc.role); 2234ef270ab1SKenneth D. Merry } 2235ef270ab1SKenneth D. Merry 2236ef270ab1SKenneth D. Merry if (role_changed) { 2237ef270ab1SKenneth D. Merry device_printf(ocs->dev, 2238ef270ab1SKenneth D. Merry "BUS:%d XPT_SET_SIM_KNOB old_role: %d new_role: %d\n", 2239ef270ab1SKenneth D. Merry bus, fcp->role, knob->xport_specific.fc.role); 2240ef270ab1SKenneth D. Merry 2241ef270ab1SKenneth D. Merry ocs_fcp_change_role(ocs, fcp, knob->xport_specific.fc.role); 2242ef270ab1SKenneth D. Merry } 2243ef270ab1SKenneth D. Merry } 2244ef270ab1SKenneth D. Merry 2245ef270ab1SKenneth D. Merry 2246ef270ab1SKenneth D. Merry 2247ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP); 2248ef270ab1SKenneth D. Merry xpt_done(ccb); 2249ef270ab1SKenneth D. Merry break; 2250ef270ab1SKenneth D. Merry } 2251ef270ab1SKenneth D. Merry case XPT_ABORT: 2252ef270ab1SKenneth D. Merry { 2253ef270ab1SKenneth D. Merry union ccb *accb = ccb->cab.abort_ccb; 2254ef270ab1SKenneth D. Merry 2255ef270ab1SKenneth D. Merry switch (accb->ccb_h.func_code) { 2256ef270ab1SKenneth D. Merry case XPT_ACCEPT_TARGET_IO: 2257ef270ab1SKenneth D. Merry ocs_abort_atio(ocs, ccb); 2258ef270ab1SKenneth D. Merry break; 2259ef270ab1SKenneth D. Merry case XPT_IMMEDIATE_NOTIFY: 2260ef270ab1SKenneth D. Merry ocs_abort_inot(ocs, ccb); 2261ef270ab1SKenneth D. Merry break; 2262ef270ab1SKenneth D. Merry case XPT_SCSI_IO: 2263ef270ab1SKenneth D. Merry rc = ocs_abort_initiator_io(ocs, accb); 2264ef270ab1SKenneth D. Merry if (rc) { 2265ef270ab1SKenneth D. Merry ccb->ccb_h.status = CAM_UA_ABORT; 2266ef270ab1SKenneth D. Merry } else { 2267ef270ab1SKenneth D. Merry ccb->ccb_h.status = CAM_REQ_CMP; 2268ef270ab1SKenneth D. Merry } 2269ef270ab1SKenneth D. Merry 2270ef270ab1SKenneth D. Merry break; 2271ef270ab1SKenneth D. Merry default: 2272ef270ab1SKenneth D. Merry printf("abort of unknown func %#x\n", 2273ef270ab1SKenneth D. Merry accb->ccb_h.func_code); 2274ef270ab1SKenneth D. Merry ccb->ccb_h.status = CAM_REQ_INVALID; 2275ef270ab1SKenneth D. Merry break; 2276ef270ab1SKenneth D. Merry } 2277ef270ab1SKenneth D. Merry break; 2278ef270ab1SKenneth D. Merry } 2279ef270ab1SKenneth D. Merry case XPT_RESET_BUS: 2280ef270ab1SKenneth D. Merry if (ocs_xport_control(ocs->xport, OCS_XPORT_PORT_OFFLINE) == 0) { 22814915e5c7SRam Kishore Vegesna rc = ocs_xport_control(ocs->xport, OCS_XPORT_PORT_ONLINE); 22824915e5c7SRam Kishore Vegesna if (rc) { 22834915e5c7SRam Kishore Vegesna ocs_log_debug(ocs, "Failed to bring port online" 22844915e5c7SRam Kishore Vegesna " : %d\n", rc); 22854915e5c7SRam Kishore Vegesna } 2286ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP); 2287ef270ab1SKenneth D. Merry } else { 2288ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP_ERR); 2289ef270ab1SKenneth D. Merry } 2290ef270ab1SKenneth D. Merry xpt_done(ccb); 2291ef270ab1SKenneth D. Merry break; 2292ef270ab1SKenneth D. Merry case XPT_RESET_DEV: 2293ef270ab1SKenneth D. Merry { 2294ef270ab1SKenneth D. Merry ocs_node_t *node = NULL; 2295ef270ab1SKenneth D. Merry ocs_io_t *io = NULL; 2296ef270ab1SKenneth D. Merry int32_t rc = 0; 22976affb8ebSRam Kishore Vegesna ocs_fcport *fcp = FCPORT(ocs, bus); 2298ef270ab1SKenneth D. Merry 22996affb8ebSRam Kishore Vegesna node = ocs_node_get_instance(ocs, fcp->tgt[ccb_h->target_id].node_id); 2300ef270ab1SKenneth D. Merry if (node == NULL) { 2301ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: no device %d\n", 2302ef270ab1SKenneth D. Merry __func__, ccb_h->target_id); 2303ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_DEV_NOT_THERE); 2304ef270ab1SKenneth D. Merry xpt_done(ccb); 2305ef270ab1SKenneth D. Merry break; 2306ef270ab1SKenneth D. Merry } 2307ef270ab1SKenneth D. Merry 2308ef270ab1SKenneth D. Merry io = ocs_scsi_io_alloc(node, OCS_SCSI_IO_ROLE_ORIGINATOR); 2309ef270ab1SKenneth D. Merry if (io == NULL) { 2310ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: unable to alloc IO\n", 2311ef270ab1SKenneth D. Merry __func__); 2312ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP_ERR); 2313ef270ab1SKenneth D. Merry xpt_done(ccb); 2314ef270ab1SKenneth D. Merry break; 2315ef270ab1SKenneth D. Merry } 2316ef270ab1SKenneth D. Merry 2317ef270ab1SKenneth D. Merry rc = ocs_scsi_send_tmf(node, io, NULL, ccb_h->target_lun, 2318ef270ab1SKenneth D. Merry OCS_SCSI_TMF_LOGICAL_UNIT_RESET, 2319ef270ab1SKenneth D. Merry NULL, 0, 0, /* sgl, sgl_count, length */ 2320ef270ab1SKenneth D. Merry ocs_initiator_tmf_cb, NULL/*arg*/); 2321ef270ab1SKenneth D. Merry 2322ef270ab1SKenneth D. Merry if (rc) { 2323ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP_ERR); 2324ef270ab1SKenneth D. Merry } else { 2325ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP); 2326ef270ab1SKenneth D. Merry } 2327ef270ab1SKenneth D. Merry 2328ef270ab1SKenneth D. Merry if (node->fcp2device) { 2329ef270ab1SKenneth D. Merry ocs_reset_crn(node, ccb_h->target_lun); 2330ef270ab1SKenneth D. Merry } 2331ef270ab1SKenneth D. Merry 2332ef270ab1SKenneth D. Merry xpt_done(ccb); 2333ef270ab1SKenneth D. Merry break; 2334ef270ab1SKenneth D. Merry } 2335ef270ab1SKenneth D. Merry case XPT_EN_LUN: /* target support */ 2336ef270ab1SKenneth D. Merry { 2337ef270ab1SKenneth D. Merry ocs_tgt_resource_t *trsrc = NULL; 2338ef270ab1SKenneth D. Merry uint32_t status = 0; 2339ef270ab1SKenneth D. Merry ocs_fcport *fcp = FCPORT(ocs, bus); 2340ef270ab1SKenneth D. Merry 2341ef270ab1SKenneth D. Merry device_printf(ocs->dev, "XPT_EN_LUN %sable %d:%d\n", 2342ef270ab1SKenneth D. Merry ccb->cel.enable ? "en" : "dis", 2343ef270ab1SKenneth D. Merry ccb->ccb_h.target_id, 2344ef270ab1SKenneth D. Merry (unsigned int)ccb->ccb_h.target_lun); 2345ef270ab1SKenneth D. Merry 2346ef270ab1SKenneth D. Merry trsrc = ocs_tgt_resource_get(fcp, &ccb->ccb_h, &status); 2347ef270ab1SKenneth D. Merry if (trsrc) { 2348ef270ab1SKenneth D. Merry trsrc->enabled = ccb->cel.enable; 2349ef270ab1SKenneth D. Merry 2350ef270ab1SKenneth D. Merry /* Abort all ATIO/INOT on LUN disable */ 2351ef270ab1SKenneth D. Merry if (trsrc->enabled == FALSE) { 2352ef270ab1SKenneth D. Merry ocs_tgt_resource_abort(ocs, trsrc); 2353ef270ab1SKenneth D. Merry } else { 2354ef270ab1SKenneth D. Merry STAILQ_INIT(&trsrc->atio); 2355ef270ab1SKenneth D. Merry STAILQ_INIT(&trsrc->inot); 2356ef270ab1SKenneth D. Merry } 2357ef270ab1SKenneth D. Merry status = CAM_REQ_CMP; 2358ef270ab1SKenneth D. Merry } 2359ef270ab1SKenneth D. Merry 2360ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, status); 2361ef270ab1SKenneth D. Merry xpt_done(ccb); 2362ef270ab1SKenneth D. Merry break; 2363ef270ab1SKenneth D. Merry } 2364ef270ab1SKenneth D. Merry /* 2365ef270ab1SKenneth D. Merry * The flow of target IOs in CAM is: 2366ef270ab1SKenneth D. Merry * - CAM supplies a number of CCBs to the driver used for received 2367ef270ab1SKenneth D. Merry * commands. 2368ef270ab1SKenneth D. Merry * - when the driver receives a command, it copies the relevant 2369ef270ab1SKenneth D. Merry * information to the CCB and returns it to the CAM using xpt_done() 2370ef270ab1SKenneth D. Merry * - after the target server processes the request, it creates 2371ef270ab1SKenneth D. Merry * a new CCB containing information on how to continue the IO and 2372ef270ab1SKenneth D. Merry * passes that to the driver 2373ef270ab1SKenneth D. Merry * - the driver processes the "continue IO" (a.k.a CTIO) CCB 2374ef270ab1SKenneth D. Merry * - once the IO completes, the driver returns the CTIO to the CAM 2375ef270ab1SKenneth D. Merry * using xpt_done() 2376ef270ab1SKenneth D. Merry */ 2377ef270ab1SKenneth D. Merry case XPT_ACCEPT_TARGET_IO: /* used to inform upper layer of 2378ef270ab1SKenneth D. Merry received CDB (a.k.a. ATIO) */ 2379ef270ab1SKenneth D. Merry case XPT_IMMEDIATE_NOTIFY: /* used to inform upper layer of other 2380ef270ab1SKenneth D. Merry event (a.k.a. INOT) */ 2381ef270ab1SKenneth D. Merry { 2382ef270ab1SKenneth D. Merry ocs_tgt_resource_t *trsrc = NULL; 2383ef270ab1SKenneth D. Merry uint32_t status = 0; 2384ef270ab1SKenneth D. Merry ocs_fcport *fcp = FCPORT(ocs, bus); 2385ef270ab1SKenneth D. Merry 2386ef270ab1SKenneth D. Merry /*printf("XPT_%s %p\n", ccb_h->func_code == XPT_ACCEPT_TARGET_IO ? 2387ef270ab1SKenneth D. Merry "ACCEPT_TARGET_IO" : "IMMEDIATE_NOTIFY", ccb);*/ 2388ef270ab1SKenneth D. Merry trsrc = ocs_tgt_resource_get(fcp, &ccb->ccb_h, &status); 2389ef270ab1SKenneth D. Merry if (trsrc == NULL) { 2390ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_DEV_NOT_THERE); 2391ef270ab1SKenneth D. Merry xpt_done(ccb); 2392ef270ab1SKenneth D. Merry break; 2393ef270ab1SKenneth D. Merry } 2394ef270ab1SKenneth D. Merry 2395ef270ab1SKenneth D. Merry if (XPT_ACCEPT_TARGET_IO == ccb->ccb_h.func_code) { 2396ef270ab1SKenneth D. Merry struct ccb_accept_tio *atio = NULL; 2397ef270ab1SKenneth D. Merry 2398ef270ab1SKenneth D. Merry atio = (struct ccb_accept_tio *)ccb; 2399ef270ab1SKenneth D. Merry atio->init_id = 0x0badbeef; 2400ef270ab1SKenneth D. Merry atio->tag_id = 0xdeadc0de; 2401ef270ab1SKenneth D. Merry 2402ef270ab1SKenneth D. Merry STAILQ_INSERT_TAIL(&trsrc->atio, &ccb->ccb_h, 2403ef270ab1SKenneth D. Merry sim_links.stqe); 2404ef270ab1SKenneth D. Merry } else { 2405ef270ab1SKenneth D. Merry STAILQ_INSERT_TAIL(&trsrc->inot, &ccb->ccb_h, 2406ef270ab1SKenneth D. Merry sim_links.stqe); 2407ef270ab1SKenneth D. Merry } 2408ef270ab1SKenneth D. Merry ccb->ccb_h.ccb_io_ptr = NULL; 2409ef270ab1SKenneth D. Merry ccb->ccb_h.ccb_ocs_ptr = ocs; 2410ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_INPROG); 2411ef270ab1SKenneth D. Merry /* 2412ef270ab1SKenneth D. Merry * These actions give resources to the target driver. 2413ef270ab1SKenneth D. Merry * If we didn't return here, this function would call 2414ef270ab1SKenneth D. Merry * xpt_done(), signaling to the upper layers that an 2415ef270ab1SKenneth D. Merry * IO or other event had arrived. 2416ef270ab1SKenneth D. Merry */ 2417ef270ab1SKenneth D. Merry break; 2418ef270ab1SKenneth D. Merry } 2419ef270ab1SKenneth D. Merry case XPT_NOTIFY_ACKNOWLEDGE: 2420ef270ab1SKenneth D. Merry { 2421ef270ab1SKenneth D. Merry ocs_io_t *io = NULL; 2422ef270ab1SKenneth D. Merry ocs_io_t *abortio = NULL; 2423ef270ab1SKenneth D. Merry 2424ef270ab1SKenneth D. Merry /* Get the IO reference for this tag */ 2425ef270ab1SKenneth D. Merry io = ocs_scsi_find_io(ocs, ccb->cna2.tag_id); 2426ef270ab1SKenneth D. Merry if (io == NULL) { 2427ef270ab1SKenneth D. Merry device_printf(ocs->dev, 2428ef270ab1SKenneth D. Merry "%s: XPT_NOTIFY_ACKNOWLEDGE no IO with tag %#x\n", 2429ef270ab1SKenneth D. Merry __func__, ccb->cna2.tag_id); 2430ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP_ERR); 2431ef270ab1SKenneth D. Merry xpt_done(ccb); 2432ef270ab1SKenneth D. Merry break; 2433ef270ab1SKenneth D. Merry } 2434ef270ab1SKenneth D. Merry 2435ef270ab1SKenneth D. Merry abortio = io->tgt_io.app; 2436ef270ab1SKenneth D. Merry if (abortio) { 2437ef270ab1SKenneth D. Merry abortio->tgt_io.flags &= ~OCS_CAM_IO_F_ABORT_NOTIFY; 2438ef270ab1SKenneth D. Merry device_printf(ocs->dev, 2439ef270ab1SKenneth D. Merry "%s: XPT_NOTIFY_ACK state=%d tag=%#x xid=%#x" 2440ef270ab1SKenneth D. Merry " flags=%#x\n", __func__, abortio->tgt_io.state, 2441ef270ab1SKenneth D. Merry abortio->tag, abortio->init_task_tag, 2442ef270ab1SKenneth D. Merry abortio->tgt_io.flags); 2443ef270ab1SKenneth D. Merry /* TMF response was sent in abort callback */ 2444ef270ab1SKenneth D. Merry } else { 2445ef270ab1SKenneth D. Merry ocs_scsi_send_tmf_resp(io, 2446ef270ab1SKenneth D. Merry OCS_SCSI_TMF_FUNCTION_COMPLETE, 2447ef270ab1SKenneth D. Merry NULL, ocs_target_tmf_cb, NULL); 2448ef270ab1SKenneth D. Merry } 2449ef270ab1SKenneth D. Merry 2450ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP); 2451ef270ab1SKenneth D. Merry xpt_done(ccb); 2452ef270ab1SKenneth D. Merry break; 2453ef270ab1SKenneth D. Merry } 2454ef270ab1SKenneth D. Merry case XPT_CONT_TARGET_IO: /* continue target IO, sending data/response (a.k.a. CTIO) */ 2455ef270ab1SKenneth D. Merry if (ocs_target_io(ocs, ccb)) { 2456ef270ab1SKenneth D. Merry device_printf(ocs->dev, 2457ef270ab1SKenneth D. Merry "XPT_CONT_TARGET_IO failed flags=%x tag=%#x\n", 2458ef270ab1SKenneth D. Merry ccb->ccb_h.flags, ccb->csio.tag_id); 2459ef270ab1SKenneth D. Merry xpt_done(ccb); 2460ef270ab1SKenneth D. Merry } 2461ef270ab1SKenneth D. Merry break; 2462ef270ab1SKenneth D. Merry default: 2463ef270ab1SKenneth D. Merry device_printf(ocs->dev, "unhandled func_code = %#x\n", 2464ef270ab1SKenneth D. Merry ccb_h->func_code); 2465ef270ab1SKenneth D. Merry ccb_h->status = CAM_REQ_INVALID; 2466ef270ab1SKenneth D. Merry xpt_done(ccb); 2467ef270ab1SKenneth D. Merry break; 2468ef270ab1SKenneth D. Merry } 2469ef270ab1SKenneth D. Merry } 2470ef270ab1SKenneth D. Merry 2471ef270ab1SKenneth D. Merry /** 2472ef270ab1SKenneth D. Merry * @ingroup cam_api 2473ef270ab1SKenneth D. Merry * @brief Process events 2474ef270ab1SKenneth D. Merry * 2475ef270ab1SKenneth D. Merry * @param sim pointer to the SCSI Interface Module 2476ef270ab1SKenneth D. Merry * 2477ef270ab1SKenneth D. Merry */ 2478ef270ab1SKenneth D. Merry static void 2479ef270ab1SKenneth D. Merry ocs_poll(struct cam_sim *sim) 2480ef270ab1SKenneth D. Merry { 2481ef270ab1SKenneth D. Merry printf("%s\n", __func__); 2482ef270ab1SKenneth D. Merry } 2483ef270ab1SKenneth D. Merry 2484ef270ab1SKenneth D. Merry static int32_t 2485ef270ab1SKenneth D. Merry ocs_initiator_tmf_cb(ocs_io_t *io, ocs_scsi_io_status_e scsi_status, 2486ef270ab1SKenneth D. Merry ocs_scsi_cmd_resp_t *rsp, uint32_t flags, void *arg) 2487ef270ab1SKenneth D. Merry { 2488ef270ab1SKenneth D. Merry int32_t rc = 0; 2489ef270ab1SKenneth D. Merry 2490ef270ab1SKenneth D. Merry switch (scsi_status) { 2491ef270ab1SKenneth D. Merry case OCS_SCSI_STATUS_GOOD: 2492ef270ab1SKenneth D. Merry case OCS_SCSI_STATUS_NO_IO: 2493ef270ab1SKenneth D. Merry break; 2494ef270ab1SKenneth D. Merry case OCS_SCSI_STATUS_CHECK_RESPONSE: 2495ef270ab1SKenneth D. Merry if (rsp->response_data_length == 0) { 2496ef270ab1SKenneth D. Merry ocs_log_test(io->ocs, "check response without data?!?\n"); 2497ef270ab1SKenneth D. Merry rc = -1; 2498ef270ab1SKenneth D. Merry break; 2499ef270ab1SKenneth D. Merry } 2500ef270ab1SKenneth D. Merry 2501ef270ab1SKenneth D. Merry if (rsp->response_data[3] != 0) { 2502ef270ab1SKenneth D. Merry ocs_log_test(io->ocs, "TMF status %08x\n", 2503ef270ab1SKenneth D. Merry be32toh(*((uint32_t *)rsp->response_data))); 2504ef270ab1SKenneth D. Merry rc = -1; 2505ef270ab1SKenneth D. Merry break; 2506ef270ab1SKenneth D. Merry } 2507ef270ab1SKenneth D. Merry break; 2508ef270ab1SKenneth D. Merry default: 2509ef270ab1SKenneth D. Merry ocs_log_test(io->ocs, "status=%#x\n", scsi_status); 2510ef270ab1SKenneth D. Merry rc = -1; 2511ef270ab1SKenneth D. Merry } 2512ef270ab1SKenneth D. Merry 2513ef270ab1SKenneth D. Merry ocs_scsi_io_free(io); 2514ef270ab1SKenneth D. Merry 2515ef270ab1SKenneth D. Merry return rc; 2516ef270ab1SKenneth D. Merry } 2517ef270ab1SKenneth D. Merry 2518ef270ab1SKenneth D. Merry /** 2519ef270ab1SKenneth D. Merry * @brief lookup target resource structure 2520ef270ab1SKenneth D. Merry * 2521ef270ab1SKenneth D. Merry * Arbitrarily support 2522ef270ab1SKenneth D. Merry * - wildcard target ID + LU 2523ef270ab1SKenneth D. Merry * - 0 target ID + non-wildcard LU 2524ef270ab1SKenneth D. Merry * 2525ef270ab1SKenneth D. Merry * @param ocs the driver instance's software context 2526ef270ab1SKenneth D. Merry * @param ccb_h pointer to the CCB header 2527ef270ab1SKenneth D. Merry * @param status returned status value 2528ef270ab1SKenneth D. Merry * 2529ef270ab1SKenneth D. Merry * @return pointer to the target resource, NULL if none available (e.g. if LU 2530ef270ab1SKenneth D. Merry * is not enabled) 2531ef270ab1SKenneth D. Merry */ 2532ef270ab1SKenneth D. Merry static ocs_tgt_resource_t *ocs_tgt_resource_get(ocs_fcport *fcp, 2533ef270ab1SKenneth D. Merry struct ccb_hdr *ccb_h, uint32_t *status) 2534ef270ab1SKenneth D. Merry { 2535ef270ab1SKenneth D. Merry target_id_t tid = ccb_h->target_id; 2536ef270ab1SKenneth D. Merry lun_id_t lun = ccb_h->target_lun; 2537ef270ab1SKenneth D. Merry 2538ef270ab1SKenneth D. Merry if (CAM_TARGET_WILDCARD == tid) { 2539ef270ab1SKenneth D. Merry if (CAM_LUN_WILDCARD != lun) { 2540ef270ab1SKenneth D. Merry *status = CAM_LUN_INVALID; 2541ef270ab1SKenneth D. Merry return NULL; 2542ef270ab1SKenneth D. Merry } 2543ef270ab1SKenneth D. Merry return &fcp->targ_rsrc_wildcard; 2544ef270ab1SKenneth D. Merry } else { 2545ef270ab1SKenneth D. Merry if (lun < OCS_MAX_LUN) { 2546ef270ab1SKenneth D. Merry return &fcp->targ_rsrc[lun]; 2547ef270ab1SKenneth D. Merry } else { 2548ef270ab1SKenneth D. Merry *status = CAM_LUN_INVALID; 2549ef270ab1SKenneth D. Merry return NULL; 2550ef270ab1SKenneth D. Merry } 2551ef270ab1SKenneth D. Merry } 2552ef270ab1SKenneth D. Merry 2553ef270ab1SKenneth D. Merry } 2554ef270ab1SKenneth D. Merry 2555ef270ab1SKenneth D. Merry static int32_t 2556ef270ab1SKenneth D. Merry ocs_tgt_resource_abort(struct ocs_softc *ocs, ocs_tgt_resource_t *trsrc) 2557ef270ab1SKenneth D. Merry { 2558ef270ab1SKenneth D. Merry union ccb *ccb = NULL; 2559ef270ab1SKenneth D. Merry uint32_t count; 2560ef270ab1SKenneth D. Merry 2561ef270ab1SKenneth D. Merry count = 0; 2562ef270ab1SKenneth D. Merry do { 2563ef270ab1SKenneth D. Merry ccb = (union ccb *)STAILQ_FIRST(&trsrc->atio); 2564ef270ab1SKenneth D. Merry if (ccb) { 2565ef270ab1SKenneth D. Merry STAILQ_REMOVE_HEAD(&trsrc->atio, sim_links.stqe); 2566ef270ab1SKenneth D. Merry ccb->ccb_h.status = CAM_REQ_ABORTED; 2567ef270ab1SKenneth D. Merry xpt_done(ccb); 2568ef270ab1SKenneth D. Merry count++; 2569ef270ab1SKenneth D. Merry } 2570ef270ab1SKenneth D. Merry } while (ccb); 2571ef270ab1SKenneth D. Merry 2572ef270ab1SKenneth D. Merry count = 0; 2573ef270ab1SKenneth D. Merry do { 2574ef270ab1SKenneth D. Merry ccb = (union ccb *)STAILQ_FIRST(&trsrc->inot); 2575ef270ab1SKenneth D. Merry if (ccb) { 2576ef270ab1SKenneth D. Merry STAILQ_REMOVE_HEAD(&trsrc->inot, sim_links.stqe); 2577ef270ab1SKenneth D. Merry ccb->ccb_h.status = CAM_REQ_ABORTED; 2578ef270ab1SKenneth D. Merry xpt_done(ccb); 2579ef270ab1SKenneth D. Merry count++; 2580ef270ab1SKenneth D. Merry } 2581ef270ab1SKenneth D. Merry } while (ccb); 2582ef270ab1SKenneth D. Merry 2583ef270ab1SKenneth D. Merry return 0; 2584ef270ab1SKenneth D. Merry } 2585ef270ab1SKenneth D. Merry 2586ef270ab1SKenneth D. Merry static void 2587ef270ab1SKenneth D. Merry ocs_abort_atio(struct ocs_softc *ocs, union ccb *ccb) 2588ef270ab1SKenneth D. Merry { 2589ef270ab1SKenneth D. Merry 2590ef270ab1SKenneth D. Merry ocs_io_t *aio = NULL; 2591ef270ab1SKenneth D. Merry ocs_tgt_resource_t *trsrc = NULL; 2592ef270ab1SKenneth D. Merry uint32_t status = CAM_REQ_INVALID; 2593ef270ab1SKenneth D. Merry struct ccb_hdr *cur = NULL; 2594ef270ab1SKenneth D. Merry union ccb *accb = ccb->cab.abort_ccb; 2595ef270ab1SKenneth D. Merry 2596ef270ab1SKenneth D. Merry int bus = cam_sim_bus(xpt_path_sim((ccb)->ccb_h.path)); 2597ef270ab1SKenneth D. Merry ocs_fcport *fcp = FCPORT(ocs, bus); 2598ef270ab1SKenneth D. Merry 2599ef270ab1SKenneth D. Merry trsrc = ocs_tgt_resource_get(fcp, &accb->ccb_h, &status); 2600ef270ab1SKenneth D. Merry if (trsrc != NULL) { 2601ef270ab1SKenneth D. Merry STAILQ_FOREACH(cur, &trsrc->atio, sim_links.stqe) { 2602ef270ab1SKenneth D. Merry if (cur != &accb->ccb_h) 2603ef270ab1SKenneth D. Merry continue; 2604ef270ab1SKenneth D. Merry 2605ef270ab1SKenneth D. Merry STAILQ_REMOVE(&trsrc->atio, cur, ccb_hdr, 2606ef270ab1SKenneth D. Merry sim_links.stqe); 2607ef270ab1SKenneth D. Merry accb->ccb_h.status = CAM_REQ_ABORTED; 2608ef270ab1SKenneth D. Merry xpt_done(accb); 2609ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP); 2610ef270ab1SKenneth D. Merry return; 2611ef270ab1SKenneth D. Merry } 2612ef270ab1SKenneth D. Merry } 2613ef270ab1SKenneth D. Merry 2614ef270ab1SKenneth D. Merry /* if the ATIO has a valid IO pointer, CAM is telling 2615ef270ab1SKenneth D. Merry * the driver that the ATIO (which represents the entire 2616ef270ab1SKenneth D. Merry * exchange) has been aborted. */ 2617ef270ab1SKenneth D. Merry 2618ef270ab1SKenneth D. Merry aio = accb->ccb_h.ccb_io_ptr; 2619ef270ab1SKenneth D. Merry if (aio == NULL) { 2620ef270ab1SKenneth D. Merry ccb->ccb_h.status = CAM_UA_ABORT; 2621ef270ab1SKenneth D. Merry return; 2622ef270ab1SKenneth D. Merry } 2623ef270ab1SKenneth D. Merry 2624ef270ab1SKenneth D. Merry device_printf(ocs->dev, 2625ef270ab1SKenneth D. Merry "%s: XPT_ABORT ATIO state=%d tag=%#x" 2626ef270ab1SKenneth D. Merry " xid=%#x flags=%#x\n", __func__, 2627ef270ab1SKenneth D. Merry aio->tgt_io.state, aio->tag, 2628ef270ab1SKenneth D. Merry aio->init_task_tag, aio->tgt_io.flags); 2629ef270ab1SKenneth D. Merry /* Expectations are: 2630ef270ab1SKenneth D. Merry * - abort task was received 2631ef270ab1SKenneth D. Merry * - already aborted IO in the DEVICE 2632ef270ab1SKenneth D. Merry * - already received NOTIFY ACKNOWLEDGE */ 2633ef270ab1SKenneth D. Merry 2634ef270ab1SKenneth D. Merry if ((aio->tgt_io.flags & OCS_CAM_IO_F_ABORT_RECV) == 0) { 2635ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: abort not received or io completed \n", __func__); 2636ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP); 2637ef270ab1SKenneth D. Merry return; 2638ef270ab1SKenneth D. Merry } 2639ef270ab1SKenneth D. Merry 2640ef270ab1SKenneth D. Merry aio->tgt_io.flags |= OCS_CAM_IO_F_ABORT_CAM; 2641ef270ab1SKenneth D. Merry ocs_target_io_free(aio); 2642ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP); 2643ef270ab1SKenneth D. Merry 2644ef270ab1SKenneth D. Merry return; 2645ef270ab1SKenneth D. Merry } 2646ef270ab1SKenneth D. Merry 2647ef270ab1SKenneth D. Merry static void 2648ef270ab1SKenneth D. Merry ocs_abort_inot(struct ocs_softc *ocs, union ccb *ccb) 2649ef270ab1SKenneth D. Merry { 2650ef270ab1SKenneth D. Merry ocs_tgt_resource_t *trsrc = NULL; 2651ef270ab1SKenneth D. Merry uint32_t status = CAM_REQ_INVALID; 2652ef270ab1SKenneth D. Merry struct ccb_hdr *cur = NULL; 2653ef270ab1SKenneth D. Merry union ccb *accb = ccb->cab.abort_ccb; 2654ef270ab1SKenneth D. Merry 2655ef270ab1SKenneth D. Merry int bus = cam_sim_bus(xpt_path_sim((ccb)->ccb_h.path)); 2656ef270ab1SKenneth D. Merry ocs_fcport *fcp = FCPORT(ocs, bus); 2657ef270ab1SKenneth D. Merry 2658ef270ab1SKenneth D. Merry trsrc = ocs_tgt_resource_get(fcp, &accb->ccb_h, &status); 2659ef270ab1SKenneth D. Merry if (trsrc) { 2660ef270ab1SKenneth D. Merry STAILQ_FOREACH(cur, &trsrc->inot, sim_links.stqe) { 2661ef270ab1SKenneth D. Merry if (cur != &accb->ccb_h) 2662ef270ab1SKenneth D. Merry continue; 2663ef270ab1SKenneth D. Merry 2664ef270ab1SKenneth D. Merry STAILQ_REMOVE(&trsrc->inot, cur, ccb_hdr, 2665ef270ab1SKenneth D. Merry sim_links.stqe); 2666ef270ab1SKenneth D. Merry accb->ccb_h.status = CAM_REQ_ABORTED; 2667ef270ab1SKenneth D. Merry xpt_done(accb); 2668ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_REQ_CMP); 2669ef270ab1SKenneth D. Merry return; 2670ef270ab1SKenneth D. Merry } 2671ef270ab1SKenneth D. Merry } 2672ef270ab1SKenneth D. Merry 2673ef270ab1SKenneth D. Merry ocs_set_ccb_status(ccb, CAM_UA_ABORT); 2674ef270ab1SKenneth D. Merry return; 2675ef270ab1SKenneth D. Merry } 2676ef270ab1SKenneth D. Merry 2677ef270ab1SKenneth D. Merry static uint32_t 2678ef270ab1SKenneth D. Merry ocs_abort_initiator_io(struct ocs_softc *ocs, union ccb *accb) 2679ef270ab1SKenneth D. Merry { 2680ef270ab1SKenneth D. Merry 2681ef270ab1SKenneth D. Merry ocs_node_t *node = NULL; 2682ef270ab1SKenneth D. Merry ocs_io_t *io = NULL; 2683ef270ab1SKenneth D. Merry int32_t rc = 0; 2684ef270ab1SKenneth D. Merry struct ccb_scsiio *csio = &accb->csio; 2685ef270ab1SKenneth D. Merry 26866affb8ebSRam Kishore Vegesna ocs_fcport *fcp = FCPORT(ocs, cam_sim_bus(xpt_path_sim((accb)->ccb_h.path))); 26876affb8ebSRam Kishore Vegesna node = ocs_node_get_instance(ocs, fcp->tgt[accb->ccb_h.target_id].node_id); 2688ef270ab1SKenneth D. Merry if (node == NULL) { 2689ef270ab1SKenneth D. Merry device_printf(ocs->dev, "%s: no device %d\n", 2690ef270ab1SKenneth D. Merry __func__, accb->ccb_h.target_id); 2691ef270ab1SKenneth D. Merry ocs_set_ccb_status(accb, CAM_DEV_NOT_THERE); 2692ef270ab1SKenneth D. Merry xpt_done(accb); 2693ef270ab1SKenneth D. Merry return (-1); 2694ef270ab1SKenneth D. Merry } 2695ef270ab1SKenneth D. Merry 2696ef270ab1SKenneth D. Merry io = ocs_scsi_io_alloc(node, OCS_SCSI_IO_ROLE_ORIGINATOR); 2697ef270ab1SKenneth D. Merry if (io == NULL) { 2698ef270ab1SKenneth D. Merry device_printf(ocs->dev, 2699ef270ab1SKenneth D. Merry "%s: unable to alloc IO\n", __func__); 2700ef270ab1SKenneth D. Merry ocs_set_ccb_status(accb, CAM_REQ_CMP_ERR); 2701ef270ab1SKenneth D. Merry xpt_done(accb); 2702ef270ab1SKenneth D. Merry return (-1); 2703ef270ab1SKenneth D. Merry } 2704ef270ab1SKenneth D. Merry 2705ef270ab1SKenneth D. Merry rc = ocs_scsi_send_tmf(node, io, 2706ef270ab1SKenneth D. Merry (ocs_io_t *)csio->ccb_h.ccb_io_ptr, 2707ef270ab1SKenneth D. Merry accb->ccb_h.target_lun, 2708ef270ab1SKenneth D. Merry OCS_SCSI_TMF_ABORT_TASK, 2709ef270ab1SKenneth D. Merry NULL, 0, 0, 2710ef270ab1SKenneth D. Merry ocs_initiator_tmf_cb, NULL/*arg*/); 2711ef270ab1SKenneth D. Merry 2712ef270ab1SKenneth D. Merry return rc; 2713ef270ab1SKenneth D. Merry } 2714ef270ab1SKenneth D. Merry 2715ef270ab1SKenneth D. Merry void 2716ef270ab1SKenneth D. Merry ocs_scsi_ini_ddump(ocs_textbuf_t *textbuf, ocs_scsi_ddump_type_e type, void *obj) 2717ef270ab1SKenneth D. Merry { 2718ef270ab1SKenneth D. Merry switch(type) { 2719ef270ab1SKenneth D. Merry case OCS_SCSI_DDUMP_DEVICE: { 2720ef270ab1SKenneth D. Merry //ocs_t *ocs = obj; 2721ef270ab1SKenneth D. Merry break; 2722ef270ab1SKenneth D. Merry } 2723ef270ab1SKenneth D. Merry case OCS_SCSI_DDUMP_DOMAIN: { 2724ef270ab1SKenneth D. Merry //ocs_domain_t *domain = obj; 2725ef270ab1SKenneth D. Merry break; 2726ef270ab1SKenneth D. Merry } 2727ef270ab1SKenneth D. Merry case OCS_SCSI_DDUMP_SPORT: { 2728ef270ab1SKenneth D. Merry //ocs_sport_t *sport = obj; 2729ef270ab1SKenneth D. Merry break; 2730ef270ab1SKenneth D. Merry } 2731ef270ab1SKenneth D. Merry case OCS_SCSI_DDUMP_NODE: { 2732ef270ab1SKenneth D. Merry //ocs_node_t *node = obj; 2733ef270ab1SKenneth D. Merry break; 2734ef270ab1SKenneth D. Merry } 2735ef270ab1SKenneth D. Merry case OCS_SCSI_DDUMP_IO: { 2736ef270ab1SKenneth D. Merry //ocs_io_t *io = obj; 2737ef270ab1SKenneth D. Merry break; 2738ef270ab1SKenneth D. Merry } 2739ef270ab1SKenneth D. Merry default: { 2740ef270ab1SKenneth D. Merry break; 2741ef270ab1SKenneth D. Merry } 2742ef270ab1SKenneth D. Merry } 2743ef270ab1SKenneth D. Merry } 2744ef270ab1SKenneth D. Merry 2745ef270ab1SKenneth D. Merry void 2746ef270ab1SKenneth D. Merry ocs_scsi_tgt_ddump(ocs_textbuf_t *textbuf, ocs_scsi_ddump_type_e type, void *obj) 2747ef270ab1SKenneth D. Merry { 2748ef270ab1SKenneth D. Merry switch(type) { 2749ef270ab1SKenneth D. Merry case OCS_SCSI_DDUMP_DEVICE: { 2750ef270ab1SKenneth D. Merry //ocs_t *ocs = obj; 2751ef270ab1SKenneth D. Merry break; 2752ef270ab1SKenneth D. Merry } 2753ef270ab1SKenneth D. Merry case OCS_SCSI_DDUMP_DOMAIN: { 2754ef270ab1SKenneth D. Merry //ocs_domain_t *domain = obj; 2755ef270ab1SKenneth D. Merry break; 2756ef270ab1SKenneth D. Merry } 2757ef270ab1SKenneth D. Merry case OCS_SCSI_DDUMP_SPORT: { 2758ef270ab1SKenneth D. Merry //ocs_sport_t *sport = obj; 2759ef270ab1SKenneth D. Merry break; 2760ef270ab1SKenneth D. Merry } 2761ef270ab1SKenneth D. Merry case OCS_SCSI_DDUMP_NODE: { 2762ef270ab1SKenneth D. Merry //ocs_node_t *node = obj; 2763ef270ab1SKenneth D. Merry break; 2764ef270ab1SKenneth D. Merry } 2765ef270ab1SKenneth D. Merry case OCS_SCSI_DDUMP_IO: { 2766ef270ab1SKenneth D. Merry ocs_io_t *io = obj; 2767ef270ab1SKenneth D. Merry char *state_str = NULL; 2768ef270ab1SKenneth D. Merry 2769ef270ab1SKenneth D. Merry switch (io->tgt_io.state) { 2770ef270ab1SKenneth D. Merry case OCS_CAM_IO_FREE: 2771ef270ab1SKenneth D. Merry state_str = "FREE"; 2772ef270ab1SKenneth D. Merry break; 2773ef270ab1SKenneth D. Merry case OCS_CAM_IO_COMMAND: 2774ef270ab1SKenneth D. Merry state_str = "COMMAND"; 2775ef270ab1SKenneth D. Merry break; 2776ef270ab1SKenneth D. Merry case OCS_CAM_IO_DATA: 2777ef270ab1SKenneth D. Merry state_str = "DATA"; 2778ef270ab1SKenneth D. Merry break; 2779ef270ab1SKenneth D. Merry case OCS_CAM_IO_DATA_DONE: 2780ef270ab1SKenneth D. Merry state_str = "DATA_DONE"; 2781ef270ab1SKenneth D. Merry break; 2782ef270ab1SKenneth D. Merry case OCS_CAM_IO_RESP: 2783ef270ab1SKenneth D. Merry state_str = "RESP"; 2784ef270ab1SKenneth D. Merry break; 2785ef270ab1SKenneth D. Merry default: 2786ef270ab1SKenneth D. Merry state_str = "xxx BAD xxx"; 2787ef270ab1SKenneth D. Merry } 2788ef270ab1SKenneth D. Merry ocs_ddump_value(textbuf, "cam_st", "%s", state_str); 2789ef270ab1SKenneth D. Merry if (io->tgt_io.app) { 2790ef270ab1SKenneth D. Merry ocs_ddump_value(textbuf, "cam_flags", "%#x", 2791ef270ab1SKenneth D. Merry ((union ccb *)(io->tgt_io.app))->ccb_h.flags); 2792ef270ab1SKenneth D. Merry ocs_ddump_value(textbuf, "cam_status", "%#x", 2793ef270ab1SKenneth D. Merry ((union ccb *)(io->tgt_io.app))->ccb_h.status); 2794ef270ab1SKenneth D. Merry } 2795ef270ab1SKenneth D. Merry 2796ef270ab1SKenneth D. Merry break; 2797ef270ab1SKenneth D. Merry } 2798ef270ab1SKenneth D. Merry default: { 2799ef270ab1SKenneth D. Merry break; 2800ef270ab1SKenneth D. Merry } 2801ef270ab1SKenneth D. Merry } 2802ef270ab1SKenneth D. Merry } 2803ef270ab1SKenneth D. Merry 2804ef270ab1SKenneth D. Merry int32_t ocs_scsi_get_block_vaddr(ocs_io_t *io, uint64_t blocknumber, 2805ef270ab1SKenneth D. Merry ocs_scsi_vaddr_len_t addrlen[], 2806ef270ab1SKenneth D. Merry uint32_t max_addrlen, void **dif_vaddr) 2807ef270ab1SKenneth D. Merry { 2808ef270ab1SKenneth D. Merry return -1; 2809ef270ab1SKenneth D. Merry } 2810ef270ab1SKenneth D. Merry 2811ef270ab1SKenneth D. Merry uint32_t 2812ef270ab1SKenneth D. Merry ocs_get_crn(ocs_node_t *node, uint8_t *crn, uint64_t lun) 2813ef270ab1SKenneth D. Merry { 2814ef270ab1SKenneth D. Merry uint32_t idx; 2815ef270ab1SKenneth D. Merry struct ocs_lun_crn *lcrn = NULL; 2816ef270ab1SKenneth D. Merry idx = lun % OCS_MAX_LUN; 2817ef270ab1SKenneth D. Merry 2818ef270ab1SKenneth D. Merry lcrn = node->ini_node.lun_crn[idx]; 2819ef270ab1SKenneth D. Merry 2820ef270ab1SKenneth D. Merry if (lcrn == NULL) { 2821ef270ab1SKenneth D. Merry lcrn = ocs_malloc(node->ocs, sizeof(struct ocs_lun_crn), 2822ef270ab1SKenneth D. Merry M_ZERO|M_NOWAIT); 2823ef270ab1SKenneth D. Merry if (lcrn == NULL) { 2824ef270ab1SKenneth D. Merry return (1); 2825ef270ab1SKenneth D. Merry } 2826ef270ab1SKenneth D. Merry 2827ef270ab1SKenneth D. Merry lcrn->lun = lun; 2828ef270ab1SKenneth D. Merry node->ini_node.lun_crn[idx] = lcrn; 2829ef270ab1SKenneth D. Merry } 2830ef270ab1SKenneth D. Merry 2831ef270ab1SKenneth D. Merry if (lcrn->lun != lun) { 2832ef270ab1SKenneth D. Merry return (1); 2833ef270ab1SKenneth D. Merry } 2834ef270ab1SKenneth D. Merry 2835ef270ab1SKenneth D. Merry if (lcrn->crnseed == 0) 2836ef270ab1SKenneth D. Merry lcrn->crnseed = 1; 2837ef270ab1SKenneth D. Merry 2838ef270ab1SKenneth D. Merry *crn = lcrn->crnseed++; 2839ef270ab1SKenneth D. Merry return (0); 2840ef270ab1SKenneth D. Merry } 2841ef270ab1SKenneth D. Merry 2842ef270ab1SKenneth D. Merry void 2843ef270ab1SKenneth D. Merry ocs_del_crn(ocs_node_t *node) 2844ef270ab1SKenneth D. Merry { 2845ef270ab1SKenneth D. Merry uint32_t i; 2846ef270ab1SKenneth D. Merry struct ocs_lun_crn *lcrn = NULL; 2847ef270ab1SKenneth D. Merry 2848ef270ab1SKenneth D. Merry for(i = 0; i < OCS_MAX_LUN; i++) { 2849ef270ab1SKenneth D. Merry lcrn = node->ini_node.lun_crn[i]; 2850ef270ab1SKenneth D. Merry if (lcrn) { 2851ef270ab1SKenneth D. Merry ocs_free(node->ocs, lcrn, sizeof(*lcrn)); 2852ef270ab1SKenneth D. Merry } 2853ef270ab1SKenneth D. Merry } 2854ef270ab1SKenneth D. Merry 2855ef270ab1SKenneth D. Merry return; 2856ef270ab1SKenneth D. Merry } 2857ef270ab1SKenneth D. Merry 2858ef270ab1SKenneth D. Merry void 2859ef270ab1SKenneth D. Merry ocs_reset_crn(ocs_node_t *node, uint64_t lun) 2860ef270ab1SKenneth D. Merry { 2861ef270ab1SKenneth D. Merry uint32_t idx; 2862ef270ab1SKenneth D. Merry struct ocs_lun_crn *lcrn = NULL; 2863ef270ab1SKenneth D. Merry idx = lun % OCS_MAX_LUN; 2864ef270ab1SKenneth D. Merry 2865ef270ab1SKenneth D. Merry lcrn = node->ini_node.lun_crn[idx]; 2866ef270ab1SKenneth D. Merry if (lcrn) 2867ef270ab1SKenneth D. Merry lcrn->crnseed = 0; 2868ef270ab1SKenneth D. Merry 2869ef270ab1SKenneth D. Merry return; 2870ef270ab1SKenneth D. Merry } 2871