diff options
| author | Daniel Stenberg <daniel@haxx.se> | 2015-05-11 14:18:53 +0200 |
|---|---|---|
| committer | Daniel Stenberg <daniel@haxx.se> | 2015-05-18 09:33:47 +0200 |
| commit | 61a94d6f77f78c72e15e34910dd4e0e035bc7bc7 (patch) | |
| tree | a36072c8439d97d29dde71babbff814cbb3e9178 /lib | |
| parent | 56c362b1a7fadc854ed39c525f704de3124d9502 (diff) | |
http2: Curl_expire() all handles with incoming traffic
... so that they'll get handled next in the multi loop.
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/http2.c | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/lib/http2.c b/lib/http2.c index 4eb842a61..0167ef9be 100644 --- a/lib/http2.c +++ b/lib/http2.c @@ -287,6 +287,7 @@ static int on_frame_recv(nghttp2_session *session, const nghttp2_frame *frame, stream->memlen += ncopy; data_s->state.drain++; + Curl_expire(data_s, 1); break; case NGHTTP2_PUSH_PROMISE: DEBUGF(infof(data_s, "Got PUSH_PROMISE, RST_STREAM it!\n")); @@ -375,8 +376,8 @@ static int on_data_chunk_recv(nghttp2_session *session, uint8_t flags, stream->memlen += nread; data_s->state.drain++; - /* TODO: this may need to set expire for the multi_socket to work for this - stream */ + Curl_expire(data_s, 1); /* TODO: fix so that this can be set to 0 for + immediately? */ DEBUGF(infof(data_s, "%zu data received for stream %x " "(%zu left in buffer %p, total %zu)\n", @@ -578,6 +579,7 @@ static int on_header(nghttp2_session *session, const nghttp2_frame *frame, Curl_add_buffer(stream->header_recvbuf, value, valuelen); Curl_add_buffer(stream->header_recvbuf, "\r\n", 2); data_s->state.drain++; + Curl_expire(data_s, 1); DEBUGF(infof(data_s, "h2 status: HTTP/2 %03d\n", stream->status_code)); @@ -603,6 +605,7 @@ static int on_header(nghttp2_session *session, const nghttp2_frame *frame, Curl_add_buffer(stream->header_recvbuf, value, valuelen); Curl_add_buffer(stream->header_recvbuf, "\r\n", 2); data_s->state.drain++; + Curl_expire(data_s, 1); DEBUGF(infof(data_s, "h2 header: %.*s: %.*s\n", namelen, name, valuelen, value)); |