geom/mirror/g_mirror.c

1051 	struct bio *cbp;
1067 	cbp = g_clone_bio(bp);
1068 	if (cbp == NULL) {
1072 	cbp->bio_done = g_std_done;
1073 	g_io_request(cbp, disk->d_consumer);
1084 	struct bio *cbp;
1090 		cbp = g_clone_bio(bp);
1091 		if (cbp == NULL) {
1092 			while ((cbp = bioq_takefirst(&queue)) != NULL)
1093 				g_destroy_bio(cbp);
1099 		bioq_insert_tail(&queue, cbp);
1100 		cbp->bio_done = g_mirror_flush_done;
1101 		cbp->bio_caller1 = disk;
1102 		cbp->bio_to = disk->d_consumer->provider;
1104 	while ((cbp = bioq_takefirst(&queue)) != NULL) {
1105 		G_MIRROR_LOGREQ(3, cbp, "Sending request.");
1106 		disk = cbp->bio_caller1;
1107 		cbp->bio_caller1 = NULL;
1112 		g_io_request(cbp, disk->d_consumer);
1429 	struct bio *cbp;
1441 	cbp = g_clone_bio(bp);
1442 	if (cbp == NULL) {
1452 	cbp->bio_done = g_mirror_done;
1453 	cbp->bio_to = cp->provider;
1454 	G_MIRROR_LOGREQ(3, cbp, "Sending request.");
1459 	g_io_request(cbp, cp);
1467 	struct bio *cbp;
1476 	cbp = g_clone_bio(bp);
1477 	if (cbp == NULL) {
1487 	cbp->bio_done = g_mirror_done;
1488 	cbp->bio_to = cp->provider;
1489 	G_MIRROR_LOGREQ(3, cbp, "Sending request.");
1494 	g_io_request(cbp, cp);
1506 	struct bio *cbp;
1529 	cbp = g_clone_bio(bp);
1530 	if (cbp == NULL) {
1540 	cbp->bio_done = g_mirror_done;
1541 	cbp->bio_to = cp->provider;
1542 	G_MIRROR_LOGREQ(3, cbp, "Sending request.");
1554 	g_io_request(cbp, cp);
1563 	struct bio *cbp;
1588 		cbp = g_clone_bio(bp);
1589 		if (cbp == NULL) {
1590 			while ((cbp = bioq_takefirst(&queue)) != NULL)
1591 				g_destroy_bio(cbp);
1597 		bioq_insert_tail(&queue, cbp);
1598 		cbp->bio_done = g_mirror_done;
1599 		cbp->bio_caller1 = disk;
1600 		cbp->bio_to = disk->d_consumer->provider;
1601 		cbp->bio_offset = offset;
1602 		cbp->bio_data = data;
1603 		cbp->bio_length = MIN(left, slice);
1604 		left -= cbp->bio_length;
1607 		offset += cbp->bio_length;
1608 		data += cbp->bio_length;
1610 	while ((cbp = bioq_takefirst(&queue)) != NULL) {
1611 		G_MIRROR_LOGREQ(3, cbp, "Sending request.");
1612 		disk = cbp->bio_caller1;
1613 		cbp->bio_caller1 = NULL;
1619 		g_io_request(cbp, disk->d_consumer);
1653 		struct bio *cbp;
1689 			cbp = g_clone_bio(bp);
1690 			if (cbp == NULL) {
1691 				while ((cbp = bioq_takefirst(&queue)) != NULL)
1692 					g_destroy_bio(cbp);
1698 			bioq_insert_tail(&queue, cbp);
1699 			cbp->bio_done = g_mirror_done;
1701 			cbp->bio_caller1 = cp;
1702 			cbp->bio_to = cp->provider;
1711 		while ((cbp = bioq_takefirst(&queue)) != NULL) {
1712 			G_MIRROR_LOGREQ(3, cbp, "Sending request.");
1713 			cp = cbp->bio_caller1;
1714 			cbp->bio_caller1 = NULL;
1717 			g_io_request(cbp, cp);