X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=recv.c;h=95711f1fce1c4ea56f8bbe00ff829d5a8bbc401c;hp=fd82bc0fa6d998e51072284aefe1dc5d79dd3663;hb=c9d743cd9a0ac9788884fafd70e6cf5e78941290;hpb=adbf9f09c9bf2a680c61b1ef3541c04f1cde97cf diff --git a/recv.c b/recv.c index fd82bc0f..95711f1f 100644 --- a/recv.c +++ b/recv.c @@ -19,6 +19,7 @@ #include "recv.h" #include "recv.cmdline.h" +#include "fd.h" #include "error.h" struct gengetopt_args_info conf; @@ -84,13 +85,11 @@ recv: timeout.tv_usec = 1000 * 1000; max = -1; ret = r->pre_select(&rn, &rfds, &wfds, &timeout); - max = MAX(max, ret); + max = PARA_MAX(max, ret); PARA_DEBUG_LOG("timeout: %lums\n", tv2ms(&timeout)); - ret = select(max + 1, &rfds, &wfds, NULL, &timeout); + ret = para_select(max + 1, &rfds, &wfds, &timeout); if (ret < 0) { - if (errno == EINTR || errno == EAGAIN) - goto recv; ret = -E_RECV_SELECT; goto out; }