Lines Matching defs:cbp
1126 struct bio *cbp;
1142 cbp = g_clone_bio(bp);
1143 if (cbp == NULL) {
1147 cbp->bio_done = g_std_done;
1148 g_io_request(cbp, disk->d_consumer);
1512 struct bio *cbp;
1524 cbp = g_clone_bio(bp);
1525 if (cbp == NULL) {
1535 cbp->bio_done = g_mirror_done;
1536 cbp->bio_to = cp->provider;
1537 G_MIRROR_LOGREQ(3, cbp, "Sending request.");
1542 g_io_request(cbp, cp);
1550 struct bio *cbp;
1559 cbp = g_clone_bio(bp);
1560 if (cbp == NULL) {
1570 cbp->bio_done = g_mirror_done;
1571 cbp->bio_to = cp->provider;
1572 G_MIRROR_LOGREQ(3, cbp, "Sending request.");
1577 g_io_request(cbp, cp);
1589 struct bio *cbp;
1612 cbp = g_clone_bio(bp);
1613 if (cbp == NULL) {
1623 cbp->bio_done = g_mirror_done;
1624 cbp->bio_to = cp->provider;
1625 G_MIRROR_LOGREQ(3, cbp, "Sending request.");
1637 g_io_request(cbp, cp);
1646 struct bio *cbp;
1671 cbp = g_clone_bio(bp);
1672 if (cbp == NULL) {
1673 while ((cbp = TAILQ_FIRST(&queue)) != NULL) {
1674 TAILQ_REMOVE(&queue, cbp, bio_queue);
1675 g_destroy_bio(cbp);
1682 TAILQ_INSERT_TAIL(&queue, cbp, bio_queue);
1683 cbp->bio_done = g_mirror_done;
1684 cbp->bio_caller1 = disk;
1685 cbp->bio_to = disk->d_consumer->provider;
1686 cbp->bio_offset = offset;
1687 cbp->bio_data = data;
1688 cbp->bio_length = MIN(left, slice);
1689 left -= cbp->bio_length;
1692 offset += cbp->bio_length;
1693 data += cbp->bio_length;
1695 while ((cbp = TAILQ_FIRST(&queue)) != NULL) {
1696 TAILQ_REMOVE(&queue, cbp, bio_queue);
1697 G_MIRROR_LOGREQ(3, cbp, "Sending request.");
1698 disk = cbp->bio_caller1;
1699 cbp->bio_caller1 = NULL;
1705 g_io_request(cbp, disk->d_consumer);
1713 struct bio *cbp;
1790 cbp = g_clone_bio(bp);
1791 if (cbp == NULL) {
1792 while ((cbp = TAILQ_FIRST(&queue)) != NULL) {
1793 TAILQ_REMOVE(&queue, cbp, bio_queue);
1794 g_destroy_bio(cbp);
1801 TAILQ_INSERT_TAIL(&queue, cbp, bio_queue);
1802 cbp->bio_done = g_mirror_done;
1804 cbp->bio_caller1 = cp;
1805 cbp->bio_to = cp->provider;
1816 while ((cbp = TAILQ_FIRST(&queue)) != NULL) {
1817 G_MIRROR_LOGREQ(3, cbp, "Sending request.");
1818 TAILQ_REMOVE(&queue, cbp, bio_queue);
1819 cp = cbp->bio_caller1;
1820 cbp->bio_caller1 = NULL;
1823 g_io_request(cbp, cp);
1837 cbp = g_clone_bio(bp);
1838 if (cbp == NULL) {
1839 while ((cbp = TAILQ_FIRST(&queue)) != NULL) {
1840 TAILQ_REMOVE(&queue, cbp, bio_queue);
1841 g_destroy_bio(cbp);
1848 TAILQ_INSERT_TAIL(&queue, cbp, bio_queue);
1849 cbp->bio_done = g_mirror_done;
1850 cbp->bio_caller1 = disk;
1851 cbp->bio_to = disk->d_consumer->provider;
1855 while ((cbp = TAILQ_FIRST(&queue)) != NULL) {
1856 G_MIRROR_LOGREQ(3, cbp, "Sending request.");
1857 TAILQ_REMOVE(&queue, cbp, bio_queue);
1858 disk = cbp->bio_caller1;
1859 cbp->bio_caller1 = NULL;
1865 g_io_request(cbp, cp);