diff options
author | Mattias Andrée <maandree@operamail.com> | 2014-05-11 19:19:43 +0200 |
---|---|---|
committer | Mattias Andrée <maandree@operamail.com> | 2014-05-11 19:19:43 +0200 |
commit | aeb42ddc7990e6e78c45b2aeb4c9f5364bbc4155 (patch) | |
tree | 91fcfa6f6260cf9cb07ef800da588b8c869a99e0 | |
parent | derp (diff) | |
download | mds-aeb42ddc7990e6e78c45b2aeb4c9f5364bbc4155.tar.gz mds-aeb42ddc7990e6e78c45b2aeb4c9f5364bbc4155.tar.bz2 mds-aeb42ddc7990e6e78c45b2aeb4c9f5364bbc4155.tar.xz |
handle errors when sending a multicast message
Signed-off-by: Mattias Andrée <maandree@operamail.com>
-rw-r--r-- | src/mds-server/mds-server.c | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/src/mds-server/mds-server.c b/src/mds-server/mds-server.c index f9c2fd0..e2978c3 100644 --- a/src/mds-server/mds-server.c +++ b/src/mds-server/mds-server.c @@ -1252,7 +1252,7 @@ void multicast_message(multicast_t* multicast) { if (errno != EINTR) perror(*argv); - break; /* TODO handle errors */ + break; } n -= sent; multicast->message_ptr += sent; @@ -1260,8 +1260,13 @@ void multicast_message(multicast_t* multicast) ); /* Stop if we are re-exec:ing. */ - if ((n > 0) && reexecing) - return; + if (n > 0) + { + if (reexecing) + return; + else + continue; + } /* Wait for a reply and act upon it. */ if ((n == 0) && client_.modifying) |