• Home
  • Raw
  • Download

Lines Matching refs:bucket

112 	struct token_bucket *bucket;  in mptcp_token_new_request()  local
123 bucket = token_bucket(token); in mptcp_token_new_request()
124 spin_lock_bh(&bucket->lock); in mptcp_token_new_request()
125 if (__token_bucket_busy(bucket, token)) { in mptcp_token_new_request()
126 spin_unlock_bh(&bucket->lock); in mptcp_token_new_request()
130 hlist_nulls_add_head_rcu(&subflow_req->token_node, &bucket->req_chain); in mptcp_token_new_request()
131 bucket->chain_len++; in mptcp_token_new_request()
132 spin_unlock_bh(&bucket->lock); in mptcp_token_new_request()
157 struct token_bucket *bucket; in mptcp_token_new_connect() local
163 bucket = token_bucket(subflow->token); in mptcp_token_new_connect()
164 spin_lock_bh(&bucket->lock); in mptcp_token_new_connect()
165 if (__token_bucket_busy(bucket, subflow->token)) { in mptcp_token_new_connect()
166 spin_unlock_bh(&bucket->lock); in mptcp_token_new_connect()
176 __sk_nulls_add_node_rcu((struct sock *)msk, &bucket->msk_chain); in mptcp_token_new_connect()
177 bucket->chain_len++; in mptcp_token_new_connect()
178 spin_unlock_bh(&bucket->lock); in mptcp_token_new_connect()
194 struct token_bucket *bucket; in mptcp_token_accept() local
196 bucket = token_bucket(req->token); in mptcp_token_accept()
197 spin_lock_bh(&bucket->lock); in mptcp_token_accept()
200 pos = __token_lookup_req(bucket, req->token); in mptcp_token_accept()
203 __sk_nulls_add_node_rcu((struct sock *)msk, &bucket->msk_chain); in mptcp_token_accept()
204 spin_unlock_bh(&bucket->lock); in mptcp_token_accept()
210 struct token_bucket *bucket; in mptcp_token_exists() local
215 bucket = token_bucket(token); in mptcp_token_exists()
218 sk_nulls_for_each_rcu(sk, pos, &bucket->msk_chain) { in mptcp_token_exists()
246 struct token_bucket *bucket; in mptcp_token_get_sock() local
251 bucket = token_bucket(token); in mptcp_token_get_sock()
254 sk_nulls_for_each_rcu(sk, pos, &bucket->msk_chain) { in mptcp_token_get_sock()
302 struct token_bucket *bucket = &token_hash[slot]; in mptcp_token_iter_next() local
307 if (hlist_nulls_empty(&bucket->msk_chain)) in mptcp_token_iter_next()
311 sk_nulls_for_each_rcu(sk, pos, &bucket->msk_chain) { in mptcp_token_iter_next()
351 struct token_bucket *bucket; in mptcp_token_destroy_request() local
356 bucket = token_bucket(subflow_req->token); in mptcp_token_destroy_request()
357 spin_lock_bh(&bucket->lock); in mptcp_token_destroy_request()
358 pos = __token_lookup_req(bucket, subflow_req->token); in mptcp_token_destroy_request()
361 bucket->chain_len--; in mptcp_token_destroy_request()
363 spin_unlock_bh(&bucket->lock); in mptcp_token_destroy_request()
374 struct token_bucket *bucket; in mptcp_token_destroy() local
380 bucket = token_bucket(msk->token); in mptcp_token_destroy()
381 spin_lock_bh(&bucket->lock); in mptcp_token_destroy()
382 pos = __token_lookup_msk(bucket, msk->token); in mptcp_token_destroy()
385 bucket->chain_len--; in mptcp_token_destroy()
387 spin_unlock_bh(&bucket->lock); in mptcp_token_destroy()