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" 31c9de4050SJohn Snow #include "block/trace.h" 32373340b2SMax Reitz #include "sysemu/block-backend.h" 33e688df6bSMarkus Armbruster #include "qapi/error.h" 349af23989SMarkus Armbruster #include "qapi/qapi-events-block-core.h" 35cc7a8ea7SMarkus Armbruster #include "qapi/qmp/qerror.h" 3610817bf0SDaniel P. Berrange #include "qemu/coroutine.h" 371de7afc9SPaolo Bonzini #include "qemu/timer.h" 382f0c9fe6SPaolo Bonzini 3988691b37SPaolo Bonzini /* 4088691b37SPaolo Bonzini * The block job API is composed of two categories of functions. 4188691b37SPaolo Bonzini * 4288691b37SPaolo Bonzini * The first includes functions used by the monitor. The monitor is 4388691b37SPaolo Bonzini * peculiar in that it accesses the block job list with block_job_get, and 4488691b37SPaolo Bonzini * therefore needs consistency across block_job_get and the actual operation 4588691b37SPaolo Bonzini * (e.g. block_job_set_speed). The consistency is achieved with 4688691b37SPaolo Bonzini * aio_context_acquire/release. These functions are declared in blockjob.h. 4788691b37SPaolo Bonzini * 4888691b37SPaolo Bonzini * The second includes functions used by the block job drivers and sometimes 4988691b37SPaolo Bonzini * by the core block layer. These do not care about locking, because the 5088691b37SPaolo Bonzini * whole coroutine runs under the AioContext lock, and are declared in 5188691b37SPaolo Bonzini * blockjob_int.h. 5288691b37SPaolo Bonzini */ 5388691b37SPaolo Bonzini 54e7c1d78bSKevin Wolf static bool is_block_job(Job *job) 55a7112795SAlberto Garcia { 56e7c1d78bSKevin Wolf return job_type(job) == JOB_TYPE_BACKUP || 57e7c1d78bSKevin Wolf job_type(job) == JOB_TYPE_COMMIT || 58e7c1d78bSKevin Wolf job_type(job) == JOB_TYPE_MIRROR || 59e7c1d78bSKevin Wolf job_type(job) == JOB_TYPE_STREAM; 60a7112795SAlberto Garcia } 61e7c1d78bSKevin Wolf 62e7c1d78bSKevin Wolf BlockJob *block_job_next(BlockJob *bjob) 63e7c1d78bSKevin Wolf { 64e7c1d78bSKevin Wolf Job *job = bjob ? &bjob->job : NULL; 65e7c1d78bSKevin Wolf 66e7c1d78bSKevin Wolf do { 67e7c1d78bSKevin Wolf job = job_next(job); 68e7c1d78bSKevin Wolf } while (job && !is_block_job(job)); 69e7c1d78bSKevin Wolf 70e7c1d78bSKevin Wolf return job ? container_of(job, BlockJob, job) : NULL; 71a7112795SAlberto Garcia } 72a7112795SAlberto Garcia 73ffb1f10cSAlberto Garcia BlockJob *block_job_get(const char *id) 74ffb1f10cSAlberto Garcia { 75e7c1d78bSKevin Wolf Job *job = job_get(id); 76ffb1f10cSAlberto Garcia 77e7c1d78bSKevin Wolf if (job && is_block_job(job)) { 78e7c1d78bSKevin Wolf return container_of(job, BlockJob, job); 79e7c1d78bSKevin Wolf } else { 80ffb1f10cSAlberto Garcia return NULL; 81ffb1f10cSAlberto Garcia } 82e7c1d78bSKevin Wolf } 83ffb1f10cSAlberto Garcia 8405b0d8e3SPaolo Bonzini static void block_job_attached_aio_context(AioContext *new_context, 8505b0d8e3SPaolo Bonzini void *opaque); 8605b0d8e3SPaolo Bonzini static void block_job_detach_aio_context(void *opaque); 8705b0d8e3SPaolo Bonzini 8880fa2c75SKevin Wolf void block_job_free(Job *job) 8905b0d8e3SPaolo Bonzini { 9080fa2c75SKevin Wolf BlockJob *bjob = container_of(job, BlockJob, job); 9180fa2c75SKevin Wolf BlockDriverState *bs = blk_bs(bjob->blk); 9280fa2c75SKevin Wolf 9305b0d8e3SPaolo Bonzini bs->job = NULL; 9480fa2c75SKevin Wolf block_job_remove_all_bdrv(bjob); 9580fa2c75SKevin Wolf blk_remove_aio_context_notifier(bjob->blk, 9605b0d8e3SPaolo Bonzini block_job_attached_aio_context, 9780fa2c75SKevin Wolf block_job_detach_aio_context, bjob); 9880fa2c75SKevin Wolf blk_unref(bjob->blk); 9980fa2c75SKevin Wolf error_free(bjob->blocker); 10005b0d8e3SPaolo Bonzini } 10105b0d8e3SPaolo Bonzini 102463e0be1SStefan Hajnoczi static void block_job_attached_aio_context(AioContext *new_context, 103463e0be1SStefan Hajnoczi void *opaque) 104463e0be1SStefan Hajnoczi { 105463e0be1SStefan Hajnoczi BlockJob *job = opaque; 106463e0be1SStefan Hajnoczi 10708be6fe2SKevin Wolf job->job.aio_context = new_context; 108463e0be1SStefan Hajnoczi if (job->driver->attached_aio_context) { 109463e0be1SStefan Hajnoczi job->driver->attached_aio_context(job, new_context); 110463e0be1SStefan Hajnoczi } 111463e0be1SStefan Hajnoczi 112b15de828SKevin Wolf job_resume(&job->job); 113463e0be1SStefan Hajnoczi } 114463e0be1SStefan Hajnoczi 115b69f777dSKevin Wolf void block_job_drain(Job *job) 116bae8196dSPaolo Bonzini { 117b69f777dSKevin Wolf BlockJob *bjob = container_of(job, BlockJob, job); 118bae8196dSPaolo Bonzini 119b69f777dSKevin Wolf blk_drain(bjob->blk); 120b69f777dSKevin Wolf if (bjob->driver->drain) { 121b69f777dSKevin Wolf bjob->driver->drain(bjob); 122bae8196dSPaolo Bonzini } 123bae8196dSPaolo Bonzini } 124bae8196dSPaolo Bonzini 125463e0be1SStefan Hajnoczi static void block_job_detach_aio_context(void *opaque) 126463e0be1SStefan Hajnoczi { 127463e0be1SStefan Hajnoczi BlockJob *job = opaque; 128463e0be1SStefan Hajnoczi 129463e0be1SStefan Hajnoczi /* In case the job terminates during aio_poll()... */ 13080fa2c75SKevin Wolf job_ref(&job->job); 131463e0be1SStefan Hajnoczi 132b15de828SKevin Wolf job_pause(&job->job); 133463e0be1SStefan Hajnoczi 134dbe5e6c1SKevin Wolf while (!job->job.paused && !job_is_completed(&job->job)) { 135b69f777dSKevin Wolf job_drain(&job->job); 136463e0be1SStefan Hajnoczi } 137463e0be1SStefan Hajnoczi 13808be6fe2SKevin Wolf job->job.aio_context = NULL; 13980fa2c75SKevin Wolf job_unref(&job->job); 140463e0be1SStefan Hajnoczi } 141463e0be1SStefan Hajnoczi 142f321dcb5SPaolo Bonzini static char *child_job_get_parent_desc(BdrvChild *c) 143f321dcb5SPaolo Bonzini { 144f321dcb5SPaolo Bonzini BlockJob *job = c->opaque; 145252291eaSKevin Wolf return g_strdup_printf("%s job '%s'", job_type_str(&job->job), job->job.id); 146f321dcb5SPaolo Bonzini } 147f321dcb5SPaolo Bonzini 148ad90febaSKevin Wolf static void child_job_drained_begin(BdrvChild *c) 149f321dcb5SPaolo Bonzini { 150ad90febaSKevin Wolf BlockJob *job = c->opaque; 151b15de828SKevin Wolf job_pause(&job->job); 152f321dcb5SPaolo Bonzini } 153f321dcb5SPaolo Bonzini 154ad90febaSKevin Wolf static void child_job_drained_end(BdrvChild *c) 155f321dcb5SPaolo Bonzini { 156ad90febaSKevin Wolf BlockJob *job = c->opaque; 157b15de828SKevin Wolf job_resume(&job->job); 158f321dcb5SPaolo Bonzini } 159f321dcb5SPaolo Bonzini 160ad90febaSKevin Wolf static const BdrvChildRole child_job = { 161ad90febaSKevin Wolf .get_parent_desc = child_job_get_parent_desc, 162ad90febaSKevin Wolf .drained_begin = child_job_drained_begin, 163ad90febaSKevin Wolf .drained_end = child_job_drained_end, 164ad90febaSKevin Wolf .stay_at_node = true, 165f321dcb5SPaolo Bonzini }; 166f321dcb5SPaolo Bonzini 167bbc02b90SKevin Wolf void block_job_remove_all_bdrv(BlockJob *job) 168bbc02b90SKevin Wolf { 169bbc02b90SKevin Wolf GSList *l; 170bbc02b90SKevin Wolf for (l = job->nodes; l; l = l->next) { 171bbc02b90SKevin Wolf BdrvChild *c = l->data; 172bbc02b90SKevin Wolf bdrv_op_unblock_all(c->bs, job->blocker); 173bbc02b90SKevin Wolf bdrv_root_unref_child(c); 174bbc02b90SKevin Wolf } 175bbc02b90SKevin Wolf g_slist_free(job->nodes); 176bbc02b90SKevin Wolf job->nodes = NULL; 177bbc02b90SKevin Wolf } 178bbc02b90SKevin Wolf 17976d554e2SKevin Wolf int block_job_add_bdrv(BlockJob *job, const char *name, BlockDriverState *bs, 18076d554e2SKevin Wolf uint64_t perm, uint64_t shared_perm, Error **errp) 18123d402d4SAlberto Garcia { 18276d554e2SKevin Wolf BdrvChild *c; 18376d554e2SKevin Wolf 18476d554e2SKevin Wolf c = bdrv_root_attach_child(bs, name, &child_job, perm, shared_perm, 18576d554e2SKevin Wolf job, errp); 18676d554e2SKevin Wolf if (c == NULL) { 18776d554e2SKevin Wolf return -EPERM; 18876d554e2SKevin Wolf } 18976d554e2SKevin Wolf 19076d554e2SKevin Wolf job->nodes = g_slist_prepend(job->nodes, c); 19123d402d4SAlberto Garcia bdrv_ref(bs); 19223d402d4SAlberto Garcia bdrv_op_block_all(bs, job->blocker); 19376d554e2SKevin Wolf 19476d554e2SKevin Wolf return 0; 19523d402d4SAlberto Garcia } 19623d402d4SAlberto Garcia 197559b935fSJohn Snow bool block_job_is_internal(BlockJob *job) 198559b935fSJohn Snow { 19933e9e9bdSKevin Wolf return (job->job.id == NULL); 200559b935fSJohn Snow } 201559b935fSJohn Snow 202bd21935bSKevin Wolf const BlockJobDriver *block_job_driver(BlockJob *job) 203bd21935bSKevin Wolf { 204bd21935bSKevin Wolf return job->driver; 205bd21935bSKevin Wolf } 206bd21935bSKevin Wolf 207da01ff7fSKevin Wolf /* Assumes the job_mutex is held */ 208da01ff7fSKevin Wolf static bool job_timer_pending(Job *job) 209da01ff7fSKevin Wolf { 210da01ff7fSKevin Wolf return timer_pending(&job->sleep_timer); 211da01ff7fSKevin Wolf } 212da01ff7fSKevin Wolf 2132f0c9fe6SPaolo Bonzini void block_job_set_speed(BlockJob *job, int64_t speed, Error **errp) 2142f0c9fe6SPaolo Bonzini { 215aa9ef2e6SJohn Snow int64_t old_speed = job->speed; 2162f0c9fe6SPaolo Bonzini 217a50c2ab8SKevin Wolf if (job_apply_verb(&job->job, JOB_VERB_SET_SPEED, errp)) { 2180ec4dfb8SJohn Snow return; 2190ec4dfb8SJohn Snow } 22018bb6928SKevin Wolf if (speed < 0) { 22118bb6928SKevin Wolf error_setg(errp, QERR_INVALID_PARAMETER, "speed"); 2222f0c9fe6SPaolo Bonzini return; 2232f0c9fe6SPaolo Bonzini } 2242f0c9fe6SPaolo Bonzini 22518bb6928SKevin Wolf ratelimit_set_speed(&job->limit, speed, BLOCK_JOB_SLICE_TIME); 22618bb6928SKevin Wolf 2272f0c9fe6SPaolo Bonzini job->speed = speed; 228d4fce188SJohn Snow if (speed && speed <= old_speed) { 229aa9ef2e6SJohn Snow return; 230aa9ef2e6SJohn Snow } 231aa9ef2e6SJohn Snow 232aa9ef2e6SJohn Snow /* kick only if a timer is pending */ 233da01ff7fSKevin Wolf job_enter_cond(&job->job, job_timer_pending); 2342f0c9fe6SPaolo Bonzini } 2352f0c9fe6SPaolo Bonzini 236dee81d51SKevin Wolf int64_t block_job_ratelimit_get_delay(BlockJob *job, uint64_t n) 237dee81d51SKevin Wolf { 238dee81d51SKevin Wolf if (!job->speed) { 239dee81d51SKevin Wolf return 0; 240dee81d51SKevin Wolf } 241dee81d51SKevin Wolf 242dee81d51SKevin Wolf return ratelimit_calculate_delay(&job->limit, n); 243dee81d51SKevin Wolf } 244dee81d51SKevin Wolf 24505df8a6aSKevin Wolf void block_job_progress_update(BlockJob *job, uint64_t done) 24605df8a6aSKevin Wolf { 24705df8a6aSKevin Wolf job->offset += done; 24805df8a6aSKevin Wolf } 24905df8a6aSKevin Wolf 25005df8a6aSKevin Wolf void block_job_progress_set_remaining(BlockJob *job, uint64_t remaining) 25105df8a6aSKevin Wolf { 25205df8a6aSKevin Wolf job->len = job->offset + remaining; 25305df8a6aSKevin Wolf } 25405df8a6aSKevin Wolf 255559b935fSJohn Snow BlockJobInfo *block_job_query(BlockJob *job, Error **errp) 25630e628b7SPaolo Bonzini { 257559b935fSJohn Snow BlockJobInfo *info; 258559b935fSJohn Snow 259559b935fSJohn Snow if (block_job_is_internal(job)) { 260559b935fSJohn Snow error_setg(errp, "Cannot query QEMU internal jobs"); 261559b935fSJohn Snow return NULL; 262559b935fSJohn Snow } 263559b935fSJohn Snow info = g_new0(BlockJobInfo, 1); 264252291eaSKevin Wolf info->type = g_strdup(job_type_str(&job->job)); 26533e9e9bdSKevin Wolf info->device = g_strdup(job->job.id); 26630e628b7SPaolo Bonzini info->len = job->len; 267da01ff7fSKevin Wolf info->busy = atomic_read(&job->job.busy); 268da01ff7fSKevin Wolf info->paused = job->job.pause_count > 0; 26930e628b7SPaolo Bonzini info->offset = job->offset; 27030e628b7SPaolo Bonzini info->speed = job->speed; 27132c81a4aSPaolo Bonzini info->io_status = job->iostatus; 272df956ae2SKevin Wolf info->ready = job_is_ready(&job->job), 273a50c2ab8SKevin Wolf info->status = job->job.status; 274bb02b65cSKevin Wolf info->auto_finalize = job->job.auto_finalize; 275bb02b65cSKevin Wolf info->auto_dismiss = job->job.auto_dismiss; 2764ad35181SKevin Wolf info->has_error = job->job.ret != 0; 2774ad35181SKevin Wolf info->error = job->job.ret ? g_strdup(strerror(-job->job.ret)) : NULL; 27830e628b7SPaolo Bonzini return info; 27930e628b7SPaolo Bonzini } 28032c81a4aSPaolo Bonzini 28132c81a4aSPaolo Bonzini static void block_job_iostatus_set_err(BlockJob *job, int error) 28232c81a4aSPaolo Bonzini { 28332c81a4aSPaolo Bonzini if (job->iostatus == BLOCK_DEVICE_IO_STATUS_OK) { 28432c81a4aSPaolo Bonzini job->iostatus = error == ENOSPC ? BLOCK_DEVICE_IO_STATUS_NOSPACE : 28532c81a4aSPaolo Bonzini BLOCK_DEVICE_IO_STATUS_FAILED; 28632c81a4aSPaolo Bonzini } 28732c81a4aSPaolo Bonzini } 28832c81a4aSPaolo Bonzini 289139a9f02SKevin Wolf static void block_job_event_cancelled(Notifier *n, void *opaque) 290a66a2a36SPaolo Bonzini { 291139a9f02SKevin Wolf BlockJob *job = opaque; 292139a9f02SKevin Wolf 293559b935fSJohn Snow if (block_job_is_internal(job)) { 294559b935fSJohn Snow return; 295559b935fSJohn Snow } 296559b935fSJohn Snow 297252291eaSKevin Wolf qapi_event_send_block_job_cancelled(job_type(&job->job), 29833e9e9bdSKevin Wolf job->job.id, 299a66a2a36SPaolo Bonzini job->len, 300a66a2a36SPaolo Bonzini job->offset, 301bcada37bSWenchao Xia job->speed, 302bcada37bSWenchao Xia &error_abort); 303a66a2a36SPaolo Bonzini } 304a66a2a36SPaolo Bonzini 305139a9f02SKevin Wolf static void block_job_event_completed(Notifier *n, void *opaque) 306a66a2a36SPaolo Bonzini { 307139a9f02SKevin Wolf BlockJob *job = opaque; 308139a9f02SKevin Wolf const char *msg = NULL; 309139a9f02SKevin Wolf 310559b935fSJohn Snow if (block_job_is_internal(job)) { 311559b935fSJohn Snow return; 312559b935fSJohn Snow } 313559b935fSJohn Snow 3144ad35181SKevin Wolf if (job->job.ret < 0) { 3154ad35181SKevin Wolf msg = strerror(-job->job.ret); 316139a9f02SKevin Wolf } 317139a9f02SKevin Wolf 318252291eaSKevin Wolf qapi_event_send_block_job_completed(job_type(&job->job), 31933e9e9bdSKevin Wolf job->job.id, 320bcada37bSWenchao Xia job->len, 321bcada37bSWenchao Xia job->offset, 322bcada37bSWenchao Xia job->speed, 323bcada37bSWenchao Xia !!msg, 324bcada37bSWenchao Xia msg, 325bcada37bSWenchao Xia &error_abort); 326bcada37bSWenchao Xia } 327bcada37bSWenchao Xia 328139a9f02SKevin Wolf static void block_job_event_pending(Notifier *n, void *opaque) 3295f241594SJohn Snow { 330139a9f02SKevin Wolf BlockJob *job = opaque; 331139a9f02SKevin Wolf 3325d4f3769SKevin Wolf if (block_job_is_internal(job)) { 3335d4f3769SKevin Wolf return; 3345d4f3769SKevin Wolf } 3355d4f3769SKevin Wolf 336252291eaSKevin Wolf qapi_event_send_block_job_pending(job_type(&job->job), 33733e9e9bdSKevin Wolf job->job.id, 3385f241594SJohn Snow &error_abort); 3395f241594SJohn Snow } 3405f241594SJohn Snow 341*2e1795b5SKevin Wolf static void block_job_event_ready(Notifier *n, void *opaque) 342*2e1795b5SKevin Wolf { 343*2e1795b5SKevin Wolf BlockJob *job = opaque; 344*2e1795b5SKevin Wolf 345*2e1795b5SKevin Wolf if (block_job_is_internal(job)) { 346*2e1795b5SKevin Wolf return; 347*2e1795b5SKevin Wolf } 348*2e1795b5SKevin Wolf 349*2e1795b5SKevin Wolf qapi_event_send_block_job_ready(job_type(&job->job), 350*2e1795b5SKevin Wolf job->job.id, 351*2e1795b5SKevin Wolf job->len, 352*2e1795b5SKevin Wolf job->offset, 353*2e1795b5SKevin Wolf job->speed, &error_abort); 354*2e1795b5SKevin Wolf } 355*2e1795b5SKevin Wolf 356*2e1795b5SKevin Wolf 35788691b37SPaolo Bonzini /* 35888691b37SPaolo Bonzini * API for block job drivers and the block layer. These functions are 35988691b37SPaolo Bonzini * declared in blockjob_int.h. 36088691b37SPaolo Bonzini */ 36188691b37SPaolo Bonzini 36288691b37SPaolo Bonzini void *block_job_create(const char *job_id, const BlockJobDriver *driver, 36362c9e416SKevin Wolf JobTxn *txn, BlockDriverState *bs, uint64_t perm, 36488691b37SPaolo Bonzini uint64_t shared_perm, int64_t speed, int flags, 36588691b37SPaolo Bonzini BlockCompletionFunc *cb, void *opaque, Error **errp) 36688691b37SPaolo Bonzini { 36788691b37SPaolo Bonzini BlockBackend *blk; 36888691b37SPaolo Bonzini BlockJob *job; 36988691b37SPaolo Bonzini int ret; 37088691b37SPaolo Bonzini 37188691b37SPaolo Bonzini if (bs->job) { 37288691b37SPaolo Bonzini error_setg(errp, QERR_DEVICE_IN_USE, bdrv_get_device_name(bs)); 37388691b37SPaolo Bonzini return NULL; 37488691b37SPaolo Bonzini } 37588691b37SPaolo Bonzini 376bb02b65cSKevin Wolf if (job_id == NULL && !(flags & JOB_INTERNAL)) { 37788691b37SPaolo Bonzini job_id = bdrv_get_device_name(bs); 37888691b37SPaolo Bonzini } 37988691b37SPaolo Bonzini 38088691b37SPaolo Bonzini blk = blk_new(perm, shared_perm); 38188691b37SPaolo Bonzini ret = blk_insert_bs(blk, bs, errp); 38288691b37SPaolo Bonzini if (ret < 0) { 38388691b37SPaolo Bonzini blk_unref(blk); 38488691b37SPaolo Bonzini return NULL; 38588691b37SPaolo Bonzini } 38688691b37SPaolo Bonzini 3877eaa8fb5SKevin Wolf job = job_create(job_id, &driver->job_driver, txn, blk_get_aio_context(blk), 3884ad35181SKevin Wolf flags, cb, opaque, errp); 38933e9e9bdSKevin Wolf if (job == NULL) { 39033e9e9bdSKevin Wolf blk_unref(blk); 39133e9e9bdSKevin Wolf return NULL; 39233e9e9bdSKevin Wolf } 39333e9e9bdSKevin Wolf 394e7c1d78bSKevin Wolf assert(is_block_job(&job->job)); 39580fa2c75SKevin Wolf assert(job->job.driver->free == &block_job_free); 396b15de828SKevin Wolf assert(job->job.driver->user_resume == &block_job_user_resume); 397b69f777dSKevin Wolf assert(job->job.driver->drain == &block_job_drain); 398e7c1d78bSKevin Wolf 39988691b37SPaolo Bonzini job->driver = driver; 40088691b37SPaolo Bonzini job->blk = blk; 40188691b37SPaolo Bonzini 402139a9f02SKevin Wolf job->finalize_cancelled_notifier.notify = block_job_event_cancelled; 403139a9f02SKevin Wolf job->finalize_completed_notifier.notify = block_job_event_completed; 404139a9f02SKevin Wolf job->pending_notifier.notify = block_job_event_pending; 405*2e1795b5SKevin Wolf job->ready_notifier.notify = block_job_event_ready; 406139a9f02SKevin Wolf 407139a9f02SKevin Wolf notifier_list_add(&job->job.on_finalize_cancelled, 408139a9f02SKevin Wolf &job->finalize_cancelled_notifier); 409139a9f02SKevin Wolf notifier_list_add(&job->job.on_finalize_completed, 410139a9f02SKevin Wolf &job->finalize_completed_notifier); 411139a9f02SKevin Wolf notifier_list_add(&job->job.on_pending, &job->pending_notifier); 412*2e1795b5SKevin Wolf notifier_list_add(&job->job.on_ready, &job->ready_notifier); 413139a9f02SKevin Wolf 41488691b37SPaolo Bonzini error_setg(&job->blocker, "block device is in use by block job: %s", 415252291eaSKevin Wolf job_type_str(&job->job)); 41688691b37SPaolo Bonzini block_job_add_bdrv(job, "main node", bs, 0, BLK_PERM_ALL, &error_abort); 41788691b37SPaolo Bonzini bs->job = job; 41888691b37SPaolo Bonzini 41988691b37SPaolo Bonzini bdrv_op_unblock(bs, BLOCK_OP_TYPE_DATAPLANE, job->blocker); 42088691b37SPaolo Bonzini 42188691b37SPaolo Bonzini blk_add_aio_context_notifier(blk, block_job_attached_aio_context, 42288691b37SPaolo Bonzini block_job_detach_aio_context, job); 42388691b37SPaolo Bonzini 42488691b37SPaolo Bonzini /* Only set speed when necessary to avoid NotSupported error */ 42588691b37SPaolo Bonzini if (speed != 0) { 42688691b37SPaolo Bonzini Error *local_err = NULL; 42788691b37SPaolo Bonzini 42888691b37SPaolo Bonzini block_job_set_speed(job, speed, &local_err); 42988691b37SPaolo Bonzini if (local_err) { 4304ad35181SKevin Wolf job_early_fail(&job->job); 43188691b37SPaolo Bonzini error_propagate(errp, local_err); 43288691b37SPaolo Bonzini return NULL; 43388691b37SPaolo Bonzini } 43488691b37SPaolo Bonzini } 43575859b94SJohn Snow 43688691b37SPaolo Bonzini return job; 43788691b37SPaolo Bonzini } 43888691b37SPaolo Bonzini 4392caf63a9SPaolo Bonzini void block_job_iostatus_reset(BlockJob *job) 4402caf63a9SPaolo Bonzini { 4414c241cf5SPaolo Bonzini if (job->iostatus == BLOCK_DEVICE_IO_STATUS_OK) { 4424c241cf5SPaolo Bonzini return; 4434c241cf5SPaolo Bonzini } 444b15de828SKevin Wolf assert(job->job.user_paused && job->job.pause_count > 0); 4452caf63a9SPaolo Bonzini job->iostatus = BLOCK_DEVICE_IO_STATUS_OK; 4462caf63a9SPaolo Bonzini } 4472caf63a9SPaolo Bonzini 448b15de828SKevin Wolf void block_job_user_resume(Job *job) 449b15de828SKevin Wolf { 450b15de828SKevin Wolf BlockJob *bjob = container_of(job, BlockJob, job); 451b15de828SKevin Wolf block_job_iostatus_reset(bjob); 452b15de828SKevin Wolf } 453b15de828SKevin Wolf 45481e254dcSKevin Wolf BlockErrorAction block_job_error_action(BlockJob *job, BlockdevOnError on_err, 45532c81a4aSPaolo Bonzini int is_read, int error) 45632c81a4aSPaolo Bonzini { 45732c81a4aSPaolo Bonzini BlockErrorAction action; 45832c81a4aSPaolo Bonzini 45932c81a4aSPaolo Bonzini switch (on_err) { 46032c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_ENOSPC: 4618c398252SKevin Wolf case BLOCKDEV_ON_ERROR_AUTO: 462a589569fSWenchao Xia action = (error == ENOSPC) ? 463a589569fSWenchao Xia BLOCK_ERROR_ACTION_STOP : BLOCK_ERROR_ACTION_REPORT; 46432c81a4aSPaolo Bonzini break; 46532c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_STOP: 466a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_STOP; 46732c81a4aSPaolo Bonzini break; 46832c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_REPORT: 469a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_REPORT; 47032c81a4aSPaolo Bonzini break; 47132c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_IGNORE: 472a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_IGNORE; 47332c81a4aSPaolo Bonzini break; 47432c81a4aSPaolo Bonzini default: 47532c81a4aSPaolo Bonzini abort(); 47632c81a4aSPaolo Bonzini } 477559b935fSJohn Snow if (!block_job_is_internal(job)) { 47833e9e9bdSKevin Wolf qapi_event_send_block_job_error(job->job.id, 4795a2d2cbdSWenchao Xia is_read ? IO_OPERATION_TYPE_READ : 4805a2d2cbdSWenchao Xia IO_OPERATION_TYPE_WRITE, 4815a2d2cbdSWenchao Xia action, &error_abort); 482559b935fSJohn Snow } 483a589569fSWenchao Xia if (action == BLOCK_ERROR_ACTION_STOP) { 484b15de828SKevin Wolf job_pause(&job->job); 485751ebd76SFam Zheng /* make the pause user visible, which will be resumed from QMP. */ 486b15de828SKevin Wolf job->job.user_paused = true; 48732c81a4aSPaolo Bonzini block_job_iostatus_set_err(job, error); 48832c81a4aSPaolo Bonzini } 48932c81a4aSPaolo Bonzini return action; 49032c81a4aSPaolo Bonzini } 491