mirror of
https://github.com/yggdrasil-network/yggdrasil-go.git
synced 2024-12-11 18:54:23 +00:00
Simpler flowlabel parsing; avoid using 0 flowlabel.
This commit is contained in:
parent
ddab8ecf33
commit
11b0a82c4a
@ -425,28 +425,28 @@ func (sinfo *sessionInfo) doSend(bs []byte) {
|
|||||||
if !sinfo.init {
|
if !sinfo.init {
|
||||||
return
|
return
|
||||||
} // To prevent using empty session keys
|
} // To prevent using empty session keys
|
||||||
|
|
||||||
|
var coords []byte
|
||||||
|
// Read IPv6 flowlabel field (20 bits).
|
||||||
|
// XXX(cathugger): is len(bs) validated there?
|
||||||
|
flowlabel := uint(bs[1]&0x0f)<<16 | uint(bs[2])<<8 | uint(bs[3])
|
||||||
|
if flowlabel != 0 {
|
||||||
// Now we append something to the coords
|
// Now we append something to the coords
|
||||||
// Specifically, we append a 0, and then arbitrary data
|
// Specifically, we append a 0, and then arbitrary data
|
||||||
// The 0 ensures that the destination node switch forwards to the self peer (router)
|
// The 0 ensures that the destination node switch forwards to the self peer (router)
|
||||||
// The rest is ignored, but it's still part as the coords, so it affects switch queues
|
// The rest is ignored, but it's still part as the coords, so it affects switch queues
|
||||||
// This helps separate traffic streams (coords, flowlabel) to be queued independently
|
// This helps separate traffic streams (coords, flowlabel) to be queued independently
|
||||||
var coords []byte
|
|
||||||
addUint64 := func(bs []byte) {
|
|
||||||
// Converts bytes to a uint64
|
|
||||||
// Converts that back to variable length bytes
|
|
||||||
// Appends it to coords
|
|
||||||
var u uint64
|
|
||||||
for _, b := range bs {
|
|
||||||
u <<= 8
|
|
||||||
u |= uint64(b)
|
|
||||||
}
|
|
||||||
coords = append(coords, wire_encode_uint64(u)...)
|
|
||||||
}
|
|
||||||
coords = append(coords, sinfo.coords...) // Start with the real coords
|
coords = append(coords, sinfo.coords...) // Start with the real coords
|
||||||
coords = append(coords, 0) // Then target the local switchport
|
coords = append(coords, 0) // Then target the local switchport
|
||||||
flowlabel := append([]byte(nil), bs[1:4]...)
|
coords = append(coords, wire_encode_uint64(uint64(flowlabel))...) // Then variable-length encoded flowlabel
|
||||||
flowlabel[0] &= 0x0f
|
} else {
|
||||||
addUint64(flowlabel)
|
// 0 value means that flowlabels aren't being generated by OS.
|
||||||
|
// To save bytes, we're not including it, therefore we won't need self-port override either.
|
||||||
|
// So just use sinfo.coords directly to avoid golang GC allocations.
|
||||||
|
// XXX: investigate where flowlabels aren't included, and attempt to look into TCP/UDP/SCTP/DCCP headers' sport/dport fields?
|
||||||
|
coords = sinfo.coords
|
||||||
|
}
|
||||||
payload, nonce := boxSeal(&sinfo.sharedSesKey, bs, &sinfo.myNonce)
|
payload, nonce := boxSeal(&sinfo.sharedSesKey, bs, &sinfo.myNonce)
|
||||||
defer util_putBytes(payload)
|
defer util_putBytes(payload)
|
||||||
p := wire_trafficPacket{
|
p := wire_trafficPacket{
|
||||||
|
Loading…
Reference in New Issue
Block a user