12  * See the COPYING file in the top-level directory.
23     ReplicationState *rs;  in replication_new()  local
26     rs = g_new0(ReplicationState, 1);  in replication_new()
27     rs->opaque = opaque;  in replication_new()
28     rs->ops = ops;  in replication_new()
29     QLIST_INSERT_HEAD(&replication_states, rs, node);  in replication_new()
31     return rs;  in replication_new()
34 void replication_remove(ReplicationState *rs)  in replication_remove()  argument
36     if (rs) {  in replication_remove()
37         QLIST_REMOVE(rs, node);  in replication_remove()
38         g_free(rs);  in replication_remove()
47     ReplicationState *rs, *next;  in replication_start_all()  local
50     QLIST_FOREACH_SAFE(rs, &replication_states, node, next) {  in replication_start_all()
51         if (rs->ops && rs->ops->start) {  in replication_start_all()
52             rs->ops->start(rs, mode, &local_err);  in replication_start_all()
63     ReplicationState *rs, *next;  in replication_do_checkpoint_all()  local
66     QLIST_FOREACH_SAFE(rs, &replication_states, node, next) {  in replication_do_checkpoint_all()
67         if (rs->ops && rs->ops->checkpoint) {  in replication_do_checkpoint_all()
68             rs->ops->checkpoint(rs, &local_err);  in replication_do_checkpoint_all()
79     ReplicationState *rs, *next;  in replication_get_error_all()  local
82     QLIST_FOREACH_SAFE(rs, &replication_states, node, next) {  in replication_get_error_all()
83         if (rs->ops && rs->ops->get_error) {  in replication_get_error_all()
84             rs->ops->get_error(rs, &local_err);  in replication_get_error_all()
95     ReplicationState *rs, *next;  in replication_stop_all()  local
98     QLIST_FOREACH_SAFE(rs, &replication_states, node, next) {  in replication_stop_all()
99         if (rs->ops && rs->ops->stop) {  in replication_stop_all()
100             rs->ops->stop(rs, failover, &local_err);  in replication_stop_all()