Searched refs:buckets (Results 1 – 13 of 13) sorted by relevance
73 throttle_leak_bucket(&ts->cfg.buckets[i], delta_ns); in throttle_do_leak()159 wait = throttle_compute_wait(&ts->cfg.buckets[index]); in throttle_compute_wait_for()223 cfg->buckets[i].burst_length = 1; in throttle_config_init()303 if (cfg->buckets[i].avg > 0) { in throttle_enabled()322 bps_flag = cfg->buckets[THROTTLE_BPS_TOTAL].avg && in throttle_is_valid()323 (cfg->buckets[THROTTLE_BPS_READ].avg || in throttle_is_valid()324 cfg->buckets[THROTTLE_BPS_WRITE].avg); in throttle_is_valid()326 ops_flag = cfg->buckets[THROTTLE_OPS_TOTAL].avg && in throttle_is_valid()327 (cfg->buckets[THROTTLE_OPS_READ].avg || in throttle_is_valid()328 cfg->buckets[THROTTLE_OPS_WRITE].avg); in throttle_is_valid()[all …]
185 struct qht_bucket *buckets; member233 qht_bucket_debug__locked(&map->buckets[i]); in qht_map_debug__all_locked()262 unsigned long bucket_idx = b - map->buckets; in qht_do_if_first_in_stripe()278 unsigned long bucket_idx = b - map->buckets; in qht_bucket_lock_do()308 return &map->buckets[hash & (map->n_buckets - 1)]; in qht_map_to_bucket()317 struct qht_bucket *b = &map->buckets[i]; in qht_map_lock_buckets()328 struct qht_bucket *b = &map->buckets[i]; in qht_map_unlock_buckets()433 qht_chain_destroy(map, &map->buckets[i]); in qht_map_destroy()435 qemu_vfree(map->buckets); in qht_map_destroy()456 map->buckets = qemu_memalign(QHT_BUCKET_ALIGN, in qht_map_create()[all …]
43 bkt = cfg.buckets[THROTTLE_BPS_TOTAL]; in test_leak_bucket()92 bkt = cfg.buckets[THROTTLE_BPS_TOTAL]; in test_compute_wait()179 g_assert(!ts.cfg.buckets[i].avg); in test_init()180 g_assert(!ts.cfg.buckets[i].max); in test_init()181 g_assert(!ts.cfg.buckets[i].level); in test_init()211 g_assert(!ts.cfg.buckets[i].avg); in test_init_readonly()212 g_assert(!ts.cfg.buckets[i].max); in test_init_readonly()213 g_assert(!ts.cfg.buckets[i].level); in test_init_readonly()243 g_assert(!ts.cfg.buckets[i].avg); in test_init_writeonly()244 g_assert(!ts.cfg.buckets[i].max); in test_init_writeonly()[all …]
37 fst->cfg.buckets[THROTTLE_BPS_TOTAL].avg = in fsdev_throttle_parse_opts()39 fst->cfg.buckets[THROTTLE_BPS_READ].avg = in fsdev_throttle_parse_opts()41 fst->cfg.buckets[THROTTLE_BPS_WRITE].avg = in fsdev_throttle_parse_opts()43 fst->cfg.buckets[THROTTLE_OPS_TOTAL].avg = in fsdev_throttle_parse_opts()45 fst->cfg.buckets[THROTTLE_OPS_READ].avg = in fsdev_throttle_parse_opts()47 fst->cfg.buckets[THROTTLE_OPS_WRITE].avg = in fsdev_throttle_parse_opts()50 fst->cfg.buckets[THROTTLE_BPS_TOTAL].max = in fsdev_throttle_parse_opts()52 fst->cfg.buckets[THROTTLE_BPS_READ].max = in fsdev_throttle_parse_opts()54 fst->cfg.buckets[THROTTLE_BPS_WRITE].max = in fsdev_throttle_parse_opts()56 fst->cfg.buckets[THROTTLE_OPS_TOTAL].max = in fsdev_throttle_parse_opts()[all …]
439 cfg.buckets[THROTTLE_BPS_TOTAL].avg = arg->bps; in qmp_block_set_io_throttle()440 cfg.buckets[THROTTLE_BPS_READ].avg = arg->bps_rd; in qmp_block_set_io_throttle()441 cfg.buckets[THROTTLE_BPS_WRITE].avg = arg->bps_wr; in qmp_block_set_io_throttle()443 cfg.buckets[THROTTLE_OPS_TOTAL].avg = arg->iops; in qmp_block_set_io_throttle()444 cfg.buckets[THROTTLE_OPS_READ].avg = arg->iops_rd; in qmp_block_set_io_throttle()445 cfg.buckets[THROTTLE_OPS_WRITE].avg = arg->iops_wr; in qmp_block_set_io_throttle()448 cfg.buckets[THROTTLE_BPS_TOTAL].max = arg->bps_max; in qmp_block_set_io_throttle()451 cfg.buckets[THROTTLE_BPS_READ].max = arg->bps_rd_max; in qmp_block_set_io_throttle()454 cfg.buckets[THROTTLE_BPS_WRITE].max = arg->bps_wr_max; in qmp_block_set_io_throttle()457 cfg.buckets[THROTTLE_OPS_TOTAL].max = arg->iops_max; in qmp_block_set_io_throttle()[all …]
840 cfg->buckets[info->type].avg = value; in throttle_group_set()843 cfg->buckets[info->type].max = value; in throttle_group_set()851 cfg->buckets[info->type].burst_length = value; in throttle_group_set()870 value = cfg.buckets[info->type].avg; in throttle_group_get()873 value = cfg.buckets[info->type].max; in throttle_group_get()876 value = cfg.buckets[info->type].burst_length; in throttle_group_get()
45 + buckets = bucket(dists, lambda dist: bool(dist.metadata))46 + return itertools.chain(buckets[True], buckets[False])68 + """Wrap *iterable* and return an object that buckets the iterable into88 + If you specify a *validator* function, selected buckets will instead be
323 uint64_t orig = backend->tc.buckets[field].avg; in cryptodev_backend_set_throttle()330 backend->tc.buckets[field].avg = value; in cryptodev_backend_set_throttle()338 backend->tc.buckets[field].avg = orig; /* revert change */ in cryptodev_backend_set_throttle()357 uint64_t value = backend->tc.buckets[THROTTLE_BPS_TOTAL].avg; in cryptodev_backend_get_bps()379 uint64_t value = backend->tc.buckets[THROTTLE_OPS_TOTAL].avg; in cryptodev_backend_get_ops()408 value = backend->tc.buckets[THROTTLE_OPS_TOTAL].avg; in cryptodev_backend_complete()413 value = backend->tc.buckets[THROTTLE_BPS_TOTAL].avg; in cryptodev_backend_complete()
31 let buckets = hist[2];32 let dw = w * 1.0 / buckets.length;34 for (let i = 0; i < buckets.length; i++) {35 if (maxCount < buckets[i]) {36 maxCount = buckets[i];38 totalCount += buckets[i];47 for (let i = 0; i < buckets.length; i++) {48 const bucketsLen = buckets.length;49 if (buckets[i] > 0) {50 let dx0 = x + PAD2 + (w - 2 * PAD2) * 1.0 * i / buckets.length,[all …]
274 let buckets = [];275 for (let j = 0; j < num_buckets; j++) buckets.push(0);279 buckets[bucket_idx]++;281 line.push(buckets);
12 | make[1]: *** [buckets/apr_buckets.lo] Error 1
93 LeakyBucket buckets[BUCKETS_COUNT]; /* leaky buckets */ member
705 `Google Cloud Storage Bucket <https://cloud.google.com/storage/docs/buckets>`__.