[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [multiprocess RFC PATCH 32/37] multi-process: handle heartb
|
From: |
elena . ufimtseva |
|
Subject: |
[Qemu-devel] [multiprocess RFC PATCH 32/37] multi-process: handle heartbit messages in remote process |
|
Date: |
Wed, 6 Mar 2019 23:22:43 -0800 |
From: Elena Ufimtseva <address@hidden>
and reply back to proxy object.
Signed-off-by: Jagannathan Raman <address@hidden>
Signed-off-by: John G Johnson <address@hidden>
Signed-off-by: Elena Ufimtseva <address@hidden>
---
remote/remote-main.c | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/remote/remote-main.c b/remote/remote-main.c
index 3fa6cbd..1e45105 100644
--- a/remote/remote-main.c
+++ b/remote/remote-main.c
@@ -339,6 +339,7 @@ static void process_msg(GIOCondition cond)
{
ProcMsg *msg = NULL;
Error *err = NULL;
+ int wait;
if ((cond & G_IO_HUP) || (cond & G_IO_ERR)) {
error_setg(&err, "socket closed, cond is %d", cond);
@@ -418,6 +419,11 @@ static void process_msg(GIOCondition cond)
case DEVICE_DEL:
process_device_del_msg(msg);
break;
+ case PROXY_PING:
+ wait = msg->fds[0];
+ notify_proxy(wait, (uint32_t)getpid());
+ PUT_REMOTE_WAIT(wait);
+ break;
default:
error_setg(&err, "Unknown command");
goto finalize_loop;
--
1.8.3.1
| [Prev in Thread] |
Current Thread |
[Next in Thread] |
- [Qemu-devel] [multiprocess RFC PATCH 32/37] multi-process: handle heartbit messages in remote process,
elena . ufimtseva <=