replication.c

   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
  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
  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  */
  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
  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
  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
  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 }