From a5229e95a7a94b1fdb97f0d793dfbc7e40885e1e Mon Sep 17 00:00:00 2001 From: Markku Rossi Date: Sat, 18 Feb 2023 14:16:36 +0100 Subject: [PATCH] Start benchmark timer after OT.Init{Sender,Receiver}(). --- ot/ot_test.go | 57 ++++++++++++++++++++++----------------------------- 1 file changed, 25 insertions(+), 32 deletions(-) diff --git a/ot/ot_test.go b/ot/ot_test.go index fae79c51..677791d2 100644 --- a/ot/ot_test.go +++ b/ot/ot_test.go @@ -125,16 +125,14 @@ func benchmarkOT(sender, receiver OT, batchSize int, b *testing.B) { pipe, rPipe := NewPipe() - b.ResetTimer() - go func(pipe *Pipe) { + err := receiver.InitReceiver(pipe) + if err != nil { + done <- err + pipe.Close() + return + } for i := 0; i < b.N; i++ { - err := receiver.InitReceiver(pipe) - if err != nil { - done <- err - pipe.Close() - return - } err = receiver.Receive(flags, labels) if err != nil { done <- err @@ -161,62 +159,57 @@ func benchmarkOT(sender, receiver OT, batchSize int, b *testing.B) { done <- nil }(rPipe) + err := sender.InitSender(pipe) + if err != nil { + b.Fatalf("InitSender: %v", err) + } + b.ResetTimer() + for i := 0; i < b.N; i++ { - err := sender.InitSender(pipe) - if err != nil { - b.Fatalf("InitSender: %v", err) - } err = sender.Send(wires) if err != nil { b.Fatalf("Send: %v", err) } } - err := <-done + err = <-done if err != nil { b.Errorf("receiver failed: %v", err) } } -func BenchmarkOTCO1(b *testing.B) { +func BenchmarkOTCO_1(b *testing.B) { benchmarkOT(NewCO(), NewCO(), 1, b) } -func XBenchmarkOTCO2(b *testing.B) { - benchmarkOT(NewCO(), NewCO(), 2, b) -} - -func XBenchmarkOTCO4(b *testing.B) { - benchmarkOT(NewCO(), NewCO(), 4, b) -} - -func BenchmarkOTCO8(b *testing.B) { +func BenchmarkOTCO_8(b *testing.B) { benchmarkOT(NewCO(), NewCO(), 8, b) } -func BenchmarkOTCO16(b *testing.B) { +func BenchmarkOTCO_16(b *testing.B) { benchmarkOT(NewCO(), NewCO(), 16, b) } -func BenchmarkOTCO32(b *testing.B) { +func BenchmarkOTCO_32(b *testing.B) { benchmarkOT(NewCO(), NewCO(), 32, b) } -func BenchmarkOTCO64(b *testing.B) { +func BenchmarkOTCO_64(b *testing.B) { benchmarkOT(NewCO(), NewCO(), 64, b) } -func XBenchmarkOTCO128(b *testing.B) { - benchmarkOT(NewCO(), NewCO(), 128, b) -} - func benchmarkOTRSA(keySize, batchSize int, b *testing.B) { benchmarkOT(NewRSA(keySize), NewRSA(keySize), batchSize, b) } -func BenchmarkOTRSA2048_1(b *testing.B) { +func BenchmarkOTRSA_2048_1(b *testing.B) { benchmarkOTRSA(2048, 1, b) } -func BenchmarkOTRSA2048_8(b *testing.B) { + +func BenchmarkOTRSA_2048_8(b *testing.B) { benchmarkOTRSA(2048, 8, b) } + +func BenchmarkOTRSA_2048_64(b *testing.B) { + benchmarkOTRSA(2048, 64, b) +}