| /linux-5.19.10/drivers/net/wireguard/ |
| D | timers.c | 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()
48 peer->device->dev->name, peer->internal_id, in wg_expired_retransmit_handshake()
49 &peer->endpoint.addr, MAX_TIMER_HANDSHAKES + 2); in wg_expired_retransmit_handshake()
51 del_timer(&peer->timer_send_keepalive); in wg_expired_retransmit_handshake()
55 wg_packet_purge_staged_packets(peer); in wg_expired_retransmit_handshake()
60 if (!timer_pending(&peer->timer_zero_key_material)) in wg_expired_retransmit_handshake()
[all …]
|
| D | peer.c | 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->serial_work_cpu = nr_cpumask_bits; in wg_peer_create()
44 wg_cookie_init(&peer->latest_cookie); in wg_peer_create()
[all …]
|
| D | send.c | 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()
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()
36 wg_timers_any_authenticated_packet_traversal(peer); in wg_packet_send_handshake_initiation()
37 wg_timers_any_authenticated_packet_sent(peer); in wg_packet_send_handshake_initiation()
38 atomic64_set(&peer->last_sent_handshake, in wg_packet_send_handshake_initiation()
[all …]
|
| D | netlink.c | 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->handshake.lock); in get_peer()
140 peer->persistent_keepalive_interval) || in get_peer()
[all …]
|
| D | receive.c | 20 static void update_rx_stats(struct wg_peer *peer, size_t len) in update_rx_stats() argument
23 get_cpu_ptr(peer->device->dev->tstats); in update_rx_stats()
28 peer->rx_bytes += len; in update_rx_stats()
103 struct wg_peer *peer = NULL; in wg_receive_handshake_packet() local
151 peer = wg_noise_handshake_consume_initiation(message, wg); in wg_receive_handshake_packet()
152 if (unlikely(!peer)) { in wg_receive_handshake_packet()
157 wg_socket_set_peer_endpoint_from_skb(peer, skb); in wg_receive_handshake_packet()
159 wg->dev->name, peer->internal_id, in wg_receive_handshake_packet()
160 &peer->endpoint.addr); in wg_receive_handshake_packet()
161 wg_packet_send_handshake_response(peer); in wg_receive_handshake_packet()
[all …]
|
| D | cookie.c | 61 void wg_cookie_checker_precompute_peer_keys(struct wg_peer *peer) in wg_cookie_checker_precompute_peer_keys() argument
63 precompute_key(peer->latest_cookie.cookie_decryption_key, in wg_cookie_checker_precompute_peer_keys()
64 peer->handshake.remote_static, cookie_key_label); in wg_cookie_checker_precompute_peer_keys()
65 precompute_key(peer->latest_cookie.message_mac1_key, in wg_cookie_checker_precompute_peer_keys()
66 peer->handshake.remote_static, mac1_key_label); in wg_cookie_checker_precompute_peer_keys()
157 struct wg_peer *peer) in wg_cookie_add_mac_to_packet() argument
162 down_write(&peer->latest_cookie.lock); in wg_cookie_add_mac_to_packet()
164 peer->latest_cookie.message_mac1_key); in wg_cookie_add_mac_to_packet()
165 memcpy(peer->latest_cookie.last_mac1_sent, macs->mac1, COOKIE_LEN); in wg_cookie_add_mac_to_packet()
166 peer->latest_cookie.have_sent_mac1 = true; in wg_cookie_add_mac_to_packet()
[all …]
|
| D | timers.h | 13 void wg_timers_init(struct wg_peer *peer);
14 void wg_timers_stop(struct wg_peer *peer);
15 void wg_timers_data_sent(struct wg_peer *peer);
16 void wg_timers_data_received(struct wg_peer *peer);
17 void wg_timers_any_authenticated_packet_sent(struct wg_peer *peer);
18 void wg_timers_any_authenticated_packet_received(struct wg_peer *peer);
19 void wg_timers_handshake_initiated(struct wg_peer *peer);
20 void wg_timers_handshake_complete(struct wg_peer *peer);
21 void wg_timers_session_derived(struct wg_peer *peer);
22 void wg_timers_any_authenticated_packet_traversal(struct wg_peer *peer);
|
| D | device.c | 35 struct wg_peer *peer; in wg_open() local
53 list_for_each_entry(peer, &wg->peer_list, peer_list) { in wg_open()
54 wg_packet_send_staged_packets(peer); in wg_open()
55 if (peer->persistent_keepalive_interval) in wg_open()
56 wg_packet_send_keepalive(peer); in wg_open()
66 struct wg_peer *peer; in wg_pm_notification() local
81 list_for_each_entry(peer, &wg->peer_list, peer_list) { in wg_pm_notification()
82 del_timer(&peer->timer_zero_key_material); in wg_pm_notification()
83 wg_noise_handshake_clear(&peer->handshake); in wg_pm_notification()
84 wg_noise_keypairs_clear(&peer->keypairs); in wg_pm_notification()
[all …]
|
| D | peerlookup.c | 36 struct wg_peer *peer) in wg_pubkey_hashtable_add() argument
39 hlist_add_head_rcu(&peer->pubkey_hash, in wg_pubkey_hashtable_add()
40 pubkey_bucket(table, peer->handshake.remote_static)); in wg_pubkey_hashtable_add()
45 struct wg_peer *peer) in wg_pubkey_hashtable_remove() argument
48 hlist_del_init_rcu(&peer->pubkey_hash); in wg_pubkey_hashtable_remove()
57 struct wg_peer *iter_peer, *peer = NULL; in wg_pubkey_hashtable_lookup() local
64 peer = iter_peer; in wg_pubkey_hashtable_lookup()
68 peer = wg_peer_get_maybe_zero(peer); in wg_pubkey_hashtable_lookup()
70 return peer; in wg_pubkey_hashtable_lookup()
204 const __le32 index, struct wg_peer **peer) in wg_index_hashtable_lookup() argument
[all …]
|
| /linux-5.19.10/net/rxrpc/ |
| D | peer_object.c | 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->srx.transport.sin.sin_port - in rxrpc_peer_cmp_key()
95 memcmp(&peer->srx.transport.sin.sin_addr, in rxrpc_peer_cmp_key()
100 return ((u16 __force)peer->srx.transport.sin6.sin6_port - in rxrpc_peer_cmp_key()
102 memcmp(&peer->srx.transport.sin6.sin6_addr, in rxrpc_peer_cmp_key()
[all …]
|
| 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->mdev_us > peer->mdev_max_us) { in rxrpc_rtt_estimator()
86 peer->mdev_max_us = peer->mdev_us; in rxrpc_rtt_estimator()
[all …]
|
| D | peer_event.c | 161 struct rxrpc_peer *peer; in rxrpc_encap_err_rcv() local
179 peer = rxrpc_lookup_peer_icmp_rcu(local, skb, udp_offset, in rxrpc_encap_err_rcv()
184 peer = rxrpc_lookup_peer_icmp6_rcu(local, skb, udp_offset, in rxrpc_encap_err_rcv()
193 if (peer && !rxrpc_get_peer_maybe(peer)) in rxrpc_encap_err_rcv()
194 peer = NULL; in rxrpc_encap_err_rcv()
195 if (!peer) { in rxrpc_encap_err_rcv()
208 rxrpc_adjust_mtu(peer, info); in rxrpc_encap_err_rcv()
210 rxrpc_put_peer(peer); in rxrpc_encap_err_rcv()
244 rxrpc_adjust_mtu(peer, info); in rxrpc_encap_err_rcv()
246 rxrpc_put_peer(peer); in rxrpc_encap_err_rcv()
[all …]
|
| D | conn_service.c | 27 struct rxrpc_connection *rxrpc_find_service_conn_rcu(struct rxrpc_peer *peer, in rxrpc_find_service_conn_rcu() argument
44 read_seqbegin_or_lock(&peer->service_conn_lock, &seq); in rxrpc_find_service_conn_rcu()
46 p = rcu_dereference_raw(peer->service_conns.rb_node); in rxrpc_find_service_conn_rcu()
58 } while (need_seqretry(&peer->service_conn_lock, seq)); in rxrpc_find_service_conn_rcu()
60 done_seqretry(&peer->service_conn_lock, seq); in rxrpc_find_service_conn_rcu()
69 static void rxrpc_publish_service_conn(struct rxrpc_peer *peer, in rxrpc_publish_service_conn() argument
76 write_seqlock_bh(&peer->service_conn_lock); in rxrpc_publish_service_conn()
78 pp = &peer->service_conns.rb_node; in rxrpc_publish_service_conn()
94 rb_insert_color(&conn->service_node, &peer->service_conns); in rxrpc_publish_service_conn()
97 write_sequnlock_bh(&peer->service_conn_lock); in rxrpc_publish_service_conn()
[all …]
|
| /linux-5.19.10/drivers/net/can/ |
| D | vxcan.c | 33 struct net_device __rcu *peer; member
39 struct net_device *peer; in vxcan_xmit() local
49 peer = rcu_dereference(priv->peer); in vxcan_xmit()
50 if (unlikely(!peer)) { in vxcan_xmit()
67 skb->dev = peer; in vxcan_xmit()
74 peerstats = &peer->stats; in vxcan_xmit()
88 struct net_device *peer = rtnl_dereference(priv->peer); in vxcan_open() local
90 if (!peer) in vxcan_open()
93 if (peer->flags & IFF_UP) { in vxcan_open()
95 netif_carrier_on(peer); in vxcan_open()
[all …]
|
| /linux-5.19.10/drivers/ntb/test/ |
| D | ntb_perf.c | 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->pidx, in perf_spad_cmd_send()
287 ntb_peer_spad_write(perf->ntb, peer->pidx, in perf_spad_cmd_send()
[all …]
|
| D | ntb_msi_test.c | 131 static void ntb_msit_copy_peer_desc(struct ntb_msit_ctx *nm, int peer) in ntb_msit_copy_peer_desc() argument
134 struct ntb_msi_desc *desc = nm->peers[peer].msi_desc; in ntb_msit_copy_peer_desc()
135 int irq_count = nm->peers[peer].num_irqs; in ntb_msit_copy_peer_desc()
138 desc[i].addr_offset = ntb_peer_spad_read(nm->ntb, peer, in ntb_msit_copy_peer_desc()
140 desc[i].data = ntb_peer_spad_read(nm->ntb, peer, 2 * i + 2); in ntb_msit_copy_peer_desc()
144 irq_count, peer); in ntb_msit_copy_peer_desc()
146 complete_all(&nm->peers[peer].init_comp); in ntb_msit_copy_peer_desc()
155 int peer; in ntb_msit_db_event() local
159 for (peer = 0; peer < sizeof(peer_mask) * 8; peer++) { in ntb_msit_db_event()
160 if (!(peer_mask & BIT(peer))) in ntb_msit_db_event()
[all …]
|
| /linux-5.19.10/drivers/net/wireless/ath/ath11k/ |
| D | peer.c | 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; in ath11k_peer_find_by_addr() local
[all …]
|
| /linux-5.19.10/net/tipc/ |
| D | monitor.c | 166 static struct tipc_peer *peer_prev(struct tipc_peer *peer) in peer_prev() argument
168 return list_last_entry(&peer->list, struct tipc_peer, list); in peer_prev()
171 static struct tipc_peer *peer_nxt(struct tipc_peer *peer) in peer_nxt() argument
173 return list_first_entry(&peer->list, struct tipc_peer, list); in peer_nxt()
176 static struct tipc_peer *peer_head(struct tipc_peer *peer) in peer_head() argument
178 while (!peer->is_head) in peer_head()
179 peer = peer_prev(peer); in peer_head()
180 return peer; in peer_head()
185 struct tipc_peer *peer; in get_peer() local
188 hlist_for_each_entry(peer, &mon->peers[thash], hash) { in get_peer()
[all …]
|
| /linux-5.19.10/net/sctp/ |
| 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()
242 asoc->peer.ipv4_address = 1; in sctp_association_init()
244 asoc->peer.ipv6_address = 1; in sctp_association_init()
349 sctp_tsnmap_free(&asoc->peer.tsn_map); in sctp_association_free()
371 kfree(asoc->peer.cookie); in sctp_association_free()
372 kfree(asoc->peer.peer_random); in sctp_association_free()
373 kfree(asoc->peer.peer_chunks); in sctp_association_free()
[all …]
|
| /linux-5.19.10/drivers/staging/fwserial/ |
| D | fwserial.c | 227 static int fwtty_send_data_async(struct fwtty_peer *peer, int tcode, in fwtty_send_data_async() argument
242 generation = peer->generation; in fwtty_send_data_async()
244 fw_send_request(peer->serial->card, &txn->fw_txn, tcode, in fwtty_send_data_async()
245 peer->node_id, generation, peer->speed, addr, payload, in fwtty_send_data_async()
250 static void fwtty_send_txn_async(struct fwtty_peer *peer, in fwtty_send_txn_async() argument
261 generation = peer->generation; in fwtty_send_txn_async()
263 fw_send_request(peer->serial->card, &txn->fw_txn, tcode, in fwtty_send_txn_async()
264 peer->node_id, generation, peer->speed, addr, payload, in fwtty_send_txn_async()
413 struct fwtty_peer *peer; in __fwtty_write_port_status() local
418 peer = rcu_dereference(port->peer); in __fwtty_write_port_status()
[all …]
|
| /linux-5.19.10/drivers/net/wireless/ath/ath10k/ |
| D | txrx.c | 140 struct ath10k_peer *peer; in ath10k_peer_find() local
144 list_for_each_entry(peer, &ar->peers, list) { in ath10k_peer_find()
145 if (peer->vdev_id != vdev_id) in ath10k_peer_find()
147 if (!ether_addr_equal(peer->addr, addr)) in ath10k_peer_find()
150 return peer; in ath10k_peer_find()
158 struct ath10k_peer *peer; in ath10k_peer_find_by_id() local
160 if (peer_id >= BITS_PER_TYPE(peer->peer_ids)) in ath10k_peer_find_by_id()
165 list_for_each_entry(peer, &ar->peers, list) in ath10k_peer_find_by_id()
166 if (test_bit(peer_id, peer->peer_ids)) in ath10k_peer_find_by_id()
167 return peer; in ath10k_peer_find_by_id()
[all …]
|
| /linux-5.19.10/net/smc/ |
| D | smc_cdc.h | 195 static inline void smc_host_cursor_to_cdc(union smc_cdc_cursor *peer, in smc_host_cursor_to_cdc() argument
201 peer->count = htonl(save->count); in smc_host_cursor_to_cdc()
202 peer->wrap = htons(save->wrap); in smc_host_cursor_to_cdc()
206 static inline void smc_host_msg_to_cdc(struct smc_cdc_msg *peer, in smc_host_msg_to_cdc() argument
212 peer->common.type = local->common.type; in smc_host_msg_to_cdc()
213 peer->len = local->len; in smc_host_msg_to_cdc()
214 peer->seqno = htons(local->seqno); in smc_host_msg_to_cdc()
215 peer->token = htonl(local->token); in smc_host_msg_to_cdc()
216 smc_host_cursor_to_cdc(&peer->prod, &local->prod, save, conn); in smc_host_msg_to_cdc()
217 smc_host_cursor_to_cdc(&peer->cons, &local->cons, save, conn); in smc_host_msg_to_cdc()
[all …]
|
| /linux-5.19.10/net/bluetooth/ |
| D | 6lowpan.c | 84 struct lowpan_peer *peer) in peer_add() argument
86 list_add_rcu(&peer->list, &dev->peers); in peer_add()
91 struct lowpan_peer *peer) in peer_del() argument
93 list_del_rcu(&peer->list); in peer_del()
94 kfree_rcu(peer, rcu); in peer_del()
109 struct lowpan_peer *peer; in __peer_lookup_chan() local
111 list_for_each_entry_rcu(peer, &dev->peers, list) { in __peer_lookup_chan()
112 if (peer->chan == chan) in __peer_lookup_chan()
113 return peer; in __peer_lookup_chan()
122 struct lowpan_peer *peer; in __peer_lookup_conn() local
[all …]
|
| /linux-5.19.10/drivers/ntb/ |
| D | msi.c | 99 int peer, peer_widx; in ntb_msi_setup_mws() local
114 for (peer = 0; peer < ntb_peer_port_count(ntb); peer++) { in ntb_msi_setup_mws()
115 peer_widx = ntb_peer_highest_mw_idx(ntb, peer); in ntb_msi_setup_mws()
119 ret = ntb_mw_get_align(ntb, peer, peer_widx, &addr_align, in ntb_msi_setup_mws()
127 for (peer = 0; peer < ntb_peer_port_count(ntb); peer++) { in ntb_msi_setup_mws()
128 peer_widx = ntb_peer_highest_mw_idx(ntb, peer); in ntb_msi_setup_mws()
134 ret = ntb_mw_get_align(ntb, peer, peer_widx, NULL, in ntb_msi_setup_mws()
144 ret = ntb_mw_set_trans(ntb, peer, peer_widx, in ntb_msi_setup_mws()
156 for (i = 0; i < peer; i++) { in ntb_msi_setup_mws()
157 peer_widx = ntb_peer_highest_mw_idx(ntb, peer); in ntb_msi_setup_mws()
[all …]
|
| /linux-5.19.10/drivers/usb/core/ |
| D | port.c | 199 struct usb_port *peer = port_dev->peer; in usb_port_runtime_resume() local
214 if (!port_dev->is_superspeed && peer) in usb_port_runtime_resume()
215 pm_runtime_get_sync(&peer->dev); in usb_port_runtime_resume()
257 struct usb_port *peer = port_dev->peer; in usb_port_runtime_suspend() local
288 if (!port_dev->is_superspeed && peer) in usb_port_runtime_suspend()
289 pm_runtime_put(&peer->dev); in usb_port_runtime_suspend()
327 if (left->peer == right && right->peer == left) in link_peers()
330 if (left->peer || right->peer) { in link_peers()
331 struct usb_port *lpeer = left->peer; in link_peers()
332 struct usb_port *rpeer = right->peer; in link_peers()
[all …]
|