aboutsummaryrefslogtreecommitdiffstats
path: root/blockpool/test/hash_pool.go
diff options
context:
space:
mode:
Diffstat (limited to 'blockpool/test/hash_pool.go')
-rw-r--r--blockpool/test/hash_pool.go32
1 files changed, 15 insertions, 17 deletions
diff --git a/blockpool/test/hash_pool.go b/blockpool/test/hash_pool.go
index 4e0332d7d..df3c750f9 100644
--- a/blockpool/test/hash_pool.go
+++ b/blockpool/test/hash_pool.go
@@ -3,20 +3,10 @@ package test
import (
"sync"
+ "github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/crypto"
)
-// test helpers
-// TODO: move into common test helper package (see p2p/crypto etc.)
-
-func NewHashPool() *TestHashPool {
- return &TestHashPool{intToHash: make(intToHash), hashToInt: make(hashToInt)}
-}
-
-type intToHash map[int][]byte
-
-type hashToInt map[string]int
-
// hashPool is a test helper, that allows random hashes to be referred to by integers
type TestHashPool struct {
intToHash
@@ -24,11 +14,19 @@ type TestHashPool struct {
lock sync.Mutex
}
-func newHash(i int) []byte {
- return crypto.Sha3([]byte(string(i)))
+func NewHashPool() *TestHashPool {
+ return &TestHashPool{intToHash: make(intToHash), hashToInt: make(hashToInt)}
+}
+
+type intToHash map[int]common.Hash
+
+type hashToInt map[common.Hash]int
+
+func newHash(i int) common.Hash {
+ return common.BytesToHash(crypto.Sha3([]byte(string(i))))
}
-func (self *TestHashPool) IndexesToHashes(indexes []int) (hashes [][]byte) {
+func (self *TestHashPool) IndexesToHashes(indexes []int) (hashes []common.Hash) {
self.lock.Lock()
defer self.lock.Unlock()
for _, i := range indexes {
@@ -36,18 +34,18 @@ func (self *TestHashPool) IndexesToHashes(indexes []int) (hashes [][]byte) {
if !found {
hash = newHash(i)
self.intToHash[i] = hash
- self.hashToInt[string(hash)] = i
+ self.hashToInt[hash] = i
}
hashes = append(hashes, hash)
}
return
}
-func (self *TestHashPool) HashesToIndexes(hashes [][]byte) (indexes []int) {
+func (self *TestHashPool) HashesToIndexes(hashes []common.Hash) (indexes []int) {
self.lock.Lock()
defer self.lock.Unlock()
for _, hash := range hashes {
- i, found := self.hashToInt[string(hash)]
+ i, found := self.hashToInt[hash]
if !found {
i = -1
}