From a39d3c79b2bfba206b22a48daff657a925f1e20e Mon Sep 17 00:00:00 2001 From: JackDoan Date: Thu, 13 Nov 2025 16:44:35 -0600 Subject: [PATCH] we can go faster tbh --- outside.go | 8 ++++---- overlay/vhostnet/device.go | 10 ++++------ 2 files changed, 8 insertions(+), 10 deletions(-) diff --git a/outside.go b/outside.go index d0c64c7..c438157 100644 --- a/outside.go +++ b/outside.go @@ -421,10 +421,10 @@ func (f *Interface) readOutsidePacketsMany(packets []*packet.Packet, out []*pack f.connectionManager.In(hostinfo) } - //_, err := f.readers[q].WriteOne(out[i], false, q) - //if err != nil { - // f.l.WithError(err).Error("Failed to write packet") - //} + _, err := f.readers[q].WriteOne(out[i], false, q) + if err != nil { + f.l.WithError(err).Error("Failed to write packet") + } } } diff --git a/overlay/vhostnet/device.go b/overlay/vhostnet/device.go index ba41c7e..a60c0ef 100644 --- a/overlay/vhostnet/device.go +++ b/overlay/vhostnet/device.go @@ -281,7 +281,6 @@ func (dev *Device) GetPacketForTx() (uint16, []byte, error) { } func (dev *Device) TransmitPacket(pkt *packet.OutPacket, kick bool) error { - //if pkt.Valid { if len(pkt.SegmentIDs) == 0 { return nil } @@ -294,12 +293,11 @@ func (dev *Device) TransmitPacket(pkt *packet.OutPacket, kick bool) error { return fmt.Errorf("offer descriptor chains: %w", err) } pkt.Reset() - //} - //if kick { - if err := dev.TransmitQueue.Kick(); err != nil { - return err + if kick { + if err := dev.TransmitQueue.Kick(); err != nil { + return err + } } - //} return nil }