[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH v10 10/10] Add a new API to start/stop replication,
From: |
Wen Congyang |
Subject: |
[Qemu-devel] [PATCH v10 10/10] Add a new API to start/stop replication, do checkpoint to all BDSes |
Date: |
Fri, 25 Sep 2015 14:17:38 +0800 |
Signed-off-by: Wen Congyang <address@hidden>
Signed-off-by: zhanghailiang <address@hidden>
Signed-off-by: Gonglei <address@hidden>
---
block.c | 83 +++++++++++++++++++++++++++++++++++++++++++++++++++
include/block/block.h | 4 +++
2 files changed, 87 insertions(+)
diff --git a/block.c b/block.c
index 5cb916b..5891c4d 100644
--- a/block.c
+++ b/block.c
@@ -4296,3 +4296,86 @@ void bdrv_stop_replication(BlockDriverState *bs, bool
failover, Error **errp)
" replication", bs->filename);
}
}
+
+void bdrv_start_replication_all(ReplicationMode mode, Error **errp)
+{
+ BlockDriverState *bs = NULL, *temp = NULL;
+ Error *local_err = NULL;
+
+ while ((bs = bdrv_next(bs))) {
+ if (!QLIST_EMPTY(&bs->parents)) {
+ /* It is not top BDS */
+ continue;
+ }
+
+ if (bdrv_is_read_only(bs) || !bdrv_is_inserted(bs)) {
+ continue;
+ }
+
+ bdrv_start_replication(bs, mode, &local_err);
+ if (local_err) {
+ error_propagate(errp, local_err);
+ goto fail;
+ }
+ }
+
+ return;
+
+fail:
+ while ((temp = bdrv_next(temp)) && bs != temp) {
+ bdrv_stop_replication(temp, false, NULL);
+ }
+}
+
+void bdrv_do_checkpoint_all(Error **errp)
+{
+ BlockDriverState *bs = NULL;
+ Error *local_err = NULL;
+
+ while ((bs = bdrv_next(bs))) {
+ if (!QLIST_EMPTY(&bs->parents)) {
+ /* It is not top BDS */
+ continue;
+ }
+
+ if (bdrv_is_read_only(bs) || !bdrv_is_inserted(bs)) {
+ continue;
+ }
+
+ bdrv_do_checkpoint(bs, &local_err);
+ if (local_err) {
+ error_propagate(errp, local_err);
+ return;
+ }
+ }
+}
+
+void bdrv_stop_replication_all(bool failover, Error **errp)
+{
+ BlockDriverState *bs = NULL;
+ Error *local_err = NULL;
+
+ while ((bs = bdrv_next(bs))) {
+ if (!QLIST_EMPTY(&bs->parents)) {
+ /* It is not top BDS */
+ continue;
+ }
+
+ if (bdrv_is_read_only(bs) || !bdrv_is_inserted(bs)) {
+ continue;
+ }
+
+ bdrv_stop_replication(bs, failover, &local_err);
+ if (!errp) {
+ /*
+ * The caller doesn't care the result, they just
+ * want to stop all block's replication.
+ */
+ continue;
+ }
+ if (local_err) {
+ error_propagate(errp, local_err);
+ return;
+ }
+ }
+}
diff --git a/include/block/block.h b/include/block/block.h
index 40ef59f..eb6a4a2 100644
--- a/include/block/block.h
+++ b/include/block/block.h
@@ -616,4 +616,8 @@ void bdrv_start_replication(BlockDriverState *bs,
ReplicationMode mode,
void bdrv_do_checkpoint(BlockDriverState *bs, Error **errp);
void bdrv_stop_replication(BlockDriverState *bs, bool failover, Error **errp);
+void bdrv_start_replication_all(ReplicationMode mode, Error **errp);
+void bdrv_do_checkpoint_all(Error **errp);
+void bdrv_stop_replication_all(bool failover, Error **errp);
+
#endif
--
2.4.3
- [Qemu-devel] [PATCH v10 00/10] Block replication for continuous checkpoints, Wen Congyang, 2015/09/25
- [Qemu-devel] [PATCH v10 02/10] Backup: clear all bitmap when doing block checkpoint, Wen Congyang, 2015/09/25
- [Qemu-devel] [PATCH v10 01/10] allow writing to the backing file, Wen Congyang, 2015/09/25
- [Qemu-devel] [PATCH v10 03/10] Allow creating backup jobs when opening BDS, Wen Congyang, 2015/09/25
- [Qemu-devel] [PATCH v10 04/10] block: make bdrv_put_ref_bh_schedule() as a public API, Wen Congyang, 2015/09/25
- [Qemu-devel] [PATCH v10 06/10] Add new block driver interfaces to control block replication, Wen Congyang, 2015/09/25
- [Qemu-devel] [PATCH v10 07/10] quorum: implement block driver interfaces for block replication, Wen Congyang, 2015/09/25
- [Qemu-devel] [PATCH v10 05/10] docs: block replication's description, Wen Congyang, 2015/09/25
- [Qemu-devel] [PATCH v10 09/10] support replication driver in blockdev-add, Wen Congyang, 2015/09/25
- [Qemu-devel] [PATCH v10 10/10] Add a new API to start/stop replication, do checkpoint to all BDSes,
Wen Congyang <=
- [Qemu-devel] [PATCH v10 08/10] Implement new driver for block replication, Wen Congyang, 2015/09/25