mkadilov/frostfs-node
1
0
Fork 0
forked from TrueCloudLab/frostfs-node
Code Pull requests Activity

[#324] ir: Register block handler before starting the listening routine

Browse source 
Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
This commit is contained in:
Leonard Lyubich 2021-01-25 16:47:01 +03:00 committed by Alex Vanin
parent 44c899b560
commit abc7885056
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
pkg/innerring/innerring.go
View file

@ -118,9 +118,6 @@ func (s *Server) Start(ctx context.Context, intError chan<- error) error {
} }
}() }()
go s.morphListener.ListenWithError(ctx, morphErr) // listen for neo:morph events
go s.mainnetListener.ListenWithError(ctx, mainnnetErr) // listen for neo:mainnet events
s.morphListener.RegisterBlockHandler(func(b *block.Block) { s.morphListener.RegisterBlockHandler(func(b *block.Block) {
s.log.Debug("new block", s.log.Debug("new block",
zap.Uint32("index", b.Index), zap.Uint32("index", b.Index),
@ -129,6 +126,9 @@ func (s *Server) Start(ctx context.Context, intError chan<- error) error {
s.tickTimers() s.tickTimers()
}) })
go s.morphListener.ListenWithError(ctx, morphErr) // listen for neo:morph events
go s.mainnetListener.ListenWithError(ctx, mainnnetErr) // listen for neo:mainnet events
if err := s.startBlockTimers(); err != nil { if err := s.startBlockTimers(); err != nil {
return errors.Wrap(err, "could not start block timers") return errors.Wrap(err, "could not start block timers")
} }