soypat/lneto
1
0
Fork 0
mirror of https://github.com/soypat/lneto.git synced 2026-09-10 08:39:30 +00:00
Code Issues Packages Projects Releases 1 Wiki Activity

add missing backoffs

Browse Source
This commit is contained in:
Patricio Whittingslow
2026-06-09 14:33:50 -03:00
parent 6ba06acdcb
commit 82f9461548
3 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
examples/berkeley-listener/berkeley_server.go
+1
View File
@@ -347,6 +347,7 @@ func mockClient(stack *xnet.StackAsync, port uint16, subnet netip.Prefix) {
TxBuf: make([]byte, 2048), TxBuf: make([]byte, 2048),
TxPacketQueueSize: 4, TxPacketQueueSize: 4,
Logger: slog.Default(), Logger: slog.Default(),
RWBackoff: tcpBackoff,
}) })
if err != nil { if err != nil {
panic(err.Error()) panic(err.Error())
x/xnet/stack-go.go
+2
View File
@@ -99,6 +99,7 @@ func (s StackGo) SocketNetip(ctx context.Context, network string, family, sotype
RxBuf: make([]byte, s.plcfg.RxBufSize), RxBuf: make([]byte, s.plcfg.RxBufSize),
TxQueueSize: s.plcfg.QueueSize, TxQueueSize: s.plcfg.QueueSize,
RxQueueSize: s.plcfg.QueueSize, RxQueueSize: s.plcfg.QueueSize,
RWBackoff: s.plcfg.NewBackoff(),
}) })
if err != nil { if err != nil {
return nil, err return nil, err
@@ -120,6 +121,7 @@ func (s StackGo) SocketNetip(ctx context.Context, network string, family, sotype
RxBuf: make([]byte, s.plcfg.RxBufSize), RxBuf: make([]byte, s.plcfg.RxBufSize),
TxQueueSize: s.plcfg.QueueSize, TxQueueSize: s.plcfg.QueueSize,
RxQueueSize: s.plcfg.QueueSize, RxQueueSize: s.plcfg.QueueSize,
RWBackoff: s.plcfg.NewBackoff(),
}) })
if err != nil { if err != nil {
return nil, err return nil, err
x/xnet/xnet_bench_test.go
+2
View File
@@ -112,6 +112,7 @@ func BenchmarkTCPHandshake(b *testing.B) {
RxBuf: buf[:MTU], RxBuf: buf[:MTU],
TxBuf: buf[MTU : MTU*2], TxBuf: buf[MTU : MTU*2],
TxPacketQueueSize: 4, TxPacketQueueSize: 4,
RWBackoff: backoffYield,
}) })
if err != nil { if err != nil {
b.Fatal(err) b.Fatal(err)
@@ -120,6 +121,7 @@ func BenchmarkTCPHandshake(b *testing.B) {
RxBuf: buf[2*MTU : 3*MTU], RxBuf: buf[2*MTU : 3*MTU],
TxBuf: buf[3*MTU : 4*MTU], TxBuf: buf[3*MTU : 4*MTU],
TxPacketQueueSize: 4, TxPacketQueueSize: 4,
RWBackoff: backoffYield,
}) })
if err != nil { if err != nil {
b.Fatal(err) b.Fatal(err)