12f0c9fe6SPaolo Bonzini /* 22f0c9fe6SPaolo Bonzini * QEMU System Emulator block driver 32f0c9fe6SPaolo Bonzini * 42f0c9fe6SPaolo Bonzini * Copyright (c) 2011 IBM Corp. 52f0c9fe6SPaolo Bonzini * Copyright (c) 2012 Red Hat, Inc. 62f0c9fe6SPaolo Bonzini * 72f0c9fe6SPaolo Bonzini * Permission is hereby granted, free of charge, to any person obtaining a copy 82f0c9fe6SPaolo Bonzini * of this software and associated documentation files (the "Software"), to deal 92f0c9fe6SPaolo Bonzini * in the Software without restriction, including without limitation the rights 102f0c9fe6SPaolo Bonzini * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell 112f0c9fe6SPaolo Bonzini * copies of the Software, and to permit persons to whom the Software is 122f0c9fe6SPaolo Bonzini * furnished to do so, subject to the following conditions: 132f0c9fe6SPaolo Bonzini * 142f0c9fe6SPaolo Bonzini * The above copyright notice and this permission notice shall be included in 152f0c9fe6SPaolo Bonzini * all copies or substantial portions of the Software. 162f0c9fe6SPaolo Bonzini * 172f0c9fe6SPaolo Bonzini * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR 182f0c9fe6SPaolo Bonzini * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, 192f0c9fe6SPaolo Bonzini * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL 202f0c9fe6SPaolo Bonzini * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER 212f0c9fe6SPaolo Bonzini * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, 222f0c9fe6SPaolo Bonzini * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN 232f0c9fe6SPaolo Bonzini * THE SOFTWARE. 242f0c9fe6SPaolo Bonzini */ 252f0c9fe6SPaolo Bonzini 26d38ea87aSPeter Maydell #include "qemu/osdep.h" 272f0c9fe6SPaolo Bonzini #include "qemu-common.h" 282f0c9fe6SPaolo Bonzini #include "trace.h" 29737e150eSPaolo Bonzini #include "block/block.h" 30737e150eSPaolo Bonzini #include "block/blockjob.h" 31737e150eSPaolo Bonzini #include "block/block_int.h" 32373340b2SMax Reitz #include "sysemu/block-backend.h" 33cc7a8ea7SMarkus Armbruster #include "qapi/qmp/qerror.h" 347b1b5d19SPaolo Bonzini #include "qapi/qmp/qjson.h" 3510817bf0SDaniel P. Berrange #include "qemu/coroutine.h" 362f0c9fe6SPaolo Bonzini #include "qmp-commands.h" 371de7afc9SPaolo Bonzini #include "qemu/timer.h" 385a2d2cbdSWenchao Xia #include "qapi-event.h" 392f0c9fe6SPaolo Bonzini 40c55a832fSFam Zheng /* Transactional group of block jobs */ 41c55a832fSFam Zheng struct BlockJobTxn { 42c55a832fSFam Zheng 43c55a832fSFam Zheng /* Is this txn being cancelled? */ 44c55a832fSFam Zheng bool aborting; 45c55a832fSFam Zheng 46c55a832fSFam Zheng /* List of jobs */ 47c55a832fSFam Zheng QLIST_HEAD(, BlockJob) jobs; 48c55a832fSFam Zheng 49c55a832fSFam Zheng /* Reference count */ 50c55a832fSFam Zheng int refcnt; 51c55a832fSFam Zheng }; 52c55a832fSFam Zheng 53a7112795SAlberto Garcia static QLIST_HEAD(, BlockJob) block_jobs = QLIST_HEAD_INITIALIZER(block_jobs); 54a7112795SAlberto Garcia 55a7112795SAlberto Garcia BlockJob *block_job_next(BlockJob *job) 56a7112795SAlberto Garcia { 57a7112795SAlberto Garcia if (!job) { 58a7112795SAlberto Garcia return QLIST_FIRST(&block_jobs); 59a7112795SAlberto Garcia } 60a7112795SAlberto Garcia return QLIST_NEXT(job, job_list); 61a7112795SAlberto Garcia } 62a7112795SAlberto Garcia 633fc4b10aSFam Zheng void *block_job_create(const BlockJobDriver *driver, BlockDriverState *bs, 64097310b5SMarkus Armbruster int64_t speed, BlockCompletionFunc *cb, 652f0c9fe6SPaolo Bonzini void *opaque, Error **errp) 662f0c9fe6SPaolo Bonzini { 67b6d2e599SKevin Wolf BlockBackend *blk; 682f0c9fe6SPaolo Bonzini BlockJob *job; 692f0c9fe6SPaolo Bonzini 70628ff683SFam Zheng if (bs->job) { 71c6bd8c70SMarkus Armbruster error_setg(errp, QERR_DEVICE_IN_USE, bdrv_get_device_name(bs)); 722f0c9fe6SPaolo Bonzini return NULL; 732f0c9fe6SPaolo Bonzini } 74b6d2e599SKevin Wolf 75b6d2e599SKevin Wolf blk = blk_new(); 76b6d2e599SKevin Wolf blk_insert_bs(blk, bs); 77b6d2e599SKevin Wolf 783fc4b10aSFam Zheng job = g_malloc0(driver->instance_size); 793718d8abSFam Zheng error_setg(&job->blocker, "block device is in use by block job: %s", 803718d8abSFam Zheng BlockJobType_lookup[driver->job_type]); 813718d8abSFam Zheng bdrv_op_block_all(bs, job->blocker); 82b112a65cSStefan Hajnoczi bdrv_op_unblock(bs, BLOCK_OP_TYPE_DATAPLANE, job->blocker); 833718d8abSFam Zheng 843fc4b10aSFam Zheng job->driver = driver; 858ccb9569SKevin Wolf job->id = g_strdup(bdrv_get_device_name(bs)); 86b6d2e599SKevin Wolf job->blk = blk; 872f0c9fe6SPaolo Bonzini job->cb = cb; 882f0c9fe6SPaolo Bonzini job->opaque = opaque; 892f0c9fe6SPaolo Bonzini job->busy = true; 9018930ba3SFam Zheng job->refcnt = 1; 912f0c9fe6SPaolo Bonzini bs->job = job; 922f0c9fe6SPaolo Bonzini 93a7112795SAlberto Garcia QLIST_INSERT_HEAD(&block_jobs, job, job_list); 94a7112795SAlberto Garcia 952f0c9fe6SPaolo Bonzini /* Only set speed when necessary to avoid NotSupported error */ 962f0c9fe6SPaolo Bonzini if (speed != 0) { 972f0c9fe6SPaolo Bonzini Error *local_err = NULL; 982f0c9fe6SPaolo Bonzini 992f0c9fe6SPaolo Bonzini block_job_set_speed(job, speed, &local_err); 10084d18f06SMarkus Armbruster if (local_err) { 10118930ba3SFam Zheng block_job_unref(job); 1022f0c9fe6SPaolo Bonzini error_propagate(errp, local_err); 1032f0c9fe6SPaolo Bonzini return NULL; 1042f0c9fe6SPaolo Bonzini } 1052f0c9fe6SPaolo Bonzini } 1062f0c9fe6SPaolo Bonzini return job; 1072f0c9fe6SPaolo Bonzini } 1082f0c9fe6SPaolo Bonzini 10918930ba3SFam Zheng void block_job_ref(BlockJob *job) 11097031164STing Wang { 11118930ba3SFam Zheng ++job->refcnt; 11218930ba3SFam Zheng } 11397031164STing Wang 11418930ba3SFam Zheng void block_job_unref(BlockJob *job) 11518930ba3SFam Zheng { 11618930ba3SFam Zheng if (--job->refcnt == 0) { 117b6d2e599SKevin Wolf BlockDriverState *bs = blk_bs(job->blk); 118b6d2e599SKevin Wolf bs->job = NULL; 119b6d2e599SKevin Wolf bdrv_op_unblock_all(bs, job->blocker); 120b6d2e599SKevin Wolf blk_unref(job->blk); 12197031164STing Wang error_free(job->blocker); 1228ccb9569SKevin Wolf g_free(job->id); 123a7112795SAlberto Garcia QLIST_REMOVE(job, job_list); 12497031164STing Wang g_free(job); 12597031164STing Wang } 12618930ba3SFam Zheng } 12797031164STing Wang 128c55a832fSFam Zheng static void block_job_completed_single(BlockJob *job) 129c55a832fSFam Zheng { 130c55a832fSFam Zheng if (!job->ret) { 131c55a832fSFam Zheng if (job->driver->commit) { 132c55a832fSFam Zheng job->driver->commit(job); 133c55a832fSFam Zheng } 134c55a832fSFam Zheng } else { 135c55a832fSFam Zheng if (job->driver->abort) { 136c55a832fSFam Zheng job->driver->abort(job); 137c55a832fSFam Zheng } 138c55a832fSFam Zheng } 139c55a832fSFam Zheng job->cb(job->opaque, job->ret); 140c55a832fSFam Zheng if (job->txn) { 141c55a832fSFam Zheng block_job_txn_unref(job->txn); 142c55a832fSFam Zheng } 143c55a832fSFam Zheng block_job_unref(job); 144c55a832fSFam Zheng } 145c55a832fSFam Zheng 146c55a832fSFam Zheng static void block_job_completed_txn_abort(BlockJob *job) 147c55a832fSFam Zheng { 148c55a832fSFam Zheng AioContext *ctx; 149c55a832fSFam Zheng BlockJobTxn *txn = job->txn; 150c55a832fSFam Zheng BlockJob *other_job, *next; 151c55a832fSFam Zheng 152c55a832fSFam Zheng if (txn->aborting) { 153c55a832fSFam Zheng /* 154c55a832fSFam Zheng * We are cancelled by another job, which will handle everything. 155c55a832fSFam Zheng */ 156c55a832fSFam Zheng return; 157c55a832fSFam Zheng } 158c55a832fSFam Zheng txn->aborting = true; 159c55a832fSFam Zheng /* We are the first failed job. Cancel other jobs. */ 160c55a832fSFam Zheng QLIST_FOREACH(other_job, &txn->jobs, txn_list) { 161b6d2e599SKevin Wolf ctx = blk_get_aio_context(other_job->blk); 162c55a832fSFam Zheng aio_context_acquire(ctx); 163c55a832fSFam Zheng } 164c55a832fSFam Zheng QLIST_FOREACH(other_job, &txn->jobs, txn_list) { 165c55a832fSFam Zheng if (other_job == job || other_job->completed) { 166c55a832fSFam Zheng /* Other jobs are "effectively" cancelled by us, set the status for 167c55a832fSFam Zheng * them; this job, however, may or may not be cancelled, depending 168c55a832fSFam Zheng * on the caller, so leave it. */ 169c55a832fSFam Zheng if (other_job != job) { 170c55a832fSFam Zheng other_job->cancelled = true; 171c55a832fSFam Zheng } 172c55a832fSFam Zheng continue; 173c55a832fSFam Zheng } 174c55a832fSFam Zheng block_job_cancel_sync(other_job); 175c55a832fSFam Zheng assert(other_job->completed); 176c55a832fSFam Zheng } 177c55a832fSFam Zheng QLIST_FOREACH_SAFE(other_job, &txn->jobs, txn_list, next) { 178b6d2e599SKevin Wolf ctx = blk_get_aio_context(other_job->blk); 179c55a832fSFam Zheng block_job_completed_single(other_job); 180c55a832fSFam Zheng aio_context_release(ctx); 181c55a832fSFam Zheng } 182c55a832fSFam Zheng } 183c55a832fSFam Zheng 184c55a832fSFam Zheng static void block_job_completed_txn_success(BlockJob *job) 185c55a832fSFam Zheng { 186c55a832fSFam Zheng AioContext *ctx; 187c55a832fSFam Zheng BlockJobTxn *txn = job->txn; 188c55a832fSFam Zheng BlockJob *other_job, *next; 189c55a832fSFam Zheng /* 190c55a832fSFam Zheng * Successful completion, see if there are other running jobs in this 191c55a832fSFam Zheng * txn. 192c55a832fSFam Zheng */ 193c55a832fSFam Zheng QLIST_FOREACH(other_job, &txn->jobs, txn_list) { 194c55a832fSFam Zheng if (!other_job->completed) { 195c55a832fSFam Zheng return; 196c55a832fSFam Zheng } 197c55a832fSFam Zheng } 198c55a832fSFam Zheng /* We are the last completed job, commit the transaction. */ 199c55a832fSFam Zheng QLIST_FOREACH_SAFE(other_job, &txn->jobs, txn_list, next) { 200b6d2e599SKevin Wolf ctx = blk_get_aio_context(other_job->blk); 201c55a832fSFam Zheng aio_context_acquire(ctx); 202c55a832fSFam Zheng assert(other_job->ret == 0); 203c55a832fSFam Zheng block_job_completed_single(other_job); 204c55a832fSFam Zheng aio_context_release(ctx); 205c55a832fSFam Zheng } 206c55a832fSFam Zheng } 207c55a832fSFam Zheng 20865f46322SPaolo Bonzini void block_job_completed(BlockJob *job, int ret) 2092f0c9fe6SPaolo Bonzini { 210b6d2e599SKevin Wolf assert(blk_bs(job->blk)->job == job); 211a689dbf2SFam Zheng assert(!job->completed); 212a689dbf2SFam Zheng job->completed = true; 213a689dbf2SFam Zheng job->ret = ret; 214c55a832fSFam Zheng if (!job->txn) { 215c55a832fSFam Zheng block_job_completed_single(job); 216c55a832fSFam Zheng } else if (ret < 0 || block_job_is_cancelled(job)) { 217c55a832fSFam Zheng block_job_completed_txn_abort(job); 218c55a832fSFam Zheng } else { 219c55a832fSFam Zheng block_job_completed_txn_success(job); 220c55a832fSFam Zheng } 2212f0c9fe6SPaolo Bonzini } 2222f0c9fe6SPaolo Bonzini 2232f0c9fe6SPaolo Bonzini void block_job_set_speed(BlockJob *job, int64_t speed, Error **errp) 2242f0c9fe6SPaolo Bonzini { 2252f0c9fe6SPaolo Bonzini Error *local_err = NULL; 2262f0c9fe6SPaolo Bonzini 2273fc4b10aSFam Zheng if (!job->driver->set_speed) { 228c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2292f0c9fe6SPaolo Bonzini return; 2302f0c9fe6SPaolo Bonzini } 2313fc4b10aSFam Zheng job->driver->set_speed(job, speed, &local_err); 23284d18f06SMarkus Armbruster if (local_err) { 2332f0c9fe6SPaolo Bonzini error_propagate(errp, local_err); 2342f0c9fe6SPaolo Bonzini return; 2352f0c9fe6SPaolo Bonzini } 2362f0c9fe6SPaolo Bonzini 2372f0c9fe6SPaolo Bonzini job->speed = speed; 2382f0c9fe6SPaolo Bonzini } 2392f0c9fe6SPaolo Bonzini 240aeae883bSPaolo Bonzini void block_job_complete(BlockJob *job, Error **errp) 241aeae883bSPaolo Bonzini { 242751ebd76SFam Zheng if (job->pause_count || job->cancelled || !job->driver->complete) { 2438ccb9569SKevin Wolf error_setg(errp, QERR_BLOCK_JOB_NOT_READY, job->id); 244aeae883bSPaolo Bonzini return; 245aeae883bSPaolo Bonzini } 246aeae883bSPaolo Bonzini 2473fc4b10aSFam Zheng job->driver->complete(job, errp); 248aeae883bSPaolo Bonzini } 249aeae883bSPaolo Bonzini 2508acc72a4SPaolo Bonzini void block_job_pause(BlockJob *job) 2512f0c9fe6SPaolo Bonzini { 252751ebd76SFam Zheng job->pause_count++; 2538acc72a4SPaolo Bonzini } 2548acc72a4SPaolo Bonzini 2558acc72a4SPaolo Bonzini bool block_job_is_paused(BlockJob *job) 2568acc72a4SPaolo Bonzini { 257751ebd76SFam Zheng return job->pause_count > 0; 2588acc72a4SPaolo Bonzini } 2598acc72a4SPaolo Bonzini 2608acc72a4SPaolo Bonzini void block_job_resume(BlockJob *job) 2618acc72a4SPaolo Bonzini { 262751ebd76SFam Zheng assert(job->pause_count > 0); 263751ebd76SFam Zheng job->pause_count--; 264751ebd76SFam Zheng if (job->pause_count) { 265751ebd76SFam Zheng return; 266751ebd76SFam Zheng } 267751ebd76SFam Zheng block_job_enter(job); 268751ebd76SFam Zheng } 269751ebd76SFam Zheng 270751ebd76SFam Zheng void block_job_enter(BlockJob *job) 271751ebd76SFam Zheng { 2722f0c9fe6SPaolo Bonzini if (job->co && !job->busy) { 2732f0c9fe6SPaolo Bonzini qemu_coroutine_enter(job->co, NULL); 2742f0c9fe6SPaolo Bonzini } 2752f0c9fe6SPaolo Bonzini } 2762f0c9fe6SPaolo Bonzini 2778acc72a4SPaolo Bonzini void block_job_cancel(BlockJob *job) 2788acc72a4SPaolo Bonzini { 2798acc72a4SPaolo Bonzini job->cancelled = true; 280*17bd51f9SStefan Hajnoczi block_job_iostatus_reset(job); 281751ebd76SFam Zheng block_job_enter(job); 2828acc72a4SPaolo Bonzini } 2838acc72a4SPaolo Bonzini 2842f0c9fe6SPaolo Bonzini bool block_job_is_cancelled(BlockJob *job) 2852f0c9fe6SPaolo Bonzini { 2862f0c9fe6SPaolo Bonzini return job->cancelled; 2872f0c9fe6SPaolo Bonzini } 2882f0c9fe6SPaolo Bonzini 28932c81a4aSPaolo Bonzini void block_job_iostatus_reset(BlockJob *job) 29032c81a4aSPaolo Bonzini { 29132c81a4aSPaolo Bonzini job->iostatus = BLOCK_DEVICE_IO_STATUS_OK; 2923fc4b10aSFam Zheng if (job->driver->iostatus_reset) { 2933fc4b10aSFam Zheng job->driver->iostatus_reset(job); 2943bd293c3SPaolo Bonzini } 29532c81a4aSPaolo Bonzini } 29632c81a4aSPaolo Bonzini 297345f9e1bSMax Reitz static int block_job_finish_sync(BlockJob *job, 298345f9e1bSMax Reitz void (*finish)(BlockJob *, Error **errp), 299345f9e1bSMax Reitz Error **errp) 3002f0c9fe6SPaolo Bonzini { 301345f9e1bSMax Reitz Error *local_err = NULL; 30294db6d2dSFam Zheng int ret; 3032f0c9fe6SPaolo Bonzini 304b6d2e599SKevin Wolf assert(blk_bs(job->blk)->job == job); 3052f0c9fe6SPaolo Bonzini 30694db6d2dSFam Zheng block_job_ref(job); 307345f9e1bSMax Reitz finish(job, &local_err); 308345f9e1bSMax Reitz if (local_err) { 309345f9e1bSMax Reitz error_propagate(errp, local_err); 31094db6d2dSFam Zheng block_job_unref(job); 311345f9e1bSMax Reitz return -EBUSY; 312345f9e1bSMax Reitz } 31394db6d2dSFam Zheng while (!job->completed) { 314794f0141SFam Zheng aio_poll(job->deferred_to_main_loop ? qemu_get_aio_context() : 315b6d2e599SKevin Wolf blk_get_aio_context(job->blk), 316794f0141SFam Zheng true); 3172f0c9fe6SPaolo Bonzini } 31894db6d2dSFam Zheng ret = (job->cancelled && job->ret == 0) ? -ECANCELED : job->ret; 31994db6d2dSFam Zheng block_job_unref(job); 32094db6d2dSFam Zheng return ret; 3212f0c9fe6SPaolo Bonzini } 3222f0c9fe6SPaolo Bonzini 323345f9e1bSMax Reitz /* A wrapper around block_job_cancel() taking an Error ** parameter so it may be 324345f9e1bSMax Reitz * used with block_job_finish_sync() without the need for (rather nasty) 325345f9e1bSMax Reitz * function pointer casts there. */ 326345f9e1bSMax Reitz static void block_job_cancel_err(BlockJob *job, Error **errp) 327345f9e1bSMax Reitz { 328345f9e1bSMax Reitz block_job_cancel(job); 329345f9e1bSMax Reitz } 330345f9e1bSMax Reitz 331345f9e1bSMax Reitz int block_job_cancel_sync(BlockJob *job) 332345f9e1bSMax Reitz { 333345f9e1bSMax Reitz return block_job_finish_sync(job, &block_job_cancel_err, NULL); 334345f9e1bSMax Reitz } 335345f9e1bSMax Reitz 336a1a2af07SKevin Wolf void block_job_cancel_sync_all(void) 337a1a2af07SKevin Wolf { 338a1a2af07SKevin Wolf BlockJob *job; 339a1a2af07SKevin Wolf AioContext *aio_context; 340a1a2af07SKevin Wolf 341a1a2af07SKevin Wolf while ((job = QLIST_FIRST(&block_jobs))) { 342b6d2e599SKevin Wolf aio_context = blk_get_aio_context(job->blk); 343a1a2af07SKevin Wolf aio_context_acquire(aio_context); 344a1a2af07SKevin Wolf block_job_cancel_sync(job); 345a1a2af07SKevin Wolf aio_context_release(aio_context); 346a1a2af07SKevin Wolf } 347a1a2af07SKevin Wolf } 348a1a2af07SKevin Wolf 349345f9e1bSMax Reitz int block_job_complete_sync(BlockJob *job, Error **errp) 350345f9e1bSMax Reitz { 351345f9e1bSMax Reitz return block_job_finish_sync(job, &block_job_complete, errp); 352345f9e1bSMax Reitz } 353345f9e1bSMax Reitz 3547483d1e5SAlex Bligh void block_job_sleep_ns(BlockJob *job, QEMUClockType type, int64_t ns) 3552f0c9fe6SPaolo Bonzini { 3568acc72a4SPaolo Bonzini assert(job->busy); 3578acc72a4SPaolo Bonzini 3582f0c9fe6SPaolo Bonzini /* Check cancellation *before* setting busy = false, too! */ 3598acc72a4SPaolo Bonzini if (block_job_is_cancelled(job)) { 3608acc72a4SPaolo Bonzini return; 3612f0c9fe6SPaolo Bonzini } 3628acc72a4SPaolo Bonzini 3638acc72a4SPaolo Bonzini job->busy = false; 3640824afdaSAlberto Garcia if (!block_job_is_paused(job)) { 3650824afdaSAlberto Garcia co_aio_sleep_ns(blk_get_aio_context(job->blk), type, ns); 3660824afdaSAlberto Garcia } 3670824afdaSAlberto Garcia /* The job can be paused while sleeping, so check this again */ 3688acc72a4SPaolo Bonzini if (block_job_is_paused(job)) { 3698acc72a4SPaolo Bonzini qemu_coroutine_yield(); 3708acc72a4SPaolo Bonzini } 3718acc72a4SPaolo Bonzini job->busy = true; 3722f0c9fe6SPaolo Bonzini } 37330e628b7SPaolo Bonzini 374dc71ce45SFam Zheng void block_job_yield(BlockJob *job) 375dc71ce45SFam Zheng { 376dc71ce45SFam Zheng assert(job->busy); 377dc71ce45SFam Zheng 378dc71ce45SFam Zheng /* Check cancellation *before* setting busy = false, too! */ 379dc71ce45SFam Zheng if (block_job_is_cancelled(job)) { 380dc71ce45SFam Zheng return; 381dc71ce45SFam Zheng } 382dc71ce45SFam Zheng 383dc71ce45SFam Zheng job->busy = false; 384dc71ce45SFam Zheng qemu_coroutine_yield(); 385dc71ce45SFam Zheng job->busy = true; 386dc71ce45SFam Zheng } 387dc71ce45SFam Zheng 38830e628b7SPaolo Bonzini BlockJobInfo *block_job_query(BlockJob *job) 38930e628b7SPaolo Bonzini { 39030e628b7SPaolo Bonzini BlockJobInfo *info = g_new0(BlockJobInfo, 1); 39179e14bf7SFam Zheng info->type = g_strdup(BlockJobType_lookup[job->driver->job_type]); 3928ccb9569SKevin Wolf info->device = g_strdup(job->id); 39330e628b7SPaolo Bonzini info->len = job->len; 3948d65883fSPaolo Bonzini info->busy = job->busy; 395751ebd76SFam Zheng info->paused = job->pause_count > 0; 39630e628b7SPaolo Bonzini info->offset = job->offset; 39730e628b7SPaolo Bonzini info->speed = job->speed; 39832c81a4aSPaolo Bonzini info->io_status = job->iostatus; 399ef6dbf1eSMax Reitz info->ready = job->ready; 40030e628b7SPaolo Bonzini return info; 40130e628b7SPaolo Bonzini } 40232c81a4aSPaolo Bonzini 40332c81a4aSPaolo Bonzini static void block_job_iostatus_set_err(BlockJob *job, int error) 40432c81a4aSPaolo Bonzini { 40532c81a4aSPaolo Bonzini if (job->iostatus == BLOCK_DEVICE_IO_STATUS_OK) { 40632c81a4aSPaolo Bonzini job->iostatus = error == ENOSPC ? BLOCK_DEVICE_IO_STATUS_NOSPACE : 40732c81a4aSPaolo Bonzini BLOCK_DEVICE_IO_STATUS_FAILED; 40832c81a4aSPaolo Bonzini } 40932c81a4aSPaolo Bonzini } 41032c81a4aSPaolo Bonzini 411bcada37bSWenchao Xia void block_job_event_cancelled(BlockJob *job) 412a66a2a36SPaolo Bonzini { 413bcada37bSWenchao Xia qapi_event_send_block_job_cancelled(job->driver->job_type, 4148ccb9569SKevin Wolf job->id, 415a66a2a36SPaolo Bonzini job->len, 416a66a2a36SPaolo Bonzini job->offset, 417bcada37bSWenchao Xia job->speed, 418bcada37bSWenchao Xia &error_abort); 419a66a2a36SPaolo Bonzini } 420a66a2a36SPaolo Bonzini 421bcada37bSWenchao Xia void block_job_event_completed(BlockJob *job, const char *msg) 422a66a2a36SPaolo Bonzini { 423bcada37bSWenchao Xia qapi_event_send_block_job_completed(job->driver->job_type, 4248ccb9569SKevin Wolf job->id, 425bcada37bSWenchao Xia job->len, 426bcada37bSWenchao Xia job->offset, 427bcada37bSWenchao Xia job->speed, 428bcada37bSWenchao Xia !!msg, 429bcada37bSWenchao Xia msg, 430bcada37bSWenchao Xia &error_abort); 431bcada37bSWenchao Xia } 432bcada37bSWenchao Xia 433bcada37bSWenchao Xia void block_job_event_ready(BlockJob *job) 434bcada37bSWenchao Xia { 435ef6dbf1eSMax Reitz job->ready = true; 436ef6dbf1eSMax Reitz 437518848a2SMarkus Armbruster qapi_event_send_block_job_ready(job->driver->job_type, 4388ccb9569SKevin Wolf job->id, 439518848a2SMarkus Armbruster job->len, 440518848a2SMarkus Armbruster job->offset, 441518848a2SMarkus Armbruster job->speed, &error_abort); 442a66a2a36SPaolo Bonzini } 443a66a2a36SPaolo Bonzini 44481e254dcSKevin Wolf BlockErrorAction block_job_error_action(BlockJob *job, BlockdevOnError on_err, 44532c81a4aSPaolo Bonzini int is_read, int error) 44632c81a4aSPaolo Bonzini { 44732c81a4aSPaolo Bonzini BlockErrorAction action; 44832c81a4aSPaolo Bonzini 44932c81a4aSPaolo Bonzini switch (on_err) { 45032c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_ENOSPC: 451a589569fSWenchao Xia action = (error == ENOSPC) ? 452a589569fSWenchao Xia BLOCK_ERROR_ACTION_STOP : BLOCK_ERROR_ACTION_REPORT; 45332c81a4aSPaolo Bonzini break; 45432c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_STOP: 455a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_STOP; 45632c81a4aSPaolo Bonzini break; 45732c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_REPORT: 458a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_REPORT; 45932c81a4aSPaolo Bonzini break; 46032c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_IGNORE: 461a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_IGNORE; 46232c81a4aSPaolo Bonzini break; 46332c81a4aSPaolo Bonzini default: 46432c81a4aSPaolo Bonzini abort(); 46532c81a4aSPaolo Bonzini } 4668ccb9569SKevin Wolf qapi_event_send_block_job_error(job->id, 4675a2d2cbdSWenchao Xia is_read ? IO_OPERATION_TYPE_READ : 4685a2d2cbdSWenchao Xia IO_OPERATION_TYPE_WRITE, 4695a2d2cbdSWenchao Xia action, &error_abort); 470a589569fSWenchao Xia if (action == BLOCK_ERROR_ACTION_STOP) { 471751ebd76SFam Zheng /* make the pause user visible, which will be resumed from QMP. */ 472751ebd76SFam Zheng job->user_paused = true; 47332c81a4aSPaolo Bonzini block_job_pause(job); 47432c81a4aSPaolo Bonzini block_job_iostatus_set_err(job, error); 47532c81a4aSPaolo Bonzini } 47632c81a4aSPaolo Bonzini return action; 47732c81a4aSPaolo Bonzini } 478dec7d421SStefan Hajnoczi 479dec7d421SStefan Hajnoczi typedef struct { 480dec7d421SStefan Hajnoczi BlockJob *job; 481dec7d421SStefan Hajnoczi QEMUBH *bh; 482dec7d421SStefan Hajnoczi AioContext *aio_context; 483dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopFn *fn; 484dec7d421SStefan Hajnoczi void *opaque; 485dec7d421SStefan Hajnoczi } BlockJobDeferToMainLoopData; 486dec7d421SStefan Hajnoczi 487dec7d421SStefan Hajnoczi static void block_job_defer_to_main_loop_bh(void *opaque) 488dec7d421SStefan Hajnoczi { 489dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopData *data = opaque; 490dec7d421SStefan Hajnoczi AioContext *aio_context; 491dec7d421SStefan Hajnoczi 492dec7d421SStefan Hajnoczi qemu_bh_delete(data->bh); 493dec7d421SStefan Hajnoczi 494dec7d421SStefan Hajnoczi /* Prevent race with block_job_defer_to_main_loop() */ 495dec7d421SStefan Hajnoczi aio_context_acquire(data->aio_context); 496dec7d421SStefan Hajnoczi 497dec7d421SStefan Hajnoczi /* Fetch BDS AioContext again, in case it has changed */ 498b6d2e599SKevin Wolf aio_context = blk_get_aio_context(data->job->blk); 499dec7d421SStefan Hajnoczi aio_context_acquire(aio_context); 500dec7d421SStefan Hajnoczi 501794f0141SFam Zheng data->job->deferred_to_main_loop = false; 502dec7d421SStefan Hajnoczi data->fn(data->job, data->opaque); 503dec7d421SStefan Hajnoczi 504dec7d421SStefan Hajnoczi aio_context_release(aio_context); 505dec7d421SStefan Hajnoczi 506dec7d421SStefan Hajnoczi aio_context_release(data->aio_context); 507dec7d421SStefan Hajnoczi 508dec7d421SStefan Hajnoczi g_free(data); 509dec7d421SStefan Hajnoczi } 510dec7d421SStefan Hajnoczi 511dec7d421SStefan Hajnoczi void block_job_defer_to_main_loop(BlockJob *job, 512dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopFn *fn, 513dec7d421SStefan Hajnoczi void *opaque) 514dec7d421SStefan Hajnoczi { 515dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopData *data = g_malloc(sizeof(*data)); 516dec7d421SStefan Hajnoczi data->job = job; 517dec7d421SStefan Hajnoczi data->bh = qemu_bh_new(block_job_defer_to_main_loop_bh, data); 518b6d2e599SKevin Wolf data->aio_context = blk_get_aio_context(job->blk); 519dec7d421SStefan Hajnoczi data->fn = fn; 520dec7d421SStefan Hajnoczi data->opaque = opaque; 521794f0141SFam Zheng job->deferred_to_main_loop = true; 522dec7d421SStefan Hajnoczi 523dec7d421SStefan Hajnoczi qemu_bh_schedule(data->bh); 524dec7d421SStefan Hajnoczi } 525c55a832fSFam Zheng 526c55a832fSFam Zheng BlockJobTxn *block_job_txn_new(void) 527c55a832fSFam Zheng { 528c55a832fSFam Zheng BlockJobTxn *txn = g_new0(BlockJobTxn, 1); 529c55a832fSFam Zheng QLIST_INIT(&txn->jobs); 530c55a832fSFam Zheng txn->refcnt = 1; 531c55a832fSFam Zheng return txn; 532c55a832fSFam Zheng } 533c55a832fSFam Zheng 534c55a832fSFam Zheng static void block_job_txn_ref(BlockJobTxn *txn) 535c55a832fSFam Zheng { 536c55a832fSFam Zheng txn->refcnt++; 537c55a832fSFam Zheng } 538c55a832fSFam Zheng 539c55a832fSFam Zheng void block_job_txn_unref(BlockJobTxn *txn) 540c55a832fSFam Zheng { 541c55a832fSFam Zheng if (txn && --txn->refcnt == 0) { 542c55a832fSFam Zheng g_free(txn); 543c55a832fSFam Zheng } 544c55a832fSFam Zheng } 545c55a832fSFam Zheng 546c55a832fSFam Zheng void block_job_txn_add_job(BlockJobTxn *txn, BlockJob *job) 547c55a832fSFam Zheng { 548c55a832fSFam Zheng if (!txn) { 549c55a832fSFam Zheng return; 550c55a832fSFam Zheng } 551c55a832fSFam Zheng 552c55a832fSFam Zheng assert(!job->txn); 553c55a832fSFam Zheng job->txn = txn; 554c55a832fSFam Zheng 555c55a832fSFam Zheng QLIST_INSERT_HEAD(&txn->jobs, job, txn_list); 556c55a832fSFam Zheng block_job_txn_ref(txn); 557c55a832fSFam Zheng } 558