LBRYCommunity/lbcd
1
0
Fork 0
Code Issues 17 Pull requests 4 Projects Releases 28 Packages Wiki Activity

Move filter generating code to CBF indexer

Browse source
This commit is contained in:
pedro martelletto 2017-01-11 16:09:08 +00:00 • committed by Olaoluwa Osuntokun
parent 95cbe2a911
commit b2990e7999
2 changed files with 27 additions and 39 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
blockchain/indexers/cbfindex.go
View file

@ -5,11 +5,13 @@
package indexers
import (
"encoding/binary"
"errors"
"github.com/btcsuite/btcd/blockchain"
"github.com/btcsuite/btcd/database"
"github.com/btcsuite/btcutil"
"github.com/btcsuite/btcutil/gcs"
)
const (
@ -82,6 +84,29 @@ func (idx *CBFIndex) Create(dbTx database.Tx) error {
//
// This is part of the Indexer interface.
func (idx *CBFIndex) ConnectBlock(dbTx database.Tx, block *btcutil.Block, view *blockchain.UtxoViewpoint) error {
txSlice := block.Transactions() // XXX can this fail?
txHashes := make([][]byte, len(txSlice))
for i := 0; i < len(txSlice); i++ {
txHash, err := block.TxHash(i)
if err != nil {
return err
}
txHashes = append(txHashes, txHash.CloneBytes())
}
var key [gcs.KeySize]byte
P := uint8(20) // collision probability
for i := 0; i < gcs.KeySize; i += 4 {
binary.BigEndian.PutUint32(key[i:], uint32(0xcafebabe))
}
_, err := gcs.BuildGCSFilter(P, key, txHashes)
if err != nil {
return err
}
return nil
}

41
server.go
View file

@ -38,7 +38,6 @@ import (
"github.com/btcsuite/btcd/wire"
"github.com/btcsuite/btcutil"
"github.com/btcsuite/btcutil/bloom"
"github.com/btcsuite/btcutil/gcs"
)
const (
@ -746,44 +745,8 @@ func (sp *serverPeer) OnGetCBFilter(_ *peer.Peer, msg *wire.MsgGetCBFilter) {
return
}
chain := sp.server.blockManager.chain
block, err := chain.BlockByHash(&msg.BlockHash)
if err != nil {
peerLog.Warnf("failed to get block %v: %v", msg.BlockHash, err)
return
}
txSlice := block.Transactions() // XXX can this fail?
txHashes := make([][]byte, len(txSlice))
for i := 0; i < len(txSlice); i++ {
txHash, err := block.TxHash(i)
if err != nil {
peerLog.Warnf("failed to get hash of tx %v of block %v",
i, msg.BlockHash)
return
}
txHashes = append(txHashes, txHash.CloneBytes())
peerLog.Warnf("got hash %v", txHash)
}
var key [gcs.KeySize]byte
P := uint8(20) // collision probability
for i := 0; i < gcs.KeySize; i += 4 {
binary.BigEndian.PutUint32(key[i:], uint32(0xcafebabe))
}
filter, err := gcs.BuildGCSFilter(P, key, txHashes)
if err != nil {
peerLog.Warnf("failed to generate filter for block %v",
msg.BlockHash)
return
}
// XXX pedro: work in progress
peerLog.Warnf("received OnGetCBFilter: %v", block)
peerLog.Warnf("received OnGetCBFilter: %v", filter)
// XXX work in progress
peerLog.Warnf("received OnGetCBFilter: not yet")
}
// enforceNodeBloomFlag disconnects the peer if the server is not configured to