git.oblomov.eu Git - linux-2.6/blob - drivers/infiniband/hw/nes/nes_hw.c

   1 /*
   2  * Copyright (c) 2006 - 2008 NetEffect, Inc. All rights reserved.
   3  *
   4  * This software is available to you under a choice of one of two
   5  * licenses.  You may choose to be licensed under the terms of the GNU
   6  * General Public License (GPL) Version 2, available from the file
   7  * COPYING in the main directory of this source tree, or the
   8  * OpenIB.org BSD license below:
   9  *
  10  *     Redistribution and use in source and binary forms, with or
  11  *     without modification, are permitted provided that the following
  12  *     conditions are met:
  13  *
  14  *      - Redistributions of source code must retain the above
  15  *        copyright notice, this list of conditions and the following
  16  *        disclaimer.
  17  *
  18  *      - Redistributions in binary form must reproduce the above
  19  *        copyright notice, this list of conditions and the following
  20  *        disclaimer in the documentation and/or other materials
  21  *        provided with the distribution.
  22  *
  23  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  24  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  25  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  26  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
  27  * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
  28  * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  29  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  30  * SOFTWARE.
  31  *
  32  */
  33
  34 #include <linux/module.h>
  35 #include <linux/moduleparam.h>
  36 #include <linux/netdevice.h>
  37 #include <linux/etherdevice.h>
  38 #include <linux/ip.h>
  39 #include <linux/tcp.h>
  40 #include <linux/if_vlan.h>
  41
  42 #include "nes.h"
  43
  44 u32 crit_err_count = 0;
  45 u32 int_mod_timer_init;
  46 u32 int_mod_cq_depth_256;
  47 u32 int_mod_cq_depth_128;
  48 u32 int_mod_cq_depth_32;
  49 u32 int_mod_cq_depth_24;
  50 u32 int_mod_cq_depth_16;
  51 u32 int_mod_cq_depth_4;
  52 u32 int_mod_cq_depth_1;
  53
  54 #include "nes_cm.h"
  55
  56
  57 #ifdef CONFIG_INFINIBAND_NES_DEBUG
  58 static unsigned char *nes_iwarp_state_str[] = {
  59         "Non-Existant",
  60         "Idle",
  61         "RTS",
  62         "Closing",
  63         "RSVD1",
  64         "Terminate",
  65         "Error",
  66         "RSVD2",
  67 };
  68
  69 static unsigned char *nes_tcp_state_str[] = {
  70         "Non-Existant",
  71         "Closed",
  72         "Listen",
  73         "SYN Sent",
  74         "SYN Rcvd",
  75         "Established",
  76         "Close Wait",
  77         "FIN Wait 1",
  78         "Closing",
  79         "Last Ack",
  80         "FIN Wait 2",
  81         "Time Wait",
  82         "RSVD1",
  83         "RSVD2",
  84         "RSVD3",
  85         "RSVD4",
  86 };
  87 #endif
  88
  89
  90 /**
  91  * nes_nic_init_timer_defaults
  92  */
  93 void  nes_nic_init_timer_defaults(struct nes_device *nesdev, u8 jumbomode)
  94 {
  95         unsigned long flags;
  96         struct nes_adapter *nesadapter = nesdev->nesadapter;
  97         struct nes_hw_tune_timer *shared_timer = &nesadapter->tune_timer;
  98
  99         spin_lock_irqsave(&nesadapter->periodic_timer_lock, flags);
 100
 101         shared_timer->timer_in_use_min = NES_NIC_FAST_TIMER_LOW;
 102         shared_timer->timer_in_use_max = NES_NIC_FAST_TIMER_HIGH;
 103         if (jumbomode) {
 104                 shared_timer->threshold_low    = DEFAULT_JUMBO_NES_QL_LOW;
 105                 shared_timer->threshold_target = DEFAULT_JUMBO_NES_QL_TARGET;
 106                 shared_timer->threshold_high   = DEFAULT_JUMBO_NES_QL_HIGH;
 107         } else {
 108                 shared_timer->threshold_low    = DEFAULT_NES_QL_LOW;
 109                 shared_timer->threshold_target = DEFAULT_NES_QL_TARGET;
 110                 shared_timer->threshold_high   = DEFAULT_NES_QL_HIGH;
 111         }
 112
 113         /* todo use netdev->mtu to set thresholds */
 114         spin_unlock_irqrestore(&nesadapter->periodic_timer_lock, flags);
 115 }
 116
 117
 118 /**
 119  * nes_nic_init_timer
 120  */
 121 static void  nes_nic_init_timer(struct nes_device *nesdev)
 122 {
 123         unsigned long flags;
 124         struct nes_adapter *nesadapter = nesdev->nesadapter;
 125         struct nes_hw_tune_timer *shared_timer = &nesadapter->tune_timer;
 126
 127         spin_lock_irqsave(&nesadapter->periodic_timer_lock, flags);
 128
 129         if (shared_timer->timer_in_use_old == 0) {
 130                 nesdev->deepcq_count = 0;
 131                 shared_timer->timer_direction_upward = 0;
 132                 shared_timer->timer_direction_downward = 0;
 133                 shared_timer->timer_in_use = NES_NIC_FAST_TIMER;
 134                 shared_timer->timer_in_use_old = 0;
 135
 136         }
 137         if (shared_timer->timer_in_use != shared_timer->timer_in_use_old) {
 138                 shared_timer->timer_in_use_old = shared_timer->timer_in_use;
 139                 nes_write32(nesdev->regs+NES_PERIODIC_CONTROL,
 140                         0x80000000 | ((u32)(shared_timer->timer_in_use*8)));
 141         }
 142         /* todo use netdev->mtu to set thresholds */
 143         spin_unlock_irqrestore(&nesadapter->periodic_timer_lock, flags);
 144 }
 145
 146
 147 /**
 148  * nes_nic_tune_timer
 149  */
 150 static void nes_nic_tune_timer(struct nes_device *nesdev)
 151 {
 152         unsigned long flags;
 153         struct nes_adapter *nesadapter = nesdev->nesadapter;
 154         struct nes_hw_tune_timer *shared_timer = &nesadapter->tune_timer;
 155         u16 cq_count = nesdev->currcq_count;
 156
 157         spin_lock_irqsave(&nesadapter->periodic_timer_lock, flags);
 158
 159         if (shared_timer->cq_count_old < cq_count) {
 160                 if (cq_count > shared_timer->threshold_low)
 161                         shared_timer->cq_direction_downward=0;
 162         }
 163         if (shared_timer->cq_count_old >= cq_count)
 164                 shared_timer->cq_direction_downward++;
 165         shared_timer->cq_count_old = cq_count;
 166         if (shared_timer->cq_direction_downward > NES_NIC_CQ_DOWNWARD_TREND) {
 167                 if (cq_count <= shared_timer->threshold_low) {
 168                         shared_timer->threshold_low = shared_timer->threshold_low/2;
 169                         shared_timer->cq_direction_downward=0;
 170                         nesdev->currcq_count = 0;
 171                         spin_unlock_irqrestore(&nesadapter->periodic_timer_lock, flags);
 172                         return;
 173                 }
 174         }
 175
 176         if (cq_count > 1) {
 177                 nesdev->deepcq_count += cq_count;
 178                 if (cq_count <= shared_timer->threshold_low) {       /* increase timer gently */
 179                         shared_timer->timer_direction_upward++;
 180                         shared_timer->timer_direction_downward = 0;
 181                 } else if (cq_count <= shared_timer->threshold_target) { /* balanced */
 182                         shared_timer->timer_direction_upward = 0;
 183                         shared_timer->timer_direction_downward = 0;
 184                 } else if (cq_count <= shared_timer->threshold_high) {  /* decrease timer gently */
 185                         shared_timer->timer_direction_downward++;
 186                         shared_timer->timer_direction_upward = 0;
 187                 } else if (cq_count <= (shared_timer->threshold_high) * 2) {
 188                         shared_timer->timer_in_use -= 2;
 189                         shared_timer->timer_direction_upward = 0;
 190                         shared_timer->timer_direction_downward++;
 191                 } else {
 192                         shared_timer->timer_in_use -= 4;
 193                         shared_timer->timer_direction_upward = 0;
 194                         shared_timer->timer_direction_downward++;
 195                 }
 196
 197                 if (shared_timer->timer_direction_upward > 3 ) {  /* using history */
 198                         shared_timer->timer_in_use += 3;
 199                         shared_timer->timer_direction_upward = 0;
 200                         shared_timer->timer_direction_downward = 0;
 201                 }
 202                 if (shared_timer->timer_direction_downward > 5) { /* using history */
 203                         shared_timer->timer_in_use -= 4 ;
 204                         shared_timer->timer_direction_downward = 0;
 205                         shared_timer->timer_direction_upward = 0;
 206                 }
 207         }
 208
 209         /* boundary checking */
 210         if (shared_timer->timer_in_use > NES_NIC_FAST_TIMER_HIGH)
 211                 shared_timer->timer_in_use = NES_NIC_FAST_TIMER_HIGH;
 212         else if (shared_timer->timer_in_use < NES_NIC_FAST_TIMER_LOW) {
 213                 shared_timer->timer_in_use = NES_NIC_FAST_TIMER_LOW;
 214         }
 215
 216         nesdev->currcq_count = 0;
 217
 218         spin_unlock_irqrestore(&nesadapter->periodic_timer_lock, flags);
 219 }
 220
 221
 222 /**
 223  * nes_init_adapter - initialize adapter
 224  */
 225 struct nes_adapter *nes_init_adapter(struct nes_device *nesdev, u8 hw_rev) {
 226         struct nes_adapter *nesadapter = NULL;
 227         unsigned long num_pds;
 228         u32 u32temp;
 229         u32 port_count;
 230         u16 max_rq_wrs;
 231         u16 max_sq_wrs;
 232         u32 max_mr;
 233         u32 max_256pbl;
 234         u32 max_4kpbl;
 235         u32 max_qp;
 236         u32 max_irrq;
 237         u32 max_cq;
 238         u32 hte_index_mask;
 239         u32 adapter_size;
 240         u32 arp_table_size;
 241         u16 vendor_id;
 242         u8  OneG_Mode;
 243         u8  func_index;
 244
 245         /* search the list of existing adapters */
 246         list_for_each_entry(nesadapter, &nes_adapter_list, list) {
 247                 nes_debug(NES_DBG_INIT, "Searching Adapter list for PCI devfn = 0x%X,"
 248                                 " adapter PCI slot/bus = %u/%u, pci devices PCI slot/bus = %u/%u, .\n",
 249                                 nesdev->pcidev->devfn,
 250                                 PCI_SLOT(nesadapter->devfn),
 251                                 nesadapter->bus_number,
 252                                 PCI_SLOT(nesdev->pcidev->devfn),
 253                                 nesdev->pcidev->bus->number );
 254                 if ((PCI_SLOT(nesadapter->devfn) == PCI_SLOT(nesdev->pcidev->devfn)) &&
 255                                 (nesadapter->bus_number == nesdev->pcidev->bus->number)) {
 256                         nesadapter->ref_count++;
 257                         return nesadapter;
 258                 }
 259         }
 260
 261         /* no adapter found */
 262         num_pds = pci_resource_len(nesdev->pcidev, BAR_1) >> PAGE_SHIFT;
 263         if ((hw_rev != NE020_REV) && (hw_rev != NE020_REV1)) {
 264                 nes_debug(NES_DBG_INIT, "NE020 driver detected unknown hardware revision 0x%x\n",
 265                                 hw_rev);
 266                 return NULL;
 267         }
 268
 269         nes_debug(NES_DBG_INIT, "Determine Soft Reset, QP_control=0x%x, CPU0=0x%x, CPU1=0x%x, CPU2=0x%x\n",
 270                         nes_read_indexed(nesdev, NES_IDX_QP_CONTROL + PCI_FUNC(nesdev->pcidev->devfn) * 8),
 271                         nes_read_indexed(nesdev, NES_IDX_INT_CPU_STATUS),
 272                         nes_read_indexed(nesdev, NES_IDX_INT_CPU_STATUS + 4),
 273                         nes_read_indexed(nesdev, NES_IDX_INT_CPU_STATUS + 8));
 274
 275         nes_debug(NES_DBG_INIT, "Reset and init NE020\n");
 276
 277
 278         if ((port_count = nes_reset_adapter_ne020(nesdev, &OneG_Mode)) == 0)
 279                 return NULL;
 280         if (nes_init_serdes(nesdev, hw_rev, port_count, OneG_Mode))
 281                 return NULL;
 282         nes_init_csr_ne020(nesdev, hw_rev, port_count);
 283
 284         max_qp = nes_read_indexed(nesdev, NES_IDX_QP_CTX_SIZE);
 285         nes_debug(NES_DBG_INIT, "QP_CTX_SIZE=%u\n", max_qp);
 286
 287         u32temp = nes_read_indexed(nesdev, NES_IDX_QUAD_HASH_TABLE_SIZE);
 288         if (max_qp > ((u32)1 << (u32temp & 0x001f))) {
 289                 nes_debug(NES_DBG_INIT, "Reducing Max QPs to %u due to hash table size = 0x%08X\n",
 290                                 max_qp, u32temp);
 291                 max_qp = (u32)1 << (u32temp & 0x001f);
 292         }
 293
 294         hte_index_mask = ((u32)1 << ((u32temp & 0x001f)+1))-1;
 295         nes_debug(NES_DBG_INIT, "Max QP = %u, hte_index_mask = 0x%08X.\n",
 296                         max_qp, hte_index_mask);
 297
 298         u32temp = nes_read_indexed(nesdev, NES_IDX_IRRQ_COUNT);
 299
 300         max_irrq = 1 << (u32temp & 0x001f);
 301
 302         if (max_qp > max_irrq) {
 303                 max_qp = max_irrq;
 304                 nes_debug(NES_DBG_INIT, "Reducing Max QPs to %u due to Available Q1s.\n",
 305                                 max_qp);
 306         }
 307
 308         /* there should be no reason to allocate more pds than qps */
 309         if (num_pds > max_qp)
 310                 num_pds = max_qp;
 311
 312         u32temp = nes_read_indexed(nesdev, NES_IDX_MRT_SIZE);
 313         max_mr = (u32)8192 << (u32temp & 0x7);
 314
 315         u32temp = nes_read_indexed(nesdev, NES_IDX_PBL_REGION_SIZE);
 316         max_256pbl = (u32)1 << (u32temp & 0x0000001f);
 317         max_4kpbl = (u32)1 << ((u32temp >> 16) & 0x0000001f);
 318         max_cq = nes_read_indexed(nesdev, NES_IDX_CQ_CTX_SIZE);
 319
 320         u32temp = nes_read_indexed(nesdev, NES_IDX_ARP_CACHE_SIZE);
 321         arp_table_size = 1 << u32temp;
 322
 323         adapter_size = (sizeof(struct nes_adapter) +
 324                         (sizeof(unsigned long)-1)) & (~(sizeof(unsigned long)-1));
 325         adapter_size += sizeof(unsigned long) * BITS_TO_LONGS(max_qp);
 326         adapter_size += sizeof(unsigned long) * BITS_TO_LONGS(max_mr);
 327         adapter_size += sizeof(unsigned long) * BITS_TO_LONGS(max_cq);
 328         adapter_size += sizeof(unsigned long) * BITS_TO_LONGS(num_pds);
 329         adapter_size += sizeof(unsigned long) * BITS_TO_LONGS(arp_table_size);
 330         adapter_size += sizeof(struct nes_qp **) * max_qp;
 331
 332         /* allocate a new adapter struct */
 333         nesadapter = kzalloc(adapter_size, GFP_KERNEL);
 334         if (nesadapter == NULL) {
 335                 return NULL;
 336         }
 337
 338         nes_debug(NES_DBG_INIT, "Allocating new nesadapter @ %p, size = %u (actual size = %u).\n",
 339                         nesadapter, (u32)sizeof(struct nes_adapter), adapter_size);
 340
 341         /* populate the new nesadapter */
 342         nesadapter->devfn = nesdev->pcidev->devfn;
 343         nesadapter->bus_number = nesdev->pcidev->bus->number;
 344         nesadapter->ref_count = 1;
 345         nesadapter->timer_int_req = 0xffff0000;
 346         nesadapter->OneG_Mode = OneG_Mode;
 347         nesadapter->doorbell_start = nesdev->doorbell_region;
 348
 349         /* nesadapter->tick_delta = clk_divisor; */
 350         nesadapter->hw_rev = hw_rev;
 351         nesadapter->port_count = port_count;
 352
 353         nesadapter->max_qp = max_qp;
 354         nesadapter->hte_index_mask = hte_index_mask;
 355         nesadapter->max_irrq = max_irrq;
 356         nesadapter->max_mr = max_mr;
 357         nesadapter->max_256pbl = max_256pbl - 1;
 358         nesadapter->max_4kpbl = max_4kpbl - 1;
 359         nesadapter->max_cq = max_cq;
 360         nesadapter->free_256pbl = max_256pbl - 1;
 361         nesadapter->free_4kpbl = max_4kpbl - 1;
 362         nesadapter->max_pd = num_pds;
 363         nesadapter->arp_table_size = arp_table_size;
 364
 365         nesadapter->et_pkt_rate_low = NES_TIMER_ENABLE_LIMIT;
 366         if (nes_drv_opt & NES_DRV_OPT_DISABLE_INT_MOD) {
 367                 nesadapter->et_use_adaptive_rx_coalesce = 0;
 368                 nesadapter->timer_int_limit = NES_TIMER_INT_LIMIT;
 369                 nesadapter->et_rx_coalesce_usecs_irq = interrupt_mod_interval;
 370         } else {
 371                 nesadapter->et_use_adaptive_rx_coalesce = 1;
 372                 nesadapter->timer_int_limit = NES_TIMER_INT_LIMIT_DYNAMIC;
 373                 nesadapter->et_rx_coalesce_usecs_irq = 0;
 374                 printk(PFX "%s: Using Adaptive Interrupt Moderation\n", __FUNCTION__);
 375         }
 376         /* Setup and enable the periodic timer */
 377         if (nesadapter->et_rx_coalesce_usecs_irq)
 378                 nes_write32(nesdev->regs+NES_PERIODIC_CONTROL, 0x80000000 |
 379                                 ((u32)(nesadapter->et_rx_coalesce_usecs_irq * 8)));
 380         else
 381                 nes_write32(nesdev->regs+NES_PERIODIC_CONTROL, 0x00000000);
 382
 383         nesadapter->base_pd = 1;
 384
 385         nesadapter->device_cap_flags =
 386                         IB_DEVICE_ZERO_STAG | IB_DEVICE_SEND_W_INV | IB_DEVICE_MEM_WINDOW;
 387
 388         nesadapter->allocated_qps = (unsigned long *)&(((unsigned char *)nesadapter)
 389                         [(sizeof(struct nes_adapter)+(sizeof(unsigned long)-1))&(~(sizeof(unsigned long)-1))]);
 390         nesadapter->allocated_cqs = &nesadapter->allocated_qps[BITS_TO_LONGS(max_qp)];
 391         nesadapter->allocated_mrs = &nesadapter->allocated_cqs[BITS_TO_LONGS(max_cq)];
 392         nesadapter->allocated_pds = &nesadapter->allocated_mrs[BITS_TO_LONGS(max_mr)];
 393         nesadapter->allocated_arps = &nesadapter->allocated_pds[BITS_TO_LONGS(num_pds)];
 394         nesadapter->qp_table = (struct nes_qp **)(&nesadapter->allocated_arps[BITS_TO_LONGS(arp_table_size)]);
 395
 396
 397         /* mark the usual suspect QPs and CQs as in use */
 398         for (u32temp = 0; u32temp < NES_FIRST_QPN; u32temp++) {
 399                 set_bit(u32temp, nesadapter->allocated_qps);
 400                 set_bit(u32temp, nesadapter->allocated_cqs);
 401         }
 402
 403         for (u32temp = 0; u32temp < 20; u32temp++)
 404                 set_bit(u32temp, nesadapter->allocated_pds);
 405         u32temp = nes_read_indexed(nesdev, NES_IDX_QP_MAX_CFG_SIZES);
 406
 407         max_rq_wrs = ((u32temp >> 8) & 3);
 408         switch (max_rq_wrs) {
 409                 case 0:
 410                         max_rq_wrs = 4;
 411                         break;
 412                 case 1:
 413                         max_rq_wrs = 16;
 414                         break;
 415                 case 2:
 416                         max_rq_wrs = 32;
 417                         break;
 418                 case 3:
 419                         max_rq_wrs = 512;
 420                         break;
 421         }
 422
 423         max_sq_wrs = (u32temp & 3);
 424         switch (max_sq_wrs) {
 425                 case 0:
 426                         max_sq_wrs = 4;
 427                         break;
 428                 case 1:
 429                         max_sq_wrs = 16;
 430                         break;
 431                 case 2:
 432                         max_sq_wrs = 32;
 433                         break;
 434                 case 3:
 435                         max_sq_wrs = 512;
 436                         break;
 437         }
 438         nesadapter->max_qp_wr = min(max_rq_wrs, max_sq_wrs);
 439         nesadapter->max_irrq_wr = (u32temp >> 16) & 3;
 440
 441         nesadapter->max_sge = 4;
 442         nesadapter->max_cqe = 32767;
 443
 444         if (nes_read_eeprom_values(nesdev, nesadapter)) {
 445                 printk(KERN_ERR PFX "Unable to read EEPROM data.\n");
 446                 kfree(nesadapter);
 447                 return NULL;
 448         }
 449
 450         u32temp = nes_read_indexed(nesdev, NES_IDX_TCP_TIMER_CONFIG);
 451         nes_write_indexed(nesdev, NES_IDX_TCP_TIMER_CONFIG,
 452                         (u32temp & 0xff000000) | (nesadapter->tcp_timer_core_clk_divisor & 0x00ffffff));
 453
 454         /* setup port configuration */
 455         if (nesadapter->port_count == 1) {
 456                 u32temp = 0x00000000;
 457                 if (nes_drv_opt & NES_DRV_OPT_DUAL_LOGICAL_PORT)
 458                         nes_write_indexed(nesdev, NES_IDX_TX_POOL_SIZE, 0x00000002);
 459                 else
 460                         nes_write_indexed(nesdev, NES_IDX_TX_POOL_SIZE, 0x00000003);
 461         } else {
 462                 if (nesadapter->port_count == 2)
 463                         u32temp = 0x00000044;
 464                 else
 465                         u32temp = 0x000000e4;
 466                 nes_write_indexed(nesdev, NES_IDX_TX_POOL_SIZE, 0x00000003);
 467         }
 468
 469         nes_write_indexed(nesdev, NES_IDX_NIC_LOGPORT_TO_PHYPORT, u32temp);
 470         nes_debug(NES_DBG_INIT, "Probe time, LOG2PHY=%u\n",
 471                         nes_read_indexed(nesdev, NES_IDX_NIC_LOGPORT_TO_PHYPORT));
 472
 473         spin_lock_init(&nesadapter->resource_lock);
 474         spin_lock_init(&nesadapter->phy_lock);
 475         spin_lock_init(&nesadapter->pbl_lock);
 476         spin_lock_init(&nesadapter->periodic_timer_lock);
 477
 478         INIT_LIST_HEAD(&nesadapter->nesvnic_list[0]);
 479         INIT_LIST_HEAD(&nesadapter->nesvnic_list[1]);
 480         INIT_LIST_HEAD(&nesadapter->nesvnic_list[2]);
 481         INIT_LIST_HEAD(&nesadapter->nesvnic_list[3]);
 482
 483         if ((!nesadapter->OneG_Mode) && (nesadapter->port_count == 2)) {
 484                 u32 pcs_control_status0, pcs_control_status1;
 485                 u32 reset_value;
 486                 u32 i = 0;
 487                 u32 int_cnt = 0;
 488                 u32 ext_cnt = 0;
 489                 unsigned long flags;
 490                 u32 j = 0;
 491
 492                 pcs_control_status0 = nes_read_indexed(nesdev,
 493                         NES_IDX_PHY_PCS_CONTROL_STATUS0);
 494                 pcs_control_status1 = nes_read_indexed(nesdev,
 495                         NES_IDX_PHY_PCS_CONTROL_STATUS0 + 0x200);
 496
 497                 for (i = 0; i < NES_MAX_LINK_CHECK; i++) {
 498                         pcs_control_status0 = nes_read_indexed(nesdev,
 499                                         NES_IDX_PHY_PCS_CONTROL_STATUS0);
 500                         pcs_control_status1 = nes_read_indexed(nesdev,
 501                                         NES_IDX_PHY_PCS_CONTROL_STATUS0 + 0x200);
 502                         if ((0x0F000100 == (pcs_control_status0 & 0x0F000100))
 503                             || (0x0F000100 == (pcs_control_status1 & 0x0F000100)))
 504                                 int_cnt++;
 505                         msleep(1);
 506                 }
 507                 if (int_cnt > 1) {
 508                         spin_lock_irqsave(&nesadapter->phy_lock, flags);
 509                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_CONTROL1, 0x0000F088);
 510                         mh_detected++;
 511                         reset_value = nes_read32(nesdev->regs+NES_SOFTWARE_RESET);
 512                         reset_value |= 0x0000003d;
 513                         nes_write32(nesdev->regs+NES_SOFTWARE_RESET, reset_value);
 514
 515                         while (((nes_read32(nesdev->regs+NES_SOFTWARE_RESET)
 516                                 & 0x00000040) != 0x00000040) && (j++ < 5000));
 517                         spin_unlock_irqrestore(&nesadapter->phy_lock, flags);
 518
 519                         pcs_control_status0 = nes_read_indexed(nesdev,
 520                                         NES_IDX_PHY_PCS_CONTROL_STATUS0);
 521                         pcs_control_status1 = nes_read_indexed(nesdev,
 522                                         NES_IDX_PHY_PCS_CONTROL_STATUS0 + 0x200);
 523
 524                         for (i = 0; i < NES_MAX_LINK_CHECK; i++) {
 525                                 pcs_control_status0 = nes_read_indexed(nesdev,
 526                                         NES_IDX_PHY_PCS_CONTROL_STATUS0);
 527                                 pcs_control_status1 = nes_read_indexed(nesdev,
 528                                         NES_IDX_PHY_PCS_CONTROL_STATUS0 + 0x200);
 529                                 if ((0x0F000100 == (pcs_control_status0 & 0x0F000100))
 530                                         || (0x0F000100 == (pcs_control_status1 & 0x0F000100))) {
 531                                         if (++ext_cnt > int_cnt) {
 532                                                 spin_lock_irqsave(&nesadapter->phy_lock, flags);
 533                                                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_CONTROL1,
 534                                                                 0x0000F0C8);
 535                                                 mh_detected++;
 536                                                 reset_value = nes_read32(nesdev->regs+NES_SOFTWARE_RESET);
 537                                                 reset_value |= 0x0000003d;
 538                                                 nes_write32(nesdev->regs+NES_SOFTWARE_RESET, reset_value);
 539
 540                                                 while (((nes_read32(nesdev->regs+NES_SOFTWARE_RESET)
 541                                                         & 0x00000040) != 0x00000040) && (j++ < 5000));
 542                                                 spin_unlock_irqrestore(&nesadapter->phy_lock, flags);
 543                                                 break;
 544                                         }
 545                                 }
 546                                 msleep(1);
 547                         }
 548                 }
 549         }
 550
 551         if (nesadapter->hw_rev == NE020_REV) {
 552                 init_timer(&nesadapter->mh_timer);
 553                 nesadapter->mh_timer.function = nes_mh_fix;
 554                 nesadapter->mh_timer.expires = jiffies + (HZ/5);  /* 1 second */
 555                 nesadapter->mh_timer.data = (unsigned long)nesdev;
 556                 add_timer(&nesadapter->mh_timer);
 557         } else {
 558                 nes_write32(nesdev->regs+NES_INTF_INT_STAT, 0x0f000000);
 559         }
 560
 561         init_timer(&nesadapter->lc_timer);
 562         nesadapter->lc_timer.function = nes_clc;
 563         nesadapter->lc_timer.expires = jiffies + 3600 * HZ;  /* 1 hour */
 564         nesadapter->lc_timer.data = (unsigned long)nesdev;
 565         add_timer(&nesadapter->lc_timer);
 566
 567         list_add_tail(&nesadapter->list, &nes_adapter_list);
 568
 569         for (func_index = 0; func_index < 8; func_index++) {
 570                 pci_bus_read_config_word(nesdev->pcidev->bus,
 571                                         PCI_DEVFN(PCI_SLOT(nesdev->pcidev->devfn),
 572                                         func_index), 0, &vendor_id);
 573                 if (vendor_id == 0xffff)
 574                         break;
 575         }
 576         nes_debug(NES_DBG_INIT, "%s %d functions found for %s.\n", __FUNCTION__,
 577                 func_index, pci_name(nesdev->pcidev));
 578         nesadapter->adapter_fcn_count = func_index;
 579
 580         return nesadapter;
 581 }
 582
 583
 584 /**
 585  * nes_reset_adapter_ne020
 586  */
 587 unsigned int nes_reset_adapter_ne020(struct nes_device *nesdev, u8 *OneG_Mode)
 588 {
 589         u32 port_count;
 590         u32 u32temp;
 591         u32 i;
 592
 593         u32temp = nes_read32(nesdev->regs+NES_SOFTWARE_RESET);
 594         port_count = ((u32temp & 0x00000300) >> 8) + 1;
 595         /* TODO: assuming that both SERDES are set the same for now */
 596         *OneG_Mode = (u32temp & 0x00003c00) ? 0 : 1;
 597         nes_debug(NES_DBG_INIT, "Initial Software Reset = 0x%08X, port_count=%u\n",
 598                         u32temp, port_count);
 599         if (*OneG_Mode)
 600                 nes_debug(NES_DBG_INIT, "Running in 1G mode.\n");
 601         u32temp &= 0xff00ffc0;
 602         switch (port_count) {
 603                 case 1:
 604                         u32temp |= 0x00ee0000;
 605                         break;
 606                 case 2:
 607                         u32temp |= 0x00cc0000;
 608                         break;
 609                 case 4:
 610                         u32temp |= 0x00000000;
 611                         break;
 612                 default:
 613                         return 0;
 614                         break;
 615         }
 616
 617         /* check and do full reset if needed */
 618         if (nes_read_indexed(nesdev, NES_IDX_QP_CONTROL+(PCI_FUNC(nesdev->pcidev->devfn)*8))) {
 619                 nes_debug(NES_DBG_INIT, "Issuing Full Soft reset = 0x%08X\n", u32temp | 0xd);
 620                 nes_write32(nesdev->regs+NES_SOFTWARE_RESET, u32temp | 0xd);
 621
 622                 i = 0;
 623                 while (((nes_read32(nesdev->regs+NES_SOFTWARE_RESET) & 0x00000040) == 0) && i++ < 10000)
 624                         mdelay(1);
 625                 if (i >= 10000) {
 626                         nes_debug(NES_DBG_INIT, "Did not see full soft reset done.\n");
 627                         return 0;
 628                 }
 629         }
 630
 631         /* port reset */
 632         switch (port_count) {
 633                 case 1:
 634                         u32temp |= 0x00ee0010;
 635                         break;
 636                 case 2:
 637                         u32temp |= 0x00cc0030;
 638                         break;
 639                 case 4:
 640                         u32temp |= 0x00000030;
 641                         break;
 642         }
 643
 644         nes_debug(NES_DBG_INIT, "Issuing Port Soft reset = 0x%08X\n", u32temp | 0xd);
 645         nes_write32(nesdev->regs+NES_SOFTWARE_RESET, u32temp | 0xd);
 646
 647         i = 0;
 648         while (((nes_read32(nesdev->regs+NES_SOFTWARE_RESET) & 0x00000040) == 0) && i++ < 10000)
 649                 mdelay(1);
 650         if (i >= 10000) {
 651                 nes_debug(NES_DBG_INIT, "Did not see port soft reset done.\n");
 652                 return 0;
 653         }
 654
 655         /* serdes 0 */
 656         i = 0;
 657         while (((u32temp = (nes_read_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_STATUS0)
 658                         & 0x0000000f)) != 0x0000000f) && i++ < 5000)
 659                 mdelay(1);
 660         if (i >= 5000) {
 661                 nes_debug(NES_DBG_INIT, "Serdes 0 not ready, status=%x\n", u32temp);
 662                 return 0;
 663         }
 664
 665         /* serdes 1 */
 666         if (port_count > 1) {
 667                 i = 0;
 668                 while (((u32temp = (nes_read_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_STATUS1)
 669                                 & 0x0000000f)) != 0x0000000f) && i++ < 5000)
 670                         mdelay(1);
 671                 if (i >= 5000) {
 672                         nes_debug(NES_DBG_INIT, "Serdes 1 not ready, status=%x\n", u32temp);
 673                         return 0;
 674                 }
 675         }
 676
 677
 678
 679         i = 0;
 680         while ((nes_read_indexed(nesdev, NES_IDX_INT_CPU_STATUS) != 0x80) && i++ < 10000)
 681                 mdelay(1);
 682         if (i >= 10000) {
 683                 printk(KERN_ERR PFX "Internal CPU not ready, status = %02X\n",
 684                                 nes_read_indexed(nesdev, NES_IDX_INT_CPU_STATUS));
 685                 return 0;
 686         }
 687
 688         return port_count;
 689 }
 690
 691
 692 /**
 693  * nes_init_serdes
 694  */
 695 int nes_init_serdes(struct nes_device *nesdev, u8 hw_rev, u8 port_count, u8  OneG_Mode)
 696 {
 697         int i;
 698         u32 u32temp;
 699
 700         if (hw_rev != NE020_REV) {
 701                 /* init serdes 0 */
 702
 703                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_CDR_CONTROL0, 0x000000FF);
 704                 if (!OneG_Mode)
 705                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_TX_HIGHZ_LANE_MODE0, 0x11110000);
 706                 if (port_count > 1) {
 707                         /* init serdes 1 */
 708                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_CDR_CONTROL1, 0x000000FF);
 709                         if (!OneG_Mode)
 710                                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_TX_HIGHZ_LANE_MODE1, 0x11110000);
 711                         }
 712         } else {
 713                 /* init serdes 0 */
 714                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_CONTROL0, 0x00000008);
 715                 i = 0;
 716                 while (((u32temp = (nes_read_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_STATUS0)
 717                                 & 0x0000000f)) != 0x0000000f) && i++ < 5000)
 718                         mdelay(1);
 719                 if (i >= 5000) {
 720                         nes_debug(NES_DBG_PHY, "Init: serdes 0 not ready, status=%x\n", u32temp);
 721                         return 1;
 722                 }
 723                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_TX_EMP0, 0x000bdef7);
 724                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_TX_DRIVE0, 0x9ce73000);
 725                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_RX_MODE0, 0x0ff00000);
 726                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_RX_SIGDET0, 0x00000000);
 727                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_BYPASS0, 0x00000000);
 728                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_LOOPBACK_CONTROL0, 0x00000000);
 729                 if (OneG_Mode)
 730                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_RX_EQ_CONTROL0, 0xf0182222);
 731                 else
 732                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_RX_EQ_CONTROL0, 0xf0042222);
 733
 734                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_CDR_CONTROL0, 0x000000ff);
 735                 if (port_count > 1) {
 736                         /* init serdes 1 */
 737                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_CONTROL1, 0x00000048);
 738                         i = 0;
 739                         while (((u32temp = (nes_read_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_STATUS1)
 740                                 & 0x0000000f)) != 0x0000000f) && (i++ < 5000))
 741                                 mdelay(1);
 742                         if (i >= 5000) {
 743                                 printk("%s: Init: serdes 1 not ready, status=%x\n", __FUNCTION__, u32temp);
 744                                 /* return 1; */
 745                         }
 746                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_TX_EMP1, 0x000bdef7);
 747                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_TX_DRIVE1, 0x9ce73000);
 748                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_RX_MODE1, 0x0ff00000);
 749                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_RX_SIGDET1, 0x00000000);
 750                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_BYPASS1, 0x00000000);
 751                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_LOOPBACK_CONTROL1, 0x00000000);
 752                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_RX_EQ_CONTROL1, 0xf0002222);
 753                         nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_CDR_CONTROL1, 0x000000ff);
 754                 }
 755         }
 756         return 0;
 757 }
 758
 759
 760 /**
 761  * nes_init_csr_ne020
 762  * Initialize registers for ne020 hardware
 763  */
 764 void nes_init_csr_ne020(struct nes_device *nesdev, u8 hw_rev, u8 port_count)
 765 {
 766         u32 u32temp;
 767
 768         nes_debug(NES_DBG_INIT, "port_count=%d\n", port_count);
 769
 770         nes_write_indexed(nesdev, 0x000001E4, 0x00000007);
 771         /* nes_write_indexed(nesdev, 0x000001E8, 0x000208C4); */
 772         nes_write_indexed(nesdev, 0x000001E8, 0x00020874);
 773         nes_write_indexed(nesdev, 0x000001D8, 0x00048002);
 774         /* nes_write_indexed(nesdev, 0x000001D8, 0x0004B002); */
 775         nes_write_indexed(nesdev, 0x000001FC, 0x00050005);
 776         nes_write_indexed(nesdev, 0x00000600, 0x55555555);
 777         nes_write_indexed(nesdev, 0x00000604, 0x55555555);
 778
 779         /* TODO: move these MAC register settings to NIC bringup */
 780         nes_write_indexed(nesdev, 0x00002000, 0x00000001);
 781         nes_write_indexed(nesdev, 0x00002004, 0x00000001);
 782         nes_write_indexed(nesdev, 0x00002008, 0x0000FFFF);
 783         nes_write_indexed(nesdev, 0x0000200C, 0x00000001);
 784         nes_write_indexed(nesdev, 0x00002010, 0x000003c1);
 785         nes_write_indexed(nesdev, 0x0000201C, 0x75345678);
 786         if (port_count > 1) {
 787                 nes_write_indexed(nesdev, 0x00002200, 0x00000001);
 788                 nes_write_indexed(nesdev, 0x00002204, 0x00000001);
 789                 nes_write_indexed(nesdev, 0x00002208, 0x0000FFFF);
 790                 nes_write_indexed(nesdev, 0x0000220C, 0x00000001);
 791                 nes_write_indexed(nesdev, 0x00002210, 0x000003c1);
 792                 nes_write_indexed(nesdev, 0x0000221C, 0x75345678);
 793                 nes_write_indexed(nesdev, 0x00000908, 0x20000001);
 794         }
 795         if (port_count > 2) {
 796                 nes_write_indexed(nesdev, 0x00002400, 0x00000001);
 797                 nes_write_indexed(nesdev, 0x00002404, 0x00000001);
 798                 nes_write_indexed(nesdev, 0x00002408, 0x0000FFFF);
 799                 nes_write_indexed(nesdev, 0x0000240C, 0x00000001);
 800                 nes_write_indexed(nesdev, 0x00002410, 0x000003c1);
 801                 nes_write_indexed(nesdev, 0x0000241C, 0x75345678);
 802                 nes_write_indexed(nesdev, 0x00000910, 0x20000001);
 803
 804                 nes_write_indexed(nesdev, 0x00002600, 0x00000001);
 805                 nes_write_indexed(nesdev, 0x00002604, 0x00000001);
 806                 nes_write_indexed(nesdev, 0x00002608, 0x0000FFFF);
 807                 nes_write_indexed(nesdev, 0x0000260C, 0x00000001);
 808                 nes_write_indexed(nesdev, 0x00002610, 0x000003c1);
 809                 nes_write_indexed(nesdev, 0x0000261C, 0x75345678);
 810                 nes_write_indexed(nesdev, 0x00000918, 0x20000001);
 811         }
 812
 813         nes_write_indexed(nesdev, 0x00005000, 0x00018000);
 814         /* nes_write_indexed(nesdev, 0x00005000, 0x00010000); */
 815         nes_write_indexed(nesdev, 0x00005004, 0x00020001);
 816         nes_write_indexed(nesdev, 0x00005008, 0x1F1F1F1F);
 817         nes_write_indexed(nesdev, 0x00005010, 0x1F1F1F1F);
 818         nes_write_indexed(nesdev, 0x00005018, 0x1F1F1F1F);
 819         nes_write_indexed(nesdev, 0x00005020, 0x1F1F1F1F);
 820         nes_write_indexed(nesdev, 0x00006090, 0xFFFFFFFF);
 821
 822         /* TODO: move this to code, get from EEPROM */
 823         nes_write_indexed(nesdev, 0x00000900, 0x20000001);
 824         nes_write_indexed(nesdev, 0x000060C0, 0x0000028e);
 825         nes_write_indexed(nesdev, 0x000060C8, 0x00000020);
 826                                                                                                                 //
 827         nes_write_indexed(nesdev, 0x000001EC, 0x7b2625a0);
 828         /* nes_write_indexed(nesdev, 0x000001EC, 0x5f2625a0); */
 829
 830         if (hw_rev != NE020_REV) {
 831                 u32temp = nes_read_indexed(nesdev, 0x000008e8);
 832                 u32temp |= 0x80000000;
 833                 nes_write_indexed(nesdev, 0x000008e8, u32temp);
 834                 u32temp = nes_read_indexed(nesdev, 0x000021f8);
 835                 u32temp &= 0x7fffffff;
 836                 u32temp |= 0x7fff0010;
 837                 nes_write_indexed(nesdev, 0x000021f8, u32temp);
 838         }
 839 }
 840
 841
 842 /**
 843  * nes_destroy_adapter - destroy the adapter structure
 844  */
 845 void nes_destroy_adapter(struct nes_adapter *nesadapter)
 846 {
 847         struct nes_adapter *tmp_adapter;
 848
 849         list_for_each_entry(tmp_adapter, &nes_adapter_list, list) {
 850                 nes_debug(NES_DBG_SHUTDOWN, "Nes Adapter list entry = 0x%p.\n",
 851                                 tmp_adapter);
 852         }
 853
 854         nesadapter->ref_count--;
 855         if (!nesadapter->ref_count) {
 856                 if (nesadapter->hw_rev == NE020_REV) {
 857                         del_timer(&nesadapter->mh_timer);
 858                 }
 859                 del_timer(&nesadapter->lc_timer);
 860
 861                 list_del(&nesadapter->list);
 862                 kfree(nesadapter);
 863         }
 864 }
 865
 866
 867 /**
 868  * nes_init_cqp
 869  */
 870 int nes_init_cqp(struct nes_device *nesdev)
 871 {
 872         struct nes_adapter *nesadapter = nesdev->nesadapter;
 873         struct nes_hw_cqp_qp_context *cqp_qp_context;
 874         struct nes_hw_cqp_wqe *cqp_wqe;
 875         struct nes_hw_ceq *ceq;
 876         struct nes_hw_ceq *nic_ceq;
 877         struct nes_hw_aeq *aeq;
 878         void *vmem;
 879         dma_addr_t pmem;
 880         u32 count=0;
 881         u32 cqp_head;
 882         u64 u64temp;
 883         u32 u32temp;
 884
 885         /* allocate CQP memory */
 886         /* Need to add max_cq to the aeq size once cq overflow checking is added back */
 887         /* SQ is 512 byte aligned, others are 256 byte aligned */
 888         nesdev->cqp_mem_size = 512 +
 889                         (sizeof(struct nes_hw_cqp_wqe) * NES_CQP_SQ_SIZE) +
 890                         (sizeof(struct nes_hw_cqe) * NES_CCQ_SIZE) +
 891                         max(((u32)sizeof(struct nes_hw_ceqe) * NES_CCEQ_SIZE), (u32)256) +
 892                         max(((u32)sizeof(struct nes_hw_ceqe) * NES_NIC_CEQ_SIZE), (u32)256) +
 893                         (sizeof(struct nes_hw_aeqe) * nesadapter->max_qp) +
 894                         sizeof(struct nes_hw_cqp_qp_context);
 895
 896         nesdev->cqp_vbase = pci_alloc_consistent(nesdev->pcidev, nesdev->cqp_mem_size,
 897                         &nesdev->cqp_pbase);
 898         if (!nesdev->cqp_vbase) {
 899                 nes_debug(NES_DBG_INIT, "Unable to allocate memory for host descriptor rings\n");
 900                 return -ENOMEM;
 901         }
 902         memset(nesdev->cqp_vbase, 0, nesdev->cqp_mem_size);
 903
 904         /* Allocate a twice the number of CQP requests as the SQ size */
 905         nesdev->nes_cqp_requests = kzalloc(sizeof(struct nes_cqp_request) *
 906                         2 * NES_CQP_SQ_SIZE, GFP_KERNEL);
 907         if (nesdev->nes_cqp_requests == NULL) {
 908                 nes_debug(NES_DBG_INIT, "Unable to allocate memory CQP request entries.\n");
 909                 pci_free_consistent(nesdev->pcidev, nesdev->cqp_mem_size, nesdev->cqp.sq_vbase,
 910                                 nesdev->cqp.sq_pbase);
 911                 return -ENOMEM;
 912         }
 913
 914         nes_debug(NES_DBG_INIT, "Allocated CQP structures at %p (phys = %016lX), size = %u.\n",
 915                         nesdev->cqp_vbase, (unsigned long)nesdev->cqp_pbase, nesdev->cqp_mem_size);
 916
 917         spin_lock_init(&nesdev->cqp.lock);
 918         init_waitqueue_head(&nesdev->cqp.waitq);
 919
 920         /* Setup Various Structures */
 921         vmem = (void *)(((unsigned long)nesdev->cqp_vbase + (512 - 1)) &
 922                         ~(unsigned long)(512 - 1));
 923         pmem = (dma_addr_t)(((unsigned long long)nesdev->cqp_pbase + (512 - 1)) &
 924                         ~(unsigned long long)(512 - 1));
 925
 926         nesdev->cqp.sq_vbase = vmem;
 927         nesdev->cqp.sq_pbase = pmem;
 928         nesdev->cqp.sq_size = NES_CQP_SQ_SIZE;
 929         nesdev->cqp.sq_head = 0;
 930         nesdev->cqp.sq_tail = 0;
 931         nesdev->cqp.qp_id = PCI_FUNC(nesdev->pcidev->devfn);
 932
 933         vmem += (sizeof(struct nes_hw_cqp_wqe) * nesdev->cqp.sq_size);
 934         pmem += (sizeof(struct nes_hw_cqp_wqe) * nesdev->cqp.sq_size);
 935
 936         nesdev->ccq.cq_vbase = vmem;
 937         nesdev->ccq.cq_pbase = pmem;
 938         nesdev->ccq.cq_size = NES_CCQ_SIZE;
 939         nesdev->ccq.cq_head = 0;
 940         nesdev->ccq.ce_handler = nes_cqp_ce_handler;
 941         nesdev->ccq.cq_number = PCI_FUNC(nesdev->pcidev->devfn);
 942
 943         vmem += (sizeof(struct nes_hw_cqe) * nesdev->ccq.cq_size);
 944         pmem += (sizeof(struct nes_hw_cqe) * nesdev->ccq.cq_size);
 945
 946         nesdev->ceq_index = PCI_FUNC(nesdev->pcidev->devfn);
 947         ceq = &nesadapter->ceq[nesdev->ceq_index];
 948         ceq->ceq_vbase = vmem;
 949         ceq->ceq_pbase = pmem;
 950         ceq->ceq_size = NES_CCEQ_SIZE;
 951         ceq->ceq_head = 0;
 952
 953         vmem += max(((u32)sizeof(struct nes_hw_ceqe) * ceq->ceq_size), (u32)256);
 954         pmem += max(((u32)sizeof(struct nes_hw_ceqe) * ceq->ceq_size), (u32)256);
 955
 956         nesdev->nic_ceq_index = PCI_FUNC(nesdev->pcidev->devfn) + 8;
 957         nic_ceq = &nesadapter->ceq[nesdev->nic_ceq_index];
 958         nic_ceq->ceq_vbase = vmem;
 959         nic_ceq->ceq_pbase = pmem;
 960         nic_ceq->ceq_size = NES_NIC_CEQ_SIZE;
 961         nic_ceq->ceq_head = 0;
 962
 963         vmem += max(((u32)sizeof(struct nes_hw_ceqe) * nic_ceq->ceq_size), (u32)256);
 964         pmem += max(((u32)sizeof(struct nes_hw_ceqe) * nic_ceq->ceq_size), (u32)256);
 965
 966         aeq = &nesadapter->aeq[PCI_FUNC(nesdev->pcidev->devfn)];
 967         aeq->aeq_vbase = vmem;
 968         aeq->aeq_pbase = pmem;
 969         aeq->aeq_size = nesadapter->max_qp;
 970         aeq->aeq_head = 0;
 971
 972         /* Setup QP Context */
 973         vmem += (sizeof(struct nes_hw_aeqe) * aeq->aeq_size);
 974         pmem += (sizeof(struct nes_hw_aeqe) * aeq->aeq_size);
 975
 976         cqp_qp_context = vmem;
 977         cqp_qp_context->context_words[0] =
 978                         cpu_to_le32((PCI_FUNC(nesdev->pcidev->devfn) << 12) + (2 << 10));
 979         cqp_qp_context->context_words[1] = 0;
 980         cqp_qp_context->context_words[2] = cpu_to_le32((u32)nesdev->cqp.sq_pbase);
 981         cqp_qp_context->context_words[3] = cpu_to_le32(((u64)nesdev->cqp.sq_pbase) >> 32);
 982
 983
 984         /* Write the address to Create CQP */
 985         if ((sizeof(dma_addr_t) > 4)) {
 986                 nes_write_indexed(nesdev,
 987                                 NES_IDX_CREATE_CQP_HIGH + (PCI_FUNC(nesdev->pcidev->devfn) * 8),
 988                                 ((u64)pmem) >> 32);
 989         } else {
 990                 nes_write_indexed(nesdev,
 991                                 NES_IDX_CREATE_CQP_HIGH + (PCI_FUNC(nesdev->pcidev->devfn) * 8), 0);
 992         }
 993         nes_write_indexed(nesdev,
 994                         NES_IDX_CREATE_CQP_LOW + (PCI_FUNC(nesdev->pcidev->devfn) * 8),
 995                         (u32)pmem);
 996
 997         INIT_LIST_HEAD(&nesdev->cqp_avail_reqs);
 998         INIT_LIST_HEAD(&nesdev->cqp_pending_reqs);
 999
1000         for (count = 0; count < 2*NES_CQP_SQ_SIZE; count++) {
1001                 init_waitqueue_head(&nesdev->nes_cqp_requests[count].waitq);
1002                 list_add_tail(&nesdev->nes_cqp_requests[count].list, &nesdev->cqp_avail_reqs);
1003         }
1004
1005         /* Write Create CCQ WQE */
1006         cqp_head = nesdev->cqp.sq_head++;
1007         cqp_wqe = &nesdev->cqp.sq_vbase[cqp_head];
1008         nes_fill_init_cqp_wqe(cqp_wqe, nesdev);
1009         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX,
1010                         (NES_CQP_CREATE_CQ | NES_CQP_CQ_CEQ_VALID |
1011                         NES_CQP_CQ_CHK_OVERFLOW | ((u32)nesdev->ccq.cq_size << 16)));
1012         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_ID_IDX,
1013                             (nesdev->ccq.cq_number |
1014                              ((u32)nesdev->ceq_index << 16)));
1015         u64temp = (u64)nesdev->ccq.cq_pbase;
1016         set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_CQ_WQE_PBL_LOW_IDX, u64temp);
1017         cqp_wqe->wqe_words[NES_CQP_CQ_WQE_CQ_CONTEXT_HIGH_IDX] = 0;
1018         u64temp = (unsigned long)&nesdev->ccq;
1019         cqp_wqe->wqe_words[NES_CQP_CQ_WQE_CQ_CONTEXT_LOW_IDX] =
1020                         cpu_to_le32((u32)(u64temp >> 1));
1021         cqp_wqe->wqe_words[NES_CQP_CQ_WQE_CQ_CONTEXT_HIGH_IDX] =
1022                         cpu_to_le32(((u32)((u64temp) >> 33)) & 0x7FFFFFFF);
1023         cqp_wqe->wqe_words[NES_CQP_CQ_WQE_DOORBELL_INDEX_HIGH_IDX] = 0;
1024
1025         /* Write Create CEQ WQE */
1026         cqp_head = nesdev->cqp.sq_head++;
1027         cqp_wqe = &nesdev->cqp.sq_vbase[cqp_head];
1028         nes_fill_init_cqp_wqe(cqp_wqe, nesdev);
1029         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX,
1030                             (NES_CQP_CREATE_CEQ + ((u32)nesdev->ceq_index << 8)));
1031         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_CEQ_WQE_ELEMENT_COUNT_IDX, ceq->ceq_size);
1032         u64temp = (u64)ceq->ceq_pbase;
1033         set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_CQ_WQE_PBL_LOW_IDX, u64temp);
1034
1035         /* Write Create AEQ WQE */
1036         cqp_head = nesdev->cqp.sq_head++;
1037         cqp_wqe = &nesdev->cqp.sq_vbase[cqp_head];
1038         nes_fill_init_cqp_wqe(cqp_wqe, nesdev);
1039         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX,
1040                         (NES_CQP_CREATE_AEQ + ((u32)PCI_FUNC(nesdev->pcidev->devfn) << 8)));
1041         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_AEQ_WQE_ELEMENT_COUNT_IDX, aeq->aeq_size);
1042         u64temp = (u64)aeq->aeq_pbase;
1043         set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_CQ_WQE_PBL_LOW_IDX, u64temp);
1044
1045         /* Write Create NIC CEQ WQE */
1046         cqp_head = nesdev->cqp.sq_head++;
1047         cqp_wqe = &nesdev->cqp.sq_vbase[cqp_head];
1048         nes_fill_init_cqp_wqe(cqp_wqe, nesdev);
1049         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX,
1050                         (NES_CQP_CREATE_CEQ + ((u32)nesdev->nic_ceq_index << 8)));
1051         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_CEQ_WQE_ELEMENT_COUNT_IDX, nic_ceq->ceq_size);
1052         u64temp = (u64)nic_ceq->ceq_pbase;
1053         set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_CQ_WQE_PBL_LOW_IDX, u64temp);
1054
1055         /* Poll until CCQP done */
1056         count = 0;
1057         do {
1058                 if (count++ > 1000) {
1059                         printk(KERN_ERR PFX "Error creating CQP\n");
1060                         pci_free_consistent(nesdev->pcidev, nesdev->cqp_mem_size,
1061                                         nesdev->cqp_vbase, nesdev->cqp_pbase);
1062                         return -1;
1063                 }
1064                 udelay(10);
1065         } while (!(nes_read_indexed(nesdev,
1066                         NES_IDX_QP_CONTROL + (PCI_FUNC(nesdev->pcidev->devfn) * 8)) & (1 << 8)));
1067
1068         nes_debug(NES_DBG_INIT, "CQP Status = 0x%08X\n", nes_read_indexed(nesdev,
1069                         NES_IDX_QP_CONTROL+(PCI_FUNC(nesdev->pcidev->devfn)*8)));
1070
1071         u32temp = 0x04800000;
1072         nes_write32(nesdev->regs+NES_WQE_ALLOC, u32temp | nesdev->cqp.qp_id);
1073
1074         /* wait for the CCQ, CEQ, and AEQ to get created */
1075         count = 0;
1076         do {
1077                 if (count++ > 1000) {
1078                         printk(KERN_ERR PFX "Error creating CCQ, CEQ, and AEQ\n");
1079                         pci_free_consistent(nesdev->pcidev, nesdev->cqp_mem_size,
1080                                         nesdev->cqp_vbase, nesdev->cqp_pbase);
1081                         return -1;
1082                 }
1083                 udelay(10);
1084         } while (((nes_read_indexed(nesdev,
1085                         NES_IDX_QP_CONTROL+(PCI_FUNC(nesdev->pcidev->devfn)*8)) & (15<<8)) != (15<<8)));
1086
1087         /* dump the QP status value */
1088         nes_debug(NES_DBG_INIT, "QP Status = 0x%08X\n", nes_read_indexed(nesdev,
1089                         NES_IDX_QP_CONTROL+(PCI_FUNC(nesdev->pcidev->devfn)*8)));
1090
1091         nesdev->cqp.sq_tail++;
1092
1093         return 0;
1094 }
1095
1096
1097 /**
1098  * nes_destroy_cqp
1099  */
1100 int nes_destroy_cqp(struct nes_device *nesdev)
1101 {
1102         struct nes_hw_cqp_wqe *cqp_wqe;
1103         u32 count = 0;
1104         u32 cqp_head;
1105         unsigned long flags;
1106
1107         do {
1108                 if (count++ > 1000)
1109                         break;
1110                 udelay(10);
1111         } while (!(nesdev->cqp.sq_head == nesdev->cqp.sq_tail));
1112
1113         /* Reset CCQ */
1114         nes_write32(nesdev->regs+NES_CQE_ALLOC, NES_CQE_ALLOC_RESET |
1115                         nesdev->ccq.cq_number);
1116
1117         /* Disable device interrupts */
1118         nes_write32(nesdev->regs+NES_INT_MASK, 0x7fffffff);
1119
1120         spin_lock_irqsave(&nesdev->cqp.lock, flags);
1121
1122         /* Destroy the AEQ */
1123         cqp_head = nesdev->cqp.sq_head++;
1124         nesdev->cqp.sq_head &= nesdev->cqp.sq_size-1;
1125         cqp_wqe = &nesdev->cqp.sq_vbase[cqp_head];
1126         cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] = cpu_to_le32(NES_CQP_DESTROY_AEQ |
1127                         ((u32)PCI_FUNC(nesdev->pcidev->devfn) << 8));
1128         cqp_wqe->wqe_words[NES_CQP_WQE_COMP_CTX_HIGH_IDX] = 0;
1129
1130         /* Destroy the NIC CEQ */
1131         cqp_head = nesdev->cqp.sq_head++;
1132         nesdev->cqp.sq_head &= nesdev->cqp.sq_size-1;
1133         cqp_wqe = &nesdev->cqp.sq_vbase[cqp_head];
1134         cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] = cpu_to_le32(NES_CQP_DESTROY_CEQ |
1135                         ((u32)nesdev->nic_ceq_index << 8));
1136
1137         /* Destroy the CEQ */
1138         cqp_head = nesdev->cqp.sq_head++;
1139         nesdev->cqp.sq_head &= nesdev->cqp.sq_size-1;
1140         cqp_wqe = &nesdev->cqp.sq_vbase[cqp_head];
1141         cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] = cpu_to_le32(NES_CQP_DESTROY_CEQ |
1142                         (nesdev->ceq_index << 8));
1143
1144         /* Destroy the CCQ */
1145         cqp_head = nesdev->cqp.sq_head++;
1146         nesdev->cqp.sq_head &= nesdev->cqp.sq_size-1;
1147         cqp_wqe = &nesdev->cqp.sq_vbase[cqp_head];
1148         cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] = cpu_to_le32(NES_CQP_DESTROY_CQ);
1149         cqp_wqe->wqe_words[NES_CQP_WQE_ID_IDX] = cpu_to_le32(nesdev->ccq.cq_number |
1150                         ((u32)nesdev->ceq_index << 16));
1151
1152         /* Destroy CQP */
1153         cqp_head = nesdev->cqp.sq_head++;
1154         nesdev->cqp.sq_head &= nesdev->cqp.sq_size-1;
1155         cqp_wqe = &nesdev->cqp.sq_vbase[cqp_head];
1156         cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] = cpu_to_le32(NES_CQP_DESTROY_QP |
1157                         NES_CQP_QP_TYPE_CQP);
1158         cqp_wqe->wqe_words[NES_CQP_WQE_ID_IDX] = cpu_to_le32(nesdev->cqp.qp_id);
1159
1160         barrier();
1161         /* Ring doorbell (5 WQEs) */
1162         nes_write32(nesdev->regs+NES_WQE_ALLOC, 0x05800000 | nesdev->cqp.qp_id);
1163
1164         spin_unlock_irqrestore(&nesdev->cqp.lock, flags);
1165
1166         /* wait for the CCQ, CEQ, and AEQ to get destroyed */
1167         count = 0;
1168         do {
1169                 if (count++ > 1000) {
1170                         printk(KERN_ERR PFX "Function%d: Error destroying CCQ, CEQ, and AEQ\n",
1171                                         PCI_FUNC(nesdev->pcidev->devfn));
1172                         break;
1173                 }
1174                 udelay(10);
1175         } while (((nes_read_indexed(nesdev,
1176                         NES_IDX_QP_CONTROL + (PCI_FUNC(nesdev->pcidev->devfn)*8)) & (15 << 8)) != 0));
1177
1178         /* dump the QP status value */
1179         nes_debug(NES_DBG_SHUTDOWN, "Function%d: QP Status = 0x%08X\n",
1180                         PCI_FUNC(nesdev->pcidev->devfn),
1181                         nes_read_indexed(nesdev,
1182                         NES_IDX_QP_CONTROL+(PCI_FUNC(nesdev->pcidev->devfn)*8)));
1183
1184         kfree(nesdev->nes_cqp_requests);
1185
1186         /* Free the control structures */
1187         pci_free_consistent(nesdev->pcidev, nesdev->cqp_mem_size, nesdev->cqp.sq_vbase,
1188                         nesdev->cqp.sq_pbase);
1189
1190         return 0;
1191 }
1192
1193
1194 /**
1195  * nes_init_phy
1196  */
1197 int nes_init_phy(struct nes_device *nesdev)
1198 {
1199         struct nes_adapter *nesadapter = nesdev->nesadapter;
1200         u32 counter = 0;
1201         u32 mac_index = nesdev->mac_index;
1202         u32 tx_config;
1203         u16 phy_data;
1204
1205         if (nesadapter->OneG_Mode) {
1206                 nes_debug(NES_DBG_PHY, "1G PHY, mac_index = %d.\n", mac_index);
1207                 if (nesadapter->phy_type[mac_index] == NES_PHY_TYPE_1G) {
1208                         printk(PFX "%s: Programming mdc config for 1G\n", __FUNCTION__);
1209                         tx_config = nes_read_indexed(nesdev, NES_IDX_MAC_TX_CONFIG);
1210                         tx_config |= 0x04;
1211                         nes_write_indexed(nesdev, NES_IDX_MAC_TX_CONFIG, tx_config);
1212                 }
1213
1214                 nes_read_1G_phy_reg(nesdev, 1, nesadapter->phy_index[mac_index], &phy_data);
1215                 nes_debug(NES_DBG_PHY, "Phy data from register 1 phy address %u = 0x%X.\n",
1216                                 nesadapter->phy_index[mac_index], phy_data);
1217                 nes_write_1G_phy_reg(nesdev, 23, nesadapter->phy_index[mac_index],  0xb000);
1218
1219                 /* Reset the PHY */
1220                 nes_write_1G_phy_reg(nesdev, 0, nesadapter->phy_index[mac_index], 0x8000);
1221                 udelay(100);
1222                 counter = 0;
1223                 do {
1224                         nes_read_1G_phy_reg(nesdev, 0, nesadapter->phy_index[mac_index], &phy_data);
1225                         nes_debug(NES_DBG_PHY, "Phy data from register 0 = 0x%X.\n", phy_data);
1226                         if (counter++ > 100) break;
1227                 } while (phy_data & 0x8000);
1228
1229                 /* Setting no phy loopback */
1230                 phy_data &= 0xbfff;
1231                 phy_data |= 0x1140;
1232                 nes_write_1G_phy_reg(nesdev, 0, nesadapter->phy_index[mac_index],  phy_data);
1233                 nes_read_1G_phy_reg(nesdev, 0, nesadapter->phy_index[mac_index], &phy_data);
1234                 nes_debug(NES_DBG_PHY, "Phy data from register 0 = 0x%X.\n", phy_data);
1235
1236                 nes_read_1G_phy_reg(nesdev, 0x17, nesadapter->phy_index[mac_index], &phy_data);
1237                 nes_debug(NES_DBG_PHY, "Phy data from register 0x17 = 0x%X.\n", phy_data);
1238
1239                 nes_read_1G_phy_reg(nesdev, 0x1e, nesadapter->phy_index[mac_index], &phy_data);
1240                 nes_debug(NES_DBG_PHY, "Phy data from register 0x1e = 0x%X.\n", phy_data);
1241
1242                 /* Setting the interrupt mask */
1243                 nes_read_1G_phy_reg(nesdev, 0x19, nesadapter->phy_index[mac_index], &phy_data);
1244                 nes_debug(NES_DBG_PHY, "Phy data from register 0x19 = 0x%X.\n", phy_data);
1245                 nes_write_1G_phy_reg(nesdev, 0x19, nesadapter->phy_index[mac_index], 0xffee);
1246
1247                 nes_read_1G_phy_reg(nesdev, 0x19, nesadapter->phy_index[mac_index], &phy_data);
1248                 nes_debug(NES_DBG_PHY, "Phy data from register 0x19 = 0x%X.\n", phy_data);
1249
1250                 /* turning on flow control */
1251                 nes_read_1G_phy_reg(nesdev, 4, nesadapter->phy_index[mac_index], &phy_data);
1252                 nes_debug(NES_DBG_PHY, "Phy data from register 0x4 = 0x%X.\n", phy_data);
1253                 nes_write_1G_phy_reg(nesdev, 4, nesadapter->phy_index[mac_index],
1254                                 (phy_data & ~(0x03E0)) | 0xc00);
1255                 /* nes_write_1G_phy_reg(nesdev, 4, nesadapter->phy_index[mac_index],
1256                                 phy_data | 0xc00); */
1257                 nes_read_1G_phy_reg(nesdev, 4, nesadapter->phy_index[mac_index], &phy_data);
1258                 nes_debug(NES_DBG_PHY, "Phy data from register 0x4 = 0x%X.\n", phy_data);
1259
1260                 nes_read_1G_phy_reg(nesdev, 9, nesadapter->phy_index[mac_index], &phy_data);
1261                 nes_debug(NES_DBG_PHY, "Phy data from register 0x9 = 0x%X.\n", phy_data);
1262                 /* Clear Half duplex */
1263                 nes_write_1G_phy_reg(nesdev, 9, nesadapter->phy_index[mac_index],
1264                                 phy_data & ~(0x0100));
1265                 nes_read_1G_phy_reg(nesdev, 9, nesadapter->phy_index[mac_index], &phy_data);
1266                 nes_debug(NES_DBG_PHY, "Phy data from register 0x9 = 0x%X.\n", phy_data);
1267
1268                 nes_read_1G_phy_reg(nesdev, 0, nesadapter->phy_index[mac_index], &phy_data);
1269                 nes_write_1G_phy_reg(nesdev, 0, nesadapter->phy_index[mac_index], phy_data | 0x0300);
1270         } else {
1271                 if (nesadapter->phy_type[mac_index] == NES_PHY_TYPE_IRIS) {
1272                         /* setup 10G MDIO operation */
1273                         tx_config = nes_read_indexed(nesdev, NES_IDX_MAC_TX_CONFIG);
1274                         tx_config |= 0x14;
1275                         nes_write_indexed(nesdev, NES_IDX_MAC_TX_CONFIG, tx_config);
1276                 }
1277         }
1278         return 0;
1279 }
1280
1281
1282 /**
1283  * nes_replenish_nic_rq
1284  */
1285 static void nes_replenish_nic_rq(struct nes_vnic *nesvnic)
1286 {
1287         unsigned long flags;
1288         dma_addr_t bus_address;
1289         struct sk_buff *skb;
1290         struct nes_hw_nic_rq_wqe *nic_rqe;
1291         struct nes_hw_nic *nesnic;
1292         struct nes_device *nesdev;
1293         u32 rx_wqes_posted = 0;
1294
1295         nesnic = &nesvnic->nic;
1296         nesdev = nesvnic->nesdev;
1297         spin_lock_irqsave(&nesnic->rq_lock, flags);
1298         if (nesnic->replenishing_rq !=0) {
1299                 if (((nesnic->rq_size-1) == atomic_read(&nesvnic->rx_skbs_needed)) &&
1300                                 (atomic_read(&nesvnic->rx_skb_timer_running) == 0)) {
1301                         atomic_set(&nesvnic->rx_skb_timer_running, 1);
1302                         spin_unlock_irqrestore(&nesnic->rq_lock, flags);
1303                         nesvnic->rq_wqes_timer.expires = jiffies + (HZ/2);      /* 1/2 second */
1304                         add_timer(&nesvnic->rq_wqes_timer);
1305                 } else
1306                 spin_unlock_irqrestore(&nesnic->rq_lock, flags);
1307                 return;
1308         }
1309         nesnic->replenishing_rq = 1;
1310         spin_unlock_irqrestore(&nesnic->rq_lock, flags);
1311         do {
1312                 skb = dev_alloc_skb(nesvnic->max_frame_size);
1313                 if (skb) {
1314                         skb->dev = nesvnic->netdev;
1315
1316                         bus_address = pci_map_single(nesdev->pcidev,
1317                                         skb->data, nesvnic->max_frame_size, PCI_DMA_FROMDEVICE);
1318
1319                         nic_rqe = &nesnic->rq_vbase[nesvnic->nic.rq_head];
1320                         nic_rqe->wqe_words[NES_NIC_RQ_WQE_LENGTH_1_0_IDX] =
1321                                         cpu_to_le32(nesvnic->max_frame_size);
1322                         nic_rqe->wqe_words[NES_NIC_RQ_WQE_LENGTH_3_2_IDX] = 0;
1323                         nic_rqe->wqe_words[NES_NIC_RQ_WQE_FRAG0_LOW_IDX] =
1324                                         cpu_to_le32((u32)bus_address);
1325                         nic_rqe->wqe_words[NES_NIC_RQ_WQE_FRAG0_HIGH_IDX] =
1326                                         cpu_to_le32((u32)((u64)bus_address >> 32));
1327                         nesnic->rx_skb[nesnic->rq_head] = skb;
1328                         nesnic->rq_head++;
1329                         nesnic->rq_head &= nesnic->rq_size - 1;
1330                         atomic_dec(&nesvnic->rx_skbs_needed);
1331                         barrier();
1332                         if (++rx_wqes_posted == 255) {
1333                                 nes_write32(nesdev->regs+NES_WQE_ALLOC, (rx_wqes_posted << 24) | nesnic->qp_id);
1334                                 rx_wqes_posted = 0;
1335                         }
1336                 } else {
1337                         spin_lock_irqsave(&nesnic->rq_lock, flags);
1338                         if (((nesnic->rq_size-1) == atomic_read(&nesvnic->rx_skbs_needed)) &&
1339                                         (atomic_read(&nesvnic->rx_skb_timer_running) == 0)) {
1340                                 atomic_set(&nesvnic->rx_skb_timer_running, 1);
1341                                 spin_unlock_irqrestore(&nesnic->rq_lock, flags);
1342                                 nesvnic->rq_wqes_timer.expires = jiffies + (HZ/2);      /* 1/2 second */
1343                                 add_timer(&nesvnic->rq_wqes_timer);
1344                         } else
1345                                 spin_unlock_irqrestore(&nesnic->rq_lock, flags);
1346                         break;
1347                 }
1348         } while (atomic_read(&nesvnic->rx_skbs_needed));
1349         barrier();
1350         if (rx_wqes_posted)
1351                 nes_write32(nesdev->regs+NES_WQE_ALLOC, (rx_wqes_posted << 24) | nesnic->qp_id);
1352         nesnic->replenishing_rq = 0;
1353 }
1354
1355
1356 /**
1357  * nes_rq_wqes_timeout
1358  */
1359 static void nes_rq_wqes_timeout(unsigned long parm)
1360 {
1361         struct nes_vnic *nesvnic = (struct nes_vnic *)parm;
1362         printk("%s: Timer fired.\n", __FUNCTION__);
1363         atomic_set(&nesvnic->rx_skb_timer_running, 0);
1364         if (atomic_read(&nesvnic->rx_skbs_needed))
1365                 nes_replenish_nic_rq(nesvnic);
1366 }
1367
1368
1369 /**
1370  * nes_init_nic_qp
1371  */
1372 int nes_init_nic_qp(struct nes_device *nesdev, struct net_device *netdev)
1373 {
1374         struct nes_hw_cqp_wqe *cqp_wqe;
1375         struct nes_hw_nic_sq_wqe *nic_sqe;
1376         struct nes_hw_nic_qp_context *nic_context;
1377         struct sk_buff *skb;
1378         struct nes_hw_nic_rq_wqe *nic_rqe;
1379         struct nes_vnic *nesvnic = netdev_priv(netdev);
1380         unsigned long flags;
1381         void *vmem;
1382         dma_addr_t pmem;
1383         u64 u64temp;
1384         int ret;
1385         u32 cqp_head;
1386         u32 counter;
1387         u32 wqe_count;
1388         u8 jumbomode=0;
1389
1390         /* Allocate fragment, SQ, RQ, and CQ; Reuse CEQ based on the PCI function */
1391         nesvnic->nic_mem_size = 256 +
1392                         (NES_NIC_WQ_SIZE * sizeof(struct nes_first_frag)) +
1393                         (NES_NIC_WQ_SIZE * sizeof(struct nes_hw_nic_sq_wqe)) +
1394                         (NES_NIC_WQ_SIZE * sizeof(struct nes_hw_nic_rq_wqe)) +
1395                         (NES_NIC_WQ_SIZE * 2 * sizeof(struct nes_hw_nic_cqe)) +
1396                         sizeof(struct nes_hw_nic_qp_context);
1397
1398         nesvnic->nic_vbase = pci_alloc_consistent(nesdev->pcidev, nesvnic->nic_mem_size,
1399                         &nesvnic->nic_pbase);
1400         if (!nesvnic->nic_vbase) {
1401                 nes_debug(NES_DBG_INIT, "Unable to allocate memory for NIC host descriptor rings\n");
1402                 return -ENOMEM;
1403         }
1404         memset(nesvnic->nic_vbase, 0, nesvnic->nic_mem_size);
1405         nes_debug(NES_DBG_INIT, "Allocated NIC QP structures at %p (phys = %016lX), size = %u.\n",
1406                         nesvnic->nic_vbase, (unsigned long)nesvnic->nic_pbase, nesvnic->nic_mem_size);
1407
1408         vmem = (void *)(((unsigned long)nesvnic->nic_vbase + (256 - 1)) &
1409                         ~(unsigned long)(256 - 1));
1410         pmem = (dma_addr_t)(((unsigned long long)nesvnic->nic_pbase + (256 - 1)) &
1411                         ~(unsigned long long)(256 - 1));
1412
1413         /* Setup the first Fragment buffers */
1414         nesvnic->nic.first_frag_vbase = vmem;
1415
1416         for (counter = 0; counter < NES_NIC_WQ_SIZE; counter++) {
1417                 nesvnic->nic.frag_paddr[counter] = pmem;
1418                 pmem += sizeof(struct nes_first_frag);
1419         }
1420
1421         /* setup the SQ */
1422         vmem += (NES_NIC_WQ_SIZE * sizeof(struct nes_first_frag));
1423
1424         nesvnic->nic.sq_vbase = (void *)vmem;
1425         nesvnic->nic.sq_pbase = pmem;
1426         nesvnic->nic.sq_head = 0;
1427         nesvnic->nic.sq_tail = 0;
1428         nesvnic->nic.sq_size = NES_NIC_WQ_SIZE;
1429         for (counter = 0; counter < NES_NIC_WQ_SIZE; counter++) {
1430                 nic_sqe = &nesvnic->nic.sq_vbase[counter];
1431                 nic_sqe->wqe_words[NES_NIC_SQ_WQE_MISC_IDX] =
1432                                 cpu_to_le32(NES_NIC_SQ_WQE_DISABLE_CHKSUM |
1433                                 NES_NIC_SQ_WQE_COMPLETION);
1434                 nic_sqe->wqe_words[NES_NIC_SQ_WQE_LENGTH_0_TAG_IDX] =
1435                                 cpu_to_le32((u32)NES_FIRST_FRAG_SIZE << 16);
1436                 nic_sqe->wqe_words[NES_NIC_SQ_WQE_FRAG0_LOW_IDX] =
1437                                 cpu_to_le32((u32)nesvnic->nic.frag_paddr[counter]);
1438                 nic_sqe->wqe_words[NES_NIC_SQ_WQE_FRAG0_HIGH_IDX] =
1439                                 cpu_to_le32((u32)((u64)nesvnic->nic.frag_paddr[counter] >> 32));
1440         }
1441
1442         nesvnic->get_cqp_request = nes_get_cqp_request;
1443         nesvnic->post_cqp_request = nes_post_cqp_request;
1444         nesvnic->mcrq_mcast_filter = NULL;
1445
1446         spin_lock_init(&nesvnic->nic.sq_lock);
1447         spin_lock_init(&nesvnic->nic.rq_lock);
1448
1449         /* setup the RQ */
1450         vmem += (NES_NIC_WQ_SIZE * sizeof(struct nes_hw_nic_sq_wqe));
1451         pmem += (NES_NIC_WQ_SIZE * sizeof(struct nes_hw_nic_sq_wqe));
1452
1453
1454         nesvnic->nic.rq_vbase = vmem;
1455         nesvnic->nic.rq_pbase = pmem;
1456         nesvnic->nic.rq_head = 0;
1457         nesvnic->nic.rq_tail = 0;
1458         nesvnic->nic.rq_size = NES_NIC_WQ_SIZE;
1459
1460         /* setup the CQ */
1461         vmem += (NES_NIC_WQ_SIZE * sizeof(struct nes_hw_nic_rq_wqe));
1462         pmem += (NES_NIC_WQ_SIZE * sizeof(struct nes_hw_nic_rq_wqe));
1463
1464         if (nesdev->nesadapter->netdev_count > 2)
1465                 nesvnic->mcrq_qp_id = nesvnic->nic_index + 32;
1466         else
1467                 nesvnic->mcrq_qp_id = nesvnic->nic.qp_id + 4;
1468
1469         nesvnic->nic_cq.cq_vbase = vmem;
1470         nesvnic->nic_cq.cq_pbase = pmem;
1471         nesvnic->nic_cq.cq_head = 0;
1472         nesvnic->nic_cq.cq_size = NES_NIC_WQ_SIZE * 2;
1473
1474         nesvnic->nic_cq.ce_handler = nes_nic_napi_ce_handler;
1475
1476         /* Send CreateCQ request to CQP */
1477         spin_lock_irqsave(&nesdev->cqp.lock, flags);
1478         cqp_head = nesdev->cqp.sq_head;
1479
1480         cqp_wqe = &nesdev->cqp.sq_vbase[cqp_head];
1481         nes_fill_init_cqp_wqe(cqp_wqe, nesdev);
1482
1483         cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] = cpu_to_le32(
1484                         NES_CQP_CREATE_CQ | NES_CQP_CQ_CEQ_VALID |
1485                         ((u32)nesvnic->nic_cq.cq_size << 16));
1486         cqp_wqe->wqe_words[NES_CQP_WQE_ID_IDX] = cpu_to_le32(
1487                         nesvnic->nic_cq.cq_number | ((u32)nesdev->nic_ceq_index << 16));
1488         u64temp = (u64)nesvnic->nic_cq.cq_pbase;
1489         set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_CQ_WQE_PBL_LOW_IDX, u64temp);
1490         cqp_wqe->wqe_words[NES_CQP_CQ_WQE_CQ_CONTEXT_HIGH_IDX] =  0;
1491         u64temp = (unsigned long)&nesvnic->nic_cq;
1492         cqp_wqe->wqe_words[NES_CQP_CQ_WQE_CQ_CONTEXT_LOW_IDX] =  cpu_to_le32((u32)(u64temp >> 1));
1493         cqp_wqe->wqe_words[NES_CQP_CQ_WQE_CQ_CONTEXT_HIGH_IDX] =
1494                         cpu_to_le32(((u32)((u64temp) >> 33)) & 0x7FFFFFFF);
1495         cqp_wqe->wqe_words[NES_CQP_CQ_WQE_DOORBELL_INDEX_HIGH_IDX] = 0;
1496         if (++cqp_head >= nesdev->cqp.sq_size)
1497                 cqp_head = 0;
1498         cqp_wqe = &nesdev->cqp.sq_vbase[cqp_head];
1499         nes_fill_init_cqp_wqe(cqp_wqe, nesdev);
1500
1501         /* Send CreateQP request to CQP */
1502         nic_context = (void *)(&nesvnic->nic_cq.cq_vbase[nesvnic->nic_cq.cq_size]);
1503         nic_context->context_words[NES_NIC_CTX_MISC_IDX] =
1504                         cpu_to_le32((u32)NES_NIC_CTX_SIZE |
1505                         ((u32)PCI_FUNC(nesdev->pcidev->devfn) << 12));
1506         nes_debug(NES_DBG_INIT, "RX_WINDOW_BUFFER_PAGE_TABLE_SIZE = 0x%08X, RX_WINDOW_BUFFER_SIZE = 0x%08X\n",
1507                         nes_read_indexed(nesdev, NES_IDX_RX_WINDOW_BUFFER_PAGE_TABLE_SIZE),
1508                         nes_read_indexed(nesdev, NES_IDX_RX_WINDOW_BUFFER_SIZE));
1509         if (nes_read_indexed(nesdev, NES_IDX_RX_WINDOW_BUFFER_SIZE) != 0) {
1510                 nic_context->context_words[NES_NIC_CTX_MISC_IDX] |= cpu_to_le32(NES_NIC_BACK_STORE);
1511         }
1512
1513         u64temp = (u64)nesvnic->nic.sq_pbase;
1514         nic_context->context_words[NES_NIC_CTX_SQ_LOW_IDX] = cpu_to_le32((u32)u64temp);
1515         nic_context->context_words[NES_NIC_CTX_SQ_HIGH_IDX] = cpu_to_le32((u32)(u64temp >> 32));
1516         u64temp = (u64)nesvnic->nic.rq_pbase;
1517         nic_context->context_words[NES_NIC_CTX_RQ_LOW_IDX] = cpu_to_le32((u32)u64temp);
1518         nic_context->context_words[NES_NIC_CTX_RQ_HIGH_IDX] = cpu_to_le32((u32)(u64temp >> 32));
1519
1520         cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] = cpu_to_le32(NES_CQP_CREATE_QP |
1521                         NES_CQP_QP_TYPE_NIC);
1522         cqp_wqe->wqe_words[NES_CQP_WQE_ID_IDX] = cpu_to_le32(nesvnic->nic.qp_id);
1523         u64temp = (u64)nesvnic->nic_cq.cq_pbase +
1524                         (nesvnic->nic_cq.cq_size * sizeof(struct nes_hw_nic_cqe));
1525         set_wqe_64bit_value(cqp_wqe->wqe_words, NES_CQP_QP_WQE_CONTEXT_LOW_IDX, u64temp);
1526
1527         if (++cqp_head >= nesdev->cqp.sq_size)
1528                 cqp_head = 0;
1529         nesdev->cqp.sq_head = cqp_head;
1530
1531         barrier();
1532
1533         /* Ring doorbell (2 WQEs) */
1534         nes_write32(nesdev->regs+NES_WQE_ALLOC, 0x02800000 | nesdev->cqp.qp_id);
1535
1536         spin_unlock_irqrestore(&nesdev->cqp.lock, flags);
1537         nes_debug(NES_DBG_INIT, "Waiting for create NIC QP%u to complete.\n",
1538                         nesvnic->nic.qp_id);
1539
1540         ret = wait_event_timeout(nesdev->cqp.waitq, (nesdev->cqp.sq_tail == cqp_head),
1541                         NES_EVENT_TIMEOUT);
1542         nes_debug(NES_DBG_INIT, "Create NIC QP%u completed, wait_event_timeout ret = %u.\n",
1543                         nesvnic->nic.qp_id, ret);
1544         if (!ret) {
1545                 nes_debug(NES_DBG_INIT, "NIC QP%u create timeout expired\n", nesvnic->nic.qp_id);
1546                 pci_free_consistent(nesdev->pcidev, nesvnic->nic_mem_size, nesvnic->nic_vbase,
1547                                 nesvnic->nic_pbase);
1548                 return -EIO;
1549         }
1550
1551         /* Populate the RQ */
1552         for (counter = 0; counter < (NES_NIC_WQ_SIZE - 1); counter++) {
1553                 skb = dev_alloc_skb(nesvnic->max_frame_size);
1554                 if (!skb) {
1555                         nes_debug(NES_DBG_INIT, "%s: out of memory for receive skb\n", netdev->name);
1556
1557                         nes_destroy_nic_qp(nesvnic);
1558                         return -ENOMEM;
1559                 }
1560
1561                 skb->dev = netdev;
1562
1563                 pmem = pci_map_single(nesdev->pcidev, skb->data,
1564                                 nesvnic->max_frame_size, PCI_DMA_FROMDEVICE);
1565
1566                 nic_rqe = &nesvnic->nic.rq_vbase[counter];
1567                 nic_rqe->wqe_words[NES_NIC_RQ_WQE_LENGTH_1_0_IDX] = cpu_to_le32(nesvnic->max_frame_size);
1568                 nic_rqe->wqe_words[NES_NIC_RQ_WQE_LENGTH_3_2_IDX] = 0;
1569                 nic_rqe->wqe_words[NES_NIC_RQ_WQE_FRAG0_LOW_IDX] = cpu_to_le32((u32)pmem);
1570                 nic_rqe->wqe_words[NES_NIC_RQ_WQE_FRAG0_HIGH_IDX] = cpu_to_le32((u32)((u64)pmem >> 32));
1571                 nesvnic->nic.rx_skb[counter] = skb;
1572         }
1573
1574         wqe_count = NES_NIC_WQ_SIZE - 1;
1575         nesvnic->nic.rq_head = wqe_count;
1576         barrier();
1577         do {
1578                 counter = min(wqe_count, ((u32)255));
1579                 wqe_count -= counter;
1580                 nes_write32(nesdev->regs+NES_WQE_ALLOC, (counter << 24) | nesvnic->nic.qp_id);
1581         } while (wqe_count);
1582         init_timer(&nesvnic->rq_wqes_timer);
1583         nesvnic->rq_wqes_timer.function = nes_rq_wqes_timeout;
1584         nesvnic->rq_wqes_timer.data = (unsigned long)nesvnic;
1585         nes_debug(NES_DBG_INIT, "NAPI support Enabled\n");
1586
1587         if (nesdev->nesadapter->et_use_adaptive_rx_coalesce)
1588         {
1589                 nes_nic_init_timer(nesdev);
1590                 if (netdev->mtu > 1500)
1591                         jumbomode = 1;
1592                 nes_nic_init_timer_defaults(nesdev, jumbomode);
1593         }
1594
1595         return 0;
1596 }
1597
1598
1599 /**
1600  * nes_destroy_nic_qp
1601  */
1602 void nes_destroy_nic_qp(struct nes_vnic *nesvnic)
1603 {
1604         struct nes_device *nesdev = nesvnic->nesdev;
1605         struct nes_hw_cqp_wqe *cqp_wqe;
1606         struct nes_hw_nic_rq_wqe *nic_rqe;
1607         u64 wqe_frag;
1608         u32 cqp_head;
1609         unsigned long flags;
1610         int ret;
1611
1612         /* Free remaining NIC receive buffers */
1613         while (nesvnic->nic.rq_head != nesvnic->nic.rq_tail) {
1614                 nic_rqe = &nesvnic->nic.rq_vbase[nesvnic->nic.rq_tail];
1615                 wqe_frag = (u64)le32_to_cpu(nic_rqe->wqe_words[NES_NIC_RQ_WQE_FRAG0_LOW_IDX]);
1616                 wqe_frag |= ((u64)le32_to_cpu(nic_rqe->wqe_words[NES_NIC_RQ_WQE_FRAG0_HIGH_IDX])) << 32;
1617                 pci_unmap_single(nesdev->pcidev, (dma_addr_t)wqe_frag,
1618                                 nesvnic->max_frame_size, PCI_DMA_FROMDEVICE);
1619                 dev_kfree_skb(nesvnic->nic.rx_skb[nesvnic->nic.rq_tail++]);
1620                 nesvnic->nic.rq_tail &= (nesvnic->nic.rq_size - 1);
1621         }
1622
1623         spin_lock_irqsave(&nesdev->cqp.lock, flags);
1624
1625         /* Destroy NIC QP */
1626         cqp_head = nesdev->cqp.sq_head;
1627         cqp_wqe = &nesdev->cqp.sq_vbase[cqp_head];
1628         nes_fill_init_cqp_wqe(cqp_wqe, nesdev);
1629
1630         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX,
1631                 (NES_CQP_DESTROY_QP | NES_CQP_QP_TYPE_NIC));
1632         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_ID_IDX,
1633                 nesvnic->nic.qp_id);
1634
1635         if (++cqp_head >= nesdev->cqp.sq_size)
1636                 cqp_head = 0;
1637
1638         cqp_wqe = &nesdev->cqp.sq_vbase[cqp_head];
1639
1640         /* Destroy NIC CQ */
1641         nes_fill_init_cqp_wqe(cqp_wqe, nesdev);
1642         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX,
1643                 (NES_CQP_DESTROY_CQ | ((u32)nesvnic->nic_cq.cq_size << 16)));
1644         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_ID_IDX,
1645                 (nesvnic->nic_cq.cq_number | ((u32)nesdev->nic_ceq_index << 16)));
1646
1647         if (++cqp_head >= nesdev->cqp.sq_size)
1648                 cqp_head = 0;
1649
1650         nesdev->cqp.sq_head = cqp_head;
1651         barrier();
1652
1653         /* Ring doorbell (2 WQEs) */
1654         nes_write32(nesdev->regs+NES_WQE_ALLOC, 0x02800000 | nesdev->cqp.qp_id);
1655
1656         spin_unlock_irqrestore(&nesdev->cqp.lock, flags);
1657         nes_debug(NES_DBG_SHUTDOWN, "Waiting for CQP, cqp_head=%u, cqp.sq_head=%u,"
1658                         " cqp.sq_tail=%u, cqp.sq_size=%u\n",
1659                         cqp_head, nesdev->cqp.sq_head,
1660                         nesdev->cqp.sq_tail, nesdev->cqp.sq_size);
1661
1662         ret = wait_event_timeout(nesdev->cqp.waitq, (nesdev->cqp.sq_tail == cqp_head),
1663                         NES_EVENT_TIMEOUT);
1664
1665         nes_debug(NES_DBG_SHUTDOWN, "Destroy NIC QP returned, wait_event_timeout ret = %u, cqp_head=%u,"
1666                         " cqp.sq_head=%u, cqp.sq_tail=%u\n",
1667                         ret, cqp_head, nesdev->cqp.sq_head, nesdev->cqp.sq_tail);
1668         if (!ret) {
1669                 nes_debug(NES_DBG_SHUTDOWN, "NIC QP%u destroy timeout expired\n",
1670                                 nesvnic->nic.qp_id);
1671         }
1672
1673         pci_free_consistent(nesdev->pcidev, nesvnic->nic_mem_size, nesvnic->nic_vbase,
1674                         nesvnic->nic_pbase);
1675 }
1676
1677 /**
1678  * nes_napi_isr
1679  */
1680 int nes_napi_isr(struct nes_device *nesdev)
1681 {
1682         struct nes_adapter *nesadapter = nesdev->nesadapter;
1683         u32 int_stat;
1684
1685         if (nesdev->napi_isr_ran) {
1686                 /* interrupt status has already been read in ISR */
1687                 int_stat = nesdev->int_stat;
1688         } else {
1689                 int_stat = nes_read32(nesdev->regs + NES_INT_STAT);
1690                 nesdev->int_stat = int_stat;
1691                 nesdev->napi_isr_ran = 1;
1692         }
1693
1694         int_stat &= nesdev->int_req;
1695         /* iff NIC, process here, else wait for DPC */
1696         if ((int_stat) && ((int_stat & 0x0000ff00) == int_stat)) {
1697                 nesdev->napi_isr_ran = 0;
1698                 nes_write32(nesdev->regs+NES_INT_STAT,
1699                                 (int_stat &
1700                                 ~(NES_INT_INTF|NES_INT_TIMER|NES_INT_MAC0|NES_INT_MAC1|NES_INT_MAC2|NES_INT_MAC3)));
1701
1702                 /* Process the CEQs */
1703                 nes_process_ceq(nesdev, &nesdev->nesadapter->ceq[nesdev->nic_ceq_index]);
1704
1705                 if (unlikely((((nesadapter->et_rx_coalesce_usecs_irq) &&
1706                                            (!nesadapter->et_use_adaptive_rx_coalesce)) ||
1707                                           ((nesadapter->et_use_adaptive_rx_coalesce) &&
1708                                            (nesdev->deepcq_count > nesadapter->et_pkt_rate_low)))) ) {
1709                         if ((nesdev->int_req & NES_INT_TIMER) == 0) {
1710                                 /* Enable Periodic timer interrupts */
1711                                 nesdev->int_req |= NES_INT_TIMER;
1712                                 /* ack any pending periodic timer interrupts so we don't get an immediate interrupt */
1713                                 /* TODO: need to also ack other unused periodic timer values, get from nesadapter */
1714                                 nes_write32(nesdev->regs+NES_TIMER_STAT,
1715                                                 nesdev->timer_int_req  | ~(nesdev->nesadapter->timer_int_req));
1716                                 nes_write32(nesdev->regs+NES_INTF_INT_MASK,
1717                                                 ~(nesdev->intf_int_req | NES_INTF_PERIODIC_TIMER));
1718                         }
1719
1720                         if (unlikely(nesadapter->et_use_adaptive_rx_coalesce))
1721                         {
1722                                 nes_nic_init_timer(nesdev);
1723                         }
1724                         /* Enable interrupts, except CEQs */
1725                         nes_write32(nesdev->regs+NES_INT_MASK, 0x0000ffff | (~nesdev->int_req));
1726                 } else {
1727                         /* Enable interrupts, make sure timer is off */
1728                         nesdev->int_req &= ~NES_INT_TIMER;
1729                         nes_write32(nesdev->regs+NES_INTF_INT_MASK, ~(nesdev->intf_int_req));
1730                         nes_write32(nesdev->regs+NES_INT_MASK, ~nesdev->int_req);
1731                         nesadapter->tune_timer.timer_in_use_old = 0;
1732                 }
1733                 nesdev->deepcq_count = 0;
1734                 return 1;
1735         } else {
1736                 return 0;
1737         }
1738 }
1739
1740
1741 /**
1742  * nes_dpc
1743  */
1744 void nes_dpc(unsigned long param)
1745 {
1746         struct nes_device *nesdev = (struct nes_device *)param;
1747         struct nes_adapter *nesadapter = nesdev->nesadapter;
1748         u32 counter;
1749         u32 loop_counter = 0;
1750         u32 int_status_bit;
1751         u32 int_stat;
1752         u32 timer_stat;
1753         u32 temp_int_stat;
1754         u32 intf_int_stat;
1755         u32 debug_error;
1756         u32 processed_intf_int = 0;
1757         u16 processed_timer_int = 0;
1758         u16 completion_ints = 0;
1759         u16 timer_ints = 0;
1760
1761         /* nes_debug(NES_DBG_ISR, "\n"); */
1762
1763         do {
1764                 timer_stat = 0;
1765                 if (nesdev->napi_isr_ran) {
1766                         nesdev->napi_isr_ran = 0;
1767                         int_stat = nesdev->int_stat;
1768                 } else
1769                         int_stat = nes_read32(nesdev->regs+NES_INT_STAT);
1770                 if (processed_intf_int != 0)
1771                         int_stat &= nesdev->int_req & ~NES_INT_INTF;
1772                 else
1773                         int_stat &= nesdev->int_req;
1774                 if (processed_timer_int == 0) {
1775                         processed_timer_int = 1;
1776                         if (int_stat & NES_INT_TIMER) {
1777                                 timer_stat = nes_read32(nesdev->regs + NES_TIMER_STAT);
1778                                 if ((timer_stat & nesdev->timer_int_req) == 0) {
1779                                         int_stat &= ~NES_INT_TIMER;
1780                                 }
1781                         }
1782                 } else {
1783                         int_stat &= ~NES_INT_TIMER;
1784                 }
1785
1786                 if (int_stat) {
1787                         if (int_stat & ~(NES_INT_INTF|NES_INT_TIMER|NES_INT_MAC0|
1788                                         NES_INT_MAC1|NES_INT_MAC2|NES_INT_MAC3)) {
1789                                 /* Ack the interrupts */
1790                                 nes_write32(nesdev->regs+NES_INT_STAT,
1791                                                 (int_stat & ~(NES_INT_INTF|NES_INT_TIMER|NES_INT_MAC0|
1792                                                 NES_INT_MAC1|NES_INT_MAC2|NES_INT_MAC3)));
1793                         }
1794
1795                         temp_int_stat = int_stat;
1796                         for (counter = 0, int_status_bit = 1; counter < 16; counter++) {
1797                                 if (int_stat & int_status_bit) {
1798                                         nes_process_ceq(nesdev, &nesadapter->ceq[counter]);
1799                                         temp_int_stat &= ~int_status_bit;
1800                                         completion_ints = 1;
1801                                 }
1802                                 if (!(temp_int_stat & 0x0000ffff))
1803                                         break;
1804                                 int_status_bit <<= 1;
1805                         }
1806
1807                         /* Process the AEQ for this pci function */
1808                         int_status_bit = 1 << (16 + PCI_FUNC(nesdev->pcidev->devfn));
1809                         if (int_stat & int_status_bit) {
1810                                 nes_process_aeq(nesdev, &nesadapter->aeq[PCI_FUNC(nesdev->pcidev->devfn)]);
1811                         }
1812
1813                         /* Process the MAC interrupt for this pci function */
1814                         int_status_bit = 1 << (24 + nesdev->mac_index);
1815                         if (int_stat & int_status_bit) {
1816                                 nes_process_mac_intr(nesdev, nesdev->mac_index);
1817                         }
1818
1819                         if (int_stat & NES_INT_TIMER) {
1820                                 if (timer_stat & nesdev->timer_int_req) {
1821                                         nes_write32(nesdev->regs + NES_TIMER_STAT,
1822                                                         (timer_stat & nesdev->timer_int_req) |
1823                                                         ~(nesdev->nesadapter->timer_int_req));
1824                                         timer_ints = 1;
1825                                 }
1826                         }
1827
1828                         if (int_stat & NES_INT_INTF) {
1829                                 processed_intf_int = 1;
1830                                 intf_int_stat = nes_read32(nesdev->regs+NES_INTF_INT_STAT);
1831                                 intf_int_stat &= nesdev->intf_int_req;
1832                                 if (NES_INTF_INT_CRITERR & intf_int_stat) {
1833                                         debug_error = nes_read_indexed(nesdev, NES_IDX_DEBUG_ERROR_CONTROL_STATUS);
1834                                         printk(KERN_ERR PFX "Critical Error reported by device!!! 0x%02X\n",
1835                                                         (u16)debug_error);
1836                                         nes_write_indexed(nesdev, NES_IDX_DEBUG_ERROR_CONTROL_STATUS,
1837                                                         0x01010000 | (debug_error & 0x0000ffff));
1838                                         /* BUG(); */
1839                                         if (crit_err_count++ > 10)
1840                                                 nes_write_indexed(nesdev, NES_IDX_DEBUG_ERROR_MASKS1, 1 << 0x17);
1841                                 }
1842                                 if (NES_INTF_INT_PCIERR & intf_int_stat) {
1843                                         printk(KERN_ERR PFX "PCI Error reported by device!!!\n");
1844                                         BUG();
1845                                 }
1846                                 if (NES_INTF_INT_AEQ_OFLOW & intf_int_stat) {
1847                                         printk(KERN_ERR PFX "AEQ Overflow reported by device!!!\n");
1848                                         BUG();
1849                                 }
1850                                 nes_write32(nesdev->regs+NES_INTF_INT_STAT, intf_int_stat);
1851                         }
1852
1853                         if (int_stat & NES_INT_TSW) {
1854                         }
1855                 }
1856                 /* Don't use the interface interrupt bit stay in loop */
1857                 int_stat &= ~NES_INT_INTF|NES_INT_TIMER|NES_INT_MAC0|
1858                                 NES_INT_MAC1|NES_INT_MAC2|NES_INT_MAC3;
1859         } while ((int_stat != 0) && (loop_counter++ < MAX_DPC_ITERATIONS));
1860
1861         if (timer_ints == 1) {
1862                 if ((nesadapter->et_rx_coalesce_usecs_irq) || (nesadapter->et_use_adaptive_rx_coalesce)) {
1863                         if (completion_ints == 0) {
1864                                 nesdev->timer_only_int_count++;
1865                                 if (nesdev->timer_only_int_count>=nesadapter->timer_int_limit) {
1866                                         nesdev->timer_only_int_count = 0;
1867                                         nesdev->int_req &= ~NES_INT_TIMER;
1868                                         nes_write32(nesdev->regs + NES_INTF_INT_MASK, ~(nesdev->intf_int_req));
1869                                         nes_write32(nesdev->regs+NES_INT_MASK, ~nesdev->int_req);
1870                                         nesdev->nesadapter->tune_timer.timer_in_use_old = 0;
1871                                 } else {
1872                                         nes_write32(nesdev->regs+NES_INT_MASK, 0x0000ffff|(~nesdev->int_req));
1873                                 }
1874                         } else {
1875                                 if (unlikely(nesadapter->et_use_adaptive_rx_coalesce))
1876                                 {
1877                                         nes_nic_init_timer(nesdev);
1878                                 }
1879                                 nesdev->timer_only_int_count = 0;
1880                                 nes_write32(nesdev->regs+NES_INT_MASK, 0x0000ffff|(~nesdev->int_req));
1881                         }
1882                 } else {
1883                         nesdev->timer_only_int_count = 0;
1884                         nesdev->int_req &= ~NES_INT_TIMER;
1885                         nes_write32(nesdev->regs+NES_INTF_INT_MASK, ~(nesdev->intf_int_req));
1886                         nes_write32(nesdev->regs+NES_TIMER_STAT,
1887                                         nesdev->timer_int_req | ~(nesdev->nesadapter->timer_int_req));
1888                         nes_write32(nesdev->regs+NES_INT_MASK, ~nesdev->int_req);
1889                 }
1890         } else {
1891                 if ( (completion_ints == 1) &&
1892                          (((nesadapter->et_rx_coalesce_usecs_irq) &&
1893                            (!nesadapter->et_use_adaptive_rx_coalesce)) ||
1894                           ((nesdev->deepcq_count > nesadapter->et_pkt_rate_low) &&
1895                            (nesadapter->et_use_adaptive_rx_coalesce) )) ) {
1896                         /* nes_debug(NES_DBG_ISR, "Enabling periodic timer interrupt.\n" ); */
1897                         nesdev->timer_only_int_count = 0;
1898                         nesdev->int_req |= NES_INT_TIMER;
1899                         nes_write32(nesdev->regs+NES_TIMER_STAT,
1900                                         nesdev->timer_int_req | ~(nesdev->nesadapter->timer_int_req));
1901                         nes_write32(nesdev->regs+NES_INTF_INT_MASK,
1902                                         ~(nesdev->intf_int_req | NES_INTF_PERIODIC_TIMER));
1903                         nes_write32(nesdev->regs+NES_INT_MASK, 0x0000ffff | (~nesdev->int_req));
1904                 } else {
1905                         nes_write32(nesdev->regs+NES_INT_MASK, ~nesdev->int_req);
1906                 }
1907         }
1908         nesdev->deepcq_count = 0;
1909 }
1910
1911
1912 /**
1913  * nes_process_ceq
1914  */
1915 void nes_process_ceq(struct nes_device *nesdev, struct nes_hw_ceq *ceq)
1916 {
1917         u64 u64temp;
1918         struct nes_hw_cq *cq;
1919         u32 head;
1920         u32 ceq_size;
1921
1922         /* nes_debug(NES_DBG_CQ, "\n"); */
1923         head = ceq->ceq_head;
1924         ceq_size = ceq->ceq_size;
1925
1926         do {
1927                 if (le32_to_cpu(ceq->ceq_vbase[head].ceqe_words[NES_CEQE_CQ_CTX_HIGH_IDX]) &
1928                                 NES_CEQE_VALID) {
1929                         u64temp = (((u64)(le32_to_cpu(ceq->ceq_vbase[head].ceqe_words[NES_CEQE_CQ_CTX_HIGH_IDX])))<<32) |
1930                                                 ((u64)(le32_to_cpu(ceq->ceq_vbase[head].ceqe_words[NES_CEQE_CQ_CTX_LOW_IDX])));
1931                         u64temp <<= 1;
1932                         cq = *((struct nes_hw_cq **)&u64temp);
1933                         /* nes_debug(NES_DBG_CQ, "pCQ = %p\n", cq); */
1934                         barrier();
1935                         ceq->ceq_vbase[head].ceqe_words[NES_CEQE_CQ_CTX_HIGH_IDX] = 0;
1936
1937                         /* call the event handler */
1938                         cq->ce_handler(nesdev, cq);
1939
1940                         if (++head >= ceq_size)
1941                                 head = 0;
1942                 } else {
1943                         break;
1944                 }
1945
1946         } while (1);
1947
1948         ceq->ceq_head = head;
1949 }
1950
1951
1952 /**
1953  * nes_process_aeq
1954  */
1955 void nes_process_aeq(struct nes_device *nesdev, struct nes_hw_aeq *aeq)
1956 {
1957 //      u64 u64temp;
1958         u32 head;
1959         u32 aeq_size;
1960         u32 aeqe_misc;
1961         u32 aeqe_cq_id;
1962         struct nes_hw_aeqe volatile *aeqe;
1963
1964         head = aeq->aeq_head;
1965         aeq_size = aeq->aeq_size;
1966
1967         do {
1968                 aeqe = &aeq->aeq_vbase[head];
1969                 if ((le32_to_cpu(aeqe->aeqe_words[NES_AEQE_MISC_IDX]) & NES_AEQE_VALID) == 0)
1970                         break;
1971                 aeqe_misc  = le32_to_cpu(aeqe->aeqe_words[NES_AEQE_MISC_IDX]);
1972                 aeqe_cq_id = le32_to_cpu(aeqe->aeqe_words[NES_AEQE_COMP_QP_CQ_ID_IDX]);
1973                 if (aeqe_misc & (NES_AEQE_QP|NES_AEQE_CQ)) {
1974                         if (aeqe_cq_id >= NES_FIRST_QPN) {
1975                                 /* dealing with an accelerated QP related AE */
1976 //                              u64temp = (((u64)(le32_to_cpu(aeqe->aeqe_words[NES_AEQE_COMP_CTXT_HIGH_IDX])))<<32) |
1977 //                                      ((u64)(le32_to_cpu(aeqe->aeqe_words[NES_AEQE_COMP_CTXT_LOW_IDX])));
1978                                 nes_process_iwarp_aeqe(nesdev, (struct nes_hw_aeqe *)aeqe);
1979                         } else {
1980                                 /* TODO: dealing with a CQP related AE */
1981                                 nes_debug(NES_DBG_AEQ, "Processing CQP related AE, misc = 0x%04X\n",
1982                                                 (u16)(aeqe_misc >> 16));
1983                         }
1984                 }
1985
1986                 aeqe->aeqe_words[NES_AEQE_MISC_IDX] = 0;
1987
1988                 if (++head >= aeq_size)
1989                         head = 0;
1990         }
1991         while (1);
1992         aeq->aeq_head = head;
1993 }
1994
1995 static void nes_reset_link(struct nes_device *nesdev, u32 mac_index)
1996 {
1997         struct nes_adapter *nesadapter = nesdev->nesadapter;
1998         u32 reset_value;
1999         u32 i=0;
2000         u32 u32temp;
2001
2002         if (nesadapter->hw_rev == NE020_REV) {
2003                 return;
2004         }
2005         mh_detected++;
2006
2007         reset_value = nes_read32(nesdev->regs+NES_SOFTWARE_RESET);
2008
2009         if ((mac_index == 0) || ((mac_index == 1) && (nesadapter->OneG_Mode)))
2010                 reset_value |= 0x0000001d;
2011         else
2012                 reset_value |= 0x0000002d;
2013
2014         if (4 <= (nesadapter->link_interrupt_count[mac_index] / ((u16)NES_MAX_LINK_INTERRUPTS))) {
2015                 if ((!nesadapter->OneG_Mode) && (nesadapter->port_count == 2)) {
2016                         nesadapter->link_interrupt_count[0] = 0;
2017                         nesadapter->link_interrupt_count[1] = 0;
2018                         u32temp = nes_read_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_CONTROL1);
2019                         if (0x00000040 & u32temp)
2020                                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_CONTROL1, 0x0000F088);
2021                         else
2022                                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_CONTROL1, 0x0000F0C8);
2023
2024                         reset_value |= 0x0000003d;
2025                 }
2026                 nesadapter->link_interrupt_count[mac_index] = 0;
2027         }
2028
2029         nes_write32(nesdev->regs+NES_SOFTWARE_RESET, reset_value);
2030
2031         while (((nes_read32(nesdev->regs+NES_SOFTWARE_RESET)
2032                         & 0x00000040) != 0x00000040) && (i++ < 5000));
2033
2034         if (0x0000003d == (reset_value & 0x0000003d)) {
2035                 u32 pcs_control_status0, pcs_control_status1;
2036
2037                 for (i = 0; i < 10; i++) {
2038                         pcs_control_status0 = nes_read_indexed(nesdev, NES_IDX_PHY_PCS_CONTROL_STATUS0);
2039                         pcs_control_status1 = nes_read_indexed(nesdev, NES_IDX_PHY_PCS_CONTROL_STATUS0 + 0x200);
2040                         if (((0x0F000000 == (pcs_control_status0 & 0x0F000000))
2041                              && (pcs_control_status0 & 0x00100000))
2042                             || ((0x0F000000 == (pcs_control_status1 & 0x0F000000))
2043                                 && (pcs_control_status1 & 0x00100000)))
2044                                 continue;
2045                         else
2046                                 break;
2047                 }
2048                 if (10 == i) {
2049                         u32temp = nes_read_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_CONTROL1);
2050                         if (0x00000040 & u32temp)
2051                                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_CONTROL1, 0x0000F088);
2052                         else
2053                                 nes_write_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_CONTROL1, 0x0000F0C8);
2054
2055                         nes_write32(nesdev->regs+NES_SOFTWARE_RESET, reset_value);
2056
2057                         while (((nes_read32(nesdev->regs + NES_SOFTWARE_RESET)
2058                                  & 0x00000040) != 0x00000040) && (i++ < 5000));
2059                 }
2060         }
2061 }
2062
2063 /**
2064  * nes_process_mac_intr
2065  */
2066 void nes_process_mac_intr(struct nes_device *nesdev, u32 mac_number)
2067 {
2068         unsigned long flags;
2069         u32 pcs_control_status;
2070         struct nes_adapter *nesadapter = nesdev->nesadapter;
2071         struct nes_vnic *nesvnic;
2072         u32 mac_status;
2073         u32 mac_index = nesdev->mac_index;
2074         u32 u32temp;
2075         u16 phy_data;
2076         u16 temp_phy_data;
2077
2078         spin_lock_irqsave(&nesadapter->phy_lock, flags);
2079         if (nesadapter->mac_sw_state[mac_number] != NES_MAC_SW_IDLE) {
2080                 spin_unlock_irqrestore(&nesadapter->phy_lock, flags);
2081                 return;
2082         }
2083         nesadapter->mac_sw_state[mac_number] = NES_MAC_SW_INTERRUPT;
2084         spin_unlock_irqrestore(&nesadapter->phy_lock, flags);
2085
2086         /* ack the MAC interrupt */
2087         mac_status = nes_read_indexed(nesdev, NES_IDX_MAC_INT_STATUS + (mac_index * 0x200));
2088         /* Clear the interrupt */
2089         nes_write_indexed(nesdev, NES_IDX_MAC_INT_STATUS + (mac_index * 0x200), mac_status);
2090
2091         nes_debug(NES_DBG_PHY, "MAC%u interrupt status = 0x%X.\n", mac_number, mac_status);
2092
2093         if (mac_status & (NES_MAC_INT_LINK_STAT_CHG | NES_MAC_INT_XGMII_EXT)) {
2094                 nesdev->link_status_interrupts++;
2095                 if (0 == (++nesadapter->link_interrupt_count[mac_index] % ((u16)NES_MAX_LINK_INTERRUPTS))) {
2096                         spin_lock_irqsave(&nesadapter->phy_lock, flags);
2097                         nes_reset_link(nesdev, mac_index);
2098                         spin_unlock_irqrestore(&nesadapter->phy_lock, flags);
2099                 }
2100                 /* read the PHY interrupt status register */
2101                 if (nesadapter->OneG_Mode) {
2102                         do {
2103                                 nes_read_1G_phy_reg(nesdev, 0x1a,
2104                                                 nesadapter->phy_index[mac_index], &phy_data);
2105                                 nes_debug(NES_DBG_PHY, "Phy%d data from register 0x1a = 0x%X.\n",
2106                                                 nesadapter->phy_index[mac_index], phy_data);
2107                         } while (phy_data&0x8000);
2108
2109                         temp_phy_data = 0;
2110                         do {
2111                                 nes_read_1G_phy_reg(nesdev, 0x11,
2112                                                 nesadapter->phy_index[mac_index], &phy_data);
2113                                 nes_debug(NES_DBG_PHY, "Phy%d data from register 0x11 = 0x%X.\n",
2114                                                 nesadapter->phy_index[mac_index], phy_data);
2115                                 if (temp_phy_data == phy_data)
2116                                         break;
2117                                 temp_phy_data = phy_data;
2118                         } while (1);
2119
2120                         nes_read_1G_phy_reg(nesdev, 0x1e,
2121                                         nesadapter->phy_index[mac_index], &phy_data);
2122                         nes_debug(NES_DBG_PHY, "Phy%d data from register 0x1e = 0x%X.\n",
2123                                         nesadapter->phy_index[mac_index], phy_data);
2124
2125                         nes_read_1G_phy_reg(nesdev, 1,
2126                                         nesadapter->phy_index[mac_index], &phy_data);
2127                         nes_debug(NES_DBG_PHY, "1G phy%u data from register 1 = 0x%X\n",
2128                                         nesadapter->phy_index[mac_index], phy_data);
2129
2130                         if (temp_phy_data & 0x1000) {
2131                                 nes_debug(NES_DBG_PHY, "The Link is up according to the PHY\n");
2132                                 phy_data = 4;
2133                         } else {
2134                                 nes_debug(NES_DBG_PHY, "The Link is down according to the PHY\n");
2135                         }
2136                 }
2137                 nes_debug(NES_DBG_PHY, "Eth SERDES Common Status: 0=0x%08X, 1=0x%08X\n",
2138                                 nes_read_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_STATUS0),
2139                                 nes_read_indexed(nesdev, NES_IDX_ETH_SERDES_COMMON_STATUS0+0x200));
2140                 pcs_control_status = nes_read_indexed(nesdev,
2141                                 NES_IDX_PHY_PCS_CONTROL_STATUS0 + ((mac_index&1)*0x200));
2142                 pcs_control_status = nes_read_indexed(nesdev,
2143                                 NES_IDX_PHY_PCS_CONTROL_STATUS0 + ((mac_index&1)*0x200));
2144                 nes_debug(NES_DBG_PHY, "PCS PHY Control/Status%u: 0x%08X\n",
2145                                 mac_index, pcs_control_status);
2146                 if (nesadapter->OneG_Mode) {
2147                         u32temp = 0x01010000;
2148                         if (nesadapter->port_count > 2) {
2149                                 u32temp |= 0x02020000;
2150                         }
2151                         if ((pcs_control_status & u32temp)!= u32temp) {
2152                                 phy_data = 0;
2153                                 nes_debug(NES_DBG_PHY, "PCS says the link is down\n");
2154                         }
2155                 } else if (nesadapter->phy_type[mac_index] == NES_PHY_TYPE_IRIS) {
2156                         nes_read_10G_phy_reg(nesdev, 1, nesadapter->phy_index[mac_index]);
2157                         temp_phy_data = (u16)nes_read_indexed(nesdev,
2158                                                                 NES_IDX_MAC_MDIO_CONTROL);
2159                         u32temp = 20;
2160                         do {
2161                                 nes_read_10G_phy_reg(nesdev, 1, nesadapter->phy_index[mac_index]);
2162                                 phy_data = (u16)nes_read_indexed(nesdev,
2163                                                                 NES_IDX_MAC_MDIO_CONTROL);
2164                                 if ((phy_data == temp_phy_data) || (!(--u32temp)))
2165                                         break;
2166                                 temp_phy_data = phy_data;
2167                         } while (1);
2168                         nes_debug(NES_DBG_PHY, "%s: Phy data = 0x%04X, link was %s.\n",
2169                                 __FUNCTION__, phy_data, nesadapter->mac_link_down ? "DOWN" : "UP");
2170
2171                 } else {
2172                         phy_data = (0x0f0f0000 == (pcs_control_status & 0x0f1f0000)) ? 4 : 0;
2173                 }
2174
2175                 if (phy_data & 0x0004) {
2176                         nesadapter->mac_link_down[mac_index] = 0;
2177                         list_for_each_entry(nesvnic, &nesadapter->nesvnic_list[mac_index], list) {
2178                                 nes_debug(NES_DBG_PHY, "The Link is UP!!.  linkup was %d\n",
2179                                                 nesvnic->linkup);
2180                                 if (nesvnic->linkup == 0) {
2181                                         printk(PFX "The Link is now up for port %u, netdev %p.\n",
2182                                                         mac_index, nesvnic->netdev);
2183                                         if (netif_queue_stopped(nesvnic->netdev))
2184                                                 netif_start_queue(nesvnic->netdev);
2185                                         nesvnic->linkup = 1;
2186                                         netif_carrier_on(nesvnic->netdev);
2187                                 }
2188                         }
2189                 } else {
2190                         nesadapter->mac_link_down[mac_index] = 1;
2191                         list_for_each_entry(nesvnic, &nesadapter->nesvnic_list[mac_index], list) {
2192                                 nes_debug(NES_DBG_PHY, "The Link is Down!!. linkup was %d\n",
2193                                                 nesvnic->linkup);
2194                                 if (nesvnic->linkup == 1) {
2195                                         printk(PFX "The Link is now down for port %u, netdev %p.\n",
2196                                                         mac_index, nesvnic->netdev);
2197                                         if (!(netif_queue_stopped(nesvnic->netdev)))
2198                                                 netif_stop_queue(nesvnic->netdev);
2199                                         nesvnic->linkup = 0;
2200                                         netif_carrier_off(nesvnic->netdev);
2201                                 }
2202                         }
2203                 }
2204         }
2205
2206         nesadapter->mac_sw_state[mac_number] = NES_MAC_SW_IDLE;
2207 }
2208
2209
2210
2211 void nes_nic_napi_ce_handler(struct nes_device *nesdev, struct nes_hw_nic_cq *cq)
2212 {
2213         struct nes_vnic *nesvnic = container_of(cq, struct nes_vnic, nic_cq);
2214
2215         netif_rx_schedule(nesdev->netdev[nesvnic->netdev_index], &nesvnic->napi);
2216 }
2217
2218
2219 /* The MAX_RQES_TO_PROCESS defines how many max read requests to complete before
2220 * getting out of nic_ce_handler
2221 */
2222 #define MAX_RQES_TO_PROCESS     384
2223
2224 /**
2225  * nes_nic_ce_handler
2226  */
2227 void nes_nic_ce_handler(struct nes_device *nesdev, struct nes_hw_nic_cq *cq)
2228 {
2229         u64 u64temp;
2230         dma_addr_t bus_address;
2231         struct nes_hw_nic *nesnic;
2232         struct nes_vnic *nesvnic = container_of(cq, struct nes_vnic, nic_cq);
2233         struct nes_adapter *nesadapter = nesdev->nesadapter;
2234         struct nes_hw_nic_rq_wqe *nic_rqe;
2235         struct nes_hw_nic_sq_wqe *nic_sqe;
2236         struct sk_buff *skb;
2237         struct sk_buff *rx_skb;
2238         __le16 *wqe_fragment_length;
2239         u32 head;
2240         u32 cq_size;
2241         u32 rx_pkt_size;
2242         u32 cqe_count=0;
2243         u32 cqe_errv;
2244         u32 cqe_misc;
2245         u16 wqe_fragment_index = 1;     /* first fragment (0) is used by copy buffer */
2246         u16 vlan_tag;
2247         u16 pkt_type;
2248         u16 rqes_processed = 0;
2249         u8 sq_cqes = 0;
2250
2251         head = cq->cq_head;
2252         cq_size = cq->cq_size;
2253         cq->cqes_pending = 1;
2254         do {
2255                 if (le32_to_cpu(cq->cq_vbase[head].cqe_words[NES_NIC_CQE_MISC_IDX]) &
2256                                 NES_NIC_CQE_VALID) {
2257                         nesnic = &nesvnic->nic;
2258                         cqe_misc = le32_to_cpu(cq->cq_vbase[head].cqe_words[NES_NIC_CQE_MISC_IDX]);
2259                         if (cqe_misc & NES_NIC_CQE_SQ) {
2260                                 sq_cqes++;
2261                                 wqe_fragment_index = 1;
2262                                 nic_sqe = &nesnic->sq_vbase[nesnic->sq_tail];
2263                                 skb = nesnic->tx_skb[nesnic->sq_tail];
2264                                 wqe_fragment_length = (__le16 *)&nic_sqe->wqe_words[NES_NIC_SQ_WQE_LENGTH_0_TAG_IDX];
2265                                 /* bump past the vlan tag */
2266                                 wqe_fragment_length++;
2267                                 if (le16_to_cpu(wqe_fragment_length[wqe_fragment_index]) != 0) {
2268                                         u64temp = (u64) le32_to_cpu(nic_sqe->wqe_words[NES_NIC_SQ_WQE_FRAG0_LOW_IDX+wqe_fragment_index*2]);
2269                                         u64temp += ((u64)le32_to_cpu(nic_sqe->wqe_words[NES_NIC_SQ_WQE_FRAG0_HIGH_IDX+wqe_fragment_index*2]))<<32;
2270                                         bus_address = (dma_addr_t)u64temp;
2271                                         if (test_and_clear_bit(nesnic->sq_tail, nesnic->first_frag_overflow)) {
2272                                                 pci_unmap_single(nesdev->pcidev,
2273                                                                 bus_address,
2274                                                                 le16_to_cpu(wqe_fragment_length[wqe_fragment_index++]),
2275                                                                 PCI_DMA_TODEVICE);
2276                                         }
2277                                         for (; wqe_fragment_index < 5; wqe_fragment_index++) {
2278                                                 if (wqe_fragment_length[wqe_fragment_index]) {
2279                                                         u64temp = le32_to_cpu(nic_sqe->wqe_words[NES_NIC_SQ_WQE_FRAG0_LOW_IDX+wqe_fragment_index*2]);
2280                                                         u64temp += ((u64)le32_to_cpu(nic_sqe->wqe_words[NES_NIC_SQ_WQE_FRAG0_HIGH_IDX+wqe_fragment_index*2]))<<32;
2281                                                         bus_address = (dma_addr_t)u64temp;
2282                                                         pci_unmap_page(nesdev->pcidev,
2283                                                                         bus_address,
2284                                                                         le16_to_cpu(wqe_fragment_length[wqe_fragment_index]),
2285                                                                         PCI_DMA_TODEVICE);
2286                                                 } else
2287                                                         break;
2288                                         }
2289                                         if (skb)
2290                                                 dev_kfree_skb_any(skb);
2291                                 }
2292                                 nesnic->sq_tail++;
2293                                 nesnic->sq_tail &= nesnic->sq_size-1;
2294                                 if (sq_cqes > 128) {
2295                                         barrier();
2296                                 /* restart the queue if it had been stopped */
2297                                 if (netif_queue_stopped(nesvnic->netdev))
2298                                         netif_wake_queue(nesvnic->netdev);
2299                                         sq_cqes = 0;
2300                                 }
2301                         } else {
2302                                 rqes_processed ++;
2303
2304                                 cq->rx_cqes_completed++;
2305                                 cq->rx_pkts_indicated++;
2306                                 rx_pkt_size = cqe_misc & 0x0000ffff;
2307                                 nic_rqe = &nesnic->rq_vbase[nesnic->rq_tail];
2308                                 /* Get the skb */
2309                                 rx_skb = nesnic->rx_skb[nesnic->rq_tail];
2310                                 nic_rqe = &nesnic->rq_vbase[nesvnic->nic.rq_tail];
2311                                 bus_address = (dma_addr_t)le32_to_cpu(nic_rqe->wqe_words[NES_NIC_RQ_WQE_FRAG0_LOW_IDX]);
2312                                 bus_address += ((u64)le32_to_cpu(nic_rqe->wqe_words[NES_NIC_RQ_WQE_FRAG0_HIGH_IDX])) << 32;
2313                                 pci_unmap_single(nesdev->pcidev, bus_address,
2314                                                 nesvnic->max_frame_size, PCI_DMA_FROMDEVICE);
2315                                 /* rx_skb->tail = rx_skb->data + rx_pkt_size; */
2316                                 /* rx_skb->len = rx_pkt_size; */
2317                                 rx_skb->len = 0;  /* TODO: see if this is necessary */
2318                                 skb_put(rx_skb, rx_pkt_size);
2319                                 rx_skb->protocol = eth_type_trans(rx_skb, nesvnic->netdev);
2320                                 nesnic->rq_tail++;
2321                                 nesnic->rq_tail &= nesnic->rq_size - 1;
2322
2323                                 atomic_inc(&nesvnic->rx_skbs_needed);
2324                                 if (atomic_read(&nesvnic->rx_skbs_needed) > (nesvnic->nic.rq_size>>1)) {
2325                                         nes_write32(nesdev->regs+NES_CQE_ALLOC,
2326                                                         cq->cq_number | (cqe_count << 16));
2327 //                                      nesadapter->tune_timer.cq_count += cqe_count;
2328                                         nesdev->currcq_count += cqe_count;
2329                                         cqe_count = 0;
2330                                         nes_replenish_nic_rq(nesvnic);
2331                                 }
2332                                 pkt_type = (u16)(le32_to_cpu(cq->cq_vbase[head].cqe_words[NES_NIC_CQE_TAG_PKT_TYPE_IDX]));
2333                                 cqe_errv = (cqe_misc & NES_NIC_CQE_ERRV_MASK) >> NES_NIC_CQE_ERRV_SHIFT;
2334                                 rx_skb->ip_summed = CHECKSUM_NONE;
2335
2336                                 if ((NES_PKT_TYPE_TCPV4_BITS == (pkt_type & NES_PKT_TYPE_TCPV4_MASK)) ||
2337                                                 (NES_PKT_TYPE_UDPV4_BITS == (pkt_type & NES_PKT_TYPE_UDPV4_MASK))) {
2338                                         if ((cqe_errv &
2339                                                         (NES_NIC_ERRV_BITS_IPV4_CSUM_ERR | NES_NIC_ERRV_BITS_TCPUDP_CSUM_ERR |
2340                                                         NES_NIC_ERRV_BITS_IPH_ERR | NES_NIC_ERRV_BITS_WQE_OVERRUN)) == 0) {
2341                                                 if (nesvnic->rx_checksum_disabled == 0) {
2342                                                         rx_skb->ip_summed = CHECKSUM_UNNECESSARY;
2343                                                 }
2344                                         } else
2345                                                 nes_debug(NES_DBG_CQ, "%s: unsuccessfully checksummed TCP or UDP packet."
2346                                                                 " errv = 0x%X, pkt_type = 0x%X.\n",
2347                                                                 nesvnic->netdev->name, cqe_errv, pkt_type);
2348
2349                                 } else if ((pkt_type & NES_PKT_TYPE_IPV4_MASK) == NES_PKT_TYPE_IPV4_BITS) {
2350                                         if ((cqe_errv &
2351                                                         (NES_NIC_ERRV_BITS_IPV4_CSUM_ERR | NES_NIC_ERRV_BITS_IPH_ERR |
2352                                                         NES_NIC_ERRV_BITS_WQE_OVERRUN)) == 0) {
2353                                                 if (nesvnic->rx_checksum_disabled == 0) {
2354                                                         rx_skb->ip_summed = CHECKSUM_UNNECESSARY;
2355                                                         /* nes_debug(NES_DBG_CQ, "%s: Reporting successfully checksummed IPv4 packet.\n",
2356                                                                   nesvnic->netdev->name); */
2357                                                 }
2358                                         } else
2359                                                 nes_debug(NES_DBG_CQ, "%s: unsuccessfully checksummed TCP or UDP packet."
2360                                                                 " errv = 0x%X, pkt_type = 0x%X.\n",
2361                                                                 nesvnic->netdev->name, cqe_errv, pkt_type);
2362                                         }
2363                                 /* nes_debug(NES_DBG_CQ, "pkt_type=%x, APBVT_MASK=%x\n",
2364                                                         pkt_type, (pkt_type & NES_PKT_TYPE_APBVT_MASK)); */
2365
2366                                 if ((pkt_type & NES_PKT_TYPE_APBVT_MASK) == NES_PKT_TYPE_APBVT_BITS) {
2367                                         nes_cm_recv(rx_skb, nesvnic->netdev);
2368                                 } else {
2369                                         if ((cqe_misc & NES_NIC_CQE_TAG_VALID) && (nesvnic->vlan_grp != NULL)) {
2370                                                 vlan_tag = (u16)(le32_to_cpu(
2371                                                                 cq->cq_vbase[head].cqe_words[NES_NIC_CQE_TAG_PKT_TYPE_IDX])
2372                                                                 >> 16);
2373                                                 nes_debug(NES_DBG_CQ, "%s: Reporting stripped VLAN packet. Tag = 0x%04X\n",
2374                                                                 nesvnic->netdev->name, vlan_tag);
2375                                                 nes_vlan_rx(rx_skb, nesvnic->vlan_grp, vlan_tag);
2376                                         } else {
2377                                                 nes_netif_rx(rx_skb);
2378                                         }
2379                                 }
2380
2381                                 nesvnic->netdev->last_rx = jiffies;
2382                                 /* nesvnic->netstats.rx_packets++; */
2383                                 /* nesvnic->netstats.rx_bytes += rx_pkt_size; */
2384                         }
2385
2386                         cq->cq_vbase[head].cqe_words[NES_NIC_CQE_MISC_IDX] = 0;
2387                         /* Accounting... */
2388                         cqe_count++;
2389                         if (++head >= cq_size)
2390                                 head = 0;
2391                         if (cqe_count == 255) {
2392                                 /* Replenish Nic CQ */
2393                                 nes_write32(nesdev->regs+NES_CQE_ALLOC,
2394                                                 cq->cq_number | (cqe_count << 16));
2395 //                              nesdev->nesadapter->tune_timer.cq_count += cqe_count;
2396                                 nesdev->currcq_count += cqe_count;
2397                                 cqe_count = 0;
2398                         }
2399
2400                         if (cq->rx_cqes_completed >= nesvnic->budget)
2401                                 break;
2402                 } else {
2403                         cq->cqes_pending = 0;
2404                         break;
2405                 }
2406
2407         } while (1);
2408
2409         if (sq_cqes) {
2410                 barrier();
2411                 /* restart the queue if it had been stopped */
2412                 if (netif_queue_stopped(nesvnic->netdev))
2413                         netif_wake_queue(nesvnic->netdev);
2414         }
2415
2416         cq->cq_head = head;
2417         /* nes_debug(NES_DBG_CQ, "CQ%u Processed = %u cqes, new head = %u.\n",
2418                         cq->cq_number, cqe_count, cq->cq_head); */
2419         cq->cqe_allocs_pending = cqe_count;
2420         if (unlikely(nesadapter->et_use_adaptive_rx_coalesce))
2421         {
2422 //              nesdev->nesadapter->tune_timer.cq_count += cqe_count;
2423                 nesdev->currcq_count += cqe_count;
2424                 nes_nic_tune_timer(nesdev);
2425         }
2426         if (atomic_read(&nesvnic->rx_skbs_needed))
2427                 nes_replenish_nic_rq(nesvnic);
2428         }
2429
2430
2431 /**
2432  * nes_cqp_ce_handler
2433  */
2434 void nes_cqp_ce_handler(struct nes_device *nesdev, struct nes_hw_cq *cq)
2435 {
2436         u64 u64temp;
2437         unsigned long flags;
2438         struct nes_hw_cqp *cqp = NULL;
2439         struct nes_cqp_request *cqp_request;
2440         struct nes_hw_cqp_wqe *cqp_wqe;
2441         u32 head;
2442         u32 cq_size;
2443         u32 cqe_count=0;
2444         u32 error_code;
2445         /* u32 counter; */
2446
2447         head = cq->cq_head;
2448         cq_size = cq->cq_size;
2449
2450         do {
2451                 /* process the CQE */
2452                 /* nes_debug(NES_DBG_CQP, "head=%u cqe_words=%08X\n", head,
2453                           le32_to_cpu(cq->cq_vbase[head].cqe_words[NES_CQE_OPCODE_IDX])); */
2454
2455                 if (le32_to_cpu(cq->cq_vbase[head].cqe_words[NES_CQE_OPCODE_IDX]) & NES_CQE_VALID) {
2456                         u64temp = (((u64)(le32_to_cpu(cq->cq_vbase[head].
2457                                         cqe_words[NES_CQE_COMP_COMP_CTX_HIGH_IDX])))<<32) |
2458                                         ((u64)(le32_to_cpu(cq->cq_vbase[head].
2459                                         cqe_words[NES_CQE_COMP_COMP_CTX_LOW_IDX])));
2460                         cqp = *((struct nes_hw_cqp **)&u64temp);
2461
2462                         error_code = le32_to_cpu(cq->cq_vbase[head].cqe_words[NES_CQE_ERROR_CODE_IDX]);
2463                         if (error_code) {
2464                                 nes_debug(NES_DBG_CQP, "Bad Completion code for opcode 0x%02X from CQP,"
2465                                                 " Major/Minor codes = 0x%04X:%04X.\n",
2466                                                 le32_to_cpu(cq->cq_vbase[head].cqe_words[NES_CQE_OPCODE_IDX])&0x3f,
2467                                                 (u16)(error_code >> 16),
2468                                                 (u16)error_code);
2469                                 nes_debug(NES_DBG_CQP, "cqp: qp_id=%u, sq_head=%u, sq_tail=%u\n",
2470                                                 cqp->qp_id, cqp->sq_head, cqp->sq_tail);
2471                         }
2472
2473                         u64temp = (((u64)(le32_to_cpu(nesdev->cqp.sq_vbase[cqp->sq_tail].
2474                                         wqe_words[NES_CQP_WQE_COMP_SCRATCH_HIGH_IDX])))<<32) |
2475                                         ((u64)(le32_to_cpu(nesdev->cqp.sq_vbase[cqp->sq_tail].
2476                                         wqe_words[NES_CQP_WQE_COMP_SCRATCH_LOW_IDX])));
2477                         cqp_request = *((struct nes_cqp_request **)&u64temp);
2478                         if (cqp_request) {
2479                                 if (cqp_request->waiting) {
2480                                         /* nes_debug(NES_DBG_CQP, "%s: Waking up requestor\n"); */
2481                                         cqp_request->major_code = (u16)(error_code >> 16);
2482                                         cqp_request->minor_code = (u16)error_code;
2483                                         barrier();
2484                                         cqp_request->request_done = 1;
2485                                         wake_up(&cqp_request->waitq);
2486                                         if (atomic_dec_and_test(&cqp_request->refcount)) {
2487                                                 nes_debug(NES_DBG_CQP, "CQP request %p (opcode 0x%02X) freed.\n",
2488                                                                 cqp_request,
2489                                                                 le32_to_cpu(cqp_request->cqp_wqe.wqe_words[NES_CQP_WQE_OPCODE_IDX])&0x3f);
2490                                                 if (cqp_request->dynamic) {
2491                                                         kfree(cqp_request);
2492                                                 } else {
2493                                                         spin_lock_irqsave(&nesdev->cqp.lock, flags);
2494                                                         list_add_tail(&cqp_request->list, &nesdev->cqp_avail_reqs);
2495                                                         spin_unlock_irqrestore(&nesdev->cqp.lock, flags);
2496                                                 }
2497                                         }
2498                                 } else if (cqp_request->callback) {
2499                                         /* Envoke the callback routine */
2500                                         cqp_request->cqp_callback(nesdev, cqp_request);
2501                                         if (cqp_request->dynamic) {
2502                                                 kfree(cqp_request);
2503                                         } else {
2504                                                 spin_lock_irqsave(&nesdev->cqp.lock, flags);
2505                                                 list_add_tail(&cqp_request->list, &nesdev->cqp_avail_reqs);
2506                                                 spin_unlock_irqrestore(&nesdev->cqp.lock, flags);
2507                                         }
2508                                 } else {
2509                                         nes_debug(NES_DBG_CQP, "CQP request %p (opcode 0x%02X) freed.\n",
2510                                                         cqp_request,
2511                                                         le32_to_cpu(cqp_request->cqp_wqe.wqe_words[NES_CQP_WQE_OPCODE_IDX])&0x3f);
2512                                         if (cqp_request->dynamic) {
2513                                                 kfree(cqp_request);
2514                                         } else {
2515                                                 spin_lock_irqsave(&nesdev->cqp.lock, flags);
2516                                                 list_add_tail(&cqp_request->list, &nesdev->cqp_avail_reqs);
2517                                                 spin_unlock_irqrestore(&nesdev->cqp.lock, flags);
2518                                         }
2519                                 }
2520                         } else {
2521                                 wake_up(&nesdev->cqp.waitq);
2522                         }
2523
2524                         cq->cq_vbase[head].cqe_words[NES_CQE_OPCODE_IDX] = 0;
2525                         nes_write32(nesdev->regs+NES_CQE_ALLOC, cq->cq_number | (1 << 16));
2526                         if (++cqp->sq_tail >= cqp->sq_size)
2527                                 cqp->sq_tail = 0;
2528
2529                         /* Accounting... */
2530                         cqe_count++;
2531                         if (++head >= cq_size)
2532                                 head = 0;
2533                 } else {
2534                         break;
2535                 }
2536         } while (1);
2537         cq->cq_head = head;
2538
2539         spin_lock_irqsave(&nesdev->cqp.lock, flags);
2540         while ((!list_empty(&nesdev->cqp_pending_reqs)) &&
2541                         ((((nesdev->cqp.sq_tail+nesdev->cqp.sq_size)-nesdev->cqp.sq_head) &
2542                         (nesdev->cqp.sq_size - 1)) != 1)) {
2543                 cqp_request = list_entry(nesdev->cqp_pending_reqs.next,
2544                                 struct nes_cqp_request, list);
2545                 list_del_init(&cqp_request->list);
2546                 head = nesdev->cqp.sq_head++;
2547                 nesdev->cqp.sq_head &= nesdev->cqp.sq_size-1;
2548                 cqp_wqe = &nesdev->cqp.sq_vbase[head];
2549                 memcpy(cqp_wqe, &cqp_request->cqp_wqe, sizeof(*cqp_wqe));
2550                 barrier();
2551                 cqp_wqe->wqe_words[NES_CQP_WQE_COMP_SCRATCH_LOW_IDX] =
2552                         cpu_to_le32((u32)((unsigned long)cqp_request));
2553                 cqp_wqe->wqe_words[NES_CQP_WQE_COMP_SCRATCH_HIGH_IDX] =
2554                         cpu_to_le32((u32)(upper_32_bits((unsigned long)cqp_request)));
2555                 nes_debug(NES_DBG_CQP, "CQP request %p (opcode 0x%02X) put on CQPs SQ wqe%u.\n",
2556                                 cqp_request, le32_to_cpu(cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX])&0x3f, head);
2557                 /* Ring doorbell (1 WQEs) */
2558                 barrier();
2559                 nes_write32(nesdev->regs+NES_WQE_ALLOC, 0x01800000 | nesdev->cqp.qp_id);
2560         }
2561         spin_unlock_irqrestore(&nesdev->cqp.lock, flags);
2562
2563         /* Arm the CCQ */
2564         nes_write32(nesdev->regs+NES_CQE_ALLOC, NES_CQE_ALLOC_NOTIFY_NEXT |
2565                         cq->cq_number);
2566         nes_read32(nesdev->regs+NES_CQE_ALLOC);
2567 }
2568
2569
2570 /**
2571  * nes_process_iwarp_aeqe
2572  */
2573 void nes_process_iwarp_aeqe(struct nes_device *nesdev, struct nes_hw_aeqe *aeqe)
2574 {
2575         u64 context;
2576         u64 aeqe_context = 0;
2577         unsigned long flags;
2578         struct nes_qp *nesqp;
2579         int resource_allocated;
2580         /* struct iw_cm_id *cm_id; */
2581         struct nes_adapter *nesadapter = nesdev->nesadapter;
2582         struct ib_event ibevent;
2583         /* struct iw_cm_event cm_event; */
2584         u32 aeq_info;
2585         u32 next_iwarp_state = 0;
2586         u16 async_event_id;
2587         u8 tcp_state;
2588         u8 iwarp_state;
2589
2590         nes_debug(NES_DBG_AEQ, "\n");
2591         aeq_info = le32_to_cpu(aeqe->aeqe_words[NES_AEQE_MISC_IDX]);
2592         if ((NES_AEQE_INBOUND_RDMA&aeq_info) || (!(NES_AEQE_QP&aeq_info))) {
2593                 context = le32_to_cpu(aeqe->aeqe_words[NES_AEQE_COMP_CTXT_LOW_IDX]);
2594                 context += ((u64)le32_to_cpu(aeqe->aeqe_words[NES_AEQE_COMP_CTXT_HIGH_IDX])) << 32;
2595         } else {
2596                 aeqe_context = le32_to_cpu(aeqe->aeqe_words[NES_AEQE_COMP_CTXT_LOW_IDX]);
2597                 aeqe_context += ((u64)le32_to_cpu(aeqe->aeqe_words[NES_AEQE_COMP_CTXT_HIGH_IDX])) << 32;
2598                 context = (unsigned long)nesadapter->qp_table[le32_to_cpu(
2599                                                 aeqe->aeqe_words[NES_AEQE_COMP_QP_CQ_ID_IDX])-NES_FIRST_QPN];
2600                 BUG_ON(!context);
2601         }
2602
2603         async_event_id = (u16)aeq_info;
2604         tcp_state = (aeq_info & NES_AEQE_TCP_STATE_MASK) >> NES_AEQE_TCP_STATE_SHIFT;
2605         iwarp_state = (aeq_info & NES_AEQE_IWARP_STATE_MASK) >> NES_AEQE_IWARP_STATE_SHIFT;
2606         nes_debug(NES_DBG_AEQ, "aeid = 0x%04X, qp-cq id = %d, aeqe = %p,"
2607                         " Tcp state = %s, iWARP state = %s\n",
2608                         async_event_id,
2609                         le32_to_cpu(aeqe->aeqe_words[NES_AEQE_COMP_QP_CQ_ID_IDX]), aeqe,
2610                         nes_tcp_state_str[tcp_state], nes_iwarp_state_str[iwarp_state]);
2611
2612
2613         switch (async_event_id) {
2614                 case NES_AEQE_AEID_LLP_FIN_RECEIVED:
2615                         nesqp = *((struct nes_qp **)&context);
2616                         if (atomic_inc_return(&nesqp->close_timer_started) == 1) {
2617                                 nesqp->cm_id->add_ref(nesqp->cm_id);
2618                                 nes_add_ref(&nesqp->ibqp);
2619                                 schedule_nes_timer(nesqp->cm_node, (struct sk_buff *)nesqp,
2620                                                 NES_TIMER_TYPE_CLOSE, 1, 0);
2621                                 nes_debug(NES_DBG_AEQ, "QP%u Not decrementing QP refcount (%d),"
2622                                                 " need ae to finish up, original_last_aeq = 0x%04X."
2623                                                 " last_aeq = 0x%04X, scheduling timer. TCP state = %d\n",
2624                                                 nesqp->hwqp.qp_id, atomic_read(&nesqp->refcount),
2625                                                 async_event_id, nesqp->last_aeq, tcp_state);
2626                         }
2627                         if ((tcp_state != NES_AEQE_TCP_STATE_CLOSE_WAIT) ||
2628                                         (nesqp->ibqp_state != IB_QPS_RTS)) {
2629                                 /* FIN Received but tcp state or IB state moved on,
2630                                                 should expect a close complete */
2631                                 return;
2632                         }
2633                 case NES_AEQE_AEID_LLP_CLOSE_COMPLETE:
2634                 case NES_AEQE_AEID_LLP_CONNECTION_RESET:
2635                 case NES_AEQE_AEID_TERMINATE_SENT:
2636                 case NES_AEQE_AEID_RDMAP_ROE_BAD_LLP_CLOSE:
2637                 case NES_AEQE_AEID_RESET_SENT:
2638                         nesqp = *((struct nes_qp **)&context);
2639                         if (async_event_id == NES_AEQE_AEID_RESET_SENT) {
2640                                 tcp_state = NES_AEQE_TCP_STATE_CLOSED;
2641                         }
2642                         nes_add_ref(&nesqp->ibqp);
2643                         spin_lock_irqsave(&nesqp->lock, flags);
2644                         nesqp->hw_iwarp_state = iwarp_state;
2645                         nesqp->hw_tcp_state = tcp_state;
2646                         nesqp->last_aeq = async_event_id;
2647
2648                         if ((tcp_state == NES_AEQE_TCP_STATE_CLOSED) ||
2649                                         (tcp_state == NES_AEQE_TCP_STATE_TIME_WAIT)) {
2650                                 nesqp->hte_added = 0;
2651                                 spin_unlock_irqrestore(&nesqp->lock, flags);
2652                                 nes_debug(NES_DBG_AEQ, "issuing hw modifyqp for QP%u to remove hte\n",
2653                                                 nesqp->hwqp.qp_id);
2654                                 nes_hw_modify_qp(nesdev, nesqp,
2655                                                 NES_CQP_QP_IWARP_STATE_ERROR | NES_CQP_QP_DEL_HTE, 0);
2656                                 spin_lock_irqsave(&nesqp->lock, flags);
2657                         }
2658
2659                         if ((nesqp->ibqp_state == IB_QPS_RTS) &&
2660                                         ((tcp_state == NES_AEQE_TCP_STATE_CLOSE_WAIT) ||
2661                                         (async_event_id == NES_AEQE_AEID_LLP_CONNECTION_RESET))) {
2662                                 switch (nesqp->hw_iwarp_state) {
2663                                         case NES_AEQE_IWARP_STATE_RTS:
2664                                                 next_iwarp_state = NES_CQP_QP_IWARP_STATE_CLOSING;
2665                                                 nesqp->hw_iwarp_state = NES_AEQE_IWARP_STATE_CLOSING;
2666                                                 break;
2667                                         case NES_AEQE_IWARP_STATE_TERMINATE:
2668                                                 next_iwarp_state = NES_CQP_QP_IWARP_STATE_TERMINATE;
2669                                                 nesqp->hw_iwarp_state = NES_AEQE_IWARP_STATE_TERMINATE;
2670                                                 if (async_event_id == NES_AEQE_AEID_RDMAP_ROE_BAD_LLP_CLOSE) {
2671                                                         next_iwarp_state |= 0x02000000;
2672                                                         nesqp->hw_tcp_state = NES_AEQE_TCP_STATE_CLOSED;
2673                                                 }
2674                                                 break;
2675                                         default:
2676                                                 next_iwarp_state = 0;
2677                                 }
2678                                 spin_unlock_irqrestore(&nesqp->lock, flags);
2679                                 if (next_iwarp_state) {
2680                                         nes_add_ref(&nesqp->ibqp);
2681                                         nes_debug(NES_DBG_AEQ, "issuing hw modifyqp for QP%u. next state = 0x%08X,"
2682                                                         " also added another reference\n",
2683                                                         nesqp->hwqp.qp_id, next_iwarp_state);
2684                                         nes_hw_modify_qp(nesdev, nesqp, next_iwarp_state, 0);
2685                                 }
2686                                 nes_cm_disconn(nesqp);
2687                         } else {
2688                                 if (async_event_id ==  NES_AEQE_AEID_LLP_FIN_RECEIVED) {
2689                                         /* FIN Received but ib state not RTS,
2690                                                         close complete will be on its way */
2691                                         spin_unlock_irqrestore(&nesqp->lock, flags);
2692                                         nes_rem_ref(&nesqp->ibqp);
2693                                         return;
2694                                 }
2695                                 spin_unlock_irqrestore(&nesqp->lock, flags);
2696                                 if (async_event_id == NES_AEQE_AEID_RDMAP_ROE_BAD_LLP_CLOSE) {
2697                                         next_iwarp_state = NES_CQP_QP_IWARP_STATE_TERMINATE | 0x02000000;
2698                                         nesqp->hw_tcp_state = NES_AEQE_TCP_STATE_CLOSED;
2699                                         nes_debug(NES_DBG_AEQ, "issuing hw modifyqp for QP%u. next state = 0x%08X,"
2700                                                         " also added another reference\n",
2701                                                         nesqp->hwqp.qp_id, next_iwarp_state);
2702                                         nes_hw_modify_qp(nesdev, nesqp, next_iwarp_state, 0);
2703                                 }
2704                                 nes_cm_disconn(nesqp);
2705                         }
2706                         break;
2707                 case NES_AEQE_AEID_LLP_TERMINATE_RECEIVED:
2708                         nesqp = *((struct nes_qp **)&context);
2709                         spin_lock_irqsave(&nesqp->lock, flags);
2710                         nesqp->hw_iwarp_state = iwarp_state;
2711                         nesqp->hw_tcp_state = tcp_state;
2712                         nesqp->last_aeq = async_event_id;
2713                         spin_unlock_irqrestore(&nesqp->lock, flags);
2714                         nes_debug(NES_DBG_AEQ, "Processing an NES_AEQE_AEID_LLP_TERMINATE_RECEIVED"
2715                                         " event on QP%u \n  Q2 Data:\n",
2716                                         nesqp->hwqp.qp_id);
2717                         if (nesqp->ibqp.event_handler) {
2718                                 ibevent.device = nesqp->ibqp.device;
2719                                 ibevent.element.qp = &nesqp->ibqp;
2720                                 ibevent.event = IB_EVENT_QP_FATAL;
2721                                 nesqp->ibqp.event_handler(&ibevent, nesqp->ibqp.qp_context);
2722                         }
2723                         if ((tcp_state == NES_AEQE_TCP_STATE_CLOSE_WAIT) ||
2724                                         ((nesqp->ibqp_state == IB_QPS_RTS)&&
2725                                         (async_event_id == NES_AEQE_AEID_LLP_CONNECTION_RESET))) {
2726                                 nes_add_ref(&nesqp->ibqp);
2727                                 nes_cm_disconn(nesqp);
2728                         } else {
2729                                 nesqp->in_disconnect = 0;
2730                                 wake_up(&nesqp->kick_waitq);
2731                         }
2732                         break;
2733                 case NES_AEQE_AEID_LLP_TOO_MANY_RETRIES:
2734                         nesqp = *((struct nes_qp **)&context);
2735                         nes_add_ref(&nesqp->ibqp);
2736                         spin_lock_irqsave(&nesqp->lock, flags);
2737                         nesqp->hw_iwarp_state = NES_AEQE_IWARP_STATE_ERROR;
2738                         nesqp->hw_tcp_state = NES_AEQE_TCP_STATE_CLOSED;
2739                         nesqp->last_aeq = async_event_id;
2740                         if (nesqp->cm_id) {
2741                                 nes_debug(NES_DBG_AEQ, "Processing an NES_AEQE_AEID_LLP_TOO_MANY_RETRIES"
2742                                                 " event on QP%u, remote IP = 0x%08X \n",
2743                                                 nesqp->hwqp.qp_id,
2744                                                 ntohl(nesqp->cm_id->remote_addr.sin_addr.s_addr));
2745                         } else {
2746                                 nes_debug(NES_DBG_AEQ, "Processing an NES_AEQE_AEID_LLP_TOO_MANY_RETRIES"
2747                                                 " event on QP%u \n",
2748                                                 nesqp->hwqp.qp_id);
2749                         }
2750                         spin_unlock_irqrestore(&nesqp->lock, flags);
2751                         next_iwarp_state = NES_CQP_QP_IWARP_STATE_ERROR | NES_CQP_QP_RESET;
2752                         nes_hw_modify_qp(nesdev, nesqp, next_iwarp_state, 0);
2753                         if (nesqp->ibqp.event_handler) {
2754                                 ibevent.device = nesqp->ibqp.device;
2755                                 ibevent.element.qp = &nesqp->ibqp;
2756                                 ibevent.event = IB_EVENT_QP_FATAL;
2757                                 nesqp->ibqp.event_handler(&ibevent, nesqp->ibqp.qp_context);
2758                         }
2759                         break;
2760                 case NES_AEQE_AEID_AMP_BAD_STAG_INDEX:
2761                         if (NES_AEQE_INBOUND_RDMA&aeq_info) {
2762                                 nesqp = nesadapter->qp_table[le32_to_cpu(
2763                                                 aeqe->aeqe_words[NES_AEQE_COMP_QP_CQ_ID_IDX])-NES_FIRST_QPN];
2764                         } else {
2765                                 /* TODO: get the actual WQE and mask off wqe index */
2766                                 context &= ~((u64)511);
2767                                 nesqp = *((struct nes_qp **)&context);
2768                         }
2769                         spin_lock_irqsave(&nesqp->lock, flags);
2770                         nesqp->hw_iwarp_state = iwarp_state;
2771                         nesqp->hw_tcp_state = tcp_state;
2772                         nesqp->last_aeq = async_event_id;
2773                         spin_unlock_irqrestore(&nesqp->lock, flags);
2774                         nes_debug(NES_DBG_AEQ, "Processing an NES_AEQE_AEID_AMP_BAD_STAG_INDEX event on QP%u\n",
2775                                         nesqp->hwqp.qp_id);
2776                         if (nesqp->ibqp.event_handler) {
2777                                 ibevent.device = nesqp->ibqp.device;
2778                                 ibevent.element.qp = &nesqp->ibqp;
2779                                 ibevent.event = IB_EVENT_QP_ACCESS_ERR;
2780                                 nesqp->ibqp.event_handler(&ibevent, nesqp->ibqp.qp_context);
2781                         }
2782                         break;
2783                 case NES_AEQE_AEID_AMP_UNALLOCATED_STAG:
2784                         nesqp = *((struct nes_qp **)&context);
2785                         spin_lock_irqsave(&nesqp->lock, flags);
2786                         nesqp->hw_iwarp_state = iwarp_state;
2787                         nesqp->hw_tcp_state = tcp_state;
2788                         nesqp->last_aeq = async_event_id;
2789                         spin_unlock_irqrestore(&nesqp->lock, flags);
2790                         nes_debug(NES_DBG_AEQ, "Processing an NES_AEQE_AEID_AMP_UNALLOCATED_STAG event on QP%u\n",
2791                                         nesqp->hwqp.qp_id);
2792                         if (nesqp->ibqp.event_handler) {
2793                                 ibevent.device = nesqp->ibqp.device;
2794                                 ibevent.element.qp = &nesqp->ibqp;
2795                                 ibevent.event = IB_EVENT_QP_ACCESS_ERR;
2796                                 nesqp->ibqp.event_handler(&ibevent, nesqp->ibqp.qp_context);
2797                         }
2798                         break;
2799                 case NES_AEQE_AEID_PRIV_OPERATION_DENIED:
2800                         nesqp = nesadapter->qp_table[le32_to_cpu(aeqe->aeqe_words
2801                                         [NES_AEQE_COMP_QP_CQ_ID_IDX])-NES_FIRST_QPN];
2802                         spin_lock_irqsave(&nesqp->lock, flags);
2803                         nesqp->hw_iwarp_state = iwarp_state;
2804                         nesqp->hw_tcp_state = tcp_state;
2805                         nesqp->last_aeq = async_event_id;
2806                         spin_unlock_irqrestore(&nesqp->lock, flags);
2807                         nes_debug(NES_DBG_AEQ, "Processing an NES_AEQE_AEID_PRIV_OPERATION_DENIED event on QP%u,"
2808                                         " nesqp = %p, AE reported %p\n",
2809                                         nesqp->hwqp.qp_id, nesqp, *((struct nes_qp **)&context));
2810                         if (nesqp->ibqp.event_handler) {
2811                                 ibevent.device = nesqp->ibqp.device;
2812                                 ibevent.element.qp = &nesqp->ibqp;
2813                                 ibevent.event = IB_EVENT_QP_ACCESS_ERR;
2814                                 nesqp->ibqp.event_handler(&ibevent, nesqp->ibqp.qp_context);
2815                         }
2816                         break;
2817                 case NES_AEQE_AEID_CQ_OPERATION_ERROR:
2818                         context <<= 1;
2819                         nes_debug(NES_DBG_AEQ, "Processing an NES_AEQE_AEID_CQ_OPERATION_ERROR event on CQ%u, %p\n",
2820                                         le32_to_cpu(aeqe->aeqe_words[NES_AEQE_COMP_QP_CQ_ID_IDX]), (void *)(unsigned long)context);
2821                         resource_allocated = nes_is_resource_allocated(nesadapter, nesadapter->allocated_cqs,
2822                                         le32_to_cpu(aeqe->aeqe_words[NES_AEQE_COMP_QP_CQ_ID_IDX]));
2823                         if (resource_allocated) {
2824                                 printk(KERN_ERR PFX "%s: Processing an NES_AEQE_AEID_CQ_OPERATION_ERROR event on CQ%u\n",
2825                                                 __FUNCTION__, le32_to_cpu(aeqe->aeqe_words[NES_AEQE_COMP_QP_CQ_ID_IDX]));
2826                         }
2827                         break;
2828                 case NES_AEQE_AEID_DDP_UBE_DDP_MESSAGE_TOO_LONG_FOR_AVAILABLE_BUFFER:
2829                         nesqp = nesadapter->qp_table[le32_to_cpu(
2830                                         aeqe->aeqe_words[NES_AEQE_COMP_QP_CQ_ID_IDX])-NES_FIRST_QPN];
2831                         spin_lock_irqsave(&nesqp->lock, flags);
2832                         nesqp->hw_iwarp_state = iwarp_state;
2833                         nesqp->hw_tcp_state = tcp_state;
2834                         nesqp->last_aeq = async_event_id;
2835                         spin_unlock_irqrestore(&nesqp->lock, flags);
2836                         nes_debug(NES_DBG_AEQ, "Processing an NES_AEQE_AEID_DDP_UBE_DDP_MESSAGE_TOO_LONG"
2837                                         "_FOR_AVAILABLE_BUFFER event on QP%u\n",
2838                                         nesqp->hwqp.qp_id);
2839                         if (nesqp->ibqp.event_handler) {
2840                                 ibevent.device = nesqp->ibqp.device;
2841                                 ibevent.element.qp = &nesqp->ibqp;
2842                                 ibevent.event = IB_EVENT_QP_ACCESS_ERR;
2843                                 nesqp->ibqp.event_handler(&ibevent, nesqp->ibqp.qp_context);
2844                         }
2845                         /* tell cm to disconnect, cm will queue work to thread */
2846                         nes_add_ref(&nesqp->ibqp);
2847                         nes_cm_disconn(nesqp);
2848                         break;
2849                 case NES_AEQE_AEID_DDP_UBE_INVALID_MSN_NO_BUFFER_AVAILABLE:
2850                         nesqp = *((struct nes_qp **)&context);
2851                         spin_lock_irqsave(&nesqp->lock, flags);
2852                         nesqp->hw_iwarp_state = iwarp_state;
2853                         nesqp->hw_tcp_state = tcp_state;
2854                         nesqp->last_aeq = async_event_id;
2855                         spin_unlock_irqrestore(&nesqp->lock, flags);
2856                         nes_debug(NES_DBG_AEQ, "Processing an NES_AEQE_AEID_DDP_UBE_INVALID_MSN"
2857                                         "_NO_BUFFER_AVAILABLE event on QP%u\n",
2858                                         nesqp->hwqp.qp_id);
2859                         if (nesqp->ibqp.event_handler) {
2860                                 ibevent.device = nesqp->ibqp.device;
2861                                 ibevent.element.qp = &nesqp->ibqp;
2862                                 ibevent.event = IB_EVENT_QP_FATAL;
2863                                 nesqp->ibqp.event_handler(&ibevent, nesqp->ibqp.qp_context);
2864                         }
2865                         /* tell cm to disconnect, cm will queue work to thread */
2866                         nes_add_ref(&nesqp->ibqp);
2867                         nes_cm_disconn(nesqp);
2868                         break;
2869                 case NES_AEQE_AEID_LLP_RECEIVED_MPA_CRC_ERROR:
2870                         nesqp = *((struct nes_qp **)&context);
2871                         spin_lock_irqsave(&nesqp->lock, flags);
2872                         nesqp->hw_iwarp_state = iwarp_state;
2873                         nesqp->hw_tcp_state = tcp_state;
2874                         nesqp->last_aeq = async_event_id;
2875                         spin_unlock_irqrestore(&nesqp->lock, flags);
2876                         nes_debug(NES_DBG_AEQ, "Processing an NES_AEQE_AEID_LLP_RECEIVED_MPA_CRC_ERROR"
2877                                         " event on QP%u \n  Q2 Data:\n",
2878                                         nesqp->hwqp.qp_id);
2879                         if (nesqp->ibqp.event_handler) {
2880                                 ibevent.device = nesqp->ibqp.device;
2881                                 ibevent.element.qp = &nesqp->ibqp;
2882                                 ibevent.event = IB_EVENT_QP_FATAL;
2883                                 nesqp->ibqp.event_handler(&ibevent, nesqp->ibqp.qp_context);
2884                         }
2885                         /* tell cm to disconnect, cm will queue work to thread */
2886                         nes_add_ref(&nesqp->ibqp);
2887                         nes_cm_disconn(nesqp);
2888                         break;
2889                         /* TODO: additional AEs need to be here */
2890                 default:
2891                         nes_debug(NES_DBG_AEQ, "Processing an iWARP related AE for QP, misc = 0x%04X\n",
2892                                         async_event_id);
2893                         break;
2894         }
2895
2896 }
2897
2898
2899 /**
2900  * nes_iwarp_ce_handler
2901  */
2902 void nes_iwarp_ce_handler(struct nes_device *nesdev, struct nes_hw_cq *hw_cq)
2903 {
2904         struct nes_cq *nescq = container_of(hw_cq, struct nes_cq, hw_cq);
2905
2906         /* nes_debug(NES_DBG_CQ, "Processing completion event for iWARP CQ%u.\n",
2907                         nescq->hw_cq.cq_number); */
2908         nes_write32(nesdev->regs+NES_CQ_ACK, nescq->hw_cq.cq_number);
2909
2910         if (nescq->ibcq.comp_handler)
2911                 nescq->ibcq.comp_handler(&nescq->ibcq, nescq->ibcq.cq_context);
2912
2913         return;
2914 }
2915
2916
2917 /**
2918  * nes_manage_apbvt()
2919  */
2920 int nes_manage_apbvt(struct nes_vnic *nesvnic, u32 accel_local_port,
2921                 u32 nic_index, u32 add_port)
2922 {
2923         struct nes_device *nesdev = nesvnic->nesdev;
2924         struct nes_hw_cqp_wqe *cqp_wqe;
2925         unsigned long flags;
2926         struct nes_cqp_request *cqp_request;
2927         int ret = 0;
2928         u16 major_code;
2929
2930         /* Send manage APBVT request to CQP */
2931         cqp_request = nes_get_cqp_request(nesdev);
2932         if (cqp_request == NULL) {
2933                 nes_debug(NES_DBG_QP, "Failed to get a cqp_request.\n");
2934                 return -ENOMEM;
2935         }
2936         cqp_request->waiting = 1;
2937         cqp_wqe = &cqp_request->cqp_wqe;
2938
2939         nes_debug(NES_DBG_QP, "%s APBV for local port=%u(0x%04x), nic_index=%u\n",
2940                         (add_port == NES_MANAGE_APBVT_ADD) ? "ADD" : "DEL",
2941                         accel_local_port, accel_local_port, nic_index);
2942
2943         nes_fill_init_cqp_wqe(cqp_wqe, nesdev);
2944         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_OPCODE_IDX, (NES_CQP_MANAGE_APBVT |
2945                         ((add_port == NES_MANAGE_APBVT_ADD) ? NES_CQP_APBVT_ADD : 0)));
2946         set_wqe_32bit_value(cqp_wqe->wqe_words, NES_CQP_WQE_ID_IDX,
2947                         ((nic_index << NES_CQP_APBVT_NIC_SHIFT) | accel_local_port));
2948
2949         nes_debug(NES_DBG_QP, "Waiting for CQP completion for APBVT.\n");
2950
2951         atomic_set(&cqp_request->refcount, 2);
2952         nes_post_cqp_request(nesdev, cqp_request, NES_CQP_REQUEST_RING_DOORBELL);
2953
2954         if (add_port == NES_MANAGE_APBVT_ADD)
2955                 ret = wait_event_timeout(cqp_request->waitq, (cqp_request->request_done != 0),
2956                                 NES_EVENT_TIMEOUT);
2957         nes_debug(NES_DBG_QP, "Completed, ret=%u,  CQP Major:Minor codes = 0x%04X:0x%04X\n",
2958                         ret, cqp_request->major_code, cqp_request->minor_code);
2959         major_code = cqp_request->major_code;
2960         if (atomic_dec_and_test(&cqp_request->refcount)) {
2961                 if (cqp_request->dynamic) {
2962                         kfree(cqp_request);
2963                 } else {
2964                         spin_lock_irqsave(&nesdev->cqp.lock, flags);
2965                         list_add_tail(&cqp_request->list, &nesdev->cqp_avail_reqs);
2966                         spin_unlock_irqrestore(&nesdev->cqp.lock, flags);
2967                 }
2968         }
2969         if (!ret)
2970                 return -ETIME;
2971         else if (major_code)
2972                 return -EIO;
2973         else
2974                 return 0;
2975 }
2976
2977
2978 /**
2979  * nes_manage_arp_cache
2980  */
2981 void nes_manage_arp_cache(struct net_device *netdev, unsigned char *mac_addr,
2982                 u32 ip_addr, u32 action)
2983 {
2984         struct nes_hw_cqp_wqe *cqp_wqe;
2985         struct nes_vnic *nesvnic = netdev_priv(netdev);
2986         struct nes_device *nesdev;
2987         struct nes_cqp_request *cqp_request;
2988         int arp_index;
2989
2990         nesdev = nesvnic->nesdev;
2991         arp_index = nes_arp_table(nesdev, ip_addr, mac_addr, action);
2992         if (arp_index == -1) {
2993                 return;
2994         }
2995
2996         /* update the ARP entry */
2997         cqp_request = nes_get_cqp_request(nesdev);
2998         if (cqp_request == NULL) {
2999                 nes_debug(NES_DBG_NETDEV, "Failed to get a cqp_request.\n");
3000                 return;
3001         }
3002         cqp_request->waiting = 0;
3003         cqp_wqe = &cqp_request->cqp_wqe;
3004         nes_fill_init_cqp_wqe(cqp_wqe, nesdev);
3005
3006         cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] = cpu_to_le32(
3007                         NES_CQP_MANAGE_ARP_CACHE | NES_CQP_ARP_PERM);
3008         cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] |= cpu_to_le32(
3009                         (u32)PCI_FUNC(nesdev->pcidev->devfn) << NES_CQP_ARP_AEQ_INDEX_SHIFT);
3010         cqp_wqe->wqe_words[NES_CQP_WQE_ID_IDX] = cpu_to_le32(arp_index);
3011
3012         if (action == NES_ARP_ADD) {
3013                 cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] |= cpu_to_le32(NES_CQP_ARP_VALID);
3014                 cqp_wqe->wqe_words[NES_CQP_ARP_WQE_MAC_ADDR_LOW_IDX] = cpu_to_le32(
3015                                 (((u32)mac_addr[2]) << 24) | (((u32)mac_addr[3]) << 16) |
3016                                 (((u32)mac_addr[4]) << 8) | (u32)mac_addr[5]);
3017                 cqp_wqe->wqe_words[NES_CQP_ARP_WQE_MAC_HIGH_IDX] = cpu_to_le32(
3018                                 (((u32)mac_addr[0]) << 16) | (u32)mac_addr[1]);
3019         } else {
3020                 cqp_wqe->wqe_words[NES_CQP_ARP_WQE_MAC_ADDR_LOW_IDX] = 0;
3021                 cqp_wqe->wqe_words[NES_CQP_ARP_WQE_MAC_HIGH_IDX] = 0;
3022         }
3023
3024         nes_debug(NES_DBG_NETDEV, "Not waiting for CQP, cqp.sq_head=%u, cqp.sq_tail=%u\n",
3025                         nesdev->cqp.sq_head, nesdev->cqp.sq_tail);
3026
3027         atomic_set(&cqp_request->refcount, 1);
3028         nes_post_cqp_request(nesdev, cqp_request, NES_CQP_REQUEST_RING_DOORBELL);
3029 }
3030
3031
3032 /**
3033  * flush_wqes
3034  */
3035 void flush_wqes(struct nes_device *nesdev, struct nes_qp *nesqp,
3036                 u32 which_wq, u32 wait_completion)
3037 {
3038         unsigned long flags;
3039         struct nes_cqp_request *cqp_request;
3040         struct nes_hw_cqp_wqe *cqp_wqe;
3041         int ret;
3042
3043         cqp_request = nes_get_cqp_request(nesdev);
3044         if (cqp_request == NULL) {
3045                 nes_debug(NES_DBG_QP, "Failed to get a cqp_request.\n");
3046                 return;
3047         }
3048         if (wait_completion) {
3049                 cqp_request->waiting = 1;
3050                 atomic_set(&cqp_request->refcount, 2);
3051         } else {
3052                 cqp_request->waiting = 0;
3053         }
3054         cqp_wqe = &cqp_request->cqp_wqe;
3055         nes_fill_init_cqp_wqe(cqp_wqe, nesdev);
3056
3057         cqp_wqe->wqe_words[NES_CQP_WQE_OPCODE_IDX] =
3058                         cpu_to_le32(NES_CQP_FLUSH_WQES | which_wq);
3059         cqp_wqe->wqe_words[NES_CQP_WQE_ID_IDX] = cpu_to_le32(nesqp->hwqp.qp_id);
3060
3061         nes_post_cqp_request(nesdev, cqp_request, NES_CQP_REQUEST_RING_DOORBELL);
3062
3063         if (wait_completion) {
3064                 /* Wait for CQP */
3065                 ret = wait_event_timeout(cqp_request->waitq, (cqp_request->request_done != 0),
3066                                 NES_EVENT_TIMEOUT);
3067                 nes_debug(NES_DBG_QP, "Flush SQ QP WQEs completed, ret=%u,"
3068                                 " CQP Major:Minor codes = 0x%04X:0x%04X\n",
3069                                 ret, cqp_request->major_code, cqp_request->minor_code);
3070                 if (atomic_dec_and_test(&cqp_request->refcount)) {
3071                         if (cqp_request->dynamic) {
3072                                 kfree(cqp_request);
3073                         } else {
3074                                 spin_lock_irqsave(&nesdev->cqp.lock, flags);
3075                                 list_add_tail(&cqp_request->list, &nesdev->cqp_avail_reqs);
3076                                 spin_unlock_irqrestore(&nesdev->cqp.lock, flags);
3077                         }
3078                 }
3079         }
3080 }