Refresh of rs-spin

diff --git a/src/rsocket.c b/src/rsocket.c
index b8ae3b4dc4ab7b558f4402e4aa391488580b2d25..3619af45815244e1ea69bd3f03e72cb0832a7192 100644 (file)
--- a/src/rsocket.c
+++ b/src/rsocket.c
@@ -955,7 +955,7 @@ static int rs_get_comp(struct rsocket *rs, int nonblock, int (*test)(struct rsoc
                gettimeofday(&e, NULL);
                poll_time = (e.tv_sec - s.tv_sec) * 1000000 +
                            (e.tv_usec - s.tv_usec) + 1;
-       } while (poll_time < polling_time);
+       } while (poll_time <= polling_time);
 
        ret = rs_process_cq(rs, 0, test);
        return ret;
@@ -1522,7 +1522,7 @@ int rpoll(struct pollfd *fds, nfds_t nfds, int timeout)
                gettimeofday(&e, NULL);
                poll_time = (e.tv_sec - s.tv_sec) * 1000000 +
                            (e.tv_usec - s.tv_usec) + 1;
-       } while (poll_time < polling_time);
+       } while (poll_time <= polling_time);
 
        rfds = rs_fds_alloc(nfds);
        if (!rfds)