Home
last modified time | relevance | path

Searched refs:bucket (Results 1 – 25 of 105) sorted by relevance

12345

/freebsd/sys/netinet6/
H A Dfrag6.c292 frag6_rmqueue(struct ip6q *q6, uint32_t bucket) in frag6_rmqueue() argument
294 IP6QB_LOCK_ASSERT(bucket); in frag6_rmqueue()
296 TAILQ_REMOVE(IP6QB_HEAD(bucket), q6, ip6q_tq); in frag6_rmqueue()
297 V_ip6qb[bucket].count--; in frag6_rmqueue()
309 frag6_freef(struct ip6q *q6, uint32_t bucket) in frag6_freef() argument
315 IP6QB_LOCK_ASSERT(bucket); in frag6_freef()
342 frag6_rmqueue(q6, bucket); in frag6_freef()
355 uint32_t bucket; in frag6_cleanup() local
371 for (bucket = 0; bucket < IP6REASS_NHASH; bucket++) { in frag6_cleanup()
372 IP6QB_LOCK(bucket); in frag6_cleanup()
[all …]
/freebsd/contrib/libarchive/libarchive/
H A Darchive_entry_link_resolver.c279 size_t hash, bucket; in find_entry() local
296 bucket = hash & (res->number_buckets - 1); in find_entry()
297 for (le = res->buckets[bucket]; le != NULL; le = le->next) { in find_entry()
315 if (res->buckets[bucket] == le) in find_entry()
316 res->buckets[bucket] = le->next; in find_entry()
330 size_t bucket; in next_entry() local
341 for (bucket = 0; bucket < res->number_buckets; bucket++) { in next_entry()
342 for (le = res->buckets[bucket]; le != NULL; le = le->next) { in next_entry()
355 res->buckets[bucket] = le->next; in next_entry()
370 size_t hash, bucket; in insert_entry() local
[all …]
H A Darchive_write_disk_set_standard_lookup.c52 struct bucket {
79 * but has a bad pathology in which it thrashes a single bucket. Even
86 struct bucket *ucache = calloc(cache_size, sizeof(struct bucket)); in archive_write_disk_set_standard_lookup()
87 struct bucket *gcache = calloc(cache_size, sizeof(struct bucket)); in archive_write_disk_set_standard_lookup()
102 struct bucket *b; in lookup_gid()
103 struct bucket *gcache = (struct bucket *)private_data; in lookup_gid()
171 struct bucket * in lookup_uid()
53 struct bucket { global() struct
54 namebucket global() argument
55 hashbucket global() argument
56 idbucket global() argument
[all...]
/freebsd/contrib/byacc/
H A Dsymtab.c10 static bucket **symbol_table = 0;
11 bucket *first_symbol;
12 bucket *last_symbol;
29 bucket *
32 bucket *bp; in make_bucket()
36 bp = TMALLOC(bucket, 1); in make_bucket()
62 bucket *
65 bucket *bp, **bpp; in lookup()
89 bucket *bp; in create_symbol_table()
91 symbol_table = TMALLOC(bucket *, TABLE_SIZE); in create_symbol_table()
[all …]
H A Ddefs.h213 typedef struct bucket bucket; typedef
214 struct bucket struct
216 struct bucket *link; argument
217 struct bucket *next; argument
388 extern bucket *first_symbol;
389 extern bucket *last_symbol;
593 extern bucket *make_bucket(const char *);
594 extern bucket *lookup(const char *);
H A Dreader.c46 static void start_rule(bucket *bp, int s_lineno);
80 static bucket *goal;
89 static bucket **pitem;
92 static bucket **plhs;
112 static bucket *default_destructor[3] =
119 static bucket *
124 bucket *bp, **bpp = &default_destructor[TYPE_SPECIFIED]; in lookup_type_destructor()
1430 static bucket *
1437 bucket *bp; in get_literal()
1629 static bucket *
[all …]
/freebsd/sys/vm/
H A Duma_core.c304 static void zone_free_bucket(uma_zone_t zone, uma_bucket_t bucket, void *udata,
467 uma_bucket_t bucket; in bucket_alloc() local
497 bucket = uma_zalloc_arg(ubz->ubz_zone, udata, flags); in bucket_alloc()
498 if (bucket) { in bucket_alloc()
500 bzero(bucket->ub_bucket, sizeof(void *) * ubz->ubz_entries); in bucket_alloc()
502 bucket->ub_cnt = 0; in bucket_alloc()
503 bucket->ub_entries = min(ubz->ubz_entries, in bucket_alloc()
505 bucket->ub_seq = SMR_SEQ_INVALID; in bucket_alloc()
507 zone->uz_name, zone, bucket); in bucket_alloc()
510 return (bucket); in bucket_alloc()
[all …]
/freebsd/sys/netpfil/ipfw/
H A Dip_fw_dynamic.c1051 uint32_t version, bucket; in dyn_lookup_ipv4_state() local
1053 bucket = DYN_BUCKET(info->hashval, V_curr_dyn_buckets); in dyn_lookup_ipv4_state()
1054 info->version = DYN_BUCKET_VERSION(bucket, ipv4_add); in dyn_lookup_ipv4_state()
1056 version = DYN_BUCKET_VERSION(bucket, ipv4_del); in dyn_lookup_ipv4_state()
1057 CK_SLIST_FOREACH(s, &V_dyn_ipv4[bucket], entry) { in dyn_lookup_ipv4_state()
1059 if (version != DYN_BUCKET_VERSION(bucket, ipv4_del)) in dyn_lookup_ipv4_state()
1089 const void *ulp, int pktlen, uint32_t bucket, uint32_t kidx) in dyn_lookup_ipv4_state_locked() argument
1095 DYN_BUCKET_ASSERT(bucket); in dyn_lookup_ipv4_state_locked()
1096 CK_SLIST_FOREACH(s, &V_dyn_ipv4[bucket], entry) { in dyn_lookup_ipv4_state_locked()
1122 uint32_t version, bucket; in dyn_lookup_ipv4_parent() local
[all …]
/freebsd/libexec/rtld-elf/
H A Drtld_malloc.c81 static void morecore(int bucket);
117 int bucket; in __crt_malloc() local
131 bucket = 0; in __crt_malloc()
134 bucket++; in __crt_malloc()
135 if (amt == 0 || bucket >= NBUCKETS) in __crt_malloc()
142 if ((op = nextf[bucket]) == NULL) { in __crt_malloc()
143 morecore(bucket); in __crt_malloc()
144 if ((op = nextf[bucket]) == NULL) in __crt_malloc()
148 nextf[bucket] = op->ov_next; in __crt_malloc()
150 op->ov_index = bucket; in __crt_malloc()
[all …]
/freebsd/contrib/jemalloc/src/
H A Dckh.c63 ckh_bucket_search(ckh_t *ckh, size_t bucket, const void *key) { in ckh_bucket_search() argument
68 cell = &ckh->tab[(bucket << LG_CKH_BUCKET_CELLS) + i]; in ckh_bucket_search()
70 return (bucket << LG_CKH_BUCKET_CELLS) + i; in ckh_bucket_search()
82 size_t hashes[2], bucket, cell; in ckh_isearch() local
89 bucket = hashes[0] & ((ZU(1) << ckh->lg_curbuckets) - 1); in ckh_isearch()
90 cell = ckh_bucket_search(ckh, bucket, key); in ckh_isearch()
96 bucket = hashes[1] & ((ZU(1) << ckh->lg_curbuckets) - 1); in ckh_isearch()
97 cell = ckh_bucket_search(ckh, bucket, key); in ckh_isearch()
102 ckh_try_bucket_insert(ckh_t *ckh, size_t bucket, const void *key, in ckh_try_bucket_insert() argument
114 cell = &ckh->tab[(bucket << LG_CKH_BUCKET_CELLS) + in ckh_try_bucket_insert()
[all …]
/freebsd/sys/cddl/contrib/opensolaris/uts/common/dtrace/
H A Dfasttrap.c386 fasttrap_bucket_t *bucket; in fasttrap_thread_dtor() local
395 bucket = &fasttrap_procs.fth_table[FASTTRAP_PROCS_INDEX(pid)]; in fasttrap_thread_dtor()
399 mutex_enter(&bucket->ftb_mtx); in fasttrap_thread_dtor()
400 for (fprc = bucket->ftb_data; fprc != NULL; fprc = fprc->ftpc_next) { in fasttrap_thread_dtor()
403 mutex_exit(&bucket->ftb_mtx); in fasttrap_thread_dtor()
408 mutex_exit(&bucket->ftb_mtx); in fasttrap_thread_dtor()
457 fasttrap_bucket_t *bucket; in fasttrap_pid_cleanup_cb() local
475 bucket = &fasttrap_provs.fth_table[i]; in fasttrap_pid_cleanup_cb()
476 mutex_enter(&bucket->ftb_mtx); in fasttrap_pid_cleanup_cb()
477 fpp = (fasttrap_provider_t **)&bucket->ftb_data; in fasttrap_pid_cleanup_cb()
[all …]
/freebsd/sys/netinet/
H A Dip_reass.c114 ipq_timeout(struct ipqbucket *bucket, struct ipq *fp) in ipq_timeout() argument
118 ipq_free(bucket, fp); in ipq_timeout()
122 ipq_drop(struct ipqbucket *bucket, struct ipq *fp) in ipq_drop() argument
126 ipq_free(bucket, fp); in ipq_drop()
127 ipreass_reschedule(bucket); in ipq_drop()
591 struct ipqbucket *bucket = arg; in ipreass_callout() local
594 IPQ_BUCKET_LOCK_ASSERT(bucket); in ipreass_callout()
597 CURVNET_SET(bucket->vnet); in ipreass_callout()
598 fp = TAILQ_LAST(&bucket->head, ipqhead); in ipreass_callout()
600 ("%s: stray callout on bucket %p, %ju < %ju", __func__, bucket, in ipreass_callout()
[all …]
/freebsd/contrib/tcsh/
H A Dtc.alloc.c181 int bucket = 0; in malloc() local
206 bucket++; in malloc()
211 if (nextf[bucket] == NULL) in malloc()
212 morecore(bucket); in malloc()
213 if ((p = nextf[bucket]) == NULL) { in malloc()
226 nextf[bucket] = nextf[bucket]->ov_next; in malloc()
228 p->ov_index = bucket; in malloc()
229 nmalloc[bucket]++; in malloc()
252 morecore(int bucket) in morecore() argument
259 if (nextf[bucket]) in morecore()
[all …]
/freebsd/sys/contrib/openzfs/cmd/zpool_influxdb/
H A Dzpool_influxdb.c427 for (int bucket = 0; bucket <= end; bucket++) { in print_vdev_latency_stats() local
428 if (bucket < MIN_LAT_INDEX) { in print_vdev_latency_stats()
431 lat_type[i].sum += lat_type[i].array[bucket]; in print_vdev_latency_stats()
435 if (bucket < end) { in print_vdev_latency_stats()
438 (float)(1ULL << bucket) * 1e-9, in print_vdev_latency_stats()
446 if (bucket <= MIN_LAT_INDEX || sum_histogram_buckets) { in print_vdev_latency_stats()
447 lat_type[i].sum += lat_type[i].array[bucket]; in print_vdev_latency_stats()
449 lat_type[i].sum = lat_type[i].array[bucket]; in print_vdev_latency_stats()
524 for (int bucket = 0; bucket <= end; bucket++) { in print_vdev_size_stats() local
525 if (bucket < MIN_SIZE_INDEX) { in print_vdev_size_stats()
[all …]
/freebsd/sys/dev/vmware/vmci/
H A Dvmci_doorbell.c91 uint32_t bucket; in vmci_doorbell_init() local
93 for (bucket = 0; bucket < ARRAYSIZE(vmci_doorbell_it.entries); in vmci_doorbell_init()
94 ++bucket) in vmci_doorbell_init()
95 vmci_list_init(&vmci_doorbell_it.entries[bucket]); in vmci_doorbell_init()
251 uint32_t bucket; in vmci_doorbell_index_table_find() local
253 bucket = VMCI_DOORBELL_HASH(idx); in vmci_doorbell_index_table_find()
255 vmci_list_scan(iter, &vmci_doorbell_it.entries[bucket], idx_list_item) { in vmci_doorbell_index_table_find()
284 uint32_t bucket; in vmci_doorbell_index_table_add() local
333 bucket = VMCI_DOORBELL_HASH(entry->idx); in vmci_doorbell_index_table_add()
334 vmci_list_insert(&vmci_doorbell_it.entries[bucket], entry, in vmci_doorbell_index_table_add()
[all …]
/freebsd/cddl/contrib/opensolaris/tools/ctf/cvt/
H A Dhash.c109 int bucket = hash->h_hashfn(hash->h_nbuckets, key); in hash_add() local
111 list_add(&hash->h_buckets[bucket], key); in hash_add()
137 int bucket = hash->h_hashfn(hash->h_nbuckets, key); in hash_remove() local
139 (void) list_remove(&hash->h_buckets[bucket], key, in hash_remove()
147 int bucket = hash->h_hashfn(hash->h_nbuckets, key); in hash_match() local
149 return (list_iter(hash->h_buckets[bucket], fun, private) < 0); in hash_match()
172 int bucket = hash->h_hashfn(hash->h_nbuckets, key); in hash_find_iter() local
180 return (list_iter(hash->h_buckets[bucket], hash_find_list_cb, in hash_find_iter()
/freebsd/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/java_api/src/
H A DTestBean.java208 Distribution.Bucket bucket; in getLogDistribution() local
220 bucket = new Distribution.Bucket(-1, -1, n++); in getLogDistribution()
221 buckets.add(bucket); in getLogDistribution()
222 bucket = new Distribution.Bucket(0, 0, n++); in getLogDistribution()
223 buckets.add(bucket); in getLogDistribution()
224 bucket = new Distribution.Bucket(1, 1, n++); in getLogDistribution()
225 buckets.add(bucket); in getLogDistribution()
238 bucket = new Distribution.Bucket(lowerBound, upperBound, n++); in getLogDistribution()
239 buckets.add(bucket); in getLogDistribution()
250 Distribution.Bucket bucket; in getLinearDistribution() local
[all …]
/freebsd/libexec/bootpd/
H A Dhash.c318 unsigned bucket; in hash_NextEntry() local
333 bucket = hashtable->bucketnum + 1; in hash_NextEntry()
334 while ((bucket < hashtable->size) && in hash_NextEntry()
335 !(memberptr = (hashtable->table)[bucket])) { in hash_NextEntry()
336 bucket++; in hash_NextEntry()
342 if (bucket >= hashtable->size) { in hash_NextEntry()
356 hashtable->bucketnum = bucket; in hash_NextEntry()
/freebsd/sys/contrib/openzfs/module/zfs/
H A Dddt_stats.c116 int bucket; in ddt_histogram_add_entry() local
120 bucket = highbit64(dds.dds_ref_blocks) - 1; in ddt_histogram_add_entry()
121 if (bucket < 0) in ddt_histogram_add_entry()
124 ddt_stat_add(&ddh->ddh_stat[bucket], &dds); in ddt_histogram_add_entry()
132 int bucket; in ddt_histogram_sub_entry() local
136 bucket = highbit64(dds.dds_ref_blocks) - 1; in ddt_histogram_sub_entry()
137 if (bucket < 0) in ddt_histogram_sub_entry()
140 ddt_stat_sub(&ddh->ddh_stat[bucket], &dds); in ddt_histogram_sub_entry()
/freebsd/contrib/ntp/sntp/libevent/
H A Dbufferevent_ratelim.c50 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_()
[all …]
/freebsd/contrib/libevent/
H A Dbufferevent_ratelim.c50 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_()
[all …]
/freebsd/sys/netgraph/
H A Dng_bridge.c638 int i = 0, bucket; in ng_bridge_rcvmsg() local
648 for (bucket = 0; bucket < priv->numBuckets; bucket++) { in ng_bridge_rcvmsg()
649 SLIST_FOREACH(host, &priv->tab[bucket], next) { in ng_bridge_rcvmsg()
1011 const int bucket = HASH(addr, priv->hashMask); in ng_bridge_get() local
1014 SLIST_FOREACH(host, &priv->tab[bucket], next) { in ng_bridge_get()
1028 const int bucket = HASH(addr, priv->hashMask); in ng_bridge_put() local
1072 SLIST_INSERT_HEAD(&priv->tab[bucket], host, next); in ng_bridge_put()
1163 int bucket; in ng_bridge_remove_hosts() local
1165 for (bucket = 0; bucket < priv->numBuckets; bucket++) { in ng_bridge_remove_hosts()
1166 struct ng_bridge_host **hptr = &SLIST_FIRST(&priv->tab[bucket]); in ng_bridge_remove_hosts()
[all …]
/freebsd/lib/librss/
H A Dlibrss.c218 int bucket, cpuset_t *cs) in rss_get_bucket_cpuset() argument
221 if (bucket < 0 || bucket >= rc->rss_nbuckets) { in rss_get_bucket_cpuset()
237 CPU_SET(rc->rss_bucket_map[bucket], cs); in rss_get_bucket_cpuset()
/freebsd/sys/contrib/ck/src/
H A Dck_epoch.c155 unsigned int i = section->bucket; in CK_STACK_CONTAINER()
157 current = &record->local.bucket[i]; in CK_STACK_CONTAINER()
172 other = &record->local.bucket[(i + 1) & CK_EPOCH_SENSE_MASK]; in CK_STACK_CONTAINER()
195 ref = &record->local.bucket[i]; in _ck_epoch_addref()
211 previous = &record->local.bucket[(i + 1) & in _ck_epoch_addref()
224 section->bucket = i; in _ck_epoch_addref()
/freebsd/usr.sbin/pmcstat/
H A Dpmcpl_gprof.c417 uintfptr_t bucket; in pmcpl_gmon_process() local
498 bucket = (cc[0] - map->ppm_lowpc) / FUNCTION_ALIGNMENT; in pmcpl_gmon_process()
500 assert(bucket < pgf->pgf_nbuckets); in pmcpl_gmon_process()
507 if (whc[bucket] < WIDEHISTCOUNTER_MAX) in pmcpl_gmon_process()
508 whc[bucket]++; in pmcpl_gmon_process()
516 if (hc[bucket] < HISTCOUNTER_MAX) in pmcpl_gmon_process()
517 hc[bucket]++; in pmcpl_gmon_process()

12345