diff options
| -rw-r--r-- | xeth/xeth.go | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/xeth/xeth.go b/xeth/xeth.go index 565e96412..4bab92904 100644 --- a/xeth/xeth.go +++ b/xeth/xeth.go @@ -29,12 +29,12 @@ var ( ) type XEth struct { - backend *eth.Ethereum + backend *eth.Ethereum + frontend Frontend + state *State whisper *Whisper - frontend Frontend - quit chan struct{} filterManager *filter.FilterManager @@ -47,7 +47,6 @@ type XEth struct { // regmut sync.Mutex // register map[string][]*interface{} // TODO improve return type - // Miner agent agent *miner.RemoteAgent } @@ -57,10 +56,10 @@ type XEth struct { func New(eth *eth.Ethereum, frontend Frontend) *XEth { xeth := &XEth{ backend: eth, + frontend: frontend, whisper: NewWhisper(eth.Whisper()), quit: make(chan struct{}), filterManager: filter.NewFilterManager(eth.EventMux()), - frontend: frontend, logs: make(map[int]*logFilter), messages: make(map[int]*whisperFilter), agent: miner.NewRemoteAgent(), @@ -71,6 +70,7 @@ func New(eth *eth.Ethereum, frontend Frontend) *XEth { xeth.frontend = dummyFrontend{} } xeth.state = NewState(xeth, xeth.backend.ChainManager().TransState()) + go xeth.start() go xeth.filterManager.Start() @@ -144,6 +144,7 @@ func (self *XEth) WithState(statedb *state.StateDB) *XEth { xeth.state = NewState(xeth, statedb) return xeth } + func (self *XEth) State() *State { return self.state } func (self *XEth) Whisper() *Whisper { return self.whisper } |