diff options
Diffstat (limited to 'sys/modules/vinum/interrupt.c')
| -rw-r--r-- | sys/modules/vinum/interrupt.c | 190 |
1 files changed, 190 insertions, 0 deletions
diff --git a/sys/modules/vinum/interrupt.c b/sys/modules/vinum/interrupt.c new file mode 100644 index 000000000000..e7eb034faf4b --- /dev/null +++ b/sys/modules/vinum/interrupt.c @@ -0,0 +1,190 @@ +/* interrupt.c: bottom half of the driver */ + +/*- + * Copyright (c) 1997, 1998 + * Nan Yang Computer Services Limited. All rights reserved. + * + * This software is distributed under the so-called ``Berkeley + * License'': + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * 3. All advertising materials mentioning features or use of this software + * must display the following acknowledgement: + * This product includes software developed by Nan Yang Computer + * Services Limited. + * 4. Neither the name of the Company nor the names of its contributors + * may be used to endorse or promote products derived from this software + * without specific prior written permission. + * + * This software is provided ``as is'', and any express or implied + * warranties, including, but not limited to, the implied warranties of + * merchantability and fitness for a particular purpose are disclaimed. + * In no event shall the company or contributors be liable for any + * direct, indirect, incidental, special, exemplary, or consequential + * damages (including, but not limited to, procurement of substitute + * goods or services; loss of use, data, or profits; or business + * interruption) however caused and on any theory of liability, whether + * in contract, strict liability, or tort (including negligence or + * otherwise) arising in any way out of the use of this software, even if + * advised of the possibility of such damage. + * + * $Id: interrupt.c,v 1.1 1998/08/13 06:12:27 grog Exp grog $ + */ + +#define REALLYKERNEL +#include "vinumhdr.h" +#include "request.h" +#include <miscfs/specfs/specdev.h> +#include <sys/resourcevar.h> + +void complete_raid5_write(struct rqelement *); +void freerq(struct request *rq); +void free_rqg(struct rqgroup *rqg); +void complete_rqe(struct buf *bp); +void sdio_done(struct buf *bp); + +/* Take a completed buffer, transfer the data back if + * it's a read, and complete the high-level request + * if this is the last subrequest. + * + * The bp parameter is in fact a struct rqelement, which + * includes a couple of extras at the end. + */ +void +complete_rqe(struct buf *bp) +{ + BROKEN_GDB; + struct rqelement *rqe; + struct request *rq; + struct rqgroup *rqg; + struct buf *ubp; /* user buffer */ + + rqe = (struct rqelement *) bp; /* point to the element element that completed */ + rqg = rqe->rqg; /* and the request group */ + rq = rqg->rq; /* and the complete request */ + + if ((bp->b_flags & B_ERROR) != 0) { /* transfer in error */ + if (bp->b_error != 0) /* did it return a number? */ + rq->error = bp->b_error; /* yes, put it in. */ + else if (rq->error == 0) /* no: do we have one already? */ + rq->error = EIO; /* no: catchall "I/O error" */ + if (rq->error == EIO) /* I/O error, */ + set_sd_state(rqe->sdno, sd_crashed, setstate_force); /* take the subdisk down */ + } + /* Now update the statistics */ + if (bp->b_flags & B_READ) { /* read operation */ + DRIVE[rqe->driveno].reads++; + DRIVE[rqe->driveno].bytes_read += bp->b_bcount; + SD[rqe->sdno].reads++; + SD[rqe->sdno].bytes_read += bp->b_bcount; + PLEX[rqe->rqg->plexno].reads++; + PLEX[rqe->rqg->plexno].bytes_read += bp->b_bcount; + } else { /* write operation */ + DRIVE[rqe->driveno].writes++; + DRIVE[rqe->driveno].bytes_written += bp->b_bcount; + SD[rqe->sdno].writes++; + SD[rqe->sdno].bytes_written += bp->b_bcount; + PLEX[rqe->rqg->plexno].writes++; + PLEX[rqe->rqg->plexno].bytes_written += bp->b_bcount; + } + ubp = rq->bp; /* user buffer */ + rqg->active--; /* one less request active */ + if (rqg->active == 0) /* request group finished, */ + rq->active--; /* one less */ + if (rq->active == 0) { /* request finished, */ +#if DEBUG + if (debug & 4) { + if (ubp->b_resid != 0) /* still something to transfer? */ + Debugger("resid"); + + { + int i; + for (i = 0; i < ubp->b_bcount; i += 512) /* XXX debug */ + if (((char *) ubp->b_data)[i] != '<') { /* and not what we expected */ + printf("At 0x%x (offset 0x%x): '%c' (0x%x)\n", + (int) (&((char *) ubp->b_data)[i]), + i, + ((char *) ubp->b_data)[i], + ((char *) ubp->b_data)[i]); + Debugger("complete_request checksum"); + } + } + } +#endif + + if (rq->error) { /* did we have an error? */ + ubp->b_flags |= B_ERROR; /* yes, propagate to user */ + ubp->b_error = rq->error; + } else + ubp->b_resid = 0; /* completed our transfer */ + if (rq->isplex == 0) /* volume request, */ + VOL[rq->volplex.volno].active--; /* another request finished */ + biodone(ubp); /* top level buffer completed */ + freerq(rq); /* return the request storage */ + } +} + + +/* Free a request block and anything hanging off it */ +void +freerq(struct request *rq) +{ + BROKEN_GDB; + struct rqgroup *rqg; + struct rqgroup *nrqg; /* next in chain */ + int rqno; + + for (rqg = rq->rqg; rqg != NULL; rqg = nrqg) { /* through the whole request chain */ + for (rqno = 0; rqno < rqg->count; rqno++) + if ((rqg->rqe[rqno].flags & XFR_MALLOCED) /* data buffer was malloced, */ + &&rqg->rqe[rqno].b.b_data) /* and the allocation succeeded */ + Free(rqg->rqe[rqno].b.b_data); /* free it */ + nrqg = rqg->next; /* note the next one */ + Free(rqg); /* and free this one */ + } + Free(rq); /* free the request itself */ +} + +void +free_rqg(struct rqgroup *rqg) +{ + if ((rqg->flags & XFR_GROUPOP) /* RAID 5 request */ + &&(rqg->rqe) /* got a buffer structure */ + &&(rqg->rqe->b.b_data)) /* and it has a buffer allocated */ + Free(rqg->rqe->b.b_data); /* free it */ +} + +/* I/O on subdisk completed */ +void +sdio_done(struct buf *bp) +{ + struct sdbuf *sbp; + + sbp = (struct sdbuf *) bp; + if (sbp->b.b_flags & B_ERROR) { /* had an error */ + bp->b_flags |= B_ERROR; + bp->b_error = sbp->b.b_error; + } + bp->b_resid = sbp->b.b_resid; + biodone(sbp->bp); /* complete the caller's I/O */ + /* Now update the statistics */ + if (bp->b_flags & B_READ) { /* read operation */ + DRIVE[sbp->driveno].reads++; + DRIVE[sbp->driveno].bytes_read += bp->b_bcount; + SD[sbp->sdno].reads++; + SD[sbp->sdno].bytes_read += bp->b_bcount; + } else { /* write operation */ + DRIVE[sbp->driveno].writes++; + DRIVE[sbp->driveno].bytes_written += bp->b_bcount; + SD[sbp->sdno].writes++; + SD[sbp->sdno].bytes_written += bp->b_bcount; + } + Free(sbp); +} |