mirror of
https://github.com/slackhq/nebula.git
synced 2025-12-30 18:48:28 +01:00
tidy
This commit is contained in:
@@ -297,7 +297,6 @@ func (f *Interface) listenOut(q int) {
|
|||||||
li.ListenOut(func(pkts []*packet.Packet) {
|
li.ListenOut(func(pkts []*packet.Packet) {
|
||||||
toSend = toSend[:0]
|
toSend = toSend[:0]
|
||||||
for i := range outPackets {
|
for i := range outPackets {
|
||||||
outPackets[i].Valid = false
|
|
||||||
outPackets[i].SegCounter = 0
|
outPackets[i].SegCounter = 0
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -10,11 +10,9 @@ type OutPacket struct {
|
|||||||
SegmentPayloads [][]byte
|
SegmentPayloads [][]byte
|
||||||
SegmentHeaders [][]byte
|
SegmentHeaders [][]byte
|
||||||
SegmentIDs []uint16
|
SegmentIDs []uint16
|
||||||
//todo virtio header?
|
|
||||||
SegSize int
|
SegSize int
|
||||||
SegCounter int
|
SegCounter int
|
||||||
Valid bool
|
|
||||||
wasSegmented bool
|
|
||||||
|
|
||||||
Scratch []byte
|
Scratch []byte
|
||||||
}
|
}
|
||||||
@@ -35,12 +33,9 @@ func (pkt *OutPacket) Reset() {
|
|||||||
pkt.SegmentHeaders = pkt.SegmentHeaders[:0]
|
pkt.SegmentHeaders = pkt.SegmentHeaders[:0]
|
||||||
pkt.SegmentIDs = pkt.SegmentIDs[:0]
|
pkt.SegmentIDs = pkt.SegmentIDs[:0]
|
||||||
pkt.SegSize = 0
|
pkt.SegSize = 0
|
||||||
pkt.Valid = false
|
|
||||||
pkt.wasSegmented = false
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (pkt *OutPacket) UseSegment(segID uint16, seg []byte, isV6 bool) int {
|
func (pkt *OutPacket) UseSegment(segID uint16, seg []byte, isV6 bool) int {
|
||||||
pkt.Valid = true
|
|
||||||
pkt.SegmentIDs = append(pkt.SegmentIDs, segID)
|
pkt.SegmentIDs = append(pkt.SegmentIDs, segID)
|
||||||
pkt.Segments = append(pkt.Segments, seg) //todo do we need this?
|
pkt.Segments = append(pkt.Segments, seg) //todo do we need this?
|
||||||
|
|
||||||
|
|||||||
@@ -9,7 +9,6 @@ type VirtIOPacket struct {
|
|||||||
Header virtio.NetHdr
|
Header virtio.NetHdr
|
||||||
Chains []uint16
|
Chains []uint16
|
||||||
ChainRefs [][]byte
|
ChainRefs [][]byte
|
||||||
// OfferDescriptorChains(chains []uint16, kick bool) error
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewVIO() *VirtIOPacket {
|
func NewVIO() *VirtIOPacket {
|
||||||
@@ -25,13 +24,3 @@ func (v *VirtIOPacket) Reset() {
|
|||||||
v.ChainRefs = v.ChainRefs[:0]
|
v.ChainRefs = v.ChainRefs[:0]
|
||||||
v.Chains = v.Chains[:0]
|
v.Chains = v.Chains[:0]
|
||||||
}
|
}
|
||||||
|
|
||||||
type VirtIOTXPacket struct {
|
|
||||||
VirtIOPacket
|
|
||||||
}
|
|
||||||
|
|
||||||
func NewVIOTX(isV4 bool) *VirtIOTXPacket {
|
|
||||||
out := new(VirtIOTXPacket)
|
|
||||||
out.VirtIOPacket = *NewVIO()
|
|
||||||
return out
|
|
||||||
}
|
|
||||||
|
|||||||
Reference in New Issue
Block a user