geom/journal/g_journal.c

802 	struct bio *nbp, *cbp, *pbp;
810 	pbp = NULL;
840 			if (pbp == NULL)
843 				pbp->bio_next = nbp;
846 			GJ_DEBUG(3, "INSERT(%p): 2 (nbp=%p pbp=%p)", *head, nbp,
847 			    pbp);
962 			if (pbp == NULL)
965 				pbp->bio_next = nbp;
986 		pbp = cbp;
989 	if (pbp == NULL)
992 		pbp->bio_next = nbp;
995 	GJ_DEBUG(3, "INSERT(%p): 8 (nbp=%p pbp=%p)", *head, nbp, pbp);
1018 	struct bio *cbp, *pbp;
1022 	pbp = NULL;
1026 			pbp = NULL;
1030 		if (pbp == NULL) {
1031 			pbp = cbp;
1035 		if (pbp->bio_offset + pbp->bio_length != cbp->bio_offset) {
1037 			KASSERT(pbp->bio_offset + pbp->bio_length < cbp->bio_offset,
1039 			    (intmax_t)pbp->bio_offset,
1040 			    (intmax_t)pbp->bio_length,
1042 			pbp = cbp;
1046 		if (pbp->bio_length + cbp->bio_length > MAXPHYS) {
1047 			pbp = cbp;
1051 		GJ_LOGREQ(4, pbp, "Join: ");
1053 		pbp->bio_data = gj_realloc(pbp->bio_data,
1054 		    pbp->bio_length + cbp->bio_length, pbp->bio_length);
1055 		bcopy(cbp->bio_data, pbp->bio_data + pbp->bio_length,
1058 		pbp->bio_length += cbp->bio_length;
1059 		pbp->bio_next = cbp->bio_next;
1061 		cbp = pbp;
1064 		GJ_LOGREQ(4, pbp, "Got: ");
1166 	struct bio *pbp;
1172 	pbp = bp->bio_parent;
1181 		g_destroy_bio(pbp);
1186 	pbp->bio_data = bp->bio_data;
1188 	g_io_request(pbp, cp);
1238 	struct bio *bp, *fbp, *pbp;
1263 	GJQ_LAST(sc->sc_flush_queue, pbp);
1273 	GJQ_INSERT_AFTER(sc->sc_flush_queue, fbp, pbp);
1274 	pbp = fbp;
1308 		GJQ_INSERT_AFTER(sc->sc_flush_queue, bp, pbp);
1309 		pbp = bp;
1475 g_journal_read_find(struct bio *head, int sorted, struct bio *pbp, off_t ostart,
1501 		    pbp->bio_data + cstart - pbp->bio_offset, cend - cstart);
1502 		pbp->bio_completed += cend - cstart;
1503 		if (pbp->bio_completed == pbp->bio_length) {
1508 			g_io_deliver(pbp, 0);
1509 			return (pbp);
1526 g_journal_read(struct g_journal_softc *sc, struct bio *pbp, off_t ostart,
1564 		bp = g_journal_read_find(head, sorted, pbp, ostart, oend);
1565 		if (bp == pbp) { /* Got the whole request. */
1578 			nbp = g_duplicate_bio(pbp);
1581 			    pbp->bio_data + cstart - pbp->bio_offset;
1593 			g_journal_read(sc, pbp, ostart, cstart);
1595 			g_journal_read(sc, pbp, cend, oend);
1602 		nbp = g_duplicate_bio(pbp);
1604 		nbp->bio_data = pbp->bio_data + ostart - pbp->bio_offset;
1622 	struct bio *pbp;
1627 	pbp = bp->bio_parent;
1628 	pbp->bio_inbed++;
1629 	pbp->bio_completed += bp->bio_length;
1632 		if (pbp->bio_error == 0)
1633 			pbp->bio_error = bp->bio_error;
1638 	if (pbp->bio_children == pbp->bio_inbed &&
1639 	    pbp->bio_completed == pbp->bio_length) {
1641 		g_io_deliver(pbp, 0);