mirror of
https://github.com/fumiama/terasu-cloudflared.git
synced 2026-06-06 09:30:24 +08:00
1fb466941a
Instead of creating a go routine to process each incoming datagram from the tunnel, a single consumer (the demuxer) will process each of the datagrams in serial. Registration datagrams will still be spun out into separate go routines since they are responsible for managing the lifetime of the session once started via the `Serve` method. UDP payload datagrams will be handled in separate channels to allow for parallel writing inside of the scope of a session via a new write loop. This channel will have a small buffer to help unblock the demuxer from dequeueing other datagrams. ICMP datagrams will be funneled into a single channel across all possible origins with a single consumer to write to their respective destinations. Each of these changes is to prevent datagram reordering from occurring when dequeuing from the tunnel connection. By establishing a single demuxer that serializes the writes per session, each session will be able to write sequentially, but in parallel to their respective origins. Closes TUN-9882
28 lines
712 B
Go
28 lines
712 B
Go
package v3_test
|
|
|
|
import (
|
|
"testing"
|
|
)
|
|
|
|
// FuzzSessionWrite verifies that we don't run into any panics when writing a single variable sized payload to the origin.
|
|
func FuzzSessionWrite(f *testing.F) {
|
|
f.Fuzz(func(t *testing.T, b []byte) {
|
|
// The origin transport read is bound to 1280 bytes
|
|
if len(b) > 1280 {
|
|
b = b[:1280]
|
|
}
|
|
testSessionWrite(t, [][]byte{b})
|
|
})
|
|
}
|
|
|
|
// FuzzSessionRead verifies that we don't run into any panics when reading a single variable sized payload from the origin.
|
|
func FuzzSessionRead(f *testing.F) {
|
|
f.Fuzz(func(t *testing.T, b []byte) {
|
|
// The origin transport read is bound to 1280 bytes
|
|
if len(b) > 1280 {
|
|
b = b[:1280]
|
|
}
|
|
testSessionRead(t, [][]byte{b})
|
|
})
|
|
}
|