diff options
| author | Joe Eykholt <jeykholt@cisco.com> | 2009-03-17 14:42:40 -0400 |
|---|---|---|
| committer | James Bottomley <James.Bottomley@HansenPartnership.com> | 2009-04-03 10:23:08 -0400 |
| commit | 97c8389d54b9665c38105ea72a428a44b97ff2f6 (patch) | |
| tree | 1548f9a3739241101f4e6f972418a16b45b52d57 | |
| parent | af5f428763eefb6547d2bee055b559c903f2a749 (diff) | |
[SCSI] fcoe, libfcoe: Add support for FIP. FCoE discovery and keep-alive.
FIP is the new standard way to discover Fibre-Channel Forwarders (FCFs)
by sending solicitations and listening for advertisements from FCFs.
It also provides for keep-alives and period advertisements so that both
parties know they have connectivity. If the FCF loses connectivity to
the storage fabric, it can send a Link Reset to inform the E_node.
This version is also compatible with pre-FIP implementations, so no
configured selection between FIP mode and non-FIP mode is required.
We wait a couple seconds after sending the initial solicitation
and then send an old-style FLOGI. If we receive any FIP frames,
we use FIP only mode. If the old FLOGI receives a response,
we disable FIP mode. After every reset or link up, this
determination is repeated.
Signed-off-by: Joe Eykholt <jeykholt@cisco.com>
Signed-off-by: Vasu Dev <vasu.dev@intel.com>
Signed-off-by: Robert Love <robert.w.love@intel.com>
Signed-off-by: James Bottomley <James.Bottomley@HansenPartnership.com>
| -rw-r--r-- | drivers/scsi/fcoe/fcoe.c | 232 | ||||
| -rw-r--r-- | drivers/scsi/fcoe/fcoe.h | 19 | ||||
| -rw-r--r-- | drivers/scsi/fcoe/libfcoe.c | 1251 | ||||
| -rw-r--r-- | include/scsi/libfcoe.h | 134 |
4 files changed, 1499 insertions, 137 deletions
diff --git a/drivers/scsi/fcoe/fcoe.c b/drivers/scsi/fcoe/fcoe.c index d5f009ad0388..94e1e3189773 100644 --- a/drivers/scsi/fcoe/fcoe.c +++ b/drivers/scsi/fcoe/fcoe.c | |||
| @@ -37,6 +37,7 @@ | |||
| 37 | #include <net/rtnetlink.h> | 37 | #include <net/rtnetlink.h> |
| 38 | 38 | ||
| 39 | #include <scsi/fc/fc_encaps.h> | 39 | #include <scsi/fc/fc_encaps.h> |
| 40 | #include <scsi/fc/fc_fip.h> | ||
| 40 | 41 | ||
| 41 | #include <scsi/libfc.h> | 42 | #include <scsi/libfc.h> |
| 42 | #include <scsi/fc_frame.h> | 43 | #include <scsi/fc_frame.h> |
| @@ -71,7 +72,6 @@ static int fcoe_hostlist_add(const struct fc_lport *); | |||
| 71 | static int fcoe_hostlist_remove(const struct fc_lport *); | 72 | static int fcoe_hostlist_remove(const struct fc_lport *); |
| 72 | 73 | ||
| 73 | static int fcoe_check_wait_queue(struct fc_lport *); | 74 | static int fcoe_check_wait_queue(struct fc_lport *); |
| 74 | static void fcoe_recv_flogi(struct fcoe_softc *, struct fc_frame *, u8 *); | ||
| 75 | static int fcoe_device_notification(struct notifier_block *, ulong, void *); | 75 | static int fcoe_device_notification(struct notifier_block *, ulong, void *); |
| 76 | static void fcoe_dev_setup(void); | 76 | static void fcoe_dev_setup(void); |
| 77 | static void fcoe_dev_cleanup(void); | 77 | static void fcoe_dev_cleanup(void); |
| @@ -185,7 +185,7 @@ static int fcoe_netdev_config(struct fc_lport *lp, struct net_device *netdev) | |||
| 185 | 185 | ||
| 186 | /* Setup lport private data to point to fcoe softc */ | 186 | /* Setup lport private data to point to fcoe softc */ |
| 187 | fc = lport_priv(lp); | 187 | fc = lport_priv(lp); |
| 188 | fc->lp = lp; | 188 | fc->ctlr.lp = lp; |
| 189 | fc->real_dev = netdev; | 189 | fc->real_dev = netdev; |
| 190 | fc->phys_dev = netdev; | 190 | fc->phys_dev = netdev; |
| 191 | 191 | ||
| @@ -210,9 +210,6 @@ static int fcoe_netdev_config(struct fc_lport *lp, struct net_device *netdev) | |||
| 210 | if (fc_set_mfs(lp, mfs)) | 210 | if (fc_set_mfs(lp, mfs)) |
| 211 | return -EINVAL; | 211 | return -EINVAL; |
| 212 | 212 | ||
| 213 | if (!fcoe_link_ok(lp)) | ||
| 214 | lp->link_up = 1; | ||
| 215 | |||
| 216 | /* offload features support */ | 213 | /* offload features support */ |
| 217 | if (fc->real_dev->features & NETIF_F_SG) | 214 | if (fc->real_dev->features & NETIF_F_SG) |
| 218 | lp->sg_supp = 1; | 215 | lp->sg_supp = 1; |
| @@ -242,7 +239,7 @@ static int fcoe_netdev_config(struct fc_lport *lp, struct net_device *netdev) | |||
| 242 | fc->fcoe_pending_queue_active = 0; | 239 | fc->fcoe_pending_queue_active = 0; |
| 243 | 240 | ||
| 244 | /* setup Source Mac Address */ | 241 | /* setup Source Mac Address */ |
| 245 | memcpy(fc->ctl_src_addr, fc->real_dev->dev_addr, | 242 | memcpy(fc->ctlr.ctl_src_addr, fc->real_dev->dev_addr, |
| 246 | fc->real_dev->addr_len); | 243 | fc->real_dev->addr_len); |
| 247 | 244 | ||
| 248 | wwnn = fcoe_wwn_from_mac(fc->real_dev->dev_addr, 1, 0); | 245 | wwnn = fcoe_wwn_from_mac(fc->real_dev->dev_addr, 1, 0); |
| @@ -358,6 +355,8 @@ static int fcoe_if_destroy(struct net_device *netdev) | |||
| 358 | 355 | ||
| 359 | /* Don't listen for Ethernet packets anymore */ | 356 | /* Don't listen for Ethernet packets anymore */ |
| 360 | dev_remove_pack(&fc->fcoe_packet_type); | 357 | dev_remove_pack(&fc->fcoe_packet_type); |
| 358 | dev_remove_pack(&fc->fip_packet_type); | ||
| 359 | fcoe_ctlr_destroy(&fc->ctlr); | ||
| 361 | 360 | ||
| 362 | /* Cleanup the fc_lport */ | 361 | /* Cleanup the fc_lport */ |
| 363 | fc_lport_destroy(lp); | 362 | fc_lport_destroy(lp); |
| @@ -375,8 +374,10 @@ static int fcoe_if_destroy(struct net_device *netdev) | |||
| 375 | rtnl_lock(); | 374 | rtnl_lock(); |
| 376 | memcpy(flogi_maddr, (u8[6]) FC_FCOE_FLOGI_MAC, ETH_ALEN); | 375 | memcpy(flogi_maddr, (u8[6]) FC_FCOE_FLOGI_MAC, ETH_ALEN); |
| 377 | dev_unicast_delete(fc->real_dev, flogi_maddr, ETH_ALEN); | 376 | dev_unicast_delete(fc->real_dev, flogi_maddr, ETH_ALEN); |
| 378 | if (compare_ether_addr(fc->data_src_addr, (u8[6]) { 0 })) | 377 | if (!is_zero_ether_addr(fc->ctlr.data_src_addr)) |
| 379 | dev_unicast_delete(fc->real_dev, fc->data_src_addr, ETH_ALEN); | 378 | dev_unicast_delete(fc->real_dev, |
| 379 | fc->ctlr.data_src_addr, ETH_ALEN); | ||
| 380 | dev_mc_delete(fc->real_dev, FIP_ALL_ENODE_MACS, ETH_ALEN, 0); | ||
| 380 | rtnl_unlock(); | 381 | rtnl_unlock(); |
| 381 | 382 | ||
| 382 | /* Free the per-CPU revieve threads */ | 383 | /* Free the per-CPU revieve threads */ |
| @@ -438,6 +439,58 @@ static struct libfc_function_template fcoe_libfc_fcn_templ = { | |||
| 438 | }; | 439 | }; |
| 439 | 440 | ||
| 440 | /** | 441 | /** |
| 442 | * fcoe_fip_recv - handle a received FIP frame. | ||
| 443 | * @skb: the receive skb | ||
| 444 | * @dev: associated &net_device | ||
| 445 | * @ptype: the &packet_type structure which was used to register this handler. | ||
| 446 | * @orig_dev: original receive &net_device, in case @dev is a bond. | ||
| 447 | * | ||
| 448 | * Returns: 0 for success | ||
| 449 | */ | ||
| 450 | static int fcoe_fip_recv(struct sk_buff *skb, struct net_device *dev, | ||
| 451 | struct packet_type *ptype, | ||
| 452 | struct net_device *orig_dev) | ||
| 453 | { | ||
| 454 | struct fcoe_softc *fc; | ||
| 455 | |||
| 456 | fc = container_of(ptype, struct fcoe_softc, fip_packet_type); | ||
| 457 | fcoe_ctlr_recv(&fc->ctlr, skb); | ||
| 458 | return 0; | ||
| 459 | } | ||
| 460 | |||
| 461 | /** | ||
| 462 | * fcoe_fip_send() - send an Ethernet-encapsulated FIP frame. | ||
| 463 | * @fip: FCoE controller. | ||
| 464 | * @skb: FIP Packet. | ||
| 465 | */ | ||
| 466 | static void fcoe_fip_send(struct fcoe_ctlr *fip, struct sk_buff *skb) | ||
| 467 | { | ||
| 468 | skb->dev = fcoe_from_ctlr(fip)->real_dev; | ||
| 469 | dev_queue_xmit(skb); | ||
| 470 | } | ||
| 471 | |||
| 472 | /** | ||
| 473 | * fcoe_update_src_mac() - Update Ethernet MAC filters. | ||
| 474 | * @fip: FCoE controller. | ||
| 475 | * @old: Unicast MAC address to delete if the MAC is non-zero. | ||
| 476 | * @new: Unicast MAC address to add. | ||
| 477 | * | ||
| 478 | * Remove any previously-set unicast MAC filter. | ||
| 479 | * Add secondary FCoE MAC address filter for our OUI. | ||
| 480 | */ | ||
| 481 | static void fcoe_update_src_mac(struct fcoe_ctlr *fip, u8 *old, u8 *new) | ||
| 482 | { | ||
| 483 | struct fcoe_softc *fc; | ||
| 484 | |||
| 485 | fc = fcoe_from_ctlr(fip); | ||
| 486 | rtnl_lock(); | ||
| 487 | if (!is_zero_ether_addr(old)) | ||
| 488 | dev_unicast_delete(fc->real_dev, old, ETH_ALEN); | ||
| 489 | dev_unicast_add(fc->real_dev, new, ETH_ALEN); | ||
| 490 | rtnl_unlock(); | ||
| 491 | } | ||
| 492 | |||
| 493 | /** | ||
| 441 | * fcoe_if_create() - this function creates the fcoe interface | 494 | * fcoe_if_create() - this function creates the fcoe interface |
| 442 | * @netdev: pointer the associated netdevice | 495 | * @netdev: pointer the associated netdevice |
| 443 | * | 496 | * |
| @@ -485,6 +538,18 @@ static int fcoe_if_create(struct net_device *netdev) | |||
| 485 | goto out_host_put; | 538 | goto out_host_put; |
| 486 | } | 539 | } |
| 487 | 540 | ||
| 541 | /* | ||
| 542 | * Initialize FIP. | ||
| 543 | */ | ||
| 544 | fcoe_ctlr_init(&fc->ctlr); | ||
| 545 | fc->ctlr.send = fcoe_fip_send; | ||
| 546 | fc->ctlr.update_mac = fcoe_update_src_mac; | ||
| 547 | |||
| 548 | fc->fip_packet_type.func = fcoe_fip_recv; | ||
| 549 | fc->fip_packet_type.type = htons(ETH_P_FIP); | ||
| 550 | fc->fip_packet_type.dev = fc->real_dev; | ||
| 551 | dev_add_pack(&fc->fip_packet_type); | ||
| 552 | |||
| 488 | /* configure lport scsi host properties */ | 553 | /* configure lport scsi host properties */ |
| 489 | rc = fcoe_shost_config(lp, shost, &netdev->dev); | 554 | rc = fcoe_shost_config(lp, shost, &netdev->dev); |
| 490 | if (rc) { | 555 | if (rc) { |
| @@ -513,6 +578,9 @@ static int fcoe_if_create(struct net_device *netdev) | |||
| 513 | 578 | ||
| 514 | fc_fabric_login(lp); | 579 | fc_fabric_login(lp); |
| 515 | 580 | ||
| 581 | if (!fcoe_link_ok(lp)) | ||
| 582 | fcoe_ctlr_link_up(&fc->ctlr); | ||
| 583 | |||
| 516 | dev_hold(netdev); | 584 | dev_hold(netdev); |
| 517 | 585 | ||
| 518 | return rc; | 586 | return rc; |
| @@ -727,11 +795,13 @@ int fcoe_rcv(struct sk_buff *skb, struct net_device *dev, | |||
| 727 | unsigned int cpu = 0; | 795 | unsigned int cpu = 0; |
| 728 | 796 | ||
| 729 | fc = container_of(ptype, struct fcoe_softc, fcoe_packet_type); | 797 | fc = container_of(ptype, struct fcoe_softc, fcoe_packet_type); |
| 730 | lp = fc->lp; | 798 | lp = fc->ctlr.lp; |
| 731 | if (unlikely(lp == NULL)) { | 799 | if (unlikely(lp == NULL)) { |
| 732 | FC_DBG("cannot find hba structure"); | 800 | FC_DBG("cannot find hba structure"); |
| 733 | goto err2; | 801 | goto err2; |
| 734 | } | 802 | } |
| 803 | if (!lp->link_up) | ||
| 804 | goto err2; | ||
| 735 | 805 | ||
| 736 | if (unlikely(debug_fcoe)) { | 806 | if (unlikely(debug_fcoe)) { |
| 737 | FC_DBG("skb_info: len:%d data_len:%d head:%p data:%p tail:%p " | 807 | FC_DBG("skb_info: len:%d data_len:%d head:%p data:%p tail:%p " |
| @@ -929,7 +999,6 @@ int fcoe_xmit(struct fc_lport *lp, struct fc_frame *fp) | |||
| 929 | unsigned int hlen; /* header length implies the version */ | 999 | unsigned int hlen; /* header length implies the version */ |
| 930 | unsigned int tlen; /* trailer length */ | 1000 | unsigned int tlen; /* trailer length */ |
| 931 | unsigned int elen; /* eth header, may include vlan */ | 1001 | unsigned int elen; /* eth header, may include vlan */ |
| 932 | int flogi_in_progress = 0; | ||
| 933 | struct fcoe_softc *fc; | 1002 | struct fcoe_softc *fc; |
| 934 | u8 sof, eof; | 1003 | u8 sof, eof; |
| 935 | struct fcoe_hdr *hp; | 1004 | struct fcoe_hdr *hp; |
| @@ -937,31 +1006,19 @@ int fcoe_xmit(struct fc_lport *lp, struct fc_frame *fp) | |||
| 937 | WARN_ON((fr_len(fp) % sizeof(u32)) != 0); | 1006 | WARN_ON((fr_len(fp) % sizeof(u32)) != 0); |
| 938 | 1007 | ||
| 939 | fc = lport_priv(lp); | 1008 | fc = lport_priv(lp); |
| 940 | /* | ||
| 941 | * if it is a flogi then we need to learn gw-addr | ||
| 942 | * and my own fcid | ||
| 943 | */ | ||
| 944 | fh = fc_frame_header_get(fp); | 1009 | fh = fc_frame_header_get(fp); |
| 945 | if (unlikely(fh->fh_r_ctl == FC_RCTL_ELS_REQ)) { | 1010 | skb = fp_skb(fp); |
| 946 | if (fc_frame_payload_op(fp) == ELS_FLOGI) { | 1011 | wlen = skb->len / FCOE_WORD_TO_BYTE; |
| 947 | fc->flogi_oxid = ntohs(fh->fh_ox_id); | 1012 | |
| 948 | fc->address_mode = FCOE_FCOUI_ADDR_MODE; | 1013 | if (!lp->link_up) { |
| 949 | fc->flogi_progress = 1; | 1014 | kfree(skb); |
| 950 | flogi_in_progress = 1; | 1015 | return 0; |
| 951 | } else if (fc->flogi_progress && ntoh24(fh->fh_s_id) != 0) { | ||
| 952 | /* | ||
| 953 | * Here we must've gotten an SID by accepting an FLOGI | ||
| 954 | * from a point-to-point connection. Switch to using | ||
| 955 | * the source mac based on the SID. The destination | ||
| 956 | * MAC in this case would have been set by receving the | ||
| 957 | * FLOGI. | ||
| 958 | */ | ||
| 959 | fc_fcoe_set_mac(fc->data_src_addr, fh->fh_s_id); | ||
| 960 | fc->flogi_progress = 0; | ||
| 961 | } | ||
| 962 | } | 1016 | } |
| 963 | 1017 | ||
| 964 | skb = fp_skb(fp); | 1018 | if (unlikely(fh->fh_r_ctl == FC_RCTL_ELS_REQ) && |
| 1019 | fcoe_ctlr_els_send(&fc->ctlr, skb)) | ||
| 1020 | return 0; | ||
| 1021 | |||
| 965 | sof = fr_sof(fp); | 1022 | sof = fr_sof(fp); |
| 966 | eof = fr_eof(fp); | 1023 | eof = fr_eof(fp); |
| 967 | 1024 | ||
| @@ -1016,16 +1073,16 @@ int fcoe_xmit(struct fc_lport *lp, struct fc_frame *fp) | |||
| 1016 | /* fill up mac and fcoe headers */ | 1073 | /* fill up mac and fcoe headers */ |
| 1017 | eh = eth_hdr(skb); | 1074 | eh = eth_hdr(skb); |
| 1018 | eh->h_proto = htons(ETH_P_FCOE); | 1075 | eh->h_proto = htons(ETH_P_FCOE); |
| 1019 | if (fc->address_mode == FCOE_FCOUI_ADDR_MODE) | 1076 | if (fc->ctlr.map_dest) |
| 1020 | fc_fcoe_set_mac(eh->h_dest, fh->fh_d_id); | 1077 | fc_fcoe_set_mac(eh->h_dest, fh->fh_d_id); |
| 1021 | else | 1078 | else |
| 1022 | /* insert GW address */ | 1079 | /* insert GW address */ |
| 1023 | memcpy(eh->h_dest, fc->dest_addr, ETH_ALEN); | 1080 | memcpy(eh->h_dest, fc->ctlr.dest_addr, ETH_ALEN); |
| 1024 | 1081 | ||
| 1025 | if (unlikely(flogi_in_progress)) | 1082 | if (unlikely(fc->ctlr.flogi_oxid != FC_XID_UNKNOWN)) |
| 1026 | memcpy(eh->h_source, fc->ctl_src_addr, ETH_ALEN); | 1083 | memcpy(eh->h_source, fc->ctlr.ctl_src_addr, ETH_ALEN); |
| 1027 | else | 1084 | else |
| 1028 | memcpy(eh->h_source, fc->data_src_addr, ETH_ALEN); | 1085 | memcpy(eh->h_source, fc->ctlr.data_src_addr, ETH_ALEN); |
| 1029 | 1086 | ||
| 1030 | hp = (struct fcoe_hdr *)(eh + 1); | 1087 | hp = (struct fcoe_hdr *)(eh + 1); |
| 1031 | memset(hp, 0, sizeof(*hp)); | 1088 | memset(hp, 0, sizeof(*hp)); |
| @@ -1125,11 +1182,9 @@ int fcoe_percpu_receive_thread(void *arg) | |||
| 1125 | * Save source MAC address before discarding header. | 1182 | * Save source MAC address before discarding header. |
| 1126 | */ | 1183 | */ |
| 1127 | fc = lport_priv(lp); | 1184 | fc = lport_priv(lp); |
| 1128 | if (unlikely(fc->flogi_progress)) | ||
| 1129 | mac = eth_hdr(skb)->h_source; | ||
| 1130 | |||
| 1131 | if (skb_is_nonlinear(skb)) | 1185 | if (skb_is_nonlinear(skb)) |
| 1132 | skb_linearize(skb); /* not ideal */ | 1186 | skb_linearize(skb); /* not ideal */ |
| 1187 | mac = eth_hdr(skb)->h_source; | ||
| 1133 | 1188 | ||
| 1134 | /* | 1189 | /* |
| 1135 | * Frame length checks and setting up the header pointers | 1190 | * Frame length checks and setting up the header pointers |
| @@ -1204,72 +1259,17 @@ int fcoe_percpu_receive_thread(void *arg) | |||
| 1204 | } | 1259 | } |
| 1205 | fr_flags(fp) &= ~FCPHF_CRC_UNCHECKED; | 1260 | fr_flags(fp) &= ~FCPHF_CRC_UNCHECKED; |
| 1206 | } | 1261 | } |
| 1207 | /* non flogi and non data exchanges are handled here */ | 1262 | if (unlikely(fc->ctlr.flogi_oxid != FC_XID_UNKNOWN) && |
| 1208 | if (unlikely(fc->flogi_progress)) | 1263 | fcoe_ctlr_recv_flogi(&fc->ctlr, fp, mac)) { |
| 1209 | fcoe_recv_flogi(fc, fp, mac); | 1264 | fc_frame_free(fp); |
| 1265 | continue; | ||
| 1266 | } | ||
| 1210 | fc_exch_recv(lp, lp->emp, fp); | 1267 | fc_exch_recv(lp, lp->emp, fp); |
| 1211 | } | 1268 | } |
| 1212 | return 0; | 1269 | return 0; |
| 1213 | } | 1270 | } |
| 1214 | 1271 | ||
| 1215 | /** | 1272 | /** |
| 1216 | * fcoe_recv_flogi() - flogi receive function | ||
| 1217 | * @fc: associated fcoe_softc | ||
| 1218 | * @fp: the recieved frame | ||
| 1219 | * @sa: the source address of this flogi | ||
| 1220 | * | ||
| 1221 | * This is responsible to parse the flogi response and sets the corresponding | ||
| 1222 | * mac address for the initiator, eitehr OUI based or GW based. | ||
| 1223 | * | ||
| 1224 | * Returns: none | ||
| 1225 | */ | ||
| 1226 | static void fcoe_recv_flogi(struct fcoe_softc *fc, struct fc_frame *fp, u8 *sa) | ||
| 1227 | { | ||
| 1228 | struct fc_frame_header *fh; | ||
| 1229 | u8 op; | ||
| 1230 | |||
| 1231 | fh = fc_frame_header_get(fp); | ||
| 1232 | if (fh->fh_type != FC_TYPE_ELS) | ||
| 1233 | return; | ||
| 1234 | op = fc_frame_payload_op(fp); | ||
| 1235 | if (op == ELS_LS_ACC && fh->fh_r_ctl == FC_RCTL_ELS_REP && | ||
| 1236 | fc->flogi_oxid == ntohs(fh->fh_ox_id)) { | ||
| 1237 | /* | ||
| 1238 | * FLOGI accepted. | ||
| 1239 | * If the src mac addr is FC_OUI-based, then we mark the | ||
| 1240 | * address_mode flag to use FC_OUI-based Ethernet DA. | ||
| 1241 | * Otherwise we use the FCoE gateway addr | ||
| 1242 | */ | ||
| 1243 | if (!compare_ether_addr(sa, (u8[6]) FC_FCOE_FLOGI_MAC)) { | ||
| 1244 | fc->address_mode = FCOE_FCOUI_ADDR_MODE; | ||
| 1245 | } else { | ||
| 1246 | memcpy(fc->dest_addr, sa, ETH_ALEN); | ||
| 1247 | fc->address_mode = FCOE_GW_ADDR_MODE; | ||
| 1248 | } | ||
| 1249 | |||
| 1250 | /* | ||
| 1251 | * Remove any previously-set unicast MAC filter. | ||
| 1252 | * Add secondary FCoE MAC address filter for our OUI. | ||
| 1253 | */ | ||
| 1254 | rtnl_lock(); | ||
| 1255 | if (compare_ether_addr(fc->data_src_addr, (u8[6]) { 0 })) | ||
| 1256 | dev_unicast_delete(fc->real_dev, fc->data_src_addr, | ||
| 1257 | ETH_ALEN); | ||
| 1258 | fc_fcoe_set_mac(fc->data_src_addr, fh->fh_d_id); | ||
| 1259 | dev_unicast_add(fc->real_dev, fc->data_src_addr, ETH_ALEN); | ||
| 1260 | rtnl_unlock(); | ||
| 1261 | |||
| 1262 | fc->flogi_progress = 0; | ||
| 1263 | } else if (op == ELS_FLOGI && fh->fh_r_ctl == FC_RCTL_ELS_REQ && sa) { | ||
| 1264 | /* | ||
| 1265 | * Save source MAC for point-to-point responses. | ||
| 1266 | */ | ||
| 1267 | memcpy(fc->dest_addr, sa, ETH_ALEN); | ||
| 1268 | fc->address_mode = FCOE_GW_ADDR_MODE; | ||
| 1269 | } | ||
| 1270 | } | ||
| 1271 | |||
| 1272 | /** | ||
| 1273 | * fcoe_watchdog() - fcoe timer callback | 1273 | * fcoe_watchdog() - fcoe timer callback |
| 1274 | * @vp: | 1274 | * @vp: |
| 1275 | * | 1275 | * |
| @@ -1285,8 +1285,8 @@ void fcoe_watchdog(ulong vp) | |||
| 1285 | 1285 | ||
| 1286 | read_lock(&fcoe_hostlist_lock); | 1286 | read_lock(&fcoe_hostlist_lock); |
| 1287 | list_for_each_entry(fc, &fcoe_hostlist, list) { | 1287 | list_for_each_entry(fc, &fcoe_hostlist, list) { |
| 1288 | if (fc->lp) | 1288 | if (fc->ctlr.lp) |
| 1289 | fcoe_check_wait_queue(fc->lp); | 1289 | fcoe_check_wait_queue(fc->ctlr.lp); |
| 1290 | } | 1290 | } |
| 1291 | read_unlock(&fcoe_hostlist_lock); | 1291 | read_unlock(&fcoe_hostlist_lock); |
| 1292 | 1292 | ||
| @@ -1387,14 +1387,14 @@ static int fcoe_device_notification(struct notifier_block *notifier, | |||
| 1387 | struct net_device *real_dev = ptr; | 1387 | struct net_device *real_dev = ptr; |
| 1388 | struct fcoe_softc *fc; | 1388 | struct fcoe_softc *fc; |
| 1389 | struct fcoe_dev_stats *stats; | 1389 | struct fcoe_dev_stats *stats; |
| 1390 | u32 new_link_up; | 1390 | u32 link_possible = 1; |
| 1391 | u32 mfs; | 1391 | u32 mfs; |
| 1392 | int rc = NOTIFY_OK; | 1392 | int rc = NOTIFY_OK; |
| 1393 | 1393 | ||
| 1394 | read_lock(&fcoe_hostlist_lock); | 1394 | read_lock(&fcoe_hostlist_lock); |
| 1395 | list_for_each_entry(fc, &fcoe_hostlist, list) { | 1395 | list_for_each_entry(fc, &fcoe_hostlist, list) { |
| 1396 | if (fc->real_dev == real_dev) { | 1396 | if (fc->real_dev == real_dev) { |
| 1397 | lp = fc->lp; | 1397 | lp = fc->ctlr.lp; |
| 1398 | break; | 1398 | break; |
| 1399 | } | 1399 | } |
| 1400 | } | 1400 | } |
| @@ -1404,15 +1404,13 @@ static int fcoe_device_notification(struct notifier_block *notifier, | |||
| 1404 | goto out; | 1404 | goto out; |
| 1405 | } | 1405 | } |
| 1406 | 1406 | ||
| 1407 | new_link_up = lp->link_up; | ||
| 1408 | switch (event) { | 1407 | switch (event) { |
| 1409 | case NETDEV_DOWN: | 1408 | case NETDEV_DOWN: |
| 1410 | case NETDEV_GOING_DOWN: | 1409 | case NETDEV_GOING_DOWN: |
| 1411 | new_link_up = 0; | 1410 | link_possible = 0; |
| 1412 | break; | 1411 | break; |
| 1413 | case NETDEV_UP: | 1412 | case NETDEV_UP: |
| 1414 | case NETDEV_CHANGE: | 1413 | case NETDEV_CHANGE: |
| 1415 | new_link_up = !fcoe_link_ok(lp); | ||
| 1416 | break; | 1414 | break; |
| 1417 | case NETDEV_CHANGEMTU: | 1415 | case NETDEV_CHANGEMTU: |
| 1418 | mfs = fc->real_dev->mtu - | 1416 | mfs = fc->real_dev->mtu - |
| @@ -1420,22 +1418,18 @@ static int fcoe_device_notification(struct notifier_block *notifier, | |||
| 1420 | sizeof(struct fcoe_crc_eof)); | 1418 | sizeof(struct fcoe_crc_eof)); |
| 1421 | if (mfs >= FC_MIN_MAX_FRAME) | 1419 | if (mfs >= FC_MIN_MAX_FRAME) |
| 1422 | fc_set_mfs(lp, mfs); | 1420 | fc_set_mfs(lp, mfs); |
| 1423 | new_link_up = !fcoe_link_ok(lp); | ||
| 1424 | break; | 1421 | break; |
| 1425 | case NETDEV_REGISTER: | 1422 | case NETDEV_REGISTER: |
| 1426 | break; | 1423 | break; |
| 1427 | default: | 1424 | default: |
| 1428 | FC_DBG("unknown event %ld call", event); | 1425 | FC_DBG("Unknown event %ld from netdev netlink\n", event); |
| 1429 | } | 1426 | } |
| 1430 | if (lp->link_up != new_link_up) { | 1427 | if (link_possible && !fcoe_link_ok(lp)) |
| 1431 | if (new_link_up) | 1428 | fcoe_ctlr_link_up(&fc->ctlr); |
| 1432 | fc_linkup(lp); | 1429 | else if (fcoe_ctlr_link_down(&fc->ctlr)) { |
| 1433 | else { | 1430 | stats = fc_lport_get_stats(lp); |
| 1434 | stats = fc_lport_get_stats(lp); | 1431 | stats->LinkFailureCount++; |
| 1435 | stats->LinkFailureCount++; | 1432 | fcoe_clean_pending_queue(lp); |
| 1436 | fc_linkdown(lp); | ||
| 1437 | fcoe_clean_pending_queue(lp); | ||
| 1438 | } | ||
| 1439 | } | 1433 | } |
| 1440 | out: | 1434 | out: |
| 1441 | return rc; | 1435 | return rc; |
| @@ -1761,7 +1755,7 @@ struct fc_lport *fcoe_hostlist_lookup(const struct net_device *netdev) | |||
| 1761 | 1755 | ||
| 1762 | fc = fcoe_hostlist_lookup_softc(netdev); | 1756 | fc = fcoe_hostlist_lookup_softc(netdev); |
| 1763 | 1757 | ||
| 1764 | return (fc) ? fc->lp : NULL; | 1758 | return (fc) ? fc->ctlr.lp : NULL; |
| 1765 | } | 1759 | } |
| 1766 | EXPORT_SYMBOL_GPL(fcoe_hostlist_lookup); | 1760 | EXPORT_SYMBOL_GPL(fcoe_hostlist_lookup); |
| 1767 | 1761 | ||
diff --git a/drivers/scsi/fcoe/fcoe.h b/drivers/scsi/fcoe/fcoe.h index 4a9611f5a589..917aae886897 100644 --- a/drivers/scsi/fcoe/fcoe.h +++ b/drivers/scsi/fcoe/fcoe.h | |||
| @@ -26,10 +26,6 @@ | |||
| 26 | #define FCOE_MAX_QUEUE_DEPTH 256 | 26 | #define FCOE_MAX_QUEUE_DEPTH 256 |
| 27 | #define FCOE_LOW_QUEUE_DEPTH 32 | 27 | #define FCOE_LOW_QUEUE_DEPTH 32 |
| 28 | 28 | ||
| 29 | /* destination address mode */ | ||
| 30 | #define FCOE_GW_ADDR_MODE 0x00 | ||
| 31 | #define FCOE_FCOUI_ADDR_MODE 0x01 | ||
| 32 | |||
| 33 | #define FCOE_WORD_TO_BYTE 4 | 29 | #define FCOE_WORD_TO_BYTE 4 |
| 34 | 30 | ||
| 35 | #define FCOE_VERSION "0.1" | 31 | #define FCOE_VERSION "0.1" |
| @@ -59,24 +55,17 @@ struct fcoe_percpu_s { | |||
| 59 | */ | 55 | */ |
| 60 | struct fcoe_softc { | 56 | struct fcoe_softc { |
| 61 | struct list_head list; | 57 | struct list_head list; |
| 62 | struct fc_lport *lp; | ||
| 63 | struct net_device *real_dev; | 58 | struct net_device *real_dev; |
| 64 | struct net_device *phys_dev; /* device with ethtool_ops */ | 59 | struct net_device *phys_dev; /* device with ethtool_ops */ |
| 65 | struct packet_type fcoe_packet_type; | 60 | struct packet_type fcoe_packet_type; |
| 61 | struct packet_type fip_packet_type; | ||
| 66 | struct sk_buff_head fcoe_pending_queue; | 62 | struct sk_buff_head fcoe_pending_queue; |
| 67 | u8 fcoe_pending_queue_active; | 63 | u8 fcoe_pending_queue_active; |
| 68 | 64 | struct fcoe_ctlr ctlr; | |
| 69 | u8 dest_addr[ETH_ALEN]; | ||
| 70 | u8 ctl_src_addr[ETH_ALEN]; | ||
| 71 | u8 data_src_addr[ETH_ALEN]; | ||
| 72 | /* | ||
| 73 | * fcoe protocol address learning related stuff | ||
| 74 | */ | ||
| 75 | u16 flogi_oxid; | ||
| 76 | u8 flogi_progress; | ||
| 77 | u8 address_mode; | ||
| 78 | }; | 65 | }; |
| 79 | 66 | ||
| 67 | #define fcoe_from_ctlr(fc) container_of(fc, struct fcoe_softc, ctlr) | ||
| 68 | |||
| 80 | static inline struct net_device *fcoe_netdev( | 69 | static inline struct net_device *fcoe_netdev( |
| 81 | const struct fc_lport *lp) | 70 | const struct fc_lport *lp) |
| 82 | { | 71 | { |
diff --git a/drivers/scsi/fcoe/libfcoe.c b/drivers/scsi/fcoe/libfcoe.c index dff97fcf8837..f410f4abb548 100644 --- a/drivers/scsi/fcoe/libfcoe.c +++ b/drivers/scsi/fcoe/libfcoe.c | |||
| @@ -1,5 +1,6 @@ | |||
| 1 | /* | 1 | /* |
| 2 | * Copyright(c) 2009 Intel Corporation. All rights reserved. | 2 | * Copyright (c) 2008-2009 Cisco Systems, Inc. All rights reserved. |
| 3 | * Copyright (c) 2009 Intel Corporation. All rights reserved. | ||
| 3 | * | 4 | * |
| 4 | * This program is free software; you can redistribute it and/or modify it | 5 | * 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 | * under the terms and conditions of the GNU General Public License, |
| @@ -17,15 +18,1261 @@ | |||
| 17 | * Maintained at www.Open-FCoE.org | 18 | * Maintained at www.Open-FCoE.org |
| 18 | */ | 19 | */ |
| 19 | 20 | ||
| 21 | #include <linux/types.h> | ||
| 20 | #include <linux/module.h> | 22 | #include <linux/module.h> |
| 23 | #include <linux/kernel.h> | ||
| 24 | #include <linux/list.h> | ||
| 25 | #include <linux/spinlock.h> | ||
| 26 | #include <linux/timer.h> | ||
| 21 | #include <linux/netdevice.h> | 27 | #include <linux/netdevice.h> |
| 28 | #include <linux/etherdevice.h> | ||
| 29 | #include <linux/ethtool.h> | ||
| 30 | #include <linux/if_ether.h> | ||
| 31 | #include <linux/if_vlan.h> | ||
| 32 | #include <linux/netdevice.h> | ||
| 33 | #include <linux/errno.h> | ||
| 34 | #include <linux/bitops.h> | ||
| 35 | #include <net/rtnetlink.h> | ||
| 36 | |||
| 37 | #include <scsi/fc/fc_els.h> | ||
| 38 | #include <scsi/fc/fc_fs.h> | ||
| 39 | #include <scsi/fc/fc_fip.h> | ||
| 40 | #include <scsi/fc/fc_encaps.h> | ||
| 41 | #include <scsi/fc/fc_fcoe.h> | ||
| 22 | 42 | ||
| 23 | #include <scsi/libfc.h> | 43 | #include <scsi/libfc.h> |
| 44 | #include <scsi/libfcoe.h> | ||
| 24 | 45 | ||
| 25 | MODULE_AUTHOR("Open-FCoE.org"); | 46 | MODULE_AUTHOR("Open-FCoE.org"); |
| 26 | MODULE_DESCRIPTION("FCoE"); | 47 | MODULE_DESCRIPTION("FIP discovery protocol support for FCoE HBAs"); |
| 27 | MODULE_LICENSE("GPL v2"); | 48 | MODULE_LICENSE("GPL v2"); |
| 28 | 49 | ||
| 50 | #define FCOE_CTLR_MIN_FKA 500 /* min keep alive (mS) */ | ||
| 51 | #define FCOE_CTLR_DEF_FKA FIP_DEF_FKA /* default keep alive (mS) */ | ||
| 52 | |||
| 53 | static void fcoe_ctlr_timeout(unsigned long); | ||
| 54 | static void fcoe_ctlr_link_work(struct work_struct *); | ||
| 55 | static void fcoe_ctlr_recv_work(struct work_struct *); | ||
| 56 | |||
| 57 | static u8 fcoe_all_fcfs[ETH_ALEN] = FIP_ALL_FCF_MACS; | ||
| 58 | |||
| 59 | static u32 fcoe_ctlr_debug; /* 1 for basic, 2 for noisy debug */ | ||
| 60 | |||
| 61 | #define FIP_DBG_LVL(level, fmt, args...) \ | ||
| 62 | do { \ | ||
| 63 | if (fcoe_ctlr_debug >= (level)) \ | ||
| 64 | FC_DBG(fmt, ##args); \ | ||
| 65 | } while (0) | ||
| 66 | |||
| 67 | #define FIP_DBG(fmt, args...) FIP_DBG_LVL(1, fmt, ##args) | ||
| 68 | |||
| 69 | /* | ||
| 70 | * Return non-zero if FCF fcoe_size has been validated. | ||
| 71 | */ | ||
| 72 | static inline int fcoe_ctlr_mtu_valid(const struct fcoe_fcf *fcf) | ||
| 73 | { | ||
| 74 | return (fcf->flags & FIP_FL_SOL) != 0; | ||
| 75 | } | ||
| 76 | |||
| 77 | /* | ||
| 78 | * Return non-zero if the FCF is usable. | ||
| 79 | */ | ||
| 80 | static inline int fcoe_ctlr_fcf_usable(struct fcoe_fcf *fcf) | ||
| 81 | { | ||
| 82 | u16 flags = FIP_FL_SOL | FIP_FL_AVAIL; | ||
| 83 | |||
| 84 | return (fcf->flags & flags) == flags; | ||
| 85 | } | ||
| 86 | |||
| 87 | /** | ||
| 88 | * fcoe_ctlr_init() - Initialize the FCoE Controller instance. | ||
| 89 | * @fip: FCoE controller. | ||
| 90 | */ | ||
| 91 | void fcoe_ctlr_init(struct fcoe_ctlr *fip) | ||
| 92 | { | ||
| 93 | fip->state = FIP_ST_LINK_WAIT; | ||
| 94 | INIT_LIST_HEAD(&fip->fcfs); | ||
| 95 | spin_lock_init(&fip->lock); | ||
| 96 | fip->flogi_oxid = FC_XID_UNKNOWN; | ||
| 97 | setup_timer(&fip->timer, fcoe_ctlr_timeout, (unsigned long)fip); | ||
| 98 | INIT_WORK(&fip->link_work, fcoe_ctlr_link_work); | ||
| 99 | INIT_WORK(&fip->recv_work, fcoe_ctlr_recv_work); | ||
| 100 | skb_queue_head_init(&fip->fip_recv_list); | ||
| 101 | } | ||
| 102 | EXPORT_SYMBOL(fcoe_ctlr_init); | ||
| 103 | |||
| 104 | /** | ||
| 105 | * fcoe_ctlr_reset_fcfs() - Reset and free all FCFs for a controller. | ||
| 106 | * @fip: FCoE controller. | ||
| 107 | * | ||
| 108 | * Called with &fcoe_ctlr lock held. | ||
| 109 | */ | ||
| 110 | static void fcoe_ctlr_reset_fcfs(struct fcoe_ctlr *fip) | ||
| 111 | { | ||
| 112 | struct fcoe_fcf *fcf; | ||
| 113 | struct fcoe_fcf *next; | ||
| 114 | |||
| 115 | fip->sel_fcf = NULL; | ||
| 116 | list_for_each_entry_safe(fcf, next, &fip->fcfs, list) { | ||
| 117 | list_del(&fcf->list); | ||
| 118 | kfree(fcf); | ||
| 119 | } | ||
| 120 | fip->fcf_count = 0; | ||
| 121 | fip->sel_time = 0; | ||
| 122 | } | ||
| 123 | |||
| 124 | /** | ||
| 125 | * fcoe_ctrl_destroy() - Disable and tear-down the FCoE controller. | ||
| 126 | * @fip: FCoE controller. | ||
| 127 | * | ||
| 128 | * This is called by FCoE drivers before freeing the &fcoe_ctlr. | ||
| 129 | * | ||
| 130 | * The receive handler will have been deleted before this to guarantee | ||
| 131 | * that no more recv_work will be scheduled. | ||
| 132 | * | ||
| 133 | * The timer routine will simply return once we set FIP_ST_DISABLED. | ||
| 134 | * This guarantees that no further timeouts or work will be scheduled. | ||
| 135 | */ | ||
| 136 | void fcoe_ctlr_destroy(struct fcoe_ctlr *fip) | ||
| 137 | { | ||
| 138 | flush_work(&fip->recv_work); | ||
| 139 | spin_lock_bh(&fip->lock); | ||
| 140 | fip->state = FIP_ST_DISABLED; | ||
| 141 | fcoe_ctlr_reset_fcfs(fip); | ||
| 142 | spin_unlock_bh(&fip->lock); | ||
| 143 | del_timer_sync(&fip->timer); | ||
| 144 | flush_work(&fip->link_work); | ||
| 145 | } | ||
| 146 | EXPORT_SYMBOL(fcoe_ctlr_destroy); | ||
| 147 | |||
| 148 | /** | ||
| 149 | * fcoe_ctlr_fcoe_size() - Return the maximum FCoE size required for VN_Port. | ||
| 150 | * @fip: FCoE controller. | ||
| 151 | * | ||
| 152 | * Returns the maximum packet size including the FCoE header and trailer, | ||
| 153 | * but not including any Ethernet or VLAN headers. | ||
| 154 | */ | ||
| 155 | static inline u32 fcoe_ctlr_fcoe_size(struct fcoe_ctlr *fip) | ||
| 156 | { | ||
| 157 | /* | ||
| 158 | * Determine the max FCoE frame size allowed, including | ||
| 159 | * FCoE header and trailer. | ||
| 160 | * Note: lp->mfs is currently the payload size, not the frame size. | ||
| 161 | */ | ||
| 162 | return fip->lp->mfs + sizeof(struct fc_frame_header) + | ||
| 163 | sizeof(struct fcoe_hdr) + sizeof(struct fcoe_crc_eof); | ||
| 164 | } | ||
| 165 | |||
| 166 | /** | ||
| 167 | * fcoe_ctlr_solicit() - Send a solicitation. | ||
| 168 | * @fip: FCoE controller. | ||
| 169 | * @fcf: Destination FCF. If NULL, a multicast solicitation is sent. | ||
| 170 | */ | ||
| 171 | static void fcoe_ctlr_solicit(struct fcoe_ctlr *fip, struct fcoe_fcf *fcf) | ||
| 172 | { | ||
| 173 | struct sk_buff *skb; | ||
| 174 | struct fip_sol { | ||
| 175 | struct ethhdr eth; | ||
| 176 | struct fip_header fip; | ||
| 177 | struct { | ||
| 178 | struct fip_mac_desc mac; | ||
| 179 | struct fip_wwn_desc wwnn; | ||
| 180 | struct fip_size_desc size; | ||
| 181 | } __attribute__((packed)) desc; | ||
| 182 | } __attribute__((packed)) *sol; | ||
| 183 | u32 fcoe_size; | ||
| 184 | |||
| 185 | skb = dev_alloc_skb(sizeof(*sol)); | ||
| 186 | if (!skb) | ||
| 187 | return; | ||
| 188 | |||
| 189 | sol = (struct fip_sol *)skb->data; | ||
| 190 | |||
| 191 | memset(sol, 0, sizeof(*sol)); | ||
| 192 | memcpy(sol->eth.h_dest, fcf ? fcf->fcf_mac : fcoe_all_fcfs, ETH_ALEN); | ||
| 193 | memcpy(sol->eth.h_source, fip->ctl_src_addr, ETH_ALEN); | ||
| 194 | sol->eth.h_proto = htons(ETH_P_FIP); | ||
| 195 | |||
| 196 | sol->fip.fip_ver = FIP_VER_ENCAPS(FIP_VER); | ||
| 197 | sol->fip.fip_op = htons(FIP_OP_DISC); | ||
| 198 | sol->fip.fip_subcode = FIP_SC_SOL; | ||
| 199 | sol->fip.fip_dl_len = htons(sizeof(sol->desc) / FIP_BPW); | ||
| 200 | sol->fip.fip_flags = htons(FIP_FL_FPMA); | ||
| 201 | |||
| 202 | sol->desc.mac.fd_desc.fip_dtype = FIP_DT_MAC; | ||
| 203 | sol->desc.mac.fd_desc.fip_dlen = sizeof(sol->desc.mac) / FIP_BPW; | ||
| 204 | memcpy(sol->desc.mac.fd_mac, fip->ctl_src_addr, ETH_ALEN); | ||
| 205 | |||
| 206 | sol->desc.wwnn.fd_desc.fip_dtype = FIP_DT_NAME; | ||
| 207 | sol->desc.wwnn.fd_desc.fip_dlen = sizeof(sol->desc.wwnn) / FIP_BPW; | ||
| 208 | put_unaligned_be64(fip->lp->wwnn, &sol->desc.wwnn.fd_wwn); | ||
| 209 | |||
| 210 | fcoe_size = fcoe_ctlr_fcoe_size(fip); | ||
| 211 | sol->desc.size.fd_desc.fip_dtype = FIP_DT_FCOE_SIZE; | ||
| 212 | sol->desc.size.fd_desc.fip_dlen = sizeof(sol->desc.size) / FIP_BPW; | ||
| 213 | sol->desc.size.fd_size = htons(fcoe_size); | ||
| 214 | |||
| 215 | skb_put(skb, sizeof(*sol)); | ||
| 216 | skb->protocol = htons(ETH_P_802_3); | ||
| 217 | skb_reset_mac_header(skb); | ||
| 218 | skb_reset_network_header(skb); | ||
| 219 | fip->send(fip, skb); | ||
| 220 | |||
| 221 | if (!fcf) | ||
| 222 | fip->sol_time = jiffies; | ||
| 223 | } | ||
| 224 | |||
| 225 | /** | ||
| 226 | * fcoe_ctlr_link_up() - Start FCoE controller. | ||
| 227 | * @fip: FCoE controller. | ||
| 228 | * | ||
| 229 | * Called from the LLD when the network link is ready. | ||
| 230 | */ | ||
| 231 | void fcoe_ctlr_link_up(struct fcoe_ctlr *fip) | ||
| 232 | { | ||
| 233 | spin_lock_bh(&fip->lock); | ||
| 234 | if (fip->state == FIP_ST_NON_FIP || fip->state == FIP_ST_AUTO) { | ||
| 235 | fip->last_link = 1; | ||
| 236 | fip->link = 1; | ||
| 237 | spin_unlock_bh(&fip->lock); | ||
| 238 | fc_linkup(fip->lp); | ||
| 239 | } else if (fip->state == FIP_ST_LINK_WAIT) { | ||
| 240 | fip->state = FIP_ST_AUTO; | ||
| 241 | fip->last_link = 1; | ||
| 242 | fip->link = 1; | ||
| 243 | spin_unlock_bh(&fip->lock); | ||
| 244 | FIP_DBG("%s", "setting AUTO mode.\n"); | ||
| 245 | fc_linkup(fip->lp); | ||
| 246 | fcoe_ctlr_solicit(fip, NULL); | ||
| 247 | } else | ||
| 248 | spin_unlock_bh(&fip->lock); | ||
| 249 | } | ||
| 250 | EXPORT_SYMBOL(fcoe_ctlr_link_up); | ||
| 251 | |||
| 252 | /** | ||
| 253 | * fcoe_ctlr_reset() - Reset FIP. | ||
| 254 | * @fip: FCoE controller. | ||
| 255 | * @new_state: FIP state to be entered. | ||
| 256 | * | ||
| 257 | * Returns non-zero if the link was up and now isn't. | ||
| 258 | */ | ||
| 259 | static int fcoe_ctlr_reset(struct fcoe_ctlr *fip, enum fip_state new_state) | ||
| 260 | { | ||
| 261 | struct fc_lport *lp = fip->lp; | ||
| 262 | int link_dropped; | ||
| 263 | |||
| 264 | spin_lock_bh(&fip->lock); | ||
| 265 | fcoe_ctlr_reset_fcfs(fip); | ||
| 266 | del_timer(&fip->timer); | ||
| 267 | fip->state = new_state; | ||
| 268 | fip->ctlr_ka_time = 0; | ||
| 269 | fip->port_ka_time = 0; | ||
| 270 | fip->sol_time = 0; | ||
| 271 | fip->flogi_oxid = FC_XID_UNKNOWN; | ||
| 272 | fip->map_dest = 0; | ||
| 273 | fip->last_link = 0; | ||
| 274 | link_dropped = fip->link; | ||
| 275 | fip->link = 0; | ||
| 276 | spin_unlock_bh(&fip->lock); | ||
| 277 | |||
| 278 | if (link_dropped) | ||
| 279 | fc_linkdown(lp); | ||
| 280 | |||
| 281 | if (new_state == FIP_ST_ENABLED) { | ||
| 282 | fcoe_ctlr_solicit(fip, NULL); | ||
| 283 | fc_linkup(lp); | ||
| 284 | link_dropped = 0; | ||
| 285 | } | ||
| 286 | return link_dropped; | ||
| 287 | } | ||
| 288 | |||
| 289 | /** | ||
| 290 | * fcoe_ctlr_link_down() - Stop FCoE controller. | ||
| 291 | * @fip: FCoE controller. | ||
| 292 | * | ||
| 293 | * Returns non-zero if the link was up and now isn't. | ||
| 294 | * | ||
| 295 | * Called from the LLD when the network link is not ready. | ||
| 296 | * There may be multiple calls while the link is down. | ||
| 297 | */ | ||
| 298 | int fcoe_ctlr_link_down(struct fcoe_ctlr *fip) | ||
| 299 | { | ||
| 300 | return fcoe_ctlr_reset(fip, FIP_ST_LINK_WAIT); | ||
| 301 | } | ||
| 302 | EXPORT_SYMBOL(fcoe_ctlr_link_down); | ||
| 303 | |||
| 304 | /** | ||
| 305 | * fcoe_ctlr_send_keep_alive() - Send a keep-alive to the selected FCF. | ||
| 306 | * @fip: FCoE controller. | ||
| 307 | * @ports: 0 for controller keep-alive, 1 for port keep-alive. | ||
| 308 | * @sa: source MAC address. | ||
| 309 | * | ||
| 310 | * A controller keep-alive is sent every fka_period (typically 8 seconds). | ||
| 311 | * The source MAC is the native MAC address. | ||
| 312 | * | ||
| 313 | * A port keep-alive is sent every 90 seconds while logged in. | ||
| 314 | * The source MAC is the assigned mapped source address. | ||
| 315 | * The destination is the FCF's F-port. | ||
| 316 | */ | ||
| 317 | static void fcoe_ctlr_send_keep_alive(struct fcoe_ctlr *fip, int ports, u8 *sa) | ||
| 318 | { | ||
| 319 | struct sk_buff *skb; | ||
| 320 | struct fip_kal { | ||
| 321 | struct ethhdr eth; | ||
| 322 | struct fip_header fip; | ||
| 323 | struct fip_mac_desc mac; | ||
| 324 | } __attribute__((packed)) *kal; | ||
| 325 | struct fip_vn_desc *vn; | ||
| 326 | u32 len; | ||
| 327 | struct fc_lport *lp; | ||
| 328 | struct fcoe_fcf *fcf; | ||
| 329 | |||
| 330 | fcf = fip->sel_fcf; | ||
| 331 | lp = fip->lp; | ||
| 332 | if (!fcf || !fc_host_port_id(lp->host)) | ||
| 333 | return; | ||
| 334 | |||
| 335 | len = fcoe_ctlr_fcoe_size(fip) + sizeof(struct ethhdr); | ||
| 336 | BUG_ON(len < sizeof(*kal) + sizeof(*vn)); | ||
| 337 | skb = dev_alloc_skb(len); | ||
| 338 | if (!skb) | ||
| 339 | return; | ||
| 340 | |||
| 341 | kal = (struct fip_kal *)skb->data; | ||
| 342 | memset(kal, 0, len); | ||
| 343 | memcpy(kal->eth.h_dest, fcf->fcf_mac, ETH_ALEN); | ||
| 344 | memcpy(kal->eth.h_source, sa, ETH_ALEN); | ||
| 345 | kal->eth.h_proto = htons(ETH_P_FIP); | ||
| 346 | |||
| 347 | kal->fip.fip_ver = FIP_VER_ENCAPS(FIP_VER); | ||
| 348 | kal->fip.fip_op = htons(FIP_OP_CTRL); | ||
| 349 | kal->fip.fip_subcode = FIP_SC_KEEP_ALIVE; | ||
| 350 | kal->fip.fip_dl_len = htons((sizeof(kal->mac) + | ||
| 351 | ports * sizeof(*vn)) / FIP_BPW); | ||
| 352 | kal->fip.fip_flags = htons(FIP_FL_FPMA); | ||
| 353 | |||
| 354 | kal->mac.fd_desc.fip_dtype = FIP_DT_MAC; | ||
| 355 | kal->mac.fd_desc.fip_dlen = sizeof(kal->mac) / FIP_BPW; | ||
| 356 | memcpy(kal->mac.fd_mac, fip->ctl_src_addr, ETH_ALEN); | ||
| 357 | |||
| 358 | if (ports) { | ||
| 359 | vn = (struct fip_vn_desc *)(kal + 1); | ||
| 360 | vn->fd_desc.fip_dtype = FIP_DT_VN_ID; | ||
| 361 | vn->fd_desc.fip_dlen = sizeof(*vn) / FIP_BPW; | ||
| 362 | memcpy(vn->fd_mac, fip->data_src_addr, ETH_ALEN); | ||
| 363 | hton24(vn->fd_fc_id, fc_host_port_id(lp->host)); | ||
| 364 | put_unaligned_be64(lp->wwpn, &vn->fd_wwpn); | ||
| 365 | } | ||
| 366 | |||
| 367 | skb_put(skb, len); | ||
| 368 | skb->protocol = htons(ETH_P_802_3); | ||
| 369 | skb_reset_mac_header(skb); | ||
| 370 | skb_reset_network_header(skb); | ||
| 371 | fip->send(fip, skb); | ||
| 372 | } | ||
| 373 | |||
| 374 | /** | ||
| 375 | * fcoe_ctlr_encaps() - Encapsulate an ELS frame for FIP, without sending it. | ||
| 376 | * @fip: FCoE controller. | ||
| 377 | * @dtype: FIP descriptor type for the frame. | ||
| 378 | * @skb: FCoE ELS frame including FC header but no FCoE headers. | ||
| 379 | * | ||
| 380 | * Returns non-zero error code on failure. | ||
| 381 | * | ||
| 382 | * The caller must check that the length is a multiple of 4. | ||
| 383 | * | ||
| 384 | * The @skb must have enough headroom (28 bytes) and tailroom (8 bytes). | ||
| 385 | * Headroom includes the FIP encapsulation description, FIP header, and | ||
| 386 | * Ethernet header. The tailroom is for the FIP MAC descriptor. | ||
| 387 | */ | ||
| 388 | static int fcoe_ctlr_encaps(struct fcoe_ctlr *fip, | ||
| 389 | u8 dtype, struct sk_buff *skb) | ||
| 390 | { | ||
| 391 | struct fip_encaps_head { | ||
| 392 | struct ethhdr eth; | ||
| 393 | struct fip_header fip; | ||
| 394 | struct fip_encaps encaps; | ||
| 395 | } __attribute__((packed)) *cap; | ||
| 396 | struct fip_mac_desc *mac; | ||
| 397 | struct fcoe_fcf *fcf; | ||
| 398 | size_t dlen; | ||
| 399 | |||
| 400 | fcf = fip->sel_fcf; | ||
| 401 | if (!fcf) | ||
| 402 | return -ENODEV; | ||
| 403 | dlen = sizeof(struct fip_encaps) + skb->len; /* len before push */ | ||
| 404 | cap = (struct fip_encaps_head *)skb_push(skb, sizeof(*cap)); | ||
| 405 | |||
| 406 | memset(cap, 0, sizeof(*cap)); | ||
| 407 | memcpy(cap->eth.h_dest, fcf->fcf_mac, ETH_ALEN); | ||
| 408 | memcpy(cap->eth.h_source, fip->ctl_src_addr, ETH_ALEN); | ||
| 409 | cap->eth.h_proto = htons(ETH_P_FIP); | ||
| 410 | |||
| 411 | cap->fip.fip_ver = FIP_VER_ENCAPS(FIP_VER); | ||
| 412 | cap->fip.fip_op = htons(FIP_OP_LS); | ||
| 413 | cap->fip.fip_subcode = FIP_SC_REQ; | ||
| 414 | cap->fip.fip_dl_len = htons((dlen + sizeof(*mac)) / FIP_BPW); | ||
| 415 | cap->fip.fip_flags = htons(FIP_FL_FPMA); | ||
| 416 | |||
| 417 | cap->encaps.fd_desc.fip_dtype = dtype; | ||
| 418 | cap->encaps.fd_desc.fip_dlen = dlen / FIP_BPW; | ||
| 419 | |||
| 420 | mac = (struct fip_mac_desc *)skb_put(skb, sizeof(*mac)); | ||
| 421 | memset(mac, 0, sizeof(mac)); | ||
| 422 | mac->fd_desc.fip_dtype = FIP_DT_MAC; | ||
| 423 | mac->fd_desc.fip_dlen = sizeof(*mac) / FIP_BPW; | ||
| 424 | if (dtype != ELS_FLOGI) | ||
| 425 | memcpy(mac->fd_mac, fip->data_src_addr, ETH_ALEN); | ||
| 426 | |||
| 427 | skb->protocol = htons(ETH_P_802_3); | ||
| 428 | skb_reset_mac_header(skb); | ||
| 429 | skb_reset_network_header(skb); | ||
| 430 | return 0; | ||
| 431 | } | ||
| 432 | |||
| 433 | /** | ||
| 434 | * fcoe_ctlr_els_send() - Send an ELS frame encapsulated by FIP if appropriate. | ||
| 435 | * @fip: FCoE controller. | ||
| 436 | * @skb: FCoE ELS frame including FC header but no FCoE headers. | ||
| 437 | * | ||
| 438 | * Returns a non-zero error code if the frame should not be sent. | ||
| 439 | * Returns zero if the caller should send the frame with FCoE encapsulation. | ||
| 440 | * | ||
| 441 | * The caller must check that the length is a multiple of 4. | ||
| 442 | * The SKB must have enough headroom (28 bytes) and tailroom (8 bytes). | ||
| 443 | */ | ||
| 444 | int fcoe_ctlr_els_send(struct fcoe_ctlr *fip, struct sk_buff *skb) | ||
| 445 | { | ||
| 446 | struct fc_frame_header *fh; | ||
| 447 | u16 old_xid; | ||
| 448 | u8 op; | ||
| 449 | |||
| 450 | if (fip->state == FIP_ST_NON_FIP) | ||
| 451 | return 0; | ||
| 452 | |||
| 453 | fh = (struct fc_frame_header *)skb->data; | ||
| 454 | op = *(u8 *)(fh + 1); | ||
| 455 | |||
| 456 | switch (op) { | ||
| 457 | case ELS_FLOGI: | ||
| 458 | old_xid = fip->flogi_oxid; | ||
| 459 | fip->flogi_oxid = ntohs(fh->fh_ox_id); | ||
| 460 | if (fip->state == FIP_ST_AUTO) { | ||
| 461 | if (old_xid == FC_XID_UNKNOWN) | ||
| 462 | fip->flogi_count = 0; | ||
| 463 | fip->flogi_count++; | ||
| 464 | if (fip->flogi_count < 3) | ||
| 465 | goto drop; | ||
| 466 | fip->map_dest = 1; | ||
| 467 | return 0; | ||
| 468 | } | ||
| 469 | op = FIP_DT_FLOGI; | ||
| 470 | break; | ||
| 471 | case ELS_FDISC: | ||
| 472 | if (ntoh24(fh->fh_s_id)) | ||
| 473 | return 0; | ||
| 474 | op = FIP_DT_FDISC; | ||
| 475 | break; | ||
| 476 | case ELS_LOGO: | ||
| 477 | if (fip->state != FIP_ST_ENABLED) | ||
| 478 | return 0; | ||
| 479 | if (ntoh24(fh->fh_d_id) != FC_FID_FLOGI) | ||
| 480 | return 0; | ||
| 481 | op = FIP_DT_LOGO; | ||
| 482 | break; | ||
| 483 | case ELS_LS_ACC: | ||
| 484 | if (fip->flogi_oxid == FC_XID_UNKNOWN) | ||
| 485 | return 0; | ||
| 486 | if (!ntoh24(fh->fh_s_id)) | ||
| 487 | return 0; | ||
| 488 | if (fip->state == FIP_ST_AUTO) | ||
| 489 | return 0; | ||
| 490 | /* | ||
| 491 | * Here we must've gotten an SID by accepting an FLOGI | ||
| 492 | * from a point-to-point connection. Switch to using | ||
| 493 | * the source mac based on the SID. The destination | ||
| 494 | * MAC in this case would have been set by receving the | ||
| 495 | * FLOGI. | ||
| 496 | */ | ||
| 497 | fip->flogi_oxid = FC_XID_UNKNOWN; | ||
| 498 | fc_fcoe_set_mac(fip->data_src_addr, fh->fh_s_id); | ||
| 499 | return 0; | ||
| 500 | default: | ||
| 501 | if (fip->state != FIP_ST_ENABLED) | ||
| 502 | goto drop; | ||
| 503 | return 0; | ||
| 504 | } | ||
| 505 | if (fcoe_ctlr_encaps(fip, op, skb)) | ||
| 506 | goto drop; | ||
| 507 | fip->send(fip, skb); | ||
| 508 | return -EINPROGRESS; | ||
| 509 | drop: | ||
| 510 | kfree_skb(skb); | ||
| 511 | return -EINVAL; | ||
| 512 | } | ||
| 513 | EXPORT_SYMBOL(fcoe_ctlr_els_send); | ||
| 514 | |||
| 515 | /* | ||
| 516 | * fcoe_ctlr_age_fcfs() - Reset and free all old FCFs for a controller. | ||
| 517 | * @fip: FCoE controller. | ||
| 518 | * | ||
| 519 | * Called with lock held. | ||
| 520 | * | ||
| 521 | * An FCF is considered old if we have missed three advertisements. | ||
| 522 | * That is, there have been no valid advertisement from it for three | ||
| 523 | * times its keep-alive period including fuzz. | ||
| 524 | * | ||
| 525 | * In addition, determine the time when an FCF selection can occur. | ||
| 526 | */ | ||
| 527 | static void fcoe_ctlr_age_fcfs(struct fcoe_ctlr *fip) | ||
| 528 | { | ||
| 529 | struct fcoe_fcf *fcf; | ||
| 530 | struct fcoe_fcf *next; | ||
| 531 | unsigned long sel_time = 0; | ||
| 532 | |||
| 533 | list_for_each_entry_safe(fcf, next, &fip->fcfs, list) { | ||
| 534 | if (time_after(jiffies, fcf->time + fcf->fka_period * 3 + | ||
| 535 | msecs_to_jiffies(FIP_FCF_FUZZ * 3))) { | ||
| 536 | if (fip->sel_fcf == fcf) | ||
| 537 | fip->sel_fcf = NULL; | ||
| 538 | list_del(&fcf->list); | ||
| 539 | WARN_ON(!fip->fcf_count); | ||
| 540 | fip->fcf_count--; | ||
| 541 | kfree(fcf); | ||
| 542 | } else if (fcoe_ctlr_mtu_valid(fcf) && | ||
| 543 | (!sel_time || time_before(sel_time, fcf->time))) { | ||
| 544 | sel_time = fcf->time; | ||
| 545 | } | ||
| 546 | } | ||
| 547 | if (sel_time) { | ||
| 548 | sel_time += msecs_to_jiffies(FCOE_CTLR_START_DELAY); | ||
| 549 | fip->sel_time = sel_time; | ||
| 550 | if (time_before(sel_time, fip->timer.expires)) | ||
| 551 | mod_timer(&fip->timer, sel_time); | ||
| 552 | } else { | ||
| 553 | fip->sel_time = 0; | ||
| 554 | } | ||
| 555 | } | ||
| 556 | |||
| 557 | /** | ||
| 558 | * fcoe_ctlr_parse_adv() - Decode a FIP advertisement into a new FCF entry. | ||
| 559 | * @skb: received FIP advertisement frame | ||
| 560 | * @fcf: resulting FCF entry. | ||
| 561 | * | ||
| 562 | * Returns zero on a valid parsed advertisement, | ||
| 563 | * otherwise returns non zero value. | ||
| 564 | */ | ||
| 565 | static int fcoe_ctlr_parse_adv(struct sk_buff *skb, struct fcoe_fcf *fcf) | ||
| 566 | { | ||
| 567 | struct fip_header *fiph; | ||
| 568 | struct fip_desc *desc = NULL; | ||
| 569 | struct fip_wwn_desc *wwn; | ||
| 570 | struct fip_fab_desc *fab; | ||
| 571 | struct fip_fka_desc *fka; | ||
| 572 | unsigned long t; | ||
| 573 | size_t rlen; | ||
| 574 | size_t dlen; | ||
| 575 | |||
| 576 | memset(fcf, 0, sizeof(*fcf)); | ||
| 577 | fcf->fka_period = msecs_to_jiffies(FCOE_CTLR_DEF_FKA); | ||
| 578 | |||
| 579 | fiph = (struct fip_header *)skb->data; | ||
| 580 | fcf->flags = ntohs(fiph->fip_flags); | ||
| 581 | |||
| 582 | rlen = ntohs(fiph->fip_dl_len) * 4; | ||
| 583 | if (rlen + sizeof(*fiph) > skb->len) | ||
| 584 | return -EINVAL; | ||
| 585 | |||
| 586 | desc = (struct fip_desc *)(fiph + 1); | ||
| 587 | while (rlen > 0) { | ||
| 588 | dlen = desc->fip_dlen * FIP_BPW; | ||
| 589 | if (dlen < sizeof(*desc) || dlen > rlen) | ||
| 590 | return -EINVAL; | ||
| 591 | switch (desc->fip_dtype) { | ||
| 592 | case FIP_DT_PRI: | ||
| 593 | if (dlen != sizeof(struct fip_pri_desc)) | ||
| 594 | goto len_err; | ||
| 595 | fcf->pri = ((struct fip_pri_desc *)desc)->fd_pri; | ||
| 596 | break; | ||
| 597 | case FIP_DT_MAC: | ||
| 598 | if (dlen != sizeof(struct fip_mac_desc)) | ||
| 599 | goto len_err; | ||
| 600 | memcpy(fcf->fcf_mac, | ||
| 601 | ((struct fip_mac_desc *)desc)->fd_mac, | ||
| 602 | ETH_ALEN); | ||
| 603 | if (!is_valid_ether_addr(fcf->fcf_mac)) { | ||
| 604 | FIP_DBG("invalid MAC addr in FIP adv\n"); | ||
| 605 | return -EINVAL; | ||
| 606 | } | ||
| 607 | break; | ||
| 608 | case FIP_DT_NAME: | ||
| 609 | if (dlen != sizeof(struct fip_wwn_desc)) | ||
| 610 | goto len_err; | ||
| 611 | wwn = (struct fip_wwn_desc *)desc; | ||
| 612 | fcf->switch_name = get_unaligned_be64(&wwn->fd_wwn); | ||
| 613 | break; | ||
| 614 | case FIP_DT_FAB: | ||
| 615 | if (dlen != sizeof(struct fip_fab_desc)) | ||
| 616 | goto len_err; | ||
| 617 | fab = (struct fip_fab_desc *)desc; | ||
| 618 | fcf->fabric_name = get_unaligned_be64(&fab->fd_wwn); | ||
| 619 | fcf->vfid = ntohs(fab->fd_vfid); | ||
| 620 | fcf->fc_map = ntoh24(fab->fd_map); | ||
| 621 | break; | ||
| 622 | case FIP_DT_FKA: | ||
| 623 | if (dlen != sizeof(struct fip_fka_desc)) | ||
| 624 | goto len_err; | ||
| 625 | fka = (struct fip_fka_desc *)desc; | ||
| 626 | t = ntohl(fka->fd_fka_period); | ||
| 627 | if (t >= FCOE_CTLR_MIN_FKA) | ||
| 628 | fcf->fka_period = msecs_to_jiffies(t); | ||
| 629 | break; | ||
| 630 | case FIP_DT_MAP_OUI: | ||
| 631 | case FIP_DT_FCOE_SIZE: | ||
| 632 | case FIP_DT_FLOGI: | ||
| 633 | case FIP_DT_FDISC: | ||
| 634 | case FIP_DT_LOGO: | ||
| 635 | case FIP_DT_ELP: | ||
| 636 | default: | ||
| 637 | FIP_DBG("unexpected descriptor type %x in FIP adv\n", | ||
| 638 | desc->fip_dtype); | ||
| 639 | /* standard says ignore unknown descriptors >= 128 */ | ||
| 640 | if (desc->fip_dtype < FIP_DT_VENDOR_BASE) | ||
| 641 | return -EINVAL; | ||
| 642 | continue; | ||
| 643 | } | ||
| 644 | desc = (struct fip_desc *)((char *)desc + dlen); | ||
| 645 | rlen -= dlen; | ||
| 646 | } | ||
| 647 | if (!fcf->fc_map || (fcf->fc_map & 0x10000)) | ||
| 648 | return -EINVAL; | ||
| 649 | if (!fcf->switch_name || !fcf->fabric_name) | ||
| 650 | return -EINVAL; | ||
| 651 | return 0; | ||
| 652 | |||
| 653 | len_err: | ||
| 654 | FIP_DBG("FIP length error in descriptor type %x len %zu\n", | ||
| 655 | desc->fip_dtype, dlen); | ||
| 656 | return -EINVAL; | ||
| 657 | } | ||
| 658 | |||
| 659 | /** | ||
| 660 | * fcoe_ctlr_recv_adv() - Handle an incoming advertisement. | ||
| 661 | * @fip: FCoE controller. | ||
| 662 | * @skb: Received FIP packet. | ||
| 663 | */ | ||
| 664 | static void fcoe_ctlr_recv_adv(struct fcoe_ctlr *fip, struct sk_buff *skb) | ||
| 665 | { | ||
| 666 | struct fcoe_fcf *fcf; | ||
| 667 | struct fcoe_fcf new; | ||
| 668 | struct fcoe_fcf *found; | ||
| 669 | unsigned long sol_tov = msecs_to_jiffies(FCOE_CTRL_SOL_TOV); | ||
| 670 | int first = 0; | ||
| 671 | int mtu_valid; | ||
| 672 | |||
| 673 | if (fcoe_ctlr_parse_adv(skb, &new)) | ||
| 674 | return; | ||
| 675 | |||
| 676 | spin_lock_bh(&fip->lock); | ||
| 677 | first = list_empty(&fip->fcfs); | ||
| 678 | found = NULL; | ||
| 679 | list_for_each_entry(fcf, &fip->fcfs, list) { | ||
| 680 | if (fcf->switch_name == new.switch_name && | ||
| 681 | fcf->fabric_name == new.fabric_name && | ||
| 682 | fcf->fc_map == new.fc_map && | ||
| 683 | compare_ether_addr(fcf->fcf_mac, new.fcf_mac) == 0) { | ||
| 684 | found = fcf; | ||
| 685 | break; | ||
| 686 | } | ||
| 687 | } | ||
| 688 | if (!found) { | ||
| 689 | if (fip->fcf_count >= FCOE_CTLR_FCF_LIMIT) | ||
| 690 | goto out; | ||
| 691 | |||
| 692 | fcf = kmalloc(sizeof(*fcf), GFP_ATOMIC); | ||
| 693 | if (!fcf) | ||
| 694 | goto out; | ||
| 695 | |||
| 696 | fip->fcf_count++; | ||
| 697 | memcpy(fcf, &new, sizeof(new)); | ||
| 698 | list_add(&fcf->list, &fip->fcfs); | ||
| 699 | } else { | ||
| 700 | /* | ||
| 701 | * Flags in advertisements are ignored once the FCF is | ||
| 702 | * selected. Flags in unsolicited advertisements are | ||
| 703 | * ignored after a usable solicited advertisement | ||
| 704 | * has been received. | ||
| 705 | */ | ||
| 706 | if (fcf == fip->sel_fcf) { | ||
| 707 | fip->ctlr_ka_time -= fcf->fka_period; | ||
| 708 | fip->ctlr_ka_time += new.fka_period; | ||
| 709 | if (time_before(fip->ctlr_ka_time, fip->timer.expires)) | ||
| 710 | mod_timer(&fip->timer, fip->ctlr_ka_time); | ||
| 711 | } else if (!fcoe_ctlr_fcf_usable(fcf)) | ||
| 712 | fcf->flags = new.flags; | ||
| 713 | fcf->fka_period = new.fka_period; | ||
| 714 | memcpy(fcf->fcf_mac, new.fcf_mac, ETH_ALEN); | ||
| 715 | } | ||
| 716 | mtu_valid = fcoe_ctlr_mtu_valid(fcf); | ||
| 717 | fcf->time = jiffies; | ||
| 718 | FIP_DBG_LVL(found ? 2 : 1, "%s FCF for fab %llx map %x val %d\n", | ||
| 719 | found ? "old" : "new", | ||
| 720 | fcf->fabric_name, fcf->fc_map, mtu_valid); | ||
| 721 | |||
| 722 | /* | ||
| 723 | * If this advertisement is not solicited and our max receive size | ||
| 724 | * hasn't been verified, send a solicited advertisement. | ||
| 725 | */ | ||
| 726 | if (!mtu_valid) | ||
| 727 | fcoe_ctlr_solicit(fip, fcf); | ||
| 728 | |||
| 729 | /* | ||
| 730 | * If its been a while since we did a solicit, and this is | ||
| 731 | * the first advertisement we've received, do a multicast | ||
| 732 | * solicitation to gather as many advertisements as we can | ||
| 733 | * before selection occurs. | ||
| 734 | */ | ||
| 735 | if (first && time_after(jiffies, fip->sol_time + sol_tov)) | ||
| 736 | fcoe_ctlr_solicit(fip, NULL); | ||
| 737 | |||
| 738 | /* | ||
| 739 | * If this is the first validated FCF, note the time and | ||
| 740 | * set a timer to trigger selection. | ||
| 741 | */ | ||
| 742 | if (mtu_valid && !fip->sel_time && fcoe_ctlr_fcf_usable(fcf)) { | ||
| 743 | fip->sel_time = jiffies + | ||
| 744 | msecs_to_jiffies(FCOE_CTLR_START_DELAY); | ||
| 745 | if (!timer_pending(&fip->timer) || | ||
| 746 | time_before(fip->sel_time, fip->timer.expires)) | ||
| 747 | mod_timer(&fip->timer, fip->sel_time); | ||
| 748 | } | ||
| 749 | out: | ||
| 750 | spin_unlock_bh(&fip->lock); | ||
| 751 | } | ||
| 752 | |||
| 753 | /** | ||
| 754 | * fcoe_ctlr_recv_els() - Handle an incoming FIP-encapsulated ELS frame. | ||
| 755 | * @fip: FCoE controller. | ||
| 756 | * @skb: Received FIP packet. | ||
| 757 | */ | ||
| 758 | static void fcoe_ctlr_recv_els(struct fcoe_ctlr *fip, struct sk_buff *skb) | ||
| 759 | { | ||
| 760 | struct fc_lport *lp = fip->lp; | ||
| 761 | struct fip_header *fiph; | ||
| 762 | struct fc_frame *fp; | ||
| 763 | struct fc_frame_header *fh = NULL; | ||
| 764 | struct fip_desc *desc; | ||
| 765 | struct fip_encaps *els; | ||
| 766 | struct fcoe_dev_stats *stats; | ||
| 767 | enum fip_desc_type els_dtype = 0; | ||
| 768 | u8 els_op; | ||
| 769 | u8 sub; | ||
| 770 | u8 granted_mac[ETH_ALEN] = { 0 }; | ||
| 771 | size_t els_len = 0; | ||
| 772 | size_t rlen; | ||
| 773 | size_t dlen; | ||
| 774 | |||
| 775 | fiph = (struct fip_header *)skb->data; | ||
| 776 | sub = fiph->fip_subcode; | ||
| 777 | if (sub != FIP_SC_REQ && sub != FIP_SC_REP) | ||
| 778 | goto drop; | ||
| 779 | |||
| 780 | rlen = ntohs(fiph->fip_dl_len) * 4; | ||
| 781 | if (rlen + sizeof(*fiph) > skb->len) | ||
| 782 | goto drop; | ||
| 783 | |||
| 784 | desc = (struct fip_desc *)(fiph + 1); | ||
| 785 | while (rlen > 0) { | ||
| 786 | dlen = desc->fip_dlen * FIP_BPW; | ||
| 787 | if (dlen < sizeof(*desc) || dlen > rlen) | ||
| 788 | goto drop; | ||
| 789 | switch (desc->fip_dtype) { | ||
| 790 | case FIP_DT_MAC: | ||
| 791 | if (dlen != sizeof(struct fip_mac_desc)) | ||
| 792 | goto len_err; | ||
| 793 | memcpy(granted_mac, | ||
| 794 | ((struct fip_mac_desc *)desc)->fd_mac, | ||
| 795 | ETH_ALEN); | ||
| 796 | if (!is_valid_ether_addr(granted_mac)) { | ||
| 797 | FIP_DBG("invalid MAC addrs in FIP ELS\n"); | ||
| 798 | goto drop; | ||
| 799 | } | ||
| 800 | break; | ||
| 801 | case FIP_DT_FLOGI: | ||
| 802 | case FIP_DT_FDISC: | ||
| 803 | case FIP_DT_LOGO: | ||
| 804 | case FIP_DT_ELP: | ||
| 805 | if (fh) | ||
| 806 | goto drop; | ||
| 807 | if (dlen < sizeof(*els) + sizeof(*fh) + 1) | ||
| 808 | goto len_err; | ||
| 809 | els_len = dlen - sizeof(*els); | ||
| 810 | els = (struct fip_encaps *)desc; | ||
| 811 | fh = (struct fc_frame_header *)(els + 1); | ||
| 812 | els_dtype = desc->fip_dtype; | ||
| 813 | break; | ||
| 814 | default: | ||
| 815 | FIP_DBG("unexpected descriptor type %x " | ||
| 816 | "in FIP adv\n", desc->fip_dtype); | ||
| 817 | /* standard says ignore unknown descriptors >= 128 */ | ||
| 818 | if (desc->fip_dtype < FIP_DT_VENDOR_BASE) | ||
| 819 | goto drop; | ||
| 820 | continue; | ||
| 821 | } | ||
| 822 | desc = (struct fip_desc *)((char *)desc + dlen); | ||
| 823 | rlen -= dlen; | ||
| 824 | } | ||
| 825 | |||
| 826 | if (!fh) | ||
| 827 | goto drop; | ||
| 828 | els_op = *(u8 *)(fh + 1); | ||
| 829 | |||
| 830 | if (els_dtype == FIP_DT_FLOGI && sub == FIP_SC_REP && | ||
| 831 | fip->flogi_oxid == ntohs(fh->fh_ox_id) && | ||
| 832 | els_op == ELS_LS_ACC && is_valid_ether_addr(granted_mac)) { | ||
| 833 | fip->flogi_oxid = FC_XID_UNKNOWN; | ||
| 834 | fip->update_mac(fip, fip->data_src_addr, granted_mac); | ||
| 835 | memcpy(fip->data_src_addr, granted_mac, ETH_ALEN); | ||
| 836 | } | ||
| 837 | |||
| 838 | /* | ||
| 839 | * Convert skb into an fc_frame containing only the ELS. | ||
| 840 | */ | ||
| 841 | skb_pull(skb, (u8 *)fh - skb->data); | ||
| 842 | skb_trim(skb, els_len); | ||
| 843 | fp = (struct fc_frame *)skb; | ||
| 844 | fc_frame_init(fp); | ||
| 845 | fr_sof(fp) = FC_SOF_I3; | ||
| 846 | fr_eof(fp) = FC_EOF_T; | ||
| 847 | fr_dev(fp) = lp; | ||
| 848 | |||
| 849 | stats = fc_lport_get_stats(lp); | ||
| 850 | stats->RxFrames++; | ||
| 851 | stats->RxWords += skb->len / FIP_BPW; | ||
| 852 | |||
| 853 | fc_exch_recv(lp, lp->emp, fp); | ||
| 854 | return; | ||
| 855 | |||
| 856 | len_err: | ||
| 857 | FIP_DBG("FIP length error in descriptor type %x len %zu\n", | ||
| 858 | desc->fip_dtype, dlen); | ||
| 859 | drop: | ||
| 860 | kfree_skb(skb); | ||
| 861 | } | ||
| 862 | |||
| 863 | /** | ||
| 864 | * fcoe_ctlr_recv_els() - Handle an incoming link reset frame. | ||
| 865 | * @fip: FCoE controller. | ||
| 866 | * @fh: Received FIP header. | ||
| 867 | * | ||
| 868 | * There may be multiple VN_Port descriptors. | ||
| 869 | * The overall length has already been checked. | ||
| 870 | */ | ||
| 871 | static void fcoe_ctlr_recv_clr_vlink(struct fcoe_ctlr *fip, | ||
| 872 | struct fip_header *fh) | ||
| 873 | { | ||
| 874 | struct fip_desc *desc; | ||
| 875 | struct fip_mac_desc *mp; | ||
| 876 | struct fip_wwn_desc *wp; | ||
| 877 | struct fip_vn_desc *vp; | ||
| 878 | size_t rlen; | ||
| 879 | size_t dlen; | ||
| 880 | struct fcoe_fcf *fcf = fip->sel_fcf; | ||
| 881 | struct fc_lport *lp = fip->lp; | ||
| 882 | u32 desc_mask; | ||
| 883 | |||
| 884 | FIP_DBG("Clear Virtual Link received\n"); | ||
| 885 | if (!fcf) | ||
| 886 | return; | ||
| 887 | if (!fcf || !fc_host_port_id(lp->host)) | ||
| 888 | return; | ||
| 889 | |||
| 890 | /* | ||
| 891 | * mask of required descriptors. Validating each one clears its bit. | ||
| 892 | */ | ||
| 893 | desc_mask = BIT(FIP_DT_MAC) | BIT(FIP_DT_NAME) | BIT(FIP_DT_VN_ID); | ||
| 894 | |||
| 895 | rlen = ntohs(fh->fip_dl_len) * FIP_BPW; | ||
| 896 | desc = (struct fip_desc *)(fh + 1); | ||
| 897 | while (rlen >= sizeof(*desc)) { | ||
| 898 | dlen = desc->fip_dlen * FIP_BPW; | ||
| 899 | if (dlen > rlen) | ||
| 900 | return; | ||
| 901 | switch (desc->fip_dtype) { | ||
| 902 | case FIP_DT_MAC: | ||
| 903 | mp = (struct fip_mac_desc *)desc; | ||
| 904 | if (dlen < sizeof(*mp)) | ||
| 905 | return; | ||
| 906 | if (compare_ether_addr(mp->fd_mac, fcf->fcf_mac)) | ||
| 907 | return; | ||
| 908 | desc_mask &= ~BIT(FIP_DT_MAC); | ||
| 909 | break; | ||
| 910 | case FIP_DT_NAME: | ||
| 911 | wp = (struct fip_wwn_desc *)desc; | ||
| 912 | if (dlen < sizeof(*wp)) | ||
| 913 | return; | ||
| 914 | if (get_unaligned_be64(&wp->fd_wwn) != fcf->switch_name) | ||
| 915 | return; | ||
| 916 | desc_mask &= ~BIT(FIP_DT_NAME); | ||
| 917 | break; | ||
| 918 | case FIP_DT_VN_ID: | ||
| 919 | vp = (struct fip_vn_desc *)desc; | ||
| 920 | if (dlen < sizeof(*vp)) | ||
| 921 | return; | ||
| 922 | if (compare_ether_addr(vp->fd_mac, | ||
| 923 | fip->data_src_addr) == 0 && | ||
| 924 | get_unaligned_be64(&vp->fd_wwpn) == lp->wwpn && | ||
| 925 | ntoh24(vp->fd_fc_id) == fc_host_port_id(lp->host)) | ||
| 926 | desc_mask &= ~BIT(FIP_DT_VN_ID); | ||
| 927 | break; | ||
| 928 | default: | ||
| 929 | /* standard says ignore unknown descriptors >= 128 */ | ||
| 930 | if (desc->fip_dtype < FIP_DT_VENDOR_BASE) | ||
| 931 | return; | ||
| 932 | break; | ||
| 933 | } | ||
| 934 | desc = (struct fip_desc *)((char *)desc + dlen); | ||
| 935 | rlen -= dlen; | ||
| 936 | } | ||
| 937 | |||
| 938 | /* | ||
| 939 | * reset only if all required descriptors were present and valid. | ||
| 940 | */ | ||
| 941 | if (desc_mask) { | ||
| 942 | FIP_DBG("missing descriptors mask %x\n", desc_mask); | ||
| 943 | } else { | ||
| 944 | FIP_DBG("performing Clear Virtual Link\n"); | ||
| 945 | fcoe_ctlr_reset(fip, FIP_ST_ENABLED); | ||
| 946 | } | ||
| 947 | } | ||
| 948 | |||
| 949 | /** | ||
| 950 | * fcoe_ctlr_recv() - Receive a FIP frame. | ||
| 951 | * @fip: FCoE controller. | ||
| 952 | * @skb: Received FIP packet. | ||
| 953 | * | ||
| 954 | * This is called from NET_RX_SOFTIRQ. | ||
| 955 | */ | ||
| 956 | void fcoe_ctlr_recv(struct fcoe_ctlr *fip, struct sk_buff *skb) | ||
| 957 | { | ||
| 958 | spin_lock_bh(&fip->fip_recv_list.lock); | ||
| 959 | __skb_queue_tail(&fip->fip_recv_list, skb); | ||
| 960 | spin_unlock_bh(&fip->fip_recv_list.lock); | ||
| 961 | schedule_work(&fip->recv_work); | ||
| 962 | } | ||
| 963 | EXPORT_SYMBOL(fcoe_ctlr_recv); | ||
| 964 | |||
| 965 | /** | ||
| 966 | * fcoe_ctlr_recv_handler() - Receive a FIP frame. | ||
| 967 | * @fip: FCoE controller. | ||
| 968 | * @skb: Received FIP packet. | ||
| 969 | * | ||
| 970 | * Returns non-zero if the frame is dropped. | ||
| 971 | */ | ||
| 972 | static int fcoe_ctlr_recv_handler(struct fcoe_ctlr *fip, struct sk_buff *skb) | ||
| 973 | { | ||
| 974 | struct fip_header *fiph; | ||
| 975 | struct ethhdr *eh; | ||
| 976 | enum fip_state state; | ||
| 977 | u16 op; | ||
| 978 | u8 sub; | ||
| 979 | |||
| 980 | if (skb_linearize(skb)) | ||
| 981 | goto drop; | ||
| 982 | if (skb->len < sizeof(*fiph)) | ||
| 983 | goto drop; | ||
| 984 | eh = eth_hdr(skb); | ||
| 985 | if (compare_ether_addr(eh->h_dest, fip->ctl_src_addr) && | ||
| 986 | compare_ether_addr(eh->h_dest, FIP_ALL_ENODE_MACS)) | ||
| 987 | goto drop; | ||
| 988 | fiph = (struct fip_header *)skb->data; | ||
| 989 | op = ntohs(fiph->fip_op); | ||
| 990 | sub = fiph->fip_subcode; | ||
| 991 | |||
| 992 | FIP_DBG_LVL(2, "ver %x op %x/%x dl %x fl %x\n", | ||
| 993 | FIP_VER_DECAPS(fiph->fip_ver), op, sub, | ||
| 994 | ntohs(fiph->fip_dl_len), ntohs(fiph->fip_flags)); | ||
| 995 | |||
| 996 | if (FIP_VER_DECAPS(fiph->fip_ver) != FIP_VER) | ||
| 997 | goto drop; | ||
| 998 | if (ntohs(fiph->fip_dl_len) * FIP_BPW + sizeof(*fiph) > skb->len) | ||
| 999 | goto drop; | ||
| 1000 | |||
| 1001 | spin_lock_bh(&fip->lock); | ||
| 1002 | state = fip->state; | ||
| 1003 | if (state == FIP_ST_AUTO) { | ||
| 1004 | fip->map_dest = 0; | ||
| 1005 | fip->state = FIP_ST_ENABLED; | ||
| 1006 | state = FIP_ST_ENABLED; | ||
| 1007 | FIP_DBG("using FIP mode\n"); | ||
| 1008 | } | ||
| 1009 | spin_unlock_bh(&fip->lock); | ||
| 1010 | if (state != FIP_ST_ENABLED) | ||
| 1011 | goto drop; | ||
| 1012 | |||
| 1013 | if (op == FIP_OP_LS) { | ||
| 1014 | fcoe_ctlr_recv_els(fip, skb); /* consumes skb */ | ||
| 1015 | return 0; | ||
| 1016 | } | ||
| 1017 | if (op == FIP_OP_DISC && sub == FIP_SC_ADV) | ||
| 1018 | fcoe_ctlr_recv_adv(fip, skb); | ||
| 1019 | else if (op == FIP_OP_CTRL && sub == FIP_SC_CLR_VLINK) | ||
| 1020 | fcoe_ctlr_recv_clr_vlink(fip, fiph); | ||
| 1021 | kfree_skb(skb); | ||
| 1022 | return 0; | ||
| 1023 | drop: | ||
| 1024 | kfree_skb(skb); | ||
| 1025 | return -1; | ||
| 1026 | } | ||
| 1027 | |||
| 1028 | /** | ||
| 1029 | * fcoe_ctlr_select() - Select the best FCF, if possible. | ||
| 1030 | * @fip: FCoE controller. | ||
| 1031 | * | ||
| 1032 | * If there are conflicting advertisements, no FCF can be chosen. | ||
| 1033 | * | ||
| 1034 | * Called with lock held. | ||
| 1035 | */ | ||
| 1036 | static void fcoe_ctlr_select(struct fcoe_ctlr *fip) | ||
| 1037 | { | ||
| 1038 | struct fcoe_fcf *fcf; | ||
| 1039 | struct fcoe_fcf *best = NULL; | ||
| 1040 | |||
| 1041 | list_for_each_entry(fcf, &fip->fcfs, list) { | ||
| 1042 | FIP_DBG("consider FCF for fab %llx VFID %d map %x val %d\n", | ||
| 1043 | fcf->fabric_name, fcf->vfid, | ||
| 1044 | fcf->fc_map, fcoe_ctlr_mtu_valid(fcf)); | ||
| 1045 | if (!fcoe_ctlr_fcf_usable(fcf)) { | ||
| 1046 | FIP_DBG("FCF for fab %llx map %x %svalid %savailable\n", | ||
| 1047 | fcf->fabric_name, fcf->fc_map, | ||
| 1048 | (fcf->flags & FIP_FL_SOL) ? "" : "in", | ||
| 1049 | (fcf->flags & FIP_FL_AVAIL) ? "" : "un"); | ||
| 1050 | continue; | ||
| 1051 | } | ||
| 1052 | if (!best) { | ||
| 1053 | best = fcf; | ||
| 1054 | continue; | ||
| 1055 | } | ||
| 1056 | if (fcf->fabric_name != best->fabric_name || | ||
| 1057 | fcf->vfid != best->vfid || | ||
| 1058 | fcf->fc_map != best->fc_map) { | ||
| 1059 | FIP_DBG("conflicting fabric, VFID, or FC-MAP\n"); | ||
| 1060 | return; | ||
| 1061 | } | ||
| 1062 | if (fcf->pri < best->pri) | ||
| 1063 | best = fcf; | ||
| 1064 | } | ||
| 1065 | fip->sel_fcf = best; | ||
| 1066 | } | ||
| 1067 | |||
| 1068 | /** | ||
| 1069 | * fcoe_ctlr_timeout() - FIP timer function. | ||
| 1070 | * @arg: &fcoe_ctlr pointer. | ||
| 1071 | * | ||
| 1072 | * Ages FCFs. Triggers FCF selection if possible. Sends keep-alives. | ||
| 1073 | */ | ||
| 1074 | static void fcoe_ctlr_timeout(unsigned long arg) | ||
| 1075 | { | ||
| 1076 | struct fcoe_ctlr *fip = (struct fcoe_ctlr *)arg; | ||
| 1077 | struct fcoe_fcf *sel; | ||
| 1078 | struct fcoe_fcf *fcf; | ||
| 1079 | unsigned long next_timer = jiffies + msecs_to_jiffies(FIP_VN_KA_PERIOD); | ||
| 1080 | DECLARE_MAC_BUF(buf); | ||
| 1081 | u8 send_ctlr_ka; | ||
| 1082 | u8 send_port_ka; | ||
| 1083 | |||
| 1084 | spin_lock_bh(&fip->lock); | ||
| 1085 | if (fip->state == FIP_ST_DISABLED) { | ||
| 1086 | spin_unlock_bh(&fip->lock); | ||
| 1087 | return; | ||
| 1088 | } | ||
| 1089 | |||
| 1090 | fcf = fip->sel_fcf; | ||
| 1091 | fcoe_ctlr_age_fcfs(fip); | ||
| 1092 | |||
| 1093 | sel = fip->sel_fcf; | ||
| 1094 | if (!sel && fip->sel_time && time_after_eq(jiffies, fip->sel_time)) { | ||
| 1095 | fcoe_ctlr_select(fip); | ||
| 1096 | sel = fip->sel_fcf; | ||
| 1097 | fip->sel_time = 0; | ||
| 1098 | } | ||
| 1099 | |||
| 1100 | if (sel != fcf) { | ||
| 1101 | fcf = sel; /* the old FCF may have been freed */ | ||
| 1102 | if (sel) { | ||
| 1103 | printk(KERN_INFO "host%d: FIP selected " | ||
| 1104 | "Fibre-Channel Forwarder MAC %s\n", | ||
| 1105 | fip->lp->host->host_no, | ||
| 1106 | print_mac(buf, sel->fcf_mac)); | ||
| 1107 | memcpy(fip->dest_addr, sel->fcf_mac, ETH_ALEN); | ||
| 1108 | fip->port_ka_time = jiffies + | ||
| 1109 | msecs_to_jiffies(FIP_VN_KA_PERIOD); | ||
| 1110 | fip->ctlr_ka_time = jiffies + sel->fka_period; | ||
| 1111 | fip->link = 1; | ||
| 1112 | } else { | ||
| 1113 | printk(KERN_NOTICE "host%d: " | ||
| 1114 | "FIP Fibre-Channel Forwarder timed out. " | ||
| 1115 | "Starting FCF discovery.\n", | ||
| 1116 | fip->lp->host->host_no); | ||
| 1117 | fip->link = 0; | ||
| 1118 | } | ||
| 1119 | schedule_work(&fip->link_work); | ||
| 1120 | } | ||
| 1121 | |||
| 1122 | send_ctlr_ka = 0; | ||
| 1123 | send_port_ka = 0; | ||
| 1124 | if (sel) { | ||
| 1125 | if (time_after_eq(jiffies, fip->ctlr_ka_time)) { | ||
| 1126 | fip->ctlr_ka_time = jiffies + sel->fka_period; | ||
| 1127 | send_ctlr_ka = 1; | ||
| 1128 | } | ||
| 1129 | if (time_after(next_timer, fip->ctlr_ka_time)) | ||
| 1130 | next_timer = fip->ctlr_ka_time; | ||
| 1131 | |||
| 1132 | if (time_after_eq(jiffies, fip->port_ka_time)) { | ||
| 1133 | fip->port_ka_time += jiffies + | ||
| 1134 | msecs_to_jiffies(FIP_VN_KA_PERIOD); | ||
| 1135 | send_port_ka = 1; | ||
| 1136 | } | ||
| 1137 | if (time_after(next_timer, fip->port_ka_time)) | ||
| 1138 | next_timer = fip->port_ka_time; | ||
| 1139 | mod_timer(&fip->timer, next_timer); | ||
| 1140 | } else if (fip->sel_time) { | ||
| 1141 | next_timer = fip->sel_time + | ||
| 1142 | msecs_to_jiffies(FCOE_CTLR_START_DELAY); | ||
| 1143 | mod_timer(&fip->timer, next_timer); | ||
| 1144 | } | ||
| 1145 | spin_unlock_bh(&fip->lock); | ||
| 1146 | |||
| 1147 | if (send_ctlr_ka) | ||
| 1148 | fcoe_ctlr_send_keep_alive(fip, 0, fip->ctl_src_addr); | ||
| 1149 | if (send_port_ka) | ||
| 1150 | fcoe_ctlr_send_keep_alive(fip, 1, fip->data_src_addr); | ||
| 1151 | } | ||
| 1152 | |||
| 1153 | /** | ||
| 1154 | * fcoe_ctlr_link_work() - worker thread function for link changes. | ||
| 1155 | * @work: pointer to link_work member inside &fcoe_ctlr. | ||
| 1156 | * | ||
| 1157 | * See if the link status has changed and if so, report it. | ||
| 1158 | * | ||
| 1159 | * This is here because fc_linkup() and fc_linkdown() must not | ||
| 1160 | * be called from the timer directly, since they use a mutex. | ||
| 1161 | */ | ||
| 1162 | static void fcoe_ctlr_link_work(struct work_struct *work) | ||
| 1163 | { | ||
| 1164 | struct fcoe_ctlr *fip; | ||
| 1165 | int link; | ||
| 1166 | int last_link; | ||
| 1167 | |||
| 1168 | fip = container_of(work, struct fcoe_ctlr, link_work); | ||
| 1169 | spin_lock_bh(&fip->lock); | ||
| 1170 | last_link = fip->last_link; | ||
| 1171 | link = fip->link; | ||
| 1172 | fip->last_link = link; | ||
| 1173 | spin_unlock_bh(&fip->lock); | ||
| 1174 | |||
| 1175 | if (last_link != link) { | ||
| 1176 | if (link) | ||
| 1177 | fc_linkup(fip->lp); | ||
| 1178 | else | ||
| 1179 | fcoe_ctlr_reset(fip, FIP_ST_LINK_WAIT); | ||
| 1180 | } | ||
| 1181 | } | ||
| 1182 | |||
| 1183 | /** | ||
| 1184 | * fcoe_ctlr_recv_work() - Worker thread function for receiving FIP frames. | ||
| 1185 | * @recv_work: pointer to recv_work member inside &fcoe_ctlr. | ||
| 1186 | */ | ||
| 1187 | static void fcoe_ctlr_recv_work(struct work_struct *recv_work) | ||
| 1188 | { | ||
| 1189 | struct fcoe_ctlr *fip; | ||
| 1190 | struct sk_buff *skb; | ||
| 1191 | |||
| 1192 | fip = container_of(recv_work, struct fcoe_ctlr, recv_work); | ||
| 1193 | spin_lock_bh(&fip->fip_recv_list.lock); | ||
| 1194 | while ((skb = __skb_dequeue(&fip->fip_recv_list))) { | ||
| 1195 | spin_unlock_bh(&fip->fip_recv_list.lock); | ||
| 1196 | fcoe_ctlr_recv_handler(fip, skb); | ||
| 1197 | spin_lock_bh(&fip->fip_recv_list.lock); | ||
| 1198 | } | ||
| 1199 | spin_unlock_bh(&fip->fip_recv_list.lock); | ||
| 1200 | } | ||
| 1201 | |||
| 1202 | /** | ||
| 1203 | * fcoe_ctlr_recv_flogi() - snoop Pre-FIP receipt of FLOGI response or request. | ||
| 1204 | * @fip: FCoE controller. | ||
| 1205 | * @fp: FC frame. | ||
| 1206 | * @sa: Ethernet source MAC address from received FCoE frame. | ||
| 1207 | * | ||
| 1208 | * Snoop potential response to FLOGI or even incoming FLOGI. | ||
| 1209 | * | ||
| 1210 | * The caller has checked that we are waiting for login as indicated | ||
| 1211 | * by fip->flogi_oxid != FC_XID_UNKNOWN. | ||
| 1212 | * | ||
| 1213 | * The caller is responsible for freeing the frame. | ||
| 1214 | * | ||
| 1215 | * Return non-zero if the frame should not be delivered to libfc. | ||
| 1216 | */ | ||
| 1217 | int fcoe_ctlr_recv_flogi(struct fcoe_ctlr *fip, struct fc_frame *fp, u8 *sa) | ||
| 1218 | { | ||
| 1219 | struct fc_frame_header *fh; | ||
| 1220 | u8 op; | ||
| 1221 | u8 mac[ETH_ALEN]; | ||
| 1222 | |||
| 1223 | fh = fc_frame_header_get(fp); | ||
| 1224 | if (fh->fh_type != FC_TYPE_ELS) | ||
| 1225 | return 0; | ||
| 1226 | |||
| 1227 | op = fc_frame_payload_op(fp); | ||
| 1228 | if (op == ELS_LS_ACC && fh->fh_r_ctl == FC_RCTL_ELS_REP && | ||
| 1229 | fip->flogi_oxid == ntohs(fh->fh_ox_id)) { | ||
| 1230 | |||
| 1231 | spin_lock_bh(&fip->lock); | ||
| 1232 | if (fip->state != FIP_ST_AUTO && fip->state != FIP_ST_NON_FIP) { | ||
| 1233 | spin_unlock_bh(&fip->lock); | ||
| 1234 | return -EINVAL; | ||
| 1235 | } | ||
| 1236 | fip->state = FIP_ST_NON_FIP; | ||
| 1237 | FIP_DBG("received FLOGI LS_ACC using non-FIP mode\n"); | ||
| 1238 | |||
| 1239 | /* | ||
| 1240 | * FLOGI accepted. | ||
| 1241 | * If the src mac addr is FC_OUI-based, then we mark the | ||
| 1242 | * address_mode flag to use FC_OUI-based Ethernet DA. | ||
| 1243 | * Otherwise we use the FCoE gateway addr | ||
| 1244 | */ | ||
| 1245 | if (!compare_ether_addr(sa, (u8[6])FC_FCOE_FLOGI_MAC)) { | ||
| 1246 | fip->map_dest = 1; | ||
| 1247 | } else { | ||
| 1248 | memcpy(fip->dest_addr, sa, ETH_ALEN); | ||
| 1249 | fip->map_dest = 0; | ||
| 1250 | } | ||
| 1251 | fip->flogi_oxid = FC_XID_UNKNOWN; | ||
| 1252 | memcpy(mac, fip->data_src_addr, ETH_ALEN); | ||
| 1253 | fc_fcoe_set_mac(fip->data_src_addr, fh->fh_d_id); | ||
| 1254 | spin_unlock_bh(&fip->lock); | ||
| 1255 | |||
| 1256 | fip->update_mac(fip, mac, fip->data_src_addr); | ||
| 1257 | } else if (op == ELS_FLOGI && fh->fh_r_ctl == FC_RCTL_ELS_REQ && sa) { | ||
| 1258 | /* | ||
| 1259 | * Save source MAC for point-to-point responses. | ||
| 1260 | */ | ||
| 1261 | spin_lock_bh(&fip->lock); | ||
| 1262 | if (fip->state == FIP_ST_AUTO || fip->state == FIP_ST_NON_FIP) { | ||
| 1263 | memcpy(fip->dest_addr, sa, ETH_ALEN); | ||
| 1264 | fip->map_dest = 0; | ||
| 1265 | if (fip->state == FIP_ST_NON_FIP) | ||
| 1266 | FIP_DBG("received FLOGI REQ, " | ||
| 1267 | "using non-FIP mode\n"); | ||
| 1268 | fip->state = FIP_ST_NON_FIP; | ||
| 1269 | } | ||
| 1270 | spin_unlock_bh(&fip->lock); | ||
| 1271 | } | ||
| 1272 | return 0; | ||
| 1273 | } | ||
| 1274 | EXPORT_SYMBOL(fcoe_ctlr_recv_flogi); | ||
| 1275 | |||
| 29 | /** | 1276 | /** |
| 30 | * fcoe_wwn_from_mac() - Converts 48-bit IEEE MAC address to 64-bit FC WWN. | 1277 | * fcoe_wwn_from_mac() - Converts 48-bit IEEE MAC address to 64-bit FC WWN. |
| 31 | * @mac: mac address | 1278 | * @mac: mac address |
diff --git a/include/scsi/libfcoe.h b/include/scsi/libfcoe.h index d07ebe688403..666cc131732e 100644 --- a/include/scsi/libfcoe.h +++ b/include/scsi/libfcoe.h | |||
| @@ -1,5 +1,6 @@ | |||
| 1 | /* | 1 | /* |
| 2 | * Copyright(c) 2007 - 2008 Intel Corporation. All rights reserved. | 2 | * Copyright (c) 2008-2009 Cisco Systems, Inc. All rights reserved. |
| 3 | * Copyright (c) 2007-2008 Intel Corporation. All rights reserved. | ||
| 3 | * | 4 | * |
| 4 | * This program is free software; you can redistribute it and/or modify it | 5 | * 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 | * under the terms and conditions of the GNU General Public License, |
| @@ -20,11 +21,142 @@ | |||
| 20 | #ifndef _LIBFCOE_H | 21 | #ifndef _LIBFCOE_H |
| 21 | #define _LIBFCOE_H | 22 | #define _LIBFCOE_H |
| 22 | 23 | ||
| 24 | #include <linux/etherdevice.h> | ||
| 25 | #include <linux/if_ether.h> | ||
| 23 | #include <linux/netdevice.h> | 26 | #include <linux/netdevice.h> |
| 24 | #include <linux/skbuff.h> | 27 | #include <linux/skbuff.h> |
| 28 | #include <linux/workqueue.h> | ||
| 25 | #include <scsi/fc/fc_fcoe.h> | 29 | #include <scsi/fc/fc_fcoe.h> |
| 26 | #include <scsi/libfc.h> | 30 | #include <scsi/libfc.h> |
| 27 | 31 | ||
| 32 | /* | ||
| 33 | * FIP tunable parameters. | ||
| 34 | */ | ||
| 35 | #define FCOE_CTLR_START_DELAY 2000 /* mS after first adv. to choose FCF */ | ||
| 36 | #define FCOE_CTRL_SOL_TOV 2000 /* min. solicitation interval (mS) */ | ||
| 37 | #define FCOE_CTLR_FCF_LIMIT 20 /* max. number of FCF entries */ | ||
| 38 | |||
| 39 | /** | ||
| 40 | * enum fip_state - internal state of FCoE controller. | ||
| 41 | * @FIP_ST_DISABLED: controller has been disabled or not yet enabled. | ||
| 42 | * @FIP_ST_LINK_WAIT: the physical link is down or unusable. | ||
| 43 | * @FIP_ST_AUTO: determining whether to use FIP or non-FIP mode. | ||
| 44 | * @FIP_ST_NON_FIP: non-FIP mode selected. | ||
| 45 | * @FIP_ST_ENABLED: FIP mode selected. | ||
| 46 | */ | ||
| 47 | enum fip_state { | ||
| 48 | FIP_ST_DISABLED, | ||
| 49 | FIP_ST_LINK_WAIT, | ||
| 50 | FIP_ST_AUTO, | ||
| 51 | FIP_ST_NON_FIP, | ||
| 52 | FIP_ST_ENABLED, | ||
| 53 | }; | ||
| 54 | |||
| 55 | /** | ||
| 56 | * struct fcoe_ctlr - FCoE Controller and FIP state. | ||
| 57 | * @state: internal FIP state for network link and FIP or non-FIP mode. | ||
| 58 | * @lp: &fc_lport: libfc local port. | ||
| 59 | * @sel_fcf: currently selected FCF, or NULL. | ||
| 60 | * @fcfs: list of discovered FCFs. | ||
| 61 | * @fcf_count: number of discovered FCF entries. | ||
| 62 | * @sol_time: time when a multicast solicitation was last sent. | ||
| 63 | * @sel_time: time after which to select an FCF. | ||
| 64 | * @port_ka_time: time of next port keep-alive. | ||
| 65 | * @ctlr_ka_time: time of next controller keep-alive. | ||
| 66 | * @timer: timer struct used for all delayed events. | ||
| 67 | * @link_work: &work_struct for doing FCF selection. | ||
| 68 | * @recv_work: &work_struct for receiving FIP frames. | ||
| 69 | * @fip_recv_list: list of received FIP frames. | ||
| 70 | * @user_mfs: configured maximum FC frame size, including FC header. | ||
| 71 | * @flogi_oxid: exchange ID of most recent fabric login. | ||
| 72 | * @flogi_count: number of FLOGI attempts in AUTO mode. | ||
| 73 | * @link: current link status for libfc. | ||
| 74 | * @last_link: last link state reported to libfc. | ||
| 75 | * @map_dest: use the FC_MAP mode for destination MAC addresses. | ||
| 76 | * @dest_addr: MAC address of the selected FC forwarder. | ||
| 77 | * @ctl_src_addr: the native MAC address of our local port. | ||
| 78 | * @data_src_addr: the assigned MAC address for the local port after FLOGI. | ||
| 79 | * @send: LLD-supplied function to handle sending of FIP Ethernet frames. | ||
| 80 | * @update_mac: LLD-supplied function to handle changes to MAC addresses. | ||
| 81 | * @lock: lock protecting this structure. | ||
| 82 | * | ||
| 83 | * This structure is used by all FCoE drivers. It contains information | ||
| 84 | * needed by all FCoE low-level drivers (LLDs) as well as internal state | ||
| 85 | * for FIP, and fields shared with the LLDS. | ||
| 86 | */ | ||
| 87 | struct fcoe_ctlr { | ||
| 88 | enum fip_state state; | ||
| 89 | struct fc_lport *lp; | ||
| 90 | struct fcoe_fcf *sel_fcf; | ||
| 91 | struct list_head fcfs; | ||
| 92 | u16 fcf_count; | ||
| 93 | unsigned long sol_time; | ||
| 94 | unsigned long sel_time; | ||
| 95 | unsigned long port_ka_time; | ||
| 96 | unsigned long ctlr_ka_time; | ||
| 97 | struct timer_list timer; | ||
| 98 | struct work_struct link_work; | ||
| 99 | struct work_struct recv_work; | ||
| 100 | struct sk_buff_head fip_recv_list; | ||
| 101 | u16 user_mfs; | ||
| 102 | u16 flogi_oxid; | ||
| 103 | u8 flogi_count; | ||
| 104 | u8 link; | ||
| 105 | u8 last_link; | ||
| 106 | u8 map_dest; | ||
| 107 | u8 dest_addr[ETH_ALEN]; | ||
| 108 | u8 ctl_src_addr[ETH_ALEN]; | ||
| 109 | u8 data_src_addr[ETH_ALEN]; | ||
| 110 | |||
| 111 | void (*send)(struct fcoe_ctlr *, struct sk_buff *); | ||
| 112 | void (*update_mac)(struct fcoe_ctlr *, u8 *old, u8 *new); | ||
| 113 | spinlock_t lock; | ||
| 114 | }; | ||
| 115 | |||
| 116 | /* | ||
| 117 | * struct fcoe_fcf - Fibre-Channel Forwarder. | ||
| 118 | * @list: list linkage. | ||
| 119 | * @time: system time (jiffies) when an advertisement was last received. | ||
| 120 | * @switch_name: WWN of switch from advertisement. | ||
| 121 | * @fabric_name: WWN of fabric from advertisement. | ||
| 122 | * @fc_map: FC_MAP value from advertisement. | ||
| 123 | * @fcf_mac: Ethernet address of the FCF. | ||
| 124 | * @vfid: virtual fabric ID. | ||
| 125 | * @pri: seletion priority, smaller values are better. | ||
| 126 | * @flags: flags received from advertisement. | ||
| 127 | * @fka_period: keep-alive period, in jiffies. | ||
| 128 | * | ||
| 129 | * A Fibre-Channel Forwarder (FCF) is the entity on the Ethernet that | ||
| 130 | * passes FCoE frames on to an FC fabric. This structure represents | ||
| 131 | * one FCF from which advertisements have been received. | ||
| 132 | * | ||
| 133 | * When looking up an FCF, @switch_name, @fabric_name, @fc_map, @vfid, and | ||
| 134 | * @fcf_mac together form the lookup key. | ||
| 135 | */ | ||
| 136 | struct fcoe_fcf { | ||
| 137 | struct list_head list; | ||
| 138 | unsigned long time; | ||
| 139 | |||
| 140 | u64 switch_name; | ||
| 141 | u64 fabric_name; | ||
| 142 | u32 fc_map; | ||
| 143 | u16 vfid; | ||
| 144 | u8 fcf_mac[ETH_ALEN]; | ||
| 145 | |||
| 146 | u8 pri; | ||
| 147 | u16 flags; | ||
| 148 | u32 fka_period; | ||
| 149 | }; | ||
| 150 | |||
| 151 | /* FIP API functions */ | ||
| 152 | void fcoe_ctlr_init(struct fcoe_ctlr *); | ||
| 153 | void fcoe_ctlr_destroy(struct fcoe_ctlr *); | ||
| 154 | void fcoe_ctlr_link_up(struct fcoe_ctlr *); | ||
| 155 | int fcoe_ctlr_link_down(struct fcoe_ctlr *); | ||
| 156 | int fcoe_ctlr_els_send(struct fcoe_ctlr *, struct sk_buff *); | ||
| 157 | void fcoe_ctlr_recv(struct fcoe_ctlr *, struct sk_buff *); | ||
| 158 | int fcoe_ctlr_recv_flogi(struct fcoe_ctlr *, struct fc_frame *fp, u8 *sa); | ||
| 159 | |||
| 28 | /* libfcoe funcs */ | 160 | /* libfcoe funcs */ |
| 29 | u64 fcoe_wwn_from_mac(unsigned char mac[], unsigned int, unsigned int); | 161 | u64 fcoe_wwn_from_mac(unsigned char mac[], unsigned int, unsigned int); |
| 30 | int fcoe_libfc_config(struct fc_lport *, struct libfc_function_template *); | 162 | int fcoe_libfc_config(struct fc_lport *, struct libfc_function_template *); |
