[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-block] [PATCH v10 07/10] quorum: implement block driver interfaces
From: |
Wen Congyang |
Subject: |
[Qemu-block] [PATCH v10 07/10] quorum: implement block driver interfaces for block replication |
Date: |
Fri, 25 Sep 2015 14:17:35 +0800 |
Signed-off-by: Wen Congyang <address@hidden>
Signed-off-by: zhanghailiang <address@hidden>
Signed-off-by: Gonglei <address@hidden>
Reviewed-by: Alberto Garcia <address@hidden>
---
block/quorum.c | 77 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 file changed, 77 insertions(+)
diff --git a/block/quorum.c b/block/quorum.c
index 111a57b..d647ab4 100644
--- a/block/quorum.c
+++ b/block/quorum.c
@@ -85,6 +85,8 @@ typedef struct BDRVQuorumState {
*/
QuorumReadPattern read_pattern;
+
+ int replication_index; /* store which child supports block replication */
} BDRVQuorumState;
typedef struct QuorumAIOCB QuorumAIOCB;
@@ -945,6 +947,7 @@ static int quorum_open(BlockDriverState *bs, QDict
*options, int flags,
}
g_free(opened);
+ s->replication_index = -1;
goto exit;
close_exit:
@@ -1093,6 +1096,76 @@ static void quorum_refresh_filename(BlockDriverState *bs)
bs->full_open_options = opts;
}
+static void quorum_start_replication(BlockDriverState *bs, ReplicationMode
mode,
+ Error **errp)
+{
+ BDRVQuorumState *s = bs->opaque;
+ int count = 0, i, index;
+ Error *local_err = NULL;
+
+ /*
+ * TODO: support REPLICATION_MODE_SECONDARY if we allow secondary
+ * QEMU becoming primary QEMU.
+ */
+ if (mode != REPLICATION_MODE_PRIMARY) {
+ error_setg(errp, "The replication mode for quorum should be
'primary'");
+ return;
+ }
+
+ if (s->read_pattern != QUORUM_READ_PATTERN_FIFO) {
+ error_setg(errp, "Block replication needs read pattern 'fifo'");
+ return;
+ }
+
+ for (i = 0; i < s->num_children; i++) {
+ bdrv_start_replication(s->bs[i], mode, &local_err);
+ if (local_err) {
+ error_free(local_err);
+ local_err = NULL;
+ } else {
+ count++;
+ index = i;
+ }
+ }
+
+ if (count == 0) {
+ error_setg(errp, "No child supports block replication");
+ } else if (count > 1) {
+ for (i = 0; i < s->num_children; i++) {
+ bdrv_stop_replication(s->bs[i], false, NULL);
+ }
+ error_setg(errp, "Too many children support block replication");
+ } else {
+ s->replication_index = index;
+ }
+}
+
+static void quorum_do_checkpoint(BlockDriverState *bs, Error **errp)
+{
+ BDRVQuorumState *s = bs->opaque;
+
+ if (s->replication_index < 0) {
+ error_setg(errp, "Block replication is not running");
+ return;
+ }
+
+ bdrv_do_checkpoint(s->bs[s->replication_index], errp);
+}
+
+static void quorum_stop_replication(BlockDriverState *bs, bool failover,
+ Error **errp)
+{
+ BDRVQuorumState *s = bs->opaque;
+
+ if (s->replication_index < 0) {
+ error_setg(errp, "Block replication is not running");
+ return;
+ }
+
+ bdrv_stop_replication(s->bs[s->replication_index], failover, errp);
+ s->replication_index = -1;
+}
+
static BlockDriver bdrv_quorum = {
.format_name = "quorum",
.protocol_name = "quorum",
@@ -1119,6 +1192,10 @@ static BlockDriver bdrv_quorum = {
.is_filter = true,
.bdrv_recurse_is_first_non_filter = quorum_recurse_is_first_non_filter,
+
+ .bdrv_start_replication = quorum_start_replication,
+ .bdrv_do_checkpoint = quorum_do_checkpoint,
+ .bdrv_stop_replication = quorum_stop_replication,
};
static void bdrv_quorum_init(void)
--
2.4.3
- [Qemu-block] [PATCH v10 00/10] Block replication for continuous checkpoints, Wen Congyang, 2015/09/25
- [Qemu-block] [PATCH v10 02/10] Backup: clear all bitmap when doing block checkpoint, Wen Congyang, 2015/09/25
- [Qemu-block] [PATCH v10 01/10] allow writing to the backing file, Wen Congyang, 2015/09/25
- [Qemu-block] [PATCH v10 03/10] Allow creating backup jobs when opening BDS, Wen Congyang, 2015/09/25
- [Qemu-block] [PATCH v10 04/10] block: make bdrv_put_ref_bh_schedule() as a public API, Wen Congyang, 2015/09/25
- [Qemu-block] [PATCH v10 06/10] Add new block driver interfaces to control block replication, Wen Congyang, 2015/09/25
- [Qemu-block] [PATCH v10 07/10] quorum: implement block driver interfaces for block replication,
Wen Congyang <=
- [Qemu-block] [PATCH v10 09/10] support replication driver in blockdev-add, Wen Congyang, 2015/09/25
- [Qemu-block] [PATCH v10 05/10] docs: block replication's description, Wen Congyang, 2015/09/25
- [Qemu-block] [PATCH v10 10/10] Add a new API to start/stop replication, do checkpoint to all BDSes, Wen Congyang, 2015/09/25
- [Qemu-block] [PATCH v10 08/10] Implement new driver for block replication, Wen Congyang, 2015/09/25