Home
last modified time | relevance | path

Searched refs:msk (Results 1 – 19 of 19) sorted by relevance

/net/mptcp/
A Dpm.c218 msk_owned_by_me(msk); in mptcp_pm_addr_send_ack()
280 if (!msk) in mptcp_pm_add_timer()
368 add_entry->sock = msk; in mptcp_pm_alloc_anno_list()
499 pr_debug("msk=%p status=%x new=%lx\n", msk, msk->pm.status, in mptcp_pm_schedule_work()
540 if (msk->token) in mptcp_pm_connection_closed()
665 msk_owned_by_me(msk); in mptcp_pm_rm_addr_or_subflow()
719 mptcp_pm_rm_addr_or_subflow(msk, &msk->pm.rm_list_rx, MPTCP_MIB_RMADDR); in mptcp_pm_rm_addr_recv()
754 msk = mptcp_sk(sk); in mptcp_pm_mp_prio_received()
815 port = !!(*echo ? msk->pm.remote.port : msk->pm.local.port); in mptcp_pm_add_addr_signal()
817 family = *echo ? msk->pm.remote.family : msk->pm.local.family; in mptcp_pm_add_addr_signal()
[all …]
A Dprotocol.c552 WRITE_ONCE(msk->ack_seq, msk->ack_seq + 1); in mptcp_check_data_fin()
980 if (unlikely(msk->recovery) && after64(msk->snd_una, msk->recovery_snd_nxt)) in __mptcp_clean_una()
1642 msk->snd_nxt + 1 == msk->write_seq) in __mptcp_subflow_push_pending()
1736 not_sent = msk->write_seq - msk->snd_nxt; in mptcp_send_limit()
1951 mptcp_rcv_space_init(msk, msk->first); in mptcp_rcv_space_adjust()
2320 msk->recovery_snd_nxt = msk->snd_nxt; in __mptcp_retransmit_pending_data()
2946 msk->snd_nxt, msk->write_seq); in mptcp_check_send_data_fin()
2951 if (!msk->snd_data_fin_enable || msk->snd_nxt + 1 != msk->write_seq || in mptcp_check_send_data_fin()
2955 WRITE_ONCE(msk->snd_nxt, msk->write_seq); in mptcp_check_send_data_fin()
3279 WRITE_ONCE(msk->snd_nxt, msk->write_seq); in mptcp_sk_clone_init()
[all …]
A Dpm_userspace.c21 spin_lock_bh(&msk->pm.lock); in mptcp_userspace_pm_free_local_addr_list()
172 if (!msk) { in mptcp_userspace_pm_get_sock()
184 return msk; in mptcp_userspace_pm_get_sock()
199 if (!msk) in mptcp_pm_nl_announce_doit()
313 if (!msk) in mptcp_pm_nl_remove_doit()
372 if (!msk) in mptcp_pm_nl_subflow_create_doit()
422 msk->pm.subflows++; in mptcp_pm_nl_subflow_create_doit()
490 if (!msk) in mptcp_pm_nl_subflow_destroy_doit()
570 if (!msk) in mptcp_userspace_pm_set_flags()
638 if (!msk) in mptcp_userspace_pm_dump_addr()
[all …]
A Dpm_kernel.c110 msk_owned_by_me(msk); in select_local_address()
190 msk->pm.subflows++; in fill_remote_addresses_vec()
221 msk->pm.subflows++; in fill_remote_addresses_vec()
416 msk->pm.subflows++; in fill_local_addresses_vec()
437 msk->pm.subflows++; in fill_local_addresses_vec()
501 if (--msk->pm.add_addr_accepted < mptcp_pm_get_add_addr_accept_max(msk)) in mptcp_pm_nl_rm_addr()
742 struct mptcp_sock *msk; in mptcp_nl_add_subflow_or_signal_addr() local
890 struct mptcp_sock *msk; in mptcp_nl_remove_subflow_and_signal_addr() local
944 if (list_empty(&msk->conn_list) || mptcp_pm_is_userspace(msk)) in mptcp_nl_remove_id_zero_address()
1264 if (list_empty(&msk->conn_list) || mptcp_pm_is_userspace(msk)) in mptcp_pm_nl_set_flags_all()
[all …]
A Dsockopt.c22 msk_owned_by_me(msk); in __mptcp_tcp_fallback()
27 return msk->first; in __mptcp_tcp_fallback()
55 msk->setsockopt_seq = sockopt_seq_reset((struct sock *)msk) + seq; in sockopt_seq_inc()
76 sockopt_seq_inc(msk); in mptcp_sol_socket_sync_intval()
619 strscpy(msk->ca_name, name, sizeof(msk->ca_name)); in mptcp_setsockopt_sol_tcp_congestion()
656 msk->cork = !!val; in __mptcp_setsockopt_sol_tcp_cork()
880 msk->maxseg = val; in mptcp_setsockopt_sol_tcp()
938 ssk = msk->first; in mptcp_getsockopt_first_sf_only()
1410 return mptcp_put_int_option(msk, optval, optlen, msk->recvmsg_inq); in mptcp_getsockopt_sol_tcp()
1412 return mptcp_put_int_option(msk, optval, optlen, msk->cork); in mptcp_getsockopt_sol_tcp()
[all …]
A Dsched.c139 msk->sched = sched; in mptcp_init_sched()
140 if (msk->sched->init) in mptcp_init_sched()
141 msk->sched->init(msk); in mptcp_init_sched()
155 msk->sched = NULL; in mptcp_release_sched()
157 sched->release(msk); in mptcp_release_sched()
176 if (msk->first && in mptcp_sched_get_send()
190 if (msk->sched == &mptcp_sched_default || !msk->sched) in mptcp_sched_get_send()
192 return msk->sched->get_send(msk); in mptcp_sched_get_send()
210 if (msk->sched == &mptcp_sched_default || !msk->sched) in mptcp_sched_get_retrans()
213 return msk->sched->get_retrans(msk); in mptcp_sched_get_retrans()
[all …]
A Dprotocol.h425 cur = msk->first_pending; in mptcp_send_next()
434 if (!msk->first_pending) in mptcp_pending_tail()
447 if (msk->snd_una == msk->snd_nxt) in mptcp_rtx_head()
477 struct mptcp_sock *msk; member
777 return READ_ONCE(msk->bytes_received) - READ_ONCE(msk->bytes_consumed); in mptcp_data_avail()
897 READ_ONCE(msk->write_seq) == READ_ONCE(msk->snd_nxt); in mptcp_data_fin_enabled()
914 notsent_bytes = READ_ONCE(msk->write_seq) - READ_ONCE(msk->snd_nxt); in mptcp_stream_memory_free()
995 struct mptcp_sock *msk);
1193 if (--msk->pm.subflows < mptcp_pm_get_subflows_max(msk)) in __mptcp_pm_close_subflow()
1241 struct mptcp_sock *msk; in mptcp_try_fallback() local
[all …]
A Dtoken_test.c54 struct mptcp_sock *msk; in build_msk() local
62 sk = (struct sock *)msk; in build_msk()
68 return msk; in build_msk()
81 sk = (struct sock *)msk; in mptcp_token_test_msk_basic()
90 mptcp_token_destroy(msk); in mptcp_token_test_msk_basic()
101 msk->token = req->token; in mptcp_token_test_accept()
103 KUNIT_EXPECT_PTR_EQ(test, msk, mptcp_token_get_sock(&init_net, msk->token)); in mptcp_token_test_accept()
107 KUNIT_EXPECT_PTR_EQ(test, msk, mptcp_token_get_sock(&init_net, msk->token)); in mptcp_token_test_accept()
110 mptcp_token_destroy(msk); in mptcp_token_test_accept()
120 sk = (struct sock *)msk; in mptcp_token_test_destroyed()
[all …]
A Dsubflow.c44 if (subflow_req->msk) in subflow_req_destructor()
72 struct mptcp_sock *msk = subflow_req->msk; in subflow_req_create_thmac() local
88 struct mptcp_sock *msk; in subflow_token_join_request() local
92 if (!msk) { in subflow_token_join_request()
105 return msk; in subflow_token_join_request()
116 subflow_req->msk = NULL; in subflow_init_req()
473 WRITE_ONCE(msk->snd_nxt, msk->write_seq); in __mptcp_sync_state()
530 struct mptcp_sock *msk; in subflow_finish_connect() local
538 msk = mptcp_sk(parent); in subflow_finish_connect()
755 struct mptcp_sock *msk = subflow_req->msk; in subflow_hmac_valid() local
[all …]
A Dtoken.c192 struct mptcp_sock *msk) in mptcp_token_accept() argument
214 struct mptcp_sock *msk; in mptcp_token_exists() local
222 msk = mptcp_sk(sk); in mptcp_token_exists()
223 if (READ_ONCE(msk->token) == token) in mptcp_token_exists()
250 struct mptcp_sock *msk; in mptcp_token_get_sock() local
258 msk = mptcp_sk(sk); in mptcp_token_get_sock()
277 msk = NULL; in mptcp_token_get_sock()
281 return msk; in mptcp_token_get_sock()
385 bucket = token_bucket(msk->token); in mptcp_token_destroy()
388 if (!WARN_ON_ONCE(pos != msk)) { in mptcp_token_destroy()
[all …]
A Doptions.c589 if (!READ_ONCE(msk->can_ack)) { in mptcp_established_options_dss()
594 ack_seq = READ_ONCE(msk->ack_seq); in mptcp_established_options_dss()
1040 msk->bytes_acked += new_snd_una - msk->snd_una; in __mptcp_snd_una_update()
1058 old_snd_una = msk->snd_una; in ack_update_msk()
1093 if (READ_ONCE(msk->rcv_data_fin)) in mptcp_update_rcv_data_fin()
1096 WRITE_ONCE(msk->rcv_data_fin_seq, in mptcp_update_rcv_data_fin()
1098 WRITE_ONCE(msk->rcv_data_fin, 1); in mptcp_update_rcv_data_fin()
1116 msk, hmac, mp_opt->ahmac); in add_addr_hmac_valid()
1142 __mptcp_snd_una_update(msk, READ_ONCE(msk->snd_nxt)); in mptcp_incoming_options()
1263 struct mptcp_sock *msk; in mptcp_set_rwin() local
[all …]
A Dpm_netlink.c293 sock_net((const struct sock *)msk), in mptcp_userspace_pm_active()
345 const struct mptcp_sock *msk, in mptcp_event_put_token_and_ssk() argument
348 const struct sock *sk = (const struct sock *)msk; in mptcp_event_put_token_and_ssk()
378 const struct mptcp_sock *msk, in mptcp_event_sub_established() argument
381 return mptcp_event_put_token_and_ssk(skb, msk, ssk); in mptcp_event_sub_established()
385 const struct mptcp_sock *msk, in mptcp_event_sub_closed() argument
390 if (mptcp_event_put_token_and_ssk(skb, msk, ssk)) in mptcp_event_sub_closed()
407 const struct mptcp_sock *msk, in mptcp_event_created() argument
456 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_event_addr_announced() local
583 if (mptcp_event_created(skb, msk, ssk) < 0) in mptcp_event()
[all …]
A Dmptcp_diag.c31 struct mptcp_sock *msk = NULL; in mptcp_diag_dump_one() local
38 msk = mptcp_token_get_sock(net, req->id.idiag_cookie[0]); in mptcp_diag_dump_one()
39 if (!msk) in mptcp_diag_dump_one()
43 sk = (struct sock *)msk; in mptcp_diag_dump_one()
158 struct mptcp_sock *msk; in mptcp_diag_dump() local
166 while ((msk = mptcp_token_iter_next(net, &diag_ctx->s_slot, in mptcp_diag_dump()
168 struct inet_sock *inet = (struct inet_sock *)msk; in mptcp_diag_dump()
169 struct sock *sk = (struct sock *)msk; in mptcp_diag_dump()
202 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_diag_get_info() local
209 struct sock *lsk = READ_ONCE(msk->first); in mptcp_diag_get_info()
[all …]
A Dsyncookies.c97 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/
A Daf_mctp.c99 if (msk->bind_peer_set) { in mctp_bind()
108 msk->bind_net = msk->bind_peer_net; in mctp_bind()
111 if (msk->bind_net != msk->bind_peer_net) { in mctp_bind()
168 if (msk->bind_peer_set) { in mctp_connect()
174 msk->bind_peer_set = true; in mctp_connect()
337 if (msk->addr_ext) { in mctp_recvmsg()
400 msk->addr_ext = val; in mctp_setsockopt()
422 val = !!msk->addr_ext; in mctp_getsockopt()
712 struct mctp_sock *msk; in mctp_sk_hash() local
719 if (msk->bind_peer_set) in mctp_sk_hash()
[all …]
A Droute.c75 return msk; in mctp_lookup_bind_details()
107 if (msk) in mctp_lookup_bind()
108 return msk; in mctp_lookup_bind()
111 if (msk) in mctp_lookup_bind()
112 return msk; in mctp_lookup_bind()
115 if (msk) in mctp_lookup_bind()
116 return msk; in mctp_lookup_bind()
119 if (msk) in mctp_lookup_bind()
120 return msk; in mctp_lookup_bind()
123 if (msk) in mctp_lookup_bind()
[all …]
/net/mctp/test/
A Dsock-test.c106 struct mctp_sock *msk; in mctp_test_sock_sendmsg_extaddr() local
129 msk = container_of(sock->sk, struct mctp_sock, sk); in mctp_test_sock_sendmsg_extaddr()
130 msk->addr_ext = true; in mctp_test_sock_sendmsg_extaddr()
155 struct mctp_sock *msk; in mctp_test_sock_recvmsg_extaddr() local
170 msk = container_of(sock->sk, struct mctp_sock, sk); in mctp_test_sock_recvmsg_extaddr()
171 msk->addr_ext = true; in mctp_test_sock_recvmsg_extaddr()
A Droute-test.c446 struct mctp_sock *msk; in mctp_test_route_input_sk_keys() local
465 msk = container_of(sock->sk, struct mctp_sock, sk); in mctp_test_route_input_sk_keys()
469 key = mctp_key_alloc(msk, net, params->key_local_addr, in mctp_test_route_input_sk_keys()
476 mctp_reserve_tag(&init_net, key, msk); in mctp_test_route_input_sk_keys()
658 struct mctp_sock *msk; in mctp_test_route_input_multiple_nets_key_init() local
667 msk = container_of(t->sock->sk, struct mctp_sock, sk); in mctp_test_route_input_multiple_nets_key_init()
669 t->key = mctp_key_alloc(msk, t->netid, hdr.dest, hdr.src, 1, GFP_KERNEL); in mctp_test_route_input_multiple_nets_key_init()
674 mctp_reserve_tag(&init_net, t->key, msk); in mctp_test_route_input_multiple_nets_key_init()
/net/mac80211/
A Ddebugfs_sta.c709 u8 msk = IEEE80211_HE_##t##_CAP##i##_##n##_MASK; \ in link_sta_he_capa_read()
710 u8 idx = ((cap[i] & msk) >> (ffs(msk) - 1)) + off; \ in link_sta_he_capa_read()

Completed in 83 milliseconds