LXR linux/drivers/scsi/csiostor/csio

   1/*
   2 * This file is part of the Chelsio FCoE driver for Linux.
   3 *
   4 * Copyright (c) 2008-2012 Chelsio Communications, Inc. All rights reserved.
   5 *
   6 * This software is available to you under a choice of one of two
   7 * licenses.  You may choose to be licensed under the terms of the GNU
   8 * General Public License (GPL) Version 2, available from the file
   9 * COPYING in the main directory of this source tree, or the
  10 * OpenIB.org BSD license below:
  11 *
  12 *     Redistribution and use in source and binary forms, with or
  13 *     without modification, are permitted provided that the following
  14 *     conditions are met:
  15 *
  16 *      - Redistributions of source code must retain the above
  17 *        copyright notice, this list of conditions and the following
  18 *        disclaimer.
  19 *
  20 *      - Redistributions in binary form must reproduce the above
  21 *        copyright notice, this list of conditions and the following
  22 *        disclaimer in the documentation and/or other materials
  23 *        provided with the distribution.
  24 *
  25 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  26 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  27 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  28 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
  29 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
  30 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  31 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  32 * SOFTWARE.
  33 */
  34
  35#include <linux/string.h>
  36#include <scsi/scsi_device.h>
  37#include <scsi/scsi_transport_fc.h>
  38#include <scsi/fc/fc_els.h>
  39#include <scsi/fc/fc_fs.h>
  40
  41#include "csio_hw.h"
  42#include "csio_lnode.h"
  43#include "csio_rnode.h"
  44
  45static int csio_rnode_init(struct csio_rnode *, struct csio_lnode *);
  46static void csio_rnode_exit(struct csio_rnode *);
  47
  48/* Static machine forward declarations */
  49static void csio_rns_uninit(struct csio_rnode *, enum csio_rn_ev);
  50static void csio_rns_ready(struct csio_rnode *, enum csio_rn_ev);
  51static void csio_rns_offline(struct csio_rnode *, enum csio_rn_ev);
  52static void csio_rns_disappeared(struct csio_rnode *, enum csio_rn_ev);
  53
  54/* RNF event mapping */
  55static enum csio_rn_ev fwevt_to_rnevt[] = {
  56        CSIO_RNFE_NONE,         /* None */
  57        CSIO_RNFE_LOGGED_IN,    /* PLOGI_ACC_RCVD  */
  58        CSIO_RNFE_NONE,         /* PLOGI_RJT_RCVD  */
  59        CSIO_RNFE_PLOGI_RECV,   /* PLOGI_RCVD      */
  60        CSIO_RNFE_LOGO_RECV,    /* PLOGO_RCVD      */
  61        CSIO_RNFE_PRLI_DONE,    /* PRLI_ACC_RCVD   */
  62        CSIO_RNFE_NONE,         /* PRLI_RJT_RCVD   */
  63        CSIO_RNFE_PRLI_RECV,    /* PRLI_RCVD       */
  64        CSIO_RNFE_PRLO_RECV,    /* PRLO_RCVD       */
  65        CSIO_RNFE_NONE,         /* NPORT_ID_CHGD   */
  66        CSIO_RNFE_LOGO_RECV,    /* FLOGO_RCVD      */
  67        CSIO_RNFE_NONE,         /* CLR_VIRT_LNK_RCVD */
  68        CSIO_RNFE_LOGGED_IN,    /* FLOGI_ACC_RCVD   */
  69        CSIO_RNFE_NONE,         /* FLOGI_RJT_RCVD   */
  70        CSIO_RNFE_LOGGED_IN,    /* FDISC_ACC_RCVD   */
  71        CSIO_RNFE_NONE,         /* FDISC_RJT_RCVD   */
  72        CSIO_RNFE_NONE,         /* FLOGI_TMO_MAX_RETRY */
  73        CSIO_RNFE_NONE,         /* IMPL_LOGO_ADISC_ACC */
  74        CSIO_RNFE_NONE,         /* IMPL_LOGO_ADISC_RJT */
  75        CSIO_RNFE_NONE,         /* IMPL_LOGO_ADISC_CNFLT */
  76        CSIO_RNFE_NONE,         /* PRLI_TMO             */
  77        CSIO_RNFE_NONE,         /* ADISC_TMO            */
  78        CSIO_RNFE_NAME_MISSING, /* RSCN_DEV_LOST  */
  79        CSIO_RNFE_NONE,         /* SCR_ACC_RCVD */
  80        CSIO_RNFE_NONE,         /* ADISC_RJT_RCVD */
  81        CSIO_RNFE_NONE,         /* LOGO_SNT */
  82        CSIO_RNFE_LOGO_RECV,    /* PROTO_ERR_IMPL_LOGO */
  83};
  84
  85#define CSIO_FWE_TO_RNFE(_evt)  ((_evt > PROTO_ERR_IMPL_LOGO) ?         \
  86                                                CSIO_RNFE_NONE :        \
  87                                                fwevt_to_rnevt[_evt])
  88int
  89csio_is_rnode_ready(struct csio_rnode *rn)
  90{
  91        return csio_match_state(rn, csio_rns_ready);
  92}
  93
  94static int
  95csio_is_rnode_uninit(struct csio_rnode *rn)
  96{
  97        return csio_match_state(rn, csio_rns_uninit);
  98}
  99
 100static int
 101csio_is_rnode_wka(uint8_t rport_type)
 102{
 103        if ((rport_type == FLOGI_VFPORT) ||
 104            (rport_type == FDISC_VFPORT) ||
 105            (rport_type == NS_VNPORT) ||
 106            (rport_type == FDMI_VNPORT))
 107                return 1;
 108
 109        return 0;
 110}
 111
 112/*
 113 * csio_rn_lookup - Finds the rnode with the given flowid
 114 * @ln - lnode
 115 * @flowid - flowid.
 116 *
 117 * Does the rnode lookup on the given lnode and flowid.If no matching entry
 118 * found, NULL is returned.
 119 */
 120static struct csio_rnode *
 121csio_rn_lookup(struct csio_lnode *ln, uint32_t flowid)
 122{
 123        struct csio_rnode *rnhead = (struct csio_rnode *) &ln->rnhead;
 124        struct list_head *tmp;
 125        struct csio_rnode *rn;
 126
 127        list_for_each(tmp, &rnhead->sm.sm_list) {
 128                rn = (struct csio_rnode *) tmp;
 129                if (rn->flowid == flowid)
 130                        return rn;
 131        }
 132
 133        return NULL;
 134}
 135
 136/*
 137 * csio_rn_lookup_wwpn - Finds the rnode with the given wwpn
 138 * @ln: lnode
 139 * @wwpn: wwpn
 140 *
 141 * Does the rnode lookup on the given lnode and wwpn. If no matching entry
 142 * found, NULL is returned.
 143 */
 144static struct csio_rnode *
 145csio_rn_lookup_wwpn(struct csio_lnode *ln, uint8_t *wwpn)
 146{
 147        struct csio_rnode *rnhead = (struct csio_rnode *) &ln->rnhead;
 148        struct list_head *tmp;
 149        struct csio_rnode *rn;
 150
 151        list_for_each(tmp, &rnhead->sm.sm_list) {
 152                rn = (struct csio_rnode *) tmp;
 153                if (!memcmp(csio_rn_wwpn(rn), wwpn, 8))
 154                        return rn;
 155        }
 156
 157        return NULL;
 158}
 159
 160/**
 161 * csio_rnode_lookup_portid - Finds the rnode with the given portid
 162 * @ln:         lnode
 163 * @portid:     port id
 164 *
 165 * Lookup the rnode list for a given portid. If no matching entry
 166 * found, NULL is returned.
 167 */
 168struct csio_rnode *
 169csio_rnode_lookup_portid(struct csio_lnode *ln, uint32_t portid)
 170{
 171        struct csio_rnode *rnhead = (struct csio_rnode *) &ln->rnhead;
 172        struct list_head *tmp;
 173        struct csio_rnode *rn;
 174
 175        list_for_each(tmp, &rnhead->sm.sm_list) {
 176                rn = (struct csio_rnode *) tmp;
 177                if (rn->nport_id == portid)
 178                        return rn;
 179        }
 180
 181        return NULL;
 182}
 183
 184static int
 185csio_rn_dup_flowid(struct csio_lnode *ln, uint32_t rdev_flowid,
 186                    uint32_t *vnp_flowid)
 187{
 188        struct csio_rnode *rnhead;
 189        struct list_head *tmp, *tmp1;
 190        struct csio_rnode *rn;
 191        struct csio_lnode *ln_tmp;
 192        struct csio_hw *hw = csio_lnode_to_hw(ln);
 193
 194        list_for_each(tmp1, &hw->sln_head) {
 195                ln_tmp = (struct csio_lnode *) tmp1;
 196                if (ln_tmp == ln)
 197                        continue;
 198
 199                rnhead = (struct csio_rnode *)&ln_tmp->rnhead;
 200                list_for_each(tmp, &rnhead->sm.sm_list) {
 201
 202                        rn = (struct csio_rnode *) tmp;
 203                        if (csio_is_rnode_ready(rn)) {
 204                                if (rn->flowid == rdev_flowid) {
 205                                        *vnp_flowid = csio_ln_flowid(ln_tmp);
 206                                        return 1;
 207                                }
 208                        }
 209                }
 210        }
 211
 212        return 0;
 213}
 214
 215static struct csio_rnode *
 216csio_alloc_rnode(struct csio_lnode *ln)
 217{
 218        struct csio_hw *hw = csio_lnode_to_hw(ln);
 219
 220        struct csio_rnode *rn = mempool_alloc(hw->rnode_mempool, GFP_ATOMIC);
 221        if (!rn)
 222                goto err;
 223
 224        memset(rn, 0, sizeof(struct csio_rnode));
 225        if (csio_rnode_init(rn, ln))
 226                goto err_free;
 227
 228        CSIO_INC_STATS(ln, n_rnode_alloc);
 229
 230        return rn;
 231
 232err_free:
 233        mempool_free(rn, hw->rnode_mempool);
 234err:
 235        CSIO_INC_STATS(ln, n_rnode_nomem);
 236        return NULL;
 237}
 238
 239static void
 240csio_free_rnode(struct csio_rnode *rn)
 241{
 242        struct csio_hw *hw = csio_lnode_to_hw(csio_rnode_to_lnode(rn));
 243
 244        csio_rnode_exit(rn);
 245        CSIO_INC_STATS(rn->lnp, n_rnode_free);
 246        mempool_free(rn, hw->rnode_mempool);
 247}
 248
 249/*
 250 * csio_get_rnode - Gets rnode with the given flowid
 251 * @ln - lnode
 252 * @flowid - flow id.
 253 *
 254 * Does the rnode lookup on the given lnode and flowid. If no matching
 255 * rnode found, then new rnode with given npid is allocated and returned.
 256 */
 257static struct csio_rnode *
 258csio_get_rnode(struct csio_lnode *ln, uint32_t flowid)
 259{
 260        struct csio_rnode *rn;
 261
 262        rn = csio_rn_lookup(ln, flowid);
 263        if (!rn) {
 264                rn = csio_alloc_rnode(ln);
 265                if (!rn)
 266                        return NULL;
 267
 268                rn->flowid = flowid;
 269        }
 270
 271        return rn;
 272}
 273
 274/*
 275 * csio_put_rnode - Frees the given rnode
 276 * @ln - lnode
 277 * @flowid - flow id.
 278 *
 279 * Does the rnode lookup on the given lnode and flowid. If no matching
 280 * rnode found, then new rnode with given npid is allocated and returned.
 281 */
 282void
 283csio_put_rnode(struct csio_lnode *ln, struct csio_rnode *rn)
 284{
 285        CSIO_DB_ASSERT(csio_is_rnode_uninit(rn) != 0);
 286        csio_free_rnode(rn);
 287}
 288
 289/*
 290 * csio_confirm_rnode - confirms rnode based on wwpn.
 291 * @ln: lnode
 292 * @rdev_flowid: remote device flowid
 293 * @rdevp: remote device params
 294 * This routines searches other rnode in list having same wwpn of new rnode.
 295 * If there is a match, then matched rnode is returned and otherwise new rnode
 296 * is returned.
 297 * returns rnode.
 298 */
 299struct csio_rnode *
 300csio_confirm_rnode(struct csio_lnode *ln, uint32_t rdev_flowid,
 301                   struct fcoe_rdev_entry *rdevp)
 302{
 303        uint8_t rport_type;
 304        struct csio_rnode *rn, *match_rn;
 305        uint32_t vnp_flowid = 0;
 306        __be32 *port_id;
 307
 308        port_id = (__be32 *)&rdevp->r_id[0];
 309        rport_type =
 310                FW_RDEV_WR_RPORT_TYPE_GET(rdevp->rd_xfer_rdy_to_rport_type);
 311
 312        /* Drop rdev event for cntrl port */
 313        if (rport_type == FAB_CTLR_VNPORT) {
 314                csio_ln_dbg(ln,
 315                            "Unhandled rport_type:%d recv in rdev evt "
 316                            "ssni:x%x\n", rport_type, rdev_flowid);
 317                return NULL;
 318        }
 319
 320        /* Lookup on flowid */
 321        rn = csio_rn_lookup(ln, rdev_flowid);
 322        if (!rn) {
 323
 324                /* Drop events with duplicate flowid */
 325                if (csio_rn_dup_flowid(ln, rdev_flowid, &vnp_flowid)) {
 326                        csio_ln_warn(ln,
 327                                     "ssni:%x already active on vnpi:%x",
 328                                     rdev_flowid, vnp_flowid);
 329                        return NULL;
 330                }
 331
 332                /* Lookup on wwpn for NPORTs */
 333                rn = csio_rn_lookup_wwpn(ln, rdevp->wwpn);
 334                if (!rn)
 335                        goto alloc_rnode;
 336
 337        } else {
 338                /* Lookup well-known ports with nport id */
 339                if (csio_is_rnode_wka(rport_type)) {
 340                        match_rn = csio_rnode_lookup_portid(ln,
 341                                      ((ntohl(*port_id) >> 8) & CSIO_DID_MASK));
 342                        if (match_rn == NULL) {
 343                                csio_rn_flowid(rn) = CSIO_INVALID_IDX;
 344                                goto alloc_rnode;
 345                        }
 346
 347                        /*
 348                         * Now compare the wwpn to confirm that
 349                         * same port relogged in. If so update the matched rn.
 350                         * Else, go ahead and alloc a new rnode.
 351                         */
 352                        if (!memcmp(csio_rn_wwpn(match_rn), rdevp->wwpn, 8)) {
 353                                if (rn == match_rn)
 354                                        goto found_rnode;
 355                                csio_ln_dbg(ln,
 356                                            "nport_id:x%x and wwpn:%llx"
 357                                            " match for ssni:x%x\n",
 358                                            rn->nport_id,
 359                                            wwn_to_u64(rdevp->wwpn),
 360                                            rdev_flowid);
 361                                if (csio_is_rnode_ready(rn)) {
 362                                        csio_ln_warn(ln,
 363                                                     "rnode is already"
 364                                                     "active ssni:x%x\n",
 365                                                     rdev_flowid);
 366                                        CSIO_ASSERT(0);
 367                                }
 368                                csio_rn_flowid(rn) = CSIO_INVALID_IDX;
 369                                rn = match_rn;
 370
 371                                /* Update rn */
 372                                goto found_rnode;
 373                        }
 374                        csio_rn_flowid(rn) = CSIO_INVALID_IDX;
 375                        goto alloc_rnode;
 376                }
 377
 378                /* wwpn match */
 379                if (!memcmp(csio_rn_wwpn(rn), rdevp->wwpn, 8))
 380                        goto found_rnode;
 381
 382                /* Search for rnode that have same wwpn */
 383                match_rn = csio_rn_lookup_wwpn(ln, rdevp->wwpn);
 384                if (match_rn != NULL) {
 385                        csio_ln_dbg(ln,
 386                                "ssni:x%x changed for rport name(wwpn):%llx "
 387                                "did:x%x\n", rdev_flowid,
 388                                wwn_to_u64(rdevp->wwpn),
 389                                match_rn->nport_id);
 390                        csio_rn_flowid(rn) = CSIO_INVALID_IDX;
 391                        rn = match_rn;
 392                } else {
 393                        csio_ln_dbg(ln,
 394                                "rnode wwpn mismatch found ssni:x%x "
 395                                "name(wwpn):%llx\n",
 396                                rdev_flowid,
 397                                wwn_to_u64(csio_rn_wwpn(rn)));
 398                        if (csio_is_rnode_ready(rn)) {
 399                                csio_ln_warn(ln,
 400                                             "rnode is already active "
 401                                             "wwpn:%llx ssni:x%x\n",
 402                                             wwn_to_u64(csio_rn_wwpn(rn)),
 403                                             rdev_flowid);
 404                                CSIO_ASSERT(0);
 405                        }
 406                        csio_rn_flowid(rn) = CSIO_INVALID_IDX;
 407                        goto alloc_rnode;
 408                }
 409        }
 410
 411found_rnode:
 412        csio_ln_dbg(ln, "found rnode:%p ssni:x%x name(wwpn):%llx\n",
 413                rn, rdev_flowid, wwn_to_u64(rdevp->wwpn));
 414
 415        /* Update flowid */
 416        csio_rn_flowid(rn) = rdev_flowid;
 417
 418        /* update rdev entry */
 419        rn->rdev_entry = rdevp;
 420        CSIO_INC_STATS(ln, n_rnode_match);
 421        return rn;
 422
 423alloc_rnode:
 424        rn = csio_get_rnode(ln, rdev_flowid);
 425        if (!rn)
 426                return NULL;
 427
 428        csio_ln_dbg(ln, "alloc rnode:%p ssni:x%x name(wwpn):%llx\n",
 429                rn, rdev_flowid, wwn_to_u64(rdevp->wwpn));
 430
 431        /* update rdev entry */
 432        rn->rdev_entry = rdevp;
 433        return rn;
 434}
 435
 436/*
 437 * csio_rn_verify_rparams - verify rparams.
 438 * @ln: lnode
 439 * @rn: rnode
 440 * @rdevp: remote device params
 441 * returns success if rparams are verified.
 442 */
 443static int
 444csio_rn_verify_rparams(struct csio_lnode *ln, struct csio_rnode *rn,
 445                        struct fcoe_rdev_entry *rdevp)
 446{
 447        uint8_t null[8];
 448        uint8_t rport_type;
 449        uint8_t fc_class;
 450        __be32 *did;
 451
 452        did = (__be32 *) &rdevp->r_id[0];
 453        rport_type =
 454                FW_RDEV_WR_RPORT_TYPE_GET(rdevp->rd_xfer_rdy_to_rport_type);
 455        switch (rport_type) {
 456        case FLOGI_VFPORT:
 457                rn->role = CSIO_RNFR_FABRIC;
 458                if (((ntohl(*did) >> 8) & CSIO_DID_MASK) != FC_FID_FLOGI) {
 459                        csio_ln_err(ln, "ssni:x%x invalid fabric portid\n",
 460                                csio_rn_flowid(rn));
 461                        return -EINVAL;
 462                }
 463                /* NPIV support */
 464                if (FW_RDEV_WR_NPIV_GET(rdevp->vft_to_qos))
 465                        ln->flags |= CSIO_LNF_NPIVSUPP;
 466
 467                break;
 468
 469        case NS_VNPORT:
 470                rn->role = CSIO_RNFR_NS;
 471                if (((ntohl(*did) >> 8) & CSIO_DID_MASK) != FC_FID_DIR_SERV) {
 472                        csio_ln_err(ln, "ssni:x%x invalid fabric portid\n",
 473                                csio_rn_flowid(rn));
 474                        return -EINVAL;
 475                }
 476                break;
 477
 478        case REG_FC4_VNPORT:
 479        case REG_VNPORT:
 480                rn->role = CSIO_RNFR_NPORT;
 481                if (rdevp->event_cause == PRLI_ACC_RCVD ||
 482                        rdevp->event_cause == PRLI_RCVD) {
 483                        if (FW_RDEV_WR_TASK_RETRY_ID_GET(
 484                                                        rdevp->enh_disc_to_tgt))
 485                                rn->fcp_flags |= FCP_SPPF_OVLY_ALLOW;
 486
 487                        if (FW_RDEV_WR_RETRY_GET(rdevp->enh_disc_to_tgt))
 488                                rn->fcp_flags |= FCP_SPPF_RETRY;
 489
 490                        if (FW_RDEV_WR_CONF_CMPL_GET(rdevp->enh_disc_to_tgt))
 491                                rn->fcp_flags |= FCP_SPPF_CONF_COMPL;
 492
 493                        if (FW_RDEV_WR_TGT_GET(rdevp->enh_disc_to_tgt))
 494                                rn->role |= CSIO_RNFR_TARGET;
 495
 496                        if (FW_RDEV_WR_INI_GET(rdevp->enh_disc_to_tgt))
 497                                rn->role |= CSIO_RNFR_INITIATOR;
 498                }
 499
 500                break;
 501
 502        case FDMI_VNPORT:
 503        case FAB_CTLR_VNPORT:
 504                rn->role = 0;
 505                break;
 506
 507        default:
 508                csio_ln_err(ln, "ssni:x%x invalid rport type recv x%x\n",
 509                        csio_rn_flowid(rn), rport_type);
 510                return -EINVAL;
 511        }
 512
 513        /* validate wwpn/wwnn for Name server/remote port */
 514        if (rport_type == REG_VNPORT || rport_type == NS_VNPORT) {
 515                memset(null, 0, 8);
 516                if (!memcmp(rdevp->wwnn, null, 8)) {
 517                        csio_ln_err(ln,
 518                                    "ssni:x%x invalid wwnn received from"
 519                                    " rport did:x%x\n",
 520                                    csio_rn_flowid(rn),
 521                                    (ntohl(*did) & CSIO_DID_MASK));
 522                        return -EINVAL;
 523                }
 524
 525                if (!memcmp(rdevp->wwpn, null, 8)) {
 526                        csio_ln_err(ln,
 527                                    "ssni:x%x invalid wwpn received from"
 528                                    " rport did:x%x\n",
 529                                    csio_rn_flowid(rn),
 530                                    (ntohl(*did) & CSIO_DID_MASK));
 531                        return -EINVAL;
 532                }
 533
 534        }
 535
 536        /* Copy wwnn, wwpn and nport id */
 537        rn->nport_id = (ntohl(*did) >> 8) & CSIO_DID_MASK;
 538        memcpy(csio_rn_wwnn(rn), rdevp->wwnn, 8);
 539        memcpy(csio_rn_wwpn(rn), rdevp->wwpn, 8);
 540        rn->rn_sparm.csp.sp_bb_data = rdevp->rcv_fr_sz;
 541        fc_class = FW_RDEV_WR_CLASS_GET(rdevp->vft_to_qos);
 542        rn->rn_sparm.clsp[fc_class - 1].cp_class = htons(FC_CPC_VALID);
 543
 544        return 0;
 545}
 546
 547static void
 548__csio_reg_rnode(struct csio_rnode *rn)
 549{
 550        struct csio_lnode *ln = csio_rnode_to_lnode(rn);
 551        struct csio_hw *hw = csio_lnode_to_hw(ln);
 552
 553        spin_unlock_irq(&hw->lock);
 554        csio_reg_rnode(rn);
 555        spin_lock_irq(&hw->lock);
 556
 557        if (rn->role & CSIO_RNFR_TARGET)
 558                ln->n_scsi_tgts++;
 559
 560        if (rn->nport_id == FC_FID_MGMT_SERV)
 561                csio_ln_fdmi_start(ln, (void *) rn);
 562}
 563
 564static void
 565__csio_unreg_rnode(struct csio_rnode *rn)
 566{
 567        struct csio_lnode *ln = csio_rnode_to_lnode(rn);
 568        struct csio_hw *hw = csio_lnode_to_hw(ln);
 569        LIST_HEAD(tmp_q);
 570        int cmpl = 0;
 571
 572        if (!list_empty(&rn->host_cmpl_q)) {
 573                csio_dbg(hw, "Returning completion queue I/Os\n");
 574                list_splice_tail_init(&rn->host_cmpl_q, &tmp_q);
 575                cmpl = 1;
 576        }
 577
 578        if (rn->role & CSIO_RNFR_TARGET) {
 579                ln->n_scsi_tgts--;
 580                ln->last_scan_ntgts--;
 581        }
 582
 583        spin_unlock_irq(&hw->lock);
 584        csio_unreg_rnode(rn);
 585        spin_lock_irq(&hw->lock);
 586
 587        /* Cleanup I/Os that were waiting for rnode to unregister */
 588        if (cmpl)
 589                csio_scsi_cleanup_io_q(csio_hw_to_scsim(hw), &tmp_q);
 590
 591}
 592
 593/*****************************************************************************/
 594/* START: Rnode SM                                                           */
 595/*****************************************************************************/
 596
 597/*
 598 * csio_rns_uninit -
 599 * @rn - rnode
 600 * @evt - SM event.
 601 *
 602 */
 603static void
 604csio_rns_uninit(struct csio_rnode *rn, enum csio_rn_ev evt)
 605{
 606        struct csio_lnode *ln = csio_rnode_to_lnode(rn);
 607        int ret = 0;
 608
 609        CSIO_INC_STATS(rn, n_evt_sm[evt]);
 610
 611        switch (evt) {
 612        case CSIO_RNFE_LOGGED_IN:
 613        case CSIO_RNFE_PLOGI_RECV:
 614                ret = csio_rn_verify_rparams(ln, rn, rn->rdev_entry);
 615                if (!ret) {
 616                        csio_set_state(&rn->sm, csio_rns_ready);
 617                        __csio_reg_rnode(rn);
 618                } else {
 619                        CSIO_INC_STATS(rn, n_err_inval);
 620                }
 621                break;
 622        case CSIO_RNFE_LOGO_RECV:
 623                csio_ln_dbg(ln,
 624                            "ssni:x%x Ignoring event %d recv "
 625                            "in rn state[uninit]\n", csio_rn_flowid(rn), evt);
 626                CSIO_INC_STATS(rn, n_evt_drop);
 627                break;
 628        default:
 629                csio_ln_dbg(ln,
 630                            "ssni:x%x unexp event %d recv "
 631                            "in rn state[uninit]\n", csio_rn_flowid(rn), evt);
 632                CSIO_INC_STATS(rn, n_evt_unexp);
 633                break;
 634        }
 635}
 636
 637/*
 638 * csio_rns_ready -
 639 * @rn - rnode
 640 * @evt - SM event.
 641 *
 642 */
 643static void
 644csio_rns_ready(struct csio_rnode *rn, enum csio_rn_ev evt)
 645{
 646        struct csio_lnode *ln = csio_rnode_to_lnode(rn);
 647        int ret = 0;
 648
 649        CSIO_INC_STATS(rn, n_evt_sm[evt]);
 650
 651        switch (evt) {
 652        case CSIO_RNFE_LOGGED_IN:
 653        case CSIO_RNFE_PLOGI_RECV:
 654                csio_ln_dbg(ln,
 655                        "ssni:x%x Ignoring event %d recv from did:x%x "
 656                        "in rn state[ready]\n", csio_rn_flowid(rn), evt,
 657                        rn->nport_id);
 658                CSIO_INC_STATS(rn, n_evt_drop);
 659                break;
 660
 661        case CSIO_RNFE_PRLI_DONE:
 662        case CSIO_RNFE_PRLI_RECV:
 663                ret = csio_rn_verify_rparams(ln, rn, rn->rdev_entry);
 664                if (!ret)
 665                        __csio_reg_rnode(rn);
 666                else
 667                        CSIO_INC_STATS(rn, n_err_inval);
 668
 669                break;
 670        case CSIO_RNFE_DOWN:
 671                csio_set_state(&rn->sm, csio_rns_offline);
 672                __csio_unreg_rnode(rn);
 673
 674                /* FW expected to internally aborted outstanding SCSI WRs
 675                 * and return all SCSI WRs to host with status "ABORTED".
 676                 */
 677                break;
 678
 679        case CSIO_RNFE_LOGO_RECV:
 680                csio_set_state(&rn->sm, csio_rns_offline);
 681
 682                __csio_unreg_rnode(rn);
 683
 684                /* FW expected to internally aborted outstanding SCSI WRs
 685                 * and return all SCSI WRs to host with status "ABORTED".
 686                 */
 687                break;
 688
 689        case CSIO_RNFE_CLOSE:
 690                /*
 691                 * Each rnode receives CLOSE event when driver is removed or
 692                 * device is reset
 693                 * Note: All outstanding IOs on remote port need to returned
 694                 * to uppper layer with appropriate error before sending
 695                 * CLOSE event
 696                 */
 697                csio_set_state(&rn->sm, csio_rns_uninit);
 698                __csio_unreg_rnode(rn);
 699                break;
 700
 701        case CSIO_RNFE_NAME_MISSING:
 702                csio_set_state(&rn->sm, csio_rns_disappeared);
 703                __csio_unreg_rnode(rn);
 704
 705                /*
 706                 * FW expected to internally aborted outstanding SCSI WRs
 707                 * and return all SCSI WRs to host with status "ABORTED".
 708                 */
 709
 710                break;
 711
 712        default:
 713                csio_ln_dbg(ln,
 714                        "ssni:x%x unexp event %d recv from did:x%x "
 715                        "in rn state[uninit]\n", csio_rn_flowid(rn), evt,
 716                        rn->nport_id);
 717                CSIO_INC_STATS(rn, n_evt_unexp);
 718                break;
 719        }
 720}
 721
 722/*
 723 * csio_rns_offline -
 724 * @rn - rnode
 725 * @evt - SM event.
 726 *
 727 */
 728static void
 729csio_rns_offline(struct csio_rnode *rn, enum csio_rn_ev evt)
 730{
 731        struct csio_lnode *ln = csio_rnode_to_lnode(rn);
 732        int ret = 0;
 733
 734        CSIO_INC_STATS(rn, n_evt_sm[evt]);
 735
 736        switch (evt) {
 737        case CSIO_RNFE_LOGGED_IN:
 738        case CSIO_RNFE_PLOGI_RECV:
 739                ret = csio_rn_verify_rparams(ln, rn, rn->rdev_entry);
 740                if (!ret) {
 741                        csio_set_state(&rn->sm, csio_rns_ready);
 742                        __csio_reg_rnode(rn);
 743                } else {
 744                        CSIO_INC_STATS(rn, n_err_inval);
 745                        csio_post_event(&rn->sm, CSIO_RNFE_CLOSE);
 746                }
 747                break;
 748
 749        case CSIO_RNFE_DOWN:
 750                csio_ln_dbg(ln,
 751                        "ssni:x%x Ignoring event %d recv from did:x%x "
 752                        "in rn state[offline]\n", csio_rn_flowid(rn), evt,
 753                        rn->nport_id);
 754                CSIO_INC_STATS(rn, n_evt_drop);
 755                break;
 756
 757        case CSIO_RNFE_CLOSE:
 758                /* Each rnode receives CLOSE event when driver is removed or
 759                 * device is reset
 760                 * Note: All outstanding IOs on remote port need to returned
 761                 * to uppper layer with appropriate error before sending
 762                 * CLOSE event
 763                 */
 764                csio_set_state(&rn->sm, csio_rns_uninit);
 765                break;
 766
 767        case CSIO_RNFE_NAME_MISSING:
 768                csio_set_state(&rn->sm, csio_rns_disappeared);
 769                break;
 770
 771        default:
 772                csio_ln_dbg(ln,
 773                        "ssni:x%x unexp event %d recv from did:x%x "
 774                        "in rn state[offline]\n", csio_rn_flowid(rn), evt,
 775                        rn->nport_id);
 776                CSIO_INC_STATS(rn, n_evt_unexp);
 777                break;
 778        }
 779}
 780
 781/*
 782 * csio_rns_disappeared -
 783 * @rn - rnode
 784 * @evt - SM event.
 785 *
 786 */
 787static void
 788csio_rns_disappeared(struct csio_rnode *rn, enum csio_rn_ev evt)
 789{
 790        struct csio_lnode *ln = csio_rnode_to_lnode(rn);
 791        int ret = 0;
 792
 793        CSIO_INC_STATS(rn, n_evt_sm[evt]);
 794
 795        switch (evt) {
 796        case CSIO_RNFE_LOGGED_IN:
 797        case CSIO_RNFE_PLOGI_RECV:
 798                ret = csio_rn_verify_rparams(ln, rn, rn->rdev_entry);
 799                if (!ret) {
 800                        csio_set_state(&rn->sm, csio_rns_ready);
 801                        __csio_reg_rnode(rn);
 802                } else {
 803                        CSIO_INC_STATS(rn, n_err_inval);
 804                        csio_post_event(&rn->sm, CSIO_RNFE_CLOSE);
 805                }
 806                break;
 807
 808        case CSIO_RNFE_CLOSE:
 809                /* Each rnode receives CLOSE event when driver is removed or
 810                 * device is reset.
 811                 * Note: All outstanding IOs on remote port need to returned
 812                 * to uppper layer with appropriate error before sending
 813                 * CLOSE event
 814                 */
 815                csio_set_state(&rn->sm, csio_rns_uninit);
 816                break;
 817
 818        case CSIO_RNFE_DOWN:
 819        case CSIO_RNFE_NAME_MISSING:
 820                csio_ln_dbg(ln,
 821                        "ssni:x%x Ignoring event %d recv from did x%x"
 822                        "in rn state[disappeared]\n", csio_rn_flowid(rn),
 823                        evt, rn->nport_id);
 824                break;
 825
 826        default:
 827                csio_ln_dbg(ln,
 828                        "ssni:x%x unexp event %d recv from did x%x"
 829                        "in rn state[disappeared]\n", csio_rn_flowid(rn),
 830                        evt, rn->nport_id);
 831                CSIO_INC_STATS(rn, n_evt_unexp);
 832                break;
 833        }
 834}
 835
 836/*****************************************************************************/
 837/* END: Rnode SM                                                             */
 838/*****************************************************************************/
 839
 840/*
 841 * csio_rnode_devloss_handler - Device loss event handler
 842 * @rn: rnode
 843 *
 844 * Post event to close rnode SM and free rnode.
 845 */
 846void
 847csio_rnode_devloss_handler(struct csio_rnode *rn)
 848{
 849        struct csio_lnode *ln = csio_rnode_to_lnode(rn);
 850
 851        /* ignore if same rnode came back as online */
 852        if (csio_is_rnode_ready(rn))
 853                return;
 854
 855        csio_post_event(&rn->sm, CSIO_RNFE_CLOSE);
 856
 857        /* Free rn if in uninit state */
 858        if (csio_is_rnode_uninit(rn))
 859                csio_put_rnode(ln, rn);
 860}
 861
 862/**
 863 * csio_rnode_fwevt_handler - Event handler for firmware rnode events.
 864 * @rn:         rnode
 865 *
 866 */
 867void
 868csio_rnode_fwevt_handler(struct csio_rnode *rn, uint8_t fwevt)
 869{
 870        struct csio_lnode *ln = csio_rnode_to_lnode(rn);
 871        enum csio_rn_ev evt;
 872
 873        evt = CSIO_FWE_TO_RNFE(fwevt);
 874        if (!evt) {
 875                csio_ln_err(ln, "ssni:x%x Unhandled FW Rdev event: %d\n",
 876                            csio_rn_flowid(rn), fwevt);
 877                CSIO_INC_STATS(rn, n_evt_unexp);
 878                return;
 879        }
 880        CSIO_INC_STATS(rn, n_evt_fw[fwevt]);
 881
 882        /* Track previous & current events for debugging */
 883        rn->prev_evt = rn->cur_evt;
 884        rn->cur_evt = fwevt;
 885
 886        /* Post event to rnode SM */
 887        csio_post_event(&rn->sm, evt);
 888
 889        /* Free rn if in uninit state */
 890        if (csio_is_rnode_uninit(rn))
 891                csio_put_rnode(ln, rn);
 892}
 893
 894/*
 895 * csio_rnode_init - Initialize rnode.
 896 * @rn: RNode
 897 * @ln: Associated lnode
 898 *
 899 * Caller is responsible for holding the lock. The lock is required
 900 * to be held for inserting the rnode in ln->rnhead list.
 901 */
 902static int
 903csio_rnode_init(struct csio_rnode *rn, struct csio_lnode *ln)
 904{
 905        csio_rnode_to_lnode(rn) = ln;
 906        csio_init_state(&rn->sm, csio_rns_uninit);
 907        INIT_LIST_HEAD(&rn->host_cmpl_q);
 908        csio_rn_flowid(rn) = CSIO_INVALID_IDX;
 909
 910        /* Add rnode to list of lnodes->rnhead */
 911        list_add_tail(&rn->sm.sm_list, &ln->rnhead);
 912
 913        return 0;
 914}
 915
 916static void
 917csio_rnode_exit(struct csio_rnode *rn)
 918{
 919        list_del_init(&rn->sm.sm_list);
 920        CSIO_DB_ASSERT(list_empty(&rn->host_cmpl_q));
 921}
 922