minor PR feedback refactor
parent
a3bf3e2ef1
commit
4d30ea1eb3
|
@ -370,11 +370,8 @@ func (e *Engine) readFileFromBackup(tr *tar.Reader, shardRelativePath string) er
|
|||
// Sync to disk & close.
|
||||
if err := f.Sync(); err != nil {
|
||||
return err
|
||||
} else if err := f.Close(); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
return f.Close()
|
||||
}
|
||||
|
||||
// addToIndexFromKey will pull the measurement name, series key, and field name from a composite key and add it to the
|
||||
|
|
|
@ -558,11 +558,7 @@ func (s *Shard) Restore(r io.Reader, basePath string) error {
|
|||
}
|
||||
|
||||
// Reopen engine.
|
||||
if err := s.Open(); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
return s.Open()
|
||||
}
|
||||
|
||||
// Shards represents a sortable list of shards.
|
||||
|
|
Loading…
Reference in New Issue