hostmap.go 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936
  1. package nebula
  2. import (
  3. "context"
  4. "encoding/json"
  5. "errors"
  6. "fmt"
  7. "log/slog"
  8. "net/netip"
  9. "slices"
  10. "sync"
  11. "sync/atomic"
  12. "time"
  13. "github.com/gaissmai/bart"
  14. "github.com/rcrowley/go-metrics"
  15. "github.com/slackhq/nebula/cert"
  16. "github.com/slackhq/nebula/config"
  17. "github.com/slackhq/nebula/header"
  18. )
  19. const defaultPromoteEvery = 1000 // Count of packets sent before we try moving a tunnel to a preferred underlay ip address
  20. const defaultReQueryEvery = 5000 // Count of packets sent before re-querying a hostinfo to the lighthouse
  21. const defaultReQueryWait = time.Minute // Minimum amount of seconds to wait before re-querying a hostinfo the lighthouse. Evaluated every ReQueryEvery
  22. const MaxRemotes = 10
  23. // MaxHostInfosPerVpnIp is the max number of hostinfos we will track for a given vpn ip
  24. // 5 allows for an initial handshake and each host pair re-handshaking twice
  25. const MaxHostInfosPerVpnIp = 5
  26. // How long we should prevent roaming back to the previous IP.
  27. // This helps prevent flapping due to packets already in flight
  28. const RoamingSuppressSeconds = 2
  29. const (
  30. Requested = iota
  31. PeerRequested
  32. Established
  33. Disestablished
  34. )
  35. const (
  36. Unknowntype = iota
  37. ForwardingType
  38. TerminalType
  39. )
  40. type Relay struct {
  41. Type int
  42. State int
  43. LocalIndex uint32
  44. RemoteIndex uint32
  45. PeerAddr netip.Addr
  46. }
  47. type HostMap struct {
  48. sync.RWMutex //Because we concurrently read and write to our maps
  49. Indexes map[uint32]*HostInfo
  50. Relays map[uint32]*HostInfo // Maps a Relay IDX to a Relay HostInfo object
  51. RemoteIndexes map[uint32]*HostInfo
  52. // Hosts maps a vpn address to its primary hostinfo, one entry per address we hold a tunnel
  53. // for. moreHosts only has an entry while an address is held by 2 or more hostinfos and stores
  54. // the full most-recent-first list; moreHosts[a][0] is always the same hostinfo as Hosts[a].
  55. // Each address gets its own independent list, so a hostinfo owning multiple addresses can
  56. // never corrupt another address's ordering the way the old shared next/prev chain could.
  57. // Entries in moreHosts are only ever written by unlockedSetHostsForAddr; Hosts is written
  58. // directly only in the single-hostinfo fast paths where moreHosts is known to have no entry,
  59. // and unlockedDeleteHostInfo swaps either map for a fresh one when it fully drains.
  60. Hosts map[netip.Addr]*HostInfo
  61. moreHosts map[netip.Addr][]*HostInfo
  62. preferredRanges atomic.Pointer[[]netip.Prefix]
  63. l *slog.Logger
  64. }
  65. // For synchronization, treat the pointed-to Relay struct as immutable. To edit the Relay
  66. // struct, make a copy of an existing value, edit the fileds in the copy, and
  67. // then store a pointer to the new copy in both realyForBy* maps.
  68. type RelayState struct {
  69. sync.RWMutex
  70. relays []netip.Addr // Ordered set of VpnAddrs of Hosts to use as relays to access this peer
  71. // For data race avoidance, the contents of a *Relay are treated immutably. To update a *Relay, copy the existing data,
  72. // modify what needs to be updated, and store the new modified copy in the relayForByIp and relayForByIdx maps (with
  73. // the RelayState Lock held)
  74. relayForByAddr map[netip.Addr]*Relay // Maps vpnAddr of peers for which this HostInfo is a relay to some Relay info
  75. relayForByIdx map[uint32]*Relay // Maps a local index to some Relay info
  76. }
  77. func (rs *RelayState) DeleteRelay(ip netip.Addr) {
  78. rs.Lock()
  79. defer rs.Unlock()
  80. for idx, val := range rs.relays {
  81. if val == ip {
  82. rs.relays = append(rs.relays[:idx], rs.relays[idx+1:]...)
  83. return
  84. }
  85. }
  86. }
  87. func (rs *RelayState) UpdateRelayForByIpState(vpnIp netip.Addr, state int) {
  88. rs.Lock()
  89. defer rs.Unlock()
  90. if r, ok := rs.relayForByAddr[vpnIp]; ok {
  91. newRelay := *r
  92. newRelay.State = state
  93. rs.relayForByAddr[newRelay.PeerAddr] = &newRelay
  94. rs.relayForByIdx[newRelay.LocalIndex] = &newRelay
  95. }
  96. }
  97. func (rs *RelayState) UpdateRelayForByIdxState(idx uint32, state int) {
  98. rs.Lock()
  99. defer rs.Unlock()
  100. if r, ok := rs.relayForByIdx[idx]; ok {
  101. newRelay := *r
  102. newRelay.State = state
  103. rs.relayForByAddr[newRelay.PeerAddr] = &newRelay
  104. rs.relayForByIdx[newRelay.LocalIndex] = &newRelay
  105. }
  106. }
  107. func (rs *RelayState) CopyAllRelayFor() []*Relay {
  108. rs.RLock()
  109. defer rs.RUnlock()
  110. ret := make([]*Relay, 0, len(rs.relayForByIdx))
  111. for _, r := range rs.relayForByIdx {
  112. ret = append(ret, r)
  113. }
  114. return ret
  115. }
  116. func (rs *RelayState) GetRelayForByAddr(addr netip.Addr) (*Relay, bool) {
  117. rs.RLock()
  118. defer rs.RUnlock()
  119. r, ok := rs.relayForByAddr[addr]
  120. return r, ok
  121. }
  122. func (rs *RelayState) InsertRelayTo(ip netip.Addr) {
  123. rs.Lock()
  124. defer rs.Unlock()
  125. if !slices.Contains(rs.relays, ip) {
  126. rs.relays = append(rs.relays, ip)
  127. }
  128. }
  129. func (rs *RelayState) CopyRelayIps() []netip.Addr {
  130. rs.RLock()
  131. defer rs.RUnlock()
  132. ret := make([]netip.Addr, len(rs.relays))
  133. copy(ret, rs.relays)
  134. return ret
  135. }
  136. func (rs *RelayState) CopyRelayForIps() []netip.Addr {
  137. rs.RLock()
  138. defer rs.RUnlock()
  139. currentRelays := make([]netip.Addr, 0, len(rs.relayForByAddr))
  140. for relayIp := range rs.relayForByAddr {
  141. currentRelays = append(currentRelays, relayIp)
  142. }
  143. return currentRelays
  144. }
  145. func (rs *RelayState) CopyRelayForIdxs() []uint32 {
  146. rs.RLock()
  147. defer rs.RUnlock()
  148. ret := make([]uint32, 0, len(rs.relayForByIdx))
  149. for i := range rs.relayForByIdx {
  150. ret = append(ret, i)
  151. }
  152. return ret
  153. }
  154. func (rs *RelayState) CompleteRelayByIP(vpnIp netip.Addr, remoteIdx uint32) bool {
  155. rs.Lock()
  156. defer rs.Unlock()
  157. r, ok := rs.relayForByAddr[vpnIp]
  158. if !ok {
  159. return false
  160. }
  161. newRelay := *r
  162. newRelay.State = Established
  163. newRelay.RemoteIndex = remoteIdx
  164. rs.relayForByIdx[r.LocalIndex] = &newRelay
  165. rs.relayForByAddr[r.PeerAddr] = &newRelay
  166. return true
  167. }
  168. func (rs *RelayState) CompleteRelayByIdx(localIdx uint32, remoteIdx uint32) (*Relay, bool) {
  169. rs.Lock()
  170. defer rs.Unlock()
  171. r, ok := rs.relayForByIdx[localIdx]
  172. if !ok {
  173. return nil, false
  174. }
  175. newRelay := *r
  176. newRelay.State = Established
  177. newRelay.RemoteIndex = remoteIdx
  178. rs.relayForByIdx[r.LocalIndex] = &newRelay
  179. rs.relayForByAddr[r.PeerAddr] = &newRelay
  180. return &newRelay, true
  181. }
  182. func (rs *RelayState) QueryRelayForByIp(vpnIp netip.Addr) (*Relay, bool) {
  183. rs.RLock()
  184. defer rs.RUnlock()
  185. r, ok := rs.relayForByAddr[vpnIp]
  186. return r, ok
  187. }
  188. func (rs *RelayState) QueryRelayForByIdx(idx uint32) (*Relay, bool) {
  189. rs.RLock()
  190. defer rs.RUnlock()
  191. r, ok := rs.relayForByIdx[idx]
  192. return r, ok
  193. }
  194. func (rs *RelayState) InsertRelay(ip netip.Addr, idx uint32, r *Relay) {
  195. rs.Lock()
  196. defer rs.Unlock()
  197. rs.relayForByAddr[ip] = r
  198. rs.relayForByIdx[idx] = r
  199. }
  200. type NetworkType uint8
  201. const (
  202. NetworkTypeUnknown NetworkType = iota
  203. // NetworkTypeVPN is a network that overlaps one or more of the vpnNetworks in our certificate
  204. NetworkTypeVPN
  205. // NetworkTypeVPNPeer is a network that does not overlap one of our networks
  206. NetworkTypeVPNPeer
  207. // NetworkTypeUnsafe is a network from Certificate.UnsafeNetworks()
  208. NetworkTypeUnsafe
  209. )
  210. type HostInfo struct {
  211. remote atomic.Pointer[netip.AddrPort]
  212. ConnectionState *ConnectionState
  213. // Traffic bits, pendingDeletion, and the rebind epoch we last sent under
  214. state atomic.Uint32
  215. promoteCounter atomic.Uint32
  216. remoteIndexId uint32
  217. localIndexId uint32
  218. remotes *RemoteList
  219. // vpnAddrs is a list of vpn addresses assigned to this host that are within our own vpn networks
  220. // The host may have other vpn addresses that are outside our
  221. // vpn networks but were removed because they are not usable
  222. vpnAddrs []netip.Addr
  223. // networks is a combination of specific vpn addresses (not prefixes!) and full unsafe networks assigned to this host.
  224. networks *bart.Table[NetworkType]
  225. relayState RelayState
  226. // HandshakePacket records the packets used to create this hostinfo
  227. // We need these to avoid replayed handshake packets creating new hostinfos which causes churn
  228. HandshakePacket map[uint8][]byte
  229. // A responder resending a fragmented handshake response offers symbols it has
  230. // not sent before. Once complete, a hybrid responder confirms again for a
  231. // resent msg3 at most once per retry interval.
  232. handshakeResendAt atomic.Int64 // unix nanos of the last confirmation
  233. handshakeNextSymbol atomic.Uint32 // next fragment symbol index to offer
  234. // nextLHQuery is the earliest we can ask the lighthouse for new information.
  235. // This is used to limit lighthouse re-queries in chatty clients
  236. nextLHQuery atomic.Int64
  237. // lastHandshakeTime records the time the remote side told us about at the stage when the handshake was completed locally
  238. // Stage 1 packet will contain it if I am a responder, stage 2 packet if I am an initiator
  239. // This is used to avoid an attack where a handshake packet is replayed after some time
  240. lastHandshakeTime uint64
  241. lastRoam time.Time
  242. lastRoamRemote netip.AddrPort
  243. // lastUsed tracks the last time ConnectionManager checked the tunnel and it was in use.
  244. // This value will be behind against actual tunnel utilization in the hot path.
  245. // This should only be used by the ConnectionManagers ticker routine.
  246. lastUsed time.Time
  247. }
  248. type ViaSender struct {
  249. UdpAddr netip.AddrPort
  250. relayHI *HostInfo // relayHI is the host info object of the relay
  251. relay *Relay // relay contains the rest of the relay information, including the PeerIP of the host trying to communicate with us.
  252. IsRelayed bool // IsRelayed is true if the packet was sent through a relay
  253. }
  254. func (v ViaSender) String() string {
  255. if v.IsRelayed {
  256. return fmt.Sprintf("%s (relayed)", v.UdpAddr)
  257. }
  258. return v.UdpAddr.String()
  259. }
  260. func (v ViaSender) MarshalJSON() ([]byte, error) {
  261. if v.IsRelayed {
  262. return json.Marshal(m{"relay": v.UdpAddr})
  263. }
  264. return json.Marshal(m{"direct": v.UdpAddr})
  265. }
  266. type cachedPacket struct {
  267. messageType header.MessageType
  268. messageSubType header.MessageSubType
  269. callback packetCallback
  270. packet []byte
  271. }
  272. type packetCallback func(t header.MessageType, st header.MessageSubType, h *HostInfo, p, nb, out []byte)
  273. type cachedPacketMetrics struct {
  274. sent metrics.Counter
  275. dropped metrics.Counter
  276. }
  277. func NewHostMapFromConfig(l *slog.Logger, c *config.C) *HostMap {
  278. hm := newHostMap(l)
  279. hm.reload(c, true)
  280. c.RegisterReloadCallback(func(c *config.C) {
  281. hm.reload(c, false)
  282. })
  283. l.Info("Main HostMap created", "preferredRanges", hm.GetPreferredRanges())
  284. return hm
  285. }
  286. func newHostMap(l *slog.Logger) *HostMap {
  287. return &HostMap{
  288. Indexes: map[uint32]*HostInfo{},
  289. Relays: map[uint32]*HostInfo{},
  290. RemoteIndexes: map[uint32]*HostInfo{},
  291. Hosts: map[netip.Addr]*HostInfo{},
  292. moreHosts: map[netip.Addr][]*HostInfo{},
  293. l: l,
  294. }
  295. }
  296. func (hm *HostMap) reload(c *config.C, initial bool) {
  297. if initial || c.HasChanged("preferred_ranges") {
  298. var preferredRanges []netip.Prefix
  299. rawPreferredRanges := c.GetStringSlice("preferred_ranges", []string{})
  300. for _, rawPreferredRange := range rawPreferredRanges {
  301. preferredRange, err := netip.ParsePrefix(rawPreferredRange)
  302. if err != nil {
  303. hm.l.Warn("Failed to parse preferred ranges, ignoring",
  304. "error", err,
  305. "range", rawPreferredRanges,
  306. )
  307. continue
  308. }
  309. preferredRanges = append(preferredRanges, preferredRange)
  310. }
  311. oldRanges := hm.preferredRanges.Swap(&preferredRanges)
  312. if !initial {
  313. hm.l.Info("preferred_ranges changed",
  314. "oldPreferredRanges", *oldRanges,
  315. "newPreferredRanges", preferredRanges,
  316. )
  317. }
  318. }
  319. }
  320. // EmitStats reports host, index, and relay counts to the stats collection system
  321. func (hm *HostMap) EmitStats() {
  322. hm.RLock()
  323. hostLen := len(hm.Hosts)
  324. indexLen := len(hm.Indexes)
  325. remoteIndexLen := len(hm.RemoteIndexes)
  326. relaysLen := len(hm.Relays)
  327. hm.RUnlock()
  328. metrics.GetOrRegisterGauge("hostmap.main.hosts", nil).Update(int64(hostLen))
  329. metrics.GetOrRegisterGauge("hostmap.main.indexes", nil).Update(int64(indexLen))
  330. metrics.GetOrRegisterGauge("hostmap.main.remoteIndexes", nil).Update(int64(remoteIndexLen))
  331. metrics.GetOrRegisterGauge("hostmap.main.relayIndexes", nil).Update(int64(relaysLen))
  332. }
  333. // unlockedSetHostsForAddr stores the per-address hostinfo list (list[0] is the primary). An empty
  334. // list removes the address. This is the one place Hosts and moreHosts are written together, keep
  335. // it that way. Callers must hold the write lock.
  336. func (hm *HostMap) unlockedSetHostsForAddr(addr netip.Addr, list []*HostInfo) {
  337. if len(list) == 0 {
  338. delete(hm.Hosts, addr)
  339. delete(hm.moreHosts, addr)
  340. return
  341. }
  342. hm.Hosts[addr] = list[0]
  343. if len(list) > 1 {
  344. hm.moreHosts[addr] = list
  345. } else {
  346. delete(hm.moreHosts, addr)
  347. }
  348. }
  349. // unlockedGetHostList returns every hostinfo holding addr, primary first, or nil if we have no
  350. // tunnel for addr. The common single-hostinfo case builds a fresh one element list, so keep this
  351. // off the packet hot path; the primary is a direct Hosts read. Callers must hold the lock (read
  352. // or write).
  353. func (hm *HostMap) unlockedGetHostList(addr netip.Addr) []*HostInfo {
  354. if list, ok := hm.moreHosts[addr]; ok {
  355. return list
  356. }
  357. if h, ok := hm.Hosts[addr]; ok {
  358. return []*HostInfo{h}
  359. }
  360. return nil
  361. }
  362. // removeHostInfo returns list with hi removed (order preserved), or list unchanged if hi is
  363. // absent. It deletes in place: every mutator holds the hostmap write lock and no reader ever
  364. // retains a slice across a mutation (readers iterate under RLock), so there is no snapshot to
  365. // invalidate.
  366. func removeHostInfo(list []*HostInfo, hi *HostInfo) []*HostInfo {
  367. idx := slices.Index(list, hi)
  368. if idx < 0 {
  369. return list
  370. }
  371. return slices.Delete(list, idx, idx+1)
  372. }
  373. // DeleteHostInfo will fully unlink the hostinfo and return true if no other hostinfo still holds
  374. // any of its vpn addrs, meaning we no longer have a tunnel to the peer
  375. func (hm *HostMap) DeleteHostInfo(hostinfo *HostInfo) bool {
  376. // Delete the host itself, ensuring it's not modified anymore
  377. hm.Lock()
  378. final := hm.unlockedDeleteHostInfo(hostinfo)
  379. hm.Unlock()
  380. return final
  381. }
  382. func (hm *HostMap) MakePrimary(hostinfo *HostInfo) {
  383. hm.Lock()
  384. defer hm.Unlock()
  385. hm.unlockedMakePrimary(hostinfo)
  386. }
  387. // unlockedMakePrimary reports whether hostinfo is (now) the primary for each of its addresses,
  388. // false only when it is no longer in the hostmap at all.
  389. func (hm *HostMap) unlockedMakePrimary(hostinfo *HostInfo) bool {
  390. // A hostinfo that is no longer in the hostmap must not be re-inserted here. Callers can race
  391. // tunnel teardown, deciding to promote under the read lock and only taking the write lock
  392. // after a delete fully unlinked the hostinfo (connection manager swapPrimary, AddRelay). Every
  393. // live hostinfo is registered in Indexes by unlockedAddHostInfo, so this is a membership test.
  394. if hm.Indexes[hostinfo.localIndexId] != hostinfo {
  395. return false
  396. }
  397. // Move hostinfo to the front (primary) of each of its address lists. The lists are
  398. // independent per address, so this can never leave a dangling entry the way promoting
  399. // against a single shared chain could.
  400. for _, addr := range hostinfo.vpnAddrs {
  401. if hm.Hosts[addr] == hostinfo {
  402. // Already primary for this address, the list is already in the right order
  403. continue
  404. }
  405. list := removeHostInfo(hm.unlockedGetHostList(addr), hostinfo)
  406. list = append([]*HostInfo{hostinfo}, list...)
  407. hm.unlockedSetHostsForAddr(addr, list)
  408. }
  409. return true
  410. }
  411. // unlockedDeleteHostInfo removes hostinfo from every one of its address lists and from the index
  412. // maps. It returns true if this was the last hostinfo for all of its addresses (we no longer have
  413. // any tunnel to the peer), which the caller uses to decide whether to clear learned lighthouse
  414. // state and disestablish relays.
  415. func (hm *HostMap) unlockedDeleteHostInfo(hostinfo *HostInfo) bool {
  416. // Remove this hostinfo from each of its address lists. The lists are independent, so a
  417. // sibling is never promoted to an address it does not own and no other list is touched.
  418. final := true
  419. for _, addr := range hostinfo.vpnAddrs {
  420. if list, ok := hm.moreHosts[addr]; ok {
  421. list = removeHostInfo(list, hostinfo)
  422. hm.unlockedSetHostsForAddr(addr, list)
  423. if len(list) > 0 {
  424. final = false
  425. }
  426. } else if existing, ok := hm.Hosts[addr]; ok {
  427. if existing == hostinfo {
  428. // Common case, the only hostinfo for this address. moreHosts has no entry to clean up.
  429. delete(hm.Hosts, addr)
  430. } else {
  431. // We don't hold this address but another hostinfo does, we still have a tunnel to the peer
  432. final = false
  433. }
  434. }
  435. }
  436. // Go maps never shrink their buckets, replace fully drained maps so a node that churned
  437. // through a large peer count gives the memory back. Same idiom as the index maps below.
  438. if len(hm.Hosts) == 0 {
  439. hm.Hosts = map[netip.Addr]*HostInfo{}
  440. }
  441. if len(hm.moreHosts) == 0 {
  442. hm.moreHosts = map[netip.Addr][]*HostInfo{}
  443. }
  444. // The remote index uses index ids outside our control so lets make sure we are only removing
  445. // the remote index pointer here if it points to the hostinfo we are deleting
  446. hostinfo2, ok := hm.RemoteIndexes[hostinfo.remoteIndexId]
  447. if ok && hostinfo2 == hostinfo {
  448. delete(hm.RemoteIndexes, hostinfo.remoteIndexId)
  449. if len(hm.RemoteIndexes) == 0 {
  450. hm.RemoteIndexes = map[uint32]*HostInfo{}
  451. }
  452. }
  453. delete(hm.Indexes, hostinfo.localIndexId)
  454. if len(hm.Indexes) == 0 {
  455. hm.Indexes = map[uint32]*HostInfo{}
  456. }
  457. if hm.l.Enabled(context.Background(), slog.LevelDebug) {
  458. hm.l.Debug("Hostmap hostInfo deleted",
  459. "hostMap", m{"mapTotalSize": len(hm.Hosts),
  460. "vpnAddrs": hostinfo.vpnAddrs, "indexNumber": hostinfo.localIndexId, "remoteIndexNumber": hostinfo.remoteIndexId},
  461. )
  462. }
  463. if final {
  464. // I have lost connectivity to my peers. My relay tunnel is likely broken. Mark the next
  465. // hops as 'Requested' so that new relay tunnels are created in the future.
  466. hm.unlockedDisestablishVpnAddrRelayFor(hostinfo)
  467. }
  468. // Clean up any local relay indexes for which I am acting as a relay hop
  469. for _, localRelayIdx := range hostinfo.relayState.CopyRelayForIdxs() {
  470. delete(hm.Relays, localRelayIdx)
  471. }
  472. return final
  473. }
  474. func (hm *HostMap) QueryIndexCached(index uint32, cache map[uint32]*HostInfo) *HostInfo {
  475. if out, ok := cache[index]; ok {
  476. return out
  477. }
  478. out := hm.QueryIndex(index)
  479. if out != nil {
  480. cache[index] = out
  481. }
  482. return out
  483. }
  484. func (hm *HostMap) QueryIndex(index uint32) *HostInfo {
  485. hm.RLock()
  486. if h, ok := hm.Indexes[index]; ok {
  487. hm.RUnlock()
  488. return h
  489. } else {
  490. hm.RUnlock()
  491. return nil
  492. }
  493. }
  494. func (hm *HostMap) QueryRelayIndex(index uint32) *HostInfo {
  495. hm.RLock()
  496. if h, ok := hm.Relays[index]; ok {
  497. hm.RUnlock()
  498. return h
  499. } else {
  500. hm.RUnlock()
  501. return nil
  502. }
  503. }
  504. func (hm *HostMap) QueryReverseIndex(index uint32) *HostInfo {
  505. hm.RLock()
  506. if h, ok := hm.RemoteIndexes[index]; ok {
  507. hm.RUnlock()
  508. return h
  509. } else {
  510. hm.RUnlock()
  511. return nil
  512. }
  513. }
  514. func (hm *HostMap) QueryVpnAddr(vpnIp netip.Addr) *HostInfo {
  515. return hm.queryVpnAddr(vpnIp, nil)
  516. }
  517. func (hm *HostMap) QueryVpnAddrsRelayFor(targetIps []netip.Addr, relayHostIp netip.Addr) (*HostInfo, *Relay, error) {
  518. hm.RLock()
  519. defer hm.RUnlock()
  520. // This runs per relayed packet, so check the primary with a single map probe and only consult
  521. // moreHosts when the primary can't relay for us.
  522. h, ok := hm.Hosts[relayHostIp]
  523. if !ok {
  524. return nil, nil, errors.New("unable to find host")
  525. }
  526. for _, targetIp := range targetIps {
  527. r, ok := h.relayState.QueryRelayForByIp(targetIp)
  528. if ok && r.State == Established {
  529. return h, r, nil
  530. }
  531. }
  532. if list, ok := hm.moreHosts[relayHostIp]; ok {
  533. // list[0] is the primary we already checked
  534. for _, h := range list[1:] {
  535. for _, targetIp := range targetIps {
  536. r, ok := h.relayState.QueryRelayForByIp(targetIp)
  537. if ok && r.State == Established {
  538. return h, r, nil
  539. }
  540. }
  541. }
  542. }
  543. return nil, nil, errors.New("unable to find host with relay")
  544. }
  545. func (hm *HostMap) unlockedDisestablishVpnAddrRelayFor(hi *HostInfo) {
  546. for _, relayHostIp := range hi.relayState.CopyRelayIps() {
  547. for _, h := range hm.unlockedGetHostList(relayHostIp) {
  548. h.relayState.UpdateRelayForByIpState(hi.vpnAddrs[0], Disestablished)
  549. }
  550. }
  551. for _, rs := range hi.relayState.CopyAllRelayFor() {
  552. if rs.Type == ForwardingType {
  553. for _, h := range hm.unlockedGetHostList(rs.PeerAddr) {
  554. h.relayState.UpdateRelayForByIpState(hi.vpnAddrs[0], Disestablished)
  555. }
  556. }
  557. }
  558. }
  559. func (hm *HostMap) queryVpnAddr(vpnIp netip.Addr, promoteIfce *Interface) *HostInfo {
  560. hm.RLock()
  561. if h, ok := hm.Hosts[vpnIp]; ok {
  562. hm.RUnlock()
  563. // Do not attempt promotion if you are a lighthouse
  564. if promoteIfce != nil && !promoteIfce.lightHouse.amLighthouse {
  565. h.TryPromoteBest(hm.GetPreferredRanges(), promoteIfce)
  566. }
  567. return h
  568. }
  569. hm.RUnlock()
  570. return nil
  571. }
  572. // unlockedAddHostInfo assumes you have a write-lock and will add a hostinfo object to the hostmap Indexes and RemoteIndexes maps.
  573. // If an entry exists for the Hosts table (vpnIp -> hostinfo) then the provided hostinfo will be made primary
  574. func (hm *HostMap) unlockedAddHostInfo(hostinfo *HostInfo, f *Interface) {
  575. if f.dnsServer != nil {
  576. remoteCert := hostinfo.ConnectionState.peerCert
  577. f.dnsServer.Add(remoteCert.Certificate.Name()+".", hostinfo.vpnAddrs)
  578. }
  579. for _, addr := range hostinfo.vpnAddrs {
  580. hm.unlockedInnerAddHostInfo(addr, hostinfo, f)
  581. }
  582. hm.Indexes[hostinfo.localIndexId] = hostinfo
  583. hm.RemoteIndexes[hostinfo.remoteIndexId] = hostinfo
  584. hostinfo.markOut(f.rebindEpoch.Load())
  585. if f.connectionManager != nil { // f.connectionManager is only nil in some unit tests
  586. f.connectionManager.trafficTimer.Add(hostinfo.localIndexId, f.connectionManager.checkInterval)
  587. }
  588. if hm.l.Enabled(context.Background(), slog.LevelDebug) {
  589. hm.l.Debug("Hostmap vpnIp added",
  590. "hostMap", m{"vpnAddrs": hostinfo.vpnAddrs, "mapTotalSize": len(hm.Hosts),
  591. "hostinfo": m{"existing": true, "localIndexId": hostinfo.localIndexId, "vpnAddrs": hostinfo.vpnAddrs}},
  592. )
  593. }
  594. }
  595. func (hm *HostMap) unlockedInnerAddHostInfo(vpnAddr netip.Addr, hostinfo *HostInfo, f *Interface) {
  596. existing, ok := hm.Hosts[vpnAddr]
  597. if !ok {
  598. // Common case, the first hostinfo for this address. moreHosts stays empty.
  599. hm.Hosts[vpnAddr] = hostinfo
  600. return
  601. }
  602. // The new hostinfo becomes the primary for this address. Remove any stale copy of it first so
  603. // we never hold a duplicate, then prepend.
  604. list, ok := hm.moreHosts[vpnAddr]
  605. if !ok {
  606. list = []*HostInfo{existing}
  607. }
  608. list = removeHostInfo(list, hostinfo)
  609. list = append([]*HostInfo{hostinfo}, list...)
  610. hm.unlockedSetHostsForAddr(vpnAddr, list)
  611. // Enforce the per-address cap by fully retiring the oldest hostinfo once we exceed it.
  612. // Deleting it removes it from all of its addresses and the index maps, matching prior behavior.
  613. if len(list) > MaxHostInfosPerVpnIp {
  614. hm.unlockedDeleteHostInfo(list[len(list)-1])
  615. }
  616. }
  617. func (hm *HostMap) GetPreferredRanges() []netip.Prefix {
  618. //NOTE: if preferredRanges is ever not stored before a load this will fail to dereference a nil pointer
  619. return *hm.preferredRanges.Load()
  620. }
  621. func (hm *HostMap) ForEachVpnAddr(f controlEach) {
  622. hm.RLock()
  623. defer hm.RUnlock()
  624. for _, v := range hm.Hosts {
  625. f(v)
  626. }
  627. }
  628. func (hm *HostMap) ForEachIndex(f controlEach) {
  629. hm.RLock()
  630. defer hm.RUnlock()
  631. for _, v := range hm.Indexes {
  632. f(v)
  633. }
  634. }
  635. // TryPromoteBest handles re-querying lighthouses and probing for better paths
  636. // NOTE: It is an error to call this if you are a lighthouse since they should not roam clients!
  637. func (i *HostInfo) TryPromoteBest(preferredRanges []netip.Prefix, ifce *Interface) {
  638. c := i.promoteCounter.Add(1)
  639. if c%ifce.tryPromoteEvery.Load() == 0 {
  640. remote := i.GetRemote()
  641. // return early if we are already on a preferred remote
  642. if remote.IsValid() {
  643. rIP := remote.Addr()
  644. for _, l := range preferredRanges {
  645. if l.Contains(rIP) {
  646. return
  647. }
  648. }
  649. }
  650. i.remotes.ForEach(preferredRanges, func(addr netip.AddrPort, preferred bool) {
  651. if remote.IsValid() && (!addr.IsValid() || !preferred) {
  652. return
  653. }
  654. // Try to send a test packet to that host, this should
  655. // cause it to detect a roaming event and switch remotes
  656. ifce.sendTo(header.Test, header.TestRequest, i.ConnectionState, i, addr, []byte(""), make([]byte, 12, 12), make([]byte, mtu))
  657. })
  658. }
  659. // Re query our lighthouses for new remotes occasionally
  660. if c%ifce.reQueryEvery.Load() == 0 && ifce.lightHouse != nil {
  661. now := time.Now().UnixNano()
  662. if now < i.nextLHQuery.Load() {
  663. return
  664. }
  665. i.nextLHQuery.Store(now + ifce.reQueryWait.Load())
  666. ifce.lightHouse.QueryServer(i.vpnAddrs[0])
  667. }
  668. }
  669. // Bits within HostInfo.state, everything above stateEpochShift is the epoch
  670. const (
  671. stateIn uint32 = 1 << iota
  672. stateOut
  673. statePendingDeletion
  674. stateFlags = stateIn | stateOut | statePendingDeletion
  675. // The epoch is the top 29 bits, it would take 2^29 rebinds to wrap and we will never get there
  676. stateEpochShift = 3
  677. )
  678. // markIn records inbound traffic
  679. func (i *HostInfo) markIn() {
  680. if i.state.Load()&stateIn == 0 {
  681. i.state.Or(stateIn)
  682. }
  683. }
  684. // markOut records a send and reports whether the epoch moved, meaning we want a punch from the far side
  685. func (i *HostInfo) markOut(epoch uint32) bool {
  686. e := epoch << stateEpochShift
  687. for {
  688. old := i.state.Load()
  689. if old&stateOut != 0 && old&^stateFlags == e {
  690. return false
  691. }
  692. if i.state.CompareAndSwap(old, old&stateFlags|stateOut|e) {
  693. return old&^stateFlags != e
  694. }
  695. }
  696. }
  697. // markOutOnly records a send without consuming the rebind epoch, for paths that cannot act on a requery
  698. func (i *HostInfo) markOutOnly() {
  699. if i.state.Load()&stateOut == 0 {
  700. i.state.Or(stateOut)
  701. }
  702. }
  703. // takeTraffic clears both traffic bits, leaving the epoch alone, and reports what they were
  704. func (i *HostInfo) takeTraffic() (in bool, out bool) {
  705. old := i.state.And(^(stateIn | stateOut))
  706. return old&stateIn != 0, old&stateOut != 0
  707. }
  708. func (i *HostInfo) setPendingDeletion(v bool) {
  709. if v {
  710. i.state.Or(statePendingDeletion)
  711. } else {
  712. i.state.And(^statePendingDeletion)
  713. }
  714. }
  715. func (i *HostInfo) isPendingDeletion() bool {
  716. return i.state.Load()&statePendingDeletion != 0
  717. }
  718. func (i *HostInfo) GetCert() *cert.CachedCertificate {
  719. if i.ConnectionState != nil {
  720. return i.ConnectionState.peerCert
  721. }
  722. return nil
  723. }
  724. func (i *HostInfo) GetRemote() netip.AddrPort {
  725. if p := i.remote.Load(); p != nil {
  726. return *p
  727. }
  728. return netip.AddrPort{}
  729. }
  730. // TODO: Maybe use ViaSender here?
  731. func (i *HostInfo) SetRemote(remote netip.AddrPort) {
  732. // We copy here because we likely got this remote from a source that reuses the object
  733. if i.GetRemote() != remote {
  734. i.remote.Store(&remote)
  735. i.remotes.LearnRemote(i.vpnAddrs[0], remote)
  736. }
  737. }
  738. // SetRemoteIfPreferred returns true if the remote was changed. The lastRoam
  739. // time on the HostInfo will also be updated.
  740. func (i *HostInfo) SetRemoteIfPreferred(hm *HostMap, via ViaSender) bool {
  741. if via.IsRelayed {
  742. return false
  743. }
  744. currentRemote := i.GetRemote()
  745. if !currentRemote.IsValid() {
  746. i.SetRemote(via.UdpAddr)
  747. return true
  748. }
  749. // NOTE: We do this loop here instead of calling `isPreferred` in
  750. // remote_list.go so that we only have to loop over preferredRanges once.
  751. newIsPreferred := false
  752. for _, l := range hm.GetPreferredRanges() {
  753. // return early if we are already on a preferred remote
  754. if l.Contains(currentRemote.Addr()) {
  755. return false
  756. }
  757. if l.Contains(via.UdpAddr.Addr()) {
  758. newIsPreferred = true
  759. }
  760. }
  761. if newIsPreferred {
  762. // Consider this a roaming event
  763. i.lastRoam = time.Now()
  764. i.lastRoamRemote = currentRemote
  765. i.SetRemote(via.UdpAddr)
  766. return true
  767. }
  768. return false
  769. }
  770. // buildNetworks fills in the networks field of HostInfo. It accepts a cert.Certificate so you never ever mix the network types up.
  771. func (i *HostInfo) buildNetworks(myVpnNetworksTable *bart.Lite, c cert.Certificate) {
  772. if len(c.Networks()) == 1 && len(c.UnsafeNetworks()) == 0 {
  773. if myVpnNetworksTable.Contains(c.Networks()[0].Addr()) {
  774. return // Simple case, no BART needed
  775. }
  776. }
  777. i.networks = new(bart.Table[NetworkType])
  778. for _, network := range c.Networks() {
  779. nprefix := netip.PrefixFrom(network.Addr(), network.Addr().BitLen())
  780. if myVpnNetworksTable.Contains(network.Addr()) {
  781. i.networks.Insert(nprefix, NetworkTypeVPN)
  782. } else {
  783. i.networks.Insert(nprefix, NetworkTypeVPNPeer)
  784. }
  785. }
  786. for _, network := range c.UnsafeNetworks() {
  787. i.networks.Insert(network, NetworkTypeUnsafe)
  788. }
  789. }
  790. // logger returns a derived slog.Logger with per-hostinfo fields pre-bound.
  791. func (i *HostInfo) logger(l *slog.Logger) *slog.Logger {
  792. if i == nil {
  793. return l
  794. }
  795. li := l.With(
  796. "vpnAddrs", i.vpnAddrs,
  797. "localIndex", i.localIndexId,
  798. "remoteIndex", i.remoteIndexId,
  799. )
  800. if connState := i.ConnectionState; connState != nil {
  801. if peerCert := connState.peerCert; peerCert != nil {
  802. li = li.With("certName", peerCert.Certificate.Name())
  803. }
  804. }
  805. return li
  806. }