diff --git a/src/tun/iface.go b/src/tun/iface.go index 2028b130..3a4c55f4 100644 --- a/src/tun/iface.go +++ b/src/tun/iface.go @@ -1,17 +1,9 @@ package tun const TUN_OFFSET_BYTES = 80 // sizeof(virtio_net_hdr) -const TUN_MAX_VECTOR = 16 - -func (tun *TunAdapter) idealBatchSize() int { - if b := tun.iface.BatchSize(); b <= TUN_MAX_VECTOR { - return b - } - return TUN_MAX_VECTOR -} func (tun *TunAdapter) read() { - vs := tun.idealBatchSize() + vs := tun.iface.BatchSize() bufs := make([][]byte, vs) sizes := make([]int, vs) for i := range bufs { diff --git a/src/tun/tun.go b/src/tun/tun.go index 027dfd00..e6795c64 100644 --- a/src/tun/tun.go +++ b/src/tun/tun.go @@ -162,7 +162,7 @@ func (tun *TunAdapter) _start() error { tun.rwc.SetMTU(tun.MTU()) tun.isOpen = true tun.isEnabled = true - tun.ch = make(chan []byte, tun.idealBatchSize()) + tun.ch = make(chan []byte, tun.iface.BatchSize()) go tun.queue() go tun.read() go tun.write()