From mboxrd@z Thu Jan  1 00:00:00 1970
Received: from eggs.gnu.org ([140.186.70.92]:60156)
	by lists.gnu.org with esmtp (Exim 4.71)
	(envelope-from <omamluk@zerto.com>) id 1RuiIn-0006W2-1s
	for qemu-devel@nongnu.org; Tue, 07 Feb 2012 05:29:44 -0500
Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71)
	(envelope-from <omamluk@zerto.com>) id 1RuiIa-00039J-R3
	for qemu-devel@nongnu.org; Tue, 07 Feb 2012 05:29:33 -0500
Received: from mail-pw0-f45.google.com ([209.85.160.45]:50012)
	by eggs.gnu.org with esmtp (Exim 4.71)
	(envelope-from <omamluk@zerto.com>) id 1RuiIZ-00038Y-V1
	for qemu-devel@nongnu.org; Tue, 07 Feb 2012 05:29:20 -0500
Received: by pbaa11 with SMTP id a11so7751087pba.4
	for <qemu-devel@nongnu.org>; Tue, 07 Feb 2012 02:29:18 -0800 (PST)
From: Ori Mamluk <omamluk@zerto.com>
MIME-Version: 1.0
Date: Tue, 7 Feb 2012 12:29:14 +0200
Message-ID: <73865e0ce364c40e0eb65ec6b22b819d@mail.gmail.com>
Content-Type: multipart/alternative; boundary=047d7b3396015fba3f04b85d40a9
Subject: [Qemu-devel]  [RFC PATCH] replication agent module
List-Id: <qemu-devel.nongnu.org>
List-Unsubscribe: <https://lists.nongnu.org/mailman/options/qemu-devel>,
	<mailto:qemu-devel-request@nongnu.org?subject=unsubscribe>
List-Archive: <http://lists.nongnu.org/archive/html/qemu-devel>
List-Post: <mailto:qemu-devel@nongnu.org>
List-Help: <mailto:qemu-devel-request@nongnu.org?subject=help>
List-Subscribe: <https://lists.nongnu.org/mailman/listinfo/qemu-devel>,
	<mailto:qemu-devel-request@nongnu.org?subject=subscribe>
To: qemu-devel@nongnu.org
Cc: Kevin Wolf <kwolf@redhat.com>, dlaor@redhat.com

--047d7b3396015fba3f04b85d40a9
Content-Type: text/plain; charset=windows-1252
Content-Transfer-Encoding: quoted-printable

Repagent is a new module that allows an external replication system to
replicate a volume of a Qemu VM.

This RFC patch adds the repagent client module to Qemu.



Documentation of the module role and API is in the patch at
replication/qemu-repagent.txt



The main motivation behind the module is to allow replication of VMs in a
virtualization environment like RhevM.

To achieve this we need basic replication support in Qemu.



This is the first submission of this module, which was written as a Proof
Of Concept, and used successfully for replicating and recovering a Qemu VM.

Points and open issues:

*             The module interfaces the Qemu storage stack at block.c
generic layer. Is this the right place to intercept/inject IOs?

*             The patch contains performing IO reads invoked by a new
thread (a TCP listener thread). See repaget_read_vol in repagent.c. It is
not protected by any lock =96 is this OK?

*             VM ID =96 the replication system implies an environment with
several VMs connected to a central replication system (Rephub).

                This requires some sort of identification for a VM. The
current patch does not include a VM ID =96 I did not find any adequate ID t=
o
use.

                Any suggestions?



Appreciate any feedback or suggestions.  Thanks,

Ori.





>>From 5a0d88689ddcf325f25fdfca2a2012f1bbf141b9 Mon Sep 17 00:00:00 2001

From: Ori Mamluk <orim@orim-fedora.(none)>

Date: Tue, 7 Feb 2012 11:12:12 +0200

Subject: [PATCH] Added replication agent module (repagent) to Qemu under

replication directory, added repagent configure and run

options, and the repagent API usage in bloc



Added build options to ./configure:  --enable-replication --disable-replica=
t

Added a commandline option to enable: -repagent <rep hub IP>

Added the module files under replication.



Signed-off-by: Ori Mamluk <orim@zerto.com>

---

Makefile                      |    9 +-

Makefile.objs                 |    6 +

block.c                       |   20 +++-

configure                     |   11 ++

qemu-options.hx               |    6 +

replication/qemu-repagent.txt |  104 +++++++++++++

replication/repagent.c        |  322
+++++++++++++++++++++++++++++++++++++++++

replication/repagent.h        |   46 ++++++

replication/repagent_client.c |  138 ++++++++++++++++++

replication/repagent_client.h |   36 +++++

replication/repcmd.h          |   59 ++++++++

replication/repcmd_listener.c |  137 +++++++++++++++++

replication/repcmd_listener.h |   32 ++++

replication/rephub_cmds.h     |  150 +++++++++++++++++++

replication/rephub_defs.h     |   40 +++++

vl.c                          |   10 ++

16 files changed, 1121 insertions(+), 5 deletions(-)

mode change 100644 =3D> 100755 Makefile.objs

mode change 100644 =3D> 100755 qemu-options.hx

create mode 100755 replication/qemu-repagent.txt

create mode 100644 replication/repagent.c

create mode 100644 replication/repagent.h

create mode 100644 replication/repagent_client.c

create mode 100644 replication/repagent_client.h

create mode 100644 replication/repcmd.h

create mode 100644 replication/repcmd_listener.c

create mode 100644 replication/repcmd_listener.h

create mode 100644 replication/rephub_cmds.h

create mode 100644 replication/rephub_defs.h



diff --git a/Makefile b/Makefile

index 4f6eaa4..a1b3701 100644

--- a/Makefile

+++ b/Makefile

@@ -149,9 +149,9 @@ qemu-img.o qemu-tool.o qemu-nbd.o qemu-io.o cmd.o
qemu-ga.o: $(GENERATED_HEADERS

tools-obj-y =3D qemu-tool.o $(oslib-obj-y) $(trace-obj-y) \

               qemu-timer-common.o cutils.o

-qemu-img$(EXESUF): qemu-img.o $(tools-obj-y) $(block-obj-y)

-qemu-nbd$(EXESUF): qemu-nbd.o $(tools-obj-y) $(block-obj-y)

-qemu-io$(EXESUF): qemu-io.o cmd.o $(tools-obj-y) $(block-obj-y)

+qemu-img$(EXESUF): qemu-img.o $(tools-obj-y) $(block-obj-y)
$(replication-obj-y)

+qemu-nbd$(EXESUF): qemu-nbd.o $(tools-obj-y) $(block-obj-y)
$(replication-obj-y)

+qemu-io$(EXESUF): qemu-io.o cmd.o $(tools-obj-y) $(block-obj-y)
$(replication-obj-y)

 qemu-img-cmds.h: $(SRC_PATH)/qemu-img-cmds.hx

               $(call quiet-command,sh $(SRC_PATH)/scripts/hxtool -h < $< >
$@,"  GEN   $@")

@@ -228,6 +228,7 @@ clean:

               rm -f trace-dtrace.dtrace trace-dtrace.dtrace-timestamp

               rm -f trace-dtrace.h trace-dtrace.h-timestamp

               rm -rf $(qapi-dir)

+             rm -f replication/*.{o,d}

               $(MAKE) -C tests clean

               for d in $(ALL_SUBDIRS) $(QEMULIBS) libcacard; do \

               if test -d $$d; then $(MAKE) -C $$d $@ || exit 1; fi; \

@@ -387,4 +388,4 @@ tar:

               rm -rf /tmp/$(FILE)

 # Include automatically generated dependency files

--include $(wildcard *.d audio/*.d slirp/*.d block/*.d net/*.d ui/*.d
qapi/*.d qga/*.d)

+-include $(wildcard *.d audio/*.d slirp/*.d block/*.d net/*.d ui/*.d
qapi/*.d qga/*.d replication/*.d)

diff --git a/Makefile.objs b/Makefile.objs

old mode 100644

new mode 100755

index d7a6539..dbd6f15

--- a/Makefile.objs

+++ b/Makefile.objs

@@ -74,6 +74,7 @@ fsdev-obj-$(CONFIG_VIRTFS) +=3D $(addprefix fsdev/,
$(fsdev-nested-y))

# CPUs and machines.

 common-obj-y =3D $(block-obj-y) blockdev.o

+common-obj-y +=3D $(replication-obj-$(CONFIG_REPLICATION))

common-obj-y +=3D $(net-obj-y)

common-obj-y +=3D $(qobject-obj-y)

common-obj-$(CONFIG_LINUX) +=3D $(fsdev-obj-$(CONFIG_LINUX))

@@ -413,6 +414,11 @@ common-obj-y +=3D qmp-marshal.o qapi-visit.o
qapi-types.o $(qapi-obj-y)

common-obj-y +=3D qmp.o hmp.o

 ######################################################################

+# replication

+replication-nested-y =3D repagent_client.o  repagent.o  repcmd_listener.o

+replication-obj-y =3D $(addprefix replication/, $(replication-nested-y))

+

+######################################################################

# guest agent

 qga-nested-y =3D guest-agent-commands.o guest-agent-command-state.o

diff --git a/block.c b/block.c

index 9bb236c..f3b8387 100644

--- a/block.c

+++ b/block.c

@@ -31,6 +31,10 @@

#include "qemu-coroutine.h"

#include "qmp-commands.h"

+#ifdef CONFIG_REPLICATION

+#include "replication/repagent.h"

+#endif

+

#ifdef CONFIG_BSD

#include <sys/types.h>

#include <sys/stat.h>

@@ -640,6 +644,9 @@ int bdrv_open(BlockDriverState *bs, const char
*filename, int flags,

         goto unlink_and_fail;

     }

+#ifdef CONFIG_REPLICATION

+    repagent_register_drive(filename,  bs);

+#endif

     /* Open the image */

     ret =3D bdrv_open_common(bs, filename, flags, drv);

     if (ret < 0) {

@@ -1292,6 +1299,17 @@ static int coroutine_fn
bdrv_co_do_writev(BlockDriverState *bs,

     ret =3D drv->bdrv_co_writev(bs, sector_num, nb_sectors, qiov);

+

+#ifdef CONFIG_REPLICATION

+    if (bs->device_name[0] !=3D '\0') {

+        /* We split the IO only at the highest stack driver layer.

+           Currently we know that by checking device_name - only

+           highest level (closest to the guest) has that name.

+           */

+           repagent_handle_protected_write(bs, sector_num,

+                nb_sectors, qiov, ret);

+    }

+#endif

     if (bs->dirty_bitmap) {

         set_dirty_bitmap(bs, sector_num, nb_sectors, 1);

     }

@@ -1783,7 +1801,7 @@ int bdrv_has_zero_init(BlockDriverState *bs)

  * 'nb_sectors' is the max value 'pnum' should be set to.

  */

int bdrv_is_allocated(BlockDriverState *bs, int64_t sector_num, int
nb_sectors,

-              int *pnum)

+    int *pnum)

{

     int64_t n;

     if (!bs->drv->bdrv_is_allocated) {

diff --git a/configure b/configure

index 9e5da44..93d600e 100755

--- a/configure

+++ b/configure

@@ -179,6 +179,7 @@ spice=3D""

rbd=3D""

smartcard=3D""

smartcard_nss=3D""

+replication=3D""

usb_redir=3D""

opengl=3D""

zlib=3D"yes"

@@ -772,6 +773,10 @@ for opt do

   ;;

   --enable-smartcard-nss) smartcard_nss=3D"yes"

   ;;

+  --disable-replication) replication=3D"no"

+  ;;

+  --enable-replication) replication=3D"yes"

+  ;;

   --disable-usb-redir) usb_redir=3D"no"

   ;;

   --enable-usb-redir) usb_redir=3D"yes"

@@ -1067,6 +1072,7 @@ echo "  --disable-usb-redir      disable usb network
redirection support"

echo "  --enable-usb-redir       enable usb network redirection support"

echo "  --disable-guest-agent    disable building of the QEMU Guest Agent"

echo "  --enable-guest-agent     enable building of the QEMU Guest Agent"

+echo "  --enable-replication     enable replication support"

echo ""

echo "NOTE: The object files are built at the place where configure is
launched"

exit 1

@@ -2733,6 +2739,7 @@ echo "curl support      $curl"

echo "check support     $check_utests"

echo "mingw32 support   $mingw32"

echo "Audio drivers     $audio_drv_list"

+echo "Replication          $replication"

echo "Extra audio cards $audio_card_list"

echo "Block whitelist   $block_drv_whitelist"

echo "Mixer emulation   $mixemu"

@@ -3080,6 +3087,10 @@ if test "$smartcard_nss" =3D "yes" ; then

   echo "CONFIG_SMARTCARD_NSS=3Dy" >> $config_host_mak

fi

+if test "$replication" =3D "yes" ; then

+  echo "CONFIG_REPLICATION=3Dy" >> $config_host_mak

+fi

+

if test "$usb_redir" =3D "yes" ; then

   echo "CONFIG_USB_REDIR=3Dy" >> $config_host_mak

fi

diff --git a/qemu-options.hx b/qemu-options.hx

old mode 100644

new mode 100755

index 681eaf1..c97e4f8

--- a/qemu-options.hx

+++ b/qemu-options.hx

@@ -2602,3 +2602,9 @@ HXCOMM This is the last statement. Insert new options
before this line!

STEXI

@end table

ETEXI

+

+DEF("repagent", HAS_ARG, QEMU_OPTION_repagent,

+    "-repagent [hub IP/name]\n"

+    "                Enable replication support for disks\n"

+    "                hub is the ip or name of the machine running the
replication hub.\n",

+    QEMU_ARCH_ALL)

diff --git a/replication/qemu-repagent.txt b/replication/qemu-repagent.txt

new file mode 100755

index 0000000..e3b0c1e

--- /dev/null

+++ b/replication/qemu-repagent.txt

@@ -0,0 +1,104 @@

+             repagent - replication agent - a Qemu module for enabling
continuous async replication of VM volumes

+

+Introduction

+             This document describes a feature in Qemu - a replication
agent (AKA Repagent).

+             The Repagent is a new module that exposes an API to an
external replication system (AKA Rephub).

+             This API allows a Rephub to communicate with a Qemu VM and
continuously replicate its volumes.

+             The imlementation of a Rephub is outside of the scope of this
document. There may be several various Rephub

+             implenetations using the same repagent in Qemu.

+

+Main feature of Repagent

+             Repagent does the following:

+             * Report volumes - report a list of all volumes in a VM to
the Rephub.

+             * Report writes to a volume - send all writes made to a
protected volume to the Rephub.

+                             The reporting of an IO is asyncronuous - i.e.
the IO is not delayed by the Repagent to get any acknowledgement from the
Rephub.

+                             It is only copied to the Rephub.

+             * Read a protected volume - allows the Rephub to read a
protected volume, to enable the protected hub to syncronize the content of
a protected volume.

+

+Description of the Repagent module

+

+Build and run options

+             New configure option: --enable-replication

+             New command line option:

+             -repagent [hub IP/name]

+
Enable replication support for disks

+
hub is the ip or name of the machine running the replication hub.

+

+Module APIs

+             The Repagent module interfaces two main components:

+             1. The Rephub - An external API based on socket messages

+             2. The generic block layer- block.c

+

+             Rephub message API

+                             The external replication API is a message
based API.

+                             We won't go into the structure of the
messages here - just the sematics.

+

+                             Messages list

+                                             (The updated list and
comments are in Rephub_cmds.h)

+

+                                             Messages from the Repagent to
the Rephub:

+                                             * Protected write

+                                                             The Repagent
sends each write to a protected volume to the hub with the IO status.

+                                                             In case the
status is bad the write content is not sent

+                                             * Report VM volumes

+                                                             The agent
reports all the volumes of the VM to the hub.

+                                             * Read Volume Response

+                                                             A response to
a Read Volume Request

+                                                             Sends the
data read from a protected volume to the hub

+                                             * Agent shutdown

+                                                             Notifies the
hub that the agent is about to shutdown.

+                                                             This allows a
graceful shutdown. Any disconnection of an agent without

+                                                             sending this
command will result in a full sync of the VM volumes.

+

+                                             Messages from the Rephub to
the Repagent:

+                                             * Start protect

+                                                             The hub
instructs the agent to start protecting a volume. When a volume is protecte=
d

+                                                             all its
writes are sent to to the hub.

+                                                             With this
command the hub also assigns a volume ID to the given volume name.

+                                             * Read volume request

+                                                             The hub
issues a read IO to a protected volume.

+                                                             This command
is used during sync - when the hub needs to read unsyncronized

+                                                             sections of a
protected volume.

+                                                             This command
is a request, the read data is returned by the read volume response message
(see above).

+             block.c API

+                             The API to the generic block storage layer
contains 3 functionalities:

+                             1. Handle writes to protected volumes

+                                             In bdrv_co_do_writev, each
write is reported to the Repagent module.

+                             2. Handle each new volume that registers

+                                             In bdrv_open - each new
bottom-level block driver that registers is reported.

+                             2. Read from a volume

+                                             Repagent calls bdrv_aio_readv
to handle read requests coming from the hub.

+

+

+General description of a Rephub  - a replication system the repagent
connects to

+             This section describes in high level a sample Rephub - a
replication system that uses the repagent API

+             to replicate disks.

+             It describes a simple Rephub that comntinuously maintains a
mirror of the volumes of a VM.

+

+             Say we have a VM we want to protect - call it PVM, say it has
2 volumes - V1, V2.

+             Our Rephub is called SingleRephub - a Rephub protecting a
single VM.

+

+             Preparations

+             1. The user chooses a host to rub SingleRephub - a different
host than PVM, call it Host2

+             2. The user creates two volumes on Host2 - same sizes of V1
and V2, call them V1R (V1 recovery) and V2R.

+             3. The user runs SingleRephub process on Host2, and gives V1R
and V2R as command line arguments.

+                             From now on SingleRephub waits for the
protected VM repagent to connect.

+             4. The user runs the protected VM PVM - and uses the switch
-repagent <Host2 IP>.

+

+             Runtime

+             1. The repagent module connects to SingleRephub on startup.

+             2. repagent reports V1 and V2 to SingleRephub.

+             3. SingleRephub starts to perform an initial synchronization
of the protected volumes-

+                             it reads each protected volume (V1 and V2) -
using read volume requests - and copies the data into the

+                             recovery volume V1R and V2R.

+             4. SingleRephub enters 'protection' mode - each write to the
protected volume is sent by the repagent to the Rephub,

+                             and the Rephub performs the write on the
matching recovery volume.

+

+             * Note that during stage 3 writes to the protected volumes
are not ignored - they're kept in a bitmap,

+                             and will be read again when stage 3 ends, in
an interative convergin process.

+

+             This flow continuously maintains an updated recovery volume.

+             If the protected system is damaged, the user can create a new
VM on Host2 with the replicated volumes attached to it.

+             The new VM is a replica of the protected system.

+

+

diff --git a/replication/repagent.c b/replication/repagent.c

new file mode 100644

index 0000000..c66eae7

--- /dev/null

+++ b/replication/repagent.c

@@ -0,0 +1,322 @@

+#include <string.h>

+#include <stdlib.h>

+#include <stdio.h>

+#include <pthread.h>

+#include <stdint.h>

+

+#include "block.h"

+#include "rephub_defs.h"

+#include "block_int.h"

+#include "repagent_client.h"

+#include "repagent.h"

+#include "rephub_cmds.h"

+

+#define ZERO_MEM_OBJ(pObj) memset(pObj, 0, sizeof(*pObj))

+#define REPAGENT_MAX_NUM_VOLUMES (64)

+#define REPAGENT_VOLUME_ID_NONE (0)

+

+typedef struct RepagentVolume {

+    uint64_t vol_id;

+    const char *vol_path;

+    BlockDriverState *driver_ptr;

+} RepagentVolume;

+

+struct RepAgentState {

+    int is_init;

+    int num_volumes;

+    RepagentVolume * volumes[REPAGENT_MAX_NUM_VOLUMES];

+};

+

+typedef struct RepagentReadVolIo {

+    QEMUIOVector qiov;

+    RepCmdReadVolReq rep_cmd;

+    uint8_t *buf;

+    struct timeval start_time;

+} RepagentReadVolIo;

+

+static int repagent_get_volume_by_name(const char *name);

+static void repagent_report_volumes_to_hub(void);

+static void repagent_vol_read_done(void *opaque, int ret);

+static struct timeval tsub(struct timeval t1, struct timeval t2);

+

+RepAgentState g_rep_agent =3D { 0 };

+

+void repagent_init(const char *hubname, int port)

