Merge pull request #1886 from influxdata/bj-refactor-test-cancellation
fix(cmd/influxd): Refactor test cancellation out of main path.pull/10616/head
commit
846192c066
|
|
@ -115,7 +115,6 @@ func (m *Main) URL() string {
|
|||
|
||||
// Shutdown shuts down the HTTP server and waits for all services to clean up.
|
||||
func (m *Main) Shutdown(ctx context.Context) {
|
||||
m.cancel()
|
||||
m.httpServer.Shutdown(ctx)
|
||||
|
||||
m.logger.Info("Stopping", zap.String("service", "task"))
|
||||
|
|
@ -144,6 +143,9 @@ func (m *Main) Shutdown(ctx context.Context) {
|
|||
m.logger.Sync()
|
||||
}
|
||||
|
||||
// Cancel executes the context cancel on the program. Used for testing.
|
||||
func (m *Main) Cancel() { m.cancel() }
|
||||
|
||||
// Run executes the program with the given CLI arguments.
|
||||
func (m *Main) Run(ctx context.Context, args ...string) error {
|
||||
dir, err := fs.InfluxDir()
|
||||
|
|
|
|||
|
|
@ -137,6 +137,7 @@ func (m *Main) Run(ctx context.Context, args ...string) error {
|
|||
|
||||
// Shutdown stops the program and cleans up temporary paths.
|
||||
func (m *Main) Shutdown(ctx context.Context) error {
|
||||
m.Cancel()
|
||||
m.Main.Shutdown(ctx)
|
||||
return os.RemoveAll(m.Path)
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue