[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH v11 12/12] Add a new API to start/stop replication,
From: |
Wen Congyang |
Subject: |
[Qemu-devel] [PATCH v11 12/12] Add a new API to start/stop replication, do checkpoint to all BDSes |
Date: |
Tue, 3 Nov 2015 18:58:49 +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 04b928c..517fa4b 100644
--- a/block.c
+++ b/block.c
@@ -4208,3 +4208,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 288e14e..8427969 100644
--- a/include/block/block.h
+++ b/include/block/block.h
@@ -643,4 +643,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 v11 00/12] Block replication is a very important feature which is used for, Wen Congyang, 2015/11/03
- [Qemu-devel] [PATCH v11 01/12] unblock backup operations in backing file, Wen Congyang, 2015/11/03
- [Qemu-devel] [PATCH v11 03/12] allow writing to the backing file, Wen Congyang, 2015/11/03
- [Qemu-devel] [PATCH v11 02/12] Store parent BDS in BdrvChild, Wen Congyang, 2015/11/03
- [Qemu-devel] [PATCH v11 08/12] Add new block driver interfaces to control block replication, Wen Congyang, 2015/11/03
- [Qemu-devel] [PATCH v11 07/12] docs: block replication's description, Wen Congyang, 2015/11/03
- [Qemu-devel] [PATCH v11 06/12] block: make bdrv_put_ref_bh_schedule() as a public API, Wen Congyang, 2015/11/03
- [Qemu-devel] [PATCH v11 05/12] Allow creating backup jobs when opening BDS, Wen Congyang, 2015/11/03
- [Qemu-devel] [PATCH v11 12/12] Add a new API to start/stop replication, do checkpoint to all BDSes,
Wen Congyang <=
- [Qemu-devel] [PATCH v11 10/12] Implement new driver for block replication, Wen Congyang, 2015/11/03
- [Qemu-devel] [PATCH v11 09/12] quorum: implement block driver interfaces for block replication, Wen Congyang, 2015/11/03
- [Qemu-devel] [PATCH v11 04/12] Backup: clear all bitmap when doing block checkpoint, Wen Congyang, 2015/11/03
- [Qemu-devel] [PATCH v11 11/12] support replication driver in blockdev-add, Wen Congyang, 2015/11/03
- Re: [Qemu-devel] [PATCH v11 00/12] Block replication for continuous checkpoints, Wen Congyang, 2015/11/12