From mboxrd@z Thu Jan 1 00:00:00 1970 From: Asias He Subject: [PATCH 1/6] kvm tools: Handle multiple IPC cmd at a time Date: Thu, 22 Dec 2011 10:10:42 +0800 Message-ID: <1324519847-19897-1-git-send-email-asias.hejun@gmail.com> Cc: Sasha Levin , Cyrill Gorcunov , Ingo Molnar , kvm@vger.kernel.org, Asias He To: Pekka Enberg Return-path: Received: from mail-iy0-f174.google.com ([209.85.210.174]:62527 "EHLO mail-iy0-f174.google.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1751850Ab1LVCM2 (ORCPT ); Wed, 21 Dec 2011 21:12:28 -0500 Received: by iaeh11 with SMTP id h11so12745040iae.19 for ; Wed, 21 Dec 2011 18:12:28 -0800 (PST) Sender: kvm-owner@vger.kernel.org List-ID: This is useful when client submiting multiple IPC cmd in one socket connection. Signed-off-by: Asias He --- tools/kvm/kvm-ipc.c | 15 ++++++++++++--- 1 files changed, 12 insertions(+), 3 deletions(-) diff --git a/tools/kvm/kvm-ipc.c b/tools/kvm/kvm-ipc.c index 2036b91..dbe2363 100644 --- a/tools/kvm/kvm-ipc.c +++ b/tools/kvm/kvm-ipc.c @@ -102,7 +102,7 @@ static void kvm_ipc__close_conn(int fd) close(fd); } -static void kvm_ipc__receive(int fd) +static int kvm_ipc__receive(int fd) { struct kvm_ipc_head head; u8 *msg = NULL; @@ -122,8 +122,11 @@ static void kvm_ipc__receive(int fd) kvm_ipc__handle(fd, head.type, head.len, msg); + return 0; + done: free(msg); + return -1; } static void *kvm_ipc__thread(void *param) @@ -140,10 +143,16 @@ static void *kvm_ipc__thread(void *param) if (fd == stop_fd && event.events & EPOLLIN) { break; } else if (fd == server_fd) { - int client; + int client, r; client = kvm_ipc__new_conn(fd); - kvm_ipc__receive(client); + /* + * Handle multiple IPC cmd at a time + */ + do { + r = kvm_ipc__receive(client); + } while (r == 0); + } else if (event.events && (EPOLLERR | EPOLLRDHUP | EPOLLHUP)) { kvm_ipc__close_conn(fd); } else { -- 1.7.7.3