Lines Matching refs:bucket
50 ev_token_bucket_init_(struct ev_token_bucket *bucket, in ev_token_bucket_init_() argument
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_()
63 if (bucket->write_limit > (ev_int64_t) cfg->write_maximum) in ev_token_bucket_init_()
64 bucket->write_limit = cfg->write_maximum; in ev_token_bucket_init_()
66 bucket->read_limit = cfg->read_rate; in ev_token_bucket_init_()
67 bucket->write_limit = cfg->write_rate; in ev_token_bucket_init_()
68 bucket->last_updated = current_tick; in ev_token_bucket_init_()
74 ev_token_bucket_update_(struct ev_token_bucket *bucket, in ev_token_bucket_update_() argument
80 unsigned n_ticks = current_tick - bucket->last_updated; in ev_token_bucket_update_()
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_()
102 if ((cfg->write_maximum - bucket->write_limit) / n_ticks < cfg->write_rate) in ev_token_bucket_update_()
103 bucket->write_limit = cfg->write_maximum; in ev_token_bucket_update_()
105 bucket->write_limit += n_ticks * cfg->write_rate; in ev_token_bucket_update_()
108 bucket->last_updated = current_tick; in ev_token_bucket_update_()