| /OK3568_Linux_fs/kernel/drivers/net/wireguard/ |
| H A 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 …]
|
| H A 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 …]
|
| H A 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 …]
|
| H A 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 …]
|
| H A 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 …]
|
| H A 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 …]
|
| H A 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()
68 struct wg_peer *peer; in wg_pm_notification() local
83 list_for_each_entry(peer, &wg->peer_list, peer_list) { in wg_pm_notification()
84 del_timer(&peer->timer_zero_key_material); in wg_pm_notification()
85 wg_noise_handshake_clear(&peer->handshake); in wg_pm_notification()
86 wg_noise_keypairs_clear(&peer->keypairs); in wg_pm_notification()
[all …]
|
| /OK3568_Linux_fs/kernel/net/rxrpc/ |
| H A 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 …]
|
| 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->mdev_us > peer->mdev_max_us) { in rxrpc_rtt_estimator()
86 peer->mdev_max_us = peer->mdev_us; in rxrpc_rtt_estimator()
[all …]
|
| H A D | peer_event.c | 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->lock); in rxrpc_adjust_mtu()
135 peer->mtu = mtu; in rxrpc_adjust_mtu()
136 peer->maxdata = peer->mtu - peer->hdrsize; in rxrpc_adjust_mtu()
[all …]
|
| /OK3568_Linux_fs/kernel/drivers/net/wireless/ath/ath11k/ |
| H A D | peer.c | 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->addr, addr)) in ath11k_peer_find_by_pdev_idx()
42 return peer; in ath11k_peer_find_by_pdev_idx()
[all …]
|
| /OK3568_Linux_fs/kernel/net/tipc/ |
| H A D | monitor.c | 136 static struct tipc_peer *peer_prev(struct tipc_peer *peer) in peer_prev() argument
138 return list_last_entry(&peer->list, struct tipc_peer, list); in peer_prev()
141 static struct tipc_peer *peer_nxt(struct tipc_peer *peer) in peer_nxt() argument
143 return list_first_entry(&peer->list, struct tipc_peer, list); in peer_nxt()
146 static struct tipc_peer *peer_head(struct tipc_peer *peer) in peer_head() argument
148 while (!peer->is_head) in peer_head()
149 peer = peer_prev(peer); in peer_head()
150 return peer; in peer_head()
155 struct tipc_peer *peer; in get_peer() local
158 hlist_for_each_entry(peer, &mon->peers[thash], hash) { in get_peer()
[all …]
|
| /OK3568_Linux_fs/kernel/drivers/ntb/test/ |
| H A 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 …]
|
| H A 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 …]
|
| /OK3568_Linux_fs/kernel/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()
88 if (peer->flags & IFF_UP) { in vxcan_open()
90 netif_carrier_on(peer); in vxcan_open()
[all …]
|
| /OK3568_Linux_fs/yocto/meta-openembedded/meta-networking/recipes-protocols/frr/frr/ |
| H A D | CVE-2022-37035.patch | 7 to a peer, usually during error handling. The io pthread wants
10 with the peer struct itself, and that's not safe.
13 notify api so that it can avoid touching the peer struct.
40 #include "bgpd/bgpd.h" // for peer, BGP_MARKER_SIZE, bgp_master, bm
42 @@ -526,8 +526,8 @@ static bool validate_header(struct peer *peer)
46 - bgp_notify_send(peer, BGP_NOTIFY_HEADER_ERR,
48 + bgp_notify_io_invalid(peer, BGP_NOTIFY_HEADER_ERR,
53 @@ -547,9 +547,8 @@ static bool validate_header(struct peer *peer)
54 zlog_debug("%s unknown message type 0x%02x", peer->host,
57 - bgp_notify_send_with_data(peer, BGP_NOTIFY_HEADER_ERR,
[all …]
|
| /OK3568_Linux_fs/kernel/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()
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()
368 kfree(asoc->peer.cookie); in sctp_association_free()
369 kfree(asoc->peer.peer_random); in sctp_association_free()
370 kfree(asoc->peer.peer_chunks); in sctp_association_free()
[all …]
|
| /OK3568_Linux_fs/kernel/drivers/staging/fwserial/ |
| H A 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 …]
|
| /OK3568_Linux_fs/kernel/net/bluetooth/ |
| H A 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_ba() local
116 list_for_each_entry_rcu(peer, &dev->peers, list) { in peer_lookup_ba()
118 &peer->chan->dst, peer->chan->dst_type); in peer_lookup_ba()
120 if (bacmp(&peer->chan->dst, ba)) in peer_lookup_ba()
123 if (type == peer->chan->dst_type) { in peer_lookup_ba()
[all …]
|
| /OK3568_Linux_fs/kernel/drivers/net/wireless/ath/ath10k/ |
| H A 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 …]
|
| /OK3568_Linux_fs/kernel/net/smc/ |
| H A 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 …]
|
| /OK3568_Linux_fs/kernel/drivers/net/ |
| H A D | veth.c | 69 struct net_device __rcu *peer; member
178 struct net_device *peer = rtnl_dereference(priv->peer); in veth_get_ethtool_stats() local
181 data[0] = peer ? peer->ifindex : 0; in veth_get_ethtool_stats()
199 if (!peer) in veth_get_ethtool_stats()
202 rcv_priv = netdev_priv(peer); in veth_get_ethtool_stats()
203 for (i = 0; i < peer->real_num_rx_queues; i++) { in veth_get_ethtool_stats()
294 rcv = rcu_dereference(priv->peer); in veth_xmit()
367 struct net_device *peer; in veth_get_stats64() local
382 peer = rcu_dereference(priv->peer); in veth_get_stats64()
383 if (peer) { in veth_get_stats64()
[all …]
|
| /OK3568_Linux_fs/kernel/drivers/usb/core/ |
| H A D | port.c | 198 struct usb_port *peer = port_dev->peer; in usb_port_runtime_resume() local
213 if (!port_dev->is_superspeed && peer) in usb_port_runtime_resume()
214 pm_runtime_get_sync(&peer->dev); in usb_port_runtime_resume()
256 struct usb_port *peer = port_dev->peer; in usb_port_runtime_suspend() local
287 if (!port_dev->is_superspeed && peer) in usb_port_runtime_suspend()
288 pm_runtime_put(&peer->dev); in usb_port_runtime_suspend()
326 if (left->peer == right && right->peer == left) in link_peers()
329 if (left->peer || right->peer) { in link_peers()
330 struct usb_port *lpeer = left->peer; in link_peers()
331 struct usb_port *rpeer = right->peer; in link_peers()
[all …]
|
| /OK3568_Linux_fs/kernel/drivers/ntb/ |
| H A D | msi.c | 101 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 …]
|
| /OK3568_Linux_fs/kernel/drivers/net/wireless/marvell/mwifiex/ |
| H A D | tdls.c | 465 const u8 *peer, u8 action_code, in mwifiex_prep_tdls_encap_data() argument
478 memcpy(tf->da, peer, ETH_ALEN); in mwifiex_prep_tdls_encap_data()
572 ret = mwifiex_tdls_add_vht_oper(priv, peer, skb); in mwifiex_prep_tdls_encap_data()
577 ret = mwifiex_tdls_add_ht_oper(priv, peer, 1, skb); in mwifiex_prep_tdls_encap_data()
583 ret = mwifiex_tdls_add_ht_oper(priv, peer, 0, skb); in mwifiex_prep_tdls_encap_data()
614 const u8 *peer, const u8 *bssid) in mwifiex_tdls_add_link_ie() argument
625 memcpy(lnkid->resp_sta, peer, ETH_ALEN); in mwifiex_tdls_add_link_ie()
628 int mwifiex_send_tdls_data_frame(struct mwifiex_private *priv, const u8 *peer, in mwifiex_send_tdls_data_frame() argument
673 ret = mwifiex_prep_tdls_encap_data(priv, peer, action_code, in mwifiex_send_tdls_data_frame()
682 mwifiex_tdls_add_link_ie(skb, priv->curr_addr, peer, in mwifiex_send_tdls_data_frame()
[all …]
|