summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorStefan Eissing <stefan@eissing.org>2023-04-21 12:19:22 +0200
committerDaniel Stenberg <daniel@haxx.se>2023-04-25 17:50:45 +0200
commitfbea71f29338cbfd2161440ff94e8c0f2eeecbc8 (patch)
tree26f18f91a58c790c5f1203a5ec12d89a51d7f8ad
parentcab2d56ea52b3724495b3dbc5bfef3343d4ecadc (diff)
downloadcurl-fbea71f29338cbfd2161440ff94e8c0f2eeecbc8.tar.gz
http2: pass `stream` to http2_handle_stream_close to avoid NULL checks
Closes #11005
-rw-r--r--lib/http2.c10
1 files changed, 5 insertions, 5 deletions
diff --git a/lib/http2.c b/lib/http2.c
index 9da3cae17..39b80a1bf 100644
--- a/lib/http2.c
+++ b/lib/http2.c
@@ -1512,9 +1512,9 @@ out:
static ssize_t http2_handle_stream_close(struct Curl_cfilter *cf,
struct Curl_easy *data,
+ struct stream_ctx *stream,
CURLcode *err)
{
- struct stream_ctx *stream = H2_STREAM_CTX(data);
ssize_t rv = 0;
if(stream->error == NGHTTP2_REFUSED_STREAM) {
@@ -1675,7 +1675,7 @@ static ssize_t stream_recv(struct Curl_cfilter *cf, struct Curl_easy *data,
if(nread < 0) {
if(stream->closed) {
- nread = http2_handle_stream_close(cf, data, err);
+ nread = http2_handle_stream_close(cf, data, stream, err);
}
else if(stream->reset ||
(ctx->conn_closed && Curl_bufq_is_empty(&ctx->inbufq)) ||
@@ -1975,7 +1975,7 @@ static ssize_t cf_h2_send(struct Curl_cfilter *cf, struct Curl_easy *data,
goto out;
}
else if(stream->closed) {
- nwritten = http2_handle_stream_close(cf, data, err);
+ nwritten = http2_handle_stream_close(cf, data, stream, err);
goto out;
}
/* If stream_id != -1, we have dispatched request HEADERS, and now
@@ -2012,7 +2012,7 @@ static ssize_t cf_h2_send(struct Curl_cfilter *cf, struct Curl_easy *data,
if(should_close_session(ctx)) {
if(stream->closed) {
- nwritten = http2_handle_stream_close(cf, data, err);
+ nwritten = http2_handle_stream_close(cf, data, stream, err);
}
else {
DEBUGF(LOG_CF(data, cf, "send: nothing to do in this session"));
@@ -2062,7 +2062,7 @@ static ssize_t cf_h2_send(struct Curl_cfilter *cf, struct Curl_easy *data,
if(should_close_session(ctx)) {
if(stream->closed) {
- nwritten = http2_handle_stream_close(cf, data, err);
+ nwritten = http2_handle_stream_close(cf, data, stream, err);
}
else {
DEBUGF(LOG_CF(data, cf, "send: nothing to do in this session"));