aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--lib/http.c13
-rw-r--r--lib/http2.c15
-rw-r--r--lib/url.c4
3 files changed, 17 insertions, 15 deletions
diff --git a/lib/http.c b/lib/http.c
index e4ff4010a..e16f6de5c 100644
--- a/lib/http.c
+++ b/lib/http.c
@@ -163,19 +163,6 @@ CURLcode Curl_http_setup_conn(struct connectdata *conn)
conn->data->req.protop = http;
- http->nread_header_recvbuf = 0;
- http->bodystarted = FALSE;
- http->status_code = -1;
- http->pausedata = NULL;
- http->pauselen = 0;
- http->error_code = NGHTTP2_NO_ERROR;
- http->closed = FALSE;
-
- /* where to store incoming data for this stream and how big the buffer is */
- http->mem = conn->data->state.buffer;
- http->len = BUFSIZE;
- http->memlen = 0;
-
Curl_http2_setup_conn(conn);
return CURLE_OK;
diff --git a/lib/http2.c b/lib/http2.c
index 961750c7e..867162a76 100644
--- a/lib/http2.c
+++ b/lib/http2.c
@@ -96,8 +96,23 @@ static CURLcode http2_disconnect(struct connectdata *conn,
/* called from Curl_http_setup_conn */
void Curl_http2_setup_conn(struct connectdata *conn)
{
+ struct HTTP *http = conn->data->req.protop;
+
conn->proto.httpc.settings.max_concurrent_streams =
DEFAULT_MAX_CONCURRENT_STREAMS;
+
+ http->nread_header_recvbuf = 0;
+ http->bodystarted = FALSE;
+ http->status_code = -1;
+ http->pausedata = NULL;
+ http->pauselen = 0;
+ http->error_code = NGHTTP2_NO_ERROR;
+ http->closed = FALSE;
+
+ /* where to store incoming data for this stream and how big the buffer is */
+ http->mem = conn->data->state.buffer;
+ http->len = BUFSIZE;
+ http->memlen = 0;
}
/*
diff --git a/lib/url.c b/lib/url.c
index 3425039de..bc342b0f9 100644
--- a/lib/url.c
+++ b/lib/url.c
@@ -3365,7 +3365,7 @@ ConnectionExists(struct SessionHandle *data,
infof(data, "Pipe is full, skip (%zu)\n", pipeLen);
continue;
}
-
+#ifdef USE_NGHTTP2
/* If multiplexed, make sure we don't go over concurrency limit */
if(check->bits.multiplex) {
/* Multiplexed connections can only be HTTP/2 for now */
@@ -3376,7 +3376,7 @@ ConnectionExists(struct SessionHandle *data,
continue;
}
}
-
+#endif
/* We can't use the connection if the pipe is penalized */
if(Curl_pipeline_penalized(data, check)) {
infof(data, "Penalized, skip\n");