Function BenchmarkRecvDataFromRemote

internal/multiplex/session_test.go:535–580

(b *testing.B)

}

func BenchmarkRecvDataFromRemote(b *testing.B) {
	testPayload := make([]byte, testPayloadLen)
	rand.Read(testPayload)
	f := Frame{
		1,
		0,
		0,
		testPayload,
	}

	var sessionKey [32]byte
	rand.Read(sessionKey[:])

	const maxIter = 500_000 // run with -benchtime 500000x to avoid index out of bounds panic
	for name, ep := range encryptionMethods {
		ep := ep
		b.Run(name, func(b *testing.B) {
			for seshType, seshConfig := range seshConfigs {
				b.Run(seshType, func(b *testing.B) {
					f := f
					seshConfig.Obfuscator, _ = MakeObfuscator(ep, sessionKey)
					sesh := MakeSession(0, seshConfig)

					go func() {
						stream, _ := sesh.Accept()
						io.Copy(ioutil.Discard, stream)
					}()

					binaryFrames := [maxIter][]byte{}
					for i := 0; i < maxIter; i++ {
						obfsBuf := make([]byte, obfsBufLen)
						n, _ := sesh.obfuscate(&f, obfsBuf, 0)
						binaryFrames[i] = obfsBuf[:n]
						f.Seq++
					}

					b.SetBytes(int64(len(f.Payload)))
					b.ResetTimer()
					for i := 0; i < b.N; i++ {
						sesh.recvDataFromRemote(binaryFrames[i])
					}
				})
			}
		})
	}
}

func BenchmarkMultiStreamWrite(b *testing.B) {
	var sessionKey [32]byte