+{

+    /* It is the responsibility of the thread to free this struct */

+    rephub_params *pParams =3D (rephub_params
*)g_malloc(sizeof(rephub_params));

+    if (hubname =3D=3D NULL) {

+        hubname =3D "127.0.0.1";

+    }

+    if (port =3D=3D 0) {

+        port =3D 9010;

+    }

+

+    printf("repagent_init %s\n", hubname);

+

+    pParams->port =3D port;

+    pParams->name =3D g_strdup(hubname);

+

+    pthread_t thread_id =3D 0;

+

+    /* Create the repagent client listener thread */

+    pthread_create(&thread_id, 0, repagent_listen, (void *) pParams);

+    pthread_detach(thread_id);

+}

+

+void repagent_register_drive(const char *drive_path,

+        BlockDriverState *driver_ptr)

+{

+    int i;

+    for (i =3D 0; i < g_rep_agent.num_volumes ; i++) {

+        RepagentVolume *vol =3D g_rep_agent.volumes[i];

+        if (vol !=3D NULL) {

+            assert(

+                    strcmp(drive_path, vol->vol_path) !=3D 0

+                    && driver_ptr !=3D vol->driver_ptr);

+        }

+    }

+

+    assert(g_rep_agent.num_volumes < REPAGENT_MAX_NUM_VOLUMES);

+

+    printf("zerto repagent: Registering drive. Num drives %d, path %s\n",

+            g_rep_agent.num_volumes, drive_path);

+    g_rep_agent.volumes[i] =3D

+            (RepagentVolume *)g_malloc(sizeof(RepagentVolume));

+    g_rep_agent.volumes[i]->driver_ptr =3D driver_ptr;

+    /* orim todo strcpy? */

+    g_rep_agent.volumes[i]->vol_path =3D drive_path;

+

+    /* Orim todo thread-safety? */

+    g_rep_agent.num_volumes++;

+

+    repagent_report_volumes_to_hub();

+}

+

+/* orim todo destruction? */

+

+static RepagentVolume *repagent_get_protected_volume_by_driver(

+        BlockDriverState *bs)

+{

+    /* orim todo optimize search */

+    int i =3D 0;

+    for (i =3D 0; i < g_rep_agent.num_volumes ; i++) {

+        RepagentVolume *p_vol =3D g_rep_agent.volumes[i];

+        if (p_vol !=3D NULL && p_vol->driver_ptr =3D=3D (void *) bs) {

+            return p_vol;

+        }

+    }

+    return NULL;

+}

+

+void repagent_handle_protected_write(BlockDriverState *bs, int64_t
sector_num,

+        int nb_sectors, QEMUIOVector *qiov, int ret_status)

+{

+    printf("zerto Protected write offset %lld, size %d, IO return status
%d",

+            (long long int) sector_num, nb_sectors, ret_status);

+    if (bs->filename !=3D NULL) {

+        printf(", filename %s", bs->filename);

+    }

+

+    printf("\n");

+

+    RepagentVolume *p_vol =3D repagent_get_protected_volume_by_driver(bs);

+    if (p_vol =3D=3D NULL || p_vol->vol_id =3D=3D REPAGENT_VOLUME_ID_NONE)=
 {

+        /* Unprotected */

+        printf("Got a write to an unprotected volume.\n");

+        return;

+    }

+

+    /* Report IO to rephub */

+

+    int data_size =3D qiov->size;

+    if (ret_status < 0) {

+        /* On failed ios we don't send the data to the hub */

+        data_size =3D 0;

+    }

+    uint8_t *pdata =3D NULL;

+    RepCmdProtectedWrite *p_cmd =3D (RepCmdProtectedWrite *) repcmd_new(

+            REPHUB_CMD_PROTECTED_WRITE, data_size, (uint8_t **) &pdata);

+

+    if (ret_status >=3D 0) {

+        qemu_iovec_to_buffer(qiov, pdata);

+    }

+

+    p_cmd->volume_id =3D p_vol->vol_id;

+    p_cmd->offset_sectors =3D sector_num;

+    p_cmd->size_sectors =3D nb_sectors;

+    p_cmd->ret_status =3D ret_status;

+

+    if (repagent_client_send((RepCmd *) p_cmd) !=3D 0) {

+        printf("Error sending command\n");

+    }

+}

+

+static void repagent_report_volumes_to_hub(void)

+{

+    /* Report IO to rephub */

+    int i;

+    RepCmdDataReportVmVolumes *p_cmd_data =3D NULL;

+    RepCmdReportVmVolumes *p_cmd =3D (RepCmdReportVmVolumes *) repcmd_new(

+            REPHUB_CMD_REPORT_VM_VOLUMES,

+            g_rep_agent.num_volumes * sizeof(RepVmVolumeInfo),

+            (uint8_t **) &p_cmd_data);

+    p_cmd->num_volumes =3D g_rep_agent.num_volumes;

+    printf("reporting %u volumes\n", g_rep_agent.num_volumes);

+    for (i =3D 0; i < g_rep_agent.num_volumes ; i++) {

+        assert(g_rep_agent.volumes[i] !=3D NULL);

+        printf("reporting volume %s size %u\n",

+                g_rep_agent.volumes[i]->vol_path,

+                (uint32_t) sizeof(p_cmd_data->volumes[i].name));

+        strncpy((char *) p_cmd_data->volumes[i].name,

+                g_rep_agent.volumes[i]->vol_path,

+                sizeof(p_cmd_data->volumes[i].name));

+        p_cmd_data->volumes[i].volume_id =3D g_rep_agent.volumes[i]->vol_i=
d;

+    }

+    if (repagent_client_send((RepCmd *) p_cmd) !=3D 0) {

+        printf("Error sending command\n");

+    }

+}

+

+int repaget_start_protect(RepCmdStartProtect *pcmd,

+        RepCmdDataStartProtect *pcmd_data)

+{

+    printf("Start protect vol %s, ID %llu\n", pcmd_data->volume_name,

+            (unsigned long long) pcmd->volume_id);

+    int vol_index =3D repagent_get_volume_by_name(pcmd_data->volume_name);

+    if (vol_index < 0) {

+        printf("The volume doesn't exist\n");

+        return TRUE;

+    }

+    /* orim todo protect */

+    g_rep_agent.volumes[vol_index]->vol_id =3D pcmd->volume_id;

+

+    return TRUE;

+}

+

+static int repagent_get_volume_by_name(const char *name)

+{

+    int i =3D 0;

+    for (i =3D 0; i < g_rep_agent.num_volumes ; i++) {

+        if (g_rep_agent.volumes[i] !=3D NULL

+                && strcmp(name, g_rep_agent.volumes[i]->vol_path) =3D=3D 0=
) {

+            return i;

+        }

+    }

+    return -1;

+}

+

+static int repagent_get_volume_by_id(uint64_t vol_id)

+{

+    int i =3D 0;

+    for (i =3D 0; i < g_rep_agent.num_volumes ; i++) {

+        if (g_rep_agent.volumes[i] !=3D NULL

+                && g_rep_agent.volumes[i]->vol_id =3D=3D vol_id) {

+            return i;

+        }

+    }

+    return -1;

+}

+

+int repaget_read_vol(RepCmdReadVolReq *pcmd, uint8_t *pdata)

+{

+    int index =3D repagent_get_volume_by_id(pcmd->volume_id);

+    int size_bytes =3D pcmd->size_sectors * 512;

+    if (index < 0) {

+        printf("Vol read - Could not find vol id %llu\n",

+                (unsigned long long int) pcmd->volume_id);

+        RepCmdReadVolRes *p_res_cmd =3D (RepCmdReadVolRes *) repcmd_new(

+                REPHUB_CMD_READ_VOL_RES, 0, NULL);

+        p_res_cmd->req_id =3D pcmd->req_id;

+        p_res_cmd->volume_id =3D pcmd->volume_id;

+        p_res_cmd->is_status_success =3D FALSE;

+        repagent_client_send((RepCmd *) p_res_cmd);

+        return TRUE;

+    }

+

+    printf("Vol read - driver %p, volId %llu, offset %llu, size %u\n",

+            g_rep_agent.volumes[index]->driver_ptr,

+            (unsigned long long int) pcmd->volume_id,

+            (unsigned long long int) pcmd->offset_sectors,
pcmd->size_sectors);

+

+    {

+        RepagentReadVolIo *read_xact =3D calloc(1,
sizeof(RepagentReadVolIo));

+

+/*        BlockDriverAIOCB *acb; */

+

+        ZERO_MEM_OBJ(read_xact);

+

+        qemu_iovec_init(&read_xact->qiov, 1);

+

+        /*read_xact->buf =3D

+        qemu_blockalign(g_rep_agent.volumes[index]->driver_ptr,
size_bytes); */

+        read_xact->buf =3D (uint8_t *) g_malloc(size_bytes);

+        read_xact->rep_cmd =3D *pcmd;

+        qemu_iovec_add(&read_xact->qiov, read_xact->buf, size_bytes);

+

+        gettimeofday(&read_xact->start_time, NULL);

+        /* orim TODO - use the returned acb to cancel the request on
shutdown */

+        /*acb =3D */bdrv_aio_readv(g_rep_agent.volumes[index]->driver_ptr,

+                read_xact->rep_cmd.offset_sectors, &read_xact->qiov,

+                read_xact->rep_cmd.size_sectors, repagent_vol_read_done,

+                read_xact);

+    }

+

+    return TRUE;

+}

+

+static void repagent_vol_read_done(void *opaque, int ret)

+{

+    struct timeval t2;

+    RepagentReadVolIo *read_xact =3D (RepagentReadVolIo *) opaque;

+    uint8_t *pdata =3D NULL;

+    RepCmdReadVolRes *pcmd =3D (RepCmdReadVolRes *) repcmd_new(

+            REPHUB_CMD_READ_VOL_RES, read_xact->rep_cmd.size_sectors * 512=
,

+            &pdata);

+    pcmd->req_id =3D read_xact->rep_cmd.req_id;

+    pcmd->volume_id =3D read_xact->rep_cmd.volume_id;

+    pcmd->is_status_success =3D FALSE;

+

+    printf("Protected vol read - volId %llu, offset %llu, size %u\n",

+            (unsigned long long int) read_xact->rep_cmd.volume_id,

+            (unsigned long long int) read_xact->rep_cmd.offset_sectors,

+            read_xact->rep_cmd.size_sectors);

+    gettimeofday(&t2, NULL);

+

+    if (ret >=3D 0) {

+        /* Read response - send the data to the hub */

+        t2 =3D tsub(t2, read_xact->start_time);

+        printf("Read prot vol done. Took %u seconds, %u us.",

+                (uint32_t) t2.tv_sec, (uint32_t) t2.tv_usec);

+

+        pcmd->is_status_success =3D TRUE;

+        /* orim todo optimize - don't copy, use the qiov buffer */

+        qemu_iovec_to_buffer(&read_xact->qiov, pdata);

+    } else {

+        printf("readv failed: %s\n", strerror(-ret));

+    }

+

+    repagent_client_send((RepCmd *) pcmd);

+

+    /*qemu_vfree(read_xact->buf); */

+    g_free(read_xact->buf);

+

+    g_free(read_xact);

+}

+

+static struct timeval tsub(struct timeval t1, struct timeval t2)

+{

+    t1.tv_usec -=3D t2.tv_usec;

+    if (t1.tv_usec < 0) {

+        t1.tv_usec +=3D 1000000;

+        t1.tv_sec--;

+    }

+    t1.tv_sec -=3D t2.tv_sec;

+    return t1;

+}

+

+void repagent_client_connected(void)

+{

+    /* orim todo thread protection */

+    repagent_report_volumes_to_hub();

+}

diff --git a/replication/repagent.h b/replication/repagent.h

new file mode 100644

index 0000000..98ccbf2

--- /dev/null

+++ b/replication/repagent.h

@@ -0,0 +1,46 @@

+/*

+ * QEMU System Emulator

+ *

+ * Copyright (c) 2003-2008 Fabrice Bellard

+ *

+ * Permission is hereby granted, free of charge, to any person obtaining a
copy

+ * of this software and associated documentation files (the "Software"),
to deal

+ * in the Software without restriction, including without limitation the
rights

+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or
sell

+ * copies of the Software, and to permit persons to whom the Software is

+ * furnished to do so, subject to the following conditions:

+ *

+ * The above copyright notice and this permission notice shall be included
in

+ * all copies or substantial portions of the Software.

+ *

+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
OR

+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY=
,

+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL

+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR
OTHER

+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM,

+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN

+ * THE SOFTWARE.

+ */

+#ifndef REPAGENT_H

+#define REPAGENT_H

+#include <stdint.h>

+

+#include "qemu-common.h"

+

+typedef struct RepAgentState RepAgentState;

+typedef struct RepCmdStartProtect RepCmdStartProtect;

+typedef struct RepCmdDataStartProtect RepCmdDataStartProtect;

+struct RepCmdReadVolReq;

+

+void repagent_init(const char *hubname, int port);

+void repagent_handle_protected_write(BlockDriverState *bs,

+        int64_t sector_num, int nb_sectors, QEMUIOVector *qiov, int
ret_status);

+void repagent_register_drive(const char *drive_path,

+        BlockDriverState *driver_ptr);

+int repaget_start_protect(RepCmdStartProtect *pcmd,

+        RepCmdDataStartProtect *pcmd_data);

+int repaget_read_vol(struct RepCmdReadVolReq *pcmd, uint8_t *pdata);

+void repagent_client_connected(void);

+

+

+#endif /* REPAGENT_H */

diff --git a/replication/repagent_client.c b/replication/repagent_client.c

new file mode 100644

index 0000000..4dd9ea4

--- /dev/null

+++ b/replication/repagent_client.c

@@ -0,0 +1,138 @@

+#include "repcmd.h"

+#include "rephub_cmds.h"

+#include "repcmd_listener.h"

+#include "repagent_client.h"

+#include "repagent.h"

+

+#include <string.h>

+#include <stdlib.h>

+#include <errno.h>

+#include <stdio.h>

+#include <resolv.h>

+#include <sys/socket.h>

+#include <arpa/inet.h>

+#include <netinet/in.h>

+#include <unistd.h>

+

+#define ZERO_MEM_OBJ(pObj) memset(pObj, 0, sizeof(*pObj))

+

+static void repagent_process_cmd(RepCmd *pCmd, uint8_t *pData, void
*clientPtr);

+

+typedef struct repagent_client_state {

+    int is_connected;

+    int is_terminate_receive;

+    int hsock;

+} repagent_client_state;

+

+static repagent_client_state g_client_state =3D { 0 };

+

+void *repagent_listen(void *pParam)

+{

+    rephub_params *pServerParams =3D (rephub_params *) pParam;

+    int host_port =3D pServerParams->port;

+    const char *host_name =3D pServerParams->name;

+

+    printf("Creating repagent listener thread...\n");

+    g_free(pServerParams);

+

+    struct sockaddr_in my_addr;

+

+    int err;

+    int retries =3D 0;

+

+    g_client_state.hsock =3D socket(AF_INET, SOCK_STREAM, 0);

+    if (g_client_state.hsock =3D=3D -1) {

+        printf("Error initializing socket %d\n", errno);

+        return (void *) -1;

+    }

+

+    int param =3D 1;

+

+    if ((setsockopt(g_client_state.hsock, SOL_SOCKET, SO_REUSEADDR,

+            (char *) &param, sizeof(int)) =3D=3D -1)

+            || (setsockopt(g_client_state.hsock, SOL_SOCKET, SO_KEEPALIVE,

+                    (char *) &param, sizeof(int)) =3D=3D -1)) {

+        printf("Error setting options %d\n", errno);

+        return (void *) -1;

+    }

+

+    my_addr.sin_family =3D AF_INET;

+    my_addr.sin_port =3D htons(host_port);

+    memset(&(my_addr.sin_zero), 0, 8);

+

+    my_addr.sin_addr.s_addr =3D inet_addr(host_name);

+

+    /* Reconnect loop */

+    while (!g_client_state.is_terminate_receive) {

+

+        if (connect(g_client_state.hsock, (struct sockaddr *) &my_addr,

+                sizeof(my_addr)) =3D=3D -1) {

+            err =3D errno;

+            if (err !=3D EINPROGRESS) {

+                retries++;

+                fprintf(

+                        stderr,

+                        "Error connecting socket %d. Host %s, port %u.
Retry count %d\n",

+                        errno, host_name, host_port, retries);

+                usleep(5 * 1000 * 1000);

+                continue;

+            }

+        }

+        retries =3D 0;

+

+        g_client_state.is_connected =3D 1;

+

+        repagent_client_connected();

+        repcmd_listener(g_client_state.hsock, repagent_process_cmd, NULL);

+        close(g_client_state.hsock);

+

+        g_client_state.is_connected =3D 0;

+    }

+    return 0;

+}

+

+void repagent_process_cmd(RepCmd *pcmd, uint8_t *pdata, void *clientPtr)

+{

+    int is_free_data =3D 1;

+    printf("Repagent got cmd %d\n", pcmd->hdr.cmdid);

+    switch (pcmd->hdr.cmdid) {

+    case REPHUB_CMD_START_PROTECT: {

+        is_free_data =3D repaget_start_protect((RepCmdStartProtect *) pcmd=
,

+                (RepCmdDataStartProtect *) pdata);

+    }

+        break;

+    case REPHUB_CMD_READ_VOL_REQ: {

+        is_free_data =3D repaget_read_vol((RepCmdReadVolReq *) pcmd, pdata=
);

+    }

+        break;

+    default:

+        assert(0);

+        break;

+

+    }

+

+    if (is_free_data) {

+        g_free(pdata);

+    }

+}

+

+int repagent_client_send(RepCmd *p_cmd)

+{

+    int bytecount =3D 0;

+    printf("Send cmd %u, data size %u\n", p_cmd->hdr.cmdid,

+            p_cmd->hdr.data_size_bytes);

+    if (!g_client_state.is_connected) {

+        printf("Not connected to hub\n");

+        return -1;

+    }

+

+    bytecount =3D send(g_client_state.hsock, p_cmd,

+            sizeof(RepCmd) + p_cmd->hdr.data_size_bytes, 0);

+    if (bytecount < sizeof(RepCmd) + p_cmd->hdr.data_size_bytes) {

+        printf("Bad send %d, errno %d\n", bytecount, errno);

+        return bytecount;

+    }

+

+    /* Success */

+    return 0;

+}

diff --git a/replication/repagent_client.h b/replication/repagent_client.h

new file mode 100644

index 0000000..62a5377

--- /dev/null

+++ b/replication/repagent_client.h

@@ -0,0 +1,36 @@

+/*

+ * QEMU System Emulator

+ *

+ * Copyright (c) 2003-2008 Fabrice Bellard

+ *

+ * Permission is hereby granted, free of charge, to any person obtaining a
copy

+ * of this software and associated documentation files (the "Software"),
to deal

+ * in the Software without restriction, including without limitation the
rights

+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or
sell

+ * copies of the Software, and to permit persons to whom the Software is

+ * furnished to do so, subject to the following conditions:

+ *

+ * The above copyright notice and this permission notice shall be included
in

+ * all copies or substantial portions of the Software.

+ *

+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
OR

+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY=
,

+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL

+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR
OTHER

+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM,

+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN

+ * THE SOFTWARE.

+ */

+#ifndef REPAGENT_CLIENT_H

+#define REPAGENT_CLIENT_H

+#include "repcmd.h"

+

+typedef struct rephub_params {

+    char *name;

+    int port;

+} rephub_params;

+

+void *repagent_listen(void *pParam);

+int repagent_client_send(RepCmd *p_cmd);

+

+#endif /* REPAGENT_CLIENT_H */

diff --git a/replication/repcmd.h b/replication/repcmd.h

new file mode 100644

index 0000000..8c6cf1b

--- /dev/null

+++ b/replication/repcmd.h

@@ -0,0 +1,59 @@

+/*

+ * QEMU System Emulator

+ *

+ * Copyright (c) 2003-2008 Fabrice Bellard

+ *

+ * Permission is hereby granted, free of charge, to any person obtaining a
copy

+ * of this software and associated documentation files (the "Software"),
to deal

+ * in the Software without restriction, including without limitation the
rights

+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or
sell

+ * copies of the Software, and to permit persons to whom the Software is

+ * furnished to do so, subject to the following conditions:

+ *

+ * The above copyright notice and this permission notice shall be included
in

+ * all copies or substantial portions of the Software.

+ *

+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
OR

+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY=
,

+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL

+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR
OTHER

+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM,

+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN

+ * THE SOFTWARE.

+ */

+#ifndef REPCMD_H

+#define REPCMD_H

+

+#include <stdint.h>

+

+#define REPCMD_MAGIC1 (0x1122)

+#define REPCMD_MAGIC2 (0x3344)

+#define REPCMD_NUM_U32_PARAMS (11)

+

