/openbmc/qemu/io/ |
H A D | channel-buffer.c | 60 QIOChannelBuffer *bioc = QIO_CHANNEL_BUFFER(ioc); in qio_channel_buffer_readv() local 66 if (bioc->offset >= bioc->usage) { in qio_channel_buffer_readv() 69 if ((bioc->offset + want) > bioc->usage) { in qio_channel_buffer_readv() 70 want = bioc->usage - bioc->offset; in qio_channel_buffer_readv() 72 memcpy(iov[i].iov_base, bioc->data + bioc->offset, want); in qio_channel_buffer_readv() 74 bioc->offset += want; in qio_channel_buffer_readv() 88 QIOChannelBuffer *bioc = QIO_CHANNEL_BUFFER(ioc); in qio_channel_buffer_writev() local 97 if ((bioc->offset + towrite) > bioc->capacity) { in qio_channel_buffer_writev() 98 bioc->capacity = bioc->offset + towrite; in qio_channel_buffer_writev() 99 bioc->data = g_realloc(bioc->data, bioc->capacity); in qio_channel_buffer_writev() [all …]
|
/openbmc/qemu/migration/ |
H A D | channel-block.c | 59 QIOChannelBlock *bioc = QIO_CHANNEL_BLOCK(ioc); in qio_channel_block_readv() local 64 ret = bdrv_readv_vmstate(bioc->bs, &qiov, bioc->offset); in qio_channel_block_readv() 70 bioc->offset += qiov.size; in qio_channel_block_readv() 84 QIOChannelBlock *bioc = QIO_CHANNEL_BLOCK(ioc); in qio_channel_block_writev() local 89 ret = bdrv_writev_vmstate(bioc->bs, &qiov, bioc->offset); in qio_channel_block_writev() 95 bioc->offset += qiov.size; in qio_channel_block_writev() 119 QIOChannelBlock *bioc = QIO_CHANNEL_BLOCK(ioc); in qio_channel_block_seek() local 123 bioc->offset = offset; in qio_channel_block_seek() 126 bioc->offset += whence; in qio_channel_block_seek() 135 return bioc->offset; in qio_channel_block_seek() [all …]
|
H A D | colo.c | 406 QIOChannelBuffer *bioc, in colo_do_checkpoint_transaction() argument 424 qio_channel_io_seek(QIO_CHANNEL(bioc), 0, 0, NULL); in colo_do_checkpoint_transaction() 425 bioc->usage = 0; in colo_do_checkpoint_transaction() 480 bioc->usage, &local_err); in colo_do_checkpoint_transaction() 485 qemu_put_buffer(s->to_dst_file, bioc->data, bioc->usage); in colo_do_checkpoint_transaction() 530 QIOChannelBuffer *bioc; in colo_process_checkpoint() local 560 bioc = qio_channel_buffer_new(COLO_BUFFER_BASE_SIZE); in colo_process_checkpoint() 561 fb = qemu_file_new_output(QIO_CHANNEL(bioc)); in colo_process_checkpoint() 562 object_unref(OBJECT(bioc)); in colo_process_checkpoint() 589 ret = colo_do_checkpoint_transaction(s, bioc, fb); in colo_process_checkpoint() [all …]
|
H A D | migration.c | 2499 QIOChannelBuffer *bioc; in postcopy_start() local 2584 bioc = qio_channel_buffer_new(4096); in postcopy_start() 2585 qio_channel_set_name(QIO_CHANNEL(bioc), "migration-postcopy-buffer"); in postcopy_start() 2586 fb = qemu_file_new_output(QIO_CHANNEL(bioc)); in postcopy_start() 2587 object_unref(OBJECT(bioc)); in postcopy_start() 2617 if (qemu_savevm_send_packaged(ms->to_dst_file, bioc->data, bioc->usage)) { in postcopy_start() 2869 qemu_put_buffer(s->to_dst_file, s->bioc->data, s->bioc->usage); in bg_migration_completion() 3597 s->bioc = qio_channel_buffer_new(512 * 1024); in bg_migration_thread() 3598 qio_channel_set_name(QIO_CHANNEL(s->bioc), "vmstate-buffer"); in bg_migration_thread() 3599 fb = qemu_file_new_output(QIO_CHANNEL(s->bioc)); in bg_migration_thread() [all …]
|
H A D | migration.h | 285 QIOChannelBuffer *bioc; member
|
H A D | savevm.c | 2304 QIOChannelBuffer *bioc; in loadvm_handle_cmd_packaged() local 2314 bioc = qio_channel_buffer_new(length); in loadvm_handle_cmd_packaged() 2315 qio_channel_set_name(QIO_CHANNEL(bioc), "migration-loadvm-buffer"); in loadvm_handle_cmd_packaged() 2317 bioc->data, in loadvm_handle_cmd_packaged() 2320 object_unref(OBJECT(bioc)); in loadvm_handle_cmd_packaged() 2325 bioc->usage += length; in loadvm_handle_cmd_packaged() 2328 QEMUFile *packf = qemu_file_new_input(QIO_CHANNEL(bioc)); in loadvm_handle_cmd_packaged() 2354 object_unref(OBJECT(bioc)); in loadvm_handle_cmd_packaged()
|
/openbmc/linux/fs/btrfs/ |
H A D | bio.c | 143 struct btrfs_io_context *orig_bioc = orig_stripe->bioc; in btrfs_bbio_propagate_error() 384 struct btrfs_io_context *bioc = bio->bi_private; in btrfs_raid56_end_io() local 387 btrfs_bio_counter_dec(bioc->fs_info); in btrfs_raid56_end_io() 388 bbio->mirror_num = bioc->mirror_num; in btrfs_raid56_end_io() 394 btrfs_put_bioc(bioc); in btrfs_raid56_end_io() 400 struct btrfs_io_context *bioc = stripe->bioc; in btrfs_orig_write_end_io() local 403 btrfs_bio_counter_dec(bioc->fs_info); in btrfs_orig_write_end_io() 406 atomic_inc(&bioc->error); in btrfs_orig_write_end_io() 414 if (atomic_read(&bioc->error) > bioc->max_errors) in btrfs_orig_write_end_io() 420 btrfs_put_bioc(bioc); in btrfs_orig_write_end_io() [all …]
|
H A D | raid56.c | 104 btrfs_put_bioc(rbio->bioc); in free_raid_bio() 112 queue_work(rbio->bioc->fs_info->rmw_workers, &rbio->work); in start_async_work() 194 rbio->bioc->fs_info->sectorsize); in cache_rbio_pages() 205 u64 num = rbio->bioc->full_stripe_logical; in rbio_bucket() 221 const u32 sectorsize = rbio->bioc->fs_info->sectorsize; in full_page_sectors_uptodate() 243 const u32 sectorsize = rbio->bioc->fs_info->sectorsize; in index_stripe_sectors() 259 const u32 sectorsize = src->bioc->fs_info->sectorsize; in steal_rbio_page() 277 rbio->bioc->fs_info->sectorsize_bits; in is_data_stripe_page() 360 table = rbio->bioc->fs_info->stripe_hash_table; in __remove_rbio_from_cache() 414 table = rbio->bioc->fs_info->stripe_hash_table; in remove_rbio_from_cache() [all …]
|
H A D | raid56.h | 20 struct btrfs_io_context *bioc; member 172 static inline int nr_bioc_data_stripes(const struct btrfs_io_context *bioc) in nr_bioc_data_stripes() argument 174 return bioc->num_stripes - btrfs_nr_parity_stripes(bioc->map_type); in nr_bioc_data_stripes() 185 void raid56_parity_recover(struct bio *bio, struct btrfs_io_context *bioc, 187 void raid56_parity_write(struct bio *bio, struct btrfs_io_context *bioc); 190 struct btrfs_io_context *bioc,
|
H A D | volumes.c | 5936 struct btrfs_io_context *bioc; in alloc_btrfs_io_context() local 5938 bioc = kzalloc( in alloc_btrfs_io_context() 5945 if (!bioc) in alloc_btrfs_io_context() 5948 refcount_set(&bioc->refs, 1); in alloc_btrfs_io_context() 5950 bioc->fs_info = fs_info; in alloc_btrfs_io_context() 5951 bioc->replace_stripe_src = -1; in alloc_btrfs_io_context() 5952 bioc->full_stripe_logical = (u64)-1; in alloc_btrfs_io_context() 5954 return bioc; in alloc_btrfs_io_context() 5957 void btrfs_get_bioc(struct btrfs_io_context *bioc) in btrfs_get_bioc() argument 5959 WARN_ON(!refcount_read(&bioc->refs)); in btrfs_get_bioc() [all …]
|
H A D | volumes.h | 394 struct btrfs_io_context *bioc; member 600 void btrfs_get_bioc(struct btrfs_io_context *bioc); 601 void btrfs_put_bioc(struct btrfs_io_context *bioc);
|
H A D | scrub.c | 892 struct btrfs_io_context *bioc = NULL; in scrub_stripe_report_errors() local 899 stripe->logical, &mapped_len, &bioc, in scrub_stripe_report_errors() 907 physical = bioc->stripes[stripe_index].physical; in scrub_stripe_report_errors() 908 dev = bioc->stripes[stripe_index].dev; in scrub_stripe_report_errors() 909 btrfs_put_bioc(bioc); in scrub_stripe_report_errors() 1856 struct btrfs_io_context *bioc = NULL; in scrub_raid56_parity_stripe() local 1976 &length, &bioc, NULL, NULL, 1); in scrub_raid56_parity_stripe() 1978 btrfs_put_bioc(bioc); in scrub_raid56_parity_stripe() 1982 rbio = raid56_parity_alloc_scrub_rbio(bio, bioc, scrub_dev, &extent_bitmap, in scrub_raid56_parity_stripe() 1984 btrfs_put_bioc(bioc); in scrub_raid56_parity_stripe()
|
H A D | zoned.c | 1893 struct btrfs_io_context *bioc = NULL; in read_zone_info() local 1900 &mapped_length, &bioc, NULL, NULL, 1); in read_zone_info() 1901 if (ret || !bioc || mapped_length < PAGE_SIZE) { in read_zone_info() 1906 if (bioc->map_type & BTRFS_BLOCK_GROUP_RAID56_MASK) { in read_zone_info() 1912 nmirrors = (int)bioc->num_stripes; in read_zone_info() 1914 u64 physical = bioc->stripes[i].physical; in read_zone_info() 1915 struct btrfs_device *dev = bioc->stripes[i].dev; in read_zone_info() 1929 btrfs_put_bioc(bioc); in read_zone_info()
|
H A D | check-integrity.c | 1462 struct btrfs_io_context *bioc = NULL; in btrfsic_map_block() local 1467 ret = btrfs_map_block(fs_info, BTRFS_MAP_READ, bytenr, &length, &bioc, in btrfsic_map_block() 1481 if (bioc) in btrfsic_map_block() 1482 map = &bioc->stripes[0]; in btrfsic_map_block() 1500 kfree(bioc); in btrfsic_map_block()
|
/openbmc/linux/include/trace/events/ |
H A D | btrfs.h | 2462 TP_fast_assign_btrfs(rbio->bioc->fs_info, 2463 __entry->full_stripe = rbio->bioc->full_stripe_logical; 2470 __entry->total_stripes = rbio->bioc->num_stripes;
|