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 262f0c9fe6SPaolo Bonzini #include "config-host.h" 272f0c9fe6SPaolo Bonzini #include "qemu-common.h" 282f0c9fe6SPaolo Bonzini #include "trace.h" 292f0c9fe6SPaolo Bonzini #include "monitor.h" 302f0c9fe6SPaolo Bonzini #include "block.h" 312f0c9fe6SPaolo Bonzini #include "blockjob.h" 322f0c9fe6SPaolo Bonzini #include "block_int.h" 332f0c9fe6SPaolo Bonzini #include "qjson.h" 342f0c9fe6SPaolo Bonzini #include "qemu-coroutine.h" 352f0c9fe6SPaolo Bonzini #include "qmp-commands.h" 362f0c9fe6SPaolo Bonzini #include "qemu-timer.h" 372f0c9fe6SPaolo Bonzini 382f0c9fe6SPaolo Bonzini void *block_job_create(const BlockJobType *job_type, BlockDriverState *bs, 392f0c9fe6SPaolo Bonzini int64_t speed, BlockDriverCompletionFunc *cb, 402f0c9fe6SPaolo Bonzini void *opaque, Error **errp) 412f0c9fe6SPaolo Bonzini { 422f0c9fe6SPaolo Bonzini BlockJob *job; 432f0c9fe6SPaolo Bonzini 442f0c9fe6SPaolo Bonzini if (bs->job || bdrv_in_use(bs)) { 452f0c9fe6SPaolo Bonzini error_set(errp, QERR_DEVICE_IN_USE, bdrv_get_device_name(bs)); 462f0c9fe6SPaolo Bonzini return NULL; 472f0c9fe6SPaolo Bonzini } 482f0c9fe6SPaolo Bonzini bdrv_set_in_use(bs, 1); 492f0c9fe6SPaolo Bonzini 502f0c9fe6SPaolo Bonzini job = g_malloc0(job_type->instance_size); 512f0c9fe6SPaolo Bonzini job->job_type = job_type; 522f0c9fe6SPaolo Bonzini job->bs = bs; 532f0c9fe6SPaolo Bonzini job->cb = cb; 542f0c9fe6SPaolo Bonzini job->opaque = opaque; 552f0c9fe6SPaolo Bonzini job->busy = true; 562f0c9fe6SPaolo Bonzini bs->job = job; 572f0c9fe6SPaolo Bonzini 582f0c9fe6SPaolo Bonzini /* Only set speed when necessary to avoid NotSupported error */ 592f0c9fe6SPaolo Bonzini if (speed != 0) { 602f0c9fe6SPaolo Bonzini Error *local_err = NULL; 612f0c9fe6SPaolo Bonzini 622f0c9fe6SPaolo Bonzini block_job_set_speed(job, speed, &local_err); 632f0c9fe6SPaolo Bonzini if (error_is_set(&local_err)) { 642f0c9fe6SPaolo Bonzini bs->job = NULL; 652f0c9fe6SPaolo Bonzini g_free(job); 662f0c9fe6SPaolo Bonzini bdrv_set_in_use(bs, 0); 672f0c9fe6SPaolo Bonzini error_propagate(errp, local_err); 682f0c9fe6SPaolo Bonzini return NULL; 692f0c9fe6SPaolo Bonzini } 702f0c9fe6SPaolo Bonzini } 712f0c9fe6SPaolo Bonzini return job; 722f0c9fe6SPaolo Bonzini } 732f0c9fe6SPaolo Bonzini 742f0c9fe6SPaolo Bonzini void block_job_complete(BlockJob *job, int ret) 752f0c9fe6SPaolo Bonzini { 762f0c9fe6SPaolo Bonzini BlockDriverState *bs = job->bs; 772f0c9fe6SPaolo Bonzini 782f0c9fe6SPaolo Bonzini assert(bs->job == job); 792f0c9fe6SPaolo Bonzini job->cb(job->opaque, ret); 802f0c9fe6SPaolo Bonzini bs->job = NULL; 812f0c9fe6SPaolo Bonzini g_free(job); 822f0c9fe6SPaolo Bonzini bdrv_set_in_use(bs, 0); 832f0c9fe6SPaolo Bonzini } 842f0c9fe6SPaolo Bonzini 852f0c9fe6SPaolo Bonzini void block_job_set_speed(BlockJob *job, int64_t speed, Error **errp) 862f0c9fe6SPaolo Bonzini { 872f0c9fe6SPaolo Bonzini Error *local_err = NULL; 882f0c9fe6SPaolo Bonzini 892f0c9fe6SPaolo Bonzini if (!job->job_type->set_speed) { 902f0c9fe6SPaolo Bonzini error_set(errp, QERR_NOT_SUPPORTED); 912f0c9fe6SPaolo Bonzini return; 922f0c9fe6SPaolo Bonzini } 932f0c9fe6SPaolo Bonzini job->job_type->set_speed(job, speed, &local_err); 942f0c9fe6SPaolo Bonzini if (error_is_set(&local_err)) { 952f0c9fe6SPaolo Bonzini error_propagate(errp, local_err); 962f0c9fe6SPaolo Bonzini return; 972f0c9fe6SPaolo Bonzini } 982f0c9fe6SPaolo Bonzini 992f0c9fe6SPaolo Bonzini job->speed = speed; 1002f0c9fe6SPaolo Bonzini } 1012f0c9fe6SPaolo Bonzini 1028acc72a4SPaolo Bonzini void block_job_pause(BlockJob *job) 1032f0c9fe6SPaolo Bonzini { 1048acc72a4SPaolo Bonzini job->paused = true; 1058acc72a4SPaolo Bonzini } 1068acc72a4SPaolo Bonzini 1078acc72a4SPaolo Bonzini bool block_job_is_paused(BlockJob *job) 1088acc72a4SPaolo Bonzini { 1098acc72a4SPaolo Bonzini return job->paused; 1108acc72a4SPaolo Bonzini } 1118acc72a4SPaolo Bonzini 1128acc72a4SPaolo Bonzini void block_job_resume(BlockJob *job) 1138acc72a4SPaolo Bonzini { 1148acc72a4SPaolo Bonzini job->paused = false; 115*32c81a4aSPaolo Bonzini block_job_iostatus_reset(job); 1162f0c9fe6SPaolo Bonzini if (job->co && !job->busy) { 1172f0c9fe6SPaolo Bonzini qemu_coroutine_enter(job->co, NULL); 1182f0c9fe6SPaolo Bonzini } 1192f0c9fe6SPaolo Bonzini } 1202f0c9fe6SPaolo Bonzini 1218acc72a4SPaolo Bonzini void block_job_cancel(BlockJob *job) 1228acc72a4SPaolo Bonzini { 1238acc72a4SPaolo Bonzini job->cancelled = true; 1248acc72a4SPaolo Bonzini block_job_resume(job); 1258acc72a4SPaolo Bonzini } 1268acc72a4SPaolo Bonzini 1272f0c9fe6SPaolo Bonzini bool block_job_is_cancelled(BlockJob *job) 1282f0c9fe6SPaolo Bonzini { 1292f0c9fe6SPaolo Bonzini return job->cancelled; 1302f0c9fe6SPaolo Bonzini } 1312f0c9fe6SPaolo Bonzini 132*32c81a4aSPaolo Bonzini void block_job_iostatus_reset(BlockJob *job) 133*32c81a4aSPaolo Bonzini { 134*32c81a4aSPaolo Bonzini job->iostatus = BLOCK_DEVICE_IO_STATUS_OK; 135*32c81a4aSPaolo Bonzini } 136*32c81a4aSPaolo Bonzini 1372f0c9fe6SPaolo Bonzini struct BlockCancelData { 1382f0c9fe6SPaolo Bonzini BlockJob *job; 1392f0c9fe6SPaolo Bonzini BlockDriverCompletionFunc *cb; 1402f0c9fe6SPaolo Bonzini void *opaque; 1412f0c9fe6SPaolo Bonzini bool cancelled; 1422f0c9fe6SPaolo Bonzini int ret; 1432f0c9fe6SPaolo Bonzini }; 1442f0c9fe6SPaolo Bonzini 1452f0c9fe6SPaolo Bonzini static void block_job_cancel_cb(void *opaque, int ret) 1462f0c9fe6SPaolo Bonzini { 1472f0c9fe6SPaolo Bonzini struct BlockCancelData *data = opaque; 1482f0c9fe6SPaolo Bonzini 1492f0c9fe6SPaolo Bonzini data->cancelled = block_job_is_cancelled(data->job); 1502f0c9fe6SPaolo Bonzini data->ret = ret; 1512f0c9fe6SPaolo Bonzini data->cb(data->opaque, ret); 1522f0c9fe6SPaolo Bonzini } 1532f0c9fe6SPaolo Bonzini 1542f0c9fe6SPaolo Bonzini int block_job_cancel_sync(BlockJob *job) 1552f0c9fe6SPaolo Bonzini { 1562f0c9fe6SPaolo Bonzini struct BlockCancelData data; 1572f0c9fe6SPaolo Bonzini BlockDriverState *bs = job->bs; 1582f0c9fe6SPaolo Bonzini 1592f0c9fe6SPaolo Bonzini assert(bs->job == job); 1602f0c9fe6SPaolo Bonzini 1612f0c9fe6SPaolo Bonzini /* Set up our own callback to store the result and chain to 1622f0c9fe6SPaolo Bonzini * the original callback. 1632f0c9fe6SPaolo Bonzini */ 1642f0c9fe6SPaolo Bonzini data.job = job; 1652f0c9fe6SPaolo Bonzini data.cb = job->cb; 1662f0c9fe6SPaolo Bonzini data.opaque = job->opaque; 1672f0c9fe6SPaolo Bonzini data.ret = -EINPROGRESS; 1682f0c9fe6SPaolo Bonzini job->cb = block_job_cancel_cb; 1692f0c9fe6SPaolo Bonzini job->opaque = &data; 1702f0c9fe6SPaolo Bonzini block_job_cancel(job); 1712f0c9fe6SPaolo Bonzini while (data.ret == -EINPROGRESS) { 1722f0c9fe6SPaolo Bonzini qemu_aio_wait(); 1732f0c9fe6SPaolo Bonzini } 1742f0c9fe6SPaolo Bonzini return (data.cancelled && data.ret == 0) ? -ECANCELED : data.ret; 1752f0c9fe6SPaolo Bonzini } 1762f0c9fe6SPaolo Bonzini 1772f0c9fe6SPaolo Bonzini void block_job_sleep_ns(BlockJob *job, QEMUClock *clock, int64_t ns) 1782f0c9fe6SPaolo Bonzini { 1798acc72a4SPaolo Bonzini assert(job->busy); 1808acc72a4SPaolo Bonzini 1812f0c9fe6SPaolo Bonzini /* Check cancellation *before* setting busy = false, too! */ 1828acc72a4SPaolo Bonzini if (block_job_is_cancelled(job)) { 1838acc72a4SPaolo Bonzini return; 1842f0c9fe6SPaolo Bonzini } 1858acc72a4SPaolo Bonzini 1868acc72a4SPaolo Bonzini job->busy = false; 1878acc72a4SPaolo Bonzini if (block_job_is_paused(job)) { 1888acc72a4SPaolo Bonzini qemu_coroutine_yield(); 1898acc72a4SPaolo Bonzini } else { 1908acc72a4SPaolo Bonzini co_sleep_ns(clock, ns); 1918acc72a4SPaolo Bonzini } 1928acc72a4SPaolo Bonzini job->busy = true; 1932f0c9fe6SPaolo Bonzini } 19430e628b7SPaolo Bonzini 19530e628b7SPaolo Bonzini BlockJobInfo *block_job_query(BlockJob *job) 19630e628b7SPaolo Bonzini { 19730e628b7SPaolo Bonzini BlockJobInfo *info = g_new0(BlockJobInfo, 1); 19830e628b7SPaolo Bonzini info->type = g_strdup(job->job_type->job_type); 19930e628b7SPaolo Bonzini info->device = g_strdup(bdrv_get_device_name(job->bs)); 20030e628b7SPaolo Bonzini info->len = job->len; 2018d65883fSPaolo Bonzini info->busy = job->busy; 2028acc72a4SPaolo Bonzini info->paused = job->paused; 20330e628b7SPaolo Bonzini info->offset = job->offset; 20430e628b7SPaolo Bonzini info->speed = job->speed; 205*32c81a4aSPaolo Bonzini info->io_status = job->iostatus; 20630e628b7SPaolo Bonzini return info; 20730e628b7SPaolo Bonzini } 208*32c81a4aSPaolo Bonzini 209*32c81a4aSPaolo Bonzini static void block_job_iostatus_set_err(BlockJob *job, int error) 210*32c81a4aSPaolo Bonzini { 211*32c81a4aSPaolo Bonzini if (job->iostatus == BLOCK_DEVICE_IO_STATUS_OK) { 212*32c81a4aSPaolo Bonzini job->iostatus = error == ENOSPC ? BLOCK_DEVICE_IO_STATUS_NOSPACE : 213*32c81a4aSPaolo Bonzini BLOCK_DEVICE_IO_STATUS_FAILED; 214*32c81a4aSPaolo Bonzini } 215*32c81a4aSPaolo Bonzini } 216*32c81a4aSPaolo Bonzini 217*32c81a4aSPaolo Bonzini 218*32c81a4aSPaolo Bonzini BlockErrorAction block_job_error_action(BlockJob *job, BlockDriverState *bs, 219*32c81a4aSPaolo Bonzini BlockdevOnError on_err, 220*32c81a4aSPaolo Bonzini int is_read, int error) 221*32c81a4aSPaolo Bonzini { 222*32c81a4aSPaolo Bonzini BlockErrorAction action; 223*32c81a4aSPaolo Bonzini 224*32c81a4aSPaolo Bonzini switch (on_err) { 225*32c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_ENOSPC: 226*32c81a4aSPaolo Bonzini action = (error == ENOSPC) ? BDRV_ACTION_STOP : BDRV_ACTION_REPORT; 227*32c81a4aSPaolo Bonzini break; 228*32c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_STOP: 229*32c81a4aSPaolo Bonzini action = BDRV_ACTION_STOP; 230*32c81a4aSPaolo Bonzini break; 231*32c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_REPORT: 232*32c81a4aSPaolo Bonzini action = BDRV_ACTION_REPORT; 233*32c81a4aSPaolo Bonzini break; 234*32c81a4aSPaolo Bonzini case BLOCKDEV_ON_ERROR_IGNORE: 235*32c81a4aSPaolo Bonzini action = BDRV_ACTION_IGNORE; 236*32c81a4aSPaolo Bonzini break; 237*32c81a4aSPaolo Bonzini default: 238*32c81a4aSPaolo Bonzini abort(); 239*32c81a4aSPaolo Bonzini } 240*32c81a4aSPaolo Bonzini bdrv_emit_qmp_error_event(job->bs, QEVENT_BLOCK_JOB_ERROR, action, is_read); 241*32c81a4aSPaolo Bonzini if (action == BDRV_ACTION_STOP) { 242*32c81a4aSPaolo Bonzini block_job_pause(job); 243*32c81a4aSPaolo Bonzini block_job_iostatus_set_err(job, error); 244*32c81a4aSPaolo Bonzini if (bs != job->bs) { 245*32c81a4aSPaolo Bonzini bdrv_iostatus_set_err(bs, error); 246*32c81a4aSPaolo Bonzini } 247*32c81a4aSPaolo Bonzini } 248*32c81a4aSPaolo Bonzini return action; 249*32c81a4aSPaolo Bonzini } 250