+enum RepCmds {

+    REPCMD_FIRST_INVALID                    =3D 0,

+    REPCMD_FIRST_HUBCMD                     =3D 1,

+    REPHUB_CMD_PROTECTED_WRITE              =3D 2,

+    REPHUB_CMD_REPORT_VM_VOLUMES            =3D 3,

+    REPHUB_CMD_START_PROTECT                =3D 4,

+    REPHUB_CMD_READ_VOL_REQ                 =3D 5,

+    REPHUB_CMD_READ_VOL_RES                 =3D 6,

+    REPHUB_CMD_AGENT_SHUTDOWN               =3D 7,

+};

+

+typedef struct RepCmdHdr {

+    uint16_t magic1;

+    uint16_t cmdid;

+    uint32_t data_size_bytes;

+} RepCmdHdr;

+

+typedef struct RepCmd {

+    RepCmdHdr hdr;

+    unsigned int parameters[REPCMD_NUM_U32_PARAMS];

+    unsigned int magic2;

+    uint8_t data[0];

+} RepCmd;

+

+RepCmd *repcmd_new(int cmd_id, int data_size, uint8_t **p_out_pdata);

+

+#endif /* REPCMD_H */

diff --git a/replication/repcmd_listener.c b/replication/repcmd_listener.c

new file mode 100644

index 0000000..a211927

--- /dev/null

+++ b/replication/repcmd_listener.c

@@ -0,0 +1,137 @@

+#include <fcntl.h>

+#include <string.h>

+#include <stdlib.h>

+#include <errno.h>

+#include <stdio.h>

+#include <netinet/in.h>

+#include <resolv.h>

+#include <sys/socket.h>

+#include <arpa/inet.h>

+#include <unistd.h>

+#include <pthread.h>

+#include <assert.h>

+

+/* Use the CONFIG_REPLICATION flag to determine whether

+ * we're under qemu build or a hub When under

+ * qemu use g_malloc */

+#ifdef CONFIG_REPLICATION

+#include <glib.h>

+#define REPCMD_MALLOC g_malloc

+#else

+#define REPCMD_MALLOC malloc

+#endif

+

+#include "repcmd.h"

+#include "repcmd_listener.h"

+

+#define ZERO_MEM_OBJ(pObj) memset((void *)pObj, 0, sizeof(*pObj))

+

+typedef struct RepCmdListenerState {

+    int is_terminate_receive;

+} RepCmdListenerState;

+

+static RepCmdListenerState g_listenerState =3D { 0 };

+

+/* Returns 0 for initiated termination or socket error value on error */

+int repcmd_listener(int hsock, pfn_received_cmd_cb callback, void
*clientPtr)

+{

+    RepCmd curCmd;

+    uint8_t *pReadBuf =3D (uint8_t *) &curCmd;

+    int bytesToGet =3D sizeof(RepCmd);

+    int bytesGotten =3D 0;

+    int isGotHeader =3D 0;

+    uint8_t *pdata =3D NULL;

+

+    assert(callback !=3D NULL);

+

+    /* receive loop */

+    while (!g_listenerState.is_terminate_receive) {

+        int bytecount;

+

+        bytecount =3D recv(hsock, pReadBuf + bytesGotten,

+                bytesToGet - bytesGotten, 0);

+        if (bytecount =3D=3D -1) {

+            fprintf(stderr, "Error receiving data %d\n", errno);

+            return errno;

+        }

+

+        if (bytecount =3D=3D 0) {

+            printf("Disconnected\n");

+            return 0;

+        }

+        bytesGotten +=3D bytecount;

+/*     printf("Recieved bytes %d, got %d/%d\n",

+                bytecount, bytesGotten, bytesToGet); */

+        /* print content */

+        if (0) {

+            int i;

+            for (i =3D 0; i < bytecount ; i +=3D 4) {

+                /*printf("%d/%d", i, bytecount/4); */

+                printf("%#x ",

+                        *(int *) (&pReadBuf[bytesGotten - bytecount + i]))=
;

+

+            }

+            printf("\n");

+        }

+        assert(bytesGotten <=3D bytesToGet);

+        if (bytesGotten =3D=3D bytesToGet) {

+            int isGotData =3D 0;

+            bytesGotten =3D 0;

+            if (!isGotHeader) {

+                /* We just got the header */

+                isGotHeader =3D 1;

+

+                assert(curCmd.hdr.magic1 =3D=3D REPCMD_MAGIC1);

+                assert(curCmd.magic2 =3D=3D REPCMD_MAGIC2);

+                if (curCmd.hdr.data_size_bytes > 0) {

+                    pdata =3D (uint8_t *)REPCMD_MALLOC(

+                                curCmd.hdr.data_size_bytes);

+/*                    printf("malloc %p\n", pdata); */

+                    pReadBuf =3D pdata;

+                } else {

+                    /* no data */

+                    isGotData =3D 1;

+                    pdata =3D NULL;

+                }

+                bytesToGet =3D curCmd.hdr.data_size_bytes;

+            } else {

+                isGotData =3D 1;

+            }

+

+            if (isGotData) {

+                /* Got command and data */

+                (*callback)(&curCmd, pdata, clientPtr);

+

+                /* It's the callee responsibility to free pData */

+                pdata =3D NULL;

+                ZERO_MEM_OBJ(&curCmd);

+                pReadBuf =3D (uint8_t *) &curCmd;

+                bytesGotten =3D 0;

+                bytesToGet =3D sizeof(RepCmd);

+                isGotHeader =3D 0;

+            }

+        }

+    }

+    return 0;

+}

+

+RepCmd *repcmd_new(int cmd_id, int data_size, uint8_t **p_out_pdata)

+{

+    RepCmd *p_cmd =3D (RepCmd *)REPCMD_MALLOC(sizeof(RepCmd) + data_size);

+    assert(p_cmd !=3D NULL);

+

+    /* Zero the CMD (not the data) */

+    ZERO_MEM_OBJ(p_cmd);

+

+    p_cmd->hdr.cmdid =3D cmd_id;

+    p_cmd->hdr.magic1 =3D REPCMD_MAGIC1;

+    p_cmd->magic2 =3D REPCMD_MAGIC2;

+    p_cmd->hdr.data_size_bytes =3D data_size;

+

+    if (p_out_pdata !=3D NULL) {

+        *p_out_pdata =3D p_cmd->data;

+    }

+

+    return p_cmd;

+}

+

diff --git a/replication/repcmd_listener.h b/replication/repcmd_listener.h

new file mode 100644

index 0000000..c09a12e

--- /dev/null

+++ b/replication/repcmd_listener.h

@@ -0,0 +1,32 @@

+/*

+ * QEMU System Emulator

+ *

+ * Copyright (c) 2003-2008 Fabrice Bellard

+ *

+ * Permission is hereby granted, free of charge, to any person obtaining a
copy

+ * of this software and associated documentation files (the "Software"),
to deal

+ * in the Software without restriction, including without limitation the
rights

+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or
sell

+ * copies of the Software, and to permit persons to whom the Software is

+ * furnished to do so, subject to the following conditions:

+ *

+ * The above copyright notice and this permission notice shall be included
in

+ * all copies or substantial portions of the Software.

+ *

+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
OR

+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY=
,

+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL

+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR
OTHER

+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM,

+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN

+ * THE SOFTWARE.

+ */

+#ifndef REPCMD_LISTENER_H

+#define REPCMD_LISTENER_H

+#include <stdint.h>

+typedef void (*pfn_received_cmd_cb)(RepCmd *pCmd,

+                uint8_t *pData, void *clientPtr);

+

+int repcmd_listener(int hsock, pfn_received_cmd_cb callback, void
*clientPtr);

+

+#endif /* REPCMD_LISTENER_H */

diff --git a/replication/rephub_cmds.h b/replication/rephub_cmds.h

new file mode 100644

index 0000000..820c37d

--- /dev/null

+++ b/replication/rephub_cmds.h

@@ -0,0 +1,150 @@

+/*

+ * QEMU System Emulator

+ *

+ * Copyright (c) 2003-2008 Fabrice Bellard

+ *

+ * Permission is hereby granted, free of charge, to any person obtaining a
copy

+ * of this software and associated documentation files (the "Software"),
to deal

+ * in the Software without restriction, including without limitation the
rights

+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or
sell

+ * copies of the Software, and to permit persons to whom the Software is

+ * furnished to do so, subject to the following conditions:

+ *

+ * The above copyright notice and this permission notice shall be included
in

+ * all copies or substantial portions of the Software.

+ *

+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
OR

+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY=
,

+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL

+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR
OTHER

+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM,

+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN

+ * THE SOFTWARE.

+ */

+#ifndef REPHUB_CMDS_H

+#define REPHUB_CMDS_H

+

+#include <stdint.h>

+#include "repcmd.h"

+#include "rephub_defs.h"

+

+/*********************************************************

+ * RepCmd Report a protected IO

+ *

+ * REPHUB_CMD_PROTECTED_WRITE

+ * Direction: agent->hub

+ *

+ * Any write of a protected volume is send with this

+ * message to the hub, with its status.

+ * When case the status is bad no data is sent

+ *********************************************************/

+typedef struct RepCmdProtectedWrite {

+    RepCmdHdr hdr;

+    uint64_t volume_id;

+    uint64_t offset_sectors;

+    /* The size field duplicates the RepCmd size,

+     * but it is needed for reporting failed IOs' sizes */

+    uint32_t size_sectors;

+    int ret_status;

+} RepCmdProtectedWrite;

+

+/*********************************************************

+ * RepCmd Report VM volumes

+ *

+ * REPHUB_CMD_REPORT_VM_VOLUMES

+ * Direction: agent->hub

+ *

+ * The agent reports all the volumes of the VM

+ * to the hub.

+ *********************************************************/

+typedef struct RepVmVolumeInfo {

+    char name[REPHUB_MAX_VOL_NAME_LEN];

+    uint64_t volume_id;

+    uint32_t size_mb;

+} RepVmVolumeInfo;

+

+typedef struct RepCmdReportVmVolumes {

+    RepCmdHdr hdr;

+    int num_volumes;

+} RepCmdReportVmVolumes;

+

+typedef struct RepCmdDataReportVmVolumes {

+    RepVmVolumeInfo volumes[0];

+} RepCmdDataReportVmVolumes;

+

+

+/*********************************************************

+ * RepCmd Start protect

+ *

+ * REPHUB_CMD_START_PROTECT

+ * Direction: hub->agent

+ *

+ * The hub instructs the agent to start protecting

+ * a volume. When a volume is protected all its writes

+ * are sent to to the hub.

+ * With this command the hub also assigns a volume ID to

+ * the given volume name.

+ *********************************************************/

+typedef struct RepCmdStartProtect {

+    RepCmdHdr hdr;

+    uint64_t volume_id;

+} RepCmdStartProtect;

+

+typedef struct RepCmdDataStartProtect {

+    char volume_name[REPHUB_MAX_VOL_NAME_LEN];

+} RepCmdDataStartProtect;

+

+

+/*********************************************************

+ * RepCmd Read Volume Request

+ *

+ * REPHUB_CMD_READ_VOL_REQ

+ * Direction: hub->agent

+ *

+ * The hub issues a read IO to a protected volume.

+ * This command is used during sync - when the hub needs

+ * to read unsyncronized sections of a protected volume.

+ * This command is a request, the read data is returned

+ * by the response command REPHUB_CMD_READ_VOL_RES

+ *********************************************************/

+typedef struct RepCmdReadVolReq {

+    RepCmdHdr hdr;

+    int req_id;

+    int size_sectors;

+    uint64_t volume_id;

+    uint64_t offset_sectors;

+} RepCmdReadVolReq;

+

+/*********************************************************

+ * RepCmd Read Volume Response

+ *

+ * REPHUB_CMD_READ_VOL_RES

+ * Direction: agent->hub

+ *

+ * A response to REPHUB_CMD_READ_VOL_REQ.

+ * Sends the data read from a protected volume

+ *********************************************************/

+typedef struct RepCmdReadVolRes {

+    RepCmdHdr hdr;

+    int req_id;

+    int is_status_success;

+    uint64_t volume_id;

+} RepCmdReadVolRes;

+

+/*********************************************************

+ * RepCmd Agent shutdown

+ *

+ * REPHUB_CMD_AGENT_SHUTDOWN

+ * Direction: agent->hub

+ *

+ * Notifies the hub that the agent is about to shutdown.

+ * This allows a graceful shutdown. Any disconnection

+ * of an agent without sending this command will result

+ * in a full sync of the VM volumes.

+ *********************************************************/

+typedef struct RepCmdAgentShutdown {

+    RepCmdHdr hdr;

+} RepCmdAgentShutdown;

+

+

+#endif /* REPHUB_CMDS_H */

diff --git a/replication/rephub_defs.h b/replication/rephub_defs.h

new file mode 100644

index 0000000..e34e0ce

--- /dev/null

+++ b/replication/rephub_defs.h

@@ -0,0 +1,40 @@

+/*

+ * QEMU System Emulator

+ *

+ * Copyright (c) 2003-2008 Fabrice Bellard

+ *

+ * Permission is hereby granted, free of charge, to any person obtaining a
copy

+ * of this software and associated documentation files (the "Software"),
to deal

+ * in the Software without restriction, including without limitation the
rights

+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or
sell

+ * copies of the Software, and to permit persons to whom the Software is

+ * furnished to do so, subject to the following conditions:

+ *

+ * The above copyright notice and this permission notice shall be included
in

+ * all copies or substantial portions of the Software.

+ *

+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
OR

+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY=
,

+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL

+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR
OTHER

+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM,

+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN

+ * THE SOFTWARE.

+ */

+#ifndef REP_HUB_DEFS_H

+#define REP_HUB_DEFS_H

+

+#include <stdint.h>

+

+#define REPHUB_MAX_VOL_NAME_LEN (1024)

+#define REPHUB_MAX_NUM_VOLUMES (512)

+

+#ifndef TRUE

+    #define TRUE (1)

+#endif

+

+#ifndef FALSE

+    #define FALSE (0)

+#endif

+

+#endif /* REP_HUB_DEFS_H */

diff --git a/vl.c b/vl.c

index 624da0f..506b5dc 100644

--- a/vl.c

+++ b/vl.c

@@ -167,6 +167,7 @@ int main(int argc, char **argv)

 #include "ui/qemu-spice.h"

+#include "replication/repagent.h"

//#define DEBUG_NET

//#define DEBUG_SLIRP

@@ -2307,6 +2308,15 @@ int main(int argc, char **argv, char **envp)

                 drive_add(IF_DEFAULT, popt->index - QEMU_OPTION_hda,
optarg,

                           HD_OPTS);

                 break;

+            case QEMU_OPTION_repagent:

+#ifdef CONFIG_REPLICATION

+                repagent_init(optarg, 0);

+#else

+                fprintf(stderr, "Replication support is disabled. "

+                    "Don't use -repagent option.\n");

+                exit(1);

+#endif

