@@ -1,5 +1,4 @@
//go:build boringcrypto
-// +build boringcrypto
package nebula
//go:build e2e_testing
-// +build e2e_testing
@@ -824,10 +824,8 @@ func (fr *FirewallRule) isAny(groups []string, host string, cidr string) bool {
return true
}
- for _, group := range groups {
- if group == "any" {
- return true
- }
+ if slices.Contains(groups, "any") {
+ return true
if host == "any" {
@@ -590,7 +590,7 @@ func (hm *HandshakeManager) allocateIndex(hh *HandshakeHostInfo) error {
hm.Lock()
defer hm.Unlock()
- for i := 0; i < 32; i++ {
+ for range 32 {
index, err := generateIndex(hm.l)
if err != nil {
return err
//go:build darwin || dragonfly || freebsd || netbsd || openbsd
-// +build darwin dragonfly freebsd netbsd openbsd
//go:build !darwin && !dragonfly && !freebsd && !netbsd && !openbsd
-// +build !darwin,!dragonfly,!freebsd,!netbsd,!openbsd
@@ -713,21 +713,14 @@ func (lh *LightHouse) unlockedShouldAddV6(vpnAddr netip.Addr, to *V6AddrPort) bo
func (lh *LightHouse) IsLighthouseAddr(vpnAddr netip.Addr) bool {
l := lh.GetLighthouses()
- for i := range l {
- if l[i] == vpnAddr {
- return false
+ return slices.Contains(l, vpnAddr)
func (lh *LightHouse) IsAnyLighthouseAddr(vpnAddrs []netip.Addr) bool {
for i := range vpnAddrs {
- for j := range l {
- if l[j] == vpnAddrs[i] {
+ if slices.Contains(l, vpnAddrs[i]) {
return false
@@ -105,11 +105,7 @@ func Main(c *config.C, configTest bool, buildVersion string, logger *logrus.Logg
// deprecated and undocumented
tunQueues := c.GetInt("tun.routines", 1)
udpQueues := c.GetInt("listen.routines", 1)
- if tunQueues > udpQueues {
- routines = tunQueues
- } else {
- routines = udpQueues
+ routines = max(tunQueues, udpQueues)
if routines != 1 {
l.WithField("routines", routines).Warn("Setting tun.routines and listen.routines is deprecated. Use `routines` instead")
//go:build !boringcrypto
-// +build !boringcrypto
@@ -574,7 +574,7 @@ func BenchmarkParseV6(b *testing.B) {
evilBytes := buffer.Bytes()
- for i := 0; i < 200; i++ {
+ for range 200 {
evilBytes = append(evilBytes, hopHeader...)
evilBytes = append(evilBytes, lastHopHeader...)
@@ -55,7 +55,7 @@ func (rm *relayManager) setAmRelay(v bool) {
func AddRelay(l *logrus.Logger, relayHostInfo *HostInfo, hm *HostMap, vpnIp netip.Addr, remoteIdx *uint32, relayType int, state int) (uint32, error) {
index, err := generateIndex(l)
return 0, err
@@ -404,12 +404,7 @@ func (r *RemoteList) Rebuild(preferredRanges []netip.Prefix) {
// unlockedIsBad assumes you have the write lock and checks if the remote matches any entry in the blocked address list
func (r *RemoteList) unlockedIsBad(remote netip.AddrPort) bool {
- for _, v := range r.badRemotes {
- if v == remote {
+ return slices.Contains(r.badRemotes, remote)
// unlockedSetLearnedV4 assumes you have the write lock and sets the current learned address for this owner and marks the
@@ -6,6 +6,7 @@ import (
"errors"
"flag"
"fmt"
+ "maps"
"net"
"net/netip"
"os"
@@ -831,9 +832,7 @@ func sshPrintRelays(ifce *Interface, fs any, a []string, w sshd.StringWriter) er
relays := map[uint32]*HostInfo{}
ifce.hostMap.Lock()
- for k, v := range ifce.hostMap.Relays {
- relays[k] = v
+ maps.Copy(relays, ifce.hostMap.Relays)
ifce.hostMap.Unlock()
type RelayFor struct {
@@ -134,7 +134,7 @@ func TestTimerWheel_Purge(t *testing.T) {
assert.True(t, tw.lastTick.After(lastTick))
// Make sure we get all 4 packets back
- for i := 0; i < 4; i++ {
+ for i := range 4 {
p, has := tw.Purge()
assert.True(t, has)
assert.Equal(t, fps[i], p)
@@ -149,7 +149,7 @@ func TestTimerWheel_Purge(t *testing.T) {
// Make sure we cached the free'd items
assert.Equal(t, 4, tw.itemsCached)
ci := tw.itemCache
+ for range 4 {
assert.NotNil(t, ci)
ci = ci.Next