summaryrefslogtreecommitdiffstats
path: root/sys/dev/vinum/vinuminterrupt.c
diff options
context:
space:
mode:
Diffstat (limited to 'sys/dev/vinum/vinuminterrupt.c')
-rw-r--r--sys/dev/vinum/vinuminterrupt.c198
1 files changed, 0 insertions, 198 deletions
diff --git a/sys/dev/vinum/vinuminterrupt.c b/sys/dev/vinum/vinuminterrupt.c
deleted file mode 100644
index 086d6d1..0000000
--- a/sys/dev/vinum/vinuminterrupt.c
+++ /dev/null
@@ -1,198 +0,0 @@
-/* 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.2 1998/10/30 06:39:36 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 */
- ubp = rq->bp; /* user buffer */
-
-#ifdef DEBUG
- if (debug & DEBUG_LASTREQS)
- logrq(loginfo_iodone, rqe, ubp);
-#endif
- 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 | setstate_noupdate); /* take the subdisk down */
- else if (rq->error = ENXIO) /* or "not configured" (drive down) */
- set_drive_state(rqe->driveno, /* take the drive down */
- drive_down,
- setstate_force | setstate_noupdate);
- }
- /* 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;
- }
- 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 & DEBUG_RESID) {
- 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);
-}
OpenPOWER on IntegriCloud