mirror of
https://github.com/curl/curl.git
synced 2026-07-23 18:27:19 +03:00
ngtcp2: deal with stream close
This commit is contained in:
parent
e42bd8a204
commit
c47ef9115e
1 changed files with 10 additions and 1 deletions
|
|
@ -1217,12 +1217,16 @@ static int cb_h3_stream_close(nghttp3_conn *conn, int64_t stream_id,
|
|||
uint64_t app_error_code, void *user_data,
|
||||
void *stream_user_data)
|
||||
{
|
||||
struct Curl_easy *data = stream_user_data;
|
||||
struct HTTP *stream = data->req.protop;
|
||||
(void)conn;
|
||||
(void)stream_id;
|
||||
(void)app_error_code;
|
||||
(void)user_data;
|
||||
(void)stream_user_data;
|
||||
fprintf(stderr, "cb_h3_stream_close CALLED\n");
|
||||
|
||||
stream->closed = TRUE;
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
|
@ -1481,6 +1485,11 @@ static ssize_t ngh3_stream_recv(struct connectdata *conn,
|
|||
return stream->memlen;
|
||||
}
|
||||
|
||||
if(stream->closed) {
|
||||
*curlcode = CURLE_OK;
|
||||
return 0;
|
||||
}
|
||||
|
||||
infof(conn->data, "ngh3_stream_recv returns 0 bytes and EAGAIN\n");
|
||||
*curlcode = CURLE_AGAIN;
|
||||
return -1;
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue