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 26*d38ea87aSPeter Maydell #include "qemu/osdep.h" 272f0c9fe6SPaolo Bonzini #include "qemu-common.h" 282f0c9fe6SPaolo Bonzini #include "trace.h" 29737e150eSPaolo Bonzini #include "block/block.h" 30737e150eSPaolo Bonzini #include "block/blockjob.h" 31737e150eSPaolo Bonzini #include "block/block_int.h" 32373340b2SMax Reitz #include "sysemu/block-backend.h" 33cc7a8ea7SMarkus Armbruster #include "qapi/qmp/qerror.h" 347b1b5d19SPaolo Bonzini #include "qapi/qmp/qjson.h" 3510817bf0SDaniel P. Berrange #include "qemu/coroutine.h" 362f0c9fe6SPaolo Bonzini #include "qmp-commands.h" 371de7afc9SPaolo Bonzini #include "qemu/timer.h" 385a2d2cbdSWenchao Xia #include "qapi-event.h" 392f0c9fe6SPaolo Bonzini 40c55a832fSFam Zheng /* Transactional group of block jobs */ 41c55a832fSFam Zheng struct BlockJobTxn { 42c55a832fSFam Zheng 43c55a832fSFam Zheng /* Is this txn being cancelled? */ 44c55a832fSFam Zheng bool aborting; 45c55a832fSFam Zheng 46c55a832fSFam Zheng /* List of jobs */ 47c55a832fSFam Zheng QLIST_HEAD(, BlockJob) jobs; 48c55a832fSFam Zheng 49c55a832fSFam Zheng /* Reference count */ 50c55a832fSFam Zheng int refcnt; 51c55a832fSFam Zheng }; 52c55a832fSFam Zheng 533fc4b10aSFam Zheng void *block_job_create(const BlockJobDriver *driver, BlockDriverState *bs, 54097310b5SMarkus Armbruster int64_t speed, BlockCompletionFunc *cb, 552f0c9fe6SPaolo Bonzini void *opaque, Error **errp) 562f0c9fe6SPaolo Bonzini { 572f0c9fe6SPaolo Bonzini BlockJob *job; 582f0c9fe6SPaolo Bonzini 59628ff683SFam Zheng if (bs->job) { 60c6bd8c70SMarkus Armbruster error_setg(errp, QERR_DEVICE_IN_USE, bdrv_get_device_name(bs)); 612f0c9fe6SPaolo Bonzini return NULL; 622f0c9fe6SPaolo Bonzini } 63fa510ebfSFam Zheng bdrv_ref(bs); 643fc4b10aSFam Zheng job = g_malloc0(driver->instance_size); 653718d8abSFam Zheng error_setg(&job->blocker, "block device is in use by block job: %s", 663718d8abSFam Zheng BlockJobType_lookup[driver->job_type]); 673718d8abSFam Zheng bdrv_op_block_all(bs, job->blocker); 68b112a65cSStefan Hajnoczi bdrv_op_unblock(bs, BLOCK_OP_TYPE_DATAPLANE, job->blocker); 693718d8abSFam Zheng 703fc4b10aSFam Zheng job->driver = driver; 718ccb9569SKevin Wolf job->id = g_strdup(bdrv_get_device_name(bs)); 722f0c9fe6SPaolo Bonzini job->bs = bs; 732f0c9fe6SPaolo Bonzini job->cb = cb; 742f0c9fe6SPaolo Bonzini job->opaque = opaque; 752f0c9fe6SPaolo Bonzini job->busy = true; 7618930ba3SFam Zheng job->refcnt = 1; 772f0c9fe6SPaolo Bonzini bs->job = job; 782f0c9fe6SPaolo Bonzini 792f0c9fe6SPaolo Bonzini /* Only set speed when necessary to avoid NotSupported error */ 802f0c9fe6SPaolo Bonzini if (speed != 0) { 812f0c9fe6SPaolo Bonzini Error *local_err = NULL; 822f0c9fe6SPaolo Bonzini 832f0c9fe6SPaolo Bonzini block_job_set_speed(job, speed, &local_err); 8484d18f06SMarkus Armbruster if (local_err) { 8518930ba3SFam Zheng block_job_unref(job); 862f0c9fe6SPaolo Bonzini error_propagate(errp, local_err); 872f0c9fe6SPaolo Bonzini return NULL; 882f0c9fe6SPaolo Bonzini } 892f0c9fe6SPaolo Bonzini } 902f0c9fe6SPaolo Bonzini return job; 912f0c9fe6SPaolo Bonzini } 922f0c9fe6SPaolo Bonzini 9318930ba3SFam Zheng void block_job_ref(BlockJob *job) 9497031164STing Wang { 9518930ba3SFam Zheng ++job->refcnt; 9618930ba3SFam Zheng } 9797031164STing Wang 9818930ba3SFam Zheng void block_job_unref(BlockJob *job) 9918930ba3SFam Zheng { 10018930ba3SFam Zheng if (--job->refcnt == 0) { 10118930ba3SFam Zheng job->bs->job = NULL; 10218930ba3SFam Zheng bdrv_op_unblock_all(job->bs, job->blocker); 10318930ba3SFam Zheng bdrv_unref(job->bs); 10497031164STing Wang error_free(job->blocker); 1058ccb9569SKevin Wolf g_free(job->id); 10697031164STing Wang g_free(job); 10797031164STing Wang } 10818930ba3SFam Zheng } 10997031164STing Wang 110c55a832fSFam Zheng static void block_job_completed_single(BlockJob *job) 111c55a832fSFam Zheng { 112c55a832fSFam Zheng if (!job->ret) { 113c55a832fSFam Zheng if (job->driver->commit) { 114c55a832fSFam Zheng job->driver->commit(job); 115c55a832fSFam Zheng } 116c55a832fSFam Zheng } else { 117c55a832fSFam Zheng if (job->driver->abort) { 118c55a832fSFam Zheng job->driver->abort(job); 119c55a832fSFam Zheng } 120c55a832fSFam Zheng } 121c55a832fSFam Zheng job->cb(job->opaque, job->ret); 122c55a832fSFam Zheng if (job->txn) { 123c55a832fSFam Zheng block_job_txn_unref(job->txn); 124c55a832fSFam Zheng } 125c55a832fSFam Zheng block_job_unref(job); 126c55a832fSFam Zheng } 127c55a832fSFam Zheng 128c55a832fSFam Zheng static void block_job_completed_txn_abort(BlockJob *job) 129c55a832fSFam Zheng { 130c55a832fSFam Zheng AioContext *ctx; 131c55a832fSFam Zheng BlockJobTxn *txn = job->txn; 132c55a832fSFam Zheng BlockJob *other_job, *next; 133c55a832fSFam Zheng 134c55a832fSFam Zheng if (txn->aborting) { 135c55a832fSFam Zheng /* 136c55a832fSFam Zheng * We are cancelled by another job, which will handle everything. 137c55a832fSFam Zheng */ 138c55a832fSFam Zheng return; 139c55a832fSFam Zheng } 140c55a832fSFam Zheng txn->aborting = true; 141c55a832fSFam Zheng /* We are the first failed job. Cancel other jobs. */ 142c55a832fSFam Zheng QLIST_FOREACH(other_job, &txn->jobs, txn_list) { 143c55a832fSFam Zheng ctx = bdrv_get_aio_context(other_job->bs); 144c55a832fSFam Zheng aio_context_acquire(ctx); 145c55a832fSFam Zheng } 146c55a832fSFam Zheng QLIST_FOREACH(other_job, &txn->jobs, txn_list) { 147c55a832fSFam Zheng if (other_job == job || other_job->completed) { 148c55a832fSFam Zheng /* Other jobs are "effectively" cancelled by us, set the status for 149c55a832fSFam Zheng * them; this job, however, may or may not be cancelled, depending 150c55a832fSFam Zheng * on the caller, so leave it. */ 151c55a832fSFam Zheng if (other_job != job) { 152c55a832fSFam Zheng other_job->cancelled = true; 153c55a832fSFam Zheng } 154c55a832fSFam Zheng continue; 155c55a832fSFam Zheng } 156c55a832fSFam Zheng block_job_cancel_sync(other_job); 157c55a832fSFam Zheng assert(other_job->completed); 158c55a832fSFam Zheng } 159c55a832fSFam Zheng QLIST_FOREACH_SAFE(other_job, &txn->jobs, txn_list, next) { 160c55a832fSFam Zheng ctx = bdrv_get_aio_context(other_job->bs); 161c55a832fSFam Zheng block_job_completed_single(other_job); 162c55a832fSFam Zheng aio_context_release(ctx); 163c55a832fSFam Zheng } 164c55a832fSFam Zheng } 165c55a832fSFam Zheng 166c55a832fSFam Zheng static void block_job_completed_txn_success(BlockJob *job) 167c55a832fSFam Zheng { 168c55a832fSFam Zheng AioContext *ctx; 169c55a832fSFam Zheng BlockJobTxn *txn = job->txn; 170c55a832fSFam Zheng BlockJob *other_job, *next; 171c55a832fSFam Zheng /* 172c55a832fSFam Zheng * Successful completion, see if there are other running jobs in this 173c55a832fSFam Zheng * txn. 174c55a832fSFam Zheng */ 175c55a832fSFam Zheng QLIST_FOREACH(other_job, &txn->jobs, txn_list) { 176c55a832fSFam Zheng if (!other_job->completed) { 177c55a832fSFam Zheng return; 178c55a832fSFam Zheng } 179c55a832fSFam Zheng } 180c55a832fSFam Zheng /* We are the last completed job, commit the transaction. */ 181c55a832fSFam Zheng QLIST_FOREACH_SAFE(other_job, &txn->jobs, txn_list, next) { 182c55a832fSFam Zheng ctx = bdrv_get_aio_context(other_job->bs); 183c55a832fSFam Zheng aio_context_acquire(ctx); 184c55a832fSFam Zheng assert(other_job->ret == 0); 185c55a832fSFam Zheng block_job_completed_single(other_job); 186c55a832fSFam Zheng aio_context_release(ctx); 187c55a832fSFam Zheng } 188c55a832fSFam Zheng } 189c55a832fSFam Zheng 19065f46322SPaolo Bonzini void block_job_completed(BlockJob *job, int ret) 1912f0c9fe6SPaolo Bonzini { 1922f0c9fe6SPaolo Bonzini BlockDriverState *bs = job->bs; 1932f0c9fe6SPaolo Bonzini 1942f0c9fe6SPaolo Bonzini assert(bs->job == job); 195a689dbf2SFam Zheng assert(!job->completed); 196a689dbf2SFam Zheng job->completed = true; 197a689dbf2SFam Zheng job->ret = ret; 198c55a832fSFam Zheng if (!job->txn) { 199c55a832fSFam Zheng block_job_completed_single(job); 200c55a832fSFam Zheng } else if (ret < 0 || block_job_is_cancelled(job)) { 201c55a832fSFam Zheng block_job_completed_txn_abort(job); 202c55a832fSFam Zheng } else { 203c55a832fSFam Zheng block_job_completed_txn_success(job); 204c55a832fSFam Zheng } 2052f0c9fe6SPaolo Bonzini } 2062f0c9fe6SPaolo Bonzini 2072f0c9fe6SPaolo Bonzini void block_job_set_speed(BlockJob *job, int64_t speed, Error **errp) 2082f0c9fe6SPaolo Bonzini { 2092f0c9fe6SPaolo Bonzini Error *local_err = NULL; 2102f0c9fe6SPaolo Bonzini 2113fc4b10aSFam Zheng if (!job->driver->set_speed) { 212c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2132f0c9fe6SPaolo Bonzini return; 2142f0c9fe6SPaolo Bonzini } 2153fc4b10aSFam Zheng job->driver->set_speed(job, speed, &local_err); 21684d18f06SMarkus Armbruster if (local_err) { 2172f0c9fe6SPaolo Bonzini error_propagate(errp, local_err); 2182f0c9fe6SPaolo Bonzini return; 2192f0c9fe6SPaolo Bonzini } 2202f0c9fe6SPaolo Bonzini 2212f0c9fe6SPaolo Bonzini job->speed = speed; 2222f0c9fe6SPaolo Bonzini } 2232f0c9fe6SPaolo Bonzini 224aeae883bSPaolo Bonzini void block_job_complete(BlockJob *job, Error **errp) 225aeae883bSPaolo Bonzini { 226751ebd76SFam Zheng if (job->pause_count || job->cancelled || !job->driver->complete) { 2278ccb9569SKevin Wolf error_setg(errp, QERR_BLOCK_JOB_NOT_READY, job->id); 228aeae883bSPaolo Bonzini return; 229aeae883bSPaolo Bonzini } 230aeae883bSPaolo Bonzini 2313fc4b10aSFam Zheng job->driver->complete(job, errp); 232aeae883bSPaolo Bonzini } 233aeae883bSPaolo Bonzini 2348acc72a4SPaolo Bonzini void block_job_pause(BlockJob *job) 2352f0c9fe6SPaolo Bonzini { 236751ebd76SFam Zheng job->pause_count++; 2378acc72a4SPaolo Bonzini } 2388acc72a4SPaolo Bonzini 2398acc72a4SPaolo Bonzini bool block_job_is_paused(BlockJob *job) 2408acc72a4SPaolo Bonzini { 241751ebd76SFam Zheng return job->pause_count > 0; 2428acc72a4SPaolo Bonzini } 2438acc72a4SPaolo Bonzini 2448acc72a4SPaolo Bonzini void block_job_resume(BlockJob *job) 2458acc72a4SPaolo Bonzini { 246751ebd76SFam Zheng assert(job->pause_count > 0); 247751ebd76SFam Zheng job->pause_count--; 248751ebd76SFam Zheng if (job->pause_count) { 249751ebd76SFam Zheng return; 250751ebd76SFam Zheng } 251751ebd76SFam Zheng block_job_enter(job); 252751ebd76SFam Zheng } 253751ebd76SFam Zheng 254751ebd76SFam Zheng void block_job_enter(BlockJob *job) 255751ebd76SFam Zheng { 25632c81a4aSPaolo Bonzini block_job_iostatus_reset(job); 2572f0c9fe6SPaolo Bonzini if (job->co && !job->busy) { 2582f0c9fe6SPaolo Bonzini qemu_coroutine_enter(job->co, NULL); 2592f0c9fe6SPaolo Bonzini } 2602f0c9fe6SPaolo Bonzini } 2612f0c9fe6SPaolo Bonzini 2628acc72a4SPaolo Bonzini void block_job_cancel(BlockJob *job) 2638acc72a4SPaolo Bonzini { 2648acc72a4SPaolo Bonzini job->cancelled = true; 265751ebd76SFam Zheng block_job_enter(job); 2668acc72a4SPaolo Bonzini } 2678acc72a4SPaolo Bonzini 2682f0c9fe6SPaolo Bonzini bool block_job_is_cancelled(BlockJob *job) 2692f0c9fe6SPaolo Bonzini { 2702f0c9fe6SPaolo Bonzini return job->cancelled; 2712f0c9fe6SPaolo Bonzini } 2722f0c9fe6SPaolo Bonzini 27332c81a4aSPaolo Bonzini void block_job_iostatus_reset(BlockJob *job) 27432c81a4aSPaolo Bonzini { 27532c81a4aSPaolo Bonzini job->iostatus = BLOCK_DEVICE_IO_STATUS_OK; 2763fc4b10aSFam Zheng if (job->driver->iostatus_reset) { 2773fc4b10aSFam Zheng job->driver->iostatus_reset(job); 2783bd293c3SPaolo Bonzini } 27932c81a4aSPaolo Bonzini } 28032c81a4aSPaolo Bonzini 281345f9e1bSMax Reitz static int block_job_finish_sync(BlockJob *job, 282345f9e1bSMax Reitz void (*finish)(BlockJob *, Error **errp), 283345f9e1bSMax Reitz Error **errp) 2842f0c9fe6SPaolo Bonzini { 2852f0c9fe6SPaolo Bonzini BlockDriverState *bs = job->bs; 286345f9e1bSMax Reitz Error *local_err = NULL; 28794db6d2dSFam Zheng int ret; 2882f0c9fe6SPaolo Bonzini 2892f0c9fe6SPaolo Bonzini assert(bs->job == job); 2902f0c9fe6SPaolo Bonzini 29194db6d2dSFam Zheng block_job_ref(job); 292345f9e1bSMax Reitz finish(job, &local_err); 293345f9e1bSMax Reitz if (local_err) { 294345f9e1bSMax Reitz error_propagate(errp, local_err); 29594db6d2dSFam Zheng block_job_unref(job); 296345f9e1bSMax Reitz return -EBUSY; 297345f9e1bSMax Reitz } 29894db6d2dSFam Zheng while (!job->completed) { 299b47ec2c4SPaolo Bonzini aio_poll(bdrv_get_aio_context(bs), true); 3002f0c9fe6SPaolo Bonzini } 30194db6d2dSFam Zheng ret = (job->cancelled && job->ret == 0) ? -ECANCELED : job->ret; 30294db6d2dSFam Zheng block_job_unref(job); 30394db6d2dSFam Zheng return ret; 3042f0c9fe6SPaolo Bonzini } 3052f0c9fe6SPaolo Bonzini 306345f9e1bSMax Reitz /* A wrapper around block_job_cancel() taking an Error ** parameter so it may be 307345f9e1bSMax Reitz * used with block_job_finish_sync() without the need for (rather nasty) 308345f9e1bSMax Reitz * function pointer casts there. */ 309345f9e1bSMax Reitz static void block_job_cancel_err(BlockJob *job, Error **errp) 310345f9e1bSMax Reitz { 311345f9e1bSMax Reitz block_job_cancel(job); 312345f9e1bSMax Reitz } 313345f9e1bSMax Reitz 314345f9e1bSMax Reitz int block_job_cancel_sync(BlockJob *job) 315345f9e1bSMax Reitz { 316345f9e1bSMax Reitz return block_job_finish_sync(job, &block_job_cancel_err, NULL); 317345f9e1bSMax Reitz } 318345f9e1bSMax Reitz 319345f9e1bSMax Reitz int block_job_complete_sync(BlockJob *job, Error **errp) 320345f9e1bSMax Reitz { 321345f9e1bSMax Reitz return block_job_finish_sync(job, &block_job_complete, errp); 322345f9e1bSMax Reitz } 323345f9e1bSMax Reitz 3247483d1e5SAlex Bligh void block_job_sleep_ns(BlockJob *job, QEMUClockType type, int64_t ns) 3252f0c9fe6SPaolo Bonzini { 3268acc72a4SPaolo Bonzini assert(job->busy); 3278acc72a4SPaolo Bonzini 3282f0c9fe6SPaolo Bonzini /* Check cancellation *before* setting busy = false, too! */ 3298acc72a4SPaolo Bonzini if (block_job_is_cancelled(job)) { 3308acc72a4SPaolo Bonzini return; 3312f0c9fe6SPaolo Bonzini } 3328acc72a4SPaolo Bonzini 3338acc72a4SPaolo Bonzini job->busy = false; 3348acc72a4SPaolo Bonzini if (block_job_is_paused(job)) { 3358acc72a4SPaolo Bonzini qemu_coroutine_yield(); 3368acc72a4SPaolo Bonzini } else { 3370b9caf9bSFam Zheng co_aio_sleep_ns(bdrv_get_aio_context(job->bs), type, ns); 3388acc72a4SPaolo Bonzini } 3398acc72a4SPaolo Bonzini job->busy = true; 3402f0c9fe6SPaolo Bonzini } 34130e628b7SPaolo Bonzini 342dc71ce45SFam Zheng void block_job_yield(BlockJob *job) 343dc71ce45SFam Zheng { 344dc71ce45SFam Zheng assert(job->busy); 345dc71ce45SFam Zheng 346dc71ce45SFam Zheng /* Check cancellation *before* setting busy = false, too! */ 347dc71ce45SFam Zheng if (block_job_is_cancelled(job)) { 348dc71ce45SFam Zheng return; 349dc71ce45SFam Zheng } 350dc71ce45SFam Zheng 351dc71ce45SFam Zheng job->busy = false; 352dc71ce45SFam Zheng qemu_coroutine_yield(); 353dc71ce45SFam Zheng job->busy = true; 354dc71ce45SFam Zheng } 355dc71ce45SFam Zheng 35630e628b7SPaolo Bonzini BlockJobInfo *block_job_query(BlockJob *job) 35730e628b7SPaolo Bonzini { 35830e628b7SPaolo Bonzini BlockJobInfo *info = g_new0(BlockJobInfo, 1); 35979e14bf7SFam Zheng info->type = g_strdup(BlockJobType_lookup[job->driver->job_type]); 3608ccb9569SKevin Wolf info->device = g_strdup(job->id); 36130e628b7SPaolo Bonzini info->len = job->len; 3628d65883fSPaolo Bonzini info->busy = job->busy; 363751ebd76SFam Zheng info->paused = job->pause_count > 0; 36430e628b7SPaolo Bonzini info->offset = job->offset; 36530e628b7SPaolo Bonzini info->speed = job->speed; 36632c81a4aSPaolo Bonzini info->io_status = job->iostatus; 367ef6dbf1eSMax Reitz info->ready = job->ready; 36830e628b7SPaolo Bonzini return info; 36930e628b7SPaolo Bonzini } 37032c81a4aSPaolo Bonzini 37132c81a4aSPaolo Bonzini static void block_job_iostatus_set_err(BlockJob *job, int error) 37232c81a4aSPaolo Bonzini { 37332c81a4aSPaolo Bonzini if (job->iostatus == BLOCK_DEVICE_IO_STATUS_OK) { 37432c81a4aSPaolo Bonzini job->iostatus = error == ENOSPC ? BLOCK_DEVICE_IO_STATUS_NOSPACE : 37532c81a4aSPaolo Bonzini BLOCK_DEVICE_IO_STATUS_FAILED; 37632c81a4aSPaolo Bonzini } 37732c81a4aSPaolo Bonzini } 37832c81a4aSPaolo Bonzini 379bcada37bSWenchao Xia void block_job_event_cancelled(BlockJob *job) 380a66a2a36SPaolo Bonzini { 381bcada37bSWenchao Xia qapi_event_send_block_job_cancelled(job->driver->job_type, 3828ccb9569SKevin Wolf job->id, 383a66a2a36SPaolo Bonzini job->len, 384a66a2a36SPaolo Bonzini job->offset, 385bcada37bSWenchao Xia job->speed, 386bcada37bSWenchao Xia &error_abort); 387a66a2a36SPaolo Bonzini } 388a66a2a36SPaolo Bonzini 389bcada37bSWenchao Xia void block_job_event_completed(BlockJob *job, const char *msg) 390a66a2a36SPaolo Bonzini { 391bcada37bSWenchao Xia qapi_event_send_block_job_completed(job->driver->job_type, 3928ccb9569SKevin Wolf job->id, 393bcada37bSWenchao Xia job->len, 394bcada37bSWenchao Xia job->offset, 395bcada37bSWenchao Xia job->speed, 396bcada37bSWenchao Xia !!msg, 397bcada37bSWenchao Xia msg, 398bcada37bSWenchao Xia &error_abort); 399bcada37bSWenchao Xia } 400bcada37bSWenchao Xia 401bcada37bSWenchao Xia void block_job_event_ready(BlockJob *job) 402bcada37bSWenchao Xia { 403ef6dbf1eSMax Reitz job->ready = true; 404ef6dbf1eSMax Reitz 405518848a2SMarkus Armbruster qapi_event_send_block_job_ready(job->driver->job_type, 4068ccb9569SKevin Wolf job->id, 407518848a2SMarkus Armbruster job->len, 408518848a2SMarkus Armbruster job->offset, 409518848a2SMarkus Armbruster job->speed, &error_abort); 410a66a2a36SPaolo Bonzini } 411a66a2a36SPaolo Bonzini 41232c81a4aSPaolo Bonzini BlockErrorAction block_job_error_action(BlockJob *job, BlockDriverState *bs, 41332c81a4aSPaolo Bonzini BlockdevOnError on_err, 41432c81a4aSPaolo Bonzini int is_read, int error) 41532c81a4aSPaolo Bonzini { 41632c81a4aSPaolo Bonzini BlockErrorAction action; 41732c81a4aSPaolo Bonzini 41832c81a4aSPaolo Bonzini switch (on_err) { 41932c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_ENOSPC: 420a589569fSWenchao Xia action = (error == ENOSPC) ? 421a589569fSWenchao Xia BLOCK_ERROR_ACTION_STOP : BLOCK_ERROR_ACTION_REPORT; 42232c81a4aSPaolo Bonzini break; 42332c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_STOP: 424a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_STOP; 42532c81a4aSPaolo Bonzini break; 42632c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_REPORT: 427a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_REPORT; 42832c81a4aSPaolo Bonzini break; 42932c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_IGNORE: 430a589569fSWenchao Xia action = BLOCK_ERROR_ACTION_IGNORE; 43132c81a4aSPaolo Bonzini break; 43232c81a4aSPaolo Bonzini default: 43332c81a4aSPaolo Bonzini abort(); 43432c81a4aSPaolo Bonzini } 4358ccb9569SKevin Wolf qapi_event_send_block_job_error(job->id, 4365a2d2cbdSWenchao Xia is_read ? IO_OPERATION_TYPE_READ : 4375a2d2cbdSWenchao Xia IO_OPERATION_TYPE_WRITE, 4385a2d2cbdSWenchao Xia action, &error_abort); 439a589569fSWenchao Xia if (action == BLOCK_ERROR_ACTION_STOP) { 440751ebd76SFam Zheng /* make the pause user visible, which will be resumed from QMP. */ 441751ebd76SFam Zheng job->user_paused = true; 44232c81a4aSPaolo Bonzini block_job_pause(job); 44332c81a4aSPaolo Bonzini block_job_iostatus_set_err(job, error); 444373340b2SMax Reitz if (bs->blk && bs != job->bs) { 445373340b2SMax Reitz blk_iostatus_set_err(bs->blk, error); 44632c81a4aSPaolo Bonzini } 44732c81a4aSPaolo Bonzini } 44832c81a4aSPaolo Bonzini return action; 44932c81a4aSPaolo Bonzini } 450dec7d421SStefan Hajnoczi 451dec7d421SStefan Hajnoczi typedef struct { 452dec7d421SStefan Hajnoczi BlockJob *job; 453dec7d421SStefan Hajnoczi QEMUBH *bh; 454dec7d421SStefan Hajnoczi AioContext *aio_context; 455dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopFn *fn; 456dec7d421SStefan Hajnoczi void *opaque; 457dec7d421SStefan Hajnoczi } BlockJobDeferToMainLoopData; 458dec7d421SStefan Hajnoczi 459dec7d421SStefan Hajnoczi static void block_job_defer_to_main_loop_bh(void *opaque) 460dec7d421SStefan Hajnoczi { 461dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopData *data = opaque; 462dec7d421SStefan Hajnoczi AioContext *aio_context; 463dec7d421SStefan Hajnoczi 464dec7d421SStefan Hajnoczi qemu_bh_delete(data->bh); 465dec7d421SStefan Hajnoczi 466dec7d421SStefan Hajnoczi /* Prevent race with block_job_defer_to_main_loop() */ 467dec7d421SStefan Hajnoczi aio_context_acquire(data->aio_context); 468dec7d421SStefan Hajnoczi 469dec7d421SStefan Hajnoczi /* Fetch BDS AioContext again, in case it has changed */ 470dec7d421SStefan Hajnoczi aio_context = bdrv_get_aio_context(data->job->bs); 471dec7d421SStefan Hajnoczi aio_context_acquire(aio_context); 472dec7d421SStefan Hajnoczi 473dec7d421SStefan Hajnoczi data->fn(data->job, data->opaque); 474dec7d421SStefan Hajnoczi 475dec7d421SStefan Hajnoczi aio_context_release(aio_context); 476dec7d421SStefan Hajnoczi 477dec7d421SStefan Hajnoczi aio_context_release(data->aio_context); 478dec7d421SStefan Hajnoczi 479dec7d421SStefan Hajnoczi g_free(data); 480dec7d421SStefan Hajnoczi } 481dec7d421SStefan Hajnoczi 482dec7d421SStefan Hajnoczi void block_job_defer_to_main_loop(BlockJob *job, 483dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopFn *fn, 484dec7d421SStefan Hajnoczi void *opaque) 485dec7d421SStefan Hajnoczi { 486dec7d421SStefan Hajnoczi BlockJobDeferToMainLoopData *data = g_malloc(sizeof(*data)); 487dec7d421SStefan Hajnoczi data->job = job; 488dec7d421SStefan Hajnoczi data->bh = qemu_bh_new(block_job_defer_to_main_loop_bh, data); 489dec7d421SStefan Hajnoczi data->aio_context = bdrv_get_aio_context(job->bs); 490dec7d421SStefan Hajnoczi data->fn = fn; 491dec7d421SStefan Hajnoczi data->opaque = opaque; 492dec7d421SStefan Hajnoczi 493dec7d421SStefan Hajnoczi qemu_bh_schedule(data->bh); 494dec7d421SStefan Hajnoczi } 495c55a832fSFam Zheng 496c55a832fSFam Zheng BlockJobTxn *block_job_txn_new(void) 497c55a832fSFam Zheng { 498c55a832fSFam Zheng BlockJobTxn *txn = g_new0(BlockJobTxn, 1); 499c55a832fSFam Zheng QLIST_INIT(&txn->jobs); 500c55a832fSFam Zheng txn->refcnt = 1; 501c55a832fSFam Zheng return txn; 502c55a832fSFam Zheng } 503c55a832fSFam Zheng 504c55a832fSFam Zheng static void block_job_txn_ref(BlockJobTxn *txn) 505c55a832fSFam Zheng { 506c55a832fSFam Zheng txn->refcnt++; 507c55a832fSFam Zheng } 508c55a832fSFam Zheng 509c55a832fSFam Zheng void block_job_txn_unref(BlockJobTxn *txn) 510c55a832fSFam Zheng { 511c55a832fSFam Zheng if (txn && --txn->refcnt == 0) { 512c55a832fSFam Zheng g_free(txn); 513c55a832fSFam Zheng } 514c55a832fSFam Zheng } 515c55a832fSFam Zheng 516c55a832fSFam Zheng void block_job_txn_add_job(BlockJobTxn *txn, BlockJob *job) 517c55a832fSFam Zheng { 518c55a832fSFam Zheng if (!txn) { 519c55a832fSFam Zheng return; 520c55a832fSFam Zheng } 521c55a832fSFam Zheng 522c55a832fSFam Zheng assert(!job->txn); 523c55a832fSFam Zheng job->txn = txn; 524c55a832fSFam Zheng 525c55a832fSFam Zheng QLIST_INSERT_HEAD(&txn->jobs, job, txn_list); 526c55a832fSFam Zheng block_job_txn_ref(txn); 527c55a832fSFam Zheng } 528