Function TestValidator

txnpool/proc/txnpool_server_test.go:234–290

(t *testing.T)

}

func TestValidator(t *testing.T) {
	t.Log("Starting validator testing")
	var s *TXPoolServer
	s = NewTxPoolServer(tc.MAX_WORKER_NUM, true, false)
	if s == nil {
		t.Error("Test case: new tx pool server failed")
		return
	}

	defer s.Stop()

	rspActor := NewVerifyRspActor(s)
	rspPid := startActor(rspActor)
	if rspPid == nil {
		t.Error("Fail to start verify rsp actor")
		return
	}
	s.RegisterActor(tc.VerifyRspActor, rspPid)

	statelessV1, err := stateless.NewValidator("stateless1")
	if err != nil {
		t.Error("failed to new stateless valdiator", err)
		return
	}
	statelessV1.Register(rspPid)

	statelessV2, err := stateless.NewValidator("stateless2")
	if err != nil {
		t.Error("failed to new stateless valdiator", err)
		return
	}
	statelessV2.Register(rspPid)

	time.Sleep(1 * time.Second)

	ret := s.getNextValidatorPIDs()
	for _, v := range ret {
		assert.NotNil(t, v)
	}

	ret = s.getNextValidatorPIDs()
	for _, v := range ret {
		assert.NotNil(t, v)
	}

	statelessV1.UnRegister(rspPid)
	statelessV2.UnRegister(rspPid)

	time.Sleep(1 * time.Second)

	ret = s.getNextValidatorPIDs()
	for _, v := range ret {
		assert.NotNil(t, v)
	}

	t.Log("Ending validator testing")
}