Function setupBenchmarkMuxParallel

xenomint/mux_test.go:133–192

(b *testing.B)

}

func setupBenchmarkMuxParallel(b *testing.B) (
	bp, miner *nodeRPCInfo, ms *MuxService, r []*MuxQueryRequest,
) {
	var err error
	var priv *ca.PrivateKey
	// Use testing private key to create several nodes
	if priv, err = kms.GetLocalPrivateKey(); err != nil {
		b.Fatalf("failed to setup bench environment: %v", err)
	}

	bp, miner, ms, err = setupMuxParallel(priv)
	if err != nil {
		b.Fatalf("failed to setup bench environment: %v", err)
	}

	// Setup query requests
	var (
		sel = `SELECT v1, v2, v3 FROM bench WHERE k=?`
		ins = `INSERT INTO bench VALUES (?, ?, ?, ?)`
		src = make([][]interface{}, benchmarkNewKeyLength)
	)
	r = make([]*MuxQueryRequest, benchmarkMaxKey)
	// Read query key space [0, n-1]
	for i := 0; i < benchmarkReservedKeyLength; i++ {
		var req = buildRequest(types.ReadQuery, []types.Query{
			buildQuery(sel, i+benchmarkReservedKeyOffset),
		})
		if err = req.Sign(priv); err != nil {
			b.Fatalf("failed to setup bench environment: %v", err)
		}
		r[i] = &MuxQueryRequest{
			DatabaseID: benchmarkDatabaseID,
			Request:    req,
		}
	}
	// Write query key space [n, 2n-1]
	for i := range src {
		var vals [benchmarkVNum][benchmarkVLen]byte
		src[i] = make([]interface{}, benchmarkVNum+1)
		src[i][0] = i + benchmarkNewKeyOffset
		for j := range vals {
			rand.Read(vals[j][:])
			src[i][j+1] = string(vals[j][:])
		}
	}
	for i := 0; i < benchmarkNewKeyLength; i++ {
		var req = buildRequest(types.WriteQuery, []types.Query{
			buildQuery(ins, src[i]...),
		})
		if err = req.Sign(priv); err != nil {
			b.Fatalf("failed to setup bench environment: %v", err)
		}
		r[i+benchmarkNewKeyOffset] = &MuxQueryRequest{
			DatabaseID: benchmarkDatabaseID,
			Request:    req,
		}
	}