Remove storage dir in case of processExitError

stellar · Jun 16, 2021 · 3d28e9e · 3d28e9e
1 parent ed5e878
commit 3d28e9e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/ingest/ledgerbackend/stellar_core_runner.go b/ingest/ledgerbackend/stellar_core_runner.go
@@ -472,9 +472,11 @@ func (r *stellarCoreRunner) close() error {
 		r.pipe.Reader.Close()
 	}
 
-	if runtime.GOOS == "windows" {
+	if runtime.GOOS == "windows" || r.processExitError != nil {
 		// It's impossible to send SIGINT on Windows so buckets can become
 		// corrupted. If we can't reuse it, then remove it.
+		// We also remove the storage path if there was an error terminating the
+		// process (files can be corrupted).
 		return os.RemoveAll(storagePath)
 	}