Skip to content

Commit 9efd887

Browse files
authored
perf: update benchmarks to record throughput (#49)
1 parent ae22b5d commit 9efd887

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

websocket_test.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -985,13 +985,15 @@ func BenchmarkReadFrame(b *testing.B) {
985985
// Run sub-benchmarks for each payload size
986986
b.Run(formatSize(size), func(b *testing.B) {
987987
src := bytes.NewReader(buf.Bytes())
988+
b.SetBytes(int64(buf.Len()))
988989
b.ResetTimer()
989990
for i := 0; i < b.N; i++ {
990991
_, _ = src.Seek(0, 0)
991-
_, err := websocket.ReadFrame(src, websocket.ServerMode, size)
992+
frame2, err := websocket.ReadFrame(src, websocket.ServerMode, size)
992993
if err != nil {
993994
b.Fatalf("unexpected error: %v", err)
994995
}
996+
assert.Equal(b, len(frame2.Payload), len(frame.Payload), "payload length")
995997
}
996998
})
997999
}
@@ -1050,6 +1052,7 @@ func BenchmarkReadMessage(b *testing.B) {
10501052

10511053
name := fmt.Sprintf("%s/%d", formatSize(msgSize), frameCount)
10521054
b.Run(name, func(b *testing.B) {
1055+
b.SetBytes(int64(buf.Len()))
10531056
for i := 0; i < b.N; i++ {
10541057
_, _ = reader.Seek(0, 0)
10551058
msg, err := ws.ReadMessage(context.Background())

0 commit comments

Comments
 (0)