1 /*
2 * Replication filter
3 *
4 * Copyright (c) 2016 HUAWEI TECHNOLOGIES CO., LTD.
5 * Copyright (c) 2016 Intel Corporation
6 * Copyright (c) 2016 FUJITSU LIMITED
7 *
8 * Author:
9 * Changlong Xie <xiecl.fnst@cn.fujitsu.com>
10 *
11 * This work is licensed under the terms of the GNU GPL, version 2 or later.
12 * See the COPYING file in the top-level directory.
13 */
14
15 #include "qemu/osdep.h"
16 #include "qapi/error.h"
17 #include "block/replication.h"
18
19 static QLIST_HEAD(, ReplicationState) replication_states;
20
replication_new(void * opaque,ReplicationOps * ops)21 ReplicationState *replication_new(void *opaque, ReplicationOps *ops)
22 {
23 ReplicationState *rs;
24
25 assert(ops != NULL);
26 rs = g_new0(ReplicationState, 1);
27 rs->opaque = opaque;
28 rs->ops = ops;
29 QLIST_INSERT_HEAD(&replication_states, rs, node);
30
31 return rs;
32 }
33
replication_remove(ReplicationState * rs)34 void replication_remove(ReplicationState *rs)
35 {
36 if (rs) {
37 QLIST_REMOVE(rs, node);
38 g_free(rs);
39 }
40 }
41
42 /*
43 * The caller of the function MUST make sure vm stopped
44 */
replication_start_all(ReplicationMode mode,Error ** errp)45 void replication_start_all(ReplicationMode mode, Error **errp)
46 {
47 ReplicationState *rs, *next;
48 Error *local_err = NULL;
49
50 QLIST_FOREACH_SAFE(rs, &replication_states, node, next) {
51 if (rs->ops && rs->ops->start) {
52 rs->ops->start(rs, mode, &local_err);
53 }
54 if (local_err) {
55 error_propagate(errp, local_err);
56 return;
57 }
58 }
59 }
60
replication_do_checkpoint_all(Error ** errp)61 void replication_do_checkpoint_all(Error **errp)
62 {
63 ReplicationState *rs, *next;
64 Error *local_err = NULL;
65
66 QLIST_FOREACH_SAFE(rs, &replication_states, node, next) {
67 if (rs->ops && rs->ops->checkpoint) {
68 rs->ops->checkpoint(rs, &local_err);
69 }
70 if (local_err) {
71 error_propagate(errp, local_err);
72 return;
73 }
74 }
75 }
76
replication_get_error_all(Error ** errp)77 void replication_get_error_all(Error **errp)
78 {
79 ReplicationState *rs, *next;
80 Error *local_err = NULL;
81
82 QLIST_FOREACH_SAFE(rs, &replication_states, node, next) {
83 if (rs->ops && rs->ops->get_error) {
84 rs->ops->get_error(rs, &local_err);
85 }
86 if (local_err) {
87 error_propagate(errp, local_err);
88 return;
89 }
90 }
91 }
92
replication_stop_all(bool failover,Error ** errp)93 void replication_stop_all(bool failover, Error **errp)
94 {
95 ReplicationState *rs, *next;
96 Error *local_err = NULL;
97
98 QLIST_FOREACH_SAFE(rs, &replication_states, node, next) {
99 if (rs->ops && rs->ops->stop) {
100 rs->ops->stop(rs, failover, &local_err);
101 }
102 if (local_err) {
103 error_propagate(errp, local_err);
104 return;
105 }
106 }
107 }
108