Don't do fancy stuff yet
This commit is contained in:
parent
8f4e2d941f
commit
d4a22edeb3
|
@ -102,15 +102,13 @@ static int stream_push_item(nghttp2_stream *stream, nghttp2_session *session) {
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
item->cycle = session->last_cycle;
|
||||||
|
|
||||||
switch (item->frame.hd.type) {
|
switch (item->frame.hd.type) {
|
||||||
case NGHTTP2_DATA:
|
case NGHTTP2_DATA:
|
||||||
/* Penalize low weight stream */
|
|
||||||
item->cycle =
|
|
||||||
session->last_cycle + NGHTTP2_MAX_WEIGHT / stream->effective_weight;
|
|
||||||
rv = nghttp2_pq_push(&session->ob_da_pq, item);
|
rv = nghttp2_pq_push(&session->ob_da_pq, item);
|
||||||
break;
|
break;
|
||||||
case NGHTTP2_HEADERS:
|
case NGHTTP2_HEADERS:
|
||||||
item->cycle = session->last_cycle;
|
|
||||||
if (stream->state == NGHTTP2_STREAM_RESERVED) {
|
if (stream->state == NGHTTP2_STREAM_RESERVED) {
|
||||||
rv = nghttp2_pq_push(&session->ob_ss_pq, item);
|
rv = nghttp2_pq_push(&session->ob_ss_pq, item);
|
||||||
} else {
|
} else {
|
||||||
|
|
Loading…
Reference in New Issue