diff options
author | obscuren <geffobscura@gmail.com> | 2014-12-15 19:08:10 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2014-12-15 19:17:33 +0800 |
commit | cdb2ebbdfa510294b8443e33c32f9e0ec414f78e (patch) | |
tree | 6f14fbe9f5042cc1ce0b6567e0a1a77d43284766 /event/filter | |
parent | 4b5ad31b3ab8e1370233be6479e7476bc0019080 (diff) | |
download | go-tangerine-cdb2ebbdfa510294b8443e33c32f9e0ec414f78e.tar go-tangerine-cdb2ebbdfa510294b8443e33c32f9e0ec414f78e.tar.gz go-tangerine-cdb2ebbdfa510294b8443e33c32f9e0ec414f78e.tar.bz2 go-tangerine-cdb2ebbdfa510294b8443e33c32f9e0ec414f78e.tar.lz go-tangerine-cdb2ebbdfa510294b8443e33c32f9e0ec414f78e.tar.xz go-tangerine-cdb2ebbdfa510294b8443e33c32f9e0ec414f78e.tar.zst go-tangerine-cdb2ebbdfa510294b8443e33c32f9e0ec414f78e.zip |
Added old filter. Needs some refactoring
Diffstat (limited to 'event/filter')
-rw-r--r-- | event/filter/old_filter.go | 94 |
1 files changed, 94 insertions, 0 deletions
diff --git a/event/filter/old_filter.go b/event/filter/old_filter.go new file mode 100644 index 000000000..1a9a88173 --- /dev/null +++ b/event/filter/old_filter.go @@ -0,0 +1,94 @@ +// XXX This is the old filter system specifically for messages. This is till in used and could use some refactoring +package filter + +import ( + "sync" + + "github.com/ethereum/go-ethereum/core" + "github.com/ethereum/go-ethereum/event" + "github.com/ethereum/go-ethereum/state" +) + +type FilterManager struct { + eventMux *event.TypeMux + + filterMu sync.RWMutex + filterId int + filters map[int]*core.Filter + + quit chan struct{} +} + +func NewFilterManager(mux *event.TypeMux) *FilterManager { + return &FilterManager{ + eventMux: mux, + filters: make(map[int]*core.Filter), + } +} + +func (self *FilterManager) Start() { + go self.filterLoop() +} + +func (self *FilterManager) Stop() { + close(self.quit) +} + +func (self *FilterManager) InstallFilter(filter *core.Filter) (id int) { + self.filterMu.Lock() + id = self.filterId + self.filters[id] = filter + self.filterId++ + self.filterMu.Unlock() + return id +} + +func (self *FilterManager) UninstallFilter(id int) { + self.filterMu.Lock() + delete(self.filters, id) + self.filterMu.Unlock() +} + +// GetFilter retrieves a filter installed using InstallFilter. +// The filter may not be modified. +func (self *FilterManager) GetFilter(id int) *core.Filter { + self.filterMu.RLock() + defer self.filterMu.RUnlock() + return self.filters[id] +} + +func (self *FilterManager) filterLoop() { + // Subscribe to events + events := self.eventMux.Subscribe(core.NewBlockEvent{}, state.Messages(nil)) + +out: + for { + select { + case <-self.quit: + break out + case event := <-events.Chan(): + switch event := event.(type) { + case core.NewBlockEvent: + self.filterMu.RLock() + for _, filter := range self.filters { + if filter.BlockCallback != nil { + filter.BlockCallback(event.Block) + } + } + self.filterMu.RUnlock() + + case state.Messages: + self.filterMu.RLock() + for _, filter := range self.filters { + if filter.MessageCallback != nil { + msgs := filter.FilterMessages(event) + if len(msgs) > 0 { + filter.MessageCallback(msgs) + } + } + } + self.filterMu.RUnlock() + } + } + } +} |