Home
last modified time | relevance | path

Searched refs:peer (Results 1 - 25 of 787) sorted by relevance

12345678910>>...32

/kernel/linux/linux-5.10/drivers/net/wireguard/
H A Dtimers.c8 #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 Dpeer.c6 #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 Dsend.c9 #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...]
H A Dnetlink.c8 #include "peer.h"
106 get_peer(struct wg_peer *peer, struct sk_buff *skb, struct dump_ctx *ctx) in get_peer() argument
116 down_read(&peer->handshake.lock); in get_peer()
118 peer->handshake.remote_static); in get_peer()
119 up_read(&peer->handshake.lock); in get_peer()
125 .tv_sec = peer->walltime_last_handshake.tv_sec, in get_peer()
126 .tv_nsec = peer->walltime_last_handshake.tv_nsec in get_peer()
129 down_read(&peer->handshake.lock); in get_peer()
132 peer->handshake.preshared_key); in get_peer()
133 up_read(&peer in get_peer()
212 struct wg_peer *peer, *next_peer_cursor; wg_get_device_dump() local
316 struct wg_peer *peer; set_port() local
329 set_allowedip(struct wg_peer *peer, struct nlattr **attrs) set_allowedip() argument
360 struct wg_peer *peer = NULL; set_peer() local
526 struct wg_peer *peer; wg_set_device() local
548 struct wg_peer *peer, *temp; wg_set_device() local
584 struct nlattr *attr, *peer[WGPEER_A_MAX + 1]; wg_set_device() local
[all...]
/kernel/linux/linux-6.6/drivers/net/wireguard/
H A Dtimers.c8 #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 Dpeer.c6 #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 Dsend.c9 #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...]
H A Dnetlink.c8 #include "peer.h"
106 get_peer(struct wg_peer *peer, struct sk_buff *skb, struct dump_ctx *ctx) in get_peer() argument
116 down_read(&peer->handshake.lock); in get_peer()
118 peer->handshake.remote_static); in get_peer()
119 up_read(&peer->handshake.lock); in get_peer()
125 .tv_sec = peer->walltime_last_handshake.tv_sec, in get_peer()
126 .tv_nsec = peer->walltime_last_handshake.tv_nsec in get_peer()
129 down_read(&peer->handshake.lock); in get_peer()
132 peer->handshake.preshared_key); in get_peer()
133 up_read(&peer in get_peer()
212 struct wg_peer *peer, *next_peer_cursor; wg_get_device_dump() local
316 struct wg_peer *peer; set_port() local
329 set_allowedip(struct wg_peer *peer, struct nlattr **attrs) set_allowedip() argument
360 struct wg_peer *peer = NULL; set_peer() local
526 struct wg_peer *peer; wg_set_device() local
548 struct wg_peer *peer, *temp; wg_set_device() local
584 struct nlattr *attr, *peer[WGPEER_A_MAX + 1]; wg_set_device() local
[all...]
/kernel/linux/linux-5.10/net/rxrpc/
H A Dpeer_object.c26 * 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 Drtt.c18 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...]
H A Dpeer_event.c26 * Find the peer associated with an ICMP packet.
107 static void rxrpc_adjust_mtu(struct rxrpc_peer *peer, struct sock_exterr_skb *serr) in rxrpc_adjust_mtu() argument
114 if (mtu > 0 && peer->if_mtu == 65535 && mtu < peer->if_mtu) { in rxrpc_adjust_mtu()
115 peer->if_mtu = mtu; in rxrpc_adjust_mtu()
121 mtu = peer->if_mtu; in rxrpc_adjust_mtu()
128 if (mtu < peer->hdrsize) in rxrpc_adjust_mtu()
129 mtu = peer->hdrsize + 4; in rxrpc_adjust_mtu()
133 if (mtu < peer->mtu) { in rxrpc_adjust_mtu()
134 spin_lock_bh(&peer in rxrpc_adjust_mtu()
151 struct rxrpc_peer *peer; rxrpc_error_report() local
216 rxrpc_store_error(struct rxrpc_peer *peer, struct sock_exterr_skb *serr) rxrpc_store_error() argument
288 rxrpc_distribute_error(struct rxrpc_peer *peer, int error, enum rxrpc_call_completion compl) rxrpc_distribute_error() argument
307 struct rxrpc_peer *peer; rxrpc_peer_keepalive_dispatch() local
[all...]
/kernel/linux/linux-6.6/net/rxrpc/
H A Dpeer_object.c26 * 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 Drtt.c18 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...]
H A Dpeer_event.c26 * Find the peer associated with a local error.
103 static void rxrpc_adjust_mtu(struct rxrpc_peer *peer, unsigned int mtu) in rxrpc_adjust_mtu() argument
106 if (mtu > 0 && peer->if_mtu == 65535 && mtu < peer->if_mtu) in rxrpc_adjust_mtu()
107 peer->if_mtu = mtu; in rxrpc_adjust_mtu()
111 mtu = peer->if_mtu; in rxrpc_adjust_mtu()
118 if (mtu < peer->hdrsize) in rxrpc_adjust_mtu()
119 mtu = peer->hdrsize + 4; in rxrpc_adjust_mtu()
123 if (mtu < peer->mtu) { in rxrpc_adjust_mtu()
124 spin_lock(&peer in rxrpc_adjust_mtu()
138 struct rxrpc_peer *peer = NULL; rxrpc_input_error() local
172 rxrpc_store_error(struct rxrpc_peer *peer, struct sk_buff *skb) rxrpc_store_error() argument
202 rxrpc_distribute_error(struct rxrpc_peer *peer, struct sk_buff *skb, enum rxrpc_call_completion compl, int err) rxrpc_distribute_error() argument
235 struct rxrpc_peer *peer; rxrpc_peer_keepalive_dispatch() local
[all...]
/kernel/linux/linux-6.6/drivers/net/wireless/ath/ath12k/
H A Dpeer.c8 #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 Dpeer.c7 #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 Dntb_perf.c64 * 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 Dntb_perf.c64 * 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 Dmonitor.c49 * @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 Dmonitor.c49 * @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 Dassociola.c170 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 Dassociola.c167 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 Dpeer.c8 #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 Dvxcan.c33 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...]
/kernel/linux/linux-6.6/drivers/net/can/
H A Dvxcan.c34 struct net_device __rcu *peer; member
40 struct net_device *peer; in vxcan_xmit() local
49 peer = rcu_dereference(priv->peer); in vxcan_xmit()
50 if (unlikely(!peer)) { in vxcan_xmit()
69 skb->dev = peer; in vxcan_xmit()
76 peerstats = &peer->stats; in vxcan_xmit()
90 struct net_device *peer = rtnl_dereference(priv->peer); in vxcan_open() local
92 if (!peer) in vxcan_open()
105 struct net_device *peer = rtnl_dereference(priv->peer); vxcan_close() local
117 struct net_device *peer; vxcan_get_iflink() local
180 struct net_device *peer; vxcan_newlink() local
267 struct net_device *peer; vxcan_dellink() local
293 struct net_device *peer = rtnl_dereference(priv->peer); vxcan_get_link_net() local
[all...]

Completed in 15 milliseconds

12345678910>>...32