@@ -1205,8 +1205,8 @@ static void coroutine_fn blk_wait_while_drained(BlockBackend *blk)
1205
1205
1206
1206
/* To be called between exactly one pair of blk_inc/dec_in_flight() */
1207
1207
static int coroutine_fn
1208
- blk_do_preadv (BlockBackend * blk , int64_t offset , int64_t bytes ,
1209
- QEMUIOVector * qiov , BdrvRequestFlags flags )
1208
+ blk_co_do_preadv (BlockBackend * blk , int64_t offset , int64_t bytes ,
1209
+ QEMUIOVector * qiov , BdrvRequestFlags flags )
1210
1210
{
1211
1211
int ret ;
1212
1212
BlockDriverState * bs ;
@@ -1242,17 +1242,17 @@ int coroutine_fn blk_co_preadv(BlockBackend *blk, int64_t offset,
1242
1242
int ret ;
1243
1243
1244
1244
blk_inc_in_flight (blk );
1245
- ret = blk_do_preadv (blk , offset , bytes , qiov , flags );
1245
+ ret = blk_co_do_preadv (blk , offset , bytes , qiov , flags );
1246
1246
blk_dec_in_flight (blk );
1247
1247
1248
1248
return ret ;
1249
1249
}
1250
1250
1251
1251
/* To be called between exactly one pair of blk_inc/dec_in_flight() */
1252
1252
static int coroutine_fn
1253
- blk_do_pwritev_part (BlockBackend * blk , int64_t offset , int64_t bytes ,
1254
- QEMUIOVector * qiov , size_t qiov_offset ,
1255
- BdrvRequestFlags flags )
1253
+ blk_co_do_pwritev_part (BlockBackend * blk , int64_t offset , int64_t bytes ,
1254
+ QEMUIOVector * qiov , size_t qiov_offset ,
1255
+ BdrvRequestFlags flags )
1256
1256
{
1257
1257
int ret ;
1258
1258
BlockDriverState * bs ;
@@ -1293,7 +1293,7 @@ int coroutine_fn blk_co_pwritev_part(BlockBackend *blk, int64_t offset,
1293
1293
int ret ;
1294
1294
1295
1295
blk_inc_in_flight (blk );
1296
- ret = blk_do_pwritev_part (blk , offset , bytes , qiov , qiov_offset , flags );
1296
+ ret = blk_co_do_pwritev_part (blk , offset , bytes , qiov , qiov_offset , flags );
1297
1297
blk_dec_in_flight (blk );
1298
1298
1299
1299
return ret ;
@@ -1319,8 +1319,8 @@ static void blk_read_entry(void *opaque)
1319
1319
BlkRwCo * rwco = opaque ;
1320
1320
QEMUIOVector * qiov = rwco -> iobuf ;
1321
1321
1322
- rwco -> ret = blk_do_preadv (rwco -> blk , rwco -> offset , qiov -> size ,
1323
- qiov , rwco -> flags );
1322
+ rwco -> ret = blk_co_do_preadv (rwco -> blk , rwco -> offset , qiov -> size ,
1323
+ qiov , rwco -> flags );
1324
1324
aio_wait_kick ();
1325
1325
}
1326
1326
@@ -1329,8 +1329,8 @@ static void blk_write_entry(void *opaque)
1329
1329
BlkRwCo * rwco = opaque ;
1330
1330
QEMUIOVector * qiov = rwco -> iobuf ;
1331
1331
1332
- rwco -> ret = blk_do_pwritev_part (rwco -> blk , rwco -> offset , qiov -> size ,
1333
- qiov , 0 , rwco -> flags );
1332
+ rwco -> ret = blk_co_do_pwritev_part (rwco -> blk , rwco -> offset , qiov -> size ,
1333
+ qiov , 0 , rwco -> flags );
1334
1334
aio_wait_kick ();
1335
1335
}
1336
1336
@@ -1483,8 +1483,8 @@ static void blk_aio_read_entry(void *opaque)
1483
1483
QEMUIOVector * qiov = rwco -> iobuf ;
1484
1484
1485
1485
assert (qiov -> size == acb -> bytes );
1486
- rwco -> ret = blk_do_preadv (rwco -> blk , rwco -> offset , acb -> bytes ,
1487
- qiov , rwco -> flags );
1486
+ rwco -> ret = blk_co_do_preadv (rwco -> blk , rwco -> offset , acb -> bytes ,
1487
+ qiov , rwco -> flags );
1488
1488
blk_aio_complete (acb );
1489
1489
}
1490
1490
@@ -1495,8 +1495,8 @@ static void blk_aio_write_entry(void *opaque)
1495
1495
QEMUIOVector * qiov = rwco -> iobuf ;
1496
1496
1497
1497
assert (!qiov || qiov -> size == acb -> bytes );
1498
- rwco -> ret = blk_do_pwritev_part (rwco -> blk , rwco -> offset , acb -> bytes ,
1499
- qiov , 0 , rwco -> flags );
1498
+ rwco -> ret = blk_co_do_pwritev_part (rwco -> blk , rwco -> offset , acb -> bytes ,
1499
+ qiov , 0 , rwco -> flags );
1500
1500
blk_aio_complete (acb );
1501
1501
}
1502
1502
@@ -1583,7 +1583,7 @@ void blk_aio_cancel_async(BlockAIOCB *acb)
1583
1583
1584
1584
/* To be called between exactly one pair of blk_inc/dec_in_flight() */
1585
1585
static int coroutine_fn
1586
- blk_do_ioctl (BlockBackend * blk , unsigned long int req , void * buf )
1586
+ blk_co_do_ioctl (BlockBackend * blk , unsigned long int req , void * buf )
1587
1587
{
1588
1588
blk_wait_while_drained (blk );
1589
1589
@@ -1599,7 +1599,7 @@ static void blk_ioctl_entry(void *opaque)
1599
1599
BlkRwCo * rwco = opaque ;
1600
1600
QEMUIOVector * qiov = rwco -> iobuf ;
1601
1601
1602
- rwco -> ret = blk_do_ioctl (rwco -> blk , rwco -> offset , qiov -> iov [0 ].iov_base );
1602
+ rwco -> ret = blk_co_do_ioctl (rwco -> blk , rwco -> offset , qiov -> iov [0 ].iov_base );
1603
1603
aio_wait_kick ();
1604
1604
}
1605
1605
@@ -1613,7 +1613,7 @@ static void blk_aio_ioctl_entry(void *opaque)
1613
1613
BlkAioEmAIOCB * acb = opaque ;
1614
1614
BlkRwCo * rwco = & acb -> rwco ;
1615
1615
1616
- rwco -> ret = blk_do_ioctl (rwco -> blk , rwco -> offset , rwco -> iobuf );
1616
+ rwco -> ret = blk_co_do_ioctl (rwco -> blk , rwco -> offset , rwco -> iobuf );
1617
1617
1618
1618
blk_aio_complete (acb );
1619
1619
}
@@ -1626,7 +1626,7 @@ BlockAIOCB *blk_aio_ioctl(BlockBackend *blk, unsigned long int req, void *buf,
1626
1626
1627
1627
/* To be called between exactly one pair of blk_inc/dec_in_flight() */
1628
1628
static int coroutine_fn
1629
- blk_do_pdiscard (BlockBackend * blk , int64_t offset , int64_t bytes )
1629
+ blk_co_do_pdiscard (BlockBackend * blk , int64_t offset , int64_t bytes )
1630
1630
{
1631
1631
int ret ;
1632
1632
@@ -1645,7 +1645,7 @@ static void blk_aio_pdiscard_entry(void *opaque)
1645
1645
BlkAioEmAIOCB * acb = opaque ;
1646
1646
BlkRwCo * rwco = & acb -> rwco ;
1647
1647
1648
- rwco -> ret = blk_do_pdiscard (rwco -> blk , rwco -> offset , acb -> bytes );
1648
+ rwco -> ret = blk_co_do_pdiscard (rwco -> blk , rwco -> offset , acb -> bytes );
1649
1649
blk_aio_complete (acb );
1650
1650
}
1651
1651
@@ -1663,7 +1663,7 @@ int coroutine_fn blk_co_pdiscard(BlockBackend *blk, int64_t offset,
1663
1663
int ret ;
1664
1664
1665
1665
blk_inc_in_flight (blk );
1666
- ret = blk_do_pdiscard (blk , offset , bytes );
1666
+ ret = blk_co_do_pdiscard (blk , offset , bytes );
1667
1667
blk_dec_in_flight (blk );
1668
1668
1669
1669
return ret ;
@@ -1674,7 +1674,7 @@ static void blk_pdiscard_entry(void *opaque)
1674
1674
BlkRwCo * rwco = opaque ;
1675
1675
QEMUIOVector * qiov = rwco -> iobuf ;
1676
1676
1677
- rwco -> ret = blk_do_pdiscard (rwco -> blk , rwco -> offset , qiov -> size );
1677
+ rwco -> ret = blk_co_do_pdiscard (rwco -> blk , rwco -> offset , qiov -> size );
1678
1678
aio_wait_kick ();
1679
1679
}
1680
1680
@@ -1684,7 +1684,7 @@ int blk_pdiscard(BlockBackend *blk, int64_t offset, int bytes)
1684
1684
}
1685
1685
1686
1686
/* To be called between exactly one pair of blk_inc/dec_in_flight() */
1687
- static int coroutine_fn blk_do_flush (BlockBackend * blk )
1687
+ static int coroutine_fn blk_co_do_flush (BlockBackend * blk )
1688
1688
{
1689
1689
blk_wait_while_drained (blk );
1690
1690
@@ -1700,7 +1700,7 @@ static void blk_aio_flush_entry(void *opaque)
1700
1700
BlkAioEmAIOCB * acb = opaque ;
1701
1701
BlkRwCo * rwco = & acb -> rwco ;
1702
1702
1703
- rwco -> ret = blk_do_flush (rwco -> blk );
1703
+ rwco -> ret = blk_co_do_flush (rwco -> blk );
1704
1704
blk_aio_complete (acb );
1705
1705
}
1706
1706
@@ -1715,7 +1715,7 @@ int coroutine_fn blk_co_flush(BlockBackend *blk)
1715
1715
int ret ;
1716
1716
1717
1717
blk_inc_in_flight (blk );
1718
- ret = blk_do_flush (blk );
1718
+ ret = blk_co_do_flush (blk );
1719
1719
blk_dec_in_flight (blk );
1720
1720
1721
1721
return ret ;
@@ -1724,7 +1724,7 @@ int coroutine_fn blk_co_flush(BlockBackend *blk)
1724
1724
static void blk_flush_entry (void * opaque )
1725
1725
{
1726
1726
BlkRwCo * rwco = opaque ;
1727
- rwco -> ret = blk_do_flush (rwco -> blk );
1727
+ rwco -> ret = blk_co_do_flush (rwco -> blk );
1728
1728
aio_wait_kick ();
1729
1729
}
1730
1730
0 commit comments