diff options
| -rw-r--r-- | src/syslog_relay.c | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/syslog_relay.c b/src/syslog_relay.c index f1231e1..2936700 100644 --- a/src/syslog_relay.c +++ b/src/syslog_relay.c | |||
| @@ -211,8 +211,10 @@ void *syslog_relay_worker(void *arg) | |||
| 211 | while (srwt->client->parent) { | 211 | while (srwt->client->parent) { |
| 212 | char c; | 212 | char c; |
| 213 | uint32_t bytes = 0; | 213 | uint32_t bytes = 0; |
| 214 | ret = syslog_relay_receive_with_timeout(srwt->client, &c, 1, &bytes, 0); | 214 | ret = syslog_relay_receive_with_timeout(srwt->client, &c, 1, &bytes, 100); |
| 215 | if (ret < 0 || (bytes != 1)) { | 215 | if ((bytes == 0) && (ret == SYSLOG_RELAY_E_SUCCESS)) { |
| 216 | continue; | ||
| 217 | } else if (ret < 0) { | ||
| 216 | debug_info("Connection to syslog relay interrupted"); | 218 | debug_info("Connection to syslog relay interrupted"); |
| 217 | break; | 219 | break; |
| 218 | } | 220 | } |
