summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/lib/dev.c12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/lib/dev.c b/src/lib/dev.c
index 86074e2b..c8b7d93b 100644
--- a/src/lib/dev.c
+++ b/src/lib/dev.c
@@ -800,14 +800,14 @@ int flow_dealloc(int fd)
timeo = frcti_dealloc(f->frcti);
while (timeo < 0) { /* keep the flow active for rtx */
- ssize_t ret;
- uint8_t buf[128];
+ ssize_t ret;
+ uint8_t buf[128];
+ struct timespec tic = {0, TICTIME};
f->oflags = FLOWFDEFAULT | FLOWFRNOPART;
f->rcv_timesout = true;
- f->rcv_timeo.tv_sec = -timeo;
- f->rcv_timeo.tv_nsec = 0;
+ f->rcv_timeo = tic;
pthread_rwlock_unlock(&ai.lock);
@@ -817,7 +817,7 @@ int flow_dealloc(int fd)
timeo = frcti_dealloc(f->frcti);
- if ((ret == -ETIMEDOUT || ret == -EFLOWDOWN) && timeo < 0)
+ if (ret == -EFLOWDOWN && timeo < 0)
timeo = -timeo;
}
@@ -1432,7 +1432,7 @@ ssize_t fevent(struct flow_set * set,
return -EINVAL;
if (fq->fqsize > 0 && fq->next != fq->fqsize)
- return fq->fqsize;
+ return 1;
clock_gettime(PTHREAD_COND_CLOCK, &abs);