|
 |
9855619 |
From 958c0035aa6a69149c1a0fa218863c26e755d9e6 Mon Sep 17 00:00:00 2001
|
|
|
9855619 |
From: Ryan McCabe <rmccabe@redhat.com>
|
|
|
9855619 |
Date: Fri, 19 Jan 2018 11:04:22 -0500
|
|
|
9855619 |
Subject: [PATCH] fence_virtd: Return control to main loop on select
|
|
|
9855619 |
interruption
|
|
|
9855619 |
|
|
|
9855619 |
Return control to the dispatch loop if select is interrupted by a
|
|
|
9855619 |
signal. The code that retried the select without breaking out of the
|
|
|
9855619 |
dispatch loop caused the daemon to not be able to be killed cleanly.
|
|
|
9855619 |
|
|
|
9855619 |
Resolves: https://github.com/ClusterLabs/fence-virt/issues/10
|
|
|
9855619 |
|
|
|
9855619 |
Signed-off-by: Ryan McCabe <rmccabe@redhat.com>
|
|
|
9855619 |
|
|
|
9855619 |
diff --git a/server/mcast.c b/server/mcast.c
|
|
|
9855619 |
index 0336823..e103675 100644
|
|
|
9855619 |
--- a/server/mcast.c
|
|
|
9855619 |
+++ b/server/mcast.c
|
|
|
9855619 |
@@ -350,9 +350,14 @@ mcast_dispatch(listener_context_t c, struct timeval *timeout)
|
|
|
9855619 |
FD_ZERO(&rfds);
|
|
|
9855619 |
FD_SET(info->mc_sock, &rfds);
|
|
|
9855619 |
|
|
|
9855619 |
- n = _select_retry((info->mc_sock)+1, &rfds, NULL, NULL, timeout);
|
|
|
9855619 |
- if (n <= 0)
|
|
|
9855619 |
+ n = select((info->mc_sock)+1, &rfds, NULL, NULL, timeout);
|
|
|
9855619 |
+ if (n <= 0) {
|
|
|
9855619 |
+ if (errno == EINTR || errno == EAGAIN)
|
|
|
9855619 |
+ n = 0;
|
|
|
9855619 |
+ else
|
|
|
9855619 |
+ dbg_printf(2, "select: %s\n", strerror(errno));
|
|
|
9855619 |
return n;
|
|
|
9855619 |
+ }
|
|
|
9855619 |
|
|
|
9855619 |
slen = sizeof(sin);
|
|
|
9855619 |
len = recvfrom(info->mc_sock, &data, sizeof(data), 0,
|
|
|
9855619 |
diff --git a/server/serial.c b/server/serial.c
|
|
|
9855619 |
index 70eb22b..23d143d 100644
|
|
|
9855619 |
--- a/server/serial.c
|
|
|
9855619 |
+++ b/server/serial.c
|
|
|
9855619 |
@@ -272,9 +272,12 @@ serial_dispatch(listener_context_t c, struct timeval *timeout)
|
|
|
9855619 |
if (info->wake_fd > max)
|
|
|
9855619 |
max = info->wake_fd;
|
|
|
9855619 |
|
|
|
9855619 |
- n = _select_retry(max+1, &rfds, NULL, NULL, timeout);
|
|
|
9855619 |
- if (n < 0) {
|
|
|
9855619 |
- dbg_printf(2, "select: %s\n", strerror(errno));
|
|
|
9855619 |
+ n = select(max+1, &rfds, NULL, NULL, timeout);
|
|
|
9855619 |
+ if (n <= 0) {
|
|
|
9855619 |
+ if (errno == EINTR || errno == EAGAIN)
|
|
|
9855619 |
+ n = 0;
|
|
|
9855619 |
+ else
|
|
|
9855619 |
+ dbg_printf(2, "select: %s\n", strerror(errno));
|
|
|
9855619 |
return n;
|
|
|
9855619 |
}
|
|
|
9855619 |
|
|
|
9855619 |
diff --git a/server/tcp.c b/server/tcp.c
|
|
|
9855619 |
index 09366b7..bbd347e 100644
|
|
|
9855619 |
--- a/server/tcp.c
|
|
|
9855619 |
+++ b/server/tcp.c
|
|
|
9855619 |
@@ -278,9 +278,14 @@ tcp_dispatch(listener_context_t c, struct timeval *timeout)
|
|
|
9855619 |
FD_ZERO(&rfds);
|
|
|
9855619 |
FD_SET(info->listen_sock, &rfds);
|
|
|
9855619 |
|
|
|
9855619 |
- n = _select_retry(info->listen_sock + 1, &rfds, NULL, NULL, timeout);
|
|
|
9855619 |
- if (n <= 0)
|
|
|
9855619 |
+ n = select(info->listen_sock + 1, &rfds, NULL, NULL, timeout);
|
|
|
9855619 |
+ if (n <= 0) {
|
|
|
9855619 |
+ if (errno == EINTR || errno == EAGAIN)
|
|
|
9855619 |
+ n = 0;
|
|
|
9855619 |
+ else
|
|
|
9855619 |
+ dbg_printf(2, "select: %s\n", strerror(errno));
|
|
|
9855619 |
return n;
|
|
|
9855619 |
+ }
|
|
|
9855619 |
|
|
|
9855619 |
client_fd = accept(info->listen_sock, NULL, NULL);
|
|
|
9855619 |
if (client_fd < 0) {
|