diff options
| author | obscuren <geffobscura@gmail.com> | 2014-12-15 19:34:06 +0800 |
|---|---|---|
| committer | obscuren <geffobscura@gmail.com> | 2014-12-15 19:34:06 +0800 |
| commit | 96272e19a6b7a3163ec53f45e04407e9d2ff8414 (patch) | |
| tree | 5ee02c968d824bc33790d992b63d107be3bbb6ac /eth/backend.go | |
| parent | bd9088792b0a7bcac00f28289a08bd1b8359316f (diff) | |
| download | go-tangerine-96272e19a6b7a3163ec53f45e04407e9d2ff8414.tar.gz go-tangerine-96272e19a6b7a3163ec53f45e04407e9d2ff8414.tar.zst go-tangerine-96272e19a6b7a3163ec53f45e04407e9d2ff8414.zip | |
removed filter manager from base
Diffstat (limited to 'eth/backend.go')
| -rw-r--r-- | eth/backend.go | 15 |
1 files changed, 0 insertions, 15 deletions
diff --git a/eth/backend.go b/eth/backend.go index fb401a68d..3ec36d3fc 100644 --- a/eth/backend.go +++ b/eth/backend.go @@ -9,7 +9,6 @@ import ( "github.com/ethereum/go-ethereum/crypto" "github.com/ethereum/go-ethereum/ethutil" "github.com/ethereum/go-ethereum/event" - "github.com/ethereum/go-ethereum/event/filter" ethlogger "github.com/ethereum/go-ethereum/logger" "github.com/ethereum/go-ethereum/p2p" "github.com/ethereum/go-ethereum/pow/ezp" @@ -53,11 +52,6 @@ type Ethereum struct { synclock sync.Mutex syncGroup sync.WaitGroup - filterManager *filter.FilterManager - //filterMu sync.RWMutex - //filterId int - //filters map[int]*core.Filter - Mining bool } @@ -81,7 +75,6 @@ func New(db ethutil.Database, identity p2p.ClientIdentity, keyManager *crypto.Ke eth.blockManager = core.NewBlockManager(eth) eth.chainManager.SetProcessor(eth.blockManager) eth.whisper = whisper.New() - eth.filterManager = filter.NewFilterManager(eth.EventMux()) hasBlock := eth.chainManager.HasBlock insertChain := eth.chainManager.InsertChain @@ -163,7 +156,6 @@ func (s *Ethereum) Start(seed bool) error { } s.blockPool.Start() s.whisper.Start() - s.filterManager.Start() // broadcast transactions s.txSub = s.eventMux.Subscribe(core.TxPreEvent{}) @@ -264,10 +256,3 @@ func saveProtocolVersion(db ethutil.Database) { db.Put([]byte("ProtocolVersion"), ethutil.NewValue(ProtocolVersion).Bytes()) } } - -// XXX Refactor me & MOVE -func (self *Ethereum) InstallFilter(filter *core.Filter) (id int) { - return self.filterManager.InstallFilter(filter) -} -func (self *Ethereum) UninstallFilter(id int) { self.filterManager.UninstallFilter(id) } -func (self *Ethereum) GetFilter(id int) *core.Filter { return self.filterManager.GetFilter(id) } |