aboutsummaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorDaniel Stenberg <daniel@haxx.se>2001-10-01 11:27:39 +0000
committerDaniel Stenberg <daniel@haxx.se>2001-10-01 11:27:39 +0000
commit09da90076f67725000e09d4c128fd052b31cd727 (patch)
treebadc58068db4c4c37675e97e8f000c2812699aed /lib
parentd0079d905495c841bdf2c9885837148caa438406 (diff)
moved the myalarm() usage, and now makes sure to switch it off after the
name resolving, as that should be the *ONLY* section in libcurl that may take a while in a synchronous call.
Diffstat (limited to 'lib')
-rw-r--r--lib/url.c66
1 files changed, 46 insertions, 20 deletions
diff --git a/lib/url.c b/lib/url.c
index ba6c36a6b..ec0e5110d 100644
--- a/lib/url.c
+++ b/lib/url.c
@@ -1116,11 +1116,7 @@ ConnectionStore(struct SessionHandle *data,
static CURLcode ConnectPlease(struct SessionHandle *data,
struct connectdata *conn)
{
-#if defined(WIN32)
- unsigned long nonblock = 0;
- fd_set connectfd;
- struct timeval conntimeout;
-#endif
+ long max_time=300000; /* milliseconds, default to five minutes */
#ifndef ENABLE_IPV6
conn->firstsocket = socket(AF_INET, SOCK_STREAM, 0);
@@ -1252,9 +1248,34 @@ static CURLcode ConnectPlease(struct SessionHandle *data,
#endif /*ENABLE_IPV6*/
/*************************************************************
+ * Figure out what maximum time we have left
+ *************************************************************/
+ if(data->set.timeout || data->set.connecttimeout) {
+ double has_passed;
+
+ /* Evaluate how much that that has passed */
+ has_passed = Curl_tvdiff(Curl_tvnow(), data->progress.start);
+
+#ifndef min
+#define min(a, b) ((a) < (b) ? (a) : (b))
+#endif
+
+ /* get the most strict timeout of the ones converted to milliseconds */
+ max_time = min(data->set.timeout, data->set.connecttimeout)*1000;
+
+ /* subtract the passed time */
+ max_time -= (long)(has_passed * 1000);
+
+ if(max_time < 0)
+ /* a precaution, no need to continue if time already is up */
+ return CURLE_OPERATION_TIMEOUTED;
+ }
+
+ /*************************************************************
* Connect to server/proxy
*************************************************************/
return Curl_connecthost(conn,
+ max_time,
conn->firstsocket, /* might be bind()ed */
&conn->firstsocket);
}
@@ -1643,21 +1664,6 @@ static CURLcode CreateConnection(struct SessionHandle *data,
}
/*************************************************************
- * Set timeout if that is being used
- *************************************************************/
- if(data->set.timeout || data->set.connecttimeout) {
- /* We set the timeout on the connection/resolving phase first, separately
- * from the download/upload part to allow a maximum time on everything */
-
- /* myalarm() makes a signal get sent when the timeout fires off, and that
- will abort system calls */
- if(data->set.connecttimeout)
- myalarm(data->set.connecttimeout);
- else
- myalarm(data->set.timeout);
- }
-
- /*************************************************************
* Setup internals depending on protocol
*************************************************************/
@@ -2055,6 +2061,23 @@ static CURLcode CreateConnection(struct SessionHandle *data,
}
/*************************************************************
+ * Set timeout if that is being used
+ *************************************************************/
+ if(data->set.timeout || data->set.connecttimeout) {
+ /* We set the timeout on the name resolving phase first, separately from
+ * the download/upload part to allow a maximum time on everything. This is
+ * a signal-based timeout, why it won't work and shouldn't be used in
+ * multi-threaded environments. */
+
+ /* myalarm() makes a signal get sent when the timeout fires off, and that
+ will abort system calls */
+ if(data->set.connecttimeout)
+ myalarm(data->set.connecttimeout);
+ else
+ myalarm(data->set.timeout);
+ }
+
+ /*************************************************************
* Resolve the name of the server or proxy
*************************************************************/
if(!data->change.proxy) {
@@ -2088,6 +2111,9 @@ static CURLcode CreateConnection(struct SessionHandle *data,
}
}
Curl_pgrsTime(data, TIMER_NAMELOOKUP);
+ if(data->set.timeout || data->set.connecttimeout)
+ /* switch off signal-based timeouts */
+ myalarm(0);
/*************************************************************
* Proxy authentication