sys/dev/ahb/ahb.c

   1 /*-
   2  * CAM SCSI device driver for the Adaptec 174X SCSI Host adapter
   3  *
   4  * Copyright (c) 1998 Justin T. Gibbs
   5  * All rights reserved.
   6  *
   7  * Redistribution and use in source and binary forms, with or without
   8  * modification, are permitted provided that the following conditions
   9  * are met:
  10  * 1. Redistributions of source code must retain the above copyright
  11  *    notice immediately at the beginning of the file, without modification,
  12  *    this list of conditions, and the following disclaimer.
  13  * 2. The name of the author may not be used to endorse or promote products
  14  *    derived from this software without specific prior written permission.
  15  *
  16  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
  17  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  18  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  19  * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE FOR
  20  * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  21  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  22  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  23  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  24  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  25  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  26  * SUCH DAMAGE.
  27  *
  28  * $FreeBSD$
  29  */
  30
  31 #include <sys/param.h>
  32 #include <sys/systm.h>
  33 #include <sys/kernel.h>
  34 #include <sys/malloc.h>
  35 #include <sys/module.h>
  36 #include <sys/lock.h>
  37 #include <sys/mutex.h>
  38 #include <sys/bus.h>
  39
  40 #include <machine/bus.h>
  41 #include <machine/resource.h>
  42 #include <sys/rman.h>
  43
  44 #include <cam/cam.h>
  45 #include <cam/cam_ccb.h>
  46 #include <cam/cam_sim.h>
  47 #include <cam/cam_xpt_sim.h>
  48 #include <cam/cam_debug.h>
  49
  50 #include <cam/scsi/scsi_message.h>
  51
  52 #include <dev/eisa/eisaconf.h>
  53
  54 #include <dev/ahb/ahbreg.h>
  55
  56 #define ccb_ecb_ptr spriv_ptr0
  57 #define ccb_ahb_ptr spriv_ptr1
  58
  59 #define ahb_inb(ahb, port)                              \
  60         bus_space_read_1((ahb)->tag, (ahb)->bsh, port)
  61
  62 #define ahb_inl(ahb, port)                              \
  63         bus_space_read_4((ahb)->tag, (ahb)->bsh, port)
  64
  65 #define ahb_outb(ahb, port, value)                      \
  66         bus_space_write_1((ahb)->tag, (ahb)->bsh, port, value)
  67
  68 #define ahb_outl(ahb, port, value)                      \
  69         bus_space_write_4((ahb)->tag, (ahb)->bsh, port, value)
  70
  71 static const char               *ahbmatch(eisa_id_t type);
  72 static struct ahb_softc         *ahballoc(u_long unit, struct resource *res);
  73 static void                      ahbfree(struct ahb_softc *ahb);
  74 static int                       ahbreset(struct ahb_softc *ahb);
  75 static void                      ahbmapecbs(void *arg, bus_dma_segment_t *segs,
  76                                             int nseg, int error);
  77 static int                       ahbxptattach(struct ahb_softc *ahb);
  78 static void                      ahbhandleimmed(struct ahb_softc *ahb,
  79                                                 u_int32_t mbox, u_int intstat);
  80 static void                      ahbcalcresid(struct ahb_softc *ahb,
  81                                               struct ecb *ecb, union ccb *ccb);
  82 static __inline void             ahbdone(struct ahb_softc *ahb, u_int32_t mbox,
  83                                          u_int intstat);
  84 static void                      ahbintr(void *arg);
  85 static bus_dmamap_callback_t     ahbexecuteecb;
  86 static void                      ahbaction(struct cam_sim *sim, union ccb *ccb);
  87 static void                      ahbpoll(struct cam_sim *sim);
  88
  89 /* Our timeout handler */
  90 static timeout_t ahbtimeout;
  91
  92 static __inline struct ecb*     ahbecbget(struct ahb_softc *ahb);
  93 static __inline void            ahbecbfree(struct ahb_softc* ahb,
  94                                            struct ecb* ecb);
  95 static __inline u_int32_t       ahbecbvtop(struct ahb_softc *ahb,
  96                                            struct ecb *ecb);
  97 static __inline struct ecb*     ahbecbptov(struct ahb_softc *ahb,
  98                                            u_int32_t ecb_addr);
  99 static __inline u_int32_t       ahbstatuspaddr(u_int32_t ecb_paddr);
 100 static __inline u_int32_t       ahbsensepaddr(u_int32_t ecb_paddr);
 101 static __inline u_int32_t       ahbsgpaddr(u_int32_t ecb_paddr);
 102 static __inline void            ahbqueuembox(struct ahb_softc *ahb,
 103                                              u_int32_t mboxval,
 104                                              u_int attn_code);
 105
 106 static __inline struct ecb*
 107 ahbecbget(struct ahb_softc *ahb)
 108 {
 109         struct  ecb* ecb;
 110         int     s;
 111
 112         s = splcam();
 113         if ((ecb = SLIST_FIRST(&ahb->free_ecbs)) != NULL)
 114                 SLIST_REMOVE_HEAD(&ahb->free_ecbs, links);
 115         splx(s);
 116
 117         return (ecb);
 118 }
 119
 120 static __inline void
 121 ahbecbfree(struct ahb_softc* ahb, struct ecb* ecb)
 122 {
 123         int s;
 124
 125         s = splcam();
 126         ecb->state = ECB_FREE;
 127         SLIST_INSERT_HEAD(&ahb->free_ecbs, ecb, links);
 128         splx(s);
 129 }
 130
 131 static __inline u_int32_t
 132 ahbecbvtop(struct ahb_softc *ahb, struct ecb *ecb)
 133 {
 134         return (ahb->ecb_physbase
 135               + (u_int32_t)((caddr_t)ecb - (caddr_t)ahb->ecb_array));
 136 }
 137
 138 static __inline struct ecb*
 139 ahbecbptov(struct ahb_softc *ahb, u_int32_t ecb_addr)
 140 {
 141         return (ahb->ecb_array
 142               + ((struct ecb*)(uintptr_t)ecb_addr
 143                 - (struct ecb*)(uintptr_t)ahb->ecb_physbase));
 144 }
 145
 146 static __inline u_int32_t
 147 ahbstatuspaddr(u_int32_t ecb_paddr)
 148 {
 149         return (ecb_paddr + offsetof(struct ecb, status));
 150 }
 151
 152 static __inline u_int32_t
 153 ahbsensepaddr(u_int32_t ecb_paddr)
 154 {
 155         return (ecb_paddr + offsetof(struct ecb, sense));
 156 }
 157
 158 static __inline u_int32_t
 159 ahbsgpaddr(u_int32_t ecb_paddr)
 160 {
 161         return (ecb_paddr + offsetof(struct ecb, sg_list));
 162 }
 163
 164 static __inline void
 165 ahbqueuembox(struct ahb_softc *ahb, u_int32_t mboxval, u_int attn_code)
 166 {
 167         u_int loopmax = 300;
 168         while (--loopmax) {
 169                 u_int status;
 170
 171                 status = ahb_inb(ahb, HOSTSTAT);
 172                 if ((status & (HOSTSTAT_MBOX_EMPTY|HOSTSTAT_BUSY))
 173                    == HOSTSTAT_MBOX_EMPTY)
 174                         break;
 175                 DELAY(20);
 176         }
 177         if (loopmax == 0)
 178                 panic("ahb%ld: adapter not taking commands\n", ahb->unit);
 179
 180         ahb_outl(ahb, MBOXOUT0, mboxval);
 181         ahb_outb(ahb, ATTN, attn_code);
 182 }
 183
 184 static const char *
 185 ahbmatch(eisa_id_t type)
 186 {
 187         switch(type & 0xfffffe00) {
 188                 case EISA_DEVICE_ID_ADAPTEC_1740:
 189                         return ("Adaptec 174x SCSI host adapter");
 190                         break;
 191                 default:
 192                         break;
 193         }
 194         return (NULL);
 195 }
 196
 197 static int
 198 ahbprobe(device_t dev)
 199 {
 200         const char *desc;
 201         u_int32_t iobase;
 202         u_int32_t irq;
 203         u_int8_t  intdef;
 204         int shared;
 205
 206         desc = ahbmatch(eisa_get_id(dev));
 207         if (!desc)
 208             return (ENXIO);
 209         device_set_desc(dev, desc);
 210
 211         iobase = (eisa_get_slot(dev) * EISA_SLOT_SIZE) +
 212             AHB_EISA_SLOT_OFFSET;
 213
 214         eisa_add_iospace(dev, iobase, AHB_EISA_IOSIZE, RESVADDR_NONE);
 215
 216         intdef = inb(INTDEF + iobase);
 217         switch (intdef & 0x7) {
 218         case INT9:
 219             irq = 9;
 220             break;
 221         case INT10:
 222             irq = 10;
 223             break;
 224         case INT11:
 225             irq = 11;
 226             break;
 227         case INT12:
 228             irq = 12;
 229             break;
 230         case INT14:
 231             irq = 14;
 232             break;
 233         case INT15:
 234             irq = 15;
 235             break;
 236         default:
 237             printf("Adaptec 174X at slot %d: illegal "
 238                    "irq setting %d\n", eisa_get_slot(dev),
 239                    (intdef & 0x7));
 240             irq = 0;
 241             break;
 242         }
 243         if (irq == 0)
 244             return ENXIO;
 245
 246         shared = (inb(INTDEF + iobase) & INTLEVEL) ?
 247                  EISA_TRIGGER_LEVEL : EISA_TRIGGER_EDGE;
 248
 249         eisa_add_intr(dev, irq, shared);
 250
 251         return 0;
 252 }
 253
 254 static int
 255 ahbattach(device_t dev)
 256 {
 257         /*
 258          * find unit and check we have that many defined
 259          */
 260         struct      ahb_softc *ahb;
 261         struct      ecb* next_ecb;
 262         struct      resource *io = 0;
 263         struct      resource *irq = 0;
 264         int         rid;
 265         void        *ih;
 266
 267         rid = 0;
 268         io = bus_alloc_resource_any(dev, SYS_RES_IOPORT, &rid, RF_ACTIVE);
 269         if (!io) {
 270                 device_printf(dev, "No I/O space?!\n");
 271                 return ENOMEM;
 272         }
 273
 274         if ((ahb = ahballoc(device_get_unit(dev), io)) == NULL) {
 275                 goto error_exit2;
 276         }
 277
 278         if (ahbreset(ahb) != 0)
 279                 goto error_exit;
 280
 281         rid = 0;
 282         irq = bus_alloc_resource_any(dev, SYS_RES_IRQ, &rid, RF_ACTIVE);
 283         if (!irq) {
 284                 device_printf(dev, "Can't allocate interrupt\n");
 285                 goto error_exit;
 286         }
 287
 288         /*
 289          * Create our DMA tags.  These tags define the kinds of device
 290          * accessible memory allocations and memory mappings we will
 291          * need to perform during normal operation.
 292          */
 293         /* DMA tag for mapping buffers into device visible space. */
 294         /* XXX Should be a child of the EISA bus dma tag */
 295         if (bus_dma_tag_create( /* parent       */ NULL,
 296                                 /* alignment    */ 1,
 297                                 /* boundary     */ 0,
 298                                 /* lowaddr      */ BUS_SPACE_MAXADDR_32BIT,
 299                                 /* highaddr     */ BUS_SPACE_MAXADDR,
 300                                 /* filter       */ NULL,
 301                                 /* filterarg    */ NULL,
 302                                 /* maxsize      */ MAXBSIZE,
 303                                 /* nsegments    */ AHB_NSEG,
 304                                 /* maxsegsz     */ BUS_SPACE_MAXSIZE_32BIT,
 305                                 /* flags        */ BUS_DMA_ALLOCNOW,
 306                                 /* lockfunc     */ busdma_lock_mutex,
 307                                 /* lockarg      */ &Giant,
 308                                 &ahb->buffer_dmat) != 0)
 309                 goto error_exit;
 310
 311         ahb->init_level++;
 312
 313         /* DMA tag for our ccb structures and ha inquiry data */
 314         if (bus_dma_tag_create( /* parent       */ NULL,
 315                                 /* alignment    */ 1,
 316                                 /* boundary     */ 0,
 317                                 /* lowaddr      */ BUS_SPACE_MAXADDR_32BIT,
 318                                 /* highaddr     */ BUS_SPACE_MAXADDR,
 319                                 /* filter       */ NULL,
 320                                 /* filterarg    */ NULL,
 321                                 /* maxsize      */ (AHB_NECB *
 322                                                     sizeof(struct ecb))
 323                                                     + sizeof(*ahb->ha_inq_data),
 324                                 /* nsegments    */ 1,
 325                                 /* maxsegsz     */ BUS_SPACE_MAXSIZE_32BIT,
 326                                 /* flags        */ 0,
 327                                 /* lockfunc     */ busdma_lock_mutex,
 328                                 /* lockarg      */ &Giant,
 329                                 &ahb->ecb_dmat) != 0)
 330                 goto error_exit;
 331
 332         ahb->init_level++;
 333
 334         /* Allocation for our ccbs */
 335         if (bus_dmamem_alloc(ahb->ecb_dmat, (void **)&ahb->ecb_array,
 336                              BUS_DMA_NOWAIT, &ahb->ecb_dmamap) != 0)
 337                 goto error_exit;
 338
 339         ahb->ha_inq_data = (struct ha_inquiry_data *)&ahb->ecb_array[AHB_NECB];
 340
 341         ahb->init_level++;
 342
 343         /* And permanently map them */
 344         bus_dmamap_load(ahb->ecb_dmat, ahb->ecb_dmamap,
 345                         ahb->ecb_array, AHB_NSEG * sizeof(struct ecb),
 346                         ahbmapecbs, ahb, /*flags*/0);
 347
 348         ahb->init_level++;
 349
 350         /* Allocate the buffer dmamaps for each of our ECBs */
 351         bzero(ahb->ecb_array, (AHB_NECB * sizeof(struct ecb))
 352               + sizeof(*ahb->ha_inq_data));
 353         next_ecb = ahb->ecb_array;
 354         while (ahb->num_ecbs < AHB_NECB) {
 355                 u_int32_t ecb_paddr;
 356
 357                 if (bus_dmamap_create(ahb->buffer_dmat, /*flags*/0,
 358                                       &next_ecb->dmamap))
 359                         break;
 360                 ecb_paddr = ahbecbvtop(ahb, next_ecb);
 361                 next_ecb->hecb.status_ptr = ahbstatuspaddr(ecb_paddr);
 362                 next_ecb->hecb.sense_ptr = ahbsensepaddr(ecb_paddr);
 363                 ahb->num_ecbs++;
 364                 ahbecbfree(ahb, next_ecb);
 365                 next_ecb++;
 366         }
 367
 368         if (ahb->num_ecbs == 0)
 369                 goto error_exit;
 370
 371         ahb->init_level++;
 372
 373         /*
 374          * Now that we know we own the resources we need, register
 375          * our bus with the XPT.
 376          */
 377         if (ahbxptattach(ahb))
 378                 goto error_exit;
 379
 380         /* Enable our interrupt */
 381         bus_setup_intr(dev, irq, INTR_TYPE_CAM|INTR_ENTROPY, ahbintr, ahb, &ih);
 382         return (0);
 383
 384 error_exit:
 385         /*
 386          * The board's IRQ line will not be left enabled
 387          * if we can't intialize correctly, so its safe
 388          * to release the irq.
 389          */
 390         ahbfree(ahb);
 391 error_exit2:
 392         if (io)
 393                 bus_release_resource(dev, SYS_RES_IOPORT, 0, io);
 394         if (irq)
 395                 bus_release_resource(dev, SYS_RES_IRQ, 0, irq);
 396         return (-1);
 397 }
 398
 399 static struct ahb_softc *
 400 ahballoc(u_long unit, struct resource *res)
 401 {
 402         struct  ahb_softc *ahb;
 403
 404         /*
 405          * Allocate a storage area for us
 406          */
 407         ahb = malloc(sizeof(struct ahb_softc), M_DEVBUF, M_NOWAIT | M_ZERO);
 408         if (!ahb) {
 409                 printf("ahb%ld: cannot malloc!\n", unit);
 410                 return (NULL);
 411         }
 412         SLIST_INIT(&ahb->free_ecbs);
 413         LIST_INIT(&ahb->pending_ccbs);
 414         ahb->unit = unit;
 415         ahb->tag = rman_get_bustag(res);
 416         ahb->bsh = rman_get_bushandle(res);
 417         ahb->disc_permitted = ~0;
 418         ahb->tags_permitted = ~0;
 419
 420         return (ahb);
 421 }
 422
 423 static void
 424 ahbfree(struct ahb_softc *ahb)
 425 {
 426         switch (ahb->init_level) {
 427         default:
 428         case 4:
 429                 bus_dmamap_unload(ahb->ecb_dmat, ahb->ecb_dmamap);
 430         case 3:
 431                 bus_dmamem_free(ahb->ecb_dmat, ahb->ecb_array,
 432                                 ahb->ecb_dmamap);
 433                 bus_dmamap_destroy(ahb->ecb_dmat, ahb->ecb_dmamap);
 434         case 2:
 435                 bus_dma_tag_destroy(ahb->ecb_dmat);
 436         case 1:
 437                 bus_dma_tag_destroy(ahb->buffer_dmat);
 438         case 0:
 439                 break;
 440         }
 441         free(ahb, M_DEVBUF);
 442 }
 443
 444 /*
 445  * reset board, If it doesn't respond, return failure
 446  */
 447 static int
 448 ahbreset(struct ahb_softc *ahb)
 449 {
 450         int     wait = 1000;    /* 1 sec enough? */
 451         int     test;
 452
 453         if ((ahb_inb(ahb, PORTADDR) & PORTADDR_ENHANCED) == 0) {
 454                 printf("ahb_reset: Controller not in enhanced mode\n");
 455                 return (-1);
 456         }
 457
 458         ahb_outb(ahb, CONTROL, CNTRL_HARD_RST);
 459         DELAY(1000);
 460         ahb_outb(ahb, CONTROL, 0);
 461         while (--wait) {
 462                 DELAY(1000);
 463                 if ((ahb_inb(ahb, HOSTSTAT) & HOSTSTAT_BUSY) == 0)
 464                         break;
 465         }
 466
 467         if (wait == 0) {
 468                 printf("ahbreset: No answer from aha1742 board\n");
 469                 return (-1);
 470         }
 471         if ((test = ahb_inb(ahb, MBOXIN0)) != 0) {
 472                 printf("ahb_reset: self test failed, val = 0x%x\n", test);
 473                 return (-1);
 474         }
 475         while (ahb_inb(ahb, HOSTSTAT) & HOSTSTAT_INTPEND) {
 476                 ahb_outb(ahb, CONTROL, CNTRL_CLRINT);
 477                 DELAY(10000);
 478         }
 479         return (0);
 480 }
 481
 482 static void
 483 ahbmapecbs(void *arg, bus_dma_segment_t *segs, int nseg, int error)
 484 {
 485         struct ahb_softc* ahb;
 486
 487         ahb = (struct ahb_softc*)arg;
 488         ahb->ecb_physbase = segs->ds_addr;
 489         /*
 490          * Space for adapter inquiry information is on the
 491          * tail of the ecb array.
 492          */
 493         ahb->ha_inq_physbase = ahbecbvtop(ahb, &ahb->ecb_array[AHB_NECB]);
 494 }
 495
 496 static int
 497 ahbxptattach(struct ahb_softc *ahb)
 498 {
 499         struct cam_devq *devq;
 500         struct ecb *ecb;
 501         u_int  i;
 502
 503         /* Remeber who are we on the scsi bus */
 504         ahb->scsi_id = ahb_inb(ahb, SCSIDEF) & HSCSIID;
 505
 506         /* Use extended translation?? */
 507         ahb->extended_trans = ahb_inb(ahb, RESV1) & EXTENDED_TRANS;
 508
 509         /* Fetch adapter inquiry data */
 510         ecb = ahbecbget(ahb);   /* Always succeeds - no outstanding commands */
 511         ecb->hecb.opcode = ECBOP_READ_HA_INQDATA;
 512         ecb->hecb.flag_word1 = FW1_SUPPRESS_URUN_ERR|FW1_ERR_STATUS_BLK_ONLY;
 513         ecb->hecb.data_ptr = ahb->ha_inq_physbase;
 514         ecb->hecb.data_len = sizeof(struct ha_inquiry_data);
 515         ecb->hecb.sense_ptr = 0;
 516         ecb->state = ECB_ACTIVE;
 517
 518         /* Tell the adapter about this command */
 519         ahbqueuembox(ahb, ahbecbvtop(ahb, ecb),
 520                      ATTN_STARTECB|ahb->scsi_id);
 521
 522         /* Poll for interrupt completion */
 523         for (i = 1000; ecb->state != ECB_FREE && i != 0; i--) {
 524                 ahbintr(ahb);
 525                 DELAY(1000);
 526         }
 527
 528         ahb->num_ecbs = MIN(ahb->num_ecbs,
 529                             ahb->ha_inq_data->scsi_data.spc2_flags);
 530         printf("ahb%ld: %.8s %s SCSI Adapter, FW Rev. %.4s, ID=%d, %d ECBs\n",
 531                ahb->unit, ahb->ha_inq_data->scsi_data.product,
 532                (ahb->ha_inq_data->scsi_data.flags & 0x4) ? "Differential"
 533                                                          : "Single Ended",
 534                ahb->ha_inq_data->scsi_data.revision,
 535                ahb->scsi_id, ahb->num_ecbs);
 536
 537         /* Restore sense paddr for future CCB clients */
 538         ecb->hecb.sense_ptr = ahbsensepaddr(ahbecbvtop(ahb, ecb));
 539
 540         ahbecbfree(ahb, ecb);
 541
 542         /*
 543          * Create the device queue for our SIM.
 544          */
 545         devq = cam_simq_alloc(ahb->num_ecbs);
 546         if (devq == NULL)
 547                 return (ENOMEM);
 548
 549         /*
 550          * Construct our SIM entry
 551          */
 552         ahb->sim = cam_sim_alloc(ahbaction, ahbpoll, "ahb", ahb, ahb->unit,
 553                                  2, ahb->num_ecbs, devq);
 554         if (ahb->sim == NULL) {
 555                 cam_simq_free(devq);
 556                 return (ENOMEM);
 557         }
 558
 559         if (xpt_bus_register(ahb->sim, 0) != CAM_SUCCESS) {
 560                 cam_sim_free(ahb->sim, /*free_devq*/TRUE);
 561                 return (ENXIO);
 562         }
 563
 564         if (xpt_create_path(&ahb->path, /*periph*/NULL,
 565                             cam_sim_path(ahb->sim), CAM_TARGET_WILDCARD,
 566                             CAM_LUN_WILDCARD) != CAM_REQ_CMP) {
 567                 xpt_bus_deregister(cam_sim_path(ahb->sim));
 568                 cam_sim_free(ahb->sim, /*free_devq*/TRUE);
 569                 return (ENXIO);
 570         }
 571
 572         /*
 573          * Allow the board to generate interrupts.
 574          */
 575         ahb_outb(ahb, INTDEF, ahb_inb(ahb, INTDEF) | INTEN);
 576
 577         return (0);
 578 }
 579
 580 static void
 581 ahbhandleimmed(struct ahb_softc *ahb, u_int32_t mbox, u_int intstat)
 582 {
 583         struct ccb_hdr *ccb_h;
 584         u_int target_id;
 585
 586         if (ahb->immed_cmd == 0) {
 587                 printf("ahb%ld: Immediate Command complete with no "
 588                        " pending command\n", ahb->unit);
 589                 return;
 590         }
 591
 592         target_id = intstat & INTSTAT_TARGET_MASK;
 593
 594         ccb_h = LIST_FIRST(&ahb->pending_ccbs);
 595         while (ccb_h != NULL) {
 596                 struct ecb *pending_ecb;
 597                 union ccb *ccb;
 598
 599                 pending_ecb = (struct ecb *)ccb_h->ccb_ecb_ptr;
 600                 ccb = pending_ecb->ccb;
 601                 ccb_h = LIST_NEXT(ccb_h, sim_links.le);
 602                 if (ccb->ccb_h.target_id == target_id
 603                  || target_id == ahb->scsi_id) {
 604                         untimeout(ahbtimeout, pending_ecb,
 605                                   ccb->ccb_h.timeout_ch);
 606                         LIST_REMOVE(&ccb->ccb_h, sim_links.le);
 607                         if ((ccb->ccb_h.flags & CAM_DIR_MASK) != CAM_DIR_NONE)
 608                                 bus_dmamap_unload(ahb->buffer_dmat,
 609                                                   pending_ecb->dmamap);
 610                         if (pending_ecb == ahb->immed_ecb)
 611                                 ccb->ccb_h.status =
 612                                     CAM_CMD_TIMEOUT|CAM_RELEASE_SIMQ;
 613                         else if (target_id == ahb->scsi_id)
 614                                 ccb->ccb_h.status = CAM_SCSI_BUS_RESET;
 615                         else
 616                                 ccb->ccb_h.status = CAM_BDR_SENT;
 617                         ahbecbfree(ahb, pending_ecb);
 618                         xpt_done(ccb);
 619                 } else if (ahb->immed_ecb != NULL) {
 620                         /* Re-instate timeout */
 621                         ccb->ccb_h.timeout_ch =
 622                             timeout(ahbtimeout, (caddr_t)pending_ecb,
 623                                     (ccb->ccb_h.timeout * hz) / 1000);
 624                 }
 625         }
 626
 627         if (ahb->immed_ecb != NULL) {
 628                 ahb->immed_ecb = NULL;
 629                 printf("ahb%ld: No longer in timeout\n", ahb->unit);
 630         } else if (target_id == ahb->scsi_id)
 631                 printf("ahb%ld: SCSI Bus Reset Delivered\n", ahb->unit);
 632         else
 633                 printf("ahb%ld:  Bus Device Reset Delibered to target %d\n",
 634                        ahb->unit, target_id);
 635
 636         ahb->immed_cmd = 0;
 637 }
 638
 639 static void
 640 ahbcalcresid(struct ahb_softc *ahb, struct ecb *ecb, union ccb *ccb)
 641 {
 642         if (ecb->status.data_overrun != 0) {
 643                 /*
 644                  * Overrun Condition.  The hardware doesn't
 645                  * provide a meaningful byte count in this case
 646                  * (the residual is always 0).  Tell the XPT
 647                  * layer about the error.
 648                  */
 649                 ccb->ccb_h.status = CAM_DATA_RUN_ERR;
 650         } else {
 651                 ccb->csio.resid = ecb->status.resid_count;
 652
 653                 if ((ecb->hecb.flag_word1 & FW1_SG_ECB) != 0) {
 654                         /*
 655                          * For S/G transfers, the adapter provides a pointer
 656                          * to the address in the last S/G element used and a
 657                          * residual for that element.  So, we need to sum up
 658                          * the elements that follow it in order to get a real
 659                          * residual number.  If we have an overrun, the residual
 660                          * reported will be 0 and we already know that all S/G
 661                          * segments have been exhausted, so we can skip this
 662                          * step.
 663                          */
 664                         ahb_sg_t *sg;
 665                         int       num_sg;
 666
 667                         num_sg = ecb->hecb.data_len / sizeof(ahb_sg_t);
 668
 669                         /* Find the S/G the adapter was working on */
 670                         for (sg = ecb->sg_list;
 671                              num_sg != 0 && sg->addr != ecb->status.resid_addr;
 672                              num_sg--, sg++)
 673                                 ;
 674
 675                         /* Skip it */
 676                         num_sg--;
 677                         sg++;
 678
 679                         /* Sum the rest */
 680                         for (; num_sg != 0; num_sg--, sg++)
 681                                 ccb->csio.resid += sg->len;
 682                 }
 683                 /* Underruns are not errors */
 684                 ccb->ccb_h.status = CAM_REQ_CMP;
 685         }
 686 }
 687
 688 static void
 689 ahbprocesserror(struct ahb_softc *ahb, struct ecb *ecb, union ccb *ccb)
 690 {
 691         struct hardware_ecb *hecb;
 692         struct ecb_status *status;
 693
 694         hecb = &ecb->hecb;
 695         status = &ecb->status;
 696         switch (status->ha_status) {
 697         case HS_OK:
 698                 ccb->csio.scsi_status = status->scsi_status;
 699                 if (status->scsi_status != 0) {
 700                         ccb->ccb_h.status = CAM_SCSI_STATUS_ERROR;
 701                         if (status->sense_stored) {
 702                                 ccb->ccb_h.status |= CAM_AUTOSNS_VALID;
 703                                 ccb->csio.sense_resid =
 704                                     ccb->csio.sense_len - status->sense_len;
 705                                 bcopy(&ecb->sense, &ccb->csio.sense_data,
 706                                       status->sense_len);
 707                         }
 708                 }
 709                 break;
 710         case HS_TARGET_NOT_ASSIGNED:
 711                 ccb->ccb_h.status = CAM_PATH_INVALID;
 712                 break;
 713         case HS_SEL_TIMEOUT:
 714                 ccb->ccb_h.status = CAM_SEL_TIMEOUT;
 715                 break;
 716         case HS_DATA_RUN_ERR:
 717                 ahbcalcresid(ahb, ecb, ccb);
 718                 break;
 719         case HS_UNEXPECTED_BUSFREE:
 720                 ccb->ccb_h.status = CAM_UNEXP_BUSFREE;
 721                 break;
 722         case HS_INVALID_PHASE:
 723                 ccb->ccb_h.status = CAM_SEQUENCE_FAIL;
 724                 break;
 725         case HS_REQUEST_SENSE_FAILED:
 726                 ccb->ccb_h.status = CAM_AUTOSENSE_FAIL;
 727                 break;
 728         case HS_TAG_MSG_REJECTED:
 729         {
 730                 struct ccb_trans_settings neg;
 731
 732                 xpt_print_path(ccb->ccb_h.path);
 733                 printf("refuses tagged commands.  Performing "
 734                        "non-tagged I/O\n");
 735                 neg.flags = 0;
 736                 neg.valid = CCB_TRANS_TQ_VALID;
 737                 xpt_setup_ccb(&neg.ccb_h, ccb->ccb_h.path, /*priority*/1);
 738                 xpt_async(AC_TRANSFER_NEG, ccb->ccb_h.path, &neg);
 739                 ahb->tags_permitted &= ~(0x01 << ccb->ccb_h.target_id);
 740                 ccb->ccb_h.status = CAM_MSG_REJECT_REC;
 741                 break;
 742         }
 743         case HS_FIRMWARE_LOAD_REQ:
 744         case HS_HARDWARE_ERR:
 745                 /*
 746                  * Tell the system that the Adapter
 747                  * is no longer functional.
 748                  */
 749                 ccb->ccb_h.status = CAM_NO_HBA;
 750                 break;
 751         case HS_CMD_ABORTED_HOST:
 752         case HS_CMD_ABORTED_ADAPTER:
 753         case HS_ATN_TARGET_FAILED:
 754         case HS_SCSI_RESET_ADAPTER:
 755         case HS_SCSI_RESET_INCOMING:
 756                 ccb->ccb_h.status = CAM_SCSI_BUS_RESET;
 757                 break;
 758         case HS_INVALID_ECB_PARAM:
 759                 printf("ahb%ld: opcode 0x%02x, flag_word1 0x%02x, flag_word2 0x%02x\n",
 760                         ahb->unit, hecb->opcode, hecb->flag_word1, hecb->flag_word2);
 761                 ccb->ccb_h.status = CAM_SCSI_BUS_RESET;
 762                 break;
 763         case HS_DUP_TCB_RECEIVED:
 764         case HS_INVALID_OPCODE:
 765         case HS_INVALID_CMD_LINK:
 766         case HS_PROGRAM_CKSUM_ERROR:
 767                 panic("ahb%ld: Can't happen host status %x occurred",
 768                       ahb->unit, status->ha_status);
 769                 break;
 770         }
 771         if (ccb->ccb_h.status != CAM_REQ_CMP) {
 772                 xpt_freeze_devq(ccb->ccb_h.path, /*count*/1);
 773                 ccb->ccb_h.status |= CAM_DEV_QFRZN;
 774         }
 775 }
 776
 777 static void
 778 ahbdone(struct ahb_softc *ahb, u_int32_t mbox, u_int intstat)
 779 {
 780         struct ecb *ecb;
 781         union ccb *ccb;
 782
 783         ecb = ahbecbptov(ahb, mbox);
 784
 785         if ((ecb->state & ECB_ACTIVE) == 0)
 786                 panic("ecb not active");
 787
 788         ccb = ecb->ccb;
 789
 790         if (ccb != NULL) {
 791                 untimeout(ahbtimeout, ecb, ccb->ccb_h.timeout_ch);
 792                 LIST_REMOVE(&ccb->ccb_h, sim_links.le);
 793
 794                 if ((ccb->ccb_h.flags & CAM_DIR_MASK) != CAM_DIR_NONE) {
 795                         bus_dmasync_op_t op;
 796
 797                         if ((ccb->ccb_h.flags & CAM_DIR_MASK) == CAM_DIR_IN)
 798                                 op = BUS_DMASYNC_POSTREAD;
 799                         else
 800                                 op = BUS_DMASYNC_POSTWRITE;
 801                         bus_dmamap_sync(ahb->buffer_dmat, ecb->dmamap, op);
 802                         bus_dmamap_unload(ahb->buffer_dmat, ecb->dmamap);
 803                 }
 804
 805                 if ((intstat & INTSTAT_MASK) == INTSTAT_ECB_OK) {
 806                         ccb->ccb_h.status = CAM_REQ_CMP;
 807                         ccb->csio.resid = 0;
 808                 } else {
 809                         ahbprocesserror(ahb, ecb, ccb);
 810                 }
 811                 ahbecbfree(ahb, ecb);
 812                 xpt_done(ccb);
 813         } else {
 814                 /* Non CCB Command */
 815                 if ((intstat & INTSTAT_MASK) != INTSTAT_ECB_OK) {
 816                         printf("ahb%ld: Command 0%x Failed %x:%x:%x\n",
 817                                ahb->unit, ecb->hecb.opcode,
 818                                *((u_int16_t*)&ecb->status),
 819                                ecb->status.ha_status, ecb->status.resid_count);
 820                 }
 821                 /* Client owns this ECB and will release it. */
 822         }
 823 }
 824
 825 /*
 826  * Catch an interrupt from the adaptor
 827  */
 828 static void
 829 ahbintr(void *arg)
 830 {
 831         struct    ahb_softc *ahb;
 832         u_int     intstat;
 833         u_int32_t mbox;
 834
 835         ahb = (struct ahb_softc *)arg;
 836
 837         while (ahb_inb(ahb, HOSTSTAT) & HOSTSTAT_INTPEND) {
 838                 /*
 839                  * Fetch information about this interrupt.
 840                  */
 841                 intstat = ahb_inb(ahb, INTSTAT);
 842                 mbox = ahb_inl(ahb, MBOXIN0);
 843
 844                 /*
 845                  * Reset interrupt latch.
 846                  */
 847                 ahb_outb(ahb, CONTROL, CNTRL_CLRINT);
 848
 849                 /*
 850                  * Process the completed operation
 851                  */
 852                 switch (intstat & INTSTAT_MASK) {
 853                 case INTSTAT_ECB_OK:
 854                 case INTSTAT_ECB_CMPWRETRY:
 855                 case INTSTAT_ECB_CMPWERR:
 856                         ahbdone(ahb, mbox, intstat);
 857                         break;
 858                 case INTSTAT_AEN_OCCURED:
 859                         if ((intstat & INTSTAT_TARGET_MASK) == ahb->scsi_id) {
 860                                 /* Bus Reset */
 861                                 xpt_print_path(ahb->path);
 862                                 switch (mbox) {
 863                                 case HS_SCSI_RESET_ADAPTER:
 864                                         printf("Host Adapter Initiated "
 865                                                "Bus Reset occurred\n");
 866                                         break;
 867                                 case HS_SCSI_RESET_INCOMING:
 868                                         printf("Bus Reset Initiated "
 869                                                "by another device occurred\n");
 870                                         break;
 871                                 }
 872                                 /* Notify the XPT */
 873                                 xpt_async(AC_BUS_RESET, ahb->path, NULL);
 874                                 break;
 875                         }
 876                         printf("Unsupported initiator selection AEN occured\n");
 877                         break;
 878                 case INTSTAT_IMMED_OK:
 879                 case INTSTAT_IMMED_ERR:
 880                         ahbhandleimmed(ahb, mbox, intstat);
 881                         break;
 882                 case INTSTAT_HW_ERR:
 883                         panic("Unrecoverable hardware Error Occurred\n");
 884                 }
 885         }
 886 }
 887
 888 static void
 889 ahbexecuteecb(void *arg, bus_dma_segment_t *dm_segs, int nseg, int error)
 890 {
 891         struct    ecb *ecb;
 892         union     ccb *ccb;
 893         struct    ahb_softc *ahb;
 894         u_int32_t ecb_paddr;
 895         int       s;
 896
 897         ecb = (struct ecb *)arg;
 898         ccb = ecb->ccb;
 899         ahb = (struct ahb_softc *)ccb->ccb_h.ccb_ahb_ptr;
 900
 901         if (error != 0) {
 902                 if (error != EFBIG)
 903                         printf("ahb%ld: Unexepected error 0x%x returned from "
 904                                "bus_dmamap_load\n", ahb->unit, error);
 905                 if (ccb->ccb_h.status == CAM_REQ_INPROG) {
 906                         xpt_freeze_devq(ccb->ccb_h.path, /*count*/1);
 907                         ccb->ccb_h.status = CAM_REQ_TOO_BIG|CAM_DEV_QFRZN;
 908                 }
 909                 ahbecbfree(ahb, ecb);
 910                 xpt_done(ccb);
 911                 return;
 912         }
 913
 914         ecb_paddr = ahbecbvtop(ahb, ecb);
 915
 916         if (nseg != 0) {
 917                 ahb_sg_t *sg;
 918                 bus_dma_segment_t *end_seg;
 919                 bus_dmasync_op_t op;
 920
 921                 end_seg = dm_segs + nseg;
 922
 923                 /* Copy the segments into our SG list */
 924                 sg = ecb->sg_list;
 925                 while (dm_segs < end_seg) {
 926                         sg->addr = dm_segs->ds_addr;
 927                         sg->len = dm_segs->ds_len;
 928                         sg++;
 929                         dm_segs++;
 930                 }
 931
 932                 if (nseg > 1) {
 933                         ecb->hecb.flag_word1 |= FW1_SG_ECB;
 934                         ecb->hecb.data_ptr = ahbsgpaddr(ecb_paddr);
 935                         ecb->hecb.data_len = sizeof(ahb_sg_t) * nseg;
 936                 } else {
 937                         ecb->hecb.data_ptr = ecb->sg_list->addr;
 938                         ecb->hecb.data_len = ecb->sg_list->len;
 939                 }
 940
 941                 if ((ccb->ccb_h.flags & CAM_DIR_MASK) == CAM_DIR_IN) {
 942 /*                      ecb->hecb.flag_word2 |= FW2_DATA_DIR_IN; */
 943                         op = BUS_DMASYNC_PREREAD;
 944                 } else {
 945                         op = BUS_DMASYNC_PREWRITE;
 946                 }
 947                 /* ecb->hecb.flag_word2 |= FW2_CHECK_DATA_DIR; */
 948
 949                 bus_dmamap_sync(ahb->buffer_dmat, ecb->dmamap, op);
 950
 951         } else {
 952                 ecb->hecb.data_ptr = 0;
 953                 ecb->hecb.data_len = 0;
 954         }
 955
 956         s = splcam();
 957
 958         /*
 959          * Last time we need to check if this CCB needs to
 960          * be aborted.
 961          */
 962         if (ccb->ccb_h.status != CAM_REQ_INPROG) {
 963                 if (nseg != 0)
 964                         bus_dmamap_unload(ahb->buffer_dmat, ecb->dmamap);
 965                 ahbecbfree(ahb, ecb);
 966                 xpt_done(ccb);
 967                 splx(s);
 968                 return;
 969         }
 970
 971         ecb->state = ECB_ACTIVE;
 972         ccb->ccb_h.status |= CAM_SIM_QUEUED;
 973         LIST_INSERT_HEAD(&ahb->pending_ccbs, &ccb->ccb_h, sim_links.le);
 974
 975         /* Tell the adapter about this command */
 976         ahbqueuembox(ahb, ecb_paddr, ATTN_STARTECB|ccb->ccb_h.target_id);
 977
 978         ccb->ccb_h.timeout_ch = timeout(ahbtimeout, (caddr_t)ecb,
 979                                         (ccb->ccb_h.timeout * hz) / 1000);
 980         splx(s);
 981 }
 982
 983 static void
 984 ahbaction(struct cam_sim *sim, union ccb *ccb)
 985 {
 986         struct  ahb_softc *ahb;
 987
 988         CAM_DEBUG(ccb->ccb_h.path, CAM_DEBUG_TRACE, ("ahbaction\n"));
 989
 990         ahb = (struct ahb_softc *)cam_sim_softc(sim);
 991
 992         switch (ccb->ccb_h.func_code) {
 993         /* Common cases first */
 994         case XPT_SCSI_IO:       /* Execute the requested I/O operation */
 995         {
 996                 struct ecb *ecb;
 997                 struct hardware_ecb *hecb;
 998
 999                 /*
1000                  * get an ecb to use.
1001                  */
1002                 if ((ecb = ahbecbget(ahb)) == NULL) {
1003                         /* Should never occur */
1004                         panic("Failed to get an ecb");
1005                 }
1006
1007                 /*
1008                  * So we can find the ECB when an abort is requested
1009                  */
1010                 ecb->ccb = ccb;
1011                 ccb->ccb_h.ccb_ecb_ptr = ecb;
1012                 ccb->ccb_h.ccb_ahb_ptr = ahb;
1013
1014                 /*
1015                  * Put all the arguments for the xfer in the ecb
1016                  */
1017                 hecb = &ecb->hecb;
1018                 hecb->opcode = ECBOP_INITIATOR_SCSI_CMD;
1019                 hecb->flag_word1 = FW1_AUTO_REQUEST_SENSE
1020                                  | FW1_ERR_STATUS_BLK_ONLY;
1021                 hecb->flag_word2 = ccb->ccb_h.target_lun
1022                                  | FW2_NO_RETRY_ON_BUSY;
1023                 if ((ccb->ccb_h.flags & CAM_TAG_ACTION_VALID) != 0) {
1024                         hecb->flag_word2 |= FW2_TAG_ENB
1025                                          | ((ccb->csio.tag_action & 0x3)
1026                                             << FW2_TAG_TYPE_SHIFT);
1027                 }
1028                 if ((ccb->ccb_h.flags & CAM_DIS_DISCONNECT) != 0)
1029                         hecb->flag_word2 |= FW2_DISABLE_DISC;
1030                 hecb->sense_len = ccb->csio.sense_len;
1031                 hecb->cdb_len = ccb->csio.cdb_len;
1032                 if ((ccb->ccb_h.flags & CAM_CDB_POINTER) != 0) {
1033                         if ((ccb->ccb_h.flags & CAM_CDB_PHYS) == 0) {
1034                                 bcopy(ccb->csio.cdb_io.cdb_ptr,
1035                                       hecb->cdb, hecb->cdb_len);
1036                         } else {
1037                                 /* I guess I could map it in... */
1038                                 ccb->ccb_h.status = CAM_REQ_INVALID;
1039                                 ahbecbfree(ahb, ecb);
1040                                 xpt_done(ccb);
1041                                 return;
1042                         }
1043                 } else {
1044                         bcopy(ccb->csio.cdb_io.cdb_bytes,
1045                               hecb->cdb, hecb->cdb_len);
1046                 }
1047
1048                 /*
1049                  * If we have any data to send with this command,
1050                  * map it into bus space.
1051                  */
1052                 if ((ccb->ccb_h.flags & CAM_DIR_MASK) != CAM_DIR_NONE) {
1053                         if ((ccb->ccb_h.flags & CAM_SCATTER_VALID) == 0) {
1054                                 /*
1055                                  * We've been given a pointer
1056                                  * to a single buffer.
1057                                  */
1058                                 if ((ccb->ccb_h.flags & CAM_DATA_PHYS)==0) {
1059                                         int s;
1060                                         int error;
1061
1062                                         s = splsoftvm();
1063                                         error = bus_dmamap_load(
1064                                             ahb->buffer_dmat,
1065                                             ecb->dmamap,
1066                                             ccb->csio.data_ptr,
1067                                             ccb->csio.dxfer_len,
1068                                             ahbexecuteecb,
1069                                             ecb, /*flags*/0);
1070                                         if (error == EINPROGRESS) {
1071                                                 /*
1072                                                  * So as to maintain ordering,
1073                                                  * freeze the controller queue
1074                                                  * until our mapping is
1075                                                  * returned.
1076                                                  */
1077                                                 xpt_freeze_simq(ahb->sim, 1);
1078                                                 ccb->ccb_h.status |=
1079                                                     CAM_RELEASE_SIMQ;
1080                                         }
1081                                         splx(s);
1082                                 } else {
1083                                         struct bus_dma_segment seg;
1084
1085                                         /* Pointer to physical buffer */
1086                                         seg.ds_addr =
1087                                             (bus_addr_t)ccb->csio.data_ptr;
1088                                         seg.ds_len = ccb->csio.dxfer_len;
1089                                         ahbexecuteecb(ecb, &seg, 1, 0);
1090                                 }
1091                         } else {
1092                                 struct bus_dma_segment *segs;
1093
1094                                 if ((ccb->ccb_h.flags & CAM_DATA_PHYS) != 0)
1095                                         panic("ahbaction - Physical segment "
1096                                               "pointers unsupported");
1097
1098                                 if ((ccb->ccb_h.flags & CAM_SG_LIST_PHYS) == 0)
1099                                         panic("btaction - Virtual segment "
1100                                               "addresses unsupported");
1101
1102                                 /* Just use the segments provided */
1103                                 segs = (struct bus_dma_segment *)
1104                                     ccb->csio.data_ptr;
1105                                 ahbexecuteecb(ecb, segs, ccb->csio.sglist_cnt,
1106                                              0);
1107                         }
1108                 } else {
1109                         ahbexecuteecb(ecb, NULL, 0, 0);
1110                 }
1111                 break;
1112         }
1113         case XPT_EN_LUN:                /* Enable LUN as a target */
1114         case XPT_TARGET_IO:             /* Execute target I/O request */
1115         case XPT_ACCEPT_TARGET_IO:      /* Accept Host Target Mode CDB */
1116         case XPT_CONT_TARGET_IO:        /* Continue Host Target I/O Connection*/
1117         case XPT_ABORT:                 /* Abort the specified CCB */
1118                 /* XXX Implement */
1119                 ccb->ccb_h.status = CAM_REQ_INVALID;
1120                 xpt_done(ccb);
1121                 break;
1122         case XPT_SET_TRAN_SETTINGS:
1123         {
1124                 ccb->ccb_h.status = CAM_FUNC_NOTAVAIL;
1125                 xpt_done(ccb);
1126                 break;
1127         }
1128         case XPT_GET_TRAN_SETTINGS:
1129         /* Get default/user set transfer settings for the target */
1130         {
1131                 struct  ccb_trans_settings *cts;
1132                 u_int   target_mask;
1133
1134                 cts = &ccb->cts;
1135                 target_mask = 0x01 << ccb->ccb_h.target_id;
1136                 if ((cts->flags & CCB_TRANS_USER_SETTINGS) != 0) {
1137                         cts->flags = 0;
1138                         if ((ahb->disc_permitted & target_mask) != 0)
1139                                 cts->flags |= CCB_TRANS_DISC_ENB;
1140                         if ((ahb->tags_permitted & target_mask) != 0)
1141                                 cts->flags |= CCB_TRANS_TAG_ENB;
1142                         cts->bus_width = MSG_EXT_WDTR_BUS_8_BIT;
1143                         cts->sync_period = 25; /* 10MHz */
1144
1145                         if (cts->sync_period != 0)
1146                                 cts->sync_offset = 15;
1147
1148                         cts->valid = CCB_TRANS_SYNC_RATE_VALID
1149                                    | CCB_TRANS_SYNC_OFFSET_VALID
1150                                    | CCB_TRANS_BUS_WIDTH_VALID
1151                                    | CCB_TRANS_DISC_VALID
1152                                    | CCB_TRANS_TQ_VALID;
1153                         ccb->ccb_h.status = CAM_REQ_CMP;
1154                 } else {
1155                         ccb->ccb_h.status = CAM_FUNC_NOTAVAIL;
1156                 }
1157                 xpt_done(ccb);
1158                 break;
1159         }
1160         case XPT_RESET_DEV:     /* Bus Device Reset the specified SCSI device */
1161         {
1162                 int i;
1163                 int s;
1164
1165                 s = splcam();
1166                 ahb->immed_cmd = IMMED_RESET;
1167                 ahbqueuembox(ahb, IMMED_RESET, ATTN_IMMED|ccb->ccb_h.target_id);
1168                 /* Poll for interrupt completion */
1169                 for (i = 1000; ahb->immed_cmd != 0 && i != 0; i--) {
1170                         DELAY(1000);
1171                         ahbintr(cam_sim_softc(sim));
1172                 }
1173                 splx(s);
1174                 break;
1175         }
1176         case XPT_CALC_GEOMETRY:
1177         {
1178                 cam_calc_geometry(&ccb->ccg, ahb->extended_trans);
1179                 xpt_done(ccb);
1180                 break;
1181         }
1182         case XPT_RESET_BUS:             /* Reset the specified SCSI bus */
1183         {
1184                 int i;
1185
1186                 ahb->immed_cmd = IMMED_RESET;
1187                 ahbqueuembox(ahb, IMMED_RESET, ATTN_IMMED|ahb->scsi_id);
1188                 /* Poll for interrupt completion */
1189                 for (i = 1000; ahb->immed_cmd != 0 && i != 0; i--)
1190                         DELAY(1000);
1191                 ccb->ccb_h.status = CAM_REQ_CMP;
1192                 xpt_done(ccb);
1193                 break;
1194         }
1195         case XPT_TERM_IO:               /* Terminate the I/O process */
1196                 /* XXX Implement */
1197                 ccb->ccb_h.status = CAM_REQ_INVALID;
1198                 xpt_done(ccb);
1199                 break;
1200         case XPT_PATH_INQ:              /* Path routing inquiry */
1201         {
1202                 struct ccb_pathinq *cpi = &ccb->cpi;
1203
1204                 cpi->version_num = 1; /* XXX??? */
1205                 cpi->hba_inquiry = PI_SDTR_ABLE|PI_TAG_ABLE;
1206                 cpi->target_sprt = 0;
1207                 cpi->hba_misc = 0;
1208                 cpi->hba_eng_cnt = 0;
1209                 cpi->max_target = 7;
1210                 cpi->max_lun = 7;
1211                 cpi->initiator_id = ahb->scsi_id;
1212                 cpi->bus_id = cam_sim_bus(sim);
1213                 cpi->base_transfer_speed = 3300;
1214                 strncpy(cpi->sim_vid, "FreeBSD", SIM_IDLEN);
1215                 strncpy(cpi->hba_vid, "Adaptec", HBA_IDLEN);
1216                 strncpy(cpi->dev_name, cam_sim_name(sim), DEV_IDLEN);
1217                 cpi->unit_number = cam_sim_unit(sim);
1218                 cpi->ccb_h.status = CAM_REQ_CMP;
1219                 xpt_done(ccb);
1220                 break;
1221         }
1222 #if 0
1223         /* Need these??? */
1224         case XPT_IMMED_NOTIFY:          /* Notify Host Target driver of event */
1225         case XPT_NOTIFY_ACK:            /* Acknowledgement of event */
1226 #endif
1227         default:
1228                 ccb->ccb_h.status = CAM_REQ_INVALID;
1229                 xpt_done(ccb);
1230                 break;
1231         }
1232 }
1233
1234 static void
1235 ahbpoll(struct cam_sim *sim)
1236 {
1237         ahbintr(cam_sim_softc(sim));
1238 }
1239
1240 static void
1241 ahbtimeout(void *arg)
1242 {
1243         struct ecb       *ecb;
1244         union  ccb       *ccb;
1245         struct ahb_softc *ahb;
1246         int               s;
1247
1248         ecb = (struct ecb *)arg;
1249         ccb = ecb->ccb;
1250         ahb = (struct ahb_softc *)ccb->ccb_h.ccb_ahb_ptr;
1251         xpt_print_path(ccb->ccb_h.path);
1252         printf("ECB %p - timed out\n", (void *)ecb);
1253
1254         s = splcam();
1255
1256         if ((ecb->state & ECB_ACTIVE) == 0) {
1257                 xpt_print_path(ccb->ccb_h.path);
1258                 printf("ECB %p - timed out ECB already completed\n",
1259                        (void *)ecb);
1260                 splx(s);
1261                 return;
1262         }
1263         /*
1264          * In order to simplify the recovery process, we ask the XPT
1265          * layer to halt the queue of new transactions and we traverse
1266          * the list of pending CCBs and remove their timeouts. This
1267          * means that the driver attempts to clear only one error
1268          * condition at a time.  In general, timeouts that occur
1269          * close together are related anyway, so there is no benefit
1270          * in attempting to handle errors in parrallel.  Timeouts will
1271          * be reinstated when the recovery process ends.
1272          */
1273         if ((ecb->state & ECB_DEVICE_RESET) == 0) {
1274                 struct ccb_hdr *ccb_h;
1275
1276                 if ((ecb->state & ECB_RELEASE_SIMQ) == 0) {
1277                         xpt_freeze_simq(ahb->sim, /*count*/1);
1278                         ecb->state |= ECB_RELEASE_SIMQ;
1279                 }
1280
1281                 ccb_h = LIST_FIRST(&ahb->pending_ccbs);
1282                 while (ccb_h != NULL) {
1283                         struct ecb *pending_ecb;
1284
1285                         pending_ecb = (struct ecb *)ccb_h->ccb_ecb_ptr;
1286                         untimeout(ahbtimeout, pending_ecb, ccb_h->timeout_ch);
1287                         ccb_h = LIST_NEXT(ccb_h, sim_links.le);
1288                 }
1289
1290                 /* Store for our interrupt handler */
1291                 ahb->immed_ecb = ecb;
1292
1293                 /*
1294                  * Send a Bus Device Reset message:
1295                  * The target that is holding up the bus may not
1296                  * be the same as the one that triggered this timeout
1297                  * (different commands have different timeout lengths),
1298                  * but we have no way of determining this from our
1299                  * timeout handler.  Our strategy here is to queue a
1300                  * BDR message to the target of the timed out command.
1301                  * If this fails, we'll get another timeout 2 seconds
1302                  * later which will attempt a bus reset.
1303                  */
1304                 xpt_print_path(ccb->ccb_h.path);
1305                 printf("Queuing BDR\n");
1306                 ecb->state |= ECB_DEVICE_RESET;
1307                 ccb->ccb_h.timeout_ch =
1308                     timeout(ahbtimeout, (caddr_t)ecb, 2 * hz);
1309
1310                 ahb->immed_cmd = IMMED_RESET;
1311                 ahbqueuembox(ahb, IMMED_RESET, ATTN_IMMED|ccb->ccb_h.target_id);
1312         } else if ((ecb->state & ECB_SCSIBUS_RESET) != 0) {
1313                 /*
1314                  * Try a SCSI bus reset.  We do this only if we
1315                  * have already attempted to clear the condition with a BDR.
1316                  */
1317                 xpt_print_path(ccb->ccb_h.path);
1318                 printf("Attempting SCSI Bus reset\n");
1319                 ecb->state |= ECB_SCSIBUS_RESET;
1320                 ccb->ccb_h.timeout_ch =
1321                     timeout(ahbtimeout, (caddr_t)ecb, 2 * hz);
1322                 ahb->immed_cmd = IMMED_RESET;
1323                 ahbqueuembox(ahb, IMMED_RESET, ATTN_IMMED|ahb->scsi_id);
1324         } else {
1325                 /* Bring out the hammer... */
1326                 ahbreset(ahb);
1327
1328                 /* Simulate the reset complete interrupt */
1329                 ahbhandleimmed(ahb, 0, ahb->scsi_id|INTSTAT_IMMED_OK);
1330         }
1331
1332         splx(s);
1333 }
1334
1335 static device_method_t ahb_eisa_methods[] = {
1336         /* Device interface */
1337         DEVMETHOD(device_probe,         ahbprobe),
1338         DEVMETHOD(device_attach,        ahbattach),
1339
1340         { 0, 0 }
1341 };
1342
1343 static driver_t ahb_eisa_driver = {
1344         "ahb",
1345         ahb_eisa_methods,
1346         1,                      /* unused */
1347 };
1348
1349 static devclass_t ahb_devclass;
1350
1351 DRIVER_MODULE(ahb, eisa, ahb_eisa_driver, ahb_devclass, 0, 0);