Function TestHeaderVerification

core/block_validator_test.go:32–82

Tests that simple header verification works, for both good and bad blocks.

(t *testing.T)

// Tests that simple header verification works, for both good and bad blocks.
func TestHeaderVerification(t *testing.T) {
	testdb := database.NewMemDatabase()
	genesis := DefaultGenesisBlock()
	genesisBlock := genesis.MustCommit(testdb)

	remoteDB := database.NewIpfsDbWithAdapter(database.NewFakeIpfsAdapter())

	config := configs.ChainConfigInfo().Dpor
	d := dpor.NewFaker(config, testdb)

	blocks, _ := GenerateChain(genesis.Config, genesisBlock, d, testdb, remoteDB, 8, nil)

	headers := make([]*types.Header, len(blocks))
	for i, block := range blocks {
		headers[i] = block.Header()
	}
	// Run the header checker for blocks one-by-one, checking for both valid and invalid nonces
	chain, _ := NewBlockChain(testdb, nil, genesis.Config, d, vm.Config{}, remoteDB, nil)
	defer chain.Stop()

	for i := 0; i < len(blocks); i++ {
		for j, valid := range []bool{true, false} {
			var results <-chan error

			if valid {
				engine := dpor.NewFaker(config, testdb)
				_, results = engine.VerifyHeaders(chain, []*types.Header{headers[i]}, []bool{true}, []*types.Header{headers[i]})
			} else {
				// engine := dpor.New(config, testdb)
				engine := dpor.NewFakeFailer(config, testdb, headers[i].Number.Uint64())
				_, results = engine.VerifyHeaders(chain, []*types.Header{headers[i]}, []bool{true}, []*types.Header{headers[i]})
			}
			// Wait for the verification result
			select {
			case result := <-results:
				if (result == nil) != valid {
					t.Errorf("test %d.%d: validity mismatch: have %v, want %v", i, j, result, valid)
				}
			case <-time.After(time.Second):
				t.Fatalf("test %d.%d: verification timeout", i, j)
			}
			// Make sure no more data is returned
			select {
			case result := <-results:
				t.Fatalf("test %d.%d: unexpected result returned: %v", i, j, result)
			case <-time.After(25 * time.Millisecond):
			}
		}
		chain.InsertChain(blocks[i : i+1])
	}
}

// Tests that concurrent header verification works, for both good and bad blocks.
func TestHeaderConcurrentVerification2(t *testing.T) {