+                break;

             case QEMU_OPTION_drive:

                 if (drive_def(optarg) =3D=3D NULL) {

                     exit(1);

--=20

1.7.6.4

--047d7b3396015fba3f04b85d40a9
Content-Type: text/html; charset=windows-1252
Content-Transfer-Encoding: quoted-printable

<html><head><meta http-equiv=3D"Content-Type" content=3D"text/html; charset=
=3Dus-ascii"><meta name=3D"Generator" content=3D"Microsoft Word 14 (filtere=
d medium)"><style><!--
/* Font Definitions */
@font-face
	{font-family:Calibri;
	panose-1:2 15 5 2 2 2 4 3 2 4;}
/* Style Definitions */
p.MsoNormal, li.MsoNormal, div.MsoNormal
	{margin:0cm;
	margin-bottom:.0001pt;
	font-size:11.0pt;
	font-family:"Calibri","sans-serif";}
a:link, span.MsoHyperlink
	{mso-style-priority:99;
	color:blue;
	text-decoration:underline;}
a:visited, span.MsoHyperlinkFollowed
	{mso-style-priority:99;
	color:purple;
	text-decoration:underline;}
span.EmailStyle17
	{mso-style-type:personal-compose;
	font-family:"Calibri","sans-serif";
	color:windowtext;}
.MsoChpDefault
	{mso-style-type:export-only;
	font-family:"Calibri","sans-serif";}
@page WordSection1
	{size:612.0pt 792.0pt;
	margin:72.0pt 90.0pt 72.0pt 90.0pt;}
div.WordSection1
	{page:WordSection1;}
--></style></head><body lang=3D"EN-US" link=3D"blue" vlink=3D"purple"><div =
class=3D"WordSection1"><p class=3D"MsoNormal">Repagent is a new module that=
 allows an external replication system to replicate a volume of a Qemu VM.<=
/p><p class=3D"MsoNormal">
This RFC patch adds the repagent client module to Qemu.</p><p class=3D"MsoN=
ormal">=A0</p><p class=3D"MsoNormal">Documentation of the module role and A=
PI is in the patch at replication/qemu-repagent.txt</p><p class=3D"MsoNorma=
l">=A0</p>
<p class=3D"MsoNormal">The main motivation behind the module is to allow re=
plication of VMs in a virtualization environment like RhevM.</p><p class=3D=
"MsoNormal">To achieve this we need basic replication support in Qemu.</p><=
p class=3D"MsoNormal">
=A0</p><p class=3D"MsoNormal">This is the first submission of this module, =
which was written as a Proof Of Concept, and used successfully for replicat=
ing and recovering a Qemu VM. </p><p class=3D"MsoNormal">Points and open is=
sues:</p>
<p class=3D"MsoNormal">*=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 The module int=
erfaces the Qemu storage stack at block.c generic layer. Is this the right =
place to intercept/inject IOs? </p><p class=3D"MsoNormal">*=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0 The patch contains performing IO reads invoked by a n=
ew thread (a TCP listener thread). See repaget_read_vol in repagent.c. It i=
s not protected by any lock =96 is this OK?</p>
<p class=3D"MsoNormal">*=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 VM ID =96 the =
replication system implies an environment with several VMs connected to a c=
entral replication system (Rephub).</p><p class=3D"MsoNormal">=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 This requires some sort of identification=
 for a VM. The current patch does not include a VM ID =96 I did not find an=
y adequate ID to use.</p>
<p class=3D"MsoNormal">=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 Any su=
ggestions?</p><p class=3D"MsoNormal">=A0</p><p class=3D"MsoNormal">Apprecia=
te any feedback or suggestions.=A0 Thanks,</p><p class=3D"MsoNormal">Ori.</=
p><p class=3D"MsoNormal">=A0</p><p class=3D"MsoNormal">
=A0</p><p class=3D"MsoNormal">From 5a0d88689ddcf325f25fdfca2a2012f1bbf141b9=
 Mon Sep 17 00:00:00 2001</p><p class=3D"MsoNormal">From: Ori Mamluk &lt;or=
im@orim-fedora.(none)&gt;</p><p class=3D"MsoNormal">Date: Tue, 7 Feb 2012 1=
1:12:12 +0200</p>
<p class=3D"MsoNormal">Subject: [PATCH] Added replication agent module (rep=
agent) to Qemu under</p><p class=3D"MsoNormal"> replication directory, adde=
d repagent configure and run</p><p class=3D"MsoNormal"> options, and the re=
pagent API usage in bloc</p>
<p class=3D"MsoNormal">=A0</p><p class=3D"MsoNormal">Added build options to=
 ./configure:=A0 --enable-replication --disable-replicat</p><p class=3D"Mso=
Normal">Added a commandline option to enable: -repagent &lt;rep hub IP&gt;<=
/p><p class=3D"MsoNormal">
Added the module files under replication.</p><p class=3D"MsoNormal">=A0</p>=
<p class=3D"MsoNormal">Signed-off-by: Ori Mamluk &lt;<a href=3D"mailto:orim=
@zerto.com">orim@zerto.com</a>&gt;</p><p class=3D"MsoNormal">---</p><p clas=
s=3D"MsoNormal">
 Makefile=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 |=
=A0=A0=A0 9 +-</p><p class=3D"MsoNormal"> Makefile.objs=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 |=A0=A0=A0 6 +</p><p class=3D"MsoNormal"> bl=
ock.c=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 =A0=A0=A0=A0|=
=A0=A0 20 +++-</p><p class=3D"MsoNormal"> configure=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 |=A0=A0 11 ++</p>
<p class=3D"MsoNormal"> qemu-options.hx=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 |=A0=A0=A0 6 +</p><p class=3D"MsoNormal"> replication/qemu-repagent.=
txt |=A0 104 +++++++++++++</p><p class=3D"MsoNormal"> replication/repagent.=
c=A0=A0=A0=A0=A0=A0=A0 |=A0 322 +++++++++++++++++++++++++++++++++++++++++</=
p>
<p class=3D"MsoNormal"> replication/repagent.h=A0=A0=A0=A0=A0=A0=A0 |=A0=A0=
 46 ++++++</p><p class=3D"MsoNormal"> replication/repagent_client.c |=A0 13=
8 ++++++++++++++++++</p><p class=3D"MsoNormal"> replication/repagent_client=
.h |=A0=A0 36 +++++</p><p class=3D"MsoNormal">
 replication/repcmd.h=A0=A0=A0=A0=A0=A0=A0=A0=A0 |=A0=A0 59 ++++++++</p><p =
class=3D"MsoNormal"> replication/repcmd_listener.c |=A0 137 +++++++++++++++=
++</p><p class=3D"MsoNormal"> replication/repcmd_listener.h |=A0=A0 32 ++++=
</p><p class=3D"MsoNormal"> replication/rephub_cmds.h=A0=A0=A0=A0 |=A0 150 =
+++++++++++++++++++</p>
<p class=3D"MsoNormal"> replication/rephub_defs.h=A0=A0=A0=A0 |=A0=A0 40 ++=
+++</p><p class=3D"MsoNormal"> vl.c=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 |=A0=A0 10 ++</p><p class=3D"MsoNormal=
"> 16 files changed, 1121 insertions(+), 5 deletions(-)</p><p class=3D"MsoN=
ormal">
 mode change 100644 =3D&gt; 100755 Makefile.objs</p><p class=3D"MsoNormal">=
 mode change 100644 =3D&gt; 100755 qemu-options.hx</p><p class=3D"MsoNormal=
"> create mode 100755 replication/qemu-repagent.txt</p><p class=3D"MsoNorma=
l"> create mode 100644 replication/repagent.c</p>
<p class=3D"MsoNormal"> create mode 100644 replication/repagent.h</p><p cla=
ss=3D"MsoNormal"> create mode 100644 replication/repagent_client.c</p><p cl=
ass=3D"MsoNormal"> create mode 100644 replication/repagent_client.h</p><p c=
lass=3D"MsoNormal">
 create mode 100644 replication/repcmd.h</p><p class=3D"MsoNormal"> create =
mode 100644 replication/repcmd_listener.c</p><p class=3D"MsoNormal"> create=
 mode 100644 replication/repcmd_listener.h</p><p class=3D"MsoNormal"> creat=
e mode 100644 replication/rephub_cmds.h</p>
<p class=3D"MsoNormal"> create mode 100644 replication/rephub_defs.h</p><p =
class=3D"MsoNormal">=A0</p><p class=3D"MsoNormal">diff --git a/Makefile b/M=
akefile</p><p class=3D"MsoNormal">index 4f6eaa4..a1b3701 100644</p><p class=
=3D"MsoNormal">
--- a/Makefile</p><p class=3D"MsoNormal">+++ b/Makefile</p><p class=3D"MsoN=
ormal">@@ -149,9 +149,9 @@ qemu-img.o qemu-tool.o qemu-nbd.o qemu-io.o cmd.=
o qemu-ga.o: $(GENERATED_HEADERS</p><p class=3D"MsoNormal"> tools-obj-y =3D=
 qemu-tool.o $(oslib-obj-y) $(trace-obj-y) \</p>
<p class=3D"MsoNormal"> =A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 qemu-tim=
er-common.o cutils.o</p><p class=3D"MsoNormal"> </p><p class=3D"MsoNormal">=
-qemu-img$(EXESUF): qemu-img.o $(tools-obj-y) $(block-obj-y)</p><p class=3D=
"MsoNormal">-qemu-nbd$(EXESUF): qemu-nbd.o $(tools-obj-y) $(block-obj-y)</p=
>
<p class=3D"MsoNormal">-qemu-io$(EXESUF): qemu-io.o cmd.o $(tools-obj-y) $(=
block-obj-y)</p><p class=3D"MsoNormal">+qemu-img$(EXESUF): qemu-img.o $(too=
ls-obj-y) $(block-obj-y) $(replication-obj-y)</p><p class=3D"MsoNormal">+qe=
mu-nbd$(EXESUF): qemu-nbd.o $(tools-obj-y) $(block-obj-y) $(replication-obj=
-y)</p>
<p class=3D"MsoNormal">+qemu-io$(EXESUF): qemu-io.o cmd.o $(tools-obj-y) $(=
block-obj-y) $(replication-obj-y)</p><p class=3D"MsoNormal"> </p><p class=
=3D"MsoNormal">=A0qemu-img-cmds.h: $(SRC_PATH)/qemu-img-cmds.hx</p><p class=
=3D"MsoNormal">
 =A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 $(call quiet-command,sh $(SRC_P=
ATH)/scripts/hxtool -h &lt; $&lt; &gt; $@,&quot;=A0 GEN=A0=A0 $@&quot;)</p>=
<p class=3D"MsoNormal">@@ -228,6 +228,7 @@ clean:</p><p class=3D"MsoNormal"=
> =A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 rm -f trace-dtrace.dtrace trac=
e-dtrace.dtrace-timestamp</p>
<p class=3D"MsoNormal"> =A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 rm -f tr=
ace-dtrace.h trace-dtrace.h-timestamp</p><p class=3D"MsoNormal"> =A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 rm -rf $(qapi-dir)</p><p class=3D"MsoNorm=
al">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 rm -f replication/*.{o,d}</p><p c=
lass=3D"MsoNormal">
 =A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 $(MAKE) -C tests clean</p><p cl=
ass=3D"MsoNormal"> =A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 for d in $(AL=
L_SUBDIRS) $(QEMULIBS) libcacard; do \</p><p class=3D"MsoNormal"> =A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 if test -d $$d; then $(MAKE) -C $$d $@ ||=
 exit 1; fi; \</p>
<p class=3D"MsoNormal">@@ -387,4 +388,4 @@ tar:</p><p class=3D"MsoNormal"> =
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 rm -rf /tmp/$(FILE)</p><p class=
=3D"MsoNormal"> </p><p class=3D"MsoNormal">=A0# Include automatically gener=
ated dependency files</p><p class=3D"MsoNormal">
--include $(wildcard *.d audio/*.d slirp/*.d block/*.d net/*.d ui/*.d qapi/=
*.d qga/*.d)</p><p class=3D"MsoNormal">+-include $(wildcard *.d audio/*.d s=
lirp/*.d block/*.d net/*.d ui/*.d qapi/*.d qga/*.d replication/*.d)</p><p c=
lass=3D"MsoNormal">
diff --git a/Makefile.objs b/Makefile.objs</p><p class=3D"MsoNormal">old mo=
de 100644</p><p class=3D"MsoNormal">new mode 100755</p><p class=3D"MsoNorma=
l">index d7a6539..dbd6f15</p><p class=3D"MsoNormal">--- a/Makefile.objs</p>=
<p class=3D"MsoNormal">
+++ b/Makefile.objs</p><p class=3D"MsoNormal">@@ -74,6 +74,7 @@ fsdev-obj-$=
(CONFIG_VIRTFS) +=3D $(addprefix fsdev/, $(fsdev-nested-y))</p><p class=3D"=
MsoNormal"> # CPUs and machines.</p><p class=3D"MsoNormal"> </p><p class=3D=
"MsoNormal">
=A0common-obj-y =3D $(block-obj-y) blockdev.o</p><p class=3D"MsoNormal">+co=
mmon-obj-y +=3D $(replication-obj-$(CONFIG_REPLICATION))</p><p class=3D"Mso=
Normal"> common-obj-y +=3D $(net-obj-y)</p><p class=3D"MsoNormal"> common-o=
bj-y +=3D $(qobject-obj-y)</p>
<p class=3D"MsoNormal"> common-obj-$(CONFIG_LINUX) +=3D $(fsdev-obj-$(CONFI=
G_LINUX))</p><p class=3D"MsoNormal">@@ -413,6 +414,11 @@ common-obj-y +=3D =
qmp-marshal.o qapi-visit.o qapi-types.o $(qapi-obj-y)</p><p class=3D"MsoNor=
mal"> common-obj-y +=3D qmp.o hmp.o</p>
<p class=3D"MsoNormal"> </p><p class=3D"MsoNormal">=A0#####################=
#################################################</p><p class=3D"MsoNormal"=
>+# replication</p><p class=3D"MsoNormal">+replication-nested-y =3D repagen=
t_client.o=A0 repagent.o=A0 repcmd_listener.o</p>
<p class=3D"MsoNormal">+replication-obj-y =3D $(addprefix replication/, $(r=
eplication-nested-y))</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal"=
>+######################################################################</p=
><p class=3D"MsoNormal">
 # guest agent</p><p class=3D"MsoNormal"> </p><p class=3D"MsoNormal">=A0qga=
-nested-y =3D guest-agent-commands.o guest-agent-command-state.o</p><p clas=
s=3D"MsoNormal">diff --git a/block.c b/block.c</p><p class=3D"MsoNormal">in=
dex 9bb236c..f3b8387 100644</p>
<p class=3D"MsoNormal">--- a/block.c</p><p class=3D"MsoNormal">+++ b/block.=
c</p><p class=3D"MsoNormal">@@ -31,6 +31,10 @@</p><p class=3D"MsoNormal"> #=
include &quot;qemu-coroutine.h&quot;</p><p class=3D"MsoNormal"> #include &q=
uot;qmp-commands.h&quot;</p>
<p class=3D"MsoNormal"> </p><p class=3D"MsoNormal">+#ifdef CONFIG_REPLICATI=
ON</p><p class=3D"MsoNormal">+#include &quot;replication/repagent.h&quot;</=
p><p class=3D"MsoNormal">+#endif</p><p class=3D"MsoNormal">+</p><p class=3D=
"MsoNormal">
 #ifdef CONFIG_BSD</p><p class=3D"MsoNormal"> #include &lt;sys/types.h&gt;<=
/p><p class=3D"MsoNormal"> #include &lt;sys/stat.h&gt;</p><p class=3D"MsoNo=
rmal">@@ -640,6 +644,9 @@ int bdrv_open(BlockDriverState *bs, const char *f=
ilename, int flags,</p>
<p class=3D"MsoNormal">=A0=A0=A0=A0=A0=A0=A0=A0 goto unlink_and_fail;</p><p=
 class=3D"MsoNormal">=A0=A0=A0=A0 }</p><p class=3D"MsoNormal"> </p><p class=
=3D"MsoNormal">+#ifdef CONFIG_REPLICATION</p><p class=3D"MsoNormal">+=A0=A0=
=A0 repagent_register_drive(filename,=A0 bs);</p>
<p class=3D"MsoNormal">+#endif</p><p class=3D"MsoNormal">=A0=A0=A0=A0 /* Op=
en the image */</p><p class=3D"MsoNormal">=A0=A0=A0=A0 ret =3D bdrv_open_co=
mmon(bs, filename, flags, drv);</p><p class=3D"MsoNormal">=A0=A0=A0=A0 if (=
ret &lt; 0) {</p><p class=3D"MsoNormal">
@@ -1292,6 +1299,17 @@ static int coroutine_fn bdrv_co_do_writev(BlockDrive=
rState *bs,</p><p class=3D"MsoNormal"> </p><p class=3D"MsoNormal">=A0=A0=A0=
=A0=A0ret =3D drv-&gt;bdrv_co_writev(bs, sector_num, nb_sectors, qiov);</p>=
<p class=3D"MsoNormal">
 </p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+#ifdef CONFIG_REPL=
ICATION</p><p class=3D"MsoNormal">+=A0=A0=A0 if (bs-&gt;device_name[0] !=3D=
 &#39;\0&#39;) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 /* We spl=
it the IO only at the highest stack driver layer.</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 Currently we know th=
at by checking device_name - only</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0 highest level (closest to the guest) has that name.</p><=
p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 */</p><p class=3D"Mso=
Normal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 repagent_handle_protected_write(bs, sector_=
num,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0 nb_sectors, qiov, ret);</p><p class=3D"MsoNormal">+=A0=A0=A0 }</p><p cl=
ass=3D"MsoNormal">+#endif</p><p class=3D"MsoNormal">=A0=A0=A0=A0 if (bs-&gt=
;dirty_bitmap) {</p>
<p class=3D"MsoNormal">=A0=A0=A0=A0=A0=A0=A0=A0 set_dirty_bitmap(bs, sector=
_num, nb_sectors, 1);</p><p class=3D"MsoNormal">=A0=A0=A0=A0 }</p><p class=
=3D"MsoNormal">@@ -1783,7 +1801,7 @@ int bdrv_has_zero_init(BlockDriverStat=
e *bs)</p><p class=3D"MsoNormal">
=A0 * &#39;nb_sectors&#39; is the max value &#39;pnum&#39; should be set to=
.</p><p class=3D"MsoNormal">=A0 */</p><p class=3D"MsoNormal"> int bdrv_is_a=
llocated(BlockDriverState *bs, int64_t sector_num, int nb_sectors,</p><p cl=
ass=3D"MsoNormal">
-=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 int *pnum)</p><p class=3D"MsoNorma=
l">+=A0=A0=A0 int *pnum)</p><p class=3D"MsoNormal"> {</p><p class=3D"MsoNor=
mal">=A0=A0=A0=A0 int64_t n;</p><p class=3D"MsoNormal">=A0=A0=A0=A0 if (!bs=
-&gt;drv-&gt;bdrv_is_allocated) {</p><p class=3D"MsoNormal">
diff --git a/configure b/configure</p><p class=3D"MsoNormal">index 9e5da44.=
.93d600e 100755</p><p class=3D"MsoNormal">--- a/configure</p><p class=3D"Ms=
oNormal">+++ b/configure</p><p class=3D"MsoNormal">@@ -179,6 +179,7 @@ spic=
e=3D&quot;&quot;</p>
<p class=3D"MsoNormal"> rbd=3D&quot;&quot;</p><p class=3D"MsoNormal"> smart=
card=3D&quot;&quot;</p><p class=3D"MsoNormal"> smartcard_nss=3D&quot;&quot;=
</p><p class=3D"MsoNormal">+replication=3D&quot;&quot;</p><p class=3D"MsoNo=
rmal"> usb_redir=3D&quot;&quot;</p>
<p class=3D"MsoNormal"> opengl=3D&quot;&quot;</p><p class=3D"MsoNormal"> zl=
ib=3D&quot;yes&quot;</p><p class=3D"MsoNormal">@@ -772,6 +773,10 @@ for opt=
 do</p><p class=3D"MsoNormal">=A0=A0 ;;</p><p class=3D"MsoNormal">=A0=A0 --=
enable-smartcard-nss) smartcard_nss=3D&quot;yes&quot;</p>
<p class=3D"MsoNormal">=A0=A0 ;;</p><p class=3D"MsoNormal">+=A0 --disable-r=
eplication) replication=3D&quot;no&quot;</p><p class=3D"MsoNormal">+=A0 ;;<=
/p><p class=3D"MsoNormal">+=A0 --enable-replication) replication=3D&quot;ye=
s&quot;</p><p class=3D"MsoNormal">
+=A0 ;;</p><p class=3D"MsoNormal">=A0=A0 --disable-usb-redir) usb_redir=3D&=
quot;no&quot;</p><p class=3D"MsoNormal">=A0=A0 ;;</p><p class=3D"MsoNormal"=
>=A0=A0 --enable-usb-redir) usb_redir=3D&quot;yes&quot;</p><p class=3D"MsoN=
ormal">@@ -1067,6 +1072,7 @@ echo &quot;=A0 --disable-usb-redir=A0=A0=A0=A0=
=A0 disable usb network redirection support&quot;</p>
<p class=3D"MsoNormal"> echo &quot;=A0 --enable-usb-redir=A0=A0=A0=A0=A0=A0=
 enable usb network redirection support&quot;</p><p class=3D"MsoNormal"> ec=
ho &quot;=A0 --disable-guest-agent=A0=A0=A0 disable building of the QEMU Gu=
est Agent&quot;</p><p class=3D"MsoNormal">
 echo &quot;=A0 --enable-guest-agent=A0=A0=A0=A0 enable building of the QEM=
U Guest Agent&quot;</p><p class=3D"MsoNormal">+echo &quot;=A0 --enable-repl=
ication=A0=A0=A0=A0 enable replication support&quot;</p><p class=3D"MsoNorm=
al"> echo &quot;&quot;</p>
<p class=3D"MsoNormal"> echo &quot;NOTE: The object files are built at the =
place where configure is launched&quot;</p><p class=3D"MsoNormal"> exit 1</=
p><p class=3D"MsoNormal">@@ -2733,6 +2739,7 @@ echo &quot;curl support=A0=
=A0=A0=A0=A0 $curl&quot;</p>
<p class=3D"MsoNormal"> echo &quot;check support=A0=A0=A0=A0 $check_utests&=
quot;</p><p class=3D"MsoNormal"> echo &quot;mingw32 support=A0=A0 $mingw32&=
quot;</p><p class=3D"MsoNormal"> echo &quot;Audio drivers=A0=A0=A0=A0 $audi=
o_drv_list&quot;</p><p class=3D"MsoNormal">
+echo &quot;Replication=A0=A0=A0=A0=A0 =A0=A0=A0 $replication&quot;</p><p c=
lass=3D"MsoNormal"> echo &quot;Extra audio cards $audio_card_list&quot;</p>=
<p class=3D"MsoNormal"> echo &quot;Block whitelist=A0=A0 $block_drv_whiteli=
st&quot;</p><p class=3D"MsoNormal">
 echo &quot;Mixer emulation=A0=A0 $mixemu&quot;</p><p class=3D"MsoNormal">@=
@ -3080,6 +3087,10 @@ if test &quot;$smartcard_nss&quot; =3D &quot;yes&quot=
; ; then</p><p class=3D"MsoNormal">=A0=A0 echo &quot;CONFIG_SMARTCARD_NSS=
=3Dy&quot; &gt;&gt; $config_host_mak</p>
<p class=3D"MsoNormal"> fi</p><p class=3D"MsoNormal"> </p><p class=3D"MsoNo=
rmal">+if test &quot;$replication&quot; =3D &quot;yes&quot; ; then</p><p cl=
ass=3D"MsoNormal">+=A0 echo &quot;CONFIG_REPLICATION=3Dy&quot; &gt;&gt; $co=
nfig_host_mak</p>
<p class=3D"MsoNormal">+fi</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNo=
rmal"> if test &quot;$usb_redir&quot; =3D &quot;yes&quot; ; then</p><p clas=
s=3D"MsoNormal">=A0=A0 echo &quot;CONFIG_USB_REDIR=3Dy&quot; &gt;&gt; $conf=
ig_host_mak</p>
<p class=3D"MsoNormal"> fi</p><p class=3D"MsoNormal">diff --git a/qemu-opti=
ons.hx b/qemu-options.hx</p><p class=3D"MsoNormal">old mode 100644</p><p cl=
ass=3D"MsoNormal">new mode 100755</p><p class=3D"MsoNormal">index 681eaf1..=
c97e4f8</p>
<p class=3D"MsoNormal">--- a/qemu-options.hx</p><p class=3D"MsoNormal">+++ =
b/qemu-options.hx</p><p class=3D"MsoNormal">@@ -2602,3 +2602,9 @@ HXCOMM Th=
is is the last statement. Insert new options before this line!</p><p class=
=3D"MsoNormal">
 STEXI</p><p class=3D"MsoNormal"> @end table</p><p class=3D"MsoNormal"> ETE=
XI</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+DEF(&quot;repagen=
t&quot;, HAS_ARG, QEMU_OPTION_repagent,</p><p class=3D"MsoNormal">+=A0=A0=
=A0 &quot;-repagent [hub IP/name]\n&quot;</p>
<p class=3D"MsoNormal">+=A0=A0=A0 &quot;=A0=A0=A0=A0=A0=A0=A0=A0=A0 =A0=A0=
=A0=A0=A0=A0Enable replication support for disks\n&quot;</p><p class=3D"Mso=
Normal">+=A0=A0=A0 &quot;=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 hub =
is the ip or name of the machine running the replication hub.\n&quot;,</p>
<p class=3D"MsoNormal">+=A0=A0=A0 QEMU_ARCH_ALL)</p><p class=3D"MsoNormal">=
diff --git a/replication/qemu-repagent.txt b/replication/qemu-repagent.txt<=
/p><p class=3D"MsoNormal">new file mode 100755</p><p class=3D"MsoNormal">in=
dex 0000000..e3b0c1e</p>
<p class=3D"MsoNormal">--- /dev/null</p><p class=3D"MsoNormal">+++ b/replic=
ation/qemu-repagent.txt</p><p class=3D"MsoNormal">@@ -0,0 +1,104 @@</p><p c=
lass=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 repagent - replica=
tion agent - a Qemu module for enabling continuous async replication of VM =
volumes</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+Introduction</p><p clas=
s=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 This document describ=
es a feature in Qemu - a replication agent (AKA Repagent).</p><p class=3D"M=
soNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 The Repagent is a new modul=
e that exposes an API to an external replication system (AKA Rephub).</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 This API allow=
s a Rephub to communicate with a Qemu VM and continuously replicate its vol=
umes.</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 The i=
mlementation of a Rephub is outside of the scope of this document. There ma=
y be several various Rephub</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 implenetations=
 using the same repagent in Qemu.</p><p class=3D"MsoNormal">+</p><p class=
