blob: c736ef8ee07de09ad8df8f56d424526ecff766dc (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
--- sys/dev/wg/if_wg.c.orig
+++ sys/dev/wg/if_wg.c
@@ -1515,8 +1515,7 @@
state = WG_PACKET_CRYPTED;
out:
pkt->p_mbuf = m;
- wmb();
- pkt->p_state = state;
+ atomic_store_rel_int(&pkt->p_state, state);
GROUPTASK_ENQUEUE(&peer->p_send);
noise_remote_put(remote);
}
@@ -1588,8 +1587,7 @@
state = WG_PACKET_CRYPTED;
out:
pkt->p_mbuf = m;
- wmb();
- pkt->p_state = state;
+ atomic_store_rel_int(&pkt->p_state, state);
GROUPTASK_ENQUEUE(&peer->p_recv);
noise_remote_put(remote);
}
@@ -1645,7 +1643,7 @@
wg_peer_get_endpoint(peer, &endpoint);
while ((pkt = wg_queue_dequeue_serial(&peer->p_encrypt_serial)) != NULL) {
- if (pkt->p_state != WG_PACKET_CRYPTED)
+ if (atomic_load_acq_int(&pkt->p_state) != WG_PACKET_CRYPTED)
goto error;
m = pkt->p_mbuf;
@@ -1687,7 +1685,7 @@
struct epoch_tracker et;
while ((pkt = wg_queue_dequeue_serial(&peer->p_decrypt_serial)) != NULL) {
- if (pkt->p_state != WG_PACKET_CRYPTED)
+ if (atomic_load_acq_int(&pkt->p_state) != WG_PACKET_CRYPTED)
goto error;
m = pkt->p_mbuf;
|
