qemu-devel
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: [Qemu-devel] [PATCH] colo-compare: Fix old packet check bug.


From: Jason Wang
Subject: Re: [Qemu-devel] [PATCH] colo-compare: Fix old packet check bug.
Date: Thu, 13 Apr 2017 15:29:18 +0800
User-agent: Mozilla/5.0 (X11; Linux x86_64; rv:45.0) Gecko/20100101 Thunderbird/45.8.0



On 2017年04月12日 20:12, Zhang Chen wrote:
If colo-compare find one old packet,we can notify colo-frame
do checkpoint, no need continue find more old packet here.

Signed-off-by: Zhang Chen <address@hidden>
---
  net/colo-compare.c | 15 +++++++++++----
  1 file changed, 11 insertions(+), 4 deletions(-)

diff --git a/net/colo-compare.c b/net/colo-compare.c
index 54e6d40..9b09cfc 100644
--- a/net/colo-compare.c
+++ b/net/colo-compare.c
@@ -372,10 +372,9 @@ static int colo_old_packet_check_one(Packet *pkt, int64_t 
*check_time)
      }
  }
-static void colo_old_packet_check_one_conn(void *opaque,
-                                           void *user_data)
+static int colo_old_packet_check_one_conn(Connection *conn,
+                                          void *user_data)
  {
-    Connection *conn = opaque;
      GList *result = NULL;
      int64_t check_time = REGULAR_PACKET_CHECK_MS;
@@ -386,7 +385,10 @@ static void colo_old_packet_check_one_conn(void *opaque,
      if (result) {
          /* do checkpoint will flush old packet */
          /* TODO: colo_notify_checkpoint();*/
+        return 0;
      }
+
+    return 1;
  }
/*
@@ -398,7 +400,12 @@ static void colo_old_packet_check(void *opaque)
  {
      CompareState *s = opaque;
- g_queue_foreach(&s->conn_list, colo_old_packet_check_one_conn, NULL);
+    /*
+     * If we find one old packet, stop finding job and notify
+     * COLO frame do checkpoint.
+     */
+    g_queue_find_custom(&s->conn_list, NULL,
+                        (GCompareFunc)colo_old_packet_check_one_conn);
  }
/*

Queued in net-next.

Thanks



reply via email to

[Prev in Thread] Current Thread [Next in Thread]