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" 377f0317cfSAlberto Garcia #include "qemu/id.h" 381de7afc9SPaolo Bonzini #include "qemu/timer.h" 392f0c9fe6SPaolo Bonzini 40fc24908eSPaolo Bonzini /* Right now, this mutex is only needed to synchronize accesses to job->busy 41fc24908eSPaolo Bonzini * and job->sleep_timer, such as concurrent calls to block_job_do_yield and 42fc24908eSPaolo Bonzini * block_job_enter. */ 43fc24908eSPaolo Bonzini static QemuMutex block_job_mutex; 44fc24908eSPaolo Bonzini 45c9de4050SJohn Snow /* BlockJob State Transition Table */ 46c9de4050SJohn Snow bool BlockJobSTT[BLOCK_JOB_STATUS__MAX][BLOCK_JOB_STATUS__MAX] = { 47*5f241594SJohn Snow /* U, C, R, P, Y, S, W, D, X, E, N */ 48*5f241594SJohn Snow /* U: */ [BLOCK_JOB_STATUS_UNDEFINED] = {0, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0}, 49*5f241594SJohn Snow /* C: */ [BLOCK_JOB_STATUS_CREATED] = {0, 0, 1, 0, 0, 0, 0, 0, 1, 0, 1}, 50*5f241594SJohn Snow /* R: */ [BLOCK_JOB_STATUS_RUNNING] = {0, 0, 0, 1, 1, 0, 1, 0, 1, 0, 0}, 51*5f241594SJohn Snow /* P: */ [BLOCK_JOB_STATUS_PAUSED] = {0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 0}, 52*5f241594SJohn Snow /* Y: */ [BLOCK_JOB_STATUS_READY] = {0, 0, 0, 0, 0, 1, 1, 0, 1, 0, 0}, 53*5f241594SJohn Snow /* S: */ [BLOCK_JOB_STATUS_STANDBY] = {0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0}, 54*5f241594SJohn Snow /* W: */ [BLOCK_JOB_STATUS_WAITING] = {0, 0, 0, 0, 0, 0, 0, 1, 1, 0, 0}, 55*5f241594SJohn Snow /* D: */ [BLOCK_JOB_STATUS_PENDING] = {0, 0, 0, 0, 0, 0, 0, 0, 1, 1, 0}, 56*5f241594SJohn Snow /* X: */ [BLOCK_JOB_STATUS_ABORTING] = {0, 0, 0, 0, 0, 0, 0, 0, 1, 1, 0}, 57*5f241594SJohn Snow /* E: */ [BLOCK_JOB_STATUS_CONCLUDED] = {0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1}, 58*5f241594SJohn Snow /* N: */ [BLOCK_JOB_STATUS_NULL] = {0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0}, 59c9de4050SJohn Snow }; 60c9de4050SJohn Snow 610ec4dfb8SJohn Snow bool BlockJobVerbTable[BLOCK_JOB_VERB__MAX][BLOCK_JOB_STATUS__MAX] = { 62*5f241594SJohn Snow /* U, C, R, P, Y, S, W, D, X, E, N */ 63*5f241594SJohn Snow [BLOCK_JOB_VERB_CANCEL] = {0, 1, 1, 1, 1, 1, 1, 1, 0, 0, 0}, 64*5f241594SJohn Snow [BLOCK_JOB_VERB_PAUSE] = {0, 1, 1, 1, 1, 1, 0, 0, 0, 0, 0}, 65*5f241594SJohn Snow [BLOCK_JOB_VERB_RESUME] = {0, 1, 1, 1, 1, 1, 0, 0, 0, 0, 0}, 66*5f241594SJohn Snow [BLOCK_JOB_VERB_SET_SPEED] = {0, 1, 1, 1, 1, 1, 0, 0, 0, 0, 0}, 67*5f241594SJohn Snow [BLOCK_JOB_VERB_COMPLETE] = {0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0}, 68*5f241594SJohn Snow [BLOCK_JOB_VERB_DISMISS] = {0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0}, 690ec4dfb8SJohn Snow }; 700ec4dfb8SJohn Snow 71c9de4050SJohn Snow static void block_job_state_transition(BlockJob *job, BlockJobStatus s1) 72c9de4050SJohn Snow { 73c9de4050SJohn Snow BlockJobStatus s0 = job->status; 74c9de4050SJohn Snow assert(s1 >= 0 && s1 <= BLOCK_JOB_STATUS__MAX); 75c9de4050SJohn Snow trace_block_job_state_transition(job, job->ret, BlockJobSTT[s0][s1] ? 76c9de4050SJohn Snow "allowed" : "disallowed", 77c9de4050SJohn Snow qapi_enum_lookup(&BlockJobStatus_lookup, 78c9de4050SJohn Snow s0), 79c9de4050SJohn Snow qapi_enum_lookup(&BlockJobStatus_lookup, 80c9de4050SJohn Snow s1)); 81c9de4050SJohn Snow assert(BlockJobSTT[s0][s1]); 82c9de4050SJohn Snow job->status = s1; 83c9de4050SJohn Snow } 84c9de4050SJohn Snow 850ec4dfb8SJohn Snow static int block_job_apply_verb(BlockJob *job, BlockJobVerb bv, Error **errp) 860ec4dfb8SJohn Snow { 870ec4dfb8SJohn Snow assert(bv >= 0 && bv <= BLOCK_JOB_VERB__MAX); 880ec4dfb8SJohn Snow trace_block_job_apply_verb(job, qapi_enum_lookup(&BlockJobStatus_lookup, 890ec4dfb8SJohn Snow job->status), 900ec4dfb8SJohn Snow qapi_enum_lookup(&BlockJobVerb_lookup, bv), 910ec4dfb8SJohn Snow BlockJobVerbTable[bv][job->status] ? 920ec4dfb8SJohn Snow "allowed" : "prohibited"); 930ec4dfb8SJohn Snow if (BlockJobVerbTable[bv][job->status]) { 940ec4dfb8SJohn Snow return 0; 950ec4dfb8SJohn Snow } 960ec4dfb8SJohn Snow error_setg(errp, "Job '%s' in state '%s' cannot accept command verb '%s'", 970ec4dfb8SJohn Snow job->id, qapi_enum_lookup(&BlockJobStatus_lookup, job->status), 980ec4dfb8SJohn Snow qapi_enum_lookup(&BlockJobVerb_lookup, bv)); 990ec4dfb8SJohn Snow return -EPERM; 1000ec4dfb8SJohn Snow } 1010ec4dfb8SJohn Snow 102fc24908eSPaolo Bonzini static void block_job_lock(void) 103fc24908eSPaolo Bonzini { 104fc24908eSPaolo Bonzini qemu_mutex_lock(&block_job_mutex); 105fc24908eSPaolo Bonzini } 106fc24908eSPaolo Bonzini 107fc24908eSPaolo Bonzini static void block_job_unlock(void) 108fc24908eSPaolo Bonzini { 109fc24908eSPaolo Bonzini qemu_mutex_unlock(&block_job_mutex); 110fc24908eSPaolo Bonzini } 111fc24908eSPaolo Bonzini 112fc24908eSPaolo Bonzini static void __attribute__((__constructor__)) block_job_init(void) 113fc24908eSPaolo Bonzini { 114fc24908eSPaolo Bonzini qemu_mutex_init(&block_job_mutex); 115fc24908eSPaolo Bonzini } 116fc24908eSPaolo Bonzini 1178254b6d9SJohn Snow static void block_job_event_cancelled(BlockJob *job); 1188254b6d9SJohn Snow static void block_job_event_completed(BlockJob *job, const char *msg); 119*5f241594SJohn Snow static int block_job_event_pending(BlockJob *job); 120aa9ef2e6SJohn Snow static void block_job_enter_cond(BlockJob *job, bool(*fn)(BlockJob *job)); 1218254b6d9SJohn Snow 122c55a832fSFam Zheng /* Transactional group of block jobs */ 123c55a832fSFam Zheng struct BlockJobTxn { 124c55a832fSFam Zheng 125c55a832fSFam Zheng /* Is this txn being cancelled? */ 126c55a832fSFam Zheng bool aborting; 127c55a832fSFam Zheng 128c55a832fSFam Zheng /* List of jobs */ 129c55a832fSFam Zheng QLIST_HEAD(, BlockJob) jobs; 130c55a832fSFam Zheng 131c55a832fSFam Zheng /* Reference count */ 132c55a832fSFam Zheng int refcnt; 133c55a832fSFam Zheng }; 134c55a832fSFam Zheng 135a7112795SAlberto Garcia static QLIST_HEAD(, BlockJob) block_jobs = QLIST_HEAD_INITIALIZER(block_jobs); 136a7112795SAlberto Garcia 13788691b37SPaolo Bonzini /* 13888691b37SPaolo Bonzini * The block job API is composed of two categories of functions. 13988691b37SPaolo Bonzini * 14088691b37SPaolo Bonzini * The first includes functions used by the monitor. The monitor is 14188691b37SPaolo Bonzini * peculiar in that it accesses the block job list with block_job_get, and 14288691b37SPaolo Bonzini * therefore needs consistency across block_job_get and the actual operation 14388691b37SPaolo Bonzini * (e.g. block_job_set_speed). The consistency is achieved with 14488691b37SPaolo Bonzini * aio_context_acquire/release. These functions are declared in blockjob.h. 14588691b37SPaolo Bonzini * 14688691b37SPaolo Bonzini * The second includes functions used by the block job drivers and sometimes 14788691b37SPaolo Bonzini * by the core block layer. These do not care about locking, because the 14888691b37SPaolo Bonzini * whole coroutine runs under the AioContext lock, and are declared in 14988691b37SPaolo Bonzini * blockjob_int.h. 15088691b37SPaolo Bonzini */ 15188691b37SPaolo Bonzini 152a7112795SAlberto Garcia BlockJob *block_job_next(BlockJob *job) 153a7112795SAlberto Garcia { 154a7112795SAlberto Garcia if (!job) { 155a7112795SAlberto Garcia return QLIST_FIRST(&block_jobs); 156a7112795SAlberto Garcia } 157a7112795SAlberto Garcia return QLIST_NEXT(job, job_list); 158a7112795SAlberto Garcia } 159a7112795SAlberto Garcia 160ffb1f10cSAlberto Garcia BlockJob *block_job_get(const char *id) 161ffb1f10cSAlberto Garcia { 162ffb1f10cSAlberto Garcia BlockJob *job; 163ffb1f10cSAlberto Garcia 164ffb1f10cSAlberto Garcia QLIST_FOREACH(job, &block_jobs, job_list) { 165559b935fSJohn Snow if (job->id && !strcmp(id, job->id)) { 166ffb1f10cSAlberto Garcia return job; 167ffb1f10cSAlberto Garcia } 168ffb1f10cSAlberto Garcia } 169ffb1f10cSAlberto Garcia 170ffb1f10cSAlberto Garcia return NULL; 171ffb1f10cSAlberto Garcia } 172ffb1f10cSAlberto Garcia 173c8ab5c2dSPaolo Bonzini BlockJobTxn *block_job_txn_new(void) 174c8ab5c2dSPaolo Bonzini { 175c8ab5c2dSPaolo Bonzini BlockJobTxn *txn = g_new0(BlockJobTxn, 1); 176c8ab5c2dSPaolo Bonzini QLIST_INIT(&txn->jobs); 177c8ab5c2dSPaolo Bonzini txn->refcnt = 1; 178c8ab5c2dSPaolo Bonzini return txn; 179c8ab5c2dSPaolo Bonzini } 180c8ab5c2dSPaolo Bonzini 181c8ab5c2dSPaolo Bonzini static void block_job_txn_ref(BlockJobTxn *txn) 182c8ab5c2dSPaolo Bonzini { 183c8ab5c2dSPaolo Bonzini txn->refcnt++; 184c8ab5c2dSPaolo Bonzini } 185c8ab5c2dSPaolo Bonzini 186c8ab5c2dSPaolo Bonzini void block_job_txn_unref(BlockJobTxn *txn) 187c8ab5c2dSPaolo Bonzini { 188c8ab5c2dSPaolo Bonzini if (txn && --txn->refcnt == 0) { 189c8ab5c2dSPaolo Bonzini g_free(txn); 190c8ab5c2dSPaolo Bonzini } 191c8ab5c2dSPaolo Bonzini } 192c8ab5c2dSPaolo Bonzini 193c8ab5c2dSPaolo Bonzini void block_job_txn_add_job(BlockJobTxn *txn, BlockJob *job) 194c8ab5c2dSPaolo Bonzini { 195c8ab5c2dSPaolo Bonzini if (!txn) { 196c8ab5c2dSPaolo Bonzini return; 197c8ab5c2dSPaolo Bonzini } 198c8ab5c2dSPaolo Bonzini 199c8ab5c2dSPaolo Bonzini assert(!job->txn); 200c8ab5c2dSPaolo Bonzini job->txn = txn; 201c8ab5c2dSPaolo Bonzini 202c8ab5c2dSPaolo Bonzini QLIST_INSERT_HEAD(&txn->jobs, job, txn_list); 203c8ab5c2dSPaolo Bonzini block_job_txn_ref(txn); 204c8ab5c2dSPaolo Bonzini } 205c8ab5c2dSPaolo Bonzini 206f321dcb5SPaolo Bonzini static void block_job_pause(BlockJob *job) 207f321dcb5SPaolo Bonzini { 208f321dcb5SPaolo Bonzini job->pause_count++; 209f321dcb5SPaolo Bonzini } 210f321dcb5SPaolo Bonzini 211f321dcb5SPaolo Bonzini static void block_job_resume(BlockJob *job) 212f321dcb5SPaolo Bonzini { 213f321dcb5SPaolo Bonzini assert(job->pause_count > 0); 214f321dcb5SPaolo Bonzini job->pause_count--; 215f321dcb5SPaolo Bonzini if (job->pause_count) { 216f321dcb5SPaolo Bonzini return; 217f321dcb5SPaolo Bonzini } 218f321dcb5SPaolo Bonzini block_job_enter(job); 219f321dcb5SPaolo Bonzini } 220f321dcb5SPaolo Bonzini 2214172a003Ssochin.jiang void block_job_ref(BlockJob *job) 22205b0d8e3SPaolo Bonzini { 22305b0d8e3SPaolo Bonzini ++job->refcnt; 22405b0d8e3SPaolo Bonzini } 22505b0d8e3SPaolo Bonzini 22605b0d8e3SPaolo Bonzini static void block_job_attached_aio_context(AioContext *new_context, 22705b0d8e3SPaolo Bonzini void *opaque); 22805b0d8e3SPaolo Bonzini static void block_job_detach_aio_context(void *opaque); 22905b0d8e3SPaolo Bonzini 2304172a003Ssochin.jiang void block_job_unref(BlockJob *job) 23105b0d8e3SPaolo Bonzini { 23205b0d8e3SPaolo Bonzini if (--job->refcnt == 0) { 2333925cd3bSJohn Snow assert(job->status == BLOCK_JOB_STATUS_NULL); 23405b0d8e3SPaolo Bonzini BlockDriverState *bs = blk_bs(job->blk); 2350a3e155fSAlberto Garcia QLIST_REMOVE(job, job_list); 23605b0d8e3SPaolo Bonzini bs->job = NULL; 23705b0d8e3SPaolo Bonzini block_job_remove_all_bdrv(job); 23805b0d8e3SPaolo Bonzini blk_remove_aio_context_notifier(job->blk, 23905b0d8e3SPaolo Bonzini block_job_attached_aio_context, 24005b0d8e3SPaolo Bonzini block_job_detach_aio_context, job); 24105b0d8e3SPaolo Bonzini blk_unref(job->blk); 24205b0d8e3SPaolo Bonzini error_free(job->blocker); 24305b0d8e3SPaolo Bonzini g_free(job->id); 244fc24908eSPaolo Bonzini assert(!timer_pending(&job->sleep_timer)); 24505b0d8e3SPaolo Bonzini g_free(job); 24605b0d8e3SPaolo Bonzini } 24705b0d8e3SPaolo Bonzini } 24805b0d8e3SPaolo Bonzini 249463e0be1SStefan Hajnoczi static void block_job_attached_aio_context(AioContext *new_context, 250463e0be1SStefan Hajnoczi void *opaque) 251463e0be1SStefan Hajnoczi { 252463e0be1SStefan Hajnoczi BlockJob *job = opaque; 253463e0be1SStefan Hajnoczi 254463e0be1SStefan Hajnoczi if (job->driver->attached_aio_context) { 255463e0be1SStefan Hajnoczi job->driver->attached_aio_context(job, new_context); 256463e0be1SStefan Hajnoczi } 257463e0be1SStefan Hajnoczi 258463e0be1SStefan Hajnoczi block_job_resume(job); 259463e0be1SStefan Hajnoczi } 260463e0be1SStefan Hajnoczi 261bae8196dSPaolo Bonzini static void block_job_drain(BlockJob *job) 262bae8196dSPaolo Bonzini { 263bae8196dSPaolo Bonzini /* If job is !job->busy this kicks it into the next pause point. */ 264bae8196dSPaolo Bonzini block_job_enter(job); 265bae8196dSPaolo Bonzini 266bae8196dSPaolo Bonzini blk_drain(job->blk); 267bae8196dSPaolo Bonzini if (job->driver->drain) { 268bae8196dSPaolo Bonzini job->driver->drain(job); 269bae8196dSPaolo Bonzini } 270bae8196dSPaolo Bonzini } 271bae8196dSPaolo Bonzini 272463e0be1SStefan Hajnoczi static void block_job_detach_aio_context(void *opaque) 273463e0be1SStefan Hajnoczi { 274463e0be1SStefan Hajnoczi BlockJob *job = opaque; 275463e0be1SStefan Hajnoczi 276463e0be1SStefan Hajnoczi /* In case the job terminates during aio_poll()... */ 277463e0be1SStefan Hajnoczi block_job_ref(job); 278463e0be1SStefan Hajnoczi 279463e0be1SStefan Hajnoczi block_job_pause(job); 280463e0be1SStefan Hajnoczi 281463e0be1SStefan Hajnoczi while (!job->paused && !job->completed) { 282bae8196dSPaolo Bonzini block_job_drain(job); 283463e0be1SStefan Hajnoczi } 284463e0be1SStefan Hajnoczi 285463e0be1SStefan Hajnoczi block_job_unref(job); 286463e0be1SStefan Hajnoczi } 287463e0be1SStefan Hajnoczi 288f321dcb5SPaolo Bonzini static char *child_job_get_parent_desc(BdrvChild *c) 289f321dcb5SPaolo Bonzini { 290f321dcb5SPaolo Bonzini BlockJob *job = c->opaque; 291f321dcb5SPaolo Bonzini return g_strdup_printf("%s job '%s'", 292977c736fSMarkus Armbruster BlockJobType_str(job->driver->job_type), 293f321dcb5SPaolo Bonzini job->id); 294f321dcb5SPaolo Bonzini } 295f321dcb5SPaolo Bonzini 296ad90febaSKevin Wolf static void child_job_drained_begin(BdrvChild *c) 297f321dcb5SPaolo Bonzini { 298ad90febaSKevin Wolf BlockJob *job = c->opaque; 299f321dcb5SPaolo Bonzini block_job_pause(job); 300f321dcb5SPaolo Bonzini } 301f321dcb5SPaolo Bonzini 302ad90febaSKevin Wolf static void child_job_drained_end(BdrvChild *c) 303f321dcb5SPaolo Bonzini { 304ad90febaSKevin Wolf BlockJob *job = c->opaque; 305f321dcb5SPaolo Bonzini block_job_resume(job); 306f321dcb5SPaolo Bonzini } 307f321dcb5SPaolo Bonzini 308ad90febaSKevin Wolf static const BdrvChildRole child_job = { 309ad90febaSKevin Wolf .get_parent_desc = child_job_get_parent_desc, 310ad90febaSKevin Wolf .drained_begin = child_job_drained_begin, 311ad90febaSKevin Wolf .drained_end = child_job_drained_end, 312ad90febaSKevin Wolf .stay_at_node = true, 313f321dcb5SPaolo Bonzini }; 314f321dcb5SPaolo Bonzini 315bbc02b90SKevin Wolf void block_job_remove_all_bdrv(BlockJob *job) 316bbc02b90SKevin Wolf { 317bbc02b90SKevin Wolf GSList *l; 318bbc02b90SKevin Wolf for (l = job->nodes; l; l = l->next) { 319bbc02b90SKevin Wolf BdrvChild *c = l->data; 320bbc02b90SKevin Wolf bdrv_op_unblock_all(c->bs, job->blocker); 321bbc02b90SKevin Wolf bdrv_root_unref_child(c); 322bbc02b90SKevin Wolf } 323bbc02b90SKevin Wolf g_slist_free(job->nodes); 324bbc02b90SKevin Wolf job->nodes = NULL; 325bbc02b90SKevin Wolf } 326bbc02b90SKevin Wolf 32776d554e2SKevin Wolf int block_job_add_bdrv(BlockJob *job, const char *name, BlockDriverState *bs, 32876d554e2SKevin Wolf uint64_t perm, uint64_t shared_perm, Error **errp) 32923d402d4SAlberto Garcia { 33076d554e2SKevin Wolf BdrvChild *c; 33176d554e2SKevin Wolf 33276d554e2SKevin Wolf c = bdrv_root_attach_child(bs, name, &child_job, perm, shared_perm, 33376d554e2SKevin Wolf job, errp); 33476d554e2SKevin Wolf if (c == NULL) { 33576d554e2SKevin Wolf return -EPERM; 33676d554e2SKevin Wolf } 33776d554e2SKevin Wolf 33876d554e2SKevin Wolf job->nodes = g_slist_prepend(job->nodes, c); 33923d402d4SAlberto Garcia bdrv_ref(bs); 34023d402d4SAlberto Garcia bdrv_op_block_all(bs, job->blocker); 34176d554e2SKevin Wolf 34276d554e2SKevin Wolf return 0; 34323d402d4SAlberto Garcia } 34423d402d4SAlberto Garcia 345559b935fSJohn Snow bool block_job_is_internal(BlockJob *job) 346559b935fSJohn Snow { 347559b935fSJohn Snow return (job->id == NULL); 348559b935fSJohn Snow } 349559b935fSJohn Snow 3505ccac6f1SJohn Snow static bool block_job_started(BlockJob *job) 3515ccac6f1SJohn Snow { 3525ccac6f1SJohn Snow return job->co; 3535ccac6f1SJohn Snow } 3545ccac6f1SJohn Snow 355e3796a24SJohn Snow /** 356e3796a24SJohn Snow * All jobs must allow a pause point before entering their job proper. This 357e3796a24SJohn Snow * ensures that jobs can be paused prior to being started, then resumed later. 358e3796a24SJohn Snow */ 359e3796a24SJohn Snow static void coroutine_fn block_job_co_entry(void *opaque) 360e3796a24SJohn Snow { 361e3796a24SJohn Snow BlockJob *job = opaque; 362e3796a24SJohn Snow 363e3796a24SJohn Snow assert(job && job->driver && job->driver->start); 364e3796a24SJohn Snow block_job_pause_point(job); 365e3796a24SJohn Snow job->driver->start(job); 366e3796a24SJohn Snow } 367e3796a24SJohn Snow 368fc24908eSPaolo Bonzini static void block_job_sleep_timer_cb(void *opaque) 369fc24908eSPaolo Bonzini { 370fc24908eSPaolo Bonzini BlockJob *job = opaque; 371fc24908eSPaolo Bonzini 372fc24908eSPaolo Bonzini block_job_enter(job); 373fc24908eSPaolo Bonzini } 374fc24908eSPaolo Bonzini 3755ccac6f1SJohn Snow void block_job_start(BlockJob *job) 3765ccac6f1SJohn Snow { 3775ccac6f1SJohn Snow assert(job && !block_job_started(job) && job->paused && 378e3796a24SJohn Snow job->driver && job->driver->start); 379e3796a24SJohn Snow job->co = qemu_coroutine_create(block_job_co_entry, job); 380e3796a24SJohn Snow job->pause_count--; 3815ccac6f1SJohn Snow job->busy = true; 382e3796a24SJohn Snow job->paused = false; 383c9de4050SJohn Snow block_job_state_transition(job, BLOCK_JOB_STATUS_RUNNING); 384aef4278cSFam Zheng bdrv_coroutine_enter(blk_bs(job->blk), job->co); 3855ccac6f1SJohn Snow } 3865ccac6f1SJohn Snow 3873925cd3bSJohn Snow static void block_job_decommission(BlockJob *job) 3883925cd3bSJohn Snow { 3893925cd3bSJohn Snow assert(job); 3903925cd3bSJohn Snow job->completed = true; 3913925cd3bSJohn Snow job->busy = false; 3923925cd3bSJohn Snow job->paused = false; 3933925cd3bSJohn Snow job->deferred_to_main_loop = true; 3943925cd3bSJohn Snow block_job_state_transition(job, BLOCK_JOB_STATUS_NULL); 3953925cd3bSJohn Snow block_job_unref(job); 3963925cd3bSJohn Snow } 3973925cd3bSJohn Snow 39875f71059SJohn Snow static void block_job_do_dismiss(BlockJob *job) 39975f71059SJohn Snow { 40075f71059SJohn Snow block_job_decommission(job); 40175f71059SJohn Snow } 40275f71059SJohn Snow 403e0cf0364SJohn Snow static void block_job_conclude(BlockJob *job) 404e0cf0364SJohn Snow { 405e0cf0364SJohn Snow block_job_state_transition(job, BLOCK_JOB_STATUS_CONCLUDED); 40675f71059SJohn Snow if (job->auto_dismiss || !block_job_started(job)) { 40775f71059SJohn Snow block_job_do_dismiss(job); 40875f71059SJohn Snow } 409e0cf0364SJohn Snow } 410e0cf0364SJohn Snow 41135d6b368SJohn Snow static void block_job_update_rc(BlockJob *job) 41235d6b368SJohn Snow { 41335d6b368SJohn Snow if (!job->ret && block_job_is_cancelled(job)) { 41435d6b368SJohn Snow job->ret = -ECANCELED; 41535d6b368SJohn Snow } 41635d6b368SJohn Snow if (job->ret) { 41735d6b368SJohn Snow block_job_state_transition(job, BLOCK_JOB_STATUS_ABORTING); 41835d6b368SJohn Snow } 41935d6b368SJohn Snow } 42035d6b368SJohn Snow 4212da4617aSJohn Snow static int block_job_prepare(BlockJob *job) 4222da4617aSJohn Snow { 4232da4617aSJohn Snow if (job->ret == 0 && job->driver->prepare) { 4242da4617aSJohn Snow job->ret = job->driver->prepare(job); 4252da4617aSJohn Snow } 4262da4617aSJohn Snow return job->ret; 4272da4617aSJohn Snow } 4282da4617aSJohn Snow 42943628d93SJohn Snow static void block_job_commit(BlockJob *job) 43043628d93SJohn Snow { 43143628d93SJohn Snow assert(!job->ret); 43243628d93SJohn Snow if (job->driver->commit) { 43343628d93SJohn Snow job->driver->commit(job); 43443628d93SJohn Snow } 43543628d93SJohn Snow } 43643628d93SJohn Snow 43743628d93SJohn Snow static void block_job_abort(BlockJob *job) 43843628d93SJohn Snow { 43943628d93SJohn Snow assert(job->ret); 44043628d93SJohn Snow if (job->driver->abort) { 44143628d93SJohn Snow job->driver->abort(job); 44243628d93SJohn Snow } 44343628d93SJohn Snow } 44443628d93SJohn Snow 44543628d93SJohn Snow static void block_job_clean(BlockJob *job) 44643628d93SJohn Snow { 44743628d93SJohn Snow if (job->driver->clean) { 44843628d93SJohn Snow job->driver->clean(job); 44943628d93SJohn Snow } 45043628d93SJohn Snow } 45143628d93SJohn Snow 4522da4617aSJohn Snow static int block_job_completed_single(BlockJob *job) 453c55a832fSFam Zheng { 4544fb588e9SPaolo Bonzini assert(job->completed); 4554fb588e9SPaolo Bonzini 45635d6b368SJohn Snow /* Ensure abort is called for late-transactional failures */ 45735d6b368SJohn Snow block_job_update_rc(job); 45810a3fbb0SJohn Snow 459c55a832fSFam Zheng if (!job->ret) { 46043628d93SJohn Snow block_job_commit(job); 461c55a832fSFam Zheng } else { 46243628d93SJohn Snow block_job_abort(job); 463c55a832fSFam Zheng } 46443628d93SJohn Snow block_job_clean(job); 4658254b6d9SJohn Snow 4668254b6d9SJohn Snow if (job->cb) { 467c55a832fSFam Zheng job->cb(job->opaque, job->ret); 4688254b6d9SJohn Snow } 4695ccac6f1SJohn Snow 4705ccac6f1SJohn Snow /* Emit events only if we actually started */ 4715ccac6f1SJohn Snow if (block_job_started(job)) { 4728254b6d9SJohn Snow if (block_job_is_cancelled(job)) { 4738254b6d9SJohn Snow block_job_event_cancelled(job); 4748254b6d9SJohn Snow } else { 4758254b6d9SJohn Snow const char *msg = NULL; 4768254b6d9SJohn Snow if (job->ret < 0) { 4778254b6d9SJohn Snow msg = strerror(-job->ret); 4788254b6d9SJohn Snow } 4798254b6d9SJohn Snow block_job_event_completed(job, msg); 4808254b6d9SJohn Snow } 4815ccac6f1SJohn Snow } 4828254b6d9SJohn Snow 4831e93b9fbSVladimir Sementsov-Ogievskiy QLIST_REMOVE(job, txn_list); 484c55a832fSFam Zheng block_job_txn_unref(job->txn); 485e0cf0364SJohn Snow block_job_conclude(job); 4862da4617aSJohn Snow return 0; 487c55a832fSFam Zheng } 488c55a832fSFam Zheng 4894c241cf5SPaolo Bonzini static void block_job_cancel_async(BlockJob *job) 4904c241cf5SPaolo Bonzini { 4914c241cf5SPaolo Bonzini if (job->iostatus != BLOCK_DEVICE_IO_STATUS_OK) { 4924c241cf5SPaolo Bonzini block_job_iostatus_reset(job); 4934c241cf5SPaolo Bonzini } 4944c241cf5SPaolo Bonzini if (job->user_paused) { 4954c241cf5SPaolo Bonzini /* Do not call block_job_enter here, the caller will handle it. */ 4964c241cf5SPaolo Bonzini job->user_paused = false; 4974c241cf5SPaolo Bonzini job->pause_count--; 4984c241cf5SPaolo Bonzini } 4994c241cf5SPaolo Bonzini job->cancelled = true; 5004c241cf5SPaolo Bonzini } 5014c241cf5SPaolo Bonzini 502*5f241594SJohn Snow static int block_job_txn_apply(BlockJobTxn *txn, int fn(BlockJob *), bool lock) 503efe4d4b7SJohn Snow { 504efe4d4b7SJohn Snow AioContext *ctx; 505efe4d4b7SJohn Snow BlockJob *job, *next; 5062da4617aSJohn Snow int rc = 0; 507efe4d4b7SJohn Snow 508efe4d4b7SJohn Snow QLIST_FOREACH_SAFE(job, &txn->jobs, txn_list, next) { 509*5f241594SJohn Snow if (lock) { 510efe4d4b7SJohn Snow ctx = blk_get_aio_context(job->blk); 511efe4d4b7SJohn Snow aio_context_acquire(ctx); 512*5f241594SJohn Snow } 5132da4617aSJohn Snow rc = fn(job); 514*5f241594SJohn Snow if (lock) { 515efe4d4b7SJohn Snow aio_context_release(ctx); 516*5f241594SJohn Snow } 5172da4617aSJohn Snow if (rc) { 5182da4617aSJohn Snow break; 519efe4d4b7SJohn Snow } 520efe4d4b7SJohn Snow } 5212da4617aSJohn Snow return rc; 5222da4617aSJohn Snow } 523efe4d4b7SJohn Snow 524c8ab5c2dSPaolo Bonzini static int block_job_finish_sync(BlockJob *job, 525c8ab5c2dSPaolo Bonzini void (*finish)(BlockJob *, Error **errp), 526c8ab5c2dSPaolo Bonzini Error **errp) 527c8ab5c2dSPaolo Bonzini { 528c8ab5c2dSPaolo Bonzini Error *local_err = NULL; 529c8ab5c2dSPaolo Bonzini int ret; 530c8ab5c2dSPaolo Bonzini 531c8ab5c2dSPaolo Bonzini assert(blk_bs(job->blk)->job == job); 532c8ab5c2dSPaolo Bonzini 533c8ab5c2dSPaolo Bonzini block_job_ref(job); 534c8ab5c2dSPaolo Bonzini 5354fb588e9SPaolo Bonzini if (finish) { 536c8ab5c2dSPaolo Bonzini finish(job, &local_err); 5374fb588e9SPaolo Bonzini } 538c8ab5c2dSPaolo Bonzini if (local_err) { 539c8ab5c2dSPaolo Bonzini error_propagate(errp, local_err); 540c8ab5c2dSPaolo Bonzini block_job_unref(job); 541c8ab5c2dSPaolo Bonzini return -EBUSY; 542c8ab5c2dSPaolo Bonzini } 543c8ab5c2dSPaolo Bonzini /* block_job_drain calls block_job_enter, and it should be enough to 544c8ab5c2dSPaolo Bonzini * induce progress until the job completes or moves to the main thread. 545c8ab5c2dSPaolo Bonzini */ 546c8ab5c2dSPaolo Bonzini while (!job->deferred_to_main_loop && !job->completed) { 547c8ab5c2dSPaolo Bonzini block_job_drain(job); 548c8ab5c2dSPaolo Bonzini } 549c8ab5c2dSPaolo Bonzini while (!job->completed) { 550c8ab5c2dSPaolo Bonzini aio_poll(qemu_get_aio_context(), true); 551c8ab5c2dSPaolo Bonzini } 552c8ab5c2dSPaolo Bonzini ret = (job->cancelled && job->ret == 0) ? -ECANCELED : job->ret; 553c8ab5c2dSPaolo Bonzini block_job_unref(job); 554c8ab5c2dSPaolo Bonzini return ret; 555c8ab5c2dSPaolo Bonzini } 556c8ab5c2dSPaolo Bonzini 557c55a832fSFam Zheng static void block_job_completed_txn_abort(BlockJob *job) 558c55a832fSFam Zheng { 559c55a832fSFam Zheng AioContext *ctx; 560c55a832fSFam Zheng BlockJobTxn *txn = job->txn; 5614fb588e9SPaolo Bonzini BlockJob *other_job; 562c55a832fSFam Zheng 563c55a832fSFam Zheng if (txn->aborting) { 564c55a832fSFam Zheng /* 565c55a832fSFam Zheng * We are cancelled by another job, which will handle everything. 566c55a832fSFam Zheng */ 567c55a832fSFam Zheng return; 568c55a832fSFam Zheng } 569c55a832fSFam Zheng txn->aborting = true; 5704fb588e9SPaolo Bonzini block_job_txn_ref(txn); 5714fb588e9SPaolo Bonzini 572c55a832fSFam Zheng /* We are the first failed job. Cancel other jobs. */ 573c55a832fSFam Zheng QLIST_FOREACH(other_job, &txn->jobs, txn_list) { 574b6d2e599SKevin Wolf ctx = blk_get_aio_context(other_job->blk); 575c55a832fSFam Zheng aio_context_acquire(ctx); 576c55a832fSFam Zheng } 5774fb588e9SPaolo Bonzini 5784fb588e9SPaolo Bonzini /* Other jobs are effectively cancelled by us, set the status for 579c55a832fSFam Zheng * them; this job, however, may or may not be cancelled, depending 580c55a832fSFam Zheng * on the caller, so leave it. */ 5814fb588e9SPaolo Bonzini QLIST_FOREACH(other_job, &txn->jobs, txn_list) { 582c55a832fSFam Zheng if (other_job != job) { 5834c241cf5SPaolo Bonzini block_job_cancel_async(other_job); 584c55a832fSFam Zheng } 585c55a832fSFam Zheng } 5864fb588e9SPaolo Bonzini while (!QLIST_EMPTY(&txn->jobs)) { 5874fb588e9SPaolo Bonzini other_job = QLIST_FIRST(&txn->jobs); 588b6d2e599SKevin Wolf ctx = blk_get_aio_context(other_job->blk); 5894fb588e9SPaolo Bonzini if (!other_job->completed) { 5904fb588e9SPaolo Bonzini assert(other_job->cancelled); 5914fb588e9SPaolo Bonzini block_job_finish_sync(other_job, NULL, NULL); 5924fb588e9SPaolo Bonzini } 593c55a832fSFam Zheng block_job_completed_single(other_job); 594c55a832fSFam Zheng aio_context_release(ctx); 595c55a832fSFam Zheng } 5964fb588e9SPaolo Bonzini 5974fb588e9SPaolo Bonzini block_job_txn_unref(txn); 598c55a832fSFam Zheng } 599c55a832fSFam Zheng 600c55a832fSFam Zheng static void block_job_completed_txn_success(BlockJob *job) 601c55a832fSFam Zheng { 602c55a832fSFam Zheng BlockJobTxn *txn = job->txn; 603efe4d4b7SJohn Snow BlockJob *other_job; 6042da4617aSJohn Snow int rc = 0; 6052da4617aSJohn Snow 606e8af5686SJohn Snow block_job_state_transition(job, BLOCK_JOB_STATUS_WAITING); 607e8af5686SJohn Snow 608c55a832fSFam Zheng /* 609c55a832fSFam Zheng * Successful completion, see if there are other running jobs in this 610c55a832fSFam Zheng * txn. 611c55a832fSFam Zheng */ 612c55a832fSFam Zheng QLIST_FOREACH(other_job, &txn->jobs, txn_list) { 613c55a832fSFam Zheng if (!other_job->completed) { 614c55a832fSFam Zheng return; 615c55a832fSFam Zheng } 616efe4d4b7SJohn Snow assert(other_job->ret == 0); 617c55a832fSFam Zheng } 6182da4617aSJohn Snow 6192da4617aSJohn Snow /* Jobs may require some prep-work to complete without failure */ 620*5f241594SJohn Snow rc = block_job_txn_apply(txn, block_job_prepare, true); 6212da4617aSJohn Snow if (rc) { 6222da4617aSJohn Snow block_job_completed_txn_abort(job); 6232da4617aSJohn Snow return; 6242da4617aSJohn Snow } 6252da4617aSJohn Snow 626c55a832fSFam Zheng /* We are the last completed job, commit the transaction. */ 627*5f241594SJohn Snow block_job_txn_apply(txn, block_job_event_pending, false); 628*5f241594SJohn Snow block_job_txn_apply(txn, block_job_completed_single, true); 629c55a832fSFam Zheng } 630c55a832fSFam Zheng 631aa9ef2e6SJohn Snow /* Assumes the block_job_mutex is held */ 632aa9ef2e6SJohn Snow static bool block_job_timer_pending(BlockJob *job) 633aa9ef2e6SJohn Snow { 634aa9ef2e6SJohn Snow return timer_pending(&job->sleep_timer); 635aa9ef2e6SJohn Snow } 636aa9ef2e6SJohn Snow 6372f0c9fe6SPaolo Bonzini void block_job_set_speed(BlockJob *job, int64_t speed, Error **errp) 6382f0c9fe6SPaolo Bonzini { 6392f0c9fe6SPaolo Bonzini Error *local_err = NULL; 640aa9ef2e6SJohn Snow int64_t old_speed = job->speed; 6412f0c9fe6SPaolo Bonzini 6423fc4b10aSFam Zheng if (!job->driver->set_speed) { 643c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 6442f0c9fe6SPaolo Bonzini return; 6452f0c9fe6SPaolo Bonzini } 6460ec4dfb8SJohn Snow if (block_job_apply_verb(job, BLOCK_JOB_VERB_SET_SPEED, errp)) { 6470ec4dfb8SJohn Snow return; 6480ec4dfb8SJohn Snow } 6493fc4b10aSFam Zheng job->driver->set_speed(job, speed, &local_err); 65084d18f06SMarkus Armbruster if (local_err) { 6512f0c9fe6SPaolo Bonzini error_propagate(errp, local_err); 6522f0c9fe6SPaolo Bonzini return; 6532f0c9fe6SPaolo Bonzini } 6542f0c9fe6SPaolo Bonzini 6552f0c9fe6SPaolo Bonzini job->speed = speed; 656d4fce188SJohn Snow if (speed && speed <= old_speed) { 657aa9ef2e6SJohn Snow return; 658aa9ef2e6SJohn Snow } 659aa9ef2e6SJohn Snow 660aa9ef2e6SJohn Snow /* kick only if a timer is pending */ 661aa9ef2e6SJohn Snow block_job_enter_cond(job, block_job_timer_pending); 6622f0c9fe6SPaolo Bonzini } 6632f0c9fe6SPaolo Bonzini 664aeae883bSPaolo Bonzini void block_job_complete(BlockJob *job, Error **errp) 665aeae883bSPaolo Bonzini { 666559b935fSJohn Snow /* Should not be reachable via external interface for internal jobs */ 667559b935fSJohn Snow assert(job->id); 6680ec4dfb8SJohn Snow if (block_job_apply_verb(job, BLOCK_JOB_VERB_COMPLETE, errp)) { 6690ec4dfb8SJohn Snow return; 6700ec4dfb8SJohn Snow } 6710ec4dfb8SJohn Snow if (job->pause_count || job->cancelled || !job->driver->complete) { 6729df229c3SAlberto Garcia error_setg(errp, "The active block job '%s' cannot be completed", 6739df229c3SAlberto Garcia job->id); 674aeae883bSPaolo Bonzini return; 675aeae883bSPaolo Bonzini } 676aeae883bSPaolo Bonzini 6773fc4b10aSFam Zheng job->driver->complete(job, errp); 678aeae883bSPaolo Bonzini } 679aeae883bSPaolo Bonzini 68075f71059SJohn Snow void block_job_dismiss(BlockJob **jobptr, Error **errp) 68175f71059SJohn Snow { 68275f71059SJohn Snow BlockJob *job = *jobptr; 68375f71059SJohn Snow /* similarly to _complete, this is QMP-interface only. */ 68475f71059SJohn Snow assert(job->id); 68575f71059SJohn Snow if (block_job_apply_verb(job, BLOCK_JOB_VERB_DISMISS, errp)) { 68675f71059SJohn Snow return; 68775f71059SJohn Snow } 68875f71059SJohn Snow 68975f71059SJohn Snow block_job_do_dismiss(job); 69075f71059SJohn Snow *jobptr = NULL; 69175f71059SJohn Snow } 69275f71059SJohn Snow 6930ec4dfb8SJohn Snow void block_job_user_pause(BlockJob *job, Error **errp) 6940df4ba58SJohn Snow { 6950ec4dfb8SJohn Snow if (block_job_apply_verb(job, BLOCK_JOB_VERB_PAUSE, errp)) { 6960ec4dfb8SJohn Snow return; 6970ec4dfb8SJohn Snow } 6980ec4dfb8SJohn Snow if (job->user_paused) { 6990ec4dfb8SJohn Snow error_setg(errp, "Job is already paused"); 7000ec4dfb8SJohn Snow return; 7010ec4dfb8SJohn Snow } 7020df4ba58SJohn Snow job->user_paused = true; 7030df4ba58SJohn Snow block_job_pause(job); 7040df4ba58SJohn Snow } 7050df4ba58SJohn Snow 7060df4ba58SJohn Snow bool block_job_user_paused(BlockJob *job) 7070df4ba58SJohn Snow { 7086573d9c6SPaolo Bonzini return job->user_paused; 7090df4ba58SJohn Snow } 7100df4ba58SJohn Snow 7110ec4dfb8SJohn Snow void block_job_user_resume(BlockJob *job, Error **errp) 7120df4ba58SJohn Snow { 7130ec4dfb8SJohn Snow assert(job); 7140ec4dfb8SJohn Snow if (!job->user_paused || job->pause_count <= 0) { 7150ec4dfb8SJohn Snow error_setg(errp, "Can't resume a job that was not paused"); 7160ec4dfb8SJohn Snow return; 7170ec4dfb8SJohn Snow } 7180ec4dfb8SJohn Snow if (block_job_apply_verb(job, BLOCK_JOB_VERB_RESUME, errp)) { 7190ec4dfb8SJohn Snow return; 7200ec4dfb8SJohn Snow } 7212caf63a9SPaolo Bonzini block_job_iostatus_reset(job); 7224c241cf5SPaolo Bonzini job->user_paused = false; 7230df4ba58SJohn Snow block_job_resume(job); 7240df4ba58SJohn Snow } 7250df4ba58SJohn Snow 7268acc72a4SPaolo Bonzini void block_job_cancel(BlockJob *job) 7278acc72a4SPaolo Bonzini { 728e0cf0364SJohn Snow if (job->status == BLOCK_JOB_STATUS_CONCLUDED) { 72975f71059SJohn Snow block_job_do_dismiss(job); 730e0cf0364SJohn Snow } else if (block_job_started(job)) { 7314c241cf5SPaolo Bonzini block_job_cancel_async(job); 732751ebd76SFam Zheng block_job_enter(job); 7335ccac6f1SJohn Snow } else { 7345ccac6f1SJohn Snow block_job_completed(job, -ECANCELED); 7355ccac6f1SJohn Snow } 7368acc72a4SPaolo Bonzini } 7378acc72a4SPaolo Bonzini 7380ec4dfb8SJohn Snow void block_job_user_cancel(BlockJob *job, Error **errp) 7390ec4dfb8SJohn Snow { 7400ec4dfb8SJohn Snow if (block_job_apply_verb(job, BLOCK_JOB_VERB_CANCEL, errp)) { 7410ec4dfb8SJohn Snow return; 7420ec4dfb8SJohn Snow } 7430ec4dfb8SJohn Snow block_job_cancel(job); 7440ec4dfb8SJohn Snow } 7450ec4dfb8SJohn Snow 746345f9e1bSMax Reitz /* A wrapper around block_job_cancel() taking an Error ** parameter so it may be 747345f9e1bSMax Reitz * used with block_job_finish_sync() without the need for (rather nasty) 748345f9e1bSMax Reitz * function pointer casts there. */ 749345f9e1bSMax Reitz static void block_job_cancel_err(BlockJob *job, Error **errp) 750345f9e1bSMax Reitz { 751345f9e1bSMax Reitz block_job_cancel(job); 752345f9e1bSMax Reitz } 753345f9e1bSMax Reitz 754345f9e1bSMax Reitz int block_job_cancel_sync(BlockJob *job) 755345f9e1bSMax Reitz { 756345f9e1bSMax Reitz return block_job_finish_sync(job, &block_job_cancel_err, NULL); 757345f9e1bSMax Reitz } 758345f9e1bSMax Reitz 759a1a2af07SKevin Wolf void block_job_cancel_sync_all(void) 760a1a2af07SKevin Wolf { 761a1a2af07SKevin Wolf BlockJob *job; 762a1a2af07SKevin Wolf AioContext *aio_context; 763a1a2af07SKevin Wolf 764a1a2af07SKevin Wolf while ((job = QLIST_FIRST(&block_jobs))) { 765b6d2e599SKevin Wolf aio_context = blk_get_aio_context(job->blk); 766a1a2af07SKevin Wolf aio_context_acquire(aio_context); 767a1a2af07SKevin Wolf block_job_cancel_sync(job); 768a1a2af07SKevin Wolf aio_context_release(aio_context); 769a1a2af07SKevin Wolf } 770a1a2af07SKevin Wolf } 771a1a2af07SKevin Wolf 772345f9e1bSMax Reitz int block_job_complete_sync(BlockJob *job, Error **errp) 773345f9e1bSMax Reitz { 774345f9e1bSMax Reitz return block_job_finish_sync(job, &block_job_complete, errp); 775345f9e1bSMax Reitz } 776345f9e1bSMax Reitz 777559b935fSJohn Snow BlockJobInfo *block_job_query(BlockJob *job, Error **errp) 77830e628b7SPaolo Bonzini { 779559b935fSJohn Snow BlockJobInfo *info; 780559b935fSJohn Snow 781559b935fSJohn Snow if (block_job_is_internal(job)) { 782559b935fSJohn Snow error_setg(errp, "Cannot query QEMU internal jobs"); 783559b935fSJohn Snow return NULL; 784559b935fSJohn Snow } 785559b935fSJohn Snow info = g_new0(BlockJobInfo, 1); 786977c736fSMarkus Armbruster info->type = g_strdup(BlockJobType_str(job->driver->job_type)); 7878ccb9569SKevin Wolf info->device = g_strdup(job->id); 78830e628b7SPaolo Bonzini info->len = job->len; 789fc24908eSPaolo Bonzini info->busy = atomic_read(&job->busy); 790751ebd76SFam Zheng info->paused = job->pause_count > 0; 79130e628b7SPaolo Bonzini info->offset = job->offset; 79230e628b7SPaolo Bonzini info->speed = job->speed; 79332c81a4aSPaolo Bonzini info->io_status = job->iostatus; 794ef6dbf1eSMax Reitz info->ready = job->ready; 79558b295baSJohn Snow info->status = job->status; 79630e628b7SPaolo Bonzini return info; 79730e628b7SPaolo Bonzini } 79832c81a4aSPaolo Bonzini 79932c81a4aSPaolo Bonzini static void block_job_iostatus_set_err(BlockJob *job, int error) 80032c81a4aSPaolo Bonzini { 80132c81a4aSPaolo Bonzini if (job->iostatus == BLOCK_DEVICE_IO_STATUS_OK) { 80232c81a4aSPaolo Bonzini job->iostatus = error == ENOSPC ? BLOCK_DEVICE_IO_STATUS_NOSPACE : 80332c81a4aSPaolo Bonzini BLOCK_DEVICE_IO_STATUS_FAILED; 80432c81a4aSPaolo Bonzini } 80532c81a4aSPaolo Bonzini } 80632c81a4aSPaolo Bonzini 8078254b6d9SJohn Snow static void block_job_event_cancelled(BlockJob *job) 808a66a2a36SPaolo Bonzini { 809559b935fSJohn Snow if (block_job_is_internal(job)) { 810559b935fSJohn Snow return; 811559b935fSJohn Snow } 812559b935fSJohn Snow 813bcada37bSWenchao Xia qapi_event_send_block_job_cancelled(job->driver->job_type, 8148ccb9569SKevin Wolf job->id, 815a66a2a36SPaolo Bonzini job->len, 816a66a2a36SPaolo Bonzini job->offset, 817bcada37bSWenchao Xia job->speed, 818bcada37bSWenchao Xia &error_abort); 819a66a2a36SPaolo Bonzini } 820a66a2a36SPaolo Bonzini 8218254b6d9SJohn Snow static void block_job_event_completed(BlockJob *job, const char *msg) 822a66a2a36SPaolo Bonzini { 823559b935fSJohn Snow if (block_job_is_internal(job)) { 824559b935fSJohn Snow return; 825559b935fSJohn Snow } 826559b935fSJohn Snow 827bcada37bSWenchao Xia qapi_event_send_block_job_completed(job->driver->job_type, 8288ccb9569SKevin Wolf job->id, 829bcada37bSWenchao Xia job->len, 830bcada37bSWenchao Xia job->offset, 831bcada37bSWenchao Xia job->speed, 832bcada37bSWenchao Xia !!msg, 833bcada37bSWenchao Xia msg, 834bcada37bSWenchao Xia &error_abort); 835bcada37bSWenchao Xia } 836bcada37bSWenchao Xia 837*5f241594SJohn Snow static int block_job_event_pending(BlockJob *job) 838*5f241594SJohn Snow { 839*5f241594SJohn Snow block_job_state_transition(job, BLOCK_JOB_STATUS_PENDING); 840*5f241594SJohn Snow if (!job->auto_finalize && !block_job_is_internal(job)) { 841*5f241594SJohn Snow qapi_event_send_block_job_pending(job->driver->job_type, 842*5f241594SJohn Snow job->id, 843*5f241594SJohn Snow &error_abort); 844*5f241594SJohn Snow } 845*5f241594SJohn Snow return 0; 846*5f241594SJohn Snow } 847*5f241594SJohn Snow 84888691b37SPaolo Bonzini /* 84988691b37SPaolo Bonzini * API for block job drivers and the block layer. These functions are 85088691b37SPaolo Bonzini * declared in blockjob_int.h. 85188691b37SPaolo Bonzini */ 85288691b37SPaolo Bonzini 85388691b37SPaolo Bonzini void *block_job_create(const char *job_id, const BlockJobDriver *driver, 85475859b94SJohn Snow BlockJobTxn *txn, BlockDriverState *bs, uint64_t perm, 85588691b37SPaolo Bonzini uint64_t shared_perm, int64_t speed, int flags, 85688691b37SPaolo Bonzini BlockCompletionFunc *cb, void *opaque, Error **errp) 85788691b37SPaolo Bonzini { 85888691b37SPaolo Bonzini BlockBackend *blk; 85988691b37SPaolo Bonzini BlockJob *job; 86088691b37SPaolo Bonzini int ret; 86188691b37SPaolo Bonzini 86288691b37SPaolo Bonzini if (bs->job) { 86388691b37SPaolo Bonzini error_setg(errp, QERR_DEVICE_IN_USE, bdrv_get_device_name(bs)); 86488691b37SPaolo Bonzini return NULL; 86588691b37SPaolo Bonzini } 86688691b37SPaolo Bonzini 86788691b37SPaolo Bonzini if (job_id == NULL && !(flags & BLOCK_JOB_INTERNAL)) { 86888691b37SPaolo Bonzini job_id = bdrv_get_device_name(bs); 86988691b37SPaolo Bonzini if (!*job_id) { 87088691b37SPaolo Bonzini error_setg(errp, "An explicit job ID is required for this node"); 87188691b37SPaolo Bonzini return NULL; 87288691b37SPaolo Bonzini } 87388691b37SPaolo Bonzini } 87488691b37SPaolo Bonzini 87588691b37SPaolo Bonzini if (job_id) { 87688691b37SPaolo Bonzini if (flags & BLOCK_JOB_INTERNAL) { 87788691b37SPaolo Bonzini error_setg(errp, "Cannot specify job ID for internal block job"); 87888691b37SPaolo Bonzini return NULL; 87988691b37SPaolo Bonzini } 88088691b37SPaolo Bonzini 88188691b37SPaolo Bonzini if (!id_wellformed(job_id)) { 88288691b37SPaolo Bonzini error_setg(errp, "Invalid job ID '%s'", job_id); 88388691b37SPaolo Bonzini return NULL; 88488691b37SPaolo Bonzini } 88588691b37SPaolo Bonzini 88688691b37SPaolo Bonzini if (block_job_get(job_id)) { 88788691b37SPaolo Bonzini error_setg(errp, "Job ID '%s' already in use", job_id); 88888691b37SPaolo Bonzini return NULL; 88988691b37SPaolo Bonzini } 89088691b37SPaolo Bonzini } 89188691b37SPaolo Bonzini 89288691b37SPaolo Bonzini blk = blk_new(perm, shared_perm); 89388691b37SPaolo Bonzini ret = blk_insert_bs(blk, bs, errp); 89488691b37SPaolo Bonzini if (ret < 0) { 89588691b37SPaolo Bonzini blk_unref(blk); 89688691b37SPaolo Bonzini return NULL; 89788691b37SPaolo Bonzini } 89888691b37SPaolo Bonzini 89988691b37SPaolo Bonzini job = g_malloc0(driver->instance_size); 90088691b37SPaolo Bonzini job->driver = driver; 90188691b37SPaolo Bonzini job->id = g_strdup(job_id); 90288691b37SPaolo Bonzini job->blk = blk; 90388691b37SPaolo Bonzini job->cb = cb; 90488691b37SPaolo Bonzini job->opaque = opaque; 90588691b37SPaolo Bonzini job->busy = false; 90688691b37SPaolo Bonzini job->paused = true; 90788691b37SPaolo Bonzini job->pause_count = 1; 90888691b37SPaolo Bonzini job->refcnt = 1; 909*5f241594SJohn Snow job->auto_finalize = !(flags & BLOCK_JOB_MANUAL_FINALIZE); 91075f71059SJohn Snow job->auto_dismiss = !(flags & BLOCK_JOB_MANUAL_DISMISS); 911c9de4050SJohn Snow block_job_state_transition(job, BLOCK_JOB_STATUS_CREATED); 912fc24908eSPaolo Bonzini aio_timer_init(qemu_get_aio_context(), &job->sleep_timer, 913fc24908eSPaolo Bonzini QEMU_CLOCK_REALTIME, SCALE_NS, 914fc24908eSPaolo Bonzini block_job_sleep_timer_cb, job); 91588691b37SPaolo Bonzini 91688691b37SPaolo Bonzini error_setg(&job->blocker, "block device is in use by block job: %s", 917977c736fSMarkus Armbruster BlockJobType_str(driver->job_type)); 91888691b37SPaolo Bonzini block_job_add_bdrv(job, "main node", bs, 0, BLK_PERM_ALL, &error_abort); 91988691b37SPaolo Bonzini bs->job = job; 92088691b37SPaolo Bonzini 92188691b37SPaolo Bonzini bdrv_op_unblock(bs, BLOCK_OP_TYPE_DATAPLANE, job->blocker); 92288691b37SPaolo Bonzini 92388691b37SPaolo Bonzini QLIST_INSERT_HEAD(&block_jobs, job, job_list); 92488691b37SPaolo Bonzini 92588691b37SPaolo Bonzini blk_add_aio_context_notifier(blk, block_job_attached_aio_context, 92688691b37SPaolo Bonzini block_job_detach_aio_context, job); 92788691b37SPaolo Bonzini 92888691b37SPaolo Bonzini /* Only set speed when necessary to avoid NotSupported error */ 92988691b37SPaolo Bonzini if (speed != 0) { 93088691b37SPaolo Bonzini Error *local_err = NULL; 93188691b37SPaolo Bonzini 93288691b37SPaolo Bonzini block_job_set_speed(job, speed, &local_err); 93388691b37SPaolo Bonzini if (local_err) { 9343925cd3bSJohn Snow block_job_early_fail(job); 93588691b37SPaolo Bonzini error_propagate(errp, local_err); 93688691b37SPaolo Bonzini return NULL; 93788691b37SPaolo Bonzini } 93888691b37SPaolo Bonzini } 93975859b94SJohn Snow 94075859b94SJohn Snow /* Single jobs are modeled as single-job transactions for sake of 94175859b94SJohn Snow * consolidating the job management logic */ 94275859b94SJohn Snow if (!txn) { 94375859b94SJohn Snow txn = block_job_txn_new(); 94475859b94SJohn Snow block_job_txn_add_job(txn, job); 94575859b94SJohn Snow block_job_txn_unref(txn); 94675859b94SJohn Snow } else { 94775859b94SJohn Snow block_job_txn_add_job(txn, job); 94875859b94SJohn Snow } 94975859b94SJohn Snow 95088691b37SPaolo Bonzini return job; 95188691b37SPaolo Bonzini } 95288691b37SPaolo Bonzini 953f321dcb5SPaolo Bonzini void block_job_pause_all(void) 954f321dcb5SPaolo Bonzini { 955f321dcb5SPaolo Bonzini BlockJob *job = NULL; 956f321dcb5SPaolo Bonzini while ((job = block_job_next(job))) { 957f321dcb5SPaolo Bonzini AioContext *aio_context = blk_get_aio_context(job->blk); 958f321dcb5SPaolo Bonzini 959f321dcb5SPaolo Bonzini aio_context_acquire(aio_context); 9603d5d319eSAlberto Garcia block_job_ref(job); 961f321dcb5SPaolo Bonzini block_job_pause(job); 962f321dcb5SPaolo Bonzini aio_context_release(aio_context); 963f321dcb5SPaolo Bonzini } 964f321dcb5SPaolo Bonzini } 965f321dcb5SPaolo Bonzini 96688691b37SPaolo Bonzini void block_job_early_fail(BlockJob *job) 96788691b37SPaolo Bonzini { 9683925cd3bSJohn Snow assert(job->status == BLOCK_JOB_STATUS_CREATED); 9693925cd3bSJohn Snow block_job_decommission(job); 97088691b37SPaolo Bonzini } 97188691b37SPaolo Bonzini 97288691b37SPaolo Bonzini void block_job_completed(BlockJob *job, int ret) 97388691b37SPaolo Bonzini { 97475859b94SJohn Snow assert(job && job->txn && !job->completed); 97588691b37SPaolo Bonzini assert(blk_bs(job->blk)->job == job); 97688691b37SPaolo Bonzini job->completed = true; 97788691b37SPaolo Bonzini job->ret = ret; 97835d6b368SJohn Snow block_job_update_rc(job); 97935d6b368SJohn Snow trace_block_job_completed(job, ret, job->ret); 98035d6b368SJohn Snow if (job->ret) { 98188691b37SPaolo Bonzini block_job_completed_txn_abort(job); 98288691b37SPaolo Bonzini } else { 98388691b37SPaolo Bonzini block_job_completed_txn_success(job); 98488691b37SPaolo Bonzini } 98588691b37SPaolo Bonzini } 98688691b37SPaolo Bonzini 98788691b37SPaolo Bonzini static bool block_job_should_pause(BlockJob *job) 98888691b37SPaolo Bonzini { 98988691b37SPaolo Bonzini return job->pause_count > 0; 99088691b37SPaolo Bonzini } 99188691b37SPaolo Bonzini 992fc24908eSPaolo Bonzini /* Yield, and schedule a timer to reenter the coroutine after @ns nanoseconds. 993fc24908eSPaolo Bonzini * Reentering the job coroutine with block_job_enter() before the timer has 994fc24908eSPaolo Bonzini * expired is allowed and cancels the timer. 995fc24908eSPaolo Bonzini * 996fc24908eSPaolo Bonzini * If @ns is (uint64_t) -1, no timer is scheduled and block_job_enter() must be 997fc24908eSPaolo Bonzini * called explicitly. */ 998fc24908eSPaolo Bonzini static void block_job_do_yield(BlockJob *job, uint64_t ns) 999356f59b8SPaolo Bonzini { 1000fc24908eSPaolo Bonzini block_job_lock(); 1001fc24908eSPaolo Bonzini if (ns != -1) { 1002fc24908eSPaolo Bonzini timer_mod(&job->sleep_timer, ns); 1003fc24908eSPaolo Bonzini } 1004356f59b8SPaolo Bonzini job->busy = false; 1005fc24908eSPaolo Bonzini block_job_unlock(); 1006356f59b8SPaolo Bonzini qemu_coroutine_yield(); 1007356f59b8SPaolo Bonzini 1008356f59b8SPaolo Bonzini /* Set by block_job_enter before re-entering the coroutine. */ 1009356f59b8SPaolo Bonzini assert(job->busy); 1010356f59b8SPaolo Bonzini } 1011356f59b8SPaolo Bonzini 101288691b37SPaolo Bonzini void coroutine_fn block_job_pause_point(BlockJob *job) 101388691b37SPaolo Bonzini { 101488691b37SPaolo Bonzini assert(job && block_job_started(job)); 101588691b37SPaolo Bonzini 101688691b37SPaolo Bonzini if (!block_job_should_pause(job)) { 101788691b37SPaolo Bonzini return; 101888691b37SPaolo Bonzini } 101988691b37SPaolo Bonzini if (block_job_is_cancelled(job)) { 102088691b37SPaolo Bonzini return; 102188691b37SPaolo Bonzini } 102288691b37SPaolo Bonzini 102388691b37SPaolo Bonzini if (job->driver->pause) { 102488691b37SPaolo Bonzini job->driver->pause(job); 102588691b37SPaolo Bonzini } 102688691b37SPaolo Bonzini 102788691b37SPaolo Bonzini if (block_job_should_pause(job) && !block_job_is_cancelled(job)) { 102858b295baSJohn Snow BlockJobStatus status = job->status; 1029c9de4050SJohn Snow block_job_state_transition(job, status == BLOCK_JOB_STATUS_READY ? \ 103058b295baSJohn Snow BLOCK_JOB_STATUS_STANDBY : \ 1031c9de4050SJohn Snow BLOCK_JOB_STATUS_PAUSED); 103288691b37SPaolo Bonzini job->paused = true; 1033fc24908eSPaolo Bonzini block_job_do_yield(job, -1); 103488691b37SPaolo Bonzini job->paused = false; 1035c9de4050SJohn Snow block_job_state_transition(job, status); 103688691b37SPaolo Bonzini } 103788691b37SPaolo Bonzini 103888691b37SPaolo Bonzini if (job->driver->resume) { 103988691b37SPaolo Bonzini job->driver->resume(job); 104088691b37SPaolo Bonzini } 104188691b37SPaolo Bonzini } 104288691b37SPaolo Bonzini 1043f321dcb5SPaolo Bonzini void block_job_resume_all(void) 1044f321dcb5SPaolo Bonzini { 10453d5d319eSAlberto Garcia BlockJob *job, *next; 10463d5d319eSAlberto Garcia 10473d5d319eSAlberto Garcia QLIST_FOREACH_SAFE(job, &block_jobs, job_list, next) { 1048f321dcb5SPaolo Bonzini AioContext *aio_context = blk_get_aio_context(job->blk); 1049f321dcb5SPaolo Bonzini 1050f321dcb5SPaolo Bonzini aio_context_acquire(aio_context); 1051f321dcb5SPaolo Bonzini block_job_resume(job); 10523d5d319eSAlberto Garcia block_job_unref(job); 1053f321dcb5SPaolo Bonzini aio_context_release(aio_context); 1054f321dcb5SPaolo Bonzini } 1055f321dcb5SPaolo Bonzini } 1056f321dcb5SPaolo Bonzini 1057aa9ef2e6SJohn Snow /* 1058aa9ef2e6SJohn Snow * Conditionally enter a block_job pending a call to fn() while 1059aa9ef2e6SJohn Snow * under the block_job_lock critical section. 1060aa9ef2e6SJohn Snow */ 1061aa9ef2e6SJohn Snow static void block_job_enter_cond(BlockJob *job, bool(*fn)(BlockJob *job)) 106288691b37SPaolo Bonzini { 1063eb05e011SPaolo Bonzini if (!block_job_started(job)) { 1064eb05e011SPaolo Bonzini return; 1065eb05e011SPaolo Bonzini } 1066eb05e011SPaolo Bonzini if (job->deferred_to_main_loop) { 1067eb05e011SPaolo Bonzini return; 1068eb05e011SPaolo Bonzini } 1069eb05e011SPaolo Bonzini 1070fc24908eSPaolo Bonzini block_job_lock(); 1071356f59b8SPaolo Bonzini if (job->busy) { 1072fc24908eSPaolo Bonzini block_job_unlock(); 1073356f59b8SPaolo Bonzini return; 107488691b37SPaolo Bonzini } 1075356f59b8SPaolo Bonzini 1076aa9ef2e6SJohn Snow if (fn && !fn(job)) { 1077aa9ef2e6SJohn Snow block_job_unlock(); 1078aa9ef2e6SJohn Snow return; 1079aa9ef2e6SJohn Snow } 1080aa9ef2e6SJohn Snow 1081fc24908eSPaolo Bonzini assert(!job->deferred_to_main_loop); 1082fc24908eSPaolo Bonzini timer_del(&job->sleep_timer); 1083356f59b8SPaolo Bonzini job->busy = true; 1084fc24908eSPaolo Bonzini block_job_unlock(); 1085356f59b8SPaolo Bonzini aio_co_wake(job->co); 108688691b37SPaolo Bonzini } 108788691b37SPaolo Bonzini 1088aa9ef2e6SJohn Snow void block_job_enter(BlockJob *job) 1089aa9ef2e6SJohn Snow { 1090aa9ef2e6SJohn Snow block_job_enter_cond(job, NULL); 1091aa9ef2e6SJohn Snow } 1092aa9ef2e6SJohn Snow 109388691b37SPaolo Bonzini bool block_job_is_cancelled(BlockJob *job) 109488691b37SPaolo Bonzini { 109588691b37SPaolo Bonzini return job->cancelled; 109688691b37SPaolo Bonzini } 109788691b37SPaolo Bonzini 10985bf1d5a7SPaolo Bonzini void block_job_sleep_ns(BlockJob *job, int64_t ns) 109988691b37SPaolo Bonzini { 110088691b37SPaolo Bonzini assert(job->busy); 110188691b37SPaolo Bonzini 110288691b37SPaolo Bonzini /* Check cancellation *before* setting busy = false, too! */ 110388691b37SPaolo Bonzini if (block_job_is_cancelled(job)) { 110488691b37SPaolo Bonzini return; 110588691b37SPaolo Bonzini } 110688691b37SPaolo Bonzini 110788691b37SPaolo Bonzini if (!block_job_should_pause(job)) { 1108fc24908eSPaolo Bonzini block_job_do_yield(job, qemu_clock_get_ns(QEMU_CLOCK_REALTIME) + ns); 110988691b37SPaolo Bonzini } 111088691b37SPaolo Bonzini 111188691b37SPaolo Bonzini block_job_pause_point(job); 111288691b37SPaolo Bonzini } 111388691b37SPaolo Bonzini 111488691b37SPaolo Bonzini void block_job_yield(BlockJob *job) 111588691b37SPaolo Bonzini { 111688691b37SPaolo Bonzini assert(job->busy); 111788691b37SPaolo Bonzini 111888691b37SPaolo Bonzini /* Check cancellation *before* setting busy = false, too! */ 111988691b37SPaolo Bonzini if (block_job_is_cancelled(job)) { 112088691b37SPaolo Bonzini return; 112188691b37SPaolo Bonzini } 112288691b37SPaolo Bonzini 112388691b37SPaolo Bonzini if (!block_job_should_pause(job)) { 1124fc24908eSPaolo Bonzini block_job_do_yield(job, -1); 112588691b37SPaolo Bonzini } 112688691b37SPaolo Bonzini 112788691b37SPaolo Bonzini block_job_pause_point(job); 112888691b37SPaolo Bonzini } 112988691b37SPaolo Bonzini 11302caf63a9SPaolo Bonzini void block_job_iostatus_reset(BlockJob *job) 11312caf63a9SPaolo Bonzini { 11324c241cf5SPaolo Bonzini if (job->iostatus == BLOCK_DEVICE_IO_STATUS_OK) { 11334c241cf5SPaolo Bonzini return; 11344c241cf5SPaolo Bonzini } 11354c241cf5SPaolo Bonzini assert(job->user_paused && job->pause_count > 0); 11362caf63a9SPaolo Bonzini job->iostatus = BLOCK_DEVICE_IO_STATUS_OK; 11372caf63a9SPaolo Bonzini } 11382caf63a9SPaolo Bonzini 1139bcada37bSWenchao Xia void block_job_event_ready(BlockJob *job) 1140bcada37bSWenchao Xia { 1141c9de4050SJohn Snow block_job_state_transition(job, BLOCK_JOB_STATUS_READY); 1142ef6dbf1eSMax Reitz job->ready = true; 1143ef6dbf1eSMax Reitz 1144559b935fSJohn Snow if (block_job_is_internal(job)) { 1145559b935fSJohn Snow return; 1146559b935fSJohn Snow } 1147559b935fSJohn Snow 1148518848a2SMarkus Armbruster qapi_event_send_block_job_ready(job->driver->job_type, 11498ccb9569SKevin Wolf job->id, 1150518848a2SMarkus Armbruster job->len, 1151518848a2SMarkus Armbruster job->offset, 1152518848a2SMarkus Armbruster job->speed, &error_abort); 1153a66a2a36SPaolo Bonzini } 1154a66a2a36SPaolo Bonzini 115581e254dcSKevin Wolf BlockErrorAction block_job_error_action(BlockJob *job, BlockdevOnError on_err, 115632c81a4aSPaolo Bonzini int is_read, int error) 115732c81a4aSPaolo Bonzini { 115832c81a4aSPaolo Bonzini BlockErrorAction action; 115932c81a4aSPaolo Bonzini 116032c81a4aSPaolo Bonzini switch (on_err) { 116132c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_ENOSPC: 11628c398252SKevin Wolf case BLOCKDEV_ON_ERROR_AUTO: 1163a589569fSWenchao Xia action = (error == ENOSPC) ? 1164a589569fSWenchao Xia BLOCK_ERROR_ACTION_STOP : BLOCK_ERROR_ACTION_REPORT; 116532c81a4aSPaolo Bonzini break; 116632c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_STOP: 1167a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_STOP; 116832c81a4aSPaolo Bonzini break; 116932c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_REPORT: 1170a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_REPORT; 117132c81a4aSPaolo Bonzini break; 117232c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_IGNORE: 1173a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_IGNORE; 117432c81a4aSPaolo Bonzini break; 117532c81a4aSPaolo Bonzini default: 117632c81a4aSPaolo Bonzini abort(); 117732c81a4aSPaolo Bonzini } 1178559b935fSJohn Snow if (!block_job_is_internal(job)) { 11798ccb9569SKevin Wolf qapi_event_send_block_job_error(job->id, 11805a2d2cbdSWenchao Xia is_read ? IO_OPERATION_TYPE_READ : 11815a2d2cbdSWenchao Xia IO_OPERATION_TYPE_WRITE, 11825a2d2cbdSWenchao Xia action, &error_abort); 1183559b935fSJohn Snow } 1184a589569fSWenchao Xia if (action == BLOCK_ERROR_ACTION_STOP) { 11850ec4dfb8SJohn Snow block_job_pause(job); 1186751ebd76SFam Zheng /* make the pause user visible, which will be resumed from QMP. */ 11870ec4dfb8SJohn Snow job->user_paused = true; 118832c81a4aSPaolo Bonzini block_job_iostatus_set_err(job, error); 118932c81a4aSPaolo Bonzini } 119032c81a4aSPaolo Bonzini return action; 119132c81a4aSPaolo Bonzini } 1192dec7d421SStefan Hajnoczi 1193dec7d421SStefan Hajnoczi typedef struct { 1194dec7d421SStefan Hajnoczi BlockJob *job; 1195dec7d421SStefan Hajnoczi AioContext *aio_context; 1196dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopFn *fn; 1197dec7d421SStefan Hajnoczi void *opaque; 1198dec7d421SStefan Hajnoczi } BlockJobDeferToMainLoopData; 1199dec7d421SStefan Hajnoczi 1200dec7d421SStefan Hajnoczi static void block_job_defer_to_main_loop_bh(void *opaque) 1201dec7d421SStefan Hajnoczi { 1202dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopData *data = opaque; 1203dec7d421SStefan Hajnoczi AioContext *aio_context; 1204dec7d421SStefan Hajnoczi 1205dec7d421SStefan Hajnoczi /* Prevent race with block_job_defer_to_main_loop() */ 1206dec7d421SStefan Hajnoczi aio_context_acquire(data->aio_context); 1207dec7d421SStefan Hajnoczi 1208dec7d421SStefan Hajnoczi /* Fetch BDS AioContext again, in case it has changed */ 1209b6d2e599SKevin Wolf aio_context = blk_get_aio_context(data->job->blk); 1210d79df2a2SPaolo Bonzini if (aio_context != data->aio_context) { 1211dec7d421SStefan Hajnoczi aio_context_acquire(aio_context); 1212d79df2a2SPaolo Bonzini } 1213dec7d421SStefan Hajnoczi 1214dec7d421SStefan Hajnoczi data->fn(data->job, data->opaque); 1215dec7d421SStefan Hajnoczi 1216d79df2a2SPaolo Bonzini if (aio_context != data->aio_context) { 1217dec7d421SStefan Hajnoczi aio_context_release(aio_context); 1218d79df2a2SPaolo Bonzini } 1219dec7d421SStefan Hajnoczi 1220dec7d421SStefan Hajnoczi aio_context_release(data->aio_context); 1221dec7d421SStefan Hajnoczi 1222dec7d421SStefan Hajnoczi g_free(data); 1223dec7d421SStefan Hajnoczi } 1224dec7d421SStefan Hajnoczi 1225dec7d421SStefan Hajnoczi void block_job_defer_to_main_loop(BlockJob *job, 1226dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopFn *fn, 1227dec7d421SStefan Hajnoczi void *opaque) 1228dec7d421SStefan Hajnoczi { 1229dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopData *data = g_malloc(sizeof(*data)); 1230dec7d421SStefan Hajnoczi data->job = job; 1231b6d2e599SKevin Wolf data->aio_context = blk_get_aio_context(job->blk); 1232dec7d421SStefan Hajnoczi data->fn = fn; 1233dec7d421SStefan Hajnoczi data->opaque = opaque; 1234794f0141SFam Zheng job->deferred_to_main_loop = true; 1235dec7d421SStefan Hajnoczi 1236fffb6e12SPaolo Bonzini aio_bh_schedule_oneshot(qemu_get_aio_context(), 1237fffb6e12SPaolo Bonzini block_job_defer_to_main_loop_bh, data); 1238dec7d421SStefan Hajnoczi } 1239