walkero
/
nghttp2
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

Cleanup nghttp2_session_next_data_read

This commit is contained in:
Tatsuhiro Tsujikawa 2013-11-12 10:48:29 +09:00
parent 5044b59453
commit a39a816a63
1 changed files with 8 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
lib/nghttp2_session.c
View File

@ -1005,23 +1005,18 @@ static int nghttp2_session_predicate_settings_send(nghttp2_session *session,
static size_t nghttp2_session_next_data_read(nghttp2_session *session, static size_t nghttp2_session_next_data_read(nghttp2_session *session,
nghttp2_stream *stream) nghttp2_stream *stream)
{ {
int32_t session_window_size; int32_t window_size = NGHTTP2_DATA_PAYLOAD_LENGTH;
int32_t stream_window_size;
int32_t window_size;
/* Take into account both connection-level flow control here */ /* Take into account both connection-level flow control here */
if(session->remote_flow_control == 0 && stream->remote_flow_control == 0) { if(session->remote_flow_control) {
return NGHTTP2_DATA_PAYLOAD_LENGTH; window_size = nghttp2_min(window_size, session->remote_window_size);
}
if(stream->remote_flow_control) {
window_size = nghttp2_min(window_size, stream->remote_window_size);
} }
session_window_size =
session->remote_flow_control ? session->remote_window_size : INT32_MAX;
stream_window_size =
stream->remote_flow_control ? stream->remote_window_size : INT32_MAX;
window_size = nghttp2_min(session_window_size, stream_window_size);
if(window_size > 0) { if(window_size > 0) {
return nghttp2_min(window_size, NGHTTP2_DATA_PAYLOAD_LENGTH); return window_size;
} else {
return 0;
} }
return 0;
} }
/* /*