aboutsummaryrefslogtreecommitdiffstatshomepage
diff options
context:
space:
mode:
authorJason A. Donenfeld <Jason@zx2c4.com>2021-05-19 17:55:51 +0200
committerJason A. Donenfeld <Jason@zx2c4.com>2021-06-02 18:31:09 +0200
commit6fbc0e62842cefac784a817cd70e90d5e29fe816 (patch)
treede8e7777bd2216b1c93110180389eee876958ee2
parentkbuild: do not use -O3 (diff)
downloadwireguard-linux-compat-6fbc0e62842cefac784a817cd70e90d5e29fe816.tar.xz
wireguard-linux-compat-6fbc0e62842cefac784a817cd70e90d5e29fe816.zip
global: use synchronize_net rather than synchronize_rcu
Many of the synchronization points are sometimes called under the rtnl lock, which means we should use synchronize_net rather than synchronize_rcu. Under the hood, this expands to using the expedited flavor of function in the event that rtnl is held, in order to not stall other concurrent changes. This fixes some very, very long delays when removing multiple peers at once, which would cause some operations to take several minutes. Signed-off-by: Jason A. Donenfeld <Jason@zx2c4.com>
-rw-r--r--src/peer.c6
-rw-r--r--src/socket.c2
2 files changed, 4 insertions, 4 deletions
diff --git a/src/peer.c b/src/peer.c
index cd5cb02..3a042d2 100644
--- a/src/peer.c
+++ b/src/peer.c
@@ -88,7 +88,7 @@ static void peer_make_dead(struct wg_peer *peer)
/* Mark as dead, so that we don't allow jumping contexts after. */
WRITE_ONCE(peer->is_dead, true);
- /* The caller must now synchronize_rcu() for this to take effect. */
+ /* The caller must now synchronize_net() for this to take effect. */
}
static void peer_remove_after_dead(struct wg_peer *peer)
@@ -160,7 +160,7 @@ void wg_peer_remove(struct wg_peer *peer)
lockdep_assert_held(&peer->device->device_update_lock);
peer_make_dead(peer);
- synchronize_rcu();
+ synchronize_net();
peer_remove_after_dead(peer);
}
@@ -178,7 +178,7 @@ void wg_peer_remove_all(struct wg_device *wg)
peer_make_dead(peer);
list_add_tail(&peer->peer_list, &dead_peers);
}
- synchronize_rcu();
+ synchronize_net();
list_for_each_entry_safe(peer, temp, &dead_peers, peer_list)
peer_remove_after_dead(peer);
}
diff --git a/src/socket.c b/src/socket.c
index e8eceeb..0473976 100644
--- a/src/socket.c
+++ b/src/socket.c
@@ -430,7 +430,7 @@ void wg_socket_reinit(struct wg_device *wg, struct sock *new4,
if (new4)
wg->incoming_port = ntohs(inet_sk(new4)->inet_sport);
mutex_unlock(&wg->socket_update_lock);
- synchronize_rcu();
+ synchronize_net();
sock_free(old4);
sock_free(old6);
}