Lines Matching refs:bucket
53 /* called with bucket lock held */
66 /* called with bucket lock held */
111 struct token_bucket *bucket;
122 bucket = token_bucket(token);
123 spin_lock_bh(&bucket->lock);
124 if (__token_bucket_busy(bucket, token)) {
125 spin_unlock_bh(&bucket->lock);
129 hlist_nulls_add_head_rcu(&subflow_req->token_node, &bucket->req_chain);
130 bucket->chain_len++;
131 spin_unlock_bh(&bucket->lock);
157 struct token_bucket *bucket;
163 bucket = token_bucket(subflow->token);
164 spin_lock_bh(&bucket->lock);
165 if (__token_bucket_busy(bucket, subflow->token)) {
166 spin_unlock_bh(&bucket->lock);
176 __sk_nulls_add_node_rcu((struct sock *)msk, &bucket->msk_chain);
177 bucket->chain_len++;
178 spin_unlock_bh(&bucket->lock);
196 struct token_bucket *bucket;
199 bucket = token_bucket(req->token);
200 spin_lock_bh(&bucket->lock);
203 pos = __token_lookup_req(bucket, req->token);
206 __sk_nulls_add_node_rcu((struct sock *)msk, &bucket->msk_chain);
207 spin_unlock_bh(&bucket->lock);
213 struct token_bucket *bucket;
218 bucket = token_bucket(token);
221 sk_nulls_for_each_rcu(sk, pos, &bucket->msk_chain) {
249 struct token_bucket *bucket;
254 bucket = token_bucket(token);
257 sk_nulls_for_each_rcu(sk, pos, &bucket->msk_chain) {
305 struct token_bucket *bucket = &token_hash[slot];
310 if (hlist_nulls_empty(&bucket->msk_chain))
314 sk_nulls_for_each_rcu(sk, pos, &bucket->msk_chain) {
354 struct token_bucket *bucket;
359 bucket = token_bucket(subflow_req->token);
360 spin_lock_bh(&bucket->lock);
361 pos = __token_lookup_req(bucket, subflow_req->token);
364 bucket->chain_len--;
366 spin_unlock_bh(&bucket->lock);
378 struct token_bucket *bucket;
385 bucket = token_bucket(msk->token);
386 spin_lock_bh(&bucket->lock);
387 pos = __token_lookup_msk(bucket, msk->token);
390 bucket->chain_len--;
392 spin_unlock_bh(&bucket->lock);