Function BenchmarkMuxParallel

xenomint/mux_test.go:200–252

(b *testing.B)

}

func BenchmarkMuxParallel(b *testing.B) {
	var bp, s, ms, r = setupBenchmarkMuxParallel(b)
	defer teardownBenchmarkMuxParallel(bp.server, s.server)
	var benchmarks = []struct {
		name string
		kg   keygen
	}{
		{
			name: "Write",
			kg:   newKeyPermKeygen,
		}, {
			name: "MixRW",
			kg:   allKeyPermKeygen,
		},
	}
	for _, bm := range benchmarks {
		b.Run(bm.name, func(b *testing.B) {
			var (
				counter int32
				c       *Chain
			)

			c = setupBenchmarkChain(b)
			ms.register(benchmarkDatabaseID, c)
			b.ResetTimer()
			defer func() {
				b.StopTimer()
				ms.unregister(benchmarkDatabaseID)
				teardownBenchmarkChain(b, c)
			}()

			b.RunParallel(func(pb *testing.PB) {
				var (
					err    error
					method = fmt.Sprintf("%s.%s", benchmarkRPCName, "Query")
					caller = rpc.NewPersistentCaller(s.node.ID)
				)
				for pb.Next() {
					if err = caller.Call(
						method, &r[bm.kg.next()], &MuxQueryResponse{},
					); err != nil {
						b.Fatalf("failed to execute: %v", err)
					}
					if atomic.AddInt32(&counter, 1)%benchmarkQueriesPerBlock == 0 {
						if err = c.state.commit(); err != nil {
							b.Fatalf("failed to commit block: %v", err)
						}
					}
				}
			})
		})
	}
}

func TestMuxService(t *testing.T) {
	Convey("test xenomint MuxService", t, func() {