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" 28737e150eSPaolo Bonzini #include "block/block.h" 29c87621eaSJohn Snow #include "block/blockjob_int.h" 30737e150eSPaolo Bonzini #include "block/block_int.h" 31373340b2SMax Reitz #include "sysemu/block-backend.h" 32cc7a8ea7SMarkus Armbruster #include "qapi/qmp/qerror.h" 337b1b5d19SPaolo Bonzini #include "qapi/qmp/qjson.h" 3410817bf0SDaniel P. Berrange #include "qemu/coroutine.h" 357f0317cfSAlberto Garcia #include "qemu/id.h" 362f0c9fe6SPaolo Bonzini #include "qmp-commands.h" 371de7afc9SPaolo Bonzini #include "qemu/timer.h" 385a2d2cbdSWenchao Xia #include "qapi-event.h" 392f0c9fe6SPaolo Bonzini 408254b6d9SJohn Snow static void block_job_event_cancelled(BlockJob *job); 418254b6d9SJohn Snow static void block_job_event_completed(BlockJob *job, const char *msg); 428254b6d9SJohn Snow 43c55a832fSFam Zheng /* Transactional group of block jobs */ 44c55a832fSFam Zheng struct BlockJobTxn { 45c55a832fSFam Zheng 46c55a832fSFam Zheng /* Is this txn being cancelled? */ 47c55a832fSFam Zheng bool aborting; 48c55a832fSFam Zheng 49c55a832fSFam Zheng /* List of jobs */ 50c55a832fSFam Zheng QLIST_HEAD(, BlockJob) jobs; 51c55a832fSFam Zheng 52c55a832fSFam Zheng /* Reference count */ 53c55a832fSFam Zheng int refcnt; 54c55a832fSFam Zheng }; 55c55a832fSFam Zheng 56a7112795SAlberto Garcia static QLIST_HEAD(, BlockJob) block_jobs = QLIST_HEAD_INITIALIZER(block_jobs); 57a7112795SAlberto Garcia 58a7112795SAlberto Garcia BlockJob *block_job_next(BlockJob *job) 59a7112795SAlberto Garcia { 60a7112795SAlberto Garcia if (!job) { 61a7112795SAlberto Garcia return QLIST_FIRST(&block_jobs); 62a7112795SAlberto Garcia } 63a7112795SAlberto Garcia return QLIST_NEXT(job, job_list); 64a7112795SAlberto Garcia } 65a7112795SAlberto Garcia 66ffb1f10cSAlberto Garcia BlockJob *block_job_get(const char *id) 67ffb1f10cSAlberto Garcia { 68ffb1f10cSAlberto Garcia BlockJob *job; 69ffb1f10cSAlberto Garcia 70ffb1f10cSAlberto Garcia QLIST_FOREACH(job, &block_jobs, job_list) { 71559b935fSJohn Snow if (job->id && !strcmp(id, job->id)) { 72ffb1f10cSAlberto Garcia return job; 73ffb1f10cSAlberto Garcia } 74ffb1f10cSAlberto Garcia } 75ffb1f10cSAlberto Garcia 76ffb1f10cSAlberto Garcia return NULL; 77ffb1f10cSAlberto Garcia } 78ffb1f10cSAlberto Garcia 79*f321dcb5SPaolo Bonzini static void block_job_pause(BlockJob *job) 80*f321dcb5SPaolo Bonzini { 81*f321dcb5SPaolo Bonzini job->pause_count++; 82*f321dcb5SPaolo Bonzini } 83*f321dcb5SPaolo Bonzini 84*f321dcb5SPaolo Bonzini static void block_job_resume(BlockJob *job) 85*f321dcb5SPaolo Bonzini { 86*f321dcb5SPaolo Bonzini assert(job->pause_count > 0); 87*f321dcb5SPaolo Bonzini job->pause_count--; 88*f321dcb5SPaolo Bonzini if (job->pause_count) { 89*f321dcb5SPaolo Bonzini return; 90*f321dcb5SPaolo Bonzini } 91*f321dcb5SPaolo Bonzini block_job_enter(job); 92*f321dcb5SPaolo Bonzini } 93*f321dcb5SPaolo Bonzini 9405b0d8e3SPaolo Bonzini static void block_job_ref(BlockJob *job) 9505b0d8e3SPaolo Bonzini { 9605b0d8e3SPaolo Bonzini ++job->refcnt; 9705b0d8e3SPaolo Bonzini } 9805b0d8e3SPaolo Bonzini 9905b0d8e3SPaolo Bonzini static void block_job_attached_aio_context(AioContext *new_context, 10005b0d8e3SPaolo Bonzini void *opaque); 10105b0d8e3SPaolo Bonzini static void block_job_detach_aio_context(void *opaque); 10205b0d8e3SPaolo Bonzini 10305b0d8e3SPaolo Bonzini static void block_job_unref(BlockJob *job) 10405b0d8e3SPaolo Bonzini { 10505b0d8e3SPaolo Bonzini if (--job->refcnt == 0) { 10605b0d8e3SPaolo Bonzini BlockDriverState *bs = blk_bs(job->blk); 10705b0d8e3SPaolo Bonzini bs->job = NULL; 10805b0d8e3SPaolo Bonzini block_job_remove_all_bdrv(job); 10905b0d8e3SPaolo Bonzini blk_remove_aio_context_notifier(job->blk, 11005b0d8e3SPaolo Bonzini block_job_attached_aio_context, 11105b0d8e3SPaolo Bonzini block_job_detach_aio_context, job); 11205b0d8e3SPaolo Bonzini blk_unref(job->blk); 11305b0d8e3SPaolo Bonzini error_free(job->blocker); 11405b0d8e3SPaolo Bonzini g_free(job->id); 11505b0d8e3SPaolo Bonzini QLIST_REMOVE(job, job_list); 11605b0d8e3SPaolo Bonzini g_free(job); 11705b0d8e3SPaolo Bonzini } 11805b0d8e3SPaolo Bonzini } 11905b0d8e3SPaolo Bonzini 120463e0be1SStefan Hajnoczi static void block_job_attached_aio_context(AioContext *new_context, 121463e0be1SStefan Hajnoczi void *opaque) 122463e0be1SStefan Hajnoczi { 123463e0be1SStefan Hajnoczi BlockJob *job = opaque; 124463e0be1SStefan Hajnoczi 125463e0be1SStefan Hajnoczi if (job->driver->attached_aio_context) { 126463e0be1SStefan Hajnoczi job->driver->attached_aio_context(job, new_context); 127463e0be1SStefan Hajnoczi } 128463e0be1SStefan Hajnoczi 129463e0be1SStefan Hajnoczi block_job_resume(job); 130463e0be1SStefan Hajnoczi } 131463e0be1SStefan Hajnoczi 132bae8196dSPaolo Bonzini static void block_job_drain(BlockJob *job) 133bae8196dSPaolo Bonzini { 134bae8196dSPaolo Bonzini /* If job is !job->busy this kicks it into the next pause point. */ 135bae8196dSPaolo Bonzini block_job_enter(job); 136bae8196dSPaolo Bonzini 137bae8196dSPaolo Bonzini blk_drain(job->blk); 138bae8196dSPaolo Bonzini if (job->driver->drain) { 139bae8196dSPaolo Bonzini job->driver->drain(job); 140bae8196dSPaolo Bonzini } 141bae8196dSPaolo Bonzini } 142bae8196dSPaolo Bonzini 143463e0be1SStefan Hajnoczi static void block_job_detach_aio_context(void *opaque) 144463e0be1SStefan Hajnoczi { 145463e0be1SStefan Hajnoczi BlockJob *job = opaque; 146463e0be1SStefan Hajnoczi 147463e0be1SStefan Hajnoczi /* In case the job terminates during aio_poll()... */ 148463e0be1SStefan Hajnoczi block_job_ref(job); 149463e0be1SStefan Hajnoczi 150463e0be1SStefan Hajnoczi block_job_pause(job); 151463e0be1SStefan Hajnoczi 152463e0be1SStefan Hajnoczi while (!job->paused && !job->completed) { 153bae8196dSPaolo Bonzini block_job_drain(job); 154463e0be1SStefan Hajnoczi } 155463e0be1SStefan Hajnoczi 156463e0be1SStefan Hajnoczi block_job_unref(job); 157463e0be1SStefan Hajnoczi } 158463e0be1SStefan Hajnoczi 159*f321dcb5SPaolo Bonzini static char *child_job_get_parent_desc(BdrvChild *c) 160*f321dcb5SPaolo Bonzini { 161*f321dcb5SPaolo Bonzini BlockJob *job = c->opaque; 162*f321dcb5SPaolo Bonzini return g_strdup_printf("%s job '%s'", 163*f321dcb5SPaolo Bonzini BlockJobType_lookup[job->driver->job_type], 164*f321dcb5SPaolo Bonzini job->id); 165*f321dcb5SPaolo Bonzini } 166*f321dcb5SPaolo Bonzini 167*f321dcb5SPaolo Bonzini static const BdrvChildRole child_job = { 168*f321dcb5SPaolo Bonzini .get_parent_desc = child_job_get_parent_desc, 169*f321dcb5SPaolo Bonzini .stay_at_node = true, 170*f321dcb5SPaolo Bonzini }; 171*f321dcb5SPaolo Bonzini 172*f321dcb5SPaolo Bonzini static void block_job_drained_begin(void *opaque) 173*f321dcb5SPaolo Bonzini { 174*f321dcb5SPaolo Bonzini BlockJob *job = opaque; 175*f321dcb5SPaolo Bonzini block_job_pause(job); 176*f321dcb5SPaolo Bonzini } 177*f321dcb5SPaolo Bonzini 178*f321dcb5SPaolo Bonzini static void block_job_drained_end(void *opaque) 179*f321dcb5SPaolo Bonzini { 180*f321dcb5SPaolo Bonzini BlockJob *job = opaque; 181*f321dcb5SPaolo Bonzini block_job_resume(job); 182*f321dcb5SPaolo Bonzini } 183*f321dcb5SPaolo Bonzini 184*f321dcb5SPaolo Bonzini static const BlockDevOps block_job_dev_ops = { 185*f321dcb5SPaolo Bonzini .drained_begin = block_job_drained_begin, 186*f321dcb5SPaolo Bonzini .drained_end = block_job_drained_end, 187*f321dcb5SPaolo Bonzini }; 188*f321dcb5SPaolo Bonzini 189bbc02b90SKevin Wolf void block_job_remove_all_bdrv(BlockJob *job) 190bbc02b90SKevin Wolf { 191bbc02b90SKevin Wolf GSList *l; 192bbc02b90SKevin Wolf for (l = job->nodes; l; l = l->next) { 193bbc02b90SKevin Wolf BdrvChild *c = l->data; 194bbc02b90SKevin Wolf bdrv_op_unblock_all(c->bs, job->blocker); 195bbc02b90SKevin Wolf bdrv_root_unref_child(c); 196bbc02b90SKevin Wolf } 197bbc02b90SKevin Wolf g_slist_free(job->nodes); 198bbc02b90SKevin Wolf job->nodes = NULL; 199bbc02b90SKevin Wolf } 200bbc02b90SKevin Wolf 20176d554e2SKevin Wolf int block_job_add_bdrv(BlockJob *job, const char *name, BlockDriverState *bs, 20276d554e2SKevin Wolf uint64_t perm, uint64_t shared_perm, Error **errp) 20323d402d4SAlberto Garcia { 20476d554e2SKevin Wolf BdrvChild *c; 20576d554e2SKevin Wolf 20676d554e2SKevin Wolf c = bdrv_root_attach_child(bs, name, &child_job, perm, shared_perm, 20776d554e2SKevin Wolf job, errp); 20876d554e2SKevin Wolf if (c == NULL) { 20976d554e2SKevin Wolf return -EPERM; 21076d554e2SKevin Wolf } 21176d554e2SKevin Wolf 21276d554e2SKevin Wolf job->nodes = g_slist_prepend(job->nodes, c); 21323d402d4SAlberto Garcia bdrv_ref(bs); 21423d402d4SAlberto Garcia bdrv_op_block_all(bs, job->blocker); 21576d554e2SKevin Wolf 21676d554e2SKevin Wolf return 0; 21723d402d4SAlberto Garcia } 21823d402d4SAlberto Garcia 2197f0317cfSAlberto Garcia void *block_job_create(const char *job_id, const BlockJobDriver *driver, 220c6cc12bfSKevin Wolf BlockDriverState *bs, uint64_t perm, 221c6cc12bfSKevin Wolf uint64_t shared_perm, int64_t speed, int flags, 2227f0317cfSAlberto Garcia BlockCompletionFunc *cb, void *opaque, Error **errp) 2232f0c9fe6SPaolo Bonzini { 224b6d2e599SKevin Wolf BlockBackend *blk; 2252f0c9fe6SPaolo Bonzini BlockJob *job; 226d7086422SKevin Wolf int ret; 2272f0c9fe6SPaolo Bonzini 228628ff683SFam Zheng if (bs->job) { 229c6bd8c70SMarkus Armbruster error_setg(errp, QERR_DEVICE_IN_USE, bdrv_get_device_name(bs)); 2302f0c9fe6SPaolo Bonzini return NULL; 2312f0c9fe6SPaolo Bonzini } 232b6d2e599SKevin Wolf 233f81e0b45SJohn Snow if (job_id == NULL && !(flags & BLOCK_JOB_INTERNAL)) { 2347f0317cfSAlberto Garcia job_id = bdrv_get_device_name(bs); 2351562047cSKevin Wolf if (!*job_id) { 2361562047cSKevin Wolf error_setg(errp, "An explicit job ID is required for this node"); 2371562047cSKevin Wolf return NULL; 2381562047cSKevin Wolf } 2397f0317cfSAlberto Garcia } 2407f0317cfSAlberto Garcia 241f81e0b45SJohn Snow if (job_id) { 242f81e0b45SJohn Snow if (flags & BLOCK_JOB_INTERNAL) { 243f81e0b45SJohn Snow error_setg(errp, "Cannot specify job ID for internal block job"); 244f81e0b45SJohn Snow return NULL; 245f81e0b45SJohn Snow } 246f81e0b45SJohn Snow 2477f0317cfSAlberto Garcia if (!id_wellformed(job_id)) { 2487f0317cfSAlberto Garcia error_setg(errp, "Invalid job ID '%s'", job_id); 2497f0317cfSAlberto Garcia return NULL; 2507f0317cfSAlberto Garcia } 2517f0317cfSAlberto Garcia 2527f0317cfSAlberto Garcia if (block_job_get(job_id)) { 2537f0317cfSAlberto Garcia error_setg(errp, "Job ID '%s' already in use", job_id); 2547f0317cfSAlberto Garcia return NULL; 2557f0317cfSAlberto Garcia } 256f81e0b45SJohn Snow } 2577f0317cfSAlberto Garcia 258c6cc12bfSKevin Wolf blk = blk_new(perm, shared_perm); 259d7086422SKevin Wolf ret = blk_insert_bs(blk, bs, errp); 260d7086422SKevin Wolf if (ret < 0) { 261d7086422SKevin Wolf blk_unref(blk); 262d7086422SKevin Wolf return NULL; 263d7086422SKevin Wolf } 264b6d2e599SKevin Wolf 2653fc4b10aSFam Zheng job = g_malloc0(driver->instance_size); 2663fc4b10aSFam Zheng job->driver = driver; 2677f0317cfSAlberto Garcia job->id = g_strdup(job_id); 268b6d2e599SKevin Wolf job->blk = blk; 2692f0c9fe6SPaolo Bonzini job->cb = cb; 2702f0c9fe6SPaolo Bonzini job->opaque = opaque; 2715ccac6f1SJohn Snow job->busy = false; 2725ccac6f1SJohn Snow job->paused = true; 2735ccac6f1SJohn Snow job->pause_count = 1; 27418930ba3SFam Zheng job->refcnt = 1; 275600ac6a0SJohn Snow 276600ac6a0SJohn Snow error_setg(&job->blocker, "block device is in use by block job: %s", 277600ac6a0SJohn Snow BlockJobType_lookup[driver->job_type]); 278600ac6a0SJohn Snow block_job_add_bdrv(job, "main node", bs, 0, BLK_PERM_ALL, &error_abort); 2792f0c9fe6SPaolo Bonzini bs->job = job; 2802f0c9fe6SPaolo Bonzini 281600ac6a0SJohn Snow blk_set_dev_ops(blk, &block_job_dev_ops, job); 282600ac6a0SJohn Snow bdrv_op_unblock(bs, BLOCK_OP_TYPE_DATAPLANE, job->blocker); 283600ac6a0SJohn Snow 284a7112795SAlberto Garcia QLIST_INSERT_HEAD(&block_jobs, job, job_list); 285a7112795SAlberto Garcia 286463e0be1SStefan Hajnoczi blk_add_aio_context_notifier(blk, block_job_attached_aio_context, 287463e0be1SStefan Hajnoczi block_job_detach_aio_context, job); 288463e0be1SStefan Hajnoczi 2892f0c9fe6SPaolo Bonzini /* Only set speed when necessary to avoid NotSupported error */ 2902f0c9fe6SPaolo Bonzini if (speed != 0) { 2912f0c9fe6SPaolo Bonzini Error *local_err = NULL; 2922f0c9fe6SPaolo Bonzini 2932f0c9fe6SPaolo Bonzini block_job_set_speed(job, speed, &local_err); 29484d18f06SMarkus Armbruster if (local_err) { 29518930ba3SFam Zheng block_job_unref(job); 2962f0c9fe6SPaolo Bonzini error_propagate(errp, local_err); 2972f0c9fe6SPaolo Bonzini return NULL; 2982f0c9fe6SPaolo Bonzini } 2992f0c9fe6SPaolo Bonzini } 3002f0c9fe6SPaolo Bonzini return job; 3012f0c9fe6SPaolo Bonzini } 3022f0c9fe6SPaolo Bonzini 303559b935fSJohn Snow bool block_job_is_internal(BlockJob *job) 304559b935fSJohn Snow { 305559b935fSJohn Snow return (job->id == NULL); 306559b935fSJohn Snow } 307559b935fSJohn Snow 3085ccac6f1SJohn Snow static bool block_job_started(BlockJob *job) 3095ccac6f1SJohn Snow { 3105ccac6f1SJohn Snow return job->co; 3115ccac6f1SJohn Snow } 3125ccac6f1SJohn Snow 313e3796a24SJohn Snow /** 314e3796a24SJohn Snow * All jobs must allow a pause point before entering their job proper. This 315e3796a24SJohn Snow * ensures that jobs can be paused prior to being started, then resumed later. 316e3796a24SJohn Snow */ 317e3796a24SJohn Snow static void coroutine_fn block_job_co_entry(void *opaque) 318e3796a24SJohn Snow { 319e3796a24SJohn Snow BlockJob *job = opaque; 320e3796a24SJohn Snow 321e3796a24SJohn Snow assert(job && job->driver && job->driver->start); 322e3796a24SJohn Snow block_job_pause_point(job); 323e3796a24SJohn Snow job->driver->start(job); 324e3796a24SJohn Snow } 325e3796a24SJohn Snow 3265ccac6f1SJohn Snow void block_job_start(BlockJob *job) 3275ccac6f1SJohn Snow { 3285ccac6f1SJohn Snow assert(job && !block_job_started(job) && job->paused && 329e3796a24SJohn Snow job->driver && job->driver->start); 330e3796a24SJohn Snow job->co = qemu_coroutine_create(block_job_co_entry, job); 331e3796a24SJohn Snow job->pause_count--; 3325ccac6f1SJohn Snow job->busy = true; 333e3796a24SJohn Snow job->paused = false; 334aef4278cSFam Zheng bdrv_coroutine_enter(blk_bs(job->blk), job->co); 3355ccac6f1SJohn Snow } 3365ccac6f1SJohn Snow 33705b0d8e3SPaolo Bonzini void block_job_early_fail(BlockJob *job) 33897031164STing Wang { 33905b0d8e3SPaolo Bonzini block_job_unref(job); 34018930ba3SFam Zheng } 34197031164STing Wang 342c55a832fSFam Zheng static void block_job_completed_single(BlockJob *job) 343c55a832fSFam Zheng { 344c55a832fSFam Zheng if (!job->ret) { 345c55a832fSFam Zheng if (job->driver->commit) { 346c55a832fSFam Zheng job->driver->commit(job); 347c55a832fSFam Zheng } 348c55a832fSFam Zheng } else { 349c55a832fSFam Zheng if (job->driver->abort) { 350c55a832fSFam Zheng job->driver->abort(job); 351c55a832fSFam Zheng } 352c55a832fSFam Zheng } 353e8a40bf7SJohn Snow if (job->driver->clean) { 354e8a40bf7SJohn Snow job->driver->clean(job); 355e8a40bf7SJohn Snow } 3568254b6d9SJohn Snow 3578254b6d9SJohn Snow if (job->cb) { 358c55a832fSFam Zheng job->cb(job->opaque, job->ret); 3598254b6d9SJohn Snow } 3605ccac6f1SJohn Snow 3615ccac6f1SJohn Snow /* Emit events only if we actually started */ 3625ccac6f1SJohn Snow if (block_job_started(job)) { 3638254b6d9SJohn Snow if (block_job_is_cancelled(job)) { 3648254b6d9SJohn Snow block_job_event_cancelled(job); 3658254b6d9SJohn Snow } else { 3668254b6d9SJohn Snow const char *msg = NULL; 3678254b6d9SJohn Snow if (job->ret < 0) { 3688254b6d9SJohn Snow msg = strerror(-job->ret); 3698254b6d9SJohn Snow } 3708254b6d9SJohn Snow block_job_event_completed(job, msg); 3718254b6d9SJohn Snow } 3725ccac6f1SJohn Snow } 3738254b6d9SJohn Snow 374c55a832fSFam Zheng if (job->txn) { 3751e93b9fbSVladimir Sementsov-Ogievskiy QLIST_REMOVE(job, txn_list); 376c55a832fSFam Zheng block_job_txn_unref(job->txn); 377c55a832fSFam Zheng } 378c55a832fSFam Zheng block_job_unref(job); 379c55a832fSFam Zheng } 380c55a832fSFam Zheng 381c55a832fSFam Zheng static void block_job_completed_txn_abort(BlockJob *job) 382c55a832fSFam Zheng { 383c55a832fSFam Zheng AioContext *ctx; 384c55a832fSFam Zheng BlockJobTxn *txn = job->txn; 385c55a832fSFam Zheng BlockJob *other_job, *next; 386c55a832fSFam Zheng 387c55a832fSFam Zheng if (txn->aborting) { 388c55a832fSFam Zheng /* 389c55a832fSFam Zheng * We are cancelled by another job, which will handle everything. 390c55a832fSFam Zheng */ 391c55a832fSFam Zheng return; 392c55a832fSFam Zheng } 393c55a832fSFam Zheng txn->aborting = true; 394c55a832fSFam Zheng /* We are the first failed job. Cancel other jobs. */ 395c55a832fSFam Zheng QLIST_FOREACH(other_job, &txn->jobs, txn_list) { 396b6d2e599SKevin Wolf ctx = blk_get_aio_context(other_job->blk); 397c55a832fSFam Zheng aio_context_acquire(ctx); 398c55a832fSFam Zheng } 399c55a832fSFam Zheng QLIST_FOREACH(other_job, &txn->jobs, txn_list) { 400c55a832fSFam Zheng if (other_job == job || other_job->completed) { 401c55a832fSFam Zheng /* Other jobs are "effectively" cancelled by us, set the status for 402c55a832fSFam Zheng * them; this job, however, may or may not be cancelled, depending 403c55a832fSFam Zheng * on the caller, so leave it. */ 404c55a832fSFam Zheng if (other_job != job) { 405c55a832fSFam Zheng other_job->cancelled = true; 406c55a832fSFam Zheng } 407c55a832fSFam Zheng continue; 408c55a832fSFam Zheng } 409c55a832fSFam Zheng block_job_cancel_sync(other_job); 410c55a832fSFam Zheng assert(other_job->completed); 411c55a832fSFam Zheng } 412c55a832fSFam Zheng QLIST_FOREACH_SAFE(other_job, &txn->jobs, txn_list, next) { 413b6d2e599SKevin Wolf ctx = blk_get_aio_context(other_job->blk); 414c55a832fSFam Zheng block_job_completed_single(other_job); 415c55a832fSFam Zheng aio_context_release(ctx); 416c55a832fSFam Zheng } 417c55a832fSFam Zheng } 418c55a832fSFam Zheng 419c55a832fSFam Zheng static void block_job_completed_txn_success(BlockJob *job) 420c55a832fSFam Zheng { 421c55a832fSFam Zheng AioContext *ctx; 422c55a832fSFam Zheng BlockJobTxn *txn = job->txn; 423c55a832fSFam Zheng BlockJob *other_job, *next; 424c55a832fSFam Zheng /* 425c55a832fSFam Zheng * Successful completion, see if there are other running jobs in this 426c55a832fSFam Zheng * txn. 427c55a832fSFam Zheng */ 428c55a832fSFam Zheng QLIST_FOREACH(other_job, &txn->jobs, txn_list) { 429c55a832fSFam Zheng if (!other_job->completed) { 430c55a832fSFam Zheng return; 431c55a832fSFam Zheng } 432c55a832fSFam Zheng } 433c55a832fSFam Zheng /* We are the last completed job, commit the transaction. */ 434c55a832fSFam Zheng QLIST_FOREACH_SAFE(other_job, &txn->jobs, txn_list, next) { 435b6d2e599SKevin Wolf ctx = blk_get_aio_context(other_job->blk); 436c55a832fSFam Zheng aio_context_acquire(ctx); 437c55a832fSFam Zheng assert(other_job->ret == 0); 438c55a832fSFam Zheng block_job_completed_single(other_job); 439c55a832fSFam Zheng aio_context_release(ctx); 440c55a832fSFam Zheng } 441c55a832fSFam Zheng } 442c55a832fSFam Zheng 44365f46322SPaolo Bonzini void block_job_completed(BlockJob *job, int ret) 4442f0c9fe6SPaolo Bonzini { 445b6d2e599SKevin Wolf assert(blk_bs(job->blk)->job == job); 446a689dbf2SFam Zheng assert(!job->completed); 447a689dbf2SFam Zheng job->completed = true; 448a689dbf2SFam Zheng job->ret = ret; 449c55a832fSFam Zheng if (!job->txn) { 450c55a832fSFam Zheng block_job_completed_single(job); 451c55a832fSFam Zheng } else if (ret < 0 || block_job_is_cancelled(job)) { 452c55a832fSFam Zheng block_job_completed_txn_abort(job); 453c55a832fSFam Zheng } else { 454c55a832fSFam Zheng block_job_completed_txn_success(job); 455c55a832fSFam Zheng } 4562f0c9fe6SPaolo Bonzini } 4572f0c9fe6SPaolo Bonzini 4582f0c9fe6SPaolo Bonzini void block_job_set_speed(BlockJob *job, int64_t speed, Error **errp) 4592f0c9fe6SPaolo Bonzini { 4602f0c9fe6SPaolo Bonzini Error *local_err = NULL; 4612f0c9fe6SPaolo Bonzini 4623fc4b10aSFam Zheng if (!job->driver->set_speed) { 463c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 4642f0c9fe6SPaolo Bonzini return; 4652f0c9fe6SPaolo Bonzini } 4663fc4b10aSFam Zheng job->driver->set_speed(job, speed, &local_err); 46784d18f06SMarkus Armbruster if (local_err) { 4682f0c9fe6SPaolo Bonzini error_propagate(errp, local_err); 4692f0c9fe6SPaolo Bonzini return; 4702f0c9fe6SPaolo Bonzini } 4712f0c9fe6SPaolo Bonzini 4722f0c9fe6SPaolo Bonzini job->speed = speed; 4732f0c9fe6SPaolo Bonzini } 4742f0c9fe6SPaolo Bonzini 475aeae883bSPaolo Bonzini void block_job_complete(BlockJob *job, Error **errp) 476aeae883bSPaolo Bonzini { 477559b935fSJohn Snow /* Should not be reachable via external interface for internal jobs */ 478559b935fSJohn Snow assert(job->id); 4795ccac6f1SJohn Snow if (job->pause_count || job->cancelled || 4805ccac6f1SJohn Snow !block_job_started(job) || !job->driver->complete) { 4819df229c3SAlberto Garcia error_setg(errp, "The active block job '%s' cannot be completed", 4829df229c3SAlberto Garcia job->id); 483aeae883bSPaolo Bonzini return; 484aeae883bSPaolo Bonzini } 485aeae883bSPaolo Bonzini 4863fc4b10aSFam Zheng job->driver->complete(job, errp); 487aeae883bSPaolo Bonzini } 488aeae883bSPaolo Bonzini 4890df4ba58SJohn Snow void block_job_user_pause(BlockJob *job) 4900df4ba58SJohn Snow { 4910df4ba58SJohn Snow job->user_paused = true; 4920df4ba58SJohn Snow block_job_pause(job); 4930df4ba58SJohn Snow } 4940df4ba58SJohn Snow 495a7f3b7ffSStefan Hajnoczi static bool block_job_should_pause(BlockJob *job) 4968acc72a4SPaolo Bonzini { 497751ebd76SFam Zheng return job->pause_count > 0; 4988acc72a4SPaolo Bonzini } 4998acc72a4SPaolo Bonzini 5000df4ba58SJohn Snow bool block_job_user_paused(BlockJob *job) 5010df4ba58SJohn Snow { 5026573d9c6SPaolo Bonzini return job->user_paused; 5030df4ba58SJohn Snow } 5040df4ba58SJohn Snow 505fc9c0a9cSStefan Hajnoczi void coroutine_fn block_job_pause_point(BlockJob *job) 506fc9c0a9cSStefan Hajnoczi { 5075ccac6f1SJohn Snow assert(job && block_job_started(job)); 5085ccac6f1SJohn Snow 509fc9c0a9cSStefan Hajnoczi if (!block_job_should_pause(job)) { 510fc9c0a9cSStefan Hajnoczi return; 511fc9c0a9cSStefan Hajnoczi } 512fc9c0a9cSStefan Hajnoczi if (block_job_is_cancelled(job)) { 513fc9c0a9cSStefan Hajnoczi return; 514fc9c0a9cSStefan Hajnoczi } 515fc9c0a9cSStefan Hajnoczi 516fc9c0a9cSStefan Hajnoczi if (job->driver->pause) { 517fc9c0a9cSStefan Hajnoczi job->driver->pause(job); 518fc9c0a9cSStefan Hajnoczi } 519fc9c0a9cSStefan Hajnoczi 520fc9c0a9cSStefan Hajnoczi if (block_job_should_pause(job) && !block_job_is_cancelled(job)) { 521fc9c0a9cSStefan Hajnoczi job->paused = true; 522fc9c0a9cSStefan Hajnoczi job->busy = false; 523fc9c0a9cSStefan Hajnoczi qemu_coroutine_yield(); /* wait for block_job_resume() */ 524fc9c0a9cSStefan Hajnoczi job->busy = true; 525fc9c0a9cSStefan Hajnoczi job->paused = false; 526fc9c0a9cSStefan Hajnoczi } 527fc9c0a9cSStefan Hajnoczi 528fc9c0a9cSStefan Hajnoczi if (job->driver->resume) { 529fc9c0a9cSStefan Hajnoczi job->driver->resume(job); 530fc9c0a9cSStefan Hajnoczi } 531fc9c0a9cSStefan Hajnoczi } 532fc9c0a9cSStefan Hajnoczi 5330df4ba58SJohn Snow void block_job_user_resume(BlockJob *job) 5340df4ba58SJohn Snow { 5350df4ba58SJohn Snow if (job && job->user_paused && job->pause_count > 0) { 5360df4ba58SJohn Snow job->user_paused = false; 5370df4ba58SJohn Snow block_job_resume(job); 5380df4ba58SJohn Snow } 5390df4ba58SJohn Snow } 5400df4ba58SJohn Snow 541751ebd76SFam Zheng void block_job_enter(BlockJob *job) 542751ebd76SFam Zheng { 5432f0c9fe6SPaolo Bonzini if (job->co && !job->busy) { 544aef4278cSFam Zheng bdrv_coroutine_enter(blk_bs(job->blk), job->co); 5452f0c9fe6SPaolo Bonzini } 5462f0c9fe6SPaolo Bonzini } 5472f0c9fe6SPaolo Bonzini 5488acc72a4SPaolo Bonzini void block_job_cancel(BlockJob *job) 5498acc72a4SPaolo Bonzini { 5505ccac6f1SJohn Snow if (block_job_started(job)) { 5518acc72a4SPaolo Bonzini job->cancelled = true; 55217bd51f9SStefan Hajnoczi block_job_iostatus_reset(job); 553751ebd76SFam Zheng block_job_enter(job); 5545ccac6f1SJohn Snow } else { 5555ccac6f1SJohn Snow block_job_completed(job, -ECANCELED); 5565ccac6f1SJohn Snow } 5578acc72a4SPaolo Bonzini } 5588acc72a4SPaolo Bonzini 5592f0c9fe6SPaolo Bonzini bool block_job_is_cancelled(BlockJob *job) 5602f0c9fe6SPaolo Bonzini { 5612f0c9fe6SPaolo Bonzini return job->cancelled; 5622f0c9fe6SPaolo Bonzini } 5632f0c9fe6SPaolo Bonzini 56432c81a4aSPaolo Bonzini void block_job_iostatus_reset(BlockJob *job) 56532c81a4aSPaolo Bonzini { 56632c81a4aSPaolo Bonzini job->iostatus = BLOCK_DEVICE_IO_STATUS_OK; 56732c81a4aSPaolo Bonzini } 56832c81a4aSPaolo Bonzini 569345f9e1bSMax Reitz static int block_job_finish_sync(BlockJob *job, 570345f9e1bSMax Reitz void (*finish)(BlockJob *, Error **errp), 571345f9e1bSMax Reitz Error **errp) 5722f0c9fe6SPaolo Bonzini { 573345f9e1bSMax Reitz Error *local_err = NULL; 57494db6d2dSFam Zheng int ret; 5752f0c9fe6SPaolo Bonzini 576b6d2e599SKevin Wolf assert(blk_bs(job->blk)->job == job); 5772f0c9fe6SPaolo Bonzini 57894db6d2dSFam Zheng block_job_ref(job); 579bae8196dSPaolo Bonzini 580345f9e1bSMax Reitz finish(job, &local_err); 581345f9e1bSMax Reitz if (local_err) { 582345f9e1bSMax Reitz error_propagate(errp, local_err); 58394db6d2dSFam Zheng block_job_unref(job); 584345f9e1bSMax Reitz return -EBUSY; 585345f9e1bSMax Reitz } 586bae8196dSPaolo Bonzini /* block_job_drain calls block_job_enter, and it should be enough to 587bae8196dSPaolo Bonzini * induce progress until the job completes or moves to the main thread. 588bae8196dSPaolo Bonzini */ 589bae8196dSPaolo Bonzini while (!job->deferred_to_main_loop && !job->completed) { 590bae8196dSPaolo Bonzini block_job_drain(job); 591bae8196dSPaolo Bonzini } 59294db6d2dSFam Zheng while (!job->completed) { 593bae8196dSPaolo Bonzini aio_poll(qemu_get_aio_context(), true); 5942f0c9fe6SPaolo Bonzini } 59594db6d2dSFam Zheng ret = (job->cancelled && job->ret == 0) ? -ECANCELED : job->ret; 59694db6d2dSFam Zheng block_job_unref(job); 59794db6d2dSFam Zheng return ret; 5982f0c9fe6SPaolo Bonzini } 5992f0c9fe6SPaolo Bonzini 600345f9e1bSMax Reitz /* A wrapper around block_job_cancel() taking an Error ** parameter so it may be 601345f9e1bSMax Reitz * used with block_job_finish_sync() without the need for (rather nasty) 602345f9e1bSMax Reitz * function pointer casts there. */ 603345f9e1bSMax Reitz static void block_job_cancel_err(BlockJob *job, Error **errp) 604345f9e1bSMax Reitz { 605345f9e1bSMax Reitz block_job_cancel(job); 606345f9e1bSMax Reitz } 607345f9e1bSMax Reitz 608345f9e1bSMax Reitz int block_job_cancel_sync(BlockJob *job) 609345f9e1bSMax Reitz { 610345f9e1bSMax Reitz return block_job_finish_sync(job, &block_job_cancel_err, NULL); 611345f9e1bSMax Reitz } 612345f9e1bSMax Reitz 613a1a2af07SKevin Wolf void block_job_cancel_sync_all(void) 614a1a2af07SKevin Wolf { 615a1a2af07SKevin Wolf BlockJob *job; 616a1a2af07SKevin Wolf AioContext *aio_context; 617a1a2af07SKevin Wolf 618a1a2af07SKevin Wolf while ((job = QLIST_FIRST(&block_jobs))) { 619b6d2e599SKevin Wolf aio_context = blk_get_aio_context(job->blk); 620a1a2af07SKevin Wolf aio_context_acquire(aio_context); 621a1a2af07SKevin Wolf block_job_cancel_sync(job); 622a1a2af07SKevin Wolf aio_context_release(aio_context); 623a1a2af07SKevin Wolf } 624a1a2af07SKevin Wolf } 625a1a2af07SKevin Wolf 626345f9e1bSMax Reitz int block_job_complete_sync(BlockJob *job, Error **errp) 627345f9e1bSMax Reitz { 628345f9e1bSMax Reitz return block_job_finish_sync(job, &block_job_complete, errp); 629345f9e1bSMax Reitz } 630345f9e1bSMax Reitz 6317483d1e5SAlex Bligh void block_job_sleep_ns(BlockJob *job, QEMUClockType type, int64_t ns) 6322f0c9fe6SPaolo Bonzini { 6338acc72a4SPaolo Bonzini assert(job->busy); 6348acc72a4SPaolo Bonzini 6352f0c9fe6SPaolo Bonzini /* Check cancellation *before* setting busy = false, too! */ 6368acc72a4SPaolo Bonzini if (block_job_is_cancelled(job)) { 6378acc72a4SPaolo Bonzini return; 6382f0c9fe6SPaolo Bonzini } 6398acc72a4SPaolo Bonzini 6408acc72a4SPaolo Bonzini job->busy = false; 641a7f3b7ffSStefan Hajnoczi if (!block_job_should_pause(job)) { 6420824afdaSAlberto Garcia co_aio_sleep_ns(blk_get_aio_context(job->blk), type, ns); 6430824afdaSAlberto Garcia } 6448acc72a4SPaolo Bonzini job->busy = true; 645fc9c0a9cSStefan Hajnoczi 646fc9c0a9cSStefan Hajnoczi block_job_pause_point(job); 6472f0c9fe6SPaolo Bonzini } 64830e628b7SPaolo Bonzini 649dc71ce45SFam Zheng void block_job_yield(BlockJob *job) 650dc71ce45SFam Zheng { 651dc71ce45SFam Zheng assert(job->busy); 652dc71ce45SFam Zheng 653dc71ce45SFam Zheng /* Check cancellation *before* setting busy = false, too! */ 654dc71ce45SFam Zheng if (block_job_is_cancelled(job)) { 655dc71ce45SFam Zheng return; 656dc71ce45SFam Zheng } 657dc71ce45SFam Zheng 658dc71ce45SFam Zheng job->busy = false; 659fc9c0a9cSStefan Hajnoczi if (!block_job_should_pause(job)) { 660dc71ce45SFam Zheng qemu_coroutine_yield(); 661fc9c0a9cSStefan Hajnoczi } 662dc71ce45SFam Zheng job->busy = true; 663fc9c0a9cSStefan Hajnoczi 664fc9c0a9cSStefan Hajnoczi block_job_pause_point(job); 665dc71ce45SFam Zheng } 666dc71ce45SFam Zheng 667559b935fSJohn Snow BlockJobInfo *block_job_query(BlockJob *job, Error **errp) 66830e628b7SPaolo Bonzini { 669559b935fSJohn Snow BlockJobInfo *info; 670559b935fSJohn Snow 671559b935fSJohn Snow if (block_job_is_internal(job)) { 672559b935fSJohn Snow error_setg(errp, "Cannot query QEMU internal jobs"); 673559b935fSJohn Snow return NULL; 674559b935fSJohn Snow } 675559b935fSJohn Snow info = g_new0(BlockJobInfo, 1); 67679e14bf7SFam Zheng info->type = g_strdup(BlockJobType_lookup[job->driver->job_type]); 6778ccb9569SKevin Wolf info->device = g_strdup(job->id); 67830e628b7SPaolo Bonzini info->len = job->len; 6798d65883fSPaolo Bonzini info->busy = job->busy; 680751ebd76SFam Zheng info->paused = job->pause_count > 0; 68130e628b7SPaolo Bonzini info->offset = job->offset; 68230e628b7SPaolo Bonzini info->speed = job->speed; 68332c81a4aSPaolo Bonzini info->io_status = job->iostatus; 684ef6dbf1eSMax Reitz info->ready = job->ready; 68530e628b7SPaolo Bonzini return info; 68630e628b7SPaolo Bonzini } 68732c81a4aSPaolo Bonzini 68832c81a4aSPaolo Bonzini static void block_job_iostatus_set_err(BlockJob *job, int error) 68932c81a4aSPaolo Bonzini { 69032c81a4aSPaolo Bonzini if (job->iostatus == BLOCK_DEVICE_IO_STATUS_OK) { 69132c81a4aSPaolo Bonzini job->iostatus = error == ENOSPC ? BLOCK_DEVICE_IO_STATUS_NOSPACE : 69232c81a4aSPaolo Bonzini BLOCK_DEVICE_IO_STATUS_FAILED; 69332c81a4aSPaolo Bonzini } 69432c81a4aSPaolo Bonzini } 69532c81a4aSPaolo Bonzini 6968254b6d9SJohn Snow static void block_job_event_cancelled(BlockJob *job) 697a66a2a36SPaolo Bonzini { 698559b935fSJohn Snow if (block_job_is_internal(job)) { 699559b935fSJohn Snow return; 700559b935fSJohn Snow } 701559b935fSJohn Snow 702bcada37bSWenchao Xia qapi_event_send_block_job_cancelled(job->driver->job_type, 7038ccb9569SKevin Wolf job->id, 704a66a2a36SPaolo Bonzini job->len, 705a66a2a36SPaolo Bonzini job->offset, 706bcada37bSWenchao Xia job->speed, 707bcada37bSWenchao Xia &error_abort); 708a66a2a36SPaolo Bonzini } 709a66a2a36SPaolo Bonzini 7108254b6d9SJohn Snow static void block_job_event_completed(BlockJob *job, const char *msg) 711a66a2a36SPaolo Bonzini { 712559b935fSJohn Snow if (block_job_is_internal(job)) { 713559b935fSJohn Snow return; 714559b935fSJohn Snow } 715559b935fSJohn Snow 716bcada37bSWenchao Xia qapi_event_send_block_job_completed(job->driver->job_type, 7178ccb9569SKevin Wolf job->id, 718bcada37bSWenchao Xia job->len, 719bcada37bSWenchao Xia job->offset, 720bcada37bSWenchao Xia job->speed, 721bcada37bSWenchao Xia !!msg, 722bcada37bSWenchao Xia msg, 723bcada37bSWenchao Xia &error_abort); 724bcada37bSWenchao Xia } 725bcada37bSWenchao Xia 726*f321dcb5SPaolo Bonzini void block_job_pause_all(void) 727*f321dcb5SPaolo Bonzini { 728*f321dcb5SPaolo Bonzini BlockJob *job = NULL; 729*f321dcb5SPaolo Bonzini while ((job = block_job_next(job))) { 730*f321dcb5SPaolo Bonzini AioContext *aio_context = blk_get_aio_context(job->blk); 731*f321dcb5SPaolo Bonzini 732*f321dcb5SPaolo Bonzini aio_context_acquire(aio_context); 733*f321dcb5SPaolo Bonzini block_job_pause(job); 734*f321dcb5SPaolo Bonzini aio_context_release(aio_context); 735*f321dcb5SPaolo Bonzini } 736*f321dcb5SPaolo Bonzini } 737*f321dcb5SPaolo Bonzini 738*f321dcb5SPaolo Bonzini void block_job_resume_all(void) 739*f321dcb5SPaolo Bonzini { 740*f321dcb5SPaolo Bonzini BlockJob *job = NULL; 741*f321dcb5SPaolo Bonzini while ((job = block_job_next(job))) { 742*f321dcb5SPaolo Bonzini AioContext *aio_context = blk_get_aio_context(job->blk); 743*f321dcb5SPaolo Bonzini 744*f321dcb5SPaolo Bonzini aio_context_acquire(aio_context); 745*f321dcb5SPaolo Bonzini block_job_resume(job); 746*f321dcb5SPaolo Bonzini aio_context_release(aio_context); 747*f321dcb5SPaolo Bonzini } 748*f321dcb5SPaolo Bonzini } 749*f321dcb5SPaolo Bonzini 750bcada37bSWenchao Xia void block_job_event_ready(BlockJob *job) 751bcada37bSWenchao Xia { 752ef6dbf1eSMax Reitz job->ready = true; 753ef6dbf1eSMax Reitz 754559b935fSJohn Snow if (block_job_is_internal(job)) { 755559b935fSJohn Snow return; 756559b935fSJohn Snow } 757559b935fSJohn Snow 758518848a2SMarkus Armbruster qapi_event_send_block_job_ready(job->driver->job_type, 7598ccb9569SKevin Wolf job->id, 760518848a2SMarkus Armbruster job->len, 761518848a2SMarkus Armbruster job->offset, 762518848a2SMarkus Armbruster job->speed, &error_abort); 763a66a2a36SPaolo Bonzini } 764a66a2a36SPaolo Bonzini 76581e254dcSKevin Wolf BlockErrorAction block_job_error_action(BlockJob *job, BlockdevOnError on_err, 76632c81a4aSPaolo Bonzini int is_read, int error) 76732c81a4aSPaolo Bonzini { 76832c81a4aSPaolo Bonzini BlockErrorAction action; 76932c81a4aSPaolo Bonzini 77032c81a4aSPaolo Bonzini switch (on_err) { 77132c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_ENOSPC: 7728c398252SKevin Wolf case BLOCKDEV_ON_ERROR_AUTO: 773a589569fSWenchao Xia action = (error == ENOSPC) ? 774a589569fSWenchao Xia BLOCK_ERROR_ACTION_STOP : BLOCK_ERROR_ACTION_REPORT; 77532c81a4aSPaolo Bonzini break; 77632c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_STOP: 777a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_STOP; 77832c81a4aSPaolo Bonzini break; 77932c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_REPORT: 780a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_REPORT; 78132c81a4aSPaolo Bonzini break; 78232c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_IGNORE: 783a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_IGNORE; 78432c81a4aSPaolo Bonzini break; 78532c81a4aSPaolo Bonzini default: 78632c81a4aSPaolo Bonzini abort(); 78732c81a4aSPaolo Bonzini } 788559b935fSJohn Snow if (!block_job_is_internal(job)) { 7898ccb9569SKevin Wolf qapi_event_send_block_job_error(job->id, 7905a2d2cbdSWenchao Xia is_read ? IO_OPERATION_TYPE_READ : 7915a2d2cbdSWenchao Xia IO_OPERATION_TYPE_WRITE, 7925a2d2cbdSWenchao Xia action, &error_abort); 793559b935fSJohn Snow } 794a589569fSWenchao Xia if (action == BLOCK_ERROR_ACTION_STOP) { 795751ebd76SFam Zheng /* make the pause user visible, which will be resumed from QMP. */ 7960df4ba58SJohn Snow block_job_user_pause(job); 79732c81a4aSPaolo Bonzini block_job_iostatus_set_err(job, error); 79832c81a4aSPaolo Bonzini } 79932c81a4aSPaolo Bonzini return action; 80032c81a4aSPaolo Bonzini } 801dec7d421SStefan Hajnoczi 802dec7d421SStefan Hajnoczi typedef struct { 803dec7d421SStefan Hajnoczi BlockJob *job; 804dec7d421SStefan Hajnoczi AioContext *aio_context; 805dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopFn *fn; 806dec7d421SStefan Hajnoczi void *opaque; 807dec7d421SStefan Hajnoczi } BlockJobDeferToMainLoopData; 808dec7d421SStefan Hajnoczi 809dec7d421SStefan Hajnoczi static void block_job_defer_to_main_loop_bh(void *opaque) 810dec7d421SStefan Hajnoczi { 811dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopData *data = opaque; 812dec7d421SStefan Hajnoczi AioContext *aio_context; 813dec7d421SStefan Hajnoczi 814dec7d421SStefan Hajnoczi /* Prevent race with block_job_defer_to_main_loop() */ 815dec7d421SStefan Hajnoczi aio_context_acquire(data->aio_context); 816dec7d421SStefan Hajnoczi 817dec7d421SStefan Hajnoczi /* Fetch BDS AioContext again, in case it has changed */ 818b6d2e599SKevin Wolf aio_context = blk_get_aio_context(data->job->blk); 819d79df2a2SPaolo Bonzini if (aio_context != data->aio_context) { 820dec7d421SStefan Hajnoczi aio_context_acquire(aio_context); 821d79df2a2SPaolo Bonzini } 822dec7d421SStefan Hajnoczi 823794f0141SFam Zheng data->job->deferred_to_main_loop = false; 824dec7d421SStefan Hajnoczi data->fn(data->job, data->opaque); 825dec7d421SStefan Hajnoczi 826d79df2a2SPaolo Bonzini if (aio_context != data->aio_context) { 827dec7d421SStefan Hajnoczi aio_context_release(aio_context); 828d79df2a2SPaolo Bonzini } 829dec7d421SStefan Hajnoczi 830dec7d421SStefan Hajnoczi aio_context_release(data->aio_context); 831dec7d421SStefan Hajnoczi 832dec7d421SStefan Hajnoczi g_free(data); 833dec7d421SStefan Hajnoczi } 834dec7d421SStefan Hajnoczi 835dec7d421SStefan Hajnoczi void block_job_defer_to_main_loop(BlockJob *job, 836dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopFn *fn, 837dec7d421SStefan Hajnoczi void *opaque) 838dec7d421SStefan Hajnoczi { 839dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopData *data = g_malloc(sizeof(*data)); 840dec7d421SStefan Hajnoczi data->job = job; 841b6d2e599SKevin Wolf data->aio_context = blk_get_aio_context(job->blk); 842dec7d421SStefan Hajnoczi data->fn = fn; 843dec7d421SStefan Hajnoczi data->opaque = opaque; 844794f0141SFam Zheng job->deferred_to_main_loop = true; 845dec7d421SStefan Hajnoczi 846fffb6e12SPaolo Bonzini aio_bh_schedule_oneshot(qemu_get_aio_context(), 847fffb6e12SPaolo Bonzini block_job_defer_to_main_loop_bh, data); 848dec7d421SStefan Hajnoczi } 849c55a832fSFam Zheng 850c55a832fSFam Zheng BlockJobTxn *block_job_txn_new(void) 851c55a832fSFam Zheng { 852c55a832fSFam Zheng BlockJobTxn *txn = g_new0(BlockJobTxn, 1); 853c55a832fSFam Zheng QLIST_INIT(&txn->jobs); 854c55a832fSFam Zheng txn->refcnt = 1; 855c55a832fSFam Zheng return txn; 856c55a832fSFam Zheng } 857c55a832fSFam Zheng 858c55a832fSFam Zheng static void block_job_txn_ref(BlockJobTxn *txn) 859c55a832fSFam Zheng { 860c55a832fSFam Zheng txn->refcnt++; 861c55a832fSFam Zheng } 862c55a832fSFam Zheng 863c55a832fSFam Zheng void block_job_txn_unref(BlockJobTxn *txn) 864c55a832fSFam Zheng { 865c55a832fSFam Zheng if (txn && --txn->refcnt == 0) { 866c55a832fSFam Zheng g_free(txn); 867c55a832fSFam Zheng } 868c55a832fSFam Zheng } 869c55a832fSFam Zheng 870c55a832fSFam Zheng void block_job_txn_add_job(BlockJobTxn *txn, BlockJob *job) 871c55a832fSFam Zheng { 872c55a832fSFam Zheng if (!txn) { 873c55a832fSFam Zheng return; 874c55a832fSFam Zheng } 875c55a832fSFam Zheng 876c55a832fSFam Zheng assert(!job->txn); 877c55a832fSFam Zheng job->txn = txn; 878c55a832fSFam Zheng 879c55a832fSFam Zheng QLIST_INSERT_HEAD(&txn->jobs, job, txn_list); 880c55a832fSFam Zheng block_job_txn_ref(txn); 881c55a832fSFam Zheng } 882