Skip to content

Commit

Permalink
Ensure block-generator service shutdown after failure. (#937)
Browse files Browse the repository at this point in the history
  • Loading branch information
winder authored Mar 17, 2022
1 parent 63c41f9 commit 9bea6c2
Showing 1 changed file with 12 additions and 10 deletions.
22 changes: 12 additions & 10 deletions cmd/block-generator/runner/run.go
Original file line number Diff line number Diff line change
Expand Up @@ -87,11 +87,23 @@ func (r *Args) run() error {
algodNet := fmt.Sprintf("localhost:%d", 11112)
indexerNet := fmt.Sprintf("localhost:%d", r.IndexerPort)
generatorShutdownFunc, generator := startGenerator(r.Path, algodNet, blockMiddleware)
defer func() {
// Shutdown generator.
if err := generatorShutdownFunc(); err != nil {
fmt.Printf("Failed to shutdown generator: %s\n", err)
}
}()

indexerShutdownFunc, err := startIndexer(logfile, r.LogLevel, r.IndexerBinary, algodNet, indexerNet, r.PostgresConnectionString, r.CPUProfilePath)
if err != nil {
return fmt.Errorf("failed to start indexer: %w", err)
}
defer func() {
// Shutdown indexer
if err := indexerShutdownFunc(); err != nil {
fmt.Printf("Failed to shutdown indexer: %s\n", err)
}
}()

// Create the report file
report, err := os.Create(reportfile)
Expand All @@ -118,16 +130,6 @@ func (r *Args) run() error {
}
}

// Shutdown generator.
if err := generatorShutdownFunc(); err != nil {
return err
}

// Shutdown indexer
if err := indexerShutdownFunc(); err != nil {
return err
}

return nil
}

Expand Down

0 comments on commit 9bea6c2

Please sign in to comment.