54 static int prepare_skb_header(struct sk_buff *skb, struct wg_device *wg)  in prepare_skb_header()  argument
99 static void wg_receive_handshake_packet(struct wg_device *wg,  in wg_receive_handshake_packet()  argument
113 					wg->dev->name, skb);  in wg_receive_handshake_packet()
115 			(struct message_handshake_cookie *)skb->data, wg);  in wg_receive_handshake_packet()
119 	under_load = skb_queue_len(&wg->incoming_handshakes) >=  in wg_receive_handshake_packet()
128 	mac_state = wg_cookie_validate_packet(&wg->cookie_checker, skb,  in wg_receive_handshake_packet()
137 					wg->dev->name, skb);  in wg_receive_handshake_packet()
147 			wg_packet_send_handshake_cookie(wg, skb,  in wg_receive_handshake_packet()
151 		peer = wg_noise_handshake_consume_initiation(message, wg);  in wg_receive_handshake_packet()
154 						wg->dev->name, skb);  in wg_receive_handshake_packet()
159 				    wg->dev->name, peer->internal_id,  in wg_receive_handshake_packet()
169 			wg_packet_send_handshake_cookie(wg, skb,  in wg_receive_handshake_packet()
173 		peer = wg_noise_handshake_consume_response(message, wg);  in wg_receive_handshake_packet()
176 						wg->dev->name, skb);  in wg_receive_handshake_packet()
181 				    wg->dev->name, peer->internal_id,  in wg_receive_handshake_packet()
215 	struct wg_device *wg = container_of(work, struct multicore_worker,  in wg_packet_handshake_receive_worker()  local
219 	while ((skb = skb_dequeue(&wg->incoming_handshakes)) != NULL) {  in wg_packet_handshake_receive_worker()
220 		wg_receive_handshake_packet(wg, skb);  in wg_packet_handshake_receive_worker()
517 static void wg_packet_consume_data(struct wg_device *wg, struct sk_buff *skb)  in wg_packet_consume_data()  argument
526 			wg->index_hashtable, INDEX_HASHTABLE_KEYPAIR, idx,  in wg_packet_consume_data()
534 	ret = wg_queue_enqueue_per_device_and_peer(&wg->decrypt_queue,  in wg_packet_consume_data()
536 						   wg->packet_crypt_wq,  in wg_packet_consume_data()
537 						   &wg->decrypt_queue.last_cpu);  in wg_packet_consume_data()
552 void wg_packet_receive(struct wg_device *wg, struct sk_buff *skb)  in wg_packet_receive()  argument
554 	if (unlikely(prepare_skb_header(skb, wg) < 0))  in wg_packet_receive()
562 		if (skb_queue_len(&wg->incoming_handshakes) >  in wg_packet_receive()
566 						wg->dev->name, skb);  in wg_packet_receive()
569 		skb_queue_tail(&wg->incoming_handshakes, skb);  in wg_packet_receive()
573 		cpu = wg_cpumask_next_online(&wg->incoming_handshake_cpu);  in wg_packet_receive()
574 		queue_work_on(cpu, wg->handshake_receive_wq,  in wg_packet_receive()
575 			&per_cpu_ptr(wg->incoming_handshakes_worker, cpu)->work);  in wg_packet_receive()
580 		wg_packet_consume_data(wg, skb);  in wg_packet_receive()