11 #include "peer.h"
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
82 		list_for_each_entry(peer, &wg->peer_list, peer_list) {  in wg_pm_notification()
83 			del_timer(&peer->timer_zero_key_material);  in wg_pm_notification()
84 			wg_noise_handshake_clear(&peer->handshake);  in wg_pm_notification()
85 			wg_noise_keypairs_clear(&peer->keypairs);  in wg_pm_notification()
99 	struct wg_peer *peer;  in wg_vm_notification()  local
104 		list_for_each_entry(peer, &wg->peer_list, peer_list)  in wg_vm_notification()
105 			wg_noise_expire_current_peer_keypairs(peer);  in wg_vm_notification()
117 	struct wg_peer *peer;  in wg_stop()  local
121 	list_for_each_entry(peer, &wg->peer_list, peer_list) {  in wg_stop()
122 		wg_packet_purge_staged_packets(peer);  in wg_stop()
123 		wg_timers_stop(peer);  in wg_stop()
124 		wg_noise_handshake_clear(&peer->handshake);  in wg_stop()
125 		wg_noise_keypairs_clear(&peer->keypairs);  in wg_stop()
126 		wg_noise_reset_last_sent_handshake(&peer->last_sent_handshake);  in wg_stop()
140 	struct wg_peer *peer;  in wg_xmit()  local
152 	peer = wg_allowedips_lookup_dst(&wg->peer_allowedips, skb);  in wg_xmit()
153 	if (unlikely(!peer)) {  in wg_xmit()
156 			net_dbg_ratelimited("%s: No peer has allowed IPs matching %pI4\n",  in wg_xmit()
159 			net_dbg_ratelimited("%s: No peer has allowed IPs matching %pI6\n",  in wg_xmit()
164 	family = READ_ONCE(peer->endpoint.addr.sa_family);  in wg_xmit()
167 		net_dbg_ratelimited("%s: No valid endpoint has been configured or discovered for peer %llu\n",  in wg_xmit()
168 				    dev->name, peer->internal_id);  in wg_xmit()
205 	spin_lock_bh(&peer->staged_packet_queue.lock);  in wg_xmit()
210 	while (skb_queue_len(&peer->staged_packet_queue) > MAX_STAGED_PACKETS) {  in wg_xmit()
211 		dev_kfree_skb(__skb_dequeue(&peer->staged_packet_queue));  in wg_xmit()
214 	skb_queue_splice_tail(&packets, &peer->staged_packet_queue);  in wg_xmit()
215 	spin_unlock_bh(&peer->staged_packet_queue.lock);  in wg_xmit()
217 	wg_packet_send_staged_packets(peer);  in wg_xmit()
219 	wg_peer_put(peer);  in wg_xmit()
223 	wg_peer_put(peer);  in wg_xmit()
418 	struct wg_peer *peer;  in wg_netns_pre_exit()  local
428 			list_for_each_entry(peer, &wg->peer_list, peer_list)  in wg_netns_pre_exit()
429 				wg_socket_clear_peer_endpoint_src(peer);  in wg_netns_pre_exit()