diff options
author | obscuren <geffobscura@gmail.com> | 2015-03-21 01:01:05 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2015-03-21 01:01:05 +0800 |
commit | f4e9638867f5dab01eeb6db5fdbd85737a11fbd6 (patch) | |
tree | 8d8cbfeb2533a2b84e5f0927e9bfdd688cdffbb2 /blockpool/test/hash_pool.go | |
parent | 54dac59285ccc6a3af47201479ca556da2899e93 (diff) | |
parent | ecd10d2cf765072cd74347b9e0ca2bb85091450f (diff) | |
download | dexon-f4e9638867f5dab01eeb6db5fdbd85737a11fbd6.tar.gz dexon-f4e9638867f5dab01eeb6db5fdbd85737a11fbd6.tar.zst dexon-f4e9638867f5dab01eeb6db5fdbd85737a11fbd6.zip |
Merge branch 'ethersphere-frontier/blockpool' into conversion
Diffstat (limited to 'blockpool/test/hash_pool.go')
-rw-r--r-- | blockpool/test/hash_pool.go | 32 |
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 } |