diff --git a/examples/berkeley-listener/berkeley_server.go b/examples/berkeley-listener/berkeley_server.go index a723f5b..f3cee5f 100644 --- a/examples/berkeley-listener/berkeley_server.go +++ b/examples/berkeley-listener/berkeley_server.go @@ -347,6 +347,7 @@ func mockClient(stack *xnet.StackAsync, port uint16, subnet netip.Prefix) { TxBuf: make([]byte, 2048), TxPacketQueueSize: 4, Logger: slog.Default(), + RWBackoff: tcpBackoff, }) if err != nil { panic(err.Error()) diff --git a/x/xnet/stack-go.go b/x/xnet/stack-go.go index 3c43d1a..cb2ca63 100644 --- a/x/xnet/stack-go.go +++ b/x/xnet/stack-go.go @@ -99,6 +99,7 @@ func (s StackGo) SocketNetip(ctx context.Context, network string, family, sotype RxBuf: make([]byte, s.plcfg.RxBufSize), TxQueueSize: s.plcfg.QueueSize, RxQueueSize: s.plcfg.QueueSize, + RWBackoff: s.plcfg.NewBackoff(), }) if err != nil { return nil, err @@ -120,6 +121,7 @@ func (s StackGo) SocketNetip(ctx context.Context, network string, family, sotype RxBuf: make([]byte, s.plcfg.RxBufSize), TxQueueSize: s.plcfg.QueueSize, RxQueueSize: s.plcfg.QueueSize, + RWBackoff: s.plcfg.NewBackoff(), }) if err != nil { return nil, err diff --git a/x/xnet/xnet_bench_test.go b/x/xnet/xnet_bench_test.go index 4f9eeec..8bcfce5 100644 --- a/x/xnet/xnet_bench_test.go +++ b/x/xnet/xnet_bench_test.go @@ -112,6 +112,7 @@ func BenchmarkTCPHandshake(b *testing.B) { RxBuf: buf[:MTU], TxBuf: buf[MTU : MTU*2], TxPacketQueueSize: 4, + RWBackoff: backoffYield, }) if err != nil { b.Fatal(err) @@ -120,6 +121,7 @@ func BenchmarkTCPHandshake(b *testing.B) { RxBuf: buf[2*MTU : 3*MTU], TxBuf: buf[3*MTU : 4*MTU], TxPacketQueueSize: 4, + RWBackoff: backoffYield, }) if err != nil { b.Fatal(err)