Skip to content

Commit

Permalink
http2: Return error if stream was closed with other than NO_ERROR
Browse files Browse the repository at this point in the history
Previously, we just ignored error code passed to
on_stream_close_callback and just return 0 (success) after stream
closure even if stream was reset with error.  This patch records error
code in on_stream_close_callback, and return -1 and use CURLE_HTTP2
error code on abnormal stream closure.
  • Loading branch information
tatsuhiro-t authored and captain-caveman2k committed Feb 27, 2015
1 parent c715fa0 commit 48b5374
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 1 deletion.
3 changes: 2 additions & 1 deletion lib/http.h
Expand Up @@ -7,7 +7,7 @@
* | (__| |_| | _ <| |___
* \___|\___/|_| \_\_____|
*
* Copyright (C) 1998 - 2014, Daniel Stenberg, <daniel@haxx.se>, et al.
* Copyright (C) 1998 - 2015, 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
Expand Down Expand Up @@ -169,6 +169,7 @@ struct http_conn {
sending send_underlying; /* underlying send Curl_send callback */
recving recv_underlying; /* underlying recv Curl_recv callback */
bool closed; /* TRUE on HTTP2 stream close */
uint32_t error_code; /* HTTP/2 error code */
Curl_send_buffer *header_recvbuf; /* store response headers. We
store non-final and final
response headers into it. */
Expand Down
9 changes: 9 additions & 0 deletions lib/http2.c
Expand Up @@ -365,6 +365,7 @@ static int on_stream_close(nghttp2_session *session, int32_t stream_id,
return 0;
}

c->error_code = error_code;
c->closed = TRUE;

return 0;
Expand Down Expand Up @@ -783,6 +784,13 @@ static ssize_t http2_recv(struct connectdata *conn, int sockindex,
/* Reset to FALSE to prevent infinite loop in readwrite_data
function. */
httpc->closed = FALSE;
if(httpc->error_code != NGHTTP2_NO_ERROR) {
failf(conn->data,
"HTTP/2 stream = %x was not closed cleanly: error_code = %d",
httpc->stream_id, httpc->error_code);
*err = CURLE_HTTP2;
return -1;
}
return 0;
}
*err = CURLE_AGAIN;
Expand Down Expand Up @@ -980,6 +988,7 @@ CURLcode Curl_http2_setup(struct connectdata *conn)

infof(conn->data, "Using HTTP2\n");
httpc->bodystarted = FALSE;
httpc->error_code = NGHTTP2_NO_ERROR;
httpc->closed = FALSE;
httpc->header_recvbuf = Curl_add_buffer_init();
httpc->nread_header_recvbuf = 0;
Expand Down

0 comments on commit 48b5374

Please sign in to comment.