forked from quic-go/quic-go
@@ -125,7 +125,7 @@ var _ = Describe("Benchmarks", func() {
|
|||||||
done := make(chan struct{})
|
done := make(chan struct{})
|
||||||
go func() {
|
go func() {
|
||||||
defer GinkgoRecover()
|
defer GinkgoRecover()
|
||||||
buf := make([]byte, 1500)
|
buf := make([]byte, 1024)
|
||||||
dataRead := 0
|
dataRead := 0
|
||||||
for dataRead < dataLen {
|
for dataRead < dataLen {
|
||||||
n, err := s2stream.Read(buf)
|
n, err := s2stream.Read(buf)
|
||||||
@@ -147,7 +147,7 @@ var _ = Describe("Benchmarks", func() {
|
|||||||
time.Sleep(time.Millisecond)
|
time.Sleep(time.Millisecond)
|
||||||
|
|
||||||
b.RecordValue("transfer rate [MB/s]", float64(dataLen)/1e6/runtime.Seconds())
|
b.RecordValue("transfer rate [MB/s]", float64(dataLen)/1e6/runtime.Seconds())
|
||||||
}, 6)
|
}, 3)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|||||||
Reference in New Issue
Block a user