add more logging to shutdown process

janelia-flyem · May 29, 2024 · daec88c · daec88c
1 parent 2976699
commit daec88c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/storage/kafka.go b/storage/kafka.go
@@ -116,6 +116,9 @@ func KafkaShutdown() {
 		} else {
 			dvid.Infof("Successfully shut down kafka producer.\n")
 		}
+		dvid.Infof("Kafka closed.")
+	} else {
+		dvid.Infof("Kafka producer was nil so unnecessary to close.")
 	}
 }
 

diff --git a/storage/storage_local.go b/storage/storage_local.go
@@ -338,6 +338,7 @@ func Shutdown() {
 			store.Close()
 		}
 		manager.setup = false
+		dvid.Infof("Finished closing all stores.\n")
 	}
 	KafkaShutdown()
 	manager = managerT{}