mirror of
https://github.com/cwinfo/yggdrasil-go.git
synced 2024-12-23 15:45:40 +00:00
commit
80535d402f
@ -6,6 +6,7 @@ package yggdrasil
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
|
"container/heap"
|
||||||
"errors"
|
"errors"
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
@ -15,42 +16,61 @@ import (
|
|||||||
"github.com/yggdrasil-network/yggdrasil-go/src/util"
|
"github.com/yggdrasil-network/yggdrasil-go/src/util"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
// Duration that we keep track of old nonces per session, to allow some out-of-order packet delivery
|
||||||
|
const nonceWindow = time.Second
|
||||||
|
|
||||||
|
// A heap of nonces, used with a map[nonce]time to allow out-of-order packets a little time to arrive without rejecting them
|
||||||
|
type nonceHeap []crypto.BoxNonce
|
||||||
|
|
||||||
|
func (h nonceHeap) Len() int { return len(h) }
|
||||||
|
func (h nonceHeap) Less(i, j int) bool { return h[i].Minus(&h[j]) < 0 }
|
||||||
|
func (h nonceHeap) Swap(i, j int) { h[i], h[j] = h[j], h[i] }
|
||||||
|
func (h *nonceHeap) Push(x interface{}) { *h = append(*h, x.(crypto.BoxNonce)) }
|
||||||
|
func (h *nonceHeap) Pop() interface{} {
|
||||||
|
l := len(*h)
|
||||||
|
var n crypto.BoxNonce
|
||||||
|
n, *h = (*h)[l-1], (*h)[:l-1]
|
||||||
|
return n
|
||||||
|
}
|
||||||
|
func (h nonceHeap) peek() *crypto.BoxNonce { return &h[len(h)-1] }
|
||||||
|
|
||||||
// All the information we know about an active session.
|
// All the information we know about an active session.
|
||||||
// This includes coords, permanent and ephemeral keys, handles and nonces, various sorts of timing information for timeout and maintenance, and some metadata for the admin API.
|
// This includes coords, permanent and ephemeral keys, handles and nonces, various sorts of timing information for timeout and maintenance, and some metadata for the admin API.
|
||||||
type sessionInfo struct {
|
type sessionInfo struct {
|
||||||
mutex sync.Mutex // Protects all of the below, use it any time you read/chance the contents of a session
|
mutex sync.Mutex // Protects all of the below, use it any time you read/chance the contents of a session
|
||||||
core *Core //
|
core *Core //
|
||||||
reconfigure chan chan error //
|
reconfigure chan chan error //
|
||||||
theirAddr address.Address //
|
theirAddr address.Address //
|
||||||
theirSubnet address.Subnet //
|
theirSubnet address.Subnet //
|
||||||
theirPermPub crypto.BoxPubKey //
|
theirPermPub crypto.BoxPubKey //
|
||||||
theirSesPub crypto.BoxPubKey //
|
theirSesPub crypto.BoxPubKey //
|
||||||
mySesPub crypto.BoxPubKey //
|
mySesPub crypto.BoxPubKey //
|
||||||
mySesPriv crypto.BoxPrivKey //
|
mySesPriv crypto.BoxPrivKey //
|
||||||
sharedSesKey crypto.BoxSharedKey // derived from session keys
|
sharedSesKey crypto.BoxSharedKey // derived from session keys
|
||||||
theirHandle crypto.Handle //
|
theirHandle crypto.Handle //
|
||||||
myHandle crypto.Handle //
|
myHandle crypto.Handle //
|
||||||
theirNonce crypto.BoxNonce //
|
theirNonce crypto.BoxNonce //
|
||||||
theirNonceMask uint64 //
|
theirNonceHeap nonceHeap // priority queue to keep track of the lowest nonce we recently accepted
|
||||||
myNonce crypto.BoxNonce //
|
theirNonceMap map[crypto.BoxNonce]time.Time // time we added each nonce to the heap
|
||||||
theirMTU uint16 //
|
myNonce crypto.BoxNonce //
|
||||||
myMTU uint16 //
|
theirMTU uint16 //
|
||||||
wasMTUFixed bool // Was the MTU fixed by a receive error?
|
myMTU uint16 //
|
||||||
timeOpened time.Time // Time the sessino was opened
|
wasMTUFixed bool // Was the MTU fixed by a receive error?
|
||||||
time time.Time // Time we last received a packet
|
timeOpened time.Time // Time the sessino was opened
|
||||||
mtuTime time.Time // time myMTU was last changed
|
time time.Time // Time we last received a packet
|
||||||
pingTime time.Time // time the first ping was sent since the last received packet
|
mtuTime time.Time // time myMTU was last changed
|
||||||
pingSend time.Time // time the last ping was sent
|
pingTime time.Time // time the first ping was sent since the last received packet
|
||||||
coords []byte // coords of destination
|
pingSend time.Time // time the last ping was sent
|
||||||
reset bool // reset if coords change
|
coords []byte // coords of destination
|
||||||
tstamp int64 // ATOMIC - tstamp from their last session ping, replay attack mitigation
|
reset bool // reset if coords change
|
||||||
bytesSent uint64 // Bytes of real traffic sent in this session
|
tstamp int64 // ATOMIC - tstamp from their last session ping, replay attack mitigation
|
||||||
bytesRecvd uint64 // Bytes of real traffic received in this session
|
bytesSent uint64 // Bytes of real traffic sent in this session
|
||||||
init chan struct{} // Closed when the first session pong arrives, used to signal that the session is ready for initial use
|
bytesRecvd uint64 // Bytes of real traffic received in this session
|
||||||
cancel util.Cancellation // Used to terminate workers
|
init chan struct{} // Closed when the first session pong arrives, used to signal that the session is ready for initial use
|
||||||
fromRouter chan wire_trafficPacket // Received packets go here, to be decrypted by the session
|
cancel util.Cancellation // Used to terminate workers
|
||||||
recv chan []byte // Decrypted packets go here, picked up by the associated Conn
|
fromRouter chan wire_trafficPacket // Received packets go here, to be decrypted by the session
|
||||||
send chan FlowKeyMessage // Packets with optional flow key go here, to be encrypted and sent
|
recv chan []byte // Decrypted packets go here, picked up by the associated Conn
|
||||||
|
send chan FlowKeyMessage // Packets with optional flow key go here, to be encrypted and sent
|
||||||
}
|
}
|
||||||
|
|
||||||
func (sinfo *sessionInfo) doFunc(f func()) {
|
func (sinfo *sessionInfo) doFunc(f func()) {
|
||||||
@ -87,7 +107,8 @@ func (s *sessionInfo) update(p *sessionPing) bool {
|
|||||||
s.theirHandle = p.Handle
|
s.theirHandle = p.Handle
|
||||||
s.sharedSesKey = *crypto.GetSharedKey(&s.mySesPriv, &s.theirSesPub)
|
s.sharedSesKey = *crypto.GetSharedKey(&s.mySesPriv, &s.theirSesPub)
|
||||||
s.theirNonce = crypto.BoxNonce{}
|
s.theirNonce = crypto.BoxNonce{}
|
||||||
s.theirNonceMask = 0
|
s.theirNonceHeap = nil
|
||||||
|
s.theirNonceMap = make(map[crypto.BoxNonce]time.Time)
|
||||||
}
|
}
|
||||||
if p.MTU >= 1280 || p.MTU == 0 {
|
if p.MTU >= 1280 || p.MTU == 0 {
|
||||||
s.theirMTU = p.MTU
|
s.theirMTU = p.MTU
|
||||||
@ -400,27 +421,40 @@ func (sinfo *sessionInfo) getMTU() uint16 {
|
|||||||
// Checks if a packet's nonce is recent enough to fall within the window of allowed packets, and not already received.
|
// Checks if a packet's nonce is recent enough to fall within the window of allowed packets, and not already received.
|
||||||
func (sinfo *sessionInfo) nonceIsOK(theirNonce *crypto.BoxNonce) bool {
|
func (sinfo *sessionInfo) nonceIsOK(theirNonce *crypto.BoxNonce) bool {
|
||||||
// The bitmask is to allow for some non-duplicate out-of-order packets
|
// The bitmask is to allow for some non-duplicate out-of-order packets
|
||||||
diff := theirNonce.Minus(&sinfo.theirNonce)
|
if theirNonce.Minus(&sinfo.theirNonce) > 0 {
|
||||||
if diff > 0 {
|
// This is newer than the newest nonce we've seen
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
return ^sinfo.theirNonceMask&(0x01<<uint64(-diff)) != 0
|
if len(sinfo.theirNonceHeap) > 0 {
|
||||||
|
if theirNonce.Minus(sinfo.theirNonceHeap.peek()) > 0 {
|
||||||
|
if _, isIn := sinfo.theirNonceMap[*theirNonce]; !isIn {
|
||||||
|
// This nonce is recent enough that we keep track of older nonces, but it's not one we've seen yet
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
// Updates the nonce mask by (possibly) shifting the bitmask and setting the bit corresponding to this nonce to 1, and then updating the most recent nonce
|
// Updates the nonce mask by (possibly) shifting the bitmask and setting the bit corresponding to this nonce to 1, and then updating the most recent nonce
|
||||||
func (sinfo *sessionInfo) updateNonce(theirNonce *crypto.BoxNonce) {
|
func (sinfo *sessionInfo) updateNonce(theirNonce *crypto.BoxNonce) {
|
||||||
// Shift nonce mask if needed
|
// Start with some cleanup
|
||||||
// Set bit
|
for len(sinfo.theirNonceHeap) > 64 {
|
||||||
diff := theirNonce.Minus(&sinfo.theirNonce)
|
if time.Since(sinfo.theirNonceMap[*sinfo.theirNonceHeap.peek()]) < nonceWindow {
|
||||||
if diff > 0 {
|
// This nonce is still fairly new, so keep it around
|
||||||
// This nonce is newer, so shift the window before setting the bit, and update theirNonce in the session info.
|
break
|
||||||
sinfo.theirNonceMask <<= uint64(diff)
|
}
|
||||||
sinfo.theirNonceMask &= 0x01
|
// TODO? reallocate the map in some cases, to free unused map space?
|
||||||
sinfo.theirNonce = *theirNonce
|
delete(sinfo.theirNonceMap, *sinfo.theirNonceHeap.peek())
|
||||||
} else {
|
heap.Pop(&sinfo.theirNonceHeap)
|
||||||
// This nonce is older, so set the bit but do not shift the window.
|
|
||||||
sinfo.theirNonceMask &= 0x01 << uint64(-diff)
|
|
||||||
}
|
}
|
||||||
|
if theirNonce.Minus(&sinfo.theirNonce) > 0 {
|
||||||
|
// This nonce is the newest we've seen, so make a note of that
|
||||||
|
sinfo.theirNonce = *theirNonce
|
||||||
|
}
|
||||||
|
// Add it to the heap/map so we know not to allow it again
|
||||||
|
heap.Push(&sinfo.theirNonceHeap, *theirNonce)
|
||||||
|
sinfo.theirNonceMap[*theirNonce] = time.Now()
|
||||||
}
|
}
|
||||||
|
|
||||||
// Resets all sessions to an uninitialized state.
|
// Resets all sessions to an uninitialized state.
|
||||||
|
Loading…
Reference in New Issue
Block a user