| /kernel/linux/linux-5.10/drivers/net/wireguard/ |
| H A D | timers.c | 8 #include "peer.h"
30 static inline void mod_peer_timer(struct wg_peer *peer, in mod_peer_timer() argument
35 if (likely(netif_running(peer->device->dev) && in mod_peer_timer()
36 !READ_ONCE(peer->is_dead))) in mod_peer_timer()
43 struct wg_peer *peer = from_timer(peer, timer, in wg_expired_retransmit_handshake() local
46 if (peer->timer_handshake_attempts > MAX_TIMER_HANDSHAKES) { in wg_expired_retransmit_handshake()
47 pr_debug("%s: Handshake for peer %llu (%pISpfsc) did not complete after %d attempts, giving up\n", in wg_expired_retransmit_handshake()
48 peer->device->dev->name, peer in wg_expired_retransmit_handshake()
81 struct wg_peer *peer = from_timer(peer, timer, timer_send_keepalive); wg_expired_send_keepalive() local
93 struct wg_peer *peer = from_timer(peer, timer, timer_new_handshake); wg_expired_new_handshake() local
107 struct wg_peer *peer = from_timer(peer, timer, timer_zero_key_material); wg_expired_zero_key_material() local
124 struct wg_peer *peer = container_of(work, struct wg_peer, wg_queued_expired_zero_key_material() local
137 struct wg_peer *peer = from_timer(peer, timer, wg_expired_send_persistent_keepalive() local
145 wg_timers_data_sent(struct wg_peer *peer) wg_timers_data_sent() argument
154 wg_timers_data_received(struct wg_peer *peer) wg_timers_data_received() argument
168 wg_timers_any_authenticated_packet_sent(struct wg_peer *peer) wg_timers_any_authenticated_packet_sent() argument
176 wg_timers_any_authenticated_packet_received(struct wg_peer *peer) wg_timers_any_authenticated_packet_received() argument
182 wg_timers_handshake_initiated(struct wg_peer *peer) wg_timers_handshake_initiated() argument
192 wg_timers_handshake_complete(struct wg_peer *peer) wg_timers_handshake_complete() argument
203 wg_timers_session_derived(struct wg_peer *peer) wg_timers_session_derived() argument
212 wg_timers_any_authenticated_packet_traversal(struct wg_peer *peer) wg_timers_any_authenticated_packet_traversal() argument
219 wg_timers_init(struct wg_peer *peer) wg_timers_init() argument
235 wg_timers_stop(struct wg_peer *peer) wg_timers_stop() argument
[all...] |
| H A D | peer.c | 6 #include "peer.h"
25 struct wg_peer *peer; in wg_peer_create() local
33 peer = kmem_cache_zalloc(peer_cache, GFP_KERNEL); in wg_peer_create()
34 if (unlikely(!peer)) in wg_peer_create()
36 if (unlikely(dst_cache_init(&peer->endpoint_cache, GFP_KERNEL))) in wg_peer_create()
39 peer->device = wg; in wg_peer_create()
40 wg_noise_handshake_init(&peer->handshake, &wg->static_identity, in wg_peer_create()
41 public_key, preshared_key, peer); in wg_peer_create()
42 peer->internal_id = atomic64_inc_return(&peer_counter); in wg_peer_create()
43 peer in wg_peer_create()
72 wg_peer_get_maybe_zero(struct wg_peer *peer) wg_peer_get_maybe_zero() argument
81 peer_make_dead(struct wg_peer *peer) peer_make_dead() argument
95 peer_remove_after_dead(struct wg_peer *peer) peer_remove_after_dead() argument
157 wg_peer_remove(struct wg_peer *peer) wg_peer_remove() argument
170 struct wg_peer *peer, *temp; wg_peer_remove_all() local
189 struct wg_peer *peer = container_of(rcu, struct wg_peer, rcu); rcu_release() local
203 struct wg_peer *peer = container_of(refcount, struct wg_peer, refcount); kref_release() local
224 wg_peer_put(struct wg_peer *peer) wg_peer_put() argument
[all...] |
| H A D | send.c | 9 #include "peer.h"
21 static void wg_packet_send_handshake_initiation(struct wg_peer *peer) in wg_packet_send_handshake_initiation() argument
25 if (!wg_birthdate_has_expired(atomic64_read(&peer->last_sent_handshake), in wg_packet_send_handshake_initiation()
29 atomic64_set(&peer->last_sent_handshake, ktime_get_coarse_boottime_ns()); in wg_packet_send_handshake_initiation()
30 net_dbg_ratelimited("%s: Sending handshake initiation to peer %llu (%pISpfsc)\n", in wg_packet_send_handshake_initiation()
31 peer->device->dev->name, peer->internal_id, in wg_packet_send_handshake_initiation()
32 &peer->endpoint.addr); in wg_packet_send_handshake_initiation()
34 if (wg_noise_handshake_create_initiation(&packet, &peer->handshake)) { in wg_packet_send_handshake_initiation()
35 wg_cookie_add_mac_to_packet(&packet, sizeof(packet), peer); in wg_packet_send_handshake_initiation()
48 struct wg_peer *peer = container_of(work, struct wg_peer, wg_packet_handshake_send_worker() local
55 wg_packet_send_queued_handshake_initiation(struct wg_peer *peer, bool is_retry) wg_packet_send_queued_handshake_initiation() argument
85 wg_packet_send_handshake_response(struct wg_peer *peer) wg_packet_send_handshake_response() argument
124 keep_key_fresh(struct wg_peer *peer) keep_key_fresh() argument
221 wg_packet_send_keepalive(struct wg_peer *peer) wg_packet_send_keepalive() argument
242 wg_packet_create_data_done(struct wg_peer *peer, struct sk_buff *first) wg_packet_create_data_done() argument
264 struct wg_peer *peer = container_of(work, struct wg_peer, transmit_packet_work); wg_packet_tx_worker() local
311 wg_packet_create_data(struct wg_peer *peer, struct sk_buff *first) wg_packet_create_data() argument
333 wg_packet_purge_staged_packets(struct wg_peer *peer) wg_packet_purge_staged_packets() argument
342 wg_packet_send_staged_packets(struct wg_peer *peer) wg_packet_send_staged_packets() argument
[all...] |
| /kernel/linux/linux-6.6/drivers/net/wireguard/ |
| H A D | timers.c | 8 #include "peer.h"
30 static inline void mod_peer_timer(struct wg_peer *peer, in mod_peer_timer() argument
35 if (likely(netif_running(peer->device->dev) && in mod_peer_timer()
36 !READ_ONCE(peer->is_dead))) in mod_peer_timer()
43 struct wg_peer *peer = from_timer(peer, timer, in wg_expired_retransmit_handshake() local
46 if (peer->timer_handshake_attempts > MAX_TIMER_HANDSHAKES) { in wg_expired_retransmit_handshake()
47 pr_debug("%s: Handshake for peer %llu (%pISpfsc) did not complete after %d attempts, giving up\n", in wg_expired_retransmit_handshake()
48 peer->device->dev->name, peer in wg_expired_retransmit_handshake()
81 struct wg_peer *peer = from_timer(peer, timer, timer_send_keepalive); wg_expired_send_keepalive() local
93 struct wg_peer *peer = from_timer(peer, timer, timer_new_handshake); wg_expired_new_handshake() local
107 struct wg_peer *peer = from_timer(peer, timer, timer_zero_key_material); wg_expired_zero_key_material() local
124 struct wg_peer *peer = container_of(work, struct wg_peer, wg_queued_expired_zero_key_material() local
137 struct wg_peer *peer = from_timer(peer, timer, wg_expired_send_persistent_keepalive() local
145 wg_timers_data_sent(struct wg_peer *peer) wg_timers_data_sent() argument
154 wg_timers_data_received(struct wg_peer *peer) wg_timers_data_received() argument
168 wg_timers_any_authenticated_packet_sent(struct wg_peer *peer) wg_timers_any_authenticated_packet_sent() argument
176 wg_timers_any_authenticated_packet_received(struct wg_peer *peer) wg_timers_any_authenticated_packet_received() argument
182 wg_timers_handshake_initiated(struct wg_peer *peer) wg_timers_handshake_initiated() argument
192 wg_timers_handshake_complete(struct wg_peer *peer) wg_timers_handshake_complete() argument
203 wg_timers_session_derived(struct wg_peer *peer) wg_timers_session_derived() argument
212 wg_timers_any_authenticated_packet_traversal(struct wg_peer *peer) wg_timers_any_authenticated_packet_traversal() argument
219 wg_timers_init(struct wg_peer *peer) wg_timers_init() argument
235 wg_timers_stop(struct wg_peer *peer) wg_timers_stop() argument
[all...] |
| H A D | peer.c | 6 #include "peer.h"
25 struct wg_peer *peer; in wg_peer_create() local
33 peer = kmem_cache_zalloc(peer_cache, GFP_KERNEL); in wg_peer_create()
34 if (unlikely(!peer)) in wg_peer_create()
36 if (unlikely(dst_cache_init(&peer->endpoint_cache, GFP_KERNEL))) in wg_peer_create()
39 peer->device = wg; in wg_peer_create()
40 wg_noise_handshake_init(&peer->handshake, &wg->static_identity, in wg_peer_create()
41 public_key, preshared_key, peer); in wg_peer_create()
42 peer->internal_id = atomic64_inc_return(&peer_counter); in wg_peer_create()
43 peer in wg_peer_create()
71 wg_peer_get_maybe_zero(struct wg_peer *peer) wg_peer_get_maybe_zero() argument
80 peer_make_dead(struct wg_peer *peer) peer_make_dead() argument
94 peer_remove_after_dead(struct wg_peer *peer) peer_remove_after_dead() argument
156 wg_peer_remove(struct wg_peer *peer) wg_peer_remove() argument
169 struct wg_peer *peer, *temp; wg_peer_remove_all() local
188 struct wg_peer *peer = container_of(rcu, struct wg_peer, rcu); rcu_release() local
202 struct wg_peer *peer = container_of(refcount, struct wg_peer, refcount); kref_release() local
223 wg_peer_put(struct wg_peer *peer) wg_peer_put() argument
[all...] |
| H A D | send.c | 9 #include "peer.h"
21 static void wg_packet_send_handshake_initiation(struct wg_peer *peer) in wg_packet_send_handshake_initiation() argument
25 if (!wg_birthdate_has_expired(atomic64_read(&peer->last_sent_handshake), in wg_packet_send_handshake_initiation()
29 atomic64_set(&peer->last_sent_handshake, ktime_get_coarse_boottime_ns()); in wg_packet_send_handshake_initiation()
30 net_dbg_ratelimited("%s: Sending handshake initiation to peer %llu (%pISpfsc)\n", in wg_packet_send_handshake_initiation()
31 peer->device->dev->name, peer->internal_id, in wg_packet_send_handshake_initiation()
32 &peer->endpoint.addr); in wg_packet_send_handshake_initiation()
34 if (wg_noise_handshake_create_initiation(&packet, &peer->handshake)) { in wg_packet_send_handshake_initiation()
35 wg_cookie_add_mac_to_packet(&packet, sizeof(packet), peer); in wg_packet_send_handshake_initiation()
48 struct wg_peer *peer = container_of(work, struct wg_peer, wg_packet_handshake_send_worker() local
55 wg_packet_send_queued_handshake_initiation(struct wg_peer *peer, bool is_retry) wg_packet_send_queued_handshake_initiation() argument
85 wg_packet_send_handshake_response(struct wg_peer *peer) wg_packet_send_handshake_response() argument
124 keep_key_fresh(struct wg_peer *peer) keep_key_fresh() argument
221 wg_packet_send_keepalive(struct wg_peer *peer) wg_packet_send_keepalive() argument
242 wg_packet_create_data_done(struct wg_peer *peer, struct sk_buff *first) wg_packet_create_data_done() argument
264 struct wg_peer *peer = container_of(work, struct wg_peer, transmit_packet_work); wg_packet_tx_worker() local
311 wg_packet_create_data(struct wg_peer *peer, struct sk_buff *first) wg_packet_create_data() argument
333 wg_packet_purge_staged_packets(struct wg_peer *peer) wg_packet_purge_staged_packets() argument
342 wg_packet_send_staged_packets(struct wg_peer *peer) wg_packet_send_staged_packets() argument
[all...] |
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/rsn_supp/ |
| H A D | tdls.c | 86 static void wpa_tdls_peer_free(struct wpa_sm *sm, struct wpa_tdls_peer *peer);
88 struct wpa_tdls_peer *peer);
181 static int wpa_tdls_del_key(struct wpa_sm *sm, struct wpa_tdls_peer *peer) in wpa_tdls_del_key() argument
184 if (wpa_sm_set_key(sm, -1, WPA_ALG_NONE, peer->addr, in wpa_tdls_del_key()
186 if (wpa_sm_set_key(sm, WPA_ALG_NONE, peer->addr, in wpa_tdls_del_key()
198 static int wpa_tdls_set_key(struct wpa_sm *sm, struct wpa_tdls_peer *peer) in wpa_tdls_set_key() argument
204 if (peer->tk_set) { in wpa_tdls_set_key()
212 wpa_printf(MSG_INFO, "TDLS: TPK-TK for the peer " MACSTR_SEC in wpa_tdls_set_key()
214 MAC2STR_SEC(peer->addr)); in wpa_tdls_set_key()
220 switch (peer in wpa_tdls_set_key()
[all...] |
| /kernel/linux/linux-5.10/net/rxrpc/ |
| H A D | peer_object.c | 26 * Hash a peer key.
60 /* Step through the peer address in 16-bit portions for speed */ in rxrpc_peer_hash_key()
69 * Compare a peer to a key. Return -ve, 0 or +ve to indicate less than, same
76 static long rxrpc_peer_cmp_key(const struct rxrpc_peer *peer, in rxrpc_peer_cmp_key() argument
83 diff = ((peer->hash_key - hash_key) ?: in rxrpc_peer_cmp_key()
84 ((unsigned long)peer->local - (unsigned long)local) ?: in rxrpc_peer_cmp_key()
85 (peer->srx.transport_type - srx->transport_type) ?: in rxrpc_peer_cmp_key()
86 (peer->srx.transport_len - srx->transport_len) ?: in rxrpc_peer_cmp_key()
87 (peer->srx.transport.family - srx->transport.family)); in rxrpc_peer_cmp_key()
93 return ((u16 __force)peer in rxrpc_peer_cmp_key()
119 struct rxrpc_peer *peer; __rxrpc_lookup_peer_rcu() local
137 struct rxrpc_peer *peer; rxrpc_lookup_peer_rcu() local
152 rxrpc_assess_MTU_size(struct rxrpc_sock *rx, struct rxrpc_peer *peer) rxrpc_assess_MTU_size() argument
213 struct rxrpc_peer *peer; rxrpc_alloc_peer() local
246 rxrpc_init_peer(struct rxrpc_sock *rx, struct rxrpc_peer *peer, unsigned long hash_key) rxrpc_init_peer() argument
288 struct rxrpc_peer *peer; rxrpc_create_peer() local
302 rxrpc_free_peer(struct rxrpc_peer *peer) rxrpc_free_peer() argument
313 rxrpc_new_incoming_peer(struct rxrpc_sock *rx, struct rxrpc_local *local, struct rxrpc_peer *peer) rxrpc_new_incoming_peer() argument
335 struct rxrpc_peer *peer, *candidate; rxrpc_lookup_peer() local
388 rxrpc_get_peer(struct rxrpc_peer *peer) rxrpc_get_peer() argument
401 rxrpc_get_peer_maybe(struct rxrpc_peer *peer) rxrpc_get_peer_maybe() argument
418 __rxrpc_put_peer(struct rxrpc_peer *peer) __rxrpc_put_peer() argument
435 rxrpc_put_peer(struct rxrpc_peer *peer) rxrpc_put_peer() argument
455 rxrpc_put_peer_locked(struct rxrpc_peer *peer) rxrpc_put_peer_locked() argument
476 struct rxrpc_peer *peer; rxrpc_destroy_all_peers() local
518 struct rxrpc_peer *peer = call->peer; rxrpc_kernel_get_srtt() local
[all...] |
| H A D | rtt.c | 18 static u32 rxrpc_rto_min_us(struct rxrpc_peer *peer) in rxrpc_rto_min_us() argument
23 static u32 __rxrpc_set_rto(const struct rxrpc_peer *peer) in __rxrpc_set_rto() argument
25 return usecs_to_jiffies((peer->srtt_us >> 3) + peer->rttvar_us); in __rxrpc_set_rto()
43 static void rxrpc_rtt_estimator(struct rxrpc_peer *peer, long sample_rtt_us) in rxrpc_rtt_estimator() argument
46 u32 srtt = peer->srtt_us; in rxrpc_rtt_estimator()
69 m -= (peer->mdev_us >> 2); /* similar update on mdev */ in rxrpc_rtt_estimator()
81 m -= (peer->mdev_us >> 2); /* similar update on mdev */ in rxrpc_rtt_estimator()
84 peer->mdev_us += m; /* mdev = 3/4 mdev + 1/4 new */ in rxrpc_rtt_estimator()
85 if (peer in rxrpc_rtt_estimator()
105 rxrpc_set_rto(struct rxrpc_peer *peer) rxrpc_set_rto() argument
130 rxrpc_ack_update_rtt(struct rxrpc_peer *peer, long rtt_us) rxrpc_ack_update_rtt() argument
152 struct rxrpc_peer *peer = call->peer; rxrpc_peer_add_rtt() local
173 rxrpc_get_rto_backoff(struct rxrpc_peer *peer, bool retrans) rxrpc_get_rto_backoff() argument
189 rxrpc_peer_init_rtt(struct rxrpc_peer *peer) rxrpc_peer_init_rtt() argument
[all...] |
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/rsn_supp/ |
| H A D | tdls.c | 86 static void wpa_tdls_peer_free(struct wpa_sm *sm, struct wpa_tdls_peer *peer);
88 struct wpa_tdls_peer *peer);
178 static int wpa_tdls_del_key(struct wpa_sm *sm, struct wpa_tdls_peer *peer) in wpa_tdls_del_key() argument
180 if (wpa_sm_set_key(sm, WPA_ALG_NONE, peer->addr, in wpa_tdls_del_key()
191 static int wpa_tdls_set_key(struct wpa_sm *sm, struct wpa_tdls_peer *peer) in wpa_tdls_set_key() argument
197 if (peer->tk_set) { in wpa_tdls_set_key()
205 wpa_printf(MSG_INFO, "TDLS: TPK-TK for the peer " MACSTR in wpa_tdls_set_key()
207 MAC2STR(peer->addr)); in wpa_tdls_set_key()
213 switch (peer->cipher) { in wpa_tdls_set_key()
228 wpa_printf(MSG_DEBUG, "TDLS: Configure pairwise key for peer " MACST in wpa_tdls_set_key()
256 struct wpa_tdls_peer *peer; wpa_tdls_tpk_send() local
320 wpa_tdls_do_teardown(struct wpa_sm *sm, struct wpa_tdls_peer *peer, u16 reason_code) wpa_tdls_do_teardown() argument
337 struct wpa_tdls_peer *peer = timeout_ctx; wpa_tdls_tpk_retry_timeout() local
382 wpa_tdls_tpk_retry_timeout_cancel(struct wpa_sm *sm, struct wpa_tdls_peer *peer, u8 action_code) wpa_tdls_tpk_retry_timeout_cancel() argument
408 wpa_tdls_generate_tpk(struct wpa_tdls_peer *peer, const u8 *own_addr, const u8 *bssid) wpa_tdls_generate_tpk() argument
580 wpa_supplicant_verify_tdls_mic(u8 trans_seq, struct wpa_tdls_peer *peer, const u8 *lnkid, const u8 *timeoutie, const struct wpa_tdls_ftie *ftie) wpa_supplicant_verify_tdls_mic() argument
609 wpa_supplicant_verify_tdls_mic_teardown( u8 trans_seq, u16 rcode, u8 dtoken, struct wpa_tdls_peer *peer, const u8 *lnkid, const struct wpa_tdls_ftie *ftie) wpa_supplicant_verify_tdls_mic_teardown() argument
635 struct wpa_tdls_peer *peer = timeout_ctx; wpa_tdls_tpk_timeout() local
664 wpa_tdls_peer_remove_from_list(struct wpa_sm *sm, struct wpa_tdls_peer *peer) wpa_tdls_peer_remove_from_list() argument
690 wpa_tdls_peer_clear(struct wpa_sm *sm, struct wpa_tdls_peer *peer) wpa_tdls_peer_clear() argument
723 wpa_tdls_peer_free(struct wpa_sm *sm, struct wpa_tdls_peer *peer) wpa_tdls_peer_free() argument
731 wpa_tdls_linkid(struct wpa_sm *sm, struct wpa_tdls_peer *peer, struct wpa_tdls_lnkid *lnkid) wpa_tdls_linkid() argument
750 struct wpa_tdls_peer *peer; wpa_tdls_send_teardown() local
843 struct wpa_tdls_peer *peer; wpa_tdls_teardown_link() local
869 wpa_tdls_disable_peer_link(struct wpa_sm *sm, struct wpa_tdls_peer *peer) wpa_tdls_disable_peer_link() argument
879 struct wpa_tdls_peer *peer; wpa_tdls_disable_unreachable_link() local
912 struct wpa_tdls_peer *peer; wpa_tdls_get_link_status() local
935 struct wpa_tdls_peer *peer = NULL; wpa_tdls_recv_teardown() local
1035 struct wpa_tdls_peer *peer; wpa_tdls_add_peer() local
1062 wpa_tdls_send_tpk_m1(struct wpa_sm *sm, struct wpa_tdls_peer *peer) wpa_tdls_send_tpk_m1() argument
1243 wpa_tdls_send_tpk_m2(struct wpa_sm *sm, const unsigned char *src_addr, u8 dtoken, struct wpa_tdls_lnkid *lnkid, const struct wpa_tdls_peer *peer) wpa_tdls_send_tpk_m2() argument
1334 wpa_tdls_send_tpk_m3(struct wpa_sm *sm, const unsigned char *src_addr, u8 dtoken, struct wpa_tdls_lnkid *lnkid, const struct wpa_tdls_peer *peer) wpa_tdls_send_tpk_m3() argument
1432 wpa_tdls_send_discovery_response(struct wpa_sm *sm, struct wpa_tdls_peer *peer, u8 dialog_token) wpa_tdls_send_discovery_response() argument
1524 struct wpa_tdls_peer *peer; wpa_tdls_process_discovery_request() local
1586 copy_supp_rates(const struct wpa_eapol_ie_parse *kde, struct wpa_tdls_peer *peer) copy_supp_rates() argument
1602 copy_peer_ht_capab(const struct wpa_eapol_ie_parse *kde, struct wpa_tdls_peer *peer) copy_peer_ht_capab() argument
1628 copy_peer_vht_capab(const struct wpa_eapol_ie_parse *kde, struct wpa_tdls_peer *peer) copy_peer_vht_capab() argument
1654 copy_peer_ext_capab(const struct wpa_eapol_ie_parse *kde, struct wpa_tdls_peer *peer) copy_peer_ext_capab() argument
1678 copy_peer_wmm_capab(const struct wpa_eapol_ie_parse *kde, struct wpa_tdls_peer *peer) copy_peer_wmm_capab() argument
1703 copy_peer_supp_channels(const struct wpa_eapol_ie_parse *kde, struct wpa_tdls_peer *peer) copy_peer_supp_channels() argument
1729 copy_peer_supp_oper_classes(const struct wpa_eapol_ie_parse *kde, struct wpa_tdls_peer *peer) copy_peer_supp_oper_classes() argument
1755 wpa_tdls_addset_peer(struct wpa_sm *sm, struct wpa_tdls_peer *peer, int add) wpa_tdls_addset_peer() argument
1788 struct wpa_tdls_peer *peer; wpa_tdls_process_tpk_m1() local
2146 wpa_tdls_enable_link(struct wpa_sm *sm, struct wpa_tdls_peer *peer) wpa_tdls_enable_link() argument
2184 struct wpa_tdls_peer *peer; wpa_tdls_process_tpk_m2() local
2473 struct wpa_tdls_peer *peer; wpa_tdls_process_tpk_m3() local
2654 struct wpa_tdls_peer *peer; wpa_tdls_start() local
2706 struct wpa_tdls_peer *peer; wpa_tdls_remove() local
2844 struct wpa_tdls_peer *peer, *tmp; wpa_tdls_teardown_peers() local
2869 struct wpa_tdls_peer *peer, *tmp; wpa_tdls_remove_peers() local
2995 struct wpa_tdls_peer *peer; wpa_tdls_enable_chan_switch() local
3042 struct wpa_tdls_peer *peer; wpa_tdls_disable_chan_switch() local
[all...] |
| /kernel/linux/linux-6.6/net/rxrpc/ |
| H A D | peer_object.c | 26 * Hash a peer key.
60 /* Step through the peer address in 16-bit portions for speed */ in rxrpc_peer_hash_key()
69 * Compare a peer to a key. Return -ve, 0 or +ve to indicate less than, same
76 static long rxrpc_peer_cmp_key(const struct rxrpc_peer *peer, in rxrpc_peer_cmp_key() argument
83 diff = ((peer->hash_key - hash_key) ?: in rxrpc_peer_cmp_key()
84 ((unsigned long)peer->local - (unsigned long)local) ?: in rxrpc_peer_cmp_key()
85 (peer->srx.transport_type - srx->transport_type) ?: in rxrpc_peer_cmp_key()
86 (peer->srx.transport_len - srx->transport_len) ?: in rxrpc_peer_cmp_key()
87 (peer->srx.transport.family - srx->transport.family)); in rxrpc_peer_cmp_key()
93 return ((u16 __force)peer in rxrpc_peer_cmp_key()
119 struct rxrpc_peer *peer; __rxrpc_lookup_peer_rcu() local
137 struct rxrpc_peer *peer; rxrpc_lookup_peer_rcu() local
150 rxrpc_assess_MTU_size(struct rxrpc_local *local, struct rxrpc_peer *peer) rxrpc_assess_MTU_size() argument
211 struct rxrpc_peer *peer; rxrpc_alloc_peer() local
239 rxrpc_init_peer(struct rxrpc_local *local, struct rxrpc_peer *peer, unsigned long hash_key) rxrpc_init_peer() argument
280 struct rxrpc_peer *peer; rxrpc_create_peer() local
294 rxrpc_free_peer(struct rxrpc_peer *peer) rxrpc_free_peer() argument
306 rxrpc_new_incoming_peer(struct rxrpc_local *local, struct rxrpc_peer *peer) rxrpc_new_incoming_peer() argument
326 struct rxrpc_peer *peer, *candidate; rxrpc_lookup_peer() local
377 rxrpc_get_peer(struct rxrpc_peer *peer, enum rxrpc_peer_trace why) rxrpc_get_peer() argument
389 rxrpc_get_peer_maybe(struct rxrpc_peer *peer, enum rxrpc_peer_trace why) rxrpc_get_peer_maybe() argument
406 __rxrpc_put_peer(struct rxrpc_peer *peer) __rxrpc_put_peer() argument
423 rxrpc_put_peer(struct rxrpc_peer *peer, enum rxrpc_peer_trace why) rxrpc_put_peer() argument
443 struct rxrpc_peer *peer; rxrpc_destroy_all_peers() local
485 struct rxrpc_peer *peer = call->peer; rxrpc_kernel_get_srtt() local
[all...] |
| H A D | rtt.c | 18 static u32 rxrpc_rto_min_us(struct rxrpc_peer *peer) in rxrpc_rto_min_us() argument
23 static u32 __rxrpc_set_rto(const struct rxrpc_peer *peer) in __rxrpc_set_rto() argument
25 return usecs_to_jiffies((peer->srtt_us >> 3) + peer->rttvar_us); in __rxrpc_set_rto()
43 static void rxrpc_rtt_estimator(struct rxrpc_peer *peer, long sample_rtt_us) in rxrpc_rtt_estimator() argument
46 u32 srtt = peer->srtt_us; in rxrpc_rtt_estimator()
69 m -= (peer->mdev_us >> 2); /* similar update on mdev */ in rxrpc_rtt_estimator()
81 m -= (peer->mdev_us >> 2); /* similar update on mdev */ in rxrpc_rtt_estimator()
84 peer->mdev_us += m; /* mdev = 3/4 mdev + 1/4 new */ in rxrpc_rtt_estimator()
85 if (peer in rxrpc_rtt_estimator()
105 rxrpc_set_rto(struct rxrpc_peer *peer) rxrpc_set_rto() argument
130 rxrpc_ack_update_rtt(struct rxrpc_peer *peer, long rtt_us) rxrpc_ack_update_rtt() argument
152 struct rxrpc_peer *peer = call->peer; rxrpc_peer_add_rtt() local
173 rxrpc_get_rto_backoff(struct rxrpc_peer *peer, bool retrans) rxrpc_get_rto_backoff() argument
189 rxrpc_peer_init_rtt(struct rxrpc_peer *peer) rxrpc_peer_init_rtt() argument
[all...] |
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/wpa_supplicant/ |
| H A D | ibss_rsn.c | 30 struct ibss_rsn_peer *peer; in ibss_rsn_get_peer() local
32 for (peer = ibss_rsn->peers; peer; peer = peer->next) in ibss_rsn_get_peer()
33 if (os_memcmp(addr, peer->addr, ETH_ALEN) == 0) in ibss_rsn_get_peer()
35 return peer; in ibss_rsn_get_peer()
39 static void ibss_rsn_free(struct ibss_rsn_peer *peer) in ibss_rsn_free() argument
41 eloop_cancel_timeout(ibss_rsn_auth_timeout, peer, NULL); in ibss_rsn_free()
42 wpa_auth_sta_deinit(peer in ibss_rsn_free()
50 struct ibss_rsn_peer *peer = ctx; supp_set_state() local
57 struct ibss_rsn_peer *peer = ctx; supp_get_state() local
65 struct ibss_rsn_peer *peer = ctx; supp_ether_send() local
116 struct ibss_rsn_peer *peer = ctx; supp_get_beacon_ie() local
130 ibss_check_rsn_completed(struct ibss_rsn_peer *peer) ibss_check_rsn_completed() argument
154 struct ibss_rsn_peer *peer = ctx; supp_set_key() local
190 struct ibss_rsn_peer *peer = ctx; supp_get_network_ctx() local
223 ibss_rsn_supp_init(struct ibss_rsn_peer *peer, const u8 *own_addr, const u8 *psk) ibss_rsn_supp_init() argument
344 struct ibss_rsn_peer *peer; auth_set_key() local
384 struct ibss_rsn_peer *peer; auth_for_each_sta() local
397 ibss_set_sta_authorized(struct ibss_rsn *ibss_rsn, struct ibss_rsn_peer *peer, int authorized) ibss_set_sta_authorized() argument
427 struct ibss_rsn_peer *peer = ibss_rsn_get_peer(ibss_rsn, addr); auth_set_eapol() local
483 ibss_rsn_auth_init(struct ibss_rsn *ibss_rsn, struct ibss_rsn_peer *peer) ibss_rsn_auth_init() argument
539 ibss_rsn_is_auth_started(struct ibss_rsn_peer * peer) ibss_rsn_is_auth_started() argument
549 struct ibss_rsn_peer *peer; ibss_rsn_peer_init() local
588 struct ibss_rsn_peer *peer = eloop_ctx; ibss_rsn_auth_timeout() local
605 struct ibss_rsn_peer *peer; ibss_rsn_start() local
638 ibss_rsn_peer_authenticated(struct ibss_rsn *ibss_rsn, struct ibss_rsn_peer *peer, int reason) ibss_rsn_peer_authenticated() argument
664 struct ibss_rsn_peer *peer, *prev; ibss_rsn_stop() local
723 struct ibss_rsn_peer *peer, *prev; ibss_rsn_deinit() local
785 ibss_rsn_process_rx_eapol(struct ibss_rsn *ibss_rsn, struct ibss_rsn_peer *peer, const u8 *buf, size_t len) ibss_rsn_process_rx_eapol() argument
826 struct ibss_rsn_peer *peer; ibss_rsn_rx_eapol() local
865 ibss_rsn_handle_auth_1_of_2(struct ibss_rsn *ibss_rsn, struct ibss_rsn_peer *peer, const u8* addr) ibss_rsn_handle_auth_1_of_2() argument
934 struct ibss_rsn_peer *peer; ibss_rsn_handle_auth() local
[all...] |
| /third_party/wpa_supplicant/wpa_supplicant-2.9/wpa_supplicant/ |
| H A D | ibss_rsn.c | 30 struct ibss_rsn_peer *peer; in ibss_rsn_get_peer() local
32 for (peer = ibss_rsn->peers; peer; peer = peer->next) in ibss_rsn_get_peer()
33 if (os_memcmp(addr, peer->addr, ETH_ALEN) == 0) in ibss_rsn_get_peer()
35 return peer; in ibss_rsn_get_peer()
39 static void ibss_rsn_free(struct ibss_rsn_peer *peer) in ibss_rsn_free() argument
41 eloop_cancel_timeout(ibss_rsn_auth_timeout, peer, NULL); in ibss_rsn_free()
42 wpa_auth_sta_deinit(peer in ibss_rsn_free()
50 struct ibss_rsn_peer *peer = ctx; supp_set_state() local
57 struct ibss_rsn_peer *peer = ctx; supp_get_state() local
65 struct ibss_rsn_peer *peer = ctx; supp_ether_send() local
110 struct ibss_rsn_peer *peer = ctx; supp_get_beacon_ie() local
123 ibss_check_rsn_completed(struct ibss_rsn_peer *peer) ibss_check_rsn_completed() argument
144 struct ibss_rsn_peer *peer = ctx; supp_set_key() local
175 struct ibss_rsn_peer *peer = ctx; supp_get_network_ctx() local
202 ibss_rsn_supp_init(struct ibss_rsn_peer *peer, const u8 *own_addr, const u8 *psk) ibss_rsn_supp_init() argument
317 struct ibss_rsn_peer *peer; auth_set_key() local
353 struct ibss_rsn_peer *peer; auth_for_each_sta() local
366 ibss_set_sta_authorized(struct ibss_rsn *ibss_rsn, struct ibss_rsn_peer *peer, int authorized) ibss_set_sta_authorized() argument
396 struct ibss_rsn_peer *peer = ibss_rsn_get_peer(ibss_rsn, addr); auth_set_eapol() local
452 ibss_rsn_auth_init(struct ibss_rsn *ibss_rsn, struct ibss_rsn_peer *peer) ibss_rsn_auth_init() argument
512 ibss_rsn_is_auth_started(struct ibss_rsn_peer * peer) ibss_rsn_is_auth_started() argument
522 struct ibss_rsn_peer *peer; ibss_rsn_peer_init() local
561 struct ibss_rsn_peer *peer = eloop_ctx; ibss_rsn_auth_timeout() local
578 struct ibss_rsn_peer *peer; ibss_rsn_start() local
611 ibss_rsn_peer_authenticated(struct ibss_rsn *ibss_rsn, struct ibss_rsn_peer *peer, int reason) ibss_rsn_peer_authenticated() argument
637 struct ibss_rsn_peer *peer, *prev; ibss_rsn_stop() local
696 struct ibss_rsn_peer *peer, *prev; ibss_rsn_deinit() local
758 ibss_rsn_process_rx_eapol(struct ibss_rsn *ibss_rsn, struct ibss_rsn_peer *peer, const u8 *buf, size_t len) ibss_rsn_process_rx_eapol() argument
799 struct ibss_rsn_peer *peer; ibss_rsn_rx_eapol() local
838 ibss_rsn_handle_auth_1_of_2(struct ibss_rsn *ibss_rsn, struct ibss_rsn_peer *peer, const u8* addr) ibss_rsn_handle_auth_1_of_2() argument
903 struct ibss_rsn_peer *peer; ibss_rsn_handle_auth() local
[all...] |
| /third_party/libwebsockets/lib/misc/ |
| H A D | peer-limits.c | 31 struct lws_peer *peer) in __lws_peer_remove_from_peer_wait_list()
36 if (*p == peer) { in __lws_peer_remove_from_peer_wait_list()
65 struct lws_peer *peer) in __lws_peer_add_to_peer_wait_list()
67 __lws_peer_remove_from_peer_wait_list(context, peer); in __lws_peer_add_to_peer_wait_list()
69 peer->peer_wait_list = context->peer_wait_list; in __lws_peer_add_to_peer_wait_list()
70 context->peer_wait_list = peer; in __lws_peer_add_to_peer_wait_list()
82 struct lws_peer *peer; in lws_get_or_create_peer() local
95 /* eg, udp doesn't have to have a peer */ in lws_get_or_create_peer()
118 lws_context_lock(context, "peer search"); /* <======================= */ in lws_get_or_create_peer()
140 lwsl_info("%s: creating new peer\ in lws_get_or_create_peer()
30 __lws_peer_remove_from_peer_wait_list(struct lws_context *context, struct lws_peer *peer) __lws_peer_remove_from_peer_wait_list() argument
64 __lws_peer_add_to_peer_wait_list(struct lws_context *context, struct lws_peer *peer) __lws_peer_add_to_peer_wait_list() argument
169 __lws_peer_destroy(struct lws_context *context, struct lws_peer *peer) __lws_peer_destroy() argument
218 lws_peer_add_wsi(struct lws_context *context, struct lws_peer *peer, struct lws *wsi) lws_peer_add_wsi() argument
236 struct lws_peer *peer; lws_peer_dump_from_wsi() local
258 lws_peer_track_wsi_close(struct lws_context *context, struct lws_peer *peer) lws_peer_track_wsi_close() argument
290 lws_peer_confirm_ah_attach_ok(struct lws_context *context, struct lws_peer *peer) lws_peer_confirm_ah_attach_ok() argument
308 lws_peer_track_ah_detach(struct lws_context *context, struct lws_peer *peer) lws_peer_track_ah_detach() argument
[all...] |
| /kernel/linux/linux-6.6/drivers/net/wireless/ath/ath12k/ |
| H A D | peer.c | 8 #include "peer.h"
14 struct ath12k_peer *peer; in ath12k_peer_find() local
18 list_for_each_entry(peer, &ab->peers, list) { in ath12k_peer_find()
19 if (peer->vdev_id != vdev_id) in ath12k_peer_find()
21 if (!ether_addr_equal(peer->addr, addr)) in ath12k_peer_find()
24 return peer; in ath12k_peer_find()
33 struct ath12k_peer *peer; in ath12k_peer_find_by_pdev_idx() local
37 list_for_each_entry(peer, &ab->peers, list) { in ath12k_peer_find_by_pdev_idx()
38 if (peer->pdev_idx != pdev_idx) in ath12k_peer_find_by_pdev_idx()
40 if (!ether_addr_equal(peer in ath12k_peer_find_by_pdev_idx()
52 struct ath12k_peer *peer; ath12k_peer_find_by_addr() local
69 struct ath12k_peer *peer; ath12k_peer_find_by_id() local
82 struct ath12k_peer *peer; ath12k_peer_exist_by_vdev_id() local
99 struct ath12k_peer *peer; ath12k_peer_find_by_ast() local
112 struct ath12k_peer *peer; ath12k_peer_unmap_event() local
137 struct ath12k_peer *peer; ath12k_peer_map_event() local
186 struct ath12k_peer *peer, *tmp; ath12k_peer_cleanup() local
268 struct ath12k_peer *peer; ath12k_peer_create() local
[all...] |
| /kernel/linux/linux-5.10/drivers/net/wireless/ath/ath11k/ |
| H A D | peer.c | 7 #include "peer.h"
13 struct ath11k_peer *peer; in ath11k_peer_find() local
17 list_for_each_entry(peer, &ab->peers, list) { in ath11k_peer_find()
18 if (peer->vdev_id != vdev_id) in ath11k_peer_find()
20 if (!ether_addr_equal(peer->addr, addr)) in ath11k_peer_find()
23 return peer; in ath11k_peer_find()
32 struct ath11k_peer *peer; in ath11k_peer_find_by_pdev_idx() local
36 list_for_each_entry(peer, &ab->peers, list) { in ath11k_peer_find_by_pdev_idx()
37 if (peer->pdev_idx != pdev_idx) in ath11k_peer_find_by_pdev_idx()
39 if (!ether_addr_equal(peer in ath11k_peer_find_by_pdev_idx()
51 struct ath11k_peer *peer; ath11k_peer_find_by_addr() local
68 struct ath11k_peer *peer; ath11k_peer_find_by_id() local
82 struct ath11k_peer *peer; ath11k_peer_find_by_vdev_id() local
98 struct ath11k_peer *peer; ath11k_peer_unmap_event() local
123 struct ath11k_peer *peer; ath11k_peer_map_event() local
171 struct ath11k_peer *peer, *tmp; ath11k_peer_cleanup() local
252 struct ath11k_peer *peer; ath11k_peer_create() local
[all...] |
| /kernel/linux/linux-5.10/drivers/ntb/test/ |
| H A D | ntb_perf.c | 64 * Eg: start performance test with peer (index 0) and get the test metrics
204 int (*cmd_send)(struct perf_peer *peer, enum perf_cmd cmd, u64 data);
249 static inline bool perf_link_is_up(struct perf_peer *peer) in perf_link_is_up() argument
253 link = ntb_link_is_up(peer->perf->ntb, NULL, NULL); in perf_link_is_up()
254 return !!(link & BIT_ULL_MASK(peer->pidx)); in perf_link_is_up()
257 static int perf_spad_cmd_send(struct perf_peer *peer, enum perf_cmd cmd, in perf_spad_cmd_send() argument
260 struct perf_ctx *perf = peer->perf; in perf_spad_cmd_send()
274 if (!perf_link_is_up(peer)) in perf_spad_cmd_send()
277 sts = ntb_peer_spad_read(perf->ntb, peer->pidx, in perf_spad_cmd_send()
284 ntb_peer_spad_write(perf->ntb, peer in perf_spad_cmd_send()
307 struct perf_peer *peer; perf_spad_cmd_recv() local
348 perf_msg_cmd_send(struct perf_peer *peer, enum perf_cmd cmd, u64 data) perf_msg_cmd_send() argument
421 perf_cmd_send(struct perf_peer *peer, enum perf_cmd cmd, u64 data) perf_cmd_send() argument
432 perf_cmd_exec(struct perf_peer *peer, enum perf_cmd cmd) perf_cmd_exec() argument
458 struct perf_peer *peer; perf_cmd_recv() local
485 struct perf_peer *peer; perf_link_event() local
532 perf_free_outbuf(struct perf_peer *peer) perf_free_outbuf() argument
537 perf_setup_outbuf(struct perf_peer *peer) perf_setup_outbuf() argument
557 perf_free_inbuf(struct perf_peer *peer) perf_free_inbuf() argument
568 perf_setup_inbuf(struct perf_peer *peer) perf_setup_inbuf() argument
630 struct perf_peer *peer = to_peer_service(work); perf_service_work() local
762 struct perf_peer *peer = &perf->peers[pidx]; perf_disable_service() local
792 struct perf_peer *peer = pthr->perf->test_peer; perf_copy_chunk() local
875 struct perf_peer *peer = pthr->perf->test_peer; perf_init_test() local
924 struct perf_peer *peer = pthr->perf->test_peer; perf_run_test() local
1079 perf_submit_test(struct perf_peer *peer) perf_submit_test() argument
1186 struct perf_peer *peer; perf_dbgfs_read_info() local
1291 struct perf_peer *peer; perf_dbgfs_write_run() local
1409 perf_setup_peer_mw(struct perf_peer *peer) perf_setup_peer_mw() argument
1440 struct perf_peer *peer; perf_init_peers() local
[all...] |
| /kernel/linux/linux-6.6/drivers/ntb/test/ |
| H A D | ntb_perf.c | 64 * Eg: start performance test with peer (index 0) and get the test metrics
204 int (*cmd_send)(struct perf_peer *peer, enum perf_cmd cmd, u64 data);
249 static inline bool perf_link_is_up(struct perf_peer *peer) in perf_link_is_up() argument
253 link = ntb_link_is_up(peer->perf->ntb, NULL, NULL); in perf_link_is_up()
254 return !!(link & BIT_ULL_MASK(peer->pidx)); in perf_link_is_up()
257 static int perf_spad_cmd_send(struct perf_peer *peer, enum perf_cmd cmd, in perf_spad_cmd_send() argument
260 struct perf_ctx *perf = peer->perf; in perf_spad_cmd_send()
274 if (!perf_link_is_up(peer)) in perf_spad_cmd_send()
277 sts = ntb_peer_spad_read(perf->ntb, peer->pidx, in perf_spad_cmd_send()
284 ntb_peer_spad_write(perf->ntb, peer in perf_spad_cmd_send()
307 struct perf_peer *peer; perf_spad_cmd_recv() local
348 perf_msg_cmd_send(struct perf_peer *peer, enum perf_cmd cmd, u64 data) perf_msg_cmd_send() argument
421 perf_cmd_send(struct perf_peer *peer, enum perf_cmd cmd, u64 data) perf_cmd_send() argument
432 perf_cmd_exec(struct perf_peer *peer, enum perf_cmd cmd) perf_cmd_exec() argument
458 struct perf_peer *peer; perf_cmd_recv() local
485 struct perf_peer *peer; perf_link_event() local
532 perf_free_outbuf(struct perf_peer *peer) perf_free_outbuf() argument
537 perf_setup_outbuf(struct perf_peer *peer) perf_setup_outbuf() argument
557 perf_free_inbuf(struct perf_peer *peer) perf_free_inbuf() argument
568 perf_setup_inbuf(struct perf_peer *peer) perf_setup_inbuf() argument
630 struct perf_peer *peer = to_peer_service(work); perf_service_work() local
762 struct perf_peer *peer = &perf->peers[pidx]; perf_disable_service() local
792 struct perf_peer *peer = pthr->perf->test_peer; perf_copy_chunk() local
875 struct perf_peer *peer = pthr->perf->test_peer; perf_init_test() local
924 struct perf_peer *peer = pthr->perf->test_peer; perf_run_test() local
1079 perf_submit_test(struct perf_peer *peer) perf_submit_test() argument
1186 struct perf_peer *peer; perf_dbgfs_read_info() local
1291 struct perf_peer *peer; perf_dbgfs_write_run() local
1409 perf_setup_peer_mw(struct perf_peer *peer) perf_setup_peer_mw() argument
1440 struct perf_peer *peer; perf_init_peers() local
[all...] |
| /kernel/linux/linux-5.10/net/tipc/ |
| H A D | monitor.c | 49 * @ack_gen: most recent generation of self's domain acked by peer
63 /* struct tipc_peer: state of a peer node and its domain
64 * @addr: tipc node identity of peer
65 * @head_map: shows which other nodes currently consider peer 'up'
66 * @domain: most recent domain record from peer
70 * @is_up: peer is up as seen from this node
71 * @is_head: peer is assigned domain head as seen from this node
72 * @is_local: peer is in local domain and should be continuously monitored
136 static struct tipc_peer *peer_prev(struct tipc_peer *peer) in peer_prev() argument
138 return list_last_entry(&peer in peer_prev()
141 peer_nxt(struct tipc_peer *peer) peer_nxt() argument
146 peer_head(struct tipc_peer *peer) peer_head() argument
155 struct tipc_peer *peer; get_peer() local
181 mon_identify_lost_members(struct tipc_peer *peer, struct tipc_mon_domain *dom_bef, int applied_bef) mon_identify_lost_members() argument
215 mon_apply_domain(struct tipc_monitor *mon, struct tipc_peer *peer) mon_apply_domain() argument
245 struct tipc_peer *peer = self; mon_update_local_domain() local
278 mon_update_neighbors(struct tipc_monitor *mon, struct tipc_peer *peer) mon_update_neighbors() argument
296 struct tipc_peer *peer = peer_nxt(head); mon_assign_roles() local
326 struct tipc_peer *peer, *prev, *head; tipc_mon_remove_peer() local
360 tipc_mon_add_peer(struct tipc_monitor *mon, u32 addr, struct tipc_peer **peer) tipc_mon_add_peer() argument
396 struct tipc_peer *peer, *head; tipc_mon_peer_up() local
415 struct tipc_peer *peer, *head; tipc_mon_peer_down() local
457 struct tipc_peer *peer; tipc_mon_rcv() local
573 struct tipc_peer *peer; tipc_mon_get_state() local
656 struct tipc_peer *peer, *tmp; tipc_mon_delete() local
712 __tipc_nl_add_monitor_peer(struct tipc_peer *peer, struct tipc_nl_msg *msg) __tipc_nl_add_monitor_peer() argument
770 struct tipc_peer *peer; tipc_nl_add_monitor_peer() local
[all...] |
| /kernel/linux/linux-6.6/net/tipc/ |
| H A D | monitor.c | 49 * @ack_gen: most recent generation of self's domain acked by peer
63 /* struct tipc_peer: state of a peer node and its domain
64 * @addr: tipc node identity of peer
65 * @head_map: shows which other nodes currently consider peer 'up'
66 * @domain: most recent domain record from peer
70 * @is_up: peer is up as seen from this node
71 * @is_head: peer is assigned domain head as seen from this node
72 * @is_local: peer is in local domain and should be continuously monitored
166 static struct tipc_peer *peer_prev(struct tipc_peer *peer) in peer_prev() argument
168 return list_last_entry(&peer in peer_prev()
171 peer_nxt(struct tipc_peer *peer) peer_nxt() argument
176 peer_head(struct tipc_peer *peer) peer_head() argument
185 struct tipc_peer *peer; get_peer() local
211 mon_identify_lost_members(struct tipc_peer *peer, struct tipc_mon_domain *dom_bef, int applied_bef) mon_identify_lost_members() argument
245 mon_apply_domain(struct tipc_monitor *mon, struct tipc_peer *peer) mon_apply_domain() argument
275 struct tipc_peer *peer = self; mon_update_local_domain() local
308 mon_update_neighbors(struct tipc_monitor *mon, struct tipc_peer *peer) mon_update_neighbors() argument
326 struct tipc_peer *peer = peer_nxt(head); mon_assign_roles() local
356 struct tipc_peer *peer, *prev, *head; tipc_mon_remove_peer() local
390 tipc_mon_add_peer(struct tipc_monitor *mon, u32 addr, struct tipc_peer **peer) tipc_mon_add_peer() argument
426 struct tipc_peer *peer, *head; tipc_mon_peer_up() local
445 struct tipc_peer *peer, *head; tipc_mon_peer_down() local
487 struct tipc_peer *peer; tipc_mon_rcv() local
604 struct tipc_peer *peer; tipc_mon_get_state() local
687 struct tipc_peer *peer, *tmp; tipc_mon_delete() local
743 __tipc_nl_add_monitor_peer(struct tipc_peer *peer, struct tipc_nl_msg *msg) __tipc_nl_add_monitor_peer() argument
801 struct tipc_peer *peer; tipc_nl_add_monitor_peer() local
[all...] |
| /kernel/linux/linux-6.6/net/sctp/ |
| H A D | associola.c | 170 asoc->peer.rwnd = SCTP_DEFAULT_MAXWINDOW; in sctp_association_init()
206 INIT_LIST_HEAD(&asoc->peer.transport_addr_list); in sctp_association_init()
219 asoc->peer.sack_needed = 1; in sctp_association_init()
220 asoc->peer.sack_generation = 1; in sctp_association_init()
238 /* Assume that peer would support both address types unless we are in sctp_association_init()
241 asoc->peer.ipv4_address = 1; in sctp_association_init()
243 asoc->peer.ipv6_address = 1; in sctp_association_init()
347 sctp_tsnmap_free(&asoc->peer.tsn_map); in sctp_association_free()
368 /* Free peer's cached cookie. */ in sctp_association_free()
369 kfree(asoc->peer in sctp_association_free()
481 sctp_assoc_rm_peer(struct sctp_association *asoc, struct sctp_transport *peer) sctp_assoc_rm_peer() argument
587 struct sctp_transport *peer; sctp_assoc_add_peer() local
[all...] |
| /kernel/linux/linux-5.10/net/sctp/ |
| H A D | associola.c | 167 asoc->peer.rwnd = SCTP_DEFAULT_MAXWINDOW; in sctp_association_init()
203 INIT_LIST_HEAD(&asoc->peer.transport_addr_list); in sctp_association_init()
216 asoc->peer.sack_needed = 1; in sctp_association_init()
217 asoc->peer.sack_generation = 1; in sctp_association_init()
236 /* Assume that peer would support both address types unless we are in sctp_association_init()
239 asoc->peer.ipv4_address = 1; in sctp_association_init()
241 asoc->peer.ipv6_address = 1; in sctp_association_init()
346 sctp_tsnmap_free(&asoc->peer.tsn_map); in sctp_association_free()
367 /* Free peer's cached cookie. */ in sctp_association_free()
368 kfree(asoc->peer in sctp_association_free()
480 sctp_assoc_rm_peer(struct sctp_association *asoc, struct sctp_transport *peer) sctp_assoc_rm_peer() argument
586 struct sctp_transport *peer; sctp_assoc_add_peer() local
[all...] |
| /kernel/linux/linux-6.6/drivers/net/wireless/ath/ath11k/ |
| H A D | peer.c | 8 #include "peer.h"
14 struct ath11k_peer *peer; in ath11k_peer_find_list_by_id() local
18 list_for_each_entry(peer, &ab->peers, list) { in ath11k_peer_find_list_by_id()
19 if (peer->peer_id != peer_id) in ath11k_peer_find_list_by_id()
22 return peer; in ath11k_peer_find_list_by_id()
31 struct ath11k_peer *peer; in ath11k_peer_find() local
35 list_for_each_entry(peer, &ab->peers, list) { in ath11k_peer_find()
36 if (peer->vdev_id != vdev_id) in ath11k_peer_find()
38 if (!ether_addr_equal(peer->addr, addr)) in ath11k_peer_find()
41 return peer; in ath11k_peer_find()
50 struct ath11k_peer *peer; ath11k_peer_find_by_addr() local
66 struct ath11k_peer *peer; ath11k_peer_find_by_id() local
82 struct ath11k_peer *peer; ath11k_peer_find_by_vdev_id() local
98 struct ath11k_peer *peer; ath11k_peer_unmap_event() local
123 struct ath11k_peer *peer; ath11k_peer_map_event() local
206 ath11k_peer_rhash_add(struct ath11k_base *ab, struct ath11k_peer *peer) ath11k_peer_rhash_add() argument
242 struct ath11k_peer *peer, *tmp; ath11k_peer_cleanup() local
296 struct ath11k_peer *peer; __ath11k_peer_delete() local
373 struct ath11k_peer *peer; ath11k_peer_create() local
474 ath11k_peer_rhash_delete(struct ath11k_base *ab, struct ath11k_peer *peer) ath11k_peer_rhash_delete() argument
[all...] |
| /kernel/linux/linux-5.10/drivers/net/can/ |
| H A D | vxcan.c | 33 struct net_device __rcu *peer; member
39 struct net_device *peer; in vxcan_xmit() local
48 peer = rcu_dereference(priv->peer); in vxcan_xmit()
49 if (unlikely(!peer)) { in vxcan_xmit()
62 skb->dev = peer; in vxcan_xmit()
69 peerstats = &peer->stats; in vxcan_xmit()
83 struct net_device *peer = rtnl_dereference(priv->peer); in vxcan_open() local
85 if (!peer) in vxcan_open()
98 struct net_device *peer = rtnl_dereference(priv->peer); vxcan_close() local
110 struct net_device *peer; vxcan_get_iflink() local
167 struct net_device *peer; vxcan_newlink() local
254 struct net_device *peer; vxcan_dellink() local
280 struct net_device *peer = rtnl_dereference(priv->peer); vxcan_get_link_net() local
[all...] |