Skip to content

Commit a088d71

Browse files
authored
fix: fire storage deal provider ready event after startup completes (#708)
1 parent f7eaf66 commit a088d71

File tree

1 file changed

+12
-5
lines changed

1 file changed

+12
-5
lines changed

storagemarket/impl/provider.go

Lines changed: 12 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -763,13 +763,20 @@ func (p *Provider) dispatch(eventName fsm.EventName, deal fsm.StateType) {
763763
}
764764
}
765765

766-
func (p *Provider) start(ctx context.Context) error {
766+
func (p *Provider) start(ctx context.Context) (err error) {
767+
defer func() {
768+
publishErr := p.readyMgr.FireReady(err)
769+
if publishErr != nil {
770+
if err != nil {
771+
log.Warnf("failed to publish storage provider ready event with err %s: %s", err, publishErr)
772+
} else {
773+
log.Warnf("failed to publish storage provider ready event: %s", publishErr)
774+
}
775+
}
776+
}()
777+
767778
// Run datastore and DAG store migrations
768779
deals, err := p.runMigrations(ctx)
769-
publishErr := p.readyMgr.FireReady(err)
770-
if publishErr != nil {
771-
log.Warnf("publish storage provider ready event: %s", err.Error())
772-
}
773780
if err != nil {
774781
return err
775782
}

0 commit comments

Comments
 (0)