Searched refs:read_limit (Results 1 – 7 of 7) sorted by relevance
61 if (bucket->read_limit > (ev_int64_t) cfg->read_maximum) in ev_token_bucket_init_()62 bucket->read_limit = cfg->read_maximum; in ev_token_bucket_init_()66 bucket->read_limit = cfg->read_rate; in ev_token_bucket_init_()96 if ((cfg->read_maximum - bucket->read_limit) / n_ticks < cfg->read_rate) in ev_token_bucket_update_()97 bucket->read_limit = cfg->read_maximum; in ev_token_bucket_update_()99 bucket->read_limit += n_ticks * cfg->read_rate; in ev_token_bucket_update_()204 (is_write ? (x).write_limit : (x).read_limit) in bufferevent_get_rlim_max_()282 bev->rate_limiting->limit.read_limit -= bytes; in bufferevent_decrement_read_buckets_()283 if (bev->rate_limiting->limit.read_limit <= 0) { in bufferevent_decrement_read_buckets_()297 bev->rate_limiting->group->rate_limit.read_limit -= bytes; in bufferevent_decrement_read_buckets_()[all …]
41 ev_ssize_t read_limit, write_limit; member93 (b)->read_limit -= (n); \
210 size_t available_data = read_limit - pos; in copy_data_from_buf()223 read_limit = pos = 0; // Reset the pointers. in copy_data_from_buf()256 read_limit += fetched_size; in read_unlocked_fbf()299 if (read_limit == 0) { in ungetc_unlocked()309 ++read_limit; in ungetc_unlocked()341 offset -= (read_limit - pos); in seek()343 pos = read_limit = 0; in seek()362 return platform_offset - (read_limit - pos); in tell()
118 size_t read_limit; variable164 read_limit(0), eof(false), err(false) { in File()
64 mf->read_limit -= move_offset; in move_window()126 coder->mf.read_limit = coder->mf.write_pos; in fill_window()132 coder->mf.read_limit = coder->mf.write_pos in fill_window()138 && coder->mf.read_pos < coder->mf.read_limit) { in fill_window()171 >= coder->mf.read_limit) in lz_encode()398 mf->read_limit = 0; in lz_encoder_init()