mirrors/nebula
1
Fork 0
mirror of https://github.com/slackhq/nebula.git synced 2025-12-06 02:30:57 -08:00
Code Issues Projects Releases Packages Wiki Activity Actions

we can go faster tbh

Browse source
This commit is contained in:
JackDoan 2025-11-13 16:44:35 -06:00
parent e8ea021bdd
commit a39d3c79b2
2 changed files with 8 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

8
outside.go
View file

@ -421,10 +421,10 @@ func (f *Interface) readOutsidePacketsMany(packets []*packet.Packet, out []*pack
f.connectionManager.In(hostinfo) f.connectionManager.In(hostinfo)
} }
//_, err := f.readers[q].WriteOne(out[i], false, q) _, err := f.readers[q].WriteOne(out[i], false, q)
//if err != nil { if err != nil {
// f.l.WithError(err).Error("Failed to write packet") f.l.WithError(err).Error("Failed to write packet")
//} }
} }
} }

6
overlay/vhostnet/device.go
View file

@ -281,7 +281,6 @@ func (dev *Device) GetPacketForTx() (uint16, []byte, error) {
} }
func (dev *Device) TransmitPacket(pkt *packet.OutPacket, kick bool) error { func (dev *Device) TransmitPacket(pkt *packet.OutPacket, kick bool) error {
//if pkt.Valid {
if len(pkt.SegmentIDs) == 0 { if len(pkt.SegmentIDs) == 0 {
return nil return nil
} }
@ -294,12 +293,11 @@ func (dev *Device) TransmitPacket(pkt *packet.OutPacket, kick bool) error {
return fmt.Errorf("offer descriptor chains: %w", err) return fmt.Errorf("offer descriptor chains: %w", err)
} }
pkt.Reset() pkt.Reset()
//} if kick {
//if kick {
if err := dev.TransmitQueue.Kick(); err != nil { if err := dev.TransmitQueue.Kick(); err != nil {
return err return err
} }
//} }
return nil return nil
} }