From 42fcf88989244ebd713ee57a48b19c12ca891087 Mon Sep 17 00:00:00 2001 From: Sean Hefty Date: Tue, 5 Jun 2012 14:51:13 -0700 Subject: [PATCH] Refresh of rs-spin --- src/rsocket.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/rsocket.c b/src/rsocket.c index b8ae3b4d..3619af45 100644 --- 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) -- 2.45.2