drivers/scsi/fcoe/fcoe.c

   1 /*
   2  * Copyright(c) 2007 - 2009 Intel Corporation. All rights reserved.
   3  *
   4  * This program is free software; you can redistribute it and/or modify it
   5  * under the terms and conditions of the GNU General Public License,
   6  * version 2, as published by the Free Software Foundation.
   7  *
   8  * This program is distributed in the hope it will be useful, but WITHOUT
   9  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  10  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
  11  * more details.
  12  *
  13  * You should have received a copy of the GNU General Public License along with
  14  * this program; if not, write to the Free Software Foundation, Inc.,
  15  * 51 Franklin St - Fifth Floor, Boston, MA 02110-1301 USA.
  16  *
  17  * Maintained at www.Open-FCoE.org
  18  */
  19
  20 #include <linux/module.h>
  21 #include <linux/spinlock.h>
  22 #include <linux/netdevice.h>
  23 #include <linux/etherdevice.h>
  24 #include <linux/ethtool.h>
  25 #include <linux/if_ether.h>
  26 #include <linux/if_vlan.h>
  27 #include <linux/crc32.h>
  28 #include <linux/slab.h>
  29 #include <linux/cpu.h>
  30 #include <linux/fs.h>
  31 #include <linux/sysfs.h>
  32 #include <linux/ctype.h>
  33 #include <linux/workqueue.h>
  34 #include <net/dcbnl.h>
  35 #include <net/dcbevent.h>
  36 #include <scsi/scsi_tcq.h>
  37 #include <scsi/scsicam.h>
  38 #include <scsi/scsi_transport.h>
  39 #include <scsi/scsi_transport_fc.h>
  40 #include <net/rtnetlink.h>
  41
  42 #include <scsi/fc/fc_encaps.h>
  43 #include <scsi/fc/fc_fip.h>
  44 #include <scsi/fc/fc_fcoe.h>
  45
  46 #include <scsi/libfc.h>
  47 #include <scsi/fc_frame.h>
  48 #include <scsi/libfcoe.h>
  49
  50 #include "fcoe.h"
  51
  52 MODULE_AUTHOR("Open-FCoE.org");
  53 MODULE_DESCRIPTION("FCoE");
  54 MODULE_LICENSE("GPL v2");
  55
  56 /* Performance tuning parameters for fcoe */
  57 static unsigned int fcoe_ddp_min = 4096;
  58 module_param_named(ddp_min, fcoe_ddp_min, uint, S_IRUGO | S_IWUSR);
  59 MODULE_PARM_DESC(ddp_min, "Minimum I/O size in bytes for "      \
  60                  "Direct Data Placement (DDP).");
  61
  62 unsigned int fcoe_debug_logging;
  63 module_param_named(debug_logging, fcoe_debug_logging, int, S_IRUGO|S_IWUSR);
  64 MODULE_PARM_DESC(debug_logging, "a bit mask of logging levels");
  65
  66 static DEFINE_MUTEX(fcoe_config_mutex);
  67
  68 static struct workqueue_struct *fcoe_wq;
  69
  70 /* fcoe host list */
  71 /* must only by accessed under the RTNL mutex */
  72 static LIST_HEAD(fcoe_hostlist);
  73 static DEFINE_PER_CPU(struct fcoe_percpu_s, fcoe_percpu);
  74
  75 /* Function Prototypes */
  76 static int fcoe_reset(struct Scsi_Host *);
  77 static int fcoe_xmit(struct fc_lport *, struct fc_frame *);
  78 static int fcoe_rcv(struct sk_buff *, struct net_device *,
  79                     struct packet_type *, struct net_device *);
  80 static void fcoe_percpu_clean(struct fc_lport *);
  81 static int fcoe_link_ok(struct fc_lport *);
  82
  83 static struct fc_lport *fcoe_hostlist_lookup(const struct net_device *);
  84 static int fcoe_hostlist_add(const struct fc_lport *);
  85 static void fcoe_hostlist_del(const struct fc_lport *);
  86
  87 static int fcoe_device_notification(struct notifier_block *, ulong, void *);
  88 static void fcoe_dev_setup(void);
  89 static void fcoe_dev_cleanup(void);
  90 static struct fcoe_interface
  91 *fcoe_hostlist_lookup_port(const struct net_device *);
  92
  93 static int fcoe_fip_recv(struct sk_buff *, struct net_device *,
  94                          struct packet_type *, struct net_device *);
  95 static int fcoe_fip_vlan_recv(struct sk_buff *, struct net_device *,
  96                               struct packet_type *, struct net_device *);
  97
  98 static void fcoe_fip_send(struct fcoe_ctlr *, struct sk_buff *);
  99 static void fcoe_update_src_mac(struct fc_lport *, u8 *);
 100 static u8 *fcoe_get_src_mac(struct fc_lport *);
 101 static void fcoe_destroy_work(struct work_struct *);
 102
 103 static int fcoe_ddp_setup(struct fc_lport *, u16, struct scatterlist *,
 104                           unsigned int);
 105 static int fcoe_ddp_done(struct fc_lport *, u16);
 106 static int fcoe_ddp_target(struct fc_lport *, u16, struct scatterlist *,
 107                            unsigned int);
 108 static int fcoe_dcb_app_notification(struct notifier_block *notifier,
 109                                      ulong event, void *ptr);
 110
 111 static bool fcoe_match(struct net_device *netdev);
 112 static int fcoe_create(struct net_device *netdev, enum fip_mode fip_mode);
 113 static int fcoe_destroy(struct net_device *netdev);
 114 static int fcoe_enable(struct net_device *netdev);
 115 static int fcoe_disable(struct net_device *netdev);
 116
 117 /* fcoe_syfs control interface handlers */
 118 static int fcoe_ctlr_alloc(struct net_device *netdev);
 119 static int fcoe_ctlr_enabled(struct fcoe_ctlr_device *cdev);
 120 static void fcoe_ctlr_mode(struct fcoe_ctlr_device *ctlr_dev);
 121
 122 static struct fc_seq *fcoe_elsct_send(struct fc_lport *,
 123                                       u32 did, struct fc_frame *,
 124                                       unsigned int op,
 125                                       void (*resp)(struct fc_seq *,
 126                                                    struct fc_frame *,
 127                                                    void *),
 128                                       void *, u32 timeout);
 129 static void fcoe_recv_frame(struct sk_buff *skb);
 130
 131 /* notification function for packets from net device */
 132 static struct notifier_block fcoe_notifier = {
 133         .notifier_call = fcoe_device_notification,
 134 };
 135
 136 /* notification function for DCB events */
 137 static struct notifier_block dcb_notifier = {
 138         .notifier_call = fcoe_dcb_app_notification,
 139 };
 140
 141 static struct scsi_transport_template *fcoe_nport_scsi_transport;
 142 static struct scsi_transport_template *fcoe_vport_scsi_transport;
 143
 144 static int fcoe_vport_destroy(struct fc_vport *);
 145 static int fcoe_vport_create(struct fc_vport *, bool disabled);
 146 static int fcoe_vport_disable(struct fc_vport *, bool disable);
 147 static void fcoe_set_vport_symbolic_name(struct fc_vport *);
 148 static void fcoe_set_port_id(struct fc_lport *, u32, struct fc_frame *);
 149 static void fcoe_fcf_get_vlan_id(struct fcoe_fcf_device *);
 150
 151
 152 static struct fcoe_sysfs_function_template fcoe_sysfs_templ = {
 153         .set_fcoe_ctlr_mode = fcoe_ctlr_mode,
 154         .set_fcoe_ctlr_enabled = fcoe_ctlr_enabled,
 155         .get_fcoe_ctlr_link_fail = fcoe_ctlr_get_lesb,
 156         .get_fcoe_ctlr_vlink_fail = fcoe_ctlr_get_lesb,
 157         .get_fcoe_ctlr_miss_fka = fcoe_ctlr_get_lesb,
 158         .get_fcoe_ctlr_symb_err = fcoe_ctlr_get_lesb,
 159         .get_fcoe_ctlr_err_block = fcoe_ctlr_get_lesb,
 160         .get_fcoe_ctlr_fcs_error = fcoe_ctlr_get_lesb,
 161
 162         .get_fcoe_fcf_selected = fcoe_fcf_get_selected,
 163         .get_fcoe_fcf_vlan_id = fcoe_fcf_get_vlan_id,
 164 };
 165
 166 static struct libfc_function_template fcoe_libfc_fcn_templ = {
 167         .frame_send = fcoe_xmit,
 168         .ddp_setup = fcoe_ddp_setup,
 169         .ddp_done = fcoe_ddp_done,
 170         .ddp_target = fcoe_ddp_target,
 171         .elsct_send = fcoe_elsct_send,
 172         .get_lesb = fcoe_get_lesb,
 173         .lport_set_port_id = fcoe_set_port_id,
 174 };
 175
 176 static struct fc_function_template fcoe_nport_fc_functions = {
 177         .show_host_node_name = 1,
 178         .show_host_port_name = 1,
 179         .show_host_supported_classes = 1,
 180         .show_host_supported_fc4s = 1,
 181         .show_host_active_fc4s = 1,
 182         .show_host_maxframe_size = 1,
 183         .show_host_serial_number = 1,
 184         .show_host_manufacturer = 1,
 185         .show_host_model = 1,
 186         .show_host_model_description = 1,
 187         .show_host_hardware_version = 1,
 188         .show_host_driver_version = 1,
 189         .show_host_firmware_version = 1,
 190         .show_host_optionrom_version = 1,
 191
 192         .show_host_port_id = 1,
 193         .show_host_supported_speeds = 1,
 194         .get_host_speed = fc_get_host_speed,
 195         .show_host_speed = 1,
 196         .show_host_port_type = 1,
 197         .get_host_port_state = fc_get_host_port_state,
 198         .show_host_port_state = 1,
 199         .show_host_symbolic_name = 1,
 200
 201         .dd_fcrport_size = sizeof(struct fc_rport_libfc_priv),
 202         .show_rport_maxframe_size = 1,
 203         .show_rport_supported_classes = 1,
 204
 205         .show_host_fabric_name = 1,
 206         .show_starget_node_name = 1,
 207         .show_starget_port_name = 1,
 208         .show_starget_port_id = 1,
 209         .set_rport_dev_loss_tmo = fc_set_rport_loss_tmo,
 210         .show_rport_dev_loss_tmo = 1,
 211         .get_fc_host_stats = fc_get_host_stats,
 212         .issue_fc_host_lip = fcoe_reset,
 213
 214         .terminate_rport_io = fc_rport_terminate_io,
 215
 216         .vport_create = fcoe_vport_create,
 217         .vport_delete = fcoe_vport_destroy,
 218         .vport_disable = fcoe_vport_disable,
 219         .set_vport_symbolic_name = fcoe_set_vport_symbolic_name,
 220
 221         .bsg_request = fc_lport_bsg_request,
 222 };
 223
 224 static struct fc_function_template fcoe_vport_fc_functions = {
 225         .show_host_node_name = 1,
 226         .show_host_port_name = 1,
 227         .show_host_supported_classes = 1,
 228         .show_host_supported_fc4s = 1,
 229         .show_host_active_fc4s = 1,
 230         .show_host_maxframe_size = 1,
 231         .show_host_serial_number = 1,
 232         .show_host_manufacturer = 1,
 233         .show_host_model = 1,
 234         .show_host_model_description = 1,
 235         .show_host_hardware_version = 1,
 236         .show_host_driver_version = 1,
 237         .show_host_firmware_version = 1,
 238         .show_host_optionrom_version = 1,
 239
 240         .show_host_port_id = 1,
 241         .show_host_supported_speeds = 1,
 242         .get_host_speed = fc_get_host_speed,
 243         .show_host_speed = 1,
 244         .show_host_port_type = 1,
 245         .get_host_port_state = fc_get_host_port_state,
 246         .show_host_port_state = 1,
 247         .show_host_symbolic_name = 1,
 248
 249         .dd_fcrport_size = sizeof(struct fc_rport_libfc_priv),
 250         .show_rport_maxframe_size = 1,
 251         .show_rport_supported_classes = 1,
 252
 253         .show_host_fabric_name = 1,
 254         .show_starget_node_name = 1,
 255         .show_starget_port_name = 1,
 256         .show_starget_port_id = 1,
 257         .set_rport_dev_loss_tmo = fc_set_rport_loss_tmo,
 258         .show_rport_dev_loss_tmo = 1,
 259         .get_fc_host_stats = fc_get_host_stats,
 260         .issue_fc_host_lip = fcoe_reset,
 261
 262         .terminate_rport_io = fc_rport_terminate_io,
 263
 264         .bsg_request = fc_lport_bsg_request,
 265 };
 266
 267 static struct scsi_host_template fcoe_shost_template = {
 268         .module = THIS_MODULE,
 269         .name = "FCoE Driver",
 270         .proc_name = FCOE_NAME,
 271         .queuecommand = fc_queuecommand,
 272         .eh_abort_handler = fc_eh_abort,
 273         .eh_device_reset_handler = fc_eh_device_reset,
 274         .eh_host_reset_handler = fc_eh_host_reset,
 275         .slave_alloc = fc_slave_alloc,
 276         .change_queue_depth = scsi_change_queue_depth,
 277         .this_id = -1,
 278         .cmd_per_lun = 3,
 279         .can_queue = FCOE_MAX_OUTSTANDING_COMMANDS,
 280         .use_clustering = ENABLE_CLUSTERING,
 281         .sg_tablesize = SG_ALL,
 282         .max_sectors = 0xffff,
 283         .track_queue_depth = 1,
 284 };
 285
 286 /**
 287  * fcoe_interface_setup() - Setup a FCoE interface
 288  * @fcoe:   The new FCoE interface
 289  * @netdev: The net device that the fcoe interface is on
 290  *
 291  * Returns : 0 for success
 292  * Locking: must be called with the RTNL mutex held
 293  */
 294 static int fcoe_interface_setup(struct fcoe_interface *fcoe,
 295                                 struct net_device *netdev)
 296 {
 297         struct fcoe_ctlr *fip = fcoe_to_ctlr(fcoe);
 298         struct netdev_hw_addr *ha;
 299         struct net_device *real_dev;
 300         u8 flogi_maddr[ETH_ALEN];
 301         const struct net_device_ops *ops;
 302
 303         fcoe->netdev = netdev;
 304
 305         /* Let LLD initialize for FCoE */
 306         ops = netdev->netdev_ops;
 307         if (ops->ndo_fcoe_enable) {
 308                 if (ops->ndo_fcoe_enable(netdev))
 309                         FCOE_NETDEV_DBG(netdev, "Failed to enable FCoE"
 310                                         " specific feature for LLD.\n");
 311         }
 312
 313         /* Do not support for bonding device */
 314         if (netdev->priv_flags & IFF_BONDING && netdev->flags & IFF_MASTER) {
 315                 FCOE_NETDEV_DBG(netdev, "Bonded interfaces not supported\n");
 316                 return -EOPNOTSUPP;
 317         }
 318
 319         /* look for SAN MAC address, if multiple SAN MACs exist, only
 320          * use the first one for SPMA */
 321         real_dev = (netdev->priv_flags & IFF_802_1Q_VLAN) ?
 322                 vlan_dev_real_dev(netdev) : netdev;
 323         fcoe->realdev = real_dev;
 324         rcu_read_lock();
 325         for_each_dev_addr(real_dev, ha) {
 326                 if ((ha->type == NETDEV_HW_ADDR_T_SAN) &&
 327                     (is_valid_ether_addr(ha->addr))) {
 328                         memcpy(fip->ctl_src_addr, ha->addr, ETH_ALEN);
 329                         fip->spma = 1;
 330                         break;
 331                 }
 332         }
 333         rcu_read_unlock();
 334
 335         /* setup Source Mac Address */
 336         if (!fip->spma)
 337                 memcpy(fip->ctl_src_addr, netdev->dev_addr, netdev->addr_len);
 338
 339         /*
 340          * Add FCoE MAC address as second unicast MAC address
 341          * or enter promiscuous mode if not capable of listening
 342          * for multiple unicast MACs.
 343          */
 344         memcpy(flogi_maddr, (u8[6]) FC_FCOE_FLOGI_MAC, ETH_ALEN);
 345         dev_uc_add(netdev, flogi_maddr);
 346         if (fip->spma)
 347                 dev_uc_add(netdev, fip->ctl_src_addr);
 348         if (fip->mode == FIP_MODE_VN2VN) {
 349                 dev_mc_add(netdev, FIP_ALL_VN2VN_MACS);
 350                 dev_mc_add(netdev, FIP_ALL_P2P_MACS);
 351         } else
 352                 dev_mc_add(netdev, FIP_ALL_ENODE_MACS);
 353
 354         /*
 355          * setup the receive function from ethernet driver
 356          * on the ethertype for the given device
 357          */
 358         fcoe->fcoe_packet_type.func = fcoe_rcv;
 359         fcoe->fcoe_packet_type.type = htons(ETH_P_FCOE);
 360         fcoe->fcoe_packet_type.dev = netdev;
 361         dev_add_pack(&fcoe->fcoe_packet_type);
 362
 363         fcoe->fip_packet_type.func = fcoe_fip_recv;
 364         fcoe->fip_packet_type.type = htons(ETH_P_FIP);
 365         fcoe->fip_packet_type.dev = netdev;
 366         dev_add_pack(&fcoe->fip_packet_type);
 367
 368         if (netdev != real_dev) {
 369                 fcoe->fip_vlan_packet_type.func = fcoe_fip_vlan_recv;
 370                 fcoe->fip_vlan_packet_type.type = htons(ETH_P_FIP);
 371                 fcoe->fip_vlan_packet_type.dev = real_dev;
 372                 dev_add_pack(&fcoe->fip_vlan_packet_type);
 373         }
 374         return 0;
 375 }
 376
 377 /**
 378  * fcoe_interface_create() - Create a FCoE interface on a net device
 379  * @netdev: The net device to create the FCoE interface on
 380  * @fip_mode: The mode to use for FIP
 381  *
 382  * Returns: pointer to a struct fcoe_interface or NULL on error
 383  */
 384 static struct fcoe_interface *fcoe_interface_create(struct net_device *netdev,
 385                                                     enum fip_state fip_mode)
 386 {
 387         struct fcoe_ctlr_device *ctlr_dev;
 388         struct fcoe_ctlr *ctlr;
 389         struct fcoe_interface *fcoe;
 390         int size;
 391         int err;
 392
 393         if (!try_module_get(THIS_MODULE)) {
 394                 FCOE_NETDEV_DBG(netdev,
 395                                 "Could not get a reference to the module\n");
 396                 fcoe = ERR_PTR(-EBUSY);
 397                 goto out;
 398         }
 399
 400         size = sizeof(struct fcoe_ctlr) + sizeof(struct fcoe_interface);
 401         ctlr_dev = fcoe_ctlr_device_add(&netdev->dev, &fcoe_sysfs_templ,
 402                                         size);
 403         if (!ctlr_dev) {
 404                 FCOE_DBG("Failed to add fcoe_ctlr_device\n");
 405                 fcoe = ERR_PTR(-ENOMEM);
 406                 goto out_putmod;
 407         }
 408
 409         ctlr = fcoe_ctlr_device_priv(ctlr_dev);
 410         ctlr->cdev = ctlr_dev;
 411         fcoe = fcoe_ctlr_priv(ctlr);
 412
 413         dev_hold(netdev);
 414
 415         /*
 416          * Initialize FIP.
 417          */
 418         fcoe_ctlr_init(ctlr, fip_mode);
 419         ctlr->send = fcoe_fip_send;
 420         ctlr->update_mac = fcoe_update_src_mac;
 421         ctlr->get_src_addr = fcoe_get_src_mac;
 422
 423         err = fcoe_interface_setup(fcoe, netdev);
 424         if (err) {
 425                 fcoe_ctlr_destroy(ctlr);
 426                 fcoe_ctlr_device_delete(ctlr_dev);
 427                 dev_put(netdev);
 428                 fcoe = ERR_PTR(err);
 429                 goto out_putmod;
 430         }
 431
 432         goto out;
 433
 434 out_putmod:
 435         module_put(THIS_MODULE);
 436 out:
 437         return fcoe;
 438 }
 439
 440 /**
 441  * fcoe_interface_remove() - remove FCoE interface from netdev
 442  * @fcoe: The FCoE interface to be cleaned up
 443  *
 444  * Caller must be holding the RTNL mutex
 445  */
 446 static void fcoe_interface_remove(struct fcoe_interface *fcoe)
 447 {
 448         struct net_device *netdev = fcoe->netdev;
 449         struct fcoe_ctlr *fip = fcoe_to_ctlr(fcoe);
 450         u8 flogi_maddr[ETH_ALEN];
 451         const struct net_device_ops *ops;
 452
 453         /*
 454          * Don't listen for Ethernet packets anymore.
 455          * synchronize_net() ensures that the packet handlers are not running
 456          * on another CPU. dev_remove_pack() would do that, this calls the
 457          * unsyncronized version __dev_remove_pack() to avoid multiple delays.
 458          */
 459         __dev_remove_pack(&fcoe->fcoe_packet_type);
 460         __dev_remove_pack(&fcoe->fip_packet_type);
 461         if (netdev != fcoe->realdev)
 462                 __dev_remove_pack(&fcoe->fip_vlan_packet_type);
 463         synchronize_net();
 464
 465         /* Delete secondary MAC addresses */
 466         memcpy(flogi_maddr, (u8[6]) FC_FCOE_FLOGI_MAC, ETH_ALEN);
 467         dev_uc_del(netdev, flogi_maddr);
 468         if (fip->spma)
 469                 dev_uc_del(netdev, fip->ctl_src_addr);
 470         if (fip->mode == FIP_MODE_VN2VN) {
 471                 dev_mc_del(netdev, FIP_ALL_VN2VN_MACS);
 472                 dev_mc_del(netdev, FIP_ALL_P2P_MACS);
 473         } else
 474                 dev_mc_del(netdev, FIP_ALL_ENODE_MACS);
 475
 476         /* Tell the LLD we are done w/ FCoE */
 477         ops = netdev->netdev_ops;
 478         if (ops->ndo_fcoe_disable) {
 479                 if (ops->ndo_fcoe_disable(netdev))
 480                         FCOE_NETDEV_DBG(netdev, "Failed to disable FCoE"
 481                                         " specific feature for LLD.\n");
 482         }
 483         fcoe->removed = 1;
 484 }
 485
 486
 487 /**
 488  * fcoe_interface_cleanup() - Clean up a FCoE interface
 489  * @fcoe: The FCoE interface to be cleaned up
 490  */
 491 static void fcoe_interface_cleanup(struct fcoe_interface *fcoe)
 492 {
 493         struct net_device *netdev = fcoe->netdev;
 494         struct fcoe_ctlr *fip = fcoe_to_ctlr(fcoe);
 495
 496         rtnl_lock();
 497         if (!fcoe->removed)
 498                 fcoe_interface_remove(fcoe);
 499         rtnl_unlock();
 500
 501         /* Release the self-reference taken during fcoe_interface_create() */
 502         /* tear-down the FCoE controller */
 503         fcoe_ctlr_destroy(fip);
 504         scsi_host_put(fip->lp->host);
 505         dev_put(netdev);
 506         module_put(THIS_MODULE);
 507 }
 508
 509 /**
 510  * fcoe_fip_recv() - Handler for received FIP frames
 511  * @skb:      The receive skb
 512  * @netdev:   The associated net device
 513  * @ptype:    The packet_type structure which was used to register this handler
 514  * @orig_dev: The original net_device the the skb was received on.
 515  *            (in case dev is a bond)
 516  *
 517  * Returns: 0 for success
 518  */
 519 static int fcoe_fip_recv(struct sk_buff *skb, struct net_device *netdev,
 520                          struct packet_type *ptype,
 521                          struct net_device *orig_dev)
 522 {
 523         struct fcoe_interface *fcoe;
 524         struct fcoe_ctlr *ctlr;
 525
 526         fcoe = container_of(ptype, struct fcoe_interface, fip_packet_type);
 527         ctlr = fcoe_to_ctlr(fcoe);
 528         fcoe_ctlr_recv(ctlr, skb);
 529         return 0;
 530 }
 531
 532 /**
 533  * fcoe_fip_vlan_recv() - Handler for received FIP VLAN discovery frames
 534  * @skb:      The receive skb
 535  * @netdev:   The associated net device
 536  * @ptype:    The packet_type structure which was used to register this handler
 537  * @orig_dev: The original net_device the the skb was received on.
 538  *            (in case dev is a bond)
 539  *
 540  * Returns: 0 for success
 541  */
 542 static int fcoe_fip_vlan_recv(struct sk_buff *skb, struct net_device *netdev,
 543                               struct packet_type *ptype,
 544                               struct net_device *orig_dev)
 545 {
 546         struct fcoe_interface *fcoe;
 547         struct fcoe_ctlr *ctlr;
 548
 549         fcoe = container_of(ptype, struct fcoe_interface, fip_vlan_packet_type);
 550         ctlr = fcoe_to_ctlr(fcoe);
 551         fcoe_ctlr_recv(ctlr, skb);
 552         return 0;
 553 }
 554
 555 /**
 556  * fcoe_port_send() - Send an Ethernet-encapsulated FIP/FCoE frame
 557  * @port: The FCoE port
 558  * @skb: The FIP/FCoE packet to be sent
 559  */
 560 static void fcoe_port_send(struct fcoe_port *port, struct sk_buff *skb)
 561 {
 562         if (port->fcoe_pending_queue.qlen)
 563                 fcoe_check_wait_queue(port->lport, skb);
 564         else if (fcoe_start_io(skb))
 565                 fcoe_check_wait_queue(port->lport, skb);
 566 }
 567
 568 /**
 569  * fcoe_fip_send() - Send an Ethernet-encapsulated FIP frame
 570  * @fip: The FCoE controller
 571  * @skb: The FIP packet to be sent
 572  */
 573 static void fcoe_fip_send(struct fcoe_ctlr *fip, struct sk_buff *skb)
 574 {
 575         struct fcoe_interface *fcoe = fcoe_from_ctlr(fip);
 576         struct fip_frame {
 577                 struct ethhdr eth;
 578                 struct fip_header fip;
 579         } __packed *frame;
 580
 581         /*
 582          * Use default VLAN for FIP VLAN discovery protocol
 583          */
 584         frame = (struct fip_frame *)skb->data;
 585         if (frame->fip.fip_op == ntohs(FIP_OP_VLAN) &&
 586             fcoe->realdev != fcoe->netdev)
 587                 skb->dev = fcoe->realdev;
 588         else
 589                 skb->dev = fcoe->netdev;
 590         fcoe_port_send(lport_priv(fip->lp), skb);
 591 }
 592
 593 /**
 594  * fcoe_update_src_mac() - Update the Ethernet MAC filters
 595  * @lport: The local port to update the source MAC on
 596  * @addr:  Unicast MAC address to add
 597  *
 598  * Remove any previously-set unicast MAC filter.
 599  * Add secondary FCoE MAC address filter for our OUI.
 600  */
 601 static void fcoe_update_src_mac(struct fc_lport *lport, u8 *addr)
 602 {
 603         struct fcoe_port *port = lport_priv(lport);
 604         struct fcoe_interface *fcoe = port->priv;
 605
 606         if (!is_zero_ether_addr(port->data_src_addr))
 607                 dev_uc_del(fcoe->netdev, port->data_src_addr);
 608         if (!is_zero_ether_addr(addr))
 609                 dev_uc_add(fcoe->netdev, addr);
 610         memcpy(port->data_src_addr, addr, ETH_ALEN);
 611 }
 612
 613 /**
 614  * fcoe_get_src_mac() - return the Ethernet source address for an lport
 615  * @lport: libfc lport
 616  */
 617 static u8 *fcoe_get_src_mac(struct fc_lport *lport)
 618 {
 619         struct fcoe_port *port = lport_priv(lport);
 620
 621         return port->data_src_addr;
 622 }
 623
 624 /**
 625  * fcoe_lport_config() - Set up a local port
 626  * @lport: The local port to be setup
 627  *
 628  * Returns: 0 for success
 629  */
 630 static int fcoe_lport_config(struct fc_lport *lport)
 631 {
 632         lport->link_up = 0;
 633         lport->qfull = 0;
 634         lport->max_retry_count = 3;
 635         lport->max_rport_retry_count = 3;
 636         lport->e_d_tov = 2 * 1000;      /* FC-FS default */
 637         lport->r_a_tov = 2 * 2 * 1000;
 638         lport->service_params = (FCP_SPPF_INIT_FCN | FCP_SPPF_RD_XRDY_DIS |
 639                                  FCP_SPPF_RETRY | FCP_SPPF_CONF_COMPL);
 640         lport->does_npiv = 1;
 641
 642         fc_lport_init_stats(lport);
 643
 644         /* lport fc_lport related configuration */
 645         fc_lport_config(lport);
 646
 647         /* offload related configuration */
 648         lport->crc_offload = 0;
 649         lport->seq_offload = 0;
 650         lport->lro_enabled = 0;
 651         lport->lro_xid = 0;
 652         lport->lso_max = 0;
 653
 654         return 0;
 655 }
 656
 657 /**
 658  * fcoe_netdev_features_change - Updates the lport's offload flags based
 659  * on the LLD netdev's FCoE feature flags
 660  */
 661 static void fcoe_netdev_features_change(struct fc_lport *lport,
 662                                         struct net_device *netdev)
 663 {
 664         mutex_lock(&lport->lp_mutex);
 665
 666         if (netdev->features & NETIF_F_SG)
 667                 lport->sg_supp = 1;
 668         else
 669                 lport->sg_supp = 0;
 670
 671         if (netdev->features & NETIF_F_FCOE_CRC) {
 672                 lport->crc_offload = 1;
 673                 FCOE_NETDEV_DBG(netdev, "Supports FCCRC offload\n");
 674         } else {
 675                 lport->crc_offload = 0;
 676         }
 677
 678         if (netdev->features & NETIF_F_FSO) {
 679                 lport->seq_offload = 1;
 680                 lport->lso_max = netdev->gso_max_size;
 681                 FCOE_NETDEV_DBG(netdev, "Supports LSO for max len 0x%x\n",
 682                                 lport->lso_max);
 683         } else {
 684                 lport->seq_offload = 0;
 685                 lport->lso_max = 0;
 686         }
 687
 688         if (netdev->fcoe_ddp_xid) {
 689                 lport->lro_enabled = 1;
 690                 lport->lro_xid = netdev->fcoe_ddp_xid;
 691                 FCOE_NETDEV_DBG(netdev, "Supports LRO for max xid 0x%x\n",
 692                                 lport->lro_xid);
 693         } else {
 694                 lport->lro_enabled = 0;
 695                 lport->lro_xid = 0;
 696         }
 697
 698         mutex_unlock(&lport->lp_mutex);
 699 }
 700
 701 /**
 702  * fcoe_netdev_config() - Set up net devive for SW FCoE
 703  * @lport:  The local port that is associated with the net device
 704  * @netdev: The associated net device
 705  *
 706  * Must be called after fcoe_lport_config() as it will use local port mutex
 707  *
 708  * Returns: 0 for success
 709  */
 710 static int fcoe_netdev_config(struct fc_lport *lport, struct net_device *netdev)
 711 {
 712         u32 mfs;
 713         u64 wwnn, wwpn;
 714         struct fcoe_interface *fcoe;
 715         struct fcoe_ctlr *ctlr;
 716         struct fcoe_port *port;
 717
 718         /* Setup lport private data to point to fcoe softc */
 719         port = lport_priv(lport);
 720         fcoe = port->priv;
 721         ctlr = fcoe_to_ctlr(fcoe);
 722
 723         /* Figure out the VLAN ID, if any */
 724         if (netdev->priv_flags & IFF_802_1Q_VLAN)
 725                 lport->vlan = vlan_dev_vlan_id(netdev);
 726         else
 727                 lport->vlan = 0;
 728
 729         /*
 730          * Determine max frame size based on underlying device and optional
 731          * user-configured limit.  If the MFS is too low, fcoe_link_ok()
 732          * will return 0, so do this first.
 733          */
 734         mfs = netdev->mtu;
 735         if (netdev->features & NETIF_F_FCOE_MTU) {
 736                 mfs = FCOE_MTU;
 737                 FCOE_NETDEV_DBG(netdev, "Supports FCOE_MTU of %d bytes\n", mfs);
 738         }
 739         mfs -= (sizeof(struct fcoe_hdr) + sizeof(struct fcoe_crc_eof));
 740         if (fc_set_mfs(lport, mfs))
 741                 return -EINVAL;
 742
 743         /* offload features support */
 744         fcoe_netdev_features_change(lport, netdev);
 745
 746         skb_queue_head_init(&port->fcoe_pending_queue);
 747         port->fcoe_pending_queue_active = 0;
 748         setup_timer(&port->timer, fcoe_queue_timer, (unsigned long)lport);
 749
 750         fcoe_link_speed_update(lport);
 751
 752         if (!lport->vport) {
 753                 if (fcoe_get_wwn(netdev, &wwnn, NETDEV_FCOE_WWNN))
 754                         wwnn = fcoe_wwn_from_mac(ctlr->ctl_src_addr, 1, 0);
 755                 fc_set_wwnn(lport, wwnn);
 756                 if (fcoe_get_wwn(netdev, &wwpn, NETDEV_FCOE_WWPN))
 757                         wwpn = fcoe_wwn_from_mac(ctlr->ctl_src_addr,
 758                                                  2, 0);
 759                 fc_set_wwpn(lport, wwpn);
 760         }
 761
 762         return 0;
 763 }
 764
 765 /**
 766  * fcoe_shost_config() - Set up the SCSI host associated with a local port
 767  * @lport: The local port
 768  * @dev:   The device associated with the SCSI host
 769  *
 770  * Must be called after fcoe_lport_config() and fcoe_netdev_config()
 771  *
 772  * Returns: 0 for success
 773  */
 774 static int fcoe_shost_config(struct fc_lport *lport, struct device *dev)
 775 {
 776         int rc = 0;
 777
 778         /* lport scsi host config */
 779         lport->host->max_lun = FCOE_MAX_LUN;
 780         lport->host->max_id = FCOE_MAX_FCP_TARGET;
 781         lport->host->max_channel = 0;
 782         lport->host->max_cmd_len = FCOE_MAX_CMD_LEN;
 783
 784         if (lport->vport)
 785                 lport->host->transportt = fcoe_vport_scsi_transport;
 786         else
 787                 lport->host->transportt = fcoe_nport_scsi_transport;
 788
 789         /* add the new host to the SCSI-ml */
 790         rc = scsi_add_host(lport->host, dev);
 791         if (rc) {
 792                 FCOE_NETDEV_DBG(fcoe_netdev(lport), "fcoe_shost_config: "
 793                                 "error on scsi_add_host\n");
 794                 return rc;
 795         }
 796
 797         if (!lport->vport)
 798                 fc_host_max_npiv_vports(lport->host) = USHRT_MAX;
 799
 800         snprintf(fc_host_symbolic_name(lport->host), FC_SYMBOLIC_NAME_SIZE,
 801                  "%s v%s over %s", FCOE_NAME, FCOE_VERSION,
 802                  fcoe_netdev(lport)->name);
 803
 804         return 0;
 805 }
 806
 807
 808 /**
 809  * fcoe_fdmi_info() - Get FDMI related info from net devive for SW FCoE
 810  * @lport:  The local port that is associated with the net device
 811  * @netdev: The associated net device
 812  *
 813  * Must be called after fcoe_shost_config() as it will use local port mutex
 814  *
 815  */
 816 static void fcoe_fdmi_info(struct fc_lport *lport, struct net_device *netdev)
 817 {
 818         struct fcoe_interface *fcoe;
 819         struct fcoe_port *port;
 820         struct net_device *realdev;
 821         int rc;
 822
 823         port = lport_priv(lport);
 824         fcoe = port->priv;
 825         realdev = fcoe->realdev;
 826
 827         /* No FDMI state m/c for NPIV ports */
 828         if (lport->vport)
 829                 return;
 830
 831         if (realdev->netdev_ops->ndo_fcoe_get_hbainfo) {
 832                 struct netdev_fcoe_hbainfo *fdmi;
 833                 fdmi = kzalloc(sizeof(*fdmi), GFP_KERNEL);
 834                 if (!fdmi)
 835                         return;
 836
 837                 rc = realdev->netdev_ops->ndo_fcoe_get_hbainfo(realdev,
 838                                                                fdmi);
 839                 if (rc) {
 840                         printk(KERN_INFO "fcoe: Failed to retrieve FDMI "
 841                                         "information from netdev.\n");
 842                         return;
 843                 }
 844
 845                 snprintf(fc_host_serial_number(lport->host),
 846                          FC_SERIAL_NUMBER_SIZE,
 847                          "%s",
 848                          fdmi->serial_number);
 849                 snprintf(fc_host_manufacturer(lport->host),
 850                          FC_SERIAL_NUMBER_SIZE,
 851                          "%s",
 852                          fdmi->manufacturer);
 853                 snprintf(fc_host_model(lport->host),
 854                          FC_SYMBOLIC_NAME_SIZE,
 855                          "%s",
 856                          fdmi->model);
 857                 snprintf(fc_host_model_description(lport->host),
 858                          FC_SYMBOLIC_NAME_SIZE,
 859                          "%s",
 860                          fdmi->model_description);
 861                 snprintf(fc_host_hardware_version(lport->host),
 862                          FC_VERSION_STRING_SIZE,
 863                          "%s",
 864                          fdmi->hardware_version);
 865                 snprintf(fc_host_driver_version(lport->host),
 866                          FC_VERSION_STRING_SIZE,
 867                          "%s",
 868                          fdmi->driver_version);
 869                 snprintf(fc_host_optionrom_version(lport->host),
 870                          FC_VERSION_STRING_SIZE,
 871                          "%s",
 872                          fdmi->optionrom_version);
 873                 snprintf(fc_host_firmware_version(lport->host),
 874                          FC_VERSION_STRING_SIZE,
 875                          "%s",
 876                          fdmi->firmware_version);
 877
 878                 /* Enable FDMI lport states */
 879                 lport->fdmi_enabled = 1;
 880                 kfree(fdmi);
 881         } else {
 882                 lport->fdmi_enabled = 0;
 883                 printk(KERN_INFO "fcoe: No FDMI support.\n");
 884         }
 885 }
 886
 887 /**
 888  * fcoe_oem_match() - The match routine for the offloaded exchange manager
 889  * @fp: The I/O frame
 890  *
 891  * This routine will be associated with an exchange manager (EM). When
 892  * the libfc exchange handling code is looking for an EM to use it will
 893  * call this routine and pass it the frame that it wishes to send. This
 894  * routine will return True if the associated EM is to be used and False
 895  * if the echange code should continue looking for an EM.
 896  *
 897  * The offload EM that this routine is associated with will handle any
 898  * packets that are for SCSI read requests.
 899  *
 900  * This has been enhanced to work when FCoE stack is operating in target
 901  * mode.
 902  *
 903  * Returns: True for read types I/O, otherwise returns false.
 904  */
 905 static bool fcoe_oem_match(struct fc_frame *fp)
 906 {
 907         struct fc_frame_header *fh = fc_frame_header_get(fp);
 908         struct fcp_cmnd *fcp;
 909
 910         if (fc_fcp_is_read(fr_fsp(fp)) &&
 911             (fr_fsp(fp)->data_len > fcoe_ddp_min))
 912                 return true;
 913         else if ((fr_fsp(fp) == NULL) &&
 914                  (fh->fh_r_ctl == FC_RCTL_DD_UNSOL_CMD) &&
 915                  (ntohs(fh->fh_rx_id) == FC_XID_UNKNOWN)) {
 916                 fcp = fc_frame_payload_get(fp, sizeof(*fcp));
 917                 if ((fcp->fc_flags & FCP_CFL_WRDATA) &&
 918                     (ntohl(fcp->fc_dl) > fcoe_ddp_min))
 919                         return true;
 920         }
 921         return false;
 922 }
 923
 924 /**
 925  * fcoe_em_config() - Allocate and configure an exchange manager
 926  * @lport: The local port that the new EM will be associated with
 927  *
 928  * Returns: 0 on success
 929  */
 930 static inline int fcoe_em_config(struct fc_lport *lport)
 931 {
 932         struct fcoe_port *port = lport_priv(lport);
 933         struct fcoe_interface *fcoe = port->priv;
 934         struct fcoe_interface *oldfcoe = NULL;
 935         struct net_device *old_real_dev, *cur_real_dev;
 936         u16 min_xid = FCOE_MIN_XID;
 937         u16 max_xid = FCOE_MAX_XID;
 938
 939         /*
 940          * Check if need to allocate an em instance for
 941          * offload exchange ids to be shared across all VN_PORTs/lport.
 942          */
 943         if (!lport->lro_enabled || !lport->lro_xid ||
 944             (lport->lro_xid >= max_xid)) {
 945                 lport->lro_xid = 0;
 946                 goto skip_oem;
 947         }
 948
 949         /*
 950          * Reuse existing offload em instance in case
 951          * it is already allocated on real eth device
 952          */
 953         if (fcoe->netdev->priv_flags & IFF_802_1Q_VLAN)
 954                 cur_real_dev = vlan_dev_real_dev(fcoe->netdev);
 955         else
 956                 cur_real_dev = fcoe->netdev;
 957
 958         list_for_each_entry(oldfcoe, &fcoe_hostlist, list) {
 959                 if (oldfcoe->netdev->priv_flags & IFF_802_1Q_VLAN)
 960                         old_real_dev = vlan_dev_real_dev(oldfcoe->netdev);
 961                 else
 962                         old_real_dev = oldfcoe->netdev;
 963
 964                 if (cur_real_dev == old_real_dev) {
 965                         fcoe->oem = oldfcoe->oem;
 966                         break;
 967                 }
 968         }
 969
 970         if (fcoe->oem) {
 971                 if (!fc_exch_mgr_add(lport, fcoe->oem, fcoe_oem_match)) {
 972                         printk(KERN_ERR "fcoe_em_config: failed to add "
 973                                "offload em:%p on interface:%s\n",
 974                                fcoe->oem, fcoe->netdev->name);
 975                         return -ENOMEM;
 976                 }
 977         } else {
 978                 fcoe->oem = fc_exch_mgr_alloc(lport, FC_CLASS_3,
 979                                               FCOE_MIN_XID, lport->lro_xid,
 980                                               fcoe_oem_match);
 981                 if (!fcoe->oem) {
 982                         printk(KERN_ERR "fcoe_em_config: failed to allocate "
 983                                "em for offload exches on interface:%s\n",
 984                                fcoe->netdev->name);
 985                         return -ENOMEM;
 986                 }
 987         }
 988
 989         /*
 990          * Exclude offload EM xid range from next EM xid range.
 991          */
 992         min_xid += lport->lro_xid + 1;
 993
 994 skip_oem:
 995         if (!fc_exch_mgr_alloc(lport, FC_CLASS_3, min_xid, max_xid, NULL)) {
 996                 printk(KERN_ERR "fcoe_em_config: failed to "
 997                        "allocate em on interface %s\n", fcoe->netdev->name);
 998                 return -ENOMEM;
 999         }
1000
1001         return 0;
1002 }
1003
1004 /**
1005  * fcoe_if_destroy() - Tear down a SW FCoE instance
1006  * @lport: The local port to be destroyed
1007  *
1008  */
1009 static void fcoe_if_destroy(struct fc_lport *lport)
1010 {
1011         struct fcoe_port *port = lport_priv(lport);
1012         struct fcoe_interface *fcoe = port->priv;
1013         struct net_device *netdev = fcoe->netdev;
1014
1015         FCOE_NETDEV_DBG(netdev, "Destroying interface\n");
1016
1017         /* Logout of the fabric */
1018         fc_fabric_logoff(lport);
1019
1020         /* Cleanup the fc_lport */
1021         fc_lport_destroy(lport);
1022
1023         /* Stop the transmit retry timer */
1024         del_timer_sync(&port->timer);
1025
1026         /* Free existing transmit skbs */
1027         fcoe_clean_pending_queue(lport);
1028
1029         rtnl_lock();
1030         if (!is_zero_ether_addr(port->data_src_addr))
1031                 dev_uc_del(netdev, port->data_src_addr);
1032         if (lport->vport)
1033                 synchronize_net();
1034         else
1035                 fcoe_interface_remove(fcoe);
1036         rtnl_unlock();
1037
1038         /* Free queued packets for the per-CPU receive threads */
1039         fcoe_percpu_clean(lport);
1040
1041         /* Detach from the scsi-ml */
1042         fc_remove_host(lport->host);
1043         scsi_remove_host(lport->host);
1044
1045         /* Destroy lport scsi_priv */
1046         fc_fcp_destroy(lport);
1047
1048         /* There are no more rports or I/O, free the EM */
1049         fc_exch_mgr_free(lport);
1050
1051         /* Free memory used by statistical counters */
1052         fc_lport_free_stats(lport);
1053
1054         /*
1055          * Release the Scsi_Host for vport but hold on to
1056          * master lport until it fcoe interface fully cleaned-up.
1057          */
1058         if (lport->vport)
1059                 scsi_host_put(lport->host);
1060 }
1061
1062 /**
1063  * fcoe_ddp_setup() - Call a LLD's ddp_setup through the net device
1064  * @lport: The local port to setup DDP for
1065  * @xid:   The exchange ID for this DDP transfer
1066  * @sgl:   The scatterlist describing this transfer
1067  * @sgc:   The number of sg items
1068  *
1069  * Returns: 0 if the DDP context was not configured
1070  */
1071 static int fcoe_ddp_setup(struct fc_lport *lport, u16 xid,
1072                           struct scatterlist *sgl, unsigned int sgc)
1073 {
1074         struct net_device *netdev = fcoe_netdev(lport);
1075
1076         if (netdev->netdev_ops->ndo_fcoe_ddp_setup)
1077                 return netdev->netdev_ops->ndo_fcoe_ddp_setup(netdev,
1078                                                               xid, sgl,
1079                                                               sgc);
1080
1081         return 0;
1082 }
1083
1084 /**
1085  * fcoe_ddp_target() - Call a LLD's ddp_target through the net device
1086  * @lport: The local port to setup DDP for
1087  * @xid:   The exchange ID for this DDP transfer
1088  * @sgl:   The scatterlist describing this transfer
1089  * @sgc:   The number of sg items
1090  *
1091  * Returns: 0 if the DDP context was not configured
1092  */
1093 static int fcoe_ddp_target(struct fc_lport *lport, u16 xid,
1094                            struct scatterlist *sgl, unsigned int sgc)
1095 {
1096         struct net_device *netdev = fcoe_netdev(lport);
1097
1098         if (netdev->netdev_ops->ndo_fcoe_ddp_target)
1099                 return netdev->netdev_ops->ndo_fcoe_ddp_target(netdev, xid,
1100                                                                sgl, sgc);
1101
1102         return 0;
1103 }
1104
1105
1106 /**
1107  * fcoe_ddp_done() - Call a LLD's ddp_done through the net device
1108  * @lport: The local port to complete DDP on
1109  * @xid:   The exchange ID for this DDP transfer
1110  *
1111  * Returns: the length of data that have been completed by DDP
1112  */
1113 static int fcoe_ddp_done(struct fc_lport *lport, u16 xid)
1114 {
1115         struct net_device *netdev = fcoe_netdev(lport);
1116
1117         if (netdev->netdev_ops->ndo_fcoe_ddp_done)
1118                 return netdev->netdev_ops->ndo_fcoe_ddp_done(netdev, xid);
1119         return 0;
1120 }
1121
1122 /**
1123  * fcoe_if_create() - Create a FCoE instance on an interface
1124  * @fcoe:   The FCoE interface to create a local port on
1125  * @parent: The device pointer to be the parent in sysfs for the SCSI host
1126  * @npiv:   Indicates if the port is a vport or not
1127  *
1128  * Creates a fc_lport instance and a Scsi_Host instance and configure them.
1129  *
1130  * Returns: The allocated fc_lport or an error pointer
1131  */
1132 static struct fc_lport *fcoe_if_create(struct fcoe_interface *fcoe,
1133                                        struct device *parent, int npiv)
1134 {
1135         struct fcoe_ctlr *ctlr = fcoe_to_ctlr(fcoe);
1136         struct net_device *netdev = fcoe->netdev;
1137         struct fc_lport *lport, *n_port;
1138         struct fcoe_port *port;
1139         struct Scsi_Host *shost;
1140         int rc;
1141         /*
1142          * parent is only a vport if npiv is 1,
1143          * but we'll only use vport in that case so go ahead and set it
1144          */
1145         struct fc_vport *vport = dev_to_vport(parent);
1146
1147         FCOE_NETDEV_DBG(netdev, "Create Interface\n");
1148
1149         if (!npiv)
1150                 lport = libfc_host_alloc(&fcoe_shost_template, sizeof(*port));
1151         else
1152                 lport = libfc_vport_create(vport, sizeof(*port));
1153
1154         if (!lport) {
1155                 FCOE_NETDEV_DBG(netdev, "Could not allocate host structure\n");
1156                 rc = -ENOMEM;
1157                 goto out;
1158         }
1159         port = lport_priv(lport);
1160         port->lport = lport;
1161         port->priv = fcoe;
1162         port->get_netdev = fcoe_netdev;
1163         port->max_queue_depth = FCOE_MAX_QUEUE_DEPTH;
1164         port->min_queue_depth = FCOE_MIN_QUEUE_DEPTH;
1165         INIT_WORK(&port->destroy_work, fcoe_destroy_work);
1166
1167         /*
1168          * Need to add the lport to the hostlist
1169          * so we catch NETDEV_CHANGE events.
1170          */
1171         fcoe_hostlist_add(lport);
1172
1173         /* configure a fc_lport including the exchange manager */
1174         rc = fcoe_lport_config(lport);
1175         if (rc) {
1176                 FCOE_NETDEV_DBG(netdev, "Could not configure lport for the "
1177                                 "interface\n");
1178                 goto out_host_put;
1179         }
1180
1181         if (npiv) {
1182                 FCOE_NETDEV_DBG(netdev, "Setting vport names, "
1183                                 "%16.16llx %16.16llx\n",
1184                                 vport->node_name, vport->port_name);
1185                 fc_set_wwnn(lport, vport->node_name);
1186                 fc_set_wwpn(lport, vport->port_name);
1187         }
1188
1189         /* configure lport network properties */
1190         rc = fcoe_netdev_config(lport, netdev);
1191         if (rc) {
1192                 FCOE_NETDEV_DBG(netdev, "Could not configure netdev for the "
1193                                 "interface\n");
1194                 goto out_lp_destroy;
1195         }
1196
1197         /* configure lport scsi host properties */
1198         rc = fcoe_shost_config(lport, parent);
1199         if (rc) {
1200                 FCOE_NETDEV_DBG(netdev, "Could not configure shost for the "
1201                                 "interface\n");
1202                 goto out_lp_destroy;
1203         }
1204
1205         /* Initialize the library */
1206         rc = fcoe_libfc_config(lport, ctlr, &fcoe_libfc_fcn_templ, 1);
1207         if (rc) {
1208                 FCOE_NETDEV_DBG(netdev, "Could not configure libfc for the "
1209                                 "interface\n");
1210                 goto out_lp_destroy;
1211         }
1212
1213         /* Initialized FDMI information */
1214         fcoe_fdmi_info(lport, netdev);
1215
1216         /*
1217          * fcoe_em_alloc() and fcoe_hostlist_add() both
1218          * need to be atomic with respect to other changes to the
1219          * hostlist since fcoe_em_alloc() looks for an existing EM
1220          * instance on host list updated by fcoe_hostlist_add().
1221          *
1222          * This is currently handled through the fcoe_config_mutex
1223          * begin held.
1224          */
1225         if (!npiv)
1226                 /* lport exch manager allocation */
1227                 rc = fcoe_em_config(lport);
1228         else {
1229                 shost = vport_to_shost(vport);
1230                 n_port = shost_priv(shost);
1231                 rc = fc_exch_mgr_list_clone(n_port, lport);
1232         }
1233
1234         if (rc) {
1235                 FCOE_NETDEV_DBG(netdev, "Could not configure the EM\n");
1236                 goto out_lp_destroy;
1237         }
1238
1239         return lport;
1240
1241 out_lp_destroy:
1242         fc_exch_mgr_free(lport);
1243 out_host_put:
1244         fcoe_hostlist_del(lport);
1245         scsi_host_put(lport->host);
1246 out:
1247         return ERR_PTR(rc);
1248 }
1249
1250 /**
1251  * fcoe_if_init() - Initialization routine for fcoe.ko
1252  *
1253  * Attaches the SW FCoE transport to the FC transport
1254  *
1255  * Returns: 0 on success
1256  */
1257 static int __init fcoe_if_init(void)
1258 {
1259         /* attach to scsi transport */
1260         fcoe_nport_scsi_transport =
1261                 fc_attach_transport(&fcoe_nport_fc_functions);
1262         fcoe_vport_scsi_transport =
1263                 fc_attach_transport(&fcoe_vport_fc_functions);
1264
1265         if (!fcoe_nport_scsi_transport) {
1266                 printk(KERN_ERR "fcoe: Failed to attach to the FC transport\n");
1267                 return -ENODEV;
1268         }
1269
1270         return 0;
1271 }
1272
1273 /**
1274  * fcoe_if_exit() - Tear down fcoe.ko
1275  *
1276  * Detaches the SW FCoE transport from the FC transport
1277  *
1278  * Returns: 0 on success
1279  */
1280 static int __exit fcoe_if_exit(void)
1281 {
1282         fc_release_transport(fcoe_nport_scsi_transport);
1283         fc_release_transport(fcoe_vport_scsi_transport);
1284         fcoe_nport_scsi_transport = NULL;
1285         fcoe_vport_scsi_transport = NULL;
1286         return 0;
1287 }
1288
1289 static void fcoe_thread_cleanup_local(unsigned int cpu)
1290 {
1291         struct page *crc_eof;
1292         struct fcoe_percpu_s *p;
1293
1294         p = per_cpu_ptr(&fcoe_percpu, cpu);
1295         spin_lock_bh(&p->fcoe_rx_list.lock);
1296         crc_eof = p->crc_eof_page;
1297         p->crc_eof_page = NULL;
1298         p->crc_eof_offset = 0;
1299         spin_unlock_bh(&p->fcoe_rx_list.lock);
1300
1301         if (crc_eof)
1302                 put_page(crc_eof);
1303         flush_work(&p->work);
1304 }
1305
1306 /**
1307  * fcoe_select_cpu() - Selects CPU to handle post-processing of incoming
1308  *                      command.
1309  *
1310  * This routine selects next CPU based on cpumask to distribute
1311  * incoming requests in round robin.
1312  *
1313  * Returns: int CPU number
1314  */
1315 static inline unsigned int fcoe_select_cpu(void)
1316 {
1317         static unsigned int selected_cpu;
1318
1319         selected_cpu = cpumask_next(selected_cpu, cpu_online_mask);
1320         if (selected_cpu >= nr_cpu_ids)
1321                 selected_cpu = cpumask_first(cpu_online_mask);
1322
1323         return selected_cpu;
1324 }
1325
1326 /**
1327  * fcoe_rcv() - Receive packets from a net device
1328  * @skb:    The received packet
1329  * @netdev: The net device that the packet was received on
1330  * @ptype:  The packet type context
1331  * @olddev: The last device net device
1332  *
1333  * This routine is called by NET_RX_SOFTIRQ. It receives a packet, builds a
1334  * FC frame and passes the frame to libfc.
1335  *
1336  * Returns: 0 for success
1337  */
1338 static int fcoe_rcv(struct sk_buff *skb, struct net_device *netdev,
1339              struct packet_type *ptype, struct net_device *olddev)
1340 {
1341         struct fc_lport *lport;
1342         struct fcoe_rcv_info *fr;
1343         struct fcoe_ctlr *ctlr;
1344         struct fcoe_interface *fcoe;
1345         struct fc_frame_header *fh;
1346         struct fcoe_percpu_s *fps;
1347         struct ethhdr *eh;
1348         unsigned int cpu;
1349
1350         fcoe = container_of(ptype, struct fcoe_interface, fcoe_packet_type);
1351         ctlr = fcoe_to_ctlr(fcoe);
1352         lport = ctlr->lp;
1353         if (unlikely(!lport)) {
1354                 FCOE_NETDEV_DBG(netdev, "Cannot find hba structure\n");
1355                 goto err2;
1356         }
1357         if (!lport->link_up)
1358                 goto err2;
1359
1360         FCOE_NETDEV_DBG(netdev,
1361                         "skb_info: len:%d data_len:%d head:%p data:%p tail:%p end:%p sum:%d dev:%s\n",
1362                         skb->len, skb->data_len, skb->head, skb->data,
1363                         skb_tail_pointer(skb), skb_end_pointer(skb),
1364                         skb->csum, skb->dev ? skb->dev->name : "<NULL>");
1365
1366
1367         skb = skb_share_check(skb, GFP_ATOMIC);
1368
1369         if (skb == NULL)
1370                 return NET_RX_DROP;
1371
1372         eh = eth_hdr(skb);
1373
1374         if (is_fip_mode(ctlr) &&
1375             !ether_addr_equal(eh->h_source, ctlr->dest_addr)) {
1376                 FCOE_NETDEV_DBG(netdev, "wrong source mac address:%pM\n",
1377                                 eh->h_source);
1378                 goto err;
1379         }
1380
1381         /*
1382          * Check for minimum frame length, and make sure required FCoE
1383          * and FC headers are pulled into the linear data area.
1384          */
1385         if (unlikely((skb->len < FCOE_MIN_FRAME) ||
1386                      !pskb_may_pull(skb, FCOE_HEADER_LEN)))
1387                 goto err;
1388
1389         skb_set_transport_header(skb, sizeof(struct fcoe_hdr));
1390         fh = (struct fc_frame_header *) skb_transport_header(skb);
1391
1392         if (ntoh24(&eh->h_dest[3]) != ntoh24(fh->fh_d_id)) {
1393                 FCOE_NETDEV_DBG(netdev, "FC frame d_id mismatch with MAC:%pM\n",
1394                                 eh->h_dest);
1395                 goto err;
1396         }
1397
1398         fr = fcoe_dev_from_skb(skb);
1399         fr->fr_dev = lport;
1400
1401         /*
1402          * In case the incoming frame's exchange is originated from
1403          * the initiator, then received frame's exchange id is ANDed
1404          * with fc_cpu_mask bits to get the same cpu on which exchange
1405          * was originated, otherwise select cpu using rx exchange id
1406          * or fcoe_select_cpu().
1407          */
1408         if (ntoh24(fh->fh_f_ctl) & FC_FC_EX_CTX)
1409                 cpu = ntohs(fh->fh_ox_id) & fc_cpu_mask;
1410         else {
1411                 if (ntohs(fh->fh_rx_id) == FC_XID_UNKNOWN)
1412                         cpu = fcoe_select_cpu();
1413                 else
1414                         cpu = ntohs(fh->fh_rx_id) & fc_cpu_mask;
1415         }
1416
1417         if (cpu >= nr_cpu_ids)
1418                 goto err;
1419
1420         fps = &per_cpu(fcoe_percpu, cpu);
1421         spin_lock(&fps->fcoe_rx_list.lock);
1422         /*
1423          * We now have a valid CPU that we're targeting for
1424          * this skb. We also have this receive thread locked,
1425          * so we're free to queue skbs into it's queue.
1426          */
1427
1428         /*
1429          * Note: We used to have a set of conditions under which we would
1430          * call fcoe_recv_frame directly, rather than queuing to the rx list
1431          * as it could save a few cycles, but doing so is prohibited, as
1432          * fcoe_recv_frame has several paths that may sleep, which is forbidden
1433          * in softirq context.
1434          */
1435         __skb_queue_tail(&fps->fcoe_rx_list, skb);
1436         schedule_work_on(cpu, &fps->work);
1437         spin_unlock(&fps->fcoe_rx_list.lock);
1438
1439         return NET_RX_SUCCESS;
1440 err:
1441         per_cpu_ptr(lport->stats, get_cpu())->ErrorFrames++;
1442         put_cpu();
1443 err2:
1444         kfree_skb(skb);
1445         return NET_RX_DROP;
1446 }
1447
1448 /**
1449  * fcoe_alloc_paged_crc_eof() - Allocate a page to be used for the trailer CRC
1450  * @skb:  The packet to be transmitted
1451  * @tlen: The total length of the trailer
1452  *
1453  * Returns: 0 for success
1454  */
1455 static int fcoe_alloc_paged_crc_eof(struct sk_buff *skb, int tlen)
1456 {
1457         struct fcoe_percpu_s *fps;
1458         int rc;
1459
1460         fps = &get_cpu_var(fcoe_percpu);
1461         rc = fcoe_get_paged_crc_eof(skb, tlen, fps);
1462         put_cpu_var(fcoe_percpu);
1463
1464         return rc;
1465 }
1466
1467 /**
1468  * fcoe_xmit() - Transmit a FCoE frame
1469  * @lport: The local port that the frame is to be transmitted for
1470  * @fp:    The frame to be transmitted
1471  *
1472  * Return: 0 for success
1473  */
1474 static int fcoe_xmit(struct fc_lport *lport, struct fc_frame *fp)
1475 {
1476         int wlen;
1477         u32 crc;
1478         struct ethhdr *eh;
1479         struct fcoe_crc_eof *cp;
1480         struct sk_buff *skb;
1481         struct fc_stats *stats;
1482         struct fc_frame_header *fh;
1483         unsigned int hlen;              /* header length implies the version */
1484         unsigned int tlen;              /* trailer length */
1485         unsigned int elen;              /* eth header, may include vlan */
1486         struct fcoe_port *port = lport_priv(lport);
1487         struct fcoe_interface *fcoe = port->priv;
1488         struct fcoe_ctlr *ctlr = fcoe_to_ctlr(fcoe);
1489         u8 sof, eof;
1490         struct fcoe_hdr *hp;
1491
1492         WARN_ON((fr_len(fp) % sizeof(u32)) != 0);
1493
1494         fh = fc_frame_header_get(fp);
1495         skb = fp_skb(fp);
1496         wlen = skb->len / FCOE_WORD_TO_BYTE;
1497
1498         if (!lport->link_up) {
1499                 kfree_skb(skb);
1500                 return 0;
1501         }
1502
1503         if (unlikely(fh->fh_type == FC_TYPE_ELS) &&
1504             fcoe_ctlr_els_send(ctlr, lport, skb))
1505                 return 0;
1506
1507         sof = fr_sof(fp);
1508         eof = fr_eof(fp);
1509
1510         elen = sizeof(struct ethhdr);
1511         hlen = sizeof(struct fcoe_hdr);
1512         tlen = sizeof(struct fcoe_crc_eof);
1513         wlen = (skb->len - tlen + sizeof(crc)) / FCOE_WORD_TO_BYTE;
1514
1515         /* crc offload */
1516         if (likely(lport->crc_offload)) {
1517                 skb->ip_summed = CHECKSUM_PARTIAL;
1518                 skb->csum_start = skb_headroom(skb);
1519                 skb->csum_offset = skb->len;
1520                 crc = 0;
1521         } else {
1522                 skb->ip_summed = CHECKSUM_NONE;
1523                 crc = fcoe_fc_crc(fp);
1524         }
1525
1526         /* copy port crc and eof to the skb buff */
1527         if (skb_is_nonlinear(skb)) {
1528                 skb_frag_t *frag;
1529                 if (fcoe_alloc_paged_crc_eof(skb, tlen)) {
1530                         kfree_skb(skb);
1531                         return -ENOMEM;
1532                 }
1533                 frag = &skb_shinfo(skb)->frags[skb_shinfo(skb)->nr_frags - 1];
1534                 cp = kmap_atomic(skb_frag_page(frag))
1535                         + frag->page_offset;
1536         } else {
1537                 cp = (struct fcoe_crc_eof *)skb_put(skb, tlen);
1538         }
1539
1540         memset(cp, 0, sizeof(*cp));
1541         cp->fcoe_eof = eof;
1542         cp->fcoe_crc32 = cpu_to_le32(~crc);
1543
1544         if (skb_is_nonlinear(skb)) {
1545                 kunmap_atomic(cp);
1546                 cp = NULL;
1547         }
1548
1549         /* adjust skb network/transport offsets to match mac/fcoe/port */
1550         skb_push(skb, elen + hlen);
1551         skb_reset_mac_header(skb);
1552         skb_reset_network_header(skb);
1553         skb->mac_len = elen;
1554         skb->protocol = htons(ETH_P_FCOE);
1555         skb->priority = fcoe->priority;
1556
1557         if (fcoe->netdev->priv_flags & IFF_802_1Q_VLAN &&
1558             fcoe->realdev->features & NETIF_F_HW_VLAN_CTAG_TX) {
1559                 /* must set skb->dev before calling vlan_put_tag */
1560                 skb->dev = fcoe->realdev;
1561                 __vlan_hwaccel_put_tag(skb, htons(ETH_P_8021Q),
1562                                        vlan_dev_vlan_id(fcoe->netdev));
1563         } else
1564                 skb->dev = fcoe->netdev;
1565
1566         /* fill up mac and fcoe headers */
1567         eh = eth_hdr(skb);
1568         eh->h_proto = htons(ETH_P_FCOE);
1569         memcpy(eh->h_dest, ctlr->dest_addr, ETH_ALEN);
1570         if (ctlr->map_dest)
1571                 memcpy(eh->h_dest + 3, fh->fh_d_id, 3);
1572
1573         if (unlikely(ctlr->flogi_oxid != FC_XID_UNKNOWN))
1574                 memcpy(eh->h_source, ctlr->ctl_src_addr, ETH_ALEN);
1575         else
1576                 memcpy(eh->h_source, port->data_src_addr, ETH_ALEN);
1577
1578         hp = (struct fcoe_hdr *)(eh + 1);
1579         memset(hp, 0, sizeof(*hp));
1580         if (FC_FCOE_VER)
1581                 FC_FCOE_ENCAPS_VER(hp, FC_FCOE_VER);
1582         hp->fcoe_sof = sof;
1583
1584         /* fcoe lso, mss is in max_payload which is non-zero for FCP data */
1585         if (lport->seq_offload && fr_max_payload(fp)) {
1586                 skb_shinfo(skb)->gso_type = SKB_GSO_FCOE;
1587                 skb_shinfo(skb)->gso_size = fr_max_payload(fp);
1588         } else {
1589                 skb_shinfo(skb)->gso_type = 0;
1590                 skb_shinfo(skb)->gso_size = 0;
1591         }
1592         /* update tx stats: regardless if LLD fails */
1593         stats = per_cpu_ptr(lport->stats, get_cpu());
1594         stats->TxFrames++;
1595         stats->TxWords += wlen;
1596         put_cpu();
1597
1598         /* send down to lld */
1599         fr_dev(fp) = lport;
1600         fcoe_port_send(port, skb);
1601         return 0;
1602 }
1603
1604 /**
1605  * fcoe_filter_frames() - filter out bad fcoe frames, i.e. bad CRC
1606  * @lport: The local port the frame was received on
1607  * @fp:    The received frame
1608  *
1609  * Return: 0 on passing filtering checks
1610  */
1611 static inline int fcoe_filter_frames(struct fc_lport *lport,
1612                                      struct fc_frame *fp)
1613 {
1614         struct fcoe_ctlr *ctlr;
1615         struct fcoe_interface *fcoe;
1616         struct fc_frame_header *fh;
1617         struct sk_buff *skb = (struct sk_buff *)fp;
1618         struct fc_stats *stats;
1619
1620         /*
1621          * We only check CRC if no offload is available and if it is
1622          * it's solicited data, in which case, the FCP layer would
1623          * check it during the copy.
1624          */
1625         if (lport->crc_offload && skb->ip_summed == CHECKSUM_UNNECESSARY)
1626                 fr_flags(fp) &= ~FCPHF_CRC_UNCHECKED;
1627         else
1628                 fr_flags(fp) |= FCPHF_CRC_UNCHECKED;
1629
1630         fh = (struct fc_frame_header *) skb_transport_header(skb);
1631         fh = fc_frame_header_get(fp);
1632         if (fh->fh_r_ctl == FC_RCTL_DD_SOL_DATA && fh->fh_type == FC_TYPE_FCP)
1633                 return 0;
1634
1635         fcoe = ((struct fcoe_port *)lport_priv(lport))->priv;
1636         ctlr = fcoe_to_ctlr(fcoe);
1637         if (is_fip_mode(ctlr) && fc_frame_payload_op(fp) == ELS_LOGO &&
1638             ntoh24(fh->fh_s_id) == FC_FID_FLOGI) {
1639                 FCOE_DBG("fcoe: dropping FCoE lport LOGO in fip mode\n");
1640                 return -EINVAL;
1641         }
1642
1643         if (!(fr_flags(fp) & FCPHF_CRC_UNCHECKED) ||
1644             le32_to_cpu(fr_crc(fp)) == ~crc32(~0, skb->data, skb->len)) {
1645                 fr_flags(fp) &= ~FCPHF_CRC_UNCHECKED;
1646                 return 0;
1647         }
1648
1649         stats = per_cpu_ptr(lport->stats, get_cpu());
1650         stats->InvalidCRCCount++;
1651         if (stats->InvalidCRCCount < 5)
1652                 printk(KERN_WARNING "fcoe: dropping frame with CRC error\n");
1653         put_cpu();
1654         return -EINVAL;
1655 }
1656
1657 /**
1658  * fcoe_recv_frame() - process a single received frame
1659  * @skb: frame to process
1660  */
1661 static void fcoe_recv_frame(struct sk_buff *skb)
1662 {
1663         u32 fr_len;
1664         struct fc_lport *lport;
1665         struct fcoe_rcv_info *fr;
1666         struct fc_stats *stats;
1667         struct fcoe_crc_eof crc_eof;
1668         struct fc_frame *fp;
1669         struct fcoe_port *port;
1670         struct fcoe_hdr *hp;
1671
1672         fr = fcoe_dev_from_skb(skb);
1673         lport = fr->fr_dev;
1674         if (unlikely(!lport)) {
1675                 FCOE_NETDEV_DBG(skb->dev, "NULL lport in skb\n");
1676                 kfree_skb(skb);
1677                 return;
1678         }
1679
1680         FCOE_NETDEV_DBG(skb->dev,
1681                         "skb_info: len:%d data_len:%d head:%p data:%p tail:%p end:%p sum:%d dev:%s\n",
1682                         skb->len, skb->data_len,
1683                         skb->head, skb->data, skb_tail_pointer(skb),
1684                         skb_end_pointer(skb), skb->csum,
1685                         skb->dev ? skb->dev->name : "<NULL>");
1686
1687         port = lport_priv(lport);
1688         skb_linearize(skb); /* check for skb_is_nonlinear is within skb_linearize */
1689
1690         /*
1691          * Frame length checks and setting up the header pointers
1692          * was done in fcoe_rcv already.
1693          */
1694         hp = (struct fcoe_hdr *) skb_network_header(skb);
1695
1696         stats = per_cpu_ptr(lport->stats, get_cpu());
1697         if (unlikely(FC_FCOE_DECAPS_VER(hp) != FC_FCOE_VER)) {
1698                 if (stats->ErrorFrames < 5)
1699                         printk(KERN_WARNING "fcoe: FCoE version "
1700                                "mismatch: The frame has "
1701                                "version %x, but the "
1702                                "initiator supports version "
1703                                "%x\n", FC_FCOE_DECAPS_VER(hp),
1704                                FC_FCOE_VER);
1705                 goto drop;
1706         }
1707
1708         skb_pull(skb, sizeof(struct fcoe_hdr));
1709         fr_len = skb->len - sizeof(struct fcoe_crc_eof);
1710
1711         stats->RxFrames++;
1712         stats->RxWords += fr_len / FCOE_WORD_TO_BYTE;
1713
1714         fp = (struct fc_frame *)skb;
1715         fc_frame_init(fp);
1716         fr_dev(fp) = lport;
1717         fr_sof(fp) = hp->fcoe_sof;
1718
1719         /* Copy out the CRC and EOF trailer for access */
1720         if (skb_copy_bits(skb, fr_len, &crc_eof, sizeof(crc_eof)))
1721                 goto drop;
1722         fr_eof(fp) = crc_eof.fcoe_eof;
1723         fr_crc(fp) = crc_eof.fcoe_crc32;
1724         if (pskb_trim(skb, fr_len))
1725                 goto drop;
1726
1727         if (!fcoe_filter_frames(lport, fp)) {
1728                 put_cpu();
1729                 fc_exch_recv(lport, fp);
1730                 return;
1731         }
1732 drop:
1733         stats->ErrorFrames++;
1734         put_cpu();
1735         kfree_skb(skb);
1736 }
1737
1738 /**
1739  * fcoe_receive_work() - The per-CPU worker
1740  * @work: The work struct
1741  *
1742  */
1743 static void fcoe_receive_work(struct work_struct *work)
1744 {
1745         struct fcoe_percpu_s *p;
1746         struct sk_buff *skb;
1747         struct sk_buff_head tmp;
1748
1749         p = container_of(work, struct fcoe_percpu_s, work);
1750         skb_queue_head_init(&tmp);
1751
1752         spin_lock_bh(&p->fcoe_rx_list.lock);
1753         skb_queue_splice_init(&p->fcoe_rx_list, &tmp);
1754         spin_unlock_bh(&p->fcoe_rx_list.lock);
1755
1756         if (!skb_queue_len(&tmp))
1757                 return;
1758
1759         while ((skb = __skb_dequeue(&tmp)))
1760                 fcoe_recv_frame(skb);
1761 }
1762
1763 /**
1764  * fcoe_dev_setup() - Setup the link change notification interface
1765  */
1766 static void fcoe_dev_setup(void)
1767 {
1768         register_dcbevent_notifier(&dcb_notifier);
1769         register_netdevice_notifier(&fcoe_notifier);
1770 }
1771
1772 /**
1773  * fcoe_dev_cleanup() - Cleanup the link change notification interface
1774  */
1775 static void fcoe_dev_cleanup(void)
1776 {
1777         unregister_dcbevent_notifier(&dcb_notifier);
1778         unregister_netdevice_notifier(&fcoe_notifier);
1779 }
1780
1781 static struct fcoe_interface *
1782 fcoe_hostlist_lookup_realdev_port(struct net_device *netdev)
1783 {
1784         struct fcoe_interface *fcoe;
1785         struct net_device *real_dev;
1786
1787         list_for_each_entry(fcoe, &fcoe_hostlist, list) {
1788                 if (fcoe->netdev->priv_flags & IFF_802_1Q_VLAN)
1789                         real_dev = vlan_dev_real_dev(fcoe->netdev);
1790                 else
1791                         real_dev = fcoe->netdev;
1792
1793                 if (netdev == real_dev)
1794                         return fcoe;
1795         }
1796         return NULL;
1797 }
1798
1799 static int fcoe_dcb_app_notification(struct notifier_block *notifier,
1800                                      ulong event, void *ptr)
1801 {
1802         struct dcb_app_type *entry = ptr;
1803         struct fcoe_ctlr *ctlr;
1804         struct fcoe_interface *fcoe;
1805         struct net_device *netdev;
1806         int prio;
1807
1808         if (entry->app.selector != DCB_APP_IDTYPE_ETHTYPE)
1809                 return NOTIFY_OK;
1810
1811         netdev = dev_get_by_index(&init_net, entry->ifindex);
1812         if (!netdev)
1813                 return NOTIFY_OK;
1814
1815         fcoe = fcoe_hostlist_lookup_realdev_port(netdev);
1816         dev_put(netdev);
1817         if (!fcoe)
1818                 return NOTIFY_OK;
1819
1820         ctlr = fcoe_to_ctlr(fcoe);
1821
1822         if (entry->dcbx & DCB_CAP_DCBX_VER_CEE)
1823                 prio = ffs(entry->app.priority) - 1;
1824         else
1825                 prio = entry->app.priority;
1826
1827         if (prio < 0)
1828                 return NOTIFY_OK;
1829
1830         if (entry->app.protocol == ETH_P_FIP ||
1831             entry->app.protocol == ETH_P_FCOE)
1832                 ctlr->priority = prio;
1833
1834         if (entry->app.protocol == ETH_P_FCOE)
1835                 fcoe->priority = prio;
1836
1837         return NOTIFY_OK;
1838 }
1839
1840 /**
1841  * fcoe_device_notification() - Handler for net device events
1842  * @notifier: The context of the notification
1843  * @event:    The type of event
1844  * @ptr:      The net device that the event was on
1845  *
1846  * This function is called by the Ethernet driver in case of link change event.
1847  *
1848  * Returns: 0 for success
1849  */
1850 static int fcoe_device_notification(struct notifier_block *notifier,
1851                                     ulong event, void *ptr)
1852 {
1853         struct fcoe_ctlr_device *cdev;
1854         struct fc_lport *lport = NULL;
1855         struct net_device *netdev = netdev_notifier_info_to_dev(ptr);
1856         struct fcoe_ctlr *ctlr;
1857         struct fcoe_interface *fcoe;
1858         struct fcoe_port *port;
1859         struct fc_stats *stats;
1860         u32 link_possible = 1;
1861         u32 mfs;
1862         int rc = NOTIFY_OK;
1863
1864         list_for_each_entry(fcoe, &fcoe_hostlist, list) {
1865                 if (fcoe->netdev == netdev) {
1866                         ctlr = fcoe_to_ctlr(fcoe);
1867                         lport = ctlr->lp;
1868                         break;
1869                 }
1870         }
1871         if (!lport) {
1872                 rc = NOTIFY_DONE;
1873                 goto out;
1874         }
1875
1876         switch (event) {
1877         case NETDEV_DOWN:
1878         case NETDEV_GOING_DOWN:
1879                 link_possible = 0;
1880                 break;
1881         case NETDEV_UP:
1882         case NETDEV_CHANGE:
1883                 break;
1884         case NETDEV_CHANGEMTU:
1885                 if (netdev->features & NETIF_F_FCOE_MTU)
1886                         break;
1887                 mfs = netdev->mtu - (sizeof(struct fcoe_hdr) +
1888                                      sizeof(struct fcoe_crc_eof));
1889                 if (mfs >= FC_MIN_MAX_FRAME)
1890                         fc_set_mfs(lport, mfs);
1891                 break;
1892         case NETDEV_REGISTER:
1893                 break;
1894         case NETDEV_UNREGISTER:
1895                 list_del(&fcoe->list);
1896                 port = lport_priv(ctlr->lp);
1897                 queue_work(fcoe_wq, &port->destroy_work);
1898                 goto out;
1899                 break;
1900         case NETDEV_FEAT_CHANGE:
1901                 fcoe_netdev_features_change(lport, netdev);
1902                 break;
1903         default:
1904                 FCOE_NETDEV_DBG(netdev, "Unknown event %ld "
1905                                 "from netdev netlink\n", event);
1906         }
1907
1908         fcoe_link_speed_update(lport);
1909
1910         cdev = fcoe_ctlr_to_ctlr_dev(ctlr);
1911
1912         if (link_possible && !fcoe_link_ok(lport)) {
1913                 switch (cdev->enabled) {
1914                 case FCOE_CTLR_DISABLED:
1915                         pr_info("Link up while interface is disabled.\n");
1916                         break;
1917                 case FCOE_CTLR_ENABLED:
1918                 case FCOE_CTLR_UNUSED:
1919                         fcoe_ctlr_link_up(ctlr);
1920                 };
1921         } else if (fcoe_ctlr_link_down(ctlr)) {
1922                 switch (cdev->enabled) {
1923                 case FCOE_CTLR_DISABLED:
1924                         pr_info("Link down while interface is disabled.\n");
1925                         break;
1926                 case FCOE_CTLR_ENABLED:
1927                 case FCOE_CTLR_UNUSED:
1928                         stats = per_cpu_ptr(lport->stats, get_cpu());
1929                         stats->LinkFailureCount++;
1930                         put_cpu();
1931                         fcoe_clean_pending_queue(lport);
1932                 };
1933         }
1934 out:
1935         return rc;
1936 }
1937
1938 /**
1939  * fcoe_disable() - Disables a FCoE interface
1940  * @netdev  : The net_device object the Ethernet interface to create on
1941  *
1942  * Called from fcoe transport.
1943  *
1944  * Returns: 0 for success
1945  *
1946  * Deprecated: use fcoe_ctlr_enabled()
1947  */
1948 static int fcoe_disable(struct net_device *netdev)
1949 {
1950         struct fcoe_ctlr *ctlr;
1951         struct fcoe_interface *fcoe;
1952         int rc = 0;
1953
1954         mutex_lock(&fcoe_config_mutex);
1955
1956         rtnl_lock();
1957         fcoe = fcoe_hostlist_lookup_port(netdev);
1958         rtnl_unlock();
1959
1960         if (fcoe) {
1961                 ctlr = fcoe_to_ctlr(fcoe);
1962                 fcoe_ctlr_link_down(ctlr);
1963                 fcoe_clean_pending_queue(ctlr->lp);
1964         } else
1965                 rc = -ENODEV;
1966
1967         mutex_unlock(&fcoe_config_mutex);
1968         return rc;
1969 }
1970
1971 /**
1972  * fcoe_enable() - Enables a FCoE interface
1973  * @netdev  : The net_device object the Ethernet interface to create on
1974  *
1975  * Called from fcoe transport.
1976  *
1977  * Returns: 0 for success
1978  */
1979 static int fcoe_enable(struct net_device *netdev)
1980 {
1981         struct fcoe_ctlr *ctlr;
1982         struct fcoe_interface *fcoe;
1983         int rc = 0;
1984
1985         mutex_lock(&fcoe_config_mutex);
1986         rtnl_lock();
1987         fcoe = fcoe_hostlist_lookup_port(netdev);
1988         rtnl_unlock();
1989
1990         if (!fcoe) {
1991                 rc = -ENODEV;
1992                 goto out;
1993         }
1994
1995         ctlr = fcoe_to_ctlr(fcoe);
1996
1997         if (!fcoe_link_ok(ctlr->lp))
1998                 fcoe_ctlr_link_up(ctlr);
1999
2000 out:
2001         mutex_unlock(&fcoe_config_mutex);
2002         return rc;
2003 }
2004
2005 /**
2006  * fcoe_ctlr_enabled() - Enable or disable an FCoE Controller
2007  * @cdev: The FCoE Controller that is being enabled or disabled
2008  *
2009  * fcoe_sysfs will ensure that the state of 'enabled' has
2010  * changed, so no checking is necessary here. This routine simply
2011  * calls fcoe_enable or fcoe_disable, both of which are deprecated.
2012  * When those routines are removed the functionality can be merged
2013  * here.
2014  */
2015 static int fcoe_ctlr_enabled(struct fcoe_ctlr_device *cdev)
2016 {
2017         struct fcoe_ctlr *ctlr = fcoe_ctlr_device_priv(cdev);
2018         struct fc_lport *lport = ctlr->lp;
2019         struct net_device *netdev = fcoe_netdev(lport);
2020
2021         switch (cdev->enabled) {
2022         case FCOE_CTLR_ENABLED:
2023                 return fcoe_enable(netdev);
2024         case FCOE_CTLR_DISABLED:
2025                 return fcoe_disable(netdev);
2026         case FCOE_CTLR_UNUSED:
2027         default:
2028                 return -ENOTSUPP;
2029         };
2030 }
2031
2032 /**
2033  * fcoe_ctlr_mode() - Switch FIP mode
2034  * @cdev: The FCoE Controller that is being modified
2035  *
2036  * When the FIP mode has been changed we need to update
2037  * the multicast addresses to ensure we get the correct
2038  * frames.
2039  */
2040 static void fcoe_ctlr_mode(struct fcoe_ctlr_device *ctlr_dev)
2041 {
2042         struct fcoe_ctlr *ctlr = fcoe_ctlr_device_priv(ctlr_dev);
2043         struct fcoe_interface *fcoe = fcoe_ctlr_priv(ctlr);
2044
2045         if (ctlr_dev->mode == FIP_CONN_TYPE_VN2VN &&
2046             ctlr->mode != FIP_MODE_VN2VN) {
2047                 dev_mc_del(fcoe->netdev, FIP_ALL_ENODE_MACS);
2048                 dev_mc_add(fcoe->netdev, FIP_ALL_VN2VN_MACS);
2049                 dev_mc_add(fcoe->netdev, FIP_ALL_P2P_MACS);
2050         } else if (ctlr->mode != FIP_MODE_FABRIC) {
2051                 dev_mc_del(fcoe->netdev, FIP_ALL_VN2VN_MACS);
2052                 dev_mc_del(fcoe->netdev, FIP_ALL_P2P_MACS);
2053                 dev_mc_add(fcoe->netdev, FIP_ALL_ENODE_MACS);
2054         }
2055         fcoe_ctlr_set_fip_mode(ctlr_dev);
2056 }
2057
2058 /**
2059  * fcoe_destroy() - Destroy a FCoE interface
2060  * @netdev  : The net_device object the Ethernet interface to create on
2061  *
2062  * Called from fcoe transport
2063  *
2064  * Returns: 0 for success
2065  */
2066 static int fcoe_destroy(struct net_device *netdev)
2067 {
2068         struct fcoe_ctlr *ctlr;
2069         struct fcoe_interface *fcoe;
2070         struct fc_lport *lport;
2071         struct fcoe_port *port;
2072         int rc = 0;
2073
2074         mutex_lock(&fcoe_config_mutex);
2075         rtnl_lock();
2076         fcoe = fcoe_hostlist_lookup_port(netdev);
2077         if (!fcoe) {
2078                 rc = -ENODEV;
2079                 goto out_nodev;
2080         }
2081         ctlr = fcoe_to_ctlr(fcoe);
2082         lport = ctlr->lp;
2083         port = lport_priv(lport);
2084         list_del(&fcoe->list);
2085         queue_work(fcoe_wq, &port->destroy_work);
2086 out_nodev:
2087         rtnl_unlock();
2088         mutex_unlock(&fcoe_config_mutex);
2089         return rc;
2090 }
2091
2092 /**
2093  * fcoe_destroy_work() - Destroy a FCoE port in a deferred work context
2094  * @work: Handle to the FCoE port to be destroyed
2095  */
2096 static void fcoe_destroy_work(struct work_struct *work)
2097 {
2098         struct fcoe_ctlr_device *cdev;
2099         struct fcoe_ctlr *ctlr;
2100         struct fcoe_port *port;
2101         struct fcoe_interface *fcoe;
2102         struct Scsi_Host *shost;
2103         struct fc_host_attrs *fc_host;
2104         unsigned long flags;
2105         struct fc_vport *vport;
2106         struct fc_vport *next_vport;
2107
2108         port = container_of(work, struct fcoe_port, destroy_work);
2109         shost = port->lport->host;
2110         fc_host = shost_to_fc_host(shost);
2111
2112         /* Loop through all the vports and mark them for deletion */
2113         spin_lock_irqsave(shost->host_lock, flags);
2114         list_for_each_entry_safe(vport, next_vport, &fc_host->vports, peers) {
2115                 if (vport->flags & (FC_VPORT_DEL | FC_VPORT_CREATING)) {
2116                         continue;
2117                 } else {
2118                         vport->flags |= FC_VPORT_DELETING;
2119                         queue_work(fc_host_work_q(shost),
2120                                    &vport->vport_delete_work);
2121                 }
2122         }
2123         spin_unlock_irqrestore(shost->host_lock, flags);
2124
2125         flush_workqueue(fc_host_work_q(shost));
2126
2127         mutex_lock(&fcoe_config_mutex);
2128
2129         fcoe = port->priv;
2130         ctlr = fcoe_to_ctlr(fcoe);
2131         cdev = fcoe_ctlr_to_ctlr_dev(ctlr);
2132
2133         fcoe_if_destroy(port->lport);
2134         fcoe_interface_cleanup(fcoe);
2135
2136         mutex_unlock(&fcoe_config_mutex);
2137
2138         fcoe_ctlr_device_delete(cdev);
2139 }
2140
2141 /**
2142  * fcoe_match() - Check if the FCoE is supported on the given netdevice
2143  * @netdev  : The net_device object the Ethernet interface to create on
2144  *
2145  * Called from fcoe transport.
2146  *
2147  * Returns: always returns true as this is the default FCoE transport,
2148  * i.e., support all netdevs.
2149  */
2150 static bool fcoe_match(struct net_device *netdev)
2151 {
2152         return true;
2153 }
2154
2155 /**
2156  * fcoe_dcb_create() - Initialize DCB attributes and hooks
2157  * @netdev: The net_device object of the L2 link that should be queried
2158  * @port: The fcoe_port to bind FCoE APP priority with
2159  * @
2160  */
2161 static void fcoe_dcb_create(struct fcoe_interface *fcoe)
2162 {
2163 #ifdef CONFIG_DCB
2164         int dcbx;
2165         u8 fup, up;
2166         struct net_device *netdev = fcoe->realdev;
2167         struct fcoe_ctlr *ctlr = fcoe_to_ctlr(fcoe);
2168         struct dcb_app app = {
2169                                 .priority = 0,
2170                                 .protocol = ETH_P_FCOE
2171                              };
2172
2173         /* setup DCB priority attributes. */
2174         if (netdev && netdev->dcbnl_ops && netdev->dcbnl_ops->getdcbx) {
2175                 dcbx = netdev->dcbnl_ops->getdcbx(netdev);
2176
2177                 if (dcbx & DCB_CAP_DCBX_VER_IEEE) {
2178                         app.selector = IEEE_8021QAZ_APP_SEL_ETHERTYPE;
2179                         up = dcb_ieee_getapp_mask(netdev, &app);
2180                         app.protocol = ETH_P_FIP;
2181                         fup = dcb_ieee_getapp_mask(netdev, &app);
2182                 } else {
2183                         app.selector = DCB_APP_IDTYPE_ETHTYPE;
2184                         up = dcb_getapp(netdev, &app);
2185                         app.protocol = ETH_P_FIP;
2186                         fup = dcb_getapp(netdev, &app);
2187                 }
2188
2189                 fcoe->priority = ffs(up) ? ffs(up) - 1 : 0;
2190                 ctlr->priority = ffs(fup) ? ffs(fup) - 1 : fcoe->priority;
2191         }
2192 #endif
2193 }
2194
2195 enum fcoe_create_link_state {
2196         FCOE_CREATE_LINK_DOWN,
2197         FCOE_CREATE_LINK_UP,
2198 };
2199
2200 /**
2201  * _fcoe_create() - (internal) Create a fcoe interface
2202  * @netdev  :   The net_device object the Ethernet interface to create on
2203  * @fip_mode:   The FIP mode for this creation
2204  * @link_state: The ctlr link state on creation
2205  *
2206  * Called from either the libfcoe 'create' module parameter
2207  * via fcoe_create or from fcoe_syfs's ctlr_create file.
2208  *
2209  * libfcoe's 'create' module parameter is deprecated so some
2210  * consolidation of code can be done when that interface is
2211  * removed.
2212  */
2213 static int _fcoe_create(struct net_device *netdev, enum fip_mode fip_mode,
2214                         enum fcoe_create_link_state link_state)
2215 {
2216         int rc = 0;
2217         struct fcoe_ctlr_device *ctlr_dev;
2218         struct fcoe_ctlr *ctlr;
2219         struct fcoe_interface *fcoe;
2220         struct fc_lport *lport;
2221
2222         mutex_lock(&fcoe_config_mutex);
2223         rtnl_lock();
2224
2225         /* look for existing lport */
2226         if (fcoe_hostlist_lookup(netdev)) {
2227                 rc = -EEXIST;
2228                 goto out_nodev;
2229         }
2230
2231         fcoe = fcoe_interface_create(netdev, fip_mode);
2232         if (IS_ERR(fcoe)) {
2233                 rc = PTR_ERR(fcoe);
2234                 goto out_nodev;
2235         }
2236
2237         ctlr = fcoe_to_ctlr(fcoe);
2238         ctlr_dev = fcoe_ctlr_to_ctlr_dev(ctlr);
2239         lport = fcoe_if_create(fcoe, &ctlr_dev->dev, 0);
2240         if (IS_ERR(lport)) {
2241                 printk(KERN_ERR "fcoe: Failed to create interface (%s)\n",
2242                        netdev->name);
2243                 rc = -EIO;
2244                 rtnl_unlock();
2245                 fcoe_interface_cleanup(fcoe);
2246                 mutex_unlock(&fcoe_config_mutex);
2247                 fcoe_ctlr_device_delete(ctlr_dev);
2248                 goto out;
2249         }
2250
2251         /* Make this the "master" N_Port */
2252         ctlr->lp = lport;
2253
2254         /* setup DCB priority attributes. */
2255         fcoe_dcb_create(fcoe);
2256
2257         /* start FIP Discovery and FLOGI */
2258         lport->boot_time = jiffies;
2259         fc_fabric_login(lport);
2260
2261         /*
2262          * If the fcoe_ctlr_device is to be set to DISABLED
2263          * it must be done after the lport is added to the
2264          * hostlist, but before the rtnl_lock is released.
2265          * This is because the rtnl_lock protects the
2266          * hostlist that fcoe_device_notification uses. If
2267          * the FCoE Controller is intended to be created
2268          * DISABLED then 'enabled' needs to be considered
2269          * handling link events. 'enabled' must be set
2270          * before the lport can be found in the hostlist
2271          * when a link up event is received.
2272          */
2273         if (link_state == FCOE_CREATE_LINK_UP)
2274                 ctlr_dev->enabled = FCOE_CTLR_ENABLED;
2275         else
2276                 ctlr_dev->enabled = FCOE_CTLR_DISABLED;
2277
2278         if (link_state == FCOE_CREATE_LINK_UP &&
2279             !fcoe_link_ok(lport)) {
2280                 rtnl_unlock();
2281                 fcoe_ctlr_link_up(ctlr);
2282                 mutex_unlock(&fcoe_config_mutex);
2283                 return rc;
2284         }
2285
2286 out_nodev:
2287         rtnl_unlock();
2288         mutex_unlock(&fcoe_config_mutex);
2289 out:
2290         return rc;
2291 }
2292
2293 /**
2294  * fcoe_create() - Create a fcoe interface
2295  * @netdev  : The net_device object the Ethernet interface to create on
2296  * @fip_mode: The FIP mode for this creation
2297  *
2298  * Called from fcoe transport
2299  *
2300  * Returns: 0 for success
2301  */
2302 static int fcoe_create(struct net_device *netdev, enum fip_mode fip_mode)
2303 {
2304         return _fcoe_create(netdev, fip_mode, FCOE_CREATE_LINK_UP);
2305 }
2306
2307 /**
2308  * fcoe_ctlr_alloc() - Allocate a fcoe interface from fcoe_sysfs
2309  * @netdev: The net_device to be used by the allocated FCoE Controller
2310  *
2311  * This routine is called from fcoe_sysfs. It will start the fcoe_ctlr
2312  * in a link_down state. The allows the user an opportunity to configure
2313  * the FCoE Controller from sysfs before enabling the FCoE Controller.
2314  *
2315  * Creating in with this routine starts the FCoE Controller in Fabric
2316  * mode. The user can change to VN2VN or another mode before enabling.
2317  */
2318 static int fcoe_ctlr_alloc(struct net_device *netdev)
2319 {
2320         return _fcoe_create(netdev, FIP_MODE_FABRIC,
2321                             FCOE_CREATE_LINK_DOWN);
2322 }
2323
2324 /**
2325  * fcoe_link_ok() - Check if the link is OK for a local port
2326  * @lport: The local port to check link on
2327  *
2328  * Returns: 0 if link is UP and OK, -1 if not
2329  *
2330  */
2331 static int fcoe_link_ok(struct fc_lport *lport)
2332 {
2333         struct net_device *netdev = fcoe_netdev(lport);
2334
2335         if (netif_oper_up(netdev))
2336                 return 0;
2337         return -1;
2338 }
2339
2340 /**
2341  * fcoe_percpu_clean() - Clear all pending skbs for an local port
2342  * @lport: The local port whose skbs are to be cleared
2343  *
2344  * Must be called with fcoe_create_mutex held to single-thread completion.
2345  *
2346  * This flushes the pending skbs by flush the work item for each CPU. The work
2347  * item on each possible CPU is flushed because we may have used the per-CPU
2348  * struct of an offline CPU.
2349  */
2350 static void fcoe_percpu_clean(struct fc_lport *lport)
2351 {
2352         struct fcoe_percpu_s *pp;
2353         unsigned int cpu;
2354
2355         for_each_possible_cpu(cpu) {
2356                 pp = &per_cpu(fcoe_percpu, cpu);
2357
2358                 flush_work(&pp->work);
2359         }
2360 }
2361
2362 /**
2363  * fcoe_reset() - Reset a local port
2364  * @shost: The SCSI host associated with the local port to be reset
2365  *
2366  * Returns: Always 0 (return value required by FC transport template)
2367  */
2368 static int fcoe_reset(struct Scsi_Host *shost)
2369 {
2370         struct fc_lport *lport = shost_priv(shost);
2371         struct fcoe_port *port = lport_priv(lport);
2372         struct fcoe_interface *fcoe = port->priv;
2373         struct fcoe_ctlr *ctlr = fcoe_to_ctlr(fcoe);
2374         struct fcoe_ctlr_device *cdev = fcoe_ctlr_to_ctlr_dev(ctlr);
2375
2376         fcoe_ctlr_link_down(ctlr);
2377         fcoe_clean_pending_queue(ctlr->lp);
2378
2379         if (cdev->enabled != FCOE_CTLR_DISABLED &&
2380             !fcoe_link_ok(ctlr->lp))
2381                 fcoe_ctlr_link_up(ctlr);
2382         return 0;
2383 }
2384
2385 /**
2386  * fcoe_hostlist_lookup_port() - Find the FCoE interface associated with a net device
2387  * @netdev: The net device used as a key
2388  *
2389  * Locking: Must be called with the RNL mutex held.
2390  *
2391  * Returns: NULL or the FCoE interface
2392  */
2393 static struct fcoe_interface *
2394 fcoe_hostlist_lookup_port(const struct net_device *netdev)
2395 {
2396         struct fcoe_interface *fcoe;
2397
2398         list_for_each_entry(fcoe, &fcoe_hostlist, list) {
2399                 if (fcoe->netdev == netdev)
2400                         return fcoe;
2401         }
2402         return NULL;
2403 }
2404
2405 /**
2406  * fcoe_hostlist_lookup() - Find the local port associated with a
2407  *                          given net device
2408  * @netdev: The netdevice used as a key
2409  *
2410  * Locking: Must be called with the RTNL mutex held
2411  *
2412  * Returns: NULL or the local port
2413  */
2414 static struct fc_lport *fcoe_hostlist_lookup(const struct net_device *netdev)
2415 {
2416         struct fcoe_ctlr *ctlr;
2417         struct fcoe_interface *fcoe;
2418
2419         fcoe = fcoe_hostlist_lookup_port(netdev);
2420         ctlr = fcoe_to_ctlr(fcoe);
2421         return (fcoe) ? ctlr->lp : NULL;
2422 }
2423
2424 /**
2425  * fcoe_hostlist_add() - Add the FCoE interface identified by a local
2426  *                       port to the hostlist
2427  * @lport: The local port that identifies the FCoE interface to be added
2428  *
2429  * Locking: must be called with the RTNL mutex held
2430  *
2431  * Returns: 0 for success
2432  */
2433 static int fcoe_hostlist_add(const struct fc_lport *lport)
2434 {
2435         struct fcoe_interface *fcoe;
2436         struct fcoe_port *port;
2437
2438         fcoe = fcoe_hostlist_lookup_port(fcoe_netdev(lport));
2439         if (!fcoe) {
2440                 port = lport_priv(lport);
2441                 fcoe = port->priv;
2442                 list_add_tail(&fcoe->list, &fcoe_hostlist);
2443         }
2444         return 0;
2445 }
2446
2447 /**
2448  * fcoe_hostlist_del() - Remove the FCoE interface identified by a local
2449  *                       port to the hostlist
2450  * @lport: The local port that identifies the FCoE interface to be added
2451  *
2452  * Locking: must be called with the RTNL mutex held
2453  *
2454  */
2455 static void fcoe_hostlist_del(const struct fc_lport *lport)
2456 {
2457         struct fcoe_interface *fcoe;
2458         struct fcoe_port *port;
2459
2460         port = lport_priv(lport);
2461         fcoe = port->priv;
2462         list_del(&fcoe->list);
2463         return;
2464 }
2465
2466 static struct fcoe_transport fcoe_sw_transport = {
2467         .name = {FCOE_TRANSPORT_DEFAULT},
2468         .attached = false,
2469         .list = LIST_HEAD_INIT(fcoe_sw_transport.list),
2470         .match = fcoe_match,
2471         .alloc = fcoe_ctlr_alloc,
2472         .create = fcoe_create,
2473         .destroy = fcoe_destroy,
2474         .enable = fcoe_enable,
2475         .disable = fcoe_disable,
2476 };
2477
2478 /**
2479  * fcoe_init() - Initialize fcoe.ko
2480  *
2481  * Returns: 0 on success, or a negative value on failure
2482  */
2483 static int __init fcoe_init(void)
2484 {
2485         struct fcoe_percpu_s *p;
2486         unsigned int cpu;
2487         int rc = 0;
2488
2489         fcoe_wq = alloc_workqueue("fcoe", 0, 0);
2490         if (!fcoe_wq)
2491                 return -ENOMEM;
2492
2493         /* register as a fcoe transport */
2494         rc = fcoe_transport_attach(&fcoe_sw_transport);
2495         if (rc) {
2496                 printk(KERN_ERR "failed to register an fcoe transport, check "
2497                         "if libfcoe is loaded\n");
2498                 goto out_destroy;
2499         }
2500
2501         mutex_lock(&fcoe_config_mutex);
2502
2503         for_each_possible_cpu(cpu) {
2504                 p = per_cpu_ptr(&fcoe_percpu, cpu);
2505                 INIT_WORK(&p->work, fcoe_receive_work);
2506                 skb_queue_head_init(&p->fcoe_rx_list);
2507         }
2508
2509         /* Setup link change notification */
2510         fcoe_dev_setup();
2511
2512         rc = fcoe_if_init();
2513         if (rc)
2514                 goto out_free;
2515
2516         mutex_unlock(&fcoe_config_mutex);
2517         return 0;
2518
2519 out_free:
2520         mutex_unlock(&fcoe_config_mutex);
2521 out_destroy:
2522         destroy_workqueue(fcoe_wq);
2523         return rc;
2524 }
2525 module_init(fcoe_init);
2526
2527 /**
2528  * fcoe_exit() - Clean up fcoe.ko
2529  *
2530  * Returns: 0 on success or a  negative value on failure
2531  */
2532 static void __exit fcoe_exit(void)
2533 {
2534         struct fcoe_interface *fcoe, *tmp;
2535         struct fcoe_ctlr *ctlr;
2536         struct fcoe_port *port;
2537         unsigned int cpu;
2538
2539         mutex_lock(&fcoe_config_mutex);
2540
2541         fcoe_dev_cleanup();
2542
2543         /* releases the associated fcoe hosts */
2544         rtnl_lock();
2545         list_for_each_entry_safe(fcoe, tmp, &fcoe_hostlist, list) {
2546                 ctlr = fcoe_to_ctlr(fcoe);
2547                 port = lport_priv(ctlr->lp);
2548                 fcoe_hostlist_del(port->lport);
2549                 queue_work(fcoe_wq, &port->destroy_work);
2550         }
2551         rtnl_unlock();
2552
2553         for_each_possible_cpu(cpu)
2554                 fcoe_thread_cleanup_local(cpu);
2555
2556         mutex_unlock(&fcoe_config_mutex);
2557
2558         /*
2559          * destroy_work's may be chained but destroy_workqueue()
2560          * can take care of them. Just kill the fcoe_wq.
2561          */
2562         destroy_workqueue(fcoe_wq);
2563
2564         /*
2565          * Detaching from the scsi transport must happen after all
2566          * destroys are done on the fcoe_wq. destroy_workqueue will
2567          * enusre the fcoe_wq is flushed.
2568          */
2569         fcoe_if_exit();
2570
2571         /* detach from fcoe transport */
2572         fcoe_transport_detach(&fcoe_sw_transport);
2573 }
2574 module_exit(fcoe_exit);
2575
2576 /**
2577  * fcoe_flogi_resp() - FCoE specific FLOGI and FDISC response handler
2578  * @seq: active sequence in the FLOGI or FDISC exchange
2579  * @fp: response frame, or error encoded in a pointer (timeout)
2580  * @arg: pointer the the fcoe_ctlr structure
2581  *
2582  * This handles MAC address management for FCoE, then passes control on to
2583  * the libfc FLOGI response handler.
2584  */
2585 static void fcoe_flogi_resp(struct fc_seq *seq, struct fc_frame *fp, void *arg)
2586 {
2587         struct fcoe_ctlr *fip = arg;
2588         struct fc_exch *exch = fc_seq_exch(seq);
2589         struct fc_lport *lport = exch->lp;
2590         u8 *mac;
2591
2592         if (IS_ERR(fp))
2593                 goto done;
2594
2595         mac = fr_cb(fp)->granted_mac;
2596         /* pre-FIP */
2597         if (is_zero_ether_addr(mac))
2598                 fcoe_ctlr_recv_flogi(fip, lport, fp);
2599         if (!is_zero_ether_addr(mac))
2600                 fcoe_update_src_mac(lport, mac);
2601 done:
2602         fc_lport_flogi_resp(seq, fp, lport);
2603 }
2604
2605 /**
2606  * fcoe_logo_resp() - FCoE specific LOGO response handler
2607  * @seq: active sequence in the LOGO exchange
2608  * @fp: response frame, or error encoded in a pointer (timeout)
2609  * @arg: pointer the the fcoe_ctlr structure
2610  *
2611  * This handles MAC address management for FCoE, then passes control on to
2612  * the libfc LOGO response handler.
2613  */
2614 static void fcoe_logo_resp(struct fc_seq *seq, struct fc_frame *fp, void *arg)
2615 {
2616         struct fc_lport *lport = arg;
2617         static u8 zero_mac[ETH_ALEN] = { 0 };
2618
2619         if (!IS_ERR(fp))
2620                 fcoe_update_src_mac(lport, zero_mac);
2621         fc_lport_logo_resp(seq, fp, lport);
2622 }
2623
2624 /**
2625  * fcoe_elsct_send - FCoE specific ELS handler
2626  *
2627  * This does special case handling of FIP encapsualted ELS exchanges for FCoE,
2628  * using FCoE specific response handlers and passing the FIP controller as
2629  * the argument (the lport is still available from the exchange).
2630  *
2631  * Most of the work here is just handed off to the libfc routine.
2632  */
2633 static struct fc_seq *fcoe_elsct_send(struct fc_lport *lport, u32 did,
2634                                       struct fc_frame *fp, unsigned int op,
2635                                       void (*resp)(struct fc_seq *,
2636                                                    struct fc_frame *,
2637                                                    void *),
2638                                       void *arg, u32 timeout)
2639 {
2640         struct fcoe_port *port = lport_priv(lport);
2641         struct fcoe_interface *fcoe = port->priv;
2642         struct fcoe_ctlr *fip = fcoe_to_ctlr(fcoe);
2643         struct fc_frame_header *fh = fc_frame_header_get(fp);
2644
2645         switch (op) {
2646         case ELS_FLOGI:
2647         case ELS_FDISC:
2648                 if (lport->point_to_multipoint)
2649                         break;
2650                 return fc_elsct_send(lport, did, fp, op, fcoe_flogi_resp,
2651                                      fip, timeout);
2652         case ELS_LOGO:
2653                 /* only hook onto fabric logouts, not port logouts */
2654                 if (ntoh24(fh->fh_d_id) != FC_FID_FLOGI)
2655                         break;
2656                 return fc_elsct_send(lport, did, fp, op, fcoe_logo_resp,
2657                                      lport, timeout);
2658         }
2659         return fc_elsct_send(lport, did, fp, op, resp, arg, timeout);
2660 }
2661
2662 /**
2663  * fcoe_vport_create() - create an fc_host/scsi_host for a vport
2664  * @vport: fc_vport object to create a new fc_host for
2665  * @disabled: start the new fc_host in a disabled state by default?
2666  *
2667  * Returns: 0 for success
2668  */
2669 static int fcoe_vport_create(struct fc_vport *vport, bool disabled)
2670 {
2671         struct Scsi_Host *shost = vport_to_shost(vport);
2672         struct fc_lport *n_port = shost_priv(shost);
2673         struct fcoe_port *port = lport_priv(n_port);
2674         struct fcoe_interface *fcoe = port->priv;
2675         struct net_device *netdev = fcoe->netdev;
2676         struct fc_lport *vn_port;
2677         int rc;
2678         char buf[32];
2679
2680         rc = fcoe_validate_vport_create(vport);
2681         if (rc) {
2682                 fcoe_wwn_to_str(vport->port_name, buf, sizeof(buf));
2683                 printk(KERN_ERR "fcoe: Failed to create vport, "
2684                         "WWPN (0x%s) already exists\n",
2685                         buf);
2686                 return rc;
2687         }
2688
2689         mutex_lock(&fcoe_config_mutex);
2690         rtnl_lock();
2691         vn_port = fcoe_if_create(fcoe, &vport->dev, 1);
2692         rtnl_unlock();
2693         mutex_unlock(&fcoe_config_mutex);
2694
2695         if (IS_ERR(vn_port)) {
2696                 printk(KERN_ERR "fcoe: fcoe_vport_create(%s) failed\n",
2697                        netdev->name);
2698                 return -EIO;
2699         }
2700
2701         if (disabled) {
2702                 fc_vport_set_state(vport, FC_VPORT_DISABLED);
2703         } else {
2704                 vn_port->boot_time = jiffies;
2705                 fc_fabric_login(vn_port);
2706                 fc_vport_setlink(vn_port);
2707         }
2708         return 0;
2709 }
2710
2711 /**
2712  * fcoe_vport_destroy() - destroy the fc_host/scsi_host for a vport
2713  * @vport: fc_vport object that is being destroyed
2714  *
2715  * Returns: 0 for success
2716  */
2717 static int fcoe_vport_destroy(struct fc_vport *vport)
2718 {
2719         struct Scsi_Host *shost = vport_to_shost(vport);
2720         struct fc_lport *n_port = shost_priv(shost);
2721         struct fc_lport *vn_port = vport->dd_data;
2722
2723         mutex_lock(&n_port->lp_mutex);
2724         list_del(&vn_port->list);
2725         mutex_unlock(&n_port->lp_mutex);
2726
2727         mutex_lock(&fcoe_config_mutex);
2728         fcoe_if_destroy(vn_port);
2729         mutex_unlock(&fcoe_config_mutex);
2730
2731         return 0;
2732 }
2733
2734 /**
2735  * fcoe_vport_disable() - change vport state
2736  * @vport: vport to bring online/offline
2737  * @disable: should the vport be disabled?
2738  */
2739 static int fcoe_vport_disable(struct fc_vport *vport, bool disable)
2740 {
2741         struct fc_lport *lport = vport->dd_data;
2742
2743         if (disable) {
2744                 fc_vport_set_state(vport, FC_VPORT_DISABLED);
2745                 fc_fabric_logoff(lport);
2746         } else {
2747                 lport->boot_time = jiffies;
2748                 fc_fabric_login(lport);
2749                 fc_vport_setlink(lport);
2750         }
2751
2752         return 0;
2753 }
2754
2755 /**
2756  * fcoe_vport_set_symbolic_name() - append vport string to symbolic name
2757  * @vport: fc_vport with a new symbolic name string
2758  *
2759  * After generating a new symbolic name string, a new RSPN_ID request is
2760  * sent to the name server.  There is no response handler, so if it fails
2761  * for some reason it will not be retried.
2762  */
2763 static void fcoe_set_vport_symbolic_name(struct fc_vport *vport)
2764 {
2765         struct fc_lport *lport = vport->dd_data;
2766         struct fc_frame *fp;
2767         size_t len;
2768
2769         snprintf(fc_host_symbolic_name(lport->host), FC_SYMBOLIC_NAME_SIZE,
2770                  "%s v%s over %s : %s", FCOE_NAME, FCOE_VERSION,
2771                  fcoe_netdev(lport)->name, vport->symbolic_name);
2772
2773         if (lport->state != LPORT_ST_READY)
2774                 return;
2775
2776         len = strnlen(fc_host_symbolic_name(lport->host), 255);
2777         fp = fc_frame_alloc(lport,
2778                             sizeof(struct fc_ct_hdr) +
2779                             sizeof(struct fc_ns_rspn) + len);
2780         if (!fp)
2781                 return;
2782         lport->tt.elsct_send(lport, FC_FID_DIR_SERV, fp, FC_NS_RSPN_ID,
2783                              NULL, NULL, 3 * lport->r_a_tov);
2784 }
2785
2786 static void fcoe_fcf_get_vlan_id(struct fcoe_fcf_device *fcf_dev)
2787 {
2788         struct fcoe_ctlr_device *ctlr_dev =
2789                 fcoe_fcf_dev_to_ctlr_dev(fcf_dev);
2790         struct fcoe_ctlr *ctlr = fcoe_ctlr_device_priv(ctlr_dev);
2791         struct fcoe_interface *fcoe = fcoe_ctlr_priv(ctlr);
2792
2793         fcf_dev->vlan_id = vlan_dev_vlan_id(fcoe->netdev);
2794 }
2795
2796 /**
2797  * fcoe_set_port_id() - Callback from libfc when Port_ID is set.
2798  * @lport: the local port
2799  * @port_id: the port ID
2800  * @fp: the received frame, if any, that caused the port_id to be set.
2801  *
2802  * This routine handles the case where we received a FLOGI and are
2803  * entering point-to-point mode.  We need to call fcoe_ctlr_recv_flogi()
2804  * so it can set the non-mapped mode and gateway address.
2805  *
2806  * The FLOGI LS_ACC is handled by fcoe_flogi_resp().
2807  */
2808 static void fcoe_set_port_id(struct fc_lport *lport,
2809                              u32 port_id, struct fc_frame *fp)
2810 {
2811         struct fcoe_port *port = lport_priv(lport);
2812         struct fcoe_interface *fcoe = port->priv;
2813         struct fcoe_ctlr *ctlr = fcoe_to_ctlr(fcoe);
2814
2815         if (fp && fc_frame_payload_op(fp) == ELS_FLOGI)
2816                 fcoe_ctlr_recv_flogi(ctlr, lport, fp);
2817 }