|
@ -55,7 +55,6 @@ type Reactor struct { |
|
|
service.BaseService |
|
|
service.BaseService |
|
|
|
|
|
|
|
|
evpool *Pool |
|
|
evpool *Pool |
|
|
eventBus *types.EventBus |
|
|
|
|
|
evidenceCh *p2p.Channel |
|
|
evidenceCh *p2p.Channel |
|
|
peerUpdates *p2p.PeerUpdates |
|
|
peerUpdates *p2p.PeerUpdates |
|
|
closeCh chan struct{} |
|
|
closeCh chan struct{} |
|
@ -87,11 +86,6 @@ func NewReactor( |
|
|
return r |
|
|
return r |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// SetEventBus implements events.Eventable.
|
|
|
|
|
|
func (r *Reactor) SetEventBus(b *types.EventBus) { |
|
|
|
|
|
r.eventBus = b |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// OnStart starts separate go routines for each p2p Channel and listens for
|
|
|
// OnStart starts separate go routines for each p2p Channel and listens for
|
|
|
// envelopes on each. In addition, it also listens for peer updates and handles
|
|
|
// envelopes on each. In addition, it also listens for peer updates and handles
|
|
|
// messages on that p2p channel accordingly. The caller must be sure to execute
|
|
|
// messages on that p2p channel accordingly. The caller must be sure to execute
|
|
|