From: Zhang Chen <chen.zh...@intel.com> Address Peter's comments in patch "COLO-compare:Add colo-compare remote notify support".
Signed-off-by: Zhang Chen <chen.zh...@intel.com> --- net/colo-compare.c | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/net/colo-compare.c b/net/colo-compare.c index 909dd6c6eb..363b1edd11 100644 --- a/net/colo-compare.c +++ b/net/colo-compare.c @@ -1008,21 +1008,20 @@ static void compare_notify_rs_finalize(SocketReadState *notify_rs) { CompareState *s = container_of(notify_rs, CompareState, notify_rs); - /* Get Xen colo-frame's notify and handle the message */ - char *data = g_memdup(notify_rs->buf, notify_rs->packet_len); - char msg[] = "COLO_COMPARE_GET_XEN_INIT"; + const char msg[] = "COLO_COMPARE_GET_XEN_INIT"; int ret; - if (!strcmp(data, "COLO_USERSPACE_PROXY_INIT")) { + if (!strcmp((char *)notify_rs->buf, "COLO_USERSPACE_PROXY_INIT")) { ret = compare_chr_send(s, (uint8_t *)msg, strlen(msg), 0, true); if (ret < 0) { error_report("Notify Xen COLO-frame INIT failed"); } - } - - if (!strcmp(data, "COLO_CHECKPOINT")) { + } else if (!strcmp((char *)notify_rs->buf, "COLO_CHECKPOINT")) { /* colo-compare do checkpoint, flush pri packet and remove sec packet */ g_queue_foreach(&s->conn_list, colo_flush_packets, s); + } else { + error_report("COLO compare got unsupported instruction '%s'", + (char *)notify_rs->buf); } } -- 2.17.GIT