moparisthebest/curl
1
0
Fork 0
mirror of https://github.com/moparisthebest/curl synced 2024-08-13 17:03:50 -04:00
Code Issues Releases Wiki Activity

multi: fix request timer management

Browse Source 
There are some bugs in how timers are managed for a single easy handle
that causes the wrong "next timeout" value to be reported to the
application when a new minimum needs to be recomputed and that new
minimum should be an existing timer that isn't currently set for the
easy handle.  When the application drives a set of easy handles via the
`curl_multi_socket_action()` API (for example), it gets told to wait the
wrong amount of time before the next call, which causes requests to
linger for a long time (or, it is my guess, possibly forever).

Bug: https://curl.haxx.se/mail/lib-2017-07/0033.html
This commit is contained in:
Brad Spencer 2017-07-29 16:44:39 +02:00 committed by Daniel Stenberg
parent 53d137d94a
commit 164a09368d
1 changed files with 13 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
lib/multi.c
View File

@ -2532,10 +2532,8 @@ static CURLMcode add_next_timeout(struct curltime now,
/* copy the first entry to 'tv' */ /* copy the first entry to 'tv' */
memcpy(tv, &node->time, sizeof(*tv)); memcpy(tv, &node->time, sizeof(*tv));
/* remove first entry from list */ /* Insert this node again into the splay. Keep the timer in the list in
Curl_llist_remove(list, e, NULL); case we need to recompute future timers. */
/* insert this node again into the splay */
multi->timetree = Curl_splayinsert(*tv, multi->timetree, multi->timetree = Curl_splayinsert(*tv, multi->timetree,
&d->state.timenode); &d->state.timenode);
} }
@ -2952,26 +2950,25 @@ void Curl_expire(struct Curl_easy *data, time_t milli, expire_id id)
set.tv_usec -= 1000000; set.tv_usec -= 1000000;
} }
/* Remove any timer with the same id just in case. */
multi_deltimeout(data, id);
/* Add it to the timer list. It must stay in the list until it has expired
in case we need to recompute the minimum timer later. */
multi_addtimeout(data, &set, id);
if(nowp->tv_sec || nowp->tv_usec) { if(nowp->tv_sec || nowp->tv_usec) {
/* This means that the struct is added as a node in the splay tree. /* This means that the struct is added as a node in the splay tree.
Compare if the new time is earlier, and only remove-old/add-new if it Compare if the new time is earlier, and only remove-old/add-new if it
is. */ is. */
time_t diff = curlx_tvdiff(set, *nowp); time_t diff = curlx_tvdiff(set, *nowp);
/* remove the previous timer first, if there */
multi_deltimeout(data, id);
if(diff > 0) { if(diff > 0) {
/* the new expire time was later so just add it to the queue /* The current splay tree entry is sooner than this new expiry time.
and get out */ We don't need to update our splay tree entry. */
multi_addtimeout(data, &set, id);
return; return;
} }
/* the new time is newer than the presently set one, so add the current
to the queue and update the head */
multi_addtimeout(data, nowp, id);
/* Since this is an updated time, we must remove the previous entry from /* Since this is an updated time, we must remove the previous entry from
the splay tree first and then re-add the new value */ the splay tree first and then re-add the new value */
rc = Curl_splayremovebyaddr(multi->timetree, rc = Curl_splayremovebyaddr(multi->timetree,
@ -2981,6 +2978,8 @@ void Curl_expire(struct Curl_easy *data, time_t milli, expire_id id)
infof(data, "Internal error removing splay node = %d\n", rc); infof(data, "Internal error removing splay node = %d\n", rc);
} }
/* Indicate that we are in the splay tree and insert the new timer expiry
value since it is our local minimum. */
*nowp = set; *nowp = set;
data->state.timenode.payload = data; data->state.timenode.payload = data;
multi->timetree = Curl_splayinsert(*nowp, multi->timetree, multi->timetree = Curl_splayinsert(*nowp, multi->timetree,