7490: use loggerutil to log any datamanager errors.
[arvados.git] / services / datamanager / summary / file.go
index 18b3aec8190408897d2857e3e6b2a212936bc21c..63c8adeb745b05b6f8886751cc135b78b0fd8d87 100644 (file)
@@ -22,7 +22,7 @@ type serializedData struct {
 }
 
 var (
-       writeDataTo  string
+       WriteDataTo  string
        readDataFrom string
 )
 
@@ -32,7 +32,7 @@ type DataFetcher func(arvLogger *logger.Logger,
        keepServerInfo *keep.ReadServers)
 
 func init() {
-       flag.StringVar(&writeDataTo,
+       flag.StringVar(&WriteDataTo,
                "write-data-to",
                "",
                "Write summary of data received to this file. Used for development only.")
@@ -51,14 +51,13 @@ func init() {
 // working with stale data.
 func MaybeWriteData(arvLogger *logger.Logger,
        readCollections collection.ReadCollections,
-       keepServerInfo keep.ReadServers) bool {
-       if writeDataTo == "" {
-               return false
+       keepServerInfo keep.ReadServers) error {
+       if WriteDataTo == "" {
+               return nil
        }
-       summaryFile, err := os.Create(writeDataTo)
+       summaryFile, err := os.Create(WriteDataTo)
        if err != nil {
-               loggerutil.FatalWithMessage(arvLogger,
-                       fmt.Sprintf("Failed to open %s: %v", writeDataTo, err))
+               return err
        }
        defer summaryFile.Close()
 
@@ -68,11 +67,10 @@ func MaybeWriteData(arvLogger *logger.Logger,
                KeepServerInfo:  keepServerInfo}
        err = enc.Encode(data)
        if err != nil {
-               loggerutil.FatalWithMessage(arvLogger,
-                       fmt.Sprintf("Failed to write summary data: %v", err))
+               return err
        }
-       log.Printf("Wrote summary data to: %s", writeDataTo)
-       return true
+       log.Printf("Wrote summary data to: %s", WriteDataTo)
+       return nil
 }
 
 // ShouldReadData should not be used outside of development