diff options
author | Daniel Stenberg <daniel@haxx.se> | 2003-10-07 21:54:04 +0000 |
---|---|---|
committer | Daniel Stenberg <daniel@haxx.se> | 2003-10-07 21:54:04 +0000 |
commit | 0436fbe226ca8ea71a751f4a86a228632e5cbc63 (patch) | |
tree | 5cf6478e89608a8000bd36014ba4032bcc9c0528 /ares/ares_timeout.c | |
parent | 6494889e3ba6b1432258f0a8ed402723607cff21 (diff) | |
download | curl-0436fbe226ca8ea71a751f4a86a228632e5cbc63.tar.gz |
ares 1.1.1 with collected applied patches
Diffstat (limited to 'ares/ares_timeout.c')
-rw-r--r-- | ares/ares_timeout.c | 67 |
1 files changed, 67 insertions, 0 deletions
diff --git a/ares/ares_timeout.c b/ares/ares_timeout.c new file mode 100644 index 000000000..3cb86f44a --- /dev/null +++ b/ares/ares_timeout.c @@ -0,0 +1,67 @@ +/* Copyright 1998 by the Massachusetts Institute of Technology. + * + * Permission to use, copy, modify, and distribute this + * software and its documentation for any purpose and without + * fee is hereby granted, provided that the above copyright + * notice appear in all copies and that both that copyright + * notice and this permission notice appear in supporting + * documentation, and that the name of M.I.T. not be used in + * advertising or publicity pertaining to distribution of the + * software without specific, written prior permission. + * M.I.T. makes no representations about the suitability of + * this software for any purpose. It is provided "as is" + * without express or implied warranty. + */ + +static const char rcsid[] = "$Id$"; + +#include <sys/types.h> + +#ifdef WIN32 + +#else +#include <sys/time.h> +#endif + +#include <time.h> +#include "ares.h" +#include "ares_private.h" + +struct timeval *ares_timeout(ares_channel channel, struct timeval *maxtv, + struct timeval *tvbuf) +{ + struct query *query; + time_t now; + int offset, min_offset; + + /* No queries, no timeout (and no fetch of the current time). */ + if (!channel->queries) + return maxtv; + + /* Find the minimum timeout for the current set of queries. */ + time(&now); + min_offset = -1; + for (query = channel->queries; query; query = query->next) + { + if (query->timeout == 0) + continue; + offset = query->timeout - now; + if (offset < 0) + offset = 0; + if (min_offset == -1 || offset < min_offset) + min_offset = offset; + } + + /* If we found a minimum timeout and it's sooner than the one + * specified in maxtv (if any), return it. Otherwise go with + * maxtv. + */ + if (min_offset != -1 && (!maxtv || min_offset <= maxtv->tv_sec)) + { + tvbuf->tv_sec = min_offset; + tvbuf->tv_usec = 0; + return tvbuf; + } + else + return maxtv; +} |