Function BenchmarkRuntime

kayak/runtime_test.go:554–737

(b *testing.B)

}

func BenchmarkRuntime(b *testing.B) {
	Convey("runtime test", b, func(c C) {
		log.SetLevel(log.FatalLevel)
		f, err := os.OpenFile("test.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0600)
		So(err, ShouldBeNil)
		log.SetOutput(f)
		defer f.Close()

		db1, err := newSQLiteStorage("test1.db")
		So(err, ShouldBeNil)
		defer func() {
			db1.Close()
			os.Remove("test1.db")
		}()
		db2, err := newSQLiteStorage("test2.db")
		So(err, ShouldBeNil)
		defer func() {
			db2.Close()
			os.Remove("test2.db")
		}()

		node1 := proto.NodeID("000005aa62048f85da4ae9698ed59c14ec0d48a88a07c15a32265634e7e64ade")
		node2 := proto.NodeID("000005f4f22c06f76c43c4f48d5a7ec1309cc94030cbf9ebae814172884ac8b5")

		peers := &proto.Peers{
			PeersHeader: proto.PeersHeader{
				Leader: node1,
				Servers: []proto.NodeID{
					node1,
					node2,
				},
			},
		}

		privKey, _, err := asymmetric.GenSecp256k1KeyPair()
		So(err, ShouldBeNil)
		err = peers.Sign(privKey)
		So(err, ShouldBeNil)

		wal1 := kl.NewMemWal()
		defer wal1.Close()
		cfg1 := &kt.RuntimeConfig{
			Handler:          db1,
			PrepareThreshold: 1.0,
			CommitThreshold:  0.0,
			PrepareTimeout:   time.Second,
			CommitTimeout:    10 * time.Second,
			LogWaitTimeout:   10 * time.Second,
			Peers:            peers,
			Wal:              wal1,
			NodeID:           node1,
			ServiceName:      "Test",
			ApplyMethodName:  "Apply",
		}
		rt1, err := kayak.NewRuntime(cfg1)
		So(err, ShouldBeNil)

		wal2 := kl.NewMemWal()