aboutsummaryrefslogtreecommitdiff
path: root/lib/http2.c
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2015-05-20 23:11:43 +0900
committerDaniel Stenberg <daniel@haxx.se>2015-05-20 22:43:37 +0200
commitc175d184a2c254765d1a0d66978de4886b0a2ece (patch)
treeb0ecd1de471f97d43e4ad41f59f196512ac9615e /lib/http2.c
parentd5aab55b3353bec1d34a2e1434399d23db79b254 (diff)
http2: Faster http2 upload
Previously, when we send all given buffer in data_source_callback, we return NGHTTP2_ERR_DEFERRED, and nghttp2 library removes this stream temporarily for writing. This itself is good. If this is the sole stream in the session, nghttp2_session_want_write() returns zero, which means that libcurl does not check writeability of the underlying socket. This leads to very slow upload, because it seems curl only upload 16k something per 1 second. To fix this, if we still have data to send, call nghttp2_session_resume_data after nghttp2_session_send. This makes nghttp2_session_want_write() returns nonzero (if connection window still opens), and as a result, socket writeability is checked, and upload speed becomes normal.
Diffstat (limited to 'lib/http2.c')
-rw-r--r--lib/http2.c13
1 files changed, 13 insertions, 0 deletions
diff --git a/lib/http2.c b/lib/http2.c
index c653bbe17..df3fa9d1b 100644
--- a/lib/http2.c
+++ b/lib/http2.c
@@ -1024,6 +1024,19 @@ static ssize_t http2_send(struct connectdata *conn, int sockindex,
}
len -= stream->upload_len;
+ /* Nullify here because we call nghttp2_session_send() and they
+ might refer to the old buffer. */
+ stream->upload_mem = NULL;
+ stream->upload_len = 0;
+
+ if(stream->upload_left) {
+ /* we are sure that we have more data to send here. Calling the
+ following API will make nghttp2_session_want_write() return
+ nonzero if remote window allows it, which then libcurl checks
+ socket is writable or not. See http2_perform_getsock(). */
+ nghttp2_session_resume_data(h2, stream->stream_id);
+ }
+
DEBUGF(infof(conn->data, "http2_send returns %zu for stream %x\n", len,
stream->stream_id));
return len;