Function BenchmarkChainParallelWrite

xenomint/chain_test.go:169–189

(b *testing.B)

}

func BenchmarkChainParallelWrite(b *testing.B) {
	var r = setupBenchmarkChainRequest(b)
	var c = setupBenchmarkChain(b)
	b.RunParallel(func(pb *testing.PB) {
		var (
			err     error
			counter int32
		)
		for pb.Next() {
			if _, err = c.Query(r[newKeyPermKeygen.next()]); 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)
				}
			}
		}
	})
	teardownBenchmarkChain(b, c)
}

func BenchmarkChainParallelMixRW(b *testing.B) {
	var r = setupBenchmarkChainRequest(b)