| /net/mptcp/ |
| D | pm.c | 17 int mptcp_pm_announce_addr(struct mptcp_sock *msk, in mptcp_pm_announce_addr() argument
21 u8 add_addr = READ_ONCE(msk->pm.addr_signal); in mptcp_pm_announce_addr()
23 pr_debug("msk=%p, local_id=%d, echo=%d", msk, addr->id, echo); in mptcp_pm_announce_addr()
25 lockdep_assert_held(&msk->pm.lock); in mptcp_pm_announce_addr()
34 msk->pm.remote = *addr; in mptcp_pm_announce_addr()
37 msk->pm.local = *addr; in mptcp_pm_announce_addr()
40 WRITE_ONCE(msk->pm.addr_signal, add_addr); in mptcp_pm_announce_addr()
44 int mptcp_pm_remove_addr(struct mptcp_sock *msk, const struct mptcp_rm_list *rm_list) in mptcp_pm_remove_addr() argument
46 u8 rm_addr = READ_ONCE(msk->pm.addr_signal); in mptcp_pm_remove_addr()
48 pr_debug("msk=%p, rm_list_nr=%d", msk, rm_list->nr); in mptcp_pm_remove_addr()
[all …]
|
| D | protocol.c | 33 struct mptcp_sock msk; member
63 struct socket *__mptcp_nmpc_socket(const struct mptcp_sock *msk) in __mptcp_nmpc_socket() argument
65 if (!msk->subflow || READ_ONCE(msk->can_ack)) in __mptcp_nmpc_socket()
68 return msk->subflow; in __mptcp_nmpc_socket()
72 static u64 mptcp_wnd_end(const struct mptcp_sock *msk) in mptcp_wnd_end() argument
74 return READ_ONCE(msk->wnd_end); in mptcp_wnd_end()
101 static int __mptcp_socket_create(struct mptcp_sock *msk) in __mptcp_socket_create() argument
104 struct sock *sk = (struct sock *)msk; in __mptcp_socket_create()
112 msk->first = ssock->sk; in __mptcp_socket_create()
113 msk->subflow = ssock; in __mptcp_socket_create()
[all …]
|
| D | pm_netlink.c | 163 struct mptcp_sock *msk) in select_local_address() argument
166 struct sock *sk = (struct sock *)msk; in select_local_address()
168 msk_owned_by_me(msk); in select_local_address()
171 __mptcp_flush_join_list(msk); in select_local_address()
189 if (!lookup_subflow_by_saddr(&msk->conn_list, &entry->addr)) { in select_local_address()
222 unsigned int mptcp_pm_get_add_addr_signal_max(struct mptcp_sock *msk) in mptcp_pm_get_add_addr_signal_max() argument
226 pernet = net_generic(sock_net((struct sock *)msk), pm_nl_pernet_id); in mptcp_pm_get_add_addr_signal_max()
231 unsigned int mptcp_pm_get_add_addr_accept_max(struct mptcp_sock *msk) in mptcp_pm_get_add_addr_accept_max() argument
235 pernet = net_generic(sock_net((struct sock *)msk), pm_nl_pernet_id); in mptcp_pm_get_add_addr_accept_max()
240 unsigned int mptcp_pm_get_subflows_max(struct mptcp_sock *msk) in mptcp_pm_get_subflows_max() argument
[all …]
|
| D | sockopt.c | 17 static struct sock *__mptcp_tcp_fallback(struct mptcp_sock *msk) in __mptcp_tcp_fallback() argument
19 sock_owned_by_me((const struct sock *)msk); in __mptcp_tcp_fallback()
21 if (likely(!__mptcp_check_fallback(msk))) in __mptcp_tcp_fallback()
24 return msk->first; in __mptcp_tcp_fallback()
48 static void sockopt_seq_inc(struct mptcp_sock *msk) in sockopt_seq_inc() argument
50 u32 seq = (msk->setsockopt_seq + 1) & 0x00ffffff; in sockopt_seq_inc()
52 msk->setsockopt_seq = sockopt_seq_reset((struct sock *)msk) + seq; in sockopt_seq_inc()
55 static int mptcp_get_int_option(struct mptcp_sock *msk, sockptr_t optval, in mptcp_get_int_option() argument
67 static void mptcp_sol_socket_sync_intval(struct mptcp_sock *msk, int optname, int val) in mptcp_sol_socket_sync_intval() argument
70 struct sock *sk = (struct sock *)msk; in mptcp_sol_socket_sync_intval()
[all …]
|
| D | protocol.h | 295 static inline void msk_owned_by_me(const struct mptcp_sock *msk) in msk_owned_by_me() argument
297 sock_owned_by_me((const struct sock *)msk); in msk_owned_by_me()
320 const struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_send_head() local
322 return READ_ONCE(msk->first_pending); in mptcp_send_head()
327 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_send_next() local
330 cur = msk->first_pending; in mptcp_send_next()
331 return list_is_last(&cur->list, &msk->rtx_queue) ? NULL : in mptcp_send_next()
337 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_pending_tail() local
339 if (!msk->first_pending) in mptcp_pending_tail()
342 if (WARN_ON_ONCE(list_empty(&msk->rtx_queue))) in mptcp_pending_tail()
[all …]
|
| D | token_test.c | 54 struct mptcp_sock *msk; in build_msk() local
56 msk = kunit_kzalloc(test, sizeof(struct mptcp_sock), GFP_USER); in build_msk()
57 KUNIT_EXPECT_NOT_ERR_OR_NULL(test, msk); in build_msk()
58 refcount_set(&((struct sock *)msk)->sk_refcnt, 1); in build_msk()
59 sock_net_set((struct sock *)msk, &init_net); in build_msk()
60 return msk; in build_msk()
67 struct mptcp_sock *msk = build_msk(test); in mptcp_token_test_msk_basic() local
72 ctx->conn = (struct sock *)msk; in mptcp_token_test_msk_basic()
73 sk = (struct sock *)msk; in mptcp_token_test_msk_basic()
78 KUNIT_EXPECT_EQ(test, ctx->token, msk->token); in mptcp_token_test_msk_basic()
[all …]
|
| D | mptcp_diag.c | 32 struct mptcp_sock *msk = NULL; in mptcp_diag_dump_one() local
39 msk = mptcp_token_get_sock(net, req->id.idiag_cookie[0]); in mptcp_diag_dump_one()
40 if (!msk) in mptcp_diag_dump_one()
44 sk = (struct sock *)msk; in mptcp_diag_dump_one()
156 struct mptcp_sock *msk; in mptcp_diag_dump() local
164 while ((msk = mptcp_token_iter_next(net, &diag_ctx->s_slot, in mptcp_diag_dump()
166 struct inet_sock *inet = (struct inet_sock *)msk; in mptcp_diag_dump()
167 struct sock *sk = (struct sock *)msk; in mptcp_diag_dump()
200 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_diag_get_info() local
210 struct sock *lsk = READ_ONCE(msk->first); in mptcp_diag_get_info()
[all …]
|
| D | options.c | 442 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_mp() local
474 opts->csum_reqd = READ_ONCE(msk->csum_enabled); in mptcp_established_options_mp()
556 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_dss() local
563 opts->csum_reqd = READ_ONCE(msk->csum_enabled); in mptcp_established_options_dss()
588 if (!READ_ONCE(msk->can_ack)) { in mptcp_established_options_dss()
593 ack_seq = READ_ONCE(msk->ack_seq); in mptcp_established_options_dss()
594 if (READ_ONCE(msk->use_64bit_ack)) { in mptcp_established_options_dss()
605 WRITE_ONCE(msk->old_wspace, __mptcp_space((struct sock *)msk)); in mptcp_established_options_dss()
650 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_add_addr() local
660 if (!mptcp_pm_should_add_signal(msk) || in mptcp_established_options_add_addr()
[all …]
|
| D | subflow.c | 44 if (subflow_req->msk) in subflow_req_destructor()
45 sock_put((struct sock *)subflow_req->msk); in subflow_req_destructor()
61 static bool mptcp_can_accept_new_subflow(const struct mptcp_sock *msk) in mptcp_can_accept_new_subflow() argument
63 return mptcp_is_fully_established((void *)msk) && in mptcp_can_accept_new_subflow()
64 READ_ONCE(msk->pm.accept_subflow); in mptcp_can_accept_new_subflow()
70 struct mptcp_sock *msk = subflow_req->msk; in subflow_req_create_thmac() local
75 subflow_generate_hmac(msk->local_key, msk->remote_key, in subflow_req_create_thmac()
85 struct mptcp_sock *msk; in subflow_token_join_request() local
88 msk = mptcp_token_get_sock(sock_net(req_to_sk(req)), subflow_req->token); in subflow_token_join_request()
89 if (!msk) { in subflow_token_join_request()
[all …]
|
| D | token.c | 154 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_token_new_connect() local
174 WRITE_ONCE(msk->token, subflow->token); in mptcp_token_new_connect()
175 __sk_nulls_add_node_rcu((struct sock *)msk, &bucket->msk_chain); in mptcp_token_new_connect()
190 struct mptcp_sock *msk) in mptcp_token_accept() argument
202 __sk_nulls_add_node_rcu((struct sock *)msk, &bucket->msk_chain); in mptcp_token_accept()
210 struct mptcp_sock *msk; in mptcp_token_exists() local
218 msk = mptcp_sk(sk); in mptcp_token_exists()
219 if (READ_ONCE(msk->token) == token) in mptcp_token_exists()
246 struct mptcp_sock *msk; in mptcp_token_get_sock() local
254 msk = mptcp_sk(sk); in mptcp_token_get_sock()
[all …]
|
| D | syncookies.c | 97 struct mptcp_sock *msk; in mptcp_token_join_cookie_init_state() local
111 msk = mptcp_token_get_sock(net, e->token); in mptcp_token_join_cookie_init_state()
112 if (!msk) { in mptcp_token_join_cookie_init_state()
122 subflow_req->msk = msk; in mptcp_token_join_cookie_init_state()
|
| /net/mctp/ |
| D | route.c | 53 struct mctp_sock *msk = container_of(sk, struct mctp_sock, sk); in mctp_lookup_bind() local
55 if (msk->bind_net != MCTP_NET_ANY && msk->bind_net != cb->net) in mctp_lookup_bind()
58 if (msk->bind_type != type) in mctp_lookup_bind()
61 if (msk->bind_addr != MCTP_ADDR_ANY && in mctp_lookup_bind()
62 msk->bind_addr != mh->dest) in mctp_lookup_bind()
65 return msk; in mctp_lookup_bind()
110 static struct mctp_sk_key *mctp_key_alloc(struct mctp_sock *msk, in mctp_key_alloc() argument
123 key->sk = &msk->sk; in mctp_key_alloc()
129 static int mctp_key_add(struct mctp_sk_key *key, struct mctp_sock *msk) in mctp_key_add() argument
131 struct net *net = sock_net(&msk->sk); in mctp_key_add()
[all …]
|
| D | af_mctp.c | 42 struct mctp_sock *msk = container_of(sk, struct mctp_sock, sk); in mctp_bind() local
68 msk->bind_net = smctp->smctp_network; in mctp_bind()
69 msk->bind_addr = smctp->smctp_addr.s_addr; in mctp_bind()
70 msk->bind_type = smctp->smctp_type & 0x7f; /* ignore the IC bit */ in mctp_bind()
241 struct mctp_sock *msk = container_of(sk, struct mctp_sock, sk); in mctp_sk_init() local
243 INIT_HLIST_HEAD(&msk->keys); in mctp_sk_init()
265 struct mctp_sock *msk = container_of(sk, struct mctp_sock, sk); in mctp_sk_unhash() local
278 hlist_for_each_entry_safe(key, tmp, &msk->keys, sklist) { in mctp_sk_unhash()
|
| /net/mac80211/ |
| D | debugfs_sta.c | 656 u8 msk = IEEE80211_HE_##t##_CAP##i##_##n##_MASK; \ in sta_he_capa_read()
657 u8 idx = ((cap[i] & msk) >> (ffs(msk) - 1)) + off; \ in sta_he_capa_read()
|