Home
last modified time | relevance | path

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

12345678

/linux-6.3-rc2/net/mptcp/
A Dtoken.c111 struct token_bucket *bucket; in mptcp_token_new_request() local
122 bucket = token_bucket(token); in mptcp_token_new_request()
123 spin_lock_bh(&bucket->lock); in mptcp_token_new_request()
130 bucket->chain_len++; in mptcp_token_new_request()
157 struct token_bucket *bucket; in mptcp_token_new_connect() local
164 spin_lock_bh(&bucket->lock); in mptcp_token_new_connect()
177 bucket->chain_len++; in mptcp_token_new_connect()
196 struct token_bucket *bucket; in mptcp_token_accept() local
200 spin_lock_bh(&bucket->lock); in mptcp_token_accept()
364 bucket->chain_len--; in mptcp_token_destroy_request()
[all …]
/linux-6.3-rc2/net/ceph/crush/
A Dmapper.c88 s = crush_hash32_3(bucket->hash, x, bucket->id, 0) % in bucket_perm_choose()
89 bucket->size; in bucket_perm_choose()
113 i = crush_hash32_3(bucket->hash, x, bucket->id, p) % in bucket_perm_choose()
114 (bucket->size - p); in bucket_perm_choose()
131 return bucket->items[s]; in bucket_perm_choose()
148 __u64 w = crush_hash32_4(bucket->h.hash, x, bucket->h.items[i], in bucket_list_choose()
149 r, bucket->h.id); in bucket_list_choose()
153 i, x, r, bucket->h.items[i], bucket->item_weights[i], in bucket_list_choose()
164 return bucket->h.items[0]; in bucket_list_choose()
237 draw = crush_hash32_3(bucket->h.hash, x, bucket->h.items[i], r); in bucket_straw_choose()
[all …]
/linux-6.3-rc2/block/
A Dblk-stat.c56 int bucket, cpu; in blk_stat_add() local
70 bucket = cb->bucket_fn(rq); in blk_stat_add()
71 if (bucket < 0) in blk_stat_add()
84 unsigned int bucket; in blk_stat_timer_fn() local
87 for (bucket = 0; bucket < cb->buckets; bucket++) in blk_stat_timer_fn()
88 blk_rq_stat_init(&cb->stat[bucket]); in blk_stat_timer_fn()
94 for (bucket = 0; bucket < cb->buckets; bucket++) { in blk_stat_timer_fn()
95 blk_rq_stat_sum(&cb->stat[bucket], &cpu_stat[bucket]); in blk_stat_timer_fn()
96 blk_rq_stat_init(&cpu_stat[bucket]); in blk_stat_timer_fn()
140 unsigned int bucket; in blk_stat_add_callback() local
[all …]
A Dkyber-iosched.c218 unsigned int bucket; in flush_latency_buckets() local
220 for (bucket = 0; bucket < KYBER_LATENCY_BUCKETS; bucket++) in flush_latency_buckets()
221 buckets[bucket] += atomic_xchg(&cpu_buckets[bucket], 0); in flush_latency_buckets()
235 for (bucket = 0; bucket < KYBER_LATENCY_BUCKETS; bucket++) in calculate_percentile()
236 samples += buckets[bucket]; in calculate_percentile()
254 for (bucket = 0; bucket < KYBER_LATENCY_BUCKETS - 1; bucket++) { in calculate_percentile()
255 if (buckets[bucket] >= percentile_samples) in calculate_percentile()
257 percentile_samples -= buckets[bucket]; in calculate_percentile()
265 return bucket; in calculate_percentile()
626 unsigned int bucket; in add_latency_sample() local
[all …]
/linux-6.3-rc2/net/sched/
A Dsch_hhf.c333 bucket->head = skb->next; in dequeue_head()
341 if (bucket->head == NULL) in bucket_add()
342 bucket->head = skb; in bucket_add()
344 bucket->tail->next = skb; in bucket_add()
345 bucket->tail = skb; in bucket_add()
352 struct wdrr_bucket *bucket; in hhf_drop() local
356 if (!bucket->head) in hhf_drop()
359 if (bucket->head) { in hhf_drop()
381 bucket = &q->buckets[idx]; in hhf_enqueue()
382 bucket_add(bucket, skb); in hhf_enqueue()
[all …]
/linux-6.3-rc2/drivers/infiniband/sw/rdmavt/
A Dtrace_qp.h18 TP_PROTO(struct rvt_qp *qp, u32 bucket),
19 TP_ARGS(qp, bucket),
23 __field(u32, bucket)
28 __entry->bucket = bucket;
34 __entry->bucket
39 TP_PROTO(struct rvt_qp *qp, u32 bucket),
40 TP_ARGS(qp, bucket));
43 TP_PROTO(struct rvt_qp *qp, u32 bucket),
44 TP_ARGS(qp, bucket));
/linux-6.3-rc2/drivers/interconnect/qcom/
A Dbcm-voter.c64 size_t i, bucket; in bcm_aggregate() local
69 for (bucket = 0; bucket < QCOM_ICC_NUM_BUCKETS; bucket++) { in bcm_aggregate()
74 agg_avg[bucket] = max(agg_avg[bucket], temp); in bcm_aggregate()
78 agg_peak[bucket] = max(agg_peak[bucket], temp); in bcm_aggregate()
81 temp = agg_avg[bucket] * bcm->vote_scale; in bcm_aggregate()
82 bcm->vote_x[bucket] = bcm_div(temp, bcm->aux_data.unit); in bcm_aggregate()
84 temp = agg_peak[bucket] * bcm->vote_scale; in bcm_aggregate()
85 bcm->vote_y[bucket] = bcm_div(temp, bcm->aux_data.unit); in bcm_aggregate()
146 wait = commit && (voter->tcs_wait & BIT(bucket)); in tcs_list_gen()
148 tcs_cmd_gen(&tcs_list[idx], bcm->vote_x[bucket], in tcs_list_gen()
[all …]
/linux-6.3-rc2/fs/nfs/
A Dnfs42xattr.c238 entry->bucket = NULL; in nfs4_xattr_alloc_entry()
396 spin_lock(&bucket->lock); in nfs4_xattr_discard_cache()
397 bucket->draining = true; in nfs4_xattr_discard_cache()
534 entry->bucket = bucket; in nfs4_xattr_hash_add()
536 spin_lock(&bucket->lock); in nfs4_xattr_hash_add()
538 if (bucket->draining) { in nfs4_xattr_hash_add()
555 spin_unlock(&bucket->lock); in nfs4_xattr_hash_add()
571 spin_lock(&bucket->lock); in nfs4_xattr_hash_remove()
594 spin_lock(&bucket->lock); in nfs4_xattr_hash_find()
897 bucket = entry->bucket; in entry_lru_isolate()
[all …]
A Dpnfs_nfs.c65 if (list_empty(&bucket->committing) && list_empty(&bucket->written)) { in pnfs_free_bucket_lseg()
67 bucket->lseg = NULL; in pnfs_free_bucket_lseg()
91 if (bucket) in pnfs_generic_clear_request_commit()
414 lseg = pnfs_get_lseg(bucket->lseg); in pnfs_bucket_get_committing()
435 struct pnfs_commit_bucket *bucket; in pnfs_generic_retry_commit() local
439 for (bucket = buckets; idx < nbuckets; bucket++, idx++) { in pnfs_generic_retry_commit()
456 struct pnfs_commit_bucket *bucket; in pnfs_bucket_alloc_ds_commits() local
461 for (i = 0, bucket = buckets; i < nbuckets; i++, bucket++) { in pnfs_bucket_alloc_ds_commits()
1162 struct pnfs_commit_bucket *bucket; in pnfs_layout_mark_request_commit() local
1169 list = &bucket->written; in pnfs_layout_mark_request_commit()
[all …]
/linux-6.3-rc2/net/9p/
A Derror.c179 int bucket; in p9_error_init() local
182 for (bucket = 0; bucket < ERRHASHSZ; bucket++) in p9_error_init()
183 INIT_HLIST_HEAD(&hash_errmap[bucket]); in p9_error_init()
188 bucket = jhash(c->name, c->namelen, 0) % ERRHASHSZ; in p9_error_init()
190 hlist_add_head(&c->list, &hash_errmap[bucket]); in p9_error_init()
208 int bucket; in p9_errstr2errno() local
212 bucket = jhash(errstr, len, 0) % ERRHASHSZ; in p9_errstr2errno()
213 hlist_for_each_entry(c, &hash_errmap[bucket], list) { in p9_errstr2errno()
/linux-6.3-rc2/net/vmw_vsock/
A Ddiag.c52 unsigned int bucket; in vsock_diag_dump() local
63 bucket = cb->args[1]; in vsock_diag_dump()
72 while (bucket < ARRAY_SIZE(vsock_bind_table)) { in vsock_diag_dump()
73 struct list_head *head = &vsock_bind_table[bucket]; in vsock_diag_dump()
94 bucket++; in vsock_diag_dump()
98 bucket = 0; in vsock_diag_dump()
102 while (bucket < ARRAY_SIZE(vsock_connected_table)) { in vsock_diag_dump()
103 struct list_head *head = &vsock_connected_table[bucket]; in vsock_diag_dump()
128 bucket++; in vsock_diag_dump()
135 cb->args[1] = bucket; in vsock_diag_dump()
/linux-6.3-rc2/fs/dlm/
A Ddebug_fs.c370 unsigned bucket; member
432 bucket = n >> 32; in table_seq_start()
452 tree = toss ? &ls->ls_rsbtbl[bucket].toss : &ls->ls_rsbtbl[bucket].keep; in table_seq_start()
461 ri->bucket = bucket; in table_seq_start()
477 bucket++; in table_seq_start()
484 tree = toss ? &ls->ls_rsbtbl[bucket].toss : &ls->ls_rsbtbl[bucket].keep; in table_seq_start()
492 ri->bucket = bucket; in table_seq_start()
509 unsigned bucket; in table_seq_next() local
512 bucket = n >> 32; in table_seq_next()
542 bucket++; in table_seq_next()
[all …]
/linux-6.3-rc2/kernel/dma/
A Ddebug.c265 __releases(&bucket->lock) in put_hash_bucket()
555 struct hash_bucket *bucket; in add_dma_entry() local
560 hash_bucket_add(bucket, entry); in add_dma_entry()
561 put_hash_bucket(bucket, flags); in add_dma_entry()
946 struct hash_bucket *bucket; in check_unmap() local
1036 put_hash_bucket(bucket, flags); in check_unmap()
1079 struct hash_bucket *bucket; in check_sync() local
1146 put_hash_bucket(bucket, flags); in check_sync()
1231 struct hash_bucket *bucket; in debug_dma_mapping_error() local
1261 put_hash_bucket(bucket, flags); in debug_dma_mapping_error()
[all …]
/linux-6.3-rc2/drivers/cpuidle/governors/
A Dmenu.c114 unsigned int bucket; member
122 int bucket = 0; in which_bucket() local
131 bucket = BUCKETS/2; in which_bucket()
134 return bucket; in which_bucket()
136 return bucket + 1; in which_bucket()
138 return bucket + 2; in which_bucket()
140 return bucket + 3; in which_bucket()
142 return bucket + 4; in which_bucket()
143 return bucket + 5; in which_bucket()
308 data->correction_factor[data->bucket] + in menu_select()
[all …]
/linux-6.3-rc2/Documentation/userspace-api/media/v4l/
A Dpixfmt-meta-vsp1-hgt.rst28 The Saturation position **n** (0 - 31) of the bucket in the matrix is
33 The Hue position **m** (0 - 5) of the bucket in the matrix depends on
101 - :cspan:`4` Histogram bucket (m=0, n=0) [31:0]
103 - :cspan:`4` Histogram bucket (m=0, n=1) [31:0]
107 - :cspan:`4` Histogram bucket (m=0, n=31) [31:0]
109 - :cspan:`4` Histogram bucket (m=1, n=0) [31:0]
113 - :cspan:`4` Histogram bucket (m=2, n=0) [31:0]
117 - :cspan:`4` Histogram bucket (m=3, n=0) [31:0]
121 - :cspan:`4` Histogram bucket (m=4, n=0) [31:0]
125 - :cspan:`4` Histogram bucket (m=5, n=0) [31:0]
[all …]
/linux-6.3-rc2/fs/ocfs2/
A Dxattr.c328 if (bucket) { in ocfs2_xattr_bucket_new()
333 return bucket; in ocfs2_xattr_bucket_new()
348 if (bucket) { in ocfs2_xattr_bucket_free()
351 kfree(bucket); in ocfs2_xattr_bucket_free()
367 bucket->bu_bhs[i] = sb_getblk(bucket->bu_inode->i_sb, in ocfs2_init_xattr_bucket()
400 bucket->bu_blocks, bucket->bu_bhs, 0, in ocfs2_read_xattr_bucket()
444 bucket->bu_bhs, bucket->bu_blocks, in ocfs2_xattr_bucket_journal_dirty()
3977 if (!bucket) { in ocfs2_iterate_xattr_buckets()
5566 xs->bucket); in ocfs2_xattr_set_entry_bucket()
5810 bucket = xbs->bucket; in ocfs2_prepare_refcount_xattr()
[all …]
/linux-6.3-rc2/drivers/md/bcache/
A Dalloc.c76 uint8_t bch_inc_gen(struct cache *ca, struct bucket *b) in bch_inc_gen()
89 struct bucket *b; in bch_rescale_priorities()
181 struct bucket *b; in invalidate_buckets_lru()
218 struct bucket *b; in invalidate_buckets_fifo()
241 struct bucket *b; in invalidate_buckets_random()
307 if (fifo_push(&ca->free[RESERVE_PRIO], bucket)) in bch_allocator_push()
311 if (fifo_push(&ca->free[i], bucket)) in bch_allocator_push()
330 long bucket; in bch_allocator_thread() local
332 if (!fifo_pop(&ca->free_inc, bucket)) in bch_allocator_thread()
338 bucket_to_sector(ca->set, bucket), in bch_allocator_thread()
[all …]
/linux-6.3-rc2/drivers/md/
A Ddm-clone-target.c588 bucket = clone->ht + i; in hash_table_init()
883 bucket_lock_irq(bucket); in hydrate_bio_region()
889 bucket_unlock_irq(bucket); in hydrate_bio_region()
895 bucket_unlock_irq(bucket); in hydrate_bio_region()
904 bucket_unlock_irq(bucket); in hydrate_bio_region()
909 bucket_lock_irq(bucket); in hydrate_bio_region()
913 bucket_unlock_irq(bucket); in hydrate_bio_region()
923 bucket_unlock_irq(bucket); in hydrate_bio_region()
935 bucket_unlock_irq(bucket); in hydrate_bio_region()
949 bucket_unlock_irq(bucket); in hydrate_bio_region()
[all …]
/linux-6.3-rc2/net/rxrpc/
A Dproc.c245 unsigned int bucket, n; in rxrpc_peer_seq_start() local
255 bucket = *_pos >> shift; in rxrpc_peer_seq_start()
257 if (bucket >= HASH_SIZE(rxnet->peer_hash)) { in rxrpc_peer_seq_start()
262 if (bucket == 0) in rxrpc_peer_seq_start()
271 bucket++; in rxrpc_peer_seq_start()
273 *_pos = (bucket << shift) | n; in rxrpc_peer_seq_start()
280 unsigned int bucket, n; in rxrpc_peer_seq_next() local
287 bucket = *_pos >> shift; in rxrpc_peer_seq_next()
294 bucket++; in rxrpc_peer_seq_next()
296 *_pos = (bucket << shift) | n; in rxrpc_peer_seq_next()
[all …]
/linux-6.3-rc2/Documentation/networking/
A Dnexthop-group-resilient.rst49 to choose a hash table bucket, then reads the next hop that this bucket
92 through a bucket, this timer is updated to current jiffies value. One
104 upkeep changes the next hop that the bucket references to one of the
135 - Single-bucket notifications of the type
145 hop associated with the bucket was removed, and the bucket really must be
150 bucket should be migrated, but the HW discovers that the bucket has in fact
153 A second way for the HW to report that a bucket is busy is through the
212 ``NHA_RES_BUCKET_INDEX`` Index of bucket in the resilient table.
255 Changing next-hop weights leads to change in bucket allocation::
261 # ip nexthop bucket show id 10
[all …]
/linux-6.3-rc2/include/trace/events/
A Dbcache.h68 __field(size_t, bucket )
72 __entry->bucket = PTR_BUCKET_NR(b->c, &b->key, 0);
75 TP_printk("bucket %zu", __entry->bucket)
267 __field(size_t, bucket )
273 __entry->bucket = PTR_BUCKET_NR(b->c, &b->key, 0);
279 __entry->bucket, __entry->block, __entry->keys)
370 __field(size_t, bucket )
429 TP_PROTO(struct cache *ca, size_t bucket),
430 TP_ARGS(ca, bucket),
450 TP_PROTO(struct cache *ca, size_t bucket),
[all …]
/linux-6.3-rc2/kernel/bpf/
A Dstackmap.c233 bucket = READ_ONCE(smap->buckets[id]); in __bpf_get_stackid()
235 hash_matches = bucket && bucket->hash == hash; in __bpf_get_stackid()
251 if (hash_matches && bucket->nr == trace_nr && in __bpf_get_stackid()
261 if (hash_matches && bucket->nr == trace_nr && in __bpf_get_stackid()
262 memcmp(bucket->data, ips, trace_len) == 0) in __bpf_get_stackid()
264 if (bucket && !(flags & BPF_F_REUSE_STACKID)) in __bpf_get_stackid()
572 struct stack_map_bucket *bucket, *old_bucket; in bpf_stackmap_copy() local
578 bucket = xchg(&smap->buckets[id], NULL); in bpf_stackmap_copy()
579 if (!bucket) in bpf_stackmap_copy()
583 memcpy(value, bucket->data, trace_len); in bpf_stackmap_copy()
[all …]
/linux-6.3-rc2/lib/
A Dstackdepot.c337 static inline struct stack_record *find_stack(struct stack_record *bucket, in find_stack() argument
343 for (found = bucket; found; found = found->next) { in find_stack()
356 struct stack_record *found = NULL, **bucket; in __stack_depot_save() local
377 bucket = &stack_table[hash & stack_hash_mask]; in __stack_depot_save()
384 found = find_stack(smp_load_acquire(bucket), entries, nr_entries, hash); in __stack_depot_save()
411 found = find_stack(*bucket, entries, nr_entries, hash); in __stack_depot_save()
417 new->next = *bucket; in __stack_depot_save()
422 smp_store_release(bucket, new); in __stack_depot_save()
/linux-6.3-rc2/arch/sparc/kernel/
A Dirq_64.c207 struct ino_bucket bucket; member
258 struct ino_bucket *bucket; in cookie_exists() local
270 irq = bucket->__irq; in cookie_exists()
279 struct ino_bucket *bucket; in sysino_exists() local
282 bucket = &ivector_table[sysino]; in sysino_exists()
616 struct ino_bucket *bucket; in build_irq() local
623 bucket = &ivector_table[ino]; in build_irq()
688 ihd->bucket.__irq = irq; in cookie_assign()
689 cookie = ~__pa(&ihd->bucket); in cookie_assign()
739 struct ino_bucket *bucket; in sysino_set_bucket() local
[all …]
/linux-6.3-rc2/net/atm/
A Dproc.c69 int bucket; member
78 static int __vcc_walk(struct sock **sock, int family, int *bucket, loff_t l) in __vcc_walk() argument
83 for (*bucket = 0; *bucket < VCC_HTABLE_SIZE; ++*bucket) { in __vcc_walk()
84 struct hlist_head *head = &vcc_hash[*bucket]; in __vcc_walk()
98 if (!sk && ++*bucket < VCC_HTABLE_SIZE) { in __vcc_walk()
99 sk = sk_head(&vcc_hash[*bucket]); in __vcc_walk()
113 return __vcc_walk(&state->sk, family, &state->bucket, l) ? in vcc_walk()

Completed in 57 milliseconds

12345678