Skip to content
This repository was archived by the owner on Jun 20, 2024. It is now read-only.

Commit bfcd8c1

Browse files
committed
Replace MacCache.Add by MacCache.AddForced
The former function is obsolete.
1 parent 2408f0e commit bfcd8c1

File tree

2 files changed

+3
-14
lines changed

2 files changed

+3
-14
lines changed

router/mac_cache.go

+1-12
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ func NewMacCache(maxAge time.Duration, onExpiry func(net.HardwareAddr, *mesh.Pee
3030
return cache
3131
}
3232

33-
func (cache *MacCache) add(mac net.HardwareAddr, peer *mesh.Peer, force bool) (bool, *mesh.Peer) {
33+
func (cache *MacCache) Add(mac net.HardwareAddr, peer *mesh.Peer) (bool, *mesh.Peer) {
3434
key := macint(mac)
3535
now := time.Now()
3636

@@ -55,9 +55,6 @@ func (cache *MacCache) add(mac net.HardwareAddr, peer *mesh.Peer, force bool) (b
5555

5656
if entry.peer != peer {
5757
conflictPeer = entry.peer
58-
if !force {
59-
return false, conflictPeer
60-
}
6158
entry.peer = peer
6259
}
6360

@@ -68,14 +65,6 @@ func (cache *MacCache) add(mac net.HardwareAddr, peer *mesh.Peer, force bool) (b
6865
return false, conflictPeer
6966
}
7067

71-
func (cache *MacCache) Add(mac net.HardwareAddr, peer *mesh.Peer) (bool, *mesh.Peer) {
72-
return cache.add(mac, peer, false)
73-
}
74-
75-
func (cache *MacCache) AddForced(mac net.HardwareAddr, peer *mesh.Peer) (bool, *mesh.Peer) {
76-
return cache.add(mac, peer, true)
77-
}
78-
7968
func (cache *MacCache) Lookup(mac net.HardwareAddr) *mesh.Peer {
8069
key := macint(mac)
8170
cache.RLock()

router/network_router.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ func (router *NetworkRouter) handleCapturedPacket(key PacketKey) FlowOp {
8484
srcMac := net.HardwareAddr(key.SrcMAC[:])
8585
dstMac := net.HardwareAddr(key.DstMAC[:])
8686

87-
switch newSrcMac, conflictPeer := router.Macs.AddForced(srcMac, router.Ourself.Peer); {
87+
switch newSrcMac, conflictPeer := router.Macs.Add(srcMac, router.Ourself.Peer); {
8888
case newSrcMac:
8989
log.Print("Discovered local MAC ", srcMac)
9090
case conflictPeer != nil:
@@ -136,7 +136,7 @@ func (router *NetworkRouter) handleForwardedPacket(key ForwardPacketKey) FlowOp
136136
srcMac := net.HardwareAddr(key.SrcMAC[:])
137137
dstMac := net.HardwareAddr(key.DstMAC[:])
138138

139-
switch newSrcMac, conflictPeer := router.Macs.AddForced(srcMac, key.SrcPeer); {
139+
switch newSrcMac, conflictPeer := router.Macs.Add(srcMac, key.SrcPeer); {
140140
case newSrcMac:
141141
log.Print("Discovered remote MAC ", srcMac, " at ", key.SrcPeer)
142142
case conflictPeer != nil:

0 commit comments

Comments
 (0)