[Top][All Lists]

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

Re: [Qemu-devel] [RFC PATCH V4 0/4] Introduce COLO-compare

From: Zhang Chen
Subject: Re: [Qemu-devel] [RFC PATCH V4 0/4] Introduce COLO-compare
Date: Tue, 31 May 2016 11:54:23 +0800
User-agent: Mozilla/5.0 (X11; Linux x86_64; rv:38.0) Gecko/20100101 Thunderbird/38.8.0

On 05/30/2016 11:19 AM, Jason Wang wrote:

On 2016年05月25日 20:50, Zhang Chen wrote:
COLO-compare is a part of COLO project. It is used
to compare the network package to help COLO decide
whether to do checkpoint.

the full version in this github:

     - add some comments
     - fix some trace-events
     - fix tcp compare error
     - add rcu_read_lock().
     - fix trace name
     - fix jason's other comments
     - rebase some Dave's branch function
     - colo_compare_connection() change g_queue_push_head() to
     - g_queue_push_tail() match to sorted order.
     - remove QemuMutex conn_list_lock

Looks like conn_list lock is still there. I still prefer to do all thing in the comparing thread. Have you tried Fam's suggestion to use g_main_context_push_thread_default()? If it does not work, does it work simply by replacing all:

g_source_attach(x, NULL);


g_souce_attach(x, g_main_context_get_thread_default());

after call g_main_context_push_thread_default()?


I have tried fam's suggestion it does not work.

so I tried what you suggestion like that:

static void *colo_compare_thread(void *opaque)
    CompareState *s = opaque;
    GSource *source;
    GMainContext *worker_context;

    source = g_source_new(&source_funcs, sizeof(DemoSource));
    worker_context = g_main_context_new ();

    g_source_attach(source, g_main_context_get_thread_default());
    g_source_set_callback(source, NULL, NULL, NULL);
    g_main_context_push_thread_default (worker_context);
    qemu_chr_add_handlers(s->chr_pri_in, compare_chr_can_read,
                          compare_pri_chr_in, NULL, s);
    qemu_chr_add_handlers(s->chr_sec_in, compare_chr_can_read,
                          compare_sec_chr_in, NULL, s);
    g_main_context_pop_thread_default (worker_context);

but it does not work too. Do you mean like this?

Zhang Chen

     - remove pkt->s
     - move data structure to colo-base.h
     - add colo-base.c reuse codes for filter-rewriter
     - add some filter-rewriter needs struct
     - depends on previous SocketReadState patch
     - except move qemu_chr_add_handlers()
       to colo thread
     - remove class_finalize
     - remove secondary arp codes
     - depends on previous SocketReadState patch

   - rebase colo-compare to colo-frame v2.7
   - fix most of Dave's comments
     (except RCU)
   - add TCP,UDP,ICMP and other packet comparison
   - add trace-event
   - add some comments
   - other bug fix
   - add RFC index
   - add usage in patch 1/4

   - add jhash.h

   - initial patch

Zhang Chen (4):
   colo-compare: introduce colo compare initialization
   colo-compare: track connection and enqueue packet
   colo-compare: introduce packet comparison thread
   colo-compare: add TCP,UDP,ICMP packet comparison

  include/qemu/jhash.h |  61 +++++
  net/Makefile.objs    |   2 +
  net/colo-base.c      | 183 +++++++++++++
  net/colo-base.h      |  92 +++++++
net/colo-compare.c | 745 +++++++++++++++++++++++++++++++++++++++++++++++++++
  qemu-options.hx      |  34 +++
  trace-events         |  11 +
  vl.c                 |   3 +-
  8 files changed, 1130 insertions(+), 1 deletion(-)
  create mode 100644 include/qemu/jhash.h
  create mode 100644 net/colo-base.c
  create mode 100644 net/colo-base.h
  create mode 100644 net/colo-compare.c



reply via email to

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