ngx_queue_t frames;
ngx_queue_t sent;
-
- size_t frames_len;
} ngx_quic_send_ctx_t;
frame->len = ngx_quic_create_frame(NULL, frame);
/* always succeeds */
- ctx->frames_len += frame->len;
-
if (qc->closing) {
return;
}
- /* TODO: TCP_NODELAY analogue ? TCP_CORK and others... */
-
- if (ctx->frames_len < NGX_QUIC_MIN_DATA_NODELAY) {
- if (!qc->push.timer_set) {
- ngx_add_timer(&qc->push, qc->tp.max_ack_delay);
- }
-
- } else {
- ngx_post_event(&qc->push, &ngx_posted_events);
- }
+ ngx_post_event(&qc->push, &ngx_posted_events);
}
ngx_queue_remove(&f->queue);
ngx_queue_insert_tail(&range, &f->queue);
- ctx->frames_len -= f->len;
len += f->len;
#define NGX_QUIC_MIN_INITIAL_SIZE 1200
-/* if we have so much data, send immediately */
-/* TODO: configurable ? */
-#define NGX_QUIC_MIN_DATA_NODELAY 512 /* bytes */
-
#define NGX_QUIC_STREAM_SERVER_INITIATED 0x01
#define NGX_QUIC_STREAM_UNIDIRECTIONAL 0x02