[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-block] [PATCH COLO v3 06/14] NBD client: implement block driver in
From: |
Wen Congyang |
Subject: |
[Qemu-block] [PATCH COLO v3 06/14] NBD client: implement block driver interfaces for block replication |
Date: |
Fri, 3 Apr 2015 18:01:12 +0800 |
Signed-off-by: Wen Congyang <address@hidden>
Signed-off-by: zhanghailiang <address@hidden>
Signed-off-by: Gonglei <address@hidden>
---
block/nbd.c | 49 +++++++++++++++++++++++++++++++++++++++++++++++++
1 file changed, 49 insertions(+)
diff --git a/block/nbd.c b/block/nbd.c
index 3faf865..269ffe0 100644
--- a/block/nbd.c
+++ b/block/nbd.c
@@ -458,6 +458,52 @@ static void nbd_refresh_filename(BlockDriverState *bs)
bs->full_open_options = opts;
}
+static void nbd_start_replication(BlockDriverState *bs, ReplicationMode mode,
+ Error **errp)
+{
+ BDRVNBDState *s = bs->opaque;
+
+ /*
+ * TODO: support REPLICATION_MODE_SECONDARY if we allow secondary
+ * QEMU becoming primary QEMU.
+ */
+ if (mode != REPLICATION_MODE_PRIMARY) {
+ error_setg(errp, "Invalid parameter '%s'", "mode");
+ return;
+ }
+
+ if (s->connected) {
+ error_setg(errp, "The connection is established");
+ return;
+ }
+
+ /* TODO: NBD client should be one child of quorum, how to verify it? */
+ nbd_connect_server(bs, errp);
+}
+
+static void nbd_do_checkpoint(BlockDriverState *bs, Error **errp)
+{
+ BDRVNBDState *s = bs->opaque;
+
+ if (!s->connected) {
+ error_setg(errp, "The connection is not established");
+ return;
+ }
+}
+
+static void nbd_stop_replication(BlockDriverState *bs, Error **errp)
+{
+ BDRVNBDState *s = bs->opaque;
+
+ if (!s->connected) {
+ error_setg(errp, "The connection is not established");
+ return;
+ }
+
+ nbd_client_close(bs);
+ s->connected = false;
+}
+
static BlockDriver bdrv_nbd = {
.format_name = "nbd",
.protocol_name = "nbd",
@@ -527,6 +573,9 @@ static BlockDriver bdrv_nbd_colo = {
.bdrv_detach_aio_context = nbd_detach_aio_context,
.bdrv_attach_aio_context = nbd_attach_aio_context,
.bdrv_refresh_filename = nbd_refresh_filename,
+ .bdrv_start_replication = nbd_start_replication,
+ .bdrv_do_checkpoint = nbd_do_checkpoint,
+ .bdrv_stop_replication = nbd_stop_replication,
.has_variable_length = true,
};
--
2.1.0
- [Qemu-block] [PATCH COLO v3 00/14] Block replication for continuous checkpoints, Wen Congyang, 2015/04/03
- [Qemu-block] [PATCH COLO v3 02/14] quorum: allow ignoring child errors, Wen Congyang, 2015/04/03
- [Qemu-block] [PATCH COLO v3 06/14] NBD client: implement block driver interfaces for block replication,
Wen Congyang <=
- [Qemu-block] [PATCH COLO v3 01/14] docs: block replication's description, Wen Congyang, 2015/04/03
- Re: [Qemu-block] [PATCH COLO v3 01/14] docs: block replication's description, Stefan Hajnoczi, 2015/04/20
- Re: [Qemu-block] [PATCH COLO v3 01/14] docs: block replication's description, Wen Congyang, 2015/04/20
- Re: [Qemu-block] [PATCH COLO v3 01/14] docs: block replication's description, Paolo Bonzini, 2015/04/21
- Re: [Qemu-block] [PATCH COLO v3 01/14] docs: block replication's description, Stefan Hajnoczi, 2015/04/22
- Re: [Qemu-block] [PATCH COLO v3 01/14] docs: block replication's description, Wen Congyang, 2015/04/22
- Re: [Qemu-block] [PATCH COLO v3 01/14] docs: block replication's description, Stefan Hajnoczi, 2015/04/23
- Re: [Qemu-block] [PATCH COLO v3 01/14] docs: block replication's description, Wen Congyang, 2015/04/23
- Re: [Qemu-block] [PATCH COLO v3 01/14] docs: block replication's description, Kevin Wolf, 2015/04/22
- Re: [Qemu-block] [PATCH COLO v3 01/14] docs: block replication's description, Paolo Bonzini, 2015/04/22