good morning!!!!

Skip to content
Snippets Groups Projects
Unverified Commit d912c992 authored by ledgerwatch's avatar ledgerwatch Committed by GitHub
Browse files

No prefetch on remote cursors in RPC daemon (#1201)

parent 1af6cbe3
No related branches found
Tags v0.2.2
No related merge requests found
...@@ -3,6 +3,8 @@ package commands ...@@ -3,6 +3,8 @@ package commands
import ( import (
"context" "context"
"fmt" "fmt"
"math/big"
"github.com/RoaringBitmap/roaring" "github.com/RoaringBitmap/roaring"
"github.com/ledgerwatch/turbo-geth/common" "github.com/ledgerwatch/turbo-geth/common"
"github.com/ledgerwatch/turbo-geth/common/dbutils" "github.com/ledgerwatch/turbo-geth/common/dbutils"
...@@ -16,7 +18,6 @@ import ( ...@@ -16,7 +18,6 @@ import (
"github.com/ledgerwatch/turbo-geth/ethdb/bitmapdb" "github.com/ledgerwatch/turbo-geth/ethdb/bitmapdb"
"github.com/ledgerwatch/turbo-geth/turbo/adapter" "github.com/ledgerwatch/turbo-geth/turbo/adapter"
"github.com/ledgerwatch/turbo-geth/turbo/transactions" "github.com/ledgerwatch/turbo-geth/turbo/transactions"
"math/big"
) )
func getReceipts(ctx context.Context, tx rawdb.DatabaseReader, kv ethdb.KV, number uint64, hash common.Hash) (types.Receipts, error) { func getReceipts(ctx context.Context, tx rawdb.DatabaseReader, kv ethdb.KV, number uint64, hash common.Hash) (types.Receipts, error) {
...@@ -108,7 +109,7 @@ func (api *APIImpl) GetLogs(ctx context.Context, crit filters.FilterCriteria) ([ ...@@ -108,7 +109,7 @@ func (api *APIImpl) GetLogs(ctx context.Context, crit filters.FilterCriteria) ([
blockNumbers := roaring.New() blockNumbers := roaring.New()
blockNumbers.AddRange(begin, end+1) // [min,max) blockNumbers.AddRange(begin, end+1) // [min,max)
topicsBitmap, err := getTopicsBitmap(tx.(ethdb.HasTx).Tx().Cursor(dbutils.LogTopicIndex).Prefetch(1), crit.Topics, uint32(begin), uint32(end)) topicsBitmap, err := getTopicsBitmap(tx.(ethdb.HasTx).Tx().Cursor(dbutils.LogTopicIndex), crit.Topics, uint32(begin), uint32(end))
if err != nil { if err != nil {
return nil, err return nil, err
} }
...@@ -120,7 +121,7 @@ func (api *APIImpl) GetLogs(ctx context.Context, crit filters.FilterCriteria) ([ ...@@ -120,7 +121,7 @@ func (api *APIImpl) GetLogs(ctx context.Context, crit filters.FilterCriteria) ([
} }
} }
logAddrIndex := tx.(ethdb.HasTx).Tx().Cursor(dbutils.LogAddressIndex).Prefetch(1) logAddrIndex := tx.(ethdb.HasTx).Tx().Cursor(dbutils.LogAddressIndex)
var addrBitmap *roaring.Bitmap var addrBitmap *roaring.Bitmap
for _, addr := range crit.Addresses { for _, addr := range crit.Addresses {
m, err := bitmapdb.Get(logAddrIndex, addr[:], uint32(begin), uint32(end)) m, err := bitmapdb.Get(logAddrIndex, addr[:], uint32(begin), uint32(end))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment