diff options
| -rw-r--r-- | weed-fs/src/pkg/directory/volume_mapping.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed-fs/src/pkg/directory/volume_mapping.go b/weed-fs/src/pkg/directory/volume_mapping.go index ffc90ec7d..e9a0647e5 100644 --- a/weed-fs/src/pkg/directory/volume_mapping.go +++ b/weed-fs/src/pkg/directory/volume_mapping.go @@ -39,7 +39,8 @@ func NewMapper(dirname string, filename string, capacity int) (m *Mapper) { log.Println("Mapping File Read", e) } else { decoder := gob.NewDecoder(dataFile) - decoder.Decode(m.Machines) + defer dataFile.Close() + decoder.Decode(&m.Machines) for _, list := range m.Machines { //TODO: what if a list has mixed readers and writers? Now it's treated as readonly allCanWrite := false @@ -50,7 +51,6 @@ func NewMapper(dirname string, filename string, capacity int) (m *Mapper) { m.writers = append(m.writers, list) } } - dataFile.Close() log.Println("Loaded mapping size", len(m.Machines)) } return |