=3D"MsoNormal">+Main feature of Repagent</p><p class=3D"MsoNormal">+=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 Repagent does the following:</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 * Report volum=
es - report a list of all volumes in a VM to the Rephub.</p><p class=3D"Mso=
Normal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 * Report writes to a volume -=
 send all writes made to a protected volume to the Rephub.</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 The reporting of an IO is asyncronuous - =
i.e. the IO is not delayed by the Repagent to get any acknowledgement from =
the Rephub.</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 It is only copied to the R=
ephub.</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 * Read a prote=
cted volume - allows the Rephub to read a protected volume, to enable the p=
rotected hub to syncronize the content of a protected volume.</p><p class=
=3D"MsoNormal">+</p><p class=3D"MsoNormal">
+Description of the Repagent module</p><p class=3D"MsoNormal">+</p><p class=
=3D"MsoNormal">+Build and run options</p><p class=3D"MsoNormal">+=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0 New configure option: --enable-replication</p><=
p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 New command lin=
e option:</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 -repagent [hub=
 IP/name]</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 Enable replication support for d=
isks</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 hub is the ip or name of the machine running the replication hub.</p=
><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+Module APIs</p><p clas=
s=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 The Repagent module interfaces two ma=
in components:</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0 1. The Rephub - An external API based on socket messages</p><p class=3D=
"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 2. The generic block laye=
r- block.c</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0 Rephub message API</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 Th=
e external replication API is a message based API.</p><p class=3D"MsoNormal=
">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0 We won&#39;t go into the structure of the messages here - just=
 the sematics.</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 Messages li=
st</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0 (The updated list and comments are in Rephub_cmds.h)</p><p cla=
ss=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0 Messages from the Repagent to the Rephub:</p><p class=3D"MsoNo=
rmal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 * Protec=
ted write</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 The Repagent sends each write to a protec=
ted volume to the hub with the IO status.</p><p class=3D"MsoNormal">+=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0 In case the status is bad the write content is not=
 sent</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 * Report VM volumes</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0 The agent reports all the volumes of the VM to the hub.</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 * Read Volume Response</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0 A response to a Read Volume Request</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 Sends the data read from a protected volu=
me to the hub</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0 * Agent shutdown</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 Notifies the hub that the agent is about =
to shutdown.</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 Th=
is allows a graceful shutdown. Any disconnection of an agent without</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 sending this command=
 will result in a full sync of the VM volumes.</p><p class=3D"MsoNormal">+<=
/p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0 Messages from the Rephub to the Repagent:</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 * Start protect</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 The hub instructs the agent to start protecting a volume. When a vol=
ume is protected</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 all its writes are s=
ent to to the hub.</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0 With this command the hub also assigns a volume ID to the given volume =
name.</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 * Read volume request</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0 The hub issues a read IO to a protected volume.</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 This command is used=
 during sync - when the hub needs to read unsyncronized</p><p class=3D"MsoN=
ormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 sections of a protected volume.</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 This command is a re=
quest, the read data is returned by the read volume response message (see a=
bove).</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 bloc=
k.c API</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 The API to the generic block storage laye=
r contains 3 functionalities:</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 1. Handl=
e writes to protected volumes</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 In bdrv_co_do_=
writev, each write is reported to the Repagent module.</p><p class=3D"MsoNo=
rmal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0 2. Handle each new volume that registers</p><p class=3D"=
MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 In bdrv_open -=
 each new bottom-level block driver that registers is reported.</p><p class=
=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0 2. Read from a volume</p><p class=3D"MsoNormal"=
>
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 Repagent calls=
 bdrv_aio_readv to handle read requests coming from the hub.</p><p class=3D=
"MsoNormal">+</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+Genera=
l description of a Rephub=A0 - a replication system the repagent connects t=
o</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 This section d=
escribes in high level a sample Rephub - a replication system that uses the=
 repagent API</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0 to replicate disks.</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0 It describes a simple Rephub that comntinuously maintains a mi=
rror of the volumes of a VM.</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0 Say we have a VM we want to protect - call it PVM, say it h=
as 2 volumes - V1, V2.</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0 Our Rephub is called SingleRephub - a Rephub protecting a sing=
le VM.</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0 Preparations</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0 1. The user chooses a host to rub SingleRephub - a diffe=
rent host than PVM, call it Host2</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 2. The user creates two volumes on Ho=
st2 - same sizes of V1 and V2, call them V1R (V1 recovery) and V2R.</p><p c=
lass=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 3. The user runs S=
ingleRephub process on Host2, and gives V1R and V2R as command line argumen=
ts.</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 From now on SingleRephub waits for the pr=
otected VM repagent to connect.</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0 4. The user runs the protected VM PVM - and uses the =
switch -repagent &lt;Host2 IP&gt;.</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0 Runtime</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0 1. The repagent module connects to SingleRephub on startup.</p=
><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 2. repagent r=
eports V1 and V2 to SingleRephub.</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 3. SingleRephu=
b starts to perform an initial synchronization of the protected volumes-</p=
><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 it reads each protected volume (V1 and=
 V2) - using read volume requests - and copies the data into the</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 recovery volume V1R and V2R.</p><p class=
=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 4. SingleRephub enters=
 &#39;protection&#39; mode - each write to the protected volume is sent by =
the repagent to the Rephub,</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 and the Rephub performs the write on the =
matching recovery volume.</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNor=
mal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 * Note that during stage 3 write=
s to the protected volumes are not ignored - they&#39;re kept in a bitmap,<=
/p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 and will be read again when stage 3 ends,=
 in an interative convergin process.</p><p class=3D"MsoNormal">+</p><p clas=
