123353Smckusick /* 2*25653Skarels * @(#)uda.c 6.15 (Berkeley) 12/19/85 323353Smckusick */ 423353Smckusick 517553Skarels /************************************************************************ 617553Skarels * * 717553Skarels * Copyright (c) 1983 by * 817553Skarels * Digital Equipment Corporation, Maynard, MA * 917553Skarels * All rights reserved. * 1017553Skarels * * 1117553Skarels ************************************************************************/ 1217553Skarels /* 1317553Skarels * uda.c - UDA50A Driver 1417553Skarels * 15*25653Skarels * decvax!rich 1617553Skarels */ 1717553Skarels 1817553Skarels #define DEBUG 1917553Skarels #define UDADEVNUM (9) /* entry in bdevsw */ 204743Swnj #include "ra.h" 2117642Skarels #if NUDA > 0 224743Swnj /* 234743Swnj * UDA50/RAxx disk device driver 244743Swnj * 254743Swnj * Restrictions: 2617553Skarels * Unit numbers must be less than 8. 274743Swnj */ 289781Ssam #include "../machine/pte.h" 294743Swnj 3017553Skarels #include "param.h" 3117553Skarels #include "systm.h" 3217553Skarels #include "buf.h" 3317553Skarels #include "conf.h" 3417553Skarels #include "dir.h" 3517553Skarels #include "user.h" 3617553Skarels #include "map.h" 3717553Skarels #include "vm.h" 3817553Skarels #include "dk.h" 3917553Skarels #include "cmap.h" 4017553Skarels #include "uio.h" 414743Swnj 428482Sroot #include "../vax/cpu.h" 4317553Skarels #include "ubareg.h" 4417553Skarels #include "ubavar.h" 4517553Skarels #include "../vax/mtpr.h" 468613Sroot 4717553Skarels #define TENSEC (1000) 4817553Skarels 4917553Skarels #define NRSPL2 3 /* log2 number of response packets */ 5017553Skarels #define NCMDL2 3 /* log2 number of command packets */ 5117553Skarels #define NRSP (1<<NRSPL2) 5217553Skarels #define NCMD (1<<NCMDL2) 538613Sroot 548482Sroot #include "../vaxuba/udareg.h" 558482Sroot #include "../vax/mscp.h" 564743Swnj 5717553Skarels 584743Swnj struct uda_softc { 5917553Skarels short sc_state; /* state of controller */ 6017553Skarels short sc_mapped; /* Unibus map allocated for uda struct? */ 6117553Skarels int sc_ubainfo; /* Unibus mapping info */ 6217553Skarels struct uda *sc_uda; /* Unibus address of uda struct */ 6317553Skarels int sc_ivec; /* interrupt vector address */ 6417553Skarels short sc_credits; /* transfer credits */ 6517553Skarels short sc_lastcmd; /* pointer into command ring */ 6617553Skarels short sc_lastrsp; /* pointer into response ring */ 674743Swnj } uda_softc[NUDA]; 684743Swnj struct uda { 6917553Skarels struct udaca uda_ca; /* communications area */ 7017553Skarels struct mscp uda_rsp[NRSP]; /* response packets */ 7117553Skarels struct mscp uda_cmd[NCMD]; /* command packets */ 724743Swnj } uda[NUDA]; 734743Swnj 7424742Sbloom #define udunit(dev) (minor(dev) >> 3) 7524742Sbloom 764743Swnj /* THIS SHOULD BE READ OFF THE PACK, PER DRIVE */ 774743Swnj struct size { 7817553Skarels daddr_t nblocks; 7917553Skarels daddr_t blkoff; 8017553Skarels } ra25_sizes[8] = { 814743Swnj 15884, 0, /* A=blk 0 thru 15883 */ 8217553Skarels 10032, 15884, /* B=blk 15884 thru 49323 */ 8317553Skarels -1, 0, /* C=blk 0 thru end */ 8417553Skarels 0, 0, /* D=blk 340670 thru 356553 */ 8517553Skarels 0, 0, /* E=blk 356554 thru 412489 */ 8617553Skarels 0, 0, /* F=blk 412490 thru end */ 8717553Skarels -1, 25916, /* G=blk 49324 thru 131403 */ 8817553Skarels 0, 0, /* H=blk 131404 thru end */ 8917553Skarels }, ra60_sizes[8] = { 9025178Smckusick 15884, 0, /* A=sectors 0 thru 15883 */ 9125178Smckusick 33440, 15884, /* B=sectors 15884 thru 49323 */ 9225178Smckusick 400176, 0, /* C=sectors 0 thru 400175 */ 9325178Smckusick 82080, 49324, /* 4.2 G => D=sectors 49324 thru 131403 */ 9425178Smckusick 268772, 131404, /* 4.2 H => E=sectors 131404 thru 400175 */ 9525178Smckusick 350852, 49324, /* F=sectors 49324 thru 400175 */ 9625178Smckusick 157570, 242606, /* UCB G => G=sectors 242606 thru 400175 */ 9725178Smckusick 193282, 49324, /* UCB H => H=sectors 49324 thru 242605 */ 9817553Skarels }, ra80_sizes[8] = { 9925178Smckusick 15884, 0, /* A=sectors 0 thru 15883 */ 10025178Smckusick 33440, 15884, /* B=sectors 15884 thru 49323 */ 10125178Smckusick 242606, 0, /* C=sectors 0 thru 242605 */ 10217642Skarels 0, 0, /* D=unused */ 10325178Smckusick 193282, 49324, /* UCB H => E=sectors 49324 thru 242605 */ 10425178Smckusick 82080, 49324, /* 4.2 G => F=sectors 49324 thru 131403 */ 10525178Smckusick 192696, 49910, /* G=sectors 49910 thru 242605 */ 10625178Smckusick 111202, 131404, /* 4.2 H => H=sectors 131404 thru 242605 */ 10717553Skarels }, ra81_sizes[8] ={ 10825178Smckusick /* 10925178Smckusick * These are the new standard partition sizes for ra81's. 110*25653Skarels * An RA_COMPAT system is compiled with D, E, and F corresponding 11125178Smckusick * to the 4.2 partitions for G, H, and F respectively. 11225178Smckusick */ 11325178Smckusick #ifndef UCBRA 11425178Smckusick 15884, 0, /* A=sectors 0 thru 15883 */ 11525178Smckusick 66880, 16422, /* B=sectors 16422 thru 83301 */ 11625178Smckusick 891072, 0, /* C=sectors 0 thru 891071 */ 117*25653Skarels #ifdef RA_COMPAT 11825178Smckusick 82080, 49324, /* 4.2 G => D=sectors 49324 thru 131403 */ 11925178Smckusick 759668, 131404, /* 4.2 H => E=sectors 131404 thru 891071 */ 12025178Smckusick 478582, 412490, /* 4.2 F => F=sectors 412490 thru 891071 */ 12125178Smckusick #else 12225178Smckusick 15884, 375564, /* D=sectors 375564 thru 391447 */ 12325178Smckusick 307200, 391986, /* E=sectors 391986 thru 699185 */ 12425178Smckusick 191352, 699720, /* F=sectors 699720 thru 891071 */ 125*25653Skarels #endif RA_COMPAT 12625178Smckusick 515508, 375564, /* G=sectors 375564 thru 891071 */ 12725178Smckusick 291346, 83538, /* H=sectors 83538 thru 374883 */ 12825178Smckusick 12925178Smckusick /* 13025178Smckusick * These partitions correspond to the sizes used by sites at Berkeley, 13125178Smckusick * and by those sites that have received copies of the Berkeley driver 13225178Smckusick * with deltas 6.2 or greater (11/15/83). 13325178Smckusick */ 13425178Smckusick #else UCBRA 13525178Smckusick 13625178Smckusick 15884, 0, /* A=sectors 0 thru 15883 */ 13725178Smckusick 33440, 15884, /* B=sectors 15884 thru 49323 */ 13825178Smckusick 891072, 0, /* C=sectors 0 thru 891071 */ 13925178Smckusick 15884, 242606, /* D=sectors 242606 thru 258489 */ 14025178Smckusick 307200, 258490, /* E=sectors 258490 thru 565689 */ 14125178Smckusick 325382, 565690, /* F=sectors 565690 thru 891071 */ 14225178Smckusick 648466, 242606, /* G=sectors 242606 thru 891071 */ 14325178Smckusick 193282, 49324, /* H=sectors 49324 thru 242605 */ 14425178Smckusick 14525178Smckusick #endif UCBRA 1464743Swnj }; 14717553Skarels 14817553Skarels struct ra_info { 14917553Skarels struct size *ra_sizes; /* Partion tables for drive */ 15017553Skarels daddr_t radsize; /* Max user size form online pkt */ 15117553Skarels unsigned ratype; /* Drive type int field */ 15217553Skarels unsigned rastatus; /* Command status from */ 15317553Skarels /* last onlin or GTUNT */ 15417553Skarels } ra_info[NRA]; 15517553Skarels 15617553Skarels 1574743Swnj /* END OF STUFF WHICH SHOULD BE READ IN PER DISK */ 15817553Skarels struct uba_ctlr *udminfo[NUDA]; 15917553Skarels struct uba_device *uddinfo[NRA]; 16017553Skarels struct uba_device *udip[NUDA][8]; /* 8 == max number of drives */ 16117553Skarels struct buf rudbuf[NRA]; 16217553Skarels struct buf udutab[NRA]; 16317553Skarels struct buf udwtab[NUDA]; /* I/O wait queue, per controller */ 1644743Swnj 16512421Ssam 16617553Skarels int nNRA = NRA; 16717553Skarels int nNUDA = NUDA; 16817553Skarels int udamicro[NUDA]; /* to store microcode level */ 1694743Swnj 1704743Swnj 17117553Skarels /* 17217553Skarels * Controller states 17317553Skarels */ 17417553Skarels #define S_IDLE 0 /* hasn't been initialized */ 17517553Skarels #define S_STEP1 1 /* doing step 1 init */ 17617553Skarels #define S_STEP2 2 /* doing step 2 init */ 17717553Skarels #define S_STEP3 3 /* doing step 3 init */ 17817553Skarels #define S_SCHAR 4 /* doing "set controller characteristics" */ 17917553Skarels #define S_RUN 5 /* running */ 18017553Skarels 18117553Skarels 18217553Skarels int udaerror = 0; /* causes hex dump of packets */ 18317553Skarels int udadebug = 0; 18417553Skarels int uda_cp_wait = 0; /* Something to wait on for command */ 18517553Skarels /* packets and or credits. */ 18617553Skarels int wakeup(); 18717553Skarels extern int hz; /* Should find the right include */ 18817553Skarels #ifdef DEBUG 18917553Skarels #define printd if (udadebug) printf 19017553Skarels #define printd10 if(udadebug >= 10) printf 19117553Skarels #endif 19217553Skarels #define mprintf printf /* temporary JG hack until Rich fixes*/ 19317553Skarels 19417553Skarels int udprobe(), udslave(), udattach(), udintr(); 19517553Skarels struct mscp *udgetcp(); 19617553Skarels 19717553Skarels u_short udstd[] = { 0772150, 0772550, 0777550, 0 }; 19817553Skarels struct uba_driver udadriver = 1994743Swnj { udprobe, udslave, udattach, 0, udstd, "ra", uddinfo, "uda", udminfo, 0 }; 2004743Swnj 20117553Skarels #define b_qsize b_resid /* queue size per drive, in udutab */ 20217553Skarels #define b_ubinfo b_resid /* Unibus mapping info, per buffer */ 2034743Swnj 2044743Swnj udprobe(reg, ctlr) 2054743Swnj caddr_t reg; 2064743Swnj int ctlr; 2074743Swnj { 2084743Swnj register int br, cvec; 2094743Swnj register struct uda_softc *sc = &uda_softc[ctlr]; 21017553Skarels struct udadevice *udaddr; 2114743Swnj 21217553Skarels int cur_time; 21317553Skarels 2144743Swnj #ifdef lint 21517553Skarels br = 0; cvec = br; br = cvec; 21612778Ssam udreset(0); udintr(0); 2174743Swnj #endif 21817553Skarels udaddr = (struct udadevice *) reg; 21917553Skarels 22017553Skarels sc->sc_ivec = (uba_hd[numuba].uh_lastiv -= 4); 22117553Skarels udaddr->udaip = 0; /* start initialization */ 22217553Skarels 22317553Skarels cur_time = mfpr(TODR); /* Time of day */ 22417553Skarels while(cur_time + TENSEC > mfpr(TODR)){ /* wait for at most 10 secs */ 22517553Skarels if((udaddr->udasa & UDA_STEP1) != 0) 22617553Skarels break; 22717553Skarels } 22817553Skarels if(cur_time + TENSEC <= mfpr(TODR)) 22917553Skarels return(0); /* Not a uda or it won't init as it */ 23017553Skarels /* should within ten seconds. */ 23117553Skarels udaddr->udasa=UDA_ERR|(NCMDL2<<11)|(NRSPL2<<8)|UDA_IE|(sc->sc_ivec/4); 23217553Skarels while((udaddr->udasa&UDA_STEP2)==0) 23317553Skarels DELAY(1000); /* intr should have */ 23417553Skarels /* have happened by now */ 23517553Skarels 2367410Skre return(sizeof (struct udadevice)); 2374743Swnj } 2384743Swnj 2394743Swnj udslave(ui, reg) 2404743Swnj struct uba_device *ui; 2414743Swnj caddr_t reg; 2424743Swnj { 24317553Skarels register struct uba_ctlr *um = udminfo[ui->ui_ctlr]; 24417553Skarels register struct uda_softc *sc = &uda_softc[ui->ui_ctlr]; 24517553Skarels struct udadevice *udaddr; 24617553Skarels struct mscp *mp; 24717553Skarels int i; /* Something to write into to start */ 24817553Skarels /* the uda polling */ 24917553Skarels 25017553Skarels 2516187Ssam #ifdef lint 25217553Skarels ui = ui; reg = reg; i = i; 2536187Ssam #endif 25417553Skarels udaddr = (struct udadevice *)um->um_addr; 25517553Skarels if(sc->sc_state != S_RUN){ 25617553Skarels if(!udinit(ui->ui_ctlr)) 25717553Skarels return(0); 25817553Skarels } 25917553Skarels /* Here we will wait for the controller */ 26017553Skarels /* to come into the run state or go idle. If we go idle we are in */ 26117553Skarels /* touble and I don't yet know what to do so I will punt */ 26217553Skarels while(sc->sc_state != S_RUN && sc->sc_state != S_IDLE); /* spin */ 26317553Skarels if(sc->sc_state == S_IDLE){ /* The Uda failed to initialize */ 26417553Skarels printf("UDA failed to init\n"); 26517553Skarels return(0); 26617553Skarels } 26717553Skarels /* The controller is up so let see if the drive is there! */ 26817553Skarels if(0 == (mp = udgetcp(um))){ /* ditto */ 26917553Skarels printf("UDA can't get command packet\n"); 27017553Skarels return(0); 27117553Skarels } 27217553Skarels mp->mscp_opcode = M_OP_GTUNT; /* This should give us the drive type*/ 27317553Skarels mp->mscp_unit = ui->ui_slave; 27417553Skarels mp->mscp_cmdref = (long) ui->ui_slave; 27517553Skarels #ifdef DEBUG 27617553Skarels printd("uda%d Get unit status slave %d\n",ui->ui_ctlr,ui->ui_slave); 27717553Skarels #endif 27817553Skarels ra_info[ui->ui_unit].rastatus = 0; /* set to zero */ 27917553Skarels udip[ui->ui_ctlr][ui->ui_slave] = ui; 28017553Skarels *((long *) mp->mscp_dscptr ) |= UDA_OWN | UDA_INT;/* maybe we should poll*/ 28117553Skarels i = udaddr->udaip; 28217553Skarels while(!ra_info[ui->ui_unit].rastatus); /* Wait for some status */ 28317553Skarels udip[ui->ui_ctlr][ui->ui_slave] = 0; 28417553Skarels if(!ra_info[ui->ui_unit].ratype) /* packet from a GTUNT */ 28517553Skarels return(0); /* Failed No such drive */ 28617553Skarels else 28717553Skarels return(1); /* Got it and it is there */ 2884743Swnj } 2894743Swnj 2904743Swnj udattach(ui) 2914743Swnj register struct uba_device *ui; 2924743Swnj { 29317553Skarels register struct uba_ctlr *um = ui->ui_mi ; 29417553Skarels struct udadevice *udaddr = (struct udadevice *) um->um_addr; 29517553Skarels struct mscp *mp; 29617553Skarels int i; /* Something to write into to start */ 29717553Skarels /* the uda polling */ 29817553Skarels #ifdef lint 29917553Skarels i = i; 30017553Skarels #endif 30112443Ssam if (ui->ui_dk >= 0) 30217553Skarels dk_mspw[ui->ui_dk] = 1.0 / (60 * 31 * 256); /* approx */ 3034743Swnj ui->ui_flags = 0; 3044743Swnj udip[ui->ui_ctlr][ui->ui_slave] = ui; 30517553Skarels /* check to see if the drive is a available if it is bring it online */ 30617553Skarels /* if not then just return. open will try an online later */ 30717553Skarels if(ra_info[ui->ui_unit].rastatus != M_ST_AVLBL) 30817553Skarels return; /* status was set by a GTUNT */ 30917553Skarels if(0 == (mp = udgetcp(um))){ /* ditto */ 31017553Skarels printf("UDA can't get command packet\n"); 31117553Skarels return; 31217553Skarels } 31317553Skarels mp->mscp_opcode = M_OP_ONLIN; 31417553Skarels mp->mscp_unit = ui->ui_slave; 31517553Skarels mp->mscp_cmdref = (long) ui->ui_slave; 31617553Skarels #ifdef DEBUG 31717553Skarels printd("uda%d ONLIN slave %d\n",ui->ui_ctlr,ui->ui_slave); 31817553Skarels #endif 31917553Skarels *((long *) mp->mscp_dscptr ) |= UDA_OWN | UDA_INT; 32017553Skarels i = udaddr->udaip; 32117553Skarels while(ui->ui_flags == 0 && ra_info[ui->ui_unit].ratype != 0); 3224743Swnj } 3234743Swnj 3244743Swnj /* 3254743Swnj * Open a UDA. Initialize the device and 3264743Swnj * set the unit online. 3274743Swnj */ 3284743Swnj udopen(dev, flag) 3294743Swnj dev_t dev; 3304743Swnj int flag; 3314743Swnj { 3324743Swnj register int unit; 3334743Swnj register struct uba_device *ui; 3344743Swnj register struct uda_softc *sc; 33517553Skarels register struct mscp *mp; 33617553Skarels register struct uba_ctlr *um; 33717553Skarels struct udadevice *udaddr; 33817553Skarels int s,i; 33917553Skarels extern quota; 34017553Skarels 3416187Ssam #ifdef lint 34217553Skarels flag = flag; i = i; 3436187Ssam #endif 34424742Sbloom unit = udunit(dev); 34517553Skarels if (unit >= nNRA || (ui = uddinfo[unit]) == 0 || ui->ui_alive == 0) 3468576Sroot return (ENXIO); 3474743Swnj sc = &uda_softc[ui->ui_ctlr]; 3485434Sroot s = spl5(); 3494743Swnj if (sc->sc_state != S_RUN) { 3504743Swnj if (sc->sc_state == S_IDLE) 35117553Skarels if(!udinit(ui->ui_ctlr)){ 35217553Skarels printf("uda: Controller failed to init\n"); 35325189Skarels (void) splx(s); 35417553Skarels return(ENXIO); 35517553Skarels } 3566187Ssam /* wait for initialization to complete */ 35717553Skarels timeout(wakeup,(caddr_t)ui->ui_mi,11*hz); /* to be sure*/ 3586187Ssam sleep((caddr_t)ui->ui_mi, 0); 3598576Sroot if (sc->sc_state != S_RUN) 36017553Skarels { 36117553Skarels (void) splx(s); /* added by Rich */ 3628576Sroot return (EIO); 36317553Skarels } 3644743Swnj } 36517553Skarels /* check to see if the device is really there. */ 36617553Skarels /* this code was taken from Fred Canters 11 driver */ 36717553Skarels um = ui->ui_mi; 36817553Skarels udaddr = (struct udadevice *) um->um_addr; 36917553Skarels (void) splx(s); 37017553Skarels if(ui->ui_flags == 0){ 37117553Skarels s = spl5(); 37217553Skarels while(0 ==(mp = udgetcp(um))){ 37317553Skarels uda_cp_wait++; 37417553Skarels sleep(&uda_cp_wait,PSWP+1); 37517553Skarels uda_cp_wait--; 37617553Skarels } 37717553Skarels mp->mscp_opcode = M_OP_ONLIN; 37817553Skarels mp->mscp_unit = ui->ui_slave; 37917553Skarels mp->mscp_cmdref = (long) & ra_info[ui->ui_unit].ratype; 38017553Skarels /* need to sleep on something */ 38117553Skarels #ifdef DEBUG 38217553Skarels printd("uda: bring unit %d online\n",ui->ui_unit); 38317553Skarels #endif 38417553Skarels *((long *) mp->mscp_dscptr ) |= UDA_OWN | UDA_INT ; 38517553Skarels i = udaddr->udaip; 38617553Skarels timeout(wakeup,(caddr_t) mp->mscp_cmdref,10 * hz); 38717553Skarels /* make sure we wake up */ 38817553Skarels sleep((caddr_t) mp->mscp_cmdref,PSWP+1); /*wakeup in udrsp() */ 38920851Skarels (void) splx(s); 39017553Skarels } 39117553Skarels if(ui->ui_flags == 0){ 39217553Skarels return(ENXIO); /* Didn't go online */ 39317553Skarels } 3948576Sroot return (0); 3954743Swnj } 3964743Swnj 3974743Swnj /* 3984743Swnj * Initialize a UDA. Set up UBA mapping registers, 3994743Swnj * initialize data structures, and start hardware 4004743Swnj * initialization sequence. 4014743Swnj */ 4024743Swnj udinit(d) 4034743Swnj int d; 4044743Swnj { 4054743Swnj register struct uda_softc *sc; 4064743Swnj register struct uda *ud; 4074743Swnj struct udadevice *udaddr; 4084743Swnj struct uba_ctlr *um; 4094743Swnj 4104743Swnj sc = &uda_softc[d]; 4114743Swnj um = udminfo[d]; 4124743Swnj um->um_tab.b_active++; 4134743Swnj ud = &uda[d]; 4144743Swnj udaddr = (struct udadevice *)um->um_addr; 4154743Swnj if (sc->sc_mapped == 0) { 4164743Swnj /* 4174743Swnj * Map the communications area and command 4184743Swnj * and response packets into Unibus address 4194743Swnj * space. 4204743Swnj */ 4214743Swnj sc->sc_ubainfo = uballoc(um->um_ubanum, (caddr_t)ud, 4224743Swnj sizeof (struct uda), 0); 4234743Swnj sc->sc_uda = (struct uda *)(sc->sc_ubainfo & 0x3ffff); 4244743Swnj sc->sc_mapped = 1; 4254743Swnj } 4264743Swnj 4274743Swnj /* 4284743Swnj * Start the hardware initialization sequence. 4294743Swnj */ 43017553Skarels 43117553Skarels udaddr->udaip = 0; /* start initialization */ 43217553Skarels 43317553Skarels while((udaddr->udasa & UDA_STEP1) == 0){ 43417553Skarels if(udaddr->udasa & UDA_ERR) 43517553Skarels return(0); /* CHECK */ 43617553Skarels } 43717553Skarels udaddr->udasa=UDA_ERR|(NCMDL2<<11)|(NRSPL2<<8)|UDA_IE|(sc->sc_ivec/4); 4384743Swnj /* 4394743Swnj * Initialization continues in interrupt routine. 4404743Swnj */ 4414743Swnj sc->sc_state = S_STEP1; 4424743Swnj sc->sc_credits = 0; 44317553Skarels return(1); 4444743Swnj } 4454743Swnj 4464743Swnj udstrategy(bp) 4474743Swnj register struct buf *bp; 4484743Swnj { 4494743Swnj register struct uba_device *ui; 4504743Swnj register struct uba_ctlr *um; 4514743Swnj register struct buf *dp; 4524743Swnj register int unit; 45317553Skarels register struct size *rasizes; 4544743Swnj int xunit = minor(bp->b_dev) & 07; 4554743Swnj daddr_t sz, maxsz; 4565434Sroot int s; 4574743Swnj 4584743Swnj sz = (bp->b_bcount+511) >> 9; 45924742Sbloom unit = udunit(bp->b_dev); 46024742Sbloom if (unit >= nNRA) { 46124742Sbloom bp->b_error = ENXIO; 4624743Swnj goto bad; 46324742Sbloom } 46417553Skarels rasizes = ra_info[unit].ra_sizes; 4654743Swnj ui = uddinfo[unit]; 4664743Swnj um = ui->ui_mi; 46724742Sbloom if (ui == 0 || ui->ui_alive == 0) { 46824742Sbloom bp->b_error = ENXIO; 4694743Swnj goto bad; 47024742Sbloom } 47117553Skarels if ((maxsz = rasizes[xunit].nblocks) < 0) 47217553Skarels maxsz = ra_info[unit].radsize - rasizes[xunit].blkoff; 4734743Swnj if (bp->b_blkno < 0 || bp->b_blkno+sz > maxsz || 47424742Sbloom rasizes[xunit].blkoff >= ra_info[unit].radsize) { 47524787Skarels if (bp->b_blkno == maxsz) { 47624787Skarels bp->b_resid = bp->b_bcount; 47724742Sbloom goto done; 47824787Skarels } 47924742Sbloom bp->b_error = EINVAL; 4804743Swnj goto bad; 48124742Sbloom } 4825434Sroot s = spl5(); 4834743Swnj /* 4844743Swnj * Link the buffer onto the drive queue 4854743Swnj */ 4864743Swnj dp = &udutab[ui->ui_unit]; 4874743Swnj if (dp->b_actf == 0) 4884743Swnj dp->b_actf = bp; 4894743Swnj else 4904743Swnj dp->b_actl->av_forw = bp; 4914743Swnj dp->b_actl = bp; 4924743Swnj bp->av_forw = 0; 4934743Swnj /* 4944743Swnj * Link the drive onto the controller queue 4954743Swnj */ 4964743Swnj if (dp->b_active == 0) { 4974743Swnj dp->b_forw = NULL; 4984743Swnj if (um->um_tab.b_actf == NULL) 4994743Swnj um->um_tab.b_actf = dp; 5004743Swnj else 5014743Swnj um->um_tab.b_actl->b_forw = dp; 5024743Swnj um->um_tab.b_actl = dp; 5034743Swnj dp->b_active = 1; 5044743Swnj } 5054743Swnj if (um->um_tab.b_active == 0) { 5064743Swnj #if defined(VAX750) 50712421Ssam if (cpu == VAX_750 50812421Ssam && udwtab[um->um_ctlr].av_forw == &udwtab[um->um_ctlr]) { 50917553Skarels if (um->um_ubinfo != 0) { 51017553Skarels printd("udastrat: ubinfo 0x%x\n",um->um_ubinfo); 51117553Skarels } else 5124743Swnj um->um_ubinfo = 51312421Ssam uballoc(um->um_ubanum, (caddr_t)0, 0, 5146187Ssam UBA_NEEDBDP); 5154743Swnj } 5164743Swnj #endif 5174743Swnj (void) udstart(um); 5184743Swnj } 5195434Sroot splx(s); 5204743Swnj return; 5214743Swnj 5224743Swnj bad: 5234743Swnj bp->b_flags |= B_ERROR; 52424742Sbloom done: 5254743Swnj iodone(bp); 5264743Swnj return; 5274743Swnj } 5284743Swnj 5294743Swnj udstart(um) 5304743Swnj register struct uba_ctlr *um; 5314743Swnj { 5324743Swnj register struct buf *bp, *dp; 5334743Swnj register struct mscp *mp; 5344743Swnj register struct uda_softc *sc; 5354743Swnj register struct uba_device *ui; 53617553Skarels struct size *rasizes; 5374743Swnj struct udadevice *udaddr; 53817553Skarels struct uda *ud = &uda[um->um_ctlr]; 5394743Swnj int i; 5404743Swnj 5414743Swnj sc = &uda_softc[um->um_ctlr]; 5424743Swnj 5434743Swnj loop: 5444743Swnj if ((dp = um->um_tab.b_actf) == NULL) { 5454743Swnj /* 5464743Swnj * Release uneeded UBA resources and return 5474743Swnj */ 5484743Swnj um->um_tab.b_active = 0; 54917553Skarels /* Check for response ring transitions lost in the 55017553Skarels * Race condition 55117553Skarels */ 55217553Skarels for (i = sc->sc_lastrsp;; i++) { 55317553Skarels i %= NRSP; 55417553Skarels if (ud->uda_ca.ca_rspdsc[i]&UDA_OWN) 55517553Skarels break; 55617553Skarels udrsp(um, ud, sc, i); 55717553Skarels ud->uda_ca.ca_rspdsc[i] |= UDA_OWN; 55817553Skarels } 55917553Skarels sc->sc_lastrsp = i; 5606187Ssam return (0); 5614743Swnj } 5624743Swnj if ((bp = dp->b_actf) == NULL) { 5634743Swnj /* 5644743Swnj * No more requests for this drive, remove 5654743Swnj * from controller queue and look at next drive. 5664743Swnj * We know we're at the head of the controller queue. 5674743Swnj */ 5684743Swnj dp->b_active = 0; 5694743Swnj um->um_tab.b_actf = dp->b_forw; 57017553Skarels goto loop; /* Need to check for loop */ 5714743Swnj } 5724743Swnj um->um_tab.b_active++; 5734743Swnj udaddr = (struct udadevice *)um->um_addr; 5744743Swnj if ((udaddr->udasa&UDA_ERR) || sc->sc_state != S_RUN) { 5754743Swnj harderr(bp, "ra"); 57617553Skarels mprintf("Uda%d udasa %o, state %d\n",um->um_ctlr , udaddr->udasa&0xffff, sc->sc_state); 5774743Swnj udinit(um->um_ctlr); 5784743Swnj /* SHOULD REQUEUE OUTSTANDING REQUESTS, LIKE UDRESET */ 5796187Ssam return (0); 5804743Swnj } 58124742Sbloom ui = uddinfo[udunit(bp->b_dev)]; 58217553Skarels rasizes = ra_info[ui->ui_unit].ra_sizes; 58317553Skarels if (ui->ui_flags == 0) { /* not online */ 58417553Skarels if ((mp = udgetcp(um)) == NULL){ 58517553Skarels return (0); 58617553Skarels } 5874743Swnj mp->mscp_opcode = M_OP_ONLIN; 5884743Swnj mp->mscp_unit = ui->ui_slave; 5894743Swnj dp->b_active = 2; 59017553Skarels um->um_tab.b_actf = dp->b_forw; /* remove from controller q */ 59117553Skarels #ifdef DEBUG 5924743Swnj printd("uda: bring unit %d online\n", ui->ui_slave); 59317553Skarels #endif 5944743Swnj *((long *)mp->mscp_dscptr) |= UDA_OWN|UDA_INT; 59517553Skarels if (udaddr->udasa&UDA_ERR) 59617553Skarels printf("Uda (%d) Error (%x)\n",um->um_ctlr , udaddr->udasa&0xffff); 5974743Swnj i = udaddr->udaip; 5984743Swnj goto loop; 5994743Swnj } 6004743Swnj switch (cpu) { 60124186Sbloom case VAX_8600: 6024743Swnj case VAX_780: 6034743Swnj i = UBA_NEEDBDP|UBA_CANTWAIT; 6044743Swnj break; 6054743Swnj 6064743Swnj case VAX_750: 6074743Swnj i = um->um_ubinfo|UBA_HAVEBDP|UBA_CANTWAIT; 6084743Swnj break; 6094743Swnj 6106949Ssam case VAX_730: 6114743Swnj i = UBA_CANTWAIT; 6124743Swnj break; 6134743Swnj } 61424388Skarels if ((i = ubasetup(um->um_ubanum, bp, i)) == 0) 61524388Skarels return(1); 61617553Skarels if ((mp = udgetcp(um)) == NULL) { 617*25653Skarels #if defined(VAX750) 618*25653Skarels if (cpu == VAX_750) 619*25653Skarels i &= 0xfffffff; /* mask off bdp */ 620*25653Skarels #endif 62117553Skarels ubarelse(um->um_ubanum,&i); 62217553Skarels return(0); 62317553Skarels } 62417553Skarels mp->mscp_cmdref = (long)bp; /* pointer to get back */ 6254743Swnj mp->mscp_opcode = bp->b_flags&B_READ ? M_OP_READ : M_OP_WRITE; 6264743Swnj mp->mscp_unit = ui->ui_slave; 62717553Skarels mp->mscp_lbn = bp->b_blkno + rasizes[minor(bp->b_dev)&7].blkoff; 6284743Swnj mp->mscp_bytecnt = bp->b_bcount; 6294743Swnj mp->mscp_buffer = (i & 0x3ffff) | (((i>>28)&0xf)<<24); 6304743Swnj #if defined(VAX750) 6314743Swnj if (cpu == VAX_750) 63217553Skarels i &= 0xfffffff; /* mask off bdp */ 6334743Swnj #endif 63417553Skarels bp->b_ubinfo = i; /* save mapping info */ 6354743Swnj *((long *)mp->mscp_dscptr) |= UDA_OWN|UDA_INT; 63617553Skarels if (udaddr->udasa&UDA_ERR) 63717553Skarels printf("Uda(%d) udasa (%x)\n",um->um_ctlr , udaddr->udasa&0xffff); 63817553Skarels i = udaddr->udaip; /* initiate polling */ 63917553Skarels dp->b_qsize++; 6404743Swnj if (ui->ui_dk >= 0) { 6414743Swnj dk_busy |= 1<<ui->ui_dk; 6424743Swnj dk_xfer[ui->ui_dk]++; 6434743Swnj dk_wds[ui->ui_dk] += bp->b_bcount>>6; 6444743Swnj } 6454743Swnj 6464743Swnj /* 6474743Swnj * Move drive to the end of the controller queue 6484743Swnj */ 6494743Swnj if (dp->b_forw != NULL) { 6504743Swnj um->um_tab.b_actf = dp->b_forw; 6514743Swnj um->um_tab.b_actl->b_forw = dp; 6524743Swnj um->um_tab.b_actl = dp; 6534743Swnj dp->b_forw = NULL; 6544743Swnj } 6554743Swnj /* 6564743Swnj * Move buffer to I/O wait queue 6574743Swnj */ 6584743Swnj dp->b_actf = bp->av_forw; 6594743Swnj dp = &udwtab[um->um_ctlr]; 6604743Swnj bp->av_forw = dp; 6614743Swnj bp->av_back = dp->av_back; 6624743Swnj dp->av_back->av_forw = bp; 6634743Swnj dp->av_back = bp; 6644743Swnj goto loop; 6654743Swnj } 6664743Swnj 6674743Swnj /* 6684743Swnj * UDA interrupt routine. 6694743Swnj */ 6704743Swnj udintr(d) 6714743Swnj int d; 6724743Swnj { 6734743Swnj register struct uba_ctlr *um = udminfo[d]; 6744743Swnj register struct udadevice *udaddr = (struct udadevice *)um->um_addr; 6754743Swnj struct buf *bp; 6764743Swnj register int i; 6774743Swnj register struct uda_softc *sc = &uda_softc[d]; 6784743Swnj register struct uda *ud = &uda[d]; 6794743Swnj struct uda *uud; 6804743Swnj struct mscp *mp; 6814743Swnj 68217553Skarels #ifdef DEBUG 68317553Skarels printd10("udintr: state %d, udasa %o\n", sc->sc_state, udaddr->udasa); 68417553Skarels #endif 6854743Swnj switch (sc->sc_state) { 6864743Swnj case S_IDLE: 6874743Swnj printf("uda%d: random interrupt ignored\n", d); 6884743Swnj return; 6894743Swnj 6904743Swnj case S_STEP1: 69117553Skarels #define STEP1MASK 0174377 69217553Skarels #define STEP1GOOD (UDA_STEP2|UDA_IE|(NCMDL2<<3)|NRSPL2) 6936964Ssam if ((udaddr->udasa&STEP1MASK) != STEP1GOOD) { 6944743Swnj sc->sc_state = S_IDLE; 6956187Ssam wakeup((caddr_t)um); 6964743Swnj return; 6974743Swnj } 6984743Swnj udaddr->udasa = ((int)&sc->sc_uda->uda_ca.ca_ringbase)| 69924186Sbloom ((cpu == VAX_780) || (cpu == VAX_8600) ? UDA_PI : 0); 7004743Swnj sc->sc_state = S_STEP2; 7014743Swnj return; 7024743Swnj 7034743Swnj case S_STEP2: 70417553Skarels #define STEP2MASK 0174377 70517553Skarels #define STEP2GOOD (UDA_STEP3|UDA_IE|(sc->sc_ivec/4)) 7066964Ssam if ((udaddr->udasa&STEP2MASK) != STEP2GOOD) { 7074743Swnj sc->sc_state = S_IDLE; 7086187Ssam wakeup((caddr_t)um); 7094743Swnj return; 7104743Swnj } 7114743Swnj udaddr->udasa = ((int)&sc->sc_uda->uda_ca.ca_ringbase)>>16; 7124743Swnj sc->sc_state = S_STEP3; 7134743Swnj return; 7144743Swnj 7154743Swnj case S_STEP3: 71617553Skarels #define STEP3MASK 0174000 71717553Skarels #define STEP3GOOD UDA_STEP4 7186964Ssam if ((udaddr->udasa&STEP3MASK) != STEP3GOOD) { 7194743Swnj sc->sc_state = S_IDLE; 7206187Ssam wakeup((caddr_t)um); 7214743Swnj return; 7224743Swnj } 72317553Skarels udamicro[d] = udaddr->udasa; 72417553Skarels #ifdef DEBUG 72517553Skarels printd("Uda%d Version %d model %d\n",d,udamicro[d]&0xF, 72617553Skarels (udamicro[d]>>4) & 0xF); 72717553Skarels /* 72817553Skarels * Requesting the error status (|= 2) 72917553Skarels * may hang older controllers. 73017553Skarels */ 73117553Skarels udaddr->udasa = UDA_GO | (udaerror? 2 : 0); 73217553Skarels #endif 7334743Swnj udaddr->udasa = UDA_GO; 7344743Swnj sc->sc_state = S_SCHAR; 7354743Swnj 7364743Swnj /* 7374743Swnj * Initialize the data structures. 7384743Swnj */ 7394743Swnj uud = sc->sc_uda; 7404743Swnj for (i = 0; i < NRSP; i++) { 7414743Swnj ud->uda_ca.ca_rspdsc[i] = UDA_OWN|UDA_INT| 7424743Swnj (long)&uud->uda_rsp[i].mscp_cmdref; 7434743Swnj ud->uda_rsp[i].mscp_dscptr = &ud->uda_ca.ca_rspdsc[i]; 74417553Skarels ud->uda_rsp[i].mscp_header.uda_msglen = mscp_msglen; 7454743Swnj } 7464743Swnj for (i = 0; i < NCMD; i++) { 7474743Swnj ud->uda_ca.ca_cmddsc[i] = UDA_INT| 7484743Swnj (long)&uud->uda_cmd[i].mscp_cmdref; 7494743Swnj ud->uda_cmd[i].mscp_dscptr = &ud->uda_ca.ca_cmddsc[i]; 75017553Skarels ud->uda_cmd[i].mscp_header.uda_msglen = mscp_msglen; 7514743Swnj } 7524743Swnj bp = &udwtab[d]; 7534743Swnj bp->av_forw = bp->av_back = bp; 75417553Skarels sc->sc_lastcmd = 1; 7554743Swnj sc->sc_lastrsp = 0; 75617553Skarels mp = &uda[um->um_ctlr].uda_cmd[0]; 75717553Skarels mp->mscp_unit = mp->mscp_modifier = 0; 75817553Skarels mp->mscp_flags = 0; 75917553Skarels mp->mscp_bytecnt = mp->mscp_buffer = 0; 76017553Skarels mp->mscp_errlgfl = mp->mscp_copyspd = 0; 7614743Swnj mp->mscp_opcode = M_OP_STCON; 7624743Swnj mp->mscp_cntflgs = M_CF_ATTN|M_CF_MISC|M_CF_THIS; 7634743Swnj *((long *)mp->mscp_dscptr) |= UDA_OWN|UDA_INT; 76417553Skarels i = udaddr->udaip; /* initiate polling */ 7654743Swnj return; 7664743Swnj 7674743Swnj case S_SCHAR: 7684743Swnj case S_RUN: 7694743Swnj break; 7704743Swnj 7714743Swnj default: 7724743Swnj printf("uda%d: interrupt in unknown state %d ignored\n", 7734743Swnj d, sc->sc_state); 7744743Swnj return; 7754743Swnj } 7764743Swnj 7774743Swnj if (udaddr->udasa&UDA_ERR) { 77817553Skarels printf("uda(%d): fatal error (%o)\n", d, udaddr->udasa&0xffff); 7794743Swnj udaddr->udaip = 0; 7806187Ssam wakeup((caddr_t)um); 7814743Swnj } 7824743Swnj 7834743Swnj /* 7844743Swnj * Check for a buffer purge request. 7854743Swnj */ 7864743Swnj if (ud->uda_ca.ca_bdp) { 7874743Swnj /* 7884743Swnj * THIS IS A KLUDGE. 7894743Swnj * Maybe we should change the entire 7904743Swnj * UBA interface structure. 7914743Swnj */ 79217553Skarels int s = spl6(); /* was spl7 but I don't like turning */ 79317553Skarels /* off machine checks */ 7944743Swnj i = um->um_ubinfo; 79517553Skarels #ifdef DEBUG 7964743Swnj printd("uda: purge bdp %d\n", ud->uda_ca.ca_bdp); 79717553Skarels #endif 7984743Swnj um->um_ubinfo = ud->uda_ca.ca_bdp<<28; 7994743Swnj ubapurge(um); 8004743Swnj um->um_ubinfo = i; 8014743Swnj (void) splx(s); 8024743Swnj ud->uda_ca.ca_bdp = 0; 80317553Skarels udaddr->udasa = 0; /* signal purge complete */ 8044743Swnj } 8054743Swnj 8064743Swnj /* 8074743Swnj * Check for response ring transition. 8084743Swnj */ 8094743Swnj if (ud->uda_ca.ca_rspint) { 8104743Swnj ud->uda_ca.ca_rspint = 0; 8114743Swnj for (i = sc->sc_lastrsp;; i++) { 8124743Swnj i %= NRSP; 8134743Swnj if (ud->uda_ca.ca_rspdsc[i]&UDA_OWN) 8144743Swnj break; 8154743Swnj udrsp(um, ud, sc, i); 8164743Swnj ud->uda_ca.ca_rspdsc[i] |= UDA_OWN; 8174743Swnj } 8184743Swnj sc->sc_lastrsp = i; 8194743Swnj } 8204743Swnj 8214743Swnj /* 8224743Swnj * Check for command ring transition. 8234743Swnj */ 8244743Swnj if (ud->uda_ca.ca_cmdint) { 82517553Skarels #ifdef DEBUG 8264743Swnj printd("uda: command ring transition\n"); 82717553Skarels #endif 8284743Swnj ud->uda_ca.ca_cmdint = 0; 8294743Swnj } 83017553Skarels if(uda_cp_wait) 83117553Skarels wakeup(&uda_cp_wait); 8326187Ssam (void) udstart(um); 8334743Swnj } 8344743Swnj 8354743Swnj /* 8364743Swnj * Process a response packet 8374743Swnj */ 8384743Swnj udrsp(um, ud, sc, i) 8394743Swnj register struct uba_ctlr *um; 8404743Swnj register struct uda *ud; 8414743Swnj register struct uda_softc *sc; 8424743Swnj int i; 8434743Swnj { 8444743Swnj register struct mscp *mp; 8454743Swnj struct uba_device *ui; 84617553Skarels struct buf *dp, *bp,nullbp; 8474743Swnj int st; 8484743Swnj 8494743Swnj mp = &ud->uda_rsp[i]; 85017553Skarels mp->mscp_header.uda_msglen = mscp_msglen; 85117553Skarels sc->sc_credits += mp->mscp_header.uda_credits & 0xf; /* just 4 bits?*/ 85217553Skarels if ((mp->mscp_header.uda_credits & 0xf0) > 0x10) /* Check */ 8534743Swnj return; 85417553Skarels #ifdef DEBUG 85517553Skarels printd10("udarsp, opcode 0x%x status 0x%x\n",mp->mscp_opcode,mp->mscp_status); 85617553Skarels #endif 8574743Swnj /* 8584743Swnj * If it's an error log message (datagram), 8594743Swnj * pass it on for more extensive processing. 8604743Swnj */ 86117553Skarels if ((mp->mscp_header.uda_credits & 0xf0) == 0x10) { /* check */ 8624743Swnj uderror(um, (struct mslg *)mp); 8634743Swnj return; 8644743Swnj } 8654743Swnj st = mp->mscp_status&M_ST_MASK; 86617553Skarels /* The controller interrupts as drive 0 */ 86717553Skarels /* this means that you must check for controller interrupts */ 86817553Skarels /* before you check to see if there is a drive 0 */ 86917553Skarels if((M_OP_STCON|M_OP_END) == mp->mscp_opcode){ 8704743Swnj if (st == M_ST_SUCC) 8714743Swnj sc->sc_state = S_RUN; 8724743Swnj else 8734743Swnj sc->sc_state = S_IDLE; 8744743Swnj um->um_tab.b_active = 0; 8756187Ssam wakeup((caddr_t)um); 87617553Skarels return; 87717553Skarels } 87817553Skarels if (mp->mscp_unit >= 8) 87917553Skarels return; 88017553Skarels if ((ui = udip[um->um_ctlr][mp->mscp_unit]) == 0) 88117553Skarels return; 88217553Skarels switch (mp->mscp_opcode) { 8834743Swnj 8844743Swnj case M_OP_ONLIN|M_OP_END: 88517553Skarels ra_info[ui->ui_unit].rastatus = st; 88617553Skarels ra_info[ui->ui_unit].ratype = mp->mscp_mediaid; 8874743Swnj dp = &udutab[ui->ui_unit]; 8884743Swnj if (st == M_ST_SUCC) { 88917553Skarels /* 89017553Skarels * Link the drive onto the controller queue 89117553Skarels */ 89217553Skarels dp->b_forw = NULL; 89317553Skarels if (um->um_tab.b_actf == NULL) 89417553Skarels um->um_tab.b_actf = dp; 89517553Skarels else 89617553Skarels um->um_tab.b_actl->b_forw = dp; 89717553Skarels um->um_tab.b_actl = dp; 89817553Skarels ui->ui_flags = 1; /* mark it online */ 89917553Skarels ra_info[ui->ui_unit].radsize=(daddr_t)mp->mscp_untsize; 90017553Skarels #ifdef DEBUG 9014743Swnj printd("uda: unit %d online\n", mp->mscp_unit); 90217553Skarels #endif 90317553Skarels #define F_to_C(x,i) ( ((x)->mscp_mediaid) >> (i*5+7) & 0x1f ? ( ( (((x)->mscp_mediaid) >>( i*5 + 7)) & 0x1f) + 'A' - 1): ' ') 90417553Skarels /* this mess decodes the Media type identifier */ 90517553Skarels #ifdef DEBUG 90617553Skarels printd("uda: unit %d online %x %c%c %c%c%c%d\n" 90717553Skarels ,mp->mscp_unit, mp->mscp_mediaid 90817553Skarels ,F_to_C(mp,4),F_to_C(mp,3),F_to_C(mp,2) 90917553Skarels ,F_to_C(mp,1),F_to_C(mp,0) 91017553Skarels ,mp->mscp_mediaid & 0x7f); 91117553Skarels #endif 91217553Skarels switch(mp->mscp_mediaid & 0x7f){ 91317553Skarels case 25: 91417553Skarels ra_info[ui->ui_unit].ra_sizes = ra25_sizes; 91517553Skarels break; 91617553Skarels case 60: 91717553Skarels ra_info[ui->ui_unit].ra_sizes = ra60_sizes; 91817553Skarels break; 91917553Skarels case 80: 92017553Skarels ra_info[ui->ui_unit].ra_sizes = ra80_sizes; 92117553Skarels break; 92217553Skarels case 81: 92317553Skarels ra_info[ui->ui_unit].ra_sizes = ra81_sizes; 92417553Skarels break; 92517553Skarels default: 92617553Skarels ui->ui_flags = 0; /* mark it offline */ 92717553Skarels ra_info[ui->ui_unit].ratype = 0; 92817553Skarels printf("Don't have a parition table for "); 92917553Skarels printf("a %c%c %c%c%c%d\n" 93017553Skarels ,F_to_C(mp,4),F_to_C(mp,3),F_to_C(mp,2) 93117553Skarels ,F_to_C(mp,1),F_to_C(mp,0) 93217553Skarels ,mp->mscp_mediaid & 0x7f); 93317553Skarels while (bp = dp->b_actf) { 93417553Skarels dp->b_actf = bp->av_forw; 93517553Skarels bp->b_flags |= B_ERROR; 93617553Skarels iodone(bp); 93717553Skarels } 93817553Skarels } 93917553Skarels dp->b_active = 1; 9404743Swnj } else { 94117553Skarels if(dp->b_actf){ 94217553Skarels harderr(dp->b_actf,"ra"); 94317553Skarels } else { 94417553Skarels nullbp.b_blkno = 0; 94517553Skarels nullbp.b_dev = makedev(UDADEVNUM,ui->ui_unit); 94617553Skarels harderr(&nullbp, "ra"); 94717553Skarels } 9484743Swnj printf("OFFLINE\n"); 9494743Swnj while (bp = dp->b_actf) { 9504743Swnj dp->b_actf = bp->av_forw; 9514743Swnj bp->b_flags |= B_ERROR; 9524743Swnj iodone(bp); 9534743Swnj } 9544743Swnj } 95517553Skarels if(mp->mscp_cmdref!=NULL){/* Seems to get lost sometimes */ 95617553Skarels wakeup((caddr_t *) mp->mscp_cmdref); 95717553Skarels } 9584743Swnj break; 9594743Swnj 96017553Skarels /* 96117553Skarels * The AVAILABLE ATTENTION messages occurs when the 96217553Skarels * unit becomes available after spinup, 96317553Skarels * marking the unit offline will force an online command 96417553Skarels * prior to using the unit. 96517553Skarels */ 9664743Swnj case M_OP_AVATN: 96717553Skarels #ifdef DEBUG 9684743Swnj printd("uda: unit %d attention\n", mp->mscp_unit); 96917553Skarels #endif 97017553Skarels ui->ui_flags = 0; /* it went offline and we didn't notice */ 97117553Skarels ra_info[ui->ui_unit].ratype = mp->mscp_mediaid; 9724743Swnj break; 9734743Swnj 97417553Skarels case M_OP_END: 97517553Skarels /* 97617553Skarels * An endcode without an opcode (0200) is an invalid command. 97717553Skarels * The mscp specification states that this would be a protocol 97817553Skarels * type error, such as illegal opcodes. The mscp spec. also 97917553Skarels * states that parameter error type of invalid commands should 98017553Skarels * return the normal end message for the command. This does not appear 98117553Skarels * to be the case. An invalid logical block number returned an endcode 98217553Skarels * of 0200 instead of the 0241 (read) that was expected. 98317553Skarels */ 98417553Skarels 98517553Skarels printf("endcd=%o, stat=%o\n", mp->mscp_opcode, mp->mscp_status); 98617553Skarels break; 9874743Swnj case M_OP_READ|M_OP_END: 9884743Swnj case M_OP_WRITE|M_OP_END: 9894743Swnj bp = (struct buf *)mp->mscp_cmdref; 9906964Ssam ubarelse(um->um_ubanum, (int *)&bp->b_ubinfo); 9914743Swnj /* 9924743Swnj * Unlink buffer from I/O wait queue. 9934743Swnj */ 9944743Swnj bp->av_back->av_forw = bp->av_forw; 9954743Swnj bp->av_forw->av_back = bp->av_back; 99612421Ssam #if defined(VAX750) 997*25653Skarels if (cpu == VAX_750 && um->um_tab.b_active == 0 99812421Ssam && udwtab[um->um_ctlr].av_forw == &udwtab[um->um_ctlr]) { 99912421Ssam if (um->um_ubinfo == 0) 100012421Ssam printf("udintr: um_ubinfo == 0\n"); 100112421Ssam else 100212421Ssam ubarelse(um->um_ubanum, &um->um_ubinfo); 100312421Ssam } 100412421Ssam #endif 10054743Swnj dp = &udutab[ui->ui_unit]; 100617553Skarels dp->b_qsize--; 10074743Swnj if (ui->ui_dk >= 0) 100817553Skarels if (dp->b_qsize == 0) 10094743Swnj dk_busy &= ~(1<<ui->ui_dk); 10104743Swnj if (st == M_ST_OFFLN || st == M_ST_AVLBL) { 101117553Skarels ui->ui_flags = 0; /* mark unit offline */ 10124743Swnj /* 10134743Swnj * Link the buffer onto the front of the drive queue 10144743Swnj */ 10154743Swnj if ((bp->av_forw = dp->b_actf) == 0) 10164743Swnj dp->b_actl = bp; 10174743Swnj dp->b_actf = bp; 10184743Swnj /* 10194743Swnj * Link the drive onto the controller queue 10204743Swnj */ 10214743Swnj if (dp->b_active == 0) { 10224743Swnj dp->b_forw = NULL; 10234743Swnj if (um->um_tab.b_actf == NULL) 10244743Swnj um->um_tab.b_actf = dp; 10254743Swnj else 10264743Swnj um->um_tab.b_actl->b_forw = dp; 10274743Swnj um->um_tab.b_actl = dp; 10284743Swnj dp->b_active = 1; 10294743Swnj } 103012421Ssam #if defined(VAX750) 103112421Ssam if (cpu == VAX750 && um->um_ubinfo == 0) 103212421Ssam um->um_ubinfo = 103312421Ssam uballoc(um->um_ubanum, (caddr_t)0, 0, 103412421Ssam UBA_NEEDBDP); 103512421Ssam #endif 10364743Swnj return; 10374743Swnj } 10384743Swnj if (st != M_ST_SUCC) { 10394743Swnj harderr(bp, "ra"); 104017553Skarels #ifdef DEBUG 104117553Skarels printd("status %o\n", mp->mscp_status); 104217553Skarels #endif 10434743Swnj bp->b_flags |= B_ERROR; 10444743Swnj } 10454743Swnj bp->b_resid = bp->b_bcount - mp->mscp_bytecnt; 10464743Swnj iodone(bp); 10474743Swnj break; 10484743Swnj 10494743Swnj case M_OP_GTUNT|M_OP_END: 105017553Skarels #ifdef DEBUG 105117553Skarels printd("GTUNT end packet status = 0x%x media id 0x%x\n" 105217553Skarels ,st,mp->mscp_mediaid); 105317553Skarels #endif 105417553Skarels ra_info[ui->ui_unit].rastatus = st; 105517553Skarels ra_info[ui->ui_unit].ratype = mp->mscp_mediaid; 10564743Swnj break; 10574743Swnj 10584743Swnj default: 10594743Swnj printf("uda: unknown packet\n"); 106017553Skarels uderror(um, (struct mslg *)mp); 10614743Swnj } 10624743Swnj } 10634743Swnj 10644743Swnj 10654743Swnj /* 10664743Swnj * Process an error log message 10674743Swnj * 10684743Swnj * For now, just log the error on the console. 10694743Swnj * Only minimal decoding is done, only "useful" 10704743Swnj * information is printed. Eventually should 10714743Swnj * send message to an error logger. 10724743Swnj */ 10734743Swnj uderror(um, mp) 10744743Swnj register struct uba_ctlr *um; 10754743Swnj register struct mslg *mp; 10764743Swnj { 107717553Skarels register i; 107817553Skarels 107917553Skarels 108017553Skarels if(!(mp->mslg_flags & (M_LF_SUCC | M_LF_CONT))) 108117553Skarels printf("uda%d: hard error\n"); 108217553Skarels 108317553Skarels mprintf("uda%d: %s error, ", um->um_ctlr, 108417553Skarels mp->mslg_flags & ( M_LF_SUCC | M_LF_CONT ) ? "soft" : "hard"); 10854743Swnj switch (mp->mslg_format) { 10864743Swnj case M_FM_CNTERR: 108717553Skarels mprintf("controller error, event 0%o\n", mp->mslg_event); 10884743Swnj break; 10894743Swnj 10904743Swnj case M_FM_BUSADDR: 109117553Skarels mprintf("host memory access error, event 0%o, addr 0%o\n", 10929174Ssam mp->mslg_event, mp->mslg_busaddr); 10934743Swnj break; 10944743Swnj 10954743Swnj case M_FM_DISKTRN: 109617553Skarels mprintf("disk transfer error, unit %d, grp 0x%x, hdr 0x%x, event 0%o\n", 109717553Skarels mp->mslg_unit, mp->mslg_group, mp->mslg_hdr, 109817553Skarels mp->mslg_event); 10994743Swnj break; 11004743Swnj 11014743Swnj case M_FM_SDI: 110217553Skarels mprintf("SDI error, unit %d, event 0%o, hdr 0x%x\n", 110312421Ssam mp->mslg_unit, mp->mslg_event, mp->mslg_hdr); 110417553Skarels for(i = 0; i < 12;i++) 110517553Skarels mprintf("\t0x%x",mp->mslg_sdistat[i] & 0xff); 110617553Skarels mprintf("\n"); 11074743Swnj break; 11084743Swnj 11094743Swnj case M_FM_SMLDSK: 111017553Skarels mprintf("small disk error, unit %d, event 0%o, cyl %d\n", 11114743Swnj mp->mslg_unit, mp->mslg_event, mp->mslg_sdecyl); 11124743Swnj break; 11134743Swnj 11144743Swnj default: 111517553Skarels mprintf("unknown error, unit %d, format 0%o, event 0%o\n", 11164743Swnj mp->mslg_unit, mp->mslg_format, mp->mslg_event); 11174743Swnj } 11186964Ssam 11196964Ssam if (udaerror) { 11206964Ssam register long *p = (long *)mp; 11216964Ssam 11226964Ssam for (i = 0; i < mp->mslg_header.uda_msglen; i += sizeof(*p)) 11236964Ssam printf("%x ", *p++); 11246964Ssam printf("\n"); 11256964Ssam } 11264743Swnj } 11274743Swnj 11284743Swnj 11294743Swnj /* 11304743Swnj * Find an unused command packet 11314743Swnj */ 11324743Swnj struct mscp * 11334743Swnj udgetcp(um) 11344743Swnj struct uba_ctlr *um; 11354743Swnj { 11364743Swnj register struct mscp *mp; 11374743Swnj register struct udaca *cp; 11384743Swnj register struct uda_softc *sc; 11394743Swnj register int i; 114017553Skarels int s; 11414743Swnj 114217553Skarels s = spl5(); 11434743Swnj cp = &uda[um->um_ctlr].uda_ca; 11444743Swnj sc = &uda_softc[um->um_ctlr]; 114517553Skarels /* 114617553Skarels * If no credits, can't issue any commands 114717553Skarels * until some outstanding commands complete. 114817553Skarels */ 11494743Swnj i = sc->sc_lastcmd; 115017553Skarels if(((cp->ca_cmddsc[i]&(UDA_OWN|UDA_INT))==UDA_INT)&& 115117553Skarels (sc->sc_credits >= 2)) { 115217553Skarels sc->sc_credits--; /* committed to issuing a command */ 11534743Swnj cp->ca_cmddsc[i] &= ~UDA_INT; 11544743Swnj mp = &uda[um->um_ctlr].uda_cmd[i]; 11554743Swnj mp->mscp_unit = mp->mscp_modifier = 0; 11564743Swnj mp->mscp_opcode = mp->mscp_flags = 0; 11574743Swnj mp->mscp_bytecnt = mp->mscp_buffer = 0; 11584743Swnj mp->mscp_errlgfl = mp->mscp_copyspd = 0; 11594743Swnj sc->sc_lastcmd = (i + 1) % NCMD; 116017553Skarels (void) splx(s); 11614743Swnj return(mp); 11624743Swnj } 116317553Skarels (void) splx(s); 11644743Swnj return(NULL); 11654743Swnj } 11664743Swnj 11677734Sroot udread(dev, uio) 11684743Swnj dev_t dev; 11697734Sroot struct uio *uio; 11704743Swnj { 117124742Sbloom register int unit = udunit(dev); 11724743Swnj 117317553Skarels if (unit >= nNRA) 11748165Sroot return (ENXIO); 11758165Sroot return (physio(udstrategy, &rudbuf[unit], dev, B_READ, minphys, uio)); 11764743Swnj } 11774743Swnj 11787845Sroot udwrite(dev, uio) 11794743Swnj dev_t dev; 11807845Sroot struct uio *uio; 11814743Swnj { 118224742Sbloom register int unit = udunit(dev); 11834743Swnj 118417553Skarels if (unit >= nNRA) 11858165Sroot return (ENXIO); 11868165Sroot return (physio(udstrategy, &rudbuf[unit], dev, B_WRITE, minphys, uio)); 11874743Swnj } 11884743Swnj 11894743Swnj udreset(uban) 11904743Swnj int uban; 11914743Swnj { 11924743Swnj register struct uba_ctlr *um; 11934743Swnj register struct uba_device *ui; 11944743Swnj register struct buf *bp, *dp; 11954743Swnj register int unit; 11964743Swnj struct buf *nbp; 11974743Swnj int d; 11984743Swnj 11994743Swnj for (d = 0; d < NUDA; d++) { 12004743Swnj if ((um = udminfo[d]) == 0 || um->um_ubanum != uban || 12014743Swnj um->um_alive == 0) 12024743Swnj continue; 12034743Swnj printf(" uda%d", d); 12044743Swnj um->um_tab.b_active = 0; 12054743Swnj um->um_tab.b_actf = um->um_tab.b_actl = 0; 12064743Swnj uda_softc[d].sc_state = S_IDLE; 120717553Skarels uda_softc[d].sc_mapped = 0; /* Rich */ 120817553Skarels for (unit = 0; unit < nNRA; unit++) { 12094743Swnj if ((ui = uddinfo[unit]) == 0) 12104743Swnj continue; 12114743Swnj if (ui->ui_alive == 0 || ui->ui_mi != um) 12124743Swnj continue; 12134743Swnj udutab[unit].b_active = 0; 12144743Swnj udutab[unit].b_qsize = 0; 12154743Swnj } 12164743Swnj for (bp = udwtab[d].av_forw; bp != &udwtab[d]; bp = nbp) { 12174743Swnj nbp = bp->av_forw; 12188576Sroot bp->b_ubinfo = 0; 12194743Swnj /* 12204743Swnj * Link the buffer onto the drive queue 12214743Swnj */ 122224742Sbloom dp = &udutab[udunit(bp->b_dev)]; 12234743Swnj if (dp->b_actf == 0) 12244743Swnj dp->b_actf = bp; 12254743Swnj else 12264743Swnj dp->b_actl->av_forw = bp; 12274743Swnj dp->b_actl = bp; 12284743Swnj bp->av_forw = 0; 12294743Swnj /* 12304743Swnj * Link the drive onto the controller queue 12314743Swnj */ 12324743Swnj if (dp->b_active == 0) { 12334743Swnj dp->b_forw = NULL; 12344743Swnj if (um->um_tab.b_actf == NULL) 12354743Swnj um->um_tab.b_actf = dp; 12364743Swnj else 12374743Swnj um->um_tab.b_actl->b_forw = dp; 12384743Swnj um->um_tab.b_actl = dp; 12394743Swnj dp->b_active = 1; 12404743Swnj } 12414743Swnj } 12424743Swnj udinit(d); 12434743Swnj } 12444743Swnj } 12454743Swnj 124617553Skarels #define DBSIZE 32 124717553Skarels 124817553Skarels #define ca_Rspdsc ca_rspdsc[0] 124917553Skarels #define ca_Cmddsc ca_rspdsc[1] 125017553Skarels #define uda_Rsp uda_rsp[0] 125117553Skarels #define uda_Cmd uda_cmd[0] 125217553Skarels 125317553Skarels struct uda udad[NUDA]; 125417553Skarels 125517553Skarels uddump(dev) 125617553Skarels dev_t dev; 12574743Swnj { 125817553Skarels struct udadevice *udaddr; 125917553Skarels struct uda *ud_ubaddr; 126017553Skarels char *start; 126117553Skarels int num, blk, unit; 126217553Skarels int maxsz; 126317553Skarels int blkoff; 126417553Skarels register struct uba_regs *uba; 126517553Skarels register struct uba_device *ui; 126617553Skarels register struct uda *udp; 126717553Skarels register struct pte *io; 126817553Skarels register int i; 126917553Skarels struct size *rasizes; 127024742Sbloom unit = udunit(dev); 127117553Skarels if (unit >= nNRA) 127217553Skarels return (ENXIO); 127317553Skarels #define phys(cast, addr) ((cast)((int)addr & 0x7fffffff)) 127417553Skarels ui = phys(struct uba_device *, uddinfo[unit]); 127517553Skarels if (ui->ui_alive == 0) 127617553Skarels return (ENXIO); 127717553Skarels uba = phys(struct uba_hd *, ui->ui_hd)->uh_physuba; 127817553Skarels ubainit(uba); 127917553Skarels udaddr = (struct udadevice *)ui->ui_physaddr; 128017553Skarels DELAY(2000000); 128117553Skarels udp = phys(struct uda *, &udad[ui->ui_ctlr]); 128217553Skarels 128317553Skarels num = btoc(sizeof(struct uda)) + 1; 128417553Skarels io = &uba->uba_map[NUBMREG-num]; 128517553Skarels for(i = 0; i<num; i++) 128617553Skarels *(int *)io++ = UBAMR_MRV|(btop(udp)+i); 128717553Skarels ud_ubaddr = (struct uda *)(((int)udp & PGOFSET)|((NUBMREG-num)<<9)); 128817553Skarels 128917553Skarels udaddr->udaip = 0; 129017553Skarels while ((udaddr->udasa & UDA_STEP1) == 0) 129117553Skarels if(udaddr->udasa & UDA_ERR) return(EFAULT); 129217553Skarels udaddr->udasa = UDA_ERR; 129317553Skarels while ((udaddr->udasa & UDA_STEP2) == 0) 129417553Skarels if(udaddr->udasa & UDA_ERR) return(EFAULT); 129517553Skarels udaddr->udasa = (short)&ud_ubaddr->uda_ca.ca_ringbase; 129617553Skarels while ((udaddr->udasa & UDA_STEP3) == 0) 129717553Skarels if(udaddr->udasa & UDA_ERR) return(EFAULT); 129817553Skarels udaddr->udasa = (short)(((int)&ud_ubaddr->uda_ca.ca_ringbase) >> 16); 129917553Skarels while ((udaddr->udasa & UDA_STEP4) == 0) 130017553Skarels if(udaddr->udasa & UDA_ERR) return(EFAULT); 130117553Skarels udaddr->udasa = UDA_GO; 130217553Skarels udp->uda_ca.ca_Rspdsc = (long)&ud_ubaddr->uda_Rsp.mscp_cmdref; 130317553Skarels udp->uda_ca.ca_Cmddsc = (long)&ud_ubaddr->uda_Cmd.mscp_cmdref; 130417553Skarels udp->uda_Cmd.mscp_cntflgs = 0; 130517553Skarels udp->uda_Cmd.mscp_version = 0; 130617553Skarels if (udcmd(M_OP_STCON, udp, udaddr) == 0) { 130717553Skarels return(EFAULT); 130817553Skarels } 130917553Skarels udp->uda_Cmd.mscp_unit = ui->ui_slave; 131017553Skarels if (udcmd(M_OP_ONLIN, udp, udaddr) == 0) { 131117553Skarels return(EFAULT); 131217553Skarels } 131317553Skarels 131417553Skarels num = maxfree; 131517553Skarels start = 0; 131617553Skarels rasizes = ra_info[ui->ui_unit].ra_sizes; 131717553Skarels maxsz = rasizes[minor(dev)&07].nblocks; 131817553Skarels blkoff = rasizes[minor(dev)&07].blkoff; 131917553Skarels if(maxsz < 0) 132017553Skarels maxsz = ra_info[unit].radsize-blkoff; 132124212Sbloom if (dumplo < 0) 132217553Skarels return (EINVAL); 132324212Sbloom if (dumplo + num >= maxsz) 132424212Sbloom num = maxsz - dumplo; 132517553Skarels blkoff += dumplo; 132617553Skarels while (num > 0) { 132717553Skarels blk = num > DBSIZE ? DBSIZE : num; 132817553Skarels io = uba->uba_map; 132917553Skarels for (i = 0; i < blk; i++) 133017553Skarels *(int *)io++ = (btop(start)+i) | UBAMR_MRV; 133117553Skarels *(int *)io = 0; 133217553Skarels udp->uda_Cmd.mscp_lbn = btop(start) + blkoff; 133317553Skarels udp->uda_Cmd.mscp_unit = ui->ui_slave; 133417553Skarels udp->uda_Cmd.mscp_bytecnt = blk*NBPG; 133517553Skarels udp->uda_Cmd.mscp_buffer = 0; 133617553Skarels if (udcmd(M_OP_WRITE, udp, udaddr) == 0) { 133717553Skarels return(EIO); 133817553Skarels } 133917553Skarels start += blk*NBPG; 134017553Skarels num -= blk; 134117553Skarels } 134217553Skarels return (0); 13434743Swnj } 134417553Skarels 134517553Skarels 134617553Skarels udcmd(op, udp, udaddr) 134717553Skarels int op; 134817553Skarels register struct uda *udp; 134917553Skarels struct udadevice *udaddr; 135017553Skarels { 135117553Skarels int i; 135217553Skarels 135317553Skarels #ifdef lint 135417553Skarels i = i; 135517553Skarels #endif 135617553Skarels 135717553Skarels udp->uda_Cmd.mscp_opcode = op; 135817553Skarels udp->uda_Rsp.mscp_header.uda_msglen = mscp_msglen; 135917553Skarels udp->uda_Cmd.mscp_header.uda_msglen = mscp_msglen; 136017553Skarels udp->uda_ca.ca_Rspdsc |= UDA_OWN|UDA_INT; 136117553Skarels udp->uda_ca.ca_Cmddsc |= UDA_OWN|UDA_INT; 136217553Skarels if (udaddr->udasa&UDA_ERR) 136317553Skarels printf("Udaerror udasa (%x)\n", udaddr->udasa&0xffff); 136417553Skarels i = udaddr->udaip; 136517553Skarels for (;;) { 136617553Skarels if (udp->uda_ca.ca_cmdint) 136717553Skarels udp->uda_ca.ca_cmdint = 0; 136817553Skarels if (udp->uda_ca.ca_rspint) 136917553Skarels break; 137017553Skarels } 137117553Skarels udp->uda_ca.ca_rspint = 0; 137217553Skarels if (udp->uda_Rsp.mscp_opcode != (op|M_OP_END) || 137317553Skarels (udp->uda_Rsp.mscp_status&M_ST_MASK) != M_ST_SUCC) { 137417553Skarels printf("error: com %d opc 0x%x stat 0x%x\ndump ", 137517553Skarels op, 137617553Skarels udp->uda_Rsp.mscp_opcode, 137717553Skarels udp->uda_Rsp.mscp_status); 137817553Skarels return(0); 137917553Skarels } 138017553Skarels return(1); 138117553Skarels } 138217553Skarels 138312511Ssam udsize(dev) 138412511Ssam dev_t dev; 138512511Ssam { 138624742Sbloom int unit = udunit(dev); 138712511Ssam struct uba_device *ui; 138817553Skarels struct size *rasizes; 138912511Ssam 139017553Skarels if (unit >= nNRA || (ui = uddinfo[unit]) == 0 || ui->ui_alive == 0 139117553Skarels || ui->ui_flags == 0) 139212511Ssam return (-1); 139317553Skarels rasizes = ra_info[ui->ui_unit].ra_sizes; 139417553Skarels return (rasizes[minor(dev) & 07].nblocks); 139512511Ssam } 139617553Skarels 139712511Ssam #endif 1398