2 * QEMU System Emulator block driver
4 * Copyright (c) 2011 IBM Corp.
5 * Copyright (c) 2012 Red Hat, Inc.
7 * Permission is hereby granted, free of charge, to any person obtaining a copy
8 * of this software and associated documentation files (the "Software"), to deal
9 * in the Software without restriction, including without limitation the rights
10 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
11 * copies of the Software, and to permit persons to whom the Software is
12 * furnished to do so, subject to the following conditions:
14 * The above copyright notice and this permission notice shall be included in
15 * all copies or substantial portions of the Software.
17 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
18 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
19 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
20 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
21 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
22 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
26 #include "config-host.h"
27 #include "qemu-common.h"
32 #include "block_int.h"
34 #include "qemu-coroutine.h"
35 #include "qmp-commands.h"
36 #include "qemu-timer.h"
38 void *block_job_create(const BlockJobType
*job_type
, BlockDriverState
*bs
,
39 int64_t speed
, BlockDriverCompletionFunc
*cb
,
40 void *opaque
, Error
**errp
)
44 if (bs
->job
|| bdrv_in_use(bs
)) {
45 error_set(errp
, QERR_DEVICE_IN_USE
, bdrv_get_device_name(bs
));
48 bdrv_set_in_use(bs
, 1);
50 job
= g_malloc0(job_type
->instance_size
);
51 job
->job_type
= job_type
;
58 /* Only set speed when necessary to avoid NotSupported error */
60 Error
*local_err
= NULL
;
62 block_job_set_speed(job
, speed
, &local_err
);
63 if (error_is_set(&local_err
)) {
66 bdrv_set_in_use(bs
, 0);
67 error_propagate(errp
, local_err
);
74 void block_job_complete(BlockJob
*job
, int ret
)
76 BlockDriverState
*bs
= job
->bs
;
78 assert(bs
->job
== job
);
79 job
->cb(job
->opaque
, ret
);
82 bdrv_set_in_use(bs
, 0);
85 void block_job_set_speed(BlockJob
*job
, int64_t speed
, Error
**errp
)
87 Error
*local_err
= NULL
;
89 if (!job
->job_type
->set_speed
) {
90 error_set(errp
, QERR_NOT_SUPPORTED
);
93 job
->job_type
->set_speed(job
, speed
, &local_err
);
94 if (error_is_set(&local_err
)) {
95 error_propagate(errp
, local_err
);
102 void block_job_pause(BlockJob
*job
)
107 bool block_job_is_paused(BlockJob
*job
)
112 void block_job_resume(BlockJob
*job
)
115 if (job
->co
&& !job
->busy
) {
116 qemu_coroutine_enter(job
->co
, NULL
);
120 void block_job_cancel(BlockJob
*job
)
122 job
->cancelled
= true;
123 block_job_resume(job
);
126 bool block_job_is_cancelled(BlockJob
*job
)
128 return job
->cancelled
;
131 struct BlockCancelData
{
133 BlockDriverCompletionFunc
*cb
;
139 static void block_job_cancel_cb(void *opaque
, int ret
)
141 struct BlockCancelData
*data
= opaque
;
143 data
->cancelled
= block_job_is_cancelled(data
->job
);
145 data
->cb(data
->opaque
, ret
);
148 int block_job_cancel_sync(BlockJob
*job
)
150 struct BlockCancelData data
;
151 BlockDriverState
*bs
= job
->bs
;
153 assert(bs
->job
== job
);
155 /* Set up our own callback to store the result and chain to
156 * the original callback.
160 data
.opaque
= job
->opaque
;
161 data
.ret
= -EINPROGRESS
;
162 job
->cb
= block_job_cancel_cb
;
164 block_job_cancel(job
);
165 while (data
.ret
== -EINPROGRESS
) {
168 return (data
.cancelled
&& data
.ret
== 0) ? -ECANCELED
: data
.ret
;
171 void block_job_sleep_ns(BlockJob
*job
, QEMUClock
*clock
, int64_t ns
)
175 /* Check cancellation *before* setting busy = false, too! */
176 if (block_job_is_cancelled(job
)) {
181 if (block_job_is_paused(job
)) {
182 qemu_coroutine_yield();
184 co_sleep_ns(clock
, ns
);
189 BlockJobInfo
*block_job_query(BlockJob
*job
)
191 BlockJobInfo
*info
= g_new0(BlockJobInfo
, 1);
192 info
->type
= g_strdup(job
->job_type
->job_type
);
193 info
->device
= g_strdup(bdrv_get_device_name(job
->bs
));
194 info
->len
= job
->len
;
195 info
->busy
= job
->busy
;
196 info
->paused
= job
->paused
;
197 info
->offset
= job
->offset
;
198 info
->speed
= job
->speed
;