s=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 This flow continuousl=
y maintains an updated recovery volume.</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 If the protect=
ed system is damaged, the user can create a new VM on Host2 with the replic=
ated volumes attached to it.</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0 The new VM is a replica of the protected system.</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNorm=
al">diff --git a/replication/repagent.c b/replication/repagent.c</p><p clas=
s=3D"MsoNormal">new file mode 100644</p><p class=3D"MsoNormal">index 000000=
0..c66eae7</p>
<p class=3D"MsoNormal">--- /dev/null</p><p class=3D"MsoNormal">+++ b/replic=
ation/repagent.c</p><p class=3D"MsoNormal">@@ -0,0 +1,322 @@</p><p class=3D=
"MsoNormal">+#include &lt;string.h&gt;</p><p class=3D"MsoNormal">+#include =
&lt;stdlib.h&gt;</p>
<p class=3D"MsoNormal">+#include &lt;stdio.h&gt;</p><p class=3D"MsoNormal">=
+#include &lt;pthread.h&gt;</p><p class=3D"MsoNormal">+#include &lt;stdint.=
h&gt;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+#include &quot=
;block.h&quot;</p>
<p class=3D"MsoNormal">+#include &quot;rephub_defs.h&quot;</p><p class=3D"M=
soNormal">+#include &quot;block_int.h&quot;</p><p class=3D"MsoNormal">+#inc=
lude &quot;repagent_client.h&quot;</p><p class=3D"MsoNormal">+#include &quo=
t;repagent.h&quot;</p>
<p class=3D"MsoNormal">+#include &quot;rephub_cmds.h&quot;</p><p class=3D"M=
soNormal">+</p><p class=3D"MsoNormal">+#define ZERO_MEM_OBJ(pObj) memset(pO=
bj, 0, sizeof(*pObj))</p><p class=3D"MsoNormal">+#define REPAGENT_MAX_NUM_V=
OLUMES (64)</p>
<p class=3D"MsoNormal">+#define REPAGENT_VOLUME_ID_NONE (0)</p><p class=3D"=
MsoNormal">+</p><p class=3D"MsoNormal">+typedef struct RepagentVolume {</p>=
<p class=3D"MsoNormal">+=A0=A0=A0 uint64_t vol_id;</p><p class=3D"MsoNormal=
">+=A0=A0=A0 const char *vol_path;</p>
<p class=3D"MsoNormal">+=A0=A0=A0 BlockDriverState *driver_ptr;</p><p class=
=3D"MsoNormal">+} RepagentVolume;</p><p class=3D"MsoNormal">+</p><p class=
=3D"MsoNormal">+struct RepAgentState {</p><p class=3D"MsoNormal">+=A0=A0=A0=
 int is_init;</p><p class=3D"MsoNormal">
+=A0=A0=A0 int num_volumes;</p><p class=3D"MsoNormal">+=A0=A0=A0 RepagentVo=
lume * volumes[REPAGENT_MAX_NUM_VOLUMES];</p><p class=3D"MsoNormal">+};</p>=
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+typedef struct Repagent=
ReadVolIo {</p><p class=3D"MsoNormal">
+=A0=A0=A0 QEMUIOVector qiov;</p><p class=3D"MsoNormal">+=A0=A0=A0 RepCmdRe=
adVolReq rep_cmd;</p><p class=3D"MsoNormal">+=A0=A0=A0 uint8_t *buf;</p><p =
class=3D"MsoNormal">+=A0=A0=A0 struct timeval start_time;</p><p class=3D"Ms=
oNormal">+} RepagentReadVolIo;</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+static int repagent_get=
_volume_by_name(const char *name);</p><p class=3D"MsoNormal">+static void r=
epagent_report_volumes_to_hub(void);</p><p class=3D"MsoNormal">+static void=
 repagent_vol_read_done(void *opaque, int ret);</p>
<p class=3D"MsoNormal">+static struct timeval tsub(struct timeval t1, struc=
t timeval t2);</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+RepAg=
entState g_rep_agent =3D { 0 };</p><p class=3D"MsoNormal">+</p><p class=3D"=
MsoNormal">
+void repagent_init(const char *hubname, int port)</p><p class=3D"MsoNormal=
">+{</p><p class=3D"MsoNormal">+=A0=A0=A0 /* It is the responsibility of th=
e thread to free this struct */</p><p class=3D"MsoNormal">+=A0=A0=A0 rephub=
_params *pParams =3D (rephub_params *)g_malloc(sizeof(rephub_params));</p>
<p class=3D"MsoNormal">+=A0=A0=A0 if (hubname =3D=3D NULL) {</p><p class=3D=
"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 hubname =3D &quot;127.0.0.1&quot;;</p><p=
 class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0 if (=
port =3D=3D 0) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 port =3D =
9010;</p>
<p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+</p><p class=
=3D"MsoNormal">+=A0=A0=A0 printf(&quot;repagent_init %s\n&quot;, hubname);<=
/p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 pParams-&g=
t;port =3D port;</p><p class=3D"MsoNormal">
+=A0=A0=A0 pParams-&gt;name =3D g_strdup(hubname);</p><p class=3D"MsoNormal=
">+</p><p class=3D"MsoNormal">+=A0=A0=A0 pthread_t thread_id =3D 0;</p><p c=
lass=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 /* Create the rep=
agent client listener thread */</p>
<p class=3D"MsoNormal">+=A0=A0=A0 pthread_create(&amp;thread_id, 0, repagen=
t_listen, (void *) pParams);</p><p class=3D"MsoNormal">+=A0=A0=A0 pthread_d=
etach(thread_id);</p><p class=3D"MsoNormal">+}</p><p class=3D"MsoNormal">+<=
/p><p class=3D"MsoNormal">
+void repagent_register_drive(const char *drive_path,</p><p class=3D"MsoNor=
mal">+=A0=A0=A0=A0=A0=A0=A0 BlockDriverState *driver_ptr)</p><p class=3D"Ms=
oNormal">+{</p><p class=3D"MsoNormal">+=A0=A0=A0 int i;</p><p class=3D"MsoN=
ormal">+=A0=A0=A0 for (i =3D 0; i &lt; g_rep_agent.num_volumes ; i++) {</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 RepagentVolume *vol =3D g_rep=
_agent.volumes[i];</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 if (vol=
 !=3D NULL) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 =
assert(</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0 strcmp(drive_path, vol-&gt;vol_path) !=3D 0</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 &amp;&amp; driver_ptr !=3D vol-&gt;driver_ptr);</p><p class=3D"MsoNo=
rmal">+=A0=A0=A0=A0=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0 }</p><p=
 class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 assert(g_rep_ag=
ent.num_volumes &lt; REPAGENT_MAX_NUM_VOLUMES);</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 printf(&quot;=
zerto repagent: Registering drive. Num drives %d, path %s\n&quot;,</p><p cl=
ass=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 g_rep_agent.num_volume=
s, drive_path);</p><p class=3D"MsoNormal">
+=A0=A0=A0 g_rep_agent.volumes[i] =3D</p><p class=3D"MsoNormal">+=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0 (RepagentVolume *)g_malloc(sizeof(RepagentVolume))=
;</p><p class=3D"MsoNormal">+=A0=A0=A0 g_rep_agent.volumes[i]-&gt;driver_pt=
r =3D driver_ptr;</p><p class=3D"MsoNormal">
+=A0=A0=A0 /* orim todo strcpy? */</p><p class=3D"MsoNormal">+=A0=A0=A0 g_r=
ep_agent.volumes[i]-&gt;vol_path =3D drive_path;</p><p class=3D"MsoNormal">=
+</p><p class=3D"MsoNormal">+=A0=A0=A0 /* Orim todo thread-safety? */</p><p=
 class=3D"MsoNormal">+=A0=A0=A0 g_rep_agent.num_volumes++;</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 repagent_repo=
rt_volumes_to_hub();</p><p class=3D"MsoNormal">+}</p><p class=3D"MsoNormal"=
>+</p><p class=3D"MsoNormal">+/* orim todo destruction? */</p><p class=3D"M=
soNormal">+</p>
<p class=3D"MsoNormal">+static RepagentVolume *repagent_get_protected_volum=
e_by_driver(</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 BlockDriverSt=
ate *bs)</p><p class=3D"MsoNormal">+{</p><p class=3D"MsoNormal">+=A0=A0=A0 =
/* orim todo optimize search */</p>
<p class=3D"MsoNormal">+=A0=A0=A0 int i =3D 0;</p><p class=3D"MsoNormal">+=
=A0=A0=A0 for (i =3D 0; i &lt; g_rep_agent.num_volumes ; i++) {</p><p class=
=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 RepagentVolume *p_vol =3D g_rep_agent=
.volumes[i];</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0 if (p_vol !=3D NULL &amp;&amp; p_vol-&gt;driver_ptr =
=3D=3D (void *) bs) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0 return p_vol;</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 }<=
/p><p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0=
 return NULL;</p>
<p class=3D"MsoNormal">+}</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNor=
mal">+void repagent_handle_protected_write(BlockDriverState *bs, int64_t se=
ctor_num,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 int nb_sectors, =
QEMUIOVector *qiov, int ret_status)</p>
<p class=3D"MsoNormal">+{</p><p class=3D"MsoNormal">+=A0=A0=A0 printf(&quot=
;zerto Protected write offset %lld, size %d, IO return status %d&quot;,</p>=
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 (long long int) s=
ector_num, nb_sectors, ret_status);</p>
<p class=3D"MsoNormal">+=A0=A0=A0 if (bs-&gt;filename !=3D NULL) {</p><p cl=
ass=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 printf(&quot;, filename %s&quot;, =
bs-&gt;filename);</p><p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"Mso=
Normal">+</p><p class=3D"MsoNormal">
+=A0=A0=A0 printf(&quot;\n&quot;);</p><p class=3D"MsoNormal">+</p><p class=
=3D"MsoNormal">+=A0=A0=A0 RepagentVolume *p_vol =3D repagent_get_protected_=
volume_by_driver(bs);</p><p class=3D"MsoNormal">+=A0=A0=A0 if (p_vol =3D=3D=
 NULL || p_vol-&gt;vol_id =3D=3D REPAGENT_VOLUME_ID_NONE) {</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 /* Unprotected */</p><p class=
=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 printf(&quot;Got a write to an unprot=
ected volume.\n&quot;);</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 re=
turn;</p><p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+=A0=A0=A0 /* Report IO to rephub */</p><p clas=
s=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 int data_size =3D qi=
ov-&gt;size;</p><p class=3D"MsoNormal">+=A0=A0=A0 if (ret_status &lt; 0) {<=
/p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0 /* On failed ios we don&#39;t send the data to the h=
ub */</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 data_size =3D 0;</p>=
<p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0 ui=
nt8_t *pdata =3D NULL;</p><p class=3D"MsoNormal">
+=A0=A0=A0 RepCmdProtectedWrite *p_cmd =3D (RepCmdProtectedWrite *) repcmd_=
new(</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 REPHUB_CM=
D_PROTECTED_WRITE, data_size, (uint8_t **) &amp;pdata);</p><p class=3D"MsoN=
ormal">+</p><p class=3D"MsoNormal">
+=A0=A0=A0 if (ret_status &gt;=3D 0) {</p><p class=3D"MsoNormal">+=A0=A0=A0=
=A0=A0=A0 =A0qemu_iovec_to_buffer(qiov, pdata);</p><p class=3D"MsoNormal">+=
=A0=A0=A0 }</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=
=A0 p_cmd-&gt;volume_id =3D p_vol-&gt;vol_id;</p>
<p class=3D"MsoNormal">+=A0=A0=A0 p_cmd-&gt;offset_sectors =3D sector_num;<=
/p><p class=3D"MsoNormal">+=A0=A0=A0 p_cmd-&gt;size_sectors =3D nb_sectors;=
</p><p class=3D"MsoNormal">+=A0=A0=A0 p_cmd-&gt;ret_status =3D ret_status;<=
/p><p class=3D"MsoNormal">+</p>
<p class=3D"MsoNormal">+=A0=A0=A0 if (repagent_client_send((RepCmd *) p_cmd=
) !=3D 0) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 printf(&quot;E=
rror sending command\n&quot;);</p><p class=3D"MsoNormal">+=A0=A0=A0 }</p><p=
 class=3D"MsoNormal">+}</p><p class=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+static void repagent_report_volumes_to_hub(voi=
d)</p><p class=3D"MsoNormal">+{</p><p class=3D"MsoNormal">+=A0=A0=A0 /* Rep=
ort IO to rephub */</p><p class=3D"MsoNormal">+=A0=A0=A0 int i;</p><p class=
=3D"MsoNormal">+=A0=A0=A0 RepCmdDataReportVmVolumes *p_cmd_data =3D NULL;</=
p>
<p class=3D"MsoNormal">+=A0=A0=A0 RepCmdReportVmVolumes *p_cmd =3D (RepCmdR=
eportVmVolumes *) repcmd_new(</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0 REPHUB_CMD_REPORT_VM_VOLUMES,</p><p class=3D"MsoNormal">+=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 g_rep_agent.num_volumes * sizeof(RepVmVol=
umeInfo),</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 (uint8_t **) &amp=
;p_cmd_data);</p><p class=3D"MsoNormal">+=A0=A0=A0 p_cmd-&gt;num_volumes =
=3D g_rep_agent.num_volumes;</p><p class=3D"MsoNormal">+=A0=A0=A0 printf(&q=
uot;reporting %u volumes\n&quot;, g_rep_agent.num_volumes);</p>
<p class=3D"MsoNormal">+=A0=A0=A0 for (i =3D 0; i &lt; g_rep_agent.num_volu=
mes ; i++) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 assert(g_rep_=
agent.volumes[i] !=3D NULL);</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=
=A0 printf(&quot;reporting volume %s size %u\n&quot;,</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 g_rep=
_agent.volumes[i]-&gt;vol_path,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 (uint32_t) sizeof(p_cmd_data-&gt;volumes[i].=
name));</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 strncpy((char *) p=
_cmd_data-&gt;volumes[i].name,</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 g_rep=
_agent.volumes[i]-&gt;vol_path,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 sizeof(p_cmd_data-&gt;volumes[i].name));</p>=
<p class=3D"MsoNormal">+ =A0=A0=A0=A0=A0=A0=A0p_cmd_data-&gt;volumes[i].vol=
ume_id =3D g_rep_agent.volumes[i]-&gt;vol_id;</p>
<p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0 if=
 (repagent_client_send((RepCmd *) p_cmd) !=3D 0) {</p><p class=3D"MsoNormal=
">+=A0=A0=A0=A0=A0=A0=A0 printf(&quot;Error sending command\n&quot;);</p><p=
 class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">
+}</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+int repaget_start=
_protect(RepCmdStartProtect *pcmd,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0 RepCmdDataStartProtect *pcmd_data)</p><p class=3D"MsoNormal">+{</=
p><p class=3D"MsoNormal">
+=A0=A0=A0 printf(&quot;Start protect vol %s, ID %llu\n&quot;, pcmd_data-&g=
t;volume_name,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
 (unsigned long long) pcmd-&gt;volume_id);</p><p class=3D"MsoNormal">+=A0=
=A0=A0 int vol_index =3D repagent_get_volume_by_name(pcmd_data-&gt;volume_n=
ame);</p>
<p class=3D"MsoNormal">+=A0=A0=A0 if (vol_index &lt; 0) {</p><p class=3D"Ms=
oNormal">+=A0=A0=A0=A0=A0=A0=A0 printf(&quot;The volume doesn&#39;t exist\n=
&quot;);</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 return TRUE;</p><=
p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">
+=A0=A0=A0 /* orim todo protect */</p><p class=3D"MsoNormal">+=A0=A0=A0 g_r=
ep_agent.volumes[vol_index]-&gt;vol_id =3D pcmd-&gt;volume_id;</p><p class=
=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 return TRUE;</p><p cl=
ass=3D"MsoNormal">+}</p><p class=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+static int repagent_get_volume_by_name(const c=
har *name)</p><p class=3D"MsoNormal">+{</p><p class=3D"MsoNormal">+=A0=A0=
=A0 int i =3D 0;</p><p class=3D"MsoNormal">+=A0=A0=A0 for (i =3D 0; i &lt; =
g_rep_agent.num_volumes ; i++) {</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 if (g_rep_agent.volumes[i] !=
=3D NULL</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 &amp;&amp; strcmp(name, g_rep_agent.volumes[i]-&gt;vol_path) =3D=3D =
0) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 return i;=
</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 }</p><p class=3D"MsoNormal">+=
=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0 return -1;</p><p class=3D"=
MsoNormal">+}</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+static=
 int repagent_get_volume_by_id(uint64_t vol_id)</p>
<p class=3D"MsoNormal">+{</p><p class=3D"MsoNormal">+=A0=A0=A0 int i =3D 0;=
</p><p class=3D"MsoNormal">+=A0=A0=A0 for (i =3D 0; i &lt; g_rep_agent.num_=
volumes ; i++) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 if (g_rep=
_agent.volumes[i] !=3D NULL</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 &amp;&amp; g_rep_agent.volum=
es[i]-&gt;vol_id =3D=3D vol_id) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0 return i;</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=
=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+=
=A0=A0=A0 return -1;</p>
<p class=3D"MsoNormal">+}</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNor=
mal">+int repaget_read_vol(RepCmdReadVolReq *pcmd, uint8_t *pdata)</p><p cl=
ass=3D"MsoNormal">+{</p><p class=3D"MsoNormal">+=A0=A0=A0 int index =3D rep=
agent_get_volume_by_id(pcmd-&gt;volume_id);</p>
<p class=3D"MsoNormal">+=A0=A0=A0 int size_bytes =3D pcmd-&gt;size_sectors =
* 512;</p><p class=3D"MsoNormal">+=A0=A0=A0 if (index &lt; 0) {</p><p class=
=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 printf(&quot;Vol read - Could not fin=
d vol id %llu\n&quot;,</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 (unsigned long long int) pcm=
d-&gt;volume_id);</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 RepCmdRe=
adVolRes *p_res_cmd =3D (RepCmdReadVolRes *) repcmd_new(</p><p class=3D"Mso=
Normal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 REPHUB_CMD_READ_VOL_=
RES, 0, NULL);</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 p_res_cmd-&gt;req_id =3D pcmd=
-&gt;req_id;</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 p_res_cmd-&gt=
;volume_id =3D pcmd-&gt;volume_id;</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0 p_res_cmd-&gt;is_status_success =3D FALSE;</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 repagent_client_send((RepCmd =
*) p_res_cmd);</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 return TRUE=
;</p><p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+</p><p =
class=3D"MsoNormal">+=A0=A0=A0 printf(&quot;Vol read - driver %p, volId %ll=
u, offset %llu, size %u\n&quot;,</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 g_rep_agent.volum=
es[index]-&gt;driver_ptr,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0 (unsigned long long int) pcmd-&gt;volume_id,</p><p class=3D"Ms=
oNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 (unsigned long long int) pcmd-&=
gt;offset_sectors, pcmd-&gt;size_sectors);</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 {</p><p class=
=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 RepagentReadVolIo *read_xact =3D call=
oc(1, sizeof(RepagentReadVolIo));</p><p class=3D"MsoNormal">+</p><p class=
=3D"MsoNormal">+/*=A0=A0=A0=A0=A0=A0=A0 BlockDriverAIOCB *acb; */</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 Z=
ERO_MEM_OBJ(read_xact);</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNorma=
l">+=A0=A0=A0=A0=A0=A0=A0 qemu_iovec_init(&amp;read_xact-&gt;qiov, 1);</p><=
p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0 /*read_xact-&gt;buf =3D</p><p class=3D"MsoNormal">+=
=A0=A0=A0=A0=A0=A0=A0 qemu_blockalign(g_rep_agent.volumes[index]-&gt;driver=
_ptr, size_bytes); */</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 read=
_xact-&gt;buf =3D (uint8_t *) g_malloc(size_bytes);</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 read_xact-&gt;rep_cmd =3D *pc=
md;</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 qemu_iovec_add(&amp;re=
ad_xact-&gt;qiov, read_xact-&gt;buf, size_bytes);</p><p class=3D"MsoNormal"=
>+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 gettimeofday(&amp;read_=
xact-&gt;start_time, NULL);</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 /* orim TODO - use the return=
ed acb to cancel the request on shutdown */</p><p class=3D"MsoNormal">+=A0=
=A0=A0=A0=A0=A0=A0 /*acb =3D */bdrv_aio_readv(g_rep_agent.volumes[index]-&g=
t;driver_ptr,</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 read_xact-&gt;rep_cmd.offset=
_sectors, &amp;read_xact-&gt;qiov,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0 =
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0read_xact-&gt;rep_cmd.size_sectors, repage=
nt_vol_read_done,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0 read_xact);</p>
<p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+</p><p class=
=3D"MsoNormal">+=A0=A0=A0 return TRUE;</p><p class=3D"MsoNormal">+}</p><p c=
lass=3D"MsoNormal">+</p><p class=3D"MsoNormal">+static void repagent_vol_re=
ad_done(void *opaque, int ret)</p>
<p class=3D"MsoNormal">+{</p><p class=3D"MsoNormal">+=A0=A0=A0 struct timev=
al t2;</p><p class=3D"MsoNormal">+=A0=A0=A0 RepagentReadVolIo *read_xact =
=3D (RepagentReadVolIo *) opaque;</p><p class=3D"MsoNormal">+=A0=A0=A0 uint=
8_t *pdata =3D NULL;</p><p class=3D"MsoNormal">
+=A0=A0=A0 RepCmdReadVolRes *pcmd =3D (RepCmdReadVolRes *) repcmd_new(</p><=
p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 REPHUB_CMD_READ_VO=
L_RES, read_xact-&gt;rep_cmd.size_sectors * 512,</p><p class=3D"MsoNormal">=
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 &amp;pdata);</p><p class=3D"MsoNormal">
+=A0=A0=A0 pcmd-&gt;req_id =3D read_xact-&gt;rep_cmd.req_id;</p><p class=3D=
"MsoNormal">+=A0=A0=A0 pcmd-&gt;volume_id =3D read_xact-&gt;rep_cmd.volume_=
id;</p><p class=3D"MsoNormal">+=A0=A0=A0 pcmd-&gt;is_status_success =3D FAL=
SE;</p><p class=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+=A0=A0=A0 printf(&quot;Protected vol read - vo=
lId %llu, offset %llu, size %u\n&quot;,</p><p class=3D"MsoNormal">+=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0 (unsigned long long int) read_xact-&gt;rep_cmd.=
volume_id,</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 (unsigned long long int) read_xact-&gt;r=
ep_cmd.offset_sectors,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0 read_xact-&gt;rep_cmd.size_sectors);</p><p class=3D"MsoNormal">+=
=A0=A0=A0 gettimeofday(&amp;t2, NULL);</p><p class=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+=A0=A0=A0 if (ret &gt;=3D 0) {</p><p class=3D"=
MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 /* Read response - send the data to the h=
ub */</p><p class=3D"MsoNormal">+=A0=A0 =A0=A0=A0=A0=A0t2 =3D tsub(t2, read=
_xact-&gt;start_time);</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0 printf(&quot;Read prot vol done. Took %u seconds, %u=
 us.&quot;,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0 (uint32_t) t2.tv_sec, (uint32_t) t2.tv_usec);</p><p class=3D"MsoN=
ormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 pcmd-&gt;is_statu=
s_success =3D TRUE;</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 /* orim todo optimize - don&#=
39;t copy, use the qiov buffer */</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0 qemu_iovec_to_buffer(&amp;read_xact-&gt;qiov, pdata);</p><p class=
=3D"MsoNormal">+=A0=A0=A0 } else {</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 printf(&quot;readv failed: %s=
\n&quot;, strerror(-ret));</p><p class=3D"MsoNormal">+=A0=A0=A0 }</p><p cla=
ss=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 repagent_client_sen=
d((RepCmd *) pcmd);</p><p class=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+=A0=A0=A0 /*qemu_vfree(read_xact-&gt;buf); */<=
/p><p class=3D"MsoNormal">+=A0=A0=A0 g_free(read_xact-&gt;buf);</p><p class=
=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 g_free(read_xact);</p=
><p class=3D"MsoNormal">
+}</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+static struct tim=
eval tsub(struct timeval t1, struct timeval t2)</p><p class=3D"MsoNormal">+=
{</p><p class=3D"MsoNormal">+=A0=A0=A0 t1.tv_usec -=3D t2.tv_usec;</p><p cl=
ass=3D"MsoNormal">
+=A0=A0=A0 if (t1.tv_usec &lt; 0) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0 t1.tv_usec +=3D 1000000;</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0 t1.tv_sec--;</p><p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=
=3D"MsoNormal">+=A0=A0=A0 t1.tv_sec -=3D t2.tv_sec;</p><p class=3D"MsoNorma=
l">
+=A0=A0=A0 return t1;</p><p class=3D"MsoNormal">+}</p><p class=3D"MsoNormal=
">+</p><p class=3D"MsoNormal">+void repagent_client_connected(void)</p><p c=
lass=3D"MsoNormal">+{</p><p class=3D"MsoNormal">+=A0=A0=A0 /* orim todo thr=
ead protection */</p>
<p class=3D"MsoNormal">+=A0=A0=A0 repagent_report_volumes_to_hub();</p><p c=
lass=3D"MsoNormal">+}</p><p class=3D"MsoNormal">diff --git a/replication/re=
pagent.h b/replication/repagent.h</p><p class=3D"MsoNormal">new file mode 1=
00644</p><p class=3D"MsoNormal">
index 0000000..98ccbf2</p><p class=3D"MsoNormal">--- /dev/null</p><p class=
=3D"MsoNormal">+++ b/replication/repagent.h</p><p class=3D"MsoNormal">@@ -0=
,0 +1,46 @@</p><p class=3D"MsoNormal">+/*</p><p class=3D"MsoNormal">+ * QEM=
U System Emulator</p>
<p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * Copyright (c) 2003=
-2008 Fabrice Bellard</p><p class=3D"MsoNormal">+ *</p><p class=3D"MsoNorma=
l">+ * Permission is hereby granted, free of charge, to any person obtainin=
g a copy</p>
<p class=3D"MsoNormal">+ * of this software and associated documentation fi=
les (the &quot;Software&quot;), to deal</p><p class=3D"MsoNormal">+ * in th=
e Software without restriction, including without limitation the rights</p>
<p class=3D"MsoNormal">+ * to use, copy, modify, merge, publish, distribute=
, sublicense, and/or sell</p><p class=3D"MsoNormal">+ * copies of the Softw=
are, and to permit persons to whom the Software is</p><p class=3D"MsoNormal=
">
+ * furnished to do so, subject to the following conditions:</p><p class=3D=
"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * The above copyright notice an=
d this permission notice shall be included in</p><p class=3D"MsoNormal">+ *=
 all copies or substantial portions of the Software.</p>
<p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * THE SOFTWARE IS PR=
OVIDED &quot;AS IS&quot;, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR</p><p cl=
ass=3D"MsoNormal">+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES =
OF MERCHANTABILITY,</p>
<p class=3D"MsoNormal">+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGE=
MENT. IN NO EVENT SHALL</p><p class=3D"MsoNormal">+ * THE AUTHORS OR COPYRI=
GHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER</p><p class=3D"MsoNor=
mal">
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING=
 FROM,</p><p class=3D"MsoNormal">+ * OUT OF OR IN CONNECTION WITH THE SOFTW=
ARE OR THE USE OR OTHER DEALINGS IN</p><p class=3D"MsoNormal">+ * THE SOFTW=
ARE.</p>
<p class=3D"MsoNormal">+ */</p><p class=3D"MsoNormal">+#ifndef REPAGENT_H</=
p><p class=3D"MsoNormal">+#define REPAGENT_H</p><p class=3D"MsoNormal">+#in=
clude &lt;stdint.h&gt;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal=
">+#include &quot;qemu-common.h&quot;</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+typedef struct RepAgent=
State RepAgentState;</p><p class=3D"MsoNormal">+typedef struct RepCmdStartP=
rotect RepCmdStartProtect;</p><p class=3D"MsoNormal">+typedef struct RepCmd=
DataStartProtect RepCmdDataStartProtect;</p>
<p class=3D"MsoNormal">+struct RepCmdReadVolReq;</p><p class=3D"MsoNormal">=
+</p><p class=3D"MsoNormal">+void repagent_init(const char *hubname, int po=
rt);</p><p class=3D"MsoNormal">+void repagent_handle_protected_write(BlockD=
riverState *bs,</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 int64_t sector_num, int nb_se=
ctors, QEMUIOVector *qiov, int ret_status);</p><p class=3D"MsoNormal">+void=
 repagent_register_drive(const char *drive_path,</p><p class=3D"MsoNormal">=
+=A0=A0=A0=A0=A0=A0=A0 BlockDriverState *driver_ptr);</p>
<p class=3D"MsoNormal">+int repaget_start_protect(RepCmdStartProtect *pcmd,=
</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 RepCmdDataStartProtect *p=
cmd_data);</p><p class=3D"MsoNormal">+int repaget_read_vol(struct RepCmdRea=
dVolReq *pcmd, uint8_t *pdata);</p>
<p class=3D"MsoNormal">+void repagent_client_connected(void);</p><p class=
=3D"MsoNormal">+</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+#en=
dif /* REPAGENT_H */</p><p class=3D"MsoNormal">diff --git a/replication/rep=
agent_client.c b/replication/repagent_client.c</p>
<p class=3D"MsoNormal">new file mode 100644</p><p class=3D"MsoNormal">index=
 0000000..4dd9ea4</p><p class=3D"MsoNormal">--- /dev/null</p><p class=3D"Ms=
oNormal">+++ b/replication/repagent_client.c</p><p class=3D"MsoNormal">@@ -=
0,0 +1,138 @@</p>
<p class=3D"MsoNormal">+#include &quot;repcmd.h&quot;</p><p class=3D"MsoNor=
mal">+#include &quot;rephub_cmds.h&quot;</p><p class=3D"MsoNormal">+#includ=
e &quot;repcmd_listener.h&quot;</p><p class=3D"MsoNormal">+#include &quot;r=
epagent_client.h&quot;</p>
<p class=3D"MsoNormal">+#include &quot;repagent.h&quot;</p><p class=3D"MsoN=
ormal">+</p><p class=3D"MsoNormal">+#include &lt;string.h&gt;</p><p class=
=3D"MsoNormal">+#include &lt;stdlib.h&gt;</p><p class=3D"MsoNormal">+#inclu=
de &lt;errno.h&gt;</p>
<p class=3D"MsoNormal">+#include &lt;stdio.h&gt;</p><p class=3D"MsoNormal">=
+#include &lt;resolv.h&gt;</p><p class=3D"MsoNormal">+#include &lt;sys/sock=
et.h&gt;</p><p class=3D"MsoNormal">+#include &lt;arpa/inet.h&gt;</p><p clas=
s=3D"MsoNormal">
+#include &lt;netinet/in.h&gt;</p><p class=3D"MsoNormal">+#include &lt;unis=
td.h&gt;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+#define ZER=
O_MEM_OBJ(pObj) memset(pObj, 0, sizeof(*pObj))</p><p class=3D"MsoNormal">+<=
/p><p class=3D"MsoNormal">
+static void repagent_process_cmd(RepCmd *pCmd, uint8_t *pData, void *clien=
tPtr);</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+typedef struc=
t repagent_client_state {</p><p class=3D"MsoNormal">+=A0=A0=A0 int is_conne=
cted;</p>
<p class=3D"MsoNormal">+=A0=A0=A0 int is_terminate_receive;</p><p class=3D"=
MsoNormal">+=A0=A0=A0 int hsock;</p><p class=3D"MsoNormal">+} repagent_clie=
nt_state;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+static rep=
agent_client_state g_client_state =3D { 0 };</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+void *repagent_listen(v=
oid *pParam)</p><p class=3D"MsoNormal">+{</p><p class=3D"MsoNormal">+=A0=A0=
=A0 rephub_params *pServerParams =3D (rephub_params *) pParam;</p><p class=
=3D"MsoNormal">
+=A0=A0=A0 int host_port =3D pServerParams-&gt;port;</p><p class=3D"MsoNorm=
al">+=A0=A0=A0 const char *host_name =3D pServerParams-&gt;name;</p><p clas=
s=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 printf(&quot;Creatin=
g repagent listener thread...\n&quot;);</p>
<p class=3D"MsoNormal">+=A0=A0=A0 g_free(pServerParams);</p><p class=3D"Mso=
Normal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 struct sockaddr_in my_addr;<=
/p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 int err;</=
p><p class=3D"MsoNormal">+=A0=A0=A0 int retries =3D 0;</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0 =A0g_client_stat=
e.hsock =3D socket(AF_INET, SOCK_STREAM, 0);</p><p class=3D"MsoNormal">+=A0=
=A0=A0 if (g_client_state.hsock =3D=3D -1) {</p><p class=3D"MsoNormal">+=A0=
=A0=A0=A0=A0=A0=A0 printf(&quot;Error initializing socket %d\n&quot;, errno=
);</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 return (void *) -1;</p><p cla=
ss=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+</p><p class=3D"Ms=
oNormal">+=A0=A0=A0 int param =3D 1;</p><p class=3D"MsoNormal">+</p><p clas=
s=3D"MsoNormal">+=A0=A0=A0 if ((setsockopt(g_client_state.hsock, SOL_SOCKET=
, SO_REUSEADDR,</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 (char *) &amp;par=
am, sizeof(int)) =3D=3D -1)</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0 || (setsockopt(g_client_state.hsock, SOL_SOCKET, SO_KEEPALI=
VE,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0 (char *) &amp;param, sizeof(int)) =3D=3D -1)) {</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 printf(&quot;Error setting op=
tions %d\n&quot;, errno);</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 =
return (void *) -1;</p><p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"M=
soNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 my_addr.sin_family =3D AF_=
INET;</p>
<p class=3D"MsoNormal">+=A0=A0=A0 my_addr.sin_port =3D htons(host_port);</p=
><p class=3D"MsoNormal">+=A0=A0=A0 memset(&amp;(my_addr.sin_zero), 0, 8);</=
p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 my_addr.sin=
_addr.s_addr =3D inet_addr(host_name);</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 /* Reconnect =
loop */</p><p class=3D"MsoNormal">+=A0=A0=A0 while (!g_client_state.is_term=
inate_receive) {</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=
=A0=A0=A0=A0=A0=A0 if (connect(g_client_state.hsock, (struct sockaddr *) &a=
mp;my_addr,</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 sizeo=
f(my_addr)) =3D=3D -1) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0 err =3D errno;</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0 if (err !=3D EINPROGRESS) {</p><p class=3D"MsoNormal">+=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 retries++;</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 fprin=
tf(</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0 stderr,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 &quot;Error conne=
cting socket %d. Host %s, port %u. Retry count %d\n&quot;,</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0 errno, host_name, host_port, retries);</p><p class=3D"Ms=
oNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 usleep(5 * 1000 * 1=
000);</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0 continue;</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0=
=A0=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 retries =3D=
 0;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=
=A0=A0 g_client_state.is_connected =3D 1;</p><p class=3D"MsoNormal">+</p><p=
 class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0 repagent_client_connected();</p><p class=3D"MsoNorma=
l">+=A0=A0=A0=A0=A0=A0=A0 repcmd_listener(g_client_state.hsock, repagent_pr=
ocess_cmd, NULL);</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 close(g_=
client_state.hsock);</p><p class=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 g_client_state.is_connec=
ted =3D 0;</p><p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal"=
>+=A0=A0=A0 return 0;</p><p class=3D"MsoNormal">+}</p><p class=3D"MsoNormal=
">+</p><p class=3D"MsoNormal">+void repagent_process_cmd(RepCmd *pcmd, uint=
8_t *pdata, void *clientPtr)</p>
<p class=3D"MsoNormal">+{</p><p class=3D"MsoNormal">+=A0=A0=A0 int is_free_=
data =3D 1;</p><p class=3D"MsoNormal">+=A0=A0=A0 printf(&quot;Repagent got =
cmd %d\n&quot;, pcmd-&gt;hdr.cmdid);</p><p class=3D"MsoNormal">+=A0=A0=A0 s=
witch (pcmd-&gt;hdr.cmdid) {</p>
<p class=3D"MsoNormal">+=A0=A0=A0 case REPHUB_CMD_START_PROTECT: {</p><p cl=
ass=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 is_free_data =3D repaget_start_pro=
tect((RepCmdStartProtect *) pcmd,</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 (RepCmdDataStartProtect *) pdata);</p>
<p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0 break;</p><p class=3D"MsoNormal">+=A0=A0=A0 case REPHUB_CMD_READ_=
VOL_REQ: {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 is_free_data =
=3D repaget_read_vol((RepCmdReadVolReq *) pcmd, pdata);</p>
<p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0 break;</p><p class=3D"MsoNormal">+=A0=A0=A0 default:</p><p class=
=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 assert(0);</p><p class=3D"MsoNormal">=
+=A0=A0=A0=A0=A0=A0=A0 break;</p><p class=3D"MsoNormal">+</p><p class=3D"Ms=
oNormal">
+=A0=A0=A0 }</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=
=A0 if (is_free_data) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 g_=
free(pdata);</p><p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNorma=
l">+}</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">
+int repagent_client_send(RepCmd *p_cmd)</p><p class=3D"MsoNormal">+{</p><p=
 class=3D"MsoNormal">+=A0=A0=A0 int bytecount =3D 0;</p><p class=3D"MsoNorm=
al">+=A0=A0=A0 printf(&quot;Send cmd %u, data size %u\n&quot;, p_cmd-&gt;hd=
r.cmdid,</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 p_cmd-&gt;hdr.data_size_bytes);</p><p cl=
ass=3D"MsoNormal">+=A0=A0=A0 if (!g_client_state.is_connected) {</p><p clas=
s=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 printf(&quot;Not connected to hub\n&=
quot;);</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 return -1;</p>
<p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+</p><p class=
=3D"MsoNormal">+=A0=A0=A0 bytecount =3D send(g_client_state.hsock, p_cmd,</=
p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 sizeof(RepCmd) =
+ p_cmd-&gt;hdr.data_size_bytes, 0);</p>
<p class=3D"MsoNormal">+=A0=A0=A0 if (bytecount &lt; sizeof(RepCmd) + p_cmd=
-&gt;hdr.data_size_bytes) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=
=A0 printf(&quot;Bad send %d, errno %d\n&quot;, bytecount, errno);</p><p cl=
ass=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 return bytecount;</p>
<p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+</p><p class=
=3D"MsoNormal">+=A0=A0=A0 /* Success */</p><p class=3D"MsoNormal">+=A0=A0=
=A0 return 0;</p><p class=3D"MsoNormal">+}</p><p class=3D"MsoNormal">diff -=
-git a/replication/repagent_client.h b/replication/repagent_client.h</p>
<p class=3D"MsoNormal">new file mode 100644</p><p class=3D"MsoNormal">index=
 0000000..62a5377</p><p class=3D"MsoNormal">--- /dev/null</p><p class=3D"Ms=
oNormal">+++ b/replication/repagent_client.h</p><p class=3D"MsoNormal">@@ -=
0,0 +1,36 @@</p>
<p class=3D"MsoNormal">+/*</p><p class=3D"MsoNormal">+ * QEMU System Emulat=
or</p><p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * Copyright (c=
) 2003-2008 Fabrice Bellard</p><p class=3D"MsoNormal">+ *</p><p class=3D"Ms=
oNormal">
+ * Permission is hereby granted, free of charge, to any person obtaining a=
 copy</p><p class=3D"MsoNormal">+ * of this software and associated documen=
tation files (the &quot;Software&quot;), to deal</p><p class=3D"MsoNormal">
+ * in the Software without restriction, including without limitation the r=
ights</p><p class=3D"MsoNormal">+ * to use, copy, modify, merge, publish, d=
istribute, sublicense, and/or sell</p><p class=3D"MsoNormal">+ * copies of =
the Software, and to permit persons to whom the Software is</p>
<p class=3D"MsoNormal">+ * furnished to do so, subject to the following con=
ditions:</p><p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * The ab=
ove copyright notice and this permission notice shall be included in</p><p =
class=3D"MsoNormal">
+ * all copies or substantial portions of the Software.</p><p class=3D"MsoN=
ormal">+ *</p><p class=3D"MsoNormal">+ * THE SOFTWARE IS PROVIDED &quot;AS =
IS&quot;, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR</p><p class=3D"MsoNormal=
">
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY=
,</p><p class=3D"MsoNormal">+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINF=
RINGEMENT. IN NO EVENT SHALL</p><p class=3D"MsoNormal">+ * THE AUTHORS OR C=
OPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER</p>
<p class=3D"MsoNormal">+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TOR=
T OR OTHERWISE, ARISING FROM,</p><p class=3D"MsoNormal">+ * OUT OF OR IN CO=
NNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN</p><p class=3D"M=
soNormal">
+ * THE SOFTWARE.</p><p class=3D"MsoNormal">+ */</p><p class=3D"MsoNormal">=
+#ifndef REPAGENT_CLIENT_H</p><p class=3D"MsoNormal">+#define REPAGENT_CLIE=
NT_H</p><p class=3D"MsoNormal">+#include &quot;repcmd.h&quot;</p><p class=
=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+typedef struct rephub_params {</p><p class=3D"=
MsoNormal">+=A0=A0=A0 char *name;</p><p class=3D"MsoNormal">+=A0=A0=A0 int =
port;</p><p class=3D"MsoNormal">+} rephub_params;</p><p class=3D"MsoNormal"=
>+</p><p class=3D"MsoNormal">
+void *repagent_listen(void *pParam);</p><p class=3D"MsoNormal">+int repage=
nt_client_send(RepCmd *p_cmd);</p><p class=3D"MsoNormal">+</p><p class=3D"M=
soNormal">+#endif /* REPAGENT_CLIENT_H */</p><p class=3D"MsoNormal">diff --=
git a/replication/repcmd.h b/replication/repcmd.h</p>
<p class=3D"MsoNormal">new file mode 100644</p><p class=3D"MsoNormal">index=
 0000000..8c6cf1b</p><p class=3D"MsoNormal">--- /dev/null</p><p class=3D"Ms=
oNormal">+++ b/replication/repcmd.h</p><p class=3D"MsoNormal">@@ -0,0 +1,59=
 @@</p>
<p class=3D"MsoNormal">+/*</p><p class=3D"MsoNormal">+ * QEMU System Emulat=
or</p><p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * Copyright (c=
) 2003-2008 Fabrice Bellard</p><p class=3D"MsoNormal">+ *</p><p class=3D"Ms=
oNormal">
+ * Permission is hereby granted, free of charge, to any person obtaining a=
 copy</p><p class=3D"MsoNormal">+ * of this software and associated documen=
tation files (the &quot;Software&quot;), to deal</p><p class=3D"MsoNormal">
+ * in the Software without restriction, including without limitation the r=
ights</p><p class=3D"MsoNormal">+ * to use, copy, modify, merge, publish, d=
istribute, sublicense, and/or sell</p><p class=3D"MsoNormal">+ * copies of =
the Software, and to permit persons to whom the Software is</p>
<p class=3D"MsoNormal">+ * furnished to do so, subject to the following con=
ditions:</p><p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * The ab=
ove copyright notice and this permission notice shall be included in</p><p =
class=3D"MsoNormal">
+ * all copies or substantial portions of the Software.</p><p class=3D"MsoN=
ormal">+ *</p><p class=3D"MsoNormal">+ * THE SOFTWARE IS PROVIDED &quot;AS =
IS&quot;, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR</p><p class=3D"MsoNormal=
">
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY=
,</p><p class=3D"MsoNormal">+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINF=
RINGEMENT. IN NO EVENT SHALL</p><p class=3D"MsoNormal">+ * THE AUTHORS OR C=
OPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER</p>
<p class=3D"MsoNormal">+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TOR=
T OR OTHERWISE, ARISING FROM,</p><p class=3D"MsoNormal">+ * OUT OF OR IN CO=
NNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN</p><p class=3D"M=
soNormal">
+ * THE SOFTWARE.</p><p class=3D"MsoNormal">+ */</p><p class=3D"MsoNormal">=
+#ifndef REPCMD_H</p><p class=3D"MsoNormal">+#define REPCMD_H</p><p class=
=3D"MsoNormal">+</p><p class=3D"MsoNormal">+#include &lt;stdint.h&gt;</p><p=
 class=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+#define REPCMD_MAGIC1 (0x1122)</p><p class=3D"=
MsoNormal">+#define REPCMD_MAGIC2 (0x3344)</p><p class=3D"MsoNormal">+#defi=
ne REPCMD_NUM_U32_PARAMS (11)</p><p class=3D"MsoNormal">+</p><p class=3D"Ms=
oNormal">
+enum RepCmds {</p><p class=3D"MsoNormal">+=A0=A0=A0 REPCMD_FIRST_INVALID=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 =3D 0,</p><p clas=
s=3D"MsoNormal">+=A0=A0=A0 REPCMD_FIRST_HUBCMD=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 =3D 1,</p><p class=3D"MsoNormal">+=A0=A0=
=A0 REPHUB_CMD_PROTECTED_WRITE=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 =3D 2=
,</p>
<p class=3D"MsoNormal">+=A0=A0=A0 REPHUB_CMD_REPORT_VM_VOLUMES=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0 =3D 3,</p><p class=3D"MsoNormal">+=A0=A0=A0 REPHUB_CM=
D_START_PROTECT=A0=A0 =A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=3D 4,</p><p c=
lass=3D"MsoNormal">+=A0=A0=A0 REPHUB_CMD_READ_VOL_REQ=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0 =3D 5,</p>
<p class=3D"MsoNormal">+=A0=A0=A0 REPHUB_CMD_READ_VOL_RES=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 =3D 6,</p><p class=3D"MsoNormal">+=A0=A0=A0 =
REPHUB_CMD_AGENT_SHUTDOWN=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 =3D 7,<=
/p><p class=3D"MsoNormal">+};</p><p class=3D"MsoNormal">+</p><p class=3D"Ms=
oNormal">
+typedef struct RepCmdHdr {</p><p class=3D"MsoNormal">+=A0=A0=A0 uint16_t m=
agic1;</p><p class=3D"MsoNormal">+=A0=A0=A0 uint16_t cmdid;</p><p class=3D"=
MsoNormal">+=A0=A0=A0 uint32_t data_size_bytes;</p><p class=3D"MsoNormal">+=
} RepCmdHdr;</p><p class=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+typedef struct RepCmd {</p><p class=3D"MsoNorm=
al">+=A0=A0=A0 RepCmdHdr hdr;</p><p class=3D"MsoNormal">+=A0=A0=A0 unsigned=
 int parameters[REPCMD_NUM_U32_PARAMS];</p><p class=3D"MsoNormal">+=A0=A0=
=A0 unsigned int magic2;</p>
<p class=3D"MsoNormal">+=A0=A0=A0 uint8_t data[0];</p><p class=3D"MsoNormal=
">+} RepCmd;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+RepCmd =
*repcmd_new(int cmd_id, int data_size, uint8_t **p_out_pdata);</p><p class=
=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+#endif /* REPCMD_H */</p><p class=3D"MsoNormal=
">diff --git a/replication/repcmd_listener.c b/replication/repcmd_listener.=
c</p><p class=3D"MsoNormal">new file mode 100644</p><p class=3D"MsoNormal">=
index 0000000..a211927</p>
<p class=3D"MsoNormal">--- /dev/null</p><p class=3D"MsoNormal">+++ b/replic=
ation/repcmd_listener.c</p><p class=3D"MsoNormal">@@ -0,0 +1,137 @@</p><p c=
lass=3D"MsoNormal">+#include &lt;fcntl.h&gt;</p><p class=3D"MsoNormal">+#in=
clude &lt;string.h&gt;</p>
<p class=3D"MsoNormal">+#include &lt;stdlib.h&gt;</p><p class=3D"MsoNormal"=
>+#include &lt;errno.h&gt;</p><p class=3D"MsoNormal">+#include &lt;stdio.h&=
gt;</p><p class=3D"MsoNormal">+#include &lt;netinet/in.h&gt;</p><p class=3D=
"MsoNormal">
+#include &lt;resolv.h&gt;</p><p class=3D"MsoNormal">+#include &lt;sys/sock=
et.h&gt;</p><p class=3D"MsoNormal">+#include &lt;arpa/inet.h&gt;</p><p clas=
s=3D"MsoNormal">+#include &lt;unistd.h&gt;</p><p class=3D"MsoNormal">+#incl=
ude &lt;pthread.h&gt;</p>
<p class=3D"MsoNormal">+#include &lt;assert.h&gt;</p><p class=3D"MsoNormal"=
>+</p><p class=3D"MsoNormal">+/* Use the CONFIG_REPLICATION flag to determi=
ne whether</p><p class=3D"MsoNormal">+ * we&#39;re under qemu build or a hu=
b When under</p>
<p class=3D"MsoNormal">+ * qemu use g_malloc */</p><p class=3D"MsoNormal">+=
#ifdef CONFIG_REPLICATION</p><p class=3D"MsoNormal">+#include &lt;glib.h&gt=
;</p><p class=3D"MsoNormal">+#define REPCMD_MALLOC g_malloc</p><p class=3D"=
MsoNormal">
+#else</p><p class=3D"MsoNormal">+#define REPCMD_MALLOC malloc</p><p class=
=3D"MsoNormal">+#endif</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal=
">+#include &quot;repcmd.h&quot;</p><p class=3D"MsoNormal">+#include &quot;=
repcmd_listener.h&quot;</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+#define ZERO_MEM_OBJ(pO=
bj) memset((void *)pObj, 0, sizeof(*pObj))</p><p class=3D"MsoNormal">+</p><=
p class=3D"MsoNormal">+typedef struct RepCmdListenerState {</p><p class=3D"=
MsoNormal">
+=A0=A0=A0 int is_terminate_receive;</p><p class=3D"MsoNormal">+} RepCmdLis=
tenerState;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+static R=
epCmdListenerState g_listenerState =3D { 0 };</p><p class=3D"MsoNormal">+</=
p><p class=3D"MsoNormal">
+/* Returns 0 for initiated termination or socket error value on error */</=
p><p class=3D"MsoNormal">+int repcmd_listener(int hsock, pfn_received_cmd_c=
b callback, void *clientPtr)</p><p class=3D"MsoNormal">+{</p><p class=3D"Ms=
oNormal">
+=A0=A0=A0 RepCmd curCmd;</p><p class=3D"MsoNormal">+=A0=A0=A0 uint8_t *pRe=
adBuf =3D (uint8_t *) &amp;curCmd;</p><p class=3D"MsoNormal">+=A0=A0=A0 int=
 bytesToGet =3D sizeof(RepCmd);</p><p class=3D"MsoNormal">+=A0=A0=A0 int by=
tesGotten =3D 0;</p><p class=3D"MsoNormal">
+=A0=A0=A0 int isGotHeader =3D 0;</p><p class=3D"MsoNormal">+=A0=A0=A0 uint=
8_t *pdata =3D NULL;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">=
+=A0=A0=A0 assert(callback !=3D NULL);</p><p class=3D"MsoNormal">+</p><p cl=
ass=3D"MsoNormal">+=A0=A0=A0 /* receive loop */</p>
<p class=3D"MsoNormal">+=A0=A0=A0 while (!g_listenerState.is_terminate_rece=
ive) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 int bytecount;</p><=
p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 by=
tecount =3D recv(hsock, pReadBuf + bytesGotten,</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 bytes=
ToGet - bytesGotten, 0);</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 i=
f (bytecount =3D=3D -1) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0 fprintf(stderr, &quot;Error receiving data %d\n&quot;, errno);=
</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 return errno;</p>=
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 }</p><p class=3D"MsoNormal">+=
</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 if (bytecount =3D=3D 0) {=
</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 printf(&quot;=
Disconnected\n&quot;);</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 return 0;</p><p c=
lass=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=
=A0=A0=A0=A0=A0=A0 bytesGotten +=3D bytecount;</p><p class=3D"MsoNormal">+/=
*=A0=A0=A0=A0 printf(&quot;Recieved bytes %d, got %d/%d\n&quot;,</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 bytec=
ount, bytesGotten, bytesToGet); */</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0 /* print content */</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=
=A0 if (0) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 i=
nt i;</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 for (i =3D 0; i &lt; bytecount ; i +=3D =
4) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0 /*printf(&quot;%d/%d&quot;, i, bytecount/4); */</p><p class=3D"MsoNorma=
l">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 printf(&quot;%#x &quot;,<=
/p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 *(in=
t *) (&amp;pReadBuf[bytesGotten - bytecount + i]));</p><p class=3D"MsoNorma=
l">+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 }</p><p c=
lass=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 printf(&quot;\n&quot;=
);</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 a=
ssert(bytesGotten &lt;=3D bytesToGet);</p><p class=3D"MsoNormal">+=A0=A0=A0=
=A0=A0=A0=A0 if (bytesGotten =3D=3D bytesToGet) {</p><p class=3D"MsoNormal"=
>+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 int isGotData =3D 0;</p><p class=3D"Mso=
Normal">
+=A0=A0=A0=A0 =A0=A0=A0=A0=A0=A0=A0bytesGotten =3D 0;</p><p class=3D"MsoNor=
mal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 if (!isGotHeader) {</p><p class=3D"=
MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 /* We just got th=
e header */</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0 isGotHeader =3D 1;</p><p class=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 =
assert(curCmd.hdr.magic1 =3D=3D REPCMD_MAGIC1);</p><p class=3D"MsoNormal">+=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 assert(curCmd.magic2 =3D=3D R=
EPCMD_MAGIC2);</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0 if (curCmd.hdr.data_size_bytes &gt; 0) {</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 pdata =3D (uint8_t *)REPCMD_MALLOC(</p><p class=3D"MsoNormal">+=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0 curCmd.hdr.data_size_bytes);</p><p class=3D"MsoNormal">+/*=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 printf(&quot;mall=
oc %p\n&quot;, pdata); */</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 pReadBuf =3D pdata;</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0 } else {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 /* no data */</p><p class=3D"=
MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 isGot=
Data =3D 1;</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 pdata =3D NULL;</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0 bytesToGet =3D curCmd.hdr.data_size_bytes;</p><p clas=
s=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 } else {</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 =A0=A0=A0=A0isGot=
Data =3D 1;</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 }<=
/p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0 if (isGotData) {</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 /* Got command and data */</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 (*cal=
lback)(&amp;curCmd, pdata, clientPtr);</p><p class=3D"MsoNormal">+</p><p cl=
ass=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 /* It&#39;=
s the callee responsibility to free pData */</p><p class=3D"MsoNormal">
+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 pdata =3D NULL;</p><p class=
=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 ZERO_MEM_OBJ(=
&amp;curCmd);</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0 pReadBuf =3D (uint8_t *) &amp;curCmd;</p><p class=3D"MsoNormal=
">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 bytesGotten =3D 0;</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 bytes=
ToGet =3D sizeof(RepCmd);</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0 isGotHeader =3D 0;</p><p class=3D"MsoNormal">+=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=
 =A0=A0}</p><p class=3D"MsoNormal">
+=A0=A0=A0 }</p><p class=3D"MsoNormal">+=A0=A0=A0 return 0;</p><p class=3D"=
MsoNormal">+}</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+RepCmd=
 *repcmd_new(int cmd_id, int data_size, uint8_t **p_out_pdata)</p><p class=
=3D"MsoNormal">+{</p>
<p class=3D"MsoNormal">+=A0=A0=A0 RepCmd *p_cmd =3D (RepCmd *)REPCMD_MALLOC=
(sizeof(RepCmd) + data_size);</p><p class=3D"MsoNormal">+=A0=A0=A0 assert(p=
_cmd !=3D NULL);</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+=A0=
=A0=A0 /* Zero the CMD (not the data) */</p>
<p class=3D"MsoNormal">+=A0=A0=A0 ZERO_MEM_OBJ(p_cmd);</p><p class=3D"MsoNo=
rmal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 p_cmd-&gt;hdr.cmdid =3D cmd_id=
;</p><p class=3D"MsoNormal">+=A0=A0=A0 p_cmd-&gt;hdr.magic1 =3D REPCMD_MAGI=
C1;</p><p class=3D"MsoNormal">
+=A0=A0=A0 p_cmd-&gt;magic2 =3D REPCMD_MAGIC2;</p><p class=3D"MsoNormal">+=
=A0=A0=A0 p_cmd-&gt;hdr.data_size_bytes =3D data_size;</p><p class=3D"MsoNo=
rmal">+</p><p class=3D"MsoNormal">+=A0=A0=A0 if (p_out_pdata !=3D NULL) {</=
p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0 *p_out_pdata =3D p_cmd-&gt;=
data;</p>
<p class=3D"MsoNormal">+=A0=A0=A0 }</p><p class=3D"MsoNormal">+</p><p class=
=3D"MsoNormal">+=A0=A0=A0 return p_cmd;</p><p class=3D"MsoNormal">+}</p><p =
class=3D"MsoNormal">+</p><p class=3D"MsoNormal">diff --git a/replication/re=
pcmd_listener.h b/replication/repcmd_listener.h</p>
<p class=3D"MsoNormal">new file mode 100644</p><p class=3D"MsoNormal">index=
 0000000..c09a12e</p><p class=3D"MsoNormal">--- /dev/null</p><p class=3D"Ms=
oNormal">+++ b/replication/repcmd_listener.h</p><p class=3D"MsoNormal">@@ -=
0,0 +1,32 @@</p>
<p class=3D"MsoNormal">+/*</p><p class=3D"MsoNormal">+ * QEMU System Emulat=
or</p><p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * Copyright (c=
) 2003-2008 Fabrice Bellard</p><p class=3D"MsoNormal">+ *</p><p class=3D"Ms=
oNormal">
+ * Permission is hereby granted, free of charge, to any person obtaining a=
 copy</p><p class=3D"MsoNormal">+ * of this software and associated documen=
tation files (the &quot;Software&quot;), to deal</p><p class=3D"MsoNormal">
+ * in the Software without restriction, including without limitation the r=
ights</p><p class=3D"MsoNormal">+ * to use, copy, modify, merge, publish, d=
istribute, sublicense, and/or sell</p><p class=3D"MsoNormal">+ * copies of =
the Software, and to permit persons to whom the Software is</p>
<p class=3D"MsoNormal">+ * furnished to do so, subject to the following con=
ditions:</p><p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * The ab=
ove copyright notice and this permission notice shall be included in</p><p =
class=3D"MsoNormal">
+ * all copies or substantial portions of the Software.</p><p class=3D"MsoN=
ormal">+ *</p><p class=3D"MsoNormal">+ * THE SOFTWARE IS PROVIDED &quot;AS =
IS&quot;, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR</p><p class=3D"MsoNormal=
">
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY=
,</p><p class=3D"MsoNormal">+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINF=
RINGEMENT. IN NO EVENT SHALL</p><p class=3D"MsoNormal">+ * THE AUTHORS OR C=
OPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER</p>
<p class=3D"MsoNormal">+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TOR=
T OR OTHERWISE, ARISING FROM,</p><p class=3D"MsoNormal">+ * OUT OF OR IN CO=
NNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN</p><p class=3D"M=
soNormal">
+ * THE SOFTWARE.</p><p class=3D"MsoNormal">+ */</p><p class=3D"MsoNormal">=
+#ifndef REPCMD_LISTENER_H</p><p class=3D"MsoNormal">+#define REPCMD_LISTEN=
ER_H</p><p class=3D"MsoNormal">+#include &lt;stdint.h&gt;</p><p class=3D"Ms=
oNormal">
+typedef void (*pfn_received_cmd_cb)(RepCmd *pCmd,</p><p class=3D"MsoNormal=
">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 uint8_t *pData, void *clie=
ntPtr);</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+int repcmd_l=
istener(int hsock, pfn_received_cmd_cb callback, void *clientPtr);</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+#endif /* REPCMD_LISTEN=
ER_H */</p><p class=3D"MsoNormal">diff --git a/replication/rephub_cmds.h b/=
replication/rephub_cmds.h</p><p class=3D"MsoNormal">new file mode 100644</p=
><p class=3D"MsoNormal">
index 0000000..820c37d</p><p class=3D"MsoNormal">--- /dev/null</p><p class=
=3D"MsoNormal">+++ b/replication/rephub_cmds.h</p><p class=3D"MsoNormal">@@=
 -0,0 +1,150 @@</p><p class=3D"MsoNormal">+/*</p><p class=3D"MsoNormal">+ *=
 QEMU System Emulator</p>
<p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * Copyright (c) 2003=
-2008 Fabrice Bellard</p><p class=3D"MsoNormal">+ *</p><p class=3D"MsoNorma=
l">+ * Permission is hereby granted, free of charge, to any person obtainin=
g a copy</p>
<p class=3D"MsoNormal">+ * of this software and associated documentation fi=
les (the &quot;Software&quot;), to deal</p><p class=3D"MsoNormal">+ * in th=
e Software without restriction, including without limitation the rights</p>
<p class=3D"MsoNormal">+ * to use, copy, modify, merge, publish, distribute=
, sublicense, and/or sell</p><p class=3D"MsoNormal">+ * copies of the Softw=
are, and to permit persons to whom the Software is</p><p class=3D"MsoNormal=
">
+ * furnished to do so, subject to the following conditions:</p><p class=3D=
"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * The above copyright notice an=
d this permission notice shall be included in</p><p class=3D"MsoNormal">+ *=
 all copies or substantial portions of the Software.</p>
<p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * THE SOFTWARE IS PR=
OVIDED &quot;AS IS&quot;, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR</p><p cl=
ass=3D"MsoNormal">+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES =
OF MERCHANTABILITY,</p>
<p class=3D"MsoNormal">+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGE=
MENT. IN NO EVENT SHALL</p><p class=3D"MsoNormal">+ * THE AUTHORS OR COPYRI=
GHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER</p><p class=3D"MsoNor=
mal">
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING=
 FROM,</p><p class=3D"MsoNormal">+ * OUT OF OR IN CONNECTION WITH THE SOFTW=
ARE OR THE USE OR OTHER DEALINGS IN</p><p class=3D"MsoNormal">+ * THE SOFTW=
ARE.</p>
<p class=3D"MsoNormal">+ */</p><p class=3D"MsoNormal">+#ifndef REPHUB_CMDS_=
H</p><p class=3D"MsoNormal">+#define REPHUB_CMDS_H</p><p class=3D"MsoNormal=
">+</p><p class=3D"MsoNormal">+#include &lt;stdint.h&gt;</p><p class=3D"Mso=
Normal">
+#include &quot;repcmd.h&quot;</p><p class=3D"MsoNormal">+#include &quot;re=
phub_defs.h&quot;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+/*=
********************************************************</p><p class=3D"Mso=
Normal">
+ * RepCmd Report a protected IO</p><p class=3D"MsoNormal">+ *</p><p class=
=3D"MsoNormal">+ * REPHUB_CMD_PROTECTED_WRITE</p><p class=3D"MsoNormal">+ *=
 Direction: agent-&gt;hub</p><p class=3D"MsoNormal">+ *</p><p class=3D"MsoN=
ormal">
+ * Any write of a protected volume is send with this</p><p class=3D"MsoNor=
mal">+ * message to the hub, with its status.</p><p class=3D"MsoNormal">+ *=
 When case the status is bad no data is sent</p><p class=3D"MsoNormal">+ **=
*******************************************************/</p>
<p class=3D"MsoNormal">+typedef struct RepCmdProtectedWrite {</p><p class=
=3D"MsoNormal">+=A0=A0=A0 RepCmdHdr hdr;</p><p class=3D"MsoNormal">+=A0=A0=
=A0 uint64_t volume_id;</p><p class=3D"MsoNormal">+=A0=A0=A0 uint64_t offse=
t_sectors;</p><p class=3D"MsoNormal">
+=A0=A0=A0 /* The size field duplicates the RepCmd size,</p><p class=3D"Mso=
Normal">+=A0=A0=A0=A0 * but it is needed for reporting failed IOs&#39; size=
s */</p><p class=3D"MsoNormal">+=A0=A0=A0 uint32_t size_sectors;</p><p clas=
s=3D"MsoNormal">+=A0=A0=A0 int ret_status;</p>
<p class=3D"MsoNormal">+} RepCmdProtectedWrite;</p><p class=3D"MsoNormal">+=
</p><p class=3D"MsoNormal">+/**********************************************=
***********</p><p class=3D"MsoNormal">+ * RepCmd Report VM volumes</p><p cl=
ass=3D"MsoNormal">
+ *</p><p class=3D"MsoNormal">+ * REPHUB_CMD_REPORT_VM_VOLUMES</p><p class=
=3D"MsoNormal">+ * Direction: agent-&gt;hub</p><p class=3D"MsoNormal">+ *</=
p><p class=3D"MsoNormal">+ * The agent reports all the volumes of the VM</p=
><p class=3D"MsoNormal">
+ * to the hub.</p><p class=3D"MsoNormal">+ *******************************=
**************************/</p><p class=3D"MsoNormal">+typedef struct RepVm=
VolumeInfo {</p><p class=3D"MsoNormal">+=A0=A0=A0 char name[REPHUB_MAX_VOL_=
NAME_LEN];</p>
<p class=3D"MsoNormal">+=A0=A0=A0 uint64_t volume_id;</p><p class=3D"MsoNor=
mal">+=A0=A0=A0 uint32_t size_mb;</p><p class=3D"MsoNormal">+} RepVmVolumeI=
nfo;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+typedef struct =
RepCmdReportVmVolumes {</p>
<p class=3D"MsoNormal">+=A0=A0=A0 RepCmdHdr hdr;</p><p class=3D"MsoNormal">=
+=A0=A0=A0 int num_volumes;</p><p class=3D"MsoNormal">+} RepCmdReportVmVolu=
mes;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+typedef struct =
RepCmdDataReportVmVolumes {</p>
<p class=3D"MsoNormal">+=A0=A0=A0 RepVmVolumeInfo volumes[0];</p><p class=
=3D"MsoNormal">+} RepCmdDataReportVmVolumes;</p><p class=3D"MsoNormal">+</p=
><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+/*********************=
************************************</p>
<p class=3D"MsoNormal">+ * RepCmd Start protect</p><p class=3D"MsoNormal">+=
 *</p><p class=3D"MsoNormal">+ * REPHUB_CMD_START_PROTECT</p><p class=3D"Ms=
oNormal">+ * Direction: hub-&gt;agent</p><p class=3D"MsoNormal">+ *</p><p c=
lass=3D"MsoNormal">
+ * The hub instructs the agent to start protecting</p><p class=3D"MsoNorma=
l">+ * a volume. When a volume is protected all its writes</p><p class=3D"M=
soNormal">+ * are sent to to the hub.</p><p class=3D"MsoNormal">+ * With th=
is command the hub also assigns a volume ID to</p>
<p class=3D"MsoNormal">+ * the given volume name.</p><p class=3D"MsoNormal"=
>+ *********************************************************/</p><p class=
=3D"MsoNormal">+typedef struct RepCmdStartProtect {</p><p class=3D"MsoNorma=
l">+=A0=A0=A0 RepCmdHdr hdr;</p>
<p class=3D"MsoNormal">+=A0=A0=A0 uint64_t volume_id;</p><p class=3D"MsoNor=
mal">+} RepCmdStartProtect;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoN=
ormal">+typedef struct RepCmdDataStartProtect {</p><p class=3D"MsoNormal">+=
=A0=A0=A0 char volume_name[REPHUB_MAX_VOL_NAME_LEN];</p>
<p class=3D"MsoNormal">+} RepCmdDataStartProtect;</p><p class=3D"MsoNormal"=
>+</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+/****************=
*****************************************</p><p class=3D"MsoNormal">+ * Rep=
Cmd Read Volume Request</p>
<p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * REPHUB_CMD_READ_VO=
L_REQ</p><p class=3D"MsoNormal">+ * Direction: hub-&gt;agent</p><p class=3D=
"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * The hub issues a read IO to a=
 protected volume.</p>
<p class=3D"MsoNormal">+ * This command is used during sync - when the hub =
needs</p><p class=3D"MsoNormal">+ * to read unsyncronized sections of a pro=
tected volume.</p><p class=3D"MsoNormal">+ * This command is a request, the=
 read data is returned</p>
<p class=3D"MsoNormal">+ * by the response command REPHUB_CMD_READ_VOL_RES<=
/p><p class=3D"MsoNormal">+ ***********************************************=
**********/</p><p class=3D"MsoNormal">+typedef struct RepCmdReadVolReq {</p=
><p class=3D"MsoNormal">
+=A0=A0=A0 RepCmdHdr hdr;</p><p class=3D"MsoNormal">+=A0=A0=A0 int req_id;<=
/p><p class=3D"MsoNormal">+=A0=A0=A0 int size_sectors;</p><p class=3D"MsoNo=
rmal">+=A0=A0=A0 uint64_t volume_id;</p><p class=3D"MsoNormal">+=A0=A0=A0 u=
int64_t offset_sectors;</p><p class=3D"MsoNormal">
+} RepCmdReadVolReq;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">=
+/*********************************************************</p><p class=3D"=
MsoNormal">+ * RepCmd Read Volume Response</p><p class=3D"MsoNormal">+ *</p=
><p class=3D"MsoNormal">
+ * REPHUB_CMD_READ_VOL_RES</p><p class=3D"MsoNormal">+ * Direction: agent-=
&gt;hub</p><p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * A respo=
nse to REPHUB_CMD_READ_VOL_REQ.</p><p class=3D"MsoNormal">+ * Sends the dat=
a read from a protected volume</p>
<p class=3D"MsoNormal">+ **************************************************=
*******/</p><p class=3D"MsoNormal">+typedef struct RepCmdReadVolRes {</p><p=
 class=3D"MsoNormal">+=A0=A0=A0 RepCmdHdr hdr;</p><p class=3D"MsoNormal">+=
=A0=A0=A0 int req_id;</p>
<p class=3D"MsoNormal">+=A0=A0=A0 int is_status_success;</p><p class=3D"Mso=
Normal">+=A0=A0=A0 uint64_t volume_id;</p><p class=3D"MsoNormal">+} RepCmdR=
eadVolRes;</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+/********=
*************************************************</p>
<p class=3D"MsoNormal">+ * RepCmd Agent shutdown</p><p class=3D"MsoNormal">=
+ *</p><p class=3D"MsoNormal">+ * REPHUB_CMD_AGENT_SHUTDOWN</p><p class=3D"=
MsoNormal">+ * Direction: agent-&gt;hub</p><p class=3D"MsoNormal">+ *</p><p=
 class=3D"MsoNormal">
+ * Notifies the hub that the agent is about to shutdown.</p><p class=3D"Ms=
oNormal">+ * This allows a graceful shutdown. Any disconnection</p><p class=
=3D"MsoNormal">+ * of an agent without sending this command will result</p>
<p class=3D"MsoNormal">+ * in a full sync of the VM volumes.</p><p class=3D=
"MsoNormal">+ *********************************************************/</p=
><p class=3D"MsoNormal">+typedef struct RepCmdAgentShutdown {</p><p class=
=3D"MsoNormal">
+=A0=A0=A0 RepCmdHdr hdr;</p><p class=3D"MsoNormal">+} RepCmdAgentShutdown;=
</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+</p><p class=3D"Mso=
Normal">+#endif /* REPHUB_CMDS_H */</p><p class=3D"MsoNormal">diff --git a/=
replication/rephub_defs.h b/replication/rephub_defs.h</p>
<p class=3D"MsoNormal">new file mode 100644</p><p class=3D"MsoNormal">index=
 0000000..e34e0ce</p><p class=3D"MsoNormal">--- /dev/null</p><p class=3D"Ms=
oNormal">+++ b/replication/rephub_defs.h</p><p class=3D"MsoNormal">@@ -0,0 =
+1,40 @@</p>
<p class=3D"MsoNormal">+/*</p><p class=3D"MsoNormal">+ * QEMU System Emulat=
or</p><p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * Copyright (c=
) 2003-2008 Fabrice Bellard</p><p class=3D"MsoNormal">+ *</p><p class=3D"Ms=
oNormal">
+ * Permission is hereby granted, free of charge, to any person obtaining a=
 copy</p><p class=3D"MsoNormal">+ * of this software and associated documen=
tation files (the &quot;Software&quot;), to deal</p><p class=3D"MsoNormal">
+ * in the Software without restriction, including without limitation the r=
ights</p><p class=3D"MsoNormal">+ * to use, copy, modify, merge, publish, d=
istribute, sublicense, and/or sell</p><p class=3D"MsoNormal">+ * copies of =
the Software, and to permit persons to whom the Software is</p>
<p class=3D"MsoNormal">+ * furnished to do so, subject to the following con=
ditions:</p><p class=3D"MsoNormal">+ *</p><p class=3D"MsoNormal">+ * The ab=
ove copyright notice and this permission notice shall be included in</p><p =
class=3D"MsoNormal">
+ * all copies or substantial portions of the Software.</p><p class=3D"MsoN=
ormal">+ *</p><p class=3D"MsoNormal">+ * THE SOFTWARE IS PROVIDED &quot;AS =
IS&quot;, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR</p><p class=3D"MsoNormal=
">
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY=
,</p><p class=3D"MsoNormal">+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINF=
RINGEMENT. IN NO EVENT SHALL</p><p class=3D"MsoNormal">+ * THE AUTHORS OR C=
OPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER</p>
<p class=3D"MsoNormal">+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TOR=
T OR OTHERWISE, ARISING FROM,</p><p class=3D"MsoNormal">+ * OUT OF OR IN CO=
NNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN</p><p class=3D"M=
soNormal">
+ * THE SOFTWARE.</p><p class=3D"MsoNormal">+ */</p><p class=3D"MsoNormal">=
+#ifndef REP_HUB_DEFS_H</p><p class=3D"MsoNormal">+#define REP_HUB_DEFS_H</=
p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+#include &lt;stdint.h=
&gt;</p>
<p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+#define REPHUB_MAX_VOL_=
NAME_LEN (1024)</p><p class=3D"MsoNormal">+#define REPHUB_MAX_NUM_VOLUMES (=
512)</p><p class=3D"MsoNormal">+</p><p class=3D"MsoNormal">+#ifndef TRUE</p=
><p class=3D"MsoNormal">
+=A0=A0=A0 #define TRUE (1)</p><p class=3D"MsoNormal">+#endif</p><p class=
=3D"MsoNormal">+</p><p class=3D"MsoNormal">+#ifndef FALSE</p><p class=3D"Ms=
oNormal">+=A0=A0=A0 #define FALSE (0)</p><p class=3D"MsoNormal">+#endif</p>=
<p class=3D"MsoNormal">
+</p><p class=3D"MsoNormal">+#endif /* REP_HUB_DEFS_H */</p><p class=3D"Mso=
Normal">diff --git a/vl.c b/vl.c</p><p class=3D"MsoNormal">index 624da0f..5=
06b5dc 100644</p><p class=3D"MsoNormal">--- a/vl.c</p><p class=3D"MsoNormal=
">+++ b/vl.c</p>
<p class=3D"MsoNormal">@@ -167,6 +167,7 @@ int main(int argc, char **argv)<=
/p><p class=3D"MsoNormal"> </p><p class=3D"MsoNormal">=A0#include &quot;ui/=
qemu-spice.h&quot;</p><p class=3D"MsoNormal"> </p><p class=3D"MsoNormal">+#=
include &quot;replication/repagent.h&quot;</p>
<p class=3D"MsoNormal"> //#define DEBUG_NET</p><p class=3D"MsoNormal"> //#d=
efine DEBUG_SLIRP</p><p class=3D"MsoNormal"> </p><p class=3D"MsoNormal">@@ =
-2307,6 +2308,15 @@ int main(int argc, char **argv, char **envp)</p><p clas=
s=3D"MsoNormal">
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 drive_add(IF_DEFAULT, popt=
-&gt;index - QEMU_OPTION_hda, optarg,</p><p class=3D"MsoNormal">=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 HD_OP=
TS);</p><p class=3D"MsoNormal">=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 break;</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 =
case QEMU_OPTION_repagent:</p>
<p class=3D"MsoNormal">+#ifdef CONFIG_REPLICATION</p><p class=3D"MsoNormal"=
>+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 repagent_init(optarg, 0);</=
p><p class=3D"MsoNormal">+#else</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 fprintf(stderr, &quot;Replication support is=
 disabled. &quot;</p>
<p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0 &quot;Don&#39;t use -repagent option.\n&quot;);</p><p class=3D"MsoNo=
rmal">+=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 exit(1);</p><p class=
=3D"MsoNormal">+#endif</p><p class=3D"MsoNormal">+=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0=A0=A0=A0=A0 break;</p>
<p class=3D"MsoNormal">=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 case QEMU_OPTIO=
N_drive:</p><p class=3D"MsoNormal">=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=
=A0=A0=A0 if (drive_def(optarg) =3D=3D NULL) {</p><p class=3D"MsoNormal">=
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 exit(1);</p><p=
 class=3D"MsoNormal">-- </p><p class=3D"MsoNormal">
1.7.6.4</p><p class=3D"MsoNormal">=A0</p></div></body></html>

--047d7b3396015fba3f04b85d40a9--