- Test cases 1051, 1052 and 1055 were added by Daniel Fandrich on July 30 and
proved how PUT and POST with a redirect could lead to a "hang" due to the data stream not being rewound properly when it had to in order to get sent properly (again) to the subsequent URL. This is now fixed and these test cases are no longer disabled.
This commit is contained in:
21
lib/http.c
21
lib/http.c
@@ -309,7 +309,7 @@ static bool pickoneauth(struct auth *pick)
|
||||
}
|
||||
|
||||
/*
|
||||
* perhapsrewind()
|
||||
* Curl_http_perhapsrewind()
|
||||
*
|
||||
* If we are doing POST or PUT {
|
||||
* If we have more data to send {
|
||||
@@ -331,18 +331,29 @@ static bool pickoneauth(struct auth *pick)
|
||||
* }
|
||||
* }
|
||||
*/
|
||||
static CURLcode perhapsrewind(struct connectdata *conn)
|
||||
CURLcode Curl_http_perhapsrewind(struct connectdata *conn)
|
||||
{
|
||||
struct SessionHandle *data = conn->data;
|
||||
struct HTTP *http = data->state.proto.http;
|
||||
curl_off_t bytessent;
|
||||
curl_off_t expectsend = -1; /* default is unknown */
|
||||
|
||||
if(!http)
|
||||
if(!http || !(conn->protocol & PROT_HTTP))
|
||||
/* If this is still NULL, we have not reach very far and we can
|
||||
safely skip this rewinding stuff */
|
||||
safely skip this rewinding stuff, or this is attempted to get used
|
||||
when HTTP isn't activated */
|
||||
return CURLE_OK;
|
||||
|
||||
infof(data, "now in %s\n", __func__);
|
||||
|
||||
switch(data->set.httpreq) {
|
||||
case HTTPREQ_GET:
|
||||
case HTTPREQ_HEAD:
|
||||
return CURLE_OK;
|
||||
default:
|
||||
break;
|
||||
}
|
||||
|
||||
bytessent = http->writebytecount;
|
||||
|
||||
if(conn->bits.authneg)
|
||||
@@ -453,7 +464,7 @@ CURLcode Curl_http_auth_act(struct connectdata *conn)
|
||||
if((data->set.httpreq != HTTPREQ_GET) &&
|
||||
(data->set.httpreq != HTTPREQ_HEAD) &&
|
||||
!conn->bits.rewindaftersend) {
|
||||
code = perhapsrewind(conn);
|
||||
code = Curl_http_perhapsrewind(conn);
|
||||
if(code)
|
||||
return code;
|
||||
}
|
||||
|
||||
@@ -8,7 +8,7 @@
|
||||
* | (__| |_| | _ <| |___
|
||||
* \___|\___/|_| \_\_____|
|
||||
*
|
||||
* Copyright (C) 1998 - 2007, Daniel Stenberg, <daniel@haxx.se>, et al.
|
||||
* Copyright (C) 1998 - 2008, Daniel Stenberg, <daniel@haxx.se>, et al.
|
||||
*
|
||||
* This software is licensed as described in the file COPYING, which
|
||||
* you should have received as part of this distribution. The terms
|
||||
@@ -57,6 +57,7 @@ void Curl_http_auth_stage(struct SessionHandle *data, int stage);
|
||||
CURLcode Curl_http_input_auth(struct connectdata *conn,
|
||||
int httpcode, const char *header);
|
||||
CURLcode Curl_http_auth_act(struct connectdata *conn);
|
||||
CURLcode Curl_http_perhapsrewind(struct connectdata *conn);
|
||||
|
||||
int Curl_http_should_fail(struct connectdata *conn);
|
||||
|
||||
|
||||
@@ -1116,6 +1116,12 @@ CURLcode Curl_readwrite(struct connectdata *conn,
|
||||
data->req.newurl = strdup(data->req.location); /* clone */
|
||||
if(!data->req.newurl)
|
||||
return CURLE_OUT_OF_MEMORY;
|
||||
|
||||
/* some cases of POST and PUT etc needs to rewind the data
|
||||
stream at this point */
|
||||
result = Curl_http_perhapsrewind(conn);
|
||||
if(result)
|
||||
return result;
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1570,6 +1576,7 @@ CURLcode Curl_readwrite(struct connectdata *conn,
|
||||
/* we've waited long enough, continue anyway */
|
||||
k->exp100 = EXP100_SEND_DATA;
|
||||
k->keepon |= KEEP_WRITE;
|
||||
infof(data, "Done waiting for 100-continue\n");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user