Home
last modified time | relevance | path

Searched refs:rate (Results 1 – 4 of 4) sorted by relevance

/unit/src/
H A Dnxt_stream_module.c93 nxt_event_write_rate_t *rate; in nxt_stream_connection_peer() local
95 rate = nxt_mp_get(c->mem_pool, sizeof(nxt_event_write_rate_t)); in nxt_stream_connection_peer()
97 if (nxt_slow_path(rate == NULL)) { in nxt_stream_connection_peer()
101 c->rate = rate; in nxt_stream_connection_peer()
103 rate->limit = 1024; in nxt_stream_connection_peer()
104 rate->limit_after = 0; in nxt_stream_connection_peer()
105 rate->average = rate->limit; in nxt_stream_connection_peer()
108 rate->last = engine->timers.now; in nxt_stream_connection_peer()
H A Dnxt_conn_write.c392 nxt_event_write_rate_t *rate; in nxt_event_conn_write_limit() local
394 rate = c->rate; in nxt_event_conn_write_limit()
396 if (rate == NULL) { in nxt_event_conn_write_limit()
400 limit = rate->limit; in nxt_event_conn_write_limit()
401 correction = limit - (size_t) rate->average; in nxt_event_conn_write_limit()
404 correction, rate->average); in nxt_event_conn_write_limit()
412 if (rate->limit_after != 0) { in nxt_event_conn_write_limit()
413 limit += rate->limit_after; in nxt_event_conn_write_limit()
414 limit = nxt_min((size_t) limit, rate->max_limit); in nxt_event_conn_write_limit()
H A Dnxt_event_conn_job_sendfile.c134 if (c->rate == NULL) { in nxt_event_conn_job_sendfile_handler()
H A Dnxt_conn.h133 nxt_event_write_rate_t *rate; member